~zhangnaisong/ruoyi-api-alarm.git

			@@ -32,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 {

			/**
			@@ -46,22 +46,57 @@
			*/
			@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);//设备IP地址
			Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口
			CameraEventInfo info;
			String sTime;//事件时间
			String url = "";//事件图片
			//lCommand是传的报警类型
			//log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand));
			switch (lCommand) {
			case HCNetSDK.COMM_ALARM_RULE:
			//region 行为分析信息
			case HCNetSDK.COMM_ALARM_V30:
			//log.debug("移动侦测");
			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));
			ArdCameras camera = ardCamerasService.selectArdCamerasList(ardCameras).get(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();
			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 行为分析信息
			ardCameras = new ArdCameras();
			ardCameras.setIp(sDeviceIP);
			ardCameras.setPort(wLinkPort);
			ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class);
			ArdCameras ardCamera = ardCamerasService.selectArdCamerasList(ardCameras).get(0);

			HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
			strVcaAlarm.write();
			Pointer pVCAInfo = strVcaAlarm.getPointer();
			@@ -71,82 +106,85 @@
			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 = new CameraEventInfo();
			info.setAlarmName("人员行为分析");
			info.setAlarmTime(sTime);
			info.setCameraName(ardcamere.getName());
			info.setCameraId(ardcamere.getId());
			info.setCameraName(ardCamera.getName());
			info.setCameraId(ardCamera.getId());
			info.setCameraIp(ipaddr);
			info.setCameraType(ardcamere.getGdtype());
			info.setCameraPort(ardCamera.getPort());
			info.setCameraType(ardCamera.getGdtype());
			info.setCameraChannel(channel);
			info.setLongitude(ardcamere.getLongitude());
			info.setLatitude(ardcamere.getLatitude());
			info.setAlarmType(ardcamere.getGdtype());
			info.setLongitude(ardCamera.getLongitude());
			info.setLatitude(ardCamera.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 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;
			// 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);
			printLog(info);
			// log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
			break;
			}
			//endregion
			//图片存入minio
			url = savePicture(info);
			info.setPicUrl(url);
			publishMqtt(info);
			break;
			case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
			log.debug("人脸检测事件上报");
			break;
			case HCNetSDK.COMM_GISINFO_UPLOAD:
			log.debug("GPS报警信息上报");
			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 报告报警上传");
			//log.debug("报警主机CID报告报警上报");
			//region 报警主机报警处理
			ArdEquipExternal ardEquipExternal = new ArdEquipExternal();
			ardEquipExternal.setIp(sDeviceIP);
			@@ -245,8 +283,10 @@
			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;
			@@ -347,54 +387,24 @@
			//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());
			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");
			@@ -409,7 +419,7 @@
			* 打印通用光电日志
			*/
			private void printLog(CameraEventInfo info) {
			log.info("【规则】" + info.getAlarmName() + "【规则id】" + info.getRuleId() + "【类型】" + info.getAlarmType() +
			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());
			@@ -428,9 +438,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());
			}

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