| | |
|---|
| | | private void save2Db(String taskId, List<UpgradeRtu> newList, List<UpgradeRtu> oldList){ |
|---|
| | | List<UpgradeRtu> newOverList = newList.stream().filter(vo -> vo.isOver).collect(Collectors.toList()) ; |
|---|
| | | List<UpgradeRtu> oldNoOverList = newList.stream().filter(vo -> !vo.isOver).collect(Collectors.toList()) ; |
|---|
| | | boolean oldExist = false ; |
|---|
| | | for(UpgradeRtu nvo : newOverList){ |
|---|
| | | if(nvo != null) { |
|---|
| | | if(oldNoOverList.stream().anyMatch(vo -> vo.rtuAddr.equals(nvo.rtuAddr))){ |
|---|
| | | //上次没有升级结束，而当前升级结束了 |
|---|
| | | this.sv.saveRtuUpgradeState(Long.parseLong(taskId), nvo); |
|---|
| | | } |
|---|
| | | oldExist = false ; |
|---|
| | | if(oldNoOverList.stream().anyMatch(vo -> vo.rtuAddr.equals(nvo.rtuAddr))){ |
|---|
| | | oldExist = true ; |
|---|
| | | } |
|---|
| | | if(!oldExist){ |
|---|
| | | //上次没有升级结束，而当前升级结束了 |
|---|
| | | this.sv.saveRtuUpgradeState(Long.parseLong(taskId), nvo); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
