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

标注用户注册

Browse Source
This commit is contained in:
ping 2025-09-11 17:14:47 +08:00
parent d9ce637e5e
commit 9320b88f3f
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
b/customer/registerUser.dspy
View File

@ -95,29 +95,48 @@ async def registerUser(ns):
return {'status': False, 'msg': '邀请码不正确'} return {'status': False, 'msg': '邀请码不正确'}
else: else:
try: try:
# 用户orgid
ns['id'] = uuid() ns['id'] = uuid()
org_id = ns['id'] org_id = ns['id']
ns['contactor_phone'] = ns.get('mobile') ns['contactor_phone'] = ns.get('mobile')
# 通过域名注册 # 通过域名注册
if ns.get('domain_name'): if ns.get('domain_name'):
# 通过域名查找分销商信息
reseller = await sor.R('reseller', {'domain_name': ns.get('domain_name')}) reseller = await sor.R('reseller', {'domain_name': ns.get('domain_name')})
if len(reseller) >= 1: if len(reseller) >= 1:
# 分销商机构ID 即orgid
org = await sor.R('organization', {'id': reseller[0]['orgid'], 'del_flg': '0'}) org = await sor.R('organization', {'id': reseller[0]['orgid'], 'del_flg': '0'})
else: else:
# 分销商不存在 则查找业主机构ID
org = await sor.R('organization', {'org_type': '0', 'del_flg': '0'}) org = await sor.R('organization', {'org_type': '0', 'del_flg': '0'})
else: else:
# 没有通过域名 则默认是获取业主机构ID
org = await sor.R('organization', {'org_type': '0', 'del_flg': '0'}) org = await sor.R('organization', {'org_type': '0', 'del_flg': '0'})
# 获取所在机构父级ID
ns['parentid'] = org[0]['id'] ns['parentid'] = org[0]['id']
# 新增用户机构信息
await sor.C('organization', ns) await sor.C('organization', ns)
# 生成用户userid
ns['id'] = uuid() ns['id'] = uuid()
userid = ns['id'] userid = ns['id']
# 加密用户密码
ns['password'] = password_encode(ns['password']) ns['password'] = password_encode(ns['password'])
ns['orgid'] = org_id ns['orgid'] = org_id
# 新增用户信息
await sor.C('users', ns) await sor.C('users', ns)
# 新增用户角色信息
listrole = ['管理员', '客户'] listrole = ['管理员', '客户']
for i in listrole: for i in listrole:
role = await sor.R('role', {'role': i, 'org_type': ns['org_type']}) role = await sor.R('role', {'role': i, 'org_type': ns['org_type']})
await sor.C('userrole', {'id': uuid(), 'userid': userid, 'roleid': role[0]['id']}) await sor.C('userrole', {'id': uuid(), 'userid': userid, 'roleid': role[0]['id']})
# 新增客户信息并使用openCustomerAccounts为客户开账
ns['id'] = uuid() ns['id'] = uuid()
ns['customerid'] = org_id ns['customerid'] = org_id
await sor.C('customer', ns) await sor.C('customer', ns)