Merge branch 'release/V1.0.0/test' of http://192.168.4.240:3000/LINK/LINK-SERVER into release/V2.0.0/test

 Conflicts:

	src/main/java/com/lqkj/link/module/zone/service/ZoneInfoService.java

pom.xml

@@ -164,6 +164,28 @@
             <version>5.8.25</version>
         </dependency>
 
+<!--        阿里云oss依赖-->
+        <dependency>
+            <groupId>com.aliyun.oss</groupId>
+            <artifactId>aliyun-sdk-oss</artifactId>
+            <version>3.17.4</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.xml.bind</groupId>
+            <artifactId>jaxb-api</artifactId>
+            <version>2.3.1</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.activation</groupId>
+            <artifactId>activation</artifactId>
+            <version>1.1.1</version>
+        </dependency>
+        <!-- no more than 2.3.3-->
+        <dependency>
+            <groupId>org.glassfish.jaxb</groupId>
+            <artifactId>jaxb-runtime</artifactId>
+            <version>2.3.3</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/lqkj/link/config/OpenApiConfig.java

@@ -106,7 +106,8 @@ public class OpenApiConfig {
                         "/audit/v1/**",
                         "/notice/v1/**",
                         "/layer/v1/**",
-                        "/resource/v1/**")
+                        "/resource/v1/**",
+                        "/resource/ossUpload")
                 .build();
     }
 

src/main/java/com/lqkj/link/config/ThreadPoolConfig.java

@@ -0,0 +1,22 @@
+package com.lqkj.link.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+public class ThreadPoolConfig {
+
+    @Bean(name = "taskExecutor")
+    public Executor taskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10); // 核心线程池大小
+        executor.setMaxPoolSize(20); // 最大线程池大小
+        executor.setQueueCapacity(50); // 队列容量
+        executor.setThreadNamePrefix("Async-"); // 线程名称前缀
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/lqkj/link/module/base/service/BaseService.java

@@ -1,15 +1,20 @@
 package com.lqkj.link.module.base.service;
 
 import com.lqkj.link.message.MessageBean;
