feat: P4ADEV-1933-add-activity-debt-position-expiration

src/main/java/it/gov/pagopa/payhub/activities/activity/debtposition/DebtPositionExpirationActivity.java

@@ -0,0 +1,25 @@
+package it.gov.pagopa.payhub.activities.activity.debtposition;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+
+import java.time.OffsetDateTime;
+
+/**
+ * Service interface responsible for handling the expiration process of a debt position.
+ * This activity checks and updates the expiration status based on its installments.
+ */
+@ActivityInterface
+public interface DebtPositionExpirationActivity {
+
+    /**
+     * Checks the expiration status of the installments linked to a specific debt position
+     * and updates the overall status of the debt position accordingly.
+     *
+     * @param debtPositionId the unique identifier of the debt position to be processed.
+     * @return the minimum due date ({@link OffsetDateTime}) among all unpaid installments,
+     *         or {@code null} if no unpaid installments exist.
+     */
+    @ActivityMethod
+    OffsetDateTime checkAndUpdateInstallmentExpiration(Long debtPositionId);
+}

src/main/java/it/gov/pagopa/payhub/activities/activity/debtposition/DebtPositionExpirationActivityImpl.java

@@ -0,0 +1,23 @@
+package it.gov.pagopa.payhub.activities.activity.debtposition;
+
+import it.gov.pagopa.payhub.activities.connector.debtposition.DebtPositionService;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Service;
+
+import java.time.OffsetDateTime;
+
+@Lazy
+@Service
+public class DebtPositionExpirationActivityImpl implements DebtPositionExpirationActivity{
+
+    private final DebtPositionService debtPositionService;
+
+    public DebtPositionExpirationActivityImpl(DebtPositionService debtPositionService) {
+        this.debtPositionService = debtPositionService;
+    }
+
+    @Override
+    public OffsetDateTime checkAndUpdateInstallmentExpiration(Long debtPositionId) {
+        return debtPositionService.checkAndUpdateInstallmentExpiration(debtPositionId);
+    }
+}

src/main/java/it/gov/pagopa/payhub/activities/connector/debtposition/DebtPositionService.java

@@ -3,6 +3,7 @@
 import it.gov.pagopa.pu.debtposition.dto.generated.DebtPositionDTO;
 import it.gov.pagopa.pu.debtposition.dto.generated.IupdSyncStatusUpdateDTO;
 
+import java.time.OffsetDateTime;
 import java.util.Map;
 
 /**
@@ -18,4 +19,11 @@ public interface DebtPositionService {
      */
     DebtPositionDTO finalizeSyncStatus(Long debtPositionId, Map<String, IupdSyncStatusUpdateDTO> syncStatusUpdateDTO);
 
+    /**
+     * Checks and updates the expiration date of the installments associated to a debt position
+     *
+     * @param debtPositionId the unique identifier of the debt position to be processed.
+     * @return the minimum due date ({@link OffsetDateTime}) among all unpaid installments
+     */
+    OffsetDateTime checkAndUpdateInstallmentExpiration(Long debtPositionId);
 }

src/main/java/it/gov/pagopa/payhub/activities/connector/debtposition/DebtPositionServiceImpl.java

@@ -3,11 +3,15 @@
 import it.gov.pagopa.payhub.activities.connector.auth.AuthnService;
 import it.gov.pagopa.payhub.activities.connector.debtposition.client.DebtPositionClient;
 import it.gov.pagopa.pu.debtposition.dto.generated.DebtPositionDTO;
+import it.gov.pagopa.pu.debtposition.dto.generated.InstallmentDTO;
 import it.gov.pagopa.pu.debtposition.dto.generated.IupdSyncStatusUpdateDTO;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
+import java.time.OffsetDateTime;
 import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
 
 @Lazy
 @Service
@@ -26,4 +30,19 @@ public DebtPositionDTO finalizeSyncStatus(Long debtPositionId, Map<String, IupdS
         String accessToken = authnService.getAccessToken();
         return debtPositionClient.finalizeSyncStatus(accessToken, debtPositionId, syncStatusUpdateDTO);
     }
