root
/
agri
2
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

自动关上锁

feasure
xce 2026-01-19 00:51:07 +08:00
parent 3774c4dc4d
commit 05039238cc
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
View File

@ -561,6 +561,15 @@ public class MqttMessageHandler implements SmartLifecycle {
}
if (current != null && current == 1) {
// 新增：自动关也走分布式锁（避免与前端并发控制同一功能导致乱序/互相覆盖）
String lockKey = "lock:" + deviceId + ":" + funcType;
Boolean lockSuccess = stringRedisTemplate.opsForValue().setIfAbsent(
lockKey, "autooff", 15, TimeUnit.SECONDS
);
if (lockSuccess == null || !lockSuccess) {
log.info("【自动关任务】{}功能忙（锁占用），跳过自动关闭：deviceId={}, funcType={}", funcType, deviceId, funcType);
return;
}
JSONObject down = new JSONObject();
down.put(funcType, 0);