wangkun 2 yıl önce
ebeveyn
işleme
353455fbae
2 değiştirilmiş dosya ile 10 ekleme ve 8 silme
  1. 4 2
      main/gzh.py
  2. 6 6
      main/run_gzh.py

+ 4 - 2
main/gzh.py

@@ -282,7 +282,7 @@ class GZH:
 
     # 获取所有用户的公众号文章信息
     @classmethod
-    def get_all_gzh(cls, log_type):
+    def get_all_gzh(cls, log_type, env):
         try:
             user_sheet = Feishu.get_values_batch(log_type, 'gzh', 'pxHL2C')
             for i in range(3, len(user_sheet)):
@@ -291,7 +291,9 @@ class GZH:
                 head_url = user_sheet[i][3]
                 Common.logger(log_type).info("获取 {} 公众号文章\n", username)
                 cls.get_gzh_url(log_type, username, userid, head_url)
-                Common.logger(log_type).info("休眠 3 - 60 分钟")
+                Common.logger(log_type).info("下载/上传 {} 公众号视频\n", username)
+                cls.run_download_publish(log_type, env)
+                Common.logger(log_type).info("休眠 3 - 30 分钟")
                 time.sleep(random.randint(60*3, 60*30))
         except Exception as e:
             Common.logger(log_type).error("get_all_gzh异常:{}\n", e)

+ 6 - 6
main/run_gzh.py

@@ -19,16 +19,16 @@ class Main:
                 # Common.logger('gzh').info("今日公众号抓取任务开始\n")
                 # GZH.search_user_by_word('gzh')
                 # 获取所有用户的公众号文章信息
-                Common.logger('gzh').info("获取用户文章信息\n")
-                GZH.get_all_gzh('gzh')
-                # 下载/上传
-                Common.logger('gzh').info("下载/上传\n")
-                GZH.run_download_publish('gzh', env)
+                Common.logger('gzh').info("开始抓取公众号任务\n")
+                GZH.get_all_gzh('gzh', env)
+                # # 下载/上传
+                # Common.logger('gzh').info("下载/上传\n")
+                # GZH.run_download_publish('gzh', env)
                 # 清除日志
                 Common.del_logs('gzh')
                 # 翻页初始化
                 GZH.gzh_count = []
-                Common.logger('gzh').info("今日公众号抓取任务结束,休眠{}小时\n", 24-datetime.datetime.now().hour)
+                Common.logger('gzh').info("公众号抓取任务结束,休眠{}小时\n", 24-datetime.datetime.now().hour)
                 time.sleep(3600 * (24-datetime.datetime.now().hour))
             else:
                 pass