| | |
| | | |
| | | dbPersonM := make(map[string]*protomsg.Esinfo,0) |
| | | captureM := make(map[string]*protomsg.Esinfo,0) |
| | | var personIds []string |
| | | var captureIds []string |
| | | personIds :=make([]string,0) |
| | | captureIds := make([]string,0) |
| | | for _,v :=range rList{ |
| | | if v.Tableid == captureTable { |
| | | captureM[v.Id] = &v |
| | |
| | | captureIds = append(captureIds,v.Id) |
| | | } |
| | | } |
| | | logger.Debug("personIds:", personIds) |
| | | logger.Debug("captureIds:",captureIds) |
| | | esServerIp := config.EsInfo.Masterip |
| | | esServerPort := config.EsInfo.Httpport |
| | | index := config.EsInfo.EsIndex.Dbtablepersons.IndexName |
| | | dbpersons, e := esApi.Dbpersoninfosbyid(personIds, index, esServerIp, esServerPort) |
| | | if e !=nil { |
| | | logger.Debug("Dbpersoninfosbyid.err:",e) |
| | | } |
| | | logger.Debug("dbpersons:", dbpersons) |
| | | if e ==nil && dbpersons !=nil { |
| | | for _,p :=range dbpersons { |