persistence/DD.Persistence.API/Services/ChangeLogService.cs

using DD.Persistence.Models.Common;
using DD.Persistence.Models;
using DD.Persistence.Models.Requests;
using DD.Persistence.Repositories;
using Microsoft.Extensions.Caching.Memory;
using DD.Persistence.Database.Entity;

namespace DD.Persistence.API.Services;

/// <summary>
/// Сервис по работе с журналом изменений
/// </summary>
public class ChangeLogService
{
    private readonly IMemoryCache memoryCache;
    private readonly IChangeLogCommitRepository commitRepository;
    private readonly IChangeLogRepository repository;
    private readonly TimeSpan? AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(60);

    /// <summary>
    /// ctor
    /// </summary>
    /// <param name="memoryCache"></param>
    /// <param name="commitRepository"></param>
    /// <param name="repository"></param>
    public ChangeLogService(
        IMemoryCache memoryCache,
        IChangeLogCommitRepository commitRepository,
        IChangeLogRepository repository)
    {
        this.memoryCache = memoryCache;
        this.commitRepository = commitRepository;
        this.repository = repository;
    }

    /// <summary>
    /// Чтение ключа коммита из кеша или (если коммита в кеше нет) создание коммита
    /// </summary>
    /// <param name="commitDto"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    private async Task<Guid> GetOrCreateCommitAsync(ChangeLogCommitRequest commitDto, CancellationToken token)
    {
        var key = (commitDto.IdAuthor, commitDto.Comment);
        var commitId = await memoryCache.GetOrCreateAsync(key, async (cacheEntry) =>
        {
            cacheEntry.AbsoluteExpirationRelativeToNow = AbsoluteExpirationRelativeToNow;

            var commitId = await commitRepository.Add(commitDto, token);

            return commitId;
        });
        return commitId;
    }

    /// <summary>
    /// Добавление записи в журнал изменений
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="commitRequestDto"></param>
    /// <param name="dtos"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<int> AddRange(Guid idDiscriminator, ChangeLogCommitRequest commitRequestDto, IEnumerable<ChangeLogValuesDto> dtos, CancellationToken token)
    {
        var commitId = await GetOrCreateCommitAsync(commitRequestDto, token);
        var commitDto = new ChangeLogCommitDto(commitId, commitRequestDto);

        var result = await repository.AddRange(idDiscriminator, commitDto, dtos, token);
        return result;
    }

    /// <summary>
    /// Пометить запись журнала изменений как удаленную
    /// </summary>
    /// <param name="ids"></param>
    /// <param name="commitRequestDto"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<int> MarkAsDeleted(IEnumerable<Guid> ids, ChangeLogCommitRequest commitRequestDto, CancellationToken token)
    {
        var commitId = await GetOrCreateCommitAsync(commitRequestDto, token);
        var commitDto = new ChangeLogCommitDto(commitId, commitRequestDto);  

        var result = await repository.MarkAsDeleted(commitId, ids, commitDto.Creation, token);

        return result;
    }

    /// <summary>
    /// Очистить старые и добавить новые записи в журнал изменений
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="commitRequestDto"></param>
    /// <param name="dtos"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<int> ClearAndAddRange(Guid idDiscriminator, ChangeLogCommitRequest commitRequestDto, IEnumerable<ChangeLogValuesDto> dtos, CancellationToken token)
    {
        var commitId = await GetOrCreateCommitAsync(commitRequestDto, token);
        var commitDto = new ChangeLogCommitDto(commitId, commitRequestDto);

        var result = await repository.ClearAndAddRange(idDiscriminator, commitDto, dtos, token);

        return result;
    }

    /// <summary>
    /// Обновить записи в журнале изменений
    /// </summary>
    /// <param name="commitRequestDto"></param>
    /// <param name="dtos"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<int> UpdateRange(ChangeLogCommitRequest commitRequestDto, IEnumerable<ChangeLogValuesDto> dtos, CancellationToken token)
    {
        var commitId = await GetOrCreateCommitAsync(commitRequestDto, token);
        var commitDto = new ChangeLogCommitDto(commitId, commitRequestDto);

        var result = await repository.UpdateRange(commitDto, dtos, token);

        return result;
    }

    /// <summary>
    ///  Получение актуальных записей на определенный момент времени (с пагинацией)
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="momentUtc"></param>
    /// <param name="paginationRequest"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<PaginationContainer<ChangeLogValuesDto>> GetByDate(
      Guid idDiscriminator,
      DateTimeOffset momentUtc,
      PaginationRequest paginationRequest,
      CancellationToken token)
    {
        var result = await repository.GetByDate(idDiscriminator, momentUtc, paginationRequest, token);

        return result;
    }

    /// <summary>
    /// Получение измененных записей за период времени
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="dateBegin"></param>
    /// <param name="dateEnd"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<IEnumerable<ChangeLogDto>> GetChangeLogForInterval(Guid idDiscriminator, DateTimeOffset dateBegin, DateTimeOffset dateEnd, CancellationToken token)
    {
        var result = await repository.GetChangeLogForInterval(idDiscriminator, dateBegin, dateEnd, token);

        return result;
    }

    /// <summary>
    /// Получение списка дат, в которые происходили изменения (день, месяц, год, без времени)
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<IEnumerable<DateOnly>> GetDatesChange(Guid idDiscriminator, CancellationToken token)
    {
        var result = await repository.GetDatesChange(idDiscriminator, token);

        return result;
    }

    /// <summary>
    /// Получить данные, начиная с определенной даты
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="dateBegin"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<IEnumerable<ChangeLogValuesDto>> GetGtDate(Guid idDiscriminator, DateTimeOffset dateBegin, CancellationToken token)
    {
        var result = await repository.GetGtDate(idDiscriminator, dateBegin, token);

        return result;      
    }

    /// <summary>
    /// Получить диапазон дат, для которых есть данные в репозитории
    /// </summary>
    /// <param name="idDiscriminator"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public async Task<DatesRangeDto?> GetDatesRange(Guid idDiscriminator, CancellationToken token)
    {
        var result = await repository.GetDatesRange(idDiscriminator, token);

        return result;
    }
}