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-06-21 17:26:26 +08:00
parent 2fe136b0f3
commit a73f8f2d6a
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pywxdump/dbpreprocess/parsingMSG.py
View File

@ -5,6 +5,7 @@
# Author: xaoyaoo # Author: xaoyaoo
# Date: 2024/04/15 # Date: 2024/04/15
# ------------------------------------------------------------------------------- # -------------------------------------------------------------------------------
import json
import os import os
import re import re
@ -18,6 +19,7 @@ import blackboxprotobuf
class ParsingMSG(DatabaseBase): class ParsingMSG(DatabaseBase):
_class_name = "MSG" _class_name = "MSG"
def __init__(self, db_path): def __init__(self, db_path):
super().__init__(db_path) super().__init__(db_path)
@ -172,7 +174,13 @@ class ParsingMSG(DatabaseBase):
cdnurl = content_tmp.get("emoji", {}).get("cdnurl", "") cdnurl = content_tmp.get("emoji", {}).get("cdnurl", "")
if cdnurl: if cdnurl:
content = {"src": cdnurl, "msg": "表情"} content = {"src": cdnurl, "msg": "表情"}
elif type_id == (48, 0): # 地图信息
content_tmp = xml2dict(StrContent)
location = content_tmp.get("location", {})
content["msg"] = (f"纬度:【{location.pop('x')}】 经度:【{location.pop('y')}】\n"
f"位置：{location.pop('label')} {location.pop('poiname')}\n"
f"其他信息：{json.dumps(location, ensure_ascii=False, indent=4)}"
)
elif type_id == (49, 0): elif type_id == (49, 0):
DictExtra = self.get_BytesExtra(BytesExtra) DictExtra = self.get_BytesExtra(BytesExtra)
url = match_BytesExtra(DictExtra) url = match_BytesExtra(DictExtra)
@ -255,7 +263,7 @@ class ParsingMSG(DatabaseBase):
"ORDER BY CreateTime ASC LIMIT ?,?") "ORDER BY CreateTime ASC LIMIT ?,?")
if msg_type: if msg_type:
sql = sql.replace("ORDER BY CreateTime ASC LIMIT ?,?", sql = sql.replace("ORDER BY CreateTime ASC LIMIT ?,?",
f"AND Type={msg_type} ORDER BY CreateTime ASC LIMIT ?,?") f"AND Type={msg_type} ORDER BY CreateTime ASC LIMIT ?,?")
result1 = self.execute_sql(sql, (wxid, start_index, page_size)) result1 = self.execute_sql(sql, (wxid, start_index, page_size))
else: else:
sql = ( sql = (
@ -263,7 +271,7 @@ class ParsingMSG(DatabaseBase):
"FROM MSG ORDER BY CreateTime ASC LIMIT ?,?") "FROM MSG ORDER BY CreateTime ASC LIMIT ?,?")
if msg_type: if msg_type:
sql = sql.replace("ORDER BY CreateTime ASC LIMIT ?,?", sql = sql.replace("ORDER BY CreateTime ASC LIMIT ?,?",
f"AND Type={msg_type} ORDER BY CreateTime ASC LIMIT ?,?") f"AND Type={msg_type} ORDER BY CreateTime ASC LIMIT ?,?")
result1 = self.execute_sql(sql, (start_index, page_size)) result1 = self.execute_sql(sql, (start_index, page_size))
if not result1: if not result1:
return [], [] return [], []