import java.io.IOException;
import java.util.List;
import java.util.UUID;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisSentinelPool;

@Component
public class RedisClient {

    @Autowired
    @Qualifier("jedisSentinelPool")
    private JedisSentinelPool jedisSentinelPool;

    @Value("${redis.key.prefix}")
    private String prefix;

    Logger logger = LoggerFactory.getLogger(RedisClient.class);

    private ObjectMapper objectMapper = new ObjectMapper();

    /**
     * 从Redis缓存获取数据
     *
     * @param redisKey
     * @return
     */
    public Object getObjFromRedis(String redisKey) {
        redisKey = prefix + redisKey;
        Jedis jedis = getJedisResource();
        String jsonStr = null;
        try {
            jsonStr = jedis.get(redisKey);
        } finally {
            if (jedis != null) {
                if (null != jedis)
                    jedis.close();
            }
        }

        if (jsonStr != null) {
            try {
                return objectMapper.readValue(jsonStr, Object.class);
            } catch (IOException e) {
                logger.error("反序列化失败", e);
            }

        }

        return null;
    }

    public <T> T getObjFromRedis(String redisKey, Class<T> clazz) {
        redisKey = prefix + redisKey;
        Jedis jedis = getJedisResource();
        String jsonStr = null;
        try {
            jsonStr = jedis.get(redisKey);
        } finally {
            if (null != jedis)
                jedis.close();
        }

        if (jsonStr != null) {
            try {
                return objectMapper.readValue(jsonStr, clazz);
            } catch (IOException e) {
                logger.error("反序列化失败", e);
            }
        }

        return null;
    }

    public Long incr(String redisKey) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        Long num = null;
        try {
            num = jedis.incr(redisKey);
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return num;

    }

    public Long incrBy(String redisKey, int offset) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        Long num = null;
        try {
            num = jedis.incrBy(redisKey, offset);
        } finally {
            // 归还资源
            if (null != jedis)
                jedis.close();
        }

        return num;

    }

    public Long decrBy(String redisKey, int offset) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        Long num = null;
        try {
            num = jedis.decrBy(redisKey, offset);
        } finally {
            // 归还资源
            if (null != jedis)
                jedis.close();
        }

        return num;

    }

    public Long decr(String redisKey) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        Long num = 0L;
        try {
            num = jedis.decr(redisKey);
        } finally {
            // 归还资源
            if(null != jedis)
            jedis.close();
        }

        return num;

    }

    public Jedis getJedisResource() {
        Jedis jedis = null;
        try {
            jedis = jedisSentinelPool.getResource();
            if (jedis != null) {
                return jedis;
            }
        } catch (Exception e) {
            logger.warn("=============Redis Resource Is Not alived====================", e);
            if (jedis != null) {
                // jedisPool.returnBrokenResource(jedis);
                jedis.close();
            }
        }

        return null;
    }

    public String set(String redisKey, String value) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        String ret = null;
        try {
            ret = jedis.set(redisKey, value);
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return ret;

    }

    public String set(String redisKey, String value, int seconds) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        String ret = null;
        try {
            ret = jedis.setex(redisKey, seconds, value);
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return ret;

    }

    public Long delete(String redisKey) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        Long ret = null;
        try {
            ret = jedis.del(redisKey);
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return ret;

    }

    public String set(String redisKey, Long value) {

        return this.set(redisKey, String.valueOf(value));
    }

    public synchronized Long getLong(String redisKey) {
        Long l = null;
        String str = this.get(redisKey);
        if (str != null) {
            l = Long.valueOf(str);
        }
        return l;
    }

    public String get(String redisKey) {

        redisKey = prefix + redisKey;

        Jedis jedis = getJedisResource();
        String str = null;
        try {
            str = jedis.get(redisKey);
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return str;

    }

    /**
     * 一次获取多个
     *
     * @param redisKey
     * @return
     */
    public List<String> mget(String[] redisKey) {

        // redisKey = prefix + redisKey;
        if (redisKey != null) {
            for (int i = 0; i < redisKey.length; i++) {
                redisKey[i] = prefix + redisKey[i];
            }
        }

        Jedis jedis = getJedisResource();
        List<String> str = null;
        try {
            str = jedis.mget(redisKey);
        } finally {

            // 归还资源
            if (null != jedis)
                jedis.close();
        }

        return str;

    }

    public String saveObjToRedis(String redisKey, Object obj, int seconds) {

        redisKey = prefix + redisKey;

        String value;
        try {
            value = objectMapper.writeValueAsString(obj);
        } catch (JsonProcessingException e) {
            logger.error("json序列化失败", e);
            return "FAIL";
        }

        Jedis jedis = getJedisResource();
        String code = null;
        try {
            code = jedis.setex(redisKey, seconds, value);
        } finally {
            // 归还资源
            if (null != jedis)
                jedis.close();
        }

        return code;
    }

    /**
     * 保存数据到Redis
     *
     * @param redisKey @throws
     */
    public String saveObjToRedis(String redisKey, Object obj) {

        redisKey = prefix + redisKey;

        String value;
        try {
            value = objectMapper.writeValueAsString(obj);
        } catch (JsonProcessingException e) {
            logger.error("json序列化失败", e);
            return "FAIL";
        }

        Jedis jedis = getJedisResource();
        String code = null;
        try {
            code = jedis.set(redisKey, value);
        } finally {
            // 归还资源
            if (null != jedis)
                jedis.close();
        }

        return code;
    }

    public String lock(String lockKey, int seconds) {

        String redisKey = prefix + lockKey;

        String lockedValue = UUID.randomUUID().toString();
        Jedis jedis = getJedisResource();
        try {
            Long result = jedis.setnx(redisKey, lockedValue);

            // 加锁失败
            if (result <= 0) {

                return lockedValue;
            }
            if (result > 0 && seconds > 0) {
                jedis.expire(redisKey, seconds);

            }
            // 归还资源
            // jedisPool.returnResource(jedis);
        } finally {
            if (null != jedis)
                jedis.close();
        }

        return lockedValue;

    }

    public Long unlock(String lockKey, String lockedValue) {

        String redisKey = prefix + lockKey;

        Jedis jedis = getJedisResource();

        try {
            String target = jedis.get(redisKey);

            if (target != null && target.equals(lockedValue)) {
                return jedis.del(redisKey);
            }
        } finally {
            // 归还资源
            // jedisPool.returnResource(jedis);
            if (null != jedis)
                jedis.close();
        }

        return -1l;
    }

    @Override
    protected void finalize() throws Throwable {

        jedisSentinelPool.destroy();
        super.finalize();

    }
}