From 96b3548131415a2a036d1514a9a0d046f3facdb5 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期四, 22 四月 2021 13:13:30 +0800 Subject: [PATCH] # --- src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java | 385 ++++++++++++++++++++++++++++++++++-------------------- 1 files changed, 239 insertions(+), 146 deletions(-) diff --git a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java index 1f205a8..abd9346 100644 --- a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java +++ b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java @@ -1,8 +1,12 @@ package zy.cloud.wms.manager.service.impl; import com.baomidou.mybatisplus.mapper.EntityWrapper; -import com.core.common.*; +import com.core.common.Arith; +import com.core.common.Cools; +import com.core.common.R; +import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -20,14 +24,12 @@ import zy.cloud.wms.manager.entity.result.StoPrintVo; import zy.cloud.wms.manager.service.*; -import java.util.ArrayList; -import java.util.Date; -import java.util.Iterator; -import java.util.List; +import java.util.*; /** * Created by vincent on 2021/2/25 */ +@Slf4j @Service("workService") public class WorkServiceImpl implements WorkService { @@ -40,24 +42,33 @@ @Autowired private LocDetlService locDetlService; @Autowired - private CustOrderService custOrderService; - @Autowired private PakoutService pakoutService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private MatService matService; @Autowired - private AsrsService asrsService; + private CheckService checkService; + @Autowired + private OrderService orderService; + @Autowired + private OrderDetlService orderDetlService; + @Autowired + private ItemService itemService; + @Autowired + private CstmrService cstmrService; @Autowired private ErpService erpService; @Autowired - private CheckService checkService; + private AsrsService asrsService; @Override @Transactional public R stockPakin(PakinParam param, Long userId) { Node node = nodeService.selectByUuid(param.getNodeId()); + if (node == null) { + node = nodeService.selectById(param.getNodeId()); + } if (node == null) { return R.error("璐т綅涓嶅瓨鍦�"); } @@ -96,6 +107,31 @@ } } } + + // 涓婃姤缁檈rp + List<BillDto> dtos = new ArrayList<>(); + for (MatnrDto dto : param.getMats()) { + BillDto billDto = new BillDto(); + billDto.setMatnr(dto.getMatnr()); + billDto.setQty(dto.getCount()); + dtos.add(billDto); + } + Integer docId = Optional.ofNullable(param.getDocType()).orElse(34); + String docNum = String.valueOf(snowflakeIdWorker.nextId()); + switch (docId) { + case 34: // 閲囪喘鍗� + docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); + break; + case 45: // 閿�鍞��璐у崟 + docNum = "SR-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); + break; + default: + break; + } + if (!erpService.uploadBill(dtos, docId, docNum)) { + throw new CoolException("鏃犳硶涓婃姤鑷砮rp"); + } + return R.ok("鍏ュ簱鎴愬姛"); } @@ -171,7 +207,6 @@ if (!erpService.uploadBill(dtos, param.getDocType(), docNum)) { throw new CoolException("鏃犳硶涓婃姤鑷砮rp"); } - return R.ok(); } @@ -181,58 +216,121 @@ } @Override - public R stockOutPrint(StockOutParam param, Long userId) { - List<Pakout> pakouts = pakoutService.selectList(new EntityWrapper<Pakout>().eq("doc_num", param.getNumber())); - Double total = 0.0D; - String custName = ""; - for (Pakout pakout : pakouts) { - total = pakout.getAnfme() + total; - custName = pakout.getCustName(); - } - StoPrintVo vo = new StoPrintVo(); - vo.setDocNum(param.getNumber()); - vo.setList(pakouts); - vo.setTotal(total); - vo.setCustName("娴欐睙涓壃绔嬪簱鎶�鏈湁闄愬叕鍙�"); - vo.setWorkerName("闄嗘檽娑�"); - return R.ok().add(vo); - } - - @Override public R stockOutPreview(StockOutParam param, Long userId) { - List<CustOrder> custOrders = custOrderService.selectList(new EntityWrapper<CustOrder>() - .eq("number", param.getNumber()) - .eq("status", 1) - ); - OrderStoDto dto = new OrderStoDto(); - dto.setNumber(param.getNumber()); - dto.setCustOrders(custOrders); + Order order = orderService.selectByOrderNo(param.getOrderNo()); + if (order.getSettle() != 1) { + return R.error("姝ゅ崟鎹棤娉曠敓鎴愭嫞璐у崟"); + } + List<OrderDetl> orderDetls = orderDetlService.selectByOrderNo(order.getOrderNo()); + if (Cools.isEmpty(orderDetls)) { + return R.error("姝ゅ崟鎹凡澶辨晥锛岃鑱旂郴绠$悊鍛�"); + } + OrderStoDto dto = new OrderStoDto().create(order.getOrderNo(), orderDetls); return R.ok().add(mainService.stockOutPreview(dto)); } @Override - public R stockOut(StockOutParam param, Long userId) { - List<CustOrder> custOrders = custOrderService.selectList(new EntityWrapper<CustOrder>() - .eq("number", param.getNumber()) - .eq("status", 1) - ); - OrderStoDto dto = new OrderStoDto(); - dto.setNumber(param.getNumber()); - dto.setCustOrders(custOrders); + public R stockOutCreate(StockOutParam param, Long userId) { + Order order = orderService.selectByOrderNo(param.getOrderNo()); + if (order.getSettle() != 1) { + return R.error("姝ゅ崟鎹棤娉曠敓鎴愭嫞璐у崟"); + } + List<OrderDetl> orderDetls = orderDetlService.selectByOrderNo(param.getOrderNo()); + if (Cools.isEmpty(orderDetls)) { + return R.error("姝ゅ崟鎹凡澶辨晥锛岃鑱旂郴绠$悊鍛�"); + } + for (OrderDetl orderDetl : orderDetls) { + try { + Integer.parseInt(String.valueOf(orderDetl.getAnfme())); + } catch (Exception e) { + return R.error(orderDetl.getMaktx() + "鏁伴噺蹇呴』涓烘暣鏁�"); + } + } + OrderStoDto dto = new OrderStoDto().create(order.getOrderNo(), orderDetls); // 寮�濮嬫暣鐞嗗嚭搴撴暟鎹� mainService.stockOutProcess(dto); return R.ok("鐢熸垚鎷h揣鍗曟垚鍔�"); } @Override + public R stockOutPrint(StockOutParam param, Long userId) { + Order order = orderService.selectByOrderNo(param.getOrderNo()); + if (order == null) { + return R.error("姝ゅ崟鎹凡澶辨晥"); + } + List<Pakout> pakouts = pakoutService.selectList(new EntityWrapper<Pakout>().eq("doc_num", order.getOrderNo())); + Double total = 0.0D; + for (Pakout pakout : pakouts) { + total = pakout.getAnfme() + total; + } + StoPrintVo vo = new StoPrintVo(); + vo.setDocNum(param.getOrderNo()); + vo.setList(pakouts); + vo.setTotal(total); + vo.setCstmrName(order.getCstmrName()); + vo.setWorkerName(Cools.isEmpty(order.getOperMemb())? "" : order.getOperMemb()); + return R.ok().add(vo); + } + + @Override @Transactional public R stockOutComplete(StockConfirmParam param, Long userId) { List<Pakout> pakouts = pakoutService.selectList(new EntityWrapper<Pakout>() - .eq("doc_num", param.getNumber()) + .eq("doc_num", param.getOrderNo()) .in("wrk_sts", 1, 2)); - // 淇敼搴撳瓨鏁伴噺 for (Pakout pakout : pakouts) { LocDetl locDetl = locDetlService.getLocDetl(pakout.getNodeId(), pakout.getMatnr()); + // 缂鸿揣 or 绔嬪簱 + if (locDetl == null) { + // 缂鸿揣 + if (pakout.getLocNo().equals("缂鸿揣")) { + Double count = Optional.ofNullable(locDetlService.selectCountByMatnr(pakout.getMatnr())).orElse(0.0D); + if (count < pakout.getAnfme()) { + throw new CoolException(pakout.getMaktx()+"缂鸿揣"); + } + Date now = new Date(); + // 鏌ユ壘鎺ㄨ崘璐т綅鏄惁搴撳瓨瓒冲 + List<LocDetl> locDetls = locDetlService.findOfSort(pakout.getMatnr()); + double issued = Optional.ofNullable(pakout.getAnfme()).orElse(0.0D) ; + for (LocDetl locDetl1 : locDetls) { + if (issued > 0) { + // 淇濆瓨鍑哄簱閫氱煡鍗� + Pakout newPakout = new Pakout(); + newPakout.setWrkSts(3L); + newPakout.setAnfme(issued>=locDetl1.getAnfme()?locDetl1.getAnfme():issued); + newPakout.setZpallet(locDetl1.getZpallet()); + newPakout.setLocNo(locDetl1.getLocNo()); + newPakout.setNodeId(locDetl1.getNodeId()); + newPakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); + VersionUtils.setPakout(newPakout, locDetl1); + newPakout.setDocId(pakout.getDocId()); // 鍗曟嵁绫诲瀷 + newPakout.setDocNum(pakout.getDocNum()); // 鍗曟嵁缂栧彿 + newPakout.setCreateTime(now); + newPakout.setUpdateTime(now); + newPakout.setStatus(1); + if (!pakoutService.insert(newPakout)) { + throw new CoolException("淇濆瓨鍑哄簱閫氱煡鍗曞け璐�"); + } + if (issued>=locDetl1.getAnfme()) { + // 鍒犻櫎搴撳瓨鏄庣粏 + if (!locDetlService.removeStock(locDetl1.getNodeId(), newPakout.getMatnr())) { + throw new CoolException("鍒犻櫎搴撳瓨鏄庣粏澶辫触"); + } + } else { + // 淇敼搴撳瓨鏄庣粏鏁伴噺 + if (!locDetlService.reduceStock(locDetl1.getNodeId(), newPakout.getMatnr(), issued)) { + throw new CoolException("淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触"); + } + } + // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 + issued = issued - locDetl1.getAnfme(); + } + } + + } + continue; + } + // 淇敼搴撳瓨鏁伴噺 if (pakout.getAnfme()>=locDetl.getAnfme()) { // 鍒犻櫎搴撳瓨鏄庣粏 if (!locDetlService.removeStock(locDetl.getNodeId(), pakout.getMatnr())) { @@ -245,32 +343,15 @@ } } } + // 淇敼鍑哄簱鍗曠姸鎬� - if (!pakoutService.stockOutComplete(param.getWrkNo(), param.getNumber(), userId)) { + if (!pakoutService.stockOutComplete(param.getWrkNo(), param.getOrderNo(), userId)) { return R.error("淇濆瓨鏁版嵁澶辫触"); } // 淇敼鍗曟嵁鐘舵�� - if (!custOrderService.updateStatus(param.getNumber(), 4)) { + if (!orderService.updateSettle(param.getOrderNo(), 4L)) { throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); } - // 閲囪喘閫�璐у崟 -// if (param.getNumber().startsWith("PR-")) { - // erp鍗曟嵁涓婁紶 - Long docId = pakouts.get(0).getDocId(); - if (null != docId) { - List<BillDto> dtos = new ArrayList<>(); - for (Pakout pakout : pakouts) { - BillDto billDto = new BillDto(); - billDto.setMatnr(pakout.getMatnr()); - billDto.setQty(pakout.getAnfme()); - dtos.add(billDto); - } - if (!erpService.uploadBill(dtos, docId.intValue() , pakouts.get(0).getDocNum())) { - throw new CoolException("鏃犳硶涓婃姤鑷砮rp"); - } - } - -// } return R.ok(); } @@ -344,7 +425,7 @@ } if (complete) { // 淇敼鍗曟嵁鐘舵�� - if (!custOrderService.updateStatus(pakout.getDocNum(), 4)) { + if (!orderService.updateSettle(pakout.getDocNum(), 4L)) { throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); } } @@ -359,35 +440,14 @@ @Transactional public R cancelPakout(String wrkNo, Long userId) { Pakout pakout = pakoutService.selectOne(new EntityWrapper<Pakout>().eq("wrk_no", wrkNo)); -// if (null != pakout) { -// LocDetl locDetl = locDetlService.getLocDetl(pakout.getNodeId(), pakout.getMatnr()); -// if (locDetl == null) { -// LocDetl oldLocDetl = new LocDetl(); -// VersionUtils.setLocDetl(oldLocDetl, pakout); -// oldLocDetl.setCreateTime(new Date()); -// oldLocDetl.setCreateBy(userId); -// oldLocDetl.setUpdateTime(new Date()); -// oldLocDetl.setUpdateBy(userId); -// if (!locDetlService.insert(oldLocDetl)) { -// throw new CoolException("鎭㈠搴撳瓨鏄庣粏澶辫触"); -// } -// } else { -// if (!locDetlService.incrementStock(locDetl.getNodeId(), locDetl.getMatnr(), pakout.getAnfme())) { -// throw new CoolException("鎭㈠搴撳瓨鏄庣粏澶辫触"); -// } -// } -// } else { -// return R.error("鎷h揣鍗曞凡澶辨晥锛屽彇娑堝け璐ワ紒"); -// } if (!pakoutService.delete(new EntityWrapper<Pakout>().eq("wrk_no", pakout.getWrkNo()))) { throw new CoolException("鍒犻櫎鎷h揣鍗曞け璐�"); } - // 鍙栨秷閿�鍞鍗� List<Pakout> pakouts = pakoutService.selectList(new EntityWrapper<Pakout>().eq("doc_num", pakout.getDocNum())); if (Cools.isEmpty(pakouts)){ // 淇敼鍗曟嵁鐘舵�� - if (!custOrderService.updateStatus(pakout.getDocNum(), 3)) { + if (!orderService.updateSettle(pakout.getDocNum(), 3L)) { throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); } } @@ -397,71 +457,74 @@ @Override @Transactional public R initOrder(InitOrderParam param, Long userId) { - if (custOrderService.selectCount(new EntityWrapper<CustOrder>().eq("number", param.getNumber()).ne("bType_id", param.getCustomerTypeId())) > 0) { + Order order = orderService.selectByOrderNo(param.getOrderNo()); + if (order != null) { return R.error("鎶辨瓑鍗曞彿宸插瓨鍦紝璇蜂慨鏀瑰崟鍙�"); } Date now = new Date(); - for (PakinMatDto dto : param.getList()){ + Item item = itemService.selectByName(param.getItem()); + Cstmr cstmr = cstmrService.selectByName(param.getCstmr()); + // 鏂板璁㈠崟琛ㄥご + order = new Order( + String.valueOf(snowflakeIdWorker.nextId()), // 缂栧彿[闈炵┖] + param.getOrderNo(), // 璁㈠崟缂栧彿 + param.getOrderTime(), // 鍗曟嵁鏃ユ湡 + param.getDocType(), // 鍗曟嵁绫诲瀷 + item==null?null:item.getId(), // 椤圭洰缂栧彿 + param.getItem(), // 椤圭洰鍚嶇О + null, // 璋冩嫧椤圭洰缂栧彿 + null, // 鍒濆绁ㄦ嵁鍙� + null, // 绁ㄦ嵁鍙� + cstmr==null?null:cstmr.getId(), // 瀹㈡埛缂栧彿 + param.getCstmr(), // 瀹㈡埛 + null, // 鑱旂郴鏂瑰紡 + null, // 鎿嶄綔浜哄憳 + null, // 鍚堣閲戦 + null, // 浼樻儬鐜� + null, // 浼樻儬閲戦 + null, // 閿�鍞垨閲囪喘璐圭敤鍚堣 + null, // 瀹炰粯閲戦 + null, // 浠樻绫诲瀷 + null, // 涓氬姟鍛� + null, // 缁撶畻澶╂暟 + null, // 閭垂鏀粯绫诲瀷 + null, // 閭垂 + null, // 浠樻鏃堕棿 + null, // 鍙戣揣鏃堕棿 + null, // 鐗╂祦鍚嶇О + null, // 鐗╂祦鍗曞彿 + 1L, // 璁㈠崟鐘舵�� + 1, // 鐘舵�� + userId, // 娣诲姞浜哄憳 + now, // 娣诲姞鏃堕棿 + userId, // 淇敼浜哄憳 + now, // 淇敼鏃堕棿 + null // 澶囨敞 + ); + if (!orderService.insert(order)) { + throw new CoolException("淇濆瓨璁㈠崟琛ㄥご澶辫触锛�"); + } + // 閬嶅巻鍟嗗搧鏁伴噺骞朵繚瀛� + for (MatnrDto dto : param.getList()){ Mat mat = matService.selectByMatnr(dto.getMatnr()); if (mat == null) { + log.error("{}鍟嗗搧涓嶅瓨鍦ㄣ��", dto.getMatnr()); continue; } - CustOrder custOrder = new CustOrder( - param.getNumber(), // 閿�鍞崟鍙� - DateUtils.convert(now), // 鍗曟嵁鏃ユ湡[闈炵┖] - param.getCustomerTypeId(), // 瀹㈡埛缂栧彿 - null, // 缁忔墜浜虹紪鍙穂绌篯 - dto.getMatnr(), // 鍟嗗搧缂栧彿 - dto.getCount(), // 鍟嗗搧鏁伴噺 - dto.getCount(), // 鎬绘暟閲� - Cools.isEmpty(mat.getName())?0.0D:Double.parseDouble(mat.getName()), // 鍟嗗搧鍗曚环 - null, // 鍟嗗搧鏄庣粏琛屽彿 - null, // 鍟嗗搧澶囨敞[绌篯 - 1, // 鐘舵�� - now, // 娣诲姞鏃堕棿 - now, // 淇敼鏃堕棿 - null // 澶囨敞 - ); - if (!custOrderService.insert(custOrder)) { - throw new CoolException("淇濆瓨閿�鍞鍗曞け璐�"); + OrderDetl orderDetl = new OrderDetl(); + orderDetl.setOrderId(order.getId()); // 璁㈠崟鍐呯爜 + orderDetl.setAnfme(dto.getCount()); // 鏁伴噺 + orderDetl.setCreateBy(userId); + orderDetl.setCreateTime(now); + orderDetl.setUpdateBy(userId); + orderDetl.setUpdateTime(now); + orderDetl.setStatus(1); + VersionUtils.setOrderDetl(orderDetl, mat); + if (!orderDetlService.insert(orderDetl)) { + throw new CoolException("淇濆瓨璁㈠崟鏄庣粏澶辫触"); } } - return R.ok("鐢熸垚閿�鍞鍗�" + param.getNumber() + "鎴愬姛"); - } - - @Override - @Transactional - public R stockTransfer(String number, Long userId) { - List<CustOrder> custOrders = custOrderService.selectList(new EntityWrapper<CustOrder>().eq("number", number).eq("status", 1)); - boolean asrs = false; - List<StockTransferParam> params = new ArrayList<>(); - for (CustOrder custOrder : custOrders) { - Double count = locDetlService.selectCountByMatnr(custOrder.getUserCode()); - if (count == null) { - count = 0.0D; - } - if (count < custOrder.getQty()) { - if (!asrs) { asrs = true; } - StockTransferParam param = new StockTransferParam(); - param.setMatnr(custOrder.getUserCode()); - param.setAnfme(custOrder.getQty() - count); - params.add(param); - } - } - if (asrs) { -// if (asrsService.stockTransfer(params)) { -// for (StockTransferParam param : params) { -// // 淇敼閿�鍞鍗曞緟鍑烘暟閲� -// if (!custOrderService.updateQty(number, param.getMatnr(), param.getAnfme())) { -// throw new CoolException("淇敼閿�鍞鍗曞緟鍑烘暟閲忓け璐�"); -// } -// } -// return R.ok("搴撳瓨璋冩嫧鎴愬姛"); -// } else { -// return R.error("绔嬪簱璋冩嫧澶辫触锛岃鑱旂郴绠$悊鍛�"); -// } - } - return R.error("鏆備笉缂鸿揣锛屼笉闇�瑕佺珛搴撹皟鎷�"); + return R.ok("鍒涘缓璁㈠崟鎴愬姛"); } @Override @@ -469,10 +532,16 @@ if (Cools.isEmpty(param.getNode_id(), param.getMatnr(), param.getSafe_qua(), param.getAmount())) { return R.error("鏁伴噺閿欒"); } + Node node = nodeService.selectById(param.getNode_id()); + Mat mat = matService.selectByMatnr(param.getMatnr()); + if (node == null || mat == null) { + return R.error(); + } + double anfme = Arith.subtract(2, param.getSafe_qua(), param.getAmount()); List<StockTransferParam> params = new ArrayList<>(); StockTransferParam transferParam = new StockTransferParam(); transferParam.setMatnr(param.getMatnr()); - transferParam.setAnfme(Arith.subtract(2, param.getSafe_qua(), param.getAmount())); + transferParam.setAnfme(anfme); transferParam.setAllotNo(param.getNode_id()+ "_" +param.getMatnr()); params.add(transferParam); Result1 result = asrsService.stockTransfer(params); @@ -483,8 +552,33 @@ throw new CodeCoolException("20001-" + result.getData()); } } + // 鐩存帴澧炲姞搴撳瓨 + LocDetl locDetl = locDetlService.getLocDetl(param.getNode_id(), param.getMatnr()); + if (locDetl == null) { + // 鏇存柊璐т綅搴撳瓨鏄庣粏 + locDetl = new LocDetl(); + locDetl.setLocNo(node.getName()); + locDetl.setNodeId(node.getId()); + locDetl.setAnfme(anfme); + VersionUtils.setLocDetl(locDetl, mat); + locDetl.setStatus(1); + locDetl.setCreateBy(userId); + locDetl.setCreateTime(new Date()); + locDetl.setUpdateBy(userId); + locDetl.setUpdateTime(new Date()); + boolean insert = locDetlService.insert(locDetl); + if (!insert) { + throw new CoolException("鏂板搴撳瓨鏄庣粏妗eけ璐�"); + } + } else { + if (!locDetlService.incrementStock(node.getId(), param.getMatnr(), anfme)) { + throw new CoolException("鏂板搴撳瓨鏄庣粏妗eけ璐�"); + } + } + return R.ok("琛ヤ粨鎴愬姛锛岀瓑寰呯珛搴撹皟鎷�"); } + @Override public R stockCheck(StoCheckParam param, Long userId) { @@ -688,7 +782,6 @@ if (!erpService.uploadBill(dtos, docId.intValue(), docNum)) { throw new CoolException("鏃犳硶涓婃姤鑷砮rp"); } - return R.ok(); } -- Gitblit v1.9.1