package com.hxzkoa.udp;

import com.hxzkoa.util.Config;
import com.hxzkoa.util.HttpUtil;

import net.sf.json.JSONObject;

/**告警信息*/
public class Warnig {

	static int IMUSTATE=2;
	static int SLEEPSTATE=2;

	/**低电量告警*/
	public static void lowpower(int power,String tagid) {
		if(ForwardDatas.get_tb_forward_datas().size() !=0) {
			//如果存在UDP转发告警数据或者全部数据选择项的时候
			/**Warning:[len],TAG_SLP,[TAGID],[Timestamp]**/
			int len=0;
			String warnig1="Warning: "+len+",TAG_SLP,"+tagid+","+GetNowTime.timestamp2();
			len=warnig1.length()+1;
			String warnig="Warning: "+len+",TAG_SLP,"+tagid+","+GetNowTime.timestamp2();
			String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
			String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ warnig + "\"}";
			JSONObject json = JSONObject.fromObject(messageJson);
			HttpUtil.doPost(postUrl, json, "UTF-8");
			warnig1=null;
			warnig=null;
		}
	}

	/**SOS告警*/
	public static void sos(StringBuffer button,StringBuffer jingzhi,StringBuffer xiumian,
			StringBuffer receive_tagid,String addtime,StringBuffer receive_baoxu) {

		if(ForwardDatas.get_tb_forward_datas().size() !=0) {
			StringBuffer SOS01=new StringBuffer("");
			StringBuffer SOS02=new StringBuffer("");
			StringBuffer SOS04=new StringBuffer("");
			StringBuffer SOS05=new StringBuffer("");
			StringBuffer SOS06=new StringBuffer("");

			if(IMUSTATE==2) {
				IMUSTATE=Integer.parseInt(jingzhi.toString());			
				SLEEPSTATE=Integer.parseInt(xiumian.toString());
			}else {

				int jingzhiint=Integer.parseInt(jingzhi.toString())-IMUSTATE;
				int xiumianint=Integer.parseInt(xiumian.toString())-SLEEPSTATE;
				//状态改变
				if(jingzhiint !=0) {
					int len=0;
					StringBuffer SOS=new StringBuffer("warning: "+len+",SOS0x05,"+receive_tagid+","+addtime+","+IMUSTATE+","+jingzhi);
					len=SOS.length()+1;
					SOS05=new StringBuffer("warning: "+len+",SOS0x05,"+receive_tagid+","+addtime+","+IMUSTATE+","+jingzhi);
					SOS=null;
				}

				if(xiumianint !=0) {
					int len=0;
					StringBuffer SOS=new StringBuffer("warning: "+len+",SOS0x06,"+receive_tagid+","+addtime+","+SLEEPSTATE+","+xiumian);
					len=SOS.length()+1;
					SOS06=new StringBuffer("warning: "+len+",SOS0x06,"+receive_tagid+","+addtime+","+SLEEPSTATE+","+xiumian);
					SOS=null;
				}

				IMUSTATE=Integer.parseInt(jingzhi.toString());			
				SLEEPSTATE=Integer.parseInt(xiumian.toString());

			}



			//标SOS告警
			if(button.toString().equals("1")) {
				int len=0;
				StringBuffer SOS=new StringBuffer("warning: "+len+",SOS0x01,"+receive_tagid+","+addtime+","+receive_baoxu);
				len=SOS.length()+1;
				SOS01=new StringBuffer("warning: "+len+",SOS0x01,"+receive_tagid+","+addtime+","+receive_baoxu);
				SOS=null;
			}

			//标签静止告警
			if(jingzhi.toString().equals("1")) {
				int len=0;
				StringBuffer SOS=new StringBuffer("warning: "+len+",SOS0x02,"+receive_tagid+","+addtime+","+receive_baoxu);
				len=SOS.length()+1;
				SOS02=new StringBuffer("warning: "+len+",SOS0x02,"+receive_tagid+","+addtime+","+receive_baoxu);
				SOS=null;
			}

			//标签休眠告警
			if(xiumian.toString().equals("1")) {
				int len=0;
				StringBuffer SOS=new StringBuffer("warning: "+len+",SOS0x04,"+receive_tagid+","+addtime+","+receive_baoxu);
				len=SOS.length()+1;
				SOS04=new StringBuffer("warning: "+len+",SOS0x04,"+receive_tagid+","+addtime+","+receive_baoxu);
				SOS=null;
			}



			/**UDP转发告警数据**/
			/**如果存在需要UDP转发位置信息**/

			if(SOS01.length()>15) {
				String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
				String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ SOS01 + "\"}";
				JSONObject json = JSONObject.fromObject(messageJson);
				HttpUtil.doPost(postUrl, json, "UTF-8");
			}

			if(SOS02.length()>15) {
				String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
				String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ SOS02 + "\"}";
				JSONObject json = JSONObject.fromObject(messageJson);
				HttpUtil.doPost(postUrl, json, "UTF-8");				
			}

			if(SOS04.length()>15) {
				String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
				String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ SOS04 + "\"}";
				JSONObject json = JSONObject.fromObject(messageJson);
				HttpUtil.doPost(postUrl, json, "UTF-8");
			}

			if(SOS05.length()>15) {
				String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
				String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ SOS05 + "\"}";
				JSONObject json = JSONObject.fromObject(messageJson);
				HttpUtil.doPost(postUrl, json, "UTF-8");
			}

			if(SOS06.length()>15) {
				String postUrl=Config.getPostUrl()+"doMessageTransfer.do";
				String messageJson = "{\"dataType\":\"告警数据\","+"\"result\":\""+ SOS06 + "\"}";
				JSONObject json = JSONObject.fromObject(messageJson);
				HttpUtil.doPost(postUrl, json, "UTF-8");
			}

			SOS01=new StringBuffer("");
			SOS02=new StringBuffer("");
			SOS04=new StringBuffer("");	
			SOS05=new StringBuffer("");	
			SOS06=new StringBuffer("");	
		}
	}

