From 18e5021c6485a4d24b567260ffae0ff651dbef3a Mon Sep 17 00:00:00 2001 From: ping <1017253325@qq.com> Date: Fri, 21 Nov 2025 18:19:02 +0800 Subject: [PATCH] update --- b/baiduc/baidu_confirm_refund_order.dspy | 22 ++++++++++++++++------ 1 file changed, 16 insertions(+), 6 deletions(-) diff --git a/b/baiduc/baidu_confirm_refund_order.dspy b/b/baiduc/baidu_confirm_refund_order.dspy index 6312104..ed3ad96 100644 --- a/b/baiduc/baidu_confirm_refund_order.dspy +++ b/b/baiduc/baidu_confirm_refund_order.dspy @@ -72,15 +72,20 @@ async def affirmbz_order(ns={}): resource_find_sql = """select id, resourceid, expire_resourceid from customer_goods where FIND_IN_SET('%s', resourceid) and del_flg = '0';""" % j['resourceids'] resource_find_li = await sor.sqlExe(resource_find_sql, {}) resource_find_id = resource_find_li[0]['id'] + expire_resourceid = resource_find_li[0]['expire_resourceid'] - expire_resourceid += expire_resourceid + ',' + j['resourceids'] if expire_resourceid else j['resourceids'] + if expire_resourceid: + new_expire_resourceid = expire_resourceid + ',' + j['resourceids'] + else: + new_expire_resourceid = j['resourceids'] + items_refund = resource_find_li[0]['resourceid'].split(',') if resource_find_li[0]['resourceid'] else [] filtered_items = [item for item in items_refund if item != j['resourceids']] result = ','.join(filtered_items) if not result: await sor.U('customer_goods', {'id': resource_find_id, 'del_flg': '1'}) else: - await sor.U('customer_goods', {'id': resource_find_id, 'resourceid': result, 'expire_resourceid': expire_resourceid}) + await sor.U('customer_goods', {'id': resource_find_id, 'resourceid': result, 'expire_resourceid': new_expire_resourceid}) # 处理续费逻辑 elif order_type == 'RENEW': @@ -118,7 +123,11 @@ async def affirmbz_order(ns={}): return {'status': True, 'msg': '支付成功'} except Exception as error: await sor.rollback() - return {'status': False, 'msg': str(error)} + import traceback + with open('baiducloud_err.txt', 'w') as f: + f.write(str(error) + str(traceback.format_exc())) + traceback.print_exc() + return {'status': False, 'msg': str(error) + str(traceback.format_exc())} async def baidu_new_update_resouce(ns={}): @@ -514,7 +523,8 @@ async def get_baidu_orderlist(ns={}): await user_action_record(ns_record) return { 'status': False, - 'msg': '支付错误, 请联系售后' + 'msg': '支付错误, 请联系售后,', + 'data': affirmbz_order_res } # 预配置local_refund用于本地操作 @@ -737,8 +747,8 @@ async def update_baidu_order_list(ns={}): async def baidu_confirm_refund_order(ns={}): # ns = { - # 'order_id': ["13f3518648054796abf7f3d00ed611bf"], - # 'userid': 'KsKhCUPizQyGiw3L1WVRy' + # 'order_id': ["2996f0baf34c4a0a98e1da0b4e290a35"], + # 'userid': 'y_xQK0G62dtZT5EneMQFT' # } import asyncio # 把 NEED_CONFIRM的订单同步到本地库，用于后续状态更新