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