Merge remote-tracking branch 'origin/master'

aijinhui

2023-10-30 305fe6a8621998e5130d541660c2e3c5f02672d6

Merge remote-tracking branch 'origin/master'

 ard-work/src/main/java/com/ruoyi/alarmpoints/tube/controller/ArdTubesDetailsController.java

@@ -120,6 +120,7 @@
        String message = ardTubesDetailsService.importArdTubesDetails(tubesDetailsList, updateSupport, operName,tubeId);
        return success(message);
    }

    @PostMapping("/importTemplate")
    @ApiOperation(value = "管线详情模板下载接口")
    public void importTemplate(HttpServletResponse response)

 ard-work/src/main/java/com/ruoyi/alarmpoints/well/controller/ArdAlarmpointsWellController.java

@@ -152,9 +152,9 @@
    @ApiOperation("导入井")
    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception {
        ExcelUtil<ArdAlarmpointsWell> util = new ExcelUtil<ArdAlarmpointsWell>(ArdAlarmpointsWell.class);
        List<ArdAlarmpointsWell> userList = util.importExcel(file.getInputStream());
        List<ArdAlarmpointsWell> wellList = util.importExcel(file.getInputStream());
        String operName = getUsername();
        String message = ardAlarmpointsWellService.importUser(userList, updateSupport, operName);
        String message = ardAlarmpointsWellService.importWell(wellList, updateSupport, operName);
        return success(message);
    }


 ard-work/src/main/java/com/ruoyi/alarmpoints/well/mapper/ArdAlarmpointsWellMapper.java

