fix(Dispatcher): fix transaction rollback (#135)

zhenlei520 · web-flow · commit 54d21905b709 · 2022-07-12T14:31:40.000+08:00
diff --git a/src/Data/Masa.Contrib.Data.UoW.EF/UnitOfWork.cs b/src/Data/Masa.Contrib.Data.UoW.EF/UnitOfWork.cs
@@ -66,9 +66,10 @@ public async Task CommitAsync(CancellationToken cancellationToken = default)
     public async Task RollbackAsync(CancellationToken cancellationToken = default)
     {
         if (!UseTransaction || !TransactionHasBegun)
-            throw new NotSupportedException("Transactions are not opened and rollback is not supported");
+            return;
 
-        await Context.Database.RollbackTransactionAsync(cancellationToken);
+        if (TransactionHasBegun)
+            await Context.Database.RollbackTransactionAsync(cancellationToken);
     }
 
     public Task AddDomainEventAsync<TDomainEvent>(TDomainEvent @event) where TDomainEvent : class

Original file line number	Diff line number	Diff line change
`@@ -66,9 +66,10 @@ public async Task CommitAsync(CancellationToken cancellationToken = default)`
`66`	`66`	`public async Task RollbackAsync(CancellationToken cancellationToken = default)`
`67`	`67`	`{`
`68`	`68`	`if (!UseTransaction \|\| !TransactionHasBegun)`
`69`		`- throw new NotSupportedException("Transactions are not opened and rollback is not supported");`
	`69`	`+ return;`
`70`	`70`
`71`		`- await Context.Database.RollbackTransactionAsync(cancellationToken);`
	`71`	`+ if (TransactionHasBegun)`
	`72`	`+ await Context.Database.RollbackTransactionAsync(cancellationToken);`
`72`	`73`	`}`
`73`	`74`
`74`	`75`	`public Task AddDomainEventAsync<TDomainEvent>(TDomainEvent @event) where TDomainEvent : class`