‘liusuyi’
2024-04-22 e6ed5230c8cdebc3effd2512c587ceb36b61687b
ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DahuaSDK.java
@@ -103,7 +103,7 @@
                //删除管理通道
                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                log.error("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败:" + getErrorCodePrint());
                return AjaxResult.error(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
                return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
            }
            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
                GlobalVariable.loginMap.remove(camera.getId());
@@ -197,7 +197,7 @@
                //删除管理通道
                ardChannelService.deleteArdChannelByDeviceId(camera.getId());
                log.error("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败:" + getErrorCodePrint());
                return AjaxResult.error(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
                return AjaxResult.warn(getErrorCodePrint());
            }
            if (GlobalVariable.loginMap.containsKey(camera.getId())) {
                GlobalVariable.loginMap.remove(camera.getId());
@@ -339,7 +339,7 @@
        Integer speed = cmd.getSpeed();
        Integer code = cmd.getCode();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
        int dwStop;
@@ -406,7 +406,7 @@
        boolean bool = PtzControlModule.ptzControl(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);
        if (!bool) {
            log.error("控制失败,请稍后重试" + getErrorCodePrint());
            return AjaxResult.error(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
            return AjaxResult.warn(ErrorCode.getErrorCode(LoginModule.netsdk.CLIENT_GetLastError()));
        }
        return AjaxResult.success("云台控制成功");
    }
@@ -421,7 +421,7 @@
        Map<String, Object> ptzMap = new HashMap<>();
        String cameraId = cmd.getCameraId();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
        NetSDKLib.NET_PTZ_LOCATION_INFO dh_ptz_location_info = new NetSDKLib.NET_PTZ_LOCATION_INFO();
@@ -429,7 +429,7 @@
        if (!b) {
            int code = netsdk.CLIENT_GetLastError();
            log.error("设置ptz失败:" + getErrorCodePrint());
            return AjaxResult.error("设置ptz失败:" + getErrorCodePrint());
            return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
        }
        DecimalFormat df = new DecimalFormat("0.0");//设置保留位数
        String nPTZPan = df.format((float) dh_ptz_location_info.nPTZPan / 10);
@@ -472,12 +472,12 @@
        Integer chanNo = cmd.getChanNo();
        Map<String, Double> ptz = cmd.getPtzMap();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            if (ptz.get("p") == null || ptz.get("t") == null || ptz.get("z") == null) {
                return AjaxResult.error("ptz参数不能为空");
                return AjaxResult.warn("ptz参数不能为空");
            }
            int p = (int) (ptz.get("p") * 10);
            int t = (int) (ptz.get("t") * 10);
@@ -487,7 +487,7 @@
            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.error("设置ptz失败:" + getErrorCodePrint());
                return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("设置ptz成功");
        } catch (Exception ex) {
@@ -510,13 +510,13 @@
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        boolean bool = NetSDKLib.NETSDK_INSTANCE.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RESETZERO, 0, 0, 0, 0);
        if (!bool) {
            log.error("设置零方位角失败:" + getErrorCodePrint());
            return AjaxResult.error("设置ptz失败:" + getErrorCodePrint());
            return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
        }
        return AjaxResult.success("设置零方位角成功");
    }
@@ -556,14 +556,16 @@
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return AjaxResult.error("设备未登录");
                return AjaxResult.warn("设备未登录");
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            String imagePath = FileUtils.createFile("D:/LocalCaptureTemp/" + cameraId + ".jpeg");
            fCaptureReceiveCB1 m_CaptureReceiveCB = new fCaptureReceiveCB1(imagePath);
            CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);
            boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);
            if (b) {
            if (!b) {
                return AjaxResult.warn("本地抓图失败");
            }
                Thread.sleep(200);
                byte[] imageBytes = Files.readAllBytes(Paths.get(imagePath));
                //OutputStream outputStream = response.getOutputStream();
@@ -573,9 +575,6 @@
                //Base64.Encoder decoder = Base64.getEncoder();
                //String png_base64 = decoder.encodeToString(jpegBuffer.array());//转换成base64串
                return AjaxResult.success(imageBytes);
            } else {
                return AjaxResult.error("本地抓图失败");
            }
        } catch (Exception ex) {
            return AjaxResult.error("本地抓图异常:" + ex);
        }
@@ -589,7 +588,7 @@
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return AjaxResult.error("设备未登录");
                return AjaxResult.warn("设备未登录");
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            //if (GlobalVariable.previewMap.containsKey(cameraId)) {
@@ -617,6 +616,7 @@
            return AjaxResult.error("本地录像开始异常" + ex.getMessage());
        }
    }
    //本地录像停止
    @Override
    public AjaxResult localRecordStop(CameraCmd cmd) {
@@ -624,7 +624,7 @@
            String cameraId = cmd.getCameraId();
            LLong lRealHandle = new LLong(cmd.getRecordId());
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return AjaxResult.error("设备未登录");
                return AjaxResult.warn("设备未登录");
            }
            RealPlayModule.stopRealPlay(lRealHandle);
