From 5037d5d0ed40c6b8693db781684c4e7157bc78af Mon Sep 17 00:00:00 2001
From: Yuzhiran Dev <dev@yuzhiran.com>
Date: Thu, 21 May 2026 10:04:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E6=B0=B4=E7=BA=BF=E6=95=B4=E4=BD=93?=
 =?UTF-8?q?=E5=89=8D=E7=A7=BB1.5h,=E5=87=8C=E6=99=A85=E7=82=B9=E5=89=8D?=
 =?UTF-8?q?=E5=85=A8=E9=83=A8=E5=B0=B1=E7=BB=AA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

01:00 search → 01:10 trends → 01:30 collect
→ 02:00 create → 03:00 review
→ 05:00 optimize_sources → 06:00 metrics

各间隔: 10min/20min/30min/60min/2h/1h
采集到创作30min缓冲足够(采集≈5-15min)
---
 platform/backend/app/core/scheduler.py | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/platform/backend/app/core/scheduler.py b/platform/backend/app/core/scheduler.py
index 65d5a7a..1f03c61 100644
--- a/platform/backend/app/core/scheduler.py
+++ b/platform/backend/app/core/scheduler.py
@@ -25,7 +25,7 @@ class TaskScheduler:
             logger.warning("Scheduler already started")
             return
         # 使用 CronTrigger 设置每日固定时间点
-        # 顺序: 搜索缓存(01:00)→采集(01:30)→趋势(03:00)→生成(03:30)→审查(04:30)→源优化(05:00)→指标(06:00)
+        # 顺序: 搜索缓存(01:00)→趋势(01:10)→采集(01:30)→创作(02:00)→审查(03:00)→源优化(05:00)→指标(06:00)
         self.scheduler.add_job(
             self._run_refresh_search_cache,
             CronTrigger(hour=1, minute=0),
@@ -34,22 +34,22 @@ class TaskScheduler:
             max_instances=1,
             coalesce=True
         )
+        self.scheduler.add_job(
+            self._run_fetch_trends,
+            CronTrigger(hour=1, minute=10),
+            id='scheduled_fetch_trends',
+            replace_existing=True,
+            max_instances=1,
+            coalesce=True
+        )
         self.scheduler.add_job(
             self._run_collect,
             CronTrigger(hour=1, minute=30),
             id='scheduled_collect',
         )
-        self.scheduler.add_job(
-            self._run_fetch_trends,
-            CronTrigger(hour=3, minute=0),
-            id='scheduled_fetch_trends',
-            replace_existing=True,
-            max_instances=1,
-            coalesce=True
-        )
         self.scheduler.add_job(
             self._run_generate,
-            CronTrigger(hour=3, minute=30),
+            CronTrigger(hour=2, minute=0),
             id='scheduled_generate',
             replace_existing=True,
             max_instances=1,
@@ -57,7 +57,7 @@ class TaskScheduler:
         )
         self.scheduler.add_job(
             self._run_optimize,
-            CronTrigger(hour=4, minute=30),
+            CronTrigger(hour=3, minute=0),
             id='scheduled_optimize',
             replace_existing=True,
             max_instances=1,
@@ -81,7 +81,7 @@ class TaskScheduler:
         )
         self.scheduler.start()
         self._started = True
-        logger.info("Scheduler started: 01:00 search_cache → 01:30 collect → 03:00 trends → 03:30 generate → 04:30 review → 05:00 optimize_sources → 06:00 metrics_sync")
+        logger.info("Scheduler started: 01:00 search 01:10 trends 01:30 collect 02:00 create 03:00 review 05:00 sources 06:00 metrics")
     def shutdown(self):
         if self.scheduler.running:
             self.scheduler.shutdown()