custom/plugins/theme/src/Subscriber/AccountOrderSubscriber.php line 30

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DonCarneTheme\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Storefront\Page\Account\Order\AccountEditOrderPageLoadedEvent;
  8. use Shopware\Storefront\Page\Account\Order\AccountOrderPageLoadedEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class AccountOrderSubscriber implements EventSubscriberInterface
  12. {
  13.     private Connection $connection;
  14.     private LoggerInterface $logger;
  16.     public function __construct(Connection $connection, LoggerInterface $logger)
  17.     {
  18.         $this->connection = $connection;
  19.         $this->logger = $logger;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             AccountEditOrderPageLoadedEvent::class => 'onAccountOrderPageLoaded',
  26.             AccountOrderPageLoadedEvent::class => 'onAccountOrderPageLoaded'
  27.         ];
  28.     }
  30.     public function onAccountOrderPageLoaded($event): void
  31.     {
  32.         $this->logger->info('AccountOrderSubscriber called for event: ' . get_class($event));
  34.         // For AccountEditOrderPageLoadedEvent, process single order
  35.         if ($event instanceof AccountEditOrderPageLoadedEvent) {
  36.             $this->logger->info('Processing AccountEditOrderPageLoadedEvent');
  37.             try {
  38.                 $order = $event->getPage()->getOrder();
  39.                 $this->logger->info('Got order: ' . ($order ? $order->getOrderNumber() : 'null'));
  40.                 if ($order) {
  41.                     $this->processOrder($order, $event);
  42.                 } else {
  43.                     $this->logger->warning('Order is null in AccountEditOrderPageLoadedEvent');
  44.                 }
  45.             } catch (\Exception $e) {
  46.                 $this->logger->error('Error in AccountEditOrderPageLoadedEvent: ' . $e->getMessage());
  47.             }
  48.             return;
  49.         }
  51.         // For AccountOrderPageLoadedEvent (Order History), process all orders
  52.         if ($event instanceof AccountOrderPageLoadedEvent) {
  53.             $this->logger->info('Processing AccountOrderPageLoadedEvent (Order History)');
  54.             try {
  55.                 $orders = $event->getPage()->getOrders();
  56.                 $this->logger->info('Got ' . $orders->count() . ' orders');
  58.                 foreach ($orders as $order) {
  59.                     $this->processOrder($order, $event);
  60.                 }
  61.             } catch (\Exception $e) {
  62.                 $this->logger->error('Error in AccountOrderPageLoadedEvent: ' . $e->getMessage());
  63.             }
  64.         }
  65.     }
  67.     private function processOrder($order, $event): void
  68.     {
  69.         $customerId = $event->getSalesChannelContext()->getCustomer()?->getId();
  71.         $this->logger->info('Order Number: ' . $order->getOrderNumber());
  72.         $this->logger->info('Customer ID: ' . ($customerId ?? 'null'));
  74.         if (!$customerId) {
  75.             $this->logger->warning('No customer ID found');
  76.             return;
  77.         }
  79.         // Get all product numbers from the order
  80.         $productNumbers = [];
  81.         foreach ($order->getLineItems() as $lineItem) {
  82.             if ($lineItem->getType() === 'product' && $lineItem->getPayload()['productNumber']) {
  83.                 $productNumbers[] = $lineItem->getPayload()['productNumber'];
  84.             }
  85.         }
  87.         $this->logger->info('Product numbers found: ' . implode(', ', $productNumbers));
  89.         if (empty($productNumbers)) {
  90.             $this->logger->warning('No product numbers found');
  91.             return;
  92.         }
  94.         // Check which products already have reviews from this customer for this order
  95.         $placeholders = str_repeat('?,', count($productNumbers) - 1) . '?';
  97.         $existingReviews = $this->connection->executeQuery("
  98.             SELECT article as productNumber
  99.             FROM `trusted_reviews`
  100.             WHERE order_number = ?
  101.             AND article IN ($placeholders)
  102.         ", array_merge([$order->getOrderNumber()], $productNumbers))
  103.         ->fetchAllAssociative();
  105.         $this->logger->info('Existing reviews found: ' . count($existingReviews));
  107.         // Create a map of reviewed product numbers
  108.         $reviewedProducts = [];
  109.         foreach ($existingReviews as $review) {
  110.             $reviewedProducts[$review['productNumber']] = true;
  111.             $this->logger->info('Product ' . $review['productNumber'] . ' already reviewed');
  112.         }
  114.         // Add extension to order entity with reviewed products info
  115.         $order->addExtension('reviewedProducts', new \Shopware\Core\Framework\Struct\ArrayStruct([
  116.             'reviewedProducts' => $reviewedProducts,
  117.             'debug_order_number' => $order->getOrderNumber(),
  118.             'debug_product_numbers' => $productNumbers,
  119.             'debug_query_result_count' => count($existingReviews)
  120.         ]));
  122.         $this->logger->info('Extension added to order');
  123.     }
  124. }