package com.sitech.ismp.coll.tivoli;

import java.math.BigDecimal;
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.COMPUTER_MEM_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.COMPUTER_MEM_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.itcm.HDISK_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.HDISK_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.itcm.IP_ADDR_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.IP_ADDR_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.itcm.NET_CARD_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.NET_CARD_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.itcm.PROCESSOR_NUM_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.PROCESSOR_NUM_VIEWDao;
import com.sitech.ismp.coll.tivoli.db.itcm.PROCESSOR_VIEW;
import com.sitech.ismp.coll.tivoli.db.itcm.PROCESSOR_VIEWDao;

/**
 * 
 * 从ITCM中获取所有主机的配置信息
 * 
 * 
 * @author winnerbao
 * 
 */
public class CollAllHDISK implements CollAllHDISKMBean {

	private String pre_unitid = "";

	public CollAllHDISK(String pre_unit_id) {
		this.pre_unitid = pre_unit_id;
	}

	/**
	 * 得到主机配置数据
	 * 
	 * 
	 * @param paramsVector
	 * @return
	 */
	public Vector getConfig(HashMap params)
			throws Exception {

		Vector collResult = new Vector();

		Vector vConfigFromCOMPUTER_VIEW = this.getConfigFromHDISK_VIEW(params);
		if (vConfigFromCOMPUTER_VIEW != null) {
			collResult.addAll(vConfigFromCOMPUTER_VIEW);
		}

		Vector vConfigFromIP_ADDR_VIEW = this.getConfigFromIP_ADDR_VIEW(params);
		if (vConfigFromIP_ADDR_VIEW != null) {
			collResult.addAll(vConfigFromIP_ADDR_VIEW);
		}

		Vector vConfigFromPROCESSOR_NUM_VIEW = this
				.getConfigFromPROCESSOR_RELATE_VIEW(params);
		if (vConfigFromPROCESSOR_NUM_VIEW != null) {
			collResult.addAll(vConfigFromPROCESSOR_NUM_VIEW);
		}

		Vector vConfigFromCOMPUTER_MEM_VIEW = this
				.getConfigFromCOMPUTER_MEM_VIEW(params);
		if (vConfigFromCOMPUTER_MEM_VIEW != null) {
			collResult.addAll(vConfigFromCOMPUTER_MEM_VIEW);
		}

		Vector vConfigFromNET_CARD_VIEW = this
				.getConfigFromNET_CARD_VIEW(params);
		if (vConfigFromNET_CARD_VIEW != null) {
			collResult.addAll(vConfigFromNET_CARD_VIEW);
		}

		return collResult;
	}

