| | |
| | | |
| | | import cn.dev33.satoken.dao.SaTokenDao; |
| | | import cn.dev33.satoken.util.SaFoxUtil; |
| | | import com.ruoyi.common.utils.RedisUtils; |
| | | import com.ruoyi.common.utils.redis.RedisUtils; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.time.Duration; |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.List; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | /** |
| | | * Sa-Token持久层接口(使用框架自带RedisUtils实现 协议统一) |
| | |
| | | */ |
| | | @Override |
| | | public void set(String key, String value, long timeout) { |
| | | if(timeout == 0 || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | if (timeout == 0 || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | return; |
| | | } |
| | | // 判断是否为永不过期 |
| | | if(timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | if (timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | RedisUtils.setCacheObject(key, value); |
| | | } else { |
| | | RedisUtils.setCacheObject(key, value, timeout, TimeUnit.SECONDS); |
| | | RedisUtils.setCacheObject(key, value, Duration.ofSeconds(timeout)); |
| | | } |
| | | } |
| | | |
| | |
| | | public void update(String key, String value) { |
| | | long expire = getTimeout(key); |
| | | // -2 = 无此键 |
| | | if(expire == SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | if (expire == SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | return; |
| | | } |
| | | this.set(key, value, expire); |
| | |
| | | */ |
| | | @Override |
| | | public long getTimeout(String key) { |
| | | return RedisUtils.getTimeToLive(key) / 1000; |
| | | long timeout = RedisUtils.getTimeToLive(key); |
| | | return timeout < 0 ? timeout : timeout / 1000; |
| | | } |
| | | |
| | | /** |
| | |
| | | @Override |
| | | public void updateTimeout(String key, long timeout) { |
| | | // 判断是否想要设置为永久 |
| | | if(timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | if (timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | long expire = getTimeout(key); |
| | | if(expire == SaTokenDao.NEVER_EXPIRE) { |
| | | if (expire == SaTokenDao.NEVER_EXPIRE) { |
| | | // 如果其已经被设置为永久,则不作任何处理 |
| | | } else { |
| | | // 如果尚未被设置为永久,那么再次set一次 |
| | |
| | | } |
| | | return; |
| | | } |
| | | RedisUtils.expire(key, timeout, TimeUnit.SECONDS); |
| | | RedisUtils.expire(key, Duration.ofSeconds(timeout)); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | public void setObject(String key, Object object, long timeout) { |
| | | if(timeout == 0 || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | if (timeout == 0 || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | return; |
| | | } |
| | | // 判断是否为永不过期 |
| | | if(timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | if (timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | RedisUtils.setCacheObject(key, object); |
| | | } else { |
| | | RedisUtils.setCacheObject(key, object, timeout, TimeUnit.SECONDS); |
| | | RedisUtils.setCacheObject(key, object, Duration.ofSeconds(timeout)); |
| | | } |
| | | } |
| | | |
| | |
| | | public void updateObject(String key, Object object) { |
| | | long expire = getObjectTimeout(key); |
| | | // -2 = 无此键 |
| | | if(expire == SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | if (expire == SaTokenDao.NOT_VALUE_EXPIRE) { |
| | | return; |
| | | } |
| | | this.setObject(key, object, expire); |
| | |
| | | */ |
| | | @Override |
| | | public long getObjectTimeout(String key) { |
| | | return RedisUtils.getTimeToLive(key) / 1000; |
| | | long timeout = RedisUtils.getTimeToLive(key); |
| | | return timeout < 0 ? timeout : timeout / 1000; |
| | | } |
| | | |
| | | /** |
| | |
| | | @Override |
| | | public void updateObjectTimeout(String key, long timeout) { |
| | | // 判断是否想要设置为永久 |
| | | if(timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | if (timeout == SaTokenDao.NEVER_EXPIRE) { |
| | | long expire = getObjectTimeout(key); |
| | | if(expire == SaTokenDao.NEVER_EXPIRE) { |
| | | if (expire == SaTokenDao.NEVER_EXPIRE) { |
| | | // 如果其已经被设置为永久,则不作任何处理 |
| | | } else { |
| | | // 如果尚未被设置为永久,那么再次set一次 |
| | |
| | | } |
| | | return; |
| | | } |
| | | RedisUtils.expire(key, timeout, TimeUnit.SECONDS); |
| | | RedisUtils.expire(key, Duration.ofSeconds(timeout)); |
| | | } |
| | | |
| | | |
| | |
| | | * 搜索数据 |
| | | */ |
| | | @Override |
| | | public List<String> searchData(String prefix, String keyword, int start, int size) { |
| | | public List<String> searchData(String prefix, String keyword, int start, int size, boolean sortType) { |
| | | Collection<String> keys = RedisUtils.keys(prefix + "*" + keyword + "*"); |
| | | List<String> list = new ArrayList<>(keys); |
| | | return SaFoxUtil.searchList(list, start, size); |
| | | return SaFoxUtil.searchList(list, start, size, sortType); |
| | | } |
| | | |
| | | } |