zhangyong 1 năm trước cách đây
mục cha
commit
e9c21c0eb0
2 tập tin đã thay đổi với 8 bổ sung5 xóa
  1. 4 1
      common/material.py
  2. 4 4
      data_assign_main.py

+ 4 - 1
common/material.py

@@ -160,7 +160,10 @@ class Material():
         douyin = Feishu.get_values_batch(feishu_id, channel_id)
         # 提取账号昵称和账号主页链接
         for row in douyin[1:]:
-            uid = row[1]
+            if channel == "站内":
+                uid = row[0]
+            else:
+                uid = row[1]
             if uid:
                 insert_sql = f"""INSERT INTO agc_channel_data (user_id, channel, mark) values ('{uid}', '{channel}', '{mark}')"""
                 MysqlHelper.update_values(

+ 4 - 4
data_assign_main.py

@@ -67,10 +67,10 @@ def kuanshou_task():
             print("处理结果:", result)
     print("快手数据抓取定时任务执行完成.")
 
-schedule.every().day.at("19:20").do(kuanshou_task)
-schedule.every().day.at("19:30").do(douyin_task)
-schedule.every().day.at("18:00").do(zhannei_task)
-
+# schedule.every().day.at("19:20").do(kuanshou_task)
+# schedule.every().day.at("19:30").do(douyin_task)
+# schedule.every().day.at("18:00").do(zhannei_task)
+zhannei_task()
 # 持续运行,直到手动终止
 while True:
     schedule.run_pending()