| | |
| | | } |
| | | |
| | | // 根据底库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 + `" |
| | | ] |
| | | } |
| | | }] |
| | | } |
| | | } |
| | | } |
| | |
| | | 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) { |