对我的变量的成员函数groupBy（）的Laravel块调用

Question

在我的Laravel8项目中，我调度了一个作业，该作业运行并从数据库中收集一堆数据，这些数据可以是从几百行数据到数千行数据的任意数量，因此可能会占用相当大的内存。

返回结果后，将对其进行处理并添加到数据库表中，我希望有某种进度指示（百分比），可以在分块进行时报告给用户，我有两个表，一个reports和一个reports_data表。

我已将by query切换到Laravel的chunk方法，并将数据集合拆分为更小的位，因为这样可以提高性能，但出于某种原因，为了将数据作为一个整体使用，就好像它是一个集合一样，我将其推入一个名为$res的空数组中，但我得到一个错误，因此我的作业FailsError：调用array上的成员函数groupBy（）：

错误：调用数组上的成员函数groupBy（）

我在想我错过了什么...

/**
 * Execute the job.
 *
 * @return void
 */
public function handle()
{

  $filters = json_decode($this->report->discovery_filters);
  $data = [];

  // create
  foreach ($filters as $findable) {
    $resultData = [];

    // query data
    if (isset($findable->query)) {
      $this->setDynamicChartOptions();

      $res = [];
      $chunkData = DB::table($findable->query->table)
                     ->select($findable->query->columns)
                     ->where($findable->query->filterBy)
                     ->orderBy($findable->query->orderBy->field, $findable->query->orderBy->direction)
                     ->chunk(100, function ($chunkedResults) use ($res) {
                        foreach ($chunkedResults as $chunk) {

                          // how to update some kind of progress?
                          array_push($res, $chunk);
                          var_dump(count($res));
                        }
                      });

      // $res expected as a collection? Maybe I can use the `collect` method?
      if (isset($findable->query->useGrouping) && $findable->query->useGrouping) {
        $results = $res->groupBy(function ($item, $key) use ($findable) {
          $date = Carbon::parse($item->{$findable->query->groupBy});
          return $date->format($findable->query->groupByFormat);
        });

        $results = $results->map(function ($item, $key) {
          return $item[0];
        });

        $resultData = $results->flatten();
      }
    }

    $res = [
      'componentID' => $findable->componentID ?? 0,
      'type' => $findable->type ?? '',
      'name' => $findable->name ?? '',
      'labelsKey' => $findable->query->labelsKey ?? '',
      'dataKey' => $findable->query->dataKey ?? '',
      'data' => $resultData ?? [],
      'structure' => $this->getStructure($findable, $resultData)
    ];

    array_push($data, $res);
  }

  // create our report data entry
  $this->createReportData($data);
}

我已尝试分块和分组,但作业失败：

$res = [];
$chunkData = DB::table($findable->query->table)
               ->select($findable->query->columns)
               ->where($findable->query->filterBy)
               ->orderBy($findable->query->orderBy->field, $findable->query->orderBy->direction)
               ->chunk(100, function ($chunkedResults) use ($res) {
                  $res[] = $chunkedResults;
                  foreach($res as $chunk) {
                    $chunk->groupBy();
                  }
                });

这也失败了...

res = [];
          $chunkData = DB::table($findable->query->table)
                         ->select($findable->query->columns)
                         ->where($findable->query->filterBy)
                         ->orderBy($findable->query->orderBy->field, $findable->query->orderBy->direction)
                         ->chunk(100, function ($chunkedResults) use ($res) {
                            $res[] = $chunkedResults;
                          });

          foreach($res as $chunk) {
            $chunk->groupBy();
          }

这一点似乎也不起作用，因为它没有返回任何集合，而这正是我的其余代码工作所需要的：

$res = [];
$chunkData = DB::table($findable->query->table)
               ->select($findable->query->columns)
               ->where($findable->query->filterBy)
               ->orderBy($findable->query->orderBy->field, $findable->query->orderBy->direction)
               ->chunk(100, function ($chunkedResults) use ($res) {
                  foreach ($chunkedResults as $key => $chunk) {
                    array_push($res, $chunk);
                  }
                });

$res = collect($res);

Answer 1

因为$res=[]；是一个数组，而不是Elecoquent的Illumate\support\collection的实例。因此，您不能调用$res->groupby()，因为您正在第一条if语句中尝试。

删除->chunk()方法，并通过使用slice来获取数据块，例如，在总是获取数据片的循环中。

也可以调用collection($res)将数组转换回集合。但是，如果已经有一个集合，那么在后面直接将它转换回数组是没有意义的。所以我会用切片的方法。

您还可以（通过块回调）执行以下操作：

->chunk(100, function ($chunkedResults) use ($res) {
  $res[] = $chunkedResults;
});

后来呢：

foreach($res as $chunk) {
  $chunk->groupBy();
}