diff --git a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java index d4b65bc..81ac89b 100644 --- a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java +++ b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java @@ -289,7 +289,6 @@ public class MqttMessageHandler implements SmartLifecycle { Integer funcValue = null; boolean isAck = false; // 新增:标记是否需要执行自动关任务(全局可用) - boolean needAutoOffTask = false; // 第二步:设备回执处理逻辑(完全移除Redis写入) if (payloadObj.containsKey("suc") && payloadObj.containsKey("prop")) { @@ -323,8 +322,7 @@ public class MqttMessageHandler implements SmartLifecycle { autoOffSeconds = LIMIT_MAP.getOrDefault(funcType, k -> 0).apply(agriLimit); } // 新增:判断是否真的需要执行自动关任务(延迟秒数>0才是有效任务) - needAutoOffTask = autoOffSeconds > 0; - if (needAutoOffTask) { + if (autoOffSeconds > 0) { scheduleAutoOff(deviceId, funcType, autoOffSeconds); log.debug("【自动关任务】标记需要执行,deviceId={}, funcType={}, delay={}s", deviceId, funcType, autoOffSeconds); }