Merge remote-tracking branch 'origin/master'

aijinhui

2023-10-24 8a8a13eb80498e9b905b47b8dc4d52cd8fdb8497

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

@@ -3,6 +3,7 @@
import com.ruoyi.alarm.global.domain.GuidePriorityQueue;

import com.ruoyi.alarm.global.domain.GuideTask;

import com.ruoyi.common.annotation.SdkOperate;

import com.ruoyi.common.utils.Threads;

import com.ruoyi.common.utils.file.FileUtils;

import com.ruoyi.common.utils.file.MimeTypeUtils;

import com.ruoyi.common.utils.uuid.IdUtils;

@@ -10,11 +11,10 @@
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.device.camera.service.impl.AsyncLogin;

import com.ruoyi.media.domain.Vtdu;

import com.ruoyi.media.service.IVtduService;

import com.ruoyi.utils.gis.GisUtil;

@@ -22,13 +22,11 @@
import com.ruoyi.device.hiksdk.service.IHikClientService;

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

import com.ruoyi.utils.minio.MinioUtil;

import com.sun.jna.Native;

import com.sun.jna.NativeLong;

import com.sun.jna.Platform;

import com.sun.jna.Pointer;

import com.sun.jna.ptr.IntByReference;

import lombok.extern.slf4j.Slf4j;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;



import java.util.Base64;

@@ -40,7 +38,6 @@
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.*;



/**

@@ -60,7 +57,7 @@
    private IArdChannelService ardChannelService;

    @Resource

    private IVtduService vtduService;



    private final Object lock = new Object();

    public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;

    private static FExceptionCallBack fExceptionCallBack;//异常回调



@@ -114,75 +111,79 @@
            //同步登录

            int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);

            if (lUserID < 0) {

                int errorCode = hCNetSDK.NET_DVR_GetLastError();

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

                log.debug("Login Failed [ " + camera.getIp() + ":" + camera.getPort() + " ],错误码：" + hCNetSDK.NET_DVR_GetLastError());

                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!");

                    }

                }

                return;

            }



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

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

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

            if (fExceptionCallBack == null) {

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

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

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

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

                    return;

                } else {

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

                }

                //删除管理通道

                ardChannelService.deleteArdChannelByDeviceId(camera.getId());

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

                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);

                camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);

                //获取最新通道

                List<ArdChannel> cameraChannelList = getCameraChannelList(camera);

                if (cameraChannelList.size() > 0) {

                    for (ArdChannel channel : cameraChannelList) {

                        channel.setId(IdUtils.simpleUUID());

                        ardChannelService.insertArdChannel(channel);

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

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

            }



            //删除管理通道

            ardChannelService.deleteArdChannelByDeviceId(camera.getId());

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

            GlobalVariable.loginCameraMap.put(lUserID, camera);



            camera.setLoginId(lUserID);

            camera.setState("1");

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

            camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);



            //获取最新通道

            List<ArdChannel> cameraChannelList = getCameraChannelList(camera);

            if (cameraChannelList.size() > 0) {

                for (ArdChannel channel : cameraChannelList) {

                    channel.setId(IdUtils.simpleUUID());

                    ardChannelService.insertArdChannel(channel);

                }

                //添加到流媒体

                for (ArdChannel channel : cameraChannelList) {

                    String name = camera.getId() + "_" + channel.getChanNo();

                    String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";

                    Vtdu vtdu = vtduService.selectVtduByName(name);

                    if (vtdu != null) {

                        vtduService.deleteVtduByName(name);

                    }

                    //添加到流媒体

                    for (ArdChannel channel : cameraChannelList) {

                        String name = camera.getId() + "_" + channel.getChanNo();

                        String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";

                        Vtdu vtdu = vtduService.selectVtduByName(name);

                        if (vtdu != null) {

                            vtduService.deleteVtduByName(name);

                        }

                        //添加到流媒体

                        vtdu = new Vtdu();

                        vtdu.setRtspSource(rtspSource);

                        vtdu.setName(camera.getId() + "_" + channel.getChanNo());

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

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

                        if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {

                            vtdu.setIsCode("0");//默认不转码

                        } else {

                            vtdu.setIsCode("1");//默认转码

                        }

                        vtdu.setMode("1");//默认CPU软解码

                        vtdu.setCameraId(camera.getId());

                        vtduService.insertVtdu(vtdu);

                    vtdu = new Vtdu();

                    vtdu.setRtspSource(rtspSource);

                    vtdu.setName(camera.getId() + "_" + channel.getChanNo());

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

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

                    if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {

                        vtdu.setIsCode("0");//默认不转码

                    } else {

                        vtdu.setIsCode("1");//默认转码

                    }

                    vtdu.setMode("1");//默认CPU软解码

                    vtdu.setCameraId(camera.getId());

                    vtduService.insertVtdu(vtdu);

                }

                //创建引导队列

                if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {

                    Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();

                    PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);

                    GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);

                }

                ardCamerasService.updateArdCameras(camera);

            }

            //创建引导队列

            if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {

                Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();

                PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);

                GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);

            }

            ardCamerasService.updateArdCameras(camera);





        } catch (Exception ex) {

            log.error("注册设备异常", ex);

        }

@@ -243,28 +244,6 @@


    }



    /**

     * @描述 登录所有相机

     * @参数 []

     * @返回值 void

     * @创建人 刘苏义

     * @创建时间 2023/2/3 10:10

     * @修改人和其它信息

     */

    @Override

    public void loginAll() {

        try {

            ArdCameras ardCamera = new ArdCameras();

            ardCamera.setFactory("1");

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

            for (ArdCameras camera : ardCameras) {

                //登录

                login(camera);

            }

        } catch (Exception ex) {

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

        }

    }



    /**

     * @描述 注销登录

@@ -318,6 +297,7 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean pTZControlWithSpeed(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -523,19 +503,21 @@
     */

    @Override

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

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

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

            return null;

        }

        Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);



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

        NET_DVR_COMPRESSIONCFG_V30 compressioncfg = new NET_DVR_COMPRESSIONCFG_V30();

        compressioncfg.write();

        Pointer pioint = compressioncfg.getPointer();

        IntByReference ibrBytesReturned = new IntByReference(0);

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

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

                return null;

            }

            Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId);



            NET_DVR_COMPRESSIONCFG_V30 compressioncfg = new NET_DVR_COMPRESSIONCFG_V30();

            compressioncfg.write();

            Pointer pioint = compressioncfg.getPointer();

            IntByReference ibrBytesReturned = new IntByReference(0);



            boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_COMPRESSCFG_V30, chanNo, pioint, compressioncfg.size(), ibrBytesReturned);

            if (bool) {

                compressioncfg.read();

@@ -1068,7 +1050,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlDefogcfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1114,7 +1095,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlInfrarecfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1162,7 +1142,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlFocusMode(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1235,7 +1214,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlPTHeateRpwron(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1268,7 +1246,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlCameraDeicing(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1349,7 +1326,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public String picCutCate(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer channelNum = cmd.getChanNo();