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

消费者执行异常问题处理：包含系统自动评价问题，和自动新增秒杀活动问题

Browse Source
This commit is contained in:
Chopper 2022-02-16 17:42:12 +08:00
parent c5da640432
commit b32bf41443
2 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
consumer/src/main/java/cn/lili/timetask/handler/impl/promotion/PromotionEverydayExecute.java
View File

@ -44,10 +44,18 @@ public class PromotionEverydayExecute implements EveryDayExecute {
*/ */
@Override @Override
public void execute() { public void execute() {
//清除所以商品索引的无效促销活动 try {
this.esGoodsIndexService.cleanInvalidPromotion(); //清除所有商品索引的无效促销活动
//定时创建活动 this.esGoodsIndexService.cleanInvalidPromotion();
addSeckill(); } catch (Exception e) {
log.error("清楚商品索引中无效促销异常", e);
}
try {
//定时创建活动
addSeckill();
} catch (Exception e) {
log.error("秒杀活动添加异常", e);
}
} }

8
framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberEvaluationServiceImpl.java
View File

@ -112,11 +112,15 @@ public class MemberEvaluationServiceImpl extends ServiceImpl<MemberEvaluationMap
//获取订单信息 //获取订单信息
Order order = orderService.getBySn(orderItem.getOrderSn()); Order order = orderService.getBySn(orderItem.getOrderSn());
//检测是否可以添加会员评价 //检测是否可以添加会员评价
Member member;
if (Boolean.TRUE.equals(isSelf)) { if (Boolean.TRUE.equals(isSelf)) {
checkMemberEvaluation(orderItem, order); checkMemberEvaluation(orderItem, order);
//获取用户信息 非自己评价时，读取数据库
member = memberService.getById(order.getMemberId());
} else {
//自我评价商品时，获取当前登录用户信息
member = memberService.getUserInfo();
} }
//获取用户信息
Member member = memberService.getUserInfo();
//获取商品信息 //获取商品信息
GoodsSku goodsSku = goodsSkuService.getGoodsSkuByIdFromCache(memberEvaluationDTO.getSkuId()); GoodsSku goodsSku = goodsSkuService.getGoodsSkuByIdFromCache(memberEvaluationDTO.getSkuId());
//新增用户评价 //新增用户评价