async def reseller_add_user(ns):
    """
    添加用户
  `id`:         '用户id',
  `name` :      '姓名',
  `password`    :'密码',
  `email` :     '邮件地址',
  `orgid`:      '所属机构',
  `nick_name`:  '显示名',
  `address`     :地址',
  `mobile`:    '手机'
    """
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        try:
            ns['id'] = uuid()
            ns['password'] = password_encode(ns['password'])
            user = await sor.R('users', {'username': ns['username']})
            if len(user) >= 1:
                return {'status': False, 'msg': '用户名重复'}
            rolereacs = await sor.R('role', {'role': '管理员', 'del_flg': '0', 'org_type': '1'})
            ns['user_reseller'] = '1'
            await sor.C('users', ns)
            await sor.C('userrole', {'userid': ns['id'], 'roleid': rolereacs[0]['id'], 'id': uuid()})
            return {'status': True, 'msg': '用户添加成功', 'userid': ns['id']}
        except Exception as e:
            raise e
    return {
        'status': False,
        'msg': '用户添加失败'
    }

ret = await reseller_add_user(params_kw)
return ret