| | |
| | | state.rtuTotal = this.taskVo.rtuAddrList.size() ; |
| | | if(this.upgradeRtus != null && this.upgradeRtus.size() > 0){ |
| | | AtomicBoolean hasRunning = new AtomicBoolean(false); |
| | | this.upgradeRtus.values().stream().forEach(info ->{ |
| | | this.upgradeRtus.values().forEach(info ->{ |
| | | if(info.state == UpgradeRtu.STATE_OFFLINE){ |
| | | state.offLineTotal ++ ; |
| | | state.failTotal++; |
| | | }else if(info.state == UpgradeRtu.STATE_UNSTART){ |
| | | state.unStartTotal ++ ; |
| | | }else if(info.state == UpgradeRtu.STATE_RUNNING){ |
| | | state.runningTotal ++ ; |
| | | }else if(info.state == UpgradeRtu.STATE_SUCCESS) { |
| | | state.successTotal++; |
| | | }else if(info.state == UpgradeRtu.STATE_FAIL) { |
| | | state.failTotal++; |
| | | }else if(info.state == UpgradeRtu.STATE_FAILONE) { |
| | | state.failOneTotal++; |
| | | state.failTotal++; |
| | | }else if(info.state == UpgradeRtu.STATE_FAIL) { |
| | | state.failMultiTotal++; |
| | | state.failTotal++; |
| | | }else if(info.state == UpgradeRtu.STATE_FAILOFFLINE) { |
| | | state.failTotal++; |
| | | state.failOffTotal++; |