diff --git a/yunke-server/app/sync/scheduler.py b/yunke-server/app/sync/scheduler.py index a504dc0..ecfa056 100644 --- a/yunke-server/app/sync/scheduler.py +++ b/yunke-server/app/sync/scheduler.py @@ -593,18 +593,21 @@ class SyncScheduler: commands: list[list[str]] = [[bash, "scripts/full_sync_all.sh"]] elif kind == "messages": # 先刷客户列表(最近沟通时间是云客列表的实时排序键,friends 快照 - # 滞后会让本地排序与云客第一页完全不同,2026-08-20),再抓消息增量 + # 滞后会让本地排序与云客第一页完全不同,2026-08-20),再抓全部四类 + # 消息增量(2026-08-21 全接入:水位增量后单对话 1 页,可承受) commands = [ [sys.executable, "scripts/scrape_via_page.py", "--entity", "friends"], [sys.executable, "scripts/scrape_via_page.py", "--entity", "wa-friends"], + ] + [ [ sys.executable, "scripts/scrape_via_page.py", "--entity", - "messages", + e, "--max-conversations", - str(self.max_conversations_per_run), - ], + "99999", + ] + for e in ("messages", "wa-messages", "group-messages", "wa-group-messages") ] elif kind == "full-history": # 每周全量对齐(周日 05:00):强制全量翻历史,对齐增量模式抓不到的