From d25f504c5fabb9eadb77c38f0df3cda983495be1 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期一, 08 七月 2019 15:40:39 +0800
Subject: [PATCH] add query dbperson info by id
---
esutil/EsApi.go | 39 +++++++++++++++++++++++++++------------
1 files changed, 27 insertions(+), 12 deletions(-)
diff --git a/esutil/EsApi.go b/esutil/EsApi.go
index 7893b16..8be8c68 100644
--- a/esutil/EsApi.go
+++ b/esutil/EsApi.go
@@ -43,18 +43,33 @@
}
// 鏍规嵁搴曞簱id鏌ヨ搴曞簱淇℃伅
-//func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
-// var dbinfo protomsg.Baseinfo
-//
-// url := fmt.Sprintf("http://192.168.1.182:9200/dbtablepersons/dbpersons/_search", id)
-// buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/dbpersons/_search",[]byte(dbinfoRequest))
-// if err != nil {
-// return dbinfo, nil
-// }
-//
-// sources, err := Sourcelist(buf)
-// if err != nil {}
-//}
+func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
+ var dbinfo protomsg.Baseinfo
+
+ var dbinfoRequest = `
+ {
+ "query":{
+ "terms":{
+ "_id":[
+ "`+ id +`"
+ ]
+ }
+ }
+ }
+ `
+ buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/_search",[]byte(dbinfoRequest))
+ if err != nil {
+ return dbinfo, err
+ }
+
+ sources, err := Sourcelist(buf)
+ if err != nil {
+ return dbinfo , err
+ }
+
+ baseinfo := Dbpersonbyid(sources)
+ return baseinfo, nil
+}
// 鏍规嵁tableid 鏌ヨtablename
--
Gitblit v1.8.0