Bedarfsausweis gewerbe

src/pages/api/bedarfsausweis-gewerbe/[uid].ts

@@ -0,0 +1,212 @@
+import { GEGNachweisWohnenClient, OptionalNullable, UUidWithPrefix, ZodOverlap } from "#components/Ausweis/types.js";
+import { exclude } from "#lib/exclude.js";
+import { authorizationHeaders, authorizationMiddleware } from "#lib/middleware/authorization.js";
+import { prisma } from "#lib/server/prisma.js";
+import { APIError, defineApiRoute } from "astro-typesafe-api/server";
+import { BedarfsausweisGewerbeSchema } from "src/generated/zod/bedarfsausweisgewerbe.js";
+import { z } from "zod";
+
+export const PATCH = defineApiRoute({
+	input: BedarfsausweisGewerbeSchema.omit({
+		uid: true,
+		id: true,
+		benutzer_id: true,
+		geg_einpreisung_id: true,
+		aufnahme_id: true,
+	}),
+	output: z.void(),
+	headers: {
+		"Authorization": z.string()
+	},
+	middleware: authorizationMiddleware,
+	async fetch(input, ctx, user) {
+		const objekt = await prisma.bedarfsausweisGewerbe.findUnique({
+			where: {
+				uid: ctx.params.uid,
+				benutzer: {
+					id: user.id
+				}
+			}
+		})
+
+		if (!objekt) {
+			throw new APIError({
+				code: "NOT_FOUND",
+				message: "Nachweis konnte nicht gefunden werden oder gehört einem anderen Benutzer."
+			})
+		}
+
+		await prisma.bedarfsausweisGewerbe.update({
+			where: {
+				uid: ctx.params.uid
+			},
+			data: input
+		})
+	},
+})
+
+export const DELETE = defineApiRoute({
+	meta: {
+		description: "Storniert einen Nachweis"
+	},
+	headers: authorizationHeaders,
+	middleware: authorizationMiddleware,
+	async fetch(input, ctx, user) {
+		const { uid } = ctx.params;
+
+		if (!UUidWithPrefix.safeParse(uid).success) {
+			throw new APIError({
+				code: "BAD_REQUEST",
+				message: "UID konnte nicht verifiziert werden."
+			})
+		}
+
+		// Wir holen uns den BedarfsNachweis
+		// Dieser MUSS mit dem Nutzer verknüpft sein.
+		const nachweis = await prisma.bedarfsausweisGewerbe.findUnique({
+			where: {
+				uid,
+			}
+		});
+
+		if (!nachweis) {
+			// Falls wir den Nachweis nicht finden können, werfen wir einen Fehler
+			throw new APIError({
+				code: "NOT_FOUND",
+				message: "Nachweis konnte nicht gefunden werden.",
+			});
+		}
+
+		// Wir dürfen den Nachweis nur stornieren, wenn er noch nicht ausgestellt wurde
+		// Außerdem müssen wir schauen, ob wir Admin oder der Besitzer des Nachweises sind.
+		if ((nachweis.benutzer_id !== user.id) && user.rolle !== "ADMIN") {
+			// Falls der Nachweis nicht dem Nutzer gehört, werfen wir einen Fehler
+			throw new APIError({
+				code: "FORBIDDEN",
+				message: "Nachweis gehört nicht dem Nutzer.",
+			});
+		}
+
+		// if (Nachweis.erledigt) {
+		// 	// Falls der Nachweis bereits ausgestellt wurde, werfen wir einen Fehler
+		// 	throw new TRPCError({
+		// 		code: "BAD_REQUEST",
+		// 		message: "Nachweis wurde bereits ausgestellt.",
+		// 	});
+		// }
+
+		if (nachweis.storniert) {
+			// Falls der Nachweis bereits storniert ist, werfen wir einen Fehler
+			throw new APIError({
+				code: "BAD_REQUEST",
+				message: "Nachweis wurde bereits storniert.",
+			});
+		}
+
+		await prisma.gEGNachweisWohnen.update({
+			where: {
+				id: nachweis.id
+			},
+			data: {
+				storniert: true
+			}
+		})
+
+		// Wir erstellen ein Event, dass der Nachweis storniert wurde
+		// Dann können wir das in der Historie anzeigen
+		await prisma.event.create({
+			data: {
+				title: "Nachweis storniert",
+				description: ((user.rolle === "ADMIN") && (nachweis.benutzer_id !== user.id)) ? "Nachweis wurde von einem Administrator storniert." : "Nachweis wurde vom Besitzer storniert.",
+				benutzer: {
+					connect: {
+						id: user.id
+					}
+				},
+				aufnahme: {
+					connect: {
+						id: nachweis.aufnahme_id
+					}
+				}
+			}
+		})
+	},
+})
+
+export const GET = defineApiRoute({
+	meta: {
+		description: "Gibt ein spezifisches Gebäude des Benutzers zurück.",
+		tags: ["Gebäude"],
+		headers: {
+			"Authorization": {
+				description: "Ein gültiger Authentifizierungstoken",
+				required: true,
+				allowEmptyValue: false,
+				examples: {
+					Bearer: {
+						value: "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9..."
+					}
+				}
+			}
+		}
+	},
+	output: BedarfsausweisGewerbeSchema.merge(z.object({
+		uid_aufnahme: UUidWithPrefix,
+		uid_objekt: UUidWithPrefix,
+		uid_benutzer: UUidWithPrefix.optional()
+	})).omit({
+		id: true,
+		aufnahme_id: true,
+		benutzer_id: true
+	}),
+	middleware: authorizationMiddleware,
+	async fetch(input, context, user) {
+		const { uid } = context.params;
+
+		if (!uid) {
+			throw new APIError({
+				code: "BAD_REQUEST",
+				message: "Missing uid in request params"
+			})
+		}
+
+		const nachweis = await prisma.bedarfsausweisGewerbe.findUnique({
+			where: {
+				uid,
+				benutzer_id: user.id
+			},
+			include: {
+				benutzer: {
+					select: {
+						uid: true
+					}
+				},
+				aufnahme: {
+					select: {
+						uid: true,
+						objekt: {
+							select: {
+								uid: true
+							}
+						}
+					}
+				}
+			}
+		});
+
+		if (!nachweis) {
+			// Falls wir den Nachweis nicht finden können, werfen wir einen Fehler
+			throw new APIError({
+				code: "NOT_FOUND",
+				message: "Nachweis konnte nicht gefunden werden.",
+			});
+		}
+
+		return {
+			uid_aufnahme: nachweis.aufnahme.uid,
+			uid_objekt: nachweis.aufnahme.objekt.uid,
+			uid_benutzer: nachweis.benutzer?.uid,
+			...exclude(nachweis, ["id", "aufnahme_id", "benutzer_id", "aufnahme"])
+		}
+	},
+});

