From d68181ce2faef4821d6d8a8ffb8027480a6262c3 Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Wed, 05 Nov 2025 17:01:20 +0800
Subject: [PATCH] 2025-11-5 zwy websockeet增加Type:livestream,开启机场和飞行器的直播接口， 增加LiveStreamHandler对开启直播和关闭直播的处理； redis增加WEBSOCKET_VideoId_PREFIX，存储videoid，关闭直播功能时使用；

---
 ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInformationServiceImpl.java |   75 ++++++++++++++++++++++++++++++++++++-
 1 files changed, 73 insertions(+), 2 deletions(-)

diff --git a/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInformationServiceImpl.java b/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInformationServiceImpl.java
index a05968e..d7b9899 100644
--- a/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInformationServiceImpl.java
+++ b/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteInformationServiceImpl.java
@@ -2,12 +2,23 @@
 
 import java.util.List;
 import com.ard.common.utils.DateUtils;
+import com.ard.common.utils.file.FileUtils;
 import com.ard.common.utils.uuid.IdUtils;
+import com.ard.oss.model.MinioUploadResult;
+import com.ard.oss.service.impl.OssServiceContext;
 import com.ard.route.domain.route.ArdRouteInformation;
+import com.ard.route.domain.vo.KmzResultVo;
+import com.ard.route.service.UavRouteService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ard.route.mapper.ArdRouteInformationMapper;
 import com.ard.route.service.IArdRouteInformationService;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+import static com.ard.route.util.ToolUtils.extractFilePath;
+import static com.ard.route.util.ToolUtils.getFileNameWithoutExtension;
 
 /**
  * 航线(kmz)Service业务层处理
@@ -20,6 +31,12 @@
 
     @Autowired
     private ArdRouteInformationMapper ardRouteInformationMapper;
+
+    @Autowired
+    private OssServiceContext ossService;
+
+    @Autowired
+    private UavRouteService routeService;
 
     /**
      * 查询航线(kmz)
@@ -50,10 +67,21 @@
      * @return 结果
      */
     @Override
-    public int insertArdRouteInformation(ArdRouteInformation ardRouteInformation) {
+    public String insertArdRouteInformation(ArdRouteInformation ardRouteInformation) {
         ardRouteInformation.setId(IdUtils.simpleUUID());
         ardRouteInformation.setCreateTime(DateUtils.getNowDate());
-        return ardRouteInformationMapper.insertArdRouteInformation(ardRouteInformation);
+
+        if (ardRouteInformation.getUavRouteReq() != null){
+
+        }
+        KmzResultVo kmzResult = routeService.buildKmz(ardRouteInformation.getUavRouteReq(), ardRouteInformation.getFileName());
+        // 将KmzResult中的信息设置到ardRouteInformation中
+        ardRouteInformation.setFileNameNew(kmzResult.getFileNameNew());
+        ardRouteInformation.setMinioUpPath(kmzResult.getMinioUpPath());
+        ardRouteInformation.setUpPath(kmzResult.getUpPath());
+        ardRouteInformation.setUpFileSize(kmzResult.getUpFileSize());
+        ardRouteInformationMapper.insertArdRouteInformation(ardRouteInformation);
+        return kmzResult.getUpPath();
     }
 
     /**
@@ -76,6 +104,11 @@
      */
     @Override
     public int deleteArdRouteInformationByIds(String[] ids) {
+        // 删除航线(kmz)文件
+        for (String id : ids) {
+            ArdRouteInformation information = ardRouteInformationMapper.selectArdRouteInformationById(id);
+            ossService.deleteObject("kmz", information.getMinioUpPath());
+        }
         return ardRouteInformationMapper.deleteArdRouteInformationByIds(ids);
     }
 
@@ -90,4 +123,42 @@
         return ardRouteInformationMapper.deleteArdRouteInformationById(id);
     }
 
+    /**
+     * 导入航线(kmz)文件
+     *
+     * @param file 文件
+     * @return 结果
+     */
+    @Override
+    public MinioUploadResult uploadArdRouteInformation(MultipartFile file) {
+        try {
+            String url = ossService.upload("kmz",file);
+            ArdRouteInformation information = new ArdRouteInformation();
+            information.setFileName(file.getOriginalFilename());
+            information.setFileNameNew(getFileNameWithoutExtension(url));
+            information.setMinioUpPath(extractFilePath(url));
+            information.setUpPath(url);
+            information.setUpFileSize((double) file.getSize());
+            insertArdRouteInformation(information);
+            return MinioUploadResult.builder()
+                    .url(url)
+                    .newFileName(FileUtils.getName(url))
+                    .originalFilename(file.getOriginalFilename())
+                    .build();
+        }catch (Exception e){
+            return null;
+        }
+    }
+
+    /**
+     * 根据文件名称查询航线信息
+     *
+     * @param name 文件名称
+     * @return 结果
+     */
+    @Override
+    public ArdRouteInformation selectArdRouteInformationByName(String name) {
+        return ardRouteInformationMapper.selectArdRouteInformationByName(name);
+    }
+
 }

--
Gitblit v1.9.3