Merge remote-tracking branch 'origin/master'

cash-common/cash-common-api-config/src/main/java/com/czg/config/CacheConfig.java

@@ -0,0 +1,43 @@
+package com.czg.config;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.time.Duration;
+
+
+/**
+ * @author GYJoker
+ */
+@Configuration
+@EnableCaching
+public class CacheConfig {
+
+    @Bean(name = "redisCacheManager")
+    @Primary
+    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
+        // 使用自定义的 FastJson2RedisSerializer 进行值的序列化
+        FastJson2RedisSerializer<Object> fastJson2RedisSerializer = new FastJson2RedisSerializer<>(Object.class);
+
+        // 配置 Redis 缓存的默认配置
+        RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
+                // 设置键的序列化方式
+                .serializeKeysWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
+                // 设置值的序列化方式，使用 Fastjson2 序列化
+                .serializeValuesWith(org.springframework.data.redis.serializer.RedisSerializationContext.SerializationPair.fromSerializer(fastJson2RedisSerializer))
+                // 设置缓存过期时间为 30 分钟
+                .entryTtl(Duration.ofMinutes(30));
+
+        // 创建 Redis 缓存管理器
+        return RedisCacheManager.builder(redisConnectionFactory)
+                .cacheDefaults(cacheConfiguration)
+                .build();
+    }
+}

cash-common/cash-common-api-config/src/main/java/com/czg/config/CorsFilter.java

@@ -0,0 +1,28 @@
+package com.czg.config;
+
+import jakarta.servlet.*;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.IOException;
+
+/**
+ * @author GYJoker
+ */
+@Configuration
+public class CorsFilter implements Filter {
+    @Override
+    public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain)
+            throws IOException, ServletException {
+        HttpServletResponse response = (HttpServletResponse) resp;
+        HttpServletRequest reqs = (HttpServletRequest) req;
+        String curOrigin = reqs.getHeader("Origin");
+        response.setHeader("Access-Control-Allow-Origin", curOrigin == null ? "true" : curOrigin);
+        response.setHeader("Access-Control-Allow-Methods", "*");
+        response.setHeader("Access-Control-Max-Age", "3600");
+        response.setHeader("Access-Control-Allow-Headers", "token");
+        response.setHeader("Access-Control-Allow-Credentials", "true");
+        chain.doFilter(req, resp);
+    }
+}

cash-common/cash-common-api-config/src/main/java/com/czg/exception/CzgControllerAdvice.java

@@ -0,0 +1,54 @@
+package com.czg.exception;
+
+import cn.dev33.satoken.exception.NotPermissionException;
+import com.czg.resp.CzgRespCode;
+import com.czg.resp.CzgResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.support.DefaultMessageSourceResolvable;
+import org.springframework.http.HttpStatus;
+import org.springframework.validation.ObjectError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * @author GYJoker
+ */
+@RestControllerAdvice
+@Slf4j
+public class CzgControllerAdvice {
+    @ResponseBody
+    @ExceptionHandler(value = Exception.class)
+    @ResponseStatus(HttpStatus.OK)
+    public CzgResult<Object> errorHandler(Exception ex) {
+        setErrorLog(ex);
+        return CzgResult.failure(CzgRespCode.SYSTEM_ERROR);
+    }
+
+    @ResponseBody
+    @ExceptionHandler(value = NotPermissionException.class)
+    @ResponseStatus(HttpStatus.OK)
+    public CzgResult<Object> notPermissionErrorHandler(NotPermissionException ex) {
+        setErrorLog(ex);
+        return CzgResult.failure(CzgRespCode.UN_PERMISSION);
+    }
+
+    @ResponseBody
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    @ResponseStatus(HttpStatus.OK)
+    public CzgResult<Object> requestParamException(MethodArgumentNotValidException ex) {
+        setErrorLog(ex);
+        List<ObjectError> allErrors = ex.getBindingResult().getAllErrors();
+        String message = allErrors.stream().map(DefaultMessageSourceResolvable::getDefaultMessage).collect(Collectors.joining(";"));
+        return CzgResult.failure(CzgRespCode.PARAM_ERROR.getCode(), message);
+    }
+
+    private void setErrorLog(Exception ex) {
+        log.error(ex.getMessage());
+    }
+}