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.utils.Initialization;
|
import com.sun.jna.Pointer;
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description ERR220210123
|
* @date 2022/2/15 16:11
|
*/
|
public class IVSSIntelligentEventDemo extends Initialization {
|
|
int channel=-1;
|
NetSDKLib.LLong attachHandle=new NetSDKLib.LLong(0);
|
/**
|
* 订阅智能任务
|
*/
|
|
public NetSDKLib.LLong AttachEventRealLoadPic() {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
if(attachHandle.longValue()!=0){
|
this.DetachEventRealLoadPic();
|
}
|
|
// 需要图片
|
int bNeedPicture = 1;
|
attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_ALL, bNeedPicture,
|
AnalyzerDataCB.getInstance(), null, null);
|
if (attachHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
|
} else {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
}
|
|
return attachHandle;
|
}
|
/**
|
* 报警事件（智能）回调
|
*/
|
private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
private final File picturePath;
|
private static AnalyzerDataCB instance;
|
|
private AnalyzerDataCB() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdirs();
|
}
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
if (instance == null) {
|
synchronized (AnalyzerDataCB.class) {
|
if (instance == null) {
|
instance = new AnalyzerDataCB();
|
}
|
}
|
}
|
return instance;
|
}
|
|
|
@Override
|
public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
switch (dwAlarmType) {
|
case NetSDKLib.EVENT_IVS_CROSSLINEDETECTION_EX : { //警戒线扩展事件(对应 DEV_EVENT_CROSSLINE_INFO_EX)
|
System.out.println("警戒线扩展事件");
|
|
DEV_EVENT_CROSSLINE_INFO_EX msg = new DEV_EVENT_CROSSLINE_INFO_EX();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
//智能事件所属大类， 取值为 EM_CLASS_TYPE 中的值
|
int emClassType
|
= msg.stuIntelliCommInfo.emClassType;
|
System.out.println("emClassType :"+emClassType);
|
|
|
//检测到的物体
|
NetSDKLib.NET_MSG_OBJECT_EX stuObject = msg.stuObject;
|
//物体类型
|
byte[] szObjectType = stuObject.szObjectType;
|
|
//物体子类别,根据不同的物体类型
|
byte[] szObjectSubType = stuObject.szObjectSubType;
|
|
try {
|
System.out.println("szObjectType UTF-8:"+new String(szObjectType,"UTF-8"));
|
System.out.println("szObjectType GBK:"+new String(szObjectType,"GBK"));
|
|
System.out.println("szObjectSubType UTF-8:"+new String(szObjectSubType,"UTF-8"));
|
System.out.println("szObjectSubType GBK:"+new String(szObjectSubType,"GBK"));
|
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
|
|
|
case NetSDKLib.EVENT_IVS_CROSSLINEDETECTION : { //警戒线事件(对应 DEV_EVENT_CROSSLINE_INFO)
|
System.out.println("警戒线事件");
|
|
NetSDKLib.DEV_EVENT_CROSSLINE_INFO msg = new NetSDKLib.DEV_EVENT_CROSSLINE_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
|
//智能事件所属大类， 取值为 EM_CLASS_TYPE 中的值
|
int emClassType
|
= msg.stuIntelliCommInfo.emClassType;
|
System.out.println("emClassType :"+emClassType);
|
|
|
//检测到的物体
|
NetSDKLib.NET_MSG_OBJECT stuObject = msg.stuObject;
|
//物体类型
|
byte[] szObjectType = stuObject.szObjectType;
|
|
//物体子类别,根据不同的物体类型
|
byte[] szObjectSubType = stuObject.szObjectSubType;
|
|
|
try {
|
System.out.println("szObjectType UTF-8:"+new String(szObjectType,"UTF-8"));
|
System.out.println("szObjectType GBK:"+new String(szObjectType,"GBK"));
|
|
System.out.println("szObjectSubType UTF-8:"+new String(szObjectSubType,"UTF-8"));
|
System.out.println("szObjectSubType GBK:"+new String(szObjectSubType,"GBK"));
|
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
|
case NetSDKLib.EVENT_IVS_CROSSREGIONDETECTION:{ //警戒区事件(对应 DEV_EVENT_CROSSREGION_INFO)
|
System.out.println("警戒区事件");
|
|
NetSDKLib.DEV_EVENT_CROSSREGION_INFO msg=new NetSDKLib.DEV_EVENT_CROSSREGION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
//智能事件所属大类， 取值为 EM_CLASS_TYPE 中的值
|
int emClassType
|
= msg.stuIntelliCommInfo.emClassType;
|
System.out.println("emClassType :"+emClassType);
|
|
//检测到的物体
|
NetSDKLib.NET_MSG_OBJECT stuObject = msg.stuObject;
|
//物体类型
|
byte[] szObjectType = stuObject.szObjectType;
|
|
//物体子类别,根据不同的物体类型
|
byte[] szObjectSubType = stuObject.szObjectSubType;
|
|
try {
|
System.out.println("szObjectType UTF-8:"+new String(szObjectType,"UTF-8"));
|
System.out.println("szObjectType GBK:"+new String(szObjectType,"GBK"));
|
|
System.out.println("szObjectSubType UTF-8:"+new String(szObjectSubType,"UTF-8"));
|
System.out.println("szObjectSubType GBK:"+new String(szObjectSubType,"GBK"));
|
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_PARKINGDETECTION: {// 非法停车事件(对应 DEV_EVENT_PARKINGDETECTION_INFO)
|
|
System.out.println("非法停车事件");
|
|
NetSDKLib.DEV_EVENT_PARKINGDETECTION_INFO msg=new NetSDKLib.DEV_EVENT_PARKINGDETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
//智能事件所属大类， 取值为 EM_CLASS_TYPE 中的值
|
int emClassType
|
= msg.stuIntelliCommInfo.emClassType;
|
System.out.println("emClassType :"+emClassType);
|
|
//检测到的物体
|
NetSDKLib.NET_MSG_OBJECT stuObject = msg.stuObject;
|
//物体类型
|
byte[] szObjectType = stuObject.szObjectType;
|
|
//物体子类别,根据不同的物体类型
|
byte[] szObjectSubType = stuObject.szObjectSubType;
|
|
|
try {
|
System.out.println("szObjectType UTF-8:"+new String(szObjectType,"UTF-8"));
|
System.out.println("szObjectType GBK:"+new String(szObjectType,"GBK"));
|
|
System.out.println("szObjectSubType UTF-8:"+new String(szObjectSubType,"UTF-8"));
|
System.out.println("szObjectSubType GBK:"+new String(szObjectSubType,"GBK"));
|
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_BREAK_RULE_BUILDING_DETECTION: {// 违章建筑检测事件(对应 DEV_EVENT_BREAK_RULE_BUILDIING_DETECTION_INFO)
|
|
System.out.println("违章建筑检测事件");
|
|
DEV_EVENT_BREAK_RULE_BUILDIING_DETECTION_INFO msg=new DEV_EVENT_BREAK_RULE_BUILDIING_DETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_FISHING_DETECTION: {//钓鱼检测事件(对应 DEV_EVENT_FISHING_DETECTION_INFO )
|
|
System.out.println("钓鱼检测事件");
|
|
DEV_EVENT_FISHING_DETECTION_INFO msg=new DEV_EVENT_FISHING_DETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
//检测目标物体的个数
|
int nObjectCount = msg.nObjectCount;
|
|
NetSDKLib.NET_MSG_OBJECT_EX2[] stuObjects
|
= msg.stuObjects;
|
for(int i=0;i<nObjectCount;i++){
|
NetSDKLib.NET_MSG_OBJECT_EX2 stuObject
|
= stuObjects[i];
|
NetSDKLib.NET_PIC_INFO stPicInfo
|
= stuObject.stPicInfo;
|
//图片
|
if (stPicInfo != null && stPicInfo.dwFileLenth > 0) {
|
String picture = picturePath + "/" + System.currentTimeMillis() + "related.jpg";
|
ToolKits.savePicture(pBuffer, stPicInfo.dwOffSet, stPicInfo.dwFileLenth, picture);
|
}
|
}
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_WATER_LEVEL_DETECTION: {// 水位检测事件 (对应 DEV_EVENT_WATER_LEVEL_DETECTION_INFO)
|
|
System.out.println("水位检测事件");
|
NetSDKLib.DEV_EVENT_WATER_LEVEL_DETECTION_INFO msg=new NetSDKLib.DEV_EVENT_WATER_LEVEL_DETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
// 事件数据类型,详见NET_EM_EVENT_DATA_TYPE
|
int emEventType = msg.emEventType;
|
System.out.println("emEventType:"+emEventType);
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_SEWAGE_DETECTION: {// 排污检测事件（对应 DEV_EVENT_SEWAGE_DETECTION_INFO)
|
System.out.println("排污检测事件");
|
DEV_EVENT_SEWAGE_DETECTION_INFO msg=new DEV_EVENT_SEWAGE_DETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
// 智能事件所属大类 EM_CLASS_TYPE
|
int emEventType = msg.emClassType;
|
System.out.println("emEventType:"+emEventType);
|
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_WATERCOLOR_DETECTION: {// 水体颜色事件（对应 DEV_EVENT_WATERCOLOR_DETECTION_INFO）
|
System.out.println("水体颜色事件");
|
DEV_EVENT_WATERCOLOR_DETECTION_INFO msg=new DEV_EVENT_WATERCOLOR_DETECTION_INFO();
|
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
|
|
byte[] szName = msg.szName;
|
try {
|
System.out.println("szName UTF-8:"+new String(szName,"UTF-8"));
|
System.out.println("szName GBK:"+new String(szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
// 智能事件所属大类 EM_CLASS_TYPE
|
int emEventType = msg.emClassType;
|
System.out.println("emEventType:"+emEventType);
|
|
break;
|
}
|
|
default:
|
System.out.println("其他事件--------------------"+ dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
}
|
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (this.attachHandle.longValue() != 0) {
|
netSdk.CLIENT_StopLoadPic(this.attachHandle);
|
}
|
}
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();;
|
menu.addItem((new CaseMenu.Item(this , "AttachEventRealLoadPic" , "AttachEventRealLoadPic")));
|
menu.addItem((new CaseMenu.Item(this , "DetachEventRealLoadPic" , "DetachEventRealLoadPic")));
|
|
menu.run();
|
}
|
|
public static void main(String[] args) {
|
IVSSIntelligentEventDemo ivssIntelligentEventDemo=new IVSSIntelligentEventDemo();
|
// InitTest("172.12.2.116",37777,"admin","admin123");
|
//20.2.35.57
|
InitTest("20.2.36.57",37777,"admin","admin123");
|
ivssIntelligentEventDemo.RunTest();
|
LoginOut();
|
|
}
|
|
}
|
