package BaoWen;
import java.util.LinkedHashMap;
import ColorAndFont.Data_to_bs;
import DataBase.DatabaseManagement;
import Method.GetNowTime;
import PbuliClass.Get_Tb_Gass;
import PbuliClass.Get_collectors;
import PbuliClass.Systems;
import VectroData.ForwardDatas;
import anchor.Anchor_Dell;
import anchor.Anchor_nerby_dell;
import http.HTTP_Post;
import person.person_Dell;
import tag.Tag_Dell;
import tbDataModel_Dell.Dell_TongbuAnchor;
import tbDataModel_Dell.Dell_tbcengzu;

/**´¦ÀíÊÕµ½µÄUDPÐÅÏ¢*/
public class Dell_Message {

	static boolean all=ForwardDatas.have_udp("È«²¿Êý¾Ý");
	static boolean havegngga=ForwardDatas.have_udp("GNGGA");
	static boolean havedisplay=ForwardDatas.have_udp("λÖÃÊý¾Ý");	
	static boolean savebaowen=Systems.sys().getOpensave().equals("1");

	/***¶¨Î»»ùÕ¾Ïà¹ØÐÅÏ¢£¬Ä¬È϶¨Î»ÒýÇ濪Æôʱºò·¢ËÍÒ»´Î
	 * anchor_info,[Length],[anchorid],[x],[y],[z],[layer],[zu],[distance],[tongbu],[ip],[version],[mark]
	 * ˵Ã÷
	 * 1	anchor_info£º°üÍ·
	 * 2	[Length]£º°ü³¤¶È
	 * 3	[anchorid] £º»ùÕ¾µÄidΨһ±àºÅ
	 * 4	[x] £º»ùÕ¾X×ø±ê£¬µ¥Î»ÀåÃ×
	 * 5	[y] £º»ùÕ¾Y×ø±ê£¬µ¥Î»ÀåÃ×
	 * 6	[z] £º»ùÕ¾Z×ø±ê£¬µ¥Î»ÀåÃ×
	 * 7	[layer] £º»ùÕ¾ËùÔÚ²ã
	 * 8	[zu] £º»ùÕ¾ËùÔÚµÄ×é
	 * 9	[distance] £º»ùÕ¾µÄÁ¿³Ì£¬µ¥Î»ÀåÃ×
	 * 10	[tongbu] £º»ùվͬ²½Çé¿ö
	 * 11	[ip] £º»ùÕ¾µÄipµØÖ·
	 * 12	[version] £º»ùÕ¾µÄ°æ±¾
	 * 13	[mark] £º±ê־룬Çø±ð´ÓÄĸöÒýÇæÉÏ´«Êý¾Ý£¬ÊÊÓÃÓÚ¶à¸öÏîÄ¿´«ÈëÒ»¸öƽ̨£¬Ä¬ÈÏΪ0
	 */

