feat: 药链智控Agent 升级 · 中文界面/默认数据/批量导入/曲线/数据集导出

.gitattributes

@@ -0,0 +1,7 @@
+*.csv filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tar.gz filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text

Dockerfile

@@ -0,0 +1,16 @@
+FROM python:3.11-slim
+
+ENV PYTHONDONTWRITEBYTECODE=1
+ENV PYTHONUNBUFFERED=1
+WORKDIR /app
+
+COPY requirements.txt /app/requirements.txt
+RUN pip install -i https://pypi.tuna.tsinghua.edu.cn/simple -r /app/requirements.txt
+
+COPY . /app
+
+ENV PORT=7860
+EXPOSE 7860
+
+CMD ["python", "app.py"]
+

README.md

@@ -0,0 +1,44 @@
+---
+title: 药链智控 Agent
+emoji: 🚚
+colorFrom: indigo
+colorTo: blue
+sdk: docker
+app_port: 7860
+short_description: 药品冷链合规与优化智能体
+---
+
+# 药链智控 Agent
+
+面向医药冷链场景的“推理/工具行动/记忆/校验/回放”闭环智能体，支持多步推理、温控数据持久化、合规校验与验收报告生成。界面中文，移动端友好，支持通过 SiliconFlow 接入 LLM（无钥时自动降级为离线策略）。
+
+## 快速开始
+
+本地运行：
+
+```bash
+pip install -r requirements.txt
+python app.py
+# 访问 http://localhost:7870
+```
+
+Docker 运行：
+
+```bash
+docker build -t pharma-chain-agent .
+docker run -p 7860:7860 -e SILICONFLOW_API_KEY=$SILICONFLOW_API_KEY pharma-chain-agent
+# 访问 http://localhost:7860
+```
+
+## 环境变量
+
+- SILICONFLOW_API_KEY 可选，提供后将通过硅基流模型进行推理。
+- SILICONFLOW_BASE_URL 默认为 https://api.siliconflow.cn/v1
+- SILICONFLOW_MODEL 默认为 deepseek-ai/DeepSeek-V3
+
+## 商业价值
+
+- 适配医药、疫苗、试剂等冷链运输环节的合规与运营优化；
+- 支持异常越界识别、路线建议与审计复核；
+- 可延展对接 IoT 平台、WMS/TMS，形成可落地的企业级解决方案。
+

app.py

