如何通过Shopware 6命令对大容量导出CSV文件进行多维度排序？

方案一：从SQL数据源层面实现排序（最优解） #

现有代码通过收集商品编号分批调用processChunk查询数据，直接在查询阶段指定多维度排序规则是最省资源、效率最高的方式：

1. 修改processChunk内的SQL查询逻辑，用ORDER BY串联多个排序维度，比如先按分类ID升序、再按价格降序、最后按商品编号升序：

   // 在processChunk的查询代码中添加排序规则
   $query = $this->productRepository->createQueryBuilder('p')
       ->where('p.productNumber IN (:productNumbers)')
       ->setParameter('productNumbers', $productNumbers)
       ->orderBy('p.categoryId', 'ASC')
       ->addOrderBy('p.price', 'DESC')
       ->addOrderBy('p.productNumber', 'ASC');
   

2. 每一批查询出的数据会自动按规则排序，写入CSV后整体结果就是有序的（无需额外处理原始输入文件的顺序）。
3. 优势：利用数据库的排序优化能力，无需占用额外内存处理大文件，适合超大规模数据场景。

方案二：CSV分块排序+多路归并（适合无法修改SQL的场景） #

如果必须基于现有CSV输入文件处理，且文件过大无法一次性加载到内存，采用外部排序思路：

1. 分块读取并排序：
   • 每次读取固定行数（比如1000行，根据服务器内存调整）的CSV数据，保留所有需要参与排序的字段
   • 用usort()自定义多维度排序逻辑，示例：

     usort($chunkData, function($a, $b) {
         // 第一维度：分类ID（CSV第2列，索引1）升序
         $catCompare = strcmp($a[1], $b[1]);
         if ($catCompare !== 0) {
             return $catCompare;
         }
         // 第二维度：价格（CSV第5列，索引4）降序
         $priceA = (float)$a[4];
         $priceB = (float)$b[4];
         if ($priceA !== $priceB) {
             return $priceB - $priceA;
         }
         // 第三维度：商品编号（CSV第1列，索引0）升序
         return strcmp($a[0], $b[0]);
     });
     

   • 将排序后的小块数据写入独立临时CSV文件（如temp_sort_001.csv）
2. 合并有序临时文件：
   • 同时打开所有临时文件，用多路归并算法：每次读取每个临时文件的当前行，选出符合排序规则的行写入最终导出文件，再从对应临时文件读取下一行，直到所有临时文件读取完毕。
   • 可以用SplFileObject管理文件指针，方便逐行操作。
3. 注意：临时文件使用后要及时删除，避免占用磁盘空间。

方案三：一次性内存排序（仅小文件适用） #

如果文件大小在服务器内存承受范围内（如几十MB），可以简化处理：

1. 一次性读取所有CSV行到数组（先跳过表头）
2. 用usort()自定义多维度排序规则（同方案二的排序回调）
3. 先写入表头，再循环写入排序后的数组到导出文件
4. 代码示例：

   // 读取所有数据
   $header = fgetcsv($file, null, ';');
   $allRows = [];
   while (($data = fgetcsv($file, null, ';')) !== false) {
       if (count($data) < 1) continue;
       $allRows[] = $data;
   }
   // 多维度排序
   usort($allRows, function($a, $b) {
       $firstCompare = strcmp($a[2], $b[2]);
       if ($firstCompare !== 0) return $firstCompare;
       $secondA = (int)$a[5];
       $secondB = (int)$b[5];
       return $secondB - $secondA;
   });
   // 写入导出文件
   fputcsv($exportFile, $header, ';');
   foreach ($allRows as $row) {
       fputcsv($exportFile, $row, ';');
   }
   

5. 缺点：大文件会导致内存溢出，仅适合小体量数据。

内容的提问来源于stack exchange，提问作者wp_lancer