20221117

xiaoyong931011

2022-11-21 5d1fc41db9c48ca7e4beffdfeb789fd6f69f4d2f

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

@@ -1,5 +1,6 @@
package cc.mrbird.febs.rabbit.producer;

import cc.mrbird.febs.rabbit.QueueEnum;
import cc.mrbird.febs.rabbit.RabbitMqConfig;
import cn.hutool.core.util.IdUtil;
import lombok.extern.slf4j.Slf4j;
@@ -7,6 +8,8 @@
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.UUID;

/**
 * @author wzy
@@ -24,6 +27,18 @@
        rabbitTemplate.setConfirmCallback(this);
    }

    public void sendMemberCoinInside(Long withdrawId) {
        log.info("发送用户内部转账的消息:{}", withdrawId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(RabbitMqConfig.MEMBER_COIN_INSIDE_EXCHANGE, RabbitMqConfig.MEMBER_COIN_INSIDE__ROUTE_KEY, withdrawId, correlationData);
    }

    public void sendOnHookEnd(Long orderId) {
        log.info("发送用户结束挂机的消息:{}", orderId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(RabbitMqConfig.END_ON_HOOK_EXCHANGE, RabbitMqConfig.END_ON_HOOK_ROUTE_KEY, orderId, correlationData);
    }

    public void sendMsg(String content) {
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_USDT_UPDATE, RabbitMqConfig.ROUTING_KEY_USDT_UPDATE, content, correlationData);