From 4c7890a506f95bfc8d06a75dbf6150bb8fcad1bb Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期六, 28 九月 2019 15:28:32 +0800 Subject: [PATCH] add logger --- controllers/taglist.go | 14 +++++++++++--- 1 files changed, 11 insertions(+), 3 deletions(-) diff --git a/controllers/taglist.go b/controllers/taglist.go index d897d74..485bfb4 100644 --- a/controllers/taglist.go +++ b/controllers/taglist.go @@ -2,8 +2,11 @@ import ( "basic.com/dbapi.git" + "basic.com/valib/logger.git" "encoding/json" "fmt" + "strconv" + "webserver/cache" "webserver/extend/code" "webserver/extend/config" "webserver/extend/esutil" @@ -19,11 +22,11 @@ // @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) @@ -50,7 +53,12 @@ //鍒ゆ柇搴曞簱鏄惁鏈夋暟鎹� func GetTotalFromDb(id string) (flag bool) { flag = false - url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport + + localConf, err2 := cache.GetServerInfo() + 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" prama := "{\"query\":{\"bool\":{\"filter\":[{\"term\":{\"baseInfo.tableId\":\"" + id + "\"}}]}},\"size\":0}" buf, err := esutil.EsReq("POST", url, []byte(prama)) -- Gitblit v1.8.0