package com.ibeetl.admin.console.rabbitmq;

import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.json.JSONUtil;
import com.ibeetl.admin.console.service.RedisService;
import com.ibeetl.admin.core.util.enums.CoreDictType;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;


@Component
@Slf4j
public class MqUtil {

    @Autowired
    private AmqpTemplate amqpTemplate;

    @Autowired
    RedisService redisUtil;

    /**
     * 发送队列
     * @param queueName
     * @param t 队列KEY
     * @param <T> 对象
     */
    public <T> void send(String queueName,T t) {
        String s = JSONUtil.toJsonStr(t);
        String uuid = IdUtil.fastSimpleUUID()+RandomUtil.randomNumbers(16);
        redisUtil.set(CoreDictType.REDIS_LOG_KEY+uuid,queueName);
        Message message = MessageBuilder.withBody(s.getBytes())
                .setContentType(MessageProperties.CONTENT_TYPE_JSON).setContentEncoding("utf-8")
                .setMessageId(uuid).build();
        try {
            amqpTemplate.convertAndSend(queueName,message);
            log.info("发送队列：【{}】成功",queueName);
        } catch (AmqpException e) {
            redisUtil.remove(CoreDictType.REDIS_LOG_KEY+uuid);
            log.error("发送队列失败:"+queueName,e);
        }
    }


}