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