package VectroData;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;

import DataBase.DatabaseManagement;
import tbDataModel.Tb_forward_data;
/**Êý¾Ýת·¢¶ÔÏóµÄ¼¯ºÏ*/
@SuppressWarnings("rawtypes")
public class ForwardDatas {
	static	Vector<Tb_forward_data> tb_forward_datas=new Vector<>();
	static boolean cutom1=false;//ÅжÏÕâ¸öÊý¾ÝÀàÐÍÊÇ·ñ´æÔÚ
	static boolean TCP=false;
	static boolean UDP=false;
	static boolean HTTPClient=false;
	static boolean HTTPServer=false;
	static Vector<Tb_forward_data> displaydata=new Vector<>();
	static Vector<Tb_forward_data> alldata=new Vector<>();
	static Vector<Tb_forward_data> warningdata=new Vector<>();
	static Vector<Tb_forward_data> yuanshidata=new Vector<>();
	static Vector<Tb_forward_data> gasdata=new Vector<>();
	static Vector<Tb_forward_data> tongjidata=new Vector<>();
	static Vector<Tb_forward_data> bujudata=new Vector<>();
	static Vector<Tb_forward_data> gnggadta=new Vector<>();
	static Vector<Tb_forward_data> custom1data=new Vector<>();
	static boolean havezhuanfa=false;
	static boolean istongji=false;


	static {
		Iterator iterator = DatabaseManagement.get_alldate_indatabase("tb_forward_data").iterator();		
		while (iterator.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ
			List info = (List) iterator.next();//½«µü´úÆ÷ÀïÃæµÄÔªËظøµ½info¼¯ºÏ
			Tb_forward_data forward_data=new Tb_forward_data();
			forward_data.setId(Integer.parseInt((String)info.get(0)));
			String type=(String)info.get(1);
			forward_data.setType(type);			
			forward_data.setIp((String)info.get(2));
			forward_data.setPort((String)info.get(3));
			String datatype=(String)info.get(4);			
			forward_data.setDatatype(datatype);
			forward_data.setAddtime((String)info.get(5));
			jugedatatype(datatype,forward_data);
			tb_forward_datas.add(forward_data);
			jugetype(type);
			havezhuanfa=true;
			if(datatype.equals("ͳ¼ÆÊý¾Ý")) {
				istongji=true;
			}
		}
	}

	/**ÅжÏijÖÖÀàÐÍת·¢Ð­ÒéÊÇ·ñ´æÔÚ*/
	public static void jugetype(String type) {
		switch(type){
		case "TCP":
			TCP=true;
			break;

		case "UDP":
			UDP=true;
			break;

		case "HTTP-Client":
			HTTPClient=true;
			break;

		case "HTTP-Server":
			HTTPServer=true;
			break;
		}
	}

	/**ijÖÖÊý¾ÝÀàÐÍÊý¾Ý¼¯ºÏ*/
	//	"λÖÃÊý¾Ý","È«²¿Êý¾Ý","¸æ¾¯Êý¾Ý","ԭʼÊý¾Ý","ÆøÌåÊý¾Ý","ͳ¼ÆÊý¾Ý","²½¾àÊý¾Ý","GNGGA","custom1"
	public static void jugedatatype(String datatype,Tb_forward_data forward_data) {
		switch(datatype){
		case "λÖÃÊý¾Ý":
			displaydata.add(forward_data);
			break;
		case "È«²¿Êý¾Ý":
			alldata.add(forward_data);
			break;
		case "¸æ¾¯Êý¾Ý":
			warningdata.add(forward_data);
			break;
		case "²½¾àÊý¾Ý":
			bujudata.add(forward_data);
			break;
		case "ԭʼÊý¾Ý":
			yuanshidata.add(forward_data);
			break;
		case "ÆøÌåÊý¾Ý":
			gasdata.add(forward_data);
			break;
		case "ͳ¼ÆÊý¾Ý":
			tongjidata.add(forward_data);
			break;
		case "GNGGA":
			gnggadta.add(forward_data);
			break;
		case "custom1":
			cutom1=true;
			custom1data.add(forward_data);
			break;
		}
	}


