From e1749547c76a5d8bae94e47d38d4d75b481610c1 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@63.com> Date: 星期四, 09 九月 2021 10:51:15 +0800 Subject: [PATCH] # --- src/main/java/zy/cloud/wms/common/service/MainService.java | 65 +++++++++++++++----------------- 1 files changed, 30 insertions(+), 35 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 01cf71f..827ef29 100644 --- a/src/main/java/zy/cloud/wms/common/service/MainService.java +++ b/src/main/java/zy/cloud/wms/common/service/MainService.java @@ -8,6 +8,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import zy.cloud.wms.common.config.CodeCoolException; +import zy.cloud.wms.common.model.MatnrDto; import zy.cloud.wms.common.model.OrderStoDto; import zy.cloud.wms.common.service.asrs.AsrsService; import zy.cloud.wms.common.service.asrs.entity.Result; @@ -16,9 +17,9 @@ import zy.cloud.wms.manager.entity.*; import zy.cloud.wms.manager.entity.param.StockTransferParam; import zy.cloud.wms.manager.entity.result.PakoutVo; -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.OrderService; import zy.cloud.wms.manager.service.PakoutService; import java.util.*; @@ -37,40 +38,40 @@ @Autowired private PakoutService pakoutService; @Autowired - private CustOrderService custOrderService; - @Autowired private SnowflakeIdWorker snowflakeIdWorker; + @Autowired + private OrderService orderService; @Autowired private AsrsService asrsService; @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<>(); // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶� - List<StockTransferParam> transferParams = locDetlService.checkLocDetlCountOfRes(dto.getNumber()); + List<StockTransferParam> transferParams = locDetlService.checkLocDetlCountOfRes(orderStoDto.getDtos()); if (!Cools.isEmpty(transferParams)) { // 鏌ョ湅绔嬪簱搴撳瓨 Result result = asrsService.stockTransferPrew(transferParams); if (result.getCode() == 500) { - throw new CodeCoolException("20001-" + String.valueOf(result.getData())); + throw new CodeCoolException("20001-" + String.valueOf(result.getMsg())); } if (result.getCode() == 200) { res = (List<StoPreTab>) result.getData(); } } - for (CustOrder custOrder : dto.getCustOrders()) { + 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) { @@ -107,21 +108,23 @@ } @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; } + Order order = orderService.selectByOrderNo(orderStoDto.getOrderNo()); + if (order == null) { + throw new CoolException(orderStoDto.getOrderNo() + "鍗曟嵁涓嶅瓨鍦�"); + } Date now = new Date(); - - /******************************* 绔嬪簱鎷h揣鍗� ********************************/ // 妫�鏌ュ簱瀛樻槸鍚﹁冻澶� - List<StockTransferParam> transferParams = locDetlService.checkLocDetlCountOfRes(dto.getNumber()); + List<StockTransferParam> transferParams = locDetlService.checkLocDetlCountOfRes(orderStoDto.getDtos()); if (!Cools.isEmpty(transferParams)) { // 鏌ョ湅绔嬪簱搴撳瓨 Result1 result = asrsService.stockTransfer(transferParams); if (result.getCode() == 500) { if (Cools.isEmpty(result.getData())) { - throw new CodeCoolException(result.getMsg()); + throw new CoolException(result.getMsg()); } else { throw new CodeCoolException("20001-" + result.getData()); } @@ -131,7 +134,7 @@ // 鍒ゆ柇鐗╂枡鏄惁瀛樺湪 Mat mat = matService.selectByMatnr(vo.getMatnr()); if (null == mat) { - throw new CoolException(vo.getMatnr() + "鐗╂枡灏氭湭鏇存柊銆�" + dto.getNumber() +"鍗曟嵁鍥犳涓柇锛�"); + throw new CoolException(vo.getMatnr() + "鐗╂枡灏氭湭鏇存柊銆�" + orderStoDto.getOrderNo() +"鍗曟嵁鍥犳涓柇锛�"); } Pakout pakout = new Pakout(); pakout.setWrkSts(1L); @@ -141,8 +144,8 @@ pakout.setNodeId(-1L); pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); VersionUtils.setPakout(pakout, mat); - pakout.setDocId(getDocId(dto.getNumber())); // 鍗曟嵁绫诲瀷 - pakout.setDocNum(dto.getNumber()); // 鍗曟嵁缂栧彿 + pakout.setDocId(order.getDocType()); // 鍗曟嵁绫诲瀷 + pakout.setDocNum(order.getOrderNo()); // 鍗曟嵁缂栧彿 pakout.setCreateTime(now); pakout.setUpdateTime(now); pakout.setStatus(1); @@ -154,16 +157,15 @@ } } - /******************************* 骞充粨鎷h揣鍗� ********************************/ - for (CustOrder custOrder : dto.getCustOrders()) { + 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) { // 淇濆瓨鍑哄簱閫氱煡鍗� @@ -175,8 +177,8 @@ pakout.setNodeId(locDetl.getNodeId()); pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); VersionUtils.setPakout(pakout, mat); - pakout.setDocId(getDocId(dto.getNumber())); // 鍗曟嵁绫诲瀷 - pakout.setDocNum(custOrder.getNumber()); // 鍗曟嵁缂栧彿 + pakout.setDocId(order.getDocType()); // 鍗曟嵁绫诲瀷 + pakout.setDocNum(order.getOrderNo()); // 鍗曟嵁缂栧彿 pakout.setCreateTime(now); pakout.setUpdateTime(now); pakout.setStatus(1); @@ -199,17 +201,10 @@ } } // 淇敼鍗曟嵁鐘舵�� - if (!custOrderService.updateStatus(custOrder.getNumber(), 2)) { + if (!orderService.updateSettle(orderStoDto.getOrderNo(), 2L)) { throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); } } - } - - private Long getDocId(String number) { - if (number.startsWith("PR")) { - return 6L; - } - return 11L; } } -- Gitblit v1.9.1