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; } }