From a7d57581591c23fd1fd0ad0f4e8f9c6ce2745750 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Wed, 22 Apr 2026 15:50:45 +0200
Subject: fix: do not block earlier initial requests with error response (#281)

Requests with errors are blocked within DNPM:DIP and not used for MVH.

Any later accepted successful request with SUCCESS or WARNING should be used as ADDITION.---
 .../dev/dnpm/etl/processor/services/RequestProcessor.kt     | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

(limited to 'src/main/kotlin/dev')

diff --git a/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt b/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
index 7325265..f0eed7f 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
@@ -115,8 +115,8 @@ class RequestProcessor(
 
         if (
             appConfigProperties.postInitialSubmissionBlock &&
-            hasSuccessfullInitialSubmission(request.patientPseudonym()) &&
-            hasUnacceptedInitialSubmission(request.patientPseudonym())
+            hasSuccessfulInitialSubmission(request.patientPseudonym()) &&
+            hasUnacceptedSuccessfulInitialSubmission(request.patientPseudonym())
         ) {
             requestService.save(
                 Request(
@@ -136,8 +136,8 @@ class RequestProcessor(
 
         if (
             appConfigProperties.postInitialSubmissionBlock &&
-            hasSuccessfullInitialSubmission(request.patientPseudonym()) &&
-            !hasUnacceptedInitialSubmission(request.patientPseudonym())
+            hasSuccessfulInitialSubmission(request.patientPseudonym()) &&
+            !hasUnacceptedSuccessfulInitialSubmission(request.patientPseudonym())
         ) {
             // Use "addition" after "intial" with "Meldebestaetigung"
             request.content.metadata?.let {
@@ -184,16 +184,17 @@ class RequestProcessor(
         )
     }
 
-    private fun hasSuccessfullInitialSubmission(patientPseudonym: PatientPseudonym): Boolean {
+    private fun hasSuccessfulInitialSubmission(patientPseudonym: PatientPseudonym): Boolean {
         return this.requestService.allRequestsByPatientPseudonym(patientPseudonym).any {
             it.submissionType == SubmissionType.INITIAL &&
                     (it.status == RequestStatus.SUCCESS || it.status == RequestStatus.WARNING)
         }
     }
 
-    private fun hasUnacceptedInitialSubmission(patientPseudonym: PatientPseudonym): Boolean {
+    private fun hasUnacceptedSuccessfulInitialSubmission(patientPseudonym: PatientPseudonym): Boolean {
         return this.requestService.allRequestsByPatientPseudonym(patientPseudonym).any {
             it.submissionType == SubmissionType.INITIAL &&
+                    (it.status == RequestStatus.SUCCESS || it.status == RequestStatus.WARNING) &&
                     !(it.submissionAccepted || it.status == RequestStatus.BLOCKED_INITIAL)
         }
     }
-- 
cgit v1.2.3