Util/test/Util.TestShare/EventHandlers/OperationLogChangedEventHandler.cs

using System.Threading;
using System.Threading.Tasks;
using Util.Domain.Events;
using Util.Events;
using Util.Tests.Models;
using Util.Tests.Repositories;
using Util.Tests.UnitOfWorks;

namespace Util.Tests.EventHandlers; 

/// <summary>
/// 操作日志变更事件处理器
/// </summary>
public class OperationLogChangedEventHandler : EventHandlerBase<EntityChangedEvent<OperationLog>> {
    /// <summary>
    /// 工作单元
    /// </summary>
    private readonly ITestUnitOfWork _unitOfWork;
    /// <summary>
    /// 操作日志仓储
    /// </summary>
    private readonly IOperationLogRepository _operationLogRepository;

    /// <summary>
    /// 初始化操作日志变更事件处理器
    /// </summary>
    /// <param name="unitOfWork">工作单元</param>
    /// <param name="operationLogRepository">操作日志仓储</param>
    public OperationLogChangedEventHandler( ITestUnitOfWork unitOfWork, IOperationLogRepository operationLogRepository ) {
        _unitOfWork = unitOfWork;
        _operationLogRepository = operationLogRepository;
    }

    /// <summary>
    /// 处理事件
    /// </summary>
    /// <param name="event">事件</param>
    /// <param name="cancellationToken">取消令牌</param>
    public override async Task HandleAsync( EntityChangedEvent<OperationLog> @event, CancellationToken cancellationToken ) {
        if ( @event.ChangeType == EntityChangeType.Deleted && @event.Entity.LogName == "EntityChangedEvent_Deleted" ) {
            var log = new OperationLog { LogName = "Test", Caption = nameof( OperationLogChangedEventHandler ), Content = @event.Entity.LogName };
            await _operationLogRepository.AddAsync( log, cancellationToken );
            await _unitOfWork.CommitAsync();
        }
    }
}