1

handlers/OperateHandler.py

@@ -24,7 +24,7 @@ class ChannelGroupHandler(BaseHandler):
         arg = self.get_args()
         if arg.get('user_id'):
             # 该用户拥有的公众号权限
-            pass
+            sql = "select "
 
         else:
             # 返回所有公众号
@@ -34,14 +34,18 @@ class ChannelGroupHandler(BaseHandler):
 
     def user_channel_group(self):
         arg = self.get_args()
-
-        if arg.get('user_id'):
+        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
 
         else:
             # 返回所有公众号组
-            sql = ""
+            sql = "select id,name from channel_group"
+            self.write_json(db.quchen_text.getData_json(sql))
 
 
 
@@ -57,5 +61,24 @@ class ChannelGroupHandler(BaseHandler):
             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