feat(mall): 实现 USDT 充值功能

KKSU

2025-02-12 1bb96bab1185f2e1aa2f468266512ee0beb83286

 src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java

@@ -47,4 +47,30 @@
    }


    /**
     * 充值成功
     */
    @RabbitListener(queues = QueueConstants.RUN_VIP_OPERATION_CHARGE_BALANCE)
    public void chargeSuccessMsg(Long chargeId) {
        try {
            agentService.chargeSuccessMsg(chargeId);
        } catch (Exception e) {
            log.error("消费充值异常", e);
        }
    }


    /**
     * 节点升级
     */
    @RabbitListener(queues = QueueConstants.RUN_VIP_NODE_UP)
    public void nodeUpMsg(Long memberId) {
        try {
            agentService.nodeUpMsg(memberId);
        } catch (Exception e) {
            log.error("消费节点升级异常", e);
        }
    }


}