diff --git a/apis/process/workOrder.go b/apis/process/workOrder.go index 3cd0e0a..4043035 100644 --- a/apis/process/workOrder.go +++ b/apis/process/workOrder.go @@ -6,7 +6,6 @@ import ( "ferry/global/orm" "ferry/models/process" "ferry/models/system" - . "ferry/pkg/response/response" "ferry/pkg/service" "ferry/tools" "ferry/tools/app" diff --git a/pkg/task/server.go b/pkg/task/server.go index 0ff8812..4ced886 100644 --- a/pkg/task/server.go +++ b/pkg/task/server.go @@ -5,8 +5,9 @@ package task */ import ( - "ferry/pkg/logger" "ferry/pkg/task/worker" + + "github.com/RichardKnop/machinery/v1/log" ) func Start() { @@ -14,6 +15,6 @@ func Start() { taskWorker := worker.NewAsyncTaskWorker(0) err := taskWorker.Launch() if err != nil { - logger.Errorf("启动machinery失败,%v", err.Error()) + log.ERROR.Println("启动machinery失败,%v", err.Error()) } }