Kontakt-CRM, Chargen-Sammeldruck, API-Status & Auto-Generierung

Kontakte/CRM (Directus):
- Neue Collections `contacts` (Leads) + `contact_actions` (Rückruf/Angebot/Mail).
- Hook `skrift-contacts`: Kontakte werden nur auf Anforderung angelegt
  (Auftrag "In Kontakte speichern"); Rückruf-Erinnerung (Zeitplan) und
  Angebots-/Mail-an-mich-Mails; Auto-Löschung nur bei Lead-Status
  "kein_interesse" nach 30 Tagen; optionaler DSGVO-Strip (per Env, Dry-Run).
- Modul `skrift-kontakte`: handytaugliches Board (Anruf via groundwire:,
  Notizen mit Autosave, Durchblättern, CSV-Export, Aktionen als Buttons).

API-Chargen & PDF-Sammeldruck:
- Produktions-Board gruppiert API-Aufträge unter "Neu" zu Chargen
  (Kunde + Typ + Versandtag + Eingangstag), aufklappbar, mit "fällig bis"
  (Versandtag der übernächsten Woche).
- Mehrfachauswahl -> Sammel-PDF (Backend `pdf-lib`, /api/charge/merge-pdf,
  Directus-Proxy /skrift-orders/charge/pdf), Kuverts an Plotter und
  Sammel-Status; PDF- und Kuvert-Reihenfolge nach Auftragsnummer (Kollation).
- Mailer: keine Einzelmail je API-Auftrag mehr, stattdessen Tagesübersicht
  (18:00) pro Kunde, nach Versandtag aufgeschlüsselt.

Status-API & Generierung:
- Public-API-Status liest jetzt production_status (Board) statt nur
  kaufmännischem Status; neues Feld `status_since` in der Antwort.
- Auftrag stempelt `production_status_changed_at` bei jedem Statuswechsel.
- Generierung wird IMMER beim Eingang angestoßen (auch Datei-Produkte mit
  handgeschriebenem Kuvert), nicht nur bei letter/postcard.
- Versandtag im Produktionsdashboard sichtbar.

Rechte: Service-Rolle darf directus_files lesen (Backend lädt PDFs für den
Sammeldruck über /assets).

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

Docker/skrift-backend/package.json

@@ -20,6 +20,7 @@
     "dotenv": "^16.4.5",
     "express": "^4.19.0",
     "multer": "^2.0.2",
+    "pdf-lib": "^1.17.1",
     "uuid": "^9.0.1",
     "xml2js": "^0.6.2"
   },

Docker/skrift-backend/src/api/controllers/charge-controller.js

@@ -0,0 +1,69 @@
+/**
+ * Charge-Controller – Sammel-PDF für API-Chargen.
+ *
+ * Führt die hochgeladenen Brief-PDFs mehrerer Aufträge (Datei-Produkte, z. B.
+ * 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.
+ */
+const { PDFDocument } = require('pdf-lib');
+const directus = require('../../services/directus-service');
+
+/**
+ * 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.' });
+    }
+
+    // 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);
+    }
+    if (!fileIds.length) {
+      return res.status(400).json({ error: 'No files', message: 'Keine Druckdateien an den Aufträgen.' });
+    }
+
+    const merged = await PDFDocument.create();
+    let ok = 0;
+    const skipped = [];
+    for (const fid of fileIds) {
+      try {
+        const buf = await directus.fetchAssetBuffer(fid);
+        const src = await PDFDocument.load(buf, { ignoreEncryption: true });
+        const pages = await merged.copyPages(src, src.getPageIndices());
+        pages.forEach((p) => merged.addPage(p));
+        ok += 1;
+      } catch (e) {
+        skipped.push(fid);
+        console.warn(`[Charge] PDF ${fid} übersprungen: ${e.message}`);
+      }
+    }
+    if (!ok) {
+      return res.status(400).json({ error: 'Merge failed', message: 'Keine gültige PDF-Datei gefunden.' });
+    }
+
+    const bytes = await merged.save();
+    res.setHeader('Content-Type', 'application/pdf');
+    res.setHeader('Content-Disposition', 'attachment; filename="charge.pdf"');
+    res.setHeader('X-Skrift-Merged', String(ok));
+    if (skipped.length) res.setHeader('X-Skrift-Skipped', String(skipped.length));
+    return res.status(200).send(Buffer.from(bytes));
+  } catch (err) {
+    return next(err);
+  }
+}
+
+module.exports = { mergePdf };

Docker/skrift-backend/src/api/routes/charge-routes.js

@@ -0,0 +1,13 @@
+const express = require('express');
+const router = express.Router();
+const chargeController = require('../controllers/charge-controller');
+const { authenticateApiToken } = require('../middleware/auth');
+
+/**
+ * POST /api/charge/merge-pdf
+ * Führt die Brief-PDFs mehrerer Aufträge zu einer PDF zusammen (Sammeldruck).
+ * Body: { orderIds: (number|string)[] }
+ */
+router.post('/merge-pdf', authenticateApiToken, chargeController.mergePdf);
+
+module.exports = router;

Docker/skrift-backend/src/server.js

@@ -4,6 +4,7 @@ const config = require('./config');
 
 const previewRoutes = require('./api/routes/preview-routes');
 const orderRoutes = require('./api/routes/order-routes');
+const chargeRoutes = require('./api/routes/charge-routes');
 const healthRoutes = require('./api/routes/health-routes');
 
 const errorHandler = require('./api/middleware/error-handler');
@@ -46,6 +47,7 @@ app.use(requestLogger);
 app.use('/health', healthRoutes);
 app.use('/api/preview', previewRoutes);
 app.use('/api/order', orderRoutes);
+app.use('/api/charge', chargeRoutes);
 
 // Format-Cache manuell auffrischen (Token-geschützt) – für „sofort übernehmen".
 app.post('/api/formats/refresh', async (req, res) => {

Docker/skrift-backend/src/services/directus-service.js

@@ -78,6 +78,30 @@ async function addStatusHistory(orderId, status, note) {
   });
 }
 
+/** Lädt mehrere Aufträge (nur die für den Charge-Sammeldruck nötigen Felder),
+ *  sortiert nach Auftragsnummer. */
+async function fetchOrdersMinimal(ids) {
+  const idList = ids.map((v) => encodeURIComponent(v)).join(',');
+  return directusFetch(
+    `/items/orders?filter[id][_in]=${idList}&limit=-1&sort=order_number` +
+    '&fields=id,order_number,source_files,source_file',
+  );
+}
+
+/** Lädt eine Directus-Datei (z. B. hochgeladenes Brief-PDF) als Buffer. */
+async function fetchAssetBuffer(fileId) {
+  requireConfig();
+  const res = await fetch(config.directus.url.replace(/\/$/, '') + '/assets/' + encodeURIComponent(fileId), {
+    headers: { Authorization: `Bearer ${config.directus.token}` },
+  });
+  if (!res.ok) {
+    const e = new Error(`Directus asset ${fileId}: ${res.status}`);
+    e.status = res.status === 404 ? 404 : 502;
+    throw e;
+  }
+  return Buffer.from(await res.arrayBuffer());
+}
+
 /** Zentrale Format-Definitionen (Seitengröße, Ränder, Zeilenlimit) aus Directus. */
 async function fetchRenderFormats() {
   return directusFetch(
@@ -86,4 +110,4 @@ async function fetchRenderFormats() {
   );
 }
 
-module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats };
+module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats, fetchOrdersMinimal, fetchAssetBuffer };