biss
3ec0f117d3
队列异步执行，拆分查询消除笛卡尔积。
修改的文件（共 13 个）
┌───────────────────────────────────────────────────────────────┬──────────────────────────────────────────────────┐
│ 文件 │ 变更 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Domain/Academic/ExamEntities.cs │ 新增 ExamPublishJob 实体 + ExamPublishJobStatus │
│ │ / ExamPublishJobKind 枚举 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Domain/System/BackgroundJobOutboxMessage.cs │ BackgroundJobKind 新增 ExamPublish = 6 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/BackgroundJobs/BackgroundJobOptions.cs │ 新增 ExamPublishConcurrency 配置项 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/BackgroundJobs/BackgroundJobRunner.cs │ RunAsync 和 MarkJobRetryLimitExceeded 添加 │
│ │ ExamPublish 分支 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/BackgroundJobs/RabbitMqBackgroundJobs.cs │ JobKinds 数组和 RoutingKey 添加 ExamPublish → │
│ │ "exam.publish" │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/BackgroundJobs/BackgroundJobOutboxPublisher.cs │ 启动恢复逻辑添加 ExamPublishJobs │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/Persistence/AppDbContext.cs │ 新增 ExamPublishJobs DbSet │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Controllers/OperationsController.cs │ CountFailedJobsAsync / GetFailedJobs │
│ │ 添加考试发布失败统计和筛选 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Program.cs │ 校验 ExamPublishConcurrency + 注册 │
│ │ ExamPublishJobProcessor │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Infrastructure/Exams/ExamPublishJobs.cs │ 新文件 — │
│ │ ExamPublishJobProcessor，拆分查询校验后发布 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Controllers/ExamsController.cs │ Publish 改为创建后台任务 + 202 返回；新增 GET │
│ │ publish-jobs/{id} / GET plans/{id}/publish-job │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ Controllers/MakeupExamsController.cs │ 同上改造 │
├───────────────────────────────────────────────────────────────┼──────────────────────────────────────────────────┤
│ tests/.../TeachingWorkflowRosterTests.cs │ 更新测试适配新的异步发布模式 │
└───────────────────────────────────────────────────────────────┴──────────────────────────────────────────────────┘
笛卡尔积消除
之前：一个 Include 链拉全部 → EF Core 生成 Sessions × Invigilators × RoomLinks × Seats 笛卡尔积
之后：
- 场次计数：db.ExamSessions.CountAsync（无 JOIN）
- 场次摘要：Select new { Id, ClassroomId, InvigilatorCount, RoomLinkCount }（只查所需列）
- 容量超限：db.ExamRooms.Select(r => new { SeatCount = r.Seats.Count, Capacity })（单表 JOIN）
- 课程冲突：db.ExamRoomSessions.Where(link => ...CourseId != link.ExamRoom!.CourseId)（独立查询）
- 每个查询只做自己需要的 JOIN，互不干扰
测试结果
213 通过，0 失败，0 跳过
配置方式
- BackgroundJobs__Transport=RabbitMq → 走 RabbitMQ 队列 jiaowu.background-jobs.exam.publish
- BackgroundJobs__Transport=InMemory（默认） → 走内存 Channel
- BackgroundJobs__ExamPublishConcurrency=1（默认，可调 1-16）
54 lines
2.3 KiB
C#
54 lines
2.3 KiB
C#
using Jiaowu.Api.Domain.System;
|
|
|
|
namespace Jiaowu.Api.Infrastructure.BackgroundJobs;
|
|
|
|
public sealed class BackgroundJobOptions
|
|
{
|
|
public const string SectionName = "BackgroundJobs";
|
|
|
|
public string Transport { get; set; } = "InMemory";
|
|
public int PollIntervalMilliseconds { get; set; } = 500;
|
|
public int LeaseSeconds { get; set; } = 120;
|
|
public ushort PrefetchCount { get; set; } = 1;
|
|
public int AutomaticScheduleConcurrency { get; set; } = 1;
|
|
public int SchedulePublishConcurrency { get; set; } = 1;
|
|
public int MakeupExamAutoConcurrency { get; set; } = 1;
|
|
public int ExamArrangementConcurrency { get; set; } = 1;
|
|
public int ExamSignInExportConcurrency { get; set; } = 1;
|
|
public int ExamPublishConcurrency { get; set; } = 1;
|
|
public string Exchange { get; set; } = "jiaowu.background-jobs";
|
|
public string QueuePrefix { get; set; } = "jiaowu.background-jobs";
|
|
public bool UseQuorumQueues { get; set; } = true;
|
|
public int ProcessingAttemptLimit { get; set; } = 5;
|
|
public int MaintenanceIntervalSeconds { get; set; } = 60;
|
|
public int CompletedRetentionDays { get; set; } = 14;
|
|
public int CleanupBatchSize { get; set; } = 500;
|
|
|
|
public bool UsesRabbitMq =>
|
|
Transport.Equals("RabbitMq", StringComparison.OrdinalIgnoreCase);
|
|
|
|
public int ConsumerConcurrency(BackgroundJobKind kind) => kind switch
|
|
{
|
|
BackgroundJobKind.AutomaticSchedule => AutomaticScheduleConcurrency,
|
|
BackgroundJobKind.SchedulePublish => SchedulePublishConcurrency,
|
|
BackgroundJobKind.MakeupExamAuto => MakeupExamAutoConcurrency,
|
|
BackgroundJobKind.ExamArrangement => ExamArrangementConcurrency,
|
|
BackgroundJobKind.ExamSignInExport => ExamSignInExportConcurrency,
|
|
BackgroundJobKind.ExamPublish => ExamPublishConcurrency,
|
|
_ => throw new ArgumentOutOfRangeException(nameof(kind), kind, null)
|
|
};
|
|
}
|
|
|
|
public sealed class RabbitMqOptions
|
|
{
|
|
public const string SectionName = "RabbitMq";
|
|
|
|
public string HostName { get; set; } = "localhost";
|
|
public int Port { get; set; } = 5672;
|
|
public string UserName { get; set; } = "guest";
|
|
public string Password { get; set; } = "guest";
|
|
public string VirtualHost { get; set; } = "/";
|
|
public bool UseTls { get; set; }
|
|
public string? TlsServerName { get; set; }
|
|
}
|