package com.sitech.ismp.coll;

import java.util.HashMap;
import java.util.Vector;
import com.sitech.util.Formater;

public class CollNet extends CollBase implements CollNetMBean {
	private final String DEVICENAMEOID = ".1.3.6.1.2.1.1.5.0";

	String KBP_ID = "10-13";

	final String COMMUNICATION = "public";

	final int PORT = 161;

	// String driverID = "";

	/*
	 * String routerip = null; String ObjectIP = null;
	 */
	public CollNet() {
	}

	public Vector getConfiguration(String driverID, String ObjectIP) {
		return getConfiguration(driverID, ObjectIP, PORT, COMMUNICATION);
	}

	public Vector getConfiguration(String driverID, String ObjectIP, int port,
			String communication) {
		System.out.println("CollNet:" + ObjectIP+":"+port+"#"+communication);
		SNMPTarget snmptarget = new SNMPTarget();
		snmptarget.init(ObjectIP, port, communication);
		 System.out.println(snmptarget.getSNMPState());
		getSystemConfiguration(driverID, snmptarget);
		getInterfacesConfiguration(driverID, snmptarget);
		snmptarget.release();
		return snmptarget.getKPISet();
	}

	public Vector getState(String driverID, String ObjectIP) {
		return getState(driverID, ObjectIP, PORT, COMMUNICATION);
	}

	public Vector getState(String driverID, String ObjectIP, int port,
			String communication) {
		SNMPTarget snmptarget = new SNMPTarget();
		// System.out.println("XXXXXXXXXXXXXXXXXXXXXXXXX1:" +
		// snmptarget.getKPISet().size());
		snmptarget.init(ObjectIP, port, communication);
		// System.out.println("XXXXXXXXXXXXXXXXXXXXXXXXX2:" +
		// snmptarget.getKPISet().size());
		if (snmptarget.getSNMPState()) {
			getSystemState(driverID, snmptarget);
			getInterfacesState(driverID, snmptarget);
		}
		snmptarget.release();
		// System.out.println("XXXXXXXXXXXXXXXXXXXXXXXXX3:" +
		// snmptarget.getKPISet().size());
		return snmptarget.getKPISet();
	}

	public Vector getPerformance(String driverID, String ObjectIP) {
		return getPerformance(driverID, ObjectIP, PORT, COMMUNICATION);
	}

	public Vector getPerformance(String driverID, String ObjectIP, int port,
			String communication) {
		SNMPTarget snmptarget = new SNMPTarget();
		snmptarget.init(ObjectIP, port, communication);
		getInterfacesPerformance(driverID, snmptarget);
		getSystemPerformance(driverID, snmptarget);
		snmptarget.release();
		return snmptarget.getKPISet();
	}

	public Vector getCMStandKPI(String driverID, String ObjectIP) {
		return getCMStandKPI(driverID, ObjectIP, PORT, COMMUNICATION);
	}

	public Vector getCMStandKPI(String driverID, String ObjectIP, int port,
			String communication) {
		SNMPTarget snmptarget = new SNMPTarget();
		snmptarget.init(ObjectIP, port, communication);
		getCMStandKPI(driverID, snmptarget);
		snmptarget.release();
		return snmptarget.getKPISet();
	}

	/* 取得默认参数 */
	private boolean getParams(java.util.HashMap params) {
		try {
			String cPost = (String) params.get("PORT");
			if (cPost == null) {
				params.put("PORT", String.valueOf(PORT));
			}
			String communication = (String) params.get("COMMUNICATION");
			if (communication == null) {
				params.put("COMMUNICATION", COMMUNICATION);
				communication = COMMUNICATION;
			}
			String driverID = (String) params.get("DRIVERID");
			if (driverID == null) {
				SNMPTarget snmptarget1 = new SNMPTarget();
				String ObjectIP = (String) params.get("IP_ADDR");
				int port = Integer.parseInt((String) params.get("PORT"));
				snmptarget1.init(ObjectIP, port, communication);
				String DRIVERID = snmptarget1.getKPIInfo(DEVICENAMEOID);
				if ((DRIVERID == null) || DRIVERID.equals("")) {
					DRIVERID = ObjectIP;
				}
				snmptarget1.release();
				params.put("DRIVERID", Formater.neatenunitid(DRIVERID));
			}
		} catch (Exception e) {
			params.put("COMMUNICATION", COMMUNICATION);
		}
		return true;
	}

