diff --git a/src/api/controllers/charge-controller.js b/src/api/controllers/charge-controller.js index 166851b..3d5dcba 100644 --- a/src/api/controllers/charge-controller.js +++ b/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 }; diff --git a/src/api/routes/charge-routes.js b/src/api/routes/charge-routes.js index 9e6d829..5ec5ffe 100644 --- a/src/api/routes/charge-routes.js +++ b/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; diff --git a/src/services/directus-service.js b/src/services/directus-service.js index eb9a046..947effa 100644 --- a/src/services/directus-service.js +++ b/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 };