有wechat模块中增加查询水肥机、墒情站、气象站所有实体的功能

liurunyu

2025-08-13 e35849618cc8d0615c09335959b76d0cca667679

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/local/localProtocol/MwInfoVo.java

New file
@@ -0,0 +1,68 @@
package com.dy.rtuMw.server.local.localProtocol;

import com.dy.common.util.*;
import lombok.Data;

import java.util.LinkedList;

/**
 * @Author: liurunyu
 * @Date: 2024/7/29 10:54
 * @Description
 */
@Data
public class MwInfoVo {
    public Integer rtuTotalConnect ;//已经连接过中间件的RTU总数（包括在线与离线的）
    public Integer rtuTotalOnLine ;//在线RTU总数
    public Integer rtuTotalOffLine ;//离线RTU总数

    public Integer comTotalDown ;//缓存的下行命令总数
    public Integer comNoResTotalDownByOnLine;//RTU在线，但对其下行命令未收到应答的总数
    public Integer comNoResTotalDownByOffLine;//RTU离线，但对其下行命令未收到应答的总数

    public Integer dataTotalUp ;//上行数据在缓存中还未处理的总数

    public Integer shortCurThread = 0 ;//短线程池当前线程数
    public Integer shortMaxThread = 0 ;//短线程池最大线程数
    public Integer shortMinThread = 0 ;//短线程池最小线程数
    public Integer longCurThread = 0 ;//长线程池当前线程数
    public Integer longMaxThread = 0 ;//长线程池最大线程数
    public Integer longMinThread = 0 ;//长线程池最小线程数

    public Integer taskTreePoolTotalInstance = 0 ;//任务树池任务实例总数

    public SysJvmUtil.JvmInfoVo jvmInfoVo ;
    public SysMemoryUtil.MemInfoVo memInfoVo ;
    public SysSysUtil.SysInfoVo sysInfoVo ;

    public String toString(){
        StringBuilder sb = new StringBuilder() ;
        sb.append("通信中间件运行信息:\n");
        sb.append("   连接RTU总数：" + rtuTotalConnect + "\n");
        sb.append("      在线RTU总数：" + rtuTotalOnLine + "\n");
        sb.append("      离线RTU总数：" + rtuTotalOffLine + "\n");
        sb.append("   下行未应答命令总数：" + comTotalDown + "\n");
        sb.append("      在线RTU未应答命令总数：" + comNoResTotalDownByOnLine + "\n");
        sb.append("      离线RTU未应答命令总数：" + comNoResTotalDownByOffLine + "\n");
        sb.append("   上行未处理数据总数：" + dataTotalUp + "\n");
        sb.append("   短线程池当前线程数：" + shortCurThread + "\n");
        sb.append("      短线程池配置最大线程数：" + shortMaxThread + "\n");
        sb.append("      短线程池配置最小线程数：" + shortMinThread + "\n");
        sb.append("   长线程池当前线程数：" + longCurThread + "\n");
        sb.append("      长线程池配置最大线程数：" + longMaxThread + "\n");
        sb.append("      长线程池配置最小线程数：" + longMinThread + "\n");
        sb.append("   任务树池任务实例总数：" + taskTreePoolTotalInstance + "\n");
        if(jvmInfoVo != null){
            sb.append(jvmInfoVo.toString()) ;
        }
       if(memInfoVo != null){
            sb.append(memInfoVo.toString()) ;
        }
       if(sysInfoVo != null){
            sb.append(sysInfoVo.toString()) ;
        }
        sb.append("\n");

        return sb.toString() ;
    }
}