pcvolkmer/etl-processor
1
0
Fork 0
mirror of https://github.com/pcvolkmer/etl-processor.git synced 2025-04-20 01:36:50 +00:00
Code Issues Releases Activity

Do not detect duplicates after deletion request

Browse Source
This commit is contained in:
Paul-Christian Volkmer 2023-08-04 11:43:23 +02:00
parent b14f2c1794
commit 459ad59c1d
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
View File

@ -46,12 +46,15 @@ class RequestProcessor(
val pid = mtbFile.patient.id val pid = mtbFile.patient.id
val pseudonymized = pseudonymizeService.pseudonymize(mtbFile) val pseudonymized = pseudonymizeService.pseudonymize(mtbFile)
val lastRequestForPatient = val allRequests = requestRepository.findAllByPatientIdOrderByProcessedAtDesc(pseudonymized.patient.id)
requestRepository.findAllByPatientIdOrderByProcessedAtDesc(pseudonymized.patient.id)
val lastMtbFileRequestForPatient = allRequests
.filter { it.type == RequestType.MTB_FILE } .filter { it.type == RequestType.MTB_FILE }
.firstOrNull { it.status == RequestStatus.SUCCESS || it.status == RequestStatus.WARNING } .firstOrNull { it.status == RequestStatus.SUCCESS || it.status == RequestStatus.WARNING }
if (null != lastRequestForPatient && lastRequestForPatient.fingerprint == fingerprint(mtbFile)) { val isLastRequestDeletion = allRequests.firstOrNull()?.type == RequestType.DELETE
if (null != lastMtbFileRequestForPatient && lastMtbFileRequestForPatient.fingerprint == fingerprint(mtbFile) && !isLastRequestDeletion) {
requestRepository.save( requestRepository.save(
Request( Request(
patientId = pseudonymized.patient.id, patientId = pseudonymized.patient.id,