Util/test/Util.TestShare/EventHandlers/ProductUpdatedEventHandler.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 ProductUpdatedEventHandler : EventHandlerBase<EntityUpdatedEvent<Product>> {
    /// <summary>
    /// 工作单元
    /// </summary>
    private readonly ITestUnitOfWork _unitOfWork;
    /// <summary>
    /// 操作日志仓储
    /// </summary>
    private readonly IOperationLogRepository _operationLogRepository;

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

    /// <summary>
    /// 处理事件
    /// </summary>
    public override async Task HandleAsync( EntityUpdatedEvent<Product> @event, CancellationToken cancellationToken ) {
        if ( @event.Entity.Name != "EntityUpdatedEvent" )
            return;
        var log = new OperationLog { Caption = @event.Entity.Name,LogName = nameof( ProductUpdatedEventHandler ) };
        await _operationLogRepository.AddAsync( log, cancellationToken );
        await _unitOfWork.CommitAsync();
    }
}