Quellcode durchsuchen

增加了rootSourceId 日志

罗俊辉 vor 11 Monaten
Ursprung
Commit
625c7b417c
2 geänderte Dateien mit 4 neuen und 3 gelöschten Zeilen
  1. 1 1
      applications/functions/common.py
  2. 3 2
      applications/schedule/process_schedule.py

+ 1 - 1
applications/functions/common.py

@@ -80,7 +80,7 @@ def create_gzh_path(video_id, shared_uid):
     url = f"pages/user-videos?id={video_id}&su={shared_uid}&fromGzh=1&rootShareId={root_share_id}&shareId={root_share_id}&rootSourceId={source_id}"
     # 自动把 root_share_id 加入到白名单
     auto_white(root_share_id)
-    return root_share_id, f"pages/category?jumpPage={urllib.parse.quote(url, safe='')}"
+    return root_share_id, source_id, f"pages/category?jumpPage={urllib.parse.quote(url, safe='')}"
 
 
 def request_for_info(video_id):

+ 3 - 2
applications/schedule/process_schedule.py

@@ -27,7 +27,7 @@ async def return_info(video_id, kimi_title, trace_id, mysql_client, index):
     programId = "wxe8f8f0e23cecad0f"
     programName = "票圈乐活"
     source = "Web"
-    root_share_id, productionPath = create_gzh_path(video_id=video_id, shared_uid=user_id)
+    root_share_id, source_id, productionPath = create_gzh_path(video_id=video_id, shared_uid=user_id)
     logging(
         code="1002",
         info="root_share_id --{}, productionPath -- {}".format(root_share_id, productionPath),
@@ -62,7 +62,8 @@ async def return_info(video_id, kimi_title, trace_id, mysql_client, index):
         trace_id=trace_id,
         data={
             "rootShareId": root_share_id,
-            "videoId": video_id
+            "videoId": video_id,
+            "sourceId": source_id
         }
     )
     return result