From bbddd048ae9016ae89136eb0f108b80ca38ed4f4 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期五, 23 一月 2026 19:16:32 +0800
Subject: [PATCH] lsh#明细添加计划跟踪号、行号、批次

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java |   19 ++++++++++++-------
 1 files changed, 12 insertions(+), 7 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
index cdbe0d6..4509896 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
@@ -506,13 +506,18 @@
                     //缁勬墭
                     WaitPakinParam pakinParam = new WaitPakinParam();
                     pakinParam.setBarcode(palletId.get());
-                    CompletableFuture.runAsync(() -> {
-                        try {
-                            asyncMergeItemsWcs(pakinParam, syncOrder.getOrderNo(), loginUserId);
-                        } catch (Exception e) {
-                            log.warn("璁㈠崟 {} 寮�濮嬭嚜鍔ㄧ粍鎵�", syncOrder.getOrderNo());
-                        }
-                    });
+                    pakinParam.setStaNo(syncOrder.getStationId());
+
+                    boolean itemsCheck = waitPakinService.mergeItemsCheck(pakinParam, loginUserId);
+                    if (itemsCheck) {
+                        CompletableFuture.runAsync(() -> {
+                            try {
+                                asyncMergeItemsWcs(pakinParam, syncOrder.getOrderNo(), loginUserId);
+                            } catch (Exception e) {
+                                log.warn("璁㈠崟 {} 寮�濮嬭嚜鍔ㄧ粍鎵�", syncOrder.getOrderNo());
+                            }
+                        });
+                    }
                 }
             });
         }

--
Gitblit v1.9.1