From 9320b88f3f7bdedb322153d147e2245c3f14cd66 Mon Sep 17 00:00:00 2001 From: ping <1017253325@qq.com> Date: Thu, 11 Sep 2025 17:14:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=87=E6=B3=A8=E7=94=A8=E6=88=B7=E6=B3=A8?= =?UTF-8?q?=E5=86=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- b/customer/registerUser.dspy | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) 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)