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}