sunty
2019-07-12 2fb553ab4774ad2605f18dacb5bacb481bfe2f8c
esutil/EsApi.go
@@ -43,16 +43,53 @@
}
// 根据底库id查询底库信息
func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
    var dbinfo protomsg.Baseinfo
func Dbtablefosbyid(id string) (protomsg.Dbtable, error) {
   var dbinfo protomsg.Dbtable
    
        var dbinfoRequest = `
            {
                "query":{
                  "bool": {
                     "filter": [{
                    "terms":{
                        "_id":[
                            "`+ id +`"
                        ]
                        }
                     }]
                  }
               }
            }
        `
   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
   var dbinfoRequest = `
            {
               "query": {
                  "bool": {
                     "filter": [{
                        "terms": {
                           "_id": [
                              "` + id + `"
                           ]
                        }
                     }]
                    }
                }
            }
@@ -67,10 +104,9 @@
        return dbinfo , err
    }
    baseinfo := Dbpersonbyid(sources)
    return baseinfo, nil
   dbperson := Dbpersonbyid(sources)
   return dbperson, nil
}
// 根据tableid 查询tablename
func Dbtablename(tableid string ) (tablename string, err error) {