feat: P4ADEV-1625 classifyiufactivity-retrieve-iuvs-save

src/main/java/it/gov/pagopa/payhub/activities/activity/classifications/IufClassificationActivity.java

@@ -1,15 +1,23 @@
 package it.gov.pagopa.payhub.activities.activity.classifications;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+import it.gov.pagopa.payhub.activities.dto.classifications.IufClassificationActivityResult;
+
 /**
  * Interface for defining an activity to process payment reporting classifications based on IUF.
  */
+@ActivityInterface
 public interface IufClassificationActivity {
 
     /**
      * Processes IUF classification based on the provided parameters.
      *
      * @param organizationId the unique identifier of the organization
+     * @param treasuryId     the unique identifier of treasury
      * @param iuf            the unique identifier of the payment reporting flow (IUF)
-     * @return true if the classification is successful, false otherwise
+     * @return IufClassificationActivityResult containing a list of payments and success flag
      */
-    boolean classify(String organizationId, String iuf);
+    @ActivityMethod
+    IufClassificationActivityResult classify(Long organizationId, Long treasuryId, String iuf);
 }

src/main/java/it/gov/pagopa/payhub/activities/activity/classifications/IufClassificationActivityImpl.java

@@ -0,0 +1,70 @@
+package it.gov.pagopa.payhub.activities.activity.classifications;
+
+import it.gov.pagopa.payhub.activities.dao.ClassificationDao;
+import it.gov.pagopa.payhub.activities.dao.PaymentsReportingDao;
+import it.gov.pagopa.payhub.activities.dto.classifications.ClassificationDTO;
+import it.gov.pagopa.payhub.activities.dto.classifications.IufClassificationActivityResult;
+import it.gov.pagopa.payhub.activities.dto.classifications.ClassifyResultDTO;
+import it.gov.pagopa.payhub.activities.enums.ClassificationsEnum;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Lazy
+@Component
+public class IufClassificationActivityImpl implements IufClassificationActivity {
+    private final PaymentsReportingDao paymentsReportingDao;
+    private final ClassificationDao classificationDao;
+
+    public IufClassificationActivityImpl(PaymentsReportingDao paymentsReportingDao, ClassificationDao classificationDao) {
+        this.paymentsReportingDao = paymentsReportingDao;
+        this.classificationDao  = classificationDao;
+    }
+
+    @Override
+    public IufClassificationActivityResult classify(Long organizationId, Long treasuryId, String iuf) {
+        log.debug("Starting IUF Classification for organization id {} and iuf {}", organizationId,iuf);
+
+        List<ClassifyResultDTO> classifyResultDTOS =
+            paymentsReportingDao.findByOrganizationIdFlowIdentifierCode(organizationId, iuf)
+            .stream()
+            .map(paymentsReportingDTO ->
+                ClassifyResultDTO.builder()
+                    .organizationId(paymentsReportingDTO.getOrganizationId())
+                    .creditorReferenceId(paymentsReportingDTO.getCreditorReferenceId())
+                    .regulationUniqueIdentifier(paymentsReportingDTO.getRegulationUniqueIdentifier())
+                    .transferIndex(paymentsReportingDTO.getTransferIndex())
+                    .build())
+            .toList();
+
+        log.debug("Saving payments reporting found for organization id {} and iuf: {}", organizationId, iuf);
+        saveClassification(organizationId, treasuryId, iuf);
+
+        return IufClassificationActivityResult.builder()
+                .classifyResultDTOS(classifyResultDTOS)
+                .success(true)
+                .build();
+    }
+
+    /**
+     * save classification data
+     *
+     * @param organizationId organization id
+     * @param treasuryId  treasury id
+     * @param iuf  flow unique identifier
+     */
+    private void saveClassification(Long organizationId, Long treasuryId, String iuf) {
+        log.debug("Saving classification TES_NO_MATCH for organizationId: {} - treasuryId: {} - iuf: {}", organizationId, treasuryId, iuf);
+
+        classificationDao.save(ClassificationDTO.builder()
+            .organizationId(organizationId)
+            .treasuryId(treasuryId)
+            .iuf(iuf)
+            .classificationsEnum(ClassificationsEnum.TES_NO_MATCH)
+            .build());
+    }
+}

src/main/java/it/gov/pagopa/payhub/activities/dao/ClassificationDao.java

@@ -1,18 +1,27 @@
 package it.gov.pagopa.payhub.activities.dao;
 
