From f7650fe88325830c406046a92d96fe3059b8021c Mon Sep 17 00:00:00 2001 From: Kenso Grimm Date: Wed, 7 Oct 2026 13:55:56 +0000 Subject: [PATCH] Buchungskalender: Storno und Buchung idempotent bei Teilfehlern Co-Authored-By: Claude Opus 5.5 --- server/services/unterkunft/ablauf.js | 38 ++++++++++--- server/services/unterkunft/rechnungen.js | 2 +- server/services/unterkunft/speicher.js | 6 +++ server/services/unterkunft/zahlung.js | 2 +- test/unterkunftAblauf.test.js | 69 +++++++++++++++++++++++- 5 files changed, 106 insertions(+), 11 deletions(-) diff --git a/server/services/unterkunft/ablauf.js b/server/services/unterkunft/ablauf.js index 39a8f00..b434860 100644 --- a/server/services/unterkunft/ablauf.js +++ b/server/services/unterkunft/ablauf.js @@ -8,7 +8,7 @@ import { UkFehler } from './fehler.js' import * as mails from './mails.js' import { berechnePreis, preiseVollstaendig, pruefePosten, summiere } from './preis.js' import { stelleAus } from './rechnungen.js' -import { aktualisiereAnfrage, ladeAnfrage, ladeEinstellungen, ladePreise, ladeRechnung, ladeUnterkunft, legeAnfrageDokAn, listeAnfragen, listeAnfragenAlle } from './speicher.js' +import { aktualisiereAnfrage, ladeAnfrage, findeRechnung, ladeEinstellungen, ladePreise, ladeRechnung, ladeUnterkunft, legeAnfrageDokAn, listeAnfragen, listeAnfragenAlle } from './speicher.js' import { neuesToken, tokenPasst } from './token.js' import * as zahlung from './zahlung.js' @@ -39,6 +39,11 @@ async function sende(fn) { } } +/** Rechnung zu Anfrage und Art ausstellen, aber nur einmal: eine vorhandene wird wiederverwendet (Wiederholung nach Teilfehler). */ +async function rechnungEinmal(ctx, a, art, opts) { + return (await findeRechnung(a.$id, art)) ?? stelleAus(ctx, a, { art, ...opts }) +} + function fuerFeature(ctx, a) { if (!a || a.featureId !== ctx.featureId) throw new UkFehler(404, 'nicht_gefunden') return a @@ -124,7 +129,7 @@ export async function gibFrei(ctx, anfrageId, { posten, fristTage, nachricht, no sauber = berechnePreis({ preise, von: a.von, bis: a.bis, personen: a.personen }).posten } const steuerart = preise?.steuerart ?? 'regel' - const summen = summiere(sauber, steuerart) + const summen = { ...summiere(sauber, steuerart), steuerart } if (!(summen.bruttoCent > 0)) throw new UkFehler(400, 'ungueltig', { posten: 'Die Summe muss größer als 0 sein.' }) if (!(await istFrei(a.unterkunftId, a.von, a.bis, { ohneAnfrage: a.$id, now }))) throw new UkFehler(409, 'zeitraum_belegt') const tage = Number.isInteger(fristTage) && fristTage >= 1 ? fristTage : preise?.fristTage || 3 @@ -194,10 +199,13 @@ export async function bucheVerbindlich(ctx, anfrageId, token, { rechnungsadresse const einst = ctx.einstellungen || {} if (zahlart === 'online' && !(einst.onlineZahlung && einst.stripeAccountId)) throw new UkFehler(409, 'online_aus') const adresse = pruefeAdresse(rechnungsadresse) + if (!einst.firma || !einst.strasse || !einst.plz || !einst.ort || !(einst.steuernummer || einst.ustId)) { + throw new UkFehler(409, 'einstellungen_unvollstaendig') + } if (!Array.isArray(a.posten) || !a.summen) throw new UkFehler(409, 'status_ungueltig') if (!(await istFrei(a.unterkunftId, a.von, a.bis, { ohneAnfrage: a.$id, now }))) throw new UkFehler(409, 'zeitraum_belegt') const vorlaeufig = { ...a, rechnungsadresse: adresse, zahlart } - const rechnung = await stelleAus(ctx, vorlaeufig, { art: 'rechnung', now }) + const rechnung = await rechnungEinmal(ctx, vorlaeufig, 'rechnung', { now }) const anfrage = await aktualisiereAnfrage(a.$id, { status: 'gebucht', rechnungsadresse: adresse, @@ -241,22 +249,36 @@ export async function storniere(ctx, anfrageId, { grund = '', erstattungCent = 0 if (a.bezahltVia !== 'stripe') throw new UkFehler(400, 'ungueltig', { erstattungCent: 'Erstattung ist nur bei Online-Zahlung möglich.' }) if (!Number.isInteger(brutto) || erstattungCent > brutto - bisher) throw new UkFehler(400, 'ungueltig', { erstattungCent: 'Der Betrag ist zu hoch.' }) } - let erstattet = 0 - if (erstattungCent > 0) erstattet = (await zahlung.erstatte(ctx, a, erstattungCent, { now })).erstattetCent let stornoRechnung = null if (a.rechnungId) { const orig = await ladeRechnung(a.rechnungId) - if (orig) stornoRechnung = await stelleAus(ctx, a, { art: 'storno', bezugNummer: orig.nummer, now }) + if (orig) stornoRechnung = await rechnungEinmal(ctx, a, 'storno', { bezugNummer: orig.nummer, now }) } + // Erst Status und Erstattungsbetrag festschreiben, dann Stripe: scheitert danach etwas, wird nie ein zweites Mal erstattet. const anfrage = await aktualisiereAnfrage(a.$id, { status: 'storniert', stornoGrund: text(grund, 500), storniertAt: iso(ms(now)), - erstattetCent: bisher + erstattet, + erstattetCent: bisher + erstattungCent, }) + let erstattet = erstattungCent + if (erstattungCent > 0) { + try { + erstattet = ( + await zahlung.erstatte(ctx, a, erstattungCent, { now, idempotencyKey: `uk-erstattung-${a.$id}-${bisher + erstattungCent}` }) + ).erstattetCent + } catch (err) { + await aktualisiereAnfrage(a.$id, { status: a.status, stornoGrund: a.stornoGrund ?? '', storniertAt: null, erstattetCent: bisher }) + throw err + } + if (erstattet !== erstattungCent) { + const korrigiert = await aktualisiereAnfrage(a.$id, { erstattetCent: bisher + erstattet }) + return { anfrage: korrigiert, stornoRechnung, erstattet } + } + } return { anfrage, stornoRechnung, erstattet } }) - await sende(() => mails.anGast('G22', ctx, r.anfrage, { stornoRechnung: r.stornoRechnung, erstattetCent: r.erstattet, grund })) + await sende(() => mails.anGast('G22', ctx, r.anfrage, { stornoRechnung: r.stornoRechnung, erstattetCent: r.erstattet, grund: text(grund, 500) })) return { anfrage: r.anfrage, stornoRechnung: r.stornoRechnung } } diff --git a/server/services/unterkunft/rechnungen.js b/server/services/unterkunft/rechnungen.js index 9dd0003..db9c511 100644 --- a/server/services/unterkunft/rechnungen.js +++ b/server/services/unterkunft/rechnungen.js @@ -51,7 +51,7 @@ export async function stelleAus(ctx, anfrage, { art = 'rechnung', bezugNummer, n personen: anfrage.personen, posten, summen, - steuerart: (anfrage.summen.ust || []).length === 0 ? 'kleinunternehmer' : 'regel', + steuerart: anfrage.summen.steuerart ?? ((anfrage.summen.ust || []).length === 0 ? 'kleinunternehmer' : 'regel'), zahlart: anfrage.zahlart || '', bezugNummer: bezugNummer ?? '', anfrageNummer: anfrage.nummer, diff --git a/server/services/unterkunft/speicher.js b/server/services/unterkunft/speicher.js index 3177f4a..7e95ef3 100644 --- a/server/services/unterkunft/speicher.js +++ b/server/services/unterkunft/speicher.js @@ -144,3 +144,9 @@ export async function listeRechnungen(featureId) { /** Alle Anfragen (aller Kunden) mit einem Status; fuer den Fristen-Job. */ export const listeAnfragenAlle = (status) => liste('ukAnfragen', [Query.equal('status', status)]) + +/** Vorhandene Rechnung einer Anfrage zu einer Art ('rechnung' | 'storno'); fuer idempotente Wiederholung nach Teilfehlern. */ +export async function findeRechnung(anfrageId, art) { + const alle = await liste('ukRechnungen', [Query.equal('anfrageId', anfrageId)]) + return alle.filter((r) => r.art === art).sort((a, b) => String(a.nummer).localeCompare(String(b.nummer)))[0] ?? null +} diff --git a/server/services/unterkunft/zahlung.js b/server/services/unterkunft/zahlung.js index e0e7ea5..26f9bb1 100644 --- a/server/services/unterkunft/zahlung.js +++ b/server/services/unterkunft/zahlung.js @@ -1,7 +1,7 @@ // Stub: Task 7 ersetzt den Inhalt. Erstattung ueber Stripe Connect. import { UkFehler } from './fehler.js' -export async function erstatte(ctx, anfrage, betragCent, { now } = {}) { +export async function erstatte(ctx, anfrage, betragCent, { now, idempotencyKey } = {}) { if (!ctx?.einstellungen?.stripeAccountId) throw new UkFehler(409, 'online_aus') return { erstattetCent: betragCent } } diff --git a/test/unterkunftAblauf.test.js b/test/unterkunftAblauf.test.js index a7d6742..25441bf 100644 --- a/test/unterkunftAblauf.test.js +++ b/test/unterkunftAblauf.test.js @@ -20,7 +20,7 @@ const { istFrei } = await import('../server/services/unterkunft/belegung.js') after(() => aw.close()) const NOW = new Date('2026-11-01T12:00:00Z') -const ctx = { featureId: 'f1', customerId: 'c1', projectId: 'p1', siteKey: 'sk', einstellungen: { firma: 'Haus', onlineZahlung: false } } +const ctx = { featureId: 'f1', customerId: 'c1', projectId: 'p1', siteKey: 'sk', einstellungen: { firma: 'Haus', strasse: 'Str 1', plz: '10115', ort: 'Berlin', steuernummer: '12/345', onlineZahlung: false } } const GAST = { name: 'Eva Gast', firma: '', email: 'eva@example.com', telefon: '', nachricht: 'Hallo' } const ADRESSE = { name: 'Eva Gast', strasse: 'Weg 1', plz: '12345', ort: 'Berlin', land: 'DE' } @@ -210,3 +210,70 @@ test('Uebergaenge', () => { assert.equal(ab.darfUebergang('bezahlt', 'storniert'), true) assert.equal(ab.darfUebergang('abgelehnt', 'neu'), false) }) + +test('Buchung: Wiederholung nach Fehler beim Anfrage-Update gibt genau eine Rechnung, gleiche Nummer', async () => { + const { id, token } = await freigegeben() + const opt = { rechnungsadresse: ADRESSE, zahlart: 'vorort', now: NOW } + aw.failNext({ collection: 'ukAnfragen', method: 'PATCH', status: 500 }) + await assert.rejects(ab.bucheVerbindlich(ctx, id, token, opt)) + assert.equal(aw.docs('ukRechnungen').size, 1) + const nr = [...aw.docs('ukRechnungen').values()][0].nummer + const r = await ab.bucheVerbindlich(ctx, id, token, opt) + assert.equal(aw.docs('ukRechnungen').size, 1) + assert.equal(r.rechnung.nummer, nr) + assert.equal(r.anfrage.status, 'gebucht') +}) + +test('Buchung: unvollstaendige Einstellungen -> 409, nichts geschrieben', async () => { + const { id, token } = await freigegeben() + const bad = { ...ctx, einstellungen: { ...ctx.einstellungen, steuernummer: '', ustId: '' } } + assert.equal(await fehlerCode(ab.bucheVerbindlich(bad, id, token, { rechnungsadresse: ADRESSE, zahlart: 'vorort', now: NOW })), '409 einstellungen_unvollstaendig') + assert.equal(aw.docs('ukRechnungen').size, 0) + assert.equal((await sp.ladeAnfrage(id)).status, 'freigegeben') +}) + +test('Storno: Erstattung scheitert -> Rollback, Wiederholung erstattet genau einmal', async () => { + const sctx = { ...ctx, einstellungen: { ...ctx.einstellungen, onlineZahlung: true, stripeAccountId: 'acct_1' } } + const ohne = { ...ctx } + const { id, token } = await freigegeben() + await ab.bucheVerbindlich(sctx, id, token, { rechnungsadresse: ADRESSE, zahlart: 'online', now: NOW }) + await ab.markiereBezahlt(sctx, id, { via: 'stripe', now: NOW }) + assert.equal(await fehlerCode(ab.storniere(ohne, id, { erstattungCent: 20000, now: NOW })), '409 online_aus') + const a = await sp.ladeAnfrage(id) + assert.equal(a.status, 'bezahlt') + assert.equal(a.erstattetCent, 0) + assert.equal(aw.docs('ukRechnungen').size, 2) + const r = await ab.storniere(sctx, id, { grund: ' g ', erstattungCent: 20000, now: NOW }) + assert.equal(r.anfrage.erstattetCent, 20000) + assert.equal(aw.docs('ukRechnungen').size, 2) + assert.equal(await fehlerCode(ab.storniere(sctx, id, { erstattungCent: 20000, now: NOW })), '409 status_ungueltig') + assert.equal(mails._aufrufe.at(-1).extra.grund, 'g') +}) + +test('Storno: Schreibfehler vor der Erstattung -> keine Erstattung, Status unveraendert', async () => { + const sctx = { ...ctx, einstellungen: { ...ctx.einstellungen, onlineZahlung: true, stripeAccountId: 'acct_1' } } + const { id, token } = await freigegeben() + await ab.bucheVerbindlich(sctx, id, token, { rechnungsadresse: ADRESSE, zahlart: 'online', now: NOW }) + await ab.markiereBezahlt(sctx, id, { via: 'stripe', now: NOW }) + aw.failNext({ collection: 'ukAnfragen', method: 'PATCH', status: 500 }) + await assert.rejects(ab.storniere(sctx, id, { erstattungCent: 20000, now: NOW })) + const a = await sp.ladeAnfrage(id) + assert.equal(a.status, 'bezahlt') + assert.equal(a.erstattetCent, 0) + const r = await ab.storniere(sctx, id, { erstattungCent: 20000, now: NOW }) + assert.equal(r.anfrage.erstattetCent, 20000) + assert.equal(aw.docs('ukRechnungen').size, 2) +}) + +test('Rechnung traegt die gespeicherte Steuerart (Kleinunternehmer; Regel mit 0 %)', async () => { + aw.seed('ukPreise', { $id: 'p1', unterkunftId: 'u1', featureId: 'f1', steuerart: 'kleinunternehmer' }) + const a = await anlegen() + const { token } = await ab.gibFrei(ctx, a.$id, { posten: [{ text: 'X', menge: 1, einzelCent: 5000, ustProzent: 0 }], now: NOW }) + const r = await ab.bucheVerbindlich(ctx, a.$id, token, { rechnungsadresse: ADRESSE, zahlart: 'vorort', now: NOW }) + assert.equal(r.rechnung.inhalt.steuerart, 'kleinunternehmer') + const b = await anlegen('2026-12-10', '2026-12-12') + aw.seed('ukPreise', { $id: 'p1', unterkunftId: 'u1', featureId: 'f1', steuerart: 'regel' }) + const f = await ab.gibFrei(ctx, b.$id, { posten: [{ text: 'X', menge: 1, einzelCent: 5000, ustProzent: 0 }], now: NOW }) + const r2 = await ab.bucheVerbindlich(ctx, b.$id, f.token, { rechnungsadresse: ADRESSE, zahlart: 'vorort', now: NOW }) + assert.equal(r2.rechnung.inhalt.steuerart, 'regel') +})