package com.kilomob.powernetwork.cache.redis;

import java.io.IOException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
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.core.io.support.ResourcePropertySource;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisSentinelConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import redis.clients.jedis.JedisPoolConfig;

/**
 * Redis InitConfiguration Bean
 * 
 *   
 * @author fengjk  
 * @date 2017年4月11日
 * @since 1.0
 */
@Configuration
@EnableCaching
public class RedisConfiguration {
	private static final Logger logger = LoggerFactory
			.getLogger(RedisConfiguration.class);

	@Autowired
	private RedisConfig redisConfig;

	@Autowired
	JedisPoolConfig jedisPoolConfig;

	@Bean
	public JedisPoolConfig jedPoolConfig() {
		JedisPoolConfig poolConfig = new JedisPoolConfig();
		poolConfig.setMaxIdle(redisConfig.maxIdle);
		poolConfig.setMaxWaitMillis(redisConfig.maxWait);
		poolConfig.setMaxTotal(redisConfig.maxTotal);
		return poolConfig;
	}

	@Bean
	public JedisConnectionFactory redisConnectionFactory() {
		JedisConnectionFactory jcf =null;
		if (redisConfig.isSentinel) {
			try {
				ResourcePropertySource propertySource = new ResourcePropertySource("resource", "classpath:application.properties");
				RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration(propertySource);
				
				jcf = new JedisConnectionFactory(sentinelConfig, jedisPoolConfig);
				jcf.setTimeout(redisConfig.maxWait);
//				jcf.setPassword(redisConfig.password);
			} catch (IOException e) {
				logger.error("confile not exist or error:",e);
			} 
			
		} else {
			jcf = new JedisConnectionFactory(jedisPoolConfig);
			jcf.setHostName(redisConfig.hostName);
			jcf.setPort(redisConfig.port);
//			jcf.setPassword(redisConfig.password);
			jcf.setTimeout(redisConfig.timeout);
			jcf.setUsePool(true);
		}
		return jcf;
	}


	@SuppressWarnings("rawtypes")
	@Bean
	public RedisTemplate redisTemplate() {
		RedisTemplate<String, String> redisTemplate = new RedisTemplate<String, String>();
		redisTemplate.setConnectionFactory(redisConnectionFactory());
//		redisTemplate.setEnableTransactionSupport(true);
		StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
		
		//jdk序列化
		RedisSerializer<Object> redisSerializer = new JdkSerializationRedisSerializer();
		
		redisTemplate.setKeySerializer(stringRedisSerializer);
		redisTemplate.setValueSerializer(redisSerializer);
		
		redisTemplate.setHashKeySerializer(stringRedisSerializer);
		redisTemplate.setHashValueSerializer(stringRedisSerializer);
		
		
		redisTemplate.setExposeConnection(true);
		redisTemplate.afterPropertiesSet();
		return redisTemplate;
	}

	@Bean
	public CacheManager cacheManager(RedisTemplate<String, Object> redisTemplate) {
		RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
		cacheManager.setDefaultExpiration(60 * 60);
		return cacheManager;
	}
}