package com.sitech.ismp.coll.busi;

import java.util.HashMap;
import java.util.ResourceBundle;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import com.sitech.util.ThreadPoolUtil;

public class ProcedureColl implements ProcedureCollMBean {
	private Logger logger = Logger.getLogger(ProcedureColl.class);

	public Vector<TblATO_KPIDETAIL> collProcedure(HashMap<String, String> params) {
		try {
			ResourceBundle agentConfig = ResourceBundle.getBundle("agent");
			String localDir = agentConfig.getString("coll.local.path");
			String connUrl = params.get("CONN_URL");

			String temp = connUrl.substring(connUrl.indexOf("@") + 1);
			String[] elem = temp.split(":");

			String ip = elem[0];
			String port = elem[1];
			String sid = elem[2];
			String username = params.get("USERNAME");
			String password = params.get("PASSWORD");
			String driveClass = params.get("CLASSNAME");

			ThreadPoolUtil.executorService.execute(new ProcedureCollThread(ip,
					port, sid, driveClass, username, password, localDir));
		} catch (Exception e) {
			logger.error("Exception while do ProcedureColl.collProcedure() ", e);
			return new Vector<TblATO_KPIDETAIL>();
		}
		return new Vector<TblATO_KPIDETAIL>();
	}

}