fix: _parse_date 兼容 ISO datetime + postprocess 阶段进度反馈 + skipped date_time 填充

Author: Astro-Han

quantclass_sync_internal/data_query.py

@@ -78,11 +78,12 @@ def infer_local_date_from_csv(data_root: Path, product: str, rule) -> Optional[s
 
 
 def _parse_date(date_str: Optional[str]) -> Optional[date]:
-    """解析 YYYY-MM-DD 日期字符串。"""
+    """解析日期字符串，支持 YYYY-MM-DD 和 YYYY-MM-DDTHH:MM:SS 两种格式。"""
     if not date_str:
         return None
     try:
-        return datetime.strptime(date_str, "%Y-%m-%d").date()
+        # 优先尝试 ISO datetime（checked_at 字段），截取日期部分
+        return datetime.strptime(date_str[:10], "%Y-%m-%d").date()
     except ValueError:
         return None
 

quantclass_sync_internal/gui/assets/app.js

@@ -59,6 +59,7 @@ document.addEventListener('alpine:init', () => {
         syncProducts: [],     // 同步过程中已处理产品列表（每项含 name/status/elapsed/files_count/error）
         allProducts: [],      // 全部待同步产品名（用于计算等待中列表）
         showWaiting: false,   // 等待中产品列表是否展开
+        postprocessing: false, // 后处理阶段标志
         estimateData: null,   // API 调用量预估数据（confirm_needed 时填充，用于展示确认卡片）
 
         // ===== 初始化 =====
@@ -179,6 +180,7 @@ document.addEventListener('alpine:init', () => {
             this.syncProducts = [];
             this.allProducts = [];
             this.showWaiting = false;
+            this.postprocessing = false;
             this.estimateData = null;
             try {
                 const result = await window.pywebview.api.start_sync();
@@ -210,6 +212,7 @@ document.addEventListener('alpine:init', () => {
             this.syncProducts = [];
             this.allProducts = [];
             this.showWaiting = false;
+            this.postprocessing = false;
             this.estimateData = null;
             try {
                 // true 表示仅重试失败产品
@@ -257,7 +260,10 @@ document.addEventListener('alpine:init', () => {
                     // confirm_needed：后台线程等待用户确认，展示确认卡片
                     if (p.status === 'confirm_needed' && p.estimate) {
                         this.estimateData = p.estimate;
+                        this.postprocessing = false;
                         // 不切换 syncStatus，继续轮询等待用户点击确认/取消
+                    } else if (p.status === 'postprocessing') {
+                        this.postprocessing = true;
                     } else if (p.status === 'done') {
                         this.syncStatus = 'done';
                         this.estimateData = null;

quantclass_sync_internal/gui/assets/index.html

@@ -389,8 +389,11 @@ <h2 class="setup-title">QuantClass Sync 初始设置</h2>
             </div>
             <span class="qs-progress-text" x-text="total > 0 ? completed + ' / ' + total : '准备中...'"></span>
           </div>
-          <!-- 进度指示行（仅在有产品时显示详情，准备中状态由进度条文字承担） -->
-          <div x-show="total > 0" 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;">
+            正在后处理数据...
+          </div>
+          <div x-show="total > 0 && !postprocessing" style="font-size:0.92em; color:#6b7280; margin:6px 0 2px;">
             <span x-text="'已完成 ' + completed + '/' + total"></span>
             <span x-show="currentProduct"> · 最新: <span style="font-weight:600" x-text="currentProduct"></span></span>
           </div>

quantclass_sync_internal/orchestrator.py

@@ -1160,6 +1160,10 @@ def _run_one_plan(plan: ProductPlan) -> Tuple[bool, float, SyncStats, str, str]:
         if not requested_dates_for_plan:
             if catch_up_to_latest:
                 elapsed = time.time() - t_product_start
+                # 读取本地 timestamp，用于填充 date_time，避免 GUI 用 today 计算落后天数
+                local_date_for_report = read_local_timestamp_date(
+                    command_ctx.data_root, normalize_product_name(plan.name)
+                )
                 # 并发路径：写 report 需加锁，防止 list.append 与其他线程竞争
                 with _lock:
                     _append_result(
@@ -1168,6 +1172,7 @@ def _run_one_plan(plan: ProductPlan) -> Tuple[bool, float, SyncStats, str, str]:
                         status="skipped",
                         strategy=plan.strategy,
                         reason_code=REASON_NO_DATA_FOR_DATE,
+                        date_time=local_date_for_report or "",
                         elapsed=elapsed,
                         mode="gate",
                         error="catch-up 日期队列为空，已跳过本产品。",
@@ -1560,6 +1565,12 @@ 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
         preprocess_has_error = _maybe_run_coin_preprocess(
             command_ctx=command_ctx,
             report=report,
@@ -1580,6 +1591,12 @@ 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
                 preprocess_has_error = _maybe_run_coin_preprocess(
                     command_ctx=command_ctx,
                     report=report,