在.NET 8中使用LINQ按ISO_WEEK聚合分组数据的问题排查

问题背景 #

前端已确保传入的是完整ISO周的UTC时间范围，示例如下：

startdate : 23-02-2025 23:00:00 UTC
endate    : 02-03-2025 23:59:59 UTC 
UTC+1时区下该范围对应ISO第9周

现有查询与聚合代码如上，但实际分组后返回了第8周部分数据+第9周完整数据，不符合预期的单条ISO周聚合结果。

核心原因 #

分组逻辑的周起始规则与ISO周不匹配：

• 当前GroupByWeek方法通过DateDiffDay以1900-01-01为基准计算周起始，最终得到的是周日到周六的周范围；
• 而ISO周的规则是周一到周日，且周数计算以周一为起始日。

这种错位导致：

• ISO第9周的周一（2025-02-24）被分到了以周日（2025-02-23）为起始的分组中，该分组的PeriodLabel会被ISOWeek.GetWeekOfYear标记为第8周；
• ISO第9周的周日（2025-03-02）则被分到下一个周日起始的分组，标记为第9周；
• 再加上前端传入的结束时间对应本地已进入第10周，进一步加剧了分组混乱。

修复方案 #

方案1：EF Core原生函数实现ISO周分组（推荐） #

修改GroupByWeek方法，使用ISO标准的星期计算逻辑，确保周起始为周一：

private static IQueryable<IGrouping<GroupKey, Reading>> GroupByWeek(
    IQueryable<Reading> query,
    string timeZoneName)
{
    return query
        .Select(reading => new
        {
            Reading = reading,
            // 将UTC时间转换为目标时区的本地日期
            LocalDate = EF.Functions.AtTimeZone(reading.Start, "UTC")
                          .AtTimeZone(timeZoneName)
                          .Date
        })
        .GroupBy(x => new GroupKey
        {
            StructureId = x.Reading.StructureId,
            // 计算ISO周的周一作为分组起始点
            LocalTimeStamp = EF.Functions.DateAdd(
                DateInterval.Day,
                -(EF.Functions.DatePart("iso_weekday", x.LocalDate) - 1),
                x.LocalDate)
        }, x => x.Reading);
}

• iso_weekday是EF Core支持的ISO标准星期字段，返回1=周一、7=周日；
• 通过DateAdd减去当前日期到周一的偏移量，直接得到ISO周的起始日。

方案2：内存中处理（兼容低版本EF） #

如果EF版本不支持iso_weekday，可先将数据加载到内存，使用.NET内置的ISOWeek类处理：

private static IQueryable<IGrouping<GroupKey, Reading>> GroupByWeek(
    IQueryable<Reading> query,
    string timeZoneName)
{
    var readingsWithLocalTime = query
        .Select(reading => new
        {
            Reading = reading,
            LocalDateTime = EF.Functions.AtTimeZone(reading.Start, "UTC")
                          .AtTimeZone(timeZoneName)
        })
        .AsEnumerable() // 切换到内存处理
        .Select(x => new
        {
            x.Reading,
            // 直接获取ISO周的起始周一
            IsoWeekStart = ISOWeek.ToDateTime(
                ISOWeek.GetYear(x.LocalDateTime.Date),
                ISOWeek.GetWeekOfYear(x.LocalDateTime.Date),
                DayOfWeek.Monday)
        });

    return readingsWithLocalTime
        .GroupBy(x => new GroupKey
        {
            StructureId = x.Reading.StructureId,
            LocalTimeStamp = x.IsoWeekStart
        }, x => x.Reading)
        .AsQueryable();
}

注：此方法会将数据加载到内存，数据量大时需谨慎使用。

额外调整：前端日期范围校准 #

当前示例中的结束时间02-03-2025 23:59:59 UTC转换为UTC+1时区是03-03-2025 00:59:59，已超出ISO第9周的范围（截止到2025-03-02）。需前端调整结束时间为ISO周最后一天本地23:59对应的UTC时间，确保范围完全匹配ISO周。

验证效果 #

修改后，分组逻辑将严格遵循ISO周规则聚合数据，前端传入的完整ISO周范围会被正确合并为单条聚合结果，不会出现跨周分组的情况。

内容的提问来源于stack exchange，提问作者leroyv