fuwencai vor 1 Jahr
Ursprung
Commit
0ddee820e5
3 geänderte Dateien mit 10 neuen und 4 gelöschten Zeilen
  1. 4 0
      jyBXCore/rpc/etc/db.yaml
  2. 1 1
      jyBXCore/rpc/model/es/es.go
  3. 5 3
      jyBXCore/rpc/service/search.go

+ 4 - 0
jyBXCore/rpc/etc/db.yaml

@@ -23,6 +23,8 @@ es:
     version: v7
     userName: ""
     password: ""
+    index: bidding
+    type: bidding
 mongo:
     main:
         dbName: qfw
@@ -42,6 +44,8 @@ esNoLogin:
     version: v7
     userName: ""
     password: ""
+    index: bidding_year
+    type: bidding_year
 esFree:
     addr: http://192.168.3.241:9205,http://192.168.3.149:9200
     size: 50

+ 1 - 1
jyBXCore/rpc/model/es/es.go

@@ -91,7 +91,7 @@ func (e *SearchByES) GetAllByNgramWithCount(loginType int) (int64, *[]map[string
 		case LoginTypePay:
 			return elastic.GetWithCount(e.Index, e.IType, e.Query, queryStr)
 		case LoginTypeFree:
-			// 免费用户 
+			// 免费用户
 			return IC.FreeEs.GetWithCount(e.Index, e.IType, e.Query, queryStr)
 		default:
 			// 未登录

+ 5 - 3
jyBXCore/rpc/service/search.go

@@ -43,8 +43,6 @@ func GetBidSearchData(in *bxcore.SearchReq, isCache bool) (count int64, list []*
 			fields = fields + es.BidSearchFieldFile
 		}
 		biddingSearch := es.SearchByES{
-			Index:      MC.If(in.UserId == "", es.INDEXNoLogin, es.INDEX).(string),
-			IType:      MC.If(in.UserId == "", es.TYPENoLogin, es.TYPE).(string),
 			Query:      es.GetSearchQuery(in, es.GetBidSearchQuery(in)),
 			FindFields: MC.If(isCache, "title", "detail").(string),
 			Order:      es.BidSearchSort,
@@ -58,12 +56,16 @@ func GetBidSearchData(in *bxcore.SearchReq, isCache bool) (count int64, list []*
 		// 处理免费用户index
 		if in.UserId == "" {
 			loginType = es.LoginTypeNoLogin
+			biddingSearch.Index = IC.DB.EsNoLogin.Index
+			biddingSearch.IType = IC.DB.EsNoLogin.Type
 		} else if !in.IsPay {
+			loginType = es.LoginTypeFree
 			biddingSearch.Index = IC.DB.EsFree.Index
 			biddingSearch.IType = IC.DB.EsFree.Type
-			loginType = es.LoginTypeFree
 		} else {
 			loginType = es.LoginTypePay
+			biddingSearch.Index = IC.DB.Es.Index
+			biddingSearch.IType = IC.DB.Es.Type
 		}
 		var repl *[]map[string]interface{}
 		if in.UserId != "" {