sunty
2019-07-12 78265dd08a17210ac67c1f82e2514b572c4734c8
esutil/EsApi.go
@@ -2,7 +2,9 @@
import (
   "errors"
    "fmt"
   "strconv"
    "strings"
   "basic.com/pubsub/protomsg.git"
)
@@ -43,9 +45,9 @@
}
// 根据底库id查询底库信息
func Dbtablefosbyid(id string) (protomsg.Dbtable, error) {
   var dbinfo protomsg.Dbtable
func Dbtablefosbyid (id []string) ([]protomsg.Dbtable, error) {
    var dbinfo []protomsg.Dbtable
    dbtableId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
   var dbinfoRequest = `
            {
               "query": {
@@ -53,7 +55,7 @@
                     "filter": [{
                        "terms": {
                           "_id": [
                              "` + id + `"
                              "`+ dbtableId +`"
                           ]
                        }
                     }]
@@ -76,9 +78,9 @@
}
// 根据底库人员id查询底库人员信息
func Dbpersoninfosbyid(id string) (protomsg.Dbperson, error) {
   var dbinfo protomsg.Dbperson
func Dbpersoninfosbyid (id []string) ([]protomsg.Dbperson, error) {
    var dbinfo []protomsg.Dbperson
    dbtablePersonId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
   var dbinfoRequest = `
            {
               "query": {
@@ -86,7 +88,7 @@
                     "filter": [{
                        "terms": {
                           "_id": [
                              "` + id + `"
                              "`+ dbtablePersonId +`"
                           ]
                        }
                     }]
@@ -105,6 +107,7 @@
   }
   dbperson := Dbpersonbyid(sources)
    println(dbperson)
   return dbperson, nil
}