品优购Ⅶ-搜索解决方案Solr


阅读数: 次   

EverydayOneCat

Cat记忆混乱…✍️🐈💦
🐈➡️🛏️💤🙏

2869749ea7e1bb8e02d71e4dc8b052bd5988700b.png@518w_1e_1c

Solr

1.什么是Solr

大多数搜索引擎应用都必须具有某种搜索功能，问题是搜索功能往往是巨大的资源消耗并且它们由于沉重的数据库加载而拖垮你的应用的性能。

Solr是一个开源搜索平台，用于构建搜索应用程序。 它建立在Lucene(全文搜索引擎)之上。 Solr是企业级的，快速的和高度可扩展的。 使用Solr构建的应用程序非常复杂，可提供高性能。

Solr可以和Hadoop一起使用。由于Hadoop处理大量数据，Solr帮助我们从这么大的源中找到所需的信息。不仅限于搜索，Solr也可以用于存储目的。像其他NoSQL数据库一样，它是一种非关系数据存储和处理技术。

总之，Solr是一个可扩展的，可 部署，搜索/存储引擎，优化搜索大量以文本为中心的数据。

2.Solr本地安装

Solr安装之前专门写过一篇文章介绍。《Linux下Solr的安装及配置》这里其实差不多，主要介绍几个关键点。

2.1中文分析器IK Analyzer

IK Analyzer 是一个开源的，基亍 java 语言开发的轻量级的中文分词工具包。从 2006年 12 月推出 1.0 版开始， IKAnalyzer 已经推出了 4 个大版本。最初，它是以开源项目Luence 为应用主体的，结合词典分词和文法分析算法的中文分词组件。从 3.0 版本开始，IK 发展为面向 Java 的公用分词组件，独立亍 Lucene 项目，同时提供了对 Lucene 的默认优化实现。在 2012 版本中，IK 实现了简单的分词歧义排除算法，标志着 IK 分词器从单纯的词典分词向模拟语义分词衍化。

image-20200731112908546

image-20200731112935559

3.配置域

域相当于数据库的表字段，用户存放数据，因此用户根据业务需要去定义相关的Field（域），一般来说，每一种对应着一种数据，用户对同一种数据进行相同的操作。

域的常用属性：

  • name：指定域的名称
  • type：指定域的类型
  • indexed：是否索引
  • stored：是否存储
  • required：是否必须
  • multiValued：是否多值

3.1普通域

修改solrhome的schema.xml 文件 根据需求设置业务系统 Field

1
2
3
4
5
6
7
<field name="item_goodsid" type="long" indexed="true" stored="true"/>
<field name="item_title" type="text_ik" indexed="true" stored="true"/>
<field name="item_price" type="double" indexed="true" stored="true"/>
<field name="item_image" type="string" indexed="false" stored="true" />
<field name="item_category" type="string" indexed="true" stored="true" />
<field name="item_seller" type="text_ik" indexed="true" stored="true" />
<field name="item_brand" type="string" indexed="true" stored="true" />

3.2复制域

复制域的作用在于将某一个Field中的数据复制到另一个域中，常用来把需要搜索的关键域结合起来形成一个新的域好搜索，但是不要存起来。

1
2
3
4
5
<field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_category" dest="item_keywords"/>
<copyField source="item_seller" dest="item_keywords"/>
<copyField source="item_brand" dest="item_keywords"/>

3.2动态域

当我们需要动态扩充字段时，我们需要使用动态域。对于品优购，规格的值是不确定的，所以我们需要使用动态域来实现。需要实现的效果如下：

image-20200731202841561

1
<dynamicField name="item_spec_*" type="string" indexed="true" stored="true" />

4.Spring Data Solr入门

在前面的淘淘商城我们学习了SolrJ的实际使用，这里介绍Spring Data Solr，Spring Data Solr就是为了方便Solr的开发所研制的一个框架，其底层是对SolrJ（官方API）的封装。

4.1配置文件

pom.xml中引入依赖

1
2
3
4
5
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-solr</artifactId>
    <version>1.5.5.RELEASE</version>
</dependency>

resources下创建 applicationContext-solr.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:solr="http://www.springframework.org/schema/data/solr"
	xsi:schemaLocation="http://www.springframework.org/schema/data/solr 
  		http://www.springframework.org/schema/data/solr/spring-solr-1.0.xsd
		http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context 
		http://www.springframework.org/schema/context/spring-context.xsd">
	<!-- solr服务器地址 -->
	<solr:solr-server id="solrServer" url="http://127.0.0.1:8080/solr" />
	<!-- solr模板，使用solr模板可对索引库进行CRUD的操作 -->
	<bean id="solrTemplate" class="org.springframework.data.solr.core.SolrTemplate">
		<constructor-arg ref="solrServer" />
	</bean>
</beans>

4.2@Field 注解

将品优购的TbItem实体类拷入工程 ,属性使用@Field注解标识 。如果属性与配置文件定义的域名称不一致，需要在注解中指定域名称。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
public class TbItem implements Serializable{

	@Field
    private Long id;

	@Field("item_title")
    private String title;
	    
    @Field("item_price")
private BigDecimal price;

    @Field("item_image")
    private String image;

    @Field("item_goodsid")
    private Long goodsId;

    @Field("item_category")
    private String category;

    @Field("item_brand")
    private String brand;

    @Field("item_seller")
private String seller;
.......
}

4.3增加（修改）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext-solr.xml")
public class TestTemplate {

	@Autowired
	private SolrTemplate solrTemplate;
	
