Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
xy
2024-09-14 13:39:41 +08:00
parent 848cc9c7de
commit b2da20cf62
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/RemoveInfoUtils.java
View File

@@ -11,7 +11,6 @@ import org.springframework.stereotype.Component;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.List; import java.util.List;
import java.util.Objects;
/** /**
* 类的介绍： * 类的介绍：
@@ -42,14 +41,14 @@ public class RemoveInfoUtils {
public void retryEventInfo(String nDid, String fileName) { 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; int retryTimes = retryObject != null ? Integer.parseInt(retryObject.toString()) : 0;
// 删除相关的 Redis 键 // 删除相关的 Redis 键
deleteRelatedKeys(nDid, fileName); deleteRelatedKeys(nDid, fileName);
// 处理重试逻辑 // 处理重试逻辑
if (retryTimes < 3) { if (retryTimes < 3) {
// 增加重试次数并保存 // 增加重试次数并保存
redisUtil.saveByKey("retryEvent:" + nDid, retryTimes + 1); redisUtil.saveByKey(("retryEvent:" + nDid + fileName), retryTimes + 1);
// 重排文件列表 // 重排文件列表
updateFileList(nDid, fileName); updateFileList(nDid, fileName);
} else { } else {