From f08a5ea16b9fd30d7832ac33d9c0ae3fae122102 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期日, 05 四月 2026 19:13:45 +0800
Subject: [PATCH] 重量1

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   24 ++++++++++++++++++------
 1 files changed, 18 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 89b9968..36dae29 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -33,7 +33,6 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import javax.rmi.CORBA.Util;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -428,6 +427,10 @@
             for (WrkMast wrkMast : activeTasks) {
                 HashMap<String,Object> hashMap = new HashMap<>();
                 hashMap.put("taskNo", wrkMast.getWrkNo());
+                if (!Cools.isEmpty(wrkMast) && wrkMast.getWrkSts() ==11L) {
+                    workService.cancelWrkMast(wrkMast.getWrkNo()+"", 9955L);
+                    continue;
+                }
                 taskList.add(hashMap);
             }
             wcsApiService.pauseOutTasks(taskList);
@@ -1258,7 +1261,12 @@
 
             if (param.getFull() == 1) {
                 //婊℃墭鐩�
-                mat = matService.selectByMatnr("cloudWarehouse");
+                if(param.getBoxType1().equals("aws")){
+                    mat = matService.selectByMatnr("amazon");
+                }else {
+                    mat = matService.selectByMatnr("cloudWarehouse");
+                }
+
             } else if (param.getFull() == 0) {
                 //绌烘墭鐩�
                 mat = matService.selectByMatnr("emptyPallet");
@@ -1283,17 +1291,19 @@
         waitPakin.setManu(String.valueOf(param.getLocId()));//mes鍏蜂綋搴撲綅缂栧彿
         waitPakin.setThreeCode(param.getBizNo());
         waitPakin.setBeBatch(param.getPackage1());//鏄惁鏁h揣锛�0 闈炴暎璐э紱1 鏁h揣锛涗负浜嗙鎺у嚭璐ч�熺巼锛屾暎璐у彲浠ュ嚭鎱㈢偣銆�
+        // ERP 鍏ュ彛榛樿鎵� erp锛孧QTT 缁勬墭浼氬湪鍙傛暟閲屾樉寮忎紶 aws銆�
+        waitPakin.setBoxType1(Cools.isEmpty(param.getBoxType1()) ? "erp" : param.getBoxType1());
         if (!waitPakinService.insert(waitPakin)) {
             throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
         }
-        return null;
+        return R.ok().add(Cools.add("palletId", param.getPalletId()).add("orderId", param.getOrderId()));
     }
 
     @Override
-    public R outOrder(OutTaskParam param) {
+    public R outOrder(OutTaskParam param,int count) {
         LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "F").eq("barcode", param.getPalletId()));
         if (locMast == null) {
-            return R.error("娌℃湁鎵惧埌鎵樼洏鐮�=" + param.getPalletId() + "瀵瑰簲鐨勫簱浣�");
+            throw new CoolException("娌℃湁鎵惧埌鎵樼洏鐮�=" + param.getPalletId() + "瀵瑰簲鐨勫簱浣�");
         }
         Integer ioType = 101;
         // 鑾峰彇璺緞
@@ -1346,6 +1356,7 @@
             wrkDetl.setAppeUser(9995L);
             wrkDetl.setModiTime(now);
             wrkDetl.setModiUser(9995L);
+            wrkDetl.setSupp(param.getSeq()+"/"+count);
 
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
@@ -1364,7 +1375,8 @@
             log.error(locMast.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
             throw new CoolException(locMast.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
         }
-        return R.ok();
+        return R.ok().add(Cools.add("wrkNo", workNo).add("orderId", param.getOrderId()));
     }
 }
 
+

--
Gitblit v1.9.1