feat(事务管理): 添加异步事务处理方法

wanshenmean

4 天以前 64a2aa2301946f777659239247233e47ad1e3076

 Code/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/UnitOfWorks/UnitOfWorkManage.cs

@@ -100,6 +100,32 @@
            }
        }

        private readonly SemaphoreSlim _asyncLock = new SemaphoreSlim(1, 1);

        public async Task<WebResponseContent> BeginTranAsync(Func<Task<WebResponseContent>> funcAsync)
        {
            await _asyncLock.WaitAsync();
            try
            {
                BeginTran();   // 假设这是同步方法，启动事务
                WebResponseContent content = await funcAsync();
                if (content.Status)
                    CommitTran();   // 同步提交
                else
                    RollbackTran(); // 同步回滚
                return content;
            }
            catch (Exception ex)
            {
                RollbackTran();
                return WebResponseContent.Instance.Error(ex.Message);
            }
            finally
            {
                _asyncLock.Release();
            }
        }

        public void CommitTran()
        {
            lock (this)