From 92f88ad4cdfab9ade03d163979d551fa34083781 Mon Sep 17 00:00:00 2001 From: wangwei_123 <1255324804@qq.com> Date: Fri, 26 Dec 2025 17:10:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=8B=E6=8C=81=E8=A1=A8=E6=89=B9=E5=A4=84?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module/mqtt/processor/BatchDeviceMessageProcessor.java | 10 ---------- .../src/main/resources/mapper/TdengineMapper.xml | 2 +- .../yudao-server/src/main/resources/application.yaml | 2 +- 3 files changed, 2 insertions(+), 12 deletions(-) diff --git a/cc-admin-master/yudao-module-hand-mqtt/src/main/java/cn/iocoder/yudao/module/mqtt/processor/BatchDeviceMessageProcessor.java b/cc-admin-master/yudao-module-hand-mqtt/src/main/java/cn/iocoder/yudao/module/mqtt/processor/BatchDeviceMessageProcessor.java index 7750784..11fcaff 100644 --- a/cc-admin-master/yudao-module-hand-mqtt/src/main/java/cn/iocoder/yudao/module/mqtt/processor/BatchDeviceMessageProcessor.java +++ b/cc-admin-master/yudao-module-hand-mqtt/src/main/java/cn/iocoder/yudao/module/mqtt/processor/BatchDeviceMessageProcessor.java @@ -31,20 +31,10 @@ import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; -/** - * 批量设备消息处理器 - *
- * 核心优化:
- * 1. 批量获取基础数据(租户信息、设备信息、报警规则)
- * 2. 内存中完成所有业务逻辑计算
- * 3. 批量执行所有数据库写操作
- */
@Slf4j
@Component
public class BatchDeviceMessageProcessor {
- private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
-
@Resource
private RedisUtil redisUtil;
@Resource
diff --git a/cc-admin-master/yudao-module-hand/src/main/resources/mapper/TdengineMapper.xml b/cc-admin-master/yudao-module-hand/src/main/resources/mapper/TdengineMapper.xml
index e85e79c..1642688 100644
--- a/cc-admin-master/yudao-module-hand/src/main/resources/mapper/TdengineMapper.xml
+++ b/cc-admin-master/yudao-module-hand/src/main/resources/mapper/TdengineMapper.xml
@@ -168,7 +168,7 @@
AND ts <= #{vo.endTime}