package com.sitech.ismp.coll;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.sitech.ismp.app.coll.RPCTarget;

public class CollTuxedoWithTuxedoShell {

	String KBP_ID = "10-12-12"; // Tuxedo标识

	// String kbp_id = "10-11-12";
	String routerip = null;

	String ObjectIP = null;

	String SHELLPATH = null;

	String communication = "public";

	String os_type = null;

	String rpcTarget_sh = "RPCTarget_suport.sh";

	String username = null;

	String password = null;

	String tuxuser = null;

	String cPort = null;

	int port = 5161;
	
	String domainId="";
	String ipckey="";
	String maxBBLProcess="";
	String maxservice="";
	String maxServers="";
	String tuxconfig="";
	String tuxdir="";
	String appdir="";
	String maxClients="";
	String maxprocess="";
	
	String currentServers="";
	String currentQueue="";
	String currentServices="";
	
	List groupList = new ArrayList();
	List serverList = new ArrayList();
	
	
	private Logger logger = Logger.getLogger("COLL");

	public CollTuxedoWithTuxedoShell() {
	}

	public Vector getConfiguration(String IP, String username, String Password,
			String tuxuser) {
		Vector result = null;
		try {
			this.ObjectIP = IP;
			RPCTarget rpctarget = new RPCTarget();

			// rpctarget.setRpcCmd("/ibnms2/ismp/masteragent/bin/lexe_hp");
			rpctarget.setRpcCmd(this.rpcTarget_sh);
			this.getConfigParams(rpctarget, IP, username, tuxuser);
			result = getConfiguration(rpctarget, IP, username, tuxuser);
			/*
			 * this.ObjectIP = IP; TelnetTarget telnetTarget = new
			 * TelnetTarget(); telnetTarget.init(ObjectIP, username, Password);
			 * result = getConfiguration(telnetTarget); telnetTarget.release();
			 */
		} catch (Exception e) {
			e.printStackTrace();
		}
		return result;
	}