@@ -0,0 +1,412 @@
+import os
+import json
+import uuid
+import datetime
+import sqlite3
+import csv
+import io
+from typing import Dict, Any, List
+from fastapi import FastAPI, Request, HTTPException, BackgroundTasks, Form, UploadFile, File
+from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+import httpx
+
+BASE_DIR = os.path.dirname(os.path.abspath(__file__))
+DB_PATH = os.path.join(BASE_DIR, "instance", "pharma.db")
+os.makedirs(os.path.join(BASE_DIR, "instance"), exist_ok=True)
+os.makedirs(os.path.join(BASE_DIR, "templates"), exist_ok=True)
+os.makedirs(os.path.join(BASE_DIR, "static"), exist_ok=True)
+UPLOAD_DIR = os.path.join(BASE_DIR, "uploads")
+os.makedirs(UPLOAD_DIR, exist_ok=True)
+HF_DATASET_DIR = os.path.join(BASE_DIR, "hf_dataset")
+os.makedirs(HF_DATASET_DIR, exist_ok=True)
+
+API_KEY = os.getenv("SILICONFLOW_API_KEY", "").strip()
+BASE_URL = os.getenv("SILICONFLOW_BASE_URL", "https://api.siliconflow.cn/v1").strip()
+MODEL_NAME = os.getenv("SILICONFLOW_MODEL", "deepseek-ai/DeepSeek-V3").strip()
+
+def init_db():
+    conn = sqlite3.connect(DB_PATH)
+    cur = conn.cursor()
+    cur.execute(
+        """
+        CREATE TABLE IF NOT EXISTS shipments (
+            id TEXT PRIMARY KEY,
+            name TEXT,
+            status TEXT DEFAULT '新建',
+            created_at TEXT,
+            updated_at TEXT
+        )
+        """
+    )
+    cur.execute(
+        """
+        CREATE TABLE IF NOT EXISTS sensors (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            shipment_id TEXT,
+            temperature REAL,
+            humidity REAL,
+            location TEXT,
+            ts TEXT
+        )
+        """
+    )
+    cur.execute(
+        """
+        CREATE TABLE IF NOT EXISTS tasks (
+            id TEXT PRIMARY KEY,
+            shipment_id TEXT,
+            title TEXT,
+            status TEXT DEFAULT 'pending',
+            created_at TEXT,
+            updated_at TEXT,
+            result_md TEXT DEFAULT '',
+            logs TEXT DEFAULT '[]'
+        )
+        """
+    )
+    conn.commit()
+    # 初始化默认数据（无数据时）
+    cur.execute("SELECT COUNT(1) FROM shipments")
+    try:
+        cnt = cur.fetchone()[0]
+    except Exception:
+        cnt = 0
+    if cnt == 0:
+        sid = "demo" + str(uuid.uuid4())[:4]
+        now = datetime.datetime.now().isoformat()
+        cur.execute(
+            "INSERT INTO shipments (id, name, status, created_at, updated_at) VALUES (?, ?, ?, ?, ?)",
+            (sid, "示例批次-疫苗-冷链 D01", "新建", now, now),
+        )
+        base_time = datetime.datetime.now()
+        samples = [
+            (5.2, 60.0, "冷库A", base_time + datetime.timedelta(minutes=0)),
+            (5.0, 61.0, "出库→装车", base_time + datetime.timedelta(minutes=15)),
+            (8.5, 59.0, "途中节点1", base_time + datetime.timedelta(minutes=35)),
+            (6.1, 58.0, "途中节点2", base_time + datetime.timedelta(minutes=50)),
+            (4.8, 62.0, "到达冷库B", base_time + datetime.timedelta(minutes=70)),
+        ]
+        for t, h, loc, ts in samples:
+            cur.execute(
+                "INSERT INTO sensors (shipment_id, temperature, humidity, location, ts) VALUES (?, ?, ?, ?, ?)",
+                (sid, t, h, loc, ts.isoformat()),
+            )
+        conn.commit()
+    conn.close()
+
+init_db()
+
+app = FastAPI(title="药链智控 Agent")
+templates = Jinja2Templates(directory=os.path.join(BASE_DIR, "templates"))
+app.mount("/static", StaticFiles(directory=os.path.join(BASE_DIR, "static")), name="static")
+app.mount("/uploads", StaticFiles(directory=UPLOAD_DIR), name="uploads")
+
+def get_conn():
+    return sqlite3.connect(DB_PATH)
+
+def append_log(conn, task_id: str, role: str, content: str):
+    cur = conn.cursor()
+    cur.execute("SELECT logs FROM tasks WHERE id = ?", (task_id,))
+    row = cur.fetchone()
+    logs = json.loads(row[0] or "[]") if row else []
+    logs.append(
+        {"timestamp": datetime.datetime.now().isoformat(), "role": role, "content": content}
+    )
+    cur.execute(
+        "UPDATE tasks SET logs = ?, updated_at = ? WHERE id = ?",
+        (json.dumps(logs, ensure_ascii=False), datetime.datetime.now().isoformat(), task_id),
+    )
+    conn.commit()
+
+async def call_llm(messages: List[Dict[str, str]]) -> str:
+    if not API_KEY:
+        return "【离线推理】将执行冷链合规检查、温控异常识别、路线建议与验收回放。"
+    url = f"{BASE_URL}/chat/completions"
+    headers = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}
+    payload = {
+        "model": MODEL_NAME,
+        "messages": messages,
+        "temperature": 0.3,
+    }
+    async with httpx.AsyncClient(timeout=60.0) as client:
+        try:
+            r = await client.post(url, headers=headers, json=payload)
+            r.raise_for_status()
+            data = r.json()
+            return data.get("choices", [{}])[0].get("message", {}).get("content", "").strip() or "（空响应）"
+        except Exception:
+            return "【备用】系统使用离线策略：以 2℃-8℃ 为冷藏区间，标记越界段并生成纠偏方案。"
+
+def temp_stats(conn, shipment_id: str) -> Dict[str, Any]:
+    cur = conn.cursor()
+    cur.execute(
+        "SELECT temperature, ts, location FROM sensors WHERE shipment_id = ? ORDER BY ts ASC",
+        (shipment_id,),
+    )
+    rows = cur.fetchall()
+    temps = [r[0] for r in rows] if rows else []
+    if not temps:
+        return {
+            "count": 0,
+            "min": None,
+            "max": None,
+            "avg": None,
+            "breaches": [],
+            "timeline": [],
+        }
+    breaches = []
+    for t, ts, loc in rows:
+        if t is not None and (t < 2.0 or t > 8.0):
+            breaches.append({"t": t, "ts": ts, "loc": loc})
+    return {
+        "count": len(temps),
+        "min": min(temps),
+        "max": max(temps),
+        "avg": round(sum(temps) / len(temps), 3),
+        "breaches": breaches,
+        "timeline": [{"t": r[0], "ts": r[1], "loc": r[2]} for r in rows],
+    }
+
+def simple_compliance_check(stats: Dict[str, Any]) -> Dict[str, Any]:
+    ok = stats["count"] > 0 and stats["min"] is not None and stats["max"] is not None and not stats["breaches"]
+    level = "合规" if ok else "警告"
+    reason = "全程处于 2-8℃" if ok else f"发现 {len(stats['breaches'])} 次越界"
+    return {"status": level, "reason": reason}
+
+def optimize_route_hint(stats: Dict[str, Any]) -> str:
+    if not stats["breaches"]:
+        return "建议维持现有路线与包装方案。"
+    first = stats["breaches"][0]
+    return f"建议在 {first['ts']} 附近增设冷媒或改道冷库中转（位置：{first['loc']}）。"
+
+async def agent_run(task_id: str, shipment_id: str, title: str):
+    conn = get_conn()
+    try:
+        cur = conn.cursor()
+        cur.execute("UPDATE tasks SET status = ?, updated_at = ? WHERE id = ?", ("in_progress", datetime.datetime.now().isoformat(), task_id))
+        conn.commit()
+
+        append_log(conn, task_id, "system", "开始推理/决策")
+        plan = await call_llm([
+            {"role": "system", "content": "你是医药冷链合规与运营专家，请用简洁中文输出执行计划。"},
+            {"role": "user", "content": f"任务：{title}；请分步说明：检查项、必要工具动作、验收标准、回放要点。"}
+        ])
+        append_log(conn, task_id, "agent_plan", plan)
+
+        append_log(conn, task_id, "system", "执行工具动作：温控统计")
+        stats = temp_stats(conn, shipment_id)
+        append_log(conn, task_id, "tool", f"温控统计: {json.dumps(stats, ensure_ascii=False)}")
+
+        append_log(conn, task_id, "system", "执行工具动作：合规检查")
+        comp = simple_compliance_check(stats)
+        append_log(conn, task_id, "tool", f"合规检查: {json.dumps(comp, ensure_ascii=False)}")
+
+        append_log(conn, task_id, "system", "执行工具动作：路线建议")
+        route = optimize_route_hint(stats)
+        append_log(conn, task_id, "tool", f"路线建议: {route}")
+
+        verify = await call_llm([
+            {"role": "system", "content": "作为审计验收官，请对执行结果进行核验并给出结论，用中文。"},
+            {"role": "user", "content": f"温控统计: {json.dumps(stats, ensure_ascii=False)}；合规检查: {json.dumps(comp, ensure_ascii=False)}；路线建议: {route}。请判定是否通过并给出改进要点。"}
+        ])
+        append_log(conn, task_id, "agent_verify", verify)
+
+        result_md = f"# 验收结论\n\n- 合规状态：{comp['status']}\n- 理由：{comp['reason']}\n- 路线建议：{route}\n\n## 规划摘要\n\n{plan}\n\n## 审计复核\n\n{verify}"
+        cur.execute(
+            "UPDATE tasks SET status = ?, result_md = ?, updated_at = ? WHERE id = ?",
+            ("completed", result_md, datetime.datetime.now().isoformat(), task_id),
+        )
+        conn.commit()
+    except Exception as e:
+        append_log(conn, task_id, "error", str(e))
+        cur = conn.cursor()
+        cur.execute("UPDATE tasks SET status = ?, updated_at = ? WHERE id = ?", ("failed", datetime.datetime.now().isoformat(), task_id))
+        conn.commit()
+    finally:
+        conn.close()
+
+@app.get("/", response_class=HTMLResponse)
+async def index(request: Request):
+    try:
+        return templates.TemplateResponse("index.html", {"request": request, "title": "药链智控 Agent"})
+    except Exception as e:
+        html = f"<html><body><h2>服务暂时不可用</h2><p>原因：{str(e)}</p></body></html>"
+        return HTMLResponse(html, status_code=200)
+
+@app.get("/api/health")
+async def health():
+    return {"status": "ok", "message": "pharma-chain-agent running"}
+
+@app.get("/api/shipments")
+async def list_shipments():
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute("SELECT id, name, status, created_at FROM shipments ORDER BY created_at DESC")
+    rows = cur.fetchall()
+    conn.close()
+    return [{"id": r[0], "name": r[1], "status": r[2], "created_at": r[3]} for r in rows]
+
+@app.post("/api/shipments")
+async def create_shipments(name: str = Form(...)):
+    sid = str(uuid.uuid4())[:8]
+    now = datetime.datetime.now().isoformat()
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute("INSERT INTO shipments (id, name, status, created_at, updated_at) VALUES (?, ?, ?, ?, ?)", (sid, name, "新建", now, now))
+    conn.commit()
+    conn.close()
+    return {"id": sid}
+
+@app.post("/api/sensors")
+async def ingest_sensor(shipment_id: str = Form(...), temperature: float = Form(...), humidity: float = Form(...), location: str = Form("未知"), ts: str = Form(None)):
+    ts = ts or datetime.datetime.now().isoformat()
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute(
+        "INSERT INTO sensors (shipment_id, temperature, humidity, location, ts) VALUES (?, ?, ?, ?, ?)",
+        (shipment_id, temperature, humidity, location, ts),
+    )
+    conn.commit()
+    conn.close()
+    return {"ok": True}
+
+@app.post("/api/sensors/batch")
+async def ingest_sensor_batch(shipment_id: str = Form(...), file: UploadFile = File(...)):
+    try:
+        raw = await file.read()
+        size_mb = len(raw) / (1024 * 1024)
+        if size_mb > 100:
+            save_name = f"{uuid.uuid4().hex}_{file.filename}"
+            save_path = os.path.join(UPLOAD_DIR, save_name)
+            with open(save_path, "wb") as f:
+                f.write(raw)
+            return JSONResponse(
+                status_code=413,
+                content={
+                    "ok": False,
+                    "message": "文件过大，已本地保存。建议改为 Hugging Face 数据集。",
+                    "saved": f"/uploads/{save_name}",
+                },
+            )
+        text = raw.decode("utf-8", errors="ignore")
+        reader = csv.DictReader(io.StringIO(text))
+        rows = list(reader)
+        if not rows:
+            raise HTTPException(status_code=400, detail="CSV 内容为空或格式不正确")
+        conn = get_conn()
+        cur = conn.cursor()
+        n = 0
+        for r in rows:
+            try:
+                t = float(r.get("temperature") or r.get("temp") or r.get("Temperature"))
+                h = float(r.get("humidity") or r.get("hum") or r.get("Humidity") or 0.0)
+                loc = r.get("location") or r.get("loc") or "未知"
+                ts = r.get("ts") or datetime.datetime.now().isoformat()
+                cur.execute(
+                    "INSERT INTO sensors (shipment_id, temperature, humidity, location, ts) VALUES (?, ?, ?, ?, ?)",
+                    (shipment_id, t, h, loc, ts),
+                )
+                n += 1
+            except Exception:
+                continue
+        conn.commit()
+        conn.close()
+        return {"ok": True, "count": n}
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=400, detail=f"导入失败：{e}")
+
+@app.get("/api/sensors/summary")
+async def sensor_summary(shipment_id: str):
+    conn = get_conn()
+    stats = temp_stats(conn, shipment_id)
+    conn.close()
+    return stats
+
+@app.post("/api/upload")
+async def upload_file(file: UploadFile = File(...)):
+    try:
+        raw = await file.read()
+        save_name = f"{uuid.uuid4().hex}_{file.filename}"
+        save_path = os.path.join(UPLOAD_DIR, save_name)
+        with open(save_path, "wb") as f:
+            f.write(raw)
+        return {"ok": True, "filename": file.filename, "saved_path": f"/uploads/{save_name}"}
+    except Exception as e:
+        raise HTTPException(status_code=400, detail=f"上传失败：{e}")
+
+@app.get("/api/export/dataset")
+async def export_dataset(shipment_id: str):
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute(
+        "SELECT temperature, humidity, location, ts FROM sensors WHERE shipment_id = ? ORDER BY ts ASC",
+        (shipment_id,),
+    )
+    rows = cur.fetchall()
+    conn.close()
+    if not rows:
+        raise HTTPException(status_code=404, detail="无数据可导出")
+    csv_path = os.path.join(HF_DATASET_DIR, f"{shipment_id}_sensors.csv")
+    with open(csv_path, "w", encoding="utf-8", newline="") as f:
+        w = csv.writer(f)
+        w.writerow(["temperature", "humidity", "location", "ts"])
+        for r in rows:
+            w.writerow(r)
+    readme_path = os.path.join(HF_DATASET_DIR, "README.md")
+    if not os.path.exists(readme_path):
+        with open(readme_path, "w", encoding="utf-8") as f:
+            f.write("# 药链智控 数据集示例\n\n- 包含传感器温湿度时序数据（2-8℃为冷藏区间）\n- 可用于冷链合规分析与路线优化研究\n")
+    return {"ok": True, "csv": csv_path, "readme": readme_path}
+
+@app.get("/api/tasks")
+async def list_tasks():
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute("SELECT id, shipment_id, title, status, created_at FROM tasks ORDER BY created_at DESC")
+    rows = cur.fetchall()
+    conn.close()
+    return [{"id": r[0], "shipment_id": r[1], "title": r[2], "status": r[3], "created_at": r[4]} for r in rows]
+
+@app.get("/api/tasks/{task_id}")
+async def get_task(task_id: str):
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute("SELECT id, shipment_id, title, status, result_md, logs, created_at, updated_at FROM tasks WHERE id = ?", (task_id,))
+    row = cur.fetchone()
+    conn.close()
+    if not row:
+        raise HTTPException(status_code=404, detail="任务不存在")
+    return {
+        "id": row[0],
+        "shipment_id": row[1],
+        "title": row[2],
+        "status": row[3],
+        "result_md": row[4],
+        "logs": json.loads(row[5] or "[]"),
+        "created_at": row[6],
+        "updated_at": row[7],
+    }
+
+@app.post("/api/agent/run")
+async def run_agent(background_tasks: BackgroundTasks, shipment_id: str = Form(...), title: str = Form("冷链合规巡检")):
+    tid = str(uuid.uuid4())
+    now = datetime.datetime.now().isoformat()
+    conn = get_conn()
+    cur = conn.cursor()
+    cur.execute(
+        "INSERT INTO tasks (id, shipment_id, title, status, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?)",
+        (tid, shipment_id, title, "pending", now, now),
+    )
+    conn.commit()
+    conn.close()
+    background_tasks.add_task(agent_run, tid, shipment_id, title)
+    return {"task_id": tid}
+
+if __name__ == "__main__":
+    import uvicorn
+    port = int(os.getenv("PORT", "7870"))
+    uvicorn.run(app, host="0.0.0.0", port=port)