	@Test
	public void testAdd(){
		TbItem item=new TbItem();
		item.setId(1L);
		item.setBrand("华为");
		item.setCategory("手机");
		item.setGoodsId(1L);
		item.setSeller("华为2号专卖店");
		item.setTitle("华为Mate9");
		item.setPrice(new BigDecimal(2000));		
		solrTemplate.saveBean(item);
		solrTemplate.commit();
	}
}

4.4按主键查询

1
2
3
4
5
@Test
public void testFindOne(){
    TbItem item = solrTemplate.getById(1, TbItem.class);
    System.out.println(item.getTitle());
}

4.5按主键删除

1
2
3
4
5
@Test
public void testDelete(){
    solrTemplate.deleteById("1");
    solrTemplate.commit();
}

4.6分页查询

首先循环插入100条测试数据，增加可以用saveBeans()方法加入集合

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@Test
public void testAddList(){
    List<TbItem> list=new ArrayList();

    for(int i=0;i<100;i++){
        TbItem item=new TbItem();
        item.setId(i+1L);
        item.setBrand("华为");
        item.setCategory("手机");
        item.setGoodsId(1L);
        item.setSeller("华为2号专卖店");
        item.setTitle("华为Mate"+i);
        item.setPrice(new BigDecimal(2000+i));	
        list.add(item);
    }

    solrTemplate.saveBeans(list);
    solrTemplate.commit();
}

编写分页查询测试代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@Test
public void testPageQuery(){
    Query query=new SimpleQuery("*:*");
    query.setOffset(20);//开始索引（默认0）
    query.setRows(20);//每页记录数(默认10)
    ScoredPage<TbItem> page = solrTemplate.queryForPage(query, TbItem.class);
    System.out.println("总记录数："+page.getTotalElements());
    List<TbItem> list = page.getContent();
    showList(list);
}	
//显示记录数据
private void showList(List<TbItem> list){		
    for(TbItem item:list){
        System.out.println(item.getTitle() +item.getPrice());
    }		
}

4.7条件查询

Criteria 用于对条件的封装：

1
2
3
4
Query query=new SimpleQuery("*:*");
Criteria criteria=new Criteria("item_title").contains("2");
criteria=criteria.and("item_title").contains("5");//每次都要等于自身，这点和MYbatis不一样		
query.addCriteria(criteria);

4.8删除全部数据

1
2
3
4
5
6
@Test
    public void testDeleteAll(){
    Query query=new SimpleQuery("*:*");
    solrTemplate.delete(query);
    solrTemplate.commit();
}

品优购

1.批量数据导入

编写专门的导入程序，将商品数据导入到Solr系统中

1.1搭建工程

创建pinyougou-solr-util（jar） ,引入pinyougou-dao 以及spring 相关依赖：

1
2
<context:component-scan base-package="com.pinyougou.solrutil">
</context:component-scan>

1.2实体类

上文解释过，需要修改pinyougou-pojo中的TbItem类添加必要的@Field注解

同时，为了让规格导入动态域，我们定义Map属性，具体代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
@Field
private Long id;

@Field("item_title")
private String title;

private String sellPoint;

@Field("item_price")
private BigDecimal price;

private Integer stockCount;

private Integer num;

private String barcode;

@Field("item_image")
private String image;

private Long categoryid;

private String status;

private Date createTime;

private Date updateTime;

private String itemSn;

private BigDecimal costPirce;

private BigDecimal marketPrice;

private String isDefault;

@Field("item_goodsid")
private Long goodsId;

private String sellerId;

private String cartThumbnail;

@Field("item_category")
private String category;

@Field("item_brand")
private String brand;

private String spec;

@Field("item_seller")
private String seller;

@Dynamic
@Field("item_spec_*")
private Map<String,String> specMap;

1.3数据导入Solr索引库

创建com.pinyougou.solrutil包，创建类SolrUtil ,实现商品数据的查询(已审核商品)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
@Component
public class SolrUtil {

	@Autowired
	private TbItemMapper itemMapper;
	@Autowired
	private SolrTemplate solrTemplate;

	
	/**
	 * 导入商品数据
	 */
	public void importItemData() {
		TbItemExample example = new TbItemExample();
		Criteria criteria = example.createCriteria();
		criteria.andStatusEqualTo("1");
		List<TbItem> list = itemMapper.selectByExample(example);
		for (TbItem tbItem : list) {
			Map specMap=JSON.parseObject(tbItem.getSpec());//将spec字段中的json字符串转换为map
			tbItem.setSpecMap(specMap);//给带注解的字段赋值	
		}
		solrTemplate.saveBeans(list);
		solrTemplate.commit();
	}
	
	public static void main(String[] args) {
		//除了扫描本工程的，还需要扫描dao工程的配置
		ApplicationContext context = new ClassPathXmlApplicationContext("classpath*:spring/applicationContext*.xml");
		SolrUtil solrUtil = (SolrUtil) context.getBean("solrUtil");
		solrUtil.importItemData();
	}
}

运行结果：

image-20200731225806709

2.关键字搜索

打开搜索页面，在搜索框输入要搜索的关键字，点击搜索按钮即可进行搜索，展示搜索结果

image-20200801002557814

2.1搭建工程

创建pinyougou-search-interface模块（搜索服务接口），依赖pinyougou-pojo

创建war工程pinyougou-search-service ，引入pinyougou-search-interface spring dubbox 等相关依赖（参照其它服务工程）Tomcat运行端口9004

创建pinyougou-search-web 工程 ，引入依赖（参见其它web模块），tomcat运行端口9104

