From 7dfd5f52332212d2f2c111cc11147469a68b7bdb Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期一, 11 三月 2024 17:23:34 +0800
Subject: [PATCH] 取消坐标数组改为实体类

---
 ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java |  466 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 459 insertions(+), 7 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java b/ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java
index 6ebfb97..cfb7b29 100644
--- a/ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java
@@ -1,16 +1,44 @@
 package com.ruoyi.device.camera.service.impl;
 
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
 
+import com.ruoyi.alarm.global.domain.GuidePoint;
+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.camera.domain.DeptAndCamerasDto;
+import com.ruoyi.device.channel.domain.ArdChannel;
+import com.ruoyi.device.channel.mapper.ArdChannelMapper;
+import com.ruoyi.media.service.IVtduService;
+import com.ruoyi.scheduling.domian.SchedulingParam;
+import com.ruoyi.system.service.ISysDeptService;
+import com.ruoyi.utils.gis.GisUtil;
+import com.ruoyi.utils.tools.ArdTool;
 import com.ruoyi.device.camera.domain.ArdCameras;
 import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
 import com.ruoyi.device.camera.service.IArdCamerasService;
 import com.ruoyi.common.annotation.DataScope;
+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涓氬姟灞傚鐞�
@@ -19,9 +47,46 @@
  * @date 2023-02-11
  */
 @Service
