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.SnowflakeIdWorker; import com.core.exception.CoolException; 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 lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; import java.util.Objects; @Slf4j @Service("orderService") public class OrderServiceImpl extends ServiceImpl implements OrderService { @Autowired private OrderDetlMapper orderDetlMapper; @Autowired private OpenService openService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private OrderDetlService orderDetlService; @Autowired private DocTypeService docTypeService; @Autowired private WrkDetlService wrkDetlService; @Override public Order selectByNo(String orderNo) { List orderList = this.selectList(new EntityWrapper().eq("order_no", orderNo)); if (Cools.isEmpty(orderList)) { return null; } return orderList.get(0); } @Override public List selectWorkingDetls(Long orderId) { return orderDetlMapper.selectWorkingDetls(orderId); } @Override public boolean updateSettle(Long orderId, Long settle, Long userId) { return this.baseMapper.updateSettle(orderId, settle, userId) > 0; } @Override public void checkComplete(String orderNo) { Order order = this.selectByNo(orderNo); if (Cools.isEmpty(order) || order.getSettle() >= 4L) { return; } List orderDetls = orderDetlMapper.selectList(new EntityWrapper().eq("order_id", order.getId())); boolean complete = true; for (OrderDetl orderDetl : orderDetls) { if (orderDetl.getAnfme() > orderDetl.getQty()) { complete = false; break; } } if (complete) { 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 wrkDetls) { // try { // List 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) { if (!this.deleteById(orderId)) { throw new CoolException("删除单据失败"); } orderDetlService.delete(new EntityWrapper().eq("order_id", orderId)); } @Override public List selectComplete() { 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 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 orderNo1 = orderDetlService.selectList(new EntityWrapper() .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 selectToBeHistoryOrder(boolean isERP) { int settle = isERP ? 6 : 4; return this.baseMapper.selectToBeHistoryOrder(settle); } @Override public List selectAllorderNo() { return this.baseMapper.selectAllorderNo(); } }