cyonjan/PyWxDump
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加获取群备注的功能

Browse Source
This commit is contained in:
xaoyaoo 2024-04-19 22:48:37 +08:00
parent abd134efed
commit 5b678e80e0
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pywxdump/dbpreprocess/parsingMicroMsg.py
View File

@ -5,6 +5,8 @@
# Author: xaoyaoo # Author: xaoyaoo
# Date: 2024/04/15 # Date: 2024/04/15
# ------------------------------------------------------------------------------- # -------------------------------------------------------------------------------
import logging
from .dbbase import DatabaseBase from .dbbase import DatabaseBase
from .utils import timestamp2str, bytes2str from .utils import timestamp2str, bytes2str
@ -134,7 +136,7 @@ class ParsingMicroMsg(DatabaseBase):
"ORDER BY A.ChatRoomName ASC;") "ORDER BY A.ChatRoomName ASC;")
if roomwxid: if roomwxid:
sql = sql.replace("ORDER BY A.ChatRoomName ASC;", sql = sql.replace("ORDER BY A.ChatRoomName ASC;",
f"where A.ChatRoomName LIKE '%{roomwxid}%' " f"and A.ChatRoomName LIKE '%{roomwxid}%' "
"ORDER BY A.ChatRoomName ASC;") "ORDER BY A.ChatRoomName ASC;")
result = self.execute_sql(sql) result = self.execute_sql(sql)
if not result: if not result:
@ -146,15 +148,19 @@ class ParsingMicroMsg(DatabaseBase):
UserNameList = UserNameList.split("^G") UserNameList = UserNameList.split("^G")
DisplayNameList = DisplayNameList.split("^G") DisplayNameList = DisplayNameList.split("^G")
RoomData = self.ChatRoom_RoomData(RoomData) RoomData = self.ChatRoom_RoomData(RoomData)
rd = [] wxid2remark = {}
if RoomData: if RoomData:
rd = []
for k, v in RoomData.items(): for k, v in RoomData.items():
if isinstance(v, list): if isinstance(v, list):
rd += v rd += v
room_datas.append(rd) for i in rd:
else: try:
print(f"ChatRoomName:{ChatRoomName} RoomData is None") if isinstance(i, dict) and isinstance(i.get('1'),str) and i.get('2'):
wxid2remark[i['1']] = i["2"]
except Exception as e:
logging.error(f"wxid2remark: ChatRoomName:{ChatRoomName}, {i} error:{e}")
rooms.append( rooms.append(
{"ChatRoomName": ChatRoomName, "UserNameList": UserNameList, "DisplayNameList": DisplayNameList, {"ChatRoomName": ChatRoomName, "UserNameList": UserNameList, "DisplayNameList": DisplayNameList,
"Announcement": Announcement, "AnnouncementEditor": AnnouncementEditor}) "Announcement": Announcement, "AnnouncementEditor": AnnouncementEditor, "wxid2remark": wxid2remark})
return rooms return rooms