Merge pull request #505 from IBCornelsen/dev

Updates und Verbesserungen

.github/workflows/dev-pipeline.yml

@@ -1,10 +1,10 @@
-name: Dev Pipeline
+name: Development Pipeline
 
 on:
   pull_request:
-    branches: [main]
+    branches: [dev]
   push:
-    branches: [main]
+    branches: [dev]
 
 jobs:
   deploy:
@@ -26,8 +26,8 @@ jobs:
             export PATH=$HOME/.nvm/versions/node/v22.14.0/bin:$PATH
             echo $PATH
             cd ~/online-energieausweis
-            git reset --hard origin/main
+            git reset --hard origin/dev
             git clean -f -d
-            git pull origin main
+            git pull origin dev
             git status
             make prod

.github/workflows/prod-pipeline.yml

@@ -0,0 +1,33 @@
+name: Production Pipeline
+
+on:
+  pull_request:
+    branches: [main]
+  push:
+    branches: [main]
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - name: Install Bun
+        run: |
+          curl -fsSL https://bun.sh/install | bash
+
+      - uses: appleboy/ssh-action@master
+        with:
+          host: ${{ secrets.PROD_HOST }}
+          username: ${{ secrets.PROD_USERNAME }}
+          password: ${{ secrets.PROD_PASSWORD }}
+          port: 22
+          script: |
+            export PATH=$HOME/.bun/bin:$PATH
+            export PATH=$HOME/.nvm/versions/node/v22.14.0/bin:$PATH
+            echo $PATH
+            cd ~/online-energieausweis
+            git reset --hard origin/main
+            git clean -f -d
+            git pull origin main
+            git status
+            make prod

backup-database.bash

@@ -2,20 +2,27 @@
 
 FILE_NAME=data-dump_`date +%Y-%m-%d"_"%H_%M_%S`.sql.br
 FILE_NAME_COMPLETE=full-dump_`date +%Y-%m-%d"_"%H_%M_%S`.sql.br
-# Wir exportieren die Datenbank und komprimieren sie.
-docker exec -t online-energieausweis-database-1 pg_dump --data-only -U main main | brotli --best > $FILE_NAME
-docker exec -t online-energieausweis-database-1 pg_dumpall -c -U main | brotli --best > $FILE_NAME_COMPLETE
 
 # Das wird benötigt für AWS Ionos Kompatibilität.
 export AWS_REQUEST_CHECKSUM_CALCULATION=when_required
 export AWS_RESPONSE_CHECKSUM_VALIDATION=when_required
 
+# Wir exportieren die Datenbank und komprimieren sie.
 # IMPORTANT: Dieser Befehl benötigt das `ionos` Profil, sonst wird er nicht funktionieren.
 # Das Profil kann mit `aws configure --profile ionos` erstellt werden.
 # Den Key dafür findet man auf https://dcd.ionos.com/latest/?lang=en#/key-management
+docker exec -t online-energieausweis-database-1 pg_dump --data-only -U main main | brotli --best > $FILE_NAME
+
 aws s3 cp $FILE_NAME s3://ibc-db-backup/ --profile ionos --endpoint-url https://s3-eu-central-1.ionoscloud.com --storage-class STANDARD
+
+echo "Uploaded $FILE_NAME"
+
+docker exec -t online-energieausweis-database-1 pg_dumpall -c -U main | brotli --best > $FILE_NAME_COMPLETE
+
 aws s3 cp $FILE_NAME_COMPLETE s3://ibc-db-backup/ --profile ionos --endpoint-url https://s3-eu-central-1.ionoscloud.com --storage-class STANDARD
 
+echo "Uploaded $FILE_NAME_COMPLETE"
+
 # Wir entfernen das Backup
 rm $FILE_NAME
 rm $FILE_NAME_COMPLETE

recover-db-dev.bash

@@ -0,0 +1,41 @@
+#!/bin/bash
+
+# === Configuration ===
+BUCKET_NAME="ibc-db-backup"
+ENDPOINT_URL="https://s3-eu-central-1.ionoscloud.com"
+LOCAL_DOWNLOAD_DIR="./"                    # Where to save the file
+
+# === Get latest file from IONOS S3 bucket ===
+LATEST_FILE=$(aws s3api list-objects-v2 \
+  --bucket "$BUCKET_NAME" \
+	--prefix "data-dump" \
+  --endpoint-url "$ENDPOINT_URL" \
+  --query 'Contents | sort_by(@, &LastModified) | [-1].Key' \
+  --output text)
+
+# === Check if file was found ===
+if [ "$LATEST_FILE" == "None" ] || [ -z "$LATEST_FILE" ]; then
+  echo "❌ No matching .sql.br file found."
+  exit 1
+fi
+
+FILENAME=$(basename "$LATEST_FILE")
+SQL_FILE="${FILENAME%.br}"  # Remove .br suffix
+
+echo "📥 Downloading $LATEST_FILE"
+aws s3 cp "s3://$BUCKET_NAME/$LATEST_FILE" "$LOCAL_DOWNLOAD_DIR" \
+  --endpoint-url "$ENDPOINT_URL"
+
+# === Decompress with Brotli ===
+echo "🗜️ Decompressing $FILENAME -> $SQL_FILE"
+brotli -d "$FILENAME"
+
+# === Import into Postgres inside Docker ===
+echo "🐘 Importing into PostgreSQL (online-energieausweis-database-1:main)"
+docker exec -i "online-energieausweis-database-1" env PGPASSWORD="hHMP8cd^N3SnzGRR" \
+  psql -U "main" -d "main" < "$SQL_FILE"
+
+echo "✅ Import complete."
+
+# === Optional: Clean up
+rm "$FILENAME" "$SQL_FILE"

src/components/Dashboard/DashboardAusweis.svelte

@@ -15,7 +15,9 @@
 	import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants.js";
 	import { Enums, Objekt } from "#lib/client/prisma.js";
 	import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016 } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016.js";
-	import { addNotification } from "#components/Notifications/shared.js";
+	import { addNotification, updateNotification } from "#components/Notifications/shared.js";
+	import { endEnergieVerbrauchVerbrauchsausweis_2016_Client } from "#lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Client.js";
+	import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Client } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Client.js";
 
 	export let ausweis: VerbrauchsausweisWohnenClient | VerbrauchsausweisGewerbeClient | BedarfsausweisWohnenClient;
 	export let aufnahme: AufnahmeKomplettClient;
@@ -86,15 +88,15 @@
 	let calculations = null;
 
 	if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
-		calculations = endEnergieVerbrauchVerbrauchsausweis_2016(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt);
+		calculations = endEnergieVerbrauchVerbrauchsausweis_2016_Client(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt);
 	} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
-		calculations = endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt);
+		calculations = endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Client(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt);
 	}
 
