diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/DocumineLayoutRewriteMigration20.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/DocumineLayoutRewriteMigration20.java index 55df55201..2eb674d17 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/DocumineLayoutRewriteMigration20.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/DocumineLayoutRewriteMigration20.java @@ -5,6 +5,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import com.iqser.red.service.persistence.management.v1.processor.migration.Migration; +import com.iqser.red.service.persistence.management.v1.processor.migration.StorageToMongoCopyService; import com.iqser.red.service.persistence.management.v1.processor.service.FileStatusService; import com.iqser.red.service.persistence.management.v1.processor.service.persistence.DossierPersistenceService; import com.iqser.red.service.persistence.management.v1.processor.service.persistence.FileStatusPersistenceService; @@ -30,6 +31,9 @@ public class DocumineLayoutRewriteMigration20 extends Migration { @Autowired private FileStatusPersistenceService fileStatusPersistenceService; + @Autowired + private StorageToMongoCopyService storageToMongoCopyService; + @Value("${application.type}") private String applicationType; @@ -50,6 +54,11 @@ public class DocumineLayoutRewriteMigration20 extends Migration { return; } + log.info("Migration: Copying all files for all dossiers to mongodb"); + storageToMongoCopyService.copy(); + log.info("Migration: Finished Mongo db migration"); + + var dossiers = dossierPersistenceService.findAllDossiers(); dossiers.forEach(dossier -> { if (dossier.getHardDeletedTime() == null) {