~zhangnaisong/ruoyi-api-alarm.git

			@@ -3,23 +3,28 @@
			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.impl.ArdCamerasServiceImpl;
			import com.ard.config.MinioClientSingleton;
			import com.ard.alarm.camera.service.IArdCamerasService;
			import com.ard.alarm.external.domain.ArdEquipExternal;
			import com.ard.alarm.external.service.IArdEquipExternalService;
			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.alarmEventInfo;
			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.DateUtils;
			import com.ard.utils.SpringTool;
			import com.ard.utils.mqtt.MqttConsumer;
			import com.ard.utils.other.DateUtils;
			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;

			import java.io.ByteArrayInputStream;
			import java.io.InputStream;
			import java.io.*;
			import java.nio.ByteBuffer;
			import java.text.SimpleDateFormat;
			import java.util.Date;
			import java.util.List;

			/**
			* @ClassName: FMSGCallBack
			@@ -28,7 +33,7 @@
			* @Date: 2023年02月15日 12:16
			* @Version: 1.0
			**/
			@Slf4j(topic = "hiksdk")
			@Slf4j(topic = "hikSdk")
			public class FMSGCallBack implements HCNetSDK.FMSGCallBack_V31 {

			/**
			@@ -42,175 +47,441 @@
			*/
			@Override
			public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
			ArdCamerasServiceImpl ardCamerasService = SpringTool.getApplicationContext().getBean(ArdCamerasServiceImpl.class);

			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;//事件图片
			alarmEventInfo info;//事件信息
			String url = "";//事件图片
			//lCommand是传的报警类型
			switch (lCommand) {
			case HCNetSDK.COMM_ALARM_RULE:
			//region 行为分析信息
			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);//通道
			ArdCameras ardCameras = new ArdCameras();
			ardCameras.setIp(ipaddr);
			ArdCameras ardcamere = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
			info = new alarmEventInfo();
			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;
			default:
			log.info("未知报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			break;
			//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);
			if (ardCamerasList.size() > 0) {
			ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);
			switch (lCommand) {
			case HCNetSDK.COMM_ALARM_V30:
			//log.debug("移动侦测");
			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();
			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;
			}
			case HCNetSDK.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
			Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道
			info = new CameraEventInfo();
			info.setAlarmName("人员行为分析");
			info.setAlarmTime(sTime);
			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
			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报告报警上报");
			//region 报警主机报警处理
			ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
			ardEquipExternal.setIp(sDeviceIP);
			ardEquipExternal.setPort(wLinkPort);
			IArdEquipExternalService ardEquipExternalService = SpringUtils.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 = 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;
			}
			String alarmType = "";
			switch (dwMinor) {
			case 104:
			alarmType = "真人检测失败";
			break;
			case 80:
			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) {
			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) {
			url = MinioUtil.getBucketObjectUrl(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.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, inputStream.available(), "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(alarmEventInfo info) {
			private String savePicture(CameraEventInfo info) {
			CameraCmd cmd = new CameraCmd();
			ArdCameras Cameras = GlobalVariable.cameraMap.get(info.getCameraIp());
			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;
			}

			/**
			* 打印日志
			* 打印通用光电日志
			*/
			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() +
			"【IP】" + info.getCameraIp() + "【通道】" + info.getCameraChannel() + "【型号】" + info.getCameraType() +
			"【图片】" + info.getPicUrl() + "【坐标】" + info.getLongitude() + "," + info.getLatitude());
			}

			/**
			* 推送mqtt
			* 打印报警主机事件日志
			*/
			private void publishMqtt(alarmEventInfo info) {
			// printLog(info);
			MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info));
			private void printLog(ExternalAlarmEventInfo info) {
			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(CameraEventInfo info) {
			printLog(info);
			MqttProducer.publish(2, false, "camera", JSON.toJSONString(info));
			}

			/**
			* 报警主机事件推送mqtt
			*/
			private void publishMqtt(ExternalAlarmEventInfo info) {
			printLog(info);
			MqttProducer.publish(2, false, "external", JSON.toJSONString(info));
			}

			/**
			* 门禁事件推送mqtt
			*/
			private void publishMqtt(AccessControlHostEventInfo info) {
			printLog(info);
			MqttProducer.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;
			}
			}