- * Licensed under the GNU LESSER GENERAL PUBLIC LICENSE 3.0; - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - *
- * http://www.gnu.org/licenses/lgpl.html - *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package top.continew.starter.auth.satoken.autoconfigure.dao;
-
-import cn.dev33.satoken.dao.SaTokenDao;
-import cn.dev33.satoken.util.SaFoxUtil;
-import top.continew.starter.cache.redisson.util.RedisUtils;
-
-import java.time.Duration;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-/**
- * 默认 Sa-Token 持久层 Redis 实现（参考：Sa-Token/sa-token-plugin/sa-token-dao-redisx/SaTokenDaoOfRedis.java）
- *
- * @author Charles7c
- * @since 1.0.0
- */
-public class SaTokenDaoRedisDefaultImpl implements SaTokenDao {
-
- @Override
- public String get(String key) {
- return RedisUtils.get(key);
- }
-
- @Override
- public void set(String key, String value, long timeout) {
- if (timeout == 0 || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) {
- return;
- }
- // 判断是否为永不过期
- if (timeout == SaTokenDao.NEVER_EXPIRE) {
- RedisUtils.set(key, value);
- } else {
- RedisUtils.set(key, value, Duration.ofSeconds(timeout));
- }
- }
-
- @Override
- public void update(String key, String value) {
- long expire = getTimeout(key);
- // -2：无此键
- if (expire == SaTokenDao.NOT_VALUE_EXPIRE) {
- return;
- }
- this.set(key, value, expire);
- }
-
- @Override
- public void delete(String key) {
- RedisUtils.delete(key);
- }
-
- @Override
- public long getTimeout(String key) {
- long timeout = RedisUtils.getTimeToLive(key);
- return timeout < 0 ? timeout : timeout / 1000;
- }
-
- @Override
- public void updateTimeout(String key, long timeout) {
- // 判断是否想要设置为永久
- if (timeout == SaTokenDao.NEVER_EXPIRE) {
- long expire = getTimeout(key);
- // 如果其已经被设置为永久，则不作任何处理。如果尚未被设置为永久，那么再次 set 一次
- if (expire != SaTokenDao.NEVER_EXPIRE) {
- this.set(key, this.get(key), timeout);
- }
- return;
- }
- RedisUtils.expire(key, Duration.ofSeconds(timeout));
- }
-
- @Override
- public Object getObject(String key) {
- return RedisUtils.get(key);
- }
-
- @Override
- public void setObject(String key, Object object, long timeout) {
- if (0 == timeout || timeout <= SaTokenDao.NOT_VALUE_EXPIRE) {
- return;
- }
- // 判断是否为永不过期
- if (timeout == SaTokenDao.NEVER_EXPIRE) {
- RedisUtils.set(key, object);
- } else {
- RedisUtils.set(key, object, Duration.ofSeconds(timeout));
- }
- }
-
- @Override
- public void updateObject(String key, Object object) {
- long expire = getObjectTimeout(key);
- // -2：无此键
- if (expire == SaTokenDao.NOT_VALUE_EXPIRE) {
- return;
- }
- this.setObject(key, object, expire);
- }
-
- @Override
- public void deleteObject(String key) {
- RedisUtils.delete(key);
- }
-
- @Override
- public long getObjectTimeout(String key) {
- return this.getTimeout(key);
- }
-
- @Override
- public void updateObjectTimeout(String key, long timeout) {
- // 判断是否想要设置为永久
- if (timeout == SaTokenDao.NEVER_EXPIRE) {
- long expire = getObjectTimeout(key);
- // 如果其已经被设置为永久，则不作任何处理。如果尚未被设置为永久，那么再次 set 一次
- if (expire != SaTokenDao.NEVER_EXPIRE) {
- this.setObject(key, this.getObject(key), timeout);
- }
- return;
- }
- RedisUtils.expire(key, Duration.ofSeconds(timeout));
- }
-
- @Override
- public List