backend/Gridient.Core/Features/FieldValues/Commands/DeleteElementCommandHandler.cs - master - softailor/gridient

backend/Gridient.Core/Features/FieldValues/Commands/DeleteElementCommandHandler.cs
57 строк3 KB
Jenkins
Auto add
18 фев 2026, 10:19
18 фев 2026, 10:191e6c4f8
using Gridient.Core.Exceptions;
using Gridient.Core.Repositories;
using Gridient.Core.Services.Interfaces;
using MediatR;

namespace Gridient.Core.Features.FieldValues.Commands
{
    /// <summary>
    /// Обработчик команды для удаления элемента списка
    /// </summary>
    public class DeleteElementCommandHandler : IRequestHandler<DeleteElementCommand>
    {
        private readonly ListsRepositoryFactory _factory;
        private readonly IUserService _usersService;

        public DeleteElementCommandHandler(
            ListsRepositoryFactory factory,
            IUserService usersService)
        {
            _factory = factory;
            _usersService = usersService;
        }

        public async Task Handle(DeleteElementCommand request, CancellationToken cancellationToken)
        {
            // Авторизация элемента списка уже проверена в AuthorizationBehavior через IRequiresListItemAuthorization

            await ValidateItemBelongsToList(request.ListId, request.ItemId, cancellationToken);
            
            bool existsLookup = await _factory.FieldValuesRepository
                .HasLookupReferencesAsync(request.ListId, request.ItemId, cancellationToken);
            if (existsLookup)
                throw ListsException.Error("Нельзя удалить элемент, так как существуют элементы-подстановки с этим значением");

            var currentUser = await _usersService.GetByLoginAsync(request.UserLogin, cancellationToken);
            if (currentUser == null)
                throw ListsException.Error("Пользователь не найден");
                
            await _factory.ListItemsSysInfoRepository.DeleteAsync(request.ListId, request.ItemId, currentUser.Id, DateTime.UtcNow, cancellationToken);
        }

        private async Task ValidateItemBelongsToList(int listId, int itemId, CancellationToken cancellationToken)
        {
            var values = await _factory.FieldValuesRepository.GetValuesByItemId(listId, itemId, cancellationToken);
            if (values.Length == 0)
            {
                // Проверяем через ListItemsSysInfo, возможно элемент существует, но не имеет значений
                var sysInfo = await _factory.ListItemsSysInfoRepository.GetEntitiesByQueryAsync(
                    e => e.ListId == listId && e.ItemId == itemId, cancellationToken);
                if (sysInfo.Length == 0)
                {
                    throw ListsException.Error($"Элемент с ID {itemId} не принадлежит списку с ID {listId} или не существует");
                }
            }
        }
    }
}