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-22 15:23:37 +08:00
parent d824aa43f0
commit 062ab4e6a5
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) await send_vcode(customer_phone, send_type, sms_send_dict)
except Exception as e: except Exception as e:
print('发送短信失败: %s' % e) print('发送短信失败: %s' % str(e))
return { return {
'status': False, 'status': False,
'msg': '发送短信失败', 'msg': '发送短信失败',
@ -662,9 +662,9 @@ async def get_baidu_orderlist(ns={}):
# 发送短信 # 发送短信
sms_send_dict = { sms_send_dict = {
'time': time.strftime('%Y-%m-%d %H:') + '00:00', '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': '该账号余额不足，无法完成购买'} return {'status': False,'msg': '该账号余额不足，无法完成购买'}
except Exception as e: 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'; """ 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} # return {'1': renew_sql}
renew_results = await sor.sqlExe(renew_sql, {}) renew_results = await sor.sqlExe(renew_sql, {})
renew_status_count = 0 try:
# 执行 get_baidu_orderlist sor分开运行 renew_status_count = 0
for renew_res in renew_results: # 执行 get_baidu_orderlist sor分开运行
order_id = renew_res.get('orderid') for renew_res in renew_results:
user_id = renew_res.get('user_id') 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 = await get_baidu_orderlist({'order_id': order_id, 'userid': user_id})
renew_status_count += 1 if renew_status.get('status'):
else: renew_status_count += 1
ns_err_log = { else:
'id': uuid(), db = DBPools()
'log_level': 'ERROR', async with db.sqlorContext('kboss') as sor:
'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)), ns_err_log = {
'user_id': user_id, 'id': uuid(),
'request_url': '/baiduc/baidu_confirm_auto_renew_order.dspy' 'log_level': 'ERROR',
} 'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)),
await sor.C('warn_error_log', ns_err_log) '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函数
update_msg = await update_baidu_order_list({'orgid': orgid}) update_msg = await update_baidu_order_list({'orgid': orgid})