From 1791d8d45a0f6de527a1e243b9ba806edc0753aa Mon Sep 17 00:00:00 2001
From: Xiajijian <1176061145@qq.com>
Date: Thu, 06 Nov 2025 14:32:14 +0800
Subject: [PATCH] 1.修改文件业务,屏蔽前台接口开关。 2.文件夹业务修改为,分组管理业务。 3.航线(kmz)对象增加分组ID。 4.分组信息删除同时删除分组下航信信息。 5.新增航线(kmz)时,不选分组,将赋值默认分组信息。 6.增加初始化数据类。 7.生成kmz文件,增加默认值管理。

---
 ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java |   14 ++++++++++++--
 1 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
index 40093b2..adacd79 100644
--- a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
+++ b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/ControlServiceImpl.java
@@ -69,7 +69,14 @@
             if (Objects.isNull(param)) {
                 return ResponseResult.error(CommonErrorEnum.ILLEGAL_ARGUMENT);
             }
-            BasicDeviceProperty basicDeviceProperty = mapper.convertValue(param.getAction(), controlMethodEnum.getClazz());
+            BasicDeviceProperty basicDeviceProperty = null;
+            if(serviceIdentifier.equals("sdr_workmode_switch")){
+                basicDeviceProperty= mapper.convertValue(param.getLink_workmode(), controlMethodEnum.getClazz());
+            }
+            else
+            {
+                basicDeviceProperty = mapper.convertValue(param.getAction(), controlMethodEnum.getClazz());
+            }
             if (!basicDeviceProperty.valid()) {
                 return ResponseResult.error(CommonErrorEnum.ILLEGAL_ARGUMENT);
             }
@@ -118,14 +125,16 @@
         String deviceSn = receiver.getGateway();
         if(method.equals("cover_close")){
             _deviceService.updateWorkType(deviceSn, 2L);
+            RedisOpsUtils.setWithExpire(RedisConst.OSD_STATUS_PREFIX + deviceSn, 2, RedisConst.DEVICE_ALIVE_SECOND);
         }
         String sn = RedisOpsUtils.get(key).toString();
         receiver.setType(MessageType.PROGRESS.getType());
         EventsReceiver<EventsOutputReceiver> eventsReceiver = mapper.convertValue(receiver.getData(),
                 new TypeReference<EventsReceiver<EventsOutputReceiver>>(){});
         eventsReceiver.setBid(receiver.getBid());
-        eventsReceiver.setSn(sn);
+        eventsReceiver.setGateway(sn);
         eventsReceiver.setType(MessageType.PROGRESS.getType());
+        eventsReceiver.setMethod(receiver.getMethod());
 
         log.info("SN: {}, {} ===> Control progress: {}",
                 sn, receiver.getMethod(), eventsReceiver.getOutput().getProgress().toString());
@@ -151,6 +160,7 @@
         // 更新设备列表状态--飞行器开机中...
         if(method.equals("drone_open")){
             _deviceService.updateWorkType(device.getChildDeviceSn(), 7L);
+            RedisOpsUtils.setWithExpire(RedisConst.OSD_STATUS_PREFIX + device.getChildDeviceSn(), 7, RedisConst.DEVICE_ALIVE_SECOND);
         }
 
         String dockProgress ="";

--
Gitblit v1.9.3