diff --git a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/migration/RedactionLogToEntityLogMigrationService.java b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/migration/RedactionLogToEntityLogMigrationService.java index b69af59e..c151aa60 100644 --- a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/migration/RedactionLogToEntityLogMigrationService.java +++ b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/migration/RedactionLogToEntityLogMigrationService.java @@ -101,8 +101,14 @@ public class RedactionLogToEntityLogMigrationService { throw new AssertionError(message); } + Set entitiesWithUnprocessedChanges = manualRedactions.buildAll() + .stream() + .filter(manualRedaction -> manualRedaction.getProcessedDate() == null) + .map(BaseAnnotation::getAnnotationId) + .collect(Collectors.toSet()); + MigratedIds idsToMigrateInDb = entitiesToMigrate.stream() - .filter(migrationEntity -> migrationEntity.hasManualChangesOrComments(entitiesWithComments)) + .filter(migrationEntity -> migrationEntity.hasManualChangesOrComments(entitiesWithComments, entitiesWithUnprocessedChanges)) .filter(m -> !m.getOldId().equals(m.getNewId())) .collect(new MigratedIdsCollector()); diff --git a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/model/MigrationEntity.java b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/model/MigrationEntity.java index a3041e01..8a1a1cab 100644 --- a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/model/MigrationEntity.java +++ b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/model/MigrationEntity.java @@ -347,11 +347,11 @@ public final class MigrationEntity { } - public boolean hasManualChangesOrComments(Set entitiesWithComments) { + public boolean hasManualChangesOrComments(Set entitiesWithComments, Set entitiesWithUnprocessedChanges) { return !(redactionLogEntry.getManualChanges() == null || redactionLogEntry.getManualChanges().isEmpty()) || // !(redactionLogEntry.getComments() == null || redactionLogEntry.getComments().isEmpty()) // - || hasManualChanges() || entitiesWithComments.contains(oldId); + || hasManualChanges() || entitiesWithComments.contains(oldId) || entitiesWithUnprocessedChanges.contains(oldId); }