|
@@ -3,7 +3,6 @@ package cn.newfeifan.mall.module.trade.mq.consumer.order;
|
|
|
import cn.newfeifan.mall.module.trade.service.order.TradeOrderUpdateService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.context.event.EventListener;
|
|
|
-import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
@@ -16,7 +15,6 @@ public class OrderConsumer {
|
|
|
private TradeOrderUpdateService tradeOrderUpdateService;
|
|
|
|
|
|
@EventListener
|
|
|
- @Async // Spring Event 默认在 Producer 发送的线程,通过 @Async 实现异步
|
|
|
public void onMessage(Long payOrderId) {
|
|
|
//修改订单状态,并计算权益
|
|
|
tradeOrderUpdateService.updateOrderPaid(payOrderId);
|