src/pages/api/bedarfsausweis-gewerbe/index.ts

@@ -0,0 +1,144 @@
+import { UUidWithPrefix } from "#components/Ausweis/types.js";
+import { authorizationHeaders, authorizationMiddleware } from "#lib/middleware/authorization.js";
+import { prisma } from "#lib/server/prisma.js";
+import { APIError, defineApiRoute } from "astro-typesafe-api/server";
+import { BedarfsausweisGewerbeSchema } from "src/generated/zod/bedarfsausweisgewerbe.js";
+import { z } from "zod";
+
+export const PUT = defineApiRoute({
+	meta: {
+		contentTypes: ["application/json"],
+		description:
+			"Erstellt einen neuen Bedarfsausweis Gewerbe.",
+		tags: ["GEG Nachweis", "Bedarfsausweis Gewerbe"],
+	},
+	input: z.object({
+		nachweis: BedarfsausweisGewerbeSchema.omit({
+			id: true,
+			benutzer_id: true,
+			uid: true,
+			aufnahme_id: true,
+			geg_einpreisung_id: true,
+			rechnung_id: true
+		}),
+		uid_aufnahme: UUidWithPrefix
+	}),
+	output: z.object({
+		uid: UUidWithPrefix,
+		objekt_uid: UUidWithPrefix,
+		aufnahme_uid: UUidWithPrefix,
+	}),
+	headers: authorizationHeaders,
+	middleware: authorizationMiddleware,
+	async fetch(input, ctx, user) {
+		const aufnahme = await prisma.aufnahme.findUnique({
+			where: {
+				uid: input.uid_aufnahme
+			}
+		})
+
+		if (!aufnahme || aufnahme.benutzer_id !== user.id) {
+			throw new APIError({
+				code: "FORBIDDEN",
+				message: "Aufnahme konnte nicht gefunden werden oder gehört nicht zu diesem Benutzer."
+			})
+		}
+
+		const nachweis = await prisma.bedarfsausweisGewerbe.create({
+			data: {
+				...input.nachweis,
+				benutzer: {
+					connect: {
+						id: user.id,
+					},
+				},
+				aufnahme: {
+					connect: {
+						id: aufnahme.id,
+					},
+				}
+			},
+			select: {
+				uid: true,
+				aufnahme: {
+					select: {
+						uid: true,
+						objekt: {
+							select: {
+								uid: true,
+							},
+						},
+					},
+				},
+			},
+		});
+
+			return {
+				uid: nachweis.uid,
+				objekt_uid: nachweis.aufnahme.objekt.uid,
+				aufnahme_uid: nachweis.aufnahme.uid,
+			};
+	},
+});
+
+export const GET = defineApiRoute({
+	meta: {
+		description: "Gibt eine spezifische GEG Nachweis Anfrage des Benutzers zurück.",
+		tags: ["GEG Nachweis"],
+		headers: {
+			Authorization: {
+				description: "Ein gültiger Authentifizierungstoken",
+				required: true,
+				allowEmptyValue: false,
+				examples: {
+					Bearer: {
+						value: "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...",
+					},
+				},
+			},
+		},
+	},
+	headers: authorizationHeaders,
+	middleware: authorizationMiddleware,
+	async fetch(input, context, user) {
+		const { uid } = context.params;
+
+		const nachweis = await prisma.bedarfsausweisGewerbe.findUnique({
+			where: {
+				uid,
+			},
+			include: {
+				benutzer: true,
+				aufnahme: {
+					include: {
+						events: {
+							include: {
+								benutzer: {
+									select: {
+										uid: true,
+									},
+								},
+							},
+							orderBy: {
+								date: "asc",
+							},
+						},
+					},
+				},
+			},
+		});
+
+		if (
+			!nachweis ||
+			(nachweis.benutzer_id !== null && nachweis.benutzer_id !== user.id)
+		) {
+			// Falls wir den Ausweis nicht finden können, werfen wir einen Fehler
+			throw new APIError({
+				code: "NOT_FOUND",
+				message: "GEG Nachweis konnte nicht gefunden werden.",
+			});
+		}
+
+		return nachweis;
+	},
+});

