Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3bef26b332 | ||
|
|
94751c12ff | ||
|
|
a6eb41f996 | ||
|
|
a39ae8cffd | ||
|
|
c7fb778a8d | ||
|
|
ee8e60bb0d | ||
|
|
812f4784fd | ||
|
|
af08202981 | ||
|
|
e56a71dfdd | ||
|
|
41a3bb46a1 |
@@ -16,8 +16,10 @@
|
||||
"author": "",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"basic-ftp": "^5.0.5",
|
||||
"cors": "^2.8.5",
|
||||
"dotenv": "^16.4.5",
|
||||
"exceljs": "^4.4.0",
|
||||
"express": "^4.19.0",
|
||||
"multer": "^2.0.2",
|
||||
"pdf-lib": "^1.17.1",
|
||||
|
||||
145
src/api/controllers/batch-controller.js
Normal file
145
src/api/controllers/batch-controller.js
Normal file
@@ -0,0 +1,145 @@
|
||||
/**
|
||||
* Batch-Bündelung (alternativer Übermittlungsweg)
|
||||
* ---------------------------------------------------------------------------
|
||||
* Fasst offene batch_submissions JE ZUGANG (api_client) zusammen:
|
||||
* • xlsx im festen Schema (Firma, Vorname, Nachname, Zeile1-3, PLZ, Stadt, Land)
|
||||
* • Sammel-Druck-PDF: alle mitgelieferten Druck-PDFs 1:1 aneinandergehängt
|
||||
* und lädt beide per FTP(S) in die Wurzel des Ziel-Servers. Danach werden die
|
||||
* Datensätze als „bundled" markiert. Text-only-Datensätze (ohne PDF) bleiben
|
||||
* offen (für die manuelle Schreibvorlage/Plotter) und wandern NICHT ins Bündel.
|
||||
*
|
||||
* Ausgelöst durch: Cron (03:00 Folgetag; Sa+So gemeinsam) und den Directus-Knopf
|
||||
* (POST /api/batch/build mit client_id = sofortige Bündelung des aktuellen Stands).
|
||||
*/
|
||||
const { Readable } = require('stream');
|
||||
const { PDFDocument } = require('pdf-lib');
|
||||
const ExcelJS = require('exceljs');
|
||||
const ftp = require('basic-ftp');
|
||||
const config = require('../../config');
|
||||
const { fetchBatchPending, markBatchBundled, fetchAssetBuffer } = require('../../services/directus-service');
|
||||
|
||||
const XLSX_HEADER = ['Firma', 'Vorname', 'Nachname', 'Zeile1', 'Zeile2', 'Zeile3', 'PLZ', 'Stadt', 'Land'];
|
||||
|
||||
/** Datum/Uhrzeit in Europe/Berlin (für Cron-Fenster + Dateinamen, TZ-unabhängig). */
|
||||
function berlinParts(d = new Date()) {
|
||||
const fmt = new Intl.DateTimeFormat('en-CA', {
|
||||
timeZone: 'Europe/Berlin', year: 'numeric', month: '2-digit', day: '2-digit',
|
||||
hour: '2-digit', minute: '2-digit', weekday: 'short', hour12: false,
|
||||
});
|
||||
const p = Object.fromEntries(fmt.formatToParts(d).map((x) => [x.type, x.value]));
|
||||
return { date: `${p.year}-${p.month}-${p.day}`, hour: parseInt(p.hour, 10), minute: parseInt(p.minute, 10), weekday: p.weekday };
|
||||
}
|
||||
/** Kalendertag (Berlin) minus N Tage → YYYY-MM-DD. Mittag-UTC vermeidet DST-Sprünge. */
|
||||
function datumMinus(dateStr, tage) {
|
||||
const [y, m, d] = String(dateStr).split('-').map(Number);
|
||||
return new Date(Date.UTC(y, m - 1, d - tage, 12, 0, 0)).toISOString().slice(0, 10);
|
||||
}
|
||||
|
||||
function buildXlsx(subs) {
|
||||
const wb = new ExcelJS.Workbook();
|
||||
const ws = wb.addWorksheet('Empfaenger');
|
||||
ws.addRow(XLSX_HEADER);
|
||||
ws.getRow(1).font = { bold: true };
|
||||
for (const s of subs) {
|
||||
ws.addRow([s.firma || '', s.vorname || '', s.nachname || '', s.zeile1 || '', s.zeile2 || '',
|
||||
s.zeile3 || '', s.plz || '', s.stadt || '', s.land || '']);
|
||||
}
|
||||
ws.columns.forEach((c) => { c.width = 18; });
|
||||
return wb.xlsx.writeBuffer().then((ab) => Buffer.from(ab));
|
||||
}
|
||||
|
||||
async function buildMergedPdf(subs) {
|
||||
const merged = await PDFDocument.create();
|
||||
let seiten = 0;
|
||||
for (const s of subs) {
|
||||
if (!s.pdf_file) continue;
|
||||
try {
|
||||
const buf = await fetchAssetBuffer(s.pdf_file);
|
||||
const src = await PDFDocument.load(buf, { ignoreEncryption: true });
|
||||
const pages = await merged.copyPages(src, src.getPageIndices());
|
||||
pages.forEach((p) => merged.addPage(p));
|
||||
seiten += pages.length;
|
||||
} catch (e) {
|
||||
console.error(`[batch] PDF ${s.pdf_file} (Datensatz ${s.id}) übersprungen: ${e.message}`);
|
||||
}
|
||||
}
|
||||
return { bytes: Buffer.from(await merged.save()), seiten };
|
||||
}
|
||||
|
||||
async function ftpUpload(dateien) {
|
||||
const { host, port, user, password, secure, rejectUnauthorized } = config.ftp;
|
||||
if (!host || !user) throw new Error('FTP nicht konfiguriert (SKRIFT_FTP_HOST/USER fehlen).');
|
||||
const client = new ftp.Client(30000);
|
||||
// client.ftp.verbose = true;
|
||||
try {
|
||||
await client.access({ host, port, user, password, secure, secureOptions: { rejectUnauthorized } });
|
||||
for (const f of dateien) await client.uploadFrom(Readable.from(f.buffer), f.name);
|
||||
} finally {
|
||||
client.close();
|
||||
}
|
||||
}
|
||||
|
||||
/** Bündelt EINEN Zugang: xlsx + Sammel-PDF bauen, hochladen, Datensätze markieren. */
|
||||
async function buendleZugang(clientId, subs, label, zeitSuffix) {
|
||||
const withPdf = subs.filter((s) => s.pdf_file);
|
||||
if (!withPdf.length) return { client_id: clientId, count: 0, skipped: 'keine Druck-PDFs' };
|
||||
const basis = `${clientId}_${label}${zeitSuffix ? `_${zeitSuffix}` : ''}`;
|
||||
const xlsx = await buildXlsx(withPdf);
|
||||
const { bytes: pdf, seiten } = await buildMergedPdf(withPdf);
|
||||
await ftpUpload([
|
||||
{ name: `${basis}.xlsx`, buffer: xlsx },
|
||||
{ name: `${basis}.pdf`, buffer: pdf },
|
||||
]);
|
||||
await markBatchBundled(withPdf.map((s) => s.id), basis);
|
||||
console.log(`[batch] Zugang ${clientId}: ${withPdf.length} Datensätze / ${seiten} PDF-Seiten → ${basis}.{xlsx,pdf} hochgeladen.`);
|
||||
return { client_id: clientId, count: withPdf.length, pages: seiten, file: basis };
|
||||
}
|
||||
|
||||
/** Bündelt alle offenen Datensätze (optional nur ein Zugang), gruppiert je Zugang. */
|
||||
async function buendleAlle({ clientId = null, ids = null, label, zeitSuffix = '' }) {
|
||||
const alle = await fetchBatchPending(clientId, ids);
|
||||
const proZugang = new Map();
|
||||
for (const s of alle) {
|
||||
const k = String(s.api_client);
|
||||
if (!proZugang.has(k)) proZugang.set(k, []);
|
||||
proZugang.get(k).push(s);
|
||||
}
|
||||
const ergebnis = [];
|
||||
for (const [k, subs] of proZugang) {
|
||||
try { ergebnis.push(await buendleZugang(k, subs, label, zeitSuffix)); }
|
||||
catch (e) { console.error(`[batch] Zugang ${k} fehlgeschlagen: ${e.message}`); ergebnis.push({ client_id: k, error: e.message }); }
|
||||
}
|
||||
return ergebnis;
|
||||
}
|
||||
|
||||
/** HTTP: POST /api/batch/build { client_id?, label?, time_suffix? }
|
||||
* Ohne client_id → alle Zugänge (wie der Cron). label default = heute (Berlin). */
|
||||
async function buildBundles(req, res) {
|
||||
try {
|
||||
const clientId = (req.body && req.body.client_id != null && String(req.body.client_id).trim()) ? String(req.body.client_id).trim() : null;
|
||||
const ids = (req.body && Array.isArray(req.body.ids) && req.body.ids.length) ? req.body.ids : null;
|
||||
const label = (req.body && req.body.label) ? String(req.body.label) : berlinParts().date;
|
||||
// Manuelle Bündelung mit Uhrzeit-Suffix, damit sie den Cron-Tageslauf (nur Datum) nicht überschreibt.
|
||||
const zeitSuffix = (req.body && req.body.time_suffix !== undefined)
|
||||
? String(req.body.time_suffix)
|
||||
: `${String(berlinParts().hour).padStart(2, '0')}${String(berlinParts().minute).padStart(2, '0')}`;
|
||||
const ergebnis = await buendleAlle({ clientId, ids, label, zeitSuffix });
|
||||
return res.json({ ok: true, bundles: ergebnis });
|
||||
} catch (err) {
|
||||
console.error('[batch] build fehlgeschlagen:', err);
|
||||
return res.status(500).json({ error: 'Batch-Bündelung fehlgeschlagen', message: err.message });
|
||||
}
|
||||
}
|
||||
|
||||
/** Cron-Lauf: alle Zugänge, Label = Vortag (Berlin). Sa+So gemeinsam am Montag,
|
||||
* Sonntag 03:00 wird übersprungen (Samstag wartet auf den Montagslauf). */
|
||||
async function runScheduledBatch() {
|
||||
const { date, weekday } = berlinParts();
|
||||
if (weekday === 'Sun') { console.log('[batch-cron] Sonntag – Samstag wird am Montag mit Sonntag gebündelt, kein Lauf.'); return; }
|
||||
const label = datumMinus(date, 1); // Vortag (bei Montag = Sonntag; deckt Sa+So ab)
|
||||
console.log(`[batch-cron] Start Tageslauf, Label ${label} (${weekday}).`);
|
||||
const ergebnis = await buendleAlle({ label, zeitSuffix: '' });
|
||||
console.log(`[batch-cron] fertig: ${ergebnis.length} Zugang/Zugänge verarbeitet.`);
|
||||
}
|
||||
|
||||
module.exports = { buildBundles, runScheduledBatch, berlinParts };
|
||||
@@ -32,6 +32,8 @@ function addressText(entry) {
|
||||
|
||||
/** Platzhalterwerte einer Zeile (strukturierte Felder + freie Platzhalter). */
|
||||
function placeholdersOf(entry) {
|
||||
// Die 5 Adresszeilen (5-Zeilen-Modus) auch als [[Zeile1]]..[[Zeile5]] verfügbar.
|
||||
const zeilen = String(entry.free_text || '').split('\n');
|
||||
return {
|
||||
Anrede: entry.salutation || '',
|
||||
Vorname: entry.first_name || '',
|
||||
@@ -41,6 +43,8 @@ function placeholdersOf(entry) {
|
||||
Ort: entry.city || '',
|
||||
Land: entry.country || '',
|
||||
Briefnummer: entry.letter_number ?? '',
|
||||
Zeile1: zeilen[0] || '', Zeile2: zeilen[1] || '', Zeile3: zeilen[2] || '',
|
||||
Zeile4: zeilen[3] || '', Zeile5: zeilen[4] || '',
|
||||
...(entry.placeholders && typeof entry.placeholders === 'object' ? entry.placeholders : {}),
|
||||
};
|
||||
}
|
||||
@@ -86,7 +90,8 @@ function buildDocuments(order, entries) {
|
||||
const briefText = (entry.text && String(entry.text).trim()) ? entry.text : (order.text_template || '');
|
||||
|
||||
// Postkarte: EIN Dokument mit Text + Absender + Empfänger (über Marker getrennt).
|
||||
if (istPostkarte) {
|
||||
// Ohne Brieftext KEINE Karte erzeugen – dann wird (falls gewünscht) nur das Kuvert erzeugt.
|
||||
if (istPostkarte && String(briefText).trim()) {
|
||||
const recip = addressText(entry);
|
||||
const sender = order.envelope_sender ? String(order.envelope_sender).trim() : '';
|
||||
let combined = String(briefText || '');
|
||||
@@ -94,7 +99,7 @@ function buildDocuments(order, entries) {
|
||||
if (recip) combined += `[[pk_adr]]${recip}`;
|
||||
documents.push({
|
||||
index: nr, type: 'postcard', text: combined, format: letterFormat, font,
|
||||
placeholders, fontScale: fontScaleLetter, realisticHandwriting: realistisch,
|
||||
placeholders, fontScale: fontScaleLetter, fontScaleEnv, realisticHandwriting: realistisch,
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -336,7 +336,7 @@ async function runGeneration({ orderNumber, letters, metadata }) {
|
||||
} else if (isPostcard) {
|
||||
svgResult = generatePostcardSVG(
|
||||
scriptalizedText, letter.format,
|
||||
{ font: letter.font, realisticHandwriting: letter.realisticHandwriting ?? false, fontScale: letter.fontScale, senderScale: metadata.envelopeSenderScale || 1 }
|
||||
{ font: letter.font, realisticHandwriting: letter.realisticHandwriting ?? false, fontScale: letter.fontScale, senderScale: metadata.envelopeSenderScale || 1, recipientScale: letter.fontScaleEnv || 1 }
|
||||
);
|
||||
} else {
|
||||
svgResult = generateLetterSVG(
|
||||
|
||||
@@ -181,7 +181,7 @@ async function generateBatch(req, res, next) {
|
||||
} else if (letter.type === "postcard") {
|
||||
const svgResult = generatePostcardSVG(scriptalizedText, letter.format, {
|
||||
font: letter.font, realisticHandwriting: letter.realisticHandwriting ?? false,
|
||||
fontScale: letter.fontScale, senderScale: letter.senderScale || 1,
|
||||
fontScale: letter.fontScale, senderScale: letter.senderScale || 1, recipientScale: letter.recipientScale || 1,
|
||||
});
|
||||
if (svgResult.overflow) hasOverflow = true;
|
||||
const filename = `letter_${pad}.svg`;
|
||||
|
||||
14
src/api/routes/batch-routes.js
Normal file
14
src/api/routes/batch-routes.js
Normal file
@@ -0,0 +1,14 @@
|
||||
const express = require('express');
|
||||
const router = express.Router();
|
||||
const { authenticateApiToken } = require('../middleware/auth');
|
||||
const batchController = require('../controllers/batch-controller');
|
||||
|
||||
/**
|
||||
* POST /api/batch/build
|
||||
* Bündelt offene batch_submissions (xlsx + Sammel-Druck-PDF) und lädt sie per FTP
|
||||
* hoch. Body: { client_id?, label?, time_suffix? }. Ohne client_id → alle Zugänge.
|
||||
* Wird vom Directus-Knopf (ein Zugang, sofort) und intern vom Cron genutzt.
|
||||
*/
|
||||
router.post('/build', authenticateApiToken, batchController.buildBundles);
|
||||
|
||||
module.exports = router;
|
||||
@@ -55,5 +55,24 @@ module.exports = {
|
||||
clientSecret: process.env.PAYPAL_CLIENT_SECRET || '',
|
||||
// 'sandbox' oder 'live'
|
||||
environment: process.env.PAYPAL_ENVIRONMENT || 'sandbox'
|
||||
}
|
||||
},
|
||||
|
||||
// Alternativer Übermittlungsweg (batch_submissions): Ziel-FTP für die täglichen
|
||||
// Bündel (xlsx + Sammel-Druck-PDF). Passwort NUR über ENV.
|
||||
// envClean entfernt versehentliche umschließende Anführungszeichen und CR/LF
|
||||
// (häufige .env-Fallen unter Windows/docker env_file), die sonst zu „530
|
||||
// Login incorrect" führen, obwohl die Daten korrekt sind.
|
||||
ftp: (() => {
|
||||
const envClean = (v) => String(v || '').replace(/[\r\n]+/g, '').replace(/^(['"])([\s\S]*)\1$/, '$2');
|
||||
return {
|
||||
host: envClean(process.env.SKRIFT_FTP_HOST),
|
||||
port: parseInt(process.env.SKRIFT_FTP_PORT, 10) || 21,
|
||||
user: envClean(process.env.SKRIFT_FTP_USER),
|
||||
password: envClean(process.env.SKRIFT_FTP_PASSWORD),
|
||||
// explizites FTP über TLS (wie im FTP-Client eingestellt). 'false' schaltet ab.
|
||||
secure: String(process.env.SKRIFT_FTP_SECURE || 'true').toLowerCase() !== 'false',
|
||||
// Selbstsigniertes Zertifikat zulassen (viele FTP-Server) – auf 'false' setzen für strikte Prüfung.
|
||||
rejectUnauthorized: String(process.env.SKRIFT_FTP_REJECT_UNAUTHORIZED || 'false').toLowerCase() === 'true',
|
||||
};
|
||||
})(),
|
||||
};
|
||||
|
||||
@@ -437,18 +437,25 @@ function splitPostcardText(text) {
|
||||
}
|
||||
|
||||
/**
|
||||
* Postkarte (einseitig): Text auf der LINKEN Hälfte, Absender + Empfänger auf der
|
||||
* RECHTEN Hälfte, Briefmarkenfeld (leerer Bereich) oben rechts. Für A6/DIN-lang-
|
||||
* Postkarten – ein SVG je Karte (ein Plotter-Durchlauf). Der Text kommt bereits
|
||||
* scriptalisiert an und enthält die Marker [[pk_abs]] / [[pk_adr]].
|
||||
* Postkarte (einseitig) nach dem Plotter-Maßblatt (Dialogpost A6, Ursprung oben
|
||||
* links, Maße in mm):
|
||||
* • Absender: x 2–72, y 2–12 (2 Zeilen, klein)
|
||||
* • Text: x 2–72, y 14–40 (oben, schmal, links neben der Frankierzone)
|
||||
* und x 2–81,4, y 40–88 (unten, breiter) – L-förmiger Textfluss
|
||||
* • Empfänger: x 86,6–146, y 42–88 (sicheres Adressfeld)
|
||||
* • Trennstrich: x 84, y 42–88, Breite 1,2 mm
|
||||
* • FREI: Frankierzone (x 74–148, y 0–40) und Codierzone (y 90–105)
|
||||
* Andere Kartengrößen: Zonen an W/H verankert (Adresse rechts, Text links,
|
||||
* Frankierzone rechts oben, Codierzone unten frei). Text kommt scriptalisiert
|
||||
* mit den Markern [[pk_abs]] / [[pk_adr]].
|
||||
*/
|
||||
function generatePostcardSVG(text, format, options = {}) {
|
||||
const fontKey = normalizeFontKey(options.font);
|
||||
const fontConfig = SVG_FONT_CONFIG[fontKey];
|
||||
const fontFile = SVG_FONT_CONFIG[fontKey].file;
|
||||
const realistic = options.realisticHandwriting ?? false;
|
||||
|
||||
const { widthPx, heightPx, widthMm, heightMm } = getPageDimensions(format);
|
||||
const { marginTopPx, marginLeftPx, lineHeightPx: baseLineHeightPx } = getLayoutForFormat(format);
|
||||
const { widthPx, heightPx, widthMm: W, heightMm: H } = getPageDimensions(format);
|
||||
const { lineHeightPx: baseLineHeightPx } = getLayoutForFormat(format);
|
||||
|
||||
const { body, sender, recipient } = splitPostcardText(text);
|
||||
|
||||
@@ -456,50 +463,98 @@ function generatePostcardSVG(text, format, options = {}) {
|
||||
const fontSizePx = FONT_SIZE_PX * fontScale;
|
||||
const lineHeightPx = baseLineHeightPx * fontScale;
|
||||
|
||||
// Zonen: linke Hälfte Text, rechte Hälfte Adresse; Briefmarke oben rechts frei.
|
||||
const textLeft = marginLeftPx;
|
||||
const textRight = widthPx * 0.48;
|
||||
const textWidth = Math.max(mmToPx(30), textRight - textLeft);
|
||||
const addrLeft = widthPx * 0.52;
|
||||
const addrRight = widthPx - mmToPx(RAND_RECHTS_MM);
|
||||
const addrWidth = Math.max(mmToPx(30), addrRight - addrLeft);
|
||||
const stampW = mmToPx(25);
|
||||
const stampX = widthPx - mmToPx(6) - stampW;
|
||||
// Zonen in mm (Maßblatt), für andere Größen an den Rändern verankert.
|
||||
const maxYmm = H - 17; // Codierzone (unten 15 mm) frei → A6: 88
|
||||
const frankBottomMm = 40; // Frankierzone-Unterkante (Briefmarke)
|
||||
const frankLeftMm = W - 74; // Frankierzone links → A6: 74
|
||||
const addrRightMm = W - 2; // A6: 146
|
||||
const addrLeftMm = addrRightMm - 59.4; // A6: 86,6
|
||||
const addrTopMm = 42;
|
||||
const textLeftMm = 2;
|
||||
const textUpperRightMm = frankLeftMm - 2; // A6: 72
|
||||
const textLowerRightMm = addrLeftMm - 5.2; // A6: 81,4
|
||||
const trennXmm = (textLowerRightMm + addrLeftMm) / 2; // A6: 84
|
||||
|
||||
const paths = [];
|
||||
let bodyLineCount = 0;
|
||||
let bodyLineLimit = 1;
|
||||
let overflow = false;
|
||||
|
||||
// Text links.
|
||||
if (body) {
|
||||
const bodyLines = wrapTextToLinesByWidth({ text: body, maxWidthPx: textWidth, fontFileName: fontConfig.file, fontSizePx });
|
||||
bodyLineCount = bodyLines.length;
|
||||
paths.push(...layoutTextToPaths({
|
||||
lines: bodyLines, fontFileName: fontConfig.file, fontSizePx,
|
||||
startX: textLeft, startY: marginTopPx + fontSizePx, lineHeightPx, realisticHandwriting: realistic,
|
||||
}));
|
||||
// Variabler (L-förmiger) Textfluss: oben schmal (bis Frankierzone), unten breit.
|
||||
const breiteBeiY = (yPx) => (yPx < mmToPx(frankBottomMm)
|
||||
? mmToPx(textUpperRightMm - textLeftMm)
|
||||
: mmToPx(textLowerRightMm - textLeftMm));
|
||||
function flowVariabel(txt, size, baseline0, lh) {
|
||||
const paras = String(txt).split(/\r?\n/);
|
||||
const out = [];
|
||||
let y = baseline0;
|
||||
for (const para of paras) {
|
||||
const words = para.split(/\s+/).filter(Boolean);
|
||||
if (!words.length) { out.push(''); y += lh; continue; }
|
||||
let cur = '';
|
||||
for (const w of words) {
|
||||
const test = cur ? cur + ' ' + w : w;
|
||||
const wpx = measureTextWidthPx({ text: test, fontFileName: fontFile, fontSizePx: size });
|
||||
if (cur && wpx > breiteBeiY(y)) { out.push(cur); y += lh; cur = w; } else cur = test;
|
||||
}
|
||||
if (cur !== '') { out.push(cur); y += lh; }
|
||||
}
|
||||
return out;
|
||||
}
|
||||
|
||||
// Absender klein oben in der Adresszone, links neben dem Briefmarkenfeld.
|
||||
// Absender oben links – ZUERST, damit der Text knapp darunter beginnen kann.
|
||||
// Größe folgt der „Absender-Größe" aus dem manuellen Druck (options.senderScale).
|
||||
let senderBottomPx = mmToPx(2);
|
||||
if (sender) {
|
||||
const senderScale = Math.max(0.5, Math.min(2, Number(options.senderScale) || 1));
|
||||
const senderSize = FONT_SIZE_PX * 0.7 * senderScale;
|
||||
const senderLH = lineHeightPx * (senderSize / fontSizePx);
|
||||
const senderWidth = Math.max(mmToPx(30), Math.min(addrWidth, stampX - addrLeft - mmToPx(3)));
|
||||
const senderLines = wrapTextToLinesByWidth({ text: sender, maxWidthPx: senderWidth, fontFileName: fontConfig.file, fontSizePx: senderSize });
|
||||
const senderScale = Math.max(0.5, Math.min(1.8, Number(options.senderScale) || 1));
|
||||
const senderSize = FONT_SIZE_PX * 0.55 * senderScale;
|
||||
const senderLH = (baseLineHeightPx / FONT_SIZE_PX) * senderSize;
|
||||
const senderLines = wrapTextToLinesByWidth({ text: sender, maxWidthPx: mmToPx(textUpperRightMm - textLeftMm), fontFileName: fontFile, fontSizePx: senderSize }).slice(0, 2);
|
||||
const senderStartY = mmToPx(2) + senderSize;
|
||||
paths.push(...layoutTextToPaths({
|
||||
lines: senderLines, fontFileName: fontConfig.file, fontSizePx: senderSize,
|
||||
startX: addrLeft, startY: mmToPx(8) + senderSize, lineHeightPx: senderLH, realisticHandwriting: realistic,
|
||||
lines: senderLines, fontFileName: fontFile, fontSizePx: senderSize,
|
||||
startX: mmToPx(textLeftMm), startY: senderStartY, lineHeightPx: senderLH, realisticHandwriting: realistic,
|
||||
}));
|
||||
senderBottomPx = senderStartY + Math.max(0, senderLines.length - 1) * senderLH + senderSize * 0.3;
|
||||
}
|
||||
|
||||
// Text links (L-förmig). Beginn nur ETWAS unter dem Absender (≈2 mm); ohne
|
||||
// Absender wie im Maßblatt bei y≈14 mm. Nur DER Text kann „zu lang" sein.
|
||||
const baseline0 = (sender ? senderBottomPx + mmToPx(2) : mmToPx(14)) + fontSizePx;
|
||||
bodyLineLimit = Math.max(1, Math.floor((mmToPx(maxYmm) - baseline0) / lineHeightPx) + 1);
|
||||
if (body) {
|
||||
const bodyLines = flowVariabel(body, fontSizePx, baseline0, lineHeightPx);
|
||||
bodyLineCount = bodyLines.length;
|
||||
if (bodyLineCount > bodyLineLimit) overflow = true;
|
||||
paths.push(...layoutTextToPaths({
|
||||
lines: bodyLines, fontFileName: fontFile, fontSizePx,
|
||||
startX: mmToPx(textLeftMm), startY: baseline0, lineHeightPx, realisticHandwriting: realistic,
|
||||
}));
|
||||
}
|
||||
|
||||
// Empfänger in der unteren Hälfte der Adresszone (klassische Anschriftzone).
|
||||
// Empfänger im sicheren Adressfeld (rechts unten). Größe folgt der „Schriftgröße
|
||||
// Kuvert" (options.recipientScale). Passt der Block nicht in die 46-mm-Zone, wird
|
||||
// er automatisch verkleinert – so bleibt die Codierzone IMMER frei.
|
||||
if (recipient) {
|
||||
const recLines = wrapTextToLinesByWidth({ text: recipient, maxWidthPx: addrWidth, fontFileName: fontConfig.file, fontSizePx });
|
||||
const recBottom = heightPx * 0.90;
|
||||
const recStartY = recBottom - Math.max(0, recLines.length - 1) * lineHeightPx;
|
||||
const feldOben = mmToPx(addrTopMm);
|
||||
const feldUnten = mmToPx(maxYmm);
|
||||
const feldBreite = mmToPx(addrRightMm - addrLeftMm);
|
||||
const recScale = Math.max(0.6, Math.min(1.6, Number(options.recipientScale) || 1));
|
||||
const recBaseSize = FONT_SIZE_PX * recScale;
|
||||
const recBaseLH = baseLineHeightPx * recScale;
|
||||
let recSize = recBaseSize;
|
||||
let recLH = recBaseLH;
|
||||
let recLines = [];
|
||||
for (const scale of [1, 0.9, 0.8, 0.72, 0.65, 0.6]) {
|
||||
recSize = recBaseSize * scale;
|
||||
recLH = recBaseLH * scale;
|
||||
recLines = wrapTextToLinesByWidth({ text: recipient, maxWidthPx: feldBreite, fontFileName: fontFile, fontSizePx: recSize });
|
||||
const blockUnten = feldOben + recSize + Math.max(0, recLines.length - 1) * recLH + recSize * 0.3;
|
||||
if (blockUnten <= feldUnten) break;
|
||||
}
|
||||
paths.push(...layoutTextToPaths({
|
||||
lines: recLines, fontFileName: fontConfig.file, fontSizePx,
|
||||
startX: addrLeft, startY: recStartY, lineHeightPx, realisticHandwriting: realistic,
|
||||
lines: recLines, fontFileName: fontFile, fontSizePx: recSize,
|
||||
startX: mmToPx(addrLeftMm), startY: feldOben + recSize, lineHeightPx: recLH, realisticHandwriting: realistic,
|
||||
}));
|
||||
}
|
||||
|
||||
@@ -515,18 +570,20 @@ function generatePostcardSVG(text, format, options = {}) {
|
||||
/>`)
|
||||
.join('\n ');
|
||||
|
||||
// Trennstrich: einfache Kugelschreiber-Linie (Single-Stroke, keine Füllung) –
|
||||
// gleiche Strichstärke wie die Handschrift, damit die Ballpoint-Optik greift.
|
||||
const trennstrich = `<path d="M ${mmToPx(trennXmm).toFixed(1)} ${mmToPx(addrTopMm).toFixed(1)} L ${mmToPx(trennXmm).toFixed(1)} ${mmToPx(maxYmm).toFixed(1)}" stroke="#000000" stroke-width="0.6" fill="none" stroke-linecap="round" vector-effect="non-scaling-stroke"/>`;
|
||||
|
||||
const svg = `<svg xmlns="http://www.w3.org/2000/svg"
|
||||
width="${widthMm}mm"
|
||||
height="${heightMm}mm"
|
||||
width="${W}mm"
|
||||
height="${H}mm"
|
||||
viewBox="0 0 ${widthPx} ${heightPx}">
|
||||
<rect x="0" y="0" width="${widthPx}" height="${heightPx}" fill="#FFFFFF" />
|
||||
${trennstrich}
|
||||
${pathElements}
|
||||
</svg>`;
|
||||
|
||||
// Überlauf: passt der Text in die linke Hälfte (Höhe)?
|
||||
const available = heightPx - (marginTopPx + fontSizePx) - fontSizePx * 0.5;
|
||||
const lineLimit = Math.max(1, Math.floor(available / lineHeightPx) + 1);
|
||||
return { svg: svg.trim(), overflow: bodyLineCount > lineLimit, lineCount: bodyLineCount, lineLimit };
|
||||
return { svg: svg.trim(), overflow, lineCount: bodyLineCount, lineLimit: bodyLineLimit };
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -5,7 +5,9 @@ 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 batchRoutes = require('./api/routes/batch-routes');
|
||||
const healthRoutes = require('./api/routes/health-routes');
|
||||
const { runScheduledBatch, berlinParts } = require('./api/controllers/batch-controller');
|
||||
|
||||
const errorHandler = require('./api/middleware/error-handler');
|
||||
const requestLogger = require('./api/middleware/request-logger');
|
||||
@@ -49,6 +51,7 @@ app.use('/health', healthRoutes);
|
||||
app.use('/api/preview', previewRoutes);
|
||||
app.use('/api/order', orderRoutes);
|
||||
app.use('/api/charge', chargeRoutes);
|
||||
app.use('/api/batch', batchRoutes);
|
||||
|
||||
// Format-Cache manuell auffrischen (Token-geschützt) – für „sofort übernehmen".
|
||||
app.post('/api/formats/refresh', async (req, res) => {
|
||||
@@ -80,6 +83,22 @@ app.listen(config.port, () => {
|
||||
// Formate initial laden und stündlich auffrischen (zentral aus Directus).
|
||||
refreshRenderFormats();
|
||||
setInterval(refreshRenderFormats, 60 * 60 * 1000);
|
||||
|
||||
// Batch-FTP-Bündelung nur, wenn ausdrücklich aktiviert (Standardweg ist die
|
||||
// Übernahme in die Produktion, nicht FTP). SKRIFT_BATCH_FTP_CRON=true schaltet
|
||||
// den täglichen 03:00-Lauf (Europe/Berlin) wieder ein; Sa+So am Montag.
|
||||
if (String(process.env.SKRIFT_BATCH_FTP_CRON || '').toLowerCase() === 'true') {
|
||||
let letzterBatchTag = null;
|
||||
setInterval(() => {
|
||||
try {
|
||||
const { date, hour } = berlinParts();
|
||||
if (hour !== 3 || letzterBatchTag === date) return;
|
||||
letzterBatchTag = date;
|
||||
runScheduledBatch().catch((e) => console.error('[batch-cron] Fehler:', e.message));
|
||||
} catch (e) { console.error('[batch-cron] Tick-Fehler:', e.message); }
|
||||
}, 60 * 1000);
|
||||
console.log('Batch-FTP-Cron: aktiv (03:00 Europe/Berlin)');
|
||||
}
|
||||
});
|
||||
|
||||
// Graceful shutdown
|
||||
|
||||
@@ -110,4 +110,23 @@ async function fetchRenderFormats() {
|
||||
);
|
||||
}
|
||||
|
||||
module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats, fetchOrdersMinimal, fetchAssetBuffer };
|
||||
/** Offene (pending) Batch-Übermittlungen MIT Druck-PDF, optional je Zugang.
|
||||
* Text-only-Datensätze (ohne PDF) werden bewusst NICHT gebündelt. */
|
||||
async function fetchBatchPending(clientId, ids) {
|
||||
let filter = 'filter[status][_eq]=pending&filter[pdf_file][_nnull]=true';
|
||||
if (clientId != null) filter += `&filter[api_client][_eq]=${encodeURIComponent(clientId)}`;
|
||||
if (Array.isArray(ids) && ids.length) filter += `&filter[id][_in]=${ids.map(encodeURIComponent).join(',')}`;
|
||||
const fields = 'id,api_client,firma,vorname,nachname,zeile1,zeile2,zeile3,plz,stadt,land,pdf_file';
|
||||
return (await directusFetch(`/items/batch_submissions?${filter}&sort=date_created&limit=-1&fields=${fields}`)) || [];
|
||||
}
|
||||
|
||||
/** Markiert Datensätze als gebündelt (nach erfolgreichem FTP-Upload). */
|
||||
async function markBatchBundled(ids, bundleName) {
|
||||
if (!ids || !ids.length) return;
|
||||
return directusFetch('/items/batch_submissions', {
|
||||
method: 'PATCH',
|
||||
body: JSON.stringify({ keys: ids, data: { status: 'bundled', bundle_name: bundleName, bundled_at: new Date().toISOString() } }),
|
||||
});
|
||||
}
|
||||
|
||||
module.exports = { fetchOrder, updateOrder, addStatusHistory, fetchRenderFormats, fetchOrdersMinimal, fetchAssetBuffer, fetchBatchPending, markBatchBundled };
|
||||
|
||||
Reference in New Issue
Block a user