|  |  |  | 
|---|
|  |  |  | if (!shuttleProtocol.isIdle()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断小车令牌是否未被占领 | 
|---|
|  |  |  | if (shuttleProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//小车已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //判断小车是否到达输送站点库位 | 
|---|
|  |  |  | if (!shuttleProtocol.getCurrentLocNo().equals(basDevp.getLocNo())) { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(5L);//4.提升机搬运完成 => 5.小车搬运中 | 
|---|
|  |  |  | wrkMast.setModiTime(new Date()); | 
|---|
|  |  |  | shuttleProtocol.setToken(wrkMast.getWrkNo());//独占小车令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Shuttle, assignCommand.getShuttleNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | if (!shuttleProtocol.isIdle()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断小车令牌是否未被占领 | 
|---|
|  |  |  | if (shuttleProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//小车已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //获取目标站对应的输送站点 | 
|---|
|  |  |  | BasDevp targetBasDevp = basDevpService.selectByLevAndLiftNo(Utils.getLev(wrkMast.getSourceLocNo()), wrkMast.getLiftNo()); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(22L);//21.生成出库任务 => 22.小车搬运中 | 
|---|
|  |  |  | wrkMast.setModiTime(new Date()); | 
|---|
|  |  |  | shuttleProtocol.setToken(wrkMast.getWrkNo());//独占小车令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Shuttle, assignCommand.getShuttleNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | switch (wrkMast.getWrkSts().intValue()) { | 
|---|
|  |  |  | case 5://5.小车搬运中 ==> 9.入库完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(9L); | 
|---|
|  |  |  | //任务号清零 | 
|---|
|  |  |  | shuttleProtocol.setTaskNo(0); | 
|---|
|  |  |  | if (shuttleProtocol.getToken() == wrkMast.getWrkNo()) { | 
|---|
|  |  |  | //释放小车令牌 | 
|---|
|  |  |  | shuttleProtocol.setToken(0); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 22://22.小车搬运中 ==> 23.小车搬运完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(23L); | 
|---|
|  |  |  | if (shuttleProtocol.getToken() == wrkMast.getWrkNo()) { | 
|---|
|  |  |  | //释放小车令牌 | 
|---|
|  |  |  | shuttleProtocol.setToken(0); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 102://102.小车到提升机中 ==> 103.小车到提升机完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(103L); | 
|---|
|  |  |  | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 108://108.小车移动中 ==> 109.小车移动完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(109L); | 
|---|
|  |  |  | if (shuttleProtocol.getToken() == wrkMast.getWrkNo()) { | 
|---|
|  |  |  | //释放小车令牌 | 
|---|
|  |  |  | shuttleProtocol.setToken(0); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | default: | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if (!liftProtocol.isIdle(wrkMast.getWrkNo().shortValue())) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断提升机令牌是否未被占领 | 
|---|
|  |  |  | if (liftProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//提升机已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断提升机是否有其他任务 | 
|---|
|  |  |  | WrkMast liftWrkMast = wrkMastMapper.selectLiftWrkMast(liftThread.getSlave().getId()); | 
|---|
|  |  |  | if (liftWrkMast != null) { | 
|---|
|  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(3L);//2.设备上走 ==> 3.提升机搬运中 | 
|---|
|  |  |  | wrkMast.setLiftNo(liftThread.getSlave().getId());//任务档绑定提升机号 | 
|---|
|  |  |  | wrkMast.setModiTime(now); | 
|---|
|  |  |  | liftProtocol.setToken(wrkMast.getWrkNo());//独占提升机令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Lift, liftProtocol.getLiftNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | if (!liftProtocol.isIdle(wrkMast.getWrkNo().shortValue())) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断提升机令牌是否未被占领 | 
|---|
|  |  |  | if (liftProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//提升机已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断提升机是否有其他任务 | 
|---|
|  |  |  | WrkMast liftWrkMast = wrkMastMapper.selectLiftWrkMast(liftThread.getSlave().getId()); | 
|---|
|  |  |  | if (liftWrkMast != null) { | 
|---|
|  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(24L);//23.小车搬运完成 ==> 24.提升机搬运中 | 
|---|
|  |  |  | wrkMast.setLiftNo(liftThread.getSlave().getId());//任务档绑定提升机号 | 
|---|
|  |  |  | wrkMast.setModiTime(now); | 
|---|
|  |  |  | liftProtocol.setToken(wrkMast.getWrkNo());//独占提升机令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Lift, liftProtocol.getLiftNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | case 3://3.提升机搬运中 ==> 4.提升机搬运完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(4L); | 
|---|
|  |  |  | wrkMast.setLiftNo(null);//释放提升机 | 
|---|
|  |  |  | if (liftProtocol.getToken() == wrkMast.getWrkNo()) { | 
|---|
|  |  |  | //释放提升机令牌 | 
|---|
|  |  |  | liftProtocol.setToken(0); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 24://24.提升机搬运中 ==> 25.提升机搬运完成 | 
|---|
|  |  |  | wrkMast.setWrkSts(25L); | 
|---|
|  |  |  | if (wrkMast.getIoType() == 11) {//库位移转 | 
|---|
|  |  |  | wrkMast.setWrkSts(4L);//4.提升机搬运完成 | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (liftProtocol.getToken() == wrkMast.getWrkNo()) { | 
|---|
|  |  |  | //释放提升机令牌 | 
|---|
|  |  |  | liftProtocol.setToken(0); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 104://104.提升机搬运中 ==> 105.提升机搬运完成 | 
|---|
|  |  |  | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //判断小车令牌是否未被占领 | 
|---|
|  |  |  | if (shuttleProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//小车已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (Utils.getLev(wrkMast.getLocNo()) == shuttleProtocol.getPoint().getZ()) { | 
|---|
|  |  |  | //目标库位和小车库位处于同一楼层,需要通过提升机调度 | 
|---|
|  |  |  | return true;//直接进入108.小车移动中 | 
|---|
|  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(102L);//小车移动到提升机中  101.生成小车移库任务 ==> 102.小车到提升机中 | 
|---|
|  |  |  | wrkMast.setLiftNo(basLift.getLiftNo());//提升机号(锁定提升机防止被其他任务抢占) | 
|---|
|  |  |  | wrkMast.setModiTime(now); | 
|---|
|  |  |  | shuttleProtocol.setToken(wrkMast.getWrkNo());//独占该小车令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Shuttle, assignCommand.getShuttleNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!liftProtocol.isIdle(wrkMast.getWrkNo().shortValue())) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断提升机令牌是否未被占领 | 
|---|
|  |  |  | if (liftProtocol.getToken() != 0) { | 
|---|
|  |  |  | return false;//提升机已被独占,禁止再派发任务 | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //获取四向穿梭车线程 | 
|---|
|  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(104L);//提升机搬运中  103.小车到提升机完成 ==> 104.提升机搬运中 | 
|---|
|  |  |  | wrkMast.setLiftNo(liftThread.getSlave().getId());//锁定提升机防止被占用 | 
|---|
|  |  |  | wrkMast.setModiTime(now); | 
|---|
|  |  |  | liftProtocol.setToken(wrkMast.getWrkNo());//独占提升机令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Lift, liftProtocol.getLiftNo().intValue(), new Task(3, assignCommand)); | 
|---|
|  |  |  | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //判断提升机令牌是否为当前任务 | 
|---|
|  |  |  | if (liftProtocol.getToken() != wrkMast.getWrkNo()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //获取四向穿梭车线程 | 
|---|
|  |  |  | NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, wrkMast.getShuttleNo()); | 
|---|
|  |  |  | if (shuttleThread == null) { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //小车处于空闲状态 | 
|---|
|  |  |  | if (!shuttleProtocol.isIdleNoCharge()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //判断小车令牌是否为当前任务 | 
|---|
|  |  |  | if (shuttleProtocol.getToken() != wrkMast.getWrkNo()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | //小车移动到目标库位中  107.小车迁出提升机完成 ==> 108.小车移动中 | 
|---|
|  |  |  | if (wrkMast.getWrkSts() == 107) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | LiftThread liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, wrkMast.getLiftNo()); | 
|---|
|  |  |  | if (liftThread == null) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | LiftProtocol liftProtocol = liftThread.getLiftProtocol(); | 
|---|
|  |  |  | if (liftProtocol == null) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //获取四向穿梭车线程 | 
|---|
|  |  |  | NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, wrkMast.getShuttleNo()); | 
|---|
|  |  |  | if (shuttleThread == null) { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //小车处于空闲状态 | 
|---|
|  |  |  | if (!shuttleProtocol.isIdleNoCharge()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //判断小车令牌是否为当前任务 | 
|---|
|  |  |  | if (shuttleProtocol.getToken() != wrkMast.getWrkNo()) { | 
|---|
|  |  |  | return false; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | wrkMast.setWrkSts(108L);//小车移动到目标库位中  107.小车迁出提升机完成 ==> 108.小车移动中 | 
|---|
|  |  |  | wrkMast.setLiftNo(null);//释放提升机 | 
|---|
|  |  |  | wrkMast.setModiTime(now); | 
|---|
|  |  |  | liftProtocol.setToken(0);//释放提升机令牌 | 
|---|
|  |  |  | if (wrkMastMapper.updateById(wrkMast) > 0) { | 
|---|
|  |  |  | //下发任务 | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Shuttle, assignCommand.getShuttleNo().intValue(), new Task(3, assignCommand)); | 
|---|