From aeb8a89b03de274f26356cc4ff5bc1e4d3052144 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B5=85=E5=BF=B5?= Date: Mon, 17 Aug 2026 09:29:39 +0800 Subject: [PATCH] =?UTF-8?q?fix(scraper):=20talker=5Fid=E7=94=A8=E5=8F=91?= =?UTF-8?q?=E9=80=81=E7=9A=84friend=5Fid=E4=BC=98=E5=85=88(API=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E7=9A=84talker=E5=8F=AF=E8=83=BD=E8=84=B1=E6=95=8F?= =?UTF-8?q?=E5=AF=BC=E8=87=B4=E6=B6=88=E6=81=AF=E6=9F=A5=E4=B8=8D=E5=88=B0?= =?UTF-8?q?)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude --- yunke-server/scripts/scrape_via_page.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/yunke-server/scripts/scrape_via_page.py b/yunke-server/scripts/scrape_via_page.py index 5263d8b..d663450 100644 --- a/yunke-server/scripts/scrape_via_page.py +++ b/yunke-server/scripts/scrape_via_page.py @@ -466,7 +466,8 @@ async def scrape_messages(cookie_str: str, max_conversations: int = 100): "msg_id": str(row.get("msgId") or row.get("msgSvrId") or row.get("id") or f"{owner_id}:{friend_id}:{i}:{len(records)}"), "channel": "wechat", "owner_account_id": owner_id, - "talker_id": row.get("talker") or row.get("oriTalker") or friend_id, + # 用发送的 friend_id（与客户表一致）优先，API 返回的 talker 可能脱敏 + "talker_id": friend_id or row.get("talker") or row.get("oriTalker"), "room_id": None, "is_send": bool(row.get("isSend", 0)) if row.get("isSend") is not None else None, "type": _normalize_msg_type(row.get("type")),