@@ -62,7 +62,13 @@
     * @return ç»“æžœ
     */
    public int updateArdAlarmpointsWell(ArdAlarmpointsWell ardAlarmpointsWell);

    /**
     * ä¿®æ”¹äº•ç®¡ç†æŒ‰äº•å·
     *
     * @param ardAlarmpointsWell äº•ç®¡ç†
     * @return ç»“æžœ
     */
    public int updateArdAlarmpointsWellByWellId(ArdAlarmpointsWell ardAlarmpointsWell);
    /**
     * åˆ é™¤äº•ç®¡ç†
     *

 ard-work/src/main/java/com/ruoyi/alarmpoints/well/service/IArdAlarmpointsWellService.java

@@ -60,7 +60,13 @@
     * @return ç»“æžœ
     */
    public int updateArdAlarmpointsWell(ArdAlarmpointsWell ardAlarmpointsWell);

    /**
     * ä¿®æ”¹äº•ç®¡ç†æŒ‰äº•å·
     *
     * @param ardAlarmpointsWell äº•ç®¡ç†
     * @return ç»“æžœ
     */
    public int updateArdAlarmpointsWellByWellId(ArdAlarmpointsWell ardAlarmpointsWell);
    /**
     * æ‰¹é‡åˆ é™¤äº•ç®¡ç†
     * 
@@ -84,7 +90,7 @@
     * @param operName æ“ä½œç”¨æˆ·
     * @return ç»“æžœ
     */
    public String importUser(List<ArdAlarmpointsWell> ardAlarmpointsWellList, Boolean isUpdateSupport, String operName);
    public String importWell(List<ArdAlarmpointsWell> ardAlarmpointsWellList, Boolean isUpdateSupport, String operName);
    /**
     * æ ¡éªŒç”¨æˆ·æ˜¯å¦æœ‰æ•°æ®æƒé™
     *

 ard-work/src/main/java/com/ruoyi/alarmpoints/well/service/impl/ArdAlarmpointsWellServiceImpl.java

@@ -126,7 +126,13 @@
        ardAlarmpointsWell.setUpdateTime(DateUtils.getNowDate());
        return ardAlarmpointsWellMapper.updateArdAlarmpointsWell(ardAlarmpointsWell);
    }

    @Override
    @Transactional
    public int updateArdAlarmpointsWellByWellId(ArdAlarmpointsWell ardAlarmpointsWell) {
        ardAlarmpointsWell.setUpdateBy(SecurityUtils.getUsername());
        ardAlarmpointsWell.setUpdateTime(DateUtils.getNowDate());
        return ardAlarmpointsWellMapper.updateArdAlarmpointsWellByWellId(ardAlarmpointsWell);
    }
    /**
     * æ‰¹é‡åˆ é™¤äº•ç®¡ç†
     *
@@ -150,7 +156,7 @@
    }

    @Override
    public String importUser(List<ArdAlarmpointsWell> ardAlarmpointsWellList, Boolean isUpdateSupport, String operName) {
    public String importWell(List<ArdAlarmpointsWell> ardAlarmpointsWellList, Boolean isUpdateSupport, String operName) {
        if (StringUtils.isNull(ardAlarmpointsWellList) || ardAlarmpointsWellList.size() == 0) {
            throw new ServiceException("导入井数据不能为空！");
        }
@@ -163,9 +169,9 @@
                //获取当前登录用户id
                String userId = SecurityUtils.getUserId();
                well.setUserId(userId);
                // éªŒè¯æ˜¯å¦å­˜åœ¨è¿™ä¸ªç”¨æˆ·
                ArdAlarmpointsWell u = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(well.getWellId());
                if (StringUtils.isNull(u)) {
                // éªŒè¯æ˜¯å¦å­˜åœ¨è¿™ä¸ªäº•
                ArdAlarmpointsWell w = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(well.getWellId());
                if (StringUtils.isNull(w)) {
                    BeanValidators.validateWithException(validator, well);
                    well.setCreateBy(operName);
                    this.insertArdAlarmpointsWell(well);
@@ -173,10 +179,9 @@
                    successMsg.append("<br/>" + successNum + "、井号 " + well.getWellId() + " å¯¼å…¥æˆåŠŸ");
                } else if (isUpdateSupport) {
                    BeanValidators.validateWithException(validator, well);
                    checkWellAllowed(well);
                    checkWellDataScope(well.getUserId());
                    well.setUpdateBy(operName);
                    this.updateArdAlarmpointsWell(well);
                    this.updateArdAlarmpointsWellByWellId(well);
                    successNum++;
                    successMsg.append("<br/>" + successNum + "、井号 " + well.getWellId() + " æ›´æ–°æˆåŠŸ");
                } else {

 ard-work/src/main/java/com/ruoyi/device/camera/controller/ArdCamerasController.java

@@ -3,6 +3,7 @@
import javax.annotation.Resource;

import javax.servlet.http.HttpServletResponse;

import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;

import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;

import com.ruoyi.common.constant.CameraConstants;

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

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

@@ -27,6 +28,7 @@
import com.ruoyi.common.core.domain.AjaxResult;

import com.ruoyi.common.enums.BusinessType;

import com.ruoyi.common.core.page.TableDataInfo;

import org.springframework.web.multipart.MultipartFile;



import java.util.*;



@@ -137,6 +139,27 @@
        return toAjax(ardCamerasService.deleteArdCamerasByIds(ids));

    }



    @Log(title = "导入相机设备", businessType = BusinessType.IMPORT)

    @PreAuthorize("@ss.hasPermi('device:cameras:import')")

    @PostMapping("/importData")

    @ApiOperation("导入相机设备")

    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception {

        ExcelUtil<ArdCameras> util = new ExcelUtil<ArdCameras>(ArdCameras.class);

        List<ArdCameras> camerasList = util.importExcel(file.getInputStream());

        String operName = getUsername();

        String message = ardCamerasService.importCameras(camerasList, updateSupport, operName);

        return success(message);

    }



    @PostMapping("/importTemplate")

    @ApiOperation("相机设备导入模板")

    public void importTemplate(HttpServletResponse response) {

        ExcelUtil<ArdCameras> util = new ExcelUtil<ArdCameras>(ArdCameras.class);

        util.importTemplateExcel(response, "相机设备数据");

    }







    @GetMapping("/options")

    @ApiOperation("选择相机数据")

    public List options(ArdCameras ardCameras) {


 ard-work/src/main/java/com/ruoyi/device/camera/controller/CameraSdkController.java

@@ -11,11 +11,18 @@
import com.ruoyi.device.camera.domain.CameraCmd;

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

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

import com.ruoyi.device.noguidezone.domain.ArdCameraNoGuideZone;

import com.ruoyi.device.noguidezone.service.IArdCameraNoGuideZoneService;

import com.ruoyi.utils.gis.GisUtil;

import com.ruoyi.utils.gis.Point;

import io.swagger.annotations.Api;

import io.swagger.annotations.ApiOperation;

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

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.*;



import javax.annotation.Resource;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;



@@ -36,7 +43,8 @@
    private ICameraSdkService cameraSdkService;

    @Resource

    private IArdCamerasService ardCamerasService;



    @Autowired

    private IArdCameraNoGuideZoneService ardCameraNoGuideZoneService;



    @RequestMapping("/preview")

    private String preview() {

@@ -137,6 +145,7 @@
        Map<String, Object> ptzMap = cameraSdkService.getPtz(cmd);

        return AjaxResult.success("获取ptz", ptzMap);

    }



    @ApiOperation("获取PTZ范围")

    @PostMapping("/getPTZScope")

    @Log(title = "获取PTZ范围", businessType = BusinessType.CONTROL)

@@ -165,6 +174,33 @@
    public @ResponseBody

    AjaxResult setTargetPosition(@RequestBody CameraCmd cmd) {

        cmd.setOperator(SecurityUtils.getUserId());

        //拦截手动引导

        ArdCameraNoGuideZone ardCameraNoGuideZone = new ArdCameraNoGuideZone();

        ardCameraNoGuideZone.setCameraId(cmd.getCameraId());

        //获取当前相机的禁引可视域列表

        List<ArdCameraNoGuideZone> ardCameraNoGuideZones = ardCameraNoGuideZoneService.selectArdCameraNoGuideZoneList(ardCameraNoGuideZone);

        if (ardCameraNoGuideZones.size() > 0) {

            //获取到当前相机的坐标集合

            List<Point> pointList = new ArrayList<>();

            for(ArdCameraNoGuideZone zone:ardCameraNoGuideZones) {

                String[] parts = zone.getPoi().split(",");

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

                    Point point = new Point();

                    point.setLongitude(Double.valueOf(parts[i]));

                    point.setLatitude(Double.valueOf(parts[i + 1]));

                    pointList.add(point);

                }

            }

            double lon = cmd.getTargetPosition()[0];

            double lat = cmd.getTargetPosition()[1];

            Point targetPoint = new Point(lon, lat);

            //判断引导目标是否在坐标集合组成的多边形内

            boolean inPolygon = GisUtil.isInPolygon(targetPoint, pointList);

            if(inPolygon)

            {

                return AjaxResult.error("引导坐标位于禁引可视域内");

            }

        }

        return toAjax(cameraSdkService.guideTargetPosition(cmd));

    }




 ard-work/src/main/java/com/ruoyi/device/camera/service/IArdCamerasService.java

@@ -5,6 +5,7 @@
import java.util.Map;
import java.util.TreeMap;

import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.scheduling.domian.SchedulingParam;
@@ -71,6 +72,30 @@
     */
    public int deleteArdCamerasById(String id);


    /**
     * å¯¼å…¥ç›¸æœºè®¾å¤‡ä¿¡æ¯
     *
     * @param ardCamerasList ç›¸æœºè®¾å¤‡æ•°æ®åˆ—表
     * @param isUpdateSupport æ˜¯å¦æ›´æ–°æ”¯æŒï¼Œå¦‚果已存在，则进行更新数据
     * @param operName æ“ä½œç”¨æˆ·
     * @return ç»“æžœ
     */
    public String importCameras(List<ArdCameras> ardCamerasList, Boolean isUpdateSupport, String operName);
    /**
     * æ ¡éªŒç›¸æœºæ˜¯å¦å…è®¸æ“ä½œ
     *
     * @param ardCameras ç›¸æœºä¿¡æ¯
     */
    public void checkCameraAllowed(ArdCameras ardCameras);
    /**
     * æ ¡éªŒç”¨æˆ·æ˜¯å¦æœ‰æ•°æ®æƒé™
     *
     * @param userId ç”¨æˆ·id
     */
    public void checkCameraDataScope(String userId);


    public List findOptions(ArdCameras ardCameras);
    /**
     * @描述 èŽ·å–本部门以下的所有相机和部门

 ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java

@@ -3,13 +3,18 @@
import java.util.*;
import java.util.stream.Collectors;

import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
import com.ruoyi.common.constant.CacheConstants;
import com.ruoyi.common.constant.CameraConstants;
import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.bean.BeanValidators;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.channel.domain.ArdChannel;
@@ -25,10 +30,12 @@
import com.ruoyi.system.mapper.SysDeptMapper;
import com.ruoyi.utils.gis.Point;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.validation.Validator;

/**
 * ç›¸æœºè®¾å¤‡Service业务层处理
@@ -50,7 +57,8 @@
    private ArdChannelMapper ardChannelMapper;
    @Resource
    private IVtduService vtduService;

    @Autowired
    protected Validator validator;

    @PostConstruct
    public void loadCameras() {
@@ -200,6 +208,84 @@
        return i;
    }

    @Override
    public String importCameras(List<ArdCameras> ardCamerasList, Boolean isUpdateSupport, String operName) {
        if (StringUtils.isNull(ardCamerasList) || ardCamerasList.size() == 0) {
            throw new ServiceException("导入井数据不能为空！");
        }
        int successNum = 0;
        int failureNum = 0;
        StringBuilder successMsg = new StringBuilder();
        StringBuilder failureMsg = new StringBuilder();
        for (ArdCameras camera : ardCamerasList) {
            try {
                //获取当前登录用户id
                String userId = SecurityUtils.getUserId();
                camera.setUserId(userId);
                // éªŒè¯æ˜¯å¦å­˜åœ¨è¿™ä¸ªç”¨æˆ·
                ArdCameras u = ardCamerasMapper.selectArdCamerasById(camera.getId());
                if (StringUtils.isNull(u)) {
                    BeanValidators.validateWithException(validator, camera);
                    camera.setCreateBy(operName);
                    this.insertArdCameras(camera);
                    successNum++;
                    successMsg.append("<br/>" + successNum + "、相机ID " + camera.getId() + " å¯¼å…¥æˆåŠŸ");
                } else if (isUpdateSupport) {
                    BeanValidators.validateWithException(validator, camera);
                    checkCameraDataScope(camera.getUserId());
                    camera.setUpdateBy(operName);
                    this.updateArdCameras(camera);
                    successNum++;
                    successMsg.append("<br/>" + successNum + "、相机ID " + camera.getId() + " æ›´æ–°æˆåŠŸ");
                } else {
                    failureNum++;
                    failureMsg.append("<br/>" + failureNum + "、相机ID " + camera.getId() + " å·²å­˜åœ¨");
                }
            } catch (Exception e) {
                failureNum++;
                String msg = "<br/>" + failureNum + "、相机ID " + camera.getId() + " å¯¼å…¥å¤±è´¥ï¼š";
                failureMsg.append(msg + e.getMessage());
                log.error(msg, e);
            }
        }
        if (failureNum > 0) {
            failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " æ¡æ•°æ®æ ¼å¼ä¸æ­£ç¡®ï¼Œé”™è¯¯å¦‚下：");
            throw new ServiceException(failureMsg.toString());
        } else {
            successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " æ¡ï¼Œæ•°æ®å¦‚下：");
        }
        return successMsg.toString();
    }

    /**
     * æ ¡éªŒç›¸æœºæ˜¯å¦å…è®¸æ“ä½œ
     *
     * @param ardCameras ç›¸æœºä¿¡æ¯
     */
    @Override
    public void checkCameraAllowed(ArdCameras ardCameras) {
        if (StringUtils.isNotNull(ardCameras.getId())) {
            throw new ServiceException("不允许操作井");
        }
    }

    /**
     * æ ¡éªŒç”¨æˆ·æ˜¯å¦æœ‰æ•°æ®æƒé™
     *
     * @param userId ç”¨æˆ·id
     */
    @Override
    public void checkCameraDataScope(String userId) {
        if (!SysUser.isAdmin(SecurityUtils.getUserId())) {
            ArdCameras camera = new ArdCameras();
            camera.setUserId(userId);
            List<ArdCameras> cameras = SpringUtils.getAopProxy(this).selectArdCamerasList(camera);
            if (StringUtils.isEmpty(cameras)) {
                throw new ServiceException("没有权限访问井数据！");
            }
        }
    }

    public List findOptions(ArdCameras ardCameras) {
        List<ArdCameras> options = ardCamerasMapper.findOptions(ardCameras);
        for (ArdCameras camera :

 ard-work/src/main/java/com/ruoyi/device/noguidezone/controller/ArdCameraNoGuideZoneController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,113 @@
package com.ruoyi.device.noguidezone.controller;

import java.util.List;
import javax.servlet.http.HttpServletResponse;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.device.noguidezone.domain.ArdCameraNoGuideZone;
import com.ruoyi.device.noguidezone.service.IArdCameraNoGuideZoneService;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;

/**
 * ç¦å¼•å¯è§†åŸŸController
 * 
 * @author ard
 * @date 2023-10-27
 */
@Api(tags = "禁引可视域管理接口")
@RestController
@RequestMapping("/device/noguidezone")
public class ArdCameraNoGuideZoneController extends BaseController
{
    @Autowired
    private IArdCameraNoGuideZoneService ardCameraNoGuideZoneService;

    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸåˆ—表
     */
    @ApiOperation("查询禁引可视域列表")
    @PreAuthorize("@ss.hasPermi('device:noguidezone:list')")
    @GetMapping("/list")
    public TableDataInfo list(ArdCameraNoGuideZone ardCameraNoGuideZone)
    {
        startPage();
        List<ArdCameraNoGuideZone> list = ardCameraNoGuideZoneService.selectArdCameraNoGuideZoneList(ardCameraNoGuideZone);
        return getDataTable(list);
    }

    /**
     * å¯¼å‡ºç¦å¼•å¯è§†åŸŸåˆ—表
     */
    @PreAuthorize("@ss.hasPermi('device:noguidezone:export')")
    @Log(title = "禁引可视域", businessType = BusinessType.EXPORT)
    @PostMapping("/export")
    public void export(HttpServletResponse response, ArdCameraNoGuideZone ardCameraNoGuideZone)
    {
        List<ArdCameraNoGuideZone> list = ardCameraNoGuideZoneService.selectArdCameraNoGuideZoneList(ardCameraNoGuideZone);
        ExcelUtil<ArdCameraNoGuideZone> util = new ExcelUtil<ArdCameraNoGuideZone>(ArdCameraNoGuideZone.class);
        util.exportExcel(response, list, "禁引可视域数据");
    }

    /**
     * èŽ·å–禁引可视域详细信息
     */
    @ApiOperation("获取禁引可视域详细信息")
    @PreAuthorize("@ss.hasPermi('device:noguidezone:query')")
    @GetMapping(value = "/{name}")
    public AjaxResult getInfo(@PathVariable("name") String name)
    {
        return success(ardCameraNoGuideZoneService.selectArdCameraNoGuideZoneByName(name));
    }

    /**
     * æ–°å¢žç¦å¼•å¯è§†åŸŸ
     */
    @ApiOperation("新增禁引可视域")
    @PreAuthorize("@ss.hasPermi('device:noguidezone:add')")
    @Log(title = "禁引可视域", businessType = BusinessType.INSERT)
    @PostMapping
    public AjaxResult add(@RequestBody ArdCameraNoGuideZone ardCameraNoGuideZone)
    {
        return toAjax(ardCameraNoGuideZoneService.insertArdCameraNoGuideZone(ardCameraNoGuideZone));
    }

    /**
     * ä¿®æ”¹ç¦å¼•å¯è§†åŸŸ
     */
    @ApiOperation("修改禁引可视域")
    @PreAuthorize("@ss.hasPermi('device:noguidezone:edit')")
    @Log(title = "禁引可视域", businessType = BusinessType.UPDATE)
    @PutMapping
    public AjaxResult edit(@RequestBody ArdCameraNoGuideZone ardCameraNoGuideZone)
    {
        return toAjax(ardCameraNoGuideZoneService.updateArdCameraNoGuideZone(ardCameraNoGuideZone));
    }

    /**
     * åˆ é™¤ç¦å¼•å¯è§†åŸŸ
     */
    @ApiOperation("删除禁引可视域")
    @PreAuthorize("@ss.hasPermi('device:noguidezone:remove')")
    @Log(title = "禁引可视域", businessType = BusinessType.DELETE)
    @DeleteMapping("/{names}")
    public AjaxResult remove(@PathVariable String[] names)
    {
        return toAjax(ardCameraNoGuideZoneService.deleteArdCameraNoGuideZoneByNames(names));
    }
}

 ard-work/src/main/java/com/ruoyi/device/noguidezone/domain/ArdCameraNoGuideZone.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,125 @@
package com.ruoyi.device.noguidezone.domain;

import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;

/**
 * ç¦å¼•å¯è§†åŸŸå¯¹è±¡ ard_camera_no_guide_zone
 * 
 * @author ard
 * @date 2023-10-27
 */
public class ArdCameraNoGuideZone extends BaseEntity
{
    private static final long serialVersionUID = 1L;

    /** åç§° */
    @Excel(name = "名称")
    private String name;

    /** èŒƒå›´ */
    @Excel(name = "范围")
    private String poi;

    /** ç›¸æœºID */
    @Excel(name = "相机ID")
    private String cameraId;

    /** æ˜¯å¦å¯ç”¨ */
    @Excel(name = "是否启用")
    private String enabled;

    /** éƒ¨é—¨ID */
    @Excel(name = "部门ID")
    private Long deptId;

    /** ç”¨æˆ·ID */
    @Excel(name = "用户ID")
    private String userId;

    /** id */
    private String id;

    public void setName(String name) 
    {
        this.name = name;
    }

    public String getName() 
    {
        return name;
    }
    public void setPoi(String poi) 
    {
        this.poi = poi;
    }

    public String getPoi() 
    {
        return poi;
    }
    public void setCameraId(String cameraId) 
    {
        this.cameraId = cameraId;
    }

    public String getCameraId() 
    {
        return cameraId;
    }
    public void setEnabled(String enabled) 
    {
        this.enabled = enabled;
    }

    public String getEnabled() 
    {
        return enabled;
    }
    public void setDeptId(Long deptId) 
    {
        this.deptId = deptId;
    }

    public Long getDeptId() 
    {
        return deptId;
    }
    public void setUserId(String userId) 
    {
        this.userId = userId;
    }

    public String getUserId() 
    {
        return userId;
    }
    public void setId(String id) 
    {
        this.id = id;
    }

    public String getId() 
    {
        return id;
    }

    @Override
    public String toString() {
        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
            .append("name", getName())
            .append("poi", getPoi())
            .append("cameraId", getCameraId())
            .append("enabled", getEnabled())
            .append("deptId", getDeptId())
            .append("userId", getUserId())
            .append("createBy", getCreateBy())
            .append("createTime", getCreateTime())
            .append("updateBy", getUpdateBy())
            .append("updateTime", getUpdateTime())
            .append("id", getId())
            .toString();
    }
}

 ard-work/src/main/java/com/ruoyi/device/noguidezone/mapper/ArdCameraNoGuideZoneMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.ruoyi.device.noguidezone.mapper;

import java.util.List;
import com.ruoyi.device.noguidezone.domain.ArdCameraNoGuideZone;

/**
 * ç¦å¼•å¯è§†åŸŸMapper接口
 * 
 * @author ard
 * @date 2023-10-27
 */
public interface ArdCameraNoGuideZoneMapper 
{
    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸ
     * 
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç¦å¼•å¯è§†åŸŸ
     */
    public ArdCameraNoGuideZone selectArdCameraNoGuideZoneByName(String name);

    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸåˆ—表
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç¦å¼•å¯è§†åŸŸé›†åˆ
     */
    public List<ArdCameraNoGuideZone> selectArdCameraNoGuideZoneList(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * æ–°å¢žç¦å¼•å¯è§†åŸŸ
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    public int insertArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * ä¿®æ”¹ç¦å¼•å¯è§†åŸŸ
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    public int updateArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * åˆ é™¤ç¦å¼•å¯è§†åŸŸ
     * 
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç»“æžœ
     */
    public int deleteArdCameraNoGuideZoneByName(String name);

    /**
     * æ‰¹é‡åˆ é™¤ç¦å¼•å¯è§†åŸŸ
     * 
     * @param names éœ€è¦åˆ é™¤çš„数据主键集合
     * @return ç»“æžœ
     */
    public int deleteArdCameraNoGuideZoneByNames(String[] names);
}

 ard-work/src/main/java/com/ruoyi/device/noguidezone/service/IArdCameraNoGuideZoneService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.ruoyi.device.noguidezone.service;

import java.util.List;
import com.ruoyi.device.noguidezone.domain.ArdCameraNoGuideZone;

/**
 * ç¦å¼•å¯è§†åŸŸService接口
 * 
 * @author ard
 * @date 2023-10-27
 */
public interface IArdCameraNoGuideZoneService 
{
    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸ
     * 
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç¦å¼•å¯è§†åŸŸ
     */
    public ArdCameraNoGuideZone selectArdCameraNoGuideZoneByName(String name);

    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸåˆ—表
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç¦å¼•å¯è§†åŸŸé›†åˆ
     */
    public List<ArdCameraNoGuideZone> selectArdCameraNoGuideZoneList(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * æ–°å¢žç¦å¼•å¯è§†åŸŸ
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    public int insertArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * ä¿®æ”¹ç¦å¼•å¯è§†åŸŸ
     * 
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    public int updateArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone);

    /**
     * æ‰¹é‡åˆ é™¤ç¦å¼•å¯è§†åŸŸ
     * 
     * @param names éœ€è¦åˆ é™¤çš„禁引可视域主键集合
     * @return ç»“æžœ
     */
    public int deleteArdCameraNoGuideZoneByNames(String[] names);

    /**
     * åˆ é™¤ç¦å¼•å¯è§†åŸŸä¿¡æ¯
     * 
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç»“æžœ
     */
    public int deleteArdCameraNoGuideZoneByName(String name);
}

 ard-work/src/main/java/com/ruoyi/device/noguidezone/service/impl/ArdCameraNoGuideZoneServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,98 @@
package com.ruoyi.device.noguidezone.service.impl;

import java.util.List;
        import com.ruoyi.common.utils.DateUtils;

import com.ruoyi.common.utils.uuid.IdUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.device.noguidezone.mapper.ArdCameraNoGuideZoneMapper;
import com.ruoyi.device.noguidezone.domain.ArdCameraNoGuideZone;
import com.ruoyi.device.noguidezone.service.IArdCameraNoGuideZoneService;

/**
 * ç¦å¼•å¯è§†åŸŸService业务层处理
 *
 * @author ard
 * @date 2023-10-27
 */
@Service
public class ArdCameraNoGuideZoneServiceImpl implements IArdCameraNoGuideZoneService {
    @Autowired
    private ArdCameraNoGuideZoneMapper ardCameraNoGuideZoneMapper;

    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸ
     *
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç¦å¼•å¯è§†åŸŸ
     */
    @Override
    public ArdCameraNoGuideZone selectArdCameraNoGuideZoneByName(String name) {
        return ardCameraNoGuideZoneMapper.selectArdCameraNoGuideZoneByName(name);
    }

    /**
     * æŸ¥è¯¢ç¦å¼•å¯è§†åŸŸåˆ—表
     *
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç¦å¼•å¯è§†åŸŸ
     */
    @Override
    public List<ArdCameraNoGuideZone> selectArdCameraNoGuideZoneList(ArdCameraNoGuideZone ardCameraNoGuideZone) {
        return ardCameraNoGuideZoneMapper.selectArdCameraNoGuideZoneList(ardCameraNoGuideZone);
    }

    /**
     * æ–°å¢žç¦å¼•å¯è§†åŸŸ
     *
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    @Override
    public int insertArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone) {
                ardCameraNoGuideZone.setUserId(SecurityUtils.getUserId());
                ardCameraNoGuideZone.setCreateBy(SecurityUtils.getUsername());
                ardCameraNoGuideZone.setCreateTime(DateUtils.getNowDate());
                ardCameraNoGuideZone.setId(IdUtils.simpleUUID());
            return ardCameraNoGuideZoneMapper.insertArdCameraNoGuideZone(ardCameraNoGuideZone);
    }

    /**
     * ä¿®æ”¹ç¦å¼•å¯è§†åŸŸ
     *
     * @param ardCameraNoGuideZone ç¦å¼•å¯è§†åŸŸ
     * @return ç»“æžœ
     */
    @Override
    public int updateArdCameraNoGuideZone(ArdCameraNoGuideZone ardCameraNoGuideZone) {
                ardCameraNoGuideZone.setUpdateBy(SecurityUtils.getUsername());
                ardCameraNoGuideZone.setUpdateTime(DateUtils.getNowDate());
        return ardCameraNoGuideZoneMapper.updateArdCameraNoGuideZone(ardCameraNoGuideZone);
    }

    /**
     * æ‰¹é‡åˆ é™¤ç¦å¼•å¯è§†åŸŸ
     *
     * @param names éœ€è¦åˆ é™¤çš„禁引可视域主键
     * @return ç»“æžœ
     */
    @Override
    public int deleteArdCameraNoGuideZoneByNames(String[] names) {
        return ardCameraNoGuideZoneMapper.deleteArdCameraNoGuideZoneByNames(names);
    }

    /**
     * åˆ é™¤ç¦å¼•å¯è§†åŸŸä¿¡æ¯
     *
     * @param name ç¦å¼•å¯è§†åŸŸä¸»é”®
     * @return ç»“æžœ
     */
    @Override
    public int deleteArdCameraNoGuideZoneByName(String name) {
        return ardCameraNoGuideZoneMapper.deleteArdCameraNoGuideZoneByName(name);
    }
}

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

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

    private static class DisConnect implements NetSDKLib.fDisConnect {

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

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

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

        }

    }



@@ -904,7 +904,7 @@
    private static class HaveReConnect implements NetSDKLib.fHaveReConnect {

        @Override

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

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

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

        }

    }




 ard-work/src/main/java/com/ruoyi/utils/sdk/hiksdk/lib/ExceptionCallBack.java

@@ -22,19 +22,19 @@
            Integer port = camera.getPort();

            switch (dwType) {

                case EXCEPTION_EXCHANGE:

                    log.warn("Device[" + ip + "] Port[" + port + "]用户交互时异常");

                    log.warn("Device[" + ip + ":" + port + "]用户交互时异常");

                    break;

                case EXCEPTION_PREVIEW:

                    log.warn("Device[" + ip + "] Port[" + port + "]网络预览异常");

                    log.warn("Device[" + ip + ":" + port + "]网络预览异常");

                    break;

                case EXCEPTION_RECONNECT:

                    log.warn("Device[" + ip + "] Port[" + port + "]预览时重连");

                    log.warn("Device[" + ip + ":" + port + "]预览时重连");

                    break;

                case RELOGIN_SUCCESS:

                    log.warn("Device[" + ip + "] Port[" + port + "]用户重登陆成功");

                    log.warn("Device[" + ip + ":" + port + "]用户重登陆成功");

                    break;

                case EXCEPTION_RELOGIN:

                    log.warn("Device[" + ip + "] Port[" + port + "]用户重登陆");

                    log.warn("Device[" + ip + ":" + port + "]用户重登陆");

                    break;

            }

        }


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

