[SELC-5434] feat: split csv aggregate API for some product

apps/onboarding-cdc/.factorypath

@@ -0,0 +1,47 @@
+<factorypath>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/mapstruct/mapstruct-processor/1.5.5.Final/mapstruct-processor-1.5.5.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/projectlombok/lombok/1.18.28/lombok-1.18.28.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/projectlombok/lombok-mapstruct-binding/0.2.0/lombok-mapstruct-binding-0.2.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-panache-common/3.5.2/quarkus-panache-common-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-core/3.5.2/quarkus-core-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/annotation/jakarta.annotation-api/2.1.1/jakarta.annotation-api-2.1.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/enterprise/jakarta.enterprise.cdi-api/4.0.1/jakarta.enterprise.cdi-api-4.0.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/enterprise/jakarta.enterprise.lang-model/4.0.1/jakarta.enterprise.lang-model-4.0.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/el/jakarta.el-api/5.0.0/jakarta.el-api-5.0.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/interceptor/jakarta.interceptor-api/2.1.0/jakarta.interceptor-api-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/inject/jakarta.inject-api/2.0.1/jakarta.inject-api-2.0.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-os/2.1.2/smallrye-common-os-2.1.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-ide-launcher/3.5.2/quarkus-ide-launcher-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-development-mode-spi/3.5.2/quarkus-development-mode-spi-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/config/smallrye-config/3.4.4/smallrye-config-3.4.4.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/config/smallrye-config-core/3.4.4/smallrye-config-core-3.4.4.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/eclipse/microprofile/config/microprofile-config-api/3.0.3/microprofile-config-api-3.0.3.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-annotation/2.2.0/smallrye-common-annotation-2.2.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-classloader/2.2.0/smallrye-common-classloader-2.2.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/ow2/asm/asm/9.5/asm-9.5.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/config/smallrye-config-common/3.4.4/smallrye-config-common-3.4.4.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/jboss/logging/jboss-logging/3.5.3.Final/jboss-logging-3.5.3.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/jboss/logmanager/jboss-logmanager/3.0.2.Final/jboss-logmanager-3.0.2.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-constraint/2.1.0/smallrye-common-constraint-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-cpu/2.1.0/smallrye-common-cpu-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-expression/2.1.0/smallrye-common-expression-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-function/2.1.0/smallrye-common-function-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-net/2.1.0/smallrye-common-net-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-ref/2.1.0/smallrye-common-ref-2.1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/json/jakarta.json-api/2.1.2/jakarta.json-api-2.1.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/eclipse/parsson/parsson/1.1.4/parsson-1.1.4.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/jboss/logging/jboss-logging-annotations/2.2.1.Final/jboss-logging-annotations-2.2.1.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/jboss/threads/jboss-threads/3.5.0.Final/jboss-threads-3.5.0.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/slf4j/slf4j-api/2.0.6/slf4j-api-2.0.6.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/jboss/slf4j/slf4j-jboss-logmanager/2.0.0.Final/slf4j-jboss-logmanager-2.0.0.Final.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/wildfly/common/wildfly-common/1.5.4.Final-format-001/wildfly-common-1.5.4.Final-format-001.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-bootstrap-runner/3.5.2/quarkus-bootstrap-runner-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/common/smallrye-common-io/2.1.2/smallrye-common-io-2.1.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/github/crac/org-crac/0.1.3/org-crac-0.1.3.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-fs-util/0.0.9/quarkus-fs-util-0.0.9.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/quarkus-arc/3.5.2/quarkus-arc-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/quarkus/arc/arc/3.5.2/arc-3.5.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/jakarta/transaction/jakarta.transaction-api/2.0.1/jakarta.transaction-api-2.0.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/io/smallrye/reactive/mutiny/2.2.0/mutiny-2.2.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/eclipse/microprofile/context-propagation/microprofile-context-propagation-api/1.3/microprofile-context-propagation-api-1.3.jar" enabled="true" runInBatchMode="false"/>
+</factorypath>

apps/onboarding-ms/src/main/docs/openapi.json

