feat: 复审任务带回归+增量结构(上一轮意见+修正记录)，根治审核无回归意识打地鼠

pipeline_bidding/bid_flow.py

@@ -613,7 +613,7 @@ async def reconcile_project(sor, project_id, project_name=""):
         needs_qc = [(t, s, imp, rnd) for t, s, imp, rnd, _on in qc_pending
                     if s == "unaudited" or (s == "rework" and t not in over_types)]
         created_qc = []
-        for t, _, _, _ in needs_qc:
+        for t, _, _, rnd in needs_qc:
             if await _open_qc_type_tasks(sor, project_id, t) > 0:
                 continue
             # 竞态守卫（2026-09-02）：该维度分析/重做任务在办 → 不派审核。
@@ -623,10 +623,41 @@ async def reconcile_project(sor, project_id, project_name=""):
             if dim and await _open_dim_tasks(sor, project_id, dim) > 0:
                 acts.append("waiting: 维度「%s」分析任务在办，暂不派 %s 审核" % (dim, t))
                 continue
+            # 回归+增量结构（2026-09-03）：复审任务带上「上一轮意见+本轮修正记录」，
+            # 审核输出必须分两段——上轮意见逐条回归验证、本轮新发现问题。
+            # 根治：审核方每轮全量重读无回归意识，旧问题修了没人验收、
+            # 新问题源源不断，产出在 8.0 分横住冲不过 8.5（实测 chapter_outline r4-r7）。
+            prev_imp, fixes = "", ""
+            if rnd and int(rnd) >= 2:
+                prev = await sor.sqlExe(
+                    "SELECT improvement FROM bid_qc_reviews WHERE project_id=${p}$ "
+                    "AND qc_type=${t}$ AND round=${r}$",
+                    {"p": project_id, "t": t, "r": int(rnd) - 1})
+                await sor.sqlExe("COMMIT", {})
+                if prev:
+                    prev_imp = rec_to_dict(prev[0]).get("improvement") or ""
+                fx = await sor.sqlExe(
+                    "SELECT action, entity, detail, updated_at FROM audit_log "
+                    "WHERE tenant_id=${p}$ AND entity IN ('bid_chapters','bid_doc_requirements',"
+                    "'bid_scoring_items','bid_qualifications','bid_cost_benefit') "
+                    "ORDER BY updated_at DESC LIMIT 30",
+                    {"p": project_id})
+                await sor.sqlExe("COMMIT", {})
+                fixes = "\n".join(
+                    "- [%s] %s/%s: %s" % (rec_to_dict(f).get("updated_at", "")[:16],
+                                          rec_to_dict(f).get("entity", ""),
+                                          rec_to_dict(f).get("action", ""),
+                                          (rec_to_dict(f).get("detail") or "")[:80])
+                    for f in fx[:20])
+            qparams = {"stage": "qc_analysis", "task_kind": "bid_qc", "qc_types": [t]}
+            if prev_imp:
+                qparams["prev_round"] = int(rnd) - 1
+                qparams["prev_improvement"] = prev_imp
+                qparams["recent_fixes"] = fixes
             tid = await create_role_task(
                 sor, project_id, R_QC,
                 "%s 解析产出契合度审核（%s）" % (pname, t),
-                {"stage": "qc_analysis", "task_kind": "bid_qc", "qc_types": [t]})
+                qparams)
             acts.append("created: QC 审核任务 %s（%s）" % (tid, t))
             created_qc.append(t)
         if created_qc: