//此类已经不使用2006-08-23
//lianlian
package com.sitech.ismp.coll.tivoli;

import java.util.Collection;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;

import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import com.sitech.ismp.coll.tivoli.db.itcm.NV_NODE_ENH_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.NV_NODE_ENH_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_EFFICIENCY;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_EFFICIENCYDao;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_HARDWARE_EFFICIENCY;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_HARDWARE_EFFICIENCYDao;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_INTERFACE_ERRORS;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_INTERFACE_ERRORSDao;
import com.sitech.ismp.coll.tivoli.db.tec.ALL_STATUS;
import com.sitech.ismp.coll.tivoli.db.tec.ALL_STATUSDao;

/**
 * 
 * 从TEC中获取所有网络的配置信息
 * 
 * 
 * @author lianlian
 * 
 */
public class CollAllNetConfig {

	private String pre_unitid = "10-13";

	public CollAllNetConfig() {

	}

	/**
	 * 得到网络配置数据
	 * 
	 * 
	 * @param paramsVector
	 * @return
	 */

	public Vector getEfficiency(HashMap params)
			throws Exception {
		Vector collResult = new Vector();

		Vector VConfigFromCOLL_DATA = this.getConfigFromCOLL_DATA(params);
		if (VConfigFromCOLL_DATA != null) {
			collResult.addAll(VConfigFromCOLL_DATA);
		}

		return collResult;
	}

	public Vector getConfiguration(HashMap params)
			throws Exception {

		Vector collResult = new Vector();

		Vector VConfigFormNV_NODE_ENH_VIEW = this
				.getConfigFormNV_NODE_ENH_VIEW(params);
		// Vector VConfigFromCOLL_DATA = this.getConfigFromCOLL_DATA(params);

		if (VConfigFormNV_NODE_ENH_VIEW != null) {
			collResult.addAll(VConfigFormNV_NODE_ENH_VIEW);
		}

		/*
		 * if(VConfigFromCOLL_DATA!=null) {
		 * collResult.addAll(VConfigFromCOLL_DATA); }
		 */

		return collResult;
	}

	// getSNMPInterfaceTypeNum 得到网络设备配置各种类型端口的数目

	private String getDeviceType(String str) {
		if (str.substring(0, 1).equals("1"))
			return "ROUTER";
		if (str.substring(1, 2).equals("1"))
			return "BRIDGE";
		if (str.substring(2, 3).equals("1"))
			return "COMPUTER";
		return "UNKNOW";
	}

	public Vector get_Interface_Performance(HashMap params)
			throws Exception {
		Vector collResult = new Vector();
		double unit = 100.00;
		String current_unit_id = "";
		String IP_ADDR = (String) params.get("IP_ADDR");

		// PM-00-02-001-04 端口误码率 端口误码率（百分比）（1） ifTotalErrorRate
		// PM-00-02-001-05 端口丢包率 端口丢包率（百分比） ifTotalDiscardsRate

		ALL_INTERFACE_ERRORSDao errordao = new ALL_INTERFACE_ERRORSDao();
		List list_ALL_INTERFACE_ERRORS = errordao.getALL_EFFICIENCY(IP_ADDR);

		for (int i = 0; i < list_ALL_INTERFACE_ERRORS.size(); i++) {
			ALL_INTERFACE_ERRORS obj = (ALL_INTERFACE_ERRORS) list_ALL_INTERFACE_ERRORS
					.get(i);
			String exp_name = obj.getEXPNAME();
			String host_name = obj.getHOSTNAME();
			String ip_addr = obj.getIPADDR();
			double d = obj.getFLOATVALUE();

			current_unit_id = this.pre_unitid + "-11:" + ip_addr
					+ "-interface ";

			if (exp_name == null || exp_name == "")
				continue;

			if (exp_name.equals("ifTotalErrorRate")) {
				// 数据目前有问题不可以采集
			} else {
				this.setResult(collResult, current_unit_id, "PM-00-02-001-05",
						d * unit + "%");
			}
		}

		return collResult;
	}

