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: // 根据工作号，查询工作明细档 List wrkDetls57 = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); if (wrkDetls57.isEmpty()) { 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 11: // 默认目标库位是空板 String locType = "D"; // 库位移转判断是否为空板移转 if (wrkMast.getEmptyMk().equals("N")) { locType = "F"; // 转移库存明细数据: 库存号 由工作档源库位变为目标库位 if (!locDetlService.updateLocNo(wrkMast.getLocNo(), wrkMast.getSourceLocNo())) { exceptionHandle(""); // todo } } // todo:luxiaotao 3)修改盘点通知档 status ==> Y // 修改源库位状态 ==> O LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo()); if (null != sourceLoc) { sourceLoc.setBarcode(""); sourceLoc.setLocType("O"); sourceLoc.setModiTime(now); sourceLoc.setIoTime(now); if (!locMastService.updateById(sourceLoc)) { exceptionHandle(""); // todo } } // 修改目标库位状态 ==> .locType locMast.setLocType(locType); locMast.setBarcode(wrkMast.getBarcode()); locMast.setIoTime(now); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } break; default: break; } // 修改工作主档状态 wrkMast.setWrkSts(5L); wrkMast.setModiTime(now); if (!wrkMastService.updateById(wrkMast)) { exceptionHandle(""); // todo } } private void doOut(WrkMast wrkMast){ Date now = new Date(); LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo()); if (null == locMast) { exceptionHandle(""); // todo return; } switch (wrkMast.getIoType()) { // 全板出库 case 101: // 根据工作号，查询工作明细档 List wrkDetls101 = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); if (wrkDetls101.isEmpty()) { exceptionHandle(""); // todo } for (WrkDetl wrkDetl : wrkDetls101) { // todo:luxiaotao 3)修改出库通知档 status ==> Y } // 删除工作档源库位的库存明细 if (!locDetlService.delete(new EntityWrapper().eq("loc_no", wrkMast.getSourceLocNo()))) { exceptionHandle(""); // todo } // 修改库位状态 R ===>> O if (locMast.getLocType().equals("R")) { locMast.setLocType("O"); locMast.setBarcode(""); locMast.setModiTime(now); locMast.setIoTime(now); if (!locMastService.updateById(locMast)) { exceptionHandle(""); // todo } } break; // 空板出库 case 110: break; default: break; } } 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(); } } } }