feat(upload): 增强上传文件配置与服务支持

- 在UploadFile结构体中新增Provider字段，支持选择上传服务商（qiniu、oss、s3）。
- 添加GetUploadProvider方法，根据配置返回当前有效的上传服务商。
- 更新上传服务的初始化逻辑，使用provider参数创建对应的上传服务实例。
- 兼容旧的NewUploadFile方法，确保向后兼容性。

Author: dengmengmian

config/config.go

@@ -117,12 +117,25 @@ type RateLimitConfig struct {
 }
 
 type UploadFile struct {
+	// Provider 上传服务商: qiniu(七牛), oss(阿里云OSS), s3(亚马逊S3，预留)
+	Provider  string `mapstructure:"provider" json:"provider"`
 	Accesskey string `mapstructure:"access-key" json:"accesskey"`
 	Secretkey string `mapstructure:"secret-key" json:"secretkey"`
 	Bucket    string `mapstructure:"bucket" json:"bucket"`
 	Endpoint  string `mapstructure:"endpoint" json:"endpoint"`
 }
 
+// GetUploadProvider 返回当前生效的上传服务商。若未配置 provider 则按 system.enable-oss 兼容：true=oss, false=qiniu
+func (u *UploadFile) GetUploadProvider(enableOss bool) string {
+	if u != nil && u.Provider != "" {
+		return u.Provider
+	}
+	if enableOss {
+		return "oss"
+	}
+	return "qiniu"
+}
+
 type JobsConfig struct {
 	Enabled bool                 `mapstructure:"enabled" json:"enabled"`
 	List    map[string]JobConfig `mapstructure:"list" json:"list"`

config/config.tmp.yml

@@ -18,8 +18,7 @@ system:
   cdn-domain: https://cdn.example.com/
   # 是否启动数据迁移
   enable-migrate: true
-  # 文件上传默认使用oss
-  enable-oss: false
+
 
 logs:
   # 日志等级(-1:Debug, 0:Info, 1:Warn, 2:Error, 3:DPanic, 4:Panic, 5:Fatal, -1<=level<=5, 参照zap.level源码)
@@ -84,11 +83,13 @@ rate-limit:
 
 # 上传文件配置
 upload-file:
-  # 访问密钥 (请填写您的OSS访问密钥)
+  # 上传服务商: qiniu(七牛) / oss(阿里云OSS) / s3(亚马逊S3，预留)
+  provider: qiniu
+  # 访问密钥 (请填写您的OSS/七牛/S3访问密钥)
   access-key: your_access_key_here
-  # 秘密密钥 (请填写您的OSS秘密密钥)
+  # 秘密密钥 (请填写您的OSS/七牛/S3秘密密钥)
   secret-key: your_secret_key_here
-  # 端点 (七牛云不用填写)
+  # 端点 (七牛云可不填；OSS/S3 填写对应 endpoint)
   endpoint: your_endpoint_here
   # 存储桶名称
   bucket: your_bucket_name_here

internal/app/controller/resource_controller.go

@@ -166,12 +166,13 @@ func (pc ResourceController) UploadResources(c *gin.Context) {
 		response.ValidationFail(c, "上传资源过大")
 		return
 	}
-	upload, err := upload.NewUploadFile(
+	provider := config.Conf.UploadFile.GetUploadProvider(config.Conf.System.EnableOss)
+	upload, err := upload.NewService(
+		provider,
 		config.Conf.UploadFile.Endpoint,
 		config.Conf.UploadFile.Accesskey,
 		config.Conf.UploadFile.Secretkey,
 		config.Conf.UploadFile.Bucket,
-		config.Conf.System.EnableOss,
 	)
 	if err != nil {
 		response.InternalServerError(c, "初始化上传服务失败："+err.Error())

internal/app/repository/resource_repository.go

@@ -97,12 +97,13 @@ func (rr ResourceRepository) DeleteResourceByID(id string) error {
 		return err
 	}
 	// 删除 cdn 文件
-	upload, err := upload.NewUploadFile(
+	provider := config.Conf.UploadFile.GetUploadProvider(config.Conf.System.EnableOss)
+	upload, err := upload.NewService(
+		provider,
 		config.Conf.UploadFile.Endpoint,
 		config.Conf.UploadFile.Accesskey,
 		config.Conf.UploadFile.Secretkey,
 		config.Conf.UploadFile.Bucket,
-		config.Conf.System.EnableOss,
 	)
 	if err != nil {
 		return err

pkg/util/upload/uploader.go

@@ -1,8 +1,10 @@
 package upload
 
 import (
+	"errors"
 	"mime/multipart"
 	"os"
+	"strings"
 )
 
 // Uploader 定义上传接口
@@ -17,23 +19,43 @@ type UploadResource struct {
 	Domain  string
 }
 
+// 支持的上传服务商
+const (
+	ProviderQiniu = "qiniu"
+	ProviderOSS   = "oss"
+	ProviderS3    = "s3"
+)
+
 // Service 提供上传和删除文件的功能
 type Service struct {
 	uploader Uploader
 }
 
-// NewService 创建一个新的 Service 实例
-func NewUploadFile(endpoint, accessKeyId, accessKeySecret, bucketName string, enableOss bool) (*Service, error) {
+// NewService 根据 provider 创建对应的上传服务实例
+// provider: qiniu(七牛) / oss(阿里云OSS) / s3(亚马逊S3，预留，当前返回未实现错误)
+func NewService(provider, endpoint, accessKeyId, accessKeySecret, bucketName string) (*Service, error) {
+	provider = strings.ToLower(strings.TrimSpace(provider))
 	var uploader Uploader
-	if enableOss {
+	switch provider {
+	case ProviderOSS:
 		uploader = NewOSS(endpoint, accessKeyId, accessKeySecret, bucketName)
-	} else {
+	case ProviderQiniu:
 		uploader = NewQiniu(accessKeyId, accessKeySecret, bucketName)
+	case ProviderS3:
+		return nil, errors.New("s3 上传尚未实现，请先使用 qiniu 或 oss")
+	default:
+		return nil, errors.New("不支持的上传服务商: " + provider + "，可选: qiniu, oss, s3")
 	}
+	return &Service{uploader: uploader}, nil
+}
 
-	return &Service{
-		uploader: uploader,
-	}, nil
+// NewUploadFile 兼容旧用法：根据 enableOss 选择 oss 或 qiniu。新代码请使用 NewService(provider, ...)
+func NewUploadFile(endpoint, accessKeyId, accessKeySecret, bucketName string, enableOss bool) (*Service, error) {
+	provider := ProviderQiniu
+	if enableOss {
+		provider = ProviderOSS
+	}
+	return NewService(provider, endpoint, accessKeyId, accessKeySecret, bucketName)
 }
 
 // UploadFile 公用上传文件方法