分支自 ard/ruoyi-api-alarm
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
@@ -3,20 +3,17 @@ 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.config.MinioClientSingleton; 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.hiksdk.util.minio.MinioUtils; import com.ard.utils.other.DateUtils; import com.ard.utils.other.SpringTool; import com.ard.utils.mqtt.MqttConsumer; import com.ard.utils.mqtt.MqttProducer; import com.ard.utils.uuid.IdUtils; import com.sun.jna.Pointer; import lombok.extern.slf4j.Slf4j; @@ -24,6 +21,9 @@ import java.nio.ByteBuffer; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Optional; import static com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK.*; /** * @ClassName: FMSGCallBack @@ -47,21 +47,38 @@ @Override public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) { SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);//设备IP地址 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)); log.debug("【" + sDeviceIP + ":" + wLinkPort + "】报警事件类型:lCommand:" + Integer.toHexString(lCommand)); switch (lCommand) { case HCNetSDK.COMM_ALARM_V30: //log.debug("移动侦测"); ArdCameras ardCameras = new ArdCameras(); ardCameras.setIp(sDeviceIP); ardCameras.setPort(wLinkPort); IArdCamerasService ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class); ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0); 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(); @@ -76,56 +93,50 @@ info.setCameraId(camera.getId()); info.setCameraIp(camera.getIp()); info.setCameraPort(camera.getPort()); info.setCameraType(camera.getGdtype()); 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); picUrl = snapPicture(info); info.setPicUrl(picUrl); publishMqtt(info, "camera"); break; } case HCNetSDK.COMM_ALARM_RULE: //log.debug("行为分析信息报警信息上报"); //region 行为分析信息 ardCameras = new ArdCameras(); ardCameras.setIp(sDeviceIP); ardCameras.setPort(wLinkPort); ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class); ArdCameras ardCamera = ardCamerasService.selectArdCamerasList(ardCameras).get(0); //endregion break; case 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 alarmTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间 Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道 info = new CameraEventInfo(); info.setAlarmName("人员行为分析"); info.setAlarmTime(sTime); info.setCameraName(ardCamera.getName()); info.setCameraId(ardCamera.getId()); info.setCameraIp(ipaddr); info.setCameraPort(ardCamera.getPort()); info.setCameraType(ardCamera.getGdtype()); 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(ardCamera.getLongitude()); info.setLatitude(ardCamera.getLatitude()); 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); picUrl = snapPicture(info); info.setPicUrl(picUrl); publishMqtt(info, "camera"); //endregion break; // case 2: //region 目标进入区域 @@ -142,9 +153,9 @@ info.setAlarmType("周界入侵报警"); strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_INTRUSION.class); //图片存入minio url = savePicture(info); info.setPicUrl(url); publishMqtt(info); picUrl = snapPicture(info); info.setPicUrl(picUrl); publishMqtt(info, "camera"); //endregion break; // case 5: //region 徘徊 @@ -172,27 +183,211 @@ // //endregion // break; default: // log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx); 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报告报警上报"); 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 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 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 = 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(); @@ -200,7 +395,6 @@ netDvrCidAlarm.read(); //CID事件名 String sCIDCode = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDCode);//CID事件名 //CID事件名 //String sCIDDescribe = ByteUtils.bytesToStringZh(netDvrCidAlarm.sCIDDescribe);//CID事件名 int position = ByteUtils.findIndexOfDoubleZero(netDvrCidAlarm.sCIDDescribe); @@ -266,24 +460,18 @@ 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 = 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) { //只获取事件 // log.debug("非事件报警数据上报(暂不解析)"); @@ -294,9 +482,7 @@ //只解析真人检测失败和人脸抓拍失败的次类型事件 break; } // log.info("门禁主机报警上传"); // log.info("【主类型】事件"); String alarmType = ""; switch (dwMinor) { case 104: alarmType = "真人检测失败"; @@ -305,13 +491,12 @@ alarmType = "人脸抓拍失败"; break; } String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s"); log.debug("门禁主机报警上传:" + alarmType); 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; @@ -321,10 +506,10 @@ 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"); String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg"; boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, input.available(), "image/JPEG"); if (uploadObject) { url = MinioClientSingleton.domainUrl + "/" + bucketName + "/" + objectName; picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName); //log.debug("上传文件成功!" + url); } } catch (Exception e) { @@ -381,26 +566,52 @@ 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: // log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand)); log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand)); break; } 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(); String key = info.getCameraIp() + ":" + info.getCameraPort(); ArdCameras Cameras = GlobalVariable.cameraMap.get(key); if (Cameras == null) { return ""; @@ -408,8 +619,7 @@ 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"; String filename = "alarm" + "/" + IdUtils.simpleUUID() + ".jpg"; cmd.setObjectName(filename); String url = HikClientUtil.picCutCate(cmd); return url; @@ -445,27 +655,13 @@ } /** * 通用光电报警推送mqtt * 发布MQTT消息 * * @param info 消息内容 * @param topic 主题 */ 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 <T> void publishMqtt(T info, String topic) { MqttProducer.publish(2, false, topic, JSON.toJSONString(info)); } /**
