New: Send Notifications to all users in a role and exchange url and user info...

Issue: Diplomarbeit-Absolventenverein/oqtane.framework#2
This commit is contained in:
2025-10-16 07:35:01 +02:00
parent e1e05eea9b
commit 515bac1455
15 changed files with 360 additions and 25 deletions

View File

@@ -1,4 +1,5 @@
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Identity;
using Oqtane.Enums;
using Oqtane.Extensions;
using Oqtane.Infrastructure;
@@ -9,6 +10,7 @@ using Oqtane.Shared;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Reflection;
using System.Threading.Tasks;
using SZUAbsolventenverein.Module.AdminModules.Models;
@@ -19,21 +21,25 @@ namespace SZUAbsolventenverein.Module.AdminModules.Services
public class ServerAdminModulesService : IAdminModulesService
{
private readonly IAdminModulesRepository _AdminModulesRepository;
private readonly UserManager<IdentityUser> _identityUserManager;
private readonly IUserPermissions _userPermissions;
private readonly IRoleRepository _roleRepository;
private readonly IUserRepository _userRepository;
private readonly IUserRoleRepository _userRoleRepository;
private readonly INotificationRepository _notifications;
private readonly ILogManager _logger;
private readonly IHttpContextAccessor _accessor;
private readonly Alias _alias;
public ServerAdminModulesService(IAdminModulesRepository AdminModulesRepository, IUserPermissions userPermissions, IRoleRepository roleRepository, IUserRepository userRepository, IUserRoleRepository userRoleRepository, ITenantManager tenantManager, ILogManager logger, IHttpContextAccessor accessor)
public ServerAdminModulesService(IAdminModulesRepository AdminModulesRepository, UserManager<IdentityUser> identityUserManager, INotificationRepository notifications, IUserPermissions userPermissions, IRoleRepository roleRepository, IUserRepository userRepository, IUserRoleRepository userRoleRepository, ITenantManager tenantManager, ILogManager logger, IHttpContextAccessor accessor)
{
_AdminModulesRepository = AdminModulesRepository;
_identityUserManager = identityUserManager;
_userPermissions = userPermissions;
_roleRepository = roleRepository;
_userRepository = userRepository;
_userRoleRepository = userRoleRepository;
_notifications = notifications;
_logger = logger;
_accessor = accessor;
_alias = tenantManager.GetAlias();
@@ -138,14 +144,38 @@ namespace SZUAbsolventenverein.Module.AdminModules.Services
}
}
public Task<EmailFields> SendMassNotification(EmailFields EmailFields)
public async Task<EmailFields> SendMassNotification(EmailFields EmailFields)
{
if (_userPermissions.IsAuthorized(_accessor.HttpContext.User, _alias.SiteId, EntityNames.Module, EmailFields.ModuleId, PermissionNames.View))
{
IEnumerable<int> userids = _userRoleRepository.GetUserRoles(_accessor.HttpContext.User.UserId(), _alias.SiteId).Select(ur => ur.UserId).AsEnumerable();
Models.AdminModules template = await GetAdminModulesAsync(EmailFields.AdminModulesId, EmailFields.ModuleId);
int emailsSent = 0;
IEnumerable<int> userids = _userRoleRepository
.GetUserRoles(_alias.SiteId)
.Where(ur => ur.Role.SiteId == EmailFields.Role.RoleId)
.Select(ur => ur.UserId)
.Distinct()
.AsEnumerable();
foreach (int userid in userids)
{
emailsSent++;
User user = _userRepository.GetUser(userid);
IdentityUser identityuser = await _identityUserManager.FindByNameAsync(user.Username);
string body = template.Content;
// Fields bef<65>llen.
string token = await _identityUserManager.GenerateEmailConfirmationTokenAsync(identityuser);
string url = _alias.Protocol + _alias.Name + "/login?name=" + user.Username + "&token=" + WebUtility.UrlEncode(token);
body = body.Replace("[UserDisplayName]", user.DisplayName);
body = body.Replace("[URL]", url);
Notification notification = new Notification(_alias.SiteId, user, template.Name, body, DateTime.Now.AddDays(emailsSent / 100));
_notifications.AddNotification(notification);
}
return null;