	/**基站离线告警
	 * warning:[LEN],OFFANCH,[DEVID],[TIMESTAMP]
	 * 示例：定位引擎开启后，上过线的基站离线告警格式如下：
	 * warning: 48,OFFANCH,7012,2017-05-25 14:37:55.923
	 */
//	public static void anchor_off(String anchorid) {
//		if(ForwardDatas.get_tb_forward_datas().size() !=0) {
//			int len=0;
//			String waring1="warning: "+len+",OFFANCH,"+anchorid+","+GetNowTime.timestamp2();
//			len=waring1.length()+1;
//			String waring="warning: "+len+",OFFANCH,"+anchorid+","+GetNowTime.timestamp2();
//
//			if(ForwardDatas.have_udp("告警数据") || ForwardDatas.have_udp("全部数据") ) {
//				//如果存在全部转发数据
//				if(ForwardDatas.get_mou_tb_forword("UDP", "全部数据").size() !=0) {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"全部数据");
//				}else {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"告警数据");
//				}
//				//显示UDP转发的数据
//				BaoWenShow.show(waring.toString(), "UDP转发");
//			}
//
//
//			/**如果存在需要TCP转发**/
//			if((ForwardDatas.have_tcp("告警数据") || ForwardDatas.have_tcp("全部数据"))) {
//				TcpClientOneToMany.send(waring);
//			}
//
//
//			waring=null;
//			waring1=null;
//
//		}
//	}


	/**标签离线告警
	 * 	 warning:[LEN],OFF_TAG,[DEVID],[TIMESTAMP]
	 * 示例：定位引擎开启后，上过线后离线的标签告警格式如下：
	 * warning: 48,OFF_TAG,D205,2017-05-25 14:28:15.346
	 */
//	public static void tag_off(String tagid) {
//		if(ForwardDatas.get_tb_forward_datas().size() !=0) {
//			int len=0;
//			String waring1="warning: "+len+",OFF_TAG,"+tagid+","+GetNowTime.timestamp2();
//			len=waring1.length()+1;
//			String waring="warning: "+len+",OFF_TAG,"+tagid+","+GetNowTime.timestamp2();
//
//			if(ForwardDatas.have_udp("告警数据") || ForwardDatas.have_udp("全部数据") ) {
//				//如果存在全部转发数据
//				if(ForwardDatas.get_mou_tb_forword("UDP", "全部数据").size() !=0) {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"全部数据");
//				}else {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"告警数据");
//				}
//				//显示UDP转发的数据
//				BaoWenShow.show(waring.toString(), "UDP转发");
//			}
//
//
//			/**如果存在需要TCP转发**/
//			if((ForwardDatas.have_tcp("告警数据") || ForwardDatas.have_tcp("全部数据"))) {
//				TcpClientOneToMany.send(waring);
//			}
//
//
//			waring=null;
//			waring1=null;
//
//		}
//	}


	/**进入危险区域告警
	 * 	 * RGN_IN：表示进入危险区域
	 * RGN_OUT：表示已经离开危险区域
	 * warning:[LEN],RGN_IN,[DEVID],[TIMESTAMP],[RNGID],[LAYID]
	 * 示例：warning: 58,RGN_IN,D59B,2018-09-05 14:22:20.274,告警1,0
	 * */
//	public static void in_warning(String tagid,String quname,String RGN_IN,String layid) {
//		if(ForwardDatas.get_tb_forward_datas().size() !=0) {
//			int len=0;
//			String waring1="warning: "+len+","+RGN_IN+","+tagid+","+GetNowTime.timestamp2()+","+quname+","+layid;
//			len=waring1.length()+1;
//			String waring="warning: "+len+","+RGN_IN+","+tagid+","+GetNowTime.timestamp2()+","+quname+","+layid;
//
//			if(ForwardDatas.have_udp("告警数据") || ForwardDatas.have_udp("全部数据") ) {
//				//如果存在全部转发数据
//				if(ForwardDatas.get_mou_tb_forword("UDP", "全部数据").size() !=0) {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"全部数据");
//				}else {
//					Udp_Out.udp_out(waring.getBytes(), waring.length(),"告警数据");
//				}
//				//显示UDP转发的数据
//				BaoWenShow.show(waring.toString(), "UDP转发");
//			}
//
//
//			/**如果存在需要TCP转发**/
//			if((ForwardDatas.have_tcp("告警数据") || ForwardDatas.have_tcp("全部数据"))) {
//				TcpClientOneToMany.send(waring);
//			}
//
//
//			waring=null;
//			waring1=null;
//
//		}
//	}

}