增加会员升级日志打印

KKSU

2024-09-10 f52cfc92db48d9a215d7f728ce4000de1cdd6ae2

 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java

@@ -91,4 +91,160 @@
        return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
    }

    @Bean
    public DirectExchange agentReturnMoneyExchange() {
        return new DirectExchange(RabbitQueueEnum.AGENT_REUTRN_MONEY.getExchange());
    }

    @Bean
    public Queue agentReturnMoneyQueue() {
        return new Queue(QueueConstants.AGENT_RETURN_MONEY);
    }

    @Bean
    public Binding agentReturnMoneyBind() {
        return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.AGENT_REUTRN_MONEY.getRoute());
    }


    @Bean
    public DirectExchange orderReturnMoneyExchange() {
        return new DirectExchange(RabbitQueueEnum.ORDER_RETURN_MONEY.getExchange());
    }

    @Bean
    public Queue orderReturnMoneyQueue() {
        return new Queue(QueueConstants.ORDER_RETURN_MONEY);
    }

    @Bean
    public Binding orderReturnMoneyBind() {
        return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute());
    }

    /**
     * 补贴金额
     * @return
     */
    //补贴金额 start
    @Bean
    public DirectExchange perkMoneyExchange() {
        return new DirectExchange(RabbitQueueEnum.PERK_MONEY.getExchange());
    }

    @Bean
    public Queue perkMoneyQueue() {
        return new Queue(QueueConstants.PERK_MONEY);
    }

    @Bean
    public Binding perkMoneyBind() {
        return BindingBuilder.bind(perkMoneyQueue()).to(perkMoneyExchange()).with(RabbitQueueEnum.PERK_MONEY.getRoute());
    }
    //补贴金额 end

    /**
     * 强制卖出
     * @return
     */
    //强制卖出 start
    @Bean
    public DirectExchange forceVoucherSaleExchange() {
        return new DirectExchange(RabbitQueueEnum.FORCE_VOUCHER_SALE.getExchange());
    }

    @Bean
    public Queue forceVoucherSaleQueue() {
        return new Queue(QueueConstants.FORCE_VOUCHER_SALE);
    }

    @Bean
    public Binding forceVoucherSaleBind() {
        return BindingBuilder.bind(forceVoucherSaleQueue()).to(forceVoucherSaleExchange()).with(RabbitQueueEnum.FORCE_VOUCHER_SALE.getRoute());
    }
    //强制卖出 end

    // === 机器人自动抢红包 延时  start ===
    @Bean
    public DirectExchange buyTimeDelayTtlExchange() {
        return new DirectExchange(RabbitQueueEnum.FCMPAY_BUY_TIME_TTL.getExchange());
    }
    @Bean
    public Binding buyTimeDelayBindTtl() {
        return BindingBuilder.bind(buyTimeDelayQueueTtl()).to(buyTimeDelayTtlExchange()).with(RabbitQueueEnum.FCMPAY_BUY_TIME_TTL.getRoute());
    }
    @Bean
    public Queue buyTimeDelayQueueTtl() {
        return QueueBuilder.durable(RabbitQueueEnum.FCMPAY_BUY_TIME_TTL.getQueue())
                //到期后转发的交换机
                .withArgument("x-dead-letter-exchange", RabbitQueueEnum.FCMPAY_BUY_TIME.getExchange())
                //到期后转发的路由键
                .withArgument("x-dead-letter-routing-key", RabbitQueueEnum.FCMPAY_BUY_TIME.getRoute())
                .build();
    }
    @Bean
    public DirectExchange buyTimeDelayExchange() {
        return new DirectExchange(RabbitQueueEnum.FCMPAY_BUY_TIME.getExchange());
    }
    @Bean
    public Queue buyTimeDelayQueue() {
        return new Queue(RabbitQueueEnum.FCMPAY_BUY_TIME.getQueue());
    }
    @Bean
    public Binding buyTimeDelayBind() {
        return BindingBuilder.bind(buyTimeDelayQueue()).to(buyTimeDelayExchange()).with(RabbitQueueEnum.FCMPAY_BUY_TIME.getRoute());
    }
    // === 机器人自动抢红包 延时  end ===

    //强制卖出 start
    @Bean
    public DirectExchange fcmNFTExchangeExchange() {
        return new DirectExchange(RabbitQueueEnum.FCMPAY_FCM_NFT_EXCHANGE.getExchange());
    }

    @Bean
    public Queue fcmNFTExchangeQueue() {
        return new Queue(RabbitQueueEnum.FCMPAY_FCM_NFT_EXCHANGE.getQueue());
    }

    @Bean
    public Binding fcmNFTExchangeBind() {
        return BindingBuilder.bind(fcmNFTExchangeQueue()).to(fcmNFTExchangeExchange()).with(RabbitQueueEnum.FCMPAY_FCM_NFT_EXCHANGE.getRoute());
    }
    //强制卖出 end

    //卖单用户确认 start
    @Bean
    public DirectExchange fcmOrderSellInsureExchange() {
        return new DirectExchange(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getExchange());
    }

    @Bean
    public Queue fcmOrderSellInsureQueue() {
        return new Queue(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getQueue());
    }

    @Bean
    public Binding fcmOrderSellInsureBind() {
        return BindingBuilder.bind(fcmOrderSellInsureQueue()).to(fcmOrderSellInsureExchange()).with(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getRoute());
    }
    //卖单用户确认 end

    //买单取消 start
    @Bean
    public DirectExchange fcmOrderBuyCancelExchange() {
        return new DirectExchange(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getExchange());
    }

    @Bean
    public Queue fcmOrderBuyCancelQueue() {
        return new Queue(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getQueue());
    }

    @Bean
    public Binding fcmOrderBuyCancelBind() {
        return BindingBuilder.bind(fcmOrderBuyCancelQueue()).to(fcmOrderBuyCancelExchange()).with(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getRoute());
    }
    //买单取消 end

}