| | |
|---|
| | | if (devpThread == null) continue; |
|---|
| | | |
|---|
| | | // 检查该PLC是否管理该站点 |
|---|
| | | if (devpThread.getStation().containsKey(sourceStaNo.shortValue())) { |
|---|
| | | StaProtocol staProtocol = devpThread.getStation().get(sourceStaNo.shortValue()); |
|---|
| | | if (staProtocol != null && staProtocol.getWorkNo() == 9998) { |
|---|
| | | if (devpThread.getStation().containsKey(sourceStaNo)) { |
|---|
| | | StaProtocol staProtocol = devpThread.getStation().get(sourceStaNo); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | continue; |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | if (staProtocol != null && staProtocol.getWorkNo() == 9999) { |
|---|
| | | |
|---|
| | | staProtocol.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | if (wrkMast.getStaNo() != null) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 下发PLC指令 |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false, 283); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false, 9999); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | |
|---|
| | | if (result) { |
|---|