	public Vector getPerformance(String IP, String username, String Password,
			String tuxuser) {
		Vector result = null;
		try {
			/*
			 * this.ObjectIP = IP; TelnetTarget telnetTarget = new
			 * TelnetTarget(); telnetTarget.init(ObjectIP, username, Password);
			 * result = getPerformance(telnetTarget); telnetTarget.release();
			 */
			this.ObjectIP = IP;
			RPCTarget rpctarget = new RPCTarget();
			// rpctarget.setRpcCmd("/ibnms2/ismp/masteragent/bin/lexe_hp");
			rpctarget.setRpcCmd(this.rpcTarget_sh);
			result = getPerformance(rpctarget, IP, username, tuxuser);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return result;
	}

	private boolean getParams(java.util.HashMap params) {
		username = params.get("USERNAME") == null ? "" : (String) params
				.get("USERNAME");
		password = params.get("PASSWORD") == null ? "" : (String) params
				.get("PASSWORD");
		ObjectIP = params.get("IP_ADDR") == null ? "" : (String) params
				.get("IP_ADDR");
		SHELLPATH = params.get("SHELLPATH") == null ? "" : (String) params
				.get("SHELLPATH");
		if (SHELLPATH != null && !SHELLPATH.endsWith("/")) {
			SHELLPATH = SHELLPATH + "/";
		}
		os_type = params.get("OS_TYPE") == null ? "" : (String) params
				.get("OS_TYPE");
		if (os_type.equalsIgnoreCase("sun")) {
			this.rpcTarget_sh = "RPCTarget_suport.sh";
		} else if (os_type.equalsIgnoreCase("hp")) {
			this.rpcTarget_sh = "lexe_hp";
		}
		tuxuser = params.get("TUXUSER") == null ? "" : (String) params
				.get("TUXUSER");
		if (!"".equals(password)) {
			password = com.sitech.util.DES3.decrypt(password);
		}
		return true;
	}

	public java.util.Vector getConfiguration(java.util.HashMap params)
			throws Exception {
		getParams(params);
		return getConfiguration(ObjectIP, username, password, tuxuser);
	}

	public java.util.Vector getPerformance(java.util.HashMap params)
			throws Exception {
		getParams(params);
		return getPerformance(ObjectIP, username, password, tuxuser);
	}

	public java.util.Vector getOverstock(java.util.HashMap params)
			throws Exception {
		getParams(params);
		return getOverstock(ObjectIP, username, password, tuxuser);
	}

	public Vector getOverstock(String IP, String username, String Password,
			String tuxuser) {
		Vector result = null;
		try {
			/*
			 * this.ObjectIP = IP; TelnetTarget telnetTarget = new
			 * TelnetTarget(); telnetTarget.init(ObjectIP, username, Password);
			 * result = getPerformance(telnetTarget); telnetTarget.release();
			 */
			this.ObjectIP = IP;
			RPCTarget rpctarget = new RPCTarget();
			// rpctarget.setRpcCmd("/ibnms2/ismp/masteragent/bin/lexe_hp");
			rpctarget.setRpcCmd(this.rpcTarget_sh);
			result = getOverstock(rpctarget, IP, username, tuxuser);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return result;
	}

	// 采集服务积压情况
	private Vector getOverstock(RPCTarget rpctarget, String IP,
			String username, String tuxuser) {
		logger.info("begin getOverstock.SHELLPATH is " + SHELLPATH);
		logger.info("username is " + username + ";tuxuser is " + tuxuser);
		CollBase collbase = new CollBase();
		String KBP_ID = this.KBP_ID + "-13" + ":" + IP.replaceAll("\\.", "_")
				+ "_" + tuxuser;
		try {
			Vector vResult = rpctarget.getKPISet(SHELLPATH + "psr.sh "
					+ tuxuser);
			logger.info("vResult.size() is " + vResult.size());
			if (vResult.size() > 0) {
				for (int i = 0; i < vResult.size(); i++) {
					String serv_info = (String) vResult.elementAt(i);
					if (serv_info.equals(""))
						continue;
					String prog_name = split(serv_info, 0);
					prog_name = prog_name.substring(1, prog_name.length());
					String queue_name = split(serv_info, 1);
					String Serve = split(serv_info, 2);
					String Wk_Queued = split(serv_info, 3);
					String Queued = split(serv_info, 4);
					String Ave_Len = split(serv_info, 5);
					String Machine = split(serv_info, 6);
					String unit_post = queue_name.replaceAll("\\.", "_");
					collbase.addKPI(KBP_ID + "-" + prog_name,
							"CM-00-04-003-12", prog_name);
					// collbase.addKPI(KBP_ID + "-" +
					// unit_post,"CM-00-04-003-13", queue_name);
					collbase.addKPI(KBP_ID + "-" + prog_name,
							"CM-00-04-003-14", Serve);
					// collbase.addKPI(KBP_ID + "-" +
					// unit_post,"PM-00-04-800-09", Wk_Queued);
					collbase.addKPI(KBP_ID + "-" + prog_name,
							"PM-00-04-800-10", Queued);
					// collbase.addKPI(KBP_ID + "-" +
					// unit_post,"PM-00-04-800-11", Ave_Len);
					// collbase.addKPI(KBP_ID + "-" +
					// unit_post,"PM-00-04-800-12", Machine);
					double value = Float.parseFloat(Queued)
							/ Float.parseFloat(Serve);
					double ret;
					BigDecimal b = new BigDecimal(value);
					ret = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
					collbase.addKPI(KBP_ID + "-" + prog_name ,
							"PM-00-04-800-13", String.valueOf(ret));
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return collbase.KPISet;
	}

	/*
	 * CM-00-04-001-01 中间件最大并发连接数 1.3.6.1.4.1.140.300.5.1.1.16.0 CM-00-04-001-02
	 * 中间件最大并发网络客户端数量 1.3.6.1.4.1.140.300.5.1.1.13.0 CM-00-04-001-03 中间件的系统日志路径
	 * 1.3.6.1.4.1.140.300.5.1.1.4.0 CM-00-04-001-04 中间件的用户日志路径
	 * 1.3.6.1.4.1.140.300.5.1.1.11.0
	 */
	/*
	 * private Vector getConfiguration(TelnetTarget telnetTarget) { String
	 * KBP_ID = this.KBP_ID + "-11" + ":" + ObjectIP + "-" + username;
	 * 
	 * CollBase collbase = new CollBase(); // CM-00-04-001-50 常用ip
	 * collbase.addKPI(KBP_ID, "CM-00-04-001-50", ObjectIP);
	 * 
	 * try { collbase.addKPI(KBP_ID, "CM-00-04-001-01", telnetTarget
	 * .getCommandResult(SHELLPATH + "CM-00-04-001-01.sh"));
	 * collbase.addKPI(KBP_ID, "CM-00-04-001-02", telnetTarget
	 * .getCommandResult(SHELLPATH + "CM-00-04-001-02.sh"));
	 * collbase.addKPI(KBP_ID, "CM-00-04-001-03", telnetTarget
	 * .getCommandResult(SHELLPATH + "CM-00-04-001-03.sh"));
	 * collbase.addKPI(KBP_ID, "CM-00-04-001-04", telnetTarget
	 * .getCommandResult(SHELLPATH + "CM-00-04-001-01.sh")); } catch (Exception
	 * e) { e.printStackTrace(); } return collbase.KPISet; }
	 */
	private Vector getConfiguration(RPCTarget rpctarget, String IP,
			String username, String tuxuser) {
		String strResult = "";
		// String KBP_ID = this.KBP_ID + "-11" + ":" + IP + "-" + tuxuser;
		// String KBP_ID = this.KBP_ID + "-11" + ":" + tuxuser;
		String KBP_ID = this.KBP_ID + "-11" + ":" + IP.replaceAll("\\.", "_")
				+ "_" + tuxuser;
		CollBase collbase = new CollBase();

		// CM-00-04-001-50 常用ip
		collbase.addKPI(KBP_ID, "CM-00-04-001-50", IP);

		try {
			strResult = rpctarget.getKPIValue(SHELLPATH + "CM-00-04-001-01.sh "
					+ tuxuser);
			logger.info(KBP_ID + "	CM-00-04-001-01	" + strResult);
			// System.out.println(KBP_ID + " CM-00-04-001-01 " + strResult);
			collbase.addKPI(KBP_ID, "CM-00-04-001-01", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "CM-00-04-001-02.sh "
					+ tuxuser);
			logger.info(KBP_ID + "	CM-00-04-001-02	" + strResult);
			// System.out.println(KBP_ID + " CM-00-04-001-02 " + strResult);
			collbase.addKPI(KBP_ID, "CM-00-04-001-02", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "CM-00-04-001-03.sh "
					+ tuxuser);
			logger.info(KBP_ID + "	CM-00-04-001-03	" + strResult);
			// System.out.println(KBP_ID + " CM-00-04-001-03 " + strResult);
			collbase.addKPI(KBP_ID, "CM-00-04-001-03", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "CM-00-04-001-04.sh "
					+ tuxuser);
			logger.info(KBP_ID + "	CM-00-04-001-04	" + strResult);
			// System.out.println(KBP_ID + " CM-00-04-001-04 " + strResult);
			collbase.addKPI(KBP_ID, "CM-00-04-001-04", strResult);
			
			collbase.addKPI(KBP_ID, "CM-00-04-004-02", this.removeQuotedMarks(this.domainId));
			collbase.addKPI(KBP_ID, "CM-00-04-004-03", this.removeQuotedMarks(this.ipckey));
			collbase.addKPI(KBP_ID, "CM-00-04-004-04", this.removeQuotedMarks(this.maxBBLProcess));
			collbase.addKPI(KBP_ID, "CM-00-04-004-05", this.removeQuotedMarks(this.maxservice));
			collbase.addKPI(KBP_ID, "CM-00-04-004-06", this.removeQuotedMarks(this.maxServers));
			
			collbase.addKPI(KBP_ID, "CM-00-04-004-08", this.removeQuotedMarks(this.tuxconfig));
			collbase.addKPI(KBP_ID, "CM-00-04-004-081",this.removeQuotedMarks( this.tuxdir));
			collbase.addKPI(KBP_ID, "CM-00-04-004-09", this.removeQuotedMarks(this.appdir));
			collbase.addKPI(KBP_ID, "CM-00-04-004-10", this.removeQuotedMarks(this.maxClients));
			collbase.addKPI(KBP_ID, "CM-00-04-004-11", this.removeQuotedMarks(this.maxprocess));
			
			if(this.groupList!=null&&this.groupList.size()>0){
				//组信息
				for(int i=0;i<groupList.size();i++){
					
					Group group = (Group) groupList.get(i);
					String groupname = group.getGroupname();
					KBP_ID = this.KBP_ID +"-13:"+IP.replaceAll("\\.", "_")
					+ "_" + tuxuser+"-"+groupname;
					String groupNo = group.getGROUPNO();
					String groupLMID = group.getLMID();
					collbase.addKPI(KBP_ID, "CM-00-04-004-13", this.removeQuotedMarks(groupname));
					collbase.addKPI(KBP_ID, "CM-00-04-004-14", this.removeQuotedMarks(groupLMID));
					collbase.addKPI(KBP_ID, "CM-00-04-004-15", this.removeQuotedMarks(groupNo));
					
				}
			}
			if(this.serverList!=null&&this.serverList.size()>0){
				//服务器信息
				for(int i=0;i<serverList.size();i++){
					Server ser = (Server) serverList.get(i);
					String servername = ser.getServername();
					KBP_ID = this.KBP_ID +"-14:"+IP.replaceAll("\\.", "_")
					+ "_" + tuxuser+"-"+servername;
					
					collbase.addKPI(KBP_ID, "CM-00-04-004-16", this.removeQuotedMarks(servername));
					collbase.addKPI(KBP_ID, "CM-00-04-004-17", this.removeQuotedMarks(ser.getServerId()));
					collbase.addKPI(KBP_ID, "CM-00-04-004-18", this.removeQuotedMarks(ser.getServergroup()));
					collbase.addKPI(KBP_ID, "CM-00-04-004-19", this.removeQuotedMarks(ser.getMinservice()));
					collbase.addKPI(KBP_ID, "CM-00-04-004-20", this.removeQuotedMarks(ser.getMaxservice()));
					collbase.addKPI(KBP_ID, "CM-00-04-004-21", this.removeQuotedMarks(ser.getClopt()));
				}
			}
			
			
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		return collbase.KPISet;
	}
	
	public void getConfigParams(RPCTarget rpctarget, String IP,
			String username, String tuxuser){
		try{
			String tmunloadcfCMD = this.SHELLPATH+"tmunloadcfToFile.sh";
			String strResult = rpctarget.getKPIValue(tmunloadcfCMD+" "
					+ tuxuser);
			String cfgFilePath = this.SHELLPATH+"tmunloadcf.txt";
			File cfg=new File(cfgFilePath);
			FileReader reader = new FileReader(cfg);
			BufferedReader bfr = new BufferedReader(reader);
			try{
				String line=null;
				 
				while((line=bfr.readLine())!=null){
					line = line.trim();
					if(line.startsWith("*MACHINES")){
						break;
					}
					line = replaceTabAndDoubleSpace(line);
					String[] cfgNameAndValue= line.split(" ");
					if(cfgNameAndValue!=null&&cfgNameAndValue.length==2){
						if("IPCKEY".equals(cfgNameAndValue[0])){
							this.ipckey = cfgNameAndValue[1];
						}
						if("DOMAINID".equals(cfgNameAndValue[0])){
							this.domainId = cfgNameAndValue[1];
						}
						/*String domainId="";
						String ipckey="";
						String maxBBLProcess="";
						String maxservice="";
						String maxServers="";
						String maxprocess="";*/
						if("MAXACCESSERS".equals(cfgNameAndValue[0])){
							this.maxBBLProcess = cfgNameAndValue[1];
						}
						if("MAXSERVICES".equals(cfgNameAndValue[0])){
							this.maxservice = cfgNameAndValue[1];
						}
						if("MAXSERVERS".equals(cfgNameAndValue[0])){
							this.maxServers = cfgNameAndValue[1];
						}
						
						if("MAXACCESSERS".equals(cfgNameAndValue[0])){
							this.maxprocess = cfgNameAndValue[1];
						}
						
					}
				}
				while((line=bfr.readLine())!=null){
					line = line.trim();
					if(line.startsWith("*GROUPS")){
						break;
					}
					line = replaceTabAndDoubleSpace(line);
					String[] cfgNameAndValue= line.split("=");
					if(cfgNameAndValue!=null&&cfgNameAndValue.length==2){
					  /*String tuxconfig="";
						String tuxdir="";
						String appdir="";
						String maxClients="";*/
						if("TUXCONFIG".equals(cfgNameAndValue[0])){
							this.tuxconfig = cfgNameAndValue[1];
						}
						if("TUXDIR".equals(cfgNameAndValue[0])){
							this.tuxdir = cfgNameAndValue[1];
						}
						if("APPDIR".equals(cfgNameAndValue[0])){
							this.appdir = cfgNameAndValue[1];
						}
						if("MAXWSCLIENTS".equals(cfgNameAndValue[0])){
							this.maxClients = cfgNameAndValue[1];
						}
					}
				}
				
				while((line=bfr.readLine())!=null){
					line = line.trim();
					if(line.startsWith("*SERVERS")){
						break;
					}
					line = replaceTabAndDoubleSpace(line);
					if(line.indexOf("LMID")!=-1){
						Group g=new Group();
						String[] ginfos =line.split(" ");
						if(ginfos!=null&&ginfos.length==3){
							g.setGroupname(ginfos[0]);
							g.setLMID(this.getValueAfterEqualSymbol(ginfos[1]));
							g.setGROUPNO(this.getValueAfterEqualSymbol(ginfos[2]));
						}
						this.groupList.add(g);
					}
				}
				
				while((line=bfr.readLine())!=null){
					line = line.trim();
					if(line.startsWith("*SERVICES")){
						break;
					}
					line = replaceTabAndDoubleSpace(line);
					
					if(line.indexOf("SRVGRP=")!=-1){
						Server ser=new Server();
						String[] sinfos =line.split(" ");
						if(sinfos!=null&&sinfos.length==3){
							ser.setServername(sinfos[0]);
							ser.setServergroup(this.getValueAfterEqualSymbol(sinfos[1]));
							ser.setServerId(this.getValueAfterEqualSymbol(sinfos[2]));
						}
						
						line = bfr.readLine();
						if(line!=null){
							ser.setClopt(this.getValueAfterEqualSymbol(line));
						}
						System.out.println("cloopt="+line);
						
						line = bfr.readLine();
						System.out.println("cloopt="+line);
						
						if(line!=null&&line.indexOf("RQPERM")==-1){
							line = bfr.readLine();
							line = line.trim();
							
						}
						System.out.println("min="+line);
						if(line!=null){
							line=line.trim();
							line = replaceTabAndDoubleSpace(line);
							sinfos =line.split(" ");
							System.out.println("min length="+sinfos.length);
								
							if(sinfos!=null&&sinfos.length==6){
								ser.setMinservice(this.getValueAfterEqualSymbol(sinfos[3]));
								ser.setMaxservice(this.getValueAfterEqualSymbol(sinfos[4]));
							}
						}
						this.serverList.add(ser);
					}
				}
				
				
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				bfr.close();
				reader.close();
			}
			
		}catch(Exception e){
			e.printStackTrace();
		}
	}

	/*
	 * PM-00-04-001-01 客户端连接的队列个数 ,取正运行的Queue Name的个数TuxedoTotalQueued.sh
	 * PM-00-04-001-02 服务个数 1.3.6.1.4.1.140.300.20.1.1.1 FM-00-04-001-01
	 * 应用服务状态(可选) 1.3.6.1.4.1.140.300.20.1.1.5.0 FM-00-04-001-02 中间件可用性
	 * 1.3.6.1.4.1.140.300.5.1.1.4.0 FM-00-04-001-03 客户端连接的队列个数 ,取正运行的Queue
	 * Name的个数 PM-00-04-001-03 队列等待数 TuxedoTotalQueued.sh PM-00-04-001-04
	 * 进程队列中消息个数 NaN PM-00-04-001-05 应用进程负载 ,Queued求和 PM-00-04-001-06 客户端活动连接数
	 * ,取正运行的server的个数
	 */
	/*
	 * private Vector getPerformance(TelnetTarget telnetTarget) { String KBP_ID =
	 * this.KBP_ID + "-12" + ":" + ObjectIP + "-" + username;
	 * 
	 * CollBase collbase = new CollBase(); try { collbase.addKPI(KBP_ID,
	 * "FM-00-04-001-01", telnetTarget .getCommandResult(SHELLPATH +
	 * "FM-00-04-001-01.sh")); // 有WSL进程 collbase.addKPI(KBP_ID,
	 * "FM-00-04-001-02", telnetTarget .getCommandResult(SHELLPATH +
	 * "FM-00-04-001-02.sh")); // 有BBL进程 //
	 * collbase.addKPI(KBP_ID,"FM-00-04-001-03",telnetTarget.getCommandResult(SHELLPATH+"FM-00-04-001-03.sh")); // //
	 * 
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-01", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-01.sh"));
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-02", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-02.sh"));
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-03", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-03.sh"));
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-04", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-04.sh"));
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-05", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-05.sh"));
	 * collbase.addKPI(KBP_ID, "PM-00-04-001-06", telnetTarget
	 * .getCommandResult(SHELLPATH + "PM-00-04-001-06.sh")); } catch (Exception
	 * e) { e.printStackTrace(); } return collbase.KPISet; }
	 */
	private Vector getPerformance(RPCTarget rpctarget, String IP,
			String username, String tuxuser) {
		String strResult = "";
		// String KBP_ID = this.KBP_ID + "-12" + ":" + IP + "-" + tuxuser;
		String KBP_ID = this.KBP_ID + "-12" + ":" + IP.replaceAll("\\.", "_")
				+ "_" + tuxuser;

		CollBase collbase = new CollBase();
		try {
			strResult = rpctarget.getKPIValue(SHELLPATH + "FM-00-04-001-01.sh "
					+ tuxuser);
			logger.info(KBP_ID + "	FM-00-04-001-01	" + strResult);
			// System.out.println(KBP_ID + " FM-00-04-001-01 " + strResult);
			collbase.addKPI(KBP_ID, "FM-00-04-001-01", strResult); // 有WSL进程

			strResult = rpctarget.getKPIValue(SHELLPATH + "FM-00-04-001-02.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " FM-00-04-001-02 " + strResult);
			logger.info(KBP_ID + "	FM-00-04-001-02	" + strResult);
			collbase.addKPI(KBP_ID, "FM-00-04-001-02", strResult); // 有BBL进程
			// collbase.addKPI(KBP_ID,"FM-00-04-001-03",telnetTarget.getCommandResult(SHELLPATH+"FM-00-04-001-03.sh"));
			// //

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-01.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-01 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-01	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-01", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-02.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-02 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-02	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-02", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-03.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-03 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-03	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-03", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-04.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-04 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-04	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-04", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-05.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-05 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-05	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-05", strResult);

			strResult = rpctarget.getKPIValue(SHELLPATH + "PM-00-04-001-06.sh "
					+ tuxuser);
			// System.out.println(KBP_ID + " PM-00-04-001-06 " + strResult);
			logger.info(KBP_ID + "	PM-00-04-001-06	" + strResult);
			collbase.addKPI(KBP_ID, "PM-00-04-001-06", strResult);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return collbase.KPISet;
	}

	/**
	 * 如果超出了返回,返回 空串
	 */
	private String split(String str, int pos) {
		StringTokenizer st = new StringTokenizer(str);
		Vector values = new Vector();
		while (st.hasMoreTokens()) {
			values.add(st.nextToken());
		}
		if (pos >= 0 && pos < values.size()) {
			return (String) values.elementAt(pos);
		}
		return "";
	}
	
	private String replaceTabAndDoubleSpace(String line){
		if(line==null){
			return "";
		}
		while(line.indexOf("	")!=-1){
			line=line.replaceAll("	", " ");
		}
		while(line.indexOf("  ")!=-1){
			line = line.replaceAll("  ", " ");
		}
		return line;
	}
	
	private String getValueAfterEqualSymbol(String values){
		if(values==null){
			return "";
		}
		String[] nameAndValue = values.split("=");
		if(nameAndValue!=null&&nameAndValue.length==2){
			return nameAndValue[1];
		}else{
			return "";
		}
	}
	private String removeQuotedMarks(String line){
		if(line!=null){
			if(line.startsWith("\"")){
				line = line.substring(1);
			}
			if(line.endsWith("\"")){
				line = line.substring(0,line.length()-1);
			}
		}
		return line;
	}
	
	private class Group{
		String groupname="";
		String LMID="";
		String GROUPNO="";
		public String getGroupname() {
			if(this.groupname!=null){
				groupname = groupname.replaceAll("\"", "");
			}
			return groupname;
		}
		public void setGroupname(String groupname) {
			this.groupname = groupname;
		}
		public String getLMID() {
			return LMID;
		}
		public void setLMID(String lMID) {
			LMID = lMID;
		}
		public String getGROUPNO() {
			return GROUPNO;
		}
		public void setGROUPNO(String gROUPNO) {
			GROUPNO = gROUPNO;
		}
	}
	
	private class Server{
		String servername ="";
		String serverId ="";
		String servergroup="";
		String minservice="";
		String maxservice="";
		String clopt="";
		public String getServername() {
			if(servername!=null&&!servername.equals("")){
				servername = servername.replaceAll("\"", "");
			}
			return servername;
		}
		public void setServername(String servername) {
			this.servername = servername;
		}
		public String getServerId() {
			return serverId;
		}
		public void setServerId(String serverId) {
			this.serverId = serverId;
		}
		public String getServergroup() {
			return servergroup;
		}
		public void setServergroup(String servergroup) {
			this.servergroup = servergroup;
		}
		public String getMinservice() {
			return minservice;
		}
		public void setMinservice(String minservice) {
			this.minservice = minservice;
		}
		public String getMaxservice() {
			return maxservice;
		}
		public void setMaxservice(String maxservice) {
			this.maxservice = maxservice;
		}
		public String getClopt() {
			return clopt;
		}
		public void setClopt(String clopt) {
			this.clopt = clopt;
		}
		
	}
	
	public static void main(String[] argv) throws Exception {
		double value = 1f / 8;
		double ret;
		BigDecimal b = new BigDecimal(value);// 这种好
		ret = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
		System.out.print(ret);
	}
}