diff --git a/pom.xml b/pom.xml
index 2ba3470..7eb61bf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -79,6 +79,15 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-thymeleaf</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
+		</dependency>
+		<!-- 如果需要连接池，可以引入 commons-pool2 （可选） -->
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-pool2</artifactId>
+		</dependency>
 
 		<!-- MyBatis -->
 		<dependency>
diff --git a/src/main/java/com/xly/config/JedisUtil.java b/src/main/java/com/xly/config/JedisUtil.java
deleted file mode 100644
index 74acc37..0000000
--- a/src/main/java/com/xly/config/JedisUtil.java
+++ /dev/null
@@ -1,2643 +0,0 @@
-//package com.xly.utils.redis;
-//
-//import java.io.ByteArrayInputStream;
-//import java.io.ByteArrayOutputStream;
-//import java.io.ObjectInputStream;
-//import java.io.ObjectOutputStream;
-//import java.util.*;
-//import java.util.concurrent.TimeUnit;
-//
-//import cn.hutool.core.util.StrUtil;
-//import cn.hutool.json.JSONUtil;
-//import com.alibaba.fastjson.JSONObject;
-//import com.google.common.collect.Sets;
-//import groovy.util.logging.Slf4j;
-//import org.slf4j.Logger;
-//import org.slf4j.LoggerFactory;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.beans.factory.annotation.Value;
-//import org.springframework.cache.annotation.Cacheable;
-//import org.springframework.stereotype.Component;
-//
-//import org.springframework.util.ObjectUtils;
-//import redis.clients.jedis.*;
-//import redis.clients.jedis.BinaryClient.LIST_POSITION;
-//
-//@Component
-//@Slf4j
-//public class JedisUtil {
-//
-//    private static final Logger logger = LoggerFactory.getLogger(JedisUtil.class);
-//
-//    private static final String LOCK_SUCCESS = "OK";
-//    private static final String SET_IF_NOT_EXIST = "NX";
-//    private static final String SET_WITH_EXPIRE_TIME = "PX";
-//    private static final String SET_WITH_EXPIRE_TIME_EX  = "EX";
-//    private static final Long RELEASE_SUCCESS = 1L;
-//    public static final int lockWaitTime = 4000;
-//    public static final int scanlimit = 10000;
-//
-//    @Value("${spring.redis.database}")
-//    private int indexdb;
-//
-//    @Autowired
-//    private JedisPool jedisPool;
-//
-//    /**
-//     * <p>
-//     * 通过key获取储存在redis中的value
-//     * </p>
-//     * <p>
-//     * 并释放连接
-//     * </p>
-//     *
-//     * @param key
-//     * @return 成功返回value 失败返回null
-//     */
-//    public String get(String key) {
-//        Jedis jedis = null;
-//        String value = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            value = jedis.get(key);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return value;
-//    }
-//    /**
-//     * <p>
-//     * 通过key获取储存在redis中的value
-//     * </p>
-//     * <p>
-//     * 并释放连接
-//     * </p>
-//     *
-//     * @param key
-//     * @return 成功返回value 失败返回null
-//     */
-//    public Object getObject(String key) {
-//        Jedis jedis = null;
-//        Object value = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            String jedV = jedis.get(key);
-//            if(StrUtil.isNotEmpty(jedV) && JSONUtil.isJsonObj(jedV)){
-//                value = JSONUtil.parseObj(jedV);
-//            }else{
-//                value = jedV;
-//            }
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return value;
-//    }
-//
-//    /**
-//     * 递增
-//     * @param key 键
-//     * @return
-//     */
-//    public long incr(String key, long delta){
-//        if(delta<0){
-//            throw new RuntimeException("递增因子必须大于0");
-//        }
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.incrBy(key,delta);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取储存在redis中的value
-//     * </p>
-//     * <p>
-//     * 并释放连接
-//     * </p>
-//     *
-//     * @param key
-//     * @param indexdb 选择redis库 0-15
-//     * @return 成功返回value 失败返回null
-//     */
-//    public byte[] get(byte[] key, int indexdb) {
-//        Jedis jedis = null;
-//        byte[] value = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            value = jedis.get(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return value;
-//    }
-//
-//    /**
-//     * <p>
-//     * 向redis存入key和value,并释放连接资源
-//     * </p>
-//     * <p>
-//     * 如果key已经存在 则覆盖
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @param indexdb 选择redis库 0-15
-//     * @return 成功 返回OK 失败返回 0
-//     */
-//    public String set(String key, String value, int indexdb) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.set(key, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return "0";
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//    /**
-//     * <p>
-//     * 向redis存入key和value,并释放连接资源
-//     * </p>
-//     * <p>
-//     * 如果key已经存在 则覆盖
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @return 成功 返回OK 失败返回 0
-//     */
-//    public String set(String key, String value) {
-//        return set( key,  value,  indexdb);
-//    }
-//    /**
-//     * <p>
-//     * 向redis存入key和value,并释放连接资源
-//     * </p>
-//     * <p>
-//     * 如果key已经存在 则覆盖
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @return 成功 返回OK 失败返回 0
-//     */
-//    public String setObject(String key, Object value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            String objJson = JSONUtil.toJsonStr(value);
-//            return jedis.set( key,objJson);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return "0";
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 向redis存入key和value,并释放连接资源
-//     * </p>
-//     * <p>
-//     * 如果key已经存在 则覆盖
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @param indexdb 选择redis库 0-15
-//     * @return 成功 返回OK 失败返回 0
-//     */
-//    public String set(byte[] key, byte[] value, int indexdb) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.set(key, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return "0";
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 删除指定的key,也可以传入一个包含key的数组
-//     * </p>
-//     *
-//     * @param keys 一个key 也可以使 string 数组
-//     * @return 返回删除成功的个数
-//     */
-//    public Long del(String... keys) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.del(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//    /**
-//     * <p>
-//     * 删除指定的key,也可以传入一个包含key的数组
-//     * </p>
-//     *
-//     * @param keysSet 一个key 也可以使 string 数组
-//     * @return 返回删除成功的个数
-//     */
-//    public Long delSet(Set<String> keysSet) {
-//        return  del(keysSet.toArray(new String[keysSet.size()]));
-//    }
-//
-//    /**
-//     * <p>
-//     * 删除指定的key,也可以传入一个包含key的数组
-//     * </p>
-//     *
-//     * @param indexdb 选择redis库 0-15
-//     * @param keys    一个key 也可以使 string 数组
-//     * @return 返回删除成功的个数
-//     */
-//    public Long del(int indexdb, String... keys) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.del(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 删除指定的key,也可以传入一个包含key的数组
-//     * </p>
-//     *
-//     * @param indexdb 选择redis库 0-15
-//     * @param keys    一个key 也可以使 string 数组
-//     * @return 返回删除成功的个数
-//     */
-//    public Long del(int indexdb, byte[]... keys) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.del(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key向指定的value值追加值
-//     * </p>
-//     *
-//     * @param key
-//     * @param str
-//     * @return 成功返回 添加后value的长度 失败 返回 添加的 value 的长度 异常返回0L
-//     */
-//    public Long append(String key, String str) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.append(key, str);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 判断key是否存在
-//     * </p>
-//     *
-//     * @param key
-//     * @return true OR false
-//     */
-//    public Boolean exists(String key) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.exists(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return false;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 清空当前数据库中的所有 key,此命令从不失败。
-//     * </p>
-//     *
-//     * @return 总是返回 OK
-//     */
-//    public String flushDB() {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.flushDB();
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 为给定 key 设置生存时间，当 key 过期时(生存时间为 0 )，它会被自动删除。
-//     * </p>
-//     *
-//     * @param key
-//     * @param value 过期时间，单位：秒
-//     * @return 成功返回1 如果存在 和 发生异常 返回 0
-//     */
-//    public Long expire(String key, int value, int indexdb) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.expire(key, value);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * 普通缓存放入并设置时间
-//     * @param key 键
-//     * @param value 值
-//     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
-//     * @return true成功 false 失败
-//     */
-//    public boolean setObjectExpire(String key,Object value,long time){
-//        String valueJson = JSONUtil.toJsonStr(value);
-//        this.setex( key, new Long(time).intValue(), valueJson);
-//        return true;
-//    }
-//
-//    /**
-//     * <p>
-//     * 以秒为单位，返回给定 key 的剩余生存时间
-//     * </p>
-//     *
-//     * @param key
-//     * @return 当 key 不存在时，返回 -2 。当 key 存在但没有设置剩余生存时间时，返回 -1 。否则，以秒为单位，返回 key
-//     * 的剩余生存时间。 发生异常 返回 0
-//     */
-//    public Long ttl(String key, int indexdb) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.ttl(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//    /**
-//     * 普通缓存放入并设置时间
-//     * @param key 键
-//     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
-//     * @return true成功 false 失败
-//     */
-//    public Long expireSeconds(String key,long time){
-//        return expire( key, new Long(time).intValue(), indexdb);
-//    }
-//    /**
-//     * 普通缓存放入并设置时间
-//     * @param key 键
-//     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
-//     * @return true成功 false 失败
-//     */
-//    public Long expireMinutes(String key,long time){
-//        time = time * 60;
-//        return expire( key,  new Long(time).intValue(), indexdb);
-//    }
-//    /**
-//     * 普通缓存放入并设置时间
-//     * @param key 键
-//     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
-//     * @return true成功 false 失败
-//     */
-//    public String createAndExpireMinutes(String key,String value,long time){
-//        return setexMinutes(key,new Long(time).intValue(),  value);
-//    }
-//
-//    /**
-//     * <p>
-//     * 移除给定 key 的生存时间，将这个 key 从『易失的』(带生存时间 key )转换成『持久的』(一个不带生存时间、永不过期的 key )
-//     * </p>
-//     *
-//     * @param key
-//     * @return 当生存时间移除成功时，返回 1 .如果 key 不存在或 key 没有设置生存时间，返回 0 ， 发生异常 返回 -1
-//     */
-//    public Long persist(String key) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.persist(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return -1L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 新增key,并将 key 的生存时间 (以秒为单位)
-//     * </p>
-//     *
-//     * @param key
-//     * @param seconds 生存时间 单位：秒
-//     * @param value
-//     * @return 设置成功时返回 OK 。当 seconds 参数不合法时，返回一个错误。
-//     */
-//    public String setex(String key, int seconds, String value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.setex(key, seconds, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//    /**
-//     * <p>
-//     * 新增key,并将 key 的生存时间 (以秒为单位)
-//     * </p>
-//     *
-//     * @param key
-//     * @param seconds 生存时间 单位：秒
-//     * @param value
-//     * @return 设置成功时返回 OK 。当 seconds 参数不合法时，返回一个错误。
-//     */
-//    public String setexMinutes(String key, int seconds, String value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            seconds = seconds*60;
-//            return jedis.setex(key, seconds, value);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 设置key value,如果key已经存在则返回0,nx==> not exist
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @return 成功返回1 如果存在 和 发生异常 返回 0
-//     */
-//    public Long setnx(String key, String value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.setnx(key, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 将给定 key 的值设为 value ，并返回 key 的旧值(old value)。
-//     * </p>
-//     * <p>
-//     * 当 key 存在但不是字符串类型时，返回一个错误。
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @return 返回给定 key 的旧值。当 key 没有旧值时，也即是， key 不存在时，返回 nil
-//     */
-//    public String getSet(String key, String value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.getSet(key, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 设置key value并制定这个键值的有效期
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @param seconds 单位:秒
-//     * @return 成功返回OK 失败和异常返回null
-//     */
-//    public String setex(String key, String value, int seconds) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.setex(key, seconds, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key 和offset 从指定的位置开始将原先value替换
-//     * </p>
-//     * <p>
-//     * 下标从0开始,offset表示从offset下标开始替换
-//     * </p>
-//     * <p>
-//     * 如果替换的字符串长度过小则会这样
-//     * </p>
-//     * <p>
-//     * example:
-//     * </p>
-//     * <p>
-//     * value : bigsea@zto.cn
-//     * </p>
-//     * <p>
-//     * str : abc
-//     * </p>
-//     * <P>
-//     * 从下标7开始替换 则结果为
-//     * </p>
-//     * <p>
-//     * RES : bigsea.abc.cn
-//     * </p>
-//     *
-//     * @param key
-//     * @param str
-//     * @param offset 下标位置
-//     * @return 返回替换后 value 的长度
-//     */
-//    public Long setrange(String key, String str, int offset) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.setrange(key, offset, str);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过批量的key获取批量的value
-//     * </p>
-//     *
-//     * @param keys string数组 也可以是一个key
-//     * @return 成功返回value的集合, 失败返回null的集合 ,异常返回空
-//     */
-//    public List<String> mget(String... keys) {
-//        Jedis jedis = null;
-//        List<String> values = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            values = jedis.mget(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return values;
-//    }
-//
-//    /**
-//     * <p>
-//     * 批量的设置key:value,可以一个
-//     * </p>
-//     * <p>
-//     * example:
-//     * </p>
-//     * <p>
-//     * obj.mset(new String[]{"key2","value1","key2","value2"})
-//     * </p>
-//     *
-//     * @param keysvalues
-//     * @return 成功返回OK 失败 异常 返回 null
-//     */
-//    public String mset(String... keysvalues) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.mset(keysvalues);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 批量的设置key:value,可以一个,如果key已经存在则会失败,操作会回滚
-//     * </p>
-//     * <p>
-//     * example:
-//     * </p>
-//     * <p>
-//     * obj.msetnx(new String[]{"key2","value1","key2","value2"})
-//     * </p>
-//     *
-//     * @param keysvalues
-//     * @return 成功返回1 失败返回0
-//     */
-//    public Long msetnx(String... keysvalues) {
-//        Jedis jedis = null;
-//        Long res = 0L;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.msetnx(keysvalues);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 设置key的值,并返回一个旧值
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @return 旧值 如果key不存在 则返回null
-//     */
-//    public String getset(String key, String value) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.getSet(key, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过下标 和key 获取指定下标位置的 value
-//     * </p>
-//     *
-//     * @param key
-//     * @param startOffset 开始位置 从0 开始 负数表示从右边开始截取
-//     * @param endOffset
-//     * @return 如果没有返回null
-//     */
-//    public String getrange(String key, int startOffset, int endOffset) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.getrange(key, startOffset, endOffset);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key 对value进行加值+1操作,当value不是int类型时会返回错误,当key不存在是则value为1
-//     * </p>
-//     *
-//     * @param key
-//     * @return 加值后的结果
-//     */
-//    public Long incr(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.incr(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key给指定的value加值,如果key不存在,则这是value为该值
-//     * </p>
-//     *
-//     * @param key
-//     * @param integer
-//     * @return
-//     */
-//    public Long incrBy(String key, Long integer) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.incrBy(key, integer);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 对key的值做减减操作,如果key不存在,则设置key为-1
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Long decr(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.decr(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 减去指定的值
-//     * </p>
-//     *
-//     * @param key
-//     * @param integer
-//     * @return
-//     */
-//    public Long decrBy(String key, Long integer) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.decrBy(key, integer);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取value值的长度
-//     * </p>
-//     *
-//     * @param key
-//     * @return 失败返回null
-//     */
-//    public Long serlen(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.strlen(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key给field设置指定的值,如果key不存在,则先创建
-//     * </p>
-//     *
-//     * @param key
-//     * @param field 字段
-//     * @param value
-//     * @return 如果存在返回0 异常返回null
-//     */
-//    public Long hset(String key, String field, String value) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hset(key, field, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key给field设置指定的值,如果key不存在则先创建,如果field已经存在,返回0
-//     * </p>
-//     *
-//     * @param key
-//     * @param field
-//     * @param value
-//     * @return
-//     */
-//    public Long hsetnx(String key, String field, String value) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hsetnx(key, field, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key同时设置 hash的多个field
-//     * </p>
-//     *
-//     * @param key
-//     * @param hash
-//     * @return 返回OK 异常返回null
-//     */
-//    public String hmset(String key, Map<String, String> hash, int indexdb) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hmset(key, hash);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key 和 field 获取指定的 value
-//     * </p>
-//     *
-//     * @param key
-//     * @param field
-//     * @return 没有返回null
-//     */
-//    public String hget(String key, String field) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hget(key, field);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key 和 fields 获取指定的value 如果没有对应的value则返回null
-//     * </p>
-//     *
-//     * @param key
-//     * @param fields 可以使 一个String 也可以是 String数组
-//     * @return
-//     */
-//    public List<String> hmget(String key, int indexdb, String... fields) {
-//        Jedis jedis = null;
-//        List<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hmget(key, fields);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key给指定的field的value加上给定的值
-//     * </p>
-//     *
-//     * @param key
-//     * @param field
-//     * @param value
-//     * @return
-//     */
-//    public Long hincrby(String key, String field, Long value) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hincrBy(key, field, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key和field判断是否有指定的value存在
-//     * </p>
-//     *
-//     * @param key
-//     * @param field
-//     * @return
-//     */
-//    public Boolean hexists(String key, String field) {
-//        Jedis jedis = null;
-//        Boolean res = false;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hexists(key, field);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回field的数量
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Long hlen(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hlen(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key 删除指定的 field
-//     * </p>
-//     *
-//     * @param key
-//     * @param fields 可以是 一个 field 也可以是 一个数组
-//     * @return
-//     */
-//    public Long hdel(String key, String... fields) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hdel(key, fields);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回所有的field
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Set<String> hkeys(String key) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hkeys(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回所有和key有关的value
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public List<String> hvals(String key) {
-//        Jedis jedis = null;
-//        List<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hvals(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取所有的field和value
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Map<String, String> hgetall(String key, int indexdb) {
-//        Jedis jedis = null;
-//        Map<String, String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.hgetAll(key);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key向list头部添加字符串
-//     * </p>
-//     *
-//     * @param key
-//     * @param strs 可以使一个string 也可以使string数组
-//     * @return 返回list的value个数
-//     */
-//    public Long lpush(int indexdb, String key, String... strs) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lpush(key, strs);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key向list尾部添加字符串
-//     * </p>
-//     *
-//     * @param key
-//     * @param strs 可以使一个string 也可以使string数组
-//     * @return 返回list的value个数
-//     */
-//    public Long rpush(String key, String... strs) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.rpush(key, strs);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key在list指定的位置之前或者之后 添加字符串元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param where LIST_POSITION枚举类型
-//     * @param pivot list里面的value
-//     * @param value 添加的value
-//     * @return
-//     */
-//    public Long linsert(String key, LIST_POSITION where, String pivot,
-//                        String value) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.linsert(key, where, pivot, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key设置list指定下标位置的value
-//     * </p>
-//     * <p>
-//     * 如果下标超过list里面value的个数则报错
-//     * </p>
-//     *
-//     * @param key
-//     * @param index 从0开始
-//     * @param value
-//     * @return 成功返回OK
-//     */
-//    public String lset(String key, Long index, String value) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lset(key, index, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key从对应的list中删除指定的count个 和 value相同的元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param count 当count为0时删除全部
-//     * @param value
-//     * @return 返回被删除的个数
-//     */
-//    public Long lrem(String key, long count, String value) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lrem(key, count, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key保留list中从strat下标开始到end下标结束的value值
-//     * </p>
-//     *
-//     * @param key
-//     * @param start
-//     * @param end
-//     * @return 成功返回OK
-//     */
-//    public String ltrim(String key, long start, long end) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.ltrim(key, start, end);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key从list的头部删除一个value,并返回该value
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    synchronized public String lpop(String key) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lpop(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key从list尾部删除一个value,并返回该元素
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    synchronized public String rpop(String key, int indexdb) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.rpop(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key从一个list的尾部删除一个value并添加到另一个list的头部,并返回该value
-//     * </p>
-//     * <p>
-//     * 如果第一个list为空或者不存在则返回null
-//     * </p>
-//     *
-//     * @param srckey
-//     * @param dstkey
-//     * @return
-//     */
-//    public String rpoplpush(String srckey, String dstkey, int indexdb) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.rpoplpush(srckey, dstkey);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取list中指定下标位置的value
-//     * </p>
-//     *
-//     * @param key
-//     * @param index
-//     * @return 如果没有返回null
-//     */
-//    public String lindex(String key, long index) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lindex(key, index);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回list的长度
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Long llen(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.llen(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取list指定下标位置的value
-//     * </p>
-//     * <p>
-//     * 如果start 为 0 end 为 -1 则返回全部的list中的value
-//     * </p>
-//     *
-//     * @param key
-//     * @param start
-//     * @param end
-//     * @return
-//     */
-//    public List<String> lrange(String key, long start, long end, int indexdb) {
-//        Jedis jedis = null;
-//        List<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.lrange(key, start, end);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 将列表 key 下标为 index 的元素的值设置为 value
-//     * </p>
-//     *
-//     * @param key
-//     * @param index
-//     * @param value
-//     * @return 操作成功返回 ok ，否则返回错误信息
-//     */
-//    public String lset(String key, long index, String value) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.lset(key, index, value);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 返回给定排序后的结果
-//     * </p>
-//     *
-//     * @param key
-//     * @param sortingParameters
-//     * @return 返回列表形式的排序结果
-//     */
-//    public List<String> sort(String key, SortingParams sortingParameters) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.sort(key, sortingParameters);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 返回排序后的结果，排序默认以数字作为对象，值被解释为双精度浮点数，然后进行比较。
-//     * </p>
-//     *
-//     * @param key
-//     * @return 返回列表形式的排序结果
-//     */
-//    public List<String> sort(String key) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.sort(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key向指定的set中添加value
-//     * </p>
-//     *
-//     * @param key
-//     * @param members 可以是一个String 也可以是一个String数组
-//     * @return 添加成功的个数
-//     */
-//    public Long sadd(String key, String... members) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sadd(key, members);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key删除set中对应的value值
-//     * </p>
-//     *
-//     * @param key
-//     * @param members 可以是一个String 也可以是一个String数组
-//     * @return 删除的个数
-//     */
-//    public Long srem(String key, String... members) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.srem(key, members);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key随机删除一个set中的value并返回该值
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public String spop(String key) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.spop(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取set中的差集
-//     * </p>
-//     * <p>
-//     * 以第一个set为标准
-//     * </p>
-//     *
-//     * @param keys 可以使一个string 则返回set中所有的value 也可以是string数组
-//     * @return
-//     */
-//    public Set<String> sdiff(String... keys) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sdiff(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取set中的差集并存入到另一个key中
-//     * </p>
-//     * <p>
-//     * 以第一个set为标准
-//     * </p>
-//     *
-//     * @param dstkey 差集存入的key
-//     * @param keys   可以使一个string 则返回set中所有的value 也可以是string数组
-//     * @return
-//     */
-//    public Long sdiffstore(String dstkey, String... keys) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sdiffstore(dstkey, keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取指定set中的交集
-//     * </p>
-//     *
-//     * @param keys 可以使一个string 也可以是一个string数组
-//     * @return
-//     */
-//    public Set<String> sinter(String... keys) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sinter(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取指定set中的交集 并将结果存入新的set中
-//     * </p>
-//     *
-//     * @param dstkey
-//     * @param keys   可以使一个string 也可以是一个string数组
-//     * @return
-//     */
-//    public Long sinterstore(String dstkey, String... keys) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sinterstore(dstkey, keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回所有set的并集
-//     * </p>
-//     *
-//     * @param keys 可以使一个string 也可以是一个string数组
-//     * @return
-//     */
-//    public Set<String> sunion(String... keys) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sunion(keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回所有set的并集,并存入到新的set中
-//     * </p>
-//     *
-//     * @param dstkey
-//     * @param keys   可以使一个string 也可以是一个string数组
-//     * @return
-//     */
-//    public Long sunionstore(String dstkey, String... keys) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sunionstore(dstkey, keys);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key将set中的value移除并添加到第二个set中
-//     * </p>
-//     *
-//     * @param srckey 需要移除的
-//     * @param dstkey 添加的
-//     * @param member set中的value
-//     * @return
-//     */
-//    public Long smove(String srckey, String dstkey, String member) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.smove(srckey, dstkey, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取set中value的个数
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Long scard(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.scard(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key判断value是否是set中的元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param member
-//     * @return
-//     */
-//    public Boolean sismember(String key, String member) {
-//        Jedis jedis = null;
-//        Boolean res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.sismember(key, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取set中随机的value,不删除元素
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public String srandmember(String key) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.srandmember(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取set中所有的value
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Set<String> smembers(String key) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.smembers(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key向zset中添加value,score,其中score就是用来排序的
-//     * </p>
-//     * <p>
-//     * 如果该value已经存在则根据score更新元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param score
-//     * @param member
-//     * @return
-//     */
-//    public Long zadd(String key, double score, String member) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zadd(key, score, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 返回有序集 key 中，指定区间内的成员。min=0,max=-1代表所有元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param min
-//     * @param max
-//     * @return 指定区间内的有序集成员的列表。
-//     */
-//    public Set<String> zrange(String key, long min, long max) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.zrange(key, min, max);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * <p>
-//     * 统计有序集 key 中,值在 min 和 max 之间的成员的数量
-//     * </p>
-//     *
-//     * @param key
-//     * @param min
-//     * @param max
-//     * @return 值在 min 和 max 之间的成员的数量。异常返回0
-//     */
-//    public Long zcount(String key, double min, double max) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.zcount(key, min, max);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//
-//    }
-//
-//    /**
-//     * <p>
-//     * 为哈希表 key 中的域 field 的值加上增量 increment 。增量也可以为负数，相当于对给定域进行减法操作。 如果 key
-//     * 不存在，一个新的哈希表被创建并执行 HINCRBY 命令。如果域 field 不存在，那么在执行命令前，域的值被初始化为 0 。
-//     * 对一个储存字符串值的域 field 执行 HINCRBY 命令将造成一个错误。本操作的值被限制在 64 位(bit)有符号数字表示之内。
-//     * </p>
-//     * <p>
-//     * 将名称为key的hash中field的value增加integer
-//     * </p>
-//     *
-//     * @param key
-//     * @param value
-//     * @param increment
-//     * @return 执行 HINCRBY 命令之后，哈希表 key 中域 field的值。异常返回0
-//     */
-//    public Long hincrBy(String key, String value, long increment) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            return jedis.hincrBy(key, value, increment);
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//            return 0L;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key删除在zset中指定的value
-//     * </p>
-//     *
-//     * @param key
-//     * @param members 可以使一个string 也可以是一个string数组
-//     * @return
-//     */
-//    public Long zrem(String key, String... members) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrem(key, members);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key增加该zset中value的score的值
-//     * </p>
-//     *
-//     * @param key
-//     * @param score
-//     * @param member
-//     * @return
-//     */
-//    public Double zincrby(String key, double score, String member) {
-//        Jedis jedis = null;
-//        Double res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zincrby(key, score, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回zset中value的排名
-//     * </p>
-//     * <p>
-//     * 下标从小到大排序
-//     * </p>
-//     *
-//     * @param key
-//     * @param member
-//     * @return
-//     */
-//    public Long zrank(String key, String member) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrank(key, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回zset中value的排名
-//     * </p>
-//     * <p>
-//     * 下标从大到小排序
-//     * </p>
-//     *
-//     * @param key
-//     * @param member
-//     * @return
-//     */
-//    public Long zrevrank(String key, String member) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrevrank(key, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key将获取score从start到end中zset的value
-//     * </p>
-//     * <p>
-//     * socre从大到小排序
-//     * </p>
-//     * <p>
-//     * 当start为0 end为-1时返回全部
-//     * </p>
-//     *
-//     * @param key
-//     * @param start
-//     * @param end
-//     * @return
-//     */
-//    public Set<String> zrevrange(String key, long start, long end) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrevrange(key, start, end);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回指定score内zset中的value
-//     * </p>
-//     *
-//     * @param key
-//     * @param max
-//     * @param min
-//     * @return
-//     */
-//    public Set<String> zrangebyscore(String key, String max, String min) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrevrangeByScore(key, max, min);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回指定score内zset中的value
-//     * </p>
-//     *
-//     * @param key
-//     * @param max
-//     * @param min
-//     * @return
-//     */
-//    public Set<String> zrangeByScore(String key, double max, double min) {
-//        Jedis jedis = null;
-//        Set<String> res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zrevrangeByScore(key, max, min);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 返回指定区间内zset中value的数量
-//     * </p>
-//     *
-//     * @param key
-//     * @param min
-//     * @param max
-//     * @return
-//     */
-//    public Long zcount(String key, String min, String max) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zcount(key, min, max);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key返回zset中的value个数
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public Long zcard(String key) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zcard(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key获取zset中value的score值
-//     * </p>
-//     *
-//     * @param key
-//     * @param member
-//     * @return
-//     */
-//    public Double zscore(String key, String member) {
-//        Jedis jedis = null;
-//        Double res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zscore(key, member);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key删除给定区间内的元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param start
-//     * @param end
-//     * @return
-//     */
-//    public Long zremrangeByRank(String key, long start, long end) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zremrangeByRank(key, start, end);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key删除指定score内的元素
-//     * </p>
-//     *
-//     * @param key
-//     * @param start
-//     * @param end
-//     * @return
-//     */
-//    public Long zremrangeByScore(String key, double start, double end) {
-//        Jedis jedis = null;
-//        Long res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.zremrangeByScore(key, start, end);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**返回满足pattern表达式的所有 key*/
-//    public Set<String> keys(String pattern) {
-//        Set<String> res = this.scan(pattern);
-//        return res;
-//    }
-//
-//    /**
-//     * key模糊查找
-//     * @param keys 要查找的key 例: aaa* ,aaa开头的所有key
-//     * @return 匹配到的key集合
-//     */
-//    public Set<String> scan(String keys) {
-//        return scan(keys,scanlimit);
-//    }
-//
-//    /**
-//     *  根据match 查询redis中中的所有key
-//     * @param match input the argument "ONLINE_*"
-//     * @param limit 每次查询个数，不要太大
-//     */
-//    public Set<String> scan(String match,int limit) {
-//        HashSet<String> keySet = Sets.newHashSet();
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            //指定规则
-//            ScanParams scanParams = new ScanParams().match(match).count(limit);
-//            boolean hasNext = true;
-//            //第一次查询的游标
-//            String cursor = "0";
-//            while (hasNext) {
-//                ScanResult<String> scanResult = jedis.scan(cursor,scanParams);
-//                //返回当前查询的key
-//                List<String> keyList = scanResult.getResult();
-//                keySet.addAll(keyList);
-//
-//                cursor = scanResult.getStringCursor();
-//                if ("0".equals(cursor)) {
-//                    hasNext = false;
-//                }
-//            }
-//        } catch (Exception e) {
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return keySet;
-//    }
-//
-//    /**
-//     * <p>
-//     * 通过key判断值得类型
-//     * </p>
-//     *
-//     * @param key
-//     * @return
-//     */
-//    public String type(String key) {
-//        Jedis jedis = null;
-//        String res = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            res = jedis.type(key);
-//        } catch (Exception e) {
-//
-//            logger.error(e.getMessage());
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return res;
-//    }
-//
-//    /**
-//     * 序列化对象
-//     *
-//     * @param obj
-//     * @return 对象需实现Serializable接口
-//     */
-//    public static byte[] ObjTOSerialize(Object obj) {
-//        ObjectOutputStream oos = null;
-//        ByteArrayOutputStream byteOut = null;
-//        try {
-//            byteOut = new ByteArrayOutputStream();
-//            oos = new ObjectOutputStream(byteOut);
-//            oos.writeObject(obj);
-//            byte[] bytes = byteOut.toByteArray();
-//            return bytes;
-//        } catch (Exception e) {
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * 反序列化对象
-//     *
-//     * @param bytes
-//     * @return 对象需实现Serializable接口
-//     */
-//    public static Object unserialize(byte[] bytes) {
-//        ByteArrayInputStream bais = null;
-//        try {
-//            //反序列化
-//            bais = new ByteArrayInputStream(bytes);
-//            ObjectInputStream ois = new ObjectInputStream(bais);
-//            return ois.readObject();
-//        } catch (Exception e) {
-//        }
-//        return null;
-//    }
-//
-//    /**
-//     * 返还到连接池
-//     *
-//     * @param jedis
-//     */
-//    public static void returnResource(Jedis jedis) {
-//        if (jedis != null) {
-//            jedis.close();
-//        }
-//    }
-//
-//    /**
-//     * jedis 上锁
-//     * @param lockKey
-//     * @param requestId 锁的值
-//     * @param expireTime
-//     * @return
-//     */
-//    public boolean tryLock(String lockKey, String requestId, int expireTime) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME_EX, expireTime);
-//            if (LOCK_SUCCESS.equals(result)) {
-//                return true;
-//            }
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//            return  false;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return false;
-//    }
-//    /**
-//     * jedis 上锁
-//     * @param lockKey
-//     * @param requestId 锁的值
-//     * @param expireTime
-//     * @return
-//     */
-//    public boolean tryLockSec(String lockKey, String requestId, int expireTime) {
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME_EX, expireTime);
-//            if (LOCK_SUCCESS.equals(result)) {
-//                return true;
-//            }
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//            return  false;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return false;
-//    }
-//    /**
-//     * jedis 上锁
-//     * @param lockKey
-//     * @param requestId 锁的值
-//     * @return
-//     */
-//    public boolean tryLock(String lockKey, String requestId) {
-//        return  this.tryLock( lockKey,  requestId, lockWaitTime);
-//    }
-//
-//
-//    /**
-//     * jedis 上锁没返回
-//     * @param lockKey
-//     * @param requestId
-//     * @param expireTime
-//     */
-//    public void lock(String lockKey, String requestId, int expireTime) {
-//        while (true) {
-//            if (tryLock(lockKey, requestId, expireTime)) {
-//                return;
-//            }
-//        }
-//    }
-//
-//    /**
-//     * jedis解锁
-//     * @param lockKey
-//     * @param requestId
-//     * @return
-//     */
-//    public boolean unLock(String lockKey, String requestId) {
-//        String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
-//        Jedis jedis = null;
-//        try {
-//            jedis = jedisPool.getResource();
-//            jedis.select(indexdb);
-//            Object result = jedis.eval(script, Collections.singletonList(lockKey),
-//                    Collections.singletonList(requestId));
-//            if (RELEASE_SUCCESS.equals(result)) {
-//                System.out.println("unlock  "+ Thread.currentThread().getName()+ " requestId:" + requestId);
-//                return true;
-//            }
-//            jedis.del(lockKey);
-//        } catch (Exception e) {
-//            throw e;
-//        } finally {
-//            returnResource(jedis);
-//        }
-//        return false;
-//    }
-//
-//
-//    @Cacheable(value="getSelectRedis" ,key="#sCacheableName")
-//    public List<Map<String,Object>> getSelectRedis(String sCacheableName,List<Map<String,Object>> selectDate) {
-//        return selectDate;
-//    }
-//
-//    public static void main(String[] args) {
-//		/*JedisPool jedisPool = new JedisPool(null,"localhost",6379,100,"123456");
-//		Jedis jedis = jedisPool.getResource();
-//		//r.get("", RedisConstants.datebase4);
-//		jedis.select(RedisConstants.datebase4);
-//		Set<String> str =  jedis.keys("*");
-//		for (String string : str) {
-//			System.out.println(string);
-//		}*/
-//    }
-//}
\ No newline at end of file
diff --git a/src/main/java/com/xly/config/RedisConfig.java b/src/main/java/com/xly/config/RedisConfig.java
new file mode 100644
index 0000000..b68afb2
--- /dev/null
+++ b/src/main/java/com/xly/config/RedisConfig.java
@@ -0,0 +1,31 @@
+package com.xly.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(factory);
+
+        // key 采用 String 序列化
+        template.setKeySerializer(new StringRedisSerializer());
+        // hash 的 key 也采用 String 序列化
+        template.setHashKeySerializer(new StringRedisSerializer());
+
+        // value 采用 Jackson 序列化
+        GenericJackson2JsonRedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer();
+        template.setValueSerializer(jsonSerializer);
+        template.setHashValueSerializer(jsonSerializer);
+
+        template.afterPropertiesSet();
+        return template;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/com/xly/config/SpringContextHolder.java b/src/main/java/com/xly/config/SpringContextHolder.java
new file mode 100644
index 0000000..f3c332c
--- /dev/null
+++ b/src/main/java/com/xly/config/SpringContextHolder.java
@@ -0,0 +1,80 @@
+package com.xly.config;
+
+import org.apache.commons.lang3.Validate;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Service;
+
+/**
+ * 以静态变量保存Spring ApplicationContext, 可在任何代码任何地方任何时候取出ApplicaitonContext.
+ */
+@Service
+@Lazy(false)
+public class SpringContextHolder implements ApplicationContextAware, DisposableBean {
+
+    private static ApplicationContext applicationContext = null;
+
+    private static Logger logger = LoggerFactory.getLogger(SpringContextHolder.class);
+
+    /**
+     * 取得存储在静态变量中的ApplicationContext.
+     */
+    public static ApplicationContext getApplicationContext() {
+        assertContextInjected();
+        return applicationContext;
+    }
+
+    /**
+     * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
+     */
+    @SuppressWarnings("unchecked")
+    public static <T> T getBean(String name) {
+        assertContextInjected();
+        return (T) applicationContext.getBean(name);
+    }
+
+    /**
+     * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
+     */
+    public static <T> T getBean(Class<T> requiredType) {
+        assertContextInjected();
+        return applicationContext.getBean(requiredType);
+    }
+
+    /**
+     * 清除SpringContextHolder中的ApplicationContext为Null.
+     */
+    public static void clearHolder() {
+        if (logger.isDebugEnabled()){
+            logger.debug("清除SpringContextHolder中的ApplicationContext:" + applicationContext);
+        }
+        applicationContext = null;
+    }
+
+    /**
+     * 实现ApplicationContextAware接口, 注入Context到静态变量中.
+     */
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) {
+        SpringContextHolder.applicationContext = applicationContext;
+    }
+
+    /**
+     * 实现DisposableBean接口, 在Context关闭时清理静态变量.
+     */
+    @Override
+    public void destroy() throws Exception {
+        SpringContextHolder.clearHolder();
+    }
+
+    /**
+     * 检查ApplicationContext不为空.
+     */
+    private static void assertContextInjected() {
+        Validate.validState(applicationContext != null, "applicaitonContext属性未注入, 请在applicationContext.xml中定义SpringContextHolder.");
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/com/xly/entity/AiSqlErrorHistory.java b/src/main/java/com/xly/entity/AiSqlErrorHistory.java
new file mode 100644
index 0000000..1b5eb38
--- /dev/null
+++ b/src/main/java/com/xly/entity/AiSqlErrorHistory.java
@@ -0,0 +1,30 @@
+package com.xly.entity;
+
+import cn.hutool.core.util.StrUtil;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class AiSqlErrorHistory {
+
+    private Integer iIncrement;
+    private String sId;
+    private Integer iOrder;
+    private Date tCreateDate;
+    private String sBrandsId;
+    private String sSubsidiaryId;
+    private String sMakePerson;
+    private String sBillNo;
+    private String sFormId= StrUtil.EMPTY;
+    private Integer sStatus;
+    private String sSceneId;
+    private String sMethodId;
+    private String sQuestion;
+    private String sError_sql;
+    private String sError_mes;
+    private String sCorrect_sql;
+    private Boolean bCheck = false;
+    private Boolean bInvalid = false;
+    private String sLoginId;
+}
diff --git a/src/main/java/com/xly/entity/AiUserAgentQuestion.java b/src/main/java/com/xly/entity/AiUserAgentQuestion.java
new file mode 100644
index 0000000..f4bf104
--- /dev/null
+++ b/src/main/java/com/xly/entity/AiUserAgentQuestion.java
@@ -0,0 +1,39 @@
+package com.xly.entity;
+
+import cn.hutool.core.util.StrUtil;
+import lombok.Data;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+@Data
+public class AiUserAgentQuestion {
+
+    private Integer iIncrement;
+    private String sId;
+    private Integer iOrder;
+    private Date tCreateDate;
+    private String sBrandsId;
+    private String sSubsidiaryId;
+    private String sMakePerson;
+    private String sBillNo;
+    private String sFormId= StrUtil.EMPTY;
+    private Integer sStatus;
+    private String sSceneId;
+    private String sMethodId;
+    private String sQuestion;
+    private String sSqlContent;
+    private Boolean bCheck = false;
+    private Boolean bInvalid = false;
+    private String sLoginId;
+    private String sQuestionGroupNo;
+    private Boolean bRedis = false;
+    private Date tUpdateDate;
+    private Integer iUpdate;
+
+
+
+
+
+}
diff --git a/src/main/java/com/xly/entity/UserSceneSession.java b/src/main/java/com/xly/entity/UserSceneSession.java
index b200072..b1c1965 100644
--- a/src/main/java/com/xly/entity/UserSceneSession.java
+++ b/src/main/java/com/xly/entity/UserSceneSession.java
@@ -29,6 +29,10 @@ public class UserSceneSession {
      * 该用户权限内可访问的所有场景（从权限映射中获取）
      */
     private List<SceneDto> authScenes;
+    /***
+     * 用户问题集合
+     **/
+    private List<String> sUserQuestionList;
 
     private List<ToolMeta> authTool;
     /**
diff --git a/src/main/java/com/xly/service/DynamicExeDbService.java b/src/main/java/com/xly/service/DynamicExeDbService.java
index 6c88414..d0e89a5 100644
--- a/src/main/java/com/xly/service/DynamicExeDbService.java
+++ b/src/main/java/com/xly/service/DynamicExeDbService.java
@@ -214,16 +214,7 @@ public class DynamicExeDbService {
     public Map<String, Object> getDoProMap(String sProName, Map<String, Object> params) throws BusinessException{
         Map<String,Object> searMap = new HashMap<>(4);
         try{
-            //根据过程名称获取过程参数
-            //添加公司子公司
-//            if((ObjectUtil.isEmpty(params.get("sBrId"))
-//                    || ObjectUtil.isEmpty(params.get("sSuId")))){
-//                params.put("sBrId",params.get("sBrandsId"));
-//                params.put("sSuId",params.get("sSubsidiaryId"));
-//            }
-//            if(ObjectUtil.isEmpty(params.get("sLoginId"))){
-//                params.put("sLoginId",params.get("sUserId"));
-//            }
+
             List<Map<String, Object>> proList = getProcParam( sProName);
             //{CALL mytest(#{ownerid,mode=IN,jdbcType=INTEGER},#{examcount,mode=OUT,jdbcType=INTEGER})}
             StringBuffer sb = new StringBuffer();
diff --git a/src/main/java/com/xly/service/RedisService.java b/src/main/java/com/xly/service/RedisService.java
new file mode 100644
index 0000000..7a998d7
--- /dev/null
+++ b/src/main/java/com/xly/service/RedisService.java
@@ -0,0 +1,436 @@
+package com.xly.service;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.*;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Service("redisService")
+@RequiredArgsConstructor
+public class RedisService {
+
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+
+    // ============================= common ============================
+
+    /**
+     * 指定缓存失效时间
+     */
+    public boolean expire(String key, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.expire(key, time, TimeUnit.SECONDS);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据key获取过期时间
+     */
+    public long getExpire(String key) {
+        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
+    }
+
+    /**
+     * 判断key是否存在
+     */
+    public boolean hasKey(String key) {
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除缓存
+     */
+    @SuppressWarnings("unchecked")
+    public boolean del(String... key) {
+        try {
+            if (key != null && key.length > 0) {
+                if (key.length == 1) {
+                    redisTemplate.delete(key[0]);
+                } else {
+                    redisTemplate.delete((Collection<String>) CollectionUtils.arrayToList(key));
+                }
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    // ============================ String =============================
+
+    /**
+     * 普通缓存获取
+     */
+    public Object get(String key) {
+        return key == null ? null : redisTemplate.opsForValue().get(key);
+    }
+
+    /**
+     * 普通缓存放入
+     */
+    public boolean set(String key, Object value) {
+        try {
+            redisTemplate.opsForValue().set(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 普通缓存放入并设置时间
+     */
+    public boolean set(String key, Object value, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
+            } else {
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 递增
+     */
+    public long incr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递增因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, delta);
+    }
+
+    /**
+     * 递减
+     */
+    public long decr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递减因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, -delta);
+    }
+
+    // ================================ Map =================================
+
+    /**
+     * HashGet
+     */
+    public Object hget(String key, String item) {
+        return redisTemplate.opsForHash().get(key, item);
+    }
+
+    /**
+     * 获取hashKey对应的所有键值
+     */
+    public Map<Object, Object> hmget(String key) {
+        return redisTemplate.opsForHash().entries(key);
+    }
+
+    /**
+     * HashSet
+     */
+    public boolean hmset(String key, Map<String, Object> map) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * HashSet 并设置时间
+     */
+    public boolean hmset(String key, Map<String, Object> map, long time) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     */
+    public boolean hset(String key, String item, Object value) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,并设置时间
+     */
+    public boolean hset(String key, String item, Object value, long time) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除hash表中的值
+     */
+    public void hdel(String key, Object... item) {
+        redisTemplate.opsForHash().delete(key, item);
+    }
+
+    /**
+     * 判断hash表中是否有该项的值
+     */
+    public boolean hHasKey(String key, String item) {
+        return redisTemplate.opsForHash().hasKey(key, item);
+    }
+
+    /**
+     * hash递增
+     */
+    public double hincr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, by);
+    }
+
+    /**
+     * hash递减
+     */
+    public double hdecr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, -by);
+    }
+
+    // ============================ set =============================
+
+    /**
+     * 根据key获取Set中的所有值
+     */
+    public Set<Object> sGet(String key) {
+        try {
+            return redisTemplate.opsForSet().members(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 根据value从一个set中查询,是否存在
+     */
+    public boolean sHasKey(String key, Object value) {
+        try {
+            return redisTemplate.opsForSet().isMember(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将数据放入set缓存
+     */
+    public long sSet(String key, Object... values) {
+        try {
+            return redisTemplate.opsForSet().add(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 将set数据放入缓存
+     */
+    public long sSetAndTime(String key, long time, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().add(key, values);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 获取set缓存的长度
+     */
+    public long sGetSetSize(String key) {
+        try {
+            return redisTemplate.opsForSet().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 移除值为value的
+     */
+    public long setRemove(String key, Object... values) {
+        try {
+            return redisTemplate.opsForSet().remove(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    // =============================== list =================================
+
+    /**
+     * 获取list缓存的内容
+     */
+    public List<Object> lGet(String key, long start, long end) {
+        try {
+            return redisTemplate.opsForList().range(key, start, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list缓存的长度
+     */
+    public long lGetListSize(String key) {
+        try {
+            return redisTemplate.opsForList().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 通过索引获取list中的值
+     */
+    public Object lGetIndex(String key, long index) {
+        try {
+            return redisTemplate.opsForList().index(key, index);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     */
+    public boolean lSet(String key, Object value) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     */
+    public boolean lSet(String key, Object value, long time) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     */
+    public boolean lSet(String key, List<Object> value) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     */
+    public boolean lSet(String key, List<Object> value, long time) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据索引修改list中的某条数据
+     */
+    public boolean lUpdateIndex(String key, long index, Object value) {
+        try {
+            redisTemplate.opsForList().set(key, index, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 移除N个值为value
+     */
+    public long lRemove(String key, long count, Object value) {
+        try {
+            return redisTemplate.opsForList().remove(key, count, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/com/xly/service/XlyErpService.java b/src/main/java/com/xly/service/XlyErpService.java
index 54c383f..1cdf9d5 100644
--- a/src/main/java/com/xly/service/XlyErpService.java
+++ b/src/main/java/com/xly/service/XlyErpService.java
@@ -3,6 +3,7 @@ package com.xly.service;
 import cn.hutool.core.collection.ListUtil;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson2.JSON;
@@ -16,8 +17,10 @@ import com.xly.constant.ReturnTypeCode;
 import com.xly.entity.*;
 import com.xly.exception.sqlexception.SqlGenerateException;
 import com.xly.exception.sqlexception.SqlValidateException;
-import com.xly.mapper.ToolMetaMapper;
 import com.xly.runner.AppStartupRunner;
+import com.xly.thread.AiSqlErrorHistoryThread;
+import com.xly.thread.AiUserAgentQuestionThread;
+import com.xly.thread.MultiThreadPoolServer;
 import com.xly.tool.DynamicToolProvider;
 import com.xly.util.EnhancedErrorGuidance;
 import com.xly.util.InputPreprocessor;
@@ -34,6 +37,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.util.IdGenerator;
 
 import java.time.Duration;
 import java.util.*;
@@ -51,6 +55,7 @@ public class XlyErpService {
     private final DynamicToolProvider dynamicToolProvider;
     private final OperableChatMemoryProvider operableChatMemoryProvider;
     private final DynamicExeDbService dynamicExeDbService;
+    private final RedisService redisService;
 
     //执行动态语句 执行异常的情况下 最多执行次数
     private final Integer maxRetries = 5;
@@ -186,6 +191,18 @@ public class XlyErpService {
             while (attempt < maxRetries) {
                 try{
                     attempt = attempt+1;
+                    if(attempt==1){
+                        List<String> userQuestionList = session.getSUserQuestionList();
+                        if(ObjectUtil.isEmpty(userQuestionList)){
+                            userQuestionList = new ArrayList<>();
+                        }
+                        String  sQuestion = StrUtil.replace(userInput," ",StrUtil.EMPTY);
+                        sQuestion = StrUtil.replace(sQuestion,"\t",StrUtil.EMPTY);
+                        sQuestion = StrUtil.replace(sQuestion,"\n",StrUtil.EMPTY);
+                        sQuestion = sQuestion.toLowerCase();
+                        userQuestionList.add(sQuestion);
+                        session.setSUserQuestionList(userQuestionList);
+                    }
                     return getDynamicTableSqlExec(session, input, userId, userInput,errorSql,errorMessage,iErroCount,historySqlList, aiAgent);
                 }catch (SqlValidateException e){
                     return "本场景没有识别到您的意图<br/> 如果切换场景，点［回首页］，如果在本场景下，转换意图，点［清除记忆］";
@@ -243,38 +260,63 @@ public class XlyErpService {
      **/
     private String getDynamicTableSqlExec(UserSceneSession session,String input,String userId,String userInput,String errorSql,String errorMessage,String iErroCount,String historySqlList,ErpAiAgent aiAgent){
         // 1. 构建自然语言转SQLAgent，
-        DynamicTableNl2SqlAiAgent aiDynamicTableNl2SqlAiAgent = createDynamicTableNl2SqlAiAgent(userId, input, session);
-        String tableNames = session.getCurrentTool().getSInputTabelName();
-        // "订单表:viw_salsalesorder,客户信息表:elecustomer,结算方式表:sispayment,产品表(无单价,无金额,无数量):viw_product_sort,销售人员表:viw_sissalesman_depart";
-        String tableStruct = session.getCurrentTool().getSStructureMemo();
-        String sDataNow = DateUtil.format(new Date(), DatePattern.CHINESE_DATE_TIME_FORMAT);
-        String rawSql = StrUtil.EMPTY;
-        if(ObjectUtil.isEmpty(errorSql) && ObjectUtil.isEmpty(errorMessage)){
-            rawSql = aiDynamicTableNl2SqlAiAgent.generateMysqlSql(userId,tableNames,tableStruct,sDataNow,userInput);
-        }else{
-            rawSql = aiDynamicTableNl2SqlAiAgent.regenerateSqlWithError(userId, tableNames,tableStruct,sDataNow,userInput,errorSql,errorMessage,iErroCount,historySqlList);
-        }
-        log.info("rawSql："+rawSql);
-        if (rawSql == null || rawSql.trim().isEmpty()) {
-            throw new SqlValidateException("SQL EMPTY");
-        }
-        // 2. 清理SQL多余符号 + 生产级强校验（核心安全保障，不可省略）
-        String cleanSql = SqlValidateUtil.cleanSqlSymbol(rawSql);
-//        String[] cleanSqlA = rawSql.split(";");
-//        if(cleanSqlA.length>1){
-//            cleanSql = cleanSqlA[cleanSqlA.length-1];
-//        }
-        SqlValidateUtil.validateMysqlSql(cleanSql);
-        // 4. 执行SQL获取结构化结果
-//                Map<String,Object> params = new HashMap<>();
         List<Map<String, Object>> sqlResult = new ArrayList<>();
+        String cleanSql = StrUtil.EMPTY;
+        String rawSql;
+        String tableStruct;
+        String sError_mes = StrUtil.EMPTY;
+        Boolean doSqlErro = false;
+        List<ChatMessage> chatMessage = operableChatMemoryProvider.getCurrentChatMessages(session.getUserId());
         try{
-           sqlResult = dynamicExeDbService.findSql(new HashMap<>(),cleanSql);
-        }catch (Exception e){
-            throw new SqlGenerateException(e.getMessage()+" OLDSQL "+cleanSql);
+            DynamicTableNl2SqlAiAgent aiDynamicTableNl2SqlAiAgent = createDynamicTableNl2SqlAiAgent(userId, input, session);
+            String tableNames = session.getCurrentTool().getSInputTabelName();
+            // "订单表:viw_salsalesorder,客户信息表:elecustomer,结算方式表:sispayment,产品表(无单价,无金额,无数量):viw_product_sort,销售人员表:viw_sissalesman_depart";
+            tableStruct = session.getCurrentTool().getSStructureMemo();
+             String sDataNow = DateUtil.format(new Date(), DatePattern.CHINESE_DATE_TIME_FORMAT);
+
+            if(ObjectUtil.isEmpty(errorSql) && ObjectUtil.isEmpty(errorMessage)){
+                rawSql = aiDynamicTableNl2SqlAiAgent.generateMysqlSql(userId,tableNames,tableStruct,sDataNow,userInput);
+            }else{
+                rawSql = aiDynamicTableNl2SqlAiAgent.regenerateSqlWithError(userId, tableNames,tableStruct,sDataNow,userInput,errorSql,errorMessage,iErroCount,historySqlList);
+            }
+            log.info("rawSql："+rawSql);
+            if (rawSql == null || rawSql.trim().isEmpty()) {
+                throw new SqlValidateException("SQL EMPTY");
+            }
+            // 2. 清理SQL多余符号 + 生产级强校验（核心安全保障，不可省略）
+             cleanSql = SqlValidateUtil.cleanSqlSymbol(rawSql);
+            //        String[] cleanSqlA = rawSql.split(";");
+            //        if(cleanSqlA.length>1){
+            //            cleanSql = cleanSqlA[cleanSqlA.length-1];
+            //        }
+            SqlValidateUtil.validateMysqlSql(cleanSql);
+            // 4. 执行SQL获取结构化结果
+            //                Map<String,Object> params = new HashMap<>();
+            try{
+               sqlResult = dynamicExeDbService.findSql(new HashMap<>(),cleanSql);
+            }catch (Exception e){
+                throw new SqlGenerateException(e.getMessage()+" OLDSQL "+cleanSql);
+            }
+        }catch (SqlValidateException e){
+            sError_mes = e.getMessage();
+            doAiSqlErrorHistoryThread(session, StrUtil.EMPTY, cleanSql, sError_mes,input);
+            throw e;
+        }catch (SqlGenerateException e){
+            sError_mes = e.getMessage();
+            doAiSqlErrorHistoryThread(session, StrUtil.EMPTY, cleanSql, sError_mes,input);
+            throw e;
         }
+
         // 5. 调用AI服务生成自然语言解释（传入表结构，让解释更贴合业务）
         String resultJson = JSON.toJSONString(sqlResult);
+
+        //执行正确去修改对应正确的SQl
+        if(Integer.valueOf(iErroCount)>0){
+            doAiSqlErrorHistoryThread(session, cleanSql, StrUtil.EMPTY, StrUtil.EMPTY,input);
+        }
+
+        //执行操作记录表
+        doAiUserAgentQuestion(session,input,cleanSql,chatMessage);
         String sText = aiAgent.explainSqlResult(
                 userId,
                 userInput,
@@ -282,10 +324,49 @@ public class XlyErpService {
                 tableStruct,
                 resultJson
         );
-        log.info("sText："+sText);
         return sText;
     }
 
+
+    /***
+     * @Author 钱豹
+     * @Date 16:57 2026/3/14
+     * @Param
+     * @return
+     * @Description 记录动态SQL日志(多线程)
+     **/
+    public void doAiSqlErrorHistoryThread(UserSceneSession session,
+                                                String sSqlContent,
+                                                String sError_sql,
+                                                String sError_mes,
+                                                String sQuestion
+
+    ){
+        MultiThreadPoolServer mts = MultiThreadPoolServer.getInstance();
+        AiSqlErrorHistoryThread at = new AiSqlErrorHistoryThread(session,  sSqlContent,  sError_sql, sError_mes,sQuestion);
+        mts.service(at);
+    }
+
+    /***
+     * @Author 钱豹
+     * @Date 16:57 2026/3/14
+     * @Param
+     * @return
+     * @Description 记录动态SQL日志(多线程)
+     **/
+    public void doAiUserAgentQuestion(UserSceneSession session,
+                                          String sQuestion,
+                                          String sSqlContent,
+                                          List<ChatMessage> chatMessage
+
+    ){
+        MultiThreadPoolServer mts = MultiThreadPoolServer.getInstance();
+        AiUserAgentQuestionThread at = new AiUserAgentQuestionThread(session,sQuestion,sSqlContent,chatMessage);
+        mts.service(at);
+    }
+
+
+
     /***
      * @Author 钱豹
      * @Date 11:22 2026/1/31
diff --git a/src/main/java/com/xly/thread/AiSqlErrorHistoryThread.java b/src/main/java/com/xly/thread/AiSqlErrorHistoryThread.java
new file mode 100644
index 0000000..86b348f
--- /dev/null
+++ b/src/main/java/com/xly/thread/AiSqlErrorHistoryThread.java
@@ -0,0 +1,65 @@
+package com.xly.thread;
+
+
+import cn.hutool.core.util.StrUtil;
+import com.xly.config.SpringContextHolder;
+import com.xly.entity.UserSceneSession;
+import com.xly.service.DynamicExeDbService;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+public class AiSqlErrorHistoryThread implements Runnable {
+    private UserSceneSession session;
+    private String sSqlContent;
+    private String sError_sql;
+    private String sError_mes;
+    private String sQuestion;
+    public final String sProName="Sp_Ai_AiSqlErrorHistoryThread";
+
+    public AiSqlErrorHistoryThread(UserSceneSession session, String sSqlContent, String sError_sql,String sError_mes,String sQuestion) {
+        this.session = session;
+        this.sSqlContent = sSqlContent;
+        this.sError_sql = sError_sql;
+        this.sError_mes = sError_mes;
+        this.sQuestion = sQuestion;
+    }
+    @Override
+    public void run() {
+        String sSceneId = session.getCurrentScene().getSId();
+        String sMethodId = session.getCurrentTool().getSId();
+        DynamicExeDbService dynamicExeDbService = SpringContextHolder.getBean(DynamicExeDbService.class);
+        Map<String, Object> data = getMap(sSceneId, sMethodId);
+        data.put("sQuestion",getsQuestion(session.getSUserQuestionList()));
+        Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
+        dynamicExeDbService.getCallPro(searMap, sProName);
+    }
+    private String getsQuestion(List<String> sUserQuestionList){
+        return String.join(",", sUserQuestionList);
+    }
+    /***
+     * @Author 钱豹
+     * @Date 4:22 2026/3/15
+     * @Param [sSceneId, sMethodId]
+     * @return java.util.Map<java.lang.String,java.lang.Object>
+     * @Description 获取执行的动态Map
+     **/
+    private Map<String, Object> getMap(String sSceneId, String sMethodId) {
+        Map<String,Object> data = new HashMap<>(16);
+        data.put("sSceneId", sSceneId);
+        data.put("sMethodId", sMethodId);
+        data.put("sSqlContent",sSqlContent);
+        data.put("sError_sql",sError_sql);
+        data.put("sError_mes",sError_mes);
+        data.put("sBrId",session.getSBrandsId());
+        data.put("sBrandsId",session.getSBrandsId());
+        data.put("sSuId",session.getSSubsidiaryId());
+        data.put("sSubsidiaryId",session.getSSubsidiaryId());
+        data.put("sLoginId",session.getUserName());
+        data.put("sUserName",session.getUserName());
+        data.put("sUserId",session.getUserId());
+        return data;
+    }
+}
diff --git a/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java b/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java
new file mode 100644
index 0000000..9071995
--- /dev/null
+++ b/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java
@@ -0,0 +1,90 @@
+package com.xly.thread;
+
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.xly.config.OperableChatMemoryProvider;
+import com.xly.config.SpringContextHolder;
+import com.xly.entity.UserSceneSession;
+import com.xly.service.DynamicExeDbService;
+import dev.langchain4j.data.message.ChatMessage;
+import dev.langchain4j.data.message.ChatMessageType;
+import jnr.ffi.annotations.In;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class AiUserAgentQuestionThread implements Runnable {
+    private UserSceneSession session;
+    private String sSqlContent;
+    private String sQuestion;
+    List<ChatMessage> userMessage;
+    public final String sProName="Sp_Ai_AiUserAgentQuestionThread";
+
+    public AiUserAgentQuestionThread(UserSceneSession session,String sQuestion,String sSqlContent, List<ChatMessage> userMessage ) {
+        this.session = session;
+        this.sSqlContent = sSqlContent;
+        this.sQuestion = sQuestion;
+        this.userMessage = userMessage;
+    }
+
+    @Override
+    public void run() {
+        sQuestion = sQuestion.replace("用户输入：",StrUtil.EMPTY);
+        String sSceneId = session.getCurrentScene().getSId();
+        String sMethodId = session.getCurrentTool().getSId();
+        DynamicExeDbService dynamicExeDbService = SpringContextHolder.getBean(DynamicExeDbService.class);
+        String sQuestionGroupNo = session.getSUserQuestionList().get(0);
+        Integer bRedis = (session.getSUserQuestionList().size()==1)?1:0;
+        Map<String, Object> data = getMap(sSceneId, sMethodId,bRedis,sQuestionGroupNo);
+        data.put("sQuestion",getsQuestion(session.getSUserQuestionList()));
+        Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
+        dynamicExeDbService.getCallPro(searMap, sProName);
+    }
+
+    private String getsQuestion(List<String> sUserQuestionList){
+        return String.join(",", sUserQuestionList);
+    }
+
+    //获取组ID
+    private String getQuestionGroupNo(){
+        String sQuestionGroupNo = userMessage.stream()
+                .filter(one -> one.type().equals(ChatMessageType.USER) && !"用户输入：initAiService".equals(one.text()))
+                .findFirst()
+                .map(one->one.text())
+                .orElse(StrUtil.EMPTY);
+        sQuestionGroupNo = sQuestionGroupNo.replace("用户输入：",StrUtil.EMPTY);
+        sQuestionGroupNo = sQuestionGroupNo.replace(" ",StrUtil.EMPTY);
+        sQuestionGroupNo = sQuestionGroupNo.replace("\\t",StrUtil.EMPTY);
+        sQuestionGroupNo = sQuestionGroupNo.replace("\\n",StrUtil.EMPTY);
+        sQuestionGroupNo = sQuestionGroupNo.toLowerCase();
+        return sQuestionGroupNo;
+    }
+
+
+    /***
+     * @Author 钱豹
+     * @Date 4:22 2026/3/15
+     * @Param [sSceneId, sMethodId]
+     * @return java.util.Map<java.lang.String,java.lang.Object>
+     * @Description 获取执行的动态Map
+     **/
+    private Map<String, Object> getMap(String sSceneId, String sMethodId,Integer bRedis,String sQuestionGroupNo) {
+        Map<String,Object> data = new HashMap<>(16);
+        data.put("sSceneId", sSceneId);
+        data.put("sMethodId", sMethodId);
+        data.put("sSqlContent",sSqlContent);
+        data.put("sBrId",session.getSBrandsId());
+        data.put("sBrandsId",session.getSBrandsId());
+        data.put("sSuId",session.getSSubsidiaryId());
+        data.put("sSubsidiaryId",session.getSSubsidiaryId());
+        data.put("sLoginId",session.getUserName());
+        data.put("sUserName",session.getUserName());
+        data.put("sUserId",session.getUserId());
+        data.put("bRedis",bRedis);
+        data.put("sQuestionGroupNo",sQuestionGroupNo);
+        return data;
+    }
+}
diff --git a/src/main/java/com/xly/thread/MultiThreadPoolServer.java b/src/main/java/com/xly/thread/MultiThreadPoolServer.java
new file mode 100644
index 0000000..bcfb49d
--- /dev/null
+++ b/src/main/java/com/xly/thread/MultiThreadPoolServer.java
@@ -0,0 +1,103 @@
+package com.xly.thread;
+
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.poi.ss.formula.functions.T;
+import org.python.google.common.util.concurrent.ThreadFactoryBuilder;
+
+
+/**
+ *
+ * 线程池不允许使用Executors去创建，而是通过ThreadPoolExecutor的方式，
+ * 这样的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。
+ *  说明：Executors各个方法的弊端：
+ * 1）newFixedThreadPool和newSingleThreadExecutor:
+ *   主要问题是堆积的请求处理队列可能会耗费非常大的内存，甚至OOM。
+ * 2）newCachedThreadPool和newScheduledThreadPool:
+ *   主要问题是线程数最大数是Integer.MAX_VALUE，可能会创建数量非常多的线程，甚至OOM。
+ * 功能:任务线程池类(2秒更新一次线程单独用)
+ * 工具类参考https://blog.csdn.net/bunnycoffer/article/details/82908024
+ * 作者:qb
+ * 日期:2018-11-13
+ * @author qianbao
+ */
+public class MultiThreadPoolServer {
+
+    /**   ˽������线程池服务*/
+    private ExecutorService executorService;
+    private static MultiThreadPoolServer mts;
+    private final static int poolSize = 30000;
+    private final static int queueSize = 30000;
+
+    private static ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("theadpool" + "-%d").setDaemon(true).build();
+    /**   单例方法   */
+    public static MultiThreadPoolServer getInstance() {
+
+        //生成实例
+        if (mts == null) {
+            //锁类ͬ����
+            synchronized(MultiThreadPoolServer.class) {
+                if (mts == null) {
+                    //实例化
+                    mts = new MultiThreadPoolServer();
+                    mts.executorService = new ThreadPoolExecutor(poolSize,
+                            poolSize,
+                            0L,
+                            TimeUnit.SECONDS,
+                            new ArrayBlockingQueue<Runnable>(queueSize),
+                            threadFactory,
+                            new ThreadPoolExecutor.AbortPolicy() {
+                                // 队列已满,而且当前线程数已经超过最大线程数时的异常处理策略
+                                @Override
+                                public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
+                                    super.rejectedExecution(r, e);
+                                }
+                            });
+                }
+            }
+        }
+
+        //返回值
+        return mts;
+
+    }
+
+    /**   线程池调用方法   */
+    public void service(Runnable handler) {
+        try {
+            //调用线程
+            this.executorService.execute(handler);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 开启一个有返回结果的线程
+     * @param
+     * @return
+     */
+    public Future<T> submit(Callable<T> handler) {
+        // 把一个任务丢到了线程池中
+        try {
+            //调用线程
+            return this.executorService.submit(handler);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+
+    /**   线程池结束   */
+    public void shutdown() {
+        this.executorService.shutdown();
+    }
+
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 4cc4d26..27ee7ab 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -50,23 +50,18 @@ spring:
       idle-timeout: 600000
       max-lifetime: 1800000
   # REDIS (RedisProperties)
-#  redis:
-#    host: 127.0.0.1
-#    password: xlyXLY2015
-#    port: 6380
-#    database: 8  # index
-#    timeout: 30000ms  # 连接超时时长（毫秒）
-#    block-when-exhausted: true #redis配置结束
-#    lettuce:
-#      pool:
-#        # 连接池中的最大空闲连接
-#        max-idle: 20
-#        # 连接池中的最小空闲连接
-#        min-idle: 20
-#        # 连接池最大连接数（使用负值表示没有限制）
-#        max-active: 200
-#        # 连接池最大阻塞等待时间（使用负值表示没有限制）
-#        max-wait: -1
+  data:
+    redis:
+      host: localhost
+      port: 6379             # Redis 端口
+      database: 0             # 使用的数据库索引（默认为0）
+      password:               # 密码（如果没有设置则为空）
+      timeout: 3000ms          # 连接超时时间
+      lettuce:
+        pool:
+          max-active: 8        # 连接池最大连接数
+          max-idle: 8          # 连接池最大空闲连接
+          min-idle: 0          # 连接池最小空闲连接
 
 # application.yml 或 application.properties
 langchain4j: