+
+
+
+
+
+
+
+
+```
+
+**A·2. 全部完成再推一次**：监听 `@completed`，一轮分析**全部**结束时回传 `AgentResult[]`：
```vue
```
+> 两个事件可同时用：`agent-completed` 做「来一个渲染一个」的增量更新，`completed` 做「全部到齐」的汇总。
+
**B. 方法（模板 ref）**：随时主动取（不必等事件）：
```vue
@@ -294,14 +446,22 @@ function readOne(id: string) {
```
`AgentResult = { agent_id, name, content, status }`，`content` 即该智能体模型返回的正文（Markdown）。
-`defineExpose` 还暴露了 `start()` / `cancel()`，可由宿主代替按钮触发开始 / 停止。
+`defineExpose` 还暴露了 `reanalyze()` / `start()` / `save()` / `cancel()` / `loadTask(id)` 等方法及
+`running` / `saving` / `hasResults` / `canStart` / `history` 等状态，完整清单见 [§六·二](#六二暴露的方法与状态模板-ref)。
## 七·二、如何保存 + 回显聊天记录
-**保存**：面板里点「保存」即把当前整段聊天记录（各智能体气泡 + 步骤条等）存到后端，按用户隔离。
+**保存**：宿主调用 `panel.save()` 即把当前整段聊天记录（各智能体气泡 + 步骤条等）存到后端，按用户隔离。
传 `:task-id` 时**以它为存储主键**做 upsert（已存在→更新；不存在→用该 id 新建）；不传则首次保存由后端
生成 id（通过 `@update:taskId` 回传，下次再保存即更新这条）。
+> **自动保存**：每轮分析（含单席位重跑）**结束后会自动保存一次**，宿主无需手动点保存也不丢记录；
+> 自动保存同样走 upsert，并照常触发 `saved` / `update:taskId` 事件（首轮会回传新生成的 id）。
+> `panel.save()` 仍保留，供宿主想随时手动存档时调用。
+
+> **进入默认显示最新**：组件挂载时若**没传 `taskId`**，会自动加载并回显**该用户最新的一条**聊天记录
+> （历史按更新时间倒序，取第一条）；传了 `taskId` 则优先回显指定那条。
+
**回显（两种方式）**：
```vue
@@ -316,7 +476,20 @@ const taskId = ref
(""); // 留空=新任务
taskId.value = "task-001"; // 改了之后面板自动回显 task-001
```
-> 方式 2：面板**右上角内置「历史」下拉**——点开选一条历史任务即回显，**无需写任何代码**。
+> 方式 2：**历史下拉已移到宿主侧**（面板不再内置）。宿主读 `panel.history`（`SavedTask[]`）自建下拉，
+> 选中某条时调 `panel.loadTask(id)` 回显；面板会通过 `update:taskName` / `update:brief` 把存档标题 / 简介
+> 回传给宿主，配合 `v-model` 同步宿主自己的输入框。需要刷新列表调 `panel.refreshHistory()`。
+
+```vue
+
+
+
+
+```
要点：先**保存过**、再用**同一个 taskId**（或从历史里选）才会有内容回显；没存过的新 id 第一次进去是空白
（后台会探测一次 `GET /…/{id}` 返回 404，属正常，面板静默处理）。
@@ -325,14 +498,17 @@ taskId.value = "task-001"; // 改了之后面板自动回显 task-
## 八、交互要点（与圆桌 Step2 一致）
-- 输入「任务名称 + 简介」→「开始分析」→ 各智能体**并行**输出。运行期间禁用**写文件**（`write_file`/
- `str_replace`）与**派活/脚本**（`agent_orchestration`/`bash`，防子智能体模仿总控调度）；检索、查看、
- `ask_clarification` 等照常 —— 所以**步骤条 / 协作卡片正常显示**，每个智能体只做自己那份分析。
+- 宿主备好「任务名称 + 简介（+ 模型）」props → 调 `panel.reanalyze()` → 各智能体**并行**输出。
+ 运行期间禁用**写文件**（`write_file`/`str_replace`）与**派活/脚本**（`agent_orchestration`/`bash`，
+ 防子智能体模仿总控调度）；检索、查看、`ask_clarification` 等照常 —— 所以**步骤条 / 协作卡片正常
+ 显示**，每个智能体只做自己那份分析。
- 主区每次只显示**一个**席位的消息列表；**点席位头像切换**要看哪个（单选）。
- 顶部席位状态条显示每个智能体的进行中 / 完成 / 出错。
-- 操作区右侧有**模型切换**下拉（拉取后端 `/api/models`）；选「默认」则用 `model` prop / 配置 / 后端回退。
- 切换作用于**下一次**「开始分析 / 重新分析」，运行中禁用。
-- 「保存」存档；「历史」里选回**回显**；「重新分析」清空重跑。
+- **任务名 / 简介 / 模型 / 按钮 / 历史下拉全部在宿主侧**：模型空 = `model` prop / 配置 / 后端回退；
+ 模型作用于**下一次**`reanalyze()`。
+- `panel.save()` 存档；`panel.loadTask(id)` 回显；`panel.reanalyze()` 清空重跑；`panel.cancel()` 停止。
+- **每轮分析结束自动保存一次**；挂载时没传 `taskId` 会**默认回显最新一条**记录。
+- 结果自动推给宿主：`@agent-completed`（来一个推一个）+ `@completed`（全部到齐再推一次）。
---
diff --git a/parallel-agents-vue/src/App.vue b/parallel-agents-vue/src/App.vue
index 6422be50..c680596e 100644
--- a/parallel-agents-vue/src/App.vue
+++ b/parallel-agents-vue/src/App.vue
@@ -1,5 +1,10 @@
@@ -258,98 +307,17 @@ onMounted(() => {
class="parallel-agents pa-bg flex h-full w-full min-h-0 flex-col"
:class="dark ? 'parallel-agents--dark' : ''"
>
-
-
-
-
-
-
-
-
- 暂无保存的任务
-
-
-
-
-
-
-
-
-
-
+
-
-
-
-
- ⚠️ 未传入任何智能体（agents 为空）
-
-
-
{{ errorMsg }}
-
+ {{ errorMsg }}
+
@@ -383,7 +351,7 @@ onMounted(() => {
v-else
class="flex h-full flex-col items-center justify-center gap-2 text-center"
>
-
填写任务名称与简介，点「开始分析」并行调用各智能体。
+
等待宿主触发「开始 / 重新分析」，并行调用各智能体。
并行运行期间禁止写文件，产出直接呈现在正文。
diff --git a/parallel-agents-vue/src/composables/useParallelRun.ts b/parallel-agents-vue/src/composables/useParallelRun.ts
index 0167af05..b316a9f2 100644
--- a/parallel-agents-vue/src/composables/useParallelRun.ts
+++ b/parallel-agents-vue/src/composables/useParallelRun.ts
@@ -18,12 +18,25 @@ function nextId(): number {
return _seq++;
}
-export function useParallelRun() {
+export interface ParallelRunOptions {
+ /** 单个智能体进入终态（完成 / 待确认 / 出错）时回调一次，用于「一分析完就回传」。 */
+ onAgentSettled?: (agentId: string, status: SeatView["status"]) => void;
+}
+
+export function useParallelRun(opts: ParallelRunOptions = {}) {
const dialogues = ref
([]);
const seats = ref([]);
const running = ref(false);
const abortRef = shallowRef(null);
+ // 本轮已「结算」（回调过 onAgentSettled）的 agentId，去重，避免重复回传。
+ const settled = new Set();
+ function settleAgent(agentId: string, status: SeatView["status"]) {
+ if (settled.has(agentId)) return;
+ settled.add(agentId);
+ opts.onAgentSettled?.(agentId, status);
+ }
+
// 增量节流：累积到 pending，rAF 合并刷新一次，避免逐 token reflow。
const pending = new Map(); // agentId -> 待追加文本
let rafScheduled = false;
@@ -93,6 +106,7 @@ export function useParallelRun() {
}
setSeatStatus(ev.agent_id, "done");
dialogues.value = [...dialogues.value];
+ settleAgent(ev.agent_id, "done");
break;
}
case "agent_clarification": {
@@ -113,6 +127,7 @@ export function useParallelRun() {
}
setSeatStatus(ev.agent_id, "done");
dialogues.value = [...dialogues.value];
+ settleAgent(ev.agent_id, "done");
break;
}
case "agent_error": {
@@ -125,6 +140,7 @@ export function useParallelRun() {
}
setSeatStatus(ev.agent_id, "error");
dialogues.value = [...dialogues.value];
+ settleAgent(ev.agent_id, "error");
break;
}
case "all_done":
@@ -188,6 +204,8 @@ export function useParallelRun() {
}
}
dialogues.value = [...dialogues.value];
+ // 兜底：没收到终态事件就断流的席位也回调一次（按当前席位状态）。
+ for (const s of seats.value) settleAgent(s.agentId, s.status === "error" ? "error" : "done");
running.value = false;
abortRef.value = null;
}
@@ -218,6 +236,7 @@ export function useParallelRun() {
setSeatStatus(args.agentId, "running");
dialogues.value = [...dialogues.value];
+ settled.delete(args.agentId); // 该席位重跑，允许再次回传
running.value = true;
const ac = new AbortController();
abortRef.value = ac;
@@ -235,6 +254,8 @@ export function useParallelRun() {
if (dd.confidence === "并行执行中") dd.confidence = "已完成";
}
dialogues.value = [...dialogues.value];
+ const st = seats.value.find((x) => x.agentId === args.agentId);
+ settleAgent(args.agentId, st?.status === "error" ? "error" : "done");
running.value = false;
abortRef.value = null;
}
@@ -266,6 +287,7 @@ export function useParallelRun() {
cancel();
pending.clear();
bubbleByAgent.clear();
+ settled.clear();
dialogues.value = [];
seats.value = [];
}