From 64a2aa2301946f777659239247233e47ad1e3076 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期日, 12 四月 2026 11:54:15 +0800
Subject: [PATCH] feat(事务管理): 添加异步事务处理方法
---
Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs | 17 ++++++-----------
1 files changed, 6 insertions(+), 11 deletions(-)
diff --git a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs
index 2310264..e6f58d7 100644
--- a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs
+++ b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs
@@ -1,13 +1,7 @@
锘縰sing Microsoft.Extensions.Logging;
using SqlSugar;
-using System;
using System.Collections.Concurrent;
-using System.Collections.Generic;
-using System.Linq;
using System.Reflection;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
using WIDESEAWCS_Core.Helper;
namespace WIDESEAWCS_Core.BaseRepository
@@ -16,13 +10,16 @@
{
// 瀹氫箟鏃ュ織璁板綍鍣�
private readonly ILogger<UnitOfWorkManage> _logger;
+
// 瀹氫箟SqlSugarClient
private readonly ISqlSugarClient _sqlSugarClient;
// 瀹氫箟浜嬪姟璁℃暟鍣�
private int _tranCount { get; set; }
+
// 瀹氫箟浜嬪姟璁℃暟鍣ㄧ殑鍙灞炴��
public int TranCount => _tranCount;
+
// 瀹氫箟浜嬪姟鏍�
public readonly ConcurrentStack<string> TranStack = new();
@@ -44,7 +41,6 @@
return _sqlSugarClient as SqlSugarClient;
}
-
// 鍒涘缓UnitOfWork
public UnitOfWork CreateUnitOfWork()
{
@@ -56,7 +52,7 @@
uow.Db.Open();
uow.Tenant.BeginTran();
-
+
_logger.LogDebug("UnitOfWork Begin");
return uow;
}
@@ -101,7 +97,7 @@
}
return content;
}
- catch(Exception ex)
+ catch (Exception ex)
{
RollbackTran();
return WebResponseContent.Instance.Error(ex.Message);
@@ -141,7 +137,6 @@
{
spinner.SpinOnce();
}
-
if (result == method.GetFullName())
{
@@ -209,4 +204,4 @@
}
}
}
-}
+}
\ No newline at end of file
--
Gitblit v1.9.3