Shop Review B I-1: Eingangsmail G15 bei SEPA, G09 nimmt die Bestellung ausdruecklich an

G15 "Wir haben Ihre Bestellung erhalten" geht einmal raus, sobald Stripe die Sitzung
abgeschlossen, die Zahlung aber noch nicht gemeldet hat (meldeEingang, Marker mailsEingangAt,
aus dem Webhook und aus pruefeOffene). G09 sagt ausdruecklich, dass der Kaufvertrag mit der
Mail geschlossen ist, trennt Bestell- und Zahlungsdatum und nennt die Telefonnummer des
Anbieters.

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

server/services/shop/bestellungen.js

@@ -604,6 +604,46 @@ export async function schliesseAb({ accountId, session, now = new Date() }) {
   })
 }
 
+/**
+ * Eingang der Bestellung (G15): Stripe meldet die Sitzung abgeschlossen, die Zahlung steht aber noch aus (SEPA-Lastschrift,
+ * payment_status unpaid / no_payment_required). Die Bestellung bleibt offen, der Kaeufer bekommt einmal eine Eingangsmail ohne
+ * Vertragsschluss (der Vertrag kommt mit G09 nach Zahlungseingang zustande). Marker `mailsEingangAt` im Bestell-JSON, Versuche in
+ * mailsVersuche.eingang (hoechstens MAIL_VERSUCHE_MAX). Aufrufer: Webhook (checkout.session.completed) und pruefeOffene.
+ * Nie ein Wurf wegen der Mail; falsches Konto, fremde Sitzung oder eine nicht mehr offene Bestellung bleiben wirkungslos.
+ * @param {{ accountId: string, session: object, now?: Date }} p
+ * @returns {Promise<{ gesendet: boolean }>}
+ */
+export async function meldeEingang({ accountId, session, now = new Date() }) {
+  const orderId = session?.metadata?.orderId
+  if (!istObjekt(session) || session.metadata?.wkShop !== '1' || typeof orderId !== 'string' || !orderId) return { gesendet: false }
+  if (session.payment_status !== 'unpaid' && session.payment_status !== 'no_payment_required') return { gesendet: false }
+  const an = kurz(session.customer_details?.email, 320)
+  if (!an) return { gesendet: false }
+  const jetzt = new Date(now)
+
+  return withLocks([`shop-order:${orderId}`], async () => {
+    const order = await bestellungLesen(orderId)
+    if (!order || order.status !== 'offen') return { gesendet: false }
+    const shop = await shopDokument(order.shopId)
+    if (!shop || typeof accountId !== 'string' || shop.stripeAccountId !== accountId) return { gesendet: false }
+    const daten = order.daten
+    const versuche = istObjekt(daten.mailsVersuche) ? daten.mailsVersuche : {}
+    if (daten.mailsEingangAt || (versuche.eingang ?? 0) >= MAIL_VERSUCHE_MAX) return { gesendet: false }
+    let ok = false
+    try {
+      leereCache(shop.siteKey)
+      const ctx = await shopPerSiteKey(shop.siteKey, { now: jetzt })
+      if (!ctx) throw new Error('Shop-Kontext nicht gefunden')
+      ok = (await anKaeufer('G15', ctx, order, { an }, jetzt)).ok
+    } catch (err) {
+      console.warn(`[shop] G15 zur Bestellung ${orderId.slice(0, 36)} nicht eingereiht: ${err?.name}: ${String(err?.message).slice(0, 120)}`)
+    }
+    const neu = ok ? { ...daten, mailsEingangAt: jetzt.toISOString() } : { ...daten, mailsVersuche: { ...versuche, eingang: (versuche.eingang ?? 0) + 1 } }
+    await updateDocument(col(), orderId, { bestellung: JSON.stringify(neu) })
+    return { gesendet: ok }
+  })
+}
+
 /**
  * Verwirft eine offene Bestellung (Status storniert, Bestand wird frei). Nur aus offen; sonst keine Wirkung.
  * @param {string} orderId
@@ -692,7 +732,11 @@ export async function pruefeOffene(now = new Date()) {
           if (session.payment_status === 'paid') {
             const erg = await schliesseAb({ accountId: shop.stripeAccountId, session, now })
             if (erg.neu) zaehler.bezahlt += 1
-          } else zaehler.wartend += 1 // SEPA unterwegs: async_payment_succeeded/failed entscheidet
+          } else {
+            // SEPA unterwegs: async_payment_succeeded/failed entscheidet; bis dahin hat der Kaeufer die Eingangsmail (G15) zu bekommen
+            zaehler.wartend += 1
+            await meldeEingang({ accountId: shop.stripeAccountId, session, now })
+          }
           continue
         }
         if (session?.status === 'open') {

server/services/shop/mails.js

@@ -13,7 +13,7 @@ import { gewaehrleistungsHinweis } from './rechtstexte.js'
  * Mails des Webshops (Spezifikation 2026-10-05-webshop-design.md, Abschnitte 5.3, 5.4 und 8; Plan Task E4).
  *
  * Kaeufer (G09 Bestellbestaetigung, G10 versendet, G11 abholbereit, G12 Eingang Widerruf, G13 Erstattung, G14 Zahlung
- * fehlgeschlagen) laufen durch die Mail-Warteschlange des Terminplaners (termine/outbox.js einreihen): Absendername = Shopname,
+ * fehlgeschlagen, G15 Eingang der Bestellung) laufen durch die Mail-Warteschlange des Terminplaners (termine/outbox.js einreihen): Absendername = Shopname,
  * Absenderadresse bleibt SMTP_FROM, Antworten an die E-Mail des Haendlers, nie BCC. featureId = ID des portalFeatures-Dokuments des
  * Shops, bookingId = Bestell-ID. Der Betreff steht in der Vorlage (G-Vorlagen des Shops haben keinen {{betreff}}-Wert). Die
  * Empfaenger-Kappe der Terminplaner-Mails (limits.darfEmpfaenger) gilt hier nicht: G09 ist Vertragspflicht.
@@ -36,7 +36,7 @@ import { gewaehrleistungsHinweis } from './rechtstexte.js'
  */
 
 const LEER = '–'
