每次查看页面时尝试增加 1

Question

我试图弄清楚如何通过每次访问页面时递增 +1 来更新字段，如果从未访问过，则将其添加到数据库中。

目前，这就是我所拥有的，但似乎并没有多大作用。我一定是在某个地方出错了，我还没有实现如果页面从未被查看过的部分，那么在存储在数据库中的数组中创建一个新对象。

小提示：如果我查看与存储在数据库中的 ID 相同但没有发生增量的页面，它们确实匹配相同 ID 的地图。

exports.pageVisitCount = (req, res, next) => {
  User.findById({
    _id: req.userData.userId
  }, 'visits', function (err, pageVists) {
    if (err) {
      res.status(401).json({
        message: "Error Occured!"
      })
    } else {
      const pageCounts = pageVists.visits;
      pageCounts.map(page => {
        const postViewed = req.body.postId;
        if (page.postId.toString() === postViewed) {
          User.findByIdAndUpdate({
              _id: req.userData.userId
            }, {
              $set: {
                visits: [{
                  "postId": postViewed,
                  $inc: { visitCount: 1 }
                }]
              }
            }, {
              upsert: false
            },
            (err) => {
              if (err) {
                res.status(401).json({
                  message: "Error Occured!"
                })
              } else {
                res.status(200).json({
                  message: "Update successful!"
                })
              }
            });
        }
      });
    }
  });
}

这是我正在使用的架构：

const visitsSchema = new Schema ({
  postId: {
    type: String
  },
  visitCount: {
    type: Number
  }
})

const userSchema = mongoose.Schema({
  email: {
    type: String,
    required: true,
    unique: true
  },
  password: {
    type: String,
    required: true
  },
  role: {
    type: String,
    required: true
  },
  answers: {
    type: String
  },
  visits: [visitsSchema]
});

非常感谢任何反馈，我想提一下我是后端新手，谢谢！

Answer 1

为了避免在查询考虑中用户的visits后使用映射过滤visits，我建议你让mongodb为你做这件事。在这种情况下，您首先根据用户 ID 和 postId 进行查找。如果您获得符合这两个条件的记录，您确信可以通过将特定的 visits visitCount 增加 1 来轻松更新用户访问。

否则，即如果它们不匹配任何记录，那么由于您可能使用了有效的用户 ID，那么此类用户尚未访问此类帖子。因此，您现在使用 postId 创建一个新访问并将其 visitCount 初始化为 1（虽然我们打算创建，但由于它是一个子文档，您需要使用 $push）。说够了，试试下面的代码。

exports.pageVisitCount = (req, res, next) => {
    User.findOne({
      _id: req.userData.userId, "visits.postId": req.body.postId
    }, 'visits.$', function (err, user) {
      if (err) {
        res.status(401).json({
          message: "Error Occured!"
        });
      } else {

        if(user == null){
           User.findByIdAndUpdate({
              _id: req.userData.userId
           }, {
                $push: {
                   visits: {
                      "postId": req.body.postId,
                      visitCount: 1
                   }
                }
           },  function (err) {
             if(err) 
                return res.status(401).json({
                   message: "Error Occured when creating new visit!"
                })
             return res.status(200).json({
                message: "Success"
             })
           })
        }

        User.update({
            _id: req.userData.userId, "visits.postId": req.body.postId
        }, {
              $inc: { "visits.$.visitCount":  1 }
        },(err) => {
           if (err) {
              res.status(401).json({
                 message: "Error Occured!"
              })
           } else {
              res.status(200).json({
                 message: "Update successful!"
              })
           }
        });
      }
    });
};