package main

import (
	"context"
	"flag"
	"os"
	"os/signal"
	"syscall"
	"vamicro/config"
	"vamicro/saas-service/controllers"
	"vamicro/saas-service/models"
	"vamicro/saas-service/service"
	"vamicro/saas-service/service/nodeService"

	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/logger.git"
	"go.uber.org/zap"
)

var (
	procName = service.ProcName
	proc     = &bhomeclient.ProcInfo{
		Name: procName, //进程名称
		ID:   procName, //进程id
		Info: "",       //进程的描述信息，用于区分同一进程名称下多个进程
	}
	env = flag.String("e", "pro", "")
)

var log *zap.SugaredLogger
var bhomeClient *bhomeclient.MicroNode

func init() {
	flag.Parse()
	// 初始化配置
	config.Init(*env)
	// 日志初始化
	var logFile = config.LogConf.Path + "vamicro-" + procName + ".log"
	log = logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
	logger.Info("log init success !")
}

func main() {
	flag.Parse()
	models.Init()
	defer models.CloseDB()

	// 注册bus
	fm, pubTopics := initFuncMap()
	ctx, cancel := context.WithCancel(context.Background())
	var reg = &bhomeclient.RegisterInfo{
		Proc:     *proc,
		Channel:  nil,
		PubTopic: pubTopics,
		SubTopic: []string{"scene-service"},
	}
	q := make(chan os.Signal, 1)
	signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)

	var err error
	if bhomeClient, err = bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug); err != nil {
		return
	}

	bhomedbapi.InitGetNetNode(bhomeClient.GetLocalNetNodeByTopic)
	bhomedbapi.InitDoReq(bhomeClient.RequestOnly)
	bhomedbapi.InitLog(logger.Debug)

	// 启动saas服务
	go bhomeClient.StartServer(fm)

	// 初始化节点
	nodeService.InitNode()

	// 监测节点变化
	nodeService.WatchNode()

	// 初始化缓存
	service.InitCache()

	// 启动服务
	go service.StartSrv(log)

	// 订阅topic消息
	go service.StartSubTopic(bhomeClient, service.SubTopicCallback)

	// 检测服务状态
	service.WatchSrv(log)

	<-q
	bhomeClient.DeRegister()
	cancel()
	bhomeClient.Free()
}

const urlPrefix = "/data/api-v/saas"

func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
	lockControler := new(controllers.LockController)
	funcMap := make(map[string]bhomeclient.MicroFunc)
	funcMap[urlPrefix+"/setLock"] = lockControler.SetLock
	funcMap[urlPrefix+"/getLock"] = lockControler.GetLock
	funcMap[urlPrefix+"/delLock"] = lockControler.DelLock
	funcMap[urlPrefix+"/gatAllLock"] = lockControler.GetAllLock
	funcMap[urlPrefix+"/syncCamera"] = lockControler.SyncCamera

	var pubTopics []string
	for key, _ := range funcMap {
		pubTopics = append(pubTopics, key)
	}
	return funcMap, pubTopics
}