From 3f30983db5b3cd2b25cb215579501a2ef134883c Mon Sep 17 00:00:00 2001 From: zyx <zyx123456> Date: 星期五, 04 八月 2023 17:00:11 +0800 Subject: [PATCH] agv 订单出库功能完善 --- src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java | 105 ++++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 81 insertions(+), 24 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java index 2f34254..2c6449c 100644 --- a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java @@ -1,6 +1,7 @@ package com.zy.asrs.service.impl; import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.core.common.Cools; import com.core.common.DateUtils; import com.core.common.SnowflakeIdWorker; @@ -11,8 +12,10 @@ import com.zy.asrs.mapper.OrderDetlMapper; import com.zy.asrs.mapper.OrderMapper; import com.zy.asrs.service.*; -import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.zy.common.model.DetlDto; +import com.zy.common.model.OrderDto; +import com.zy.common.model.OrderMergeVo; +import com.zy.common.service.erp.ErpService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -36,6 +39,12 @@ private DocTypeService docTypeService; @Autowired private WrkDetlService wrkDetlService; + @Autowired + private AgvWrkDetlService agvWrkDetlService; + @Autowired + private MatService matService; + @Autowired + private ErpService erpService; @Override public Order selectByNo(String orderNo) { @@ -59,10 +68,14 @@ @Override public void checkComplete(String orderNo) { Order order = this.selectByNo(orderNo); + if(Cools.isEmpty(order)){ + return; + } if (order.getSettle() >= 4L) { return; } List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId())); + // 浣滀笟鏁伴噺鏄惁绛変簬鏁伴噺 boolean complete = true; for (OrderDetl orderDetl : orderDetls) { if (orderDetl.getAnfme() > orderDetl.getQty()) { @@ -70,30 +83,34 @@ break; } } - if (complete) { + // 濡傛灉 浣滀笟鏁伴噺绛変簬鍗曟嵁鎬绘暟閲� && 宸ヤ綔鏄庣粏妗d腑鏃犺鍗曟嵁鐨勬暟鎹� && AGV宸ヤ綔鏄庣粏妗d腑鏃犺鍗曟嵁鐨勬暟鎹� + if (complete + && wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().like("order_no", orderNo)) < 1 + && agvWrkDetlService.selectCount(new EntityWrapper<AgvWrkDetl>().like("order_no",orderNo)) < 1) { // 鍑哄簱璁㈠崟閲嶆柊鏁寸悊鏄庣粏 - DocType docType = docTypeService.selectById(order.getDocType()); - if (null != docType && docType.getPakout() == 1) { - if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()))) { - throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�"); - } - List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNo(orderNo); - for (WrkDetl wrkDetl : wrkDetls) { - OrderDetl orderDetl = new OrderDetl(); - orderDetl.sync(wrkDetl); - orderDetl.setQty(orderDetl.getAnfme()); - orderDetl.setOrderId(order.getId()); - orderDetl.setOrderNo(orderNo); - orderDetl.setStatus(1); - orderDetl.setCreateTime(order.getCreateTime()); - orderDetl.setCreateBy(order.getCreateBy()); - orderDetl.setUpdateTime(order.getUpdateTime()); - orderDetl.setUpdateBy(order.getUpdateBy()); - if (!orderDetlService.insert(orderDetl)) { - throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�"); - } - } - } +// DocType docType = docTypeService.selectById(order.getDocType()); +// if (null != docType && docType.getPakout() == 1) { +// // 閲嶇粍鏄庣粏 +// if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()))) { +// throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�"); +// } +// List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNo(orderNo); +// for (WrkDetl wrkDetl : wrkDetls) { +// OrderDetl orderDetl = new OrderDetl(); +// orderDetl.sync(wrkDetl); +// orderDetl.setQty(orderDetl.getAnfme()); +// orderDetl.setOrderId(order.getId()); +// orderDetl.setOrderNo(orderNo); +// orderDetl.setStatus(1); +// orderDetl.setCreateTime(order.getCreateTime()); +// orderDetl.setCreateBy(order.getCreateBy()); +// orderDetl.setUpdateTime(order.getUpdateTime()); +// orderDetl.setUpdateBy(order.getUpdateBy()); +// if (!orderDetlService.insert(orderDetl)) { +// throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�"); +// } +// } +// } if (!this.updateSettle(order.getId(), 4L, null)) { throw new CoolException("淇敼璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戠姸鎬佷负宸插畬鎴愬け璐�"); @@ -141,6 +158,10 @@ throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触"); } } + // 宸ヤ綔妗f槑缁嗘洿鏂板崟鎹紪鍙� + for (WrkDetl wrkDetl : wrkDetls) { + wrkDetlService.updateOrderNo(orderNo, wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch()); + } } catch (Exception e) { log.error("", e); return false; @@ -161,4 +182,40 @@ return this.baseMapper.selectComplete(); } + @Override + public List<OrderMergeVo> mergePreview(List<Long> ids) { + List<OrderMergeVo> result = new ArrayList<>(); + for (Long orderId : ids) { + Order order = this.selectById(orderId); + // 鑾峰彇鎵�鏈夋湭浣滀笟鐨勬槑缁� + List<OrderDetl> orderDetls = orderDetlService.selectRemainder(orderId); + for (OrderDetl orderDetl : orderDetls) { + Double leave = orderDetl.getAnfme() - orderDetl.getQty(); + OrderMergeVo vo = new OrderMergeVo(orderDetl.getMatnr(), orderDetl.getBatch(), leave); + OrderDto orderDto = new OrderDto(orderDetl.getOrderNo(), null,null, leave); + if (OrderMergeVo.has(result, vo)) { + OrderMergeVo exist = OrderMergeVo.find(result, vo.getMatnr(), vo.getBatch()); + assert exist != null; + exist.setAnfme(exist.getAnfme() + vo.getAnfme()); + exist.getOrderDtos().add(orderDto); + } else { + vo.getOrderDtos().add(orderDto); + result.add(vo); + } + + } + } + for (OrderMergeVo vo : result) { + Mat mat = matService.selectByMatnr(vo.getMatnr()); + assert mat != null; + vo.setMaktx(mat.getMaktx()); + vo.setSpecs(mat.getSpecs()); + } + return result; + } + @Override + public List<Order> selectorderNoL(String orderNo) { + return this.baseMapper.selectorderNoL(orderNo); + } + } -- Gitblit v1.9.1