分支自 ard/ruoyi-api-alarm
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
@@ -6,17 +6,17 @@ 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.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.spring.SpringUtils; import com.ard.utils.uuid.IdUtils; import com.sun.jna.Pointer; import lombok.extern.slf4j.Slf4j; @@ -24,6 +24,7 @@ import java.nio.ByteBuffer; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; /** * @ClassName: FMSGCallBack @@ -46,27 +47,56 @@ */ @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); SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP).trim();//设备IP地址 Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口 CameraEventInfo info; String sTime;//事件时间 String url = "";//事件图片 Boolean isSnapPic=true; //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); switch (lCommand) { //region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备) case HCNetSDK.COMM_ALARM_V30: //log.debug("移动侦测、视频丢失、遮挡、IO信号量等报警信息(暂不解析)"+Integer.toHexString(lCommand)); //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; } } //endregion break; case HCNetSDK.COMM_ALARM_RULE: log.debug("行为分析信息报警信息"+Integer.toHexString(lCommand)); //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.debug("行为分析信息报警信息上报"); //region 异常行为识别信息 HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM(); strVcaAlarm.write(); Pointer pVCAInfo = strVcaAlarm.getPointer(); @@ -79,88 +109,91 @@ 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.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx); isSnapPic=false; break; 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; // 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); //图片存入minio url = savePicture(info); info.setPicUrl(url); publishMqtt(info); //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.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx); break; } } //endregion //图片存入minio if(isSnapPic) { url = savePicture(info); info.setPicUrl(url); } publishMqtt(info); break; case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT: log.debug("人脸检测事件上报(暂不解析)"+Integer.toHexString(lCommand)); //log.debug("人脸检测事件上报(暂不解析)"); break; case HCNetSDK.COMM_GISINFO_UPLOAD: log.debug("GPS报警信息上报(暂不解析)"+Integer.toHexString(lCommand)); //log.debug("GPS报警信息上报(暂不解析)"); break; case HCNetSDK.COMM_ALARMHOST_CID_ALARM: log.debug("报警主机 CID 报告报警上传"+Integer.toHexString(lCommand)); log.debug("报警主机CID报告报警上报"); //region 报警主机报警处理 ArdEquipExternal ardEquipExternal = new ArdEquipExternal(); ardEquipExternal.setIp(sDeviceIP); ardEquipExternal.setPort(wLinkPort); IArdEquipExternalService ardEquipExternalService = SpringTool.getApplicationContext().getBean(IArdEquipExternalService.class); IArdEquipExternalService ardEquipExternalService = SpringUtils.getBean(IArdEquipExternalService.class); ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal); HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM(); netDvrCidAlarm.write(); @@ -169,7 +202,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); @@ -239,30 +271,31 @@ //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); 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; } // log.info("门禁主机报警上传"); // log.info("【主类型】事件"); String alarmType = ""; switch (dwMinor) { case 104: @@ -272,13 +305,12 @@ 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) { SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String newName = sf.format(new Date()); try { //将字节写入文件 long offset = 0; @@ -288,10 +320,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; url = MinioUtil.getBucketObjectUrl(bucketName, objectName); //log.debug("上传文件成功!" + url); } } catch (Exception e) { @@ -354,63 +386,28 @@ //endregion break; default: log.info("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand)); log.debug("未知报警事件类型: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()); if(Cameras==null) { String key = info.getCameraIp() + ":" + info.getCameraPort(); ArdCameras Cameras = GlobalVariable.cameraMap.get(key); if (Cameras == null) { return ""; } 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; @@ -439,9 +436,9 @@ * 打印门禁事件日志 */ private void printLog(AccessControlHostEventInfo info) { log.debug("【报警ID】" + info.getSerialNo() + "【设备编号】"+ log.debug("【报警ID】" + info.getSerialNo() + "【设备编号】" + "【门编号】" + info.getDoorNo() + "【事件类型】" + info.getAlarmType() + "【防区类型】" + info.getDefenseType()+"【时间】" + info.getAlarmTime() + "【防区类型】" + info.getDefenseType() + "【时间】" + info.getAlarmTime() + "【门禁主机ID】" + info.getAcsId()); } @@ -449,8 +446,8 @@ * 通用光电报警推送mqtt */ private void publishMqtt(CameraEventInfo info) { // printLog(info); MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info)); printLog(info); MqttProducer.publish(2, false, "camera", JSON.toJSONString(info)); } /** @@ -458,7 +455,7 @@ */ private void publishMqtt(ExternalAlarmEventInfo info) { printLog(info); MqttConsumer.publish(2, false, "external", JSON.toJSONString(info)); MqttProducer.publish(2, false, "external", JSON.toJSONString(info)); } /** @@ -466,7 +463,7 @@ */ private void publishMqtt(AccessControlHostEventInfo info) { printLog(info); MqttConsumer.publish(2, false, "accessControl", JSON.toJSONString(info)); MqttProducer.publish(2, false, "accessControl", JSON.toJSONString(info)); } /**
