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-manufacture/pkg/constant"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/redis"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/log"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/port/mqtt"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/port/task"
	"time"

	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/application/crontab"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/constant"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/pg"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/redis"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/log"
	_ "gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/port/beego"
)

func main() {
	defer func() {
		if r := recover(); r != nil {
			log.Logger.Error(fmt.Sprintf("%v", r))
		}
	}()
	if constant.ENABLE_KAFKA_LOG {
		w, _ := logrus.NewKafkaWriter(constant.KAFKA_HOST, constant.TOPIC_LOG_STASH, false)
		log.Logger.AddHook(w)
	}
	bw := log.NewBeegoLogWriter(log.LoggerConfig{
		Filename: constant.LOG_FILE,
		Level:    7,
		MaxSize:  1024 * 1024 * 2,
	})
	log.Logger.AddHook(bw)
	redis.InitRedis()
	log.Logger.Info("server start ....")
	log.Logger.Debug(fmt.Sprintf("ENABLE_KAFKA_LOG:%v", constant.ENABLE_KAFKA_LOG))

	go mqtt.Start()
	go task.Run()
	cron := crontab.NewCrontabService(nil)
	cron.StartCrontabTask()
	defer cron.StopCrontabTask()
	time.Sleep(time.Second)
	log.Logger.Info("server start!")
	web.Run()
	log.Logger.Info("server stop!")
}