	public java.util.Vector getConfiguration(java.util.HashMap params)
			throws Exception {
		getParams(params);
		String driverID = (String) params.get("DRIVERID");
		String ObjectIP = (String) params.get("IP_ADDR");
		int port = Integer.parseInt((String) params.get("PORT"));
		String communication = (String) params.get("COMMUNICATION");
		return getConfiguration(driverID, ObjectIP, port, communication);
	}

	public java.util.Vector getState(java.util.HashMap params) throws Exception {
		getParams(params);
		String driverID = (String) params.get("DRIVERID");
		String ObjectIP = (String) params.get("IP_ADDR");
		int port = Integer.parseInt((String) params.get("PORT"));
		String communication = (String) params.get("COMMUNICATION");
		return getState(driverID, ObjectIP, port, communication);
	}

	public java.util.Vector getPerformance(java.util.HashMap params)
			throws Exception {
		getParams(params);
		String driverID = (String) params.get("DRIVERID");
		String ObjectIP = (String) params.get("IP_ADDR");
		int port = Integer.parseInt((String) params.get("PORT"));
		String communication = (String) params.get("COMMUNICATION");
		return getPerformance(driverID, ObjectIP, port, communication);
	}

	public java.util.Vector getCMStandKPI(java.util.HashMap params)
			throws Exception {
		getParams(params);
		String driverID = (String) params.get("DRIVERID");
		String ObjectIP = (String) params.get("IP_ADDR");
		int port = Integer.parseInt((String) params.get("PORT"));
		String communication = (String) params.get("COMMUNICATION");
		return getCMStandKPI(driverID, ObjectIP, port, communication);
	}

	public void getKPI(HashMap params) {
		getParams(params);
		String driverID = (String) params.get("DRIVERID");
		String ObjectIP = (String) params.get("IP_ADDR");
		int port = Integer.parseInt((String) params.get("PORT"));
		String communication = (String) params.get("COMMUNICATION");
		getKPI(driverID, ObjectIP, port, communication);
	}

	public void getKPI(String driverID, String ObjectIP, int port,
			String communication) {
		SNMPTarget snmptarget = new SNMPTarget();
		snmptarget.init(ObjectIP, port, communication);
		if (snmptarget.getSNMPState()) {
			snmptarget.addKPI(KBP_ID + "-10" + ":" + driverID + "-"
					+ snmptarget.ObjectIP, "FM-00-02-001-01", "up");
			getConfiguration(driverID, ObjectIP, port, communication);
			getState(driverID, ObjectIP, port, communication);
			getPerformance(driverID, ObjectIP, port, communication);
			getCMStandKPI(driverID, ObjectIP, port, communication);
		} else {
			snmptarget.addKPI(KBP_ID + "-10" + ":" + driverID + "-"
					+ snmptarget.ObjectIP, "FM-00-02-001-01", "up");
		}
		snmptarget.release();
	}

	/*
	 * FM-00-02-01-02 设备端口状态 .1.3.6.1.2.1.2.2.1.8.* up(1) down(2) dormant(5)
	 * FM-00-02-01-03 设备端口管理状态 .1.3.6.1.2.1.2.2.1.7.* up(1) down(2) dormant(5)
	 * FM-10-11-11-13 Line Protocol状态 .1.3.6.1.4.1.9.2.2.1.1.2.* up(1) down(2)
	 * //只对CISCO设备有效
	 */
	private void getInterfacesState(String driverID, SNMPTarget snmptarget) {
		String KBP_ID = this.KBP_ID + "-11" + ":" + driverID + "-"
				+ snmptarget.ObjectIP + "-interfaces-";
		// sucg要求不采集
		// snmptarget.addKPI(KBP_ID, "FM-00-02-001-02", snmptarget
		// .walkKPIInfo(".1.3.6.1.2.1.2.2.1.8"));
		// snmptarget.addKPI(KBP_ID, "FM-00-02-001-03", snmptarget
		// .walkKPIInfo(".1.3.6.1.2.1.2.2.1.7"));
	}

