| | |
| | | @Value("${ctu.station}") |
| | | private String station; |
| | | |
| | | @Value("${ctu.getLoc}") |
| | | private String getLoc; |
| | | |
| | | @Value("${ctu.update}") |
| | | private String updateSta; |
| | | |
| | | @Autowired |
| | | private SlaveProperties slaveProperties; |
| | |
| | | staProtocol.setWorkNo(0); |
| | | staProtocol.setStaNo((short) 0); |
| | | boolean result = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
| | | log.info("取走写入确认位:{},{}", staProtocol.getWorkNo(), 1006); |
| | | log.info("1007站点清空:{},{}", staProtocol.getWorkNo(), 1006); |
| | | StaProtocol staProtocol1006 = devpThread.getStation().get(1006); |
| | | staProtocol1006.setWorkNo(workNo); |
| | | staProtocol1006.setStaNo((short) 1007); |
| | | boolean result2 = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
| | | log.info("取走写入确认位:{},{}", staProtocol.getWorkNo(), 1007); |
| | | log.info("1006站点往前走一格:{},{}", staProtocol.getWorkNo(), 1007); |
| | | } |
| | | } |
| | | |