package com.zy.asrs.task.handler; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.zy.asrs.entity.*; import com.zy.asrs.service.*; import com.zy.asrs.task.AbstractHandler; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Date; import java.util.List; /** * Created by vincent on 2020/7/4 */ @Service @Transactional public class WorkMastHandler extends AbstractHandler { @Autowired private WrkMastService wrkMastService; @Autowired private WrkDetlService wrkDetlService; @Autowired private LocMastService locMastService; @Autowired private LocDetlService locDetlService; @Autowired private WaitPakinService waitPakinService; public void start() { List wrkMasts = wrkMastService.selectToBeCompleteData(); if (wrkMasts.isEmpty()) { return; } for (WrkMast wrkMast : wrkMasts) { // 4.入库完成 if (wrkMast.getWrkSts() == 4) { doIn(wrkMast); // 14.出库完成 } else if (wrkMast.getWrkSts() == 14) { doOut(wrkMast); } } } private void doIn(WrkMast wrkMast){ Date now = new Date(); LocMast locMast = locMastService.selectById(wrkMast.getLocNo()); if (null == locMast) { exceptionHandle(""); // todo return; } switch (wrkMast.getIoType()) { // 空板入库 case 10: // 修改库位状态=D if (locMast.getLocType().equals("S") || locMast.getLocType().equals("Q")) { locMast.setLocType("D"); locMast.setIoTime(now); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } } break; // 全板入库 case 1: // 清除所属库位之前的库存明细 List locDetls = locDetlService.selectList(new EntityWrapper().eq("loc_no", wrkMast.getLocNo())); if (!locDetls.isEmpty()) { locDetlService.delete(new EntityWrapper().eq("loc_no", wrkMast.getLocNo())); } // 根据工作号，查询工作明细档 List wrkDetls = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); if (wrkDetls.isEmpty()) { exceptionHandle(""); // todo } // 遍历工作明细，更新库存明细和入库通知档 for (WrkDetl wrkDetl : wrkDetls) { LocDetl locDetl = locDetlService.selectOne(new EntityWrapper().eq("loc_no", wrkMast.getLocNo()).eq("matnr", wrkDetl.getMatnr())); if (null != locDetl) { boolean res = locDetlService.updateAnfme(wrkDetl.getAnfme(), wrkMast.getLocNo(), wrkDetl.getMatnr()); if (!res) { exceptionHandle(""); // todo } } else { locDetl = new LocDetl( wrkMast.getLocNo(), // 库位号 wrkDetl.getMatnr(), // 物料号 null, // 仓库号 null, // 转储请求编号 null, // 行项目 null, // 物料标签ID wrkDetl.getMaktx(), // 物料描述 null, // 工厂 wrkDetl.getAnfme(), // 数量 wrkDetl.getAltme(), // 单位 wrkDetl.getZpallet(), // 托盘条码 null, // 用户ID null, // 备注 null, // 修改人员 now, // 修改时间 null, // 创建者 now // 添加时间 ); if (!locDetlService.insert(locDetl)) { exceptionHandle(""); // todo } } // 更新入库通知档 status ===>> Y WaitPakin setParam = new WaitPakin(); setParam.setStatus("Y"); boolean updateRes = waitPakinService.update(setParam , new EntityWrapper().eq("barcode", wrkDetl.getZpallet()) .eq("matnr", wrkDetl.getMatnr()) .eq("anfme", wrkDetl.getAnfme())); if (!updateRes) { exceptionHandle(""); // todo } } // 修改库位状态 S ====>> F if (locMast.getLocType().equals("S")) { locMast.setLocType("F"); locMast.setBarcode(wrkMast.getBarcode()); locMast.setIoTime(now); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } } break; // 拣料入库 case 53: // 根据工作号，查询工作明细档 List wrkDetls53 = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); if (wrkDetls53.isEmpty()) { exceptionHandle(""); // todo } for (WrkDetl wrkDetl:wrkDetls53) { // 修改库存明细数量，如果工作明细数量为0时，删除库存明细 LocDetl locDetl = locDetlService.selectOne(new EntityWrapper().eq("loc_no", locMast.getLocNo()).eq("matnr", wrkDetl.getMatnr())); if (null != locDetl) { if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr())) { exceptionHandle(""); // todo } // todo:luxiaotao 3)修改出库通知档 status ==> Y } } // 修改库位状态 Q ====>> F if (locMast.getLocType().equals("Q")) { locMast.setLocType("F"); locMast.setBarcode(wrkMast.getBarcode()); locMast.setIoTime(now); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } } break; // 并板入库 case 54: // 根据工作号，查询工作明细档 List wrkDetls54 = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); if (wrkDetls54.isEmpty()) { exceptionHandle(""); // todo } // 修改库存明细数量，如无库存，曾新增 for (WrkDetl wrkDetl:wrkDetls54) { LocDetl locDetl = locDetlService.selectOne(new EntityWrapper().eq("loc_no", locMast.getLocNo()).eq("matnr", wrkDetl.getMatnr())); if (null != locDetl) { if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr())) { exceptionHandle(""); // todo } } else { locDetl = new LocDetl( wrkMast.getLocNo(), // 库位号 wrkDetl.getMatnr(), // 物料号 null, // 仓库号 null, // 转储请求编号 null, // 行项目 null, // 物料标签ID wrkDetl.getMaktx(), // 物料描述 null, // 工厂 wrkDetl.getAnfme(), // 数量 wrkDetl.getAltme(), // 单位 wrkDetl.getZpallet(), // 托盘条码 null, // 用户ID null, // 备注 null, // 修改人员 now, // 修改时间 null, // 创建者 now // 添加时间 ); if (!locDetlService.insert(locDetl)) { exceptionHandle(""); // todo } } // todo:luxiaotao 3)修改出库通知档 status ==> Y } // 修改库位状态 Q ====>> F if (locMast.getLocType().equals("Q")) { locMast.setLocType("F"); locMast.setBarcode(wrkMast.getBarcode()); locMast.setIoTime(now); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } } break; case 57: break; case 11: break; default: break; } } private void doOut(WrkMast wrkMast){ } public static void main(String[] args) { for (int i = 0;i<10;i++) { try { System.out.println("====" + i); if (i == 5){ throw new Exception("dsa"); } System.out.println("----" + i); } catch (Exception e) { e.printStackTrace(); } } } }