添加 WMS 初始项目

z8018

2026-02-11 b8fb68b44c29e4667f6ea5746119413809a60a9e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
using KH.WMS.Core.Database.Repositories;
using KH.WMS.Core.DependencyInjection.ServiceLifetimes;
using Microsoft.AspNetCore.DataProtection.KeyManagement;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using SqlSugar;
 
namespace KH.WMS.Core.Database.SqlSugar;
 
/// <summary>
/// SQL Sugar 数据库上下文（支持事务嵌套）
/// </summary>
[RegisteredService(Lifetime = Microsoft.Extensions.DependencyInjection.ServiceLifetime.Scoped)]
public class SqlSugarDbContext : IDbContext
{
    private readonly ISqlSugarClient _sqlSugarClient;
    private readonly ILogger<SqlSugarDbContext> _logger;
    private readonly DatabaseOptions _options;
 
    // 事务栈，用于支持嵌套事务
    private readonly Stack<TransactionScope> _transactionScopes = new();
 
    public SqlSugarDbContext(
        ISqlSugarClient sqlSugarClient,
        ILogger<SqlSugarDbContext> logger,
        IOptions<DatabaseOptions> options)
    {
        _sqlSugarClient = sqlSugarClient;
        _logger = logger;
        _options = options.Value;
    }
 
    /// <summary>
    /// 获取当前事务隔离级别
    /// </summary>
    public System.Data.IsolationLevel? CurrentIsolationLevel =>
        _transactionScopes.Count > 0 ? _transactionScopes.Peek().IsolationLevel : null;
 
    public ISqlSugarClient Db => _sqlSugarClient;
 
    public async Task BeginTransactionAsync(System.Data.IsolationLevel isolationLevel = System.Data.IsolationLevel.ReadCommitted)
    {
        await _sqlSugarClient.Ado.BeginTranAsync(isolationLevel);
    }
 
    public async Task CommitTransactionAsync()
    {
        await _sqlSugarClient.Ado.CommitTranAsync();
        _logger.LogInformation("事务已提交");
    }
 
    public async Task RollbackTransactionAsync()
    {
        await _sqlSugarClient.Ado.RollbackTranAsync();
        _logger.LogInformation("事务已回滚");
    }
 
    public IRepository<T, TKey> GetRepository<T, TKey>() where T : class, new() where TKey : struct
    {
        return new RepositoryBase<T, TKey>(_sqlSugarClient, _logger);
    }
 
    public void Dispose()
    {
        // 如果有未提交的事务，自动回滚
 
        _sqlSugarClient?.Ado.RollbackTran();
 
        _sqlSugarClient?.Dispose();
    }
 
    IRepository<T, TKey> IDbContext.GetRepository<T, TKey>()
    {
        throw new NotImplementedException();
    }
 
    /// <summary>
    /// 事务作用域
    /// </summary>
    private class TransactionScope
    {
        public System.Data.IsolationLevel IsolationLevel { get; }
        public bool IsCompleted { get; set; }
        public bool RequiresRollback { get; set; }
 
        public TransactionScope(System.Data.IsolationLevel isolationLevel)
        {
            IsolationLevel = isolationLevel;
            IsCompleted = false;
            RequiresRollback = false;
        }
    }
}