From 3823dc87eb8ef4d5cd25390ec9b17c856d10fafd Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Thu, 16 Nov 2023 15:07:55 +0800
Subject: [PATCH] 图斑飞行途中进入控制

---
 src/main/java/com/dji/sample/control/service/impl/ControlServiceImpl.java |   26 +++++++++++++++++++-------
 1 files changed, 19 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/dji/sample/control/service/impl/ControlServiceImpl.java b/src/main/java/com/dji/sample/control/service/impl/ControlServiceImpl.java
index c186883..3e36a3b 100644
--- a/src/main/java/com/dji/sample/control/service/impl/ControlServiceImpl.java
+++ b/src/main/java/com/dji/sample/control/service/impl/ControlServiceImpl.java
@@ -100,6 +100,16 @@
             RedisOpsUtils.setWithExpire(serviceIdentifier + RedisConst.DELIMITER + bid, sn,
                     RedisConst.DEVICE_ALIVE_SECOND * RedisConst.DEVICE_ALIVE_SECOND);
         }
+
+        //当执行返航指令时,删除图斑redis
+        if (serviceIdentifier == "return_home"){
+            if (RedisOpsUtils.checkExist("tuban:" + sn)){
+                RedisOpsUtils.del("tuban:" + sn);
+            }
+        }
+
+
+
         return ResponseResult.success();
     }
 
@@ -205,27 +215,32 @@
                                 eventsReceiver.getStatus().getMessage() : eventsReceiver.getResult().getErrorMsg())
                         .result(eventsReceiver.getResult().getErrorCode())
                         .build());
-
+        //当飞向目标点成功后
         if (eventsReceiver.getStatus().equals(FlyToStatusEnum.WAYLINE_OK)) {
             JSONObject jsonObject = (JSONObject) RedisOpsUtils.get("tuban:" + dockSn);
             if (jsonObject != null) {
                 List<PointPOJO> targetList = (List<PointPOJO>) jsonObject.get("targetList");
                 int curIndex = (Integer) jsonObject.get("curIndex");
                 String payloadIndex = jsonObject.getString("payloadIndex");
-                flyToNextPoint(targetList, curIndex, dockSn, payloadIndex);
+                flyToNextPoint(targetList, curIndex+1, dockSn, payloadIndex);
             }
         }
         return receiver;
     }
 
-    private ResponseResult flyToNextPoint(List<PointPOJO> targetList, int curIndex, String sn, String payloadIndex) throws Exception {
-        curIndex = curIndex + 1;
+    @Override
+    public ResponseResult flyToNextPoint(List<PointPOJO> targetList, int curIndex, String sn, String payloadIndex) throws Exception {
         //当无人机状态为人工时再发布下一个命令
         while (true) {
             Optional<DeviceDTO> dockOpt = deviceRedisService.getDeviceOnline(sn);
             DeviceModeCodeEnum deviceMode = deviceService.getDeviceMode(dockOpt.get().getChildDeviceSn());
 
             if (DeviceModeCodeEnum.MANUAL == deviceMode) {
+
+                //执行拍照
+                ResponseResult responseResult = takePhoto(sn, payloadIndex);
+
+                //发布飞行指令
                 if (curIndex == targetList.size()) {
                     //当前是最后一个点,返航
                     ResponseResult returnHome = controlDockDebug(sn, "return_home", null);
@@ -245,9 +260,6 @@
                     pointDTO.setLatitude(targetList.get(curIndex).getLat());
                     pointDTOS.add(pointDTO);
                     flyToPointParam.setPoints(pointDTOS);
-
-                    //执行拍照
-                    ResponseResult responseResult = takePhoto(sn, payloadIndex);
 
                     //发布下一个飞行指令
                     ResponseResult flyToRes = flyToPoint(sn, flyToPointParam);

--
Gitblit v1.9.3