	public  static Vector<Tb_forward_data> get_tb_forward_datas(){
		return tb_forward_datas;
	}

	public static boolean get_gas_zhuanfa() {
		boolean gas_zhuan_fa=false;//Êý¾Ýת·¢ÆøÌå²»´æÔÚ
		int size=tb_forward_datas.size();
		if(size!=0) {//Êý¾Ýת·¢¼¯ºÏ²»Îª¿Õ
			for(int i=0;i<size;i++) {
				Tb_forward_data forward_data=tb_forward_datas.get(i);
				String type=forward_data.getType();
				String datatype=forward_data.getDatatype();
				if(type.equals("TCP") && datatype.equals("ÆøÌåÊý¾Ý")) {
					gas_zhuan_fa=true;
				}
			}
		}
		return gas_zhuan_fa;

	}

	/**ÅжÏij¸ö¶Ë¿Ú,µØÖ·£¬Ð­ÒéÀàÊÇ·ñ´æÔÚת·¢È«²¿Êý¾Ý*/
	public static boolean get_all(String type,String ip,String port) {
		boolean ishave=false;

		//Èç¹û´æÔÚÁËת·¢È«²¿Êý¾ÝµÄÑ¡ÔñÏîÄ¿
		if(forward_data_is_have(type,ip, port,"È«²¿Êý¾Ý" )) {
			ishave=true;
		}

		return ishave;	
	}

	/**Ïò¼¯ºÏÖÐÌí¼ÓÒ»¸ö¶ÔÏó*/
	public static void add_tb_forward_data(String type,String ip,String port,String datatype) {
		Tb_forward_data new_forward_data=new Tb_forward_data();
		new_forward_data.setIp(ip);
		new_forward_data.setPort(port);
		new_forward_data.setType(type);
		new_forward_data.setDatatype(datatype);
		tb_forward_datas.add(new_forward_data);
	}

	/**ͨ¹ýIDÕÒµ½Ä³¸ö¶ÔÏó*/
	public static Tb_forward_data get_forward_data(String id) {
		int id0=Integer.parseInt(id);
		Tb_forward_data mou_forward_data=null;
		if(tb_forward_datas.size() !=0) {

			Iterator<Tb_forward_data> it=tb_forward_datas.iterator();
			while(it.hasNext()) {
				Tb_forward_data forward_data1=it.next();
				int id1=forward_data1.getId();
				if(id1==id0) {
					mou_forward_data=forward_data1;
					break;
				}
			}
		}
		return mou_forward_data;
	}

	/**Ô¶³Ìɾ³ýת·¢
	 * deltefoword,ip,port,end*/
	public static void delete(String message) {
		String[] a=message.split(",");
		if(a.length==4) {
			String ip=a[1];
			String port=a[2];			
			if(tb_forward_datas.size() !=0) {
				Iterator<Tb_forward_data> it=tb_forward_datas.iterator();
				while(it.hasNext()) {
					Tb_forward_data forward_data1=it.next();
					String ip1=forward_data1.getIp();
					String port1=forward_data1.getPort();
					String id=String.valueOf(forward_data1.getId());
					if(ip1.equals(ip) && port.equals(port1)) {						
						String deleteSql="DELETE FROM tb_forward_data WHERE id='"+id+"'";
						DatabaseManagement.update(deleteSql);// ɾ³ý±êÇ©ÐÅÏ¢
						tb_forward_datas.removeElement(forward_data1);
					}
				}
			}
		}

	}

	/**ɾ³ýij¸ö¶ÔÏó*/
	public static void delete_forward_data(String id) {
		Tb_forward_data mou_forward_data=get_forward_data(id);
		if(mou_forward_data !=null) {
			tb_forward_datas.removeElement(mou_forward_data);
		}

	}