@@ -1094,7 +1094,7 @@
    public boolean controlInfrarecfg(CameraCmd cmd) {

        String cameraId = cmd.getCameraId();

        boolean enable = cmd.isEnable();

        Integer channelNum = cmd.getChanNo();

        Integer chanNo = cmd.getChanNo();

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

            return false;

        }

@@ -1102,17 +1102,17 @@
        NET_DVR_CAMERAPARAMCFG_EX struDayNigh = new NET_DVR_CAMERAPARAMCFG_EX();

        Pointer point = struDayNigh.getPointer();

        IntByReference ibrBytesReturned = new IntByReference(0);

        boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, channelNum, point, struDayNigh.size(), ibrBytesReturned);

        boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, chanNo, point, struDayNigh.size(), ibrBytesReturned);

        if (!b_GetCameraParam) {

            log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError());

        }

        struDayNigh.read();

        log.debug("是否开启夜视：" + struDayNigh.struDayNight.byDayNightFilterType);

        String current = struDayNigh.struDayNight.byDayNightFilterType == 1 ? "开启" : "关闭";

        log.debug("当前状态:" + current);



        NET_DVR_DAYNIGHT daynight = new NET_DVR_DAYNIGHT();

        if (enable) {

            daynight.byDayNightFilterType = 1;//夜晚



        } else {

            daynight.byDayNightFilterType = 0;//白天

        }

