逻辑删除异常修复

Author: Coldairarrow

src/Coldairarrow.Util/01.Coldairarrow.Util.csproj

@@ -32,7 +32,7 @@
     <PackageReference Include="AutoMapper" Version="9.0.0" />
     <PackageReference Include="Caching.CSRedis" Version="3.6.2" />
     <PackageReference Include="CSRedisCore" Version="3.6.2" />
-    <PackageReference Include="EFCore.Sharding" Version="3.1.3.36" />
+    <PackageReference Include="EFCore.Sharding" Version="3.1.3.39" />
     <PackageReference Include="EFCore.Sharding.SqlServer" Version="3.1.3" />
     <PackageReference Include="IdHelper.Zookeeper" Version="1.5.1" />
     <PackageReference Include="Microsoft.AspNetCore" Version="2.2.0" />

src/Coldairarrow.Util/AOP/TransactionalAttribute.cs

@@ -45,10 +45,15 @@ public TransactionContainer(IServiceProvider serviceProvider)
         {
             _distributedTransaction = DistributedTransactionFactory.GetDistributedTransaction();
 
-            var repositories = GlobalData.AllFxTypes.Where(x =>
-                  typeof(IRepository).IsAssignableFrom(x)
-                  && x.IsInterface
-                ).Select(x => serviceProvider.GetService(x) as IRepository)
+            var allRepositoryInterfaces = GlobalData.AllFxTypes.Where(x =>
+                    typeof(IRepository).IsAssignableFrom(x)
+                    && x.IsInterface
+                    && x != typeof(IRepository)
+                ).ToList();
+            allRepositoryInterfaces.Add(typeof(IRepository));
+
+            var repositories = allRepositoryInterfaces
+                .Select(x => serviceProvider.GetService(x) as IRepository)
                 .ToArray();
 
             _distributedTransaction.AddRepository(repositories);

src/Coldairarrow.Util/GlobalData.cs

@@ -1,5 +1,4 @@
-using EFCore.Sharding;
-using System;
+using System;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
@@ -45,8 +44,6 @@ public static List<Type> AllFxTypes
 
                                     }
                                 });
-
-                            _allFxTypes.Add(typeof(IRepository));
                         }
                     }
                 }