新增配置工具类 迁移配置信息实体类到common包

‘liusuyi’

2023-08-23 cf7a09fdfb98e41039e08af1ff5e9dacfbecfc03

新增配置工具类
迁移配置信息实体类到common包

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

@@ -1,7 +1,5 @@
package com.ruoyi.device.camera.service.impl;

import java.awt.geom.Point2D;
import java.time.LocalTime;
import java.util.*;
import java.util.stream.Collectors;

@@ -14,11 +12,7 @@
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.channel.domain.ArdChannel;
import com.ruoyi.device.channel.mapper.ArdChannelMapper;
import com.ruoyi.device.channel.service.IArdChannelService;
import com.ruoyi.device.hiksdk.common.GlobalVariable;
import com.ruoyi.device.hiksdk.service.IHikClientService;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.utils.tools.ArdTool;
import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
@@ -27,7 +21,6 @@
import com.ruoyi.system.mapper.SysDeptMapper;
import com.ruoyi.utils.tools.GisTool;
import com.ruoyi.utils.tools.Point;
import com.sun.org.apache.bcel.internal.generic.NEW;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;


 ard-work/src/main/java/com/ruoyi/storage/minio/utils/MinioConfig.java

@@ -1,5 +1,6 @@
package com.ruoyi.storage.minio.utils;

import io.minio.MinioClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
@@ -16,60 +17,19 @@
@Component
public class MinioConfig {
    @Value("${minio.endpoint}")
    private  String endpoint;
    private String endpoint;
    @Value("${minio.accessKey}")
    private  String accessKey;
    private String accessKey;
    @Value("${minio.secretKey}")
    private  String secretKey;

//    private volatile static MinioClient minioClient;
    private String secretKey;

    @Bean
    public io.minio.MinioClient getMinioClient() {
        return io.minio.MinioClient.builder()
    public MinioClient getMinioClient() {
        return MinioClient.builder()
                .endpoint(endpoint)
                .credentials(accessKey, secretKey)
                .build();
    }

//    /**
//     * èŽ·å–minio客户端实例
//     *
//     * @return {@link MinioClient}
//     */
//    public static MinioClient getMinioClient() {
//        if (minioClient == null) {
//            synchronized (MinioClientSingleton.class) {
//                if (minioClient == null) {
//                    minioClient = MinioClient.builder()
//                            .endpoint(endpoint)
//                            .credentials(accessKey, secretKey)
//                            .build();
//                }
//            }
//        }
//        return minioClient;
//    }
    //    static {
//        domainUrl = getYmlNew("minio.endpoint");
//        accessKey = getYmlNew("minio.accessKey");
//        secretKey = getYmlNew("minio.secretKey");
//        log.debug("minio信息：" + domainUrl + "(" + accessKey + "/" + secretKey + ")");
//    }
    /*yml配置信息获取*/
//    public static String getYmlNew(String key) {
//        Resource resource = new ClassPathResource("application-prod.yml");
//        Properties properties = null;
//        try {
//            YamlPropertiesFactoryBean yamlFactory = new YamlPropertiesFactoryBean();
//            yamlFactory.setResources(resource);
//            properties = yamlFactory.getObject();
//        } catch (Exception e) {
//            e.printStackTrace();
//            return null;
//        }
//        return properties.get(key).toString();
//    }

}


 ard-work/src/main/java/com/ruoyi/storage/minio/utils/MinioUtils.java

@@ -355,6 +355,7 @@

    /**
     * èŽ·å–单个桶中的所有文件对象名称
     *
     * @param [bucket,prefix]
     * @return {@link List}<{@link String}>
     */
@@ -571,7 +572,7 @@

    /**
     * @描述 èŽ·å–桶中所有对象
     * @参数 [bucketName,prefix]
     * @参数 [bucketName, prefix]
     * @返回值 java.lang.Iterable<io.minio.Result < io.minio.messages.Item>>
     * @创建人 åˆ˜è‹ä¹‰
     * @创建时间 2023/2/6 10:32

 ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java

@@ -13,7 +13,7 @@
import com.ruoyi.sy.gps31.PushClientImplAlarm;
import com.ruoyi.sy.gps31.PushClientImplPosition;
import com.ruoyi.sy.service.IArdSyUserService;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.system.service.ISysConfigService;
import com.ruoyi.system.service.ISysDeptService;
import com.ruoyi.system.service.ISysUserService;

 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java

@@ -23,19 +23,16 @@
import com.ruoyi.sy.mapper.ArdSyCarDayMapper;
import com.ruoyi.utils.tools.GisTool;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import com.ruoyi.storage.minio.utils.MinioConfig;
import com.ruoyi.storage.minio.utils.MinioUtils;
import com.ruoyi.sy.domain.ArdSyUser;
import com.ruoyi.sy.gps31.PositionContainer;
import com.ruoyi.sy.mapper.ArdSyUserMapper;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.utils.forest.SYClient;
import com.ruoyi.utils.result.Results;
import io.minio.GetPresignedObjectUrlArgs;
import io.minio.ListObjectsArgs;
import io.minio.PutObjectArgs;
import io.minio.Result;
import io.minio.http.Method;
import io.minio.messages.Item;

 ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java

@@ -8,9 +8,20 @@
 * @Version: 1.0
 **/

import com.ruoyi.common.utils.ConfigUtils;
import com.ruoyi.common.utils.DictUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.sql.*;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;

@Slf4j
@Component
public class ReadAccessDatabase {

