package com.dy.rtuMw.server.local.localProtocol;

import com.dy.common.threadPool.TreadPoolFactory;
import com.dy.common.util.*;
import com.dy.rtuMw.server.forTcp.TcpDownCommandCache;
import com.dy.rtuMw.server.forTcp.TcpSessionCache;
import com.dy.rtuMw.server.rtuData.RtuDataCache;
import com.dy.rtuMw.server.rtuData.TaskPool;
import oshi.SystemInfo;
import oshi.hardware.HardwareAbstractionLayer;

/**
 * @Author: liurunyu
 * @Date: 2024/7/29 11:07
 * @Description
 */
public class MwInfoDeal {

    public MwInfoVo deal() throws Exception{
        MwInfoVo vo = new MwInfoVo() ;
        Integer[] info = TcpSessionCache.info() ;
        vo.rtuTotalConnect = info[0] ;
        vo.rtuTotalOnLine = info[1] ;
        vo.rtuTotalOffLine = info[2] ;

        info = TcpDownCommandCache.info() ;
        vo.comTotalDown = info[0] ;
        vo.comNoResTotalDownByOnLine = info[1] ;
        vo.comNoResTotalDownByOffLine = info[2] ;

        vo.dataTotalUp = RtuDataCache.size() ;

        info = TreadPoolFactory.pool_short_state() ;
        vo.shortCurThread = info[0] ;
        vo.shortMaxThread = info[1] ;
        vo.shortMinThread = info[2] ;

        info = TreadPoolFactory.pool_long_state() ;
        vo.longCurThread = info[0] ;
        vo.longMaxThread = info[1] ;
        vo.longMinThread = info[2] ;

        vo.taskTreePoolTotalInstance = TaskPool.totalTasks() ;

        SystemInfo si = new SystemInfo();
        HardwareAbstractionLayer hal = si.getHardware();
        vo.memInfoVo = SysMemoryUtil.info(hal.getMemory());
        vo.sysInfoVo = SysSysUtil.info();
        vo.jvmInfoVo = SysJvmUtil.info();

        return vo ;
    }
}