| | |
| | | continue; |
| | | } |
| | | WrkMast onlyWrkNo = wrkMastMapper.selectByOnlyWrkNo(crnProtocol.getTaskNo().intValue()); |
| | | if (Cools.isEmpty(onlyWrkNo)){ |
| | | if (Cools.isEmpty(onlyWrkNo) || |
| | | (onlyWrkNo.getStaNo()!=114 && onlyWrkNo.getStaNo()!=214 && |
| | | onlyWrkNo.getSourceStaNo()!=114 && onlyWrkNo.getSourceStaNo()!=214)){ |
| | | continue; |
| | | } |
| | | // 判断堆垛机状态等待确认 |
| | |
| | | && crnProtocol.getBay().equals(crnStn.getBay().shortValue()) && crnProtocol.getLevel().equals(crnStn.getLev().shortValue())) { |
| | | News.info("堆垛机接驳任务完成,工作号:"+crnProtocol.getTaskNo()+";执行堆垛机号:"+crnSlave.getId()+";接驳放货位:"+crnStn.getStaNo()+";接驳行走目标站:"+Utils.getStaNoConvertCentreOther2(crnStn.getStaNo())); |
| | | // 下发站点信息 |
| | | News.error("new867===>"+crnProtocol.getTaskNo()); |
| | | News.error("new867===>"+Utils.getStaNoConvertCentreOther2(crnStn.getStaNo()).toString()); |
| | | staProtocol.setWorkNo(crnProtocol.getTaskNo()); |
| | | staProtocol.setStaNo(Utils.getStaNoConvertCentreOther2(crnStn.getStaNo()).shortValue()); |
| | | if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) { |
| | |
| | | } |
| | | } |
| | | } catch (Exception e){ |
| | | News.info("堆垛机接驳任务完成,一场:"+e.getMessage()); |
| | | News.info("堆垛机接驳任务完成,异常:"+e.getMessage()); |
| | | } |
| | | continue; |
| | | } |
| | |
| | | |
| | | // 下发站点信息 |
| | | staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue()); |
| | | News.error("new902===>"+crnProtocol.getCrnNo().toString()); |
| | | News.error("new902===>"+wrkMast.getStaNoConvert(crnProtocol.getCrnNo()).toString()); |
| | | staProtocol.setStaNo(wrkMast.getStaNoConvert(crnProtocol.getCrnNo()).shortValue()); |
| | | if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) { |
| | | continue; |
| | |
| | | } |
| | | continue; |
| | | } catch (Exception e){ |
| | | News.info("堆垛机接驳任务执行,一场:"+e.getMessage()); |
| | | News.info("堆垛机接驳任务执行,异常:"+e.getMessage()); |
| | | } |
| | | continue; |
| | | } |