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

import com.dy.common.threadPool.TreadPoolFactory;
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;

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

    public MwInfoVo deal(){
        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() ;

        return vo ;
    }
}