35 lines
994 B
C#
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);
|
|
}
|
|
}
|
|
}
|