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/es.go | 18 +++++++++++------- 1 files changed, 11 insertions(+), 7 deletions(-) diff --git a/controllers/es.go b/controllers/es.go index 7e0cc8e..d566366 100644 --- a/controllers/es.go +++ b/controllers/es.go @@ -1,12 +1,13 @@ package controllers import ( - "basic.com/dbapi.git" + "basic.com/valib/logger.git" "fmt" "github.com/gin-gonic/gin" "math/rand" "strconv" "strings" + "webserver/cache" "webserver/extend/code" "webserver/extend/config" "webserver/extend/esutil" @@ -45,7 +46,7 @@ m :=make(map[string]interface{},0) m["compareNum"] = searchBody.CompareNum m["total"] = 0 - m["totalList"] = []service.CompareResult{} + m["totalList"] = []CompareResult{} util.ResponseFormat(c,code.CompareResultGone,m) return } @@ -53,7 +54,7 @@ m :=make(map[string]interface{},0) m["compareNum"] = searchBody.CompareNum m["total"] = 0 - m["totalList"] = []service.CompareResult{} + m["totalList"] = []CompareResult{} util.ResponseFormat(c,code.CompareResultGone,m) } @@ -103,12 +104,15 @@ esSize := strconv.Itoa(webSize) //浣跨敤es搴曞眰鏈哄埗澶勭悊鍒嗛〉 //璇锋眰澶� - 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 nil + } + url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) + "/" + index + "/_search?search_type=dfs_query_then_fetch" - var setApi dbapi.SysSetApi - _, sysconf := setApi.GetServerInfo() - analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}," + analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}}," //璇锋眰浣� prama := "{\"from\":\"" + esFrom + "\",\"size\":\"" + esSize + "\"," + -- Gitblit v1.8.0