From 893c1ef4c42b9e158d95c22172d332d328efd829 Mon Sep 17 00:00:00 2001 From: ‘liusuyi’ <1951119284@qq.com> Date: 星期二, 19 九月 2023 10:10:13 +0800 Subject: [PATCH] 增加三场数字化推送mqtt --- src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java | 11 +++++------ 1 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java index d0cae9d..9ee1b35 100644 --- a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java +++ b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java @@ -6,7 +6,7 @@ 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.MinioUtils; +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.AccessControlHostEventInfo; @@ -290,7 +290,7 @@ // log.debug("闈炰簨浠舵姤璀︽暟鎹笂鎶�(鏆備笉瑙f瀽)"); break; } - log.debug("闂ㄧ涓绘満鎶ヨ涓婁紶"); + int dwMinor = strACSInfo.dwMinor; if (dwMinor != 80 && dwMinor != 104) { //鍙В鏋愮湡浜烘娴嬪け璐ュ拰浜鸿劯鎶撴媿澶辫触鐨勬绫诲瀷浜嬩欢 @@ -305,7 +305,7 @@ alarmType = "浜鸿劯鎶撴媿澶辫触"; break; } - log.debug("銆愪富绫诲瀷銆戜簨浠�"+alarmType); + log.debug("闂ㄧ涓绘満鎶ヨ涓婁紶:"+alarmType); String alarmTime = DateUtils.convertDate(parseAlarmTime(strACSInfo.struTime), "yyyy-M-d H:m:s"); //浜嬩欢鍥剧墖澶勭悊 @@ -321,10 +321,9 @@ InputStream input = new ByteArrayInputStream(bytes); String bucketName = "pic"; String objectName = "alarm/" + IdUtils.simpleUUID() + ".jpeg"; - MinioUtils minioUtil = SpringUtils.getBean(MinioUtils.class); - boolean uploadObject = minioUtil.uploadObject(bucketName, objectName, input,input.available(), "image/JPEG"); + boolean uploadObject = MinioUtil.uploadObject(bucketName, objectName, input,input.available(), "image/JPEG"); if (uploadObject) { - url = minioUtil.getBucketObjectUrl(bucketName, objectName); + url = MinioUtil.getBucketObjectUrl(bucketName, objectName); //log.debug("涓婁紶鏂囦欢鎴愬姛!" + url); } } catch (Exception e) { -- Gitblit v1.9.3