diff --git a/docs/offline-election-counting.md b/docs/offline-election-counting.md index b61deed..fbd471d 100644 --- a/docs/offline-election-counting.md +++ b/docs/offline-election-counting.md @@ -2,7 +2,7 @@ ## 规则与权限 -- 活动必须指定一个目标行政区。只有直接被分配至该行政区的省、市、区、镇或村管理员可创建、编辑及发布；系统管理员可以全局操作。上级管理员仍可以只读查看其下级范围的活动。 +- 活动必须指定一个投票范围。创建页可停在省、市、区县、镇街或村社任一级；系统管理员还可选择“全国”。全国范围是系统保留的持久化范围，覆盖所有有效行政区，但不会改写 AreaCity 原始层级。只有直接被分配至目标行政区的省、市、区、镇或村管理员可创建、编辑及发布；全国范围仅系统管理员可创建、编辑及发布。上级管理员仍可以只读查看其下级范围的活动。 - 活动在草稿阶段依次配置议题、选项和计票所。发布后定义冻结，不能增删候选人、计票所或改变计票规则。 - 一个活动可以包含多个 `CandidateElection`（岗位/多席位竞选）及 `Proposition`（议案）议题。每个议题独立记录每个选项的有效票、弃权、无效票和系统计算的缺投数。 - 每个议题可配置席位数、最少/最多选择数、最高票/简单多数/绝对多数/特定比例门槛、计票分母（仅有效票或全部投出选票）以及平票后的人工复核或无结果处理。 diff --git a/src/ElectionSystem.Api/Components/Pages/Admin/CountingStations.razor b/src/ElectionSystem.Api/Components/Pages/Admin/CountingStations.razor index 1790224..4664b6c 100644 --- a/src/ElectionSystem.Api/Components/Pages/Admin/CountingStations.razor +++ b/src/ElectionSystem.Api/Components/Pages/Admin/CountingStations.razor @@ -7,19 +7,21 @@ @inject RegionCascadeFilterService Cascade 计票所管理 -

人员与场所 / 计票

计票所管理

按四级行政区划筛选；工作人员必须另行分配到具体计票所。

+

人员与场所 / 计票

计票所管理

按四级行政区划筛选；工作人员必须另行分配到具体计票所。

@if (notice is not null) {
@notice
} -
+
@if (creating) {

新增计票所

 }
@if (!loaded) { } else if (stations.Count == 0) { } @foreach (var station in stations) { }
代码名称所属地区状态
正在加载…
暂无计票所。
@station.Code@station.Name@station.Region@(station.Active ? "启用" : "停用")
每页 @PageSize 条
-

分配计票所工作人员

