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

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

namespace DD.Persistence.API.Controllers;

[ApiController]
[Authorize]
[Route("api/[controller]")]
public class ChangeLogController : ControllerBase, IChangeLogApi
{
    private readonly IChangeLogRepository repository;

    public ChangeLogController(IChangeLogRepository repository)
    {
        this.repository = repository;
    }

    [HttpPost("{idDiscriminator}")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
    public async Task<IActionResult> Add(
        [FromRoute] Guid idDiscriminator,
        [FromBody] ChangeLogValuesDto dto,
        CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.AddRange(userId, idDiscriminator, [dto], token);

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

    [HttpPost("range/{idDiscriminator}")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
    public async Task<IActionResult> AddRange(
        [FromRoute] Guid idDiscriminator,
        [FromBody] IEnumerable<ChangeLogValuesDto> dtos,
        CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.AddRange(userId, idDiscriminator, dtos, token);

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

    [HttpDelete]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> Delete(Guid id, CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.MarkAsDeleted(userId, [id], token);

        return Ok(result);
    }

    [HttpDelete("range")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> DeleteRange(IEnumerable<Guid> ids, CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.MarkAsDeleted(userId, ids, token);

        return Ok(result);
    }

    [HttpPost("replace/{idDiscriminator}")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> ClearAndAddRange(
        [FromRoute] Guid idDiscriminator,
        [FromBody] IEnumerable<ChangeLogValuesDto> dtos,
        CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.ClearAndAddRange(userId, idDiscriminator, dtos, token);
        return Ok(result);
    }

    [HttpPut]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> Update(
        ChangeLogValuesDto dto,
        CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.UpdateRange(userId, [dto], token);

        return Ok(result);
    }

    [HttpPut("range")]
    [ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> UpdateRange(
        IEnumerable<ChangeLogValuesDto> dtos,
        CancellationToken token)
    {
        var userId = User.GetUserId<Guid>();
        var result = await repository.UpdateRange(userId, dtos, token);

        return Ok(result);
    }

    [HttpGet("{idDiscriminator}")]
    [ProducesResponseType(typeof(PaginationContainer<ChangeLogValuesDto>), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> GetCurrent(
        [FromRoute] Guid idDiscriminator,
        [FromQuery] PaginationRequest paginationRequest,
        CancellationToken token)
    {
        var moment = new DateTimeOffset(3000, 1, 1, 0, 0, 0, TimeSpan.Zero);
        var result = await repository.GetByDate(idDiscriminator, moment, paginationRequest, token);

        return Ok(result);
    }

    [HttpGet("moment/{idDiscriminator}")]
    [ProducesResponseType(typeof(PaginationContainer<ChangeLogValuesDto>), (int)HttpStatusCode.OK)]
    public async Task<IActionResult> GetByDate(
        [FromRoute] Guid idDiscriminator,
        DateTimeOffset moment,
        [FromQuery] PaginationRequest paginationRequest,
        CancellationToken token)
    {
        var result = await repository.GetByDate(idDiscriminator, moment, paginationRequest, token);

        return Ok(result);
    }

    [HttpGet("history/{idDiscriminator}")]
    [ProducesResponseType(typeof(IEnumerable<ChangeLogDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<IActionResult> GetChangeLogForDate(
        [FromRoute] Guid idDiscriminator,
        DateTimeOffset dateBegin,
        DateTimeOffset dateEnd,
        CancellationToken token)
    {
        var result = await repository.GetChangeLogForInterval(idDiscriminator, dateBegin, dateEnd, token);

        return Ok(result);
    }

    [HttpGet("datesChange/{idDiscriminator}")]
    [ProducesResponseType(typeof(IEnumerable<DateOnly>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<IActionResult> GetDatesChange([FromRoute] Guid idDiscriminator, CancellationToken token)
    {
        var result = await repository.GetDatesChange(idDiscriminator, token);

        return Ok(result);
    }

    [HttpGet("part/{idDiscriminator}")]
    [ProducesResponseType(typeof(IEnumerable<ChangeLogValuesDto>), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<IEnumerable<ChangeLogValuesDto>>> GetPart([FromRoute] Guid idDiscriminator, DateTimeOffset dateBegin, int take = 86400, CancellationToken token = default)
    {
        var result = await repository.GetGtDate(idDiscriminator, dateBegin, token);

        return Ok(result);
    }

    [HttpGet("datesRange/{idDiscriminator}")]
    [ProducesResponseType(typeof(DatesRangeDto), (int)HttpStatusCode.OK)]
    [ProducesResponseType((int)HttpStatusCode.NoContent)]
    public async Task<ActionResult<DatesRangeDto>> GetDatesRangeAsync([FromRoute] Guid idDiscriminator, CancellationToken token)
    {
        var result = await repository.GetDatesRange(idDiscriminator, token);

        if (result is null)
            return NoContent();

        return Ok(result);
    }

    /// <summary>
    /// Метод, который возвращает статистику по количеству изменений в разрезе дней
    /// </summary>
    /// <param name="request"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    [HttpGet("statistics")]
    public async Task<ActionResult<IEnumerable<StatisticsChangeLogDto>>> GetStatisticsCountAsync([FromQuery] ChangeLogRequest request, CancellationToken token)
    {
        var result = new List<StatisticsChangeLogDto>() {
            new() { DateTime = DateTimeOffset.UtcNow.AddDays(-60), ChangesCount = 10},
            new() { DateTime = DateTimeOffset.UtcNow.AddDays(-50), ChangesCount = 2},
            new() { DateTime = DateTimeOffset.UtcNow.AddDays(-25), ChangesCount = 560},
            new() { DateTime = DateTimeOffset.UtcNow.AddDays(-2), ChangesCount = 78},
            new() { DateTime = DateTimeOffset.UtcNow.AddDays(-1), ChangesCount = 39},
        };

        return Ok(result);
    }

    /// <summary>
    /// Метод, который возвращает историю изменений в разрезе дней
    /// </summary>
    /// <param name="request"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    [HttpGet("history")]
    public async Task<ActionResult<IEnumerable<HistoryChangeLogDto>>> HistoryChangeLogAsync([FromQuery] ChangeLogRequest request, CancellationToken token)
    {
        var userId = Guid.CreateVersion7();
        var changeLogItemCurrentId = Guid.CreateVersion7();
        var changeLogItems = new List<ChangeLogDto>()
        {
            new ChangeLogDto()
            {
                Id = changeLogItemCurrentId,
                Creation = DateTimeOffset.UtcNow,
                IdAuthor = userId,
                IdEditor = userId,
                Obsolete = null,
                Value = new ChangeLogValuesDto(){
                    Id = Guid.CreateVersion7(),
                    Value = new Dictionary<string, object>() {
                        ["1"] = new { id = 1, caption = "Изменение 1 (c правкой)" },
                        ["2"] = new { id = 2, caption = "Изменение 2 (с правкой)" },
                    }
                }
            },
            new ChangeLogDto()
            {
                Id = Guid.CreateVersion7(),
                Creation = DateTimeOffset.UtcNow.AddDays(-10),
                IdAuthor = userId,
                IdEditor = userId,
                IdNext = changeLogItemCurrentId,
                Obsolete = DateTimeOffset.UtcNow.AddDays(-5),
                Value = new ChangeLogValuesDto(){ 
                    Id = Guid.CreateVersion7(),
                    Value = new Dictionary<string, object>() {
                        ["1"] = new { id = 1, caption = "Изменение 1" },
                        ["2"] = new { id = 2, caption = "Изменение 2" },
                    }
                }
            }
        };
        var result = new List<HistoryChangeLogDto>() {
            new() { 
                Comment = "Петров И. Ю. попросил внести изменения",
                DateTime = DateTimeOffset.UtcNow,
                DiscriminatorId = Guid.CreateVersion7(),
                User = new UserDto()
                {
                    Id = userId,
                    DisplayName = "Иванов И. И"
                },
                ChangeLogItems = changeLogItems
            },
        };

        return Ok(result);
    }
}