add news memory cache

Author: YukiRinLL

.idea/workspace.xml

@@ -223,6 +223,11 @@
 <!--            <groupId>org.springframework.boot</groupId>-->
 <!--            <artifactId>spring-boot-starter-data-redis</artifactId>-->
 <!--        </dependency>-->
+        <dependency>
+            <groupId>javax.annotation</groupId>
+            <artifactId>javax.annotation-api</artifactId>
+            <version>1.3.2</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.data</groupId>
             <artifactId>spring-data-redis</artifactId>

pom.xml

@@ -9,6 +9,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import javax.annotation.PostConstruct;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -39,6 +40,38 @@ public class FF14GlobalNewsScheduler {
     @Value("${napcat.default-group-id}")
     private String defaultGroupId;
 
+    @PostConstruct
+    public void initCache() {
+        logger.info("初始化FF14国际服新闻缓存");
+        try {
+            // 尝试从Redis读取缓存
+            try {
+                Object cachedIdsObj = redisUtil.get(FF14_GLOBAL_NEWS_CACHE_KEY);
+                if (cachedIdsObj instanceof List) {
+                    inMemoryCache = (List<String>) cachedIdsObj;
+                    logger.info("从Redis加载缓存成功，共 {} 条国际服新闻ID", inMemoryCache.size());
+                    return;
+                }
+            } catch (Exception e) {
+                logger.warn("从Redis读取缓存失败: {}", e.getMessage());
+            }
+
+            // 如果Redis不可用，从新闻源获取最新新闻列表作为初始缓存
+            logger.info("Redis不可用，从新闻源获取初始缓存");
+            List<FF14GlobalNewsUtils.NewsItem> newsList = ff14GlobalNewsUtils.fetchGlobalNews();
+            if (!newsList.isEmpty()) {
+                inMemoryCache = newsList.stream()
+                    .map(FF14GlobalNewsUtils.NewsItem::getId)
+                    .collect(Collectors.toList());
+                logger.info("从新闻源加载初始缓存成功，共 {} 条国际服新闻ID", inMemoryCache.size());
+            } else {
+                logger.warn("从新闻源获取初始缓存失败，使用空缓存");
+            }
+        } catch (Exception e) {
+            logger.error("初始化缓存失败", e);
+        }
+    }
+
     @Scheduled(fixedRate = 5 * 60 * 1000)
     public void fetchAndSendFF14GlobalNews() {
         logger.info("开始获取FF14国际服新闻列表");
@@ -112,7 +145,7 @@ private void sendNewsToGroup(List<FF14GlobalNewsUtils.NewsItem> newsList) {
                     message.append(news.getLinkUrl());
                 }
 
-                napCatQQUtil.sendGroupMessage(defaultGroupId, message.toString());
+                napCatQQUtil.sendGroupMessage(phantomGroupId, message.toString());
                 logger.info("已发送FF14国际服新闻: {}", news.getTitle());
 
                 Thread.sleep(1000);

src/main/java/com/phantoms/phantomsbackend/service/scheduler/FF14GlobalNewsScheduler.java

@@ -9,6 +9,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import javax.annotation.PostConstruct;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -39,6 +40,38 @@ public class FF14NewsScheduler {
     @Value("${napcat.default-group-id}")
     private String defaultGroupId;
 
+    @PostConstruct
+    public void initCache() {
+        logger.info("初始化FF14新闻缓存");
+        try {
+            // 尝试从Redis读取缓存
+            try {
+                Object cachedIdsObj = redisUtil.get(FF14_NEWS_CACHE_KEY);
+                if (cachedIdsObj instanceof List) {
+                    inMemoryCache = (List<String>) cachedIdsObj;
+                    logger.info("从Redis加载缓存成功，共 {} 条新闻ID", inMemoryCache.size());
+                    return;
+                }
+            } catch (Exception e) {
+                logger.warn("从Redis读取缓存失败: {}", e.getMessage());
+            }
+
+            // 如果Redis不可用，从新闻源获取最新新闻列表作为初始缓存
+            logger.info("Redis不可用，从新闻源获取初始缓存");
+            List<FF14NewsUtils.NewsItem> newsList = ff14NewsUtils.fetchNewsList();
+            if (!newsList.isEmpty()) {
+                inMemoryCache = newsList.stream()
+                    .map(FF14NewsUtils.NewsItem::getId)
+                    .collect(Collectors.toList());
+                logger.info("从新闻源加载初始缓存成功，共 {} 条新闻ID", inMemoryCache.size());
+            } else {
+                logger.warn("从新闻源获取初始缓存失败，使用空缓存");
+            }
+        } catch (Exception e) {
+            logger.error("初始化缓存失败", e);
+        }
+    }
+
     @Scheduled(fixedRate = 5 * 60 * 1000)
     public void fetchAndSendFF14News() {
         logger.info("开始获取FF14新闻列表");
@@ -111,7 +144,7 @@ private void sendNewsToGroup(List<FF14NewsUtils.NewsItem> newsList) {
                     message.append(news.getLinkUrl());
                 }
 
-                napCatQQUtil.sendGroupMessage(defaultGroupId, message.toString());
+                napCatQQUtil.sendGroupMessage(phantomGroupId, message.toString());
                 logger.info("已发送新闻: {}", news.getTitle());
 
                 Thread.sleep(1000);