From 7ec0d6926482a21b38c246ad460ca25cc78d6ffc Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期五, 17 四月 2026 12:56:05 +0800
Subject: [PATCH] 1.erp对接 2.电视机对接

---
 src/main/java/com/zy/asrs/controller/OpenController.java |   55 ++++++++++++++++++++++++++++++++++++-------------------
 1 files changed, 36 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 8f859d0..e018904 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -535,7 +535,7 @@
         }
         log.info("[outOrder] cache: {}", JSON.toJSONString(params));
         request.setAttribute("cache", params);
-        Map<String, List<OutTaskParam>> linesByBatch = new LinkedHashMap<>();
+        Map<String, List<OutTaskParam>> linesByBatchSeq = new LinkedHashMap<>();
         for (OutTaskParam outTaskParam : params) {
             if (Cools.isEmpty(outTaskParam) || Cools.isEmpty(outTaskParam.getOrderId())) {
                 return R.error("鍑哄簱鍗曞彿涓嶈兘涓虹┖");
@@ -546,10 +546,10 @@
             if (Cools.isEmpty(outTaskParam.getStationId())) {
                 return R.error("鎵樼洏銆�" + outTaskParam.getPalletId() + "銆嶅嚭搴撳彛缂栫爜涓嶈兘涓虹┖");
             }
-            linesByBatch.computeIfAbsent(outTaskParam.getBatchSeq(), k -> new ArrayList<>()).add(outTaskParam);
+            linesByBatchSeq.computeIfAbsent(outTaskParam.getBatchSeq(), k -> new ArrayList<>()).add(outTaskParam);
         }
 
-        for (Map.Entry<String, List<OutTaskParam>> entry : linesByBatch.entrySet()) {
+        for (Map.Entry<String, List<OutTaskParam>> entry : linesByBatchSeq.entrySet()) {
             List<OutTaskParam> lines = entry.getValue();
             OutTaskParam head = lines.get(0);
             String oid = head.getOrderId();
@@ -584,8 +584,13 @@
             }
         }
 
+        List<OutTaskParam> groupedParams = new ArrayList<>(params.size());
+        for (List<OutTaskParam> lines : linesByBatchSeq.values()) {
+            groupedParams.addAll(lines);
+        }
+
         Set<String> seenPallet = new LinkedHashSet<>();
-        for (OutTaskParam outTaskParam : params) {
+        for (OutTaskParam outTaskParam : groupedParams) {
             String pid = outTaskParam.getPalletId();
             String palletKey = pid == null ? "" : pid;
             if (!seenPallet.add(palletKey)) {
@@ -614,7 +619,7 @@
 
         List<OutTaskParam> missingStock = Lists.newArrayList();
         List<OutTaskParam> missingLoc = Lists.newArrayList();
-        for (OutTaskParam outTaskParam : params) {
+        for (OutTaskParam outTaskParam : groupedParams) {
             int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", outTaskParam.getPalletId()));
             if (countLoc == 0) {
                 missingStock.add(outTaskParam);
@@ -642,7 +647,7 @@
             return R.error("娌℃湁鎵惧埌鎵樼洏鐮佸搴斿簱浣嶏細" + String.join("锛�", badPalletIds)).add(missingLoc);
         }
 
-        return openService.outOrderBatch(params);
+        return openService.outOrderBatch(linesByBatchSeq);
     }
 
     /**
@@ -692,6 +697,15 @@
 
     private String buildOutOrderBatchKey(OutTaskParam param) {
         return param.getOrderId() + "#" + param.getBatchSeq();
+    }
+
+    /**
+     * 鎺ㄨ崘鍑哄簱绔欑偣
+     */
+    @PostMapping("/pakoutStaNo")
+    public synchronized R pakoutStaNo(@RequestBody List<String> barcodes) {
+        String StaNo = "1,2,3,4,5";
+        return R.ok().add(StaNo);
     }
 
 
@@ -839,8 +853,8 @@
                 if (w.getYmd() != null && key.equals(w.getYmd().trim())) {
                     inV = w.getInqty();
                     outV = w.getOutqty();
-                    inC = w.getCube_inqty();
-                    outC = w.getCube_outqty();
+                    inC = w.getCubeInqty();
+                    outC = w.getCubeOutqty();
                     break;
                 }
             }
@@ -863,18 +877,21 @@
         outqty.setData(data2.toArray(array2));
         list.add(outqty);
 
-        AxisBean cubeInqty = new AxisBean();
-        cubeInqty.setName("鍏ュ簱浣撶Н");
-        Integer[] array3 = new Integer[data3.size()];
-        cubeInqty.setData(data3.toArray(array3));
-        list.add(cubeInqty);
+        if (data3.size() >0) {
+            AxisBean cubeInqty = new AxisBean();
+            cubeInqty.setName("鍏ュ簱浣撶Н");
+            Integer[] array3 = new Integer[data3.size()];
+            cubeInqty.setData(data3.toArray(array3));
+            list.add(cubeInqty);
+        }
 
-        AxisBean cubeOutqty = new AxisBean();
-        cubeOutqty.setName("鍑哄簱浣撶Н");
-        Integer[] array4 = new Integer[data4.size()];
-        cubeOutqty.setData(data4.toArray(array4));
-        list.add(cubeOutqty);
-
+        if (data3.size() >0) {
+            AxisBean cubeOutqty = new AxisBean();
+            cubeOutqty.setName("鍑哄簱浣撶Н");
+            Integer[] array4 = new Integer[data4.size()];
+            cubeOutqty.setData(data4.toArray(array4));
+            list.add(cubeOutqty);
+        }
         map.put("categories", categories);
         map.put("rows", list);
         return R.ok(map);

--
Gitblit v1.9.1