From 44d51d79370da8973fcd52203c669da9d0a1e479 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期二, 31 十二月 2024 10:00:37 +0800
Subject: [PATCH] 并板入库,并板途中拣料,拣料途中并板,以及相关查询接口

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |  480 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 469 insertions(+), 11 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 5b87e24..c401b70 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -7,19 +7,17 @@
 import com.core.common.*;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
-import com.zy.asrs.entity.param.CombParam;
-import com.zy.asrs.entity.param.MobileAdjustParam;
-import com.zy.asrs.entity.param.OffSaleParam;
-import com.zy.asrs.entity.param.OpenOrderPakinParam;
+import com.zy.asrs.entity.param.*;
+import com.zy.asrs.mapper.LocMastMapper;
 import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.MatUtils;
 import com.zy.asrs.utils.OrderInAndOutUtil;
-import com.zy.common.CodeRes;
 import com.zy.common.constant.MesConstant;
 import com.zy.common.entity.Parameter;
 import com.zy.common.model.DetlDto;
 import com.zy.common.model.MesCombParam;
+import com.zy.common.model.enums.WorkNoType;
 import com.zy.common.service.CommonService;
 import com.zy.common.utils.HttpHandler;
 import lombok.extern.slf4j.Slf4j;
@@ -27,10 +25,8 @@
 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 javax.annotation.Resource;
