From 83b02c918a02f548ac5fbe189891867a00a53fc2 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期六, 13 三月 2021 14:11:59 +0800
Subject: [PATCH] #

---
 src/main/java/zy/cloud/wms/common/service/MainService.java |   70 ++++++++++++++++++++++++++++++-----
 1 files changed, 60 insertions(+), 10 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 dbc4645..4e6a347 100644
--- a/src/main/java/zy/cloud/wms/common/service/MainService.java
+++ b/src/main/java/zy/cloud/wms/common/service/MainService.java
@@ -9,12 +9,13 @@
 import org.springframework.transaction.annotation.Transactional;
 import zy.cloud.wms.common.model.OrderStoDto;
 import zy.cloud.wms.common.utils.VersionUtils;
-import zy.cloud.wms.manager.entity.CustOrder;
-import zy.cloud.wms.manager.entity.LocDetl;
-import zy.cloud.wms.manager.entity.Mat;
-import zy.cloud.wms.manager.entity.Pakout;
-import zy.cloud.wms.manager.service.*;
+import zy.cloud.wms.manager.entity.*;
+import zy.cloud.wms.manager.service.CustOrderService;
+import zy.cloud.wms.manager.service.LocDetlService;
+import zy.cloud.wms.manager.service.MatService;
+import zy.cloud.wms.manager.service.PakoutService;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.Optional;
@@ -38,6 +39,48 @@
     private SnowflakeIdWorker snowflakeIdWorker;
 
     @Transactional
+    public List<StoPreVo> stockOutPreview(OrderStoDto dto) {
+        if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getCustOrders())) {
+            throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
+        }
+        // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶�
+        locDetlService.checkLocDetlCount(dto.getNumber());
+        List<StoPreVo> result = new ArrayList<>();
+        for (CustOrder custOrder : dto.getCustOrders()) {
+            // 鍒ゆ柇鐗╂枡鏄惁瀛樺湪
+            Mat mat = matService.selectByMatnr(custOrder.getUserCode());
+            if (null == mat) {
+                throw new CoolException(custOrder.getUserCode() + "鐗╂枡灏氭湭鏇存柊銆�" + custOrder.getNumber() +"鍗曟嵁鍥犳涓柇锛�");
+            }
+            // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣�
+            List<LocDetl> locDetls = locDetlService.findOfSort(mat.getMatnr());
+            double issued = Optional.ofNullable(custOrder.getQty()).orElse(0.0D) ;
+            // 瑙嗗浘瀵硅薄
+            StoPreVo vo = new StoPreVo();
+            vo.setMatnr(mat.getMatnr());
+            vo.setMaktx(mat.getMaktx());
+            vo.setAnfme(issued);
+            List<StoPreVo.StoPreLoc> locVos = new ArrayList<>();
+            vo.setLocs(locVos);
+            for (LocDetl locDetl : locDetls) {
+                if (issued > 0) {
+                    StoPreVo.StoPreLoc locVo = new StoPreVo.StoPreLoc();
+                    locVo.setLocNo(locDetl.getLocNo());
+                    locVo.setNodeId(locDetl.getNodeId());
+                    locVo.setTotal(locDetl.getAnfme());
+                    locVo.setReduce(issued>=locDetl.getAnfme()?locDetl.getAnfme():issued);
+                    locVo.setPrior(locDetlService.isPrior(locDetl.getNodeId(), mat.getMatnr()));
+                    locVos.add(locVo);
+                    // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
+                    issued = issued - locDetl.getAnfme();
+                }
+            }
+            result.add(vo);
+        }
+        return result;
+    }
+
+    @Transactional
     public void stockOutProcess(OrderStoDto dto) {
         if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getCustOrders())) {
             return;
@@ -54,8 +97,8 @@
             // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣�
             List<LocDetl> locDetls = locDetlService.findOfSort(mat.getMatnr());
             double issued = Optional.ofNullable(custOrder.getQty()).orElse(0.0D) ;
-            while (issued > 0) {
-                for (LocDetl locDetl : locDetls) {
+            for (LocDetl locDetl : locDetls) {
+               if (issued > 0) {
                     // 淇濆瓨鍑哄簱閫氱煡鍗�
                     Pakout pakout = new Pakout();
                     pakout.setWrkSts(1L);
@@ -73,9 +116,16 @@
                     if (!pakoutService.insert(pakout)) {
                         throw new CoolException("淇濆瓨鍑哄簱閫氱煡鍗曞け璐�");
                     }
-                    // 淇敼搴撳瓨鏄庣粏鏁伴噺
-                    if (!locDetlService.reduceStock(locDetl.getNodeId(), mat.getMatnr(), issued>=locDetl.getAnfme()?locDetl.getAnfme():issued)) {
-                        throw new CoolException("淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触");
+                    if (issued>=locDetl.getAnfme()) {
+                        // 鍒犻櫎搴撳瓨鏄庣粏
+                        if (!locDetlService.removeStock(locDetl.getNodeId(), mat.getMatnr())) {
+                            throw new CoolException("鍒犻櫎搴撳瓨鏄庣粏澶辫触");
+                        }
+                    } else {
+                        // 淇敼搴撳瓨鏄庣粏鏁伴噺
+                        if (!locDetlService.reduceStock(locDetl.getNodeId(), mat.getMatnr(), issued)) {
+                            throw new CoolException("淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触");
+                        }
                     }
                     // 鍓╀綑寰呭嚭鏁伴噺閫掑噺
                     issued = issued - locDetl.getAnfme();

--
Gitblit v1.9.1