package com.topdraw.mq.consumer;

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

@Component
@Slf4j
public class UcEngineManageConsumer {

    private static final Logger LOG = LoggerFactory.getLogger(UcEngineManageConsumer.class);

    @Autowired
    AutoRoute autoUser;

    /**
     * @param content
     * @description 基础数据同步
     * @author Hongyan Wang
     * @date 2021/9/7 11:26 上午
     */
    /*@RabbitHandler
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue(value = RabbitMqConfig.UC_ROUTE_KEY_DIRECT_EVENT_CCC),
                    exchange = @Exchange(value = ExchangeTypes.DIRECT))
    }, containerFactory = "managementRabbitListenerContainerFactory")
    public void memberServiceFanoutConsumer(String content) {
        try {
            log.info(" receive dataSync msg , content is : {} ", content);
            TableOperationMsg dataSyncMsg = JSONUtil.parseMsg2Object(content, TableOperationMsg.class);
            autoUser.route(dataSyncMsg);
            LOG.info("memberServiceFanoutConsumer ====>>>> "+dataSyncMsg);
        } catch (Exception e) {
            log.error(" LocalDataSyncMsg || msg：{} || error：{} ", content, e.getMessage());
        }
    }*/
}