From 6ab0ec5ade792e91ba90018c0b7f822abb1db5b2 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Wed, 06 Dec 2023 11:29:51 +0800
Subject: [PATCH] 增加超脑报警事件
---
src/main/java/com/ard/utils/sdk/hiksdk/domain/SuperBrainEventInfo.java | 54 ++++
src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java | 529 +++++++++++++++++++++++++++++++++++-------------
src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java | 16 +
src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java | 8
4 files changed, 462 insertions(+), 145 deletions(-)
diff --git a/src/main/java/com/ard/utils/sdk/hiksdk/domain/SuperBrainEventInfo.java b/src/main/java/com/ard/utils/sdk/hiksdk/domain/SuperBrainEventInfo.java
new file mode 100644
index 0000000..9dc4b31
--- /dev/null
+++ b/src/main/java/com/ard/utils/sdk/hiksdk/domain/SuperBrainEventInfo.java
@@ -0,0 +1,54 @@
+package com.ard.utils.sdk.hiksdk.domain;
+
+import lombok.Data;
+
+/**
+ * @Description:
+ * @ClassName: SuperBrainEventInfo
+ * @Author: 刘苏义
+ * @Date: 2023年12月05日10:39:53
+ **/
+@Data
+public class SuperBrainEventInfo {
+ /**
+ * 报警名称
+ */
+ String alarmName;
+ /**
+ * 报警类别
+ */
+ String alarmType;
+ /**
+ * 报警时间
+ */
+ String alarmTime;
+
+ /**
+ * 超脑设备ID
+ */
+ String deviceId;
+ /**
+ * 超脑设备名称
+ */
+ String deviceName;
+ /**
+ * 超脑设备通道号
+ */
+ Integer chanNo;
+ /**
+ * 关联超脑经度
+ */
+ Double longitude;
+ /**
+ * 关联超脑纬度
+ */
+ Double latitude;
+ /**
+ * 大图url
+ */
+ String picUrl;
+ /**
+ * 人脸抓拍图片url
+ */
+ String faceUrl;
+}
diff --git a/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java b/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java
index 3283dbf..a5a8575 100644
--- a/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java
+++ b/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/FMSGCallBack.java
@@ -15,6 +15,7 @@
import com.ard.utils.mqtt.MqttProducer;
import com.ard.utils.util.IdUtils;
import com.sun.jna.Pointer;
+import javafx.scene.Camera;
import lombok.extern.slf4j.Slf4j;
import java.io.*;
@@ -65,19 +66,20 @@
if (camera == null && ardEquipExternal == null) {
return false;
}
- CameraEventInfo info;
+ CameraEventInfo cameraEventInfo;
+ SuperBrainEventInfo superBrainEventInfo;
+ String alarmName = "";//报警名称
String alarmTime;//事件时间
String alarmType = "";//报警类型
String picUrl = "";//事件图片
- String facePicUrl = "";//人脸图片
+ String facePicUrl = "";//人脸抓拍图片
+ String faceLibUrl = "";//人脸库图片
+ int dwPicDataLen;//图片数据长度
//lCommand是传的报警类型
log.debug("【" + sDeviceIP + ":" + wLinkPort + "】报警事件类型:lCommand:" + Integer.toHexString(lCommand));
switch (lCommand) {
case COMM_ALARM_V30:
- log.debug("移动侦测报警信息上报");
- if (camera == null) {
- return false;
- }
+ log.debug("移动侦测信息上报");
//region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
netDvrAlarminfoV30.write();
@@ -86,28 +88,17 @@
netDvrAlarminfoV30.read();
switch (netDvrAlarminfoV30.dwAlarmType) {
case 3:
- info = new CameraEventInfo();
- info.setAlarmName("移动侦测");
- info.setAlarmTime(fmt.format(new Date()));
- info.setCameraName(camera.getName());
- info.setCameraId(camera.getId());
- info.setCameraIp(camera.getIp());
- info.setCameraPort(camera.getPort());
- info.setCameraType(camera.getGdType());
- info.setCameraChannel(Integer.valueOf(netDvrAlarminfoV30.byChannel[0]));
- info.setLongitude(camera.getLongitude());
- info.setLatitude(camera.getLatitude());
- info.setAlarmType("移动侦测");
- //图片存入minio
- picUrl = snapPicture(info);
- info.setPicUrl(picUrl);
- publishMqtt(info, "camera");
+ if (camera != null) {
+ cameraEventHandler(camera, "移动侦测", "移动侦测报警", fmt.format(new Date()), "");
+ }
break;
}
//endregion
break;
+ case COMM_VCA_ALARM:
+ log.debug("智能检测通用信息上报(暂不解析)");
case COMM_ALARM_RULE:
- log.debug("异常行为识别信息报警信息上报");
+ log.debug("异常行为识别信息上报");
//region 异常行为识别信息
HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
strVcaAlarm.write();
@@ -117,74 +108,108 @@
Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
alarmTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
- info = new CameraEventInfo();
- info.setAlarmName("人员行为分析");
- info.setAlarmTime(alarmTime);
- info.setCameraName(camera.getName());
- info.setCameraId(camera.getId());
- info.setCameraIp(camera.getIp());
- info.setCameraPort(camera.getPort());
- info.setCameraType(camera.getGdType());
- info.setCameraChannel(channel);
- info.setLongitude(camera.getLongitude());
- info.setLatitude(camera.getLatitude());
- info.setRuleId(ruleID);
switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
case 1: //region穿越警戒面 (越界侦测)
- info.setAlarmType("越界侦测报警");
- strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_TRAVERSE_PLANE.class);
- //图片存入minio
- picUrl = snapPicture(info);
- info.setPicUrl(picUrl);
- publishMqtt(info, "camera");
+ alarmType = "越界侦测报警";
//endregion
break;
-// case 2: //region 目标进入区域
-// info.setAlarmType("目标进入区域报警");
-// strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
-// //endregion
-// break;
-// case 3: //region 目标离开区域
-// info.setAlarmType("目标离开区域报警");
-// strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
-// //endregion
-// break;
+ case 2: //region 目标进入区域
+ alarmType = "目标进入区域报警";
+ //endregion
+ break;
+ case 3: //region 目标离开区域
+ alarmType = "目标离开区域报警";
+ //strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
+ //endregion
+ break;
case 4: //region 周界入侵
- info.setAlarmType("周界入侵报警");
- strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class);
- //图片存入minio
- picUrl = snapPicture(info);
- info.setPicUrl(picUrl);
- publishMqtt(info, "camera");
+ alarmType = "周界入侵报警";
//endregion
break;
-// case 5: //region 徘徊
-// info.setAlarmType("徘徊事件报警");
-// //endregion
-// break;
-// case 8: //region 快速移动(奔跑)
-// info.setAlarmType("快速移动(奔跑)事件报警");
-// //endregion
-// break;
-// case 13: //region 物品遗留事件
-// info.setAlarmType("物品遗留事件报警");
-// //endregion
-// break;
-// case 14: //region 物品拿取事件
-// info.setAlarmType("物品拿取事件事件报警");
-// //endregion
-// break;
-// case 20: //region 倒地检测
-// info.setAlarmType("倒地事件触发");
-// //endregion
-// break;
-// case 44: //region 玩手机
-// info.setAlarmType("玩手机报警事件");
-// //endregion
-// break;
+ case 5: //region 徘徊
+ alarmType = "徘徊事件报警";
+ //endregion
+ break;
+ case 8: //region 快速移动(奔跑)
+ alarmType = "快速移动报警";
+ //endregion
+ break;
+ case 9: //region 人员聚集报警
+ alarmType = "人员聚集报警";
+ //endregion
+ break;
+ case 13: //region 物品遗留事件
+ alarmType = "物品遗留事件报警";
+ //endregion
+ break;
+ case 14: //region 物品拿取事件
+ alarmType = "物品拿取事件报警";
+ //endregion
+ break;
+ case 15: //region 离岗事件
+ strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_LEAVE_POSITION.class);
+ int byMode = strVcaAlarm.struRuleInfo.uEventParam.struLeavePos.byMode;
+ switch (byMode) {
+ case 0:
+ alarmType = "离岗事件报警";
+ break;
+ case 1:
+ alarmType = "睡岗事件报警";
+ break;
+ }
+ //endregion
+ break;
+ case 20: //region 倒地检测
+ alarmType = "倒地检测事件报警";
+ //endregion
+ break;
+ case 35: //region 倒地检测
+ alarmType = "人数变化事件报警";
+ //endregion
+ break;
+ case 41: //region 滞留检测
+ alarmType = "滞留检测事件报警";
+ //endregion
+ break;
+ case 44: //region 玩手机
+ alarmType = "玩手机事件报警";
+ //endregion
+ break;
default:
log.debug("未知异常行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
break;
+ }
+ //图片接收
+ int byPicType = strVcaAlarm.byPicType;
+ dwPicDataLen = strVcaAlarm.dwPicDataLen;
+ int byPicTransType = strVcaAlarm.byPicTransType;
+ if (dwPicDataLen > 0 && strVcaAlarm.pImage != null && byPicTransType == 0) {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, dwPicDataLen);
+ byte[] bytes = new byte[dwPicDataLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ InputStream input = new ByteArrayInputStream(bytes);
+ try {
+ String bucketName = "pic";
+ String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
+ boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
+ if (uploadObject) {
+ picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ //log.debug("上传文件成功!" + picUrl);
+ }
+ } catch (Exception e) {
+ log.error("异常行为识别信息报警信息上报图片保存失败" + e.getMessage());
+ }
+ }
+ if (camera != null) {
+ camera.setChannel(channel);
+ cameraEventHandler(camera, alarmName, alarmType, alarmTime, picUrl);
+ }
+ if (ardEquipExternal != null) {
+ alarmName = "异常行为识别";
+ superBrainEventHandler(ardEquipExternal, channel, alarmName, alarmType, alarmTime, picUrl, "");
}
//endregion
break;
@@ -249,7 +274,7 @@
log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
}
}
- log.debug("【人脸抓拍报警信息】: alarmTime:" + alarmTime + " picUrl:" + picUrl + " facePicType:" + facePicTyp + " facePicUrl:" + facePicUrl);
+ //log.debug("【人脸抓拍报警信息】: alarmTime:" + alarmTime + " picUrl:" + picUrl + " facePicType:" + facePicTyp + " facePicUrl:" + facePicUrl);
FaceSnapEventInfo faceSnapEventInfo = new FaceSnapEventInfo();
faceSnapEventInfo.setAlarmTime(alarmTime);
faceSnapEventInfo.setPicUrl(picUrl);
@@ -260,27 +285,17 @@
log.debug("人脸比对报警信息");
//region 人脸比对报警信息
HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM struFaceMatchAlarm = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
+ struFaceMatchAlarm.byPicTransType = 0;
struFaceMatchAlarm.write();
Pointer fmaInfo = struFaceMatchAlarm.getPointer();
fmaInfo.write(0, pAlarmInfo.getByteArray(0, struFaceMatchAlarm.size()), 0, struFaceMatchAlarm.size());
struFaceMatchAlarm.read();
alarmTime = DateUtils.parseTime(struFaceMatchAlarm.struSnapInfo.dwAbsTime);//报警时间
-
int byMatchPicNum = struFaceMatchAlarm.byMatchPicNum;//匹配图片数量
- String picTransType = "";
- switch (struFaceMatchAlarm.byPicTransType) {
- case 0:
- picTransType = "二进制图片";
- break;
- case 1:
- picTransType = "URL路径图片";
- break;
- }
String contrastStatus = "";
switch (struFaceMatchAlarm.byContrastStatus) {
case 1:
contrastStatus = "比对成功";
-
break;
case 2:
contrastStatus = "比对失败";
@@ -289,42 +304,157 @@
contrastStatus = "未知";
break;
}
+ String BlockType = "";
switch (struFaceMatchAlarm.struBlockListInfo.struBlockListInfo.byType) {
case 1:
- alarmType = "陌生人报警";
+ BlockType = "陌生人报警";
break;
case 2:
- alarmType = "人脸比对报警";
+ BlockType = "人脸比对报警";
break;
default:
- alarmType = "未知";
+ BlockType = "未知";
break;
}
- if (struFaceMatchAlarm.dwSnapPicLen > 0 && struFaceMatchAlarm.pSnapPicBuffer != null && struFaceMatchAlarm.byPicTransType == 0) {
- //将字节写入文件
+ //人脸比对报警图片保存，图片格式二进制
+ if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
+ SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+ String newName = sf.format(new Date());
+ FileOutputStream fout;
+ try {
+ String filename = "../pic/" + newName + "_pSnapPicBuffer" + ".jpg";
+ fout = new FileOutputStream(filename);
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struFaceMatchAlarm.pSnapPicBuffer.getByteBuffer(offset, struFaceMatchAlarm.dwSnapPicLen);
+ byte[] bytes = new byte[struFaceMatchAlarm.dwSnapPicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ fout.write(bytes);
+ fout.close();
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ if ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
+ SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+ String newName = sf.format(new Date());
+ FileOutputStream fout;
+ try {
+ String filename = "../pic/" + newName + "_struSnapInfo_pBuffer1" + ".jpg";
+ fout = new FileOutputStream(filename);
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struFaceMatchAlarm.struSnapInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
+ byte[] bytes = new byte[struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ fout.write(bytes);
+ fout.close();
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ if ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
+ SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+ String newName = sf.format(new Date());
+ FileOutputStream fout;
+ try {
+ String filename = "../pic/" + newName + "_fSimilarity_" + struFaceMatchAlarm.fSimilarity + "_struBlackListInfo_pBuffer1" + ".jpg";
+ fout = new FileOutputStream(filename);
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struFaceMatchAlarm.struBlockListInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen);
+ byte[] bytes = new byte[struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ fout.write(bytes);
+ fout.close();
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ //人脸比对报警图片保存，图片格式URL格式
+ if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {
+
long offset = 0;
ByteBuffer buffers = struFaceMatchAlarm.pSnapPicBuffer.getByteBuffer(offset, struFaceMatchAlarm.dwSnapPicLen);
byte[] bytes = new byte[struFaceMatchAlarm.dwSnapPicLen];
buffers.rewind();
buffers.get(bytes);
- InputStream input = new ByteArrayInputStream(bytes);
- try {
- String bucketName = "pic";
- String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
- boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
- if (uploadObject) {
- picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
- //log.debug("上传文件成功!" + url);
- }
- } catch (Exception e) {
- log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
- }
+ picUrl = new String(bytes);
+ //log.debug("抓拍图URL：" + picUrl);
}
- if (struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0 && struFaceMatchAlarm.struBlockListInfo.pBuffer1 != null) {
- //将字节写入文件
+ if ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {
+
+ long offset = 0;
+ ByteBuffer buffers = struFaceMatchAlarm.struSnapInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
+ byte[] bytes = new byte[struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ facePicUrl = new String(bytes);
+ //System.out.println("抓拍人脸子图URL：" + SnapPicUrl);
+ }
+ if ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {
+
long offset = 0;
ByteBuffer buffers = struFaceMatchAlarm.struBlockListInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen);
byte[] bytes = new byte[struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ faceLibUrl = new String(bytes);
+ //System.out.println("人脸库人脸图的URL：" + SnapPicUrl);
+ }
+ if (ardEquipExternal != null) {
+ alarmName = "人脸比对检测";
+ alarmType = contrastStatus + "[" + BlockType + "]";
+ superBrainEventHandler(ardEquipExternal, 0, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
+ }
+ //endregion
+ break;
+ case COMM_UPLOAD_AIOP_VIDEO:
+ log.debug("AI开放平台接入视频检测报警上传");
+ //region AI开放平台接入视频检测
+ HCNetSDK.NET_AIOP_VIDEO_HEAD struAIOPVideo = new HCNetSDK.NET_AIOP_VIDEO_HEAD();
+ struAIOPVideo.write();
+ Pointer pAIOPVideo = struAIOPVideo.getPointer();
+ pAIOPVideo.write(0, pAlarmInfo.getByteArray(0, struAIOPVideo.size()), 0, struAIOPVideo.size());
+ struAIOPVideo.read();
+ log.debug("视频任务ID" + new String(struAIOPVideo.szTaskID).trim());
+ log.debug("通道号：" + struAIOPVideo.dwChannel);
+ String szMPID = new String(struAIOPVideo.szMPID).trim();//检测模型包ID
+ log.debug("检测模型包ID" + szMPID);
+ alarmTime = String.format("%04d", struAIOPVideo.struTime.wYear) + "-" +
+ String.format("%02d", struAIOPVideo.struTime.wMonth) + "-" +
+ String.format("%02d", struAIOPVideo.struTime.wDay) + " " +
+ String.format("%02d", struAIOPVideo.struTime.wHour) + ":" +
+ String.format("%02d", struAIOPVideo.struTime.wMinute) + ":" +
+ String.format("%02d", struAIOPVideo.struTime.wSecond) + "." +
+ String.format("%03d", struAIOPVideo.struTime.wMilliSec);
+ alarmName = "AI开放平台接入视频检测";
+ switch (szMPID) {
+ case "H930_MODEL_SPD":
+ alarmType = "抽烟打电话";
+ break;
+ }
+ //图片数据保存
+ if (struAIOPVideo.dwPictureSize > 0) {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struAIOPVideo.pBufferPicture.getByteBuffer(offset, struAIOPVideo.dwPictureSize);
+ byte[] bytes = new byte[struAIOPVideo.dwPictureSize];
buffers.rewind();
buffers.get(bytes);
InputStream input = new ByteArrayInputStream(bytes);
@@ -334,34 +464,19 @@
boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
if (uploadObject) {
picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
- //log.debug("上传文件成功!" + url);
+ //log.debug("上传文件成功!" + picUrl);
}
} catch (Exception e) {
- log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
+ log.error("AI开放平台接入视频检测报警上传上报图片保存失败" + e.getMessage());
}
}
- String sAlarmType = "";
- try {
- sAlarmType = "人脸黑名单比对报警，相识度：" + struFaceMatchAlarm.fSimilarity + "，黑名单姓名：" +
- new String(struFaceMatchAlarm.struBlockListInfo.struBlockListInfo.struAttribute.byName, "GBK").trim() + "，黑名单证件信息：" +
- new String(struFaceMatchAlarm.struBlockListInfo.struBlockListInfo.struAttribute.byCertificateNumber).trim();
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
+ if (ardEquipExternal != null) {
+ superBrainEventHandler(ardEquipExternal, struAIOPVideo.dwChannel, alarmName, alarmType, alarmTime, picUrl, "");
}
- log.debug(sAlarmType);
- log.debug("【人脸比对报警信息】:" + " 比对结果:" + contrastStatus + " 比对类型:" + alarmType + " 报警时间:" + alarmTime + " 匹配图片数量：" + byMatchPicNum + " 图片类型：" + picTransType + " 比对图片:" + picUrl);
- FaceMatchEventInfo faceMatchEventInfo = new FaceMatchEventInfo();
- faceMatchEventInfo.setAlarmTime(alarmTime);
- faceMatchEventInfo.setStatus(contrastStatus);
- faceMatchEventInfo.setAlarmType(alarmType);
- publishMqtt(faceMatchEventInfo, "faceMatch");
//endregion
break;
- case COMM_UPLOAD_AIOP_VIDEO:
- log.debug("设备支持AI开放平台接入，上传视频检测数据(暂不解析)");
- break;
case COMM_ISAPI_ALARM:
- log.debug("安全帽检测报警信息");
+ log.debug("安全帽检测报警信息上报");
//region 安全帽检测报警信息
HCNetSDK.NET_DVR_ALARM_ISAPI_INFO struEventISAPI = new HCNetSDK.NET_DVR_ALARM_ISAPI_INFO();
struEventISAPI.write();
@@ -371,22 +486,53 @@
int dwAlarmDataLen = struEventISAPI.dwAlarmDataLen;
int byDataType = struEventISAPI.byDataType;
int byPicturesNumber = struEventISAPI.byPicturesNumber;
-
//处理安全帽检测上传的照片数据
- HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA struPicData = new HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA();
- struPicData.write();
- Pointer pPicData = struPicData.getPointer();
- pPicData.write(0, struEventISAPI.pPicPackData.getByteArray(0, struPicData.size()), 0,
- struPicData.size());
- struPicData.read();
- log.debug("检测到安全帽事件");
+ Pointer pPicPackData = struEventISAPI.pPicPackData;
+ if (pPicPackData != null) {
+ HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA struPicData = new HCNetSDK.NET_DVR_ALARM_ISAPI_PICDATA();
+ struPicData.write();
+ if (struPicData.size() > 0) {
+ Pointer pPicData = struPicData.getPointer();
+ pPicData.write(0, pPicPackData.getByteArray(0, struPicData.size()), 0, struPicData.size());
+ struPicData.read();
+ int dwPicLen = struPicData.dwPicLen;
+ pPicData = struPicData.pPicData;
+ if (dwPicLen > 0 && pPicData != null) {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = pPicData.getByteBuffer(offset, dwPicLen);
+ byte[] bytes = new byte[dwPicLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ InputStream input = new ByteArrayInputStream(bytes);
+ try {
+ String bucketName = "pic";
+ String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
+ boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
+ if (uploadObject) {
+ picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ //log.debug("上传文件成功!" + picUrl);
+ }
+ } catch (Exception e) {
+ log.error("异常行为识别信息报警信息上报图片保存失败" + e.getMessage());
+ }
+ }
+
+ }
+ }
+ if (ardEquipExternal != null) {
+ alarmName = "安全帽检测";
+ alarmType = "安全帽事件报警";
+ alarmTime = fmt.format(new Date());
+ superBrainEventHandler(ardEquipExternal, 0, alarmName, alarmType, alarmTime, picUrl, "");
+ }
//endregion
break;
case COMM_GISINFO_UPLOAD:
log.debug("GPS报警信息上报(暂不解析)");
break;
case COMM_ALARMHOST_CID_ALARM:
- log.debug("报警主机CID报告报警上报");
+ log.debug("报警主机CID报告信息上报");
//region 报警主机报警处理
HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
netDvrCidAlarm.write();
@@ -464,7 +610,7 @@
//endregion
break;
case HCNetSDK.COMM_ALARM_ACS:
- log.debug("门禁主机报警上报");
+ log.debug("门禁主机信息上报");
//region 门禁主机报警处理
HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
strACSInfo.write();
@@ -495,7 +641,7 @@
alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
//事件图片处理
- int dwPicDataLen = strACSInfo.dwPicDataLen;
+ dwPicDataLen = strACSInfo.dwPicDataLen;
if (dwPicDataLen > 0) {
try {
//将字节写入文件
@@ -571,12 +717,107 @@
publishMqtt(accessControlHostEventInfo, "accessControl");
//endregion
break;
+ case COMM_FIREDETECTION_ALARM: //火点检测报警
+ log.debug("火点检测信息上报");
+ //region 火点检测报警
+ HCNetSDK.NET_DVR_FIREDETECTION_ALARM struFireDecAlarm = new HCNetSDK.NET_DVR_FIREDETECTION_ALARM();
+ struFireDecAlarm.write();
+ Pointer pFireDecAlarm = struFireDecAlarm.getPointer();
+ pFireDecAlarm.write(0, pAlarmInfo.getByteArray(0, struFireDecAlarm.size()), 0, struFireDecAlarm.size());
+ struFireDecAlarm.read();
+ String sFireDecAlarmInfo = "绝对时间：" + struFireDecAlarm.dwAbsTime + ",报警子类型：" + struFireDecAlarm.byAlarmSubType + ",火点最高温度 :" +
+ struFireDecAlarm.wFireMaxTemperature + ",火点目标距离：" + struFireDecAlarm.wTargetDistance;
+ System.out.println(sFireDecAlarmInfo);
+ //图片保存
+ if ((struFireDecAlarm.dwPicDataLen > 0) && (struFireDecAlarm.byPicTransType == 0)) {
+ long offset = 0;
+ ByteBuffer buffers = struFireDecAlarm.pBuffer.getByteBuffer(offset, struFireDecAlarm.dwPicDataLen);
+ byte[] bytes = new byte[struFireDecAlarm.dwPicDataLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ InputStream input = new ByteArrayInputStream(bytes);
+ try {
+ String bucketName = "pic";
+ String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
+ boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
+ if (uploadObject) {
+ picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ //log.debug("上传文件成功!" + picUrl);
+ }
+ } catch (Exception e) {
+ log.error("火点检测事件报警上报热成像图片保存失败" + e.getMessage());
+ }
+
+ }
+ if (ardEquipExternal != null) {
+ alarmName = "火焰检测信息上报";
+ alarmType = "火焰检测事件报警";
+ int dwVisibleChannel = struFireDecAlarm.dwVisibleChannel;
+ alarmTime = DateUtils.parseTime(struFireDecAlarm.dwAbsTime);//报警时间
+ superBrainEventHandler(ardEquipExternal, dwVisibleChannel, alarmName, alarmType, alarmTime, picUrl, "");
+ }
+ //endregion
+ break;
+ case COMM_ITS_PLATE_RESULT://交通抓拍的终端图片上传
+ log.debug("交通抓拍的终端图片上报(暂不解析)");
+ break;
default:
log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
break;
}
return true;
+ }
+
+
+ /**
+ * 相机事件处理
+ * 刘苏义
+ * 2023/12/5 12:56:47
+ */
+ public void cameraEventHandler(ArdCameras camera, String alarmName, String alarmType, String alarmTime, String picUrl) {
+
+ CameraEventInfo cameraEventInfo = new CameraEventInfo();
+ cameraEventInfo.setAlarmName(alarmName);
+ cameraEventInfo.setAlarmTime(alarmTime);
+ cameraEventInfo.setCameraName(camera.getName());
+ cameraEventInfo.setCameraId(camera.getId());
+ cameraEventInfo.setCameraIp(camera.getIp());
+ cameraEventInfo.setCameraPort(camera.getPort());
+ cameraEventInfo.setCameraType(camera.getGdType());
+ cameraEventInfo.setCameraChannel(camera.getChannel());
+ cameraEventInfo.setLongitude(camera.getLongitude());
+ cameraEventInfo.setLatitude(camera.getLatitude());
+ cameraEventInfo.setAlarmType(alarmType);
+ //图片存入minio
+ if (picUrl.equals("")) {
+ picUrl = snapPicture(cameraEventInfo);
+ }
+ cameraEventInfo.setPicUrl(picUrl);
+ log.debug("处理通用光电事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + camera.getName() + "【Url】" + picUrl);
+ publishMqtt(cameraEventInfo, "camera");
+ }
+
+ /**
+ * 超脑事件处理
+ * 刘苏义
+ * 2023/12/5 12:56:47
+ */
+ public void superBrainEventHandler(ArdEquipExternal superBrainDevice, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {
+
+ SuperBrainEventInfo superBrainEventInfo = new SuperBrainEventInfo();
+ superBrainEventInfo.setAlarmName(alarmName);
+ superBrainEventInfo.setAlarmType(alarmType);
+ superBrainEventInfo.setAlarmTime(alarmTime);
+ superBrainEventInfo.setDeviceId(superBrainDevice.getId());
+ superBrainEventInfo.setDeviceName(superBrainDevice.getName());
+ superBrainEventInfo.setChanNo(chanNo);
+ superBrainEventInfo.setLongitude(superBrainDevice.getLongitude());
+ superBrainEventInfo.setLatitude(superBrainDevice.getLatitude());
+ superBrainEventInfo.setPicUrl(picUrl);
+ superBrainEventInfo.setFaceUrl(faceUrl);
+ log.debug("处理通超脑事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + superBrainDevice.getName() + "【Url】" + picUrl + "【faceUrl】" + faceUrl );
+ publishMqtt(superBrainEventInfo, "superBrain");
}
/**
@@ -604,7 +845,6 @@
.filter(camera -> camera.getIp().equals(ip) && camera.getPort() == port)
.findFirst();
}
-
/**
* 相机截图
@@ -689,4 +929,5 @@
int bySecond = netDvrTimeEx.dwSecond;
return wYear + "-" + byMonth + "-" + byDay + " " + byHour + ":" + byMinute + ":" + bySecond;
}
+
}
diff --git a/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java b/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java
index d9ef675..f98eddc 100644
--- a/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java
+++ b/src/main/java/com/ard/utils/sdk/hiksdk/service/impl/HikClientUtil.java
@@ -44,6 +44,7 @@
if (!hCNetSDK.NET_DVR_Init()) {
log.error("SDK初始化失败");
}
+
//打印海康sdk日志
if (Platform.isWindows()) {
String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
@@ -58,6 +59,7 @@
//设置连接时间与重连时间
hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
hCNetSDK.NET_DVR_SetReconnect(100000, true);
+
//设备信息, 输出参数
HCNetSDK.NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
int lUserID = hCNetSDK.NET_DVR_Login_V30(m_sDeviceIP, m_sPort, m_sUsername, m_sPassword, m_strDeviceInfo);
@@ -86,6 +88,12 @@
if (!hCNetSDK.NET_DVR_Init()) {
log.error("SDK初始化失败");
}
+ //设置JSON透传报警数据和图片分离
+ HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG struNET_DVR_LOCAL_GENERAL_CFG = new HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG();
+ struNET_DVR_LOCAL_GENERAL_CFG.byAlarmJsonPictureSeparate = 1; //设置JSON透传报警数据和图片分离
+ struNET_DVR_LOCAL_GENERAL_CFG.write();
+ Pointer pStrNET_DVR_LOCAL_GENERAL_CFG = struNET_DVR_LOCAL_GENERAL_CFG.getPointer();
+ hCNetSDK.NET_DVR_SetSDKLocalCfg(17, pStrNET_DVR_LOCAL_GENERAL_CFG);
//打印海康sdk日志
if (Platform.isWindows()) {
String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
diff --git a/src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java b/src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java
index d840fca..91dfaf0 100644
--- a/src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java
+++ b/src/main/java/com/ard/utils/sdk/hiksdk/util/hikSdkUtil/HCNetSDK.java
@@ -3155,7 +3155,7 @@
public static class NET_DVR_ALARMIN_PARAM extends HIKSDKStructure {
public int dwSize;
public byte[] byName = new byte[NAME_LEN];
- // public DETECTOR_TYPE wDetectorType;
+ // public DETECTOR_TYPE wDetectorType;
public byte byType;
public byte byUploadAlarmRecoveryReport;
public int dwParam;
@@ -4608,6 +4608,16 @@
public byte byIvmsChannel;
}
+ public static class NET_VCA_LEAVE_POSITION extends HIKSDKStructure {
+ public NET_VCA_POLYGON struRegion; //区域范围
+ public short wLeaveDelay; //无人报警时间，单位：s
+ public short wStaticDelay; //睡觉报警时间，单位：s
+ public byte byMode; //模式，0-离岗事件，1-睡岗事件，2-离岗睡岗事件，3-在岗（当离岗人员回到岗位）
+ public byte byPersonType; //值岗人数类型，0-单人值岗，1-双人值岗
+ public byte byOnPosition; //在岗人数，1-10，默认1
+ public byte bySensitivity; //灵敏度参数，范围[1,5]
+ }
+
//事件规则信息
public static class NET_VCA_RULE_INFO extends HIKSDKStructure {
public byte byRuleID;
@@ -4626,6 +4636,9 @@
case 2:
case 3:
uEventParam.setType(NET_VCA_AREA.class);
+ break;
+ case 15:
+ uEventParam.setType(NET_VCA_LEAVE_POSITION.class);
break;
default:
break;
@@ -4646,6 +4659,7 @@
public NET_VCA_TRAVERSE_PLANE struTraversePlane;
public NET_VCA_AREA struArea;
public NET_VCA_INTRUSION struIntrusion;
+ public NET_VCA_LEAVE_POSITION struLeavePos; //离岗参数
}
//穿越警戒面参数
--
Gitblit v1.9.3