|  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | import com.core.exception.CoolException; | 
|---|
|  |  |  | import com.zy.asrs.entity.*; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.OpenOrderPakinParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.OpenOrderPakoutParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.ManPakOut; | 
|---|
|  |  |  | import com.zy.asrs.entity.Order; | 
|---|
|  |  |  | import com.zy.asrs.entity.OrderDetl; | 
|---|
|  |  |  | import com.zy.asrs.entity.OrderListDTO; | 
|---|
|  |  |  | 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 lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.stereotype.Service; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.ArrayList; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  | import java.util.Objects; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Slf4j | 
|---|
|  |  |  | @Service("orderService") | 
|---|
|  |  |  | 
|---|
|  |  |  | private DocTypeService docTypeService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private WrkDetlService wrkDetlService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ManPakOutService manPakOutService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public Order selectByNo(String orderNo) { | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void checkComplete(String orderNo) { | 
|---|
|  |  |  | Order order = this.selectByNo(orderNo); | 
|---|
|  |  |  | if (order.getSettle() >= 4L) { | 
|---|
|  |  |  | if (Cools.isEmpty(order) || order.getSettle() >= 4L) { | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId())); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (complete) { | 
|---|
|  |  |  | // 出库订单重新整理明细 | 
|---|
|  |  |  | 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("重整出库订单【orderNo = " + 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("重整出库订单【orderNo = " + order.getOrderNo() + "】明细失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (OrderDetl orderDetl : orderDetls) { | 
|---|
|  |  |  | if (Cools.isEmpty(orderDetl.getBatch())){ | 
|---|
|  |  |  | orderDetlService.updateById(orderDetl); | 
|---|
|  |  |  | }else if (orderDetl.getBatch().equals("")){//生成单据和入库通知档时,给batch为空的明细赋了一个 ="", 现在改为null,回传用 | 
|---|
|  |  |  | orderDetl.setBatch(null); | 
|---|
|  |  |  | orderDetlService.updateById(orderDetl); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (!this.updateSettle(order.getId(), 4L, null)) { | 
|---|
|  |  |  | throw new CoolException("修改订单【orderNo = " + order.getOrderNo() + "】状态为已完成失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public boolean saveHandlerOrder(Boolean pakin, WrkMast wrkMast, List<WrkDetl> wrkDetls) { | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | List<DetlDto> detlDtos = new ArrayList<>(); | 
|---|
|  |  |  | wrkDetls.forEach(wrkDetl -> { | 
|---|
|  |  |  | detlDtos.add(new DetlDto(wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | String orderNo = "HAND" + snowflakeIdWorker.nextId(); | 
|---|
|  |  |  | if (pakin) { | 
|---|
|  |  |  | // 生成入库单据 | 
|---|
|  |  |  | OpenOrderPakinParam openParam = new OpenOrderPakinParam(); | 
|---|
|  |  |  | openParam.setOrderNo(orderNo); | 
|---|
|  |  |  | openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime())); | 
|---|
|  |  |  | openParam.setOrderType("手动入库单"); | 
|---|
|  |  |  | openParam.setOrderDetails(detlDtos); | 
|---|
|  |  |  | openService.pakinOrderCreate(openParam); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | // 生成出库单据 | 
|---|
|  |  |  | OpenOrderPakoutParam openParam = new OpenOrderPakoutParam(); | 
|---|
|  |  |  | openParam.setOrderNo(orderNo); | 
|---|
|  |  |  | openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime())); | 
|---|
|  |  |  | openParam.setOrderType("手动出库单"); | 
|---|
|  |  |  | openParam.setOrderDetails(detlDtos); | 
|---|
|  |  |  | openService.pakoutOrderCreate(openParam); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Order order = this.selectByNo(orderNo); | 
|---|
|  |  |  | if (null == order) { | 
|---|
|  |  |  | throw new CoolException("生成单据失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!this.updateSettle(order.getId(), 4L, null)) { | 
|---|
|  |  |  | throw new CoolException("修改单据状态失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (DetlDto detlDto : detlDtos) { | 
|---|
|  |  |  | // 修改订单明细数量 | 
|---|
|  |  |  | if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { | 
|---|
|  |  |  | throw new CoolException("修改单据明细数量失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("", e); | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return true; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //    @Override | 
|---|
|  |  |  | //    public boolean saveHandlerOrder(Boolean pakin, WrkMast wrkMast, List<WrkDetl> wrkDetls) { | 
|---|
|  |  |  | //        try { | 
|---|
|  |  |  | //            List<DetlDto> detlDtos = new ArrayList<>(); | 
|---|
|  |  |  | //            wrkDetls.forEach(wrkDetl -> { | 
|---|
|  |  |  | //                detlDtos.add(new DetlDto(wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())); | 
|---|
|  |  |  | //            }); | 
|---|
|  |  |  | //            String orderNo = "HAND" + snowflakeIdWorker.nextId(); | 
|---|
|  |  |  | //            if (pakin) { | 
|---|
|  |  |  | //                // 生成入库单据 | 
|---|
|  |  |  | //                OpenOrderPakinParam openParam = new OpenOrderPakinParam(); | 
|---|
|  |  |  | //                openParam.setOrderNo(orderNo); | 
|---|
|  |  |  | //                openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime())); | 
|---|
|  |  |  | //                openParam.setOrderType("手动入库单"); | 
|---|
|  |  |  | //                openParam.setOrderDetails(detlDtos); | 
|---|
|  |  |  | //                openService.pakinOrderCreate(openParam); | 
|---|
|  |  |  | //            } else { | 
|---|
|  |  |  | //                // 生成出库单据 | 
|---|
|  |  |  | //                OpenOrderPakoutParam openParam = new OpenOrderPakoutParam(); | 
|---|
|  |  |  | //                openParam.setOrderNo(orderNo); | 
|---|
|  |  |  | //                openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime())); | 
|---|
|  |  |  | //                openParam.setOrderType("手动出库单"); | 
|---|
|  |  |  | //                openParam.setOrderDetails(detlDtos); | 
|---|
|  |  |  | //                openService.pakoutOrderCreate(openParam); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //            Order order = this.selectByNo(orderNo); | 
|---|
|  |  |  | //            if (null == order) { | 
|---|
|  |  |  | //                throw new CoolException("生成单据失败"); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | //            if (!this.updateSettle(order.getId(), 4L, null)) { | 
|---|
|  |  |  | //                throw new CoolException("修改单据状态失败"); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | //            for (DetlDto detlDto : detlDtos) { | 
|---|
|  |  |  | //                // 修改订单明细数量 | 
|---|
|  |  |  | //                if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { | 
|---|
|  |  |  | //                    throw new CoolException("修改单据明细数量失败"); | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | //                // 修改订单作业数量 | 
|---|
|  |  |  | //                if (!orderDetlService.increaseWorkQty(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { | 
|---|
|  |  |  | //                    throw new CoolException("修改单据作业数量失败"); | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | //        } catch (Exception e) { | 
|---|
|  |  |  | //            log.error("saveHandlerOrder===>>", e); | 
|---|
|  |  |  | //            return false; | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        return true; | 
|---|
|  |  |  | //    } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void remove(Long orderId) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Order order = this.selectById(orderId); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | int count = manPakOutService.selectCount(new EntityWrapper<ManPakOut>().eq("doc_num", order.getOrderNo())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(count > 0){ | 
|---|
|  |  |  | throw new CoolException("请先删除拣货单"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (!this.deleteById(orderId)) { | 
|---|
|  |  |  | throw new CoolException("删除单据失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | return this.baseMapper.selectComplete(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public boolean addToLogTable(Order order) { | 
|---|
|  |  |  | return this.baseMapper.addToLogTable(order) > 0; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * | 
|---|
|  |  |  | * @param orderNo | 
|---|
|  |  |  | * | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void BackToInit(String orderNo) { | 
|---|
|  |  |  | Integer count = this.baseMapper.checkDetlWorkQtyLess0(orderNo); | 
|---|
|  |  |  | //如果所有明细的工作数量和完成量都小于等于0, 那么将主档更新为“待处理”状态 | 
|---|
|  |  |  | if (count == 0 ){ | 
|---|
|  |  |  | this.baseMapper.updateSettleTo1(orderNo); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<Order> selectInOrOutOrders(boolean inOrders) { | 
|---|
|  |  |  | if (inOrders) { | 
|---|
|  |  |  | return this.baseMapper.selectInOrOutOrders(1); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | return this.baseMapper.selectInOrOutOrders(0); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void checkSettleUpdate(Long orderId) { | 
|---|
|  |  |  | long settle = 1; | 
|---|
|  |  |  | Integer count = 0; | 
|---|
|  |  |  | List<OrderDetl> orderNo1 = orderDetlService.selectList(new EntityWrapper<OrderDetl>() | 
|---|
|  |  |  | .eq("order_id", orderId)); | 
|---|
|  |  |  | for (int i = 0; i < orderNo1.size(); i++) { | 
|---|
|  |  |  | OrderDetl orderDetl = orderNo1.get(i); | 
|---|
|  |  |  | if (orderDetl.getQty() > 0){ | 
|---|
|  |  |  | settle = 2; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (Objects.equals(orderDetl.getAnfme(), orderDetl.getQty())){ | 
|---|
|  |  |  | count++; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (count == orderNo1.size()){ | 
|---|
|  |  |  | settle = 4; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | updateSettle(orderId,settle,1L); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<Order> selectToBeHistoryOrder(boolean isERP) { | 
|---|
|  |  |  | int settle = isERP ? 6 : 4; | 
|---|
|  |  |  | return this.baseMapper.selectToBeHistoryOrder(settle); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<OrderListDTO> selectAllorderNo() { | 
|---|
|  |  |  | return this.baseMapper.selectAllorderNo(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|