web.xml把search.html设为默认主页

1
2
3
<welcome-file-list>
    <welcome-file>search.html</welcome-file>
</welcome-file-list>

2.2后端

创建业务接口

1
2
3
4
5
6
7
8
9
10
11
public interface ItemSearchService {
	/**
	 * 搜索
	 * 条件不仅有关键词，还有品牌价格区间等，因此用Map
	 * 返回值不仅有商品，输入品牌对应的规格等等也要考虑，也用Map
	 * @param keywords
	 * @return
	 */
	public Map<String,Object> search(Map searchMap);

}

编写服务实现类ItemSearchServiceImpl.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@Service(timeout=5000)
public class ItemSearchServiceImpl implements ItemSearchService{

	@Autowired
	private SolrTemplate solrTemplate;

	@Override
	public Map<String, Object> search(Map searchMap) {
		Map<String,Object> map=new HashMap<>();
		Query query = new SimpleQuery();
		Criteria criteria = new Criteria("item_keywords").is(searchMap.get("keywords"));
        //is-匹配	在复制域中查找
		query.addCriteria(criteria);
		ScoredPage<TbItem> page = solrTemplate.queryForPage(query , TbItem.class);
		map.put("rows", page.getContent());
		return map;
	}
	
}

创建包com.pinyougou.search.controller 编写控制器类 

1
2
3
4
5
6
7
8
9
10
11
@RestController
@RequestMapping("/itemsearch")
public class ItemSearchController {
	@Reference
	private ItemSearchService itemSearchService;
	
	@RequestMapping("/search")
	public Map<String, Object> search(@RequestBody Map searchMap ){
		return  itemSearchService.search(searchMap);
	}	
}

2.3前端

pinyougou-search-web工程创建searchService.js

1
2
3
4
5
6
//搜索服务层
app.service("searchService",function($http){
	this.search=function(searchMap){
		return $http.post('itemsearch/search.do',searchMap);
	}
});

pinyougou-search-web工程searchController.js 

1
2
3
4
5
6
7
8
9
10
app.controller('searchController',function($scope,searchService){	
	//搜索
	$scope.search=function(){
		searchService.search( $scope.searchMap ).success(
			function(response){						
				$scope.resultMap=response;//搜索返回的结果
			}
		);	
	}	
});

search.html绑定搜索框

1
2
3
4
<div class="input-append">
	<input type="text" id="autocomplete" ng-model="searchMap.keywords" type="text" class="input-error input-xxlarge" />
	<button class="sui-btn btn-xlarge btn-danger" ng-click="search()" type="button">搜索</button>
</div>

循环显示数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
<li class="yui3-u-1-5" ng-repeat="item in resultMap.rows">
	<div class="list-wrap">
		<div class="p-img">
			<a href="item.html" target="_blank"><img src="{{item.image}}" /></a>
		</div>
		<div class="price">
			<strong>
				<em>¥</em>
				<i>{{item.price}}</i>
			</strong>
		</div>
		<div class="attr">
			<em>{{item.title}}</em>
		</div>
		<div class="cu">
			<em><span>促</span>满一件可参加超值换购</em>
		</div>
		<div class="commit">
			<i class="command">已有2000人评价</i>
		</div>
		<div class="operate">
			<a href="success-cart.html" target="_blank" class="sui-btn btn-bordered btn-danger">加入购物车</a>
			<a href="javascript:void(0);" class="sui-btn btn-bordered">对比</a>
			<a href="javascript:void(0);" class="sui-btn btn-bordered">关注</a>
		</div>
	</div>
</li>

3.高亮显示

将用户输入的关键字在标题中以红色的字体显示出来，就是搜索中常用的高亮显示。

3.1后端

修改服务层代码ItemSearchServiceImpl.java

为了方便模块化处理，创建私有方法，用于返回查询列表的结果（高亮）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
//根据关键字搜索列表
private Map searchList(Map searchMap) {
    Map map=new HashMap();
    HighlightQuery query = new SimpleHighlightQuery();
    //按照关键字查询
    Criteria criteria = new Criteria("item_keywords").is(searchMap.get("keywords"));
    query.addCriteria(criteria);
    //设置高亮选项
    HighlightOptions highlightOptions = new HighlightOptions().addField("item_title");//设置高亮的域
    highlightOptions.setSimplePrefix("<em style='color:red'>");//高亮前缀
    highlightOptions.setSimplePostfix("</em>");//高亮后缀
    query.setHighlightOptions(highlightOptions);
    //高亮页对象
    HighlightPage<TbItem> page = solrTemplate.queryForHighlightPage(query, TbItem.class);
    //高亮入口集合
    List<HighlightEntry<TbItem>> entryList = page.getHighlighted();
    for (HighlightEntry<TbItem> entry : entryList) {
        //获取高亮列表
        List<Highlight> highlights = entry.getHighlights();
        /*for (Highlight highlight : highlights) {
				List<String> snipplets = highlight.getSnipplets();//每个域可能存储多个值
				System.out.println(snipplets);
			}*/
        if(highlights.size()>0&&highlights.get(0).getSnipplets().size()>0) {
            TbItem item = entry.getEntity();
            item.setTitle(highlights.get(0).getSnipplets().get(0));
        }
    }
    map.put("rows",page.getContent());
    return map;
}

修改ItemSearchServiceImpl 的search方法，调用刚才编写的私有方法

1
2
3
4
5
6
7
@Override
public Map<String, Object> search(Map searchMap) {
    Map<String,Object> map=new HashMap<>();
    //1.查询列表		
    map.putAll(searchList(searchMap));
    return map;
}