@@ -1120,12 +1120,15 @@
        daynight.byDayNightFilterTime = 60;

        struDayNigh.struDayNight = daynight;

        struDayNigh.write();

        boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, channelNum, point, struDayNigh.size());

        boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, chanNo, point, struDayNigh.size());

        if (!bool) {

            int code = hCNetSDK.NET_DVR_GetLastError();

            log.error("设置夜视失败,请稍后重试" + code);

        }

        log.debug("设置夜视成功");

        else {

            log.debug("设置夜视成功");

        }



        return bool;

    }




 ard-work/src/main/resources/mapper/alarmpoints/ArdAlarmpointsWellMapper.xml

@@ -185,7 +185,35 @@
        </trim>
        where id = #{id}
    </update>

    <update id="updateArdAlarmpointsWellByWellId" parameterType="ArdAlarmpointsWell">
        update ard_alarmpoints_well
        <trim prefix="SET" suffixOverrides=",">
            <if test="wellId != null">well_id = #{wellId},</if>
            <if test="wellNumber != null">well_number = #{wellNumber},</if>
            <if test="oilProduction != null">oil_production = #{oilProduction},</if>
            <if test="wellBlock != null">well_block = #{wellBlock},</if>
            <if test="productionDate != null">production_date = #{productionDate},</if>
            <if test="displacementMode != null">displacement_mode = #{displacementMode},</if>
            <if test="surroundingEnvironment != null">surrounding_environment = #{surroundingEnvironment},</if>
            <if test="wellType != null">well_type = #{wellType},</if>
            <if test="installedLoad != null">installed_load = #{installedLoad},</if>
            <if test="meteringStation != null">metering_station = #{meteringStation},</if>
            <if test="transferStation != null">transfer_station = #{transferStation},</if>
            <if test="dehydrationStation != null">dehydration_station = #{dehydrationStation},</if>
            <if test="runStatus != null">run_status = #{runStatus},</if>
            <if test="longitude != null">longitude = #{longitude},</if>
            <if test="latitude != null">latitude = #{latitude},</if>
            <if test="altitude != null">altitude = #{altitude},</if>
            <if test="deptId != null">dept_id = #{deptId},</if>
            <if test="userId != null">user_id = #{userId},</if>
            <if test="createBy != null">create_by = #{createBy},</if>
            <if test="createTime != null">create_time = #{createTime},</if>
            <if test="updateBy != null">update_by = #{updateBy},</if>
            <if test="updateTime != null">update_time = #{updateTime},</if>
            <if test="cameraId != null">camera_id = #{cameraId},</if>
        </trim>
        where well_id = #{wellId}
    </update>
    <delete id="deleteArdAlarmpointsWellById" parameterType="String">
        delete
        from ard_alarmpoints_well

 ard-work/src/main/resources/mapper/device/ArdCameraNoGuideZoneMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,99 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ruoyi.device.noguidezone.mapper.ArdCameraNoGuideZoneMapper">
    
    <resultMap type="ArdCameraNoGuideZone" id="ArdCameraNoGuideZoneResult">
        <result property="name"    column="name"    />
        <result property="poi"    column="poi"    />
        <result property="cameraId"    column="camera_id"    />
        <result property="enabled"    column="enabled"    />
        <result property="deptId"    column="dept_id"    />
        <result property="userId"    column="user_id"    />
        <result property="createBy"    column="create_by"    />
        <result property="createTime"    column="create_time"    />
        <result property="updateBy"    column="update_by"    />
        <result property="updateTime"    column="update_time"    />
        <result property="id"    column="id"    />
    </resultMap>

    <sql id="selectArdCameraNoGuideZoneVo">
        select name, poi, camera_id, enabled, dept_id, user_id, create_by, create_time, update_by, update_time, id from ard_camera_no_guide_zone
    </sql>

    <select id="selectArdCameraNoGuideZoneList" parameterType="ArdCameraNoGuideZone" resultMap="ArdCameraNoGuideZoneResult">
        <include refid="selectArdCameraNoGuideZoneVo"/>
        <where>  
            <if test="name != null  and name != ''"> and name like '%'||#{name}||'%'</if>
            <if test="poi != null  and poi != ''"> and poi = #{poi}</if>
            <if test="cameraId != null  and cameraId != ''"> and camera_id = #{cameraId}</if>
            <if test="enabled != null  and enabled != ''"> and enabled = #{enabled}</if>
            <if test="deptId != null "> and dept_id = #{deptId}</if>
            <if test="userId != null  and userId != ''"> and user_id = #{userId}</if>
        </where>
    </select>
    
    <select id="selectArdCameraNoGuideZoneByName" parameterType="String" resultMap="ArdCameraNoGuideZoneResult">
        <include refid="selectArdCameraNoGuideZoneVo"/>
        where name = #{name}
    </select>
        
    <insert id="insertArdCameraNoGuideZone" parameterType="ArdCameraNoGuideZone">
        insert into ard_camera_no_guide_zone
        <trim prefix="(" suffix=")" suffixOverrides=",">
            <if test="name != null">name,</if>
            <if test="poi != null">poi,</if>
            <if test="cameraId != null">camera_id,</if>
            <if test="enabled != null">enabled,</if>
            <if test="deptId != null">dept_id,</if>
            <if test="userId != null">user_id,</if>
            <if test="createBy != null">create_by,</if>
            <if test="createTime != null">create_time,</if>
            <if test="updateBy != null">update_by,</if>
            <if test="updateTime != null">update_time,</if>
            <if test="id != null">id,</if>
         </trim>
        <trim prefix="values (" suffix=")" suffixOverrides=",">
            <if test="name != null">#{name},</if>
            <if test="poi != null">#{poi},</if>
            <if test="cameraId != null">#{cameraId},</if>
            <if test="enabled != null">#{enabled},</if>
            <if test="deptId != null">#{deptId},</if>
            <if test="userId != null">#{userId},</if>
            <if test="createBy != null">#{createBy},</if>
            <if test="createTime != null">#{createTime},</if>
            <if test="updateBy != null">#{updateBy},</if>
            <if test="updateTime != null">#{updateTime},</if>
            <if test="id != null">#{id},</if>
         </trim>
    </insert>

    <update id="updateArdCameraNoGuideZone" parameterType="ArdCameraNoGuideZone">
        update ard_camera_no_guide_zone
        <trim prefix="SET" suffixOverrides=",">
            <if test="poi != null">poi = #{poi},</if>
            <if test="cameraId != null">camera_id = #{cameraId},</if>
            <if test="enabled != null">enabled = #{enabled},</if>
            <if test="deptId != null">dept_id = #{deptId},</if>
            <if test="userId != null">user_id = #{userId},</if>
            <if test="createBy != null">create_by = #{createBy},</if>
            <if test="createTime != null">create_time = #{createTime},</if>
            <if test="updateBy != null">update_by = #{updateBy},</if>
            <if test="updateTime != null">update_time = #{updateTime},</if>
            <if test="id != null">id = #{id},</if>
        </trim>
        where name = #{name}
    </update>

    <delete id="deleteArdCameraNoGuideZoneByName" parameterType="String">
        delete from ard_camera_no_guide_zone where name = #{name}
    </delete>

    <delete id="deleteArdCameraNoGuideZoneByNames" parameterType="String">
        delete from ard_camera_no_guide_zone where name in 
        <foreach item="name" collection="array" open="(" separator="," close=")">
            #{name}
        </foreach>
    </delete>
