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());