|
@@ -2,10 +2,12 @@ package cn.newfeifan.mall.module.distri.mq.consumer.topupconsumptionpoints;
|
|
|
|
|
|
import cn.newfeifan.mall.module.distri.service.usertopupconsumptionpointsorder.UserTopUpConsumptionPointsOrderService;
|
|
|
import cn.newfeifan.mall.module.pay.dal.dataobject.order.PayOrderDO;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.context.event.EventListener;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
|
+@Slf4j
|
|
|
public class TopUpConsumptionPointsConsumer {
|
|
|
|
|
|
@Resource
|
|
@@ -14,6 +16,7 @@ public class TopUpConsumptionPointsConsumer {
|
|
|
@EventListener
|
|
|
public void onMessage(PayOrderDO payOrderDO) {
|
|
|
//修改订单状态,并计算权益
|
|
|
+ log.info("app消费者开始消费:对象:{}",payOrderDO);
|
|
|
userTopUpConsumptionPointsOrderService.topUpConsumptionPoints(payOrderDO);
|
|
|
}
|
|
|
}
|