Merge remote-tracking branch 'origin/master'

aijinhui

2023-11-07 1ccdcb4a890687d59b272f5397e8b41ae4ce2254

 ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DhSdkStrategy.java

ÎļþÃû´Ó ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/service/impl/DhClientServiceImpl.java ÐÞ¸Ä
@@ -1,941 +1,1063 @@
package com.ruoyi.utils.sdk.dhsdk.service.impl;



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.file.FileUtils;

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

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

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

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

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

import com.ruoyi.device.channel.domain.ArdChannel;

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

import com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib;

import com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.LLong;

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_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.ruoyi.utils.sdk.dhsdk.service.IDhClientService;

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

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.sun.jna.Pointer;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Service;



import javax.annotation.Resource;

import java.io.*;

import java.text.DecimalFormat;

import java.util.*;

import java.util.concurrent.PriorityBlockingQueue;



import static com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib.*;

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;

import static com.ruoyi.utils.sdk.dhsdk.module.LoginModule.netsdk;





/**

 * @ClassName DhSdkServiceImpl

 * @Description:

 * @Author åˆ˜è‹ä¹‰

 * @Date 2023/10/13 21:19

 * @Version 1.0

 */

@Service

@Slf4j(topic = "dhSdk")

public class DhClientServiceImpl implements IDhClientService {

    @Resource

    private IArdCamerasService ardCamerasService;

    @Resource

    private IArdChannelService ardChannelService;

    @Resource

    private IVtduService vtduService;

    @Value("${minio.endpoint}")

    private String minioEndPoint;

    private final Object lock = new Object();



    // è®¾å¤‡æ–­çº¿é€šçŸ¥å›žè°ƒ

    private static DisConnect disConnect = new DisConnect();

    // ç½‘络连接恢复

    private static HaveReConnect haveReConnect = new HaveReConnect();





    /**

     * ç™»å½•

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:28:13

     */

    @Override

