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 | 468 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 462 insertions(+), 6 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 45f092a..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,6 +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) { + 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