|
@@ -62,7 +62,7 @@ func (l *BuyerListLogic) BuyerList(in *bxbuyer.BuyerListReq) (*bxbuyer.BuyerList
|
|
|
if model.CheckEmpty(in) {
|
|
|
res := model.GetL2CacheData("other", model.BuyerListQueryLock, model.P_redis_key, func() interface{} {
|
|
|
//聚合查询获取最近一个月中标单位数量最多的采购单位
|
|
|
- agg := model.GetAggs("projectset", "projectset", fmt.Sprintf(`{"query":{"bool":{"must":[{"range":{"jgtime":{"gt":%d}}}]}},"aggs":{"buyerTop":{"terms":{"field":"buyer","size":%d}}}}`, time.Now().AddDate(0, 0, -1).Unix(), IC.C.BuyerSearchLimit))
|
|
|
+ agg := model.GetAggs("projectset", "projectset", fmt.Sprintf(`{"query":{"bool":{"must":[{"range":{"jgtime":{"gt":%d}}}]}},"aggs":{"buyerTop":{"terms":{"field":"buyer","size":%d}}}}`, time.Now().AddDate(-3, 0, -1).Unix(), IC.C.BuyerSearchLimit))
|
|
|
var ta TopAgg
|
|
|
err := gconv.Struct(gconv.String(agg["buyerTop"]), &ta)
|
|
|
if err != nil {
|