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

updata

Browse Source
This commit is contained in:
hrx 2025-12-22 16:54:37 +08:00
commit 5c882cc2f9
1 changed files with 28 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
b/baiduc/baidu_confirm_auto_renew_order.dspy
View File

@ -248,7 +248,7 @@ async def diff_sms_send_save(sor=None, productname=None, time_interval=24*60, se
# 给个人发送短信
await send_vcode(customer_phone, send_type, sms_send_dict)
except Exception as e:
print('发送短信失败: %s' % e)
print('发送短信失败: %s' % str(e))
return {
'status': False,
'msg': '发送短信失败',
@ -662,9 +662,9 @@ async def get_baidu_orderlist(ns={}):
# 发送短信
sms_send_dict = {
'time': time.strftime('%Y-%m-%d %H:') + '00:00',
'productname': None
'productname': '相关服务'
}
await diff_sms_send_save(sor=sor, time_interval=24*60, send_type='用户欠费通知', user_orgid=orgid, sms_send_dict=sms_send_dict)
await diff_sms_send_save(sor=sor, time_interval=24*60, send_type='用户欠费通知', user_orgid=orgid[0]['id'], sms_send_dict=sms_send_dict)
return {'status': False,'msg': '该账号余额不足，无法完成购买'}
except Exception as e:
@ -792,25 +792,31 @@ async def baidu_confirm_auto_renew_order(ns={}):
renew_sql = """ SELECT bo.*, bs.user_id FROM baidu_orders AS bo LEFT JOIN baidu_users AS bs ON bo.accountid = bs.baidu_id WHERE bo.ordertype = 'RENEW' AND bo.status = 'NEED_CONFIRM' AND bo.del_flg = '0'; """
# return {'1': renew_sql}
renew_results = await sor.sqlExe(renew_sql, {})
renew_status_count = 0
# 执行 get_baidu_orderlist sor分开运行
for renew_res in renew_results:
order_id = renew_res.get('orderid')
user_id = renew_res.get('user_id')
renew_status = await get_baidu_orderlist({'order_id': order_id, 'userid': user_id})
if renew_status.get('status'):
renew_status_count += 1
else:
ns_err_log = {
'id': uuid(),
'log_level': 'ERROR',
'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)),
'user_id': user_id,
'request_url': '/baiduc/baidu_confirm_auto_renew_order.dspy'
}
await sor.C('warn_error_log', ns_err_log)
try:
renew_status_count = 0
# 执行 get_baidu_orderlist sor分开运行
for renew_res in renew_results:
order_id = renew_res.get('orderid')
user_id = renew_res.get('user_id')
renew_status = await get_baidu_orderlist({'order_id': order_id, 'userid': user_id})
if renew_status.get('status'):
renew_status_count += 1
else:
db = DBPools()
async with db.sqlorContext('kboss') as sor:
ns_err_log = {
'id': uuid(),
'log_level': 'ERROR',
'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)),
'user_id': user_id,
'request_url': '/baiduc/baidu_confirm_auto_renew_order.dspy'
}
await sor.C('warn_error_log', ns_err_log)
except Exception as e:
print(e)
# 并触发update函数
update_msg = await update_baidu_order_list({'orgid': orgid})