| 
					
				 | 
			
			
				@@ -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); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 } 
			 |