Dockerfile

config.yml

@@ -1,18 +1,49 @@
 server:
   address: ":3008"
   name: "oss"
+  workerId: 1
 rate:
   limit: 200
   burst: 300
-mongo:
+
+# Database.
+database:
   default:
-    address: "116.204.74.41:17027"
+    - type: "pgsql"
-    username: "root"
+      host: "116.204.74.41"
-    password: "M0ng0DB@Pass2026!"
+      port: "15432"
-    database: "oss"
+      user: "postgres"
-    maxPoolSize: 100
+      pass: "123456"
-    minPoolSize: 10
+      name: "oss"
-    connectTimeout: "10s"
+      role: "master"
+      maxIdle: "5"
+      maxOpen: "20"
+      maxLifetime: "60s"
+      charset: "utf8mb4" #数据库编码
+      debug: true
+      dryRun: false #空跑
+      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: "123456"
+      name: "oss"
+      role: "slave"
+      maxIdle: "5"
+      maxOpen: "20"
+      maxLifetime: "60s"
+      charset: "utf8mb4" #数据库编码
+      debug: true
+      dryRun: false #空跑
+      createdAt: "created_at"     # (可选)自动创建时间字段名称
+      updatedAt: "updated_at"     # (可选)自动更新时间字段名称
+      deletedAt: "deleted_at"     # (可选)软删除时间字段名称
+      timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性，为true时CreatedAt/UpdatedAt/DeletedAt都将失效
+
 redis:
   # 集群模式配置方法
   default:
@@ -34,8 +65,8 @@ jaeger: #链路追踪
 # MinIO 连接配置
 minio:
   endpoint: "116.204.74.41:9000"       # 核心：仅协议+主机+端口，无路径/末尾斜杠
-  accessKey: "rag_flow"                # 访问密钥（本地默认）
+  accessKey: "admin"                # 访问密钥（本地默认）
-  secretKey: "infini_rag_flow"                # 秘密密钥（本地默认）
+  secretKey: "12345678"                # 秘密密钥（本地默认）
   secure: false                           # 本地 MinIO 关闭 SSL（生产按需改为 true）
   region: "us-east-1"                     # 与 MinIO 服务端 REGION 一致（默认 us-east-1）
 
@@ -44,4 +75,8 @@ filePrefix: "116.204.74.41:9000"
 
 # 文件存储初始化容量大小配置
 oss:
-  capacitySize: 500 #文件存储初始化容量（单位MB）
+  capacitySize: 500 #文件存储初始化容量（单位MB）
+
+cache:
+  localTTL: 60
+  redisTTL: 300

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.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) {
+func (d *file) Insert(ctx context.Context, req *dto.UploadFile) (id int64, err error) {
-	_, err = mongo.DB().Insert(ctx, []interface{}{&entity}, consts.FileCollection)
+	var res *entity.File
-	return
+	if err = gconv.Struct(req, &res); err != nil {
+		return
+	}
+	r, err := gfdb.DB(ctx).Model(ctx, consts.FileCollection).Insert(&res)
+	if err != nil {
+		return
+	}
+	return r.LastInsertId()
 }

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
-}

dao/tenant_oss_total.go

@@ -6,38 +6,33 @@ import (
 	"oss/model/dto"
 	"oss/model/entity"
 
-	"gitea.com/red-future/common/db/mongo"
+	"gitea.com/red-future/common/db/gfdb"
-	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/util/gconv"
-	"go.mongodb.org/mongo-driver/v2/bson"
 )
 
 var TenantOssTotal = &tenantOssTotal{}
 
-type tenantOssTotal struct {
+type tenantOssTotal struct{}
-}
 
 // SaveOrUpdate 增加或更新
