From d877a24dec61e9c319cbb7afd614436f72b156cd Mon Sep 17 00:00:00 2001 From: paulGao Date: Mon, 8 Nov 2021 16:20:44 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=95=86=E5=93=81=E6=90=9C?= =?UTF-8?q?=E7=B4=A2=EF=BC=88=E5=A2=9E=E5=8A=A0=E5=95=86=E5=93=81=E5=9F=BA?= =?UTF-8?q?=E7=A1=80=E5=88=86=E6=95=B0=EF=BC=8C=E5=90=8CgoodsId=E9=80=92?= =?UTF-8?q?=E5=87=8F=E3=80=82=E5=A2=9E=E5=8A=A0=E9=94=80=E9=87=8F=E5=88=86?= =?UTF-8?q?=E6=95=B0=E5=8D=A0=E6=AF=94=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/cn/lili/listener/GoodsMessageListener.java | 4 ++-- .../java/cn/lili/modules/search/entity/dos/EsGoodsIndex.java | 4 ++-- .../modules/search/serviceimpl/EsGoodsIndexServiceImpl.java | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java index 71fa5d6f..8738bf0c 100644 --- a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java +++ b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java @@ -288,11 +288,11 @@ public class GoodsMessageListener implements RocketMQListener { * @param goodsSkuList 商品sku信息 */ private void generatorGoodsIndex(Goods goods, List goodsSkuList) { - int skuNo = 100; + int skuSource = 100; for (GoodsSku goodsSku : goodsSkuList) { EsGoodsIndex esGoodsOld = goodsIndexService.findById(goodsSku.getId()); EsGoodsIndex goodsIndex = this.settingUpGoodsIndexData(goods, goodsSku); - goodsIndex.setSkuNo(skuNo--); + goodsIndex.setSkuSource(skuSource--); //如果商品库存不为0，并且es中有数据 if (goodsSku.getQuantity() > 0 && esGoodsOld == null) { log.info("生成商品索引 {}", goodsIndex); diff --git a/framework/src/main/java/cn/lili/modules/search/entity/dos/EsGoodsIndex.java b/framework/src/main/java/cn/lili/modules/search/entity/dos/EsGoodsIndex.java index 5d4137b6..80e5db4a 100644 --- a/framework/src/main/java/cn/lili/modules/search/entity/dos/EsGoodsIndex.java +++ b/framework/src/main/java/cn/lili/modules/search/entity/dos/EsGoodsIndex.java @@ -262,8 +262,8 @@ public class EsGoodsIndex implements Serializable { /** * @see cn.lili.modules.goods.entity.enums.GoodsTypeEnum */ - @ApiModelProperty(value = "商品sku编号（当前商品中第几个sku）", required = true) - private Integer skuNo; + @ApiModelProperty(value = "商品sku基础分数", required = true) + private Integer skuSource; /** * 商品属性（参数和规格） 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 9b44f877..7bead3dd 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 @@ -139,10 +139,10 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements skuQueryWrapper.eq(GoodsSku::getMarketEnable, GoodsStatusEnum.UPPER.name()); List goodsSkuList = goodsSkuService.list(skuQueryWrapper); - int skuNo = 100; + int skuSource = 100; for (GoodsSku goodsSku : goodsSkuList) { EsGoodsIndex esGoodsIndex = wrapperEsGoodsIndex(goodsSku, goods); - esGoodsIndex.setSkuNo(skuNo--); + esGoodsIndex.setSkuSource(skuSource--); esGoodsIndices.add(esGoodsIndex); //库存锁是在redis做的，所以生成索引，同时更新一下redis中的库存数量 cache.put(GoodsSkuService.getStockCacheKey(goodsSku.getId()), goodsSku.getQuantity());