孩子学习状态不好怎么调整？把每日沟通+复盘做成一条 AI 自动化流水线

# event.py —— 每日事件的最小结构化模型
from dataclasses import dataclass, field
from datetime import date
from enum import Enum
from typing import Optional

class Tracker(str, Enum):          # 学心四力的观测代理
    DIRECTING   = "心航力"          # 方向：今天知不知道自己该做什么
    FOCUS       = "心定力"          # 专注：在不在任务上
    RESILIENCE  = "心韧力"          # 抗挫：卡住之后能不能回来
    EFFICACY    = "心效力"          # 胜任：信不信自己能做成

@dataclass
class Event:
    child_id:    str              # 归到哪个孩子
    day:         date             # 发生日期（对账的主键之一）
    kind:        str              # "checkin" 打卡 / "qa" 问答
    tracker:     Tracker          # 本事件主要落在哪个力上
    ok:          Optional[bool]   # 打卡类：完成了没
    blocker:     Optional[str]    # 打卡类：卡在哪
    raw_text:    str              # 问答类：孩子的原话（脱敏后入库）
    sentiment:   float = 0.0      # AI 打的情感分，-1~1，落库用
    created_at:  str = field(default_factory=lambda: __import__("datetime").datetime.now().isoformat())

# reply.py —— 决定"怎么说"，而不是让模型自由发挥
SYSTEM_RULE = (
    "你是一名温和的儿童心理陪伴助手。接到孩子的反馈时："
    "1) 先共情，复述他描述的具体事实；"
    "2) 用一句话把行为翻译成可训练的能力（方向/专注/抗挫/胜任）；"
    "3) 给出一个'明天可以试一试'的具体小动作；"
    "4) 字数≤60，绝不批评，绝不贴标签。"
)

def build_prompt(event: Event, child_profile: str) -> str:
    # 知识库注入：孩子的历史趋势 + 四力口径，让 AI 的接话"有上下文"
    trend = summarize_history(event.child_id, event.day)   # 见关③
    return f"【孩子档案】{child_profile}\n【近期趋势】{trend}\n" \
           f"【本次输入】{event.raw_text or event.blocker or '今日打卡完成'}\n" \
           f"依据 {SYSTEM_RULE} 给出回复。"

# store.py —— 落库 + 每日聚合成一张"对账表"
import sqlite3, datetime

SCHEMA = """
CREATE TABLE IF NOT EXISTS events(
  child_id TEXT, day TEXT, kind TEXT, tracker TEXT, ok INTEGER,
  blocker TEXT, raw_text TEXT, sentiment REAL, created_at TEXT
);
CREATE TABLE IF NOT EXISTS daily_metrics(
  child_id TEXT, day TEXT PRIMARY KEY,
  n_directing INTEGER DEFAULT 0, n_focus INTEGER DEFAULT 0,
  n_resilience INTEGER DEFAULT 0, n_efficacy INTEGER DEFAULT 0,
  ok_rate REAL, avg_sentiment REAL
);
"""

def upsert_today(conn, child_id: str, day: str = str(datetime.date.today())):
    """每次写入后，把当日记录收敛成一行，供周复盘直接取用。"""
    row = conn.execute(
        "SELECT COUNT(*), COALESCE(AVG(ok),0), COALESCE(AVG(sentiment),0) "
        "FROM events WHERE child_id=? AND day=? AND ok IS NOT NULL", (child_id, day)
    ).fetchone()
    n_ok, ok_rate, avg_senti = row[0], (row[1] or 0), (row[2] or 0)
    counts = {t: 0 for t in ("心航力", "心定力", "心韧力", "心效力")}
    for t, c in conn.execute(
        "SELECT tracker, COUNT(*) FROM events WHERE child_id=? AND day=? GROUP BY tracker",
        (child_id, day)):
        counts[t] = c
    conn.execute(
        "INSERT OR REPLACE INTO daily_metrics(child_id, day, n_directing, n_focus, "
        "n_resilience, n_efficacy, ok_rate, avg_sentiment) "
        "VALUES(?,?,?,?,?,?,?,?)",
        (child_id, day, counts["心航力"], counts["心定力"], counts["心韧力"],
         counts["心效力"], ok_rate, avg_senti))
    conn.commit()

# weekly.py —— 每周复盘报告
def weekly_report(conn, child_id: str, day: str):
    since = (datetime.date.fromisoformat(day) - datetime.timedelta(days=6)).isoformat()
    rows = conn.execute(
        "SELECT day, n_resilience, n_focus, n_directing, n_efficacy, "
        "ROUND(ok_rate,2), ROUND(avg_sentiment,2) "
        "FROM daily_metrics WHERE child_id=? AND day>=? ORDER BY day", (child_id, since)
    ).fetchall()
    # 关键卡点：把孩子的原话问题也一起带进面谈
    blockers = [r[0] for r in conn.execute(
        "SELECT blocker FROM events WHERE child_id=? AND day>=? AND blocker IS NOT NULL "
        "ORDER BY created_at", (child_id, since)).fetchall() if r[0]]
    return {"days": rows,
            "curve": moving_avg([r[1] for r in rows], window=5),  # 抗挫力是复盘主盯项
            "blockers": blockers}