From 590a65475bd271284bfa6f7bcdfbfcf9824cfb38 Mon Sep 17 00:00:00 2001
From: wuweihua <88888888>
Date: Tue, 29 Sep 2026 09:49:22 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=90=8C=E6=AD=A5=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/bms/price/search/EsBizLogSupport.java | 27 +++++++++++++------
 .../service/impl/PrcOrderBillServiceImpl.java | 10 ++++---
 2 files changed, 26 insertions(+), 11 deletions(-)

diff --git a/bms-back/bms-system/src/main/java/com/bms/price/search/EsBizLogSupport.java b/bms-back/bms-system/src/main/java/com/bms/price/search/EsBizLogSupport.java
index 5a9cf335..a215a129 100644
--- a/bms-back/bms-system/src/main/java/com/bms/price/search/EsBizLogSupport.java
+++ b/bms-back/bms-system/src/main/java/com/bms/price/search/EsBizLogSupport.java
@@ -94,11 +94,27 @@ public final class EsBizLogSupport
         return text;
     }
 
+    /**
+     * Billing ES bizId: prefer transferNo, then orderNo.
+     */
     public static String billBizId(TmsPriceBillRequest request)
     {
-        if (request != null && StringUtils.isNotEmpty(request.getOrderNo()))
+        if (request == null)
         {
-            return request.getOrderNo().trim();
+            return "FAIL-" + UUID.randomUUID();
+        }
+        return billBizId(request.getTransferNo(), request.getOrderNo());
+    }
+
+    public static String billBizId(String transferNo, String orderNo)
+    {
+        if (StringUtils.isNotEmpty(transferNo))
+        {
+            return transferNo.trim();
+        }
+        if (StringUtils.isNotEmpty(orderNo))
+        {
+            return orderNo.trim();
         }
         return "FAIL-" + UUID.randomUUID();
     }
@@ -213,12 +229,7 @@ public final class EsBizLogSupport
             {
                 return billFailBizId((TmsPriceBillRequest) boundTarget);
             }
-            String orderNo = extractJsonField(rawBody, "orderNo");
-            if (StringUtils.isNotEmpty(orderNo))
-            {
-                return orderNo.trim();
-            }
-            return "FAIL-" + UUID.randomUUID();
+            return billBizId(extractJsonField(rawBody, "transferNo"), extractJsonField(rawBody, "orderNo"));
         }
         if (EsLogType.QUOTE.equals(logType))
         {
diff --git a/bms-back/bms-system/src/main/java/com/bms/price/service/impl/PrcOrderBillServiceImpl.java b/bms-back/bms-system/src/main/java/com/bms/price/service/impl/PrcOrderBillServiceImpl.java
index f478d539..b534786e 100644
--- a/bms-back/bms-system/src/main/java/com/bms/price/service/impl/PrcOrderBillServiceImpl.java
+++ b/bms-back/bms-system/src/main/java/com/bms/price/service/impl/PrcOrderBillServiceImpl.java
@@ -159,6 +159,7 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
             {
                 throw new ServiceException(MessageUtils.message("price.bill.notFound"));
             }
+            failReq.setTransferNo(bill.getTransferNo());
             assertOrderBillEditable(bill);
 
             List<PrcIncomeBillFee> fees = incomeBillFeeMapper.selectByBillId(bill.getBillId());
@@ -215,12 +216,15 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
             JSONObject req = new JSONObject();
             req.put("action", "REFUND");
             req.put("orderNo", orderNo);
+            req.put("transferNo", bill.getTransferNo());
             req.put("billId", bill.getBillId());
             req.put("refundAmount", feeSum.negate());
             req.put("feeId", refundFee.getFeeId());
             if (billSearchStore != null)
             {
-                billSearchStore.save(EsLogType.BILL, orderNo, req.toJSONString(), toResponseJson(result));
+                billSearchStore.save(EsLogType.BILL,
+                    EsBizLogSupport.billBizId(bill.getTransferNo(), orderNo),
+                    req.toJSONString(), toResponseJson(result));
             }
             return result;
         }
@@ -906,7 +910,7 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
         String requestJson = toRequestJson(request);
         persistBillExt(bill, request.getUpstreamRow());
         result.setRequestJson(requestJson);
-        billSearchStore.save(EsLogType.BILL, orderNo, requestJson, toResponseJson(result));
+        billSearchStore.save(EsLogType.BILL, EsBizLogSupport.billBizId(request), requestJson, toResponseJson(result));
     }
 
     /**
@@ -1355,7 +1359,7 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
             return null;
         }
         obj.remove("apiCode");
-        obj.remove("upstreamRow");
+        // Keep upstreamRow (Oracle/TAB_ORDER payload) in ES request for ops troubleshooting.
         return obj.toJSONString();
     }