    public static void main(String[] args) {

 ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysConfigController.java

@@ -23,7 +23,7 @@
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.system.service.ISysConfigService;

/**

 ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysConfig.java

ÎļþÃû´Ó ruoyi-system/src/main/java/com/ruoyi/system/domain/SysConfig.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.ruoyi.system.domain;
package com.ruoyi.common.core.domain.entity;

import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Size;

 ruoyi-common/src/main/java/com/ruoyi/common/core/redis/RedisCache.java

@@ -1,10 +1,6 @@
package com.ruoyi.common.core.redis;

import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.*;
import java.util.concurrent.TimeUnit;

import org.springframework.beans.factory.annotation.Autowired;
@@ -249,8 +245,22 @@
     * æ ¹æ®å‰ç¼€èŽ·å–所有的key* ä¾‹å¦‚：pro_
     */
    public List<Object> getListKey(String prefix) {
        Set<Object> keys = redisTemplate.keys(prefix+"*");
        Set<Object> keys = redisTemplate.keys(prefix + "*");
        List<Object> values = redisTemplate.opsForValue().multiGet(keys);
        return values;
    }

    /**
     * æ ¹æ®å‰ç¼€èŽ·å–所有的key* ä¾‹å¦‚：pro_
     */
    public HashMap<String, Object> getMapKey(String prefix) {
        HashMap<String, Object> map = new HashMap<>();
        Set<String> keys = redisTemplate.keys(prefix + "*");
        for (String key : keys) {
            Object value = redisTemplate.opsForValue().get(key);
            String nKey = key.replace(prefix, "");
            map.put(nKey, value);
        }
        return map;
    }
}

 ruoyi-common/src/main/java/com/ruoyi/common/utils/ConfigUtils.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,55 @@
package com.ruoyi.common.utils;

import com.ruoyi.common.constant.CacheConstants;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.spring.SpringUtils;

import java.util.Map;


/**
 * @Description: é…ç½®å·¥å…·ç±»
 * @ClassName: ConfigUtils
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´08月23日16:12:09
 * @Version: 1.0
 **/
public class ConfigUtils {
    /**
     * æ ¹æ®é…ç½®key获取配置value值
     *
     * @param key é…ç½®key
     * @return configValue é…ç½®value值
     */
    public static String getConfigValue(String key) {
        String configValue = SpringUtils.getBean(RedisCache.class).getCacheObject(getCacheKey(key));
        if (StringUtils.isNotNull(configValue)) {
            return configValue;
        }
        return null;
    }

    /**
     * èŽ·å–所有配置信息
     *
     * @return configMap é…ç½®ä¿¡æ¯map
     */
    public static Map<String, Object> getConfigMap() {
        Map<String, Object> configMap = SpringUtils.getBean(RedisCache.class).getMapKey(CacheConstants.SYS_CONFIG_KEY);
        if (StringUtils.isNotNull(configMap)) {
            return configMap;
        }
        return null;
    }

    /**
     * è®¾ç½®cache key
     *
     * @param configKey å‚æ•°é”®
     * @return ç¼“存键key
     */
    public static String getCacheKey(String configKey) {
        return CacheConstants.SYS_CONFIG_KEY + configKey;
    }

}

 ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysConfigMapper.java

@@ -1,7 +1,7 @@
package com.ruoyi.system.mapper;

import java.util.List;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;

/**
 * å‚数配置 æ•°æ®å±‚

 ruoyi-system/src/main/java/com/ruoyi/system/service/ISysConfigService.java

@@ -1,7 +1,7 @@
package com.ruoyi.system.service;

import java.util.List;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;

/**
 * å‚数配置 æœåŠ¡å±‚

 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysConfigServiceImpl.java

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

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.constant.CacheConstants;
@@ -15,7 +14,7 @@
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.service.ISysConfigService;