本地调试

qixiaoning

2025-07-18 24f44f6ecefb5e83295bab670533529c6bc81810

 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 (
@@ -75,7 +76,7 @@
   ms.Free()
}

//处理订阅消息
// 处理订阅消息
func dealSubMsg(ctx context.Context, ms *bhomeclient.MicroNode) {

   for {
@@ -125,6 +126,9 @@
   funcMap[urlPrefix+"/camera/getSyncSensorData"] = cc.GetSyncSensorData
   funcMap[urlPrefix+"/camera/saveNotExistOrUpdate"] = cc.SaveNotExistOrUpdate

   //摄像机关联督查任务
   funcMap[urlPrefix+"/camera/getTasks"] = cc.GetTaskById

   var pubTopics []string
   for key, _ := range funcMap {
      pubTopics = append(pubTopics, key)