up

service/ziyin_service.go

@@ -161,19 +161,17 @@ func searchZiYingGoods( req map[string]string,zy bool,classList *model.ZhyClassL
 	query := elastic.NewBoolQuery()
 
 	if(len(req) > 0){
-
 		for k,v:=range req{
 			k_temp := make([]string,0)
 			if strings.Contains(k,"/") {
 				k_temp = strings.Split(k,"/")
 				if len(k_temp) == 2 {
-					isok := makeQuery(query,k_temp,&goods_temp_status,&v,&keyword)
+					isok := makeQuery(query,source,k_temp,&goods_temp_status,&v,&keyword)
 					if !isok {
 						continue;
 					}
 				}
 			}
-
 		}
 	}
 	source.Query(query)
@@ -181,7 +179,7 @@ func searchZiYingGoods( req map[string]string,zy bool,classList *model.ZhyClassL
 	fmt.Println(res)
 }
 
-func makeQuery(query *elastic.BoolQuery,conditions []string,goods_temp_status *int,searchValue *string,keyword *string) bool{
+func makeQuery(query *elastic.BoolQuery,source *elastic.SearchSource,conditions []string,goods_temp_status *int,searchValue *string,keyword *string) bool{
 
 	var (
 		err error
@@ -202,6 +200,9 @@ func makeQuery(query *elastic.BoolQuery,conditions []string,goods_temp_status *i
 		redisConn.Close()
 	}()
 
+	searchKey = strings.TrimSpace(searchKey)
+	searchCondition = strings.TrimSpace(searchCondition)
+	*searchValue = strings.TrimSpace(*searchValue)
 	switch searchCondition{
 		case "condition":
 			if searchKey != "status" && searchCondition == ""{
@@ -322,9 +323,50 @@ func makeQuery(query *elastic.BoolQuery,conditions []string,goods_temp_status *i
 				query.Must(elastic.NewTermsQuery(searchKey,term_v_interface))
 			}
 		case "order":
-
+			orderSort := false
+			if strings.ToLower(*searchValue)  == "asc"{
+				orderSort =true
+			}else if strings.ToLower(*searchValue) == "desc"{
+				orderSort =false
+			}
+			source.Sort(searchKey,orderSort)
 		case "range":
+			paramsRange := make([]int64,2)
+			term_v := make([]string,0)
+			term_v = strings.Split(*searchValue,",")
+			if len(term_v) > 0{
+				for i:=0;i<=len(term_v)-1;i++{
+					if term_v[i] != "" {
+						if rangeGte,err :=  strconv.ParseInt(term_v[i], 10, 64);err == nil{
+							paramsRange[i] = rangeGte
+						}
+					}
+				}
+			}
+			query.Must(elastic.NewRangeQuery(searchKey).Gte(paramsRange[0]).Lte(paramsRange[1]))
+
 		case "sr":
+			term_v := make([]string,0)
+			term_v = strings.Split(*searchValue,",")
+			if len(term_v) == 2{
+				term_v0 := strings.ToLower(strings.TrimSpace(term_v[0]))
+				term_v1 := strings.TrimSpace(term_v[1])
+				if term_v1_int,err :=  strconv.ParseInt(term_v1, 10, 64);err == nil{
+					if php2go.InArray(term_v0,[]string{"gt","lt","gte","lte"}){
+						rangequery := elastic.NewRangeQuery(searchKey)
+						if term_v0 == "gt"{
+							rangequery.Gt(term_v1_int)
+						}else if(term_v0 == "lt"){
+							rangequery.Lt(term_v1_int)
+						}else if(term_v0 == "gte"){
+							rangequery.Gte(term_v1_int)
+						}else if(term_v0 == "lte"){
+							rangequery.Lte(term_v1_int)
+						}
+						query.Must(rangequery)
+					}
+				}
+			}
 		case "nested":
 		case "eq":
 	}