analyze/internal/model/do/task.go

package do

import (
	"analyze/internal/model"
	"github.com/gogf/gf/v2/encoding/gjson"
	"github.com/gogf/gf/v2/frame/g"
)

type taskInfo struct {
	FirstRun bool
	TaskRun  bool
	Ticker   int
}
type taskConfig struct {
	Name           string
	MainSwitch     bool
	MarketAnalysis taskInfo
}

var (
	TaskConfig taskConfig
)

func init() {
	g.Log().Info(model.Ctx, "--定时任务配置初始化--开始--")
	var (
		task map[string]interface{}
		err  error
		b    []byte
		msg  = "--定时任务配置初始化--异常--"
	)
	task, err = g.Cfg("task.yaml").Data(model.Ctx)
	if err == nil {
		b, err = gjson.Marshal(task)
		if err == nil {
			if err = gjson.Unmarshal(b, &TaskConfig); err == nil {
				msg = ""
			}
		}
	}
	if msg != "" {
		g.Log().Error(model.Ctx, msg)
	}
	g.Log().Info(model.Ctx, "--定时任务配置初始化--结束--")
}