bug修复

src/main/java/com/project/interaction/utils/NotifyUtil.java

@@ -11,6 +11,7 @@ import org.redisson.api.RedissonClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -31,30 +32,34 @@ public class NotifyUtil {
             "01231011386731976125",
             "590204300932000212"
     );
-    // 防重复缓存key前缀
+    // 防重复缓存 key 前缀
     private static final String WARN_LOCK_KEY_PREFIX = "question:gen:warn:lock:";
-    // 重复发送间隔：1小时（3600秒）
+    // 重复发送间隔：1 小时（3600 秒）
     private static final long WARN_LOCK_EXPIRE_SECONDS = 3600L;
 
 
     public void notify(Long taskId,Long clusterId) {
 
-        // 构建Redis缓存key（按taskId唯一）
+        // 构建 Redis 缓存 key（按 taskId 唯一）
         String cacheKey = WARN_LOCK_KEY_PREFIX + taskId;
 
-        // 核心逻辑：检查Redis缓存，存在则直接返回（1小时内已发送过）
+        // 核心逻辑：使用原子操作 setIfAbsent 防止并发重复发送
-        boolean isCached = redissonClient.getBucket(cacheKey).isExists();
+        // 返回 true 表示成功设置（之前不存在），返回 false 表示 1 小时内已发送过
-        if (isCached) {
+        boolean acquired = redissonClient.getBucket(cacheKey).setIfAbsent(
+                "SEND_SUCCESS",
+                Duration.ofSeconds(WARN_LOCK_EXPIRE_SECONDS)
+        );
+        if (!acquired) {
+            log.debug(">>> [算法生题 API 调用失败通知] 任务{}在 1 小时内已发送过，跳过", taskId);
             return;
         }
 
-
         try {
             String now = DateUtil.now();
-            String markdown = String.format("### 【告警】算法生题API调用失败通知 \n\n") +
+            String markdown = String.format("### 【告警】算法生题 API 调用失败通知 \n\n") +
                     String.format("## 核心信息\n") +
-                    String.format("- 考试任务ID：%d\n", taskId) +
+                    String.format("- 考试任务 ID：%d\n", taskId) +
-                    String.format("- 知识点簇ID：%d\n", clusterId) +
+                    String.format("- 知识点簇 ID：%d\n", clusterId) +
                     String.format("- 当前时间：%s\n\n", now) +
                     String.format("## 异常说明\n") +
                     String.format("算法服务生成题目时调用失败，可能导致考试题目不完整或无法正常作答，请尽快排查以下问题：\n") +
@@ -63,21 +68,20 @@ public class NotifyUtil {
                     .agentId(dtService.getDtConfigStorage().getAgentId())
                     .userIds(WARN_USER_LIST)
                     .msg(DtMessage.MARKDOWN()
-                            .content("算法生题API调用失败通知")
+                            .content("算法生题 API 调用失败通知")
                             .text(markdown)
                             .build())
                     .build();
             DtCorpConversationMsgSendResult result = dtService.getCorpConversationMsgService().send(corpConversationMessage);
             if (result.getErrCode() == 0) {
-                log.info(">>> [算法生题API调用失败通知] 成功发送通知 ,考试任务ID：{} ,知识点簇ID：{}", taskId, clusterId);
+                log.info(">>> [算法生题 API 调用失败通知] 成功发送通知，考试任务 ID：{} ,知识点簇 ID：{}", taskId, clusterId);
             } else {
-                log.error(">>> [算法生题API调用失败通知] 发送失败.考试任务ID：{} ,知识点簇ID：{}, 错误码: {}, 错误信息: {}", taskId, clusterId,
+                log.error(">>> [算法生题 API 调用失败通知] 发送失败，考试任务 ID：{} ,知识点簇 ID：{}, 错误码：{}, 错误信息：{}", taskId, clusterId,
                         result.getErrCode(), result.getErrMsg());
             }
-            redissonClient.getBucket(cacheKey).set("SEND_SUCCESS", WARN_LOCK_EXPIRE_SECONDS, TimeUnit.SECONDS);
 
         } catch (Exception e) {
-            log.error(">>> [算法生题API调用失败通知] 钉钉接口调用异常, 考试任务ID：{} ,知识点簇ID：{}, 原因: {}",taskId, clusterId, e.getMessage());
+            log.error(">>> [算法生题 API 调用失败通知] 钉钉接口调用异常，考试任务 ID：{} ,知识点簇 ID：{}, 原因：{}",taskId, clusterId, e.getMessage());
         }
     }
 }