package com.zy.asrs.task.handler; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.entity.*; import com.zy.asrs.service.*; import com.zy.asrs.task.AbstractHandler; import com.zy.asrs.task.core.ReturnT; import com.zy.common.model.OrderDto; import com.zy.common.service.erp.ErpService; import com.zy.common.service.erp.entity.Goods; import com.zy.common.web.BaseController; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import java.util.ArrayList; import java.util.Iterator; import java.util.List; /** * Created by vincent on 2020/7/6 */ @Slf4j @Service public class WorkLogHandler extends AbstractHandler { @Autowired private WrkMastService wrkMastService; @Autowired private WrkMastLogService wrkMastLogService; @Autowired private WrkDetlService wrkDetlService; @Autowired private WrkDetlLogService wrkDetlLogService; @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private ErpService erpService; @Autowired private DocTypeService docTypeService; // update asr_wrk_mast set inv_wh = 'Y', ove_mk = 'Y' where wrk_no = @Transactional public ReturnT start(WrkMast wrkMast) { try { List wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); // 区分订单任务 List wrkDetlsKeyOrder = new ArrayList<>(); if (!Cools.isEmpty(wrkDetls)) { Iterator iterator = wrkDetls.iterator(); while (iterator.hasNext()) { WrkDetl wrkDetl = iterator.next(); if (!Cools.isEmpty(wrkDetl.getOrderNo())) { wrkDetlsKeyOrder.add(wrkDetl); iterator.remove(); } } } // 入库 -------------------------------------------------------------------------------- if (wrkMast.getWrkSts() == 10) { // 全板入库 if (wrkMast.getIoType() == 1) { // 【 上报三方平台 】 if (!Cools.isEmpty(wrkDetls)) { for (WrkDetl wrkDetl : wrkDetls) { // Goods 表 Goods goods = erpService.selectGoodsOne(wrkDetl.getBatch()); if (!Cools.isEmpty(goods)) { if (!erpService.updateStateAndLocForGoods(goods.getBarCode(), 3, wrkMast.getLocNo())) { log.error("{}条码在erp数据库中更新失败！", goods.getBarCode()); } } else { log.error("{}条码不在erp数据库中！", wrkDetl.getBatch()); } // OrderDetl 表 OrderDetl orderDetl = orderDetlService.selectContainBatch(wrkDetl.getMatnr()); if (!Cools.isEmpty(orderDetl)) { Order order = orderService.selectById(orderDetl.getOrderId()); DocType docType = docTypeService.selectById(order.getDocType()); if (docType.getPakin() == 1) { if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), wrkDetl.getAnfme())) { log.error("{}编号订单，更新{}条码数量失败", orderDetl.getOrderNo(), orderDetl.getMatnr()); } } // Order 表 if (order.getSettle() < 3L) { List orderDetls = orderDetlService.selectByOrderId(order.getId()); boolean complete = true; for (OrderDetl detl : orderDetls) { if (detl.getAnfme() > detl.getQty()) { complete = false; break; } } if (complete) { if (!orderService.updateSettle(order.getId(), 4L, null)) { throw new CoolException("修改订单【orderNo = " + order.getOrderNo() + "】状态为已完成失败"); } } } } } } // 拣料再入库 } else if (wrkMast.getIoType() == 53) { if (!Cools.isEmpty(wrkDetls)) { if (!orderService.saveHandlerOrder(Boolean.FALSE, wrkMast, wrkDetls)) { exceptionHandle("生成手动出库单据[workNo={0}]失败", wrkMast.getWrkNo()); } } // 修改 erp Goods 表 for (WrkDetl wrkDetl : wrkDetls) { Goods goods = erpService.selectGoodsOne(wrkDetl.getBatch()); if (!Cools.isEmpty(goods)) { if (!erpService.updateStateForGoods(goods.getBarCode(), 4)) { log.error("{}条码在erp数据库中更新失败！", goods.getBarCode()); } } else { log.error("{}条码不在erp数据库中！", wrkDetl.getMatnr()); } } for (WrkDetl wrkDetl : wrkDetlsKeyOrder) { Goods goods = erpService.selectGoodsOne(wrkDetl.getBatch()); if (!Cools.isEmpty(goods)) { if (!erpService.updateStateForGoods(goods.getBarCode(), 4)) { log.error("{}条码在erp数据库中更新失败！", goods.getBarCode()); } } else { log.error("{}条码不在erp数据库中！", wrkDetl.getMatnr()); } } } // 出库 -------------------------------------------------------------------------------- } else if (wrkMast.getWrkSts() == 18) { if (!Cools.isEmpty(wrkDetls)) { if (!orderService.saveHandlerOrder(Boolean.FALSE, wrkMast, wrkDetls)) { exceptionHandle("生成手动出库单据[workNo={0}]失败", wrkMast.getWrkNo()); } } // 修改 erp Goods 表 for (WrkDetl wrkDetl : wrkDetls) { Goods goods = erpService.selectGoodsOne(wrkDetl.getBatch()); if (!Cools.isEmpty(goods)) { if (!erpService.updateStateForGoods(goods.getBarCode(), 4)) { log.error("{}条码在erp数据库中更新失败！", goods.getBarCode()); } } else { log.error("{}条码不在erp数据库中！", wrkDetl.getMatnr()); } } for (WrkDetl wrkDetl : wrkDetlsKeyOrder) { Goods goods = erpService.selectGoodsOne(wrkDetl.getBatch()); if (!Cools.isEmpty(goods)) { if (!erpService.updateStateForGoods(goods.getBarCode(), 4)) { log.error("{}条码在erp数据库中更新失败！", goods.getBarCode()); } } else { log.error("{}条码不在erp数据库中！", wrkDetl.getMatnr()); } } } // 保存工作主档历史档 if (!wrkMastLogService.save(wrkMast.getWrkNo())) { exceptionHandle("保存工作历史档[workNo={0}]失败", wrkMast.getWrkNo()); } // 删除工作主档 if (!wrkMastService.deleteById(wrkMast)) { exceptionHandle("删除工作主档[workNo={0}]失败", wrkMast.getWrkNo()); } // 保存工作明细档历史档 if (!wrkDetlLogService.save(wrkMast.getWrkNo())) { // exceptionHandle("保存工作明细历史档[workNo={0}]失败", wrkMast.getWrkNo()); } // 删除工作明细档 if (!wrkDetlService.delete(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo()))) { // exceptionHandle("删除工作明细档[workNo={0}]失败", wrkMast.getWrkNo()); } // 修改订单状态 作业中 ===>> 已完成 for (WrkDetl wrkDetl : wrkDetlsKeyOrder) { if (!BaseController.isJSON(wrkDetl.getOrderNo())) { orderService.checkComplete(wrkDetl.getOrderNo()); } else { // 订单合并出库 List orderDtoList = JSON.parseArray(wrkDetl.getOrderNo(), OrderDto.class); for (OrderDto one : orderDtoList) { orderService.checkComplete(one.getOrderNo()); } } } } catch (Exception e) { log.error("fail", e); e.printStackTrace(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return FAIL.setMsg(e.getMessage()); } return SUCCESS; } }