+import it.gov.pagopa.payhub.activities.dto.classifications.ClassificationDTO;
 import it.gov.pagopa.payhub.activities.enums.ClassificationsEnum;
 
 /**
- * Data Access Object interface for saving payments classification
+ * Data Access Object interface  for saving payments classification
  */
 public interface ClassificationDao {
 	/**
+	 * save classification
 	 *
-	 * @param organizationId organization id
-	 * @param iuf fow identifier
-	 * @param classification classification to delete
-	 * @return true for success deletion
-	 */
+     * @param classificationDTO dto classification  to save
+     */
+	void save(ClassificationDTO classificationDTO);
+
+    /**
+     * delete classification
+     *
+     * @param organizationId organization id
+     * @param iuf fow identifier
+     * @param classification classification to delete
+     * @return true for success deletion
+     */
 	boolean deleteClassificationByIuf(Long organizationId, String iuf, ClassificationsEnum classification);
 }
 

src/main/java/it/gov/pagopa/payhub/activities/dao/PaymentsReportingDao.java

@@ -18,4 +18,13 @@ public interface PaymentsReportingDao {
 	 *         fields (e.g., generated IDs or timestamps).
 	 */
 	List<PaymentsReportingDTO> saveAll(List<PaymentsReportingDTO> dtos);
+
+	/**
+	 *
+	 * @param organizationId organization id
+	 * @param flowIdentifierCode identifies a specific reporting code
+	 * @return List of PaymentsReportingDTO objects that may be an empty list
+	 */
+	List<PaymentsReportingDTO> findByOrganizationIdFlowIdentifierCode(Long organizationId, String flowIdentifierCode);
+
 }

src/main/java/it/gov/pagopa/payhub/activities/dao/TreasuryDao.java

