diff --git a/worker/go.mod b/worker/go.mod index c024458..203afaa 100644 --- a/worker/go.mod +++ b/worker/go.mod @@ -6,19 +6,23 @@ require ( github.com/hibiken/asynq v0.25.1 github.com/samber/lo v1.52.0 github.com/spf13/cast v1.10.0 + github.com/stretchr/testify v1.11.1 go.uber.org/zap v1.27.1 ) require ( github.com/cespare/xxhash/v2 v2.3.0 // indirect + github.com/davecgh/go-spew v1.1.1 // indirect github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect github.com/google/uuid v1.6.0 // indirect + github.com/pmezard/go-difflib v1.0.0 // indirect github.com/redis/go-redis/v9 v9.17.3 // indirect github.com/robfig/cron/v3 v3.0.1 // indirect - github.com/stretchr/testify v1.11.1 // indirect go.uber.org/multierr v1.11.0 // indirect golang.org/x/sys v0.40.0 // indirect golang.org/x/text v0.33.0 // indirect golang.org/x/time v0.14.0 // indirect google.golang.org/protobuf v1.36.11 // indirect + gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/worker/go.sum b/worker/go.sum index 5e0f0c7..b2e73fe 100644 --- a/worker/go.sum +++ b/worker/go.sum @@ -48,5 +48,8 @@ golang.org/x/time v0.14.0 h1:MRx4UaLrDotUKUdCIqzPC48t1Y9hANFKIRpNx+Te8PI= golang.org/x/time v0.14.0/go.mod h1:eL/Oa2bBBK0TkX57Fyni+NgnyQQN4LitPmob2Hjnqw4= google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE= google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo= +gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/worker/internal/tasks/image.go b/worker/internal/tasks/image.go index 25fef08..19c56d7 100644 --- a/worker/internal/tasks/image.go +++ b/worker/internal/tasks/image.go @@ -3,7 +3,6 @@ package tasks import ( "context" "encoding/json" - "errors" "mime" "path/filepath" "pkg/models" @@ -62,7 +61,7 @@ func ConvertImage(ctx context.Context, task *asynq.Task) error { } originalFileInfo, _ := models.GetRedisFileInfo(payload.FileId) if originalFileInfo == nil || originalFileInfo.FileType != models.FileTypeUpload { - return errors.New("文件不存在") + return ErrNotFoundFile } uploadPath, err := utils.GetUploadDirPath() if err != nil {