-@code { private const int PageSize = 50; [CascadingParameter] private Task AuthenticationStateTask { get; set; } = default!; private HashSet scope = []; private bool loaded, creating; private string? notice, currentCursor, nextCursor; private string keyword = ""; private Guid? provinceId, cityId, districtId, townshipId; private StationDraft draft = new(); private StaffDraft staffDraft = new(); private readonly List regions = []; private readonly List filterRegions = []; private readonly List stations = []; private readonly List stationChoices = []; private readonly List cursorHistory = []; - protected override async Task OnInitializedAsync() { var id = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); scope = await Scope.GetManagedRegionIdsAsync(id, CancellationToken.None); var all = await Db.AdministrativeRegions.Where(x => scope.Contains(x.Id) && x.IsActive).OrderBy(x => x.Level).ThenBy(x => x.Code).ToListAsync(); regions.AddRange(all.Select(x => new Region(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}"))); filterRegions.AddRange(regions); await LoadStationChoicesAsync(); await SearchAsync(); } - private IEnumerable Options(AdministrativeRegionLevel level, Guid? parentId) => filterRegions.Where(x => x.Level == level && (!parentId.HasValue || x.ParentId == parentId)).OrderBy(x => x.Name); - private async Task LoadStationChoicesAsync() { var map = await Db.AdministrativeRegions.Where(x => scope.Contains(x.Id)).ToDictionaryAsync(x => x.Id, x => x.Name); stationChoices.Clear(); stationChoices.AddRange((await Db.CountingStations.Where(x => scope.Contains(x.RegionId) && x.IsActive).OrderBy(x => x.Code).ToListAsync()).Select(x => new StationChoice(x.Id, $"{x.Code} · {x.Name}（{map.GetValueOrDefault(x.RegionId, "—")}）"))); } - private async Task SelectProvinceAsync(ChangeEventArgs e) { provinceId = Parse(e); cityId = districtId = townshipId = null; await SearchAsync(); } private async Task SelectCityAsync(ChangeEventArgs e) { cityId = Parse(e); districtId = townshipId = null; await SearchAsync(); } private async Task SelectDistrictAsync(ChangeEventArgs e) { districtId = Parse(e); townshipId = null; await SearchAsync(); } private async Task SelectTownshipAsync(ChangeEventArgs e) { townshipId = Parse(e); await SearchAsync(); } private static Guid? Parse(ChangeEventArgs e) => Guid.TryParse(e.Value?.ToString(), out var id) ? id : null; +

分配计票所工作人员

+@code { private const int PageSize = 50; [CascadingParameter] private Task AuthenticationStateTask { get; set; } = default!; private HashSet scope = []; private bool loaded, creating; private string? notice, currentCursor, nextCursor; private string keyword = "", stationKeyword = ""; private Guid? provinceId, cityId, districtId, townshipId; private StationDraft draft = new(); private StaffDraft staffDraft = new(); private readonly List regions = [], provinces = [], cities = [], districts = [], townships = []; private readonly List stations = []; private readonly List stationChoices = []; private readonly List cursorHistory = []; + protected override async Task OnInitializedAsync() { var id = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); scope = await Scope.GetManagedRegionIdsAsync(id, CancellationToken.None); await LoadInitialOptionsAsync(id); await SearchAsync(); } + private async Task LoadInitialOptionsAsync(Guid userId) { var systemAdmin = await Db.UserRegionalRoleAssignments.AsNoTracking().AnyAsync(x => x.UserId == userId && x.Role == RegionalRole.SystemAdministrator && x.RegionId == null); if (systemAdmin) { await LoadOptionsAsync(provinces, null, AdministrativeRegionLevel.Province); return; } var roots = await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && Db.UserRegionalRoleAssignments.Any(a => a.UserId == userId && a.RegionId == x.Id && (a.Role == RegionalRole.ProvinceAdministrator || a.Role == RegionalRole.CityAdministrator || a.Role == RegionalRole.DistrictAdministrator || a.Role == RegionalRole.TownshipAdministrator))).OrderBy(x => x.Code).Select(x => new Region(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync(); provinces.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.Province)); cities.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.City)); districts.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.District)); townships.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.Township)); } + private async Task LoadOptionsAsync(List target, Guid? parentId, AdministrativeRegionLevel level) { target.Clear(); target.AddRange(await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && x.Level == level && x.ParentId == parentId && scope.Contains(x.Id)).OrderBy(x => x.Code).Select(x => new Region(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync()); } + private async Task ToggleCreateAsync() { creating = !creating; if (creating && regions.Count == 0) regions.AddRange(await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && scope.Contains(x.Id)).OrderBy(x => x.Level).ThenBy(x => x.Code).Select(x => new Region(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync()); } + private async Task SearchStationChoicesAsync() { stationChoices.Clear(); var query = Db.CountingStations.AsNoTracking().Where(x => x.IsActive && scope.Contains(x.RegionId)); if (!string.IsNullOrWhiteSpace(stationKeyword)) query = query.Where(x => x.Code.Contains(stationKeyword) || x.Name.Contains(stationKeyword)); var rows = await query.OrderBy(x => x.Code).Take(PageSize).Select(x => new { x.Id, x.Code, x.Name, x.RegionId }).ToListAsync(); var names = await Db.AdministrativeRegions.AsNoTracking().Where(x => rows.Select(y => y.RegionId).Contains(x.Id)).ToDictionaryAsync(x => x.Id, x => x.Name); stationChoices.AddRange(rows.Select(x => new StationChoice(x.Id, $"{x.Code} · {x.Name}（{names.GetValueOrDefault(x.RegionId, "—")}）"))); } + private async Task SelectProvinceAsync(ChangeEventArgs e) { provinceId = Parse(e); cityId = districtId = townshipId = null; cities.Clear(); districts.Clear(); townships.Clear(); if (provinceId.HasValue) await LoadOptionsAsync(cities, provinceId, AdministrativeRegionLevel.City); await SearchAsync(); } private async Task SelectCityAsync(ChangeEventArgs e) { cityId = Parse(e); districtId = townshipId = null; districts.Clear(); townships.Clear(); if (cityId.HasValue) await LoadOptionsAsync(districts, cityId, AdministrativeRegionLevel.District); await SearchAsync(); } private async Task SelectDistrictAsync(ChangeEventArgs e) { districtId = Parse(e); townshipId = null; townships.Clear(); if (districtId.HasValue) await LoadOptionsAsync(townships, districtId, AdministrativeRegionLevel.Township); await SearchAsync(); } private async Task SelectTownshipAsync(ChangeEventArgs e) { townshipId = Parse(e); await SearchAsync(); } private static Guid? Parse(ChangeEventArgs e) => Guid.TryParse(e.Value?.ToString(), out var id) ? id : null; private async Task SearchAsync() { currentCursor = null; cursorHistory.Clear(); await LoadAsync(); } private async Task NextAsync() { if (nextCursor is null) return; cursorHistory.Add(currentCursor); currentCursor = nextCursor; await LoadAsync(); } private async Task PreviousAsync() { if (cursorHistory.Count == 0) return; currentCursor = cursorHistory[^1]; cursorHistory.RemoveAt(cursorHistory.Count - 1); await LoadAsync(); } private async Task LoadAsync() { loaded = false; try { var selectedRegions = await Cascade.ResolveAsync(scope, new(provinceId, cityId, districtId, townshipId), CancellationToken.None); var query = Db.CountingStations.Where(x => selectedRegions.Contains(x.RegionId)); if (!string.IsNullOrWhiteSpace(keyword)) query = query.Where(x => x.Code.Contains(keyword) || x.Name.Contains(keyword)); if (!CursorToken.TryDecode(currentCursor, out var token)) throw new InvalidOperationException("分页游标无效，请重新查询。"); if (token is not null) query = query.Where(x => string.Compare(x.Code, token.Code) > 0 || (x.Code == token.Code && x.Id.CompareTo(token.Id) > 0)); var rows = await query.OrderBy(x => x.Code).ThenBy(x => x.Id).Take(PageSize + 1).ToListAsync(); var hasMore = rows.Count > PageSize; if (hasMore) rows.RemoveAt(rows.Count - 1); var map = await Db.AdministrativeRegions.Where(x => rows.Select(y => y.RegionId).Contains(x.Id)).ToDictionaryAsync(x => x.Id, x => x.Name); stations.Clear(); stations.AddRange(rows.Select(x => new StationRow(x.Id, x.Code, x.Name, map.GetValueOrDefault(x.RegionId, "—"), x.IsActive))); nextCursor = hasMore && rows.Count > 0 ? CursorToken.Encode(new Cursor(rows[^1].Code, rows[^1].Id)) : null; } catch (ArgumentException e) { notice = e.Message; stations.Clear(); nextCursor = null; } finally { loaded = true; } } - private async Task CreateAsync() { if (!draft.RegionId.HasValue || !scope.Contains(draft.RegionId.Value)) { notice = "请选择您有权管理的地区。"; return; } if (await Db.CountingStations.AnyAsync(x => x.Code == draft.Code)) { notice = "计票所代码已存在。"; return; } Db.CountingStations.Add(new CountingStation { Code = draft.Code.Trim(), Name = draft.Name.Trim(), RegionId = draft.RegionId.Value }); await Db.SaveChangesAsync(); notice = "计票所已创建。"; creating = false; draft = new(); await LoadStationChoicesAsync(); await SearchAsync(); } + private async Task CreateAsync() { if (!draft.RegionId.HasValue || !scope.Contains(draft.RegionId.Value)) { notice = "请选择您有权管理的地区。"; return; } if (await Db.CountingStations.AnyAsync(x => x.Code == draft.Code)) { notice = "计票所代码已存在。"; return; } Db.CountingStations.Add(new CountingStation { Code = draft.Code.Trim(), Name = draft.Name.Trim(), RegionId = draft.RegionId.Value }); await Db.SaveChangesAsync(); notice = "计票所已创建。"; creating = false; draft = new(); stationChoices.Clear(); await SearchAsync(); } private async Task AssignStaffAsync() { if (!staffDraft.StationId.HasValue || !Guid.TryParse(staffDraft.UserId, out var userId)) { notice = "请选择计票所并输入有效用户 ID。"; return; } var station = await Db.CountingStations.FindAsync(staffDraft.StationId); if (station is null || !scope.Contains(station.RegionId)) { notice = "不能管理此计票所。"; return; } if (!await Db.UserRegionalRoleAssignments.AnyAsync(x => x.UserId == userId && x.RegionId == station.RegionId && (x.Role == RegionalRole.CountingStationClerk || x.Role == RegionalRole.Supervisor))) { notice = "用户必须先取得本辖区的计票员或监督员角色。"; return; } if (await Db.UserCountingStationAssignments.AnyAsync(x => x.UserId == userId && x.CountingStationId == station.Id)) { notice = "该用户已分配到此计票所。"; return; } Db.UserCountingStationAssignments.Add(new UserCountingStationAssignment { UserId = userId, CountingStationId = station.Id }); await Db.SaveChangesAsync(); notice = "工作人员已分配。"; staffDraft = new(); } private sealed class StationDraft { public string Code { get; set; } = ""; public string Name { get; set; } = ""; public Guid? RegionId { get; set; } } private sealed class StaffDraft { public Guid? StationId { get; set; } public string UserId { get; set; } = ""; } private sealed record Region(Guid Id, Guid? ParentId, AdministrativeRegionLevel Level, string Name, string Path); private sealed record StationRow(Guid Id, string Code, string Name, string Region, bool Active); private sealed record StationChoice(Guid Id, string Name); private sealed record Cursor(string Code, Guid Id); } diff --git a/src/ElectionSystem.Api/Components/Pages/Admin/Elections.razor b/src/ElectionSystem.Api/Components/Pages/Admin/Elections.razor index 0fb78e7..9d7d213 100644 --- a/src/ElectionSystem.Api/Components/Pages/Admin/Elections.razor +++ b/src/ElectionSystem.Api/Components/Pages/Admin/Elections.razor @@ -6,6 +6,7 @@ @using ElectionSystem.Api.Modules.Candidates.Domain @inject ElectionDbContext Db @inject RegionScopeService Scope +@inject RegionCascadeFilterService Cascade 投票发布
@@ -13,7 +14,7 @@ @if (notice is not null) { } @if (!loaded) {

正在加载授权范围…

} else { -

新建本级投票

 +

新建投票

可停在任一层级创建：全国、全省、全市、全县、镇街或村社。当前范围：@SelectedScopeName

@if (systemAdmin) {
}
@foreach (var election in elections) { }
活动地区状态截止时间
@election.Name@regionNames.GetValueOrDefault(election.RegionId, "—")@election.Status@election.VotingEndsAtUtc.ToString("yyyy-MM-dd HH:mm") UTC
@if (selected is not null) {

@selected.Name · 配置

状态：@selected.Status。@if (selected.Status != ElectionActivityStatus.Draft) { 已发布活动仅可查看。 }

@@ -30,11 +31,20 @@ @code { [CascadingParameter] private Task AuthenticationStateTask { get; set; } = default!; - private Guid actorId; private bool loaded; private string? notice; private readonly List elections = []; private readonly List contests = []; private readonly List options = []; private readonly List candidates = []; private readonly List stations = []; private readonly List publishRegions = []; private readonly Dictionary regionNames = []; private readonly HashSet selectedStationIds = []; private ElectionActivity? selected; private ElectionDraft draft = new(); private ContestDraft contestDraft = new(); private OptionDraft optionDraft = new(); - protected override async Task OnInitializedAsync() { actorId = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); var managed = await Scope.GetManagedRegionIdsAsync(actorId, CancellationToken.None); var allRegions = await Db.AdministrativeRegions.Where(x => managed.Contains(x.Id) && x.IsActive).OrderBy(x => x.Level).ThenBy(x => x.Code).ToListAsync(); foreach (var region in allRegions) { regionNames[region.Id] = region.Name; if (await IsDirectPublisherAsync(region.Id)) publishRegions.Add(region); } elections.AddRange(await Db.ElectionActivities.Where(x => managed.Contains(x.RegionId)).OrderByDescending(x => x.CreatedAtUtc).ToListAsync()); stations.AddRange(await Db.CountingStations.Where(x => managed.Contains(x.RegionId) && x.IsActive).OrderBy(x => x.Code).ToListAsync()); candidates.AddRange(await Db.Candidates.Where(x => managed.Contains(x.RegionId) && (x.Status == CandidateStatus.Approved || x.Status == CandidateStatus.Publicized)).OrderBy(x => x.DisplayName).ToListAsync()); loaded = true; } - private async Task IsDirectPublisherAsync(Guid regionId) { try { await Scope.RequirePublisherAtRegionAsync(actorId, regionId, CancellationToken.None); return true; } catch (UnauthorizedAccessException) { return false; } } + private Guid actorId; private bool loaded, systemAdmin; private string? notice; private HashSet managed = []; private Guid? provinceId, cityId, districtId, townshipId, villageId; private readonly List elections = []; private readonly List contests = []; private readonly List options = []; private readonly List candidates = []; private readonly List stations = []; private readonly List provinces = [], cities = [], districts = [], townships = [], villages = []; private readonly Dictionary regionNames = []; private readonly HashSet selectedStationIds = []; private ElectionActivity? selected; private ElectionDraft draft = new(); private ContestDraft contestDraft = new(); private OptionDraft optionDraft = new(); + protected override async Task OnInitializedAsync() { actorId = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); systemAdmin = await Db.UserRegionalRoleAssignments.AsNoTracking().AnyAsync(x => x.UserId == actorId && x.Role == RegionalRole.SystemAdministrator && x.RegionId == null); if (!systemAdmin) managed = await Scope.GetManagedRegionIdsAsync(actorId, CancellationToken.None); await LoadPublishRegionsAsync(); var query = Db.ElectionActivities.AsQueryable(); if (!systemAdmin) query = query.Where(x => managed.Contains(x.RegionId)); elections.AddRange(await query.OrderByDescending(x => x.CreatedAtUtc).ToListAsync()); var ids = elections.Select(x => x.RegionId).Distinct().ToArray(); foreach (var region in await Db.AdministrativeRegions.AsNoTracking().Where(x => ids.Contains(x.Id)).Select(x => new { x.Id, x.Name }).ToListAsync()) regionNames[region.Id] = region.Name; loaded = true; } + private async Task LoadPublishRegionsAsync() { if (systemAdmin) { await LoadRegionOptionsAsync(provinces, null, AdministrativeRegionLevel.Province); return; } var direct = await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && Db.UserRegionalRoleAssignments.Any(a => a.UserId == actorId && a.RegionId == x.Id && (a.Role == RegionalRole.ProvinceAdministrator || a.Role == RegionalRole.CityAdministrator || a.Role == RegionalRole.DistrictAdministrator || a.Role == RegionalRole.TownshipAdministrator || a.Role == RegionalRole.VillageAdministrator))).OrderBy(x => x.Code).Select(x => new RegionOption(x.Id, x.Level, x.Name)).ToListAsync(); provinces.AddRange(direct.Where(x => x.Level == AdministrativeRegionLevel.Province)); cities.AddRange(direct.Where(x => x.Level == AdministrativeRegionLevel.City)); districts.AddRange(direct.Where(x => x.Level == AdministrativeRegionLevel.District)); townships.AddRange(direct.Where(x => x.Level == AdministrativeRegionLevel.Township)); villages.AddRange(direct.Where(x => x.Level == AdministrativeRegionLevel.Village)); } + private async Task LoadRegionOptionsAsync(List target, Guid? parentId, AdministrativeRegionLevel level) { target.Clear(); target.AddRange(await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && x.Level == level && x.ParentId == parentId).OrderBy(x => x.Code).Select(x => new RegionOption(x.Id, x.Level, x.Name)).ToListAsync()); } + private async Task SelectProvinceAsync(ChangeEventArgs e) { provinceId = Parse(e); cityId = districtId = townshipId = villageId = null; draft.RegionId = provinceId; cities.Clear(); districts.Clear(); townships.Clear(); villages.Clear(); if (provinceId.HasValue) await LoadRegionOptionsAsync(cities, provinceId, AdministrativeRegionLevel.City); } + private async Task SelectCityAsync(ChangeEventArgs e) { cityId = Parse(e); districtId = townshipId = villageId = null; draft.RegionId = cityId ?? provinceId; districts.Clear(); townships.Clear(); villages.Clear(); if (cityId.HasValue) await LoadRegionOptionsAsync(districts, cityId, AdministrativeRegionLevel.District); } + private async Task SelectDistrictAsync(ChangeEventArgs e) { districtId = Parse(e); townshipId = villageId = null; draft.RegionId = districtId ?? cityId ?? provinceId; townships.Clear(); villages.Clear(); if (districtId.HasValue) await LoadRegionOptionsAsync(townships, districtId, AdministrativeRegionLevel.Township); } + private async Task SelectTownshipAsync(ChangeEventArgs e) { townshipId = Parse(e); villageId = null; draft.RegionId = townshipId ?? districtId ?? cityId ?? provinceId; villages.Clear(); if (townshipId.HasValue) await LoadRegionOptionsAsync(villages, townshipId, AdministrativeRegionLevel.Village); } + private Task SelectVillageAsync(ChangeEventArgs e) { villageId = Parse(e); draft.RegionId = villageId ?? townshipId ?? districtId ?? cityId ?? provinceId; return Task.CompletedTask; } + private void SelectNationwide() { provinceId = cityId = districtId = townshipId = villageId = null; draft.RegionId = RegionScopeService.NationwideRegionId; cities.Clear(); districts.Clear(); townships.Clear(); villages.Clear(); } + private string SelectedScopeName => draft.RegionId == RegionScopeService.NationwideRegionId ? "全国" : villageId.HasValue ? villages.SingleOrDefault(x => x.Id == villageId.Value)?.Name ?? "村社" : townshipId.HasValue ? townships.SingleOrDefault(x => x.Id == townshipId.Value)?.Name ?? "镇街" : districtId.HasValue ? districts.SingleOrDefault(x => x.Id == districtId.Value)?.Name ?? "区县" : cityId.HasValue ? cities.SingleOrDefault(x => x.Id == cityId.Value)?.Name ?? "市" : provinceId.HasValue ? provinces.SingleOrDefault(x => x.Id == provinceId.Value)?.Name ?? "省" : "未选择"; + private static Guid? Parse(ChangeEventArgs e) => Guid.TryParse(e.Value?.ToString(), out var id) ? id : null; private async Task CreateAsync() { try { if (!draft.RegionId.HasValue) throw new ArgumentException("请选择要发布投票的本级地区。"); await Scope.RequirePublisherAtRegionAsync(actorId, draft.RegionId.Value, CancellationToken.None); var start = Utc(draft.VotingStarts); var end = Utc(draft.VotingEnds); var countingEnd = Utc(draft.CountingEnds); if (start >= end || end > countingEnd) throw new ArgumentException("时间必须满足投票开始 < 投票截止 <= 计票截止。"); var election = new ElectionActivity { Name = Text(draft.Name), RegionId = draft.RegionId.Value, VotingStartsAtUtc = start, VotingEndsAtUtc = end, CountingEndsAtUtc = countingEnd, PublishLiveParticipation = draft.PublishLiveParticipation, PublishLiveCandidateTotals = draft.PublishLiveCandidateTotals, CreatedByUserId = actorId }; Db.ElectionActivities.Add(election); await Db.SaveChangesAsync(); elections.Insert(0, election); selected = election; notice = "草稿已创建，请继续配置议题和计票所。"; } catch (Exception exception) { notice = exception.Message; } } - private async Task SelectAsync(Guid id) { selected = elections.Single(x => x.Id == id); contests.Clear(); contests.AddRange(await Db.ElectionContests.Where(x => x.ElectionActivityId == id).OrderBy(x => x.SortOrder).ToListAsync()); options.Clear(); options.AddRange(await Db.ElectionOptions.Where(x => contests.Select(c => c.Id).Contains(x.ElectionContestId)).OrderBy(x => x.SortOrder).ToListAsync()); selectedStationIds.Clear(); foreach (var stationId in await Db.ElectionCountingStations.Where(x => x.ElectionActivityId == id).Select(x => x.CountingStationId).ToListAsync()) selectedStationIds.Add(stationId); } + private async Task SelectAsync(Guid id) { selected = elections.Single(x => x.Id == id); if (systemAdmin && managed.Count == 0) managed = await Scope.GetManagedRegionIdsAsync(actorId, CancellationToken.None); contests.Clear(); contests.AddRange(await Db.ElectionContests.Where(x => x.ElectionActivityId == id).OrderBy(x => x.SortOrder).ToListAsync()); options.Clear(); options.AddRange(await Db.ElectionOptions.Where(x => contests.Select(c => c.Id).Contains(x.ElectionContestId)).OrderBy(x => x.SortOrder).ToListAsync()); var level = await Db.AdministrativeRegions.AsNoTracking().Where(x => x.Id == selected.RegionId).Select(x => x.Level).SingleAsync(); HashSet eligibleRegions; if (selected.RegionId == RegionScopeService.NationwideRegionId) eligibleRegions = managed; else if (level == AdministrativeRegionLevel.Village) { if (!managed.Contains(selected.RegionId)) throw new UnauthorizedAccessException("投票目标地区超出当前管理范围。"); eligibleRegions = [selected.RegionId]; } else { var filter = level switch { AdministrativeRegionLevel.Province => new AdministrativeRegionFilter(selected.RegionId, null, null, null), AdministrativeRegionLevel.City => new AdministrativeRegionFilter(null, selected.RegionId, null, null), AdministrativeRegionLevel.District => new AdministrativeRegionFilter(null, null, selected.RegionId, null), AdministrativeRegionLevel.Township => new AdministrativeRegionFilter(null, null, null, selected.RegionId), _ => throw new InvalidOperationException("投票目标地区无效。") }; eligibleRegions = await Cascade.ResolveAsync(managed, filter, CancellationToken.None); } candidates.Clear(); candidates.AddRange(await Db.Candidates.AsNoTracking().Where(x => eligibleRegions.Contains(x.RegionId) && (x.Status == CandidateStatus.Approved || x.Status == CandidateStatus.Publicized)).OrderBy(x => x.DisplayName).ToListAsync()); stations.Clear(); stations.AddRange(await Db.CountingStations.AsNoTracking().Where(x => eligibleRegions.Contains(x.RegionId) && x.IsActive).OrderBy(x => x.Code).ToListAsync()); selectedStationIds.Clear(); foreach (var stationId in await Db.ElectionCountingStations.Where(x => x.ElectionActivityId == id).Select(x => x.CountingStationId).ToListAsync()) selectedStationIds.Add(stationId); } private async Task AddContestAsync() { try { await RequireDraftPublisherAsync(); if (contestDraft.MinSelections < 0 || contestDraft.MinSelections > contestDraft.MaxSelections || contestDraft.MaxSelections > contestDraft.Seats || contestDraft.RequiredSupportPercent is <= 0 or > 100) throw new ArgumentException("选择数或门槛配置无效。"); var contest = new ElectionContest { ElectionActivityId = selected!.Id, Title = Text(contestDraft.Title), Type = contestDraft.Type, SortOrder = contests.Count + 1, Seats = contestDraft.Type == ElectionContestType.Proposition ? 1 : contestDraft.Seats, MinSelections = contestDraft.Type == ElectionContestType.Proposition ? 1 : contestDraft.MinSelections, MaxSelections = contestDraft.Type == ElectionContestType.Proposition ? 1 : contestDraft.MaxSelections, Determination = contestDraft.Determination, RequiredSupportPercent = contestDraft.RequiredSupportPercent }; Db.ElectionContests.Add(contest); await Db.SaveChangesAsync(); contests.Add(contest); contestDraft = new(); notice = "议题已添加。"; } catch (Exception exception) { notice = exception.Message; } } private async Task AddOptionAsync() { try { await RequireDraftPublisherAsync(); if (!optionDraft.ContestId.HasValue) throw new ArgumentException("请选择议题。"); var contest = contests.Single(x => x.Id == optionDraft.ContestId); if (contest.Type == ElectionContestType.CandidateElection && !optionDraft.CandidateId.HasValue) throw new ArgumentException("岗位竞选必须选择候选人。"); if (contest.Type == ElectionContestType.Proposition && optionDraft.CandidateId.HasValue) throw new ArgumentException("议案选项不能关联候选人。"); if (optionDraft.CandidateId.HasValue) { var candidate = candidates.SingleOrDefault(x => x.Id == optionDraft.CandidateId.Value) ?? throw new ArgumentException("候选人不可用。"); if (!await Scope.IsInRegionSubtreeAsync(candidate.RegionId, selected!.RegionId, CancellationToken.None)) throw new ArgumentException("候选人必须属于该活动辖区。"); } if (options.Any(x => x.ElectionContestId == contest.Id && (x.Label == optionDraft.Label.Trim() || (optionDraft.CandidateId.HasValue && x.CandidateId == optionDraft.CandidateId)))) throw new ArgumentException("该候选人或选项已存在。"); var option = new ElectionOption { ElectionContestId = contest.Id, CandidateId = optionDraft.CandidateId, Label = Text(optionDraft.Label), SortOrder = options.Count(x => x.ElectionContestId == contest.Id) + 1 }; Db.ElectionOptions.Add(option); await Db.SaveChangesAsync(); options.Add(option); optionDraft = new(); notice = "选项已添加。"; } catch (Exception exception) { notice = exception.Message; } } private void ToggleStation(Guid stationId, ChangeEventArgs e) { if (e.Value is bool value && value) selectedStationIds.Add(stationId); else selectedStationIds.Remove(stationId); } @@ -45,4 +55,5 @@ private sealed class ElectionDraft { public string Name { get; set; } = ""; public Guid? RegionId { get; set; } public DateTime VotingStarts { get; set; } = DateTime.UtcNow.AddDays(1); public DateTime VotingEnds { get; set; } = DateTime.UtcNow.AddDays(2); public DateTime CountingEnds { get; set; } = DateTime.UtcNow.AddDays(3); public bool PublishLiveParticipation { get; set; } = true; public bool PublishLiveCandidateTotals { get; set; } } private sealed class ContestDraft { public string Title { get; set; } = ""; public ElectionContestType Type { get; set; } = ElectionContestType.CandidateElection; public int Seats { get; set; } = 1; public int MinSelections { get; set; } = 1; public int MaxSelections { get; set; } = 1; public WinnerDetermination Determination { get; set; } = WinnerDetermination.HighestVotes; public decimal RequiredSupportPercent { get; set; } = 50m; } private sealed class OptionDraft { public Guid? ContestId { get; set; } public Guid? CandidateId { get; set; } public string Label { get; set; } = ""; } + private sealed record RegionOption(Guid Id, AdministrativeRegionLevel Level, string Name); } diff --git a/src/ElectionSystem.Api/Components/Pages/Admin/Voters.razor b/src/ElectionSystem.Api/Components/Pages/Admin/Voters.razor index ef3fe7c..007f0e8 100644 --- a/src/ElectionSystem.Api/Components/Pages/Admin/Voters.razor +++ b/src/ElectionSystem.Api/Components/Pages/Admin/Voters.razor @@ -11,10 +11,10 @@

