| | |
| | | |
| | | type CompareOnce struct { |
| | | CompareNum string `json:"compareOnce"` |
| | | CompareData *CompareResultSort `json:"compareData"` |
| | | CompareData *CompareList `json:"compareData"` |
| | | } |
| | | |
| | | type CompareResultSort []*protomsg.SdkCompareEach |
| | | type CompareList []*protomsg.SdkCompareEach |
| | | |
| | | func (crw CompareResultSort) Len()int { |
| | | return len(crw) |
| | | func (s CompareList) Len()int { |
| | | return len(s) |
| | | } |
| | | func (crw CompareResultSort) Swap(i,j int) { |
| | | crw[i],crw[j] = crw[j],crw[i] |
| | | func (s CompareList) Swap(i,j int) { |
| | | s[i],s[j] = s[j],s[i] |
| | | } |
| | | func (crw CompareResultSort) Less(i,j int) bool{//降序排序 |
| | | return crw[i].CompareScore > crw[j].CompareScore |
| | | func (s CompareList) Less(i,j int) bool{//降序排序 |
| | | return s[i].CompareScore > s[j].CompareScore |
| | | } |
| | | |
| | | var compResultHisM = make(map[string]*CompareOnce,0) |
| | |
| | | compServerList := config.CompServerInfo.Url |
| | | logger.Debug("compServerList:", compServerList) |
| | | //1.向各个compare进程发起请求拿到比对结果 |
| | | var resultList CompareResultSort |
| | | var resultList CompareList |
| | | //resultList :=make([]*protomsg.SdkCompareEach,0) |
| | | for _,str :=range compServerList{ |
| | | reqUrl := "tcp://"+str |