判断Transaction 是否rollback

yuzd · yuzd · commit 59823d0dea17 · 2019-09-30T22:50:42.000+08:00
diff --git a/ant.mgr/Repository/Repository/Interceptors/TransactionScope.cs b/ant.mgr/Repository/Repository/Interceptors/TransactionScope.cs
@@ -27,8 +27,9 @@ public override async Task InterceptAsync(IComponentContext context, IInvocation
             using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
             {
                 await proceed(invocation);
-
-                scope.Complete();
+                
+                if(Transaction.Current.TransactionInformation.Status == TransactionStatus.Active)
+                    scope.Complete();
             }
         }
 
@@ -46,7 +47,8 @@ public override async Task<TResult> InterceptAsync<TResult>(IComponentContext co
             {
                 var r = await proceed(invocation);
 
-                scope.Complete();
+                if(Transaction.Current.TransactionInformation.Status == TransactionStatus.Active)
+                    scope.Complete();
 
                 return r;
             }

Original file line number	Diff line number	Diff line change
`@@ -27,8 +27,9 @@ public override async Task InterceptAsync(IComponentContext context, IInvocation`
`27`	`27`	`using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))`
`28`	`28`	`{`
`29`	`29`	`await proceed(invocation);`
`30`		`-`
`31`		`- scope.Complete();`
	`30`	`+`
	`31`	`+ if(Transaction.Current.TransactionInformation.Status == TransactionStatus.Active)`
	`32`	`+ scope.Complete();`
`32`	`33`	`}`
`33`	`34`	`}`
`34`	`35`
`@@ -46,7 +47,8 @@ public override async Task<TResult> InterceptAsync<TResult>(IComponentContext co`
`46`	`47`	`{`
`47`	`48`	`var r = await proceed(invocation);`
`48`	`49`
`49`		`- scope.Complete();`
	`50`	`+ if(Transaction.Current.TransactionInformation.Status == TransactionStatus.Active)`
	`51`	`+ scope.Complete();`
`50`	`52`
`51`	`53`	`return r;`
`52`	`54`	`}`