	public Vector get_Hardware_Performance(HashMap params)
			throws Exception {
		Vector collResult = new Vector();
		double unit = 100.00;
		String current_unit_id = "";
		String IP_ADDR = (String) params.get("IP_ADDR");

		// ALL_HARDWARE_EFFICIENCYDao
		// /PM-00-02-001-06 设备CPU利用率 网络设备CPU利用率（百分比） busyPer
		// PM-00-02-001-07 设备内存利用率 网络设备内存利用率（百分比） ciscoMemoryPoolUsedRate
		// PM-00-02-001-08 设备缓存利用率 网络设备缓存利用率（百分比） bufferElFreeRate
		ALL_HARDWARE_EFFICIENCYDao hardware_dao = new ALL_HARDWARE_EFFICIENCYDao();
		List list_ALL_HARDWARE_EFFICIENCY = hardware_dao
				.getALL_HARDWARE_EFFICIENCY(IP_ADDR);

		for (int i = 0; i < list_ALL_HARDWARE_EFFICIENCY.size(); i++) {
			ALL_HARDWARE_EFFICIENCY obj = (ALL_HARDWARE_EFFICIENCY) list_ALL_HARDWARE_EFFICIENCY
					.get(i);
			String exp_name = obj.getEXPNAME();
			String host_name = obj.getHOSTNAME();
			String ip_addr = obj.getIPADDR();
			double d = obj.getFLOATVALUE();

			current_unit_id = this.pre_unitid + "-10:" + ip_addr
					+ "-interface ";

			if (exp_name == null || exp_name == "")
				continue;

			if (exp_name.equals("busyPer")) {
				// PM-00-02-001-06
				this.setResult(collResult, current_unit_id, "PM-00-02-001-06",
						d * unit + "%");
			} else if (exp_name.equals("ciscoMemoryPoolUsedRate")) {
				// PM-00-02-001-07
				this.setResult(collResult, current_unit_id, "PM-00-02-001-07",
						d * unit + "%");
			} else {
				// PM-00-02-001-08 bufferElFreeRate指标不够准确暂时不要采集
			}
		}
		return collResult;
	}

	private Vector getConfigFromCOLL_DATA(HashMap params) {
		Vector collResult = new Vector();
		HashMap map = new HashMap();
		double unit = 100.00;

		String current_unit_id = "";

		String IP_ADDR = (String) params.get("IP_ADDR");

		// ALL_HARDWARE_EFFICIENCYDao
		// /PM-00-02-001-06 设备CPU利用率 网络设备CPU利用率（百分比） busyPer
		// PM-00-02-001-07 设备内存利用率 网络设备内存利用率（百分比） ciscoMemoryPoolUsedRate
		// PM-00-02-001-08 设备缓存利用率 网络设备缓存利用率（百分比） bufferElFreeRate
		ALL_HARDWARE_EFFICIENCYDao hardware_dao = new ALL_HARDWARE_EFFICIENCYDao();
		List list_ALL_HARDWARE_EFFICIENCY = hardware_dao
				.getALL_HARDWARE_EFFICIENCY(IP_ADDR);

		for (int i = 0; i < list_ALL_HARDWARE_EFFICIENCY.size(); i++) {
			ALL_HARDWARE_EFFICIENCY obj = (ALL_HARDWARE_EFFICIENCY) list_ALL_HARDWARE_EFFICIENCY
					.get(i);
			String exp_name = obj.getEXPNAME();
			String host_name = obj.getHOSTNAME();
			String ip_addr = obj.getIPADDR();
			double d = obj.getFLOATVALUE();

			current_unit_id = this.pre_unitid + "-10:" + ip_addr
					+ "-interface ";

			if (exp_name == null || exp_name == "")
				continue;

			if (exp_name.equals("busyPer")) {
				// PM-00-02-001-06
				this.setResult(collResult, current_unit_id, "PM-00-02-001-06",
						d * unit + "%");
			} else if (exp_name.equals("ciscoMemoryPoolUsedRate")) {
				// PM-00-02-001-07
				this.setResult(collResult, current_unit_id, "PM-00-02-001-07",
						d * unit + "%");
			} else {
				// PM-00-02-001-08 bufferElFreeRate指标不够准确暂时不要采集
			}
		}

		/*
		 * PM-00-02-001-01 LAN（半双工）端口利用率 LAN端口利用率（百分比） PM-00-02-001-02
		 * WAN（全双工）端口流入利用率率 WAN端口的流入利用率（百分比） PM-00-02-001-03 WAN（全双工）端口流出利用率率
		 * WAN端口的流出利用率（百分比）
		 */

		ALL_EFFICIENCYDao dao = new ALL_EFFICIENCYDao();
		List list_ALL_EFFICIENCY = dao.getINTERFACE_INFO_BY_IPADDR(IP_ADDR);

		for (int i = 0; i < list_ALL_EFFICIENCY.size(); i++) {
			ALL_EFFICIENCY obj = (ALL_EFFICIENCY) list_ALL_EFFICIENCY.get(i);
			String exp_name = obj.getEXPNAME();
			String host_name = obj.getHOSTNAME();
			String ip_addr = obj.getIPADDR();
			double d = obj.getFLOATVALUE();
			if (ip_addr == null)
				ip_addr = "ip_addr_unkown";

			current_unit_id = this.pre_unitid + "-11:" + ip_addr
					+ "-interface ";
			/*
			 * EXPNAME='BandwidthUtilHdx' EXPNAME='BandwidthUtilIn'
			 * EXPNAME='BandwidthUtilOut'
			 */
			if (exp_name == "BandwidthUtilHdx") {

				this.setResult(collResult, current_unit_id, "PM-00-02-001-01",
						d * unit + "%");
			} else if (exp_name == "BandwidthUtilIn") {
				this.setResult(collResult, current_unit_id, "PM-00-02-001-02",
						d * unit + "%");
			} else {
				this.setResult(collResult, current_unit_id, "PM-00-02-001-03",
						d * unit + "%");
			}
		}

		return collResult;
	}

