微服务改造

2026-04-27 11:47:17 +08:00
parent 1504e86b35
commit 0019ae01ea
30 changed files with 1258 additions and 105 deletions
--- a/src/main/java/com/aida/seller/module/file/FileUploadController.java
+++ b/src/main/java/com/aida/seller/module/file/FileUploadController.java
@@ -0,0 +1,87 @@
+package com.aida.seller.module.file;
+
+import cn.hutool.crypto.digest.DigestUtil;
+import com.aida.seller.common.constants.CommonConstants;
+import com.aida.seller.common.context.UserContext;
+import com.aida.seller.common.exception.BusinessException;
+import com.aida.seller.common.result.Response;
+import com.aida.seller.util.MinioUtil;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.util.Arrays;
+
+/**
+ * 文件上传控制器
+ *
+ * @author Fida Team
+ * @date 2026-02-03
+ */
+@Slf4j
+@RestController
+@RequestMapping("/file")
+@Tag(name = "文件管理", description = "文件上传、下载等功能接口")
+@RequiredArgsConstructor
+public class FileUploadController {
+
+    private final MinioUtil minioUtil;
+
+    @Value("${multipart.max-file-size}")
+    private Long maxFileSize;
+
+    @PostMapping("/upload")
+    @Operation(summary = "文件上传", description = "上传文件到Minio服务器")
+    public Response<String> uploadFile(
+            @Parameter(description = "文件", required = true) @RequestParam("file") MultipartFile file,
+            @Parameter(description = "允许的文件类型") @RequestParam(value = "allowedTypes", required = false) String[] allowedTypes
+    ) {
+        Long userId = UserContext.getUserId();
+
+        if (file.isEmpty()) {
+            throw new BusinessException("文件不能为空");
+        }
+        // 验证文件类型
+        String contentType = file.getContentType();
+        if (allowedTypes != null && allowedTypes.length > 0) {
+            boolean validType = false;
+            for (String allowedType : allowedTypes) {
+                if (contentType != null && contentType.startsWith(allowedType)) {
+                    validType = true;
+                    break;
+                }
+            }
+            if (!validType) {
+                throw new BusinessException("不支持的文件类型: " + contentType);
+            }
+        }
+        // 验证文件大小
+        if (file.getSize() > maxFileSize * 1024 * 1024) {
+            throw new BusinessException("文件大小超出限制: " + maxFileSize + " MB");
+        }
+        try {
+            // 计算文件MD5（可选，用于文件完整性校验）
+            String md5 = DigestUtil.md5Hex(file.getInputStream());
+            log.info("文件MD5: {}", md5);
+
+            // 调用MinioUtil上传文件（使用默认桶名，按userId划分文件夹）
+            String filePath = minioUtil.uploadImage(file, String.valueOf(userId));
+
+            log.info("文件上传成功: {}, 文件路径: {}", file.getOriginalFilename(), filePath);
+
+            return Response.success(minioUtil.processMinioResource(filePath, CommonConstants.MINIO_PATH_TIMEOUT));
+        } catch (IOException e) {
+            log.error("文件上传失败: {}", e.getMessage(), e);
+            throw new BusinessException("文件上传失败");
+        }
+
+    }
+
+
+}