async def upledger_examine(ns): """ 线下充值冲账审核提交 orgid – 机构 id user_id – 内部用户id business_id – 业务id form_component – 表单参数 result_org – 被执行机构 original_id – 原充值日志id """ db = DBPools() async with db.sqlorContext('kboss') as sor: try: orgid = await sor.R('users',{'id':ns['userid']}) apv_business = await sor.R('apv_business', {'del_flg': '0', 'business_name': '充值冲账'}) if len(apv_business) < 1: return {'status': False, 'msg': '失败'} issue_approvecode = await issue_approve(phone=orgid[0]['mobile'],orgid=orgid[0]['orgid'], user_id=ns['userid'], business_id=apv_business[0]['id'], form_component={"title": {"": ""},'detail': {'price': ns['balance']}},result_org=ns['orgid'],original_id=ns['id']) if issue_approvecode['status'] ==True: return {'status': True, 'msg': '提交成功,请等待审核'} else: return {'status': False, 'msg': '失败'} except Exception as e: raise e return {'status': False, 'msg': '失败'} ret = await upledger_examine(params_kw) return ret