init

.gitignore

@@ -0,0 +1,5 @@
+__pycache__/
+*.py[cod]
+*.db
+instance/
+.env

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=7865
+EXPOSE 7865
+
+CMD ["python", "app.py"]

README.md

@@ -1,10 +1,60 @@
 ---
-title: Coldchain Optimizer Agent
-emoji: 🏃
-colorFrom: red
-colorTo: green
+title: 冷链闭环智能体
+emoji: 🧊
+colorFrom: blue
+colorTo: teal
 sdk: docker
+app_port: 7865
+short_description: 冷链闭环智能体：医药与生鲜的智能合规运营平台
 pinned: false
+license: mit
 ---
 
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# 冷链闭环智能体（ColdChain Optimizer Agent）
+
+## 项目简介
+面向医药、生鲜与高价值温控品类的冷链运营平台，提供完整的“推理/决策 → 工具行动 → 状态/记忆 → 校验/验收 → 迭代/回放”闭环体系。  
+支持多智能体协同、指标验收、资产沉淀与历史回放，适用于冷链合规、运力优化与成本控制等商业场景。
+
+## 核心能力
+- 冷链闭环决策：从策略推理到执行校验的一体化流程
+- 工具行动层：温控风险、线路规模、准时率、成本节约的量化输出
+- 资产沉淀：SOP、指标字典、异常追溯模板与协作清单存档
+- 可回放：历史会话复盘，支持再次迭代优化
+- Markdown 渲染：推理结果与报告直接展示为可读文档
+- 移动端适配：响应式界面，适合现场调度使用
+
+## 技术栈
+- 后端：Python 3.11 + Flask + SQLite
+- 前端：原生 HTML/CSS/JS + Marked.js
+- AI：SiliconFlow API（支持本地 Mock 模式回退）
+- 部署：Docker（Hugging Face Spaces 兼容）
+
+## 快速开始
+
+### 本地运行
+```bash
+pip install -r requirements.txt
+python app.py
+```
+
+访问：http://localhost:7865
+
+### Docker 运行
+```bash
+docker build -t coldchain-optimizer-agent .
+docker run -p 7865:7865 --env-file .env coldchain-optimizer-agent
+```
+
+## 环境变量
+在项目根目录创建 `.env` 文件，可配置：
+```env
+SILICONFLOW_API_KEY=你的_siliconflow_key
+SILICONFLOW_BASE_URL=https://api.siliconflow.cn/v1
+SILICONFLOW_MODEL=Qwen/Qwen2.5-7B-Instruct
+```
+
+## 商业价值
+- 为医药/生鲜冷链企业提供合规与成本优化的可执行方案
+- 通过资产沉淀形成可复用的冷链运营知识库
+- 支持作为 SaaS 产品或行业解决方案持续变现

app.py

