package com.topdraw.mq.consumer;

import com.topdraw.config.RabbitMqConfig;
import com.topdraw.mq.domain.DataSyncMsg;
import com.topdraw.resttemplate.RestTemplateClient;
import com.topdraw.util.JSONUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;

@Component
@Slf4j
public class UcGatewayIptv2IptvConsumer {

    @Autowired
    RestTemplateClient restTemplateClient;

    @Autowired
    AutoRoute autoUser;

    /**
     * 事件
     * @param content
     * @description 基础数据同步
     * @author Hongyan Wang
     * @date 2021/9/7 11:26 上午
     */
    @RabbitHandler
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue(value = RabbitMqConfig.GATEWAY_TO_SERVICE_DIRECT),
                    exchange = @Exchange(value = ExchangeTypes.DIRECT))
    }, containerFactory = "managementRabbitListenerContainerFactory")
    public void ucEventConsumer(String content) {
        log.info(" receive dataSync msg , content is : {} ", content);
        DataSyncMsg dataSyncMsg = this.parseContent(content);
        this.taskDeal(dataSyncMsg);
        log.info("ucEventConsumer ====>>>> end");
    }

    /**
     * 数据解析
     * @param content
     * @return
     */
    private DataSyncMsg parseContent(String content) {
        DataSyncMsg dataSyncMsg = JSONUtil.parseMsg2Object(content,DataSyncMsg.class);
        Assert.notNull(dataSyncMsg,"ERROR -->> operationConsumer -->> parseContent -->> 【dataSyncMsg】 not be null !!");
        DataSyncMsg.MsgData msgData = dataSyncMsg.getMsg();
        Assert.notNull(msgData,"ERROR -->> operationConsumer -->> parseContent -->> 【msgData】 not be null !!");
        return dataSyncMsg;
    }

    /**
     * 任务处理
     * @param dataSyncMsg
     */
    private void taskDeal(DataSyncMsg dataSyncMsg) {
        this.restTemplateClient.dealTask(dataSyncMsg);
    }
}