+@Slf4j
 public class ArdCamerasServiceImpl implements IArdCamerasService {
     @Resource
     private ArdCamerasMapper ardCamerasMapper;
+    @Resource
+    private SysDeptMapper sysDeptMapper;
+    @Resource
+    private RedisCache redisCache;
+    @Autowired
+    private ISysDeptService deptService;
+    @Resource
+    private ArdChannelMapper ardChannelMapper;
+    @Resource
+    private IVtduService vtduService;
+    @Autowired
+    protected Validator validator;
+
+    @PostConstruct
+    public void loadCameras() {
+
+        //娓呯┖鐩告満缂撳瓨
+        Collection<String> cacheKeys = redisCache.keys(getCacheKey("*"));
+        redisCache.deleteObject(cacheKeys);
+        //閲嶆柊鍔犺浇鐩告満鍒扮紦瀛�
+        List<ArdCameras> ardCameras = selectArdCamerasListNoDataScope(new ArdCameras());
+        for (ArdCameras ardCamera : ardCameras) {
+            redisCache.setCacheObject(getCacheKey(ardCamera.getId()), ardCamera);
+        }
+
+    }
+
+    /**
+     * 璁剧疆cache key
+     *
+     * @param configKey 鍙傛暟閿�
+     * @return 缂撳瓨閿甼ey
+     */
+    private String getCacheKey(String configKey) {
+        return CacheConstants.CAMERA_LIST_KEY + configKey;
+    }
 
     /**
      * 鏌ヨ鐩告満璁惧
@@ -31,7 +96,16 @@
      */
     @Override
     public ArdCameras selectArdCamerasById(String id) {
-        return ardCamerasMapper.selectArdCamerasById(id);
+        ArdCameras ardCameras = ardCamerasMapper.selectArdCamerasById(id);
+        if (ardCameras != null) {
+            ArdChannel ardChannel = new ArdChannel();
+            ardChannel.setDeviceId(ardCameras.getId());
+            List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+            if (ardChannels != null) {
+                ardCameras.setChannelList(ardChannels);
+            }
+        }
+        return ardCameras;
     }
 
     /**
@@ -43,7 +117,18 @@
     @Override
     @DataScope(deptAlias = "d", userAlias = "u")
     public List<ArdCameras> selectArdCamerasList(ArdCameras ardCameras) {
-        return ardCamerasMapper.selectArdCamerasList(ardCameras);
+        List<ArdCameras> ardCamerasList = ardCamerasMapper.selectArdCamerasList(ardCameras);
+        if (ardCamerasList.size() > 0) {
+            for (ArdCameras camera : ardCamerasList) {
+                ArdChannel ardChannel = new ArdChannel();
+                ardChannel.setDeviceId(camera.getId());
+                List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                if (ardChannels != null) {
+                    camera.setChannelList(ardChannels);
+                }
+            }
+        }
+        return ardCamerasList;
     }
 
     /**
@@ -65,9 +150,11 @@
      */
     @Override
     public int insertArdCameras(ArdCameras ardCameras) {
+        ardCameras.setId(IdUtils.simpleUUID());
         ardCameras.setCreateBy(SecurityUtils.getUsername());
         ardCameras.setCreateTime(DateUtils.getNowDate());
         ardCameras.setUserId(SecurityUtils.getUserId());
+        redisCache.setCacheObject(getCacheKey(ardCameras.getId()), ardCameras);
         return ardCamerasMapper.insertArdCameras(ardCameras);
     }
 
@@ -80,7 +167,12 @@
     @Override
     public int updateArdCameras(ArdCameras ardCameras) {
         ardCameras.setUpdateTime(DateUtils.getNowDate());
-        return ardCamerasMapper.updateArdCameras(ardCameras);
+        int res = ardCamerasMapper.updateArdCameras(ardCameras);
+        if (res > 0) {
+            redisCache.deleteObject(getCacheKey(ardCameras.getId()));
+            redisCache.setCacheObject(getCacheKey(ardCameras.getId()), ardCameras);
+        }
+        return res;
     }
 
     /**
@@ -91,7 +183,17 @@
      */
     @Override
     public int deleteArdCamerasByIds(String[] ids) {
-        return ardCamerasMapper.deleteArdCamerasByIds(ids);
+        int res = ardCamerasMapper.deleteArdCamerasByIds(ids);
+        if (res > 0) {
+            for (String id : ids) {
+                redisCache.deleteObject(getCacheKey(id));
+                //鍒犻櫎娴佸獟浣�
+                vtduService.deleteVtduByCameraId(id);
+                //鍒犻櫎褰撳墠鐩告満鐨勬墍鏈夐�氶亾
+                ardChannelMapper.deleteArdChannelByDeviceId(id);
+            }
+        }
+        return res;
     }
 
     /**
@@ -102,10 +204,360 @@
      */
     @Override
     public int deleteArdCamerasById(String id) {
-        return ardCamerasMapper.deleteArdCamerasById(id);
+        int i = ardCamerasMapper.deleteArdCamerasById(id);
+        if (i > 0) {
+            //鍒犻櫎褰撳墠鐩告満鐨勬墍鏈夐�氶亾
+            ardChannelMapper.deleteArdChannelByDeviceId(id);
+        }
+        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 + "銆佺浉鏈篒D " + camera.getId() + " 瀵煎叆鎴愬姛");
+                } else if (isUpdateSupport) {
+                    BeanValidators.validateWithException(validator, camera);
+                    checkCameraDataScope(camera.getUserId());
+                    camera.setUpdateBy(operName);
+                    this.updateArdCameras(camera);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "銆佺浉鏈篒D " + camera.getId() + " 鏇存柊鎴愬姛");
+                } else {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "銆佺浉鏈篒D " + camera.getId() + " 宸插瓨鍦�");
+                }
+            } catch (Exception e) {
+                failureNum++;
+                String msg = "<br/>" + failureNum + "銆佺浉鏈篒D " + camera.getId() + " 瀵煎叆澶辫触锛�";
+                failureMsg.append(msg + e.getMessage());
+                log.error(msg, e);
+            }
+        }
+        if (failureNum > 0) {
+            failureMsg.insert(0, "寰堟姳姝夛紝瀵煎叆澶辫触锛佸叡 " + failureNum + " 鏉℃暟鎹牸寮忎笉姝g‘锛岄敊璇涓嬶細");
+            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) {
-        return ardCamerasMapper.findOptions(ardCameras);
+        List<ArdCameras> options = ardCamerasMapper.findOptions(ardCameras);
+        for (ArdCameras camera :
+                options) {
+            ArdChannel ardChannel = new ArdChannel();
+            ardChannel.setDeviceId(camera.getId());
+            List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+            camera.setChannelList(ardChannels);
+        }
+        return options;
+    }
+
+    /**
+     * @鎻忚堪 鑾峰彇鏈儴闂ㄤ互涓嬬殑鎵�鏈夌浉鏈哄拰閮ㄩ棬
+     * @鍙傛暟 []
+     * @杩斿洖鍊� java.util.Map
+     * @鍒涘缓浜� 鍒樿嫃涔�
+     * @鍒涘缓鏃堕棿 2023/6/2 10:58
+     * @淇敼浜哄拰鍏跺畠淇℃伅
+     */
+    @Override
+    public Map getChildDeptAndCamera(Boolean disabled) {
+        Long deptId = SecurityUtils.getDeptId();
+        SysDept sysDept = sysDeptMapper.selectDeptById(deptId);
+        Map<String, Object> map = fetchChildDepartments(sysDept, disabled);
+        return map;
+    }
+
+    @Override
+    public List<DeptAndCamerasDto> getChildDeptAndCamera() {
+        List<SysDept> depts = deptService.selectDeptList(new SysDept());
+        return fetchChildDepartments(depts);
+    }
+    /**
+     * @鎻忚堪 閫掑綊鏌ヨ
+     * @鍙傛暟 [sysDept]
+     * @杩斿洖鍊� java.util.Map<java.lang.String, java.lang.Object>
+     * @鍒涘缓浜� 鍒樿嫃涔�
+     * @鍒涘缓鏃堕棿 2023/6/2 14:38
+     * @淇敼浜哄拰鍏跺畠淇℃伅
+     */
+    public Map<String, Object> fetchChildDepartments(SysDept sysDept, Boolean disabled) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("name", sysDept.getDeptName());
+        map.put("deptId", sysDept.getDeptId());
+        map.put("disabled", disabled);
+        List<SysDept> sysDepts = sysDeptMapper.selectNextChildrenDeptById(sysDept.getDeptId());
+        List<ArdCameras> ardCameras = ardCamerasMapper.selectArdCamerasByDeptId(sysDept.getDeptId());
+        List<Object> childList = new ArrayList<>();
+        for (SysDept childDept : sysDepts) {
+            Map<String, Object> childMap = new HashMap<>();
+            childMap.put("name", childDept.getDeptName());
+            childMap.put("deptId", childDept.getDeptId());
+            childMap.put("disabled", disabled);
+            Map<String, Object> map1 = fetchChildDepartments(childDept, disabled);
+            childMap.putAll(map1);
+            childList.add(childMap);
+        }
+        if (ardCameras.size() > 0) {
+            for (ArdCameras camera : ardCameras) {
+                ArdChannel ardChannel = new ArdChannel();
+                ardChannel.setDeviceId(camera.getId());
+                List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                if (ardChannels != null) {
+                    camera.setChannelList(ardChannels);
+                }
+                Map<String, Object> cameraMap = ArdTool.convertEntityToMap(camera);
+                childList.add(cameraMap);
+            }
+        }
+        map.put("children", childList);
+        return map;
+    }
+
+    /**
+     * 鑾峰彇鎵�鏈夐儴闂ㄥ強閮ㄩ棬涓嬬殑鐩告満
+     * 鍒樿嫃涔�
+     * 2024/3/4 14:45:03
+     */
+    public List<DeptAndCamerasDto> fetchChildDepartments(List<SysDept> sysDepts) {
+
+        List<DeptAndCamerasDto> deptAndCamerasList = sysDepts.stream()
+                .map(sysDept -> {
+                    List<ArdCameras> ardCameras = ardCamerasMapper.selectArdCamerasByDeptId(sysDept.getDeptId());
+                    ardCameras.stream().forEach(ardCamera ->{
+                        ArdChannel  ardChannel = new ArdChannel();
+                        ardChannel.setDeviceId(ardCamera.getId());
+                        List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                        if (ardChannels != null) {
+                            ardCamera.setChannelList(ardChannels);
+                        }
+                    });
+                    DeptAndCamerasDto deptAndCamerasDto = new DeptAndCamerasDto();
+                    deptAndCamerasDto.setSysDept(sysDept);
+                    deptAndCamerasDto.setArdCamerasList(ardCameras);
+                    return deptAndCamerasDto;
+                })
+                .collect(Collectors.toList());
+
+        return deptAndCamerasList;
+    }
+
+    /**
+     * @鎻忚堪 閫氳繃鍧愭爣鑾峰彇闄勮繎鐨勭浉鏈�
+     * @鍙傛暟 [cmd]
+     * @杩斿洖鍊� java.util.Map
+     * @鍒涘缓浜� 鍒樿嫃涔�
+     * @鍒涘缓鏃堕棿 2023/6/17 11:55
+     * @淇敼浜哄拰鍏跺畠淇℃伅
+     */
+    @Override
+    public TreeMap getNearCamerasBycoordinate(CameraCmd cmd) {
+        try {
+            double[] targetPosition = cmd.getTargetPosition();
+            if (targetPosition == null) {
+                log.debug("鐩爣浣嶇疆涓虹┖");
+                return new TreeMap<>();
+            }
+            String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
+            //鑾峰彇鎵�鏈夊ぇ鍏夌數
+            List<ArdCameras> ardCamerasList = ardCamerasMapper.selectArdCamerasList(new ArdCameras("1"));
+            //缁熻鎵�鏈夊ぇ鍏夌數鍙鑼冨洿鍐呬笌鎶ヨ鐐圭殑璺濈
+            Map<String, Double> distanceMap = new HashMap<>();
+            TreeMap<Double, ArdCameras> ardCameras = new TreeMap<>();
+            for (ArdCameras camera : ardCamerasList) {
+                if (camera.getLongitude() == null && camera.getLatitude() == null) {
+                    continue;
+                }
+                double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()};
+                double distance = GisUtil.getDistance(targetPosition, camPosition);
+                if (camera.getCamMaxVisibleDistance() == null) {
+                    continue;
+                }
+                if (distance != 0.0 && distance <= camera.getCamMaxVisibleDistance()) {
+                    distanceMap.put(camera.getId(), distance);
+                    camera.setChanNo(ArdTool.getChannelBydayNightTime(dayNightTime));
+                    ardCameras.put(distance, camera);
+                }
+                //鑾峰彇閫氶亾鍒楄〃
+                ArdChannel ardChannel = new ArdChannel();
+                ardChannel.setDeviceId(camera.getId());
+                List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                if (ardChannels != null) {
+                    camera.setChannelList(ardChannels);
+                }
+            }
+            return ardCameras;
+        } catch (Exception ex) {
+            log.error("鑾峰彇闄勮繎鐩告満寮傚父:" + ex.getMessage());
+        }
+        return null;
+    }
+
+    /**
+     * 鑾峰彇鐩戞帶鍦堝唴鎵�鏈夊湪绾垮厜鐢�
+     * 鍒樿嫃涔�
+     * 2023/8/17 13:57:21
+     */
+    @Override
+    public List<ArdCameras> getNearCameras(SchedulingParam param) {
+        try {
+            Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
+            Double longitude = param.getLongitude();
+            Double latitude = param.getLatitude();
+            if (longitude == null && latitude == null) {
+                log.debug("鍘熺偣鍧愭爣涓虹┖");
+                return null;
+            }
+            Integer radius = param.getMonitoringRadius();
+            if (radius == null) {
+                log.debug("鐩戞帶鍦堝崐寰勮窛绂讳负绌�");
+                return null;
+            }
+            String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
+            //鑾峰彇鎵�鏈夊厜鐢�(鎸夐儴闂�)
+            ArdCameras cameras = new ArdCameras();
+            cameras.setDeptId(deptId);
+            List<ArdCameras> ardCamerasList = ardCamerasMapper.selectArdCamerasList(cameras);
+            //缁熻鎵�鏈夊厜鐢靛彲瑙嗚寖鍥村唴涓庢姤璀︾偣鐨勮窛绂�
+            List<ArdCameras> ardCameras = new ArrayList<>();
+            for (ArdCameras camera : ardCamerasList) {
+                if (camera.getLongitude() == null && camera.getLatitude() == null) {
+                    continue;
+                }
+                double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()};
+                double distance = GisUtil.getDistance(new double[]{longitude, latitude}, camPosition);
+                if (distance <= radius) {
+                    /*鑾峰彇閫氶亾鍒楄〃*/
+                    ArdChannel ardChannel = new ArdChannel();
+                    ardChannel.setDeviceId(camera.getId());
+                    List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                    camera.setChannelList(ardChannels);
+                    ardCameras.add(camera);
+                }
+            }
+            //杩囨护鍦ㄧ嚎鐩告満
+            List<ArdCameras> onlineList = ardCameras.stream()
+                    .filter(ardCamera -> (!ardCamera.getLoginId().equals(-1)))
+                    .collect(Collectors.toList());
+            return onlineList;
+        } catch (Exception ex) {
+            log.error("鑾峰彇闄勮繎鐩告満寮傚父:" + ex.getMessage());
+        }
+        return null;
+    }
+
+    /**
+     * 鑾峰彇鐩戞帶鍦堝唴鎵�鏈夊湪绾垮厜鐢�
+     * 鍒樿嫃涔�
+     * 2023/8/17 13:57:21
+     */
+    @Override
+    public List<ArdCameras> getNearCamerasWithPolygon(SchedulingParam param) {
+        try {
+            Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
+            List<Point> partitionLocation = param.getPartitionLocation();
+            if (partitionLocation == null) {
+                log.debug("澶氳竟褰㈠潗鏍囬泦鍚堜负绌�");
+                return null;
+            }
+            String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
+            //鑾峰彇鎵�鏈夊厜鐢�(鎸夐儴闂�)
+            ArdCameras cameras = new ArdCameras();
+            cameras.setDeptId(deptId);
+            List<ArdCameras> ardCamerasList = ardCamerasMapper.selectArdCamerasList(cameras);
+            List<ArdCameras> ardCameras = new ArrayList<>();
+            for (ArdCameras camera : ardCamerasList) {
+                if (camera.getLongitude() == null && camera.getLatitude() == null) {
+                    continue;
+                }
+                /*鍒ゆ柇鍧愭爣鏄惁鍦ㄥ杈瑰舰鑼冨洿鍐�*/
+                Point camPosition = new Point(camera.getLongitude(), camera.getLatitude());
+                boolean inPolygon = GisUtil.isInPolygon(camPosition, partitionLocation);
+                if (inPolygon) {
+                    /*鑾峰彇閫氶亾鍒楄〃*/
+                    ArdChannel ardChannel = new ArdChannel();
+                    ardChannel.setDeviceId(camera.getId());
+                    List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
+                    camera.setChannelList(ardChannels);
+                    ardCameras.add(camera);
+                }
+            }
+            //杩囨护鍦ㄧ嚎鐩告満
+            List<ArdCameras> onlineList = ardCameras.stream()
+                    .filter(ardCamera -> (!ardCamera.getLoginId().equals(-1)))
+                    .collect(Collectors.toList());
+            return onlineList;
+        } catch (Exception ex) {
+            log.error("鑾峰彇闄勮繎鐩告満寮傚父:" + ex.getMessage());
+        }
+        return null;
+    }
+
+    /**
+     * 鏍¢獙鐩告満鏄惁鍞竴
+     *
+     * @param camera 鐩告満
+     * @return 缁撴灉
+     */
+    @Override
+    public String checkCameraIpAndPortUnique(ArdCameras camera) {
+        String id = camera.getId();
+        String ip = camera.getIp();
+        Integer port = camera.getPort();
+        ArdCameras info = ardCamerasMapper.checkCameraIpAndPortUnique(ip, port);
+        if (StringUtils.isNotNull(info) && !info.getId().equals(id)) {
+            return CameraConstants.NOT_UNIQUE;
+        }
+        return CameraConstants.UNIQUE;
     }
 }

--
Gitblit v1.9.3