11

dk-common/common-oss/src/main/java/org/dromara/common/oss/core/OssClient.java

@@ -375,6 +375,10 @@ public class OssClient {
         return upload(new ByteArrayInputStream(data), getPath(properties.getPrefix(), suffix), Long.valueOf(data.length), contentType);
     }
 
+    public UploadResult uploadSuffix(byte[] data, String suffix,String fileName, String contentType) {
+        return upload(new ByteArrayInputStream(data), getPath(properties.getPrefix(), suffix,fileName), Long.valueOf(data.length), contentType);
+    }
+
     /**
      * 上传 InputStream 到 Amazon S3，使用指定的后缀构造对象键。
      *
@@ -388,6 +392,8 @@ public class OssClient {
         return upload(inputStream, getPath(properties.getPrefix(), suffix), length, contentType);
     }
 
+
+
     public UploadResult uploadSuffix(InputStream inputStream, String suffix, String fileName,Long length, String contentType) {
         return upload(inputStream, getPath(properties.getPrefix(), suffix,fileName), length, contentType);
     }
@@ -506,10 +512,17 @@ public class OssClient {
      * @return 文件路径
      */
     public String getPath(String prefix, String suffix) {
+        // 生成uuid
+        String uuid = IdUtil.fastSimpleUUID();
         // 生成日期路径
-        return prefix + StringUtils.SLASH + DateUtils.datePath() + StringUtils.SLASH + suffix ;
+        String datePath = DateUtils.datePath();
+        // 拼接路径
+        String path = StringUtils.isNotEmpty(prefix) ?
+            prefix + StringUtils.SLASH + datePath + StringUtils.SLASH + uuid : datePath + StringUtils.SLASH + uuid;
+        return path + suffix;
     }
 
+
     public String getPath(String prefix,String fileName, String suffix) {
         // 生成uuid
         String uuid = IdUtil.fastSimpleUUID();

dk-modules/sample/src/main/java/org/dromara/sample/map/service/impl/FlightAreaFileServiceImpl.java

@@ -123,7 +123,7 @@ public class FlightAreaFileServiceImpl implements IFlightAreaFileService {
                 storage.uploadSuffix(is,name,length,"json");
                 return FlightAreaFileDTO.builder()
                         .name(name)
-                        .objectKey("flightareafile/"+name)
+                        .objectKey(storage.getOssProperties().getBucketName())
                         .fileId(UUID.randomUUID().toString())
                         .size(os.size())
                         .workspaceId(workspaceId)

dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/WaylineFileServiceImpl.java

@@ -197,7 +197,8 @@ public class WaylineFileServiceImpl implements IWaylineFileService {
             waylineFile.setUsername(creator);
             OssClient storage = OssFactory.instance("waylinefile");
             String originalfileName = file.getOriginalFilename();
-            UploadResult uploadResult = storage.uploadSuffix(file.getBytes(), originalfileName, file.getContentType());
+            String suffix = org.apache.commons.lang3.StringUtils.substring(originalfileName, originalfileName.lastIndexOf("."), originalfileName.length());;
+            UploadResult uploadResult = storage.uploadSuffix(file.getBytes(),suffix, originalfileName, file.getContentType());
             waylineFile.setObjectKey(uploadResult.getFilename());
             List<String> deviceSns = new ArrayList<>();
             deviceSns.add(deviceSn);

pom.xml

@@ -99,15 +99,15 @@
             </activation>
         </profile>
         <profile>
-            <id>prod</id>
+            <id>dk_quanshan</id>
             <properties>
-                <profiles.active>prod</profiles.active>
+                <profiles.active>dk_quanshan</profiles.active>
-                <nacos.server>127.0.0.1:8848</nacos.server>
+                <nacos.server>192.168.0.8:8848</nacos.server>
                 <nacos.discovery.group>DEFAULT_GROUP</nacos.discovery.group>
                 <nacos.config.group>DEFAULT_GROUP</nacos.config.group>
                 <nacos.username>nacos</nacos.username>
                 <nacos.password>nacos</nacos.password>
-                <logstash.address>127.0.0.1:4560</logstash.address>
+                <logstash.address>192.168.0.8:4560</logstash.address>
             </properties>
         </profile>
     </profiles>