Koa 不等待 MongoDB 响应并返回 null 响应

Question

我正在为客户创建一个应用程序。我在应用程序中使用 koa.js mongodb（用于数据库）。我试图获取客户详细信息以及特定客户的总提醒，但 koa 不会等待承诺并在我尝试致电时返回“[]”作为响应该路线

是我的代码

    router.get("/getcustomers",async (ctx)=>{
      ctx.customers = [await remind_col.find({}).toArray()][0];
      ctx.customeralgo = [];
      new Promise((reso,reje)=>{ 
        ctx.customers.map(async cust=>{
          return {
            email:cust.email,
            first_name:cust.first_name,
            last_name:cust.last_name,

             //------------- This is the when I'm trying to get count for customer
            total_reminders:[await remind_col.count({"email":cust.email})][0],
            //----------------
          }
        })
      }).then(rlt=>{
        ctx.customeralgo = rlt;
        console.log(rlt);
        ctx.body = ctx.customeralgo;
      })

    })

，这是我调用此路线时的响应图像：

Answer 1

尝试 Promise.all 而不是 new Promise

router.get("/getcustomers", async (ctx) => {
  ctx.customers = [await remind_col.find({}).toArray()][0]
  ctx.customeralgo = []
  const promises = ctx.customers.map(async cust => ({
    email: cust.email,
    first_name: cust.first_name,
    last_name: cust.last_name,
    // ------------- This is the when I'm trying to get count for customer
    total_reminders: [await remind_col.count({ "email": cust.email })][0],
    //----------------
  }))
  Promise.all(promises).then(rlt => {
    ctx.customeralgo = rlt
    console.log(rlt)
    ctx.body = ctx.customeralgo
  })
})

Answer 2

你那里有很多额外的东西。

这背后的想法是什么？

ctx.customers = [await remind_col.find({}).toArray()][0];

如果这部分 remind_col.find({}).toArray() 返回一个数组，为什么要放入数组中然后获取第一个元素？

我坚信，您可以简单地在下面使用它，

const customers = await remind_col.find({}).toArray();

因为它不是中间件，您不需要向上下文对象分配任何内容。

您定义了承诺，但从未解决价值。

我清理了一下你的代码，我认为这对你有用

router.get('/getcustomers', async (ctx) => {
  const customers = await remind_col.find({}).toArray();
  const transformedCustomers = customers.map(async (customer) => ({
    email: customer.email,
    first_name: customer.first_name,
    last_name: customer.last_name,
    total_reminders: await remind_col.count({ email: customer.email }),
  }));

  ctx.body = await Promise.all(transformedCustomers);
});