+import com.lqkj.link.util.AliOSSUtils;
 import com.lqkj.link.util.FileUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.IOException;
 import java.util.UUID;
 
 @Service
 public class BaseService {
 
+    @Autowired
+    private AliOSSUtils aliOSSUtils;
     public MessageBean<String> uploadImg(MultipartFile file, String path) {
         String fileName = file.getOriginalFilename();
         String suffix = fileName == null ? "" : fileName.substring(fileName.lastIndexOf(".") + 1);
@@ -75,4 +80,12 @@ public class BaseService {
         FileUtils.saveFile(file, filePath, newFileName);
         return MessageBean.ok(filePath.substring(1) + newFileName, "上传模型文件");
     }
+
+    public String ossUpload(MultipartFile file) {
+        try {
+            return aliOSSUtils.upload(file);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
 }

src/main/java/com/lqkj/link/module/zone/controller/ResourceController.java

@@ -237,4 +237,17 @@ public class ResourceController {
         String userCode = jwtService.decryptUsernameWithHeader(authHeader);
         return MessageBean.ok(resourceService.needRefreshResource(userCode), "资源更新检查");
     }
+
+
+    @Operation(
+            summary = "5.1.3.7 阿里云上传接口",
+            description = "5.1.3.7 阿里云上传接口",
+            parameters = {
+                    @Parameter(name = "file", description = "文件", required = true)
+            }
+    )
+    @PostMapping("/ossUpload")
+    public MessageBean<String> ossUpload(MultipartFile file) {
+        return MessageBean.ok(baseService.ossUpload(file), "oss上传");
+    }
 }

src/main/java/com/lqkj/link/module/zone/domain/GeomInfo.java

@@ -54,6 +54,18 @@ public class GeomInfo {
     private JSONObject trans;
     @Transient
     private String modelPath;
+    @Column(name = "pics")
+    private String pics;
+    @Column(name = "video_url")
+    private String videoUrl;
+    @Column(name = "audio_url")
+    private String audioUrl;
+    @Column(name = "brief")
+    private String brief;
+    @Column(name = "navigation")
+    private Boolean navigation;
+    @Column(name = "navigation_end")
+    private String navigationEnd;
 
     /**
      * 材质ID

src/main/java/com/lqkj/link/module/zone/service/ResourceService.java

@@ -6,8 +6,10 @@ import com.lqkj.link.module.zone.domain.ModelCategory;
 import com.lqkj.link.module.zone.domain.ModelInfo;
 import com.lqkj.link.module.zone.repository.ModelCategoryRepository;
 import com.lqkj.link.module.zone.repository.ModelInfoRepository;
+import com.lqkj.link.util.AliOSSUtils;
 import com.lqkj.link.util.Unzipper;
 import org.apache.commons.compress.archivers.ArchiveException;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
@@ -25,6 +27,9 @@ public class ResourceService {
     private final ModelInfoRepository infoRepository;
     private final UserInfoRepository userInfoRepository;
 
+    @Autowired
+    private AliOSSUtils aliOSSUtils;
+
     public ResourceService(ModelCategoryRepository categoryRepository, ModelInfoRepository infoRepository, UserInfoRepository userInfoRepository) {
         this.categoryRepository = categoryRepository;
         this.infoRepository = infoRepository;
@@ -72,39 +77,25 @@ public class ResourceService {
                 for (File model : models) {
                     if (model.isFile() && model.getName().endsWith(".fbx")) {
                         String modelFileName = model.getName();
-                        String modelPath = "/upload/resource/" + category.getCategoryId() + "/model/";
-                        if (modelFileName.matches(".*[一-龥]+.*")) {
-                            // 如果包含中文，重命名
-                            String newFileName = UUID.randomUUID() + ".fbx";
-                            modelPath += newFileName;
-                            boolean rename = model.renameTo(new File("." + modelPath));
+                        String modelPath = aliOSSUtils.upload(model);
+                        // 如果包含中文，重命名
+                        String newFileName = UUID.randomUUID() + ".png";
+                        String modelIconPath = "." + "/upload/resource/" + category.getCategoryId() + "/icon/" + newFileName;
+                        // 模型图标也许要重命名
+                        File oldIconFile = new File("." + "/upload/resource/" + category.getCategoryId() + "/icon/" + modelFileName.replace(".fbx", ".png"));
+                        if (oldIconFile.exists()) {
+                            File newIconFile = new File(modelIconPath);
+                            Boolean rename = oldIconFile.renameTo(newIconFile);
                             System.out.println(rename);
-                            // 材质文件也需要重命名
-                            File oldMaterialFile = new File("." + "/upload/resource/" + category.getCategoryId() + "/model/" + modelFileName.replace(".fbx", ".json"));
-                            if (oldMaterialFile.exists()) {
-                                File newMaterialFile = new File("." + "/upload/resource/" + category.getCategoryId() + "/model/" + newFileName.replace(".fbx", ".json"));
-                                rename = oldMaterialFile.renameTo(newMaterialFile);
-                                System.out.println(rename);
-                            }
-
-                            // 模型图标也许要重命名
-                            File oldIconFile = new File("." + "/upload/resource/" + category.getCategoryId() + "/icon/" + modelFileName.replace(".fbx", ".png"));
-                            if (oldIconFile.exists()) {
-                                File newIconFile = new File("." + "/upload/resource/" + category.getCategoryId() + "/icon/" + newFileName.replace(".fbx", ".png"));
-                                rename = oldIconFile.renameTo(newIconFile);
-                                System.out.println(rename);
-                            }
-                        } else {
-                            modelPath += modelFileName;
                         }
                         if (!modelInfoMap.containsKey(modelFileName.substring(0, modelFileName.lastIndexOf(".")))) {
                             list.add(new ModelInfo(null, category.getCategoryId(), modelFileName.substring(0, modelFileName.lastIndexOf(".")),
                                     null, null, null, modelPath,
-                                    modelPath.replace("model", "icon").replace("fbx", "png"), null, null));
+                                    modelIconPath.substring(1), null, null));
                         } else {
                             ModelInfo modelInfo = modelInfoMap.get(modelFileName.substring(0, modelFileName.lastIndexOf(".")));
                             modelInfo.setOriginalPath(modelPath);
-                            modelInfo.setModelIcon(modelPath.replace("model", "icon").replace("fbx", "png"));
+                            modelInfo.setModelIcon(modelIconPath.substring(1));
                             modelInfo.setJsonPath(null);
                             modelInfo.setTexturePath(null);
                             list.add(modelInfo);

src/main/java/com/lqkj/link/module/zone/service/ZoneInfoService.java

@@ -26,6 +26,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.io.File;
+import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
@@ -40,6 +41,9 @@ public class ZoneInfoService {
     private final GeomInfoRepository geomInfoRepository;
     private final ModelInfoRepository modelInfoRepository;
 
+    @Autowired
+    private AliOSSUtils aliOSSUtils;
+
     private static final Long ONEDAY = 24 * 60 * 60 * 1000L;
 
     @Autowired
@@ -79,150 +83,137 @@ public class ZoneInfoService {
             zoneInfo.setTemplateUse(0);
         }
         ZoneInfo zoneInfo1 = zoneInfoRepository.save(zoneInfo);
-        try {
-            if (StringUtils.isNotBlank(zoneInfo.getTemplateFilePath())) {
-                // 清除元素与模型
-                geomInfoRepository.deleteAllByZoneId(zoneInfo1.getZoneId());
-                modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
 
-                // 解压压缩文件
-                // 文件目录格式：
-                // --geom.json
-                // --models
-                // ----model1.fbx 模型1文件
-                // ----model2.fbx 模型2文件
-                // ----model1.json 模型1材质
-                // ----model2.json 模型2材质
-                //
-                // geom.json文件总json格式：
-                // 	{
-                //		"init": {
-                //			"rotation": {
-                //				"x": 0,
-                //				"y": 0,
-                //				"z": 0,
-                //				"w": 0
-                //			},
-                //			"translation": {
-                //				"x": 0,
-                //				"y": 0,
-                //				"z": 0
-                //			},
-                //			"scale3D": {
-                //				"x": 0,
-                //				"y": 0,
-                //				"z": 0
-                //			}
-                //		},
-                //		"models": [
-                //			{
-                //				"modelPath": "model1.fbx",
-                //				"location": [
-                //					{
-                //						"rotation": {
-                //							"x": 0,
-                //							"y": 0,
-                //							"z": 0,
-                //							"w": 0
-                //						},
-                //						"translation": {
-                //							"x": 0,
-                //							"y": 0,
-                //							"z": 0
-                //						},
-                //						"scale3D": {
-                //							"x": 0,
-                //							"y": 0,
-                //							"z": 0
-                //						}
-                //					}
-                //				]
-                //			}
-                //		]
-                //	}
+        if (StringUtils.isNotBlank(zoneInfo.getTemplateFilePath())) {
+            // 清除元素与模型
+            geomInfoRepository.deleteAllByZoneId(zoneInfo1.getZoneId());
+            modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
+
+            // 解压压缩文件
+            // 文件目录格式：
+            // --geom.json
+            // --models
+            // ----model1.fbx 模型1文件
+            // ----model2.fbx 模型2文件
+            // ----model1.json 模型1材质
+            // ----model2.json 模型2材质
+            //
+            // geom.json文件总json格式：
+            // 	{
+            //		"init": {
+            //			"rotation": {
+            //				"x": 0,
+            //				"y": 0,
+            //				"z": 0,
+            //				"w": 0
+            //			},
+            //			"translation": {
+            //				"x": 0,
+            //				"y": 0,
+            //				"z": 0
+            //			},
+            //			"scale3D": {
+            //				"x": 0,
+            //				"y": 0,
+            //				"z": 0
+            //			}
+            //		},
+            //		"models": [
+            //			{
+            //				"modelPath": "model1.fbx",
+            //				"location": [
+            //					{
+            //						"rotation": {
+            //							"x": 0,
+            //							"y": 0,
+            //							"z": 0,
+            //							"w": 0
+            //						},
+            //						"translation": {
+            //							"x": 0,
+            //							"y": 0,
+            //							"z": 0
+            //						},
+            //						"scale3D": {
+            //							"x": 0,
+            //							"y": 0,
+            //							"z": 0
+            //						}
+            //					}
+            //				]
+            //			}
+            //		]
+            //	}
+            String geomJsonString = null;
+            try {
                 Unzipper.unZipFiles(new File("." + zoneInfo.getTemplateFilePath()), "./upload/template/" + zoneInfo1.getZoneId() + "/");
-                String geomJsonString = Files.readString(Paths.get("./upload/template/" + zoneInfo1.getZoneId() + "/geom.json"));
-                TemplateGeom templateGeom = JSON.parseObject(geomJsonString, TemplateGeom.class);
-
-                zoneInfo1.setInitLocation(templateGeom.getInit());
-                zoneInfoRepository.save(zoneInfo1);
-
-                List<TemplateInfo> templateInfoList = templateGeom.getModels();
-
-                String modelFolderPath = "./upload/template/" + zoneInfo1.getZoneId() + "/models";
-                File modelFolder = new File(modelFolderPath);
-                List<ModelInfo> list = new ArrayList<>();
-                File[] models = modelFolder.listFiles();
-                assert models != null;
-                for (File model : models) {
-                    if (model.isFile()) {
-                        String modelFileName = model.getName();
-                        if (modelFileName.endsWith(".fbx")) {
-                            String modelPath = "/upload/template/" + zoneInfo1.getZoneId() + "/models/";
-                            if (modelFileName.matches(".*[\u4e00-\u9fa5]+.*")) {
-                                // 如果包含中文，重命名
-                                String newFileName =UUID.randomUUID() + ".fbx";
-                                modelPath += newFileName;
-                                boolean rename = model.renameTo(new File("." + modelPath));
-                                System.out.println(rename);
-                                // 材质文件也需要重命名
-                                File oldMaterialFile = new File("." + "/upload/template/" + zoneInfo1.getZoneId() + "/models/" + modelFileName.replace(".fbx", ".json"));
-                                if (oldMaterialFile.exists()) {
-                                    File newMaterialFile = new File("." + "/upload/template/" + zoneInfo1.getZoneId() + "/models/" + newFileName.replace(".fbx", ".json"));
-                                    rename = oldMaterialFile.renameTo(newMaterialFile);
-                                    System.out.println(rename);
-                                }
-                            } else {
-                                modelPath += modelFileName;
-                            }
-                            list.add(new ModelInfo(null, null, modelFileName.substring(0, modelFileName.lastIndexOf(".")).toLowerCase(),
-                                    null, null, null, modelPath,
-                                    zoneInfo1.getThumbnail(), null, zoneInfo1.getZoneId()));
-                        }
+                geomJsonString = Files.readString(Paths.get("./upload/template/" + zoneInfo1.getZoneId() + "/geom.json"));
+            } catch (IOException e) {
+                modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
+                zoneInfoRepository.delete(zoneInfo1);
+                result.put("msg", "模板压缩文件解压失败！");
+                return result;
+            }
+            TemplateGeom templateGeom = JSON.parseObject(geomJsonString, TemplateGeom.class);
+
+            zoneInfo1.setInitLocation(templateGeom.getInit());
+            zoneInfoRepository.save(zoneInfo1);
+
+            List<TemplateInfo> templateInfoList = templateGeom.getModels();
+
+            String modelFolderPath = "./upload/template/" + zoneInfo1.getZoneId() + "/models";
+            File modelFolder = new File(modelFolderPath);
+            List<ModelInfo> list = new ArrayList<>();
+            File[] models = modelFolder.listFiles();
+            assert models != null;
+            for (File model : models) {
+                if (model.isFile()) {
+                    String modelFileName = model.getName();
+                    if (modelFileName.endsWith(".fbx")) {
+                        String modelPath = aliOSSUtils.upload(model);
+                        list.add(new ModelInfo(null, null, modelFileName.substring(0, modelFileName.lastIndexOf(".")).toLowerCase(),
+                                null, null, null, modelPath,
+                                zoneInfo1.getThumbnail(), null, zoneInfo1.getZoneId()));
                     }
                 }
-                List<ModelInfo> modelInfoList = modelInfoRepository.saveAll(list);
-                Map<String, ModelInfo> modelPathIdMap = modelInfoList
-                        .stream()
-                        .collect(Collectors.toMap(ModelInfo::getModelName, ModelInfo -> ModelInfo));
-
-                List<GeomInfo> geomInfoList = new ArrayList<>();
-                GeometryFactory geometryFactory = new GeometryFactory();
-                int j = 1;
-                for (TemplateInfo templateInfo : templateInfoList) {
-
-                    String modelName = templateInfo.getModelPath().substring(0, templateInfo.getModelPath().lastIndexOf(".")).toLowerCase();
-                    ModelInfo modelInfo = modelPathIdMap.get(modelName);
-                    for (int i = 0; i < templateInfo.getLocation().size(); i++) {
-                        JSONObject trans = templateInfo.getLocation().get(i);
-                        GeomInfo geomInfo = new GeomInfo();
-
-                        geomInfo.setGeomId(zoneInfo1.getZoneId() + "_" + j);
-                        geomInfo.setModelId(modelInfo.getModelId());
-                        geomInfo.setGeomName(modelInfo.getModelName());
-                        geomInfo.setZoneId(zoneInfo1.getZoneId());
-                        geomInfo.setLocking(false);
-
-                        geomInfo.setTrans(trans);
-                        JSONObject pointObject = trans.getJSONObject("translation");
-                        geomInfo.setGeom(geometryFactory.createPoint(new Coordinate(
-                                Double.parseDouble(pointObject.get("x").toString()),
-                                Double.parseDouble(pointObject.get("y").toString()),
-                                Double.parseDouble(pointObject.get("z").toString()))));
-                        j++;
-                        geomInfoList.add(geomInfo);
-                    }
+            }
+            List<ModelInfo> modelInfoList = modelInfoRepository.saveAll(list);
+            Map<String, ModelInfo> modelPathIdMap = modelInfoList
+                    .stream()
+                    .collect(Collectors.toMap(ModelInfo::getModelName, ModelInfo -> ModelInfo));
 
+            List<GeomInfo> geomInfoList = new ArrayList<>();
+            GeometryFactory geometryFactory = new GeometryFactory();
+            int j = 1;
+            for (TemplateInfo templateInfo : templateInfoList) {
+
+                String modelName = templateInfo.getModelPath().substring(0, templateInfo.getModelPath().lastIndexOf(".")).toLowerCase();
+                ModelInfo modelInfo = modelPathIdMap.get(modelName);
+                for (int i = 0; i < templateInfo.getLocation().size(); i++) {
+                    JSONObject trans = templateInfo.getLocation().get(i);
+                    GeomInfo geomInfo = new GeomInfo();
+
+                    geomInfo.setGeomId(zoneInfo1.getZoneId() + "_" + j);
+                    geomInfo.setModelId(modelInfo.getModelId());
+                    geomInfo.setGeomName(modelInfo.getModelName());
+                    geomInfo.setZoneId(zoneInfo1.getZoneId());
+                    geomInfo.setLocking(false);
+
+                    geomInfo.setTrans(trans);
+                    JSONObject pointObject = trans.getJSONObject("translation");
+                    geomInfo.setGeom(geometryFactory.createPoint(new Coordinate(
+                            Double.parseDouble(pointObject.get("x").toString()),
+                            Double.parseDouble(pointObject.get("y").toString()),
+                            Double.parseDouble(pointObject.get("z").toString()))));
+                    j++;
+                    geomInfoList.add(geomInfo);
                 }
-                geomInfoRepository.saveAll(geomInfoList);
 
             }
-        } catch (Exception e) {
-            modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
-            zoneInfoRepository.delete(zoneInfo1);
-            result.put("msg", "模板压缩文件解压失败！");
-            return result;
+            geomInfoRepository.saveAll(geomInfoList);
+
         }
+
         result.put("zone", zoneInfo1);
         return result;
     }

src/main/java/com/lqkj/link/util/AliOSSUtils.java

@@ -0,0 +1,67 @@
+package com.lqkj.link.util;
+
+import com.aliyun.oss.OSS;
+import com.aliyun.oss.OSSClientBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.UUID;
+import java.util.concurrent.Callable;
+
+@Component
+public class AliOSSUtils {
+ 
+    /**
+     * 注入AliProperties
+     */
+    private final AliProperties aliProperties;
+
+    private final ThreadPoolUtil threadPoolUtil;
+
+    public AliOSSUtils(AliProperties aliProperties, ThreadPoolUtil threadPoolUtil) {
+        this.aliProperties = aliProperties;
+        this.threadPoolUtil = threadPoolUtil;
+    }
+
+    /**
+     * 实现上传图片到OSS
+     */
+    public String upload(File file) {
+        String originalFilename = file.getName();
+        String fileName = UUID.randomUUID() + originalFilename.substring(originalFilename.lastIndexOf("."));
+        //上传文件到 OSS
+        OSS ossClient = new OSSClientBuilder().build(aliProperties.getEndpoint(), aliProperties.getAccessKeyId(), aliProperties.getAccessKeySecret());
+        threadPoolUtil.getTaskExecutor().execute(() -> {
+            ossClient.putObject(aliProperties.getBucketName(), fileName, file);
+            ossClient.shutdown();
+        });
+        //文件访问路径
+        String url = aliProperties.getEndpoint().split("//")[0] + "//" + aliProperties.getBucketName() + "." + aliProperties.getEndpoint().split("//")[1] + "/" + fileName;
+        // 关闭ossClient
+
+        return url;// 把上传到oss的路径返回
+    }
+
+    public String upload(MultipartFile file) throws IOException {
+        // 获取上传的文件的输入流
+        InputStream inputStream = file.getInputStream();
+        // 避免文件覆盖
+        String originalFilename = file.getOriginalFilename();
+        String fileName = UUID.randomUUID() + originalFilename.substring(originalFilename.lastIndexOf("."));
+        //上传文件到 OSS
+        OSS ossClient = new OSSClientBuilder().build(aliProperties.getEndpoint(), aliProperties.getAccessKeyId(), aliProperties.getAccessKeySecret());
+        threadPoolUtil.getTaskExecutor().execute(() -> {
+            ossClient.putObject(aliProperties.getBucketName(), fileName, inputStream);
+            ossClient.shutdown();
+        });
+        //文件访问路径
+        return aliProperties.getEndpoint().split("//")[0] + "//" + aliProperties.getBucketName() + "." + aliProperties.getEndpoint().split("//")[1] + "/" + fileName;
+    }
+
+ 
+}

src/main/java/com/lqkj/link/util/AliProperties.java

@@ -0,0 +1,16 @@
+package com.lqkj.link.util;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+ 
+@Component
+@Data
+@ConfigurationProperties(prefix = "aliyun")
+public class AliProperties {
+    private String endpoint;		//Bucket域名
+    private String accessKeyId;		//阿里云账号AccessKey
+    private String accessKeySecret;	//阿里云账号AccessKey对应的秘钥
+    private String bucketName;		//Bucket名称
+
+}

src/main/java/com/lqkj/link/util/ThreadPoolUtil.java

@@ -0,0 +1,23 @@
+package com.lqkj.link.util;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.Executor;
+
+@Component
+public class ThreadPoolUtil {
+
+    private final Executor taskExecutor;
+
+    @Autowired
+    public ThreadPoolUtil(Executor taskExecutor) {
+        this.taskExecutor = taskExecutor;
+    }
+
+    public Executor getTaskExecutor() {
+
+
+        return taskExecutor;
+    }
+}

src/main/resources/application-install.yml

@@ -95,4 +95,11 @@ springdoc:
     path: /v3/api-docs
   swagger-ui:
     persist-authorization: true
-    path: /swagger-ui.html
+    path: /swagger-ui.html
+
+  # 阿里云
+aliyun:
+  endpoint: https://oss-cn-chengdu.aliyuncs.com
+  accessKeyId: LTAI5tLJsyF7YvFf48sC5yVL
+  accessKeySecret: v48ceFlBuXhyeoduxOBFcEdeN4pL1G
+  bucketName: link-meta