	/**ɾ³ýÈ«²¿¶ÔÏó*/
	public static void delete_all_forward_data() {
		if(tb_forward_datas.size() !=0) {
			tb_forward_datas.removeAllElements();
		}
	}

	/**²éѯij¸ö¶ÔÏóÊÇ·ñÒѾ­´æÔÚ*/
	public static boolean forward_data_is_have(String type,String ip,String port,String datatyp ) {
		boolean forward_data_is_have=false;
		if(tb_forward_datas.size() !=0) {
			Iterator<Tb_forward_data> it=tb_forward_datas.iterator();
			while(it.hasNext()) {
				Tb_forward_data forward_data=it.next();
				String type1=forward_data.getType();
				String ip1=forward_data.getIp();
				String port1=forward_data.getPort();
				String datatype1=forward_data.getDatatype();
				if(type1.equals(type) && ip1.equals(ip) && port1.equals(port) && datatype1.equals(datatyp)) {
					forward_data_is_have=true;
					break;
				}
			}
		}

		return forward_data_is_have;

	}


	public static void xiugai(String id,String type,String ip,String port,String datatype) {
		if(get_forward_data(id) !=null) {
			get_forward_data(id).setType(type);
			get_forward_data(id).setPort(port);
			get_forward_data(id).setIp(ip);
			get_forward_data(id).setDatatype(datatype);
		}
	}

	/**»ñȡijÖÖת·¢¶ÔÏóµÄËùÓм¯ºÏ
	 * @param typeת·¢ÀàÐÍÈçUDP
	 * @param datypeÐèҪת·¢µÄÊý¾Ý*/
	public  static Vector<Tb_forward_data> get_mou_tb_forword(String type,String datatype){
		Vector<Tb_forward_data> mou_data=new Vector<>();
		if(tb_forward_datas.size() !=0) {
			Iterator<Tb_forward_data> it=tb_forward_datas.iterator();
			while(it.hasNext()) {
				Tb_forward_data forward_data=it.next();
				String type1=forward_data.getType();
				String datatype1=forward_data.getDatatype();				
				if(type1.equals(type) && datatype1.equals(datatype) ) {					
					mou_data.add(forward_data);
				}
			}
		}
		return mou_data;		
	}






	/**»ñȡijÖÖÀàÐ͵ÄÐèҪת·¢µÄÊý¾Ý¶ÔÏ󼯺Ï*/
	public  static Vector<Tb_forward_data> get_mou_tb_forword(String type){
		Vector<Tb_forward_data> mou_data=new Vector<>();
		if(tb_forward_datas.size() !=0) {
			Iterator<Tb_forward_data> it=tb_forward_datas.iterator();
			while(it.hasNext()) {
				Tb_forward_data forward_data=it.next();
				String type1=forward_data.getType();				
				if(type1.equals(type) ) {					
					mou_data.add(forward_data);
				}
			}
		}

		return mou_data;		
	}

	/**»ñȡij¸öHTTPת·¢¶ÔÏó*/
	public static Tb_forward_data gethttp() {
		Tb_forward_data http=null;
		int size=get_mou_tb_forword("HTTP-Server").size();
		if(size !=0) {
			http=get_mou_tb_forword("HTTP-Server").get(0);
		}
		return http;
	}

	/**Èç¹û´æÔÚÐèÒªTCPת·¢µÄµØÖ·ºÍ¶Ë¿Ú²¢ÇÒÐèҪת·¢µÄÊÇλÖÃÊý¾Ý*/
	public static boolean have_tcp(String datatype) {
		boolean have=false;
		if(get_mou_tb_forword("TCP",datatype).size() !=0) {
			have=true;
		}
		return have;		
	}

	/**Èç¹û´æÔÚÐèÒªUDPת·¢µÄµØÖ·ºÍ¶Ë¿Ú²¢ÇÒÐèҪת·¢µÄÊÇλÖÃÊý¾Ý*/
	public static boolean have_udp(String datatype) {
		boolean have=false;
		if(get_mou_tb_forword("UDP",datatype).size() !=0) {
			have=true;
		}
		return have;		
	}

