在 await model.save in nodejs/express

Question

我有2个模型员工和任务列表。var mongoose=require("mongoose");var findOrCreate = require('mongoose-findorcreate');var uniqueValidator = require('mongoose-unique-validator');var employeeSchema = new mongoose.Schema({    empId : { type : Number , unique : true, required : true },    empName : { type : String , unique : true, required : true },    empTeam : { type : String , required : true },    created : {type : Date, default : Date.now}  });  employeeSchema.plugin(findOrCreate,uniqueValidator);  module.exports = mongoose.model("Employee", employeeSchema);// Mongoose Tasklist Model configvar mongoose=require("mongoose");var findOrCreate = require('mongoose-findorcreate');var uniqueValidator = require('mongoose-unique-validator');var tasklistSchema = new mongoose.Schema({    taskId : { type : Number , unique : true, required : true },    taskDesc : { type : String , unique : true, required : true },    taskDetails : {type : String},    taskAssignee : [{        type:mongoose.Schema.Types.ObjectId,        ref:"Employee"    }],    startDate: Date,    dueDate: Date,    taskStatus: String,    created : {type : Date, default : Date.now},  });  tasklistSchema.plugin(findOrCreate, uniqueValidator);    module.exports = mongoose.model("Tasklist", tasklistSchema);我有一个编辑路由，其中我为任务分配了多个受托人。  router.post("/tasklist/:id/edit", function(req,res){    Tasklist.findOneAndUpdate({_id:req.params.id},req.body.tasklist, async function(err, tasklist){        if(err){            req.flash("error", "Unable to update the tasklist record : "+err.message);            res.redirect("/employee");        } else {            var emp_id=req.body.taskAssignee.split(',');我能够将员工推送到 tasklist.taskAssignee，还可以执行 tasklist.save（）。没有错误。但是，更新不会保留在 mongoDB 中。

Answer 1

我看urcode，似乎你没有等待承诺来解决

const promises = emp_id.map((assignee) => {

  return new Promise(function (resolve, reject) {

    Employee.findById(assignee, function (err, employee) {

      if (err) {

        console.log("error in finding employee :" + assignee);

        reject(

          "There was an error loading the employee data in to the database : " +

            err.message

        );

      } else {

        tasklist.taskAssignee.push(employee);

        console.log("employee saved");

        resolve("Employee records uploaded successfully");

      }

    });

  });

});

await Promise.all(promises) // here wait..

整个示例。

router.post("/tasklist/:id/edit", function (req, res) {

  Tasklist.findOneAndUpdate(

    { _id: req.params.id },

    req.body.tasklist,

    async function (err, tasklist) {

      if (err) {

        req.flash(

          "error",

          "Unable to update the tasklist record : " + err.message

        );

        res.redirect("/employee");

      } else {

        var emp_id = req.body.taskAssignee.split(",");

        try {

          const promises = emp_id.map((assignee) => {

            return new Promise(function (resolve, reject) {

              Employee.findById(assignee, function (err, employee) {

                if (err) {

                  console.log("error in finding employee :" + assignee);

                  reject(

                    "There was an error loading the employee data in to the database : " +

                      err.message

                  );

                } else {

                  tasklist.taskAssignee.push(employee);

                  console.log("employee saved");

                  resolve("Employee records uploaded successfully");

                }

              });

            });

          });

          await Promise.all(promises)

          console.log("Tasklist Saving....");

          let savetasklist = await tasklist.save();

          console.log("Tasklist Saved : ");

          req.flash("success", "Updated Tasklist" + req.body.tasklist);

          res.redirect("/tasklist");

        } catch (err) {

          req.flash("error", "Updating Tasklist" + err);

          res.redirect("/tasklist");

        }

      }

    }

  );

});