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