~zhangnaisong/ruoyi-api-alarm.git

			@@ -46,26 +46,56 @@
			*/
			@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 = "";//事件图片
			Boolean isSnapPic=true;
			//lCommand是传的报警类型
			log.debug("报警事件类型:lCommand:" + Integer.toHexString(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 行为分析信息
			//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);
			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();
			@@ -79,82 +109,82 @@
			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);
			isSnapPic=false;
			// log.debug("未知行为事件类型:" + strVcaAlarm.struRuleInfo.wEventTypeEx);
			break;
			}
			//endregion
			//图片存入minio
			if(isSnapPic) {
			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);
			@@ -256,7 +286,7 @@

			if (dwMajor != 5) {
			//只获取事件
			log.debug("非事件报警数据上报(暂不解析)");
			// log.debug("非事件报警数据上报(暂不解析)");
			break;
			}
			int dwMinor = strACSInfo.dwMinor;
			@@ -357,56 +387,22 @@
			//endregion
			break;
			default:
			log.debug("未知报警事件类型: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());
			if(Cameras==null)
			{
			String key=info.getCameraIp()+":"+info.getCameraPort();
			ArdCameras Cameras = GlobalVariable.cameraMap.get(key);
			if (Cameras == null) {
			return "";
			}
			cmd.setCameraId(Cameras.getId());
			@@ -442,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());
			}

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