diff --git a/internal/services/bucket.go b/internal/services/bucket.go index 3255da9..b977b6a 100644 --- a/internal/services/bucket.go +++ b/internal/services/bucket.go @@ -42,7 +42,7 @@ func (svc *Service) GetBucketObjects(msg *coormsg.GetBucketObjects) (*coormsg.Ge } func (svc *Service) CreateBucket(msg *coormsg.CreateBucket) (*coormsg.CreateBucketResp, *ramsg.CodeMessage) { - var bucketID int + var bucketID int64 var err error svc.db.DoTx(sql.LevelDefault, func(tx *sqlx.Tx) error { // 这里用的是外部的err diff --git a/internal/services/object.go b/internal/services/object.go index a736cbc..99dcaa3 100644 --- a/internal/services/object.go +++ b/internal/services/object.go @@ -318,7 +318,7 @@ func (svc *Service) DeleteObject(msg *coormsg.DeleteObject) (*coormsg.DeleteObje // 不追求及时、准确 if len(stgs) == 0 { // 如果没有被引用,直接投递CheckObject的任务 - err := svc.scanner.PostEvent(scevt.NewCheckObject([]int{msg.ObjectID}), false, false) + err := svc.scanner.PostEvent(scevt.NewCheckObject([]int64{msg.ObjectID}), false, false) if err != nil { logger.Warnf("post event to scanner failed, but this will not affect deleting, err: %s", err.Error()) } @@ -327,7 +327,7 @@ func (svc *Service) DeleteObject(msg *coormsg.DeleteObject) (*coormsg.DeleteObje } else { // 有引用则让Agent去检查StorageObject for _, stg := range stgs { - err := svc.scanner.PostEvent(scevt.NewAgentCheckStorage(stg.StorageID, []int{msg.ObjectID}), false, false) + err := svc.scanner.PostEvent(scevt.NewAgentCheckStorage(stg.StorageID, []int64{msg.ObjectID}), false, false) if err != nil { logger.Warnf("post event to scanner failed, but this will not affect deleting, err: %s", err.Error()) }