审查视图

tangxvhui authored
1
package main
tangxvhui authored
2 3 4

import (
	"github.com/beego/beego/v2/server/web"
郑周 authored
5 6
	service "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/node_task"
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
tangxvhui authored
7
	_ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego"
tangxvhui authored
8
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/consumer"
郑周 authored
9
	"time"
tangxvhui authored
10 11 12
)

func main() {
郑周 authored
13 14
	startNodeTask()
Your Name authored
15 16 17 18 19
	// tree := web.PrintTree()
	// methods := tree["Data"].(web.M)
	// for k, v := range methods {
	// 	fmt.Printf("%s => %v \n", k, v)
	// }
tangxvhui authored
20
	go consumer.Run()
tangxvhui authored
21 22
	web.Run()
}
郑周 authored
23 24 25 26 27 28 29 30 31 32 33 34 35 36

// 定时任务-间隔发送评估环节
func startNodeTask() {
	go func() {
		nodeTaskService := service.NewNodeTaskService()
		for {
			timer := time.NewTimer(time.Second * 60)
			<-timer.C
			if err := nodeTaskService.SendEvaluationNode(); err != nil {
				log.Logger.Error(err.Error())
			}
		}
	}()
}