优化落库功能

2026-10-26 23:23:22 +08:00
parent 8fba64e2d6
commit 2bae431e74
9 changed files with 370 additions and 204 deletions
@@ -224,7 +224,7 @@ public class TabOrderMonitorController extends BaseController
    @PostMapping("/syncByFilter")
    public AjaxResult syncByFilter(@RequestBody TabOrderMonitorQuery query)
    {
-        // 与列表查询同口径：有单号即可同步；无单号时必须客户 + 提货时间
+        // Upstream field overwrite only (no billing). Same filters as list query.
        if (!hasListFilters(query))
        {
            return error("orderIdentifiers or (customer and pickup time) required");
@@ -257,6 +257,7 @@ public class TabOrderMonitorController extends BaseController
        return success(task);
    }

+    /** Selected rows: overwrite local bill fields from Oracle; does not quote/rebill. */
    @PreAuthorize("@ss.hasPermi('monitor:orderSource:sync') or @ss.hasPermi('price:orderBill:rebill')")
    @Log(title = "order source sync selected", businessType = BusinessType.UPDATE)
    @PostMapping("/sync")
@@ -2,8 +2,8 @@ package com.bms.price.enums;

 /**
 * Snapshot of prc_order_bill.order_status (aligned with upstream TAB_ORDER).
- * Fee refund sets {@link #REFUNDED} (9 / 已退件).
- * Upstream 9/10 trigger billType=REFUND when billing pulls Oracle.
+ * Fee refund sets {@link #REFUNDED} (9 / 已退件); rebill/bill follows Oracle and does not pin 9/10.
+ * Upstream 9/10 trigger billType=REFUND when billing-task pulls Oracle.
 */
 public enum BillOrderStatus
 {
@@ -35,14 +35,15 @@ public class OracleOrderBillMapper
        req.setUpstreamRow(row);
        req.setCustomerCode(firstStr(row, "CUSTOMER_CODE"));
        req.setCustomerName(firstStr(row, "CUSTOMER_NAME"));
-        // Map LINE_CODE/LINE_NAME to product_code/product_name; fallback PRODUCT_*.
-        String product = firstStr(row, "LINE_CODE", "PRODUCT_CODE");
+        // Upstream product identity: TAB_ORDER.LINE_CODE / LINE_NAME only
+        // (BMS product_code_mapping applied later in quote / persist).
+        String product = firstStr(row, "LINE_CODE");
        if (StringUtils.isEmpty(product))
        {
            product = defaultProductCode;
        }
        req.setProductCode(product);
-        req.setProductName(firstStr(row, "LINE_NAME", "PRODUCT_NAME"));
+        req.setProductName(firstStr(row, "LINE_NAME"));
        req.setCountryCode(firstStr(row, "COUNTRY"));
        String countryName = firstStr(row, "COUNTRY_NAME", "COUNTRY_EINGTH_NAME", "COUNTRY");
        req.setCountryName(countryName);
@@ -24,6 +24,16 @@ public interface IPrcOrderBillService
 {
    TmsPriceQuoteResult bill(TmsPriceBillRequest request);

+    /**
+     * Order-source sync only: overwrite local {@code prc_order_bill} + {@code prc_order_bill_ext}
+     * from an Oracle TAB_ORDER row. No quote / credit / fee / refund / AR validation.
+     * Rebilling remains on the order-list local-rebill path.
+     *
+     * @param upstreamRow Oracle TAB_ORDER full row
+     * @return billId
+     */
+    String syncUpstreamOverwrite(java.util.Map<String, Object> upstreamRow);
+
    /**
     * Persist prc_order_bill and ext when billing cannot produce a quote.
     * Status outside 0/1/2/3 does not write prc_income_bill.
@@ -290,6 +290,19 @@ public class PrcBillingTaskServiceImpl implements IPrcBillingTaskService
        task.setCustomerCode(billReq.getCustomerCode());
        try
        {
+            // No hard validate on customer/product/weight: always try bill (or soft-fail snapshot)
+            // so upstream fields still overwrite. Quote failures land in persistFailedSnapshot.
+            if (StringUtils.isEmpty(billReq.getOrderNo()))
+            {
+                if (StringUtils.isNotEmpty(billReq.getTransferNo()))
+                {
+                    billReq.setOrderNo(billReq.getTransferNo().trim());
+                }
+                else if (StringUtils.isNotEmpty(billReq.getTrackingNo()))
+                {
+                    billReq.setOrderNo(billReq.getTrackingNo().trim());
+                }
+            }
            if (StringUtils.isEmpty(billReq.getOrderNo()) && StringUtils.isEmpty(billReq.getTransferNo()))
            {
                throw new ServiceException("Oracle order mapped orderNo empty");
@@ -308,18 +321,6 @@ public class PrcBillingTaskServiceImpl implements IPrcBillingTaskService
                deleteTaskAfterBillSaved(task);
                return;
            }
-            if (StringUtils.isEmpty(billReq.getCustomerCode()))
-            {
-                throw new ServiceException("Oracle order mapped customerCode empty");
-            }
-            if (StringUtils.isEmpty(billReq.getProductCode()))
-            {
-                throw new ServiceException("Oracle order mapped productCode empty");
-            }
-            if (billReq.getWeight() == null || billReq.getWeight().signum() <= 0)
-            {
-                throw new ServiceException("Oracle order mapped weight invalid");
-            }
            billWithDbRetry(taskId, billReq);
        }
        catch (RuntimeException e)
@@ -46,6 +46,7 @@ import com.bms.customer.customerinfo.domain.BmsCustomer;
 import com.bms.customer.customerinfo.mapper.BmsCustomerMapper;
 import com.bms.system.mapper.SysUserMapper;
 import com.bms.system.service.IBmsBizRuleService;
+import com.bms.system.service.IBmsProductCodeMappingService;
 import com.bms.price.domain.PrcIncomeBill;
 import com.bms.price.domain.PrcIncomeBillFee;
 import com.bms.price.domain.PrcOrderBill;
@@ -88,6 +89,7 @@ import com.bms.price.mapper.PrcOrderBillMapper;
 import com.bms.price.mapper.PrcPayBillFeeMapper;
 import com.bms.price.mapper.PrcPayBillMapper;
 import com.bms.price.oracle.OracleOrderBillExtFiller;
+import com.bms.price.oracle.OracleOrderBillMapper;
 import com.bms.price.search.EsBizLogSupport;
 import com.bms.price.search.EsLogType;
 import com.bms.price.search.IBillSearchStore;
@@ -129,6 +131,9 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
    @Autowired
    private PrcOrderBillExtMapper orderBillExtMapper;

+    @Autowired
+    private OracleOrderBillMapper oracleOrderBillMapper;
+
    @Autowired
    private PrcIncomeBillFeeMapper incomeBillFeeMapper;

@@ -171,6 +176,9 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
    @Autowired
    private IBmsBizRuleService bizRuleService;

+    @Autowired
+    private IBmsProductCodeMappingService productCodeMappingService;
+
    private static final int BATCH_ADD_FEE_MAX = 5000;
    private static final int BATCH_ADD_FEE_PREVIEW_LIMIT = 20;
    private static final int CHARGE_WEIGHT_IMPORT_MAX = 5000;
@@ -1322,12 +1330,14 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
        bill.setSurchargeAmount(surchargeTotal);
        bill.setIncomeTotal(incomeTotal);

+        String refundStatus = resolveRefundStatus(fees);
        PrcIncomeBill incomeBill = incomeBillMapper.selectByBillId(bill.getBillId());
        if (incomeBill != null)
        {
            incomeBill.setSalesAmount(incomeTotal);
            incomeBill.setIncomeTotal(incomeTotal);
            incomeBill.setCurrency(StringUtils.isEmpty(bill.getCurrency()) ? "CNY" : bill.getCurrency());
+            incomeBill.setRefundStatus(refundStatus);
            incomeBillMapper.updatePrcIncomeBill(incomeBill);
        }

@@ -1335,7 +1345,7 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
            StringUtils.isEmpty(bill.getCustomerActiveStatus())
                ? BillCustomerActiveStatus.ACTIVE.getCode() : bill.getCustomerActiveStatus());
        bill.setCreditArrearsStatus(creditArrearsStatus);
-        bill.setRefundStatus(resolveRefundStatus(fees));
+        bill.setRefundStatus(refundStatus);
        orderBillMapper.updatePrcOrderBill(bill);
        orderBillMapper.refreshArBillStatusByBillIds(Arrays.asList(bill.getBillId()));
        return toResult(bill, fees, payBillFeeMapper.selectByBillId(bill.getBillId()));
@@ -1660,54 +1670,49 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
        }
        bill.setBillKey(billKey);
        bill.setOrderNo(orderNo);
+        // Upstream header overwrite (no validate); charge_weight kept via resolvePersistChargeWeight below.
+        applyUpstreamBillHeaderFields(bill, request);
        Long customerId = request.getCustomerId();
        if (customerId == null && result != null)
        {
            customerId = result.getCustomerId();
        }
-        bill.setCustomerId(customerId == null ? Long.valueOf(0L) : customerId);
-        String customerCode = request.getCustomerCode();
-        if (StringUtils.isEmpty(customerCode) && result != null)
+        if (customerId == null || customerId.longValue() <= 0L)
        {
-            customerCode = result.getCustomerCode();
+            customerId = resolveCustomerIdByCode(request.getCustomerCode(), bill.getCustomerId());
+        }
+        bill.setCustomerId(customerId == null ? Long.valueOf(0L) : customerId);
+        if (StringUtils.isEmpty(bill.getCustomerCode()) && result != null)
+        {
+            bill.setCustomerCode(result.getCustomerCode());
        }
-        bill.setCustomerCode(customerCode);
-        bill.setCustomerName(request.getCustomerName());
-        bill.setTrackingNo(request.getTrackingNo());
-        bill.setTransferNo(request.getTransferNo());
-        // Oracle 中文人员名 -> sys_user.nick_name，*_code 写 user_name（数据权限）
-        resolveOrderStaffFromSysUser(request);
-        bill.setBelongSaler(request.getBelongSaler());
-        bill.setBelongSalerCode(request.getBelongSalerCode());
-        bill.setSettlementMan(request.getSettlementMan());
-        bill.setSettlementManCode(request.getSettlementManCode());
-        bill.setServiceMan(request.getServiceMan());
-        bill.setServiceManCode(request.getServiceManCode());
        String customerActiveStatus = result == null ? null : result.getCustomerActiveStatus();
        if (StringUtils.isEmpty(customerActiveStatus))
        {
            customerActiveStatus = BillCustomerActiveStatus.ACTIVE.getCode();
        }
        bill.setCustomerActiveStatus(customerActiveStatus);
-        bill.setPieces(request.getPieces());
-        bill.setActualWeight(request.getActualWeight());
-        bill.setReceiveWeight(request.getReceiveWeight());
-        bill.setVolume(request.getVolume());
-        bill.setVolumeWeight(request.getVolumeWeight());
-        bill.setPkgLength(request.getPkgLength());
-        bill.setPkgWidth(request.getPkgWidth());
-        bill.setPkgHeight(request.getPkgHeight());
-        bill.setShipperName(request.getShipperName());
-        bill.setConsigneeName(request.getConsigneeName());
-        bill.setDestPostcode(request.getDestPostcode());
-        bill.setWarehouseCode(request.getWarehouseCode());
-        bill.setOrderTime(request.getOrderTime());
-        applyUpstreamOrderStatus(bill, request);
-        bill.setOrderRemark(request.getOrderRemark());
-        bill.setProductCode(result.getProductCode());
-        bill.setProductName(result.getProductName());
-        bill.setCountryCode(result.getCountryCode());
-        bill.setCountryName(result.getCountryName());
+        // Product: quote result already resolved LINE_CODE via product_code_mapping.
+        if (result != null && StringUtils.isNotEmpty(result.getProductCode()))
+        {
+            bill.setProductCode(result.getProductCode());
+        }
+        else
+        {
+            applyProductCodeMapping(bill, request);
+        }
+        if (result != null && StringUtils.isNotEmpty(result.getProductName()))
+        {
+            bill.setProductName(result.getProductName());
+        }
+        if (StringUtils.isEmpty(bill.getCountryCode()) && result != null)
+        {
+            bill.setCountryCode(result.getCountryCode());
+        }
+        if (StringUtils.isEmpty(bill.getCountryName()) && result != null)
+        {
+            bill.setCountryName(result.getCountryName());
+        }
        // weight = system/original; charge_weight = effective (may be manual override)
        bill.setWeight(weight);
        bill.setBizDate(bizDate);
@@ -2803,6 +2808,151 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
        return parsed;
    }

+    /**
+     * Order-source sync: full upstream field overwrite onto local bill + ext.
+     * Does not quote, occupy credit, touch fees, or validate AR / refund.
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public String syncUpstreamOverwrite(java.util.Map<String, Object> upstreamRow)
+    {
+        if (upstreamRow == null || upstreamRow.isEmpty())
+        {
+            throw new ServiceException("Oracle order row empty");
+        }
+        TmsPriceBillRequest request = oracleOrderBillMapper.toBillRequest(upstreamRow, null);
+        if (request == null)
+        {
+            throw new ServiceException("Oracle order mapped empty");
+        }
+        request.setUpstreamRow(upstreamRow);
+
+        String orderNo = StringUtils.trim(request.getOrderNo());
+        String transferNo = StringUtils.trim(request.getTransferNo());
+        String trackingNo = StringUtils.trim(request.getTrackingNo());
+        if (StringUtils.isEmpty(orderNo))
+        {
+            orderNo = transferNo;
+        }
+        if (StringUtils.isEmpty(orderNo))
+        {
+            orderNo = trackingNo;
+        }
+        if (StringUtils.isEmpty(orderNo))
+        {
+            throw new ServiceException("Oracle order mapped orderNo empty");
+        }
+        request.setOrderNo(orderNo);
+
+        PrcOrderBill existed = orderBillMapper.selectPrcOrderBillByOrderNo(orderNo);
+        if (existed == null && StringUtils.isNotEmpty(transferNo))
+        {
+            existed = orderBillMapper.selectPrcOrderBillByTransferNo(transferNo);
+        }
+        if (existed == null && StringUtils.isNotEmpty(trackingNo))
+        {
+            List<PrcOrderBill> byTrack = orderBillMapper.selectPrcOrderBillByTmsIdentifier(trackingNo);
+            if (byTrack != null && !byTrack.isEmpty())
+            {
+                existed = byTrack.get(0);
+            }
+        }
+
+        boolean creating = existed == null;
+        PrcOrderBill bill = creating ? new PrcOrderBill() : existed;
+        if (creating)
+        {
+            bill.setBillId(UUID.randomUUID().toString());
+            bill.setArBillStatus(ArOrderBillStatus.UNBILLED.getCode());
+            bill.setRefundStatus(BillRefundStatus.NONE.getCode());
+            bill.setBillingFailStatus(Integer.valueOf(BillBillingFailStatus.SUCCESS.getCode()));
+            bill.setFreightRate(BigDecimal.ZERO);
+            bill.setBaseFreightRate(BigDecimal.ZERO);
+            bill.setRegistrationFee(BigDecimal.ZERO);
+            bill.setFreightAmount(BigDecimal.ZERO);
+            bill.setSurchargeAmount(BigDecimal.ZERO);
+            bill.setIncomeTotal(BigDecimal.ZERO);
+            bill.setPayTotal(BigDecimal.ZERO);
+            bill.setCurrency("CNY");
+            bill.setRoundMode("HALF_UP");
+            bill.setCustomerActiveStatus(BillCustomerActiveStatus.ACTIVE.getCode());
+            bill.setCreditArrearsStatus(BillCreditArrearsStatus.NORMAL.getCode());
+        }
+
+        bill.setBillKey(Md5Utils.hash(orderNo));
+        bill.setOrderNo(orderNo);
+        applyUpstreamBillHeaderFields(bill, request);
+        applyProductCodeMapping(bill, request);
+        Long customerId = resolveCustomerIdByCode(request.getCustomerCode(), bill.getCustomerId());
+        bill.setCustomerId(customerId == null ? Long.valueOf(0L) : customerId);
+        // System weight overwrite; charge_weight keeps existing manual override when present.
+        if (request.getWeight() != null)
+        {
+            bill.setWeight(request.getWeight());
+            if (creating || bill.getChargeWeight() == null)
+            {
+                bill.setChargeWeight(request.getWeight());
+            }
+        }
+        if (creating)
+        {
+            Date bizDate = request.getPickupDate() != null ? request.getPickupDate() : new Date();
+            bill.setBizDate(bizDate);
+        }
+
+        if (creating)
+        {
+            orderBillMapper.insertPrcOrderBill(bill);
+        }
+        else
+        {
+            orderBillMapper.updatePrcOrderBill(bill);
+        }
+        persistBillExt(bill, upstreamRow);
+
+        JSONObject req = new JSONObject();
+        req.put("action", "UPSTREAM_SYNC");
+        req.put("orderNo", orderNo);
+        req.put("transferNo", bill.getTransferNo());
+        req.put("billId", bill.getBillId());
+        req.put("orderStatus", bill.getOrderStatus());
+        req.put("creating", Boolean.valueOf(creating));
+        billSearchStore.save(EsLogType.BILL, bill.getBillId(), req.toJSONString(),
+            "{\"ok\":true,\"action\":\"UPSTREAM_SYNC\"}");
+        return bill.getBillId();
+    }
+
+    /** Best-effort customer id by code; keep previous id when lookup misses. */
+    private Long resolveCustomerIdByCode(String customerCode, Long previousId)
+    {
+        if (StringUtils.isEmpty(customerCode))
+        {
+            return previousId;
+        }
+        try
+        {
+            BmsCustomer query = new BmsCustomer();
+            query.setCustomerCode(customerCode.trim());
+            List<BmsCustomer> list = bmsCustomerMapper.selectBmsCustomerList(query);
+            if (list != null)
+            {
+                for (BmsCustomer row : list)
+                {
+                    if (row != null && row.getCustomerId() != null
+                        && customerCode.trim().equalsIgnoreCase(StringUtils.trim(row.getCustomerCode())))
+                    {
+                        return row.getCustomerId();
+                    }
+                }
+            }
+        }
+        catch (RuntimeException e)
+        {
+            log.warn("resolveCustomerIdByCode skip code={} msg={}", customerCode, e.getMessage());
+        }
+        return previousId;
+    }
+
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void persistFailedSnapshot(TmsPriceBillRequest request, int billingFailStatus, String errorMessage)
@@ -2839,41 +2989,19 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
        }
        bill.setBillKey(Md5Utils.hash(orderNo));
        bill.setOrderNo(orderNo);
-        bill.setCustomerId(request.getCustomerId() == null ? Long.valueOf(0L) : request.getCustomerId());
-        bill.setCustomerCode(request.getCustomerCode());
-        bill.setCustomerName(request.getCustomerName());
-        bill.setTrackingNo(request.getTrackingNo());
-        bill.setTransferNo(request.getTransferNo());
-        resolveOrderStaffFromSysUser(request);
-        bill.setBelongSaler(request.getBelongSaler());
-        bill.setBelongSalerCode(request.getBelongSalerCode());
-        bill.setSettlementMan(request.getSettlementMan());
-        bill.setSettlementManCode(request.getSettlementManCode());
-        bill.setServiceMan(request.getServiceMan());
-        bill.setServiceManCode(request.getServiceManCode());
+        applyUpstreamBillHeaderFields(bill, request);
+        applyProductCodeMapping(bill, request);
+        Long customerId = request.getCustomerId();
+        if (customerId == null || customerId.longValue() <= 0L)
+        {
+            customerId = resolveCustomerIdByCode(request.getCustomerCode(), bill.getCustomerId());
+        }
+        bill.setCustomerId(customerId == null ? Long.valueOf(0L) : customerId);
        if (StringUtils.isEmpty(bill.getCustomerActiveStatus()))
        {
            bill.setCustomerActiveStatus(BillCustomerActiveStatus.ACTIVE.getCode());
        }
-        bill.setPieces(request.getPieces());
-        bill.setActualWeight(request.getActualWeight());
-        bill.setReceiveWeight(request.getReceiveWeight());
-        bill.setVolume(request.getVolume());
-        bill.setVolumeWeight(request.getVolumeWeight());
-        bill.setPkgLength(request.getPkgLength());
-        bill.setPkgWidth(request.getPkgWidth());
-        bill.setPkgHeight(request.getPkgHeight());
-        bill.setShipperName(request.getShipperName());
-        bill.setConsigneeName(request.getConsigneeName());
-        bill.setDestPostcode(request.getDestPostcode());
-        bill.setWarehouseCode(request.getWarehouseCode());
-        bill.setOrderTime(request.getOrderTime());
-        applyUpstreamOrderStatus(bill, request);
-        bill.setOrderRemark(request.getOrderRemark());
-        bill.setProductCode(request.getProductCode());
-        bill.setProductName(request.getProductName());
-        bill.setCountryCode(request.getCountryCode());
-        bill.setCountryName(request.getCountryName());
+        // Soft-fail snapshot: overwrite system weight; do not touch charge_weight (keep current logic).
        bill.setWeight(request.getWeight());
        Date bizDate = StringUtils.isEmpty(request.getBizDate()) ? new Date() : resolveBizDate(request.getBizDate());
        bill.setBizDate(bizDate);
@@ -2920,22 +3048,18 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
    }

    /**
-     * Locked by AR bill: write fail status + upstream ORDER_STATUS only.
-     * Amounts / income fees stay untouched.
+     * Locked by AR bill: overwrite upstream header + ext; keep amounts / fees / charge_weight.
     */
    private void persistFailedSnapshotWhenLocked(PrcOrderBill bill, TmsPriceBillRequest request,
        int billingFailStatus, String errorMessage)
    {
-        applyUpstreamOrderStatus(bill, request);
        if (request != null)
        {
-            if (StringUtils.isNotEmpty(request.getTrackingNo()))
+            applyUpstreamBillHeaderFields(bill, request);
+            applyProductCodeMapping(bill, request);
+            if (request.getWeight() != null)
            {
-                bill.setTrackingNo(request.getTrackingNo());
-            }
-            if (StringUtils.isNotEmpty(request.getTransferNo()))
-            {
-                bill.setTransferNo(request.getTransferNo());
+                bill.setWeight(request.getWeight());
            }
        }
        applyBillingFailText(bill, billingFailStatus, errorMessage);
@@ -2946,19 +3070,92 @@ public class PrcOrderBillServiceImpl implements IPrcOrderBillService
        }
    }

