Backend-KI-Workflows: Intelligente Automatisierung mit Intrexx + n8n

// Intrexx Groovy Hook: Rechnung an n8n senden
import groovy.json.JsonOutput
import groovy.json.JsonSlurper

// Hole Rechnungsdatei aus Intrexx Record
def invoiceFile = g_record.getFile("invoice_pdf")
def invoiceBytes = invoiceFile.getBytes()
def invoiceBase64 = invoiceBytes.encodeBase64().toString()

// n8n Webhook URL
def n8nWebhook = "https://n8n.himmelblau.digital/webhook/invoice-check"

// Payload erstellen
def payload = [
    invoice_id: g_record.getIntegerValue("id"),
    pdf_base64: invoiceBase64,
    supplier: g_record.getStringValue("supplier_name"),
    expected_amount: g_record.getDoubleValue("po_amount")
]

// HTTP POST zu n8n
def connection = new URL(n8nWebhook).openConnection()
connection.setRequestMethod("POST")
connection.doOutput = true
connection.setRequestProperty("Content-Type", "application/json")

def writer = new OutputStreamWriter(connection.outputStream)
writer.write(JsonOutput.toJson(payload))
writer.flush()
writer.close()

// Response von n8n lesen
def responseCode = connection.responseCode
if (responseCode == 200) {
    def response = connection.inputStream.text
    def json = new JsonSlurper().parseText(response)

    // Update Intrexx Record mit KI-Ergebnissen
    g_record.setValue("ai_extracted_amount", json.amount)
    g_record.setValue("ai_extracted_date", json.invoice_date)
    g_record.setValue("ai_extracted_iban", json.iban)
    g_record.setValue("ai_confidence", json.confidence)
    g_record.setValue("ai_status", "processed")
} else {
    g_record.setValue("ai_status", "error")
    g_record.setValue("ai_error", "n8n returned " + responseCode)
}

n8n Workflow (visuell, kein Code nötig):

1. Webhook Trigger
   └─ Empfängt JSON von Intrexx

2. Base64 Decode
   └─ Konvertiert pdf_base64 zurück zu Binary

3. Claude Vision API Call
   └─ Prompt: "Extrahiere aus dieser Rechnung: Betrag, Datum, Rechnungsnr, IBAN, MwSt"
   └─ Response Format: JSON

4. JSON Parse & Validation
   └─ Prüft ob alle Felder vorhanden
   └─ Plausibilitätscheck (Betrag > 0, Datum im Jahr 2024-2026)

5. Respond to Webhook
   └─ Sendet strukturiertes JSON zurück an Intrexx

Prompt-Beispiel für Claude:

Du bist ein Rechnungsprüfungs-Assistent. Analysiere das hochgeladene PDF
und extrahiere folgende Informationen:

1. Rechnungsnummer
2. Rechnungsdatum (Format: YYYY-MM-DD)
3. Fälligkeitsdatum (Format: YYYY-MM-DD)
4. Lieferant (Firmenname)
5. Rechnungsbetrag (Netto)
6. MwSt. (in Euro)
7. Rechnungsbetrag (Brutto)
8. IBAN (falls vorhanden)
9. Zahlungsziel (z.B. "14 Tage netto")
10. Skonto (%, falls vorhanden)

WICHTIG:
- Gib die Daten als strukturiertes JSON zurück
- Wenn ein Feld nicht gefunden wird, gib null zurück
- Gib auch eine Confidence (0-100%) für die Extraktion an

Beispiel-Output:
{
  "invoice_number": "RE-2024-12345",
  "invoice_date": "2024-03-15",
  "due_date": "2024-03-29",
  "supplier": "Mustermann GmbH",
  "amount_net": 5000.00,
  "vat": 950.00,
  "amount_gross": 5950.00,
  "iban": "DE89370400440532013000",
  "payment_term": "14 Tage netto",
  "discount": 2.0,
  "confidence": 95
}

// Intrexx Hook (Fortsetzung): Business Logic nach KI-Extraktion

// Plausibilitätsprüfung
def extractedAmount = g_record.getDoubleValue("ai_extracted_amount")
def expectedAmount = g_record.getDoubleValue("po_amount")
def tolerance = 0.05 // 5% Toleranz

def amountDiff = Math.abs(extractedAmount - expectedAmount)
def amountDiffPercent = (amountDiff / expectedAmount) * 100

if (amountDiffPercent > tolerance) {
    // Abweichung > 5% → Manueller Review
    g_record.setValue("approval_status", "manual_review_required")
    g_record.setValue("approval_reason", "Betrag weicht um ${amountDiffPercent}% ab")

    // Workflow-Task erstellen für Controller
    def task = g_appContext.createTask()
    task.setSubject("Rechnung ${g_record.getStringValue('invoice_number')} - Betrag prüfen")
    task.setAssignee("controller_team")
    task.setRecordId(g_record.getIntegerValue("id"))
    task.save()
} else {
    // Alles ok → Automatische Freigabe
    g_record.setValue("approval_status", "auto_approved")
    g_record.setValue("approval_reason", "KI-Prüfung erfolgreich, Betrag korrekt")

    // Weiterleitung an DATEV-Export-Workflow
    g_record.setValue("datev_export_ready", true)
}