	/*
	 * CM-10-11-11-15 端口IP地址
	 * .1.3.6.1.2.1.4.20.1.1.*(.1.3.6.1.2.1.4.20.1.2.*为interface的index)
	 * CM-10-11-11-16 端口IP的NETMASK
	 * .1.3.6.1.2.1.4.20.1.3.*(.1.3.6.1.2.1.4.20.1.2.*为interface的index)
	 * 
	 * PM-10-11-11-11 端口流入速率 bit/sec .1.3.6.1.4.1.9.2.2.1.1.6.* PM-10-11-11-12
	 * 端口流入包数packets/sec .1.3.6.1.4.1.9.2.2.1.1.7.* PM-10-11-11-13 端口流出速率
	 * bit/sec .1.3.6.1.4.1.9.2.2.1.1.8.* PM-10-11-11-14 端口流出包数packets/sec
	 * .1.3.6.1.4.1.9.2.2.1.1.9.*
	 * 
	 * PM-10-11-11-15 流入dropped packets .1.3.6.1.4.1.9.2.2.1.1.26.* The number
	 * of packets dropped because the input queue was full. PM-10-11-11-16
	 * 流出dropped packets .1.3.6.1.4.1.9.2.2.1.1.27.*
	 * 
	 * PM-10-11-11-17 OverRun packets .1.3.6.1.4.1.9.2.2.1.1.14.* PM-10-11-11-18
	 * 端口流入忽略包数ignored .1.3.6.1.4.1.9.2.2.1.1.15.* PM-10-11-11-19
	 * 端口流入丢弃包数aborted. .1.3.6.1.4.1.9.2.2.1.1.16.*
	 * 
	 * PM-10-11-11-20 端口流入总字节数（8Bytes） .1.3.6.1.2.1.2.2.1.10.* PM-10-11-11-21
	 * 端口流入总包数（unicast） .1.3.6.1.2.1.2.2.1.11.* PM-10-11-11-22
	 * 端口流入总包数（non-unicast） .1.3.6.1.2.1.2.2.1.12.* PM-10-11-11-23 端口流入discard包数
	 * .1.3.6.1.2.1.2.2.1.13.* PM-10-11-11-24 端口流入错误包数 .1.3.6.1.2.1.2.2.1.14.*
	 * 
	 * PM-10-11-11-25 端口流出总字节数（8Bytes） .1.3.6.1.2.1.2.2.1.16.* PM-10-11-11-26
	 * 端口流出总包数（unicast） .1.3.6.1.2.1.2.2.1.17.* PM-10-11-11-27
	 * 端口流出总包数（non-unicast） .1.3.6.1.2.1.2.2.1.18.* PM-10-11-11-28 端口流出discard包数
	 * .1.3.6.1.2.1.2.2.1.19.* PM-10-11-11-29 端口流出错误包数 .1.3.6.1.2.1.2.2.1.20.*
	 * 
	 * PM-10-11-11-30 端口流出误码率 (PM-10-11-10-29)/(PM-10-11-10-26 + PM-10-11-10-27)
	 * PM-10-11-11-31 端口流入误码率 (PM-10-11-10-24)/(PM-10-11-10-21 + PM-10-11-10-22)
	 * PM-10-11-11-32 端口流出丢包率 (PM-10-11-10-28)/(PM-10-11-10-26 + PM-10-11-10-27)
	 * PM-10-11-11-33 端口流入丢包率 (PM-10-11-10-23)/(PM-10-11-10-21 + PM-10-11-10-22)
	 * 
	 * 
	 * FM-00-02-002-01 端口误码率 //表示万分之X的误码率 FM-00-02-002-02 端口丢包率 //表示万分之X的丢包率
	 * PM-00-02-001-01 端口利用率 PM-00-02-001-02 端口流入利用率率 PM-00-02-001-03 端口流出利用率率
	 */
	private void getInterfacesPerformance(String driverID, SNMPTarget snmptarget) {
		String KBP_ID = this.KBP_ID + "-11" + ":" + driverID + "-"
				+ snmptarget.ObjectIP + "-interfaces-";

		Vector vindex = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.1");
		Vector fixedspeed = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.5"); // 端口设置速率
		Vector indiscard = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.13"); // 入丢包数
		Vector inerror = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.14"); // 入错误包数
		Vector inoctetsb = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.10"); // 入总字节数数/8
		Vector outoctetsb = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.16"); // 出总字节数数/8
		try {
			Thread.sleep(2000);// 等待2秒
		} catch (Exception e) {
		}
		Vector inoctetse = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.10"); // 入总字节数数/8
		Vector outoctetse = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.16"); // 出总字节数数/8

		Vector inpackage = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.11"); // 入总包数
		Vector outpackage = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.17"); // 出总包数
		Vector outdiscard = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.19"); // 出丢包数
		Vector outerror = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.20"); // 出错误包数

		/*
		 * Vector discardper = new Vector(); Vector errorper = new Vector();
		 * Vector inoutper = new Vector(); Vector inper = new Vector(); Vector
		 * outper = new Vector();
		 */
		for (int i = 0; i < outerror.size(); i++) {
			String index = (String) vindex.elementAt(i);
			float speed = Float.parseFloat((String) fixedspeed.elementAt(i)) / 64; // 一个octet8字节,1字节8bit
			float inoctets = Float.parseFloat((String) inoctetse.elementAt(i))
					- Float.parseFloat((String) inoctetsb.elementAt(i));// /speed;
			float outoctets = Float
					.parseFloat((String) outoctetse.elementAt(i))
					- Float.parseFloat((String) outoctetsb.elementAt(i)); // /speed;

			float totalpackage = Float.parseFloat((String) inpackage
					.elementAt(i))
					+ Float.parseFloat((String) outpackage.elementAt(i));
			float totalerrorpackage = Float.parseFloat((String) inerror
					.elementAt(i))
					+ Float.parseFloat((String) outerror.elementAt(i));
			float totaldiscardpackage = Float.parseFloat((String) indiscard
					.elementAt(i))
					+ Float.parseFloat((String) outdiscard.elementAt(i));
			if (totalpackage < 1)
				totalpackage = 1F;

			/*
			 * errorper.add(String.valueOf((totalerrorpackage/totalpackage)*5000F));
			 * //表示十万分之X的误码率
			 * discardper.add(String.valueOf((totaldiscardpackage/totalpackage)*5000F));
			 * //表示十万分之X的丢包率 inper.add(String.valueOf(inoctets/speed*50F));
			 * //千分比,等待了2秒 outper.add(String.valueOf(outoctets/speed*50F));
			 * //千分比,等待了2秒
			 * inoutper.add(String.valueOf((inoctets+outoctets)/speed*50F));
			 */
			String cerrorper = Formater.formatDecimalByScale(String
					.valueOf((totalerrorpackage / totalpackage) * 5000F), 4); // 表示十万分之X的误码率
			String cdiscardper = Formater.formatDecimalByScale(String
					.valueOf((totaldiscardpackage / totalpackage) * 5000F), 4); // 表示十万分之X的丢包率
			String cinper = Formater.formatDecimalByScale(String
					.valueOf(inoctets / speed * 50F), 4); // 千分比,等待了2秒
			String coutper = Formater.formatDecimalByScale(String
					.valueOf(outoctets / speed * 50F), 4); // 千分比,等待了2秒
			String cinoutper = Formater.formatDecimalByScale(String
					.valueOf((inoctets + outoctets) / speed * 50F), 4);

			snmptarget.addKPI(KBP_ID + index, "FM-00-02-002-01", cerrorper);
			snmptarget.addKPI(KBP_ID + index, "FM-00-02-002-02", cdiscardper);
			snmptarget.addKPI(KBP_ID + index, "PM-00-02-001-01", cinoutper);
			snmptarget.addKPI(KBP_ID + index, "PM-00-02-001-02", cinper);
			snmptarget.addKPI(KBP_ID + index, "PM-00-02-001-03", coutper);
		}
	}

