diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/ReanalyzeNonApprovedFilesService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/ReanalyzeNonApprovedFilesService.java index 027900e25..c735477e6 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/ReanalyzeNonApprovedFilesService.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/ReanalyzeNonApprovedFilesService.java @@ -27,8 +27,9 @@ public class ReanalyzeNonApprovedFilesService { public void reanalyzeNonApprovedFiles() { List dossierEntities = dossierRepository.findAll(); - dossierEntities.forEach(dossierEntity -> { + dossierEntities.stream().filter(dossier -> !dossier.isDeleted()).forEach(dossierEntity -> { Set unapprovedFilesByDossierIds = fileRepository.findByDossierIdAndWorkflowStatusNotApproved(dossierEntity.getId()).stream() + .filter(fileEntity -> !fileEntity.isSoftOrHardDeleted()) .map(FileEntity::getId) .collect(Collectors.toSet()); reanalysisService.reanalyzeFiles(dossierEntity.getId(), unapprovedFilesByDossierIds, true);