Mongoose使用aggregate与lookup查询关联团队及清理失效用户方案

你原代码的错误点如下：

• Mongoose aggregate 方法接收的是聚合阶段组成的数组，不能直接传入对象
• $lookup 配置的字段名是驼峰格式：localField、foreignField，不是下划线分隔的命名

你要的引用associatedTeams数组内teamId字段的写法很简单，直接用点语法associatedTeams.teamId即可，完整的聚合查询写法如下：

const deletedUserId = "待删除用户的ObjectId";
const aggResult = await UserInfo.aggregate([
  // 匹配待删除的目标用户
  {
    $match: { _id: deletedUserId }
  },
  // 关联查询用户所属的所有团队
  {
    $lookup: {
      from: Team.collection.name,
      localField: "associatedTeams.teamId",
      foreignField: "_id",
      as: "relatedTeams"
    }
  },
  // 仅返回关联的团队数据
  {
    $project: { relatedTeams: 1, _id: 0 }
  }
]);
const relatedTeams = aggResult[0]?.relatedTeams || [];

拿到关联团队后，你可以用以下代码批量将用户从团队的players数组中移除：

await Team.updateMany(
  { _id: { $in: relatedTeams.map(team => team._id) } },
  { $pull: { players: deletedUserId } }
);

更简洁的实现方案（无需使用聚合） #

这个场景下你完全不需要走聚合查询，直接读取用户的associatedTeams字段提取团队ID即可，代码更简洁性能也更好：

const deletedUserId = "待删除用户的ObjectId";
// 仅查询用户的associatedTeams字段
const deletedUser = await UserInfo.findById(deletedUserId, "associatedTeams.teamId");
if (!deletedUser) return;
// 提取所有关联团队ID
const teamIds = deletedUser.associatedTeams.map(item => item.teamId);
// 批量更新移除用户
await Team.updateMany(
  { _id: { $in: teamIds } },
  { $pull: { players: deletedUserId } }
);

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