package com.wgcloud.util;

import com.wgcloud.entity.DbInfo;
import com.wgcloud.entity.DceInfo;
import com.wgcloud.entity.HeathMonitor;
import com.wgcloud.entity.SnmpInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * @version v3.3
 * @ClassName: ServerBackupUtil
 * @author: http://www.wgstart.com
 * @date: 2022年09月13日
 * @Description: wgcloud-server-backup客户端的工具类（数据源、数据表、PING设备、SNMP设备、服务接口）
 * @Copyright: 2019-2021 wgcloud. All rights reserved.
 */
public class ServerBackupUtil {

    private static final Logger logger = LoggerFactory.getLogger(ServerBackupUtil.class);

    //server-backup节点处理数据监控的数据源ID，server节点不监控这些数据源和其数据表
    public static List<String> DB_INFO_ID_LIST = Collections.synchronizedList(new ArrayList<String>());

    //server-backup节点处理监控的PING设备ID，server节点不监控这些PING设备
    public static List<String> DCE_INFO_ID_LIST = Collections.synchronizedList(new ArrayList<String>());

    //server-backup节点处理监控的SNMP设备ID，server节点不监控这些SNMP设备
    public static List<String> SNMP_INFO_ID_LIST = Collections.synchronizedList(new ArrayList<String>());

    //server-backup节点处理监控的服务接口ID，server节点不监控这些服务接口
    public static List<String> HEATH_MONITOR_ID_LIST = Collections.synchronizedList(new ArrayList<String>());

    /**
     * 定期清空这些ID list
     */
    public static void clearCacheIdList() {
        logger.info("清空server-backup节点处理的缓存ID");
        DB_INFO_ID_LIST.clear();
        DCE_INFO_ID_LIST.clear();
        SNMP_INFO_ID_LIST.clear();
        HEATH_MONITOR_ID_LIST.clear();
    }

    /**
     * 将server-backup节点处理的数据源ID，暂存起来，server节点就不监控这些数据源了
     *
     * @param dbInfoList
     */
    public static void cacheSaveDbInfoId(List<DbInfo> dbInfoList) {
        for (DbInfo dbInfo : dbInfoList) {
            if (!ServerBackupUtil.DB_INFO_ID_LIST.contains(dbInfo.getId())) {
                ServerBackupUtil.DB_INFO_ID_LIST.add(dbInfo.getId());
            }
        }
    }

    /**
     * 将server-backup节点处理的的PING设备ID，暂存起来，server节点就不监控这些的PING设备了
     *
     * @param dceInfoList
     */
    public static void cacheSaveDceInfoId(List<DceInfo> dceInfoList) {
        for (DceInfo dceInfo : dceInfoList) {
            if (!ServerBackupUtil.DCE_INFO_ID_LIST.contains(dceInfo.getId())) {
                ServerBackupUtil.DCE_INFO_ID_LIST.add(dceInfo.getId());
            }
        }
    }


    /**
     * 将server-backup节点处理的的SNMP设备ID，暂存起来，server节点就不监控这些的SNMP设备了
     *
     * @param snmpInfoList
     */
    public static void cacheSaveSnmpInfoId(List<SnmpInfo> snmpInfoList) {
        for (SnmpInfo snmpInfo : snmpInfoList) {
            if (!ServerBackupUtil.SNMP_INFO_ID_LIST.contains(snmpInfo.getId())) {
                ServerBackupUtil.SNMP_INFO_ID_LIST.add(snmpInfo.getId());
            }
        }
    }


    /**
     * 将server-backup节点处理的的服务接口ID，暂存起来，server节点就不监控这些的服务接口了
     *
     * @param heathMonitorList
     */
    public static void cacheSaveHeathMontiorId(List<HeathMonitor> heathMonitorList) {
        for (HeathMonitor heathMontior : heathMonitorList) {
            if (!ServerBackupUtil.HEATH_MONITOR_ID_LIST.contains(heathMontior.getId())) {
                ServerBackupUtil.HEATH_MONITOR_ID_LIST.add(heathMontior.getId());
            }
        }
    }

}