package com.sitech.ismp.coll.middleware.weblogic.impl;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.adventnet.snmp.beans.SnmpTarget;
import com.adventnet.snmp.snmp2.SnmpOID;
import com.sitech.ismp.coll.CollBase;
import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import org.springframework.util.CollectionUtils;

public class CollWeblogic8WithSNMP implements ICollWebLogic {
	
	static Logger logger = Logger.getLogger("LOGER");

	SnmpTarget target = null;
	private boolean DEBUG = false;
	private String servicename = "";

    public Vector<TblATO_KPIDETAIL> getStatus(HashMap<String, String> params) {
        return null;
    }

	/**
	 * 服务器运行状态
	 * 
	 */
	public Vector<TblATO_KPIDETAIL>  collRunState(HashMap<String, String> params) {
		String unitID = "10-12-11-11-10:"; // update by 2006-9-12 in
		// 10-12-11-11-13
		String hostName = "";
		String domainName = "";
		boolean bool = true;
		String logPath = "";
		String serverName = "";
        String serverip = (String) params.get("SERVERIP");
        CollBase collResult = new CollBase();
        init(params);
		try {
//			Vector vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45",
//					false); // domain name
//			String[] domain = ((String) vc_Domain.elementAt(0)).split("/");
//			domainName = domain[domain.length - 2]; // get Domain
//
//			Vector vc_hostName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.70",
//					false); // host name
//			hostName = (String) vc_hostName.elementAt(0);
			unitID = unitID + serverip + "-" + this.servicename + "-RunState";
			// hostName + "-" + domainName + "-" + "RunState";

			Vector stateRun = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.60", bool);// logPath
			// and
			// logFileName

			String state = (String) stateRun.elementAt(0);
			if (state != null && state.length() > 0
					&& state.toUpperCase().equals("RUNNING")) {
				state = "UP";
			} else {
				state = "DOWN";
			}
			if (stateRun.size() > 0) {
                collResult.addKPI(unitID, "FM-00-04-001-01",state);
				//setResult(state, unitID, "FM-00-04-001-01");
			}

		} catch (Exception e) {
			logger.error("collRunState fail", e);
		}
        return collResult.KPISet;
	}

	/**
	 * @author pc103
	 * @date 2006-07-21
	 * @param oid
	 * @param bool
	 * @return vector 参数说明书： oid-----对应weblogic控制台监控的性能指标id(关键) bool----无多大用处
	 *         功能：储存各采集结果 返回类型：vector
	 * 
	 */
	public Vector<String> walkKPIInfo(String oid, boolean bool) {
		Vector<String> tmp_result = new Vector<String>();
		try {
			Vector<String> tmp_oid = new Vector<String>();
			target.setObjectID(oid);
			target.oidList[0] = new SnmpOID(oid);
			int maxtry = 0;
			SnmpOID[] oidList = target.getSnmpOIDList();
			if (oidList == null) {
				System.out.println("oidList is null");
				return null;
			} else {
				SnmpOID rootoid = oidList[0];
				SnmpOID curroid = null;
				while (maxtry++ < 3000) {
					String result1[] = target.snmpGetNextList();
					if (result1 == null) {
						target.oidList[0] = curroid;
						continue;
					}
					if (!SnmpTarget.isInSubTree(rootoid, target.getSnmpOID()))
						break;
					for (int i = 0; i < result1.length; i++) {
						tmp_result.add(result1[i]);
						tmp_oid.add(target.getObjectID(i));
					}
					if (result1[0].compareTo("NULL") == 0)
						break;
				}
				if (maxtry == 1) {
					System.err
							.println("Request failed, timed out or no available data("
									+ oid + "). \n " + target.getErrorString());
				}
			}
		} catch (Exception e) {
			logger.error("walkKPIInfo fail", e);
		}
		return tmp_result;
	}

