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

backend/Gridient.Core/Features/FieldValues/Commands/UpdateElementCommandHandler.cs
95 строк5 KB
Jenkins
Auto add
18 фев 2026, 10:19
18 фев 2026, 10:191e6c4f8
using Gridient.Core.Exceptions;
using Gridient.Core.Extensions;
using Gridient.Core.Mapping;
using Gridient.Core.Models;
using Gridient.Core.Repositories;
using Gridient.Core.Services.Interfaces;
using MediatR;
using Microsoft.Extensions.Logging;

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

        public UpdateElementCommandHandler(
            ListsRepositoryFactory factory,
            IUserService usersService,
            ILogger<UpdateElementCommandHandler> logger)
        {
            _factory = factory;
            _usersService = usersService;
            _logger = logger;
        }

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

            await ValidateItemBelongsToList(request.ListId, request.ItemId, cancellationToken);
            await CheckUniqueValues(request.ListId, request.Values, cancellationToken);

            var currentUser = await _usersService.GetByLoginAsync(request.UserLogin, cancellationToken);
            if (currentUser == null)
                throw ListsException.Error("Пользователь не найден");

            await _factory.UnitOfWork.ExecuteInTransactionAsync(async transaction =>
            {
                var dateTimeUtc = DateTime.UtcNow;

                var list = await _factory.ListsRepository.GetByIdAsync(request.ListId, cancellationToken);
                if (list == null)
                    throw ListsException.EntityNotFound(request.ListId);

                var updatedFieldValueEntities = await _factory.FieldValuesRepository
                   .UpdateElement(request.ListId, request.ItemId, request.Values, cancellationToken);

                await _factory.ListItemVersionsRepository.Add(request.ListId, request.ItemId, currentUser.Id, dateTimeUtc, FieldValueMapper.MapToSimpleFieldValueArray(updatedFieldValueEntities), cancellationToken);
                await _factory.ListsRepository.RemoveOldVersionsAsync(request.ListId, list.MaxVersions ?? 1, cancellationToken);

                await _factory.ListItemsSysInfoRepository.OnUpdatedAsync(request.ListId, request.ItemId, currentUser.Id, dateTimeUtc, cancellationToken);
            }, _logger, 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} или не существует");
                }
            }
        }

        private async Task CheckUniqueValues(int listId, FieldValue[] values, CancellationToken cancellationToken)
        {
            var updatingFields = values.Select(e => e.FieldName).ToArray();
            var uniqueFields = await _factory.FieldsRepository
                .GetEntitiesByQueryAsync(f => f.ListId == listId && f.UniqueValues == true && updatingFields.Contains(f.Name), cancellationToken);
            if (uniqueFields.Length > 0)
            {
                foreach (var uniqueField in uniqueFields)
                {
                    var fieldValue = values.FirstOrDefault(f => f.FieldName == uniqueField.Name);
                    if (fieldValue != null)
                    {
                        bool hasSameValue = await _factory.FieldValuesRepository.CheckUniqueValue(listId, uniqueField, fieldValue, cancellationToken);
                        if (hasSameValue)
                            throw ListsException.Error($"Изменения не сохранены, т.к. нарушается уникальность поля '{uniqueField.Title}'");
                    }
                }
            }
        }
    }
}