feat: verbessere Onboarding-Workflow, verbessere mDNS-Discovery & ZNS-Import

Signed-off-by: StefanMoCoAt <stefan.mo.co@gmail.com>

backend/infrastructure/zns-importer/src/main/kotlin/at/mocode/zns/importer/ZnsImportService.kt

@@ -47,10 +47,10 @@ class ZnsImportService(
   companion object {
     private val CP850 = Charset.forName("Cp850")
 
-    private const val FILE_VEREIN = "VEREIN01.DAT"
-    private const val FILE_LIZENZ = "LIZENZ01.DAT"
-    private const val FILE_PFERDE = "PFERDE01.DAT"
-    private const val FILE_RICHT = "RICHT01.DAT"
+    private const val FILE_VEREIN = "VEREIN"
+    private const val FILE_LIZENZ = "LIZENZ"
+    private const val FILE_PFERDE = "PFERDE"
+    private const val FILE_RICHT = "RICHT"
   }
 
   /**
@@ -65,7 +65,16 @@ class ZnsImportService(
       while (entry != null) {
         val fileName = entry.name.uppercase().substringAfterLast("/")
 
-        if (fileName in setOf(FILE_VEREIN, FILE_LIZENZ, FILE_PFERDE, FILE_RICHT)) {
+        // Toleranter Check: Erkennt VEREIN01.DAT, VEREIN.DAT, etc.
+        val targetKey = when {
+          fileName.startsWith(FILE_VEREIN) -> FILE_VEREIN
+          fileName.startsWith(FILE_LIZENZ) -> FILE_LIZENZ
+          fileName.startsWith(FILE_PFERDE) -> FILE_PFERDE
+          fileName.startsWith(FILE_RICHT) -> FILE_RICHT
+          else -> null
+        }
+
+        if (targetKey != null && fileName.endsWith(".DAT")) {
           // Wir lesen den Stream direkt zeilenweise mit dem korrekten Encoding
           val lines = mutableListOf<String>()
           val reader = zip.bufferedReader(CP850)
@@ -78,8 +87,8 @@ class ZnsImportService(
             }
             line = reader.readLine()
           }
-          println("[DEBUG_LOG] Datei $fileName extrahiert: ${lines.size} Zeilen")
-          dateien[fileName] = lines
+          println("[DEBUG_LOG] Datei $fileName extrahiert als $targetKey: ${lines.size} Zeilen")
+          dateien[targetKey] = lines
         }
         zip.closeEntry()
         entry = zip.nextEntry
@@ -129,20 +138,20 @@ class ZnsImportService(
     var richterImportiert = 0
     var richterAktualisiert = 0
 
-    when (fileName) {
-      FILE_VEREIN -> {
+    when {
+      fileName.startsWith(FILE_VEREIN) -> {
         val (n, u) = importiereVereine(lines, fehler)
         vereineImportiert = n
         vereineAktualisiert = u
       }
 
-      FILE_LIZENZ -> {
+      fileName.startsWith(FILE_LIZENZ) -> {
         val (n, u) = importiereReiter(lines, fehler, warnungen)
         reiterImportiert = n
         reiterAktualisiert = u
       }
 
-      FILE_PFERDE -> {
+      fileName.startsWith(FILE_PFERDE) -> {
         if (mode == ZnsImportMode.FULL) {
           val (n, u) = importierePferde(lines, fehler)
           pferdeImportiert = n
@@ -150,7 +159,7 @@ class ZnsImportService(
         }
       }
 
-      FILE_RICHT -> {
+      fileName.startsWith(FILE_RICHT) -> {
         if (mode == ZnsImportMode.FULL) {
           val (n, u) = importiereFunktionaere(lines, fehler, warnungen)
           richterImportiert = n
@@ -211,6 +220,14 @@ class ZnsImportService(
       richterUpd = rUpd
     }
 
+    // Zusätzliche Warnung wenn Dateien fehlen
+    if (dateien[FILE_VEREIN] == null) warnungen.add("Vereinsdaten (VEREIN*.DAT) nicht gefunden.")
+    if (dateien[FILE_LIZENZ] == null) warnungen.add("Reiter/Lizenzdaten (LIZENZ*.DAT) nicht gefunden.")
+    if (mode == ZnsImportMode.FULL) {
+      if (dateien[FILE_PFERDE] == null) warnungen.add("Pferdedaten (PFERDE*.DAT) nicht gefunden.")
+      if (dateien[FILE_RICHT] == null) warnungen.add("Funktionärsdaten (RICHT*.DAT) nicht gefunden.")
+    }
+
     return ZnsImportResult(
       vereineImportiert = vereineNeu,
       vereineAktualisiert = vereineUpd,

backend/services/ping/ping-service/build.gradle.kts

@@ -3,6 +3,7 @@ plugins {
     alias(libs.plugins.kotlinSpring)
     alias(libs.plugins.kotlinJpa)
     alias(libs.plugins.spring.boot)
+  alias(libs.plugins.spring.dependencyManagement)
 }
 
 kotlin {

backend/services/ping/ping-service/src/main/resources/application.yaml

@@ -43,14 +43,14 @@ spring:
     consul:
       host: ${SPRING_CLOUD_CONSUL_HOST:localhost}
       port: ${SPRING_CLOUD_CONSUL_PORT:8500}
-      enabled: ${CONSUL_ENABLED:true}
+      enabled: ${SPRING_CLOUD_CONSUL_ENABLED:true}
       discovery:
-        enabled: ${CONSUL_ENABLED:true}
-        register: ${CONSUL_ENABLED:true}
-        prefer-ip-address: true
-        health-check-path: /actuator/health
+        enabled: ${SPRING_CLOUD_CONSUL_DISCOVERY_ENABLED:true}
+        register: ${SPRING_CLOUD_CONSUL_DISCOVERY_REGISTER:true}
+        prefer-ip-address: ${SPRING_CLOUD_CONSUL_DISCOVERY_PREFER_IP_ADDRESS:true}
+        health-check-path: ${SPRING_CLOUD_CONSUL_DISCOVERY_HEALTH_CHECK_PATH:/actuator/health}
         health-check-interval: 10s
-        health-check-port: 8082
+        health-check-port: ${SERVER_PORT:8082}
         instance-id: ${spring.application.name}:${server.port}:${random.uuid}
         service-name: ${spring.application.name}