From 63a0de547069fce19536b278ccd412a211ce8b11 Mon Sep 17 00:00:00 2001
From: wang..123 <brook_w@163.com>
Date: 星期三, 23 三月 2022 08:48:50 +0800
Subject: [PATCH] #

---
 src/main/java/zy/cloud/wms/common/service/MainService.java |   80 ++++++++++++++++++++++++++++++++++++++++
 1 files changed, 80 insertions(+), 0 deletions(-)

diff --git a/src/main/java/zy/cloud/wms/common/service/MainService.java b/src/main/java/zy/cloud/wms/common/service/MainService.java
index 2e299b5..ec44a62 100644
--- a/src/main/java/zy/cloud/wms/common/service/MainService.java
+++ b/src/main/java/zy/cloud/wms/common/service/MainService.java
@@ -10,6 +10,7 @@
 import zy.cloud.wms.common.model.MatnrDto;
 import zy.cloud.wms.common.model.OrderStoDto;
 import zy.cloud.wms.common.model.ReceiveStoDto;
+import zy.cloud.wms.common.model.WaveStoDto;
 import zy.cloud.wms.common.utils.VersionUtils;
 import zy.cloud.wms.manager.entity.*;
 import zy.cloud.wms.manager.service.*;
@@ -437,6 +438,8 @@
             pickout.setUserId(userId);
             pickout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId()));
             pickout.setWrkSts(1L);
+            pickout.setOrderQty(1);
+            pickout.setOrderNos(orderStoDto.getOrderNo());
             pickout.setCreateBy(userId.intValue());
             pickout.setUpdateBy(userId.intValue());
             pickoutService.insert(pickout);
@@ -501,4 +504,81 @@
             }
         }
     }
+
+    public Object waveOutPreview(WaveStoDto waveStoDto, Long hostId) {
+        if (Cools.isEmpty(waveStoDto) || Cools.isEmpty(waveStoDto.getDtos())) {
+            throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
+        }
+        List<StoPreTab> res = new ArrayList<>();
+        // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶�
+//        locDetlService.checkLocDetlCount(orderStoDto.getDtos());
+
+        for (MatnrDto matnrDto : waveStoDto.getDtos()) {
+            // 鍒ゆ柇鐗╂枡鏄惁瀛樺湪
+            Mat mat = matService.selectByMatnr(hostId, matnrDto.getMatnr());
+            if (null == mat) {
+                throw new CoolException(matnrDto.getMatnr() + "鐗╂枡灏氭湭鏇存柊銆�" + waveStoDto.getOrderNo() +"鍗曟嵁鍥犳涓柇锛�");
+            }
+
+            Double sumAnfme = Optional.ofNullable(locDetlService.selectCountByMatnr(mat.getMatnr(), hostId)).orElse(0.0D);
+            double lack = 0.0D;
+            // 缂鸿揣
+            if (sumAnfme < matnrDto.getCount()) {
+                lack = matnrDto.getCount() - sumAnfme;
+                // 瑙嗗浘瀵硅薄
+                StoPreTab tab = new StoPreTab();
+                tab.setTitle(mat.getMaktx() + "锛�" + mat.getMatnr() + "锛�");
+                tab.setMatnr(mat.getMatnr());
+                tab.setMaktx(mat.getMaktx());
+                tab.setAnfme(matnrDto.getCount());
+                tab.setLocNo("缂鸿揣");
+                tab.setTotal(lack);
+                tab.setReduce(lack);
+                tab.setRemQty(0.0D);
+                tab.setPrior(false);
+                tab.setPrior$("脳");
+                tab.setType(0);
+                tab.setWaveId(waveStoDto.getOrderNo());
+                res.add(tab);
+            }
+
+            // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣�
+            List<LocDetl> locDetls = locDetlService.findOfSort(hostId, mat.getMatnr());
+            double issued = Optional.of(matnrDto.getCount() - lack).orElse(0.0D) ;
+            double anfme = issued;
+            for (LocDetl locDetl : locDetls) {
+                if (issued > 0) {
+                    // 瑙嗗浘瀵硅薄
+                    StoPreTab tab = new StoPreTab();
+                    tab.setTitle(mat.getMaktx() + "锛�" + mat.getMatnr() + "锛�");
+                    tab.setMatnr(mat.getMatnr());
+                    tab.setMaktx(mat.getMaktx());
+                    tab.setAnfme(matnrDto.getCount());
+
+                    tab.setLocNo(locDetl.getLocNo());
+                    tab.setNodeId(locDetl.getNodeId());
+                    tab.setTotal(locDetl.getAnfme());
+                    tab.setReduce(issued>=locDetl.getAnfme()?locDetl.getAnfme():issued);
+                    tab.setRemQty(tab.getTotal() - tab.getReduce());
+                    tab.setPrior(locDetlService.isPrior(locDetl.getNodeId(), mat.getMatnr()));
+                    tab.setPrior$(tab.getPrior()?"鉁�":"脳");
+                    tab.setType(1);
+                    tab.setWaveId(waveStoDto.getOrderNo());
+                    res.add(tab);
+                    // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
+                    issued = issued - locDetl.getAnfme();
+                }
+            }
+
+        }
+        res.sort(new Comparator<StoPreTab>() {
+            @Override
+            public int compare(StoPreTab o1, StoPreTab o2) {
+//                return o1.getMatnr().length() - o2.getMatnr().length();
+                return (int) (o1.getAnfme() - o2.getAnfme());
+            }
+        });
+        return res;
+
+    }
 }

--
Gitblit v1.9.1