| | |
| | | "github.com/gin-gonic/gin" |
| | | ) |
| | | |
| | | // @Security ApiKeyAuth |
| | | // @Summary 标签列表 |
| | | // @Description 返回底库标签 |
| | | // @Accept json |
| | |
| | | // @Tags es |
| | | // @Success 200 {string} json "{"code":200, msg:"", success:true}" |
| | | // @Failure 500 {string} json "{"code":500, msg:"", success:false}" |
| | | // @Router /data/api-v/es/taskList [POST] |
| | | // @Router /data/api-v/es/tagList [POST] |
| | | func (sc *EsSearchController) PostEsTagList(c *gin.Context) { |
| | | |
| | | var dtApi dbapi.DbTableApi |
| | | dts, err := dtApi.FindAllDbTablesByCurServer() |
| | | dts, err := dtApi.FindAllDbTablesByCurServer("-1") |
| | | if err == nil { |
| | | if dts !=nil { |
| | | sources := make([]map[string]interface{}, 0) |
| | |
| | | tokenRes["title"] = dt.TableName |
| | | tokenRes["value"] = dt.Id |
| | | tokenRes["status"] = dt.IsDelete |
| | | tokenRes["bwType"] = dt.BwType //0:白名单,1:黑名单 |
| | | tokenRes["analyServerId"] = dt.AnalyServerId //为空是同步库,不为空是本地库 |
| | | if dt.IsDelete == 1 { |
| | | if GetTotalFromDb(dt.Id) == false { |
| | | continue |
| | |
| | | func GetTotalFromDb(id string) (flag bool) { |
| | | flag = false |
| | | localConf, err2 := cache.GetServerInfo() |
| | | if err2 !=nil || localConf.AlarmIp == "" { |
| | | if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" { |
| | | logger.Debug("localConfig is wrong!!!") |
| | | return false |
| | | } |
| | | url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) + |
| | | "/" + config.EsInfo.EsIndex.VideoPersons.IndexName + "/_search" |
| | | "/" + config.EsInfo.EsIndex.AiOcean.IndexName + "/_search" |
| | | prama := "{\"query\":{\"bool\":{\"filter\":[{\"term\":{\"baseInfo.tableId\":\"" + id + "\"}}]}},\"size\":0}" |
| | | buf, err := esutil.EsReq("POST", url, []byte(prama)) |
| | | if err != nil { |