测试搜索：image-20200801130147522

3.2前端

我们测试后发现高亮显示的html代码原样输出，这是angularJS为了防止html攻击采取的安全机制。

我们会用到$sce服务的trustAsHtml方法来实现转换。因为这个功能具有一定通用性，我们可以通过angularJS的过滤器来简化开发，这样只写一次，调用的时候就非常方便了。

（1）修改base.js 

1
2
3
4
5
6
7
8
// 定义模块:
var app = angular.module("pinyougou",[]);
/*$sce服务写成过滤器*/
app.filter('trustHtml',['$sce',function($sce){
    return function(data){
        return $sce.trustAsHtml(data);
    }
}]);

（2）使用过滤器

ng-bind-html指令用于显示html内容，竖线 |用于调用过滤器

1
<div class="attr" ng-bind-html="item.title | trustHtml"></div>

效果：华为手机(确信)image-20200801131414590

4.分类列表

根据搜索关键字查询商品分类名称列表

4.1后端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
//查询分类列表 
private List searchCategoryList(Map searchMap) {
    List<String> list = new ArrayList<String>();
    Query query = new SimpleQuery();
    //按照关键字查询
    Criteria criteria = new Criteria("item_keywords").is(searchMap.get("keywords"));//where...
    query.addCriteria(criteria);
    //设置分组选项
    GroupOptions groupOptions = new GroupOptions().addGroupByField("item_category");//group by
    query.setGroupOptions(groupOptions);
    //得到分组页
    GroupPage<TbItem> page = solrTemplate.queryForGroupPage(query,TbItem.class);
    //根据列得到分组结果集
    GroupResult<TbItem> groupResult = page.getGroupResult("item_category");
    //得到分组结果入口页
    Page<GroupEntry<TbItem>> groupEntries = groupResult.getGroupEntries();
    //得到分组入口集合
    List<GroupEntry<TbItem>> entries = groupEntries.getContent();
    for (GroupEntry<TbItem> entry : entries) {
        list.add(entry.getGroupValue());//将分组结果的名称封装到返回值中	
    }
    return list;
}

search方法调用

1
2
3
4
5
6
7
8
9
10
@Override
public Map<String, Object> search(Map searchMap) {
    Map<String,Object> map=new HashMap<>();		
    //1.按关键字查询（高亮显示）
    ......		
    //2.根据关键字查询商品分类
    List categoryList = searchCategoryList(searchMap);
    map.put("categoryList",categoryList);		
    return map;
}

4.2前端

修改search.html

1
2
3
4
5
6
7
8
9
<div class="type-wrap" ng-if="resultMap.categoryList!=null">
	<div class="fl key">商品分类</div>
	<div class="fl value">
		<span ng-repeat="category in resultMap.categoryList">
			<a href="#">{{category}}</a>
		</span>
	</div>
	<div class="fl ext"></div>
</div>

5.品牌和规格数据

5.1缓存品牌和规格数据

将商品分类数据、品牌数据、和规格数据都放入Redis存储。

（1）当用户进入运营商后台的商品分类页面时，将商品分类数据放入缓存（Hash）。以分类名称作为key ,以模板ID作为值

（2）当用户进入运营商后台的模板管理页面时，分别将品牌数据和规格数据放入缓存（Hash）。以模板ID作为key,以品牌列表和规格列表作为值。

缓存商品分类数据：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Autowired
private RedisTemplate redisTemplate;

@Override
public List<TbItemCat> findByParentId(Long parentId) {
    TbItemCatExample example1=new TbItemCatExample();
    Criteria criteria1 = example1.createCriteria();
    criteria1.andParentIdEqualTo(parentId);

    //每次执行查询的时候，一次性读取缓存进行存储 (因为每次增删改都要执行此方法)
    //以分类名称作为key ,以模板ID作为值
    List<TbItemCat> list = findAll();
    for (TbItemCat itemCat : list) {
        redisTemplate.boundHashOps("itemCat").put(itemCat.getName(), itemCat.getTypeId());
    }
    System.out.println("更新缓存:商品分类表");
    return  itemCatMapper.selectByExample(example1);		
}

缓存品牌和规格列表数据：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@Autowired
private RedisTemplate redisTemplate;

//将数据存入缓存
//分别将品牌数据和规格数据放入缓存（Hash）。以模板ID作为key,以品牌列表和规格列表作为值
private void saveToRedis() {
    List<TbTypeTemplate> list = findAll();
    for (TbTypeTemplate typeTemplate : list) {
        //存储品牌列表
        List<Map> brandList = JSON.parseArray(typeTemplate.getBrandIds(), Map.class);
        redisTemplate.boundHashOps("brandList").put(typeTemplate.getId(), brandList);
        //存储规格列表
        List<Map> specList = findSpecList(typeTemplate.getId());//根据模板ID查询规格列表
        redisTemplate.boundHashOps("specList").put(typeTemplate.getId(), specList);	
    }
    System.out.println("品牌数据和规格数据放入缓存");
}

在查询分页方法(findPage) 时调用此方法 

1
2
3
4
5
public PageResult findPage(TbTypeTemplate typeTemplate, int pageNum, int pageSize) {
    ......	
        saveToRedis();//存入数据到缓存
    return new PageResult(page.getTotal(), page.getResult());
}

5.2显示品牌和规格数据

后端：

修改ItemSearchServiceImpl.java ，增加方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@Autowired
private RedisTemplate redisTemplate;

