From af8474ee7e0f6ad3c6139b72304cdcb286a5c60e Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期四, 15 八月 2024 14:40:50 +0800
Subject: [PATCH] 优化:修改高精度setPtz转动角速度为最大值

---
 ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikvisionSDK.java |  203 +++++++++++++++++++++-----------------------------
 1 files changed, 86 insertions(+), 117 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikvisionSDK.java b/ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikvisionSDK.java
index 802d315..9a205a6 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikvisionSDK.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/service/impl/HikvisionSDK.java
@@ -9,15 +9,14 @@
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.utils.file.FileUtils;
 import com.ruoyi.common.utils.file.MimeTypeUtils;
-import com.ruoyi.common.utils.spring.SpringUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
-import com.ruoyi.device.camera.service.IArdCamerasService;
-import com.ruoyi.device.camera.factory.CameraSDK;
 import com.ruoyi.device.camera.domain.ArdCameras;
 import com.ruoyi.device.camera.domain.CameraCmd;
+import com.ruoyi.device.camera.factory.CameraSDK;
+import com.ruoyi.device.camera.service.IArdCamerasService;
+import com.ruoyi.device.camera.service.ICameraSdkService;
 import com.ruoyi.device.channel.domain.ArdChannel;
 import com.ruoyi.device.channel.service.IArdChannelService;
-import com.ruoyi.media.domain.Vtdu;
 import com.ruoyi.media.service.IVtduService;
 import com.ruoyi.utils.gis.GisUtil;
 import com.ruoyi.utils.minio.MinioUtil;
@@ -33,8 +32,8 @@
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
-import javax.servlet.http.HttpServletResponse;
 import java.io.*;
 import java.math.BigDecimal;
 import java.nio.ByteBuffer;
@@ -45,7 +44,6 @@
 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;
 
 /**
  * @Description: 娴峰悍sdk绛栫暐
@@ -64,10 +62,39 @@
     private IVtduService vtduService;
     @Resource
     private QueueHandler queueHandler;
+    @Resource
+    ICameraSdkService cameraSdkService;
 
-    public Object _lock = new Object();
     public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;
     private static HCNetSDK.FExceptionCallBack fExceptionCallBack;//寮傚父鍥炶皟
+
+    @PostConstruct
+    public void initSdk() {
+        log.info("鍒濆鍖栨捣搴穝dk");
+        // 鍒濆鍖�
+        if (!hCNetSDK.NET_DVR_Init()) {
+            log.debug("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);
+        }
+        if (fExceptionCallBack == null) {
+            fExceptionCallBack = new ExceptionCallBack();//寮傚父鍥炶皟
+            //璁剧疆寮傚父鍥炶皟鍑芥暟(鍙湪鍥炶皟鍑芥暟涓幏鍙栬澶囦笂涓嬬嚎鐘舵�佺瓑)
+            if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {
+                log.debug("Set fExceptionCallBack function fail");
+            } else {
+                log.debug("Set fExceptionCallBack function successfully!");
+            }
+        }
+        //璁剧疆杩炴帴鏃堕棿涓庨噸杩炴椂闂�
+        hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
+        hCNetSDK.NET_DVR_SetReconnect(5000, true);
+    }
 
     /**
      * @鎻忚堪 娉ㄥ唽鐧诲綍 鍙敮鎸佸悓姝ョ櫥闄嗭紝涓斿畼鏂逛笉寤鸿鐩存帴鍦ㄦ鎺ュ彛涓嬪啓鑰楁椂鎿嶄綔
@@ -80,24 +107,11 @@
     @Override
     public AjaxResult login(ArdCameras camera) {
         try {
-            // 鍒濆鍖�
-            if (!hCNetSDK.NET_DVR_Init()) {
-                log.debug("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();
@@ -115,37 +129,26 @@
             //鏄惁寮傛鐧诲綍锛�0- 鍚︼紝1- 鏄�  windowsSDK閲屾槸true鍜宖alse
             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();
                 camera.setChanNum(0);
-                camera.setLoginId(-1);
+                camera.setLoginId(-1l);
                 camera.setState("0");
                 //鍒犻櫎绠$悊閫氶亾
                 ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                 ardCamerasService.updateArdCameras(camera);
-                log.debug("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
+                log.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
                 return AjaxResult.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
             }
 
             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");
-                } else {
-                    log.debug("Set fExceptionCallBack function successfully!");
-                }
-            }
 
-//            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
-//                GlobalVariable.loginMap.remove(camera.getId());
-//            }
             GlobalVariable.loginMap.put(camera.getId(), lUserID);
             GlobalVariable.loginCameraMap.put(lUserID, camera);
-            camera.setLoginId(lUserID);
+            camera.setLoginId((long) lUserID);
             camera.setState("1");
             int chanNum = m_strDeviceInfo.struDeviceV30.byChanNum;
             int startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan + 1;
@@ -154,18 +157,24 @@
                 startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan;
             }
             camera.setChanNum(chanNum);
-            camera.setStartDChan(startDchan);
+            camera.setStartChan(startDchan);
             //鑾峰彇鏈�鏂伴�氶亾
             List<ArdChannel> cameraChannelList = getChannels(camera);
             if (cameraChannelList.size() > 0) {
+                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+                cameraChannelList.stream().forEach(channel -> {
+                    ardChannelService.insertArdChannel(channel);
+                });
                 camera.setChannelList(cameraChannelList);
-                camera.setChanNum(cameraChannelList.size());
-                ardCamerasService.updateArdCameras(camera);
-                //娣诲姞鍒版祦濯掍綋
-                addVtdu(camera);
+                //camera.setChanNum(cameraChannelList.size());
+                //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+                batchAddVtdu(camera);
             }
+            ardCamerasService.updateArdCameras(camera);
             //鍒涘缓寮曞闃熷垪
             createGuideQueue(camera);
+            //鍔犲叆宸茬櫥褰曡澶囬泦鍚�
+            GlobalVariable.loginedSet.add(camera);
             return AjaxResult.success("璁惧鐧诲綍鎴愬姛");
         } catch (Exception ex) {
             log.error("璁惧鐧诲綍寮傚父", ex);
@@ -182,32 +191,16 @@
      * @淇敼浜哄拰鍏跺畠淇℃伅
      */
     @Override
