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