LqUserProfileVersionAppenderService.cs
4.49 KB
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
using System;
using System.Linq;
using System.Threading.Tasks;
using NCC.Common.Const;
using NCC.Common.Core.Manager;
using NCC.Dependency;
using NCC.Extend.Entitys.lq_user_profile_version;
using NCC.Extend.Interfaces.UserProfileVersion;
using NCC.Extend.Models;
using NCC.System.Entitys.Permission;
using Newtonsoft.Json;
using SqlSugar;
using Yitter.IdGenerator;
namespace NCC.Extend
{
/// <summary>
/// 用户主档时点全量版本写入（R-004）。
/// </summary>
public class LqUserProfileVersionAppenderService : IUserProfileVersionAppender, ITransient
{
private static readonly JsonSerializerSettings FullSnapshotJsonSettings = new JsonSerializerSettings
{
NullValueHandling = NullValueHandling.Include,
DateFormatString = "yyyy-MM-dd HH:mm:ss",
DateTimeZoneHandling = DateTimeZoneHandling.Local
};
private readonly ISqlSugarClient _db;
public LqUserProfileVersionAppenderService(ISqlSugarClient db)
{
_db = db;
}
/// <inheritdoc />
public async Task AfterUserProfilePersistedAsync(string targetUserId, string changeTrigger, bool forceNewVersion = false)
{
if (string.IsNullOrWhiteSpace(targetUserId))
{
return;
}
var row = await _db.Queryable<UserEntity>()
.Where(x => x.Id == targetUserId)
.FirstAsync();
if (row == null)
{
return;
}
var sanitized = BuildSanitizedUserSnapshot(row);
var fullPayload = new LqUserProfileFullSnapshotDto
{
SchemaVersion = LqUserProfileSnapshotConstants.FullUserSchemaVersion,
User = sanitized
};
var fullJson = JsonConvert.SerializeObject(fullPayload, FullSnapshotJsonSettings);
var lastRows = await _db.Queryable<LqUserProfileVersionEntity>()
.Where(x => x.TargetUserId == targetUserId)
.OrderBy(x => x.VersionNo, OrderByType.Desc)
.Take(1)
.ToListAsync();
var last = lastRows.FirstOrDefault();
if (!forceNewVersion
&& last != null
&& string.Equals(last.FullSnapshotJson ?? string.Empty, fullJson, StringComparison.Ordinal))
{
return;
}
var now = DateTime.Now;
if (last != null)
{
await _db.Updateable<LqUserProfileVersionEntity>()
.SetColumns(x => new LqUserProfileVersionEntity { ValidTo = now })
.Where(x => x.Id == last.Id)
.ExecuteCommandAsync();
}
var (opId, opName) = ResolveOperatorFromClaims();
var ver = new LqUserProfileVersionEntity
{
Id = YitIdHelper.NextId().ToString(),
TargetUserId = row.Id,
VersionNo = (last?.VersionNo ?? 0) + 1,
ValidFrom = now,
ValidTo = null,
OperatorUserId = opId,
OperatorUserName = opName,
ChangeTrigger = changeTrigger,
Mdid = row.Mdid,
Gw = row.Gw,
OrganizeId = row.OrganizeId,
FullSnapshotJson = fullJson
};
await _db.Insertable(ver).ExecuteCommandAsync();
}
private static UserEntity BuildSanitizedUserSnapshot(UserEntity src)
{
var c = UserProfileAuditAppenderService.CloneUser(src);
if (c == null)
{
return null;
}
c.Password = null;
c.Secretkey = null;
return c;
}
private static (string opId, string opName) ResolveOperatorFromClaims()
{
var ctx = App.HttpContext;
if (ctx?.User?.Identity?.IsAuthenticated != true)
{
return (null, "系统");
}
var uid = ctx.User.FindFirst(ClaimConst.CLAINM_USERID)?.Value?.Trim();
var name = ctx.User.FindFirst(ClaimConst.CLAINM_REALNAME)?.Value?.Trim();
if (string.IsNullOrWhiteSpace(name))
{
name = ctx.User.FindFirst(ClaimConst.CLAINM_ACCOUNT)?.Value?.Trim();
}
if (string.IsNullOrWhiteSpace(name))
{
name = "系统";
}
return (uid, name);
}
}
}