Charge: Adress-Excel zum Sammel-PDF (POST /api/charge/merge-xlsx)

Excel mit allen Empfaengern der gewaehlten Auftraege in EXAKT der Reihenfolge
des Sammel-PDFs: gleiche Auftragsabfrage (fetchOrdersMinimal, sort=order_number)
und gleiche Datei-Reihenfolge (dateienVon, geteilt mit merge-pdf); innerhalb des
Auftrags nach Briefnummer. Je Zeile die PDF-Seiten im Sammel-PDF (je Brief bei
1 PDF je Empfaenger, sonst Bereich des Auftrags) + Hinweis bei fehlender oder
defekter Druckdatei. merge-pdf liefert unveraendert dieselben Seiten in
derselben Reihenfolge.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

src/api/controllers/charge-controller.js

@@ -5,33 +5,48 @@
  * Unterschriften-Service) zu EINER PDF zusammen, die am Bürodrucker in einem
  * Rutsch gedruckt werden kann. Reihenfolge = Auftragsnummer (aufsteigend), damit
  * sie zur Kuvert-Reihenfolge im Plotter passt.
+ *
+ * Dazu passend: Excel-Export aller Adressen in EXAKT derselben Reihenfolge wie
+ * das Sammel-PDF (gleiche Auftragsabfrage, gleiche Datei-Reihenfolge).
  */
 const { PDFDocument } = require('pdf-lib');
+const ExcelJS = require('exceljs');
 const directus = require('../../services/directus-service');
 
