线上业务优化之案例实战 - ToB企服应用市场:ToB评测及商务社交产业平台

@Transactional(rollbackFor = Exception.class)
public void doUnPaidTask(Long orderId) {
// 1. 查询订单是否存在
Order order = orderService.getById(orderId);
，，，
// 2. 更新订单为已取消状态
order.setOrderStatus((byte) OrderStatusEnum.ORDER_CLOSED_BY_EXPIRED.getOrderStatus());
orderService.updateById(order);
...
// 3. 订单商品数量增加
LambdaQueryWrapper<OrderItem> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(OrderItem::getOrderId， orderId);
List<OrderItem> orderItems = orderItemService.list(queryWrapper);
for (OrderItem orderItem : orderItems) {
Long goodsId = orderItem.getGoodsId();
Integer goodsCount = orderItem.getGoodsCount();
if (!goodsDao.addStock(goodsId， goodsCount)) {
throw new BusinessException("秒杀商品货品库存增加失败");
}
}
// 4. 返还用户优惠券
couponService.releaseCoupon(orderId);
log.info("---------------订单orderId:{}，未支付超时取消成功"， orderId);
}

复制代码

@Resource
private PlatformTransactionManager platformTransactionManager;
@Resource
private TransactionDefinition transactionDefinition;
public void doUnPaidTask(Long orderId) {
// 启用编程式事务
// 1. 在开启事务钱查询订单是否存在
Order order = orderService.getById(orderId);
...
// 2. 开启事务
TransactionStatus transaction = platformTransactionManager.getTransaction(transactionDefinition);
try {
// 3. 设置订单为已取消状态
order.setOrderStatus((byte) OrderStatusEnum.ORDER_CLOSED_BY_EXPIRED.getOrderStatus());
orderService.updateById(order);
...
// 4. 商品货品数量增加
LambdaQueryWrapper<OrderItem> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(OrderItem::getOrderId， orderId);
List<OrderItem> orderItems = orderItemService.list(queryWrapper);
for (OrderItem orderItem : orderItems) {
Long goodsId = orderItem.getGoodsId();
Integer goodsCount = orderItem.getGoodsCount();
if (!goodsDao.addStock(goodsId， goodsCount)) {
throw new BusinessException("秒杀商品货品库存增加失败");
}
}
// 5. 返还优惠券
couponService.releaseCoupon(orderId);
// 6. 所有更新操作完成后，提交事务
platformTransactionManager.commit(transaction);
log.info("---------------订单orderId:{}，未支付超时取消成功"， orderId);
} catch (Exception e) {
log.info("---------------订单orderId:{}，未支付超时取消失败"， orderId， e);
// 7. 发生异常，回滚事务
platformTransactionManager.rollback(transaction);
}
}

复制代码