feat: 新增删除文件接口并支持多文件上传

- 新增 DeleteFile 接口，支持通过文件 URL 删除文件 - UploadFile 接口支持多文件上传，返回结果包含文件列表 - DownloadToBrowser 改为流式读取，避免大文件占用内存 - 移除 UploadFileBytes 字节流上传接口 - 修复租户存储容量校验顺序，先校验容量再写入 Redis
ci/cd调整
2026-06-11 09:14:45 +08:00 · 2026-06-10 16:30:36 +08:00 · 2026-04-22 18:00:33 +08:00 · 2026-04-22 14:25:48 +08:00 · 2026-04-22 13:57:39 +08:00 · 2026-04-22 13:02:33 +08:00
19 changed files with 815 additions and 388 deletions
--- a/24
+++ b/24
@@ -0,0 +1,24 @@
+# 阶段1: 构建
+FROM golang:alpine AS builder
+
+RUN apk add --no-cache git ca-certificates tzdata
+
+ENV TZ=Asia/Shanghai
+RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
+
+ENV GO111MODULE=on
+ENV GOPROXY=https://goproxy.cn,direct
+ENV CGO_ENABLED=0
+ENV GOTOOLCHAIN=auto
+WORKDIR /build
+
+COPY . .
+
+RUN go mod download && go mod tidy
+
+RUN go build -ldflags="-s -w" -o main ./main.go
+
+
+EXPOSE 3008
+
+CMD ["./main"]
--- a/config.yml
+++ b/config.yml
@@ -1,18 +1,78 @@
 server:
  address: ":3008"
  name: "oss"
+  workerId: 1
 rate:
  limit: 200
  burst: 300
-mongo:
+cache:
+  localTTL: 60
+  redisTTL: 300
+# Database.
+database:
  default:
-    address: "116.204.74.41:17027"
-    username: "root"
-    password: "M0ng0DB@Pass2026!"
-    database: "oss"
-    maxPoolSize: 100
-    minPoolSize: 10
-    connectTimeout: "10s"
+    - type: "pgsql"
+      host: "116.204.74.41"
+      port: "15432"
+      user: "postgres"
+      pass: "Bjang09@686^*^"
+      name: "oss"
+      prefix: "oss_"        # (可选)表名前缀
+      role: "master"              # (可选)数据库主从角色(master/slave)，默认为master。如果不使用应用主从机制请不配置或留空即可。
+      debug: false                # (可选)开启调试模式
+      dryRun: false               # (可选)ORM空跑(只读不写)
+      charset: "utf8"             # (可选)数据库编码(如: utf8mb4/utf8/gbk/gb2312)，一般设置为utf8mb4。默认为utf8。
+      timezone: "Asia/Shanghai"           # (可选)时区配置，例如:Local
+      maxIdle: 5                  # (可选)连接池最大闲置的连接数(默认10)
+      maxOpen: 20                 # (可选)连接池最大打开的连接数(默认无限制)
+      maxLifetime: "30s"          # (可选)连接对象可重复使用的时间长度(默认30秒)
+      maxIdleConnTime: "30s"      # (可选，v2.10新增)连接池中空闲连接的最大生存时间(默认30秒)。可以通过配置文件或SetConnMaxIdleTime方法设置，避免长时间空闲连接占用资源。
+      createdAt: "created_at"     # (可选)自动创建时间字段名称
+      updatedAt: "updated_at"     # (可选)自动更新时间字段名称
+      deletedAt: "deleted_at"     # (可选)软删除时间字段名称
+      timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性，为true时CreatedAt/UpdatedAt/DeletedAt都将失效
+    - type: "pgsql"
+      host: "116.204.74.41"
+      port: "15432"
+      user: "postgres"
+      pass: "Bjang09@686^*^"
+      name: "oss"
+      prefix: "oss_"        # (可选)表名前缀
+      role: "slave"               # (可选)数据库主从角色(master/slave)，默认为master。如果不使用应用主从机制请不配置或留空即可。
+      debug: false                # (可选)开启调试模式
+      dryRun: false               # (可选)ORM空跑(只读不写)
+      charset: "utf8"             # (可选)数据库编码(如: utf8mb4/utf8/gbk/gb2312)，一般设置为utf8mb4。默认为utf8。
+      timezone: "Asia/Shanghai"           # (可选)时区配置，例如:Local
+      maxIdle: 5                  # (可选)连接池最大闲置的连接数(默认10)
+      maxOpen: 20                 # (可选)连接池最大打开的连接数(默认无限制)
+      maxLifetime: "30s"          # (可选)连接对象可重复使用的时间长度(默认30秒)
+      maxIdleConnTime: "30s"      # (可选，v2.10新增)连接池中空闲连接的最大生存时间(默认30秒)。可以通过配置文件或SetConnMaxIdleTime方法设置，避免长时间空闲连接占用资源。
+      createdAt: "created_at"     # (可选)自动创建时间字段名称
+      updatedAt: "updated_at"     # (可选)自动更新时间字段名称
+      deletedAt: "deleted_at"     # (可选)软删除时间字段名称
+      timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性，为true时CreatedAt/UpdatedAt/DeletedAt都将失效
+#  tenant-1:
+#    - type: "pgsql"
+#      host: "localhost"
+#      port: "5432"
+#      user: "postgres"
+#      pass: "123456"
+#      name: "tenant-1"
+#      role: "master"
+#      prefix: "oss_"        # (可选)表名前缀
+#      debug: false                # (可选)开启调试模式
+#      dryRun: false               # (可选)ORM空跑(只读不写)
+#      charset: "utf8"             # (可选)数据库编码(如: utf8mb4/utf8/gbk/gb2312)，一般设置为utf8mb4。默认为utf8。
+#      timezone: "Asia/Shanghai"           # (可选)时区配置，例如:Local
+#      maxIdle: 5                  # (可选)连接池最大闲置的连接数(默认10)
+#      maxOpen: 20                 # (可选)连接池最大打开的连接数(默认无限制)
+#      maxLifetime: "30s"          # (可选)连接对象可重复使用的时间长度(默认30秒)
+#      maxIdleConnTime: "30s"      # (可选，v2.10新增)连接池中空闲连接的最大生存时间(默认30秒)。可以通过配置文件或SetConnMaxIdleTime方法设置，避免长时间空闲连接占用资源。
+#      createdAt: "created_at"     # (可选)自动创建时间字段名称
+#      updatedAt: "updated_at"     # (可选)自动更新时间字段名称
+#      deletedAt: "deleted_at"     # (可选)软删除时间字段名称
+#      timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性，为true时CreatedAt/UpdatedAt/DeletedAt都将失效
+
 redis:
  # 集群模式配置方法
  default:
@@ -34,14 +94,14 @@ jaeger: #链路追踪
 # MinIO 连接配置
 minio:
  endpoint: "116.204.74.41:9000"       # 核心：仅协议+主机+端口，无路径/末尾斜杠
-  accessKey: "rag_flow"                # 访问密钥（本地默认）
-  secretKey: "infini_rag_flow"                # 秘密密钥（本地默认）
+  accessKey: "admin"                # 访问密钥（本地默认）
+  secretKey: "Bjang09@686^*^"                # 秘密密钥（本地默认）
  secure: false                           # 本地 MinIO 关闭 SSL（生产按需改为 true）
  region: "us-east-1"                     # 与 MinIO 服务端 REGION 一致（默认 us-east-1）

 # 文件上传服务地址，与oss模块minio中的endpoint一致
-filePrefix: "116.204.74.41:9000"
+filePrefix: "http://116.204.74.41:9000"

 # 文件存储初始化容量大小配置
 oss:
-  capacitySize: 500 #文件存储初始化容量（单位MB）
+  capacitySize: 500 #文件存储初始化容量（单位MB）
--- a/consts/collections.go
+++ b/consts/collections.go
@@ -1,7 +0,0 @@
-package consts
-
-// MongoDB集合名称常量
-const (
-	FileCollection           = "file"
-	TenantOssTotalCollection = "tenant_oss_total"
-)
--- a/consts/table_name.go
+++ b/consts/table_name.go
@@ -0,0 +1,7 @@
+package consts
+
+// 数据库表名
+const (
+	TableNameFile           = "file"
+	TableNameTenantOssTotal = "tenant_oss_total"
+)
--- a/controller/file_controller.go
+++ b/controller/file_controller.go
@@ -4,6 +4,8 @@ import (
 	"context"
 	"oss/model/dto"
 	"oss/service"
+
+	"gitea.redpowerfuture.com/red-future/common/beans"
 )

 type file struct{}
@@ -14,6 +16,24 @@ var File = new(file)
 func init() {
 }

