171 lines
14 KiB
TypeScript
171 lines
14 KiB
TypeScript
// Lane L8 „Notdienst" — Backoffice-Nachbearbeitung: Liste/Detail (Fortschritt), Kunde bestätigen
|
|
// (Kundennummer), bestehendem Kunden zuordnen (alles umgehängt, vorläufig → merged), Dublette
|
|
// zusammenführen, Objekt korrigieren/zuordnen, Auftrag ergänzen, Abrechnungsfreigabe.
|
|
// Rechte: Monteur/Teamleiter können nicht reviewen; Mandant B sieht/ändert nichts von A.
|
|
//
|
|
// Lauf: npx tsx scripts/test-notdienst-review.ts
|
|
|
|
import "dotenv/config";
|
|
import { randomUUID } from "node:crypto";
|
|
import { prisma } from "../src/server/db";
|
|
import type { EmergencyCreateInput } from "../src/lib/emergency/schemas";
|
|
import { createEmergencyOrder } from "../src/server/services/emergency/create";
|
|
import {
|
|
assignEmergencySite,
|
|
assignEmergencyToCustomer,
|
|
completeEmergencyOrderData,
|
|
confirmEmergencyCustomer,
|
|
correctEmergencySite,
|
|
getEmergencyReview,
|
|
listEmergencyReviews,
|
|
mergeEmergencyCustomer,
|
|
releaseEmergencyForBilling,
|
|
} from "../src/server/services/emergency/review";
|
|
import { endSession } from "../src/server/services/field/sessions";
|
|
import { createCompletionReport } from "../src/server/services/reports/create";
|
|
import { updateReportTexts } from "../src/server/services/reports/edit";
|
|
import { captureSignature } from "../src/server/services/reports/signature";
|
|
import { submitReport } from "../src/server/services/reports/submit";
|
|
import { approveReport } from "../src/server/services/reports/approve";
|
|
import type { ServiceCtx } from "../src/server/services/context";
|
|
import { cleanupTenants, createFixture, expectCode, failures, ok } from "./lib-auftraege-fixtures";
|
|
|
|
const SLUG_A = "zz-l8-review-a";
|
|
const SLUG_B = "zz-l8-review-b";
|
|
|
|
function payload(over: Partial<EmergencyCreateInput> = {}): EmergencyCreateInput {
|
|
return {
|
|
clientIds: { workOrder: randomUUID(), session: randomUUID() },
|
|
customer: { mode: "new", firstName: "Lutz", lastName: "Meier", phone: "0171 7654321", street: "Elbchaussee", houseNumber: "12", postalCode: "22763", city: "Hamburg" },
|
|
site: { mode: "new", street: "Elbchaussee", houseNumber: "12", postalCode: "22763", city: "Hamburg" },
|
|
onSiteContact: { name: "Lutz Meier", phone: "0171 7654321" },
|
|
reason: "Heizung ausgefallen",
|
|
...over,
|
|
};
|
|
}
|
|
|
|
async function finishWithReport(ctx: ServiceCtx, workOrderId: string): Promise<string> {
|
|
await endSession(ctx, { workOrderId });
|
|
const report = (await createCompletionReport(ctx, { workOrderId })).report;
|
|
await updateReportTexts(ctx, { reportId: report.id, texts: { workPerformed: "Brenner getauscht." } });
|
|
await captureSignature(ctx, { reportId: report.id, outcome: "customer_absent", reason: "Kunde nicht vor Ort", confirmationText: "Bestätigt" });
|
|
await submitReport(ctx, { reportId: report.id });
|
|
return report.id;
|
|
}
|
|
|
|
async function main() {
|
|
await cleanupTenants([SLUG_A, SLUG_B]);
|
|
const A = await createFixture(SLUG_A);
|
|
const B = await createFixture(SLUG_B);
|
|
const office = A.ctx.backoffice;
|
|
try {
|
|
const r1 = await createEmergencyOrder(A.ctx.tech, payload());
|
|
const reportId = await finishWithReport(A.ctx.tech, r1.workOrderId);
|
|
const r2 = await createEmergencyOrder(A.ctx.tech, payload({ customer: { mode: "new", companyName: "Bäckerei Sonne", phone: "040 3333" }, onSiteContact: { name: "Frau Sonne", phone: "040 3333" }, reason: "Stromausfall Backstube" }));
|
|
const existing = await prisma.customer.create({
|
|
data: { tenantId: A.tenantId, customerNumber: "K-77001", firstName: "Lutz", lastName: "Meier", phone: "+49 171 7654321", city: "Hamburg", street: "Elbchaussee" },
|
|
});
|
|
const existingSite = await prisma.site.create({ data: { tenantId: A.tenantId, customerId: existing.id, name: "Wohnhaus Elbchaussee", street: "Elbchaussee", houseNumber: "12", city: "Hamburg" } });
|
|
|
|
console.log("\n— Rechte & Mandantentrennung —");
|
|
await expectCode(() => listEmergencyReviews(A.ctx.tech), "forbidden", "Monteur: Liste → forbidden");
|
|
await expectCode(() => listEmergencyReviews(A.ctx.lead), "forbidden", "Teamleiter: Liste → forbidden");
|
|
await expectCode(() => getEmergencyReview(A.ctx.tech, r1.workOrderId), "forbidden", "Monteur: Detail → forbidden");
|
|
await expectCode(() => confirmEmergencyCustomer(A.ctx.tech, r2.workOrderId), "forbidden", "Monteur: Kunden bestätigen → forbidden");
|
|
await expectCode(() => assignEmergencyToCustomer(A.ctx.tech, { workOrderId: r1.workOrderId, targetCustomerId: existing.id }), "forbidden", "Monteur: zuordnen → forbidden");
|
|
await expectCode(() => releaseEmergencyForBilling(A.ctx.tech, { workOrderId: r1.workOrderId }), "forbidden", "Monteur: Abrechnung → forbidden");
|
|
ok((await listEmergencyReviews(B.ctx.backoffice, { filter: "all" })).length === 0, "Mandant B: Liste enthält keine Notdienste von A");
|
|
await expectCode(() => getEmergencyReview(B.ctx.backoffice, r1.workOrderId), "not_found", "Mandant B: Detail → not_found");
|
|
await expectCode(() => confirmEmergencyCustomer(B.ctx.backoffice, r2.workOrderId), "not_found", "Mandant B: Kunden bestätigen → not_found");
|
|
await expectCode(() => assignEmergencyToCustomer(B.ctx.backoffice, { workOrderId: r1.workOrderId, targetCustomerId: existing.id }), "not_found", "Mandant B: zuordnen → not_found");
|
|
await expectCode(() => completeEmergencyOrderData(B.ctx.backoffice, { workOrderId: r1.workOrderId, title: "B" }), "not_found", "Mandant B: Auftrag ergänzen → not_found");
|
|
ok((await prisma.customer.findUniqueOrThrow({ where: { id: r2.customerId } })).status === "provisional", "nach fremden Versuchen unverändert vorläufig");
|
|
const regular = await prisma.workOrder.create({ data: { tenantId: A.tenantId, number: "A-TEST-1", title: "Normal", customerId: A.customerId, status: "in_review" } });
|
|
await expectCode(() => getEmergencyReview(office, regular.id), "not_found", "normaler Auftrag ist kein Notdienst → not_found");
|
|
|
|
console.log("\n— Liste & Fortschritt —");
|
|
const list = await listEmergencyReviews(office);
|
|
const item1 = list.find((i) => i.id === r1.workOrderId);
|
|
ok(!!item1 && !!list.find((i) => i.id === r2.workOrderId), "Liste enthält Notdienste mit vorläufigen Stammdaten");
|
|
ok(item1?.progress.total === 5 && item1.progress.count === 0 && item1.technician === `tech ${SLUG_A}`, "Fortschritt 0 von 5, Monteur angezeigt");
|
|
const detail = await getEmergencyReview(office, r1.workOrderId);
|
|
ok(detail.duplicates.some((d) => d.customerId === existing.id), "Dublettenkandidat über findDuplicateCustomers (Telefon/Name)");
|
|
ok(detail.startedAt instanceof Date && detail.endedAt instanceof Date && detail.startedAt <= detail.endedAt, "Einsatzbeginn/-ende aus Arbeitszeiten");
|
|
|
|
console.log("\n— Bestehendem Kunden zuordnen —");
|
|
await expectCode(() => assignEmergencyToCustomer(office, { workOrderId: r1.workOrderId, targetCustomerId: r1.customerId }), "invalid", "gleicher Kunde → invalid");
|
|
await expectCode(() => assignEmergencyToCustomer(office, { workOrderId: r1.workOrderId, targetCustomerId: B.customerId }), "invalid", "Kunde aus Mandant B als Ziel → invalid");
|
|
const before = await prisma.workOrder.findUniqueOrThrow({ where: { id: r1.workOrderId } });
|
|
const assigned = await assignEmergencyToCustomer(office, { workOrderId: r1.workOrderId, targetCustomerId: existing.id });
|
|
const woAfter = await prisma.workOrder.findUniqueOrThrow({ where: { id: r1.workOrderId }, include: { site: true, contact: true } });
|
|
const src = await prisma.customer.findUniqueOrThrow({ where: { id: r1.customerId } });
|
|
ok(woAfter.customerId === existing.id && woAfter.version === before.version + 1, "Auftrag umgehängt, Version +1");
|
|
ok(woAfter.site?.customerId === existing.id && woAfter.contact?.customerId === existing.id, "Objekt und Ansprechpartner umgehängt");
|
|
ok(src.status === "merged" && src.mergedIntoId === existing.id && !src.isProvisional, "vorläufiger Kunde → merged (mergedIntoId)");
|
|
ok(assigned.moved.workOrders === 1 && assigned.moved.sites === 1, "Zähler der umgehängten Datensätze");
|
|
ok((await prisma.auditLog.count({ where: { tenantId: A.tenantId, entity: "customer", entityId: { in: [r1.customerId, existing.id] } } })) >= 2, "Audit für Quelle und Ziel");
|
|
await expectCode(() => assignEmergencyToCustomer(office, { workOrderId: r1.workOrderId, targetCustomerId: A.customerId }), "conflict", "erneutes Zuordnen (nicht mehr vorläufig) → conflict");
|
|
ok((await getEmergencyReview(office, r1.workOrderId)).progress.done.customer, "Prüfschritt Kunde erledigt");
|
|
|
|
console.log("\n— Objekt zuordnen / korrigieren —");
|
|
const oldSiteId = woAfter.siteId!;
|
|
const siteRes = await assignEmergencySite(office, { workOrderId: r1.workOrderId, siteId: existingSite.id });
|
|
const woSite = await prisma.workOrder.findUniqueOrThrow({ where: { id: r1.workOrderId } });
|
|
ok(woSite.siteId === existingSite.id && siteRes.removed, "Auftrag am bestehenden Objekt");
|
|
ok(!!(await prisma.site.findUniqueOrThrow({ where: { id: oldSiteId } })).deletedAt, "ungenutztes vorläufiges Objekt soft-gelöscht");
|
|
await expectCode(() => assignEmergencySite(office, { workOrderId: r1.workOrderId, siteId: B.siteId }), "invalid", "Objekt aus Mandant B → invalid");
|
|
const corrected = await correctEmergencySite(office, { workOrderId: r2.workOrderId, patch: { name: "Backstube", accessNotes: "Hintereingang" }, confirm: true });
|
|
ok(corrected.status === "active" && corrected.name === "Backstube" && corrected.customerId === r2.customerId, "vorläufiges Objekt korrigiert und bestätigt");
|
|
|
|
console.log("\n— Kunde bestätigen —");
|
|
const confirmed = await confirmEmergencyCustomer(office, r2.workOrderId);
|
|
const c2 = await prisma.customer.findUniqueOrThrow({ where: { id: r2.customerId } });
|
|
ok(/^K-\d+$/.test(confirmed.customerNumber ?? "") && c2.customerNumber === confirmed.customerNumber, `Kundennummer bei Bestätigung vergeben (${confirmed.customerNumber})`);
|
|
ok(c2.status === "active" && !c2.isProvisional, "Kunde aktiv");
|
|
await expectCode(() => confirmEmergencyCustomer(office, r2.workOrderId), "conflict", "zweite Bestätigung → conflict");
|
|
|
|
console.log("\n— Dublette zusammenführen —");
|
|
await expectCode(() => mergeEmergencyCustomer(office, { workOrderId: r2.workOrderId, targetCustomerId: A.customerId, confirm: false }), "invalid", "ohne Bestätigung → invalid");
|
|
await expectCode(() => mergeEmergencyCustomer(A.ctx.tech, { workOrderId: r2.workOrderId, targetCustomerId: A.customerId, confirm: true }), "forbidden", "Monteur → forbidden");
|
|
await mergeEmergencyCustomer(office, { workOrderId: r2.workOrderId, targetCustomerId: A.customerId, confirm: true });
|
|
ok((await prisma.workOrder.findUniqueOrThrow({ where: { id: r2.workOrderId } })).customerId === A.customerId, "Auftrag nach Merge am Zielkunden");
|
|
ok((await prisma.customer.findUniqueOrThrow({ where: { id: r2.customerId } })).status === "merged", "Quelle merged");
|
|
|
|
console.log("\n— Auftrag ergänzen & Abrechnung —");
|
|
const notdienst = await prisma.orderType.findFirstOrThrow({ where: { tenantId: A.tenantId, key: "notdienst" } });
|
|
await expectCode(() => completeEmergencyOrderData(office, { workOrderId: r1.workOrderId, title: "" }), "invalid", "leerer Titel → invalid");
|
|
await completeEmergencyOrderData(office, { workOrderId: r1.workOrderId, title: "Notdienst Heizung", description: "Brenner getauscht", orderTypeId: notdienst.id, billingType: "time_material" });
|
|
const woData = await prisma.workOrder.findUniqueOrThrow({ where: { id: r1.workOrderId } });
|
|
ok(woData.title === "Notdienst Heizung" && woData.billingType === "time_material" && woData.orderTypeId === notdienst.id, "Titel, Auftragsart, Abrechnungsart gespeichert");
|
|
await expectCode(() => completeEmergencyOrderData(office, { workOrderId: r1.workOrderId, title: "alt", baseVersion: 1 }), "conflict", "veraltete Version → conflict");
|
|
|
|
const r3 = await createEmergencyOrder(A.ctx.tech, payload({ customer: { mode: "new", lastName: "Offen", phone: "040 4444" } }));
|
|
await expectCode(() => releaseEmergencyForBilling(office, { workOrderId: r3.workOrderId }), "blocked", "vorläufige Stammdaten → Abrechnung blocked");
|
|
const blockedErr = await releaseEmergencyForBilling(office, { workOrderId: r3.workOrderId }).catch((e) => e);
|
|
ok((blockedErr?.details as { reason?: string })?.reason === "master_data_open", "Grund master_data_open");
|
|
await expectCode(() => releaseEmergencyForBilling(office, { workOrderId: r1.workOrderId }), "blocked", "ohne freigegebenen Abschlussbericht → blocked");
|
|
await approveReport(office, { reportId }, { dispatchPdf: async () => {} });
|
|
const released = await releaseEmergencyForBilling(office, { workOrderId: r1.workOrderId });
|
|
ok(released.status === "released_for_billing", "zur Abrechnung freigegeben");
|
|
const final = await getEmergencyReview(office, r1.workOrderId);
|
|
ok(final.progress.count === 5, "Fortschritt 5 von 5");
|
|
ok(!(await listEmergencyReviews(office)).some((i) => i.id === r1.workOrderId), "erledigter Notdienst nicht mehr in „Zu prüfen“");
|
|
ok((await listEmergencyReviews(office, { filter: "all" })).some((i) => i.id === r1.workOrderId), "unter „Alle“ weiterhin sichtbar");
|
|
ok((await prisma.auditLog.count({ where: { tenantId: A.tenantId, entity: "emergency", entityId: r1.workOrderId, action: "update" } })) >= 4, "Prüfschritte auditiert");
|
|
|
|
console.log(`\n${failures === 0 ? "✓ alle Prüfungen bestanden" : `✗ ${failures} Prüfung(en) fehlgeschlagen`}`);
|
|
} finally {
|
|
await cleanupTenants([SLUG_A, SLUG_B]);
|
|
}
|
|
}
|
|
|
|
main()
|
|
.catch((err) => {
|
|
console.error(err);
|
|
process.exitCode = 1;
|
|
})
|
|
.finally(async () => {
|
|
await prisma.$disconnect();
|
|
process.exit(failures > 0 || process.exitCode ? 1 : 0);
|
|
});
|