-const GAST_ARTEN = Object.freeze(['G09', 'G10', 'G11', 'G12', 'G13', 'G14'])
+const GAST_ARTEN = Object.freeze(['G09', 'G10', 'G11', 'G12', 'G13', 'G14', 'G15'])
 /** Grenzen des Outbox-Schemas (html 100000, text 50000) mit etwas Luft. */
 const MAX_HTML = 95000
 const MAX_TEXT = 47000
@@ -87,7 +87,7 @@ function anbieterZeile(a) {
   const ort = [text(a.plz), text(a.ort)].filter(Boolean).join(' ')
   const land = text(a.land) && a.land !== 'DE' ? (LANDNAMEN[a.land] ?? a.land) : ''
   const anschrift = [text(a.strasse), ort, land].filter(Boolean).join(', ')
-  return [text(a.name), anschrift, text(a.email)].filter(Boolean).join(', ') || LEER
+  return [text(a.name), anschrift, text(a.email), text(a.telefon) ? `Tel. ${einzeilig(a.telefon)}` : ''].filter(Boolean).join(', ') || LEER
 }
 
 const siteKeyVon = (ctx) => ctx?.shop?.siteKey || ctx?.doc?.siteKey || ''
@@ -143,9 +143,13 @@ function eingangText(eingang) {
   return `${datumKurz(d)}, ${uhrzeit(d)} Uhr`
 }
 
