1

data_manage/operate.py

@@ -56,3 +56,19 @@ def group_del(arg):
 
 
 
+def group_auth_add(arg):
+    db = MysqlUtils()
+    user_id = arg.get("user_id")
+    group_id = arg.get("group_id")
+    if user_id and group_id:
+        sql = "insert into user_channel_group_auth (user_id,channel_group_id)  values (%s,%s)"
+        db.quchen_text.execute(sql, (user_id, group_id))
+
+def group_auth_del(arg):
+    db = MysqlUtils()
+    user_id = arg.get("user_id")
+    group_id = arg.get("group_id")
+    if user_id and group_id:
+        sql = f"delete from  user_channel_group_auth where user_id={user_id} and channel_group_id={group_id}"
+        # print(sql)
+        db.quchen_text.execute(sql)

handlers/OperateHandler.py

@@ -13,7 +13,9 @@ class ChannelGroupHandler(BaseHandler):
         "user_channel_group": user_channel_group,
         "user": user,
         "group_add": group_add,
-        "group_del": group_del
+        "group_del": group_del,
+        "group_auth_add": group_auth_add,
+        "group_auth_del": group_auth_del
     }