update

2026-06-14 22:43:54 +02:00
parent 6e5d673ca7
commit 08dd0ccd69
6 changed files with 107 additions and 39 deletions
--- a/backend/database.py
+++ b/backend/database.py
@@ -66,6 +66,7 @@ CREATE TABLE IF NOT EXISTS baustein_progress (
    gute_antworten INTEGER NOT NULL DEFAULT 0,
    absolviert TEXT,
    verstanden TEXT,
+    gemeistert TEXT,
    updated_at TEXT NOT NULL,
    PRIMARY KEY (topic, baustein)
 )
@@ -101,6 +102,10 @@ async def init_db():
        await db.execute("ALTER TABLE baustein_progress ADD COLUMN verstanden TEXT")
    except aiosqlite.OperationalError:
        pass
+    try:  # Migration für Bestands-DBs ohne gemeistert-Spalte (Meisterpfad 25)
+        await db.execute("ALTER TABLE baustein_progress ADD COLUMN gemeistert TEXT")
+    except aiosqlite.OperationalError:
+        pass
    # Migration: alte vertiefungen-Tabelle → baustein_texte (Bestand = lange Form, art 'deepdive')
    cursor = await db.execute("SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'vertiefungen'")
    if await cursor.fetchone():
@@ -338,10 +343,10 @@ async def list_vertiefungen(topic: str) -> dict[str, set[str]]:
 async def list_baustein_progress(topic: str) -> list[dict]:
    db = await get_db()
    cursor = await db.execute(
-        "SELECT baustein, gute_antworten, absolviert, verstanden FROM baustein_progress WHERE topic = ?", (topic,)
+        "SELECT baustein, gute_antworten, absolviert, verstanden, gemeistert FROM baustein_progress WHERE topic = ?", (topic,)
    )
    rows = await cursor.fetchall()
-    return [{"baustein": b, "gute_antworten": n, "absolviert": a, "verstanden": v} for b, n, a, v in rows]
+    return [{"baustein": b, "gute_antworten": n, "absolviert": a, "verstanden": v, "gemeistert": m} for b, n, a, v, m in rows]


 async def set_baustein_score(topic: str, baustein: str, score: int) -> int:
@@ -375,6 +380,23 @@ async def set_baustein_verstanden(topic: str, baustein: str) -> bool:
    return cursor.rowcount > 0


+async def set_baustein_gemeistert(topic: str, baustein: str) -> bool:
+    """Markiert gemeistert (Meisterpfad, Score 25); True nur beim ersten Mal. Sticky."""
+    db = await get_db()
+    now = _now()
+    await db.execute(
+        "INSERT OR IGNORE INTO baustein_progress (topic, baustein, gute_antworten, updated_at) VALUES (?, ?, 0, ?)",
+        (topic, baustein, now),
+    )
+    cursor = await db.execute(
+        "UPDATE baustein_progress SET gemeistert = ?, updated_at = ? "
+        "WHERE topic = ? AND baustein = ? AND gemeistert IS NULL",
+        (now, now, topic, baustein),
+    )
+    await db.commit()
+    return cursor.rowcount > 0
+
+
 async def set_baustein_absolviert(topic: str, baustein: str) -> bool:
    """Markiert absolviert; True nur beim ersten Mal (steuert den Element-Task)."""
    db = await get_db()
--- a/backend/lernen.py
+++ b/backend/lernen.py
@@ -19,26 +19,36 @@ from textkit import _norm_titel

 log = logging.getLogger("creator.lernen")

-NOETIG = 3   # gute Antworten bis "absolviert" (Tier 1)
+NOETIG = 3    # gute Antworten bis "absolviert" (Tier 1)
 MASTERY = 10  # Score bis "verstanden" (Tier 2)
+MEISTERN = 25  # Score bis "gemeistert" (Tier 3, Maximum)
 VERTIEFUNG_TIMEOUT = 600
 CHAT_TIMEOUT = 240
 PRUEFUNG_TIMEOUT = 120  # kurze JSON-Turns; deckelt die Serien-Latenz pro Prüfungs-Schritt
 KRITIK_MAX_RUNDEN = 2   # Generator → Kritiker → ggf. Neu, höchstens so oft