-	async function registriernummerAnfordern() {
+	async function registriernummer() {
 		try {
 			const result = await api.admin.registriernummer.GET.fetch({
-				uid: ausweis.id
+				id: ausweis.id
 			}, {
 				headers: {
 					"Authorization": `Bearer ${Cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)}`
@@ -141,7 +143,13 @@
 		}
 	}
 
-	async function ausweisAusstellen() {
+	async function ausstellen() {
+		const notification = addNotification({
+			message: "Ausweis wird ausgestellt.",
+			subtext: "Der Ausweis wird nun ausgestellt, bitte habe einen Augenblick geduld..",
+			type: "info",
+			timeout: 0,
+		})
 		try {
 			await api.admin.ausstellen.GET.fetch({
 				id_ausweis: ausweis.id
@@ -150,8 +158,17 @@
 					"Authorization": `Bearer ${Cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)}`
 				}
 			})
+
+			ausweis.ausgestellt = true;
+
+			updateNotification(notification, {
+				message: "Ausweis ausgestellt.",
+				subtext: "Der Ausweis wurde erfolgreich ausgestellt.",
+				timeout: 3000,
+				type: "success",
+			})
 		} catch(e) {			
-			addNotification({
+			updateNotification(notification, {
 				message: "Das hat nicht geklappt.",
 				subtext: e as string,
 				timeout: 3000,
@@ -227,7 +244,11 @@
 			{:else if ausweis.bestellt}
 				<span class="bg-primary px-2 py-0.5 text-sm font-semibold rounded-lg text-white">Bestellt</span>
 			{:else}
-				<span class="bg-red-600 px-2 py-0.5 text-sm font-semibold rounded-lg text-white">Gespeichert</span>
+				{#if ausweisart === Enums.Ausweisart.BedarfsausweisGewerbe || ausweisart === Enums.Ausweisart.GEGNachweisWohnen || ausweisart === Enums.Ausweisart.GEGNachweisGewerbe}
+					<span class="bg-red-600 px-2 py-0.5 text-sm font-semibold rounded-lg text-white">Gespeichert</span>
+				{:else}
+					<span class="bg-red-600 px-2 py-0.5 text-sm font-semibold rounded-lg text-white">Angefordert</span>
+				{/if}
 			{/if}
 		</div>
 		<div class="badge badge-accent font-semibold text-black text-m">{objekt.adresse}</div>
@@ -244,7 +265,7 @@
 			<p class="text-sm font-semibold">Sie haben Hilfe zu diesem Ausweis angefordert. Sie werden innerhalb der nächsten 48 Stunden über die hinterlegte Telefonnummer vom IB Cornelsen kontaktiert.</p>
 			{:else if ausweis.ausweistyp === Enums.AusweisTyp.Offline || ausweis.ausweistyp === Enums.AusweisTyp.OfflineXL}
 			<p class="text-sm font-semibold">Sie haben die offline Variant zu diesem Ausweis angefordert. Bitte übermitteln Sie uns die letzten drei Jahre der Energieabrechnungen Ihres Energieversorgers.</p>
-			{:else}
+			{:else if !ausweis.ausgestellt}
 			<p class="text-sm font-semibold">Der Ausweis wurde von Ihnen freigegeben und befindet sich in Prüfung vom IB Cornelsen</p>
 			{/if}
 		{/if}
@@ -392,9 +413,9 @@
 			{/if}
 
 			{#if benutzer.rolle === Enums.BenutzerRolle.ADMIN}
-				<button class="button text-sm" on:click={ausweisAusstellen}>A</button>
+				<button class="button text-sm" on:click={ausstellen}>A</button>
 				<button class="button text-sm" on:click={stornieren}>S</button>
-				<button class="button text-sm" on:click={registriernummerAnfordern}>R</button>
+				<button class="button text-sm" on:click={registriernummer}>R</button>
 			{/if}
 			
 			<a

src/components/Dashboard/DashboardObjekt.svelte

@@ -47,19 +47,6 @@
 				<div class="text-sm text-center">Energieausweis</div>
 			</a>
 		{/if}
-		{#if objekt.aufnahmen.at(-1)?.bedarfsausweise_wohnen.length}
-			{@const ausweis = objekt.aufnahmen.at(-1)?.bedarfsausweise_wohnen.at(-1)}
-			<a href="/pdf/ansichtsausweis?id={ausweis.id}" target="_blank">
-				<div class="inline-block border rounded-lg bg-white">
-					{#if ausweis?.ausgestellt}
-						<img src="/images/dashboard/AusweisHaken.svg" class="h-auto w-auto max-h-[150px] max-w-full object-contain p-1" alt="Energieausweis ausgestellt">	
-					{:else}
-						<img src="/images/dashboard/AusweisKreuz.svg" class="h-auto w-auto max-h-[150px] max-w-full object-contain p-1" alt="Energieausweis ausgestellt">	
-					{/if}
-				</div>
-				<div class="text-sm text-center">Energieausweis</div>
-			</a>
-		{/if}
 	</div>
 	<div class="flex flex-col gap-4">
 		{#each objekt.aufnahmen as aufnahme}

src/components/Notifications/shared.ts

@@ -28,6 +28,12 @@ export function updateNotification(uid: string, updater: Partial<Notification>)
 		value[uid] = { ...defaults, ...value[uid], ...updater } as Notification;
 		return value;
 	})
+
+	if (updater.timeout) {
+		setTimeout(() => {
+			deleteNotification(uid);
+		}, updater.timeout);
+	}
 }
 
 export function addNotification(notification: Partial<Notification>): string {

src/lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016.ts

@@ -2,7 +2,8 @@ import { AufnahmeClient, ObjektClient, VerbrauchsausweisGewerbeClient } from "#c
 import { getKlimafaktoren } from "#lib/Klimafaktoren.js";
 import { getHeizwertfaktor } from "#lib/server/Heizwertfaktor.js";
 import moment from "moment";
-import bauwerkskatalog from "./bauwerkskatalog.json" assert { type: "json" }
+import bauwerkskatalog from "./bauwerkskatalog.json" with { type: "json" }
+import { getKlimafaktorenServer } from "#lib/server/klimafaktoren.js";
 
 function vergleichsWertNichtWohngebaeude(ausweis: VerbrauchsausweisGewerbeClient, aufnahme: AufnahmeClient) {
 	let tekWerte = new Array(8).fill(0);
@@ -59,43 +60,13 @@ function vergleichsWertNichtWohngebaeude(ausweis: VerbrauchsausweisGewerbeClient
  * @param Ausweis ausweis Ein Ausweis dessen Energiebedarf berechnet werden soll
  * @return VerbrauchsausweisGewerbeCalculationResult
  */
-export async function endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis: VerbrauchsausweisGewerbeClient, aufnahme: AufnahmeClient, objekt: ObjektClient) {
+export async function endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis: VerbrauchsausweisGewerbeClient, aufnahme: AufnahmeClient, objekt: ObjektClient, klimafaktoren: { month: number, year: number, klimafaktor: number }[]) {
-		if (!aufnahme || !objekt || !ausweis) {
+		if (!aufnahme || !objekt || !ausweis || !klimafaktoren) {
 			return null;
 		}
 
 		const nutzflaeche = aufnahme.nutzflaeche || 0;
 
-		let startdatum = moment(ausweis.startdatum);
-	
-		let klimafaktoren: Awaited<ReturnType<typeof getKlimafaktoren>> = [{
-			month: startdatum.month(),
-			year: startdatum.year(),
-			klimafaktor: 1
-		},
-		{
-			month: startdatum.month(),
-			year: startdatum.year() + 1,
-			klimafaktor: 1
-		},
-		{
-			month: startdatum.month(),
-			year: startdatum.year() + 2,
-			klimafaktor: 1
-		}];
-	
-		try {
-			const response = await getKlimafaktoren(ausweis.startdatum, objekt.plz)
-			
-			if (response) {
-				klimafaktoren = response
-			}
-		} catch (e) {
-			// TODO: Entweder setzen wir hier mit falschen Klimafaktoren fort, oder wir geben null zurück.
-			// Im Moment setzen wir einfach fort, aber das ist nicht unbedingt die beste Lösung.
-			// return null
-		}
-
 	// Endenergieverbrauch
 	// Um den EEV auszurechnen, müssen die Verbräuche zu kWh konvertiert werden.
 	let brennstoff_1 = { coe: 0, energietraeger: "", einheit: "", umrechnungsfaktor: 0, primaerenergiefaktor: 0 }, brennstoff_2 = { coe: 0, energietraeger: "", einheit: "", umrechnungsfaktor: 0, primaerenergiefaktor: 0 };

src/lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Client.ts

@@ -0,0 +1,39 @@
+import moment from "moment";
+import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016 } from "./VerbrauchsausweisGewerbe_2016.js";
+import { Aufnahme, Objekt, VerbrauchsausweisGewerbe } from "#lib/server/prisma.js";
+import { getKlimafaktoren } from "#lib/Klimafaktoren.js";
+
+export async function endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Client(
+	ausweis: VerbrauchsausweisGewerbe,
+	aufnahme: Aufnahme,
+	objekt: Objekt,
+) {
+	const startdatum = moment(ausweis.startdatum);
+	let klimafaktoren = await getKlimafaktoren(
+		objekt.plz as string,
+		startdatum.toDate(),
+		startdatum.add(2, "years").toDate()
+	);
+
+	if (!klimafaktoren || klimafaktoren.length === 0) {
+		klimafaktoren = [
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year"),
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 1,
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 2,
+			},
+		];
+	}
+
+	return await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis, aufnahme, objekt, klimafaktoren)
+}

src/lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Server.ts

@@ -0,0 +1,39 @@
+import moment from "moment";
+import { getKlimafaktorenServer } from "#lib/server/klimafaktoren.js";
+import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016 } from "./VerbrauchsausweisGewerbe_2016.js";
+import { Aufnahme, Objekt, VerbrauchsausweisGewerbe } from "#lib/server/prisma.js";
+
+export async function endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Server(
+	ausweis: VerbrauchsausweisGewerbe,
+	aufnahme: Aufnahme,
+	objekt: Objekt,
+) {
+	const startdatum = moment(ausweis.startdatum);
+	let klimafaktoren = await getKlimafaktorenServer(
+		objekt.plz as string,
+		startdatum.toDate(),
+		startdatum.add(2, "years").toDate()
+	);
+
+	if (klimafaktoren.length === 0) {
+		klimafaktoren = [
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year"),
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 1,
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 2,
+			},
+		];
+	}
+
+	return await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis, aufnahme, objekt, klimafaktoren)
+}

src/lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016.ts

@@ -1,8 +1,6 @@
 import { AufnahmeClient, ObjektClient, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types.js";
-import { getKlimafaktoren } from "#lib/Klimafaktoren.js";
 import { getHeizwertfaktor } from "#lib/server/Heizwertfaktor.js";
 import { Enums } from "#lib/client/prisma.js";
-import moment from "moment";
 
 export function energetischeNutzflaecheVerbrauchsausweisWohnen_2016(
 	ausweis: VerbrauchsausweisWohnenClient,
@@ -24,43 +22,13 @@ export function energetischeNutzflaecheVerbrauchsausweisWohnen_2016(
 export async function endEnergieVerbrauchVerbrauchsausweis_2016(
 	ausweis: VerbrauchsausweisWohnenClient,
 	aufnahme: AufnahmeClient,
-	objekt: ObjektClient
+	objekt: ObjektClient,
+	klimafaktoren: {month: number, year: number, klimafaktor: number}[]
 ) {
-	if (!aufnahme || !objekt || !ausweis) {
+	if (!aufnahme || !objekt || !ausweis || !klimafaktoren) {
 		return null;
 	}
 
-	let startdatum = moment(ausweis.startdatum);
-
-	let klimafaktoren: Awaited<ReturnType<typeof getKlimafaktoren>> = [{
-		month: startdatum.month(),
-		year: startdatum.year(),
-		klimafaktor: 1
-	},
-	{
-		month: startdatum.month(),
-		year: startdatum.year() + 1,
-		klimafaktor: 1
-	},
-	{
-		month: startdatum.month(),
-		year: startdatum.year() + 2,
-		klimafaktor: 1
-	}];
-
-	try {
-		const response = await getKlimafaktoren(ausweis.startdatum, objekt.plz)
-		
-		if (response) {
-			klimafaktoren = response
-		}
-	} catch (e) {
-		// TODO: Entweder setzen wir hier mit falschen Klimafaktoren fort, oder wir geben null zurück.
-		// Im Moment setzen wir einfach fort, aber das ist nicht unbedingt die beste Lösung.
-		// return null
-	}
-	
-
 	// Endenergieverbrauch
 	// Um den EEV auszurechnen, müssen die Verbräuche zu kWh konvertiert werden.
 	let brennstoff_1 = getHeizwertfaktor(

src/lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Client.ts

@@ -0,0 +1,43 @@
+import {
+	VerbrauchsausweisWohnenClient,
+	AufnahmeClient,
+	ObjektClient,
+} from "#components/Ausweis/types.js";
+import { getKlimafaktoren } from "#lib/Klimafaktoren.js";
+import moment from "moment";
+import { endEnergieVerbrauchVerbrauchsausweis_2016 } from "./VerbrauchsausweisWohnen_2016.js";
+
+export async function endEnergieVerbrauchVerbrauchsausweis_2016_Client(
+	ausweis: VerbrauchsausweisWohnenClient,
+	aufnahme: AufnahmeClient,
+	objekt: ObjektClient,
+) {
+	const startdatum = moment(ausweis.startdatum);
+	let klimafaktoren = await getKlimafaktoren(
+		objekt.plz as string,
+		startdatum.toDate(),
+		startdatum.add(2, "years").toDate()
+	);
+
+	if (!klimafaktoren || klimafaktoren.length === 0) {
+		klimafaktoren = [
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year"),
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 1,
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 2,
+			},
+		];
+	}
+
+	return await endEnergieVerbrauchVerbrauchsausweis_2016(ausweis, aufnahme, objekt, klimafaktoren)
+}

src/lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Server.ts

@@ -0,0 +1,48 @@
+import {
+	VerbrauchsausweisWohnenClient,
+	AufnahmeClient,
+	ObjektClient,
+} from "#components/Ausweis/types.js";
+import moment from "moment";
+import { endEnergieVerbrauchVerbrauchsausweis_2016 } from "./VerbrauchsausweisWohnen_2016.js";
+import { getKlimafaktorenServer } from "#lib/server/klimafaktoren.js";
+
+export async function endEnergieVerbrauchVerbrauchsausweis_2016_Server(
+	ausweis: VerbrauchsausweisWohnenClient,
+	aufnahme: AufnahmeClient,
+	objekt: ObjektClient
+) {
+	const startdatum = moment(ausweis.startdatum);
+	let klimafaktoren = await getKlimafaktorenServer(
+		objekt.plz as string,
+		startdatum.toDate(),
+		startdatum.add(2, "years").toDate()
+	);
+
+	if (klimafaktoren.length === 0) {
+		klimafaktoren = [
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year"),
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 1,
+			},
+			{
+				klimafaktor: 1,
+				month: startdatum.get("m"),
+				year: startdatum.get("year") + 2,
+			},
+		];
+	}
+
+	return await endEnergieVerbrauchVerbrauchsausweis_2016(
+		ausweis,
+		aufnahme,
+		objekt,
+		klimafaktoren
+	);
+}

src/lib/Berechnungen/endEnergieVerbrauch.ts

@@ -1,13 +0,0 @@
-import type { VerbrauchsausweisWohnen } from "#lib/client/prisma";
-import { endEnergieVerbrauchVerbrauchsausweis_2016 } from "./VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016.js";
-import { AufnahmeClient, ObjektClient } from "#components/Ausweis/types.js";
-
-export async function endEnergieVerbrauch(ausweis: VerbrauchsausweisWohnen, aufnahme: AufnahmeClient, objekt: ObjektClient): Promise<number> {
-	const result = await endEnergieVerbrauchVerbrauchsausweis_2016(ausweis, aufnahme, objekt);
-
-	if (!result) {
-		return 0;
-	}
-
-	return result.endEnergieVerbrauchGesamt;
-}

src/lib/Klimafaktoren.ts

@@ -18,8 +18,6 @@ export const getKlimafaktoren = memoize(async (date: Date, plz: string) => {
 		});
 		return response;
 	} catch (e) {
-		console.log(e);
-		
 		return null;
 	}
 });

src/lib/constants.ts

@@ -112,4 +112,4 @@ export const SERVICES: Record<
 };
 
 export const BASE_URI = process.env.NODE_ENV == "production" ? "https://online-energieausweis.org" : "http://localhost:3000";
-export const LEX_OFFICE_API_KEY = process.env.NODE_ENV == "production" ? "iwQLCU_ZAq6bVV7hmR8RO8MiC8Q" : "znjmkmbA3Hbx9dC7wdKp7TnOf1pcRl_tCUwEBZys7bj-QRPG"
+export const LEX_OFFICE_API_KEY = process.env.NODE_ENV == "production" ? "iwQLCU_ZAq6bVV7hmR8RO8MiC8Q" : "iwQLCU_ZAq6bVV7hmR8RO8MiC8Q"

src/lib/pdf/pdfDatenblattVerbrauchsausweisGewerbe.ts

@@ -4,8 +4,8 @@ import { PDFDocument, StandardFonts } from "pdf-lib";
 import { xml2pdf } from "./elements/xml2pdf.js";
 import moment from "moment";
 import { Enums, Heizungsstatus } from "#lib/server/prisma.js";
-import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016 } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016.js";
 import { copyPage } from "./utils/copyPage.js";
+import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Server } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Server.js";
 
 /* -------------------------------- Pdf Tools ------------------------------- */
 
@@ -18,7 +18,7 @@ export async function pdfDatenblattVerbrauchsausweisGewerbe(ausweis: Verbrauchsa
 	
 	// const template = VerbrauchsausweisWohnen2016Template as Template;
 
-	const berechnungen = await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis, aufnahme, objekt);
+	const berechnungen = await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Server(ausweis, aufnahme, objekt);
 
 	const height = pages[0].getHeight()
 	const width = pages[0].getWidth()

src/lib/pdf/pdfDatenblattVerbrauchsausweisWohnen.ts

@@ -6,6 +6,7 @@ import { xml2pdf } from "./elements/xml2pdf.js";
 import moment from "moment";
 import { Enums, Heizungsstatus } from "#lib/server/prisma.js";
 import { copyPage } from "./utils/copyPage.js";
+import { endEnergieVerbrauchVerbrauchsausweis_2016_Server } from "#lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Server.js";
 
 /* -------------------------------- Pdf Tools ------------------------------- */
 
@@ -19,7 +20,7 @@ export async function pdfDatenblattVerbrauchsausweisWohnen(ausweis: Verbrauchsau
 	
 	// const template = VerbrauchsausweisWohnen2016Template as Template;
 
-	const berechnungen = await endEnergieVerbrauchVerbrauchsausweis_2016(ausweis, aufnahme, objekt);
+	const berechnungen = await endEnergieVerbrauchVerbrauchsausweis_2016_Server(ausweis, aufnahme, objekt);
 
 	const height = pages[0].getHeight()
 	const width = pages[0].getWidth()
@@ -332,8 +333,5 @@ export async function pdfDatenblattVerbrauchsausweisWohnen(ausweis: Verbrauchsau
 	await layoutPage2.draw(pages[1], 0, pages[1].getHeight())
 	await layoutPage3.draw(pages[2], 0, pages[2].getHeight())
 
-	console.log("DONE");
-	
-
 	return pdf.save();
 }

src/lib/pdf/pdfVerbrauchsausweisGewerbe.ts

@@ -1,5 +1,4 @@
 import { AufnahmeClient, BenutzerClient, BildClient, ObjektClient, VerbrauchsausweisGewerbeClient } from "#components/Ausweis/types.js";
-import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016 } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016.js";
 import { getEmpfehlungen } from "#lib/XML/getEmpfehlungen.js";
 import { Enums } from "#lib/server/prisma.js";
 import * as fs from "fs"
@@ -7,18 +6,19 @@ import moment from "moment";
 import { PDFDocument, PDFFont, PDFImage, PDFPage, StandardFonts } from "pdf-lib";
 import { addCheckMark } from "./utils/checkbox.js";
 import { addText } from "./utils/text.js";
-import { addAnsichtsausweisLabel, addDatumGEG } from "./utils/helpers.js";
+import { addAnsichtsausweisLabel, addDatumGEG, addRegistriernummer } from "./utils/helpers.js";
 import { getS3File } from "#lib/s3.js";
+import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Server } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Server.js";
 
 
-export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewerbeClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient) {
+export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewerbeClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient, vorschau = true) {
 	const VerbrauchsausweisWohnenGEG2024PDF = fs.readFileSync(new URL("../../../public/pdf/templates/GEG24_Nichtwohngebaeude.pdf", import.meta.url), "base64");
 	const pdf = await PDFDocument.load(VerbrauchsausweisWohnenGEG2024PDF)
 	const pages = pdf.getPages()
 	
 	// const template = VerbrauchsausweisWohnen2016Template as Template;
 
-	const berechnungen = await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016(ausweis, aufnahme, objekt);
+	const berechnungen = await endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Server(ausweis, aufnahme, objekt);
 	
 	const empfehlungen = getEmpfehlungen(ausweis, aufnahme, objekt)
 
@@ -612,10 +612,16 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 	}
 	
 
-	for (const page of pages) {
+	for (let i = 0; i < pages.length; i++) {
-		addAnsichtsausweisLabel(page, font)
+			const page = pages[i];
-		addDatumGEG(page, font)
+			if (vorschau) {
-	}
+				addAnsichtsausweisLabel(page, font)
+			}
+			addDatumGEG(page, font)
+			if (i !== pages.length - 1) {
+				addRegistriernummer(page, font, ausweis.registriernummer || "")
+			}
+		}
 	
 
 	

src/lib/pdf/pdfVerbrauchsausweisWohnen.ts

@@ -1,5 +1,4 @@
 import { AufnahmeClient, BenutzerClient, BildClient, ObjektClient, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types.js";
-import { endEnergieVerbrauchVerbrauchsausweis_2016 } from "#lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016.js";
 import { getEmpfehlungen } from "#lib/XML/getEmpfehlungen.js";
 import { Enums } from "#lib/server/prisma.js";
 import * as fs from "fs"
@@ -7,19 +6,21 @@ import moment from "moment";
 import { PDFDocument, PDFFont, PDFImage, PDFPage, StandardFonts } from "pdf-lib";
 import { addCheckMark } from "./utils/checkbox.js";
 import { addText } from "./utils/text.js";
-import { addAnsichtsausweisLabel, addDatumGEG } from "./utils/helpers.js";
+import { addAnsichtsausweisLabel, addDatumGEG, addRegistriernummer } from "./utils/helpers.js";
 import { getS3File } from "#lib/s3.js";
+import { endEnergieVerbrauchVerbrauchsausweis_2016_Server } from "#lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Server.js";
 
 /* -------------------------------- Pdf Tools ------------------------------- */
 
-export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohnenClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient) {
+export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohnenClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient, vorschau = true) {
 	const VerbrauchsausweisWohnenGEG2024PDF = fs.readFileSync(new URL("../../../public/pdf/templates/GEG24_Wohngebaeude_ohne_pfeile.pdf", import.meta.url), "base64");
 	const pdf = await PDFDocument.load(VerbrauchsausweisWohnenGEG2024PDF)
 	const pages = pdf.getPages()
 	
 	// const template = VerbrauchsausweisWohnen2016Template as Template;
 
-	const berechnungen = await endEnergieVerbrauchVerbrauchsausweis_2016(ausweis, aufnahme, objekt);
+	const berechnungen = await endEnergieVerbrauchVerbrauchsausweis_2016_Server(ausweis, aufnahme, objekt);
+	
 	const empfehlungen = getEmpfehlungen(ausweis, aufnahme, objekt)
 
 	const height = pages[0].getHeight()
@@ -591,9 +592,15 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 		addEmpfehlung(empfehlung.anlagenteil, empfehlung.description, true, empfehlung.amortisationszeit, empfehlung.kosten)
 	}
 
-	for (const page of pages) {
+	for (let i = 0; i < pages.length; i++) {
-		addAnsichtsausweisLabel(page, font)
+		const page = pages[i];
+		if (vorschau) {
+			addAnsichtsausweisLabel(page, font)
+		}
 		addDatumGEG(page, font)
+		if (i !== pages.length - 1) {
+			addRegistriernummer(page, font, ausweis.registriernummer || "")
+		}
 	}
 	
 	return pdf.save();

src/lib/pdf/utils/helpers.ts

@@ -22,3 +22,13 @@ export function addAnsichtsausweisLabel(page: PDFPage, font: PDFFont) {
 		opacity: 0.3,
 	});
 }
+
+
+export function addRegistriernummer(page: PDFPage, font: PDFFont, registriernummer: string) {
+	page.drawText(registriernummer, {
+		x: 435,
+		y: page.getHeight() - 113,
+		size: 10,
+		font,
+	});
+}

src/lib/server/ausweis.ts

@@ -31,15 +31,15 @@ export function getPrismaAusweisAdapter(id: string) {
  * Gibt den richtigen Ansichtsausweis basierend auf der Ausweisart zurück.
  * @param ausweis 
  */
-export async function getAnsichtsausweis(ausweis: VerbrauchsausweisWohnenClient | VerbrauchsausweisGewerbeClient | BedarfsausweisWohnenClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient, ausweisart = getAusweisartFromId(ausweis.id)) {
+export async function getAnsichtsausweis(ausweis: VerbrauchsausweisWohnenClient | VerbrauchsausweisGewerbeClient | BedarfsausweisWohnenClient, aufnahme: AufnahmeClient, objekt: ObjektClient, bilder: BildClient[], user: BenutzerClient, vorschau: boolean = true, ausweisart = getAusweisartFromId(ausweis.id)) {
 	if (!ausweisart) {
 		return null
 	}
 
 	if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
-		return await pdfVerbrauchsausweisWohnen(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt, bilder, user)
+		return await pdfVerbrauchsausweisWohnen(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt, bilder, user, vorschau)
 	} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
-		return await pdfVerbrauchsausweisGewerbe(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt, bilder, user)
+		return await pdfVerbrauchsausweisGewerbe(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt, bilder, user, vorschau)
 	}
 
 	return null

src/lib/server/db.ts

@@ -8,6 +8,26 @@ export async function getVerbrauchsausweisWohnen(id: string): Promise<Verbrauchs
 	})
 }
 
+export async function getVerbrauchsausweisWohnenKomplett(id: string) {
+	return await prisma.verbrauchsausweisWohnen.findUnique({
+		where: {
+			id
+		},
+		include: {
+			aufnahme: {
+				include: {
+					bilder: true,
+					objekt: {
+						include: {
+							benutzer: true,
+						},
+					},
+				},
+			},
+		},
+	})
+}
+
 export async function getVerbrauchsausweisGewerbe(id: string): Promise<VerbrauchsausweisGewerbe | null> {
 	return await prisma.verbrauchsausweisGewerbe.findUnique({
 		where: {
@@ -16,6 +36,26 @@ export async function getVerbrauchsausweisGewerbe(id: string): Promise<Verbrauch
 	})
 }
 
+export async function getVerbrauchsausweisGewerbeKomplett(id: string) {
+	return await prisma.verbrauchsausweisGewerbe.findUnique({
+		where: {
+			id
+		},
+		include: {
+			aufnahme: {
+				include: {
+					bilder: true,
+					objekt: {
+						include: {
+							benutzer: true,
+						},
+					},
+				},
+			},
+		},
+	})
+}
+
 export async function getBedarfsausweisWohnen(id: string): Promise<BedarfsausweisWohnen | null> {
 	return await prisma.bedarfsausweisWohnen.findUnique({
 		where: {
@@ -24,6 +64,26 @@ export async function getBedarfsausweisWohnen(id: string): Promise<Bedarfsauswei
 	})
 }
 
+export async function getBedarfsausweisWohnenKomplett(id: string) {
+	return await prisma.bedarfsausweisWohnen.findUnique({
+		where: {
+			id
+		},
+		include: {
+			aufnahme: {
+				include: {
+					bilder: true,
+					objekt: {
+						include: {
+							benutzer: true,
+						},
+					},
+				},
+			},
+		},
+	})
+}
+
 export async function getBedarfsausweisGewerbe(id: string): Promise<BedarfsausweisGewerbe | null> {
 	return await prisma.bedarfsausweisGewerbe.findUnique({
 		where: {

src/lib/server/invoice.ts

@@ -0,0 +1,191 @@
+import { getAusweisartFromId } from "#components/Ausweis/types.js";
+import moment from "moment";
+import { createLexOfficeCustomer } from "./lexoffice.js";
+import { Enums, prisma, Rechnung, VerbrauchsausweisWohnen } from "./prisma.js";
+import { LEX_OFFICE_API_KEY, PRICES } from "#lib/constants.js";
+
+export function createLineItem(name: string, preis: number, steuer: number) {
+	return {
+		"type": "custom",
+		"name": name,
+		"description": "",
+		"quantity": 1,
+		"lineItemAmount": preis,
+		"unitName": name,
+		"unitPrice": {
+			"currency": "EUR",
+			"grossAmount": preis,
+			"taxRatePercentage": steuer
+		}
+	};
+}
+
+export function addedServicesNeu(data: any, rechnung: Rechnung, steuer: number){
+	if (rechnung.services.includes(Enums.Service.Qualitaetsdruck)){
+		data["lineItems"].push(createLineItem('Zusatzservice Postversand', 9, steuer))
+	}
+	if (rechnung.services.includes(Enums.Service.Aushang)){
+		data["lineItems"].push(createLineItem('Zusatzservice Aushang', 10, steuer))
+	}
+	if (rechnung.services.includes(Enums.Service.SameDay)){
+		data["lineItems"].push(createLineItem('Zusatzservice Same Day Service', 29, steuer))
+	}
+	if (rechnung.services.includes(Enums.Service.Telefonberatung)){
+		data["lineItems"].push(createLineItem('Zusatzservice Telefonische Beratung', 75, steuer))
+	}
+
+	return data;
+}
+
+/**
+ * Erstellt eine Rechnung in LexOffice und gibt die ID zurück.
+ * Die Preise basieren auf den in der Konstante `__PRICES__` definierten Preisen.
+ * @param Ausweis ausweis
+ * @param Rechnung $rechnung
+ * @return array
+ * @throws Error
+ */
+export async function createInvoice(ausweis: VerbrauchsausweisWohnen, rechnung: Rechnung) {
+	if (!ausweis.benutzer_id) {
+		throw new Error("Benutzer ist nicht vorhanden")
+	}
+
+	const user = await prisma.benutzer.findUnique({
+		where: {
+			id: ausweis.benutzer_id
+		}
+	})
+	
+	if (!user) {
+		throw new Error("Nutzer existiert nicht!");
+	} else if (user.lex_office_id == null) {
+		// User has no valid lex_id
+		const lex_office_id = await createLexOfficeCustomer(user);
+
+		user.lex_office_id = lex_office_id;
+		
+		await prisma.benutzer.update({
+			where: {
+				id: user.id
+			},
+			data: {
+				lex_office_id: user.lex_office_id
+			}
+		})
+	}
+
+	const ausweisart = getAusweisartFromId(ausweis.id); 
+
+	let data = {
+		"voucherDate": moment().format('YYYY-MM-DDTHH:mm:ss.SSSZ'),
+		"taxConditions": {
+			"taxType": "gross"
+		},
+		"shippingConditions": {
+			"shippingType": "none"
+		},
+		"address": {
+			"contactId": user.lex_office_id,
+			"name": rechnung.empfaenger || "----",
+			"street": rechnung.strasse,
+			"city": rechnung.ort,
+			"zip": rechnung.plz,
+			"countryCode": "DE",
+			"supplement": rechnung.zusatzzeile
+		},
+		"lineItems": [],
+		"totalPrice": {
+			"currency": "EUR",
+			"totalGrossAmount": rechnung.betrag,
+		},
+		"title": "Rechnung",
+		"introduction": "Ihren Energieausweis (Ausweis ID {ausweis.id}) stellen wir Ihnen hiermit in Rechnung",
+		"remark": "Vielen Dank für Ihren Einkauf."
+	};
+
+	if (rechnung.status == Enums.Rechnungsstatus.paid) {
+		const types = {
+		[Enums.Bezahlmethoden.paypal]: "PayPal",
+		[Enums.Bezahlmethoden.creditcard]: "Kreditkarte",
+		[Enums.Bezahlmethoden.sofort]: "Sofortüberweisung",
+		[Enums.Bezahlmethoden.giropay]: "Giropay",
+		};
+
+		const type = types[rechnung.bezahlmethode];
+
+		data["introduction"] = `Vielen Dank für Ihren Einkauf (Ausweis ID ${ausweis.id}). Ihre Rechnung haben sie bereits mit ${type} bezahlt.`;
+	}
+
+	const tax_rate = 19;
+
+	if (rechnung.betrag == 15) {
+		// Korrektur alleinstehend
+		data["lineItems"].push(createLineItem("Service Korrektur anfordern", rechnung.betrag, 19));
+	} else if (rechnung.betrag == 476) {
+		data["lineItems"].push(createLineItem("GEG Berechnung Wohngebäude", rechnung.betrag, 19));
+	} else if (rechnung.betrag > 400 && rechnung.betrag != 476) {
+		data["lineItems"].push(createLineItem("Bedarfsausweis Gewerbe", rechnung.betrag, 19));
+	} else if (ausweisart == Enums.Ausweisart.VerbrauchsausweisWohnen) {
+		if (ausweis.ausweistyp == Enums.AusweisTyp.Standard) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Online (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Standard, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Beratung) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Online (Vorprüfung negativ) (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Beratung, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Offline) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Offline (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Offline, 19));
+		}
+	} else if (ausweisart == Enums.Ausweisart.BedarfsausweisWohnen) {
+		if (ausweis.ausweistyp == Enums.AusweisTyp.Standard) {
+			data["lineItems"].push(createLineItem(`Bedarfsausweis Online (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Standard, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Beratung) {
+			data["lineItems"].push(createLineItem(`Bedarfsausweis Online (Vorprüfung negativ) (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Beratung, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Offline) {
+			data["lineItems"].push(createLineItem(`Bedarfsausweis Offline (ID ${ausweis.id})`, PRICES.VerbrauchsausweisWohnen.Offline, 19));
+		}
+	} else if (ausweisart == Enums.Ausweisart.VerbrauchsausweisGewerbe) {
+		if (ausweis.ausweistyp == Enums.AusweisTyp.Standard) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Nichtwohngebäude Online (ID ${ausweis.id})`, PRICES.VerbrauchsausweisGewerbe.Standard, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Beratung) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Nichtwohngebäude Online (Vorprüfung negativ) (ID ${ausweis.id})`, PRICES.VerbrauchsausweisGewerbe.Beratung, 19));
+		} else if (ausweis.ausweistyp == Enums.AusweisTyp.Offline) {
+			data["lineItems"].push(createLineItem(`Verbrauchsausweis Nichtwohngebäude Offline (ID ${ausweis.id})`, PRICES.VerbrauchsausweisGewerbe.Offline, 19));
+		}
+	}
+
+	data = addedServicesNeu(data, rechnung, 19);
+
+
+	const response = await fetch("https://api.lexoffice.io/v1/invoices?finalize=true", {
+		method: "POST",
+		headers: {
+			Accept: `application/json`,
+			Authorization: `Bearer ${LEX_OFFICE_API_KEY}`,
+			"Content-Type": "application/json"
+		},
+		body: JSON.stringify(data)
+	})
+
+	if (response.status == 400) {
+		throw new Error("Fehler beim Absenden der Request.")
+	}
+
+	const invoice = await response.json()
+
+	// Wir müssen den Ausweis nun wieder abfragen, um die erstellte Rechnungsnummer zu bekommen.
+	const response_id = invoice["id"];
+
+	const request = await fetch(`https://api.lexoffice.io/v1/invoices/${response_id}`, {
+		method: "GET",
+		headers: {
+			Accept: `application/json`,
+			Authorization: `Bearer ${LEX_OFFICE_API_KEY}`,
+			"Content-Type": "application/json"
+		}
+	})
+
+	const abfrage_response = await request.json()
+
+	return {
+		id: invoice["id"],
+		voucherNumber: abfrage_response["voucherNumber"]
+	}
+}

src/lib/server/klimafaktoren.ts

@@ -0,0 +1,47 @@
+import moment from "moment";
+import { prisma } from "./prisma.js";
+
+export async function getKlimafaktorenServer(plz: string, startdatum: Date, enddatum: Date) {
+	const start = moment(startdatum);
+	const end = moment(enddatum);
+
+	if (start.isSameOrAfter(end)) {
+		return []
+	}
+
+	const intervals = [];
+
+	let currentDate = start.clone();
+	while (currentDate.isSameOrBefore(end)) {
+		let copy = currentDate.clone();
+		intervals.push(copy);
+		currentDate.add(1, "year");
+	}
+
+	let klimafaktoren = await prisma.klimafaktoren.findMany({
+		where: {
+			plz,
+			month: intervals[0].month(),
+			OR: intervals.map((date) => {
+				return {
+					year: date.year(),
+				};
+			}),
+		},
+	});
+
+	if (!klimafaktoren) {
+		return []
+	}
+
+	// NOTE: Sollten wir hier lieber den Output padden und trotzdem die gefundenen zurückgeben?
+	if (klimafaktoren.length !== intervals.length) {
+		return []
+	}
+
+	return klimafaktoren.map((klimafaktor) => ({
+		month: klimafaktor.month,
+		year: klimafaktor.year,
+		klimafaktor: klimafaktor.klimafaktor,
+	}));
+}

src/lib/server/lexoffice.ts

@@ -1,10 +1,10 @@
 import { VerbrauchsausweisWohnenClient } from "#components/Ausweis/types.js";
 import { LEX_OFFICE_API_KEY } from "#lib/constants.js";
-import { Aufnahme, BedarfsausweisWohnen, Benutzer, Rechnung, VerbrauchsausweisGewerbe, VerbrauchsausweisWohnen } from "#lib/client/prisma";
+import { Aufnahme, BedarfsausweisWohnen, Benutzer, Rechnung, VerbrauchsausweisGewerbe, VerbrauchsausweisWohnen } from "#lib/client/prisma.js";
-import { prisma } from "#lib/server/prisma";
+import { prisma } from "#lib/server/prisma.js";
 import moment from "moment";
 
-export function lexOfficeAnfrageSenden(ausweis: VerbrauchsausweisWohnen | BedarfsausweisWohnen | VerbrauchsausweisGewerbe, options: {
+export async function lexOfficeAnfrageSenden(ausweis: VerbrauchsausweisWohnen | BedarfsausweisWohnen | VerbrauchsausweisGewerbe, options: {
 	bezeichnung: string,
 	positionstext: string,
 	preis: number,
@@ -103,149 +103,149 @@ export function lexOfficeAnfrageSenden(ausweis: VerbrauchsausweisWohnen | Bedarf
 		throw new Error(`Ein Fehler ist aufgetreten: ${pdfResult.message}`);
 	}
 	
-	$pdf_id = $render_response["documentFileId"];
+	// $pdf_id = $render_response["documentFileId"];
 	
-	db()->execute("UPDATE Angebotsanfragen SET
+	// db()->execute("UPDATE Angebotsanfragen SET
-	Adresse_Objekt = :Adresse_Objekt,
+	// Adresse_Objekt = :Adresse_Objekt,
-	PLZ_Objekt = :PLZ_Objekt,
+	// PLZ_Objekt = :PLZ_Objekt,
-	Ort_Objekt = :Ort_Objekt,
+	// Ort_Objekt = :Ort_Objekt,
-	Dienstleistung = :Dienstleistung,
+	// Dienstleistung = :Dienstleistung,
-	Empfaengerrechnung = :Empfaengerrechnung,
+	// Empfaengerrechnung = :Empfaengerrechnung,
-	Zusatzzeilerechnung = :Zusatzzeilerechnung,
+	// Zusatzzeilerechnung = :Zusatzzeilerechnung,
-	Adresse = :Adresse,
+	// Adresse = :Adresse,
-	PLZ = :PLZ,
+	// PLZ = :PLZ,
-	Ort = :Ort,
+	// Ort = :Ort,
-	Anlass = :Anlass,
+	// Anlass = :Anlass,
-	Baujahrheizung = :Baujahrheizung,
+	// Baujahrheizung = :Baujahrheizung,
-	Baujahrgebaeude = :Baujahrgebaeude,
+	// Baujahrgebaeude = :Baujahrgebaeude,
-	Baujahrklima = :Baujahrklima,
+	// Baujahrklima = :Baujahrklima,
-	Gebaeudetyp = :Gebaeudetyp,
+	// Gebaeudetyp = :Gebaeudetyp,
-	Nutzflaeche = :Nutzflaeche,
+	// Nutzflaeche = :Nutzflaeche,
-	Sanierungsstatus = :Sanierungsstatus,
+	// Sanierungsstatus = :Sanierungsstatus,
-	Nachricht = :Nachricht,
+	// Nachricht = :Nachricht,
-	Datei = :Datei,
+	// Datei = :Datei,
-	Rolle = :Rolle,
+	// Rolle = :Rolle,
-	Email = :Email,
+	// Email = :Email,
-	Angebotspreis = :Angebotspreis,
+	// Angebotspreis = :Angebotspreis,
-	Rabatt = :Rabatt,
+	// Rabatt = :Rabatt,
-	`Status` = 'Verschickt',
+	// `Status` = 'Verschickt',
-	lex_office_id = :lex_office_id,
+	// lex_office_id = :lex_office_id,
-	Textanschreiben = :Textanschreiben,
+	// Textanschreiben = :Textanschreiben,
-	Positionstext = :Positionstext
+	// Positionstext = :Positionstext
-	WHERE Auftragsnummer = :Auftragsnummer", [
+	// WHERE Auftragsnummer = :Auftragsnummer", [
-		"Adresse_Objekt": $_POST["gebaeude_strasse"],
+	// 	"Adresse_Objekt": $_POST["gebaeude_strasse"],
-		"PLZ_Objekt": $_POST["gebaeude_plz"],
+	// 	"PLZ_Objekt": $_POST["gebaeude_plz"],
-		"Ort_Objekt": $_POST["gebaeude_ort"],
+	// 	"Ort_Objekt": $_POST["gebaeude_ort"],
-		"Dienstleistung": $_POST["dienstleistung"],
+	// 	"Dienstleistung": $_POST["dienstleistung"],
-		"Empfaengerrechnung": $_POST["rechnung_empfaenger"],
+	// 	"Empfaengerrechnung": $_POST["rechnung_empfaenger"],
-		"Zusatzzeilerechnung": $_POST["rechnung_zusatzzeile"],
+	// 	"Zusatzzeilerechnung": $_POST["rechnung_zusatzzeile"],
-		"Adresse": $_POST["rechnung_strasse"],
+	// 	"Adresse": $_POST["rechnung_strasse"],
-		"PLZ": $_POST["rechnung_plz"],
+	// 	"PLZ": $_POST["rechnung_plz"],
-		"Ort": $_POST["rechnung_ort"],
+	// 	"Ort": $_POST["rechnung_ort"],
-		"Anlass": $_POST["anlass"],
+	// 	"Anlass": $_POST["anlass"],
-		"Baujahrheizung": $_POST["baujahr_heizung"],
+	// 	"Baujahrheizung": $_POST["baujahr_heizung"],
-		"Baujahrgebaeude": $_POST["baujahr_gebaeude"],
+	// 	"Baujahrgebaeude": $_POST["baujahr_gebaeude"],
-		"Baujahrklima": $_POST["baujahr_klimaanlage"],
+	// 	"Baujahrklima": $_POST["baujahr_klimaanlage"],
-		"Gebaeudetyp": $_POST["gebaeudetyp"],
+	// 	"Gebaeudetyp": $_POST["gebaeudetyp"],
-		"Nutzflaeche": $_POST["nutzflaeche"],
+	// 	"Nutzflaeche": $_POST["nutzflaeche"],
-		"Sanierungsstatus": $_POST["sanierungsstatus"],
+	// 	"Sanierungsstatus": $_POST["sanierungsstatus"],
-		"Nachricht": $_POST["nachricht"],
+	// 	"Nachricht": $_POST["nachricht"],
-		"Datei": $dateien,
+	// 	"Datei": $dateien,
-		"Rolle": $_POST["rolle"],
+	// 	"Rolle": $_POST["rolle"],
-		"Email": $_POST["email"],
+	// 	"Email": $_POST["email"],
-		"Angebotspreis": $_POST["Angebotspreis"],
+	// 	"Angebotspreis": $_POST["Angebotspreis"],
-		"Rabatt": $_POST["Rabatt"],
+	// 	"Rabatt": $_POST["Rabatt"],
-		"lex_office_id": $lex_office_id,
+	// 	"lex_office_id": $lex_office_id,
-		"Textanschreiben": $_POST["Textanschreiben"],
+	// 	"Textanschreiben": $_POST["Textanschreiben"],
-		"Positionstext": $_POST["Positionstext"],
+	// 	"Positionstext": $_POST["Positionstext"],
-		"Auftragsnummer": $_POST["Auftragsnummer"]
+	// 	"Auftragsnummer": $_POST["Auftragsnummer"]
-	]);
+	// ]);
 	
-	// Die Auftragsnummer abfragen
+	// // Die Auftragsnummer abfragen
 	
-	$curl_nummer = curl_init();
+	// $curl_nummer = curl_init();
 	
-	curl_setopt_array($curl_nummer, [
+	// curl_setopt_array($curl_nummer, [
-		CURLOPT_URL: "https://api.lexoffice.io/v1/quotations/$lex_office_id",
+	// 	CURLOPT_URL: "https://api.lexoffice.io/v1/quotations/$lex_office_id",
-		CURLOPT_RETURNTRANSFER: true,
+	// 	CURLOPT_RETURNTRANSFER: true,
-		CURLOPT_ENCODING: "",
+	// 	CURLOPT_ENCODING: "",
-		CURLOPT_MAXREDIRS: 10,
+	// 	CURLOPT_MAXREDIRS: 10,
-		CURLOPT_TIMEOUT: 30,
+	// 	CURLOPT_TIMEOUT: 30,
-		CURLOPT_HTTP_VERSION: CURL_HTTP_VERSION_1_1,
+	// 	CURLOPT_HTTP_VERSION: CURL_HTTP_VERSION_1_1,
-		CURLOPT_CUSTOMREQUEST: "GET",
+	// 	CURLOPT_CUSTOMREQUEST: "GET",
-		CURLOPT_HTTPHEADER: [
+	// 	CURLOPT_HTTPHEADER: [
-			"Accept: application/json",
+	// 		"Accept: application/json",
-			"Authorization: Bearer " . LEX_OFFICE_API_KEY
+	// 		"Authorization: Bearer " . LEX_OFFICE_API_KEY
-		]
+	// 	]
-	]);
+	// ]);
 	
-	$nummer_response = curl_exec($curl_nummer);
+	// $nummer_response = curl_exec($curl_nummer);
-	$nummer_response = json_decode($nummer_response, true);
+	// $nummer_response = json_decode($nummer_response, true);
-	$err = curl_error($curl_nummer);
+	// $err = curl_error($curl_nummer);
 	
-	curl_close($curl_nummer);
+	// curl_close($curl_nummer);
 	
-	// Und die Mail verschicken
+	// // Und die Mail verschicken
 	
-	$mail = new PHPMailer\PHPMailer\PHPMailer(true);
+	// $mail = new PHPMailer\PHPMailer\PHPMailer(true);
 	
-	$mail->IsSMTP();
+	// $mail->IsSMTP();
-	$mail->Host = "smtp.ionos.de";
+	// $mail->Host = "smtp.ionos.de";
-	$mail->SMTPAuth = true;
+	// $mail->SMTPAuth = true;
-	$mail->Username = 'info@online-energieausweis.org';
+	// $mail->Username = 'info@online-energieausweis.org';
-	$mail->Password = 'Katendeich5a2024!';
+	// $mail->Password = 'Katendeich5a2024!';
 	
-	$mail->CharSet = 'UTF-8';
+	// $mail->CharSet = 'UTF-8';
-	$mail->Encoding  = 'base64';
+	// $mail->Encoding  = 'base64';
-	$mail->setFrom("info@online-energieausweis.org", "IB Cornelsen",0);
+	// $mail->setFrom("info@online-energieausweis.org", "IB Cornelsen",0);
-	$mail->addAddress($_POST["email"], $_POST["vorname"] . " " . $_POST["name"]);
+	// $mail->addAddress($_POST["email"], $_POST["vorname"] . " " . $_POST["name"]);
-	$mail->addCC("jens.cornelsen@ib-cornelsen.de", "Jens Cornelsen");
+	// $mail->addCC("jens.cornelsen@ib-cornelsen.de", "Jens Cornelsen");
-	$mail->isHTML(true);
+	// $mail->isHTML(true);
-	$mail->Subject = "{$nummer_response["voucherNumber"]} - {$_POST["Angebotsbezeichnung"]}";
+	// $mail->Subject = "{$nummer_response["voucherNumber"]} - {$_POST["Angebotsbezeichnung"]}";
 	
 	
-	// carriage return type (RFC)
+	// // carriage return type (RFC)
-	$eol = "<br>";
+	// $eol = "<br>";
-	$anrede = "Sehr geehrte" . ($_POST["anrede"] == "Herr" ? "r " : " ") . $_POST["anrede"];
+	// $anrede = "Sehr geehrte" . ($_POST["anrede"] == "Herr" ? "r " : " ") . $_POST["anrede"];
 	
-	$message = "$anrede {$_POST["name"]},{$eol}{$eol}";
+	// $message = "$anrede {$_POST["name"]},{$eol}{$eol}";
-	$message .= "vielen Dank für Ihre Anfrage. Im Anhang finden Sie das ausgearbeitete Angebot als PDF-Dokument.{$eol}{$eol}";
+	// $message .= "vielen Dank für Ihre Anfrage. Im Anhang finden Sie das ausgearbeitete Angebot als PDF-Dokument.{$eol}{$eol}";
-	$message .= "Mit freundlichen Grüßen,$eol";
+	// $message .= "Mit freundlichen Grüßen,$eol";
-	$message .= "Jens Cornelsen$eol";
+	// $message .= "Jens Cornelsen$eol";
-	$message .= "--{$eol}IB Cornelsen{$eol}Katendeich 5A{$eol}21035 Hamburg{$eol}{$eol}www.ib-cornelsen.de{$eol}{$eol}Fon   040 209339858{$eol}Fax   040 209339859";
+	// $message .= "--{$eol}IB Cornelsen{$eol}Katendeich 5A{$eol}21035 Hamburg{$eol}{$eol}www.ib-cornelsen.de{$eol}{$eol}Fon   040 209339858{$eol}Fax   040 209339859";
-	$mail->Body = $message;
+	// $mail->Body = $message;
 	
-	$curl_pdf = curl_init();
+	// $curl_pdf = curl_init();
 	
-	curl_setopt_array($curl_pdf, [
+	// curl_setopt_array($curl_pdf, [
-		CURLOPT_URL: "https://api.lexoffice.io/v1/files/$pdf_id",
+	// 	CURLOPT_URL: "https://api.lexoffice.io/v1/files/$pdf_id",
-		CURLOPT_RETURNTRANSFER: true,
+	// 	CURLOPT_RETURNTRANSFER: true,
-		CURLOPT_ENCODING: "",
+	// 	CURLOPT_ENCODING: "",
-		CURLOPT_MAXREDIRS: 10,
+	// 	CURLOPT_MAXREDIRS: 10,
-		CURLOPT_TIMEOUT: 30,
+	// 	CURLOPT_TIMEOUT: 30,
-		CURLOPT_HTTP_VERSION: CURL_HTTP_VERSION_1_1,
+	// 	CURLOPT_HTTP_VERSION: CURL_HTTP_VERSION_1_1,
-		CURLOPT_CUSTOMREQUEST: "GET",
+	// 	CURLOPT_CUSTOMREQUEST: "GET",
-		CURLOPT_HTTPHEADER: [
+	// 	CURLOPT_HTTPHEADER: [
-			"Accept: application/pdf",
+	// 		"Accept: application/pdf",
-			"Authorization: Bearer " . LEX_OFFICE_API_KEY
+	// 		"Authorization: Bearer " . LEX_OFFICE_API_KEY
-		]
+	// 	]
-	]);
+	// ]);
 	
-	$response = curl_exec($curl_pdf);
+	// $response = curl_exec($curl_pdf);
-	$err = curl_error($curl_pdf);
+	// $err = curl_error($curl_pdf);
 	
-	$HOME = dirname($ROOT);
+	// $HOME = dirname($ROOT);
 	
-	curl_close($curl_pdf);
+	// curl_close($curl_pdf);
-	$fp = fopen("$HOME/{$PERSISTENT_FOLDER}/angebote/$pdf_id.pdf", "w+");
+	// $fp = fopen("$HOME/{$PERSISTENT_FOLDER}/angebote/$pdf_id.pdf", "w+");
-	fwrite($fp, $response);
+	// fwrite($fp, $response);
-	fclose($fp);
+	// fclose($fp);
 	
-	$mail->addAttachment("$HOME/{$PERSISTENT_FOLDER}/angebote/$pdf_id.pdf", "Angebot.pdf");
+	// $mail->addAttachment("$HOME/{$PERSISTENT_FOLDER}/angebote/$pdf_id.pdf", "Angebot.pdf");
 	
-	$mail->send();
+	// $mail->send();
 	
-	echo "Alles wurde abgesendet! Du kannst die Webseite nun verlassen.";
+	// echo "Alles wurde abgesendet! Du kannst die Webseite nun verlassen.";
 }
 
 export async function createLexOfficeCustomer(user: Benutzer) {

src/modules/BedarfsausweisWohnen/BedarfsausweisWohnenModule.svelte

@@ -36,6 +36,8 @@
 	export let unterlagen: Unterlage[] = [];
 	export let id: string | null;
 
+	export let partner_code: string;
+
 	export let loadFromDatabase: boolean = false;
 
 	// Wir holen die daten aus dem LocalStorage falls
@@ -143,6 +145,7 @@
 			bind:unterlagen
 			bind:blockLocalStorageSync
 			{ausweisart}
+			{partner_code}
 			showWeiter={false}
 			{form}
 			{skala}
@@ -277,6 +280,7 @@
 		bind:unterlagen
 		bind:blockLocalStorageSync
 		{ausweisart}
+		{partner_code}
 		showWeiter={true}
 		{form}
 		{skala}

src/modules/Dashboard/DashboardAufnahmeModule.svelte

@@ -4,7 +4,7 @@
 	import Carousel from "#components/Carousel.svelte";
 	import DashboardAusweis from "#components/Dashboard/DashboardAusweis.svelte";
 	import DashboardNachweis from "#components/Dashboard/DashboardNachweis.svelte";
-	import NotificationProvider from "#components/NotificationProvider/NotificationProvider.svelte";
+	import NotificationWrapper from "#components/Notifications/NotificationWrapper.svelte";
 	import { Objekt } from "#lib/client/prisma.js";
 	import mime from "mime"
 	import { ChevronLeft, ChevronRight, FileText } from "radix-svelte-icons";
@@ -96,5 +96,5 @@
 </div>
 
 <div class="fixed bottom-8 right-8 flex flex-col gap-4">
-	<NotificationProvider component={AusweisPruefenNotification}></NotificationProvider>
+	<NotificationWrapper></NotificationWrapper>
 </div>

src/modules/Dashboard/DashboardAusweiseModule.svelte

@@ -1,83 +0,0 @@
-<script lang="ts">
-	import { BenutzerClient, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types.js";
-	import DashboardAusweis from "#components/Dashboard/DashboardAusweis.svelte";
-	import DashboardAusweisSkeleton from "#components/Dashboard/DashboardAusweisSkeleton.svelte";
-	import { verbrauchsausweisWohnenCalculateFormProgress } from "#lib/VerbrauchsausweisWohnen/calculateFormProgress";
-	import { onMount } from "svelte";
-	export let user: BenutzerClient;
-
-	let ausweise: VerbrauchsausweisWohnenClient[] | null = null;
-
-	let ausweisUeberpruefung: ReturnType<typeof verbrauchsausweisWohnenCalculateFormProgress>[] = [];
-	let errorCount = 0;
-
-	onMount(async () => {
-		ausweise = await client.v1.verbrauchsausweisWohnen.getMany.query({
-			limit: 10
-		});
-
-		console.log(ausweise);
-		
-
-		if (!ausweise) return;
-
-		ausweisUeberpruefung = ausweise.map(ausweis => verbrauchsausweisWohnenCalculateFormProgress(ausweis));
-
-		errorCount = ausweisUeberpruefung.reduce((acc, { errors }) => acc + errors.length, 0);
-	})
-
-	
-</script>
-
-{#if errorCount > 0}
-<h1 class="text-4xl font-medium my-8">Wichtiges</h1>
-
-<div class="flex flex-row gap-4 overflow-x-auto">
-	{#each ausweisUeberpruefung as { errors }}
-		{#if errors.length > 0}
-			<div class="card w-96 card-bordered bg-base-200 border-base-300">
-				<div class="card-body">
-					<div class="badge font-semibold" class:badge-warning={errors[0].severity == "warning"} class:badge-error={errors[0].severity == "error"}>{errors[0].severity == "error" ? "Achtung!" : "Wichtig!"}</div>
-					<h2 class="card-title">{errors[0].title}</h2>
-					<p>{errors[0].description}</p>
-					{#if errors[0].resolvehref}
-					<div class="card-actions justify-end">
-						<a class="btn btn-primary" href={errors[0].resolvehref}>Beheben</a>
-					</div>
-					{/if}
-				</div>
-			</div>
-		{/if}
-	{/each}
-</div>
-{/if}
-
-<h1 class="text-4xl font-medium my-8">Ihre Ausweise</h1>
-	
-<div class="grid xl:grid-cols-2 grid-cols-1 gap-4">
-
-	{#if ausweise === null}
-		<DashboardAusweisSkeleton></DashboardAusweisSkeleton>
-	{:else}
-		{#if ausweise.length == 0}
-			<div class="">
-				<h1 class="text-2xl">Es konnten keine Ausweise gefunden werden.</h1>
-				<p>Erstellen sie einen Verbrauchsausweis für ihr Wohngebäude <a href="/energieausweis-erstellen/verbrauchsausweis-wohngebaeude">hier</a></p>
-			</div>
-		{:else}
-			{#each ausweise as ausweis, i}
-				<DashboardAusweis progress={ausweisUeberpruefung[i]?.progress || 0} {ausweis}></DashboardAusweis>
-			{/each}
-		{/if}
-	{/if}
-
-</div>
-
-<div class="flex items-center justify-center mt-12">
-	<div class="join">
-		<button class="join-item btn btn-ghost shadow-none">1</button>
-		<button class="join-item btn btn-ghost shadow-none">2</button>
-		<button class="join-item btn btn-ghost shadow-none">3</button>
-		<button class="join-item btn btn-ghost shadow-none">4</button>
-	</div>
-</div>

src/modules/KundendatenModule.svelte

@@ -211,7 +211,7 @@
 					versand_plz: versand_plz,
 					versand_ort: versand_ort,
 					telefon: telefon,
-					nachweis_id: result.nachweis_id,
+					nachweis_id: result.nachweis_id
 				},
 				{
 					headers: {
@@ -291,7 +291,7 @@
 
 		let result: Awaited<ReturnType<typeof ausweisSpeichern>> | Awaited<ReturnType<typeof nachweisSpeichern>> | null = null;
 		if (ausweisart === Enums.Ausweisart.GEGNachweisWohnen || ausweisart === Enums.Ausweisart.GEGNachweisGewerbe || ausweisart === Enums.Ausweisart.BedarfsausweisGewerbe) {
-			result = await nachweisSpeichern(ausweis, objekt, aufnahme, bilder, unterlagen, ausweisart)
+			result = await nachweisSpeichern(ausweis as unknown as GEGNachweisWohnen, objekt, aufnahme, bilder, unterlagen, ausweisart)
 		} else {
 			result = await ausweisSpeichern(ausweis, objekt, aufnahme, bilder, unterlagen, ausweisart)
 		}

src/modules/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbeModule.svelte

@@ -49,6 +49,7 @@
 	export let bilder: BildClient[];
 	export let id: string | null;
 
+	export let partner_code: string;
 	export let loadFromDatabase: boolean = false;
 
 	const ausweisart = Enums.Ausweisart.VerbrauchsausweisGewerbe	
@@ -128,6 +129,7 @@
 		ausweisart={Enums.Ausweisart.VerbrauchsausweisGewerbe}
 		showWeiter={false}
 		{form}
+		{partner_code}
 		{skala}
 		>
 		</ButtonWeiterHilfe>
@@ -244,6 +246,7 @@
 			ausweisart={Enums.Ausweisart.VerbrauchsausweisGewerbe}
 			showWeiter={true}
 			{form}
+			{partner_code}
 			{skala}
 			>
 			</ButtonWeiterHilfe>

src/modules/VerbrauchsausweisWohnen/VerbrauchsausweisWohnenModule.svelte

@@ -160,6 +160,7 @@ let skala: HTMLDivElement;
 		bind:aufnahme
 		ausweisart={Enums.Ausweisart.VerbrauchsausweisWohnen}
 		showWeiter={false}
+		{partner_code}
 		{form}
 		{skala}
 		>

src/pages/[partner]/energieausweis-erstellen/bedarfsausweis-wohngebaeude/index.astro

@@ -1,84 +1,91 @@
 ---
-import AusweisLayout from "#layouts/AusweisLayoutDaten_partner.astro";
+
+import AusweisLayout from "#layouts/AusweisLayoutDaten.astro";
 import BedarfsausweisWohnenModule from "#modules/BedarfsausweisWohnen/BedarfsausweisWohnenModule.svelte";
-import { AufnahmeClient, ObjektClient, BildClient, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types";
+import { Aufnahme, BedarfsausweisWohnen, Bild, Enums, Objekt } from "#lib/server/prisma";
-import { createCaller } from "src/astro-typesafe-api-caller";
+import { getAufnahme, getObjekt, getBilder, getBedarfsausweisWohnen } from "#lib/server/db";
-import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants";
+import { getCurrentUser } from "#lib/server/user";
-import { validateAccessTokenServer } from "#server/lib/validateAccessToken";
-import { Enums } from "#lib/server/prisma";
 
-const id = Astro.url.searchParams.get("uid") || "";
+const id = Astro.url.searchParams.get("id");
 const aufnahme_id = Astro.url.searchParams.get("aufnahme")
-const ausweistyp = Astro.url.searchParams.get("ausweistyp") || Enums.AusweisTyp.Standard;
+let ausweistyp = Astro.url.searchParams.get("ausweistyp") as Enums.AusweisTyp || Enums.AusweisTyp.Standard;
-let ausweis: VerbrauchsausweisWohnenClient = {} as VerbrauchsausweisWohnenClient;
+const partner_code = Astro.params.partner as string;
-let aufnahme: AufnahmeClient = {} as AufnahmeClient;
-let objekt: ObjektClient = {} as ObjektClient;
-let bilder: BildClient[] = []
 
-const valid = validateAccessTokenServer(Astro);
+let ausweis: BedarfsausweisWohnen = {} as BedarfsausweisWohnen;
+let aufnahme: Aufnahme = {} as Aufnahme;
+let objekt: Objekt = {} as Objekt;
+let bilder: Bild[] = []
 
-const caller = createCaller(Astro);
+const user = await getCurrentUser(Astro)
 
 if (id) {
-	if (!valid) {
+	if (!user) {
 		return Astro.redirect(
 			`/auth/login?redirect=${Astro.url.toString()}`
 		);
 	}
 
-	try {
+	ausweis = await getBedarfsausweisWohnen(id) as BedarfsausweisWohnen
-		ausweis = await caller["bedarfsausweis-wohnen"]._id.GET.fetch(null, {
+	ausweistyp = ausweis.ausweistyp;
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				id
-			}
-		});
 
-		aufnahme = await caller.aufnahme._id.GET.fetch(null, {
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
-			headers: {
+		// Der Ausweis scheint nicht zu existieren.
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
+		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
-			},
+		return Astro.redirect(
-			params: {
+			"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
-				id: ausweis.aufnahme_id
+		);
-			}
+	}
-		})
 
-		objekt = await caller.objekt._id.GET.fetch(null, {
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				id: ausweis.objekt_id
-			}
-		})
 
-		bilder = await caller.aufnahme._id.bilder.GET.fetch(null, {
+	if (!aufnahme) {
-			headers: {
+		// Die Aufnahme existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
+		return Astro.redirect(
-			},
+			"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
-			params: {
+		);
-				id: ausweis.aufnahme_id
+	}
-			}
-		})
 
-		if (!ausweis) {
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
-			// Der Ausweis scheint nicht zu existieren.
+
-			// Wir leiten auf die generische Ausweisseite ohne UID weiter.
+	if (!objekt) {
-			return Astro.redirect(
+		// Das Objekt existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-				"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
+		return Astro.redirect(
-			);
+			"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
-		}
+		);
-	} catch(e) {
+	}
+
+	bilder = await getBilder(aufnahme.id);
+} else if (aufnahme_id) {
+	if (!user) {
+		return Astro.redirect(
+			`/auth/login?redirect=${Astro.url.toString()}`
+		);
+	}
+
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
+
+	if (!aufnahme) {
+		// Die Aufnahme existiert wohl nicht.
+		return Astro.redirect(
+			"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
+		);
+	}
+
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
+
+	if (!objekt) {
+		// Das Objekt existiert nicht.
 		return Astro.redirect(
 			"/energieausweis-erstellen/bedarfsausweis-wohngebaeude"
 		);
 	}
 }
 
+console.log(ausweistyp);
+
+
 
 ---
-<AusweisLayout title="Bedarfsausweis erstellen | IBCornelsen" tabHover3="glow">
+<AusweisLayout title="Bedarfsausweis erstellen | IBCornelsen">
-	<BedarfsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {ausweistyp} {id}></BedarfsausweisWohnenModule>
+	<BedarfsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {ausweistyp} {id} {user} loadFromDatabase={id !== null} {partner_code}></BedarfsausweisWohnenModule>
 </AusweisLayout>

src/pages/[partner]/energieausweis-erstellen/verbrauchsausweis-gewerbe/index.astro

@@ -1,79 +1,80 @@
 ---
-import AusweisLayout from "#layouts/AusweisLayoutDaten_partner.astro";
+import AusweisLayout from "#layouts/AusweisLayoutDaten.astro";
-import { AufnahmeClient, ObjektClient, UploadedGebaeudeBild, VerbrauchsausweisGewerbeClient } from "#components/Ausweis/types";
+import { AufnahmeClient, ObjektClient, BildClient, VerbrauchsausweisGewerbeClient } from "#components/Ausweis/types";
-import { createCaller } from "src/astro-typesafe-api-caller";
-import { inferOutput } from "astro-typesafe-api/client";
-import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants";
-import { validateAccessTokenServer } from "#server/lib/validateAccessToken";
 import VerbrauchsausweisGewerbeModule from "#modules/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbeModule.svelte";
-import { Enums } from "#lib/server/prisma";
+import { Aufnahme, Enums, Objekt, VerbrauchsausweisGewerbe } from "#lib/server/prisma";
+import { getAufnahme, getObjekt, getBilder, getVerbrauchsausweisGewerbe } from "#lib/server/db";
+import { getCurrentUser } from "#lib/server/user";
 
-const uid = Astro.url.searchParams.get("uid");
+const id = Astro.url.searchParams.get("id");
-const ausweistyp = Astro.url.searchParams.get("ausweistyp") || Enums.AusweisTyp.Standard;
+const aufnahme_id = Astro.url.searchParams.get("aufnahme")
+let ausweistyp = Astro.url.searchParams.get("ausweistyp") as Enums.AusweisTyp || Enums.AusweisTyp.Standard;
+const partner_code = Astro.params.partner as string;
 
 let ausweis: VerbrauchsausweisGewerbeClient = {} as VerbrauchsausweisGewerbeClient;
 let aufnahme: AufnahmeClient = {} as AufnahmeClient;
 let objekt: ObjektClient = {} as ObjektClient;
-let bilder: UploadedGebaeudeBild[] = []
+let bilder: BildClient[] = []
 
-const valid = validateAccessTokenServer(Astro);
+const user = await getCurrentUser(Astro)
 
-const caller = createCaller(Astro);
+if (id) {
-
+	if (!user) {
-if (uid) {
-	if (!valid) {
 		return Astro.redirect(
 			`/auth/login?redirect=${Astro.url.toString()}`
 		);
 	}
 
-	try {
+	ausweis = await getVerbrauchsausweisGewerbe(id) as VerbrauchsausweisGewerbe
-		let { uid_aufnahme, uid_objekt, uid_benutzer, ...result } = await caller["verbrauchsausweis-gewerbe"]._uid.GET.fetch(null, {
+	ausweistyp = ausweis.ausweistyp;
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				uid
-			}
-		});
 
-		ausweis = result
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
+		// Der Ausweis scheint nicht zu existieren.
+		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
+		return Astro.redirect(
+			"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
+		);
+	}
 
-		aufnahme = await caller.aufnahme._uid.GET.fetch(null, {
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				uid: uid_aufnahme
-			}
-		})
 
-		objekt = await caller.objekt._uid.GET.fetch(null, {
+	if (!aufnahme) {
-			headers: {
+		// Die Aufnahme existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
+		return Astro.redirect(
-			},
+			"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
-			params: {
+		);
-				uid: uid_objekt
+	}
-			}
-		})
 
-		bilder = await caller.aufnahme._uid.bilder.GET.fetch(null, {
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				uid: uid_aufnahme
-			}
-		})
 
-		if (!ausweis) {
+	if (!objekt) {
-			// Der Ausweis scheint nicht zu existieren.
+		// Das Objekt existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-			// Wir leiten auf die generische Ausweisseite ohne UID weiter.
+		return Astro.redirect(
-			return Astro.redirect(
+			"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
-				"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
+		);
-			);
+	}
-		}
+
-	} catch(e) {
+	bilder = await getBilder(aufnahme.id);
+} else if (aufnahme_id) {
+	if (!user) {
+		return Astro.redirect(
+			`/auth/login?redirect=${Astro.url.toString()}`
+		);
+	}
+
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
+
+	if (!aufnahme) {
+		// Die Aufnahme existiert wohl nicht.
+		return Astro.redirect(
+			"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
+		);
+	}
+
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
+
+	if (!objekt) {
+		// Das Objekt existiert nicht.
 		return Astro.redirect(
 			"/energieausweis-erstellen/verbrauchsausweis-gewerbe"
 		);
@@ -81,6 +82,6 @@ if (uid) {
 }
 ---
 
-<AusweisLayout title="Verbrauchsausweis Gewerbe erstellen | IBCornelsen" tabHover2="glow">
+<AusweisLayout title="Verbrauchsausweis Gewerbe erstellen | IBCornelsen">
-	<VerbrauchsausweisGewerbeModule client:only {ausweis} {objekt} {aufnahme} {bilder} {ausweistyp}/>
+	<VerbrauchsausweisGewerbeModule client:only {ausweis} {objekt} {aufnahme} {bilder} {ausweistyp} {user} {id} {partner_code} loadFromDatabase={id !== null}/>
 </AusweisLayout>

src/pages/[partner]/energieausweis-erstellen/verbrauchsausweis-wohngebaeude/index.astro

@@ -1,77 +1,79 @@
 ---
 import AusweisLayout from "#layouts/AusweisLayoutDaten_partner.astro";
 import VerbrauchsausweisWohnenModule from "#modules/VerbrauchsausweisWohnen/VerbrauchsausweisWohnenModule.svelte";
-import { AufnahmeClient, ObjektClient, UploadedGebaeudeBild, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types";
+import { Aufnahme, Bild, Enums, Objekt, VerbrauchsausweisWohnen } from "#lib/server/prisma";
-import { createCaller } from "src/astro-typesafe-api-caller";
+import { getVerbrauchsausweisWohnen, getAufnahme, getObjekt, getBilder } from "#lib/server/db";
-import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants";
+import { getCurrentUser } from "#lib/server/user";
-import { validateAccessTokenServer } from "#server/lib/validateAccessToken";
-import { Enums } from "#lib/server/prisma";
 
-const uid = Astro.url.searchParams.get("uid");
+const id = Astro.url.searchParams.get("id");
-const ausweistyp = Astro.url.searchParams.get("ausweistyp") || Enums.AusweisTyp.Standard;
+const aufnahme_id = Astro.url.searchParams.get("aufnahme")
+let ausweistyp = Astro.url.searchParams.get("ausweistyp") as Enums.AusweisTyp || Enums.AusweisTyp.Standard;
+const partner_code = Astro.params.partner as string;
 
+let ausweis: VerbrauchsausweisWohnen = {} as VerbrauchsausweisWohnen;
+let aufnahme: Aufnahme = {} as Aufnahme;
+let objekt: Objekt = {} as Objekt;
+let bilder: Bild[] = []
 
-let ausweis: VerbrauchsausweisWohnenClient = {} as VerbrauchsausweisWohnenClient;
+const user = await getCurrentUser(Astro)
-let aufnahme: AufnahmeClient = {} as AufnahmeClient;
-let objekt: ObjektClient = {} as ObjektClient;
-let bilder: UploadedGebaeudeBild[] = []
 
-const valid = validateAccessTokenServer(Astro);
+if (id) {
-
+	if (!user) {
-const caller = createCaller(Astro);
-
-if (uid) {
-	if (!valid) {
 		return Astro.redirect(
 			`/auth/login?redirect=${Astro.url.toString()}`
 		);
 	}
 
-	try {
+	ausweis = await getVerbrauchsausweisWohnen(id) as VerbrauchsausweisWohnen
-		ausweis = await caller["verbrauchsausweis-wohnen"]._uid.GET.fetch(null, {
+	ausweistyp = ausweis.ausweistyp;
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				uid
-			}
-		});
 
-		aufnahme = await caller.aufnahme._uid.GET.fetch(null, {
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
-			headers: {
+		// Der Ausweis scheint nicht zu existieren.
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
+		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
-			},
+		return Astro.redirect(
-			params: {
+			"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
-				uid: ausweis.uid_aufnahme
+		);
-			}
+	}
-		})
 
-		objekt = await caller.objekt._uid.GET.fetch(null, {
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
-			headers: {
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
-			},
-			params: {
-				uid: ausweis.uid_objekt
-			}
-		})
 
-		bilder = await caller.aufnahme._uid.bilder.GET.fetch(null, {
+	if (!aufnahme) {
-			headers: {
+		// Die Aufnahme existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-				authorization: `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
+		return Astro.redirect(
-			},
+			"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
-			params: {
+		);
-				uid: ausweis.uid_aufnahme
+	}
-			}
-		})
 
-		if (!ausweis) {
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
-			// Der Ausweis scheint nicht zu existieren.
+
-			// Wir leiten auf die generische Ausweisseite ohne UID weiter.
+	if (!objekt) {
-			return Astro.redirect(
+		// Das Objekt existiert nicht, das sollte eigentlich nicht passieren aber so können wir nicht fortfahren.
-				"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
+		return Astro.redirect(
-			);
+			"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
-		}
+		);
-	} catch(e) {
+	}
+
+	bilder = await getBilder(aufnahme.id);
+} else if (aufnahme_id) {
+	if (!user) {
+		return Astro.redirect(
+			`/auth/login?redirect=${Astro.url.toString()}`
+		);
+	}
+
+	aufnahme = await getAufnahme(ausweis.aufnahme_id) as Aufnahme
+
+	if (!aufnahme) {
+		// Die Aufnahme existiert wohl nicht.
+		return Astro.redirect(
+			"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
+		);
+	}
+
+	objekt = await getObjekt(aufnahme.objekt_id) as Objekt
+
+	if (!objekt) {
+		// Das Objekt existiert nicht.
 		return Astro.redirect(
 			"/energieausweis-erstellen/verbrauchsausweis-wohngebaeude"
 		);
@@ -81,5 +83,5 @@ if (uid) {
 ---
 
 <AusweisLayout title="Verbrauchsausweis erstellen" tabHover1="glow">
-	<VerbrauchsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {ausweistyp} />
+	<VerbrauchsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {id} {ausweistyp} {user} {partner_code} loadFromDatabase={id !== null} />
 </AusweisLayout>

src/pages/api/admin/ausstellen.ts

@@ -18,6 +18,9 @@ import { BASE_URI } from "#lib/constants.js";
 import { getAnsichtsausweis, getDatenblatt } from "#lib/server/ausweis.js";
 import { PutObjectCommand } from "@aws-sdk/client-s3";
 import { s3Client } from "#lib/s3.js";
+import { createInvoice } from "#lib/server/invoice.js";
+import { tryCatch } from "#lib/tryCatch.js";
+import { getBedarfsausweisWohnenKomplett, getVerbrauchsausweisGewerbeKomplett, getVerbrauchsausweisWohnenKomplett } from "#lib/server/db.js";
 
 export const GET = defineApiRoute({
 	input: z.object({
@@ -44,59 +47,11 @@ export const GET = defineApiRoute({
 			| null = null;
 
 		if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
-			ausweis = await prisma.verbrauchsausweisWohnen.findUnique({
+			ausweis = await getVerbrauchsausweisWohnenKomplett(id_ausweis)
-				where: {
-					id: id_ausweis,
-				},
-				include: {
-					aufnahme: {
-						include: {
-							bilder: true,
-							objekt: {
-								include: {
-									benutzer: true,
-								},
-							},
-						},
-					},
-				},
-			});
 		} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
-			ausweis = await prisma.verbrauchsausweisGewerbe.findUnique({
+			ausweis = await getVerbrauchsausweisGewerbeKomplett(id_ausweis)
-				where: {
-					id: id_ausweis,
-				},
-				include: {
-					aufnahme: {
-						include: {
-							bilder: true,
-							objekt: {
-								include: {
-									benutzer: true,
-								},
-							},
-						},
-					},
-				},
-			});
 		} else if (ausweisart === Enums.Ausweisart.BedarfsausweisWohnen) {
-			ausweis = await prisma.bedarfsausweisWohnen.findUnique({
+			ausweis = await getBedarfsausweisWohnenKomplett(id_ausweis)
-				where: {
-					id: id_ausweis,
-				},
-				include: {
-					aufnahme: {
-						include: {
-							bilder: true,
-							objekt: {
-								include: {
-									benutzer: true,
-								},
-							},
-						},
-					},
-				},
-			});
 		}
 
 		if (!ausweis) {
@@ -125,34 +80,32 @@ export const GET = defineApiRoute({
 			});
 		}
 
-		// TODO
+		if (!rechnung.lex_office_id) {
-		// SECTION: Rechnung erstellen (LexOffice)
+			const [result, error] = await tryCatch(createInvoice(ausweis, rechnung));
-		// Wir wollen die Rechnung an lex office versenden, und uns die ID von da holen.
-		// Falls die Rechnung bereits existiert ist das nicht nötig.
-		// if (!$rechnung->lex_office_id) {
-		// 	[$lex_office_id, $renr] = createInvoice($ausweis, $rechnung);
-		// 	sleep(1); // TODO: Nach der Umstellung von LexOffice auf etwas anderes MUSS das hier unbedingt entfernt werden!
 
-		// 	if (!$lex_office_id || !$renr) {
+			if (error) {
-		// 		die("Bei der Erstellung der Rechnung ist etwas schiefgelaufen - Möglicherweise ist etwas mit LexOffice?");
+				return
-		// 	}
+			}
 
-		// 	$rechnung->lex_office_id = $lex_office_id;
+			const { id, voucherNumber } = result;
-		// 	$rechnung->rechnungsnummer = $renr;
-		// 	$rechnung->save();
-		// }
 
-		// TODO
+			await prisma.rechnung.update({
-		// if ($ausweis->erledigt != 2) {$ausweis->erstellungsdatum = date("Y-m-d H:i:s");}
+				where: {
-		// $ausweis->erledigt = 2;
+					id: rechnung.id
-		// $ausweis->save();
+				},
+				data: {
+					lex_office_id: id
+				}
+			})
+		}
 
 		const pdfAusweis = await getAnsichtsausweis(
 			ausweis,
 			ausweis.aufnahme,
 			ausweis.aufnahme.objekt,
 			ausweis.aufnahme.bilder,
-			ausweis.aufnahme.objekt.benutzer
+			ausweis.aufnahme.objekt.benutzer,
+			false
 		);
 		const pdfDatenblatt = await getDatenblatt(
 			ausweis,
@@ -176,7 +129,7 @@ export const GET = defineApiRoute({
 		if (pdfDatenblatt) {
 			const command = new PutObjectCommand({
 				Bucket: "ibc-pdfs",
-				Key: `ID_${ausweis.id}_Energieausweis.pdf`,
+				Key: `ID_${ausweis.id}_Datenblatt.pdf`,
 				Body: pdfDatenblatt,
 				ACL: "private",
 			});
@@ -273,5 +226,34 @@ fax 040 · 209339859
 			subject: `Ihr Originalausweis vom Ingenieurbüro Cornelsen (ID: ${ausweis.id})`,
 			text,
 		});
+
+		if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
+			await prisma.verbrauchsausweisWohnen.update({
+				where: {
+					id: ausweis.id
+				},
+				data: {
+					ausgestellt: true
+				}
+			})
+		} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
+			await prisma.verbrauchsausweisGewerbe.update({
+				where: {
+					id: ausweis.id
+				},
+				data: {
+					ausgestellt: true
+				}
+			})
+		} else if (ausweisart === Enums.Ausweisart.BedarfsausweisWohnen) {
+			await prisma.bedarfsausweisWohnen.update({
+				where: {
+					id: ausweis.id
+				},
+				data: {
+					ausgestellt: true,
+				}
+			})
+		}
 	},
 });

src/pages/api/admin/registriernummer.ts

@@ -7,10 +7,7 @@ import {
 	authorizationHeaders,
 } from "#lib/middleware/authorization.js";
 import {
-	BedarfsausweisWohnen,
 	Enums,
-	VerbrauchsausweisGewerbe,
-	VerbrauchsausweisWohnen,
 } from "#lib/server/prisma.js";
 import { prisma } from "#lib/server/prisma.js";
 import { APIError, defineApiRoute } from "astro-typesafe-api/server";
@@ -21,14 +18,14 @@ import { getPrismaAusweisAdapter } from "#lib/server/ausweis.js";
 
 export const GET = defineApiRoute({
 	input: z.object({
-		uid: UUidWithPrefix,
+		id: UUidWithPrefix,
 	}),
 	headers: authorizationHeaders,
 	middleware: adminMiddleware,
-	async fetch({ uid }, context, user) {
+	async fetch({ id }, context, user) {
-		const ausweisart = getAusweisartFromId(uid);
+		const ausweisart = getAusweisartFromId(id);
 		const adapter = getPrismaAusweisAdapter(
-			uid
+			id
 		) as typeof prisma.verbrauchsausweisWohnen;
 
 		if (!adapter) {
@@ -40,7 +37,7 @@ export const GET = defineApiRoute({
 
 		const ausweis = await adapter.findUnique({
 			where: {
-				uid,
+				id,
 			},
 			include: {
 				aufnahme: {
@@ -125,32 +122,27 @@ export const GET = defineApiRoute({
 				? "Energiebedarfsausweis"
 				: "Energieverbrauchsausweis";
 
-		const body = `<Datenregistratur xmlns="http://energieausweis.dibt.de/WebServiceEnergie/DibtEnergieAusweisService">
+		const requestPayload = {
-						<doc>
+			doc: {
-						<root>
+				root: {
-						<Authentifizierung>
+					Authentifizierung: {
-							<Aussteller_ID_DIBT>${Aussteller_ID_DIBT}</Aussteller_ID_DIBT>
+						Aussteller_ID_DIBT: Aussteller_ID_DIBT,
-							<Aussteller_PWD_DIBT>${Aussteller_PWD_DIBT}</Aussteller_PWD_DIBT>
+						Aussteller_PWD_DIBT: Aussteller_PWD_DIBT,
-						</Authentifizierung>
+					},
-						<EnEV-Nachweis>
+					'EnEV-Nachweis': {
-							<Ausstellungsdatum>${Ausstellungsdatum}</Ausstellungsdatum>
+						Ausstellungsdatum: Ausstellungsdatum,
-							<Bundesland>${postleitzahl.bundesland}</Bundesland>
+						Bundesland: postleitzahl.bundesland,
-							<Postleitzahl>${postleitzahl.plz}</Postleitzahl>
+						Postleitzahl: postleitzahl.plz,
-							<Gesetzesgrundlage>${Gesetzesgrundlage}</Gesetzesgrundlage>
+						Gesetzesgrundlage: Gesetzesgrundlage,
-						</EnEV-Nachweis>
+					},
-						<Energieausweis-Daten>
+					'Energieausweis-Daten': {
-							<Gebaeudeart>${gebaeudeart}</Gebaeudeart>
+						Gebaeudeart: gebaeudeart,
-							<Art>${art}</Art>
+						Art: art,
-							<Neubau>${
+						Neubau: ausweis.ausstellgrund === Enums.Ausstellgrund.Neubau ? "1" : "0",
-								ausweis.ausstellgrund ===
+					},
-								Enums.Ausstellgrund.Neubau
+				},
-									? "1"
+			},
-									: "0"
+		}
-							}</Neubau>
-						</Energieausweis-Daten>
-				</root>
-			</doc>
-		</Datenregistratur>`;
 
 		return await new Promise(async (resolve, reject) => {
 			soap.createClient(
@@ -165,7 +157,7 @@ export const GET = defineApiRoute({
 					}
 
 					client.Datenregistratur(
-						body,
+						requestPayload,
 						async function (
 							err: any,
 							result: {
@@ -193,7 +185,7 @@ export const GET = defineApiRoute({
 									adapter as typeof prisma.verbrauchsausweisWohnen
 								).update({
 									where: {
-										uid,
+										id,
 									},
 									data: {
 										registriernummer:

src/pages/api/rechnung/anfordern.ts

@@ -52,9 +52,6 @@ export const PUT = defineApiRoute({
 			})
 		}
 
-		console.log(nachweis);
-		
-
 		if (!nachweis || nachweis.benutzer_id !== user.id) {
 			throw new APIError({
 				code: "BAD_REQUEST",

src/pages/api/user/index.ts

@@ -3,6 +3,7 @@ import { VALID_UUID_PREFIXES } from "#lib/constants.js";
 import { generatePrefixedId } from "#lib/db.js";
 import { adminMiddleware, authorizationMiddleware } from "#lib/middleware/authorization.js";
 import { hashPassword } from "#lib/password.js";
+import { createLexOfficeCustomer } from "#lib/server/lexoffice.js";
 import { sendRegisterMail } from "#lib/server/mail/registrierung.js";
 import { prisma } from "#lib/server/prisma.js";
 import { APIError, defineApiRoute } from "astro-typesafe-api/server";
@@ -117,6 +118,17 @@ export const PUT = defineApiRoute({
 			}
 		})
 
+		const lex_office_id = await createLexOfficeCustomer(user);
+
+		await prisma.benutzer.update({
+			where: {
+				id: user.id
+			},
+			data: {
+				lex_office_id
+			}
+		})
+
 		await sendRegisterMail(user)
 
 		return { id }

src/pages/api/webhooks/mollie.ts

@@ -19,7 +19,7 @@ export const POST = defineApiRoute({
 
 		// Wir holen uns die Transaktion von Mollie.
 		const payment = await mollieClient.payments.get(id);
-		const metadata = payment.metadata as { rechnung_uid: string }
+		const metadata = payment.metadata as { rechnung_id: string }
 
 		if (!payment) {
 			throw new APIError({
@@ -28,7 +28,7 @@ export const POST = defineApiRoute({
 			});
 		}
 
-		if (!metadata.rechnung_uid) {
+		if (!metadata.rechnung_id) {
 			throw new APIError({
 				code: "BAD_REQUEST",
 				message: "Rechnung UID nicht gefunden.",
@@ -38,7 +38,7 @@ export const POST = defineApiRoute({
 		// Wir holen uns die Rechnung aus unserer Datenbank.
 		const rechnung = await prisma.rechnung.findUnique({
 			where: {
-				uid: metadata.rechnung_uid,
+				id: metadata.rechnung_id,
 			},
 		});
 

src/pages/dashboard/ausweise/index.astro

@@ -1,21 +0,0 @@
----
-import UserLayout from "#layouts/DashboardLayout.astro";
-import DashboardAusweiseModule from "#modules/Dashboard/DashboardAusweiseModule.svelte";
-
-import { validateAccessTokenServer } from "#server/lib/validateAccessToken";
-import { createCaller } from "src/astro-typesafe-api-caller";
-
-const accessTokenValid = await validateAccessTokenServer(Astro);
-
-if (!accessTokenValid) {
-	return Astro.redirect("/auth/login")
-}
-
-const caller = createCaller(Astro);
-
-const user = await caller.v1.benutzer.self();
----
-
-<UserLayout title="Dashboard">
-	<DashboardAusweiseModule user={user} client:load></DashboardAusweiseModule>
-</UserLayout>

src/pages/energieausweis-erstellen/bedarfsausweis-wohngebaeude/index.astro

@@ -27,7 +27,7 @@ if (id) {
 	ausweis = await getBedarfsausweisWohnen(id) as BedarfsausweisWohnen
 	ausweistyp = ausweis.ausweistyp;
 
-	if (!ausweis || ausweis.benutzer_id !== user.id) {
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
 		// Der Ausweis scheint nicht zu existieren.
 		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
 		return Astro.redirect(

src/pages/energieausweis-erstellen/verbrauchsausweis-gewerbe/index.astro

@@ -27,7 +27,7 @@ if (id) {
 	ausweis = await getVerbrauchsausweisGewerbe(id) as VerbrauchsausweisGewerbe
 	ausweistyp = ausweis.ausweistyp;
 
-	if (!ausweis || ausweis.benutzer_id !== user.id) {
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
 		// Der Ausweis scheint nicht zu existieren.
 		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
 		return Astro.redirect(

src/pages/energieausweis-erstellen/verbrauchsausweis-wohngebaeude/index.astro

@@ -1,7 +1,6 @@
 ---
 import AusweisLayout from "#layouts/AusweisLayoutDaten.astro";
 import VerbrauchsausweisWohnenModule from "#modules/VerbrauchsausweisWohnen/VerbrauchsausweisWohnenModule.svelte";
-import { AufnahmeClient, BildClient, ObjektClient, UploadedGebaeudeBild, VerbrauchsausweisWohnenClient } from "#components/Ausweis/types";
 import { Aufnahme, Bild, Enums, Objekt, VerbrauchsausweisWohnen } from "#lib/server/prisma";
 import { getAufnahme, getBilder, getObjekt, getVerbrauchsausweisWohnen } from "#lib/server/db";
 import { getCurrentUser } from "#lib/server/user";
@@ -27,7 +26,7 @@ if (id) {
 	ausweis = await getVerbrauchsausweisWohnen(id) as VerbrauchsausweisWohnen
 	ausweistyp = ausweis.ausweistyp;
 
-	if (!ausweis || ausweis.benutzer_id !== user.id) {
+	if (!ausweis || (ausweis.benutzer_id !== user.id && user.rolle !== Enums.BenutzerRolle.ADMIN)) {
 		// Der Ausweis scheint nicht zu existieren.
 		// Wir leiten auf die generische Ausweisseite ohne ID weiter.
 		return Astro.redirect(
@@ -82,5 +81,5 @@ if (id) {
 ---
 
 <AusweisLayout title="Verbrauchsausweis erstellen">
-	<VerbrauchsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {id} {ausweistyp} {user} loadFromDatabase={id !== null} />
+	<VerbrauchsausweisWohnenModule client:only {ausweis} {objekt} {aufnahme} {bilder} {id} {ausweistyp} {user} loadFromDatabase={id !== null} partner_code="" />
 </AusweisLayout>