gateway/core/logs/init.go

package logs

import (
	"bp.jydev.jianyu360.cn/BaseService/gateway/common/db"
	"bp.jydev.jianyu360.cn/BaseService/gateway/core/logs/internal/notice"
	"bp.jydev.jianyu360.cn/BaseService/gateway/core/logs/internal/savedb"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/os/gctx"
)

var GateWayServerLog *serverLog

func InitLogs() {
	//初始化通知
	var noticeConfig notice.NoticeConfig
	ctx := gctx.New()
	if err := g.Cfg().MustGet(ctx, "alarm").Scan(&noticeConfig); err != nil {
		g.Log().Errorf(ctx, "nsq通知配置异常", err)
	}

	noticeObj, err := notice.NewNotice(noticeConfig)
	if err != nil {
		g.Log().Errorf(ctx, "nsq通知初始化异常异常", err)
	}

	// 持久化化存储
	var sDB *savedb.DbLogs
	if g.Cfg().MustGet(ctx, "logger.reqLog.saveToDb").Bool() {
		sDB = new(savedb.DbLogs)
		sDB.Db = db.MgoLog
	}

	GateWayServerLog = new(serverLog)

	if noticeObj != nil {
		GateWayServerLog.initNotice(noticeObj)
	}

	if sDB != nil {
		GateWayServerLog.initSaveLog(sDB)
	}
}