javascript - Strongloop Loopback - 远程方法中的异步函数处理(每个函数内部)

Question

我正在使用 Loopback 开发一个 api，并开发一些远程方法来从传出模块检索数据并按照我的意愿重新排列数据。这是我的示例代码。

mainModule.viewAll = function(cb) {
    var mainFilter = {fields: ['f_name', 'l_name', 'id'], where: {status: 1}};
    var cEmp = null;
    mainModule.find(mainFilter, function(err, mainModules) {
      var returnArray = [];
      var returnEle;
      var secondModule = app.models.secondModule;

      mainModules.forEach(emp=>{
        returnEle = {};
        returnEle['name'] = emp.name;
          secondModule.count({ where: { type: 1 }}, function (err, count) {
              returnEle['field1'] = count;
              console.log(count);
          });
          secondModule.count({ where: { type: 1 } }, function (err, count) {
              returnEle['field2'] = count;
              console.log(count);
          });
          secondModule.count({ where: { type: 1 } }, function (err, count) {
              returnEle['field3'] = count;
              console.log(count);
          });
        returnArray.push(returnEle);

      });
      cb(null, returnArray);
    });
  };

  mainModule.remoteMethod('viewAll', {
    'http': {'verb': 'get', 'path': '/viewAll'},
    returns: {arg: 'profiles', type: 'Array'},
  });

我的回答是这样的，

{
  "profiles":[
    {
      "name":"Jhone",
      "id":1
    },
    {
      "name":"Shaam",
      "id":2
    },
    {
      "name":"Viki",
      "id":3
    }
    ] 
}

正如您在此处看到的，它仅响应名称和 id 字段，没有有关“filed1”、“field2”、“field3”的详细信息。但在控制台日志中“field1”、“field2”、“field3”显示完美。

我发现原因可能是 JavaScript 的异步行为。我研究了一些解决这个问题的方法，例如使用回调函数，Promise等等，但这些都不适合情况。 ( Promises 接缝效率更高一些，所以我尝试将第二个模块函数与一个 Promise 和整个“foreach”函数包装到另一个 Promise 中，并将 cb(null, returnArray); 设置为then 函数。但它也不起作用)。

我是环回新手，所以如果有人知道答案，请帮助我。

Answer 1

使用 async.eachOf 在每个模块上应用异步操作，然后对于每个模块，使用 async.parallel 并行计算 3 个计数:

var returnArray = [];

async.eachOf(mainModules, function(module, index, acb){

     // for each module do parallel count

    async.parallel({

        field1: function(pcb){
            secondModule.count({ where: { type: 1 }}, pcb);
        },

        field2: function(pcb){
            secondModule.count({ where: { type: 1 } }, pcb);
        },

        field3: function(pcb){
            secondModule.count({ where: { type: 1 } }, pcb);
        }
    }, function(err, result){

        // final parallel callback, when all parallel count are finished
        if(err || !result)
        {
            return acb(err || true);
        }
        else
        {
            result.name = module.name;

            // here result contains the 3 count in result["field1"], result["field2"] and result["field3"]

            returnArray.push(result);

            return acb(null);
        }
    })


    }, function(err){
       // final async.each of callback when all modules are proceed
       if(err)
       {
          // do stg
        }
       else
      {
          return cb(null, returnArray)
      }
  })