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/scene-service/controllers"
|
"vamicro/scene-service/models"
|
|
"net/http"
|
_ "net/http/pprof"
|
)
|
|
var (
|
procName = "scene-service"
|
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() {
|
// pprof 用于分析性能
|
go func() {
|
logger.Info(http.ListenAndServe("0.0.0.0:6089", nil))
|
}()
|
|
flag.Parse()
|
vaversion.Usage()
|
|
models.Init()
|
defer models.CloseDB()
|
ctx, cancel := context.WithCancel(context.Background())
|
fm, pubTopics := initFuncMap()
|
var reg = &bhomeclient.RegisterInfo{
|
Proc: *proc,
|
Channel: nil,
|
PubTopic: pubTopics,
|
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
|
}
|
|
bhomedbapi.InitLog(logger.Debug)
|
bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic)
|
bhomedbapi.InitDoReq(ms.RequestOnly)
|
|
go ms.StartServer(fm)
|
|
<-q
|
|
ms.DeRegister()
|
cancel()
|
ms.Free()
|
}
|
|
const urlPrefix = "/data/api-v"
|
|
func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
|
funcMap := make(map[string]bhomeclient.MicroFunc)
|
crc := new(controllers.CameraRuleController)
|
ctc := new(controllers.CameraTimeRuleController)
|
cpc := new(controllers.CameraPolygonController)
|
cgc := new(controllers.CameraGroupController)
|
tc := new(controllers.CameraTaskController)
|
|
funcMap[urlPrefix+"/camera/rule/findAll"] = crc.FindAll
|
funcMap[urlPrefix+"/camera/rule/save"] = crc.Save
|
funcMap[urlPrefix+"/camera/rule/saveLinkRulesByGroup"] = crc.SaveLinkRulesByGroup
|
funcMap[urlPrefix+"/camera/rule/getLinkRulesByCameraIds"] = crc.GetLinkRulesByCameraIds
|
funcMap[urlPrefix+"/camera/rule/findByCameraId"] = crc.FindByCameraId
|
funcMap[urlPrefix+"/camera/rule/existRunningTask"] = crc.ExistRunningTask
|
funcMap[urlPrefix+"/camera/pasteRules"] = crc.PasteRules
|
funcMap[urlPrefix+"/camera/rule/updateAlarmLevel"] = crc.UpdateAlarmLevel
|
funcMap[urlPrefix+"/camera/rule/deleteGroup"] = crc.DeleteByGroup
|
funcMap[urlPrefix+"/camera/findAllCameraLink"] = crc.FindAllCameraLink
|
funcMap[urlPrefix+"/camera/rule/findAllTaskById"] = crc.FindAllTaskById
|
funcMap[urlPrefix+"/camera/findLinksByCameraIds"] = crc.FindLinksByCameraIds
|
funcMap[urlPrefix+"/camera/rule/dispatch"] = crc.Dispatch
|
funcMap[urlPrefix+"/camera/rule/syncDelBySaas"] = crc.SyncDelBySaas
|
|
funcMap[urlPrefix+"/camera/alltask"] = tc.FindTasksByCameraIds
|
|
/****************时间设置******************/
|
funcMap[urlPrefix+"/cameraTimerule/save"] = ctc.Save
|
funcMap[urlPrefix+"/cameraTimerule/delete"] = ctc.Delete
|
funcMap[urlPrefix+"/cameraTimerule/findAll"] = ctc.FindAll
|
|
/*********************区域配置***********************/
|
funcMap[urlPrefix+"/polygon/save"] = cpc.Save
|
//funcMap[urlPrefix+"/polygon/delete"] = cpc.Delete
|
funcMap[urlPrefix+"/polygon/findByCameraId"] = cpc.FindByCameraId
|
funcMap[urlPrefix+"/polygon/findAll"] = cpc.FindAll
|
funcMap[urlPrefix+"/polygon/updateDefenceStateByPolygonId"] = cpc.UpdateDefenceStateByPolygonId
|
funcMap[urlPrefix+"/polygon/updateDefenceStateByCameraId"] = cpc.UpdateDefenceStateByCameraId
|
funcMap[urlPrefix+"/polygon/findByCamGroup"] = cpc.FindByCamGroup
|
|
/*************************saas同步***************************/
|
funcMap[urlPrefix+"/polygon/getSyncSceneData"] = cpc.GetSyncSceneData
|
|
/**********************关联区域*************************/
|
funcMap[urlPrefix+"/polygon/relation/findAll"] = cpc.FindAllRelation
|
funcMap[urlPrefix+"/polygon/relations"] = cpc.Relations
|
funcMap[urlPrefix+"/polygon/relation/save"] = cpc.SaveRelation
|
funcMap[urlPrefix+"/polygon/relation/del"] = cpc.DelRelation
|
funcMap[urlPrefix+"/polygon/relation/findByGroup"] = cpc.FindRelationByGroup
|
|
/**********************太原营业厅需求*************************/
|
acpC := new(controllers.AreaCamPgnController)
|
funcMap[urlPrefix+"/acp/findAll"] = acpC.FindAll
|
funcMap[urlPrefix+"/acp/save"] = acpC.Save
|
funcMap[urlPrefix+"/acp/delete"] = acpC.Delete
|
|
/*************************全景图***************************/
|
funcMap[urlPrefix+"/panorama/show"] = cpc.ShowPanorama //获取全景图地址
|
funcMap[urlPrefix+"/panorama/upload"] = cpc.UploadPanorama //上传新的全景图地址
|
|
funcMap[urlPrefix+"/camera/group/findAll"] = cgc.FindAll
|
funcMap[urlPrefix+"/camera/group/save"] = cgc.Save
|
funcMap[urlPrefix+"/camera/group/del"] = cgc.Delete
|
|
var pubTopics []string
|
for key, _ := range funcMap {
|
pubTopics = append(pubTopics, key)
|
}
|
return funcMap, pubTopics
|
}
|
