feat: 套餐使用统计与使用租户接口
This commit is contained in:
@@ -0,0 +1,175 @@
|
||||
using MediatR;
|
||||
using System.Data;
|
||||
using System.Data.Common;
|
||||
using TakeoutSaaS.Application.App.Tenants.Dto;
|
||||
using TakeoutSaaS.Application.App.Tenants.Queries;
|
||||
using TakeoutSaaS.Domain.Tenants.Enums;
|
||||
using TakeoutSaaS.Shared.Abstractions.Constants;
|
||||
using TakeoutSaaS.Shared.Abstractions.Data;
|
||||
using TakeoutSaaS.Shared.Abstractions.Results;
|
||||
|
||||
namespace TakeoutSaaS.Application.App.Tenants.Handlers;
|
||||
|
||||
/// <summary>
|
||||
/// 查询套餐当前使用租户列表处理器。
|
||||
/// </summary>
|
||||
public sealed class GetTenantPackageTenantsQueryHandler(IDapperExecutor dapperExecutor)
|
||||
: IRequestHandler<GetTenantPackageTenantsQuery, PagedResult<TenantPackageTenantDto>>
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public async Task<PagedResult<TenantPackageTenantDto>> Handle(GetTenantPackageTenantsQuery request, CancellationToken cancellationToken)
|
||||
{
|
||||
// 1. 参数规范化
|
||||
var page = request.Page <= 0 ? 1 : request.Page;
|
||||
var pageSize = request.PageSize <= 0 ? 20 : request.PageSize;
|
||||
var keyword = string.IsNullOrWhiteSpace(request.Keyword) ? null : request.Keyword.Trim();
|
||||
|
||||
// 2. (空行后) 以当前时间为准筛选“有效订阅”
|
||||
var now = DateTime.UtcNow;
|
||||
var offset = (page - 1) * pageSize;
|
||||
|
||||
// 3. (空行后) 查询总数 + 列表
|
||||
return await dapperExecutor.QueryAsync(
|
||||
DatabaseConstants.AppDataSource,
|
||||
DatabaseConnectionRole.Read,
|
||||
async (connection, token) =>
|
||||
{
|
||||
// 3.1 统计总数
|
||||
var total = await ExecuteScalarIntAsync(
|
||||
connection,
|
||||
BuildCountSql(),
|
||||
[
|
||||
("packageId", request.TenantPackageId),
|
||||
("now", now),
|
||||
("keyword", keyword)
|
||||
],
|
||||
token);
|
||||
|
||||
// 3.2 (空行后) 查询列表
|
||||
var listSql = BuildListSql();
|
||||
await using var listCommand = CreateCommand(
|
||||
connection,
|
||||
listSql,
|
||||
[
|
||||
("packageId", request.TenantPackageId),
|
||||
("now", now),
|
||||
("keyword", keyword),
|
||||
("offset", offset),
|
||||
("limit", pageSize)
|
||||
]);
|
||||
|
||||
await using var reader = await listCommand.ExecuteReaderAsync(token);
|
||||
var items = new List<TenantPackageTenantDto>();
|
||||
while (await reader.ReadAsync(token))
|
||||
{
|
||||
items.Add(new TenantPackageTenantDto
|
||||
{
|
||||
TenantId = reader.GetInt64(0),
|
||||
Code = reader.GetString(1),
|
||||
Name = reader.GetString(2),
|
||||
Status = (TenantStatus)reader.GetInt32(3),
|
||||
ContactName = reader.IsDBNull(4) ? null : reader.GetString(4),
|
||||
ContactPhone = reader.IsDBNull(5) ? null : reader.GetString(5),
|
||||
SubscriptionEffectiveFrom = reader.GetDateTime(6),
|
||||
SubscriptionEffectiveTo = reader.GetDateTime(7)
|
||||
});
|
||||
}
|
||||
|
||||
// 3.3 (空行后) 返回分页
|
||||
return new PagedResult<TenantPackageTenantDto>(items, page, pageSize, total);
|
||||
},
|
||||
cancellationToken);
|
||||
}
|
||||
|
||||
private static string BuildCountSql()
|
||||
{
|
||||
return """
|
||||
select count(*)
|
||||
from public.tenants t
|
||||
where t."DeletedAt" is null
|
||||
and (
|
||||
@keyword is null
|
||||
or t."Name" ilike ('%' || @keyword || '%')
|
||||
or t."Code" ilike ('%' || @keyword || '%')
|
||||
or coalesce(t."ContactName", '') ilike ('%' || @keyword || '%')
|
||||
or coalesce(t."ContactPhone", '') ilike ('%' || @keyword || '%')
|
||||
)
|
||||
and exists (
|
||||
select 1
|
||||
from public.tenant_subscriptions s
|
||||
where s."DeletedAt" is null
|
||||
and s."TenantId" = t."Id"
|
||||
and s."TenantPackageId" = @packageId
|
||||
and s."Status" = 1
|
||||
and s."EffectiveFrom" <= @now
|
||||
and s."EffectiveTo" >= @now
|
||||
);
|
||||
""";
|
||||
}
|
||||
|
||||
private static string BuildListSql()
|
||||
{
|
||||
return """
|
||||
select
|
||||
t."Id" as "TenantId",
|
||||
t."Code",
|
||||
t."Name",
|
||||
t."Status",
|
||||
t."ContactName",
|
||||
t."ContactPhone",
|
||||
s."EffectiveFrom",
|
||||
s."EffectiveTo"
|
||||
from public.tenants t
|
||||
join lateral (
|
||||
select s."EffectiveFrom", s."EffectiveTo"
|
||||
from public.tenant_subscriptions s
|
||||
where s."DeletedAt" is null
|
||||
and s."TenantId" = t."Id"
|
||||
and s."TenantPackageId" = @packageId
|
||||
and s."Status" = 1
|
||||
and s."EffectiveFrom" <= @now
|
||||
and s."EffectiveTo" >= @now
|
||||
order by s."EffectiveTo" desc
|
||||
limit 1
|
||||
) s on true
|
||||
where t."DeletedAt" is null
|
||||
and (
|
||||
@keyword is null
|
||||
or t."Name" ilike ('%' || @keyword || '%')
|
||||
or t."Code" ilike ('%' || @keyword || '%')
|
||||
or coalesce(t."ContactName", '') ilike ('%' || @keyword || '%')
|
||||
or coalesce(t."ContactPhone", '') ilike ('%' || @keyword || '%')
|
||||
)
|
||||
order by t."CreatedAt" desc
|
||||
offset @offset
|
||||
limit @limit;
|
||||
""";
|
||||
}
|
||||
|
||||
private static async Task<int> ExecuteScalarIntAsync(
|
||||
IDbConnection connection,
|
||||
string sql,
|
||||
(string Name, object? Value)[] parameters,
|
||||
CancellationToken cancellationToken)
|
||||
{
|
||||
await using var command = CreateCommand(connection, sql, parameters);
|
||||
var result = await command.ExecuteScalarAsync(cancellationToken);
|
||||
return result is null or DBNull ? 0 : Convert.ToInt32(result);
|
||||
}
|
||||
|
||||
private static DbCommand CreateCommand(IDbConnection connection, string sql, (string Name, object? Value)[] parameters)
|
||||
{
|
||||
var command = connection.CreateCommand();
|
||||
command.CommandText = sql;
|
||||
|
||||
foreach (var (name, value) in parameters)
|
||||
{
|
||||
var p = command.CreateParameter();
|
||||
p.ParameterName = name;
|
||||
p.Value = value ?? DBNull.Value;
|
||||
command.Parameters.Add(p);
|
||||
}
|
||||
|
||||
return (DbCommand)command;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,117 @@
|
||||
using MediatR;
|
||||
using System.Data;
|
||||
using System.Data.Common;
|
||||
using TakeoutSaaS.Application.App.Tenants.Dto;
|
||||
using TakeoutSaaS.Application.App.Tenants.Queries;
|
||||
using TakeoutSaaS.Shared.Abstractions.Constants;
|
||||
using TakeoutSaaS.Shared.Abstractions.Data;
|
||||
|
||||
namespace TakeoutSaaS.Application.App.Tenants.Handlers;
|
||||
|
||||
/// <summary>
|
||||
/// 查询套餐使用统计处理器。
|
||||
/// </summary>
|
||||
public sealed class GetTenantPackageUsagesQueryHandler(IDapperExecutor dapperExecutor)
|
||||
: IRequestHandler<GetTenantPackageUsagesQuery, IReadOnlyList<TenantPackageUsageDto>>
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public async Task<IReadOnlyList<TenantPackageUsageDto>> Handle(GetTenantPackageUsagesQuery request, CancellationToken cancellationToken)
|
||||
{
|
||||
// 1. 规范化输入
|
||||
var ids = request.TenantPackageIds?
|
||||
.Where(x => x > 0)
|
||||
.Distinct()
|
||||
.ToArray();
|
||||
|
||||
// 2. (空行后) 构造 SQL（以当前时间为准统计“有效订阅/使用租户”）
|
||||
var now = DateTime.UtcNow;
|
||||
var sql = BuildSql(ids, out var parameters, now);
|
||||
|
||||
// 3. (空行后) 查询统计结果
|
||||
return await dapperExecutor.QueryAsync(
|
||||
DatabaseConstants.AppDataSource,
|
||||
DatabaseConnectionRole.Read,
|
||||
async (connection, token) =>
|
||||
{
|
||||
await using var command = CreateCommand(connection, sql, parameters);
|
||||
await using var reader = await command.ExecuteReaderAsync(token);
|
||||
var list = new List<TenantPackageUsageDto>();
|
||||
|
||||
// 4. (空行后) 逐行读取
|
||||
while (await reader.ReadAsync(token))
|
||||
{
|
||||
list.Add(new TenantPackageUsageDto
|
||||
{
|
||||
TenantPackageId = reader.GetInt64(0),
|
||||
ActiveSubscriptionCount = reader.GetInt32(1),
|
||||
ActiveTenantCount = reader.GetInt32(2),
|
||||
TotalSubscriptionCount = reader.GetInt32(3)
|
||||
});
|
||||
}
|
||||
|
||||
return (IReadOnlyList<TenantPackageUsageDto>)list;
|
||||
},
|
||||
cancellationToken);
|
||||
}
|
||||
|
||||
private static string BuildSql(long[]? ids, out (string Name, object? Value)[] parameters, DateTime now)
|
||||
{
|
||||
// 1. 基础查询
|
||||
var builder = new System.Text.StringBuilder();
|
||||
builder.AppendLine("""
|
||||
select
|
||||
"TenantPackageId" as "TenantPackageId",
|
||||
count(*) filter (where "Status" = 1 and "EffectiveFrom" <= @now and "EffectiveTo" >= @now) as "ActiveSubscriptionCount",
|
||||
count(distinct "TenantId") filter (where "Status" = 1 and "EffectiveFrom" <= @now and "EffectiveTo" >= @now) as "ActiveTenantCount",
|
||||
count(*) as "TotalSubscriptionCount"
|
||||
from public.tenant_subscriptions
|
||||
where "DeletedAt" is null
|
||||
""");
|
||||
|
||||
var list = new List<(string Name, object? Value)>
|
||||
{
|
||||
("now", now)
|
||||
};
|
||||
|
||||
// 2. (空行后) 可选按套餐 ID 过滤
|
||||
if (ids is { Length: > 0 })
|
||||
{
|
||||
builder.Append(" and \"TenantPackageId\" in (");
|
||||
for (var i = 0; i < ids.Length; i++)
|
||||
{
|
||||
if (i > 0)
|
||||
{
|
||||
builder.Append(',');
|
||||
}
|
||||
|
||||
var name = $"p{i}";
|
||||
builder.Append($"@{name}");
|
||||
list.Add((name, ids[i]));
|
||||
}
|
||||
|
||||
builder.AppendLine(")");
|
||||
}
|
||||
|
||||
// 3. (空行后) 分组
|
||||
builder.AppendLine("group by \"TenantPackageId\";");
|
||||
|
||||
parameters = list.ToArray();
|
||||
return builder.ToString();
|
||||
}
|
||||
|
||||
private static DbCommand CreateCommand(IDbConnection connection, string sql, (string Name, object? Value)[] parameters)
|
||||
{
|
||||
var command = connection.CreateCommand();
|
||||
command.CommandText = sql;
|
||||
|
||||
foreach (var (name, value) in parameters)
|
||||
{
|
||||
var p = command.CreateParameter();
|
||||
p.ParameterName = name;
|
||||
p.Value = value ?? DBNull.Value;
|
||||
command.Parameters.Add(p);
|
||||
}
|
||||
|
||||
return (DbCommand)command;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user