From 6b4b5e571f52d3d7e9df38a1acaecefdb91ef500 Mon Sep 17 00:00:00 2001
From: admin <jerryhaozhang@gmail.com>
Date: Tue, 13 Oct 2026 11:18:53 +0800
Subject: [PATCH] =?UTF-8?q?feat(bioflow):=20=E5=B0=B1=E7=BB=AA=E5=8D=A1+?=
 =?UTF-8?q?=E7=89=88=E6=9C=AC=E5=8C=96=E5=8D=A1=E6=8E=A5=E7=BA=BF=E2=80=94?=
 =?UTF-8?q?=E2=80=94=E5=B7=A5=E5=85=B7=E7=BB=93=E6=9E=9C=E7=BB=8F=20payloa?=
 =?UTF-8?q?d.bioflow=20=E4=B8=8B=E5=8F=91=E5=89=8D=E7=AB=AF=E6=B8=B2?=
 =?UTF-8?q?=E6=9F=93=20(#009)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 agent/qa/src/rag/qa_v1_1_73/bioflow_agent.py | 42 ++++++++++++++++++++
 agent/qa/src/rag/qa_v1_1_73/tool_runner.py   |  2 +
 ui/src/stores/chat.js                        | 10 ++++-
 3 files changed, 53 insertions(+), 1 deletion(-)

diff --git a/agent/qa/src/rag/qa_v1_1_73/bioflow_agent.py b/agent/qa/src/rag/qa_v1_1_73/bioflow_agent.py
index 365e312..68ec3ec 100644
--- a/agent/qa/src/rag/qa_v1_1_73/bioflow_agent.py
+++ b/agent/qa/src/rag/qa_v1_1_73/bioflow_agent.py
@@ -291,6 +291,28 @@ def _empty_audit() -> Dict[str, Any]:
     return {"rounds": 0, "tool_calls": 0, "used_json_fallback": False, "tool_names": [], "errors": []}
 
 
+def _map_readiness(data: Dict[str, Any]) -> Dict[str, Any]:
+    """check_readiness 结果 → 就绪卡字段 {ready, quadrants:[{name,ok}]}。"""
+    inner = data.get("result", data) if isinstance(data, dict) else {}
+    quadrants = []
+    for key in ("environment", "reference", "space", "budget"):
+        q = inner.get(key) or {}
+        quadrants.append({"name": key, "ok": bool(q.get("ok"))})
+    return {"ready": bool(inner.get("ready")), "quadrants": quadrants}
+
+
+def _map_versioning(data: Dict[str, Any]) -> Dict[str, Any]:
+    """propose_change 结果 → 版本化卡字段 {plan_revision, run_id, affected_stages, based_on_revision}。"""
+    inner = data.get("result", data) if isinstance(data, dict) else {}
+    affected = inner.get("affected") or []
+    return {
+        "plan_revision": "",
+        "run_id": "",
+        "affected_stages": list(affected),
+        "based_on_revision": None,
+    }
+
+
 def _make_payload(
     question: str,
     answer: str,
@@ -299,6 +321,8 @@ def _make_payload(
     capabilities: Optional[List[str]] = None,
     active_job_id: Optional[str] = None,
     chain: Optional[str] = None,
+    readiness: Optional[Dict[str, Any]] = None,
+    versioning: Optional[Dict[str, Any]] = None,
 ) -> Dict[str, Any]:
     payload: Dict[str, Any] = {
         "success": True,
@@ -318,6 +342,10 @@ def _make_payload(
         payload["bioflow"]["active_job_id"] = str(active_job_id)
     if chain:
         payload["bioflow"]["chain"] = str(chain)
+    if readiness:
+        payload["bioflow"]["readiness"] = readiness
+    if versioning:
+        payload["bioflow"]["versioning"] = versioning
     return payload
 
 
@@ -647,6 +675,18 @@ def _try_bioflow_agent_impl(
     if not answer:
         return None
 
+    tool_results = (audit or {}).get("tool_results") or {}
+    readiness = None
+    versioning = None
+    for name, result_text in tool_results.items():
+        data = _try_parse_json(result_text)
+        if not isinstance(data, dict):
+            continue
+        if name == "check_readiness":
+            readiness = _map_readiness(data)
+        elif name == "propose_change":
+            versioning = _map_versioning(data)
+
     return _make_payload(
         question,
         answer,
@@ -654,6 +694,8 @@ def _try_bioflow_agent_impl(
         capabilities=[m.name for m in manifests],
         active_job_id=(bioflow or {}).get("active_job_id"),
         chain=(bioflow or {}).get("chain"),
+        readiness=readiness,
+        versioning=versioning,
     )
 
 
diff --git a/agent/qa/src/rag/qa_v1_1_73/tool_runner.py b/agent/qa/src/rag/qa_v1_1_73/tool_runner.py
index 1e4b637..260d448 100644
--- a/agent/qa/src/rag/qa_v1_1_73/tool_runner.py
+++ b/agent/qa/src/rag/qa_v1_1_73/tool_runner.py
@@ -66,6 +66,7 @@ class ToolRunner:
             "tool_calls": 0,
             "used_json_fallback": False,
             "tool_names": [],
+            "tool_results": {},
             "errors": [],
         }
         messages: List[Dict[str, Any]] = []
@@ -125,6 +126,7 @@ class ToolRunner:
                         "function": {"name": name or "unknown", "arguments": json.dumps(arguments, ensure_ascii=False)},
                     }
                 )
+                audit["tool_results"][name] = result_text
                 messages.append({"role": "tool", "tool_call_id": call_id, "content": result_text})
             assistant_message["tool_calls"] = tool_call_blocks
             messages.append(assistant_message)
diff --git a/ui/src/stores/chat.js b/ui/src/stores/chat.js
index 079e8ef..8643c8b 100644
--- a/ui/src/stores/chat.js
+++ b/ui/src/stores/chat.js
@@ -2549,10 +2549,18 @@ export const useChatStore = defineStore('chat', {
               const p = ev.payload || {};
               const answer = p.answer || '';
               updateLocal(() => {
-                aMsg.blocks = [
+                const blocks = [
                   { type: 'bioflow_path', status: 'done', candidates: [] },
                   { type: 'text', html: answer },
                 ];
+                const bfPayload = p.bioflow || {};
+                if (bfPayload.readiness) {
+                  blocks.push({ type: 'bioflow_readiness', ...bfPayload.readiness, error: null });
+                }
+                if (bfPayload.versioning) {
+                  blocks.push({ type: 'bioflow_versioning', ...bfPayload.versioning });
+                }
+                aMsg.blocks = blocks;
                 aMsg.raw = p.raw ?? p;
                 aMsg.status = 'done';
               });