调试

common/sql_help.py

@@ -253,9 +253,9 @@ class sqlCollect():
     获取相似溯源基础账号
     """
     @classmethod
-    def get_machine_making_reflux(cls, channel, channel1, channel2, channel3):
-        sql = """SELECT user FROM machine_making_reflux WHERE (channel = %s or channel = %s or channel = %s or channel = %s) and status = 0"""
-        data = MysqlHelper.get_values(sql, (channel, channel1, channel2, channel3))
+    def get_machine_making_reflux(cls, channel, channel1, channel2, channel3, channel4):
+        sql = """SELECT user FROM machine_making_reflux WHERE (channel = %s or channel = %s or channel = %s or channel = %s or channel = %s) and status = 0"""
+        data = MysqlHelper.get_values(sql, (channel, channel1, channel2, channel3, channel4))
         if len(data) == 0 or data == ():
             return None
         return data

xssy_channel/dy_rdb_nrxs.py

@@ -13,7 +13,7 @@ class DyRdbNrxs:
 
     @classmethod
     def get_dy_rdb_nrxs(cls):
-        user = sqlCollect.get_machine_making_reflux("抖音", "抖音历史", "相似溯源", "单点视频")
+        user = sqlCollect.get_machine_making_reflux("抖音", "抖音历史", "相似溯源", "单点视频", "抖音品类账号")
         if user == None:
             return
         user = [item[0] for item in user]

xssy_channel/sph_jr_nrxs.py

@@ -321,7 +321,7 @@ class SphNrxs:
     """获取需溯源账号"""
     @classmethod
     def sph_nrxs_data(cls):
-        user = sqlCollect.get_machine_making_reflux("视频号", "单点视频", "视频号历史", "相似溯源")
+        user = sqlCollect.get_machine_making_reflux("视频号", "单点视频", "视频号历史", "相似溯源", "视频H品类账号")
         if user == None:
             return
         user = [item[0] for item in user]

xssy_main.py

@@ -30,7 +30,7 @@ def video_start_dy():
 schedule.every().day.at("10:30").do(video_start_sph)
 
 schedule.every().day.at("03:30").do(video_start_dy)
-
+DyRdbNrxs.get_dy_rdb_nrxs()
 # SphNrxs.sph_nrxs_data()
 while True:
     schedule.run_pending()