From 0f45d9efa1dfd1580975ecc410d44de053f7af81 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期五, 05 七月 2019 09:45:05 +0800
Subject: [PATCH] remove base64

---
 esutil/EsClient.go |   19 ++++++++++---------
 1 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/esutil/EsClient.go b/esutil/EsClient.go
index d022703..4381757 100644
--- a/esutil/EsClient.go
+++ b/esutil/EsClient.go
@@ -8,21 +8,20 @@
 	"net/http"
 	"time"
     "bytes"
-)
 
+    "basic.com/pubsub/protomsg.git"
+)
 
 func GetDbinfo(dbinforequest string)([]byte, error) {
     buf , err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/dbpersons/_search", []byte(dbinforequest))
     return buf, err
 }
 
-
-func Parsesources(sources []map[string]interface{}) []Baseinfo {
-    var tmpinfo Baseinfo
-    var baseinfos []Baseinfo
+func Parsesources(sources []map[string]interface{}) []*protomsg.Baseinfo {
+    var baseinfos []*protomsg.Baseinfo
     var ok bool
     for _, source := range sources {
-
+        var tmpinfo protomsg.Baseinfo
         tmpinfo.FaceFeature, ok =   source["faceFeature"].(string)
             Isnil("faceFeature", ok)
         tmpinfo.PersonId, ok    =   source["id"].(string)  
@@ -40,7 +39,11 @@
         tmpinfo.Idcard,ok       =  source["idCard"].(string)
             Isnil("idCard", ok)
         tmpinfo.MonitorLevel,ok =  source["monitorLevel"].(string)
-        baseinfos = append(baseinfos, tmpinfo)
+
+        // 鏍规嵁 tableid 鑾峰彇 tablename
+        name, _:= Dbtablename(tmpinfo.TableId) 
+        tmpinfo.TableName= name 
+        baseinfos = append(baseinfos, &tmpinfo)
     }
     return baseinfos
 }
@@ -93,13 +96,11 @@
     }
 
     defer resp.Body.Close()
-
     body, err := ioutil.ReadAll(resp.Body)
     if err != nil {
         fmt.Println(err) 
         return nil , err
     }
-
     return body, nil
 }
 

--
Gitblit v1.8.0