From 092d7c56bb8653075b8f4b27220e69e6bb8e5d37 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Thu, 09 Nov 2023 16:49:26 +0800
Subject: [PATCH] 增加超脑业务
---
src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java | 59 ++++
src/main/java/com/ard/utils/tcp/ClientHandler.java | 22 +
src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java | 57 ++++
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java | 467 +++++++++++++++++++++--------------------
src/main/java/com/ard/alarm/radar/controller/RadarController.java | 15 +
src/main/java/com/ard/utils/other/ByteUtils.java | 29 ++
6 files changed, 387 insertions(+), 262 deletions(-)
diff --git a/src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java b/src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java
index 723ab35..411eaf2 100644
--- a/src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java
+++ b/src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java
@@ -19,6 +19,8 @@
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+
/**
* externalService业务层处理
@@ -35,12 +37,12 @@
public static List<ArdEquipExternal> ardAlarmHostList = new ArrayList<>();
public static List<ArdEquipExternal> ardAccessHostList = new ArrayList<>();
-
- @Autowired
+ public static List<ArdEquipExternal> ardSuperBrainHostList = new ArrayList<>();
+ @Resource
private ArdEquipExternalMapper ardEquipExternalMapper;
@Override
- public void run(ApplicationArguments args){
+ public void run(ApplicationArguments args) {
//获取全部海康报警主机尝试登录
ArdEquipExternal alarmHost = new ArdEquipExternal();
alarmHost.setFactory("1");
@@ -55,6 +57,13 @@
ardAccessHostList = selectArdEquipExternalList(accessControlHost);
HikClientUtil.loginAllAccessControlHost(ardAccessHostList);
log.debug("门禁主机尝试登录");
+ //获取全部超脑尝试登录
+ ArdEquipExternal superBrainHost = new ArdEquipExternal();
+ superBrainHost.setFactory("1");
+ superBrainHost.setType("5");
+ ardSuperBrainHostList = selectArdEquipExternalList(superBrainHost);
+ HikClientUtil.loginAllSuperBrainHost(ardSuperBrainHostList);
+ log.debug("超脑尝试登录");
//同步任务
syncTask();
}
@@ -99,10 +108,10 @@
//endregion
//region 定时同步门禁主机
- alarmHost = new ArdEquipExternal();
- alarmHost.setFactory("1");
- alarmHost.setType("6");
- List<ArdEquipExternal> newAccessHostList = selectArdEquipExternalList(alarmHost);
+ ArdEquipExternal accessHost = new ArdEquipExternal();
+ accessHost.setFactory("1");
+ accessHost.setType("6");
+ List<ArdEquipExternal> newAccessHostList = selectArdEquipExternalList(accessHost);
//需要更新的数据
updateList = sameListWithDifferent(ardAccessHostList, newAccessHostList);
if (updateList.size() > 0) {
@@ -128,6 +137,36 @@
}
}
//endregion
+ //region 定时同步超脑
+ ArdEquipExternal superBrainHost = new ArdEquipExternal();
+ superBrainHost.setFactory("1");
+ superBrainHost.setType("5");
+ List<ArdEquipExternal> newSuperBrainList = selectArdEquipExternalList(superBrainHost);
+ //需要更新的数据
+ updateList = sameListWithDifferent(ardSuperBrainHostList, newSuperBrainList);
+ if (updateList.size() > 0) {
+ HikClientUtil.logoutAllSuperBrainHost(updateList);
+ HikClientUtil.loginAllSuperBrainHost(updateList);
+ ardSuperBrainHostList.clear();
+ ardSuperBrainHostList.addAll(newSuperBrainList);
+ }
+ //需要删除的数据
+ delList = diffList(ardSuperBrainHostList, newSuperBrainList);
+ if (delList.size() > 0) {
+ HikClientUtil.logoutAllSuperBrainHost(delList);
+ for (ArdEquipExternal ardEquipExternal : delList) {
+ ardSuperBrainHostList.remove(ardEquipExternal);
+ }
+ }
+ //需要新增的数据
+ inserList = diffList(newSuperBrainList, ardSuperBrainHostList);
+ if (inserList.size() > 0) {
+ HikClientUtil.loginAllSuperBrainHost(inserList);
+ for (ArdEquipExternal ardEquipExternal : inserList) {
+ ardSuperBrainHostList.add(ardEquipExternal);
+ }
+ }
+ //endregion
} catch (Exception e) {
log.error("同步外联任务执行出错" + e.getMessage());
}
@@ -148,7 +187,7 @@
@Override
public ArdEquipExternal selectArdEquipExternal(ArdEquipExternal ardEquipExternal) {
- QueryWrapper<ArdEquipExternal> queryWrapper=new QueryWrapper<>(ardEquipExternal);
+ QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
return ardEquipExternalMapper.selectOne(queryWrapper);
}
@@ -160,7 +199,7 @@
*/
@Override
public List<ArdEquipExternal> selectArdEquipExternalList(ArdEquipExternal ardEquipExternal) {
- QueryWrapper<ArdEquipExternal> queryWrapper=new QueryWrapper<>(ardEquipExternal);
+ QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
return ardEquipExternalMapper.selectList(queryWrapper);
}
diff --git a/src/main/java/com/ard/alarm/radar/controller/RadarController.java b/src/main/java/com/ard/alarm/radar/controller/RadarController.java
index e4dfbad..72f02fb 100644
--- a/src/main/java/com/ard/alarm/radar/controller/RadarController.java
+++ b/src/main/java/com/ard/alarm/radar/controller/RadarController.java
@@ -9,12 +9,15 @@
import com.ard.utils.tcp.ClientInitialize;
import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
+
+import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
/**
* @Description: 雷达接口
@@ -24,6 +27,7 @@
**/
@RestController
@RequestMapping("/radar")
+@Slf4j(topic = "netty")
public class RadarController {
@Resource
@@ -55,14 +59,19 @@
radarPosition[1] = latitude;
double distance = GisUtils.getDistance(radarPosition, targetPosition);
float angleInRadians = (float)Math.atan(distance / altitude);
- float t = 90-(float)Math.toDegrees(angleInRadians);
-
+ float t = (90-(float)Math.toDegrees(angleInRadians))*-1;
+ log.debug("distance："+distance);
+ log.debug("p："+p);
+ log.debug("t："+t);
//发送告警前端的角度提示
byte[] header = {0x01, 0x02, 0x01};//包头
- byte[] payloadHeader = {0x10, 0x03, 0x40, 0x00};//负载头
+ byte[] payloadHeader = {0x10, 0x03, 0x20, 0x00};//负载头
byte[] distanceBytes = ByteUtils.decimalToBytes((int)distance);
+ distanceBytes=ByteUtils.toLittleEndian(distanceBytes);
byte[] pBytes = ByteUtils.floatToBytes(p);
+ pBytes=ByteUtils.toLittleEndian(pBytes);
byte[] tBytes = ByteUtils.floatToBytes(t);
+ tBytes=ByteUtils.toLittleEndian(tBytes);
byte[] resBytes=new byte[20];
byte[] payloadBody = ByteUtils.appendArrays(distanceBytes,pBytes,tBytes,resBytes);//负载
diff --git a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
index aea22b1..6e3ca3c 100644
--- a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
+++ b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
@@ -54,22 +54,23 @@
String sTime;//事件时间
String url = "";//事件图片
//lCommand是传的报警类型
- //log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
+ log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
ArdCameras ardCameras = new ArdCameras();
ardCameras.setIp(sDeviceIP);
ardCameras.setPort(wLinkPort);
IArdCamerasService ardCamerasService = SpringUtils.getBean(IArdCamerasService.class);
List<ArdCameras> ardCamerasList = ardCamerasService.selectArdCamerasList(ardCameras);
- if (ardCamerasList.size() > 0) {
- ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
- switch (lCommand) {
- case HCNetSDK.COMM_ALARM_V30:
- //log.debug("移动侦测");
- HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
- netDvrAlarminfoV30.write();
- Pointer pNDAInfo = netDvrAlarminfoV30.getPointer();
- pNDAInfo.write(0, pAlarmInfo.getByteArray(0, netDvrAlarminfoV30.size()), 0, netDvrAlarminfoV30.size());
- netDvrAlarminfoV30.read();
+ switch (lCommand) {
+ //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
+ case HCNetSDK.COMM_ALARM_V30:
+ //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
+ HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
+ netDvrAlarminfoV30.write();
+ Pointer pNDAInfo = netDvrAlarminfoV30.getPointer();
+ pNDAInfo.write(0, pAlarmInfo.getByteArray(0, netDvrAlarminfoV30.size()), 0, netDvrAlarminfoV30.size());
+ netDvrAlarminfoV30.read();
+ if (ardCamerasList.size() > 0) {
+ ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
switch (netDvrAlarminfoV30.dwAlarmType) {
case 3:
info = new CameraEventInfo();
@@ -90,21 +91,26 @@
publishMqtt(info);
break;
}
- case HCNetSDK.COMM_ALARM_RULE:
- //log.debug("行为分析信息报警信息上报");
- //region 行为分析信息
- HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
- strVcaAlarm.write();
- Pointer pVCAInfo = strVcaAlarm.getPointer();
- pVCAInfo.write(0, pAlarmInfo.getByteArray(0, strVcaAlarm.size()), 0, strVcaAlarm.size());
- strVcaAlarm.read();
- Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
- sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
- String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
- Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
- info = new CameraEventInfo();
- info.setAlarmName("人员行为分析");
- info.setAlarmTime(sTime);
+ }
+ //endregion
+ break;
+ case HCNetSDK.COMM_ALARM_RULE:
+ //log.debug("行为分析信息报警信息上报");
+ //region 异常行为识别信息
+ HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
+ strVcaAlarm.write();
+ Pointer pVCAInfo = strVcaAlarm.getPointer();
+ pVCAInfo.write(0, pAlarmInfo.getByteArray(0, strVcaAlarm.size()), 0, strVcaAlarm.size());
+ strVcaAlarm.read();
+ Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
+ sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
+ String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
+ Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
+ info = new CameraEventInfo();
+ info.setAlarmName("人员行为分析");
+ info.setAlarmTime(sTime);
+ if (ardCamerasList.size() > 0) {
+ ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
info.setCameraName(camera.getName());
info.setCameraId(camera.getId());
info.setCameraIp(camera.getIp());
@@ -171,217 +177,218 @@
// log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
break;
}
- //endregion
- break;
- case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
- //log.debug("人脸检测事件上报(暂不解析)");
- break;
- case HCNetSDK.COMM_GISINFO_UPLOAD:
- //log.debug("GPS报警信息上报(暂不解析)");
- break;
- case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
- //log.debug("报警主机CID报告报警上报");
- //region 报警主机报警处理
- ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
- ardEquipExternal.setIp(sDeviceIP);
- ardEquipExternal.setPort(wLinkPort);
- IArdEquipExternalService ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
- ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal);
+ }
+ //endregion
+ break;
+ case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
+ //log.debug("人脸检测事件上报(暂不解析)");
+ break;
+ case HCNetSDK.COMM_GISINFO_UPLOAD:
+ //log.debug("GPS报警信息上报(暂不解析)");
+ break;
+ case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
+ log.debug("报警主机CID报告报警上报");
+ //region 报警主机报警处理
+ ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
+ ardEquipExternal.setIp(sDeviceIP);
+ ardEquipExternal.setPort(wLinkPort);
+ IArdEquipExternalService ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
+ ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal);
- HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
- netDvrCidAlarm.write();
- Pointer pCIDInfo = netDvrCidAlarm.getPointer();
- pCIDInfo.write(0, pAlarmInfo.getByteArray(0, netDvrCidAlarm.size()), 0, netDvrCidAlarm.size());
- netDvrCidAlarm.read();
- //CID事件名
- String sCIDCode = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDCode);//CID事件名
- //CID事件名
- //String sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);//CID事件名
- int position = ByteUtils.findIndexOfDoubleZero(netDvrCidAlarm.sCIDDescribe);
- String sCIDDescribe;
- if (position != -1) {
- byte[] result = new byte[position];
- System.arraycopy(netDvrCidAlarm.sCIDDescribe, 0, result, 0, position);
- sCIDDescribe = ByteUtils.bytesToStringZh(result);
- } else {
- sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);
- }
- //触发报警的时间点
- String struTriggerTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struTriggerTime), "yyyy-M-d H:m:s");
- //上传报警的时间点
- String struUploadTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struUploadTime), "yyyy-M-d H:m:s");
- //报告类型
- String byReportType = "";
- switch (netDvrCidAlarm.byReportType) {
- case 1:
- byReportType = "防区报警";
- break;
- case 2:
- byReportType = "视频报警";
- break;
- case 3:
- byReportType = "软防区报警";
- break;
- case 4:
- byReportType = "挟持报警";
- break;
- case 5:
- byReportType = "防拆报警 ";
- break;
- case 6:
- byReportType = "操作报告 ";
- break;
- case 7:
- byReportType = "异常报告 ";
- break;
- }
- //子系统号
- Integer bySubSysNo = Integer.valueOf(netDvrCidAlarm.bySubSysNo);
- //防区号 起始0
- Integer wDefenceNo = Integer.valueOf(netDvrCidAlarm.wDefenceNo);
- //防区名称
- String wDefenceName = "";
- if (!bySubSysNo.equals(-1)) {
- CameraCmd cmd = new CameraCmd();
- cmd.setCameraId(ardEquipExternal.getId());
- cmd.setWZoneIndex(wDefenceNo);
- wDefenceName = HikClientUtil.getDefenseZoneName(cmd);
- }
- if (sCIDDescribe.contains("恢复")) {
- return true;
- }
-
- ExternalAlarmEventInfo externalAlarmEventInfo = new ExternalAlarmEventInfo();
- externalAlarmEventInfo.setAlarmId(sCIDCode);
- externalAlarmEventInfo.setAlarmName(sCIDDescribe);
- externalAlarmEventInfo.setDefenseId((wDefenceNo + 1));
- externalAlarmEventInfo.setDefenseName(wDefenceName);
- externalAlarmEventInfo.setSubSysNo(bySubSysNo);
- externalAlarmEventInfo.setAlarmType(byReportType);
- externalAlarmEventInfo.setAlarmTime(struTriggerTime);
- externalAlarmEventInfo.setAlarmHostId(ardEquipExternal.getId());
- publishMqtt(externalAlarmEventInfo);
- //endregion
- break;
- case HCNetSDK.COMM_ALARM_ACS:
- //region 门禁主机报警处理
- ArdEquipExternal accessControlHost = new ArdEquipExternal();
- accessControlHost.setIp(sDeviceIP);
- accessControlHost.setPort(wLinkPort);
- ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
- accessControlHost = ardEquipExternalService.selectArdEquipExternal(accessControlHost);
- HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
- strACSInfo.write();
- Pointer acsInfo = strACSInfo.getPointer();
- acsInfo.write(0, pAlarmInfo.getByteArray(0, strACSInfo.size()), 0, strACSInfo.size());
- strACSInfo.read();
- int dwMajor = strACSInfo.dwMajor;
-
- if (dwMajor != 5) {
- //只获取事件
- // log.debug("非事件报警数据上报(暂不解析)");
+ HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
+ netDvrCidAlarm.write();
+ Pointer pCIDInfo = netDvrCidAlarm.getPointer();
+ pCIDInfo.write(0, pAlarmInfo.getByteArray(0, netDvrCidAlarm.size()), 0, netDvrCidAlarm.size());
+ netDvrCidAlarm.read();
+ //CID事件名
+ String sCIDCode = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDCode);//CID事件名
+ //CID事件名
+ //String sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);//CID事件名
+ int position = ByteUtils.findIndexOfDoubleZero(netDvrCidAlarm.sCIDDescribe);
+ String sCIDDescribe;
+ if (position != -1) {
+ byte[] result = new byte[position];
+ System.arraycopy(netDvrCidAlarm.sCIDDescribe, 0, result, 0, position);
+ sCIDDescribe = ByteUtils.bytesToStringZh(result);
+ } else {
+ sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);
+ }
+ //触发报警的时间点
+ String struTriggerTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struTriggerTime), "yyyy-M-d H:m:s");
+ //上传报警的时间点
+ String struUploadTime = DateUtils.convertDate(parseAlarmTime(netDvrCidAlarm.struUploadTime), "yyyy-M-d H:m:s");
+ //报告类型
+ String byReportType = "";
+ switch (netDvrCidAlarm.byReportType) {
+ case 1:
+ byReportType = "防区报警";
break;
- }
-
- int dwMinor = strACSInfo.dwMinor;
- if (dwMinor != 80 && dwMinor != 104) {
- //只解析真人检测失败和人脸抓拍失败的次类型事件
+ case 2:
+ byReportType = "视频报警";
break;
- }
- String alarmType = "";
- switch (dwMinor) {
- case 104:
- alarmType = "真人检测失败";
- break;
- case 80:
- alarmType = "人脸抓拍失败";
- break;
- }
- log.debug("门禁主机报警上传:" + alarmType);
- String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
+ case 3:
+ byReportType = "软防区报警";
+ break;
+ case 4:
+ byReportType = "挟持报警";
+ break;
+ case 5:
+ byReportType = "防拆报警 ";
+ break;
+ case 6:
+ byReportType = "操作报告 ";
+ break;
+ case 7:
+ byReportType = "异常报告 ";
+ break;
+ }
+ //子系统号
+ Integer bySubSysNo = Integer.valueOf(netDvrCidAlarm.bySubSysNo);
+ //防区号 起始0
+ Integer wDefenceNo = Integer.valueOf(netDvrCidAlarm.wDefenceNo);
+ //防区名称
+ String wDefenceName = "";
+ if (!bySubSysNo.equals(-1)) {
+ CameraCmd cmd = new CameraCmd();
+ cmd.setCameraId(ardEquipExternal.getId());
+ cmd.setWZoneIndex(wDefenceNo);
+ wDefenceName = HikClientUtil.getDefenseZoneName(cmd);
+ }
+ if (sCIDDescribe.contains("恢复")) {
+ return true;
+ }
- //事件图片处理
- int dwPicDataLen = strACSInfo.dwPicDataLen;
- if (dwPicDataLen > 0) {
- try {
- //将字节写入文件
- long offset = 0;
- ByteBuffer buffers = strACSInfo.pPicData.getByteBuffer(offset, strACSInfo.dwPicDataLen);
- byte[] bytes = new byte[strACSInfo.dwPicDataLen];
- buffers.rewind();
- buffers.get(bytes);
- InputStream input = new ByteArrayInputStream(bytes);
- String bucketName = "pic";
- String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
- boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
- if (uploadObject) {
- url = MinioUtil.getBucketObjectUrl(bucketName, objectName);
- //log.debug("上传文件成功!" + url);
- }
- } catch (Exception e) {
- log.error("图片保存失败");
+ ExternalAlarmEventInfo externalAlarmEventInfo = new ExternalAlarmEventInfo();
+ externalAlarmEventInfo.setAlarmId(sCIDCode);
+ externalAlarmEventInfo.setAlarmName(sCIDDescribe);
+ externalAlarmEventInfo.setDefenseId((wDefenceNo + 1));
+ externalAlarmEventInfo.setDefenseName(wDefenceName);
+ externalAlarmEventInfo.setSubSysNo(bySubSysNo);
+ externalAlarmEventInfo.setAlarmType(byReportType);
+ externalAlarmEventInfo.setAlarmTime(struTriggerTime);
+ externalAlarmEventInfo.setAlarmHostId(ardEquipExternal.getId());
+ publishMqtt(externalAlarmEventInfo);
+ //endregion
+ break;
+ case HCNetSDK.COMM_ALARM_ACS:
+ log.debug("门禁主机报警上报");
+ //region 门禁主机报警处理
+ ArdEquipExternal accessControlHost = new ArdEquipExternal();
+ accessControlHost.setIp(sDeviceIP);
+ accessControlHost.setPort(wLinkPort);
+ ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class);
+ accessControlHost = ardEquipExternalService.selectArdEquipExternal(accessControlHost);
+ HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
+ strACSInfo.write();
+ Pointer acsInfo = strACSInfo.getPointer();
+ acsInfo.write(0, pAlarmInfo.getByteArray(0, strACSInfo.size()), 0, strACSInfo.size());
+ strACSInfo.read();
+ int dwMajor = strACSInfo.dwMajor;
+
+ if (dwMajor != 5) {
+ //只获取事件
+ // log.debug("非事件报警数据上报(暂不解析)");
+ break;
+ }
+
+ int dwMinor = strACSInfo.dwMinor;
+ if (dwMinor != 80 && dwMinor != 104) {
+ //只解析真人检测失败和人脸抓拍失败的次类型事件
+ break;
+ }
+ String alarmType = "";
+ switch (dwMinor) {
+ case 104:
+ alarmType = "真人检测失败";
+ break;
+ case 80:
+ alarmType = "人脸抓拍失败";
+ break;
+ }
+ log.debug("门禁主机报警上传:" + alarmType);
+ String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
+
+ //事件图片处理
+ int dwPicDataLen = strACSInfo.dwPicDataLen;
+ if (dwPicDataLen > 0) {
+ try {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = strACSInfo.pPicData.getByteBuffer(offset, strACSInfo.dwPicDataLen);
+ byte[] bytes = new byte[strACSInfo.dwPicDataLen];
+ buffers.rewind();
+ buffers.get(bytes);
+ InputStream input = new ByteArrayInputStream(bytes);
+ String bucketName = "pic";
+ String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
+ boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
+ if (uploadObject) {
+ url = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ //log.debug("上传文件成功!" + url);
}
+ } catch (Exception e) {
+ log.error("图片保存失败");
}
- HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
- int byType = struAcsEventInfo.byType;
- String defenseType = "";
- switch (byType) {
- case 0:
- defenseType = "即时防区";
- break;
- case 1:
- defenseType = "24小时防区";
- break;
- case 2:
- defenseType = "延时防区";
- break;
- case 3:
- defenseType = "内部防区";
- break;
- case 4:
- defenseType = "钥匙防区";
- break;
- case 5:
- defenseType = "火警防区";
- break;
- case 6:
- defenseType = "周界防区";
- break;
- case 7:
- defenseType = "24小时无声防区";
- break;
- case 8:
- defenseType = "24小时辅助防区";
- break;
- case 9:
- defenseType = "24小时震动防区";
- break;
- case 10:
- defenseType = "门禁紧急开门防区";
- break;
- case 11:
- defenseType = "门禁紧急关门防区";
- break;
- default:
- defenseType = "无";
- break;
- }
- AccessControlHostEventInfo accessControlHostEventInfo = new AccessControlHostEventInfo();
- accessControlHostEventInfo.setSerialNo(struAcsEventInfo.dwSerialNo);
- accessControlHostEventInfo.setAlarmType(alarmType);
- accessControlHostEventInfo.setDoorNo(struAcsEventInfo.dwDoorNo);
- accessControlHostEventInfo.setDefenseType(defenseType);
- accessControlHostEventInfo.setAlarmTime(alarmTime);
- accessControlHostEventInfo.setPicUrl(url);
- accessControlHostEventInfo.setAcsId(accessControlHost.getId());
- publishMqtt(accessControlHostEventInfo);
- //endregion
- break;
- default:
- // log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
- break;
+ }
+ HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
+ int byType = struAcsEventInfo.byType;
+ String defenseType = "";
+ switch (byType) {
+ case 0:
+ defenseType = "即时防区";
+ break;
+ case 1:
+ defenseType = "24小时防区";
+ break;
+ case 2:
+ defenseType = "延时防区";
+ break;
+ case 3:
+ defenseType = "内部防区";
+ break;
+ case 4:
+ defenseType = "钥匙防区";
+ break;
+ case 5:
+ defenseType = "火警防区";
+ break;
+ case 6:
+ defenseType = "周界防区";
+ break;
+ case 7:
+ defenseType = "24小时无声防区";
+ break;
+ case 8:
+ defenseType = "24小时辅助防区";
+ break;
+ case 9:
+ defenseType = "24小时震动防区";
+ break;
+ case 10:
+ defenseType = "门禁紧急开门防区";
+ break;
+ case 11:
+ defenseType = "门禁紧急关门防区";
+ break;
+ default:
+ defenseType = "无";
+ break;
+ }
+ AccessControlHostEventInfo accessControlHostEventInfo = new AccessControlHostEventInfo();
+ accessControlHostEventInfo.setSerialNo(struAcsEventInfo.dwSerialNo);
+ accessControlHostEventInfo.setAlarmType(alarmType);
+ accessControlHostEventInfo.setDoorNo(struAcsEventInfo.dwDoorNo);
+ accessControlHostEventInfo.setDefenseType(defenseType);
+ accessControlHostEventInfo.setAlarmTime(alarmTime);
+ accessControlHostEventInfo.setPicUrl(url);
+ accessControlHostEventInfo.setAcsId(accessControlHost.getId());
+ publishMqtt(accessControlHostEventInfo);
+ //endregion
+ break;
+ default:
+ log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
+ break;
- }
}
return true;
}
diff --git a/src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java b/src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java
index ee4b07d..24e4662 100644
--- a/src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java
+++ b/src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java
@@ -124,7 +124,7 @@
int i = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
if (i < 0) {
int errorCode = hCNetSDK.NET_DVR_GetLastError();
- log.info("登录异常：" + errorCode);
+ log.error("登录异常：" + errorCode);
}
}
@@ -221,7 +221,7 @@
// GlobalVariable.alarmHostMap.put(key, alarmHost);
}
} catch (Exception ex) {
- log.error("初始化报警主机异常：" + ex.getMessage());
+ log.error("登录所有报警主机异常：" + ex.getMessage());
}
}
@@ -245,7 +245,7 @@
// GlobalVariable.alarmHostMap.remove(key);
}
} catch (Exception ex) {
- log.error("初始化登录相机异常：" + ex.getMessage());
+ log.error("登出所有报警主机异常：" + ex.getMessage());
}
}
@@ -270,7 +270,7 @@
// GlobalVariable.accessHostMap.put(key, accessControlHost);
}
} catch (Exception ex) {
- log.error("初始化报警主机异常：" + ex.getMessage());
+ log.error("登录所有门禁主机异常：" + ex.getMessage());
}
}
@@ -294,10 +294,57 @@
// GlobalVariable.accessHostMap.remove(key);
}
} catch (Exception ex) {
- log.error("初始化报警主机异常：" + ex.getMessage());
+ log.error("登出所有门禁主机异常：" + ex.getMessage());
+ }
+ }
+ /**
+ * @描述 登录所有超脑
+ * @创建人 刘苏义
+ * @创建时间 2023/2/3 10:10
+ */
+ public static void loginAllSuperBrainHost(List<ArdEquipExternal> ardEquipExternals) {
+ try {
+ for (ArdEquipExternal superBrainHost : ardEquipExternals) {
+ Thread.sleep(100);
+ DeviceInfo info = new DeviceInfo();
+ info.setDeviceId(superBrainHost.getId());
+ info.setIp(superBrainHost.getIp());
+ info.setPort(superBrainHost.getPort());
+ info.setUsername(superBrainHost.getUsername());
+ info.setPassword(superBrainHost.getPassword());
+ login(info);
+//
+// String key=accessControlHost.getIp()+":"+accessControlHost.getPort();
+// GlobalVariable.accessHostMap.put(key, accessControlHost);
+ }
+ } catch (Exception ex) {
+ log.error("登录所有超脑异常：" + ex.getMessage());
}
}
+ /**
+ * @描述 登出所有超脑
+ * @创建人 刘苏义
+ * @创建时间 2023/2/3 10:10
+ */
+ public static void logoutAllSuperBrainHost(List<ArdEquipExternal> ardEquipExternals) {
+ try {
+ for (ArdEquipExternal superBrainHost : ardEquipExternals) {
+ Thread.sleep(100);
+ DeviceInfo info = new DeviceInfo();
+ info.setDeviceId(superBrainHost.getId());
+ info.setIp(superBrainHost.getIp());
+ info.setPort(superBrainHost.getPort());
+ info.setUsername(superBrainHost.getUsername());
+ info.setPassword(superBrainHost.getPassword());
+ logout(info);
+// String key=accessControlHost.getIp()+":"+accessControlHost.getPort();
+// GlobalVariable.accessHostMap.remove(key);
+ }
+ } catch (Exception ex) {
+ log.error("登出所有超脑异常：" + ex.getMessage());
+ }
+ }
/**
* 建立布防上传通道，用于传输数据
@@ -323,7 +370,7 @@
HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();
m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
// 智能交通布防优先级：0 - 一等级（高），1 - 二等级（中），2 - 三等级（低）
- m_strAlarmInfo.byLevel = 2;
+ m_strAlarmInfo.byLevel = 0;
// 智能交通报警信息上传类型：0 - 老报警信息（NET_DVR_PLATE_RESULT）, 1 - 新报警信息(NET_ITS_PLATE_RESULT)
m_strAlarmInfo.byAlarmInfoType = 1;
// 布防类型(仅针对门禁主机、人证设备)：0 - 客户端布防(会断网续传)，1 - 实时布防(只上传实时数据)
diff --git a/src/main/java/com/ard/utils/other/ByteUtils.java b/src/main/java/com/ard/utils/other/ByteUtils.java
index bda4b8c..0c11f68 100644
--- a/src/main/java/com/ard/utils/other/ByteUtils.java
+++ b/src/main/java/com/ard/utils/other/ByteUtils.java
@@ -30,13 +30,27 @@
* byte数组转中文字符串
*/
public static String bytesToStringZh(byte[] bytes) {
- ByteBuffer buffer = ByteBuffer.wrap(bytes); // byteArray 是包含字节数组的变量
+ //ByteBuffer buffer = ByteBuffer.wrap(bytes); // byteArray 是包含字节数组的变量
+ //try {
+ // return new String(buffer.array(), "GBK");
+ //} catch (UnsupportedEncodingException e) {
+ // e.printStackTrace();
+ //}
+ //return "";
+ String zhStr = "";
try {
- return new String(buffer.array(), "GBK");
+ int position = ByteUtils.findIndexOfDoubleZero(bytes);
+ if (position != -1) {
+ byte[] result = new byte[position];
+ System.arraycopy(bytes, 0, result, 0, position);
+ zhStr = new String(result, "GBK");
+ } else {
+ zhStr = new String(bytes, "GBK");
+ }
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
- return "";
+ return zhStr;
}
/**
@@ -67,8 +81,13 @@
* byte数组转整型
*/
public static int bytesToDecimal(byte[] byteArray) {
- ByteBuffer buffer = ByteBuffer.wrap(byteArray); // byteArray 是包含字节数组的变量
- return buffer.getInt();
+ //ByteBuffer buffer = ByteBuffer.wrap(byteArray); // byteArray 是包含字节数组的变量
+ //return buffer.getInt();
+ int decimalValue = 0;
+ for (int i = 0; i < byteArray.length; i++) {
+ decimalValue = (decimalValue << 8) | (byteArray[i] & 0xFF);
+ }
+ return decimalValue;
}
diff --git a/src/main/java/com/ard/utils/tcp/ClientHandler.java b/src/main/java/com/ard/utils/tcp/ClientHandler.java
index 15258ce..0063611 100644
--- a/src/main/java/com/ard/utils/tcp/ClientHandler.java
+++ b/src/main/java/com/ard/utils/tcp/ClientHandler.java
@@ -175,7 +175,7 @@
if (!crc32Check) {
log.debug("CRC32校验不通过");
} else {
- log.debug("CRC32校验通过");
+ //log.debug("CRC32校验通过");
}
//endregion
//log.info("原始数据:" + DatatypeConverter.printHexBinary(data));
@@ -188,6 +188,7 @@
// log.info("命令ID:" + DatatypeConverter.printHexBinary(cmdId));
byte[] payloadSize = Arrays.copyOfRange(data, 2, 4);//有效负载大小
payloadSize = ByteUtils.toLittleEndian(payloadSize);
+ //log.info("payloadSize:" + DatatypeConverter.printHexBinary(payloadSize));
int payloadSizeToDecimal = ByteUtils.bytesToDecimal(payloadSize);
// log.info("有效负载大小(转整型):" + payloadSizeToDecimal);
//endregion
@@ -461,13 +462,17 @@
log.debug("方位:" + tx);
byte[] fTy = Arrays.copyOfRange(data, 12, 16);
fTy = ByteUtils.toLittleEndian(fTy);
- float ty= ByteUtils.bytesToFloat(fTy);
+ float ty = ByteUtils.bytesToFloat(fTy);
+ if (ty < 0) {
+ ty += 360;
+ }
log.debug("俯仰:" + ty);
- Map<String,Object>forceGuideMap=new HashMap<>();
- forceGuideMap.put("p",tx);
- forceGuideMap.put("t",ty);
- forceGuideMap.put("z",1);
- forceGuideMap.put("radarId",radarId);
+ Map<String, Object> forceGuideMap = new HashMap<>();
+ forceGuideMap.put("distance", distance);
+ forceGuideMap.put("p", tx);
+ forceGuideMap.put("t", ty);
+ forceGuideMap.put("radarId", radarId);
+ log.debug("强制引导信息" + forceGuideMap);
//endregion
MqttProducer.publish(2, false, "radarForceGuide", JSON.toJSONString(forceGuideMap));
}
@@ -475,5 +480,4 @@
log.error("雷达报文解析异常:" + ex.getMessage());
}
}
-
-}
+}
\ No newline at end of file
--
Gitblit v1.9.3