多个正文获取

common/src/qfw/util/jy/subScribe.go

@@ -9,6 +9,7 @@ import (
 	"app.yhyue.com/moapp/jybase/mongodb"
 	"fmt"
 	"github.com/gogf/gf/v2/util/gconv"
+	"strings"
 	"time"
 )
 
@@ -189,11 +190,20 @@ func SaveUserLog(mg mongodb.MongodbSim, userid, phone, way, system, source, open
 }
 
 // 正文获取
-func GetEsDetail(sid string) string {
-	r := elastic.Get("bidding", "bidding", fmt.Sprintf(`{"query":{"bool":{"must":[{"term":{"id":"%s"}}]}},"_source":["_id","detail"],"size":1}`, sid))
-	detail := ""
-	if len(*r) > 0 {
-		detail = gconv.String((*r)[0]["detail"])
+func GetEsDetail(ids []string) map[string]interface{} {
+	data := map[string]interface{}{}
+	if len(ids) > 0 {
+		id := strings.Join(ids, `","`)
+		query := fmt.Sprintf(`{"query": {"bool": {"must": [{"terms": {"id": ["%s"]}}]}}, "_source": ["_id", "detail"], "size":%d }`, id, len(ids))
+		r := elastic.Get("bidding", "bidding", query)
+		detail := ""
+		if len(*r) > 0 {
+			for _, m := range *r {
+				_id := gconv.String(m["_id"])
+				detail := gconv.String(m["detail"])
+				data[_id] = detail
+			}
+		}
 	}
-	return detail
+	return data
 }