From f97d74f9f851ef70048fab599d7bc54d7932afc7 Mon Sep 17 00:00:00 2001 From: Administrator <1144154118@qq.com> Date: 星期三, 23 八月 2023 17:29:44 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java | 134 +++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 125 insertions(+), 9 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 7a1a5be..245b74e 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,7 +1,7 @@ package com.ruoyi.device.camera.service.impl; -import java.time.LocalTime; import java.util.*; +import java.util.stream.Collectors; import com.ruoyi.common.constant.CacheConstants; import com.ruoyi.common.core.domain.entity.SysDept; @@ -10,8 +10,9 @@ import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.uuid.IdUtils; import com.ruoyi.device.camera.domain.CameraCmd; -import com.ruoyi.device.hiksdk.common.GlobalVariable; -import com.ruoyi.system.domain.SysConfig; +import com.ruoyi.device.channel.domain.ArdChannel; +import com.ruoyi.device.channel.mapper.ArdChannelMapper; +import com.ruoyi.scheduling.domian.SchedulingParam; import com.ruoyi.utils.tools.ArdTool; import com.ruoyi.device.camera.domain.ArdCameras; import com.ruoyi.device.camera.mapper.ArdCamerasMapper; @@ -19,6 +20,7 @@ import com.ruoyi.common.annotation.DataScope; import com.ruoyi.system.mapper.SysDeptMapper; import com.ruoyi.utils.tools.GisTool; +import com.ruoyi.utils.tools.Point; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; @@ -40,6 +42,9 @@ private SysDeptMapper sysDeptMapper; @Resource private RedisCache redisCache; + + @Resource + private ArdChannelMapper ardChannelMapper; @PostConstruct @@ -137,11 +142,11 @@ @Override public int deleteArdCamerasByIds(String[] ids) { int res = ardCamerasMapper.deleteArdCamerasByIds(ids); - if(res>0) - { - for(String id:ids) - { + if (res > 0) { + for (String id : ids) { redisCache.deleteObject(getCacheKey(id)); + //鍒犻櫎褰撳墠鐩告満鐨勬墍鏈夐�氶亾 + ardChannelMapper.deleteArdChannelByDeviceId(id); } } return res; @@ -155,7 +160,12 @@ */ @Override public int deleteArdCamerasById(String id) { - return ardCamerasMapper.deleteArdCamerasById(id); + int i = ardCamerasMapper.deleteArdCamerasById(id); + if (i > 0) { + //鍒犻櫎褰撳墠鐩告満鐨勬墍鏈夐�氶亾 + ardChannelMapper.deleteArdChannelByDeviceId(id); + } + return i; } public List findOptions(ArdCameras ardCameras) { @@ -206,6 +216,13 @@ } 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); } @@ -248,7 +265,7 @@ } if (distance != 0.0 && distance <= camera.getCamMaxVisibleDistance()) { distanceMap.put(camera.getId(), distance); - camera.setChannel(ArdTool.getChannelBydayNightTime(dayNightTime)); + camera.setChanNo(ArdTool.getChannelBydayNightTime(dayNightTime)); ardCameras.put(distance, camera); } @@ -260,5 +277,104 @@ 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 = GisTool.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 = GisTool.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; + } } -- Gitblit v1.9.3