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

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

    /// <summary>
    /// 处理事件
    /// </summary>
    public override async Task HandleAsync( EntityChangedEvent<Product> @event, CancellationToken cancellationToken ) {
        if ( @event.ChangeType == EntityChangeType.Created && @event.Entity.Name == "EntityChangedEvent_Created" ) {
            var log = new OperationLog { Caption = @event.Entity.Name, LogName = nameof( ProductChangedEventHandler ) };
            await _operationLogRepository.AddAsync( log, cancellationToken );
            await _unitOfWork.CommitAsync();
            return;
        }
        if( @event.ChangeType == EntityChangeType.Updated && @event.Entity.Name == "EntityChangedEvent_Updated" ) {
            var log = new OperationLog { Caption = @event.Entity.Name, LogName = nameof( ProductChangedEventHandler ) };
            await _operationLogRepository.AddAsync( log, cancellationToken );
            await _unitOfWork.CommitAsync();
            return;
        }
        if( @event.ChangeType == EntityChangeType.Deleted && @event.Entity.Name == "EntityChangedEvent_Deleted" ) {
            var log = new OperationLog { Caption = @event.Entity.Name, LogName = nameof( ProductChangedEventHandler ) };
            await _operationLogRepository.AddAsync( log, cancellationToken );
            await _unitOfWork.CommitAsync();
        }
    }
}