节点 JS 嵌套 Promise.all 和映射逻辑不起作用

Question

我正在尝试让嵌套的 Promise.all * 映射逻辑工作。当我到达 getData2 时，我不断收到未定义的值。

exports.getData = (param1, param2) => {
  return getData0(param1, param2)
    .then(data0 => Promise.all(data0.map(e => getData1(e.id))))
    .then(data1 => Promise.all(data1.map(i => getData2(i.id))))
    .then(data2 => data2.map(a => getData3(a.id)))
    .catch(err => console.error(err.message));
};

附注： 1. getData0 到 getData1 返回结构（例如 { a: val1, b: val2 }） 2. 我认为问题出在 getData 的编写方式上。我怀疑他们应该回报承诺。谁能给我一个关于返回结构的函数的虚拟示例，其中（参见上面的 a 和 b）的两个元素都是以异步方式获得的？

谢谢！

Answer 1

首先，如果您的所有getData* 方法正在执行任何异步操作，它们都应该返回Promise 对象。 （例如获取数据）。

getData3 可能是一个例外，因为在所有 getData3 调用完成后，它看起来不需要做任何事情。 如果不是这种情况，您可以对getData3 使用与上述类似的方法。 例如data2 => Promise.all(data2.map(a => getData3(a.id)))

现在让我们逐行查看代码

exports.getData = (param1, param2) => {
  return getData0(param1, param2)
    .then(data0 => Promise.all(data0.map(e => getData1(e.id))))
    // data0 here should be an Array

    .then(data1 => Promise.all(data1.map(i => getData2(i.id))))

    // 1. data1 will be an Array with results from each getData1 call
    //    mapped by index. for e.g [result1, result2, ...]
    // 2. depending on the type of result (Object/Array) from getData1
    //    you should extract `id` from `i`(result item) and then 
    //    trigger `getData2`using that `id`. I'm assuming the issue is 
    //    here. 

    .then(data2 => data2.map(a => getData3(a.id)))
    .catch(err => console.error(err.message));
};

至于Can anyone give me a dummy example about a function that returns a structure wherein both elements of the (see a and b above) are obtained in an async way? 我相信这应该回答How to use Promise.all with an object as input

Answer 2

我已将 Dhruv 的答案标记为有效答案，因为它解释了我所描述的逻辑中涉及的不同概念。

getData1 和 getData2 确实在 getData3 同步时调用异步函数（在我的例子中：doSomeEWSwork 下面）。

function doSomeEWSwork(param) {

  var ewsFunction = '.....';
  var ewsArgs = ....;

  return ews.run(ewsFunction, ewsArgs)
    .then(result => result.something)
    .catch(err => console.log(err.message));
}

我的旧 getData1 和 getData2 用于返回结构对象（例如 {a: val1, b: val2} 而不是 Promise（Promise.all 需要）。这导致异步块永远不会执行/评估。

我的新 getData1 和 getData2 具有以下骨架：

function getData1_or_2(param) {

  var promise = new Promise(function(resolve, reject) {
    doSomeEWSwork(param) // <- important: settle this using 'then'
    .then(res => {
      var ret = { a: res.val1, b: res.val2 };
      resolve(ret);
    }).catch(err => {
      console.log(err.message);
      reject(Error(err.message));
    });
  });
  return promise;
}

所以 main 方法（已经包含在我的原始问题中）现在可以正常工作，因为我返回了异步的承诺和同步的对象。

exports.getData = (param1, param2) => {
  return getData0(param1, param2)
    .then(data0 => Promise.all(data0.map(e => getData1(e.id))))
    .then(data1 => Promise.all(data1.map(i => getData2(i.id))))
    .then(data2 => data2.map(a => getData3(a.id)))
    .catch(err => console.error(err.message));
};

只是嵌套 promise、map 和结构对象的组合让我感到困惑。 谢谢！