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

RED-5724 - Pressing Reanalyze-Button should reset processing_error_counter

Browse Source 
- reset the counter in state of REPROCESS
This commit is contained in:
devplant 2023-01-16 12:43:23 +02:00
parent 7c73aabfb1
commit 09fc65541f
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/FileStatusPersistenceService.java
View File

@ -481,6 +481,7 @@ public class FileStatusPersistenceService {
return fileRepository.findById(fileId).map(FileEntity::getProcessingErrorCounter).orElse(0) + 1; return fileRepository.findById(fileId).map(FileEntity::getProcessingErrorCounter).orElse(0) + 1;
case PROCESSED: case PROCESSED:
case REPROCESS:
return 0; return 0;
default: default:

22
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/tests/FileProcessingTest.java
View File

@ -3,7 +3,9 @@ package com.iqser.red.service.peristence.v1.server.integration.tests;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import java.util.List; import java.util.List;
import java.util.Set;
import com.iqser.red.service.peristence.v1.server.integration.client.ReanalysisClient;
import org.junit.Test; import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -36,6 +38,9 @@ public class FileProcessingTest extends AbstractPersistenceServerServiceTest {
@Autowired @Autowired
private UploadClient uploadClient; private UploadClient uploadClient;
@Autowired
private ReanalysisClient reanalysisClient;
@Test @Test
public void testFileProcessing() { public void testFileProcessing() {
@ -203,4 +208,21 @@ public class FileProcessingTest extends AbstractPersistenceServerServiceTest {
} }
@Test
public void testFileProcessingInErrorStateAndReanalyise() {
var dossier = dossierTesterAndProvider.provideTestDossier();
var file = fileTesterAndProvider.testAndProvideFile(dossier);
fileProcessingClient.analysisFailed(dossier.getId(), file.getId());
var loadedFile = fileClient.getFileStatus(dossier.getId(), file.getId());
assertThat(loadedFile.getProcessingStatus()).isEqualTo(ProcessingStatus.ERROR);
reanalysisClient.reanalyzeFiles(dossier.getId(), Set.of(loadedFile.getId()), true);
loadedFile = fileClient.getFileStatus(dossier.getId(), file.getId());
assertThat(loadedFile.getProcessingStatus()).isEqualTo(ProcessingStatus.FULL_PROCESSING);
}
} }