@@ -0,0 +1,15 @@
+package it.gov.pagopa.payhub.activities.dao;
+
+import it.gov.pagopa.payhub.activities.dto.treasury.TreasuryDTO;
+
+import java.util.List;
+
+public interface TreasuryDao {
+     /**
+      * retrieve treasury for the same iuf
+      *
+      * @param iuf flow unique identifier
+      * @return list of treasury records associated to the iuf
+      */
+     List<TreasuryDTO> searchByIuf(String iuf);
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/classifications/ClassificationDTO.java

@@ -0,0 +1,29 @@
+package it.gov.pagopa.payhub.activities.dto.classifications;
+
+import it.gov.pagopa.payhub.activities.enums.ClassificationsEnum;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+
+@Data
+@Builder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class ClassificationDTO implements Serializable {
+    private Long organizationId;
+    private Long transferId;
+    private Long paymentNotifyId;
+    private Long paymentReportingId;
+    private Long treasuryId;
+    private String iuf;
+    private String iud;
+    private String iuv;
+    private String iur;
+    private int transferIndex;
+    private ClassificationsEnum classificationsEnum;
+    private LocalDate creationDate;
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/classifications/ClassifyResultDTO.java

@@ -0,0 +1,17 @@
+package it.gov.pagopa.payhub.activities.dto.classifications;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class ClassifyResultDTO {
+	private Long organizationId;
+	private String creditorReferenceId;
+	private String regulationUniqueIdentifier;
+	private int transferIndex;
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/classifications/IufClassificationActivityResult.java

@@ -0,0 +1,17 @@
+package it.gov.pagopa.payhub.activities.dto.classifications;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@Builder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class IufClassificationActivityResult {
+    private List<ClassifyResultDTO> classifyResultDTOS;
+    private boolean success;
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/treasury/TreasuryDTO.java

@@ -0,0 +1,56 @@
+package it.gov.pagopa.payhub.activities.dto.treasury;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * DTO for the TreasuryDto
+ */
+@Data
+@Builder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class TreasuryDTO {
+    private Long mygovFlussoTesoreriaId;
+    private String deAnnoBolletta;
+    private String codBolletta;
+    private String codConto;
+    private String codIdDominio;
+    private String codTipoMovimento;
+    private String codCausale;
+    private BigDecimal numIpBolletta;
+    private Date dtBolletta;
+    private Date dtRicezione;
+    private String deAnnoDocumento;
+    private String codDocumento;
+    private String codBollo;
+    private String deAeProvvisorio;
+    private String codProvvisorio;
+    private Character codTipoConto;
+    private String codProcesso;
+    private String codPgEsecuzione;
+    private String codPgTrasferimento;
+    private Long numPgProcesso;
+    private Date dtDataValutaRegione;
+    private Long mygovEnteId;
+    private String codIdUnivocoFlusso;
+    private String codIdUnivocoVersamento;
+    private Date dtCreazione;
+    private Date dtUltimaModifica;
+    private boolean flgRegolarizzata;
+    private Long mygovManageFlussoId;
+    private Date dtEffettivaSospeso;
+    private String codiceGestionaleProvvisorio;
+    private String endToEndId;
+
+    private byte[] codCodiceFiscaleHash;
+    private byte[] codPartitaIvaHash;
+    private byte[] deCognomeHash;
+
+    private Long personalDataId;
+}

src/test/java/it/gov/pagopa/payhub/activities/activity/classifications/IufClassificationActivitySaveTest.java

@@ -0,0 +1,85 @@
+package it.gov.pagopa.payhub.activities.activity.classifications;
+
+import it.gov.pagopa.payhub.activities.dao.ClassificationDao;
+import it.gov.pagopa.payhub.activities.dao.PaymentsReportingDao;
+import it.gov.pagopa.payhub.activities.dto.classifications.ClassifyResultDTO;
+import it.gov.pagopa.payhub.activities.dto.classifications.IufClassificationActivityResult;
+import it.gov.pagopa.payhub.activities.dto.paymentsreporting.PaymentsReportingDTO;
+import it.gov.pagopa.payhub.activities.utility.faker.PaymentsReportingFaker;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static it.gov.pagopa.payhub.activities.utility.faker.ClassifyResultFaker.buildClassifyResultDTO;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.Mockito.when;
+
+@ExtendWith(MockitoExtension.class)
+class IufClassificationActivitySaveTest {
+    @Mock
+    private PaymentsReportingDao paymentsReportingDao;
+
+    @Mock
+    private ClassificationDao classificationDao;
+
+    private IufClassificationActivity iufClassificationActivity;
+
+    private static final Long ORGANIZATIONID = 1L;
+    private static final Long TREASURYID = 1L;
+    private static final String FLOWIDENTIFIERCODE = "FLOW";
+
+
+    @BeforeEach
+    void init() {
+        iufClassificationActivity = new IufClassificationActivityImpl(paymentsReportingDao, classificationDao);
+    }
+
+
+    @Test
+    void saveClassificationSuccess() {
+        PaymentsReportingDTO expectedPaymentsReportingDTO = PaymentsReportingFaker.buildClassifyResultDTO();
+        List<PaymentsReportingDTO> expectedPaymentsReportingDTOS = new ArrayList<>();
+        expectedPaymentsReportingDTOS.add(expectedPaymentsReportingDTO);
+
+        ClassifyResultDTO expectedClassifyResultDTO = buildClassifyResultDTO(ORGANIZATIONID);
+        List<ClassifyResultDTO> expectedClassifyResultDTOS = new ArrayList<>();
+        expectedClassifyResultDTOS.add(expectedClassifyResultDTO);
+
+        IufClassificationActivityResult expectedIufClassificationActivityResult =
+                IufClassificationActivityResult
+                        .builder()
+                        .classifyResultDTOS(expectedClassifyResultDTOS)
+                        .success(true)
+                        .build();
+
+        when(paymentsReportingDao.findByOrganizationIdFlowIdentifierCode(ORGANIZATIONID, FLOWIDENTIFIERCODE))
+                .thenReturn(expectedPaymentsReportingDTOS);
+
+        IufClassificationActivityResult iufClassificationActivityResult =
+                iufClassificationActivity.classify(ORGANIZATIONID, TREASURYID, FLOWIDENTIFIERCODE);
+        assertEquals(iufClassificationActivityResult,expectedIufClassificationActivityResult);
+    }
+
+    @Test
+    void saveClassificationNoPayments() {
+        List<ClassifyResultDTO> classifyResultDTOS  = new ArrayList<>();
+
+        IufClassificationActivityResult expectedIufClassificationActivityResult =
+                IufClassificationActivityResult
+                        .builder()
+                        .classifyResultDTOS(classifyResultDTOS)
+                        .success(true)
+                        .build();
+
+        IufClassificationActivityResult iufClassificationActivityResult =
+                iufClassificationActivity.classify(ORGANIZATIONID, TREASURYID, FLOWIDENTIFIERCODE);
+
+        assertEquals(iufClassificationActivityResult,expectedIufClassificationActivityResult);
+    }
+}
+

src/test/java/it/gov/pagopa/payhub/activities/utility/faker/ClassifyResultFaker.java

@@ -0,0 +1,15 @@
+package it.gov.pagopa.payhub.activities.utility.faker;
+
+import it.gov.pagopa.payhub.activities.dto.classifications.ClassifyResultDTO;
+
+public class ClassifyResultFaker {
+
+    public static ClassifyResultDTO buildClassifyResultDTO(Long organizationId){
+        return ClassifyResultDTO.builder()
+                .organizationId(organizationId)
+                .creditorReferenceId("IUV")
+                .regulationUniqueIdentifier("IUR")
+                .transferIndex(1)
+                .build();
+    }
+}