package com.qxueyou.scc.base.dao;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

import redis.clients.jedis.ShardedJedis;

/***
 * redis常用操作类
 * 
 * @author kevin
 * @date 2017-05-15 17:00
 */
@Repository(value="commonRedisTemplate")
 public class CommonRedisTemplate extends AbstractRedisTemplate {
	
	private static final Logger log = LogManager.getLogger(CommonRedisTemplate.class);
	
	@Autowired
	private ReidsSharedPoolWrapper reidsSharedPoolWrapper ;
	
	protected ShardedJedis getJedisClient() {
		ShardedJedis jedisClient = null;
		try {
			if (reidsSharedPoolWrapper != null) {
				jedisClient = reidsSharedPoolWrapper.getResource();
			}
		} catch (Exception e) {
			log.error("获取redisClient异常！");
		}
		return jedisClient;
	}

	protected void closeJedisClient(ShardedJedis jedisClient) {
		try {
			if (jedisClient != null) {
				jedisClient.close();
			}
		} catch (Exception e) {
			log.error("关闭redis连接失败");
		}
	}

	public void setReidsSharedPoolWrapper(ReidsSharedPoolWrapper reidsSharedPoolWrapper) {
		this.reidsSharedPoolWrapper = reidsSharedPoolWrapper;
	}

	
}