2016-08-18 58 views
0

我无法使用简单的for循环,因为request.save是一个函数。所以我尝试了每个。它完美的工作!在我添加request.save部分之前,我收到以下错误消息,它会中断我的应用程序。跨阵列在Node.JS中迭代保存

错误:发送后无法设置标题。

exports.submit = function (req, res) { 


    Person.find({ 
     cellPhone: req.body.phone 
    }).exec(function (err, people) { 
     people.forEach(saveRequest); 
    } 

    function saveRequest(item, index) { 

     var request = new Requests(); 
     request.start = req.body.start.value; 
     request.finish = req.body.finish.value; 
     request.phone = req.body.phone; 
     request.offDay = req.body.date; 

     request.user = people[index]._id; 
     request.name = people[index].name; 
     request.group = people[index].group; 

     request.save(function (err) { 
      if (err) { 
      console.log('request.save'); 
      return res.status(400); 
      } else { 
      // Remove sensitive data before login 
      //user.password = undefined; 
      //user.salt = undefined; 
      console.log(request); 
      res.json(request); 
      } 
     }); 
    } 
}); 
+0

你不能多次调用'res.json',你应该使用res.write。由于保存是异步的,我认为最好是使用Promise –

+0

谢谢!代码应该是什么样子?我试过res.writeHead(200,{'Content-Type':'text/plain'});我尝试了res.write(200,{'Content-Type':'text/plain'});多次,他们都打破了应用程序。 –

回答

1

问题是,当你执行.save()传递一个匿名函数完成错误的情况下的响应。

因此,您完成第一个保存事件错误。

您应完成保存回调以外的响应。

也许使用事件来同步你的代码,或更好的发电机。

您forEach循环之前:

let savedResponses = []; 
let savedErrors = []; 
... 

那么你savedRequest:

function saveRequest(item, index) { 

    var request = new Requests(); 
    request.start = req.body.start.value; 
    request.finish = req.body.finish.value; 
    request.phone = req.body.phone; 
    request.offDay = req.body.date; 

    request.user = people[index]._id; 
    request.name = people[index].name; 
    request.group = people[index].group; 

    request.save(function (err) { 
     if (err) { 
      console.log('request.save error'); 
      savedErrors.push(err); 
      // return res.status(400); 
     } else { 
      // Remove sensitive data before login 
      //user.password = undefined; 
      //user.salt = undefined; 
      console.log(request); 
      savedResponses.push(request); 

     } 
    }); 

} 

然后foreach循环后,应等待在.save异步工作人员结束()回调。

您可以使用事件包或生成器或承诺模式。

它取决于您节点的版本。

当你的代码同步的,你可以只完成你的第一反应检查错误:

if (savedErrors.length > 0) { 
    res.status = 400; 
    // ... report errors 
} 

或者只是完成与savedResponses的响应。

+0

我将删除保存函数中的响应,并在foreach后面直接添加它 –

+0

如果这样做,则无法保证所有保存都是**异步**。正如我在评论中所说的,你绝对应该在Promise.all中使用Promises –

+0

@ oliv37我在答复中写道,应该以某种方式处理ascynchronous部分。 –