yumoqing/kboss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
ping 2026-07-22 15:12:11 +08:00
parent 00de124ae7
commit 0baf4fb9ad
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
b/reseller/reseller_add_user.dspy
View File

@ -27,15 +27,16 @@ async def reseller_add_user(ns):
try: try:
ns['id'] = uuid() ns['id'] = uuid()
ns['password'] = password_encode(ns['password']) ns['password'] = password_encode(ns['password'])
tenant_orgid = await get_reseller_user_tenant_orgid(sor, ns.get('orgid')) # tenant_orgid = await get_reseller_user_tenant_orgid(sor, ns.get('orgid'))
tenant_orgid = ns.get('orgid')
if not tenant_orgid: if not tenant_orgid:
return {'status': False, 'msg': '未找到用户所属租户'} return {'status': False, 'msg': '未找到用户所属租户'}
user_sql = """select id from users where username = '%s' and tenant_orgid = '%s' and del_flg = '0' limit 1;""" % (ns['username'], tenant_orgid) user_sql = """select id from users where username = '%s' and tenant_orgid = '%s' and del_flg = '0' limit 1;""" % (ns['username'], tenant_orgid)
user = await sor.sqlExe(user_sql, {}) user = await sor.sqlExe(user_sql, {})
if len(user) >= 1: if len(user) >= 1:
return {'status': False, 'msg': '用户名重复'} return {'status': False, 'msg': '用户名重复'}
rolereacs = await sor.R('role', {'role': '管理员', 'del_flg': '0', 'org_type': '1'}) rolereacs = await sor.R('role', {'role': '管理员', 'del_flg': '0', 'org_type': ns.get('org_type')})
ns['user_reseller'] = '1' ns['user_reseller'] = ns.get('org_type')
ns['tenant_orgid'] = tenant_orgid ns['tenant_orgid'] = tenant_orgid
await sor.C('users', ns) await sor.C('users', ns)
await sor.C('userrole', {'userid': ns['id'], 'roleid': rolereacs[0]['id'], 'id': uuid()}) await sor.C('userrole', {'userid': ns['id'], 'roleid': rolereacs[0]['id'], 'id': uuid()})