	/**
	 * @exception
	 * @express 建立与weblogic8.0的初始连接,特别注意port指的是weblogic的snmp的port，并非weblogic所开服务监听的port
	 */
	private void init(HashMap<String, String> params) {
		try {
			String serverip = (String) params.get("SERVERIP");
			int port = Integer.parseInt((String) params.get("PORT"));
			String snmp_version = (String) params.get("SNMPV");
			String community = (String) params.get("COMMUNITY");
			servicename = (String) params.get("SERVERNAME");
			
			target = new SnmpTarget();
			// target.setLoadFromCompiledMibs(true);
			target.setDebug(DEBUG);
			if (snmp_version.equals("1")) {
				target.setSnmpVersion(SnmpTarget.VERSION1);
			} else if (snmp_version.equals("2")) {
				target.setSnmpVersion(SnmpTarget.VERSION2C);
			} else if (snmp_version.equals("3")) {
				target.setSnmpVersion(SnmpTarget.VERSION3);
			}
			target.setTargetHost(serverip); // set the agent hostname
			target.setCommunity(community.trim());
			/**
			 * 关于weblogic多服务器情况下，如何采集不同的server的值的方法，主要就是设置COMMUNITY的值
			 * 在这个我以admin server with clustered servers的情况来说明
			 * domain name = mydomain2，administrtation server = myserver, managed server = server1
			 * 1.如果取myserver的相关的OID的值，COMMUNITY = "public"
			 * 2.如果取server1的相关的OID的值，COMMUNITY = "public@server1"
			 * 3.如果取整个domain的所有server的相关的OID的值，COMMUNITY = "public@mydomain2"
			 */
			target.setTargetPort(port);
		} catch (Exception e) {
			logger.error(params+"weblogic8 init fail", e);
		}
	}

	/**
	 * 释放initWeblogic(String weblogicip,String servername,int port, String hostname,String community)申请的资源
	 */
	public void release() {
		if (target != null) {
			target.releaseResources();
		}
	}

