Merge remote-tracking branch 'origin/master'

aijinhui

2023-10-24 8a87e4226aa802d6a0e3566c66824fedf68e77da

 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;//异常回调



@@ -75,112 +72,119 @@
     */

    @Override

    public void login(ArdCameras camera) {

        // 初始化

        if (!hCNetSDK.NET_DVR_Init()) {

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

        }

        //打印海康sdk日志

        if (Platform.isWindows()) {

            String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;

            hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);

        } else {

            hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);

        }

        String m_sDeviceIP = camera.getIp();

        String m_sUsername = camera.getUsername();

        String m_sPassword = camera.getPassword();

        short m_sPort = camera.getPort().shortValue();

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

        hCNetSDK.NET_DVR_SetConnectTime(2000, 1);

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



        // 注册设备-登录参数，包括设备地址、登录用户、密码等

        m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];

        System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());

        m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];

        System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());

        m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];

        System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());

        m_strLoginInfo.wPort = m_sPort;

        m_strLoginInfo.byVerifyMode = 0;

        m_strLoginInfo.byLoginMode = 0;

        //是否异步登录：0- 否，1- 是  windowsSDK里是true和false

        m_strLoginInfo.bUseAsynLogin = false;

        m_strLoginInfo.write();

        //同步登录

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

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

                }

        try {

            // 初始化

            if (!hCNetSDK.NET_DVR_Init()) {

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

            }



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

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

            //打印海康sdk日志

            if (Platform.isWindows()) {

                String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;

                hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);

            } else {

                hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);

            }

            //删除管理通道

            ardChannelService.deleteArdChannelByDeviceId(camera.getId());

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

            GlobalVariable.loginCameraMap.put(lUserID,camera);

            String m_sDeviceIP = camera.getIp();

            String m_sUsername = camera.getUsername();

            String m_sPassword = camera.getPassword();

            short m_sPort = camera.getPort().shortValue();

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

            hCNetSDK.NET_DVR_SetConnectTime(2000, 1);

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



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

            // 注册设备-登录参数，包括设备地址、登录用户、密码等

            m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];

            System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());

            m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];

            System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());

            m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];

            System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());

            m_strLoginInfo.wPort = m_sPort;

            m_strLoginInfo.byVerifyMode = 0;

            m_strLoginInfo.byLoginMode = 0;

            //是否异步登录：0- 否，1- 是  windowsSDK里是true和false

            m_strLoginInfo.bUseAsynLogin = false;

            m_strLoginInfo.write();

            //同步登录

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

            if (lUserID < 0) {

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

                camera.setChanNum(0);

                camera.setLoginId(-1);

                camera.setState("0");

                return;

            }

            synchronized (lock) {

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

                    }

                }

                //添加到流媒体

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



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

                    }

                    //添加到流媒体

                    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");//默认转码

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

        }

    }



@@ -239,28 +243,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());

        }

    }



    /**

     * @描述 注销登录

@@ -314,6 +296,7 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean pTZControlWithSpeed(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1064,7 +1047,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlDefogcfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1110,7 +1092,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlInfrarecfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1158,7 +1139,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlFocusMode(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1231,7 +1211,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlPTHeateRpwron(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1264,7 +1243,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean controlCameraDeicing(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

@@ -1345,7 +1323,6 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public String picCutCate(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer channelNum = cmd.getChanNo();