| | |
| | | package cc.mrbird.febs.rabbit.consumer; |
| | | |
| | | import cc.mrbird.febs.mall.service.HappyActivityService; |
| | | import cc.mrbird.febs.mall.service.IAgentService; |
| | | import cc.mrbird.febs.mall.service.IApiMallOrderInfoService; |
| | | import cc.mrbird.febs.mall.service.IMemberProfitService; |
| | |
| | | private IAgentService agentService; |
| | | @Autowired |
| | | private IMemberProfitService memberProfitService; |
| | | @Autowired |
| | | private HappyActivityService happyActivityService; |
| | | |
| | | @RabbitListener(queues = QueueConstants.QUEUE_DEFAULT) |
| | | public void agentReturn(Message message, Channel channel) { |
| | |
| | | log.error("会员升级消息异常", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.ACTIVITY_ORDER_ITEM_CHECK) |
| | | public void checkActivityItem(Long orderId) { |
| | | log.info("收到核销活动门票:{}", orderId); |
| | | try { |
| | | happyActivityService.checkActivityItem(orderId); |
| | | } catch (Exception e) { |
| | | log.error("核销活动门票异常", e); |
| | | } |
| | | } |
| | | } |