From 277b4f8a32c2332bc067a263bcce2e763e8d13aa Mon Sep 17 00:00:00 2001
From: Xiajijian <1176061145@qq.com>
Date: Wed, 21 Jan 2026 16:38:01 +0800
Subject: [PATCH] 1. 新增航线任务接口。 2. 新增查询航线任务列表接口。 3. 新增获取航线任务详细信息。 4. 新增航线任务接口。 5. 新增修改航线任务接口。 6. 新增删除航线任务接口。 7. 新增修改航线任务状态接口。 8. 优化查询分组业务逻辑。 9. 航线(kmz)对象增加航线任务ID信息。 10. 新增航线(kmz)业务增加航线任务数据加工校验相关业务逻辑。 11. 新增航向任务下航点信息业务相关接口。
---
ard-work/src/main/java/com/ard/work/component/websocket/handler/UavControlManager.java | 50 +++++++++++++++++++++++++++-----------------------
1 files changed, 27 insertions(+), 23 deletions(-)
diff --git a/ard-work/src/main/java/com/ard/work/component/websocket/handler/UavControlManager.java b/ard-work/src/main/java/com/ard/work/component/websocket/handler/UavControlManager.java
index ea5b677..86e880b 100644
--- a/ard-work/src/main/java/com/ard/work/component/websocket/handler/UavControlManager.java
+++ b/ard-work/src/main/java/com/ard/work/component/websocket/handler/UavControlManager.java
@@ -21,8 +21,9 @@
@Resource
private RedisCache redisCache;
- /* ===================== 1️⃣ 申请控制 ===================== */
-
+ /**
+ * 申请控制
+ */
public void sendControlRequest(Long controllerId, String boxSn, String type, Long requesterId) {
SysUser requester = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + requesterId);
@@ -39,8 +40,9 @@
WebSocketUtil.sendMessage(controllerId, JSON.toJSONString(base));
}
- /* ===================== 2️⃣ 同意控制 ===================== */
-
+ /**
+ * 同意控制
+ */
public void sendControlApproval(Long requesterId, String boxSn, String type, Long controllerId) {
SysUser controller = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + controllerId);
@@ -57,8 +59,9 @@
WebSocketUtil.sendMessage(requesterId, JSON.toJSONString(base));
}
- /* ===================== 3️⃣ 拒绝控制 ===================== */
-
+ /**
+ * 拒绝控制
+ */
public void sendControlRejection(Long requesterId, String boxSn, String type, Long controllerId) {
SysUser controller = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + controllerId);
@@ -76,24 +79,8 @@
}
/**
- * 发送控制释放通知
+ * 控制权接管
*/
- public void sendControlRelease(String boxSn, String type, Long operatorId) {
- SysUser operator = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + operatorId);
-
- UavControlMessage message = new UavControlMessage();
- message.setBoxSn(boxSn);
- message.setType(type);
- message.setAction("release");
- message.setOperatorId(operatorId);
- message.setOperator(operator);
-
- BaseMessage<UavControlMessage> baseMessage = new BaseMessage<>("control", message);
- WebSocketUtil.sendMessageAll(JSON.toJSONString(baseMessage));
- }
-
- /* ===================== 4️⃣ 控制权接管 ===================== */
-
public void sendControlTakeover(Long oldControllerId, Long newControllerId, String boxSn, String type) {
SysUser newController = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + newControllerId);
@@ -135,6 +122,23 @@
}
/**
+ * 控制权释放
+ */
+ public void sendControlRelease(String boxSn, String type, Long operatorId) {
+ SysUser operator = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + operatorId);
+
+ UavControlMessage message = new UavControlMessage();
+ message.setBoxSn(boxSn);
+ message.setType(type);
+ message.setAction("release");
+ message.setOperatorId(operatorId);
+ message.setOperator(operator);
+
+ BaseMessage<UavControlMessage> baseMessage = new BaseMessage<>("control", message);
+ WebSocketUtil.sendMessageAll(JSON.toJSONString(baseMessage));
+ }
+
+ /**
* 获取指定设备的当前操作者信息
* 该方法重写自父类，用于获取无人机和载荷的当前控制者用户ID
*
--
Gitblit v1.9.3