From 5e11c2d04268eaa79c196449b42b44833d3e9de9 Mon Sep 17 00:00:00 2001 From: Sydonian <794346190@qq.com> Date: Thu, 11 May 2023 17:03:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/services/storage.go | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/internal/services/storage.go b/internal/services/storage.go index 264a744..f10d61e 100644 --- a/internal/services/storage.go +++ b/internal/services/storage.go @@ -9,19 +9,6 @@ import ( log "gitlink.org.cn/cloudream/utils/logger" ) -func (service *Service) MoveObjectToStorage(msg *coormsg.MoveObjectToStorage) *coormsg.MoveObjectToStorageResp { - err := service.db.Storage().UserMoveObjectTo(msg.Body.UserID, msg.Body.ObjectID, msg.Body.StorageID) - if err != nil { - log.WithField("UserID", msg.Body.UserID). - WithField("ObjectID", msg.Body.ObjectID). - WithField("StorageID", msg.Body.StorageID). - Warnf("user move object to storage failed, err: %s", err.Error()) - return ramsg.ReplyFailed[coormsg.MoveObjectToStorageResp](errorcode.OPERATION_FAILED, "user move object to storage failed") - } - - return ramsg.ReplyOK(coormsg.NewMoveObjectToStorageRespBody()) -} - func (service *Service) PreMoveObjectToStorage(msg *coormsg.PreMoveObjectToStorage) *coormsg.PreMoveObjectToStorageResp { //查询数据库，获取冗余类型，冗余参数 //jh:使用command中的bucketname和objectname查询对象表,获得redundancy，EcName,fileSizeInBytes @@ -110,3 +97,16 @@ func (service *Service) PreMoveObjectToStorage(msg *coormsg.PreMoveObjectToStora object.FileSizeInBytes, )) } + +func (service *Service) MoveObjectToStorage(msg *coormsg.MoveObjectToStorage) *coormsg.MoveObjectToStorageResp { + err := service.db.Storage().UserMoveObjectTo(msg.Body.UserID, msg.Body.ObjectID, msg.Body.StorageID) + if err != nil { + log.WithField("UserID", msg.Body.UserID). + WithField("ObjectID", msg.Body.ObjectID). + WithField("StorageID", msg.Body.StorageID). + Warnf("user move object to storage failed, err: %s", err.Error()) + return ramsg.ReplyFailed[coormsg.MoveObjectToStorageResp](errorcode.OPERATION_FAILED, "user move object to storage failed") + } + + return ramsg.ReplyOK(coormsg.NewMoveObjectToStorageRespBody()) +}