+import java.util.*;
 
 /**
  * 绉诲姩绔湇鍔℃牳蹇冪被
@@ -79,6 +75,468 @@
     @Autowired
     private ManLocDetlMapper manLocDetlMapper;
 
+    @Autowired
+    private AdjDetlService adjDetlService;
+
+    @Resource
+    private LocMastMapper locMastMapper;
+
+    @Resource
+    private DocTypeService docTypeService;
+
+    @Resource
+    private OrderDetlPakinService orderDetlPakinService;
+
+    @Resource
+    private OrderPakinService orderPakinService;
+
+    @Resource
+    private OrderPakoutService orderPakoutService;
+
+    @Resource
+    private OrderDetlPakoutService orderDetlPakoutService;
+
+    @Override
+    @Transactional
+    public R WarehouseOutPickMergeV1(WarehouseOutPickMergeParam param, Long hostId, Long userId) {
+        //鍒ゆ柇搴撲綅鐘舵��
+        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getLocNo()));
+        if (Cools.isEmpty(locMast)){
+            return R.error("璇ュ簱浣嶄笉瀛樺湪");
+        }
+        if (!locMast.getLocSts().equals("P")){
+            return R.error("璇ュ簱浣嶇姸鎬佷负锛�"+locMast.getLocSts()+",涓嶆弧瓒虫嫞鏂欓�斾腑骞舵澘鏉′欢锛侊紒锛�");
+        }
+
+        Date now = new Date();
+        // 鍒涘缓鍏ュ簱宸ヤ綔涓绘。
+        WrkMast wrkMast = new WrkMast();
+        wrkMast.setWrkNo(commonService.getWorkNo(0));
+        wrkMast.setIoTime(now);
+        wrkMast.setWrkSts(4L); // 宸ヤ綔鐘舵�侊細鍏ュ簱瀹屾垚
+        wrkMast.setIoType(8); // 鍏ュ嚭搴撶姸鎬侊細8.鎷f枡閫斾腑骞舵澘
+        wrkMast.setIoPri(13D); // 浼樺厛绾�
+        wrkMast.setCrnNo(1);
+        wrkMast.setSourceStaNo(1);
+        wrkMast.setStaNo(1);
+        wrkMast.setLocNo(param.getLocNo());
+        wrkMast.setBarcode(param.getBarcode()); // 鎵樼洏鐮�
+        wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+        wrkMast.setPicking("N"); // 鎷f枡
+        wrkMast.setExitMk("N"); // 閫�鍑�
+        wrkMast.setEmptyMk("N"); // 绌烘澘
+        wrkMast.setLinkMis("Y");
+        wrkMast.setCtnType(0); // 瀹瑰櫒绫诲瀷
+        // 鎿嶄綔浜哄憳鏁版嵁
+        wrkMast.setAppeTime(now);
+        wrkMast.setModiTime(now);
+        wrkMast.setAppeUser(userId);
+        wrkMast.setModiUser(userId);
+        wrkMastService.insert(wrkMast);
+
+        for (OrderDetl orderDetl : param.getCombMats()) {
+            Mat mat = matService.selectOne(new EntityWrapper<Mat>().eq("matnr",orderDetl.getMatnr()));
+            if (mat == null) {
+                throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鐗╂枡淇℃伅涓嶅瓨鍦細" + orderDetl.getMatnr());
+            }
+            WrkDetl wrkDetl = new WrkDetl();
+            wrkDetl.sync(mat);
+            wrkDetl.setOrderNo(orderDetl.getOrderNo());
+            wrkDetl.setWrkNo(wrkMast.getWrkNo());
+            wrkDetl.setIoTime(now);
+            wrkDetl.setAnfme(orderDetl.getAnfme()); // 鏁伴噺
+            wrkDetl.setAppeTime(now);
+            wrkDetl.setAppeUser(userId);
+            wrkDetl.setModiTime(now);
+            wrkDetl.setModiUser(userId);
+            wrkDetl.setZpallet(wrkMast.getBarcode());
+            wrkDetl.setBatch(orderDetl.getBatch());
+            if(Cools.isEmpty(orderDetl.getBatch())){
+                wrkDetl.setBatch("");
+            }
+            wrkDetl.setBoxType1(orderDetl.getBoxType1());
+            wrkDetl.setBoxType2(orderDetl.getBoxType2());
+            wrkDetl.setBoxType3(orderDetl.getBoxType3());
+            wrkDetl.setStandby1(orderDetl.getStandby1());
+            wrkDetl.setStandby2(orderDetl.getStandby2());
+            wrkDetl.setStandby3(orderDetl.getStandby3());
+            // 鐢熸垚宸ヤ綔妗f槑缁�
+            wrkDetlService.insert(wrkDetl);
+
+            if (!Cools.isEmpty(orderDetl.getOrderNo())) {
+                OrderPakin order = orderPakinService.selectByNo(orderDetl.getOrderNo());
+                if (Cools.isEmpty(order)){
+                    continue;
+                }
+                OrderDetlPakin orderDetlPakin = orderDetlPakinService.selectItem(order.getId(), orderDetl.getMatnr(), orderDetl.getBatch(),orderDetl.getBrand(),orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3());
+                if (Cools.isEmpty(orderDetlPakin)){
+                    continue;
+                }
+                if (orderDetlPakin.getAnfme() < (orderDetlPakin.getWorkQty() + orderDetl.getAnfme())) {
+                    throw new CoolException("骞舵澘鏁伴噺鍑洪敊,璁㈠崟鍓╀綑鍑哄簱鏁伴噺灏忎簬宸插嚭搴撴暟閲忎笌灏嗗苟鏉挎暟閲忎箣鍜岋紒锛侊紒");
+                }
+                // 淇敼璁㈠崟鏄庣粏浣滀笟鏁伴噺
+                if (!orderDetlPakinService.increaseWorkQty(orderDetlPakin.getOrderId(), orderDetlPakin.getMatnr(), orderDetlPakin.getBatch(), orderDetlPakin.getBrand(),
+                        orderDetlPakin.getStandby1(), orderDetlPakin.getStandby2(), orderDetlPakin.getStandby3(), orderDetlPakin.getBoxType1(), orderDetlPakin.getBoxType2(), orderDetlPakin.getBoxType3(),orderDetl.getAnfme())) {
+                    throw new CoolException("淇敼鍗曟嵁鏄庣粏宸ヤ綔鏁伴噺澶辫触");
+                }
+
+                if (order.getSettle() == 1){
+                    orderPakinService.updateSettle(order.getId(), 2L, userId);
+                }
+            }
+        }
+
+        return R.ok();
+    }
+
+    @Override
+    @Transactional
+    public R pickConfirm(PickConfirmParam param,Long userId) {
+
+        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                .eq("loc_no", param.getLocNo()));
+        if (!locMast.getLocSts().equals("F")) {
+            return R.error("搴撲綅鐘舵�佷笉鏄湪搴�");
+        }
+
+        // 鍒ゆ柇搴撲綅鏄惁鍐荤粨
+        String sourceLocFrozen = locMastMapper.findFirstFrozenLocNo(Collections.singletonList(locMast.getLocNo()));
+        if (sourceLocFrozen != null) {
+            throw new CoolException(sourceLocFrozen + "搴撲綅宸茶鍐荤粨!");
+        }
+
+        StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+                .eq("type_no", 104)
+                .eq("stn_no", param.getStaNo()));
+        if (staDesc == null) {
+            return R.error("绔欑偣涓嶅瓨鍦�");
+        }
+        OrderDetlPakin orderDetlPakin = null;
+        //妫�楠屼紶鍙傛槸鍚﹀拰璁㈠崟鏄庣粏鍖归厤
+        for (PickMatParam matParam : param.getList()) {
+            orderDetlPakin = orderDetlPakinService.selectItem
+                    (matParam.getOrderNo(), matParam.getMatnr(),matParam.getBatch(),matParam.getBrand(),
+                            matParam.getStandby1(),matParam.getStandby2(),matParam.getStandby3(),
+                            matParam.getBoxType1(),matParam.getBoxType2(),matParam.getBoxType3());
+            if (orderDetlPakin == null) {
+                return R.error("鐗╂枡鏁版嵁涓嶅瓨鍦�");
+            }
+
+            //鍓╀綑鍙敤鏁伴噺
+            double count = orderDetlPakin.getAnfme() - orderDetlPakin.getWorkQty();
+            if (matParam.getCount() != count) {
+                return R.error("鐗╂枡鏁版嵁宸茶繃鏈�");
+            }
+
+            if (matParam.getUseCount() > count) {
+                return R.error("鍙敤鏁伴噺涓嶈冻");
+            }
+        }
+
+        Date now = new Date();
+        // 鐢熸垚宸ヤ綔鍙�
+        int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(104));
+        // 鐢熸垚宸ヤ綔妗�
+        WrkMast wrkMast = new WrkMast();
+        wrkMast.setWrkNo(workNo);
+        wrkMast.setIoTime(now);
+        wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細101.鐢熸垚鍑哄簱
+        wrkMast.setIoType(104); // 鍏ュ嚭搴撶姸鎬�
+        wrkMast.setIoPri(13D); // 浼樺厛绾э細13
+        wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
+        wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
+        wrkMast.setSourceLocNo(param.getLocNo()); // 婧愬簱浣�
+        wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+        wrkMast.setPicking("Y"); // 鎷f枡
+        wrkMast.setExitMk("N"); // 閫�鍑�
+        wrkMast.setEmptyMk("N"); // 绌烘澘
+        wrkMast.setBarcode(locMast.getBarcode());
+        wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
+        wrkMast.setAppeTime(now);
+        wrkMast.setModiUser(userId);
+        wrkMast.setModiTime(now);
+        wrkMast.setCrnNo(staDesc.getCrnNo());
+        if (!wrkMastService.insert(wrkMast)) {
+            throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鍑哄簱搴撲綅鍙凤細" + param.getLocNo());
+        }
+        // 鐢熸垚宸ヤ綔妗f槑缁�
+        for (PickMatParam matParam : param.getList()) {
+            Wrapper<Mat> wrapper = new EntityWrapper<>();
+            wrapper.eq("status", 1);
+            wrapper.eq("matnr", matParam.getMatnr());
+            Mat mat = matService.selectOne(wrapper);
+            if (mat == null) {
+                throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鐗╂枡淇℃伅涓嶅瓨鍦細" + matParam.getMatnr());
+            }
+
+            WrkDetl wrkDetl = new WrkDetl();
+            wrkDetl.sync(mat);
+            wrkDetl.setBatch(matParam.getBatch());
+            wrkDetl.setOrderNo(matParam.getOrderNo());
+            wrkDetl.setWrkNo(workNo);
+            wrkDetl.setIoTime(now);
+            wrkDetl.setAnfme(matParam.getUseCount()); // 鏁伴噺
+            wrkDetl.setAppeTime(now);
+            wrkDetl.setAppeUser(userId);
+            wrkDetl.setModiTime(now);
+            wrkDetl.setModiUser(userId);
+            wrkDetl.setZpallet(wrkMast.getBarcode());
+            if(Cools.isEmpty(matParam.getBatch())){
+                wrkDetl.setBatch("");
+            }
+            if (!wrkDetlService.insert(wrkDetl)) {
+                throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
+            }
+
+            //鏇存柊璁㈠崟宸ヤ綔鏁伴噺
+            orderDetlPakinService.increaseWorkQty(orderDetlPakin.getOrderId(), matParam.getMatnr(),
+                    matParam.getBatch(),matParam.getBrand(),matParam.getStandby1(),matParam.getStandby2(),matParam.getStandby3(),
+                    matParam.getBoxType1(),matParam.getBoxType2(),matParam.getBoxType3(),matParam.getUseCount());
+            // 鏇存柊宸ヤ綔妗g姸鎬�
+            orderPakinService.updateSettle(orderDetlPakin.getOrderId(),2L,userId);
+        }
+        // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
+        locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getLocNo()));
+        if (locMast.getLocSts().equals("F")) {
+            locMast.setLocSts("P");
+            locMast.setModiUser(userId);
+            locMast.setModiTime(now);
+            if (!locMastService.updateById(locMast)) {
+                throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細" + param.getLocNo());
+            }
+        } else {
+            throw new CoolException(param.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+        }
+
+        return R.ok();
+    }
+
+    @Override
+    @Transactional
+    public R WarehouseOutV1(CombParam combParam, Long hostId, Long userId) {
+        //鍒ゆ柇搴撲綅鐘舵��
+        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", combParam.getLocNo()));
+        if (Cools.isEmpty(locMast)){
+            return R.error("璇ュ簱浣嶄笉瀛樺湪");
+        }
+        if (!locMast.getLocSts().equals("P")){
+            return R.error("璇ュ簱浣嶇姸鎬佷负锛�"+locMast.getLocSts()+",涓嶆弧瓒冲苟鏉块�斾腑鎷i�夋潯浠讹紒锛侊紒");
+        }
+        //鏌ヨ搴撳瓨鏁版嵁
+        for (CombParam.CombMat combMat :combParam.getCombMats()){
+            List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>()
+                            .eq("loc_no", combParam.getLocNo())
+                            .eq("matnr", combMat.getMatnr())
+            );
+            if (locDetlList.isEmpty()){
+                return R.error("鏈煡璇㈠埌搴撳瓨鏁版嵁");
+            }
+            if (locDetlList.size()>1){
+                return R.error("搴撳瓨鏁版嵁澶т簬1鏉★紝涓轰繚璇佹暟鎹噯纭�э紝璇风敤姝e父娴佺▼鍑哄簱锛侊紒锛�");
+            }
+            LocDetl locDetl = locDetlList.get(0);
+            if (combMat.getAnfme() > locDetl.getAnfme()){
+                return R.error("鎷i�夋暟閲忛敊璇紝瓒呭嚭搴撳瓨鏁伴噺");
+            }
+            if (!Cools.isEmpty(combMat.getOrderNo())){
+                OrderPakout orderPakout = orderPakoutService.selectByNo(combMat.getOrderNo());
+                if (Cools.isEmpty(orderPakout)){
+                    continue;
+                }
+                if (orderPakout.getSettle() == 1){
+                    OrderInAndOutUtil.updateOrder(false,orderPakout.getId(), 2L, 9527L);
+                }
+                OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(orderPakout.getId(), combMat.getMatnr(), combMat.getBatch(),
+                        combMat.getBrand(), combMat.getStandby1(), combMat.getStandby2(), combMat.getStandby3(), combMat.getBoxType1(), combMat.getBoxType2(), combMat.getBoxType3());
+                if (Cools.isEmpty(orderDetlPakout)){
+                    continue;
+                }
+                if (orderDetlPakout.getAnfme() < (orderDetlPakout.getWorkQty()+combMat.getAnfme())){
+                    throw new CoolException("鎷i�夋暟閲忓嚭閿�,璁㈠崟鍓╀綑鍑哄簱鏁伴噺灏忎簬宸插嚭搴撴暟閲忎笌灏嗘嫞閫夋暟閲忎箣鍜岋紒锛侊紒");
+                }
+                // 淇敼璁㈠崟鏄庣粏浣滀笟鏁伴噺
+                if (!orderDetlPakoutService.increaseWorkQty(orderDetlPakout.getOrderId(), combMat.getMatnr(), combMat.getBatch(), combMat.getBrand(),
+                        combMat.getStandby1(), combMat.getStandby2(), combMat.getStandby3(), combMat.getBoxType1(), combMat.getBoxType2(), combMat.getBoxType3(),combMat.getAnfme())) {
+                    throw new CoolException("淇敼鍗曟嵁鏄庣粏宸ヤ綔鏁伴噺澶辫触");
+                }
+//                // 淇敼璁㈠崟鏄庣粏瀹屾垚鏁伴噺
+//                if (!orderDetlPakoutService.increase(orderPakout.getId(),combMat.getMatnr(), combMat.getBatch(), combMat.getBrand(),
+//                        combMat.getStandby1(), combMat.getStandby2(), combMat.getStandby3(), combMat.getBoxType1(), combMat.getBoxType2(), combMat.getBoxType3(),combMat.getAnfme())) {
+//                    throw new CoolException("淇敼鍗曟嵁鏄庣粏瀹屾垚鏁伴噺澶辫触");
+//                }
+//                // 淇敼璁㈠崟鐘舵�� 浣滀笟涓� ===>> 宸插畬鎴�
+//                orderPakoutService.checkComplete(combMat.getOrderNo());
+            }
+            try {
+                Date now = new Date();
+                // 鍒涘缓鍏ュ簱宸ヤ綔妗�
+                WrkMast wrkMast = new WrkMast();
+                wrkMast.setWrkNo(commonService.getWorkNo(2));
+                wrkMast.setIoTime(now);
+                wrkMast.setWrkSts(14L); // 宸ヤ綔鐘舵�侊細鍑哄簱瀹屾垚
+                wrkMast.setIoType(108); // 鍏ュ嚭搴撶姸鎬侊細鍑哄簱锛屾嫞鏂欏叆搴�
+                wrkMast.setIoPri(13D); // 浼樺厛绾�
+                wrkMast.setCrnNo(1);
+                wrkMast.setSourceStaNo(1);
+                wrkMast.setStaNo(1);
+                wrkMast.setSourceLocNo(combParam.getLocNo());
+                wrkMast.setBarcode(combParam.getBarcode()); // 鎵樼洏鐮�
+                wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+                wrkMast.setPicking("N"); // 鎷f枡
+                wrkMast.setExitMk("N"); // 閫�鍑�
+                wrkMast.setEmptyMk("N"); // 绌烘澘
+                wrkMast.setLinkMis("Y");
+                wrkMast.setCtnType(0); // 瀹瑰櫒绫诲瀷
+                // 鎿嶄綔浜哄憳鏁版嵁
+                wrkMast.setAppeTime(now);
+                wrkMast.setModiTime(now);
+                wrkMast.setAppeUser(userId);
+                wrkMast.setModiUser(userId);
+                wrkMastService.insert(wrkMast);
+
+                Mat mat = matService.selectOne(new EntityWrapper<Mat>().eq("matnr",combMat.getMatnr()));
+                if (mat == null) {
+                    throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鐗╂枡淇℃伅涓嶅瓨鍦細" + combMat.getMatnr());
+                }
+
+                WrkDetl wrkDetl = new WrkDetl();
+                wrkDetl.sync(mat);
+                wrkDetl.setOrderNo(combMat.getOrderNo());
+                wrkDetl.setWrkNo(wrkMast.getWrkNo());
+                wrkDetl.setIoTime(now);
+                wrkDetl.setAnfme(combMat.getAnfme()); // 鏁伴噺
+                wrkDetl.setAppeTime(now);
+                wrkDetl.setAppeUser(userId);
+                wrkDetl.setModiTime(now);
+                wrkDetl.setModiUser(userId);
+                wrkDetl.setZpallet(wrkMast.getBarcode());
+                wrkDetl.setBatch(combMat.getBatch());
+                if(Cools.isEmpty(combMat.getBatch())){
+                    wrkDetl.setBatch("");
+                }
+                wrkDetl.setBoxType1(combMat.getBoxType1());
+                wrkDetl.setBoxType2(combMat.getBoxType2());
+                wrkDetl.setBoxType3(combMat.getBoxType3());
+                wrkDetl.setStandby1(combMat.getStandby1());
+                wrkDetl.setStandby2(combMat.getStandby2());
+                wrkDetl.setStandby3(combMat.getStandby3());
+                // 鐢熸垚宸ヤ綔妗f槑缁�
+                wrkDetlService.insert(wrkDetl);
+                System.out.println("姝e父");
+
+            }catch (Exception e) {
+                throw new CoolException("鎿嶄綔鏁版嵁寮傚父锛�"+e.getMessage());
+            }
+        }
+        return R.ok("鎿嶄綔鎴愬姛锛�");
+    }
+
+    @Override
+    public R orderOutListOrder(String barcode, Long userId) {
+        ArrayList<WrkMast> wrkMastArrayList = new ArrayList<>();
+        if (Cools.isEmpty(barcode) || barcode.isEmpty()) {
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .eq("wrk_sts", 14L)
+                    .eq("io_type", 104));
+            wrkMastArrayList.addAll(wrkMasts);
+            List<WrkMast> wrkMasts1 = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .eq("wrk_sts", 14L)
+                    .eq("io_type", 107));
+            wrkMastArrayList.addAll(wrkMasts1);
+        } else {
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .like("barcode", barcode)
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 104));
+            wrkMastArrayList.addAll(wrkMasts);
+            List<WrkMast> wrkMasts1 = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .like("barcode", barcode)
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 107));
+            wrkMastArrayList.addAll(wrkMasts1);
+        }
+        return R.ok().add(wrkMastArrayList);
+    }
+
+    @Override
+    public R orderOutListOrderPick(String barcode, Long userId) {
+        ArrayList<WrkMast> wrkMastArrayList = new ArrayList<>();
+        if (Cools.isEmpty(barcode) || barcode.isEmpty()) {
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 103));
+            wrkMastArrayList.addAll(wrkMasts);
+            List<WrkMast> wrkMasts1 = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 107));
+            wrkMastArrayList.addAll(wrkMasts1);
+        } else {
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .like("barcode", barcode)
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 103)
+            );
+            wrkMastArrayList.addAll(wrkMasts);
+            List<WrkMast> wrkMasts1 = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                    .like("barcode", barcode)
+                    .eq("wrk_sts", 199L)
+                    .eq("io_type", 107));
+            wrkMastArrayList.addAll(wrkMasts1);
+        }
+        return R.ok().add(wrkMastArrayList);
+    }
+
+    @Override
+    public R pickMats(String matnr, String orderNo) {
+        List<DocType> docTypes = docTypeService.selectList(new EntityWrapper<DocType>().like("pakin", "1"));
+        ArrayList<Long> typeList = new ArrayList<>();
+        for (DocType docType : docTypes) {
+            typeList.add(docType.getDocId());
+        }
+
+        Wrapper<Order> wrapper = new EntityWrapper<>();
+        wrapper.eq("status", 1);
+        wrapper.in("doc_type", typeList);
+        List<Order> orders = orderService.selectList(wrapper);
+
+        ArrayList<Long> orderIds = new ArrayList<>();
+        for (Order order : orders) {
+            orderIds.add(order.getId());
+        }
+
+        //鎼滅储鏄庣粏
+        Wrapper<OrderDetl> wrapper1 = new EntityWrapper<>();
+        wrapper1.eq("status", 1);
+        wrapper1.in("order_id", orderIds);
+        wrapper1.orderBy("create_time",false);
+        if (!Cools.isEmpty(matnr)) {
+            wrapper1.like("matnr", matnr);
+        }
+        if (!Cools.isEmpty(orderNo)) {
+            wrapper1.like("order_no", orderNo);
+        }
+        List<OrderDetl> list = orderDetlService.selectList(wrapper1);
+
+        ArrayList<PickMatParam> maps = new ArrayList<>();
+        for (OrderDetl orderDetl : list) {
+            //鍓╀綑鍙敤鏁伴噺
+            double count = orderDetl.getAnfme() - orderDetl.getWorkQty();
+            if (count <= 0) {
+                continue;
+            }
+
+            PickMatParam matParam = new PickMatParam();
+            matParam.setMatnr(orderDetl.getMatnr());
+            matParam.setBatch(orderDetl.getBatch());
+            matParam.setOrderNo(orderDetl.getOrderNo());
+            matParam.setOrderId(orderDetl.getOrderId());
+            matParam.setCount(count);
+            matParam.setUseCount(count);
+            maps.add(matParam);
+        }
+        return R.ok().add(maps);
+    }
 
     @Override
     @Transactional
@@ -215,10 +673,10 @@
     public void onSale(CombParam param) {
         Date now = new Date();
         // 鑾峰彇搴撲綅鍙�
-        String locno = param.getLocno();
+        String locno = param.getLocNo();
         Node node = nodeService.selectByUuid(locno);
         if (Cools.isEmpty(node)) {
-            throw new CoolException(param.getLocno() + ":搴撲綅涓嶅瓨鍦�");
+            throw new CoolException(param.getLocNo() + ":搴撲綅涓嶅瓨鍦�");
         }
 
         // 鑾峰彇鍟嗗搧鍒楄〃

--
Gitblit v1.9.1