diff --git a/src/model/service/task_service.go b/src/model/service/task_service.go index 67b0c82..30bb432 100644 --- a/src/model/service/task_service.go +++ b/src/model/service/task_service.go @@ -5,6 +5,8 @@ import ( "net/http" "sync" + "github.com/spf13/viper" + "github.com/assimon/luuu/model/data" "github.com/assimon/luuu/model/request" "github.com/assimon/luuu/mq" @@ -136,7 +138,6 @@ func Trc20CallBack(token string, wg *sync.WaitGroup) { } // 回调队列 orderCallbackQueue, _ := handle.NewOrderCallbackQueue(order) - orderCallbackQueue, _ := handle.NewOrderCallbackQueue(order) orderNoticeMaxRetry := viper.GetInt("order_notice_max_retry") mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(orderNoticeMaxRetry)) // mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(5))