perf(notes): 清偿TD-A——会话转笔记三命令迁spawn_blocking

Author: Aparencia

app/src-tauri/src/commands_session_note.rs

@@ -157,26 +157,35 @@ fn convert_to_note(
 }
 
 /// 会话 → 笔记：转写段 + OCR 块经 note_filter 净化管线，一键落库（REQ-010 闭环）。
+///
+/// @ai-context: TD-2026-08-20-A 清偿：主体迁 spawn_blocking——v0.7.6 起管线叠加
+///              analyze_session_opt 全量分析（章节/术语/重点等），千段长会话
+///              可达秒级，不得占用异步运行时线程（review_text_filter 先例）。
 #[tauri::command]
 pub async fn session_to_note(
     state: State<'_, AppState>,
     id: i64,
     title: Option<String>,
     ai_decisions: Option<Vec<TextFilterDecision>>,
 ) -> Result<Note, String> {
-    convert_to_note(
-        &state.db,
-        &state.ui_junk,
-        &PurifyEnv {
-            config: state.purify.clone(),
-            symbol: state.symbol_normalize.clone(),
-            corrections: state.ocr_corrections.clone(),
-        },
-        &state.data_dir,
-        id,
-        title,
-        ai_decisions,
-    )
+    let state: AppState = (*state).clone();
+    tauri::async_runtime::spawn_blocking(move || {
+        convert_to_note(
+            &state.db,
+            &state.ui_junk,
+            &PurifyEnv {
+                config: state.purify.clone(),
+                symbol: state.symbol_normalize.clone(),
+                corrections: state.ocr_corrections.clone(),
+            },
+            &state.data_dir,
+            id,
+            title,
+            ai_decisions,
+        )
+    })
+    .await
+    .map_err(|e| format!("转笔记任务失败: {}", e))?
 }
 
 /// 批量转笔记核心编排（v0.7.1：部分成功语义——单条失败不阻塞其他）。
@@ -238,22 +247,29 @@ pub fn run_batch_conversion(
 }
 
 /// 批量转笔记（v0.7.1 会话体验：列表勾选批量转化）。
+/// @ai-context: TD-2026-08-20-A 清偿：迁 spawn_blocking（≤50 条 × 全量分析，
+///              长会话批量可达数十秒——不得阻塞异步运行时线程）。
 #[tauri::command]
 pub async fn batch_session_to_note(
     state: State<'_, AppState>,
     ids: Vec<i64>,
 ) -> Result<BatchNoteResult, String> {
-    run_batch_conversion(
-        &state.db,
-        &state.ui_junk,
-        &PurifyEnv {
-            config: state.purify.clone(),
-            symbol: state.symbol_normalize.clone(),
-            corrections: state.ocr_corrections.clone(),
-        },
-        &state.data_dir,
-        ids,
-    )
+    let state: AppState = (*state).clone();
+    tauri::async_runtime::spawn_blocking(move || {
+        run_batch_conversion(
+            &state.db,
+            &state.ui_junk,
+            &PurifyEnv {
+                config: state.purify.clone(),
+                symbol: state.symbol_normalize.clone(),
+                corrections: state.ocr_corrections.clone(),
+            },
+            &state.data_dir,
+            ids,
+        )
+    })
+    .await
+    .map_err(|e| format!("批量转笔记任务失败: {}", e))?
 }
 
 /// 会话笔记预览（REQ-081）：过滤后只读预览——不落库、不改库。
@@ -270,19 +286,26 @@ pub async fn preview_session_note(
     state: State<'_, AppState>,
     id: i64,
 ) -> Result<NoteFilterResult, String> {
-    let (session, segments, ocr_blocks) = load_note_material(&state.db, id)?;
-    let env = PurifyEnv {
-        config: state.purify.clone(),
-        symbol: state.symbol_normalize.clone(),
-        corrections: state.ocr_corrections.clone(),
-    };
-    let mut result = filter_note(&session.title, &segments, &ocr_blocks, &state.ui_junk, &env);
-    let images_dir = state.data_dir.join("session-images").join(id.to_string());
-    crate::screens::attach_images(&mut result.ocr_screens, &images_dir);
-    // v0.7.5（REQ-170）：预览与落库同口径——异常会话预览即带警示行
-    crate::note_filter::apply_session_warning(&mut result, &session.status);
-    crate::note_filter::refresh_screen_points(&mut result);
-    // v0.7.6（REQ-177/178）：结构渲染（与 convert_to_note 同函数同口径）
-    apply_note_structure(&mut result, &state.db, &session, &segments, &ocr_blocks, &env);
-    Ok(result)
+    // TD-2026-08-20-A 清偿：迁 spawn_blocking（预览与落库同口径——全量分析
+    // 同样耗时；数据所有权移入闭包，消除 segments/ocr_blocks 二次拷贝——观察 1）
+    let state: AppState = (*state).clone();
+    tauri::async_runtime::spawn_blocking(move || {
+        let (session, segments, ocr_blocks) = load_note_material(&state.db, id)?;
+        let env = PurifyEnv {
+            config: state.purify.clone(),
+            symbol: state.symbol_normalize.clone(),
+            corrections: state.ocr_corrections.clone(),
+        };
+        let mut result = filter_note(&session.title, &segments, &ocr_blocks, &state.ui_junk, &env);
+        let images_dir = state.data_dir.join("session-images").join(id.to_string());
+        crate::screens::attach_images(&mut result.ocr_screens, &images_dir);
+        // v0.7.5（REQ-170）：预览与落库同口径——异常会话预览即带警示行
+        crate::note_filter::apply_session_warning(&mut result, &session.status);
+        crate::note_filter::refresh_screen_points(&mut result);
+        // v0.7.6（REQ-177/178）：结构渲染（与 convert_to_note 同函数同口径）
+        apply_note_structure(&mut result, &state.db, &session, &segments, &ocr_blocks, &env);
+        Ok(result)
+    })
+    .await
+    .map_err(|e| format!("笔记预览任务失败: {}", e))?
 }