oss文件存储服务-租户存储空间信息同步接口优化

config.yml

@@ -37,4 +37,4 @@ minio:
 
 # 文件存储初始化容量大小配置
 oss:
-  capacitySize: 10 #文件存储初始化容量（单位G）
+  capacitySize: 500 #文件存储初始化容量（单位MB）

main.go

@@ -23,7 +23,7 @@ func main() {
 		controller.File,
 	})
 
-	gtimer.AddSingleton(ctx, time.Minute*1, func(ctx context.Context) {
+	gtimer.AddSingleton(ctx, time.Minute*5, func(ctx context.Context) {
 		err := service.TenantOssTotal.UpdateUsedOssSize(ctx)
 		if err != nil {
 			glog.Error(ctx, "UpdateUsedOssSize err: %v", err)

service/file_service.go

@@ -59,7 +59,7 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 			if tenantOssTotal.Id.IsZero() {
 				tenantOssTotalEntity.TenantId = user.TenantId
 				tenantOssTotalEntity.UsedOssSize = 0
-				tenantOssTotalEntity.TotalOssSize = g.Cfg().MustGet(ctx, "oss.capacitySize").Int() * 1024 * 1024 * 1024
+				tenantOssTotalEntity.TotalOssSize = g.Cfg().MustGet(ctx, "oss.capacitySize").Int() * 1024 * 1024
 			} else {
 				tenantOssTotalEntity = tenantOssTotal.TenantOssTotal
 			}
@@ -107,8 +107,7 @@ func (f *file) UploadFile(ctx context.Context, req *dto.UploadFileReq) (res *dto
 		FileURL:  fileURL,
 		FileSize: fileSize,
 	}
-	err = dao.File.Insert(ctx, ossEntity)
-	if err != nil {
+	if err = dao.File.Insert(ctx, ossEntity); err != nil {
 		return nil, err
 	}
 	// 返回图片url