package com.ard.utils.hiksdk.service.impl;
|
|
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.external.domain.ArdEquipExternal;
|
import com.ard.alarm.external.service.IArdEquipExternalService;
|
import com.ard.config.MinioClientSingleton;
|
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.hiksdk.util.minio.MinioUtils;
|
import com.ard.utils.other.DateUtils;
|
import com.ard.utils.other.SpringTool;
|
import com.ard.utils.mqtt.MqttConsumer;
|
import com.sun.jna.Pointer;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.io.*;
|
import java.nio.ByteBuffer;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
/**
|
* @ClassName: FMSGCallBack
|
* @Description:
|
* @Author: Administrator
|
* @Date: 2023年02月15日 12:16
|
* @Version: 1.0
|
**/
|
@Slf4j(topic = "hiksdk")
|
public class FMSGCallBack implements HCNetSDK.FMSGCallBack_V31 {
|
|
/**
|
* 报警信息回调函数
|
*
|
* @param lCommand 上传消息类型
|
* @param pAlarmer 报警设备信息
|
* @param pAlarmInfo 报警信息
|
* @param dwBufLen 报警信息缓存大小
|
* @param pUser 用户数据
|
*/
|
@Override
|
public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
|
|
String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);
|
Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);
|
|
String sTime;//事件时间
|
String url = "";//事件图片
|
//lCommand是传的报警类型
|
switch (lCommand) {
|
case HCNetSDK.COMM_ALARM_RULE:
|
//region 行为分析信息
|
ArdCameras ardCameras = new ArdCameras();
|
ardCameras.setIp(sDeviceIP);
|
ardCameras.setPort(wLinkPort);
|
IArdCamerasService ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class);
|
ArdCameras ardcamere = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
|
log.info("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
|
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);//通道
|
CameraEventInfo info = new CameraEventInfo();
|
info.setAlarmName("人员行为分析");
|
info.setAlarmTime(sTime);
|
info.setCameraName(ardcamere.getName());
|
info.setCameraId(ardcamere.getId());
|
info.setCameraIp(ipaddr);
|
info.setCameraType(ardcamere.getGdtype());
|
info.setCameraChannel(channel);
|
info.setLongitude(ardcamere.getLongitude());
|
info.setLatitude(ardcamere.getLatitude());
|
info.setAlarmType(ardcamere.getGdtype());
|
info.setRuleId(ruleID);
|
switch (strVcaAlarm.struRuleInfo.wEventTypeEx) {
|
case 1: //region穿越警戒面 (越界侦测)
|
info.setAlarmType("越界侦测报警");
|
strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_TRAVERSE_PLANE.class);
|
//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 4: //region 周界入侵
|
info.setAlarmType("周界入侵报警");
|
strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class);
|
//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;
|
default:
|
log.info("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
|
printLog(info);
|
break;
|
}
|
//endregion
|
//图片存入minio
|
url = savePicture(info);
|
info.setPicUrl(url);
|
publishMqtt(info);
|
break;
|
case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
|
log.info("人脸检测事件上报");
|
break;
|
case HCNetSDK.COMM_GISINFO_UPLOAD:
|
log.info("GPS报警信息上报");
|
break;
|
case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
|
log.info("报警主机 CID 报告报警上传");
|
//region 报警主机报警处理
|
ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
|
ardEquipExternal.setIp(sDeviceIP);
|
ardEquipExternal.setPort(wLinkPort);
|
IArdEquipExternalService ardEquipExternalService = SpringTool.getApplicationContext().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 = SpringTool.getApplicationContext().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) {
|
//只获取事件
|
break;
|
}
|
int dwMinor = strACSInfo.dwMinor;
|
if (dwMinor != 80 && dwMinor != 104) {
|
//只解析真人检测失败和人脸抓拍失败的次类型事件
|
break;
|
}
|
// log.info("门禁主机报警上传");
|
// log.info("【主类型】事件");
|
String alarmType = "";
|
switch (dwMinor) {
|
case 104:
|
alarmType = "真人检测失败";
|
break;
|
case 80:
|
alarmType = "人脸抓拍失败";
|
break;
|
}
|
String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");
|
|
//事件图片处理
|
int dwPicDataLen = strACSInfo.dwPicDataLen;
|
if (dwPicDataLen > 0) {
|
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
String newName = sf.format(new Date());
|
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_" + newName + ".jpeg";
|
boolean uploadObject = MinioUtils.uploadObject(bucketName, objectName, input, "image/JPEG");
|
if (uploadObject) {
|
url = MinioClientSingleton.domainUrl + "/" + 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.info("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
|
break;
|
|
}
|
return true;
|
}
|
|
/**
|
* @描述 保存图片封装方法
|
* @参数 [strVcaAlarm, eventName, eventNameEng]
|
* @返回值 java.lang.String
|
* @创建人 刘苏义
|
* @创建时间 2023/2/17 15:05
|
* @修改人和其它信息
|
*/
|
private String savePicture(HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm, String eventName, String eventNameEng) {
|
String url = "";
|
if ((strVcaAlarm.dwPicDataLen > 0) && (strVcaAlarm.byPicTransType == 0)) {
|
String currentTime = new SimpleDateFormat("yyyyMMdd").format(new Date());
|
try {
|
//存入minio
|
long offset = 0;
|
ByteBuffer buffers = strVcaAlarm.pImage.getByteBuffer(offset, strVcaAlarm.dwPicDataLen);
|
byte[] bytes = new byte[strVcaAlarm.dwPicDataLen];
|
buffers.rewind();
|
buffers.get(bytes);
|
InputStream inputStream = new ByteArrayInputStream(bytes);
|
String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
|
String UUID = java.util.UUID.randomUUID().toString().replace("-", "");
|
String filename = ipaddr + "/" + currentTime + "/" + eventNameEng + "/" + UUID + ".jpg";
|
boolean uploadRes = MinioUtils.uploadObject("pic", filename, inputStream, "image/jpeg");
|
if (uploadRes) {
|
url = MinioClientSingleton.domainUrl + filename;
|
log.info("写入minio图片地址：" + url);
|
}
|
} catch (Exception ex) {
|
log.error(eventName + "处理图片异常：" + ex.getMessage());
|
}
|
}
|
return url;
|
}
|
|
/**
|
* 相机截图
|
*/
|
private String savePicture(CameraEventInfo info) {
|
CameraCmd cmd = new CameraCmd();
|
ArdCameras Cameras = GlobalVariable.cameraMap.get(info.getCameraIp());
|
cmd.setCameraId(Cameras.getId());
|
cmd.setChannelNum(info.getCameraChannel());
|
cmd.setBucketName("pic");
|
String UUID = java.util.UUID.randomUUID().toString().replace("-", "");
|
String filename = info.getCameraName() + "/" + info.getAlarmType() + "/" + UUID + ".jpg";
|
cmd.setObjectName(filename);
|
String url = HikClientUtil.picCutCate(cmd);
|
return url;
|
}
|
|
/**
|
* 打印通用光电日志
|
*/
|
private void printLog(CameraEventInfo info) {
|
log.info("【规则】" + info.getAlarmName() + "【规则id】" + info.getRuleId() + "【类型】" + info.getAlarmType() +
|
"【时间】" + info.getAlarmTime() + "【相机id】" + info.getCameraId() + "【相机】" + info.getCameraName() +
|
"【IP】" + info.getCameraIp() + "【通道】" + info.getCameraChannel() + "【型号】" + info.getCameraType() +
|
"【图片】" + info.getPicUrl() + "【坐标】" + info.getLongitude() + "," + info.getLatitude());
|
}
|
|
/**
|
* 打印报警主机事件日志
|
*/
|
private void printLog(ExternalAlarmEventInfo info) {
|
log.info("【报警ID】" + info.getAlarmId() + "【报警名称】" + info.getAlarmName() +
|
"【防区ID】" + info.getDefenseId() + "【防区名称】" + info.getDefenseName() + "【类型】" + info.getAlarmType() +
|
"【时间】" + info.getAlarmTime() + "【报警主机ID】" + info.getAlarmHostId());
|
}
|
|
/**
|
* 打印门禁事件日志
|
*/
|
private void printLog(AccessControlHostEventInfo info) {
|
log.info("【报警ID】" + info.getSerialNo() + "【设备编号】"+
|
"【门编号】" + info.getDoorNo() + "【事件类型】" + info.getAlarmType() +
|
"【防区类型】" + info.getDefenseType()+"【时间】" + info.getAlarmTime() +
|
"【门禁主机ID】" + info.getAcsId());
|
}
|
|
/**
|
* 通用光电报警推送mqtt
|
*/
|
private void publishMqtt(CameraEventInfo info) {
|
// printLog(info);
|
MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info));
|
}
|
|
/**
|
* 报警主机事件推送mqtt
|
*/
|
private void publishMqtt(ExternalAlarmEventInfo info) {
|
printLog(info);
|
MqttConsumer.publish(2, false, "external", JSON.toJSONString(info));
|
}
|
|
/**
|
* 门禁事件推送mqtt
|
*/
|
private void publishMqtt(AccessControlHostEventInfo info) {
|
printLog(info);
|
MqttConsumer.publish(2, false, "accessControl", JSON.toJSONString(info));
|
}
|
|
/**
|
* 时间格式化
|
*/
|
private String parseAlarmTime(HCNetSDK.NET_DVR_TIME_EX netDvrTimeEx) {
|
short wYear = netDvrTimeEx.wYear;
|
byte byMonth = netDvrTimeEx.byMonth;
|
byte byDay = netDvrTimeEx.byDay;
|
byte byHour = netDvrTimeEx.byHour;
|
byte byMinute = netDvrTimeEx.byMinute;
|
byte bySecond = netDvrTimeEx.bySecond;
|
return wYear + "-" + byMonth + "-" + byDay + " " + byHour + ":" + byMinute + ":" + bySecond;
|
}
|
|
/**
|
* 时间格式化
|
*/
|
private String parseAlarmTime(HCNetSDK.NET_DVR_TIME netDvrTimeEx) {
|
int wYear = netDvrTimeEx.dwYear;
|
int byMonth = netDvrTimeEx.dwMonth;
|
int byDay = netDvrTimeEx.dwDay;
|
int byHour = netDvrTimeEx.dwHour;
|
int byMinute = netDvrTimeEx.dwMinute;
|
int bySecond = netDvrTimeEx.dwSecond;
|
return wYear + "-" + byMonth + "-" + byDay + " " + byHour + ":" + byMinute + ":" + bySecond;
|
}
|
}
|
