diff --git a/src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/OrganizationPaymentsReportingPagoPaRetrieverActivityImpl.java b/src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/OrganizationPaymentsReportingPagoPaRetrieverActivityImpl.java index 70d60149..0ad64b2c 100644 --- a/src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/OrganizationPaymentsReportingPagoPaRetrieverActivityImpl.java +++ b/src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/OrganizationPaymentsReportingPagoPaRetrieverActivityImpl.java @@ -32,7 +32,7 @@ public List fetch(Long organizationId, List paymen if (paymentsReportingIds.isEmpty()) { return Collections.emptyList(); } - List ingestionFlowFileNames = getFilenamesFilteredByNotCompleted(organizationId, paymentsReportingIds); + List ingestionFlowFileNames = getFilenamesFilteredByStatus(organizationId, paymentsReportingIds); return paymentsReportingIds.stream() .filter(item -> ingestionFlowFileNames.contains(item.getPaymentsReportingFileName())) @@ -46,7 +46,7 @@ public List fetch(Long organizationId, List paymen * @param paymentsReportingIds * @return a list of file names that have not been processed */ - private List getFilenamesFilteredByNotCompleted(Long organizationId, List paymentsReportingIds) { + private List getFilenamesFilteredByStatus(Long organizationId, List paymentsReportingIds) { return paymentsReportingIds.stream().map(PaymentsReportingIdDTO::getPaymentsReportingFileName) .map(item -> ingestionFlowFileService .findByOrganizationIdFlowTypeFilename(organizationId, FlowFileTypeEnum.PAYMENTS_REPORTING_PAGOPA, item))