-    /** Prefer request status fields; never clear existing order_status with null. */
+    /**
+     * Overwrite local bill header fields from upstream request (no validation).
+     * Does not set weight / charge_weight / bizDate / amounts / customerId.
+     */
+    private void applyUpstreamBillHeaderFields(PrcOrderBill bill, TmsPriceBillRequest request)
+    {
+        if (bill == null || request == null)
+        {
+            return;
+        }
+        resolveOrderStaffFromSysUser(request);
+        bill.setCustomerCode(request.getCustomerCode());
+        bill.setCustomerName(request.getCustomerName());
+        bill.setTrackingNo(request.getTrackingNo());
+        bill.setTransferNo(request.getTransferNo());
+        bill.setBelongSaler(request.getBelongSaler());
+        bill.setBelongSalerCode(request.getBelongSalerCode());
+        bill.setSettlementMan(request.getSettlementMan());
+        bill.setSettlementManCode(request.getSettlementManCode());
+        bill.setServiceMan(request.getServiceMan());
+        bill.setServiceManCode(request.getServiceManCode());
+        bill.setPieces(request.getPieces());
+        bill.setActualWeight(request.getActualWeight());
+        bill.setReceiveWeight(request.getReceiveWeight());
+        bill.setVolume(request.getVolume());
+        bill.setVolumeWeight(request.getVolumeWeight());
+        bill.setPkgLength(request.getPkgLength());
+        bill.setPkgWidth(request.getPkgWidth());
+        bill.setPkgHeight(request.getPkgHeight());
+        bill.setShipperName(request.getShipperName());
+        bill.setConsigneeName(request.getConsigneeName());
+        bill.setDestPostcode(request.getDestPostcode());
+        bill.setWarehouseCode(request.getWarehouseCode());
+        bill.setOrderTime(request.getOrderTime());
+        applyUpstreamOrderStatus(bill, request);
+        bill.setOrderRemark(request.getOrderRemark());
+        // Source = TAB_ORDER.LINE_CODE / LINE_NAME (mapping applied by caller after quote / sync).
+        bill.setProductCode(request.getProductCode());
+        bill.setProductName(request.getProductName());
+        bill.setCountryCode(request.getCountryCode());
+        bill.setCountryName(request.getCountryName());
+    }
+
+    /**
+     * LINE_CODE (on request/bill) -> BMS product via product_code_mapping when configured.
+     */
+    private void applyProductCodeMapping(PrcOrderBill bill, TmsPriceBillRequest request)
+    {
+        if (bill == null || productCodeMappingService == null)
+        {
+            return;
+        }
+        String upstream = bill.getProductCode();
+        if (StringUtils.isEmpty(upstream) && request != null)
+        {
+            upstream = request.getProductCode();
+        }
+        if (StringUtils.isEmpty(upstream))
+        {
+            return;
+        }
+        String mapped = productCodeMappingService.resolveBmsProductCode(upstream.trim());
+        if (StringUtils.isEmpty(mapped))
+        {
+            return;
+        }
+        mapped = mapped.trim();
+        bill.setProductCode(mapped);
+        if (request != null)
+        {
+            request.setProductCode(mapped);
+        }
+    }
+
+    /**
+     * Prefer request status fields; never clear existing order_status with null.
+     * Do not pin order_status to 9/10 when refundStatus=REFUNDED — rebill / upstream
+     * bill must follow Oracle ORDER_STATUS. Actual fee refund still sets 9 in {@link #refund}.
+     */
    private static void applyUpstreamOrderStatus(PrcOrderBill bill, TmsPriceBillRequest request)
    {
        if (bill == null || request == null)
        {
            return;
        }
-        // Fee refund marks order_status=9 (已退件); do not let Oracle sync overwrite it.
-        if (BillRefundStatus.REFUNDED.getCode().equalsIgnoreCase(bill.getRefundStatus()))
-        {
-            bill.setOrderStatus(BillOrderStatus.REFUNDED.getCodeBoxed());
-        }
-        else if (request.getOrderStatus() != null)
+        if (request.getOrderStatus() != null)
        {
            bill.setOrderStatus(request.getOrderStatus());
        }
@@ -22,21 +22,17 @@ import org.springframework.stereotype.Component;
 import com.bms.common.core.redis.RedisCache;
 import com.bms.common.utils.StringUtils;
 import com.bms.price.config.BillingProperties;
-import com.bms.price.domain.PrcBillingTask;
 import com.bms.price.domain.PrcBillingTaskRetryTask;
-import com.bms.price.domain.vo.BillingTaskSubmitRequest;
 import com.bms.price.domain.vo.TabOrderMonitorQuery;
 import com.bms.price.domain.vo.TabOrderMonitorVo;
-import com.bms.price.enums.BillOrderStatus;
-import com.bms.price.enums.BillTaskSuccessStatus;
-import com.bms.price.enums.BillTaskType;
+import com.bms.price.oracle.OracleUpstreamOrderService;
 import com.bms.price.oracle.TabOrderMonitorService;
 import com.bms.price.search.IBillSearchStore;
 import com.bms.price.search.TabOrderSyncEsLog;
-import com.bms.price.service.IPrcBillingTaskService;
+import com.bms.price.service.IPrcOrderBillService;

 /**
- * Page Oracle TAB_ORDER then multi-thread submitAndProcess each row.
+ * Page Oracle TAB_ORDER then multi-thread overwrite local bill fields (no billing).
 */
@Component
 public class TabOrderSyncAsyncRunner
@@ -59,7 +55,10 @@ public class TabOrderSyncAsyncRunner

    @Autowired
    @Lazy
-    private IPrcBillingTaskService billingTaskService;
+    private IPrcOrderBillService prcOrderBillService;
+
+    @Autowired
+    private OracleUpstreamOrderService oracleUpstreamOrderService;

    @Autowired
    private RedisCache redisCache;
@@ -201,8 +200,7 @@ public class TabOrderSyncAsyncRunner
    }

    /**
-     * Sync or refund selected rows.
-     * @param billType optional PENDING/REBILL/REFUND; null = auto by orderStatus / bill existence
+     * Sync selected rows (upstream field overwrite only; billType ignored).
     */
    public Map<String, Object> syncRowsParallel(List<TabOrderMonitorVo> rows, String billType)
    {
@@ -220,8 +218,8 @@ public class TabOrderSyncAsyncRunner
    }

    /**
-     * Sync or refund selected rows carrying the upstream Oracle full row (skip re-query).
-     * @param billType optional PENDING/REBILL/REFUND; null = auto by orderStatus / bill existence
+     * Sync selected rows carrying the upstream Oracle full row when present (skip re-query).
+     * Overwrites local bill fields only; does not bill / refund.
     */
    public Map<String, Object> syncRowsParallelRows(List<com.bms.price.oracle.TabOrderRow> rows, String billType)
    {
@@ -234,7 +232,6 @@ public class TabOrderSyncAsyncRunner
            data.put("details", details);
            return data;
        }
