未处理的承诺拒绝猫鼬聚合

Question

我知道有多个帖子处理类似类型的问题，但似乎没有一个适合我。

在我的应用程序中，我需要从我的数据库中获取垂直条形图的图形数据。过滤基于两种状态类型和 updatedAt 字段。将为一年中的每个月绘制数据。

我尝试了两种相同的方法：

第一：

exports.leads_based_on_status = async (req, res) => {
  const { userId } = req.user;
  const fetchMonths = getMonths();

  try {
    const fetch_leads_new = await fetchMonths.map(async (month) => {
      return Lead.aggregate([
        {
          $match: {
            userId: mongoose.Types.ObjectId(userId),
          },
        },
        {
          $unwind: "$leads",
        },
        {
          $match: {
            $and: [
              { updatedAt: { $gt: month._start, $lt: month._end } },
              { "leads.status": "New" },
            ],
          },
        },
      ]);
    });

    const fetch_leads_pending = await fetchMonths.map(async (month) => {
      return Lead.aggregate([
        {
          $match: {
            userId: mongoose.Types.ObjectId(userId),
          },
        },
        {
          $unwind: "$leads",
        },
        {
          $match: {
            $and: [
              { updatedAt: { $gt: month._start, $lt: month._end } },
              { "leads.status": "Pending" },
            ],
          },
        },
      ]);
    });

    Promise.all([fetch_leads_new, fetch_leads_pending]).then(
      (resultnew, resultpending) => {
        console.log("show result new", resultnew);

        console.log("show result pending", resultpending);

        //both these results in Promise <pending>
      }
    );

    const leads_status_statics = [
      {
        New: fetch_leads_new,
      },
      {
        Pending: fetch_leads_pending,
      },
    ];
    res.status(200).json({ message: "Graphical Data", leads_status_statics });
  } catch (error) {
    console.log(error) || res.status(500).json({ error });
  }
};

第二：

exports.leads_based_on_status = async (req, res) => {
  const { userId } = req.user;
  const fetchMonths = getMonths();

  try {
    fetchMonths.map(async (month) => {
      const fetch_leads_new = await Lead.aggregate([
        {
          $match: {
            userId: mongoose.Types.ObjectId(userId),
          },
        },
        {
          $unwind: "$leads",
        },
        {
          $match: {
            $and: [
              { updatedAt: { $gt: month._start, $lt: month._end } },
              { "leads.status": "New" },
            ],
          },
        },
      ]);

      const fetch_leads_pending = await Lead.aggregate([
        {
          $match: {
            userId: mongoose.Types.ObjectId(userId),
          },
        },
        {
          $unwind: "$leads",
        },
        {
          $match: {
            $and: [
              { updatedAt: { $gt: month._start, $lt: month._end } },
              { "leads.status": "New" },
            ],
          },
        },
      ]);

      const leads_status_statics = [
        {
          New: fetch_leads_new,
        },
        {
          Pending: fetch_leads_pending,
        },
      ];
      res.status(200).json({ message: "Graphical Data", leads_status_statics });

      //de:16484) UnhandledPromiseRejectionWarning: Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
    });
  } catch (error) {
    console.log(error) || res.status(500).json({ error });
  }
};

但是他们都不能帮助我解决我的问题。第一种方法不断返回Promise <Pending>，而第二种方法返回Cannot set headers after they are sent to the client at ServerResponse.setHeader (_http_outgoing.js:467:11)

感谢您帮助解决问题:)

Answer 1

关于您的第一种方法，Promise.all(iterable) 方法将可迭代对象作为输入。在您的情况下，fetch_leads_new 和 fetch_leads_pending 已经返回一个待处理的 Promise 数组，例如 ：[ Promise { <pending> }, Promise { <pending> } ].

因此，目前您正在将带有数组或待处理 promise(Promise.all([fetch_leads_new, fetch_leads_pending])) 的数组传递给 Promise.all 函数，类似于

Promise.all([[ Promise { <pending> }, Promise { <pending> } ], [ Promise { <pending> }, Promise { <pending> } ]])

所以我认为您可以考虑使用两种Promise.all 方法，其中一种用于fetch_leads_new，另一种用于fetch_leads_pending

const newRecords = await Promise.all(fetch_leads_new);
const pendingRecords = await Promise.all(fetch_leads_pending);

const leads_status_statics = [
  {
    New: newRecords,
  },
  {
    Pending: pendingRecords,
  },
];

关于第二种方法

当fetchMonths 有多个条目时，这意味着res.status(200).json(... 也被多次调用（在map 函数的每次迭代中），这就是为什么您会收到Cannot set headers after they are sent to the client 错误