Refactor BundeslandRepository, implement V012 migration for Reiter master data changes, harmonize domain models, resolve repository interface inconsistencies, and enhance ZNS import with relational mapping improvements.

2026-04-06 16:51:14 +02:00 · 2026-04-06 16:51:14 +02:00 · 1b6f8e7c59
commit 1b6f8e7c59
parent 0ae9a1f1b8
8 changed files with 75 additions and 28 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@ -57,6 +57,20 @@ Versionierung folgt [Semantic Versioning](https://semver.org/lang/de/).

 ---

+## [1.0.3-SNAPSHOT] — 2026-04-06
+
+### Hinzugefügt
+- **Masterdata:** Refactoring der Reiter-Stammdaten (LIZENZ01.DAT). Bundesland, Verein und Nation werden nun über Master-Tabellen referenziert.
+- **Domain:** Validierungslogik für die 8-stellige OEPS-Mitgliedsnummer im `Reiter`-Modell implementiert.
+- **Infrastructure:** Neue Tabellen `reiter_lizenz` (1:n Beziehung) und Migration `V012` zur Schemaanpassung und Datenbereinigung eingeführt.
+- **ZNS-Import:** Automatisches Auflösen von Relationen (Verein nach Name, Bundesland nach Nummer, Nation nach ISO-Code) während des Reiter-Imports.
+
+### Behoben
+- **Build:** Kompilierfehler in `BundeslandExposedRepository.kt` behoben (inkonsistente Rückgabetypen im `BundeslandRepository`-Interface).
+- **Infrastruktur:** Fehlendes Autowiring im `zns-import-service` durch explizite Bean-Definitionen für alle Repositories in `ZnsImportServiceApplication.kt` behoben.
+- **Domain:** Kompilierfehler in `Bundesland.kt` behoben (uninitialisierte Eigenschaft `bundeslandId` entfernt).
+- **Migration:** SQL-Syntaxfehler in `V012` behoben (korrekter Fremdschlüssel-Constraint für `reiter_lizenz` und Wiederherstellung des `DO $$`-Blocks).
+
 ## [1.0.2-SNAPSHOT] — 2026-04-06

 ### Geändert
--- a/backend/services/masterdata/masterdata-domain/src/commonMain/kotlin/at/mocode/masterdata/domain/repository/BundeslandRepository.kt
+++ b/backend/services/masterdata/masterdata-domain/src/commonMain/kotlin/at/mocode/masterdata/domain/repository/BundeslandRepository.kt
@ -1,6 +1,7 @@
@file:OptIn(kotlin.uuid.ExperimentalUuidApi::class)
 package at.mocode.masterdata.domain.repository

+import at.mocode.masterdata.domain.model.Bundesland
 import at.mocode.masterdata.domain.model.BundeslandDefinition
 import kotlin.uuid.Uuid

@ -12,7 +13,7 @@ interface BundeslandRepository {
    /**
     * ZNS-Spezifisch: Sucht ein Bundesland anhand seiner Nummer (01-09).
     */
-    suspend fun findByNr(nr: Int): at.mocode.masterdata.domain.model.BundeslandDefinition?
+    suspend fun findByNr(nr: Int): BundeslandDefinition?

    /**
     * Finds a federal state by its unique ID.
--- a/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/BundeslandRepositoryImpl.kt
+++ b/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/BundeslandRepositoryImpl.kt
@ -181,7 +181,7 @@ class BundeslandRepositoryImpl : BundeslandRepository {
          it[createdAt] = bundesland.createdAt
          it[updatedAt] = bundesland.updatedAt
        }
-      } catch (e: Exception) {
+      } catch (_: Exception) {
        // Race-Condition → erneut Update
        if (bundesland.kuerzel != null) {
          BundeslandTable.update({ (BundeslandTable.landId eq bundesland.landId) and (BundeslandTable.kuerzel eq bundesland.kuerzel) }) {
--- a/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/reiter/BundeslandExposedRepository.kt
+++ b/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/reiter/BundeslandExposedRepository.kt
@ -2,10 +2,11 @@

 package at.mocode.masterdata.infrastructure.persistence.reiter

-import at.mocode.masterdata.domain.model.Bundesland
 import at.mocode.masterdata.domain.model.BundeslandDefinition
 import at.mocode.masterdata.domain.repository.BundeslandRepository
 import at.mocode.core.utils.database.DatabaseFactory
+import at.mocode.masterdata.infrastructure.persistence.BundeslandTable
+import kotlinx.datetime.Clock
 import org.jetbrains.exposed.v1.core.ResultRow
 import org.jetbrains.exposed.v1.core.eq
 import org.jetbrains.exposed.v1.jdbc.*
@ -16,14 +17,22 @@ import kotlin.uuid.Uuid
 * Hinweis: Implementiert nur die für den ZNS-Import notwendigen Methoden.
 */
 class BundeslandExposedRepository : BundeslandRepository {
-    private fun rowToDom(row: ResultRow) = Bundesland(
-        id = row[BundeslandTable.id],
+    private fun rowToDom(row: ResultRow) = BundeslandDefinition(
+        bundeslandId = row[BundeslandTable.id],
+        landId = row[BundeslandTable.landId],
        bundeslandNr = row[BundeslandTable.bundeslandNr],
-        bezeichnung = row[BundeslandTable.bezeichnung],
-        wappenUrl = row[BundeslandTable.wappenUrl]
+        oepsCode = row[BundeslandTable.oepsCode],
+        iso3166_2_Code = row[BundeslandTable.iso3166_2_Code],
+        name = row[BundeslandTable.name],
+        kuerzel = row[BundeslandTable.kuerzel],
+        wappenUrl = row[BundeslandTable.wappenUrl],
+        istAktiv = row[BundeslandTable.istAktiv],
+        sortierReihenfolge = row[BundeslandTable.sortierReihenfolge],
+        createdAt = row[BundeslandTable.createdAt],
+        updatedAt = row[BundeslandTable.updatedAt]
    )

-    override suspend fun findByNr(nr: Int): Bundesland? = DatabaseFactory.dbQuery {
+    override suspend fun findByNr(nr: Int): BundeslandDefinition? = DatabaseFactory.dbQuery {
        BundeslandTable.selectAll().where { BundeslandTable.bundeslandNr eq nr }
            .map(::rowToDom)
            .singleOrNull()
--- a/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/verein/VereinExposedRepository.kt
+++ b/backend/services/masterdata/masterdata-infrastructure/src/main/kotlin/at/mocode/masterdata/infrastructure/persistence/verein/VereinExposedRepository.kt
@ -9,7 +9,6 @@ import at.mocode.masterdata.domain.repository.VereinRepository
 import org.jetbrains.exposed.v1.core.ResultRow
 import org.jetbrains.exposed.v1.core.eq
 import org.jetbrains.exposed.v1.core.like
-import org.jetbrains.exposed.v1.core.or
 import org.jetbrains.exposed.v1.jdbc.*
 import kotlin.uuid.ExperimentalUuidApi
 import kotlin.uuid.Uuid
--- a/backend/services/masterdata/masterdata-service/src/main/resources/db/migration/V012__Reiter_Masterdata_Refactoring.sql
+++ b/backend/services/masterdata/masterdata-service/src/main/resources/db/migration/V012__Reiter_Masterdata_Refactoring.sql
@ -36,16 +36,15 @@ ALTER TABLE reiter ADD COLUMN IF NOT EXISTS nation_id UUID;
 -- Fremdschlüssel-Constraints
 ALTER TABLE reiter ADD CONSTRAINT fk_reiter_verein FOREIGN KEY (verein_id) REFERENCES verein(verein_id);
 ALTER TABLE reiter ADD CONSTRAINT fk_reiter_bundesland FOREIGN KEY (bundesland_id) REFERENCES bundesland(id);
-ALTER TABLE reiter ADD CONSTRAINT fk_reiter_nation FOREIGN KEY (nation_id) REFERENCES land(id);
-ALTER TABLE reiter ADD CONSTRAINT fk_reiter_lizenz_reiter FOREIGN KEY (reiter_id) REFERENCES reiter(reiter_id) ON DELETE CASCADE;
+ALTER TABLE reiter ADD CONSTRAINT fk_reiter_nation FOREIGN KEY (nation_id) REFERENCES land(land_id);
+ALTER TABLE reiter_lizenz ADD CONSTRAINT fk_reiter_lizenz_reiter FOREIGN KEY (reiter_id) REFERENCES reiter(reiter_id) ON DELETE CASCADE;

 -- 3. Daten gemäß OEPS-Spezifikation korrigieren (für Österreich)
-
 DO $$
 DECLARE
    austria_id UUID;
 BEGIN
-    SELECT id INTO austria_id FROM land WHERE iso_alpha2_code = 'AT';
+    SELECT land_id INTO austria_id FROM land WHERE iso_alpha2_code = 'AT';

    IF austria_id IS NOT NULL THEN
        -- Bestehende Einträge löschen oder aktualisieren
--- a/backend/services/zns-import/zns-import-service/src/main/kotlin/at/mocode/zns/import/service/ZnsImportServiceApplication.kt
+++ b/backend/services/zns-import/zns-import-service/src/main/kotlin/at/mocode/zns/import/service/ZnsImportServiceApplication.kt
@ -1,32 +1,57 @@
 package at.mocode.zns.import.service

-import at.mocode.masterdata.domain.repository.FunktionaerRepository
-import at.mocode.masterdata.domain.repository.HorseRepository
-import at.mocode.masterdata.domain.repository.ReiterRepository
-import at.mocode.masterdata.domain.repository.VereinRepository
+import at.mocode.masterdata.domain.repository.*
+import at.mocode.masterdata.infrastructure.persistence.*
+import at.mocode.masterdata.infrastructure.persistence.funktionaer.FunktionaerExposedRepository
+import at.mocode.masterdata.infrastructure.persistence.pferd.HorseExposedRepository
+import at.mocode.masterdata.infrastructure.persistence.reiter.ReiterExposedRepository
+import at.mocode.masterdata.infrastructure.persistence.verein.VereinExposedRepository
 import at.mocode.zns.importer.ZnsImportService
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
 import org.springframework.context.annotation.Bean
-import org.springframework.context.annotation.ComponentScan

@SpringBootApplication
-@ComponentScan(
-  basePackages = [
-    "at.mocode.zns.import.service",
-    "at.mocode.masterdata.infrastructure"
-  ]
-)
 class ZnsImportServiceApplication {

+  // Manuelle Bean-Definitionen für die Repositories, da diese in der Infrastruktur
+  // keine @Repository-Annotationen haben und wir MasterdataConfiguration nicht importieren wollen.
+
+  @Bean
+  fun landRepository(): LandRepository = LandRepositoryImpl()
+
+  @Bean
+  fun bundeslandRepository(): BundeslandRepository = BundeslandRepositoryImpl()
+
+  @Bean
+  fun vereinRepository(): VereinRepository = VereinExposedRepository()
+
+  @Bean
+  fun reiterRepository(): ReiterRepository = ReiterExposedRepository()
+
+  @Bean
+  fun horseRepository(): HorseRepository = HorseExposedRepository()
+
+  @Bean
+  fun funktionaerRepository(): FunktionaerRepository = FunktionaerExposedRepository()
+
  @Bean
  fun znsImportService(
    vereinRepository: VereinRepository,
    reiterRepository: ReiterRepository,
    horseRepository: HorseRepository,
-    funktionaerRepository: FunktionaerRepository
+    funktionaerRepository: FunktionaerRepository,
+    landRepository: LandRepository,
+    bundeslandRepository: BundeslandRepository
  ): ZnsImportService {
-    return ZnsImportService(vereinRepository, reiterRepository, horseRepository, funktionaerRepository)
+    return ZnsImportService(
+      vereinRepository,
+      reiterRepository,
+      horseRepository,
+      funktionaerRepository,
+      landRepository,
+      bundeslandRepository
+    )
  }
 }

--- a/docs/01_Architecture/MASTER_ROADMAP.md
+++ b/docs/01_Architecture/MASTER_ROADMAP.md
@ -125,8 +125,8 @@ und über definierte Schnittstellen kommunizieren.

 #### 👷 Agent: Backend Developer

-*   [x] **ZNS-Importer:** Support für Richter-Import (RICHT01.DAT) vervollständigt.
-*   [x] **Masterdata:** Qualifikations-System auf professionelle Master-Daten-Referenzierung (`QualifikationMasterTable`) umgestellt.
+*   [x] **ZNS-Importer:** Support für Richter-Import (RICHT01.DAT) und Reiter-Refactoring (LIZENZ01.DAT) vervollständigt.
+*   [x] **Masterdata:** Qualifikations-System und Personen-Referenzen (Vereine, Bundesländer, Nationen) auf professionelle Master-Daten umgestellt.
 *   [x] **Database:** Initialisierung der Funktionärs-Tabellen stabilisiert (PSQLException Fix).
 *   [x] **`actor-context`:** Domain-Modelle für `Pferd`, `Funktionaer`, `Verein` implementiert.
 *   [x] **`registration-context`:** `DomBewerb`, `DomAbteilung`, `DomStartliste` implementiert.