基础资料 / 选民

选民管理

按省、市、区县、镇街筛选；结果仅包含当前辖区及下级地区。

@if (message is not null) {
@message
}
- - - - + + + +
@if (creating) {

新增选民

 } @@ -23,21 +23,22 @@ @code { private const int PageSize = 50; [CascadingParameter] private Task AuthenticationStateTask { get; set; } = default!; - private readonly List voters = []; private readonly List regions = []; private readonly List filterRegions = []; private readonly List cursorHistory = []; + private readonly List voters = []; private readonly List regions = [], provinces = [], cities = [], districts = [], townships = []; private readonly List cursorHistory = []; private VoterDraft draft = new(); private string keyword = "", status = ""; private bool loaded, creating; private string? message, currentCursor, nextCursor; private HashSet managed = []; private Guid? provinceId, cityId, districtId, townshipId; protected override async Task OnInitializedAsync() { await LoadRegionsAsync(); await SearchAsync(); } - private async Task LoadRegionsAsync() { var id = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); managed = await Scope.GetManagedRegionIdsAsync(id, CancellationToken.None); var all = await Db.AdministrativeRegions.Where(x => managed.Contains(x.Id) && x.IsActive).OrderBy(x => x.Level).ThenBy(x => x.Code).ToListAsync(); filterRegions.AddRange(all.Select(x => new RegionOption(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}"))); regions.AddRange(filterRegions); } - private IEnumerable Options(AdministrativeRegionLevel level, Guid? parentId) => filterRegions.Where(x => x.Level == level && (!parentId.HasValue || x.ParentId == parentId)).OrderBy(x => x.Name); - private async Task SelectProvinceAsync(ChangeEventArgs e) { provinceId = Parse(e); cityId = districtId = townshipId = null; await SearchAsync(); } - private async Task SelectCityAsync(ChangeEventArgs e) { cityId = Parse(e); districtId = townshipId = null; await SearchAsync(); } - private async Task SelectDistrictAsync(ChangeEventArgs e) { districtId = Parse(e); townshipId = null; await SearchAsync(); } + private async Task LoadRegionsAsync() { var id = RegionScopeService.GetRequiredUserId((await AuthenticationStateTask).User); managed = await Scope.GetManagedRegionIdsAsync(id, CancellationToken.None); await LoadInitialOptionsAsync(id); } + private async Task LoadInitialOptionsAsync(Guid userId) { var systemAdmin = await Db.UserRegionalRoleAssignments.AsNoTracking().AnyAsync(x => x.UserId == userId && x.Role == RegionalRole.SystemAdministrator && x.RegionId == null); if (systemAdmin) { await LoadOptionsAsync(provinces, null, AdministrativeRegionLevel.Province); return; } var roots = await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && Db.UserRegionalRoleAssignments.Any(a => a.UserId == userId && a.RegionId == x.Id && (a.Role == RegionalRole.ProvinceAdministrator || a.Role == RegionalRole.CityAdministrator || a.Role == RegionalRole.DistrictAdministrator || a.Role == RegionalRole.TownshipAdministrator))).OrderBy(x => x.Code).Select(x => new RegionOption(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync(); provinces.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.Province)); cities.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.City)); districts.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.District)); townships.AddRange(roots.Where(x => x.Level == AdministrativeRegionLevel.Township)); } + private async Task LoadOptionsAsync(List target, Guid? parentId, AdministrativeRegionLevel level) { target.Clear(); target.AddRange(await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && x.Level == level && x.ParentId == parentId && managed.Contains(x.Id)).OrderBy(x => x.Code).Select(x => new RegionOption(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync()); } + private async Task SelectProvinceAsync(ChangeEventArgs e) { provinceId = Parse(e); cityId = districtId = townshipId = null; cities.Clear(); districts.Clear(); townships.Clear(); if (provinceId.HasValue) await LoadOptionsAsync(cities, provinceId, AdministrativeRegionLevel.City); await SearchAsync(); } + private async Task SelectCityAsync(ChangeEventArgs e) { cityId = Parse(e); districtId = townshipId = null; districts.Clear(); townships.Clear(); if (cityId.HasValue) await LoadOptionsAsync(districts, cityId, AdministrativeRegionLevel.District); await SearchAsync(); } + private async Task SelectDistrictAsync(ChangeEventArgs e) { districtId = Parse(e); townshipId = null; townships.Clear(); if (districtId.HasValue) await LoadOptionsAsync(townships, districtId, AdministrativeRegionLevel.Township); await SearchAsync(); } private async Task SelectTownshipAsync(ChangeEventArgs e) { townshipId = Parse(e); await SearchAsync(); } private static Guid? Parse(ChangeEventArgs e) => Guid.TryParse(e.Value?.ToString(), out var id) ? id : null; private async Task SearchAsync() { currentCursor = null; cursorHistory.Clear(); await LoadAsync(); } private async Task NextAsync() { if (nextCursor is null) return; cursorHistory.Add(currentCursor); currentCursor = nextCursor; await LoadAsync(); } private async Task PreviousAsync() { if (cursorHistory.Count == 0) return; currentCursor = cursorHistory[^1]; cursorHistory.RemoveAt(cursorHistory.Count - 1); await LoadAsync(); } private async Task LoadAsync() { loaded = false; try { var selectedRegions = await Cascade.ResolveAsync(managed, new(provinceId, cityId, districtId, townshipId), CancellationToken.None); var query = Db.Voters.Where(x => selectedRegions.Contains(x.RegionId)); if (!string.IsNullOrWhiteSpace(keyword)) query = query.Where(x => x.VoterNumber.Contains(keyword) || x.DisplayName.Contains(keyword)); if (Enum.TryParse(status, out var state)) query = query.Where(x => x.Status == state); if (!CursorToken.TryDecode(currentCursor, out var token)) throw new InvalidOperationException("分页游标无效，请重新查询。"); if (token is not null) query = query.Where(x => string.Compare(x.DisplayName, token.DisplayName) > 0 || (x.DisplayName == token.DisplayName && x.Id.CompareTo(token.Id) > 0)); var rows = await query.OrderBy(x => x.DisplayName).ThenBy(x => x.Id).Take(PageSize + 1).Select(x => new { x.Id, x.VoterNumber, x.DisplayName, x.RegionId, x.Status }).ToListAsync(); var hasMore = rows.Count > PageSize; if (hasMore) rows.RemoveAt(rows.Count - 1); var names = await Db.AdministrativeRegions.Where(x => rows.Select(y => y.RegionId).Contains(x.Id)).ToDictionaryAsync(x => x.Id, x => x.Name); voters.Clear(); voters.AddRange(rows.Select(x => new VoterRow(x.Id, x.VoterNumber, x.DisplayName, names.GetValueOrDefault(x.RegionId, "—"), x.Status))); nextCursor = hasMore && rows.Count > 0 ? CursorToken.Encode(new Cursor(rows[^1].DisplayName, rows[^1].Id)) : null; } catch (ArgumentException e) { message = e.Message; voters.Clear(); nextCursor = null; } finally { loaded = true; } } - private void ToggleCreate() { creating = !creating; message = null; } + private async Task ToggleCreate() { creating = !creating; message = null; if (creating && regions.Count == 0) regions.AddRange(await Db.AdministrativeRegions.AsNoTracking().Where(x => x.IsActive && managed.Contains(x.Id)).OrderBy(x => x.Level).ThenBy(x => x.Code).Select(x => new RegionOption(x.Id, x.ParentId, x.Level, x.Name, $"{x.Level}: {x.Name}")).ToListAsync()); } private async Task CreateAsync() { if (!draft.RegionId.HasValue || !managed.Contains(draft.RegionId.Value)) { message = "请选择您有权管理的行政区划。"; return; } if (await Db.Voters.AnyAsync(x => x.VoterNumber == draft.VoterNumber)) { message = "选民编号已存在。"; return; } Db.Voters.Add(new VoterProfile { VoterNumber = draft.VoterNumber.Trim(), DisplayName = draft.DisplayName.Trim(), RegionId = draft.RegionId.Value }); await Db.SaveChangesAsync(); draft = new(); creating = false; message = "已新增选民。"; await SearchAsync(); } private async Task SetStatusAsync(VoterRow voter, VoterStatus target) { var entity = await Db.Voters.FindAsync(voter.Id); if (entity is null || !managed.Contains(entity.RegionId)) { message = "未找到可管理的选民。"; return; } entity.Status = target; entity.DisabledReason = target == VoterStatus.Disabled ? "管理员在管理端停用" : null; entity.UpdatedAtUtc = DateTime.UtcNow; await Db.SaveChangesAsync(); message = target == VoterStatus.Disabled ? "已停用选民。" : "已恢复选民。"; await LoadAsync(); } private static string StatusText(VoterStatus value) => value switch { VoterStatus.Active => "有效", VoterStatus.Disabled => "已停用", _ => "待审核" }; diff --git a/src/ElectionSystem.Api/Modules/Organization/AreaCityCatalogBootstrapService.cs b/src/ElectionSystem.Api/Modules/Organization/AreaCityCatalogBootstrapService.cs index 5334442..ad44135 100644 --- a/src/ElectionSystem.Api/Modules/Organization/AreaCityCatalogBootstrapService.cs +++ b/src/ElectionSystem.Api/Modules/Organization/AreaCityCatalogBootstrapService.cs @@ -9,6 +9,22 @@ public sealed class AreaCityCatalogBootstrapService(IServiceScopeFactory scopeFa { await using var scope = scopeFactory.CreateAsyncScope(); var db = scope.ServiceProvider.GetRequiredService(); + var nationwide = await db.AdministrativeRegions.SingleOrDefaultAsync(x => x.Id == RegionScopeService.NationwideRegionId, cancellationToken); + if (nationwide is null) + { + db.AdministrativeRegions.Add(new Domain.AdministrativeRegion + { + Id = RegionScopeService.NationwideRegionId, + Code = "CN", + Name = "全国", + Level = Domain.AdministrativeRegionLevel.Nationwide, + Source = "ElectionSystem", + SourceVersion = "1", + IsSynthetic = true + }); + await db.SaveChangesAsync(cancellationToken); + } + if (await db.AdministrativeRegions.AnyAsync(x => x.Source == "AreaCity-JsSpider-StatsGov", cancellationToken)) return; var path = Path.Combine(environment.ContentRootPath, "Data", "areacity-level4.csv"); diff --git a/src/ElectionSystem.Api/Modules/Organization/Domain/AdministrativeRegion.cs b/src/ElectionSystem.Api/Modules/Organization/Domain/AdministrativeRegion.cs index 1250bf6..b99c135 100644 --- a/src/ElectionSystem.Api/Modules/Organization/Domain/AdministrativeRegion.cs +++ b/src/ElectionSystem.Api/Modules/Organization/Domain/AdministrativeRegion.cs @@ -2,6 +2,7 @@ namespace ElectionSystem.Api.Modules.Organization.Domain; public enum AdministrativeRegionLevel { + Nationwide = 0, Province = 1, City = 2, District = 3, diff --git a/src/ElectionSystem.Api/Modules/Organization/RegionCascadeFilterService.cs b/src/ElectionSystem.Api/Modules/Organization/RegionCascadeFilterService.cs index 38969a5..6ec4944 100644 --- a/src/ElectionSystem.Api/Modules/Organization/RegionCascadeFilterService.cs +++ b/src/ElectionSystem.Api/Modules/Organization/RegionCascadeFilterService.cs @@ -13,10 +13,20 @@ public sealed class RegionCascadeFilterService(ElectionDbContext dbContext) { if (managedRegionIds.Count == 0) return []; - var regions = await dbContext.AdministrativeRegions - .Where(x => x.IsActive) - .Select(x => new RegionNode(x.Id, x.ParentId, x.Level)) - .ToListAsync(cancellationToken); + // A four-level filter is used on several interactive pages. Do not load the + // complete national catalogue for every query: only the selected nodes need + // validation, and descendants are fetched level by level when required. + var ids = new[] { filter.ProvinceId, filter.CityId, filter.DistrictId, filter.TownshipId } + .Where(x => x.HasValue) + .Select(x => x!.Value) + .Distinct() + .ToArray(); + var regions = ids.Length == 0 + ? [] + : await dbContext.AdministrativeRegions.AsNoTracking() + .Where(x => x.IsActive && ids.Contains(x.Id)) + .Select(x => new RegionNode(x.Id, x.ParentId, x.Level)) + .ToListAsync(cancellationToken); var byId = regions.ToDictionary(x => x.Id); Validate(filter.ProvinceId, AdministrativeRegionLevel.Province, byId, managedRegionIds); Validate(filter.CityId, AdministrativeRegionLevel.City, byId, managedRegionIds); @@ -29,14 +39,16 @@ public sealed class RegionCascadeFilterService(ElectionDbContext dbContext) var selectedId = filter.TownshipId ?? filter.DistrictId ?? filter.CityId ?? filter.ProvinceId; if (!selectedId.HasValue) return managedRegionIds; - var children = regions.Where(x => x.ParentId.HasValue) - .GroupBy(x => x.ParentId!.Value) - .ToDictionary(x => x.Key, x => x.Select(y => y.Id).ToArray()); var subtree = new HashSet { selectedId.Value }; - var queue = new Queue(subtree); - while (queue.TryDequeue(out var parentId) && children.TryGetValue(parentId, out var childIds)) - foreach (var childId in childIds) - if (subtree.Add(childId)) queue.Enqueue(childId); + var parents = new HashSet(subtree); + while (parents.Count != 0) + { + var childIds = await dbContext.AdministrativeRegions.AsNoTracking() + .Where(x => x.IsActive && x.ParentId.HasValue && parents.Contains(x.ParentId.Value)) + .Select(x => x.Id) + .ToListAsync(cancellationToken); + parents = childIds.Where(subtree.Add).ToHashSet(); + } subtree.IntersectWith(managedRegionIds); return subtree; diff --git a/src/ElectionSystem.Api/Modules/Organization/RegionScopeService.cs b/src/ElectionSystem.Api/Modules/Organization/RegionScopeService.cs index 14dc17c..7249099 100644 --- a/src/ElectionSystem.Api/Modules/Organization/RegionScopeService.cs +++ b/src/ElectionSystem.Api/Modules/Organization/RegionScopeService.cs @@ -7,6 +7,11 @@ namespace ElectionSystem.Api.Modules.Organization; public sealed class RegionScopeService(ElectionDbContext dbContext) { + // A durable root used only as an election scope. Provinces intentionally keep + // their authoritative AreaCity parentage, so nationwide containment is handled + // explicitly rather than rewriting the imported catalogue. + public static readonly Guid NationwideRegionId = Guid.Parse("6ff2f32f-12b9-4c41-9ff0-df446deaeb52"); + public static Guid GetRequiredUserId(ClaimsPrincipal principal) { var raw = principal.FindFirstValue(ClaimTypes.NameIdentifier) ?? principal.FindFirstValue("sub"); @@ -44,6 +49,9 @@ public sealed class RegionScopeService(ElectionDbContext dbContext) public async Task RequirePublisherAtRegionAsync(Guid userId, Guid regionId, CancellationToken cancellationToken) { + if (!await dbContext.AdministrativeRegions.AnyAsync(x => x.Id == regionId && x.IsActive, cancellationToken)) + throw new ArgumentException("投票范围不存在或已停用。"); + var isPublisher = await dbContext.UserRegionalRoleAssignments.AnyAsync(x => x.UserId == userId && ((x.Role == RegionalRole.SystemAdministrator && x.RegionId == null) || (x.RegionId == regionId && (x.Role == RegionalRole.ProvinceAdministrator || x.Role == RegionalRole.CityAdministrator || x.Role == RegionalRole.DistrictAdministrator || x.Role == RegionalRole.TownshipAdministrator || x.Role == RegionalRole.VillageAdministrator))), cancellationToken); @@ -61,6 +69,9 @@ public sealed class RegionScopeService(ElectionDbContext dbContext) public async Task IsInRegionSubtreeAsync(Guid regionId, Guid rootRegionId, CancellationToken cancellationToken) { + if (rootRegionId == NationwideRegionId) + return await dbContext.AdministrativeRegions.AnyAsync(x => x.Id == regionId && x.IsActive, cancellationToken); + var current = await dbContext.AdministrativeRegions.Where(x => x.Id == regionId).Select(x => new { x.Id, x.ParentId }).SingleOrDefaultAsync(cancellationToken); while (current is not null) { diff --git a/tests/ElectionSystem.Api.Tests/RegionScopeServiceTests.cs b/tests/ElectionSystem.Api.Tests/RegionScopeServiceTests.cs new file mode 100644 index 0000000..691c9cd --- /dev/null +++ b/tests/ElectionSystem.Api.Tests/RegionScopeServiceTests.cs @@ -0,0 +1,37 @@ +using ElectionSystem.Api.Infrastructure.Persistence; +using ElectionSystem.Api.Modules.Organization; +using ElectionSystem.Api.Modules.Organization.Domain; +using Microsoft.EntityFrameworkCore; + +namespace ElectionSystem.Api.Tests; + +public sealed class RegionScopeServiceTests +{ + [Fact] + public async Task Nationwide_scope_contains_every_active_administrative_region() + { + var options = new DbContextOptionsBuilder() + .UseInMemoryDatabase(Guid.NewGuid().ToString()) + .Options; + await using var context = new ElectionDbContext(options); + var province = Region("11", "省", AdministrativeRegionLevel.Province); + var disabled = Region("12", "停用省", AdministrativeRegionLevel.Province); + disabled.IsActive = false; + context.AddRange(province, disabled); + await context.SaveChangesAsync(); + + var scope = new RegionScopeService(context); + + Assert.True(await scope.IsInRegionSubtreeAsync(province.Id, RegionScopeService.NationwideRegionId, CancellationToken.None)); + Assert.False(await scope.IsInRegionSubtreeAsync(disabled.Id, RegionScopeService.NationwideRegionId, CancellationToken.None)); + } + + private static AdministrativeRegion Region(string code, string name, AdministrativeRegionLevel level) => new() + { + Code = code, + Name = name, + Level = level, + Source = "test", + SourceVersion = "1" + }; +}