+// DownloadToFile 下载文件到本地
+func (c *file) DownloadToFile(ctx context.Context, req *dto.DownloadToFileReq) (res *beans.ResponseEmpty, err error) {
+	err = service.File.DownloadToFile(ctx, req)
+	return
+}
+
+// DownloadToBrowser 下载文件到浏览器
+func (c *file) DownloadToBrowser(ctx context.Context, req *dto.DownloadToBrowserReq) (res *beans.ResponseEmpty, err error) {
+	err = service.File.DownloadToBrowser(ctx, req)
+	return
+}
+
+// DeleteFile 删除文件
+func (c *file) DeleteFile(ctx context.Context, req *dto.DeleteFileReq) (res *beans.ResponseEmpty, err error) {
+	err = service.File.DeleteFile(ctx, req)
+	return
+}
+
 // UploadFile 上传文件
 func (c *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto.UploadFileRes, err error) {
 	return service.File.UploadFile(ctx, req)
--- a/dao/file_dao.go
+++ b/dao/file_dao.go
@@ -3,18 +3,26 @@ package dao
 import (
 	"context"
 	"oss/consts"
+	"oss/model/dto"
 	"oss/model/entity"

-	"gitea.com/red-future/common/db/mongo"
+	"gitea.redpowerfuture.com/red-future/common/db/gfdb"
+	"github.com/gogf/gf/v2/util/gconv"
 )

 var File = &file{}

-type file struct {
-}
+type file struct{}

 // Insert 插入
-func (d *file) Insert(ctx context.Context, entity *entity.File) (err error) {
-	_, err = mongo.DB().Insert(ctx, []interface{}{&entity}, consts.FileCollection)
-	return
+func (d *file) Insert(ctx context.Context, req *dto.UploadFile) (id int64, err error) {
+	var res *entity.File
+	if err = gconv.Struct(req, &res); err != nil {
+		return
+	}
+	r, err := gfdb.DB(ctx).Model(ctx, consts.TableNameFile).Insert(&res)
+	if err != nil {
+		return
+	}
+	return r.LastInsertId()
 }
--- a/dao/mongo_dao.go
+++ b/dao/mongo_dao.go
@@ -1,95 +0,0 @@
-package dao
-
-import (
-	"context"
-	commonMongo "gitea.com/red-future/common/db/mongo"
-	"github.com/gogf/gf/v2/errors/gerror"
-	"github.com/gogf/gf/v2/frame/g"
-	"github.com/gogf/gf/v2/os/glog"
-	"github.com/gogf/gf/v2/os/gtime"
-	"github.com/gogf/gf/v2/util/gconv"
-	"go.mongodb.org/mongo-driver/v2/bson"
-	"go.mongodb.org/mongo-driver/v2/mongo"
-	"go.mongodb.org/mongo-driver/v2/mongo/options"
-)
-
-// MongoDAO MongoDB原生查询（不需要token验证）
-var MongoDAO = &mongoDAO{}
-
-type mongoDAO struct{}
-
-// SaveOrUpdate 原生批量增加或修改
-func (d *mongoDAO) SaveOrUpdate(ctx context.Context, filter []bson.M, update []bson.M, collection string, opts ...options.Lister[options.UpdateManyOptions]) (result *mongo.BulkWriteResult, err error) {
-	db := commonMongo.GetDB()
-	if len(filter) == 0 || len(update) == 0 {
-		err = gerror.New("缺少查询条件或更新数据")
-		return
-	}
-	if len(filter) != len(update) {
-		err = gerror.New("查询条件和更新数据的数量必须一致")
-		return
-	}
-	// 构建批量操作模型
-	var models []mongo.WriteModel
-	for i := 0; i < len(filter); i++ {
-		if g.IsEmpty(filter[i]["tenantId"]) && g.IsEmpty(gconv.Map(update[i]["$set"])["updater"]) {
-			return nil, gerror.New("tenantId不能为空")
-		}
-		if g.IsEmpty(filter[i]["updater"]) && g.IsEmpty(gconv.Map(update[i]["$set"])["updater"]) {
-			return nil, gerror.New("updater不能为空")
-		}
-		// 处理过滤器
-		filter[i]["isDeleted"] = false
-		// 处理更新数据
-		if setDoc, exists := update[i]["$set"].(bson.M); exists {
-			setDoc["updater"] = gconv.Map(update[i]["$set"])["updater"]
-			setDoc["updatedAt"] = gtime.Now().Time
-		} else {
-			// 如果没有$set字段，则创建一个
-			setDoc := bson.M{}
-			setDoc["updater"] = gconv.Map(update[i]["$set"])["updater"]
-			setDoc["updatedAt"] = gtime.Now().Time
-			update[i]["$set"] = setDoc
-		}
-		// 创建更新操作模型
-		updateModel := mongo.NewUpdateOneModel()
-		updateModel.SetFilter(filter[i])
-		updateModel.SetUpdate(update[i])
-		updateModel.SetUpsert(true) // 默认不插入新文档
-		// 处理选项参数
-		if len(opts) > 0 {
-			for _, opt := range opts {
-				var updateOpts options.UpdateManyOptions
-				optFuncs := opt.List()
-				for _, fn := range optFuncs {
-					fn(&updateOpts)
-				}
-				if updateOpts.Upsert != nil {
-					updateModel.SetUpsert(*updateOpts.Upsert)
-				}
-			}
-		}
-		models = append(models, updateModel)
-	}
-	// 执行批量操作，无序执行提高性能
-	bulkOpts := options.BulkWrite().SetOrdered(false)
-	bulkResult, err := db.Collection(collection).BulkWrite(ctx, models, bulkOpts)
-	if err != nil {
-		return nil, err
-	}
-	// 清理相关缓存
-	for i := 0; i < len(filter); i++ {
-		var tenantId any
-		if g.IsEmpty(filter[i]["tenantId"]) {
-			tenantId = filter[i]["tenantId"]
-		}
-		if g.IsEmpty(gconv.Map(update[i]["$set"])["tenantId"]) {
-			tenantId = gconv.Map(update[i]["$set"])["tenantId"]
-		}
-		err = commonMongo.DB().CleanRedis(ctx, filter[i], tenantId, collection)
-		if err != nil {
-			glog.Warning(ctx, "清理Redis缓存失败:", err)
-		}
-	}
-	return bulkResult, nil
-}
--- a/dao/tenant_oss_total.go
+++ b/dao/tenant_oss_total.go
@@ -6,38 +6,33 @@ import (
 	"oss/model/dto"
 	"oss/model/entity"

-	"gitea.com/red-future/common/db/mongo"
-	"github.com/gogf/gf/v2/frame/g"
-	"go.mongodb.org/mongo-driver/v2/bson"
+	"gitea.redpowerfuture.com/red-future/common/db/gfdb"
+	"github.com/gogf/gf/v2/util/gconv"
 )

 var TenantOssTotal = &tenantOssTotal{}

-type tenantOssTotal struct {
-}
+type tenantOssTotal struct{}

 // SaveOrUpdate 增加或更新
-func (d *tenantOssTotal) SaveOrUpdate(ctx context.Context, updateData []*dto.UpdateUsedOssReq) (err error) {
-	if !g.IsEmpty(updateData) {
-		var filter, update []bson.M
-		for _, v := range updateData {
-			buildUpdateData, err := mongo.BuildUpdateData(ctx, v)
-			if err != nil {
-				return err
-			}
-			filter = append(filter, bson.M{"tenantId": v.TenantId})
-			update = append(update, bson.M{"$set": buildUpdateData})
-		}
-		_, err = MongoDAO.SaveOrUpdate(ctx, filter, update, consts.TenantOssTotalCollection)
-		if err != nil {
-			return err
-		}
+func (d *tenantOssTotal) SaveOrUpdate(ctx context.Context, updateData []*dto.UpdateUsedOssReq) (rows int64, err error) {
+	var res []*entity.TenantOssTotal
+	if err = gconv.Structs(updateData, &res); err != nil {
+		return
 	}
-	return
+	r, err := gfdb.DB(ctx).Model(ctx, consts.TableNameTenantOssTotal).Data(res).OnConflict(entity.TenantOssCol.TenantId).Save()
+	if err != nil {
+		return
+	}
+	return r.RowsAffected()
 }

 func (d *tenantOssTotal) GetOneByTenantId(ctx context.Context, req *dto.GetByTenantIdReq) (res *entity.TenantOssTotal, err error) {
-	filter := bson.M{"tenantId": req.TenantId}
-	err = mongo.DB().FindOne(ctx, filter, &res, consts.TenantOssTotalCollection)
+	model := gfdb.DB(ctx).Model(ctx, consts.TableNameTenantOssTotal).Where(entity.TenantOssCol.TenantId, req.TenantId)
+	record, err := model.One()
+	if err != nil {
+		return
+	}
+	err = record.Struct(&res)
 	return
 }
--- a/go.mod
+++ b/go.mod
@@ -1,30 +1,32 @@
 module oss

-go 1.25.3
+go 1.26.1

 require (
-	gitea.com/red-future/common v0.0.2
-	github.com/gogf/gf/contrib/nosql/redis/v2 v2.9.5
-	github.com/gogf/gf/v2 v2.9.5
-	go.mongodb.org/mongo-driver/v2 v2.4.1
+	gitea.redpowerfuture.com/red-future/common v0.0.23
+	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.2
+	github.com/gogf/gf/contrib/nosql/redis/v2 v2.10.2
+	github.com/gogf/gf/v2 v2.10.2
+	github.com/google/uuid v1.6.0
+	github.com/minio/minio-go/v7 v7.2.0
 )

-// replace gitea.com/red-future/common => ../common
-
 require (
-	github.com/BurntSushi/toml v1.5.0 // indirect
+	github.com/BurntSushi/toml v1.6.0 // indirect
 	github.com/armon/go-metrics v0.4.1 // indirect
+	github.com/bwmarrin/snowflake v0.3.0 // indirect
 	github.com/cenkalti/backoff/v5 v5.0.3 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/clbanning/mxj/v2 v2.7.0 // indirect
+	github.com/clipperhouse/uax29/v2 v2.7.0 // indirect
 	github.com/dgraph-io/badger/v4 v4.2.0 // indirect
 	github.com/dgraph-io/ristretto v0.1.1 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
-	github.com/emirpasic/gods v1.18.1 // indirect
-	github.com/fatih/color v1.18.0 // indirect
+	github.com/emirpasic/gods/v2 v2.0.0-alpha // indirect
+	github.com/fatih/color v1.19.0 // indirect
 	github.com/fsnotify/fsnotify v1.9.0 // indirect
-	github.com/go-ini/ini v1.67.0 // indirect
+	github.com/go-ego/gse v1.0.2 // indirect
 	github.com/go-logr/logr v1.4.3 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/gogf/gf/contrib/registry/consul/v2 v2.9.5 // indirect
@@ -36,8 +38,7 @@ require (
 	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/golang/snappy v1.0.0 // indirect
 	github.com/google/flatbuffers v1.12.1 // indirect
-	github.com/google/uuid v1.6.0 // indirect
-	github.com/gorilla/websocket v1.5.3 // indirect
+	github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674 // indirect
 	github.com/grokify/html-strip-tags-go v0.1.0 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.2 // indirect
 	github.com/hashicorp/consul/api v1.26.1 // indirect
@@ -47,39 +48,35 @@ require (
 	github.com/hashicorp/go-immutable-radix v1.3.1 // indirect
 	github.com/hashicorp/go-multierror v1.1.1 // indirect
 	github.com/hashicorp/go-rootcerts v1.0.2 // indirect
-	github.com/hashicorp/golang-lru v0.5.4 // indirect
+	github.com/hashicorp/golang-lru v1.0.2 // indirect
 	github.com/hashicorp/serf v0.10.1 // indirect
-	github.com/klauspost/compress v1.18.0 // indirect
+	github.com/klauspost/compress v1.18.6 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.11 // indirect
 	github.com/klauspost/crc32 v1.3.0 // indirect
+	github.com/lib/pq v1.10.9 // indirect
 	github.com/magiconair/properties v1.8.10 // indirect
 	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/mattn/go-runewidth v0.0.16 // indirect
-	github.com/minio/crc64nvme v1.1.0 // indirect
+	github.com/mattn/go-runewidth v0.0.23 // indirect
+	github.com/minio/crc64nvme v1.1.1 // indirect
 	github.com/minio/md5-simd v1.1.2 // indirect
-	github.com/minio/minio-go/v7 v7.0.97 // indirect
 	github.com/mitchellh/go-homedir v1.1.0 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
-	github.com/nats-io/nats.go v1.48.0 // indirect
-	github.com/nats-io/nkeys v0.4.11 // indirect
-	github.com/nats-io/nuid v1.0.1 // indirect
 	github.com/olekukonko/errors v1.1.0 // indirect
 	github.com/olekukonko/ll v0.0.9 // indirect
 	github.com/olekukonko/tablewriter v1.1.0 // indirect
 	github.com/philhofer/fwd v1.2.0 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
-	github.com/rabbitmq/amqp091-go v1.10.0 // indirect
+	github.com/r3labs/diff/v2 v2.15.1 // indirect
 	github.com/redis/go-redis/v9 v9.12.1 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/rs/xid v1.6.0 // indirect
-	github.com/stretchr/objx v0.5.2 // indirect
 	github.com/tiger1103/gfast-token v1.0.10 // indirect
-	github.com/tinylib/msgp v1.3.0 // indirect
-	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
-	github.com/xdg-go/scram v1.1.2 // indirect
-	github.com/xdg-go/stringprep v1.0.4 // indirect
-	github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 // indirect
+	github.com/tinylib/msgp v1.6.1 // indirect
+	github.com/vcaesar/cedar v0.30.0 // indirect
+	github.com/vmihailenco/msgpack v4.0.4+incompatible // indirect
+	github.com/zeebo/xxh3 v1.1.0 // indirect
+	go.mongodb.org/mongo-driver/v2 v2.4.0 // indirect
 	go.opencensus.io v0.23.0 // indirect
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
 	go.opentelemetry.io/otel v1.38.0 // indirect
@@ -89,15 +86,17 @@ require (
 	go.opentelemetry.io/otel/sdk v1.38.0 // indirect
 	go.opentelemetry.io/otel/trace v1.38.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.7.1 // indirect
-	golang.org/x/crypto v0.44.0 // indirect
-	golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63 // indirect
-	golang.org/x/net v0.47.0 // indirect
-	golang.org/x/sync v0.18.0 // indirect
-	golang.org/x/sys v0.38.0 // indirect
-	golang.org/x/text v0.31.0 // indirect
+	go.yaml.in/yaml/v3 v3.0.4 // indirect
+	golang.org/x/crypto v0.51.0 // indirect
+	golang.org/x/exp v0.0.0-20250305212735-054e65f0b394 // indirect
+	golang.org/x/net v0.53.0 // indirect
+	golang.org/x/sys v0.44.0 // indirect
+	golang.org/x/text v0.37.0 // indirect
+	google.golang.org/appengine v1.6.7 // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20250825161204-c5933d9347a5 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250825161204-c5933d9347a5 // indirect
 	google.golang.org/grpc v1.75.0 // indirect
-	google.golang.org/protobuf v1.36.8 // indirect
+	google.golang.org/protobuf v1.36.10 // indirect
+	gopkg.in/ini.v1 v1.67.2 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
--- a/go.sum
+++ b/go.sum
@@ -1,9 +1,9 @@
 cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
-gitea.com/red-future/common v0.0.2 h1:KjiIyZo0JeSN9ldXofuGkFifJ/H66kTybOU34Yew7R0=
-gitea.com/red-future/common v0.0.2/go.mod h1:CUurYN0elToJTwB2pX9wSnjQqZv9D/Vxbo5ueb7i9BI=
+gitea.redpowerfuture.com/red-future/common v0.0.23 h1:xieoA00iKOCDm5SO9iXn+cSyMKBAlZwI0fuEVPWrHLg=
+gitea.redpowerfuture.com/red-future/common v0.0.23/go.mod h1:50U1Xi+Ie56z09S5LQbZvaken0Mxv3OeS9LgR7U/ZRY=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
-github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
-github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
+github.com/BurntSushi/toml v1.6.0 h1:dRaEfpa2VI55EwlIW72hMRHdWouJeRF7TPYhI+AUQjk=
+github.com/BurntSushi/toml v1.6.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
 github.com/DataDog/datadog-go v3.2.0+incompatible/go.mod h1:LButxg5PwREeZtORoXG3tL4fMGNddJ+vMq1mwgfaqoQ=
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
@@ -23,6 +23,8 @@ github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
 github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
 github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
 github.com/bsm/gomega v1.27.10/go.mod h1:JyEr/xRbxbtgWNi8tIEVPUYZ5Dzef52k01W3YH0H+O0=
+github.com/bwmarrin/snowflake v0.3.0 h1:xm67bEhkKh6ij1790JB83OujPR5CzNe8QuQqAgISZN0=
+github.com/bwmarrin/snowflake v0.3.0/go.mod h1:NdZxfVWX+oR6y2K0o6qAYv6gIOP9rjG0/E9WsDpxqwE=
 github.com/cenkalti/backoff/v5 v5.0.3 h1:ZN+IMa753KfX5hd8vVaMixjnqRZ3y8CuJKRKj1xcsSM=
 github.com/cenkalti/backoff/v5 v5.0.3/go.mod h1:rkhZdG3JZukswDf7f0cwqPNk4K0sa+F97BxZthm/crw=
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
@@ -34,6 +36,8 @@ github.com/circonus-labs/circonusllhist v0.1.3/go.mod h1:kMXHVDlOchFAehlya5ePtbp
 github.com/clbanning/mxj/v2 v2.7.0 h1:WA/La7UGCanFe5NpHF0Q3DNtnCsVoxbPKuyBNHWRyME=
 github.com/clbanning/mxj/v2 v2.7.0/go.mod h1:hNiWqW14h+kc+MdF9C6/YoRfjEJoR3ou6tn/Qo+ve2s=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/clipperhouse/uax29/v2 v2.7.0 h1:+gs4oBZ2gPfVrKPthwbMzWZDaAFPGYK72F0NJv2v7Vk=
+github.com/clipperhouse/uax29/v2 v2.7.0/go.mod h1:EFJ2TJMRUaplDxHKj1qAEhCtQPW2tJSwu5BF98AuoVM=
 github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -50,8 +54,8 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cu
 github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
 github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
 github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
-github.com/emirpasic/gods v1.18.1 h1:FXtiHYKDGKCW2KzwZKx0iC0PQmdlorYgdFG9jPXJ1Bc=
-github.com/emirpasic/gods v1.18.1/go.mod h1:8tpGGwCnJ5H4r6BWwaV6OrWmMoPhUl5jm/FMNAnJvWQ=
+github.com/emirpasic/gods/v2 v2.0.0-alpha h1:dwFlh8pBg1VMOXWGipNMRt8v96dKAIvBehtCt6OtunU=
+github.com/emirpasic/gods/v2 v2.0.0-alpha/go.mod h1:W0y4M2dtBB9U5z3YlghmpuUhiaZT2h6yoeE+C1sCp6A=
 github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
 github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
 github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
@@ -59,12 +63,12 @@ github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7
 github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
 github.com/fatih/color v1.9.0/go.mod h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL+zU=
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
-github.com/fatih/color v1.18.0 h1:S8gINlzdQ840/4pfAwic/ZE0djQEH3wM94VfqLTZcOM=
-github.com/fatih/color v1.18.0/go.mod h1:4FelSpRwEGDpQ12mAdzqdOukCy4u8WUtOY6lkT/6HfU=
+github.com/fatih/color v1.19.0 h1:Zp3PiM21/9Ld6FzSKyL5c/BULoe/ONr9KlbYVOfG8+w=
+github.com/fatih/color v1.19.0/go.mod h1:zNk67I0ZUT1bEGsSGyCZYZNrHuTkJJB+r6Q9VuMi0LE=
 github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=
 github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
-github.com/go-ini/ini v1.67.0 h1:z6ZrTEZqSWOTyH2FlglNbNgARyHG8oLW9gMELqKr06A=
-github.com/go-ini/ini v1.67.0/go.mod h1:ByCAeIL28uOIIG0E3PJtZPDL8WnHpFKFOtgjp+3Ies8=
+github.com/go-ego/gse v1.0.2 h1:+27lYFPhQEhA9igtdOsJPRKYL/k3TwYsxBF5jr6KFv4=
+github.com/go-ego/gse v1.0.2/go.mod h1:Fy35G+q7VV7Et1zIKO8o/sW1kkugV3znXap/lF/11zc=
 github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
 github.com/go-kit/kit v0.9.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
 github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
@@ -75,14 +79,16 @@ github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ4
 github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
 github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
-github.com/gogf/gf/contrib/nosql/redis/v2 v2.9.5 h1:Ku7p3CvGchxC7zPSgArf/tZs2w9Yb8tS/gH5ADN+p9g=
-github.com/gogf/gf/contrib/nosql/redis/v2 v2.9.5/go.mod h1:cjy18NsSLZQf5zaLAzuo7B2gr8GGjCTWDTEPY7T+6FI=
+github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.2 h1:u8EpP24GkprogROnJ7htMov9Fc66pTP1eVYrWxiCYOs=
+github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.2/go.mod h1:GmvM3r8GVByVMi4RD2+MCs5+CfxVXPMeT8mVDkAaAXE=
+github.com/gogf/gf/contrib/nosql/redis/v2 v2.10.2 h1:iTQegT+lEg/wDKvj2mi3W1wrdrwFarjokf88EXVVgu4=
+github.com/gogf/gf/contrib/nosql/redis/v2 v2.10.2/go.mod h1:ZRw3GNz5cq4uYrW4TPSVyrYWaoqzujKdWro/AOcGBaE=
 github.com/gogf/gf/contrib/registry/consul/v2 v2.9.5 h1:eUqwJ/qNH8lJ6yssiqskazgp1ACQuNU6zXlLOZVuXTQ=
 github.com/gogf/gf/contrib/registry/consul/v2 v2.9.5/go.mod h1:sjQyMry9+0POYZCA6lHXBxO77WoNKkruJpRB4xKqk5k=
 github.com/gogf/gf/contrib/trace/otlphttp/v2 v2.9.5 h1:tHUEZYB5GTqEYYVDYnlGobf1xISARKDE4KHVlgjwTec=
 github.com/gogf/gf/contrib/trace/otlphttp/v2 v2.9.5/go.mod h1:cfzTn2HS9RDX8f5pUVkbGxUWcSosouqfNQ1G6cY0V88=
-github.com/gogf/gf/v2 v2.9.5 h1:1scfOdHbMP854oQaiLejl+eL+c4xfuvtWmmZiDJxbKs=
-github.com/gogf/gf/v2 v2.9.5/go.mod h1:VUb5eyJKpvW77O/dXsbbLNO/Kjrg0UycIiq0lRiBjjo=
+github.com/gogf/gf/v2 v2.10.2 h1:46IO0Uc8e85/FqdftJFskfDejJLBL0JBnGS5qOftUu8=
+github.com/gogf/gf/v2 v2.10.2/go.mod h1:Svl1N+E8G/QshU2DUbh/3J/AJauqCgUnxHurXWR4Qx0=
 github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
 github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
@@ -126,8 +132,8 @@ github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
-github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674 h1:JeSE6pjso5THxAzdVpqr6/geYxZytqFMBCOtn/ujyeo=
+github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674/go.mod h1:r4w70xmWCQKmi1ONH4KIaBptdivuRPyosB9RmPlGEwA=
 github.com/grokify/html-strip-tags-go v0.1.0 h1:03UrQLjAny8xci+R+qjCce/MYnpNXCtgzltlQbOBae4=
 github.com/grokify/html-strip-tags-go v0.1.0/go.mod h1:ZdzgfHEzAfz9X6Xe5eBLVblWIxXfYSQ40S/VKrAOGpc=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.2 h1:8Tjv8EJ+pM1xP8mK6egEbD1OgnVTyacbefKhmbLhIhU=
@@ -165,11 +171,11 @@ github.com/hashicorp/go-uuid v1.0.0/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/b
 github.com/hashicorp/go-uuid v1.0.1/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
 github.com/hashicorp/go-uuid v1.0.3 h1:2gKiV6YVmrJ1i2CKKa9obLvRieoRGviZFL26PcT/Co8=
 github.com/hashicorp/go-uuid v1.0.3/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
-github.com/hashicorp/go-version v1.2.1 h1:zEfKbn2+PDgroKdiOzqiE8rsmLqU2uwi5PB5pBJ3TkI=
-github.com/hashicorp/go-version v1.2.1/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09ZGVZPK5anwXA=
+github.com/hashicorp/go-version v1.9.0 h1:CeOIz6k+LoN3qX9Z0tyQrPtiB1DFYRPfCIBtaXPSCnA=
+github.com/hashicorp/go-version v1.9.0/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09ZGVZPK5anwXA=
 github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
-github.com/hashicorp/golang-lru v0.5.4 h1:YDjusn29QI/Das2iO9M0BHnIbxPeyuCHsjMW+lJfyTc=
-github.com/hashicorp/golang-lru v0.5.4/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
+github.com/hashicorp/golang-lru v1.0.2 h1:dV3g9Z/unq5DpblPpw+Oqcv4dU/1omnb4Ok8iPY6p1c=
+github.com/hashicorp/golang-lru v1.0.2/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
 github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64=
 github.com/hashicorp/mdns v1.0.4/go.mod h1:mtBihi+LeNXGtG8L9dX59gAEa12BDtBQSp4v/YAJqrc=
 github.com/hashicorp/memberlist v0.5.0 h1:EtYPN8DpAURiapus508I4n9CzHs2W+8NZGbmmR/prTM=
@@ -181,8 +187,8 @@ github.com/json-iterator/go v1.1.9/go.mod h1:KdQUCv79m/52Kvf8AW2vK1V8akMuk1QjK/u
 github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
-github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
-github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
+github.com/klauspost/compress v1.18.6 h1:2jupLlAwFm95+YDR+NwD2MEfFO9d4z4Prjl1XXDjuao=
+github.com/klauspost/compress v1.18.6/go.mod h1:cwPg85FWrGar70rWktvGQj8/hthj3wpl0PGDogxkrSQ=
 github.com/klauspost/cpuid/v2 v2.0.1/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.2.11 h1:0OwqZRYI2rFrjS4kvkDnqJkKHdHaRnCm68/DY4OxRzU=
 github.com/klauspost/cpuid/v2 v2.2.11/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
@@ -197,6 +203,8 @@ github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
+github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 github.com/magiconair/properties v1.8.10 h1:s31yESBquKXCV9a/ScB3ESkOjUYYv+X0rg8SYxI99mE=
 github.com/magiconair/properties v1.8.10/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0=
 github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
@@ -213,18 +221,19 @@ github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Ky
 github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc=
-github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
+github.com/mattn/go-runewidth v0.0.23 h1:7ykA0T0jkPpzSvMS5i9uoNn2Xy3R383f9HDx3RybWcw=
+github.com/mattn/go-runewidth v0.0.23/go.mod h1:XBkDxAl56ILZc9knddidhrOlY5R/pDhgLpndooCuJAs=
 github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
 github.com/miekg/dns v1.1.26/go.mod h1:bPDLeHnStXmXAq1m/Ch/hvfNHr14JKNPMBo3VZKjuso=
-github.com/miekg/dns v1.1.41 h1:WMszZWJG0XmzbK9FEmzH2TVcqYzFesusSIB41b8KHxY=
 github.com/miekg/dns v1.1.41/go.mod h1:p6aan82bvRIyn+zDIv9xYNUpwa73JcSh9BKwknJysuI=
-github.com/minio/crc64nvme v1.1.0 h1:e/tAguZ+4cw32D+IO/8GSf5UVr9y+3eJcxZI2WOO/7Q=
-github.com/minio/crc64nvme v1.1.0/go.mod h1:eVfm2fAzLlxMdUGc0EEBGSMmPwmXD5XiNRpnu9J3bvg=
+github.com/miekg/dns v1.1.63 h1:8M5aAw6OMZfFXTT7K5V0Eu5YiiL8l7nUAkyN6C9YwaY=
+github.com/miekg/dns v1.1.63/go.mod h1:6NGHfjhpmr5lt3XPLuyfDJi5AXbNIPM9PY6H6sF1Nfs=
+github.com/minio/crc64nvme v1.1.1 h1:8dwx/Pz49suywbO+auHCBpCtlW1OfpcLN7wYgVR6wAI=
+github.com/minio/crc64nvme v1.1.1/go.mod h1:eVfm2fAzLlxMdUGc0EEBGSMmPwmXD5XiNRpnu9J3bvg=
 github.com/minio/md5-simd v1.1.2 h1:Gdi1DZK69+ZVMoNHRXJyNcxrMA4dSxoYHZSQbirFg34=
 github.com/minio/md5-simd v1.1.2/go.mod h1:MzdKDxYpY2BT9XQFocsiZf/NKVtR7nkE4RoEpN+20RM=
-github.com/minio/minio-go/v7 v7.0.97 h1:lqhREPyfgHTB/ciX8k2r8k0D93WaFqxbJX36UZq5occ=
-github.com/minio/minio-go/v7 v7.0.97/go.mod h1:re5VXuo0pwEtoNLsNuSr0RrLfT/MBtohwdaSmPPSRSk=
+github.com/minio/minio-go/v7 v7.2.0 h1:RCJM0R1XOsRs+A3x3UCaf3ZYbByDaLjFeAi+YCQEPhs=
+github.com/minio/minio-go/v7 v7.2.0/go.mod h1:EU9hENAStx/xXduNdrGO5e4X5vk19NtgB+RIPjZO8o0=
 github.com/mitchellh/cli v1.1.0/go.mod h1:xcISNoH86gajksDmfB23e/pu+B+GeFRMYmoHXxx3xhI=
 github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
 github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
@@ -236,12 +245,6 @@ github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJ
 github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
-github.com/nats-io/nats.go v1.48.0 h1:pSFyXApG+yWU/TgbKCjmm5K4wrHu86231/w84qRVR+U=
-github.com/nats-io/nats.go v1.48.0/go.mod h1:iRWIPokVIFbVijxuMQq4y9ttaBTMe0SFdlZfMDd+33g=
-github.com/nats-io/nkeys v0.4.11 h1:q44qGV008kYd9W1b1nEBkNzvnWxtRSQ7A8BoqRrcfa0=
-github.com/nats-io/nkeys v0.4.11/go.mod h1:szDimtgmfOi9n25JpfIdGw12tZFYXqhGxjhVxsatHVE=
-github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
-github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c=
 github.com/olekukonko/errors v1.1.0 h1:RNuGIh15QdDenh+hNvKrJkmxxjV4hcS50Db478Ou5sM=
 github.com/olekukonko/errors v1.1.0/go.mod h1:ppzxA5jBKcO1vIpCXQ9ZqgDh8iwODz6OXIGKU8r5m4Y=
 github.com/olekukonko/ll v0.0.9 h1:Y+1YqDfVkqMWuEQMclsF9HUR5+a82+dxJuL1HHSRpxI=
@@ -274,15 +277,14 @@ github.com/prometheus/common v0.9.1/go.mod h1:yhUN8i9wzaXS3w1O07YhxHEBxD+W35wd8b
 github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
 github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
 github.com/prometheus/procfs v0.0.8/go.mod h1:7Qr8sr6344vo1JqZ6HhLceV9o3AJ1Ff+GxbHq6oeK9A=
-github.com/rabbitmq/amqp091-go v1.10.0 h1:STpn5XsHlHGcecLmMFCtg7mqq0RnD+zFr4uzukfVhBw=
-github.com/rabbitmq/amqp091-go v1.10.0/go.mod h1:Hy4jKW5kQART1u+JkDTF9YYOQUHXqMuhrgxOEeS7G4o=
+github.com/r3labs/diff/v2 v2.15.1 h1:EOrVqPUzi+njlumoqJwiS/TgGgmZo83619FNDB9xQUg=
+github.com/r3labs/diff/v2 v2.15.1/go.mod h1:I8noH9Fc2fjSaMxqF3G2lhDdC0b+JXCfyx85tWFM9kc=
 github.com/redis/go-redis/v9 v9.12.1 h1:k5iquqv27aBtnTm2tIkROUDp8JBXhXZIVu1InSgvovg=
 github.com/redis/go-redis/v9 v9.12.1/go.mod h1:huWgSWd8mW6+m0VPhJjSSQ+d6Nh1VICQ6Q5lHuCH/Iw=
-github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
 github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ=
 github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
-github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
-github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
 github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
 github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
 github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
@@ -292,33 +294,40 @@ github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPx
 github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
 github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
 github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.2/go.mod h1:R6va5+xMeoiuVRoj+gSkQ7d3FALtqAAGI1FQKckRals=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
 github.com/tiger1103/gfast-token v1.0.10 h1:fNiBE/Dq5iTHvTGlCx3DmXa2o4hr0NtumFpffZ39k6s=
 github.com/tiger1103/gfast-token v1.0.10/go.mod h1:a/21mxmj7zFeNvjhZSC0XpEAFHfb1aT2k6DXnufFU1s=
-github.com/tinylib/msgp v1.3.0 h1:ULuf7GPooDaIlbyvgAxBV/FI7ynli6LZ1/nVUNu+0ww=
-github.com/tinylib/msgp v1.3.0/go.mod h1:ykjzy2wzgrlvpDCRc4LA8UXy6D8bzMSuAF3WD57Gok0=
+github.com/tinylib/msgp v1.6.1 h1:ESRv8eL3u+DNHUoSAAQRE50Hm162zqAnBoGv9PzScPY=
+github.com/tinylib/msgp v1.6.1/go.mod h1:RSp0LW9oSxFut3KzESt5Voq4GVWyS+PSulT77roAqEA=
 github.com/tv42/httpunix v0.0.0-20150427012821-b75d8614f926/go.mod h1:9ESjWnEqriFuLhtthL60Sar/7RFoluCcXsuvEwTV5KM=
-github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
-github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
-github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
-github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
-github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
-github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
-github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 h1:ilQV1hzziu+LLM3zUTJ0trRztfwgjqKnBWNtSRkbmwM=
-github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78/go.mod h1:aL8wCCfTfSfmXjznFBSZNN13rSJjlIOI1fUNAtF7rmI=
+github.com/vcaesar/cedar v0.30.0 h1:9fSDpM7FTjjUdPiBUUa0MWYMRGSEcqgFXvppZcZ4d7Y=
+github.com/vcaesar/cedar v0.30.0/go.mod h1:lyuGvALuZZDPNXwpzv/9LyxW+8Y6faN7zauFezNsnik=
+github.com/vcaesar/tt v0.20.1 h1:D/jUeeVCNbq3ad8M7hhtB3J9x5RZ6I1n1eZ0BJp7M+4=
+github.com/vcaesar/tt v0.20.1/go.mod h1:cH2+AwGAJm19Wa6xvEa+0r+sXDJBT0QgNQey6mwqLeU=
+github.com/vmihailenco/msgpack v4.0.4+incompatible h1:dSLoQfGFAo3F6OoNhwUmLwVgaUXK79GlxNBwueZn0xI=
+github.com/vmihailenco/msgpack v4.0.4+incompatible/go.mod h1:fy3FlTQTDXWkZ7Bh6AcGMlsjHatGryHQYUTf1ShIgkk=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
-github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
-go.mongodb.org/mongo-driver/v2 v2.4.1 h1:hGDMngUao03OVQ6sgV5csk+RWOIkF+CuLsTPobNMGNI=
-go.mongodb.org/mongo-driver/v2 v2.4.1/go.mod h1:jHeEDJHJq7tm6ZF45Issun9dbogjfnPySb1vXA7EeAI=
+github.com/zeebo/assert v1.3.0 h1:g7C04CbJuIDKNPFHmsk4hwZDO5O+kntRxzaUoNXj+IQ=
+github.com/zeebo/assert v1.3.0/go.mod h1:Pq9JiuJQpG8JLJdtkwrJESF0Foym2/D9XMU5ciN/wJ0=
+github.com/zeebo/xxh3 v1.1.0 h1:s7DLGDK45Dyfg7++yxI0khrfwq9661w9EN78eP/UZVs=
+github.com/zeebo/xxh3 v1.1.0/go.mod h1:IisAie1LELR4xhVinxWS5+zf1lA4p0MW4T+w+W07F5s=
+go.mongodb.org/mongo-driver/v2 v2.4.0 h1:Oq6BmUAAFTzMeh6AonuDlgZMuAuEiUxoAD1koK5MuFo=
+go.mongodb.org/mongo-driver/v2 v2.4.0/go.mod h1:jHeEDJHJq7tm6ZF45Issun9dbogjfnPySb1vXA7EeAI=
 go.opencensus.io v0.23.0 h1:gqCw0LfLxScz8irSi8exQc7fyQ0fKQU/qnC/X8+V/1M=
 go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
 go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
@@ -341,29 +350,32 @@ go.opentelemetry.io/proto/otlp v1.7.1 h1:gTOMpGDb0WTBOP8JaO72iL3auEZhVmAQg4ipjOV
 go.opentelemetry.io/proto/otlp v1.7.1/go.mod h1:b2rVh6rfI/s2pHWNlB7ILJcRALpcNDzKhACevjI+ZnE=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
+go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc=
+go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
 golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod h1:/lpIB1dKB+9EgE3H3cr1v9wB50oz8l4C4h62xy7jSTY=
 golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
-golang.org/x/crypto v0.44.0 h1:A97SsFvM3AIwEEmTBiaxPPTYpDC47w720rdiiUvgoAU=
-golang.org/x/crypto v0.44.0/go.mod h1:013i+Nw79BMiQiMsOPcVCB5ZIJbYkerPrGnOa00tvmc=
+golang.org/x/crypto v0.51.0 h1:IBPXwPfKxY7cWQZ38ZCIRPI50YLeevDLlLnyC5wRGTI=
+golang.org/x/crypto v0.51.0/go.mod h1:8AdwkbraGNABw2kOX6YFPs3WM22XqI4EXEd8g+x7Oc8=
 golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
-golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63 h1:m64FZMko/V45gv0bNmrNYoDEq8U5YUhetc9cBWKS1TQ=
-golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63/go.mod h1:0v4NqG35kSWCMzLaMeX+IQrlSnVE/bqGSyC2cz/9Le8=
+golang.org/x/exp v0.0.0-20250305212735-054e65f0b394 h1:nDVHiLt8aIbd/VzvPWN6kSOPE7+F/fNFDSXLVYkE/Iw=
+golang.org/x/exp v0.0.0-20250305212735-054e65f0b394/go.mod h1:sIifuuw/Yco/y6yb6+bDNfyeQ/MdPUy/hKEMYQV17cM=
 golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
 golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
 golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
 golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
 golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
-golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/mod v0.35.0 h1:Ww1D637e6Pg+Zb2KrWfHQUnH2dQRLBQyAtpr/haaJeM=
+golang.org/x/mod v0.35.0/go.mod h1:+GwiRhIInF8wPm+4AoT6L0FA1QWAad3OMdTRx4tFYlU=
 golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks=
 golang.org/x/net v0.0.0-20190613194153-d28f0bde5980/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20190923162816-aa69164e4478/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
@@ -372,9 +384,8 @@ golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwY
 golang.org/x/net v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-20210410081132-afb366fc7cd1/go.mod h1:9tjilg8BloeKEkVJvy7fQ90B1CfIiPueXVOjqfkSzI8=
-golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
-golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
-golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
+golang.org/x/net v0.53.0 h1:d+qAbo5L0orcWAr0a9JweQpjXF19LMXJE8Ey7hwOdUA=
+golang.org/x/net v0.53.0/go.mod h1:JvMuJH7rrdiCfbeHoo3fCQU24Lf5JJwT9W3sJFulfgs=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -383,9 +394,8 @@ golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJ
 golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.18.0 h1:kr88TuHDroi+UVf+0hZnirlk8o8T+4MrK6mr60WkH/I=
-golang.org/x/sync v0.18.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
+golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
+golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
 golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
@@ -404,27 +414,21 @@ golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210303074136-134d130e1a04/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210927094055-39ccf1dd6fa6/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220503163025-988cb79eb6c6/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220728004956-3c1f35247d10/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20221010170243-090e33056c14/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.38.0 h1:3yZWxaJjBmCWXqhN1qh02AkOnCQ1poK6oF+a7xWL6Gc=
-golang.org/x/sys v0.38.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
+golang.org/x/sys v0.44.0 h1:ildZl3J4uzeKP07r2F++Op7E9B29JRUy+a27EibtBTQ=
+golang.org/x/sys v0.44.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
-golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
-golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
-golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
-golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
+golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
+golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
@@ -434,7 +438,8 @@ golang.org/x/tools v0.0.0-20190907020128-2ca718005c18/go.mod h1:b+2E5dAYhXwXZwtn
 golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
 golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
-golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/tools v0.44.0 h1:UP4ajHPIcuMjT1GqzDWRlalUEoY+uzoZKnhOjbIPD2c=
+golang.org/x/tools v0.44.0/go.mod h1:KA0AfVErSdxRZIsOVipbv3rQhVXTnlU6UhKxHd1seDI=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
@@ -443,6 +448,9 @@ gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
 gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E=
 google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
 google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.6.6/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
+google.golang.org/appengine v1.6.7 h1:FZR1q0exgwxzPzp/aF+VccGrSfxfPpkBqjIIEq3ru6c=
+google.golang.org/appengine v1.6.7/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
 google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
 google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
 google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
@@ -466,13 +474,15 @@ google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2
 google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
 google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
 google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
-google.golang.org/protobuf v1.36.8 h1:xHScyCOEuuwZEc6UtSOvPbAT4zRh0xcNRYekJwfqyMc=
-google.golang.org/protobuf v1.36.8/go.mod h1:fuxRtAxBytpl4zzqUh6/eyUujkJdNiuEkXntxiD/uRU=
+google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
+google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
 gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
+gopkg.in/ini.v1 v1.67.2 h1:JtOSMb9OuaCZKr7h5D/h6iii14sK0hLbplTc6frx4Ss=
+gopkg.in/ini.v1 v1.67.2/go.mod h1:x/cyOwCgZqOkJoDIJ3c1KNHMo10+nLGAhh+kn3Zizss=
 gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
--- a/main.go
+++ b/main.go
@@ -6,12 +6,12 @@ import (
 	"oss/service"
 	"time"

+	"gitea.redpowerfuture.com/red-future/common/http"
+	"gitea.redpowerfuture.com/red-future/common/jaeger"
+	_ "github.com/gogf/gf/contrib/drivers/pgsql/v2"
+	_ "github.com/gogf/gf/contrib/nosql/redis/v2"
 	"github.com/gogf/gf/v2/os/glog"
 	"github.com/gogf/gf/v2/os/gtimer"
-
-	"gitea.com/red-future/common/http"
-	"gitea.com/red-future/common/jaeger"
-	_ "github.com/gogf/gf/contrib/nosql/redis/v2"
 )

 func main() {
@@ -30,18 +30,6 @@ func main() {
 		}
 	})

-	// 启动消息队列消费者
-	//if err := message.StartConsumers(ctx, &message.RedisMessageConfig{
-	//	StreamKey:    mongo.LogRedisKey,
-	//	GroupName:    consts.GroupName,
-	//	ConsumerName: consts.ConsumerName,
-	//	BatchSize:    consts.BatchSize,
-	//	AutoAck:      consts.AutoAck,
-	//	HandleFunc:   logService.OperationLog.AddOperationLog,
-	//}); err != nil {
-	//	return
-	//}
-
 	// 保持应用运行
 	select {}
 }
--- a/minio/minio.go
+++ b/minio/minio.go
@@ -0,0 +1,215 @@
+package minio
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"net/http"
+	"path/filepath"
+	"strings"
+	"time"
+
+	"gitea.redpowerfuture.com/red-future/common/utils"
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/net/ghttp"
+	"github.com/gogf/gf/v2/os/glog"
+	"github.com/google/uuid"
+	"github.com/minio/minio-go/v7"
+	"github.com/minio/minio-go/v7/pkg/credentials"
+)
+
+// IoConfig 映射 YAML 中的 minio 配置节点
+type IoConfig struct {
+	Endpoint  string `yaml:"endpoint"`  // MinIO API 地址
+	AccessKey string `yaml:"accessKey"` // AK
+	SecretKey string `yaml:"secretKey"` // SK
+	Secure    bool   `yaml:"secure"`    // 是否启用 SSL
+	Region    string `yaml:"region"`    // 区域
+}
+
+// 全局 MinIO 客户端（初始化一次，避免重复创建）
+var minioClient *minio.Client
+var minioCfg IoConfig
+
+// initMinIO 初始化 MinIO 客户端。
+func init() {
+	ctx := context.Background()
+	if !g.Cfg().MustGet(ctx, "minio").IsEmpty() {
+		// 加载 MinIO 配置（可从配置文件/环境变量读取，这里硬编码示例）
+		minioCfg = IoConfig{
+			Endpoint:  g.Cfg().MustGet(ctx, "minio.endpoint").String(),
+			AccessKey: g.Cfg().MustGet(ctx, "minio.accessKey").String(),
+			SecretKey: g.Cfg().MustGet(ctx, "minio.secretKey").String(),
+			Secure:    g.Cfg().MustGet(ctx, "minio.secure").Bool(),
+			Region:    g.Cfg().MustGet(ctx, "minio.region").String(),
+		}
+		// 创建 MinIO 客户端
+		var err error
+		if minioClient, err = minio.New(minioCfg.Endpoint, &minio.Options{
+			Creds:  credentials.NewStaticV4(minioCfg.AccessKey, minioCfg.SecretKey, ""),
+			Secure: minioCfg.Secure,
+			Region: minioCfg.Region,
+		}); err != nil {
+			glog.Errorf(ctx, "初始化 MinIO 客户端失败: %v", err)
+		}
+	}
+}
+
+// ensureBucketAndObjectName 确保桶存在，并生成对象名
+// 返回: bucketName, objectName, fileFormat, error
+func ensureBucketAndObjectName(ctx context.Context, fileName string, fileStoreURL string) (string, string, string, error) {
+	bucketName, err := utils.GetBucketName(ctx)
+	if err != nil {
+		glog.Errorf(ctx, "获取桶名称失败: %v", err)
+		return "", "", "", err
+	}
+	// 检查/创建桶
+	exists, err := minioClient.BucketExists(ctx, bucketName)
+	if err != nil {
+		glog.Errorf(ctx, "检查桶是否存在失败: %v", err)
+		return "", "", "", err
+	}
+	if !exists {
+		if err = minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{Region: minioCfg.Region}); err != nil {
+			glog.Errorf(ctx, "创建桶失败: %v", err)
+			return "", "", "", err
+		}
+		glog.Infof(ctx, "成功创建 MinIO 桶: %s", bucketName)
+	}
+	// 生成对象名
+	fileExt := filepath.Ext(fileName)
+	uniqueID := uuid.New().String()[:32]
+	timestamp := time.Now().Format("2006-01-02")
+	objectName := fmt.Sprintf("/%s/%s%s", timestamp, uniqueID, fileExt)
+	if fileStoreURL != "" {
+		objectName = fmt.Sprintf("/%s/%s/%s%s", timestamp, fileStoreURL, uniqueID, fileExt)
+	}
+	// 设置存储桶公共读权限
+	policy := `{"Version":"2012-10-17","Statement":[{"Effect":"Allow","Principal":{"AWS":["*"]},"Action":["s3:GetObject"],"Resource":["arn:aws:s3:::` + bucketName + `/*"]}]}`
+	if err = minioClient.SetBucketPolicy(ctx, bucketName, policy); err != nil {
+		glog.Errorf(ctx, "设置存储桶权限失败: %v", err)
+		return "", "", "", err
+	}
+	return bucketName, objectName, strings.TrimPrefix(fileExt, "."), nil
+}
+
+func UploadFile(ctx context.Context, fileHeader *ghttp.UploadFile) (imagesUrl string, fileName string, fileFormat string, err error) {
+	bucketName, objectName, fileFormat, err := ensureBucketAndObjectName(ctx, fileHeader.Filename, "")
+	if err != nil {
+		return
+	}
+	// 打开文件，获取 io.Reader（*os.File 实现了 io.Reader）
+	file, err := fileHeader.Open()
+	if err != nil {
+		glog.Errorf(ctx, "打开文件失败: %v", err)
+		return
+	}
+	defer file.Close() // 必须关闭，避免文件句柄泄露
+	// 获取文件类型
+	buffer := make([]byte, 512)
+	_, err = file.Read(buffer)
+	if err != nil {
+		glog.Errorf(ctx, "读取文件头失败: %v", err)
+		return
+	}
+	contentType := http.DetectContentType(buffer)
+	// 重置文件读取位置，否则后续 PutObject 会从第512字节开始上传
+	if _, err = file.Seek(0, 0); err != nil {
+		glog.Errorf(ctx, "重置文件读取位置失败: %v", err)
+		return
+	}
+	// 执行图片上传
+	_, err = minioClient.PutObject(
+		ctx,
+		bucketName,
+		objectName,
+		file,
+		fileHeader.Size,
+		minio.PutObjectOptions{
+			ContentType: contentType, // 关键：指定图片MIME类型，S3会根据此类型处理
+		},
+	)
+	if err != nil {
+		glog.Errorf(ctx, "上传图片失败: %v", err)
+		return
+	}
+	return objectName, fileHeader.Filename, fileFormat, nil
+}
+
+// DeleteFile 删除单个文件
+func DeleteFile(ctx context.Context, objectName string) (err error) {
+	bucketName, err := utils.GetBucketName(ctx)
+	if err != nil {
+		glog.Errorf(ctx, "获取桶名称失败: %v", err)
+		return
+	}
+	// 执行删除
+	err = minioClient.RemoveObject(ctx, bucketName, objectName, minio.RemoveObjectOptions{})
+	if err != nil {
+		glog.Errorf(ctx, "删除失败: %v\n", err)
+		return
+	}
+	return
+}
+
+func DownloadToFile(ctx context.Context, fileURL string, localPath string) (err error) {
+	bucketName, err := utils.GetBucketName(ctx) // 桶名
+	if err != nil {
+		glog.Errorf(ctx, "获取桶名称失败: %v", err)
+		return
+	}
+
+	fileName := filepath.Base(fileURL)
+	localPath = filepath.Join(localPath, fileName)
+
+	// 执行下载
+	err = minioClient.FGetObject(
+		ctx,
+		bucketName,
+		fileURL,
+		localPath,
+		minio.GetObjectOptions{}, // 可设置签名、加密等参数
+	)
+	if err != nil {
+		fmt.Println("下载失败:", err)
+		return
+	}
+
+	return
+}
+
+// DownloadToBrowser 下载文件到浏览器（返回 读取接口 + 文件名 + 类型 + 大小，不加载全量内存）
+func DownloadToBrowser(ctx context.Context, fileURL string) (reader io.Reader, fileName string, contentType string, fileSize int64, err error) {
+	bucketName, err := utils.GetBucketName(ctx)
+	if err != nil {
+		glog.Errorf(ctx, "获取桶名称失败: %v", err)
+		return
+	}
+
+	// 获取对象流
+	object, err := minioClient.GetObject(ctx, bucketName, fileURL, minio.GetObjectOptions{})
+	if err != nil {
+		glog.Errorf(ctx, "获取文件流失败: %v", err)
+		return
+	}
+
+	// 获取对象元信息
+	info, err := object.Stat()
+	if err != nil {
+		defer object.Close() // 出错必须关闭
+		glog.Errorf(ctx, "获取文件信息失败: %v", err)
+		return
+	}
+
+	// 直接返回流，不读取到内存
+	reader = object
+	fileName = filepath.Base(fileURL)
+	contentType = info.ContentType
+	fileSize = info.Size
+
+	if contentType == "" {
+		contentType = "application/octet-stream"
+	}
+
+	return
+}
--- a/model/dto/file_dto.go
+++ b/model/dto/file_dto.go
@@ -5,21 +5,42 @@ import (
 	"github.com/gogf/gf/v2/net/ghttp"
 )

+type DownloadToFileReq struct {
+	g.Meta    `path:"/downloadToFile" method:"post" tags:"存储管理" summary:"下载文件到本地" dc:"下载文件到本地"`
+	FileURL   string `json:"fileURL" dc:"文件URL"`
+	LocalPath string `json:"localPath" dc:"本地路径"`
+}
+
+// DownloadToBrowserReq 下载文件到浏览器请求
+type DownloadToBrowserReq struct {
+	g.Meta  `path:"/downloadToBrowser" method:"post" tags:"存储管理" summary:"下载文件到浏览器" dc:"下载文件到浏览器"`
+	FileURL string `json:"fileURL" dc:"文件URL" in:"query"`
+}
+
+type DeleteFileReq struct {
+	g.Meta  `path:"/deleteFile" method:"post" tags:"存储管理" summary:"删除文件" dc:"删除文件"`
+	FileURL string `json:"fileUrl" dc:"文件URL"` // 文件URL
+}
+
 // UploadFileReq 上传文件请求
 type UploadFileReq struct {
 	g.Meta `path:"/uploadFile" method:"post" tags:"存储管理" summary:"上传文件" dc:"上传文件"`
-	File   *ghttp.UploadFile `json:"file" type:"file"` // 文件URL
+	File   *ghttp.UploadFile  `json:"file" type:"file"`   // 文件URL
+	Files  *ghttp.UploadFiles `json:"files" type:"files"` // 文件URL
+}
+
+type UploadFile struct {
+	TenantId uint64 `json:"tenantId"`
+	FileURL  string `json:"fileURL"`
+	FileSize int    `json:"fileSize"`
 }

 // UploadFileRes 上传文件响应
 type UploadFileRes struct {
-	FileURL           string `json:"fileURL" dc:"上传地址"`
-	FileAddressPrefix string `json:"fileAddressPrefix"`
-}
-
-type TenantOssTotal struct {
-	TenantId     interface{} `json:"tenantId"`
-	UsedOssSize  int         `json:"usedOssSize"`
-	TotalOssSize int         `json:"totalOssSize"`
-	Updater      interface{} `json:"updater"`
+	FileURL           string           `json:"fileURL" dc:"上传地址"`
+	FileSize          int              `json:"fileSize" dc:"文件大小"`
+	FileName          string           `json:"fileName" dc:"文件名称"`
+	FileFormat        string           `json:"fileFormat" dc:"文件格式"`
+	FileAddressPrefix string           `json:"fileAddressPrefix"`
+	Items             []*UploadFileRes `json:"files"`
 }
--- a/model/dto/tenant_oss_total.go
+++ b/model/dto/tenant_oss_total.go
@@ -1,8 +1,9 @@
 package dto

 import (
-	"github.com/gogf/gf/v2/frame/g"
 	"oss/model/entity"
+
+	"github.com/gogf/gf/v2/frame/g"
 )

 // GetByTenantIdReq 根据租户id获取存储总量请求
@@ -20,12 +21,9 @@ type GetByTenantIdRes struct {
 type UpdateUsedOssReq struct {
 	g.Meta `path:"/GetOneByTenantId" method:"get" tags:"租户存储总量管理" summary:"更新使用存储总量" dc:"更新使用存储总量"`

-	TenantId     interface{} `json:"tenantId" v:"required#租户id不能为空"`
-	UsedOssSize  int         `bson:"usedOssSize"  json:"usedOssSize"`
-	TotalOssSize int         `bson:"totalOssSize" json:"totalOssSize"`
-	Updater      interface{} `json:"updater" v:"required#更新人不能为空"`
-}
-
-// UpdateUsedOssRes 更新使用存储总量响应
-type UpdateUsedOssRes struct {
+	TenantId     uint64 `json:"tenantId" v:"required#租户id不能为空"`
+	UsedOssSize  int    `json:"usedOssSize"`
+	TotalOssSize int    `json:"totalOssSize"`
+	Creator      string `json:"creator"`
+	Updater      string `json:"updater"`
 }
--- a/model/entity/file.go
+++ b/model/entity/file.go
@@ -1,20 +1,25 @@
 package entity

 import (
-	"oss/consts"
-
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
 )

 // File 存储文件实体
 type File struct {
-	beans.MongoBaseDO `bson:",inline"` // 嵌入基础字段：Id, Creator, CreatedAt, Updater, UpdatedAt, TenantId, IsDeleted
-	// 基础信息
-	FileURL  string `bson:"fileURL"  json:"fileURL"` // 图URL
-	FileSize int    `bson:"fileSize" json:"fileSize"`
+	beans.SQLBaseDO `orm:",inherit"` // 嵌入基础字段：Id, Bid, Creator, CreatedAt, Updater, UpdatedAt, Deleter, DeletedAt, IsDeleted
+	// 业务字段
+	FileURL  string `orm:"file_url"  json:"fileURL"` // 文件URL
+	FileSize int    `orm:"file_size" json:"fileSize"`
 }

-// CollectionName 存储集合名称
-func (File) CollectionName() string {
-	return consts.FileCollection
+type fileCol struct {
+	beans.SQLBaseCol
+	FileURL  string
+	FileSize string
+}
+
+var FileCol = fileCol{
+	SQLBaseCol: beans.DefSQLBaseCol,
+	FileURL:    "file_url",
+	FileSize:   "file_size",
 }
--- a/model/entity/tenant_oss_total.go
+++ b/model/entity/tenant_oss_total.go
@@ -1,20 +1,25 @@
 package entity

 import (
-	"oss/consts"
-
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
 )

 // TenantOssTotal 租户储存服务总计实体
 type TenantOssTotal struct {
-	beans.MongoBaseDO `bson:",inline"` // 嵌入基础字段：Id, Creator, CreatedAt, Updater, UpdatedAt, TenantId, IsDeleted
+	beans.SQLBaseDO `orm:",inherit"` // 嵌入基础字段：Id, Creator, CreatedAt, Updater, UpdatedAt, TenantId, IsDeleted
 	// 基础信息
-	UsedOssSize  int `bson:"usedOssSize"  json:"usedOssSize"`
-	TotalOssSize int `bson:"totalOssSize" json:"totalOssSize"`
+	UsedOssSize  int `orm:"used_oss_size"  json:"usedOssSize"`
+	TotalOssSize int `orm:"total_oss_size" json:"totalOssSize"`
 }

-// CollectionName 租户储存服务总计集合名称
-func (TenantOssTotal) CollectionName() string {
-	return consts.TenantOssTotalCollection
+type tenantOssCol struct {
+	beans.SQLBaseCol
+	UsedOssSize  string
+	TotalOssSize string
+}
+
+var TenantOssCol = tenantOssCol{
+	SQLBaseCol:   beans.DefSQLBaseCol,
+	UsedOssSize:  "used_oss_size",
+	TotalOssSize: "total_oss_size",
 }
--- a/service/file_service.go
+++ b/service/file_service.go
@@ -3,16 +3,19 @@ package service
 import (
 	"context"
 	"fmt"
-	"github.com/gogf/gf/v2/os/glog"
+	"io"
+	"net/url"
 	"oss/consts"
 	"oss/dao"
+	"oss/minio"
 	"oss/model/dto"
 	"oss/model/entity"
 	"time"

-	"gitea.com/red-future/common/minio"
-	"gitea.com/red-future/common/redis"
-	"gitea.com/red-future/common/utils"
+	"github.com/gogf/gf/v2/net/ghttp"
+	"github.com/gogf/gf/v2/os/glog"
+
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/util/gconv"
@@ -23,27 +26,143 @@ type file struct{}
 // File 存储文件服务
 var File = new(file)

-func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto.UploadFileRes, err error) {
-	fileSize := gconv.Int(req.File.Size)
-	totalFileSize := 0
-	// 获取租户id
-	user, err := utils.GetUserInfo(ctx)
+func (f *file) DownloadToFile(ctx context.Context, req *dto.DownloadToFileReq) (err error) {
+	return minio.DownloadToFile(ctx, req.FileURL, req.LocalPath)
+}
+
+// DownloadToBrowser 下载文件到浏览器
+func (f *file) DownloadToBrowser(ctx context.Context, req *dto.DownloadToBrowserReq) (err error) {
+	// 拿到流，而不是全量字节数组
+	reader, fileName, contentType, fileSize, err := minio.DownloadToBrowser(ctx, req.FileURL)
 	if err != nil {
+		return err
+	}
+
+	// 重要：确保流最后关闭
+	if closer, ok := reader.(io.Closer); ok {
+		defer closer.Close()
+	}
+
+	r := ghttp.RequestFromCtx(ctx)
+	resp := r.Response
+
+	resp.Header().Set("Content-Type", contentType)
+	resp.Header().Set("Content-Disposition", fmt.Sprintf(
+		`attachment; filename="%s"; filename*=UTF-8''%s`,
+		fileName, url.PathEscape(fileName),
+	))
+	resp.Header().Set("Content-Length", fmt.Sprintf("%d", fileSize))
+	resp.Header().Del("Content-Encoding")
+	resp.Header().Del("Transfer-Encoding")
+	data, err := io.ReadAll(reader)
+	if err != nil {
+		return err
+	}
+	resp.WriteExit(data)
+	return
+}
+
+func (f *file) DeleteFile(ctx context.Context, req *dto.DeleteFileReq) (err error) {
+	return minio.DeleteFile(ctx, req.FileURL)
+}
+
+func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto.UploadFileRes, err error) {
+	fileReq := new(dto.UploadFileReq)
+	if !g.IsEmpty(req.File) {
+		fileReq.Files = &ghttp.UploadFiles{req.File}
+		files, err := f.UploadFiles(ctx, fileReq)
+		if err != nil {
+			return nil, err
+		}
+		res = files.Items[0]
+	} else if !g.IsEmpty(req.Files) {
+		fileReq.Files = req.Files
+		res, err = f.UploadFiles(ctx, fileReq)
+	} else {
+		return nil, gerror.New("上传内容不能为空")
+	}
+	return
+}
+
+// UploadFiles 上传多个文件（新接口）
+func (f *file) UploadFiles(ctx context.Context, req *dto.UploadFileReq) (res *dto.UploadFileRes, err error) {
+	var files = *req.Files
+
+	totalAdd := 0
+	for _, file := range files {
+		if file == nil {
+			continue
+		}
+		totalAdd += gconv.Int(file.Size)
+	}
+	tenantId, err := f.reserveTenantOssSize(ctx, totalAdd)
+	if err != nil {
+		return nil, err
+	}
+
+	prefix, _ := utils.GetFileAddressPrefix(ctx)
+	items := make([]*dto.UploadFileRes, 0, len(files))
+
+	for _, file := range files {
+		if file == nil {
+			continue
+		}
+
+		fileURL, fileName, fileFormat, e := minio.UploadFile(ctx, file)
+		if e != nil {
+			glog.Errorf(ctx, "上传文件失败: %v", e)
+			return nil, e
+		}
+
+		ossEntity := &dto.UploadFile{
+			TenantId: tenantId,
+			FileURL:  fileURL,
+			FileSize: gconv.Int(file.Size),
+		}
+		if _, e = dao.File.Insert(ctx, ossEntity); e != nil {
+			return nil, e
+		}
+
+		items = append(items, &dto.UploadFileRes{
+			FileURL:           fileURL,
+			FileSize:          gconv.Int(file.Size),
+			FileName:          fileName,
+			FileFormat:        fileFormat,
+			FileAddressPrefix: prefix,
+		})
+	}
+	fileRes := &dto.UploadFileRes{
+		FileAddressPrefix: prefix,
+		Items:             items,
+	}
+	return fileRes, nil
+}
+
+func (f *file) reserveTenantOssSize(ctx context.Context, addSize int) (tenantId uint64, err error) {
+	if addSize < 0 {
+		err = gerror.New("addSize 不能为负数")
+		return
+	}
+	// 获取租户id
+	user, e := utils.GetUserInfo(ctx)
+	if e != nil {
+		err = e
 		glog.Errorf(ctx, "获取用户信息失败: %v", err)
 		return
 	}
-	tenantId := user.TenantId
+	tenantId = user.TenantId
+
 	// 获取redis-租户存储容量总数key
 	tenantOssTotalKey := fmt.Sprintf(consts.TenantOssTotalKey, gconv.String(user.TenantId))
 	// 获取redis-租户存储-锁key
 	fileLockKey := fmt.Sprintf(consts.FileLockKey, gconv.String(user.TenantId))

-	success, err := redis.Lock(ctx, fileLockKey, gconv.Int64(time.Minute*1), func(ctx context.Context) error {
+	success, e := utils.Lock(ctx, fileLockKey, gconv.Int64(time.Minute*1), func(ctx context.Context) error {
 		// 获取redis-租户存储容量总数
-		get, err := redis.RedisClient().Get(ctx, tenantOssTotalKey)
-		if err != nil {
-			glog.Errorf(ctx, "获取redis-租户存储容量总数失败: %v", err)
-			return err
+		get, e := g.Redis().Get(ctx, tenantOssTotalKey)
+		if e != nil {
+			glog.Errorf(ctx, "获取redis-租户存储容量总数失败: %v", e)
+			return e
 		}
 		tenantOssTotalEntity := &entity.TenantOssTotal{}
 		if g.IsEmpty(get) {
@@ -51,69 +170,55 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 			getByTenantIdReq := &dto.GetByTenantIdReq{
 				TenantId: user.TenantId,
 			}
-			tenantOssTotalRes, err := TenantOssTotal.GetOneByTenantId(ctx, getByTenantIdReq)
-			if err != nil {
-				glog.Errorf(ctx, "查询数据库-获取租户存储容量总数失败: %v", err)
-				return err
+			tenantOssTotalRes, e := dao.TenantOssTotal.GetOneByTenantId(ctx, getByTenantIdReq)
+			if e != nil {
+				glog.Errorf(ctx, "查询数据库-获取租户存储容量总数失败: %v", e)
+				return e
 			}
-			if tenantOssTotalRes == nil || tenantOssTotalRes.TenantOssTotal == nil || g.IsEmpty(tenantOssTotalRes.Id) || tenantOssTotalRes.Id.IsZero() {
+			if tenantOssTotalRes == nil || g.IsEmpty(tenantOssTotalRes.Id) {
 				// 数据库中没有该租户的记录，创建默认配置
 				tenantOssTotalEntity.TenantId = user.TenantId
 				tenantOssTotalEntity.UsedOssSize = 0
 				tenantOssTotalEntity.TotalOssSize = g.Cfg().MustGet(ctx, "oss.capacitySize").Int() * 1024 * 1024
 			} else {
-				tenantOssTotalEntity = tenantOssTotalRes.TenantOssTotal
+				tenantOssTotalEntity = tenantOssTotalRes
 			}
 		} else {
 			// 反序列化-redis获取租户存储容量总数
-			if err = gconv.Struct(get, tenantOssTotalEntity); err != nil {
-				glog.Errorf(ctx, "反序列化-redis获取租户存储容量总数失败: %v", err)
-				return err
+			if e = gconv.Struct(get, tenantOssTotalEntity); e != nil {
+				glog.Errorf(ctx, "反序列化-redis获取租户存储容量总数失败: %v", e)
+				return e
 			}
 		}
 		tenantId = tenantOssTotalEntity.TenantId
-		fileSize = tenantOssTotalEntity.UsedOssSize + fileSize
-		totalFileSize = tenantOssTotalEntity.TotalOssSize
-		// 设置redis-租户存储容量总数
-		tenantOssTotalKeyMap := dto.TenantOssTotal{
+		usedAfter := tenantOssTotalEntity.UsedOssSize + addSize
+		total := tenantOssTotalEntity.TotalOssSize
+
+		if usedAfter > total {
+			return gerror.New("存储服务内存不足")
+		}
+
+		// 设置redis-租户存储容量总数（超时时间10分钟）
+		tenantOssTotalKeyMap := dto.UpdateUsedOssReq{
 			TenantId:     tenantId,
-			UsedOssSize:  fileSize,
-			TotalOssSize: totalFileSize,
+			UsedOssSize:  usedAfter,
+			TotalOssSize: total,
+			Creator:      user.UserName,
 			Updater:      user.UserName,
 		}
-		// 修改redis-租户存储容量总数 超时时间10分钟
-		if err = redis.RedisClient().SetEX(ctx, tenantOssTotalKey, tenantOssTotalKeyMap, gconv.Int64(time.Minute*10)); err != nil {
-			glog.Errorf(ctx, "修改redis-租户存储容量总数 超时时间10分钟失败: %v", err)
-			return err
-		}
-		if fileSize > totalFileSize {
-			return gerror.New("存储服务内存不足")
+		if e = g.Redis().SetEX(ctx, tenantOssTotalKey, tenantOssTotalKeyMap, gconv.Int64(time.Minute*10)); e != nil {
+			glog.Errorf(ctx, "修改redis-租户存储容量总数失败: %v", e)
+			return e
 		}
 		return nil
 	})
-	if err != nil {
-		return nil, err
+	if e != nil {
+		err = e
+		return
 	}
 	if !success {
-		return nil, gerror.New("存储服务内存不足")
+		err = gerror.New("存储服务内存不足")
+		return
 	}
-	// 上传图片
-	fileURL, err := minio.UploadFile(ctx, req.File)
-	if err != nil {
-		glog.Errorf(ctx, "上传图片失败: %v", err)
-		return nil, err
-	}
-	// 插入数据库
-	ossEntity := &entity.File{
-		FileURL:  fileURL,
-		FileSize: fileSize,
-	}
-	if err = dao.File.Insert(ctx, ossEntity); err != nil {
-		return nil, err
-	}
-	// 返回图片url
-	return &dto.UploadFileRes{
-		FileURL:           fileURL,
-		FileAddressPrefix: minio.GetFileAddressPrefix(ctx),
-	}, err
+	return
 }
--- a/service/tenant_oss_total_service.go
+++ b/service/tenant_oss_total_service.go
@@ -2,12 +2,13 @@ package service

 import (
 	"context"
-	"gitea.com/red-future/common/redis"
-	"github.com/gogf/gf/v2/frame/g"
-	"github.com/gogf/gf/v2/util/gconv"
 	"oss/consts"
 	"oss/dao"
 	"oss/model/dto"
+
+	"gitea.redpowerfuture.com/red-future/common/beans"
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/util/gconv"
 )

 type tenantOssTotal struct{}
@@ -15,19 +16,12 @@ type tenantOssTotal struct{}
 // TenantOssTotal 存储文件服务
 var TenantOssTotal = new(tenantOssTotal)

-func (s *tenantOssTotal) GetOneByTenantId(ctx context.Context, req *dto.GetByTenantIdReq) (res *dto.GetByTenantIdRes, err error) {
-	e, err := dao.TenantOssTotal.GetOneByTenantId(ctx, req)
-	if err != nil {
-		return nil, err
-	}
-	return &dto.GetByTenantIdRes{
-		TenantOssTotal: e,
-	}, nil
-}
-
 func (s *tenantOssTotal) UpdateUsedOssSize(ctx context.Context) (err error) {
+	ctx = context.WithValue(ctx, "user", &beans.User{
+		UserName: "admin",
+	})
 	// 使用 Keys 取出所有key
-	keys, err := redis.RedisClient().Keys(ctx, consts.OssTotalKey)
+	keys, err := g.Redis().Keys(ctx, consts.OssTotalKey)
 	if err != nil {
 		return
 	}
@@ -45,10 +39,12 @@ func (s *tenantOssTotal) UpdateUsedOssSize(ctx context.Context) (err error) {
 		updateData = append(updateData, e)

 	}
-	// 更新数据库
-	err = dao.TenantOssTotal.SaveOrUpdate(ctx, updateData)
-	if err != nil {
-		return err
+	if len(updateData) != 0 {
+		// 更新数据库
+		_, err = dao.TenantOssTotal.SaveOrUpdate(ctx, updateData)
+		if err != nil {
+			return err
+		}
 	}
 	return err
 }
--- a/update.sql
+++ b/update.sql
@@ -1 +1,74 @@
-----------张斌2025-06-16 15:00:00--------------
+-----------张斌2025-06-16 15:00:00--------------
+
+--------------------pgsql创建oss_file表语句---------------------------
+
+-- 存储文件表
+CREATE TABLE IF NOT EXISTS oss_file (
+    -- 基础字段
+    id BIGINT PRIMARY KEY,
+    creator VARCHAR(64) NOT NULL,
+    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updater VARCHAR(64) NOT NULL,
+    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    deleted_at timestamp(6),
+
+    -- 文件核心字段
+    tenant_id BIGINT NOT NULL,
+    file_url VARCHAR(512) NOT NULL,
+    file_size INT NOT NULL DEFAULT 0
+);
+-- 为文件表添加索引
+CREATE INDEX idx_file_tenant_id ON oss_file(tenant_id);
+CREATE INDEX idx_file_file_size ON oss_file(file_size);
+
+-- 文件表字段注释
+COMMENT ON TABLE oss_file IS '存储文件表';
+COMMENT ON COLUMN oss_file.id IS '主键ID';
+COMMENT ON COLUMN oss_file.creator IS '创建人';
+COMMENT ON COLUMN oss_file.created_at IS '创建时间';
+COMMENT ON COLUMN oss_file.updater IS '更新人';
+COMMENT ON COLUMN oss_file.updated_at IS '更新时间';
+COMMENT ON COLUMN oss_file.deleted_at IS '删除时间（软删）';
+COMMENT ON COLUMN oss_file.tenant_id IS '租户ID';
+COMMENT ON COLUMN oss_file.file_url IS '文件URL';
+COMMENT ON COLUMN oss_file.file_size IS '文件大小（字节）';
+
+--------------------pgsql创建oss_file表语句---------------------------
+
+--------------------pgsql创建oss_tenant_oss_total表语句---------------------------
+-- 租户存储服务总计表
+CREATE TABLE IF NOT EXISTS oss_tenant_oss_total (
+    -- 基础字段
+    id BIGINT PRIMARY KEY,  -- 保留id作为主键
+    creator VARCHAR(64) NOT NULL,
+    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updater VARCHAR(64) NOT NULL,
+    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    deleted_at timestamp(6),
+
+    -- 租户存储字段
+    tenant_id BIGINT NOT NULL,
+    used_oss_size INT NOT NULL DEFAULT 0,
+    total_oss_size INT NOT NULL DEFAULT 0,
+
+    -- 唯一索引（仅约束tenant_id唯一性，不替代主键）
+    CONSTRAINT uk_tenant_oss_total_tenant_id UNIQUE (tenant_id)
+);
+
+-- 为租户存储表添加索引
+CREATE INDEX idx_tenant_oss_total_used_size ON oss_tenant_oss_total(used_oss_size);
+CREATE INDEX idx_tenant_oss_total_total_size ON oss_tenant_oss_total(total_oss_size);
+
+-- 租户存储表字段注释
+COMMENT ON TABLE oss_tenant_oss_total IS '租户存储服务总计表';
+COMMENT ON COLUMN oss_tenant_oss_total.id IS '主键ID';
+COMMENT ON COLUMN oss_tenant_oss_total.creator IS '创建人';
+COMMENT ON COLUMN oss_tenant_oss_total.created_at IS '创建时间';
+COMMENT ON COLUMN oss_tenant_oss_total.updater IS '更新人';
+COMMENT ON COLUMN oss_tenant_oss_total.updated_at IS '更新时间';
+COMMENT ON COLUMN oss_tenant_oss_total.deleted_at IS '删除时间（软删）';
+COMMENT ON COLUMN oss_tenant_oss_total.tenant_id IS '租户ID（唯一）';
+COMMENT ON COLUMN oss_tenant_oss_total.used_oss_size IS '已使用存储大小（字节）';
+COMMENT ON COLUMN oss_tenant_oss_total.total_oss_size IS '总存储大小（字节）';
+
+--------------------pgsql创建oss_tenant_oss_total表语句---------------------------
Author	SHA1	Message	Date
qhd	625ec05599	feat: 新增删除文件接口并支持多文件上传 - 新增 DeleteFile 接口，支持通过文件 URL 删除文件 - UploadFile 接口支持多文件上传，返回结果包含文件列表 - DownloadToBrowser 改为流式读取，避免大文件占用内存 - 移除 UploadFileBytes 字节流上传接口 - 修复租户存储容量校验顺序，先校验容量再写入 Redis	2026-06-11 09:14:45 +08:00
张斌	99cbdec579	ci/cd调整	2026-06-10 16:30:36 +08:00
张斌	69cbec24d4	common版本更新	2026-04-22 18:00:33 +08:00
张斌	d5a6b53bb0	dockerfile修改	2026-04-22 14:25:48 +08:00
张斌	aad37f1b6f	dockerfile修改	2026-04-22 13:57:39 +08:00
qhd	30e961cecc	chore: 更新MinIO服务端口配置	2026-04-22 13:02:33 +08:00
qhd	033fc33150	chore: 更新MinIO服务端口配置	2026-04-22 13:00:31 +08:00
qhd	3055b15855	feat: 添加下载文件到浏览器功能	2026-04-22 12:49:27 +08:00
张斌	98f0082d44	dockerfile修改	2026-04-22 11:35:59 +08:00
张斌	89c8d06bcf	dockerfile修改	2026-04-22 11:31:10 +08:00
qhd	7fa8b6eb7d	feat: 添加文件下载及字节流上传功能	2026-04-22 08:45:45 +08:00
张斌	2181cab5a5	网络环境调整	2026-04-20 20:04:03 +08:00
张斌	ac98d52472	网络环境调整	2026-04-20 19:47:45 +08:00
qhd	f297ca9d12	refactor: 将Redis客户端迁移至g.Redis并添加MinIO支持	2026-04-15 17:00:09 +08:00
张斌	076aa26036	网络环境调整	2026-04-13 13:25:40 +08:00
qhd	00018cb47e	chore: 移除未使用的配置导入	2026-04-11 18:44:44 +08:00
qhd	6699d8ac32	chore: 移除未使用的 config 导入	2026-04-11 18:39:09 +08:00
张斌	76f4f0b4d2	增加dockerfile配置	2026-04-09 17:42:57 +08:00
张斌	5d33124e52	增加dockerfile配置	2026-04-09 16:14:32 +08:00
张斌	2786c69949	增加dockerfile配置	2026-04-09 15:58:05 +08:00
张斌	81846cb1e9	增加dockerfile配置	2026-04-09 09:07:12 +08:00
张斌	9e5c546f1d	测试服务器IP配置变更	2026-04-08 22:14:22 +08:00
qhd	662a2f13c5	refactor: 添加表名前缀配置及重构数据库表名	2026-04-03 15:10:38 +08:00
张斌	47c569f6fb	golang版本升级1.26.0	2026-04-03 11:39:34 +08:00
张斌	1ae15aeb08	golang版本升级1.26.0	2026-04-03 11:05:05 +08:00
张斌	311bf643d0	Dockerfile	2026-04-01 14:05:31 +08:00
张斌	c856c6e2c3	Dockerfile	2026-04-01 13:49:16 +08:00
张斌	269771f982	Dockerfile	2026-04-01 13:16:32 +08:00
张斌	4d8cabacc5	Merge remote-tracking branch 'origin/dev' into dev	2026-04-01 13:05:42 +08:00
张斌	06b3f40905	Dockerfile	2026-04-01 13:04:59 +08:00
qhd	508f139da2	refactor: 优化数据库查询构建链式调用	2026-03-27 14:55:45 +08:00
qhd	7b8caaca53	refactor: 重命名集合常量并优化配置注释	2026-03-27 10:59:54 +08:00
qhd	12a743d8da	refactor: 将分布式锁从 redis 迁移至 utils 包	2026-03-27 09:49:45 +08:00
qhd	19d62ab927	Generating commit message...	2026-03-24 16:23:04 +08:00
张斌	1d6eb7a03b	Dockerfile	2026-03-19 17:39:51 +08:00
qhd	39fd187502	refactor: 移除业务ID字段并优化DAO层实现	2026-03-19 17:35:38 +08:00
qhd	8e2ea0bde1	perf: 优化租户OSS总计存储逻辑	2026-03-18 14:26:15 +08:00
qhd	63681c3a91	chore: 更新 MinIO 访问凭据	2026-03-18 13:33:24 +08:00
qhd	3ed275bd7e	refactor: 将数据库从MongoDB迁移至PostgreSQL	2026-03-18 13:17:59 +08:00
张斌	16723e5b5e	.gitignore	2026-03-16 11:36:41 +08:00
张斌	dae562c3be	.gitignore	2026-03-16 08:59:37 +08:00
张斌	4ca0cf6ceb	.gitignore	2026-03-14 18:30:37 +08:00
张斌	3ddd4a4911	1	2026-03-12 10:41:44 +08:00
张斌	ec2096dae4	.gitignore	2026-02-27 16:37:39 +08:00