调整数据推送相关接口

qixiaoning

2025-08-08 ef51da5404827e826e979ad614950a9e0192f4c6

 search-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"
@@ -12,6 +8,11 @@
   "syscall"
   "vamicro/config"
   "vamicro/search-service/controllers"

   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/bhomedbapi.git"
   "basic.com/valib/logger.git"
   vaversion "basic.com/valib/version.git"
)

var (
@@ -71,7 +72,7 @@
func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
   funcMap := make(map[string]bhomeclient.MicroFunc)
   sc := new(controllers.EsSearchController)
   tc := new(controllers.TaskController)
   // tc := new(controllers.TaskController)

   funcMap[urlPrefix+"/dbperson/faceExtract"] = sc.FaceExtract
   funcMap[urlPrefix+"/dbperson/searchByPhoto"] = sc.SearchByPhoto
@@ -79,7 +80,7 @@
   funcMap[urlPrefix+"/es/esSearch"] = sc.PostEsSearch
   funcMap[urlPrefix+"/es/tagList"] = sc.PostEsTagList
   funcMap[urlPrefix+"/es/taskList"] = sc.PostEsTaskList
   funcMap[urlPrefix+"/task/aggregateTaskList"] = tc.AggregateTaskList
   // funcMap[urlPrefix+"/task/aggregateTaskList"] = tc.AggregateTaskList
   funcMap[urlPrefix+"/es/collect"] = sc.Collect
   funcMap[urlPrefix+"/es/deleteById"] = sc.PostEsDelete
   funcMap[urlPrefix+"/es/signMisreport"] = sc.SignMisreport