update

data/porter_tasks/porter_task_songkewei_douyin_video_to_youtube.json

@@ -6,7 +6,7 @@
     "sec_user_id": "MS4wLjABAAAAs2XhHg7SMVu-STXWpod1zFxTzlnoeWzTXxAE02c7OQ49GMnGiHCcLxk8c3aDPr3s",
     "check_interval": 900,
     "key_of_credentials": "douyin_wentao_credentials",
-    "min_date2": "2025-12-27 00:00:00",
+    "min_date": "2020-12-27 00:00:00",
     "output_video_dir": "data/tasks/songkewei_douyin_video_to_youtube/video/douyin/宋可为",
     "output_video_info_file": "data/tasks/songkewei_douyin_video_to_youtube/video/douyin/宋可为/file_info.json"
   },

toolbox/bilibili/live/live_manager.py

@@ -7,10 +7,8 @@ https://github.com/ChaceQC/bilibili_live_stream_code/blob/master/main/bilibili_l
 
 """
 import argparse
+import json
 import logging
-import urllib
-import urllib.parse
-import hashlib
 
 from tenacity import before_sleep_log, retry, retry_if_exception_type, stop_after_attempt, wait_fixed
 

toolbox/porter/tasks/douyin_live_record_task.py

@@ -273,12 +273,34 @@ class DouyinLiveRecordTask(BaseTask):
         paid_live_data: dict = js.get("paid_live_data") or dict()
         privilege_info_map: dict = paid_live_data.get("privilege_info_map") or dict()
         if len(privilege_info_map) != 0:
-            for _, v in privilege_info_map.items():
-                paid_live_type = v.get("paid_live_type")
-                ui_config = v.get("ui_config") or dict()
-                paid_live_icon_title = ui_config.get("paid_live_icon_title")
-                logger.info(f"{self.flag}跳过付费直播；live_check_method: {live_check_method}, paid_live_type: {paid_live_type}, paid_live_icon_title: {paid_live_icon_title}")
-            return None
+            # 会员直播似乎可以通过 by_sec_user_id 方法录制到。
+            if live_check_method != "by_sec_user_id":
+                live_check_method = "by_sec_user_id"
+                js = await self.get_live_info_by_sec_user_id()
+                if js is None:
+                    logger.info(f"{self.flag} {live_check_method},尝试录制会员直播失败；")
+                    return None
+
+                status: int = js["status"]
+                title: str = js["title"]
+                stream_data: dict = js["stream_data"]
+                metadata = copy.deepcopy(js)
+                metadata.pop("stream_data")
+                metadata["live_check_method"] = live_check_method
+                if status != 2:
+                    logger.info(f"{self.flag} {live_check_method},未开播；")
+                    return None
+
+        # 会员直播
+        # paid_live_data: dict = js.get("paid_live_data") or dict()
+        # privilege_info_map: dict = paid_live_data.get("privilege_info_map") or dict()
+        # if len(privilege_info_map) != 0:
+        #     for _, v in privilege_info_map.items():
+        #         paid_live_type = v.get("paid_live_type")
+        #         ui_config = v.get("ui_config") or dict()
+        #         paid_live_icon_title = ui_config.get("paid_live_icon_title")
+        #         logger.info(f"{self.flag}跳过付费直播；live_check_method: {live_check_method}, paid_live_type: {paid_live_type}, paid_live_icon_title: {paid_live_icon_title}")
+        #     return None
 
         live_url = None
         for quality_code in ("origin", "uhd", "hd", "sd", "md", "ld"):