async def getretrieve(ns): """忘记密码""" db = DBPools() async with db.sqlorContext('kboss') as sor: val = await sor.R('validatecode',{'id':ns['codeid'],'vcode':ns['vcode']}) if len(val) >= 1: ns['password'] = password_encode(ns['password']) await sor.U('users',ns) return {'status': True, 'msg': '修改成功'} else: return {'status': False, 'msg': '验证码不正确'} ret = await getretrieve(params_kw) return ret