优化异步日志

notify/producer.go

 package notify
 
 import (
+	"context"
 	"fmt"
 	"github.com/nsqio/go-nsq"
 	"gitlab.jxhh.com/stbz/library.git/logs"
@@ -56,7 +57,7 @@ func (p *NsqProducer) Publish(topic string, message string) error {
 //发布延迟消息
 func (p *NsqProducer) DeferredPublish(topic string,delay time.Duration, message string) error {
 
-	logs.Info("topic",message)
+	logs.Infof(context.Background(),"topic",message)
 
 	var err error
 	if p.producer != nil {