修改数据导出金额查询语句

src/jfw/front/dataExport.go

@@ -466,7 +466,6 @@ func (d *DataExport) ToCreateOrderPage(_id string) error {
 	//邮箱验证
 	email := d.GetSession("DataExportVerifyEmail_val")
 	resPhone := d.GetSession("DataExportVerifyPhone_val")
-	log.Println(util.Int64All(d.GetSession("CreatEVerifyTime")), "----", time.Now().Unix())
 	if email != nil {
 		lastSendDEVerify := util.Int64All(d.GetSession("CreatEVerifyTime"))
 		timeSpaceing := lastSendDEVerify - time.Now().Unix() + 60*5
@@ -635,9 +634,7 @@ func (d *DataExport) SendMailVerify() {
 		}
 		if email_used {
 			lastSendDEVerify := util.Int64All(d.GetSession("CreatEVerifyTime"))
-			log.Println(util.Int64All(d.GetSession("CreatEVerifyTime")), "----", time.Now().Unix())
 			timeSpaceing := lastSendDEVerify - time.Now().Unix() + 60*5
-			log.Println("--------:", timeSpaceing)
 			incurKey := fmt.Sprintf("SendEmail_%s_%d", d.GetSession("userId"), time.Now().Day())
 			//log.Println(incurKey)
 			if lastSendDEVerify == 0 || timeSpaceing < 0 {

src/jfw/front/swordfish.go

@@ -2315,7 +2315,6 @@ func (f *Front) SearchResult(at, name string) error {
 		var datas *[]map[string]interface{}
 		if list == nil {
 			count := elastic.Count(INDEX, TYPE, query1)
-			//log.Println("count:", count, "----", query)
 			r := rand.New(rand.NewSource(time.Now().UnixNano()))
 			currentPage = no
 			startPage = r.Intn(currentPage * limitcount)

src/jfw/modules/subscribepay/src/entity/dataExportSearch.go

@@ -78,7 +78,7 @@ func getDataExportSql(scd *SieveCondition) string {
 	multi_match := `{"multi_match": {"query": %s,"type": "phrase", "fields": [%s]}}`
 	query := `{"query":{"bool":{"must":[%s],"should":[%s],"minimum_should_match": %d}}}`
 	query_bool_should := `{"bool":{"should":[%s],"minimum_should_match": 1}}`
-	query_bools_must := `{"bool":{"must":[{"range":{"bidamount":{%s}}}],"must_not":[{"term":{"bidamount":0}},{"term":{"budget":0}}]}},{"bool":{"must":[{"term":{"bidamount":0}},{"range":{"budget":{%s}}}]}},{"bool":{"must":[{"term":{"budget":0}},{"range":{"bidamount":{%s}}}]}}`
+	query_price := `{"bool":{"must":[{"range":{"bidamount":{%s}}}]}},{"bool":{"must":[{"range":{"budget":{%s}}}],"must_not":[{"range":{"bidamount":{"gte":-1}}}]}}`
 	query_bool_must := `{"terms":{"%s":[%s]}}`
 	query_bool_must_and := `{"bool":{"must":[%s]%s}}`
 	gte := `"gte": %s`
@@ -202,7 +202,7 @@ func getDataExportSql(scd *SieveCondition) string {
 		if _maxPrice != "" {
 			sq += fmt.Sprintf(lte, _maxPrice)
 		}
-		query_price := fmt.Sprintf(query_bool_should, fmt.Sprintf(query_bools_must, sq, sq, sq))
+		query_price := fmt.Sprintf(query_bool_should, fmt.Sprintf(query_price, sq, sq))
 		musts = append(musts, query_price)
 	}
 	boolsNum := 0

src/jfw/public/search.go

@@ -61,7 +61,7 @@ func getDataExportSql(scd *SieveCondition) string {
 	multi_match := `{"multi_match": {"query": %s,"type": "phrase", "fields": [%s]}}`
 	query := `{"query":{"bool":{"must":[%s],"should":[%s],"minimum_should_match": %d}}}`
 	query_bool_should := `{"bool":{"should":[%s],"minimum_should_match": 1}}`
-	query_bools_must := `{"bool":{"must":[{"range":{"bidamount":{%s}}}],"must_not":[{"term":{"bidamount":0}},{"term":{"budget":0}}]}},{"bool":{"must":[{"term":{"bidamount":0}},{"range":{"budget":{%s}}}]}},{"bool":{"must":[{"term":{"budget":0}},{"range":{"bidamount":{%s}}}]}}`
+	query_price := `{"bool":{"must":[{"range":{"bidamount":{%s}}}]}},{"bool":{"must":[{"range":{"budget":{%s}}}],"must_not":[{"range":{"bidamount":{"gte":-1}}}]}}`
 	query_bool_must := `{"terms":{"%s":[%s]}}`
 	query_bool_must_and := `{"bool":{"must":[%s]%s}}`
 	gte := `"gte": %s`
@@ -185,7 +185,7 @@ func getDataExportSql(scd *SieveCondition) string {
 		if _maxPrice != "" {
 			sq += fmt.Sprintf(lte, _maxPrice)
 		}
-		query_price := fmt.Sprintf(query_bool_should, fmt.Sprintf(query_bools_must, sq, sq, sq))
+		query_price := fmt.Sprintf(query_bool_should, fmt.Sprintf(query_price, sq, sq))
 		musts = append(musts, query_price)
 	}
 	boolsNum := 0
@@ -273,9 +273,6 @@ func getSqlObjFromId(_id string) *SieveCondition {
 
 //数据导出-查询结果数量
 func GetDataExportSearchCountUseId(_id string) (count int) {
-	defer func(t time.Time) {
-		fmt.Println("do Cost: ", time.Since(t).Seconds())
-	}(time.Now())
 	scd := getSqlObjFromId(_id)
 	qstr := getDataExportSql(scd)
 	log.Printf("GetDataExportSearchCountUseId-%s-count:%d-sql:%s\n", _id, count, qstr)
@@ -669,7 +666,6 @@ func doSearch(sql string, start, count int, dataType string) *[]map[string]inter
 		//分页排序
 		sql = sql[:len(sql)-1] + `,"sort": {"publishtime":"desc"},"from":` + strconv.Itoa(start) + `,"size":` + strconv.Itoa(count) + "}"
 	}
-	// log.Println("sql----", sql)
 	return elastic.Get(INDEX, TYPE, sql)
 }
 
@@ -709,7 +705,6 @@ func ScreenData(arr *[]map[string]interface{}, dataType string, resultNum int, k
 		if emptyNum == -1 {
 			continue
 		}
-		//		log.Println(util.ObjToString(v["title"]), "----", kws[0].Keyword)
 		if len(kws) > 0 && kws[0].Keyword != "" {
 			var kwsFlag = true
 			for _, vk := range kws {