import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.core.env.MapPropertySource;
import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

import java.net.URLDecoder;
import java.util.HashMap;
import java.util.Map;


public class TestRedis {

    public static void main(String... args) {
//        RedisTemplate<String, Object> redisTemplate = new TestRedis().redisTemplate();
////        // System.out.println(redisTemplate.opsForValue().setIfAbsent("1", 1000));
////        // System.out.println(redisTemplate.opsForValue().setIfAbsent("2", 2000));
//        // System.out.println(redisTemplate.opsForValue().get("budgetLock_13_17_954"));
//        // System.out.println(System.currentTimeMillis());
//        // System.out.println(((Long)redisTemplate.opsForValue().get("budgetLock_13_17_954")) > System.currentTimeMillis());
        // System.out.println(URLDecoder.decode("/ubp//ubp-api-control/process/rest/check?companyId=17&data=%7B%22tenantId%22%3A%22100000023%22%2C%22companyId%22%3A%2217%22%2C%22serviceId%22%3A2%7D&id=128989920180405694362503&loginSecurity=%7B%22accessId%22%3A%221289899%22%2C%22openId%22%3A%2268c6f3148506b3f1%22%2C%22appKey%22%3A%225e933001a7784cf2b7f5c11f9fb0047e%22%2C%22token%22%3A%2238312cb13caebe8b41ea10ca59d9b37f%22%7D&serviceId=2&sign=3a0fcfd99df89755d54e9accc3a18d83&tenantId=100000023"));
    }

    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> rt = new RedisTemplate<>();
        rt.setValueSerializer(getJacksonRedisSerializer());
        rt.setHashKeySerializer(getJacksonRedisSerializer());
        rt.setConnectionFactory(getConnectionFactory());
        rt.afterPropertiesSet();
        return rt;
    }

    public JedisConnectionFactory getConnectionFactory() {
        JedisConnectionFactory factory = new JedisConnectionFactory(getClusterConfiguration());
//        if(ObjectUtil.notEmpty(environment.getProperty("spring.redis.cluster.password"))){
//            factory.setPassword(environment.getProperty("spring.redis.cluster.password"));
//        }
        factory.afterPropertiesSet();
        return factory;
    }

    public RedisClusterConfiguration getClusterConfiguration() {
        Map<String, Object> source = new HashMap<String, Object>();
        source.put("spring.redis.cluster.nodes", "10.4.32.148:7000,10.4.32.148:7001,10.4.32.148:7002,10.4.32.148:7003,10.4.32.148:7004,10.4.32.148:7005");
        source.put("spring.redis.cluster.max-redirects", 8);
        return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source));
    }

    /**
     * 获得redis数据转换对象
     * @Title: getJacksonRedisSerializer
     * @param @return    设定文件
     * @return Jackson2JsonRedisSerializer<?>    返回类型
     * @throws
     */
    @SuppressWarnings({ "rawtypes", "unchecked" })
    public Jackson2JsonRedisSerializer<?> getJacksonRedisSerializer(){
        Jackson2JsonRedisSerializer<?> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        return jackson2JsonRedisSerializer;
    }

}