diff --git a/b/baiduc/baidu_users_get_post_pay.dspy b/b/baiduc/baidu_users_get_post_pay.dspy index aaafa24..6820347 100644 --- a/b/baiduc/baidu_users_get_post_pay.dspy +++ b/b/baiduc/baidu_users_get_post_pay.dspy @@ -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) 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: print('用户: %s, 账单: %s, 扣费失败: %s' % (user_orgid, info_detail['billid'], e)) if not bill_exist: @@ -645,8 +649,8 @@ async def baidu_users_get_post_pay(ns={}): userid = baidu_user['user_id'] baidu_id = baidu_user['baidu_id'] - if baidu_id != 'a6f0dbc20f074ea18b4d3ac3ec77d537': - continue + # if baidu_id != 'f61b662bcd684499b6403371365715b9': + # continue try: user_orgid = (await sor.R('users', {'id': userid}))[0]['orgid'] user_parentid = (await sor.R('organization', {'id': user_orgid}))[0]['parentid']