交易市场平台（供应商）

baqing-admin/src/main/java/com/ruoyi/web/modules/screen/mallstats/MallStatsOpenApiClientImpl.java

@@ -27,7 +27,9 @@ public class MallStatsOpenApiClientImpl implements MallStatsOpenApiClient
 {
     private static final Logger log = LoggerFactory.getLogger(MallStatsOpenApiClientImpl.class);
 
-    private static final String CACHE_KEY_PREFIX = "bigscreen:mallstats:overview:";
+    private static final String CACHE_KEY_PREFIX = "bigscreen:mallstats:overview:v2:";
+
+    private final ObjectMapper objectMapper = new ObjectMapper();
 
     private final MallStatsOpenProperties properties;
 
@@ -37,8 +39,6 @@ public class MallStatsOpenApiClientImpl implements MallStatsOpenApiClient
 
     private final RedisCache redisCache;
 
-    private final ObjectMapper objectMapper = new ObjectMapper();
-
     public MallStatsOpenApiClientImpl(
             MallStatsOpenProperties properties,
             @Qualifier("mallStatsRestTemplate") RestTemplate restTemplate,
@@ -59,7 +59,7 @@ public class MallStatsOpenApiClientImpl implements MallStatsOpenApiClient
             return null;
         }
         String cacheKey = CACHE_KEY_PREFIX + statYear;
-        MallStatsOverviewVo cached = redisCache.getCacheObject(cacheKey);
+        MallStatsOverviewVo cached = readCachedOverview(cacheKey);
         if (cached != null)
         {
             return cached;
@@ -70,7 +70,7 @@ public class MallStatsOpenApiClientImpl implements MallStatsOpenApiClient
             if (overview != null)
             {
                 int ttl = Math.max(1, properties.getCacheTtlMinutes());
-                redisCache.setCacheObject(cacheKey, overview, ttl, TimeUnit.MINUTES);
+                writeCachedOverview(cacheKey, overview, ttl);
             }
             return overview;
         }
@@ -81,6 +81,38 @@ public class MallStatsOpenApiClientImpl implements MallStatsOpenApiClient
         }
     }
 
+    private MallStatsOverviewVo readCachedOverview(String cacheKey)
+    {
+        try
+        {
+            String json = redisCache.getCacheObject(cacheKey);
+            if (StringUtils.isEmpty(json))
+            {
+                return null;
+            }
+            return objectMapper.readValue(json, MallStatsOverviewVo.class);
+        }
+        catch (Exception ex)
+        {
+            log.warn("商城统计缓存反序列化失败，将重新拉取 {}: {}", cacheKey, ex.getMessage());
+            redisCache.deleteObject(cacheKey);
+            return null;
+        }
+    }
+
+    private void writeCachedOverview(String cacheKey, MallStatsOverviewVo overview, int ttlMinutes)
+    {
+        try
+        {
+            String json = objectMapper.writeValueAsString(overview);
+            redisCache.setCacheObject(cacheKey, json, ttlMinutes, TimeUnit.MINUTES);
+        }
+        catch (Exception ex)
+        {
+            log.warn("商城统计缓存写入失败 {}: {}", cacheKey, ex.getMessage());
+        }
+    }
+
     private MallStatsOverviewVo requestOverview(int statYear) throws Exception
     {
         String base = trimTrailingSlash(properties.getBaseUrl());