优化代码结构和错误处理

肖洋

2025-01-19 d59b540dd78d49ddf1f2e1c6dfb7b19a7d3e3d7c

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
94
95
96
97
98
99
100
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Core.Const;
using WIDESEAWCS_Core.DB.Models;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_Core.HttpContextUser;
using WIDESEAWCS_Core.Tenants;
 
namespace WIDESEAWCS_Core.AOP
{
    public static class SqlSugarAop
    {
        public static void DataExecuting(object oldValue, DataFilterModel entityInfo)
        {
            if (entityInfo.EntityValue is BaseEntity baseEntity)
            {
                // 新增操作
                if (entityInfo.OperationType == DataFilterType.InsertByObject)
                {
                    if (entityInfo.PropertyName == nameof(BaseEntity.CreateDate))
                    {
                        baseEntity.CreateDate = DateTime.Now;
                    }
                }
 
                else if (entityInfo.OperationType == DataFilterType.UpdateByObject)
                {
                    baseEntity.ModifyDate = DateTime.Now;
                }
 
                try
                {
                    if (App.User?.UserId > 0)
                    {
                        switch (entityInfo.OperationType)
                        {
                            case DataFilterType.UpdateByObject:
                                baseEntity.Modifier = App.User.UserName;
                                break;
                            case DataFilterType.InsertByObject:
                                baseEntity.Creater = App.User.UserName;
                                break;
                        }
                    }
                    else
                    {
                        switch (entityInfo.OperationType)
                        {
                            case DataFilterType.UpdateByObject:
                                baseEntity.Modifier = "System";
                                break;
                            case DataFilterType.InsertByObject:
                                baseEntity.Creater = "System";
                                break;
                        }
                    }
                }
                catch (NullReferenceException)
                {
                    switch (entityInfo.OperationType)
                    {
                        case DataFilterType.UpdateByObject:
                            baseEntity.Modifier = "System";
                            break;
                        case DataFilterType.InsertByObject:
                            baseEntity.Creater = "System";
                            break;
                    }
                }
                
            }
        }
 
        private static string GetWholeSql(SugarParameter[] paramArr, string sql)
        {
            foreach (var param in paramArr)
            {
                sql = sql.Replace(param.ParameterName, $@"'{param.Value.ObjToString()}'");
            }
 
            return sql;
        }
 
        private static string GetParas(SugarParameter[] pars)
        {
            string key = "【SQL参数】：";
            foreach (var param in pars)
            {
                key += $"{param.ParameterName}:{param.Value}\n";
            }
 
            return key;
        }
    }
}