From 87cba28b3dc8389e1df61f3ba7d986b09fd89db0 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Sat, 02 Nov 2024 11:26:21 +0800
Subject: [PATCH] 增加:无人机设置接口

---
 ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java |   48 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 48 insertions(+), 0 deletions(-)

diff --git a/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java b/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
index f50c111..8c16ec9 100644
--- a/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
+++ b/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
@@ -19,6 +19,9 @@
 import com.ard.tianyu.model.dto.converter.UavTelemetryDataConverter;
 import com.ard.tianyu.model.dto.converter.wayline.PlanLineDataConverter;
 import com.ard.tianyu.model.dto.manual.*;
+import com.ard.tianyu.model.dto.settings.ReturnHeightSettingDTO;
+import com.ard.tianyu.model.dto.settings.ReturnPointSettingDTO;
+import com.ard.tianyu.model.dto.settings.VideoStreamSettingDTO;
 import com.ard.tianyu.model.dto.signal.SignalInfo;
 import com.ard.tianyu.model.dto.speaker.*;
 import com.ard.tianyu.model.dto.state.UavState;
@@ -39,6 +42,7 @@
 import com.ard.tianyu.netty.command.real.UavStateCmd;
 import com.ard.tianyu.netty.command.real.UavTelemetryDataCmd;
 import com.ard.tianyu.netty.command.register.*;
+import com.ard.tianyu.netty.command.settings.*;
 import com.ard.tianyu.netty.command.speaker.*;
 import com.ard.tianyu.netty.command.wayline.*;
 import com.ard.tianyu.netty.handler.ErrorCodeEnum;
@@ -146,6 +150,33 @@
     public Boolean updateBoxSettings(BoxSettingsDTO boxSettingsDTO) {
         TyHttpCommonReceiver<?> result = tyClient.updateBoxSettings(boxSettingsDTO, tyConfiguration.getAccessToken().convertFromDTO());
         return result.getState() == 1;
+    }
+
+    /**
+     * 设置返航高度
+     */
+    @Override
+    public void updateReturnHeight(ReturnHeightSettingDTO returnHeightSettingDTO) {
+        ReturnHeightSettingCmd returnHeightSettingCmd = new ReturnHeightSettingCmd(returnHeightSettingDTO);
+        this.sendMessage(tyConfiguration.getIpPort(), returnHeightSettingCmd);
+    }
+
+    /**
+     * 设置返航点
+     */
+    @Override
+    public void updateReturnPoint(ReturnPointSettingDTO returnPointSettingDTO) {
+        ReturnPointSettingCmd returnPointSettingCmd = new ReturnPointSettingCmd(returnPointSettingDTO);
+        this.sendMessage(tyConfiguration.getIpPort(), returnPointSettingCmd);
+    }
+
+    /**
+     * 设置视频码流
+     */
+    @Override
+    public void updateVideoStream(VideoStreamSettingDTO videoStreamSettingDTO) {
+        VideoStreamSettingCmd videoStreamSettingCmd = new VideoStreamSettingCmd(videoStreamSettingDTO);
+        this.sendMessage(tyConfiguration.getIpPort(), videoStreamSettingCmd);
     }
 
     /**
@@ -704,6 +735,23 @@
                     WayLineEndReplyCmd wayLineEndReplyCmd = (WayLineEndReplyCmd) tyCommand;
                     logPrint("结束航线", wayLineEndReplyCmd.getResult(), wayLineEndReplyCmd.getErrorCode());
                 }
+                //设置返航高度回复
+                if (tyCommand instanceof ReturnHeightSettingReplyCmd) {
+                    ReturnHeightSettingReplyCmd returnHeightSettingReplyCmd = (ReturnHeightSettingReplyCmd) tyCommand;
+                    logPrint("设置返航高度", returnHeightSettingReplyCmd.getResult(), returnHeightSettingReplyCmd.getErrorCode());
+                }
+                //设置返航点回复
+                if (tyCommand instanceof ReturnPointSettingReplyCmd) {
+                    ReturnPointSettingReplyCmd returnPointSettingReplyCmd = (ReturnPointSettingReplyCmd) tyCommand;
+                    logPrint("设置返航点", returnPointSettingReplyCmd.getResult(), returnPointSettingReplyCmd.getErrorCode());
+                }
+                break;
+            case (byte) 0xD2:
+                //设置视频码流回复
+                if (tyCommand instanceof VideoStreamSettingReplyCmd) {
+                    VideoStreamSettingReplyCmd videoStreamSettingReplyCmd = (VideoStreamSettingReplyCmd) tyCommand;
+                    logPrint("设置视频码流", videoStreamSettingReplyCmd.getResult(), videoStreamSettingReplyCmd.getErrorCode());
+                }
                 break;
             default:
                 // 处理其他消息

--
Gitblit v1.9.3