Shopware 6商品列表基于聚合的自定义排序实现疑问

核心问题解答 #

你当前的代码无法实现按periodPrice最小值排序：

• 你添加的MinAggregation仅用于统计每个商品对应leasingPlan中periodPrice的最小值，但该聚合结果不会参与到排序逻辑中
• 直接在ProductSortingEntity的fields里使用leasingPlan.periodPrice时，DAL会从关联的leasingPlan记录中取任意一条（而非最小值）用于排序，结果完全不符合预期

可行解决方案 #

结合你提到的DAL不支持子查询的限制，提供两种可行方案：

方案一：预计算自定义字段（推荐，性能更优） #

给Product实体添加一个自定义字段（比如min_leasing_period_price），在数据变更时自动计算并更新该字段的值：

1. 在Shopware后台或通过插件为Product创建数值型自定义字段min_leasing_period_price
2. 编写事件订阅者，监听以下事件以触发值的更新：
   • LeasingPlanEntity的EntityWrittenEvent：当租赁计划新增/修改/删除时，更新关联商品的自定义字段值
   • ProductEntity的EntityWrittenEvent：当商品关联的租赁计划变更时，重新计算值
3. 核心计算逻辑示例：

   public function updateMinLeasingPrice(EntityWrittenEvent $event): void
   {
       $ids = $event->getIds();
       $criteria = new Criteria($ids);
       $criteria->addAssociation('products');
       $leasingPlans = $this->leasingPlanRepository->search($criteria, $event->getContext());
       
       foreach ($leasingPlans as $plan) {
           foreach ($plan->getProducts() as $product) {
               $minPrice = $this->calculateMinLeasingPrice($product->getId(), $event->getContext());
               $this->productRepository->update([
                   [
                       'id' => $product->getId(),
                       'min_leasing_period_price' => $minPrice
                   ]
               ], $event->getContext());
           }
       }
   }
   
   private function calculateMinLeasingPrice(string $productId, Context $context): float
   {
       $criteria = new Criteria();
       $criteria->addFilter(new EqualsFilter('productId', $productId));
       $criteria->addAggregation(new MinAggregation('min_price', 'periodPrice'));
       $result = $this->leasingPlanRepository->aggregate($criteria, $context);
       return $result->get('min_price')->getValue() ?? PHP_INT_MAX;
   }
   

4. 排序时直接使用该自定义字段：

   $myCustomSorting->setFields([
       [
           'field' => 'min_leasing_period_price',
           'order' => 'asc',
           'priority' => 1,
           'naturalSorting' => 0,
       ],
   ]);
   

方案二：查询后手动排序（适合小数据量场景） #

如果不想预计算字段，可以在查询执行后，利用聚合结果手动对当前页的商品排序：

1. 保留你当前的ProductListingCriteriaEvent订阅逻辑，同时添加分组字段：

   public function addCriteria(ProductListingCriteriaEvent $event): void
   {
       $criteria = $event->getCriteria();
       $criteria->addAssociation('leasingPlan');
       // 添加分组，确保聚合按商品维度统计
       $criteria->addGroupField('product.id');
       $criteria->addAggregation(new MinAggregation('min_period_price', 'leasingPlan.periodPrice'));
       
       // 原有排序添加逻辑不变...
   }
   

2. 新增ProductListingResultEvent的订阅，手动排序结果集：

   public static function getSubscribedEvents(): array
   {
       return [
           ProductListingCriteriaEvent::class => ['addCriteria', 5000],
           ProductListingResultEvent::class => ['sortByMinLeasingPrice', 5000]
       ];
   }
   
   public function sortByMinLeasingPrice(ProductListingResultEvent $event): void
   {
       $result = $event->getResult();
       $aggregations = $result->getAggregations();
       $minPriceAgg = $aggregations->get('min_period_price');
       if (!$minPriceAgg) return;
       
       // 提取每个商品的最小租赁价格
       $minPrices = [];
       foreach ($minPriceAgg->getBuckets() as $bucket) {
           $minPrices[$bucket->getKey()] = $bucket->getValue();
       }
       
       // 对当前页商品按最小价格排序
       $sortedProducts = $result->getEntities()->sort(function(ProductEntity $a, ProductEntity $b) use ($minPrices) {
           $priceA = $minPrices[$a->getId()] ?? PHP_INT_MAX;
           $priceB = $minPrices[$b->getId()] ?? PHP_INT_MAX;
           return $priceA <=> $priceB;
       });
       
       $result->setEntities($sortedProducts);
   }
   

   注意：该方式仅对当前页商品有效，分页场景下无法保证全量数据的排序正确性，适合数据量小或无需分页的场景。

内容的提问来源于stack exchange，提问作者Steve Krämer