| | |
| | | "webserver/extend/code" |
| | | "webserver/extend/config" |
| | | "webserver/extend/esutil" |
| | | "webserver/extend/logger" |
| | | "webserver/extend/util" |
| | | "webserver/models" |
| | | "webserver/service" |
| | |
| | | return |
| | | } |
| | | compServerList := config.CompServerInfo.Url |
| | | fmt.Println("compServerList:", compServerList) |
| | | logger.Debug("compServerList:", compServerList) |
| | | resultList :=make([]CompareResult,0) |
| | | for _,str :=range compServerList{ |
| | | reqUrl := "tcp://"+str |
| | | reqClient := deliver.NewClient(deliver.ReqRep, reqUrl) |
| | | err = reqClient.Send(b) |
| | | if err !=nil{ |
| | | logger.Debug("reqClient.Send err:",err) |
| | | continue |
| | | } |
| | | resultB, err := reqClient.Recv() |
| | | if err !=nil{ |
| | | logger.Debug("reqClient.Recv err:",err) |
| | | continue |
| | | } |
| | | rList :=make([]protomsg.Esinfo,0) |
| | | err = json.Unmarshal(resultB, &rList) |
| | | if err !=nil{ |
| | | logger.Debug("recv result Unmarshal err:", err) |
| | | continue |
| | | } |
| | | logger.Debug("rList:", rList) |
| | | |
| | | dbPersonM := make(map[string]*protomsg.Esinfo,0) |
| | | captureM := make(map[string]*protomsg.Esinfo,0) |
| | |
| | | esServerPort := config.EsInfo.Httpport |
| | | index := config.EsInfo.EsIndex.Dbtablepersons.IndexName |
| | | dbpersons, e := esApi.Dbpersoninfosbyid(personIds, index, esServerIp, esServerPort) |
| | | logger.Debug("dbpersons:", dbpersons) |
| | | if e ==nil && dbpersons !=nil { |
| | | for _,p :=range dbpersons { |
| | | var dbP = DbPersonVo { |
| | |
| | | resultList = append(resultList,cr) |
| | | } |
| | | } |
| | | logger.Debug("resultList:",resultList) |
| | | } |
| | | util.ResponseFormat(c,code.Success,resultList) |
| | | } |