~zhangnaisong/ruoyi-api-alarm.git

			@@ -4,27 +4,23 @@
			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.alarm.external.service.impl.ArdEquipExternalServiceImpl;
			import com.ard.config.MinioClientSingleton;
			import com.ard.utils.ByteUtils;
			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.domain.alarmEventInfo;
			import com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK;
			import com.ard.utils.hiksdk.util.minio.MinioUtils;
			import com.ard.utils.DateUtils;
			import com.ard.utils.SpringTool;
			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 org.apache.commons.lang3.StringUtils;

			import javax.xml.bind.DatatypeConverter;
			import java.io.ByteArrayInputStream;
			import java.io.InputStream;
			import java.io.*;
			import java.nio.ByteBuffer;
			import java.text.SimpleDateFormat;
			import java.util.Date;
			@@ -36,7 +32,7 @@
			* @Date: 2023年02月15日 12:16
			* @Version: 1.0
			**/
			@Slf4j(topic = "hiksdk")
			@Slf4j(topic = "hikSdk")
			public class FMSGCallBack implements HCNetSDK.FMSGCallBack_V31 {

			/**
			@@ -53,21 +49,24 @@

			String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);
			Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);

			CameraEventInfo info;
			String sTime;//事件时间
			String url;//事件图片
			alarmEventInfo info;//事件信息

			String url = "";//事件图片
			Boolean isSnapPic=true;
			//lCommand是传的报警类型
			log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			switch (lCommand) {
			case HCNetSDK.COMM_ALARM_V30:
			log.debug("移动侦测、视频丢失、遮挡、IO信号量等报警信息(暂不解析)");
			case HCNetSDK.COMM_ALARM_RULE:
			log.debug("行为分析信息报警信息上报");
			//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();
			@@ -77,7 +76,7 @@
			sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间
			String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip
			Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
			info = new alarmEventInfo();
			info = new CameraEventInfo();
			info.setAlarmName("人员行为分析");
			info.setAlarmTime(sTime);
			info.setCameraName(ardcamere.getName());
			@@ -135,29 +134,33 @@
			//endregion
			break;
			default:
			log.info("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
			printLog(info);
			// log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
			isSnapPic=false;
			break;
			}
			//endregion
			//图片存入minio
			url = savePicture(info);
			info.setPicUrl(url);
			publishMqtt(info);
			if(isSnapPic) {
			url = savePicture(info);
			info.setPicUrl(url);
			publishMqtt(info);
			}

			break;
			case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
			log.info("人脸检测事件上报");
			log.debug("人脸检测事件上报(暂不解析)");
			break;
			case HCNetSDK.COMM_GISINFO_UPLOAD:
			log.info("GPS报警信息上报");
			log.debug("GPS报警信息上报(暂不解析)");
			break;
			case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
			log.info("报警主机 CID 报告报警上传");
			log.debug("报警主机CID报告报警上报");
			//region 报警主机报警处理
			ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
			ardEquipExternal.setIp(sDeviceIP);
			ardEquipExternal.setPort(wLinkPort);
			IArdEquipExternalService ardEquipExternalService = SpringTool.getApplicationContext().getBean(IArdEquipExternalService.class);
			ardEquipExternal = ardEquipExternalService.selectArdEquipExternalList(ardEquipExternal).get(0);
			ardEquipExternal = ardEquipExternalService.selectArdEquipExternal(ardEquipExternal);


			HCNetSDK.NET_DVR_CID_ALARM netDvrCidAlarm = new HCNetSDK.NET_DVR_CID_ALARM();
			@@ -234,9 +237,127 @@
			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) {
			//只获取事件
			log.debug("非事件报警数据上报(暂不解析)");
			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));
			log.debug("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			break;

			}
			@@ -266,7 +387,7 @@
			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, inputStream.available(), "image/jpeg");
			boolean uploadRes = MinioUtils.uploadObject("pic", filename, inputStream, "image/jpeg");
			if (uploadRes) {
			url = MinioClientSingleton.domainUrl + filename;
			log.info("写入minio图片地址：" + url);
			@@ -279,11 +400,15 @@
			}

			/**
			* 打保存图片
			* 相机截图
			*/
			private String savePicture(alarmEventInfo info) {
			private String savePicture(CameraEventInfo info) {
			CameraCmd cmd = new CameraCmd();
			ArdCameras Cameras = GlobalVariable.cameraMap.get(info.getCameraIp());
			if(Cameras==null)
			{
			return "";
			}
			cmd.setCameraId(Cameras.getId());
			cmd.setChannelNum(info.getCameraChannel());
			cmd.setBucketName("pic");
			@@ -297,36 +422,54 @@
			/**
			* 打印通用光电日志
			*/
			private void printLog(alarmEventInfo info) {
			log.info("【规则】" + info.getAlarmName() + "【规则id】" + info.getRuleId() + "【类型】" + info.getAlarmType() +
			private void printLog(CameraEventInfo info) {
			log.debug("【规则】" + 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() +
			log.debug("【报警ID】" + info.getAlarmId() + "【报警名称】" + info.getAlarmName() +
			"【防区ID】" + info.getDefenseId() + "【防区名称】" + info.getDefenseName() + "【类型】" + info.getAlarmType() +
			"【时间】" + info.getAlarmTime() + "【报警主机ID】" + info.getAlarmHostId());
			}

			/**
			* 打印门禁事件日志
			*/
			private void printLog(AccessControlHostEventInfo info) {
			log.debug("【报警ID】" + info.getSerialNo() + "【设备编号】"+
			"【门编号】" + info.getDoorNo() + "【事件类型】" + info.getAlarmType() +
			"【防区类型】" + info.getDefenseType()+"【时间】" + info.getAlarmTime() +
			"【门禁主机ID】" + info.getAcsId());
			}

			/**
			* 通用光电报警推送mqtt
			*/
			private void publishMqtt(alarmEventInfo info) {
			private void publishMqtt(CameraEventInfo info) {
			// printLog(info);
			MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info));
			}

			/**
			* 外联报警推送mqtt
			* 报警主机事件推送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));
			}

			/**
			@@ -341,4 +484,17 @@
			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;
			}
			}