From a0741df5a2cff792740d7d31f7101ba2339ba3ec Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Tue, 09 Dec 2025 15:30:36 +0800
Subject: [PATCH] 2025-12-09 zwy 增加机场飞行器摄像头切换状态通道，增加LiveStatusTwoReceiver路由
---
ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/PropertySetReplyHandler.java | 25 +++++++++++++++++++++++++
1 files changed, 25 insertions(+), 0 deletions(-)
diff --git a/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/PropertySetReplyHandler.java b/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/PropertySetReplyHandler.java
index d8f3726..4bb5a40 100644
--- a/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/PropertySetReplyHandler.java
+++ b/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/PropertySetReplyHandler.java
@@ -3,10 +3,13 @@
import com.ard.sample.component.mqtt.model.Chan;
import com.ard.sample.component.mqtt.model.ChannelName;
import com.ard.sample.component.mqtt.model.CommonTopicReceiver;
+import com.ard.sample.component.websocket.enums.MessageType;
+import com.ard.sample.component.websocket.handler.DockWebSocketHandler;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.annotation.ServiceActivator;
+import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;
@@ -23,6 +26,9 @@
@Autowired
private ObjectMapper mapper;
+ @Autowired
+ private DockWebSocketHandler _dockWebSocketHandler;
+
/**
* Handle the reply message from the pilot side to the on-demand video.
* @param message reply message
@@ -30,11 +36,30 @@
*/
@ServiceActivator(inputChannel = ChannelName.INBOUND_PROPERTY_SET_REPLY)
public void serviceReply(Message<?> message) throws IOException {
+ // 解析消息的主题，从中提取设备序列号等信息
+ String topic = message.getHeaders().get(MqttHeaders.RECEIVED_TOPIC).toString();
+ // thing/product/7CTDLCE00A1UPE/property/set_reply
+ String[] parts = topic.split("/");
+ // 目标子串是分割后数组的第3个元素（索引2）
+ String deviceSn = parts.length > 2 ? parts[2] : ""; // 加判断避免数组越界
+
byte[] payload = (byte[])message.getPayload();
CommonTopicReceiver receiver = mapper.readValue(payload, new TypeReference<CommonTopicReceiver>() {});
Chan<CommonTopicReceiver<?>> chan = Chan.getInstance();
// Put the message to the chan object.
chan.put(receiver);
+
+ receiver.setGateway(deviceSn);
+ receiver.setType(MessageType.CONTROL.getType());
+// receiver.setMethod();
+
+ // 设备属性设置后的处理逻辑
+
+ // WebSocket 接口，发给前端
+ String dockControl="";
+ dockControl=mapper.writeValueAsString(receiver);
+
+ _dockWebSocketHandler.sendMessageToSubscribers(deviceSn, MessageType.CONTROL.getType(),dockControl);
}
}
--
Gitblit v1.9.3