-        final String fixedBillType = StringUtils.isEmpty(billType) ? null : billType.trim();
        int threads = Math.min(clampThreads(billingProperties == null ? null : billingProperties.getOrderSourceSyncThreads()),
            Math.max(1, rows.size()));
        ExecutorService pool = newWorkerPool(threads, "order-source-sel");
@@ -253,26 +250,16 @@ public class TabOrderSyncAsyncRunner
                    item.put("transferOrderId", vo == null ? null : vo.getTransferOrderId());
                    try
                    {
-                        PrcBillingTask task = billingTaskService.submitAndProcess(
-                            toSubmit(vo, fixedBillType), one == null ? null : one.getRaw());
-                        item.put("successStatus", task == null ? null : task.getSuccessStatus());
-                        item.put("errorMessage", task == null ? null : task.getErrorMessage());
-                        item.put("billType", task == null ? fixedBillType : task.getBillType());
-                        if (task != null && BillTaskSuccessStatus.SUCCESS.getCode().equals(task.getSuccessStatus()))
-                        {
-                            ok.incrementAndGet();
-                        }
-                        else
-                        {
-                            fail.incrementAndGet();
-                        }
+                        String billId = overwriteOne(one);
+                        item.put("successStatus", "SUCCESS");
+                        item.put("billId", billId);
+                        ok.incrementAndGet();
                    }
                    catch (RuntimeException e)
                    {
                        fail.incrementAndGet();
                        item.put("successStatus", "ERROR");
                        item.put("errorMessage", e.getMessage());
-                        item.put("billType", fixedBillType);
                    }
                    return item;
                });
