46 lines
1.6 KiB
Plaintext
46 lines
1.6 KiB
Plaintext
async def create_user(ns={}):
|
|
createUserInfo = {
|
|
'userId': await get_user(),
|
|
'name': ns.get('username'),
|
|
'mobilePhone': ns.get('mobile'),
|
|
'verificationCode': ns.get('verificationcode'),
|
|
}
|
|
try:
|
|
parameters = JDAPI.CreateUserRequest.CreateUserParameters(partnerId="44733868076", createUserInfo=createUserInfo)
|
|
request = JDAPI.CreateUserRequest.CreateUserRequest(parameters)
|
|
resp = JDAPI.CpClient.send(request)
|
|
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
if resp.error:
|
|
return {
|
|
'status': False,
|
|
'msg': 'create user failed, %s' % resp.error.message
|
|
}
|
|
elif resp.result.get('pin'):
|
|
create_user_dic = {
|
|
'id': uuid(),
|
|
'userid': await get_user(),
|
|
'username': ns.get('username'),
|
|
'mobile': ns.get('mobile'),
|
|
'pin': resp.result.get('pin'),
|
|
'rolejrn': resp.result.get('roleJrn')
|
|
}
|
|
await sor.C('jd_users', create_user_dic)
|
|
return {
|
|
'status': True,
|
|
'msg': 'create user success'
|
|
}
|
|
else:
|
|
return {
|
|
'status': False,
|
|
'msg': 'create user failed'
|
|
}
|
|
except Exception as e:
|
|
return {
|
|
'status': False,
|
|
'msg': 'create user failed, %s' % str(e)
|
|
}
|
|
|
|
ret = await create_user(params_kw)
|
|
return ret |