From 2c9e82adc057f330d7c56be04c4333dae92cfd5c Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期五, 26 七月 2019 19:08:47 +0800
Subject: [PATCH] add Videopersonsinfosbyid
---
EsApi.go | 35 ++++++++++++++++++++++++++++++++++-
1 files changed, 34 insertions(+), 1 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index 246b57a..0baed8f 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -100,6 +100,40 @@
return dbtable, nil
}
+// 鏍规嵁鎶撴媿浜哄憳id鏌ヨ鎶撴媿浜哄憳淇℃伅
+func Videopersonsinfosbyid (id []string, indexName string, serverIp string, serverPort string) ([]protomsg.Videopersons, error) {
+ var videopersonsInfo []protomsg.Videopersons
+ videopersonsPersonId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
+ var dbinfoRequest = `
+ {
+ "query": {
+ "bool": {
+ "filter": [{
+ "terms": {
+ "id": [
+ "`+ videopersonsPersonId +`"
+ ]
+ }
+ }]
+ }
+ }
+ }
+ `
+ buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search",[]byte(dbinfoRequest))
+ if err != nil {
+ return videopersonsInfo, err
+ }
+
+ sources, err := Sourcelist(buf)
+ if err != nil {
+ return videopersonsInfo , err
+ }
+
+ videoperson := Videopersonsbyid(sources)
+ println(videoperson)
+ return videoperson,nil
+}
+
// 鏍规嵁搴曞簱浜哄憳id鏌ヨ搴曞簱浜哄憳淇℃伅
func Dbpersoninfosbyid (id []string, indexName string, serverIp string, serverPort string) ([]protomsg.Dbperson, error) {
var dbinfo []protomsg.Dbperson
@@ -161,7 +195,6 @@
if err != nil {
return "",err
}
-
for _, source := range sources {
if name, ok := source["tableName"].(string); ok {
tablename = name
--
Gitblit v1.8.0