From c525bf64b32e80ac92317f520c9fa17fc5a2ac03 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 02 三月 2021 14:48:03 +0800
Subject: [PATCH] #

---
 src/main/java/zy/cloud/wms/common/service/MainService.java |   57 +++++++++++++++++++++++++++++++--------------------------
 1 files changed, 31 insertions(+), 26 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 cc82650..c5f3b5d 100644
--- a/src/main/java/zy/cloud/wms/common/service/MainService.java
+++ b/src/main/java/zy/cloud/wms/common/service/MainService.java
@@ -1,6 +1,5 @@
 package zy.cloud.wms.common.service;
 
-import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
 import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
@@ -10,7 +9,10 @@
 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.*;
+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.LocDetlService;
 import zy.cloud.wms.manager.service.MatService;
 import zy.cloud.wms.manager.service.PakoutService;
@@ -18,6 +20,7 @@
 
 import java.util.Date;
 import java.util.List;
+import java.util.Optional;
 
 /**
  * Created by vincent on 2021/3/1
@@ -49,36 +52,38 @@
             if (null == mat) {
                 throw new CoolException(custOrder.getUserCode() + "鐗╂枡灏氭湭鏇存柊銆�" + custOrder.getNumber() +"鍗曟嵁鍥犳涓柇锛�");
             }
-            // 鏍规嵁鎺ㄨ崘搴撲綅鏌ユ壘搴撳瓨
-            List<Prior> priors = priorService.selectList(new EntityWrapper<Prior>().eq("matnr", mat.getMatnr()).orderBy("prio"));
-            if (!Cools.isEmpty(priors)) {
-                for (Prior prior : priors) {
-                    LocDetl locDetl = locDetlService.getLocDetl(prior.getNodeId(), prior.getMatnr());
-                    if (null != locDetl && locDetl.getAnfme() > 0) {
-                        // 淇濆瓨鍑哄簱閫氱煡鍗昞
-                        Pakout pakout = new Pakout();
-                        pakout.setWrkSts(1L);
-//                        pakout.setAnfme();
-                        pakout.setZpallet(locDetl.getZpallet());
-                        pakout.setLocNo(locDetl.getLocNo());
-                        pakout.setNodeId(locDetl.getNodeId());
-                        pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId()));
-                        VersionUtils.setPakout(pakout, mat);
-                        pakout.setCreateTime(now);
-                        pakout.setUpdateTime(now);
-                        pakout.setStatus(1);
-                        if (!pakoutService.insert(pakout)) {
-                            throw new CoolException("淇濆瓨鍑哄簱閫氱煡鍗曞け璐�");
-                        }
-
+            // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣�
+            List<LocDetl> locDetls = locDetlService.findOfSort(mat.getMatnr());
+            double issued = Optional.ofNullable(custOrder.getQty()).orElse(0.0D) ;
+            while (issued > 0) {
+                for (LocDetl locDetl : locDetls) {
+                    // 淇濆瓨鍑哄簱閫氱煡鍗�
+                    Pakout pakout = new Pakout();
+                    pakout.setWrkSts(1L);
+                    pakout.setAnfme(issued>=locDetl.getAnfme()?locDetl.getAnfme():issued);
+                    pakout.setZpallet(locDetl.getZpallet());
+                    pakout.setLocNo(locDetl.getLocNo());
+                    pakout.setNodeId(locDetl.getNodeId());
+                    pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId()));
+                    VersionUtils.setPakout(pakout, mat);
+                    pakout.setCreateTime(now);
+                    pakout.setUpdateTime(now);
+                    pakout.setStatus(1);
+                    if (!pakoutService.insert(pakout)) {
+                        throw new CoolException("淇濆瓨鍑哄簱閫氱煡鍗曞け璐�");
                     }
+                    // 淇敼搴撳瓨鏄庣粏鏁伴噺
+                    if (!locDetlService.reduceStock(locDetl.getNodeId(), mat.getMatnr(), issued>=locDetl.getAnfme()?locDetl.getAnfme():issued)) {
+                        throw new CoolException("淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触");
+                    }
+                    // 鍓╀綑寰呭嚭璐т綅閫掑噺
+                    issued = issued - locDetl.getAnfme();
                 }
-            } else {
-
             }
 
 
 
+
         }
     }
 

--
Gitblit v1.9.1