From 653fe8bc1f58d94deb987b70dbfd5dbe3bf99276 Mon Sep 17 00:00:00 2001
From: kerwincui <164770707@qq.com>
Date: Fri, 26 Apr 2024 09:53:19 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=84=E5=88=99=E8=84=9A=E6=9C=AC=E4=B8=8D?=
 =?UTF-8?q?=E5=AE=9E=E6=97=B6=E6=98=BE=E7=A4=BA=E9=97=AE=E9=A2=98=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/springboot/fastbee-server/mqtt-broker/src/main/java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java b/springboot/fastbee-server/mqtt-broker/src/main/java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java
index 6c287ec8..b6f2ff21 100644
--- a/springboot/fastbee-server/mqtt-broker/src/main/java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java
+++ b/springboot/fastbee-server/mqtt-broker/src/main/java/com/fastbee/mqtt/service/impl/DataHandlerImpl.java
@@ -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);