-def score_berechnen(score_vor_frage: int, gut: bool, tier2: bool, absolviert: bool) -> int:
+def score_berechnen(
+    score_vor_frage: int, gut: bool, tier2: bool, tier3: bool, absolviert: bool, gemeistert: bool,
+) -> int:
    """Neuer Score nach einer Antwort · driftfrei (immer aus dem Basis-Score gerechnet).

-    Tier 1 (tier2=False): +1 bei richtig, KEINE Strafe bei falsch, Deckel NOETIG (3).
-    Tier 2 (tier2=True):  +1 bei richtig (Deckel MASTERY=10), −1 bei falsch.
-    Boden ist NOETIG, sobald der Baustein absolviert ist — sonst 0 (kann nicht
-    unter 3 fallen, absolviert bleibt erhalten). Re-Bewertung nutzt denselben
-    Basis-Score und ersetzt so das vorige Ergebnis (kein Doppelzählen).
+    Drei Stufen, freigeschaltet über Guide-Flags:
+    - Tier 1 (tier2=False): +1 bei richtig, KEINE Strafe, Deckel NOETIG (3).
+    - Tier 2 (tier2, nicht tier3): +1 / −1, Boden 3, Deckel MASTERY (10).
+    - Tier 3 (tier3, Meisterpfad): +1 / −2, Boden 10, Deckel MEISTERN (25).
+    Boden vor dem Absolvieren ist 0 (sonst NOETIG — absolviert bleibt erhalten).
+    Ist der Baustein gemeistert, friert der Score bei MEISTERN ein (keine Punkte mehr).
+    Re-Bewertung nutzt denselben Basis-Score und ersetzt das vorige Ergebnis.
    """
-    delta = 1 if gut else (-1 if tier2 else 0)
-    floor = NOETIG if absolviert else 0
-    cap = MASTERY if tier2 else NOETIG
+    if gemeistert:
+        return MEISTERN
+    if not tier2:
+        delta, floor, cap = (1 if gut else 0), (NOETIG if absolviert else 0), NOETIG
+    elif not tier3:
+        delta, floor, cap = (1 if gut else -1), NOETIG, MASTERY
+    else:
+        delta, floor, cap = (1 if gut else -2), MASTERY, MEISTERN
    return max(floor, min(cap, score_vor_frage + delta))


--- a/backend/models.py
+++ b/backend/models.py
@@ -195,7 +195,8 @@ class BausteinPruefungRequest(BaseModel):
    frage: str = Field(default="", max_length=2000)  # aktuell geprüfte Frage (für diskussion/antwort)
    letzte_bewertung: str = Field(default="", max_length=2000)  # Feedback der letzten Bewertung (Kontext für diskussion)
    score_vor_frage: int = 0  # Score, als die Frage gestellt wurde → driftfreies (Re-)Bewerten
-    tier2: bool = False  # Mastery-Modus (ganzer Guide absolviert) → −1 bei falsch, Deckel 10
+    tier2: bool = False  # ganzer Guide absolviert (alle ≥3) → −1 bei falsch, Deckel 10
+    tier3: bool = False  # ganzer Guide verstanden (alle ≥10) → Meisterpfad, −2 bei falsch, Deckel 25
    messages: list[ChatMessage] = []  # Dialog bisher; leer = erste Frage
    provider: ProviderType = "claude"

@@ -208,12 +209,14 @@ class BausteinPruefungResponse(BaseModel):
    gute_antworten: int
    absolviert: bool
    verstanden: bool = False
+    gemeistert: bool = False


 class BausteinLernstand(BaseModel):
    gute_antworten: int
    absolviert: bool
    verstanden: bool
+    gemeistert: bool
    vertiefung: bool
    deepdive: bool

--- a/backend/routes.py
+++ b/backend/routes.py
@@ -14,11 +14,11 @@ from database import (
    list_progress, set_progress, delete_progress,
    create_element, list_elements, get_element, update_element, delete_element,
    get_vertiefung, set_vertiefung, list_vertiefungen,
-    list_baustein_progress, set_baustein_score, set_baustein_absolviert, set_baustein_verstanden, delete_baustein_daten,
+    list_baustein_progress, set_baustein_score, set_baustein_absolviert, set_baustein_verstanden, set_baustein_gemeistert, delete_baustein_daten,
 )
 from bausteine import generate_bausteine, cancel_bausteine, bausteine_status, active_bausteine, reset_bausteine
 from elements import generate_element, chat_with_guide, chat_with_element, check_element, style_element, refine_suggestion