src/pages/api/rechnung/[uid].ts

@@ -140,7 +140,7 @@ function getPaymentDescription(ausweisart: Enums.Ausweisart) {
 			return "Verbrauchsausweis Gewerbegebäude"
 		case "VerbrauchsausweisWohnen":
 			return "Verbrauchsausweis Wohngebäude"
-		case "GEGNachweisBedarfsausweis":
+		case "BedarfsausweisGewerbe":
 		case "GEGNachweisGewerbe":
 		case "GEGNachweisWohnen":
 			return "GEG Nachweis"

src/pages/api/rechnung/anfordern.ts

@@ -35,6 +35,12 @@ export const PUT = defineApiRoute({
 					uid: input.nachweis_uid
 				}
 			})
+		} else if (ausweisart === Enums.Ausweisart.BedarfsausweisGewerbe) {
+			nachweis = await prisma.bedarfsausweisGewerbe.findUnique({
+				where: {
+					uid: input.nachweis_uid
+				}
+			})
 		} else {
 			throw new APIError({
 				"code": "BAD_REQUEST",
@@ -84,6 +90,23 @@ export const PUT = defineApiRoute({
 					}
 				}
 			})
+		} else if (ausweisart === Enums.Ausweisart.BedarfsausweisGewerbe) {
+			einpreisung = await prisma.gEGEinpreisung.create({
+				data: {
+					...omit(input, ["nachweis_uid"]),
+					status: Enums.Einpreisungsstatus.open,
+					benutzer: {
+						connect: {
+							id: user.id
+						}
+					},
+					bedarfsausweis_gewerbe: {
+						connect: {
+							uid: input.nachweis_uid
+						}
+					}
+				}
+			})
 		}
 
 		await sendGEGAnforderungsMail(nachweis, user)