| 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() ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|