package main import ( "fmt" "github.com/beego/beego/v2/server/web" "github.com/linmadan/egglib-go/log/logrus" "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/constant" _ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/constant" _ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg" "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/log" _ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/log" _ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/port/beego" ) func main() { // web主服务 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) web.Run() }