| | |
| | | @RabbitListener(queues = QueueConstants.ORDER_RETURN_MONEY) |
| | | public void orderReturnMoney(String orderId) { |
| | | log.info("收到订单返利消息:{}", orderId); |
| | | |
| | | try { |
| | | memberProfitService.dynamicProfit(Long.parseLong(orderId)); |
| | | } catch (Exception e) { |
| | | log.error("订单返利异常:{}", e); |
| | | log.error("订单返利异常:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.MALL_COIN_DIRECT_REWARD) |
| | | public void directReward(Long directRewardId) { |
| | | log.info("消费补贴奖励、直推返利、分享奖励直推上级、分享奖励直推上级的直推、团队管理补贴消息:{}", directRewardId); |
| | | try { |
| | | agentService.directReward(directRewardId); |
| | | } catch (Exception e) { |
| | | log.error("消费奖励异常", e); |
| | | } |
| | | } |
| | | } |