fix query by id Multiple Id ([]id)

sunty

2019-07-12 78265dd08a17210ac67c1f82e2514b572c4734c8

 esutil/EsApi.go

@@ -2,9 +2,11 @@

import (
        "errors"
        "strconv"
    "fmt"
    "strconv"
    "strings"

        "basic.com/pubsub/protomsg.git"
    "basic.com/pubsub/protomsg.git"
        )

// 查询底库人员信息
@@ -43,19 +45,71 @@
}

// 根据底库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 Dbtablefosbyid (id []string) ([]protomsg.Dbtable, error) {
    var dbinfo []protomsg.Dbtable
    dbtableId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
        var dbinfoRequest = `
            {
               "query": {
                  "bool": {
                     "filter": [{
                        "terms": {
                           "_id": [
                              "`+ dbtableId +`"
                           ]
                        }
                     }]
                  }
               }
            }
        `
    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtables/_search",[]byte(dbinfoRequest))
    if err != nil {
        return dbinfo,  err
    }

    sources, err := Sourcelist(buf)
    if err != nil {
        return dbinfo , err
    }

    dbtable := Dbtablebyid(sources)
    return dbtable, nil
}

// 根据底库人员id查询底库人员信息
func Dbpersoninfosbyid (id []string) ([]protomsg.Dbperson, error) {
    var dbinfo []protomsg.Dbperson
    dbtablePersonId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
    var dbinfoRequest = `
            {
               "query": {
                  "bool": {
                     "filter": [{
                        "terms": {
                           "_id": [
                              "`+ dbtablePersonId +`"
                           ]
                        }
                     }]
                  }
               }
            }
        `
    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
    }

    dbperson := Dbpersonbyid(sources)
    println(dbperson)
    return dbperson,nil
}

// 根据tableid 查询tablename
func Dbtablename(tableid string ) (tablename string, err error) {