~zhangnaisong/ruoyi-api-alarm.git

			@@ -1,6 +1,7 @@
			package com.ard.utils.sdk.hiksdk.service.impl;

			import com.alibaba.fastjson2.JSON;
			import com.alibaba.fastjson2.JSONObject;
			import com.ard.alarm.camera.domain.ArdCameras;
			import com.ard.alarm.camera.domain.CameraCmd;
			import com.ard.alarm.camera.service.impl.ArdCamerasServiceImpl;
			@@ -8,6 +9,8 @@
			import com.ard.alarm.external.service.impl.ArdEquipExternalServiceImpl;
			import com.ard.utils.sdk.hiksdk.domain.*;
			import com.ard.utils.minio.MinioUtil;
			import com.ard.utils.sdk.hiksdk.domain.isapi.FaceCapture;
			import com.ard.utils.sdk.hiksdk.domain.isapi.IsapiAlarm;
			import com.ard.utils.util.ByteUtils;
			import com.ard.utils.sdk.hiksdk.common.GlobalVariable;
			import com.ard.utils.sdk.hiksdk.util.hikSdkUtil.HCNetSDK;
			@@ -15,12 +18,14 @@
			import com.ard.utils.mqtt.MqttProducer;
			import com.ard.utils.util.IdUtils;
			import com.sun.jna.Pointer;
			import javafx.scene.Camera;
			import lombok.extern.slf4j.Slf4j;

			import java.io.*;
			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.sdk.hiksdk.util.hikSdkUtil.HCNetSDK.*;
			@@ -48,7 +53,7 @@
			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).trim();//设备IP地址
			Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口
			int wLinkPort = pAlarmer.wLinkPort;//设备通讯端口
			//通过ip和端口查询设备
			Optional<ArdCameras> foundCamera = findArdCameraByIpAndPort(sDeviceIP, wLinkPort);
			Optional<ArdEquipExternal> foundExternal = findArdEquipExternalByIpAndPort(sDeviceIP, wLinkPort);
			@@ -65,19 +70,18 @@
			if (camera == null && ardEquipExternal == null) {
			return false;
			}
			CameraEventInfo info;
			String alarmName = "";//报警名称
			String alarmTime;//事件时间
			String alarmType = "";//报警类型
			String picUrl = "";//事件图片
			String facePicUrl = "";//人脸图片
			String facePicUrl = "";//人脸抓拍图片
			int dwPicDataLen;//图片数据长度
			int chanNo = 0;//通道号
			//lCommand是传的报警类型
			log.debug("【" + sDeviceIP + ":" + wLinkPort + "】报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			switch (lCommand) {
			case COMM_ALARM_V30:
			log.debug("移动侦测报警信息上报");
			if (camera == null) {
			return false;
			}
			log.debug("移动侦测信息上报");
			//region 移动侦测、视频丢失、遮挡、IO信号量等报警信息(V3.0以上版本支持的设备)
			HCNetSDK.NET_DVR_ALARMINFO_V30 netDvrAlarminfoV30 = new HCNetSDK.NET_DVR_ALARMINFO_V30();
			netDvrAlarminfoV30.write();
			@@ -86,28 +90,26 @@
			netDvrAlarminfoV30.read();
			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");
			if (camera != null) {
			for (byte b : netDvrAlarminfoV30.byChannel) {
			if (b == 1) {
			chanNo = b;
			switch (camera.getGdType()) {
			case "0":
			cameraEventHandler(camera, chanNo, "移动侦测", "移动侦测报警", fmt.format(new Date()), picUrl, "");
			break;
			}
			}
			}
			}
			break;
			}
			//endregion
			break;
			case COMM_VCA_ALARM:
			log.debug("智能检测通用信息上报(暂不解析)");
			case COMM_ALARM_RULE:
			log.debug("异常行为识别信息报警信息上报");
			log.debug("异常行为识别信息上报");
			//region 异常行为识别信息
			HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
			strVcaAlarm.write();
			@@ -116,80 +118,100 @@
			strVcaAlarm.read();
			Integer ruleID = Integer.valueOf(strVcaAlarm.struRuleInfo.byRuleID);
			alarmTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
			Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
			info = new CameraEventInfo();
			info.setAlarmName("人员行为分析");
			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);
			chanNo = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
			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");
			alarmType = "越界侦测报警";
			//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 2: //region 目标进入区域
			alarmType = "目标进入区域报警";
			//endregion
			break;
			case 3: //region 目标离开区域
			alarmType = "目标离开区域报警";
			//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
			picUrl = snapPicture(info);
			info.setPicUrl(picUrl);
			publishMqtt(info, "camera");
			alarmType = "周界入侵报警";
			//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;
			case 5: //region 徘徊
			alarmType = "徘徊事件报警";
			//endregion
			break;
			case 8: //region 快速移动(奔跑)
			alarmType = "快速移动报警";
			//endregion
			break;
			case 9: //region 人员聚集报警
			alarmType = "人员聚集报警";
			//endregion
			break;
			case 13: //region 物品遗留事件
			alarmType = "物品遗留事件报警";
			//endregion
			break;
			case 14: //region 物品拿取事件
			alarmType = "物品拿取事件报警";
			//endregion
			break;
			case 15: //region 离岗事件
			strVcaAlarm.struRuleInfo.uEventParam.setType(HCNetSDK.NET_VCA_LEAVE_POSITION.class);
			int byMode = strVcaAlarm.struRuleInfo.uEventParam.struLeavePos.byMode;
			switch (byMode) {
			case 0:
			alarmType = "离岗事件报警";
			break;
			case 1:
			alarmType = "睡岗事件报警";
			break;
			}
			//endregion
			break;
			case 20: //region 倒地检测
			alarmType = "倒地检测事件报警";
			//endregion
			break;
			case 35: //region 人数变化事件报警
			alarmType = "人数变化事件报警";
			//endregion
			break;
			case 41: //region 滞留检测
			alarmType = "滞留检测事件报警";
			//endregion
			break;
			case 44: //region 玩手机
			alarmType = "玩手机事件报警";
			//endregion
			break;
			default:
			log.debug("未知异常行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
			break;
			}
			//图片接收
			int byPicType = strVcaAlarm.byPicType;
			dwPicDataLen = strVcaAlarm.dwPicDataLen;
			int byPicTransType = strVcaAlarm.byPicTransType;
			if (dwPicDataLen > 0 && strVcaAlarm.pImage != null && byPicTransType == 0) {
			picUrl = saveBinPicToMinio(strVcaAlarm.pImage, dwPicDataLen);
			}
			if (camera != null) {
			alarmName = "异常行为识别";
			switch (camera.getGdType()) {
			case "0":
			cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, "");
			break;
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, "");
			break;
			}
			}
			//endregion
			break;
			case COMM_UPLOAD_FACESNAP_RESULT:
			log.debug("人脸抓拍报警信息(暂不解析)");
			log.debug("人脸抓拍报警信息上报");
			//region 人脸抓拍报警信息
			HCNetSDK.NET_VCA_FACESNAP_RESULT struFaceSnap = new HCNetSDK.NET_VCA_FACESNAP_RESULT();
			struFaceSnap.write();
			@@ -198,6 +220,7 @@
			struFaceSnap.read();
			alarmTime = DateUtils.parseTime(struFaceSnap.dwAbsTime);
			String facePicTyp;
			chanNo = struFaceSnap.struDevInfo.byChannel;
			switch (struFaceSnap.byUploadEventDataType) {
			case 0:
			facePicTyp = "二进制数据";
			@@ -210,54 +233,28 @@
			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());
			}
			facePicUrl = saveBinPicToMinio(struFaceSnap.pBuffer1, struFaceSnap.dwFacePicLen);
			}
			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());
			picUrl = saveBinPicToMinio(struFaceSnap.pBuffer2, struFaceSnap.dwBackgroundPicLen);
			}
			//log.debug("【人脸抓拍报警信息】: alarmTime:" + alarmTime + " picUrl:" + picUrl + " facePicType:" + facePicTyp + " facePicUrl:" + facePicUrl);
			if (camera != null) {
			alarmName = "人脸抓拍检测";
			alarmType = "人脸抓拍报警";
			switch (camera.getGdType()) {
			case "0":
			cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, "", "");
			break;
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
			break;
			}
			}
			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("人脸比对报警信息");
			log.debug("人脸比对报警信息上报");
			//region 人脸比对报警信息
			HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM struFaceMatchAlarm = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
			struFaceMatchAlarm.write();
			@@ -265,22 +262,13 @@
			fmaInfo.write(0, pAlarmInfo.getByteArray(0, struFaceMatchAlarm.size()), 0, struFaceMatchAlarm.size());
			struFaceMatchAlarm.read();
			alarmTime = DateUtils.parseTime(struFaceMatchAlarm.struSnapInfo.dwAbsTime);//报警时间

			chanNo = struFaceMatchAlarm.struSnapInfo.struDevInfo.byChannel;
			int byMatchPicNum = struFaceMatchAlarm.byMatchPicNum;//匹配图片数量
			String picTransType = "";
			switch (struFaceMatchAlarm.byPicTransType) {
			case 0:
			picTransType = "二进制图片";
			break;
			case 1:
			picTransType = "URL路径图片";
			break;
			}
			int picTransType = struFaceMatchAlarm.byPicTransType;////图片数据传输方式: 0-二进制；1-url
			String contrastStatus = "";
			switch (struFaceMatchAlarm.byContrastStatus) {
			case 1:
			contrastStatus = "比对成功";

			break;
			case 2:
			contrastStatus = "比对失败";
			@@ -289,104 +277,181 @@
			contrastStatus = "未知";
			break;
			}
			String BlockType = "";
			switch (struFaceMatchAlarm.struBlockListInfo.struBlockListInfo.byType) {
			case 1:
			alarmType = "陌生人报警";
			BlockType = "陌生人报警";
			break;
			case 2:
			alarmType = "人脸比对报警";
			BlockType = "人脸比对报警";
			break;
			default:
			alarmType = "未知";
			BlockType = "未知";
			break;
			}
			if (struFaceMatchAlarm.dwSnapPicLen > 0 && struFaceMatchAlarm.pSnapPicBuffer != null && struFaceMatchAlarm.byPicTransType == 0) {
			//将字节写入文件
			//人脸比对报警图片保存，图片格式URL格式
			if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {

			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());
			}
			picUrl = new String(bytes);
			//log.debug("抓拍图URL：" + picUrl);
			}
			if (struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0 && struFaceMatchAlarm.struBlockListInfo.pBuffer1 != null) {
			//将字节写入文件
			if ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {

			long offset = 0;
			ByteBuffer buffers = struFaceMatchAlarm.struSnapInfo.pBuffer1.getByteBuffer(offset, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
			byte[] bytes = new byte[struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen];
			buffers.rewind();
			buffers.get(bytes);
			facePicUrl = new String(bytes);
			//System.out.println("抓拍人脸子图URL：" + SnapPicUrl);
			}
			if ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 1)) {

			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 faceLibUrl = new String(bytes);
			//System.out.println("人脸库人脸图的URL：" + SnapPicUrl);
			}
			//人脸比对报警图片保存，图片格式二进制
			//if ((struFaceMatchAlarm.dwSnapPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
			// picUrl = saveBinPicToMinio(struFaceMatchAlarm.pSnapPicBuffer, struFaceMatchAlarm.dwSnapPicLen);
			//}
			//if ((struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
			// facePicUrl = saveBinPicToMinio(struFaceMatchAlarm.struSnapInfo.pBuffer1, struFaceMatchAlarm.struSnapInfo.dwSnapFacePicLen);
			//}
			//if ((struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen > 0) && (struFaceMatchAlarm.byPicTransType == 0)) {
			// //String faceBlockPicUrl = saveBinPicToMinio(struFaceMatchAlarm.struBlockListInfo.pBuffer1, struFaceMatchAlarm.struBlockListInfo.dwBlockListPicLen);
			//}
			if (camera != null) {
			alarmName = "人脸比对检测";
			alarmType = BlockType + "[" + contrastStatus + "]";
			switch (camera.getGdType()) {
			case "0":
			cameraEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, "", "");
			break;
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
			break;
			}
			}
			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开放平台接入，上传视频检测数据(暂不解析)");
			log.debug("AI视频检测报警上传");
			//region AI开放平台接入视频检测
			HCNetSDK.NET_AIOP_VIDEO_HEAD struAIOPVideo = new HCNetSDK.NET_AIOP_VIDEO_HEAD();
			struAIOPVideo.write();
			Pointer pAIOPVideo = struAIOPVideo.getPointer();
			pAIOPVideo.write(0, pAlarmInfo.getByteArray(0, struAIOPVideo.size()), 0, struAIOPVideo.size());
			struAIOPVideo.read();
			log.debug("视频任务ID" + new String(struAIOPVideo.szTaskID).trim());
			log.debug("通道号：" + struAIOPVideo.dwChannel);
			String szMPID = new String(struAIOPVideo.szMPID).trim();//检测模型包ID
			log.debug("检测模型包ID" + szMPID);
			alarmTime = String.format("%04d", struAIOPVideo.struTime.wYear) + "-" +
			String.format("%02d", struAIOPVideo.struTime.wMonth) + "-" +
			String.format("%02d", struAIOPVideo.struTime.wDay) + " " +
			String.format("%02d", struAIOPVideo.struTime.wHour) + ":" +
			String.format("%02d", struAIOPVideo.struTime.wMinute) + ":" +
			String.format("%02d", struAIOPVideo.struTime.wSecond);
			// + "." + String.format("%03d", struAIOPVideo.struTime.wMilliSec);
			chanNo = struAIOPVideo.dwChannel;
			switch (szMPID) {
			case "H930_MODEL_SPD":
			alarmType = "抽烟打电话";
			break;
			}
			//图片数据保存
			if (struAIOPVideo.dwPictureSize > 0) {
			picUrl = saveBinPicToMinio(struAIOPVideo.pBufferPicture, struAIOPVideo.dwPictureSize);
			}
			if (camera != null) {
			alarmName = "AI视频检测";
			switch (camera.getGdType()) {
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
			break;
			}
			}
			//endregion
			break;
			case COMM_ISAPI_ALARM:
			log.debug("安全帽检测报警信息");
			//region 安全帽检测报警信息
			case COMM_ISAPI_ALARM://ISAPI协议报警信息
			log.debug("ISAPI协议报警信息上报");
			//region ISAPI协议报警信息
			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;
			int dwAlarmDataLen = struEventISAPI.dwAlarmDataLen;// 报警数据长度
			int byDataType = struEventISAPI.byDataType;// 0-invalid,1-xml,2-json
			int byPicturesNumber = struEventISAPI.byPicturesNumber;// 图片数量
			if (dwAlarmDataLen > 0) {//报警数据打印
			HCNetSDK.BYTE_ARRAY m_strISAPIData = new HCNetSDK.BYTE_ARRAY(struEventISAPI.dwAlarmDataLen);
			m_strISAPIData.write();
			Pointer pPlateInfo = m_strISAPIData.getPointer();
			pPlateInfo.write(0, struEventISAPI.pAlarmData.getByteArray(0, m_strISAPIData.size()), 0, m_strISAPIData.size());
			m_strISAPIData.read();
			String json = new String(m_strISAPIData.byValue).trim();
			// log.debug(new String(m_strISAPIData.byValue).trim() + "\n");
			//解析JSON数据
			if (byDataType == 2) {
			IsapiAlarm isapiAlarm = JSONObject.parseObject(json, IsapiAlarm.class);
			alarmName = "ISAPI协议信息检测";
			switch (isapiAlarm.getEventType()) {
			//case "HFPD":
			//chanNo = isapiAlarm.getChannelID();
			//alarmType = "高频人员事件报警";
			//picUrl = isapiAlarm.getFaceCapture().get(0).getTargetAttrs().getBkgUrl();
			//facePicUrl = isapiAlarm.getFaceCapture().get(0).getFaces().get(0).getURL();
			// break;
			case "safetyHelmetDetection":
			chanNo = isapiAlarm.getChannelID();
			alarmType = "安全帽事件报警";
			alarmTime = fmt.format(isapiAlarm.getDateTime());
			//图片保存
			for (int i = 0; i < struEventISAPI.byPicturesNumber; i++) {
			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(i * struPicData.size(), struPicData.size()), 0, struPicData.size());
			struPicData.read();
			switch (i) {
			case 0:
			picUrl = saveBinPicToMinio(struPicData.pPicData, struPicData.dwPicLen);
			break;
			case 1:
			facePicUrl = saveBinPicToMinio(struPicData.pPicData, struPicData.dwPicLen);
			break;
			}
			}
			if (camera != null) {
			switch (camera.getGdType()) {
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
			break;
			}
			}
			break;
			}

			//处理安全帽检测上传的照片数据
			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报告报警上报");
			log.debug("报警主机CID报告信息上报");
			//region 报警主机报警处理
			HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
			netDvrCidAlarm.write();
			@@ -464,7 +529,7 @@
			//endregion
			break;
			case HCNetSDK.COMM_ALARM_ACS:
			log.debug("门禁主机报警上报");
			log.debug("门禁主机信息上报");
			//region 门禁主机报警处理
			HCNetSDK.NET_DVR_ACS_ALARM_INFO strACSInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
			strACSInfo.write();
			@@ -495,26 +560,9 @@
			alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s");

			//事件图片处理
			int dwPicDataLen = strACSInfo.dwPicDataLen;
			dwPicDataLen = strACSInfo.dwPicDataLen;
			if (dwPicDataLen > 0) {
			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/" + 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("图片保存失败");
			}
			picUrl = saveBinPicToMinio(strACSInfo.pPicData, strACSInfo.dwPicDataLen);
			}
			HCNetSDK.NET_DVR_ACS_EVENT_INFO struAcsEventInfo = strACSInfo.struAcsEventInfo;
			int byType = struAcsEventInfo.byType;
			@@ -571,12 +619,115 @@
			publishMqtt(accessControlHostEventInfo, "accessControl");
			//endregion
			break;
			case COMM_FIREDETECTION_ALARM: //火点检测报警
			log.debug("火点检测信息上报");
			//region 火点检测报警
			HCNetSDK.NET_DVR_FIREDETECTION_ALARM struFireDecAlarm = new HCNetSDK.NET_DVR_FIREDETECTION_ALARM();
			struFireDecAlarm.write();
			Pointer pFireDecAlarm = struFireDecAlarm.getPointer();
			pFireDecAlarm.write(0, pAlarmInfo.getByteArray(0, struFireDecAlarm.size()), 0, struFireDecAlarm.size());
			struFireDecAlarm.read();
			switch (struFireDecAlarm.byAlarmSubType) {
			case 0:
			alarmType = "火点检测报警";
			break;
			case 1:
			alarmType = "烟雾检测报警";
			break;
			case 2:
			alarmType = "烟火报警 ";
			break;
			}
			//String sFireDecAlarmInfo = "绝对时间：" + struFireDecAlarm.dwAbsTime + ",报警子类型：" + struFireDecAlarm.byAlarmSubType + ",火点最高温度 :" +
			// struFireDecAlarm.wFireMaxTemperature + ",火点目标距离：" + struFireDecAlarm.wTargetDistance;
			//System.out.println(sFireDecAlarmInfo);
			//图片保存
			if ((struFireDecAlarm.dwPicDataLen > 0) && (struFireDecAlarm.byPicTransType == 0)) {
			picUrl = saveBinPicToMinio(struFireDecAlarm.pBuffer, struFireDecAlarm.dwPicDataLen);
			}
			chanNo = struFireDecAlarm.dwVisibleChannel;
			alarmTime = DateUtils.parseTime(struFireDecAlarm.dwAbsTime);//报警时间
			if (camera != null) {
			alarmName = "火焰检测信息上报";
			switch (camera.getGdType()) {
			case "3":
			superBrainEventHandler(camera, chanNo, alarmName, alarmType, alarmTime, picUrl, facePicUrl);
			break;
			}
			}
			//endregion
			break;
			case COMM_ITS_PLATE_RESULT://交通抓拍的终端图片上传
			log.debug("交通抓拍的终端图片上报(暂不解析)");
			break;
			default:
			log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			break;

			}
			return true;
			}

			/**
			* 相机事件处理
			* 刘苏义
			* 2023/12/5 12:56:47
			*/
			public void cameraEventHandler(ArdCameras camera, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {
			CameraEventInfo cameraEventInfo = new CameraEventInfo();
			cameraEventInfo.setAlarmName(alarmName);
			cameraEventInfo.setAlarmTime(alarmTime);
			cameraEventInfo.setCameraName(camera.getName());
			cameraEventInfo.setCameraId(camera.getId());
			cameraEventInfo.setCameraIp(camera.getIp());
			cameraEventInfo.setCameraPort(camera.getPort());
			cameraEventInfo.setCameraType(camera.getGdType());
			cameraEventInfo.setCameraChannel(chanNo);
			cameraEventInfo.setLongitude(camera.getLongitude());
			cameraEventInfo.setLatitude(camera.getLatitude());
			cameraEventInfo.setAlarmType(alarmType);
			//图片存入minio
			if (picUrl.equals("")) {
			picUrl = snapPicture(cameraEventInfo);
			}
			cameraEventInfo.setPicUrl(picUrl);
			log.debug("处理通用光电事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + camera.getName() + "【Url】" + picUrl);
			publishMqtt(cameraEventInfo, "camera");
			}

			/**
			* 超脑事件处理
			* 刘苏义
			* 2023/12/5 12:56:47
			*/
			public void superBrainEventHandler(ArdCameras camera, Integer chanNo, String alarmName, String alarmType, String alarmTime, String picUrl, String faceUrl) {

			SuperBrainEventInfo superBrainEventInfo = new SuperBrainEventInfo();
			superBrainEventInfo.setAlarmName(alarmName);
			superBrainEventInfo.setAlarmType(alarmType);
			superBrainEventInfo.setAlarmTime(alarmTime);
			List<ChannelInfo> channelInfoList = GlobalVariable.deviceChanMap.get(camera.getId());//获取超脑的通道集合
			if (channelInfoList.size() > 0) {
			if (chanNo > 0) {
			ChannelInfo channelInfo = channelInfoList.get(chanNo - 1);//根据通道号获取通道信息
			if (channelInfo != null) {
			Optional<ArdCameras> foundCamera = findArdCameraByIpAndPort(channelInfo.getIp(), channelInfo.getPort());
			if (foundCamera.isPresent()) {
			camera = foundCamera.get();
			superBrainEventInfo.setDeviceId(camera.getId());
			superBrainEventInfo.setDeviceName(camera.getName());
			superBrainEventInfo.setLongitude(camera.getLongitude());
			superBrainEventInfo.setLatitude(camera.getLatitude());
			superBrainEventInfo.setAltitude(camera.getAltitude());
			}
			}
			}
			}
			superBrainEventInfo.setChanNo(chanNo);
			superBrainEventInfo.setPicUrl(picUrl);
			superBrainEventInfo.setFaceUrl(faceUrl);
			log.debug("处理超脑事件报警:【Name】" + alarmName + "【Type】" + alarmType + "【Time】" + alarmTime + "【Device】" + camera.getName() + "【Url】" + picUrl + "【faceUrl】" + faceUrl);
			publishMqtt(superBrainEventInfo, "superBrain");
			}

			/**
			@@ -604,7 +755,6 @@
			.filter(camera -> camera.getIp().equals(ip) && camera.getPort() == port)
			.findFirst();
			}


			/**
			* 相机截图
			@@ -689,4 +839,29 @@
			int bySecond = netDvrTimeEx.dwSecond;
			return wYear + "-" + byMonth + "-" + byDay + " " + byHour + ":" + byMinute + ":" + bySecond;
			}

			//二进制图片接收写入minio返回url
			private String saveBinPicToMinio(Pointer picData, int picDataLen) {
			String picUrl = "";
			try {
			//将字节写入文件
			long offset = 0;
			ByteBuffer buffers = picData.getByteBuffer(offset, picDataLen);
			byte[] bytes = new byte[picDataLen];
			buffers.rewind();
			buffers.get(bytes);
			InputStream input = new ByteArrayInputStream(bytes);
			String bucketName = "pic";
			String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg";
			boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input, picDataLen, "image/JPEG");
			if (uploadObject) {
			picUrl = MinioUtil.getBucketObjectUrl(bucketName, objectName);
			//log.debug("上传文件成功!" + picUrl);
			}
			} catch (Exception e) {
			log.error("图片保存失败:" + e.getMessage());
			}
			return picUrl;
			}

			}