package com.topdraw.config;

import lombok.Data;
import org.apache.commons.lang3.StringUtils;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Lazy;

import java.util.Map;
import java.util.Objects;

/**
 * @author ：
 * @description：
 * @function :
 * @date ：Created in 2022/5/12 12:37
 * @version: ：
 * @modified By：
 * @since : modified in 2022/5/12 12:37
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.rabbitmq", ignoreInvalidFields = true)
public class RabbitMqConfig {

    @Lazy
    private Map<String, String> uce;
    @Lazy
    private Map<String, String> memberInfo;
    @Lazy
    private Map<String, String> eventBus;
    @Lazy
    private Map<String, String> event;
    @Lazy
    private Map<String, String> viewRecord;
    @Lazy
    private Map<String, String> addCollction;
    @Lazy
    private Map<String, String> deleteCollction;
    @Lazy
    private Map<String, String> deleteAllCollction;
    @Lazy
    private Map<String, String> ucgCollection;
    @Lazy
    private Map<String, String> wechat;
    @Lazy
    private Map<String, String> growthReport;

    /**
     * uce
     * @return
     */
    public String getGrowthReportQueue() {
        if (Objects.isNull(growthReport)) {
            return "growthReport.queue";
        }
        String queue = this.growthReport.get("queue");
        return StringUtils.isBlank(queue) ? "growthReport.queue" : queue;
    }

    /**
     * uce
     * @return
     */
    public String getUceQueue() {
        if (Objects.isNull(uce)) {
            return "uce.queue";
        }
        String queue = this.uce.get("queue");
        return StringUtils.isBlank(queue) ? "uce.queue" : queue;
    }

    /**
     * memberInfo
     * @return
     */
    public String getMemberInfoQueue() {
        if (Objects.isNull(memberInfo)) {
            return "queue.MemberInfoSync";
        }
        String queue = this.memberInfo.get("queue");
        return StringUtils.isBlank(queue) ? "queue.MemberInfoSync" : queue;
    }

    /**
     * uce
     * @return
     */
    public String getEventBusQueue() {
        if (Objects.isNull(eventBus)) {
            return "uc.eventbus";
        }
        String queue = this.eventBus.get("queue");
        return StringUtils.isBlank(queue) ? "uc.eventbus" : queue;
    }

    /**
     * uce
     * @return
     */
    public String getUcgEventQueue() {
        if (event != null) {
            String queue = this.event.get("queue");
            return StringUtils.isBlank(queue) ? "event.queue" : queue;
        }
        return "event.queue";
    }

    /**
     * memberInfo
     * @return
     */
    public String getViewRecordQueue() {
        if (viewRecord != null) {
            String queue = this.viewRecord.get("queue");
            return StringUtils.isBlank(queue) ? "viewRecord.queue" : queue;
        }
        return "viewRecord.queue";
    }

    /**
     * uce
     * @return
     */
    public String getUcgCollectionQueueAdd() {
        if (addCollction != null) {
            String queue = this.addCollction.get("queue");
            return StringUtils.isBlank(queue) ? "queue.collection.add" : queue;
        }
        return "queue.collection.add";
    }

    /**
     * memberInfo
     * @return
     */
    public String getUcgCollectionQueueDelete() {
        if (deleteCollction != null) {
            String queue = this.deleteCollction.get("queue");
            return StringUtils.isBlank(queue) ? "queue.collection.delete" : queue;
        }
        return "queue.collection.delete";
    }

    /**
     * uce
     * @return
     */
    public String getUcgCollectionQueueDeleteAll() {
        if (deleteAllCollction != null) {
            String queue = this.deleteAllCollction.get("queue");
            return StringUtils.isBlank(queue) ? "queue.collection.deleteall" : queue;
        }
        return "queue.collection.deleteall";
    }


    public String getUcgCollectionQueue() {
        if (ucgCollection != null) {
            String queue = this.ucgCollection.get("queue");
            return StringUtils.isBlank(queue) ? "collection.queue" : queue;
        }
        return "collection.queue";
    }

    /**
     * memberInfo
     * @return
     */
    public String getWechatQueue() {
        if (wechat != null) {
            String queue = this.wechat.get("queue");
            return StringUtils.isBlank(queue) ? "weixin.subOrUnSub.queue" : queue;
        }
        return "weixin.subOrUnSub.queue";
    }
}