diff --git a/b/baiduc/baidu_confirm_auto_renew_order.dspy b/b/baiduc/baidu_confirm_auto_renew_order.dspy index 0aafc0d..2f22643 100644 --- a/b/baiduc/baidu_confirm_auto_renew_order.dspy +++ b/b/baiduc/baidu_confirm_auto_renew_order.dspy @@ -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})