-from lernen import NOETIG, MASTERY, baustein_chat, baustein_diskussion, baustein_element_anlegen, pruefung_bewertung, pruefung_frage, score_berechnen, vertiefung_generieren
+from lernen import NOETIG, MASTERY, MEISTERN, baustein_chat, baustein_diskussion, baustein_element_anlegen, pruefung_bewertung, pruefung_frage, score_berechnen, vertiefung_generieren
 from guide import generate_guide, guide_slot_dateien
 from pipeline import cancel_guide
 from regeln import FORMATE, formate_stats, guide_lock, ist_absolviert, lade_lernstand
@@ -162,6 +162,7 @@ async def baustein_lernstand(topic: str):
            "gute_antworten": p["gute_antworten"],
            "absolviert": p["absolviert"] is not None,
            "verstanden": p["verstanden"] is not None,
+            "gemeistert": p["gemeistert"] is not None,
            "vertiefung": "vertiefung" in texte.get(p["baustein"], set()),
            "deepdive": "deepdive" in texte.get(p["baustein"], set()),
        }
@@ -170,7 +171,7 @@ async def baustein_lernstand(topic: str):
    for b, arten in texte.items():
        if b not in bausteine:
            bausteine[b] = {
-                "gute_antworten": 0, "absolviert": False, "verstanden": False,
+                "gute_antworten": 0, "absolviert": False, "verstanden": False, "gemeistert": False,
                "vertiefung": "vertiefung" in arten, "deepdive": "deepdive" in arten,
            }
    return {"bausteine": bausteine}
@@ -209,11 +210,12 @@ async def baustein_chat_route(req: BausteinChatRequest):
 async def baustein_pruefung_route(req: BausteinPruefungRequest):
    stand = next(
        (p for p in await list_baustein_progress(req.topic) if p["baustein"] == req.baustein),
-        {"gute_antworten": 0, "absolviert": None, "verstanden": None},
+        {"gute_antworten": 0, "absolviert": None, "verstanden": None, "gemeistert": None},
    )
    gute = stand["gute_antworten"]
    absolviert = stand["absolviert"] is not None
    verstanden = stand["verstanden"] is not None
+    gemeistert = stand["gemeistert"] is not None
    vertiefung = await _bester_text(req.topic, req.baustein)
    msgs = [m.model_dump() for m in req.messages]

@@ -221,7 +223,7 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
        frage = await pruefung_frage(req.topic, req.baustein, req.section, vertiefung, msgs, provider=req.provider)
        if frage is None:
            raise HTTPException(502, "Frage fehlgeschlagen — bitte erneut versuchen")
-        return {"frage": frage, "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden}
+        return {"frage": frage, "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden, "gemeistert": gemeistert}

    if req.aktion == "diskussion":
        if not req.frage.strip():
@@ -232,7 +234,7 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
        )
        if reply is None:
            raise HTTPException(502, "Diskussion fehlgeschlagen — bitte erneut versuchen")
-        return {"reply": reply, "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden}
+        return {"reply": reply, "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden, "gemeistert": gemeistert}

    # aktion == "antwort" — mindestens eine Nutzer-Antwort muss im Dialog stehen
    # (nach einer Diskussion endet der Dialog mit dem Tutor; Re-Bewertung bleibt erlaubt).
@@ -247,7 +249,9 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
        raise HTTPException(502, "Bewertung fehlgeschlagen — bitte erneut versuchen")

    # Score driftfrei aus dem Basis-Score rechnen (Re-Bewertung ersetzt das vorige Ergebnis).
-    score = score_berechnen(req.score_vor_frage, data["bewertung"] == "gut", req.tier2, absolviert)
+    score = score_berechnen(
+        req.score_vor_frage, data["bewertung"] == "gut", req.tier2, req.tier3, absolviert, gemeistert,
+    )
    gute = await set_baustein_score(req.topic, req.baustein, score)
    if score >= NOETIG and not absolviert:
        absolviert = True
@@ -256,7 +260,10 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
    if score >= MASTERY and not verstanden:
        await set_baustein_verstanden(req.topic, req.baustein)
        verstanden = True
-    return {"feedback": data["feedback"], "bewertung": data["bewertung"], "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden}
+    if score >= MEISTERN and not gemeistert:
+        await set_baustein_gemeistert(req.topic, req.baustein)
+        gemeistert = True
+    return {"feedback": data["feedback"], "bewertung": data["bewertung"], "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden, "gemeistert": gemeistert}


 # --- Guides ---