@@ -315,15 +302,8 @@ public class TabOrderSyncAsyncRunner
        TabOrderMonitorVo vo = row == null ? null : row.getVo();
        try
        {
-            PrcBillingTask task = billingTaskService.submitAndProcess(
-                toSubmit(vo), row == null ? null : row.getRaw());
-            boolean success = task != null
-                && BillTaskSuccessStatus.SUCCESS.getCode().equals(task.getSuccessStatus());
-            if (!success)
-            {
-                collectFailDetail(failDetails, vo, task, null);
-            }
-            return success;
+            overwriteOne(row);
+            return true;
        }
        catch (RuntimeException e)
        {
@@ -331,15 +311,34 @@ public class TabOrderSyncAsyncRunner
                vo == null ? null : vo.getOrderId(),
                vo == null ? null : vo.getTransferOrderId(),
                e.getMessage());
-            collectFailDetail(failDetails, vo, null, e.getMessage());
+            collectFailDetail(failDetails, vo, e.getMessage());
            return false;
        }
    }

+    /** Resolve Oracle row then overwrite local bill + ext (no billing). */
+    private String overwriteOne(com.bms.price.oracle.TabOrderRow row)
+    {
+        Map<String, Object> raw = row == null ? null : row.getRaw();
+        TabOrderMonitorVo vo = row == null ? null : row.getVo();
+        if (raw == null || raw.isEmpty())
+        {
+            String transferNo = vo == null ? null : vo.getTransferOrderId();
+            String orderNo = vo == null ? null : vo.getOrderId();
+            String trackingNo = vo == null ? null : vo.getOrgOrderId();
+            raw = oracleUpstreamOrderService.findMainOrder(transferNo, orderNo, trackingNo);
+        }
+        if (raw == null || raw.isEmpty())
+        {
+            throw new com.bms.common.exception.ServiceException("Oracle main order not found");
+        }
+        return prcOrderBillService.syncUpstreamOverwrite(raw);
+    }
+
    private static final int FAIL_DETAIL_MAX = 200;

    private static void collectFailDetail(List<Map<String, Object>> failDetails, TabOrderMonitorVo row,
-        PrcBillingTask task, String exceptionMessage)
+        String exceptionMessage)
    {
        if (failDetails == null)
        {
@@ -348,22 +347,7 @@ public class TabOrderSyncAsyncRunner
        Map<String, Object> item = new LinkedHashMap<String, Object>();
        item.put("orderId", row == null ? null : row.getOrderId());
        item.put("transferOrderId", row == null ? null : row.getTransferOrderId());
-        String err = exceptionMessage;
-        if (task != null)
-        {
-            item.put("successStatus", task.getSuccessStatus());
-            item.put("billType", task.getBillType());
-            item.put("taskId", task.getTaskId());
-            if (StringUtils.isEmpty(err))
-            {
-                err = task.getErrorMessage();
-            }
-        }
-        if (StringUtils.isEmpty(err))
-        {
-            err = "sync failed";
-        }
-        item.put("errorMessage", err);
+        item.put("errorMessage", StringUtils.isEmpty(exceptionMessage) ? "sync failed" : exceptionMessage);
        synchronized (failDetails)
        {
            if (failDetails.size() >= FAIL_DETAIL_MAX)
@@ -490,32 +474,4 @@ public class TabOrderSyncAsyncRunner
        return n;
    }

-    public static BillingTaskSubmitRequest toSubmit(TabOrderMonitorVo row)
-    {
-        return toSubmit(row, null);
-    }
-
-    public static BillingTaskSubmitRequest toSubmit(TabOrderMonitorVo row, String billType)
-    {
-        if (row == null)
-        {
-            throw new com.bms.common.exception.ServiceException("order row required");
-        }
-        BillingTaskSubmitRequest req = new BillingTaskSubmitRequest();
-        req.setTransferNo(row.getTransferOrderId());
-        req.setTrackingNo(row.getOrgOrderId());
-        req.setOrderNo(row.getOrderId());
-        req.setCustomerCode(row.getCustomerCode());
-        req.setBillTime(row.getPickupDate());
-        if (StringUtils.isNotEmpty(billType))
-        {
-            req.setBillType(billType.trim());
-        }
-        else if (BillOrderStatus.requiresFeeRefund(row.getOrderStatus()))
-        {
-            // Upstream 已退件(9) / 已取消(10) -> fee refund task
-            req.setBillType(BillTaskType.REFUND.getCode());
-        }
-        return req;
-    }
 }