package com.sitech.ismp.coll.tivoli;

import java.util.Date;
import java.util.HashMap;
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_INTERFACES;
import com.sitech.ismp.coll.tivoli.db.itcm.NV_INTERFACESDao;
import com.sitech.ismp.coll.tivoli.db.itcm.NV_NODES;
import com.sitech.ismp.coll.tivoli.db.itcm.NV_NODESDao;
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_INTERFACE_STATUS;
import com.sitech.ismp.coll.tivoli.db.netview.ALL_INTERFACE_STATUSDao;
import com.sitech.ismp.coll.tivoli.db.netview.SOFTWAREVERSION;
import com.sitech.ismp.coll.tivoli.db.netview.SOFTWAREVERSIONDao;
import com.sitech.ismp.coll.tivoli.db.tec.ALL_STATUS;
import com.sitech.ismp.coll.tivoli.db.tec.ALL_STATUSDao;
import com.sitech.util.Formater;

;

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

	private String pre_unitid = "10-13";

	public CollNetConfig() {
	}

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

		// PM-00-02-001-01 LAN（半双工）端口利用率 LAN端口利用率（百分比） BandwidthUtilHdx
		// PM-00-02-001-02 WAN（全双工）端口流入利用率率 WAN端口的流入利用率（百分比） BandwidthUtilIn
		// PM-00-02-001-03 WAN（全双工）端口流出利用率率 WAN端口的流出利用率（百分比） BandwidthUtilOut
		// PM-00-02-001-04 端口误码率 端口误码率（百分比）（1） ifTotalErrorRate
		// PM-00-02-001-05 端口丢包率 端口丢包率（百分比） ifTotalDiscardsRate
		// lianlian 2006-8-23
		String current_unit_id = this.pre_unitid;

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

		ALL_EFFICIENCYDao EFFICIENCY_dao = new ALL_EFFICIENCYDao();
		List list_INTERFACE_EFFICIENCY = EFFICIENCY_dao
				.getINTERFACE_INFO_BY_IPADDR(IPADDR);

		if (list_INTERFACE_EFFICIENCY == null) {
			System.out
					.println("@tivoli , no interface info got by tivoli in getConfigFromTEMP_COLLDATA "
							+ new Date());
		} else {
			for (int i = 0; i < list_INTERFACE_EFFICIENCY.size(); i++) {
				ALL_EFFICIENCY obj = (ALL_EFFICIENCY) list_INTERFACE_EFFICIENCY
						.get(i);
				String expname = obj.getEXPNAME();
				String hostname = obj.getHOSTNAME();
				String instance = obj.getINSTANCE();
				Date date = obj.getCOLLECTTIME();
				double value = obj.getFLOATVALUE();

				if (expname.equalsIgnoreCase("BandwidthUtilHdx")) {
					String strvalue = Formater.getByScale(
							String.valueOf(value), 2);
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "PM-00-02-001-01", strvalue);
				} else if (expname.equalsIgnoreCase("BandwidthUtilIn")) {
					String strvalue = Formater.getByScale(
							String.valueOf(value), 2);
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "PM-00-02-001-02", strvalue);
				} else if (expname.equalsIgnoreCase("BandwidthUtilOut")) {
					String strvalue = Formater.getByScale(
							String.valueOf(value), 2);
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "PM-00-02-001-03", strvalue);
				} else if (expname.equalsIgnoreCase("ifTotalErrorRate")) {
					String strvalue = Formater.getByScale(
							String.valueOf(value), 2);
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "PM-00-02-001-04", strvalue);
				} else {
					String strvalue = Formater.getByScale(
							String.valueOf(value), 2);
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "PM-00-02-001-05", strvalue);
				}

			}
		}

		/**
		 * PM-00-02-001-06 设备CPU利用率 网络设备CPU利用率（百分比） busyPer
		 * 黑龙江此指标不需要采集PM-00-02-001-08 设备缓存利用率 网络设备缓存利用率（百分比） bufferElFreeRate
		 * lianlian 2006-08-23
		 */

		List list_NODE_EFFICIENCY = EFFICIENCY_dao
				.getNODE_INFO_BY_IPADDR(IPADDR);

		if (list_NODE_EFFICIENCY == null) {
			System.out
					.println("@tivoli , no node info got by tivoli in getConfigFromTEMP_COLLDATA "
							+ new Date());
		} else {
			for (int i = 0; i < list_NODE_EFFICIENCY.size(); i++) {
				ALL_EFFICIENCY obj = (ALL_EFFICIENCY) list_NODE_EFFICIENCY
						.get(i);
				String varid = obj.getVARID();
				String expname = obj.getEXPNAME();
				double value = obj.getFLOATVALUE();

				String strvalue = Formater.getByScale(String.valueOf(value), 2);
				this.setResult(collResult, current_unit_id + "-10" + ":"
						+ DEVICEID + "_" + IPADDR, "PM-00-02-001-06", strvalue);
			}
		}

		/**
		 * 黑龙江此指标不需要采集PM-00-02-001-07 设备内存利用率 网络设备内存利用率（百分比）
		 */
		List list_MEMORY_EFFICIENCY = EFFICIENCY_dao
				.getINTERFACE_EFFICIENCY_BY_IPADDR(IPADDR);
		{
			if (list_MEMORY_EFFICIENCY == null
					|| list_MEMORY_EFFICIENCY.size() == 0) {
				System.out
						.println("@tivoli , no node info got by tivoli in getINTERFACE_EFFICIENCY_BY_IPADDR "
								+ new Date());
			} else {
				double MemoryPoolUsed = 0.0;
				double MemoryPoolFree = 0.0;
				double dvalue = 0.0;
				for (int i = 0; i < list_MEMORY_EFFICIENCY.size(); i++) {
					ALL_EFFICIENCY obj = (ALL_EFFICIENCY) list_MEMORY_EFFICIENCY
							.get(i);
					String varid = obj.getVARID();
					double value = obj.getFLOATVALUE();
					if (varid.equalsIgnoreCase(".1.3.6.1.4.1.9.9.48.1.1.1.5")) {
						MemoryPoolUsed = MemoryPoolUsed + value;
					} else {
						MemoryPoolFree = MemoryPoolFree + value;
					}
				}
				dvalue = MemoryPoolUsed / (MemoryPoolUsed + MemoryPoolFree);
				String strvalue = Formater
						.getByScale(String.valueOf(dvalue), 2);
				this.setResult(collResult, current_unit_id + "-10" + ":"
						+ DEVICEID + "_" + IPADDR, "PM-00-02-001-07", strvalue);
			}
		}

		return collResult;
	}

	public Vector getFailure(HashMap params)
			throws Exception {
		Vector collResult = new Vector();
		Vector v = this.getConfigFormTEC_T_EVT_REP(params);
		if (v != null) {
			collResult.addAll(v);
		}
		return collResult;
	}

	public Vector getConfiguration(HashMap params)
			throws Exception {

		Vector collResult = new Vector();
		String IPADDR = (String) params.get("IP_ADDR");
		String IP_HOSTNAME = (String) params.get("IP_ADDR");
		String DEVICEID = (String) params.get("DEVICEID");
		String current_unit_id = this.pre_unitid;

		/**
		 * CM-00-02-001-01 网元类型 网络中各种设备的类型；包括：路由器、交换机、第二层交换机、专用防火墙等，以及其产品序列号等属性
		 * CM-00-02-001-02 网元厂商 网络中各种类型设备供应商 CM-00-02-001-03 设备软件版本
		 * 网元设备当前安装的软件版本号 CM-00-02-001-04 网元名 网元配置名称，或由名字解析、DNS服务解释的名称
		 * CM-00-02-001-05 网元IP地址 网元管理端口IP地址 lianlian 2006-09-28
		 */
		NV_NODESDao nvnodesdao = new NV_NODESDao();
		List list_nvnodes = nvnodesdao
				.getNODEINFO_FROM_NV_NODES_BY_IP_HOSTNAME(IP_HOSTNAME);
		if (list_nvnodes == null || list_nvnodes.size() == 0) {
			System.out
					.println("@tivoli , no node info got by tivoli in getConfigFormNV_NODES "
							+ new Date());
		} else {
			NV_NODES obj = (NV_NODES) list_nvnodes.get(0);
			String ip_hostname = obj.getIP_HOSTNAME();
			String smp_sysdescr = obj.getSNMP_SYSDESCR();
			String vendor = obj.getVENDOR();
			String iscomputer = String.valueOf(obj.getISCOMPUTER());
			String isbridge = String.valueOf(obj.getISBRIDGE());
			String isrouter = String.valueOf(obj.getISROUTER());
			String devicetype = this.getDeviceType(isrouter + isbridge
					+ iscomputer);

			// String current_unit_id=this.pre_unitid;
			this.setResult(collResult, current_unit_id + "-10" + ":" + DEVICEID
					+ "_" + IP_HOSTNAME, "CM-00-02-001-01", devicetype);
			this.setResult(collResult, current_unit_id + "-10" + ":" + DEVICEID
					+ "_" + IP_HOSTNAME, "CM-00-02-001-02", vendor);
			// this.setResult(collResult,
			// current_unit_id+"-10"+":"+DRIVERID+"-"+IP_HOSTNAME,
			// "CM-00-02-001-03" , smp_sysdescr);
			this.setResult(collResult, current_unit_id + "-10" + ":" + DEVICEID
					+ "_" + IP_HOSTNAME, "CM-00-02-001-04", ip_hostname);
			this.setResult(collResult, current_unit_id + "-10" + ":" + DEVICEID
					+ "_" + IP_HOSTNAME, "CM-00-02-001-05", ip_hostname);
		}

		SOFTWAREVERSIONDao softdao = new SOFTWAREVERSIONDao();
		List list_softdao = softdao.getSOFTWAREVERSION(IP_HOSTNAME);
		if (list_softdao == null || list_softdao.size() == 0) {
			System.out
					.println("@tivoli , no node info got by tivoli in getSOFTWAREVERSION "
							+ new Date());
		} else {
			// String current_unit_id=this.pre_unitid;
			SOFTWAREVERSION obj = (SOFTWAREVERSION) list_softdao.get(0);
			String snmp_sysdescr = obj.getSNMP_SYSDESCR();
			this.setResult(collResult, current_unit_id + "-10" + ":" + DEVICEID
					+ "_" + IP_HOSTNAME, "CM-00-02-001-03", snmp_sysdescr);
		}

		/**
		 * CM-00-02-002-01 端口标识 网元设备的每个端口的唯一标识名或ID号 CM-00-02-002-02 端口类型
		 * 网络设备配置的端口模块类型；包括：以太网口、串口等 CM-00-02-002-03 端口设置速率 网络设备各端口的最大速率（kbps）
		 * CM-00-02-002-04 端口物理地址 网络设备端口固化的物理地址 CM-00-02-002-05 端口IP地址
		 * 网络设备端口配置的IP地址以及其掩码 CM-00-02-002-06 端口数量 网络设备配置各种类型端口的数目 计算 lianlian
		 * 2006-8-23
		 */
		NV_INTERFACESDao nvinterfacedao = new NV_INTERFACESDao();
		List list_nvinterface = nvinterfacedao
				.getINTERFACEINFO_FROM_NV_INTERFACES_BY_IP_ADDRESS(IP_HOSTNAME);
		if (list_nvinterface == null || list_nvinterface.size() == 0) {
			System.out
					.println("@tivoli , no node info got by tivoli in getINTERFACEINFO_FROM_NV_INTERFACES_BY_IP_ADDRESS "
							+ new Date());
		} else {
			// String current_unit_id=this.pre_unitid;
			for (int i = 0; i < list_nvinterface.size(); i++) {
				NV_INTERFACES obj = (NV_INTERFACES) list_nvinterface.get(i);
				String ip_address = obj.getIP_ADDRESS();
				String snmp_ifdescr = obj.getSNMP_IFDESCR();
				String snmp_ifphysaddr = obj.getSNMP_IFPHYSADDR();
				String snmp_iftype = obj.getSNMP_IFTYPE();
				int instance = obj.getINSTANCE();

				this.setResult(collResult, current_unit_id + "-11" + ":"
						+ DEVICEID + "_" + IPADDR + "-interface-" + instance,
						"CM-00-02-002-01", snmp_ifdescr);
				this.setResult(collResult, current_unit_id + "-11" + ":"
						+ DEVICEID + "_" + IPADDR + "-interface-" + instance,
						"CM-00-02-002-02", snmp_iftype);
				this.setResult(collResult, current_unit_id + "-11" + ":"
						+ DEVICEID + "_" + IPADDR + "-interface-" + instance,
						"CM-00-02-002-04", snmp_ifphysaddr);
				this.setResult(collResult, current_unit_id + "-11" + ":"
						+ DEVICEID + "_" + IPADDR + "-interface-" + instance,
						"CM-00-02-002-05", ip_address);
			}
		}

		ALL_EFFICIENCYDao EFFICIENCY_dao = new ALL_EFFICIENCYDao();
		List list_INTERFACE_KBPS = EFFICIENCY_dao
				.getINTERFACE_KBPS_BY_IPADDR(IPADDR);
		if (list_INTERFACE_KBPS == null || list_INTERFACE_KBPS.size() == 0) {
			System.out
					.println("@tivoli , no node info got by tivoli in getINTERFACE_KBPS_BY_IPADDR "
							+ new Date());
		} else {
			for (int i = 0; i < list_INTERFACE_KBPS.size(); i++) {
				ALL_EFFICIENCY obj = (ALL_EFFICIENCY) list_INTERFACE_KBPS
						.get(i);
				String varid = obj.getVARID();
				String instance = obj.getINSTANCE();
				double floatvalue = obj.getFLOATVALUE();
				String strvalue = Formater.getByScale(String
						.valueOf(floatvalue), 0);
				if (varid.equalsIgnoreCase(".1.3.6.1.2.1.2.2.1.5")) {
					this.setResult(collResult, current_unit_id + "-11" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-"
							+ instance, "CM-00-02-002-03", strvalue);
				} else {
					this.setResult(collResult, current_unit_id + "-10" + ":"
							+ DEVICEID + "_" + IPADDR + "-interface-number",
							"CM-00-02-002-06", strvalue);
				}
			}
		}

		return collResult;
	}

	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";
	}

	/**
	 * FM-00-02-001-01 网元状态 网络中各网元运行的UP/DOWN状态 FM-00-02-001-02 设备端口状态
	 * 网元设备的各端口的状态 FM-00-02-001-03 网络链路状态 lianlian 2006-08-21
	 */
	private Vector getConfigFormTEC_T_EVT_REP(HashMap params) {
		Vector collResult = new Vector();
		HashMap map = new HashMap();

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

		// 2006-12-05 lianlian 修改
		// 原因：由于IBM无法将采集到的告警中文信息放入到数据库中，暂时此指标用原sitech网络采集程序采集。
		// 待中文问题解决后可启用此方法。或者改为EIF接口。
		if (list_ALL_STATUS == null || list_ALL_STATUS.size() == 0) {
			System.out
					.println("@tivoli , no node and interface info got by tivoli in getConfigFormTEC_T_EVT_REP "
							+ new Date());
		} else {
			for (int i = 0; i < list_ALL_STATUS.size(); i++) {
				ALL_STATUS obj = (ALL_STATUS) list_ALL_STATUS.get(i);
				String strclass = obj.getCLASS();
				String hostname = obj.getHOSTNAME();
				// Date date = obj.getLAST_MODIFIED_TIME();
				String msg = obj.getMSG().toUpperCase();
				if (strclass.equalsIgnoreCase("TEC_ITS_NODE_STATUS")
						|| strclass.equalsIgnoreCase("TEC_ITS_ROUTER_STATUS")
						|| strclass.equalsIgnoreCase("TEC_ITS_SERVER_STATUS")) {
					// 网元状态
					current_unit_id = this.pre_unitid + "-10" + ":" + DEVICEID
							+ "_" + hostname;
					if (msg.indexOf("UP") > -1) {
						this.setResult(collResult, current_unit_id,
								"FM-00-02-001-01", "UP");
					} else if (msg.indexOf("DOWN") > -1) {
						this.setResult(collResult, current_unit_id,
								"FM-00-02-001-01", "DOWN");
					}
				}
			}
		}

		/**
		 * FM-00-02-001-02 设备端口状态 网元设备的各端口的状态
		 */
		ALL_INTERFACE_STATUSDao all_interface_statusdao = new ALL_INTERFACE_STATUSDao();
		List list_interface_statusdao = all_interface_statusdao
				.getINTERFACE_STATUS_BY_IPADDR(IPADDR);
		if (list_interface_statusdao == null
				|| list_interface_statusdao.size() == 0) {

		} else {
			current_unit_id = this.pre_unitid + "-10" + ":" + DEVICEID;
			String interfacestatuc = "";
			for (int i = 0; i < list_interface_statusdao.size(); i++) {
				ALL_INTERFACE_STATUS obj = (ALL_INTERFACE_STATUS) list_interface_statusdao
						.get(i);
				String instance = obj.getINSTANCE();
				String host_name = obj.getHOSTNAME();
				int floatvalue = obj.getFLOATVALUE();
				interfacestatuc = this.getInterfaceStatus(floatvalue);
				this.setResult(collResult, "10-13-11:" + DEVICEID + "_"
						+ IPADDR + "-interface-" + instance, "FM-00-02-001-02",
						interfacestatuc);
			}
		}

		/**
		 * FM-00-02-001-03 网络链路状态
		 */
		List list_LINK_STATUS = statusdao.getLINK_STATUS_BY_IPADDR(IPADDR);
		if (list_LINK_STATUS == null || list_LINK_STATUS.size() == 0) {
			this.setResult(collResult, this.pre_unitid + "-10" + ":" + DEVICEID
					+ "_" + IPADDR + "-total", "FM-00-02-001-03", "UNKNOW");
		} else {
			for (int j = 0; j < list_LINK_STATUS.size(); j++) {
				ALL_STATUS linkobj = (ALL_STATUS) list_LINK_STATUS.get(j);
				String linkmsg = linkobj.getMSG();
				this.setResult(collResult, this.pre_unitid + "-10" + ":"
						+ DEVICEID + "_" + IPADDR + "-total",
						"FM-00-02-001-03", linkmsg);
			}
		}
		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();
		}
	}

	private String getInterfaceStatus(int i) {
		String interfacestatus = "";
		switch (i) {
		case 1:
			interfacestatus = "UP";
			break;
		case 2:
			interfacestatus = "DOWN";
			break;
		case 3:
			interfacestatus = "TESTING";
			break;
		case 4:
			interfacestatus = "UNKOWN";
			break;
		case 5:
			interfacestatus = "DORMANT";
		default:
			break;
		}
		return interfacestatus;
	}

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

		CollNetConfigMBean netconfig = new CollNetConfig();
		HashMap params = new HashMap();
		String IP_ADDR = "10.110.5.196";
		// String IP_ADDR = "10.109.231.3";
		params.put("IP_ADDR", IP_ADDR);
		params.put("DEVICEID", "DEVICEID-" + IP_ADDR);
		Vector v = new Vector();
		v.addAll(netconfig.getConfiguration(params));
		v.addAll(netconfig.getPerformance(params));
		v.addAll(netconfig.getFailure(params));
		String temp[][] = CheckKPIHelper.Check_Net_KPI(v);
		for (int i = 0; i < temp.length; i++) {
			System.out.println("KPI_ID : " + temp[i][0] + "---" + temp[i][1]);
		}
		// String filename = "NetKPIValue.xls";
		// CheckKPIHelper.Write_KPIValue2File(v,filename);
	}

}