| | |
| | | && (staProtocol.getWorkNo() > 0) |
| | | && staProtocol.isPakMk()) { |
| | | |
| | | staProtocol.setStaNo((short) 341);//写入目标站 |
| | | staProtocol.setPakMk(false); |
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
| | | WrkMast wrkMast = wrkMastMapper.selectByWorkNo(staProtocol.getWorkNo().intValue()); |
| | | if (wrkMast == null) { |
| | | continue; |
| | | } |
| | | if (wrkMast.getSteNo() == null) { |
| | | wrkMast.setSteNo(1); |
| | | wrkMastMapper.updateById(wrkMast); |
| | | staProtocol.setStaNo((short) 341);//写入目标站 |
| | | staProtocol.setPakMk(false); |
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
| | | } |
| | | } |
| | | } |
| | | |