From bee596030bf9f9d395d65fbe17be57c52fa0af04 Mon Sep 17 00:00:00 2001
From: shenyijian <1178253012@qq.com>
Date: Tue, 21 Nov 2023 22:06:00 +0800
Subject: [PATCH] 无人机 -统计飞行、航线列表新增查询条件
---
src/main/java/com/dji/sample/component/mqtt/handler/ServicesReplyHandler.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/dji/sample/component/mqtt/handler/ServicesReplyHandler.java b/src/main/java/com/dji/sample/component/mqtt/handler/ServicesReplyHandler.java
index c0115ab..8d8030d 100644
--- a/src/main/java/com/dji/sample/component/mqtt/handler/ServicesReplyHandler.java
+++ b/src/main/java/com/dji/sample/component/mqtt/handler/ServicesReplyHandler.java
@@ -36,13 +36,16 @@
byte[] payload = (byte[])message.getPayload();
CommonTopicReceiver receiver = mapper.readValue(payload, new TypeReference<CommonTopicReceiver>() {});
+ ServiceReply reply;
if (LogsFileMethodEnum.FILE_UPLOAD_LIST.getMethod().equals(receiver.getMethod())) {
LogsFileUploadList list = mapper.convertValue(receiver.getData(), new TypeReference<LogsFileUploadList>() {});
- receiver.setData(list);
+ reply = new ServiceReply();
+ reply.setResult(list.getResult());
+ reply.setOutput(list.getFiles());
} else {
- ServiceReply reply = mapper.convertValue(receiver.getData(), new TypeReference<ServiceReply>() {});
- receiver.setData(reply);
+ reply = mapper.convertValue(receiver.getData(), new TypeReference<ServiceReply>() {});
}
+ receiver.setData(reply);
Chan<CommonTopicReceiver<?>> chan = Chan.getInstance();
// Put the message to the chan object.
chan.put(receiver);
--
Gitblit v1.9.3