From 1cb134a269b9e7a70481a875d61e288be47ca99f Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期三, 14 四月 2021 08:51:30 +0800 Subject: [PATCH] # --- src/main/java/zy/cloud/wms/common/service/MainService.java | 72 ++++++++++++++++++++---------------- 1 files changed, 40 insertions(+), 32 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 433c536..6c81900 100644 --- a/src/main/java/zy/cloud/wms/common/service/MainService.java +++ b/src/main/java/zy/cloud/wms/common/service/MainService.java @@ -7,18 +7,13 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import zy.cloud.wms.common.model.MatnrDto; 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.service.CustOrderService; -import zy.cloud.wms.manager.service.LocDetlService; -import zy.cloud.wms.manager.service.MatService; -import zy.cloud.wms.manager.service.PakoutService; +import zy.cloud.wms.manager.service.*; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; -import java.util.Optional; +import java.util.*; /** * Created by vincent on 2021/3/1 @@ -34,27 +29,28 @@ @Autowired private PakoutService pakoutService; @Autowired - private CustOrderService custOrderService; - @Autowired private SnowflakeIdWorker snowflakeIdWorker; + @Autowired + private OrderService orderService; @Transactional - public List<StoPreTab> stockOutPreview(OrderStoDto dto) { - if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getCustOrders())) { + public List<StoPreTab> stockOutPreview(OrderStoDto orderStoDto) { + if (Cools.isEmpty(orderStoDto) || Cools.isEmpty(orderStoDto.getDtos())) { throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�"); } + List<StoPreTab> res = new ArrayList<>(); // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶� - locDetlService.checkLocDetlCount(dto.getNumber()); - List<StoPreTab> result = new ArrayList<>(); - for (CustOrder custOrder : dto.getCustOrders()) { + locDetlService.checkLocDetlCount(orderStoDto.getDtos()); + + for (MatnrDto matnrDto : orderStoDto.getDtos()) { // 鍒ゆ柇鐗╂枡鏄惁瀛樺湪 - Mat mat = matService.selectByMatnr(custOrder.getUserCode()); + Mat mat = matService.selectByMatnr(matnrDto.getMatnr()); if (null == mat) { - throw new CoolException(custOrder.getUserCode() + "鐗╂枡灏氭湭鏇存柊銆�" + custOrder.getNumber() +"鍗曟嵁鍥犳涓柇锛�"); + throw new CoolException(matnrDto.getMatnr() + "鐗╂枡灏氭湭鏇存柊銆�" + orderStoDto.getOrderNo() +"鍗曟嵁鍥犳涓柇锛�"); } // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣� List<LocDetl> locDetls = locDetlService.findOfSort(mat.getMatnr()); - double issued = Optional.ofNullable(custOrder.getQty()).orElse(0.0D) ; + double issued = Optional.ofNullable(matnrDto.getCount()).orElse(0.0D) ; double anfme = issued; for (LocDetl locDetl : locDetls) { if (issued > 0) { @@ -72,33 +68,46 @@ tab.setRemQty(tab.getTotal() - tab.getReduce()); tab.setPrior(locDetlService.isPrior(locDetl.getNodeId(), mat.getMatnr())); tab.setPrior$(tab.getPrior()?"鉁�":"脳"); - result.add(tab); + tab.setType(1); + res.add(tab); // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 issued = issued - locDetl.getAnfme(); } } } - return result; + 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; } @Transactional - public void stockOutProcess(OrderStoDto dto) { - if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getCustOrders())) { + public void stockOutProcess(OrderStoDto orderStoDto) { + if (Cools.isEmpty(orderStoDto) || Cools.isEmpty(orderStoDto.getDtos())) { return; } - // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶� - locDetlService.checkLocDetlCount(dto.getNumber()); + Order order = orderService.selectByOrderNo(orderStoDto.getOrderNo()); + if (order == null) { + throw new CoolException(orderStoDto.getOrderNo() + "鍗曟嵁涓嶅瓨鍦�"); + } Date now = new Date(); - for (CustOrder custOrder : dto.getCustOrders()) { + // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶� + locDetlService.checkLocDetlCount(orderStoDto.getDtos()); + + for (MatnrDto matnrDto : orderStoDto.getDtos()) { // 鍒ゆ柇鐗╂枡鏄惁瀛樺湪 - Mat mat = matService.selectByMatnr(custOrder.getUserCode()); + Mat mat = matService.selectByMatnr(matnrDto.getMatnr()); if (null == mat) { - throw new CoolException(custOrder.getUserCode() + "鐗╂枡灏氭湭鏇存柊銆�" + custOrder.getNumber() +"鍗曟嵁鍥犳涓柇锛�"); + throw new CoolException(matnrDto.getMatnr() + "鐗╂枡灏氭湭鏇存柊銆�" + matnrDto.getCount() +"鍗曟嵁鍥犳涓柇锛�"); } // 鏌ヨ瀛樻湁褰撳墠鐗╂枡鐨勮揣浣� List<LocDetl> locDetls = locDetlService.findOfSort(mat.getMatnr()); - double issued = Optional.ofNullable(custOrder.getQty()).orElse(0.0D) ; + double issued = Optional.ofNullable(matnrDto.getCount()).orElse(0.0D) ; for (LocDetl locDetl : locDetls) { if (issued > 0) { // 淇濆瓨鍑哄簱閫氱煡鍗� @@ -110,8 +119,8 @@ pakout.setNodeId(locDetl.getNodeId()); pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); VersionUtils.setPakout(pakout, mat); -// pakout.setDocId(custOrder.getBTypeId()); - pakout.setDocNum(custOrder.getNumber()); // 鍗曟嵁缂栧彿 + pakout.setDocId(order.getDocType()); // 鍗曟嵁绫诲瀷 + pakout.setDocNum(order.getOrderNo()); // 鍗曟嵁缂栧彿 pakout.setCreateTime(now); pakout.setUpdateTime(now); pakout.setStatus(1); @@ -134,11 +143,10 @@ } } // 淇敼鍗曟嵁鐘舵�� - if (!custOrderService.updateStatus(custOrder.getNumber(), 2)) { + if (!orderService.updateSettle(orderStoDto.getOrderNo(), 2L)) { throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); } } } - } -- Gitblit v1.9.1