@@ -0,0 +1,615 @@
+import os
+import json
+import sqlite3
+import datetime
+import random
+import requests
+from flask import Flask, render_template, request, jsonify, g
+from werkzeug.utils import secure_filename
+from dotenv import load_dotenv
+
+# 冷链闭环智能体：加载环境变量
+load_dotenv()
+
+BASE_DIR = os.path.abspath(os.path.dirname(__file__))
+INSTANCE_DIR = os.path.join(BASE_DIR, "instance")
+os.makedirs(INSTANCE_DIR, exist_ok=True)
+
+app = Flask(__name__)
+app.config["DATABASE"] = os.path.join(INSTANCE_DIR, "coldchain.db")
+app.config["SECRET_KEY"] = os.getenv("SECRET_KEY", "coldchain-secret-key")
+app.config["JSON_AS_ASCII"] = False
+app.config["MAX_CONTENT_LENGTH"] = 32 * 1024 * 1024
+
+SILICONFLOW_API_KEY = os.getenv("SILICONFLOW_API_KEY", "").strip()
+SILICONFLOW_BASE_URL = os.getenv("SILICONFLOW_BASE_URL", "https://api.siliconflow.cn/v1").strip()
+SILICONFLOW_MODEL = os.getenv("SILICONFLOW_MODEL", "Qwen/Qwen2.5-7B-Instruct").strip()
+
+
+def get_db():
+    # 统一获取数据库连接
+    db = getattr(g, "_database", None)
+    if db is None:
+        db = g._database = sqlite3.connect(app.config["DATABASE"])
+        db.row_factory = sqlite3.Row
+    return db
+
+
+@app.teardown_appcontext
+def close_connection(exception):
+    # 请求结束后关闭连接
+    db = getattr(g, "_database", None)
+    if db is not None:
+        db.close()
+
+
+def simulate_coldchain_tools(scenario, target, constraints):
+    seed = len(scenario) + len(target or "") + len(constraints or "")
+    random.seed(seed)
+    route_count = max(5, min(18, seed // 40))
+    hubs = max(2, min(8, seed // 90))
+    temp_risk = round(random.uniform(0.8, 2.8), 2)
+    on_time = round(96 + random.uniform(1.2, 2.8), 2)
+    compliance = round(99.0 + random.uniform(0.2, 0.7), 2)
+    cost_saving = round(random.uniform(5.0, 12.0), 1)
+
+    risk_keywords = ["堵车", "夜间", "限行", "偏差", "高峰", "雨雪", "台风"]
+    risk_score = 0
+    for k in risk_keywords:
+        if k in scenario or k in (constraints or ""):
+            risk_score += 2
+    risk_score += min(6, seed // 160)
+    if risk_score <= 3:
+        risk_level = "低"
+    elif risk_score <= 6:
+        risk_level = "中"
+    else:
+        risk_level = "高"
+
+    return {
+        "route_count": route_count,
+        "hub_count": hubs,
+        "temp_risk": temp_risk,
+        "on_time": on_time,
+        "compliance": compliance,
+        "cost_saving": cost_saving,
+        "risk_level": risk_level,
+    }
+
+
+def seed_demo(db):
+    row = db.execute("SELECT COUNT(*) AS c FROM sessions").fetchone()
+    if row and row["c"]:
+        return
+    demo = {
+        "name": "示例会话 · 医药冷链干线 + 末端",
+        "scenario": (
+            "为华东地区 6 个仓与 28 家三甲医院建立 2-8℃医药冷链网络，"
+            "需要在 24 小时内完成跨城配送，温控偏差不能超过 30 分钟。"
+            "要求支持节假日高峰、夜间配送以及异常追溯。"
+        ),
+        "target": "准时交付率 ≥ 98%，温控合规率 ≥ 99.5%，综合成本降低 8%",
+        "constraints": "夜间限行、部分城市冷链车辆通行证审批较慢，预算上限 450 万/年",
+    }
+    cursor = db.execute(
+        "INSERT INTO sessions (name, scenario, target, constraints) VALUES (?, ?, ?, ?)",
+        (demo["name"], demo["scenario"], demo["target"], demo["constraints"]),
+    )
+    session_id = cursor.lastrowid
+    tool_result = simulate_coldchain_tools(demo["scenario"], demo["target"], demo["constraints"])
+    db.execute(
+        """
+        INSERT INTO steps (session_id, step_order, role, step_type, content)
+        VALUES (?, 1, 'Planner', 'reasoning', ?)
+        """,
+        (
+            session_id,
+            "## 示例推理结果\n\n"
+            "- 将华东划分为干线 + 末端两级网络，优先保障医院到区域仓的时效\n"
+            "- 对夜间与节假日高峰设置冗余线路与备用车辆池\n"
+            "- 使用温度记录仪与异常告警系统保障 2-8℃ 全程可追溯\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO steps (session_id, step_order, role, step_type, content)
+        VALUES (?, 2, 'RouteOps', 'tool_action', ?)
+        """,
+        (
+            session_id,
+            "## 示例工具行动结果\n\n"
+            f"- 规划干线/支线数：{tool_result['route_count']} 条\n"
+            f"- 冷链枢纽节点：{tool_result['hub_count']} 个\n"
+            f"- 温控偏差风险指数：{tool_result['temp_risk']}\n"
+            f"- 预计准时交付率：{tool_result['on_time']}%\n"
+            f"- 预计温控合规率：{tool_result['compliance']}%\n"
+            f"- 预计综合成本节约：{tool_result['cost_saving']}%\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO steps (session_id, step_order, role, step_type, content)
+        VALUES (?, 3, 'Memory', 'memory', ?)
+        """,
+        (
+            session_id,
+            "## 示例状态记���\n\n"
+            "- 首轮试点重点关注医院急配线路与疫苗仓温控告警阈值\n"
+            "- 记录各城市夜间限行时间窗口与通行证办理周期\n"
+            "- 建立合作冷链车队与外包商的服务等级基线\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO steps (session_id, step_order, role, step_type, content)
+        VALUES (?, 4, 'QualityAuditor', 'validation', ?)
+        """,
+        (
+            session_id,
+            "## 示例校验与验收\n\n"
+            "- 首轮模拟结果满足准时率与温控合规目标\n"
+            "- 建议在真实运营前增加极端天气与高峰场景的压力测试\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO steps (session_id, step_order, role, step_type, content)
+        VALUES (?, 5, 'Optimizer', 'iteration', ?)
+        """,
+        (
+            session_id,
+            "## 示例迭代计划\n\n"
+            "- 第二阶段纳入更多区域仓与三方物流合作方\n"
+            "- 收集真实运营数据后，进一步优化线路与车辆编组\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO assets (session_id, asset_type, title, content)
+        VALUES (?, 'report', '冷链闭环运营资产包（示例）', ?)
+        """,
+        (
+            session_id,
+            "## 资产包概要（示例）\n\n"
+            "- 冷链网络拓扑草案：干线 + 末端两级结构\n"
+            "- 温控合规模板：2-8℃ 温度区间与偏差告警策略\n"
+            "- KPI 指标字典：准时率、合规率、成本节约率\n"
+            "- 合作方清单：仓、车队与医院联络窗口\n",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO assets (session_id, asset_type, title, content)
+        VALUES (?, 'metrics', '本轮关键指标快照（示例）', ?)
+        """,
+        (session_id, json.dumps(tool_result, ensure_ascii=False)),
+    )
+    db.commit()
+
+
+def init_db():
+    db = get_db()
+    db.execute(
+        """
+        CREATE TABLE IF NOT EXISTS sessions (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            name TEXT,
+            scenario TEXT NOT NULL,
+            target TEXT,
+            constraints TEXT,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+        """
+    )
+    db.execute(
+        """
+        CREATE TABLE IF NOT EXISTS steps (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            session_id INTEGER NOT NULL,
+            step_order INTEGER NOT NULL,
+            role TEXT NOT NULL,
+            step_type TEXT NOT NULL,
+            content TEXT NOT NULL,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY(session_id) REFERENCES sessions(id) ON DELETE CASCADE
+        )
+        """
+    )
+    db.execute(
+        """
+        CREATE TABLE IF NOT EXISTS assets (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            session_id INTEGER NOT NULL,
+            asset_type TEXT NOT NULL,
+            title TEXT NOT NULL,
+            content TEXT NOT NULL,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY(session_id) REFERENCES sessions(id) ON DELETE CASCADE
+        )
+        """
+    )
+    db.commit()
+    seed_demo(db)
+
+
+with app.app_context():
+    init_db()
+
+
+def build_api_url(base_url):
+    # 统一拼接 SiliconFlow API 地址
+    if base_url.endswith("/chat/completions"):
+        return base_url
+    return f"{base_url.rstrip('/')}/chat/completions"
+
+
+def call_llm(messages, temperature=0.7, max_tokens=900):
+    # 调用硅基流大模型，失败时自动回落
+    if not SILICONFLOW_API_KEY or not SILICONFLOW_API_KEY.startswith("sk-"):
+        return mock_completion(messages)
+
+    payload = {
+        "model": SILICONFLOW_MODEL,
+        "messages": messages,
+        "stream": False,
+        "temperature": temperature,
+        "max_tokens": max_tokens,
+    }
+    headers = {
+        "Authorization": f"Bearer {SILICONFLOW_API_KEY}",
+        "Content-Type": "application/json",
+    }
+    try:
+        resp = requests.post(build_api_url(SILICONFLOW_BASE_URL), json=payload, headers=headers, timeout=20)
+        if resp.status_code == 200:
+            data = resp.json()
+            return data["choices"][0]["message"]["content"]
+        return mock_completion(messages)
+    except Exception:
+        return mock_completion(messages)
+
+
+def mock_completion(messages):
+    # 本地模拟输出，保持闭环演示可运行
+    last_user = ""
+    for m in reversed(messages):
+        if m.get("role") == "user":
+            last_user = m.get("content", "")[:240]
+            break
+    now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
+    return (
+        f"## 本地模拟输出\n\n"
+        f"- 时间：{now}\n"
+        f"- 说明：未配置硅基流 API Key，系统使用规则化策略生成示意结果。\n\n"
+        f"### 场景摘要\n\n{last_user}\n\n"
+        f"### 建���要点\n\n"
+        f"- 优先保证温控合规与准时交付\n"
+        f"- 对高风险线路设置双层冗余方案\n"
+        f"- 建议分阶段上线与持续迭代"
+    )
+
+
+def simulate_coldchain_tools(scenario, target, constraints):
+    # 工具层模拟：输出可量化指标
+    seed = len(scenario) + len(target or "") + len(constraints or "")
+    random.seed(seed)
+    route_count = max(5, min(18, seed // 40))
+    hubs = max(2, min(8, seed // 90))
+    temp_risk = round(random.uniform(0.8, 2.8), 2)
+    on_time = round(96 + random.uniform(1.2, 2.8), 2)
+    compliance = round(99.0 + random.uniform(0.2, 0.7), 2)
+    cost_saving = round(random.uniform(5.0, 12.0), 1)
+
+    risk_keywords = ["堵车", "夜间", "限行", "偏差", "高峰", "雨雪", "台风"]
+    risk_score = 0
+    for k in risk_keywords:
+        if k in scenario or k in (constraints or ""):
+            risk_score += 2
+    risk_score += min(6, seed // 160)
+    if risk_score <= 3:
+        risk_level = "低"
+    elif risk_score <= 6:
+        risk_level = "中"
+    else:
+        risk_level = "高"
+
+    return {
+        "route_count": route_count,
+        "hub_count": hubs,
+        "temp_risk": temp_risk,
+        "on_time": on_time,
+        "compliance": compliance,
+        "cost_saving": cost_saving,
+        "risk_level": risk_level,
+    }
+
+
+def run_coldchain_workflow(scenario, target, constraints):
+    # 冷链闭环主流程：推理 -> 工具行动 -> 状态记忆 -> 校验验收 -> 迭代复盘
+    tool_result = simulate_coldchain_tools(scenario, target, constraints)
+
+    system_role = (
+        "你是冷链物流与医药合规专家，负责构建可执行的闭环方案。"
+        "输出中文 Markdown，结构清晰，强调可落地与可复用资产。"
+    )
+
+    reasoning_prompt = (
+        f"冷链场景：{scenario}\n"
+        f"目标：{target or '未指定'}\n"
+        f"约束：{constraints or '未指定'}\n"
+        "请生成推理/决策阶段的方案，包含关键假设、优先级、核心路径。"
+    )
+    reasoning = call_llm(
+        [
+            {"role": "system", "content": system_role},
+            {"role": "user", "content": reasoning_prompt},
+        ],
+        temperature=0.6,
+    )
+
+    tool_md = (
+        "## 工具行动结果（模拟）\n\n"
+        f"- 规划干线/支线数：{tool_result['route_count']} 条\n"
+        f"- 冷链枢纽节点：{tool_result['hub_count']} 个\n"
+        f"- 温控偏差风险指数：{tool_result['temp_risk']}\n"
+        f"- 预计准时交付率：{tool_result['on_time']}%\n"
+        f"- 预计温控合规率：{tool_result['compliance']}%\n"
+        f"- 预计综合成本节约：{tool_result['cost_saving']}%\n"
+        f"- 风险等级：{tool_result['risk_level']}\n"
+    )
+
+    memory_prompt = (
+        "请输出可沉淀的状态/记忆资产清单，至少包含："
+        "标准化 SOP、关键指标字典、异常追溯模板、合作方清单。"
+    )
+    memory_md = call_llm(
+        [
+            {"role": "system", "content": system_role},
+            {"role": "user", "content": memory_prompt},
+        ],
+        temperature=0.5,
+    )
+
+    validation_prompt = (
+        f"当前工具指标：准时交付率 {tool_result['on_time']}%，"
+        f"温控合规率 {tool_result['compliance']}%，成本节约 {tool_result['cost_saving']}%。"
+        "请生成校验/验收结论，列出是否达标与需补强项。"
+    )
+    validation_md = call_llm(
+        [
+            {"role": "system", "content": system_role},
+            {"role": "user", "content": validation_prompt},
+        ],
+        temperature=0.4,
+    )
+
+    iteration_prompt = (
+        "请生成迭代/复盘计划，包含下一轮优化假设、需要补采的数据、"
+        "以及可以立即执行的 3 条改进动作。"
+    )
+    iteration_md = call_llm(
+        [
+            {"role": "system", "content": system_role},
+            {"role": "user", "content": iteration_prompt},
+        ],
+        temperature=0.6,
+    )
+
+    steps = [
+        {
+            "step_order": 1,
+            "role": "Planner",
+            "step_type": "reasoning",
+            "content": reasoning,
+        },
+        {
+            "step_order": 2,
+            "role": "RouteOps",
+            "step_type": "tool_action",
+            "content": tool_md,
+        },
+        {
+            "step_order": 3,
+            "role": "Memory",
+            "step_type": "memory",
+            "content": memory_md,
+        },
+        {
+            "step_order": 4,
+            "role": "QualityAuditor",
+            "step_type": "validation",
+            "content": validation_md,
+        },
+        {
+            "step_order": 5,
+            "role": "Optimizer",
+            "step_type": "iteration",
+            "content": iteration_md,
+        },
+    ]
+
+    assets = [
+        {
+            "asset_type": "report",
+            "title": "冷链闭环运营资产包",
+            "content": (
+                "## 资产包概要\n\n"
+                "- 冷链网络拓扑草案\n"
+                "- 温控合规模板与异常追溯SOP\n"
+                "- KPI 指标字典与验收阈值\n"
+                "- 供应商与节点协作清单\n"
+            ),
+        },
+        {
+            "asset_type": "metrics",
+            "title": "本轮关键指标快照",
+            "content": json.dumps(tool_result, ensure_ascii=False),
+        },
+    ]
+
+    return steps, assets
+
+
+@app.route("/")
+def index():
+    return render_template("index.html")
+
+
+@app.route("/api/overview")
+def overview():
+    db = get_db()
+    session_count = db.execute("SELECT COUNT(*) AS c FROM sessions").fetchone()["c"]
+    step_count = db.execute("SELECT COUNT(*) AS c FROM steps").fetchone()["c"]
+    asset_count = db.execute("SELECT COUNT(*) AS c FROM assets").fetchone()["c"]
+    return jsonify(
+        {
+            "session_count": session_count,
+            "step_count": step_count,
+            "asset_count": asset_count,
+        }
+    )
+
+
+@app.route("/api/sessions")
+def list_sessions():
+    db = get_db()
+    rows = db.execute(
+        "SELECT id, name, scenario, target, created_at FROM sessions ORDER BY id DESC LIMIT 50"
+    ).fetchall()
+    sessions = [
+        {
+            "id": r["id"],
+            "name": r["name"],
+            "scenario": r["scenario"],
+            "target": r["target"],
+            "created_at": r["created_at"],
+        }
+        for r in rows
+    ]
+    return jsonify({"sessions": sessions})
+
+
+@app.route("/api/session/<int:session_id>")
+def get_session(session_id):
+    db = get_db()
+    session = db.execute(
+        "SELECT * FROM sessions WHERE id = ?", (session_id,)
+    ).fetchone()
+    if not session:
+        return jsonify({"error": "会话不存在"}), 404
+    steps = db.execute(
+        "SELECT step_order, role, step_type, content, created_at FROM steps WHERE session_id = ? ORDER BY step_order ASC",
+        (session_id,),
+    ).fetchall()
+    assets = db.execute(
+        "SELECT asset_type, title, content, created_at FROM assets WHERE session_id = ? ORDER BY id DESC",
+        (session_id,),
+    ).fetchall()
+    return jsonify(
+        {
+            "session": dict(session),
+            "steps": [dict(s) for s in steps],
+            "assets": [dict(a) for a in assets],
+        }
+    )
+
+
+@app.route("/api/assets")
+def list_assets():
+    db = get_db()
+    rows = db.execute(
+        "SELECT id, session_id, asset_type, title, content, created_at FROM assets ORDER BY id DESC LIMIT 50"
+    ).fetchall()
+    assets = [dict(r) for r in rows]
+    return jsonify({"assets": assets})
+
+
+@app.route("/api/upload", methods=["POST"])
+def upload_file():
+    file = request.files.get("file")
+    if not file:
+        return jsonify({"error": "未收到上传文件"}), 400
+
+    filename = secure_filename(file.filename or "unnamed.bin")
+    if not filename:
+        filename = "unnamed.bin"
+
+    uploads_dir = os.path.join(INSTANCE_DIR, "uploads")
+    os.makedirs(uploads_dir, exist_ok=True)
+
+    path = os.path.join(uploads_dir, filename)
+    file.save(path)
+    size_bytes = os.path.getsize(path)
+    size_kb = round(size_bytes / 1024, 2)
+
+    db = get_db()
+    db.execute(
+        """
+        INSERT INTO assets (session_id, asset_type, title, content)
+        VALUES (?, ?, ?, ?)
+        """,
+        (
+            1,
+            "upload",
+            f"上传文件：{filename}",
+            f"大小：{size_kb} KB；存储于内部 uploads 目录，用于演示 Hugging Face 大文件处理策略。",
+        ),
+    )
+    db.commit()
+
+    return jsonify({"filename": filename, "size_kb": size_kb})
+
+
+@app.route("/api/run", methods=["POST"])
+def run_workflow():
+    try:
+        data = request.get_json(force=True)
+    except Exception:
+        return jsonify({"error": "请求体必须为 JSON"}), 400
+
+    scenario = (data or {}).get("scenario", "").strip()
+    target = (data or {}).get("target", "").strip()
+    constraints = (data or {}).get("constraints", "").strip()
+    name = (data or {}).get("name", "").strip() or "冷链运营会话"
+
+    if not scenario:
+        return jsonify({"error": "请提供冷链场景描述"}), 400
+
+    db = get_db()
+    cursor = db.execute(
+        "INSERT INTO sessions (name, scenario, target, constraints) VALUES (?, ?, ?, ?)",
+        (name, scenario, target, constraints),
+    )
+    session_id = cursor.lastrowid
+
+    steps, assets = run_coldchain_workflow(scenario, target, constraints)
+    for s in steps:
+        db.execute(
+            """
+            INSERT INTO steps (session_id, step_order, role, step_type, content)
+            VALUES (?, ?, ?, ?, ?)
+            """,
+            (session_id, s["step_order"], s["role"], s["step_type"], s["content"]),
+        )
+    for a in assets:
+        db.execute(
+            """
+            INSERT INTO assets (session_id, asset_type, title, content)
+            VALUES (?, ?, ?, ?)
+            """,
+            (session_id, a["asset_type"], a["title"], a["content"]),
+        )
+    db.commit()
+
+    return jsonify(
+        {
+            "session_id": session_id,
+            "steps": steps,
+            "assets": assets,
+        }
+    )
+
+
+if __name__ == "__main__":
+    port = int(os.getenv("PORT", "7865"))
+    app.run(host="0.0.0.0", port=port, debug=False)

requirements.txt

@@ -0,0 +1,3 @@
+Flask==3.0.0
+requests==2.31.0
+python-dotenv==1.0.0

templates/index.html

@@ -0,0 +1,532 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>冷链闭环智能体 · ColdChain Optimizer</title>
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <style>
+      :root {
+        --bg: #f4f7fb;
+        --card: #ffffff;
+        --primary: #0f3d5e;
+        --accent: #14b8a6;
+        --text: #1f2937;
+        --muted: #6b7280;
+        --shadow: 0 12px 30px rgba(15, 61, 94, 0.12);
+      }
+      * {
+        box-sizing: border-box;
+      }
+      body {
+        margin: 0;
+        font-family: "PingFang SC", "Noto Sans SC", "Microsoft YaHei", sans-serif;
+        background: var(--bg);
+        color: var(--text);
+      }
+      .app-shell {
+        max-width: 1200px;
+        margin: 0 auto;
+        padding: 24px 20px 48px;
+      }
+      header {
+        display: flex;
+        flex-wrap: wrap;
+        align-items: center;
+        justify-content: space-between;
+        gap: 16px;
+        margin-bottom: 20px;
+      }
+      .brand {
+        display: flex;
+        align-items: center;
+        gap: 16px;
+      }
+      .brand-mark {
+        width: 52px;
+        height: 52px;
+        border-radius: 16px;
+        background: linear-gradient(135deg, #0f3d5e, #14b8a6);
+        color: #fff;
+        font-weight: 700;
+        display: flex;
+        align-items: center;
+        justify-content: center;
+        font-size: 20px;
+        letter-spacing: 2px;
+      }
+      .brand-title {
+        font-size: 22px;
+        font-weight: 700;
+      }
+      .brand-subtitle {
+        color: var(--muted);
+        margin-top: 4px;
+      }
+      .chips {
+        display: flex;
+        gap: 8px;
+        flex-wrap: wrap;
+      }
+      .chip {
+        background: rgba(20, 184, 166, 0.12);
+        color: #0f766e;
+        padding: 6px 12px;
+        border-radius: 999px;
+        font-size: 12px;
+        font-weight: 600;
+      }
+      .overview {
+        display: grid;
+        grid-template-columns: repeat(auto-fit, minmax(180px, 1fr));
+        gap: 16px;
+        margin-bottom: 24px;
+      }
+      .overview-card {
+        background: var(--card);
+        border-radius: 16px;
+        padding: 18px;
+        box-shadow: var(--shadow);
+      }
+      .overview-title {
+        font-size: 13px;
+        color: var(--muted);
+      }
+      .overview-value {
+        font-size: 26px;
+        font-weight: 700;
+        margin-top: 8px;
+      }
+      .layout {
+        display: grid;
+        grid-template-columns: minmax(0, 1fr) minmax(0, 1fr);
+        gap: 20px;
+      }
+      .panel {
+        background: var(--card);
+        border-radius: 18px;
+        padding: 20px;
+        box-shadow: var(--shadow);
+      }
+      .panel-title {
+        font-size: 16px;
+        font-weight: 700;
+        margin-bottom: 12px;
+      }
+      .panel-subtitle {
+        color: var(--muted);
+        margin-bottom: 16px;
+        font-size: 13px;
+      }
+      .form-grid {
+        display: grid;
+        gap: 12px;
+      }
+      label {
+        font-size: 13px;
+        color: var(--muted);
+      }
+      input,
+      textarea {
+        width: 100%;
+        border-radius: 12px;
+        border: 1px solid #e5e7eb;
+        padding: 10px 12px;
+        font-size: 14px;
+        background: #f9fafb;
+      }
+      textarea {
+        min-height: 110px;
+        resize: vertical;
+      }
+      .btn-row {
+        display: flex;
+        gap: 12px;
+        flex-wrap: wrap;
+      }
+      button {
+        border: none;
+        border-radius: 12px;
+        padding: 10px 16px;
+        font-weight: 600;
+        cursor: pointer;
+      }
+      .btn-primary {
+        background: var(--primary);
+        color: #fff;
+      }
+      .btn-ghost {
+        background: rgba(15, 61, 94, 0.08);
+        color: var(--primary);
+      }
+      .status-card {
+        background: #0f3d5e;
+        color: #fff;
+        border-radius: 16px;
+        padding: 16px;
+        margin-top: 16px;
+      }
+      .timeline {
+        display: grid;
+        gap: 16px;
+      }
+      .timeline-item {
+        border: 1px solid #e5e7eb;
+        border-radius: 14px;
+        padding: 16px;
+        background: #fbfdff;
+      }
+      .timeline-header {
+        display: flex;
+        justify-content: space-between;
+        align-items: center;
+        margin-bottom: 8px;
+      }
+      .badge {
+        background: rgba(15, 61, 94, 0.1);
+        color: var(--primary);
+        padding: 4px 10px;
+        border-radius: 999px;
+        font-size: 12px;
+      }
+      .badge-soft {
+        background: rgba(20, 184, 166, 0.1);
+        color: #0f766e;
+      }
+      .timeline-type {
+        font-size: 13px;
+      }
+      .markdown {
+        line-height: 1.7;
+        font-size: 14px;
+      }
+      .history-list,
+      .asset-list {
+        display: grid;
+        gap: 10px;
+        margin-top: 12px;
+      }
+      .history-item,
+      .asset-item {
+        border: 1px solid #e5e7eb;
+        border-radius: 12px;
+        padding: 12px;
+        background: #fff;
+        cursor: pointer;
+      }
+      .muted {
+        color: var(--muted);
+        font-size: 12px;
+      }
+      .footer-tip,
+      .upload-tip {
+        margin-top: 18px;
+        color: var(--muted);
+        font-size: 12px;
+      }
+      @media (max-width: 960px) {
+        .layout {
+          grid-template-columns: 1fr;
+        }
+      }
+    </style>
+  </head>
+  <body>
+    <div class="app-shell">
+      <header>
+        <div class="brand">
+          <div class="brand-mark">CC</div>
+          <div>
+            <div class="brand-title">冷链闭环智能体 · ColdChain Optimizer</div>
+            <div class="brand-subtitle">
+              推理 / 工具行动 / 状态记忆 / 校验验收 / 迭代复盘
+            </div>
+          </div>
+        </div>
+        <div class="chips">
+          <div class="chip">医药冷链</div>
+          <div class="chip">多智能体协作</div>
+          <div class="chip">资产沉淀</div>
+          <div class="chip">移动端适配</div>
+        </div>
+      </header>
+
+      <section class="overview" id="overview">
+        <div class="overview-card">
+          <div class="overview-title">累计会话</div>
+          <div class="overview-value" id="session-count">0</div>
+        </div>
+        <div class="overview-card">
+          <div class="overview-title">闭环步骤</div>
+          <div class="overview-value" id="step-count">0</div>
+        </div>
+        <div class="overview-card">
+          <div class="overview-title">沉淀资产</div>
+          <div class="overview-value" id="asset-count">0</div>
+        </div>
+      </section>
+
+      <main class="layout">
+        <section class="panel">
+          <div class="panel-title">冷链场景输入</div>
+          <div class="panel-subtitle">
+            输入真实业务场景，系统将自动生成完整闭环，并支持历史回放
+          </div>
+          <form id="run-form" class="form-grid">
+            <div>
+              <label>会话名称</label>
+              <input id="name" placeholder="如：华东医药冷链升级计划" />
+            </div>
+            <div>
+              <label>场景描述</label>
+              <textarea id="scenario" placeholder="描述冷链网络、温控要求、运输路径、服务对象等"></textarea>
+            </div>
+            <div>
+              <label>目标指标</label>
+              <input id="target" placeholder="如：准时交付率≥98%，温控合规率≥99.5%" />
+            </div>
+            <div>
+              <label>约束条件</label>
+              <textarea id="constraints" placeholder="如：夜间限行、预算、车辆通行证等"></textarea>
+            </div>
+            <div class="btn-row">
+              <button class="btn-primary" type="submit" id="run-btn">生成闭环</button>
+              <button class="btn-ghost" type="button" id="demo-btn">填充示例</button>
+            </div>
+          </form>
+          <div class="status-card" id="status-card">等待生成冷链闭环方案</div>
+
+          <div class="panel-title" style="margin-top: 18px;">历史会话资产</div>
+          <div class="history-list" id="history-list"></div>
+
+          <div class="panel-title" style="margin-top: 18px;">数据上传（可选）</div>
+          <div class="history-list">
+            <div class="history-item">
+              <div class="muted upload-tip">
+                可上传冷链线路 CSV/JSON 或二进制温度记录文件，系统将只记录文件名与大小作为资产示例，避免大文件占用 Hugging Face 空间。
+              </div>
+              <input type="file" id="file-input" />
+              <div class="btn-row" style="margin-top: 8px;">
+                <button class="btn-ghost" type="button" id="upload-btn">上传文件并登记资产</button>
+              </div>
+              <div class="muted" id="upload-status">尚未上传任何文件</div>
+            </div>
+          </div>
+        </section>
+
+        <section class="panel">
+          <div class="panel-title">闭环轨迹与资产</div>
+          <div class="panel-subtitle">按时间顺序展示本轮推理与执行过程（已内置示例会话）</div>
+          <div class="timeline" id="timeline"></div>
+
+          <div class="panel-title" style="margin-top: 18px;">资产沉淀</div>
+          <div class="asset-list" id="asset-list"></div>
+          <div class="footer-tip">
+            提示：设置 .env 的 SILICONFLOW_API_KEY 可接入真实硅基流推理
+          </div>
+        </section>
+      </main>
+    </div>
+
+    <script src="https://cdn.jsdelivr.net/npm/marked/marked.min.js"></script>
+    <script>
+      const sessionCountEl = document.getElementById("session-count");
+      const stepCountEl = document.getElementById("step-count");
+      const assetCountEl = document.getElementById("asset-count");
+      const historyListEl = document.getElementById("history-list");
+      const timelineEl = document.getElementById("timeline");
+      const assetListEl = document.getElementById("asset-list");
+      const statusCardEl = document.getElementById("status-card");
+      const runForm = document.getElementById("run-form");
+      const runBtn = document.getElementById("run-btn");
+      const demoBtn = document.getElementById("demo-btn");
+
+      const renderMarkdown = (content) => {
+        if (!content) return "";
+        return marked.parse(content);
+      };
+
+      const updateOverview = async () => {
+        const res = await fetch("/api/overview");
+        const data = await res.json();
+        sessionCountEl.textContent = data.session_count || 0;
+        stepCountEl.textContent = data.step_count || 0;
+        assetCountEl.textContent = data.asset_count || 0;
+      };
+
+      const loadHistory = async () => {
+        const res = await fetch("/api/sessions");
+        const data = await res.json();
+        historyListEl.innerHTML = "";
+        (data.sessions || []).forEach((item) => {
+          const div = document.createElement("div");
+          div.className = "history-item";
+          div.innerHTML = `
+            <div><strong>${item.name || "未命名会话"}</strong></div>
+            <div class="muted">${item.created_at || ""}</div>
+            <div class="muted">目标：${item.target || "未填写"}</div>
+          `;
+          div.addEventListener("click", () => loadSession(item.id));
+          historyListEl.appendChild(div);
+        });
+      };
+
+      const stepTypeLabel = (type) => {
+        const map = {
+          reasoning: "推理决策",
+          tool_action: "工具行动",
+          memory: "状态记忆",
+          validation: "校验验收",
+          iteration: "迭代复盘",
+        };
+        return map[type] || type || "步骤";
+      };
+
+      const stepRoleLabel = (role) => {
+        const map = {
+          Planner: "规划智能体",
+          RouteOps: "线路与运力智能体",
+          Memory: "资产沉淀智能体",
+          QualityAuditor: "质量合规智能体",
+          Optimizer: "迭代优化智能体",
+        };
+        return map[role] || role || "智能体";
+      };
+
+      const renderTimeline = (steps = []) => {
+        timelineEl.innerHTML = "";
+        if (!steps.length) {
+          timelineEl.innerHTML =
+            "<div class='muted'>暂无闭环步骤，可点击左侧示例按钮快速体验。</div>";
+          return;
+        }
+        steps.forEach((step) => {
+          const card = document.createElement("div");
+          card.className = "timeline-item";
+          card.innerHTML = `
+            <div class="timeline-header">
+              <div class="timeline-type">
+                <strong>${stepTypeLabel(step.step_type)}</strong>
+                · ${stepRoleLabel(step.role)}
+              </div>
+              <span class="badge badge-soft">步骤 ${step.step_order}</span>
+            </div>
+            <div class="markdown">${renderMarkdown(step.content)}</div>
+          `;
+          timelineEl.appendChild(card);
+        });
+      };
+
+      const renderAssets = (assets = []) => {
+        assetListEl.innerHTML = "";
+        if (!assets.length) {
+          assetListEl.innerHTML = "<div class='muted'>暂无资产沉淀</div>";
+          return;
+        }
+        assets.forEach((asset) => {
+          const card = document.createElement("div");
+          card.className = "asset-item";
+          const isMetrics = asset.asset_type === "metrics";
+          const content = isMetrics
+            ? `<pre class="muted">${asset.content}</pre>`
+            : renderMarkdown(asset.content);
+          card.innerHTML = `
+            <div><strong>${asset.title}</strong></div>
+            <div class="muted">${asset.created_at || ""}</div>
+            <div class="markdown">${content}</div>
+          `;
+          assetListEl.appendChild(card);
+        });
+      };
+
+      const loadSession = async (sessionId) => {
+        const res = await fetch(`/api/session/${sessionId}`);
+        const data = await res.json();
+        if (data.error) {
+          statusCardEl.textContent = data.error;
+          return;
+        }
+        const title = data.session?.name || "冷链运营会话";
+        statusCardEl.textContent = `正在回放：${title}`;
+        renderTimeline(data.steps || []);
+        renderAssets(data.assets || []);
+      };
+
+      runForm.addEventListener("submit", async (event) => {
+        event.preventDefault();
+        runBtn.disabled = true;
+        statusCardEl.textContent = "正在生成闭环方案，请稍候...";
+        const payload = {
+          name: document.getElementById("name").value,
+          scenario: document.getElementById("scenario").value,
+          target: document.getElementById("target").value,
+          constraints: document.getElementById("constraints").value,
+        };
+        const res = await fetch("/api/run", {
+          method: "POST",
+          headers: { "Content-Type": "application/json" },
+          body: JSON.stringify(payload),
+        });
+        const data = await res.json();
+        if (data.error) {
+          statusCardEl.textContent = data.error;
+          runBtn.disabled = false;
+          return;
+        }
+        statusCardEl.textContent = "闭环生成完成，可继续迭代";
+        renderTimeline(data.steps || []);
+        renderAssets(data.assets || []);
+        await updateOverview();
+        await loadHistory();
+        runBtn.disabled = false;
+      });
+
+      const fileInput = document.getElementById("file-input");
+      const uploadBtn = document.getElementById("upload-btn");
+      const uploadStatus = document.getElementById("upload-status");
+
+      uploadBtn.addEventListener("click", async () => {
+        if (!fileInput.files || !fileInput.files[0]) {
+          uploadStatus.textContent = "请先选择要上传的文件";
+          return;
+        }
+        const file = fileInput.files[0];
+        uploadStatus.textContent = "正在上传与登记资产...";
+        const formData = new FormData();
+        formData.append("file", file);
+        try {
+          const res = await fetch("/api/upload", {
+            method: "POST",
+            body: formData,
+          });
+          const data = await res.json();
+          if (data.error) {
+            uploadStatus.textContent = data.error;
+            return;
+          }
+          uploadStatus.textContent = `已登记资产：${data.filename}（${data.size_kb} KB）`;
+          await updateOverview();
+          await loadHistory();
+        } catch (e) {
+          uploadStatus.textContent = "上传失败，请稍后重试";
+        }
+      });
+
+      demoBtn.addEventListener("click", () => {
+        document.getElementById("name").value = "华南疫苗冷链优化";
+        document.getElementById("scenario").value =
+          "覆盖 4 个省会城市与 16 家疾控中心，要求 2-8℃温控，疫苗需 12 小时内送达；" +
+          "高峰期需提升运力 30%，并确保可追溯与异常预警。";
+        document.getElementById("target").value =
+          "准时交付率≥98%，温控合规率≥99.7%，运输成本降低 10%";
+        document.getElementById("constraints").value =
+          "夜间限行、高速收费上涨、部分区域冷库容量不足";
+      });
+
+      updateOverview();
+      loadHistory();
+      renderTimeline([]);
+      renderAssets([]);
+    </script>
+  </body>
+</html>