app查询光电修改提交

zhangnaisong

2024-03-16 377f8bd94743a102b321b313d7e0824b39efa274

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

@@ -1,18 +1,30 @@
package com.ruoyi.device.camera.service.impl;

import java.text.SimpleDateFormat;
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;
@@ -22,10 +34,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业务层处理
@@ -42,13 +56,22 @@
    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);
@@ -74,7 +97,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;
    }

    /**
@@ -156,6 +188,8 @@
        if (res > 0) {
            for (String id : ids) {
                redisCache.deleteObject(getCacheKey(id));
                //删除流媒体
                vtduService.deleteVtduByCameraId(id);
                //删除当前相机的所有通道
                ardChannelMapper.deleteArdChannelByDeviceId(id);
            }
@@ -179,8 +213,94 @@
        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) {
        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;
    }

    /**
@@ -191,7 +311,6 @@
     * @创建时间 2023/6/2 10:58
     * @修改人和其它信息
     */

    @Override
    public Map getChildDeptAndCamera(Boolean disabled) {
        Long deptId = SecurityUtils.getDeptId();
@@ -200,6 +319,11 @@
        return map;
    }

    @Override
    public List<DeptAndCamerasDto> getChildDeptAndCamera() {
        List<SysDept> depts = deptService.selectDeptList(new SysDept());
        return fetchChildDepartments(depts);
    }
    /**
     * @描述 递归查询
     * @参数 [sysDept]
@@ -231,6 +355,7 @@
                ardChannel.setDeviceId(camera.getId());
                List<ArdChannel> ardChannels = ardChannelMapper.selectArdChannelList(ardChannel);
                if (ardChannels != null) {
                    ardChannels.stream().sorted();
                    camera.setChannelList(ardChannels);
                }
                Map<String, Object> cameraMap = ArdTool.convertEntityToMap(camera);
@@ -239,7 +364,34 @@
        }
        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;
    }

    /**
@@ -254,7 +406,7 @@
    public TreeMap getNearCamerasBycoordinate(CameraCmd cmd) {
        try {
            double[] targetPosition = cmd.getTargetPosition();
            if (targetPosition == null || (targetPosition != null && targetPosition.length == 0)) {
            if (targetPosition == null) {
                log.debug("目标位置为空");
                return new TreeMap<>();
            }
@@ -269,7 +421,7 @@
                    continue;
                }
                double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()};
                double distance = GisUtil.getDistance(cmd.getTargetPosition(), camPosition);
                double distance = GisUtil.getDistance(targetPosition, camPosition);
                if (camera.getCamMaxVisibleDistance() == null) {
                    continue;
                }
@@ -393,4 +545,70 @@
        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;
    }

    @Override
    public List<Map<String, Object>> getCamerasByDeptId(Long deptId,String userId) {
        List<Map<String, Object>> result = ardCamerasMapper.getCamerasByDeptId(deptId,userId);
        return result;
    }

    @Override
    public Boolean getCameraOperationByCameraId(String id, String userId) {
        Boolean result = ardCamerasMapper.getCameraOperationByCameraId(id,userId);
        return result;
    }

    @Override
    public Map<String, Object> getChannelByCameraId(String id) {
        List<Map<String,Object>> result = ardCamerasMapper.getChannelByCameraId(id);
        Map<String,Object> resultMap = new HashMap();
        if(result.size() == 1){
            resultMap.put("chanNo", result.get(0).get("chan_no"));
            return resultMap;
        }else{
            String configValue = (String) result.get(0).get("config_value");
            String beginTime = configValue.split("-")[0];
            String endTime = configValue.split("-")[1];
            Date now = new Date();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            String nowDay = sdf.format(now);
            try{
                Long beginDate = sdf.parse(nowDay).getTime()
                        + Integer.parseInt(beginTime.split(":")[0]) * 60 * 60 *1000
                        + Integer.parseInt(beginTime.split(":")[1]) * 60 *1000;
                Long endDate = sdf.parse(nowDay).getTime()
                        + Integer.parseInt(endTime.split(":")[0]) * 60 * 60 *1000
                        + Integer.parseInt(endTime.split(":")[1]) * 60 *1000;
                if(now.getTime() >= beginDate && now.getTime() <= endDate){
                    result = result.stream().filter(map -> ((Integer)map.get("chan_no")) == 1).collect(Collectors.toList());
                    resultMap.put("chanNo", result.get(0).get("chan_no"));
                    return resultMap;
                }else{
                    result = result.stream().filter(map -> ((Integer)map.get("chan_no")) == 2).collect(Collectors.toList());
                    resultMap.put("chanNo", result.get(0).get("chan_no"));
                    return resultMap;
                }
            }catch (Exception e){
                e.printStackTrace();
                return resultMap;
            }
        }
    }
}