Merge pull request #18 from cnblogs/fix-domain-event-dispatch-order

fix: domain event dispatch order
cnblogs · Feb 9, 2023 · 6a61bae · 6a61bae
2 parents 7e43a23 + a678dbb
commit 6a61bae
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/BaseRepository.cs b/src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/BaseRepository.cs
@@ -52,7 +52,7 @@ public IQueryable<T> GetNoTrackingQueryable<T>()
     public async Task<TEntity> AddAsync(TEntity entity)
     {
         await Context.AddAsync(entity);
-        await SaveEntitiesInternalAsync(true);
+        await SaveEntitiesInternalAsync();
         return entity;
     }
 
@@ -61,7 +61,7 @@ public async Task<TEnumerable> AddRangeAsync<TEnumerable>(TEnumerable entities)
         where TEnumerable : IEnumerable<TEntity>
     {
         await Context.AddRangeAsync(entities);
-        await SaveEntitiesInternalAsync(true);
+        await SaveEntitiesInternalAsync();
         return entities;
     }
 
@@ -80,22 +80,22 @@ public async Task<TEnumerable> AddRangeAsync<TEnumerable>(TEnumerable entities)
     /// <inheritdoc />
     public async Task<TEntity> UpdateAsync(TEntity entity)
     {
-        await SaveEntitiesInternalAsync(true);
+        await SaveEntitiesInternalAsync();
         return entity;
     }
 
     /// <inheritdoc />
     public async Task<IEnumerable<TEntity>> UpdateRangeAsync(IEnumerable<TEntity> entities)
     {
-        await SaveEntitiesInternalAsync(true);
+        await SaveEntitiesInternalAsync();
         return entities;
     }
 
     /// <inheritdoc />
     public async Task<TEntity> DeleteAsync(TEntity entity)
     {
         Context.Remove(entity);
-        await SaveEntitiesInternalAsync(true);
+        await SaveEntitiesInternalAsync();
         return entity;
     }
 
@@ -130,7 +130,7 @@ public async Task<int> SaveChangesAsync(CancellationToken cancellationToken = de
     /// <inheritdoc />
     public Task<bool> SaveEntitiesAsync(CancellationToken cancellationToken = default)
     {
-        return SaveEntitiesInternalAsync(false, cancellationToken);
+        return SaveEntitiesInternalAsync(true, cancellationToken);
     }
 
     /// <summary>
@@ -145,7 +145,7 @@ protected virtual Task BeforeDispatchDomainEventAsync(List<DomainEvent> events,
     }
 
     private async Task<bool> SaveEntitiesInternalAsync(
-        bool dispatchDomainEventFirst,
+        bool dispatchDomainEventFirst = false,
         CancellationToken cancellationToken = default)
     {
         var entities = Context.ExtractDomainEventSources();