增加会员升级日志打印

KKSU

2024-09-10 f52cfc92db48d9a215d7f728ce4000de1cdd6ae2

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

@@ -143,4 +143,108 @@
    }
    //补贴金额 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

}