From c20bd338ddf092a3d9be15d68652d20b9645437d Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期二, 22 十月 2024 15:08:00 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   84 +++++++++++++++++++++++++++++++++++++----
 1 files changed, 75 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index 1923cd6..25ce48e 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -26,10 +26,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.Iterator;
-import java.util.List;
+import java.util.*;
 
 /**
  * 绉诲姩绔湇鍔℃牳蹇冪被
@@ -84,6 +81,9 @@
     public void comb(CombParam param, Long userId) {
         if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) {
             throw new CoolException(BaseRes.PARAM);
+        }
+        if(param.getCombMats().size()>1){
+            throw new CoolException("璇锋彁鍙栦竴涓晢鍝侊紝鎴栬�呭埛鏂伴噸鏂扮粍鎵橈紒");
         }
         // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
         if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
@@ -147,15 +147,22 @@
         // 鍏宠仈缁勬墭
         } else {
             Order order = orderService.selectByNo(param.getOrderNo());
-            if (order.getSettle() > 2) {
+            if (Cools.isEmpty(order) || order.getSettle() > 2) {
                 throw new CoolException("鍗曟嵁缂栧彿宸茶繃鏈�");
             }
             // 鐢熸垚鍏ュ簱閫氱煡妗�
             List<DetlDto> detlDtos = new ArrayList<>();
-            param.getCombMats().forEach(elem -> {
+
+            for (CombParam.CombMat elem : param.getCombMats()) {
+
+
+//            param.getCombMats().forEach(elem -> {
 
                 // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙
                 OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), elem.getMatnr(), elem.getBatch());
+                if (Cools.isEmpty(orderDetl)) {
+                    throw new CoolException("璇ュ崟鎹腑鏈壘鍒板搴旂墿鏂欐槑缁�");
+                }
                 if (elem.getAnfme() > orderDetl.getEnableQty()) {
                     throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�");
                 }
@@ -164,7 +171,7 @@
                     throw new CoolException("淇敼鍗曟嵁浣滀笟鏁伴噺澶辫触");
                 }
 
-                DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme());
+                DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme(),orderDetl.getManu());
                 if (DetlDto.has(detlDtos, detlDto)) {
                     DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());
                     assert one != null;
@@ -172,7 +179,8 @@
                 } else {
                     detlDtos.add(detlDto);
                 }
-            });
+//            });
+            }
             for (DetlDto detlDto : detlDtos) {
                 Mat mat = matService.selectByMatnr(detlDto.getMatnr());
                 if (Cools.isEmpty(mat)) {
@@ -190,6 +198,7 @@
                 waitPakin.setAppeTime(now);
                 waitPakin.setModiUser(userId);
                 waitPakin.setModiTime(now);
+                waitPakin.setManu(detlDto.getMark());
                 if (!waitPakinService.insert(waitPakin)) {
                     throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
                 }
@@ -431,7 +440,7 @@
             String orderNo = "PACK" + snowflakeIdWorker.nextId();
             OpenOrderPakinParam openParam = new OpenOrderPakinParam();
             openParam.setOrderNo(orderNo);
-            openParam.setOrderTime(DateUtils.convert(now));
+            openParam.setInboundDate(DateUtils.convert(now));
             openParam.setOrderType("鎵撳寘鍏ュ簱鍗�");
             openParam.setOrderDetails(detlDtos);
             openService.pakinOrderCreate(openParam);
@@ -558,6 +567,63 @@
     }
 
     @Override
+//    @Transactional
+    public void leftoversOut(Map<String, Object> map,Long userId) {
+        String barcode = map.get("barcode").toString();
+        String barcode2 = map.get("barcode2").toString();
+        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", barcode).eq("io_type", 103));
+        if (Cools.isEmpty(wrkMast)) {
+            throw new CoolException("鏈煡璇㈠埌鎷f枡浠诲姟");
+        }
+        int workNo = commonService.getWorkNo(1);
+        WrkMast wrkMast2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", barcode2).eq("io_type", 200));
+        if (Cools.isEmpty(wrkMast2)) {
+            Date now = new Date();
+
+            WrkMast wrkMast1 = new WrkMast();
+            wrkMast1.sync(wrkMast);
+            wrkMast1.setWrkNo(workNo);
+            wrkMast1.setWrkSts(2L);
+            wrkMast1.setIoType(200);
+            wrkMast1.setSourceStaNo(wrkMast.getStaNo() == 113 ? 111 : 117);
+            wrkMast1.setStaNo(wrkMast.getStaNo() == 113 ? 204 : 304);
+            wrkMast1.setIoTime(now);
+            wrkMast1.setIoPri(13D); // 浼樺厛绾э細13
+            wrkMast1.setCrnNo(wrkMast.getCrnNo());
+            wrkMast1.setSourceLocNo(wrkMast.getLocNo()); // 婧愬簱浣�
+            wrkMast1.setFullPlt("Y"); // 婊℃澘锛歒
+            wrkMast1.setPicking("N"); // 鎷f枡
+            wrkMast1.setExitMk("N"); // 閫�鍑�
+            wrkMast1.setEmptyMk("N"); // 绌烘澘
+            wrkMast1.setLinkMis("N");
+            wrkMast1.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
+            wrkMast1.setAppeTime(now);
+            wrkMast1.setModiUser(userId);
+            wrkMast1.setModiTime(now);
+            wrkMast1.setBarcode(barcode2);
+            if (!wrkMastService.insert(wrkMast1)) {
+                throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
+            }
+        }
+
+
+        List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("zpallet", map.get("barcode")));
+        if (Cools.isEmpty(wrkDetls)) {
+            throw new CoolException("鏈煡璇㈠埌鎷f枡浠诲姟鏄庣粏");
+        }
+
+        for(WrkDetl wrkDetl : wrkDetls){
+            WrkDetl wrkDetl1 = new WrkDetl();
+            wrkDetl1.sync(wrkDetl);
+            wrkDetl1.setWrkNo(workNo);
+            wrkDetlService.insert(wrkDetl1);
+        }
+
+
+
+    }
+
+    @Override
     @Transactional
     public void stockOut(OrderDetl orderDetl, BasDevp staNo, LocDetl locDetl,
                          Double curOutQty, Integer ioType, Long userId, Date now) {

--
Gitblit v1.9.1