Преглед изворни кода

233的status=0 防止被version2的定时任务读取到

liyuyi@c-top.com.cn пре 4 година
родитељ
комит
7349cd10ad
2 измењених фајлова са 8 додато и 8 уклоњено
  1. 1 1
      ai_strategy_request_func.py
  2. 7 7
      ai_time_task_creative_handler.py

+ 1 - 1
ai_strategy_request_func.py

@@ -94,7 +94,7 @@ class ParseAddCampaignOrAddGroupRequest(object):
         select * 
         from ctop_ai_kuaishou_advertiser_strategy 
         where account_id = %d 
-        and status = 1
+        and status = 0
         limit 1
         """ % self.account_id
         advertiser_strategy_df = pd.read_sql(sql, engine)

+ 7 - 7
ai_time_task_creative_handler.py

@@ -38,7 +38,7 @@ class AiHistoricalMissingMaterial(tornado.web.RequestHandler):
         try:
             sql = """
             select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-            where account_id=%s and status=1 order by create_time desc limit 1
+            where account_id=%s and status=0 order by create_time desc limit 1
             """ % account_id
             df = pd.read_sql(sql, engine)
             if df['general_track'].values[0] == 0:
@@ -173,7 +173,7 @@ class AiAutoCreative(tornado.web.RequestHandler):
         try:
             sql = """
                         select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-                        where account_id=%s and status=1 order by create_time desc limit 1
+                        where account_id=%s and status=0 order by create_time desc limit 1
                         """ % account_id
             df = pd.read_sql(sql, engine)
             if df['general_track'].values[0] == 0:
@@ -311,7 +311,7 @@ class AiHighQualityMaterial(tornado.web.RequestHandler):
                     (account_id, os.getpid(), os.getppid(), data))
         try:
             sql = """select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-                     where account_id=%s and status=1 order by create_time desc limit 1
+                     where account_id=%s and status=0 order by create_time desc limit 1
                      """ % account_id
             df = pd.read_sql(sql, engine)
             if df['general_track'].values[0] == 0:
@@ -459,7 +459,7 @@ class AiCheckAndUpTOFullCreative(tornado.web.RequestHandler):
             sql = """
             select image_cnt from ctop_ai_kuaishou_advertiser_strategy 
             where account_id = %s 
-            and status = 1
+            and status = 0
             limit 1
             """ % account_id
             df = pd.read_sql(sql, engine)
@@ -490,7 +490,7 @@ class AiCheckAndUpTOFullCreative(tornado.web.RequestHandler):
                 logger.info("需要补充的视频数量:%s" % video_cnt)
 
                 sql = """select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-                                 where account_id=%s and status=1 order by create_time desc limit 1
+                                 where account_id=%s and status=0 order by create_time desc limit 1
                               """ % account_id
                 df = pd.read_sql(sql, engine)
                 if df['general_track'].values[0] == 0:
@@ -639,7 +639,7 @@ class AiProgramCreativeHighQualityMaterial(tornado.web.RequestHandler):
                     (account_id, os.getpid(), os.getppid(), data))
         try:
             sql = """select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-                     where account_id=%s and status=1 order by create_time desc limit 1
+                     where account_id=%s and status=0 order by create_time desc limit 1
                   """ % account_id
             df = pd.read_sql(sql, engine)
             if df['general_track'].values[0] == 0:
@@ -746,7 +746,7 @@ class AiProgramCreativeNewMaterial(tornado.web.RequestHandler):
                     (account_id, os.getpid(), os.getppid(), data))
         try:
             sql = """select account_id, single_appid, app_id_array, general_track from ctop_ai_kuaishou_advertiser_strategy
-                     where account_id=%s and status=1 order by create_time desc limit 1
+                     where account_id=%s and status=0 order by create_time desc limit 1
                   """ % account_id
             df = pd.read_sql(sql, engine)
             if df['general_track'].values[0] == 0: