Merge pull request 'Feature/56 anzeige korrektur' (#59) from feature/56-anzeige-korrektur into unstable

Reviewed-on: #59

changelog.txt

@@ -1,3 +1,8 @@
+- Neu: Anzeige für den Eigentümer im Tab „Eigentümer“. „Daten anzeigen“ in der Trefferliste zeigt Name, Anschrift und E-Mail der gewählten Einträge in einem eigenen Fenster mit Rahmen, das der Bearbeiter auf den Bildschirm des Eigentümers schiebt; Größe und Lage gelten bis zum Neustart von QGIS für die nächste Sitzung weiter. Die Sitzung wird von Hand begonnen und beendet; „Anzeige leeren“ entfernt die Daten, ohne das Fenster zu schließen, damit der nächste Eigentümer sie nicht sieht (#56)
+- Neu: Angezeigte Daten lassen sich mit „Korrigieren …“ ändern. Die Eigentümerdatei bleibt unverändert; jede Änderung wird mit Zeitpunkt, Konto, Personen-ID, altem und neuem Wert an „<Eigentümerdatei>_korrekturen.csv“ angehängt und sofort angezeigt; Pfad und Name der Korrektur-Datei stehen unter den Knöpfen (#56)
+- Neu: Eigentümersuche im Tab „Eigentümer“. Den Serienbriefexport (CSV) von Hand als Layer laden, als Eigentümerdatei wählen, Name und/oder Vorname eingeben: Die Trefferliste zeigt Name, Anschrift, E-Mail, den Wert von PER_RECHTSPERSON (0, 1, 5 oder 9, noch nicht entschlüsselt) und das Kennzeichen „verstorben“. Gleiche Personen mit gleicher Anschrift werden zusammengefasst, Groß-/Kleinschreibung und Umlautschreibweise spielen keine Rolle (#56)
+- Intern: Die Auswahltabelle aus „Verfahrensgebiete aus Landkreis laden“ (Suchfeld, „Alle auswählen“, Mehrfachauswahl) ist als gemeinsame Funktion herausgelöst und wird von der Eigentümer-Trefferliste mitgenutzt; der Landkreis-Dialog verhält sich unverändert (#56)
+- Neu: Tab „Eigentümer“ mit Flurstückssuche. Gemarkung (Name oder Nummer) und Flurstücksnummer (z. B. 562 oder 12/3) eingeben, die Treffer werden im Layer „Flurstücke“ ausgewählt und angezoomt. Ohne Nenner werden alle Flurstücke mit diesem Zähler gefunden. Fehlt der Layer „Flurstücke“, weist ein Dialog darauf hin, zuerst Verfahrensgebiet und Flurstücke aus ALKIS zu laden (#56)
 - Bugfix: Nach dem Laden des Verfahrensgebiets (ALKIS oder Shape) sprang die Karte an die falsche Stelle, wenn ein anderes Projekt-KBS als EPSG:25833 eingestellt war. Der Zoom rechnet die Ausdehnung jetzt in das KBS der Kartenansicht um (`zoom_auf_layer` aus sn_basis, setzt sn_basis mit Basis #99 voraus) (Basis #99)
 - Neu: Grenzpunkte aus ALKIS werden nach dem Laden im ALKIS-Stil dargestellt (styles/alkis_grenzpunkte.qml), statt ungestylt zu bleiben (#53)
 - Intern: Tests von TestFlurstueckAlkis an die seit längerem geänderte Ladelogik angeglichen (Mocks zeigten noch auf die alte Ein-Query-/Zwei-Knopf-Variante), bbox-Dokumentation in flurstueck_alkis.py korrigiert (bbox wird nicht mehr ausgewertet) – keine Verhaltensänderung (Test-Audit #16)

functions/eigentuemer_korrektur.py

@@ -0,0 +1,128 @@
+"""sn_verfahrensgebiet/functions/eigentuemer_korrektur.py – Korrekturen beim Datenabgleich (#56).
+
+Der Bearbeiter korrigiert im Plugin Name, Anschrift oder E-Mail eines
+angezeigten Eigentümers. Die Eigentümerdatei (Serienbriefexport) bleibt
+unverändert; jede Änderung wird als eigene Zeile an eine Korrektur-CSV
+angehängt, standardmäßig ``<Eigentümerdatei>_korrekturen.csv`` im selben Ordner.
+
+Spalten der Korrektur-CSV (UTF-8 mit BOM, Komma, wie der Export):
+``Zeitpunkt, EIG_KONTO, PER_ID, Feld, Alter Wert, Neuer Wert``. ``Feld`` ist
+der Spaltenname aus dem Export. Gehören mehrere Konten oder Personen-IDs zu
+einem Eintrag, stehen sie durch Leerzeichen getrennt in einer Zelle.
+
+**Datenschutz:** Die Korrektur-CSV enthält Personendaten. Sie liegt neben
+dem Export und ist genauso zu schützen wie dieser. Das Modul schreibt
+nichts auf die Konsole und zeigt keine Dialoge.
+"""
+
+from __future__ import annotations
+
+import csv
+import os
+import re
+from dataclasses import replace
+from datetime import datetime
+from typing import Dict, List, Optional, Tuple
+from urllib.parse import unquote, urlparse
+
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer, SPALTEN
+
+#: Korrigierbare Felder: (Schlüssel, Beschriftung). Der Spaltenname kommt aus SPALTEN.
+FELDER: List[Tuple[str, str]] = [
+    ("anrede", "Anrede"),
+    ("titel", "Titel"),
+    ("vorname", "Vorname"),
+    ("nachname", "Name"),
+    ("strasse", "Straße"),
+    ("plz", "PLZ"),
+    ("wohnort", "Wohnort"),
+    ("ortsteil", "Ortsteil"),
+    ("email", "E-Mail"),
+]
+KOPFZEILE = ["Zeitpunkt", "EIG_KONTO", "PER_ID", "Feld", "Alter Wert", "Neuer Wert"]
+ENDUNG_KORREKTUR = "_korrekturen.csv"
+
+Aenderung = Tuple[str, str, str]  # (Schlüssel, alter Wert, neuer Wert)
+
+
+def feldwerte(eigentuemer: Eigentuemer) -> Dict[str, str]:
+    """Die korrigierbaren Werte eines Eintrags; mehrere E-Mails durch ``, `` getrennt."""
+    werte = {schluessel: getattr(eigentuemer, schluessel, "") for schluessel, _ in FELDER if schluessel != "email"}
+    werte["email"] = ", ".join(eigentuemer.emails)
+    return werte
+
+
+def ermittle_aenderungen(eigentuemer: Eigentuemer, neue_werte: Dict[str, str]) -> List[Aenderung]:
+    """Vergleicht die Eingaben mit dem Eintrag; Leerraum am Rand und doppelte Leerzeichen zählen nicht."""
+    alt = feldwerte(eigentuemer)
+    aenderungen: List[Aenderung] = []
+    for schluessel, _ in FELDER:
+        if schluessel not in neue_werte:
+            continue
+        neu = " ".join(str(neue_werte[schluessel] or "").split())
+        if neu != alt[schluessel]:
+            aenderungen.append((schluessel, alt[schluessel], neu))
+    return aenderungen
+
+
+def wende_an(eigentuemer: Eigentuemer, aenderungen: List[Aenderung]) -> Eigentuemer:
+    """Liefert den Eintrag mit den neuen Werten (für die Anzeige)."""
+    felder = {}
+    for schluessel, _alt, neu in aenderungen:
+        if schluessel == "email":
+            felder["emails"] = tuple(t.strip() for t in neu.split(",") if t.strip())
+        else:
+            felder[schluessel] = neu
+    return replace(eigentuemer, **felder)
+
+
+def korrektur_pfad(layer_quelle: str) -> Optional[str]:
+    """Vorgeschlagene Korrektur-CSV neben der Eigentümerdatei, oder ``None``.
+
+    Versteht die Quellangaben des Textdatei-Providers
+    (``file:///D:/ordner/export.csv?type=csv&…``) und des OGR-Providers
+    (``D:/ordner/export.csv|layername=export``).
+    """
+    quelle = (layer_quelle or "").strip()
+    if not quelle:
+        return None
+    if quelle.lower().startswith("file:"):
+        pfad = unquote(urlparse(quelle).path)
+        if re.match(r"^/[A-Za-z]:", pfad):
+            pfad = pfad[1:]
+    else:
+        pfad = quelle.split("|", 1)[0]
+    stamm, endung = os.path.splitext(pfad)
+    if endung.lower() != ".csv":
+        return None
+    return stamm + ENDUNG_KORREKTUR
+
+
+def schreibe_korrekturen(
+    pfad: str,
+    eigentuemer: Eigentuemer,
+    aenderungen: List[Aenderung],
+    zeitpunkt: Optional[datetime] = None,
+) -> int:
+    """Hängt die Änderungen an die Korrektur-CSV an und gibt die Zahl der Zeilen zurück.
+
+    Legt die Datei mit Kopfzeile an, wenn sie fehlt oder leer ist.
+
+    Raises
+    ------
+    OSError
+        Die Datei lässt sich nicht schreiben.
+    """
+    if not aenderungen:
+        return 0
+    stempel = (zeitpunkt or datetime.now()).strftime("%Y-%m-%d %H:%M:%S")
+    konten = " ".join(eigentuemer.konten)
+    per_ids = " ".join(eigentuemer.per_ids)
+    neu_anlegen = not os.path.exists(pfad) or os.path.getsize(pfad) == 0
+    with open(pfad, "a", encoding="utf-8-sig" if neu_anlegen else "utf-8", newline="") as datei:
+        schreiber = csv.writer(datei, delimiter=",", lineterminator="\r\n")
+        if neu_anlegen:
+            schreiber.writerow(KOPFZEILE)
+        for schluessel, alt, neu in aenderungen:
+            schreiber.writerow([stempel, konten, per_ids, SPALTEN[schluessel], alt, neu])
+    return len(aenderungen)

functions/eigentuemer_suche.py

@@ -0,0 +1,229 @@
+"""sn_verfahrensgebiet/functions/eigentuemer_suche.py – Eigentümersuche in einer CSV (#56).
+
+Die Eigentümerdaten kommen als CSV-Export (Serienbriefexport, Kopfzeile siehe
+:data:`SPALTEN`), den der Anwender von Hand als Layer ins Projekt lädt. Das
+Plugin speichert davon nichts, es liest nur den Layer.
+
+Gesucht wird über Nachname und Vorname, ohne Rücksicht auf Groß- und
+Kleinschreibung und Umlautschreibweise (``Müller`` findet ``Mueller``). Ein
+leeres Feld schränkt nicht ein. Zeilen mit gleichem Namen und gleicher Anschrift
+werden zu einem :class:`Eigentuemer` zusammengefasst; dieselbe Person mit einer
+anderen Anschrift bleibt ein eigener Eintrag.
+
+**Datenschutz:** Das Modul schreibt keine Personendaten in Ausgaben oder
+Meldungen. Es zeigt keine Dialoge; Fehler kommen als
+:class:`EigentuemerSucheFehler` mit einer Meldung ohne Personendaten zurück.
+"""
+
+from __future__ import annotations
+
+from dataclasses import dataclass
+from typing import Dict, List, Optional, Tuple
+
+from sn_basis.functions import QgsProject
+
+#: Spalten des Serienbriefexports, die das Plugin auswertet.
+SPALTEN = {
+    "konto": "EIG_KONTO",
+    "per_id": "PER_ID",
+    "verstorben": "PER_VERSTORBEN",
+    "anrede": "Anrede",
+    "titel": "Titel",
+    "vorname": "Vorname",
+    "nachname": "Nachname",
+    "ortsteil": "OT",
+    "strasse": "STRASSE",
+    "plz": "PLZ",
+    "wohnort": "WOHNORT",
+    "email": "Email",
+    "rechtsperson": "PER_RECHTSPERSON",
+}
+PFLICHTSPALTEN = ("Nachname", "Vorname")
+
+_NEIN_WERTE = {"", "0", "n", "nein", "f", "false", "falsch", "null"}
+_UMLAUTE = str.maketrans({"ä": "ae", "ö": "oe", "ü": "ue"})
+
+
+class EigentuemerSucheFehler(Exception):
+    """Eingabe- oder Layerfehler; der Text enthält keine Personendaten."""
+
+
+@dataclass(frozen=True)
+class Eigentuemer:
+    """Ein Treffer der Eigentümersuche, zusammengefasst über gleiche Zeilen."""
+
+    anrede: str = ""
+    titel: str = ""
+    vorname: str = ""
+    nachname: str = ""
+    strasse: str = ""
+    plz: str = ""
+    wohnort: str = ""
+    ortsteil: str = ""
+    emails: Tuple[str, ...] = ()
+    verstorben: bool = False
+    rechtsperson: Tuple[str, ...] = ()
+    per_ids: Tuple[str, ...] = ()
+    konten: Tuple[str, ...] = ()
+    feature_ids: Tuple[int, ...] = ()
+
+    @property
+    def name(self) -> str:
+        """``Nachname, Titel Vorname`` für Listen."""
+        vorne = " ".join(t for t in (self.titel, self.vorname) if t)
+        return ", ".join(t for t in (self.nachname, vorne) if t)
+
+    @property
+    def anschrift(self) -> str:
+        """Einzeilige Anschrift, z. B. ``Hauptstraße 1, 01234 Musterstadt, OT Beispiel``."""
+        ort = " ".join(t for t in (self.plz, self.wohnort) if t)
+        ortsteil = self.ortsteil
+        if ortsteil and not ortsteil.upper().startswith("OT"):
+            ortsteil = f"OT {ortsteil}"
+        return ", ".join(t for t in (self.strasse, ort, ortsteil) if t)
+
+    @property
+    def hinweise(self) -> str:
+        """Kennzeichen für die Trefferliste (nicht für das Anzeigefenster)."""
+        return "verstorben" if self.verstorben else ""
+
+    @property
+    def rechtsperson_text(self) -> str:
+        """Rohwert(e) von ``PER_RECHTSPERSON`` (bekannt: 0, 1, 5, 9), noch nicht entschlüsselt."""
+        return ", ".join(self.rechtsperson)
+
+
+def _text(wert) -> str:
+    """Attributwert als bereinigter Text; QGIS-NULL und ``None`` werden leer."""
+    if wert is None:
+        return ""
+    ist_null = getattr(wert, "isNull", None)
+    if callable(ist_null):
+        try:
+            if ist_null():
+                return ""
+        except Exception:
+            pass
+    text = " ".join(str(wert).split())
+    return "" if text == "NULL" else text
+
+
+def _plz(text: str) -> str:
+    """Stellt führende Nullen wieder her.
+
+    QGIS erkennt beim Laden einer CSV Feldtypen und liest ``01067`` dann als
+    Ganzzahl ``1067`` – in Sachsen beginnt fast jede PLZ mit 0.
+    """
+    if text.endswith(".0") and text[:-2].isdigit():
+        text = text[:-2]
+    return text.zfill(5) if text.isdigit() and len(text) < 5 else text
+
+
+def _ist_gesetzt(wert) -> bool:
+    return _text(wert).casefold() not in _NEIN_WERTE
+
+
+def _vergleichstext(text: str) -> str:
+    """Für die Suche: Groß-/Kleinschreibung, ß und Umlautschreibweise angleichen."""
+    return " ".join(text.split()).casefold().translate(_UMLAUTE)
+
+
+def _spalten_des_layers(layer) -> Dict[str, str]:
+    """Ordnet die Spaltennamen des Layers den Schlüsseln aus :data:`SPALTEN` zu.
+
+    Verglichen wird ohne Groß-/Kleinschreibung und ohne Byte-Order-Mark, das
+    beim Laden einer UTF-8-CSV an der ersten Spalte hängen bleiben kann.
+    """
+    vorhanden = {}
+    for name in layer.fields().names():
+        vorhanden[str(name).replace("", "").strip().casefold()] = name
+    return {
+        schluessel: vorhanden[spalte.casefold()]
+        for schluessel, spalte in SPALTEN.items()
+        if spalte.casefold() in vorhanden
+    }
+
+
+def ist_eigentuemerlayer(layer) -> bool:
+    """``True``, wenn der Layer die Spalten ``Nachname`` und ``Vorname`` hat."""
+    try:
+        spalten = _spalten_des_layers(layer)
+    except Exception:
+        return False
+    return "nachname" in spalten and "vorname" in spalten
+
+
+def eigentuemerlayer_im_projekt() -> List[object]:
+    """Alle Layer des Projekts, die als Eigentümerdatei taugen, nach Namen sortiert."""
+    layer = [lyr for lyr in QgsProject.instance().mapLayers().values() if ist_eigentuemerlayer(lyr)]
+    return sorted(layer, key=lambda lyr: lyr.name().casefold())
+
+
+def _gruppenschluessel(werte: Dict[str, str]) -> Tuple[str, ...]:
+    return tuple(werte[k].casefold() for k in ("nachname", "vorname", "strasse", "plz", "wohnort", "ortsteil"))
+
+
+def suche_eigentuemer(layer, nachname: str, vorname: str) -> List[Eigentuemer]:
+    """Sucht Eigentümer, deren Nach- und Vorname die Eingaben enthalten.
+
+    Raises
+    ------
+    EigentuemerSucheFehler
+        Beide Felder sind leer oder dem Layer fehlen die Pflichtspalten.
+    """
+    such_nachname = _vergleichstext(nachname or "")
+    such_vorname = _vergleichstext(vorname or "")
+    if not such_nachname and not such_vorname:
+        raise EigentuemerSucheFehler("Bitte einen Namen oder Vornamen eingeben.")
+
+    spalten = _spalten_des_layers(layer)
+    if "nachname" not in spalten or "vorname" not in spalten:
+        raise EigentuemerSucheFehler(
+            f"Der Layer „{layer.name()}“ hat nicht die Spalten "
+            f"{' und '.join(PFLICHTSPALTEN)}. Ist es der Serienbriefexport?"
+        )
+
+    gruppen: Dict[Tuple[str, ...], dict] = {}
+    for feature in layer.getFeatures():
+        werte = {k: _text(feature[spalte]) for k, spalte in spalten.items()}
+        for k in SPALTEN:
+            werte.setdefault(k, "")
+        werte["plz"] = _plz(werte["plz"])
+        if such_nachname and such_nachname not in _vergleichstext(werte["nachname"]):
+            continue
+        if such_vorname and such_vorname not in _vergleichstext(werte["vorname"]):
+            continue
+
+        gruppe = gruppen.setdefault(_gruppenschluessel(werte), {
+            "werte": werte, "emails": [], "per_ids": [], "konten": [], "feature_ids": [],
+            "verstorben": False, "rechtsperson": [],
+        })
+        for k in ("anrede", "titel"):
+            if not gruppe["werte"][k] and werte[k]:
+                gruppe["werte"][k] = werte[k]
+        for liste, wert in (("emails", werte["email"]), ("per_ids", werte["per_id"]),
+                            ("konten", werte["konto"]), ("rechtsperson", werte["rechtsperson"])):
+            if wert and wert not in gruppe[liste]:
+                gruppe[liste].append(wert)
+        gruppe["feature_ids"].append(feature.id())
+        gruppe["verstorben"] = gruppe["verstorben"] or _ist_gesetzt(werte["verstorben"])
+
+    treffer = []
+    for gruppe in gruppen.values():
+        w = gruppe["werte"]
+        treffer.append(Eigentuemer(
+            anrede=w["anrede"], titel=w["titel"], vorname=w["vorname"], nachname=w["nachname"],
+            strasse=w["strasse"], plz=w["plz"], wohnort=w["wohnort"], ortsteil=w["ortsteil"],
+            emails=tuple(gruppe["emails"]),
+            verstorben=gruppe["verstorben"], rechtsperson=tuple(gruppe["rechtsperson"]),
+            per_ids=tuple(gruppe["per_ids"]), konten=tuple(gruppe["konten"]),
+            feature_ids=tuple(gruppe["feature_ids"]),
+        ))
+    return sorted(treffer, key=lambda e: (e.nachname.casefold(), e.vorname.casefold(), e.wohnort.casefold()))
+
+
+def hole_layer(layer_id: Optional[str]):
+    """Layer zur ID aus dem Projekt oder ``None``."""
+    if not layer_id:
+        return None
+    return QgsProject.instance().mapLayer(layer_id)

functions/flurstueck_suche.py

@@ -0,0 +1,175 @@
+"""sn_verfahrensgebiet/functions/flurstueck_suche.py – Flurstückssuche im Layer „Flurstücke“ (#56).
+
+Findet ein Flurstück über Gemarkung und Flurstücksnummer im Layer „Flurstücke“,
+den der Bearbeitungs-Tab aus ALKIS lädt. Verglichen wird das
+``flurstueckskennzeichen``, nicht die von QGIS abgeflachten Einzelfelder des
+WFS – deren Namen hängen vom Provider ab, das Kennzeichen nicht.
+
+Aufbau des Kennzeichens (20 Zeichen, unbesetzte Teile füllt ALKIS mit ``_``)::
+
+    14 0268 ___ 00562 ____ 00
+    │  │    │   │     │    └ Flurstücksfolge
+    │  │    │   │     └ Nenner
+    │  │    │   └ Zähler
+    │  │    └ Flur (in Sachsen unbesetzt)
+    │  └ Gemarkungsnummer
+    └ Land
+
+Die Gemarkung darf als Nummer oder als Name eingegeben werden. Namen werden
+über den Layer „Gemarkungen“ (vereinfachter ALKIS-Dienst, Feld ``ave_name``)
+in Nummern übersetzt. Das Modul zeigt keine Dialoge; Fehler kommen als
+:class:`FlurstueckSucheFehler` mit einer Meldung für den Nutzer zurück.
+"""
+
+from __future__ import annotations
+
+import re
+from dataclasses import dataclass, field
+from typing import List, Optional, Tuple
+
+from sn_basis.functions import QgsProject
+
+from sn_verfahrensgebiet.functions.flurstueck_alkis import (
+    FELD_FLURSTUECKSKENNZEICHEN,
+    FLST_LAYER_NAME,
+)
+from sn_verfahrensgebiet.functions.gemarkung_alkis import _extract_schluessel_und_name
+
+GEMARKUNGEN_LAYER_NAME = "Gemarkungen"
+MELDUNG_KEIN_FLURSTUECKSLAYER = (
+    "Zuerst Verfahrensgebiet und zugehörige Flurstücke aus ALKIS laden."
+)
+
+_NUMMER_MUSTER = re.compile(r"^\s*(\d+)\s*(?:/\s*([0-9A-Za-z]+)\s*)?$")
+
+
+class FlurstueckSucheFehler(Exception):
+    """Eingabe- oder Suchfehler; der Text ist für den Nutzer bestimmt."""
+
+
+class KeinFlurstueckslayer(FlurstueckSucheFehler):
+    """Im Projekt gibt es keinen Layer „Flurstücke“."""
+
+    def __init__(self):
+        super().__init__(MELDUNG_KEIN_FLURSTUECKSLAYER)
+
+
+@dataclass
+class SuchErgebnis:
+    """Treffer einer Flurstückssuche im Layer ``layer``."""
+
+    layer: object
+    feature_ids: List[int] = field(default_factory=list)
+
+
+def _normiere_nenner(wert: str) -> str:
+    return (wert or "").strip().strip("_").lstrip("0").lower()
+
+
+def zerlege_flurstuecksnummer(text: str) -> Tuple[str, str]:
+    """Zerlegt ``"562"`` in ``("562", "")`` und ``"12/3"`` in ``("12", "3")``.
+
+    Führende Nullen fallen weg, damit ``"0562"`` und ``"562"`` gleich sind.
+    """
+    treffer = _NUMMER_MUSTER.match(text or "")
+    if not treffer:
+        raise FlurstueckSucheFehler(
+            "Die Flurstücksnummer bitte als Zahl oder als Zähler/Nenner eingeben, "
+            "z. B. 562 oder 12/3."
+        )
+    zaehler = treffer.group(1).lstrip("0") or "0"
+    return zaehler, _normiere_nenner(treffer.group(2) or "")
+
+
+def zerlege_kennzeichen(kennzeichen) -> Optional[Tuple[str, str, str]]:
+    """Liefert ``(gemarkungsnummer, zaehler, nenner)`` eines Flurstückskennzeichens.
+
+    ``None``, wenn das Kennzeichen zu kurz ist oder keine Gemarkung bzw. keinen
+    Zähler enthält.
+    """
+    kz = str(kennzeichen or "").strip()
+    if len(kz) < 18:
+        return None
+    gemarkung = kz[2:6]
+    zaehler = kz[9:14].strip("_").lstrip("0")
+    if not gemarkung.isdigit() or not zaehler:
+        return None
+    return gemarkung, zaehler, _normiere_nenner(kz[14:18])
+
+
+def gemarkungsnummern(eingabe: str, gemarkungen_layer=None) -> List[str]:
+    """Übersetzt die Gemarkungseingabe in 4-stellige Gemarkungsnummern.
+
+    Ziffern gelten als Nummer: bis zu vier Stellen werden mit Nullen aufgefüllt,
+    bei längeren Schlüsseln (z. B. ``140268``) zählen die letzten vier Stellen.
+    Ein Name wird ohne Rücksicht auf Groß- und Kleinschreibung im Layer
+    „Gemarkungen“ gesucht. Gleichnamige Gemarkungen liefern mehrere Nummern.
+    """
+    text = (eingabe or "").strip()
+    if not text:
+        raise FlurstueckSucheFehler("Bitte eine Gemarkung eingeben (Name oder Nummer).")
+    if text.isdigit():
+        return [text[-4:].zfill(4)]
+
+    if gemarkungen_layer is None:
+        raise FlurstueckSucheFehler(
+            f"Den Gemarkungsnamen „{text}“ kann das Plugin nur mit dem Layer "
+            f"„{GEMARKUNGEN_LAYER_NAME}“ auflösen. Bitte die Gemarkungsnummer "
+            "eingeben oder die Gemarkungen laden."
+        )
+
+    gesucht = text.casefold()
+    nummern = set()
+    for feature in gemarkungen_layer.getFeatures():
+        nummer, name = _extract_schluessel_und_name(feature)
+        if nummer and name.casefold() == gesucht:
+            nummern.add(nummer.zfill(4))
+    if not nummern:
+        raise FlurstueckSucheFehler(
+            f"Im Layer „{GEMARKUNGEN_LAYER_NAME}“ gibt es keine Gemarkung „{text}“."
+        )
+    return sorted(nummern)
+
+
+def finde_flurstuecke(layer, nummern: List[str], zaehler: str, nenner: str) -> List[int]:
+    """Feature-IDs der Flurstücke mit passender Gemarkung, Zähler und Nenner.
+
+    Ohne Nenner passen alle Flurstücke mit diesem Zähler (``562``, ``562/1`` …).
+    """
+    if layer.fields().indexFromName(FELD_FLURSTUECKSKENNZEICHEN) < 0:
+        raise FlurstueckSucheFehler(
+            f"Der Layer „{FLST_LAYER_NAME}“ hat kein Feld „{FELD_FLURSTUECKSKENNZEICHEN}“."
+        )
+    gesucht = set(nummern)
+    ids: List[int] = []
+    for feature in layer.getFeatures():
+        teile = zerlege_kennzeichen(feature[FELD_FLURSTUECKSKENNZEICHEN])
+        if teile is None:
+            continue
+        gemarkung, f_zaehler, f_nenner = teile
+        if gemarkung in gesucht and f_zaehler == zaehler and (not nenner or f_nenner == nenner):
+            ids.append(feature.id())
+    return ids
+
+
+def _hole_layer(name: str):
+    treffer = QgsProject.instance().mapLayersByName(name)
+    return treffer[0] if treffer else None
+
+
+def flurstueck_suchen(gemarkung_text: str, nummer_text: str) -> SuchErgebnis:
+    """Sucht das Flurstück im Layer „Flurstücke“ des aktuellen Projekts.
+
+    Raises
+    ------
+    KeinFlurstueckslayer
+        Der Layer „Flurstücke“ fehlt.
+    FlurstueckSucheFehler
+        Die Eingabe ist unvollständig oder ungültig.
+    """
+    flst_layer = _hole_layer(FLST_LAYER_NAME)
+    if flst_layer is None:
+        raise KeinFlurstueckslayer()
+    zaehler, nenner = zerlege_flurstuecksnummer(nummer_text)
+    nummern = gemarkungsnummern(gemarkung_text, _hole_layer(GEMARKUNGEN_LAYER_NAME))
+    return SuchErgebnis(flst_layer, finde_flurstuecke(flst_layer, nummern, zaehler, nenner))

functions/verfahrensgebiet_dialoge.py

@@ -1,5 +1,8 @@
 """sn_verfahrensgebiet/functions/verfahrensgebiet_dialoge.py – Dialoge zum
 Laden eines Verfahrensgebiets aus ALKIS (Qt5/6/Mock-kompatibel).
+
+Enthält außerdem die gemeinsame Auswahltabelle (:func:`baue_auswahltabelle`),
+die auch die Eigentümer-Trefferliste (#56) nutzt.
 """
 from typing import Any, Optional
 from sn_basis.functions.qt_wrapper import (
@@ -8,6 +11,7 @@ from sn_basis.functions.qt_wrapper import (
     QTableWidget, QTableWidgetItem, QTableWidgetSelectionRange,
     QIcon, QVBoxLayout, QHBoxLayout, QLabel, QCheckBox,
     DialogAccepted, ExtendedSelection, SelectRows, NoEditTriggers, AscendingOrder,
+    UserRole,
 )
 from sn_basis.functions.landkreise import ALLE_LANDKREISE
 import os
@@ -17,6 +21,98 @@ _PLUGINS_DIR = os.path.dirname(os.path.dirname(os.path.dirname(__file__)))
 _WAPPEN_ICON = os.path.join(_PLUGINS_DIR, "sn_basis", "favicon.ico")
 
 
+def zeilen_sichtbar(zeilen_texte: list[list[str]], suchtext: str) -> list[bool]:
+    """Ob jede Tabellenzeile zum Suchtext passt: Teilstring in irgendeiner Spalte,
+    ohne Groß-/Kleinschreibung. Ein leerer Suchtext zeigt alle Zeilen."""
+    such = (suchtext or "").strip().lower()
+    return [not such or any(such in (t or "").lower() for t in texte) for texte in zeilen_texte]
+
+
+def baue_auswahltabelle(
+    layout: Any,
+    spaltenkoepfe: list[str],
+    zeilen: list[tuple[str, ...]],
+    platzhalter: str = "Suche …",
+    alle_auswaehlen: bool = True,
+) -> Any:
+    """Fügt Suchfeld, „Alle auswählen“, Auswahltabelle und Mehrfachauswahl-Hinweis
+    in ``layout`` ein und gibt die Tabelle zurück.
+
+    Gemeinsamer Baustein von :func:`ask_landkreis_objekte` und der
+    Eigentümer-Trefferliste (#56). Die Tabelle ist nach Spalte 0 aufsteigend
+    sortiert, per Klick auf den Spaltenkopf umsortierbar und erlaubt die
+    Mehrfachauswahl ganzer Zeilen. Spalte 0 trägt den Index der Zeile in
+    ``zeilen`` (``UserRole``), damit die Auswahl auch nach dem Umsortieren
+    zugeordnet werden kann (:func:`ausgewaehlte_indizes`).
+    """
+    suche_zeile = QHBoxLayout()
+    suche_zeile.addWidget(QLabel("Suche:"))
+    suche_feld = QLineEdit()
+    suche_feld.setPlaceholderText(platzhalter)
+    suche_zeile.addWidget(suche_feld)
+    layout.addLayout(suche_zeile)
+
+    alle_checkbox = None
+    if alle_auswaehlen:
+        alle_checkbox = QCheckBox("Alle auswählen")
+        layout.addWidget(alle_checkbox)
+
+    table = QTableWidget(len(zeilen), len(spaltenkoepfe))
+    table.setHorizontalHeaderLabels(spaltenkoepfe)
+    table.setSelectionMode(ExtendedSelection)
+    table.setSelectionBehavior(SelectRows)
+    table.setEditTriggers(NoEditTriggers)
+    table.verticalHeader().setVisible(False)
+    table.verticalHeader().setDefaultSectionSize(22)  # flachere Zeilen
+    table.horizontalHeader().setStretchLastSection(True)
+    # Sortierung erst nach dem Befüllen einschalten, sonst wandern Zeilen beim setItem
+    table.setSortingEnabled(False)
+    for row, texte in enumerate(zeilen):
+        for col, text in enumerate(texte):
+            item = QTableWidgetItem(text)
+            if col == 0:
+                item.setData(UserRole, row)
+            table.setItem(row, col, item)
+    table.setSortingEnabled(True)
+    table.sortByColumn(0, AscendingOrder)
+    layout.addWidget(table, 1)  # Stretch-Faktor: wächst mit Fenstergröße
+
+    def _suche_geaendert(text):
+        texte = [
+            [table.item(row, col).text() for col in range(table.columnCount())]
+            for row in range(table.rowCount())
+        ]
+        for row, sichtbar in enumerate(zeilen_sichtbar(texte, text)):
+            table.setRowHidden(row, not sichtbar)
+
+    suche_feld.textChanged.connect(_suche_geaendert)
+
+    def _alle_auswaehlen_umschalten(checked):
+        table.clearSelection()
+        if checked:
+            letzte_spalte = table.columnCount() - 1
+            for row in range(table.rowCount()):
+                if not table.isRowHidden(row):
+                    # setRangeSelected (statt selectRow) fügt der Selektion
+                    # hinzu, ohne vorherige Zeilen wieder abzuwählen.
+                    table.setRangeSelected(
+                        QTableWidgetSelectionRange(row, 0, row, letzte_spalte), True
+                    )
+
+    if alle_checkbox is not None:
+        alle_checkbox.stateChanged.connect(_alle_auswaehlen_umschalten)
+
+    layout.addWidget(QLabel("<small>Mehrfachauswahl mit Strg + Umschalt</small>"))
+    return table
+
+
+def ausgewaehlte_indizes(table: Any) -> list[int]:
+    """Indizes der ausgewählten Zeilen, bezogen auf ``zeilen`` aus
+    :func:`baue_auswahltabelle`, aufsteigend."""
+    zeilen = {item.row() for item in table.selectedItems()}
+    return sorted(int(table.item(row, 0).data(UserRole)) for row in zeilen)
+
+
 def ask_bror_kombinationen(
     parent: Any,
     kombinationen: list[tuple[str, str]],
@@ -144,65 +240,17 @@ def ask_landkreis_objekte(
     hinweis.setWordWrap(True)
     layout.addWidget(hinweis)
 
-    suche_zeile = QHBoxLayout()
-    suche_zeile.addWidget(QLabel("Suche:"))
-    suche_feld = QLineEdit()
-    suche_feld.setPlaceholderText("Nummer oder Name …")
-    suche_zeile.addWidget(suche_feld)
-    layout.addLayout(suche_zeile)
-
-    alle_auswaehlen = QCheckBox("Alle auswählen")
-    layout.addWidget(alle_auswaehlen)
-
-    # Standardsortierung nach Bezeichnung; per Klick auf Spaltenkopf änderbar
-    # (setSortingEnabled aktiviert die eingebaute Tabellensortierung).
+    # Standardsortierung nach Bezeichnung; per Klick auf Spaltenkopf änderbar.
     sortierte_kombinationen = sorted(kombinationen, key=lambda kb: kb[1])
-
-    table = QTableWidget(len(sortierte_kombinationen), 2)
-    table.setHorizontalHeaderLabels(["Nummer", "Name"])
-    table.setSelectionMode(ExtendedSelection)
-    table.setSelectionBehavior(SelectRows)
-    table.setEditTriggers(NoEditTriggers)
-    table.verticalHeader().setVisible(False)
-    table.verticalHeader().setDefaultSectionSize(22)  # flachere Zeilen
-    table.horizontalHeader().setStretchLastSection(True)
-    table.setSortingEnabled(False)
-    for row, (adv, bez) in enumerate(sortierte_kombinationen):
-        table.setItem(row, 0, QTableWidgetItem(bez))
-        table.setItem(row, 1, QTableWidgetItem(adv))
-    table.setSortingEnabled(True)
-    table.sortByColumn(0, AscendingOrder)  # Standard: aufsteigend nach Nummer
+    table = baue_auswahltabelle(
+        layout,
+        ["Nummer", "Name"],
+        [(bez, adv) for adv, bez in sortierte_kombinationen],
+        platzhalter="Nummer oder Name …",
+    )
     table.resizeColumnToContents(0)
     table.setColumnWidth(0, max(110, table.columnWidth(0)))
     table.selectRow(0)
-    layout.addWidget(table, 1)  # Stretch-Faktor: wächst mit Fenstergröße
-
-    def _suche_geaendert(text):
-        text_lower = text.strip().lower()
-        for row in range(table.rowCount()):
-            bez_text = table.item(row, 0).text().lower()
-            adv_text = table.item(row, 1).text().lower()
-            treffer = not text_lower or text_lower in bez_text or text_lower in adv_text
-            table.setRowHidden(row, not treffer)
-
-    suche_feld.textChanged.connect(_suche_geaendert)
-
-    def _alle_auswaehlen_umschalten(checked):
-        table.clearSelection()
-        if checked:
-            letzte_spalte = table.columnCount() - 1
-            for row in range(table.rowCount()):
-                if not table.isRowHidden(row):
-                    # setRangeSelected (statt selectRow) fügt der Selektion
-                    # hinzu, ohne vorherige Zeilen wieder abzuwählen.
-                    table.setRangeSelected(
-                        QTableWidgetSelectionRange(row, 0, row, letzte_spalte), True
-                    )
-
-    alle_auswaehlen.stateChanged.connect(_alle_auswaehlen_umschalten)
-
-    mehrfachauswahl_hinweis = QLabel("<small>Mehrfachauswahl mit Strg + Umschalt</small>")
-    layout.addWidget(mehrfachauswahl_hinweis)
 
     buttons = QDialogButtonBox(QDialogButtonBox.StandardButton.Ok | QDialogButtonBox.StandardButton.Cancel)
     buttons.accepted.connect(dialog.accept)

tests/test_eigentuemer_anzeige.py

@@ -0,0 +1,91 @@
+"""Tests für das Anzeigefenster des Eigentümer-Datenabgleichs (#56).
+
+Alle Namen und Anschriften sind erfunden.
+"""
+
+import unittest
+from unittest.mock import MagicMock
+
+from sn_verfahrensgebiet.ui import eigentuemer_anzeige as ea
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+
+ANNA = Eigentuemer(anrede="Frau", titel="Dr.", vorname="Anna", nachname="Beispiel", strasse="Hauptstraße 1",
+                   plz="01234", wohnort="Musterstadt", ortsteil="Unterdorf", emails=("anna@example.org",),
+                   verstorben=True, rechtsperson=("0",), per_ids=("4711",), konten=("98765",))
+
+
+class TestAnzeigetext(unittest.TestCase):
+
+    def test_name_anschrift_email(self):
+        """Prüft, dass die Anzeige Name mit Anrede und Titel, die mehrzeilige Anschrift mit Ortsteil und die E-Mail zeigt."""
+        text = ea.anzeige_html([ANNA])
+        self.assertIn("Frau Dr. Anna Beispiel", text)
+        self.assertIn("Hauptstraße 1<br/>01234 Musterstadt<br/>OT Unterdorf", text)
+        self.assertIn("anna@example.org", text)
+
+    def test_keine_internen_angaben(self):
+        """Prüft, dass der Eigentümer weder Konten, Personen-IDs, Rechtsperson-Wert noch das Kennzeichen „verstorben“ sieht."""
+        text = ea.anzeige_html([ANNA])
+        for intern in ("98765", "4711", "verstorben", "Rechtsperson"):
+            self.assertNotIn(intern, text)
+
+    def test_fehlende_email_wird_genannt(self):
+        """Prüft, dass eine fehlende E-Mail ausdrücklich als „keine angegeben“ erscheint."""
+        self.assertIn(ea.OHNE_EMAIL, ea.anzeige_html([Eigentuemer(nachname="Muster")]))
+
+    def test_werte_werden_maskiert(self):
+        """Prüft, dass Sonderzeichen aus den Daten maskiert werden und kein HTML einschleusen."""
+        text = ea.anzeige_html([Eigentuemer(nachname="<b>Muster</b> & Co")])
+        self.assertIn("&lt;b&gt;Muster&lt;/b&gt; &amp; Co", text)
+        self.assertNotIn("<b>Muster", text)
+
+    def test_mehrere_eintraege_getrennt(self):
+        """Prüft, dass mehrere Einträge untereinander, durch eine Linie getrennt, erscheinen."""
+        text = ea.anzeige_html([ANNA, Eigentuemer(vorname="Bernd", nachname="Muster")])
+        self.assertEqual(text.count("<hr/>"), 1)
+        self.assertIn("Bernd Muster", text)
+
+    def test_leer_nur_platzhalter(self):
+        """Prüft, dass die leere Anzeige nur den neutralen Platzhalter zeigt."""
+        text = ea.anzeige_html([])
+        self.assertIn(ea.PLATZHALTER, text)
+        self.assertNotIn("Name", text)
+
+
+class TestFensterOeffnen(unittest.TestCase):
+
+    def test_normales_fenster_in_standardgroesse(self):
+        """Prüft, dass das Anzeigefenster ohne gemerkte Lage als normales Fenster mit Rahmen in Standardgröße öffnet, nie im Vollbild."""
+        fenster = MagicMock()
+        ea.zeige_anzeigefenster(fenster)
+        fenster.resize.assert_called_once_with(*ea.STANDARDGROESSE)
+        fenster.show.assert_called_once()
+        fenster.showFullScreen.assert_not_called()
+        fenster.setWindowFlags.assert_not_called()
+
+    def test_gemerkte_lage_wird_wiederhergestellt(self):
+        """Prüft, dass eine gemerkte Größe und Lage der letzten Sitzung wiederhergestellt wird."""
+        fenster = MagicMock()
+        fenster.restoreGeometry.return_value = True
+        ea.zeige_anzeigefenster(fenster, b"geometrie")
+        fenster.restoreGeometry.assert_called_once_with(b"geometrie")
+        fenster.resize.assert_not_called()
+        fenster.show.assert_called_once()
+        fenster.showFullScreen.assert_not_called()
+
+    def test_unbrauchbare_lage_ergibt_standardgroesse(self):
+        """Prüft, dass eine nicht wiederherstellbare Lage auf die Standardgröße zurückfällt."""
+        for ergebnis in (False, RuntimeError("kaputt")):
+            with self.subTest(ergebnis=ergebnis):
+                fenster = MagicMock()
+                if isinstance(ergebnis, Exception):
+                    fenster.restoreGeometry.side_effect = ergebnis
+                else:
+                    fenster.restoreGeometry.return_value = ergebnis
+                ea.zeige_anzeigefenster(fenster, b"alt")
+                fenster.resize.assert_called_once_with(*ea.STANDARDGROESSE)
+                fenster.show.assert_called_once()
+
+
+if __name__ == "__main__":
+    unittest.main()

tests/test_eigentuemer_korrektur.py

@@ -0,0 +1,134 @@
+"""Tests für die Korrekturen beim Eigentümer-Datenabgleich (#56).
+
+Alle Namen und Anschriften sind erfunden.
+"""
+
+import contextlib
+import csv
+import io
+import os
+import tempfile
+import unittest
+from datetime import datetime
+
+from sn_verfahrensgebiet.functions import eigentuemer_korrektur as ek
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+
+ANNA = Eigentuemer(anrede="Frau", vorname="Anna", nachname="Beispiel", strasse="Hauptstraße 1", plz="01234",
+                   wohnort="Musterstadt", emails=("anna@example.org",), per_ids=("7",), konten=("100", "200"))
+
+
+class TestAenderungen(unittest.TestCase):
+
+    def test_feldwerte(self):
+        """Prüft, dass alle korrigierbaren Felder vorbelegt werden, mehrere E-Mails durch Komma getrennt."""
+        werte = ek.feldwerte(Eigentuemer(nachname="Beispiel", emails=("a@example.org", "b@example.org")))
+        self.assertEqual(set(werte), {k for k, _ in ek.FELDER})
+        self.assertEqual(werte["email"], "a@example.org, b@example.org")
+        self.assertEqual(werte["nachname"], "Beispiel")
+
+    def test_nur_echte_aenderungen(self):
+        """Prüft, dass nur geänderte Felder zählen und Leerraum am Rand oder doppelte Leerzeichen keine Änderung sind."""
+        werte = ek.feldwerte(ANNA)
+        werte.update(strasse="  Hauptstraße  1 ", wohnort="Neustadt", email="anna.neu@example.org")
+        self.assertEqual(ek.ermittle_aenderungen(ANNA, werte), [
+            ("wohnort", "Musterstadt", "Neustadt"),
+            ("email", "anna@example.org", "anna.neu@example.org"),
+        ])
+        self.assertEqual(ek.ermittle_aenderungen(ANNA, ek.feldwerte(ANNA)), [])
+
+    def test_feld_leeren_ist_aenderung(self):
+        """Prüft, dass das Leeren eines Feldes als Änderung zählt."""
+        self.assertEqual(ek.ermittle_aenderungen(ANNA, {"email": ""}), [("email", "anna@example.org", "")])
+
+    def test_wende_an(self):
+        """Prüft, dass die Änderungen im angezeigten Eintrag landen und E-Mails wieder getrennt werden; Konten bleiben."""
+        neu = ek.wende_an(ANNA, [("wohnort", "Musterstadt", "Neustadt"),
+                                 ("email", "", "a@example.org, b@example.org")])
+        self.assertEqual(neu.wohnort, "Neustadt")
+        self.assertEqual(neu.emails, ("a@example.org", "b@example.org"))
+        self.assertEqual(neu.konten, ANNA.konten)
+        self.assertEqual(ANNA.wohnort, "Musterstadt")
+
+
+class TestKorrekturPfad(unittest.TestCase):
+
+    def test_textdatei_provider(self):
+        """Prüft, dass aus der Quelle eines Textdatei-Layers (file-URI, Leerzeichen kodiert) der Pfad neben der CSV wird."""
+        quelle = "file:///D:/Verfahren/Eigent%C3%BCmer%20Export.csv?type=csv&detectTypes=yes&geomType=none"
+        self.assertEqual(ek.korrektur_pfad(quelle), "D:/Verfahren/Eigentümer Export_korrekturen.csv")
+        self.assertEqual(ek.korrektur_pfad("file:///home/test/export.CSV?type=csv"),
+                         "/home/test/export_korrekturen.csv")
+
+    def test_ogr_provider(self):
+        """Prüft, dass auch eine OGR-Quelle mit Layernamen den Pfad neben der CSV ergibt."""
+        self.assertEqual(ek.korrektur_pfad("D:/Verfahren/export.csv|layername=export"),
+                         "D:/Verfahren/export_korrekturen.csv")
+
+    def test_keine_csv(self):
+        """Prüft, dass für Quellen ohne CSV-Datei kein Pfad vorgeschlagen wird."""
+        self.assertIsNone(ek.korrektur_pfad(""))
+        self.assertIsNone(ek.korrektur_pfad("D:/Verfahren/daten.gpkg|layername=export"))
+        self.assertIsNone(ek.korrektur_pfad("memory?geometry=None"))
+
+
+class TestSchreiben(unittest.TestCase):
+
+    def setUp(self):
+        self._ordner = tempfile.TemporaryDirectory()
+        self.pfad = os.path.join(self._ordner.name, "export_korrekturen.csv")
+
+    def tearDown(self):
+        self._ordner.cleanup()
+
+    def _zeilen(self):
+        with open(self.pfad, encoding="utf-8-sig", newline="") as datei:
+            return list(csv.reader(datei))
+
+    def test_neue_datei_mit_kopfzeile_und_bom(self):
+        """Prüft, dass eine neue Korrektur-CSV mit BOM, Kopfzeile und je Änderung einer Zeile mit Exportspaltennamen entsteht."""
+        anzahl = ek.schreibe_korrekturen(self.pfad, ANNA, [
+            ("strasse", "Hauptstraße 1", "Am Anger 3, Haus B"),
+            ("email", "anna@example.org", ""),
+        ], zeitpunkt=datetime(2026, 10, 6, 14, 30, 5))
+        self.assertEqual(anzahl, 2)
+        with open(self.pfad, "rb") as datei:
+            self.assertTrue(datei.read().startswith(b"\xef\xbb\xbf"))
+        self.assertEqual(self._zeilen(), [
+            ek.KOPFZEILE,
+            ["2026-10-06 14:30:05", "100 200", "7", "STRASSE", "Hauptstraße 1", "Am Anger 3, Haus B"],
+            ["2026-10-06 14:30:05", "100 200", "7", "Email", "anna@example.org", ""],
+        ])
+
+    def test_anhaengen_ohne_zweite_kopfzeile(self):
+        """Prüft, dass weitere Korrekturen angehängt werden, ohne Kopfzeile oder BOM zu wiederholen."""
+        ek.schreibe_korrekturen(self.pfad, ANNA, [("wohnort", "Musterstadt", "Neustadt")])
+        ek.schreibe_korrekturen(self.pfad, ANNA, [("plz", "01234", "01235")])
+        zeilen = self._zeilen()
+        self.assertEqual(len(zeilen), 3)
+        self.assertEqual(zeilen[0], ek.KOPFZEILE)
+        self.assertEqual([z[3] for z in zeilen[1:]], ["WOHNORT", "PLZ"])
+        with open(self.pfad, "rb") as datei:
+            self.assertEqual(datei.read().count(b"\xef\xbb\xbf"), 1)
+
+    def test_ohne_aenderung_keine_datei(self):
+        """Prüft, dass ohne Änderung keine Datei angelegt wird."""
+        self.assertEqual(ek.schreibe_korrekturen(self.pfad, ANNA, []), 0)
+        self.assertFalse(os.path.exists(self.pfad))
+
+    def test_schreibfehler_wird_weitergereicht(self):
+        """Prüft, dass ein nicht schreibbarer Pfad als OSError beim Aufrufer ankommt."""
+        with self.assertRaises(OSError):
+            ek.schreibe_korrekturen(os.path.join(self._ordner.name, "fehlt", "x.csv"), ANNA,
+                                    [("wohnort", "Musterstadt", "Neustadt")])
+
+    def test_schreibt_nichts_auf_die_konsole(self):
+        """Prüft, dass das Festhalten von Korrekturen keine Personendaten auf die Konsole schreibt (Datenschutz)."""
+        ausgabe = io.StringIO()
+        with contextlib.redirect_stdout(ausgabe), contextlib.redirect_stderr(ausgabe):
+            ek.schreibe_korrekturen(self.pfad, ANNA, [("wohnort", "Musterstadt", "Neustadt")])
+        self.assertEqual(ausgabe.getvalue(), "")
+
+
+if __name__ == "__main__":
+    unittest.main()

tests/test_eigentuemer_suche.py

@@ -0,0 +1,197 @@
+"""Tests für die Eigentümersuche im Serienbriefexport (#56).
+
+Alle Namen und Anschriften sind erfunden.
+"""
+
+import contextlib
+import io
+import types
+import unittest
+from unittest.mock import patch
+
+from sn_verfahrensgebiet.functions import eigentuemer_suche as es
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+
+KOPF = [
+    "EIG_KONTO", "PER_ID", "PER_VERSTORBEN", "PER_NR", "Anrede", "Titel", "Vorname", "Nachname",
+    "OT", "STRASSE", "PLZ", "WOHNORT", "Email", "PER_KONTOINHABER", "PER_RECHTSPERSON",
+    "EIG_GEMARKUNG", "EIG_BLATT", "LISTE_ZGBBL", "ANZAHL_PERSONEN", "EIG_ID",
+]
+
+
+class _Null:
+    """Nachbildung von QGIS-NULL."""
+
+    def isNull(self):
+        return True
+
+
+class _Feature(dict):
+    def __init__(self, fid, werte):
+        super().__init__(werte)
+        self._fid = fid
+
+    def id(self):
+        return self._fid
+
+
+class _Layer:
+    def __init__(self, zeilen, kopf=KOPF, name="Serienbrief", layer_id="csv1"):
+        self._kopf = list(kopf)
+        self._name = name
+        self._id = layer_id
+        self._features = [
+            _Feature(i + 1, {spalte: zeile.get(spalte.lstrip(""), "") for spalte in self._kopf})
+            for i, zeile in enumerate(zeilen)
+        ]
+
+    def name(self):
+        return self._name
+
+    def id(self):
+        return self._id
+
+    def fields(self):
+        return types.SimpleNamespace(names=lambda: list(self._kopf))
+
+    def getFeatures(self):
+        return iter(self._features)
+
+
+def _zeile(nachname, vorname, strasse="Hauptstraße 1", plz="01234", ort="Musterstadt", **weitere):
+    zeile = {"Nachname": nachname, "Vorname": vorname, "STRASSE": strasse, "PLZ": plz, "WOHNORT": ort}
+    zeile.update(weitere)
+    return zeile
+
+
+class TestLayererkennung(unittest.TestCase):
+
+    def test_layer_mit_name_und_vorname_ist_eigentuemerlayer(self):
+        """Prüft, dass ein Layer mit den Spalten Nachname und Vorname als Eigentümerdatei erkannt wird, auch mit BOM und anderer Schreibweise."""
+        self.assertTrue(es.ist_eigentuemerlayer(_Layer([])))
+        self.assertTrue(es.ist_eigentuemerlayer(_Layer([], kopf=["NACHNAME", "vorname"])))
+        self.assertFalse(es.ist_eigentuemerlayer(_Layer([], kopf=["flurstueckskennzeichen"])))
+        self.assertFalse(es.ist_eigentuemerlayer(object()))
+
+    def test_eigentuemerlayer_im_projekt(self):
+        """Prüft, dass aus dem Projekt nur passende Layer kommen, nach Namen sortiert."""
+        b = _Layer([], name="b-Export", layer_id="b")
+        a = _Layer([], name="A-Export", layer_id="a")
+        flst = _Layer([], kopf=["flurstueckskennzeichen"], name="Flurstücke", layer_id="f")
+        projekt = types.SimpleNamespace(mapLayers=lambda: {"b": b, "f": flst, "a": a})
+        with patch.object(es, "QgsProject", types.SimpleNamespace(instance=lambda: projekt)):
+            self.assertEqual(es.eigentuemerlayer_im_projekt(), [a, b])
+
+
+class TestSuche(unittest.TestCase):
+
+    def test_ohne_eingabe_fehler(self):
+        """Prüft, dass ohne Name und Vorname nicht die ganze Datei gelistet, sondern um eine Eingabe gebeten wird."""
+        with self.assertRaisesRegex(es.EigentuemerSucheFehler, "Namen"):
+            es.suche_eigentuemer(_Layer([_zeile("Beispiel", "Anna")]), " ", "")
+
+    def test_layer_ohne_pflichtspalten(self):
+        """Prüft, dass ein Layer ohne Nachname/Vorname mit Hinweis auf den Serienbriefexport abgelehnt wird."""
+        with self.assertRaisesRegex(es.EigentuemerSucheFehler, "Serienbriefexport"):
+            es.suche_eigentuemer(_Layer([], kopf=["flurstueckskennzeichen"]), "Beispiel", "")
+
+    def test_teilstring_ohne_gross_kleinschreibung(self):
+        """Prüft, dass Name und Vorname als Teilstring ohne Rücksicht auf Groß-/Kleinschreibung gesucht werden."""
+        layer = _Layer([
+            _zeile("Beispiel", "Anna"),
+            _zeile("Beispiel-Muster", "Bernd"),
+            _zeile("Anders", "Anna"),
+        ])
+        self.assertEqual([e.nachname for e in es.suche_eigentuemer(layer, "beispiel", "")],
+                         ["Beispiel", "Beispiel-Muster"])
+        self.assertEqual([e.nachname for e in es.suche_eigentuemer(layer, "", "ANNA")], ["Anders", "Beispiel"])
+        self.assertEqual([e.vorname for e in es.suche_eigentuemer(layer, "beisp", "an")], ["Anna"])
+
+    def test_umlaute_und_eszett(self):
+        """Prüft, dass „Müller“ auch „Mueller“ findet und „Strauss“ auch „Strauß“."""
+        layer = _Layer([_zeile("Mueller", "Jörg"), _zeile("Strauß", "Erika", ort="Anderswo")])
+        self.assertEqual(len(es.suche_eigentuemer(layer, "Müller", "Joerg")), 1)
+        self.assertEqual(len(es.suche_eigentuemer(layer, "Strauss", "")), 1)
+
+    def test_gleiche_person_gleiche_anschrift_zusammengefasst(self):
+        """Prüft, dass Zeilen mit gleichem Namen und gleicher Anschrift ein Treffer werden und Konten, Personen-IDs und E-Mails gesammelt werden."""
+        layer = _Layer([
+            _zeile("Beispiel", "Anna", EIG_KONTO="100", PER_ID="7", Email="anna@example.org"),
+            _zeile("beispiel ", " Anna", strasse="Hauptstraße  1", EIG_KONTO="200", PER_ID="7",
+                   Titel="Dr.", Email="anna@example.org"),
+            _zeile("Beispiel", "Anna", EIG_KONTO="300", PER_ID="8", Email="a.b@example.org"),
+        ])
+        treffer = es.suche_eigentuemer(layer, "Beispiel", "Anna")
+        self.assertEqual(len(treffer), 1)
+        e = treffer[0]
+        self.assertEqual(e.konten, ("100", "200", "300"))
+        self.assertEqual(e.per_ids, ("7", "8"))
+        self.assertEqual(e.emails, ("anna@example.org", "a.b@example.org"))
+        self.assertEqual(e.feature_ids, (1, 2, 3))
+        self.assertEqual(e.titel, "Dr.")
+
+    def test_andere_anschrift_eigener_treffer(self):
+        """Prüft, dass dieselbe Person mit anderer Anschrift ein eigener Treffer bleibt, sortiert nach Wohnort."""
+        layer = _Layer([
+            _zeile("Beispiel", "Anna", ort="Zettlitz"),
+            _zeile("Beispiel", "Anna", ort="Altdorf", plz="09999"),
+        ])
+        treffer = es.suche_eigentuemer(layer, "Beispiel", "Anna")
+        self.assertEqual([e.wohnort for e in treffer], ["Altdorf", "Zettlitz"])
+
+    def test_kennzeichen_verstorben(self):
+        """Prüft, dass „verstorben“ beim Exportwert 1 (auch als Zahl gelesen) gesetzt ist und bei 0, Leerem und NULL nicht."""
+        ja = ["1", 1]
+        nein = ["0", 0, "", None, _Null()]
+        zeilen = [_zeile(f"Ja{i}", "Test", PER_VERSTORBEN=w) for i, w in enumerate(ja)]
+        zeilen += [_zeile(f"Nein{i}", "Test", PER_VERSTORBEN=w) for i, w in enumerate(nein)]
+        for e in es.suche_eigentuemer(_Layer(zeilen), "", "Test"):
+            erwartet = e.nachname.startswith("Ja")
+            with self.subTest(name=e.nachname):
+                self.assertEqual(e.verstorben, erwartet)
+                self.assertEqual(e.hinweise, "verstorben" if erwartet else "")
+
+    def test_rechtsperson_als_rohwert(self):
+        """Prüft, dass PER_RECHTSPERSON unverändert angezeigt wird (0, 1, 5, 9; noch nicht entschlüsselt) und abweichende Werte einer Person gesammelt werden."""
+        layer = _Layer([
+            _zeile("Beispiel", "Anna", PER_RECHTSPERSON="0"),
+            _zeile("Gemeinde Musterstadt", "", strasse="Markt 1", PER_RECHTSPERSON=5),
+            _zeile("Muster", "Bernd", PER_RECHTSPERSON="1"),
+            _zeile("Muster", "Bernd", PER_RECHTSPERSON="9"),
+            _zeile("Ohnewert", "Clara", PER_RECHTSPERSON=_Null()),
+        ])
+        werte = {e.nachname: e.rechtsperson_text for e in es.suche_eigentuemer(layer, "e", "")}
+        self.assertEqual(werte, {"Beispiel": "0", "Gemeinde Musterstadt": "5", "Muster": "1, 9", "Ohnewert": ""})
+
+    def test_plz_mit_fuehrender_null(self):
+        """Prüft, dass eine von QGIS als Zahl gelesene PLZ wieder fünfstellig mit führender Null erscheint und Zeilen dadurch zusammenfinden."""
+        layer = _Layer([
+            _zeile("Beispiel", "Anna", plz=1067),
+            _zeile("Beispiel", "Anna", plz="01067"),
+            _zeile("Muster", "Bernd", plz="1067.0"),
+        ])
+        treffer = es.suche_eigentuemer(layer, "e", "")
+        self.assertEqual([(e.nachname, e.plz) for e in treffer], [("Beispiel", "01067"), ("Muster", "01067")])
+
+    def test_suche_gibt_nichts_aus(self):
+        """Prüft, dass die Suche keine Personendaten auf die Konsole schreibt (Datenschutz)."""
+        ausgabe = io.StringIO()
+        with contextlib.redirect_stdout(ausgabe), contextlib.redirect_stderr(ausgabe):
+            es.suche_eigentuemer(_Layer([_zeile("Beispiel", "Anna")]), "Beispiel", "")
+        self.assertEqual(ausgabe.getvalue(), "")
+
+
+class TestAnzeigeformen(unittest.TestCase):
+
+    def test_name_und_anschrift(self):
+        """Prüft, dass Name mit Titel und einzeilige Anschrift mit Ortsteil lesbar zusammengesetzt werden."""
+        e = Eigentuemer(titel="Dr.", vorname="Anna", nachname="Beispiel", strasse="Hauptstraße 1",
+                        plz="01234", wohnort="Musterstadt", ortsteil="Unterdorf")
+        self.assertEqual(e.name, "Beispiel, Dr. Anna")
+        self.assertEqual(e.anschrift, "Hauptstraße 1, 01234 Musterstadt, OT Unterdorf")
+        self.assertEqual(Eigentuemer(nachname="Beispiel", ortsteil="OT Unterdorf").anschrift, "OT Unterdorf")
+        self.assertEqual(Eigentuemer(nachname="Gemeinde Musterstadt").name, "Gemeinde Musterstadt")
+
+
+if __name__ == "__main__":
+    unittest.main()

tests/test_eigentuemer_tab.py

@@ -0,0 +1,433 @@
+"""Tests für den Tab „Eigentümer“ – Flurstückssuche, Eigentümersuche, Anzeige und Korrektur (#56).
+
+Alle Namen und Anschriften sind erfunden.
+"""
+
+import os
+import sys
+import tempfile
+import types
+import unittest
+from datetime import datetime
+from unittest.mock import MagicMock, patch
+
+if "qgis" not in sys.modules:
+    qgis_mod = types.ModuleType("qgis")
+    qgis_utils = types.ModuleType("qgis.utils")
+    qgis_utils.iface = types.SimpleNamespace()
+    qgis_utils.plugins = {}
+    qgis_mod.utils = qgis_utils
+    sys.modules["qgis"] = qgis_mod
+    sys.modules["qgis.utils"] = qgis_utils
+
+from sn_verfahrensgebiet.ui.tabs import eigentuemer_tab as et
+from sn_verfahrensgebiet.ui.tabs.eigentuemer_tab import EigentuemerTab
+from sn_verfahrensgebiet.functions.flurstueck_suche import (
+    FlurstueckSucheFehler,
+    KeinFlurstueckslayer,
+    SuchErgebnis,
+)
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer, EigentuemerSucheFehler
+from sn_verfahrensgebiet.ui import eigentuemer_treffer as treffer_modul
+from sn_verfahrensgebiet.ui.eigentuemer_treffer import EigentuemerTrefferFenster, trefferzeile
+
+
+def _tab(gemarkung="0268", flurstueck="562"):
+    tab = EigentuemerTab.__new__(EigentuemerTab)
+    tab.gemarkung_edit = types.SimpleNamespace(text=lambda: gemarkung)
+    tab.flurstueck_edit = types.SimpleNamespace(text=lambda: flurstueck)
+    return tab
+
+
+@patch.object(et, "success")
+@patch.object(et, "info")
+@patch.object(et, "warning")
+@patch.object(et, "show_info_dialog")
+class TestFlurstueckSuchen(unittest.TestCase):
+
+    def test_ohne_flurstueckslayer_erscheint_hinweisdialog(self, dialog, warnung, hinweis, erfolg):
+        """Prüft, dass ohne Layer „Flurstücke“ ein Dialog zum Laden von Verfahrensgebiet und Flurstücken erscheint."""
+        with patch.object(et, "flurstueck_suchen", side_effect=KeinFlurstueckslayer()):
+            _tab()._on_flurstueck_suchen()
+        dialog.assert_called_once()
+        self.assertIn("Flurstücke aus ALKIS laden", dialog.call_args[0][1])
+        warnung.assert_not_called()
+        erfolg.assert_not_called()
+
+    def test_eingabefehler_als_warnung(self, dialog, warnung, hinweis, erfolg):
+        """Prüft, dass eine ungültige Eingabe als Warnung in der Meldungsleiste erscheint, nicht als Dialog."""
+        with patch.object(et, "flurstueck_suchen", side_effect=FlurstueckSucheFehler("falsch")):
+            _tab()._on_flurstueck_suchen()
+        warnung.assert_called_once_with("Flurstückssuche", "falsch")
+        dialog.assert_not_called()
+
+    def test_kein_treffer(self, dialog, warnung, hinweis, erfolg):
+        """Prüft, dass ohne Treffer ein Hinweis erscheint und keine Auswahl gesetzt wird."""
+        layer = MagicMock()
+        with patch.object(et, "flurstueck_suchen", return_value=SuchErgebnis(layer, [])):
+            _tab(flurstueck="999")._on_flurstueck_suchen()
+        hinweis.assert_called_once()
+        self.assertIn("999", hinweis.call_args[0][1])
+        layer.selectByIds.assert_not_called()
+
+    def test_treffer_werden_ausgewaehlt_und_angezoomt(self, dialog, warnung, hinweis, erfolg):
+        """Prüft, dass Treffer im Flurstückslayer ausgewählt, angezoomt und gemeldet werden."""
+        layer = MagicMock()
+        layer.name.return_value = "Flurstücke"
+        canvas = MagicMock()
+        with patch.object(et, "flurstueck_suchen", return_value=SuchErgebnis(layer, [1, 2])) as suche, \
+                patch.object(et, "iface", types.SimpleNamespace(mapCanvas=lambda: canvas)):
+            _tab(gemarkung=" Beispielhausen ", flurstueck=" 562 ")._on_flurstueck_suchen()
+        suche.assert_called_once_with("Beispielhausen", "562")
+        layer.selectByIds.assert_called_once_with([1, 2])
+        canvas.zoomToSelected.assert_called_once_with(layer)
+        canvas.flashFeatureIds.assert_called_once_with(layer, [1, 2])
+        erfolg.assert_called_once()
+        self.assertIn("2 Flurstücke", erfolg.call_args[0][1])
+
+    def test_ohne_kartenansicht_bleibt_auswahl(self, dialog, warnung, hinweis, erfolg):
+        """Prüft, dass die Auswahl auch ohne Kartenansicht gesetzt und gemeldet wird."""
+        layer = MagicMock()
+        with patch.object(et, "flurstueck_suchen", return_value=SuchErgebnis(layer, [7])), \
+                patch.object(et, "iface", types.SimpleNamespace()):
+            _tab()._on_flurstueck_suchen()
+        layer.selectByIds.assert_called_once_with([7])
+        self.assertIn("1 Flurstück", erfolg.call_args[0][1])
+
+
+def _eig_tab(nachname="Beispiel", vorname="", layer_id="csv1"):
+    tab = EigentuemerTab.__new__(EigentuemerTab)
+    tab.nachname_edit = types.SimpleNamespace(text=lambda: nachname)
+    tab.vorname_edit = types.SimpleNamespace(text=lambda: vorname)
+    tab.eigentuemer_layer_combo = MagicMock()
+    tab.eigentuemer_layer_combo.currentData.return_value = layer_id
+    tab._trefferfenster = None
+    return tab
+
+
+_ANNA = Eigentuemer(vorname="Anna", nachname="Beispiel", strasse="Hauptstraße 1", plz="01234",
+                    wohnort="Musterstadt", emails=("anna@example.org",), verstorben=True,
+                    rechtsperson=("0",))
+
+
+@patch.object(et, "info")
+@patch.object(et, "warning")
+class TestEigentuemerSuchen(unittest.TestCase):
+
+    def test_ohne_eigentuemerdatei_warnung(self, warnung, hinweis):
+        """Prüft, dass ohne gewählte Eigentümerdatei die Liste aufgefrischt und dann auf das Laden der CSV hingewiesen wird."""
+        tab = _eig_tab(layer_id=None)
+        with patch.object(et, "hole_layer", return_value=None), \
+                patch.object(et, "suche_eigentuemer") as suche:
+            tab._on_eigentuemer_suchen()
+        tab.eigentuemer_layer_combo.aktualisieren.assert_called_once()
+        warnung.assert_called_once()
+        self.assertIn("CSV", warnung.call_args[0][1])
+        suche.assert_not_called()
+
+    def test_suchfehler_als_warnung(self, warnung, hinweis):
+        """Prüft, dass ein Fehler der Suche (z. B. leere Eingabe) als Warnung erscheint."""
+        with patch.object(et, "hole_layer", return_value=object()), \
+                patch.object(et, "suche_eigentuemer", side_effect=EigentuemerSucheFehler("Bitte eingeben")):
+            _eig_tab()._on_eigentuemer_suchen()
+        warnung.assert_called_once_with("Eigentümersuche", "Bitte eingeben")
+
+    def test_kein_treffer_ohne_namen_in_meldung(self, warnung, hinweis):
+        """Prüft, dass ohne Treffer ein Hinweis erscheint, der den gesuchten Namen nicht wiederholt (Datenschutz)."""
+        with patch.object(et, "hole_layer", return_value=object()), \
+                patch.object(et, "suche_eigentuemer", return_value=[]), \
+                patch.object(et, "EigentuemerTrefferFenster") as fenster:
+            _eig_tab(nachname="Beispiel")._on_eigentuemer_suchen()
+        hinweis.assert_called_once()
+        self.assertNotIn("Beispiel", hinweis.call_args[0][1])
+        fenster.assert_not_called()
+
+    def test_treffer_oeffnen_trefferliste_und_ersetzen_die_alte(self, warnung, hinweis):
+        """Prüft, dass Treffer in einer neuen Trefferliste mit Anzeige-Rückruf erscheinen, eine offene alte Liste geschlossen wird und die Eingaben an die Suche gehen."""
+        layer = MagicMock()
+        layer.id.return_value = "csv1"
+        tab = _eig_tab(nachname="Beisp", vorname="An")
+        altes_fenster = MagicMock()
+        tab._trefferfenster = altes_fenster
+        with patch.object(et, "hole_layer", return_value=layer), \
+                patch.object(et, "suche_eigentuemer", return_value=[_ANNA]) as suche,                 patch.object(et, "EigentuemerTrefferFenster") as fenster:
+            tab._on_eigentuemer_suchen()
+        suche.assert_called_once_with(layer, "Beisp", "An")
+        altes_fenster.close.assert_called_once()
+        fenster.assert_called_once_with([_ANNA], tab, beim_anzeigen=tab._daten_anzeigen)
+        fenster.return_value.show.assert_called_once()
+        self.assertIs(tab._trefferfenster, fenster.return_value)
+        self.assertEqual(tab._treffer_layer_id, "csv1")
+
+
+class TestTrefferliste(unittest.TestCase):
+
+    def test_trefferzeile_mit_hinweis(self):
+        """Prüft, dass die Trefferliste Name, Anschrift, E-Mail, den Rohwert von PER_RECHTSPERSON und das Kennzeichen „verstorben“ zeigt."""
+        self.assertEqual(
+            trefferzeile(_ANNA),
+            ("Beispiel, Anna", "Hauptstraße 1, 01234 Musterstadt", "anna@example.org", "0", "verstorben"),
+        )
+
+    def test_ausgewaehlte_eigentuemer(self):
+        """Prüft, dass das Trefferfenster die in der Tabelle gewählten Einträge zurückgibt."""
+        bernd = Eigentuemer(vorname="Bernd", nachname="Muster")
+        fenster = EigentuemerTrefferFenster.__new__(EigentuemerTrefferFenster)
+        fenster.treffer = [_ANNA, bernd]
+        fenster.tabelle = object()
+        with patch.object(treffer_modul, "ausgewaehlte_indizes", return_value=[1]) as indizes:
+            self.assertEqual(fenster.ausgewaehlte_eigentuemer(), [bernd])
+        indizes.assert_called_once_with(fenster.tabelle)
+
+    def test_daten_anzeigen_gibt_auswahl_weiter(self):
+        """Prüft, dass „Daten anzeigen“ die Auswahl der Trefferliste an den Tab übergibt."""
+        fenster = EigentuemerTrefferFenster.__new__(EigentuemerTrefferFenster)
+        fenster.treffer = [_ANNA]
+        fenster.tabelle = object()
+        fenster.beim_anzeigen = MagicMock()
+        with patch.object(treffer_modul, "ausgewaehlte_indizes", return_value=[0]):
+            fenster._on_anzeigen()
+        fenster.beim_anzeigen.assert_called_once_with([_ANNA])
+
+
+def _anz_tab(angezeigt=None, anzeige=None, layer_id="csv1"):
+    tab = EigentuemerTab.__new__(EigentuemerTab)
+    for name in ("btn_sitzung", "btn_anzeige_leeren", "btn_korrigieren", "sitzung_label", "korrektur_label",
+                 "eigentuemer_layer_combo"):
+        setattr(tab, name, MagicMock())
+    tab.eigentuemer_layer_combo.currentData.return_value = layer_id
+    tab._anzeige = anzeige
+    tab._anzeige_geometrie = None
+    tab._sitzung_seit = datetime(2026, 10, 6, 9, 5) if anzeige is not None else None
+    tab._angezeigt = list(angezeigt or [])
+    tab._treffer_layer_id = layer_id
+    tab._anzeige_layer_id = layer_id
+    tab._korrektur_pfade = {}
+    return tab
+
+
+_BERND = Eigentuemer(vorname="Bernd", nachname="Muster", konten=("300",), per_ids=("8",))
+
+
+@patch.object(et, "hole_layer", return_value=None)
+@patch.object(et, "zeige_anzeigefenster")
+@patch.object(et, "EigentuemerAnzeige")
+class TestSitzung(unittest.TestCase):
+
+    def test_sitzung_beginnen_oeffnet_leeres_fenster_mit_rahmen(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass „Sitzung beginnen“ ein leeres Anzeigefenster als normales Fenster öffnet (ohne gemerkte Lage beim ersten Mal)."""
+        tab = _anz_tab()
+        tab._on_sitzung_umschalten()
+        anzeige_klasse.assert_called_once_with(tab)
+        zeige.assert_called_once_with(anzeige_klasse.return_value, None)
+        self.assertIs(tab._anzeige, anzeige_klasse.return_value)
+        self.assertEqual(tab._angezeigt, [])
+        tab.btn_sitzung.setText.assert_called_with("Sitzung beenden")
+        self.assertIn("leer", tab.sitzung_label.setText.call_args[0][0])
+
+    def test_lage_gilt_fuer_naechste_sitzung(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass Größe und Lage des Fensters beim Beenden gemerkt und in der nächsten Sitzung wiederverwendet werden."""
+        tab = _anz_tab()
+        tab._sitzung_beginnen()
+        anzeige_klasse.return_value.saveGeometry.return_value = b"zweiter-bildschirm"
+        tab._sitzung_beenden()
+        tab._sitzung_beginnen()
+        self.assertEqual(zeige.call_args_list[-1][0][1], b"zweiter-bildschirm")
+
+    def test_daten_anzeigen_beginnt_sitzung_bei_bedarf(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass „Daten anzeigen“ ohne laufende Sitzung diese beginnt und die Einträge zeigt; die Statuszeile nennt nur die Anzahl."""
+        tab = _anz_tab()
+        tab._daten_anzeigen([_ANNA, _BERND])
+        anzeige_klasse.return_value.zeige.assert_called_once_with([_ANNA, _BERND])
+        self.assertEqual(tab._angezeigt, [_ANNA, _BERND])
+        status = tab.sitzung_label.setText.call_args[0][0]
+        self.assertIn("2 Einträge", status)
+        self.assertNotIn("Beispiel", status)
+
+    def test_daten_anzeigen_ohne_auswahl(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass „Daten anzeigen“ ohne Auswahl nur einen Hinweis gibt und keine Sitzung beginnt."""
+        tab = _anz_tab()
+        with patch.object(et, "warning") as warnung:
+            tab._daten_anzeigen([])
+        warnung.assert_called_once()
+        anzeige_klasse.assert_not_called()
+
+    def test_anzeige_leeren_laesst_fenster_offen(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass „Anzeige leeren“ die Daten entfernt, das Fenster aber nicht schließt."""
+        anzeige = MagicMock()
+        tab = _anz_tab(angezeigt=[_ANNA], anzeige=anzeige)
+        tab._on_anzeige_leeren()
+        anzeige.leeren.assert_called_once()
+        anzeige.close.assert_not_called()
+        self.assertEqual(tab._angezeigt, [])
+        self.assertIs(tab._anzeige, anzeige)
+        tab.btn_anzeige_leeren.setEnabled.assert_called_with(False)
+
+    def test_sitzung_beenden_schliesst_fenster(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass „Sitzung beenden“ das Anzeigefenster schließt und die angezeigten Daten vergisst."""
+        anzeige = MagicMock()
+        tab = _anz_tab(angezeigt=[_ANNA], anzeige=anzeige)
+        tab._on_sitzung_umschalten()
+        anzeige.close.assert_called_once()
+        self.assertIsNone(anzeige.beim_schliessen)
+        self.assertIsNone(tab._anzeige)
+        self.assertEqual(tab._angezeigt, [])
+        tab.btn_sitzung.setText.assert_called_with("Sitzung beginnen")
+
+    def test_von_aussen_geschlossen_beendet_sitzung(self, anzeige_klasse, zeige, _layer):
+        """Prüft, dass ein über den Fensterrahmen geschlossenes Anzeigefenster die Sitzung beendet und seine Lage gemerkt wird."""
+        tab = _anz_tab()
+        tab._sitzung_beginnen()
+        anzeige_klasse.return_value.saveGeometry.return_value = b"lage"
+        anzeige_klasse.return_value.beim_schliessen()
+        self.assertIsNone(tab._anzeige)
+        self.assertEqual(tab._anzeige_geometrie, b"lage")
+
+
+class TestKorrekturLabel(unittest.TestCase):
+
+    def _text(self, tab):
+        return tab.korrektur_label.setText.call_args[0][0]
+
+    def test_ohne_eigentuemerdatei(self):
+        """Prüft, dass ohne Eigentümerdatei unter den Knöpfen steht, dass keine gewählt ist."""
+        tab = _anz_tab(layer_id=None)
+        tab._aktualisiere_korrektur_label()
+        self.assertIn("keine Eigentümerdatei", self._text(tab))
+
+    def test_pfad_neben_der_eigentuemerdatei(self):
+        """Prüft, dass der Pfad der Korrektur-CSV angezeigt wird, mit Hinweis, solange sie noch nicht angelegt ist."""
+        with tempfile.TemporaryDirectory() as ordner:
+            quelle = "file:///" + os.path.join(ordner, "export.csv").replace(os.sep, "/") + "?type=csv"
+            erwartet = os.path.normpath(os.path.join(ordner, "export_korrekturen.csv"))
+            tab = _anz_tab()
+            with patch.object(et, "hole_layer", return_value=types.SimpleNamespace(source=lambda: quelle)):
+                tab._aktualisiere_korrektur_label()
+                self.assertEqual(os.path.normcase(self._text(tab)),
+                                 os.path.normcase(f"Korrektur-Datei: {erwartet} (wird beim ersten Speichern angelegt)"))
+                open(erwartet, "w").close()
+                tab._aktualisiere_korrektur_label()
+                self.assertEqual(os.path.normcase(self._text(tab)), os.path.normcase(f"Korrektur-Datei: {erwartet}"))
+
+    def test_ohne_csv_quelle_wird_abgefragt(self):
+        """Prüft, dass bei einer Quelle ohne CSV angekündigt wird, dass der Speicherort beim ersten Speichern abgefragt wird."""
+        tab = _anz_tab()
+        with patch.object(et, "hole_layer", return_value=types.SimpleNamespace(source=lambda: "memory?geometry=None")):
+            tab._aktualisiere_korrektur_label()
+        self.assertIn("abgefragt", self._text(tab))
+
+    def test_gewaehlter_pfad_wird_angezeigt(self):
+        """Prüft, dass ein einmal gewählter Speicherort angezeigt wird."""
+        tab = _anz_tab()
+        tab._korrektur_pfade["csv1"] = "D:/Termine/korrekturen.csv"
+        with patch.object(et, "hole_layer", return_value=None):
+            tab._aktualisiere_korrektur_label()
+        self.assertIn(os.path.normpath("D:/Termine/korrekturen.csv"), self._text(tab))
+
+
+@patch.object(et, "hole_layer", return_value=None)
+@patch.object(et, "success")
+@patch.object(et, "info")
+@patch.object(et, "warning")
+class TestKorrektur(unittest.TestCase):
+
+    def test_korrektur_wird_festgehalten_und_angezeigt(self, warnung, hinweis, erfolg, _layer):
+        """Prüft, dass eine Korrektur in die Korrektur-CSV geschrieben, sofort angezeigt und ohne Namen gemeldet wird."""
+        anzeige = MagicMock()
+        tab = _anz_tab(angezeigt=[_ANNA, _BERND], anzeige=anzeige)
+        tab._korrektur_pfade["csv1"] = "D:/Verfahren/export_korrekturen.csv"
+        with patch.object(et, "frage_korrektur", return_value=(1, {"wohnort": "Neustadt"})), \
+                patch.object(et, "schreibe_korrekturen") as schreiben:
+            tab._on_korrigieren()
+        schreiben.assert_called_once_with("D:/Verfahren/export_korrekturen.csv", _BERND,
+                                          [("wohnort", "", "Neustadt")])
+        self.assertEqual(tab._angezeigt[1].wohnort, "Neustadt")
+        self.assertIs(tab._angezeigt[0], _ANNA)
+        anzeige.zeige.assert_called_once_with(tab._angezeigt)
+        meldung = erfolg.call_args[0][1]
+        self.assertIn("export_korrekturen.csv", meldung)
+        self.assertNotIn("Muster", meldung)
+
+    def test_ohne_aenderung_nichts_schreiben(self, warnung, hinweis, erfolg, _layer):
+        """Prüft, dass ein unverändert gespeicherter Dialog nichts schreibt."""
+        tab = _anz_tab(angezeigt=[_ANNA], anzeige=MagicMock())
+        with patch.object(et, "frage_korrektur", return_value=(0, {"nachname": "Beispiel"})), \
+                patch.object(et, "schreibe_korrekturen") as schreiben:
+            tab._on_korrigieren()
+        schreiben.assert_not_called()
+        hinweis.assert_called_once()
+
+    def test_abbruch_nichts_schreiben(self, warnung, hinweis, erfolg, _layer):
+        """Prüft, dass ein abgebrochener Korrekturdialog nichts schreibt."""
+        tab = _anz_tab(angezeigt=[_ANNA], anzeige=MagicMock())
+        with patch.object(et, "frage_korrektur", return_value=None), \
+                patch.object(et, "schreibe_korrekturen") as schreiben:
+            tab._on_korrigieren()
+        schreiben.assert_not_called()
+
+    def test_schreibfehler_warnung_und_anzeige_unveraendert(self, warnung, hinweis, erfolg, _layer):
+        """Prüft, dass bei einem Schreibfehler gewarnt, die Anzeige nicht geändert und der Pfad beim nächsten Mal neu bestimmt wird."""
+        anzeige = MagicMock()
+        tab = _anz_tab(angezeigt=[_ANNA], anzeige=anzeige)
+        tab._korrektur_pfade["csv1"] = "X:/gesperrt.csv"
+        with patch.object(et, "frage_korrektur", return_value=(0, {"wohnort": "Neustadt"})), \
+                patch.object(et, "schreibe_korrekturen", side_effect=PermissionError(13, "Zugriff verweigert")):
+            tab._on_korrigieren()
+        warnung.assert_called_once()
+        anzeige.zeige.assert_not_called()
+        self.assertIs(tab._angezeigt[0], _ANNA)
+        self.assertNotIn("csv1", tab._korrektur_pfade)
+
+    def test_ohne_anzeige_keine_korrektur(self, warnung, hinweis, erfolg, _layer):
+        """Prüft, dass ohne angezeigte Daten kein Korrekturdialog erscheint."""
+        tab = _anz_tab()
+        with patch.object(et, "frage_korrektur") as dialog:
+            tab._on_korrigieren()
+        dialog.assert_not_called()
+        warnung.assert_called_once()
+
+
+class TestKorrekturDatei(unittest.TestCase):
+
+    def test_vorschlag_neben_der_eigentuemerdatei(self):
+        """Prüft, dass die Korrektur-CSV ohne Rückfrage neben der Eigentümerdatei liegt, wenn der Ordner beschreibbar ist, und gemerkt wird."""
+        with tempfile.TemporaryDirectory() as ordner:
+            quelle = "file:///" + os.path.join(ordner, "export.csv").replace(os.sep, "/") + "?type=csv"
+            layer = types.SimpleNamespace(source=lambda: quelle)
+            tab = _anz_tab()
+            with patch.object(et, "hole_layer", return_value=layer), \
+                    patch.object(et.QFileDialog, "getSaveFileName") as dialog:
+                pfad = tab._korrektur_datei()
+            dialog.assert_not_called()
+            self.assertEqual(os.path.normcase(os.path.normpath(pfad)),
+                             os.path.normcase(os.path.join(ordner, "export_korrekturen.csv")))
+            self.assertEqual(tab._korrektur_pfade["csv1"], pfad)
+
+    def test_ohne_csv_quelle_wird_gefragt(self):
+        """Prüft, dass ohne verwertbare CSV-Quelle nach dem Speicherort gefragt wird; Abbrechen liefert keinen Pfad."""
+        tab = _anz_tab()
+        layer = types.SimpleNamespace(source=lambda: "memory?geometry=None")
+        with patch.object(et, "hole_layer", return_value=layer), \
+                patch.object(et.QFileDialog, "getSaveFileName", return_value=("", "")) as dialog:
+            self.assertIsNone(tab._korrektur_datei())
+        dialog.assert_called_once()
+        self.assertEqual(tab._korrektur_pfade, {})
+
+        with patch.object(et, "hole_layer", return_value=layer), \
+                patch.object(et.QFileDialog, "getSaveFileName", return_value=("D:/k.csv", "")):
+            self.assertEqual(tab._korrektur_datei(), "D:/k.csv")
+
+
+class TestDockWidgetTabs(unittest.TestCase):
+
+    def test_tab_ist_im_dockwidget_eingetragen(self):
+        """Prüft, dass der Tab „Eigentümer“ im DockWidget direkt nach dem Bearbeitungs-Tab steht."""
+        from sn_verfahrensgebiet.ui.dockwidget import DockWidget
+        from sn_verfahrensgebiet.ui.tabs.working_tab import WorkingTab
+
+        self.assertEqual(DockWidget.tabs[:2], [WorkingTab, EigentuemerTab])
+        self.assertEqual(EigentuemerTab.tab_title, "Eigentümer")
+
+
+if __name__ == "__main__":
+    unittest.main()

tests/test_flurstueck_suche.py

@@ -0,0 +1,146 @@
+"""Tests für die Flurstückssuche im Layer „Flurstücke“ (#56)."""
+
+import types
+import unittest
+from unittest.mock import patch
+
+from sn_verfahrensgebiet.functions import flurstueck_suche as fs
+
+
+class _Feature(dict):
+    def __init__(self, fid, **attribute):
+        super().__init__(attribute)
+        self._fid = fid
+
+    def id(self):
+        return self._fid
+
+
+class _Layer:
+    def __init__(self, name, features, felder=("flurstueckskennzeichen",)):
+        self._name = name
+        self._features = features
+        self._felder = list(felder)
+
+    def name(self):
+        return self._name
+
+    def fields(self):
+        return types.SimpleNamespace(
+            indexFromName=lambda n: self._felder.index(n) if n in self._felder else -1
+        )
+
+    def getFeatures(self):
+        return iter(self._features)
+
+
+def _flurstuecke():
+    return _Layer("Flurstücke", [
+        _Feature(1, flurstueckskennzeichen="140268___00562____00"),
+        _Feature(2, flurstueckskennzeichen="140268___00562000100"),
+        _Feature(3, flurstueckskennzeichen="140268___00012000300"),
+        _Feature(4, flurstueckskennzeichen="140269___00562____00"),
+        _Feature(5, flurstueckskennzeichen="140268___00012000a00"),
+        _Feature(6, flurstueckskennzeichen=None),
+    ])
+
+
+def _gemarkungen():
+    return _Layer("Gemarkungen", [
+        _Feature(1, schluessel="140640268", ave_name="Beispielhausen"),
+        _Feature(2, schluessel="140640269", ave_name="Musterdorf"),
+        _Feature(3, schluessel="140650270", ave_name="Musterdorf"),
+    ], felder=("schluessel", "ave_name"))
+
+
+def _projekt(*layer):
+    nach_name = {lyr.name(): lyr for lyr in layer}
+    projekt = types.SimpleNamespace(
+        mapLayersByName=lambda name: [nach_name[name]] if name in nach_name else []
+    )
+    return types.SimpleNamespace(instance=lambda: projekt)
+
+
+class TestEingabe(unittest.TestCase):
+
+    def test_flurstuecksnummer_mit_und_ohne_nenner(self):
+        """Prüft, dass Zähler und Nenner getrennt und führende Nullen entfernt werden."""
+        self.assertEqual(fs.zerlege_flurstuecksnummer("562"), ("562", ""))
+        self.assertEqual(fs.zerlege_flurstuecksnummer(" 0012 / 03 "), ("12", "3"))
+        self.assertEqual(fs.zerlege_flurstuecksnummer("12/A"), ("12", "a"))
+
+    def test_ungueltige_flurstuecksnummer(self):
+        """Prüft, dass leere oder unzulässige Flurstücksnummern abgelehnt werden."""
+        for text in ("", "abc", "12/", "12/3/4", "12-3"):
+            with self.subTest(text=text):
+                with self.assertRaises(fs.FlurstueckSucheFehler):
+                    fs.zerlege_flurstuecksnummer(text)
+
+    def test_kennzeichen_zerlegen(self):
+        """Prüft, dass Gemarkung, Zähler und Nenner aus dem ALKIS-Kennzeichen gelesen werden."""
+        self.assertEqual(fs.zerlege_kennzeichen("140268___00562____00"), ("0268", "562", ""))
+        self.assertEqual(fs.zerlege_kennzeichen("140268___00012000300"), ("0268", "12", "3"))
+        self.assertEqual(fs.zerlege_kennzeichen("140268___00012000a00"), ("0268", "12", "a"))
+        self.assertIsNone(fs.zerlege_kennzeichen("1402"))
+        self.assertIsNone(fs.zerlege_kennzeichen(None))
+
+    def test_gemarkungsnummer_aus_ziffern(self):
+        """Prüft, dass Ziffern als Gemarkungsnummer gelten, auch ohne führende Nullen oder als langer Schlüssel."""
+        self.assertEqual(fs.gemarkungsnummern("268"), ["0268"])
+        self.assertEqual(fs.gemarkungsnummern("140268"), ["0268"])
+
+    def test_gemarkungsname_ueber_gemarkungslayer(self):
+        """Prüft, dass ein Gemarkungsname ohne Rücksicht auf Großschreibung in alle passenden Nummern übersetzt wird."""
+        self.assertEqual(fs.gemarkungsnummern("beispielhausen", _gemarkungen()), ["0268"])
+        self.assertEqual(fs.gemarkungsnummern("Musterdorf", _gemarkungen()), ["0269", "0270"])
+
+    def test_gemarkungsname_ohne_layer_oder_unbekannt(self):
+        """Prüft, dass ein Name ohne Gemarkungslayer oder ohne Treffer eine verständliche Meldung ergibt."""
+        with self.assertRaisesRegex(fs.FlurstueckSucheFehler, "Gemarkungsnummer"):
+            fs.gemarkungsnummern("Beispielhausen", None)
+        with self.assertRaisesRegex(fs.FlurstueckSucheFehler, "keine Gemarkung"):
+            fs.gemarkungsnummern("Nirgendwo", _gemarkungen())
+        with self.assertRaises(fs.FlurstueckSucheFehler):
+            fs.gemarkungsnummern("  ")
+
+
+class TestSuche(unittest.TestCase):
+
+    def test_mit_nenner_genau_ein_treffer(self):
+        """Prüft, dass mit Nenner nur das passende Flurstück der Gemarkung gefunden wird."""
+        self.assertEqual(fs.finde_flurstuecke(_flurstuecke(), ["0268"], "12", "3"), [3])
+        self.assertEqual(fs.finde_flurstuecke(_flurstuecke(), ["0268"], "12", "a"), [5])
+
+    def test_ohne_nenner_alle_mit_diesem_zaehler(self):
+        """Prüft, dass ohne Nenner alle Flurstücke mit dem Zähler gefunden werden, aber nur in der gesuchten Gemarkung."""
+        self.assertEqual(fs.finde_flurstuecke(_flurstuecke(), ["0268"], "562", ""), [1, 2])
+        self.assertEqual(fs.finde_flurstuecke(_flurstuecke(), ["0268", "0269"], "562", ""), [1, 2, 4])
+
+    def test_kein_treffer(self):
+        """Prüft, dass ein nicht vorhandenes Flurstück eine leere Trefferliste ergibt."""
+        self.assertEqual(fs.finde_flurstuecke(_flurstuecke(), ["0268"], "999", ""), [])
+
+    def test_layer_ohne_kennzeichenfeld(self):
+        """Prüft, dass ein Flurstückslayer ohne Feld „flurstueckskennzeichen“ gemeldet wird."""
+        layer = _Layer("Flurstücke", [], felder=("gml_id",))
+        with self.assertRaisesRegex(fs.FlurstueckSucheFehler, "flurstueckskennzeichen"):
+            fs.finde_flurstuecke(layer, ["0268"], "562", "")
+
+    def test_fehlender_flurstueckslayer_bricht_ab(self):
+        """Prüft, dass die Suche ohne Layer „Flurstücke“ mit dem Hinweis abbricht, zuerst Verfahrensgebiet und Flurstücke zu laden."""
+        with patch.object(fs, "QgsProject", _projekt(_gemarkungen())):
+            with self.assertRaises(fs.KeinFlurstueckslayer) as kontext:
+                fs.flurstueck_suchen("0268", "562")
+        self.assertIn("Flurstücke aus ALKIS laden", str(kontext.exception))
+
+    def test_suche_im_projekt_mit_gemarkungsname(self):
+        """Prüft, dass die Suche im Projekt den Gemarkungsnamen auflöst und Layer samt Treffern liefert."""
+        flurstuecke = _flurstuecke()
+        with patch.object(fs, "QgsProject", _projekt(flurstuecke, _gemarkungen())):
+            ergebnis = fs.flurstueck_suchen("Beispielhausen", "12/3")
+        self.assertIs(ergebnis.layer, flurstuecke)
+        self.assertEqual(ergebnis.feature_ids, [3])
+
+
+if __name__ == "__main__":
+    unittest.main()

tests/test_verfahrensgebiet_dialoge.py

@@ -0,0 +1,44 @@
+"""Tests für die gemeinsame Auswahltabelle in verfahrensgebiet_dialoge (#56)."""
+
+import types
+import unittest
+
+from sn_verfahrensgebiet.functions.verfahrensgebiet_dialoge import (
+    ausgewaehlte_indizes,
+    zeilen_sichtbar,
+)
+
+
+class _Item:
+    def __init__(self, row, index):
+        self._row = row
+        self._index = index
+
+    def row(self):
+        return self._row
+
+    def data(self, _rolle):
+        return self._index
+
+
+class TestAuswahltabelle(unittest.TestCase):
+
+    def test_suchfilter_ueber_alle_spalten(self):
+        """Prüft, dass der Suchfilter Teilstrings in jeder Spalte ohne Groß-/Kleinschreibung findet und leer alles zeigt."""
+        zeilen = [["14612", "Verfahren Nord"], ["14613", "Süd"], ["14700", None]]
+        self.assertEqual(zeilen_sichtbar(zeilen, "nord"), [True, False, False])
+        self.assertEqual(zeilen_sichtbar(zeilen, " 146 "), [True, True, False])
+        self.assertEqual(zeilen_sichtbar(zeilen, ""), [True, True, True])
+
+    def test_auswahl_nach_umsortieren(self):
+        """Prüft, dass die Auswahl über den gespeicherten Index auf die ursprünglichen Zeilen zurückgeführt wird, auch wenn die Tabelle umsortiert ist."""
+        # Tabelle zeigt Zeile 0 → Index 2, Zeile 1 → Index 0; beide Spalten je Zeile ausgewählt
+        tabelle = types.SimpleNamespace(
+            selectedItems=lambda: [_Item(0, 2), _Item(0, 2), _Item(1, 0), _Item(1, 0)],
+            item=lambda row, col: _Item(row, {0: 2, 1: 0}[row]),
+        )
+        self.assertEqual(ausgewaehlte_indizes(tabelle), [0, 2])
+
+
+if __name__ == "__main__":
+    unittest.main()

ui/dockwidget.py

@@ -1,10 +1,11 @@
 """sn_verfahrensgebiet/ui/dockwidget.py – Haupt-DockWidget für sn_verfahrensgebiet.
-Verwaltet die Tabs für Verfahrensgebiet-Bearbeitung, Druck und Einstellungen.
+Verwaltet die Tabs für Verfahrensgebiet-Bearbeitung, Eigentümer, Druck und Einstellungen.
 """
 
 from sn_basis.ui.tabs.settings_tab import SettingsTab
 from sn_basis.ui.tabs.print_tab import PrintTab
 from sn_verfahrensgebiet.ui.tabs.working_tab import WorkingTab
+from sn_verfahrensgebiet.ui.tabs.eigentuemer_tab import EigentuemerTab
 from sn_basis.ui.base_dockwidget import BaseDockWidget
 from sn_basis.functions.qt_wrapper import QTabWidget
 from sn_basis.functions.message_wrapper import error
@@ -14,12 +15,12 @@ class DockWidget(BaseDockWidget):
     """Haupt-DockWidget für sn_verfahrensgebiet mit Tab-Verwaltung.
     
     Attributes:
-        tabs: Liste von Tab-Klassen (WorkingTab, PrintTab, SettingsTab)
+        tabs: Liste von Tab-Klassen (WorkingTab, EigentuemerTab, PrintTab, SettingsTab)
         pruefmanager: Prüfmanager-Instanz für Validierung
         data_grabber: DataGrabber-Instanz für Fachdatenabruf
     """
     
-    tabs = [WorkingTab, PrintTab, SettingsTab]
+    tabs = [WorkingTab, EigentuemerTab, PrintTab, SettingsTab]
 
     def __init__(self, parent=None, subtitle="", pruefmanager=None, data_grabber=None):
         """Initialisiert das DockWidget mit Services und Tabs.

ui/eigentuemer_anzeige.py

@@ -0,0 +1,112 @@
+"""sn_verfahrensgebiet/ui/eigentuemer_anzeige.py – Anzeigefenster für den Eigentümer (#56).
+
+Das Fenster ist für einen zweiten Bildschirm gedacht, den nur der Eigentümer
+sieht. Es zeigt ausschließlich Name, Anschrift und E-Mail der vom Bearbeiter
+gewählten Einträge – keine Konten, keine Kennzeichen, keine anderen Treffer.
+Ohne Inhalt zeigt es nur einen neutralen Platzhalter.
+
+Das Fenster öffnet immer als normales Fenster mit Rahmen; der Bearbeiter
+schiebt es selbst auf den Bildschirm des Eigentümers und kann es dort
+maximieren. Eine automatische Bildschirmwahl mit Vollbild hat sich im QGIS-Test
+nicht bewährt: Das Fenster landete stets auf dem Hauptbildschirm und ließ sich
+im Vollbild weder verschieben noch schließen (siehe ``fallstricke.md``).
+"""
+
+import html
+from typing import Callable, Optional, Sequence
+
+from sn_basis.functions.qt_wrapper import QWidget, QVBoxLayout, QLabel, Qt
+
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+
+PLATZHALTER = "Datenabgleich"
+OHNE_EMAIL = "keine angegeben"
+STANDARDGROESSE = (900, 650)
+
+
+def _ortsteil(text: str) -> str:
+    return text if not text or text.upper().startswith("OT") else f"OT {text}"
+
+
+def anzeige_html(eintraege: Sequence[Eigentuemer]) -> str:
+    """HTML für das Anzeigefenster; alle Werte sind maskiert.
+
+    Je Eintrag eine Tabelle mit Name, Anschrift (mehrzeilig) und E-Mail. Eine
+    fehlende E-Mail wird ausdrücklich genannt, damit der Eigentümer sie ergänzen
+    kann. Ohne Einträge nur der Platzhalter.
+    """
+    if not eintraege:
+        return f"<p style='color:#888888;'>{html.escape(PLATZHALTER)}</p>"
+
+    bloecke = []
+    for e in eintraege:
+        name = " ".join(t for t in (e.anrede, e.titel, e.vorname, e.nachname) if t)
+        ort = " ".join(t for t in (e.plz, e.wohnort) if t)
+        anschrift = "<br/>".join(html.escape(t) for t in (e.strasse, ort, _ortsteil(e.ortsteil)) if t)
+        email = html.escape(", ".join(e.emails)) if e.emails else f"<i>{OHNE_EMAIL}</i>"
+        bloecke.append(
+            "<table cellpadding='6'>"
+            f"<tr><td style='color:#666666;'>Name</td><td><b>{html.escape(name)}</b></td></tr>"
+            f"<tr><td style='color:#666666;' valign='top'>Anschrift</td><td>{anschrift}</td></tr>"
+            f"<tr><td style='color:#666666;'>E-Mail</td><td>{email}</td></tr>"
+            "</table>"
+        )
+    return "<hr/>".join(bloecke)
+
+
+class EigentuemerAnzeige(QWidget):
+    """Eigenes Fenster (nicht im Dock) mit großer Schrift für den Eigentümer.
+
+    ``beim_schliessen`` wird aufgerufen, wenn das Fenster von außen geschlossen
+    wird (z. B. Alt+F4), damit der Tab die Sitzung als beendet führt.
+    """
+
+    def __init__(self, parent=None):
+        super().__init__(parent, Qt.WindowType.Window)
+        self.beim_schliessen: Optional[Callable[[], None]] = None
+        self.setWindowTitle(PLATZHALTER)
+        self.setStyleSheet("background-color: white; color: black;")
+
+        layout = QVBoxLayout(self)
+        layout.setContentsMargins(60, 50, 60, 50)
+        self._text = QLabel()
+        self._text.setTextFormat(Qt.TextFormat.RichText)
+        self._text.setWordWrap(True)
+        self._text.setAlignment(Qt.AlignmentFlag.AlignTop | Qt.AlignmentFlag.AlignLeft)
+        self._text.setStyleSheet("font-size: 26pt;")
+        layout.addWidget(self._text)
+        self.leeren()
+
+    def zeige(self, eintraege: Sequence[Eigentuemer]) -> None:
+        """Ersetzt den Inhalt durch die Einträge."""
+        self._text.setText(anzeige_html(eintraege))
+
+    def leeren(self) -> None:
+        """Zeigt nur noch den neutralen Platzhalter."""
+        self._text.setText(anzeige_html([]))
+
+    def closeEvent(self, event):  # noqa: N802 (Qt-Name)
+        rueckruf, self.beim_schliessen = self.beim_schliessen, None
+        if rueckruf is not None:
+            rueckruf()
+        super().closeEvent(event)
+
+
+def zeige_anzeigefenster(fenster, geometrie=None) -> None:
+    """Zeigt das Anzeigefenster als normales Fenster mit Rahmen, nie im Vollbild.
+
+    Mit ``geometrie`` (aus ``saveGeometry()`` der letzten Sitzung) erscheint es
+    wieder dort, wohin der Bearbeiter es geschoben hatte; sonst in
+    Standardgröße an der von Qt gewählten Stelle.
+    """
+    wiederhergestellt = False
+    if geometrie is not None:
+        try:
+            wiederhergestellt = bool(fenster.restoreGeometry(geometrie))
+        except Exception:
+            wiederhergestellt = False
+    if not wiederhergestellt:
+        fenster.resize(*STANDARDGROESSE)
+    fenster.show()
+    fenster.raise_()
+    fenster.activateWindow()

ui/eigentuemer_korrektur_dialog.py

@@ -0,0 +1,79 @@
+"""sn_verfahrensgebiet/ui/eigentuemer_korrektur_dialog.py – Korrekturdialog für den Bearbeiter (#56).
+
+Zeigt die Felder eines angezeigten Eintrags zum Bearbeiten. Sind mehrere
+Einträge angezeigt, wählt der Bearbeiter oben, welchen er korrigiert. Der
+Dialog speichert nichts selbst; das übernimmt der Tab über
+:mod:`sn_verfahrensgebiet.functions.eigentuemer_korrektur`.
+"""
+
+from typing import Dict, Optional, Sequence, Tuple
+
+from sn_basis.functions.qt_wrapper import (
+    QT_VERSION, exec_dialog, DialogAccepted,
+    QDialog, QDialogButtonBox, QVBoxLayout, QGridLayout, QLabel, QLineEdit, QComboBox,
+)
+
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+from sn_verfahrensgebiet.functions.eigentuemer_korrektur import FELDER, feldwerte
+
+
+def frage_korrektur(
+    parent,
+    eintraege: Sequence[Eigentuemer],
+) -> Optional[Tuple[int, Dict[str, str]]]:
+    """Fragt die korrigierten Werte ab.
+
+    Returns
+    -------
+    Optional[Tuple[int, Dict[str, str]]]
+        Index des gewählten Eintrags und die Werte aller Felder, oder ``None``
+        bei Abbruch (und im Mock-Modus).
+    """
+    if not eintraege or QT_VERSION == 0:
+        return None
+
+    dialog = QDialog(parent)
+    dialog.setWindowTitle("Daten korrigieren")
+    layout = QVBoxLayout(dialog)
+
+    auswahl = QComboBox()
+    for eintrag in eintraege:
+        auswahl.addItem(f"{eintrag.name} – {eintrag.anschrift}")
+    if len(eintraege) > 1:
+        layout.addWidget(QLabel("Eintrag:"))
+        layout.addWidget(auswahl)
+
+    raster = QGridLayout()
+    felder: Dict[str, QLineEdit] = {}
+    for zeile, (schluessel, beschriftung) in enumerate(FELDER):
+        raster.addWidget(QLabel(f"{beschriftung}:"), zeile, 0)
+        feld = QLineEdit()
+        raster.addWidget(feld, zeile, 1)
+        felder[schluessel] = feld
+    layout.addLayout(raster)
+
+    def _fuellen(index: int) -> None:
+        if 0 <= index < len(eintraege):
+            for schluessel, wert in feldwerte(eintraege[index]).items():
+                felder[schluessel].setText(wert)
+
+    auswahl.currentIndexChanged.connect(_fuellen)
+    _fuellen(0)
+
+    hinweis = QLabel(
+        "<small>Die Eigentümerdatei bleibt unverändert. Jede Änderung wird in der "
+        "Korrektur-CSV festgehalten und sofort im Anzeigefenster gezeigt. "
+        "Mehrere E-Mail-Adressen mit Komma trennen.</small>"
+    )
+    hinweis.setWordWrap(True)
+    layout.addWidget(hinweis)
+
+    knoepfe = QDialogButtonBox(QDialogButtonBox.StandardButton.Save | QDialogButtonBox.StandardButton.Cancel)
+    knoepfe.accepted.connect(dialog.accept)
+    knoepfe.rejected.connect(dialog.reject)
+    layout.addWidget(knoepfe)
+    dialog.resize(520, dialog.sizeHint().height())
+
+    if exec_dialog(dialog) != DialogAccepted:
+        return None
+    return auswahl.currentIndex(), {schluessel: feld.text() for schluessel, feld in felder.items()}

ui/eigentuemer_treffer.py

@@ -0,0 +1,83 @@
+"""sn_verfahrensgebiet/ui/eigentuemer_treffer.py – Trefferliste der Eigentümersuche (#56).
+
+Nicht modales Fenster für den Bearbeiter. Es zeigt die zusammengefassten
+Treffer mit dem Wert von ``PER_RECHTSPERSON`` (noch nicht entschlüsselt) und dem
+Kennzeichen „verstorben“ und erlaubt die Mehrfachauswahl. „Daten anzeigen“
+übergibt die Auswahl an das Anzeigefenster für den Eigentümer. Die Tabelle kommt aus
+:func:`~sn_verfahrensgebiet.functions.verfahrensgebiet_dialoge.baue_auswahltabelle`,
+dieselbe wie bei „Verfahrensgebiete aus Landkreis laden“.
+"""
+
+from typing import Callable, List, Optional, Sequence, Tuple
+
+from sn_basis.functions.qt_wrapper import QDialog, QVBoxLayout, QHBoxLayout, QLabel, QPushButton
+
+from sn_verfahrensgebiet.functions.eigentuemer_suche import Eigentuemer
+from sn_verfahrensgebiet.functions.verfahrensgebiet_dialoge import (
+    baue_auswahltabelle,
+    ausgewaehlte_indizes,
+)
+
+SPALTENKOEPFE = ["Name", "Anschrift", "E-Mail", "Rechtsperson", "Hinweis"]
+
+
+def trefferzeile(eigentuemer: Eigentuemer) -> Tuple[str, str, str, str, str]:
+    """Spaltentexte eines Treffers in der Reihenfolge von :data:`SPALTENKOEPFE`."""
+    return (
+        eigentuemer.name,
+        eigentuemer.anschrift,
+        ", ".join(eigentuemer.emails),
+        eigentuemer.rechtsperson_text,
+        eigentuemer.hinweise,
+    )
+
+
+class EigentuemerTrefferFenster(QDialog):
+    """Trefferliste der Eigentümersuche; bleibt offen, während weitergesucht wird."""
+
+    def __init__(
+        self,
+        treffer: Sequence[Eigentuemer],
+        parent=None,
+        beim_anzeigen: Optional[Callable[[List[Eigentuemer]], None]] = None,
+    ):
+        super().__init__(parent)
+        self.treffer: List[Eigentuemer] = list(treffer)
+        self.beim_anzeigen = beim_anzeigen
+        self.setWindowTitle("Eigentümersuche – Treffer")
+        self.setModal(False)
+
+        layout = QVBoxLayout(self)
+        anzahl = len(self.treffer)
+        layout.addWidget(QLabel("1 Eintrag gefunden." if anzahl == 1 else f"{anzahl} Einträge gefunden."))
+
+        self.tabelle = baue_auswahltabelle(
+            layout,
+            SPALTENKOEPFE,
+            [trefferzeile(e) for e in self.treffer],
+            platzhalter="Name, Ort oder Hinweis …",
+        )
+        self.tabelle.resizeColumnsToContents()
+        if anzahl == 1:
+            self.tabelle.selectRow(0)
+
+        knoepfe = QHBoxLayout()
+        self.btn_anzeigen = QPushButton("Daten anzeigen")
+        self.btn_anzeigen.setToolTip("Zeigt die ausgewählten Einträge im Fenster für den Eigentümer.")
+        self.btn_anzeigen.clicked.connect(self._on_anzeigen)
+        knoepfe.addWidget(self.btn_anzeigen)
+        knoepfe.addStretch()
+        self.btn_schliessen = QPushButton("Schließen")
+        self.btn_schliessen.clicked.connect(self.close)
+        knoepfe.addWidget(self.btn_schliessen)
+        layout.addLayout(knoepfe)
+
+        self.resize(760, 420)
+
+    def ausgewaehlte_eigentuemer(self) -> List[Eigentuemer]:
+        """Die in der Tabelle ausgewählten Treffer, in der Reihenfolge der Trefferliste."""
+        return [self.treffer[i] for i in ausgewaehlte_indizes(self.tabelle)]
+
+    def _on_anzeigen(self) -> None:
+        if self.beim_anzeigen is not None:
+            self.beim_anzeigen(self.ausgewaehlte_eigentuemer())

ui/tabs/eigentuemer_tab.py

@@ -0,0 +1,440 @@
+"""sn_verfahrensgebiet/ui/tabs/eigentuemer_tab.py – Tab „Eigentümer“ (#56).
+
+Zwei Bereiche:
+
+- **Flurstückssuche:** Gemarkung (Name oder Nummer) und Flurstücksnummer
+  eingeben, „Suchen“ wählt die Treffer im Layer „Flurstücke“ aus und zoomt hin.
+  Logik: :mod:`sn_verfahrensgebiet.functions.flurstueck_suche`.
+- **Eigentümersuche:** Eigentümerdatei (CSV-Layer) wählen, Name und/oder Vorname
+  eingeben, „Suchen“ öffnet die Trefferliste.
+  Logik: :mod:`sn_verfahrensgebiet.functions.eigentuemer_suche`.
+- **Anzeige für den Eigentümer:** Sitzung beginnen und beenden, Anzeige
+  leeren, angezeigte Daten korrigieren. „Daten anzeigen“ in der Trefferliste
+  füllt das Anzeigefenster (und beginnt bei Bedarf die Sitzung). Das Fenster
+  schiebt der Bearbeiter selbst auf den Bildschirm des Eigentümers; Größe und
+  Lage gelten für die nächste Sitzung weiter. Korrekturen landen in einer
+  Korrektur-CSV neben der Eigentümerdatei, deren Pfad unter den Knöpfen steht
+  (:mod:`sn_verfahrensgebiet.functions.eigentuemer_korrektur`).
+"""
+
+import os
+from datetime import datetime
+
+from sn_basis.functions.qt_wrapper import (
+    QWidget, QVBoxLayout, QHBoxLayout, QGridLayout, QLabel, QLineEdit, QPushButton, QComboBox,
+    QFileDialog, Qt,
+)
+from sn_basis.functions.qgisui_wrapper import iface
+from sn_basis.functions.dialog_wrapper import show_info_dialog
+from sn_basis.functions.message_wrapper import success, info, warning
+
+from sn_verfahrensgebiet.functions.flurstueck_suche import (
+    flurstueck_suchen,
+    FlurstueckSucheFehler,
+    KeinFlurstueckslayer,
+)
+from sn_verfahrensgebiet.functions.eigentuemer_suche import (
+    eigentuemerlayer_im_projekt,
+    hole_layer,
+    suche_eigentuemer,
+    EigentuemerSucheFehler,
+)
+from sn_verfahrensgebiet.functions.eigentuemer_korrektur import (
+    ermittle_aenderungen,
+    korrektur_pfad,
+    schreibe_korrekturen,
+    wende_an,
+)
+from sn_verfahrensgebiet.ui.eigentuemer_treffer import EigentuemerTrefferFenster
+from sn_verfahrensgebiet.ui.eigentuemer_anzeige import EigentuemerAnzeige, zeige_anzeigefenster
+from sn_verfahrensgebiet.ui.eigentuemer_korrektur_dialog import frage_korrektur
+
+_TITEL_SUCHE = "Flurstückssuche"
+_TITEL_EIGENTUEMER = "Eigentümersuche"
+_TITEL_ANZEIGE = "Anzeige für den Eigentümer"
+
+
+class EigentuemerLayerAuswahl(QComboBox):
+    """Auswahl der Eigentümerdatei; zeigt nur Layer mit den Spalten Nachname und Vorname.
+
+    Die Liste wird beim Aufklappen neu aufgebaut, damit eine gerade geladene CSV
+    ohne Projektsignale erscheint.
+    """
+
+    def aktualisieren(self) -> None:
+        """Baut die Liste neu auf und behält die bisherige Auswahl, solange es den Layer noch gibt."""
+        bisher = self.currentData()
+        self.clear()
+        for layer in eigentuemerlayer_im_projekt():
+            self.addItem(layer.name(), layer.id())
+        index = self.findData(bisher) if bisher else -1
+        self.setCurrentIndex(index if index >= 0 else 0)
+
+    def showPopup(self) -> None:
+        self.aktualisieren()
+        super().showPopup()
+
+
+class EigentuemerTab(QWidget):
+    """Tab für Flurstückssuche und Eigentümersuche.
+
+    Attributes:
+        tab_title: Anzeigetitel des Tabs ("Eigentümer")
+    """
+
+    tab_title = "Eigentümer"
+
+    def __init__(self, parent=None):
+        super().__init__(parent)
+
+        layout = QVBoxLayout()
+        layout.setAlignment(Qt.AlignmentFlag.AlignTop)
+
+        layout.addWidget(QLabel("<b>Flurstückssuche</b>"))
+
+        raster = QGridLayout()
+        raster.addWidget(QLabel("Gemarkung:"), 0, 0)
+        self.gemarkung_edit = QLineEdit()
+        self.gemarkung_edit.setPlaceholderText("Name oder Nummer, z. B. 0268")
+        raster.addWidget(self.gemarkung_edit, 0, 1)
+        raster.addWidget(QLabel("Flurstück:"), 1, 0)
+        self.flurstueck_edit = QLineEdit()
+        self.flurstueck_edit.setPlaceholderText("z. B. 562 oder 12/3")
+        raster.addWidget(self.flurstueck_edit, 1, 1)
+        layout.addLayout(raster)
+
+        zeile_suchen = QHBoxLayout()
+        zeile_suchen.addStretch()
+        self.btn_flurstueck_suchen = QPushButton("Suchen")
+        self.btn_flurstueck_suchen.setToolTip(
+            "Sucht im Layer „Flurstücke“. Ohne Nenner werden alle Flurstücke "
+            "mit diesem Zähler gefunden."
+        )
+        zeile_suchen.addWidget(self.btn_flurstueck_suchen)
+        layout.addLayout(zeile_suchen)
+
+        self.btn_flurstueck_suchen.clicked.connect(self._on_flurstueck_suchen)
+        self.gemarkung_edit.returnPressed.connect(self._on_flurstueck_suchen)
+        self.flurstueck_edit.returnPressed.connect(self._on_flurstueck_suchen)
+
+        titel_eigentuemer = QLabel("<b>Eigentümersuche</b>")
+        titel_eigentuemer.setStyleSheet("margin-top: 12px;")
+        layout.addWidget(titel_eigentuemer)
+
+        raster_eig = QGridLayout()
+        raster_eig.addWidget(QLabel("Eigentümerdatei:"), 0, 0)
+        self.eigentuemer_layer_combo = EigentuemerLayerAuswahl()
+        self.eigentuemer_layer_combo.setToolTip(
+            "CSV-Layer mit den Spalten Nachname und Vorname (Serienbriefexport). "
+            "Die CSV von Hand ins Projekt laden; die Liste wird beim Aufklappen aktualisiert."
+        )
+        raster_eig.addWidget(self.eigentuemer_layer_combo, 0, 1)
+        raster_eig.addWidget(QLabel("Name:"), 1, 0)
+        self.nachname_edit = QLineEdit()
+        raster_eig.addWidget(self.nachname_edit, 1, 1)
+        raster_eig.addWidget(QLabel("Vorname:"), 2, 0)
+        self.vorname_edit = QLineEdit()
+        raster_eig.addWidget(self.vorname_edit, 2, 1)
+        layout.addLayout(raster_eig)
+
+        zeile_eig_suchen = QHBoxLayout()
+        zeile_eig_suchen.addStretch()
+        self.btn_eigentuemer_suchen = QPushButton("Suchen")
+        self.btn_eigentuemer_suchen.setToolTip(
+            "Findet Einträge, deren Name und Vorname die Eingaben enthalten. "
+            "Gleiche Personen mit gleicher Anschrift werden zusammengefasst."
+        )
+        zeile_eig_suchen.addWidget(self.btn_eigentuemer_suchen)
+        layout.addLayout(zeile_eig_suchen)
+
+        self.btn_eigentuemer_suchen.clicked.connect(self._on_eigentuemer_suchen)
+        self.nachname_edit.returnPressed.connect(self._on_eigentuemer_suchen)
+        self.vorname_edit.returnPressed.connect(self._on_eigentuemer_suchen)
+
+        titel_anzeige = QLabel(f"<b>{_TITEL_ANZEIGE}</b>")
+        titel_anzeige.setStyleSheet("margin-top: 12px;")
+        layout.addWidget(titel_anzeige)
+
+        zeile_sitzung = QHBoxLayout()
+        self.btn_sitzung = QPushButton("Sitzung beginnen")
+        self.btn_sitzung.setToolTip(
+            "Öffnet das Anzeigefenster. Es auf den Bildschirm des Eigentümers schieben; "
+            "Größe und Lage gelten für die nächste Sitzung weiter."
+        )
+        self.btn_anzeige_leeren = QPushButton("Anzeige leeren")
+        self.btn_anzeige_leeren.setToolTip(
+            "Entfernt die Daten aus dem Anzeigefenster, ohne es zu schließen – "
+            "vor dem nächsten Eigentümer."
+        )
+        self.btn_korrigieren = QPushButton("Korrigieren …")
+        self.btn_korrigieren.setToolTip(
+            "Angezeigte Daten korrigieren; die Änderung wird in der Korrektur-CSV festgehalten."
+        )
+        for knopf in (self.btn_sitzung, self.btn_anzeige_leeren, self.btn_korrigieren):
+            zeile_sitzung.addWidget(knopf)
+        layout.addLayout(zeile_sitzung)
+
+        self.sitzung_label = QLabel()
+        self.sitzung_label.setWordWrap(True)
+        layout.addWidget(self.sitzung_label)
+
+        self.korrektur_label = QLabel()
+        self.korrektur_label.setWordWrap(True)
+        self.korrektur_label.setTextInteractionFlags(Qt.TextInteractionFlag.TextSelectableByMouse)
+        layout.addWidget(self.korrektur_label)
+
+        self.btn_sitzung.clicked.connect(self._on_sitzung_umschalten)
+        self.btn_anzeige_leeren.clicked.connect(self._on_anzeige_leeren)
+        self.btn_korrigieren.clicked.connect(self._on_korrigieren)
+        self.eigentuemer_layer_combo.currentIndexChanged.connect(
+            lambda _index: self._aktualisiere_korrektur_label()
+        )
+
+        self._trefferfenster = None
+        self._treffer_layer_id = None
+        self._anzeige = None
+        self._anzeige_geometrie = None
+        self._sitzung_seit = None
+        self._angezeigt = []
+        self._anzeige_layer_id = None
+        self._korrektur_pfade = {}
+        self.eigentuemer_layer_combo.aktualisieren()
+        self._aktualisiere_sitzungsstatus()
+
+        self.setLayout(layout)
+
+    def _on_flurstueck_suchen(self) -> None:
+        """Sucht das eingegebene Flurstück, wählt die Treffer aus und zoomt hin."""
+        gemarkung = self.gemarkung_edit.text().strip()
+        nummer = self.flurstueck_edit.text().strip()
+        try:
+            ergebnis = flurstueck_suchen(gemarkung, nummer)
+        except KeinFlurstueckslayer as exc:
+            show_info_dialog(_TITEL_SUCHE, str(exc), self)
+            return
+        except FlurstueckSucheFehler as exc:
+            warning(_TITEL_SUCHE, str(exc))
+            return
+
+        if not ergebnis.feature_ids:
+            info(_TITEL_SUCHE, f"Flurstück {nummer} in Gemarkung {gemarkung} nicht gefunden.")
+            return
+
+        ergebnis.layer.selectByIds(ergebnis.feature_ids)
+        self._zoome_auf_auswahl(ergebnis.layer, ergebnis.feature_ids)
+        anzahl = len(ergebnis.feature_ids)
+        text = "1 Flurstück" if anzahl == 1 else f"{anzahl} Flurstücke"
+        success(_TITEL_SUCHE, f"{text} im Layer „{ergebnis.layer.name()}“ ausgewählt.")
+
+    @staticmethod
+    def _zoome_auf_auswahl(layer, feature_ids) -> bool:
+        """Zoomt auf die Auswahl und lässt die Treffer kurz aufblinken.
+
+        ``zoomToSelected`` rechnet selbst in das KBS der Kartenansicht um.
+        Gibt ``False`` zurück, wenn keine Kartenansicht verfügbar ist.
+        """
+        try:
+            canvas = iface.mapCanvas()
+            canvas.zoomToSelected(layer)
+            canvas.flashFeatureIds(layer, feature_ids)
+            return True
+        except Exception:
+            return False
+
+    def _on_eigentuemer_suchen(self) -> None:
+        """Sucht in der gewählten Eigentümerdatei und zeigt die Trefferliste.
+
+        Meldungen enthalten bewusst keine Namen (Datenschutz).
+        """
+        layer = hole_layer(self.eigentuemer_layer_combo.currentData())
+        if layer is None:
+            self.eigentuemer_layer_combo.aktualisieren()
+            layer = hole_layer(self.eigentuemer_layer_combo.currentData())
+        if layer is None:
+            warning(
+                _TITEL_EIGENTUEMER,
+                "Keine Eigentümerdatei gewählt. Bitte den Serienbriefexport (CSV) "
+                "als Layer laden und hier auswählen.",
+            )
+            return
+
+        try:
+            treffer = suche_eigentuemer(layer, self.nachname_edit.text(), self.vorname_edit.text())
+        except EigentuemerSucheFehler as exc:
+            warning(_TITEL_EIGENTUEMER, str(exc))
+            return
+
+        if not treffer:
+            info(_TITEL_EIGENTUEMER, "Keine passenden Einträge gefunden.")
+            return
+        self._treffer_layer_id = layer.id()
+        self._zeige_treffer(treffer)
+
+    def _zeige_treffer(self, treffer) -> None:
+        """Ersetzt eine offene Trefferliste durch die neue."""
+        alt = getattr(self, "_trefferfenster", None)
+        if alt is not None:
+            alt.close()
+        self._trefferfenster = EigentuemerTrefferFenster(
+            treffer, self, beim_anzeigen=self._daten_anzeigen
+        )
+        self._trefferfenster.show()
+
+    # ------------------------------------------------------------------
+    # Anzeige für den Eigentümer
+    # ------------------------------------------------------------------
+
+    def _on_sitzung_umschalten(self) -> None:
+        if self._anzeige is None:
+            self._sitzung_beginnen()
+        else:
+            self._sitzung_beenden()
+
+    def _sitzung_beginnen(self) -> None:
+        """Öffnet das Anzeigefenster leer, mit Rahmen, an der Stelle der letzten Sitzung."""
+        anzeige = EigentuemerAnzeige(self)
+        anzeige.beim_schliessen = self._anzeige_wurde_geschlossen
+        zeige_anzeigefenster(anzeige, self._anzeige_geometrie)
+        self._anzeige = anzeige
+        self._sitzung_seit = datetime.now()
+        self._angezeigt = []
+        self._aktualisiere_sitzungsstatus()
+
+    def _sitzung_beenden(self) -> None:
+        """Schließt das Anzeigefenster; die Korrektur-CSV bleibt, wie sie ist."""
+        anzeige = self._anzeige
+        self._anzeige_wurde_geschlossen()
+        if anzeige is not None:
+            anzeige.beim_schliessen = None
+            anzeige.close()
+
+    def _anzeige_wurde_geschlossen(self) -> None:
+        if self._anzeige is not None:
+            try:
+                self._anzeige_geometrie = self._anzeige.saveGeometry()
+            except Exception:
+                pass
+        self._anzeige = None
+        self._sitzung_seit = None
+        self._angezeigt = []
+        self._aktualisiere_sitzungsstatus()
+
+    def _on_anzeige_leeren(self) -> None:
+        """Entfernt die Daten aus der Anzeige, das Fenster bleibt offen."""
+        if self._anzeige is not None:
+            self._anzeige.leeren()
+        self._angezeigt = []
+        self._aktualisiere_sitzungsstatus()
+
+    def _daten_anzeigen(self, eintraege) -> None:
+        """Rückruf der Trefferliste: zeigt die gewählten Einträge, beginnt bei Bedarf die Sitzung."""
+        if not eintraege:
+            warning(_TITEL_ANZEIGE, "Bitte in der Trefferliste mindestens einen Eintrag auswählen.")
+            return
+        if self._anzeige is None:
+            self._sitzung_beginnen()
+        self._angezeigt = list(eintraege)
+        self._anzeige_layer_id = self._treffer_layer_id
+        self._anzeige.zeige(self._angezeigt)
+        self._aktualisiere_sitzungsstatus()
+
+    def _aktualisiere_sitzungsstatus(self) -> None:
+        """Knopftexte und Statuszeile; ohne Namen, damit der Tab nichts preisgibt."""
+        aktiv = self._anzeige is not None
+        self.btn_sitzung.setText("Sitzung beenden" if aktiv else "Sitzung beginnen")
+        self.btn_anzeige_leeren.setEnabled(aktiv and bool(self._angezeigt))
+        self.btn_korrigieren.setEnabled(aktiv and bool(self._angezeigt))
+        if not aktiv:
+            text = "Keine Sitzung. „Daten anzeigen“ in der Trefferliste beginnt sie automatisch."
+        else:
+            anzahl = len(self._angezeigt)
+            inhalt = "leer" if not anzahl else ("1 Eintrag" if anzahl == 1 else f"{anzahl} Einträge")
+            text = f"Sitzung seit {self._sitzung_seit:%H:%M} Uhr – Anzeige: {inhalt}"
+        self.sitzung_label.setText(text)
+        self._aktualisiere_korrektur_label()
+
+    def _korrektur_layer_id(self):
+        """Eigentümerdatei, zu der Korrekturen gehören: die angezeigte, sonst die gesuchte, sonst die gewählte."""
+        return self._anzeige_layer_id or self._treffer_layer_id or self.eigentuemer_layer_combo.currentData()
+
+    def _korrektur_vorschau(self):
+        """Pfad der Korrektur-CSV ohne Rückfrage, oder ``None``, wenn er erst beim Speichern erfragt wird."""
+        layer_id = self._korrektur_layer_id()
+        if layer_id in self._korrektur_pfade:
+            return self._korrektur_pfade[layer_id]
+        layer = hole_layer(layer_id)
+        vorschlag = korrektur_pfad(layer.source()) if layer is not None else None
+        ordner = os.path.dirname(vorschlag) if vorschlag else ""
+        if vorschlag and os.path.isdir(ordner) and os.access(ordner, os.W_OK):
+            return vorschlag
+        return None
+
+    def _aktualisiere_korrektur_label(self) -> None:
+        """Zeigt unter den Knöpfen, wohin Korrekturen geschrieben werden."""
+        if not self._korrektur_layer_id():
+            text = "Korrektur-Datei: – (keine Eigentümerdatei gewählt)"
+        else:
+            pfad = self._korrektur_vorschau()
+            if pfad is None:
+                text = "Korrektur-Datei: wird beim ersten Speichern abgefragt"
+            else:
+                zusatz = "" if os.path.exists(pfad) else " (wird beim ersten Speichern angelegt)"
+                text = f"Korrektur-Datei: {os.path.normpath(pfad)}{zusatz}"
+        self.korrektur_label.setText(text)
+
+    # ------------------------------------------------------------------
+    # Korrekturen
+    # ------------------------------------------------------------------
+
+    def _on_korrigieren(self) -> None:
+        """Fragt Korrekturen ab, hält sie in der Korrektur-CSV fest und zeigt sie sofort an."""
+        if not self._angezeigt:
+            warning(_TITEL_ANZEIGE, "Es werden keine Daten angezeigt.")
+            return
+        ergebnis = frage_korrektur(self, self._angezeigt)
+        if ergebnis is None:
+            return
+        index, werte = ergebnis
+        eintrag = self._angezeigt[index]
+        aenderungen = ermittle_aenderungen(eintrag, werte)
+        if not aenderungen:
+            info(_TITEL_ANZEIGE, "Keine Änderung.")
+            return
+
+        pfad = self._korrektur_datei()
+        if not pfad:
+            return
+        try:
+            schreibe_korrekturen(pfad, eintrag, aenderungen)
+        except OSError as exc:
+            self._korrektur_pfade.pop(self._anzeige_layer_id, None)
+            warning(_TITEL_ANZEIGE, f"Die Korrektur-CSV konnte nicht geschrieben werden: {exc.strerror or exc}")
+            return
+
+        self._angezeigt[index] = wende_an(eintrag, aenderungen)
+        if self._anzeige is not None:
+            self._anzeige.zeige(self._angezeigt)
+        self._aktualisiere_korrektur_label()
+        anzahl = len(aenderungen)
+        text = "1 Änderung" if anzahl == 1 else f"{anzahl} Änderungen"
+        success(_TITEL_ANZEIGE, f"{text} in „{os.path.basename(pfad)}“ festgehalten.")
+
+    def _korrektur_datei(self):
+        """Pfad der Korrektur-CSV für die angezeigte Eigentümerdatei.
+
+        Vorgabe ist ``<Eigentümerdatei>_korrekturen.csv`` daneben. Lässt sich
+        daraus kein beschreibbarer Ordner ableiten, wird gefragt. Die Wahl gilt
+        für die Eigentümerdatei, solange der Tab besteht.
+        """
+        layer_id = self._anzeige_layer_id
+        pfad = self._korrektur_vorschau() if layer_id == self._korrektur_layer_id() else None
+        if pfad is None:
+            layer = hole_layer(layer_id)
+            vorschlag = korrektur_pfad(layer.source()) if layer is not None else None
+            pfad, _ = QFileDialog.getSaveFileName(
+                self, "Korrektur-CSV wählen", vorschlag or os.path.expanduser("~"), "CSV-Dateien (*.csv)"
+            )
+            if not pfad:
+                return None
+        self._korrektur_pfade[layer_id] = pfad
+        return pfad