From 855034287991bb2cb16a3a52e4746105e0679870 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?=
 =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= <falldimka007@gmail.com>
Date: Fri, 16 Feb 2024 12:00:46 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A4=D0=B8=D0=BA=D1=81=20ChangeLogRepository?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Repository/ChangeLogRepositoryAbstract.cs | 27 ++++++++++++++-----
 1 file changed, 21 insertions(+), 6 deletions(-)

diff --git a/AsbCloudInfrastructure/Repository/ChangeLogRepositoryAbstract.cs b/AsbCloudInfrastructure/Repository/ChangeLogRepositoryAbstract.cs
index f9265ba8..61e5bdcb 100644
--- a/AsbCloudInfrastructure/Repository/ChangeLogRepositoryAbstract.cs
+++ b/AsbCloudInfrastructure/Repository/ChangeLogRepositoryAbstract.cs
@@ -30,7 +30,6 @@ public abstract class ChangeLogRepositoryAbstract<TDto, TEntity, TRequest> : ICh
         var result = 0;
         if (dtos.Any())
         {
-            using var transaction = await db.Database.BeginTransactionAsync(token);
             var entities = dtos.Select(Convert);
             var creation = DateTimeOffset.UtcNow;
             var dbSet = db.Set<TEntity>();
@@ -47,7 +46,6 @@ public abstract class ChangeLogRepositoryAbstract<TDto, TEntity, TRequest> : ICh
             }
 
             result += await SaveChangesWithExceptionHandling(token);
-            await transaction.CommitAsync(token);
         }
         return result;
     }
@@ -104,8 +102,17 @@ public abstract class ChangeLogRepositoryAbstract<TDto, TEntity, TRequest> : ICh
         }
 
         result += await SaveChangesWithExceptionHandling(token);
-        await transaction.CommitAsync(token);
-        return result;
+
+        try
+        {
+            await transaction.CommitAsync(token);
+            return result;
+        }
+        catch
+        {
+            await transaction.RollbackAsync(token);
+            throw;
+        }
     }
 
     public async Task<int> UpdateOrInsertRange(int idUser, IEnumerable<TDto> dtos, CancellationToken token)
@@ -148,8 +155,16 @@ public abstract class ChangeLogRepositoryAbstract<TDto, TEntity, TRequest> : ICh
         using var transaction = await db.Database.BeginTransactionAsync(token);
         result += await Clear(idUser, request, token);
         result += await InsertRange(idUser, dtos, token);
-        await transaction.CommitAsync(token);
-        return result;
+        try
+        {
+            await transaction.CommitAsync(token);
+            return result;
+        }
+        catch
+        {
+            await transaction.RollbackAsync(token);
+            throw;
+        }
     }
 
     public async Task<int> DeleteRange(int idUser, IEnumerable<int> ids, CancellationToken token)