using Cms.Core.Entity.vo;
using DG.Kafka;
using Microsoft.AspNetCore.Mvc;
using Serilog;

namespace Cms.Core.WebApi.Controllers
{
    public class QueueController : BaseController
    {
        public QueueController()
        {
        }
        [HttpPost("Send")]
        public async Task Send([FromBody] dynamic data)
        {
            var consumers = KafkaClient.GetConsumers();
            //await _kafkaProducer.ProduceAsync("crm-topic-2", data);
            KafkaClient.SendMessage(consumers[0], data);
        }

        /// <summary>
        /// 企业微信打标签接口
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        [HttpPost("WeworkTag")]
        public async Task WeworkTag([FromBody] WeWorkTagVo data)
        {
            var consumers = KafkaClient.GetConsumers();
            //await _kafkaProducer.ProduceAsync("crm-topic-2", data);
            KafkaClient.SendMessage(consumers[1], data);
        }
    }
}