1. 将sdk动态链接库dll集成到项目内,提升部署便捷性； 2. 增加设备断线重连回调方法，打印相关日志； 3. 删除多余依赖，减小jar包体积； ...

‘liusuyi’

2023-10-23 4806b676dbbab4675e5ee43b4018f2cd9d43797f

 ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java

@@ -10,8 +10,11 @@
import com.ruoyi.device.camera.service.IArdCamerasService;

import com.ruoyi.device.channel.domain.ArdChannel;

import com.ruoyi.device.channel.service.IArdChannelService;

import com.ruoyi.device.dhsdk.lib.LibraryLoad;

import com.ruoyi.device.dhsdk.lib.NetSDKLib;

import com.ruoyi.device.hiksdk.common.GlobalVariable;

import com.ruoyi.device.camera.domain.ArdCameras;

import com.ruoyi.device.hiksdk.sdk.ExceptionCallBack;

import com.ruoyi.media.domain.Vtdu;

import com.ruoyi.media.service.IVtduService;

import com.ruoyi.utils.gis.GisUtil;

@@ -37,6 +40,7 @@
import java.util.*;

import java.util.concurrent.PriorityBlockingQueue;



import static com.ruoyi.device.hiksdk.common.GlobalVariable.loginCameraMap;

import static com.ruoyi.device.hiksdk.sdk.HCNetSDK.*;



/**

@@ -57,52 +61,10 @@
    @Resource

    private IVtduService vtduService;



    private static HCNetSDK hCNetSDK;

    public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;

    private static FExceptionCallBack fExceptionCallBack;//异常回调



    @Override

    public boolean init() {

        try {

            log.debug("开始加载sdk库文件路径");

            if (Platform.isWindows()) {

                String WIN_PATH = System.getProperty("user.dir") + File.separator + "lib\\hikDll\\HCNetSDK.dll";

                log.debug("当前Windows平台的sdk库路径：" + WIN_PATH);

                hCNetSDK = (HCNetSDK) Native.loadLibrary(WIN_PATH, HCNetSDK.class);

            } else {

                log.debug("Linux平台");

                String LINUX_PATH = System.getProperty("user.dir") + File.separator + "hiklib" + File.separator + "libhcnetsdk.so";

                log.debug("当前Linux平台的sdk库路径：" + LINUX_PATH);

                hCNetSDK = (HCNetSDK) Native.loadLibrary(LINUX_PATH, HCNetSDK.class);



                //设置HCNetSDKCom组件库所在路径

                //libhcnetsdk.so

                String strPathCom = "/home/hiklib";

                NET_DVR_LOCAL_SDK_PATH struComPath = new NET_DVR_LOCAL_SDK_PATH();

                System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());

                struComPath.write();

                hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());



                //设置libcrypto.so所在路径

                BYTE_ARRAY ptrByteArrayCrypto = new BYTE_ARRAY(256);

                String strPathCrypto = "/home/hiklib/libcrypto.so.1.1";

                System.arraycopy(strPathCrypto.getBytes(), 0, ptrByteArrayCrypto.byValue, 0, strPathCrypto.length());

                ptrByteArrayCrypto.write();

                hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArrayCrypto.getPointer());



                //设置libssl.so所在路径

                BYTE_ARRAY ptrByteArraySsl = new BYTE_ARRAY(256);

                String strPathSsl = "/home/hiklib/libssl.so.1.1";

                System.arraycopy(strPathSsl.getBytes(), 0, ptrByteArraySsl.byValue, 0, strPathSsl.length());

                ptrByteArraySsl.write();

                hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArraySsl.getPointer());

            }

            return true;

        } catch (Exception ex) {

            log.error("加载库文件异常：" + ex.getMessage());

            return false;

        }

    }



    @Override

    /**

     * @描述 注册登录 只支持同步登陆，且官方不建议直接在此接口下写耗时操作

     * @参数 [dvrLogin]

@@ -111,8 +73,8 @@
     * @创建时间 2023/1/17 16:12

     * @修改人和其它信息

     */

    @Async

    public void syncLogin(ArdCameras camera) {

    @Override

    public void login(ArdCameras camera) {

        // 初始化

        if (!hCNetSDK.NET_DVR_Init()) {

            log.error("SDK初始化失败");

@@ -130,7 +92,7 @@
        short m_sPort = camera.getPort().shortValue();

        //设置连接时间与重连时间

        hCNetSDK.NET_DVR_SetConnectTime(2000, 1);

        hCNetSDK.NET_DVR_SetReconnect(100000, true);

        hCNetSDK.NET_DVR_SetReconnect(5000, true);

        //设备信息, 输出参数

        HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();

        HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();

@@ -152,13 +114,21 @@
        int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);

        if (lUserID < 0) {

            int errorCode = hCNetSDK.NET_DVR_GetLastError();

            log.error("登录异常：" + errorCode);



            log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败");

            log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败,错误码："+errorCode);

            camera.setChanNum(0);

            camera.setLoginId(-1);

            camera.setState("0");

        } else {

            if (fExceptionCallBack == null) {

                fExceptionCallBack = new ExceptionCallBack();//异常回调

                //设置异常回调函数(可在回调函数中获取设备上下线状态等)

                if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {

                    log.info("Set fExceptionCallBack function fail");

                    return;

                } else {

                    log.info("Set fExceptionCallBack function successfully!");

                }

            }



            if (GlobalVariable.loginMap.containsKey(camera.getId())) {

                GlobalVariable.loginMap.remove(camera.getId());

@@ -166,8 +136,9 @@
            //删除管理通道

            ardChannelService.deleteArdChannelByDeviceId(camera.getId());

            GlobalVariable.loginMap.put(camera.getId(), lUserID);

            log.debug(camera.getIp() + ":" + camera.getPort() + "登录成功");

            GlobalVariable.loginCameraMap.put(lUserID,camera);



            log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]");

            camera.setLoginId(lUserID);

            camera.setState("1");

            camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum);

@@ -279,14 +250,12 @@
    @Override

    public void loginAll() {

        try {

            log.debug("加载lib完成！");

            ArdCameras ardCamera = new ArdCameras();

            ardCamera.setFactory("1");

            List<ArdCameras> ardCameras = ardCamerasService.selectArdCamerasListNoDataScope(ardCamera);

            for (ArdCameras camera : ardCameras) {

                Thread.sleep(500);

                //异步登录

                syncLogin(camera);

                //登录

                login(camera);

            }

        } catch (Exception ex) {

            log.error("初始化登录相机异常：" + ex.getMessage());

@@ -897,7 +866,6 @@
            log.error("控制失败,请稍后重试" + code);

            return new HashMap<>();

        }



    }



    /**