-    @Async("loginExecutor")
+    @Async("globalExecutor")
     public AjaxResult asyncLogin(ArdCameras camera) {
         try {
-            // 鍒濆鍖�
-            if (!hCNetSDK.NET_DVR_Init()) {
-                log.error("SDK鍒濆鍖栧け璐�");
-                return AjaxResult.warn("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());
@@ -226,32 +219,19 @@
             if (lUserID < 0) {
                 int errorCode = hCNetSDK.NET_DVR_GetLastError();
                 camera.setChanNum(0);
-                camera.setLoginId(-1);
+                camera.setLoginId(-1l);
                 camera.setState("0");
                 //鍒犻櫎绠$悊閫氶亾
                 ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                 ardCamerasService.updateArdCameras(camera);
-                log.error("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
+                log.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
                 return AjaxResult.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")");
             }
             log.debug("Login Success 銆� " + camera.getIp() + ":" + camera.getPort() + " 銆�");
-            synchronized (_lock) {
-                if (fExceptionCallBack == null) {
-                    fExceptionCallBack = new ExceptionCallBack();//寮傚父鍥炶皟
-                    //璁剧疆寮傚父鍥炶皟鍑芥暟(鍙湪鍥炶皟鍑芥暟涓幏鍙栬澶囦笂涓嬬嚎鐘舵�佺瓑)
-                    if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {
-                        log.debug("Set fExceptionCallBack function fail");
-                    } else {
-                        log.debug("Set fExceptionCallBack function successfully!");
-                    }
-                }
-            }
-//            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
-//                GlobalVariable.loginMap.remove(camera.getId());
-//            }
+
             GlobalVariable.loginMap.put(camera.getId(), lUserID);
             GlobalVariable.loginCameraMap.put(lUserID, camera);
-            camera.setLoginId(lUserID);
+            camera.setLoginId((long) lUserID);
             camera.setState("1");
             int chanNum = m_strDeviceInfo.struDeviceV30.byChanNum;
             int startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan + 1;
@@ -260,18 +240,24 @@
                 startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan;
             }
             camera.setChanNum(chanNum);
-            camera.setStartDChan(startDchan);
+            camera.setStartChan(startDchan);
             //鑾峰彇鏈�鏂伴�氶亾
             List<ArdChannel> cameraChannelList = getChannels(camera);
             if (cameraChannelList.size() > 0) {
+                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+                cameraChannelList.stream().forEach(channel -> {
+                    ardChannelService.insertArdChannel(channel);
+                });
                 camera.setChannelList(cameraChannelList);
-                camera.setChanNum(cameraChannelList.size());
-                ardCamerasService.updateArdCameras(camera);
-                //娣诲姞鍒版祦濯掍綋
-                addVtdu(camera);
+                //camera.setChanNum(cameraChannelList.size());
+                //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+                batchAddVtdu(camera);
             }
+            ardCamerasService.updateArdCameras(camera);
             //鍒涘缓寮曞闃熷垪
             createGuideQueue(camera);
+            //鍔犲叆宸茬櫥褰曡澶囬泦鍚�
+            GlobalVariable.loginedSet.add(camera);
             return AjaxResult.success("璁惧鐧诲綍鎴愬姛");
         } catch (Exception ex) {
             log.error("娉ㄥ唽璁惧寮傚父", ex);
@@ -292,36 +278,18 @@
         }
     }
 
-    //娣诲姞鍒版祦濯掍綋
-    private void addVtdu(ArdCameras camera) {
+    //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+    public void batchAddVtdu(ArdCameras camera) {
         try {
-            for (ArdChannel channel : camera.getChannelList()) {
-                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);
-            }
+            camera.getChannelList().stream().forEach(channel -> {
+                vtduService.addChanToVtdu(camera, channel);
+            });
         } catch (Exception ex) {
             log.error("閫氶亾娣诲姞鍒版祦濯掍綋寮傚父锛�" + ex.getMessage());
         }
 
     }
+
 
     /**
      * @鎻忚堪 娉ㄩ攢鐧诲綍
@@ -1064,8 +1032,8 @@
             lpPTZAbsoluteEX_cfgInfo.struPTZCtrl.fZoom = new Double(ptz.get("z")).floatValue();
             lpPTZAbsoluteEX_cfgInfo.struPTZCtrl.dwFocus = 399;
             lpPTZAbsoluteEX_cfgInfo.dwFocalLen = 1250;
-            lpPTZAbsoluteEX_cfgInfo.fHorizontalSpeed = (float) 10;
-            lpPTZAbsoluteEX_cfgInfo.fVerticalSpeed = (float) 10;
+            lpPTZAbsoluteEX_cfgInfo.fHorizontalSpeed = (float) 1000;
+            lpPTZAbsoluteEX_cfgInfo.fVerticalSpeed = (float) 1000;
             lpPTZAbsoluteEX_cfgInfo.byZoomType = 0;
             lpPTZAbsoluteEX_cfgInfo.write();
             lpConfigParam6697.lpInBuffer = lpPTZAbsoluteEX_cfgInfo.getPointer();
@@ -1102,7 +1070,10 @@
             double[] targetPositions = cmd.getTargetPosition();
             double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150);
             String p = String.valueOf((int) (cameraPTZ[0] * 10));
-            String t = String.valueOf((int) (cameraPTZ[1] * 10));
+            //淇淇话
+            double correctPitch = cameraSdkService.correctPitch(cmd);
+            double newt = cameraPTZ[1] + correctPitch;
+            String t = String.valueOf((int) (newt * 10));
             String z = String.valueOf((int) (cameraPTZ[2] * 10));
             m_ptzPosCurrent.wPanPos = (short) (Integer.parseInt(p, 16));
             m_ptzPosCurrent.wTiltPos = (short) (Integer.parseInt(t, 16));
@@ -1115,7 +1086,7 @@
                 log.error("璁剧疆ptz澶辫触,璇风◢鍚庨噸璇�" + code);
                 return AjaxResult.warn("璁剧疆ptz澶辫触:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")");
             }
-            return AjaxResult.success("寮曞鍧愭爣鎴愬姛");
+            return AjaxResult.success("寮曞鍧愭爣鎴愬姛", correctPitch);
         } catch (Exception ex) {
             log.error("寮曞鍧愭爣寮傚父:" + ex.getMessage());
             return AjaxResult.error("寮曞鍧愭爣寮傚父:" + ex.getMessage());
@@ -1841,27 +1812,24 @@
         //鑾峰彇閫氶亾
         List<ArdChannel> channelList = new ArrayList<>();
         try {
-            //鍒犻櫎绠$悊閫氶亾
-            ardChannelService.deleteArdChannelByDeviceId(camera.getId());
             IntByReference ibrBytesReturned = new IntByReference(0);//鑾峰彇IP鎺ュ叆閰嶇疆鍙傛暟
             HCNetSDK.NET_DVR_IPPARACFG_V40 m_strIpparaCfg = new HCNetSDK.NET_DVR_IPPARACFG_V40();
             m_strIpparaCfg.write();
             //lpIpParaConfig 鎺ユ敹鏁版嵁鐨勭紦鍐叉寚閽�
             Pointer lpIpParaConfig = m_strIpparaCfg.getPointer();
-            boolean bRet = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId(), HCNetSDK.NET_DVR_GET_IPPARACFG_V40, 0, lpIpParaConfig, m_strIpparaCfg.size(), ibrBytesReturned);
+            boolean bRet = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId().intValue(), HCNetSDK.NET_DVR_GET_IPPARACFG_V40, 0, lpIpParaConfig, m_strIpparaCfg.size(), ibrBytesReturned);
             m_strIpparaCfg.read();
             //log.debug("璧峰鏁板瓧閫氶亾鍙凤細" + m_strIpparaCfg.dwStartDChan);//m_strIpparaCfg.dwDChanNum
             for (int iChannum = 0; iChannum < camera.getChanNum(); iChannum++) {
                 ArdChannel channel = new ArdChannel();
-                int chanNo = iChannum + camera.getStartDChan();
+                int chanNo = iChannum + camera.getStartChan();
                 HCNetSDK.NET_DVR_PICCFG_V40 strPicCfg = new HCNetSDK.NET_DVR_PICCFG_V40();
                 strPicCfg.dwSize = strPicCfg.size();
                 strPicCfg.write();
                 Pointer pStrPicCfg = strPicCfg.getPointer();
                 NativeLong lChannel = new NativeLong(chanNo);
                 IntByReference pInt = new IntByReference(0);
-                boolean b_GetPicCfg = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId(), HCNetSDK.NET_DVR_GET_PICCFG_V40, lChannel.intValue(),
-                        pStrPicCfg, strPicCfg.size(), pInt);
+                boolean b_GetPicCfg = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId().intValue(), HCNetSDK.NET_DVR_GET_PICCFG_V40, lChannel.intValue(), pStrPicCfg, strPicCfg.size(), pInt);
                 if (!b_GetPicCfg) {
                     // log.error("鑾峰彇鍥惧儚鍙傛暟澶辫触锛岄敊璇爜锛�" + hCNetSDK.NET_DVR_GetLastError());
                 }
@@ -1884,7 +1852,6 @@
                     }
                     channelList.add(channel);
                 }
-                ardChannelService.insertArdChannel(channel);
             }
         } catch (Exception ex) {
             log.error("鑾峰彇IP閫氶亾寮傚父:" + ex.getMessage());
@@ -1939,11 +1906,12 @@
     @Override
     public AjaxResult localRecordStart(CameraCmd cmd) {
         try {
+            String operator = cmd.getOperator();
             String cameraId = cmd.getCameraId();
             Integer channelNum = cmd.getChanNo();
             // 鏈湴涓存椂褰曞儚鍦板潃
             String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
-            String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
+            String path = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
             if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                 return AjaxResult.warn("璁惧鏈櫥褰�");
             }
@@ -2000,6 +1968,7 @@
     @Override
     public AjaxResult localRecordStop(CameraCmd cmd) {
         try {
+            String operator = cmd.getOperator();
             String cameraId = cmd.getCameraId();
             Integer channelNum = cmd.getChanNo();
             Integer lRealHandle = cmd.getRecordId().intValue();
@@ -2034,7 +2003,7 @@
             log.debug("鏈湴褰曞儚鍋滄");
             // 鏈湴涓存椂褰曞儚鍦板潃
             String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
-            String recordPath = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
+            String recordPath = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
             byte[] recordBytes = Files.readAllBytes(Paths.get(recordPath));
             return AjaxResult.success(recordBytes);
         } catch (Exception ex) {

--
Gitblit v1.9.3