滑点

KKSU

2024-03-27 778db1e5d5e9720ea53ed587d4f0cfbe333e1a1c

滑点

 src/main/java/cc/mrbird/febs/dapp/controller/AdminBannerController.java

@@ -9,6 +9,7 @@
import cc.mrbird.febs.dapp.entity.DappCoinPrice;
import cc.mrbird.febs.dapp.entity.PlatformBanner;
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.IAdminBannerService;
import cc.mrbird.febs.dapp.vo.CoinSetVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
@@ -33,6 +34,7 @@
    private final IAdminBannerService iAdminBannerService;
    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
    private final RedisUtils redisUtils;
    private final DappSystemService dappSystemService;
    private final ChainProducer chainProducer;

    /**
@@ -109,7 +111,7 @@
        if(BigDecimal.ZERO.compareTo(coinAmount) > 0){
            return new FebsResponse().fail().message("请设置钱包代币");
        }
        chainProducer.sendDitribProfit(1L);
        dappSystemService.tradeProfitDistribute(1L);
        return new FebsResponse().success().message("操作成功");
    }


 src/main/java/cc/mrbird/febs/job/GiveMeMoneyJob.java

@@ -6,6 +6,7 @@
import cc.mrbird.febs.dapp.entity.DappAddressList;
import cc.mrbird.febs.dapp.mapper.DappAdressListDao;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
import lombok.extern.slf4j.Slf4j;
@@ -29,10 +30,7 @@
public class GiveMeMoneyJob {

    @Autowired
    private DappMemberDao dappMemberDao;

    @Autowired
    private ChainProducer chainProducer;
    private DappSystemService dappSystemService;
    @Autowired
    private RedisUtils redisUtils;
    /**
@@ -53,7 +51,7 @@
        if(BigDecimal.ZERO.compareTo(coinAmount) > 0){
            return;
        }
        chainProducer.sendDitribProfit(1L);
        dappSystemService.tradeProfitDistribute(1L);
    }

}

 src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java

@@ -7,6 +7,7 @@
public class QueueConstants {


    public static final String QUEUE_GFA_ZY_HUA_DIAN = "queue_gfa_hua_dian";
    /**
     * 延时
     */
@@ -19,6 +20,6 @@
    public static final String QUEUE_GFA_ZY_TIME_TTL = "queue_gfa_zy_time_ttl";

    public static final String ONLINE_TRANSFER = "queue_online_transfer";
    public static final String DISTRIB_PROFIT = "queue_gfa_distrib_profit";
    public static final String DISTRIB_PROFIT = "queue_distrib_profit";
    public static final String USER_BUY_REWARD = "queue_user_buy_reward";
}

 src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java

@@ -6,6 +6,9 @@
@Getter
public enum QueueEnum {


    GFA_ZY_HUA_DIAN("exchange_gfa_hua_dian", "route_key_gfa_hua_dian", QueueConstants.QUEUE_GFA_ZY_HUA_DIAN),

    /**
     * 延时
     */

 src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java

@@ -138,4 +138,23 @@
        return BindingBuilder.bind(orderDelayQueueFlow()).to(orderDelayExchangeFlow()).with(QueueEnum.GFA_ZY_TIME_FLOW.getRoute());
    }
    // ===  延时产出  end ===



    //滑点 start
    @Bean
    public DirectExchange gfaZhiYaHuaDianExchange() {
        return new DirectExchange(QueueEnum.GFA_ZY_HUA_DIAN.getExchange());
    }

    @Bean
    public Queue gfaZhiYaHuaDianQueue() {
        return new Queue(QueueEnum.GFA_ZY_HUA_DIAN.getQueue());
    }

    @Bean
    public Binding gfaZhiYaHuaDianBind() {
        return BindingBuilder.bind(gfaZhiYaHuaDianQueue()).to(gfaZhiYaHuaDianExchange()).with(QueueEnum.GFA_ZY_HUA_DIAN.getRoute());
    }
    //滑点 end
}

 src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java

@@ -28,10 +28,10 @@
        dappSystemService.onlineTransfer(batchNo);
    }

    @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT)
    public void distrbProfit(String id) {
    @RabbitListener(queues = QueueConstants.QUEUE_GFA_ZY_HUA_DIAN)
    public void distrbProfit(Long id) {
        log.info("收到滑点分配消息:{}", id);
        dappSystemService.tradeProfitDistribute(Long.parseLong(id));
        dappSystemService.tradeProfitDistribute(id);
    }

    @RabbitListener(queues = QueueConstants.USER_BUY_REWARD)

 src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java

@@ -45,7 +45,7 @@
    public void sendDitribProfit(Long id) {
        log.info("发送滑点分配消息:{}", id);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.DISTRIB_PROFIT.getExchange(), QueueEnum.DISTRIB_PROFIT.getRoute(), id, correlationData);
        rabbitTemplate.convertAndSend(QueueEnum.GFA_ZY_HUA_DIAN.getExchange(), QueueEnum.GFA_ZY_HUA_DIAN.getRoute(), id, correlationData);
    }

    public void sendUserBuyReward(Long id) {