fix:上传模块调整

server/upload/internal/logic/uploadcallbacklogic.go

@@ -83,8 +83,10 @@ func (l *UploadCallbackLogic) UploadCallback(req *types.UploadCallbackReq, useri
 		fsResource.ResourceUrl = &req.ResourceUrl
 		fsResource.Metadata = &req.Metadata
 		fsResource.ApiType = &req.ApiType
+		fsResource.Source = &req.Source
 		fsResource.BucketName = bucketName
 		fsResource.Version = &version
+
 		if resourceInfo.ResourceId == "" {
 			_, err = resourceModelTS.BuilderCreate(ctx, transBuilder, fsResource)
 		} else {

server/upload/internal/logic/uploadfilebackendlogic.go

@@ -90,6 +90,7 @@ func (l *UploadFileBackendLogic) UploadFileBackend(req *types.UploadFileBackendR
 		ApiType:      req.ApiType,
 		UserId:       userId,
 		GuestId:      guestId,
+		Source:       req.Source,
 	})
 
 	if err != nil {

server/upload/internal/logic/uploadfilebaselogic.go

@@ -77,6 +77,7 @@ func (l *UploadFileBaseLogic) UploadFileBase(req *types.UploadFileBaseReq, useri
 		ApiType:      req.ApiType,
 		UserId:       userId,
 		GuestId:      guestId,
+		Source:       req.Source,
 	})
 
 	if err != nil {

server/upload/internal/logic/uploadfilesbackendlogic.go

@@ -123,6 +123,7 @@ func (l *UploadFilesBackendLogic) UploadFilesBackend(req *types.UploadFilesReq,
 				ApiType:  req.ApiType,
 				Bucket:   bucketName,
 				HashKey:  hashKey,
+				Source:   req.Source,
 			}
 		}
 	}, func(item interface{}, writer mr.Writer[interface{}], cancel func(error)) {
@@ -148,6 +149,7 @@ func (l *UploadFilesBackendLogic) UploadFilesBackend(req *types.UploadFilesReq,
 			ApiType:      req.ApiType,
 			UserId:       userId,
 			GuestId:      guestId,
+			Source:       uploadDataInfo.Source,
 		})
 		if err == nil {
 			uploadUrl.Status = 1
@@ -201,6 +203,7 @@ type UploadData struct {
 	Bucket   *string `json:"bucket"`
 	HashKey  string  `json:"hash_key"`
 	FileData []byte  `fsfile:"data"`
+	Source   string  `json:"source"`
 }
 
 type UploadUrl struct {

server/upload/internal/logic/uploadlogologic.go

@@ -115,6 +115,7 @@ func (l *UploadLogoLogic) UploadLogo(req *types.UploadLogoReq, userinfo *auth.Us
 		ApiType:      2,
 		UserId:       userId,
 		GuestId:      guestId,
+		Source:       "upload-logo",
 	})
 
 	if err != nil {