init factory flow agent

.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -0,0 +1,3 @@
+__pycache__/
+instance/*.db
+*.pyc

Dockerfile

@@ -0,0 +1,14 @@
+FROM python:3.9-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY . .
+
+RUN mkdir -p instance && chmod 777 instance
+
+EXPOSE 7868
+
+CMD ["python", "app.py"]

README.md

@@ -0,0 +1,57 @@
+---
+title: 产线闭环运营智能体
+emoji: 🏭
+colorFrom: orange
+colorTo: slate
+sdk: docker
+app_port: 7868
+short_description: 产线闭环运营智能体
+pinned: false
+license: mit
+---
+
+# Factory Flow Agent（产线闭环运营智能体）
+
+## 项目简介
+Factory Flow Agent 面向制造业产线与仓配协同场景，提供“推理决策 → 工具行动 → 状态记忆 → 校验验收 → 迭代复盘”的闭环智能体流程。  
+系统支持方案回放、资产沉淀、对话分析与数据持久化，适用于生产优化、质量控制、能耗治理与交付保障等商业化场景。
+
+## 核心能力
+- 六阶段闭环：推理决策、执行路线图、工具行动、状态记忆、校验验收、迭代复盘
+- 指标看板：OEE、能耗、良率、交付与成本改善预估
+- 快速模板：内置场景模板一键生成闭环
+- 资产沉淀：可复用策略、模板与验收清单存储
+- 对话分析：产线问题咨询与策略建议
+- 数据持久化：SQLite 本地存储，支持历史查询
+
+## 技术栈
+- 后端：Python + Flask + SQLite
+- 前端：Vue 3 + Marked.js（Markdown 渲染）
+- 模型：SiliconFlow API（未配置时自动使用本地模拟）
+- 部署：Docker
+
+## 快速开始
+
+### 本地运行
+```bash
+pip install -r requirements.txt
+python app.py
+```
+访问：http://localhost:7868
+
+### Docker 运行
+```bash
+docker build -t factory-flow-agent .
+docker run -p 7868:7868 factory-flow-agent
+```
+
+### 模型配置
+如需连接硅基流，设置环境变量：
+```bash
+export SILICONFLOW_API_KEY="你的_API_KEY"
+```
+
+## 商业价值
+- 制造企业降本增效、缩短交付周期与提升良率
+- 支持构建可复用的产线知识资产与运营标准
+- 可扩展为 SaaS 或行业解决方案

app.py

@@ -0,0 +1,666 @@
+import os
+import sqlite3
+import json
+import datetime
+import random
+import requests
+from flask import Flask, render_template, request, jsonify, g
+
+app = Flask(__name__, instance_relative_config=True)
+app.config["SECRET_KEY"] = "factory-flow-secret-key"
+app.config["JSON_AS_ASCII"] = False
+
+try:
+    os.makedirs(app.instance_path, exist_ok=True)
+except OSError:
+    pass
+
+DB_PATH = os.path.join(app.instance_path, "factory_flow.db")
+
+SILICON_FLOW_API_URL = "https://api.siliconflow.cn/v1/chat/completions"
+DEFAULT_MODEL = "Qwen/Qwen2.5-7B-Instruct"
+DEFAULT_TEMPLATES = [
+    {
+        "title": "电池产线良率提升闭环",
+        "scenario": "动力电池产线希望在 2 个月内提升良品率 1.5%，同时降低涂布段停机率。请给出闭环方案与验收指标。",
+        "hint": "优先解决涂布段设备老化与质量波动问题。",
+    },
+    {
+        "title": "仓配协同排产闭环",
+        "scenario": "电子制造工厂需要将排产与仓配补料联动，降低缺料率并提高交付准时率。",
+        "hint": "关注安全库存阈值与跨班次协同。",
+    },
+    {
+        "title": "冷链质量追溯闭环",
+        "scenario": "冷链食品工厂的温控波动导致返工率上升，需要建立温控预警与批次追溯体系。",
+        "hint": "明确温控指标和追溯链路。",
+    },
+    {
+        "title": "设备预防性维护闭环",
+        "scenario": "设备故障频发导致产能波动，要求建立预防性维护节奏与停机风险预测。",
+        "hint": "补齐设备状态监测与维护日志闭环。",
+    },
+]
+
+
+def get_db():
+    db = getattr(g, "_database", None)
+    if db is None:
+        db = g._database = sqlite3.connect(DB_PATH)
+        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 init_db():
+    db = get_db()
+    db.execute(
+        """
+        CREATE TABLE IF NOT EXISTS sessions (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            name TEXT,
+            scenario TEXT NOT NULL,
+            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,
+            title TEXT NOT NULL,
+            category TEXT NOT NULL,
+            content TEXT NOT NULL,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+        """
+    )
+    db.execute(
+        """
+        CREATE TABLE IF NOT EXISTS chats (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            role TEXT NOT NULL,
+            content TEXT NOT NULL,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+        """
+    )
+    db.commit()
+    seed_default_data(db)
+
+
+def seed_default_data(db):
+    row = db.execute("SELECT COUNT(*) AS c FROM sessions").fetchone()
+    if row and row["c"]:
+        return
+
+    demos = [
+        {
+            "name": "示例会话 · 新能源电池产线降本增效",
+            "scenario": (
+                "一家动力电池工厂计划在 3 个月内将良品率提升 2%，并降低单位能耗 8%。"
+                "当前产线瓶颈集中在涂布与化成段，设备老化导致停机频繁。"
+                "要求输出：可执行的改造路径、数据采集方案、质量验证与验收指标。"
+            ),
+            "hint": "优先解决涂布段产能与能耗问题，同时建立快速验收闭环。",
+        },
+        {
+            "name": "示例会话 · 智能仓配协同工厂排产",
+            "scenario": (
+                "一家电子制造企业需要将产线排产与仓配补料联动。"
+                "目标是让关键物料缺料率下降 50%，并保证交付准时率 > 95%。"
+                "请给出排产策略、补料触发规则、异常处理与复盘机制。"
+            ),
+            "hint": "关注关键物料的安全库存阈值与跨班次协同。",
+        },
+        {
+            "name": "示例会话 · 食品工厂冷链质量闭环",
+            "scenario": (
+                "一家冷链食品工厂需要降低返工率并提升出货稳定性。"
+                "当前问题集中在冷链温控波动、包装漏检与批次追溯不完整。"
+                "请给出数据采集与批次追溯闭环方案，并输出验收指标。"
+            ),
+            "hint": "优先建立温控波动预警与批次追溯链路。",
+        },
+    ]
+
+    for item in demos:
+        cursor = db.execute(
+            "INSERT INTO sessions (name, scenario) VALUES (?, ?)",
+            (item["name"], item["scenario"]),
+        )
+        session_id = cursor.lastrowid
+        result = run_factory_workflow(item["scenario"], extra_hint=item["hint"])
+        for s in result["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"]),
+            )
+
+    db.execute(
+        """
+        INSERT INTO assets (title, category, content)
+        VALUES (?, ?, ?)
+        """,
+        (
+            "基准产线画像模板",
+            "流程资产",
+            "用于沉淀关键工序、设备台账与质量指标的基础模板，可直接复用为后续方案的输入。",
+        ),
+    )
+    db.execute(
+        """
+        INSERT INTO assets (title, category, content)
+        VALUES (?, ?, ?)
+        """,
+        (
+            "关键工序异常响应卡",
+            "运营资产",
+            "当检测到异常停机、良率波动或温控偏移时，按照分级响应流程快速锁定问题并记录复盘。",
+        ),
+    )
+    db.execute(
+        "INSERT INTO chats (role, content) VALUES (?, ?)",
+        ("assistant", "你好，我可以帮你评估产线瓶颈、成本与交付风险。"),
+    )
+    db.commit()
+
+
+def call_llm(messages, model=DEFAULT_MODEL, max_tokens=1200):
+    api_key = os.getenv("SILICONFLOW_API_KEY", "").strip()
+
+    def mock_completion():
+        now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
+        last_user = ""
+        for m in reversed(messages):
+            if m.get("role") == "user":
+                last_user = m.get("content", "")[:300]
+                break
+        return (
+            f"## 本地模拟智能体回复\n\n"
+            f"- 时间：{now}\n"
+            f"- 说明：当前未连接硅基流 API，系统使用本地规则进行推演。\n\n"
+            f"### 输入摘要\n\n"
+            f"{last_user}\n\n"
+            f"### 建议\n\n"
+            f"- 先建立数据采集与异常预警，再扩展到全链路优化。"
+        )
+
+    if not api_key or not api_key.startswith("sk-"):
+        return mock_completion()
+
+    headers = {
+        "Authorization": f"Bearer {api_key}",
+        "Content-Type": "application/json",
+    }
+    payload = {
+        "model": model,
+        "messages": messages,
+        "stream": False,
+        "max_tokens": max_tokens,
+    }
+
+    try:
+        resp = requests.post(SILICON_FLOW_API_URL, headers=headers, json=payload, timeout=20)
+        if resp.status_code == 200:
+            data = resp.json()
+            return data["choices"][0]["message"]["content"]
+        return mock_completion()
+    except Exception:
+        return mock_completion()
+
+
+def simulate_factory_tools(scenario_text):
+    length = len(scenario_text)
+    demand_index = min(96, max(55, 55 + length % 42))
+    energy_cost_index = round(0.62 + (length % 36) * 0.01, 2)
+    utilization = min(93, 66 + (length % 24))
+    defect_risk = min(88, 35 + (length % 52))
+
+    bottlenecks = ["涂布段", "化成段", "贴片段", "包装段", "检测段", "仓配补料"]
+    weighted = []
+    for item in bottlenecks:
+        weight = 1
+        if item in scenario_text:
+            weight += 2
+        weighted.extend([item] * weight)
+    bottleneck = random.choice(weighted)
+
+    keywords = ["冷链", "良品率", "缺料", "停机", "能耗", "交付", "追溯", "排产"]
+    risk_score = 0
+    for k in keywords:
+        if k in scenario_text:
+            risk_score += 7
+    risk_score = min(92, risk_score + length % 12)
+
+    sla_score = min(98, 72 + (100 - risk_score) // 4)
+    oee = min(90, max(58, 60 + (length % 28)))
+    throughput_gain = min(22, 6 + (length % 16))
+    cost_reduction = min(20, 5 + (length % 14))
+    energy_saving = min(18, 4 + (length % 12))
+    inventory_turnover = min(14, 6 + (length % 9))
+
+    return {
+        "demand_index": demand_index,
+        "energy_cost_index": energy_cost_index,
+        "capacity_utilization": utilization,
+        "defect_risk": defect_risk,
+        "bottleneck": bottleneck,
+        "risk_score": risk_score,
+        "sla_score": sla_score,
+        "oee": oee,
+        "throughput_gain": throughput_gain,
+        "cost_reduction": cost_reduction,
+        "energy_saving": energy_saving,
+        "inventory_turnover": inventory_turnover,
+    }
+
+
+def build_state_memory(scenario_text, tool_data):
+    return (
+        "### 产线状态记忆快照\n\n"
+        f"- 当前瓶颈：{tool_data['bottleneck']}\n"
+        f"- 产能利用率：{tool_data['capacity_utilization']}%\n"
+        f"- 缺陷风险指数：{tool_data['defect_risk']}\n"
+        f"- OEE 综合效率：{tool_data['oee']}%\n"
+        f"- 能耗成本指数：{tool_data['energy_cost_index']}\n\n"
+        "### 可复用资产\n\n"
+        "- 产线瓶颈诊断模板\n"
+        "- 工序 KPI 看板结构\n"
+        "- 质量验收与复盘清单"
+    )
+
+
+def build_acceptance(tool_data):
+    score = round(
+        (tool_data["sla_score"] * 0.5)
+        + (100 - tool_data["defect_risk"]) * 0.3
+        + (100 - tool_data["risk_score"]) * 0.2,
+        1,
+    )
+    verdict = "通过" if score >= 75 else "需整改"
+    return {
+        "acceptance_score": score,
+        "verdict": verdict,
+        "key_checks": [
+            "瓶颈段产能提升是否达到目标",
+            "能耗与成本下降是否有数据闭环",
+            "质量缺陷率是否稳定下降",
+            "异常处理与复盘是否形成闭环机制",
+        ],
+    }
+
+def derive_risk_level(score):
+    if score <= 35:
+        return "低"
+    if score <= 70:
+        return "中"
+    return "高"
+
+
+def build_insight(tool_data):
+    risk_level = derive_risk_level(tool_data["risk_score"])
+    gaps = []
+    if tool_data["defect_risk"] >= 60:
+        gaps.append("质量波动偏高")
+    if tool_data["capacity_utilization"] < 75:
+        gaps.append("产能利用率偏低")
+    if tool_data["energy_cost_index"] > 0.75:
+        gaps.append("能耗成本偏高")
+    if not gaps:
+        gaps.append("暂无明显短板")
+    return {
+        "risk_level": risk_level,
+        "gaps": gaps,
+        "roi_hint": f"预计成本下降 {tool_data['cost_reduction']}%，产能提升 {tool_data['throughput_gain']}%。",
+    }
+
+
+def build_action_plan(tool_data):
+    return (
+        "### 执行路线图\n\n"
+        "#### 第 1 周：数据基线建立\n"
+        "- 梳理瓶颈工序与关键设备状态\n"
+        "- 建立良率、能耗、停机与交付基线\n\n"
+        "#### 第 2-4 周：瓶颈突破与协同排产\n"
+        f"- 重点优化工序：{tool_data['bottleneck']}\n"
+        "- 建立补料触发规则与异常响应流程\n"
+        "- 引入批次追溯与质量预警\n\n"
+        "#### 第 5-8 周：质量闭环与节能优化\n"
+        "- 固化标准作业与质量验收清单\n"
+        "- 建立节能计划与设备维护节奏\n\n"
+        "#### 第 9-12 周：规模化复制与复盘\n"
+        "- 复制闭环方案到相似产线\n"
+        "- 形成复盘报告与资产沉淀"
+    )
+
+
+def run_factory_workflow(scenario_text, extra_hint=None):
+    system_prompt = (
+        "你是产线闭环运营智能体，负责从推理决策到工具行动、验收与复盘。"
+        "输出内容必须是可执行的中文 Markdown。"
+    )
+    hint = extra_hint or "请给出可落地的改造步骤与量化指标。"
+
+    reasoning = call_llm(
+        [
+            {"role": "system", "content": system_prompt},
+            {
+                "role": "user",
+                "content": f"场景：{scenario_text}\n要求：{hint}\n请输出决策推理与行动路径。",
+            },
+        ]
+    )
+
+    tool_data = simulate_factory_tools(scenario_text)
+    tool_payload = json.dumps(tool_data, ensure_ascii=False, indent=2)
+
+    state_memory = build_state_memory(scenario_text, tool_data)
+    acceptance = build_acceptance(tool_data)
+    action_plan = build_action_plan(tool_data)
+    acceptance_md = (
+        "### 验收与校验\n\n"
+        f"- 综合得分：{acceptance['acceptance_score']}\n"
+        f"- 验收结论：{acceptance['verdict']}\n\n"
+        "#### 关键校验点\n\n"
+        + "\n".join([f"- {c}" for c in acceptance["key_checks"]])
+    )
+
+    iteration = call_llm(
+        [
+            {"role": "system", "content": system_prompt},
+            {
+                "role": "user",
+                "content": (
+                    f"基于以下产线工具结果与验收结论，输出迭代与复盘计划：\n\n"
+                    f"工具结果：{tool_payload}\n\n"
+                    f"验收结论：{acceptance['verdict']}\n"
+                ),
+            },
+        ]
+    )
+
+    insight = build_insight(tool_data)
+    return {
+        "steps": [
+            {
+                "step_order": 1,
+                "role": "决策官",
+                "step_type": "reasoning",
+                "content": reasoning,
+            },
+            {
+                "step_order": 2,
+                "role": "计划官",
+                "step_type": "plan",
+                "content": action_plan,
+            },
+            {
+                "step_order": 3,
+                "role": "工具引擎",
+                "step_type": "tool_action",
+                "content": tool_payload,
+            },
+            {
+                "step_order": 4,
+                "role": "状态记忆",
+                "step_type": "state_memory",
+                "content": state_memory,
+            },
+            {
+                "step_order": 5,
+                "role": "验收官",
+                "step_type": "verification",
+                "content": acceptance_md,
+            },
+            {
+                "step_order": 6,
+                "role": "复盘官",
+                "step_type": "iteration",
+                "content": iteration,
+            },
+        ],
+        "tool_data": tool_data,
+        "acceptance": acceptance,
+        "insight": insight,
+        "state_memory": state_memory,
+    }
+
+
+@app.route("/")
+def index():
+    return render_template("index.html")
+
+
+@app.route("/api/sessions", methods=["GET"])
+def list_sessions():
+    db = get_db()
+    rows = db.execute(
+        "SELECT id, name, scenario, created_at FROM sessions ORDER BY id DESC LIMIT 50"
+    ).fetchall()
+    sessions = [
+        {
+            "id": r["id"],
+            "name": r["name"],
+            "scenario": r["scenario"],
+            "created_at": r["created_at"],
+        }
+        for r in rows
+    ]
+    return jsonify({"sessions": sessions})
+
+
+@app.route("/api/templates", methods=["GET"])
+def list_templates():
+    return jsonify({"templates": DEFAULT_TEMPLATES})
+
+
+@app.route("/api/overview", methods=["GET"])
+def overview():
+    db = get_db()
+    session_count = db.execute("SELECT COUNT(*) AS c FROM sessions").fetchone()["c"]
+    asset_count = db.execute("SELECT COUNT(*) AS c FROM assets").fetchone()["c"]
+    chat_count = db.execute("SELECT COUNT(*) AS c FROM chats").fetchone()["c"]
+    latest_tool = db.execute(
+        "SELECT content FROM steps WHERE step_type = 'tool_action' ORDER BY id DESC LIMIT 1"
+    ).fetchone()
+    tool_data = {}
+    if latest_tool:
+        try:
+            tool_data = json.loads(latest_tool["content"])
+        except Exception:
+            tool_data = {}
+    return jsonify(
+        {
+            "session_count": session_count,
+            "asset_count": asset_count,
+            "chat_count": chat_count,
+            "latest_tool": tool_data,
+        }
+    )
+
+
+@app.route("/api/sessions/<int:session_id>", methods=["GET"])
+def get_session_detail(session_id):
+    db = get_db()
+    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()
+    step_list = [
+        {
+            "step_order": s["step_order"],
+            "role": s["role"],
+            "step_type": s["step_type"],
+            "content": s["content"],
+            "created_at": s["created_at"],
+        }
+        for s in steps
+    ]
+    return jsonify({"steps": step_list})
+
+
+@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()
+    name = (data or {}).get("name", "").strip() or "产线闭环会话"
+    hint = (data or {}).get("hint", "").strip()
+
+    if not scenario:
+        return jsonify({"error": "请提供场景描述"}), 400
+
+    db = get_db()
+    cursor = db.execute(
+        "INSERT INTO sessions (name, scenario) VALUES (?, ?)", (name, scenario)
+    )
+    session_id = cursor.lastrowid
+
+    result = run_factory_workflow(scenario, extra_hint=hint)
+    for s in result["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"]),
+        )
+    if result["acceptance"]["verdict"] == "通过":
+        db.execute(
+            "INSERT INTO assets (title, category, content) VALUES (?, ?, ?)",
+            (
+                f"{name} · 闭环方案摘要",
+                "闭环资产",
+                result["state_memory"],
+            ),
+        )
+    db.commit()
+    return jsonify(
+        {
+            "session_id": session_id,
+            "tool_data": result["tool_data"],
+            "acceptance": result["acceptance"],
+            "insight": result["insight"],
+        }
+    ), 201
+
+
+@app.route("/api/assets", methods=["GET"])
+def list_assets():
+    db = get_db()
+    rows = db.execute(
+        "SELECT id, title, category, content, created_at FROM assets ORDER BY id DESC"
+    ).fetchall()
+    assets = [
+        {
+            "id": r["id"],
+            "title": r["title"],
+            "category": r["category"],
+            "content": r["content"],
+            "created_at": r["created_at"],
+        }
+        for r in rows
+    ]
+    return jsonify({"assets": assets})
+
+
+@app.route("/api/assets", methods=["POST"])
+def create_asset():
+    data = request.get_json(force=True)
+    title = (data.get("title") or "").strip()
+    category = (data.get("category") or "").strip()
+    content = (data.get("content") or "").strip()
+
+    if not title or not category or not content:
+        return jsonify({"error": "标题、分类与内容不能为��"}), 400
+
+    db = get_db()
+    db.execute(
+        "INSERT INTO assets (title, category, content) VALUES (?, ?, ?)",
+        (title, category, content),
+    )
+    db.commit()
+    return jsonify({"status": "ok"})
+
+
+@app.route("/api/chats", methods=["GET"])
+def list_chats():
+    db = get_db()
+    rows = db.execute(
+        "SELECT role, content, created_at FROM chats ORDER BY id DESC LIMIT 50"
+    ).fetchall()
+    chats = [
+        {"role": r["role"], "content": r["content"], "created_at": r["created_at"]}
+        for r in rows[::-1]
+    ]
+    return jsonify({"messages": chats})
+
+
+@app.route("/api/chat", methods=["POST"])
+def chat():
+    data = request.get_json(force=True)
+    message = (data.get("message") or "").strip()
+    if not message:
+        return jsonify({"error": "消息不能为空"}), 400
+
+    system_prompt = (
+        "你是制造业产线运营顾问，擅长在成本、质量、交付与风险之间做平衡决策。"
+        "你的回复必须是中文 Markdown。"
+    )
+
+    reply = call_llm(
+        [
+            {"role": "system", "content": system_prompt},
+            {"role": "user", "content": message},
+        ]
+    )
+
+    db = get_db()
+    db.execute(
+        "INSERT INTO chats (role, content) VALUES (?, ?)", ("user", message)
+    )
+    db.execute(
+        "INSERT INTO chats (role, content) VALUES (?, ?)", ("assistant", reply)
+    )
+    db.commit()
+    return jsonify({"reply": reply})
+
+
+with app.app_context():
+    init_db()
+
+
+if __name__ == "__main__":
+    port = int(os.getenv("PORT", "7868"))
+    app.run(host="0.0.0.0", port=port, debug=False)

requirements.txt

@@ -0,0 +1,2 @@
+flask
+requests

templates/index.html

@@ -0,0 +1,740 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Factory Flow Agent | 产线闭环运营智能体</title>
+    <script src="https://unpkg.com/vue@3/dist/vue.global.js"></script>
+    <script src="https://cdn.jsdelivr.net/npm/marked/marked.min.js"></script>
+    <style>
+        :root {
+            color-scheme: light;
+            font-family: "Inter", "Noto Sans SC", system-ui, -apple-system, sans-serif;
+            background: #f4f6f8;
+            color: #1f2937;
+        }
+        body {
+            margin: 0;
+            min-height: 100vh;
+            background: #f4f6f8;
+        }
+        .app-shell {
+            display: flex;
+            flex-direction: column;
+            min-height: 100vh;
+        }
+        header {
+            background: linear-gradient(120deg, #111827, #1f2937);
+            color: #fff;
+            padding: 24px 28px;
+        }
+        .brand {
+            display: flex;
+            align-items: center;
+            gap: 12px;
+        }
+        .brand-mark {
+            width: 46px;
+            height: 46px;
+            border-radius: 12px;
+            background: linear-gradient(135deg, #f97316, #f59e0b);
+            display: grid;
+            place-items: center;
+            font-weight: 700;
+            font-size: 18px;
+        }
+        .brand-title {
+            font-size: 20px;
+            font-weight: 700;
+        }
+        .brand-subtitle {
+            font-size: 13px;
+            opacity: 0.75;
+        }
+        .tagline {
+            margin-top: 14px;
+            display: flex;
+            gap: 12px;
+            flex-wrap: wrap;
+        }
+        .chip {
+            background: rgba(255, 255, 255, 0.1);
+            padding: 6px 12px;
+            border-radius: 999px;
+            font-size: 12px;
+        }
+        main {
+            flex: 1;
+            display: grid;
+            grid-template-columns: 320px 1fr;
+            gap: 20px;
+            padding: 20px 24px 32px;
+        }
+        .panel {
+            background: #fff;
+            border-radius: 16px;
+            box-shadow: 0 10px 30px rgba(15, 23, 42, 0.08);
+            padding: 18px;
+            display: flex;
+            flex-direction: column;
+            gap: 14px;
+        }
+        .panel-title {
+            font-weight: 700;
+            font-size: 15px;
+            display: flex;
+            justify-content: space-between;
+            align-items: center;
+        }
+        .panel-subtitle {
+            font-size: 12px;
+            color: #6b7280;
+        }
+        .input-group label {
+            font-size: 12px;
+            color: #374151;
+            margin-bottom: 6px;
+            display: block;
+        }
+        .input-group input,
+        .input-group textarea,
+        .input-group select {
+            width: 100%;
+            padding: 10px 12px;
+            border-radius: 10px;
+            border: 1px solid #e5e7eb;
+            font-size: 13px;
+            background: #f9fafb;
+            outline: none;
+        }
+        .input-group textarea {
+            min-height: 120px;
+            resize: vertical;
+        }
+        .primary-btn {
+            background: #f97316;
+            color: #fff;
+            border: none;
+            border-radius: 10px;
+            padding: 10px 14px;
+            font-weight: 600;
+            cursor: pointer;
+        }
+        .primary-btn:disabled {
+            opacity: 0.6;
+            cursor: not-allowed;
+        }
+        .secondary-btn {
+            background: #111827;
+            color: #fff;
+            border: none;
+            border-radius: 10px;
+            padding: 9px 12px;
+            font-weight: 600;
+            cursor: pointer;
+        }
+        .ghost-btn {
+            background: #fff;
+            color: #111827;
+            border: 1px solid #e5e7eb;
+            border-radius: 10px;
+            padding: 9px 12px;
+            font-weight: 600;
+            cursor: pointer;
+        }
+        .overview-grid {
+            display: grid;
+            grid-template-columns: repeat(2, 1fr);
+            gap: 10px;
+        }
+        .overview-card {
+            background: #f8fafc;
+            border-radius: 12px;
+            padding: 10px 12px;
+            border: 1px solid #e5e7eb;
+        }
+        .overview-title {
+            font-size: 11px;
+            color: #6b7280;
+        }
+        .overview-value {
+            font-size: 16px;
+            font-weight: 700;
+            margin-top: 4px;
+        }
+        .template-list {
+            display: grid;
+            gap: 8px;
+        }
+        .template-item {
+            border: 1px solid #e5e7eb;
+            border-radius: 12px;
+            padding: 10px 12px;
+            background: #fff;
+        }
+        .template-item h5 {
+            margin: 0 0 4px;
+            font-size: 13px;
+        }
+        .template-item p {
+            margin: 0;
+            font-size: 12px;
+            color: #6b7280;
+        }
+        .badge {
+            display: inline-flex;
+            align-items: center;
+            gap: 4px;
+            padding: 4px 10px;
+            border-radius: 999px;
+            font-size: 11px;
+            background: #fef3c7;
+            color: #92400e;
+        }
+        .metrics {
+            display: grid;
+            gap: 10px;
+        }
+        .metric-card {
+            background: #f8fafc;
+            border-radius: 12px;
+            padding: 12px;
+            border: 1px solid #e5e7eb;
+        }
+        .metric-label {
+            font-size: 12px;
+            color: #6b7280;
+        }
+        .metric-value {
+            font-size: 18px;
+            font-weight: 700;
+            margin-top: 4px;
+        }
+        .tabs {
+            display: flex;
+            gap: 10px;
+        }
+        .tab-btn {
+            padding: 8px 14px;
+            border-radius: 999px;
+            border: 1px solid #e5e7eb;
+            background: #fff;
+            font-size: 13px;
+            cursor: pointer;
+        }
+        .tab-btn.active {
+            background: #111827;
+            color: #fff;
+            border-color: #111827;
+        }
+        .list {
+            display: grid;
+            gap: 10px;
+        }
+        .card {
+            border-radius: 14px;
+            border: 1px solid #e5e7eb;
+            padding: 12px 14px;
+            background: #fff;
+        }
+        .card h4 {
+            margin: 0 0 6px;
+            font-size: 14px;
+        }
+        .card p {
+            margin: 0;
+            font-size: 12px;
+            color: #6b7280;
+        }
+        .step-tag {
+            font-size: 11px;
+            padding: 2px 8px;
+            border-radius: 999px;
+            background: #fff7ed;
+            color: #c2410c;
+            border: 1px solid #fed7aa;
+        }
+        .step-head {
+            display: flex;
+            justify-content: space-between;
+            align-items: center;
+            margin-bottom: 8px;
+        }
+        .markdown-body h1 { font-size: 1.3em; }
+        .markdown-body h2 { font-size: 1.15em; margin-top: 1em; }
+        .markdown-body h3 { font-size: 1.05em; margin-top: 0.8em; }
+        .markdown-body ul { padding-left: 1.2em; }
+        .markdown-body code { background: #f3f4f6; padding: 2px 4px; border-radius: 4px; }
+        .chat-box {
+            height: 360px;
+            overflow-y: auto;
+            border: 1px solid #e5e7eb;
+            border-radius: 14px;
+            padding: 12px;
+            background: #f9fafb;
+            display: flex;
+            flex-direction: column;
+            gap: 10px;
+        }
+        .chat-item {
+            max-width: 80%;
+            padding: 10px 12px;
+            border-radius: 12px;
+            font-size: 13px;
+        }
+        .chat-user {
+            align-self: flex-end;
+            background: #111827;
+            color: #fff;
+        }
+        .chat-assistant {
+            align-self: flex-start;
+            background: #fff;
+            border: 1px solid #e5e7eb;
+        }
+        @media (max-width: 960px) {
+            main {
+                grid-template-columns: 1fr;
+            }
+        }
+    </style>
+</head>
+<body>
+{% raw %}
+<div id="app" class="app-shell" v-cloak>
+    <header>
+        <div class="brand">
+            <div class="brand-mark">FF</div>
+            <div>
+                <div class="brand-title">Factory Flow Agent</div>
+                <div class="brand-subtitle">产线闭环运营智能体 · 决策 / 工具 / 记忆 / 验收 / 复盘</div>
+            </div>
+        </div>
+        <div class="tagline">
+            <div class="chip">制造业生产力闭环</div>
+            <div class="chip">资产沉淀 + 可回放</div>
+            <div class="chip">移动端友好</div>
+        </div>
+    </header>
+
+    <main>
+        <section class="panel">
+            <div>
+                <div class="panel-title">闭环任务输入</div>
+                <div class="panel-subtitle">描述真实产线问题，自动生成推理到验收的完整闭环</div>
+            </div>
+            <div class="overview-grid">
+                <div class="overview-card">
+                    <div class="overview-title">历史会话</div>
+                    <div class="overview-value">{{ overview.session_count || 0 }}</div>
+                </div>
+                <div class="overview-card">
+                    <div class="overview-title">沉淀资产</div>
+                    <div class="overview-value">{{ overview.asset_count || 0 }}</div>
+                </div>
+                <div class="overview-card">
+                    <div class="overview-title">对话条数</div>
+                    <div class="overview-value">{{ overview.chat_count || 0 }}</div>
+                </div>
+                <div class="overview-card">
+                    <div class="overview-title">最新风险级别</div>
+                    <div class="overview-value">{{ insight.risk_level || "待分析" }}</div>
+                </div>
+            </div>
+            <div class="template-list">
+                <div class="template-item" v-for="tpl in templates" :key="tpl.title">
+                    <h5>{{ tpl.title }}</h5>
+                    <p>{{ tpl.scenario.slice(0, 36) }}...</p>
+                    <div style="margin-top:8px; display:flex; gap:8px;">
+                        <button class="ghost-btn" @click="applyTemplate(tpl)">一键填充</button>
+                        <button class="secondary-btn" @click="applyTemplate(tpl); runWorkflow()">直接运行</button>
+                    </div>
+                </div>
+            </div>
+            <div class="input-group">
+                <label>会话名称</label>
+                <input v-model="form.name" placeholder="例如：涂布段产能优化闭环" />
+            </div>
+            <div class="input-group">
+                <label>场景描述</label>
+                <textarea v-model="form.scenario" placeholder="请输入产线现状、目标、约束与时间要求"></textarea>
+            </div>
+            <div class="input-group">
+                <label>补充提示</label>
+                <input v-model="form.hint" placeholder="例如：优先降低能耗、保证交付节奏" />
+            </div>
+            <div style="display:flex; gap:10px; flex-wrap:wrap;">
+                <button class="primary-btn" @click="runWorkflow" :disabled="loading">生成闭环方案</button>
+                <button class="ghost-btn" @click="refreshOverview">刷新看板</button>
+            </div>
+
+            <div class="panel-title">关键指标仪表</div>
+            <div class="metrics">
+                <div class="metric-card" v-for="(value, key) in metricCards" :key="key">
+                    <div class="metric-label">{{ value.label }}</div>
+                    <div class="metric-value">{{ value.value }}</div>
+                </div>
+            </div>
+        </section>
+
+        <section class="panel">
+            <div class="panel-title">
+                <span>产线闭环工作台</span>
+                <div class="tabs">
+                    <button class="tab-btn" :class="{active: currentTab==='loop'}" @click="currentTab='loop'">决策闭环</button>
+                    <button class="tab-btn" :class="{active: currentTab==='assets'}" @click="currentTab='assets'">资产库</button>
+                    <button class="tab-btn" :class="{active: currentTab==='chat'}" @click="currentTab='chat'">对话分析</button>
+                </div>
+            </div>
+
+            <div v-if="currentTab === 'loop'" class="list">
+                <div class="card">
+                    <h4>闭环洞察与验收</h4>
+                    <div class="badge">风险级别：{{ insight.risk_level || "待分析" }}</div>
+                    <div style="margin-top:10px;" class="panel-subtitle">ROI 预测</div>
+                    <div class="markdown-body" v-html="renderMarkdown(insight.roi_hint || '等待生成闭环方案后更新')"></div>
+                    <div class="panel-subtitle">关键短板</div>
+                    <ul v-if="insight.gaps && insight.gaps.length" class="markdown-body">
+                        <li v-for="gap in insight.gaps" :key="gap">{{ gap }}</li>
+                    </ul>
+                    <div v-else class="panel-subtitle">暂无风险洞察</div>
+                    <div class="panel-subtitle" style="margin-top:8px;">验收结果：{{ acceptance.verdict || "待验收" }} · 得分 {{ acceptance.acceptance_score || "-" }}</div>
+                    <div style="margin-top:10px; display:flex; gap:8px; flex-wrap:wrap;">
+                        <button class="ghost-btn" @click="snapshotAsset">一键沉淀为资产</button>
+                        <button class="secondary-btn" @click="currentTab='chat'">进入对话分析</button>
+                    </div>
+                </div>
+                <div class="card">
+                    <h4>会话记录</h4>
+                    <div class="list">
+                        <div class="card" v-for="session in sessions" :key="session.id" @click="loadSession(session.id)" style="cursor:pointer;">
+                            <h4>{{ session.name }}</h4>
+                            <p>{{ session.created_at }}</p>
+                            <p>{{ session.scenario.slice(0, 60) }}...</p>
+                        </div>
+                    </div>
+                </div>
+                <div class="card">
+                    <h4>闭环步骤回放</h4>
+                    <div class="list">
+                        <div class="card" v-for="step in steps" :key="step.step_order">
+                            <div class="step-head">
+                                <div>{{ step.role }}</div>
+                                <span class="step-tag">{{ stepLabels[step.step_type] || step.step_type }}</span>
+                            </div>
+                            <div v-if="step.step_type === 'tool_action'">
+                                <div class="markdown-body" v-html="renderTool(step.content)"></div>
+                            </div>
+                            <div v-else class="markdown-body" v-html="renderMarkdown(step.content)"></div>
+                        </div>
+                        <div v-if="steps.length === 0" class="panel-subtitle">选择左侧会话查看闭环步骤</div>
+                    </div>
+                </div>
+            </div>
+
+            <div v-if="currentTab === 'assets'" class="list">
+                <div class="card">
+                    <h4>沉淀资产</h4>
+                    <div class="input-group">
+                        <label>资产标题</label>
+                        <input v-model="assetForm.title" placeholder="例如：瓶颈诊断清单" />
+                    </div>
+                    <div class="input-group">
+                        <label>资产分类</label>
+                        <input v-model="assetForm.category" placeholder="例如：质量验收" />
+                    </div>
+                    <div class="input-group">
+                        <label>资产内容</label>
+                        <textarea v-model="assetForm.content" placeholder="请填写可复用的策略、模板或指标"></textarea>
+                    </div>
+                    <button class="primary-btn" @click="createAsset">保存资产</button>
+                </div>
+                <div class="card">
+                    <h4>资产列表</h4>
+                    <div class="list">
+                        <div class="card" v-for="asset in assets" :key="asset.id">
+                            <h4>{{ asset.title }}</h4>
+                            <p>{{ asset.category }} · {{ asset.created_at }}</p>
+                            <div class="markdown-body" v-html="renderMarkdown(asset.content)"></div>
+                        </div>
+                    </div>
+                </div>
+            </div>
+
+            <div v-if="currentTab === 'chat'" class="list">
+                <div class="card">
+                    <h4>产线分析对话</h4>
+                    <div class="chat-box">
+                        <div v-for="msg in chatMessages" :key="msg.created_at + msg.role" class="chat-item" :class="msg.role === 'user' ? 'chat-user' : 'chat-assistant'">
+                            <div v-if="msg.role === 'assistant'" v-html="renderMarkdown(msg.content)"></div>
+                            <div v-else>{{ msg.content }}</div>
+                        </div>
+                    </div>
+                    <div class="input-group" style="margin-top:10px;">
+                        <label>输入问题</label>
+                        <input v-model="chatInput" @keyup.enter="sendChat" placeholder="例如：如何降低涂布段停机频率？" />
+                    </div>
+                    <button class="primary-btn" @click="sendChat" :disabled="chatLoading">发送</button>
+                </div>
+            </div>
+        </section>
+    </main>
+</div>
+{% endraw %}
+
+<script>
+    const { createApp, ref, reactive, onMounted } = Vue;
+
+    createApp({
+        setup() {
+            const form = reactive({ name: "", scenario: "", hint: "" });
+            const sessions = ref([]);
+            const steps = ref([]);
+            const assets = ref([]);
+            const metricCards = ref({});
+            const loading = ref(false);
+            const currentTab = ref("loop");
+            const assetForm = reactive({ title: "", category: "", content: "" });
+            const chatMessages = ref([]);
+            const chatInput = ref("");
+            const chatLoading = ref(false);
+            const templates = ref([]);
+            const overview = ref({});
+            const insight = ref({});
+            const acceptance = ref({});
+
+            const stepLabels = {
+                reasoning: "推理决策",
+                plan: "执行路线图",
+                tool_action: "工具行动",
+                state_memory: "状态记忆",
+                verification: "校验验收",
+                iteration: "迭代复盘"
+            };
+
+            const renderMarkdown = (text) => marked.parse(text || "");
+
+            const renderTool = (text) => {
+                try {
+                    const data = JSON.parse(text || "{}");
+                    return marked.parse(
+                        `**瓶颈工序**：${data.bottleneck}\n\n` +
+                        `- 需求指数：${data.demand_index}\n` +
+                        `- 产能利用率：${data.capacity_utilization}%\n` +
+                        `- OEE：${data.oee}%\n` +
+                        `- 缺陷风险：${data.defect_risk}\n` +
+                        `- 能耗成本指数：${data.energy_cost_index}\n` +
+                        `- 成本下降预估：${data.cost_reduction}%\n` +
+                        `- 产能提升预估：${data.throughput_gain}%\n` +
+                        `- 能耗节省预估：${data.energy_saving}%\n` +
+                        `- 库存周转提升：${data.inventory_turnover}%\n` +
+                        `- 交付评分：${data.sla_score}\n` +
+                        `- 综合风险：${data.risk_score}`
+                    );
+                } catch (e) {
+                    return renderMarkdown(text);
+                }
+            };
+
+            const buildMetricCards = (parsed) => ({
+                demand: { label: "需求指数", value: parsed.demand_index ?? "-" },
+                bottleneck: { label: "瓶颈工序", value: parsed.bottleneck ?? "-" },
+                utilization: { label: "产能利用率", value: parsed.capacity_utilization ? `${parsed.capacity_utilization}%` : "-" },
+                oee: { label: "OEE", value: parsed.oee ? `${parsed.oee}%` : "-" },
+                defect: { label: "缺陷风险", value: parsed.defect_risk ?? "-" },
+                energy: { label: "能耗成本", value: parsed.energy_cost_index ?? "-" },
+                cost: { label: "成本下降", value: parsed.cost_reduction ? `${parsed.cost_reduction}%` : "-" },
+                gain: { label: "产能提升", value: parsed.throughput_gain ? `${parsed.throughput_gain}%` : "-" }
+            });
+
+            const buildInsightFromTool = (parsed) => {
+                const score = parsed.risk_score ?? 0;
+                let level = "低";
+                if (score > 70) level = "高";
+                else if (score > 35) level = "中";
+                const gaps = [];
+                if ((parsed.defect_risk ?? 0) >= 60) gaps.push("质量波动偏高");
+                if ((parsed.capacity_utilization ?? 100) < 75) gaps.push("产能利用率偏低");
+                if ((parsed.energy_cost_index ?? 0) > 0.75) gaps.push("能耗成本偏高");
+                if (!gaps.length) gaps.push("暂无明显短板");
+                return {
+                    risk_level: level,
+                    gaps,
+                    roi_hint: `预计成本下降 ${parsed.cost_reduction ?? "-"}%，产能提升 ${parsed.throughput_gain ?? "-"}%。`
+                };
+            };
+
+            const applyTemplate = (tpl) => {
+                form.name = tpl.title;
+                form.scenario = tpl.scenario;
+                form.hint = tpl.hint;
+            };
+
+            const snapshotAsset = () => {
+                const memory = steps.value.find((s) => s.step_type === "state_memory");
+                if (memory) {
+                    assetForm.title = "闭环状态快照资产";
+                    assetForm.category = "闭环资产";
+                    assetForm.content = memory.content;
+                    currentTab.value = "assets";
+                }
+            };
+
+            const refreshOverview = async () => {
+                const res = await fetch("/api/overview");
+                const data = await res.json();
+                overview.value = data || {};
+                if (data && data.latest_tool) {
+                    metricCards.value = buildMetricCards(data.latest_tool);
+                    insight.value = buildInsightFromTool(data.latest_tool);
+                }
+            };
+
+            const fetchTemplates = async () => {
+                const res = await fetch("/api/templates");
+                const data = await res.json();
+                templates.value = data.templates || [];
+            };
+
+            const fetchSessions = async () => {
+                const res = await fetch("/api/sessions");
+                const data = await res.json();
+                sessions.value = data.sessions || [];
+            };
+
+            const loadSession = async (id) => {
+                const res = await fetch(`/api/sessions/${id}`);
+                const data = await res.json();
+                steps.value = data.steps || [];
+                const toolStep = steps.value.find((s) => s.step_type === "tool_action");
+                if (toolStep) {
+                    try {
+                        const parsed = JSON.parse(toolStep.content);
+                        metricCards.value = buildMetricCards(parsed);
+                        insight.value = buildInsightFromTool(parsed);
+                    } catch (e) {
+                        metricCards.value = {};
+                    }
+                }
+                const verifyStep = steps.value.find((s) => s.step_type === "verification");
+                if (verifyStep) {
+                    const scoreMatch = verifyStep.content.match(/综合得分：([0-9.]+)/);
+                    const verdictMatch = verifyStep.content.match(/验收结论：([^\n]+)/);
+                    acceptance.value = {
+                        acceptance_score: scoreMatch ? scoreMatch[1] : "-",
+                        verdict: verdictMatch ? verdictMatch[1] : "待验收"
+                    };
+                }
+            };
+
+            const runWorkflow = async () => {
+                if (!form.scenario.trim()) return;
+                loading.value = true;
+                const res = await fetch("/api/run", {
+                    method: "POST",
+                    headers: { "Content-Type": "application/json" },
+                    body: JSON.stringify(form)
+                });
+                loading.value = false;
+                if (res.ok) {
+                    const data = await res.json();
+                    await fetchSessions();
+                    await loadSession(data.session_id);
+                    insight.value = data.insight || insight.value;
+                    acceptance.value = data.acceptance || acceptance.value;
+                    if (data.tool_data) {
+                        metricCards.value = buildMetricCards(data.tool_data);
+                    }
+                    form.name = "";
+                    form.scenario = "";
+                    form.hint = "";
+                }
+            };
+
+            const fetchAssets = async () => {
+                const res = await fetch("/api/assets");
+                const data = await res.json();
+                assets.value = data.assets || [];
+            };
+
+            const createAsset = async () => {
+                const payload = { ...assetForm };
+                if (!payload.title || !payload.category || !payload.content) return;
+                const res = await fetch("/api/assets", {
+                    method: "POST",
+                    headers: { "Content-Type": "application/json" },
+                    body: JSON.stringify(payload)
+                });
+                if (res.ok) {
+                    assetForm.title = "";
+                    assetForm.category = "";
+                    assetForm.content = "";
+                    await fetchAssets();
+                }
+            };
+
+            const fetchChats = async () => {
+                const res = await fetch("/api/chats");
+                const data = await res.json();
+                chatMessages.value = data.messages || [];
+            };
+
+            const sendChat = async () => {
+                if (!chatInput.value.trim()) return;
+                chatLoading.value = true;
+                const message = chatInput.value;
+                chatInput.value = "";
+                const res = await fetch("/api/chat", {
+                    method: "POST",
+                    headers: { "Content-Type": "application/json" },
+                    body: JSON.stringify({ message })
+                });
+                chatLoading.value = false;
+                if (res.ok) {
+                    await fetchChats();
+                }
+            };
+
+            onMounted(async () => {
+                await fetchSessions();
+                await fetchAssets();
+                await fetchChats();
+                await fetchTemplates();
+                await refreshOverview();
+                if (sessions.value.length > 0) {
+                    await loadSession(sessions.value[0].id);
+                }
+            });
+
+            return {
+                form,
+                sessions,
+                steps,
+                assets,
+                metricCards,
+                loading,
+                currentTab,
+                assetForm,
+                chatMessages,
+                chatInput,
+                chatLoading,
+                templates,
+                overview,
+                insight,
+                acceptance,
+                stepLabels,
+                renderMarkdown,
+                renderTool,
+                runWorkflow,
+                loadSession,
+                createAsset,
+                sendChat,
+                applyTemplate,
+                refreshOverview,
+                snapshotAsset
+            };
+        }
+    }).mount("#app");
+</script>
+</body>
+</html>