| | |
| | | |
| | | import cc.mrbird.febs.mall.service.IAgentService; |
| | | import cc.mrbird.febs.mall.service.IApiMallOrderInfoService; |
| | | import cc.mrbird.febs.mall.service.IMatrixTreeNodeService; |
| | | import cc.mrbird.febs.mall.service.IMemberProfitService; |
| | | import cc.mrbird.febs.rabbit.constants.QueueConstants; |
| | | import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum; |
| | |
| | | * @date 2021-09-25 |
| | | **/ |
| | | @Slf4j |
| | | //@Component |
| | | @Component |
| | | public class AgentConsumer { |
| | | |
| | | @Autowired |
| | |
| | | private IAgentService agentService; |
| | | @Autowired |
| | | private IMemberProfitService memberProfitService; |
| | | |
| | | @Autowired |
| | | private IMatrixTreeNodeService matrixTreeNodeService; |
| | | |
| | | @RabbitListener(queues = "meye_queue_order_delay") |
| | | public void orderCancelDelay(String id) { |
| | |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.ORDER_BONUS) |
| | | public void calOrderBonus(String orderId) { |
| | | log.info("收到订单分红消息:{}", orderId); |
| | | try { |
| | | memberProfitService.orderBonus(Long.parseLong(orderId)); |
| | | } catch (Exception e) { |
| | | log.error("订单分红消息异常:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.MATRIX_TREE) |
| | | public void matrixTree(Long memberId) { |
| | | log.info("矩阵节点消息:{}", memberId); |
| | | matrixTreeNodeService.addTreeNode(memberId); |
| | | } |
| | | |
| | | } |