From d4bc3f5476db018e80caaa76741c592d95cd4370 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B5=85=E5=BF=B5?= Date: Fri, 21 Aug 2026 15:15:24 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=204h=E5=A2=9E=E9=87=8F?= =?UTF-8?q?=E6=8E=A5=E5=85=A5=E5=85=A8=E9=83=A8=E5=9B=9B=E7=B1=BB=E6=B6=88?= =?UTF-8?q?=E6=81=AF(wa-messages/group-messages/wa-group-messages,?= =?UTF-8?q?=E6=B0=B4=E4=BD=8D=E5=90=8E=E5=8D=95=E5=AF=B9=E8=AF=9D1?= =?UTF-8?q?=E9=A1=B5=E5=8F=AF=E6=89=BF=E5=8F=97)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude --- yunke-server/app/sync/scheduler.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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):强制全量翻历史,对齐增量模式抓不到的