remove DomainEventUnitOfWorkBehavior，不支持在domainEvent中处理事务

netcorepal · Dec 28, 2023 · a706a8d · a706a8d
1 parent d1ff8c1
commit a706a8d
Show file tree

Hide file tree

Showing 3 changed files with 47 additions and 47 deletions.
diff --git a/eng/versions.props b/eng/versions.props
@@ -1,6 +1,6 @@
 <Project>
   <PropertyGroup>
-    <VersionPrefix>1.0.2</VersionPrefix>
+    <VersionPrefix>1.0.3</VersionPrefix>
     <VersionSuffix></VersionSuffix>
   </PropertyGroup>
 </Project>
diff --git a/src/Repository.EntityFrameworkCore/Behaviors/DomainEventUnitOfWorkBehavior.cs b/src/Repository.EntityFrameworkCore/Behaviors/DomainEventUnitOfWorkBehavior.cs
@@ -1,43 +1,44 @@
-using MediatR;
-using NetCorePal.Extensions.Domain;
-using NetCorePal.Extensions.Primitives;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace NetCorePal.Extensions.Repository.EntityFrameworkCore
-{
-
-    internal class DomainEventUnitOfWorkBehavior<TDomanEvent, TResponse> : IPipelineBehavior<TDomanEvent, TResponse> where TDomanEvent : IDomainEvent
-    {
-        private readonly ITransactionUnitOfWork _unitOfWork;
-        public DomainEventUnitOfWorkBehavior(ITransactionUnitOfWork unitOfWork)
-        {
-            _unitOfWork = unitOfWork;
-        }
-
-
-        public async Task<TResponse> Handle(TDomanEvent request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
-        {
-            if (_unitOfWork.CurrentTransaction != null)
-            {
-                var response = await next();
-                await _unitOfWork.SaveEntitiesAsync(cancellationToken);
-                return response;
-            }
-
-
-            using (var transaction = _unitOfWork.BeginTransaction())
-            {
-                var response = await next();
-                await _unitOfWork.SaveEntitiesAsync(cancellationToken);
-                await _unitOfWork.CommitAsync(cancellationToken);
-                return response;
-            }
-        }
-    }
-
-
-}
+// using MediatR;
+// using NetCorePal.Extensions.Domain;
+// using NetCorePal.Extensions.Primitives;
+// using System;
+// using System.Collections.Generic;
+// using System.Linq;
+// using System.Text;
+// using System.Threading.Tasks;
+//
+// namespace NetCorePal.Extensions.Repository.EntityFrameworkCore
+// {
+//
+//     
+//     internal class DomainEventUnitOfWorkBehavior<TDomanEvent, TResponse> : IPipelineBehavior<TDomanEvent, TResponse> where TDomanEvent : IDomainEvent
+//     {
+//         private readonly ITransactionUnitOfWork _unitOfWork;
+//         public DomainEventUnitOfWorkBehavior(ITransactionUnitOfWork unitOfWork)
+//         {
+//             _unitOfWork = unitOfWork;
+//         }
+//
+//
+//         public async Task<TResponse> Handle(TDomanEvent request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
+//         {
+//             if (_unitOfWork.CurrentTransaction != null)
+//             {
+//                 var response = await next();
+//                 await _unitOfWork.SaveEntitiesAsync(cancellationToken);
+//                 return response;
+//             }
+//
+//
+//             using (var transaction = _unitOfWork.BeginTransaction())
+//             {
+//                 var response = await next();
+//                 await _unitOfWork.SaveEntitiesAsync(cancellationToken);
+//                 await _unitOfWork.CommitAsync(cancellationToken);
+//                 return response;
+//             }
+//         }
+//     }
+//
+//
+// }
diff --git a/src/Repository.EntityFrameworkCore/Extensions/ServiceCollectionExtensions.cs b/src/Repository.EntityFrameworkCore/Extensions/ServiceCollectionExtensions.cs
@@ -9,7 +9,6 @@ namespace NetCorePal.Extensions.DependencyInjection
 {
     public static class ServiceCollectionExtensions
     {
-
         /// <summary>
         /// Scan assemblies add all IRepository to ServiceCollection
         /// </summary>
@@ -27,7 +26,8 @@ public static IServiceCollection AddRepositories(this IServiceCollection service
             {
                 services.TryAddScoped(repositoryType);
                 var repositoryInterfaceType = repositoryType.GetInterfaces()
-                    .FirstOrDefault(x => !x.IsGenericType && Array.Exists(x.GetInterfaces(), i => i.IsGenericType && i.GetGenericTypeDefinition() == typeof(IRepository<>)));
+                    .FirstOrDefault(x => !x.IsGenericType && Array.Exists(x.GetInterfaces(),
+                        i => i.IsGenericType && i.GetGenericTypeDefinition() == typeof(IRepository<>)));
 
                 if (repositoryInterfaceType == null)
                     continue;
@@ -49,7 +49,6 @@ public static IServiceCollection AddUnitOfWork<TDbContext>(this IServiceCollecti
         public static MediatRServiceConfiguration AddUnitOfWorkBehaviors(this MediatRServiceConfiguration cfg)
         {
             cfg.AddOpenBehavior(typeof(CommandUnitOfWorkBehavior<,>));
-            cfg.AddOpenBehavior(typeof(DomainEventUnitOfWorkBehavior<,>));
             return cfg;
         }
     }