审查视图

1 2
package main
3
import (
4
	"fmt"
5
	"github.com/beego/beego/v2/server/web"
6 7
	"github.com/linmadan/egglib-go/log/logrus"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/constant"
yangfu authored
8
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/constant"
yangfu authored
9
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg"
10
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/log"
yangfu authored
11
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/log"
陈志颖 authored
12
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/port/beego"
13
)
14 15

func main() {
16
	// web主服务
17 18 19 20 21 22 23 24 25 26
	if constant.ENABLE_KAFKA_LOG {
		w, err := logrus.NewKafkaWriter(constant.KAFKA_HOSTS, constant.TOPIC_LOG_STASH, false)
		if err != nil {
			log.Logger.Error(err.Error())
		}
		log.Logger.AddHook(w)
	}

	fmt.Printf("Server running at:%d\n", web.BConfig.Listen.HTTPPort)
27
	web.Run()
28
}