</mapper>

 ard-work/src/main/resources/templates/test.html

@@ -4,133 +4,139 @@
    <meta charset="UTF-8">
    <title>测试页</title>
    <script th:src="@{/js/jquery-3.6.4.min.js}"></script>
    <script th:src="@{/js/adapter.min.js}"></script>
    <script th:src="@{/js/webrtcstreamer.js}"></script>
    <link rel="stylesheet" th:href="@{/css/bootstrap.css}"/>
    <script th:src="@{/js/bootstrap.js}"></script>
    <style>
        .top-buffer {
            margin-top: 10px;
        }

        .container {
            border: 2px solid #1b6d85;
            padding: 20px;
        }
    </style>
<body>
<div class="container">
    <div class="row ">
        <div class="dropdown">
            ç›¸æœºid：<select id="select">
        <div class="col-md-12">
            ç›¸æœºid：<select id="select" style="width: 330px;">
        </select>
        </div>
    </div>
    <div class="row top-buffer">
        <div class="col-md-1 col-md-offset-1">
            <button id="up" type="button" class="btn btn-primary">上</button>
        </div>
        <div class="col-md-4 col-md-offset-3">
            <div class="btn-group" role="group">
                <button id="controlZoomIn" type="button" class="btn btn-primary">调焦-</button>
                <button id="controlZoomOut" type="button" class="btn btn-primary">调焦+</button>
            </div>
        </div>
    </div>
    <div class="row ">
        <div class="col-md-1">
            <button id="left" type="button" class="btn btn-primary">å·¦</button>
        </div>
        <div class="col-md-1 col-md-offset-1">
            <button id="right" type="button" class="btn btn-primary">右</button>
        </div>
        <div class="col-md-4 col-md-offset-2">
            <div class="btn-group" role="group">
                <button id="controlFocusNear" type="button" class="btn btn-primary">聚焦-</button>
                <button id="controlFocusFar" type="button" class="btn btn-primary">聚焦+</button>
            </div>
        </div>
    </div>
    <div class="row ">
        <div class="col-md-1 col-md-offset-1">
            <button id="down" type="button" class="btn btn-primary">下</button>
        </div>
        <div class="col-md-4 col-md-offset-3">
            <div class="btn-group" role="group">
                <button id="controlIrisOpen" type="button" class="btn btn-primary">光圈-</button>
                <button id="controlIrisClose" type="button" class="btn btn-primary">光圈+</button>
            </div>
        </div>
    </div>
    <div class="row">
        <div class="col-md-6">
            <div class="row top-buffer">
                <div class="input-group">
                    <span class="input-group-addon">目的坐标值：</span>
                    <input id="targetPostion" class="form-control" placeholder="目的坐标"/>
                    <button id="setTargetPostion" type="button" class="btn btn-default">指向坐标</button>
                </div>
                <div class="input-group">
                    <span class="input-group-addon">P值：</span>
                    <input id="p" class="form-control" placeholder="请输入P值"/>
                </div>
                <div class="input-group">
                    <span class="input-group-addon">T值：</span>
                    <input id="t" class="form-control" placeholder="请输入T值"/>
                </div>
                <div class="input-group">
                    <span class="input-group-addon">Z值：</span>
                    <input id="z" class="form-control" placeholder="请输入Z值"/>
                </div>
            </div>
            <div class="row top-buffer">
                <div class="btn-group" role="group">
                    <button id="getPTZ" type="button" class="btn btn-default">获取ptz</button>
                    <button id="setPTZ" type="button" class="btn btn-default">设置ptz</button>
                    <button id="setPreset" type="button" class="btn btn-default">设预置点</button>
                    <button id="gotoPreset" type="button" class="btn btn-default">调预置点</button>
                    <button id="getZeroPTZ" type="button" class="btn btn-default">调用零方位角</button>
                    <button id="setZeroPTZ" type="button" class="btn btn-default">设置零方位角</button>
                </div>
            </div>
            <div class="row top-buffer">
                <div class="btn-group" role="group">
                    <button id="FocusMode" type="button" class="btn btn-default">手动聚焦</button>
                    <div id="focusDiv" class="input-group">
                        <span class="input-group-addon">聚焦值：</span>
                        <input id="focus" class="form-control" placeholder="聚焦值"/>
                    </div>
                    <button id="getFocusPos" type="button" class="btn btn-default">获取聚焦值</button>
                    <button id="setFocusPos" type="button" class="btn btn-default">设置聚焦值</button>
                </div>
            </div>
            <div class="row top-buffer">
                <div class="btn-group" role="group">
                    <button id="WiperPwron" type="button" class="btn btn-default">开启雨刷</button>
                    <button id="Defogcfg" type="button" class="btn btn-default">开启透雾</button>
                    <button id="Infrarecfg" type="button" class="btn btn-default">开启红外</button>
                    <button id="HeateRpwron" type="button" class="btn btn-default">开启云台加热</button>
                    <button id="CameraDeicing" type="button" class="btn btn-default">开启镜头加热</button>
                </div>
            </div>
            <div class="row top-buffer">
                <div class="btn-group" role="group">
                    <button id="voice" type="button" class="btn btn-default">开始语音对讲</button>
                    <button id="record" type="button" class="btn btn-default">开始录像</button>
                    <button id="realCutPic" type="button" class="btn btn-default">实时抓图</button>
                    <button id="saveCutPic" type="button" class="btn btn-default">存储抓图</button>
                </div>
            </div>
            <div class="row top-buffer">
                <div class="col-md-6">
                    <img class="thumbnail" id="imgContainer" style="width: 500px; height: 300px;"/>
                </div>
            </div>
        </div>
        <div class="col-md-1"/>
        <div class="col-md-5">
            <div class="row top-buffer">
                <video id="video" muted autoplay loop controls style="width: 800px; height: 100%; object-fit: fill;"/>
                <div class="col-md-1 col-md-offset-1">
                    <button id="up" type="button" class="btn btn-primary">上</button>
                </div>
                <div class="col-md-6 col-md-offset-2">
                    <div class="btn-group" role="group">
                        <button id="controlZoomIn" type="button" class="btn btn-primary">调焦-</button>
                        <button id="controlZoomOut" type="button" class="btn btn-primary">调焦+</button>
                    </div>
                </div>
            </div>
            <div class="row ">
                <div class="col-md-1">
                    <button id="left" type="button" class="btn btn-primary">å·¦</button>
                </div>
                <div class="col-md-1 col-md-offset-1">
                    <button id="right" type="button" class="btn btn-primary">右</button>
                </div>
                <div class="col-md-6 col-md-offset-1">
                    <div class="btn-group" role="group">
                        <button id="controlFocusNear" type="button" class="btn btn-primary">聚焦-</button>
                        <button id="controlFocusFar" type="button" class="btn btn-primary">聚焦+</button>
                    </div>
                </div>
            </div>
            <div class="row ">
                <div class="col-md-1 col-md-offset-1">
                    <button id="down" type="button" class="btn btn-primary">下</button>
                </div>
                <div class="col-md-6 col-md-offset-2">
                    <div class="btn-group" role="group">
                        <button id="controlIrisOpen" type="button" class="btn btn-primary">光圈-</button>
                        <button id="controlIrisClose" type="button" class="btn btn-primary">光圈+</button>
                    </div>
                </div>
            </div>
            <div class="row ">
                <div class="col-md-10">
                    <div class="row top-buffer">
                        <div class="input-group">
                            <span class="input-group-addon">目的坐标值：</span>
                            <input id="targetPostion" class="form-control" placeholder="目的坐标"/>
                            <button id="setTargetPostion" type="button" class="btn btn-default">指向坐标</button>
                        </div>
                        <div class="input-group">
                            <span class="input-group-addon">P值：</span>
                            <input id="p" class="form-control" placeholder="请输入P值"/>
                        </div>
                        <div class="input-group">
                            <span class="input-group-addon">T值：</span>
                            <input id="t" class="form-control" placeholder="请输入T值"/>
                        </div>
                        <div class="input-group">
                            <span class="input-group-addon">Z值：</span>
                            <input id="z" class="form-control" placeholder="请输入Z值"/>
                        </div>
                    </div>
                    <div class="row top-buffer">
                        <div class="btn-group" role="group">
                            <button id="getPTZ" type="button" class="btn btn-default">获取ptz</button>
                            <button id="setPTZ" type="button" class="btn btn-default">设置ptz</button>
                            <button id="setPreset" type="button" class="btn btn-default">设预置点</button>
                            <button id="gotoPreset" type="button" class="btn btn-default">调预置点</button>
                            <button id="setZeroPTZ" type="button" class="btn btn-default">设置零方位角</button>
                        </div>
                    </div>
                    <div class="row top-buffer">
                        <div class="btn-group" role="group">
                            <button id="FocusMode" type="button" class="btn btn-default">手动聚焦</button>
                            <div id="focusDiv" class="input-group">
                                <span class="input-group-addon">聚焦值：</span>
                                <input id="focus" class="form-control" placeholder="聚焦值"/>
                            </div>
                            <button id="getFocusPos" type="button" class="btn btn-default">获取聚焦值</button>
                            <button id="setFocusPos" type="button" class="btn btn-default">设置聚焦值</button>
                        </div>
                    </div>
                    <div class="row top-buffer">
                        <div class="btn-group" role="group">
                            <button id="WiperPwron" type="button" class="btn btn-default">开启雨刷</button>
                            <button id="Defogcfg" type="button" class="btn btn-default">开启透雾</button>
                            <button id="Infrarecfg" type="button" class="btn btn-default">开启红外</button>
                            <button id="HeateRpwron" type="button" class="btn btn-default">开启云台加热</button>
                            <button id="CameraDeicing" type="button" class="btn btn-default">开启镜头加热</button>
                        </div>
                    </div>
                    <div class="row top-buffer">
                        <div class="btn-group" role="group">
                            <button id="voice" type="button" class="btn btn-default">开始语音对讲</button>
                            <button id="record" type="button" class="btn btn-default">开始录像</button>
                            <button id="saveCutPic" type="button" class="btn btn-default">存储抓图</button>
                        </div>
                    </div>
                </div>
            </div>
        </div>
        <div class="col-md-6">
            <div class="row">
                <div class="row top-buffer">
                    <video id="video" muted autoplay loop controls
                           style="width: 100%; height: 360px; object-fit: fill; border: 2px solid #3498db;"/>
                </div>
                <div class="row">
                    <img class="thumbnail" id="imgContainer"
                         style="width: 100%; height: 360px; border: 2px solid #3498db;"/>
                </div>
            </div>
        </div>
    </div>
