异步登录增加延迟时间避免接口频繁 修改大华通道数量获取

‘liusuyi’

2023-10-24 4a293865ac437a812eea8800cc0b04314efbd210

 ard-work/src/main/java/com/ruoyi/device/dhsdk/service/impl/DhClientServiceImpl.java

@@ -18,6 +18,7 @@
import com.ruoyi.device.dhsdk.module.*;

import com.ruoyi.device.dhsdk.service.IDhClientService;

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

import com.ruoyi.device.camera.service.impl.AsyncLogin;

import com.ruoyi.media.domain.Vtdu;

import com.ruoyi.media.service.IVtduService;

import com.ruoyi.utils.gis.GisUtil;

@@ -25,7 +26,6 @@
import com.sun.jna.Pointer;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;



import javax.annotation.Resource;

@@ -59,41 +59,12 @@
    @Value("${minio.endpoint}")

    private String minioEndPoint;





    // 设备断线通知回调

    private static DisConnect disConnect = new DisConnect();

    // 网络连接恢复

    private static HaveReConnect haveReConnect = new HaveReConnect();



    /**

     * 登录所有相机

     * 刘苏义

     * 2023/10/17 8:28:13

     */

    @Override

    public void loginAll() {

        try {

            ArdCameras ardCamera = new ArdCameras();

            ardCamera.setFactory("2");//获取大华相机

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

            for (ArdCameras camera : ardCameras) {

                Thread.sleep(500);

                //异步登录

                login(camera);

            }

        } catch (Exception ex) {

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

        }

    }



    /**

     * sdk初始化

     * 刘苏义

     * 2023/10/17 8:28:13

     */

    @Override

    public Boolean init() {

        return LoginModule.init(disConnect, haveReConnect);   // 打开工程，初始化

    }



    /**

     * 登录

@@ -101,9 +72,10 @@
     * 2023/10/17 8:28:13

     */

    @Override

    @Async

    public Boolean login(ArdCameras camera) {

        LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword());

        LoginModule.init(disConnect, haveReConnect);

        NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();

        LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword(), m_stDeviceInfo);

        if (loginId.longValue() > 0) {

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

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

@@ -112,13 +84,14 @@
            //删除管理通道

            ardChannelService.deleteArdChannelByDeviceId(camera.getId());

            camera.setState("1");

            camera.setChanNum(LoginModule.m_stDeviceInfo.byChanNum);

            camera.setChanNum(m_stDeviceInfo.byChanNum);

            camera.setStartDChan(1);

            camera.setLoginId((int) loginId.longValue());

            ardCamerasService.updateArdCameras(camera);

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



            //获取最新通道

            for (int i = 1; i < LoginModule.m_stDeviceInfo.byChanNum + 1; i++) {

            for (int i = 1; i < m_stDeviceInfo.byChanNum + 1; i++) {

                ArdChannel channel = new ArdChannel();

                AV_CFG_ChannelName av_cfg_channelName = new AV_CFG_ChannelName();

                boolean b = ConfigModule.GetNewDevConfig(loginId, i - 1, CFG_CMD_CHANNELTITLE, av_cfg_channelName);

@@ -144,7 +117,6 @@
                if (vtdu != null) {

                    vtduService.deleteVtduByName(name);

                }



                //添加到流媒体

                CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo());

                Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);

@@ -168,7 +140,6 @@
            ardCamerasService.updateArdCameras(camera);

            return false;

        }



        return true;

    }



@@ -217,6 +188,7 @@
     * 2023/10/17 8:28:13

     */

    @Override

    @SdkOperate

    public boolean pTZControl(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -368,7 +340,6 @@
     * @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置

     */

    @Override

    @SdkOperate

    public boolean setZeroPtz(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

@@ -392,7 +363,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public String picCutCate(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

@@ -823,62 +793,66 @@
    @Override

    public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {

        Map<String, Object> map = new HashMap<>();

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return null;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();

        cfg_encode_info.nChannelID = chanNo - 1;

        boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);

        if (b) {

            int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式

            String videoEncType = "";

            switch (emCompression) {

                case 0:

                    videoEncType = "MPEG4";

                    break;

                case 1:

                    videoEncType = "MS-MPEG4";

                    break;

                case 2:

                    videoEncType = "MPEG2";

                    break;

                case 3:

                    videoEncType = "MPEG1";

                    break;

                case 4:

                    videoEncType = "H.263";

                    break;

                case 5:

                    videoEncType = "MJPG";

                    break;

                case 6:

                    videoEncType = "FCC-MPEG4";

                    break;

                case 7:

                    videoEncType = "标准h264";

                    break;

                case 8:

                    videoEncType = "标准h265";

                    break;

                case 9:

                    videoEncType = "SVAC";

                    break;

                default:

                    videoEncType = "未知";

                    break;

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return null;

            }

            int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;

            int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;

            int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;

            String resolution = nWidth + "*" + nHeight;

            float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;

            map.put("resolution", resolution);//分辨率

            map.put("videoBitrate", String.valueOf(nBitRate));//比特率

            map.put("videoEncType", videoEncType);//编码

            map.put("nFrameRate", String.valueOf(nFrameRate));//帧率

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();

            cfg_encode_info.nChannelID = chanNo - 1;

            boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);

            if (b) {

                int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式

                String videoEncType = "";

                switch (emCompression) {

                    case 0:

                        videoEncType = "MPEG4";

                        break;

                    case 1:

                        videoEncType = "MS-MPEG4";

                        break;

                    case 2:

                        videoEncType = "MPEG2";

                        break;

                    case 3:

                        videoEncType = "MPEG1";

                        break;

                    case 4:

                        videoEncType = "H.263";

                        break;

                    case 5:

                        videoEncType = "MJPG";

                        break;

                    case 6:

                        videoEncType = "FCC-MPEG4";

                        break;

                    case 7:

                        videoEncType = "标准h264";

                        break;

                    case 8:

                        videoEncType = "标准h265";

                        break;

                    case 9:

                        videoEncType = "SVAC";

                        break;

                    default:

                        videoEncType = "未知";

                        break;

                }

                int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;

                int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;

                int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;

                String resolution = nWidth + "*" + nHeight;

                float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;

                map.put("resolution", resolution);//分辨率

                map.put("videoBitrate", String.valueOf(nBitRate));//比特率

                map.put("videoEncType", videoEncType);//编码

                map.put("nFrameRate", String.valueOf(nFrameRate));//帧率

            }

        } catch (Exception ex) {

            log.error("取码流压缩参数异常:" + ex.getMessage());

        }

        return map;

    }

@@ -912,7 +886,7 @@
    // 设备断线回调: 当设备出现断线时，SDK会调用该函数

    private static class DisConnect implements NetSDKLib.fDisConnect {

        public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {

            System.out.printf("Device[%s] Port[%d] DisConnect!\n", pchDVRIP, nDVRPort);

            log.warn("Device[" + pchDVRIP + "] Port[" + nDVRPort + "] DisConnect!");

        }

    }



@@ -920,7 +894,7 @@
    private static class HaveReConnect implements NetSDKLib.fHaveReConnect {

        @Override

        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {

            System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);

            log.warn("ReConnect Device[" + pchDVRIP + "] Port[" + nDVRPort + "]");

        }

    }