package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.lib.structure.NET_TIME;
|
import com.netsdk.lib.structure.NET_TIME_EX;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
|
import static com.netsdk.lib.NetSDKLib.*;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description GIP220629025
|
* @date 2022/7/19 10:01
|
*/
|
public class WireLessDevLowDemo extends Initialization {
|
|
|
/**
|
* 订阅
|
* @return
|
*/
|
public void startListen() {
|
// 设置报警回调函数
|
netSdk.CLIENT_SetDVRMessCallBack(fAlarmDataCB.getCallBack(), null);
|
|
// 订阅报警
|
boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle);
|
if (!bRet) {
|
System.err.println("订阅报警失败! LastError = 0x%x\n" + netSdk.CLIENT_GetLastError());
|
}
|
else {
|
System.out.println("订阅报警成功.");
|
}
|
}
|
|
/**
|
* 取消订阅
|
* @return
|
*/
|
public void stopListen() {
|
// 停止订阅报警
|
boolean bRet = netSdk.CLIENT_StopListen(loginHandle);
|
if (bRet) {
|
System.out.println("取消订阅报警信息.");
|
}
|
}
|
|
/**
|
* 报警信息回调函数原形,建议写成单例模式
|
*/
|
private static class fAlarmDataCB implements NetSDKLib.fMessCallBack{
|
private fAlarmDataCB(){}
|
|
private static class fAlarmDataCBHolder {
|
private static fAlarmDataCB callback = new fAlarmDataCB();
|
}
|
|
public static fAlarmDataCB getCallBack() {
|
return fAlarmDataCB.fAlarmDataCBHolder.callback;
|
}
|
|
public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP, NativeLong nDevicePort, Pointer dwUser){
|
// System.out.printf("command = %x\n", lCommand);
|
switch (lCommand)
|
{
|
case NetSDKLib.NET_ALARM_AREAARM_MODECHANGE: { // 区域防区模式改变(对应结构体ALARM_AREAARM_MODECHANGE_INFO)
|
|
System.out.println(" 区域防区模式改变");
|
ALARM_AREAARM_MODECHANGE_INFO msg = new ALARM_AREAARM_MODECHANGE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
/**
|
区域编号
|
*/
|
int nAreaIndex
|
= msg.nAreaIndex;
|
int nEventID
|
= msg.nEventID;
|
|
NET_TIME_EX utc
|
= msg.UTC;
|
int emTriggerMode
|
= msg.emTriggerMode;
|
|
int emUser
|
= msg.emUser;
|
|
int nID
|
= msg.nID;
|
System.out.println(" nAreaIndex:"+nAreaIndex);
|
System.out.println(" nEventID:"+nEventID);
|
System.out.println(" utc:"+utc);
|
System.out.println(" emTriggerMode:"+emTriggerMode);
|
System.out.println(" emUser:"+emUser);
|
System.out.println(" nID:"+nID);
|
|
break;
|
|
}
|
case NetSDKLib.NET_ALARM_ALARM_EX2: { // 本地报警事件(对应结构体ALARM_ALARM_INFO_EX2,对NET_ALARM_ALARM_EX升级)
|
System.out.println(" 本地报警事件");
|
NetSDKLib.ALARM_ALARM_INFO_EX2 msg = new NetSDKLib.ALARM_ALARM_INFO_EX2();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("nChannelID" + msg.nChannelID);
|
|
System.out.println("nAction" + msg.nAction);
|
|
System.out.println("stuTime" + msg.stuTime.toStringTime());
|
|
System.out.println("emSenseType" + msg.emSenseType);
|
|
System.out.println("emDefenceAreaType" + msg.emDefenceAreaType);
|
|
System.out.println("nEventID" + msg.nEventID);
|
|
System.out.println("szName" +new String(msg.szName) );
|
|
|
break;
|
}
|
|
case NetSDKLib.NET_ALARM_WIRELESSDEV_LOWPOWER:{ // 获取无线设备低电量上报事件(对应结构体ALARM_WIRELESSDEV_LOWPOWER_INFO)
|
System.out.println(" 获取无线设备低电量上报事件");
|
ALARM_WIRELESSDEV_LOWPOWER_INFO msg=new ALARM_WIRELESSDEV_LOWPOWER_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
int emResult
|
= msg.emResult;
|
System.out.println(" emResult:"+emResult);
|
|
NET_TIME stuTime
|
= msg.stuTime;
|
System.out.println(" stuTime:"+stuTime.toStringTime());
|
|
int emType
|
= msg.emType;
|
System.out.println(" emType:"+emType);
|
break;
|
}
|
case NetSDKLib.NET_ALARM_MODULE_LOST:{ // 扩展模块掉线事件(对应结构体 ALARM_MODULE_LOST_INFO)
|
System.out.println(" 扩展模块掉线事件");
|
NetSDKLib.ALARM_MODULE_LOST_INFO msg=new NetSDKLib.ALARM_MODULE_LOST_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件上报时间
|
NetSDKLib.NET_TIME stuTime=msg.stuTime;
|
|
System.out.println(" stuTime:"+stuTime.toStringTime());
|
|
// 扩展模块接的总线的序号(从0开始)
|
int nSequence
|
= msg.nSequence;
|
System.out.println(" nSequence:"+nSequence);
|
|
// 总线类型, 参考枚举 NET_BUS_TYPE
|
int emBusType = msg.emBusType;
|
System.out.println(" emBusType:"+emBusType);
|
// 掉线的扩展模块数目
|
int nAddr =msg.nAddr;
|
System.out.println(" nAddr:"+nAddr);
|
|
// 掉线的扩展模块的序号(从0开始)
|
int[] anAddr
|
= msg.anAddr;
|
|
for(int i=0;i<nAddr;i++){
|
System.out.println(anAddr[i]);
|
}
|
//// 设备类型 "SmartLock",是级联设备,当设备类型"AlarmDefence"接口序号为报警序号
|
System.out.println(" szDevType:"+new String(msg.szDevType));
|
|
|
// 在线情况 默认0。 0-不在线; 1-在线
|
System.out.println(" bOnline:"+msg.bOnline);
|
|
break;
|
}
|
case NET_ALARM_SENSOR_ABNORMAL:{// 探测器异常报警(对应结构体 ALARM_SENSOR_ABNORMAL_INFO)
|
|
System.out.println(" 探测器异常报警");
|
NetSDKLib.ALARM_SENSOR_ABNORMAL_INFO msg=new NetSDKLib.ALARM_SENSOR_ABNORMAL_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
int nAction
|
= msg.nAction;
|
System.out.println(" nAction:"+nAction);
|
|
int nChannelID= msg.nChannelID;
|
System.out.println(" nChannelID:"+nChannelID);
|
|
NetSDKLib.NET_TIME_EX stuTime= msg.stuTime;
|
System.out.println(" stuTime:"+stuTime.toStringTime());
|
|
System.out.println(" emStatus:"+msg.emStatus);
|
break;
|
}
|
|
case NET_ALARM_RCEMERGENCY_CALL:{// 紧急呼叫报警事件(对应结构体 ALARM_RCEMERGENCY_CALL_INFO)
|
|
System.out.println(" 紧急呼叫报警事件");
|
ALARM_RCEMERGENCY_CALL_INFO msg=new ALARM_RCEMERGENCY_CALL_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println(" nAction:" + msg.nAction );
|
System.out.println(" emType:" + msg.emType );
|
System.out.println(" Happend:" + msg.stuTime.toStringTime() );
|
System.out.println(" emMode:" + msg.emMode);
|
System.out.println(" dwID:" + msg.dwID );
|
|
if (msg.emType == 1) {
|
System.out.println("火警");
|
} else if (msg.emType == 2) {
|
System.out.println("胁迫");
|
} else if (msg.emType == 3) {
|
System.out.println("匪警");
|
} else if (msg.emType == 4) {
|
System.out.println("医疗");
|
|
} else if (msg.emType == 5) {
|
System.out.println("紧急");
|
}
|
break;
|
}
|
case NET_ALARM_BATTERYLOWPOWER:{ // 电池电量低报警(对应结构体 ALARM_BATTERYLOWPOWER_INFO)
|
System.out.println(" 电池电量低报警");
|
ALARM_BATTERYLOWPOWER_INFO msg=new ALARM_BATTERYLOWPOWER_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
//0:开始1:停止
|
int nAction = msg.nAction;
|
System.out.println(" nAction:" + nAction );
|
//剩余电量百分比,单位%
|
int nBatteryLeft = msg.nBatteryLeft;
|
System.out.println(" nBatteryLeft:" + nBatteryLeft );
|
|
//事件发生时间
|
|
NetSDKLib.NET_TIME stTime = msg.stTime;
|
System.out.println(" stTime:" + stTime.toStringTime() );
|
|
int nChannelID = msg.nChannelID;//通道号,标识子设备电池,从0开始
|
System.out.println(" nChannelID:" + nChannelID );
|
|
break;
|
}
|
case NET_ALARM_POWERFAULT: { // 电源故障事件(对应结构体ALARM_POWERFAULT_INFO)
|
System.out.println(" 电源故障事件");
|
ALARM_POWERFAULT_INFO msg=new ALARM_POWERFAULT_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
int emPowerType = msg.emPowerType;// 电源类型，详见EM_POWER_TYPE
|
System.out.println(" emPowerType:" + emPowerType );
|
|
int emPowerFaultEvent= msg. emPowerFaultEvent; // 电源故障事件，详见EM_POWERFAULT_EVENT_TYPE
|
System.out.println(" emPowerFaultEvent:" + emPowerFaultEvent );
|
// 报警事件发生的时间
|
NetSDKLib.NET_TIME stuTime
|
= msg.stuTime;
|
System.out.println(" stuTime:" + stuTime.toStringTime() );
|
// 0:开始 1:停止
|
int nAction = msg.nAction;
|
System.out.println(" nAction:" + nAction );
|
break;
|
}
|
case NET_ALARM_CHASSISINTRUDED: {// 机箱入侵(防拆)报警事件(对应结构体ALARM_CHASSISINTRUDED_INFO)
|
|
System.out.println(" 机箱入侵(防拆)报警事件");
|
ALARM_CHASSISINTRUDED_INFO msg=new ALARM_CHASSISINTRUDED_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
// 0:开始 1:停止
|
int nAction = msg.nAction;
|
System.out.println(" nAction:" + nAction );
|
// 报警事件发生的时间
|
NetSDKLib.NET_TIME stuTime
|
= msg.stuTime;
|
System.out.println(" stuTime:" + stuTime );
|
|
int nChannelID = msg.nChannelID;//通道号
|
System.out.println(" nChannelID:" + nChannelID );
|
|
byte[] szReaderID = msg.szReaderID;
|
System.out.println(" szReaderID:" + new String(szReaderID) );
|
|
// 事件ID
|
System.out.println(" nEventID:" + msg.nEventID );
|
|
// 无线设备序列号
|
System.out.println(" szSN:" + new String(msg.szSN) );
|
|
|
int bRealUTC = msg.bRealUTC;
|
System.out.println(" bRealUTC:" + bRealUTC );
|
|
|
System.out.println(" RealUTC:" + msg.RealUTC.toString() );
|
|
//设备类型,参考EM_ALARM_CHASSISINTRUDED_DEV_TYPE
|
System.out.println(" emDevType:" + msg.emDevType );
|
break;
|
}
|
case NET_ALARM_AREAALARM: {// 区域报警(对应结构体ALARM_AREAALARM_INFO)
|
System.out.println(" 区域报警");
|
ALARM_AREAALARM_INFO msg=new ALARM_AREAALARM_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
int nAreaIndex = msg.nAreaIndex;
|
System.out.println(" nAreaIndex:" + nAreaIndex );
|
|
|
System.out.println(" nEventID:" +msg.nEventID );
|
|
|
System.out.println(" UTC:" +msg.UTC.toString() );
|
|
System.out.println(" szName:" + new String(msg.szName) );
|
|
System.out.println(" emDefenceAreaType:" + msg.emDefenceAreaType );
|
|
System.out.println(" nIndex:" + msg.nIndex );
|
|
System.out.println(" emTrigerType:" + msg.emTrigerType );
|
|
break;
|
}
|
case NET_ALARM_RF_JAMMING:{// RF干扰事件(对应结构体 NET_ALARM_RF_JAMMING_INFO)
|
System.out.println(" RF干扰事件");
|
NET_ALARM_RF_JAMMING_INFO msg=new NET_ALARM_RF_JAMMING_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
System.out.println(" nAction:" + msg.nAction );
|
|
|
System.out.println(" nChannel:" + msg.nChannel );
|
|
System.out.println(" stuUTC:" + msg.stuUTC );
|
|
|
System.out.println(" szDeviceName:" + new String(msg.szDeviceName) );
|
|
break;
|
|
}
|
case NET_ALARM_ARMING_FAILURE:{ // 布防失败事件(对应结构体 NET_ALARM_ARMING_FAILURE_INFO)
|
|
System.out.println(" 布防失败事件");
|
NET_ALARM_ARMING_FAILURE_INFO msg=new NET_ALARM_ARMING_FAILURE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
// 通道号
|
System.out.println(" nChannel:" + msg.nChannel );
|
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString() );
|
// 布撤防模式
|
System.out.println(" emMode:" + msg.emMode );
|
|
|
break;
|
|
}
|
case NET_ALARM_USER_MODIFIED: { // 用户信息被修改(增加、删除、修改)事件(对应结构体 NET_ALARM_USER_MODIFIED_INFO)
|
|
System.out.println(" 用户信息被修改(增加、删除、修改)事件");
|
NET_ALARM_USER_MODIFIED_INFO msg=new NET_ALARM_USER_MODIFIED_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
// 通道号
|
System.out.println(" nChannel:" + msg.nChannel );
|
|
// 用户名称
|
System.out.println(" szUser:" + new String(msg.szUser) );
|
|
// 操作类型
|
System.out.println(" emOpType:" + msg.emOpType );
|
|
// 用户类型
|
System.out.println(" emUserType:" + msg.emUserType );
|
|
|
break;
|
}
|
case NET_ALARM_MANUAL_TEST:{ // 手动测试事件(对应结构体 NET_ALARM_MANUAL_TEST_INFO)
|
|
System.out.println(" 手动测试事件");
|
NET_ALARM_MANUAL_TEST_INFO msg=new NET_ALARM_MANUAL_TEST_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
// 通道号
|
System.out.println(" nChannel:" + msg.nChannel );
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString() );
|
// 配件序列号
|
System.out.println(" szSN:" + new String(msg.szSN) );
|
// 配件名称
|
System.out.println(" szName:" + new String(msg.szName) );
|
// 配件所属区域名称
|
System.out.println(" szAreaName:" + new String(msg.szAreaName) );
|
|
break;
|
}
|
case NET_ALARM_ATS_FAULT: { // 报警传输系统故障事件(对应结构体 NET_ALARM_ATS_FAULT_INFO)
|
System.out.println(" 报警传输系统故障事件");
|
NET_ALARM_ATS_FAULT_INFO msg=new NET_ALARM_ATS_FAULT_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
// 通道号
|
System.out.println(" nChannel:" + msg.nChannel );
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString() );
|
|
break;
|
}
|
case NET_ALARM_ARC_OFFLINE:{ // 报警接收中心离线事件(对应结构体 NET_ALARM_ARC_OFFLINE_INFO)
|
|
System.out.println(" 报警接收中心离线事件");
|
NET_ALARM_ARC_OFFLINE_INFO msg=new NET_ALARM_ARC_OFFLINE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
// 通道号
|
System.out.println(" nChannel:" + msg.nChannel );
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString() );
|
|
// ARC通讯异常描述信息
|
System.out.println(" szDetail:" + new String(msg.szDetail) );
|
|
|
break;
|
}
|
case NET_ALARM_WIFI_FAILURE:{ // wifi故障事件(对应结构体 NET_ALARM_WIFI_FAILURE_INFO)
|
System.out.println(" wifi故障事件");
|
NET_ALARM_WIFI_FAILURE_INFO msg=new NET_ALARM_WIFI_FAILURE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString());
|
// 配件序列号
|
System.out.println(" szSN:" + new String(msg.szSN) );
|
|
// 配件名称
|
System.out.println(" szName:" + new String(msg.szName) );
|
|
// wifi故障错误码 1:未知错误;2:无效的网络名称;3:无效的网络口令;4:网络故障
|
System.out.println(" nErrorCode:" + msg.nErrorCode );
|
|
// 所属区域信息个数
|
System.out.println(" nAreaInfoNum:" + msg.nAreaInfoNum );
|
|
NET_EVENT_AREAR_INFO[] stuAreaInfo = msg.stuAreaInfo;
|
|
for(int i=0;i<msg.nAreaInfoNum;i++){
|
NET_EVENT_AREAR_INFO info = stuAreaInfo[i];
|
System.out.println(" nIndex:" +info.nIndex );
|
|
System.out.println(" szName:" + new String(info.szName) );
|
|
}
|
|
break;
|
}
|
case NET_ALARM_OVER_TEMPERATURE: { // 超温报警事件(对应结构体 NET_ALARM_OVER_TEMPERATURE_INFO)
|
|
System.out.println(" 超温报警事件");
|
NET_ALARM_OVER_TEMPERATURE_INFO msg=new NET_ALARM_OVER_TEMPERATURE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
|
// 事件动作 0:脉冲
|
System.out.println(" nAction:" + msg.nAction );
|
|
// 事件发生的时间,标准的（不带时区偏差的）UTC时间
|
System.out.println(" stuUTC:" + msg.stuUTC.toString() );
|
// 配件序列号
|
System.out.println(" szSN:" + new String(msg.szSN) );
|
|
// 配件名称
|
System.out.println(" szSN:" + new String(msg.szName) );
|
|
// 超温类型 0:温度恢复正常;1:温度超过下限;2:温度超过上限
|
System.out.println(" nTemperatureType:" + msg.nTemperatureType );
|
|
// 所属区域信息个数
|
System.out.println(" nAreaInfoNum:" + msg.nAreaInfoNum );
|
|
NET_EVENT_AREAR_INFO[] stuAreaInfo = msg.stuAreaInfo;
|
|
for(int i=0;i<msg.nAreaInfoNum;i++){
|
NET_EVENT_AREAR_INFO info = stuAreaInfo[i];
|
|
System.out.println(" nIndex:" +info.nIndex );
|
|
System.out.println(" szName:" + new String(info.szName) );
|
|
}
|
|
|
break;
|
}
|
default:
|
break;
|
}
|
return true;
|
}
|
}
|
|
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();;
|
menu.addItem((new CaseMenu.Item(this , "startListen" , "startListen")));
|
menu.addItem((new CaseMenu.Item(this , "stopListen" , "stopListen")));
|
menu.run();
|
}
|
|
public static void main(String[] args) {
|
WireLessDevLowDemo wireLessDevLowDemo=new WireLessDevLowDemo();
|
|
InitTest("172.3.3.135",37777,"admin","admin123");
|
wireLessDevLowDemo.RunTest();
|
LoginOut();
|
|
}
|
}
|
