Browse Source

Storage相关操作增加锁

gitlink
Sydonian 2 years ago
parent
commit
a2c8b96bba
1 changed files with 1 additions and 1 deletions
  1. +1
    -1
      internal/services/storage.go

+ 1
- 1
internal/services/storage.go View File

@@ -98,7 +98,7 @@ func (svc *Service) PreMoveObjectToStorage(msg *coormsg.PreMoveObjectToStorage)
}

func (svc *Service) MoveObjectToStorage(msg *coormsg.MoveObjectToStorage) *coormsg.MoveObjectToStorageResp {
err := svc.db.Storage().UserMoveObjectTo(svc.db.SQLCtx(), msg.Body.UserID, msg.Body.ObjectID, msg.Body.StorageID)
err := svc.db.StorageObject().MoveObjectTo(svc.db.SQLCtx(), msg.Body.UserID, msg.Body.ObjectID, msg.Body.StorageID)
if err != nil {
log.WithField("UserID", msg.Body.UserID).
WithField("ObjectID", msg.Body.ObjectID).


Loading…
Cancel
Save