fix(scraper): talker_id用发送的friend_id优先(API返回的talker可能脱敏导致消息查不到)
Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
@@ -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)}"),
|
"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",
|
"channel": "wechat",
|
||||||
"owner_account_id": owner_id,
|
"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,
|
"room_id": None,
|
||||||
"is_send": bool(row.get("isSend", 0)) if row.get("isSend") is not None else None,
|
"is_send": bool(row.get("isSend", 0)) if row.get("isSend") is not None else None,
|
||||||
"type": _normalize_msg_type(row.get("type")),
|
"type": _normalize_msg_type(row.get("type")),
|
||||||
|
|||||||
Reference in New Issue
Block a user