diff --git a/kimi.md b/kimi.md
index 261b655..c10ee89 100644
--- a/kimi.md
+++ b/kimi.md
@@ -189,6 +189,21 @@ tar -czf mp-dist.tar.gz -C dist .
## 8. Verlauf / offene Punkte
+**Erledigt 04.10. (v1.9):** Zähler-Modul + Registrierungs-Mail + getrennter Name.
+Neue Tabelle `meters` (Zählernummer, Art Strom/Wasser/Gas/Wärme/Sonstiges,
+Stand, Stand-Datum, Wohneinheit nullable, Haus, Pflege-Zeitstempel) mit
+idempotentem Demo-Seed (`seedeZaehler()` läuft bei jedem Start, füllt nur bei
+leerer Tabelle – auch nachträglich auf Live-DB). API: POST/PATCH /api/meters
+(adminOnly), Bootstrap liefert meters (Admin: alle, Mieter: nur eigene Wohnung);
+Haus wird aus der Wohneinheit abgeleitet, bei Allgemeinzählern direkt gepflegt.
+Frontend: neue Seite /zaehler (Kartenraster, Filter nach Haus + Art, Admin-
+Dialog zum Anlegen/Bearbeiten), Nav-Eintrag mit Gauge-Icon, Store-Aktionen
+addZaehler/updateZaehler. Registrierung: neuer Mieter löst HTML-Mail an die
+Verwaltung aus (Name/Benutzername/E-Mail/Wohnung, Button zur Benutzerverwaltung);
+Formular jetzt mit getrennten Feldern Vorname/Nachname + Benutzername.
+E2E verifiziert: Zähler-CRUD + Rechte (403 Mieter), Registrierung inkl.
+Mail-Zustellung an beide Verwaltungspostfächer, Umlaute sauber.
+
**Erledigt 02.10. (v1.8):** Schadensmeldungen starten jetzt automatisch eine
Unterhaltung (Thread „Schadensmeldung: …" mit erster Nachricht inkl. Kategorie/
Priorität, ungelesen für die Gegenseite) – Antworten darauf lösen über
diff --git a/server/src/db.js b/server/src/db.js
index 6b8f45a..b6ef406 100644
--- a/server/src/db.js
+++ b/server/src/db.js
@@ -115,6 +115,18 @@ CREATE TABLE IF NOT EXISTS sessions (
expires TIMESTAMPTZ NOT NULL
);
CREATE INDEX IF NOT EXISTS idx_sessions_user ON sessions(user_id);
+
+CREATE TABLE IF NOT EXISTS meters (
+ id TEXT PRIMARY KEY,
+ unit_id TEXT REFERENCES units(id), -- NULL = Haus-/Allgemeinzähler
+ building TEXT NOT NULL,
+ nummer TEXT NOT NULL, -- Zählernummer
+ art TEXT NOT NULL CHECK (art IN ('Strom','Wasser','Gas','Wärme','Sonstiges')),
+ stand NUMERIC(12,3) NOT NULL,
+ stand_am TEXT NOT NULL, -- Datum des abgelesenen Standes
+ geaendert_am TEXT NOT NULL -- letzte Pflege durch die Verwaltung
+);
+CREATE INDEX IF NOT EXISTS idx_meters_unit ON meters(unit_id);
`
async function init() {
diff --git a/server/src/index.js b/server/src/index.js
index 96868dc..cc9ca57 100644
--- a/server/src/index.js
+++ b/server/src/index.js
@@ -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}`))
}
diff --git a/server/src/seed-data.js b/server/src/seed-data.js
index 89ec9f7..14babe4 100644
--- a/server/src/seed-data.js
+++ b/server/src/seed-data.js
@@ -152,4 +152,20 @@ const announcements = [
{ id: 'a-4', title: 'Nebenkostenabrechnungen 2025 versandt', text: 'Alle Abrechnungen liegen digital im Dokumentenbereich vor. Nachzahlungen sind bis 31.10.2026 überwiesen.', date: '31.05.2026', tag: 'Abrechnung' },
]
-module.exports = { users, registrationCodes, tickets, documents, threads, announcements }
+const meters = [
+ // Hauptstraße 12 (hs) – Wohnung hs-7 (Anna Berger)
+ { id: 'z-1', unit_id: 'hs-7', building: 'Hauptstraße 12', nummer: 'ST-0815-4711', art: 'Strom', stand: 48231.4, stand_am: '01.09.2026', geaendert_am: '01.09.2026, 10:15' },
+ { id: 'z-2', unit_id: 'hs-7', building: 'Hauptstraße 12', nummer: 'WA-0815-1024', art: 'Wasser', stand: 903.812, stand_am: '01.09.2026', geaendert_am: '01.09.2026, 10:16' },
+ { id: 'z-3', unit_id: 'hs-7', building: 'Hauptstraße 12', nummer: 'GA-0815-3387', art: 'Gas', stand: 22114.9, stand_am: '01.09.2026', geaendert_am: '01.09.2026, 10:17' },
+ // Ringweg 3 (rw) – Wohnung rw-4 (Jonas Klein)
+ { id: 'z-4', unit_id: 'rw-4', building: 'Ringweg 3', nummer: 'ST-2201-8842', art: 'Strom', stand: 31877.2, stand_am: '15.09.2026', geaendert_am: '15.09.2026, 09:40' },
+ { id: 'z-5', unit_id: 'rw-4', building: 'Ringweg 3', nummer: 'WA-2201-5518', art: 'Wasser', stand: 412.095, stand_am: '15.09.2026', geaendert_am: '15.09.2026, 09:41' },
+ // Am Park 5 (ap) – Wohnung ap-2
+ { id: 'z-6', unit_id: 'ap-2', building: 'Am Park 5', nummer: 'ST-3307-2210', art: 'Strom', stand: 15002.7, stand_am: '20.09.2026', geaendert_am: '20.09.2026, 14:05' },
+ { id: 'z-7', unit_id: 'ap-2', building: 'Am Park 5', nummer: 'GA-3307-0904', art: 'Gas', stand: 9812.55, stand_am: '20.09.2026', geaendert_am: '20.09.2026, 14:06' },
+ // Haus-/Allgemeinzähler ohne Wohnungsbezug
+ { id: 'z-8', unit_id: null, building: 'Hauptstraße 12', nummer: 'WA-HAUS-0001', art: 'Wasser', stand: 12044.6, stand_am: '01.09.2026', geaendert_am: '01.09.2026, 10:20' },
+ { id: 'z-9', unit_id: null, building: 'Ringweg 3', nummer: 'ST-HAUS-0007', art: 'Strom', stand: 88420.3, stand_am: '15.09.2026', geaendert_am: '15.09.2026, 09:45' },
+]
+
+module.exports = { users, registrationCodes, tickets, documents, threads, announcements, meters }
diff --git a/server/src/seed.js b/server/src/seed.js
index eb22338..a2f59eb 100644
--- a/server/src/seed.js
+++ b/server/src/seed.js
@@ -5,7 +5,7 @@
*/
const { pool } = require('./db')
-const { users, registrationCodes, tickets, documents, threads, announcements } = require('./seed-data')
+const { users, registrationCodes, tickets, documents, threads, announcements, meters } = require('./seed-data')
const generated = require('../seed/generated.json')
async function seed() {
@@ -87,6 +87,14 @@ async function seed() {
)
}
+ for (const z of meters) {
+ await client.query(
+ `INSERT INTO meters (id, unit_id, building, nummer, art, stand, stand_am, geaendert_am)
+ VALUES ($1,$2,$3,$4,$5,$6,$7,$8)`,
+ [z.id, z.unit_id, z.building, z.nummer, z.art, z.stand, z.stand_am, z.geaendert_am],
+ )
+ }
+
await client.query('COMMIT')
return true
} catch (e) {
@@ -98,3 +106,21 @@ async function seed() {
}
module.exports = { seed }
+
+/** Zähler-Demo-Daten: idempotent – läuft bei jedem Start und füllt die
+ * Zähler-Tabelle nur, wenn sie leer ist (auch nachträglich auf bestehenden
+ * Datenbanken, z. B. nach dem v1.9-Update). */
+async function seedeZaehler() {
+ const { rows } = await pool.query('SELECT COUNT(*)::int AS n FROM meters')
+ if (rows[0].n > 0) return false
+ for (const z of meters) {
+ 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)`,
+ [z.id, z.unit_id, z.building, z.nummer, z.art, z.stand, z.stand_am, z.geaendert_am],
+ )
+ }
+ return true
+}
+
+module.exports = { seed, seedeZaehler }
diff --git a/src/App.tsx b/src/App.tsx
index e58ed68..56ae332 100644
--- a/src/App.tsx
+++ b/src/App.tsx
@@ -8,6 +8,7 @@ import Payments from './pages/Payments'
import Tickets from './pages/Tickets'
import Documents from './pages/Documents'
import Messages from './pages/Messages'
+import Zaehler from './pages/Zaehler'
import BenutzerVerwaltung from './pages/BenutzerVerwaltung'
/** Fängt Render-Fehler ab – statt schwarzem Bildschirm: Hinweis + Reload. */
@@ -80,6 +81,7 @@ export default function App() {