	/**
	 * 一行一个主机
	 * 
	 * @param params
	 * @return
	 */
	private Vector getConfigFromHDISK_VIEW(HashMap params) {

		Vector collResult = new Vector();

		// private String TME_OBJECT_LABEL ;//34 CM-00-01-01-01 主机名 主机的标识 TCM 获取
		// 得到数据 computer_query
		// private String COMPUTER_MODEL ;//36 CM-00-01-01-03 主机厂商 主机厂商 得到数据
		// computer_query
		// private String OS_SUB_VERS ;//41 CM-00-01-01-08 主机操作系统版本
		// 操作系统的版本号和位数（32/64） 得到数据 computer_query

		HDISK_VIEWDao dao = new HDISK_VIEWDao();

		// COMPUTER_VIEWDao dao = new COMPUTER_VIEWDao();
		String host_name = (String) params.get("HOST_NAME");
		List HDISK_views = dao.getHDISK_VIEW_BY_OBJECT(host_name);
		// List computer_views = dao.getAllCOMPUTER_VIEW();
		for (int i = 0; i < HDISK_views.size(); i++) {

			HDISK_VIEW hdisk = (HDISK_VIEW) HDISK_views.get(i);

			String TME_OBJECT_LABEL = hdisk.getTME_OBJECT_LABEL();
			String SER_NUM = hdisk.getSER_NUM();
			int HDISK_CYLINDERS = hdisk.getHDISK_CYLINDERS();

			Date RECORD_TIME = hdisk.getRECORD_TIME();

			// String COMPUTER_MODEL = computer.getCOMPUTER_MODEL();
			// String OS_SUB_VERS = computer.getOS_SUB_VERS();
			// Date RECORD_TIME = computer.getRECORD_TIME();

			String unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
					+ "-total";

			this.setResult(collResult, unit_id, "CM-00-01-001-01",
					TME_OBJECT_LABEL, RECORD_TIME);
			this.setResult(collResult, unit_id, "CM-00-01-001-03", SER_NUM,
					RECORD_TIME);
			this.setResult(collResult, unit_id, "CM-00-01-001-08", String
					.valueOf(HDISK_CYLINDERS), RECORD_TIME);

		}

		// begin 2006-7-6 lianlian CM-00-01-01-09
		List HDISK_TOTAL_SIZE = dao.getHDISK_TOTAL_SIZE_BY_OJBECT(host_name);
		for (int i = 0; i < HDISK_TOTAL_SIZE.size(); i++) {
			HDISK_VIEW hdisk = (HDISK_VIEW) HDISK_views.get(i);
			String TME_OBJECT_LABEL = hdisk.getTME_OBJECT_LABEL();
			int HDISK_TOTAL_SIZE_MB = hdisk.getHDISK_TOTAL_SIZE_MB();
			Date RECORD_TIME = hdisk.getRECORD_TIME();

			String unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
					+ "-total";

			this.setResult(collResult, unit_id, "CM-00-01-001-09", String
					.valueOf(HDISK_TOTAL_SIZE_MB), RECORD_TIME);
		}

		// end

		return collResult;
	}

	/**
	 * 一行一个ip 一个主机可能有多行
	 * 
	 * select的时候已经按照主机名称排序了
	 * 
	 * @param params
	 * @return
	 */
	private Vector getConfigFromIP_ADDR_VIEW(HashMap params) {

		String host_name = (String) params.get("HOST_NAME");
		Vector collResult = new Vector();

		// private String IP_ADDR ;//35 CM-00-01-01-02 主机地址 主机的IP地址(服务IP) 得到数据
		// ip_addr_query IP_ADDR_VIEW

		IP_ADDR_VIEWDao dao = new IP_ADDR_VIEWDao();

		List computer_views = dao.getIP_ADDR_VIEW_BY_OBJECT(host_name);

		String last_host = "";
		String current_host_ip = "";
		String current_unit_id = "";
		Date current_RECORD_TIME = null;
		for (int i = 0; i < computer_views.size(); i++) {

			IP_ADDR_VIEW obj = (IP_ADDR_VIEW) computer_views.get(i);

			String TME_OBJECT_LABEL = obj.getTME_OBJECT_LABEL();
			String IP_ADDR = obj.getIP_ADDR();
			current_RECORD_TIME = obj.getRECORD_TIME();

			current_unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
					+ "-total";
			String last_unit_id = this.pre_unitid + "-10:" + last_host
					+ "-total";

			if (TME_OBJECT_LABEL.equals(last_host)) {
				current_host_ip = current_host_ip + "," + IP_ADDR;
			} else {

				// 第一个元素
				if (last_host.length() == 0) {
					current_host_ip = IP_ADDR;
					last_host = TME_OBJECT_LABEL;
					continue;
				}

				// 上一台主机计算已完成
				this.setResult(collResult, last_unit_id, "CM-00-01-001-02",
						current_host_ip, current_RECORD_TIME);

				current_host_ip = IP_ADDR;
			}

			last_host = TME_OBJECT_LABEL;

		}
		this.setResult(collResult, current_unit_id, "CM-00-01-001-02",
				current_host_ip, current_RECORD_TIME);

		return collResult;
	}

