From 8181f2602ade5884a6ec47d5b2a24eff62292aae Mon Sep 17 00:00:00 2001 From: misworga831 Date: Mon, 8 May 2023 17:37:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96es=E7=94=9F=E6=88=90?= =?UTF-8?q?=E7=B4=A2=E5=BC=95sku=E5=8F=96=E5=88=86=E5=8F=AF=E8=83=BD?= =?UTF-8?q?=E4=B8=BA=E5=A4=8D=E6=95=B0=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/cn/lili/listener/GoodsMessageListener.java | 6 +++++- .../modules/search/serviceimpl/EsGoodsIndexServiceImpl.java | 3 +++ 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java index 8661814d..8ed979cb 100644 --- a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java +++ b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java @@ -382,7 +382,11 @@ public class GoodsMessageListener implements RocketMQListener { List esGoodsIndices = new ArrayList<>(); for (GoodsSku goodsSku : goodsSkuList) { EsGoodsIndex goodsIndex = this.settingUpGoodsIndexData(goods, goodsSku); - goodsIndex.setSkuSource(skuSource--); + skuSource--; + if (skuSource <= 0) { + skuSource = 1; + } + goodsIndex.setSkuSource(skuSource); log.info("goodsSku：{}", goodsSku); log.info("生成商品索引 {}", goodsIndex); esGoodsIndices.add(goodsIndex); diff --git a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java index 6a77c8e5..32359149 100644 --- a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java @@ -235,6 +235,9 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements if (count >= 1) { skuSource -= count; } + if (skuSource <= 0) { + skuSource = 1; + } esGoodsIndex.setSkuSource(skuSource);