1、修改相机异步登录 2、sdk切换更改为策略模式 3、修复手动巡检停止录像bug

‘liusuyi’

2023-11-07 6decb63d865de6b551324fd9782555786132170e

 ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikSdkStrategy.java

ÎļþÃû´Ó ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikClientServiceImpl.java ÐÞ¸Ä
@@ -6,28 +6,27 @@
import com.ruoyi.common.utils.file.FileUtils;

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

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

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

import com.ruoyi.device.camera.service.IArdCamerasService;

import com.ruoyi.device.camera.strategy.SdkStrategy;
import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.channel.domain.ArdChannel;

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

import com.ruoyi.utils.sdk.common.GlobalVariable;

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

import com.ruoyi.utils.sdk.hiksdk.lib.ExceptionCallBack;

import com.ruoyi.media.domain.Vtdu;

import com.ruoyi.media.service.IVtduService;

import com.ruoyi.utils.gis.GisUtil;

import com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK;

import com.ruoyi.utils.sdk.hiksdk.service.IHikClientService;

import com.ruoyi.utils.sdk.hiksdk.lib.LoginResultCallBack;

import com.ruoyi.utils.minio.MinioUtil;

import com.ruoyi.utils.sdk.common.GlobalVariable;
import com.ruoyi.utils.sdk.hiksdk.lib.ExceptionCallBack;
import com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK;
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;

import javax.annotation.Resource;

import java.io.*;

import java.math.BigDecimal;

@@ -37,28 +36,26 @@
import java.util.concurrent.PriorityBlockingQueue;



import static com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK.*;

import static com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK.NET_DVR_GET_GISINFO;


/**

 * @ClassName: hikClientServiceImpl

 * @Description: æµ·åº·æ“ä½œå®¢æˆ·ç«¯å®žçŽ°ç±»

 * @Author: Administrator

 * @Date: 2023å¹´01月17日 11:25

 * @Version: 1.2

 * @Description: æµ·åº·sdk策略
 * @ClassName: DhSdkStrategy
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´11月07日10:51:09
 **/

@Slf4j(topic = "hikSdk")

@Service

public class HikClientServiceImpl implements IHikClientService {



@Slf4j(topic = "hikSdk")
public class HikSdkStrategy implements SdkStrategy {
    @Resource

    private IArdCamerasService ardCamerasService;

    @Resource

    private IArdChannelService ardChannelService;

    @Resource

    private IVtduService vtduService;

    private final Object lock = new Object();

    public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;

    private static FExceptionCallBack fExceptionCallBack;//异常回调



    public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;
    private static HCNetSDK.FExceptionCallBack fExceptionCallBack;//异常回调


    /**

     * @描述 æ³¨å†Œç™»å½• åªæ”¯æŒåŒæ­¥ç™»é™†ï¼Œä¸”官方不建议直接在此接口下写耗时操作

@@ -69,7 +66,7 @@
     * @修改人和其它信息

     */

    @Override

    public void login(ArdCameras camera) {

    public boolean login(ArdCameras camera) {
        try {

            // åˆå§‹åŒ–

            if (!hCNetSDK.NET_DVR_Init()) {

@@ -113,6 +110,139 @@
                camera.setChanNum(0);

                camera.setLoginId(-1);

                camera.setState("0");

                //删除管理通道
                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                ardCamerasService.updateArdCameras(camera);
                return false;
            }

            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 false;
                } else {
                    log.debug("Set fExceptionCallBack function successfully!");
                }
            }

            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);
            ardCamerasService.updateArdCameras(camera);
            //获取最新通道
            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);
                    }
                    //添加到流媒体
                    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);
            }

        } catch (Exception ex) {
            log.error("注册设备异常", ex);
        }
        return true;
    }

    /**
     * @描述 æ³¨å†Œç™»å½• é›†æˆäºŽNET_DVR_Login_V30，支持同步和异步登录
     * @参数 [dvrLogin]
     * @返回值 java.lang.Integer
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/17 16:12
     * @修改人和其它信息
     */
    @Override
    @Async("loginExecutor")
    public void asyncLogin(ArdCameras camera) {
        try {
            // åˆå§‹åŒ–
            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) {
                log.debug("Login Failed [ " + camera.getIp() + ":" + camera.getPort() + " ],错误码：" + hCNetSDK.NET_DVR_GetLastError());
                camera.setChanNum(0);
                camera.setLoginId(-1);
                camera.setState("0");
                //删除管理通道
                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                ardCamerasService.updateArdCameras(camera);
                return;

            }



@@ -186,62 +316,6 @@
    }



    /**

     * @描述 æ³¨å†Œç™»å½• é›†æˆäºŽNET_DVR_Login_V30，支持同步和异步登录

     * @参数 [dvrLogin]

     * @返回值 java.lang.Integer

     * @创建人 åˆ˜è‹ä¹‰

     * @创建时间 2023/1/17 16:12

     * @修改人和其它信息

     */

    @Override

    public void asyncLogin(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(100000, 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 = true;

        //异步登录回调

        m_strLoginInfo.cbLoginResult = new LoginResultCallBack(camera);

        m_strLoginInfo.write();

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

        if (i < 0) {

            int errorCode = hCNetSDK.NET_DVR_GetLastError();

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

        }



    }





    /**

     * @描述 æ³¨é”€ç™»å½•

     * @参数 [dvrLogin]

     * @返回值 java.lang.Integer

@@ -293,8 +367,7 @@
     * @修改人和其它信息

     */

    @Override

    @SdkOperate

    public boolean pTZControlWithSpeed(CameraCmd cmd) {

    public boolean pTZControl(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

        Integer channelNum = cmd.getChanNo();

@@ -934,7 +1007,6 @@
     * @创建时间 2023/1/17 16:36

     * @修改人和其它信息 0-解锁 1-锁定

     */

    @Override

    public int getPTZLockInfo(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer channelNum = cmd.getChanNo();

@@ -966,7 +1038,6 @@
     * @修改人和其它信息 æ³¨æ„ä¿¯ä»°è§’度负值需要加上360得到的正值进行设置

     */

    @Override

    @SdkOperate

    public boolean setZeroPtz(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer channelNum = cmd.getChanNo();