diff --git a/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java b/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java index 4e560febe..62e5d4dc1 100644 --- a/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java +++ b/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java @@ -221,7 +221,7 @@ public void rejectOutdatedOnboardings(Onboarding onboarding) { LocalDateTime now = LocalDateTime.now(); onboardingRepository .update("status = ?1 and updatedAt = ?2 ", REJECTED, now) - .where("productId = ?1 and institution.origin = ?2 and institution.originId = ?3 and status not in ['COMPLETED', 'FAILED', 'DELETED']", + .where("productId = ?1 and institution.origin = ?2 and institution.originId = ?3 and status IN ('PENDING', 'TOBEVALIDATED')", onboarding.getProductId(), onboarding.getInstitution().getOrigin(), onboarding.getInstitution().getOriginId()); } diff --git a/apps/onboarding-functions/src/test/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefaultTest.java b/apps/onboarding-functions/src/test/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefaultTest.java index f613815c0..0ab7514e7 100644 --- a/apps/onboarding-functions/src/test/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefaultTest.java +++ b/apps/onboarding-functions/src/test/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefaultTest.java @@ -209,7 +209,7 @@ void rejectOutdatedOnboardings(){ onboarding.getInstitution().setOrigin(Origin.IPA); PanacheUpdate panacheUpdateMock = mock(PanacheUpdate.class); - when(panacheUpdateMock.where("productId = ?1 and institution.origin = ?2 and institution.originId = ?3 and status not in ['COMPLETED', 'FAILED', 'DELETED']", + when(panacheUpdateMock.where("productId = ?1 and institution.origin = ?2 and institution.originId = ?3 and status IN ('PENDING', 'TOBEVALIDATED')", onboarding.getProductId(), onboarding.getInstitution().getOrigin(), onboarding.getInstitution().getOriginId())) .thenReturn(Long.valueOf(1)); when(onboardingRepository.update("status = ?1 and updatedAt = ?2 ", any(), any()))