yumoqing/kboss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
ping 2025-12-16 18:09:32 +08:00
parent 89b29980de
commit a57ec1f2e4
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
b/baiduc/baidu_users_get_post_pay.dspy
View File

@ -340,6 +340,10 @@ async def baidu_post_pay_charge(bill_exist=None, info_detail=None, baidu_orgid=N
} }
await sor_bill.U('baidu_post_bill', ns_bill_status) await sor_bill.U('baidu_post_bill', ns_bill_status)
print('百度账单扣费: %s, 扣费成功' % info_detail['billid']) print('百度账单扣费: %s, 扣费成功' % info_detail['billid'])
# 扣费成功后 arrears表中数据更新
update_arrears_sql = """update arrears set bill_state = '1' and endtime = '%s' where localid = '%s';""" % (time.strftime('%Y-%m-%d %H:%M:%S'), info_detail_id)
await sor_bill.sqlExe(update_arrears_sql, {})
except Exception as e: except Exception as e:
print('用户: %s, 账单: %s, 扣费失败: %s' % (user_orgid, info_detail['billid'], e)) print('用户: %s, 账单: %s, 扣费失败: %s' % (user_orgid, info_detail['billid'], e))
if not bill_exist: if not bill_exist:
@ -645,8 +649,8 @@ async def baidu_users_get_post_pay(ns={}):
userid = baidu_user['user_id'] userid = baidu_user['user_id']
baidu_id = baidu_user['baidu_id'] baidu_id = baidu_user['baidu_id']
if baidu_id != 'a6f0dbc20f074ea18b4d3ac3ec77d537': # if baidu_id != 'f61b662bcd684499b6403371365715b9':
continue # continue
try: try:
user_orgid = (await sor.R('users', {'id': userid}))[0]['orgid'] user_orgid = (await sor.R('users', {'id': userid}))[0]['orgid']
user_parentid = (await sor.R('organization', {'id': user_orgid}))[0]['parentid'] user_parentid = (await sor.R('organization', {'id': user_orgid}))[0]['parentid']