更新 run_yggxxsp_recommend

youlegaoxiaoxiaoshipin/youlegaoxiaoxiaoshipin_main/run_ylgxxsp_recommend.py

@@ -88,8 +88,13 @@ def main(my_platform, mode, topic_name, group_id, env):
                     rule_dict=rule_dict,
                     our_uid=our_uid,
                 )
-                for i in range(10):
-                    YLGXXSP.get_videoList(page_id=i + 1)
+                for i in range(20):
+                    if YLGXXSP.download_count >= int(rule_dict.get("videos_cnt", {}).get("min", 10)):
+                        YLGXXSP.download_count = 0
+                        break
+                    else:
+                        YLGXXSP.get_videoList(page_id=i + 1)
+                        time.sleep(60)
 
                 AliyunLogger.logging(
                     code="1000",

youlegaoxiaoxiaoshipin/youlegaoxiaoxiaoshipin_recommend/youlegaoxiaoxiaoshipin_scheduling.py

@@ -157,9 +157,9 @@ class YLGXXSPScheduling:
             video_dict["video_url"] = video_obj["data"]["url"]
             video_dict["avatar_url"] = "http:" + video_obj["data"]["avatar"]
             video_dict["cover_url"] = "http:" + video_obj["data"]["thumbUrl"]
-            print(json.dumps(video_dict, ensure_ascii=False, indent=4))
+            # print(json.dumps(video_dict, ensure_ascii=False, indent=4))
             self.download_count += 1
-            # self.mq.send_msg(video_dict)
+            self.mq.send_msg(video_dict)
 
 
 if __name__ == "__main__":