ES---golang

ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。
1.查询DSL（query DSL）和过滤DSL（filter DSL）

package elastic

import (
"boss/base"
"boss/models"
"context"
"fmt"
"gopkg.in/olivere/elastic.v5"
"log"
"os"
"reflect"
"strconv"
"strings"
)

var client *elastic.Client
var host = "http://127.0.0.1:9200/"

type CmsAudiosets struct {
Name string json:"name"
PublishName string json:"publishname"
Summary string json:"summary"
Detail string json:"detail"
Cid int64 json:"cid"
Type int json:"type"
ImgUrl string json:"imgurl"
Frequency string json:"frequency"
LogoImg string json:"logoimg"
AuthorName string json:"authorname"
Sort int64 json:"sort"
}

//初始化
func init() {
errorlog := log.New(os.Stdout, "APP", log.LstdFlags)
var err error
client, err = elastic.NewClient(elastic.SetErrorLog(errorlog), elastic.SetURL(host))
if err != nil {
base.LOG_INFO("client err:", err)
panic(err)
}
info, code, err := client.Ping(host).Do(context.Background())
if err != nil {
base.LOG_INFO("client err:", err)
panic(err)
}
base.LOG_INFO("client:", code, info.Version.Number)
//本地测试使用
create()
}

//创建
func create() {
var dao models.DetailDao
//获取除电台外数据
maps_ic := dao.GetCMSAudioAllExcept4()
if maps_ic != nil {
maps := maps_ic.(*models.MapsModel)
//base.LOG_INFO("maps:", maps)
content_index := 0
for index := int64(0); index < maps.Counts; index++ {
gcontent := new(CmsAudiosets)
gcontent.Name = maps.GetString("name", index)
gcontent.PublishName = maps.GetString("publishName", index)
gcontent.Summary = maps.GetString("summary", index)
gcontent.Cid = maps.GetInt64("cid", index)
gcontent.Type = maps.GetInt("type", index)
gcontent.ImgUrl = maps.GetString("imgurl", index)
//TODO 作者
content_index++
put1, err := client.Index().Index("cmsaudio").Type("cmsaudiosets").
Id(strconv.Itoa(content_index)).BodyJson(gcontent).Do(context.Background())
if err != nil {
panic(err)
}
fmt.Printf("Indexed tweet %s to index s%s, type %s\n", put1.Id, put1.Index, put1.Type)
}
}
//电台
maps_ir := dao.GetAllFmRadio()
if maps_ic != nil {
maps := maps_ir.(models.MapsModel)
//base.LOG_INFO("maps:", *maps)
content_index := 0
for index := int64(0); index < maps.Counts; index++ {
gcontent := new(CmsAudiosets)
gcontent.Name = maps.GetString("id", index)
gcontent.Cid = maps.GetInt64("cid", index)
gcontent.Type = 4
gcontent.ImgUrl = maps.GetString("imgurl", index)
gcontent.LogoImg = maps.GetString("logoimg", index)
gcontent.Frequency = maps.GetString("frequency", index)
content_index++
put1, err := client.Index().Index("cmsaudio").Type("cmsaudiosets").
Id(strconv.Itoa(content_index)).BodyJson(gcontent).Do(context.Background())
if err != nil {
panic(err)
}
fmt.Printf("Indexed tweet %s to index s%s, type %s\n", put1.Id, put1.Index, put1.Type)
}
}
}

type DetailAssociateContent struct {
Id string json:"id"
Name string json:"name"
}

//搜索联想词4028
func AssociatWord(keyword string) ([]DetailAssociateContent, int, error) {
var res *elastic.SearchResult
var err error
//取所有 TODO context时间
res, err = client.Search("cmsaudio").Type("cmsaudiosets").Do(context.Background())
boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword))
res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())
var estyp CmsAudiosets
var content = make([]DetailAssociateContent, 0)
index := 0
for _, item := range res.Each(reflect.TypeOf(estyp)) { //从搜索结果中取数据的方法
t := item.(CmsAudiosets)
if strings.Index(t.Name, keyword) != -1 {
content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Name})

        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Summary, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Summary})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Frequency, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Frequency})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.PublishName, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.PublishName})

        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.AuthorName, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.AuthorName})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Detail, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Detail})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
}
return content, index, err

}

type DetailSearchContent struct {
Name string json:"name"
Summary string json:"summary"
Cid int64 json:"cid"
Type int json:"type"
ImgUrl string json:"imgurl"
Frequency string json:"frequency"
LogoImg string json:"logoimg"
}

func EsSearch(keyword string, typ string) ([]DetailSearchContent, int, error) {
var res *elastic.SearchResult
var content = make([]DetailSearchContent, 0)
index := 0
var estyp CmsAudiosets
var err error
//取所有
res, err = client.Search("cmsaudio").Type("cmsaudiosets").Do(context.Background())
if typ == "0" {
boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword))
res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())
} else {
typint, er := strconv.Atoi(typ)
if er != nil {
return content, index, err
}
boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword)).Filter(elastic.NewTermQuery("type", typint))
res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())
}
for _, item := range res.Each(reflect.TypeOf(estyp)) {
t := item.(CmsAudiosets)
content = append(content, DetailSearchContent{
Name: t.Name,
Summary: t.Summary,
Cid: t.Cid,
Type: t.Type,
ImgUrl: t.ImgUrl,
Frequency: t.Frequency,
LogoImg: t.LogoImg,
})
if index >= 20 {
return content, index, err
}
index++
}
return content, index, err
}