//通过分类名称查询品牌和规格列表
private Map searchBrandAndSpecList(String category) {
    Map map = new HashMap<>();
    Long typeId = (Long) redisTemplate.boundHashOps("itemCat").get(category);//获取模板ID
    if(typeId!=null) {
        //根据模板ID查询品牌列表 
        List brandList = (List) redisTemplate.boundHashOps("brandList").get(typeId);
        map.put("brandList", brandList);
        //根据模板ID查询规格列表
        List specList = (List) redisTemplate.boundHashOps("specList").get(typeId);
        map.put("specList", specList);
    }
    return map;
}

Search方法调用此方法

1
2
3
4
5
6
7
8
9
10
11
@Override
public Map<String, Object> search(Map searchMap) {
    Map<String,Object> map=new HashMap<>();			
    //1.按关键字查询（高亮显示）
    //2.根据关键字查询商品分类
    //3.查询品牌和规格列表
    if(categoryList.size()>0){
        map.putAll(searchBrandAndSpecList(categoryList.get(0)));
    }
    return map;
}

前端：
修改页面search.html，实现品牌列表和规格列表

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
<div class="type-wrap logo" ng-if="resultMap.brandList!=null">
	<div class="fl key brand">品牌</div>
	<div class="value logos">
		<ul class="logo-list">
			<li ng-repeat="brand in resultMap.brandList">
				{{brand.text}}
			</li>							
		</ul>
	</div>
	<div class="ext">
		<a href="javascript:void(0);" class="sui-btn">多选</a>
		<a href="javascript:void(0);">更多</a>
	</div>
</div>
<div class="type-wrap" ng-repeat="spec in resultMap.specList">
	<div class="fl key">{{spec.text}}</div>
	<div class="fl value">
		<ul class="type-list">						
			<li ng-repeat="pojo in spec.options">
				<a>{{pojo.optionName}}</a>
			</li>							
		</ul>
	</div>
	<div class="fl ext"></div>
</div>

6.过滤构建和查询

6.1过滤条件构建

点击搜索面板上的分类、品牌和规格，实现查询条件的构建。查询条件以面包屑的形式显示。

当面包屑显示分类、品牌和规格时，要同时隐藏搜索面板对应的区域。

用户可以点击面包屑上的X 撤销查询条件。撤销后显示搜索面包相应的区域。

1、添加搜索项：

修改pinyougou-search-web的searchController.js 

1
2
3
4
5
6
7
8
9
10
11
$scope.searchMap={'keywords':'','category':'','brand':'','spec':{},'price':''};//搜索对象
//添加搜索项
$scope.addSearchItem=function(key,value){
    if(key=='category'||key=='brand'|| key=='price'){
        //如果点击的是分类或者是品牌
        $scope.searchMap[key]=value;
    }else{
        $scope.searchMap.spec[key]=value;
    }
    $scope.search();//执行搜索
}

修改pinyougou-search-web 的search.html ，为搜索面板添加点击事件

1
2
3
<li class="tag" ng-if="searchMap.category!=''" ng-click="removeSearchItem('category')">商品分类:{{searchMap.category}}<i class="sui-icon icon-tb-close"></i></li>
<li class="tag" ng-if="searchMap.brand!=''" ng-click="removeSearchItem('brand')">品牌:{{searchMap.brand}}<i class="sui-icon icon-tb-close"></i></li>
<li class="tag" ng-repeat="(key,value) in searchMap.spec" ng-click="removeSearchItem(key)">{{key}}:{{value}}<i class="sui-icon icon-tb-close"></i></li>

修改pinyougou-search-web 的search.html，用面包屑形式显示搜索条件

1
2
3
4
5
6
7
<ul class="fl sui-breadcrumb">搜索条件：</ul>
<ul class="tags-choose">
    <li class="tag" ng-if="searchMap.category!=''">商品分类：{{searchMap.category}}<i class="sui-icon icon-tb-close"></i></li>
    <li class="tag" ng-if="searchMap.brand!=''">品牌：{{searchMap.brand}}<i class="sui-icon icon-tb-close"></i></li>
    <li class="tag" ng-repeat="(key,value) in searchMap.spec">{{key}}:{{value}}<i class="sui-icon icon-tb-close"></i></li>
    <li class="tag" ng-if="searchMap.price!=''" ng-click="removeSearchItem('price')">价格：{{searchMap.price}}<i  class="sui-icon icon-tb-close"></i></li>
</ul>

2、撤销搜索项：

修改pinyougou-search-web工程searchController.js

1
2
3
4
5
6
7
8
//移除复合搜索条件
$scope.removeSearchItem=function(key){
    if(key=="category" ||  key=="brand"|| key=='price'){//如果是分类或品牌
        $scope.searchMap[key]="";		
    }else{//否则是规格
        delete $scope.searchMap.spec[key];//移除此属性
    }	
}

3、隐藏查询面板

修改search.html 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
<div class="type-wrap" ng-if="resultMap.categoryList!=null && searchMap.category==''">
	<div class="fl key">商品分类</div>
	......
</div>
<div class="type-wrap logo" ng-if="resultMap.brandList!=null && searchMap.brand==''">
	<div class="fl key brand">品牌</div>
	.......
</div>
<div class="type-wrap" ng-repeat="spec in resultMap.specList"  ng-if="searchMap.spec[spec.text]==null">
	<div class="fl key">{{spec.text}}</div>
	......
