| | |
|---|
| | | return new RabbitTemplate(connectionFactory); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // === 业绩树 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange onlineTransferExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ONLINE_TRANSFER.getExchange()); |
|---|
| | | public DirectExchange achieveTreeExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ACHIEVE_TREE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue onlineTransferQueue() { |
|---|
| | | return new Queue(QueueEnum.ONLINE_TRANSFER.getQueue()); |
|---|
| | | public Queue achieveTreeQueue() { |
|---|
| | | return new Queue(QueueEnum.ACHIEVE_TREE.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding defaultBind() { |
|---|
| | | return BindingBuilder.bind(onlineTransferQueue()).to(onlineTransferExchange()).with(QueueEnum.ONLINE_TRANSFER.getRoute()); |
|---|
| | | public Binding achieveTreeBind() { |
|---|
| | | return BindingBuilder.bind(achieveTreeQueue()).to(achieveTreeExchange()).with(QueueEnum.ACHIEVE_TREE.getRoute()); |
|---|
| | | } |
|---|
| | | // === 业绩树 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 提现手续费 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange withdrawFeeExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.WITHDRAW_FEE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public DirectExchange distribProfitExchange() { |
|---|
| | | public Queue withdrawFeeQueue() { |
|---|
| | | return new Queue(QueueEnum.WITHDRAW_FEE.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding withdrawFeeBind() { |
|---|
| | | return BindingBuilder.bind(withdrawFeeQueue()).to(withdrawFeeExchange()).with(QueueEnum.WITHDRAW_FEE.getRoute()); |
|---|
| | | } |
|---|
| | | // === 提现手续费 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // === tfc最新价 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange tfcNewPriceExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.TFC_NEW_PRICE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue tfcNewPriceQueue() { |
|---|
| | | return new Queue(QueueEnum.TFC_NEW_PRICE.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding tfcNewPriceBind() { |
|---|
| | | return BindingBuilder.bind(tfcNewPriceQueue()).to(tfcNewPriceExchange()).with(QueueEnum.TFC_NEW_PRICE.getRoute()); |
|---|
| | | } |
|---|
| | | // === tfc最新价 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 手续费分发 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange feeDistributeExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.DISTRIB_PROFIT.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue distribProfitQueue() { |
|---|
| | | public Queue feeDistributeQueue() { |
|---|
| | | return new Queue(QueueEnum.DISTRIB_PROFIT.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding distribProfitBind() { |
|---|
| | | return BindingBuilder.bind(distribProfitQueue()).to(distribProfitExchange()).with(QueueEnum.DISTRIB_PROFIT.getRoute()); |
|---|
| | | public Binding feeDistributeBind() { |
|---|
| | | return BindingBuilder.bind(feeDistributeQueue()).to(feeDistributeExchange()).with(QueueEnum.DISTRIB_PROFIT.getRoute()); |
|---|
| | | } |
|---|
| | | // === 手续费分发 end === |
|---|
| | | |
|---|
| | | // === 用户购买奖励 start === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 层级奖励分发 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange userBuyRewardExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.USER_BUY_REWARD.getExchange()); |
|---|
| | | public DirectExchange levelProfitExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.LEVEL_PROFIT.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue userBuyRewardQueue() { |
|---|
| | | return new Queue(QueueEnum.USER_BUY_REWARD.getQueue()); |
|---|
| | | public Queue levelProfitQueue() { |
|---|
| | | return new Queue(QueueEnum.LEVEL_PROFIT.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding userBuyRewardBind() { |
|---|
| | | return BindingBuilder.bind(userBuyRewardQueue()).to(userBuyRewardExchange()).with(QueueEnum.USER_BUY_REWARD.getRoute()); |
|---|
| | | public Binding levelProfitBind() { |
|---|
| | | return BindingBuilder.bind(levelProfitQueue()).to(levelProfitExchange()).with(QueueEnum.LEVEL_PROFIT.getRoute()); |
|---|
| | | } |
|---|
| | | // === 用户购买奖励 end === |
|---|
| | | // === 层级奖励分发 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === nft卡牌盲盒 start === |
|---|
| | | |
|---|
| | | // === 计算是否有人出局 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange nftBoxExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.NFT_BOX.getExchange()); |
|---|
| | | public DirectExchange memberOutExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.MEMBER_OUT.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue nftBoxQueue() { |
|---|
| | | return new Queue(QueueEnum.NFT_BOX.getQueue()); |
|---|
| | | public Queue memberOutQueue() { |
|---|
| | | return new Queue(QueueEnum.MEMBER_OUT.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding nftBoxBind() { |
|---|
| | | return BindingBuilder.bind(nftBoxQueue()).to(nftBoxExchange()).with(QueueEnum.NFT_BOX.getRoute()); |
|---|
| | | public Binding memberOutBind() { |
|---|
| | | return BindingBuilder.bind(memberOutQueue()).to(memberOutExchange()).with(QueueEnum.MEMBER_OUT.getRoute()); |
|---|
| | | } |
|---|
| | | // === nft卡牌盲盒 end === |
|---|
| | | // === 计算是否有人出局 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 转账拨币 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange bnbTransferExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.BNB_TRANSFER.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue bnbTransferQueue() { |
|---|
| | | return new Queue(QueueEnum.BNB_TRANSFER.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding bnbTransferBind() { |
|---|
| | | return BindingBuilder.bind(bnbTransferQueue()).to(bnbTransferExchange()).with(QueueEnum.BNB_TRANSFER.getRoute()); |
|---|
| | | } |
|---|
| | | // === 转账拨币 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 代理升级 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange agentUpExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.BNB_AGENT_UP.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue agentUpQueue() { |
|---|
| | | return new Queue(QueueEnum.BNB_AGENT_UP.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding agentUpBind() { |
|---|
| | | return BindingBuilder.bind(agentUpQueue()).to(agentUpExchange()).with(QueueEnum.BNB_AGENT_UP.getRoute()); |
|---|
| | | } |
|---|
| | | // === 代理升级 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // === 消息测试 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange bnbTransferTestExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.BNB_TRANSFER_TEST.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue bnbTransferTestQueue() { |
|---|
| | | return new Queue(QueueEnum.BNB_TRANSFER_TEST.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding bnbTransferTestBind() { |
|---|
| | | return BindingBuilder.bind(bnbTransferTestQueue()).to(bnbTransferTestExchange()).with(QueueEnum.BNB_TRANSFER_TEST.getRoute()); |
|---|
| | | } |
|---|
| | | // === 消息测试 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 入金的消息 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinInExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinInQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_IN.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinInBind() { |
|---|
| | | return BindingBuilder.bind(antACoinInQueue()).to(antACoinInExchange()).with(QueueEnum.ANT_A_CION_IN.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 入金的消息 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 入金,转入A底池 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinInAPoolExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN_A_POOL.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinInAPoolQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_IN_A_POOL.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinInAPoolBind() { |
|---|
| | | return BindingBuilder.bind(antACoinInAPoolQueue()).to(antACoinInAPoolExchange()).with(QueueEnum.ANT_A_CION_IN_A_POOL.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 入金,转入A底池 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 入金,转入B底池 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinInBPoolExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN_B_POOL.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinInBPoolQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_IN_B_POOL.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinInBPoolBind() { |
|---|
| | | return BindingBuilder.bind(antACoinInBPoolQueue()).to(antACoinInBPoolExchange()).with(QueueEnum.ANT_A_CION_IN_B_POOL.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 入金,转入B底池 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 入金,5%节点 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinInNodeExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN_NODE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinInNodeQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_IN_NODE.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinInNodeBind() { |
|---|
| | | return BindingBuilder.bind(antACoinInNodeQueue()).to(antACoinInNodeExchange()).with(QueueEnum.ANT_A_CION_IN_NODE.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 入金,5%节点 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 入金,极差奖 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinInLevelExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN_LEVEL.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinInLevelQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_IN_LEVEL.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinInLevelBind() { |
|---|
| | | return BindingBuilder.bind(antACoinInLevelQueue()).to(antACoinInLevelExchange()).with(QueueEnum.ANT_A_CION_IN_LEVEL.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 入金,极差奖 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 提现 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antACoinOutExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_A_CION_OUT.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antACoinOutQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_A_CION_OUT.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antACoinOutBind() { |
|---|
| | | return BindingBuilder.bind(antACoinOutQueue()).to(antACoinOutExchange()).with(QueueEnum.ANT_A_CION_OUT.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 提现 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A 会员升级 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antMemberLevelExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_MEMBER_LEVEL.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antMemberLevelQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_MEMBER_LEVEL.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antMemberLevelBind() { |
|---|
| | | return BindingBuilder.bind(antMemberLevelQueue()).to(antMemberLevelExchange()).with(QueueEnum.ANT_MEMBER_LEVEL.getRoute()); |
|---|
| | | } |
|---|
| | | // === A 会员升级 end === |
|---|
| | | |
|---|
| | | |
|---|
| | | // === A k线数据 start === |
|---|
| | | @Bean |
|---|
| | | public DirectExchange antKLineExchange() { |
|---|
| | | return new DirectExchange(QueueEnum.ANT_K_LINE.getExchange()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Queue antKLineQueue() { |
|---|
| | | return new Queue(QueueEnum.ANT_K_LINE.getQueue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Bean |
|---|
| | | public Binding antKLineBind() { |
|---|
| | | return BindingBuilder.bind(antKLineQueue()).to(antKLineExchange()).with(QueueEnum.ANT_K_LINE.getRoute()); |
|---|
| | | } |
|---|
| | | // === A k线数据 end === |
|---|
| | | } |
|---|
