qixiaoning
2025-09-18 fd31206bcb8b084720291a53c986db771d8f5975
camera-service/main.go
@@ -1,10 +1,6 @@
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"
@@ -15,6 +11,11 @@
   "vamicro/camera-service/models"
   "vamicro/camera-service/service"
   "vamicro/config"
   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/bhomedbapi.git"
   "basic.com/valib/logger.git"
   vaversion "basic.com/valib/version.git"
)
var (
@@ -40,6 +41,8 @@
func main() {
   models.Init()
   models.InitVectorDb()
   defer models.CloseDBClient()
   defer models.CloseDB()
   ctx, cancel := context.WithCancel(context.Background())
@@ -75,7 +78,7 @@
   ms.Free()
}
//处理订阅消息
// 处理订阅消息
func dealSubMsg(ctx context.Context, ms *bhomeclient.MicroNode) {
   for {
@@ -125,6 +128,15 @@
   funcMap[urlPrefix+"/camera/getSyncSensorData"] = cc.GetSyncSensorData
   funcMap[urlPrefix+"/camera/saveNotExistOrUpdate"] = cc.SaveNotExistOrUpdate
   //获取抓拍预警信息
   funcMap[urlPrefix+"/camera/getRecord"] = cc.GetRecord
   //获取任务根据摄像机ids
   funcMap[urlPrefix+"/camera/getTasks"] = cc.GetTasks
   //删除记录
   funcMap[urlPrefix+"/clearData/deleteData"] = cc.DelRecord
   funcMap[urlPrefix+"/task/aggregateTaskList"] = cc.GetAllTasks
   var pubTopics []string
   for key, _ := range funcMap {
      pubTopics = append(pubTopics, key)