	public static void main(String[] argv) {
		CollWeblogic8WithSNMP web = new CollWeblogic8WithSNMP();
		HashMap<String, String> params = new HashMap<String, String>();
		params.put("SERVERIP", "172.21.0.203");
		params.put("PORT", "161");
		params.put("SNMPV", "2");
		params.put("SERVERNAME", "BOSS");
		params.put("COMMUNITY", "public");
		//Vector<TblATO_KPIDETAIL> vector_ds = web.getJMS(params);
       // Vector<TblATO_KPIDETAIL> vector_ds = web.collRunState(params);
        Vector<TblATO_KPIDETAIL> vector_ds = web.getExecuteQueue(params);
		for (int i = 0; i < vector_ds.size(); i++) {
			TblATO_KPIDETAIL ato = (TblATO_KPIDETAIL) vector_ds.get(i);
			System.out.println(ato.UNIT_ID + " | " + ato.KPI_ID + " | " + ato.KPI_VALUE + " | " + ato.CLL_TIME);
		}
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getExecuteQueue(HashMap<String, String> params) {
		logger.info("Begin getExecuteQueue...");
		init(params);
		// 消息队列
		String unitId = "10-12-11-15:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Execute_Queue = walkKPIInfo(".1.3.6.1.4.1.140.625.180", false);
			int count = vc_Execute_Queue.size() / 10;
			for (int i = 0; i < count; i++) {
				String execqueuename = vc_Execute_Queue.get(i + count * 3);
				String executethreadcurrentidlecount = vc_Execute_Queue.get(i + count * 5);
				String servicedrequesttotalcount = vc_Execute_Queue.get(i + count * 8);
				String pendingrequestcurrentcount = vc_Execute_Queue.get(i + count * 7);
				String _unitId = unitId + execqueuename;
				collResult.addKPI(_unitId, "CM-00-04-009-17", execqueuename);
				collResult.addKPI(_unitId, "PM-00-05-009-27", executethreadcurrentidlecount);
				collResult.addKPI(_unitId, "PM-00-05-009-26", servicedrequesttotalcount);
				collResult.addKPI(_unitId, "PM-00-05-009-29", pendingrequestcurrentcount);
			}
		} catch (Exception e) {
			logger.error(params+"getExecuteQueue fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getJDBC(HashMap<String, String> params) {
		logger.info("Begin getJDBC...");
		CollBase collResult = new CollBase();
		collResult.addKPISet(getjdbcConnectionPoolMaxCapacity(params));
		collResult.addKPISet(getJdbcPoolUseRate(params));
		collResult.addKPISet(getjdbcConnectionPoolActiveConnectionsCurrentCount(params));
		return collResult.KPISet;
	}

	/**
	 * JDBC连接池的最大容量: 1.3.6.1.4.1.140.625.190.1.15
	 * CM-00-04-003-04 配置的数据库连接池大小
	 * @return 
	 */
	private Vector<TblATO_KPIDETAIL> getjdbcConnectionPoolMaxCapacity(HashMap<String, String> params) {
		logger.info("Begin getjdbcConnectionPoolMaxCapacity...");
		init(params);
		// JDBC连接池
		String unitId = "10-12-11-13:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		
//		String connPoolName = "";
		String connDomain = "";
//		String connServerName = "";
//		String hostName = "";
		String count[] = null;
		int i = 0;
		int j = 0;
		try {
			Vector<String> vc_Max = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.60", false);
			count = new String[vc_Max.size()];
			for (Iterator tt = vc_Max.iterator(); tt.hasNext();) {
				count[i] = (String) tt.next();
				i++;
			}
			// connPool Name
			Vector<String> vc_ConnPollName = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.15", false);
			// domain name
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false);
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			connDomain = domain[domain.length - 2];
			/*if(!CollectionUtils.isEmpty(vc_Domain)){
				String[] domain = ((String) vc_Domain.elementAt(0)).split("/");
				connDomain = domain[domain.length - 2];
			}else {
				logger.info(params+"domain is empty!");
			}*/
			// server name.
//			Vector<String> vc_ServerName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.15.32", false);
//			connServerName = (String) vc_ServerName.elementAt(0);
			// host name
//			Vector<String> vc_hostName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.70", false);
//			hostName = (String) vc_hostName.elementAt(0);
			for (Iterator connName = vc_ConnPollName.iterator(); connName.hasNext();) {
				String temp = (String) connName.next();
				String _unitId = unitId + connDomain + "-" + temp;
				collResult.addKPI(_unitId, "CM-00-04-003-04", count[j]);
				j++;
			}
		} catch (Exception e) {
			logger.error(params+"getjdbcConnectionPoolMaxCapacity fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	/**
	 * 1. JDBC 连接池的连接使用率=JDBC连接池的已经激活的连接数/JDBC连接池的最大容量*100
	 * 		(.1.3.6.1.4.1.140.625.190.1.25) * 100F/(.1.3.6.1.4.1.140.625.190.1.60)
	 * 2. JDBC连接池的已经激活的连接数:.1.3.6.1.4.1.140.625.190.1.25
	 * 3. JDBC连接池的最大容量:.1.3.6.1.4.1.140.625.190.1.60
	 */
	private Vector<TblATO_KPIDETAIL> getJdbcPoolUseRate(HashMap<String, String> params) {
		logger.info("Begin getJdbcPoolUseRate...");
		init(params);
		// JDBC连接池
		String unitId = "10-12-11-13:" + this.servicename + "-";
		CollBase collResult = new CollBase();

		try {
//			String connPoolName = "";
			String connDomain = "";
//			String connServerName = "";
//			String hostName = "";
			String[] max_ = null;
			String[] active_ = null;
			Vector<String> vc_Max = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.60", false);
			// connPool Name
			Vector<String> vc_ConnPollName = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.15", false);
			// domain name
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false);
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			// get Domain
			connDomain = domain[domain.length - 2];
			// server name
			Vector<String> vc_ServerName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.15.32", false);
			String[] connName = new String[vc_ConnPollName.size()];
			int m = 0;
			for (Iterator itera = vc_ConnPollName.iterator(); itera.hasNext();) {
				connName[m] = itera.next().toString();
				m++;
			}
//			connServerName = (String) vc_ServerName.elementAt(0);
//			Vector vc_hostName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.70", false); // host name
//			hostName = (String) vc_hostName.elementAt(0);
			max_ = new String[vc_Max.size()];
			int i = 0;
			int j = 0;
			if (vc_Max.size() > 0) {
				int Max_num = Integer.parseInt(((String) vc_Max.elementAt(0)).trim());// get max conn count
				Vector<String> vc_Active = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.25", false);
				active_ = new String[vc_Active.size()];
				for (Iterator active = vc_Active.iterator(); active.hasNext();) {
					active_[i] = (String) active.next();
					i++;
				}
				for (Iterator max = vc_Max.iterator(); max.hasNext();) {
					max_[j] = (String) max.next();
					j++;
				}
				if (vc_Active.size() > 0) {
					int Active_num = Integer.parseInt(((String) vc_Active.elementAt(0)).trim());// get active conn count
					float userate = 0;
					if (Max_num != 0) {
						for (int k = 0, l = 0; k < max_.length; k++) {
							String _unitID = unitId + connDomain + "-" + connName[k];
							userate = Float.parseFloat(active_[k]) * 100F / Float.parseFloat(max_[k]);
							collResult.addKPI(_unitID, "PM-00-04-003-02", String.valueOf(userate));
							collResult.addKPI(_unitID, "CM-00-04-001-17", connName[k]);
						}
					}
				}
			}
		} catch (Exception e) {
			logger.error(params+"getJdbcPoolUseRate fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	/**
	 * JDBC 连接池的已经激活的连接数: .1.3.6.1.4.1.140.625.190.1.25
	 */
	private Vector<TblATO_KPIDETAIL> getjdbcConnectionPoolActiveConnectionsCurrentCount(HashMap<String, String> params) {
		logger.info("Begin getjdbcConnectionPoolActiveConnectionsCurrentCount...");
		init(params);
		// JDBC连接池
		String unitId = "10-12-11-13:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
	//		String connDomain = "";
	//		String connServerName = "";
	//		String hostName = "";
	//		String[] active = null;
			Vector<String> vc_active = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.25", true);
			// connPool Name
			Vector<String> vc_ConnPollName = walkKPIInfo(".1.3.6.1.4.1.140.625.190.1.15", false);
			int k = 0;
	
			String[] active = new String[vc_active.size()];
			for (Iterator activee = vc_active.iterator(); activee.hasNext();) {
				active[k] = (String) activee.next();
				k++;
			}
	
			int j = 0;
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain
			// name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String connDomain = domain[domain.length - 2]; // get Domain
	//		Vector<String> vc_ServerName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.15.32", false); // server name.
	//		connServerName = (String) vc_ServerName.elementAt(0);
	//		Vector vc_hostName = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.70", false); // host
			// name
	//		hostName = (String) vc_hostName.elementAt(0);
			for (Iterator connName = vc_ConnPollName.iterator(); connName.hasNext();) {
				String temp = (String) connName.next();
				String _unitID = unitId + connDomain + "-" + temp;
				collResult.addKPI(_unitID, "PM-00-04-003-03", active[j]);
				j++;
			}
		} catch (Exception e) {
			logger.error(params+"getjdbcConnectionPoolActiveConnectionsCurrentCount fail", e);
		} finally {
			release();
		}
		
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getJMS(HashMap<String, String> params) {
		logger.info("Begin getJMS...");
		init(params);
		// JMS消息队列
		String unitId = "10-12-11-16:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-";
			Vector<String> vc_Jms = walkKPIInfo(".1.3.6.1.4.1.140.625.610.1", false); // JMS name
			int count = vc_Jms.size() / 16;
			for (int i = 0; i < count; i++) {
				String jmsname = vc_Jms.get(i + count * 3);
				String jndiname = vc_Jms.get(i + count * 5);
				String cliendid = vc_Jms.get(i + count * 6);
				String _unitId = unitId + jmsname;
				collResult.addKPI(_unitId, "CM-00-05-009-22", jmsname);
				collResult.addKPI(_unitId, "CM-00-05-009-28", jndiname);
				collResult.addKPI(_unitId, "CM-00-05-009-29", cliendid);
			}
		} catch (Exception e) {
			logger.error(params+"getJMS fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getJVM(HashMap<String, String> params) {
		logger.info("Begin getJVM...");
		CollBase collResult = new CollBase();
		collResult.addKPISet(getJVMMEM(params));
		collResult.addKPISet(getFreeJVMMEM(params));
		collResult.addKPISet(getUsedJVMMEM(params));
		collResult.addKPISet(getJVMMEMUseRate(params));
		return collResult.KPISet;
	}

	/**
	 * 当前JVM中的堆内存值: .1.3.6.1.4.1.140.625.340.1.30
	 */
	private Vector<TblATO_KPIDETAIL> getJVMMEM(HashMap<String, String> params) {
		logger.info("Begin getJVMMEM...");
		init(params);
		// JVM内存堆
		String unitId = "10-12-11-12:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-HeapSize";
			Vector<String> JVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.30", false);
			if (JVMMEM.size() > 0) {
				String state = String.valueOf(JVMMEM.elementAt(0));
				collResult.addKPI(unitId, "PM-00-05-009-03", state);
			}
		} catch (Exception e) {
			logger.error(params+"getJVMMEM fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	/**
	 * JVM 中free memory值: .1.3.6.1.4.1.140.625.340.1.25
	 */
	private Vector<TblATO_KPIDETAIL> getFreeJVMMEM(HashMap<String, String> params) {
		logger.info("Begin getFreeJVMMEM...");
		init(params);
		// JVM内存堆
		String unitId = "10-12-11-12:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-HeapSize";
			Vector<String> FreeJVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.25", false);
			if (FreeJVMMEM.size() > 0) {
				String state = String.valueOf(FreeJVMMEM.elementAt(0));
				collResult.addKPI(unitId, "PM-00-05-009-02", state);
			}
		} catch (Exception e) {
			logger.error(params+"getFreeJVMMEM fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	/**
	 * JVM 中的使用的内存值 = JVM中的堆内存值 - JVM 中的剩余内存
	 * (.1.3.6.1.4.1.140.625.340.1.30)-(.1.3.6.1.4.1.140.625.340.1.25)
	 */
	private Vector<TblATO_KPIDETAIL> getUsedJVMMEM(HashMap<String, String> params) {
		logger.info("Begin getUsedJVMMEM...");
		init(params);
		// JVM内存堆
		String unitId = "10-12-11-12:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-HeapSize";
			Vector<String> JVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.30", false);
			if (JVMMEM.size() > 0) {
				int state_all = Integer.parseInt((String) JVMMEM.elementAt(0));
				Vector<String> FreeJVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.25", false);
				if (FreeJVMMEM.size() > 0) {
					int state_free = Integer.parseInt((String) FreeJVMMEM.elementAt(0));
					int state_use = state_all - state_free;
					collResult.addKPI(unitId, "PM-00-04-009-05", String.valueOf(state_use));
				}
			}
		} catch (Exception e) {
			logger.error(params+"getUsedJVMMEM fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	private Vector<TblATO_KPIDETAIL> getJVMMEMUseRate(HashMap<String, String> params) {
		logger.info("Begin getJVMMEMUseRate...");
		init(params);
		// JVM内存堆
		String unitId = "10-12-11-12:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-HeapSize";
			Vector<String> JVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.30", false);
			if (JVMMEM.size() > 0) {
				int state_all = Integer.parseInt((String) JVMMEM.elementAt(0));
				Vector<String> FreeJVMMEM = walkKPIInfo(".1.3.6.1.4.1.140.625.340.1.25", false);
				if (FreeJVMMEM.size() > 0) {
					int state_free = Integer.parseInt((String) FreeJVMMEM.elementAt(0));
					int state_use = state_all - state_free;
					if (state_all != 0) {
						float userate = state_use * 100F / state_all;
						collResult.addKPI(unitId, "PM-00-04-003-01", String.valueOf(userate));
						float freerate = state_free * 100F / state_all;
						collResult.addKPI(unitId, "PM-00-05-009-04", String.valueOf(freerate));
						
					}
				}
			}
		} catch (Exception e) {
			logger.error(params+"getJVMMEMUseRate fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getServers(HashMap<String, String> params) {
		logger.info("Begin getServers...");
		init(params);
		// SERVER
		String unitId = "10-12-11-10:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			// server name
			Vector<String> vc_Servers = walkKPIInfo(".1.3.6.1.4.1.140.625.730", false);
			int count = vc_Servers.size() / 57;
			for (int i = 0; i < count; i++) {
				String servername = vc_Servers.get(i + count * 3);
				String listenport = vc_Servers.get(i + count * 24);
				String servercluster = vc_Servers.get(i + count * 26);
				String _unitId = unitId + servername + "-server";
				collResult.addKPI(_unitId, "CM-00-04-001-10", servername);
				collResult.addKPI(_unitId, "CM-00-04-009-06", listenport);
				collResult.addKPI(_unitId, "CM-00-05-009-16", servercluster);
			}
		} catch (Exception e) {
			logger.error(params+"getServers fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getCluster(HashMap<String, String> params) {
		logger.info("Begin getCluster...");
		init(params);
		// 集群
		String unitId = "10-12-11-14:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-";
			Vector<String> vc_Cluster = walkKPIInfo(".1.3.6.1.4.1.140.625.510", false);
			int count = vc_Cluster.size() / 16;
			for (int i = 0; i < count; i++) {
				String clustername = vc_Cluster.get(i + count * 3);
				String serversip = vc_Cluster.get(i + count * 6);
				String serversconf = vc_Cluster.get(i + count * 5);
				String multicastaddress  = vc_Cluster.get(i + count * 7);
				String loadalgorithm   = vc_Cluster.get(i + count * 10);
				String multicastport  = vc_Cluster.get(i + count * 13);
				String _unitId = unitId + clustername;
				collResult.addKPI(_unitId, "CM-00-05-009-16", clustername);
				collResult.addKPI(_unitId, "CM-00-05-009-17", serversip);
				collResult.addKPI(_unitId, "CM-00-05-009-30", serversconf);
				collResult.addKPI(_unitId, "CM-00-05-009-19", multicastaddress);
				collResult.addKPI(_unitId, "CM-00-05-009-31", loadalgorithm);
				collResult.addKPI(_unitId, "CM-00-05-009-18", multicastport);
			}
		} catch (Exception e) {
			logger.error(params+"getCluster fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getWebApps(HashMap<String, String> params) {
		logger.info("Begin getWebApps...");
		init(params);
		// WEBAPPS
		String unitId = "10-12-11-11:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-";
			Vector<String> vc_Webapps = walkKPIInfo(".1.3.6.1.4.1.140.625.430", false);
			int count = vc_Webapps.size() / 34;
			for (int i = 0; i < count; i++) {
				String webappsname = vc_Webapps.get(i + count * 3);
				String contextroot = vc_Webapps.get(i + count * 27);
				String sourceinfo = vc_Webapps.get(i + count * 7);
				String status = vc_Webapps.get(i + count * 6);
				String opensessionscurrentcount = vc_Webapps.get(i + count * 10);
				String sessionsopenedtotalcount = vc_Webapps.get(i + count * 12);
				String opensessionshighcount = vc_Webapps.get(i + count * 11);
				String _unitId = unitId + webappsname;
				collResult.addKPI(_unitId, "CM-00-05-009-01", webappsname);
				collResult.addKPI(_unitId, "CM-00-05-009-06", contextroot);
				collResult.addKPI(_unitId, "CM-00-05-009-07", sourceinfo);
				collResult.addKPI(_unitId, "CM-00-05-009-08", status);
				collResult.addKPI(_unitId, "PM-00-05-009-40", opensessionscurrentcount);
				collResult.addKPI(_unitId, "PM-00-05-009-41", sessionsopenedtotalcount);
				collResult.addKPI(_unitId, "PM-00-05-009-42", opensessionshighcount);
			}
		} catch (Exception e) {
			logger.error(params+"getWebApps fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getChannel(HashMap<String, String> params) {
		logger.info("Begin getChannel...");
		init(params);
		// 协议队列
		String unitId = "10-12-11-18:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-";
			Vector<String> vc_Channel = walkKPIInfo(".1.3.6.1.4.1.140.625.366", false);
			int count = vc_Channel.size() / 13;
			for (int i = 0; i < count; i++) {
				String channelname = vc_Channel.get(i + count * 3);
				String acceptcount = vc_Channel.get(i + count * 9);
				String bytesreceivedcount = vc_Channel.get(i + count * 5);
				String bytessentcount = vc_Channel.get(i + count * 6);
				String connectionscount = vc_Channel.get(i + count * 8);
				String messagesreceivedcount = vc_Channel.get(i + count * 10);
				String messagessentcount = vc_Channel.get(i + count * 11);
				String _unitId = unitId + channelname;
				collResult.addKPI(_unitId, "CM-00-05-009-27", channelname);
				collResult.addKPI(_unitId, "PM-00-05-009-34", acceptcount);
				collResult.addKPI(_unitId, "PM-00-05-009-35", bytesreceivedcount);
				collResult.addKPI(_unitId, "PM-00-05-009-36", bytessentcount);
				collResult.addKPI(_unitId, "PM-00-05-009-37", connectionscount);
				collResult.addKPI(_unitId, "PM-00-05-009-38", messagesreceivedcount);
				collResult.addKPI(_unitId, "PM-00-05-009-39", messagessentcount);
			}
		} catch (Exception e) {
			logger.error(params+"getChannel fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public Vector<TblATO_KPIDETAIL> getThreads(HashMap<String, String> params) {
		logger.info("Begin getThreads...");
		init(params);
		// 线程池
		String unitId = "10-12-11-17:" + this.servicename + "-";
		CollBase collResult = new CollBase();
		try {
			Vector<String> vc_Domain = walkKPIInfo(".1.3.6.1.4.1.140.625.360.1.45", false); // domain name
			String dir = (String) vc_Domain.elementAt(0);
			String[] domain = null;
			if(dir.indexOf("/") != -1){
				domain = dir.split("/");
			}else{
				domain = dir.split("\\\\");
			}
			String domainName = domain[domain.length - 2]; // get Domain
			unitId += domainName + "-";
			Vector<String> vc_Thread_Pool = walkKPIInfo(".1.3.6.1.4.1.140.625.367", false);
			int count = vc_Thread_Pool.size() / 16;
			int totalThreads = 0;
			for (int i = 0; i < count; i++) {
				String tpname = vc_Thread_Pool.get(i + count * 3);
				String compreqcount = vc_Thread_Pool.get(i + count * 10);
				String execthreadidle = vc_Thread_Pool.get(i + count * 6);
				String execthreadtotal = vc_Thread_Pool.get(i + count * 5);
				totalThreads += Integer.valueOf(execthreadtotal);
				String penduserreqcount = vc_Thread_Pool.get(i + count * 8);
				String standbythreadcount = vc_Thread_Pool.get(i + count * 12);
				String throughput = vc_Thread_Pool.get(i + count * 13);
				String queuelength = vc_Thread_Pool.get(i + count * 7);
				String hogthreadcount = vc_Thread_Pool.get(i + count * 11);
				String _unitId = unitId + tpname;
				collResult.addKPI(_unitId, "CM-00-05-009-25", tpname);
				collResult.addKPI(_unitId, "PM-00-05-009-26", compreqcount);
				collResult.addKPI(_unitId, "PM-00-05-009-27", execthreadidle);
				collResult.addKPI(_unitId, "PM-00-05-009-28", execthreadtotal);
				collResult.addKPI(_unitId, "PM-00-05-009-29", penduserreqcount);
				collResult.addKPI(_unitId, "PM-00-05-009-30", standbythreadcount);
				collResult.addKPI(_unitId, "PM-00-05-009-31", throughput);
				collResult.addKPI(_unitId, "PM-00-05-009-32", queuelength);
				collResult.addKPI(_unitId, "PM-00-05-009-33", hogthreadcount);
			}
		} catch (Exception e) {
			logger.error(params+"getThreads fail", e);
		} finally {
			release();
		}
		return collResult.KPISet;
	}

	@Override
	public void collWeblogic10WithJMX(HashMap<String, String> map) {
	}

	@Override
	public Vector<TblATO_KPIDETAIL> collWeblogic10ForSX(HashMap<String, String> params) {
		return null;
	}
}