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-oss/src/main/java/com/ard/oss/service/impl/OssServiceContext.java |   36 +++++++++++++-----------------------
 1 files changed, 13 insertions(+), 23 deletions(-)

diff --git a/ard-oss/src/main/java/com/ard/oss/service/impl/OssServiceContext.java b/ard-oss/src/main/java/com/ard/oss/service/impl/OssServiceContext.java
index e78de05..2ee3fdc 100644
--- a/ard-oss/src/main/java/com/ard/oss/service/impl/OssServiceContext.java
+++ b/ard-oss/src/main/java/com/ard/oss/service/impl/OssServiceContext.java
@@ -140,13 +140,7 @@
             // 上传文件到 Minio
             this.ossService.putObject(bucket, objectName, inputStream, contentType);
 
-            // ✅ 拼接永久 URL(不带 presigned 过期参数)
-            String baseUrl = OssConfiguration.endpoint;
-            if (!baseUrl.endsWith("/")) {
-                baseUrl += "/";
-            }
-
-            return baseUrl + bucket + "/" + objectName;
+            return buildUrl(bucket, objectName);
         } catch (Exception e) {
             throw new IOException("Upload failed: " + e.getMessage(), e);
         }
@@ -154,32 +148,19 @@
 
     public String upload(String bucket, String objectKey, InputStream input) {
         try {
-
             // 上传文件
             this.ossService.putObject(bucket, objectKey, input);
-
-            // ✅ 构建永久访问 URL
-            String baseUrl = OssConfiguration.endpoint;
-            if (!baseUrl.endsWith("/")) {
-                baseUrl += "/";
-            }
-            return baseUrl + bucket + "/" + objectKey;
+            return buildUrl(bucket, objectKey);
         } catch (Exception e) {
             throw new RuntimeException("Upload failed: " + e.getMessage(), e);
         }
     }
-    @Async("threadPoolTaskExecutor")
+
     public String upload(String bucket, String objectKey, InputStream input, String contentType) {
         try {
             // 上传文件时指定 Content-Type
             this.ossService.putObject(bucket, objectKey, input, contentType);
-
-            // ✅ 构建永久访问 URL
-            String baseUrl = OssConfiguration.endpoint;
-            if (!baseUrl.endsWith("/")) {
-                baseUrl += "/";
-            }
-            return baseUrl + bucket + "/" + objectKey;
+            return buildUrl(bucket, objectKey);
         } catch (Exception e) {
             throw new RuntimeException("Upload failed: " + e.getMessage(), e);
         }
@@ -216,4 +197,13 @@
         }
     }
 
+    // 构建url
+    private String buildUrl(String bucket, String key) {
+        String base = OssConfiguration.endpoint;
+        if (!base.endsWith("/")) {
+            base += "/";
+        }
+        return base + bucket + "/" + key;
+    }
+
 }

--
Gitblit v1.9.3