33 lines
1.2 KiB
Plaintext
33 lines
1.2 KiB
Plaintext
roles = await get_user_roles()
|
|
for r in roles:
|
|
if not r.startswith("owner."):
|
|
return UiError(title="手工充值", message="只有平台用户才能执行")
|
|
userorgid = await get_userorgid()
|
|
if params_kw.customerid == userorgid:
|
|
return UiError(title="手工充值",message="不能给平台机构充值")
|
|
db = DBPools()
|
|
dbname = get_module_dbname('unipay')
|
|
async with db.sqlorContext(dbname) as sor:
|
|
recs = await sor.R('organization', {'id': params_kw.customerid})
|
|
if len(recs) < 0:
|
|
return UiError(title="手工充值",
|
|
message=f"客户机构不存在{params_kw.customerid}")
|
|
|
|
pl = PaymentLog(request._run_ns)
|
|
plid = await pl.new_log(serid, params_kw.customerid, 'manual',
|
|
'手工充值', params_kw.amount, 0.0,
|
|
request['client_ip'], currency='CNY')
|
|
|
|
async with db.sqlorContext(dbname) as sor:
|
|
biz_date = await get_business_date(sor)
|
|
await recharge_accounting(sor, params_kw.customerid, 'RECHARGE',
|
|
plid,
|
|
biz_date,
|
|
params_kw.amount,
|
|
0.00)
|
|
pl.payed_log(plid)
|
|
return UiMessage(title="手工充值",message=f"充值{params_kw.amount} 成功")
|
|
exception(f'Exception:{db.e_except}')
|
|
return UiError(title="手工充值",
|
|
message=f"充值失败")
|