| | |
| | | } else { |
| | | staProtocol.setWorkNo((short) 9995); |
| | | if (inSta.getStaNo() != 402) { |
| | | staProtocol.setStaNo((short) (inSta.getStaNo() - 1)); |
| | | } else { |
| | | staProtocol.setStaNo((short) (inSta.getStaNo() + 1)); |
| | | } else { |
| | | staProtocol.setStaNo((short) (inSta.getStaNo() - 1)); |
| | | } |
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
| | |
| | | staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue()); |
| | | staProtocol.setStaNo(wrkMast.getStaNo().shortValue()); |
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
| | | log.warn("盘点再入库给输送线下发命令前:{}",JSON.toJSON(staProtocol)); |
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
| | | if (!result) { |
| | | log.error("发布命令至输送线队列失败!!! [plc编号:{}]", devp.getId()); |