如何在Node.JS中使用MongoDB进行更新操作

Question

如何在Node.JS中使用MongoDB进行更新操作

3

我有这段代码想要编写，它的作用是在正确计算余额后更新MongoDB中的余额。问题在于，虽然它可以正确计算余额，但无法更新用户列的内容。我一直在寻找如何更新余额，但没有找到任何有帮助的信息。

我的代码如下：

const router = require("express").Router();
const User = require("../models/User");
const bcrypt = require("bcrypt");
const jwt = require("jsonwebtoken");


router.post("/update-balance/:email", async (req, res) => {

    try {
        if (
          !req.headers.authorization ||
          !req.headers.authorization.startsWith("Bearer ") ||
          !req.headers.authorization.split(" ")[1]
        ) {
          return res.status(422).json({ message: "Please Provide Token!" });
        }

        const amount = parseInt(req.body.amount);

        const user = await User.find({ email: req.params.email });
        const balance = parseInt(user[0].balance);

        //return balance;
        //console.log(balance);

        const total_amt = amount + balance;
        //console.log(total_amt);

        // update Balance
        const wallet_user = new User();
        try{
          await wallet_user.updateOne({email : req.params.email}, {$set: {balance: total_amt}});
        }catch(err){
          console.log(err);
        }

        return res.send({ error: false, message: "OK" });

      } catch (error) {
        res.status(404).json({ message: error.message });
      }

});



module.exports = router;

我应该做什么，我做得不对，请帮帮我。

上面的代码显示了我尝试过的内容。

- Diddy

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- lpizzinidev · Accepted Answer

您可以使用 $inc ：

router.post('/update-balance/:email', async (req, res) => {
  try {
    if (
      !req.headers.authorization ||
      !req.headers.authorization.startsWith('Bearer ') ||
      !req.headers.authorization.split(' ')[1]
    ) {
      return res.status(422).json({ message: 'Please Provide Token!' });
    }

    const amount = parseInt(req.body.amount);

    try {
      await User.findOneAndUpdate(
        { email: req.params.email },
        { $inc: { balance: amount } }
      );
    } catch (err) {
      console.log(err);
    }

    return res.send({ error: false, message: 'OK' });
  } catch (error) {
    res.status(404).json({ message: error.message });
  }
});