From d9961a9baccaff511662b1aa1de18bdd02f94f5e Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Mon, 21 Sep 2026 11:43:03 +0200
Subject: feat: add switch/routing to send dedicated data to nNGM (#322)

---
 src/main/resources/application-dev.yml                            | 8 +++++++-
 .../resources/db/migration/mariadb/V0_18_0_1__Destination.sql     | 2 ++
 .../resources/db/migration/postgresql/V0_18_0_1__Destination.sql  | 2 ++
 src/main/resources/templates/fragments.html                       | 5 ++++-
 src/main/resources/templates/report.html                          | 2 +-
 5 files changed, 16 insertions(+), 3 deletions(-)
 create mode 100644 src/main/resources/db/migration/mariadb/V0_18_0_1__Destination.sql
 create mode 100644 src/main/resources/db/migration/postgresql/V0_18_0_1__Destination.sql

(limited to 'src/main/resources')

diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 6c1e51f..77bf157 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -119,6 +119,12 @@ app:
   #  input-topic: test_input
   #  output-topic: test_output
   #  output-response-topic: test_response
+  switch:
+    nngm:
+      uri: https://mvh-test.medicalsyn.com/api/v1.0/mvh-import/import-dnpm
+      api-key: a12b34decacdefg1213
+      icd10:
+        - C34
   security:
     admin-user: admin
     admin-password: "{noop}very-secret"
@@ -126,4 +132,4 @@ app:
 
 server:
   port: 8000
-  shutdown: immediate
\ No newline at end of file
+  shutdown: immediate
diff --git a/src/main/resources/db/migration/mariadb/V0_18_0_1__Destination.sql b/src/main/resources/db/migration/mariadb/V0_18_0_1__Destination.sql
new file mode 100644
index 0000000..a65c016
--- /dev/null
+++ b/src/main/resources/db/migration/mariadb/V0_18_0_1__Destination.sql
@@ -0,0 +1,2 @@
+ALTER TABLE request ADD COLUMN destination varchar(16) DEFAULT 'UNKNOWN';
+UPDATE request SET destination = 'UNKNOWN';
diff --git a/src/main/resources/db/migration/postgresql/V0_18_0_1__Destination.sql b/src/main/resources/db/migration/postgresql/V0_18_0_1__Destination.sql
new file mode 100644
index 0000000..a65c016
--- /dev/null
+++ b/src/main/resources/db/migration/postgresql/V0_18_0_1__Destination.sql
@@ -0,0 +1,2 @@
+ALTER TABLE request ADD COLUMN destination varchar(16) DEFAULT 'UNKNOWN';
+UPDATE request SET destination = 'UNKNOWN';
diff --git a/src/main/resources/templates/fragments.html b/src/main/resources/templates/fragments.html
index ea83ed2..1a7a257 100644
--- a/src/main/resources/templates/fragments.html
+++ b/src/main/resources/templates/fragments.html
@@ -54,7 +54,10 @@
             <div th:if="${request.type.value == 'delete'}">
                 <span>🗑 Löschanfrage vom </span><time th:datetime="${request.processedAt}">[[ ${request.processedAt} ]]</time>
             </div>
-            <div sec:authorize="hasRole('USER') or hasRole('ADMIN')" th:if="${postInitialSubmissionBlock}">
+            <div class="destination" th:if="${request.destination.value == 'kafka'}">Kafka Broker</div>
+            <div class="destination" th:if="${request.destination.value == 'dnpm_dip'}">DNPM:DIP</div>
+            <div class="destination" th:if="${request.destination.value == 'nngm_api'}">nNGM-API</div>
+            <div class="accepted" sec:authorize="hasRole('USER') or hasRole('ADMIN')" th:if="${postInitialSubmissionBlock}">
                 <button class="btn btn-green" hx-swap="outerHTML" th:hx-target="${'#request_' + request.uuid}" th:hx-delete="@{/submission/{requestId}/accepted(requestId=${request.uuid})}" th:if="${         request.submissionType.value == 'initial'         and (request.status.value == 'success' or request.status.value == 'warning')         and request.submissionAccepted == true}" title="Doch keine Meldebestätigung - jetzt blockieren">
                     🔓 Bestätigte Initialmeldung
                 </button>
diff --git a/src/main/resources/templates/report.html b/src/main/resources/templates/report.html
index bdc7457..b739bbf 100644
--- a/src/main/resources/templates/report.html
+++ b/src/main/resources/templates/report.html
@@ -34,7 +34,7 @@
                 <td th:if="${issue.severity.value == 'error'}" class="bg-red"><small>[[ ${issue.severity} ]]</small></td>
                 <td th:if="${issue.severity.value == 'fatal'}" class="bg-red"><small>[[ ${issue.severity} ]]</small></td>
                 <td>
-                    <div class="issue-message">[[ ${issue.getMessage()} ]]</div>
+                    <div class="issue-message">[[ ${issue.getMessageText()} ]]</div>
                     <div class="issue-path" th:if="${issue.path.isPresent()}">[[ ${issue.path.get()} ]]</div>
                     <div class="issue-path" th:if="${issue.path.isEmpty()}"><i>Keine Angabe</i></div>
                 </td>
-- 
cgit v1.2.3