Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

RED-9180 - Add migration to reanalyze all non-approved files

Browse Source
This commit is contained in:
Andrei Isvoran 2024-05-22 15:00:44 +03:00
parent b4736783b8
commit 6874f746c9
2 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/ReanalyzeNonApprovedFilesService.java
View File

@ -28,11 +28,7 @@ public class ReanalyzeNonApprovedFilesService {
List<DossierEntity> dossierEntities = dossierRepository.findAll(); List<DossierEntity> dossierEntities = dossierRepository.findAll();
dossierEntities.forEach(dossierEntity -> { dossierEntities.forEach(dossierEntity -> {
List<FileEntity> unapprovedFilesByDossier = fileRepository.findByDossierId(dossierEntity.getId()) Set<String> unapprovedFilesByDossierIds = fileRepository.findByDossierIdAndWorkflowStatusNotApproved(dossierEntity.getId()).stream()
.stream()
.filter(fileEntity -> !fileEntity.getWorkflowStatus().equals(WorkflowStatus.APPROVED))
.toList();
Set<String> unapprovedFilesByDossierIds = unapprovedFilesByDossier.stream()
.map(FileEntity::getId) .map(FileEntity::getId)
.collect(Collectors.toSet()); .collect(Collectors.toSet());
reanalysisService.reanalyzeFiles(dossierEntity.getId(), unapprovedFilesByDossierIds, true); reanalysisService.reanalyzeFiles(dossierEntity.getId(), unapprovedFilesByDossierIds, true);

16
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/repository/FileRepository.java
View File

@ -30,6 +30,10 @@ public interface FileRepository extends JpaRepository<FileEntity, String> {
List<FileEntity> findByAddedBefore(OffsetDateTime end); List<FileEntity> findByAddedBefore(OffsetDateTime end);
@Query("SELECT f FROM FileEntity f WHERE f.dossierId = :dossierId AND f.workflowStatus <> 'APPROVED'")
List<FileEntity> findByDossierIdAndWorkflowStatusNotApproved(@Param("dossierId") String dossierId);
@Modifying @Modifying
@Query("update FileEntity e set e.hasRedactions = :hasRedactions ," @Query("update FileEntity e set e.hasRedactions = :hasRedactions ,"
+ " e.hasHints = :hasHints, e.hasSuggestions = :hasSuggestions," + " e.hasHints = :hasHints, e.hasSuggestions = :hasSuggestions,"
@ -168,12 +172,13 @@ public interface FileRepository extends JpaRepository<FileEntity, String> {
@Param("lastUpdated") OffsetDateTime lastUpdated, @Param("lastUpdated") OffsetDateTime lastUpdated,
@Param("softDeletedTime") OffsetDateTime softDeletedTime); @Param("softDeletedTime") OffsetDateTime softDeletedTime);
@Modifying @Modifying
@Query("update FileEntity f set f.processingStatus = :processingStatus, f.lastUpdated = :lastUpdated, " + "f.deleted = :softDeletedTime where f.id in (:fileIds)") @Query("update FileEntity f set f.processingStatus = :processingStatus, f.lastUpdated = :lastUpdated, " + "f.deleted = :softDeletedTime where f.id in (:fileIds)")
int softDeleteFiles(@Param("fileIds") List<String> fileIds, int softDeleteFiles(@Param("fileIds") List<String> fileIds,
@Param("processingStatus") ProcessingStatus processingStatus, @Param("processingStatus") ProcessingStatus processingStatus,
@Param("lastUpdated") OffsetDateTime lastUpdated, @Param("lastUpdated") OffsetDateTime lastUpdated,
@Param("softDeletedTime") OffsetDateTime softDeletedTime); @Param("softDeletedTime") OffsetDateTime softDeletedTime);
@Modifying @Modifying
@ -380,10 +385,7 @@ public interface FileRepository extends JpaRepository<FileEntity, String> {
+ " when f.deleted is not null then f.deleted " + " when f.deleted is not null then f.deleted "
+ "end " + "end "
+ "where f.id in (:fileIds)") + "where f.id in (:fileIds)")
int hardDeleteFiles(@Param("fileIds") List<String> fileIds, int hardDeleteFiles(@Param("fileIds") List<String> fileIds, @Param("processingStatus") ProcessingStatus processingStatus, @Param("deletionTime") OffsetDateTime deletionTime);
@Param("processingStatus") ProcessingStatus processingStatus,
@Param("deletionTime") OffsetDateTime deletionTime);
} }