code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-17 08:25:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

规则脚本不实时显示问题修复

Browse Source
This commit is contained in:
kerwincui
2024-04-26 09:53:19 +08:00
parent b143c30501
commit 653fe8bc1f
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
springboot/fastbee-server/mqtt-broker/src/main/java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java
View File

@@ -66,6 +66,11 @@ public class DataHandlerImpl implements IDataHandler {
input.setSlaveId(bo.getSlaveId());
List<ThingsModelSimpleItem> result = deviceService.reportDeviceThingsModelValue(input, bo.getType(), bo.isShadow());
//发送至前端
PushMessageBo messageBo = new PushMessageBo();
messageBo.setTopic(topicsUtils.buildTopic(bo.getProductId(), bo.getSerialNumber(), TopicType.WS_SERVICE_INVOKE));
messageBo.setMessage(JSON.toJSONString(result));
remoteManager.pushCommon(messageBo);
} catch (Exception e) {
log.error("接收属性数据，解析数据时异常 message={},e={}", e.getMessage(),e);