package com.tianbo.analysis.service.imp;

import com.tianbo.analysis.service.MQ;
import com.tianbo.util.RabitMq.exchange.ExSendMsg;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class MQImpl implements MQ {

    //回执读取目录
    @Value("${mq.connection.ip}")
    private  String mqIp;

    @Value("${mq.connection.port}")
    private  int mqPort;

    @Value("${mq.connection.vHost}")
    private  String mqVhost;

    @Value("${mq.connection.username}")
    private  String mqUsername;

    @Value("${mq.connection.password}")
    private  String mqPassword;

    @Value("${mq.queue.send-to-mq}")
    private String queueName;

    @Value("${mq.exchange.name}")
    private String exchangeName;

    @Value("${mq.exchange.type}")
    private String exchangeType;

    @Value("${mq.exchange.routing-key}")
    private String routingName;

    @Value("${mq.needSend}")
    private boolean mqNeedSend;

    @Override
    public boolean send(String message) {
        try{
            if (mqNeedSend){
                boolean mqSendResult = ExSendMsg.sendMsg(
                        exchangeName,
                        exchangeType,
                        routingName,
                        queueName,
                        message,
                        mqIp,
                        mqPort,
                        mqVhost,
                        mqUsername,
                        mqPassword
                );
                if (mqSendResult){
                    log.info("转发到MQ成功");
                }else{
                    log.info("转发到MQ失败");
                }

                return mqSendResult;
            }
            return false;

        } catch (Exception e){
            log.error("mq读写失败",e);
            return false;
        }
    }

    @Override
    public void get() {

    }
}