    public Boolean login(ArdCameras camera) {

        LoginModule.init(disConnect, haveReConnect);

        NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();

        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.setState("0");

            ardCamerasService.updateArdCameras(camera);

            return false;

        }

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

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

        }

        //删除管理通道

        ardChannelService.deleteArdChannelByDeviceId(camera.getId());

        camera.setState("1");

        camera.setChanNum(m_stDeviceInfo.byChanNum);

        camera.setStartDChan(1);

        camera.setLoginId((int) 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();

            AV_CFG_ChannelName av_cfg_channelName = new AV_CFG_ChannelName();

            boolean b = ConfigModule.GetNewDevConfig(loginId, i - 1, CFG_CMD_CHANNELTITLE, av_cfg_channelName);

            if (b) {

                String chanName = null;

                try {

                    chanName = new String(av_cfg_channelName.szName, "GBK").trim();

                } catch (UnsupportedEncodingException e) {

                    e.printStackTrace();

                }

                channel.setName(chanName);

            } else {

                channel.setName("通道" + i);

            }

            channel.setDeviceId(camera.getId());

            channel.setChanNo(i);

            ardChannelService.insertArdChannel(channel);

        }

        //配置到流媒体

        for (int i = 1; i < m_stDeviceInfo.byChanNum + 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);

        }



        //创建引导队列

        if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {

            Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();

            PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);

            GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);

        }

        return true;

    }



    /**

     * æ³¨é”€

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:28:13

     */

    @Override

    public Boolean logout(String cameraId) {

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        return LoginModule.logout(loginId);

    }



    /**

     * æ˜¯å¦åœ¨çº¿æ£€æµ‹

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:28:13

     */

    @Override

    public boolean isOnLine(CameraCmd cmd) {

        try {

            String cameraId = cmd.getCameraId();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return false;

            }

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            NetSDKLib.NET_WORKSTATE dh_ptz_location_info = new NetSDKLib.NET_WORKSTATE();

            boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_ONLINE, dh_ptz_location_info);

            if (!b) {

                return false;

            }

        } catch (Exception ex) {

            log.error("检测在线异常：" + ex.getMessage());

            return false;

        }

        return true;

    }



    /**

     * äº‘台控制

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:28:13

     */

    @Override

    @SdkOperate

    public boolean pTZControl(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

        Integer chanNo = cmd.getChanNo();

        Integer speed = cmd.getSpeed();

        Integer code = cmd.getCode();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        int dwStop;

        if (enable) {

            dwStop = 0;//开启

        } else {

            dwStop = 1;//关闭

        }

        int dwPTZCommand = -1;

        switch (code) {

            /*方向*/

            case 1:

                dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTTOP;

                break;

            case 2:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_UP_CONTROL;

                break;

            case 3:

                dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTTOP;

                break;

            case 4:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_LEFT_CONTROL;

                break;

            case 5:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_POINT_LOOP_CONTROL;

                break;

            case 6:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_RIGHT_CONTROL;

                break;

            case 7:

                dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTDOWN;

                break;

            case 8:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_DOWN_CONTROL;

                break;

            case 9:

                dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTDOWN;

                break;

            /*焦距*/

            case 10:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_ZOOM_ADD_CONTROL;

                break;

            case 11:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_ZOOM_DEC_CONTROL;

                break;

            /*焦点*/

            case 12:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_FOCUS_ADD_CONTROL;

                break;

            case 13:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_FOCUS_DEC_CONTROL;

                break;

            /*光圈*/

            case 14:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_APERTURE_ADD_CONTROL;

                break;

            case 15:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_APERTURE_DEC_CONTROL;

                break;

            case 16:

                dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_LAMP_CONTROL;

                break;

        }

        boolean bool = PtzControlModule.ptzControl(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);

        if (!bool) {

            log.error("控制失败,请稍后重试" + getErrorCodePrint());

        }

        return bool;

    }



    /**

     * èŽ·å–PTZ值

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:28:13

     */

    @Override

    public Map<String, Object> getPtz(CameraCmd cmd) {

        Map<String, Object> ptzMap = new HashMap<>();

        String cameraId = cmd.getCameraId();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return null;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        NetSDKLib.NET_PTZ_LOCATION_INFO dh_ptz_location_info = new NetSDKLib.NET_PTZ_LOCATION_INFO();

        boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, dh_ptz_location_info);

        if (b) {

            DecimalFormat df = new DecimalFormat("0.0");//设置保留位数

            String nPTZPan = df.format((float) dh_ptz_location_info.nPTZPan / 10);

            float t = (float) dh_ptz_location_info.nPTZTilt / 10 * -1;

            String nPTZTilt = df.format(t < 0 ? t + 360 : t);

            String nPTZZoom = df.format((float) dh_ptz_location_info.nPTZZoom);

            ptzMap.put("p", nPTZPan);

            ptzMap.put("t", nPTZTilt);

            ptzMap.put("z", nPTZZoom);

        }

        return ptzMap;

    }



    /**

     * @描述 è®¾ç½®ptz信息

     * @参数 [userId, channelNum]

     * @返回值 boolean

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

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

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

     */

    @Override

    @SdkOperate

    public boolean setPtz(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        Map<String, Double> ptz = cmd.getPtzMap();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            int p = (int) (ptz.get("p") * 10);

            int t = (int) (ptz.get("t") * 10);

            t = t > 900 ? 3600 - t : t * -1;



            int z = ptz.get("z").intValue() == 0 ? 1 : ptz.get("z").intValue();

            boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_EXACTGOTO, p, t, z, 0);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error(ex.getMessage());

            return false;

        }

    }



    /**

     * @描述 è®¾ç½®é›¶æ–¹ä½è§’

     * @参数 [userId, channelNum]

     * @返回值 boolean

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

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

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

     */

    @Override

    public boolean setZeroPtz(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

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

    }



    /**

     * @描述 æˆªå›¾ å­˜æœåŠ¡å™¨

     * @参数 [cameraId, channelNum]

     * @返回值 java.lang.String

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

     * @创建时间 2023/2/2 14:59

     * @修改人和其它信息

     */

    @Override

    public String picCutCate(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return "";

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        String bucketName = "pic";

        String picUrl = "";

        String bucketObject = "/capture/" + IdUtils.simpleUUID() + ".jpeg";

        fCaptureReceiveCB m_CaptureReceiveCB = new fCaptureReceiveCB(minioEndPoint, bucketName, bucketObject);

        CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);

        boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);

        if (b) {

            picUrl = minioEndPoint + "/" + bucketName + bucketObject;

        }

        return picUrl;



    }



    /**

     * @描述 çŸ­æ—¶å½•åƒ

     * @参数 [userId, channelNum, enable]

     * @返回值 void

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

     * @创建时间 2023/1/20 11:18

     * @修改人和其它信息

     */

    @Override

    public String record(CameraCmd cmd) {

        try {

            String url = "";

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");

            boolean enable = cmd.isEnable();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return "";

            }

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);



            if (enable) {

                LLong lRealHandle = new LLong(0);

                if (!GlobalVariable.previewMap.containsKey(cameraId)) {

                    lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);

                    if (lRealHandle.longValue() <= 0) {

                        log.error("取流失败" + getErrorCodePrint());

                        return "";

                    }

                    log.debug("取流成功");

                    GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());

                }

                log.debug("录像开始");

            } else {

                if (GlobalVariable.previewMap.containsKey(cameraId)) {

                    LLong lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));

                    RealPlayModule.stopRealPlay(lRealHandle);

                    GlobalVariable.previewMap.remove(cameraId);

                }

                log.debug("录像停止");

            }

            return url;

        } catch (Exception ex) {

            log.error("录像异常" + ex.getMessage());

            return "";

        }

    }



    @Override

    public boolean recordStart(CameraCmd cmd) {

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return false;

            }

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            LLong lRealHandle;

            if (GlobalVariable.previewMap.containsKey(cameraId)) {

                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));

                RealPlayModule.stopRealPlay(lRealHandle);

                GlobalVariable.previewMap.remove(cameraId);

                log.debug("停止当前录像");

            }

            lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);

            if (lRealHandle.longValue() <= 0) {

                log.error("取流失败" + getErrorCodePrint());

            }

            log.debug("取流成功");

            GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());

            GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());

            //if (!netsdk.CLIENT_SaveRealData(lRealHandle, path)) {

            //    log.error("保存视频文件到临时文件夹失败 é”™è¯¯ç ä¸º:  " +getErrorCodePrint());

            //    return false;

            //}

            log.debug("录像开始");

            return true;

        } catch (Exception ex) {

            log.error("开始录像异常" + ex.getMessage());

            return false;

        }

    }



    @Override

    public String recordStopToMinio(CameraCmd cmd) {

        String url = "";

        try {

            String cameraId = cmd.getCameraId();

            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return "";

            }

            LLong lRealHandle;

            if (GlobalVariable.previewMap.containsKey(cameraId)) {

                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));

                RealPlayModule.stopRealPlay(lRealHandle);

                GlobalVariable.previewMap.remove(cameraId);

                log.debug("停止当前录像");

            }

            //存入minio

            String BucketName = cmd.getRecordBucketName();

            String ObjectName = cmd.getRecordObjectName() + ".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) {

            log.error("录像异常" + ex.getMessage());

            return "";

        }

    }



    @Override

    public boolean recordStopNotToMinio(CameraCmd cmd) {

        boolean result = false;

        try {

            String cameraId = cmd.getCameraId();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return false;

            }

            LLong lRealHandle;

            if (GlobalVariable.previewMap.containsKey(cameraId)) {

                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));

                RealPlayModule.stopRealPlay(lRealHandle);

                GlobalVariable.previewMap.remove(cameraId);

                log.debug("停止当前录像");

            }



            result = true;

        } catch (Exception ex) {

            log.error("录像异常" + ex.getMessage());

        }

        return result;

    }



    /**

     * å¼•å¯¼ç›®æ ‡ä½ç½®

     * åˆ˜è‹ä¹‰

     * 2023/10/17 8:27:48

     */

    @Override

    public boolean guideTargetPosition(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            ArdCameras cameras = ardCamerasService.selectArdCamerasById(cameraId);

            double[] cameraPositon = new double[]{cameras.getLongitude(), cameras.getLatitude(), cameras.getAltitude()};

            double[] targetPositions = cmd.getTargetPosition();

            double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150);

            int p = (int) (cameraPTZ[0] * 10);

            int t = (int) (cameraPTZ[1] * 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("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error("引导异常:" + ex.getMessage());

            return false;

        }

    }



    //转至预置点

    @Override

    public boolean gotoPreset(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        Integer PresetIndex = cmd.getPresetIndex();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

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

        } catch (Exception ex) {

            log.error("转至预置点异常:" + ex.getMessage());

            return false;

        }

    }



    @Override

    //设置预置位

    public boolean setPreset(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        Integer PresetIndex = cmd.getPresetIndex();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

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

        } catch (Exception ex) {

            log.error("设置预置点异常:" + ex.getMessage());

            return false;

        }

    }



    //切换聚焦模式

    @Override

    public boolean controlFocusMode(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        boolean enable = cmd.isEnable();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            CFG_VIDEO_IN_FOCUS cfg_video_in_focus = new CFG_VIDEO_IN_FOCUS();

            cfg_video_in_focus.nVideoInFocusRealNum = 3;//配置使用个数

            for (int i = 0; i < 3; i++) {

                cfg_video_in_focus.stVideoInFocusUnit[i].nSensitivity = 1;//聚焦灵敏度, 0-高, 1-默认, 2-低



                cfg_video_in_focus.stVideoInFocusUnit[i].nIRCorrection = 2;//红外光聚焦修正, 0-不修正, 1-修正, 2-自动修正

                cfg_video_in_focus.stVideoInFocusUnit[i].nFocusLimit = 10000;//聚焦极限值, å•ä½æ¯«ç±³

                if (enable) {//聚焦模式, 0-关闭, 1-辅助聚焦, 2-自动聚焦, 3-半自动聚焦, 4-手动聚焦

                    cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 4;//手动聚焦

                    cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 0;//聚焦极限Manual

                    log.debug("当前为手动聚焦模式");

                } else {

                    cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 2;//自动聚焦

                    cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 1;//聚焦极限Auto

                    log.debug("当前为自动聚焦模式");

                }

            }

            cfg_video_in_focus.nChannelIndex = chanNo - 1;

            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, NetSDKLib.CFG_CMD_VIDEOIN_FOCUS, cfg_video_in_focus);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error("切换聚焦模式异常:" + ex.getMessage());

            return false;

        }

    }



    @Override

    public String getFocusMode(CameraCmd cmd) {

        String mode = "";

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return "";

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            NET_VIDEOIN_FOCUSMODE_INFO focusModeInfo = new NET_VIDEOIN_FOCUSMODE_INFO();

            int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VIDEOIN_FOCUSMODE;

            boolean bool = ConfigModule.GetConfig(loginId, chanNo - 1, emCfgOpType, focusModeInfo);

            if (!bool) {

                log.error("获取失败,请稍后重试" + getErrorCodePrint());

            }

            System.out.println("配置类型:" + focusModeInfo.emCfgType);     // å…·ä½“信息，参考库里的枚举

            System.out.println("聚焦模式:" + focusModeInfo.emFocusMode);

            switch (focusModeInfo.emFocusMode) {

                case 0:

                    mode = "关闭";

                    break;

                case 1:

                    mode = "辅助聚焦";

                    break;

                case 2:

                    mode = "自动聚焦";

                    break;

                case 3:

                    mode = "半自动聚焦";

                    break;

                case 4:

                    mode = "手动聚焦";

                    break;

            }



        } catch (Exception ex) {

            log.error("获取聚焦模式异常:" + ex.getMessage());



        }

        return mode;

    }



    //透雾

    @Override

    public boolean controlDefogcfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        boolean enable = cmd.isEnable();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            String command = EM_NEW_CONFIG.CFG_CMD_VIDEOINDEFOG.getValue();

            //CFG_VIDEOINDEFOG_LIST cfg_videoindefog_list=new CFG_VIDEOINDEFOG_LIST();

            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, command, null);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error("切换透雾异常:" + ex.getMessage());

            return false;

        }

    }



    //红外

    @Override

    public boolean controlInfrarecfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        boolean enable = cmd.isEnable();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();

            cfg_lighting_info.nLightingDetailNum = 1;

            if (enable) {

                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;

            } else {

                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;

            }

            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error("切换红外异常:" + ex.getMessage());

            return false;

        }

    }



    //获取聚焦值

    @Override

    public int getFocusPos(CameraCmd cmd) {

        int result = 0;

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return result;

            }

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            NET_PTZ_LOCATION_INFO net_ptz_location_info = new NET_PTZ_LOCATION_INFO();

            net_ptz_location_info.nChannelID = chanNo - 1;

            boolean bool = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, net_ptz_location_info);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            result = net_ptz_location_info.nFocusMapValue;

        } catch (Exception ex) {

            log.error("获取聚焦值异常:" + ex.getMessage());

        }

        return result;

    }



    //设置聚焦值

    @Override

    public boolean setFocusPos(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        Integer chanNo = cmd.getChanNo();

        boolean enable = cmd.isEnable();

        if (!GlobalVariable.loginMap.containsKey(cameraId)) {

            return false;

        }

        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

        try {

            CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();

            cfg_lighting_info.nLightingDetailNum = 1;

            if (enable) {

                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;

            } else {

                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;

            }

            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);

            if (!bool) {

                log.error("控制失败,请稍后重试" + getErrorCodePrint());

            }

            return bool;

        } catch (Exception ex) {

            log.error("设置聚焦值异常:" + ex.getMessage());

            return false;

        }

    }



    //获取码流压缩参数

    @Override

    public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {

        Map<String, Object> map = new HashMap<>();

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return null;

            }

            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();

            cfg_encode_info.nChannelID = chanNo - 1;

            boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);

            if (b) {

                int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式

                String videoEncType = "";

                switch (emCompression) {

                    case 0:

                        videoEncType = "MPEG4";

                        break;

                    case 1:

                        videoEncType = "MS-MPEG4";

                        break;

                    case 2:

                        videoEncType = "MPEG2";

                        break;

                    case 3:

                        videoEncType = "MPEG1";

                        break;

                    case 4:

                        videoEncType = "H.263";

                        break;

                    case 5:

                        videoEncType = "MJPG";

                        break;

                    case 6:

                        videoEncType = "FCC-MPEG4";

                        break;

                    case 7:

                        videoEncType = "标准h264";

                        break;

                    case 8:

                        videoEncType = "标准h265";

                        break;

                    case 9:

                        videoEncType = "SVAC";

                        break;

                    default:

                        videoEncType = "未知";

                        break;

                }

                int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;

                int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;

                int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;

                String resolution = nWidth + "*" + nHeight;

                float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;

                map.put("resolution", resolution);//分辨率

                map.put("videoBitrate", String.valueOf(nBitRate));//比特率

                map.put("videoEncType", videoEncType);//编码

                map.put("nFrameRate", String.valueOf(nFrameRate));//帧率

            }

        } catch (Exception ex) {

            log.error("取码流压缩参数异常:" + ex.getMessage());

        }

        return map;

    }



    //获取GIS信息数据

    @Override

    public Map<String, Object> getGisInfo(CameraCmd cmd) {

        Map<String, Object> map = new HashMap<>();

        try {

            String cameraId = cmd.getCameraId();

            Integer chanNo = cmd.getChanNo();

            if (!GlobalVariable.loginMap.containsKey(cameraId)) {

                return null;

            }

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

                float nAngelH = (float) dh_out_ptz_view_range_status.nAngelH / 10;

                float nAngelV = (float) dh_out_ptz_view_range_status.nAngelV / 10;

                map = getPtz(cmd);//获取ptz

                map.put("fHorFieldAngle", nAngelH);// æ°´å¹³è§†åœºè§’

                map.put("fVerFieldAngle", nAngelV);// åž‚直视场角

            }

        } catch (Exception ex) {

            log.error("获取云台可视域异常" + ex.getMessage());

        }

        return map;

    }



    // è®¾å¤‡æ–­çº¿å›žè°ƒ: å½“设备出现断线时，SDK会调用该函数

    private static class DisConnect implements NetSDKLib.fDisConnect {

        public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {

            log.warn("Device[" + pchDVRIP + ":" + nDVRPort + "] DisConnect!");

        }

    }



    // ç½‘络连接恢复回调:设备重连成功回调，当已断线的设备重连成功时，SDK会调用该函数

    private static class HaveReConnect implements NetSDKLib.fHaveReConnect {

        @Override

        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {

            log.warn("ReConnect Device[" + pchDVRIP + ":" + nDVRPort + "]");

        }

    }



    // æŠ“图接收回调:当抓图成功，sdk会调用该函数

    public static class fCaptureReceiveCB implements NetSDKLib.fSnapRev {

        private String minioEndPoint;

        private String ObjectName;

        private String bucketName;



        public fCaptureReceiveCB(String minioEndPoint, String bucketName, String ObjectName) {

            this.minioEndPoint = minioEndPoint;

            this.bucketName = bucketName;

            this.ObjectName = ObjectName;

        }



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

                //存储到minio

                InputStream input = new ByteArrayInputStream(buf);



                try {

                    boolean b = MinioUtil.uploadObject(bucketName, ObjectName, input, input.available(), MimeTypeUtils.IMAGE_JPEG);

                    if (b) {

                        String url = minioEndPoint + "/" + bucketName + ObjectName;

                        log.debug("上传文件成功!" + url);

                    }

                } catch (IOException ex) {

                    log.error("上传文件异常：" + ex.getMessage());

                }

            }

        }

    }

