v1.9: Zähler-Modul (Strom/Wasser/Gas) + Registrierungs-Mail an Verwaltung + Vorname/Nachname im Formular
This commit is contained in:
+101
-2
@@ -9,7 +9,7 @@
|
||||
const express = require('express')
|
||||
const crypto = require('crypto')
|
||||
const { pool, init, sessionsAufraeumen } = require('./db')
|
||||
const { seed } = require('./seed')
|
||||
const { seed, seedeZaehler } = require('./seed')
|
||||
const mail = require('./mail')
|
||||
|
||||
const PORT = Number(process.env.PORT || 3000)
|
||||
@@ -111,6 +111,10 @@ const mapThread = (t) => ({
|
||||
})
|
||||
const mapCode = (c) => ({ code: c.code, einheitId: c.einheit_id, erstelltAm: c.erstellt_am, verwendetAm: c.verwendet_am ?? undefined })
|
||||
const mapAnnouncement = (a) => ({ id: a.id, title: a.title, text: a.text, date: a.date, tag: a.tag })
|
||||
const mapMeter = (m) => ({
|
||||
id: m.id, unitId: m.unit_id, building: m.building, nummer: m.nummer, art: m.art,
|
||||
stand: Number(m.stand), standAm: m.stand_am, geaendertAm: m.geaendert_am,
|
||||
})
|
||||
|
||||
const deutschesDatum = () => new Date().toLocaleDateString('de-DE')
|
||||
const deutschesDatumZeit = () => new Date().toLocaleString('de-DE')
|
||||
@@ -181,6 +185,30 @@ app.post('/api/auth/register', async (req, res, next) => {
|
||||
String(email || '').trim(), codeRows[0].einheit_id, deutschesDatum()],
|
||||
)
|
||||
await sessionAnlegen(res, id, req)
|
||||
// Verwaltung über die neue Registrierung benachrichtigen (fire-and-forget)
|
||||
const { rows: einheitRows } = await pool.query('SELECT * FROM units WHERE id = $1', [codeRows[0].einheit_id])
|
||||
const label = mail.einheitLabel(mapUnit(einheitRows[0]))
|
||||
const benutzernameNeu = String(benutzername || '').trim()
|
||||
const nameNeu = String(name || '').trim()
|
||||
const emailNeu = String(email || '').trim()
|
||||
const betreff = `Neue Mieter-Registrierung: ${nameNeu} (${label})`
|
||||
const text =
|
||||
`Im Mieterportal hat sich ein neuer Mieter registriert.\n\n` +
|
||||
`Name: ${nameNeu}\nBenutzername: ${benutzernameNeu}\nE-Mail: ${emailNeu}\nWohnung: ${label}\nRegistriert am: ${deutschesDatumZeit()}`
|
||||
const html = mail.baueHtmlMail({
|
||||
titel: 'Neue Mieter-Registrierung',
|
||||
untertitel: label,
|
||||
einleitung: `Im Mieterportal hat sich ein neuer Mieter registriert:`,
|
||||
zeilen: [
|
||||
['Name', nameNeu],
|
||||
['Benutzername', benutzernameNeu],
|
||||
['E-Mail', emailNeu],
|
||||
['Wohnung', label],
|
||||
['Registriert am', deutschesDatumZeit()],
|
||||
],
|
||||
aktionenHtml: mail.buttonHtml('Zur Benutzerverwaltung', `${process.env.PORTAL_URL || 'https://mieterportal.hocks.eu'}/benutzer`),
|
||||
})
|
||||
mail.benachrichtigeVerwaltung(betreff, text, html)
|
||||
res.json({ benutzer: oeffentlicherBenutzer(rows[0]) })
|
||||
} catch (e) { next(e) }
|
||||
})
|
||||
@@ -190,7 +218,7 @@ app.get('/api/bootstrap', auth, async (req, res, next) => {
|
||||
try {
|
||||
const istAdmin = req.user.rolle === 'verwaltung'
|
||||
const einheit = req.user.einheit_id
|
||||
const [units, transactions, documents, tickets, threads, messages, announcements, users, codes] =
|
||||
const [units, transactions, documents, tickets, threads, messages, announcements, users, codes, meters] =
|
||||
await Promise.all([
|
||||
pool.query('SELECT * FROM units ORDER BY id'),
|
||||
istAdmin
|
||||
@@ -215,6 +243,9 @@ app.get('/api/bootstrap', auth, async (req, res, next) => {
|
||||
istAdmin
|
||||
? pool.query('SELECT * FROM registration_codes ORDER BY erstellt_am DESC')
|
||||
: { rows: [] },
|
||||
istAdmin
|
||||
? pool.query('SELECT * FROM meters ORDER BY building, nummer')
|
||||
: pool.query('SELECT * FROM meters WHERE unit_id = $1 ORDER BY nummer', [einheit]),
|
||||
])
|
||||
// Threads mit ihren Nachrichten zusammenführen
|
||||
const nachrichtenProThread = {}
|
||||
@@ -234,6 +265,7 @@ app.get('/api/bootstrap', auth, async (req, res, next) => {
|
||||
announcements: announcements.rows.map(mapAnnouncement),
|
||||
benutzer: users.rows.map(oeffentlicherBenutzer),
|
||||
codes: codes.rows.map(mapCode),
|
||||
meters: meters.rows.map(mapMeter),
|
||||
})
|
||||
} catch (e) { next(e) }
|
||||
})
|
||||
@@ -338,6 +370,71 @@ app.patch('/api/tickets/:id', auth, adminOnly, async (req, res, next) => {
|
||||
} catch (e) { next(e) }
|
||||
})
|
||||
|
||||
// ── Zählerstände (Strom / Wasser / Gas) ─────────────────────
|
||||
const ZAEHLER_ARTEN = ['Strom', 'Wasser', 'Gas', 'Wärme', 'Sonstiges']
|
||||
|
||||
app.post('/api/meters', auth, adminOnly, async (req, res, next) => {
|
||||
try {
|
||||
const { nummer, art, stand, unitId, building } = req.body || {}
|
||||
if (!String(nummer || '').trim()) return res.status(400).json({ fehler: 'Zählernummer fehlt.' })
|
||||
if (!ZAEHLER_ARTEN.includes(art)) return res.status(400).json({ fehler: 'Ungültige Zählerart.' })
|
||||
const standZahl = Number(stand)
|
||||
if (!Number.isFinite(standZahl) || standZahl < 0) return res.status(400).json({ fehler: 'Ungültiger Zählerstand.' })
|
||||
// Wohnung angegeben → Haus aus der Wohnung ableiten; sonst muss das Haus im Body stehen
|
||||
let einheitId = unitId ? String(unitId) : null
|
||||
let haus = String(building || '').trim()
|
||||
if (einheitId) {
|
||||
const { rows: u } = await pool.query('SELECT building FROM units WHERE id = $1', [einheitId])
|
||||
if (!u.length) return res.status(400).json({ fehler: 'Wohnung unbekannt.' })
|
||||
haus = u[0].building
|
||||
} else if (!haus) {
|
||||
return res.status(400).json({ fehler: 'Haus fehlt (bei Zählern ohne Wohnung).' })
|
||||
}
|
||||
const id = `z-${Date.now()}`
|
||||
const { rows } = await pool.query(
|
||||
`INSERT INTO meters (id, unit_id, building, nummer, art, stand, stand_am, geaendert_am)
|
||||
VALUES ($1,$2,$3,$4,$5,$6,$7,$8) RETURNING *`,
|
||||
[id, einheitId, haus, String(nummer).trim(), art, standZahl, deutschesDatum(), deutschesDatumZeit()],
|
||||
)
|
||||
res.json({ meter: mapMeter(rows[0]) })
|
||||
} catch (e) { next(e) }
|
||||
})
|
||||
|
||||
app.patch('/api/meters/:id', auth, adminOnly, async (req, res, next) => {
|
||||
try {
|
||||
const b = req.body || {}
|
||||
const { rows } = await pool.query('SELECT * FROM meters WHERE id = $1', [req.params.id])
|
||||
if (!rows.length) return res.status(404).json({ fehler: 'Zähler nicht gefunden.' })
|
||||
const m = rows[0]
|
||||
const neu = {
|
||||
nummer: b.nummer !== undefined ? String(b.nummer).trim() : m.nummer,
|
||||
art: b.art !== undefined ? String(b.art) : m.art,
|
||||
stand: b.stand !== undefined ? Number(b.stand) : Number(m.stand),
|
||||
unit_id: b.unitId !== undefined ? (b.unitId || null) : m.unit_id,
|
||||
building: m.building,
|
||||
}
|
||||
if (!neu.nummer) return res.status(400).json({ fehler: 'Zählernummer darf nicht leer sein.' })
|
||||
if (!ZAEHLER_ARTEN.includes(neu.art)) return res.status(400).json({ fehler: 'Ungültige Zählerart.' })
|
||||
if (!Number.isFinite(neu.stand) || neu.stand < 0) return res.status(400).json({ fehler: 'Ungültiger Zählerstand.' })
|
||||
if (neu.unit_id) {
|
||||
const { rows: u } = await pool.query('SELECT building FROM units WHERE id = $1', [neu.unit_id])
|
||||
if (!u.length) return res.status(400).json({ fehler: 'Wohnung unbekannt.' })
|
||||
neu.building = u[0].building // Haus folgt immer der Wohnung
|
||||
} else if (b.building !== undefined && String(b.building).trim()) {
|
||||
neu.building = String(b.building).trim()
|
||||
}
|
||||
// Stand-Datum nur neu setzen, wenn sich der Stand ändert
|
||||
const standGeaendert = b.stand !== undefined && neu.stand !== Number(m.stand)
|
||||
const { rows: aktualisiert } = await pool.query(
|
||||
`UPDATE meters SET nummer = $1, art = $2, stand = $3, unit_id = $4, building = $5,
|
||||
stand_am = $6, geaendert_am = $7
|
||||
WHERE id = $8 RETURNING *`,
|
||||
[neu.nummer, neu.art, neu.stand, neu.unit_id, neu.building,
|
||||
standGeaendert ? deutschesDatum() : m.stand_am, deutschesDatumZeit(), req.params.id],
|
||||
)
|
||||
res.json({ meter: mapMeter(aktualisiert[0]) })
|
||||
} catch (e) { next(e) }
|
||||
})
|
||||
// ── Nachrichten (Threads) ────────────────────────────────────
|
||||
app.post('/api/threads', auth, async (req, res, next) => {
|
||||
try {
|
||||
@@ -544,6 +641,8 @@ async function start() {
|
||||
await warteAufDatenbank()
|
||||
const geseedet = await seed()
|
||||
if (geseedet) console.log('[api] Demo-Daten eingespielt (50 Wohnungen, 552 Buchungen, …)')
|
||||
const zaehlerGeseedet = await seedeZaehler()
|
||||
if (zaehlerGeseedet) console.log('[api] Zähler-Demo-Daten eingespielt')
|
||||
setInterval(sessionsAufraeumen, 60 * 60 * 1000).unref()
|
||||
app.listen(PORT, () => console.log(`[api] mp-api lauscht auf :${PORT}`))
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user