修改权限,修复删除rag记录问题

qixiaoning

1 天以前 c3fd4effdef0cc5955f89b5df279b14841e857f5

 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)