QcWebServerGame/data_manage/operate.py

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