feat(agents): Phase3.2 Agent凭据Fernet加密存储 写入加密+调用点解密+返回脱敏+主密钥持久化防竞态 [v2026.07.19.7]

VERSION

@@ -1 +1 @@
-v2026.07.19.4
+v2026.07.19.6

backend/python/app/api/admin/observability_admin.py

@@ -0,0 +1,103 @@
+"""调用可观测面板后端 API（媒体/LLM 调用归因）。
+路由前缀: /app/api/admin/observability
+数据来源: token_usage_logs（Phase 2.2 已加 trace_id 列，可经 X-Trace-Id 关联请求链路）。
+"""
+from datetime import datetime, timedelta
+
+from fastapi import APIRouter, Query, Depends
+from ...database import get_db
+from ..auth import get_current_user
+from sqlalchemy import text
+from sqlalchemy.orm import Session
+
+router = APIRouter()
+
+
+@router.get("/summary")
+async def observability_summary(
+    days: int = Query(30, description="统计天数"),
+    db: Session = Depends(get_db),
+    user=Depends(get_current_user),
+):
+    """媒体/LLM 调用归因：总览 + 按模型 + 按用户 + 每日趋势 + 最近调用(trace_id 下钻)。"""
+    since = datetime.now() - timedelta(days=days)
+
+    totals = db.execute(text("""
+        SELECT COUNT(*),
+               COALESCE(SUM(total_tokens), 0),
+               COALESCE(SUM(cost), 0),
+               COUNT(DISTINCT user_id)
+        FROM token_usage_logs WHERE created_at >= :since
+    """), {"since": since}).fetchone()
+
+    by_model = db.execute(text("""
+        SELECT model_name, COUNT(*), COALESCE(SUM(total_tokens), 0), COALESCE(SUM(cost), 0)
+        FROM token_usage_logs WHERE created_at >= :since
+        GROUP BY model_name ORDER BY COALESCE(SUM(total_tokens), 0) DESC
+    """), {"since": since}).fetchall()
+
+    by_user = db.execute(text("""
+        SELECT t.user_id, u.username, COUNT(*), COALESCE(SUM(t.total_tokens), 0), COALESCE(SUM(t.cost), 0)
+        FROM token_usage_logs t LEFT JOIN users u ON u.id = t.user_id
+        WHERE t.created_at >= :since
+        GROUP BY t.user_id, u.username ORDER BY COALESCE(SUM(t.total_tokens), 0) DESC LIMIT 20
+    """), {"since": since}).fetchall()
+
+    daily = db.execute(text("""
+        SELECT DATE(created_at) AS d, COALESCE(SUM(total_tokens), 0), COALESCE(SUM(cost), 0), COUNT(*)
+        FROM token_usage_logs WHERE created_at >= :since
+        GROUP BY DATE(created_at) ORDER BY d
+    """), {"since": since}).fetchall()
+
+    recent = db.execute(text("""
+        SELECT trace_id, model_name, total_tokens, cost, created_at
+        FROM token_usage_logs WHERE created_at >= :since
+        ORDER BY created_at DESC LIMIT 50
+    """), {"since": since}).fetchall()
+
+    return {
+        "totals": {
+            "calls": int(totals[0] or 0),
+            "tokens": int(totals[1] or 0),
+            "cost": float(totals[2] or 0),
+            "users": int(totals[3] or 0),
+        },
+        "by_model": [
+            {
+                "model_name": m[0] or "unknown",
+                "calls": int(m[1] or 0),
+                "tokens": int(m[2] or 0),
+                "cost": float(m[3] or 0),
+            }
+            for m in by_model
+        ],
+        "by_user": [
+            {
+                "user_id": u[0],
+                "username": u[1] or u[0],
+                "calls": int(u[2] or 0),
+                "tokens": int(u[3] or 0),
+                "cost": float(u[4] or 0),
+            }
+            for u in by_user
+        ],
+        "daily": [
+            {
+                "date": str(d[0]),
+                "tokens": int(d[1] or 0),
+                "cost": float(d[2] or 0),
+                "calls": int(d[3] or 0),
+            }
+            for d in daily
+        ],
+        "recent": [
+            {
+                "trace_id": r[0],
+                "model_name": r[1] or "unknown",
+                "tokens": int(r[2] or 0),
+                "cost": float(r[3] or 0),
+                "created_at": r[4].strftime("%Y-%m-%d %H:%M:%S") if r[4] else None,
+            }
+            for r in recent
+        ],
+    }

backend/python/app/api/im_llm.py

