43 lines
1.0 KiB
C#
43 lines
1.0 KiB
C#
using Cloud.Requests;
|
|
using Cloud.Services;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using System.ComponentModel.DataAnnotations;
|
|
using System.Text.Json;
|
|
|
|
namespace Cloud.Controllers
|
|
{
|
|
[Authorize]
|
|
[ApiController]
|
|
[Route("api")]
|
|
public class ValveController : ControllerBase
|
|
{
|
|
//Контроллер вентиля
|
|
|
|
private readonly ProducerService _producerService;
|
|
|
|
public ValveController(ProducerService producerService)
|
|
{
|
|
_producerService = producerService;
|
|
}
|
|
|
|
[HttpPost("farm/{farmId}/greenhouse/{ghId}/watering")]
|
|
public async Task<IActionResult> interactValve([FromBody] ValveRequest request, int farmId, int ghId)
|
|
{
|
|
var kafkaRequest = new
|
|
{
|
|
FarmId = farmId,
|
|
GreenHouseId = ghId,
|
|
SomeAction = request.Action,
|
|
};
|
|
|
|
var message = JsonSerializer.Serialize(kafkaRequest);
|
|
return Ok(kafkaRequest);
|
|
|
|
/*await _producerService.ProduceMessageAsync("ValvesHeatersRequest", message);
|
|
|
|
return Ok($"Valve status is {request.Action}");*/
|
|
}
|
|
}
|
|
}
|