	/**
	 * 一行一个网卡 一个主机可能有多行
	 * 
	 * select的时候已经按照主机名称排序了
	 * 
	 * @param params
	 * @return
	 */
	private Vector getConfigFromNET_CARD_VIEW(HashMap params) {

		String host_name = (String) params.get("HOST_NAME");
		Vector collResult = new Vector();

		// private String IP_ADDR ;//35 CM-00-01-01-02 主机地址 主机的IP地址(服务IP) 得到数据
		// ip_addr_query IP_ADDR_VIEW

		NET_CARD_VIEWDao dao = new NET_CARD_VIEWDao();
		List netcard_views = dao.getNET_CARD_VIEW_BY_OBJECT(host_name);

		List netcard_count_views = dao.getCARD_COUNT_BY_OBJECT(host_name);
		HashMap host_netcardnum = new HashMap();
		for (int i = 0; i < netcard_count_views.size(); i++) {
			HashMap countMap = (HashMap) netcard_count_views.get(i);
			String TME_OBJECT_LABEL = (String) countMap.get("TME_OBJECT_LABEL");
			BigDecimal netcard_count = (BigDecimal) countMap
					.get("NET_CARD_NUM");
			host_netcardnum.put(TME_OBJECT_LABEL, netcard_count);
		}

		String last_host = "";
		// String current_host = "";
		for (int i = 0; i < netcard_views.size(); i++) {

			NET_CARD_VIEW obj = (NET_CARD_VIEW) netcard_views.get(i);

			String TME_OBJECT_LABEL = obj.getTME_OBJECT_LABEL();
			String ADAPTER_MODEL = obj.getADAPTER_MODEL(); // 例如：Gigabit
			// Ethernet-SX PCI
			// Adapter
			// (14100401) [ent1]
			String PERM_MAC_ADDR = obj.getPERM_MAC_ADDR();
			Date RECORD_TIME = obj.getRECORD_TIME();

			String card_name = "NETCARD";// 截取ADAPTER_MODEL中中括号内的部分作为card名称[]
			try {
				int from = ADAPTER_MODEL.lastIndexOf('[');
				int to = ADAPTER_MODEL.lastIndexOf(']');
				card_name = ADAPTER_MODEL.substring(from + 1, to);
			} catch (Exception e) {
				e.printStackTrace();
			}
			String unit_id = this.pre_unitid + "-16:" + TME_OBJECT_LABEL + "-"
					+ card_name;
			this.setResult(collResult, unit_id, "CM-00-01-001-12",
					PERM_MAC_ADDR, RECORD_TIME);

			if (last_host.length() == 0) {
				// 第一次循环
				BigDecimal netcard_count = (BigDecimal) host_netcardnum
						.get(TME_OBJECT_LABEL);
				if (netcard_count != null) {
					this.setResult(collResult, this.pre_unitid + "-10:"
							+ TME_OBJECT_LABEL + "-total", "CM-00-01-001-10",
							netcard_count.toString(), RECORD_TIME);
				}
				last_host = TME_OBJECT_LABEL;
			} else if (!TME_OBJECT_LABEL.equals(last_host)) {
				BigDecimal netcard_count = (BigDecimal) host_netcardnum
						.get(TME_OBJECT_LABEL);
				this.setResult(collResult, this.pre_unitid + "-10:"
						+ TME_OBJECT_LABEL + "-total", "CM-00-01-001-10",
						netcard_count.toString(), RECORD_TIME);
				last_host = TME_OBJECT_LABEL;
			}

		}

		return collResult;
	}

