|
@@ -441,13 +441,18 @@ func (this *Analysis) DecReviewExperts() {
|
|
//log.Println("专家top10", aggsArr["reviewExperts"])
|
|
//log.Println("专家top10", aggsArr["reviewExperts"])
|
|
var expertlist []map[string]interface{}
|
|
var expertlist []map[string]interface{}
|
|
if reviewExperts, ok := aggsArr["reviewExperts"].([]map[string]interface{}); ok {
|
|
if reviewExperts, ok := aggsArr["reviewExperts"].([]map[string]interface{}); ok {
|
|
- for _, v := range reviewExperts {
|
|
|
|
- expertName := qutil.ObjToString(v["key"])
|
|
|
|
- decQuery := ExpertsCooperationProjectCount(expertName, getRes.Area, getRes.BuyerContent, getRes.Buyer, getRes.LimitTime, getRes.SearchItem, getRes.ProjectScope)
|
|
|
|
- _, count, _ := elastic.GetAggs("projectset", "projectset", decQuery)
|
|
|
|
- v["count"] = count
|
|
|
|
- expertlist = append(expertlist, v)
|
|
|
|
|
|
+ for k, v := range reviewExperts {
|
|
|
|
+ if k < 10 {
|
|
|
|
+ expertName := qutil.ObjToString(v["key"])
|
|
|
|
+ decQuery := ExpertsCooperationProjectCount(expertName, getRes.Area, getRes.BuyerContent, getRes.Buyer, getRes.LimitTime, getRes.SearchItem, getRes.ProjectScope)
|
|
|
|
+ _, count, _ := elastic.GetAggs("projectset", "projectset", decQuery)
|
|
|
|
+ v["doc_count"] = count
|
|
|
|
+ expertlist = append(expertlist, v)
|
|
|
|
+ } else {
|
|
|
|
+ break
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
+ util.SortData(&expertlist, "doc_count", true)
|
|
aggsArr["reviewExperts"] = expertlist
|
|
aggsArr["reviewExperts"] = expertlist
|
|
}
|
|
}
|
|
|
|
|