mirror of https://github.com/abpframework/abp.git
liangshiwei
4 years ago
6 changed files with 1 additions and 334 deletions
@ -1,227 +0,0 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Microsoft.Extensions.Logging; |
|||
using Microsoft.Extensions.Logging.Abstractions; |
|||
using Microsoft.Extensions.Options; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.Domain.Entities.Events.Distributed; |
|||
using Volo.Abp.DynamicProxy; |
|||
using Volo.Abp.EventBus; |
|||
using Volo.Abp.EventBus.Distributed; |
|||
using Volo.Abp.EventBus.Local; |
|||
using Volo.Abp.Uow; |
|||
|
|||
namespace Volo.Abp.Domain.Entities.Events; |
|||
|
|||
/// <summary>
|
|||
/// Used to trigger entity change events.
|
|||
/// </summary>
|
|||
public class EntityChangeEventHelper : IEntityChangeEventHelper, ITransientDependency |
|||
{ |
|||
private const string UnitOfWorkEventRecordEntityPropName = "_Abp_Entity"; |
|||
|
|||
public ILogger<EntityChangeEventHelper> Logger { get; set; } |
|||
public ILocalEventBus LocalEventBus { get; set; } |
|||
public IDistributedEventBus DistributedEventBus { get; set; } |
|||
|
|||
protected IUnitOfWorkManager UnitOfWorkManager { get; } |
|||
protected IEntityToEtoMapper EntityToEtoMapper { get; } |
|||
protected AbpDistributedEntityEventOptions DistributedEntityEventOptions { get; } |
|||
|
|||
public EntityChangeEventHelper( |
|||
IUnitOfWorkManager unitOfWorkManager, |
|||
IEntityToEtoMapper entityToEtoMapper, |
|||
IOptions<AbpDistributedEntityEventOptions> distributedEntityEventOptions) |
|||
{ |
|||
UnitOfWorkManager = unitOfWorkManager; |
|||
EntityToEtoMapper = entityToEtoMapper; |
|||
DistributedEntityEventOptions = distributedEntityEventOptions.Value; |
|||
|
|||
LocalEventBus = NullLocalEventBus.Instance; |
|||
DistributedEventBus = NullDistributedEventBus.Instance; |
|||
Logger = NullLogger<EntityChangeEventHelper>.Instance; |
|||
} |
|||
|
|||
public virtual void PublishEntityCreatingEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
#pragma warning disable 618
|
|||
typeof(EntityCreatingEventData<>), |
|||
#pragma warning restore 618
|
|||
entity, |
|||
entity |
|||
); |
|||
} |
|||
|
|||
public virtual void PublishEntityCreatedEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
typeof(EntityCreatedEventData<>), |
|||
entity, |
|||
entity |
|||
); |
|||
|
|||
if (ShouldPublishDistributedEventForEntity(entity)) |
|||
{ |
|||
var eto = EntityToEtoMapper.Map(entity); |
|||
if (eto != null) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
DistributedEventBus, |
|||
typeof(EntityCreatedEto<>), |
|||
eto, |
|||
entity |
|||
); |
|||
} |
|||
} |
|||
} |
|||
|
|||
private bool ShouldPublishDistributedEventForEntity(object entity) |
|||
{ |
|||
return DistributedEntityEventOptions |
|||
.AutoEventSelectors |
|||
.IsMatch( |
|||
ProxyHelper |
|||
.UnProxy(entity) |
|||
.GetType() |
|||
); |
|||
} |
|||
|
|||
public virtual void PublishEntityUpdatingEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
#pragma warning disable 618
|
|||
typeof(EntityUpdatingEventData<>), |
|||
#pragma warning restore 618
|
|||
entity, |
|||
entity |
|||
); |
|||
} |
|||
|
|||
public virtual void PublishEntityUpdatedEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
typeof(EntityUpdatedEventData<>), |
|||
entity, |
|||
entity |
|||
); |
|||
|
|||
if (ShouldPublishDistributedEventForEntity(entity)) |
|||
{ |
|||
var eto = EntityToEtoMapper.Map(entity); |
|||
if (eto != null) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
DistributedEventBus, |
|||
typeof(EntityUpdatedEto<>), |
|||
eto, |
|||
entity |
|||
); |
|||
} |
|||
} |
|||
} |
|||
|
|||
public virtual void PublishEntityDeletingEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
#pragma warning disable 618
|
|||
typeof(EntityDeletingEventData<>), |
|||
#pragma warning restore 618
|
|||
entity, |
|||
entity |
|||
); |
|||
} |
|||
|
|||
public virtual void PublishEntityDeletedEvent(object entity) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
LocalEventBus, |
|||
typeof(EntityDeletedEventData<>), |
|||
entity, |
|||
entity |
|||
); |
|||
|
|||
if (ShouldPublishDistributedEventForEntity(entity)) |
|||
{ |
|||
var eto = EntityToEtoMapper.Map(entity); |
|||
if (eto != null) |
|||
{ |
|||
TriggerEventWithEntity( |
|||
DistributedEventBus, |
|||
typeof(EntityDeletedEto<>), |
|||
eto, |
|||
entity |
|||
); |
|||
} |
|||
} |
|||
} |
|||
|
|||
protected virtual void TriggerEventWithEntity( |
|||
IEventBus eventPublisher, |
|||
Type genericEventType, |
|||
object entityOrEto, |
|||
object originalEntity) |
|||
{ |
|||
var entityType = ProxyHelper.UnProxy(entityOrEto).GetType(); |
|||
var eventType = genericEventType.MakeGenericType(entityType); |
|||
var eventData = Activator.CreateInstance(eventType, entityOrEto); |
|||
var currentUow = UnitOfWorkManager.Current; |
|||
|
|||
if (currentUow == null) |
|||
{ |
|||
Logger.LogWarning("UnitOfWorkManager.Current is null! Can not publish the event."); |
|||
return; |
|||
} |
|||
|
|||
var eventRecord = new UnitOfWorkEventRecord(eventType, eventData, EventOrderGenerator.GetNext()) |
|||
{ |
|||
Properties = |
|||
{ |
|||
{ UnitOfWorkEventRecordEntityPropName, originalEntity }, |
|||
} |
|||
}; |
|||
|
|||
/* We are trying to eliminate same events for the same entity. |
|||
* In this way, for example, we don't trigger update event for an entity multiple times |
|||
* even if it is updated multiple times in the current UOW. |
|||
*/ |
|||
|
|||
if (eventPublisher == DistributedEventBus) |
|||
{ |
|||
currentUow.AddOrReplaceDistributedEvent( |
|||
eventRecord, |
|||
otherRecord => IsSameEntityEventRecord(eventRecord, otherRecord) |
|||
); |
|||
} |
|||
else |
|||
{ |
|||
currentUow.AddOrReplaceLocalEvent( |
|||
eventRecord, |
|||
otherRecord => IsSameEntityEventRecord(eventRecord, otherRecord) |
|||
); |
|||
} |
|||
} |
|||
|
|||
public bool IsSameEntityEventRecord(UnitOfWorkEventRecord record1, UnitOfWorkEventRecord record2) |
|||
{ |
|||
if (record1.EventType != record2.EventType) |
|||
{ |
|||
return false; |
|||
} |
|||
|
|||
var record1OriginalEntity = record1.Properties.GetOrDefault(UnitOfWorkEventRecordEntityPropName) as IEntity; |
|||
var record2OriginalEntity = record2.Properties.GetOrDefault(UnitOfWorkEventRecordEntityPropName) as IEntity; |
|||
|
|||
if (record1OriginalEntity == null || record2OriginalEntity == null) |
|||
{ |
|||
return false; |
|||
} |
|||
|
|||
return EntityHelper.EntityEquals(record1OriginalEntity, record2OriginalEntity); |
|||
} |
|||
} |
|||
@ -1,23 +0,0 @@ |
|||
using System; |
|||
|
|||
namespace Volo.Abp.Domain.Entities.Events; |
|||
|
|||
/// <summary>
|
|||
/// Used to pass data for an event when an entity (<see cref="IEntity"/>) is being changed (creating, updating or deleting).
|
|||
/// See <see cref="EntityCreatingEventData{TEntity}"/>, <see cref="EntityDeletingEventData{TEntity}"/> and <see cref="EntityUpdatingEventData{TEntity}"/> classes.
|
|||
/// </summary>
|
|||
/// <typeparam name="TEntity">Entity type</typeparam>
|
|||
[Serializable] |
|||
[Obsolete("This event is no longer needed and identical to EntityChangedEventData. Please use EntityChangedEventData instead.")] |
|||
public class EntityChangingEventData<TEntity> : EntityEventData<TEntity> |
|||
{ |
|||
/// <summary>
|
|||
/// Constructor.
|
|||
/// </summary>
|
|||
/// <param name="entity">Changing entity in this event</param>
|
|||
public EntityChangingEventData(TEntity entity) |
|||
: base(entity) |
|||
{ |
|||
|
|||
} |
|||
} |
|||
@ -1,22 +0,0 @@ |
|||
using System; |
|||
|
|||
namespace Volo.Abp.Domain.Entities.Events; |
|||
|
|||
/// <summary>
|
|||
/// This type of event is used to notify just before creation of an Entity.
|
|||
/// </summary>
|
|||
/// <typeparam name="TEntity">Entity type</typeparam>
|
|||
[Serializable] |
|||
[Obsolete("This event is no longer needed and identical to EntityCreatedEventData. Please use EntityCreatedEventData instead.")] |
|||
public class EntityCreatingEventData<TEntity> : EntityChangingEventData<TEntity> |
|||
{ |
|||
/// <summary>
|
|||
/// Constructor.
|
|||
/// </summary>
|
|||
/// <param name="entity">The entity which is being created</param>
|
|||
public EntityCreatingEventData(TEntity entity) |
|||
: base(entity) |
|||
{ |
|||
|
|||
} |
|||
} |
|||
@ -1,22 +0,0 @@ |
|||
using System; |
|||
|
|||
namespace Volo.Abp.Domain.Entities.Events; |
|||
|
|||
/// <summary>
|
|||
/// This type of event is used to notify just before deletion of an Entity.
|
|||
/// </summary>
|
|||
/// <typeparam name="TEntity">Entity type</typeparam>
|
|||
[Serializable] |
|||
[Obsolete("This event is no longer needed and identical to EntityDeletedEventData. Please use EntityDeletedEventData instead.")] |
|||
public class EntityDeletingEventData<TEntity> : EntityChangingEventData<TEntity> |
|||
{ |
|||
/// <summary>
|
|||
/// Constructor.
|
|||
/// </summary>
|
|||
/// <param name="entity">The entity which is being deleted</param>
|
|||
public EntityDeletingEventData(TEntity entity) |
|||
: base(entity) |
|||
{ |
|||
|
|||
} |
|||
} |
|||
@ -1,22 +0,0 @@ |
|||
using System; |
|||
|
|||
namespace Volo.Abp.Domain.Entities.Events; |
|||
|
|||
/// <summary>
|
|||
/// This type of event is used to notify just before update of an Entity.
|
|||
/// </summary>
|
|||
/// <typeparam name="TEntity">Entity type</typeparam>
|
|||
[Serializable] |
|||
[Obsolete("This event is no longer needed and identical to EntityUpdatedEventData. Please use EntityUpdatedEventData instead.")] |
|||
public class EntityUpdatingEventData<TEntity> : EntityChangingEventData<TEntity> |
|||
{ |
|||
/// <summary>
|
|||
/// Constructor.
|
|||
/// </summary>
|
|||
/// <param name="entity">The entity which is being updated</param>
|
|||
public EntityUpdatingEventData(TEntity entity) |
|||
: base(entity) |
|||
{ |
|||
|
|||
} |
|||
} |
|||
Loading…
Reference in new issue