From b2da20cf62b344c60f82adbb5a57376f1eccfec3 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Sat, 14 Sep 2024 13:39:41 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java
index 5b6a304..b940de3 100644
--- a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java
+++ b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java
@@ -11,7 +11,6 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.List;
-import java.util.Objects;
 
 /**
  * 类的介绍：
@@ -42,14 +41,14 @@ public class RemoveInfoUtils {
 
     public void retryEventInfo(String nDid, String fileName) {
         // 尝试获取重试次数
-        Object retryObject = redisUtil.getObjectByKey("retryEvent:" + nDid);
+        Object retryObject = redisUtil.getObjectByKey("retryEvent:" + nDid + fileName);
         int retryTimes = retryObject != null ? Integer.parseInt(retryObject.toString()) : 0;
         // 删除相关的 Redis 键
         deleteRelatedKeys(nDid, fileName);
         // 处理重试逻辑
         if (retryTimes < 3) {
             // 增加重试次数并保存
-            redisUtil.saveByKey("retryEvent:" + nDid, retryTimes + 1);
+            redisUtil.saveByKey(("retryEvent:" + nDid + fileName), retryTimes + 1);
             // 重排文件列表
             updateFileList(nDid, fileName);
         } else {