Mongoose:特定用户查询的所有点的总和

const mongoose = require('mongoose');

const pointSchema = new mongoose.Schema({
  userId: { type: mongoose.Schema.Types.ObjectId, ref: 'User', required: true },
  points: { type: Number, required: true }
});

const Point = mongoose.model('Point', pointSchema);

const userSchema = new mongoose.Schema({
  name: String,
  email: String
});

const User = mongoose.model('User', userSchema);

async function getTotalPointsForUser(userId) {
  try {
    const totalPoints = await Point.aggregate([
      { $match: { userId: mongoose.Types.ObjectId(userId) } },
      { $group: { _id: null, total: { $sum: '$points' } } }
    ]).exec();

    return totalPoints.length > 0 ? totalPoints[0].total : 0;
  } catch (error) {
    console.error('Error fetching total points:', error);
    throw error;
  }
}

Point.collection.createIndex({ userId: 1 });