IBCornelsen/online-energieausweis
1
0
Fork 0
Code Issues 272 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

Bedarfsausweis Wohnen ausstellen

Browse Source
This commit is contained in:
Moritz Utcke
2025-04-23 10:34:30 -03:00
parent cfad65878e
commit 076c49c054
8 changed files with 616 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files

167
src/pages/api/admin/ausstellen.ts
View File

@@ -12,7 +12,7 @@ import {
VerbrauchsausweisGewerbe,
VerbrauchsausweisWohnen,
} from "#lib/server/prisma.js";
import { join } from "path"
import { join } from "path";
import { APIError, defineApiRoute } from "astro-typesafe-api/server";
import { z } from "astro:content";
import { transport } from "#lib/mail.js";
@@ -20,9 +20,13 @@ 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, getLexOfficeRechnung, getLexOfficeVoucherNumber } from "#lib/server/invoice.js";
import {
createInvoice,
getLexOfficeRechnung,
getLexOfficeVoucherNumber,
} from "#lib/server/invoice.js";
import { tryCatch } from "#lib/tryCatch.js";
import SFTPClient from 'ssh2-sftp-client';
import SFTPClient from "ssh2-sftp-client";
import {
getBedarfsausweisWohnenKomplett,
getVerbrauchsausweisGewerbeKomplett,
@@ -33,7 +37,11 @@ import { PDFDocument } from "pdf-lib";
export const GET = defineApiRoute({
input: z.object({
id_ausweis: z.string(),
post: z.boolean().describe("Ob der Ausweis auch per Post ausgestellt werden soll.").optional().default(false)
post: z
.boolean()
.describe("Ob der Ausweis auch per Post ausgestellt werden soll.")
.optional()
.default(false),
}),
output: z.void(),
middleware: adminMiddleware,
@@ -51,8 +59,8 @@ export const GET = defineApiRoute({
objekt: Objekt & {
benutzer: Benutzer | null;
};
},
rechnung: Rechnung
};
rechnung: Rechnung;
})
| null = null;
@@ -76,15 +84,15 @@ export const GET = defineApiRoute({
OR: [
{ bedarfsausweis_wohnen: { id: id_ausweis } },
{ verbrauchsausweis_wohnen: { id: id_ausweis } },
{ verbrauchsausweis_gewerbe: { id: id_ausweis } }
]
{ verbrauchsausweis_gewerbe: { id: id_ausweis } },
],
},
orderBy: {
erstellt_am: "desc",
},
include: {
benutzer: true
}
benutzer: true,
},
});
if (!rechnung) {
@@ -106,7 +114,7 @@ export const GET = defineApiRoute({
code: "BAD_REQUEST",
message:
"Die Rechnung konnte bei LexOffice nicht angelegt werden..",
cause: error
cause: error,
});
}
@@ -123,7 +131,7 @@ export const GET = defineApiRoute({
},
});
} else {
voucherNumber = await getLexOfficeVoucherNumber(rechnung)
voucherNumber = await getLexOfficeVoucherNumber(rechnung);
}
const pdfAusweis = await getAnsichtsausweis(
@@ -146,73 +154,78 @@ export const GET = defineApiRoute({
// TODO: Das ist immer noch scheiße, LexOffice ist doof
// Hier müssen wir warten, damit wir sichergehen können, dass die Rechnung bei LexOffice existiert.
setTimeout(async () => {
const [pdfRechnung, pdfRechnungError] = await tryCatch(getLexOfficeRechnung(rechnung));
const [pdfRechnung, pdfRechnungError] = await tryCatch(
getLexOfficeRechnung(rechnung)
);
if (pdfRechnungError) {
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message: "Rechnungs PDF konnte nicht generiert werden."
})
message: "Rechnungs PDF konnte nicht generiert werden.",
});
}
if (!pdfAusweis) {
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message: "Ausweis PDF konnte nicht generiert werden."
})
message: "Ausweis PDF konnte nicht generiert werden.",
});
}
if (!pdfDatenblatt) {
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message: "Datenblatt PDF konnte nicht generiert werden."
})
message: "Datenblatt PDF konnte nicht generiert werden.",
});
}
const ausweisCommand = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: `ID_${ausweis.id}_Energieausweis.pdf`,
Body: pdfAusweis,
ACL: "private",
});
await s3Client.send(ausweisCommand);
const datenblattCommand = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: `ID_${ausweis.id}_Datenblatt.pdf`,
Body: pdfDatenblatt,
ACL: "private",
});
await s3Client.send(datenblattCommand);
const rechnungsCommand = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: `ID_${ausweis.id}_Rechnung.pdf`,
Body: pdfDatenblatt,
Body: Buffer.from(pdfRechnung),
ACL: "private",
});
await s3Client.send(rechnungsCommand);
// Falls Postversand angefragt wurde müssen wir die Dateien auf den Postserver hochladen
if (post) {
const dateiNameDruck = `1011000000000-AW_ID_${ausweis.id}.pdf`;
const outputPdf = await PDFDocument.create();
async function appendPdf(buffer: Uint8Array<ArrayBufferLike>) {
const doc = await PDFDocument.load(buffer);
const copiedPages = await outputPdf.copyPages(doc, doc.getPageIndices());
const copiedPages = await outputPdf.copyPages(
doc,
doc.getPageIndices()
);
for (const page of copiedPages) {
outputPdf.addPage(page);
}
}
await appendPdf(pdfDatenblatt);
await appendPdf(pdfAusweis);
const pdfBytes = await outputPdf.save();
const pdfCommand = new PutObjectCommand({
@@ -221,38 +234,44 @@ export const GET = defineApiRoute({
Body: pdfBytes,
ACL: "private",
});
await s3Client.send(pdfCommand);
const sftp = new SFTPClient();
try {
await sftp.connect({
host: 'api.ppost.de',
username: 'jens.cornelsen@ib-cornelsen.de',
password: 'ANTQesWYjd',
host: "api.ppost.de",
username: "jens.cornelsen@ib-cornelsen.de",
password: "ANTQesWYjd",
});
const cwd = await sftp.cwd();
await sftp.put(Buffer.from(pdfBytes), join(cwd, "upload/api", dateiNameDruck));
await sftp.put(
Buffer.from(pdfBytes),
join(cwd, "upload/api", dateiNameDruck)
);
} catch (err) {
console.error('SFTP Upload failed:', err);
console.error("SFTP Upload failed:", err);
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message: "Login zum Postversand Server war nicht erfolgreich."
message:
"Login zum Postversand Server war nicht erfolgreich.",
});
} finally {
sftp.end();
}
}
let html: string;
if (rechnung.status === Enums.Rechnungsstatus.paid) {
html = `
<p>Sehr geehrte*r ${rechnung.empfaenger},</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""} Den Rechnungsbetrag haben Sie bereits bezahlt. Vielen Dank.</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
} Den Rechnungsbetrag haben Sie bereits bezahlt. Vielen Dank.</p>
<p>
Mit freundlichen Grüßen,
@@ -279,7 +298,9 @@ export const GET = defineApiRoute({
html = `
<p>Sehr geehrte*r ${rechnung.empfaenger},</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""} Nachfolgend finden Sie unsere Bankverbindung. Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
} Nachfolgend finden Sie unsere Bankverbindung. Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
<br>
<table>
@@ -316,34 +337,38 @@ export const GET = defineApiRoute({
fax 040 · 209339859
</p>`;
}
await transport.sendMail({
from: `"IBCornelsen" <info@online-energieausweis.org>`,
to: rechnung.email || rechnung.benutzer.email,
bcc: "info@online-energieausweis.org",
subject: `Ihr Originalausweis vom Ingenieurbüro Cornelsen (ID: ${ausweis.id})`,
html,
attachments: [{
filename: `ID_${ausweis.id}_Energieausweis.pdf`,
encoding: "binary",
content: Buffer.from(pdfAusweis),
contentType: "application/pdf",
contentDisposition: "attachment",
}, {
filename: `ID_${ausweis.id}_Datenblatt.pdf`,
encoding: "binary",
content: Buffer.from(pdfDatenblatt),
contentType: "application/pdf",
contentDisposition: "attachment",
}, {
filename: `ID_${ausweis.id}_Rechnung.pdf`,
encoding: "binary",
content: Buffer.from(pdfRechnung),
contentType: "application/pdf",
contentDisposition: "attachment",
}]
attachments: [
{
filename: `ID_${ausweis.id}_Energieausweis.pdf`,
encoding: "binary",
content: Buffer.from(pdfAusweis),
contentType: "application/pdf",
contentDisposition: "attachment",
},
{
filename: `ID_${ausweis.id}_Datenblatt.pdf`,
encoding: "binary",
content: Buffer.from(pdfDatenblatt),
contentType: "application/pdf",
contentDisposition: "attachment",
},
{
filename: `ID_${ausweis.id}_Rechnung.pdf`,
encoding: "binary",
content: Buffer.from(pdfRechnung),
contentType: "application/pdf",
contentDisposition: "attachment",
},
],
});
if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
await prisma.verbrauchsausweisWohnen.update({
where: {
@@ -353,7 +378,9 @@ export const GET = defineApiRoute({
ausgestellt: true,
},
});
} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
} else if (
ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe
) {
await prisma.verbrauchsausweisGewerbe.update({
where: {
id: ausweis.id,
@@ -372,6 +399,6 @@ export const GET = defineApiRoute({
},
});
}
}, 3000)
}, 3000);
},
});

361
src/pages/api/admin/bedarfsausweis-ausstellen.ts Normal file
View File

@@ -0,0 +1,361 @@
import { getAusweisartFromId } from "#components/Ausweis/types.js";
import { adminMiddleware } from "#lib/middleware/authorization.js";
import {
Aufnahme,
BedarfsausweisWohnen,
Benutzer,
Bild,
Enums,
Objekt,
prisma,
Rechnung,
} from "#lib/server/prisma.js";
import { join } from "path";
import { APIError, defineApiRoute } from "astro-typesafe-api/server";
import { z } from "astro:content";
import { transport } from "#lib/mail.js";
import { PutObjectCommand } from "@aws-sdk/client-s3";
import { s3Client } from "#lib/s3.js";
import {
createInvoice,
getLexOfficeRechnung,
getLexOfficeVoucherNumber,
} from "#lib/server/invoice.js";
import { tryCatch } from "#lib/tryCatch.js";
import SFTPClient from "ssh2-sftp-client";
import {
getBedarfsausweisWohnenKomplett,
} from "#lib/server/db.js";
import { PDFDocument } from "pdf-lib";
import isBase64 from "is-base64";
import Mail from "nodemailer/lib/mailer/index.js";
import mime from "mime"
export const POST = defineApiRoute({
input: z.object({
id_ausweis: z.string(),
post: z
.boolean()
.describe("Ob der Ausweis auch per Post ausgestellt werden soll.")
.optional()
.default(false),
files: z.object({
data: z.string(),
name: z.string(),
type: z.enum(["Ausweis", "Sonstiges"])
}).array()
}),
output: z.void(),
middleware: adminMiddleware,
async fetch({ id_ausweis, post, files }, context) {
const ausweisart = getAusweisartFromId(id_ausweis);
let ausweis:
| ((BedarfsausweisWohnen) & {
aufnahme: Aufnahme & {
bilder: Bild[];
objekt: Objekt & {
benutzer: Benutzer | null;
};
};
rechnung: Rechnung;
})
| null = null;
if (ausweisart === Enums.Ausweisart.BedarfsausweisWohnen) {
ausweis = await getBedarfsausweisWohnenKomplett(id_ausweis);
} else {
throw new APIError({
code: "BAD_REQUEST",
message: "Nur Bedarfsausweise werden von dieser Route unterstützt."
})
}
if (!ausweis) {
throw new APIError({
code: "BAD_REQUEST",
message: "Ausweis existiert nicht.",
});
}
const rechnung = await prisma.rechnung.findFirst({
where: {
bedarfsausweis_wohnen: { id: id_ausweis }
},
orderBy: {
erstellt_am: "desc",
},
include: {
benutzer: true,
},
});
if (!rechnung) {
throw new APIError({
code: "BAD_REQUEST",
message:
"Die Rechnung wurde noch nicht erstellt, wir können nicht fortfahren.",
});
}
let voucherNumber: string = "";
if (!rechnung.lex_office_id) {
const [result, error] = await tryCatch(
createInvoice(ausweis, rechnung)
);
if (error) {
throw new APIError({
code: "BAD_REQUEST",
message:
"Die Rechnung konnte bei LexOffice nicht angelegt werden..",
cause: error,
});
}
const { id, voucherNumber: lexOfficeVoucherNumber } = result;
voucherNumber = lexOfficeVoucherNumber;
await prisma.rechnung.update({
where: {
id: rechnung.id,
},
data: {
lex_office_id: id,
},
});
} else {
voucherNumber = await getLexOfficeVoucherNumber(rechnung);
}
// Hier müssen wir warten, damit wir sichergehen können, dass die Rechnung bei LexOffice existiert.
setTimeout(async () => {
const [pdfRechnung, pdfRechnungError] = await tryCatch(
getLexOfficeRechnung(rechnung)
);
if (pdfRechnungError) {
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message: "Rechnungs PDF konnte nicht generiert werden.",
});
}
const processedFiles: Mail.Attachment[] = []
for (const file of files) {
const { data, name, type } = file;
if (!isBase64(data, { mimeRequired: true })) {
throw new APIError({
code: "BAD_REQUEST",
message: `Das Attachment '${name}' kann nicht gespeichert werden.`,
});
}
const dataWithoutPrefix = data.replace(
/^data:image\/\w+;base64,/,
""
);
const buffer = Buffer.from(dataWithoutPrefix, "base64");
const mimeType = mime.getType(name.split(".").pop() as string)
if (!mimeType) {
throw new APIError({
code: "BAD_REQUEST",
message: `Die Datei ${name} hat einen ungültigen MimeType`
})
}
let filename: string;
if (type === "Ausweis") {
filename = `ID_${ausweis.id}_Ausweis.pdf`
} else {
filename = `ID_${ausweis.id}_${name}`;
}
processedFiles.push({
content: buffer,
contentDisposition: "attachment",
contentType: mimeType as string,
encoding: "binary",
filename
})
const command = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: name,
Body: buffer,
ACL: "private",
});
await s3Client.send(command);
}
const rechnungsCommand = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: `ID_${ausweis.id}_Rechnung.pdf`,
Body: Buffer.from(pdfRechnung),
ACL: "private",
});
await s3Client.send(rechnungsCommand);
// Falls Postversand angefragt wurde müssen wir die Dateien auf den Postserver hochladen
if (post) {
const dateiNameDruck = `1011000000000-AW_ID_${ausweis.id}.pdf`;
const outputPdf = await PDFDocument.create();
async function appendPdf(buffer: Uint8Array<ArrayBufferLike>) {
const doc = await PDFDocument.load(buffer);
const copiedPages = await outputPdf.copyPages(
doc,
doc.getPageIndices()
);
for (const page of copiedPages) {
outputPdf.addPage(page);
}
}
for (const file of processedFiles) {
await appendPdf(file.content as Buffer);
}
const pdfBytes = await outputPdf.save();
const pdfCommand = new PutObjectCommand({
Bucket: "ibc-pdfs",
Key: dateiNameDruck,
Body: pdfBytes,
ACL: "private",
});
await s3Client.send(pdfCommand);
const sftp = new SFTPClient();
try {
await sftp.connect({
host: "api.ppost.de",
username: "jens.cornelsen@ib-cornelsen.de",
password: "ANTQesWYjd",
});
const cwd = await sftp.cwd();
await sftp.put(
Buffer.from(pdfBytes),
join(cwd, "upload/api", dateiNameDruck)
);
} catch (err) {
console.error("SFTP Upload failed:", err);
throw new APIError({
code: "INTERNAL_SERVER_ERROR",
message:
"Login zum Postversand Server war nicht erfolgreich.",
});
} finally {
sftp.end();
}
}
let html: string;
if (rechnung.status === Enums.Rechnungsstatus.paid) {
html = `
<p>Sehr geehrte*r ${rechnung.empfaenger},</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
} Den Rechnungsbetrag haben Sie bereits bezahlt. Vielen Dank.</p>
<p>
Mit freundlichen Grüßen,
<br>
Dipl.-Ing. Jens Cornelsen
<br>
<br>
<strong>IB Cornelsen</strong>
<br>
Katendeich 5A
<br>
21035 Hamburg
<br>
www.online-energieausweis.org
<br>
<br>
fon 040 · 209339850
<br>
fax 040 · 209339859
</p>`;
} else {
html = `
<p>Sehr geehrte*r ${rechnung.empfaenger},</p>
<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
} Nachfolgend finden Sie unsere Bankverbindung. Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
<br>
<table>
<tr><td>Kreditinstitut</td><td>:</td><td>\t Commerzbank AG</td>
<tr><td>Empfänger</td><td>:</td><td>\t IB Cornelsen</td>
<tr><td>IBAN</td><td>:<td>\t DE81 2004 0000 0348 6008 00</td>
<tr><td>BIC</td><td>:</td><td>\t COBADEFFXXX</td>
<tr><td>Betrag</td><td>:</td><td>\t <b>${rechnung.betrag}€</b></td>
<tr><td>Verwendungszweck</td><td>:</td><td>\t <b>${voucherNumber}</b></td>
</table>
<br>
<br>
<p>
Mit freundlichen Grüßen,
<br>
Dipl.-Ing. Jens Cornelsen
<br>
<br>
<strong>IB Cornelsen</strong>
<br>
Katendeich 5A
<br>
21035 Hamburg
<br>
www.online-energieausweis.org
<br>
<br>
fon 040 · 209339850
<br>
fax 040 · 209339859
</p>`;
}
await transport.sendMail({
from: `"IBCornelsen" <info@online-energieausweis.org>`,
to: rechnung.email || rechnung.benutzer.email,
bcc: "info@online-energieausweis.org",
subject: `Ihr Originalausweis vom Ingenieurbüro Cornelsen (ID: ${ausweis.id})`,
html,
attachments: processedFiles,
});
if (ausweisart === Enums.Ausweisart.BedarfsausweisWohnen) {
await prisma.bedarfsausweisWohnen.update({
where: {
id: ausweis.id,
},
data: {
ausgestellt: true,
},
});
}
}, 3000);
},
});

19
src/pages/dashboard/admin/impersonate-user.astro
View File

@@ -1,21 +1,10 @@
---
import DashboardLayout from "#layouts/DashboardLayout.astro";
import UserLayout from "#layouts/DashboardLayout.astro";
import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants";
import { Enums, prisma } from "#lib/server/prisma";
import { createCaller } from "src/astro-typesafe-api-caller";
import DashboardModule from "#modules/Dashboard/DashboardModule.svelte";
import { Enums } from "#lib/server/prisma";
import ImpersonateUserModule from "#modules/ImpersonateUserModule.svelte";
import { getCurrentUser } from "#lib/server/user";
const caller = createCaller(Astro)
const params = Astro.params;
const user = await caller.user.self.GET.fetch(undefined, {
headers: {
"Authorization": `Bearer ${Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value}`
}
});
const user = await getCurrentUser(Astro)
if (!user) {
return Astro.redirect("/auth/login")
@@ -27,6 +16,6 @@ if (user.rolle !== Enums.BenutzerRolle.ADMIN) {
---
<DashboardLayout title="Impersonate User" {user}>
<DashboardLayout title="Impersonate User" {user} besteller={null}>
<ImpersonateUserModule client:load></ImpersonateUserModule>
</DashboardLayout>

21
src/pages/dashboard/objekte/index.astro
View File

@@ -1,6 +1,8 @@
---
import { Enums, prisma } from "#lib/server/prisma";
import UserLayout from "#layouts/DashboardLayout.astro";
import { getCurrentUser } from "#lib/server/user";
import moment from "moment";
const page = Number(Astro.url.searchParams.get("p"));
@@ -38,6 +40,15 @@ if (user.rolle === Enums.BenutzerRolle.USER) {
SELECT id, updated_at FROM "GEGNachweisGewerbe" WHERE benutzer_id = ${user.id}
ORDER BY updated_at DESC LIMIT 1 OFFSET ${page - 1}`;
} else {
const date = moment().subtract(2, "hours").toDate()
// SELECT id, updated_at FROM "VerbrauchsausweisWohnen" WHERE created_at >= ${date} AND bestellt = ${true} UNION ALL
// SELECT id, updated_at FROM "VerbrauchsausweisGewerbe" WHERE created_at >= ${date} AND bestellt = ${true} UNION ALL
// SELECT id, updated_at FROM "BedarfsausweisWohnen" WHERE created_at >= ${date} AND bestellt = ${true} UNION ALL
// SELECT id, updated_at FROM "BedarfsausweisGewerbe" WHERE created_at >= ${date} AND bestellt = ${true} UNION ALL
// SELECT id, updated_at FROM "GEGNachweisWohnen" WHERE created_at >= ${date} AND bestellt = ${true} UNION ALL
// SELECT id, updated_at FROM "GEGNachweisGewerbe" WHERE created_at >= ${date} AND bestellt = ${true}
result =
await prisma.$queryRaw`SELECT id, updated_at FROM "VerbrauchsausweisWohnen" UNION ALL
SELECT id, updated_at FROM "VerbrauchsausweisGewerbe" UNION ALL
@@ -48,11 +59,11 @@ if (user.rolle === Enums.BenutzerRolle.USER) {
ORDER BY updated_at DESC LIMIT 1 OFFSET ${page - 1}`;
}
if (!result) {
return Astro.redirect("/dashboard/objekte?p=1");
if (result.length > 0) {
return Astro.redirect(`/dashboard/objekte/${result[0].id}?p=${page}`)
}
return Astro.redirect(`/dashboard/objekte/${result[0].id}?p=${page}`)
---
<script></script>
<UserLayout title="Objekte" {user} besteller={null}>
<p>Keine Ausweise konnten gefunden werden.</p>
</UserLayout>