From 015a24c9eb5bdb97b31c447c32dd38ca7c5861fc Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Thu, 16 Nov 2023 14:39:58 +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