init vamicro

qixiaoning

2025-07-08 84d2ef9760af0a4a4aa933937294400b3caa291d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
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
}