package com.netsdk.demo.event;
|
|
import com.netsdk.demo.customize.FireWarnDemo;
|
import com.netsdk.demo.intelligentTraffic.parkingDemo.ParkingUtils;
|
import com.netsdk.demo.units.TimeUtils;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.ENUMERROR;
|
import com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
|
import com.netsdk.lib.structure.DEV_EVENT_DISTANCE_DETECTION_INFO;
|
import com.sun.jna.Memory;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
import java.io.File;
|
import java.util.Date;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
import static com.netsdk.lib.Utils.getPlatformEncode;
|
|
/**
|
* @Author 251589
|
* @Description： 宁波智慧公交 跌倒事件和异常间距事件
|
* @Date 2020/11/28 9:47
|
*/
|
public class TumbleDistanceDemo {
|
|
static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
|
// 设备信息
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
//登录句柄
|
private NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);
|
|
// 智能订阅句柄
|
private NetSDKLib.LLong attachHandle = new NetSDKLib.LLong(0);
|
|
/**
|
* 登录设备
|
*/
|
public boolean login() {
|
int nSpecCap = 0;
|
Pointer pCapParam = null;
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netSdk.CLIENT_LoginEx2(m_strIp, m_nPort, m_strUser,
|
m_strPassword, nSpecCap, pCapParam, deviceInfo, nError);
|
|
if (loginHandle.longValue() != 0) {
|
System.out.printf("Login Device[%s] Port[%d] Success!\n", m_strIp, m_nPort);
|
} else {
|
System.out.printf("Login Device[%s] Port[%d] Failed. %s\n", m_strIp, m_nPort, ToolKits.getErrorCode());
|
}
|
|
return loginHandle.longValue() != 0;
|
}
|
|
|
/**
|
* 登出设备
|
*/
|
public void logout() {
|
if (loginHandle.longValue() != 0)
|
netSdk.CLIENT_Logout(loginHandle);
|
}
|
|
public void InitTest() {
|
ParkingUtils.Init(); // SDK初始化
|
if (!login()) // 登陆设备
|
EndTest();
|
}
|
|
public void EndTest() {
|
stopLoadPicture(); // 取消订阅
|
logout(); // 登出设备
|
System.out.println("See You...");
|
netSdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
/**
|
* 远程抓图（异步）
|
*/
|
public void snapPicture() {
|
// send capture picture instruction to device
|
NetSDKLib.SNAP_PARAMS stuSnapParams = new NetSDKLib.SNAP_PARAMS();
|
stuSnapParams.Channel = 0; // channel
|
stuSnapParams.mode = 0; // capture picture mode
|
stuSnapParams.Quality = 3; // picture quality
|
stuSnapParams.InterSnap = 0;
|
stuSnapParams.CmdSerial = 0;
|
|
IntByReference reserved = new IntByReference(0);
|
if (!netSdk.CLIENT_SnapPictureEx(loginHandle, stuSnapParams, reserved)) {
|
System.err.printf("CLIENT_SnapPictureEx Failed!" + ToolKits.getErrorCode());
|
} else {
|
System.out.println("CLIENT_SnapPictureEx success");
|
}
|
}
|
|
public static class SnapCallback implements NetSDKLib.fSnapRev {
|
private static SnapCallback instance = new SnapCallback();
|
|
private File path;
|
|
private SnapCallback() {
|
path = new File("./Snap/");
|
if (!path.exists()) {
|
path.mkdir();
|
}
|
}
|
|
public static SnapCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(NetSDKLib.LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
|
if (EncodeType == 10) { // jpg
|
String fileName = path + File.separator + "AsyncSnapPicture_" + TimeUtils.getTimeStringWithoutSign(new Date()) + ".jpg";
|
//保存图片到本地文件
|
ToolKits.savePicture(pBuf, RevLen, fileName);
|
}
|
}
|
}
|
|
|
/**
|
* 【需求描述】 跌倒事件檢測
|
*/
|
public boolean realLoadPicture() {
|
int bNeedPicture = 1; // 是否需要图片
|
int channel = 0; // 订阅全通道
|
if (deviceInfo.byChanNum == 1)
|
channel = 0;
|
|
// AnalyzerDataCB.getInstance() 回调
|
attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel,
|
NetSDKLib.EVENT_IVS_ALL, bNeedPicture, AnalyzerDataCB.getInstance(), null, null);
|
if (attachHandle.longValue() != 0) {
|
System.out.printf("Channel[%d] RealLoad Picture Succeed！\n", channel);
|
} else {
|
System.err.printf("Channel[%d] RealLoad Picture Failed！ errCode == %s\n errMsg == %s\n", channel, ToolKits.getErrorCode(), ENUMERROR.getErrorMessage());
|
}
|
return attachHandle.longValue() != 0;
|
}
|
|
/**
|
* 订阅报警信息
|
*
|
* @return
|
*/
|
public void startListen() {
|
// 设置报警回调函数
|
|
netSdk.CLIENT_SetDVRMessCallBack(ParkingMessageCallBackEx1.getSingleInstance(), null);
|
|
// 订阅报警
|
boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle);
|
if (!bRet) {
|
System.err.printf("订阅报警失败! error:%d\n", netSdk.CLIENT_GetLastError() + ENUMERROR.getErrorMessage());
|
} else {
|
System.out.println("订阅报警成功.");
|
}
|
}
|
|
public static class ParkingMessageCallBackEx1 implements NetSDKLib.fMessCallBackEx1 {
|
|
private static com.netsdk.demo.intelligentTraffic.parkingDemo.ParkingMessageCallBackEx1 singleInstance;
|
|
public static com.netsdk.demo.intelligentTraffic.parkingDemo.ParkingMessageCallBackEx1 getSingleInstance() {
|
if (singleInstance == null) {
|
singleInstance = new com.netsdk.demo.intelligentTraffic.parkingDemo.ParkingMessageCallBackEx1();
|
}
|
return singleInstance;
|
}
|
|
public static String encode;
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
}
|
|
@Override
|
public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP, NativeLong nDevicePort, int bAlarmAckFlag, NativeLong nEventID, Pointer dwUser) {
|
switch (lCommand) {
|
case NetSDKLib.NET_ALARM_FIREWARNING_INFO: {
|
dealData(pStuEvent);
|
break;
|
}
|
default:
|
System.out.printf("Get Other Event 0x%x\n", lCommand);
|
break;
|
}
|
|
return true;
|
}
|
|
// 处理事件
|
private static void dealData(Pointer pAlarmInfo) {
|
NetSDKLib.ALARM_FIREWARNING_INFO_DETAIL msg = new NetSDKLib.ALARM_FIREWARNING_INFO_DETAIL();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
for (int i = 0; i < msg.stuFireWarningInfo.length; i++) {
|
System.out.println("msg 距离" + msg.stuFireWarningInfo[i].nDistance);
|
System.out.println("msg GPS" + msg.stuFireWarningInfo[i].stuGpsPoint.dwLatidude + "," +msg.stuFireWarningInfo[i].stuGpsPoint.dwLongitude);
|
System.out.println("msg 温度" + msg.stuFireWarningInfo[i].nTemperatureUnit);
|
}
|
|
}
|
|
}
|
|
|
/**
|
* 跌倒事件回调
|
*/
|
public static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
// (倒地报警事件)对应数据块描述信息
|
private NetSDKLib.DEV_EVENT_TUMBLE_DETECTION_INFO msg = new NetSDKLib.DEV_EVENT_TUMBLE_DETECTION_INFO();
|
|
private File path;
|
|
private AnalyzerDataCB() {
|
|
path = new File("./Snap/");
|
if (!path.exists())
|
path.mkdir();
|
}
|
|
private static class CallBackHolder {
|
private static AnalyzerDataCB instance = new AnalyzerDataCB();
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
return AnalyzerDataCB.CallBackHolder.instance;
|
}
|
|
// 回调
|
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_TUMBLE_DETECTION: { // 跌倒事件
|
dealData4TumbleDetection(pAlarmInfo);
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_DISTANCE_DETECTION: { // 异常距离检测事件
|
dealData4DistanceDetection(pAlarmInfo);
|
break;
|
}
|
default:
|
System.out.printf("其他事件： 0x%x\n" , dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
// 处理事件
|
private void dealData4TumbleDetection(Pointer pAlarmInfo) {
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
System.out.println("跌倒 -> 事件ID：" + msg.nEventID);
|
System.out.println("跌倒 -> 事件动作: " + msg.nAction);
|
System.out.println("跌倒 -> 目标ID: " + msg.nObjectID);
|
System.out.println("跌倒 -> 智能事件所属大类: " + msg.emClassType);
|
System.out.println("跌倒 -> 事件发生的时间: " + msg.UTC);
|
}
|
// 异常间距事件对应的数据块描述信息
|
private void dealData4DistanceDetection(Pointer pAlarmInfo) {
|
DEV_EVENT_DISTANCE_DETECTION_INFO distanceDetectionInfo = new DEV_EVENT_DISTANCE_DETECTION_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, distanceDetectionInfo);
|
NetSDKLib.DH_MSG_OBJECT object = new NetSDKLib.DH_MSG_OBJECT();
|
ToolKits.GetPointerData(distanceDetectionInfo.stuObject.getPointer(), object);
|
System.out.println("异常间距 -> 事件ID：" + distanceDetectionInfo.nEventID);
|
System.out.println("异常间距 -> 事件动作: " + distanceDetectionInfo.nAction);
|
System.out.println("异常间距 -> 检测区域顶点数: " + distanceDetectionInfo.nDetectRegionNum);
|
System.out.println("异常间距 -> 事件发生的时间: " + distanceDetectionInfo.UTC);
|
}
|
}
|
|
/**
|
* 停止智能订阅
|
*/
|
public void stopLoadPicture() {
|
if (attachHandle.longValue() != 0) {
|
netSdk.CLIENT_StopLoadPic(attachHandle);
|
attachHandle.setValue(0);
|
System.out.println("Had Stop RealLoad Picture！");
|
}
|
}
|
|
/**
|
* 云台配置
|
*/
|
public void cfgPTZ() {
|
NetSDKLib.CFG_PTZ_INFO stuPTZ = new NetSDKLib.CFG_PTZ_INFO();
|
if (!ToolKits.GetDevConfig(loginHandle, 0, NetSDKLib.CFG_CMD_PTZ, stuPTZ)) {
|
System.err.println("Get PTZ Failed!" + ToolKits.getErrorCode());
|
return;
|
}
|
|
System.out.printf("Enable: %d PresetId:%d FreeSec:%d \n", stuPTZ.bEnable,
|
stuPTZ.stuPresetHoming.nPtzPresetId, stuPTZ.stuPresetHoming.nFreeSec);
|
|
stuPTZ.bEnable = 1; // 使能
|
stuPTZ.stuPresetHoming.nFreeSec = 36; // 归位时间，单位为秒
|
if (!ToolKits.SetDevConfig(loginHandle, 0, NetSDKLib.CFG_CMD_PTZ, stuPTZ)) {
|
System.err.println("Set PTZ Failed!" + ToolKits.getErrorCode());
|
} else {
|
System.err.println("Set PTZ Success!");
|
}
|
}
|
|
// 选中目标进行抓拍
|
public void snapPictureByAnalyseObject() {
|
NetSDKLib.NET_IN_SNAP_BY_ANALYSE_OBJECT stuIn = new NetSDKLib.NET_IN_SNAP_BY_ANALYSE_OBJECT();
|
|
stuIn.nChannelID = 0; // 通道号
|
stuIn.nSnapObjectNum = 1; // 抓拍物体个数
|
// 抓拍物体信息 (点坐标归一化到[0, 8192]坐标)
|
// 实际使用时通过如下计算: 8192.0 * 相对坐标/显示宽(高) 其中左右通过显示的宽度计算，上下通过显示的高度计算
|
// 如 (int)(8192.0*80/120)——浮点计算是为了使结果更精确
|
// stuIn.stuSnapObjects[0].stuBoundingBox.left = 0;
|
// stuIn.stuSnapObjects[0].stuBoundingBox.top = 0;
|
// stuIn.stuSnapObjects[0].stuBoundingBox.right = 8192;
|
// stuIn.stuSnapObjects[0].stuBoundingBox.bottom = 8192;
|
stuIn.stuSnapObjects[0].stuBoundingBox.left = 4154;
|
stuIn.stuSnapObjects[0].stuBoundingBox.top = 3172;
|
stuIn.stuSnapObjects[0].stuBoundingBox.right = 5160;
|
stuIn.stuSnapObjects[0].stuBoundingBox.bottom = 4380;
|
|
NetSDKLib.NET_OUT_SNAP_BY_ANALYSE_OBJECT stuOut = new NetSDKLib.NET_OUT_SNAP_BY_ANALYSE_OBJECT();
|
if (!netSdk.CLIENT_SnapPictureByAnalyseObject(loginHandle, stuIn, stuOut, 5000)) {
|
System.err.println("Snap Picture By Analyse Object Failed!" + ToolKits.getErrorCode());
|
} else {
|
System.err.println("Snap Picture By Analyse Object Success!");
|
}
|
}
|
|
/**
|
* 场景抓拍设置
|
*/
|
public void snapShotWithRulecfg() {
|
int nMaxRuleNum = 10; // 可根据实际修改
|
NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO[] stuRule = new NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO[nMaxRuleNum];
|
for (int i = 0; i < nMaxRuleNum; ++i) {
|
stuRule[i] = new NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO();
|
}
|
|
int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_SCENE_SNAP_SHOT_WITH_RULE2; // 场景抓拍设置
|
int nChannelID = 0;
|
NetSDKLib.NET_CFG_SCENE_SNAP_SHOT_WITH_RULE2_INFO stuCfg = new NetSDKLib.NET_CFG_SCENE_SNAP_SHOT_WITH_RULE2_INFO();
|
stuCfg.nMaxRuleNum = nMaxRuleNum;
|
stuCfg.pstuSceneSnapShotWithRule = new Memory(nMaxRuleNum * stuRule[0].size());
|
stuCfg.pstuSceneSnapShotWithRule.clear(nMaxRuleNum * stuRule[0].size());
|
ToolKits.SetStructArrToPointerData(stuRule, stuCfg.pstuSceneSnapShotWithRule);
|
|
// 获取
|
stuCfg.write();
|
if (!netSdk.CLIENT_GetConfig(loginHandle, emCfgOpType, nChannelID,
|
stuCfg.getPointer(), stuCfg.size(), 4000, null)) {
|
System.err.println("获取场景抓拍配置失败!" + ToolKits.getErrorCode());
|
return;
|
}
|
|
stuCfg.read();
|
ToolKits.GetPointerDataToStructArr(stuCfg.pstuSceneSnapShotWithRule, stuRule);
|
|
System.out.printf("stuRule[0]--PresetID:%d RuleNum:%d RuleType:%x SingleInterval:%d\n",
|
stuRule[0].nPresetID, stuRule[0].nRetSnapShotRuleNum,
|
stuRule[0].stuSnapShotWithRule[0].dwRuleType, stuRule[0].stuSnapShotWithRule[0].nSingleInterval[1]);
|
|
// 设置，在获取的基础上设置
|
IntByReference restart = new IntByReference(0);
|
stuRule[0].stuSnapShotWithRule[0].nSingleInterval[1] = 15; // 抓图时间间隔
|
ToolKits.SetStructArrToPointerData(stuRule, stuCfg.pstuSceneSnapShotWithRule);
|
stuCfg.write();
|
if (!netSdk.CLIENT_SetConfig(loginHandle, emCfgOpType, nChannelID,
|
stuCfg.getPointer(), stuCfg.size(), 4000, restart, null)) {
|
System.err.println("设置场景抓拍配置失败!" + ToolKits.getErrorCode() + " \n errMsg: " + ENUMERROR.getErrorMessage());
|
} else {
|
System.err.println("设置场景抓拍配置成功!");
|
}
|
}
|
|
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "远程抓图", "snapPicture"));
|
menu.addItem(new CaseMenu.Item(this, "智能订阅", "realLoadPicture"));
|
menu.addItem(new CaseMenu.Item(this, "停止智能订阅", "stopLoadPicture"));
|
menu.run();
|
}
|
|
/**
|
* Parameter for login
|
*/
|
////////////////////////////////////////////////////////////////
|
private String m_strIp = "172.25.100.21";// "172.32.101.59"; //"10.11.16.168";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
|
////////////////////////////////////////////////////////////////
|
public static void main(String[] args) {
|
TumbleDistanceDemo demo = new TumbleDistanceDemo();
|
demo.InitTest();
|
System.out.println("Run Test");
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
