定时任务调整

base/RedisPPData.py

@@ -114,7 +114,7 @@ def NoticeEnterprise_task():
     # 实例化一个调度器
     scheduler = BlockingScheduler()
     # 每天执行一次
-    scheduler.add_job(NoticeEnterprise, 'cron', hour=12,minute=0)
+    scheduler.add_job(NoticeEnterprise, 'cron', hour=0,minute=0)
     try:
         # redisPushData  # 定时开始前执行一次
         scheduler.start()
@@ -247,8 +247,8 @@ def AnnualEnterprise():
 def AnnualEnterprise_task():
     # 实例化一个调度器
     scheduler = BlockingScheduler()
-    # 每年执行一次
-    scheduler.add_job(AnnualEnterprise, 'cron', second='*/10')
+    # 每月七点执行一次
+    scheduler.add_job(AnnualEnterprise, 'cron', day='1',hour='7',minute='0')
     try:
         # 定时开始前执行一次
         AnnualEnterprise()
@@ -564,13 +564,13 @@ if __name__ == "__main__":
     # kegaishifan()
     # shuangbaiqiye()
     # zhuangjingtexind()
-    # NoticeEnterprise()
+    NoticeEnterprise()
     # AnnualEnterpriseIPO()
     # AnnualEnterprise()
     # BaseInfoEnterprise()
     # BaseInfoEnterpriseAbroad()
     # NewsEnterprise_task()
-    NewsEnterprise()
+    # NewsEnterprise()
     # CorPerson()
     # china100()
     # global100()
@@ -585,8 +585,8 @@ if __name__ == "__main__":
     # dujioashou()
     # omeng()
     # AnnualEnterpriseUS()
-    # NoticeEnterprise_task()
-    # AnnualEnterprise_task()
+    NoticeEnterprise_task()
+    AnnualEnterprise_task()
     # FinanceFromEast()
     log.info(f'====={basecore.getNowTime(1)}=====添加数据成功======耗时：{basecore.getTimeCost(start,time.time())}===')