New file |
| | |
| | | package com.dy.common.softUpgrade.state; |
| | | |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | import java.util.concurrent.atomic.AtomicBoolean; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2024/11/11 17:32 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | public class UpgradeInfo { |
| | | //升级任务ID |
| | | public String ugTaskId; |
| | | //升级任务总体状态 |
| | | public UpgradeState ugOverallState; |
| | | //升级任务RTU状态列表 |
| | | public List<UpgradeRtu> ugRtuStateList; |
| | | public String toString(){ |
| | | return this.toString(null) ; |
| | | } |
| | | |
| | | public String toString(String logRtuAddr){ |
| | | StringBuilder sb = new StringBuilder() ; |
| | | sb.append("RTU远程升级状态:") ; |
| | | sb.append(" \n任务id:" + ugTaskId) ; |
| | | sb.append(" \n" + ugOverallState.toString()) ; |
| | | if(ugRtuStateList != null && ugRtuStateList.size() > 0){ |
| | | sb.append(" \n升级的控制器总数:" + ugRtuStateList.size()) ; |
| | | sb.append(" \n其中一个控制器升级情况:") ; |
| | | AtomicBoolean exist = new AtomicBoolean(false); |
| | | if(logRtuAddr != null){ |
| | | ugRtuStateList.stream().filter(ur -> ur.getRtuAddr().equals(logRtuAddr)).forEach(ur -> { |
| | | sb.append(" \n" + ur.toString()) ; |
| | | exist.set(true); |
| | | }) ; |
| | | } |
| | | if(!exist.get()){ |
| | | sb.append(" \n" + ugRtuStateList.get(0).toString()) ; |
| | | } |
| | | } |
| | | return sb.toString() ; |
| | | } |
| | | } |