3d.lehrstun.de/services/dashboard_status.py

"""Daten-Helper fuer das Lehrer-Drill-Down-Dashboard (V5).

Siehe docs/lehrer-dashboard.md fuer die 4 Sektionen:
  1. Wer ist heute hier
  2. Wartet auf Review
  3. Drucker-Status
  4. Wer haengt fest
"""
from datetime import date, timedelta

from database import get_db


def wer_ist_heute_hier() -> list[dict]:
    """SuS, die heute schon eingecheckt haben."""
    conn = get_db()
    rows = conn.execute(
        "SELECT c.id AS check_in_id, c.modus, c.freitext, c.erstellt_am, "
        "       p.id AS profil_id, p.vorname, p.tier "
        "FROM check_in c "
        "JOIN profil p ON p.id = c.profil_id "
        "WHERE c.besuch_datum = ? "
        "ORDER BY c.erstellt_am DESC",
        (date.today().isoformat(),)
    ).fetchall()
    conn.close()
    return [dict(r) for r in rows]


def wartet_auf_review() -> list[dict]:
    """Projekte mit Status 'wartet_auf_freigabe' — Lehrer muss reviewen."""
    conn = get_db()
    rows = conn.execute(
        "SELECT pr.id, pr.titel, pr.abgeschlossen_am, pr.selbsteinschaetzung, "
        "       p.vorname, p.tier "
        "FROM projekt pr "
        "LEFT JOIN profil p ON p.id = pr.profil_id "
        "WHERE pr.freigabe_status = 'wartet_auf_freigabe' "
        "ORDER BY pr.abgeschlossen_am ASC",
    ).fetchall()
    conn.close()
    return [dict(r) for r in rows]


def offene_rueckfragen() -> list[dict]:
    """Rueckfragen, die der SuS noch nicht erledigt hat (alt = Warnung)."""
    conn = get_db()
    rows = conn.execute(
        "SELECT r.id, r.text, r.erstellt_am, "
        "       pr.id AS projekt_id, pr.titel AS projekt_titel, "
        "       p.vorname, p.tier "
        "FROM projekt_rueckfrage r "
        "JOIN projekt pr ON pr.id = r.projekt_id "
        "LEFT JOIN profil p ON p.id = pr.profil_id "
        "WHERE r.status = 'offen' "
        "ORDER BY r.erstellt_am ASC",
    ).fetchall()
    conn.close()
    return [dict(r) for r in rows]


def drucker_status_alle() -> list[dict]:
    """Alle Drucker mit Status (oder None, wenn nie gepollt)."""
    conn = get_db()
    rows = conn.execute(
        "SELECT d.id, d.name, d.modell, d.geschlossenes_gehaeuse, d.notiz, "
        "       ds.status, ds.job_name, ds.progress_pct, ds.restzeit_min, "
        "       ds.fehlermeldung, ds.gepollt_am, ds.manuell_gesetzt "
        "FROM drucker d "
        "LEFT JOIN drucker_status ds ON ds.drucker_id = d.id "
        "WHERE d.aktiv = 1 "
        "ORDER BY d.name",
    ).fetchall()
    conn.close()
    return [dict(r) for r in rows]


def wer_haengt_fest(tage: int = 14) -> list[dict]:
    """SuS, die seit > N Tagen keinen Check-In + keinen Projekt-Abschluss hatten."""
    schwelle = (date.today() - timedelta(days=tage)).isoformat()
    conn = get_db()
    rows = conn.execute(
        "SELECT p.id, p.vorname, p.tier, "
        "       (SELECT MAX(besuch_datum) FROM check_in WHERE profil_id = p.id) AS letzter_check_in, "
        "       (SELECT MAX(abgeschlossen_am) FROM projekt WHERE profil_id = p.id) AS letzter_abschluss "
        "FROM profil p "
        "WHERE p.aktiv = 1 "
        "  AND ( "
        "       (SELECT MAX(besuch_datum) FROM check_in WHERE profil_id = p.id) IS NULL "
        "       OR (SELECT MAX(besuch_datum) FROM check_in WHERE profil_id = p.id) < ? "
        "      ) "
        "ORDER BY letzter_check_in DESC NULLS LAST",
        (schwelle,)
    ).fetchall()
    conn.close()
    return [dict(r) for r in rows]


def dashboard_zahlen() -> dict:
    """Badge-Zahlen fuer die Header-Anzeige."""
    conn = get_db()
    review_n = conn.execute(
        "SELECT COUNT(*) AS n FROM projekt WHERE freigabe_status = 'wartet_auf_freigabe'"
    ).fetchone()["n"]
    heute_n = conn.execute(
        "SELECT COUNT(*) AS n FROM check_in WHERE besuch_datum = ?",
        (date.today().isoformat(),)
    ).fetchone()["n"]
    drucker_problem_n = conn.execute(
        "SELECT COUNT(*) AS n FROM drucker_status WHERE status IN ('failed', 'offline')"
    ).fetchone()["n"]
    conn.close()
    return {
        "review_n": review_n,
        "heute_n": heute_n,
        "drucker_problem_n": drucker_problem_n,
    }