From ef506d591338c4e1deabede781550cf2e0156f3f Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Wed, 09 Nov 2022 23:46:18 +0800 Subject: [PATCH] 增加每日返利,提现逻辑修改,手续费分发逻辑 --- src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java | 11 +++++++++++ 1 files changed, 11 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java index fcae1bf..c6483d3 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java @@ -49,4 +49,15 @@ CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); rabbitTemplate.convertAndSend(QueueEnum.WITHDRAW_FEE.getExchange(), QueueEnum.WITHDRAW_FEE.getRoute(), data, correlationData); } + + /** + * 发送手续费分发消息 + * + * @param id + */ + public void sendFeeDistributeMsg(Long id) { + log.info("发送手续费分发消息:{}", id); + CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); + rabbitTemplate.convertAndSend(QueueEnum.DISTRIB_PROFIT.getExchange(), QueueEnum.DISTRIB_PROFIT.getRoute(), id, correlationData); + } } -- Gitblit v1.9.1