From 58cdde93bbe0c913c0c45a63bb9d7307fac65962 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期二, 25 六月 2019 19:57:05 +0800
Subject: [PATCH] add tablename by id
---
esutil/EsClient.go | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/esutil/EsClient.go b/esutil/EsClient.go
index fa2de87..4381757 100644
--- a/esutil/EsClient.go
+++ b/esutil/EsClient.go
@@ -12,19 +12,16 @@
"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{}) []protomsg.Baseinfo {
- var tmpinfo protomsg.Baseinfo
- var baseinfos []protomsg.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)
@@ -42,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
}
@@ -95,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