CollHPHost.java 8.4 KB
package com.sitech.ismp.coll.centercoll;

import java.util.HashMap;
import java.util.Scanner;
import java.util.Vector;

import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import com.sitech.ismp.coll.host.CollHPWithCMDByCron;
import com.sitech.util.DES3;

public class CollHPHost implements CollHPHostMBean {
	public Vector<TblATO_KPIDETAIL> getConfig(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getConfig(params);
	}

	public Vector<TblATO_KPIDETAIL> getCpu(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getCpu(params);
	}

	public Vector<TblATO_KPIDETAIL> getMemory(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getMemory(params);
	}

	public Vector<TblATO_KPIDETAIL> getDisk(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getDisk(params);
	}

	public Vector<TblATO_KPIDETAIL> getFileSystem(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getFileSystem(params);
	}

	public Vector<TblATO_KPIDETAIL> getSpecProcess(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getSpecProcess(params);
	}

	public Vector<TblATO_KPIDETAIL> getJLSpecProcess(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getJLSpecProcess(params);
	}

	public Vector<TblATO_KPIDETAIL> getUserProNum(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getUserProNum(params);
	}

	public Vector<TblATO_KPIDETAIL> getSyslog(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getSyslog(params);
	}

	public Vector<TblATO_KPIDETAIL> getPing(HashMap<String, String> params) {
		CollHPWithCMD cmd = new CollHPWithCMD();
		return cmd.getPing(params);
	}

    public Vector<TblATO_KPIDETAIL> getCabinetRackInfo(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getCabinetRackInfo(params);
    }

    public Vector<TblATO_KPIDETAIL> getShow(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getShow(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWDisk(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWDisk(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWNetWork(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWNetWork(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWFan(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWFan(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWSensor(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWSensor(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWPCISolt(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWPCISolt(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWSPCard(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWSPCard(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWPower(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWPower(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWPowerSupply(
            HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWPowerSupply(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWCPU(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWCPU(params);
    }

    @Override
    public Vector<TblATO_KPIDETAIL> getHWMemory(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getHWMemory(params);
    }

    /**
     * 采集文件变更指标
     */
    @Override
    public Vector<TblATO_KPIDETAIL> getFileChange(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getFileChange(params);
    }

    /**
     *采集大目录
     * */
    @Override
    public Vector<TblATO_KPIDETAIL> getCatalog(HashMap<String, String> params) {
        CollHPWithCMD cmd = new CollHPWithCMD();
        return cmd.getCatalog(params);
    }

	public static void main(String[] args) {
		System.out
				.println("***************HP Center Collect Test Begin*********************");
		String ipAddr = "172.21.0.117";
		String username = "yfbnms";
		String password = "yfbnms";
		String prototal = "ssh";
		String hostName = "yf4";
		String methodStr = "10";
//        String ipAddr = "10.7.81.228";
//		String username = "USERID";
//		String password = "PASSW0RD";
//		String prototal = "ssh";
//		String hostName = "TEST_HOST";
//		String methodStr = "9";
        String pointIPs = "172.21.0.31,172.21.0.252";
        String process_name = "init,swapper";
//		String ipAddr = read("IP_ADDR(remote host ip):\n");
//		String username = read("USERNAME:\n");
//		String password = read("PASSWORD:\n");
//		String prototal = read("PROTOTAL(ssh/telent):\n");
//		String hostName = read("HOST_NAME(remote host name):\n");
//		String methodStr = read("METHOD(0:getAll, 1:getConfig, 2:getCpu, 3:getMemory, 4:getDisk, 5:getFileSystem):\n");

		System.out.println("IP_ADDR=" + ipAddr + ", USERNAME=" + username
				+ ", PASSWORD=" + password + ", PROTOTAL=" + prototal
				+ ", HOST_NAME=" + hostName + ", METHOD=" + methodStr);

		HashMap<String, String> params = new HashMap<String, String>();		
		params.put("IP_ADDR", ipAddr);
		params.put("USERNAME", username);
		params.put("PASSWORD", DES3.encrypt(password));
		params.put("PROTOCOL", prototal);
		params.put("DEVICE_NAME", hostName);
		params.put("POINT_IPS", pointIPs);
		params.put("PROCESS_NAME", process_name);

		int method = Integer.parseInt(methodStr);
		Vector<TblATO_KPIDETAIL> result = new Vector<TblATO_KPIDETAIL>();

		CollHPHost collector = new CollHPHost();

		switch (method) {
            case 0:
                result.addAll(collector.getConfig(params));
                result.addAll(collector.getCpu(params));
                result.addAll(collector.getMemory(params));
                result.addAll(collector.getDisk(params));
                result.addAll(collector.getFileSystem(params));
                result.addAll(collector.getPing(params));
                result.addAll(collector.getShow(params));
                result.addAll(collector.getFileChange(params));
                break;
            case 1:
                result.addAll(collector.getConfig(params));
                break;
            case 2:
                result.addAll(collector.getCpu(params));
                break;
            case 3:
                result.addAll(collector.getMemory(params));
                break;
            case 4:
                result.addAll(collector.getDisk(params));
                break;
            case 5:
                result.addAll(collector.getFileSystem(params));
                break;
            case 6:
                result.addAll(collector.getPing(params));
                break;
            case 7:
                result.addAll(collector.getCabinetRackInfo(params));
                break;
            case 8:
                result.addAll(collector.getShow(params));
                break;
            case 9:
                result.addAll(collector.getHWFan(params));
                break;
            case 10:
                result.addAll(collector.getFileChange(params));
                result.addAll(collector.getCatalog(params));
                break;
            case 11:
                result.addAll(collector.getSpecProcess(params));
                break;
            default:
                break;
		}

		System.out.println("***************HP Center Collect Test End*********************");
		System.out.println();
		for (int i = 0; i < result.size(); i++) {
			TblATO_KPIDETAIL record = (TblATO_KPIDETAIL) result.get(i);
			System.out.println(record.UNIT_ID + "\t" + record.KPI_ID + "\t" + record.KPI_VALUE);
		}
	}
	
	private static String read(String prompt) {
		Scanner scanner = new Scanner(System.in);
		System.out.print(prompt);
		return scanner.nextLine();
	}

}