1

data_manage/operate.py

@@ -0,0 +1,45 @@
+from model.DateUtils import DateUtils
+from model.DataBaseUtils import *
+from model.log import logger
+from model.CommonUtils import *
+du = DateUtils()
+db =MysqlUtils()
+
+def user_channel(arg):
+    # 返回所有公众号
+    sql = "select id,nick_name from t_mp_account where del_flag=0"
+    return db.zx.getData_json(sql)
+
+
+def user_channel_group(arg):
+    user_id = arg.get('user_id')
+    if user_id:
+        # 该用户拥有的公众号组
+        sql = f"""SELECT id,name from channel_group where id in  
+               (select channel_group_id from user_channel_group_auth where user_id={user_id})"""
+        return db.quchen_text.getData_json(sql)
+
+
+    else:
+        # 返回所有公众号组
+        sql = "select id,name from channel_group"
+        return db.quchen_text.getData_json(sql)
+
+
+def user(self, arg):
+    # 返回所有用户
+    sql = "SELECT user_id,nick_name from t_sys_user where del_flag=0 and status=0"
+    data = db.zx.getData_json(sql)
+    self.write_json(data=data)
+
+
+def group_add(self, arg):
+    name = ''
+
+    sql = "insert into channel_group name,channel_ids values (%s,%s)"
+
+
+def group_del(self, arg):
+    pass
+
+

handlers/OperateHandler.py

@@ -2,83 +2,44 @@ from handlers.HandlerBase import BaseHandler
 from model.DataBaseUtils import MysqlUtils
 import json
 import requests
+from data_manage.operate import *
 from model.DataBaseUtils import MysqlUtils
 db = MysqlUtils()
 
 
 class ChannelGroupHandler(BaseHandler):
+    APP_MAP = {
+        "user_channel": user_channel,
+        "user_channel_group": user_channel_group,
+        "user": user,
+        "group_add": group_add,
+        "group_del": group_del
+    }
 
-    def post(self):
-
-        key = self.request.full_url().split('/')[-1]
-        if key == "user_channel":
-            self.user_channel()
-        elif key == "user_channel_group":
-            self.user_channel_group()
-        elif key == "user":
-            self.user()
-        else:
-            self.write_fail()
-
-    def user_channel(self):
-        arg = self.get_args()
-        if arg.get('user_id'):
-            # 该用户拥有的公众号权限
-            sql = "select "
-
-        else:
-            # 返回所有公众号
-            sql = "select id,nick_name from t_mp_account where del_flag=0"
-            self.write_json(data=db.zx.getData_json(sql))
 
+    def post(self):
 
-    def user_channel_group(self):
         arg = self.get_args()
-        user_id = arg.get('user_id')
-        if user_id:
-            # 该用户拥有的公众号组
-            sql = f"""SELECT id,name from channel_group where id in  
-                (select channel_group_id from user_channel_group_auth where user_id={user_id})"""
-            self.write_json(db.quchen_text.getData_json(sql))
-            pass
+        print(arg)
+        try:
+            data = self.run(arg)
+            print(data)
+            self.write_json(data=data)
+        except Exception as e:
+            print(e)
+            self.write_fail()
 
-        else:
-            # 返回所有公众号组
-            sql = "select id,name from channel_group"
-            self.write_json(db.quchen_text.getData_json(sql))
+    def run(self, arg):
 
+        app = self.request.full_url().split('/')[-1]
+        return self.run_function(self.APP_MAP[app], arg)
 
+    def run_function(self, func, arg):
+        return func(arg)
 
-    def user(self):
-        arg = self.get_args()
-        if arg.get('user_id'):
-            # 该用户管理的用户
-            pass
 
-        else:
-            # 返回所有用户
-            sql = "SELECT user_id,nick_name from t_sys_user where del_flag=0 and status=0"
-            data = db.zx.getData_json(sql)
-            self.write_json(data=data)
 
-    # 添加/删除公众号
-    def channel_auth(self):
-        arg = self.get_args()
-        user_id = arg.get("user_id")
-        channel_id = arg.get("channel_id")
-        if user_id and channel_id:
 
-            flag = arg.get('flag')
-            if flag == "add":
-                db.quchen_text.execute(f" ")
-            elif flag == "del":
-                pass
-            else:
-                self.write_fail(msg="flag missing")
-        else:
-            self.write_fail(msg="user_id or channel_id missing")
 
 
-    def channel_group(self):
-        pass