+
+    @Override
+    public OffsetDateTime checkAndUpdateInstallmentExpiration(Long debtPositionId) {
+        String accessToken = authnService.getAccessToken();
+        DebtPositionDTO debtPositionDTO = debtPositionClient.checkAndUpdateInstallmentExpiration(accessToken, debtPositionId);
+
+        Optional<OffsetDateTime> dueDate = debtPositionDTO.getPaymentOptions().stream()
+                .flatMap(paymentOption -> paymentOption.getInstallments().stream())
+                .filter(installment -> InstallmentDTO.StatusEnum.UNPAID.equals(installment.getStatus()))
+                .map(InstallmentDTO::getDueDate)
+                .filter(Objects::nonNull)
+                .min(OffsetDateTime::compareTo);
+
+        return dueDate.orElse(null);
+    }
 }

src/main/java/it/gov/pagopa/payhub/activities/connector/debtposition/client/DebtPositionClient.java

@@ -21,4 +21,8 @@ public DebtPositionClient(DebtPositionApisHolder debtPositionApisHolder) {
     public DebtPositionDTO finalizeSyncStatus(String accessToken, Long debtPositionId, Map<String, IupdSyncStatusUpdateDTO> syncStatusUpdateDTO){
         return debtPositionApisHolder.getDebtPositionApi(accessToken).finalizeSyncStatus(debtPositionId, syncStatusUpdateDTO);
     }
+
+    public DebtPositionDTO checkAndUpdateInstallmentExpiration(String accessToken, Long debtPositionId){
+        return debtPositionApisHolder.getDebtPositionApi(accessToken).checkAndUpdateInstallmentExpiration(debtPositionId);
+    }
 }

src/test/java/it/gov/pagopa/payhub/activities/activity/debtposition/DebtPositionExpirationActivityTest.java

@@ -0,0 +1,46 @@
+package it.gov.pagopa.payhub.activities.activity.debtposition;
+
+import it.gov.pagopa.payhub.activities.connector.debtposition.DebtPositionService;
+import org.junit.jupiter.api.AfterEach;
+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.Mockito;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.time.OffsetDateTime;
+
+import static it.gov.pagopa.payhub.activities.util.TestUtils.OFFSETDATETIME;
+import static org.junit.jupiter.api.Assertions.assertSame;
+
+@ExtendWith(MockitoExtension.class)
+class DebtPositionExpirationActivityTest {
+
+    @Mock
+    private DebtPositionService debtPositionServiceMock;
+
+    private DebtPositionExpirationActivity activity;
+
+    @BeforeEach
+    void init() {
+        activity = new DebtPositionExpirationActivityImpl(debtPositionServiceMock);
+    }
+
+    @AfterEach
+    void verifyNoMoreInteractions(){
+        Mockito.verifyNoMoreInteractions(debtPositionServiceMock);
+    }
+
+    @Test
+    void givenCheckAndUpdateInstallmentExpirationThenOk(){
+        Mockito.when(debtPositionServiceMock.checkAndUpdateInstallmentExpiration(1L))
+                .thenReturn(OFFSETDATETIME);
+
+        OffsetDateTime offsetDateTime = activity.checkAndUpdateInstallmentExpiration(1L);
+
+        Mockito.verify(debtPositionServiceMock, Mockito.times(1))
+                .checkAndUpdateInstallmentExpiration(1L);
+        assertSame(OFFSETDATETIME, offsetDateTime);
+    }
+}

src/test/java/it/gov/pagopa/payhub/activities/connector/debtposition/DebtPositionServiceTest.java

@@ -2,6 +2,8 @@
 
 import it.gov.pagopa.payhub.activities.connector.auth.AuthnService;
 import it.gov.pagopa.payhub.activities.connector.debtposition.client.DebtPositionClient;
+import it.gov.pagopa.pu.debtposition.dto.generated.DebtPositionDTO;
+import it.gov.pagopa.pu.debtposition.dto.generated.InstallmentDTO;
 import it.gov.pagopa.pu.debtposition.dto.generated.IupdSyncStatusUpdateDTO;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
@@ -11,8 +13,13 @@
 import org.mockito.Mockito;
 import org.mockito.junit.jupiter.MockitoExtension;
 
+import java.time.OffsetDateTime;
+import java.util.List;
 import java.util.Map;
 
+import static it.gov.pagopa.payhub.activities.util.faker.DebtPositionFaker.buildDebtPositionDTO;
+import static org.junit.jupiter.api.Assertions.*;
+
 @ExtendWith(MockitoExtension.class)
 class DebtPositionServiceTest {
 
@@ -53,4 +60,57 @@ void whenFinalizeSyncStatusThenInvokeClient() {
         // Then
         Mockito.verify(debtPositionClientMock).finalizeSyncStatus(accessToken, 0L, Map.of("iud", iupdSyncStatusUpdateDTO));
     }
+
+    @Test
+    void givenCheckAndUpdateInstallmentExpirationThenOk() {
+        // Given
+        String accessToken = "ACCESSTOKEN";
+        DebtPositionDTO debtPositionDTO = buildDebtPositionDTO();
+        InstallmentDTO.StatusEnum unpaidStatus = InstallmentDTO.StatusEnum.UNPAID;
+        OffsetDateTime now = OffsetDateTime.now();
+
+        InstallmentDTO installment1 = new InstallmentDTO();
+        installment1.setStatus(unpaidStatus);
+        installment1.setDueDate(now.plusDays(10));
+
+        InstallmentDTO installment2 = new InstallmentDTO();
+        installment2.setStatus(unpaidStatus);
+        installment2.setDueDate(now.plusDays(5));
+
+        debtPositionDTO.getPaymentOptions().getFirst().setInstallments(List.of(installment1, installment2));
+
+        Mockito.when(authnServiceMock.getAccessToken())
+                .thenReturn(accessToken);
+
+        Mockito.when(debtPositionClientMock.checkAndUpdateInstallmentExpiration(accessToken, 1L))
+                .thenReturn(debtPositionDTO);
+
+        // When
+        OffsetDateTime dueDate = debtPositionService.checkAndUpdateInstallmentExpiration(1L);
+
+        // Then
+        assertNotNull(dueDate);
+        assertEquals(installment2.getDueDate(), dueDate);
+        Mockito.verify(debtPositionClientMock).checkAndUpdateInstallmentExpiration(accessToken, 1L);
+    }
+
+    @Test
+    void givenCheckAndUpdateInstallmentExpirationWhenInstallmentIsNotUnpaidThenNull() {
+        // Given
+        String accessToken = "ACCESSTOKEN";
+        DebtPositionDTO debtPositionDTO = buildDebtPositionDTO();
+
+        Mockito.when(authnServiceMock.getAccessToken())
+                .thenReturn(accessToken);
+
+        Mockito.when(debtPositionClientMock.checkAndUpdateInstallmentExpiration(accessToken,1L))
+                .thenReturn(debtPositionDTO);
+
+        // When
+        OffsetDateTime dueDate = debtPositionService.checkAndUpdateInstallmentExpiration(1L);
+
+        // Then
+        assertNull(dueDate);
+        Mockito.verify(debtPositionClientMock).checkAndUpdateInstallmentExpiration(accessToken,1L);
+    }
 }

src/test/java/it/gov/pagopa/payhub/activities/connector/debtposition/client/DebtPositionClientTest.java

@@ -61,4 +61,24 @@ void whenFinalizeSyncStatusThenInvokeWithAccessToken(){
         // Then
         Assertions.assertSame(expectedResult, result);
     }
+
+    @Test
+    void givenCheckAndUpdateInstallmentExpirationThenOk(){
+        // Given
+        String accessToken = "ACCESSTOKEN";
+        Long debtPositionId = 0L;
+
+        DebtPositionDTO expectedResult = buildDebtPositionDTO();
+
+        Mockito.when(debtPositionApisHolderMock.getDebtPositionApi(accessToken))
+                .thenReturn(debtPositionApiMock);
+        Mockito.when(debtPositionApiMock.checkAndUpdateInstallmentExpiration(debtPositionId))
+                .thenReturn(expectedResult);
+
+        // When
+        DebtPositionDTO result = debtPositionClient.checkAndUpdateInstallmentExpiration(accessToken, debtPositionId);
+
+        // Then
+        Assertions.assertSame(expectedResult, result);
+    }
 }

version

@@ -1 +1 @@
-1.45.5
+1.46.0-SNAPSHOT