From 2574db703fa175765394dba9d4e0d623a1bcd16a Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Wed, 29 Nov 2023 17:19:57 +0800
Subject: [PATCH] 修复bug
---
src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java | 59 +++
/dev/null | 7
src/main/java/com/ard/utils/tcp/ClientHandler.java | 62 ++-
src/main/java/com/ard/utils/hiksdk/domain/FaceSnapEventInfo.java | 16 +
src/main/java/com/ard/alarm/external/service/impl/ArdEquipExternalServiceImpl.java | 143 ++--------
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java | 446 ++++++++++++++++++++++++---------
src/main/java/com/ard/utils/hiksdk/domain/FaceMatchEventInfo.java | 19 +
src/main/java/com/ard/alarm/external/service/IArdEquipExternalService.java | 14
src/main/java/com/ard/alarm/radar/domain/RadarAlarmData.java | 1
pom.xml | 11
10 files changed, 476 insertions(+), 302 deletions(-)
diff --git a/Dockerfile b/Dockerfile
deleted file mode 100644
index f798222..0000000
--- a/Dockerfile
+++ /dev/null
@@ -1,7 +0,0 @@
-FROM openjdk:8-jdk-alpine
-ARG JAR_FILE=target/*.jar
-COPY ${JAR_FILE} ard_alarm.jar
-ENV TimeZone=Asia/Shanghai
-# 使用软连接，并且将时区配置覆盖/etc/timezone
-RUN ln -snf /usr/share/zoneinfo/$TimeZone /etc/localtime && echo $TimeZone > /etc/timezone
-ENTRYPOINT ["java","-jar","/ard_alarm.jar"]
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 13ace48..4ddcd2e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -139,17 +139,6 @@
</configuration>
</plugin>
<plugin>
- <groupId>com.spotify</groupId>
- <artifactId>dockerfile-maven-plugin</artifactId>
- <version>1.3.6</version>
- <configuration>
- <repository>${docker.image.prefix}/${project.artifactId}</repository>
- <buildArgs>
- <JAR_FILE>target/${project.build.finalName}.jar</JAR_FILE>
- </buildArgs>
- </configuration>
- </plugin>
- <plugin>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>1.4.1</version>
diff --git a/src/main/java/com/ard/alarm/external/service/IArdEquipExternalService.java b/src/main/java/com/ard/alarm/external/service/IArdEquipExternalService.java
index db2b2e0..d670221 100644
--- a/src/main/java/com/ard/alarm/external/service/IArdEquipExternalService.java
+++ b/src/main/java/com/ard/alarm/external/service/IArdEquipExternalService.java
@@ -12,13 +12,7 @@
* @date 2023-03-13
*/
public interface IArdEquipExternalService {
- /**
- * 查询external
- *
- * @param id external主键
- * @return external
- */
- public ArdEquipExternal selectArdEquipExternalById(String id);
+
/**
* 查询external
@@ -29,11 +23,11 @@
public ArdEquipExternal selectArdEquipExternal(ArdEquipExternal ardEquipExternal);
/**
- * 查询external列表
+ * 查询external列表按类型列表
*
- * @param ardEquipExternal external
+ * @param types 类型列表
* @return external集合
*/
- public List<ArdEquipExternal> selectArdEquipExternalList(ArdEquipExternal ardEquipExternal);
+ public List<ArdEquipExternal> selectArdEquipExternalListByTypes(List<String> types);
}
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 411eaf2..782a1c9 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
@@ -35,35 +35,17 @@
private final static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
- public static List<ArdEquipExternal> ardAlarmHostList = new ArrayList<>();
- public static List<ArdEquipExternal> ardAccessHostList = new ArrayList<>();
- public static List<ArdEquipExternal> ardSuperBrainHostList = new ArrayList<>();
+ public static List<ArdEquipExternal> ardEquipExternalList = new ArrayList<>();
@Resource
private ArdEquipExternalMapper ardEquipExternalMapper;
@Override
public void run(ApplicationArguments args) {
- //获取全部海康报警主机尝试登录
- ArdEquipExternal alarmHost = new ArdEquipExternal();
- alarmHost.setFactory("1");
- alarmHost.setType("1");
- ardAlarmHostList = selectArdEquipExternalList(alarmHost);
- HikClientUtil.loginAllAlarmHost(ardAlarmHostList);
- log.debug("报警主机尝试登录");
- //获取全部门禁主机尝试登录
- ArdEquipExternal accessControlHost = new ArdEquipExternal();
- accessControlHost.setFactory("1");
- accessControlHost.setType("6");
- 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("超脑尝试登录");
+ List<String> targetTypes = Arrays.asList("1", "5", "6");
+ List<ArdEquipExternal> ardEquipExternals = selectArdEquipExternalListByTypes(targetTypes);
+ HikClientUtil.loginAllArdEquipExternals(ardEquipExternals);
+ ardEquipExternalList.addAll(ardEquipExternals);
+ log.debug("外联设备尝试登录");
//同步任务
syncTask();
}
@@ -76,94 +58,31 @@
private void syncTask() {
scheduler.scheduleAtFixedRate(() -> {
try {
- //region 定时同步报警主机
- ArdEquipExternal alarmHost = new ArdEquipExternal();
- alarmHost.setFactory("1");
- alarmHost.setType("1");
- List<ArdEquipExternal> newAlarmHostList = selectArdEquipExternalList(alarmHost);
+ //region 定时同步外联设备
+ List<String> targetTypes = Arrays.asList("1", "5", "6");
+ List<ArdEquipExternal> ardEquipExternalsNew = selectArdEquipExternalListByTypes(targetTypes);
//需要更新的数据
- List<ArdEquipExternal> updateList = sameListWithDifferent(ardAlarmHostList, newAlarmHostList);
+ List<ArdEquipExternal> updateList = sameListWithDifferent(ardEquipExternalList, ardEquipExternalsNew);
if (updateList.size() > 0) {
- HikClientUtil.logoutAllAlarmHost(updateList);
- HikClientUtil.loginAllAlarmHost(updateList);
- ardAlarmHostList.clear();
- ardAlarmHostList.addAll(newAlarmHostList);
+ HikClientUtil.logoutAllArdEquipExternals(updateList);
+ HikClientUtil.loginAllArdEquipExternals(updateList);
+ ardEquipExternalList.clear();
+ ardEquipExternalList.addAll(ardEquipExternalsNew);
}
//需要删除的数据
- List<ArdEquipExternal> delList = diffList(ardAlarmHostList, newAlarmHostList);
+ List<ArdEquipExternal> delList = diffList(ardEquipExternalList, ardEquipExternalsNew);
if (delList.size() > 0) {
- HikClientUtil.logoutAllAlarmHost(delList);
+ HikClientUtil.logoutAllArdEquipExternals(delList);
for (ArdEquipExternal ardEquipExternal : delList) {
- ardAlarmHostList.remove(ardEquipExternal);
+ ardEquipExternalList.remove(ardEquipExternal);
}
}
//需要新增的数据
- List<ArdEquipExternal> inserList = diffList(newAlarmHostList, ardAlarmHostList);
+ List<ArdEquipExternal> inserList = diffList(ardEquipExternalsNew, ardEquipExternalList);
if (inserList.size() > 0) {
- HikClientUtil.loginAllAlarmHost(inserList);
+ HikClientUtil.loginAllArdEquipExternals(inserList);
for (ArdEquipExternal ardEquipExternal : inserList) {
- ardAlarmHostList.add(ardEquipExternal);
- }
- }
-
- //endregion
- //region 定时同步门禁主机
- ArdEquipExternal accessHost = new ArdEquipExternal();
- accessHost.setFactory("1");
- accessHost.setType("6");
- List<ArdEquipExternal> newAccessHostList = selectArdEquipExternalList(accessHost);
- //需要更新的数据
- updateList = sameListWithDifferent(ardAccessHostList, newAccessHostList);
- if (updateList.size() > 0) {
- HikClientUtil.logoutAllAlarmHost(updateList);
- HikClientUtil.loginAllAlarmHost(updateList);
- ardAccessHostList.clear();
- ardAccessHostList.addAll(newAccessHostList);
- }
- //需要删除的数据
- delList = diffList(ardAccessHostList, newAccessHostList);
- if (delList.size() > 0) {
- HikClientUtil.logoutAllAccessControlHost(delList);
- for (ArdEquipExternal ardEquipExternal : delList) {
- ardAccessHostList.remove(ardEquipExternal);
- }
- }
- //需要新增的数据
- inserList = diffList(newAccessHostList, ardAccessHostList);
- if (inserList.size() > 0) {
- HikClientUtil.loginAllAccessControlHost(inserList);
- for (ArdEquipExternal ardEquipExternal : inserList) {
- ardAccessHostList.add(ardEquipExternal);
- }
- }
- //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);
+ ardEquipExternalList.add(ardEquipExternal);
}
}
//endregion
@@ -173,18 +92,12 @@
}, 10, 10, TimeUnit.SECONDS);
}
-
/**
* 查询external
*
- * @param id external主键
- * @return external
+ * @param ardEquipExternal external
+ * @return external集合
*/
- @Override
- public ArdEquipExternal selectArdEquipExternalById(String id) {
- return ardEquipExternalMapper.selectById(id);
- }
-
@Override
public ArdEquipExternal selectArdEquipExternal(ArdEquipExternal ardEquipExternal) {
QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
@@ -192,17 +105,17 @@
}
/**
- * 查询external列表
+ * 按类型列表查询external列表
*
- * @param ardEquipExternal external
+ * @param types 类型列表
* @return external
*/
@Override
- public List<ArdEquipExternal> selectArdEquipExternalList(ArdEquipExternal ardEquipExternal) {
- QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>(ardEquipExternal);
+ public List<ArdEquipExternal> selectArdEquipExternalListByTypes(List<String> types) {
+ QueryWrapper<ArdEquipExternal> queryWrapper = new QueryWrapper<>();
+ queryWrapper.in("type", types);
return ardEquipExternalMapper.selectList(queryWrapper);
}
-
//求两个对象List的交集字段不同Id相同
private List<ArdEquipExternal> sameListWithDifferent(List<ArdEquipExternal> oldList, List<ArdEquipExternal> newList) {
@@ -224,8 +137,6 @@
return differentFieldsList;
}
-
-
// 求两个对象List的差集
private List<ArdEquipExternal> diffList(List<ArdEquipExternal> oldArrayList, List<ArdEquipExternal> newArrayList) {
List<ArdEquipExternal> resultList = oldArrayList.stream()
diff --git a/src/main/java/com/ard/alarm/radar/domain/RadarAlarmData.java b/src/main/java/com/ard/alarm/radar/domain/RadarAlarmData.java
index 192c4a3..8cf17ec 100644
--- a/src/main/java/com/ard/alarm/radar/domain/RadarAlarmData.java
+++ b/src/main/java/com/ard/alarm/radar/domain/RadarAlarmData.java
@@ -17,4 +17,5 @@
String radarName;
String alarmTime;
List<ArdAlarmRadar> ardAlarmRadars;
+ List<ArdAlarmRadar> ardFollowRadars;
}
diff --git a/src/main/java/com/ard/utils/hiksdk/domain/FaceMatchEventInfo.java b/src/main/java/com/ard/utils/hiksdk/domain/FaceMatchEventInfo.java
new file mode 100644
index 0000000..3044d2c
--- /dev/null
+++ b/src/main/java/com/ard/utils/hiksdk/domain/FaceMatchEventInfo.java
@@ -0,0 +1,19 @@
+package com.ard.utils.hiksdk.domain;
+
+import lombok.Data;
+
+/**
+ * @Description: 人脸比对事件信息
+ * @Version: 1.0
+ * @ClassName: FaceSnapEventInfo
+ * @Author: 刘苏义
+ * @Date: 2023年11月10日13:03:22
+ **/
+@Data
+public class FaceMatchEventInfo {
+
+ private String alarmType;
+ private String status;
+ private String alarmTime;
+ private String picUrl;
+}
diff --git a/src/main/java/com/ard/utils/hiksdk/domain/FaceSnapEventInfo.java b/src/main/java/com/ard/utils/hiksdk/domain/FaceSnapEventInfo.java
new file mode 100644
index 0000000..9976726
--- /dev/null
+++ b/src/main/java/com/ard/utils/hiksdk/domain/FaceSnapEventInfo.java
@@ -0,0 +1,16 @@
+package com.ard.utils.hiksdk.domain;
+
+import lombok.Data;
+
+/**
+ * @Description:
+ * @ClassName: FaceSnapEventInfo
+ * @Author: 刘苏义
+ * @Date: 2023年11月10日13:03:22
+ **/
+@Data
+public class FaceSnapEventInfo {
+ private String eventId;
+ private String alarmTime;
+ private String picUrl;
+}
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 6e3ca3c..0295348 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
@@ -3,19 +3,16 @@
import com.alibaba.fastjson2.JSON;
import com.ard.alarm.camera.domain.ArdCameras;
import com.ard.alarm.camera.domain.CameraCmd;
-import com.ard.alarm.camera.service.IArdCamerasService;
+import com.ard.alarm.camera.service.impl.ArdCamerasServiceImpl;
import com.ard.alarm.external.domain.ArdEquipExternal;
-import com.ard.alarm.external.service.IArdEquipExternalService;
+import com.ard.alarm.external.service.impl.ArdEquipExternalServiceImpl;
+import com.ard.utils.hiksdk.domain.*;
import com.ard.utils.minio.MinioUtil;
import com.ard.utils.other.ByteUtils;
import com.ard.utils.hiksdk.common.GlobalVariable;
-import com.ard.utils.hiksdk.domain.AccessControlHostEventInfo;
-import com.ard.utils.hiksdk.domain.CameraEventInfo;
-import com.ard.utils.hiksdk.domain.ExternalAlarmEventInfo;
import com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK;
import com.ard.utils.other.DateUtils;
import com.ard.utils.mqtt.MqttProducer;
-import com.ard.utils.spring.SpringUtils;
import com.ard.utils.uuid.IdUtils;
import com.sun.jna.Pointer;
import lombok.extern.slf4j.Slf4j;
@@ -24,7 +21,9 @@
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
-import java.util.List;
+import java.util.Optional;
+
+import static com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK.*;
/**
* @ClassName: FMSGCallBack
@@ -50,52 +49,65 @@
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP).trim();//设备IP地址
Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口
+ //通过ip和端口查询设备
+ Optional<ArdCameras> foundCamera = findArdCameraByIpAndPort(sDeviceIP, wLinkPort);
+ Optional<ArdEquipExternal> foundExternal = findArdEquipExternalByIpAndPort(sDeviceIP, wLinkPort);
+ ArdCameras camera = null;
+ ArdEquipExternal ardEquipExternal = null;
+ if (foundCamera.isPresent()) {
+ camera = foundCamera.get();
+ } else {
+ if (foundExternal.isPresent()) {
+ ardEquipExternal = foundExternal.get();
+ }
+ }
+ //如果没有找到设备，直接返回
+ if (camera == null && ardEquipExternal == null) {
+ return false;
+ }
CameraEventInfo info;
- String sTime;//事件时间
- String url = "";//事件图片
+ String alarmTime;//事件时间
+ String alarmType = "";//报警类型
+ String picUrl = "";//事件图片
+ String facePicUrl = "";//人脸图片
//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);
+ log.debug("【" + sDeviceIP + ":" + wLinkPort + "】报警事件类型:lCommand:" + Integer.toHexString(lCommand));
switch (lCommand) {
- //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
- case HCNetSDK.COMM_ALARM_V30:
+ case COMM_ALARM_V30:
+ log.debug("移动侦测报警信息上报");
+ if (camera == null) {
+ return false;
+ }
//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();
- 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
- url = savePicture(info);
- info.setPicUrl(url);
- publishMqtt(info);
- break;
- }
+ 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");
+ break;
}
//endregion
break;
- case HCNetSDK.COMM_ALARM_RULE:
- //log.debug("行为分析信息报警信息上报");
+ case COMM_ALARM_RULE:
+ log.debug("异常行为识别信息报警信息上报");
//region 异常行为识别信息
HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
strVcaAlarm.write();
@@ -103,33 +115,30 @@
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
+ alarmTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
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());
- 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
- url = savePicture(info);
- info.setPicUrl(url);
- publishMqtt(info);
- //endregion
- break;
+ 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");
+ //endregion
+ break;
// case 2: //region 目标进入区域
// info.setAlarmType("目标进入区域报警");
// strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_AREA.class);
@@ -140,15 +149,15 @@
// 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
- url = savePicture(info);
- info.setPicUrl(url);
- publishMqtt(info);
- //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");
+ //endregion
+ break;
// case 5: //region 徘徊
// info.setAlarmType("徘徊事件报警");
// //endregion
@@ -173,28 +182,212 @@
// info.setAlarmType("玩手机报警事件");
// //endregion
// break;
- default:
- // log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
- break;
- }
+ default:
+ log.debug("未知异常行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
+ break;
}
//endregion
break;
- case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
- //log.debug("人脸检测事件上报(暂不解析)");
+ case COMM_UPLOAD_FACESNAP_RESULT:
+ log.debug("人脸抓拍报警信息(暂不解析)");
+ //region 人脸抓拍报警信息
+ HCNetSDK.NET_VCA_FACESNAP_RESULT struFaceSnap = new HCNetSDK.NET_VCA_FACESNAP_RESULT();
+ struFaceSnap.write();
+ Pointer vcaInfo = struFaceSnap.getPointer();
+ vcaInfo.write(0, pAlarmInfo.getByteArray(0, struFaceSnap.size()), 0, struFaceSnap.size());
+ struFaceSnap.read();
+ alarmTime = DateUtils.parseTime(struFaceSnap.dwAbsTime);
+ String facePicTyp;
+ switch (struFaceSnap.byUploadEventDataType) {
+ case 0:
+ facePicTyp = "二进制数据";
+ break;
+ case 1:
+ facePicTyp = "URL";
+ break;
+ default:
+ facePicTyp = "";
+ break;
+ }
+ if (struFaceSnap.dwFacePicLen > 0 && struFaceSnap.pBuffer1 != null) {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struFaceSnap.pBuffer1.getByteBuffer(offset, struFaceSnap.dwBackgroundPicLen);
+ byte[] bytes = new byte[struFaceSnap.dwBackgroundPicLen];
+ 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) {
+ facePicUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ //log.debug("上传文件成功!" + url);
+ }
+ } catch (Exception e) {
+ log.error("人脸抓拍报警信息图片保存失败" + e.getMessage());
+ }
+ }
+ if (struFaceSnap.dwBackgroundPicLen > 0 && struFaceSnap.pBuffer2 != null) {
+ //将字节写入文件
+ long offset = 0;
+ ByteBuffer buffers = struFaceSnap.pBuffer2.getByteBuffer(offset, struFaceSnap.dwBackgroundPicLen);
+ byte[] bytes = new byte[struFaceSnap.dwBackgroundPicLen];
+ 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());
+ }
+ }
+ log.debug("【人脸抓拍报警信息】: alarmTime:" + alarmTime + " picUrl:" + picUrl + " facePicType:" + facePicTyp + " facePicUrl:" + facePicUrl);
+ FaceSnapEventInfo faceSnapEventInfo = new FaceSnapEventInfo();
+ faceSnapEventInfo.setAlarmTime(alarmTime);
+ faceSnapEventInfo.setPicUrl(picUrl);
+ publishMqtt(faceSnapEventInfo, "superbrain");
+ //endregion
break;
- case HCNetSDK.COMM_GISINFO_UPLOAD:
- //log.debug("GPS报警信息上报(暂不解析)");
+ case COMM_SNAP_MATCH_ALARM:
+ log.debug("人脸比对报警信息");
+ //region 人脸比对报警信息
+ HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM struFaceMatchAlarm = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
+ 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 = "比对失败";
+ break;
+ default:
+ contrastStatus = "未知";
+ break;
+ }
+ switch (struFaceMatchAlarm.struBlockListInfo.struBlockListInfo.byType) {
+ case 1:
+ alarmType = "陌生人报警";
+ break;
+ case 2:
+ alarmType = "人脸比对报警";
+ break;
+ default:
+ alarmType = "未知";
+ break;
+ }
+ if (struFaceMatchAlarm.dwSnapPicLen > 0 && struFaceMatchAlarm.pSnapPicBuffer != null && struFaceMatchAlarm.byPicTransType == 0) {
+ //将字节写入文件
+ 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());
+ }
+ }
+ if (struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0 && struFaceMatchAlarm.struBlockListInfo.pBuffer1 != null) {
+ //将字节写入文件
+ 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);
+ 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());
+ }
+ }
+ 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();
+ }
+ 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 HCNetSDK.COMM_ALARMHOST_CID_ALARM:
+ case COMM_UPLOAD_AIOP_VIDEO:
+ log.debug("设备支持AI开放平台接入，上传视频检测数据(暂不解析)");
+ break;
+ case COMM_ISAPI_ALARM:
+ log.debug("安全帽检测报警信息");
+ //region 安全帽检测报警信息
+ HCNetSDK.NET_DVR_ALARM_ISAPI_INFO struEventISAPI = new HCNetSDK.NET_DVR_ALARM_ISAPI_INFO();
+ struEventISAPI.write();
+ Pointer pEventISAPI = struEventISAPI.getPointer();
+ pEventISAPI.write(0, pAlarmInfo.getByteArray(0, struEventISAPI.size()), 0, struEventISAPI.size());
+ struEventISAPI.read();
+ 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("检测到安全帽事件");
+ //endregion
+ break;
+ case COMM_GISINFO_UPLOAD:
+ log.debug("GPS报警信息上报(暂不解析)");
+ break;
+ case 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();
@@ -267,36 +460,29 @@
externalAlarmEventInfo.setAlarmType(byReportType);
externalAlarmEventInfo.setAlarmTime(struTriggerTime);
externalAlarmEventInfo.setAlarmHostId(ardEquipExternal.getId());
- publishMqtt(externalAlarmEventInfo);
+ publishMqtt(externalAlarmEventInfo, "external");
//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 = "真人检测失败";
@@ -306,7 +492,7 @@
break;
}
log.debug("门禁主机报警上传:" + alarmType);
- String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
+ alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
//事件图片处理
int dwPicDataLen = strACSInfo.dwPicDataLen;
@@ -323,7 +509,7 @@
String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG");
if (uploadObject) {
- url = MinioUtil.getBucketObjectUrl(bucketName, objectName);
+ picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
//log.debug("上传文件成功!" + url);
}
} catch (Exception e) {
@@ -380,9 +566,9 @@
accessControlHostEventInfo.setDoorNo(struAcsEventInfo.dwDoorNo);
accessControlHostEventInfo.setDefenseType(defenseType);
accessControlHostEventInfo.setAlarmTime(alarmTime);
- accessControlHostEventInfo.setPicUrl(url);
- accessControlHostEventInfo.setAcsId(accessControlHost.getId());
- publishMqtt(accessControlHostEventInfo);
+ accessControlHostEventInfo.setPicUrl(picUrl);
+ accessControlHostEventInfo.setAcsId(ardEquipExternal.getId());
+ publishMqtt(accessControlHostEventInfo, "accessControl");
//endregion
break;
default:
@@ -393,11 +579,37 @@
return true;
}
+ /**
+ * 根据给定的IP地址和端口查找ArdEquipExternal对象
+ *
+ * @param ip IP地址
+ * @param port 端口
+ * @return ArdEquipExternal对象的Optional，如果找到则有值，否则为空
+ */
+ public static Optional<ArdEquipExternal> findArdEquipExternalByIpAndPort(String ip, int port) {
+ return ArdEquipExternalServiceImpl.ardEquipExternalList.stream()
+ .filter(equip -> equip.getIp().equals(ip) && equip.getPort() == port)
+ .findFirst();
+ }
+
+ /**
+ * 根据IP地址和端口查找ArdCamera对象。
+ *
+ * @param ip IP地址
+ * @param port 端口
+ * @return ArdCamera对象的Optional，如果找不到则为空
+ */
+ public static Optional<ArdCameras> findArdCameraByIpAndPort(String ip, int port) {
+ return ArdCamerasServiceImpl.ardCameraList.stream()
+ .filter(camera -> camera.getIp().equals(ip) && camera.getPort() == port)
+ .findFirst();
+ }
+
/**
* 相机截图
*/
- private String savePicture(CameraEventInfo info) {
+ private String snapPicture(CameraEventInfo info) {
CameraCmd cmd = new CameraCmd();
String key = info.getCameraIp() + ":" + info.getCameraPort();
ArdCameras Cameras = GlobalVariable.cameraMap.get(key);
@@ -443,27 +655,13 @@
}
/**
- * 通用光电报警推送mqtt
+ * 发布MQTT消息
+ *
+ * @param info 消息内容
+ * @param topic 主题
*/
- private void publishMqtt(CameraEventInfo info) {
- printLog(info);
- MqttProducer.publish(2, false, "camera", JSON.toJSONString(info));
- }
-
- /**
- * 报警主机事件推送mqtt
- */
- private void publishMqtt(ExternalAlarmEventInfo info) {
- printLog(info);
- MqttProducer.publish(2, false, "external", JSON.toJSONString(info));
- }
-
- /**
- * 门禁事件推送mqtt
- */
- private void publishMqtt(AccessControlHostEventInfo info) {
- printLog(info);
- MqttProducer.publish(2, false, "accessControl", JSON.toJSONString(info));
+ private <T> void publishMqtt(T info, String topic) {
+ MqttProducer.publish(2, false, topic, JSON.toJSONString(info));
}
/**
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 24e4662..c992f8e 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
@@ -265,9 +265,6 @@
info.setUsername(accessControlHost.getUsername());
info.setPassword(accessControlHost.getPassword());
login(info);
-//
-// String key=accessControlHost.getIp()+":"+accessControlHost.getPort();
-// GlobalVariable.accessHostMap.put(key, accessControlHost);
}
} catch (Exception ex) {
log.error("登录所有门禁主机异常：" + ex.getMessage());
@@ -290,13 +287,12 @@
info.setUsername(accessControlHost.getUsername());
info.setPassword(accessControlHost.getPassword());
logout(info);
-// String key=accessControlHost.getIp()+":"+accessControlHost.getPort();
-// GlobalVariable.accessHostMap.remove(key);
}
} catch (Exception ex) {
log.error("登出所有门禁主机异常：" + ex.getMessage());
}
}
+
/**
* @描述 登录所有超脑
* @创建人 刘苏义
@@ -313,9 +309,6 @@
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());
@@ -345,6 +338,50 @@
log.error("登出所有超脑异常：" + ex.getMessage());
}
}
+ /**
+ * @描述 登录所有外联设备
+ * @创建人 刘苏义
+ * @创建时间 2023/2/3 10:10
+ */
+ public static void loginAllArdEquipExternals(List<ArdEquipExternal> ardEquipExternals) {
+ try {
+ for (ArdEquipExternal ardEquipExternal : ardEquipExternals) {
+ Thread.sleep(100);
+ DeviceInfo info = new DeviceInfo();
+ info.setDeviceId(ardEquipExternal.getId());
+ info.setIp(ardEquipExternal.getIp());
+ info.setPort(ardEquipExternal.getPort());
+ info.setUsername(ardEquipExternal.getUsername());
+ info.setPassword(ardEquipExternal.getPassword());
+ login(info);
+ }
+ } catch (Exception ex) {
+ log.error("登录所有外联设备异常：" + ex.getMessage());
+ }
+ }
+ /**
+ * @描述 登出所有外联设备
+ * @创建人 刘苏义
+ * @创建时间 2023/2/3 10:10
+ */
+ public static void logoutAllArdEquipExternals(List<ArdEquipExternal> ardEquipExternals) {
+ try {
+ for (ArdEquipExternal ardEquipExternal : ardEquipExternals) {
+ Thread.sleep(100);
+ DeviceInfo info = new DeviceInfo();
+ info.setDeviceId(ardEquipExternal.getId());
+ info.setIp(ardEquipExternal.getIp());
+ info.setPort(ardEquipExternal.getPort());
+ info.setUsername(ardEquipExternal.getUsername());
+ info.setPassword(ardEquipExternal.getPassword());
+ logout(info);
+ }
+ } catch (Exception ex) {
+ log.error("登出所有超脑异常：" + ex.getMessage());
+ }
+ }
+
+
/**
* 建立布防上传通道，用于传输数据
@@ -375,6 +412,8 @@
m_strAlarmInfo.byAlarmInfoType = 1;
// 布防类型(仅针对门禁主机、人证设备)：0 - 客户端布防(会断网续传)，1 - 实时布防(只上传实时数据)
m_strAlarmInfo.byDeployType = 1;
+ //人脸报警信息类型：1- 人脸侦测报警 0- 人脸抓拍报警
+ m_strAlarmInfo.byFaceAlarmDetection = 0;
m_strAlarmInfo.write();
// 布防成功，返回布防成功的数据传输通道号
lAlarmHandle = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID, m_strAlarmInfo);
@@ -440,10 +479,10 @@
InputStream input = new ByteArrayInputStream(array);
String url = "";
try {
- boolean b = MinioUtil.uploadObject(cmd.getBucketName(), cmd.getObjectName(), input,input.available(), ContentType);
+ boolean b = MinioUtil.uploadObject(cmd.getBucketName(), cmd.getObjectName(), input, input.available(), ContentType);
if (b) {
url = MinioUtil.getBucketObjectUrl(cmd.getBucketName(), cmd.getObjectName());
- // log.debug("上传文件成功!" + url);
+ // log.debug("上传文件成功!" + url);
}
} catch (Exception ex) {
log.error("上传文件异常：" + ex.getMessage());
diff --git a/src/main/java/com/ard/utils/tcp/ClientHandler.java b/src/main/java/com/ard/utils/tcp/ClientHandler.java
index 0063611..7065348 100644
--- a/src/main/java/com/ard/utils/tcp/ClientHandler.java
+++ b/src/main/java/com/ard/utils/tcp/ClientHandler.java
@@ -21,6 +21,8 @@
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
+import static com.ard.utils.other.ByteUtils.toLittleEndian;
+
/**
* @Description: 客户端处理器
* @ClassName: ClientHandler
@@ -187,27 +189,29 @@
byte[] cmdId = Arrays.copyOfRange(data, 1, 2);//命令ID
// log.info("命令ID:" + DatatypeConverter.printHexBinary(cmdId));
byte[] payloadSize = Arrays.copyOfRange(data, 2, 4);//有效负载大小
- payloadSize = ByteUtils.toLittleEndian(payloadSize);
+ payloadSize = toLittleEndian(payloadSize);
//log.info("payloadSize:" + DatatypeConverter.printHexBinary(payloadSize));
int payloadSizeToDecimal = ByteUtils.bytesToDecimal(payloadSize);
// log.info("有效负载大小(转整型):" + payloadSizeToDecimal);
//endregion
List<ArdAlarmRadar> radarAlarmInfos = new ArrayList<>();
+ List<ArdAlarmRadar> radarFollowInfos = new ArrayList<>();
//抽油机状态雷达推送集合
List<ArdAlarmRadar> well = new ArrayList<>();
String alarmTime = "";
Integer targetNum = 0;
+ //雷达移动防火报警
if (Arrays.equals(cmdId, new byte[]{0x01})) {
//region 告警信息反馈
byte[] dwTim = Arrays.copyOfRange(data, 4, 8);
- dwTim = ByteUtils.toLittleEndian(dwTim);
+ dwTim = toLittleEndian(dwTim);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
long l = ByteUtils.bytesToDecimal(dwTim);
alarmTime = sdf.format(l * 1000);
// log.info("周视图像的出现时间(转date):" + alarmTime);
byte[] wTargetNum = Arrays.copyOfRange(data, 8, 10);
- wTargetNum = ByteUtils.toLittleEndian(wTargetNum);
+ wTargetNum = toLittleEndian(wTargetNum);
targetNum = ByteUtils.bytesToDecimal(wTargetNum);
if (targetNum == 0) {
return;
@@ -223,12 +227,12 @@
Integer index = 68 + uintSize * i;
byte[] dwID = Arrays.copyOfRange(data, index, index + 4);
// log.info("目标ID:" + DatatypeConverter.printHexBinary(cmdId));
- dwID = ByteUtils.toLittleEndian(dwID);
+ dwID = toLittleEndian(dwID);
int id = ByteUtils.bytesToDecimal(dwID);
// log.info("目标ID号：" + id);
byte[] iDistance = Arrays.copyOfRange(data, index + 8, index + 12);
- iDistance = ByteUtils.toLittleEndian(iDistance);
+ iDistance = toLittleEndian(iDistance);
double Distance = ByteUtils.bytesToDecimal(iDistance);
log.debug("目标当前直线距离(m):" + Distance);
@@ -279,9 +283,7 @@
//endregion
String alarmType = "";
byte[] cStat = Arrays.copyOfRange(data, index + 23, index + 24);
- cStat = ByteUtils.toLittleEndian(cStat);
- String binaryString = String.format("%8s", Integer.toBinaryString(cStat[0] & 0xFF)).replace(' ', '0');
- // log.info("目标当前状态:" + binaryString);
+ cStat = toLittleEndian(cStat);
// 提取第4位至第6位的值
int extractedValue = (cStat[0] >> 4) & 0b00001111;
// 判断提取的值
@@ -291,16 +293,15 @@
alarmType = "热源检测";
}
// log.info("报警类型:" + alarmType);
-
byte[] szName = Arrays.copyOfRange(data, index + 64, index + 96);
String alarmPointName = ByteUtils.bytesToStringZh(szName);
// log.info("所属告警区域名称:" + alarmPointName);
byte[] afTx = Arrays.copyOfRange(data, index + 96, index + 100);
- afTx = ByteUtils.toLittleEndian(afTx);
+ afTx = toLittleEndian(afTx);
float fTx = ByteUtils.bytesToFloat(afTx);
// log.info("水平角度:" + fTx);
byte[] afTy = Arrays.copyOfRange(data, index + 112, index + 116);
- afTy = ByteUtils.toLittleEndian(afTy);
+ afTy = toLittleEndian(afTy);
float fTy = ByteUtils.bytesToFloat(afTy);
log.debug("垂直角度:" + fTy);
// 将角度转换为弧度
@@ -319,6 +320,12 @@
ardAlarmRadar.setLatitude(alarmXY[1]);
ardAlarmRadar.setAlarmType(alarmType);
radarAlarmInfos.add(ardAlarmRadar);
+ int bit1 = (cStat[0]>>1) & 0x1;;
+ //目标的B1=1 锁定
+ if(bit1==1) {
+ //将锁定目标放入锁定list
+ radarFollowInfos.add(ardAlarmRadar);
+ }
}
//endregion
if (StringUtils.isEmpty(alarmTime)) {
@@ -333,24 +340,30 @@
radarAlarmData.setAlarmTime(alarmTime);
radarAlarmData.setArdAlarmRadars(radarAlarmInfos);
MqttProducer.publish(2, false, "radar", JSON.toJSONString(radarAlarmData));
+ if(radarFollowInfos.size()>0) {
+ radarAlarmData.setArdFollowRadars(radarFollowInfos);
+ MqttProducer.publish(2, false, "radarFollowGuide", JSON.toJSONString(radarAlarmData));
+ }
//抽油机状态MQTT队列
radarAlarmData.setArdAlarmRadars(well);
MqttProducer.publish(2, false, "radarWellData", JSON.toJSONString(radarAlarmData));
+
}
+ //抽油机AI状态反馈
if (Arrays.equals(cmdId, new byte[]{0x04})) {
//region抽油机AI状态反馈
String hexString = DatatypeConverter.printHexBinary(data);
//log.info(hexString);
byte[] dwTim = Arrays.copyOfRange(data, 4, 8);
- dwTim = ByteUtils.toLittleEndian(dwTim);
+ dwTim = toLittleEndian(dwTim);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
long l = ByteUtils.bytesToDecimal(dwTim);
alarmTime = sdf.format(l * 1000);
//log.info("周视图像的出现时间(转date):" + alarmTime);
byte[] wTargetNum = Arrays.copyOfRange(data, 8, 10);
- wTargetNum = ByteUtils.toLittleEndian(wTargetNum);
+ wTargetNum = toLittleEndian(wTargetNum);
targetNum = ByteUtils.bytesToDecimal(wTargetNum);
log.debug("目标总点数(转整型):" + targetNum);
if (targetNum == 0) {
@@ -363,36 +376,36 @@
Integer index = 68 + uintSize * i;
byte[] dwID = Arrays.copyOfRange(data, index, index + 4);
//log.info("目标ID:" + DatatypeConverter.printHexBinary(dwID));
- dwID = ByteUtils.toLittleEndian(dwID);
+ dwID = toLittleEndian(dwID);
int id = ByteUtils.bytesToDecimal(dwID);
//log.info("目标ID号：" + id);
//region 不需要的字段
byte[] iTw = Arrays.copyOfRange(data, index + 4, index + 8);
- iTw = ByteUtils.toLittleEndian(iTw);
+ iTw = toLittleEndian(iTw);
int Tw = ByteUtils.bytesToDecimal(iTw);
// log.info("目标当前的像素宽度:" + Tw);
byte[] iTh = Arrays.copyOfRange(data, index + 8, index + 12);
- iTh = ByteUtils.toLittleEndian(iTh);
+ iTh = toLittleEndian(iTh);
int Th = ByteUtils.bytesToDecimal(iTh);
//log.info("目标当前的像素高度:" + Th);
byte[] fTx = Arrays.copyOfRange(data, index + 12, index + 16);
- fTx = ByteUtils.toLittleEndian(fTx);
+ fTx = toLittleEndian(fTx);
float fTxAngle = ByteUtils.bytesToFloat(fTx);
log.debug("p角度:" + fTxAngle);
byte[] fTy = Arrays.copyOfRange(data, index + 16, index + 20);
- fTy = ByteUtils.toLittleEndian(fTy);
+ fTy = toLittleEndian(fTy);
float fTyAngle = ByteUtils.bytesToFloat(fTy);
log.debug("t角度:" + fTyAngle);
byte[] sAreaNo = Arrays.copyOfRange(data, index + 20, index + 22);
- sAreaNo = ByteUtils.toLittleEndian(sAreaNo);
+ sAreaNo = toLittleEndian(sAreaNo);
int AreaNo = ByteUtils.bytesToDecimal(sAreaNo);
log.debug("目标归属的告警区域号:" + AreaNo);
byte[] cGrp = Arrays.copyOfRange(data, index + 22, index + 23);
- cGrp = ByteUtils.toLittleEndian(cGrp);
+ cGrp = toLittleEndian(cGrp);
int Grp = ByteUtils.bytesToDecimal(cGrp);
//log.info("所属组:" + Grp);
//endregion
@@ -400,7 +413,7 @@
//抽油机状态变量
String wellType;
byte[] cStat = Arrays.copyOfRange(data, index + 23, index + 24);
- cStat = ByteUtils.toLittleEndian(cStat);
+ cStat = toLittleEndian(cStat);
//String binaryString = String.format("%8s", Integer.toBinaryString(cStat[0] & 0xFF)).replace(' ', '0');
//log.info("目标当前状态:" + binaryString);
// 提取第0位值
@@ -450,18 +463,19 @@
radarAlarmData.setArdAlarmRadars(well);
MqttProducer.publish(2, false, "radarWellData", JSON.toJSONString(radarAlarmData));
}
+ //强制引导
if (Arrays.equals(cmdId, new byte[]{0x02})) {
//region 告警前端发送的强制引导信息
byte[] iDistance = Arrays.copyOfRange(data, 4, 8);
- iDistance = ByteUtils.toLittleEndian(iDistance);
+ iDistance = toLittleEndian(iDistance);
long distance = ByteUtils.bytesToDecimal(iDistance);
log.info("目标当前距离(m):" + distance);
byte[] fTx = Arrays.copyOfRange(data, 8, 12);
- fTx = ByteUtils.toLittleEndian(fTx);
+ fTx = toLittleEndian(fTx);
float tx = ByteUtils.bytesToFloat(fTx);
log.debug("方位:" + tx);
byte[] fTy = Arrays.copyOfRange(data, 12, 16);
- fTy = ByteUtils.toLittleEndian(fTy);
+ fTy = toLittleEndian(fTy);
float ty = ByteUtils.bytesToFloat(fTy);
if (ty < 0) {
ty += 360;
--
Gitblit v1.9.3