@@ -1,232 +1,234 @@
-"""
+"""
-IM Bot 真实 LLM 调用。
+IM Bot 真实 LLM 调用。
-
+
-原实现位于 channels.py（通用频道管理模块），该模块已移除。
+原实现位于 channels.py（通用频道管理模块），该模块已移除。
-为保持 IM Bot（微信机器人等）正常生成回复，将 _call_real_llm 迁移至此独立模块。
+为保持 IM Bot（微信机器人等）正常生成回复，将 _call_real_llm 迁移至此独立模块。
-
+
-行为（对齐 AI 聊天）：
+行为（对齐 AI 聊天）：
-- Issue 7：图像/视频/语音意图优先走平台媒体模型（与 AI 聊天同一套 Auto 路由），
+- Issue 7：图像/视频/语音意图优先走平台媒体模型（与 AI 聊天同一套 Auto 路由），
-  不再对"制作图片"这类请求只回文本。
+  不再对"制作图片"这类请求只回文本。
-- Issue 8：默认 Auto 模型；每轮先自动发现本账号已安装且平台已部署的技能，
+- Issue 8：默认 Auto 模型；每轮先自动发现本账号已安装且平台已部署的技能，
-  多个适用时由模型自行判断选 1 个最优，通过 function calling 执行。
+  多个适用时由模型自行判断选 1 个最优，通过 function calling 执行。
-- 2026-07-15：修复 trust_env=False + proxy 处理，避免容器坏代理导致调用失败；
+- 2026-07-15：修复 trust_env=False + proxy 处理，避免容器坏代理导致调用失败；
-  媒体生成前先经 _optimize_media_prompt 精炼提示词，提升 AGNES 生成质量。
+  媒体生成前先经 _optimize_media_prompt 精炼提示词，提升 AGNES 生成质量。
-"""
+"""
-import asyncio
+import asyncio
-import json
+import json
-import logging
+import logging
-import re as _re
+import re as _re
-from datetime import datetime, timezone, timedelta
+from datetime import datetime, timezone, timedelta
-from typing import Optional
+from typing import Optional
-from urllib.parse import urlparse as _urlparse
+from urllib.parse import urlparse as _urlparse
-
+
-import httpx
+import httpx
-from sqlalchemy.orm import Session
+from sqlalchemy.orm import Session
-
+
-from ..capability_registry import resolve_auto_model
+from ..capability_registry import resolve_auto_model
-from ..models import AIModel, ModelProvider, TokenUsageLog, gen_uuid
+from ..models import AIModel, ModelProvider, TokenUsageLog, gen_uuid
-
+from app.core.observability import get_trace_id
-logger = logging.getLogger(__name__)
+
-
+logger = logging.getLogger(__name__)
-
+
-# 香港出网代理(实测对 AGNES 延迟更低，2026-07-15 用户实测)，与 chat.py 同值。
+
-_HK_PROXY = "http://qyyfw:XHR521yhf@103.242.14.208:11495"
+# 香港出网代理(实测对 AGNES 延迟更低，2026-07-15 用户实测)，与 chat.py 同值。
-
+_HK_PROXY = "http://qyyfw:XHR521yhf@103.242.14.208:11495"
-
+
-def _proxy_for_url(url: str) -> str | None:
+
-    """按目标域名选择是否走代理（与 chat.py 同逻辑）。
+def _proxy_for_url(url: str) -> str | None:
-
+    """按目标域名选择是否走代理（与 chat.py 同逻辑）。
-    2026-07-15 调整：AGNES 改走香港代理(实测延迟更低)，不再直连。
+
-    国内域名(尊重 NO_PROXY)直连，更稳定。
+    2026-07-15 调整：AGNES 改走香港代理(实测延迟更低)，不再直连。
-    """
+    国内域名(尊重 NO_PROXY)直连，更稳定。
-    import os
+    """
-    host = (_urlparse(url).hostname or "").lower()
+    import os
-    if "agnes-ai.com" in host or "agnes-ai.space" in host:
+    host = (_urlparse(url).hostname or "").lower()
-        return _HK_PROXY
+    if "agnes-ai.com" in host or "agnes-ai.space" in host:
-    if "qihuyun.com" in host:
+        return _HK_PROXY
-        return None
+    if "qihuyun.com" in host:
-    _no_proxy = [h.strip().lower() for h in os.environ.get("NO_PROXY", "").split(",") if h.strip()]
+        return None
-    for _np in _no_proxy:
+    _no_proxy = [h.strip().lower() for h in os.environ.get("NO_PROXY", "").split(",") if h.strip()]
-        if host == _np or host.endswith("." + _np) or _np in host:
+    for _np in _no_proxy:
-            return None
+        if host == _np or host.endswith("." + _np) or _np in host:
-    return os.environ.get("HTTPS_PROXY") or os.environ.get("HTTP_PROXY") or "http://172.18.0.1:7890"
+            return None
-
+    return os.environ.get("HTTPS_PROXY") or os.environ.get("HTTP_PROXY") or "http://172.18.0.1:7890"
-
+
-def _run_async(coro, timeout=None):
+
-    """在同步上下文中运行协程，兼容「无事件循环」与「已有事件循环」两种场景。
+def _run_async(coro, timeout=None):
-
+    """在同步上下文中运行协程，兼容「无事件循环」与「已有事件循环」两种场景。
-    IM 个人微信在独立线程中调用（无事件循环）→ asyncio.run；
+
-    IM 多平台 Webhook 可能在 FastAPI 协程内调用（已有事件循环）→ 丢到线程池执行。
+    IM 个人微信在独立线程中调用（无事件循环）→ asyncio.run；
-
+    IM 多平台 Webhook 可能在 FastAPI 协程内调用（已有事件循环）→ 丢到线程池执行。
-    timeout: 可选，秒数；超时抛出 asyncio.TimeoutError（由调用方捕获）。
+
-    """
+    timeout: 可选，秒数；超时抛出 asyncio.TimeoutError（由调用方捕获）。
-    try:
+    """
-        loop = asyncio.get_running_loop()
+    try:
-    except RuntimeError:
+        loop = asyncio.get_running_loop()
-        loop = None
+    except RuntimeError:
-
+        loop = None
-    if timeout is not None:
+
-        async def _timed():
+    if timeout is not None:
-            return await asyncio.wait_for(coro, timeout=timeout)
+        async def _timed():
-        target = _timed()
+            return await asyncio.wait_for(coro, timeout=timeout)
-    else:
+        target = _timed()
-        target = coro
+    else:
-
+        target = coro
-    if loop is not None and loop.is_running():
+
-        import concurrent.futures
+    if loop is not None and loop.is_running():
-        with concurrent.futures.ThreadPoolExecutor(1) as ex:
+        import concurrent.futures
-            return ex.submit(lambda: asyncio.run(target)).result(timeout=(timeout + 10) if timeout else None)
+        with concurrent.futures.ThreadPoolExecutor(1) as ex:
-    return asyncio.run(target)
+            return ex.submit(lambda: asyncio.run(target)).result(timeout=(timeout + 10) if timeout else None)
-
+    return asyncio.run(target)
-
+
-def _log_media_usage(db: Session, user_id: str, ai_model, media_type: str, prompt: str):
+
-    """IM Bot 媒体生成记账：把图片/视频消耗写入 TokenUsageLog，供驾驶舱统计。
+def _log_media_usage(db: Session, user_id: str, ai_model, media_type: str, prompt: str):
-
+    """IM Bot 媒体生成记账：把图片/视频消耗写入 TokenUsageLog，供驾驶舱统计。
-    此前 IM Bot 路径完全不写 TokenUsageLog，导致微信生成的图片/视频在驾驶舱里“查无此项”。
+
-    媒体 API 不返回 token 用量，这里用与 chat.py _generate_media_task 一致的估算。
+    此前 IM Bot 路径完全不写 TokenUsageLog，导致微信生成的图片/视频在驾驶舱里“查无此项”。
-    """
+    媒体 API 不返回 token 用量，这里用与 chat.py _generate_media_task 一致的估算。
-    if not user_id or not ai_model:
+    """
-        return
+    if not user_id or not ai_model:
-    try:
+        return
-        base = 1200 if media_type == "video" else 400
+    try:
-        est = base + (len(prompt or "") // 4)
+        base = 1200 if media_type == "video" else 400
-        db.add(TokenUsageLog(
+        est = base + (len(prompt or "") // 4)
-            id=gen_uuid(),
+        db.add(TokenUsageLog(
-            user_id=user_id,
+            id=gen_uuid(),
-            model_id=ai_model.id,
+            user_id=user_id,
-            model_name=ai_model.name,
+            model_id=ai_model.id,
-            prompt_tokens=est,
+            model_name=ai_model.name,
-            completion_tokens=0,
+            trace_id=get_trace_id(),
-            total_tokens=est,
+            prompt_tokens=est,
-            created_at=datetime.now(timezone(timedelta(hours=8))).replace(tzinfo=None),
+            completion_tokens=0,
-        ))
+            total_tokens=est,
-        db.commit()
+            created_at=datetime.now(timezone(timedelta(hours=8))).replace(tzinfo=None),
-    except Exception as e:
+        ))
-        try:
+        db.commit()
-            db.rollback()
+    except Exception as e:
-        except Exception:
+        try:
-            pass
+            db.rollback()
-        logger.warning(f"[im_llm] 媒体 Token 记账失败(忽略): {e}")
+        except Exception:
-
+            pass
-
+        logger.warning(f"[im_llm] 媒体 Token 记账失败(忽略): {e}")
-def _call_real_llm(db: Session, user=None, prompt: str = "", platform: str = "im", user_id: str = None) -> "str | dict":
+
-    """调用七虎AI 生成回复，供 IM Bot 复用。支持媒体意图路由与已安装技能自动发现。"""
+
-    try:
+def _call_real_llm(db: Session, user=None, prompt: str = "", platform: str = "im", user_id: str = None) -> "str | dict":
-        from app.api.chat import (
+    """调用七虎AI 生成回复，供 IM Bot 复用。支持媒体意图路由与已安装技能自动发现。"""
-            _generate_media,
+    try:
-            detect_media_intent,
+        from app.api.chat import (
-            _discover_installed_skills,
+            _generate_media,
-            _build_system_prompt,
+            detect_media_intent,
-            _execute_skill_tool,
+            _discover_installed_skills,
-        )
+            _build_system_prompt,
-
+            _execute_skill_tool,
-        # ===== 1) 媒体意图路由（Issue 7）=====
+        )
-        intent = detect_media_intent(prompt)
+
-        if intent:
+        # ===== 1) 媒体意图路由（Issue 7）=====
-            ai_model = resolve_auto_model(intent, db)
+        intent = detect_media_intent(prompt)
-            if ai_model:
+        if intent:
-                try:
+            ai_model = resolve_auto_model(intent, db)
-                    result = _run_async(_generate_media(db, ai_model, prompt, user_id), timeout=300)
+            if ai_model:
-                except Exception:
+                try:
-                    # 任何未预期异常(如 AGNES 连接重置)统一兜底为友好提示，
+                    result = _run_async(_generate_media(db, ai_model, prompt, user_id), timeout=300)
-                    # 绝不直接把原始异常(如 "Server disconnected")甩给用户
+                except Exception:
-                    result = "⚠️ 媒体生成暂时失败（连接或服务波动），请稍后重试。"
+                    # 任何未预期异常(如 AGNES 连接重置)统一兜底为友好提示，
-                if result:
+                    # 绝不直接把原始异常(如 "Server disconnected")甩给用户
-                    # 媒体生成成功：返回结构化对象，交由 im_bot_user 在微信内联发送图片/视频
+                    result = "⚠️ 媒体生成暂时失败（连接或服务波动），请稍后重试。"
-                    s = result.strip()
+                if result:
-                    if s.startswith("<img") or s.startswith("<video"):
+                    # 媒体生成成功：返回结构化对象，交由 im_bot_user 在微信内联发送图片/视频
-                        m = _re.search(r'src="([^"]+)"', s)
+                    s = result.strip()
-                        url = m.group(1) if m else ""
+                    if s.startswith("<img") or s.startswith("<video"):
-                        media_type = "image" if s.startswith("<img") else "video"
+                        m = _re.search(r'src="([^"]+)"', s)
-                        if not url:
+                        url = m.group(1) if m else ""
-                            return "（生成完成，但未能提取媒体地址）"
+                        media_type = "image" if s.startswith("<img") else "video"
-                        # IM Bot 路径此前完全不记账 → 补写媒体消耗，驾驶舱才看得到图片/视频数据
+                        if not url:
-                        _log_media_usage(db, user_id, ai_model, media_type, prompt)
+                            return "（生成完成，但未能提取媒体地址）"
-                        return {"__media__": True, "media_type": media_type, "url": url}
+                        # IM Bot 路径此前完全不记账 → 补写媒体消耗，驾驶舱才看得到图片/视频数据
-                    # 媒体生成失败：_generate_media 已返回友好中文（如限频/队列繁忙），
+                        _log_media_usage(db, user_id, ai_model, media_type, prompt)
-                    # 直接透传，绝不把原始提示词/标签/JSON 透传给用户
+                        return {"__media__": True, "media_type": media_type, "url": url}
-                    if s.startswith("⚠️") or s.startswith("（媒体"):
+                    # 媒体生成失败：_generate_media 已返回友好中文（如限频/队列繁忙），
-                        return s
+                    # 直接透传，绝不把原始提示词/标签/JSON 透传给用户
-                    return "（媒体生成未能返回有效内容，请重试）"
+                    if s.startswith("⚠️") or s.startswith("（媒体"):
-
+                        return s
-        # ===== 2) 文本回复 + 技能自动发现（Issue 8）=====
+                    return "（媒体生成未能返回有效内容，请重试）"
-        ai_model = resolve_auto_model("text", db)
+
-        if not ai_model:
+        # ===== 2) 文本回复 + 技能自动发现（Issue 8）=====
-            return "（未配置默认文本模型，无法生成回复）"
+        ai_model = resolve_auto_model("text", db)
-        provider = db.query(ModelProvider).filter(ModelProvider.id == ai_model.provider_id).first()
+        if not ai_model:
-        api_key = ai_model.api_key or (provider.api_key if provider else None)
+            return "（未配置默认文本模型，无法生成回复）"
-        api_url = ai_model.endpoint
+        provider = db.query(ModelProvider).filter(ModelProvider.id == ai_model.provider_id).first()
-        if not api_url and provider and provider.api_base_url:
+        api_key = ai_model.api_key or (provider.api_key if provider else None)
-            api_url = f"{provider.api_base_url.rstrip('/')}/v1/chat/completions"
+        api_url = ai_model.endpoint
-        if not (api_key and api_url):
+        if not api_url and provider and provider.api_base_url:
-            return "（模型未配置 API Key 或地址，无法生成回复）"
+            api_url = f"{provider.api_base_url.rstrip('/')}/v1/chat/completions"
-
+        if not (api_key and api_url):
-        # 自动发现本账号已安装且平台已部署的技能
+            return "（模型未配置 API Key 或地址，无法生成回复）"
-        skills = []
+
-        if user_id:
+        # 自动发现本账号已安装且平台已部署的技能
-            try:
+        skills = []
-                skills = _discover_installed_skills(db, user_id)[:15]
+        if user_id:
-            except Exception:
+            try:
-                skills = []
+                skills = _discover_installed_skills(db, user_id)[:15]
-
+            except Exception:
-        system_prompt, function_definitions = _build_system_prompt(
+                skills = []
-            skills=skills,
+
-            agents=[],
+        system_prompt, function_definitions = _build_system_prompt(
-            kb_context="",
+            skills=skills,
-            user_content=prompt,
+            agents=[],
-            mcp=[],
+            kb_context="",
-            auto_discovered=bool(skills),
+            user_content=prompt,
-        )
+            mcp=[],
-        messages = [
+            auto_discovered=bool(skills),
-            {"role": "system", "content": system_prompt},
+        )
-            {"role": "user", "content": prompt},
+        messages = [
-        ]
+            {"role": "system", "content": system_prompt},
-
+            {"role": "user", "content": prompt},
-        max_rounds = 3
+        ]
-        ai_content = ""
+
-        for _ in range(max_rounds):
+        max_rounds = 3
-            request_body = {"model": ai_model.name, "messages": messages, "max_tokens": 2048}
+        ai_content = ""
-            if function_definitions and skills:
+        for _ in range(max_rounds):
-                request_body["tools"] = [
+            request_body = {"model": ai_model.name, "messages": messages, "max_tokens": 2048}
-                    {"type": "function", "function": fd} for fd in function_definitions
+            if function_definitions and skills:
-                ]
+                request_body["tools"] = [
-                request_body["tool_choice"] = "auto"
+                    {"type": "function", "function": fd} for fd in function_definitions
-            with httpx.Client(
+                ]
-                timeout=ai_model.timeout or 120,
+                request_body["tool_choice"] = "auto"
-                proxy=_proxy_for_url(api_url),
+            with httpx.Client(
-                trust_env=False,
+                timeout=ai_model.timeout or 120,
-            ) as client:
+                proxy=_proxy_for_url(api_url),
-                resp = client.post(
+                trust_env=False,
-                    api_url,
+            ) as client:
-                    headers={"Authorization": f"Bearer {api_key}", "Content-Type": "application/json"},
+                resp = client.post(
-                    json=request_body,
+                    api_url,
-                )
+                    headers={"Authorization": f"Bearer {api_key}", "Content-Type": "application/json"},
-                if resp.status_code != 200:
+                    json=request_body,
-                    return f"（AI 模型调用失败 HTTP {resp.status_code}）"
+                )
-                data = resp.json()
+                if resp.status_code != 200:
-                message = data.get("choices", [{}])[0].get("message", {})
+                    return f"（AI 模型调用失败 HTTP {resp.status_code}）"
-                tool_calls = message.get("tool_calls", [])
+                data = resp.json()
-                if tool_calls and skills:
+                message = data.get("choices", [{}])[0].get("message", {})
-                    messages.append({
+                tool_calls = message.get("tool_calls", [])
-                        "role": "assistant",
+                if tool_calls and skills:
-                        "content": message.get("content") or "",
+                    messages.append({
-                        "tool_calls": tool_calls,
+                        "role": "assistant",
-                    })
+                        "content": message.get("content") or "",
-                    for tc in tool_calls:
+                        "tool_calls": tool_calls,
-                        func_name = tc.get("function", {}).get("name", "")
+                    })
-                        try:
+                    for tc in tool_calls:
-                            func_args = json.loads(tc.get("function", {}).get("arguments", "{}"))
+                        func_name = tc.get("function", {}).get("name", "")
-                        except Exception:
+                        try:
-                            func_args = {"input": tc.get("function", {}).get("arguments", "")}
+                            func_args = json.loads(tc.get("function", {}).get("arguments", "{}"))
-                        tool_result = _execute_skill_tool(db, func_name, func_args, skills, prompt)
+                        except Exception:
-                        messages.append({
+                            func_args = {"input": tc.get("function", {}).get("arguments", "")}
-                            "role": "tool",
+                        tool_result = _execute_skill_tool(db, func_name, func_args, skills, prompt)
-                            "tool_call_id": tc.get("id", "call_1"),
+                        messages.append({
-                            "content": tool_result,
+                            "role": "tool",
-                        })
+                            "tool_call_id": tc.get("id", "call_1"),
-                    continue
+                            "content": tool_result,
-                ai_content = message.get("content", "")
+                        })
-                break
+                    continue
-        return ai_content or "（AI 回复为空）"
+                ai_content = message.get("content", "")
-    except Exception as e:
+                break
-        return f"（AI 回复生成失败：{e}）"
+        return ai_content or "（AI 回复为空）"
+    except Exception as e:
+        return f"（AI 回复生成失败：{e}）"

backend/python/app/api/market.py

@@ -1,3 +1,4 @@
+from app.core.credential import encrypt_secret
 from fastapi import APIRouter, Depends, HTTPException, Query
 from sqlalchemy.orm import Session
 from sqlalchemy import and_, desc, asc, func
@@ -557,7 +558,7 @@ def upload_app(
         is_member_free=req.is_member_free if req.is_member_free is not None else False,
         join_promotion=req.join_promotion if req.join_promotion is not None else False,
         agent_endpoint=req.agent_endpoint,
-        agent_api_key=req.api_key,
+        agent_api_key=encrypt_secret(req.api_key),
         status="published",  # 用户创建的应用直接发布
         created_at=datetime.now(),
         updated_at=datetime.now(),

backend/python/app/core/credential.py

@@ -0,0 +1,105 @@
+# -*- coding: utf-8 -*-
+"""Phase 3.2 - Agent 凭据加解密 (Fernet 对称加密)。
+
+主密钥获取策略 (防竞态):
+- 优先环境变量 AGENT_MASTER_KEY。
+- 否则读写 /app/secrets/agent_master_key:
+  * 部署阶段由 patch 显式生成并落盘 (原子写), 容器重启/提交后稳定存在。
+  * 运行时只读, 文件存在即读取, 绝不重新生成 —— 避免多进程/多请求并发
+    重建密钥导致新旧密文无法互解。
+  * 仅当文件确实不存在时, 才在文件锁保护下生成 (双重检查, 原子替换)。
+- 存储格式: 密文以 "enc:" 前缀标识; 非 "enc:" 视为旧明文 (向后兼容, 解密原样返回)。
+"""
+import os
+import logging
+import fcntl
+from cryptography.fernet import Fernet
+
+logger = logging.getLogger(__name__)
+
+_MASTER_KEY_FILE = "/app/secrets/agent_master_key"
+_fernet_instance = None
+
+
+def _generate_and_persist_key() -> bytes:
+    key = Fernet.generate_key()
+    os.makedirs(os.path.dirname(_MASTER_KEY_FILE), exist_ok=True)
+    tmp = _MASTER_KEY_FILE + ".tmp"
+    with open(tmp, "w") as f:
+        f.write(key.decode())
+        f.flush()
+        os.fsync(f.fileno())
+    try:
+        os.chmod(tmp, 0o600)
+    except Exception:
+        pass
+    os.replace(tmp, _MASTER_KEY_FILE)  # 原子替换, 避免读到半截文件
+    return key
+
+
+def get_master_key() -> bytes:
+    env_key = os.environ.get("AGENT_MASTER_KEY")
+    if env_key:
+        return env_key.encode() if isinstance(env_key, str) else env_key
+    # 运行时只读: 文件已存在则直接读取 (部署阶段已生成)
+    if os.path.exists(_MASTER_KEY_FILE):
+        try:
+            with open(_MASTER_KEY_FILE, "r") as f:
+                k = f.read().strip()
+                if k:
+                    return k.encode()
+        except Exception as e:
+            logger.warning("[credential] 读取主密钥失败: %s" % e)
+    # 文件缺失: 加锁串行生成, 防多进程并发重建
+    lockf = open(_MASTER_KEY_FILE + ".lock", "w")
+    try:
+        fcntl.flock(lockf, fcntl.LOCK_EX)
+        if os.path.exists(_MASTER_KEY_FILE):  # 双重检查
+            with open(_MASTER_KEY_FILE, "r") as f:
+                k = f.read().strip()
+                if k:
+                    return k.encode()
+        return _generate_and_persist_key()
+    finally:
+        fcntl.flock(lockf, fcntl.LOCK_UN)
+        try:
+            lockf.close()
+        except Exception:
+            pass
+
+
+def _fernet() -> Fernet:
+    global _fernet_instance
+    if _fernet_instance is None:
+        _fernet_instance = Fernet(get_master_key())
+    return _fernet_instance
+
+
+def encrypt_secret(plain):
+    if plain is None or plain == "":
+        return None
+    if isinstance(plain, str) and plain.startswith("enc:"):
+        return plain  # 已是密文, 幂等
+    try:
+        return "enc:" + _fernet().encrypt(plain.encode()).decode()
+    except Exception as e:
+        logger.error("[credential] 加密失败: %s" % e)
+        return None
+
+
+def decrypt_secret(cipher):
+    if cipher is None or cipher == "":
+        return None
+    if isinstance(cipher, str) and cipher.startswith("enc:"):
+        try:
+            return _fernet().decrypt(cipher[4:].encode()).decode()
+        except Exception as e:
+            logger.error("[credential] 解密失败(密钥不匹配或数据损坏): %s" % e)
+            return None
+    return cipher  # 旧明文, 向后兼容
+
+
+def mask_secret(plain):
+    if not plain:
+        return ""
+    return ("*" * 8) + plain[-4:]

backend/python/main.py

@@ -1,249 +1,250 @@
-"""
+"""
-Qihu-AIFlow FastAPI 主应用
+Qihu-AIFlow FastAPI 主应用
-完整后端API，监听18080端口，所有接口以 /app 为前缀
+完整后端API，监听18080端口，所有接口以 /app 为前缀
-"""
+"""
-import sys
+import sys
-import os
+import os
-import time
+import time
-import uuid
+import uuid
-import logging
+import logging
-from contextlib import asynccontextmanager
+from contextlib import asynccontextmanager
-from fastapi import FastAPI, Request
+from fastapi import FastAPI, Request
-from fastapi.middleware.cors import CORSMiddleware
+from fastapi.middleware.cors import CORSMiddleware
-from starlette.middleware.base import BaseHTTPMiddleware
+from starlette.middleware.base import BaseHTTPMiddleware
-from datetime import datetime
+from datetime import datetime
-
+
-sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
+sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
-
+
-from app.api import auth, chat, knowledge, market, token_usage, payment, profile, notifications, assets, evolution
+from app.api import auth, chat, knowledge, market, token_usage, payment, profile, notifications, assets, evolution
-from app.casdoor_auth import router as casdoor_router
+from app.casdoor_auth import router as casdoor_router
-from app.api.admin import dashboard, users, models, settings, payment_admin, services, membership_admin, ads, market_admin, logs, skills_admin, agents_admin, knowledge_admin, workflow_admin, storage_admin, automation_admin, mcp_admin, developer_admin, apps_admin, distro_admin, code_exec_admin, privacy_admin, im_bot_admin, promotion_admin, achievement_admin, tenant_admin, billing_admin, analytics_admin
+from app.api.admin import dashboard, users, models, settings, payment_admin, services, membership_admin, ads, market_admin, logs, skills_admin, agents_admin, knowledge_admin, workflow_admin, storage_admin, automation_admin, mcp_admin, developer_admin, apps_admin, distro_admin, code_exec_admin, privacy_admin, im_bot_admin, promotion_admin, achievement_admin, tenant_admin, billing_admin, analytics_admin, observability_admin
-from app.api.im_bot_user import router as im_bot_user_router
+from app.api.im_bot_user import router as im_bot_user_router
-from app.api.im_bot_platform import router as im_bot_platform_router
+from app.api.im_bot_platform import router as im_bot_platform_router
-from app.api.portal import user_portal
+from app.api.portal import user_portal
-from app.api.admin.developer_tools_admin import router as developer_tools_router
+from app.api.admin.developer_tools_admin import router as developer_tools_router
-from app.api.admin.mcp_market_admin import router as mcp_market_router
+from app.api.admin.mcp_market_admin import router as mcp_market_router
-from app.api.admin import asset_admin, achievement_admin
+from app.api.admin import asset_admin, achievement_admin
-from app.config import setup_file_logging, SLOW_REQUEST_THRESHOLD
+from app.config import setup_file_logging, SLOW_REQUEST_THRESHOLD
-from app.core.observability import set_trace_id
+from app.core.observability import set_trace_id
-from app.database import SessionLocal
+from app.database import SessionLocal
-from app.models import OperationLog as OperationLogModel, TokenUsageLog as TokenUsageLogModel
+from app.models import OperationLog as OperationLogModel, TokenUsageLog as TokenUsageLogModel
-
+
-# 导入平台适配器触发注册（AstrBot借鉴优化方案 P1）
+# 导入平台适配器触发注册（AstrBot借鉴优化方案 P1）
-import app.platform_adapters  # noqa: F401 - 触发所有平台适配器装饰器注册
+import app.platform_adapters  # noqa: F401 - 触发所有平台适配器装饰器注册
-
+
-# 初始化文件日志（按天轮转）
+# 初始化文件日志（按天轮转）
-access_logger = setup_file_logging()
+access_logger = setup_file_logging()
-logger = logging.getLogger("aiflow")
+logger = logging.getLogger("aiflow")
-
+
-
+
-class APITrackingMiddleware(BaseHTTPMiddleware):
+class APITrackingMiddleware(BaseHTTPMiddleware):
-    """API调用统计中间件 - 记录请求耗时，标记慢请求"""
+    """API调用统计中间件 - 记录请求耗时，标记慢请求"""
-
+
-    async def dispatch(self, request: Request, call_next):
+    async def dispatch(self, request: Request, call_next):
-        request_id = str(uuid.uuid4())
+        request_id = str(uuid.uuid4())
-        set_trace_id(request_id)
+        set_trace_id(request_id)
-        start_time = time.time()
+        start_time = time.time()
-        path = request.url.path
+        path = request.url.path
-        method = request.method
+        method = request.method
-
+
-        # 跳过健康检查和静态资源
+        # 跳过健康检查和静态资源
-        skip_paths = ["/app/api/health", "/favicon.ico"]
+        skip_paths = ["/app/api/health", "/favicon.ico"]
-        should_skip = any(path.startswith(p) for p in skip_paths)
+        should_skip = any(path.startswith(p) for p in skip_paths)
-
+
-        try:
+        try:
-            response = await call_next(request)
+            response = await call_next(request)
-            elapsed = time.time() - start_time
+            elapsed = time.time() - start_time
-            status_code = response.status_code
+            status_code = response.status_code
-            response.headers["X-Trace-Id"] = request_id
+            response.headers["X-Trace-Id"] = request_id
-
+
-            if not should_skip:
+            if not should_skip:
-                access_logger.info(
+                access_logger.info(
-                    f"[{request_id}] {method} {path} -> {status_code} ({elapsed:.3f}s)"
+                    f"[{request_id}] {method} {path} -> {status_code} ({elapsed:.3f}s)"
-                )
+                )
-
+
-                # 异步记录API调用统计
+                # 异步记录API调用统计
-                try:
+                try:
-                    db = SessionLocal()
+                    db = SessionLocal()
-                    try:
+                    try:
-                        _record_api_call(db, method, path, status_code, elapsed)
+                        _record_api_call(db, method, path, status_code, elapsed)
-                    finally:
+                    finally:
-                        db.close()
+                        db.close()
-                except Exception as e:
+                except Exception as e:
-                    logger.warning(f"API统计记录失败: {e}")
+                    logger.warning(f"API统计记录失败: {e}")
-
+
-            return response
+            return response
-        except Exception as e:
+        except Exception as e:
-            elapsed = time.time() - start_time
+            elapsed = time.time() - start_time
-            if not should_skip:
+            if not should_skip:
-                access_logger.info(
+                access_logger.info(
-                    f"[{request_id}] {method} {path} -> ERROR ({elapsed:.3f}s): {str(e)}"
+                    f"[{request_id}] {method} {path} -> ERROR ({elapsed:.3f}s): {str(e)}"
-                )
+                )
-            raise
+            raise
-
+
-    async def __call__(self, scope, receive, send):
+    async def __call__(self, scope, receive, send):
-        if scope["type"] != "http":
+        if scope["type"] != "http":
-            await self.app(scope, receive, send)
+            await self.app(scope, receive, send)
-            return
+            return
-        await super().__call__(scope, receive, send)
+        await super().__call__(scope, receive, send)
-
+
-
+
-def _record_api_call(db, method: str, path: str, status_code: int, elapsed: float):
+def _record_api_call(db, method: str, path: str, status_code: int, elapsed: float):
-    """记录API调用到数据库统计表"""
+    """记录API调用到数据库统计表"""
-    # 简化路径以减少基数（去掉动态ID）
+    # 简化路径以减少基数（去掉动态ID）
-    parts = path.split("/")
+    parts = path.split("/")
-    simplified_parts = []
+    simplified_parts = []
-    for part in parts:
+    for part in parts:
-        # 将UUID样式的路径段替换为{id}
+        # 将UUID样式的路径段替换为{id}
-        if len(part) == 36 and part.count("-") == 4:
+        if len(part) == 36 and part.count("-") == 4:
-            simplified_parts.append("{id}")
+            simplified_parts.append("{id}")
-        # 将纯数字路径段替换为{id}
+        # 将纯数字路径段替换为{id}
-        elif part.isdigit():
+        elif part.isdigit():
-            simplified_parts.append("{id}")
+            simplified_parts.append("{id}")
-        else:
+        else:
-            simplified_parts.append(part)
+            simplified_parts.append(part)
-    simplified_path = "/".join(simplified_parts)
+    simplified_path = "/".join(simplified_parts)
-
+
-    # 统计记录通过数据库实现，简化版记录到日志
+    # 统计记录通过数据库实现，简化版记录到日志
-    is_error = status_code >= 400
+    is_error = status_code >= 400
-    is_slow = elapsed >= SLOW_REQUEST_THRESHOLD
+    is_slow = elapsed >= SLOW_REQUEST_THRESHOLD
-
+
-    if is_slow:
+    if is_slow:
-        logger.warning(
+        logger.warning(
-            f"慢请求: {method} {simplified_path} -> {status_code} ({elapsed:.3f}s, 阈值: {SLOW_REQUEST_THRESHOLD}s)"
+            f"慢请求: {method} {simplified_path} -> {status_code} ({elapsed:.3f}s, 阈值: {SLOW_REQUEST_THRESHOLD}s)"
-        )
+        )
-
+
-
+
-@asynccontextmanager
+@asynccontextmanager
-async def lifespan(app: FastAPI):
+async def lifespan(app: FastAPI):
-    logger.info("Qihu-AIFlow v2.0.0 启动中...")
+    logger.info("Qihu-AIFlow v2.0.0 启动中...")
-
+
-    # 启动后台 Evolution Pipeline（知识库图谱已存在的用户配置自动恢复运行）
+    # 启动后台 Evolution Pipeline（知识库图谱已存在的用户配置自动恢复运行）
-    try:
+    try:
-        from app.services.evolution_service import EvolutionWatcherManager
+        from app.services.evolution_service import EvolutionWatcherManager
-        from app.models import UserEvolutionConfig
+        from app.models import UserEvolutionConfig
-        db = SessionLocal()
+        db = SessionLocal()
-        try:
+        try:
-            configs = db.query(UserEvolutionConfig).filter(
+            configs = db.query(UserEvolutionConfig).filter(
-                UserEvolutionConfig.watcher_status == "running"
+                UserEvolutionConfig.watcher_status == "running"
-            ).all()
+            ).all()
-            if configs:
+            if configs:
-                watcher = EvolutionWatcherManager()
+                watcher = EvolutionWatcherManager()
-                for cfg in configs:
+                for cfg in configs:
-                    try:
+                    try:
-                        watcher.start_user_evolution(cfg.user_id, lambda: SessionLocal())
+                        watcher.start_user_evolution(cfg.user_id, lambda: SessionLocal())
-                        logger.info(f"[Evolution] 恢复用户 {cfg.user_id} 的进化Pipeline")
+                        logger.info(f"[Evolution] 恢复用户 {cfg.user_id} 的进化Pipeline")
-                    except Exception as e:
+                    except Exception as e:
-                        logger.warning(f"[Evolution] 恢复用户 {cfg.user_id} 失败: {e}")
+                        logger.warning(f"[Evolution] 恢复用户 {cfg.user_id} 失败: {e}")
-                logger.info(f"[Evolution] 已恢复 {len(configs)} 个用户的进化Pipeline")
+                logger.info(f"[Evolution] 已恢复 {len(configs)} 个用户的进化Pipeline")
-            else:
+            else:
-                logger.info("[Evolution] 无待恢复的进化配置")
+                logger.info("[Evolution] 无待恢复的进化配置")
-        finally:
+        finally:
-            db.close()
+            db.close()
-    except Exception as e:
+    except Exception as e:
-        logger.warning(f"[Evolution] Pipeline自动启动异常(不影响正常服务): {e}")
+        logger.warning(f"[Evolution] Pipeline自动启动异常(不影响正常服务): {e}")
-
+
-    # 启动Redis事件总线
+    # 启动Redis事件总线
-    try:
+    try:
-        from app.event_bus import get_event_bus
+        from app.event_bus import get_event_bus
-        event_bus = get_event_bus()
+        event_bus = get_event_bus()
-        event_bus.start(num_consumers=2)
+        event_bus.start(num_consumers=2)
-        logger.info("[EventBus] Redis事件总线已启动")
+        logger.info("[EventBus] Redis事件总线已启动")
-    except Exception as e:
+    except Exception as e:
-        logger.warning(f"[EventBus] 启动失败(不影响正常服务): {e}")
+        logger.warning(f"[EventBus] 启动失败(不影响正常服务): {e}")
-
+
-    logger.info("Qihu-AIFlow v2.0.0 启动完成")
+    logger.info("Qihu-AIFlow v2.0.0 启动完成")
-
+
-    yield
+    yield
-
+
-    # 停止Redis事件总线
+    # 停止Redis事件总线
-    try:
+    try:
-        from app.event_bus import get_event_bus
+        from app.event_bus import get_event_bus
-        get_event_bus().stop()
+        get_event_bus().stop()
-        logger.info("[EventBus] Redis事件总线已停止")
+        logger.info("[EventBus] Redis事件总线已停止")
-    except Exception:
+    except Exception:
-        pass
+        pass
-
+
-    # 优雅关闭：停止所有 Evolution Pipeline
+    # 优雅关闭：停止所有 Evolution Pipeline
-    try:
+    try:
-        from app.services.evolution_service import EvolutionWatcherManager
+        from app.services.evolution_service import EvolutionWatcherManager
-        EvolutionWatcherManager().shutdown_all()
+        EvolutionWatcherManager().shutdown_all()
-        logger.info("[Evolution] 所有Pipeline已停止")
+        logger.info("[Evolution] 所有Pipeline已停止")
-    except Exception:
+    except Exception:
-        pass
+        pass
-
+
-    logger.info("Qihu-AIFlow 正在关闭...")
+    logger.info("Qihu-AIFlow 正在关闭...")
-
+
-
+
-app = FastAPI(
+app = FastAPI(
-    title="Qihu-AIFlow - 智能自动化PaaS平台",
+    title="Qihu-AIFlow - 智能自动化PaaS平台",
-    version="1.0.0",
+    version="1.0.0",
-    lifespan=lifespan,
+    lifespan=lifespan,
-)
+)
-
+
-# API调用追踪中间件
+# API调用追踪中间件
-app.add_middleware(APITrackingMiddleware)
+app.add_middleware(APITrackingMiddleware)
-
+
-# CORS配置
+# CORS配置
-app.add_middleware(
+app.add_middleware(
-    CORSMiddleware,
+    CORSMiddleware,
-    allow_origins=["*"],
+    allow_origins=["*"],
-    allow_credentials=True,
+    allow_credentials=True,
-    allow_methods=["*"],
+    allow_methods=["*"],
-    allow_headers=["*"],
+    allow_headers=["*"],
-)
+)
-
+
-# 前台 API
+# 前台 API
-app.include_router(auth.router, prefix="/app/api/auth", tags=["认证"])
+app.include_router(auth.router, prefix="/app/api/auth", tags=["认证"])
-app.include_router(chat.router, prefix="/app/api/chat", tags=["AI聊天"])
+app.include_router(chat.router, prefix="/app/api/chat", tags=["AI聊天"])
-app.include_router(knowledge.router, prefix="/app/api/knowledge", tags=["知识库"])
+app.include_router(knowledge.router, prefix="/app/api/knowledge", tags=["知识库"])
-app.include_router(market.router, prefix="/app/api/market", tags=["应用市场"])
+app.include_router(market.router, prefix="/app/api/market", tags=["应用市场"])
-app.include_router(token_usage.router, prefix="/app/api/token", tags=["Token驾驶舱"])
+app.include_router(token_usage.router, prefix="/app/api/token", tags=["Token驾驶舱"])
-app.include_router(payment.router, prefix="/app/api/payment", tags=["付费中心"])
+app.include_router(payment.router, prefix="/app/api/payment", tags=["付费中心"])
-app.include_router(profile.router, prefix="/app/api/profile", tags=["个人中心"])
+app.include_router(profile.router, prefix="/app/api/profile", tags=["个人中心"])
-app.include_router(notifications.router, prefix="/app/api/notifications", tags=["消息通知"])
+app.include_router(notifications.router, prefix="/app/api/notifications", tags=["消息通知"])
-app.include_router(assets.router, prefix="/app/api/assets", tags=["资产管理"])
+app.include_router(assets.router, prefix="/app/api/assets", tags=["资产管理"])
-app.include_router(evolution.router, prefix="/app/api/evolution", tags=["AI自进化"])
+app.include_router(evolution.router, prefix="/app/api/evolution", tags=["AI自进化"])
-
+
-# 后台 API
+# 后台 API
-app.include_router(dashboard.router, prefix="/app/api/admin/dashboard", tags=["后台-仪表盘"])
+app.include_router(dashboard.router, prefix="/app/api/admin/dashboard", tags=["后台-仪表盘"])
-app.include_router(users.router, prefix="/app/api/admin/users", tags=["后台-用户管理"])
+app.include_router(users.router, prefix="/app/api/admin/users", tags=["后台-用户管理"])
-app.include_router(models.router, prefix="/app/api/admin/models", tags=["后台-模型管理"])
+app.include_router(models.router, prefix="/app/api/admin/models", tags=["后台-模型管理"])
-app.include_router(settings.router, prefix="/app/api/admin/settings", tags=["后台-网站设置"])
+app.include_router(settings.router, prefix="/app/api/admin/settings", tags=["后台-网站设置"])
-app.include_router(payment_admin.router, prefix="/app/api/admin/payment", tags=["后台-支付配置"])
+app.include_router(payment_admin.router, prefix="/app/api/admin/payment", tags=["后台-支付配置"])
-app.include_router(services.router, prefix="/app/api/admin/services", tags=["后台-增值服务"])
+app.include_router(services.router, prefix="/app/api/admin/services", tags=["后台-增值服务"])
-app.include_router(membership_admin.router, prefix="/app/api/admin/membership", tags=["后台-会员管理"])
+app.include_router(membership_admin.router, prefix="/app/api/admin/membership", tags=["后台-会员管理"])
-app.include_router(ads.router, prefix="/app/api/admin/ads", tags=["后台-广告管理"])
+app.include_router(ads.router, prefix="/app/api/admin/ads", tags=["后台-广告管理"])
-app.include_router(market_admin.router, prefix="/app/api/admin/market", tags=["后台-应用审核"])
+app.include_router(market_admin.router, prefix="/app/api/admin/market", tags=["后台-应用审核"])
-app.include_router(logs.router, prefix="/app/api/admin/logs", tags=["后台-日志风控"])
+app.include_router(logs.router, prefix="/app/api/admin/logs", tags=["后台-日志风控"])
-
+
-app.include_router(skills_admin.router, prefix="/app/api/admin/skills", tags=["后台-技能管理"])
+app.include_router(skills_admin.router, prefix="/app/api/admin/skills", tags=["后台-技能管理"])
-app.include_router(agents_admin.router, prefix="/app/api/admin/agents", tags=["后台-Agent管理"])
+app.include_router(agents_admin.router, prefix="/app/api/admin/agents", tags=["后台-Agent管理"])
-app.include_router(knowledge_admin.router, prefix="/app/api/admin/knowledge", tags=["后台-知识库管理"])
+app.include_router(knowledge_admin.router, prefix="/app/api/admin/knowledge", tags=["后台-知识库管理"])
-app.include_router(workflow_admin.router, prefix="/app/api/admin/workflows", tags=["后台-工作流编排"])
+app.include_router(workflow_admin.router, prefix="/app/api/admin/workflows", tags=["后台-工作流编排"])
-app.include_router(asset_admin.router, prefix="/app/api/admin/assets", tags=["后台-资产管理"])
+app.include_router(asset_admin.router, prefix="/app/api/admin/assets", tags=["后台-资产管理"])
-app.include_router(storage_admin.router, prefix="/app/api/admin/storage", tags=["后台-存储配置"])
+app.include_router(storage_admin.router, prefix="/app/api/admin/storage", tags=["后台-存储配置"])
-app.include_router(automation_admin.router, prefix="/app/api/admin/automation", tags=["后台-自动化任务"])
+app.include_router(automation_admin.router, prefix="/app/api/admin/automation", tags=["后台-自动化任务"])
-app.include_router(mcp_admin.router, prefix="/app/api/admin/mcp", tags=["后台-MCP服务"])
+app.include_router(mcp_admin.router, prefix="/app/api/admin/mcp", tags=["后台-MCP服务"])
-app.include_router(developer_admin.router, prefix="/app/api/admin/developer", tags=["后台-开发者API"])
+app.include_router(developer_admin.router, prefix="/app/api/admin/developer", tags=["后台-开发者API"])
-app.include_router(developer_tools_router, prefix="/app/api/admin/developer-tools", tags=["dev-tools"])
+app.include_router(developer_tools_router, prefix="/app/api/admin/developer-tools", tags=["dev-tools"])
-app.include_router(apps_admin.router, prefix="/app/api/admin/apps", tags=["admin-ai-apps"])
+app.include_router(apps_admin.router, prefix="/app/api/admin/apps", tags=["admin-ai-apps"])
-app.include_router(mcp_market_router, prefix="/app/api/admin/mcp-market", tags=["mcp-market"])
+app.include_router(mcp_market_router, prefix="/app/api/admin/mcp-market", tags=["mcp-market"])
-app.include_router(code_exec_admin.router, prefix="/app/api/admin/code-exec", tags=["code-exec"])
+app.include_router(code_exec_admin.router, prefix="/app/api/admin/code-exec", tags=["code-exec"])
-app.include_router(distro_admin.router, prefix="/app/api/admin/distributions", tags=["distributions"])
+app.include_router(distro_admin.router, prefix="/app/api/admin/distributions", tags=["distributions"])
-app.include_router(privacy_admin.router, prefix="/app/api/admin/privacy", tags=["privacy"])
+app.include_router(privacy_admin.router, prefix="/app/api/admin/privacy", tags=["privacy"])
-app.include_router(im_bot_admin.router, prefix="/app/api/admin/im-bot", tags=["im-bot"])
+app.include_router(im_bot_admin.router, prefix="/app/api/admin/im-bot", tags=["im-bot"])
-app.include_router(im_bot_user_router, prefix="/app/api/im/wechat", tags=["im-wechat-user"])
+app.include_router(im_bot_user_router, prefix="/app/api/im/wechat", tags=["im-wechat-user"])
-app.include_router(im_bot_platform_router, prefix="/app/api/im/platform", tags=["im-platform-user"])
+app.include_router(im_bot_platform_router, prefix="/app/api/im/platform", tags=["im-platform-user"])
-app.include_router(promotion_admin.router, prefix="/app/api/admin/promotion", tags=["promotion"])
+app.include_router(promotion_admin.router, prefix="/app/api/admin/promotion", tags=["promotion"])
-app.include_router(tenant_admin.router, prefix="/app/api/admin/tenant", tags=["tenant"])
+app.include_router(tenant_admin.router, prefix="/app/api/admin/tenant", tags=["tenant"])
-app.include_router(billing_admin.router, prefix="/app/api/admin/billing", tags=["billing"])
+app.include_router(billing_admin.router, prefix="/app/api/admin/billing", tags=["billing"])
-app.include_router(analytics_admin.router, prefix="/app/api/admin/analytics", tags=["analytics"])
+app.include_router(analytics_admin.router, prefix="/app/api/admin/analytics", tags=["analytics"])
-app.include_router(user_portal.router, prefix="/app/api/portal", tags=["portal"])
+app.include_router(observability_admin.router, prefix="/app/api/admin/observability", tags=["后台-调用可观测"])
-app.include_router(achievement_admin.router, prefix="/app/api/admin/achievement", tags=["achievement"])
+app.include_router(user_portal.router, prefix="/app/api/portal", tags=["portal"])
-app.include_router(casdoor_router, prefix="/app/api/auth", tags=["Casdoor SSO"])
+app.include_router(achievement_admin.router, prefix="/app/api/admin/achievement", tags=["achievement"])
-
+app.include_router(casdoor_router, prefix="/app/api/auth", tags=["Casdoor SSO"])
-
+
-@app.get("/app/api/health")
+
-async def health_check():
+@app.get("/app/api/health")
-    return {"status": "ok", "service": "Qihu-AIFlow"}
+async def health_check():
+    return {"status": "ok", "service": "Qihu-AIFlow"}

frontend/src/App.tsx

@@ -1,175 +1,177 @@
-import React, { useState, useEffect, Suspense } from 'react';
+import React, { useState, useEffect, Suspense } from 'react';
-import { Routes, Route, Navigate } from 'react-router-dom';
+import { Routes, Route, Navigate } from 'react-router-dom';
-import type { User } from '@/types';
+import type { User } from '@/types';
-import { AuthContext, AuthContextType } from '@/contexts/AuthContext';
+import { AuthContext, AuthContextType } from '@/contexts/AuthContext';
-import { authAPI } from '@/api';
+import { authAPI } from '@/api';
-
+
-// Layouts（保留为即时加载，构成应用外壳）
+// Layouts（保留为即时加载，构成应用外壳）
-import FrontLayout from '@/components/layout/FrontLayout';
+import FrontLayout from '@/components/layout/FrontLayout';
-import AdminLayout from '@/components/layout/AdminLayout';
+import AdminLayout from '@/components/layout/AdminLayout';
-
+
-// 路由级代码分割：每个页面独立打包成 chunk，首屏只加载外壳与公共依赖，
+// 路由级代码分割：每个页面独立打包成 chunk，首屏只加载外壳与公共依赖，
-// 访问具体页面时才按需加载对应 chunk，显著加快首屏渲染与路由切换速度。
+// 访问具体页面时才按需加载对应 chunk，显著加快首屏渲染与路由切换速度。
-const LandingPage = React.lazy(() => import('@/pages/front/LandingPage'));
+const LandingPage = React.lazy(() => import('@/pages/front/LandingPage'));
-const LoginPage = React.lazy(() => import('@/pages/front/LoginPage'));
+const LoginPage = React.lazy(() => import('@/pages/front/LoginPage'));
-const ChatPage = React.lazy(() => import('@/pages/front/ChatPage'));
+const ChatPage = React.lazy(() => import('@/pages/front/ChatPage'));
-const KnowledgePage = React.lazy(() => import('@/pages/front/KnowledgePage'));
+const KnowledgePage = React.lazy(() => import('@/pages/front/KnowledgePage'));
-const MarketPage = React.lazy(() => import('@/pages/front/MarketPage'));
+const MarketPage = React.lazy(() => import('@/pages/front/MarketPage'));
-const TokenDashboardPage = React.lazy(() => import('@/pages/front/TokenDashboardPage'));
+const TokenDashboardPage = React.lazy(() => import('@/pages/front/TokenDashboardPage'));
-const PricingPage = React.lazy(() => import('@/pages/front/PricingPage'));
+const PricingPage = React.lazy(() => import('@/pages/front/PricingPage'));
-const ProfilePage = React.lazy(() => import('@/pages/front/ProfilePage'));
+const ProfilePage = React.lazy(() => import('@/pages/front/ProfilePage'));
-const NotificationPage = React.lazy(() => import('@/pages/front/NotificationPage'));
+const NotificationPage = React.lazy(() => import('@/pages/front/NotificationPage'));
-const AssetsPage = React.lazy(() => import('@/pages/front/AssetsPage'));
+const AssetsPage = React.lazy(() => import('@/pages/front/AssetsPage'));
-const NovelPreviewPage = React.lazy(() => import('@/pages/front/NovelPreviewPage'));
+const NovelPreviewPage = React.lazy(() => import('@/pages/front/NovelPreviewPage'));
-const EvolutionDashboard = React.lazy(() => import('@/pages/front/EvolutionDashboard'));
+const EvolutionDashboard = React.lazy(() => import('@/pages/front/EvolutionDashboard'));
-
+
-const AdminDashboard = React.lazy(() => import('@/pages/admin/Dashboard'));
+const AdminDashboard = React.lazy(() => import('@/pages/admin/Dashboard'));
-const AdminUsers = React.lazy(() => import('@/pages/admin/Users'));
+const AdminUsers = React.lazy(() => import('@/pages/admin/Users'));
-const AdminModels = React.lazy(() => import('@/pages/admin/Models'));
+const AdminModels = React.lazy(() => import('@/pages/admin/Models'));
-const AdminSiteSettings = React.lazy(() => import('@/pages/admin/SiteSettings'));
+const AdminSiteSettings = React.lazy(() => import('@/pages/admin/SiteSettings'));
-const AdminSmsConfig = React.lazy(() => import('@/pages/admin/SmsConfig'));
+const AdminSmsConfig = React.lazy(() => import('@/pages/admin/SmsConfig'));
-const AdminPayment = React.lazy(() => import('@/pages/admin/Payment'));
+const AdminPayment = React.lazy(() => import('@/pages/admin/Payment'));
-const AdminServices = React.lazy(() => import('@/pages/admin/Services'));
+const AdminServices = React.lazy(() => import('@/pages/admin/Services'));
-const AdminMembership = React.lazy(() => import('@/pages/admin/Membership'));
+const AdminMembership = React.lazy(() => import('@/pages/admin/Membership'));
-const AdminAds = React.lazy(() => import('@/pages/admin/Ads'));
+const AdminAds = React.lazy(() => import('@/pages/admin/Ads'));
-const AdminMarket = React.lazy(() => import('@/pages/admin/Market'));
+const AdminMarket = React.lazy(() => import('@/pages/admin/Market'));
-const AdminLogs = React.lazy(() => import('@/pages/admin/Logs'));
+const AdminLogs = React.lazy(() => import('@/pages/admin/Logs'));
-const AdminSkills = React.lazy(() => import('@/pages/admin/Skills'));
+const AdminSkills = React.lazy(() => import('@/pages/admin/Skills'));
-const AdminAgents = React.lazy(() => import('@/pages/admin/Agents'));
+const AdminAgents = React.lazy(() => import('@/pages/admin/Agents'));
-const AdminCodeExec = React.lazy(() => import('@/pages/admin/CodeExec'));
+const AdminCodeExec = React.lazy(() => import('@/pages/admin/CodeExec'));
-const DistributionBuilder = React.lazy(() => import('@/pages/admin/DistributionBuilder'));
+const DistributionBuilder = React.lazy(() => import('@/pages/admin/DistributionBuilder'));
-const ImBots = React.lazy(() => import('@/pages/admin/ImBots'));
+const ImBots = React.lazy(() => import('@/pages/admin/ImBots'));
-const PrivacySettings = React.lazy(() => import('@/pages/admin/PrivacySettings'));
+const PrivacySettings = React.lazy(() => import('@/pages/admin/PrivacySettings'));
-const Promotion = React.lazy(() => import('@/pages/admin/Promotion'));
+const Promotion = React.lazy(() => import('@/pages/admin/Promotion'));
-const Achievement = React.lazy(() => import('@/pages/admin/Achievement'));
+const Achievement = React.lazy(() => import('@/pages/admin/Achievement'));
-const Tenant = React.lazy(() => import('@/pages/admin/Tenant'));
+const Tenant = React.lazy(() => import('@/pages/admin/Tenant'));
-const Billing = React.lazy(() => import('@/pages/admin/Billing'));
+const Billing = React.lazy(() => import('@/pages/admin/Billing'));
-const Analytics = React.lazy(() => import('@/pages/admin/Analytics'));
+const Analytics = React.lazy(() => import('@/pages/admin/Analytics'));
-const AdminKnowledge = React.lazy(() => import('@/pages/admin/Knowledge'));
+const Observability = React.lazy(() => import('@/pages/admin/Observability'));
-const AdminWorkflow = React.lazy(() => import('@/pages/admin/Workflow'));
+const AdminKnowledge = React.lazy(() => import('@/pages/admin/Knowledge'));
-const AdminStorage = React.lazy(() => import('@/pages/admin/Storage'));
+const AdminWorkflow = React.lazy(() => import('@/pages/admin/Workflow'));
-const AdminDeveloper = React.lazy(() => import('@/pages/admin/Developer'));
+const AdminStorage = React.lazy(() => import('@/pages/admin/Storage'));
-const AdminDeveloperTools = React.lazy(() => import('@/pages/admin/DeveloperTools'));
+const AdminDeveloper = React.lazy(() => import('@/pages/admin/Developer'));
-const AdminAutomation = React.lazy(() => import('@/pages/admin/Automation'));
+const AdminDeveloperTools = React.lazy(() => import('@/pages/admin/DeveloperTools'));
-const AdminMcp = React.lazy(() => import('@/pages/admin/Mcp'));
+const AdminAutomation = React.lazy(() => import('@/pages/admin/Automation'));
-const AdminApps = React.lazy(() => import('@/pages/admin/Apps'));
+const AdminMcp = React.lazy(() => import('@/pages/admin/Mcp'));
-const AssetCenter = React.lazy(() => import('@/pages/admin/AssetCenter'));
+const AdminApps = React.lazy(() => import('@/pages/admin/Apps'));
-const UserPortal = React.lazy(() => import('@/pages/UserPortal'));
+const AssetCenter = React.lazy(() => import('@/pages/admin/AssetCenter'));
-const WechatBot = React.lazy(() => import('@/pages/front/WechatBot'));
+const UserPortal = React.lazy(() => import('@/pages/UserPortal'));
-const ImBotHub = React.lazy(() => import('@/pages/front/ImBotHub'));
+const WechatBot = React.lazy(() => import('@/pages/front/WechatBot'));
-const AppServices = React.lazy(() => import('@/pages/front/AppServices'));
+const ImBotHub = React.lazy(() => import('@/pages/front/ImBotHub'));
-
+const AppServices = React.lazy(() => import('@/pages/front/AppServices'));
-const pageFallback = <div className="loading-screen">加载中...</div>;
+
-
+const pageFallback = <div className="loading-screen">加载中...</div>;
-const App: React.FC = () => {
+
-  const [user, setUser] = useState<User | null>(null);
+const App: React.FC = () => {
-  const [loading, setLoading] = useState(true);
+  const [user, setUser] = useState<User | null>(null);
-
+  const [loading, setLoading] = useState(true);
-  // 初始化：从localStorage恢复登录状态
+
-  useEffect(() => {
+  // 初始化：从localStorage恢复登录状态
-    const token = localStorage.getItem('aiflow_token');
+  useEffect(() => {
-    const cachedUser = localStorage.getItem('aiflow_user');
+    const token = localStorage.getItem('aiflow_token');
-    if (token && cachedUser) {
+    const cachedUser = localStorage.getItem('aiflow_user');
-      try {
+    if (token && cachedUser) {
-        setUser(JSON.parse(cachedUser));
+      try {
-      } catch {
+        setUser(JSON.parse(cachedUser));
-        localStorage.removeItem('aiflow_token');
+      } catch {
-        localStorage.removeItem('aiflow_user');
+        localStorage.removeItem('aiflow_token');
-      }
+        localStorage.removeItem('aiflow_user');
-    }
+      }
-    setLoading(false);
+    }
-  }, []);
+    setLoading(false);
-
+  }, []);
-  const login = (u: User) => {
+
-    setUser(u);
+  const login = (u: User) => {
-    localStorage.setItem('aiflow_user', JSON.stringify(u));
+    setUser(u);
-  };
+    localStorage.setItem('aiflow_user', JSON.stringify(u));
-  const logout = () => {
+  };
-    setUser(null);
+  const logout = () => {
-    localStorage.removeItem('aiflow_token');
+    setUser(null);
-    localStorage.removeItem('aiflow_user');
+    localStorage.removeItem('aiflow_token');
-  };
+    localStorage.removeItem('aiflow_user');
-  const isAdmin = user?.role === 'admin';
+  };
-
+  const isAdmin = user?.role === 'admin';
-  if (loading) {
+
-    return <div className="loading-screen">加载中...</div>;
+  if (loading) {
-  }
+    return <div className="loading-screen">加载中...</div>;
-
+  }
-  return (
+
-    <AuthContext.Provider value={{ user, login, logout, isAdmin }}>
+  return (
-      <Suspense fallback={pageFallback}>
+    <AuthContext.Provider value={{ user, login, logout, isAdmin }}>
-        <Routes>
+      <Suspense fallback={pageFallback}>
-          {/* Login */}
+        <Routes>
-          <Route path="/login" element={
+          {/* Login */}
-            user ? (isAdmin ? <Navigate to="/admin" /> : <Navigate to="/chat" />) : <LoginPage />
+          <Route path="/login" element={
-          } />
+            user ? (isAdmin ? <Navigate to="/admin" /> : <Navigate to="/chat" />) : <LoginPage />
-
+          } />
-          {/* Root - Landing for guests, redirect for authenticated users */}
+
-          <Route path="/" element={
+          {/* Root - Landing for guests, redirect for authenticated users */}
-            user ? (isAdmin ? <Navigate to="/admin" /> : <Navigate to="/chat" />) : <LandingPage />
+          <Route path="/" element={
-          } />
+            user ? (isAdmin ? <Navigate to="/admin" /> : <Navigate to="/chat" />) : <LandingPage />
-
+          } />
-          {/* Front Routes (authenticated only) */}
+
-          <Route path="/" element={<FrontLayout />}>
+          {/* Front Routes (authenticated only) */}
-            <Route path="chat" element={<ChatPage />} />
+          <Route path="/" element={<FrontLayout />}>
-            <Route path="chat/:id" element={<ChatPage />} />
+            <Route path="chat" element={<ChatPage />} />
-            <Route path="knowledge" element={<KnowledgePage />} />
+            <Route path="chat/:id" element={<ChatPage />} />
-            <Route path="market" element={<MarketPage />} />
+            <Route path="knowledge" element={<KnowledgePage />} />
-            <Route path="token" element={<TokenDashboardPage />} />
+            <Route path="market" element={<MarketPage />} />
-            <Route path="pricing" element={<PricingPage />} />
+            <Route path="token" element={<TokenDashboardPage />} />
-            <Route path="profile" element={<ProfilePage />} />
+            <Route path="pricing" element={<PricingPage />} />
-            <Route path="notifications" element={<NotificationPage />} />
+            <Route path="profile" element={<ProfilePage />} />
-            <Route path="assets" element={<AssetsPage />} />
+            <Route path="notifications" element={<NotificationPage />} />
-            <Route path="assets/novel/:id" element={<NovelPreviewPage />} />
+            <Route path="assets" element={<AssetsPage />} />
-            <Route path="evolution" element={<EvolutionDashboard />} />
+            <Route path="assets/novel/:id" element={<NovelPreviewPage />} />
-            <Route path="wechat-bot" element={<WechatBot />} />
+            <Route path="evolution" element={<EvolutionDashboard />} />
-            <Route path="im-bots" element={<ImBotHub />} />
+            <Route path="wechat-bot" element={<WechatBot />} />
-            <Route path="app-services" element={<AppServices />} />
+            <Route path="im-bots" element={<ImBotHub />} />
-          </Route>
+            <Route path="app-services" element={<AppServices />} />
-
+          </Route>
-          {/* Admin Routes */}
+
-          <Route path="/admin" element={<AdminLayout />}>
+          {/* Admin Routes */}
-            <Route index element={<AdminDashboard />} />
+          <Route path="/admin" element={<AdminLayout />}>
-            <Route path="users" element={<AdminUsers />} />
+            <Route index element={<AdminDashboard />} />
-            <Route path="models" element={<AdminModels />} />
+            <Route path="users" element={<AdminUsers />} />
-            <Route path="settings" element={<AdminSiteSettings />} />
+            <Route path="models" element={<AdminModels />} />
-            <Route path="sms" element={<AdminSmsConfig />} />
+            <Route path="settings" element={<AdminSiteSettings />} />
-            <Route path="payment" element={<AdminPayment />} />
+            <Route path="sms" element={<AdminSmsConfig />} />
-            <Route path="services" element={<AdminServices />} />
+            <Route path="payment" element={<AdminPayment />} />
-            <Route path="membership" element={<AdminMembership />} />
+            <Route path="services" element={<AdminServices />} />
-            <Route path="ads" element={<AdminAds />} />
+            <Route path="membership" element={<AdminMembership />} />
-            <Route path="market" element={<AdminMarket />} />
+            <Route path="ads" element={<AdminAds />} />
-            <Route path="logs" element={<AdminLogs />} />
+            <Route path="market" element={<AdminMarket />} />
-            <Route path="skills" element={<AdminSkills />} />
+            <Route path="logs" element={<AdminLogs />} />
-            <Route path="agents" element={<AdminAgents />} />
+            <Route path="skills" element={<AdminSkills />} />
-            <Route path="code-exec" element={<AdminCodeExec />} />
+            <Route path="agents" element={<AdminAgents />} />
-            <Route path="distributions" element={<DistributionBuilder />} />
+            <Route path="code-exec" element={<AdminCodeExec />} />
-            <Route path="im-bots" element={<ImBots />} />
+            <Route path="distributions" element={<DistributionBuilder />} />
-            <Route path="privacy" element={<PrivacySettings />} />
+            <Route path="im-bots" element={<ImBots />} />
-            <Route path="promotion" element={<Promotion />} />
+            <Route path="privacy" element={<PrivacySettings />} />
-            <Route path="achievement" element={<Achievement />} />
+            <Route path="promotion" element={<Promotion />} />
-            <Route path="tenant" element={<Tenant />} />
+            <Route path="achievement" element={<Achievement />} />
-            <Route path="billing" element={<Billing />} />
+            <Route path="tenant" element={<Tenant />} />
-            <Route path="analytics" element={<Analytics />} />
+            <Route path="billing" element={<Billing />} />
-            <Route path="knowledge" element={<AdminKnowledge />} />
+            <Route path="analytics" element={<Analytics />} />
-            <Route path="workflow" element={<AdminWorkflow />} />
+      <Route path="observability" element={<Observability />} />
-            <Route path="storage" element={<AdminStorage />} />
+            <Route path="knowledge" element={<AdminKnowledge />} />
-            <Route path="developer" element={<AdminDeveloper />} />
+            <Route path="workflow" element={<AdminWorkflow />} />
-            <Route path="developer-tools" element={<AdminDeveloperTools />} />
+            <Route path="storage" element={<AdminStorage />} />
-            <Route path="automation" element={<AdminAutomation />} />
+            <Route path="developer" element={<AdminDeveloper />} />
-            <Route path="mcp" element={<AdminMcp />} />
+            <Route path="developer-tools" element={<AdminDeveloperTools />} />
-            <Route path="apps" element={<AdminApps />} />
+            <Route path="automation" element={<AdminAutomation />} />
-            <Route path="assets" element={<AssetCenter />} />
+            <Route path="mcp" element={<AdminMcp />} />
-            <Route path="portal" element={<UserPortal />} />
+            <Route path="apps" element={<AdminApps />} />
-          </Route>
+            <Route path="assets" element={<AssetCenter />} />
-
+            <Route path="portal" element={<UserPortal />} />
-          {/* 公开前台首页：不受登录态拦截，供后台「访问前台」直接打开 */}
+          </Route>
-          <Route path="/home" element={<LandingPage />} />
+
-          <Route path="*" element={<Navigate to="/" />} />
+          {/* 公开前台首页：不受登录态拦截，供后台「访问前台」直接打开 */}
-        </Routes>
+          <Route path="/home" element={<LandingPage />} />
-      </Suspense>
+          <Route path="*" element={<Navigate to="/" />} />
-    </AuthContext.Provider>
+        </Routes>
-  );
+      </Suspense>
-};
+    </AuthContext.Provider>
-
+  );
-export default App;
+};
+
+export default App;

frontend/src/components/layout/AdminLayout.tsx

@@ -1,435 +1,437 @@
-import React, { useState, useEffect } from 'react';
+import React, { useState, useEffect } from 'react';
-
+
-import { Outlet, NavLink, useNavigate, useLocation } from 'react-router-dom';
+import { Outlet, NavLink, useNavigate, useLocation } from 'react-router-dom';
-
+
-import { useAuth } from '@/contexts/AuthContext';
+import { useAuth } from '@/contexts/AuthContext';
-
+
-import './AdminLayout.css';
+import './AdminLayout.css';
-
+
-
+
-
+
-interface NavItem {
+interface NavItem {
-
+
-  path: string;
+  path: string;
-
+
-  icon: string;
+  icon: string;
-
+
-  label: string;
+  label: string;
-
+
-  exact?: boolean;
+  exact?: boolean;
-
+
-}
+}
-
+
-
+
-
+
-interface NavGroup {
+interface NavGroup {
-
+
-  title: string;
+  title: string;
-
+
-  icon: string;
+  icon: string;
-
+
-  items: NavItem[];
+  items: NavItem[];
-
+
-}
+}
-
+
-
+
-
+
-const adminNavGroups: NavGroup[] = [
+const adminNavGroups: NavGroup[] = [
-
+
-  {
+  {
-    title: '数据驾驶舱',
+    title: '数据驾驶舱',
-    icon: 'dashboard',
+    icon: 'dashboard',
-    items: [
+    items: [
-      { path: '/admin', icon: 'dashboard', label: '平台驾驶舱', exact: true },
+      { path: '/admin', icon: 'dashboard', label: '平台驾驶舱', exact: true },
-    ],
+    ],
-  },
+  },
-
+
-  {
+  {
-    title: 'AI技能中心',
+    title: 'AI技能中心',
-    icon: 'agents',
+    icon: 'agents',
-    items: [
+    items: [
-      { path: '/admin/models', icon: 'models', label: '大模型库' },
+      { path: '/admin/models', icon: 'models', label: '大模型库' },
-      { path: '/admin/agents', icon: 'agents', label: 'Agent 管理' },
+      { path: '/admin/agents', icon: 'agents', label: 'Agent 管理' },
-      { path: '/admin/skills', icon: 'skills', label: 'Skills技能管理' },
+      { path: '/admin/skills', icon: 'skills', label: 'Skills技能管理' },
-      { path: '/admin/mcp', icon: 'mcp', label: 'MCP Client 管理' },
+      { path: '/admin/mcp', icon: 'mcp', label: 'MCP Client 管理' },
-      { path: '/admin/market', icon: 'market', label: 'AI 技能审核' },
+      { path: '/admin/market', icon: 'market', label: 'AI 技能审核' },
-    ],
+    ],
-  },
+  },
-
+
-  {
+  {
-    title: '平台运营',
+    title: '平台运营',
-    icon: 'users',
+    icon: 'users',
-    items: [
+    items: [
-      { path: '/admin/users', icon: 'users', label: '用户管理' },
+      { path: '/admin/users', icon: 'users', label: '用户管理' },
-      { path: '/admin/membership', icon: 'membership', label: '会员管理' },
+      { path: '/admin/membership', icon: 'membership', label: '会员管理' },
-      { path: '/admin/promotion', icon: 'promotion', label: '推广系统' },
+      { path: '/admin/promotion', icon: 'promotion', label: '推广系统' },
-      { path: '/admin/achievement', icon: 'achievement', label: '成就系统' },
+      { path: '/admin/achievement', icon: 'achievement', label: '成就系统' },
-    ],
+    ],
-  },
+  },
-
+
-  {
+  {
-    title: '商业变现',
+    title: '商业变现',
-    icon: 'billing',
+    icon: 'billing',
-    items: [
+    items: [
-      { path: '/admin/billing', icon: 'billing', label: '计费与支付' },
+      { path: '/admin/billing', icon: 'billing', label: '计费与支付' },
-      { path: '/admin/payment', icon: 'payment', label: '支付渠道' },
+      { path: '/admin/payment', icon: 'payment', label: '支付渠道' },
-      { path: '/admin/services', icon: 'services', label: '增值服务' },
+      { path: '/admin/services', icon: 'services', label: '增值服务' },
-      { path: '/admin/ads', icon: 'ads', label: '广告管理' },
+      { path: '/admin/ads', icon: 'ads', label: '广告管理' },
-      { path: '/admin/assets', icon: 'assets', label: '资产管理' },
+      { path: '/admin/assets', icon: 'assets', label: '资产管理' },
-    ],
+    ],
-  },
+  },
-
+
-  {
+  {
-    title: '系统管理',
+    title: '系统管理',
-    icon: 'settings',
+    icon: 'settings',
-    items: [
+    items: [
-      { path: '/admin/settings', icon: 'settings', label: '网站设置' },
+      { path: '/admin/settings', icon: 'settings', label: '网站设置' },
-      { path: '/admin/logs', icon: 'logs', label: '日志与风控' },
+      { path: '/admin/logs', icon: 'logs', label: '日志与风控' },
-      { path: '/admin/knowledge', icon: 'knowledge', label: '知识库管理' },
+      { path: '/admin/knowledge', icon: 'knowledge', label: '知识库管理' },
-      { path: '/admin/sms', icon: 'sms', label: '短信配置' },
+      { path: '/admin/sms', icon: 'sms', label: '短信配置' },
-      { path: '/admin/storage', icon: 'storage', label: '存储配置' },
+      { path: '/admin/storage', icon: 'storage', label: '存储配置' },
-      { path: '/admin/automation', icon: 'automation', label: '自动化任务' },
+      { path: '/admin/automation', icon: 'automation', label: '自动化任务' },
-    ],
+    ],
-  },
+  },
-
+
-  {
+  {
-    title: '待处理',
+    title: '待处理',
-    icon: 'developer',
+    icon: 'developer',
-    items: [
+    items: [
-      { path: '/admin/analytics', icon: 'analytics', label: '数据分析' },
+      { path: '/admin/analytics', icon: 'analytics', label: '数据分析' },
-      { path: '/admin/workflow', icon: 'workflow', label: '工作流编排' },
+      { path: '/admin/observability', icon: 'observability', label: '调用可观测' },
-      { path: '/admin/apps', icon: 'apps', label: 'AI 应用管理' },
+      { path: '/admin/workflow', icon: 'workflow', label: '工作流编排' },
-      { path: '/admin/code-exec', icon: 'code', label: '代码执行沙箱' },
+      { path: '/admin/apps', icon: 'apps', label: 'AI 应用管理' },
-      { path: '/admin/tenant', icon: 'tenant', label: '多租户管理' },
+      { path: '/admin/code-exec', icon: 'code', label: '代码执行沙箱' },
-      { path: '/admin/im-bots', icon: 'imbot', label: 'IM 机器人' },
+      { path: '/admin/tenant', icon: 'tenant', label: '多租户管理' },
-      { path: '/admin/privacy', icon: 'privacy', label: '隐私与本地代理' },
+      { path: '/admin/im-bots', icon: 'imbot', label: 'IM 机器人' },
-      { path: '/admin/distributions', icon: 'distro', label: '发行版构建' },
+      { path: '/admin/privacy', icon: 'privacy', label: '隐私与本地代理' },
-      { path: '/admin/developer', icon: 'developer', label: '开发者 API' },
+      { path: '/admin/distributions', icon: 'distro', label: '发行版构建' },
-      { path: '/admin/developer-tools', icon: 'devtools', label: '开发者工具' },
+      { path: '/admin/developer', icon: 'developer', label: '开发者 API' },
-    ],
+      { path: '/admin/developer-tools', icon: 'devtools', label: '开发者工具' },
-  },
+    ],
-
+  },
-];
+
-
+];
-
+
-
+
-const adminIconPaths: Record<string, JSX.Element> = {
+
-
+const adminIconPaths: Record<string, JSX.Element> = {
-  dashboard: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/></svg>,
+
-
+  dashboard: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/></svg>,
-  users: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M17 21v-2a4 4 0 0 0-4-4H5a4 4 0 0 0-4 4v2"/><circle cx="9" cy="7" r="4"/><path d="M23 21v-2a4 4 0 0 0-3-3.87"/><path d="M16 3.13a4 4 0 0 1 0 7.75"/></svg>,
+
-
+  users: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M17 21v-2a4 4 0 0 0-4-4H5a4 4 0 0 0-4 4v2"/><circle cx="9" cy="7" r="4"/><path d="M23 21v-2a4 4 0 0 0-3-3.87"/><path d="M16 3.13a4 4 0 0 1 0 7.75"/></svg>,
-  models: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2L2 7l10 5 10-5-10-5z"/><path d="M2 17l10 5 10-5"/><path d="M2 12l10 5 10-5"/></svg>,
+
-
+  models: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2L2 7l10 5 10-5-10-5z"/><path d="M2 17l10 5 10-5"/><path d="M2 12l10 5 10-5"/></svg>,
-  settings: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="12" r="3"/><path d="M19.4 15a1.65 1.65 0 0 0 .33 1.82l.06.06a2 2 0 0 1-2.83 2.83l-.06-.06a1.65 1.65 0 0 0-1.82-.33 1.65 1.65 0 0 0-1 1.51V21a2 2 0 0 1-4 0v-.09A1.65 1.65 0 0 0 9 19.4a1.65 1.65 0 0 0-1.82.33l-.06.06a2 2 0 0 1-2.83-2.83l.06-.06A1.65 1.65 0 0 0 4.68 15a1.65 1.65 0 0 0-1.51-1H3a2 2 0 0 1 0-4h.09A1.65 1.65 0 0 0 4.6 9a1.65 1.65 0 0 0-.33-1.82l-.06-.06a2 2 0 0 1 2.83-2.83l.06.06A1.65 1.65 0 0 0 9 4.68a1.65 1.65 0 0 0 1-1.51V3a2 2 0 0 1 4 0v.09a1.65 1.65 0 0 0 1 1.51 1.65 1.65 0 0 0 1.82-.33l.06-.06a2 2 0 0 1 2.83 2.83l-.06.06A1.65 1.65 0 0 0 19.4 9a1.65 1.65 0 0 0 1.51 1H21a2 2 0 0 1 0 4h-.09a1.65 1.65 0 0 0-1.51 1z"/></svg>,
+
-
+  settings: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="12" r="3"/><path d="M19.4 15a1.65 1.65 0 0 0 .33 1.82l.06.06a2 2 0 0 1-2.83 2.83l-.06-.06a1.65 1.65 0 0 0-1.82-.33 1.65 1.65 0 0 0-1 1.51V21a2 2 0 0 1-4 0v-.09A1.65 1.65 0 0 0 9 19.4a1.65 1.65 0 0 0-1.82.33l-.06.06a2 2 0 0 1-2.83-2.83l.06-.06A1.65 1.65 0 0 0 4.68 15a1.65 1.65 0 0 0-1.51-1H3a2 2 0 0 1 0-4h.09A1.65 1.65 0 0 0 4.6 9a1.65 1.65 0 0 0-.33-1.82l-.06-.06a2 2 0 0 1 2.83-2.83l.06.06A1.65 1.65 0 0 0 9 4.68a1.65 1.65 0 0 0 1-1.51V3a2 2 0 0 1 4 0v.09a1.65 1.65 0 0 0 1 1.51 1.65 1.65 0 0 0 1.82-.33l.06-.06a2 2 0 0 1 2.83 2.83l-.06.06A1.65 1.65 0 0 0 19.4 9a1.65 1.65 0 0 0 1.51 1H21a2 2 0 0 1 0 4h-.09a1.65 1.65 0 0 0-1.51 1z"/></svg>,
-  payment: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="5" width="20" height="14" rx="2"/><line x1="2" y1="10" x2="22" y2="10"/></svg>,
+
-
+  payment: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="5" width="20" height="14" rx="2"/><line x1="2" y1="10" x2="22" y2="10"/></svg>,
-  services: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 3 21 3 21 8"/><line x1="4" y1="20" x2="21" y2="3"/><polyline points="21 16 21 21 16 21"/><line x1="15" y1="15" x2="21" y2="21"/><line x1="4" y1="4" x2="9" y2="9"/></svg>,
+
-
+  services: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 3 21 3 21 8"/><line x1="4" y1="20" x2="21" y2="3"/><polyline points="21 16 21 21 16 21"/><line x1="15" y1="15" x2="21" y2="21"/><line x1="4" y1="4" x2="9" y2="9"/></svg>,
-  membership: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M20.59 13.41l-7.17 7.17a2 2 0 0 1-2.83 0L2 12V2h10l8.59 8.59a2 2 0 0 1 0 2.82z"/><line x1="7" y1="7" x2="7.01" y2="7"/></svg>,
+
-
+  membership: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M20.59 13.41l-7.17 7.17a2 2 0 0 1-2.83 0L2 12V2h10l8.59 8.59a2 2 0 0 1 0 2.82z"/><line x1="7" y1="7" x2="7.01" y2="7"/></svg>,
-  ads: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="3" width="20" height="14" rx="2"/><line x1="8" y1="21" x2="16" y2="21"/><line x1="12" y1="17" x2="12" y2="21"/></svg>,
+
-
+  ads: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="3" width="20" height="14" rx="2"/><line x1="8" y1="21" x2="16" y2="21"/><line x1="12" y1="17" x2="12" y2="21"/></svg>,
-  market: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1.2"/><rect x="14" y="3" width="7" height="7" rx="1.2"/><rect x="3" y="14" width="7" height="7" rx="1.2"/><rect x="14" y="14" width="7" height="7" rx="1.2"/></svg>,
+
-
+  market: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1.2"/><rect x="14" y="3" width="7" height="7" rx="1.2"/><rect x="3" y="14" width="7" height="7" rx="1.2"/><rect x="14" y="14" width="7" height="7" rx="1.2"/></svg>,
-  logs: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14 2H6a2 2 0 0 0-2 2v16a2 2 0 0 0 2 2h12a2 2 0 0 0 2-2V8z"/><polyline points="14 2 14 8 20 8"/><line x1="16" y1="13" x2="8" y2="13"/><line x1="16" y1="17" x2="8" y2="17"/><polyline points="10 9 9 9 8 9"/></svg>,
+
-
+  logs: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14 2H6a2 2 0 0 0-2 2v16a2 2 0 0 0 2 2h12a2 2 0 0 0 2-2V8z"/><polyline points="14 2 14 8 20 8"/><line x1="16" y1="13" x2="8" y2="13"/><line x1="16" y1="17" x2="8" y2="17"/><polyline points="10 9 9 9 8 9"/></svg>,
-  agents: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="11" width="18" height="10" rx="2"/><circle cx="12" cy="5" r="2"/><path d="M12 7v4"/><line x1="8" y1="16" x2="8" y2="16"/><line x1="16" y1="16" x2="16" y2="16"/></svg>,
+
-
+  agents: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="11" width="18" height="10" rx="2"/><circle cx="12" cy="5" r="2"/><path d="M12 7v4"/><line x1="8" y1="16" x2="8" y2="16"/><line x1="16" y1="16" x2="16" y2="16"/></svg>,
-  skills: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14.7 6.3a1 1 0 0 0 0 1.4l1.6 1.6a1 1 0 0 0 1.4 0l3.77-3.77a6 6 0 0 1-7.94 7.94l-6.91 6.91a2.12 2.12 0 0 1-3-3l6.91-6.91a6 6 0 0 1 7.94-7.94l-3.76 3.76z"/></svg>,
+
-
+  skills: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14.7 6.3a1 1 0 0 0 0 1.4l1.6 1.6a1 1 0 0 0 1.4 0l3.77-3.77a6 6 0 0 1-7.94 7.94l-6.91 6.91a2.12 2.12 0 0 1-3-3l6.91-6.91a6 6 0 0 1 7.94-7.94l-3.76 3.76z"/></svg>,
-  code: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 18 22 12 16 6"/><polyline points="8 6 2 12 8 18"/></svg>,
+
-
+  code: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 18 22 12 16 6"/><polyline points="8 6 2 12 8 18"/></svg>,
-  distro: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 16V8a2 2 0 0 0-1-1.73l-7-4a2 2 0 0 0-2 0l-7 4A2 2 0 0 0 3 8v8a2 2 0 0 0 1 1.73l7 4a2 2 0 0 0 2 0l7-4A2 2 0 0 0 21 16z"/><polyline points="3.27 6.96 12 12.01 20.73 6.96"/><line x1="12" y1="22.08" x2="12" y2="12"/></svg>,
+
-
+  distro: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 16V8a2 2 0 0 0-1-1.73l-7-4a2 2 0 0 0-2 0l-7 4A2 2 0 0 0 3 8v8a2 2 0 0 0 1 1.73l7 4a2 2 0 0 0 2 0l7-4A2 2 0 0 0 21 16z"/><polyline points="3.27 6.96 12 12.01 20.73 6.96"/><line x1="12" y1="22.08" x2="12" y2="12"/></svg>,
-  privacy: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="11" width="18" height="11" rx="2" ry="2"/><path d="M7 11V7a5 5 0 0 1 10 0v4"/><circle cx="12" cy="16" r="1"/></svg>,
+
-
+  privacy: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="11" width="18" height="11" rx="2" ry="2"/><path d="M7 11V7a5 5 0 0 1 10 0v4"/><circle cx="12" cy="16" r="1"/></svg>,
-  promotion: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="8" r="7"/><path d="M8.5 12.5L6 21l6-2 6 2-2.5-8.5"/><circle cx="12" cy="8" r="3"/></svg>,
+
-
+  promotion: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="8" r="7"/><path d="M8.5 12.5L6 21l6-2 6 2-2.5-8.5"/><circle cx="12" cy="8" r="3"/></svg>,
-  achievement: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2l3.09 6.26L22 9.27l-5 4.87L18.18 22 12 18.27 7.82 22 7 14.14l-5-4.87 6.91-1.01L12 2z"/></svg>,
+
-
+  achievement: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2l3.09 6.26L22 9.27l-5 4.87L18.18 22 12 18.27 7.82 22 7 14.14l-5-4.87 6.91-1.01L12 2z"/></svg>,
-  tenant: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M3 21V8l9-5 9 5v13"/><path d="M9 21v-6h6v6"/><path d="M3 13h18"/></svg>,
+
-
+  tenant: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M3 21V8l9-5 9 5v13"/><path d="M9 21v-6h6v6"/><path d="M3 13h18"/></svg>,
-  billing: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="5" width="20" height="14" rx="2"/><line x1="2" y1="10" x2="22" y2="10"/><line x1="6" y1="15" x2="10" y2="15"/></svg>,
+
-
+  billing: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="2" y="5" width="20" height="14" rx="2"/><line x1="2" y1="10" x2="22" y2="10"/><line x1="6" y1="15" x2="10" y2="15"/></svg>,
-  analytics: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><line x1="18" y1="20" x2="18" y2="10"/><line x1="12" y1="20" x2="12" y2="4"/><line x1="6" y1="20" x2="6" y2="14"/><line x1="3" y1="20" x2="21" y2="20"/></svg>,
+
-
+  analytics: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><line x1="18" y1="20" x2="18" y2="10"/><line x1="12" y1="20" x2="12" y2="4"/><line x1="6" y1="20" x2="6" y2="14"/><line x1="3" y1="20" x2="21" y2="20"/></svg>,
-  imbot: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 11.5a8.38 8.38 0 0 1-.9 3.8 8.5 8.5 0 0 1-7.6 4.7 8.38 8.38 0 0 1-3.8-.9L3 21l1.9-5.7a8.38 8.38 0 0 1-.9-3.8 8.5 8.5 0 0 1 4.7-7.6 8.38 8.38 0 0 1 3.8-.9h.5a8.48 8.48 0 0 1 8 8v.5z"/></svg>,
+  observability: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M3 12h4l3 8 4-16 3 8h4"/></svg>,
-
+
-  storage: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><ellipse cx="12" cy="5" rx="9" ry="3"/><path d="M21 12c0 1.66-4 3-9 3s-9-1.34-9-3"/><path d="M3 5v14c0 1.66 4 3 9 3s9-1.34 9-3V5"/></svg>,
+  imbot: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 11.5a8.38 8.38 0 0 1-.9 3.8 8.5 8.5 0 0 1-7.6 4.7 8.38 8.38 0 0 1-3.8-.9L3 21l1.9-5.7a8.38 8.38 0 0 1-.9-3.8 8.5 8.5 0 0 1 4.7-7.6 8.38 8.38 0 0 1 3.8-.9h.5a8.48 8.48 0 0 1 8 8v.5z"/></svg>,
-
+
-  automation: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2v4M12 18v4M4.93 4.93l2.83 2.83M16.24 16.24l2.83 2.83M2 12h4M18 12h4M4.93 19.07l2.83-2.83M16.24 7.76l2.83-2.83"/></svg>,
+  storage: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><ellipse cx="12" cy="5" rx="9" ry="3"/><path d="M21 12c0 1.66-4 3-9 3s-9-1.34-9-3"/><path d="M3 5v14c0 1.66 4 3 9 3s9-1.34 9-3V5"/></svg>,
-
+
-  developer: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 18 22 12 16 6"/><polyline points="8 6 2 12 8 18"/></svg>,
+  automation: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M12 2v4M12 18v4M4.93 4.93l2.83 2.83M16.24 16.24l2.83 2.83M2 12h4M18 12h4M4.93 19.07l2.83-2.83M16.24 7.76l2.83-2.83"/></svg>,
-
+
-  devtools: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14.7 6.3a1 1 0 0 0 0 1.4l1.6 1.6a1 1 0 0 0 1.4 0l3.77-3.77a6 6 0 0 1-7.94 7.94l-6.91 6.91a2.12 2.12 0 0 1-3-3l6.91-6.91a6 6 0 0 1 7.94-7.94l-3.76 3.76z"/></svg>,
+  developer: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><polyline points="16 18 22 12 16 6"/><polyline points="8 6 2 12 8 18"/></svg>,
-
+
-  knowledge: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M4 19.5A2.5 2.5 0 0 1 6.5 17H20"/><path d="M6.5 2H20v20H6.5A2.5 2.5 0 0 1 4 19.5v-15A2.5 2.5 0 0 1 6.5 2z"/></svg>,
+  devtools: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M14.7 6.3a1 1 0 0 0 0 1.4l1.6 1.6a1 1 0 0 0 1.4 0l3.77-3.77a6 6 0 0 1-7.94 7.94l-6.91 6.91a2.12 2.12 0 0 1-3-3l6.91-6.91a6 6 0 0 1 7.94-7.94l-3.76 3.76z"/></svg>,
-
+
-  workflow: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/><line x1="10" y1="6" x2="14" y2="6"/><line x1="10" y1="17" x2="14" y2="17"/></svg>,
+  knowledge: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M4 19.5A2.5 2.5 0 0 1 6.5 17H20"/><path d="M6.5 2H20v20H6.5A2.5 2.5 0 0 1 4 19.5v-15A2.5 2.5 0 0 1 6.5 2z"/></svg>,
-
+
-  mcp: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="12" r="3"/><path d="M19.4 15a1.65 1.65 0 0 0 .33 1.82l.06.06a2 2 0 0 1-2.83 2.83l-.06-.06a1.65 1.65 0 0 0-1.82-.33 1.65 1.65 0 0 0-1 1.51V21a2 2 0 0 1-4 0v-.09A1.65 1.65 0 0 0 9 19.4a1.65 1.65 0 0 0-1.82.33l-.06.06a2 2 0 0 1-2.83-2.83l.06-.06A1.65 1.65 0 0 0 4.68 15a1.65 1.65 0 0 0-1.51-1H3a2 2 0 0 1 0-4h.09A1.65 1.65 0 0 0 4.6 9a1.65 1.65 0 0 0-.33-1.82l-.06-.06a2 2 0 0 1 2.83-2.83l.06.06A1.65 1.65 0 0 0 9 4.68a1.65 1.65 0 0 0 1-1.51V3a2 2 0 0 1 4 0v.09a1.65 1.65 0 0 0 1 1.51 1.65 1.65 0 0 0 1.82-.33l.06-.06a2 2 0 0 1 2.83 2.83l-.06.06A1.65 1.65 0 0 0 19.4 9a1.65 1.65 0 0 0 1.51 1H21a2 2 0 0 1 0 4h-.09a1.65 1.65 0 0 0-1.51 1z"/></svg>,
+  workflow: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/><line x1="10" y1="6" x2="14" y2="6"/><line x1="10" y1="17" x2="14" y2="17"/></svg>,
-
+
-  apps: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/></svg>,
+  mcp: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><circle cx="12" cy="12" r="3"/><path d="M19.4 15a1.65 1.65 0 0 0 .33 1.82l.06.06a2 2 0 0 1-2.83 2.83l-.06-.06a1.65 1.65 0 0 0-1.82-.33 1.65 1.65 0 0 0-1 1.51V21a2 2 0 0 1-4 0v-.09A1.65 1.65 0 0 0 9 19.4a1.65 1.65 0 0 0-1.82.33l-.06.06a2 2 0 0 1-2.83-2.83l.06-.06A1.65 1.65 0 0 0 4.68 15a1.65 1.65 0 0 0-1.51-1H3a2 2 0 0 1 0-4h.09A1.65 1.65 0 0 0 4.6 9a1.65 1.65 0 0 0-.33-1.82l-.06-.06a2 2 0 0 1 2.83-2.83l.06.06A1.65 1.65 0 0 0 9 4.68a1.65 1.65 0 0 0 1-1.51V3a2 2 0 0 1 4 0v.09a1.65 1.65 0 0 0 1 1.51 1.65 1.65 0 0 0 1.82-.33l.06-.06a2 2 0 0 1 2.83 2.83l-.06.06A1.65 1.65 0 0 0 19.4 9a1.65 1.65 0 0 0 1.51 1H21a2 2 0 0 1 0 4h-.09a1.65 1.65 0 0 0-1.51 1z"/></svg>,
-
+
-  assets: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 16V8a2 2 0 0 0-1-1.73l-7-4a2 2 0 0 0-2 0l-7 4A2 2 0 0 0 3 8v8a2 2 0 0 0 1 1.73l7 4a2 2 0 0 0 2 0l7-4A2 2 0 0 0 21 16z"/><polyline points="3.27 6.96 12 12.01 20.73 6.96"/><line x1="12" y1="22.08" x2="12" y2="12"/></svg>,
+  apps: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><rect x="3" y="3" width="7" height="7" rx="1"/><rect x="14" y="3" width="7" height="7" rx="1"/><rect x="3" y="14" width="7" height="7" rx="1"/><rect x="14" y="14" width="7" height="7" rx="1"/></svg>,
-
+
-  chevron: <svg width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round"><polyline points="6 9 12 15 18 9"/></svg>,
+  assets: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 16V8a2 2 0 0 0-1-1.73l-7-4a2 2 0 0 0-2 0l-7 4A2 2 0 0 0 3 8v8a2 2 0 0 0 1 1.73l7 4a2 2 0 0 0 2 0l7-4A2 2 0 0 0 21 16z"/><polyline points="3.27 6.96 12 12.01 20.73 6.96"/><line x1="12" y1="22.08" x2="12" y2="12"/></svg>,
-
+
-  sms: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 15a2 2 0 0 1-2 2H7l-4 4V5a2 2 0 0 1 2-2h14a2 2 0 0 1 2 2z"/></svg>,
+  chevron: <svg width="14" height="14" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round"><polyline points="6 9 12 15 18 9"/></svg>,
-
+
-};
+  sms: <svg width="18" height="18" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="1.8" strokeLinecap="round" strokeLinejoin="round"><path d="M21 15a2 2 0 0 1-2 2H7l-4 4V5a2 2 0 0 1 2-2h14a2 2 0 0 1 2 2z"/></svg>,
-
+
-
+};
-
+
-const AdminLayout: React.FC = () => {
+
-
+
-  const { user, logout } = useAuth();
+const AdminLayout: React.FC = () => {
-
+
-  const navigate = useNavigate();
+  const { user, logout } = useAuth();
-
+
-  const location = useLocation();
+  const navigate = useNavigate();
-
+
-  // 后台必须登录且为管理员
+  const location = useLocation();
-  useEffect(() => {
+
-    const token = localStorage.getItem('aiflow_token');
+  // 后台必须登录且为管理员
-    if (!token || !user || user.role !== 'admin') {
+  useEffect(() => {
-      logout();
+    const token = localStorage.getItem('aiflow_token');
-      navigate('/login', { replace: true });
+    if (!token || !user || user.role !== 'admin') {
-    }
+      logout();
-  }, [user, logout, navigate]);
+      navigate('/login', { replace: true });
-
+    }
-  const navCrumb = (() => {
+  }, [user, logout, navigate]);
-
+
-    for (const g of adminNavGroups) {
+  const navCrumb = (() => {
-
+
-      for (const it of g.items) {
+    for (const g of adminNavGroups) {
-
+
-        const match = it.exact
+      for (const it of g.items) {
-
+
-          ? location.pathname === it.path
+        const match = it.exact
-
+
-          : location.pathname === it.path || location.pathname.startsWith(it.path + '/');
+          ? location.pathname === it.path
-
+
-        if (match) return { group: g.title, label: it.label };
+          : location.pathname === it.path || location.pathname.startsWith(it.path + '/');
-
+
-      }
+        if (match) return { group: g.title, label: it.label };
-
+
-    }
+      }
-
+
-    return { group: '', label: '' };
+    }
-
+
-  })();
+    return { group: '', label: '' };
-
+
-  const navGroup = navCrumb.group;
+  })();
-
+
-  const navLabel = navCrumb.label;
+  const navGroup = navCrumb.group;
-
+
-
+  const navLabel = navCrumb.label;
-
+
-  // 默认展开全部功能板块，确保后台所有模块在 UI 中可见（DESIGN.md: 侧栏分类清晰）
+
-  const [expandedGroups, setExpandedGroups] = useState<Set<string>>(() => {
+
-    return new Set(adminNavGroups.map((g) => g.title));
+  // 默认展开全部功能板块，确保后台所有模块在 UI 中可见（DESIGN.md: 侧栏分类清晰）
-  });
+  const [expandedGroups, setExpandedGroups] = useState<Set<string>>(() => {
-
+    return new Set(adminNavGroups.map((g) => g.title));
-
+  });
-
+
-  const toggleGroup = (title: string) => {
+
-
+
-    setExpandedGroups(prev => {
+  const toggleGroup = (title: string) => {
-
+
-      const next = new Set(prev);
+    setExpandedGroups(prev => {
-
+
-      if (next.has(title)) next.delete(title);
+      const next = new Set(prev);
-
+
-      else next.add(title);
+      if (next.has(title)) next.delete(title);
-
+
-      return next;
+      else next.add(title);
-
+
-    });
+      return next;
-
+
-  };
+    });
-
+
-
+  };
-
+
-  const handleLogout = () => {
+
-
+
-    logout();
+  const handleLogout = () => {
-
+
-    navigate('/');
+    logout();
-
+
-  };
+    navigate('/');
-
+
-
+  };
-
+
-  const handleVisitFrontend = () => {
+
-
+
-    const url = window.location.origin + '/chat';
+  const handleVisitFrontend = () => {
-
+
-    window.open(url, '_blank');
+    const url = window.location.origin + '/chat';
-
+
-  };
+    window.open(url, '_blank');
-
+
-
+  };
-
+
-  return (
+
-
+
-    <div className="admin-layout">
+  return (
-
+
-      <aside className="admin-sidebar">
+    <div className="admin-layout">
-
+
-        <div className="admin-sidebar-header">
+      <aside className="admin-sidebar">
-
+
-          <h1 className="admin-logo">七虎AI</h1>
+        <div className="admin-sidebar-header">
-
+
-          <span className="admin-subtitle">管理控制台</span>
+          <h1 className="admin-logo">七虎AI</h1>
-
+
-        </div>
+          <span className="admin-subtitle">管理控制台</span>
-
+
-        <button onClick={handleVisitFrontend} className="admin-frontend-link">
+        </div>
-
+
-          <svg width="16" height="16" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round"><path d="M18 13v6a2 2 0 0 1-2 2H5a2 2 0 0 1-2-2V8a2 2 0 0 1 2-2h6"/><polyline points="15 3 21 3 21 9"/><line x1="10" y1="14" x2="21" y2="3"/></svg>
+        <button onClick={handleVisitFrontend} className="admin-frontend-link">
-
+
-          <span>访问前台</span>
+          <svg width="16" height="16" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round"><path d="M18 13v6a2 2 0 0 1-2 2H5a2 2 0 0 1-2-2V8a2 2 0 0 1 2-2h6"/><polyline points="15 3 21 3 21 9"/><line x1="10" y1="14" x2="21" y2="3"/></svg>
-
+
-        </button>
+          <span>访问前台</span>
-
+
-        <nav className="sidebar-nav">
+        </button>
-
+
-          {adminNavGroups.map((group) => {
+        <nav className="sidebar-nav">
-
+
-            const isExpanded = expandedGroups.has(group.title);
+          {adminNavGroups.map((group) => {
-
+
-            const hasActiveChild = group.items.some(item =>
+            const isExpanded = expandedGroups.has(group.title);
-
+
-              item.exact ? location.pathname === item.path : location.pathname.startsWith(item.path)
+            const hasActiveChild = group.items.some(item =>
-
+
-            );
+              item.exact ? location.pathname === item.path : location.pathname.startsWith(item.path)
-
+
-            return (
+            );
-
+
-              <div key={group.title} className={`nav-group ${hasActiveChild ? 'nav-group-active' : ''}`}>
+            return (
-
+
-                <div
+              <div key={group.title} className={`nav-group ${hasActiveChild ? 'nav-group-active' : ''}`}>
-
+
-                  className={`nav-group-header ${isExpanded ? 'expanded' : ''}`}
+                <div
-
+
-                  onClick={() => toggleGroup(group.title)}
+                  className={`nav-group-header ${isExpanded ? 'expanded' : ''}`}
-
+
-                >
+                  onClick={() => toggleGroup(group.title)}
-
+
-                  <span className="nav-group-chevron-wrap">
+                >
-
+
-                    <span className={`nav-group-chevron ${isExpanded ? 'chevron-expanded' : ''}`}>
+                  <span className="nav-group-chevron-wrap">
-
+
-                      {adminIconPaths.chevron}
+                    <span className={`nav-group-chevron ${isExpanded ? 'chevron-expanded' : ''}`}>
-
+
-                    </span>
+                      {adminIconPaths.chevron}
-
+
-                  </span>
+                    </span>
-
+
-                  <span className="nav-group-title">{group.title}</span>
+                  </span>
-
+
-                </div>
+                  <span className="nav-group-title">{group.title}</span>
-
+
-                {isExpanded && (
+                </div>
-
+
-                  <div className="nav-group-items">
+                {isExpanded && (
-
+
-                    {group.items.map((item) => (
+                  <div className="nav-group-items">
-
+
-                      <NavLink
+                    {group.items.map((item) => (
-
+
-                        key={item.path}
+                      <NavLink
-
+
-                        to={item.path}
+                        key={item.path}
-
+
-                        end={item.exact}
+                        to={item.path}
-
+
-                        className={({ isActive }) =>
+                        end={item.exact}
-
+
-                          `nav-item ${isActive ? 'nav-item-active' : ''}`
+                        className={({ isActive }) =>
-
+
-                        }
+                          `nav-item ${isActive ? 'nav-item-active' : ''}`
-
+
-                      >
+                        }
-
+
-                        <span className="nav-item-icon">{adminIconPaths[item.icon]}</span>
+                      >
-
+
-                        <span className="nav-item-label">{item.label}</span>
+                        <span className="nav-item-icon">{adminIconPaths[item.icon]}</span>
-
+
-                      </NavLink>
+                        <span className="nav-item-label">{item.label}</span>
-
+
-                    ))}
+                      </NavLink>
-
+
-                  </div>
+                    ))}
-
+
-                )}
+                  </div>
-
+
-              </div>
+                )}
-
+
-            );
+              </div>
-
+
-          })}
+            );
-
+
-        </nav>
+          })}
-
+
-        <div className="admin-sidebar-footer">
+        </nav>
-
+
-          <div className="admin-user-info">
+        <div className="admin-sidebar-footer">
-
+
-            <div className="admin-user-avatar">{user?.username?.[0]?.toUpperCase() || 'A'}</div>
+          <div className="admin-user-info">
-
+
-            <div className="admin-user-detail">
+            <div className="admin-user-avatar">{user?.username?.[0]?.toUpperCase() || 'A'}</div>
-
+
-              <div className="admin-user-name">{user?.username || 'admin'}</div>
+            <div className="admin-user-detail">
-
+
-              <button className="admin-logout-btn" onClick={handleLogout}>退出登录</button>
+              <div className="admin-user-name">{user?.username || 'admin'}</div>
-
+
-            </div>
+              <button className="admin-logout-btn" onClick={handleLogout}>退出登录</button>
-
+
-          </div>
+            </div>
-
+
-        </div>
+          </div>
-
+
-      </aside>
+        </div>
-
+
-      <main className="admin-content">
+      </aside>
-
+
-        <header className="admin-topbar">
+      <main className="admin-content">
-
+
-          <nav className="admin-breadcrumb" aria-label="breadcrumb">
+        <header className="admin-topbar">
-
+
-            <span className="crumb-root">管理控制台</span>
+          <nav className="admin-breadcrumb" aria-label="breadcrumb">
-
+
-            {navGroup && (<><span className="crumb-sep">/</span><span className="crumb-group">{navGroup}</span></>)}
+            <span className="crumb-root">管理控制台</span>
-
+
-            {navLabel && (<><span className="crumb-sep">/</span><span className="crumb-current">{navLabel}</span></>)}
+            {navGroup && (<><span className="crumb-sep">/</span><span className="crumb-group">{navGroup}</span></>)}
-
+
-          </nav>
+            {navLabel && (<><span className="crumb-sep">/</span><span className="crumb-current">{navLabel}</span></>)}
-
+
-          <div className="admin-topbar-user">
+          </nav>
-
+
-            <div className="admin-user-avatar sm">{user?.username?.[0]?.toUpperCase() || 'A'}</div>
+          <div className="admin-topbar-user">
-
+
-            <span className="admin-topbar-username">{user?.username || 'admin'}</span>
+            <div className="admin-user-avatar sm">{user?.username?.[0]?.toUpperCase() || 'A'}</div>
-
+
-          </div>
+            <span className="admin-topbar-username">{user?.username || 'admin'}</span>
-
+
-        </header>
+          </div>
-
+
-        <Outlet />
+        </header>
-
+
-      </main>
+        <Outlet />
-
+
-    </div>
+      </main>
-
+
-  );
+    </div>
-
+
-};
+  );
-
+
-
+};
-
+
-export default AdminLayout;
+
-
+
+export default AdminLayout;
+

frontend/src/pages/admin/Agents.tsx

@@ -105,6 +105,10 @@ const Agents: React.FC = () => {
   // Available skills for linking
   const [availableSkills, setAvailableSkills] = useState<any[]>([]);
   const [availableModels, setAvailableModels] = useState<AvailableModel[]>([]);
+  // Available MCP servers for tool_policy sandbox allowlist
+  const [availableMcps, setAvailableMcps] = useState<any[]>([]);
+  // Tool policy (sandbox) — null means disabled / no policy
+  const [toolPolicy, setToolPolicy] = useState<any>(null);
 
   // Toast
   const [toast, setToast] = useState<{ msg: string; type: 'success' | 'error' } | null>(null);
@@ -144,14 +148,17 @@ const Agents: React.FC = () => {
   // Load available skills & models
   const loadAvailable = async () => {
     try {
-      const [skillsResult, modelsResult] = await Promise.all([
+      const [skillsResult, modelsResult, mcpsResult] = await Promise.all([
         adminAPI.getAdminAvailableSkills({ page_size: 50 }) as any,
         adminAPI.getAdminAvailableModels() as any,
+        adminAPI.getAdminMcpServers({ page_size: 50 }) as any,
       ]);
       const skills = (skillsResult.data || skillsResult).items || [];
       const models = (modelsResult.data || modelsResult) || [];
+      const mcps = (mcpsResult.data || mcpsResult).items || [];
       setAvailableSkills(skills);
       setAvailableModels(models);
+      setAvailableMcps(mcps);
     } catch {}
   };
 
@@ -187,6 +194,7 @@ const Agents: React.FC = () => {
       memory_enabled: false,
       reasoning_enabled: false,
     });
+    setToolPolicy(null);
     setShowModal(true);
   };
 
@@ -194,6 +202,7 @@ const Agents: React.FC = () => {
   const openEdit = async (agent: Agent) => {
     setEditingAgent(agent);
     await loadAvailable();
+    await openEditLoadPolicy(agent.id);
 
     const cfg = agent.config || {};
     setForm({
@@ -213,7 +222,15 @@ const Agents: React.FC = () => {
     setShowModal(true);
   };
 
-  // Open detail
+  // Fetch existing tool_policy (sandbox) for this agent
+  const openEditLoadPolicy = async (agentId: string) => {
+    try {
+      const tpRes = await adminAPI.getAgentToolPolicy(agentId) as any;
+      setToolPolicy(tpRes?.data?.tool_policy || null);
+    } catch {
+      setToolPolicy(null);
+    }
+  };
   const openDetail = async (agent: Agent) => {
     setDetailAgent(agent);
     setShowDetail(true);
@@ -246,7 +263,13 @@ const Agents: React.FC = () => {
     try {
       if (editingAgent) {
         await adminAPI.updateAdminAgent(editingAgent.id, payload);
-        showToast('Agent 已更新');
+        // Phase 3.1: persist tool_policy sandbox (null clears it)
+        try {
+          await adminAPI.setAgentToolPolicy(editingAgent.id, toolPolicy);
+          showToast('Agent 已更新');
+        } catch (pe: any) {
+          showToast(`Agent 已更新，但策略保存失败: ${pe.message || pe}`, 'error');
+        }
       } else {
         await adminAPI.createAdminAgent(payload);
         showToast('Agent 创建成功');
@@ -612,6 +635,87 @@ const Agents: React.FC = () => {
                   </div>
                 )}
               </div>
+              {editingAgent && (
+                <div style={{ gridColumn: '1 / -1' }}>
+                  <hr style={{ border: 'none', borderTop: '1px solid #E5E7EB', margin: '16px 0' }} />
+                  <div style={{ fontWeight: 600, marginBottom: 12 }}>🛡️ 工具权限沙箱 (tool_policy)</div>
+                  <label style={{ display: 'flex', alignItems: 'center', gap: 8, cursor: 'pointer', marginBottom: 12 }}>
+                    <input type="checkbox" checked={toolPolicy !== null} onChange={e => {
+                      if (e.target.checked) {
+                        setToolPolicy({ allowed_tools: { skill_ids: [], mcp_ids: [] }, max_calls_per_conversation: null, per_round_cap: null, fallback_message: '' });
+                      } else {
+                        setToolPolicy(null);
+                      }
+                    }} />
+                    启用工具/MCP 权限沙箱（限制该 Agent 可调用的工具与调用频次）
+                  </label>
+                  {toolPolicy && (
+                    <div style={{ display: 'flex', flexDirection: 'column', gap: 16 }}>
+                      <div className="form-group" style={{ marginBottom: 0 }}>
+                        <label className="form-label">允许调用的技能（不选 = 禁止调用任何技能）</label>
+                        <div style={{ display: 'flex', flexWrap: 'wrap', gap: 6, maxHeight: 160, overflowY: 'auto', padding: 8, border: '1px solid #E5E7EB', borderRadius: 6 }}>
+                          {availableSkills.length === 0 ? (
+                            <span style={{ color: '#9CA3AF', fontSize: 13 }}>暂无技能</span>
+                          ) : availableSkills.map((skill: any) => {
+                            const checked = (toolPolicy.allowed_tools?.skill_ids || []).includes(skill.id);
+                            return (
+                              <label key={skill.id} style={{ display: 'flex', alignItems: 'center', gap: 4, padding: '4px 10px', borderRadius: 12, fontSize: 12, cursor: 'pointer', background: checked ? '#EEF2FF' : '#F9FAFB', border: `1px solid ${checked ? '#6366F1' : '#E5E7EB'}`, color: checked ? '#6366F1' : '#374151' }}>
+                                <input type="checkbox" style={{ display: 'none' }} checked={checked} onChange={() => {
+                                  const cur = toolPolicy.allowed_tools?.skill_ids || [];
+                                  const next = checked ? cur.filter((x: string) => x !== skill.id) : [...cur, skill.id];
+                                  setToolPolicy({ ...toolPolicy, allowed_tools: { ...(toolPolicy.allowed_tools || {}), skill_ids: next } });
+                                }} />
+                                {skill.skill_name}
+                              </label>
+                            );
+                          })}
+                        </div>
+                      </div>
+                      <div className="form-group" style={{ marginBottom: 0 }}>
+                        <label className="form-label">允许调用的 MCP 服务（不选 = 禁止调用任何 MCP）</label>
+                        <div style={{ display: 'flex', flexWrap: 'wrap', gap: 6, maxHeight: 160, overflowY: 'auto', padding: 8, border: '1px solid #E5E7EB', borderRadius: 6 }}>
+                          {availableMcps.length === 0 ? (
+                            <span style={{ color: '#9CA3AF', fontSize: 13 }}>暂无 MCP 服务</span>
+                          ) : availableMcps.map((m: any) => {
+                            const checked = (toolPolicy.allowed_tools?.mcp_ids || []).includes(m.id);
+                            return (
+                              <label key={m.id} style={{ display: 'flex', alignItems: 'center', gap: 4, padding: '4px 10px', borderRadius: 12, fontSize: 12, cursor: 'pointer', background: checked ? '#EEF2FF' : '#F9FAFB', border: `1px solid ${checked ? '#6366F1' : '#E5E7EB'}`, color: checked ? '#6366F1' : '#374151' }}>
+                                <input type="checkbox" style={{ display: 'none' }} checked={checked} onChange={() => {
+                                  const cur = toolPolicy.allowed_tools?.mcp_ids || [];
+                                  const next = checked ? cur.filter((x: string) => x !== m.id) : [...cur, m.id];
+                                  setToolPolicy({ ...toolPolicy, allowed_tools: { ...(toolPolicy.allowed_tools || {}), mcp_ids: next } });
+                                }} />
+                                {m.name}
+                              </label>
+                            );
+                          })}
+                        </div>
+                      </div>
+                      <div style={{ display: 'grid', gridTemplateColumns: '1fr 1fr', gap: 16 }}>
+                        <div className="form-group" style={{ marginBottom: 0 }}>
+                          <label className="form-label">单对话最大调用次数（留空=不限制）</label>
+                          <input className="admin-form-input" type="number" min="0"
+                            value={toolPolicy.max_calls_per_conversation ?? ''}
+                            onChange={e => setToolPolicy({ ...toolPolicy, max_calls_per_conversation: e.target.value === '' ? null : parseInt(e.target.value) })} />
+                        </div>
+                        <div className="form-group" style={{ marginBottom: 0 }}>
+                          <label className="form-label">单轮最大调用次数（留空=不限制）</label>
+                          <input className="admin-form-input" type="number" min="0"
+                            value={toolPolicy.per_round_cap ?? ''}
+                            onChange={e => setToolPolicy({ ...toolPolicy, per_round_cap: e.target.value === '' ? null : parseInt(e.target.value) })} />
+                        </div>
+                      </div>
+                      <div className="form-group" style={{ marginBottom: 0 }}>
+                        <label className="form-label">额度耗尽提示语（可选）</label>
+                        <textarea className="admin-form-input" rows={2}
+                          value={toolPolicy.fallback_message || ''}
+                          onChange={e => setToolPolicy({ ...toolPolicy, fallback_message: e.target.value })}
+                          placeholder="例如：该智能体已达到工具调用上限，请开启新对话或调整智能体设置。" />
+                      </div>
+                    </div>
+                  )}
+                </div>
+              )}
             </div>
             <div className="modal-footer">
               <button className="admin-btn" onClick={() => setShowModal(false)}>取消</button>

frontend/src/pages/admin/Observability.tsx

@@ -0,0 +1,165 @@
+import { useEffect, useState } from 'react';
+import { adminAPI } from '@/api';
+
+interface Summary {
+  totals: { calls: number; tokens: number; cost: number; users: number };
+  by_model: { model_name: string; calls: number; tokens: number; cost: number }[];
+  by_user: { user_id: string; username: string; calls: number; tokens: number; cost: number }[];
+  daily: { date: string; tokens: number; cost: number; calls: number }[];
+  recent: { trace_id: string | null; model_name: string; tokens: number; cost: number; created_at: string | null }[];
+}
+
+const ACCENT = '#5B5FED';
+const ACCENT_HOVER = '#4A4ECC';
+
+export default function Observability() {
+  const [days, setDays] = useState(30);
+  const [data, setData] = useState<Summary | null>(null);
+  const [loading, setLoading] = useState(false);
+  const [err, setErr] = useState('');
+
+  useEffect(() => {
+    let alive = true;
+    setLoading(true);
+    setErr('');
+    adminAPI.getObservabilitySummary(days)
+      .then((d: Summary) => { if (alive) setData(d); })
+      .catch((e: any) => { if (alive) setErr(e?.message || '加载失败'); })
+      .finally(() => { if (alive) setLoading(false); });
+    return () => { alive = false; };
+  }, [days]);
+
+  const maxTokens = data ? Math.max(1, ...data.daily.map(d => d.tokens)) : 1;
+  const maxModel = data ? Math.max(1, ...data.by_model.map(m => m.tokens)) : 1;
+  const fmt = (n: number) => n.toLocaleString('zh-CN');
+  const fmtCost = (n: number) => `¥${n.toFixed(4)}`;
+
+  const card: React.CSSProperties = {
+    background: '#fff', border: '1px solid #eceef5', borderRadius: 16,
+    padding: 20, boxShadow: '0 1px 3px rgba(20,30,60,0.04)', marginBottom: 18,
+  };
+  const stat: React.CSSProperties = {
+    flex: 1, minWidth: 150, background: '#fff', border: '1px solid #eceef5',
+    borderRadius: 16, padding: 18, boxShadow: '0 1px 3px rgba(20,30,60,0.04)',
+  };
+
+  return (
+    <div style={{ padding: 24, maxWidth: 1160, margin: '0 auto', color: '#1f2330' }}>
+      <div style={{ display: 'flex', alignItems: 'center', justifyContent: 'space-between', marginBottom: 20, flexWrap: 'wrap', gap: 12 }}>
+        <div>
+          <h2 style={{ margin: 0, fontSize: 22, fontWeight: 700 }}>调用可观测</h2>
+          <div style={{ color: '#8a90a2', fontSize: 13, marginTop: 4 }}>
+            媒体 / LLM 调用归因 · 基于 trace_id 关联请求链路（Phase 2.2）
+          </div>
+        </div>
+        <div style={{ display: 'flex', gap: 8 }}>
+          {[7, 30, 90].map(d => (
+            <button key={d} onClick={() => setDays(d)}
+              style={{
+                padding: '7px 14px', borderRadius: 10, cursor: 'pointer', fontSize: 13,
+                border: `1px solid ${days === d ? ACCENT : '#e2e5ee'}`,
+                background: days === d ? ACCENT : '#fff',
+                color: days === d ? '#fff' : '#5b6172', fontWeight: 600,
+                transition: 'all .15s',
+              }}>
+              {d} 天
+            </button>
+          ))}
+        </div>
+      </div>
+
+      {err && <div style={{ ...card, borderColor: '#f3c2c2', color: '#c0392b' }}>{err}</div>}
+      {loading && !data && <div style={{ color: '#8a90a2' }}>加载中…</div>}
+
+      {data && (
+        <>
+          <div style={{ display: 'flex', gap: 14, flexWrap: 'wrap', marginBottom: 18 }}>
+            <div style={stat}><div style={{ color: '#8a90a2', fontSize: 12 }}>调用次数</div><div style={{ fontSize: 24, fontWeight: 700, marginTop: 6 }}>{fmt(data.totals.calls)}</div></div>
+            <div style={stat}><div style={{ color: '#8a90a2', fontSize: 12 }}>Token 消耗</div><div style={{ fontSize: 24, fontWeight: 700, marginTop: 6 }}>{fmt(data.totals.tokens)}</div></div>
+            <div style={stat}><div style={{ color: '#8a90a2', fontSize: 12 }}>成本</div><div style={{ fontSize: 24, fontWeight: 700, marginTop: 6, color: ACCENT }}>{fmtCost(data.totals.cost)}</div></div>
+            <div style={stat}><div style={{ color: '#8a90a2', fontSize: 12 }}>活跃用户</div><div style={{ fontSize: 24, fontWeight: 700, marginTop: 6 }}>{fmt(data.totals.users)}</div></div>
+          </div>
+
+          <div style={card}>
+            <h3 style={{ margin: '0 0 14px', fontSize: 16 }}>按模型</h3>
+            <div style={{ display: 'flex', flexDirection: 'column', gap: 10 }}>
+              {data.by_model.length === 0 && <div style={{ color: '#8a90a2', fontSize: 13 }}>暂无数据</div>}
+              {data.by_model.map(m => (
+                <div key={m.model_name} style={{ display: 'flex', alignItems: 'center', gap: 12 }}>
+                  <div style={{ width: 150, fontSize: 13, fontWeight: 600, overflow: 'hidden', textOverflow: 'ellipsis', whiteSpace: 'nowrap' }}>{m.model_name}</div>
+                  <div style={{ flex: 1, height: 10, background: '#f1f3f9', borderRadius: 6, overflow: 'hidden' }}>
+                    <div style={{ width: `${(m.tokens / maxModel) * 100}%`, height: '100%', background: ACCENT, borderRadius: 6 }} />
+                  </div>
+                  <div style={{ width: 90, textAlign: 'right', fontSize: 13, color: '#5b6172' }}>{fmt(m.tokens)}</div>
+                  <div style={{ width: 90, textAlign: 'right', fontSize: 13, color: ACCENT }}>{fmtCost(m.cost)}</div>
+                </div>
+              ))}
+            </div>
+          </div>
+
+          <div style={card}>
+            <h3 style={{ margin: '0 0 14px', fontSize: 16 }}>每日趋势（Token）</h3>
+            <div style={{ display: 'flex', alignItems: 'flex-end', gap: 6, height: 140, overflowX: 'auto', paddingBottom: 4 }}>
+              {data.daily.length === 0 && <div style={{ color: '#8a90a2', fontSize: 13 }}>暂无数据</div>}
+              {data.daily.map(d => (
+                <div key={d.date} title={`${d.date} · ${fmt(d.tokens)} tokens · ${fmtCost(d.cost)}`}
+                  style={{ display: 'flex', flexDirection: 'column', alignItems: 'center', gap: 4, minWidth: 22 }}>
+                  <div style={{ width: 16, height: `${(d.tokens / maxTokens) * 110}px`, background: ACCENT, borderRadius: '4px 4px 0 0', opacity: 0.85 }} />
+                  <div style={{ fontSize: 9, color: '#aab', transform: 'rotate(-45deg)', whiteSpace: 'nowrap' }}>{d.date.slice(5)}</div>
+                </div>
+              ))}
+            </div>
+          </div>
+
+          <div style={{ display: 'flex', gap: 18, flexWrap: 'wrap' }}>
+            <div style={{ ...card, flex: 1, minWidth: 320 }}>
+              <h3 style={{ margin: '0 0 14px', fontSize: 16 }}>按用户（Top 20）</h3>
+              <table style={{ width: '100%', borderCollapse: 'collapse', fontSize: 13 }}>
+                <thead><tr style={{ color: '#8a90a2', textAlign: 'left' }}>
+                  <th style={th}>用户</th><th style={thR}>调用</th><th style={thR}>Token</th><th style={thR}>成本</th>
+                </tr></thead>
+                <tbody>
+                  {data.by_user.map(u => (
+                    <tr key={u.user_id} style={{ borderTop: '1px solid #f1f3f9' }}>
+                      <td style={td}>{u.username}</td>
+                      <td style={tdR}>{fmt(u.calls)}</td>
+                      <td style={tdR}>{fmt(u.tokens)}</td>
+                      <td style={{ ...tdR, color: ACCENT }}>{fmtCost(u.cost)}</td>
+                    </tr>
+                  ))}
+                  {data.by_user.length === 0 && <tr><td colSpan={4} style={{ ...td, color: '#8a90a2' }}>暂无数据</td></tr>}
+                </tbody>
+              </table>
+            </div>
+          </div>
+
+          <div style={card}>
+            <h3 style={{ margin: '0 0 14px', fontSize: 16 }}>最近调用（trace_id 可下钻）</h3>
+            <table style={{ width: '100%', borderCollapse: 'collapse', fontSize: 13 }}>
+              <thead><tr style={{ color: '#8a90a2', textAlign: 'left' }}>
+                <th style={th}>Trace ID</th><th style={th}>模型</th><th style={thR}>Token</th><th style={thR}>成本</th><th style={thR}>时间</th>
+              </tr></thead>
+              <tbody>
+                {data.recent.map((r, i) => (
+                  <tr key={(r.trace_id || '') + i} style={{ borderTop: '1px solid #f1f3f9' }}>
+                    <td style={{ ...td, fontFamily: 'monospace', fontSize: 12, maxWidth: 200, overflow: 'hidden', textOverflow: 'ellipsis', whiteSpace: 'nowrap' }}>{r.trace_id || '—'}</td>
+                    <td style={td}>{r.model_name}</td>
+                    <td style={tdR}>{fmt(r.tokens)}</td>
+                    <td style={{ ...tdR, color: ACCENT }}>{fmtCost(r.cost)}</td>
+                    <td style={tdR}>{r.created_at || '—'}</td>
+                  </tr>
+                ))}
+                {data.recent.length === 0 && <tr><td colSpan={5} style={{ ...td, color: '#8a90a2' }}>暂无数据</td></tr>}
+              </tbody>
+            </table>
+          </div>
+        </>
+      )}
+    </div>
+  );
+}
+
+const th: React.CSSProperties = { padding: '8px 6px', fontWeight: 600, fontSize: 12 };
+const thR: React.CSSProperties = { ...th, textAlign: 'right' };
+const td: React.CSSProperties = { padding: '8px 6px' };
+const tdR: React.CSSProperties = { ...td, textAlign: 'right', color: '#5b6172' };

migrations/022_add_tool_policy.sql

@@ -0,0 +1,15 @@
+-- Phase 3.1: MarketApp 增加 tool_policy（Agent 工具/MCP 权限沙箱策略）
+-- 幂等：仅当列不存在时才 ALTER
+SET @db = 'aiflow';
+SET @tbl = 'market_apps';
+SET @col = 'tool_policy';
+SET @exists = (
+    SELECT COUNT(*) FROM information_schema.columns
+    WHERE table_schema = @db AND table_name = @tbl AND column_name = @col
+);
+SET @sql = IF(@exists = 0,
+    'ALTER TABLE market_apps ADD COLUMN tool_policy JSON NULL',
+    'SELECT 1');
+PREPARE stmt FROM @sql;
+EXECUTE stmt;
+DEALLOCATE PREPARE stmt;

migrations/023_widen_agent_api_key.sql

@@ -0,0 +1,11 @@
+-- Phase 3.2: 放宽 market_apps.agent_api_key 容量以容纳 Fernet 密文
+SET @db = DATABASE();
+SET @tbl = 'market_apps';
+SET @col = 'agent_api_key';
+SELECT COLUMN_TYPE INTO @ctype FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=@db AND TABLE_NAME=@tbl AND COLUMN_NAME=@col;
+SET @sql = IF(@ctype IS NULL OR @ctype NOT LIKE '%text%',
+  CONCAT('ALTER TABLE ', @tbl, ' MODIFY COLUMN ', @col, ' TEXT NULL COMMENT \'Agent 接入 API Key(3.2 起 Fernet 加密存储)\''),
+  'SELECT 1');
+PREPARE stmt FROM @sql;
+EXECUTE stmt;
+DEALLOCATE PREPARE stmt;