package com.thhy.gateway.config.redis;

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.codec.JsonJacksonCodec;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import org.redisson.spring.cache.CacheConfig;
import org.redisson.spring.cache.RedissonSpringCacheManager;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.util.StringUtils;

import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

@Configuration
@EnableCaching
@ConditionalOnProperty(prefix="redisson",name = "enable", havingValue = "true")
public class RedissonConfig {

    @Bean(destroyMethod = "shutdown")
    RedissonClient redissonClient(RedissonProperties redssionProperties) {
        Config config = new Config().setCodec(new JsonJacksonCodec());
        SingleServerConfig singleServerConfig = config.useSingleServer()
                .setAddress(redssionProperties.getAddress())//连接地址
                .setConnectTimeout(redssionProperties.getConnectTimeout())//连接超时
                .setTimeout(redssionProperties.getTimeout())//Redis服务器响应超时
                .setConnectionPoolSize(redssionProperties.getConnectionPoolSize())//Redis连接的最大池大小
                .setConnectionMinimumIdleSize(redssionProperties.getConnectionMinimumIdleSize())//最小空闲Redis连接量
                .setRetryAttempts(redssionProperties.getRetryAttempts())//命令失败重试次数
                .setRetryInterval(redssionProperties.getRetryInterval());//命令重试发送时间间隔
        if (!StringUtils.isEmpty(redssionProperties.getPassword())) {
            singleServerConfig.setPassword(redssionProperties.getPassword());
        }
        /*ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 解决jackson2无法反序列化LocalDateTime的问题
        om.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
        om.registerModule(new JavaTimeModule());
        config.setCodec(new JsonJacksonCodec(om));*/
        return Redisson.create(config);
    }

    @Primary
    @Bean
    CacheManager redissonCacheManager(RedissonClient redissonClient, RedissonProperties redssionProperties) {
        RedissonProperties.RedissonCache redissonCache = redssionProperties.getRedissonCache();
        String cacheConfigs = redissonCache.getCacheConfigs()==null?"secure:userInfo&2592000000,secure:interfaceAuth&315360000000,secure:interfaceVersion&315360000000":redissonCache.getCacheConfigs()+",secure:userInfo&2592000000,secure:interfaceAuth&315360000000,secure:interfaceVersion&315360000000";
        Map<String, CacheConfig> configMap = new HashMap<>();
        if(!cacheConfigs.trim().equals("".trim())){
            //如果有缓存配置，则逐个加入到管理器
            String[] cacheConfigsArray = cacheConfigs.split(",");
            Arrays.stream(cacheConfigsArray).forEach(cacheConfig -> {
                String[] params = cacheConfig.split("&");
                String cacheName = params[0];//缓存名字
                CacheConfig config = new CacheConfig();
                //如果设置了TTL
                if(params.length>1){
                    config.setTTL(Long.valueOf(params[1]));
                    //如果设置了MaxIdleTime
                    if(params.length>2){
                        config.setMaxIdleTime(Long.valueOf(params[2]));
                    }else {
                        //如果没设置MaxIdleTime，则使用和TTL一样的值
                        config.setMaxIdleTime(Long.valueOf(params[1]));
                    }
                }else{
                    //如果没设置TTL和MaxIdleTime，则使用默认值
                    config.setTTL(redssionProperties.getRedissonCacheDefault());
                    config.setMaxIdleTime(redssionProperties.getRedissonCacheDefault());
                }
                configMap.put(cacheName, config);
            });
        }
        return new RedissonSpringCacheManager(redissonClient, configMap, new JsonJacksonCodec());
    }
}