@@ -25,7 +25,7 @@
     "name" : "support"
   } ],
   "paths" : {
-    "/v1/aggregates/verification" : {
+    "/v1/aggregates/verification/appio" : {
       "post" : {
         "tags" : [ "Aggregates Controller" ],
         "summary" : "Validate the data related to the aggregated entities present in a CSV file",
@@ -55,17 +55,76 @@
                 }
               }
             }
-          },
-          "401" : {
-            "description" : "Not Authorized"
-          },
-          "403" : {
-            "description" : "Not Allowed"
+          }
+        }
+      }
+    },
+    "/v1/aggregates/verification/pagopa" : {
+      "post" : {
+        "tags" : [ "Aggregates Controller" ],
+        "summary" : "Validate the data related to the aggregated entities present in a CSV file",
+        "requestBody" : {
+          "content" : {
+            "multipart/form-data" : {
+              "schema" : {
+                "required" : [ "aggregates" ],
+                "type" : "object",
+                "properties" : {
+                  "aggregates" : {
+                    "format" : "binary",
+                    "type" : "string"
+                  }
+                }
+              }
+            }
           }
         },
-        "security" : [ {
-          "SecurityScheme" : [ ]
-        } ]
+        "responses" : {
+          "200" : {
+            "description" : "OK",
+            "content" : {
+              "application/json" : {
+                "schema" : {
+                  "$ref" : "#/components/schemas/VerifyAggregateResponse"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
+    "/v1/aggregates/verification/send" : {
+      "post" : {
+        "tags" : [ "Aggregates Controller" ],
+        "summary" : "Validate the data related to the aggregated entities present in a CSV file",
+        "requestBody" : {
+          "content" : {
+            "multipart/form-data" : {
+              "schema" : {
+                "required" : [ "aggregates" ],
+                "type" : "object",
+                "properties" : {
+                  "aggregates" : {
+                    "format" : "binary",
+                    "type" : "string"
+                  }
+                }
+              }
+            }
+          }
+        },
+        "responses" : {
+          "200" : {
+            "description" : "OK",
+            "content" : {
+              "application/json" : {
+                "schema" : {
+                  "$ref" : "#/components/schemas/VerifyAggregateResponse"
+                }
+              }
+            }
+          }
+        }
       }
     },
     "/v1/notification/resend" : {

apps/onboarding-ms/src/main/docs/openapi.yaml

@@ -16,7 +16,55 @@ tags:
 - name: internal-v1
 - name: support
 paths:
-  /v1/aggregates/verification:
+  /v1/aggregates/verification/appio:
+    post:
+      tags:
+      - Aggregates Controller
+      summary: Validate the data related to the aggregated entities present in a CSV
+        file
+      requestBody:
+        content:
+          multipart/form-data:
+            schema:
+              required:
+              - aggregates
+              type: object
+              properties:
+                aggregates:
+                  format: binary
+                  type: string
+      responses:
+        "200":
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/VerifyAggregateResponse"
+  /v1/aggregates/verification/pagopa:
+    post:
+      tags:
+      - Aggregates Controller
+      summary: Validate the data related to the aggregated entities present in a CSV
+        file
+      requestBody:
+        content:
+          multipart/form-data:
+            schema:
+              required:
+              - aggregates
+              type: object
+              properties:
+                aggregates:
+                  format: binary
+                  type: string
+      responses:
+        "200":
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/VerifyAggregateResponse"
+  /v1/aggregates/verification/send:
     post:
       tags:
       - Aggregates Controller
@@ -40,12 +88,6 @@ paths:
             application/json:
               schema:
                 $ref: "#/components/schemas/VerifyAggregateResponse"
-        "401":
-          description: Not Authorized
-        "403":
-          description: Not Allowed
-      security:
-      - SecurityScheme: []
   /v1/notification/resend:
     post:
       tags:

apps/onboarding-ms/src/main/java/it/pagopa/selfcare/onboarding/controller/AggregatesController.java

@@ -6,10 +6,7 @@
 import it.pagopa.selfcare.onboarding.service.AggregatesService;
 import jakarta.inject.Inject;
 import jakarta.validation.constraints.NotNull;
-import jakarta.ws.rs.Consumes;
-import jakarta.ws.rs.POST;
-import jakarta.ws.rs.Path;
-import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.*;
 import jakarta.ws.rs.core.MediaType;
 import lombok.AllArgsConstructor;
 import org.eclipse.microprofile.openapi.annotations.Operation;
@@ -29,12 +26,32 @@ public class AggregatesController {
 
     @Operation(summary = "Validate the data related to the aggregated entities present in a CSV file")
     @POST
-    @Path("/verification")
+    @Path("/verification/appio")
     @Produces(MediaType.APPLICATION_JSON)
     @Consumes(MediaType.MULTIPART_FORM_DATA)
-    public Uni<VerifyAggregateResponse> verifyAggregatesCsv(@NotNull @RestForm("aggregates") File file){
+    public Uni<VerifyAggregateResponse> verifyAppIoAggregatesCsv(@NotNull @RestForm("aggregates") File file){
 
-        return aggregatesService.validateAggregatesCsv(file);
+        return aggregatesService.validateAppIoAggregatesCsv(file);
+    }
+
+    @Operation(summary = "Validate the data related to the aggregated entities present in a CSV file")
+    @POST
+    @Path("/verification/send")
+    @Produces(MediaType.APPLICATION_JSON)
+    @Consumes(MediaType.MULTIPART_FORM_DATA)
+    public Uni<VerifyAggregateResponse> verifySendAggregatesCsv(@NotNull @RestForm("aggregates") File file){
+
+        return aggregatesService.validateSendAggregatesCsv(file);
+    }
+
+    @Operation(summary = "Validate the data related to the aggregated entities present in a CSV file")
+    @POST
+    @Path("/verification/pagopa")
+    @Produces(MediaType.APPLICATION_JSON)
+    @Consumes(MediaType.MULTIPART_FORM_DATA)
+    public Uni<VerifyAggregateResponse> verifyPagoPaAggregatesCsv(@NotNull @RestForm("aggregates") File file){
+
+        return aggregatesService.validatePagoPaAggregatesCsv(file);
     }
 
 

apps/onboarding-ms/src/main/java/it/pagopa/selfcare/onboarding/model/AggregatesCsvResponse.java

@@ -3,29 +3,29 @@
 import java.util.ArrayList;
 import java.util.List;
 
-public class AggregatesCsvResponse {
-    private List<CsvAggregate> csvAggregateList;
-    private List<CsvAggregate> validAggregates = new ArrayList<>();
+public class AggregatesCsvResponse <T extends Csv>{
+    private List<T> csvAggregateList;
+    private List<T> validAggregates = new ArrayList<>();
     private List<RowError> rowErrorList;
 
-    public AggregatesCsvResponse(List<CsvAggregate> csvAggregateList, List<RowError> rowErrorList) {
+    public AggregatesCsvResponse(List<T> csvAggregateList, List<RowError> rowErrorList) {
         this.csvAggregateList = csvAggregateList;
         this.rowErrorList = rowErrorList;
     }
 
-    public List<CsvAggregate> getCsvAggregateList() {
+    public List<T> getCsvAggregateList() {
         return csvAggregateList;
     }
 
-    public void setCsvAggregateList(List<CsvAggregate> csvAggregateList) {
+    public void setCsvAggregateList(List<T> Csv) {
         this.csvAggregateList = csvAggregateList;
     }
 
-    public List<CsvAggregate> getValidAggregates() {
+    public List<T> getValidAggregates() {
         return validAggregates;
     }
 
-    public void setValidAggregates(List<CsvAggregate> validAggregates) {
+    public void setValidAggregates(List<T> Csv) {
         this.validAggregates = validAggregates;
     }
 

apps/onboarding-ms/src/main/java/it/pagopa/selfcare/onboarding/model/Csv.java

@@ -0,0 +1,5 @@
+package it.pagopa.selfcare.onboarding.model;
+
+public interface Csv {
+    void setRowNumber(int lineNumber);
+}

apps/onboarding-ms/src/main/java/it/pagopa/selfcare/onboarding/model/CsvAggregate.java → apps/onboarding-ms/src/main/java/it/pagopa/selfcare/onboarding/model/CsvAggregateAppIo.java

@@ -4,24 +4,45 @@
 import lombok.Data;
 
 @Data
-public class CsvAggregate {
+public class CsvAggregateAppIo implements Csv {
 
     @CsvBindByPosition(position = 0)
-    private String taxCode;
-    @CsvBindByPosition(position = 1)
     private String description;
+
+    @CsvBindByPosition(position = 1)
+    private String pec;
+
     @CsvBindByPosition(position = 2)
-    private String vatNumber;
+    private String taxCode;
+
     @CsvBindByPosition(position = 3)
-    private String subunitType;
+    private String vatNumber;
+
     @CsvBindByPosition(position = 4)
-    private String subunitCode;
-    @CsvBindByPosition(position = 5)
     private String address;
+
+    @CsvBindByPosition(position = 5)
+    private String city;
+
     @CsvBindByPosition(position = 6)
-    private String originId;
+    private String province;
+
+    @CsvBindByPosition(position = 7)
+    private String ipaCode;
 
+    @CsvBindByPosition(position = 8)
+    private String subunitType;
+
+    @CsvBindByPosition(position = 9)
+    private String subunitCode;
+
+    @CsvBindByPosition(position = 10)
+    private String originId;
     private Integer rowNumber;
 
+    @Override
+    public void setRowNumber(int lineNumber) {
+        this.rowNumber = lineNumber;
+    }
 
 }