update

xiaoniangao/xiaoniangao_hour/xiaoniangao_hour.py

@@ -514,7 +514,7 @@ class XiaoniangaoHour:
                                                       v_id=video_id)
                     ten_play_cnt = video_info_dict['play_cnt']
                     Common.logger(log_type, crawler).info(f"ten_play_cnt:{ten_play_cnt}")
-                    update_sql = f""" update crawler_xiaoniangao_hour set ten_play_cnt={ten_play_cnt} WHERE out_video_id={video_id}; """
+                    update_sql = f""" update crawler_xiaoniangao_hour set ten_play_cnt={ten_play_cnt} WHERE out_video_id="{video_id}"; """
                     # Common.logger(log_type, crawler).info(f"update_sql:{update_sql}")
                     MysqlHelper.update_values(log_type, crawler, update_sql, env)
                     cls.download_publish(log_type, crawler, video_info_dict, update_video_info, strategy, oss_endpoint, env)
@@ -526,12 +526,12 @@ class XiaoniangaoHour:
                                                          v_title=video_title,
                                                          v_id=video_id)
                     fifteen_play_cnt = video_info_dict['play_cnt']
-                    Common.logger(log_type, crawler).info(f"ten_play_cnt:{fifteen_play_cnt}")
-                    update_sql = f""" update crawler_xiaoniangao_hour set ten_play_cnt={fifteen_play_cnt} WHERE out_video_id={video_id}; """
+                    Common.logger(log_type, crawler).info(f"fifteen_play_cnt:{fifteen_play_cnt}")
+                    update_sql = f""" update crawler_xiaoniangao_hour set fifteen_play_cnt={fifteen_play_cnt} WHERE out_video_id="{video_id}"; """
                     # Common.logger(log_type, crawler).info(f"update_sql:{update_sql}")
                     MysqlHelper.update_values(log_type, crawler, update_sql, env)
                     cls.download_publish(log_type, crawler, video_info_dict, update_video_info, strategy, oss_endpoint, env)
-                elif datetime.datetime.now().hour == 18 and datetime.datetime.now().minute <=50:
+                elif datetime.datetime.now().hour == 20 and datetime.datetime.now().minute <=10:
                     video_info_dict = cls.get_video_info(log_type=log_type,
                                                          crawler=crawler,
                                                          p_id=profile_id,
@@ -539,8 +539,8 @@ class XiaoniangaoHour:
                                                          v_title=video_title,
                                                          v_id=video_id)
                     twenty_play_cnt = video_info_dict['play_cnt']
-                    Common.logger(log_type, crawler).info(f"ten_play_cnt:{twenty_play_cnt}")
-                    update_sql = f""" update crawler_xiaoniangao_hour set ten_play_cnt={twenty_play_cnt} WHERE out_video_id={video_id}; """
+                    Common.logger(log_type, crawler).info(f"twenty_play_cnt:{twenty_play_cnt}")
+                    update_sql = f""" update crawler_xiaoniangao_hour set twenty_play_cnt={twenty_play_cnt} WHERE out_video_id="{video_id}"; """
                     # Common.logger(log_type, crawler).info(f"update_sql:{update_sql}")
                     MysqlHelper.update_values(log_type, crawler, update_sql, env)
                     cls.download_publish(log_type, crawler, video_info_dict, update_video_info, strategy, oss_endpoint, env)

xiaoniangao/xiaoniangao_main/run_xiaoniangao_hour.py

@@ -35,7 +35,7 @@ def main(log_type, crawler, env):
                                              oss_endpoint=oss_endpoint,
                                              env=env)
 
-        elif now.hour == 18 and now.minute <= 50:
+        elif now.hour == 20 and now.minute <= 10:
             Common.logger(log_type, crawler).info("开始更新/下载上升榜")
             XiaoniangaoHour.update_videoList(log_type=log_type,
                                              crawler=crawler,