fix(ai): v0.17.0 审查即修——笔记级精修闭环/双入口 target_kind 分发/重生成沿用策略档位/流式订阅容错（P0x2 P1x1 P2x3）

Author: Aparencia

app/src-tauri/src/commands_ai_enrich.rs

@@ -144,6 +144,7 @@ pub async fn ai_enrich_start(
         created_at: crate::db_sessions_rows::unix_seconds(),
         finished_at: None,
         adopted: false,
+        target_kind: Some("note".to_string()),
     }) {
         eprintln!("[AiTasks] enrich 任务 {} 落库失败（不阻断 AI 调用；重启后不可恢复）: {}", task_id, e);
     }

app/src-tauri/src/commands_ai_note_refine.rs

@@ -120,6 +120,7 @@ pub async fn ai_note_refine_start(
         created_at: crate::db_sessions_rows::unix_seconds(),
         finished_at: None,
         adopted: false,
+        target_kind: Some("note".to_string()),
     }) {
         eprintln!("[AiTasks] note-refine 任务 {} 落库失败（不阻断 AI 调用；重启后不可恢复）: {}", task_id, e);
     }

app/src-tauri/src/commands_ai_refine.rs

@@ -224,6 +224,7 @@ pub async fn ai_refine_start(
         created_at: crate::db_sessions_rows::unix_seconds(),
         finished_at: None,
         adopted: false,
+        target_kind: Some("session".to_string()),
     }) {
         eprintln!("[AiTasks] refine 任务 {} 落库失败（不阻断 AI 调用；重启后不可恢复）: {}", task_id, e);
     }

app/src-tauri/src/db_ai_chat_tests.rs

@@ -29,6 +29,7 @@ fn task_rec(task_id: u64, state: &str) -> AiTaskRecord {
         created_at: 1,
         finished_at: None,
         adopted: false,
+        target_kind: None,
     }
 }
 

app/src-tauri/src/db_ai_tasks.rs

