diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/controller/ReanalysisController.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/controller/ReanalysisController.java index 8df0a1d15..c5ca7d777 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/controller/ReanalysisController.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/controller/ReanalysisController.java @@ -154,14 +154,14 @@ public class ReanalysisController implements ReanalysisResource { if (force) { filesToReanalyse.forEach(file -> { - fileStatusService.setStatusReprocess(dossierId, file.getId(), 1); + fileStatusService.setStatusReprocess(dossierId, file.getId(), 2); }); } else { var enhancedAndConvertedFiles = reanalysisRequiredStatusService.enhanceFileStatusWithAnalysisRequirements(convert( fileStatusService.getAllStatuses(), FileModel.class, new FileModelMapper())); enhancedAndConvertedFiles.forEach(file -> { - fileStatusService.setStatusReprocess(dossierId, file.getId(), 1); + fileStatusService.setStatusReprocess(dossierId, file.getId(), 2); }); } diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/FileService.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/FileService.java index cf12a7c6f..65f7948c2 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/FileService.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/FileService.java @@ -81,8 +81,7 @@ public class FileService { } else { // the file is new, should create a new status for it. log.info("File {} has no status yet, creating one and setting to unprocessed.", request.getFilename()); - fileStatusService.createStatus(request.getDossierId(), fileId, request.getUploader(), request.getFilename(), request - .getData().length); + fileStatusService.createStatus(request.getDossierId(), fileId, request.getUploader(), request.getFilename(), 1); } return new JSONPrimitive<>(fileId); } diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/ManualRedactionService.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/ManualRedactionService.java index f40b40351..975245a5f 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/ManualRedactionService.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/ManualRedactionService.java @@ -188,7 +188,7 @@ public class ManualRedactionService { fileStatusPersistenceService.setUpdateLastManualRedactionAndHasSuggestions(fileId, now, true); } else { fileStatusPersistenceService.updateLastManualRedaction(fileId, now); - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } return ManualAddResponse.builder() @@ -321,7 +321,7 @@ public class ManualRedactionService { fileStatusPersistenceService.setUpdateLastManualRedactionAndHasSuggestions(fileId, OffsetDateTime.now(), hasSuggestions); } else { fileStatusPersistenceService.updateLastManualRedaction(fileId, OffsetDateTime.now()); - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } } @@ -410,10 +410,10 @@ public class ManualRedactionService { ManualImageRecategorizationEntity imageRecategorization = recategorizationPersistenceService.findRecategorization(fileId, annotationId); // if it was previously approved, revert the delete if (imageRecategorization.getStatus() == AnnotationStatus.APPROVED) { - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } } else if (annotationStatus.equals(AnnotationStatus.APPROVED)) { - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } dossierPersistenceService.getAndValidateDossier(dossierId); @@ -510,7 +510,7 @@ public class ManualRedactionService { log.debug("Adding entries for {} / {}", dossierId, fileId); dictionaryController.addEntries(typeId, List.of(value), false); - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } catch (Exception e) { throw new BadRequestException(e.getMessage()); } @@ -522,7 +522,7 @@ public class ManualRedactionService { try { log.debug("Deleting entries for {} / {}", dossierId, fileId); dictionaryController.deleteEntries(typeId, List.of(value)); - fileStatusService.setStatusReprocess(dossierId, fileId, 100); + fileStatusService.setStatusReprocess(dossierId, fileId, 2); } catch (FeignException e) { throw new BadRequestException(e.getMessage()); }