优化索引生成,商品索引查询

This commit is contained in:
paulGao
2022-06-13 18:50:09 +08:00
parent 24de62f5f4
commit 056f040317
11 changed files with 151 additions and 64 deletions

View File

@@ -33,7 +33,7 @@ public class ElasticsearchController {
}
@GetMapping("/progress")
public ResultMessage<Map<String, Integer>> getProgress() {
public ResultMessage<Map<String, Long>> getProgress() {
return ResultUtil.data(esGoodsIndexService.getProgress());
}
}

View File

@@ -3,9 +3,11 @@ package cn.lili.test.elasticsearch;
import cn.hutool.json.JSONUtil;
import cn.lili.cache.Cache;
import cn.lili.common.vo.PageVO;
import cn.lili.modules.goods.entity.dos.Goods;
import cn.lili.modules.goods.entity.dos.GoodsSku;
import cn.lili.modules.goods.entity.enums.GoodsAuthEnum;
import cn.lili.modules.goods.entity.enums.GoodsStatusEnum;
import cn.lili.modules.goods.service.GoodsService;
import cn.lili.modules.goods.service.GoodsSkuService;
import cn.lili.modules.promotion.service.PromotionService;
import cn.lili.modules.search.entity.dos.EsGoodsAttribute;
@@ -47,6 +49,9 @@ class EsTest {
@Autowired
private GoodsSkuService goodsSkuService;
@Autowired
private GoodsService goodsService;
@Autowired
private Cache cache;
@@ -63,6 +68,13 @@ class EsTest {
// System.out.println(HtmlUtil.filter("+ADw-script+AD4-alert(document.cookie)+ADw-/script+AD4-"));
// Date dt1 = new Date(2021, 12, 10);
// Date dt2 = new Date(2021, 12, 14);
for (int i = 0; i < 1000; i++) {
Goods goods = new Goods();
goods.setGoodsName("测试商品" + i);
// goods.setAuthFlag();
}
//
}
@@ -132,7 +144,7 @@ class EsTest {
esGoodsIndices.add(index);
cache.put(GoodsSkuService.getStockCacheKey(goodsSku.getId()), goodsSku.getQuantity());
}
esGoodsIndexService.initIndex(esGoodsIndices);
esGoodsIndexService.initIndex(esGoodsIndices, true);
Assertions.assertTrue(true);
}