	/*
	 * CM-00-02-002-01 端口标识 .1.3.6.1.2.1.2.2.1.2.* CM-00-02-002-02 端口类型
	 * .1.3.6.1.2.1.2.2.1.3.* (标识型)
	 * //.1.3.6.1.4.1.9.2.2.1.1.1.*(字符型，更准确,CISCO有效) CM-00-02-002-03 端口设置速率
	 * .1.3.6.1.2.1.2.2.1.5.* CM-00-02-002-04 端口物理地址 .1.3.6.1.2.1.2.2.1.6.*
	 * 
	 * 
	 * CM-00-02-002-05 端口IP地址
	 * .1.3.6.1.2.1.4.20.1.1.*(.1.3.6.1.2.1.4.20.1.2.*为interface的index)
	 * CM-00-02-002-06 端口IP的NETMASK
	 * .1.3.6.1.2.1.4.20.1.3.*(.1.3.6.1.2.1.4.20.1.2.*为interface的index)
	 */
	private void getInterfacesConfiguration(String driverID,
			SNMPTarget snmptarget) {
		try {
			String KBP_ID = this.KBP_ID + "-11" + ":" + driverID + "-"
					+ snmptarget.ObjectIP + "-interfaces-";
			Vector vindex = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.1");
			Vector vdescr = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.2");
			Vector viftype = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.3");
			Vector vspeed = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.5");
			Vector vphys = snmptarget.walkKPIInfo(".1.3.6.1.2.1.2.2.1.6");
			Vector vindex2 = snmptarget.walkKPIInfo(".1.3.6.1.2.1.4.20.1.2");// index
			Vector vaddr = snmptarget.walkKPIInfo(".1.3.6.1.2.1.4.20.1.1");
			Vector vnetmask = snmptarget.walkKPIInfo(".1.3.6.1.2.1.4.20.1.3");

			for (int i = 0; i < vindex.size(); i++) {
				String index = (String) vindex.elementAt(i);
				String descr = (String) vdescr.elementAt(i);
				String iftype = (String) viftype.elementAt(i);
				String speed = (String) vspeed.elementAt(i);
				String phys = (String) vphys.elementAt(i);
				if (!descr.startsWith("Null") && !descr.startsWith("unrouted")) {
					System.out.println(descr);
					snmptarget.addKPI(KBP_ID + index, "CM-00-02-002-01", descr);
				}
				// sucg要求不采集
				// snmptarget.addKPI(KBP_ID + index, "CM-00-02-002-02", iftype);
				// snmptarget.addKPI(KBP_ID + index, "CM-00-02-002-03", speed);
				// snmptarget.addKPI(KBP_ID + index, "CM-00-02-002-04", phys);
			}

			for (int i = 0; i < vindex2.size(); i++) {
				String index2 = (String) vindex2.elementAt(i);
				String addr = (String) vaddr.elementAt(i);
				String netmask = (String) vnetmask.elementAt(i);
				snmptarget.addKPI(KBP_ID + index2, "CM-00-02-002-05", addr);
				// sucg要求不采集
				// snmptarget.addKPI(KBP_ID + index2, "CM-00-02-002-06",
				// netmask);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// 仅正对CISCO有效,其他有待完善
	/*
	 * FM-00-02-02-03 设备1分钟CPU利用率 .1.3.6.1.4.1.9.2.1.57.0 PM-10-11-10-13 内存容量
	 * .1.3.6.1.4.1.9.9.48.1.1.1.5.* +
	 * .1.3.6.1.4.1.9.9.48.1.1.1.6.*（此为一Table,表示各个内存条，对此求和） PM-10-11-10-14 内存使用量
	 * .1.3.6.1.4.1.9.9.48.1.1.1.5.* （此为一Table,表示各个内存条，对此求和） PM-10-11-10-15
	 * 内存剩余量 .1.3.6.1.4.1.9.9.48.1.1.1.6.* （此为一Table,表示各个内存条，对此求和）
	 * FM-00-02-02-04 设备内存利用率 100 - PM-10-11-10-14×100/PM-10-11-10-13
	 */
	private void getSystemPerformance_CISCO(String driverID,
			SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;
		snmptarget.addKPI(kpiid, "FM-00-02-002-03", snmptarget
				.getKPIInfo(".1.3.6.1.4.1.9.2.1.57.0"));
		Vector memusedpool = snmptarget
				.walkKPIInfo(".1.3.6.1.4.1.9.9.48.1.1.1.5");
		Vector memfreepool = snmptarget
				.walkKPIInfo(".1.3.6.1.4.1.9.9.48.1.1.1.6");
		int usedmem = snmptarget.sumKPI(memusedpool);
		int freemem = snmptarget.sumKPI(memfreepool);
		int mem = usedmem + freemem;
		float memper = usedmem * 100F / mem;
		snmptarget.addKPI(kpiid, "FM-00-02-002-04", String.valueOf((int)memper));
	}

	private void getSystemPerformance_HUAWEI(String driverID,
			SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;
		snmptarget.addKPI(kpiid, "FM-00-02-002-03", "NaN");
		snmptarget.addKPI(kpiid, "FM-00-02-002-04", "NaN");
	}

	private void getSystemPerformance_OTHER(String driverID,
			SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;
		snmptarget.addKPI(kpiid, "FM-00-02-002-03", "NaN");
		snmptarget.addKPI(kpiid, "FM-00-02-002-04", "NaN");
	}

	private void getSystemPerformance(String driverID, SNMPTarget snmptarget) {
		if (getVendor(snmptarget.getKPIInfo(".1.3.6.1.2.1.1.1.0")).equals(
				"CISCO")) {
			getSystemPerformance_CISCO(driverID, snmptarget);
			return;
		}
		if (getVendor(snmptarget.getKPIInfo(".1.3.6.1.2.1.1.1.0")).equals(
				"HUAWEI")) {
			getSystemPerformance_HUAWEI(driverID, snmptarget);
			return;
		}
		getSystemPerformance_OTHER(driverID, snmptarget);
	}

	/*
	 * CM-00-02-001-01 网元类型 ROUTER CM-00-02-001-02 网元厂商 .1.3.6.1.2.1.1.1.0
	 * 从系统描述中获取 CM-00-02-001-03 设备型号 .1.3.6.1.2.1.1.2.0 CM-00-02-001-04 网元名
	 * .1.3.6.1.2.1.1.5.0 CM-00-02-001-05 网元IP地址 为输入参数 CM-00-02-001-06 端口数量
	 * .1.3.6.1.2.1.2.1.0 CM-00-02-001-07 系统描述 .1.3.6.1.2.1.1.1.0
	 * PM-00-02-001-08 设备启动时间 .1.3.6.1.2.1.1.3.0
	 */
	private void getSystemConfiguration(String driverID, SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;

		//常用ip,用于告警标题 2006-07-26 WANGBY
		snmptarget.addKPI(kpiid, "CM-00-02-001-50", snmptarget.ObjectIP);

		snmptarget.addKPI(kpiid, "CM-00-02-001-01", getDeviceType(snmptarget
				.getKPIInfo(".1.3.6.1.2.1.1.1.0")));
		snmptarget.addKPI(kpiid, "CM-00-02-001-02", getVendor(snmptarget
				.getKPIInfo(".1.3.6.1.2.1.1.1.0")));
		snmptarget.addKPI(kpiid, "CM-00-02-001-03", snmptarget
				.getKPIInfo(".1.3.6.1.2.1.1.2.0"));
		String devicename = snmptarget.getKPIInfo(DEVICENAMEOID);
		snmptarget.addKPI(kpiid, "CM-00-02-001-04", devicename);
		snmptarget.addKPI(kpiid, "CM-00-02-001-05", snmptarget.ObjectIP);
		snmptarget.addKPI(kpiid, "CM-00-02-001-06", snmptarget
				.getKPIInfo(".1.3.6.1.2.1.2.1.0"));
		snmptarget.addKPI(kpiid, "CM-00-02-001-07", snmptarget
				.getKPIInfo(".1.3.6.1.2.1.1.1.0"));
		snmptarget.addKPI(kpiid, "PM-10-02-001-08", snmptarget
				.getKPIInfo(".1.3.6.1.2.1.1.3.0"));
	}

	private String getVendor(String desc) {
		if ((desc == null) || desc.equals(""))
			return "UNKNOW";
		desc = desc.toUpperCase();
		if (desc.indexOf("AIX") > -1)
			return "IBM";
		if (desc.indexOf("HP-UX") > -1)
			return "HP";
		if (desc.indexOf("SUN") > -1)
			return "SUN";
		if (desc.indexOf("CISCO") > -1)
			return "CISCO";
		if (desc.indexOf("WINDOWS") > -1)
			return "MICROSOFT";
		if (desc.indexOf("HUAWEI") > -1)
			return "HUAWEI";
		return "UNKNOW";
	}

	private String getDeviceType(String desc) {
		if ((desc == null) || desc.equals(""))
			return "UNKNOW";
		desc = desc.toUpperCase();
		if (desc.indexOf("AIX") > -1)
			return "AIX";
		if (desc.indexOf("HP-UX") > -1)
			return "HP_UX";
		if (desc.indexOf("SUN") > -1)
			return "SUN";
		if (desc.indexOf("CISCO") > -1)
			return "SWITCH/ROUTER";
		if (desc.indexOf("WINDOWS") > -1)
			return "WINDOWS";
		return "UNKNOW";
	}

	/*
	 * 4 FM-00-02-001-04 域名解析服务 可以正常解析得到重要设备的网络地址 5分钟 字符型 major （可选） 5
	 * FM-00-02-001-05 NTP服务状态 NTP时钟同步服务状态 5分钟 字符型 major （可选） 6 FM-00-02-001-06
	 * IP地址重复 在网络内，存在两个或两个以上相同的IP地址（不包括集群系统中的心跳私有地址） 15分钟 字符型 major 6
	 * FM-00-02-001-07 掩码不一致
	 */
	private void getCMStandKPI(String driverID, SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;
		// sucg要求不采集
		// snmptarget.addKPI(kpiid,"FM-00-02-001-04","noneffective");
		// snmptarget.addKPI(kpiid,"FM-00-02-001-05","noneffective");
		// snmptarget.addKPI(kpiid,"FM-00-02-001-06","noneffective");
		// snmptarget.addKPI(kpiid,"PM-00-02-001-07","noneffective");
	}

	private void getSystemState(String driverID, SNMPTarget snmptarget) {
		String kpiid = KBP_ID + "-10" + ":" + driverID + "-"
				+ snmptarget.ObjectIP;
		if (snmptarget.getSNMPState()) {
			snmptarget.addKPI(kpiid, "FM-00-02-001-01", "up");
		} else {
			snmptarget.addKPI(kpiid, "FM-00-02-001-01", "down");
		}
	}

	public static void main(String[] argv) {
		CollNet collnet = new CollNet();

		HashMap params = new HashMap();
		params.put("IP_ADDR", "10.208.192.10");
		params.put("COMMUNICATION", "sx_boss41");
		params.put("PORT", "161");
		params.put("DRIVERID", "aa");

		Vector result = new Vector();
		try {
			result = collnet.getConfiguration(params);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		collnet.displayKPI(result);

	}
}