| | |
| | | if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(2, rgvCommand))) { |
| | | // |
| | | log.error("RGV命令下发失败,RGV号={},任务数据={}", rgvId, JSON.toJSON(rgvCommand)); |
| | | wrkMast.setLogErrTime(new Date()); |
| | | wrkMast.setLogErrMemo("RGV命令下发失败,RGV号={"+rgvId+"}===>跳过"); |
| | | wrkMastService.updateById(wrkMast); |
| | | break runRgv; |
| | | } |
| | | log.info("RGV命令下发成功,RGV号={},任务数据={}", rgvId, JSON.toJSON(rgvCommand)); |
| | |
| | | && rgvProtocol.getTaskNo1() == 0 |
| | | && rgvProtocol.getAlarm() == 0) { |
| | | if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(5,devperimeter))) { |
| | | log.error("RGV漫游启动命令下发失败,RGV号={},任务数据={}", rgvNo, "漫游指令"); |
| | | log.error("RGV漫游启动命令下发失败,RGV号={},任务数据={}", rgvNo, "漫游指令,目的地:"+devperimeter); |
| | | break; |
| | | } else { |
| | | log.info("RGV漫游启动命令下发成功,RGV号={},任务数据={}", rgvNo, "漫游指令,目的地:"+devperimeter); |
| | | } |
| | | } |
| | | } |