Angular 2中如何在MongoDB存储并更新用户得分？

嘿，看起来你已经搭好了用户注册的基础框架，要搞定分数存储和更新其实没那么复杂，我分几步给你捋清楚：

1. 给MongoDB用户模型添加score字段 #

首先得让你的用户集合能存分数对吧？找到你的用户模型文件（比如user.model.js），在Schema里补上score字段，默认值设为0，新用户注册时直接带初始分：

const userSchema = new mongoose.Schema({
  // 你已有的其他字段，比如username、email、password等
  score: {
    type: Number,
    default: 0 // 新用户默认分数为0
  }
});

module.exports = mongoose.model('User', userSchema);

2. 在后端用户服务里写分数更新方法 #

接下来要在user.service.js里实现一个安全的分数更新函数，用MongoDB的$inc原子操作符来做递增，这样能避免并发场景下的分数计算错误：

// user.service.js
async function updateUserScore(userId) {
  try {
    // 找到对应用户，将score字段原子加1
    const updatedUser = await Users.findByIdAndUpdate(
      userId,
      { $inc: { score: 1 } }, // $inc是MongoDB原生的原子递增操作，安全可靠
      { new: true } // 配置这个选项，返回更新后的用户数据
    );
    return updatedUser;
  } catch (err) {
    throw new Error('更新分数失败：' + err.message);
  }
}

// 记得把这个方法导出，供控制器调用
module.exports = {
  // 你已有的其他方法，比如register、login等
  updateUserScore
};

然后在用户控制器里添加对应的路由处理逻辑：

// user.controller.js
const userService = require('./user.service');

// 更新分数的路由处理函数
async function updateScore(req, res) {
  try {
    // 假设你用了身份验证中间件，能从req.user拿到当前登录用户的ID
    const userId = req.user._id;
    const updatedUser = await userService.updateUserScore(userId);
    res.status(200).json({ score: updatedUser.score });
  } catch (err) {
    res.status(500).json({ message: err.message });
  }
}

// 配置路由，比如PUT请求 /api/users/score
router.put('/score', updateScore);

3. 在Angular组件里调用后端同步分数 #

回到你的dashboard.component.ts，当用户答对题目时，既要更新本地显示的分数，也要调用后端API把分数同步到数据库：

// dashboard.component.ts
import { Component } from '@angular/core';
import { UserService } from '../services/user.service'; // 导入Angular的用户服务
import { AuthService } from '../services/auth.service'; // 假设你有获取当前登录用户的Auth服务

export class DashboardComponent{
  score: number = 0;
  imageMatch: any;
  emotionMatch: any;

  constructor(
    private userService: UserService,
    private authService: AuthService
  ) {
    // 组件初始化时，先从后端拉取用户当前的最新分数
    this.loadUserScore();
  }

  async loadUserScore() {
    const currentUser = this.authService.getCurrentUser();
    if (currentUser) {
      const response = await this.userService.getUserScore(currentUser._id).toPromise();
      this.score = response.score;
    }
  }

  async makeMatch() {
    if (this.imageMatch === this.emotionMatch) {
      // 先更新本地分数
      this.score += 1;
      // 调用后端API同步分数到数据库
      try {
        const currentUser = this.authService.getCurrentUser();
        if (currentUser) {
          await this.userService.updateUserScore(currentUser._id).toPromise();
        }
      } catch (err) {
        console.error('分数更新失败：', err);
        // 如果后端更新失败，把本地分数回滚，避免数据不一致
        this.score -= 1;
        // 这里可以给用户加个错误提示，比如弹出Toast
      }
    }
  }
}

另外，你的Angular UserService里需要添加对应的HTTP请求方法：

// user.service.ts（Angular端的服务）
import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core';

@Injectable({ providedIn: 'root' })
export class UserService {
  private apiUrl = 'http://localhost:3000/api/users'; // 替换成你的后端API地址

  constructor(private http: HttpClient) {}

  // 获取用户当前分数
  getUserScore(userId: string) {
    return this.http.get(`${this.apiUrl}/${userId}/score`);
  }

  // 调用后端更新分数
  updateUserScore(userId: string) {
    return this.http.put(`${this.apiUrl}/score`, { userId });
  }
}

几个关键注意点 #

• 身份验证：一定要确保只有登录用户才能调用分数更新接口，后端要验证请求的用户ID合法性，防止恶意刷分。
• 原子操作：用$inc而不是先查询再手动加1更新，这样能保证多并发场景下分数计算不会出错。
• 错误回滚：前端调用API失败时，记得把本地分数回滚，避免本地显示和数据库数据不一致。

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