diff --git a/fam-edge/src/fam_edge/model_adapters/nvidia_adapter.py b/fam-edge/src/fam_edge/model_adapters/nvidia_adapter.py
index 52268c5..6f68779 100644
--- a/fam-edge/src/fam_edge/model_adapters/nvidia_adapter.py
+++ b/fam-edge/src/fam_edge/model_adapters/nvidia_adapter.py
@@ -82,8 +82,13 @@ class NvidiaVisionAdapter(BaseModelAdapter):
     # ------------------------------------------------------------------
     @staticmethod
     def _ts_to_seconds(ts: str) -> float:
-        """'HH:MM:SS' 或 'HH:MM:SS.mmm' -> 秒"""
-        parts = str(ts).strip().split(':')
+        """'2026-08-20 04:34:10'（生产格式）/ 'HH:MM:SS' -> 当日秒偏移"""
+        s = str(ts).strip()
+        # 绝对时间格式: 取时间部分（同一天 30min 片段内足够）
+        date_part, _, time_part = s.partition(' ')
+        if time_part and '-' in date_part:
+            s = time_part
+        parts = s.split(':')
         try:
             if len(parts) == 3:
                 return int(parts[0]) * 3600 + int(parts[1]) * 60 + float(parts[2])
@@ -230,7 +235,7 @@ class NvidiaVisionAdapter(BaseModelAdapter):
         ts_list = '\n'.join(f'  片段{i}: 原始时间 {ts}' for i, ts in enumerate(frame_timestamps, 1))
         return f"""你是家庭监控视频分析助手。下面的视频是由一段长时间监控录像中抽取的片段集锦，
 共 {len(frame_timestamps)} 个片段（每个约 3 秒），按顺序拼接。每个片段左上角叠加了
-原始时间戳（ts 后的 00-05-00 表示 00:05:00）。
+原始时间戳（ts 后的 2026-08-20 04-34-10 表示北京时间 2026年8月20日 04:34:10）。
 
 片段时间对照：
 {ts_list}
diff --git a/fam-edge/src/fam_edge/queue/queue_manager.py b/fam-edge/src/fam_edge/queue/queue_manager.py
index e77a6e1..d8d946b 100644
--- a/fam-edge/src/fam_edge/queue/queue_manager.py
+++ b/fam-edge/src/fam_edge/queue/queue_manager.py
@@ -47,8 +47,8 @@ def _init_db():
             error_message TEXT,
             failure_stage TEXT,
             retry_count INTEGER DEFAULT 0,
-            created_at TEXT DEFAULT (datetime('now', 'localtime')),
-            updated_at TEXT DEFAULT (datetime('now', 'localtime')),
+            created_at TEXT DEFAULT (datetime('now', '+8 hours')),
+            updated_at TEXT DEFAULT (datetime('now', '+8 hours')),
             delivered INTEGER DEFAULT 0,
             UNIQUE(nas_task_id)
         )
@@ -85,7 +85,7 @@ def enqueue(nas_task_id: int, video_filename: str, video_path: str,
                     "UPDATE task_queue SET status='PENDING', result_json=NULL, error_message=NULL, "
                     "failure_stage=NULL, retry_count=0, delivered=0, video_filename=?, video_path=?, "
                     "camera_name=?, event_start_time=?, known_members_context=?, "
-                    "updated_at=datetime('now','localtime') WHERE id=?",
+                    "updated_at=datetime('now','+8 hours') WHERE id=?",
                     (video_filename, video_path, camera_name, event_start_time,
                      known_members_context, row['id'])
                 )
@@ -105,7 +105,7 @@ def claim_next() -> Optional[Dict]:
         ).fetchone()
         if row:
             conn.execute(
-                "UPDATE task_queue SET status='PROCESSING', updated_at=datetime('now','localtime') WHERE id=?",
+                "UPDATE task_queue SET status='PROCESSING', updated_at=datetime('now','+8 hours') WHERE id=?",
                 (row['id'],)
             )
             conn.commit()
@@ -123,7 +123,7 @@ def mark_success(task_id: int, result_json: str):
     conn = _get_conn()
     try:
         conn.execute(
-            "UPDATE task_queue SET status='SUCCESS', result_json=?, updated_at=datetime('now','localtime') WHERE id=?",
+            "UPDATE task_queue SET status='SUCCESS', result_json=?, updated_at=datetime('now','+8 hours') WHERE id=?",
             (result_json, task_id)
         )
         conn.commit()
@@ -136,7 +136,7 @@ def mark_failed(task_id: int, error_message: str, failure_stage: str = ''):
     try:
         conn.execute(
             "UPDATE task_queue SET status='FAILED', error_message=?, failure_stage=?, "
-            "updated_at=datetime('now','localtime') WHERE id=?",
+            "updated_at=datetime('now','+8 hours') WHERE id=?",
             (error_message, failure_stage, task_id)
         )
         conn.commit()
@@ -165,7 +165,7 @@ def mark_delivered(task_ids: List[int]):
     try:
         placeholders = ','.join('?' * len(task_ids))
         conn.execute(
-            f"UPDATE task_queue SET delivered=1, updated_at=datetime('now','localtime') "
+            f"UPDATE task_queue SET delivered=1, updated_at=datetime('now','+8 hours') "
             f"WHERE id IN ({placeholders})", task_ids
         )
         conn.commit()
diff --git a/fam-edge/src/fam_edge/video_preprocessor/preprocessor.py b/fam-edge/src/fam_edge/video_preprocessor/preprocessor.py
index 8a1e548..ec74d80 100644
--- a/fam-edge/src/fam_edge/video_preprocessor/preprocessor.py
+++ b/fam-edge/src/fam_edge/video_preprocessor/preprocessor.py
@@ -287,10 +287,15 @@ class VideoPreprocessor:
             duration = frame_count * 60  # 兜底
 
         interval = duration / frame_count
+        from datetime import timedelta, timezone
+        # 统一北京时区: 视频均为北京时间录制，Edge 机器是 UTC，
+        # fallback 不能用本地 datetime.now()
         try:
             start_dt = datetime.fromisoformat(event_start_time.replace('Z', '+00:00'))
+            if start_dt.tzinfo is not None:
+                start_dt = start_dt.astimezone(timezone(timedelta(hours=8))).replace(tzinfo=None)
         except Exception:
-            start_dt = datetime.now()
+            start_dt = datetime.now(timezone(timedelta(hours=8))).replace(tzinfo=None)
 
         timestamps = []
         for i in range(frame_count):