package main

import (
	"github.com/kardianos/service"
	"iot-master/active"
	"iot-master/args"
	"iot-master/camera"
	"iot-master/config"
	"iot-master/db"
	"iot-master/history"
	"iot-master/log"
	"iot-master/master"
	"iot-master/web"
	"os"
	"os/signal"
	"syscall"
)

var serviceConfig = &service.Config{
	Name:        "iot-master",
	DisplayName: "物联大师",
	Description: "物联网设备自动控制系统",
	Arguments:   nil,
}

func main() {
	args.Parse()

	//传递参数到服务
	serviceConfig.Arguments = []string{"-c", args.ConfigPath}

	// 构建服务对象
	program := &Program{}
	s, err := service.New(program, serviceConfig)
	if err != nil {
		log.Fatal(err)
	}

	// 用于记录系统日志
	logger, err := s.Logger(nil)
	if err != nil {
		log.Fatal(err)
	}

	if args.Uninstall {
		err = s.Uninstall()
		if err != nil {
			log.Fatal(err)
		}
		log.Println("卸载服务成功")
		return
	}

	if args.Install {
		err = s.Install()
		if err != nil {
			log.Fatal(err)
		}
		log.Println("安装服务成功")
		return
	}

	err = s.Run()
	if err != nil {
		_ = logger.Error(err)
	}
}

type Program struct{}

func (p *Program) Start(s service.Service) error {
	//log.Println("===开始服务===")
	go p.run()
	return nil
}

func (p *Program) Stop(s service.Service) error {
	//log.Println("===停止服务===")
	_ = shutdown()
	return nil
}

func (p *Program) run() {

	// 此处编写具体的服务代码
	hup := make(chan os.Signal, 2)
	signal.Notify(hup, syscall.SIGHUP)
	quit := make(chan os.Signal, 2)
	signal.Notify(quit, os.Interrupt, os.Kill)

	go func() {
		for {
			select {
			case <-hup:
			case <-quit:
				//优雅地结束
				_ = shutdown()
				//os.Exit(0)
			}
		}
	}()

	//原本的Main函数
	originMain()
}

func originMain() {
	err := config.Load()
	if err != nil {
		log.Fatal(err)
	}

	err = log.Open(&config.Config.Log)
	if err != nil {
		log.Fatal(err)
	}

	//配置文件存在，说明已经安装
	if config.Existing() {
		//加载数据库
		err = db.Open(&config.Config.Database)
		if err != nil {
			log.Fatal(err)
		}
		defer db.Close()

		//加载历史数据库
		err = history.Open(&config.Config.History)
		if err != nil {
			log.Fatal(err)
		}
		defer history.Close()

		//加载主程序
		err = master.Start()
		if err != nil {
			log.Fatal(err)
		}
		defer master.Stop()

		//加载相机
		err = camera.Start()
		if err != nil {
			log.Fatal(err)
		}
		defer camera.Stop()
	}

	//加载授权
	err = active.Load()
	if err != nil {
		log.Fatal(err)
	}

	//判断是否开启Web
	web.Serve(&config.Config.Web)
}

func shutdown() error {

	//_ = database.Close()
	//_ = tsdb.Close()
	//connect.Close()
	//master.Close()

	//只关闭Web就行了，其他通过defer关闭
	_ = web.Close()

	return nil
}