如何修改MongoDB聚合查询以按特定时区筛选数据？

问题分析 #

MongoDB默认以UTC时区存储时间戳，用户在**+8时区12月21日凌晨2点注册，对应的UTC时间是12月20日20:40:09.275+00:00**。现有查询使用+8时区的日期直接生成起止时间，但因时区转换逻辑不严谨，无法匹配到该UTC时间对应的记录。

解决方案 #

方案一：转换目标时区日期为UTC时间范围（推荐，可利用索引） #

核心思路：将+8时区的「当日起止时间」转换为对应的UTC时间范围，直接用UTC时间匹配MongoDB存储的createdAt，既能保证查询准确性，又能利用createdAt字段的索引，保障查询性能。

修改代码如下：

const tz = 'Asia/Shanghai'; // 明确指定+8时区

let currentWeekDates = [
   '2022-12-19T00:00:00+08:00',
   '2022-12-20T00:00:00+08:00',
   '2022-12-21T00:00:00+08:00',
   '2022-12-22T00:00:00+08:00',
   '2022-12-23T00:00:00+08:00',
   '2022-12-24T00:00:00+08:00',
   '2022-12-25T00:00:00+08:00'
]

const facet = {};
for (let date of currentWeekDates) {
    const formatedDate = moment.tz(date, tz).format('YYYY-MM-DD');
    // 计算+8时区当日的起止时间，转换为UTC时间对象
    const startOfDayUTC = moment.tz(date, tz).startOf('day').utc().toDate();
    const endOfDayUTC = moment.tz(date, tz).endOf('day').utc().toDate();
    
    facet[formatedDate] = [
      {
        $match: {
          createdAt: { $gte: startOfDayUTC, $lte: endOfDayUTC }
        }
      }
    ]
}

let data = await User.aggregate([{ $facet: facet }]);

关键说明：

• 使用moment.tz明确绑定时区，避免服务器本地时区干扰计算结果；
• 对+8时区的日期执行startOf('day')和endOf('day')后，转换为UTC时间，确保查询范围精准覆盖目标用户的UTC注册时间。

方案二：在聚合中转换UTC时间到目标时区（无索引依赖，适合小数据集） #

如果无法调整查询时间范围，可在聚合管道中将存储的UTC时间转换为+8时区的日期后再匹配。但此方法会跳过createdAt的索引，大数据量下性能会受影响。

修改代码如下：

const tz = 'Asia/Shanghai';

let currentWeekDates = [
   '2022-12-19T00:00:00+08:00',
   '2022-12-20T00:00:00+08:00',
   '2022-12-21T00:00:00+08:00',
   '2022-12-22T00:00:00+08:00',
   '2022-12-23T00:00:00+08:00',
   '2022-12-24T00:00:00+08:00',
   '2022-12-25T00:00:00+08:00'
]

const facet = {};
for (let date of currentWeekDates) {
    const formatedDate = moment.tz(date, tz).format('YYYY-MM-DD');
    
    facet[formatedDate] = [
      {
        $addFields: {
          // 将UTC时间转换为+8时区的日期字符串
          createdAtLocal: {
            $dateToString: {
              format: "%Y-%m-%d",
              date: "$createdAt",
              timezone: tz
            }
          }
        }
      },
      {
        $match: {
          createdAtLocal: formatedDate
        }
      }
    ]
}

let data = await User.aggregate([{ $facet: facet }]);

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