fix:调整

server/upload/internal/logic/uploadcallbacklogic.go

@@ -41,6 +41,29 @@ func (l *UploadCallbackLogic) UploadCallback(req *types.UploadCallbackReq, useri
 	// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
 	// userinfo 传入值时, 一定不为null
 
+	var userId int64
+	var guestId int64
+
+	// 检查用户是否是游客
+	if userinfo.IsGuest() {
+		// 如果是，使用游客ID和游客键名格式
+		guestId = userinfo.GuestId
+	} else {
+		// 否则，使用用户ID和用户键名格式
+		userId = userinfo.UserId
+	}
+
+	// 定义存储桶名称
+	var bucketName *string
+
+	// 根据类别选择存储桶
+	switch req.UploadBucket {
+	case 2:
+		bucketName = basic.TempfileBucketName
+	default:
+		bucketName = basic.StorageBucketName
+	}
+
 	resourceModel := gmodel.NewFsResourceModel(l.svcCtx.MysqlConn)
 	err := resourceModel.Trans(l.ctx, func(ctx context.Context, connGorm *gorm.DB) (err error) {
 		resourceModelTS := gmodel.NewFsResourceModel(l.svcCtx.MysqlConn)
@@ -50,11 +73,14 @@ func (l *UploadCallbackLogic) UploadCallback(req *types.UploadCallbackReq, useri
 		}
 
 		var fsResource = &gmodel.FsResource{}
+		fsResource.UserId = &userId
+		fsResource.GuestId = &guestId
 		fsResource.ResourceId = req.ResourceId
 		fsResource.ResourceType = &req.ResourceType
 		fsResource.ResourceUrl = &req.ResourceUrl
 		fsResource.Metadata = &req.Metadata
 		fsResource.ApiType = &req.ApiType
+		fsResource.BucketName = bucketName
 		if resourceInfo.ResourceId == "" {
 			_, err = resourceModelTS.Create(ctx, fsResource)
 		} else {

server/upload/internal/logic/uploadfilebaselogic.go

@@ -140,6 +140,7 @@ func (l *UploadFileBaseLogic) UploadFileBase(req *types.UploadFileBaseReq, useri
 				UploadedAt:   &nowTime,
 				Metadata:     &req.Metadata,
 				ApiType:      &apiType,
+				BucketName:   bucketName,
 			})
 			if err != nil {
 				logx.Error(err)

server/upload/internal/logic/uploadfilesbackendlogic.go

@@ -195,6 +195,7 @@ func (l *UploadFilesBackendLogic) UploadFilesBackend(req *types.UploadFilesReq,
 					UploadedAt:   &nowTime,
 					Metadata:     &uploadDataInfo.Metadata,
 					ApiType:      &uploadDataInfo.ApiType,
+					BucketName:   bucketName,
 				})
 				if err != nil {
 					logx.Error(err)