	/**ÅжÏÊÇ·ñ´æÔÚHTTPÊý¾Ýת·¢ÀàÐÍ*/
	public static boolean have_http(String datatype) {
		boolean have=false;
		int size=get_mou_tb_forword("HTTP-Client",datatype).size();
		if( size!=0) {
			have=true;
		}
		return have;
	}

	public static Vector<Tb_forward_data> getTb_forward_datas() {
		return tb_forward_datas;
	}

	public static boolean isCutom1() {
		return cutom1;
	}

	public static void setCutom1(boolean cutom1) {
		ForwardDatas.cutom1 = cutom1;
	}



	public static boolean isTCP() {
		return TCP;
	}



	public static void setTCP(boolean tCP) {
		TCP = tCP;
	}



	public static boolean isUDP() {
		return UDP;
	}



	public static void setUDP(boolean uDP) {
		UDP = uDP;
	}



	public static boolean isHTTPClient() {
		return HTTPClient;
	}



	public static void setHTTPClient(boolean hTTPClient) {
		HTTPClient = hTTPClient;
	}



	public static boolean isHTTPServer() {
		return HTTPServer;
	}



	public static void setHTTPServer(boolean hTTPServer) {
		HTTPServer = hTTPServer;
	}



	public static void setTb_forward_datas(Vector<Tb_forward_data> tb_forward_datas) {
		ForwardDatas.tb_forward_datas = tb_forward_datas;
	}

	public static Vector<Tb_forward_data> getDisplaydata() {
		return displaydata;
	}

	public static void setDisplaydata(Vector<Tb_forward_data> displaydata) {
		ForwardDatas.displaydata = displaydata;
	}

	public static Vector<Tb_forward_data> getAlldata() {
		return alldata;
	}

	public static void setAlldata(Vector<Tb_forward_data> alldata) {
		ForwardDatas.alldata = alldata;
	}

	public static Vector<Tb_forward_data> getWarningdata() {
		return warningdata;
	}

	public static void setWarningdata(Vector<Tb_forward_data> warningdata) {
		ForwardDatas.warningdata = warningdata;
	}

	public static Vector<Tb_forward_data> getYuanshidata() {
		return yuanshidata;
	}

	public static void setYuanshidata(Vector<Tb_forward_data> yuanshidata) {
		ForwardDatas.yuanshidata = yuanshidata;
	}

	public static Vector<Tb_forward_data> getGasdata() {
		return gasdata;
	}

	public static void setGasdata(Vector<Tb_forward_data> gasdata) {
		ForwardDatas.gasdata = gasdata;
	}

	public static Vector<Tb_forward_data> getTongjidata() {
		return tongjidata;
	}

	public static void setTongjidata(Vector<Tb_forward_data> tongjidata) {
		ForwardDatas.tongjidata = tongjidata;
	}

	public static Vector<Tb_forward_data> getBujudata() {
		return bujudata;
	}

	public static void setBujudata(Vector<Tb_forward_data> bujudata) {
		ForwardDatas.bujudata = bujudata;
	}

	public static Vector<Tb_forward_data> getGnggadta() {
		return gnggadta;
	}

	public static void setGnggadta(Vector<Tb_forward_data> gnggadta) {
		ForwardDatas.gnggadta = gnggadta;
	}

	public static Vector<Tb_forward_data> getCustom1data() {
		return custom1data;
	}

	public static void setCustom1data(Vector<Tb_forward_data> custom1data) {
		ForwardDatas.custom1data = custom1data;
	}

	public static boolean isHavezhuanfa() {
		return havezhuanfa;
	}

	public static void setHavezhuanf(boolean havezhuanfa) {
		ForwardDatas.havezhuanfa = havezhuanfa;
	}

	public static boolean isIstongji() {
		return istongji;
	}

	public static void setIstongji(boolean istongji) {
		ForwardDatas.istongji = istongji;
	}


}