package com.sitech.ismp.coll.busi;

import java.io.IOException;
import java.net.Socket;
import java.util.HashMap;

import org.apache.log4j.Logger;

import com.sitech.ismp.coll.CollBase;

public class SocketCollThread implements Runnable {
	static Logger logger = Logger.getLogger("BUSI_COLL");
	private String ip = "";
	private String port = "";
	private String unitId = "";
	
	private String interval;
	
	public SocketCollThread(HashMap<String, String> params) {
		ip = params.get("IPADDR");
		port = params.get("PORT");
		unitId = params.get("KBPCLASS") + ":" + ip + "_" + port;
		
		interval = params.get("COLL_INTERVAL");
	}

	public void run(){
		CollBase collResult = new CollBase();
		
		String result = "";
		Socket socket = null;
		try {
			socket = new Socket(ip, Integer.parseInt(port));
			result = "SUCCESS";
		} catch (Exception e) {
			result = "FAIL";
		}finally{
			if(socket != null){
				try {
					socket.close();
				} catch (IOException e) {
				}
			}
		}
		
		logger.info("Socket[" + ip + ":" + port + "] :" + result);
		collResult.addKPI(unitId, "CM-10-01-001-01-01", ip + ":" + port, interval);
		collResult.addKPI(unitId, "FM-10-01-001-01-01", result, interval);

		collResult.saveKPI2File();
	}
	
}