| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(cache == null){ |
|---|
| | | cache = info; |
|---|
| | | //此时不做任务操作，只保障cache不为空， 等待下次发来数据 |
|---|
| | | if(info.ugRtuStateList != null && info.ugRtuStateList.size() > 0){ |
|---|
| | | List<UpgradeRtu> overList = info.ugRtuStateList.stream().filter(itemVo -> itemVo.isOver).collect(Collectors.toList()) ; |
|---|
| | | if(overList != null && overList.size() > 0){ |
|---|
| | | cache = info; |
|---|
| | | this.save2Db(info.ugTaskId, overList); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | if(info.ugRtuStateList != null && info.ugRtuStateList.size() > 0){ |
|---|
| | | //此时保证两个集合都不为null |
|---|
| | | this.save2Db(info.ugTaskId, info.ugRtuStateList, cache.ugRtuStateList); |
|---|
| | | cache = info; |
|---|
| | | } |
|---|
| | | //cache赋值必须放在上面处理的后面，否则上面的比较不成功 |
|---|
| | | cache = info; |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | |
|---|
| | | }else if(rtu.state == UpgradeRtu.STATE_SUCCESS) { |
|---|
| | | cache.ugOverallState.successTotal++; |
|---|
| | | }else if(rtu.state == UpgradeRtu.STATE_FAILONE) { |
|---|
| | | cache.ugOverallState.failOneTotal++; |
|---|
| | | cache.ugOverallState.dieOneTotal++; |
|---|
| | | cache.ugOverallState.failTotal++; |
|---|
| | | }else if(rtu.state == UpgradeRtu.STATE_FAIL) { |
|---|
| | | cache.ugOverallState.failMultiTotal++; |
|---|
| | | cache.ugOverallState.dieMultiTotal++; |
|---|
| | | cache.ugOverallState.failTotal++; |
|---|
| | | } |
|---|
| | | if(rtu.isOver){ |
|---|
| | |
|---|
| | | cache.ugOverallState.allOver = true ; |
|---|
| | | } |
|---|
| | | if(cache.ugOverallState.allOver){ |
|---|
| | | cache.ugOverallState.overTotal = 0; |
|---|
| | | if(cache.ugRtuStateList != null && cache.ugRtuStateList.size() > 0){ |
|---|
| | | for(UpgradeRtu rtu : cache.ugRtuStateList){ |
|---|
| | | rtu.isOver = true ; |
|---|
| | | cache.ugOverallState.overTotal++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
