caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加促销活动更新日志

Browse Source
This commit is contained in:
paulGao 2022-03-08 12:08:12 +08:00
parent ee5355668d
commit ac475ca456
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
View File

@ -636,6 +636,11 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
} else { } else {
promotionMap = goodsIndex.getPromotionMap(); promotionMap = goodsIndex.getPromotionMap();
} }
log.info("ES修改商品活动索引-活动信息:{}", promotion);
log.info("ES修改商品活动索引-活动信息状态:{}", promotion.getPromotionStatus());
log.info("ES修改商品活动索引-原商品索引信息:{}", goodsIndex);
log.info("ES修改商品活动索引-原商品索引活动信息:{}", promotionMap);
//如果活动已结束 //如果活动已结束
if (promotion.getPromotionStatus().equals(PromotionsStatusEnum.END.name()) || promotion.getPromotionStatus().equals(PromotionsStatusEnum.CLOSE.name())) {//如果存在活动 if (promotion.getPromotionStatus().equals(PromotionsStatusEnum.END.name()) || promotion.getPromotionStatus().equals(PromotionsStatusEnum.CLOSE.name())) {//如果存在活动
//删除活动 //删除活动
@ -643,6 +648,7 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
} else { } else {
promotionMap.put(key, promotion); promotionMap.put(key, promotion);
} }
log.info("ES修改商品活动索引-过滤后商品索引活动信息:{}", promotionMap);
return this.getGoodsIndexPromotionUpdateRequest(goodsIndex.getId(), promotionMap); return this.getGoodsIndexPromotionUpdateRequest(goodsIndex.getId(), promotionMap);
} }
@ -678,7 +684,7 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
if (responses.hasFailures()) { if (responses.hasFailures()) {
log.info("批量更新商品索引的促销信息中出现部分异常：{}", responses.buildFailureMessage()); log.info("批量更新商品索引的促销信息中出现部分异常：{}", responses.buildFailureMessage());
} else { } else {
log.info("批量更新商品索引的促销信息结果：{}", responses.status()); log.info("批量更新商品索引的促销信息结果：{}", responses);
} }
} catch (IOException e) { } catch (IOException e) {
log.error("批量更新商品索引的促销信息出现异常！", e); log.error("批量更新商品索引的促销信息出现异常！", e);