From 38f29e38fcc668171dc05c53d40a36b895c86102 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期四, 10 十月 2024 13:34:28 +0800
Subject: [PATCH] init

---
 ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java |  258 ++++++++++++++++++++++++---------------------------
 1 files changed, 123 insertions(+), 135 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java b/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java
index e374b7a..bb92799 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java
@@ -4,44 +4,42 @@
 import com.ruoyi.alarm.global.domain.GuideTask;
 import com.ruoyi.alarm.global.service.impl.QueueHandler;
 import com.ruoyi.common.annotation.SdkOperate;
+import com.ruoyi.common.config.ARDConfig;
+import com.ruoyi.common.constant.Constants;
 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.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;
 import com.ruoyi.utils.sdk.common.GlobalVariable;
-import com.ruoyi.utils.sdk.common.SdkErrorCodeEnum;
 import com.ruoyi.utils.sdk.dhsdk.common.ErrorCode;
 import com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib;
-import com.ruoyi.utils.sdk.dhsdk.lib.ToolKits;
 import com.ruoyi.utils.sdk.dhsdk.lib.enumeration.EM_NEW_CONFIG;
 import com.ruoyi.utils.sdk.dhsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
 import com.ruoyi.utils.sdk.dhsdk.lib.structure.CFG_INFRARED_INFO;
 import com.ruoyi.utils.sdk.dhsdk.lib.structure.CFG_VIDEO_IN_FOCUS;
 import com.ruoyi.utils.sdk.dhsdk.lib.structure.DH_OUT_PTZ_VIEW_RANGE_STATUS;
 import com.ruoyi.utils.sdk.dhsdk.module.*;
-import com.sun.jna.Native;
 import com.sun.jna.Pointer;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
-import javax.servlet.ServletOutputStream;
-import javax.servlet.http.HttpServletResponse;
 import java.io.*;
-import java.nio.ByteBuffer;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.text.DecimalFormat;
@@ -49,7 +47,6 @@
 import java.util.concurrent.PriorityBlockingQueue;
 
 import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.*;
-import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_DEVSTATE_PTZ_VIEW_RANGE;
 import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_MOVE_CONTROL;
 import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_SET_CONTROL;
 import static com.ruoyi.utils.sdk.dhsdk.lib.ToolKits.getErrorCodePrint;
@@ -71,6 +68,9 @@
     private IArdChannelService ardChannelService;
     @Resource
     private IVtduService vtduService;
+
+    @Resource
+    ICameraSdkService cameraSdkService;
     @Value("${minio.endpoint}")
     private String minioEndPoint;
     @Resource
@@ -81,6 +81,11 @@
     // 缃戠粶杩炴帴鎭㈠
     private static HaveReConnect haveReConnect = new HaveReConnect();
 
