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