feat: 桌码管理支持区域、批量生成与二维码导出

2025-12-04 09:10:00 +08:00
parent 9051a024ea
commit 1a5209a8b1
33 changed files with 1343 additions and 2 deletions
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/CreateStoreTableAreaCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/CreateStoreTableAreaCommandHandler.cs
@@ -0,0 +1,58 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Domain.Stores.Entities;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 创建桌台区域处理器。
+/// </summary>
+public sealed class CreateStoreTableAreaCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<CreateStoreTableAreaCommandHandler> logger)
+    : IRequestHandler<CreateStoreTableAreaCommand, StoreTableAreaDto>
+{
+    /// <inheritdoc />
+    public async Task<StoreTableAreaDto> Handle(CreateStoreTableAreaCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 校验门店存在
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var store = await storeRepository.FindByIdAsync(request.StoreId, tenantId, cancellationToken);
+        if (store is null)
+        {
+            throw new BusinessException(ErrorCodes.NotFound, "门店不存在");
+        }
+
+        // 2. 校验区域名称唯一
+        var existingAreas = await storeRepository.GetTableAreasAsync(request.StoreId, tenantId, cancellationToken);
+        var hasDuplicate = existingAreas.Any(x => x.Name.Equals(request.Name, StringComparison.OrdinalIgnoreCase));
+        if (hasDuplicate)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "区域名称已存在");
+        }
+
+        // 3. 构建实体
+        var area = new StoreTableArea
+        {
+            StoreId = request.StoreId,
+            Name = request.Name.Trim(),
+            Description = request.Description?.Trim(),
+            SortOrder = request.SortOrder
+        };
+
+        // 4. 持久化
+        await storeRepository.AddTableAreasAsync(new[] { area }, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("创建桌台区域 {AreaId} 对应门店 {StoreId}", area.Id, request.StoreId);
+
+        // 5. 返回 DTO
+        return StoreMapping.ToDto(area);
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/DeleteStoreTableAreaCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/DeleteStoreTableAreaCommandHandler.cs
@@ -0,0 +1,52 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 删除桌台区域处理器。
+/// </summary>
+public sealed class DeleteStoreTableAreaCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<DeleteStoreTableAreaCommandHandler> logger)
+    : IRequestHandler<DeleteStoreTableAreaCommand, bool>
+{
+    /// <inheritdoc />
+    public async Task<bool> Handle(DeleteStoreTableAreaCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 读取区域
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var area = await storeRepository.FindTableAreaByIdAsync(request.AreaId, tenantId, cancellationToken);
+        if (area is null)
+        {
+            return false;
+        }
+
+        // 2. 校验门店归属
+        if (area.StoreId != request.StoreId)
+        {
+            return false;
+        }
+
+        // 3. 校验区域下无桌码
+        var tables = await storeRepository.GetTablesAsync(request.StoreId, tenantId, cancellationToken);
+        var hasTable = tables.Any(x => x.AreaId == request.AreaId);
+        if (hasTable)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "区域下仍有桌码，无法删除");
+        }
+
+        // 4. 删除
+        await storeRepository.DeleteTableAreaAsync(request.AreaId, tenantId, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("删除桌台区域 {AreaId} 对应门店 {StoreId}", request.AreaId, request.StoreId);
+
+        return true;
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/DeleteStoreTableCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/DeleteStoreTableCommandHandler.cs
@@ -0,0 +1,36 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 删除桌码处理器。
+/// </summary>
+public sealed class DeleteStoreTableCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<DeleteStoreTableCommandHandler> logger)
+    : IRequestHandler<DeleteStoreTableCommand, bool>
+{
+    /// <inheritdoc />
+    public async Task<bool> Handle(DeleteStoreTableCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 读取桌码
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var table = await storeRepository.FindTableByIdAsync(request.TableId, tenantId, cancellationToken);
+        if (table is null || table.StoreId != request.StoreId)
+        {
+            return false;
+        }
+
+        // 2. 删除
+        await storeRepository.DeleteTableAsync(request.TableId, tenantId, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("删除桌码 {TableId} 对应门店 {StoreId}", request.TableId, request.StoreId);
+
+        return true;
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ExportStoreTableQRCodesQueryHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ExportStoreTableQRCodesQueryHandler.cs
@@ -0,0 +1,86 @@
+using System.IO.Compression;
+using System.Linq;
+using System.Text;
+using MediatR;
+using Microsoft.Extensions.Logging;
+using QRCoder;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Application.App.Stores.Queries;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 导出桌码二维码处理器。
+/// </summary>
+public sealed class ExportStoreTableQRCodesQueryHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<ExportStoreTableQRCodesQueryHandler> logger)
+    : IRequestHandler<ExportStoreTableQRCodesQuery, StoreTableExportResult?>
+{
+    /// <inheritdoc />
+    public async Task<StoreTableExportResult?> Handle(ExportStoreTableQRCodesQuery request, CancellationToken cancellationToken)
+    {
+        // 1. 校验门店存在
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var store = await storeRepository.FindByIdAsync(request.StoreId, tenantId, cancellationToken);
+        if (store is null)
+        {
+            return null;
+        }
+
+        // 2. 获取桌码列表
+        var tables = await storeRepository.GetTablesAsync(request.StoreId, tenantId, cancellationToken);
+        if (request.AreaId.HasValue)
+        {
+            tables = tables.Where(x => x.AreaId == request.AreaId.Value).ToList();
+        }
+
+        if (tables.Count == 0)
+        {
+            return null;
+        }
+
+        // 3. 生成 ZIP
+        var template = string.IsNullOrWhiteSpace(request.QrContentTemplate) ? "{code}" : request.QrContentTemplate!;
+        using var memoryStream = new MemoryStream();
+        using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true, Encoding.UTF8))
+        {
+            foreach (var table in tables)
+            {
+                var content = BuildPayload(template, table.TableCode);
+                var svg = RenderSvg(content);
+                var entry = archive.CreateEntry($"{table.TableCode}.svg", CompressionLevel.Fastest);
+                using var entryStream = entry.Open();
+                using var writer = new StreamWriter(entryStream, Encoding.UTF8);
+                writer.Write(svg);
+            }
+        }
+
+        // 4. 返回导出结果
+        var fileName = $"store_{request.StoreId}_tables_{DateTime.UtcNow:yyyyMMddHHmmss}.zip";
+        logger.LogInformation("导出门店 {StoreId} 桌码二维码 {Count} 个", request.StoreId, tables.Count);
+        return new StoreTableExportResult
+        {
+            FileName = fileName,
+            ContentType = "application/zip",
+            Content = memoryStream.ToArray()
+        };
+    }
+
+    private static string BuildPayload(string template, string tableCode)
+    {
+        var payload = template.Replace("{code}", tableCode, StringComparison.OrdinalIgnoreCase);
+        return string.IsNullOrWhiteSpace(payload) ? tableCode : payload;
+    }
+
+    private static string RenderSvg(string payload)
+    {
+        using var generator = new QRCodeGenerator();
+        var data = generator.CreateQrCode(payload, QRCodeGenerator.ECCLevel.Q);
+        var svg = new SvgQRCode(data);
+        return svg.GetGraphic(5);
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/GenerateStoreTablesCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/GenerateStoreTablesCommandHandler.cs
@@ -0,0 +1,73 @@
+using System.Linq;
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Domain.Stores.Entities;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 批量生成桌码处理器。
+/// </summary>
+public sealed class GenerateStoreTablesCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<GenerateStoreTablesCommandHandler> logger)
+    : IRequestHandler<GenerateStoreTablesCommand, IReadOnlyList<StoreTableDto>>
+{
+    /// <inheritdoc />
+    public async Task<IReadOnlyList<StoreTableDto>> Handle(GenerateStoreTablesCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 校验门店存在
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var store = await storeRepository.FindByIdAsync(request.StoreId, tenantId, cancellationToken);
+        if (store is null)
+        {
+            throw new BusinessException(ErrorCodes.NotFound, "门店不存在");
+        }
+
+        // 2. 校验区域归属
+        if (request.AreaId.HasValue)
+        {
+            var area = await storeRepository.FindTableAreaByIdAsync(request.AreaId.Value, tenantId, cancellationToken);
+            if (area is null || area.StoreId != request.StoreId)
+            {
+                throw new BusinessException(ErrorCodes.ValidationFailed, "桌台区域不存在或不属于该门店");
+            }
+        }
+
+        // 3. 校验桌码唯一性
+        var existingTables = await storeRepository.GetTablesAsync(request.StoreId, tenantId, cancellationToken);
+        var newCodes = Enumerable.Range(request.StartNumber, request.Count)
+            .Select(i => $"{request.TableCodePrefix.Trim()}{i}")
+            .ToList();
+        var conflicts = existingTables.Where(t => newCodes.Contains(t.TableCode, StringComparer.OrdinalIgnoreCase)).ToList();
+        if (conflicts.Count > 0)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "桌码已存在，生成失败");
+        }
+
+        // 4. 构建实体
+        var tables = newCodes.Select(code => new StoreTable
+        {
+            StoreId = request.StoreId,
+            AreaId = request.AreaId,
+            TableCode = code,
+            Capacity = request.DefaultCapacity,
+            Tags = request.Tags?.Trim()
+        }).ToList();
+
+        // 5. 持久化
+        await storeRepository.AddTablesAsync(tables, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("批量创建桌码 {Count} 条 对应门店 {StoreId}", tables.Count, request.StoreId);
+
+        // 6. 返回 DTO
+        return tables.Select(StoreMapping.ToDto).ToList();
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ListStoreTableAreasQueryHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ListStoreTableAreasQueryHandler.cs
@@ -0,0 +1,26 @@
+using System.Linq;
+using MediatR;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Application.App.Stores.Queries;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 桌台区域列表查询处理器。
+/// </summary>
+public sealed class ListStoreTableAreasQueryHandler(IStoreRepository storeRepository, ITenantProvider tenantProvider)
+    : IRequestHandler<ListStoreTableAreasQuery, IReadOnlyList<StoreTableAreaDto>>
+{
+    /// <inheritdoc />
+    public async Task<IReadOnlyList<StoreTableAreaDto>> Handle(ListStoreTableAreasQuery request, CancellationToken cancellationToken)
+    {
+        // 1. 查询区域列表
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var areas = await storeRepository.GetTableAreasAsync(request.StoreId, tenantId, cancellationToken);
+
+        // 2. 映射 DTO
+        return areas.Select(StoreMapping.ToDto).ToList();
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ListStoreTablesQueryHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/ListStoreTablesQueryHandler.cs
@@ -0,0 +1,39 @@
+using System.Linq;
+using MediatR;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Application.App.Stores.Queries;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 桌码列表查询处理器。
+/// </summary>
+public sealed class ListStoreTablesQueryHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider)
+    : IRequestHandler<ListStoreTablesQuery, IReadOnlyList<StoreTableDto>>
+{
+    /// <inheritdoc />
+    public async Task<IReadOnlyList<StoreTableDto>> Handle(ListStoreTablesQuery request, CancellationToken cancellationToken)
+    {
+        // 1. 查询桌码列表
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var tables = await storeRepository.GetTablesAsync(request.StoreId, tenantId, cancellationToken);
+
+        // 2. 过滤
+        if (request.AreaId.HasValue)
+        {
+            tables = tables.Where(x => x.AreaId == request.AreaId.Value).ToList();
+        }
+
+        if (request.Status.HasValue)
+        {
+            tables = tables.Where(x => x.Status == request.Status.Value).ToList();
+        }
+
+        // 3. 映射 DTO
+        return tables.Select(StoreMapping.ToDto).ToList();
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/UpdateStoreTableAreaCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/UpdateStoreTableAreaCommandHandler.cs
@@ -0,0 +1,59 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 更新桌台区域处理器。
+/// </summary>
+public sealed class UpdateStoreTableAreaCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<UpdateStoreTableAreaCommandHandler> logger)
+    : IRequestHandler<UpdateStoreTableAreaCommand, StoreTableAreaDto?>
+{
+    /// <inheritdoc />
+    public async Task<StoreTableAreaDto?> Handle(UpdateStoreTableAreaCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 读取区域
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var area = await storeRepository.FindTableAreaByIdAsync(request.AreaId, tenantId, cancellationToken);
+        if (area is null)
+        {
+            return null;
+        }
+
+        // 2. 校验门店归属
+        if (area.StoreId != request.StoreId)
+        {
+            throw new BusinessException(ErrorCodes.ValidationFailed, "区域不属于该门店");
+        }
+
+        // 3. 名称唯一校验
+        var areas = await storeRepository.GetTableAreasAsync(request.StoreId, tenantId, cancellationToken);
+        var hasDuplicate = areas.Any(x => x.Id != request.AreaId && x.Name.Equals(request.Name, StringComparison.OrdinalIgnoreCase));
+        if (hasDuplicate)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "区域名称已存在");
+        }
+
+        // 4. 更新字段
+        area.Name = request.Name.Trim();
+        area.Description = request.Description?.Trim();
+        area.SortOrder = request.SortOrder;
+
+        // 5. 持久化
+        await storeRepository.UpdateTableAreaAsync(area, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("更新桌台区域 {AreaId} 对应门店 {StoreId}", area.Id, area.StoreId);
+
+        // 6. 返回 DTO
+        return StoreMapping.ToDto(area);
+    }
+}
--- a/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/UpdateStoreTableCommandHandler.cs
+++ b/src/Application/TakeoutSaaS.Application/App/Stores/Handlers/UpdateStoreTableCommandHandler.cs
@@ -0,0 +1,72 @@
+using System.Linq;
+using MediatR;
+using Microsoft.Extensions.Logging;
+using TakeoutSaaS.Application.App.Stores.Commands;
+using TakeoutSaaS.Application.App.Stores.Dto;
+using TakeoutSaaS.Domain.Stores.Repositories;
+using TakeoutSaaS.Shared.Abstractions.Constants;
+using TakeoutSaaS.Shared.Abstractions.Exceptions;
+using TakeoutSaaS.Shared.Abstractions.Tenancy;
+
+namespace TakeoutSaaS.Application.App.Stores.Handlers;
+
+/// <summary>
+/// 更新桌码处理器。
+/// </summary>
+public sealed class UpdateStoreTableCommandHandler(
+    IStoreRepository storeRepository,
+    ITenantProvider tenantProvider,
+    ILogger<UpdateStoreTableCommandHandler> logger)
+    : IRequestHandler<UpdateStoreTableCommand, StoreTableDto?>
+{
+    /// <inheritdoc />
+    public async Task<StoreTableDto?> Handle(UpdateStoreTableCommand request, CancellationToken cancellationToken)
+    {
+        // 1. 读取桌码
+        var tenantId = tenantProvider.GetCurrentTenantId();
+        var table = await storeRepository.FindTableByIdAsync(request.TableId, tenantId, cancellationToken);
+        if (table is null)
+        {
+            return null;
+        }
+
+        // 2. 校验门店归属
+        if (table.StoreId != request.StoreId)
+        {
+            throw new BusinessException(ErrorCodes.ValidationFailed, "桌码不属于该门店");
+        }
+
+        // 3. 校验区域归属
+        if (request.AreaId.HasValue)
+        {
+            var area = await storeRepository.FindTableAreaByIdAsync(request.AreaId.Value, tenantId, cancellationToken);
+            if (area is null || area.StoreId != request.StoreId)
+            {
+                throw new BusinessException(ErrorCodes.ValidationFailed, "桌台区域不存在或不属于该门店");
+            }
+        }
+
+        // 4. 校验桌码唯一
+        var tables = await storeRepository.GetTablesAsync(request.StoreId, tenantId, cancellationToken);
+        var exists = tables.Any(x => x.Id != request.TableId && x.TableCode.Equals(request.TableCode, StringComparison.OrdinalIgnoreCase));
+        if (exists)
+        {
+            throw new BusinessException(ErrorCodes.Conflict, "桌码已存在");
+        }
+
+        // 5. 更新字段
+        table.AreaId = request.AreaId;
+        table.TableCode = request.TableCode.Trim();
+        table.Capacity = request.Capacity;
+        table.Tags = request.Tags?.Trim();
+        table.Status = request.Status;
+
+        // 6. 持久化
+        await storeRepository.UpdateTableAsync(table, cancellationToken);
+        await storeRepository.SaveChangesAsync(cancellationToken);
+        logger.LogInformation("更新桌码 {TableId} 对应门店 {StoreId}", table.Id, table.StoreId);
+
+        // 7. 返回 DTO
+        return StoreMapping.ToDto(table);
+    }
+}