27 lines
1.0 KiB
Plaintext
27 lines
1.0 KiB
Plaintext
async def alipays(ns):
|
|
"""支付宝线上充值"""
|
|
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
if float(ns['amount']) < 1:
|
|
return {'status': False, 'msg': '充值金额不能小于1块钱'}
|
|
try:
|
|
user = await sor.R('users',{'id':ns['userid']})
|
|
recharge_logdict = {}
|
|
recharge_logdict['id'] = uuid()
|
|
recharge_logdict['customerid'] = user[0]['orgid']
|
|
recharge_logdict['action'] = 'RECHARGE_ALIPAY'
|
|
recharge_logdict['recharge_path'] = '0'
|
|
recharge_logdict['recharge_amt'] = ns['amount']
|
|
await sor.C('recharge_log',recharge_logdict)
|
|
out_trade_no = recharge_logdict['id']
|
|
total_amount = float(ns['amount'])
|
|
subject = 'kboss-充值'
|
|
pay = await alipay(out_trade_no,total_amount,subject)
|
|
return {'status': True, 'url': pay}
|
|
except Exception as e:
|
|
raise e
|
|
return {'status': False, 'msg': '失败'}
|
|
|
|
ret = await alipays(params_kw)
|
|
return ret |