初始项目
This commit is contained in:
liupopo
@@ -0,0 +1,12 @@
|
||||
package com.zscat.mallplus;
|
||||
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||
|
||||
@SpringBootApplication
|
||||
public class MallSearchApplication {
|
||||
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(MallSearchApplication.class, args);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,13 @@
|
||||
package com.zscat.mallplus.search.config;
|
||||
|
||||
import org.mybatis.spring.annotation.MapperScan;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
/**
|
||||
* MyBatis配置类
|
||||
* Created by mallplus on 2019/4/8.
|
||||
*/
|
||||
@Configuration
|
||||
@MapperScan({"com.zscat.mallplus.search.mapper", "com.zscat.mallplus.search.dao"})
|
||||
public class MyBatisConfig {
|
||||
}
|
||||
@@ -0,0 +1,38 @@
|
||||
package com.zscat.mallplus.search.config;
|
||||
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import springfox.documentation.builders.ApiInfoBuilder;
|
||||
import springfox.documentation.builders.PathSelectors;
|
||||
import springfox.documentation.builders.RequestHandlerSelectors;
|
||||
import springfox.documentation.service.ApiInfo;
|
||||
import springfox.documentation.spi.DocumentationType;
|
||||
import springfox.documentation.spring.web.plugins.Docket;
|
||||
import springfox.documentation.swagger2.annotations.EnableSwagger2;
|
||||
|
||||
/**
|
||||
* Swagger2API文档的配置
|
||||
* Created by mallplus on 2018/4/26.
|
||||
*/
|
||||
@Configuration
|
||||
@EnableSwagger2
|
||||
public class Swagger2Config {
|
||||
@Bean
|
||||
public Docket createRestApi() {
|
||||
return new Docket(DocumentationType.SWAGGER_2)
|
||||
.apiInfo(apiInfo())
|
||||
.select()
|
||||
.apis(RequestHandlerSelectors.basePackage("com.zscat.mallplus.search.controller"))
|
||||
.paths(PathSelectors.any())
|
||||
.build();
|
||||
}
|
||||
|
||||
private ApiInfo apiInfo() {
|
||||
return new ApiInfoBuilder()
|
||||
.title("mall搜索系统")
|
||||
.description("mall搜索模块")
|
||||
.contact("mallplus")
|
||||
.version("1.0")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,106 @@
|
||||
package com.zscat.mallplus.search.controller;
|
||||
|
||||
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import com.zscat.mallplus.search.domain.EsProductRelatedInfo;
|
||||
import com.zscat.mallplus.search.service.EsProductService;
|
||||
import com.zscat.mallplus.utils.CommonResult;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiImplicitParam;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.data.domain.Page;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 搜索商品管理Controller
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
@RestController
|
||||
@Api(tags = "EsProductController", description = "搜索商品管理")
|
||||
@RequestMapping("/esProduct")
|
||||
public class EsProductController {
|
||||
@Autowired
|
||||
private EsProductService esProductService;
|
||||
|
||||
@ApiOperation(value = "导入所有数据库中商品到ES")
|
||||
@RequestMapping(value = "/importAll", method = RequestMethod.POST)
|
||||
@ResponseBody
|
||||
public Object importAllList() {
|
||||
int count = esProductService.importAll();
|
||||
return new CommonResult().success(count);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "根据id删除商品")
|
||||
@RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
|
||||
@ResponseBody
|
||||
public Object delete(@PathVariable Long id) {
|
||||
esProductService.delete(id);
|
||||
return new CommonResult().success();
|
||||
}
|
||||
|
||||
@ApiOperation(value = "根据id批量删除商品")
|
||||
@RequestMapping(value = "/delete/batch", method = RequestMethod.POST)
|
||||
@ResponseBody
|
||||
public Object delete(@RequestParam("ids") List<Long> ids) {
|
||||
esProductService.delete(ids);
|
||||
return new CommonResult().success();
|
||||
}
|
||||
|
||||
@ApiOperation(value = "根据id创建商品")
|
||||
@RequestMapping(value = "/create/{id}", method = RequestMethod.POST)
|
||||
@ResponseBody
|
||||
public Object create(@PathVariable Long id) {
|
||||
EsProduct esProduct = esProductService.create(id);
|
||||
if (esProduct != null) {
|
||||
return new CommonResult().success(esProduct);
|
||||
} else {
|
||||
return new CommonResult().failed();
|
||||
}
|
||||
}
|
||||
|
||||
@ApiOperation(value = "简单搜索")
|
||||
@RequestMapping(value = "/search/simple", method = RequestMethod.GET)
|
||||
@ResponseBody
|
||||
public Object search(@RequestParam(required = false) String keyword,
|
||||
@RequestParam(required = false, defaultValue = "0") Integer pageNum,
|
||||
@RequestParam(required = false, defaultValue = "10") Integer pageSize) {
|
||||
Page<EsProduct> esProductPage = esProductService.search(keyword, pageNum, pageSize);
|
||||
return new CommonResult().success(esProductPage);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "综合搜索、筛选、排序")
|
||||
@ApiImplicitParam(name = "sort", value = "排序字段:0->按相关度；1->按新品；2->按销量；3->价格从低到高；4->价格从高到低",
|
||||
defaultValue = "0", allowableValues = "0,1,2,3,4", paramType = "query", dataType = "integer")
|
||||
@RequestMapping(value = "/search", method = RequestMethod.GET)
|
||||
@ResponseBody
|
||||
public Object search(@RequestParam(required = false) String keyword,
|
||||
@RequestParam(required = false) Long brandId,
|
||||
@RequestParam(required = false) Long productCategoryId,
|
||||
@RequestParam(required = false, defaultValue = "0") Integer pageNum,
|
||||
@RequestParam(required = false, defaultValue = "10") Integer pageSize,
|
||||
@RequestParam(required = false, defaultValue = "0") Integer sort) {
|
||||
Page<EsProduct> esProductPage = esProductService.search(keyword, brandId, productCategoryId, pageNum, pageSize, sort);
|
||||
return new CommonResult().success(esProductPage);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "根据商品id推荐商品")
|
||||
@RequestMapping(value = "/recommend/{id}", method = RequestMethod.GET)
|
||||
@ResponseBody
|
||||
public Object recommend(@PathVariable Long id,
|
||||
@RequestParam(required = false, defaultValue = "0") Integer pageNum,
|
||||
@RequestParam(required = false, defaultValue = "10") Integer pageSize) {
|
||||
Page<EsProduct> esProductPage = esProductService.recommend(id, pageNum, pageSize);
|
||||
return new CommonResult().success(esProductPage);
|
||||
}
|
||||
|
||||
@ApiOperation(value = "获取搜索的相关品牌、分类及筛选属性")
|
||||
@RequestMapping(value = "/search/relate", method = RequestMethod.GET)
|
||||
@ResponseBody
|
||||
public Object searchRelatedInfo(@RequestParam(required = false) String keyword) {
|
||||
EsProductRelatedInfo productRelatedInfo = esProductService.searchRelatedInfo(keyword);
|
||||
return new CommonResult().success(productRelatedInfo);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
package com.zscat.mallplus.search.dao;
|
||||
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 搜索系统中的商品管理自定义Dao
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
public interface EsProductDao {
|
||||
List<EsProduct> getAllEsProductList(@Param("id") Long id);
|
||||
}
|
||||
@@ -0,0 +1,189 @@
|
||||
package com.zscat.mallplus.search.domain;
|
||||
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.elasticsearch.annotations.Document;
|
||||
import org.springframework.data.elasticsearch.annotations.Field;
|
||||
import org.springframework.data.elasticsearch.annotations.FieldType;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigDecimal;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 搜索中的商品信息
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
@Document(indexName = "pms", type = "product", shards = 1, replicas = 0)
|
||||
public class EsProduct implements Serializable {
|
||||
private static final long serialVersionUID = -1L;
|
||||
@Id
|
||||
private Long id;
|
||||
@Field(type = FieldType.Keyword)
|
||||
private String productSn;
|
||||
private Long brandId;
|
||||
@Field(type = FieldType.Keyword)
|
||||
private String brandName;
|
||||
private Long productCategoryId;
|
||||
@Field(type = FieldType.Keyword)
|
||||
private String productCategoryName;
|
||||
private String pic;
|
||||
@Field(analyzer = "ik_max_word", type = FieldType.Text)
|
||||
private String name;
|
||||
@Field(analyzer = "ik_max_word", type = FieldType.Text)
|
||||
private String subTitle;
|
||||
@Field(analyzer = "ik_max_word", type = FieldType.Text)
|
||||
private String keywords;
|
||||
private BigDecimal price;
|
||||
private Integer sale;
|
||||
private Integer newStatus;
|
||||
private Integer recommandStatus;
|
||||
private Integer stock;
|
||||
private Integer promotionType;
|
||||
private Integer sort;
|
||||
@Field(type = FieldType.Nested)
|
||||
private List<EsProductAttributeValue> attrValueList;
|
||||
|
||||
public Long getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
public void setId(Long id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
public String getProductSn() {
|
||||
return productSn;
|
||||
}
|
||||
|
||||
public void setProductSn(String productSn) {
|
||||
this.productSn = productSn;
|
||||
}
|
||||
|
||||
public Long getBrandId() {
|
||||
return brandId;
|
||||
}
|
||||
|
||||
public void setBrandId(Long brandId) {
|
||||
this.brandId = brandId;
|
||||
}
|
||||
|
||||
public String getBrandName() {
|
||||
return brandName;
|
||||
}
|
||||
|
||||
public void setBrandName(String brandName) {
|
||||
this.brandName = brandName;
|
||||
}
|
||||
|
||||
public Long getProductCategoryId() {
|
||||
return productCategoryId;
|
||||
}
|
||||
|
||||
public void setProductCategoryId(Long productCategoryId) {
|
||||
this.productCategoryId = productCategoryId;
|
||||
}
|
||||
|
||||
public String getProductCategoryName() {
|
||||
return productCategoryName;
|
||||
}
|
||||
|
||||
public void setProductCategoryName(String productCategoryName) {
|
||||
this.productCategoryName = productCategoryName;
|
||||
}
|
||||
|
||||
public String getPic() {
|
||||
return pic;
|
||||
}
|
||||
|
||||
public void setPic(String pic) {
|
||||
this.pic = pic;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String getSubTitle() {
|
||||
return subTitle;
|
||||
}
|
||||
|
||||
public void setSubTitle(String subTitle) {
|
||||
this.subTitle = subTitle;
|
||||
}
|
||||
|
||||
public BigDecimal getPrice() {
|
||||
return price;
|
||||
}
|
||||
|
||||
public void setPrice(BigDecimal price) {
|
||||
this.price = price;
|
||||
}
|
||||
|
||||
public Integer getSale() {
|
||||
return sale;
|
||||
}
|
||||
|
||||
public void setSale(Integer sale) {
|
||||
this.sale = sale;
|
||||
}
|
||||
|
||||
public Integer getNewStatus() {
|
||||
return newStatus;
|
||||
}
|
||||
|
||||
public void setNewStatus(Integer newStatus) {
|
||||
this.newStatus = newStatus;
|
||||
}
|
||||
|
||||
public Integer getRecommandStatus() {
|
||||
return recommandStatus;
|
||||
}
|
||||
|
||||
public void setRecommandStatus(Integer recommandStatus) {
|
||||
this.recommandStatus = recommandStatus;
|
||||
}
|
||||
|
||||
public Integer getStock() {
|
||||
return stock;
|
||||
}
|
||||
|
||||
public void setStock(Integer stock) {
|
||||
this.stock = stock;
|
||||
}
|
||||
|
||||
public Integer getPromotionType() {
|
||||
return promotionType;
|
||||
}
|
||||
|
||||
public void setPromotionType(Integer promotionType) {
|
||||
this.promotionType = promotionType;
|
||||
}
|
||||
|
||||
public Integer getSort() {
|
||||
return sort;
|
||||
}
|
||||
|
||||
public void setSort(Integer sort) {
|
||||
this.sort = sort;
|
||||
}
|
||||
|
||||
public List<EsProductAttributeValue> getAttrValueList() {
|
||||
return attrValueList;
|
||||
}
|
||||
|
||||
public void setAttrValueList(List<EsProductAttributeValue> attrValueList) {
|
||||
this.attrValueList = attrValueList;
|
||||
}
|
||||
|
||||
public String getKeywords() {
|
||||
return keywords;
|
||||
}
|
||||
|
||||
public void setKeywords(String keywords) {
|
||||
this.keywords = keywords;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,64 @@
|
||||
package com.zscat.mallplus.search.domain;
|
||||
|
||||
import org.springframework.data.elasticsearch.annotations.Field;
|
||||
import org.springframework.data.elasticsearch.annotations.FieldType;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 搜索中的商品属性信息
|
||||
* Created by mallplus on 2018/6/27.
|
||||
*/
|
||||
public class EsProductAttributeValue implements Serializable {
|
||||
private static final long serialVersionUID = 1L;
|
||||
private Long id;
|
||||
private Long productAttributeId;
|
||||
//属性值
|
||||
@Field(type = FieldType.Keyword)
|
||||
private String value;
|
||||
//属性参数：0->规格；1->参数
|
||||
private Integer type;
|
||||
//属性名称
|
||||
@Field(type = FieldType.Keyword)
|
||||
private String name;
|
||||
|
||||
public Long getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
public void setId(Long id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
public Long getProductAttributeId() {
|
||||
return productAttributeId;
|
||||
}
|
||||
|
||||
public void setProductAttributeId(Long productAttributeId) {
|
||||
this.productAttributeId = productAttributeId;
|
||||
}
|
||||
|
||||
public String getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public void setValue(String value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public Integer getType() {
|
||||
return type;
|
||||
}
|
||||
|
||||
public void setType(Integer type) {
|
||||
this.type = type;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,67 @@
|
||||
package com.zscat.mallplus.search.domain;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 搜索相关商品品牌名称，分类名称及属性
|
||||
* Created by mallplus on 2018/6/27.
|
||||
*/
|
||||
public class EsProductRelatedInfo {
|
||||
private List<String> brandNames;
|
||||
private List<String> productCategoryNames;
|
||||
private List<ProductAttr> productAttrs;
|
||||
|
||||
public List<String> getBrandNames() {
|
||||
return brandNames;
|
||||
}
|
||||
|
||||
public void setBrandNames(List<String> brandNames) {
|
||||
this.brandNames = brandNames;
|
||||
}
|
||||
|
||||
public List<String> getProductCategoryNames() {
|
||||
return productCategoryNames;
|
||||
}
|
||||
|
||||
public void setProductCategoryNames(List<String> productCategoryNames) {
|
||||
this.productCategoryNames = productCategoryNames;
|
||||
}
|
||||
|
||||
public List<ProductAttr> getProductAttrs() {
|
||||
return productAttrs;
|
||||
}
|
||||
|
||||
public void setProductAttrs(List<ProductAttr> productAttrs) {
|
||||
this.productAttrs = productAttrs;
|
||||
}
|
||||
|
||||
public static class ProductAttr {
|
||||
private Long attrId;
|
||||
private String attrName;
|
||||
private List<String> attrValues;
|
||||
|
||||
public Long getAttrId() {
|
||||
return attrId;
|
||||
}
|
||||
|
||||
public void setAttrId(Long attrId) {
|
||||
this.attrId = attrId;
|
||||
}
|
||||
|
||||
public List<String> getAttrValues() {
|
||||
return attrValues;
|
||||
}
|
||||
|
||||
public void setAttrValues(List<String> attrValues) {
|
||||
this.attrValues = attrValues;
|
||||
}
|
||||
|
||||
public String getAttrName() {
|
||||
return attrName;
|
||||
}
|
||||
|
||||
public void setAttrName(String attrName) {
|
||||
this.attrName = attrName;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,24 @@
|
||||
package com.zscat.mallplus.search.repository;
|
||||
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import org.springframework.data.domain.Page;
|
||||
import org.springframework.data.domain.Pageable;
|
||||
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
|
||||
|
||||
/**
|
||||
* 商品ES操作类
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
public interface EsProductRepository extends ElasticsearchRepository<EsProduct, Long> {
|
||||
/**
|
||||
* 搜索查询
|
||||
*
|
||||
* @param name 商品名称
|
||||
* @param subTitle 商品标题
|
||||
* @param keywords 商品关键字
|
||||
* @param page 分页信息
|
||||
* @return
|
||||
*/
|
||||
Page<EsProduct> findByNameOrSubTitleOrKeywords(String name, String subTitle, String keywords, Pageable page);
|
||||
|
||||
}
|
||||
@@ -0,0 +1,53 @@
|
||||
package com.zscat.mallplus.search.service;
|
||||
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import com.zscat.mallplus.search.domain.EsProductRelatedInfo;
|
||||
import org.springframework.data.domain.Page;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 商品搜索管理Service
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
public interface EsProductService {
|
||||
/**
|
||||
* 从数据库中导入所有商品到ES
|
||||
*/
|
||||
int importAll();
|
||||
|
||||
/**
|
||||
* 根据id删除商品
|
||||
*/
|
||||
void delete(Long id);
|
||||
|
||||
/**
|
||||
* 根据id创建商品
|
||||
*/
|
||||
EsProduct create(Long id);
|
||||
|
||||
/**
|
||||
* 批量删除商品
|
||||
*/
|
||||
void delete(List<Long> ids);
|
||||
|
||||
/**
|
||||
* 根据关键字搜索名称或者副标题
|
||||
*/
|
||||
Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize);
|
||||
|
||||
/**
|
||||
* 根据关键字搜索名称或者副标题复合查询
|
||||
*/
|
||||
Page<EsProduct> search(String keyword, Long brandId, Long productCategoryId, Integer pageNum, Integer pageSize, Integer sort);
|
||||
|
||||
/**
|
||||
* 根据商品id推荐相关商品
|
||||
*/
|
||||
Page<EsProduct> recommend(Long id, Integer pageNum, Integer pageSize);
|
||||
|
||||
/**
|
||||
* 获取搜索词相关品牌、分类、属性
|
||||
*/
|
||||
EsProductRelatedInfo searchRelatedInfo(String keyword);
|
||||
}
|
||||
@@ -0,0 +1,273 @@
|
||||
package com.zscat.mallplus.search.service.impl;
|
||||
|
||||
import com.zscat.mallplus.search.dao.EsProductDao;
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import com.zscat.mallplus.search.domain.EsProductRelatedInfo;
|
||||
import com.zscat.mallplus.search.repository.EsProductRepository;
|
||||
import com.zscat.mallplus.search.service.EsProductService;
|
||||
import org.elasticsearch.action.search.SearchResponse;
|
||||
import org.elasticsearch.common.lucene.search.function.FunctionScoreQuery;
|
||||
import org.elasticsearch.index.query.BoolQueryBuilder;
|
||||
import org.elasticsearch.index.query.QueryBuilders;
|
||||
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
|
||||
import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
|
||||
import org.elasticsearch.search.aggregations.AbstractAggregationBuilder;
|
||||
import org.elasticsearch.search.aggregations.Aggregation;
|
||||
import org.elasticsearch.search.aggregations.AggregationBuilders;
|
||||
import org.elasticsearch.search.aggregations.bucket.filter.InternalFilter;
|
||||
import org.elasticsearch.search.aggregations.bucket.nested.InternalNested;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.LongTerms;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.StringTerms;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
|
||||
import org.elasticsearch.search.sort.SortBuilders;
|
||||
import org.elasticsearch.search.sort.SortOrder;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.data.domain.Page;
|
||||
import org.springframework.data.domain.PageImpl;
|
||||
import org.springframework.data.domain.PageRequest;
|
||||
import org.springframework.data.domain.Pageable;
|
||||
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
|
||||
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
|
||||
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
|
||||
/**
|
||||
* 商品搜索管理Service实现类
|
||||
* Created by mallplus on 2018/6/19.
|
||||
*/
|
||||
@Service
|
||||
public class EsProductServiceImpl implements EsProductService {
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(EsProductServiceImpl.class);
|
||||
@Autowired
|
||||
private EsProductDao productDao;
|
||||
@Autowired
|
||||
private EsProductRepository productRepository;
|
||||
@Autowired
|
||||
private ElasticsearchTemplate elasticsearchTemplate;
|
||||
|
||||
@Override
|
||||
public int importAll() {
|
||||
List<EsProduct> esProductList = productDao.getAllEsProductList(null);
|
||||
Iterable<EsProduct> esProductIterable = productRepository.saveAll(esProductList);
|
||||
Iterator<EsProduct> iterator = esProductIterable.iterator();
|
||||
int result = 0;
|
||||
while (iterator.hasNext()) {
|
||||
result++;
|
||||
iterator.next();
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void delete(Long id) {
|
||||
productRepository.deleteById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public EsProduct create(Long id) {
|
||||
EsProduct result = null;
|
||||
List<EsProduct> esProductList = productDao.getAllEsProductList(id);
|
||||
if (esProductList.size() > 0) {
|
||||
EsProduct esProduct = esProductList.get(0);
|
||||
result = productRepository.save(esProduct);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void delete(List<Long> ids) {
|
||||
if (!CollectionUtils.isEmpty(ids)) {
|
||||
List<EsProduct> esProductList = new ArrayList<EsProduct>();
|
||||
for (Long id : ids) {
|
||||
EsProduct esProduct = new EsProduct();
|
||||
esProduct.setId(id);
|
||||
esProductList.add(esProduct);
|
||||
}
|
||||
productRepository.deleteAll(esProductList);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize) {
|
||||
Pageable pageable = PageRequest.of(pageNum, pageSize);
|
||||
return productRepository.findByNameOrSubTitleOrKeywords(keyword, keyword, keyword, pageable);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<EsProduct> search(String keyword, Long brandId, Long productCategoryId, Integer pageNum, Integer pageSize, Integer sort) {
|
||||
Pageable pageable = PageRequest.of(pageNum, pageSize);
|
||||
NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();
|
||||
//分页
|
||||
nativeSearchQueryBuilder.withPageable(pageable);
|
||||
//过滤
|
||||
if (brandId != null || productCategoryId != null) {
|
||||
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
|
||||
if (brandId != null) {
|
||||
boolQueryBuilder.must(QueryBuilders.termQuery("brandId", brandId));
|
||||
}
|
||||
if (productCategoryId != null) {
|
||||
boolQueryBuilder.must(QueryBuilders.termQuery("productCategoryId", productCategoryId));
|
||||
}
|
||||
nativeSearchQueryBuilder.withFilter(boolQueryBuilder);
|
||||
}
|
||||
//搜索
|
||||
if (StringUtils.isEmpty(keyword)) {
|
||||
nativeSearchQueryBuilder.withQuery(QueryBuilders.matchAllQuery());
|
||||
} else {
|
||||
List<FunctionScoreQueryBuilder.FilterFunctionBuilder> filterFunctionBuilders = new ArrayList<>();
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("name", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(10)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("subTitle", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(5)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("keywords", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(2)));
|
||||
FunctionScoreQueryBuilder.FilterFunctionBuilder[] builders = new FunctionScoreQueryBuilder.FilterFunctionBuilder[filterFunctionBuilders.size()];
|
||||
filterFunctionBuilders.toArray(builders);
|
||||
FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(builders)
|
||||
.scoreMode(FunctionScoreQuery.ScoreMode.SUM)
|
||||
.setMinScore(2);
|
||||
nativeSearchQueryBuilder.withQuery(functionScoreQueryBuilder);
|
||||
}
|
||||
//排序
|
||||
if (sort == 1) {
|
||||
//按新品从新到旧
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("id").order(SortOrder.DESC));
|
||||
} else if (sort == 2) {
|
||||
//按销量从高到低
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("sale").order(SortOrder.DESC));
|
||||
} else if (sort == 3) {
|
||||
//按价格从低到高
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.ASC));
|
||||
} else if (sort == 4) {
|
||||
//按价格从高到低
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.DESC));
|
||||
} else {
|
||||
//按相关度
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.scoreSort().order(SortOrder.DESC));
|
||||
}
|
||||
nativeSearchQueryBuilder.withSort(SortBuilders.scoreSort().order(SortOrder.DESC));
|
||||
NativeSearchQuery searchQuery = nativeSearchQueryBuilder.build();
|
||||
LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
|
||||
return productRepository.search(searchQuery);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<EsProduct> recommend(Long id, Integer pageNum, Integer pageSize) {
|
||||
Pageable pageable = PageRequest.of(pageNum, pageSize);
|
||||
List<EsProduct> esProductList = productDao.getAllEsProductList(id);
|
||||
if (esProductList.size() > 0) {
|
||||
EsProduct esProduct = esProductList.get(0);
|
||||
String keyword = esProduct.getName();
|
||||
Long brandId = esProduct.getBrandId();
|
||||
Long productCategoryId = esProduct.getProductCategoryId();
|
||||
//根据商品标题、品牌、分类进行搜索
|
||||
List<FunctionScoreQueryBuilder.FilterFunctionBuilder> filterFunctionBuilders = new ArrayList<>();
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("name", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(8)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("subTitle", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(2)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("keywords", keyword),
|
||||
ScoreFunctionBuilders.weightFactorFunction(2)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("brandId", brandId),
|
||||
ScoreFunctionBuilders.weightFactorFunction(10)));
|
||||
filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("productCategoryId", productCategoryId),
|
||||
ScoreFunctionBuilders.weightFactorFunction(6)));
|
||||
FunctionScoreQueryBuilder.FilterFunctionBuilder[] builders = new FunctionScoreQueryBuilder.FilterFunctionBuilder[filterFunctionBuilders.size()];
|
||||
filterFunctionBuilders.toArray(builders);
|
||||
FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(builders)
|
||||
.scoreMode(FunctionScoreQuery.ScoreMode.SUM)
|
||||
.setMinScore(2);
|
||||
NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
|
||||
builder.withQuery(functionScoreQueryBuilder);
|
||||
builder.withPageable(pageable);
|
||||
NativeSearchQuery searchQuery = builder.build();
|
||||
LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
|
||||
return productRepository.search(searchQuery);
|
||||
}
|
||||
return new PageImpl<>(null);
|
||||
}
|
||||
|
||||
@Override
|
||||
public EsProductRelatedInfo searchRelatedInfo(String keyword) {
|
||||
NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
|
||||
//搜索条件
|
||||
if (StringUtils.isEmpty(keyword)) {
|
||||
builder.withQuery(QueryBuilders.matchAllQuery());
|
||||
} else {
|
||||
builder.withQuery(QueryBuilders.multiMatchQuery(keyword, "name", "subTitle", "keywords"));
|
||||
}
|
||||
//聚合搜索品牌名称
|
||||
builder.addAggregation(AggregationBuilders.terms("brandNames").field("brandName"));
|
||||
//集合搜索分类名称
|
||||
builder.addAggregation(AggregationBuilders.terms("productCategoryNames").field("productCategoryName"));
|
||||
//聚合搜索商品属性，去除type=1的属性
|
||||
AbstractAggregationBuilder aggregationBuilder = AggregationBuilders.nested("allAttrValues", "attrValueList")
|
||||
.subAggregation(AggregationBuilders.filter("productAttrs", QueryBuilders.termQuery("attrValueList.type", 1))
|
||||
.subAggregation(AggregationBuilders.terms("attrIds")
|
||||
.field("attrValueList.productAttributeId")
|
||||
.subAggregation(AggregationBuilders.terms("attrValues")
|
||||
.field("attrValueList.value"))
|
||||
.subAggregation(AggregationBuilders.terms("attrNames")
|
||||
.field("attrValueList.name"))));
|
||||
builder.addAggregation(aggregationBuilder);
|
||||
NativeSearchQuery searchQuery = builder.build();
|
||||
return elasticsearchTemplate.query(searchQuery, response -> {
|
||||
LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
|
||||
return convertProductRelatedInfo(response);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* 将返回结果转换为对象
|
||||
*/
|
||||
private EsProductRelatedInfo convertProductRelatedInfo(SearchResponse response) {
|
||||
EsProductRelatedInfo productRelatedInfo = new EsProductRelatedInfo();
|
||||
Map<String, Aggregation> aggregationMap = response.getAggregations().getAsMap();
|
||||
//设置品牌
|
||||
Aggregation brandNames = aggregationMap.get("brandNames");
|
||||
List<String> brandNameList = new ArrayList<>();
|
||||
for (int i = 0; i < ((Terms) brandNames).getBuckets().size(); i++) {
|
||||
brandNameList.add(((Terms) brandNames).getBuckets().get(i).getKeyAsString());
|
||||
}
|
||||
productRelatedInfo.setBrandNames(brandNameList);
|
||||
//设置分类
|
||||
Aggregation productCategoryNames = aggregationMap.get("productCategoryNames");
|
||||
List<String> productCategoryNameList = new ArrayList<>();
|
||||
for (int i = 0; i < ((Terms) productCategoryNames).getBuckets().size(); i++) {
|
||||
productCategoryNameList.add(((Terms) productCategoryNames).getBuckets().get(i).getKeyAsString());
|
||||
}
|
||||
productRelatedInfo.setProductCategoryNames(productCategoryNameList);
|
||||
//设置参数
|
||||
Aggregation productAttrs = aggregationMap.get("allAttrValues");
|
||||
List<LongTerms.Bucket> attrIds = ((LongTerms) ((InternalFilter) ((InternalNested) productAttrs).getProperty("productAttrs")).getProperty("attrIds")).getBuckets();
|
||||
List<EsProductRelatedInfo.ProductAttr> attrList = new ArrayList<>();
|
||||
for (Terms.Bucket attrId : attrIds) {
|
||||
EsProductRelatedInfo.ProductAttr attr = new EsProductRelatedInfo.ProductAttr();
|
||||
attr.setAttrId((Long) attrId.getKey());
|
||||
List<String> attrValueList = new ArrayList<>();
|
||||
List<StringTerms.Bucket> attrValues = ((StringTerms) attrId.getAggregations().get("attrValues")).getBuckets();
|
||||
List<StringTerms.Bucket> attrNames = ((StringTerms) attrId.getAggregations().get("attrNames")).getBuckets();
|
||||
for (Terms.Bucket attrValue : attrValues) {
|
||||
attrValueList.add(attrValue.getKeyAsString());
|
||||
}
|
||||
attr.setAttrValues(attrValueList);
|
||||
if (!CollectionUtils.isEmpty(attrNames)) {
|
||||
String attrName = attrNames.get(0).getKeyAsString();
|
||||
attr.setAttrName(attrName);
|
||||
}
|
||||
attrList.add(attr);
|
||||
}
|
||||
productRelatedInfo.setProductAttrs(attrList);
|
||||
return productRelatedInfo;
|
||||
}
|
||||
}
|
||||
19
mallplus-search/src/main/resources/application-dev.yml
Normal file
19
mallplus-search/src/main/resources/application-dev.yml
Normal file
@@ -0,0 +1,19 @@
|
||||
spring:
|
||||
datasource:
|
||||
url: jdbc:mysql://localhost:3306/mallplus1?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
|
||||
username: root
|
||||
password: root
|
||||
druid:
|
||||
initial-size: 5 #连接池初始化大小
|
||||
min-idle: 10 #最小空闲连接数
|
||||
max-active: 20 #最大连接数
|
||||
web-stat-filter:
|
||||
exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*" #不统计这些请求数据
|
||||
stat-view-servlet: #访问监控网页的登录用户名和密码
|
||||
login-username: druid
|
||||
login-password: druid
|
||||
data:
|
||||
elasticsearch:
|
||||
repositories:
|
||||
enabled: true
|
||||
cluster-nodes: 127.0.0.1:9300
|
||||
19
mallplus-search/src/main/resources/application-prod.yml
Normal file
19
mallplus-search/src/main/resources/application-prod.yml
Normal file
@@ -0,0 +1,19 @@
|
||||
spring:
|
||||
datasource:
|
||||
url: jdbc:mysql://localhost:3306/mallplus1?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
|
||||
username: root
|
||||
password: root
|
||||
druid:
|
||||
initial-size: 5 #连接池初始化大小
|
||||
min-idle: 10 #最小空闲连接数
|
||||
max-active: 20 #最大连接数
|
||||
web-stat-filter:
|
||||
exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*" #不统计这些请求数据
|
||||
stat-view-servlet: #访问监控网页的登录用户名和密码
|
||||
login-username: druid
|
||||
login-password: druid
|
||||
data:
|
||||
elasticsearch:
|
||||
repositories:
|
||||
enabled: true
|
||||
cluster-nodes: 127.0.0.1:9300
|
||||
29
mallplus-search/src/main/resources/application.yml
Normal file
29
mallplus-search/src/main/resources/application.yml
Normal file
@@ -0,0 +1,29 @@
|
||||
spring:
|
||||
profiles:
|
||||
active: dev #默认为开发环境
|
||||
|
||||
server:
|
||||
port: 8081
|
||||
mybatis-plus:
|
||||
configuration:
|
||||
cache-enabled: false
|
||||
map-underscore-to-camel-case: true
|
||||
global-config:
|
||||
db-config:
|
||||
column-underline: true
|
||||
db-type: mysql
|
||||
field-strategy: not_empty
|
||||
id-type: id_worker
|
||||
logic-delete-value: 0
|
||||
logic-not-delete-value: 1
|
||||
refresh: true
|
||||
mapper-locations: classpath:dao/*.xml
|
||||
typeAliasesPackage: com.zscat.mallplus.*.domain
|
||||
|
||||
logging:
|
||||
level:
|
||||
root: info
|
||||
com.mallplus: debug
|
||||
|
||||
|
||||
|
||||
47
mallplus-search/src/main/resources/dao/EsProductDao.xml
Normal file
47
mallplus-search/src/main/resources/dao/EsProductDao.xml
Normal file
@@ -0,0 +1,47 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.zscat.mallplus.search.dao.EsProductDao">
|
||||
<resultMap id="esProductListMap" type="com.zscat.mallplus.search.domain.EsProduct" autoMapping="true">
|
||||
<id column="id" jdbcType="BIGINT" property="id"/>
|
||||
<collection property="attrValueList" columnPrefix="attr_"
|
||||
ofType="com.zscat.mallplus.search.domain.EsProductAttributeValue">
|
||||
<id column="id" property="id" jdbcType="BIGINT"/>
|
||||
<result column="product_attribute_id" property="productAttributeId" jdbcType="BIGINT"/>
|
||||
<result column="value" property="value" jdbcType="VARCHAR"/>
|
||||
<result column="type" property="type"/>
|
||||
<result column="name" property="name"/>
|
||||
</collection>
|
||||
</resultMap>
|
||||
<select id="getAllEsProductList" resultMap="esProductListMap">
|
||||
select
|
||||
p.id id,
|
||||
p.product_sn productSn,
|
||||
p.brand_id brandId,
|
||||
p.brand_name brandName,
|
||||
p.product_category_id productCategoryId,
|
||||
p.product_category_name productCategoryName,
|
||||
p.pic pic,
|
||||
p.name name,
|
||||
p.sub_title subTitle,
|
||||
p.price price,
|
||||
p.sale sale,
|
||||
p.new_status newStatus,
|
||||
p.recommand_status recommandStatus,
|
||||
p.stock stock,
|
||||
p.promotion_type promotionType,
|
||||
p.keywords keywords,
|
||||
p.sort sort,
|
||||
pav.id attr_id,
|
||||
pav.value attr_value,
|
||||
pav.product_attribute_id attr_product_attribute_id,
|
||||
pa.type attr_type,
|
||||
pa.name attr_name
|
||||
from pms_product p
|
||||
left join pms_product_attribute_value pav on p.id = pav.product_id
|
||||
left join pms_product_attribute pa on pav.product_attribute_id= pa.id
|
||||
where delete_status = 0 and publish_status = 1
|
||||
<if test="id!=null">
|
||||
and p.id=#{id}
|
||||
</if>
|
||||
</select>
|
||||
</mapper>
|
||||
@@ -0,0 +1,40 @@
|
||||
package com.zscat.mallplus.search;
|
||||
|
||||
import com.zscat.mallplus.search.dao.EsProductDao;
|
||||
import com.zscat.mallplus.search.domain.EsProduct;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest
|
||||
public class MallSearchApplicationTests {
|
||||
@Autowired
|
||||
private EsProductDao productDao;
|
||||
@Autowired
|
||||
private ElasticsearchTemplate elasticsearchTemplate;
|
||||
|
||||
@Test
|
||||
public void contextLoads() {
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testGetAllEsProductList() {
|
||||
List<EsProduct> esProductList = productDao.getAllEsProductList(null);
|
||||
System.out.print(esProductList);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testEsProductMapping() {
|
||||
elasticsearchTemplate.putMapping(EsProduct.class);
|
||||
Map mapping = elasticsearchTemplate.getMapping(EsProduct.class);
|
||||
System.out.println(mapping);
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user