feat(mall): 代码优化

waynboot-admin-api/src/main/java/com/wayn/admin/api/controller/system/LoginController.java

@@ -68,7 +68,6 @@ public class LoginController {
         return success;
     }
 
-
     @GetMapping("/getRouters")
     public R getRouters(HttpServletRequest request) {
         R success = R.success();

waynboot-common/src/main/java/com/wayn/common/base/controller/CommonFileController.java

@@ -99,6 +99,7 @@ public class CommonFileController {
         try {
             // 1. 获取上传文件的保存路径
             String filePath = WaynConfig.getUploadDir();
+            log.info("file path is {}", filePath);
             // 2. 上传文件至服务器
             String fileName = FileUploadUtil.uploadFile(file, filePath);
             // 3. 返回文件访问路径

waynboot-data/waynboot-data-redis/src/main/java/com/wayn/data/redis/config/CacheConfig.java

@@ -32,8 +32,7 @@ public class CacheConfig implements CachingConfigurer {
         redisTemplate.setConnectionFactory(connectionFactory);
         redisTemplate.setKeySerializer(keySerializer());
         redisTemplate.setHashKeySerializer(keySerializer());
-        redisTemplate.setValueSerializer(valueSerializer());
+        redisTemplate.setDefaultSerializer(valueSerializer());
-        redisTemplate.setHashValueSerializer(valueSerializer());
         redisTemplate.afterPropertiesSet();
         return redisTemplate;
     }

waynboot-data/waynboot-data-redis/src/main/java/com/wayn/data/redis/manager/RedisCache.java

@@ -2,14 +2,12 @@ package com.wayn.data.redis.manager;
 
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.data.redis.core.HashOperations;
+import org.springframework.data.redis.core.*;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
-import org.springframework.data.redis.core.ZSetOperations;
 import org.springframework.data.redis.core.script.DefaultRedisScript;
 import org.springframework.data.redis.core.script.RedisScript;
 import org.springframework.stereotype.Component;
 
+import java.nio.charset.StandardCharsets;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
 
@@ -290,6 +288,29 @@ public class RedisCache {
         return (Long) redisTemplate.execute(redisScript, Collections.singletonList(key), orderSnIncrLimit);
     }
 
+    /**
+     * 获取匹配的所有key，使用scan避免阻塞
+     *
+     * @param pattern 匹配keys的规则
+     * @return 返回获取到的keys
+     */
+    public Set<String> scan(String pattern) {
+        return (Set<String>) redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
+            Set<String> keysTmp = new HashSet<>();
+            try (Cursor<byte[]> cursor = connection.keyCommands().scan(ScanOptions.scanOptions()
+                    .match(pattern)
+                    .count(1000).build())) {
+                while (cursor.hasNext()) {
+                    keysTmp.add(new String(cursor.next(), StandardCharsets.UTF_8));
+                }
+            } catch (Exception e) {
+                log.error(e.getMessage(), e);
+                throw new RuntimeException(e);
+            }
+            return keysTmp;
+        });
+    }
+
     /**
      * lua原子脚本
      */