</div>
<ul class="type-list" ng-if="searchMap.price==''">
	<li>
		<a ng-click="addSearchItem('price','0-500')">0-500元</a>
	</li>
	<li>
		<a ng-click="addSearchItem('price','500-1000')">500-1000元</a>
	</li>
	<li>
		<a ng-click="addSearchItem('price','1000-1500')">1000-1500元</a>
	</li>
	<li>
		<a ng-click="addSearchItem('price','1500-2000')">1500-2000元</a>
	</li>
	<li>
		<a ng-click="addSearchItem('price','2000-3000')">2000-3000元 </a>
	</li>
	<li>
		<a ng-click="addSearchItem('price','3000-*')">3000元以上</a>
	</li>
</ul>

4、如果用户输入的是品牌的关键字，则隐藏品牌列表

修改searchController.js

1
2
3
4
5
6
7
8
9
//判断关键字是不是品牌
$scope.keywordsIsBrand=function(){
    for(var i=0;i<$scope.resultMap.brandList.length;i++){
        if($scope.searchMap.keywords.indexOf($scope.resultMap.brandList[i].text)>=0){//如果包含
            return true;
        }			
    }		
    return false;
}

修改页面

1
2
3
4
<div class="type-wrap logo" ng-if="resultMap.brandList!=null&& searchMap.brand=='' && keywordsIsBrand()==false">
    <div class="fl key brand">品牌</div>
    .........
</div>

image-20200802130025617

6.2过滤查询

根据分类查询品牌规格列表：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Override
public Map<String, Object> search(Map searchMap) {
    Map<String,Object> map=new HashMap<>();		
    //1.按关键字查询（高亮显示）
    ......		
        //2.根据关键字查询商品分类	
        ......	
        //3.查询品牌和规格列表
        String categoryName=(String)searchMap.get("category");
    if(!"".equals(categoryName)){//如果有分类名称
        map.putAll(searchBrandAndSpecList(categoryName));			
    }else{//如果没有分类名称，按照第一个查询
        if(categoryList.size()>0){
            map.putAll(searchBrandAndSpecList(categoryList.get(0)));
        }
    }
    return map;
}

分类和品牌过滤：

1
2
3
4
5
6
7
8
9
10
11
12
13
//按分类筛选
if(!"".equals(searchMap.get("category"))){			
    Criteria filterCriteria=new Criteria("item_category").is(searchMap.get("category"));
    FilterQuery filterQuery=new SimpleFilterQuery(filterCriteria);
    query.addFilterQuery(filterQuery);
}

//按品牌筛选
if(!"".equals(searchMap.get("brand"))){			
    Criteria filterCriteria=new Criteria("item_brand").is(searchMap.get("brand"));
    FilterQuery filterQuery=new SimpleFilterQuery(filterCriteria);
    query.addFilterQuery(filterQuery);
}

规格过滤：

实现思路：规格有多项，需要循环过滤。循环规格查询条件，根据key得到域名城，根据value设置过滤条件

1
2
3
4
5
6
7
8
9
//过滤规格
if(searchMap.get("spec")!=null) {
    Map<String, String> specMap = (Map<String, String>) searchMap.get("spec");
    for(String key:specMap.keySet()) {
        Criteria filterCriteria=new Criteria("item_spec_"+key).is( specMap.get(key) );
        FilterQuery filterQuery=new SimpleFilterQuery(filterCriteria);
        query.addFilterQuery(filterQuery);	
    }
}

按价格筛选：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
//按价格筛选
if(!"".equals(searchMap.get("price"))) {
    String[] price = ((String)searchMap.get("price")).split("-");
    if(!price[0].equals("0")) {
        //如果区间起点不等于0
        Criteria filterCriteria=new Criteria("item_price").greaterThanEqual(price[0]);
        FilterQuery filterQuery=new SimpleFilterQuery(filterCriteria);
        query.addFilterQuery(filterQuery);	
    }
    if(!price[1].equals("*")){//如果区间终点不等于*
        Criteria filterCriteria=new  Criteria("item_price").lessThanEqual(price[1]);
        FilterQuery filterQuery=new SimpleFilterQuery(filterCriteria);
        query.addFilterQuery(filterQuery);				
    }	
}

7.搜索结果分页

之前的分页我们都是用PageHelper来完成的，但是PageHelper做出来的界面不太美观，达不到我们想要的前台效果，适合后台。这里我们通过Spring Data Solr来完成分页。

7.1后端

修改pinyougou-search-service工程ItemSearchServiceImpl.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
//分页查询
Integer pageNo= (Integer) searchMap.get("pageNo");//提取页码
if(pageNo==null){
    pageNo=1;//默认第一页
}
Integer pageSize=(Integer) searchMap.get("pageSize");//每页记录数 
if(pageSize==null){
    pageSize=20;//默认20
}
query.setOffset((pageNo-1)*pageSize);//从第几条记录查询
query.setRows(pageSize);

map.put("totalPages", page.getTotalPages());//返回总页数
map.put("total", page.getTotalElements());//返回总记录数

7.2构建分页标签

为搜索对象添加属性

1
2
$scope.searchMap={'keywords':'','category':'','brand':'','spec':{},'price':'',
'pageNo':1,'pageSize':40 };//搜索条件封装对象

