fix query by id Multiple Id ([]id)

sunty

2019-07-12 78265dd08a17210ac67c1f82e2514b572c4734c8

fix query by id
Multiple Id ([]id)

 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
}


 esutil/EsClient.go

@@ -12,6 +12,7 @@
    "basic.com/pubsub/protomsg.git"
)


func Parsesources(sources []map[string]interface{}) (esinfos []*protomsg.Esinfo) {
    var ok bool
    for _, source := range sources {
@@ -52,9 +53,8 @@
    }
    return
}

//解析底库人员结构
func Dbpersonbyid(sources []map[string]interface{}) protomsg.Dbperson {
func Dbpersonbyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbperson) {
    var ok bool

    var tmpinfo protomsg.Dbperson
@@ -115,13 +115,14 @@
        //根据 tableid 获取 tablename
        //name, _:= Dbtablename(tmpinfo.TableId)
        //tmpinfo.TableName= name
            tmpinfos = append(tmpinfos, tmpinfo)
    }

    return tmpinfo
        return tmpinfos
}

//解析底库结构
func Dbtablebyid(sources []map[string]interface{}) protomsg.Dbtable {
func Dbtablebyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbtable) {
    var ok bool

    var tmpinfo protomsg.Dbtable
@@ -168,9 +169,11 @@
        Isnil("isSync", ok)
        tmpinfo.AnalyServerId, ok = source["analyServerId"].(string)
        Isnil("analyServerId", ok)

        tmpinfos = append(tmpinfos, tmpinfo)
    }

    return tmpinfo
    return tmpinfos
}

func Sourcelist(buf []byte) (sources []map[string]interface{}, err error) {