调试

common/sql_help.py

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

data_channel/piaoquan.py

@@ -319,7 +319,7 @@ class PQ:
                             url_video = url_videos
                 if i == 3:
                     return new_video
-            return new_video
+        return new_video
 
 
     """

sph_sy_main.py

@@ -1,7 +1,7 @@
 import schedule
 import time
 
-from xssy_channel.sph_nrxs import SphNrxs
+from xssy_channel.sph_jr_nrxs import SphNrxs
 
 def video_start_sph():
     print("视频号任务开始...")

xssy_channel/dy_nrxs.py

@@ -13,7 +13,7 @@ class DYNrxs:
     """
     @classmethod
     def get_dy_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/dy_rdb_nrxs.py

@@ -0,0 +1,7 @@
+
+
+
+class DyRdbNrxs:
+    @classmethod
+    def get_dy_rdb_nrxs(cls):
+        pass

xssy_channel/sph_nrxs.py → xssy_channel/sph_jr_nrxs.py

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