</div>
<script th:inline="javascript" th:type="module">
<script th:inline="javascript">

    var cameraId, opt, optOpen, optClose, token;
    window.onload = function () {
@@ -175,7 +181,6 @@
            dataType: "json",
            data: JSON.stringify(opt),
            success: function (data) {
                console.log(data);
                token = data.token;
            }
        })
@@ -589,20 +594,20 @@
        cameraId = $('#select option:selected').val();
        opt = {"cameraId": cameraId, "chanNo": 1};
        $.ajax({
                headers: {
                    'Accept': 'application/json',
                    'Content-Type': 'application/json',
                    'Authorization': token
                },
                url: "../cameraSdk/getFocusPos",
                type: "post",
                dataType: "json",
                data: JSON.stringify(opt),
                success: function (datas) {
                    console.log(datas);
                    $("#focus").val(datas.data);
                }
            })
            headers: {
                'Accept': 'application/json',
                'Content-Type': 'application/json',
                'Authorization': token
            },
            url: "../cameraSdk/getFocusPos",
            type: "post",
            dataType: "json",
            data: JSON.stringify(opt),
            success: function (datas) {
                console.log(datas);
                $("#focus").val(datas.data);
            }
        })
    })
    var heateRpwronflag = true;
    $("#HeateRpwron").click(function () {
@@ -656,7 +661,8 @@
            $.ajax({
                headers: {
                    'Accept': 'application/json',
                    'Content-Type': 'application/json'
                    'Content-Type': 'application/json',
                    'Authorization': token
                },
                url: "../cameraSdk/cameraDeicing",
                type: "post",
@@ -721,7 +727,7 @@
                console.log(data.data);
                setTimeout(() => {
                    $('#imgContainer').attr('src', data.data);
                }, 1000 )
                }, 1000)

            }
        })
