package main

import (
	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/logger.git"
	_ "basic.com/valib/version.git"
	"context"
	"flag"
	"os"
	"os/signal"
	"syscall"
	"vamicro/config"
	"vamicro/sync-service/controllers"
	"vamicro/sync-service/models"
	"vamicro/sync-service/service"
)

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

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

func main(){
	models.Init()

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

	ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug)
	if err !=nil {
		return
	}
	defer func() {
		ms.DeRegister()
		cancel()
		ms.Free()
	}()
	bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic)
	bhomedbapi.InitDoReq(ms.RequestOnly)
	ms.StartServer(fm)
}
const urlPrefix = "/data/api-v"
func initFuncMap() (map[string]bhomeclient.MicroFunc,[]string) {
	funcMap := make(map[string]bhomeclient.MicroFunc)
	cc := new(controllers.CameraController)
	ac := new(controllers.AreaController)
	cpc := new(controllers.CameraPolygonController)

	funcMap[urlPrefix+"/area/localmenu"] = ac.CameraTree
	funcMap[urlPrefix+"/area/add"] = ac.AreaAdd
	funcMap[urlPrefix+"/area/update"] = ac.AreaUpdate
	funcMap[urlPrefix+"/area/del"] = ac.AreaDelete
	funcMap[urlPrefix+"/camera/add"] = cc.CameraAdd
	funcMap[urlPrefix+"/camera/update"] = cc.CameraUpdate
	funcMap[urlPrefix+"/camera/del"] = cc.CameraDel
	funcMap[urlPrefix+"/camera/show"] = cc.CameraSel
	funcMap[urlPrefix+"/camera/showAll"] = cc.GetAllCameras
	funcMap[urlPrefix+"/camera/getAllCamerasByServer"] = cc.GetAllCamerasByServer
	funcMap[urlPrefix+"/camera/getCamerasByRunType"] = cc.GetCamerasByRunType
	funcMap[urlPrefix+"/camera/updateRunEnable"] = cc.UpdateRunEnable
	funcMap[urlPrefix+"/camera/changeRunType"] = cc.ChangeRunType
	funcMap[urlPrefix+"/camera/updateIsRunningState"] = cc.UpdateIsRunningState
	funcMap[urlPrefix+"/camera/updateIsRunningAll"] = cc.UpdateIsRunningAll
	funcMap[urlPrefix+"/camera/updateSnapshot"] = cc.UpdateSnapshot
	funcMap[urlPrefix+"/camera/updateCameraArea"] = cc.UpdateCameraArea
	funcMap[urlPrefix+"/polygon/findByCameraId"] = cpc.FindByCameraId
	funcMap[urlPrefix+"/polygon/findAll"] = cpc.FindAll
	funcMap[urlPrefix+"/polygon/updateDefenceStateByPolygonId"] = cpc.UpdateDefenceStateByPolygonId
	funcMap[urlPrefix+"/polygon/updateDefenceStateByCameraId"] = cpc.UpdateDefenceStateByCameraId
	var pubTopics []string
	for key,_ := range funcMap {
		pubTopics = append(pubTopics, key)
	}

	return funcMap, pubTopics
}