feat: 系统参数应用层与验证

2025-12-02 12:53:06 +08:00
parent dd15a88ff4
commit 3b2b376787
18 changed files with 771 additions and 0 deletions
--- a/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/CreateSystemParameterCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/CreateSystemParameterCommandHandler.cs
@@ -0,0 +1,64 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.SystemParameters.Commands;
+using TakeoutSaaS.Application.App.SystemParameters.Dto;
+using TakeoutSaaS.Domain.SystemParameters.Entities;
+using TakeoutSaaS.Domain.SystemParameters.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+
+namespace TakeoutSaaS.Application.App.SystemParameters.Handlers;
+
+/// <summary>
+/// 创建系统参数命令处理器。
+/// </summary>
+public sealed class CreateSystemParameterCommandHandler(
+    ISystemParameterRepository repository,
+    ILogger<CreateSystemParameterCommandHandler> logger)
+    : IRequestHandler<CreateSystemParameterCommand, SystemParameterDto>
+{
+    private readonly ISystemParameterRepository _repository = repository;
+    private readonly ILogger<CreateSystemParameterCommandHandler> _logger = logger;
+
+    /// <inheritdoc />
+    public async Task<SystemParameterDto> Handle(CreateSystemParameterCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 唯一性校验
+        var existing = await _repository.FindByKeyAsync(request.Key, cancellationToken);
+        if (existing != null)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "系统参数键已存在");
+        }
+
+        // 2. 构建实体
+        var parameter = new SystemParameter
+        {
+            Key = request.Key.Trim(),
+            Value = request.Value.Trim(),
+            Description = request.Description?.Trim(),
+            SortOrder = request.SortOrder,
+            IsEnabled = request.IsEnabled
+        };
+
+        // 3. 持久化
+        await _repository.AddAsync(parameter, cancellationToken);
+        await _repository.SaveChangesAsync(cancellationToken);
+        _logger.LogInformation("创建系统参数 {Key}", parameter.Key);
+
+        // 4. 映射返回
+        return MapToDto(parameter);
+    }
+
+    private static SystemParameterDto MapToDto(SystemParameter parameter) => new()
+    {
+        Id = parameter.Id,
+        TenantId = parameter.TenantId,
+        Key = parameter.Key,
+        Value = parameter.Value,
+        Description = parameter.Description,
+        SortOrder = parameter.SortOrder,
+        IsEnabled = parameter.IsEnabled,
+        CreatedAt = parameter.CreatedAt,
+        UpdatedAt = parameter.UpdatedAt
+    };
+}
--- a/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/DeleteSystemParameterCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/DeleteSystemParameterCommandHandler.cs
@@ -0,0 +1,33 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.SystemParameters.Commands;
+using TakeoutSaaS.Domain.SystemParameters.Repositories;
+
+namespace TakeoutSaaS.Application.App.SystemParameters.Handlers;
+
+/// <summary>
+/// 删除系统参数命令处理器。
+/// </summary>
+public sealed class DeleteSystemParameterCommandHandler(
+    ISystemParameterRepository repository,
+    ILogger<DeleteSystemParameterCommandHandler> logger)
+    : IRequestHandler<DeleteSystemParameterCommand, bool>
+{
+    private readonly ISystemParameterRepository _repository = repository;
+    private readonly ILogger<DeleteSystemParameterCommandHandler> _logger = logger;
+
+    /// <inheritdoc />
+    public async Task<bool> Handle(DeleteSystemParameterCommand request, CancellationToken cancellationToken)
+    {
+        var existing = await _repository.FindByIdAsync(request.ParameterId, cancellationToken);
+        if (existing == null)
+        {
+            return false;
+        }
+
+        await _repository.RemoveAsync(existing, cancellationToken);
+        await _repository.SaveChangesAsync(cancellationToken);
+        _logger.LogInformation("删除系统参数 {Key}", existing.Key);
+        return true;
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/GetSystemParameterByIdQueryHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/GetSystemParameterByIdQueryHandler.cs
@@ -0,0 +1,35 @@
+using MediatR;
+using TakeoutSaaS.Application.App.SystemParameters.Dto;
+using TakeoutSaaS.Application.App.SystemParameters.Queries;
+using TakeoutSaaS.Domain.SystemParameters.Repositories;
+
+namespace TakeoutSaaS.Application.App.SystemParameters.Handlers;
+
+/// <summary>
+/// 获取系统参数详情查询处理器。
+/// </summary>
+public sealed class GetSystemParameterByIdQueryHandler(ISystemParameterRepository repository)
+    : IRequestHandler<GetSystemParameterByIdQuery, SystemParameterDto?>
+{
+    private readonly ISystemParameterRepository _repository = repository;
+
+    /// <inheritdoc />
+    public async Task<SystemParameterDto?> Handle(GetSystemParameterByIdQuery request, CancellationToken cancellationToken)
+    {
+        var parameter = await _repository.FindByIdAsync(request.ParameterId, cancellationToken);
+        return parameter == null ? null : MapToDto(parameter);
+    }
+
+    private static SystemParameterDto MapToDto(Domain.SystemParameters.Entities.SystemParameter parameter) => new()
+    {
+        Id = parameter.Id,
+        TenantId = parameter.TenantId,
+        Key = parameter.Key,
+        Value = parameter.Value,
+        Description = parameter.Description,
+        SortOrder = parameter.SortOrder,
+        IsEnabled = parameter.IsEnabled,
+        CreatedAt = parameter.CreatedAt,
+        UpdatedAt = parameter.UpdatedAt
+    };
+}
--- a/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/SearchSystemParametersQueryHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/SearchSystemParametersQueryHandler.cs
@@ -0,0 +1,69 @@
+using MediatR;
+using TakeoutSaaS.Application.App.SystemParameters.Dto;
+using TakeoutSaaS.Application.App.SystemParameters.Queries;
+using TakeoutSaaS.Domain.SystemParameters.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Results;
+
+namespace TakeoutSaaS.Application.App.SystemParameters.Handlers;
+
+/// <summary>
+/// 系统参数列表查询处理器。
+/// </summary>
+public sealed class SearchSystemParametersQueryHandler(ISystemParameterRepository repository)
+    : IRequestHandler<SearchSystemParametersQuery, PagedResult<SystemParameterDto>>
+{
+    private readonly ISystemParameterRepository _repository = repository;
+
+    /// <inheritdoc />
+    public async Task<PagedResult<SystemParameterDto>> Handle(SearchSystemParametersQuery request, CancellationToken cancellationToken)
+    {
+        var parameters = await _repository.SearchAsync(request.Keyword, request.IsEnabled, cancellationToken);
+
+        var sorted = ApplySorting(parameters, request.SortBy, request.SortDescending);
+        var paged = sorted
+            .Skip((request.Page - 1) * request.PageSize)
+            .Take(request.PageSize)
+            .ToList();
+
+        var items = paged.Select(MapToDto).ToList();
+        return new PagedResult<SystemParameterDto>(items, request.Page, request.PageSize, parameters.Count);
+    }
+
+    private static IOrderedEnumerable<Domain.SystemParameters.Entities.SystemParameter> ApplySorting(
+        IReadOnlyCollection<Domain.SystemParameters.Entities.SystemParameter> parameters,
+        string? sortBy,
+        bool sortDescending)
+    {
+        return sortBy?.ToLowerInvariant() switch
+        {
+            "key" => sortDescending
+                ? parameters.OrderByDescending(x => x.Key)
+                : parameters.OrderBy(x => x.Key),
+            "sortorder" => sortDescending
+                ? parameters.OrderByDescending(x => x.SortOrder)
+                : parameters.OrderBy(x => x.SortOrder),
+            "updatedat" => sortDescending
+                ? parameters.OrderByDescending(x => x.UpdatedAt ?? x.CreatedAt)
+                : parameters.OrderBy(x => x.UpdatedAt ?? x.CreatedAt),
+            "isenabled" => sortDescending
+                ? parameters.OrderByDescending(x => x.IsEnabled)
+                : parameters.OrderBy(x => x.IsEnabled),
+            _ => sortDescending
+                ? parameters.OrderByDescending(x => x.CreatedAt)
+                : parameters.OrderBy(x => x.CreatedAt)
+        };
+    }
+
+    private static SystemParameterDto MapToDto(Domain.SystemParameters.Entities.SystemParameter parameter) => new()
+    {
+        Id = parameter.Id,
+        TenantId = parameter.TenantId,
+        Key = parameter.Key,
+        Value = parameter.Value,
+        Description = parameter.Description,
+        SortOrder = parameter.SortOrder,
+        IsEnabled = parameter.IsEnabled,
+        CreatedAt = parameter.CreatedAt,
+        UpdatedAt = parameter.UpdatedAt
+    };
+}
--- a/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/UpdateSystemParameterCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/SystemParameters/Handlers/UpdateSystemParameterCommandHandler.cs
@@ -0,0 +1,66 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.SystemParameters.Commands;
+using TakeoutSaaS.Application.App.SystemParameters.Dto;
+using TakeoutSaaS.Domain.SystemParameters.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+
+namespace TakeoutSaaS.Application.App.SystemParameters.Handlers;
+
+/// <summary>
+/// 更新系统参数命令处理器。
+/// </summary>
+public sealed class UpdateSystemParameterCommandHandler(
+    ISystemParameterRepository repository,
+    ILogger<UpdateSystemParameterCommandHandler> logger)
+    : IRequestHandler<UpdateSystemParameterCommand, SystemParameterDto?>
+{
+    private readonly ISystemParameterRepository _repository = repository;
+    private readonly ILogger<UpdateSystemParameterCommandHandler> _logger = logger;
+
+    /// <inheritdoc />
+    public async Task<SystemParameterDto?> Handle(UpdateSystemParameterCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 读取已有参数
+        var existing = await _repository.FindByIdAsync(request.ParameterId, cancellationToken);
+        if (existing == null)
+        {
+            return null;
+        }
+
+        // 2. 唯一性校验
+        var duplicate = await _repository.FindByKeyAsync(request.Key, cancellationToken);
+        if (duplicate != null && duplicate.Id != existing.Id)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "系统参数键已存在");
+        }
+
+        // 3. 更新字段
+        existing.Key = request.Key.Trim();
+        existing.Value = request.Value.Trim();
+        existing.Description = request.Description?.Trim();
+        existing.SortOrder = request.SortOrder;
+        existing.IsEnabled = request.IsEnabled;
+
+        // 4. 持久化
+        await _repository.UpdateAsync(existing, cancellationToken);
+        await _repository.SaveChangesAsync(cancellationToken);
+        _logger.LogInformation("更新系统参数 {Key}", existing.Key);
+
+        return MapToDto(existing);
+    }
+
+    private static SystemParameterDto MapToDto(Domain.SystemParameters.Entities.SystemParameter parameter) => new()
+    {
+        Id = parameter.Id,
+        TenantId = parameter.TenantId,
+        Key = parameter.Key,
+        Value = parameter.Value,
+        Description = parameter.Description,
+        SortOrder = parameter.SortOrder,
+        IsEnabled = parameter.IsEnabled,
+        CreatedAt = parameter.CreatedAt,
+        UpdatedAt = parameter.UpdatedAt
+    };
+}