update

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的订单同步到本地库，用于后续状态更新