From a678dbbeba55c97b92e63f19b7b5ccb1804af97a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=B2=88=E6=98=9F=E7=B9=81?= <ikesnowy@outlook.com>
Date: Thu, 9 Feb 2023 10:01:41 +0800
Subject: [PATCH] fix: domain event dispatch order

---
 .../BaseRepository.cs                              | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/BaseRepository.cs b/src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/BaseRepository.cs
index 8d5ac22..d73f816 100644
--- 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,14 +80,14 @@ 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;
     }
 
@@ -95,7 +95,7 @@ public async Task<IEnumerable<TEntity>> UpdateRangeAsync(IEnumerable<TEntity> en
     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();