From 98d61ad472df848bba78a45b80126687d5ad7529 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期六, 12 十月 2024 18:30:02 +0800
Subject: [PATCH] 代码提交
---
ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
index e1aebbd..45edd51 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
@@ -195,7 +195,8 @@
if (StringUtils.isEmpty(value)) {
value = "," + serviceSubtask2.getId().toString() + ",";
} else {
- value = value + "," + serviceSubtask2.getId().toString() + ",";
+ if (!value.contains("," + serviceSubtask2.getId().toString()))
+ value = value + "," + serviceSubtask2.getId().toString() + ",";
}
}
redisCache.setCacheObject("cache-0", value);
@@ -325,7 +326,7 @@
if ((Boolean) map.get("succ") == false) {
serviceSubtaskRecord.setResult("error");
}
- serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
+ serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
serviceSubtaskRecordService.insertServiceSubtaskRecord(serviceSubtaskRecord);
} catch (Exception e) {
String guid = UUID.randomUUID().toString();
@@ -335,7 +336,7 @@
serviceSubtask.setGuid(guid);
serviceSubtask.setSendstate(5L);
serviceSubtask.setFinishtime(new Date());
- serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
+ serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
}
}
}
--
Gitblit v1.9.3