package com.javaweb.redis.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Client;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.ShardedJedis;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Set;

public class RedisUtil {

    public static final String SYS_CACHE = "sysCache";
    public static final String USER_CACHE = "userCache";
    public static final String DEFAULT_CACHE = "defaultCache";

    public static String getSysInfo(String key) {
        return RedisUtil.getStringValue(SYS_CACHE+"_"+key);
    }
    public static String getDefaultInfo(String key) {
        return RedisUtil.getStringValue(DEFAULT_CACHE+"_"+key);
    }
    public static String getUserInfo(String key,String yhid) {
        return RedisUtil.getStringValue(USER_CACHE+"_"+key+"_"+yhid);
    }

    public static void putSysInfo(String key, Object value) {
        RedisUtil.setStringValue(SYS_CACHE+"_"+key,JSON.toJSONString(value));
    }
    public static void putDefaultInfo(String key, Object value) {

        RedisUtil.setStringValue(DEFAULT_CACHE+"_"+key,JSON.toJSONString(value));
    }
    public static void putUserInfo(String key,String yhid, Object value) {
        RedisUtil.setStringValue(USER_CACHE+"_"+key+"_"+yhid,JSON.toJSONString(value));
    }

    public static void removeSysInfo(String key) {
        RedisUtil.del(SYS_CACHE+"_"+key);
    }
    public static void removeDefaultInfo(String key) {
        RedisUtil.del(DEFAULT_CACHE+"_"+key);
    }
    public static void removeUserInfo(String key,String yhid) {
        RedisUtil.del(USER_CACHE+"_"+key+"_"+yhid);
    }
    public static void clearUserInfo(String yhid){
        List<String> keys=RedisUtil.keys(USER_CACHE+"_*_"+yhid);
        keys.forEach(s->{
            RedisUtil.del(s);
        });
    }
    public static void clearUserCache(){
        List<String> keys=RedisUtil.keys(USER_CACHE+"_*");
        keys.forEach(s->{
            RedisUtil.del(s);
        });
    }
    public static void clearSysCache(){
        List<String> keys=RedisUtil.keys(SYS_CACHE+"_*");
        keys.forEach(s->{
            RedisUtil.del(s);
        });
    }
    public static void clearDefaultCache(){
        List<String> keys=RedisUtil.keys(DEFAULT_CACHE+"_*");
        keys.forEach(s->{
            RedisUtil.del(s);
        });
    }
    //--------------------------------------------------

    public static String setStringValue(String key, String value) {
        return InitRedisUtil.setStringValue(key,value);
    }

    public static String type(String key) {
        return InitRedisUtil.type(key);
    }
    public static long ttl(String key) {
        return InitRedisUtil.ttl(key);
    }
    /**
     * Set String
     *
     * @param key
     * @param value
     * @param seconds 存活时间,单位/秒
     * @return
     */
    public static String setStringValue(String key, String value, int seconds) {
        return InitRedisUtil.setStringValue(key,value,seconds);
    }

    /**
     * Set Object
     * @param key
     * @param obj
     * @param seconds 存活时间,单位/秒
     */
    public static String setObjectValue(String key, Object obj, int seconds) {
        return InitRedisUtil.setObjectValue(key,obj,seconds);
    }

    /**
     * Get String
     *
     * @param key
     * @return
     */
    public static String getStringValue(String key) {
        return InitRedisUtil.getStringValue(key);
    }

    /**
     * Get Object
     *
     * @param key
     * @return
     */
    public static Object getObjectValue(String key) {
        return InitRedisUtil.getObjectValue(key);
    }
    public static Object getObjectValue(String key,Class cls) {
        return InitRedisUtil.getObjectValue(key,cls);
    }
    /**
     * Delete key
     *
     * @param key
     * @return Integer reply, specifically:
     * an integer greater than 0 if one or more keys were removed
     * 0 if none of the specified key existed
     */
    public static Long del(String key) {
        return InitRedisUtil.del(key);
    }

    /**
     * incrBy i(+i)
     *
     * @param key
     * @param i
     * @return new value after incr
     */
    public static Long incrBy(String key, int i) {
        return InitRedisUtil.incrBy(key,i);
    }

    /**
     * exists valid
     *
     * @param key
     * @return Boolean reply, true if the key exists, otherwise false
     */
    public static boolean exists(String key) {
        return InitRedisUtil.exists(key);
    }

    /**
     * expire reset
     * @param key
     * @param seconds 存活时间,单位/秒
     * @return Integer reply, specifically:
     * 1: the timeout was set.
     * 0: the timeout was not set since the key already has an associated timeout (versions lt 2.1.3), or the key does not exist.
     */
    public static long expire(String key, int seconds) {
        return InitRedisUtil.expireAt(key,seconds);
    }

    /**
     * expire at unixTime
     * @param key
     * @param unixTime
     * @return
     */
    public static long expireAt(String key, long unixTime) {
        return InitRedisUtil.expireAt(key,unixTime);
    }

    /**
     * 实现redis keys 模糊查询
     * @author hq
     * @param pattern
     * @return
     */
    public static List<String> keys(String pattern){
        return InitRedisUtil.keys(pattern);
    }

    public static void main(String[] args) {

    }
}