@@ -28,6 +28,10 @@ pub struct AiTaskRecord {
     pub ref_id: i64,
     /// 状态（pending|running|succeeded|failed|partial_failed）
     pub state: String,
+    /// 目标类别（v0.17.0 审查修复：session=会话级精修 | note=笔记级精修/补充；
+    /// NULL=旧数据（展示层按 session 语义兜底——后端不猜，防双入口错跳）
+    #[serde(default)]
+    pub target_kind: Option<String>,
     /// 成功结果 JSON（AiRefineResult/AiEnrichResult；失败/进行中 NULL）
     pub result_json: Option<String>,
     /// 成本（元；采纳落库后回填）
@@ -61,6 +65,7 @@ impl Db {
                 error TEXT,
                 slices INTEGER,
                 trajectory_json TEXT,
+                target_kind TEXT,
                 created_at INTEGER NOT NULL,
                 finished_at INTEGER,
                 adopted INTEGER NOT NULL DEFAULT 0
@@ -77,6 +82,14 @@ impl Db {
             "trajectory_json",
             "ALTER TABLE ai_tasks ADD COLUMN trajectory_json TEXT",
         )?;
+        // v0.17.0 审查修复：目标类别列（session|note——双入口错跳修复）。
+        // 幂等迁移；旧数据 NULL（展示层按 session 语义兜底——不猜）。
+        crate::db_migrations::ensure_column(
+            &conn,
+            "ai_tasks",
+            "target_kind",
+            "ALTER TABLE ai_tasks ADD COLUMN target_kind TEXT",
+        )?;
         Ok(())
     }
 
@@ -86,8 +99,8 @@ impl Db {
         conn.execute(
             "INSERT OR REPLACE INTO ai_tasks
                 (task_id, op_type, ref_id, state, result_json, cost_yuan, elapsed_ms,
-                 model, error, slices, created_at, finished_at, adopted)
-             VALUES (?1,?2,?3,?4,?5,?6,?7,?8,?9,?10,?11,?12,?13)",
+                 model, error, slices, target_kind, created_at, finished_at, adopted)
+             VALUES (?1,?2,?3,?4,?5,?6,?7,?8,?9,?10,?11,?12,?13,?14)",
             params![
                 rec.task_id as i64,
                 rec.op_type,
@@ -99,6 +112,7 @@ impl Db {
                 rec.model,
                 rec.error,
                 rec.slices.map(|s| s as i64),
+                rec.target_kind.as_deref(),
                 rec.created_at,
                 rec.finished_at,
                 rec.adopted as i64,
@@ -188,7 +202,7 @@ impl Db {
         let conn = self.conn.lock().unwrap_or_else(|e| e.into_inner());
         let mut stmt = conn.prepare(
             "SELECT task_id, op_type, ref_id, state, result_json, cost_yuan, elapsed_ms,
-                    model, error, slices, created_at, finished_at, adopted
+                    model, error, slices, target_kind, created_at, finished_at, adopted
              FROM ai_tasks
              WHERE state='succeeded' AND adopted=0 AND result_json IS NOT NULL
              ORDER BY created_at DESC LIMIT ?1",
@@ -207,7 +221,7 @@ impl Db {
         let conn = self.conn.lock().unwrap_or_else(|e| e.into_inner());
         let mut stmt = conn.prepare(
             "SELECT task_id, op_type, ref_id, state, result_json, cost_yuan, elapsed_ms,
-                    model, error, slices, created_at, finished_at, adopted
+                    model, error, slices, target_kind, created_at, finished_at, adopted
              FROM ai_tasks
              WHERE op_type='refine' AND ref_id=?1 AND state='succeeded'
                    AND adopted=0 AND result_json IS NOT NULL
@@ -225,7 +239,7 @@ impl Db {
         let conn = self.conn.lock().unwrap_or_else(|e| e.into_inner());
         let mut stmt = conn.prepare(
             "SELECT task_id, op_type, ref_id, state, result_json, cost_yuan, elapsed_ms,
-                    model, error, slices, created_at, finished_at, adopted
+                    model, error, slices, target_kind, created_at, finished_at, adopted
              FROM ai_tasks
              WHERE op_type=?1
              ORDER BY created_at DESC LIMIT ?2",
@@ -239,7 +253,7 @@ impl Db {
         let conn = self.conn.lock().unwrap_or_else(|e| e.into_inner());
         let mut stmt = conn.prepare(
             "SELECT task_id, op_type, ref_id, state, result_json, cost_yuan, elapsed_ms,
-                    model, error, slices, created_at, finished_at, adopted
+                    model, error, slices, target_kind, created_at, finished_at, adopted
              FROM ai_tasks WHERE task_id=?1",
         )?;
         let mut rows = stmt.query_map(params![task_id as i64], map_record)?;
@@ -280,9 +294,10 @@ fn map_record(row: &rusqlite::Row<'_>) -> rusqlite::Result<AiTaskRecord> {
         model: row.get(7)?,
         error: row.get(8)?,
         slices: row.get::<_, Option<i64>>(9)?.map(|v| v as usize),
-        created_at: row.get(10)?,
-        finished_at: row.get(11)?,
-        adopted: row.get::<_, i64>(12)? != 0,
+        target_kind: row.get(10)?,
+        created_at: row.get(11)?,
+        finished_at: row.get(12)?,
+        adopted: row.get::<_, i64>(13)? != 0,
     })
 }
 

app/src-tauri/src/db_ai_tasks_tests.rs

@@ -27,6 +27,7 @@ fn rec(task_id: u64, op: &str, ref_id: i64, state: &str) -> AiTaskRecord {
         created_at: task_id as i64,
         finished_at: if state == "succeeded" { Some(task_id as i64) } else { None },
         adopted: false,
+        target_kind: None,
     }
 }
 

app/src/components/AiRefineCard.tsx

@@ -18,9 +18,11 @@ import type {
   AiRefineResult,
   AiSettingsView,
   AiTaskState,
+  StrategyOverride,
 } from "../types";
 import RefineWorkbench from "./RefineWorkbench";
 import RefineLaunchDialog from "./RefineLaunchDialog";
+import { overrideFromInfo } from "../utils/refineStrategy";
 
 const btn: React.CSSProperties = { padding: "5px 10px", cursor: "pointer", fontSize: 12, borderRadius: 6 };
 
@@ -37,7 +39,7 @@ export default function AiRefineCard({
   onAutoTaskMissing?: () => void;
 }) {
   const [settings, setSettings] = useState<AiSettingsView | null>(null);
-  const [phase, setPhase] = useState<"idle" | "consent" | "confirm" | "running" | "done" | "failed">("idle");
+  const [phase, setPhase] = useState<"idle" | "running" | "done" | "failed">("idle");
   const [progress, setProgress] = useState<{ finished: number; total: number } | null>(null);
   const [result, setResult] = useState<AiRefineResult | null>(null);
   const [failure, setFailure] = useState<AiTaskFailureLike | null>(null);
@@ -126,8 +128,8 @@ export default function AiRefineCard({
     startPolling(taskId);
   }, [onTaskStarted, startPolling]);
 
-  /** ② 启动任务（工作台「重新生成」路径——沿全局默认偏好；策略选择在主发起对话框） */
-  const start = async () => {
+  /** ② 启动任务（重生成路径——沿用本次策略档位；主发起对话框传策略） */
+  const start = async (strategy?: StrategyOverride) => {
     setMsg("");
     setPhase("running");
     // 契约修复（2026-08-21 真机"排队中"根因）：Rust AiTaskHandle 为 camelCase
@@ -136,6 +138,7 @@ export default function AiRefineCard({
     const handle = await invoke<{ taskId: number; state: AiTaskState }>("ai_refine_start", {
       sessionId,
       authorized: true,
+      strategy: strategy ?? null,
     }).catch((e) => {
       setMsg(`启动失败：${e}`);
       setPhase("idle");
@@ -184,9 +187,6 @@ export default function AiRefineCard({
         )}
       </div>
 
-      {/* 授权卡由 RefineLaunchDialog 承载（v0.17.0——策略/成本/授权一屏编排） */}
-      {phase === "consent" && null}
-
       {/* 任务进行中（切片进度） */}
       {phase === "running" && (
         <div style={{ fontSize: 12, color: "#4b5563" }}>
@@ -225,7 +225,10 @@ export default function AiRefineCard({
               // 审查修复：regenerate 旁路 onTaskStarted 导航（不离开当前页）
               onRegenerate={async () => {
                 skipNavigateRef.current = true;
-                try { await start(); } finally { skipNavigateRef.current = false; }
+                try {
+                  // 审查修复：重生成沿用本次策略档位（首版与重生成同档位）
+                  await start(result.strategy ? overrideFromInfo(result.strategy) : undefined);
+                } finally { skipNavigateRef.current = false; }
               }}
               onClose={() => setShowWorkbench(false)}
               onApplied={(id) => { reset(); onApplied?.(id); }}