+    @PostConstruct
+    public void initSdk() {
+        log.info("鍒濆鍖栧ぇ鍗巗dk");
+        LoginModule.init(disConnect, haveReConnect);
+    }
 
     /**
      * 鐧诲綍
@@ -92,53 +97,40 @@
     @Override
     public AjaxResult login(ArdCameras camera) {
         try {
-            LoginModule.init(disConnect, haveReConnect);
             NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
             NetSDKLib.LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword(), m_stDeviceInfo);
             if (loginId.longValue() <= 0) {
                 camera.setChanNum(0);
-                camera.setLoginId(-1);
+                camera.setLoginId(-1l);
                 camera.setState("0");
                 ardCamerasService.updateArdCameras(camera);
                 //鍒犻櫎绠$悊閫氶亾
                 ardChannelService.deleteArdChannelByDeviceId(camera.getId());
-                log.error("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触:" + getErrorCodePrint());
+                log.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触:" + getErrorCodePrint());
                 return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
             }
-            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
-                GlobalVariable.loginMap.remove(camera.getId());
-            }
-            //鍒犻櫎绠$悊閫氶亾
-            ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+            log.debug("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍鎴愬姛:" + (int) loginId.longValue());
             camera.setState("1");
             camera.setChanNum(m_stDeviceInfo.byChanNum);
-            camera.setStartDChan(1);
-            camera.setLoginId((int) loginId.longValue());
-            ardCamerasService.updateArdCameras(camera);
+            camera.setStartChan(1);
+            camera.setLoginId(loginId.longValue());
             GlobalVariable.loginMap.put(camera.getId(), loginId);
-
             //鑾峰彇鏈�鏂伴�氶亾
-            for (int i = 1; i < m_stDeviceInfo.byChanNum + 1; i++) {
-                ArdChannel channel = new ArdChannel();
-                NetSDKLib.AV_CFG_ChannelName av_cfg_channelName = new NetSDKLib.AV_CFG_ChannelName();
-                boolean b = ConfigModule.GetNewDevConfig(loginId, i - 1, CFG_CMD_CHANNELTITLE, av_cfg_channelName);
-                if (b) {
-                    String chanName = "";
-                    try {
-                        chanName = new String(av_cfg_channelName.szName, "GBK").trim();
-                    } catch (UnsupportedEncodingException e) {
-                        e.printStackTrace();
-                    }
-                    channel.setName(chanName.equals("") ? "閫氶亾" + i : chanName);
-                }
-                channel.setDeviceId(camera.getId());
-                channel.setChanNo(i);
-                ardChannelService.insertArdChannel(channel);
+            List<ArdChannel> ardChannelList = getChannels(camera);
+            if (ardChannelList.size() > 0) {
+                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+                ardChannelList.stream().forEach(channel -> {
+                    ardChannelService.insertArdChannel(channel);
+                });
+                camera.setChannelList(ardChannelList);
+                //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+                batchAddVtdu(camera);
             }
-            //閰嶇疆鍒版祦濯掍綋
-            addVtdu(camera);
+            ardCamerasService.updateArdCameras(camera);
             //鍒涘缓寮曞闃熷垪
             createGuideQueue(camera);
+            //鍔犲叆宸茬櫥褰曡澶囬泦鍚�
+            GlobalVariable.loginedSet.add(camera);
             return AjaxResult.success("璁惧鐧诲綍鎴愬姛");
         } catch (Exception ex) {
             log.error("璁惧鐧诲綍寮傚父:" + ex.getMessage());
@@ -147,59 +139,45 @@
     }
 
     @Override
-    @Async("loginExecutor")
+    @Async("globalExecutor")
     public AjaxResult asyncLogin(ArdCameras camera) {
         try {
-            LoginModule.init(disConnect, haveReConnect);
             NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
             NetSDKLib.LLong loginId = LoginModule.login(camera.getIp(), camera.getPort(), camera.getUsername(), camera.getPassword(), m_stDeviceInfo);
             if (loginId.longValue() <= 0) {
                 camera.setChanNum(0);
-                camera.setLoginId(-1);
+                camera.setLoginId(-1l);
                 camera.setState("0");
                 ardCamerasService.updateArdCameras(camera);
                 //鍒犻櫎绠$悊閫氶亾
                 ardChannelService.deleteArdChannelByDeviceId(camera.getId());
-                log.error("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触:" + getErrorCodePrint());
+                log.warn("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍澶辫触:" + getErrorCodePrint());
                 return AjaxResult.warn(getErrorCodePrint());
             }
-            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
-                GlobalVariable.loginMap.remove(camera.getId());
-            }
-            //鍒犻櫎绠$悊閫氶亾
-            ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+            log.debug("璁惧[" + camera.getIp() + ":" + camera.getPort() + "]鐧诲綍鎴愬姛:" + loginId);
             camera.setState("1");
             camera.setChanNum(m_stDeviceInfo.byChanNum);
-            camera.setStartDChan(1);
-            camera.setLoginId((int) loginId.longValue());
+            camera.setStartChan(1);
+            camera.setLoginId(loginId.longValue());
             ardCamerasService.updateArdCameras(camera);
             GlobalVariable.loginMap.put(camera.getId(), loginId);
 
             //鑾峰彇鏈�鏂伴�氶亾
-            for (int i = 1; i < m_stDeviceInfo.byChanNum + 1; i++) {
-                ArdChannel channel = new ArdChannel();
-                NetSDKLib.AV_CFG_ChannelName av_cfg_channelName = new NetSDKLib.AV_CFG_ChannelName();
-                boolean b = ConfigModule.GetNewDevConfig(loginId, i-1, CFG_CMD_CHANNELTITLE, av_cfg_channelName);
-                if (!b) {
-                    log.error("鑾峰彇閰嶇疆澶辫触,璇风◢鍚庨噸璇�" + getErrorCodePrint());
-                   // return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
-                }
-                String chanName = "";
-                try {
-                    chanName = new String(av_cfg_channelName.szName, "GBK").trim();
-                } catch (UnsupportedEncodingException e) {
-                    e.printStackTrace();
-                }
-                channel.setName(chanName.equals("") ? "閫氶亾" + i : chanName);
-
-                channel.setDeviceId(camera.getId());
-                channel.setChanNo(i);
-                ardChannelService.insertArdChannel(channel);
+            List<ArdChannel> ardChannelList = getChannels(camera);
+            if (ardChannelList.size() > 0) {
+                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
+                ardChannelList.stream().forEach(channel -> {
+                    ardChannelService.insertArdChannel(channel);
+                });
+                camera.setChannelList(ardChannelList);
+                //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+                batchAddVtdu(camera);
             }
-            //閰嶇疆鍒版祦濯掍綋
-            addVtdu(camera);
+            ardCamerasService.updateArdCameras(camera);
             //鍒涘缓寮曞闃熷垪
             createGuideQueue(camera);
+            //鍔犲叆宸茬櫥褰曡澶囬泦鍚�
+            GlobalVariable.loginedSet.add(camera);
             return AjaxResult.success("鐧诲綍鎴愬姛");
         } catch (Exception ex) {
             log.error("鐧诲綍寮傚父:" + ex.getMessage());
@@ -207,45 +185,49 @@
         }
     }
 
-    //娣诲姞鍒版祦濯掍綋
-    private void addVtdu(ArdCameras camera) {
-        for (int i = 1; i < camera.getChanNum() + 1; i++) {
-            String name = camera.getId() + "_" + i;
-            String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/cam/realmonitor?channel=" + i + "&subtype=0";
-            Vtdu vtdu = vtduService.selectVtduByName(name);
-            if (vtdu != null) {
-                vtduService.deleteVtduByName(name);
-            }
-            //娣诲姞鍒版祦濯掍綋
-            CameraCmd cmd = new CameraCmd(camera.getId(), i);
-            Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);
-            vtdu = new Vtdu();
-            if (videoCompressionCfg.get("videoEncType") != null) {
-                if (videoCompressionCfg.get("videoEncType").equals("鏍囧噯h264")) {
-                    vtdu.setIsCode("0");//榛樿涓嶈浆鐮�
-                } else {
-                    vtdu.setIsCode("1");//榛樿杞爜
-                }
-            } else {
-                vtdu.setIsCode("0");//榛樿涓嶈浆鐮�
-            }
-            vtdu.setRtspSource(rtspSource);
-            vtdu.setName(camera.getId() + "_" + i);
-            vtdu.setMode("1");//榛樿CPU杞В鐮�
-            vtdu.setCameraId(camera.getId());
-            vtduService.insertVtdu(vtdu);
-        }
+    //閫氶亾鎵归噺娣诲姞鍒版祦濯掍綋
+    public void batchAddVtdu(ArdCameras camera) {
+        camera.getChannelList().stream().forEach(channel -> {
+            vtduService.addChanToVtdu(camera, channel);
+        });
     }
+
 
     //鍒涘缓寮曞闃熷垪
     private void createGuideQueue(ArdCameras 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);
-            //鍚姩闃熷垪澶勭悊鍣�
-            queueHandler.process(camera.getId());
+        if (camera.getGdtype().equals("1")) {
+            if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
+                Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
+                PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
+                GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
+                //鍚姩闃熷垪澶勭悊鍣�
+                queueHandler.process(camera.getId());
+            }
         }
+    }
+
+    //鑾峰彇閫氶亾
+    public List<ArdChannel> getChannels(ArdCameras camera) {
+        if (camera.getLoginId() < 0) {
+            return new ArrayList<>();
+        }
+        LLong loginId = new LLong(camera.getLoginId());
+        List<ArdChannel> ardChannelList = new ArrayList<>();
+        for (int i = 1; i < camera.getChanNum() + 1; i++) {
+            ArdChannel channel = new ArdChannel();
+            String chanName = ConfigModule.getChannelName(loginId, i).trim();
+            channel.setName(chanName.equals("") ? "閫氶亾" + i : chanName);
+            channel.setDeviceId(camera.getId());
+            channel.setChanNo(i);
+            if (camera.getGdtype().equals("2")) {
+                //NVR杩囨护涓嶅湪绾跨殑閫氶亾
+                if (!ConfigModule.queryCameraState(loginId, camera.getChanNum(), i)) {
+                    continue;
+                }
+            }
+            ardChannelList.add(channel);
+        }
+        return ardChannelList;
     }
 
     /**
@@ -524,7 +506,9 @@
                 return AjaxResult.warn("璁惧鏈櫥褰�");
             }
             LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
-            String imagePath = FileUtils.createFile("D:/LocalCaptureTemp/" + cameraId + ".jpeg");
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String imagePath = FileUtils.createFile(tempPath + "/" + cameraId + ".jpeg");
             fCaptureReceiveCB1 m_CaptureReceiveCB = new fCaptureReceiveCB1(imagePath);
             CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);
             boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);
@@ -549,6 +533,7 @@
     @Override
     public AjaxResult localRecordStart(CameraCmd cmd) {
         try {
+            String operator = cmd.getOperator();
             String cameraId = cmd.getCameraId();
             Integer chanNo = cmd.getChanNo();
 
@@ -562,7 +547,10 @@
             //    GlobalVariable.previewMap.remove(cameraId);
             //    log.debug("鍋滄褰撳墠褰曞儚");
             //}
-            String path = FileUtils.createFile("D:/LocalRecordTemp/" + cameraId + ".mp4");
+
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String path = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
             LLong lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
             if (lRealHandle.longValue() <= 0) {
                 log.error("鍙栨祦澶辫触" + getErrorCodePrint());
@@ -586,33 +574,19 @@
     @Override
     public AjaxResult localRecordStop(CameraCmd cmd) {
         try {
+            String operator = cmd.getOperator();
             String cameraId = cmd.getCameraId();
             LLong lRealHandle = new LLong(cmd.getRecordId());
             if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                 return AjaxResult.warn("璁惧鏈櫥褰�");
             }
-
             RealPlayModule.stopRealPlay(lRealHandle);
             log.debug("鏈湴褰曞儚鍋滄");
-            String recordPath = FileUtils.createFile("D:/LocalRecordTemp/" + cameraId + ".mp4");
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String recordPath = FileUtils.createFile(tempPath + "/" + operator + "/" + cameraId + ".mp4");
             byte[] imageBytes = Files.readAllBytes(Paths.get(recordPath));
-            // OutputStream outputStream = response.getOutputStream();
-            // outputStream.write(imageBytes);
             return AjaxResult.success(imageBytes);
-            //if (GlobalVariable.previewMap.containsKey(cameraId)) {
-            //    lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
-            //    RealPlayModule.stopRealPlay(lRealHandle);
-            //    GlobalVariable.previewMap.remove(cameraId);
-            //    log.debug("鏈湴褰曞儚鍋滄");
-            //    String recordPath = FileUtils.createFile("D:/LocalRecordTemp/" + cameraId + ".mp4");
-            //    byte[] imageBytes = Files.readAllBytes(Paths.get(recordPath));
-            //   // OutputStream outputStream = response.getOutputStream();
-            //   // outputStream.write(imageBytes);
-            //    return AjaxResult.success(imageBytes);
-            //}
-            //else {
-            //    return AjaxResult.error("璁惧鏈紑濮嬪綍鍍�");
-            //}
         } catch (Exception ex) {
             log.error("鏈湴褰曞儚鍋滄寮傚父" + ex.getMessage());
             return AjaxResult.error("鏈湴褰曞儚鍋滄寮傚父" + ex.getMessage());
@@ -633,7 +607,9 @@
             String url = "";
             String cameraId = cmd.getCameraId();
             Integer chanNo = cmd.getChanNo();
-            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
             boolean enable = cmd.isEnable();
             if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                 return "";
@@ -659,6 +635,15 @@
                     GlobalVariable.previewMap.remove(cameraId);
                 }
                 log.debug("褰曞儚鍋滄");
+                //瀛樺叆minio
+                String BucketName = "record";
+                String ObjectName = IdUtils.fastSimpleUUID() + ".mp4";
+                FileInputStream stream = new FileInputStream(path);
+                boolean b = MinioUtil.uploadObject(BucketName, ObjectName, stream, stream.available(), "video/MP4");
+                if (b) {
+                    url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName);
+                    log.debug("涓婁紶鏂囦欢鎴愬姛!" + url);
+                }
             }
             return url;
         } catch (Exception ex) {
@@ -672,7 +657,9 @@
         try {
             String cameraId = cmd.getCameraId();
             Integer chanNo = cmd.getChanNo();
-            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
             if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                 return false;
             }
@@ -708,7 +695,9 @@
         String url = "";
         try {
             String cameraId = cmd.getCameraId();
-            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
+            // 鏈湴涓存椂褰曞儚鍦板潃
+            String tempPath = ARDConfig.getProfile() + Constants.LOCAL_RECORD_TEMP_PREFIX;
+            String path = FileUtils.createFile(tempPath + "/" + cameraId + ".mp4");
             if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                 return "";
             }
@@ -758,10 +747,6 @@
         return result;
     }
 
-    @Override
-    public List<ArdChannel> getIPChannelInfo(ArdCameras camera) {
-        return null;
-    }
 
     /**
      * 寮曞鐩爣浣嶇疆
@@ -781,15 +766,18 @@
             double[] cameraPositon = new double[]{cameras.getLongitude(), cameras.getLatitude(), cameras.getAltitude()};
             double[] targetPositions = cmd.getTargetPosition();
             double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150);
+            //淇淇话
+            double correctPitch = cameraSdkService.correctPitch(cmd);
+            double newt = cameraPTZ[1] + correctPitch;
             int p = (int) (cameraPTZ[0] * 10);
-            int t = (int) (cameraPTZ[1] * 10);
+            int t = (int) (newt * 10);
             int z = (int) (cameraPTZ[2]);
             boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_EXACTGOTO, p, t, z, 0);
             if (!bool) {
                 log.error("璁剧疆ptz澶辫触:" + getErrorCodePrint());
                 return AjaxResult.warn("璁剧疆ptz澶辫触:" + getErrorCodePrint());
             }
-            return AjaxResult.success("寮曞鐩爣浣嶇疆鎴愬姛");
+            return AjaxResult.success("寮曞鐩爣浣嶇疆鎴愬姛", correctPitch);
         } catch (Exception ex) {
             log.error("寮曞鐩爣浣嶇疆寮傚父:" + ex.getMessage());
             return AjaxResult.error("寮曞鐩爣浣嶇疆寮傚父:" + ex.getMessage());

--
Gitblit v1.9.3