From 7f7a1b01527843ffb178d015a044380acbde4fe2 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Tue, 02 Jul 2024 16:23:25 +0800 Subject: [PATCH] 逻辑 --- src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java | 96 +++++++++++++++++++++++++++-------------------- 1 files changed, 55 insertions(+), 41 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 2801643..b13b9e6 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java @@ -33,57 +33,71 @@ } - public void sendAchieveTreeMsg(Long id) { - log.info("发送业绩树消息:{}", id); - CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.ACHIEVE_TREE.getExchange(), QueueEnum.ACHIEVE_TREE.getRoute(), id, correlationData); - } - /** - * 消费者在tfc应用 - * - * @param data - */ - public void sendTfcFee(String data) { - log.info("发送提现手续费消息:{}", data); - 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); - } - - /** - * 推荐规则: - * 无直推奖励,推2个3层,3个6层,4个10层。1%见点奖(有效层级内,每个每1%),共10层,共%10。 + * 一、DAO成员静态: + * 质押PEOPLE(500枚起)静态每天1%。 + * 直推8% * @param id 流水ID */ - public void sendInvitePerkMsg(Long id) { - log.info("发送推荐规则奖励,流水ID:{}", id); + public void sendDirectPerkMsg(Long id) { + log.info("发送直推:{}", id); CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.TFC_INVITE_PERK.getExchange(), QueueEnum.TFC_INVITE_PERK.getRoute(), id, correlationData); + rabbitTemplate.convertAndSend(QueueEnum.FPD_MEMBER_DIRECT_PERK.getExchange(), QueueEnum.FPD_MEMBER_DIRECT_PERK.getRoute(), id, correlationData); } + + /** + * 二、DAO成员动态: + * 1.直推1个拿2代,直推10个拿20代,直推15个拿30代,最高30代 + * 2. 1-5代奖励7% + * 6-10代奖励6% + * 11-15代奖励5% + * 15-20代奖励4% + * 21-25代奖励4% + * 26-30代奖励7% + * @param id 流水ID + */ + public void sendMemberDynamicPerkMsg(Long id) { + log.info("发送DAO成员动态,流水ID:{}", id); + CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); + rabbitTemplate.convertAndSend(QueueEnum.FPD_MEMBER_DYNAMIC_PERK.getExchange(), QueueEnum.FPD_MEMBER_DYNAMIC_PERK.getRoute(), id, correlationData); + } + + /** + * 六、永动补偿池2% + * 五、DAO永动激励池:6% + * 四、DAO联盟委员会 : 5% (50名全球DAO委员) + * @param id 流水ID + */ public void sendNodePerkMsg(Long id) { - log.info("发送节点投资,流水ID:{}", id); + log.info("发送DAO节点,激励,补偿,流水ID:{}", id); CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.TFC_NODE_PERK.getExchange(), QueueEnum.TFC_NODE_PERK.getRoute(), id, correlationData); + rabbitTemplate.convertAndSend(QueueEnum.FPD_NODE_JILI_BUCHANG_PERK.getExchange(), QueueEnum.FPD_NODE_JILI_BUCHANG_PERK.getRoute(), id, correlationData); } - public void sendNodeMsg(Long id) { - log.info("发送复投:{}", id); + + /** + * + * 3. DAO成员团队奖:5%加权分红(people数量) + * DAO1:小区业绩30万/币 加权分红50% + * DAO2:小区业绩100万/币 加权分红30% + * DAO3:小区业绩500万/币加权分红20% + */ + public void sendTeamPerk(Long id) { + log.info("发送成员团队奖5%,流水ID:{}", id); CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.TFC_NODE_AGAIN.getExchange(), QueueEnum.TFC_NODE_AGAIN.getRoute(), id, correlationData); + rabbitTemplate.convertAndSend(QueueEnum.FPD_TEAM_PERK.getExchange(), QueueEnum.FPD_TEAM_PERK.getRoute(), id, correlationData); } - public void sendNodeMsgLong(Long id) { - log.info("发送复投原本数据:{}", id); + + /** + * + * 3. 成员升级 + * DAO1:小区业绩30万/币 加权分红50% + * DAO2:小区业绩100万/币 加权分红30% + * DAO3:小区业绩500万/币加权分红20% + */ + public void sendMemberLevel(Long id) { + log.info("发送成员升级,会员ID:{}", id); CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.TFC_NODE_AGAIN_LONG.getExchange(), QueueEnum.TFC_NODE_AGAIN_LONG.getRoute(), id, correlationData); + rabbitTemplate.convertAndSend(QueueEnum.FPD_TEAM_PERK.getExchange(), QueueEnum.FPD_TEAM_PERK.getRoute(), id, correlationData); } + } -- Gitblit v1.9.1