feat:免费用户

jyBXCore/rpc/entity/search.go

@@ -155,7 +155,6 @@ func (kws *KeyWordsSearch) GetSearchKeyWordsQueryStr(in *bxcore.SearchReq) (sear
 func (kws *KeyWordsSearch) SearchParamsHandle(in *bxcore.SearchReq) []string {
 	//判断用户身份
 	userInfo := util.GetVipState(IC.MainMysql, IC.Mgo, in.UserId, in.EntId)
-	userInfo.BigMember = 1
 	//是否是付费用户
 	in.IsPay = userInfo.IsPayedUser()
 	//默认搜索范围

jyBXCore/rpc/model/es/es.go

@@ -9,6 +9,7 @@ import (
 )
 
 const (
+	queryBoolMustTermDomain = `{"bool": {"must": [{ "term": {"bid_field": "%s" }}]}}` // 领域化数据类型
 	multiMatch              = `{"multi_match": {"query": "%s","type": "phrase", "fields": [%s]}}`
 	query                   = `{"query":{"bool":{"must":[%s],"must_not":[%s]}}}`
 	queryBoolShould         = `{"bool":{"should":[%s],"minimum_should_match": 1}}`

jyBXCore/rpc/model/es/search.go

@@ -196,6 +196,10 @@ func GetSearchQuery(in *bxcore.SearchReq, mustQuery string) (qstr string) {
 			musts = append(musts, fmt.Sprintf(queryMissing, "isValidFile"))
 		}
 	}
+	// 如果是领域化数据则需要加标签
+	if in.BidField != "" {
+		musts = append(musts, fmt.Sprintf(queryBoolMustTermDomain, in.BidField))
+	}
 	qstr = fmt.Sprintf(query, strings.Join(musts, ","), strings.Join(mustNot, ","))
 	logx.Info("qstr:", qstr)
 	return