当 forEach 循环全部完成时遍历数组

Iterate over array when forEach loop is all done

我正在尝试遍历我从 angular.forEach()

中的多个 http 调用构造的数组

函数

$scope.ticket_stats = function(){
    //cleaning variables
    $scope.data_set = [];
    $scope.closed_tickets = [];

    //fetching time stamps (epoch)
    $scope.time_frame = time_period.days(7);

              //calling data using time stamps
              angular.forEach($scope.time_frame, function(item) {
                  //debug
                  console.log(item);

                  var promise = tickets.status("closed", item);

                  promise.success(function(data){
                      console.log(data);
                      $scope.closed_tickets.push(data[0].datapoints[0][0]); // returns a numerical value
                  });

              });
              //SEE MESSAGE BELOW
              $scope.data_set.push($scope.closed_tickets);

}

最后一行 $scope.data_set.push() 有效,但一旦调用 return 数据,它会随着时间的推移而增加。我希望在 for Each 循环中的所有内容都完成后执行这一行。之后我需要遍历 $scope.closed_tickets 数组以在其中播放(添加)数据并构建第二个数组。

以下是此功能中使用的服务:

// CALL TICKETS STATS
app.service('tickets', function($http){

    this.status = function(status, date){
        var one_snap = date - 100;
        var url = "/url/render?format=json&target=sum(stats.tickets."+status+")&from="+one_snap+"&until="+date+"";
        return $http.get(url);
    };            
});

// TIME STAMPS MATHS
app.service('time_period', function(){
    var currentDate = parseInt((new Date).getTime()/1000);

    this.days = function(number){
        var pending = [];
        for (var i = number; i > 0; i--) {
            pending.push(currentDate - (87677*i));
        }
        return pending;
    }; 
});

我搜索了信息并找到了 $q.all() 服务,但未能按照我想要的方式进行这项工作。

欢迎任何建议! 谢谢!

您可以使用 $q.all 来等待多个异步事件(承诺)完成。

$scope.ticket_stats = function() {
    // list of all promises
    var promises = [];

    //cleaning variables
    $scope.data_set = [];
    $scope.closed_tickets = [];

    //fetching time stamps (epoch)
    $scope.time_frame = time_period.days(7);

    //calling data using time stamps
    angular.forEach($scope.time_frame, function(item) {
        // create a $q deferred promise
        var deferred = $q.defer();
        //debug
        console.log(item);

        tickets.status("closed", item).success(function(data) {
            console.log(data);
            $scope.closed_tickets.push(data[0].datapoints[0][0]);

            // promise successfully resolved
            deferred.resolve(data);
        });

        // add to the list of promises
        promises.push(deferred.promise);
    });

    // execute all the promises and do something with the results
    $q.all(promises).then(
        // success
        // results: an array of data objects from each deferred.resolve(data) call
        function(results) {
            $scope.data_set.push($scope.closed_tickets);
        },
        // error
        function(response) {
        }
    );
}

首先,deferred 表示一段代码,执行时间未知(异步)。 deferred.resolve(data) 只是声明代码已完成。数据可以是任何东西,对象、字符串等等,但它通常是异步代码的结果。同样,您可以使用 deferred.reject(data) 拒绝承诺(服务器可能抛出错误)。同样,数据可以是任何东西,但在这里它可能应该是错误响应。

deferred.promise 只是 returns 一个承诺对象。 promise 对象允许你设置像 .then(successFunction, errorFunction) 这样的回调,这样你就知道一段代码在继续 successFunction(或 errorFunction 在失败的情况下)之前已经完成执行。在我们的例子中,$q.all 方法,该方法等待一组承诺完成,然后将所有承诺的结果作为一个数组提供给您。

不要忘记注入 $q 服务。

尝试只做出一系列承诺,而不是解决它们。然后用 $q.all() 聚合它们。在聚合 promise resolve 之后,再次遍历这些 promise 的数组。现在您确定它们都已解决。

var promises = [];
angular.forEach($scope.time_frame, function(item) {
    promises.push(tickets.status("closed", item));
});

var aggregatedPromise = $q.all(promises);

aggregatedPromise.success(function(){
    angular.forEach(promises, function(promise) {
        promise.success(function(data){
            $scope.closed_tickets.push(data[0].datapoints[0][0]); // returns a numerical value
        });
    });
});

也许这不是最有效的方法,但我认为这应该可以解决您的问题。

尽管您提到 $q.all 对您不起作用,但我不明白为什么它不应该,下面是我将如何做到这一点。

基本上你想将一组事物(时间戳)映射到其他一些事物(在这种情况下是承诺,因为我们有异步调用)并对结果数组执行一些操作。

var promises = $scope.time_frame.map(function (item) {
    return tickets.status("closed", item);
});

现在我们使用$q.all等待所有的promise解决:

$q.all(promises).then(function (tickets) {
    $scope.data_set.push(tickets);
});