feat: 添加视频统计字段并更新视频数据处理逻辑

This commit is contained in:
晓丰 2025-06-01 16:44:18 +08:00
parent f0fa81da92
commit befa954c9a
2 changed files with 7 additions and 8 deletions

14
DB.py
View File

@ -62,6 +62,10 @@ video = Table("sh_dm_video_v2", _meta,
Column("status", Integer), Column("status", Integer),
Column("createtime", Integer), Column("createtime", Integer),
Column("updatetime", Integer), Column("updatetime", Integer),
Column("watch_number", Integer),
Column("follow_number", Integer),
Column("video_number", Integer),
) )
@ -520,7 +524,9 @@ class DBSA:
"public_time": data["create_time"], "cover_pic": data["cover_pic"], "public_time": data["create_time"], "cover_pic": data["cover_pic"],
"sort": data["sort"], "u_xid": data["u_xid"], "u_id": data["u_id"], "sort": data["sort"], "u_xid": data["u_xid"], "u_id": data["u_id"],
"u_pic": data["u_pic"], "u_name": data["u_name"], "u_pic": data["u_pic"], "u_name": data["u_name"],
"status": 1, "createtime": now_ts, "updatetime": now_ts, "status": 1, "createtime": now_ts, "updatetime": now_ts, "watch_number": data.get("view", 0),
"follow_number": data.get("fans", 0),
"video_number": data.get("videos", 0),
} }
with cls._lock: with cls._lock:
@ -601,12 +607,6 @@ class DBSA:
@classmethod @classmethod
def update_video_stats(cls, locator: dict, stats: dict) -> int: def update_video_stats(cls, locator: dict, stats: dict) -> int:
"""
立即更新 sh_dm_video_v2 表中的统计字段n
:param locator: 用于定位行的字典必须包含: v_xid, rn
:param stats: 需要更新的统计字段 {"fans": 633, "videos": 10090, "view": 1678408}
:return: 受影响的行数
"""
v_xid = locator.get("v_xid") v_xid = locator.get("v_xid")
rn = locator.get("rn") rn = locator.get("rn")
if not v_xid or not rn: if not v_xid or not rn:

View File

@ -117,7 +117,6 @@ def get_searchInfo(keyword, level, headers, proxy_name, r=2):
"u_name": iteminfo.get('owner.screenname'), "u_name": iteminfo.get('owner.screenname'),
"u_pic": iteminfo.get('owner.avatar_60_url') "u_pic": iteminfo.get('owner.avatar_60_url')
} }
print(v_data)
video_list.append(v_data) video_list.append(v_data)
time.sleep(1) time.sleep(1)
return video_list return video_list