patrickandClaude Sonnet 5
aba991bbe2
CI / backend-tests (push) Successful in 54s
- benutzer.email ergänzt (additive Migration 0003) - Prompt 20 hatte kein E-Mail- Feld vorgesehen, aber Karte 05 braucht es für Benachrichtigungen - Dashboard-Kennzahlen (Prompt 12.2): offen/in_bearbeitung/nachgefuellt_teilweise zählen gemeinsam als "offen", genehmigte Mindermengen separat, kürzlich erledigt (7 Tage), problematische Objekte - Ablaufdaten-Warnungen (Prompt 14): serverseitige Statusberechnung gueltig/bald_ablaufend/abgelaufen je Objektposition, Standard-Warnzeitraum 30 Tage falls am Material nicht gesetzt, sortiert nach verbleibenden Tagen (E1: einzige Zeit-/Fälligkeits-Sicht in V1, keine Kontrollintervall-Logik) - GET /fehlbestaende um Filter (Standort/Objekt/Material/genehmigt) und Alter-Sortierung erweitert (Prompt 12.3) - Asynchrone E-Mail-Benachrichtigung bei neuem Fehlbestand (Karte 05): fire-and- forget an aktive Materialverantwortliche/Leitungsverantwortliche mit hinterlegter E-Mail; kein SMTP konfiguriert -> wird nur geloggt, kein harter Fehler - Tests: Aggregationsregel, Ablaufdaten-Filterung/Sortierung, Rollenrechte, E-Mail-Versand (SMTP gemockt, kein Docker/Test-Mailserver im Host-Runner verfügbar - Aufruf mit korrekten Empfängern/Betreff wird geprüft) Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01L85hmKbvX7Cqkq47KnQhFt
60 lines
2.4 KiB
Python
60 lines
2.4 KiB
Python
import asyncio
|
|
import logging
|
|
|
|
from sqlalchemy import select
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.core.email import send_email
|
|
from app.models.auth import Benutzer, BenutzerRolle, RolleTyp
|
|
from app.models.fehlbestand import Fehlbestand
|
|
from app.models.stammdaten import Material
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
async def _empfaenger_fuer_objekt(db: AsyncSession) -> list[str]:
|
|
"""V1-Vereinfachung: alle aktiven Materialverantwortlichen/Leitungsverantwortlichen
|
|
(Karte 05 spezifiziert keine feinere, zuständigkeitsbasierte Adressierung).
|
|
Feinere Filterung nach Zuständigkeit (Karte 04) wäre eine spätere Ausbaustufe."""
|
|
result = await db.execute(
|
|
select(Benutzer.email)
|
|
.join(BenutzerRolle, BenutzerRolle.benutzer_id == Benutzer.id)
|
|
.where(
|
|
BenutzerRolle.rolle.in_(
|
|
[RolleTyp.materialverantwortlicher, RolleTyp.leitungsverantwortlicher]
|
|
),
|
|
Benutzer.aktiv.is_(True),
|
|
Benutzer.email.is_not(None),
|
|
)
|
|
)
|
|
return [email for (email,) in result.all() if email]
|
|
|
|
|
|
async def benachrichtige_neuer_fehlbestand(db: AsyncSession, *, fehlbestand: Fehlbestand) -> asyncio.Task:
|
|
"""Karte 05: asynchroner E-Mail-Versand bei neuem Fehlbestand, blockiert den
|
|
Kontroll-Workflow nicht (fire-and-forget, Fehler beim Versand werden geloggt,
|
|
nicht an den aufrufenden Request weitergereicht). Gibt den Task zurück, damit
|
|
Tests den Versand deterministisch abwarten können - im normalen Betrieb wird
|
|
der Rückgabewert bewusst nicht awaited."""
|
|
empfaenger = await _empfaenger_fuer_objekt(db)
|
|
material = await db.get(Material, fehlbestand.material_id)
|
|
material_name = material.name if material else str(fehlbestand.material_id)
|
|
|
|
subject = f"Neuer Fehlbestand: {material_name}"
|
|
body = (
|
|
f"Material: {material_name}\n"
|
|
f"Objekt-ID: {fehlbestand.objekt_id}\n"
|
|
f"Sollmenge: {fehlbestand.sollmenge}\n"
|
|
f"Istmenge: {fehlbestand.istmenge}\n"
|
|
f"Fehlmenge: {fehlbestand.fehlmenge}\n"
|
|
f"Entstanden am: {fehlbestand.entstanden_am.isoformat()}\n"
|
|
)
|
|
|
|
async def _senden() -> None:
|
|
try:
|
|
await send_email(to=empfaenger, subject=subject, body=body)
|
|
except Exception: # noqa: BLE001 - Versandfehler dürfen den Workflow nie stören
|
|
logger.exception("E-Mail-Versand für Fehlbestand %s fehlgeschlagen", fehlbestand.id)
|
|
|
|
return asyncio.create_task(_senden())
|