+/** Druckdateien eines Auftrags in Stapel-Reihenfolge (geteilt von PDF + Excel). */
+function dateienVon(order) {
+  const sf = Array.isArray(order.source_files) ? order.source_files.filter(Boolean) : [];
+  if (sf.length) return sf;
+  return order.source_file ? [order.source_file] : [];
+}
+
+/** Ausgewählte Aufträge laden – sortiert nach Auftragsnummer (wie bisher). */
+async function ladeAuftraege(req, res) {
+  const ids = Array.isArray(req.body?.orderIds) ? req.body.orderIds.filter((v) => v != null) : [];
+  if (!ids.length) {
+    res.status(400).json({ error: 'Invalid request', message: 'orderIds (array) is required.' });
+    return null;
+  }
+  const orders = await directus.fetchOrdersMinimal(ids);
+  if (!orders || !orders.length) {
+    res.status(404).json({ error: 'Not found', message: 'Keine Aufträge gefunden.' });
+    return null;
+  }
+  return orders;
+}
+
 /**
  * POST /api/charge/merge-pdf
  * Body: { orderIds: (number|string)[] }  → application/pdf (zusammengeführt)
  */
 async function mergePdf(req, res, next) {
   try {
-    const ids = Array.isArray(req.body?.orderIds) ? req.body.orderIds.filter((v) => v != null) : [];
-    if (!ids.length) {
-      return res.status(400).json({ error: 'Invalid request', message: 'orderIds (array) is required.' });
-    }
-
-    const orders = await directus.fetchOrdersMinimal(ids);
-    if (!orders || !orders.length) {
-      return res.status(404).json({ error: 'Not found', message: 'Keine Aufträge gefunden.' });
-    }
+    const orders = await ladeAuftraege(req, res);
+    if (!orders) return undefined;
 
     // Datei-IDs in Auftragsnummern-Reihenfolge (orders ist bereits sortiert).
     const fileIds = [];
-    for (const o of orders) {
-      const sf = Array.isArray(o.source_files) ? o.source_files.filter(Boolean) : [];
-      if (sf.length) fileIds.push(...sf);
-      else if (o.source_file) fileIds.push(o.source_file);
-    }
+    for (const o of orders) fileIds.push(...dateienVon(o));
     if (!fileIds.length) {
       return res.status(400).json({ error: 'No files', message: 'Keine Druckdateien an den Aufträgen.' });
     }
@@ -66,4 +81,103 @@ async function mergePdf(req, res, next) {
   }
 }
 
-module.exports = { mergePdf };
+const seitenText = (von, bis) => (bis < von ? '' : (von === bis ? String(von) : `${von}–${bis}`));
+
+/**
+ * POST /api/charge/merge-xlsx
+ * Body: { orderIds: (number|string)[] }  → .xlsx (Adressen in Sammel-PDF-Reihenfolge)
+ *
+ * Je Empfänger eine Zeile. Aufträge in derselben Reihenfolge wie merge-pdf,
+ * innerhalb des Auftrags nach Briefnummer. „PDF-Seiten" zeigt, wo die Zeile im
+ * Sammel-PDF liegt: je Brief, wenn der Auftrag genau eine PDF je Empfänger hat,
+ * sonst den Seitenbereich des ganzen Auftrags.
+ */
+async function mergeXlsx(req, res, next) {
+  try {
+    const orders = await ladeAuftraege(req, res);
+    if (!orders) return undefined;
+
+    const entries = await directus.fetchEntriesForOrders(orders.map((o) => o.id));
+    const proAuftrag = new Map();
+    for (const e of entries) {
+      const k = String(e.order);
+      if (!proAuftrag.has(k)) proAuftrag.set(k, []);
+      proAuftrag.get(k).push(e);
+    }
+
+    const wb = new ExcelJS.Workbook();
+    const ws = wb.addWorksheet('Adressen');
+    ws.columns = [
+      { header: 'Nr.', key: 'nr', width: 6 },
+      { header: 'Auftragsnummer', key: 'auftrag', width: 16 },
+      { header: 'Briefnummer', key: 'brief', width: 11 },
+      { header: 'Anrede', key: 'salutation', width: 12 },
+      { header: 'Vorname', key: 'first_name', width: 16 },
+      { header: 'Nachname', key: 'last_name', width: 18 },
+      { header: 'Straße', key: 'street', width: 22 },
+      { header: 'Hausnr.', key: 'house_no', width: 8 },
+      { header: 'PLZ', key: 'zip', width: 8 },
+      { header: 'Ort', key: 'city', width: 16 },
+      { header: 'Land', key: 'country', width: 12 },
+      { header: 'Adresse (Freitext)', key: 'free_text', width: 36 },
+      { header: 'PDF-Seiten', key: 'seiten', width: 11 },
+      { header: 'Hinweis', key: 'hinweis', width: 34 },
+    ];
+    ws.getRow(1).font = { bold: true };
+    ws.views = [{ state: 'frozen', ySplit: 1 }];
+
+    // Seitenzähler läuft über alle Dateien – identisch zum Zusammenfügen in merge-pdf
+    // (defekte/fehlende PDFs werden dort übersprungen und belegen keine Seiten).
+    let seite = 0;
+    let nr = 0;
+    for (const o of orders) {
+      const empf = proAuftrag.get(String(o.id)) || [];
+      const dateien = [];
+      for (const fid of dateienVon(o)) {
+        try {
+          const buf = await directus.fetchAssetBuffer(fid);
+          const src = await PDFDocument.load(buf, { ignoreEncryption: true });
+          const n = src.getPageCount();
+          dateien.push({ von: seite + 1, bis: seite + n, ok: true });
+          seite += n;
+        } catch (e) {
+          dateien.push({ ok: false });
+          console.warn(`[Charge] PDF ${fid} (Excel) übersprungen: ${e.message}`);
+        }
+      }
+      const okDateien = dateien.filter((d) => d.ok);
+      const auftragSeiten = okDateien.length ? seitenText(okDateien[0].von, okDateien[okDateien.length - 1].bis) : '';
+      const jeBrief = dateien.length > 0 && dateien.length === empf.length && okDateien.length === dateien.length;
+
+      let hinweis = '';
+      if (!dateien.length) hinweis = 'Keine Druckdatei – nicht im Sammel-PDF.';
+      else if (okDateien.length < dateien.length) hinweis = `${dateien.length - okDateien.length} PDF(s) defekt/fehlend – im Sammel-PDF übersprungen.`;
+      else if (!jeBrief) hinweis = 'Seitenbereich gilt für den ganzen Auftrag.';
+
+      const zeilen = empf.length ? empf : [{}]; // Auftrag ohne Empfänger trotzdem sichtbar
+      zeilen.forEach((e, i) => {
+        nr += 1;
+        ws.addRow({
+          nr,
+          auftrag: o.order_number || '',
+          brief: e.letter_number ?? '',
+          salutation: e.salutation || '', first_name: e.first_name || '', last_name: e.last_name || '',
+          street: e.street || '', house_no: e.house_no || '', zip: e.zip || '', city: e.city || '',
+          country: e.country || '', free_text: e.free_text || '',
+          seiten: jeBrief ? seitenText(dateien[i].von, dateien[i].bis) : auftragSeiten,
+          hinweis: empf.length ? hinweis : 'Keine Empfänger am Auftrag.',
+        });
+      });
+    }
+    ws.getColumn('free_text').alignment = { wrapText: true, vertical: 'top' };
+
+    const buf = Buffer.from(await wb.xlsx.writeBuffer());
+    res.setHeader('Content-Type', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
+    res.setHeader('Content-Disposition', 'attachment; filename="charge.xlsx"');
+    return res.status(200).send(buf);
+  } catch (err) {
+    return next(err);
+  }
+}
+
+module.exports = { mergePdf, mergeXlsx };

src/api/controllers/order-controller.js

@@ -598,6 +598,113 @@ async function registerOrder(req, res, next) {
   }
 }
 
+// ── Empfänger-Datei einlesen (XLSX/CSV) nach Spaltennamen ────────────────────
+// Spiegelt die Logik der Web-App (skrift-app/src/lib/excel.ts): feste Spalten,
+// „Zeile N" → Freitext, unbekannte Spalten → Platzhalter.
+const EMPF_SPALTEN = {
+  anrede: 'salutation', vorname: 'first_name', nachname: 'last_name', name: 'last_name',
+  strasse: 'street', 'straße': 'street', nr: 'house_no', hausnummer: 'house_no',
+  plz: 'zip', ort: 'city', stadt: 'city', land: 'country',
+};
+const normSpalte = (s) => String(s || '').trim().toLowerCase().replace(/\s+/g, '');
+
+function zelleText(v) {
+  if (v === null || v === undefined) return '';
+  if (v instanceof Date) return v.toISOString().slice(0, 10);
+  if (typeof v === 'object') {
+    if (v.text !== undefined) return String(v.text);
+    if (v.result !== undefined) return String(v.result);
+    if (v.richText) return v.richText.map((t) => t.text).join('');
+    if (v.hyperlink !== undefined) return String(v.text || v.hyperlink);
+    return '';
+  }
+  return String(v);
+}
+
+// Robuster CSV/TSV-Parser (Trenner-Erkennung, Anführungszeichen, "" = ").
+function parseCsvText(text) {
+  const erste = String(text).replace(/\r\n?/g, '\n').replace(/^/, '').split('\n')[0] || '';
+  const anz = (d) => erste.split(d).length - 1;
+  const delim = anz('\t') > 0 ? '\t' : ((anz(';') > 0 && anz(';') >= anz(',')) ? ';' : ',');
+  const s = String(text).replace(/\r\n?/g, '\n').replace(/^/, '');
+  const rows = []; let row = []; let cur = ''; let q = false;
+  for (let i = 0; i < s.length; i++) {
+    const c = s[i];
+    if (q) { if (c === '"') { if (s[i + 1] === '"') { cur += '"'; i++; } else { q = false; } } else { cur += c; } }
+    else if (c === '"') { q = true; }
+    else if (c === delim) { row.push(cur); cur = ''; }
+    else if (c === '\n') { row.push(cur); rows.push(row); row = []; cur = ''; }
+    else { cur += c; }
+  }
+  if (cur !== '' || row.length) { row.push(cur); rows.push(row); }
+  return rows.filter((r) => r.some((c) => String(c).trim() !== ''));
+}
+
+async function tabelleAusDatei(buffer, filename) {
+  const ext = String(filename || '').toLowerCase();
+  const istCsv = ext.endsWith('.csv') || ext.endsWith('.tsv') || ext.endsWith('.txt');
+  if (!istCsv) {
+    try {
+      const ExcelJS = require('exceljs');
+      const wb = new ExcelJS.Workbook();
+      await wb.xlsx.load(buffer);
+      const ws = wb.worksheets[0];
+      if (ws) {
+        const breite = ws.actualColumnCount || ws.columnCount || 0;
+        const rows = [];
+        ws.eachRow({ includeEmpty: false }, (zeile) => {
+          const a = [];
+          for (let c = 1; c <= breite; c++) a.push(zelleText(zeile.getCell(c).value));
+          rows.push(a);
+        });
+        if (rows.length) return rows;
+      }
+    } catch (e) { /* keine gültige XLSX → als CSV versuchen */ }
+  }
+  return parseCsvText(buffer.toString('utf8'));
+}
+
+/**
+ * POST /api/order/parse-recipients
+ * Body: { data_base64, filename }. Antwort: { entries, columns, count }.
+ */
+async function parseRecipients(req, res, next) {
+  try {
+    const b64 = String((req.body && req.body.data_base64) || '').replace(/^data:[^,]*,/, '');
+    const filename = (req.body && req.body.filename) || '';
+    if (!b64) return res.status(400).json({ error: 'Keine Datei übermittelt.' });
+    const buffer = Buffer.from(b64, 'base64');
+    if (!buffer.length) return res.status(400).json({ error: 'Leere Datei.' });
+
+    const tab = await tabelleAusDatei(buffer, filename);
+    if (tab.length < 2) return res.status(422).json({ error: 'Keine Datenzeilen – Datei braucht eine Kopfzeile mit Spaltennamen und mindestens einen Empfänger.' });
+
+    const kopf = tab[0].map((h) => String(h || '').trim());
+    const erkannt = new Set();
+    const entries = [];
+    for (let r = 1; r < tab.length; r++) {
+      const zellen = tab[r];
+      const e = { salutation: '', first_name: '', last_name: '', street: '', house_no: '', zip: '', city: '', country: '', free_text: '', placeholders: {} };
+      const freitextZeilen = [];
+      kopf.forEach((spalte, ci) => {
+        if (!spalte) return;
+        const wert = String(zellen[ci] ?? '').trim();
+        const zm = /^zeile\s*(\d+)$/i.exec(spalte);
+        const feld = EMPF_SPALTEN[normSpalte(spalte)];
+        if (zm) { freitextZeilen[Number(zm[1]) - 1] = wert; erkannt.add('Zeile ' + zm[1]); }
+        else if (feld) { e[feld] = wert; erkannt.add(spalte); }
+        else if (wert) { e.placeholders[spalte] = wert; erkannt.add(spalte); }
+      });
+      if (freitextZeilen.length) e.free_text = freitextZeilen.map((z) => z || '').join('\n').replace(/\n+$/, '');
+      entries.push(e);
+    }
+    return res.json({ entries, columns: [...erkannt], count: entries.length });
+  } catch (err) {
+    console.error('[Order] parseRecipients:', err);
+    return res.status(500).json({ error: 'Datei konnte nicht gelesen werden.' });
+  }
+}
+
 module.exports = {
   finalizeOrder,
   generateOrder,
@@ -605,4 +712,5 @@ module.exports = {
   uploadMotif,
   uploadOrderFile,
   registerOrder,
+  parseRecipients,
 };

src/api/routes/charge-routes.js

@@ -10,4 +10,11 @@ const { authenticateApiToken } = require('../middleware/auth');
  */
 router.post('/merge-pdf', authenticateApiToken, chargeController.mergePdf);
 
+/**
+ * POST /api/charge/merge-xlsx
+ * Excel-Export aller Adressen in derselben Reihenfolge wie merge-pdf.
+ * Body: { orderIds: (number|string)[] }
+ */
+router.post('/merge-xlsx', authenticateApiToken, chargeController.mergeXlsx);
+
 module.exports = router;

src/api/routes/order-routes.js

@@ -133,6 +133,13 @@ router.post('/files', authenticateApiToken, uploadOrderFile.single('file'), orde
  */
 router.post('/register', authenticateApiToken, orderController.registerOrder);
 
+/**
+ * POST /api/order/parse-recipients
+ * Liest eine hochgeladene Empfängerdatei (XLSX/CSV als Base64) nach Spaltennamen ein.
+ * Body: { data_base64, filename }
+ */
+router.post('/parse-recipients', authenticateApiToken, orderController.parseRecipients);
+
 /**
  * POST /api/order/from-directus
  * Generiert einen Auftrag, dessen Daten in Directus liegen.

src/lib/svg-generator.js

@@ -190,10 +190,12 @@ function generateLetterSVG(text, format, options = {}) {
     const seg = segments[si];
 
     if (seg.type === 'text') {
+      // Leerzeilen direkt an der Signatur-Grenze entfernen – sonst „fressen" die
+      // \n\n um [[signatur1]] zusätzlichen Platz. Abstand regelt NUR das spacing.
       const trimmed = seg.content.replace(/^\n+/, '').replace(/\n+$/, '');
       if (!trimmed) { si++; continue; }
       const lines = wrapTextToLinesByWidth({
-        text: seg.content,
+        text: trimmed,
         maxWidthPx,
         fontFileName: fontConfig.file,
         fontSizePx,

src/services/directus-service.js

@@ -88,6 +88,16 @@ async function fetchOrdersMinimal(ids) {
   );
 }
 
+/** Empfängerzeilen mehrerer Aufträge, je Auftrag nach Briefnummer sortiert
+ *  (dieselbe Reihenfolge wie bei der Generierung in fetchOrder). */
+async function fetchEntriesForOrders(ids) {
+  const idList = ids.map((v) => encodeURIComponent(v)).join(',');
+  return (await directusFetch(
+    `/items/order_entries?filter[order][_in]=${idList}&sort=letter_number&limit=-1` +
+    '&fields=order,letter_number,salutation,first_name,last_name,street,house_no,zip,city,country,free_text',
+  )) || [];
+}
+
 /** Lädt eine Directus-Datei (z. B. hochgeladenes Brief-PDF) als Buffer. */
 async function fetchAssetBuffer(fileId) {
   requireConfig();
@@ -129,4 +139,4 @@ async function markBatchBundled(ids, bundleName) {
   });
 }
 
-module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats, fetchOrdersMinimal, fetchAssetBuffer, fetchBatchPending, markBatchBundled };
+module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats, fetchOrdersMinimal, fetchEntriesForOrders, fetchAssetBuffer, fetchBatchPending, markBatchBundled };