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

Compare commits

base: yumoqing:9fb678fd92d6e0b35fe6b53e7fb3dc45841215a2
Branches Tags
yumoqing:main
yumoqing:prod
yumoqing:dev1
..
compare: yumoqing:47e4e9718a27b4e52c29c952d1f8b5fb04e6fba6
Branches Tags
yumoqing:prod
yumoqing:main
yumoqing:dev1

No commits in common. "9fb678fd92d6e0b35fe6b53e7fb3dc45841215a2" and "47e4e9718a27b4e52c29c952d1f8b5fb04e6fba6" have entirely different histories.
9fb678fd92 ... 47e4e9718a

1 changed files with 22 additions and 28 deletions
Show Stats Expand all files Collapse all files

46
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' % str(e)) print('发送短信失败: %s' % 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': '相关服务' 'productname': None
} }
await diff_sms_send_save(sor=sor, time_interval=24*60, send_type='用户欠费通知', user_orgid=orgid[0]['id'], sms_send_dict=sms_send_dict) await diff_sms_send_save(sor=sor, time_interval=24*60, send_type='用户欠费通知', user_orgid=orgid, sms_send_dict=sms_send_dict)
return {'status': False,'msg': '该账号余额不足，无法完成购买'} return {'status': False,'msg': '该账号余额不足，无法完成购买'}
except Exception as e: except Exception as e:
@ -793,30 +793,24 @@ async def baidu_confirm_auto_renew_order(ns={}):
# return {'1': renew_sql} # return {'1': renew_sql}
renew_results = await sor.sqlExe(renew_sql, {}) renew_results = await sor.sqlExe(renew_sql, {})
try: renew_status_count = 0
renew_status_count = 0 # 执行 get_baidu_orderlist sor分开运行
# 执行 get_baidu_orderlist sor分开运行 for renew_res in renew_results:
for renew_res in renew_results: order_id = renew_res.get('orderid')
order_id = renew_res.get('orderid') user_id = renew_res.get('user_id')
user_id = renew_res.get('user_id')
renew_status = await get_baidu_orderlist({'order_id': order_id, 'userid': user_id}) renew_status = await get_baidu_orderlist({'order_id': order_id, 'userid': user_id})
if renew_status.get('status'): if renew_status.get('status'):
renew_status_count += 1 renew_status_count += 1
else: else:
db = DBPools() ns_err_log = {
async with db.sqlorContext('kboss') as sor: 'id': uuid(),
ns_err_log = { 'log_level': 'ERROR',
'id': uuid(), 'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)),
'log_level': 'ERROR', 'user_id': user_id,
'log_content': '续费订单 %s 失败 %s' % (order_id, str(renew_status)), 'request_url': '/baiduc/baidu_confirm_auto_renew_order.dspy'
'user_id': user_id, }
'request_url': '/baiduc/baidu_confirm_auto_renew_order.dspy' await sor.C('warn_error_log', ns_err_log)
}
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})