- 多智能体会商全流程报错与关键事件（含后台挂起卡死、超时、产物缺失等） + 多智能体会商全流程报错日志（席位失败 / 空交付 / 超时 / 模型容错 / 产物缺失 / 崩溃等；运行进度类 info 不再收集）
`. Missing/revoked/non-`view` codes all return 404. | | **Scheduled Tasks** (`/api/scheduled-tasks`) | Per-user cron-like agent tasks. `GET/POST /` - list/create owned tasks; `PATCH/DELETE /{id}` - update/delete (owner); `POST /{id}/{pause,resume,trigger}`; `GET /{id}/runs`, `GET /runs/{rid}`, run-file preview/edit/download; `GET /runs/{rid}/messages` - agent messages for the run's underlying agent run (used to inspect a stuck/running run; authorized via `_load_run`); `GET /runs/{rid}/html` - generated HTML document for an `html_page` run; `DELETE /runs/{rid}` - owner-scoped, with an admin fallback so admins can delete any user's run; publish/subscribe under `/{id}/{publish,unpublish,subscribe}` and `GET /published`. **Admin (cross-user):** `GET /admin/all` - every task; `PATCH/DELETE /admin/{id}` - edit/delete any task; `POST /admin/{id}/trigger`; `GET /admin/{id}/runs`. Admin routes require `system_role == "admin"`. | diff --git a/offline-backend-20260512/backend/app/gateway/routers/roundtable_drafts.py b/offline-backend-20260512/backend/app/gateway/routers/roundtable_drafts.py index 9ef5ccd5..75574acf 100644 --- a/offline-backend-20260512/backend/app/gateway/routers/roundtable_drafts.py +++ b/offline-backend-20260512/backend/app/gateway/routers/roundtable_drafts.py @@ -47,6 +47,8 @@ class DraftMetaResponse(BaseModel): task_id: str | None = None title: str = "" furthest_step: int = 1 + # 本次会商所用业务链名（历史卡片展示）；无链条（自由/recommend 模式）时为 None。 + chain_title: str | None = None created_at: datetime | str | None = None updated_at: datetime | str | None = None # 最近一次后台作业的状态（Phase 6 历史下拉「进行中」loading 用）；无作业时为 None。 diff --git a/offline-backend-20260512/backend/app/gateway/routers/roundtable_task_drafts.py b/offline-backend-20260512/backend/app/gateway/routers/roundtable_task_drafts.py index b0696cdd..1bea7a18 100644 --- a/offline-backend-20260512/backend/app/gateway/routers/roundtable_task_drafts.py +++ b/offline-backend-20260512/backend/app/gateway/routers/roundtable_task_drafts.py @@ -42,6 +42,8 @@ class TaskDraftMetaResponse(BaseModel): task_id: str title: str = "" furthest_step: int = 1 + # 本次会商所用业务链名（历史卡片展示）；无链条（自由/recommend 模式）时为 None。 + chain_title: str | None = None created_at: datetime | str | None = None updated_at: datetime | str | None = None # Latest background-job status for this draft (history-dropdown loading badge). diff --git a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_diagnostics/__init__.py b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_diagnostics/__init__.py index 2afba98c..99204114 100644 --- a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_diagnostics/__init__.py +++ b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_diagnostics/__init__.py @@ -41,10 +41,17 @@ def get_default_store() -> RoundtableDiagnosticRepository | None: async def record_diagnostic(store: RoundtableDiagnosticRepository | None = None, **fields: Any) -> None: - """Best-effort 写一条诊断事件。``store`` 缺省用进程级默认仓储。任何异常静默吞掉。""" + """Best-effort 写一条诊断事件。``store`` 缺省用进程级默认仓储。任何异常静默吞掉。 + + 会商诊断**只收集报错日志**：``info`` 级是纯运行进度（begin/consensus/gather/job_started + 等「运行日志」），对排障没价值、还会淹没真正的报错，直接不落库；只保留 ``warning`` / + ``error``（席位失败、空交付、超时、模型容错、产物缺失、崩溃等）。 + """ repo = store or _default_store if repo is None: return + if str(fields.get("level") or "").strip().lower() == "info": + return try: await repo.record(**fields) except Exception: # noqa: BLE001 — 诊断日志写失败绝不打断会商 diff --git a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_drafts/sql.py b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_drafts/sql.py index aeb74b88..2ca3ddcb 100644 --- a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_drafts/sql.py +++ b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_drafts/sql.py @@ -11,6 +11,7 @@ All write/read paths are scoped by ``user_id`` for ownership isolation. from __future__ import annotations import json +import re from datetime import UTC, datetime from typing import Any @@ -24,6 +25,29 @@ from deerflow.persistence.roundtable_drafts.model import ( _UNSET = object() +# 业务链名抽取：在已加载进内存的 step2 JSON 串里直接找 `"chain":{...,"title":"X"}`， +# 不整体 json.loads（step2 是 LONGTEXT 大块），只做一次廉价正则扫描。`"chain":null` +# （recommend/自由模式）不匹配 → 返回 None。`[^{}]*?` 限定在 chain 对象内（{id,title} +# 无嵌套花括号）。 +_CHAIN_TITLE_RE = re.compile(r'"chain"\s*:\s*\{[^{}]*?"title"\s*:\s*"((?:\\.|[^"\\])*)"') + + +def _extract_chain_title(step2_raw: Any) -> str | None: + """从 step2 原始 JSON 串里抽取所用业务链名（无链条 → None，前端显示「自由模式」）。""" + if not isinstance(step2_raw, str) or not step2_raw: + return None + m = _CHAIN_TITLE_RE.search(step2_raw) + if not m: + return None + title = m.group(1) + try: + # 还原 JSON 字符串转义（\" \\ \n \uXXXX 等）。 + title = json.loads(f'"{title}"') + except Exception: + pass + title = title.strip() + return title or None + def _loads(value: Any) -> Any: if not isinstance(value, str): @@ -56,6 +80,8 @@ class RoundtableDraftRepository: "task_id": row.task_id, "title": row.title, "furthest_step": row.furthest_step, + # 所用业务链名（历史卡片展示用）；无链条 → None → 前端显示「自由模式」。 + "chain_title": _extract_chain_title(row.step2), "created_at": row.created_at.isoformat() if isinstance(row.created_at, datetime) else row.created_at, "updated_at": row.updated_at.isoformat() if isinstance(row.updated_at, datetime) else row.updated_at, } diff --git a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_task_drafts/sql.py b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_task_drafts/sql.py index c415f62d..fad0ef0a 100644 --- a/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_task_drafts/sql.py +++ b/offline-backend-20260512/backend/packages/harness/deerflow/persistence/roundtable_task_drafts/sql.py @@ -15,6 +15,7 @@ in ``PortableLongText`` and round-tripped with ``json.dumps`` / ``json.loads``. from __future__ import annotations import json +import re from datetime import UTC, datetime from typing import Any @@ -25,6 +26,27 @@ from deerflow.persistence.roundtable_task_drafts.model import RoundtableTaskDraf _UNSET = object() +# 业务链名抽取：在已加载进内存的 step2 JSON 串里直接找 `"chain":{...,"title":"X"}`， +# 不整体 json.loads（step2 是 LONGTEXT 大块）。`"chain":null`（自由模式）不匹配 → None。 +# 与 roundtable_drafts/sql.py 保持一致。 +_CHAIN_TITLE_RE = re.compile(r'"chain"\s*:\s*\{[^{}]*?"title"\s*:\s*"((?:\\.|[^"\\])*)"') + + +def _extract_chain_title(step2_raw: Any) -> str | None: + """从 step2 原始 JSON 串里抽取所用业务链名（无链条 → None，前端显示「自由模式」）。""" + if not isinstance(step2_raw, str) or not step2_raw: + return None + m = _CHAIN_TITLE_RE.search(step2_raw) + if not m: + return None + title = m.group(1) + try: + title = json.loads(f'"{title}"') + except Exception: + pass + title = title.strip() + return title or None + def _loads(value: Any) -> Any: if not isinstance(value, str): @@ -55,6 +77,8 @@ class RoundtableTaskDraftRepository: "task_id": row.task_id, "title": row.title, "furthest_step": row.furthest_step, + # 所用业务链名（历史卡片展示用）；无链条 → None → 前端显示「自由模式」。 + "chain_title": _extract_chain_title(row.step2), "created_at": row.created_at.isoformat() if isinstance(row.created_at, datetime) else row.created_at, "updated_at": row.updated_at.isoformat() if isinstance(row.updated_at, datetime) else row.updated_at, }