| | |
| | | continue; |
| | | } |
| | | // 只有当堆垛机空闲 并且 无任务时才继续执行 |
| | | if (crnProtocol.getStatusType() == CrnStatusType.IDLE && crnProtocol.getTaskNo() == 0 && crnProtocol.getModeType() == CrnModeType.AUTO) { |
| | | if (true || crnProtocol.getStatusType() == CrnStatusType.IDLE && crnProtocol.getTaskNo() == 0 && crnProtocol.getModeType() == CrnModeType.AUTO) { |
| | | // 如果最近一次是入库模式 |
| | | if (crnProtocol.getLastIo().equals("I")) { |
| | | if (basCrnp.getInEnable().equals("Y")) { |
| | |
| | | } |
| | | // 库位移转 |
| | | this.locToLoc1(crn, crnProtocol); |
| | | // 库位移转(高频移库,io_type=111) |
| | | this.locToLoc111(crn, crnProtocol); |
| | | // 库位移转,回原库位 |
| | | this.locToLoc17(crn, crnProtocol); |
| | | // 演示任务 |
| | |
| | | if(!Cools.isEmpty(one)){ |
| | | News.error("入库 ===>> 存在移库未完成任务,不能入库。移库任务号={},堆垛机号={}", one.getWrkNo(), slave.getId()); |
| | | // continue; |
| | | } |
| | | |
| | | //入库库位不是最外层库位,判断最外层库位是否为空库位,如不是则进行移库任务 |
| | | if(!locMastService.isOutMost(wrkMast.getLocNo())) { |
| | | WrkMast wrkMastMove = wrkMastMapper.selectLocMoveWorking(slave.getId()); |
| | | if (wrkMastMove != null && wrkMast.getWrkNo() == 111) { |
| | | continue; |
| | | } |
| | | |
| | | WrkMast two = wrkMastMapper.selectWorking1(slave.getId(), wrkMast.getWrkNo()); |
| | | if (two != null) {//2号机有在执行任务时,禁止生成移库工作档 |
| | | continue; |
| | | } else { |
| | | List<String> shallowLocs = Utils.getShallowLocs(wrkMast.getLocNo()); |
| | | if (!Cools.isEmpty(shallowLocs)) { |
| | | for (String shallowLocNo : shallowLocs) { |
| | | LocMast shallowLoc = locMastService.selectById(shallowLocNo); |
| | | WrkMast waitWrkMast = wrkMastMapper.selectByLocNo(shallowLocNo); |
| | | if (shallowLoc.getLocSts().equals("F") || shallowLoc.getLocSts().equals("D")) { |
| | | if (null == waitWrkMast) { |
| | | // 生成一笔移库任务工作档、改变浅库位的源库/目标库 库位状态 |
| | | // 没有作业中的入库任务时,才能生成移库任务 |
| | | WrkMast one2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("crn_no", slave.getId()) |
| | | .last(" and wrk_sts in (3,4,5,6,7,8)")); |
| | | if (one2 == null) { |
| | | moveLocForDeepLoc(slave, shallowLoc); |
| | | // 置顶任务 |
| | | wrkMast.setIoPri((double) 9999); |
| | | wrkMastMapper.updateById(wrkMast); |
| | | } else { |
| | | News.error("浅库位阻塞时,且浅库位存在作业中出库任务!工作号={}", one2.getWrkNo()); |
| | | } |
| | | flag = true; |
| | | break; |
| | | } else { |
| | | if (waitWrkMast.getWrkSts() != 18) { |
| | | News.error("库位出库到堆垛机站 ===>> 库位状态在库,但是浅库位已存在工作档任务!出库库位={},浅库位号={}", shallowLoc.getLocNo()); |
| | | flag = true; |
| | | break; |
| | | } |
| | | |
| | | } |
| | | } else if (shallowLoc.getLocSts().equals("Q") || shallowLoc.getLocSts().equals("S")) { |
| | | News.error("库位出库到堆垛机站 ===>> 浅库位库位状态为入库预约!出库库位={},浅库位号={}", shallowLoc.getLocNo()); |
| | | flag = true; |
| | | break; |
| | | } |
| | | |
| | | //20230307 ADD,再加一次判断,当浅库位状态不为O时,不执行当前出库任务 |
| | | if (shallowLoc != null && !shallowLoc.getLocSts().equals("O")) { |
| | | News.error("做了浅库位阻塞处理后反复判断,浅库位状态不为O ===>> 浅库位库位状态为入库预约!出库库位={},浅库位号={}", wrkMast.getSourceLocNo(), shallowLoc.getLocNo()); |
| | | flag = true; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | if(flag){ |
| | | return false; |
| | | } |
| | | |
| | | // 判断是否已存在小车绑定任务 |
| | |
| | | } |
| | | } |
| | | |
| | | //出库库位不是最外层库位,判断浅库位组是否都为空,或存在库位移转任务 |
| | | //出库库位不是最外层库位,判断最外层库位是否为空库位,如不是则进行移库任务 |
| | | boolean flag = false; |
| | | if(!locMastService.isOutMost(wrkMast.getSourceLocNo())) { |
| | | WrkMast wrkMastMove = wrkMastMapper.selectLocMoveWorking(slave.getId()); |
| | | if (wrkMastMove != null && wrkMast.getWrkNo() == 11) { |
| | | if (wrkMastMove != null && wrkMast.getWrkNo() == 111) { |
| | | continue; |
| | | } |
| | | |
| | |
| | | if (two != null) {//2号机有在执行任务时,禁止生成移库工作档 |
| | | continue; |
| | | } else { |
| | | String[] shallowlocs = Utils.getShallowLocs(wrkMast.getSourceLocNo()); |
| | | if (!Cools.isEmpty(shallowlocs)) { |
| | | for (String shallowLocNo : shallowlocs) { |
| | | List<String> shallowLocs = Utils.getShallowLocs(wrkMast.getSourceLocNo()); |
| | | if (!Cools.isEmpty(shallowLocs)) { |
| | | for (String shallowLocNo : shallowLocs) { |
| | | LocMast shallowLoc = locMastService.selectById(shallowLocNo); |
| | | WrkMast waitWrkMast = wrkMastMapper.selectByLocNo(shallowLocNo); |
| | | if (shallowLoc.getLocSts().equals("P") || shallowLoc.getLocSts().equals("R")) { |
| | | if (null == waitWrkMast) { |
| | | News.error("{}库位异常,未检索到相应工作档!", shallowLocNo); |
| | | } else { |
| | | //iotype=11,wrksts=17,说明货物已经移库到暂存库位,等待回原库位,此时允许继续出库 |
| | | if (waitWrkMast.getIoType() != 11 || waitWrkMast.getWrkSts() != 17) { |
| | | waitWrkMast.setIoPri((double) 9999); |
| | | waitWrkMast.setModiTime(new Date()); |
| | | if (wrkMastMapper.updateById(waitWrkMast) == 0) { |
| | | News.error("调整工作档优先级失败!工作号={}", waitWrkMast.getWrkNo()); |
| | | } |
| | | if (waitWrkMast.getWrkSts() != 17) { |
| | | flag = true; |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | } else if (shallowLoc.getLocSts().equals("F") || shallowLoc.getLocSts().equals("D")) { |
| | | if (shallowLoc.getLocSts().equals("F") || shallowLoc.getLocSts().equals("D")) { |
| | | if (null == waitWrkMast) { |
| | | // 生成一笔移库任务工作档、改变浅库位的源库/目标库 库位状态 |
| | | // 没有作业中的出库任务时,才能生成移库任务 |
| | |
| | | if (wrkMast.getWrkSts() == 12L) { |
| | | this.carMoveIn(wrkMast, wrkMast.getSteNo(), crnProtocol); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 库位移转(高频移库,io_type=111) |
| | | */ |
| | | public synchronized void locToLoc111(CrnSlave slave, CrnProtocol crnProtocol){ |
| | | // 获取工作档信息 |
| | | WrkMast wrkMast = wrkMastMapper.selectLocMove111(slave.getId()); |
| | | if (null == wrkMast) { |
| | | return; |
| | | } |
| | | // 过滤 |
| | | if (null != wrkMastMapper.selectPakin(slave.getId(), null)) { |
| | | News.error("{}出库任务无法作业,因存在入库中任务!", wrkMast.getWrkNo()); |
| | | return; |
| | | } |
| | | |
| | | // 判断是否已存在小车绑定任务 |
| | | BasSte basSte = basSteService.findByCrnNo(wrkMast.getCrnNo()); |
| | | if(basSte == null) return; |
| | | WrkMast one = wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("ste_no",basSte.getSteNo()) |
| | | .last(" and io_type != 111 and wrk_sts < 10")); |
| | | if(one != null){ |
| | | News.error("{}移库任务无法作业,因入库任务已绑定小车!", wrkMast.getWrkNo()); |
| | | return; |
| | | } |
| | | |
| | | // 获取源库位信息 |
| | | LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo()); |
| | | if (null == sourceLoc) { |
| | | News.error("工作档库位移转失败,原因:检索源库位失败!工作号={},源库位={}", wrkMast.getWrkNo(), wrkMast.getSourceLocNo()); |
| | | return; |
| | | } |
| | | // 源库位 库位状态判断 |
| | | if (!sourceLoc.getLocSts().equals("R")) { |
| | | return; |
| | | } |
| | | // 获取目标库位信息 |
| | | LocMast loc = locMastService.selectById(wrkMast.getLocNo()); |
| | | if (null == loc || !loc.getLocSts().equals("S")) { |
| | | News.error("工作档库位移转失败,原因:检索目标库位失败!工作号={},源库位={}", wrkMast.getWrkNo(), wrkMast.getLocNo()); |
| | | return; |
| | | } |
| | | // 获取堆垛机信息 并 判断是否可入出 |
| | | BasCrnp basCrnp = basCrnpService.selectById(slave.getId()); |
| | | if (!basCrnp.getInEnable().equals("Y") && !basCrnp.getOutEnable().equals("Y")) { |
| | | return; |
| | | } |
| | | |
| | | // // 堆垛机控制过滤 |
| | | // if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { |
| | | // return; |
| | | // } |
| | | |
| | | // 已经存在吊车执行任务时,则过滤 |
| | | if (wrkMastMapper.selectWorking(slave.getId()) != null) { |
| | | return; |
| | | } |
| | | |
| | | // 置顶任务 |
| | | wrkMast.setIoPri((double) 9999); |
| | | wrkMastMapper.updateById(wrkMast); |
| | | |
| | | // 源库位 ===>> 最外层库位 |
| | | if (locMastService.isOutMost(wrkMast.getSourceLocNo())) { |
| | | // 目标库位 ===>> 最外层库位 |
| | | if (locMastService.isOutMost(wrkMast.getLocNo())) { |
| | | // 命令下发区 -------------------------------------------------------------------------- |
| | | CrnCommand crnCommand = new CrnCommand(); |
| | | crnCommand.setCrnNo(slave.getId()); // 堆垛机编号 |
| | | crnCommand.setTaskNo(wrkMast.getWrkNo().shortValue()); // 工作号 |
| | | crnCommand.setAckFinish((short) 0); // 任务完成确认位 |
| | | crnCommand.setCommand((short) 0); |
| | | crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 任务模式: 库位移转 |
| | | crnCommand.setSourcePosX(sourceLoc.getRow1().shortValue()); // 源库位排 |
| | | crnCommand.setSourcePosY(sourceLoc.getBay1().shortValue()); // 源库位列 |
| | | crnCommand.setSourcePosZ(sourceLoc.getLev1().shortValue()); // 源库位层 |
| | | crnCommand.setDestinationPosX(loc.getRow1().shortValue()); // 目标库位排 |
| | | crnCommand.setDestinationPosY(loc.getBay1().shortValue()); // 目标库位列 |
| | | crnCommand.setDestinationPosZ(loc.getLev1().shortValue()); // 目标库位层 |
| | | if (!MessageQueue.offer(SlaveType.Crn, wrkMast.getCrnNo(), new Task(2, crnCommand))) { |
| | | News.error("堆垛机命令下发失败,堆垛机号={},任务数据={}", wrkMast.getCrnNo(), JSON.toJSON(crnCommand)); |
| | | } else { |
| | | // 修改工作档状态 11.生成出库ID => 7.吊车入库中 |
| | | Date now = new Date(); |
| | | wrkMast.setWrkSts(7L); |
| | | wrkMast.setCrnStrTime(now); |
| | | wrkMast.setModiTime(now); |
| | | if (wrkMastMapper.updateById(wrkMast) == 0) { |
| | | News.error("【库位移转】 修改工作档状态 11.生成出库ID => 7.吊车入库中 失败!!,工作号={}", wrkMast.getWrkNo()); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | } |
| | | if (wrkMast == null) { continue; } |
| | | if (wrkMast.getIoType() != 11) { |
| | | if (wrkMast.getIoType() != 11 && wrkMast.getIoType() != 111) { |
| | | // 入库 ==>> 货物搬入库 |
| | | if (wrkMast.getWrkSts() == 7){ |
| | | // 判断是否需要小车入库 |
| | |
| | | } |
| | | // 移库 ===>> 堆垛机搬至目标库位组 完成 |
| | | } |
| | | // 库位移转(高频io_type111) |
| | | } else if(wrkMast.getIoType() == 111) { |
| | | Date now = new Date(); |
| | | // 入库 ==>> 货物搬入库 |
| | | if (wrkMast.getWrkSts() == 7){ |
| | | if (locMastService.isOutMost(wrkMast.getLocNo()) && locMastService.isOutMost(wrkMast.getSourceLocNo())) { |
| | | // ==> 9.入库完成 |
| | | wrkMast.setWrkSts(9L); |
| | | wrkMast.setCrnEndTime(now); |
| | | wrkMast.setModiTime(now); |
| | | // 修改成功后复位堆垛机 |
| | | if (wrkMastMapper.updateById(wrkMast) > 0) { |
| | | |
| | | // if (!locDetlService.updateLocNo(wrkMast.getLocNo(), wrkMast.getSourceLocNo())) { |
| | | // News.error("库位移转 ===>> 转移库存明细数据失败;[源库位={}],[目标库位={}]", wrkMast.getSourceLocNo(), wrkMast.getLocNo()); |
| | | // continue; |
| | | // } |
| | | |
| | | // // 修改源库位状态 ==> O |
| | | // LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo()); |
| | | // if (null != sourceLoc) { |
| | | // sourceLoc.setLocSts("O"); |
| | | // sourceLoc.setModiTime(now); |
| | | // if (!locMastService.updateById(sourceLoc)) { |
| | | // News.error("库位移转 ===>> 修改源库位状态失败;[workNo={}],[sourceLoc={}]", wrkMast.getWrkNo(), wrkMast.getSourceLocNo()); |
| | | // } |
| | | // } |
| | | // // 修改目标库位状态 ==> F |
| | | // LocMast locMast = locMastService.selectById(wrkMast.getLocNo()); |
| | | // if (locMast != null) { |
| | | // locMast.setLocSts("F"); |
| | | // locMast.setModiTime(now); |
| | | // if (!locMastService.updateById(locMast)) { |
| | | // News.error("库位移转 ===>> 修改目标库位状态失败;[workNo={}],[locNo={}]", wrkMast.getWrkNo(), wrkMast.getLocNo()); |
| | | // } |
| | | // } |
| | | |
| | | // 堆垛机复位 |
| | | crnThread.setResetFlag(true); |
| | | } else { |
| | | News.error("修改工作档状态 7.吊车入库中 => 9.入库完成 失败!!,工作号={}", wrkMast.getWrkNo()); |
| | | } |
| | | } |
| | | } |
| | | // 库位移转 |
| | | } else { |
| | | }else { |
| | | // 入库 ==>> 货物搬入库 |
| | | if (wrkMast.getWrkSts() == 7){ |
| | | // 判断是否需要小车入库 |
| | |
| | | LocMast loc = null; |
| | | List<LocMast> locs = locMastService.selectList(new EntityWrapper<LocMast>().eq("crn_no",crn.getId()) |
| | | .eq("loc_type1",shallowLoc.getLocType1()) |
| | | .eq("loc_type2",shallowLoc.getLocType2()) |
| | | .eq("loc_sts","O") |
| | | .last(" and row1 in (" + rows + ") order by bay1,lev1")); |
| | | for (LocMast one : locs){ |
| | |
| | | || Utils.getBay(one.getLocNo()) != Utils.getBay(shallowLoc.getLocNo()) |
| | | || Utils.getLev(one.getLocNo()) != Utils.getLev(shallowLoc.getLocNo())){ |
| | | |
| | | boolean success = true; |
| | | List<String> insideLoc = Utils.getGroupInsideLoc(one.getLocNo()); |
| | | for (String inside : insideLoc) { |
| | | LocMast locMast = locMastService.selectById(inside); |
| | | if(Cools.isEmpty(locMast)){ |
| | | continue; |
| | | } |
| | | if (locMast.getLocSts().equals("P") |
| | | || locMastService.selectById(inside).getLocSts().equals("R") |
| | | || locMastService.selectById(inside).getLocSts().equals("S") |
| | | || locMastService.selectById(inside).getLocSts().equals("Q")) { |
| | | success = false; break; |
| | | } |
| | | } |
| | | |
| | | Integer steNo = this.hasCar(one.getLocNo()); |
| | | if (steNo != null) { |
| | | continue; |
| | | } |
| | | |
| | | if (success) { |
| | | loc = one; |
| | | break; |
| | | } |
| | | loc = one; |
| | | break; |
| | | } |
| | | } |
| | | |
| | |
| | | wrkMast.setWrkNo(workNo); |
| | | wrkMast.setIoTime(now); |
| | | wrkMast.setWrkSts(11L); // 工作状态:11.生成出库ID |
| | | wrkMast.setIoType(11); // 入出库状态: 11.库格移载 |
| | | wrkMast.setIoType(111); // 入出库状态: 111.库格移载(高频) |
| | | wrkMast.setIoPri((double) 9999); |
| | | wrkMast.setCrnNo(crn.getId()); |
| | | wrkMast.setSourceLocNo(shallowLoc.getLocNo()); // 源库位 |