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()
}