	private Vector getConfigFormNV_NODE_ENH_VIEW(
			HashMap params) {
		Vector collResult = new Vector();
		HashMap map = new HashMap();
		String IP_ADDR = (String) params.get("IP_ADDR");

		/*
		 * CM-00-02-001-01 网元类型 网络中各种设备的类型；包括：路由器、交换机、第二层交换机、专用防火墙等，以及其产品序列号等属性
		 * NV_NODE_ENH_VIEW.多个
		 * 
		 * CM-00-02-001-02 网元厂商 网络中各种类型设备供应商 NV_NODE_ENH_VIEW.Vendor_Info
		 * CM-00-02-001-03 设备软件版本 网元设备当前安装的软件版本号
		 * NV_NODE_ENH_VIEW.SNMPDescription CM-00-02-001-04 网元名
		 * 网元配置名称，或由名字解析、DNS服务解释的名称 NV_NODE_ENH_VIEW.Node_Name CM-00-02-001-05
		 * 网元IP地址 网元管理端口IP地址 NV_NODE_ENH_VIEW.IP_Address
		 * 
		 * 
		 * 
		 * CM-00-02-002-01 端口标识 网元设备的每个端口的唯一标识名或ID号
		 * NV_NODE_ENH_VIEW.Interface_Name CM-00-02-002-02 端口类型
		 * 网络设备配置的端口模块类型；包括：以太网口、串口等， NV_NODE_ENH_VIEW.SNMPInterfaceType
		 * 
		 * CM-00-02-002-03 端口设置速率 网络设备各端口的最大速率（kbps）
		 * 
		 * CM-00-02-002-04 端口物理地址 网络设备端口固化的物理地址 NV_NODE_ENH_VIEW.SNMPMacAddress
		 * CM-00-02-002-05 端口IP地址 网络设备端口配置的IP地址以及其掩码 NV_NODE_ENH_VIEW.IP_Address
		 * 
		 * CM-00-02-002-06 端口数量 网络设备配置各种类型端口的数目 计算
		 */

		// CM-00-02-01-01 网元类型 网络中各种设备的类型；包括：路由器、交换机、第二层交换机、专用防火墙等，以及其产品序列号等属性
		NV_NODE_ENH_VIEWDao dao = new NV_NODE_ENH_VIEWDao();
		List List_NV_NODE_ENH_VIEW = dao
				.getNODEINFO_FROM_NV_NODE_ENH_VIEW_BY_IP_HOSTNAME(IP_ADDR);

		String current_unit_id = "";

		for (int i = 0; i < List_NV_NODE_ENH_VIEW.size(); i++) {
			NV_NODE_ENH_VIEW obj = (NV_NODE_ENH_VIEW) List_NV_NODE_ENH_VIEW
					.get(i);
			String IP_Aaddress = obj.getIP_Address();
			String Node_Name = obj.getNode_Name();
			String SNMPDescription = obj.getSNMPDescription();
			String Vendor_Info = obj.getVendor_Info();
			String temptype = String.valueOf(obj.getISROUTER())
					+ String.valueOf(obj.getISBRIDGE())
					+ String.valueOf(obj.getISCOMPUTER());

			String DeviceType = this.getDeviceType(temptype);

			current_unit_id = this.pre_unitid + "-10:" + IP_Aaddress;
			this.setResult(collResult, current_unit_id, "CM-00-02-001-01",
					DeviceType); // ??router
			this.setResult(collResult, current_unit_id, "CM-00-02-001-02",
					Vendor_Info);
			this.setResult(collResult, current_unit_id, "CM-00-02-001-03",
					SNMPDescription);
			this.setResult(collResult, current_unit_id, "CM-00-02-001-04",
					Node_Name);
			this.setResult(collResult, current_unit_id, "CM-00-02-001-05",
					IP_Aaddress);
		}

		for (int i = 0; i < List_NV_NODE_ENH_VIEW.size(); i++) {
			NV_NODE_ENH_VIEW obj = (NV_NODE_ENH_VIEW) List_NV_NODE_ENH_VIEW
					.get(i);
			String Interface_Name = obj.getInterface_Name();
			String IP_Aaddress = obj.getIP_Address();
			String SNMPInterfaceType = obj.getSNMPInterfaceType();
			String SNMPMacAddress = obj.getSNMPMacAddress();

			current_unit_id = this.pre_unitid + "-11:" + IP_Aaddress;

			this.setResult(collResult, current_unit_id, "CM-00-02-002-01",
					Interface_Name);
			this.setResult(collResult, current_unit_id, "CM-00-02-002-02",
					SNMPInterfaceType);
			this.setResult(collResult, current_unit_id, "CM-00-02-002-04",
					SNMPMacAddress);
			this.setResult(collResult, current_unit_id, "CM-00-02-002-05",
					IP_Aaddress);
		}

		for (int i = 0; i < List_NV_NODE_ENH_VIEW.size(); i++) {
			// CM-00-02-002-06 端口数量 网络设备配置各种类型端口的数目 计算
			NV_NODE_ENH_VIEW obj = (NV_NODE_ENH_VIEW) List_NV_NODE_ENH_VIEW
					.get(i);
			String Node_Name = obj.getNode_Name();
			String SNMPInterfaceType = obj.getSNMPInterfaceType();
			String str = Node_Name + "-" + SNMPInterfaceType + "-Number";

			if (map.containsKey(str)) {
				String temp = ((String) map.get(str)).substring(((String) map
						.get(str)).lastIndexOf("-") + 1);
				int num = Integer.parseInt(temp) + 1;
				map.put(str, str + "-" + num);
			} else {
				map.put(str, str + "-1");
				// System.out.println(str + "-1");
			}
		}

		Collection col = map.values();
		Iterator it = col.iterator();
		while (it.hasNext()) {
			current_unit_id = this.pre_unitid + "-11:";
			String value = (String) it.next();
			this.setResult(collResult, current_unit_id, "CM-00-02-002-06",
					value);
		}

		/*
		 * FM-00-02-001-01 网元状态 网络中各网元运行的UP/DOWN状态 node FM-00-02-001-02 设备端口状态
		 * 网元设备的各端口的状态 interface FM-00-02-001-03 网络链路状态
		 * 网络链路状态是通过网络设备状态间接获取。包含：链路通/断两种状态 link
		 */
		/*
		 * -10 -11 -11
		 */

		ALL_STATUSDao statusdao = new ALL_STATUSDao();
		String IPADDR = (String) params.get("IPADDR");
		List list_ALL_STATUS = statusdao.getALL_STATUS_BY_IPADDR(IPADDR);

		for (int i = 0; i < list_ALL_STATUS.size(); i++) {
			current_unit_id = this.pre_unitid;
			ALL_STATUS obj = (ALL_STATUS) list_ALL_STATUS.get(i);
			// String host_name = obj.getHOST_NAME();
			String host_name = "";
			String msgvalue = obj.getMSG();
			String msg = msgvalue.toUpperCase();
			if (msg.indexOf("NODE") > -1) {
				current_unit_id = current_unit_id + "-10" + host_name;
				if (msg.indexOf("UP") > -1 || msg.indexOf("DOWN") > -1) {
					this.setResult(collResult, current_unit_id,
							"FM-00-02-001-01", msgvalue);
				}
			} else {
				current_unit_id = current_unit_id + "-11" + host_name;
				if (msg.indexOf("UP") > -1 || msg.indexOf("DOWN") > -1) {
					this.setResult(collResult, current_unit_id,
							"FM-00-02-001-02", msgvalue);
				}
			}
		}

		return collResult;
	}

	private void setResult(Vector result, String unitID, String kpiID,
			String value) {
		try {
			TblATO_KPIDETAIL record;

			record = new TblATO_KPIDETAIL();
			record.setCLL_TIME(new Date());
			record.setKPI_ID(kpiID);
			record.setKPI_VALUE(value);
			record.setUNIT_ID(unitID);
			record.setCLL_TIME(new Date());
			result.add(record);
		} catch (Exception e) {

			e.printStackTrace();
		}
	}

	private void setResult(Vector result, String unitID, String kpiID,
			String value, Date date) {
		try {
			TblATO_KPIDETAIL record;

			record = new TblATO_KPIDETAIL();
			record.setCLL_TIME(new Date());
			record.setKPI_ID(kpiID);
			record.setKPI_VALUE(value);
			record.setUNIT_ID(unitID);
			record.setCLL_TIME(date);
			result.add(record);
		} catch (Exception e) {

			e.printStackTrace();
		}
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// x

	}

}