| | |
|---|
| | | import cn.lili.modules.search.service.EsGoodsSearchService; |
|---|
| | | import cn.lili.rocketmq.RocketmqSendCallbackBuilder; |
|---|
| | | import cn.lili.rocketmq.tags.GoodsTagsEnum; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
|---|
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|---|
| | |
|---|
| | | if (CollUtil.isNotEmpty(promotionGoods)) { |
|---|
| | | esGoodsIndex.setPromotionMapJson(JSONUtil.toJsonStr(promotionService.wrapperPromotionMapList(promotionGoods))); |
|---|
| | | } |
|---|
| | | |
|---|
| | | log.info("构建出es的索引信息为{}", JSON.toJSONString(esGoodsIndex)); |
|---|
| | | esGoodsIndex.setGoodsSort(goodsSku.getGoodsSort()); |
|---|
| | | esGoodsIndices.add(esGoodsIndex); |
|---|
| | | //库存锁是在redis做的，所以生成索引，同时更新一下redis中的库存数量 |
|---|
| | | cache.put(GoodsSkuService.getStockCacheKey(goodsSku.getId()), goodsSku.getQuantity()); |
|---|
