数据修改

xiaoyong931011

2023-08-10 18b681e553980b20bc9b5b3a113167f33b83a7b3

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

@@ -50,10 +50,31 @@
     * speed 代理升级
     * @param memberId
     */
    public void sendAutoLevelUpTeamMsg(@NotNull Long memberId) {
        log.info("sendAutoLevelUpTeamMsg:{}", memberId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.SPEED_LEVEL_UP_TEAM.getExchange(), QueueEnum.SPEED_LEVEL_UP_TEAM.getRoute(), memberId, correlationData);
    }


    /**
     * speed 代理升级
     * @param memberId
     */
    public void sendAutoLevelUpMsg(@NotNull Long memberId) {
        log.info("sendAutoLevelUpMsg:{}", memberId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.SPEED_LEVEL_UP.getExchange(), QueueEnum.SPEED_LEVEL_UP.getRoute(), memberId, correlationData);
    }


    /**
     * speed 直推返利
     */
    public void sendDirectPerkMsg(@NotNull Long memberId) {
        log.info("sendDirectPerkMsg:{}", memberId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.SPEED_DIRECT_PERK.getExchange(), QueueEnum.SPEED_DIRECT_PERK.getRoute(), memberId, correlationData);
    }

}