@@ -808,7 +808,7 @@
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -822,7 +822,7 @@
            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.error("设置ptz失败:" + getErrorCodePrint());
                return AjaxResult.warn("设置ptz失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("引导目标位置成功");
        } catch (Exception ex) {
@@ -838,14 +838,14 @@
        Integer chanNo = cmd.getChanNo();
        Integer PresetIndex = cmd.getPresetIndex();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NET_PTZ_POINT_MOVE_CONTROL, 0, PresetIndex, 0, 0);
            if (!bool) {
                log.error("转至预置点失败:" + getErrorCodePrint());
                return AjaxResult.error("转至预置点失败:" + getErrorCodePrint());
                return AjaxResult.warn("转至预置点失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("转至预置点成功");
        } catch (Exception ex) {
@@ -861,14 +861,14 @@
        Integer chanNo = cmd.getChanNo();
        Integer PresetIndex = cmd.getPresetIndex();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NET_PTZ_POINT_SET_CONTROL, 0, PresetIndex, 0, 0);
            if (!bool) {
                log.error("设置预置点失败:" + getErrorCodePrint());
                return AjaxResult.error("设置预置点失败:" + getErrorCodePrint());
                return AjaxResult.warn("设置预置点失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("设置预置点成功");
        } catch (Exception ex) {
@@ -884,7 +884,7 @@
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -909,7 +909,7 @@
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, NetSDKLib.CFG_CMD_VIDEOIN_FOCUS, cfg_video_in_focus);
            if (!bool) {
                log.error("切换聚焦模式失败:" + getErrorCodePrint());
                return AjaxResult.error("切换聚焦模式失败:" + getErrorCodePrint());
                return AjaxResult.warn("切换聚焦模式失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("切换聚焦模式成功");
        } catch (Exception ex) {
@@ -925,7 +925,7 @@
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -934,7 +934,7 @@
            boolean bool = ConfigModule.GetConfig(loginId, chanNo - 1, emCfgOpType, focusModeInfo);
            if (!bool) {
                log.error("获取聚焦模式失败:" + getErrorCodePrint());
                return AjaxResult.error("获取聚焦模式失败:" + getErrorCodePrint());
                return AjaxResult.warn("获取聚焦模式失败:" + getErrorCodePrint());
            }
            //System.out.println("配置类型:" + focusModeInfo.emCfgType);     // 具体信息,参考库里的枚举
            //System.out.println("聚焦模式:" + focusModeInfo.emFocusMode);
@@ -985,7 +985,7 @@
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -994,7 +994,7 @@
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, command, netVideoinDefogInfo);
            if (!bool) {
                log.error("切换透雾失败:" + getErrorCodePrint());
                return AjaxResult.error("切换透雾失败:" + getErrorCodePrint());
                return AjaxResult.warn("切换透雾失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("切换透雾成功");
        } catch (Exception ex) {
@@ -1008,7 +1008,7 @@
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -1016,7 +1016,7 @@
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_INFRARED_CONFIG, cfg_infrared_info);
            if (!bool) {
                log.error("切换红外失败:" + getErrorCodePrint());
                return AjaxResult.error("切换红外失败:" + getErrorCodePrint());
                return AjaxResult.warn("切换红外失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("切换红外成功");
        } catch (Exception ex) {
@@ -1032,7 +1032,7 @@
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return AjaxResult.error("设备未登录");
                return AjaxResult.warn("设备未登录");
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            NET_PTZ_LOCATION_INFO net_ptz_location_info = new NET_PTZ_LOCATION_INFO();
@@ -1040,7 +1040,7 @@
            boolean bool = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, net_ptz_location_info);
            if (!bool) {
                log.error("获取聚焦值失败:" + getErrorCodePrint());
                return AjaxResult.error("获取聚焦值失败:" + getErrorCodePrint());
                return AjaxResult.warn("获取聚焦值失败:" + getErrorCodePrint());
            }
            result = net_ptz_location_info.nFocusMapValue;
            return AjaxResult.success(result);
@@ -1058,7 +1058,7 @@
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return AjaxResult.error("设备未登录");
            return AjaxResult.warn("设备未登录");
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
@@ -1072,7 +1072,7 @@
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
            if (!bool) {
                log.error("设置聚焦值失败:" + getErrorCodePrint());
                return AjaxResult.error("设置聚焦值失败:" + getErrorCodePrint());
                return AjaxResult.warn("设置聚焦值失败:" + getErrorCodePrint());
            }
            return AjaxResult.success("设置聚焦值成功");
        } catch (Exception ex) {
@@ -1156,14 +1156,14 @@
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return AjaxResult.error("设备未登录");
                return AjaxResult.warn("设备未登录");
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            DH_OUT_PTZ_VIEW_RANGE_STATUS dh_out_ptz_view_range_status = new DH_OUT_PTZ_VIEW_RANGE_STATUS();
            boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_VIEW_RANGE, dh_out_ptz_view_range_status);
            if (!b) {
                log.error("获取云台可视域失败:" + getErrorCodePrint());
                return AjaxResult.error("获取云台可视域失败:" + getErrorCodePrint());
                return AjaxResult.warn("获取云台可视域失败:" + getErrorCodePrint());
            }
            float nAngelH = (float) dh_out_ptz_view_range_status.nAngelH / 10;
            float nAngelV = (float) dh_out_ptz_view_range_status.nAngelV / 10;
@@ -1226,9 +1226,11 @@
    // 抓图接收回调:当抓图成功,sdk会调用该函数
    public static class fCaptureReceiveCB1 implements NetSDKLib.fSnapRev {
        private String picPath;
        public fCaptureReceiveCB1(String picPath) {
            this.picPath = picPath;
        }
        public void invoke(LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
            if (pBuf != null && RevLen > 0) {
                byte[] buf = pBuf.getByteArray(0, RevLen);