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 {