fix(task-settle): 僵尸 goal 收口漏看 cancelled+archived 的 task (T-mt664821)

settleGoalIfAllTasksDone 用 listGoalTasks 默认口径（includeArchived: false）取 task 列表，task 若同时被 cancelled+archived 会被过滤掉， tasks.length 提前归零直接 return null，goal 永远收不了口——僵尸扫描等于没扫到。实证：G-mt0a6upq-a98e / G-mt0a6upq-52ee 两条 goal 卡在 active 超 17 小时未被收口，两条 task 均已 cancelled+archived。改成 includeArchived: true 取全量后再按语义过滤：draft 任务归档（人删掉的需求）继续不参与判定，但 cancelled/completed/failed 之后再归档（结果已发生只是从界面收起）必须照样计入，否则会反过来破坏"归档掉的草稿不参与判定"这条既有行为（拆分产出可删的验收用例钉住的就是这个）。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>

fix(task-settle): 僵尸 goal 收口漏看 cancelled+archived 的 task (T-mt664821)
settleGoalIfAllTasksDone 用 listGoalTasks 默认口径（includeArchived: false）取 task 列表，task 若同时被 cancelled+archived 会被过滤掉， tasks.length 提前归零直接 return null，goal 永远收不了口——僵尸扫描等于没扫到。实证：G-mt0a6upq-a98e / G-mt0a6upq-52ee 两条 goal 卡在 active 超 17 小时未被收口，两条 task 均已 cancelled+archived。改成 includeArchived: true 取全量后再按语义过滤：draft 任务归档（人删掉的需求）继续不参与判定，但 cancelled/completed/failed 之后再归档（结果已发生只是从界面收起）必须照样计入，否则会反过来破坏"归档掉的草稿不参与判定"这条既有行为（拆分产出可删的验收用例钉住的就是这个）。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
yibo
1 parent 2237621d
Showing 2 changed files with 30 additions and 1 deletions
server/services/task-settle.js
server/tests/unit/goal-task-acceptance.test.js
@@ -232,7 +232,15 @@ function settleRootRun(run, to) {
  */
 function settleGoalIfAllTasksDone(goalId) {
   const wdb = require('./work-graph-db');
-  const tasks = wdb.listGoalTasks(goalId);
+  // 默认口径（includeArchived: false）是给 UI 列表用的「别显示归档项」，不是「这条 task 不存在了」。
+  // 但归档并不都一个意思：draft 任务归档 = 人删掉了这条需求（DELETE /tasks 的 taskHoldsRun 闸门
+  // 保证非终态里能被归档的只剩 draft），这类不该参与判定（下面那条「拆分产出可删」的用例钉住的
+  // 就是这个）；而 cancelled/completed/failed 之后再归档 = 结果已经发生，只是从界面收起来，
+  // 必须照样计入——否则用默认口径直接漏看这条 task，tasks.length 提前掉到 0 就 return null，
+  // goal 永远收不了口（T-mt664821：G-mt0a6upq-a98e / G-mt0a6upq-52ee 卡在 active 超 17 小时
+  // 未被僵尸扫描收口，两条 task 都是 cancelled+archived）。
+  const tasks = wdb.listGoalTasks(goalId, { includeArchived: true })
+    .filter((t) => !t.archived_at || wdb.TASK_TERMINAL_STATUS.includes(t.status));
   if (!tasks.length) return null;
   if (tasks.some((t) => !wdb.TASK_TERMINAL_STATUS.includes(t.status))) return null;
@@ -774,6 +774,27 @@ describe(&#39;27-P3C 批 1 验收（§八 4 / 5 / 6 / 10 / 11 / 12b）&#39;, () =&gt; {
     expect(await settle.sweepStuckActiveGoals()).toBe(0);
   });
+  it('僵尸扫描：task 被同时 cancelled+archived 也能收口，不会因 listGoalTasks 默认过滤归档项而误判 tasks.length===0（T-mt664821）', async () => {
+    const cid = newCompany();
+    const settle = require('../../services/task-settle');
+
+    const goal = wdb.createGoal({ companyId: cid, title: '被取消并归档的目标', description: '人工取消后归档' });
+    const t = wdb.createTask({ goalId: goal.id, companyId: cid, title: 'T', description: 'T' });
+    wdb.updateTask(t.id, { status: 'cancelled', archivedAt: new Date().toISOString() });
+    wdb.updateGoal(goal.id, { status: 'active', dispatchedAt: new Date().toISOString() });
+    expect(wdb.getGoal(goal.id).status).toBe('active');
+
+    // 默认口径（includeArchived: false）会把这条 task 过滤掉，看见空列表——回归防线
+    expect(wdb.listGoalTasks(goal.id)).toHaveLength(0);
+    expect(wdb.listGoalTasks(goal.id, { includeArchived: true })).toHaveLength(1);
+
+    const settled = await settle.sweepStuckActiveGoals();
+    expect(settled).toBe(1);
+    expect(wdb.getGoal(goal.id).status).toBe('failed'); // 唯一 task 是 cancelled，判词跟着它走
+
+    expect(await settle.sweepStuckActiveGoals()).toBe(0);
+  });
+
   it('汇报环节同步抛出时只丢一行日志，不变成 unhandledRejection 杀进程（缺陷 3）', async () => {
     // reportGoalOutcome 有两条同步抛出面（terminalAgentId 读库、OkrService.updateNode 的 fs 写）。
     // 批 1 走同步路径，异常由 graph-run-sse 的 try/catch 兜住；这条路跑在 setImmediate 的 async