ZUGFeRD-Positionen automatisch ins
Rechnungseingangsbuch

// ============================================================
// ZUGFeRD Positions-Import für eGECKO/Integris
// Kubisch Consulting — kubisch.consulting
// ============================================================
#!gscript
import de.integris.kit.ctl.PropertyEdit;
import de.css.report.archiv.DokumentenarchivTools;
import org.apache.pdfbox.pdmodel.PDDocument;
import org.apache.pdfbox.Loader;
import org.apache.pdfbox.text.PDFTextStripper;
import org.apache.pdfbox.cos.*;

// ── Parameter ─────────────────────────────────────────────
final double MIN_SCORE = 0.80d        // Mindest-Trefferquote
final String DUMMY_KEY = "dummy"      // Fallback-Mapping-Schlüssel

// ── Hilfsfunktionen ───────────────────────────────────────
def normalizeText = { s ->
    if (!s) return ""
    s.toLowerCase()
     .replaceAll("[\\p{Punct}]+", " ")
     .replaceAll("\\s+", " ")
     .trim()
}

def levenshtein = { a, b ->
    a = (a ?: "").toLowerCase()
    b = (b ?: "").toLowerCase()
    int m = a.length(), n = b.length()
    int[][] dp = new int[m+1][n+1]
    (0..m).each { dp[it][0] = it }
    (0..n).each { dp[0][it] = it }
    for (i in 1..m) {
        for (j in 1..n) {
            int cost = (a.charAt(i-1) == b.charAt(j-1)) ? 0 : 1
            dp[i][j] = Math.min(Math.min(dp[i-1][j]+1, dp[i][j-1]+1),
                                   dp[i-1][j-1]+cost)
        }
    }
    dp[m][n]
}

def similarity = { a, b ->
    def na = normalizeText(a), nb = normalizeText(b)
    if (!na || !nb) return 0d
    // Contain-Boost: exakter Teilstring → mind. 90%
    boolean boost = (" "+na+" ").contains(" "+nb+" ")
                  || (" "+nb+" ").contains(" "+na+" ")
    int dist = levenshtein(na, nb)
    double base = 1d - (dist / (double)Math.max(na.length(), nb.length()))
    if (boost) base = Math.max(base, 0.90d)
    Math.min(1d, Math.max(0d, base))
}

// ── 1) FibuBeleg laden ────────────────────────────────────
def fibuBeleg = obj.fibuBeleg
if (!fibuBeleg) { println("ABBRUCH: fibuBeleg ist null"); return }

// ── 2) XML aus PDF/Archiv extrahieren ────────────────────
def xmlString = null
try {
    def zuordnungen = DokumentenarchivTools
        .getDokumentenzuordnungenZuIObject(fibuBeleg)
    def binary = zuordnungen?.find { true }?.getDokumentenarchivBinaryData()
    byte[] pdfBytes = binary?.dokumentBinaryData?.data

    if (pdfBytes) {
        def header = new String(pdfBytes, 0, Math.min(pdfBytes.length, 200), "UTF-8")
        if (header.contains("<?xml") || header.contains("CrossIndustryInvoice")) {
            xmlString = new String(pdfBytes, "UTF-8")  // direkte XML-Datei
        } else {
            PDDocument pdf = Loader.loadPDF(pdfBytes)
            try {
                // Names-Tree → AF-Array (ZUGFeRD 2.x Standard)
                // ... [PDF-Parsing-Logik] ...
            } finally { pdf.close() }
        }
    }
} catch (Exception ex) { println("WARNUNG: " + ex.message) }

if (!xmlString) { println("ABBRUCH: Keine XML gefunden"); return }

// ── 3) Positionen aus XML parsen ─────────────────────────
def positions = []
def xml = xmlString
def escaped = xml.contains("&lt;")

def lineItemPat = escaped
    ? /(?s)&lt;[^&]*IncludedSupplyChainTradeLineItem[^&]*&gt;(.*?)&lt;\/[^&]*IncludedSupplyChainTradeLineItem&gt;/
    : /(?s)<[^>]*IncludedSupplyChainTradeLineItem[^>]*>(.*?)<\/[^>]*IncludedSupplyChainTradeLineItem>/

(xml =~ lineItemPat).each { m ->
    // Name, LineTotalAmount, ApplicablePercent extrahieren
    // → positions << [text, net, vatPct]
}

// ── 4) Mapping laden ─────────────────────────────────────
def mapping = fetchObject("de.css.uss.Mapping", "bezeichnung", "Zugferd")
def mvList  = mapping?.mappingValues?.collect {
    [ eingang    : it.eingangsWert.toString(),
      ausgang    : it.ausgangsWert.toString(),
      eingangNorm: normalizeText(it.eingangsWert.toString()) ]
}
def dummyMV = mvList?.find { it.eingang?.equalsIgnoreCase(DUMMY_KEY) }

// ── 5 + 6) Positionen anlegen ────────────────────────────
PropertyEdit edit = obj.getEditingContext().beginEdit("ZUGFeRD-Positionen")
try {
    positions.each { p ->
        // Bestes Mapping finden
        def best = null; double bestScore = 0d
        mvList.each { mv ->
            double sc = similarity(normalizeText(p.text), mv.eingangNorm)
            if (sc > bestScore) { bestScore = sc; best = mv }
        }
        def chosen = (bestScore >= MIN_SCORE) ? best : dummyMV
        if (!chosen) { println("Übersprungen: kein Mapping"); return }

        def sk = fetchObject("de.css.fibu.stammdaten.konten.Sachkonto",
                             "kontonummer", chosen.ausgang)
        if (!sk) { return }  // kein gültiges Konto

        // Brutto aus Netto + MwSt berechnen
        BigDecimal rate  = p.vatPct.divide(new BigDecimal("100"), 10, ROUND_HALF_UP)
        BigDecimal gross = p.net.multiply(BigDecimal.ONE.add(rate)).setScale(2, ROUND_HALF_UP)
        BigDecimal vat   = gross.subtract(p.net).setScale(2, ROUND_HALF_UP)

        def bp = fibuBeleg.createIntoBelegpositionen(edit, -1, [] as Object[])
        bp.setSachkonto(sk)
        fibuBeleg.clientSetBelegwaehrungsbetrag(edit, bp, gross)
        edit.set(bp, "steuerbetragBelegwaehrung", vat)
        edit.set(bp, "buchtext", p.text)
    }
    edit.commit()
} catch (Exception ex) {
    edit.rollback(ex)
}

// ── 7) Saldo neu berechnen ───────────────────────────────
def e2 = obj.getEditingContext().beginEdit("Saldo aktualisieren")
try {
    fibuBeleg.setzeSollHabenSaldo(e2)
    e2.commit()
} catch (ex) { e2.rollback(ex) }

println "OK – ZUGFeRD-Import abgeschlossen."