yuhaiming/water
Template
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: MQTT 排程完成回调移除无效的 LoginHelper.getUserId

Browse Source 
MQTT 消息处理线程没有登录上下文，LoginHelper.getUserId() 取不到值
还会覆盖 buildWateringLog 里基于设备查询设置的 userId

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
yuhaiming
2026-06-23 15:38:19 +08:00
parent 228a01843f
commit 0f165b50ff
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
water-modules/water-app/src/main/java/org/dromara/app/handler/ScheduleFinishHandler.java
View File

@@ -12,7 +12,6 @@ import org.dromara.app.service.IAppDeviceService;
import org.dromara.app.service.IAppWateringLogService; import org.dromara.app.service.IAppWateringLogService;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.json.utils.JsonUtils; import org.dromara.common.json.utils.JsonUtils;
import org.dromara.common.satoken.utils.LoginHelper;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.text.ParseException; import java.text.ParseException;
@@ -54,7 +53,6 @@ public class ScheduleFinishHandler implements MqttTopicHandler {
} }
Map<String, Object> dto = JsonUtils.parseObject(payload, Map.class); Map<String, Object> dto = JsonUtils.parseObject(payload, Map.class);
AppWateringLogBo logBo = buildWateringLog(deviceNo, dto); AppWateringLogBo logBo = buildWateringLog(deviceNo, dto);
logBo.setUserId(LoginHelper.getUserId());
appWateringLogService.confirmScheduleLog(logBo); appWateringLogService.confirmScheduleLog(logBo);
log.info("[MQTT] 浇水排程上报已保存 时间={} 设备编号={} 消息体={}", HandlerLogTime.now(), deviceNo, payload); log.info("[MQTT] 浇水排程上报已保存 时间={} 设备编号={} 消息体={}", HandlerLogTime.now(), deviceNo, payload);
} catch (Exception e) { } catch (Exception e) {