|
@@ -76,7 +76,7 @@ func EntSearch(searchCode string) ([]*bxcore.Search, int64) {
|
|
thisQuery = append(thisQuery, fmt.Sprintf(`{"match_phrase":{"name":"%s"}}`, searchCode))
|
|
thisQuery = append(thisQuery, fmt.Sprintf(`{"match_phrase":{"name":"%s"}}`, searchCode))
|
|
musts = append(musts, fmt.Sprintf(`{"bool":{"should":[%s],"minimum_should_match": 1}}`, strings.Join(thisQuery, ",")))
|
|
musts = append(musts, fmt.Sprintf(`{"bool":{"should":[%s],"minimum_should_match": 1}}`, strings.Join(thisQuery, ",")))
|
|
sql := fmt.Sprintf(entQuery, strings.Join(musts, ","), "")
|
|
sql := fmt.Sprintf(entQuery, strings.Join(musts, ","), "")
|
|
- sql = sql[:len(sql)-1] + fmt.Sprintf(`,"from":%d,"size":%d}`, 0, 10)
|
|
|
|
|
|
+ sql = sql[:len(sql)-1] + fmt.Sprintf(`,"from":%d,"size":%d}`, 0, 5)
|
|
log.Println("企业搜索sql:", sql)
|
|
log.Println("企业搜索sql:", sql)
|
|
count, list := elastic.GetWithCount(index, itype, "", sql)
|
|
count, list := elastic.GetWithCount(index, itype, "", sql)
|
|
if list != nil {
|
|
if list != nil {
|
|
@@ -94,7 +94,7 @@ func ProcureSearch(searchCode string) ([]*bxcore.Search, int64) {
|
|
count := int64(0)
|
|
count := int64(0)
|
|
//数据查询处理
|
|
//数据查询处理
|
|
entNameQuery := fmt.Sprintf(`{"multi_match": {"query": "%s","type": "phrase", "fields": ["name"]}}`, searchCode)
|
|
entNameQuery := fmt.Sprintf(`{"multi_match": {"query": "%s","type": "phrase", "fields": ["name"]}}`, searchCode)
|
|
- qstr := fmt.Sprintf(query, fmt.Sprintf(`"from":%d,"size": %d,`, 0, 10), entNameQuery)
|
|
|
|
|
|
+ qstr := fmt.Sprintf(query, fmt.Sprintf(`"from":%d,"size": %d,`, 0, 5), entNameQuery)
|
|
log.Println("采购单位搜索sql:", qstr)
|
|
log.Println("采购单位搜索sql:", qstr)
|
|
count, rs := elastic.GetWithCount(BuyerIndex, BuyerType, "", qstr)
|
|
count, rs := elastic.GetWithCount(BuyerIndex, BuyerType, "", qstr)
|
|
//rs := elastic.Get(BuyerIndex, BuyerType, qstr) // 采购单位列表
|
|
//rs := elastic.Get(BuyerIndex, BuyerType, qstr) // 采购单位列表
|