实现页码的构建 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
//构建分页标签(totalPages为总页数)
buildPageLabel=function(){
    $scope.pageLabel=[];//新增分页栏属性		
    var maxPageNo= $scope.resultMap.totalPages;//得到最后页码
    var firstPage=1;//开始页码
    var lastPage=maxPageNo;//截止页码			
    if($scope.resultMap.totalPages> 5){  //如果总页数大于5页,显示部分页码		
        if($scope.searchMap.pageNo<=3){//如果当前页小于等于3
            lastPage=5; //前5页
        }else if( $scope.searchMap.pageNo>=lastPage-2  ){//如果当前页大于等于最大页码-2
            firstPage= maxPageNo-4;		 //后5页	
        }else{ //显示当前页为中心的5页
            firstPage=$scope.searchMap.pageNo-2;
            lastPage=$scope.searchMap.pageNo+2;			
        }
    }	
    //循环产生页码标签				
    for(var i=firstPage;i<=lastPage;i++){
        $scope.pageLabel.push(i);				
    }		
}

在查询后调用此方法

7.3提交页码查询

在searchController.js增加方法，修改页码执行查询

1
2
3
4
5
6
7
8
9
//根据页码查询
$scope.queryByPage=function(pageNo){
    //页码验证
    if(pageNo<1 || pageNo>$scope.resultMap.totalPages){
        return;
    }		
    $scope.searchMap.pageNo=pageNo;			
    $scope.search();
}

修改页码调用方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
<div class="sui-pagination pagination-large">
	<ul>
		<li class="prev {{searchMap.pageNo==1?'disabled':''}}">
			<a href="#" ng-click="queryByPage(searchMap.pageNo-1)">«</a>
		</li>
		<li ng-repeat="p in pageLabel">
			<a href="#" ng-click="queryByPage(p)">{{p}}</a>
		</li>
		<li class="next  {{searchMap.pageNo==resultMap.totalPages?'disabled':''}}">
			<a href="#" ng-click="queryByPage(searchMap.pageNo+1)">»</a>
		</li>
	</ul>
	<div>
	<span>&nbsp;共{{resultMap.totalPages}}页&nbsp;</span>						
	<span>  到第 <input type="text" class="page-num" ng-model="searchMap.pageNo">页 
	    <button class="page-confirm"  ng-click="queryByPage(searchMap.pageNo)" >确定</button></span>
	 </div>
</div>

修改search方法, 在执行查询前，转换为int类型，否则提交到后端有可能变成字符串

1
2
3
4
5
//搜索
$scope.search=function(){
    $scope.searchMap.pageNo= parseInt($scope.searchMap.pageNo) ;
    .......	
}

7.4显示省略号

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
//构建分页栏	
buildPageLabel=function(){
    ...
    $scope.firstDot=true;//前面有点
    $scope.lastDot=true;//后边有点		
    if($scope.resultMap.totalPages>5){  //如果页码数量大于5			
        if($scope.searchMap.pageNo<=3){//如果当前页码小于等于3 ，显示前5页
            lastPage=5;
            $scope.firstDot=false;//前面没点
        }else if( $scope.searchMap.pageNo>= $scope.resultMap.totalPages-2 ){//显示后5页
            firstPage=$scope.resultMap.totalPages-4;	
            $scope.lastDot=false;//后边没点
        }else{  //显示以当前页为中心的5页
           ...
        }			
    }else{
        $scope.firstDot=false;//前面无点
        $scope.lastDot=false;//后边无点
    }
   ...
}

修改页面 ：页码的省略号

1
2
<li class="dotted" ng-if="firstDot==true"><span>...</span></li>
<li class="dotted" ng-if="lastDot==true"><span>...</span></li>

7.5搜索起始页码处理

测试：如果我们先按照“手机”关键字进行搜索，得出的页数是19页，然后我们点击第18页进行查询，然后我们再根据“三星”关键字搜索，会发现没有结果显示。是因为当前页仍然为18，而三星的结果只有4页，所以无法显示。我们需要在每次点击查询时将页码设置为1 。

修改搜索按钮，调用搜索前将起始页码设置为1

1
<button class="sui-btn btn-xlarge btn-danger" ng-click="searchMap.pageNo=1;search()" type="button">搜索</button>

8.排序

8.1按价格排序

修改pinyougou-search-service的ItemSearchServiceImpl.java 添加排序的代码

1
2
3
4
5
6
7
8
9
10
11
12
13
//排序
String sortValue= (String) searchMap.get("sort");//ASC  DESC  
String sortField= (String) searchMap.get("sortField");//排序字段
if(sortValue!=null&&!sortValue.equals("")) {
    if(sortValue.equals("ASC")) {
        Sort sort = new Sort(Sort.Direction.ASC, "item_"+sortField);
        query.addSort(sort);
    }
    if(sortValue.equals("DESC")){		
        Sort sort=new Sort(Sort.Direction.DESC, "item_"+sortField);
        query.addSort(sort);
    }		
}

修改searchController.js

1
2
3
4
5
6
7
$scope.searchMap={'keywords':'','category':'','brand':'','spec':{},'price':'','pageNo':1,'pageSize':40 ,'sortField':'','sort':'' };//搜索对象
//设置排序规则
$scope.sortSearch=function(sortField,sort){
    $scope.searchMap.sortField=sortField;	
    $scope.searchMap.sort=sort;	
    $scope.search();
}

修改页面search.html 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
<div class="navbar-inner filter">
    <ul class="sui-nav">
        <li class="active">
            <a href="#" ng-click="sortSearch('','')">综合</a>
        </li>
        <li>
            <a href="#">销量</a>
        </li>
        <li>
            <a href="#">新品</a>
        </li>
        <li>
            <a href="#">评价</a>
        </li>
        <li>
            <a href="#" ng-click="sortSearch('price','ASC')">价格↑</a>
        </li>
        <li>
            <a href="#" ng-click="sortSearch('price','DESC')">价格↓</a>
        </li>
    </ul>
