mongoose同时查询,如何用promise.all包装

发布于 2022-09-04 05:29:21 字数 1320 浏览 18 评论 0

想实现的是 reply - save后,同时操作 topic表和user表,然后一起返回,不知怎么用promise.all来包装这2个 查询更新 操作,希望大家能帮我解决下= =

更新:下面是修改好的.

/* 回复 话题 */
router.post('/reply', (req, res, next) => {
  let topic_id = req.body.topic_id,
      content  = req.body.content

  let replyEntity = new replyModel({
    author: req._id,
    topic: topic_id,
    content
  })

  replyEntity.save()
             .then((_new_reply) => {
                Promise.all([
                  topicModel.findByIdAndUpdate(topic_id, {
                    $inc: {replyNum: 1},
                    last_reply_author: req._id,
                    last_reply_time: Date.now()
                  }),
                  userModel.findByIdAndUpdate(req._id, {
                    $push: {replies: _new_reply._id}
                  })
                ])
                .then((res_arr) => {
                  return res.json({
                    status: 0
                  })
                })
                .catch((err) => {
                  return res.json({
                    status: -1
                  })
                })
             })
             .catch((err) => {
                return res.json({
                  status: -1
                })
             })
})

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

别再吹冷风 2022-09-11 05:29:21
replyEntity.save()
    .then((_new_reply) => {

        var topic = function (topic_id,authorId) {
            return topicModel.findByIdAndUpdate(topic_id, {
                $inc: {replyNum: 1},
                last_reply_author: authorId,
                last_reply_time: Date.now()
            }).exec();
        }
        var user = function (authorId,replyId) {
            return userModel.findByIdAndUpdate(authorId, {
                $push: {replies: replyId}
            }).exec();
        }
        return Promise.all([topic(topic_id,req._id), user(req._id,_new_reply._id)])
            .then(function (results) {
                console.log('===results===',results);
                return res.json({
                    status: 0
                })
        }).catch((err) => {
                return res.json({
                    status: -1
                });

    }).catch((err) => {
    return res.json({
        status: -1
    })
})

大概写了下,你试试呢

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文