-const datumText = (order, now) => {
-  const ms = zeitMs(order?.bezahltAt || order?.erstelltAt)
-  return datumKurz(Number.isFinite(ms) ? new Date(ms) : now)
+/** Datum des ersten brauchbaren Zeitpunkts (Berliner Tag), sonst des Ersatzdatums. */
+const datumVon = (now, ...zeitpunkte) => {
+  for (const wert of zeitpunkte) {
+    const ms = zeitMs(wert)
+    if (Number.isFinite(ms)) return datumKurz(new Date(ms))
+  }
+  return datumKurz(now)
 }
 
 // ---------------------------------------------------------------- Werte
@@ -184,7 +188,8 @@ export function kaeuferWerte(ctx, order, now = new Date()) {
     impressum_url: text(rechtstexte.impressumUrl) || shop,
     datenschutz_url: text(rechtstexte.datenschutzUrl) || shop,
     bestellnummer: oderLeer(order?.bestellnummer),
-    datum: datumText(order, now),
+    datum: datumVon(now, order?.erstelltAt),
+    zahlungsdatum: datumVon(now, order?.bezahltAt, order?.erstelltAt),
     positionen: positionenText(snap.positionen),
     zwischensumme: text(texte.zwischensumme) || cent(summen.zwischensummeCent),
     versand: text(texte.versand) || (lieferart === 'abholung' ? 'Abholung – kostenlos' : cent(summen.versandCent)),

server/services/termine/outbox.js

@@ -39,7 +39,7 @@ import { pruefeNow, pruefeText, zeitMs } from './util.js'
  *   pause       Anmeldepause laeuft
  *   budget      Plaetze im Fenster >= mailsProStunde
  *   reserve     nachrangige Mails (G05, K20, K21) im Fenster >= max(1, floor(mailsProStunde x (1 - mailsReserve))): so bleibt
- *               ein Teil der Stunde den Vorrang-Mails (G01, G02, G08, Webshop G09, G12) und den normalen Mails vorbehalten
+ *               ein Teil der Stunde den Vorrang-Mails (G01, G02, G08, Webshop G09, G12, G15) und den normalen Mails vorbehalten
  *   kontingent  Mails dieser Funktion im Fenster >= mailsProFunktion: eine Funktion kann die Stunde nicht allein fuellen
  *
  * Minutenjob (verarbeite): liest nie alle wartenden Eintraege. Bei Pause oder leerem Gesamtbudget endet er ohne Abfrage.
@@ -73,10 +73,10 @@ const iso = (wertMs) => new Date(wertMs).toISOString()
 
 /**
  * Mails, die vor allen anderen rausgehen duerfen (Bestaetigung, Termin, Eingangsbestaetigung des Widerrufs). Dazu die beiden
- * Pflichtmails des Webshops: G09 Bestellbestaetigung (dauerhafter Datentraeger) und G12 Eingangsbestaetigung des Widerrufs. Die
+ * Pflichtmails des Webshops: G09 Bestellbestaetigung (dauerhafter Datentraeger), G12 Eingangsbestaetigung des Widerrufs und G15 Eingang der Bestellung (SEPA, Zahlung noch offen). Die
  * uebrigen Shop-Mails G10, G11, G13, G14 sind 'normal'.
  */
-export const MAIL_VORRANG = Object.freeze(['G01', 'G02', 'G08', 'G09', 'G12'])
+export const MAIL_VORRANG = Object.freeze(['G01', 'G02', 'G08', 'G09', 'G12', 'G15'])
 /** Mails, die zuerst warten (Erinnerung, Hinweise an den Betrieb): sie nehmen nie die ganze Stunde. */
 export const MAIL_NACHRANGIG = Object.freeze(['G05', 'K20', 'K21'])
 
@@ -119,7 +119,7 @@ function gesamtBremse(nowMs) {
  * 'pause' | 'budget' | 'reserve' | 'kontingent'. Nur lesen: belegt keinen Platz.
  * @param {number} nowMs
  * @param {string} featureId
- * @param {string} art Vorlagen-ID der Mail ('G01' ... 'K21', Shop: 'G09' ... 'G14')
+ * @param {string} art Vorlagen-ID der Mail ('G01' ... 'K21', Shop: 'G09' ... 'G15')
  * @returns {null|'pause'|'budget'|'reserve'|'kontingent'}
  */
 export function pruefePlatz(nowMs, featureId, art) {
@@ -442,7 +442,7 @@ async function verarbeiteKlasse(klasse, nowMs, now, lauf) {
 }
 
 /**
- * Minutenjob: sendet faellige wartende Eintraege, Vorrang-Mails (G01, G02, G08, G09, G12) vor normalen vor nachrangigen (G05, K20, K21),
+ * Minutenjob: sendet faellige wartende Eintraege, Vorrang-Mails (G01, G02, G08, G09, G12, G15) vor normalen vor nachrangigen (G05, K20, K21),
  * in jeder Klasse die faelligsten zuerst, bis Pause oder Stundenbudget bremsen. Er liest begrenzte Listen statt aller Eintraege
  * (siehe Kopfkommentar); Eintraege, die Vorrang-Reserve oder Kontingent ihrer Funktion bremsen, bleiben `wartet`, und die uebrigen
  * kommen trotzdem dran. Fehler bei einzelnen Eintraegen (z. B. Appwrite) stehen im Log und stoppen den Lauf nicht.