| | |
| | | add(3); |
| | | add(4); |
| | | }}); |
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 2); |
| | | |
| | | Integer count = basJarMastList.size(); |
| | | ArrayList<Integer> wrkNoList = new ArrayList<>(); |
| | | |
| | | for (Integer staNoEnt : staNos){ |
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 2); |
| | | StaProtocol staProtocolEnt = devpThread.getStation().get(staNoEnt); |
| | | if (staProtocolEnt != null && staProtocolEnt.getWorkNo()!=0 && !wrkNoList.contains(staProtocolEnt.getWorkNo())){ |
| | | if (staProtocolEnt == null || (staProtocolEnt.isLoading() && staProtocolEnt.getWorkNo()==0)){ |
| | | log.error("站点异常,计数加一,站点号:"+staNoEnt); |
| | | count++; |
| | | } else if (staProtocolEnt != null && staProtocolEnt.getWorkNo()!=0 && !wrkNoList.contains(staProtocolEnt.getWorkNo())){ |
| | | if (staProtocolEnt.getStaNo().equals(basJar.getEntStaNo$())){ |
| | | count++; |
| | | wrkNoList.add(staProtocolEnt.getWorkNo()); |