feat: 后处理阶段进度反馈(GUI + CLI)

- GUI: postprocessing 状态正确传递，前端显示"正在后处理: 币圈合成数据..."
- GUI: elapsed_seconds 在后处理阶段持续更新
- GUI: 防重入判断(start_sync/health_check/repair)统一纳入 postprocessing
- GUI: done/error 终态显式清空 postprocessing 状态
- CLI: update/all_data 加 progress_callback，后处理阶段打印提示
- dry_run 模式不发 postprocessing 通知（预处理实际跳过）

Author: Astro-Han

quantclass_sync_internal/cli.py

@@ -472,6 +472,14 @@ def cmd_setup(
         secrets_file=str(secrets_path),
     )
 
+def _cli_sync_progress(product_name: str, completed: int, total: int, *,
+                       status: str = "ok", **kwargs) -> None:
+    """CLI 同步进度回调：后处理阶段打印提示，避免长时间无输出。"""
+    if status == "postprocessing":
+        detail = kwargs.get("postprocess_detail", "")
+        msg = f"正在后处理: {detail}..." if detail else "正在后处理数据..."
+        RICH_CONSOLE.print(f"  {msg}")
+
 @app.command("update")
 @command_guard("update")
 def cmd_update(
@@ -566,6 +574,7 @@ def cmd_update(
         api_call_limit=user_config.api_call_limit,
         course_type=user_config.course_type,
         auto_confirm=yes,
+        progress_callback=_cli_sync_progress,
     )
     log_info("update 执行完成。", event="CMD_DONE", exit_code=exit_code)
     if exit_code == -1:
@@ -843,6 +852,7 @@ def cmd_all_data(
         # 从 user_config 读取 API 调用限额和课程类型（影响确认提示文本，无配置时用默认值）
         api_call_limit=getattr(user_config_all, "api_call_limit", 50),
         course_type=getattr(user_config_all, "course_type", ""),
+        progress_callback=_cli_sync_progress,
     )
     log_info("all_data 执行完成。", event="CMD_DONE", exit_code=exit_code)
     if exit_code == -1:

quantclass_sync_internal/gui/api.py

@@ -69,7 +69,7 @@ def _format_run_summary(raw_run: Dict[str, Any]) -> Dict[str, Any]:
 
 # _progress 的初始结构，每次 start_sync 前重置为此形态
 _PROGRESS_INIT: Dict[str, Any] = {
-    "status": "idle",          # idle / syncing / confirm_needed / done / error
+    "status": "idle",          # idle / syncing / confirm_needed / postprocessing / done / error
     "current_product": "",     # 最近完成的产品名
     "completed": 0,            # 已完成产品数
     "total": 0,                # 本次同步产品总数
@@ -79,6 +79,7 @@ def _format_run_summary(raw_run: Dict[str, Any]) -> Dict[str, Any]:
     "products": [],            # 已完成产品列表 [{name, status, elapsed_seconds, files_count}]
     "all_products": [],        # 全部产品名列表（由 progress_callback 初始化调用时传入）
     "estimate": None,          # EstimateResult 的 dict 表示（confirm_needed 时填充）
+    "postprocess_detail": "",  # 后处理阶段描述（用户可读）
 }
 
 
@@ -432,8 +433,8 @@ def start_sync(self, retry_failed: bool = False) -> Dict[str, Any]:
             # 检查 worker 线程是否仍在运行（cancel 后 status 变 error，但线程可能未退出）
             if hasattr(self, "_sync_thread") and self._sync_thread and self._sync_thread.is_alive():
                 return {"started": False, "message": "同步正在进行中，请等待完成后再试。"}
-            # confirm_needed 状态表示同步已在进行中（等待用户确认），也需拦截
-            if self._progress.get("status") in ("syncing", "confirm_needed"):
+            # confirm_needed/postprocessing 状态表示同步已在进行中，也需拦截
+            if self._progress.get("status") in ("syncing", "confirm_needed", "postprocessing"):
                 return {"started": False, "message": "同步正在进行中，请等待完成后再试。"}
 
             # retry_failed 分支：从上次 run_summary 读取失败产品名
@@ -552,7 +553,7 @@ def open_data_dir(self) -> Dict[str, Any]:
     def start_health_check(self) -> Dict[str, Any]:
         """启动后台健康检查线程。同步中（含等待确认）拒绝，重复启动拒绝。"""
         with self._lock:
-            if self._progress.get("status") in ("syncing", "confirm_needed"):
+            if self._progress.get("status") in ("syncing", "confirm_needed", "postprocessing"):
                 return {"ok": False, "error": "同步进行中，请稍后再试"}
             if self._health_progress["checking"]:
                 return {"ok": False, "error": "检查已在进行中"}
@@ -606,9 +607,9 @@ def get_health_result(self) -> Dict[str, Any]:
             return self._health_progress.get("result")
 
     def repair_health_issues(self) -> Dict[str, Any]:
-        """修复可修复的数据问题。同步中（含等待确认）拒绝。"""
+        """修复可修复的数据问题。同步中（含等待确认/后处理）拒绝。"""
         with self._lock:
-            if self._progress.get("status") in ("syncing", "confirm_needed"):
+            if self._progress.get("status") in ("syncing", "confirm_needed", "postprocessing"):
                 return {"ok": False, "error": "同步进行中，请稍后修复"}
             result = self._health_progress.get("result")
         if not result or not result.get("ok"):
@@ -866,6 +867,12 @@ def progress_callback(product_name: str, completed: int, total: int, *,
                     if status == "init":
                         self._progress["total"] = total
                         return
+                    # 后处理阶段：更新顶层 status 和 elapsed，供前端检测
+                    if status == "postprocessing":
+                        self._progress["status"] = "postprocessing"
+                        self._progress["elapsed_seconds"] = round(time.time() - t_start, 1)
+                        self._progress["postprocess_detail"] = _kwargs.get("postprocess_detail", "")
+                        return
                     # 计算本产品同步的文件数（新建 + 更新）
                     files_count = (stats.created_files + stats.updated_files) if stats else 0
                     # 追加到已完成产品列表，包含 error 字段供前端展示失败原因

quantclass_sync_internal/gui/assets/app.js

@@ -60,6 +60,7 @@ document.addEventListener('alpine:init', () => {
         allProducts: [],      // 全部待同步产品名（用于计算等待中列表）
         showWaiting: false,   // 等待中产品列表是否展开
         postprocessing: false, // 后处理阶段标志
+        postprocessDetail: '', // 后处理描述（用户可读）
         estimateData: null,   // API 调用量预估数据（confirm_needed 时填充，用于展示确认卡片）
 
         // ===== 初始化 =====
@@ -181,6 +182,7 @@ document.addEventListener('alpine:init', () => {
             this.allProducts = [];
             this.showWaiting = false;
             this.postprocessing = false;
+            this.postprocessDetail = '';
             this.estimateData = null;
             try {
                 const result = await window.pywebview.api.start_sync();
@@ -213,6 +215,7 @@ document.addEventListener('alpine:init', () => {
             this.allProducts = [];
             this.showWaiting = false;
             this.postprocessing = false;
+            this.postprocessDetail = '';
             this.estimateData = null;
             try {
                 // true 表示仅重试失败产品
@@ -264,8 +267,11 @@ document.addEventListener('alpine:init', () => {
                         // 不切换 syncStatus，继续轮询等待用户点击确认/取消
                     } else if (p.status === 'postprocessing') {
                         this.postprocessing = true;
+                        this.postprocessDetail = p.postprocess_detail || '';
                     } else if (p.status === 'done') {
                         this.syncStatus = 'done';
+                        this.postprocessing = false;
+                        this.postprocessDetail = '';
                         this.estimateData = null;
                         this.runSummary = p.run_summary;
                         this.historyLoaded = false; // 有新运行，下次切历史页时刷新
@@ -274,6 +280,8 @@ document.addEventListener('alpine:init', () => {
                         return; // 终态，不再调度下次轮询
                     } else if (p.status === 'error') {
                         this.syncStatus = 'error';
+                        this.postprocessing = false;
+                        this.postprocessDetail = '';
                         this.estimateData = null;
                         this.errorMessage = p.error_message || '同步失败';
                         this.runSummary = p.run_summary;  // 部分失败时也携带摘要

quantclass_sync_internal/gui/assets/index.html

@@ -390,8 +390,8 @@ <h2 class="setup-title">QuantClass Sync 初始设置</h2>
             <span class="qs-progress-text" x-text="total > 0 ? completed + ' / ' + total : '准备中...'"></span>
           </div>
           <!-- 进度指示行 -->
-          <div x-show="postprocessing" style="font-size:0.92em; color:#6b7280; margin:6px 0 2px;">
-            正在后处理数据...
+          <div x-show="postprocessing" style="font-size:0.92em; color:#6b7280; margin:6px 0 2px;"
+               x-text="'正在后处理' + (postprocessDetail ? ': ' + postprocessDetail : '') + '...'">
           </div>
           <div x-show="total > 0 && !postprocessing" style="font-size:0.92em; color:#6b7280; margin:6px 0 2px;">
             <span x-text="'已完成 ' + completed + '/' + total"></span>

quantclass_sync_internal/orchestrator.py

@@ -1565,12 +1565,7 @@ def run_update_with_settings(
             max_workers=max_workers,
             progress_callback=progress_callback,
         )
-        # 后处理前通知前端，postprocessing 状态用于 GUI 显示"正在后处理数据..."
-        if progress_callback is not None:
-            try:
-                progress_callback("", len(plans), len(plans), status="postprocessing")
-            except Exception:
-                pass
+        # dry_run 模式下 _maybe_run_coin_preprocess 会直接跳过，不发 postprocessing 通知
         preprocess_has_error = _maybe_run_coin_preprocess(
             command_ctx=command_ctx,
             report=report,
@@ -1591,10 +1586,12 @@ def run_update_with_settings(
                     max_workers=max_workers,
                     progress_callback=progress_callback,
                 )
-                # 后处理前通知前端，postprocessing 状态用于 GUI 显示"正在后处理数据..."
+                # 后处理前通知前端，postprocessing 状态用于 GUI 显示后处理进度
                 if progress_callback is not None:
                     try:
-                        progress_callback("", len(plans), len(plans), status="postprocessing")
+                        progress_callback("", len(plans), len(plans),
+                                          status="postprocessing",
+                                          postprocess_detail="币圈合成数据")
                     except Exception:
                         pass
                 preprocess_has_error = _maybe_run_coin_preprocess(