caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 优化生成索引，增加批量生成参数

Browse Source
This commit is contained in:
misworga831 2023-02-21 12:08:33 +08:00
parent 88efc2da38
commit 8e0b77c232
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java
View File

@ -57,6 +57,8 @@ import java.util.stream.Collectors;
@RocketMQMessageListener(topic = "${lili.data.rocketmq.goods-topic}", consumerGroup = "${lili.data.rocketmq.goods-group}") @RocketMQMessageListener(topic = "${lili.data.rocketmq.goods-topic}", consumerGroup = "${lili.data.rocketmq.goods-group}")
public class GoodsMessageListener implements RocketMQListener<MessageExt> { public class GoodsMessageListener implements RocketMQListener<MessageExt> {
private static final int BATCH_SIZE = 10;
/** /**
* ES商品 * ES商品
*/ */
@ -267,7 +269,7 @@ public class GoodsMessageListener implements RocketMQListener<MessageExt> {
searchParams.setPromotionId(promotions.getId()); searchParams.setPromotionId(promotions.getId());
PageVO pageVO = new PageVO(); PageVO pageVO = new PageVO();
pageVO.setPageNumber(i); pageVO.setPageNumber(i);
pageVO.setPageSize(100); pageVO.setPageSize(BATCH_SIZE);
Page<PromotionGoods> promotionGoodsPage = this.promotionGoodsService.pageFindAll(searchParams, pageVO); Page<PromotionGoods> promotionGoodsPage = this.promotionGoodsService.pageFindAll(searchParams, pageVO);
if (promotionGoodsPage == null || promotionGoodsPage.getRecords().isEmpty()) { if (promotionGoodsPage == null || promotionGoodsPage.getRecords().isEmpty()) {
break; break;
@ -283,7 +285,7 @@ public class GoodsMessageListener implements RocketMQListener<MessageExt> {
GoodsSearchParams searchParams = new GoodsSearchParams(); GoodsSearchParams searchParams = new GoodsSearchParams();
searchParams.setCategoryPath(promotions.getScopeId()); searchParams.setCategoryPath(promotions.getScopeId());
searchParams.setPageNumber(i); searchParams.setPageNumber(i);
searchParams.setPageSize(100); searchParams.setPageSize(BATCH_SIZE);
IPage<GoodsSku> goodsSkuByPage = this.goodsSkuService.getGoodsSkuByPage(searchParams); IPage<GoodsSku> goodsSkuByPage = this.goodsSkuService.getGoodsSkuByPage(searchParams);
if (goodsSkuByPage == null || goodsSkuByPage.getRecords().isEmpty()) { if (goodsSkuByPage == null || goodsSkuByPage.getRecords().isEmpty()) {
break; break;
@ -340,7 +342,7 @@ public class GoodsMessageListener implements RocketMQListener<MessageExt> {
GoodsSearchParams searchParams = new GoodsSearchParams(); GoodsSearchParams searchParams = new GoodsSearchParams();
searchParams.setGoodsId(goods.getId()); searchParams.setGoodsId(goods.getId());
searchParams.setPageNumber(i); searchParams.setPageNumber(i);
searchParams.setPageSize(100); searchParams.setPageSize(BATCH_SIZE);
IPage<GoodsSku> goodsSkuByPage = this.goodsSkuService.getGoodsSkuByPage(searchParams); IPage<GoodsSku> goodsSkuByPage = this.goodsSkuService.getGoodsSkuByPage(searchParams);
if (goodsSkuByPage == null || goodsSkuByPage.getRecords().isEmpty()) { if (goodsSkuByPage == null || goodsSkuByPage.getRecords().isEmpty()) {
break; break;