-func (d *tenantOssTotal) SaveOrUpdate(ctx context.Context, updateData []*dto.UpdateUsedOssReq) (err error) {
+func (d *tenantOssTotal) SaveOrUpdate(ctx context.Context, updateData []*dto.UpdateUsedOssReq) (rows int64, err error) {
-	if !g.IsEmpty(updateData) {
+	var res []*entity.TenantOssTotal
-		var filter, update []bson.M
+	if err = gconv.Structs(updateData, &res); err != nil {
-		for _, v := range updateData {
+		return
-			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
-		}
 	}
-	return
+	r, err := gfdb.DB(ctx).Model(ctx, consts.TenantOssTotalCollection).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}
+	model := gfdb.DB(ctx).Model(ctx, consts.TenantOssTotalCollection).Where(entity.TenantOssCol.TenantId, req.TenantId)
-	err = mongo.DB().FindOne(ctx, filter, &res, consts.TenantOssTotalCollection)
+	record, err := model.One()
+	if err != nil {
+		return
+	}
+	err = record.Struct(&res)
 	return
 }

go.mod

@@ -1,19 +1,20 @@
 module oss
 
-go 1.25.3
+go 1.26.0
 
 require (
-	gitea.com/red-future/common v0.0.2
+	gitea.com/red-future/common v0.0.4
+	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.0
 	github.com/gogf/gf/contrib/nosql/redis/v2 v2.9.5
-	github.com/gogf/gf/v2 v2.9.5
+	github.com/gogf/gf/v2 v2.10.0
-	go.mongodb.org/mongo-driver/v2 v2.4.1
 )
 
-// replace gitea.com/red-future/common => ../common
+//replace gitea.com/red-future/common => ../common
 
 require (
 	github.com/BurntSushi/toml v1.5.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
@@ -21,7 +22,7 @@ require (
 	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/emirpasic/gods/v2 v2.0.0-alpha // indirect
 	github.com/fatih/color v1.18.0 // indirect
 	github.com/fsnotify/fsnotify v1.9.0 // indirect
 	github.com/go-ini/ini v1.67.0 // indirect
@@ -47,11 +48,12 @@ 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/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
@@ -61,15 +63,11 @@ require (
 	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/redis/go-redis/v9 v9.12.1 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/rs/xid v1.6.0 // indirect
@@ -80,6 +78,7 @@ require (
 	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
+	go.mongodb.org/mongo-driver/v2 v2.4.1 // 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,8 +88,8 @@ 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/crypto v0.45.0 // indirect
-	golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63 // indirect
+	golang.org/x/exp v0.0.0-20250128144449-3edf0e91c1ae // 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

go.sum

@@ -1,6 +1,6 @@
 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.4 h1:2QgKc+B2iNfPRncKpmIqIzVwaMGJ3y3dt5v+35YD8SU=
-gitea.com/red-future/common v0.0.2/go.mod h1:CUurYN0elToJTwB2pX9wSnjQqZv9D/Vxbo5ueb7i9BI=
+gitea.com/red-future/common v0.0.4/go.mod h1:UI9N5UUjilbMPF7+/lypZSnqDVHigt14300oSRrAyZg=
 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=
@@ -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=
@@ -50,8 +52,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/v2 v2.0.0-alpha h1:dwFlh8pBg1VMOXWGipNMRt8v96dKAIvBehtCt6OtunU=
-github.com/emirpasic/gods v1.18.1/go.mod h1:8tpGGwCnJ5H4r6BWwaV6OrWmMoPhUl5jm/FMNAnJvWQ=
+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=
@@ -75,14 +77,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/drivers/pgsql/v2 v2.10.0 h1:39+jbTenm7KBj4hO2C8ANAxVHpX/7OuRDs1VcGC9ylA=
+github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.0/go.mod h1:B0s0fVzn0W220E8UTpSGzrrGKsop5KcB90twBeLCiz0=
 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/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.10.0 h1:rzDROlyqGMe/eM6dCalSR8dZOuMIdLhmxKSH1DGhbFs=
-github.com/gogf/gf/v2 v2.9.5/go.mod h1:VUb5eyJKpvW77O/dXsbbLNO/Kjrg0UycIiq0lRiBjjo=
+github.com/gogf/gf/v2 v2.10.0/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=
@@ -168,8 +172,8 @@ github.com/hashicorp/go-uuid v1.0.3/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/b
 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/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 v1.0.2 h1:dV3g9Z/unq5DpblPpw+Oqcv4dU/1omnb4Ok8iPY6p1c=
-github.com/hashicorp/golang-lru v0.5.4/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
+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=
@@ -197,6 +201,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=
@@ -217,8 +223,9 @@ github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6T
 github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
 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/miekg/dns v1.1.63 h1:8M5aAw6OMZfFXTT7K5V0Eu5YiiL8l7nUAkyN6C9YwaY=
+github.com/miekg/dns v1.1.63/go.mod h1:6NGHfjhpmr5lt3XPLuyfDJi5AXbNIPM9PY6H6sF1Nfs=
 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/minio/md5-simd v1.1.2 h1:Gdi1DZK69+ZVMoNHRXJyNcxrMA4dSxoYHZSQbirFg34=
@@ -236,12 +243,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,8 +275,6 @@ 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/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=
@@ -347,17 +346,19 @@ golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod h1:/lpIB1dKB+9EgE3
 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.45.0 h1:jMBrvKuj23MTlT0bQEOBcAE0mjg8mK9RXFhRH6nyF3Q=
-golang.org/x/crypto v0.44.0/go.mod h1:013i+Nw79BMiQiMsOPcVCB5ZIJbYkerPrGnOa00tvmc=
+golang.org/x/crypto v0.45.0/go.mod h1:XTGrrkGJve7CYK7J8PEww4aY7gM3qMCElcJQ8n8JdX4=
 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-20250128144449-3edf0e91c1ae h1:COZdc9Ut6wLq7MO9GIYxfZl4n4ScmgqQLoHocKXrxco=
-golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63/go.mod h1:0v4NqG35kSWCMzLaMeX+IQrlSnVE/bqGSyC2cz/9Le8=
+golang.org/x/exp v0.0.0-20250128144449-3edf0e91c1ae/go.mod h1:tujkw807nyEEAamNbDrEGzRav+ilXA7PCRAd6xsmwiU=
 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.29.0 h1:HV8lRxZC4l2cr3Zq1LvtOsi/ThTgWnUk/y64QSs8GwA=
+golang.org/x/mod v0.29.0/go.mod h1:NyhrlYXJ2H4eJiRy/WDBO6HMqZQ6q9nk4JzS3NuCK+w=
 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=
@@ -435,6 +436,8 @@ golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtn
 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.38.0 h1:Hx2Xv8hISq8Lm16jvBZ2VQf+RLmbd7wVUsALibYI/IQ=
+golang.org/x/tools v0.38.0/go.mod h1:yEsQ/d/YK8cjh0L6rZlY8tgtlKiBNTL14pGDJPJpYQs=
 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=

main.go

@@ -6,12 +6,12 @@ import (
 	"oss/service"
 	"time"
 
-	"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/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"
 )
 
 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 {}
 }

model/dto/file_dto.go

@@ -11,15 +11,14 @@ type UploadFileReq struct {
 	File   *ghttp.UploadFile `json:"file" type:"file"` // 文件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"`
-}

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不能为空"`
+	TenantId     uint64 `json:"tenantId" v:"required#租户id不能为空"`
-	UsedOssSize  int         `bson:"usedOssSize"  json:"usedOssSize"`
+	UsedOssSize  int    `json:"usedOssSize"`
-	TotalOssSize int         `bson:"totalOssSize" json:"totalOssSize"`
+	TotalOssSize int    `json:"totalOssSize"`
-	Updater      interface{} `json:"updater" v:"required#更新人不能为空"`
+	Creator      string `json:"creator"`
-}
+	Updater      string `json:"updater"`
-
-// UpdateUsedOssRes 更新使用存储总量响应
-type UpdateUsedOssRes struct {
 }

model/entity/file.go

@@ -1,20 +1,28 @@
 package entity
 
 import (
-	"oss/consts"
-
 	"gitea.com/red-future/common/beans"
 )
 
 // File 存储文件实体
 type File struct {
-	beans.MongoBaseDO `bson:",inline"` // 嵌入基础字段：Id, Creator, CreatedAt, Updater, UpdatedAt, TenantId, IsDeleted
+	beans.SQLBaseDO `orm:",inherit"` // 嵌入基础字段：Id, Bid, Creator, CreatedAt, Updater, UpdatedAt, Deleter, DeletedAt, IsDeleted
-	// 基础信息
+	// 业务字段
-	FileURL  string `bson:"fileURL"  json:"fileURL"` // 图URL
+	TenantId uint64 `orm:"tenant_id" json:"tenantId"` // 租户ID
-	FileSize int    `bson:"fileSize" json:"fileSize"`
+	FileURL  string `orm:"file_url"  json:"fileURL"`  // 文件URL
+	FileSize int    `orm:"file_size" json:"fileSize"`
 }
 
-// CollectionName 存储集合名称
+type fileCol struct {
-func (File) CollectionName() string {
+	beans.SQLBaseCol
-	return consts.FileCollection
+	TenantId string
+	FileURL  string
+	FileSize string
+}
+
+var FileCol = fileCol{
+	SQLBaseCol: beans.DefSQLBaseCol,
+	TenantId:   "tenant_id",
+	FileURL:    "file_url",
+	FileSize:   "file_size",
 }

model/entity/tenant_oss_total.go

@@ -1,20 +1,28 @@
 package entity
 
 import (
-	"oss/consts"
-
 	"gitea.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"`
+	TenantId     uint64 `orm:"tenant_id" json:"tenantId"` // 租户ID
-	TotalOssSize int `bson:"totalOssSize" json:"totalOssSize"`
+	UsedOssSize  int    `orm:"used_oss_size"  json:"usedOssSize"`
+	TotalOssSize int    `orm:"total_oss_size" json:"totalOssSize"`
 }
 
-// CollectionName 租户储存服务总计集合名称
+type tenantOssCol struct {
-func (TenantOssTotal) CollectionName() string {
+	beans.SQLBaseCol
-	return consts.TenantOssTotalCollection
+	TenantId     string
+	UsedOssSize  string
+	TotalOssSize string
+}
+
+var TenantOssCol = tenantOssCol{
+	SQLBaseCol:   beans.DefSQLBaseCol,
+	TenantId:     "tenant_id",
+	UsedOssSize:  "used_oss_size",
+	TotalOssSize: "total_oss_size",
 }

service/file_service.go

@@ -3,13 +3,14 @@ package service
 import (
 	"context"
 	"fmt"
-	"github.com/gogf/gf/v2/os/glog"
 	"oss/consts"
 	"oss/dao"
 	"oss/model/dto"
 	"oss/model/entity"
 	"time"
 
+	"github.com/gogf/gf/v2/os/glog"
+
 	"gitea.com/red-future/common/minio"
 	"gitea.com/red-future/common/redis"
 	"gitea.com/red-future/common/utils"
@@ -51,18 +52,18 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 			getByTenantIdReq := &dto.GetByTenantIdReq{
 				TenantId: user.TenantId,
 			}
-			tenantOssTotalRes, err := TenantOssTotal.GetOneByTenantId(ctx, getByTenantIdReq)
+			tenantOssTotalRes, err := dao.TenantOssTotal.GetOneByTenantId(ctx, getByTenantIdReq)
 			if err != nil {
 				glog.Errorf(ctx, "查询数据库-获取租户存储容量总数失败: %v", err)
 				return err
 			}
-			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获取租户存储容量总数
@@ -75,10 +76,11 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 		fileSize = tenantOssTotalEntity.UsedOssSize + fileSize
 		totalFileSize = tenantOssTotalEntity.TotalOssSize
 		// 设置redis-租户存储容量总数
-		tenantOssTotalKeyMap := dto.TenantOssTotal{
+		tenantOssTotalKeyMap := dto.UpdateUsedOssReq{
 			TenantId:     tenantId,
 			UsedOssSize:  fileSize,
 			TotalOssSize: totalFileSize,
+			Creator:      user.UserName,
 			Updater:      user.UserName,
 		}
 		// 修改redis-租户存储容量总数 超时时间10分钟
@@ -104,11 +106,12 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 		return nil, err
 	}
 	// 插入数据库
-	ossEntity := &entity.File{
+	ossEntity := &dto.UploadFile{
+		TenantId: tenantId,
 		FileURL:  fileURL,
 		FileSize: fileSize,
 	}
-	if err = dao.File.Insert(ctx, ossEntity); err != nil {
+	if _, err = dao.File.Insert(ctx, ossEntity); err != nil {
 		return nil, err
 	}
 	// 返回图片url

service/tenant_oss_total_service.go

@@ -2,12 +2,14 @@ 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.com/red-future/common/beans"
+	"gitea.com/red-future/common/redis"
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/util/gconv"
 )
 
 type tenantOssTotal struct{}
@@ -15,17 +17,10 @@ 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)
 	if err != nil {
@@ -46,7 +41,7 @@ func (s *tenantOssTotal) UpdateUsedOssSize(ctx context.Context) (err error) {
 
 	}
 	// 更新数据库
-	err = dao.TenantOssTotal.SaveOrUpdate(ctx, updateData)
+	_, err = dao.TenantOssTotal.SaveOrUpdate(ctx, updateData)
 	if err != nil {
 		return err
 	}

update.sql

@@ -1 +1,75 @@
------------张斌2025-06-16 15:00:00--------------
+-----------张斌2025-06-16 15:00:00--------------
+
+--------------------pgsql创建file表语句---------------------------
+
+-- 存储文件表
+CREATE TABLE IF NOT EXISTS 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 file(tenant_id);
+CREATE INDEX idx_file_file_size ON file(file_size);
+
+-- 文件表字段注释
+COMMENT ON TABLE file IS '存储文件表';
+COMMENT ON COLUMN file.id IS '主键ID';
+COMMENT ON COLUMN file.creator IS '创建人';
+COMMENT ON COLUMN file.created_at IS '创建时间';
+COMMENT ON COLUMN file.updater IS '更新人';
+COMMENT ON COLUMN file.updated_at IS '更新时间';
+COMMENT ON COLUMN file.deleted_at IS '删除时间（软删）';
+COMMENT ON COLUMN file.tenant_id IS '租户ID';
+COMMENT ON COLUMN file.file_url IS '文件URL';
+COMMENT ON COLUMN file.file_size IS '文件大小（字节）';
+
+--------------------pgsql创建file表语句---------------------------
+
+
+--------------------pgsql创建tenant_oss_total表语句---------------------------
+-- 租户存储服务总计表
+CREATE TABLE IF NOT EXISTS 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 tenant_oss_total(used_oss_size);
+CREATE INDEX idx_tenant_oss_total_total_size ON tenant_oss_total(total_oss_size);
+
+-- 租户存储表字段注释
+COMMENT ON TABLE tenant_oss_total IS '租户存储服务总计表';
+COMMENT ON COLUMN tenant_oss_total.id IS '主键ID';
+COMMENT ON COLUMN tenant_oss_total.creator IS '创建人';
+COMMENT ON COLUMN tenant_oss_total.created_at IS '创建时间';
+COMMENT ON COLUMN tenant_oss_total.updater IS '更新人';
+COMMENT ON COLUMN tenant_oss_total.updated_at IS '更新时间';
+COMMENT ON COLUMN tenant_oss_total.deleted_at IS '删除时间（软删）';
+COMMENT ON COLUMN tenant_oss_total.tenant_id IS '租户ID（唯一）';
+COMMENT ON COLUMN tenant_oss_total.used_oss_size IS '已使用存储大小（字节）';
+COMMENT ON COLUMN tenant_oss_total.total_oss_size IS '总存储大小（字节）';
+
+--------------------pgsql创建tenant_oss_total表语句---------------------------