update

toolbox/porter/tasks/douyin_live_to_bilibili_live_task.py

@@ -83,19 +83,33 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
             self.success_rate_of_get_live_info_by_web_enter.append(0)
             return None
         data = js["data"]["data"]
+
         if len(data) == 0:
             self.success_rate_of_get_live_info_by_web_enter.append(1)
             return None
         data = data[0]
         status = data["status"]
         title = data["title"]
-        stream_data = json.loads(data["stream_url"]["live_core_sdk_data"]["pull_data"]["stream_data"])
-        stream_data = stream_data["data"]
+
+        if status == 4:
+            paid_live_data = {}
+            stream_data = {}
+        else:
+            try:
+                paid_live_data = data["paid_live_data"]
+                stream_data = data["stream_url"]["live_core_sdk_data"]["pull_data"]["stream_data"]
+            except KeyError as error:
+                logger.info(f"data.keys: {data.keys()}, error type: {type(error)}, error text: {error}, traceback: {traceback.format_exc()}")
+                self.success_rate_of_get_live_info_by_web_enter.append(0)
+                return None
+            stream_data = json.loads(stream_data)
+            stream_data = stream_data["data"]
 
         result = {
             "status": status,
             "title": title,
             "stream_data": stream_data,
+            "paid_live_data": paid_live_data,
         }
         self.success_rate_of_get_live_info_by_web_enter.append(1)
         return result