From 08933ad92ffa53338f82bce850e5dcd545058844 Mon Sep 17 00:00:00 2001 From: misworga831 Date: Tue, 18 Apr 2023 10:35:56 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E8=B6=B3=E8=BF=B9?= =?UTF-8?q?=E6=90=9C=E7=B4=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lili/modules/member/serviceimpl/FootprintServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java index b9239f6e..b8110c7c 100644 --- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java @@ -88,6 +88,9 @@ public class FootprintServiceImpl extends ServiceImpl { if (goodsSkuByIdFromCache.get(i) == null) { EsGoodsIndex esGoodsIndex = new EsGoodsIndex(); + FootPrint footPrint = footPrintPages.getRecords().get(i); + esGoodsIndex.setGoodsId(footPrint.getGoodsId()); + esGoodsIndex.setId(footPrint.getSkuId()); esGoodsIndex.setReleaseTime(footPrintPages.getRecords().get(i).getCreateTime().getTime()); return esGoodsIndex; } From 8181f2602ade5884a6ec47d5b2a24eff62292aae Mon Sep 17 00:00:00 2001 From: misworga831 Date: Mon, 8 May 2023 17:37:29 +0800 Subject: [PATCH 2/2] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96es=E7=94=9F?= =?UTF-8?q?=E6=88=90=E7=B4=A2=E5=BC=95sku=E5=8F=96=E5=88=86=E5=8F=AF?= =?UTF-8?q?=E8=83=BD=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);