77 lines
1.5 KiB
Plaintext
77 lines
1.5 KiB
Plaintext
# 用短信模块检查验证码是否正确
|
|
debug(f'{params_kw=}')
|
|
if params_kw.cellphone is None:
|
|
return {
|
|
"status": "error",
|
|
"data":{
|
|
"message": "需输入手机号"
|
|
}
|
|
}
|
|
if params_kw.sms_code is None:
|
|
return {
|
|
"status": "error",
|
|
"data": {
|
|
"message": "需输入验证码"
|
|
}
|
|
}
|
|
if params_kw.key is None:
|
|
return {
|
|
"status": "error",
|
|
"data": {
|
|
"message": "需要短信验证key"
|
|
}
|
|
}
|
|
f = await sms_engine.check_sms_code(params_kw.key, params_kw.sms_code)
|
|
if not f:
|
|
return {
|
|
"status": "error",
|
|
"data": {
|
|
"message": "手机短信验证码出错"
|
|
}
|
|
}
|
|
|
|
ns = {
|
|
"username": params_kw.cellphone,
|
|
"password": "^&%UHI",
|
|
"cfm_password": "^&%UHI",
|
|
"mobile": params_kw.cellphone,
|
|
"user_status": "0"
|
|
}
|
|
async with get_sor_context(request._run_ns, 'rbac') as sor:
|
|
recs = await sor.R('users', {'mobile': params_kw.cellphone})
|
|
if recs:
|
|
if len(recs) == 1:
|
|
r = recs[0]
|
|
await remember_user(r.id, username=r.username, userorgid=r.orgid)
|
|
return {
|
|
"status": "ok",
|
|
"data":{
|
|
"user": r
|
|
}
|
|
}
|
|
if params_kw.selected_id:
|
|
for r in recs:
|
|
if r.id == params_kw.selected_id:
|
|
await remember_user(r.id, username=r.username, userorgid=r.orgid)
|
|
return {
|
|
"status": "ok",
|
|
"data":{
|
|
"user": r
|
|
}
|
|
}
|
|
else:
|
|
return {
|
|
"status": "choose",
|
|
"data": {
|
|
"users": recs
|
|
}
|
|
}
|
|
|
|
d = await register_user(sor, ns)
|
|
if d['status'] == 'error':
|
|
return d
|
|
|
|
r = d['data']['user']
|
|
await remember_user(r.id, username=r.username, userorgid=r.orgid)
|
|
|