persistence/DD.Persistence.API/Controllers/TimestampedValuesController.cs

using DD.Persistence.Models;
using DD.Persistence.Models.Common;
using DD.Persistence.Repositories;
using DD.Persistence.Services.Interfaces;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using System.Net;

namespace DD.Persistence.API.Controllers;

/// <summary>
/// Хранение наборов данных с отметкой времени.
/// </summary>
[ApiController]
[Authorize]
[Route("api/[controller]")]
public class TimestampedValuesController : ControllerBase
{
    private readonly ITimestampedValuesService timestampedValuesService;
    private readonly ITimestampedValuesRepository timestampedValuesRepository;
    public TimestampedValuesController(ITimestampedValuesService repository, ITimestampedValuesRepository timestampedValuesRepository)
    {
        this.timestampedValuesService = repository;
        this.timestampedValuesRepository = timestampedValuesRepository;
    }

    /// <summary>
    /// Записать новые данные.
    /// Предполагается что данные с одним дискриминатором имеют одинаковую структуру
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="dtos"></param>
    /// <param name="token"></param>
    [HttpPost("{discriminatorId}")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
    public async Task<IActionResult> AddRange([FromRoute] Guid discriminatorId, [FromBody] IEnumerable<TimestampedValuesDto> dtos, CancellationToken token)
    {
        var result = await timestampedValuesService.AddRange(discriminatorId, dtos, token);

        return CreatedAtAction(nameof(AddRange), result);
    }

    /// <summary>
    /// Получение данных с фильтрацией. Значение фильтра null - отключен
    /// </summary>
    /// <param name="discriminatorIds">Набор дискриминаторов</param>
    /// <param name="timestampBegin">Фильтр позднее даты</param>
    /// <param name="columnNames">Фильтр свойств набора</param>
    /// <param name="skip"></param>
    /// <param name="take"></param>
    /// <param name="token"></param>
    [HttpGet]
    [ProducesResponseType(typeof(IEnumerable<TimestampedValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<TimestampedValuesDto>>> Get([FromQuery] IEnumerable<Guid> discriminatorIds, DateTimeOffset? timestampBegin, [FromQuery] string[]? columnNames, int skip, int take, CancellationToken token)
    {
        var result = await timestampedValuesService.Get(discriminatorIds, timestampBegin, columnNames, skip, take, token);

        return result.Any() ? Ok(result) : NoContent();
    }

    /// <summary>
    /// Получить данные, начиная с заданной отметки времени
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="timestampBegin">Фильтр позднее даты</param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/gtdate")]
    [ProducesResponseType(typeof(IEnumerable<TimestampedValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<TimestampedValuesDto>>> GetGtDate([FromRoute] Guid discriminatorId, DateTimeOffset timestampBegin, CancellationToken token)
    {
        var result = await timestampedValuesService.GetGtDate(discriminatorId, timestampBegin, token);

        return result.Any() ? Ok(result) : NoContent();
    }

    /// <summary>
    /// Получить данные c начала
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="take"></param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/first")]
    [ProducesResponseType(typeof(IEnumerable<TimestampedValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<TimestampedValuesDto>>> GetFirst([FromRoute] Guid discriminatorId, int take, CancellationToken token)
    {
        var result = await timestampedValuesService.GetFirst(discriminatorId, take, token);

        return result.Any() ? Ok(result) : NoContent();
    }

    /// <summary>
    /// Получить данные c конца
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="take"></param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/last")]
    [ProducesResponseType(typeof(IEnumerable<TimestampedValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<TimestampedValuesDto>>> GetLast([FromRoute] Guid discriminatorId, int take, CancellationToken token)
    {
        var result = await timestampedValuesService.GetLast(discriminatorId, take, token);

        return result.Any() ? Ok(result) : NoContent();
    }

    /// <summary>
    /// Получить список объектов с прореживанием, удовлетворяющий диапазону дат
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="timestampBegin">Фильтр позднее даты</param>
    /// <param name="intervalSec"></param>
    /// <param name="approxPointsCount"></param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/resampled")]
    [ProducesResponseType(typeof(IEnumerable<TimestampedValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<TimestampedValuesDto>>> GetResampledData([FromRoute] Guid discriminatorId, DateTimeOffset timestampBegin, double intervalSec = 600d, int approxPointsCount = 1024, CancellationToken token = default)
    {
        var result = await timestampedValuesService.GetResampledData(discriminatorId, timestampBegin, intervalSec, approxPointsCount, token);

        return result.Any() ? Ok(result) : NoContent();
    }

    /// <summary>
    /// Получить количество записей по указанному набору в БД. Для пагинации
    /// </summary>
    /// <param name="discriminatorId">Дискриминатор (идентификатор) набора</param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/count")]
    public async Task<ActionResult<int>> Count([FromRoute] Guid discriminatorId, CancellationToken token)
    {
        var result = await timestampedValuesRepository.Count(discriminatorId, token);

        return Ok(result);
    }

    /// <summary>
    /// Получить диапазон дат, в пределах которых хранятся даные
    /// </summary>
    /// <param name="discriminatorId"></param>
    /// <param name="token"></param>
    [HttpGet("{discriminatorId}/datesRange")]
    public async Task<ActionResult<DatesRangeDto>> GetDatesRange([FromRoute] Guid discriminatorId, CancellationToken token)
    {
        var result = await timestampedValuesRepository.GetDatesRange(discriminatorId, token);

        return Ok(result);
    }
}