增加门禁主机报警事件解析上传mqtt

‘liusuyi’

2023-07-10 2607eb0f1105f753d48d8eafe7799b6efb2c66ba

 src/main/java/com/ard/utils/hiksdk/service/impl/HikClientUtil.java

@@ -3,6 +3,7 @@
import com.ard.alarm.camera.domain.ArdCameras;
import com.ard.alarm.camera.domain.CameraCmd;
import com.ard.alarm.external.domain.ArdEquipExternal;
import com.ard.config.MinioClientSingleton;
import com.ard.utils.ByteUtils;
import com.ard.utils.hiksdk.common.GlobalVariable;
import com.ard.utils.hiksdk.domain.DeviceInfo;
@@ -19,7 +20,6 @@
import java.io.*;
import java.nio.ByteBuffer;
import java.util.*;



/**
@@ -173,6 +173,7 @@
            log.info("登录异常：" + errorCode);
        }
    }

    /**
     * @描述 登录所有相机
     * @参数 []
@@ -199,6 +200,7 @@
            log.error("初始化登录相机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 登录所有报警主机
     * @参数 []
@@ -225,7 +227,32 @@
            log.error("初始化报警主机异常：" + ex.getMessage());
        }
    }

    /**
     * @描述 登录所有门禁主机
     * @参数 []
     * @返回值 void
     * @创建人 刘苏义
     * @创建时间 2023/2/3 10:10
     * @修改人和其它信息
     */
    public static void loginAllAccessControlHost(List<ArdEquipExternal> ardEquipExternals) {
        try {
            for (ArdEquipExternal accessControlHost : ardEquipExternals) {
                Thread.sleep(100);
                DeviceInfo info = new DeviceInfo();
                info.setDeviceId(accessControlHost.getId());
                info.setIp(accessControlHost.getIp());
                info.setPort(accessControlHost.getPort());
                info.setUsername(accessControlHost.getUsername());
                info.setPassword(accessControlHost.getPassword());
                login(info);
                String ip = accessControlHost.getIp();
                GlobalVariable.alarmHostMap.put(ip, accessControlHost);
            }
        } catch (Exception ex) {
            log.error("初始化报警主机异常：" + ex.getMessage());
        }
    }
    /**
     * @描述 注销登录
     * @参数 [dvrLogin]
@@ -269,7 +296,7 @@
     * @param lUserID      唯一标识符
     * @param lAlarmHandle 报警处理器
     */
    public static int setupAlarmChan(int lUserID, int lAlarmHandle) {
    public static int setupAlarmChan(String deviceIpPort, int lUserID, int lAlarmHandle) {
        // 根据设备注册生成的lUserID建立布防的上传通道，即数据的上传通道
        if (lUserID == -1) {
            log.info("请先注册");
@@ -296,12 +323,12 @@
            // 布防成功，返回布防成功的数据传输通道号
            lAlarmHandle = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID, m_strAlarmInfo);
            if (lAlarmHandle == -1) {
                log.error("设备布防失败，错误码==========》" + hCNetSDK.NET_DVR_GetLastError());
                log.error("设备【" + deviceIpPort + "】布防失败，错误码==========》" + hCNetSDK.NET_DVR_GetLastError());
                // 注销 释放sdk资源
                logout(lUserID);
                return lAlarmHandle;
            } else {
                log.info("设备布防成功");
                log.info("设备【" + deviceIpPort + "】布防成功");
                return lAlarmHandle;
            }
        }
@@ -361,13 +388,14 @@
            InputStream input = new ByteArrayInputStream(array);
            String url = "";
            try {
                boolean b = MinioUtils.uploadObject(cmd.getBucketName(), cmd.getObjectName(), input, input.available(), ContentType);
                boolean b = MinioUtils.uploadObject(cmd.getBucketName(), cmd.getObjectName(), input, ContentType);
                if (b) {
                    url = MinioUtils.getBucketObjectUrl(cmd.getBucketName(), cmd.getObjectName());
                    url = url.indexOf('?') != -1 ? url.substring(0, url.indexOf('?')) : url;
                    // url = MinioUtils.getBucketObjectUrl(cmd.getBucketName(), cmd.getObjectName());
                    // url = url.indexOf('?') != -1 ? url.substring(0, url.indexOf('?')) : url;
                    url = MinioClientSingleton.domainUrl + "/" + cmd.getBucketName() + "/" + cmd.getObjectName();
                    log.debug("上传文件成功!" + url);
                }
            } catch (IOException ex) {
            } catch (Exception ex) {
                log.error("上传文件异常：" + ex.getMessage());
            }
            return url;
@@ -411,6 +439,5 @@
        }
        return name;
    }


}