diff --git a/cucyuqing/cmd/es-sync.py b/cucyuqing/cmd/es-sync.py
index b225e29..371d29e 100644
--- a/cucyuqing/cmd/es-sync.py
+++ b/cucyuqing/cmd/es-sync.py
@@ -180,11 +180,11 @@ async def sync():
             await cur.execute(
                 """
             WITH RECURSIVE time_slots AS (
-                SELECT date_trunc('hour', now() - interval '1 hour') - interval '14 day' AS start_time
+                SELECT date_trunc('hour', now() - interval '2 hour') - interval '14 day' AS start_time
                 UNION ALL
                 SELECT start_time + INTERVAL '1 hour'
                 FROM time_slots
-                WHERE start_time < date_trunc('hour', now() - interval '1 hour')
+                WHERE start_time < date_trunc('hour', now() - interval '2 hour')
             )
             SELECT
                 ts.start_time,