Cms.Core/Cms.Core.WebApi/Controllers/QueueController.cs

35 lines
994 B
C#

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);
}
}
}