|
@@ -201,7 +201,7 @@ func BuyerListRedisCache(query string, in *bxbuyer.BuyerListReq) (buyerNames []s
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
for i := 0; i < len(buyerBuckets.Buckets); i++ {
|
|
for i := 0; i < len(buyerBuckets.Buckets); i++ {
|
|
|
- if len(saveBuyerList) == 100 {
|
|
|
|
|
|
|
+ if len(saveBuyerList) == int(IC.C.BuyerSearchLimit) {
|
|
|
break
|
|
break
|
|
|
}
|
|
}
|
|
|
// 查buyer 确认数据存在 补充 buyerclass 省份 城市信息
|
|
// 查buyer 确认数据存在 补充 buyerclass 省份 城市信息
|
|
@@ -575,7 +575,7 @@ func BuyerSupplyInfo(buyerNames []string) (resp *bxbuyer.BuyerSupplyResp) {
|
|
|
func GetProjectContactCount(buyerName string) int64 {
|
|
func GetProjectContactCount(buyerName string) int64 {
|
|
|
start := time.Now()
|
|
start := time.Now()
|
|
|
list := []string{}
|
|
list := []string{}
|
|
|
- searchSql := fmt.Sprintf(`{"query":{"bool":{"filter":[{"term":{"buyer":"%s"}}]}},"_source":["list.buyerperson","list.buyertel"],"sort":[{"zbtime":"desc"}],"size":500}`,buyerName)
|
|
|
|
|
|
|
+ searchSql := fmt.Sprintf(`{"query":{"bool":{"filter":[{"term":{"buyer":"%s"}}]}},"_source":["list.buyerperson","list.buyertel"],"sort":[{"zbtime":"desc"}],"size":500}`, buyerName)
|
|
|
projectList := elastic.Get(P_INDEX, P_TYPE, searchSql)
|
|
projectList := elastic.Get(P_INDEX, P_TYPE, searchSql)
|
|
|
logx.Info("GetProjectContactCount esget 耗时", time.Since(start), searchSql)
|
|
logx.Info("GetProjectContactCount esget 耗时", time.Since(start), searchSql)
|
|
|
if projectList == nil || len(*projectList) == 0 {
|
|
if projectList == nil || len(*projectList) == 0 {
|