	@SuppressWarnings("unused")
	public static void dell_anchor_info(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==13) {
			String anchorid=mes[2];
			String posx=mes[3];
			String posy=mes[4];
			String posz=mes[5];
			String layer=mes[6];
			String zu=mes[7];
			String distance=mes[8];
			String tongbu=mes[9];
			String ip=mes[10];
			String version=mes[11];
			String mark=mes[12];

			if(distance.equals("null")) {
				distance="";
			}

			if(tongbu.equals("null")) {
				tongbu="";
			}

			if(ip.equals("null")) {
				ip="";
			}

			if(version.equals("null")) {
				version="";
			}




			if(Anchor_Dell.get_anchor(anchorid)==null) {
				String[]  ziduan= {"anchorid","POSX","POSY","POSZ","layer","zu","liangcheng","anchorip","version","GreateTime","anchormode","baoliu9"};
				String[] zhi= {anchorid,posx,posy,posz,layer,zu,distance,ip,version,GetNowTime.now(),"1"};			
				DatabaseManagement.insertfast("tb_achor", ziduan, zhi);				
				Dell_tbcengzu.add_cengzu_form_addanchor(layer, zu);//Ìí¼Ó²ã×é¶ÔÏó				
				Anchor_nerby_dell.add_anchorby(anchorid,"","","","","","","","","","","0");//ÐÂÔöÁÙ½ü»ùÕ¾ÐÅÏ¢				
				Dell_TongbuAnchor.add_one_rootanchor(anchorid, "", "0", "");//ÐÂÔöͬ²½»ùÕ¾
				Anchor_Dell.set_anchor(anchorid, posx,posy,posz,layer,zu,distance,ip, "1","0");
			}else {
				String[]  ziduan= {"anchormode","POSX","POSY","POSZ","layer","zu","liangcheng","anchorip","version","GreateTime","anchorid"};
				String[] zhi= {"1",posx,posy,posz,layer,zu,distance,ip,version,GetNowTime.now(),anchorid};		
				DatabaseManagement.fast_alert_dbase("tb_achor", ziduan, zhi);
				Anchor_Dell.alert_anchor(anchorid, posx,posy,posz, layer, distance, "0", ip, version,"1");
			}
		}
	}

	/**3.	»ùÕ¾ÁÙ½üÐÅÏ¢anchor_near
	 * »ùÕ¾ÁÙ½üÐÅÏ¢
	 * anchor_near,[length], [anchorid], [near1],[near2],[near3],[near4], [near5], [near6], [near7], [near8], [distance],[mark]
	 * ˵Ã÷
	 * 1	anchor_near£º°üÍ·
	 * 2	[length] £ºÊý¾Ý°ü³¤¶È
	 * 3	[anchorid]£º»ùÕ¾ID
	 * 4	[near1] £ºÁÙ½ü»ùÕ¾1ID
	 * 5	[near2] £ºÁÙ½ü»ùÕ¾2ID
	 * 6	[near3] £ºÁÙ½ü»ùÕ¾3ID
	 * 7	[near4] £ºÁÙ½ü»ùÕ¾4ID
	 * 8	[near5] £ºÁÙ½ü»ùÕ¾5ID
	 * 9	[near6] £ºÁÙ½ü»ùÕ¾6ID
	 * 10	[near7] £ºÁÙ½ü»ùÕ¾7ID
	 * 11	[near8] £ºÁÙ½ü»ùÕ¾8ID
	 * 12	[distance] £ºÁÙ½ü»ùÕ¾9ID
	 * 13	[mark] £º±ê־룬Çø±ð´ÓÄĸöÒýÇæÉÏ´«Êý¾Ý£¬ÊÊÓÃÓÚ¶à¸öÏîÄ¿´«ÈëÒ»¸öƽ̨£¬Ä¬ÈÏΪ0**/
	@SuppressWarnings("unused")
	public static void dell_anchor_near(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==13) {
			String anchorid=mes[2];
			String near1=mes[3];
			String near2=mes[4];
			String near3=mes[5];
			String near4=mes[6];
			String near5=mes[7];
			String near6=mes[8];
			String near7=mes[9];
			String near8=mes[10];
			String distance=mes[11];
			String mark=mes[12];


			if(near1.equals("FFFF")) {
				near1="";
			}

			if(near2.equals("FFFF")) {
				near2="";
			}

			if(near3.equals("FFFF")) {
				near3="";
			}

			if(near4.equals("FFFF")) {
				near4="";
			}

			if(near5.equals("FFFF")) {
				near5="";
			}

			if(near6.equals("FFFF")) {
				near6="";
			}

			if(near7.equals("FFFF")) {
				near7="";
			}

			if(near8.equals("FFFF")) {
				near8="";
			}



			if(Anchor_nerby_dell.get_anchor(anchorid) !=null) {
				String[]  ziduan= {"near1","near2","near3","near4","near5","near6","near7","near8","qiehuan","anchorid"};
				String[] zhi= {near1,near2,near3,near4,near5,near6,near7,near8,distance,anchorid};		
				DatabaseManagement.fast_alert_dbase("tb_anchor_nearby", ziduan, zhi);
			}
		}
	}

	/**
	 * »ùվͬ²½ÉèÖÃÐÅÏ¢anchor_tongbu 
	 * anchor_tongbu,[length],[anchorid],[tongbuanchorid],[anchortype],[state],[mark]
	 * 1	anchor_tongbu£º°üÍ·
	 * 2	[length]£º±¨Îij¤¶È
	 * 3	[anchorid] £º»ùÕ¾ID
	 * 4	[tongbuanchorid] £ºÍ¬²½»ùÕ¾ID
	 * 5	[anchortype] £º»ùÕ¾ÀàÐÍ
	 * 6	[state] £ºÍ¬²½×´Ì¬
	 * 7	[mark] £º±ê־룬Çø±ð´ÓÄĸöÒýÇæÉÏ´«Êý¾Ý£¬ÊÊÓÃÓÚ¶à¸öÏîÄ¿´«ÈëÒ»¸öƽ̨£¬Ä¬ÈÏΪ0**/

	@SuppressWarnings("unused")
	public static void dell_anchor_tongbu(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==7) {
			String anchorid=mes[2];
			String tongbuanchorid=mes[3];
			String anchortype=mes[4];
			String state=mes[5];
			String mark=mes[6];
			if(Dell_TongbuAnchor.get_tb_rootanchor(tongbuanchorid) !=null) {
				String[]  ziduan= {"rootanchorid","type","state","addtime","anchorid"};
				String[] zhi= {tongbuanchorid,anchortype,state,GetNowTime.now(),anchorid};		
				DatabaseManagement.fast_alert_dbase("tb_tongbuanchor", ziduan, zhi);
			}
		}
	}


	/**
	 * ±êÇ©Ïà¹ØÐÅÏ¢tag_info
	 * ¶¨Î»±êÇ©Ïà¹ØÐÅÏ¢£¬Ä¬È϶¨Î»ÒýÇ濪Æôʱºò·¢ËÍÒ»´Î
	 * Êý¾Ý¸ñʽ£º BSTOCS1,ADDTAG,±êÇ©id,°ó¶¨¶ÔÏó,Åå´÷¸ß¶È,ËÙ¶ÈÏÞÖÆ,¶¨Î»ÆµÂÊ,±êÇ©ÀàÐÍ,END
	 * Tag_info,[length],[tagid],[name],[power],[gao],[speed],[hz],[version],[sleepopen],
	 * [sleeptime],[gonglv],[mcuzhi],[mcutime],[moveopen],[±êÖ¾]
	 * ˵Ã÷
	 * 1	Tag_info£º°üÍ·
	 * 2	[length] £º°ü³¤¶È
	 * 3	[tagid] £º±êÇ©id£¬Î¨Ò»±àºÅ
	 * 4	[name] £º±êÇ©°ó¶¨µÄÃû³Æ
	 * 5	[power] £º±êÇ©µçÁ¿£¬0~100Êý×Ö
	 * 6	[gao] £º±êÇ©Åå´÷¸ß¶Èµ¥Î»ÀåÃ×
	 * 7	[speed] £º±êÇ©×î´óÔ˶¯ËÙ
	 * 8	[hz] £º±êÇ©µÄƵÂÊ
	 * 9	[version] £º±êÇ©µÄ°æ±¾
	 * 10	[sleepopen] £º±êÇ©ÐÝÃßÊÇ·ñ¿ªÆô£¬¿ªÆôΪ1£¬Ã»ÓпªÆôΪ0
	 * 11	[sleeptime] £º±êÇ©ÐÝÃßʱ¼ä
	 * 12	[gonglv] £º±êÇ©¹¦ÂÊ
	 * 13	[mcuzhi] £º±êÇ©mcuÖµ
	 * 14	[moveopen] £º±êÇ©Õ𶯹¦ÄÜÊÇ·ñ¿ªÆô£¬¿ªÆôΪ1·´Ö®Îª0
	 * 15	[mark] £º±ê־λ,ÓÃÓÚÇø·Ö²»Í¬ÒýÇæÉÏ´«µÄÊý¾Ý£¬Ä¬ÈÏΪ0**/

	@SuppressWarnings("unused")
	public static void dell_tag_info(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==15) {
			String tagid=mes[2];
			String name=mes[3];
			String power=mes[4];
			String gao=mes[5];
			String speed=mes[6];
			String hz=mes[7];
			String version=mes[8];
			String sleepopen=mes[9];
			String sleeptime=mes[10];
			String gonglv=mes[11];
			String mcuzhi=mes[12];
			String moveopen=mes[13];
			String mark=mes[14];

			if(speed.equals("ÎÞ")) {
				speed="1000";
			}
			if(gonglv.length()>2) {
				gonglv="67";
			}
			if(sleeptime.equals("null")) {
				sleeptime="120";
			}
			if(sleepopen.equals("null")) {
				sleepopen="0";
			}
			if(mcuzhi.equals("null")) {
				mcuzhi="10";
			}
			if(moveopen.equals("null")) {
				moveopen="0";
			}


			if(Tag_Dell.get_tag(tagid)==null) {
				String[]  ziduan= {"tag_id","state","power","status","gaodu","sudu","pinglv","Addtime"};
				String[] zhi= {tagid,name,power,"1",gao,speed,hz,GetNowTime.now()};
				DatabaseManagement.insertfast("tb_tag", ziduan, zhi);
				//ÐÂÔöÈËÔ±
				person_Dell.add_person(tagid, "ϵͳĬÈÏ", name, "ÄÐ", " ",speed,"ϵͳĬÈÏ");
				Tag_Dell.add_tag2(tagid, name, gao, speed,hz);

			}else {
				String[]  ziduan= {"state","power","status","gaodu","sudu","pinglv","Addtime","tag_id"};
				String[] zhi= {name,power,"1",gao,speed,hz,GetNowTime.now(),tagid};			
				DatabaseManagement.fast_alert_dbase("tb_tag", ziduan, zhi);
				Tag_Dell.alert_tag(
						tagid, 
						version, 
						moveopen, 
						sleepopen, 
						"0", 						
						Integer.parseInt(gonglv),
						Integer.parseInt(speed), 
						Integer.parseInt(sleeptime),
						Integer.parseInt(power),
						0);
			}
		}
	}

	/**ÆøÌå²É¼¯ÒÇÐÅÏ¢gas_colector
	 * ÆøÌå²É¼¯ÒÇÐÅÏ¢£¬Ä¬È϶¨Î»ÒýÇ濪Æôʱºò·¢ËÍÒ»´Î
	 * gas_colector,[length],[dizhi],[qishidizhi],[datalength],[ip],[weizhi],[x],[y],[mark]
	 * ˵Ã÷
	 * 1	gas_colector£º°üÍ·
	 * 2	[length]£º±¨Îij¤¶È
	 * 3	[dizhi] £º²É¼¯ÒǵØÖ·
	 * 4	[qishidizhi] £ºÆðʼµØÖ·
	 * 5	[datalength] £ºÊý¾Ý³¤¶È
	 * 6	[ip] £ºipµØÖ·
	 * 7	[weizhi] £º°²×°Î»ÖÃ
	 * 8	[x] £º°²×°X×ø±ê
	 * 9	[y] £º°²×°Y×ø±ê
	 * 10	[mark] £º±ê־룬Çø±ð´ÓÄĸöÒýÇæÉÏ´«Êý¾Ý£¬ÊÊÓÃÓÚ¶à¸öÏîÄ¿´«ÈëÒ»¸öƽ̨£¬Ä¬ÈÏΪ0**/
	@SuppressWarnings("unused")
	public static void dell_gas_colector(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==10) {
			String dizhi=mes[2];
			String qishidizhi=mes[3];
			String datalength=mes[4];
			String ip=mes[5];
			String weizhi=mes[6];
			String x=mes[7];
			String y=mes[8];
			String mark=mes[9];
			if(Get_collectors.get_caijingyi(ip)==null) {
				String[]  ziduan= {"macid","startip","datlenth","ip","macname","posx","posy","addtime"};
				String[] zhi= {dizhi,qishidizhi,datalength,ip,weizhi,x,y,GetNowTime.now()};
				DatabaseManagement.insertfast("tb_collector", ziduan, zhi);			

			}else {
				String[]  ziduan= {"tb_collector","startip","datlenth","macname","posx","posy","addtime","ip"};
				String[] zhi= {dizhi,qishidizhi,datalength,weizhi,x,y,GetNowTime.now(),ip};		
				DatabaseManagement.fast_alert_dbase("tb_collector", ziduan, zhi);

			}
		}
	}

	/**ÆøÌå´«¸ÐÆ÷Ïà¹ØÐÅÏ¢gas_sensor
	 * ÆøÌå´«¸ÐÆ÷ÐÅÏ¢ÐÅÏ¢£¬£¬Ä¬È϶¨Î»ÒýÇ濪Æôʱºò·¢ËÍÒ»´Î
	 * gas_sensor,[length],[weizhi],[gastype],[nongdu],[caijidizhi],[tongdao],[warning],[ip],[x],[y],[mark]
	 * ˵Ã÷£º
	 * 1	gas_sensor£º°üÍ·
	 * 2	[length] £º±¨Îij¤¶È
	 * 3	[weizhi] £ºÆøÌå´«¸ÐÆ÷°²×°Î»ÖÃ
	 * 4	[gastype] £ºÆøÌåÀàÐÍ
	 * 5	[nongdu] £ºÆøÌåŨ¶ÈÖµ
	 * 6	[caijidizhi] £º²É¼¯ÒǵØÖ·
	 * 7	[tongdao] £ºÆøÌå´«¸ÐÆ÷ËùÔڲɼ¯ÒǵÄͨµÀ
	 * 8	[warning] £º¸æ¾¯ãÐÖµ
	 * 9	[ip] £º²É¼¯ÒǵÄIPµØÖ·
	 * 10	[x] £ºÆøÌå´«¸ÐÆ÷°²×°µÄλÖÃX×ø±ê
	 * 11	[y] £ºÆøÌå´«¸ÐÆ÷°²×°Î»ÖÃY×ø±ê
	 * 12	[mark] £º±ê־룬Çø±ð´ÓÄĸöÒýÇæÉÏ´«Êý¾Ý£¬ÊÊÓÃÓÚ¶à¸öÏîÄ¿´«ÈëÒ»¸öƽ̨£¬Ä¬ÈÏΪ0**/
	@SuppressWarnings("unused")
	public static void dell_gas_sensor(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==12) {
			String weizhi=mes[2];
			String gastype=mes[3];
			String nongdu=mes[4];
			String caijidizhi=mes[5];
			String tongdao=mes[6];
			String warning=mes[7];
			String ip=mes[8];
			String x=mes[9];
			String y=mes[10];
			String mark=mes[11];
			if(Get_Tb_Gass.get_gas(tongdao, ip)==null) {
				String[]  ziduan= {"wei_zhi","gas_type","nong_du","status","collect_ip","tong_dao","waring_zhi","ip","x","y","addtime"};
				String[] zhi= {weizhi,gastype,nongdu,"Õý³£",caijidizhi,tongdao,warning,ip,x,y,GetNowTime.now()};
				DatabaseManagement.insertfast("tb_gas", ziduan, zhi);			

			}
		}
	}

	/**»ñÈ¡»ùÕ¾Ïà¹ØÐÅÏ¢get_anchor_info
	 * ±¨Îĸñʽ
	 * get_anchor_info,[anchorid/all],[end]
	 * ˵Ã÷
	 * 1	get_anchor_info£º°üÍ·
	 * 2	[anchorid/all] £ºÐèÒª»ñÈ¡µÄ»ùÕ¾ID£¬ÈçÐèÒª»ñÈ¡ËùÓоÍΪall
	 * 3	[end] £º±¨ÎĽáÊø±êÖ¾**/
	public static void dell_get_anchor_info(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==3) {
			String anchorid=mes[1];
			if(anchorid.equals("all")) {
				Data_to_bs.get_anchor_info();
			}else {
				Data_to_bs.get_one_anchor_info(anchorid);
			}
		}
	}

	/**»ñÈ¡»ùÕ¾ÁÙ½üÐÅÏ¢get_anchor_nearinfo
	 * 	±¨Îĸñʽ
	 * 	get_anchor_nearinfo,[anchorid/all],[end]
	 * 	˵Ã÷	
	 * 1	get_anchor_nearinfo£º°üÍ·
	 * 	2	[anchorid/all]£ºÐèÒª»ñÈ¡µÄ»ùÕ¾ID£¬È«²¿»ñȡΪall
	 * 	3	[end]£º±¨ÎĽáÊø±êÖ¾**/

	public static void dell_get_anchor_nearinfo(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==3) {
			String anchorid=mes[1];
			if(anchorid.equals("all")) {
				Data_to_bs.get_anchor_near();
			}else {
				Data_to_bs.get_one_anchor_nearby(anchorid);
			}
		}
	}


	/**
	 *»ñÈ¡±êÇ©ÐÅÏ¢get_taginfo
	 *±¨Îĸñʽ
	 *get_taginfo,[tagid/all],[end]
	 *˵Ã÷
	 *0	get_taginfo£º°üÍ·
	 *1	[tagid/all]£ºÐèÒª»ñÈ¡µÄ»ùÕ¾ID£¬È«²¿»ñȡΪall
	 *2	[end]£º±¨ÎĽáÊø±êÖ¾**/
	public static void dell_get_taginfo(String message) {
		String[] mes=message.split(",");
		int lenth=mes.length;
		if(lenth==3) {
			String tagid=mes[1];
			if(tagid.equals("all")) {
				Data_to_bs.get_tag_info();
			}else {
				Data_to_bs.get_one_taginfo(tagid);
			}
		}

	}



	/**´¦ÀíGPGGAÊý¾Ý*/
	public static void dell_gpgga(String message,String ip) {		
		//HTTPת·¢Î»ÖÃÊý¾Ý
		if(ForwardDatas.have_http("λÖÃÊý¾Ý")) {
			LinkedHashMap<String, Object> display=new LinkedHashMap<String, Object>();
			display.put("positionmsg", message);
			HTTP_Post.gngga("", "", display);
		}
	}


}