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;
|
//
|
// }
|
// }
|
|
}
|
