using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using DD.Persistence.Models; using DD.Persistence.Repositories; namespace DD.Persistence.API.Controllers; [ApiController] [Authorize] [Route("api/[controller]")] public class TimeSeriesController : ControllerBase, ITimeSeriesDataApi where TDto : class, ITimeSeriesAbstractDto, new() { private readonly ITimeSeriesDataRepository timeSeriesDataRepository; public TimeSeriesController(ITimeSeriesDataRepository timeSeriesDataRepository) { this.timeSeriesDataRepository = timeSeriesDataRepository; } /// /// Получить список объектов, удовлетворяющий диапазону дат /// /// /// /// [HttpGet] [ProducesResponseType(StatusCodes.Status200OK)] public async Task Get(DateTimeOffset dateBegin, CancellationToken token) { var result = await timeSeriesDataRepository.GetGtDate(dateBegin, token); return Ok(result); } /// /// Получить диапазон дат, для которых есть данные в репозитории /// /// /// [HttpGet("datesRange")] public async Task GetDatesRange(CancellationToken token) { var result = await timeSeriesDataRepository.GetDatesRange(token); return Ok(result); } /// /// Получить список объектов с прореживанием, удовлетворяющий диапазону дат /// /// /// /// /// /// [HttpGet("resampled")] public async Task GetResampledData(DateTimeOffset dateBegin, double intervalSec = 600d, int approxPointsCount = 1024, CancellationToken token = default) { var result = await timeSeriesDataRepository.GetResampledData(dateBegin, intervalSec, approxPointsCount, token); return Ok(result); } /// /// Добавить записи /// /// /// /// [HttpPost] public async Task AddRange(IEnumerable dtos, CancellationToken token) { var result = await timeSeriesDataRepository.AddRange(dtos, token); return Ok(result); } }