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


def user_channel(arg):
    db = MysqlUtils()
    # 返回所有公众号
    sql = "select id,nick_name from t_mp_account where del_flag=0"
    return db.zx.getData_json(sql)


def user_channel_group(arg):
    db = MysqlUtils()
    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(arg):
    db = MysqlUtils()
    # 返回所有用户
    sql = "SELECT user_id,nick_name from t_sys_user where del_flag=0 and status=0"
    return db.zx.getData_json(sql)



def group_add(arg):
    db = MysqlUtils()
    name = arg.get("name")
    ids = arg.get("channel_ids")
    if name and ids:

        sql = "insert into channel_group (name,channel_ids)  values (%s,%s)"
        db.quchen_text.execute(sql,(name,ids))


def group_del(arg):
    db = MysqlUtils()
    id = arg.get("id")

    if id:
        sql = f"delete from  channel_group where id={id}"
        db.quchen_text.execute(sql)