强制使用快递路线

Question

可以强制路由吗？

示例：

我有这条路线A：

notiSchema = 通知模型

router.get('/set', function(req, res){
    User.findById("userId". function(err, foundUser){
        foundUser.notiSchemaSent.forEach(function(notiSchema, i){
            if(req.user.notifications.length === 0){
                req.user.notifications.unshift(notiSchema);
                req.user.save();
            } else {
                req.user.notifications.forEach(function(userSchema, i){
                    if(req.user.notifications.indexOf(notiSchema) === -1){
                         req.user.notifications.unshift(notiSchema);
                         req.user.save();
                    }
                });
            }
        });
    });

    res.json(req.user.notifications);
});

这里的问题是在 userB 更新之前读取了“res.json”行

所以我创建了这条其他路线B：

router.get('/get', middleware.isLoggedIn, function(req, res){
  res.json(req.user.notifications);
});

我的Ajax：

$.get('/set', function(data){
    // I only add a "fa-spin" class here
}).then(function(){
    $.get('/get', function(data){
        $(data).each(function(i, item){
            $('.notDrop').prepend(item);
        });

        // Remove the "fa-spin" class
    });
}); 

但有时路由“B”在“A”结束之前被调用；

所以我想知道是否只有在“A”完全完成后才可以调用“B”路线。

Answer 1

我重写了您的路线以将所有更改累积到 req.user.notifications 中，然后在最后保存一次（如果修改了数组）。这样您就可以只进行一次.save() 操作，并通过向其传递回调来知道它何时完成。

变更摘要：

1. 在数组中累加结果，只在最后保存。
2. 仅在数组被修改时保存。
3. 去掉 .length === 0 的特殊情况，因为这不是必需的。
4. 使用req.user.save() 上的回调来知道它什么时候完成，这样我们就可以了。保存完成后发送响应。
5. 为.save() 添加错误处理。
6. 为.findById() 添加错误处理

代码如下：

router.get('/set', function(req, res){
    User.findById("userId", function(err, foundUser){
        if (err) {
           console.log(err);
           res.status(500).send("Error finding user.")
           return;
        }
        let origLength = req.user.notifications.length;
        foundUser.notiSchemaSent.forEach(function(notiSchema, i){
            req.user.notifications.forEach(function(userSchema, i){
                if(req.user.notifications.indexOf(notiSchema) === -1){
                    req.user.notifications.unshift(notiSchema);
                }
            });
        });
        if (req.user.notifications.length !== origLength) {
            req.user.save(function(err) {
                if (err) {
                    console.log(err);
                    res.status(500).send("Error saving user notifications.")
                } else {
                    res.json(req.user.notifications);
                }
            });
        } else {
            res.json(req.user.notifications);
        }
    });
});

如果您更改数据库代码以便从查找操作中获取一组用户，那么您可以像这样处理这些：

router.get('/set', function(req, res){
    User.find({_id: {$in: arrayOfIds}}, function(err, foundUsers){
        if (err) {
           console.log(err);
           res.status(500).send("Error finding user.")
           return;
        }
        let origLength = req.user.notifications.length;
        foundUsers.forEach(function(foundUser) {
            foundUser.notiSchemaSent.forEach(function(notiSchema, i){
                req.user.notifications.forEach(function(userSchema, i){
                    if(req.user.notifications.indexOf(notiSchema) === -1){
                        req.user.notifications.unshift(notiSchema);
                    }
                });
            });
        });
        if (req.user.notifications.length !== origLength) {
            req.user.save(function(err) {
                if (err) {
                    console.log(err);
                    res.status(500).send("Error saving user notifications.")
                } else {
                    res.json(req.user.notifications);
                }
            });
        } else {
            res.json(req.user.notifications);
        }
    });
});