MOD:修改 task

web_module/tornado_api.py

@@ -408,6 +408,8 @@ class delete_ad_plan(BaseHandler):
     def get(self):
         user_id = self.get_argument('user_id', None)
         plan_name = self.get_argument('plan_name', None)
+        service_name = self.get_argument('service_name', None)
+        wechat_name = self.get_argument('wechat_name', None)
         sql_session = db.DBSession()
         if user_id is None or plan_name is None:
             self.write({'status': {'msg': 'url parameter error', "RetCode": 400}})
@@ -415,7 +417,8 @@ class delete_ad_plan(BaseHandler):
         # 落地页名字精确到毫秒,默认是全局唯一
 
         sql_tools.delete_ad_plan_typesetting_vir(sql_session=sql_session, user_id=user_id,
-                                                 typesetting_name=plan_name)
+                                                 typesetting_name=plan_name, wechat_name=wechat_name,
+                                                 service_name=service_name)
         self.write({'status': {'msg': 'success', "RetCode": 200}})
 
 
@@ -500,7 +503,7 @@ class get_task_list(BaseHandler):
             return
         # 落地页名字精确到毫秒,默认是全局唯一
 
-        result = sql_tools.get_plan_record(sql_session=sql_session, user_id=user_id)
+        result = sql_tools.get_ad_task(sql_session=sql_session, user_id=user_id)
         result_ = []
         for i in range(len(result)):
             print(result[i])

wechat_action/sql_tools.py

@@ -155,12 +155,14 @@ def get_ad_plan_typesetting(sql_session, user_id, typesetting_name):
         return result_list
 
 
-def delete_ad_plan_typesetting_vir(sql_session, user_id, typesetting_name):
+def delete_ad_plan_typesetting_vir(sql_session, user_id, typesetting_name, wechat_name, service_name):
     sql = '''
             update ad_plan_typesetting lt 
             set is_delete=1
-            where user_id ='{}' and name = '{}';
-    '''.format(user_id, typesetting_name)
+            where user_id ='{user_id}' and name = '{name}' and 
+            wechat_name='{wechat_name}' and service_name='{service_name}';
+    '''.format(user_id=user_id, name=typesetting_name,
+               service_name=service_name, wechat_name=wechat_name)
     print(sql)
     sql_session.execute(sql)
     sql_session.commit()