Method GetDocForElasticSearch

models/DocumentModel.go:388–436

根据id查询搜索数据结构 @param id 根据id查询搜索文档

(id ...int)

//根据id查询搜索数据结构
//@param            id         根据id查询搜索文档
func (this *Document) GetDocForElasticSearch(id ...int) (es []ElasticSearchData, err error) {
	var (
		sql    string
		params []orm.Params
		num    int64
	)
	tables := []string{GetTableDocumentInfo() + " i", GetTableDocument() + " d", GetTableDocumentStore() + " ds"}
	on := []map[string]string{
		{"i.Id": "d.Id"},
		{"i.DsId": "ds.Id"},
	}
	fields := map[string][]string{
		"i":  {"Score", "Id", "Dcnt", "Vcnt", "Ccnt", "Price", "TimeCreate"},
		"d":  {"Title", "Description", "Keywords"},
		"ds": {"Page", "Size", "ExtNum DocType", "Id DsId"},
	}
	listRows := len(id)
	if listRows == 0 {
		err = errors.New("请至少传递一个文档Id")
		return
	}
	var idSlice []string
	for _, v := range id {
		idSlice = append(idSlice, strconv.Itoa(v))
	}
	if sql, err = LeftJoinSqlBuild(tables, on, fields, 1, listRows, nil, nil, fmt.Sprintf("i.Status>=0 and i.Id in(%v)", strings.Join(idSlice, ","))); err == nil {
		if num, err = orm.NewOrm().Raw(sql).Values(&params); num > 0 {
			for _, param := range params {
				es = append(es, ElasticSearchData{
					Id:          helper.Interface2Int(param["Id"]),
					Title:       param["Title"].(string),
					Keywords:    param["Keywords"].(string),
					Description: param["Description"].(string),
					Vcnt:        helper.Interface2Int(param["Vcnt"]),
					Ccnt:        helper.Interface2Int(param["Ccnt"]),
					Dcnt:        helper.Interface2Int(param["Dcnt"]),
					Score:       helper.Interface2Int(param["Score"]),
					Size:        helper.Interface2Int(param["Size"]),
					Page:        helper.Interface2Int(param["Page"]),
					DocType:     helper.Interface2Int(param["DocType"]),
					DsId:        helper.Interface2Int(param["DsId"]),
					Price:       helper.Interface2Int(param["Price"]),
					TimeCreate:  helper.Interface2Int(param["TimeCreate"]),
				})
			}
		}
	}
	return
}

//查询需要索引的稳定id
//@param            page            页面