1

data_manage/operate.py

@@ -3,15 +3,17 @@ from model.DataBaseUtils import *
 from model.log import logger
 from model.CommonUtils import *
 du = DateUtils()
-db =MysqlUtils()
+
 
 def user_channel(arg):
+    db = MysqlUtils()
     # 返回所有公众号
     sql = "select id,nick_name from t_mp_account where del_flag=0"
     return db.zx.getData_json(sql)
 
 
 def user_channel_group(arg):
+    db = MysqlUtils()
     user_id = arg.get('user_id')
     if user_id:
         # 该用户拥有的公众号组
@@ -27,6 +29,7 @@ def user_channel_group(arg):
 
 
 def user(arg):
+    db = MysqlUtils()
     # 返回所有用户
     sql = "SELECT user_id,nick_name from t_sys_user where del_flag=0 and status=0"
     return db.zx.getData_json(sql)
@@ -34,12 +37,22 @@ def user(arg):
 
 
 def group_add(arg):
-    name = ''
+    db = MysqlUtils()
+    name = arg.get("name")
+    ids = arg.get("channel_ids")
+    if name and ids:
 
-    sql = "insert into channel_group name,channel_ids values (%s,%s)"
+        sql = "insert into channel_group (name,channel_ids)  values (%s,%s)"
+        db.quchen_text.execute(sql,(name,ids))
 
 
 def group_del(arg):
-    pass
+    db = MysqlUtils()
+    id = arg.get("id")
+
+    if id:
+        sql = f"delete from  channel_group where id={id}"
+        db.quchen_text.execute(sql)
+
 
 

handlers/OperateHandler.py

@@ -23,7 +23,7 @@ class ChannelGroupHandler(BaseHandler):
         print(arg)
         try:
             data = self.run(arg)
-            print(data)
+
             self.write_json(data=data)
         except Exception as e:
             print(e)

model/DataBaseOperation.py

@@ -67,9 +67,9 @@ class MysqlOperation:
 
 
 
-    def execute(self, sql):
+    def execute(self, sql,args=None):
         start = time.time()
-        self.cursor.execute(sql)
+        self.cursor.execute(query=sql,args=args)
         self.conn.commit()
         if MYSQL_DEBUG: