QcWebServerGame/handlers/OperateHandler.py

from handlers.HandlerBase import BaseHandler
from model.DataBaseUtils import MysqlUtils
import json
import requests
from model.DataBaseUtils import MysqlUtils
db = MysqlUtils()


class ChannelGroupHandler(BaseHandler):

    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 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

        else:
            # 返回所有公众号组
            sql = "select id,name from channel_group"
            self.write_json(db.quchen_text.getData_json(sql))



    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