| | |
|---|
| | | if(this.taskVo.rtuAddrList != null && this.taskVo.rtuAddrList.size() > 0){ |
|---|
| | | state.rtuTotal = this.taskVo.rtuAddrList.size() ; |
|---|
| | | if(this.upgradeRtus != null && this.upgradeRtus.size() > 0){ |
|---|
| | | Collection<UpgradeRtu> col = this.upgradeRtus.values() ; |
|---|
| | | for(UpgradeRtu info : col){ |
|---|
| | | this.upgradeRtus.values().stream().forEach(info ->{ |
|---|
| | | if(info.state == UpgradeRtu.STATE_OFFLINE){ |
|---|
| | | state.offLineTotal ++ ; |
|---|
| | | }else if(info.state == UpgradeRtu.STATE_UNSTART){ |
|---|
| | |
|---|
| | | 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) { |
|---|
| | | }else if(info.state == UpgradeRtu.STATE_FAILOFFLINE) { |
|---|
| | | state.failTotal++; |
|---|
| | | state.failOffTotal++; |
|---|
| | | } |
|---|
| | | if(info.isOver){ |
|---|
| | | state.overTotal++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return state ; |
|---|
| | |
|---|
| | | * 判断是否没用任何一个RTU进行过升级，而且超过了时限 |
|---|
| | | * @return -1:无一RTU升级且超时，0：无RTU升级但未超时等待，1有RTU升级正常执行 |
|---|
| | | */ |
|---|
| | | protected int countNoOneRtuUpgrade(){ |
|---|
| | | protected int countNoOneRtuUpgradeInDuration(){ |
|---|
| | | if(this.upgradeRtus == null || upgradeRtus.size() == 0){ |
|---|
| | | //当前没有任何一个设备进行过升级 |
|---|
| | | Long now = System.currentTimeMillis() ; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 统计当前正在升级的RTU数量，为同时升级数量限制做准备 |
|---|
| | | */ |
|---|
| | | protected void statisticsRunningRtuCount(){ |
|---|
| | | protected void countRunningRtuCount(){ |
|---|
| | | int runningTotal = 0 ; |
|---|
| | | Collection<UpgradeRtu> col = this.upgradeRtus.values() ; |
|---|
| | | for(UpgradeRtu info : col){ |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 统计需要升级但当前离线RTU的情况 |
|---|
| | | * 统计需要升级但当前离线RTU的情况，超过时限的设备为升级完成 |
|---|
| | | */ |
|---|
| | | protected void statisticsOffRtuCountAndSet() { |
|---|
| | | protected void countOffRtuAndSetIfOver() { |
|---|
| | | Long now = System.currentTimeMillis() ; |
|---|
| | | if(now - this.setupDtLong > UpgradeUnit.confVo.rtuOffLineWaitDuration){ |
|---|
| | | //rtu离线，等待其升级的时长(毫秒)，超过配置的最大时长，设置其升级失败，且设置升级任务完成 |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 统计是否升级全部结束 |
|---|
| | | */ |
|---|
| | | protected boolean statisticsIsAllOver() { |
|---|
| | | protected boolean countIsAllOver() { |
|---|
| | | if (this.taskVo.rtuAddrList != null && this.taskVo.rtuAddrList.size() > 0) { |
|---|
| | | Collection<UpgradeRtu> col = this.upgradeRtus.values() ; |
|---|
| | | for(UpgradeRtu info : col){ |
|---|
