From 8ba736b00a482ab531f96b8047c23934e45f2d27 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期三, 24 七月 2019 18:04:36 +0800 Subject: [PATCH] query db person list --- controllers/fileController.go | 21 +++++++++++++++++++-- 1 files changed, 19 insertions(+), 2 deletions(-) diff --git a/controllers/fileController.go b/controllers/fileController.go index fe3f7d5..8f97e3e 100644 --- a/controllers/fileController.go +++ b/controllers/fileController.go @@ -6,6 +6,7 @@ "basic.com/valib/deliver.git" "bytes" "encoding/base64" + "encoding/json" "errors" "fmt" "github.com/gin-gonic/gin" @@ -27,6 +28,7 @@ "webserver/extend/util" "webserver/models" "webserver/service" + esApi "basic.com/pubsub/esutil.git" ) type FileController struct { @@ -168,12 +170,27 @@ util.ResponseFormat(c, code.ComError, "姣斿鏈嶅姟璇锋眰澶辫触") return } - msg, err := reqClient.Recv() + resultB, err := reqClient.Recv() if err !=nil{ util.ResponseFormat(c, code.ComError, "姣斿鏈嶅姟鍝嶅簲澶辫触") return } - fmt.Println("compareReuslt:",msg) + m :=make(map[string]float32,0) + err = json.Unmarshal(resultB, &m) + if err !=nil{ + util.ResponseFormat(c, code.ComError, "result Unmarshal err") + return + } + personIds := make([]string,len(m)) + for k,_ :=range m{ + personIds = append(personIds,k) + } + dbpeople, e := esApi.Dbpersoninfosbyid(personIds, "dbtablepersons", "192.168.1.182", "9200") + if e !=nil{ + util.ResponseFormat(c, code.ComError, "result es query err") + } else { + util.ResponseFormat(c,code.Success,dbpeople) + } } } -- Gitblit v1.8.0