	/**
	 * 一行一个处理器 一个主机可能有多行
	 * 
	 * select的时候已经按照主机名称排序了
	 * 
	 * @param params
	 * @return
	 */
	private Vector getConfigFromPROCESSOR_RELATE_VIEW(
			HashMap params) {

		String host_name = (String) params.get("HOST_NAME");
		Vector collResult = new Vector();

		// private String IP_ADDR ;//35 CM-00-01-01-02 主机地址 主机的IP地址(服务IP) 得到数据
		// ip_addr_query IP_ADDR_VIEW

		PROCESSOR_NUM_VIEWDao pNumDao = new PROCESSOR_NUM_VIEWDao();
		List pNumViews = pNumDao.getPROCESSOR_NUM_VIEW_BY_OBJECT(host_name);

		// initialize hostname , and processor cll time map
		PROCESSOR_VIEWDao pDao = new PROCESSOR_VIEWDao();
		List pViews = pDao.getPROCESSOR_VIEW_BY_OBJECT(host_name);
		HashMap host_clltime = new HashMap();
		for (int i = 0; i < pViews.size(); i++) {
			PROCESSOR_VIEW p = (PROCESSOR_VIEW) pViews.get(i);
			host_clltime.put(p.getTME_OBJECT_LABEL(), p.getRECORD_TIME());

			String TME_OBJECT_LABEL = p.getTME_OBJECT_LABEL();
			String PROCESSOR_MODEL = p.getPROCESSOR_MODEL();
			int PROCESSOR_SPEED = p.getPROCESSOR_SPEED();
			Date RECORD_TIME = p.getRECORD_TIME();

			String unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
					+ "-total";
			this.setResult(collResult, unit_id, "CM-00-01-001-05",
					PROCESSOR_MODEL, RECORD_TIME);
			this.setResult(collResult, unit_id, "CM-00-01-001-06", String
					.valueOf(PROCESSOR_SPEED), RECORD_TIME);
		}

		for (int i = 0; i < pNumViews.size(); i++) {

			PROCESSOR_NUM_VIEW p = (PROCESSOR_NUM_VIEW) pNumViews.get(i);

			String TME_OBJECT_LABEL = p.getTME_OBJECT_LABEL();
			int NUM_PROCESSOR = p.getNUM_PROCESSOR();
			Date RECORD_TIME = (Date) host_clltime.get(TME_OBJECT_LABEL);
			if (RECORD_TIME == null) {
				// if tivoli not get cll time , continue
				continue;
			} else {
				String unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
						+ "-total";
				this.setResult(collResult, unit_id, "CM-00-01-001-04", String
						.valueOf(NUM_PROCESSOR), RECORD_TIME);

			}
		}// end for

		return collResult;
	}

	/**
	 * 一行一个主机
	 * 
	 * select的时候已经按照主机名称排序了
	 * 
	 * @param params
	 * @return
	 */
	private Vector getConfigFromCOMPUTER_MEM_VIEW(
			HashMap params) {

		String host_name = (String) params.get("HOST_NAME");
		Vector collResult = new Vector();

		// private String IP_ADDR ;//35 CM-00-01-01-02 主机地址 主机的IP地址(服务IP) 得到数据
		// ip_addr_query IP_ADDR_VIEW

		COMPUTER_MEM_VIEWDao dao = new COMPUTER_MEM_VIEWDao();
		List result = dao.getCOMPUTER_MEM_VIEW_BY_OBJECT(host_name);

		for (int i = 0; i < result.size(); i++) {
			COMPUTER_MEM_VIEW p = (COMPUTER_MEM_VIEW) result.get(i);

			String TME_OBJECT_LABEL = p.getTME_OBJECT_LABEL();
			int PHYSICAL_TOTAL_MB = p.getPHYSICAL_TOTAL_MB();
			Date RECORD_TIME = p.getRECORD_TIME();

			String unit_id = this.pre_unitid + "-10:" + TME_OBJECT_LABEL
					+ "-total";
			this.setResult(collResult, unit_id, "CM-00-01-001-07", String
					.valueOf(PHYSICAL_TOTAL_MB), RECORD_TIME);
		}

		return collResult;
	}

	private void setResult(Vector result, String unitID, String kpiID,
			String value, Date cll_time) {
		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(cll_time);
			result.add(record);
		} catch (Exception e) {

			e.printStackTrace();
		}
	}

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

	}

}