</div>

8.2按上架时间排序

修改solrhome的schema.xml 添加域定义

1
<field name="item_updatetime" type="date" indexed="true" stored="true" />

修改实体类为updatetime属性添加注解

1
2
@Field("item_updatetime")
private Date updateTime;

重新启动solr

安装pinyougou-pojo

重新运行pinyougou-solr-util

修改search.html 

1
2
3
<li>
	<a href="#" ng-click="sortSearch('updatetime','DESC')">新品</a>
</li>

8.3按销量和评价排序

（1）增加域item_salecount 用于存储每个SKU的销量数据

（2）编写定时器程序，用于更新每个SKU的销量数据（查询近1个月的销量数据，不是累计数据）

（3）定时器每天只需执行一次，可以设定为凌晨开始执行。

定时器可以使用spring task技术来实现

评论分为好评、中评、差评，我们不能简单地将评论数相加，而是应该根据每种评论加权进行统计。比如好评的权重是3 ，中评的权重是1，而差评的权重是 -3，这样得出的是评价的综合得分。

9.搜索页与首页对接

用户在首页的搜索框输入关键字，点击搜索后自动跳转到搜索页查询

9.1首页传递关键字

修改pinyougou-portal-web的contentController.js

1
2
3
4
//搜索跳转
$scope.search=function(){
	location.href="http://localhost:9104/search.html#?keywords="+$scope.keywords;
}

修改pinyougou-portal-web的index.html

1
2
3
4
<div class="input-append">
	<input type="text" id="autocomplete" type="text" ng-model="keywords" class="input-error input-xxlarge" />
	<button class="sui-btn btn-xlarge btn-danger" ng-click="search()" type="button">搜索</button>
</div>

9.2搜索页接收关键字

修改pinyougou-search-web的searchController.js

添加location服务用于接收参数

1
app.controller('searchController',function($scope,$location,searchService)

接收参数并进行查询

1
2
3
4
5
//加载查询字符串
$scope.loadkeywords=function(){
    $scope.searchMap.keywords=  $location.search()['keywords'];
    $scope.search();
}

在search页面初始化调用此方法

10.更新索引库

10.1查询审核商品（SKU）列表

修改pinyougou-sellergoods-interface的GoodsService.java，新增方法

1
2
3
4
5
6
7
/**
 * 根据商品ID和状态查询Item表信息  
 * @param goodsId
 * @param status
 * @return
 */
public List<TbItem> findItemListByGoodsIdandStatus(Long[] goodsIds, String status );

GoodsServiceImpl.java 实现该方法

1
2
3
4
5
6
7
8
@Override
public List<TbItem> findItemListByGoodsIdandStatus(Long[] goodsIds, String status) {
	TbItemExample example=new TbItemExample();
com.pinyougou.pojo.TbItemExample.Criteria criteria = example.createCriteria();
	criteria.andGoodsIdIn(Arrays.asList(goodsIds));
	criteria.andStatusEqualTo(status);
	return itemMapper.selectByExample(example);
}

10.2更新到索引库

修改pinyougou-search-interface的ItemSearchService.java 

1
2
3
4
5
/**
	 * 导入数据
	 * @param list
	 */
public void importList(List list);

ItemSearchServiceImpl.java实现该方法

1
2
3
4
5
@Override
public void importList(List list) {
    solrTemplate.saveBeans(list);	
    solrTemplate.commit();
}

修改pinyougou-manager-web工程的GoodsController.java 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
@Reference
private ItemSearchService itemSearchService;
@RequestMapping("/updateStatus")
public Result updateStatus(Long[] ids,String status){
    try {
        goodsService.updateStatus(ids, status);
        //按照SPU ID查询 SKU列表(状态为1)		
        if(status.equals("1")){//审核通过
            List<TbItem> itemList = goodsService.findItemListByGoodsIdandStatus(ids, status);						
            //调用搜索接口实现数据批量导入
            if(itemList.size()>0){				
                itemSearchService.importList(itemList);
            }else{
                System.out.println("没有明细数据");
            }
        }
        return new Result(true, "修改状态成功"); 
    } catch (Exception e) {
        e.printStackTrace();
        return new Result(false, "修改状态失败");
    }
}

10.3商品删除同步索引数据

服务接口层

1
2
3
4
5
/**
	 * 删除数据
	 * @param ids
	 */
public void deleteByGoodsIds(List goodsIdList);

服务实现层

1
2
3
4
5
6
7
8
9
@Override
public void deleteByGoodsIds(List goodsIdList) {
    System.out.println("删除商品ID"+goodsIdList);
    Query query=new SimpleQuery();		
    Criteria criteria=new Criteria("item_goodsid").in(goodsIdList);
    query.addCriteria(criteria);
    solrTemplate.delete(query);
    solrTemplate.commit();
}

控制层

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
/**
	 * 批量删除
	 * @param ids
	 * @return
	 */
@RequestMapping("/delete")
public Result delete(Long [] ids){
    try {
        goodsService.delete(ids);
        itemSearchService.deleteByGoodsIds(Arrays.asList(ids));
        return new Result(true, "删除成功"); 
    } catch (Exception e) {
        e.printStackTrace();
        return new Result(false, "删除失败");
    }
}

结语

天天35°C以上的高温，只想呆在空调里面裹着被子刷手机📱或者睡觉😴

赏

谢谢你请我吃糖果

支付宝
微信

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

很惭愧<br><br>只做了一点微小的工作<br>谢谢大家