fix: 优化es生成索引sku取分可能为复数问题

This commit is contained in:
misworga831 2023-05-08 17:37:29 +08:00
parent 3e74697215
commit 8181f2602a
2 changed files with 8 additions and 1 deletions

View File

@ -382,7 +382,11 @@ public class GoodsMessageListener implements RocketMQListener<MessageExt> {
List<EsGoodsIndex> 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);

View File

@ -235,6 +235,9 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
if (count >= 1) {
skuSource -= count;
}
if (skuSource <= 0) {
skuSource = 1;
}
esGoodsIndex.setSkuSource(skuSource);