|
|
@ -1,224 +1,93 @@ |
|
|
using Microsoft.Extensions.Options; |
|
|
using JetBrains.Annotations; |
|
|
|
|
|
using LINGYUN.Abp.Dynamic.Definitions; |
|
|
|
|
|
using Microsoft.Extensions.Options; |
|
|
using System.Collections.Generic; |
|
|
using System.Collections.Generic; |
|
|
using System.Collections.Immutable; |
|
|
|
|
|
using System.Linq; |
|
|
|
|
|
using System.Threading.Tasks; |
|
|
using System.Threading.Tasks; |
|
|
using Volo.Abp; |
|
|
using Volo.Abp; |
|
|
using Volo.Abp.DependencyInjection; |
|
|
using Volo.Abp.DependencyInjection; |
|
|
|
|
|
|
|
|
namespace LINGYUN.Abp.Notifications; |
|
|
namespace LINGYUN.Abp.Notifications; |
|
|
|
|
|
|
|
|
public class NotificationDefinitionManager : INotificationDefinitionManager, ITransientDependency |
|
|
public class NotificationDefinitionManager : |
|
|
|
|
|
DynamicDefinitionManager<NotificationGroupDefinition, NotificationDefinition>, |
|
|
|
|
|
INotificationDefinitionManager, |
|
|
|
|
|
ITransientDependency |
|
|
{ |
|
|
{ |
|
|
private readonly AbpNotificationsOptions _notificationsOptions; |
|
|
protected IStaticNotificationDefinitionStore StaticStore { get; } |
|
|
private readonly IStaticNotificationDefinitionStore _staticStore; |
|
|
protected IDynamicNotificationDefinitionStore DynamicStore { get; } |
|
|
private readonly IDynamicNotificationDefinitionStore _dynamicStore; |
|
|
|
|
|
|
|
|
|
|
|
public NotificationDefinitionManager( |
|
|
public NotificationDefinitionManager( |
|
|
IStaticNotificationDefinitionStore staticStore, |
|
|
IStaticNotificationDefinitionStore staticStore, |
|
|
IDynamicNotificationDefinitionStore dynamicStore, |
|
|
IDynamicNotificationDefinitionStore dynamicStore, |
|
|
IOptions<AbpNotificationsOptions> notificationsOptions) |
|
|
IOptions<AbpDynamicDefinitionsOptions> options) : base(options) |
|
|
{ |
|
|
{ |
|
|
_staticStore = staticStore; |
|
|
StaticStore = staticStore; |
|
|
_dynamicStore = dynamicStore; |
|
|
DynamicStore = dynamicStore; |
|
|
_notificationsOptions = notificationsOptions.Value; |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public async virtual Task<NotificationDefinition> GetAsync(string name) |
|
|
public async virtual Task<NotificationDefinition> GetAsync([NotNull] string name) |
|
|
{ |
|
|
{ |
|
|
var notification = await GetOrNullAsync(name); |
|
|
return await GetOrNullAsync(name) ?? throw new AbpException("Undefined notification: " + name); |
|
|
if (notification == null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new AbpException("Undefined notification: " + name); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return notification; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public async virtual Task<NotificationDefinition?> GetOrNullAsync(string name) |
|
|
|
|
|
{ |
|
|
|
|
|
Check.NotNull(name, nameof(name)); |
|
|
|
|
|
|
|
|
|
|
|
var staticDefinition = await _staticStore.GetOrNullAsync(name); |
|
|
|
|
|
var dynamicDefinition = await _dynamicStore.GetOrNullAsync(name); |
|
|
|
|
|
|
|
|
|
|
|
if (staticDefinition != null && dynamicDefinition != null) |
|
|
|
|
|
{ |
|
|
|
|
|
return _notificationsOptions.DynamicNotificationStrategy switch |
|
|
|
|
|
{ |
|
|
|
|
|
DynamicNotificationStrategy.Ignore => staticDefinition, |
|
|
|
|
|
DynamicNotificationStrategy.Covering => dynamicDefinition, |
|
|
|
|
|
DynamicNotificationStrategy.Merge => MergeNotification(staticDefinition, dynamicDefinition), |
|
|
|
|
|
_ => staticDefinition |
|
|
|
|
|
}; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return staticDefinition ?? dynamicDefinition; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public async virtual Task<IReadOnlyList<NotificationDefinition>> GetNotificationsAsync() |
|
|
|
|
|
{ |
|
|
|
|
|
var staticNotifications = await _staticStore.GetNotificationsAsync(); |
|
|
|
|
|
var dynamicNotifications = await _dynamicStore.GetNotificationsAsync(); |
|
|
|
|
|
|
|
|
|
|
|
// 根据策略处理通知定义
|
|
|
|
|
|
return _notificationsOptions.DynamicNotificationStrategy switch |
|
|
|
|
|
{ |
|
|
|
|
|
DynamicNotificationStrategy.Ignore => await GetNotificationsWithIgnoreStrategy(staticNotifications, dynamicNotifications), |
|
|
|
|
|
DynamicNotificationStrategy.Covering => await GetNotificationsWithCoveringStrategy(staticNotifications, dynamicNotifications), |
|
|
|
|
|
DynamicNotificationStrategy.Merge => await GetNotificationsWithMergeStrategy(staticNotifications, dynamicNotifications), |
|
|
|
|
|
_ => await GetNotificationsWithIgnoreStrategy(staticNotifications, dynamicNotifications) |
|
|
|
|
|
}; |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public async virtual Task<NotificationGroupDefinition?> GetGroupOrNullAsync(string name) |
|
|
public async virtual Task<NotificationGroupDefinition?> GetGroupOrNullAsync(string name) |
|
|
{ |
|
|
{ |
|
|
Check.NotNull(name, nameof(name)); |
|
|
Check.NotNull(name, nameof(name)); |
|
|
|
|
|
|
|
|
var staticDefinition = await _staticStore.GetGroupOrNullAsync(name); |
|
|
var staticGroupDefinition = await StaticStore.GetGroupOrNullAsync(name); |
|
|
var dynamicDefinition = await _dynamicStore.GetGroupOrNullAsync(name); |
|
|
var dynamicGroupDefinition = await DynamicStore.GetGroupOrNullAsync(name); |
|
|
|
|
|
|
|
|
if (staticDefinition != null && dynamicDefinition != null) |
|
|
|
|
|
{ |
|
|
|
|
|
switch (_notificationsOptions.DynamicNotificationStrategy) |
|
|
|
|
|
{ |
|
|
|
|
|
case DynamicNotificationStrategy.Ignore: |
|
|
|
|
|
return staticDefinition; |
|
|
|
|
|
case DynamicNotificationStrategy.Covering: |
|
|
|
|
|
return dynamicDefinition; |
|
|
|
|
|
case DynamicNotificationStrategy.Merge: |
|
|
|
|
|
MergeGroupNotifications(staticDefinition, dynamicDefinition); |
|
|
|
|
|
return staticDefinition; |
|
|
|
|
|
default: |
|
|
|
|
|
return staticDefinition; |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return staticDefinition ?? dynamicDefinition; |
|
|
return await GetGroupDefinitionAsync(staticGroupDefinition, dynamicGroupDefinition); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public async virtual Task<IReadOnlyList<NotificationGroupDefinition>> GetGroupsAsync() |
|
|
public async virtual Task<IReadOnlyList<NotificationGroupDefinition>> GetGroupsAsync() |
|
|
{ |
|
|
{ |
|
|
var staticGroups = await _staticStore.GetGroupsAsync(); |
|
|
var staticGroupDefinitions = await StaticStore.GetGroupsAsync(); |
|
|
var dynamicGroups = await _dynamicStore.GetGroupsAsync(); |
|
|
var dynamicGroupDefinitions = await DynamicStore.GetGroupsAsync(); |
|
|
|
|
|
|
|
|
// 根据策略处理分组定义
|
|
|
return await GetGroupDefinitionsAsync(staticGroupDefinitions, dynamicGroupDefinitions); |
|
|
return _notificationsOptions.DynamicNotificationStrategy switch |
|
|
|
|
|
{ |
|
|
|
|
|
DynamicNotificationStrategy.Ignore => await GetGroupsWithIgnoreStrategy(staticGroups, dynamicGroups), |
|
|
|
|
|
DynamicNotificationStrategy.Covering => await GetGroupsWithCoveringStrategy(staticGroups, dynamicGroups), |
|
|
|
|
|
DynamicNotificationStrategy.Merge => await GetGroupsWithMergeStrategy(staticGroups, dynamicGroups), |
|
|
|
|
|
_ => await GetGroupsWithIgnoreStrategy(staticGroups, dynamicGroups) |
|
|
|
|
|
}; |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
#region 通知定义策略
|
|
|
public async virtual Task<IReadOnlyList<NotificationDefinition>> GetNotificationsAsync() |
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
|
/// 忽略策略：静态优先，过滤掉同名的动态通知
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationDefinition>> GetNotificationsWithIgnoreStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> staticNotifications, |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> dynamicNotifications) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var staticNotificationNames = staticNotifications |
|
|
var staticDefinitions = await StaticStore.GetNotificationsAsync(); |
|
|
.Select(p => p.Name) |
|
|
var dynamicDefinitions = await DynamicStore.GetNotificationsAsync(); |
|
|
.ToImmutableHashSet(); |
|
|
|
|
|
|
|
|
return await GetDefinitionsAsync(staticDefinitions, dynamicDefinitions); |
|
|
return Task.FromResult<IReadOnlyList<NotificationDefinition>>( |
|
|
|
|
|
staticNotifications |
|
|
|
|
|
.Concat(dynamicNotifications.Where(d => !staticNotificationNames.Contains(d.Name))) |
|
|
|
|
|
.ToImmutableList() |
|
|
|
|
|
); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
public async virtual Task<NotificationDefinition?> GetOrNullAsync(string name) |
|
|
/// 覆盖策略：动态完全覆盖静态通知
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationDefinition>> GetNotificationsWithCoveringStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> staticNotifications, |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> dynamicNotifications) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var dynamicNotificationNames = dynamicNotifications |
|
|
Check.NotNull(name, nameof(name)); |
|
|
.Select(p => p.Name) |
|
|
|
|
|
.ToImmutableHashSet(); |
|
|
|
|
|
|
|
|
|
|
|
// 动态通知完全覆盖静态通知
|
|
|
var staticDefinition = await StaticStore.GetOrNullAsync(name); |
|
|
var result = dynamicNotifications |
|
|
var dynamicDefinition = await DynamicStore.GetOrNullAsync(name); |
|
|
.Concat(staticNotifications.Where(s => !dynamicNotificationNames.Contains(s.Name))) |
|
|
|
|
|
.ToImmutableList(); |
|
|
|
|
|
|
|
|
|
|
|
return Task.FromResult<IReadOnlyList<NotificationDefinition>>(result); |
|
|
return await GetDefinitionAsync(staticDefinition, dynamicDefinition); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
protected override string GetDefinitionKey(NotificationDefinition definition) |
|
|
/// 合并策略：合并静态和动态通知，创建新实例
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationDefinition>> GetNotificationsWithMergeStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> staticNotifications, |
|
|
|
|
|
IReadOnlyList<NotificationDefinition> dynamicNotifications) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var mergedNotifications = new Dictionary<string, NotificationDefinition>(); |
|
|
return definition.Name; |
|
|
|
|
|
|
|
|
// 先添加所有静态通知
|
|
|
|
|
|
foreach (var staticNotification in staticNotifications) |
|
|
|
|
|
{ |
|
|
|
|
|
mergedNotifications[staticNotification.Name] = staticNotification; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// 合并动态通知
|
|
|
|
|
|
foreach (var dynamicNotification in dynamicNotifications) |
|
|
|
|
|
{ |
|
|
|
|
|
if (mergedNotifications.TryGetValue(dynamicNotification.Name, out var existingNotification)) |
|
|
|
|
|
{ |
|
|
|
|
|
// 通知已存在，创建新的合并通知
|
|
|
|
|
|
var mergedNotification = MergeNotification(existingNotification, dynamicNotification); |
|
|
|
|
|
mergedNotifications[dynamicNotification.Name] = mergedNotification; |
|
|
|
|
|
} |
|
|
|
|
|
else |
|
|
|
|
|
{ |
|
|
|
|
|
// 添加新的动态通知
|
|
|
|
|
|
mergedNotifications[dynamicNotification.Name] = dynamicNotification; |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return Task.FromResult<IReadOnlyList<NotificationDefinition>>(mergedNotifications.Values.ToImmutableList()); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
protected override Task<NotificationDefinition> MergeDefinitionAsync(NotificationDefinition targetDefinition, NotificationDefinition sourceDefinition) |
|
|
/// 合并两个通知定义，返回新的 NotificationDefinition 实例
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual NotificationDefinition MergeNotification( |
|
|
|
|
|
NotificationDefinition staticNotification, |
|
|
|
|
|
NotificationDefinition dynamicNotification) |
|
|
|
|
|
{ |
|
|
{ |
|
|
// 决定使用哪个显示名称（优先使用动态的）
|
|
|
var displayName = sourceDefinition.DisplayName ?? targetDefinition.DisplayName; |
|
|
var displayName = dynamicNotification.DisplayName ?? staticNotification.DisplayName; |
|
|
var description = sourceDefinition.Description ?? targetDefinition.Description; |
|
|
|
|
|
var notificationType = sourceDefinition.NotificationType != NotificationType.Application |
|
|
// 决定使用哪个描述（优先使用动态的）
|
|
|
? sourceDefinition.NotificationType |
|
|
var description = dynamicNotification.Description ?? staticNotification.Description; |
|
|
: targetDefinition.NotificationType; |
|
|
|
|
|
var lifetime = sourceDefinition.NotificationLifetime != NotificationLifetime.Persistent |
|
|
// 决定通知类型（优先使用动态的）
|
|
|
? sourceDefinition.NotificationLifetime |
|
|
var notificationType = dynamicNotification.NotificationType != NotificationType.Application |
|
|
: targetDefinition.NotificationLifetime; |
|
|
? dynamicNotification.NotificationType |
|
|
var contentType = sourceDefinition.ContentType != NotificationContentType.Text |
|
|
: staticNotification.NotificationType; |
|
|
? sourceDefinition.ContentType |
|
|
|
|
|
: targetDefinition.ContentType; |
|
|
// 决定存活类型（优先使用动态的）
|
|
|
var allowSubscriptionToClients = sourceDefinition.AllowSubscriptionToClients || targetDefinition.AllowSubscriptionToClients; |
|
|
var lifetime = dynamicNotification.NotificationLifetime != NotificationLifetime.Persistent |
|
|
|
|
|
? dynamicNotification.NotificationLifetime |
|
|
|
|
|
: staticNotification.NotificationLifetime; |
|
|
|
|
|
|
|
|
|
|
|
// 决定内容类型（优先使用动态的）
|
|
|
|
|
|
var contentType = dynamicNotification.ContentType != NotificationContentType.Text |
|
|
|
|
|
? dynamicNotification.ContentType |
|
|
|
|
|
: staticNotification.ContentType; |
|
|
|
|
|
|
|
|
|
|
|
// 决定是否允许客户端订阅（优先使用动态的）
|
|
|
|
|
|
var allowSubscriptionToClients = dynamicNotification.AllowSubscriptionToClients || staticNotification.AllowSubscriptionToClients; |
|
|
|
|
|
|
|
|
|
|
|
// 创建新的通知实例
|
|
|
|
|
|
var mergedNotification = new NotificationDefinition( |
|
|
var mergedNotification = new NotificationDefinition( |
|
|
staticNotification.Name, // 保持名称不变
|
|
|
targetDefinition.Name, |
|
|
displayName, |
|
|
displayName, |
|
|
description, |
|
|
description, |
|
|
notificationType, |
|
|
notificationType, |
|
|
@ -227,20 +96,17 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
allowSubscriptionToClients |
|
|
allowSubscriptionToClients |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
// 复制静态通知的属性
|
|
|
foreach (var property in targetDefinition.Properties) |
|
|
foreach (var property in staticNotification.Properties) |
|
|
|
|
|
{ |
|
|
{ |
|
|
mergedNotification.Properties[property.Key] = property.Value; |
|
|
mergedNotification.Properties[property.Key] = property.Value; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 复制动态通知的属性（覆盖同名的静态属性）
|
|
|
foreach (var property in sourceDefinition.Properties) |
|
|
foreach (var property in dynamicNotification.Properties) |
|
|
|
|
|
{ |
|
|
{ |
|
|
mergedNotification.Properties[property.Key] = property.Value; |
|
|
mergedNotification.Properties[property.Key] = property.Value; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 合并提供者
|
|
|
foreach (var provider in targetDefinition.Providers) |
|
|
foreach (var provider in staticNotification.Providers) |
|
|
|
|
|
{ |
|
|
{ |
|
|
if (!mergedNotification.Providers.Contains(provider)) |
|
|
if (!mergedNotification.Providers.Contains(provider)) |
|
|
{ |
|
|
{ |
|
|
@ -248,7 +114,7 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
foreach (var provider in dynamicNotification.Providers) |
|
|
foreach (var provider in sourceDefinition.Providers) |
|
|
{ |
|
|
{ |
|
|
if (!mergedNotification.Providers.Contains(provider)) |
|
|
if (!mergedNotification.Providers.Contains(provider)) |
|
|
{ |
|
|
{ |
|
|
@ -256,107 +122,32 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 合并模板（优先使用动态的）
|
|
|
if (sourceDefinition.Template != null) |
|
|
if (dynamicNotification.Template != null) |
|
|
|
|
|
{ |
|
|
{ |
|
|
mergedNotification.WithTemplate(dynamicNotification.Template); |
|
|
mergedNotification.WithTemplate(sourceDefinition.Template); |
|
|
} |
|
|
} |
|
|
else if (staticNotification.Template != null) |
|
|
else if (targetDefinition.Template != null) |
|
|
{ |
|
|
{ |
|
|
mergedNotification.WithTemplate(staticNotification.Template); |
|
|
mergedNotification.WithTemplate(targetDefinition.Template); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return mergedNotification; |
|
|
return Task.FromResult(mergedNotification); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
#endregion
|
|
|
protected override string GetGroupDefinitionKey(NotificationGroupDefinition groupDefinition) |
|
|
|
|
|
|
|
|
#region 分组定义策略
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
|
/// 忽略策略：静态优先，过滤掉同名的动态分组
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationGroupDefinition>> GetGroupsWithIgnoreStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> staticGroups, |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> dynamicGroups) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var staticGroupNames = staticGroups |
|
|
return groupDefinition.Name; |
|
|
.Select(p => p.Name) |
|
|
|
|
|
.ToImmutableHashSet(); |
|
|
|
|
|
|
|
|
|
|
|
return Task.FromResult<IReadOnlyList<NotificationGroupDefinition>>( |
|
|
|
|
|
staticGroups |
|
|
|
|
|
.Concat(dynamicGroups.Where(d => !staticGroupNames.Contains(d.Name))) |
|
|
|
|
|
.ToImmutableList() |
|
|
|
|
|
); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
|
/// 覆盖策略：动态完全覆盖静态分组
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationGroupDefinition>> GetGroupsWithCoveringStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> staticGroups, |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> dynamicGroups) |
|
|
|
|
|
{ |
|
|
|
|
|
var dynamicGroupNames = dynamicGroups |
|
|
|
|
|
.Select(p => p.Name) |
|
|
|
|
|
.ToImmutableHashSet(); |
|
|
|
|
|
|
|
|
|
|
|
var result = dynamicGroups |
|
|
|
|
|
.Concat(staticGroups.Where(s => !dynamicGroupNames.Contains(s.Name))) |
|
|
|
|
|
.ToImmutableList(); |
|
|
|
|
|
|
|
|
|
|
|
return Task.FromResult<IReadOnlyList<NotificationGroupDefinition>>(result); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
protected override Task MergeGroupDefinitionAsync(NotificationGroupDefinition targetGroupDefinition, NotificationGroupDefinition sourceGroupDefinition) |
|
|
/// 合并策略：合并静态和动态分组
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
protected virtual Task<IReadOnlyList<NotificationGroupDefinition>> GetGroupsWithMergeStrategy( |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> staticGroups, |
|
|
|
|
|
IReadOnlyList<NotificationGroupDefinition> dynamicGroups) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var mergedGroups = new Dictionary<string, NotificationGroupDefinition>(); |
|
|
foreach (var sourceNotification in sourceGroupDefinition.Notifications) |
|
|
|
|
|
|
|
|
// 先添加所有静态分组
|
|
|
|
|
|
foreach (var staticGroup in staticGroups) |
|
|
|
|
|
{ |
|
|
|
|
|
mergedGroups[staticGroup.Name] = staticGroup; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// 合并动态分组
|
|
|
|
|
|
foreach (var dynamicGroup in dynamicGroups) |
|
|
|
|
|
{ |
|
|
|
|
|
if (mergedGroups.TryGetValue(dynamicGroup.Name, out var existingGroup)) |
|
|
|
|
|
{ |
|
|
|
|
|
// 分组已存在，合并通知
|
|
|
|
|
|
MergeGroupNotifications(existingGroup, dynamicGroup); |
|
|
|
|
|
} |
|
|
|
|
|
else |
|
|
|
|
|
{ |
|
|
|
|
|
// 添加新的动态分组
|
|
|
|
|
|
mergedGroups[dynamicGroup.Name] = dynamicGroup; |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return Task.FromResult<IReadOnlyList<NotificationGroupDefinition>>( |
|
|
|
|
|
mergedGroups.Values.ToImmutableList() |
|
|
|
|
|
); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
|
/// 合并分组的通知列表
|
|
|
|
|
|
/// </summary>
|
|
|
|
|
|
private static void MergeGroupNotifications(NotificationGroupDefinition target, NotificationGroupDefinition source) |
|
|
|
|
|
{ |
|
|
|
|
|
foreach (var sourceNotification in source.Notifications) |
|
|
|
|
|
{ |
|
|
{ |
|
|
var existingNotification = target.GetNotificationOrNull(sourceNotification.Name); |
|
|
var existingNotification = targetGroupDefinition.GetNotificationOrNull(sourceNotification.Name); |
|
|
|
|
|
|
|
|
if (existingNotification == null) |
|
|
if (existingNotification == null) |
|
|
{ |
|
|
{ |
|
|
// 通知不存在，直接添加
|
|
|
var newNotification = targetGroupDefinition.AddNotification( |
|
|
var newNotification = target.AddNotification( |
|
|
|
|
|
sourceNotification.Name, |
|
|
sourceNotification.Name, |
|
|
sourceNotification.DisplayName, |
|
|
sourceNotification.DisplayName, |
|
|
sourceNotification.Description, |
|
|
sourceNotification.Description, |
|
|
@ -366,7 +157,6 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
sourceNotification.AllowSubscriptionToClients |
|
|
sourceNotification.AllowSubscriptionToClients |
|
|
); |
|
|
); |
|
|
|
|
|
|
|
|
// 复制提供者
|
|
|
|
|
|
foreach (var provider in sourceNotification.Providers) |
|
|
foreach (var provider in sourceNotification.Providers) |
|
|
{ |
|
|
{ |
|
|
if (!newNotification.Providers.Contains(provider)) |
|
|
if (!newNotification.Providers.Contains(provider)) |
|
|
@ -375,13 +165,11 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 复制属性
|
|
|
|
|
|
foreach (var property in sourceNotification.Properties) |
|
|
foreach (var property in sourceNotification.Properties) |
|
|
{ |
|
|
{ |
|
|
newNotification.Properties[property.Key] = property.Value; |
|
|
newNotification.Properties[property.Key] = property.Value; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 复制模板
|
|
|
|
|
|
if (sourceNotification.Template != null) |
|
|
if (sourceNotification.Template != null) |
|
|
{ |
|
|
{ |
|
|
newNotification.WithTemplate(sourceNotification.Template); |
|
|
newNotification.WithTemplate(sourceNotification.Template); |
|
|
@ -389,13 +177,11 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
} |
|
|
} |
|
|
else |
|
|
else |
|
|
{ |
|
|
{ |
|
|
// 通知已存在，合并属性
|
|
|
|
|
|
foreach (var property in sourceNotification.Properties) |
|
|
foreach (var property in sourceNotification.Properties) |
|
|
{ |
|
|
{ |
|
|
existingNotification.Properties[property.Key] = property.Value; |
|
|
existingNotification.Properties[property.Key] = property.Value; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 合并提供者
|
|
|
|
|
|
foreach (var provider in sourceNotification.Providers) |
|
|
foreach (var provider in sourceNotification.Providers) |
|
|
{ |
|
|
{ |
|
|
if (!existingNotification.Providers.Contains(provider)) |
|
|
if (!existingNotification.Providers.Contains(provider)) |
|
|
@ -404,30 +190,26 @@ public class NotificationDefinitionManager : INotificationDefinitionManager, ITr |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 更新显示名称（如果源提供了）
|
|
|
|
|
|
if (sourceNotification.DisplayName != null) |
|
|
if (sourceNotification.DisplayName != null) |
|
|
{ |
|
|
{ |
|
|
existingNotification.DisplayName = sourceNotification.DisplayName; |
|
|
existingNotification.DisplayName = sourceNotification.DisplayName; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 更新描述（如果源提供了）
|
|
|
|
|
|
if (sourceNotification.Description != null) |
|
|
if (sourceNotification.Description != null) |
|
|
{ |
|
|
{ |
|
|
existingNotification.Description = sourceNotification.Description; |
|
|
existingNotification.Description = sourceNotification.Description; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 更新模板（优先使用动态的）
|
|
|
|
|
|
if (sourceNotification.Template != null) |
|
|
if (sourceNotification.Template != null) |
|
|
{ |
|
|
{ |
|
|
existingNotification.WithTemplate(sourceNotification.Template); |
|
|
existingNotification.WithTemplate(sourceNotification.Template); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 更新允许客户端订阅
|
|
|
|
|
|
existingNotification.AllowSubscriptionToClients = |
|
|
existingNotification.AllowSubscriptionToClients = |
|
|
existingNotification.AllowSubscriptionToClients || sourceNotification.AllowSubscriptionToClients; |
|
|
existingNotification.AllowSubscriptionToClients || sourceNotification.AllowSubscriptionToClients; |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
#endregion
|
|
|
return Task.CompletedTask; |
|
|
} |
|
|
} |
|
|
|
|
|
} |
|
|
|
colin
2 weeks ago