requirements.txt

@@ -0,0 +1,5 @@
+fastapi==0.110.0
+uvicorn[standard]==0.27.1
+jinja2==3.1.3
+httpx==0.27.0
+python-multipart==0.0.9

templates/index.html

@@ -0,0 +1,264 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+  <meta charset="UTF-8" />
+  <meta name="viewport" content="width=device-width, initial-scale=1" />
+  <title>药链智控 Agent</title>
+  <link rel="preconnect" href="https://fonts.googleapis.com">
+  <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
+  <link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;600;800&display=swap" rel="stylesheet">
+  <style>
+    :root { --bg:#0b1220; --card:#121a2b; --muted:#8aa0b6; --text:#e8eef5; --accent:#4fd1c5; --danger:#ef4444; }
+    *{box-sizing:border-box}body{margin:0;font-family:Inter,system-ui,Segoe UI,Arial; background:var(--bg); color:var(--text)}
+    .wrap{max-width:980px;margin:0 auto;padding:16px}
+    header{display:flex;align-items:center;justify-content:space-between;padding:14px 8px}
+    .brand{font-weight:800;letter-spacing:.3px}
+    .badge{padding:4px 10px;border-radius:999px;background:rgba(79,209,197,.1);color:var(--accent);font-size:12px}
+    .grid{display:grid;gap:12px}
+    @media(min-width:800px){.grid{grid-template-columns:1.2fr .8fr}}
+    .card{background:linear-gradient(180deg,rgba(255,255,255,.02),transparent 60%) ,var(--card);border:1px solid rgba(255,255,255,.06);border-radius:14px;padding:16px}
+    .card h3{margin:0 0 10px 0;font-size:18px}
+    input,button,select,textarea{width:100%;padding:10px 12px;border-radius:10px;border:1px solid rgba(255,255,255,.1);background:#0d1626;color:var(--text)}
+    button{background:linear-gradient(90deg,#1f4b99,#3b82f6);border:none;cursor:pointer;font-weight:600}
+    button:disabled{opacity:.6;cursor:not-allowed}
+    .row{display:flex;gap:8px}
+    .row>*{flex:1}
+    .list{display:grid;gap:8px}
+    .item{display:flex;justify-content:space-between;align-items:center;padding:10px 12px;background:#0e1730;border:1px solid rgba(255,255,255,.06);border-radius:10px}
+    .muted{color:var(--muted);font-size:12px}
+    .status{font-size:12px;padding:2px 8px;border-radius:999px;border:1px solid rgba(255,255,255,.12)}
+    .status.ok{color:#10b981;border-color:#10b98133}
+    .status.wip{color:#f59e0b;border-color:#f59e0b33}
+    .status.fail{color:var(--danger);border-color:#ef444433}
+    .log{white-space:pre-wrap;background:#0a1122;border:1px solid rgba(255,255,255,.08);padding:10px;border-radius:10px;max-height:240px;overflow:auto}
+    .md{line-height:1.6}
+    .md h1,.md h2{margin:12px 0 8px}
+    .md ul{padding-left:18px}
+  </style>
+  <script src="https://cdn.jsdelivr.net/npm/marked/marked.min.js"></script>
+  <script src="https://cdn.jsdelivr.net/npm/chart.js@4.4.1/dist/chart.umd.min.js"></script>
+</head>
+<body>
+  <div class="wrap">
+    <header>
+      <div>
+        <div class="brand">药链智控 Agent</div>
+        <div class="muted">医药冷链合规与运营闭环 · 推理/行动/记忆/验收/回放</div>
+      </div>
+      <div class="badge">Beta</div>
+    </header>
+
+    <div class="grid">
+      <section class="card">
+        <h3>创建运输批次</h3>
+        <div class="row">
+          <input id="shipmentName" placeholder="输入批次名称，如：疫苗-成都→贵阳 D01" />
+          <button id="btnCreate">创建批次</button>
+        </div>
+        <div class="muted" style="margin-top:6px">创建后可录入温湿度数据，并触发合规智能体。</div>
+      </section>
+
+      <section class="card">
+        <h3>批次列表</h3>
+        <div id="shipList" class="list"></div>
+      </section>
+    </div>
+
+    <section class="card" style="margin-top:12px">
+      <h3>录入传感数据</h3>
+      <div class="row">
+        <select id="selShip"></select>
+        <input id="temp" type="number" step="0.1" placeholder="温度 ℃，如 5.2" />
+      </div>
+      <div class="row" style="margin-top:8px">
+        <input id="humi" type="number" step="0.1" placeholder="湿度 %，如 60" />
+        <input id="loc" placeholder="位置/节点，如：冷库A→转运点B" />
+      </div>
+      <button id="btnIngest" style="margin-top:8px">提交传感数据</button>
+      <div class="muted" style="margin-top:6px">支持多次提交以形成温控曲线。可批量导入 CSV。</div>
+      <div class="row" style="margin-top:8px">
+        <input id="csvFile" type="file" accept=".csv,text/csv" />
+        <button id="btnBatch">批量导入 CSV</button>
+      </div>
+    </section>
+
+    <section class="card" style="margin-top:12px">
+      <h3>温度曲线 · 越界一览</h3>
+      <div class="muted" id="statsLine" style="margin-bottom:6px"></div>
+      <canvas id="chart" height="120"></canvas>
+      <div class="muted" style="margin-top:6px">绿色为 2-8℃ 合规区间，红点表示越界。</div>
+      <div class="row" style="margin-top:8px">
+        <select id="selSummary"></select>
+        <button id="btnExport">导出为数据集</button>
+      </div>
+      <div id="exportMsg" class="muted" style="margin-top:6px"></div>
+    </section>
+
+    <section class="card" style="margin-top:12px">
+      <h3>合规智能体 · 执行</h3>
+      <div class="row">
+        <select id="selRun"></select>
+        <input id="taskTitle" placeholder="任务标题，如：例行合规巡检" />
+      </div>
+      <button id="btnRun" style="margin-top:8px">启动智能体</button>
+      <div id="taskStatus" class="muted" style="margin-top:6px"></div>
+    </section>
+
+    <section class="card" style="margin-top:12px">
+      <h3>任务详情 · 验收与回放</h3>
+      <div id="result" class="md"></div>
+      <h4 style="margin:12px 0 6px">执行过程日志</h4>
+      <div id="logs" class="log"></div>
+    </section>
+  </div>
+
+  <script>
+    const api = async (p, opt={})=>{
+      const r = await fetch(p, opt);
+      let data = null;
+      try { data = await r.json(); } catch { data = {}; }
+      if(!r.ok){
+        const msg = (data && (data.detail || data.message)) || '请求失败';
+        throw new Error(msg);
+      }
+      return data;
+    };
+    const $ = (id)=>document.getElementById(id);
+    let chart = null;
+
+    async function refreshShipments() {
+      let data = [];
+      try { data = await api('/api/shipments'); } catch(e){ alert('获取批次失败：'+e.message); return; }
+      const list = $('shipList');
+      const sel1 = $('selShip');
+      const sel2 = $('selRun');
+      const sel3 = $('selSummary');
+      list.innerHTML = '';
+      sel1.innerHTML = '';
+      sel2.innerHTML = '';
+      sel3.innerHTML = '';
+      data.forEach(s=>{
+        const div = document.createElement('div');
+        div.className='item';
+        div.innerHTML = `<div><div>${s.name}</div><div class="muted">${s.id} · ${s.created_at}</div></div><div class="status ${s.status==='新建'?'wip':'ok'}">${s.status}</div>`;
+        list.appendChild(div);
+        const opt1 = new Option(s.name, s.id);
+        const opt2 = new Option(s.name, s.id);
+        const opt3 = new Option(s.name, s.id);
+        sel1.add(opt1); sel2.add(opt2); sel3.add(opt3);
+      })
+      if(sel1.options.length>0){ sel1.selectedIndex=0; }
+      if(sel2.options.length>0){ sel2.selectedIndex=0; }
+      if(sel3.options.length>0){ sel3.selectedIndex=0; loadSummary(sel3.value); }
+    }
+
+    $('btnCreate').onclick = async ()=>{
+      const name = $('shipmentName').value.trim();
+      if(!name) return alert('请输入批次名称');
+      const fd = new FormData(); fd.append('name', name);
+      try {
+        await api('/api/shipments', {method:'POST', body: fd});
+      } catch(e){ return alert('创建失败：'+e.message); }
+      $('shipmentName').value = '';
+      refreshShipments();
+    };
+
+    $('btnIngest').onclick = async ()=>{
+      const sid = $('selShip').value;
+      if(!sid) return alert('请选择批次');
+      const t = $('temp').value; const h = $('humi').value; const l = $('loc').value || '未知';
+      if(t==='') return alert('请输入温度');
+      const fd = new FormData(); fd.append('shipment_id', sid); fd.append('temperature', t); fd.append('humidity', h||'0'); fd.append('location', l);
+      try {
+        const res = await api('/api/sensors', {method:'POST', body: fd});
+        if(res.ok){ $('temp').value=''; $('humi').value=''; $('loc').value=''; alert('已记录'); loadSummary($('selSummary').value || sid); }
+      } catch(e){ alert('提交失败：'+e.message); }
+    };
+
+    $('btnBatch').onclick = async ()=>{
+      const f = $('csvFile').files[0];
+      const sid = $('selShip').value;
+      if(!sid) return alert('请选择批次');
+      if(!f) return alert('请选择CSV文件');
+      const fd = new FormData(); fd.append('shipment_id', sid); fd.append('file', f);
+      try {
+        const res = await api('/api/sensors/batch', {method:'POST', body: fd});
+        if(res.ok){ alert(`导入成功：${res.count} 条`); loadSummary($('selSummary').value || sid); }
+      } catch(e){ alert('导入失败：'+e.message); }
+    };
+
+    async function loadSummary(sid){
+      if(!sid) return;
+      try {
+        const s = await api('/api/sensors/summary?shipment_id='+encodeURIComponent(sid));
+        $('statsLine').textContent = `记录数：${s.count}，最低：${s.min??'-'}℃，最高：${s.max??'-'}℃，平均：${s.avg??'-'}℃；越界次数：${s.breaches.length}`;
+        const labels = s.timeline.map(x=>x.ts.slice(11,19));
+        const temps = s.timeline.map(x=>x.t);
+        const ctx = $('chart').getContext('2d');
+        if(chart){ chart.destroy(); }
+        chart = new Chart(ctx, {
+          type: 'line',
+          data: { labels, datasets:[{ label:'温度℃', data:temps, borderColor:'#3b82f6', tension:0.2, pointRadius:2 }] },
+          options: {
+            plugins:{ legend:{display:false}},
+            scales:{ y:{ beginAtZero:false, suggestedMin:0, suggestedMax:10 } }
+          }
+        });
+      } catch(e){
+        $('statsLine').textContent = '加载统计失败：'+e.message;
+      }
+    }
+
+    $('selSummary').onchange = (e)=> loadSummary(e.target.value);
+
+    let polling = null;
+    function startPoll(taskId){
+      if(polling) clearInterval(polling);
+      polling = setInterval(async ()=>{
+        try{
+          const d = await api('/api/tasks/'+taskId);
+          $('taskStatus').textContent = `状态：${d.status} · 任务ID：${d.id}`;
+          $('logs').textContent = d.logs.map(x=>`[${x.timestamp}] ${x.role}: ${x.content}`).join('\n');
+          $('result').innerHTML = marked.parse(d.result_md || '');
+          if(d.status!=='in_progress' && d.status!=='pending') clearInterval(polling);
+        }catch(e){
+          $('taskStatus').textContent = '查询任务失败：'+e.message;
+          clearInterval(polling);
+        }
+      }, 1000);
+    }
+
+    $('btnRun').onclick = async ()=>{
+      const sid = $('selRun').value;
+      if(!sid) return alert('请选择批次');
+      const title = $('taskTitle').value || '冷链合规巡检';
+      const fd = new FormData(); fd.append('shipment_id', sid); fd.append('title', title);
+      try{
+        const r = await api('/api/agent/run', {method:'POST', body: fd});
+        $('taskStatus').textContent = '任务已创建，正在执行…';
+        startPoll(r.task_id);
+      }catch(e){
+        $('taskStatus').textContent = '启动失败：'+e.message;
+      }
+    };
+
+    $('btnExport').onclick = async ()=>{
+      const sid = $('selSummary').value;
+      if(!sid) return alert('请选择批次');
+      try{
+        const r = await api('/api/export/dataset', {method:'POST', body: new URLSearchParams({shipment_id: sid})});
+      }catch{
+        // 兼容 GET 导出
+      }
+      try{
+        const r2 = await api('/api/export/dataset?shipment_id='+encodeURIComponent(sid));
+        $('exportMsg').textContent = '已导出到本地 hf_dataset 目录：'+ (r2.csv||'');
+      }catch(e){
+        $('exportMsg').textContent = '导出失败：'+e.message;
+      }
+    };
+
+    refreshShipments();
+  </script>
+</body>
+</html>