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")),