feat:日志调整

main.go

@@ -47,7 +47,10 @@ func nsqWork() {
 func main() {
 	go nsqWork()
 	go task.SelectOrderTask()
-	util.LogInit(util.NsqLog, config.NsqLogConfig, *db.Mgo_Log)
+
+	c := config.NsqLogConfig
+	util.NsqLog = util.NewSaveLog(c.Name, c.CollName, c.MgoSaveCacheSize, c.SPSize, c.BulkSize, c.TimeAfter, c.Timeout, *db.Mgo_Log)
+	go util.NsqLog.SaveMgo()
 	mux1 := http.NewServeMux()
 	xweb.RunBase(gcfg.Instance().MustGet(gctx.New(), "webport", "").String(), mux1)
 }

util/logs.go

@@ -2,7 +2,6 @@ package util
 
 import (
 	"app.yhyue.com/moapp/jybase/mongodb"
-	"app.yhyue.com/moapp/message/config"
 	"fmt"
 	"log"
 	"time"
@@ -10,11 +9,6 @@ import (
 
 var NsqLog *SaveLogs
 
-func LogInit(sl *SaveLogs, c config.SaveLogConfig, mgo mongodb.MongodbSim) {
-	sl = NewSaveLog(c.Name, c.CollName, c.MgoSaveCacheSize, c.SPSize, c.BulkSize, c.TimeAfter, c.Timeout, mgo)
-	go sl.SaveMgo()
-}
-
 type SaveLogs struct {
 	Name             string // 日志名称
 	CollName         string // 保存的coll