package com.ruoyi.utils.sdk.dhsdk.service.impl;

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.file.FileUtils;
import com.ruoyi.common.utils.file.MimeTypeUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
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.camera.service.IArdCamerasService;
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.dhsdk.lib.NetSDKLib;
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_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.Pointer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.io.*;
import java.text.DecimalFormat;
import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
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;
import static com.ruoyi.utils.sdk.dhsdk.module.LoginModule.netsdk;

/**
 * @Description: å¤§åŽsdk策略
 * @ClassName: DhSdkStrategy
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´11月07日10:51:09
 **/
@Slf4j(topic = "dhSdk")
@Service
public class DhSdkStrategy implements SdkStrategy {

    @Resource
    private IArdCamerasService ardCamerasService;
    @Resource
    private IArdChannelService ardChannelService;
    @Resource
    private IVtduService vtduService;
    @Value("${minio.endpoint}")
    private String minioEndPoint;


    // è®¾å¤‡æ–­çº¿é€šçŸ¥å›žè°ƒ
    private static DisConnect disConnect = new DisConnect();
    // ç½‘络连接恢复
    private static HaveReConnect haveReConnect = new HaveReConnect();


    /**
     * ç™»å½•
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:28:13
     * @return
     */
    @Override

    public boolean login(ArdCameras camera) {
        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.setState("0");
            ardCamerasService.updateArdCameras(camera);
            //删除管理通道
            ardChannelService.deleteArdChannelByDeviceId(camera.getId());
            return false;
        }
        if (GlobalVariable.loginMap.containsKey(camera.getId())) {
            GlobalVariable.loginMap.remove(camera.getId());
        }
        //删除管理通道
        ardChannelService.deleteArdChannelByDeviceId(camera.getId());
        camera.setState("1");
        camera.setChanNum(m_stDeviceInfo.byChanNum);
        camera.setStartDChan(1);
        camera.setLoginId((int) 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) {
                String chanName = null;
                try {
                    chanName = new String(av_cfg_channelName.szName, "GBK").trim();
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                channel.setName(chanName);
            } else {
                channel.setName("通道" + i);
            }
            channel.setDeviceId(camera.getId());
            channel.setChanNo(i);
            ardChannelService.insertArdChannel(channel);
        }
        //配置到流媒体
        for (int i = 1; i < m_stDeviceInfo.byChanNum + 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);
        }

        //创建引导队列
        if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
            Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
            PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
            GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
        }
        return true;
    }

    @Override
    @Async("loginExecutor")
    public void asyncLogin(ArdCameras camera){
        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.setState("0");
            ardCamerasService.updateArdCameras(camera);
            //删除管理通道
            ardChannelService.deleteArdChannelByDeviceId(camera.getId());
            return;
        }
        if (GlobalVariable.loginMap.containsKey(camera.getId())) {
            GlobalVariable.loginMap.remove(camera.getId());
        }
        //删除管理通道
        ardChannelService.deleteArdChannelByDeviceId(camera.getId());
        camera.setState("1");
        camera.setChanNum(m_stDeviceInfo.byChanNum);
        camera.setStartDChan(1);
        camera.setLoginId((int) 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) {
                String chanName = null;
                try {
                    chanName = new String(av_cfg_channelName.szName, "GBK").trim();
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                channel.setName(chanName);
            } else {
                channel.setName("通道" + i);
            }
            channel.setDeviceId(camera.getId());
            channel.setChanNo(i);
            ardChannelService.insertArdChannel(channel);
        }
        //配置到流媒体
        for (int i = 1; i < m_stDeviceInfo.byChanNum + 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);
        }

        //创建引导队列
        if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
            Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
            PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
            GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
        }
    }

    /**
     * æ³¨é”€
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:28:13
     * @return
     */
    @Override
    public boolean logout(String cameraId) {
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
        return LoginModule.logout(loginId);
    }

    /**
     * æ˜¯å¦åœ¨çº¿æ£€æµ‹
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:28:13
     */
    @Override
    public boolean isOnLine(CameraCmd cmd) {
        try {
            String cameraId = cmd.getCameraId();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return false;
            }
            NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
            NetSDKLib.NET_WORKSTATE dh_ptz_location_info = new NetSDKLib.NET_WORKSTATE();
            boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_ONLINE, dh_ptz_location_info);
            if (!b) {
                return false;
            }
        } catch (Exception ex) {
            log.error("检测在线异常：" + ex.getMessage());
            return false;
        }
        return true;
    }


    /**
     * äº‘台控制
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:28:13
     */
    @Override
    public boolean pTZControl(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        boolean enable = cmd.isEnable();
        Integer chanNo = cmd.getChanNo();
        Integer speed = cmd.getSpeed();
        Integer code = cmd.getCode();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
        int dwStop;
        if (enable) {
            dwStop = 0;//开启
        } else {
            dwStop = 1;//关闭
        }
        int dwPTZCommand = -1;
        switch (code) {
            /*方向*/
            case 1:
                dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTTOP;
                break;
            case 2:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_UP_CONTROL;
                break;
            case 3:
                dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTTOP;
                break;
            case 4:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LEFT_CONTROL;
                break;
            case 5:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_LOOP_CONTROL;
                break;
            case 6:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_RIGHT_CONTROL;
                break;
            case 7:
                dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTDOWN;
                break;
            case 8:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_DOWN_CONTROL;
                break;
            case 9:
                dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTDOWN;
                break;
            /*焦距*/
            case 10:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_ADD_CONTROL;
                break;
            case 11:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_DEC_CONTROL;
                break;
            /*焦点*/
            case 12:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_ADD_CONTROL;
                break;
            case 13:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_DEC_CONTROL;
                break;
            /*光圈*/
            case 14:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_ADD_CONTROL;
                break;
            case 15:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_DEC_CONTROL;
                break;
            case 16:
                dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LAMP_CONTROL;
                break;
        }
        boolean bool = PtzControlModule.ptzControl(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);
        if (!bool) {
            log.error("控制失败,请稍后重试" + getErrorCodePrint());
        }
        return bool;
    }

    /**
     * èŽ·å–PTZ值
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:28:13
     */
    @Override
    public Map<String, Object> getPtz(CameraCmd cmd) {
        Map<String, Object> ptzMap = new HashMap<>();
        String cameraId = cmd.getCameraId();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return null;
        }
        NetSDKLib.LLong loginId = (NetSDKLib.LLong) GlobalVariable.loginMap.get(cameraId);
        NetSDKLib.NET_PTZ_LOCATION_INFO dh_ptz_location_info = new NetSDKLib.NET_PTZ_LOCATION_INFO();
        boolean b = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, dh_ptz_location_info);
        if (b) {
            DecimalFormat df = new DecimalFormat("0.0");//设置保留位数
            String nPTZPan = df.format((float) dh_ptz_location_info.nPTZPan / 10);
            float t = (float) dh_ptz_location_info.nPTZTilt / 10 * -1;
            String nPTZTilt = df.format(t < 0 ? t + 360 : t);
            String nPTZZoom = df.format((float) dh_ptz_location_info.nPTZZoom);
            ptzMap.put("p", nPTZPan);
            ptzMap.put("t", nPTZTilt);
            ptzMap.put("z", nPTZZoom);
        }
        return ptzMap;
    }

    @Override
    public Map<String, Object> getPtzScope(CameraCmd cmd) {
        return null;
    }

    /**
     * @描述 è®¾ç½®ptz信息
     * @参数 [userId, channelNum]
     * @返回值 boolean
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/17 16:36
     * @修改人和其它信息 æ³¨æ„ä¿¯ä»°è§’度负值需要加上360得到的正值进行设置
     */
    @Override
    public boolean setPtz(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        Map<String, Double> ptz = cmd.getPtzMap();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            int p = (int) (ptz.get("p") * 10);
            int t = (int) (ptz.get("t") * 10);
            t = t > 900 ? 3600 - t : t * -1;

            int z = ptz.get("z").intValue() == 0 ? 1 : ptz.get("z").intValue();
            boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_EXACTGOTO, p, t, z, 0);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error(ex.getMessage());
            return false;
        }
    }

    /**
     * @描述 è®¾ç½®é›¶æ–¹ä½è§’
     * @参数 [userId, channelNum]
     * @返回值 boolean
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/17 16:36
     * @修改人和其它信息 æ³¨æ„ä¿¯ä»°è§’度负值需要加上360得到的正值进行设置
     */
    @Override
    public boolean setZeroPtz(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        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 bool;
    }

    /**
     * @描述 æˆªå›¾ å­˜æœåŠ¡å™¨
     * @参数 [cameraId, channelNum]
     * @返回值 java.lang.String
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/2 14:59
     * @修改人和其它信息
     */
    @Override
    public String picCutCate(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return "";
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        String bucketName = "pic";
        String picUrl = "";
        String bucketObject = "/capture/" + IdUtils.simpleUUID() + ".jpeg";
        fCaptureReceiveCB m_CaptureReceiveCB = new fCaptureReceiveCB(minioEndPoint, bucketName, bucketObject);
        CapturePictureModule.setSnapRevCallBack(m_CaptureReceiveCB);
        boolean b = CapturePictureModule.remoteCapturePicture(loginId, chanNo - 1);
        if (b) {
            picUrl = minioEndPoint + "/" + bucketName + bucketObject;
        }
        return picUrl;

    }

    /**
     * @描述 çŸ­æ—¶å½•åƒ
     * @参数 [userId, channelNum, enable]
     * @返回值 void
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/1/20 11:18
     * @修改人和其它信息
     */
    @Override
    public String record(CameraCmd cmd) {
        try {
            String url = "";
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
            boolean enable = cmd.isEnable();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return "";
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);

            if (enable) {
                LLong lRealHandle = new LLong(0);
                if (!GlobalVariable.previewMap.containsKey(cameraId)) {
                    lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
                    if (lRealHandle.longValue() <= 0) {
                        log.error("取流失败" + getErrorCodePrint());
                        return "";
                    }
                    log.debug("取流成功");
                    GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
                }
                log.debug("录像开始");
            } else {
                if (GlobalVariable.previewMap.containsKey(cameraId)) {
                    LLong lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
                    RealPlayModule.stopRealPlay(lRealHandle);
                    GlobalVariable.previewMap.remove(cameraId);
                }
                log.debug("录像停止");
            }
            return url;
        } catch (Exception ex) {
            log.error("录像异常" + ex.getMessage());
            return "";
        }
    }

    @Override
    public boolean recordStart(CameraCmd cmd) {
        try {
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return false;
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            LLong lRealHandle;
            if (GlobalVariable.previewMap.containsKey(cameraId)) {
                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
                RealPlayModule.stopRealPlay(lRealHandle);
                GlobalVariable.previewMap.remove(cameraId);
                log.debug("停止当前录像");
            }
            lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
            if (lRealHandle.longValue() <= 0) {
                log.error("取流失败" + getErrorCodePrint());
            }
            log.debug("取流成功");
            GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
            GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());
            //if (!netsdk.CLIENT_SaveRealData(lRealHandle, path)) {
            //    log.error("保存视频文件到临时文件夹失败 é”™è¯¯ç ä¸º:  " +getErrorCodePrint());
            //    return false;
            //}
            log.debug("录像开始");
            return true;
        } catch (Exception ex) {
            log.error("开始录像异常" + ex.getMessage());
            return false;
        }
    }

    @Override
    public String recordStopToMinio(CameraCmd cmd) {
        String url = "";
        try {
            String cameraId = cmd.getCameraId();
            String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4");
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return "";
            }
            LLong lRealHandle;
            if (GlobalVariable.previewMap.containsKey(cameraId)) {
                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
                RealPlayModule.stopRealPlay(lRealHandle);
                GlobalVariable.previewMap.remove(cameraId);
                log.debug("停止当前录像");
            }
            //存入minio
            String BucketName = cmd.getRecordBucketName();
            String ObjectName = cmd.getRecordObjectName() + ".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) {
            log.error("录像异常" + ex.getMessage());
            return "";
        }
    }

    @Override
    public boolean recordStopNotToMinio(CameraCmd cmd) {
        boolean result = false;
        try {
            String cameraId = cmd.getCameraId();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return false;
            }
            LLong lRealHandle;
            if (GlobalVariable.previewMap.containsKey(cameraId)) {
                lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
                RealPlayModule.stopRealPlay(lRealHandle);
                GlobalVariable.previewMap.remove(cameraId);
                log.debug("停止当前录像");
            }

            result = true;
        } catch (Exception ex) {
            log.error("录像异常" + ex.getMessage());
        }
        return result;
    }

    @Override
    public List<ArdChannel> getCameraChannelList(ArdCameras camera) {
        return null;
    }

    /**
     * å¼•å¯¼ç›®æ ‡ä½ç½®
     * åˆ˜è‹ä¹‰
     * 2023/10/17 8:27:48
     */
    @Override
    public boolean guideTargetPosition(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            ArdCameras cameras = ardCamerasService.selectArdCamerasById(cameraId);
            double[] cameraPositon = new double[]{cameras.getLongitude(), cameras.getLatitude(), cameras.getAltitude()};
            double[] targetPositions = cmd.getTargetPosition();
            double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150);
            int p = (int) (cameraPTZ[0] * 10);
            int t = (int) (cameraPTZ[1] * 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("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error("引导异常:" + ex.getMessage());
            return false;
        }
    }

    //转至预置点
    @Override
    public boolean gotoPreset(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        Integer PresetIndex = cmd.getPresetIndex();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        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 bool;
        } catch (Exception ex) {
            log.error("转至预置点异常:" + ex.getMessage());
            return false;
        }
    }

    @Override
    //设置预置位
    public boolean setPreset(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        Integer PresetIndex = cmd.getPresetIndex();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        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 bool;
        } catch (Exception ex) {
            log.error("设置预置点异常:" + ex.getMessage());
            return false;
        }
    }

    //切换聚焦模式
    @Override
    public boolean controlFocusMode(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            CFG_VIDEO_IN_FOCUS cfg_video_in_focus = new CFG_VIDEO_IN_FOCUS();
            cfg_video_in_focus.nVideoInFocusRealNum = 3;//配置使用个数
            for (int i = 0; i < 3; i++) {
                cfg_video_in_focus.stVideoInFocusUnit[i].nSensitivity = 1;//聚焦灵敏度, 0-高, 1-默认, 2-低

                cfg_video_in_focus.stVideoInFocusUnit[i].nIRCorrection = 2;//红外光聚焦修正, 0-不修正, 1-修正, 2-自动修正
                cfg_video_in_focus.stVideoInFocusUnit[i].nFocusLimit = 10000;//聚焦极限值, å•ä½æ¯«ç±³
                if (enable) {//聚焦模式, 0-关闭, 1-辅助聚焦, 2-自动聚焦, 3-半自动聚焦, 4-手动聚焦
                    cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 4;//手动聚焦
                    cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 0;//聚焦极限Manual
                    log.debug("当前为手动聚焦模式");
                } else {
                    cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 2;//自动聚焦
                    cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 1;//聚焦极限Auto
                    log.debug("当前为自动聚焦模式");
                }
            }
            cfg_video_in_focus.nChannelIndex = chanNo - 1;
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, NetSDKLib.CFG_CMD_VIDEOIN_FOCUS, cfg_video_in_focus);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error("切换聚焦模式异常:" + ex.getMessage());
            return false;
        }
    }

    @Override
    public String getFocusMode(CameraCmd cmd) {
        String mode = "";
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return "";
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            NET_VIDEOIN_FOCUSMODE_INFO focusModeInfo = new NET_VIDEOIN_FOCUSMODE_INFO();
            int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VIDEOIN_FOCUSMODE;
            boolean bool = ConfigModule.GetConfig(loginId, chanNo - 1, emCfgOpType, focusModeInfo);
            if (!bool) {
                log.error("获取失败,请稍后重试" + getErrorCodePrint());
            }
            System.out.println("配置类型:" + focusModeInfo.emCfgType);     // å…·ä½“信息，参考库里的枚举
            System.out.println("聚焦模式:" + focusModeInfo.emFocusMode);
            switch (focusModeInfo.emFocusMode) {
                case 0:
                    mode = "关闭";
                    break;
                case 1:
                    mode = "辅助聚焦";
                    break;
                case 2:
                    mode = "自动聚焦";
                    break;
                case 3:
                    mode = "半自动聚焦";
                    break;
                case 4:
                    mode = "手动聚焦";
                    break;
            }

        } catch (Exception ex) {
            log.error("获取聚焦模式异常:" + ex.getMessage());

        }
        return mode;
    }

    @Override
    public boolean controlPTHeateRpwron(CameraCmd cmd) {
        return false;
    }

    @Override
    public boolean controlCameraDeicing(CameraCmd cmd) {
        return false;
    }

    @Override
    public int getPTZLockInfo(CameraCmd cmd) {
        return 0;
    }

    @Override
    public String captureJPEGPicture(CameraCmd cmd) {
        return null;
    }

    //透雾
    @Override
    public boolean controlDefogcfg(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            String command = EM_NEW_CONFIG.CFG_CMD_VIDEOINDEFOG.getValue();
            //CFG_VIDEOINDEFOG_LIST cfg_videoindefog_list=new CFG_VIDEOINDEFOG_LIST();
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, command, null);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error("切换透雾异常:" + ex.getMessage());
            return false;
        }
    }

    //红外
    @Override
    public boolean controlInfrarecfg(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();
            cfg_lighting_info.nLightingDetailNum = 1;
            if (enable) {
                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;
            } else {
                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;
            }
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error("切换红外异常:" + ex.getMessage());
            return false;
        }
    }

    //获取聚焦值
    @Override
    public int getFocusPos(CameraCmd cmd) {
        int result = 0;
        try {
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return result;
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            NET_PTZ_LOCATION_INFO net_ptz_location_info = new NET_PTZ_LOCATION_INFO();
            net_ptz_location_info.nChannelID = chanNo - 1;
            boolean bool = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, net_ptz_location_info);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            result = net_ptz_location_info.nFocusMapValue;
        } catch (Exception ex) {
            log.error("获取聚焦值异常:" + ex.getMessage());
        }
        return result;
    }

    //设置聚焦值
    @Override
    public boolean setFocusPos(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer chanNo = cmd.getChanNo();
        boolean enable = cmd.isEnable();
        if (!GlobalVariable.loginMap.containsKey(cameraId)) {
            return false;
        }
        LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
        try {
            CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();
            cfg_lighting_info.nLightingDetailNum = 1;
            if (enable) {
                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;
            } else {
                cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;
            }
            boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
            if (!bool) {
                log.error("控制失败,请稍后重试" + getErrorCodePrint());
            }
            return bool;
        } catch (Exception ex) {
            log.error("设置聚焦值异常:" + ex.getMessage());
            return false;
        }
    }

    //获取码流压缩参数
    @Override
    public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {
        Map<String, Object> map = new HashMap<>();
        try {
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return null;
            }
            LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
            CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();
            cfg_encode_info.nChannelID = chanNo - 1;
            boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);
            if (b) {
                int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式
                String videoEncType = "";
                switch (emCompression) {
                    case 0:
                        videoEncType = "MPEG4";
                        break;
                    case 1:
                        videoEncType = "MS-MPEG4";
                        break;
                    case 2:
                        videoEncType = "MPEG2";
                        break;
                    case 3:
                        videoEncType = "MPEG1";
                        break;
                    case 4:
                        videoEncType = "H.263";
                        break;
                    case 5:
                        videoEncType = "MJPG";
                        break;
                    case 6:
                        videoEncType = "FCC-MPEG4";
                        break;
                    case 7:
                        videoEncType = "标准h264";
                        break;
                    case 8:
                        videoEncType = "标准h265";
                        break;
                    case 9:
                        videoEncType = "SVAC";
                        break;
                    default:
                        videoEncType = "未知";
                        break;
                }
                int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;
                int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;
                int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;
                String resolution = nWidth + "*" + nHeight;
                float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;
                map.put("resolution", resolution);//分辨率
                map.put("videoBitrate", String.valueOf(nBitRate));//比特率
                map.put("videoEncType", videoEncType);//编码
                map.put("nFrameRate", String.valueOf(nFrameRate));//帧率
            }
        } catch (Exception ex) {
            log.error("取码流压缩参数异常:" + ex.getMessage());
        }
        return map;
    }

    //获取GIS信息数据
    @Override
    public Map<String, Object> getGisInfo(CameraCmd cmd) {
        Map<String, Object> map = new HashMap<>();
        try {
            String cameraId = cmd.getCameraId();
            Integer chanNo = cmd.getChanNo();
            if (!GlobalVariable.loginMap.containsKey(cameraId)) {
                return null;
            }
            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) {
                float nAngelH = (float) dh_out_ptz_view_range_status.nAngelH / 10;
                float nAngelV = (float) dh_out_ptz_view_range_status.nAngelV / 10;
                map = getPtz(cmd);//获取ptz
                map.put("fHorFieldAngle", nAngelH);// æ°´å¹³è§†åœºè§’
                map.put("fVerFieldAngle", nAngelV);// åž‚直视场角
            }
        } catch (Exception ex) {
            log.error("获取云台可视域异常" + ex.getMessage());
        }
        return map;
    }

    // è®¾å¤‡æ–­çº¿å›žè°ƒ: å½“设备出现断线时，SDK会调用该函数
    private static class DisConnect implements NetSDKLib.fDisConnect {
        public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            log.warn("Device[" + pchDVRIP + ":" + nDVRPort + "] DisConnect!");
        }
    }

    // ç½‘络连接恢复回调:设备重连成功回调，当已断线的设备重连成功时，SDK会调用该函数
    private static class HaveReConnect implements NetSDKLib.fHaveReConnect {
        @Override
        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            log.warn("ReConnect Device[" + pchDVRIP + ":" + nDVRPort + "]");
        }
    }

    // æŠ“图接收回调:当抓图成功，sdk会调用该函数
    public static class fCaptureReceiveCB implements NetSDKLib.fSnapRev {
        private String minioEndPoint;
        private String ObjectName;
        private String bucketName;

        public fCaptureReceiveCB(String minioEndPoint, String bucketName, String ObjectName) {
            this.minioEndPoint = minioEndPoint;
            this.bucketName = bucketName;
            this.ObjectName = ObjectName;
        }

        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);
                //存储到minio
                InputStream input = new ByteArrayInputStream(buf);

                try {
                    boolean b = MinioUtil.uploadObject(bucketName, ObjectName, input, input.available(), MimeTypeUtils.IMAGE_JPEG);
                    if (b) {
                        String url = minioEndPoint + "/" + bucketName + ObjectName;
                        log.debug("上传文件成功!" + url);
                    }
                } catch (IOException ex) {
                    log.error("上传文件异常：" + ex.getMessage());
                }
            }
        }
    }

}