@@ -790,67 +796,264 @@
        })
    }

    let webRtcServer = null;
    let videoMap = new Map();
    $('video').click(function (e) {
        let ID = e.target.id;//获取当前点击事件的元素
        console.log(ID);
        if (videoMap.get(ID) != null) {
            closeVideo(ID, videoMap.get(ID));
        } else {
            var cameraId = $('#select option:selected').val();
            let camera = cameraMap.get(cameraId);
            console.log(camera);
            if (camera.factory == "3") {
                realViewYs("127.0.0.1", ID, camera.username, camera.password, camera.ipaddr, camera.port);
            } else if (camera.factory == "2") {
                realViewDh("127.0.0.1", ID, camera.username, camera.password, camera.ipaddr, camera.port);
            } else {
                realViewHik("127.0.0.1", ID, camera.username, camera.password, camera.ipaddr, camera.port);
        var cameraId = $('#select option:selected').val();
        $.ajax({
            headers: {
                'Accept': 'application/json',
                'Content-Type': 'application/json',
                'Authorization': token
            },
            url: "../vtdu/media/" + cameraId + "_" + 1,
            type: "get",
            dataType: "json",
            success: function (data) {
                realView(data.data.webrtcUrl + "/", e.target.id);
            }
        }
        })
    });

    //预览海康相机
    function realViewHik(serverip, elem, username, password, ipaddr, port) {
       // webRtcServer = new WebRtcStreamer(elem, "http://" + serverip + ":8000");
        webRtcServer = new WebRtcStreamer(elem, "http://192.168.1.227:8000");
        let rtspUrl = "rtsp://" + username + ":" + password + "@" + ipaddr + ":" + port + "/ch1/main/av_stream";
        let option = "rtptransport=tcp";
        console.log("rtsp地址：" + rtspUrl);
        webRtcServer.connect(rtspUrl, null, option, null);
        videoMap.set(elem, webRtcServer);
    let webrtcClient;
    //whep操作方法
    const restartPause = 2000;
    const unquoteCredential = (v) => (
        JSON.parse(`"${v}"`)
    );
    const linkToIceServers = (links) => (
        (links !== null) ? links.split(', ').map((link) => {
            const m = link.match(/^<(.+?)>; rel="ice-server"(; username="(.*?)"; credential="(.*?)"; credential-type="password")?/i);
            const ret = {
                urls: [m[1]],
            };

            if (m[3] !== undefined) {
                ret.username = unquoteCredential(m[3]);
                ret.credential = unquoteCredential(m[4]);
                ret.credentialType = "password";
            }

            return ret;
        }) : []
    );
    const parseOffer = (offer) => {
        const ret = {
            iceUfrag: '',
            icePwd: '',
            medias: [],
        };

        for (const line of offer.split('\r\n')) {
            if (line.startsWith('m=')) {
                ret.medias.push(line.slice('m='.length));
            } else if (ret.iceUfrag === '' && line.startsWith('a=ice-ufrag:')) {
                ret.iceUfrag = line.slice('a=ice-ufrag:'.length);
            } else if (ret.icePwd === '' && line.startsWith('a=ice-pwd:')) {
                ret.icePwd = line.slice('a=ice-pwd:'.length);
            }
        }

        return ret;
    };
    const generateSdpFragment = (offerData, candidates) => {
        const candidatesByMedia = {};
        for (const candidate of candidates) {
            const mid = candidate.sdpMLineIndex;
            if (candidatesByMedia[mid] === undefined) {
                candidatesByMedia[mid] = [];
            }
            candidatesByMedia[mid].push(candidate);
        }

        let frag = 'a=ice-ufrag:' + offerData.iceUfrag + '\r\n'
            + 'a=ice-pwd:' + offerData.icePwd + '\r\n';

        let mid = 0;

        for (const media of offerData.medias) {
            if (candidatesByMedia[mid] !== undefined) {
                frag += 'm=' + media + '\r\n'
                    + 'a=mid:' + mid + '\r\n';

                for (const candidate of candidatesByMedia[mid]) {
                    frag += 'a=' + candidate.candidate + '\r\n';
                }
            }
            mid++;
        }

        return frag;
    }

    //预览大华相机
    function realViewDh(serverip, elem, username, password, ipaddr, port) {
        webRtcServer = new WebRtcStreamer(elem, "http://" + serverip + ":8000");
        let rtspUrl = "rtsp://" + username + ":" + password + "@" + ipaddr + ":" + port + "/cam/realmonitor?channel=1&subtype=0";
        let option = "rtptransport=tcp";
        console.log("rtsp地址：" + rtspUrl);
    class WHEPClient {
        constructor(whepUrl, videoId) {
            this.video = videoId;
            this.wurl = new URL('whep', whepUrl);
            this.pc = null;
            this.restartTimeout = null;
            this.eTag = '';
            this.queuedCandidates = [];
            this.start();
        }

        webRtcServer.connect(rtspUrl, null, option, null);
        videoMap.set(elem, webRtcServer);
        start() {
            console.log("requesting ICE servers");
            fetch(this.wurl, {
                method: 'OPTIONS',
            })
                .then((res) => this.onIceServers(res))
                .catch((err) => {
                    console.log('error: ' + err);
                    this.scheduleRestart();
                });
        }

        onIceServers(res) {
            this.pc = new RTCPeerConnection({
                iceServers: linkToIceServers(res.headers.get('Link')),
            });

            const direction = "sendrecv";
            this.pc.addTransceiver("video", {direction});
            this.pc.addTransceiver("audio", {direction});

            this.pc.onicecandidate = (evt) => this.onLocalCandidate(evt);
            this.pc.oniceconnectionstatechange = () => this.onConnectionState();

            this.pc.ontrack = (evt) => {
                console.log("new track:", evt.track.kind);
                document.getElementById(this.video).srcObject = evt.streams[0];
            };

            this.pc.createOffer()
                .then((offer) => this.onLocalOffer(offer));
        }

        onLocalOffer(offer) {
            this.offerData = parseOffer(offer.sdp);
            this.pc.setLocalDescription(offer);

            console.log("sending offer");
            console.log(this.wurl);
            fetch(this.wurl, {
                method: 'POST',
                headers: {
                    'Content-Type': 'application/sdp',
                },
                body: offer.sdp,
            })
                .then((res) => {
                    if (res.status !== 201) {
                        throw new Error('bad status code');
                    }
                    // this.eTag = res.headers.get('ETag');
                    this.eTag = res.headers.get("ETag") || res.headers.get('E-Tag');
                    return res.text();
                })
                .then((sdp) => this.onRemoteAnswer(new RTCSessionDescription({
                    type: 'answer',
                    sdp,
                })))
                .catch((err) => {
                    console.log('error: ' + err);
                    this.scheduleRestart();
                });
        }

        onConnectionState() {
            if (this.restartTimeout !== null) {
                return;
            }

            console.log("peer connection state:", this.pc.iceConnectionState);

            switch (this.pc.iceConnectionState) {
                case "disconnected":
                    this.scheduleRestart();
            }
        }

        onRemoteAnswer(answer) {
            if (this.restartTimeout !== null) {
                return;
            }

            this.pc.setRemoteDescription(new RTCSessionDescription(answer));

            if (this.queuedCandidates.length !== 0) {
                this.sendLocalCandidates(this.queuedCandidates);
                this.queuedCandidates = [];
            }
        }

        onLocalCandidate(evt) {
            if (this.restartTimeout !== null) {
                return;
            }

            if (evt.candidate !== null) {
                if (this.eTag === '') {
                    this.queuedCandidates.push(evt.candidate);
                } else {
                    this.sendLocalCandidates([evt.candidate])
                }
            }
        }

        sendLocalCandidates(candidates) {
            fetch(this.wurl, {
                method: 'PATCH',
                headers: {
                    'Content-Type': 'application/trickle-ice-sdpfrag',
                    'If-Match': this.eTag,
                },

                body: generateSdpFragment(this.offerData, candidates),
            })
                .then((res) => {
                    if (res.status !== 204) {
                        throw new Error('bad status code');
                    }
                })
                .catch((err) => {
                    console.log('error: ' + err);
                    this.scheduleRestart();
                });
        }

        scheduleRestart() {
            if (this.restartTimeout !== null) {
                return;
            }

            if (this.pc !== null) {
                this.pc.close();
                this.pc = null;
            }

            this.restartTimeout = window.setTimeout(() => {
                this.restartTimeout = null;
                this.start();
            }, restartPause);

            this.eTag = '';
            this.queuedCandidates = [];
        }

        stop() {
            if (this.pc) {
                try {
                    this.pc.close();
                } catch (e) {
                    console.log("Failure close peer connection:" + e);
                }
                this.pc = null;
            }
        }
    }

    //预览宇视相机
    function realViewYs(serverip, elem, username, password, ipaddr, port) {
        webRtcServer = new WebRtcStreamer(elem, "http://" + serverip + ":8000");
        let rtspUrl = "rtsp://" + username + ":" + password + "@" + ipaddr + ":" + port + "/media/video1/multicast";
        console.log("rtsp地址：" + rtspUrl);
        let option = "rtptransport=tcp";
        webRtcServer.connect(rtspUrl, null, option, null);
        videoMap.set(elem, webRtcServer);
    }

    function closeVideo(id, webrtc) {
        webrtc.disconnect();
        videoMap.delete(id);
    }

    //页面退出时销毁
    window.onbeforeunload = function () {
        webRtcServer.disconnect();
    function realView(whepUrl, videoId) {
        console.log(whepUrl)
        webrtcClient = new WHEPClient(whepUrl, videoId);
    }
</script>
</body>