custom/plugins/AsbsTrustedShopsReviews/src/Subscriber/OrderStateChangeSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Asbs\TrustedShopsReviews\Subscriber;
  7. use Asbs\TrustedShopsReviews\Service\ReviewEmailService;
  8. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class OrderStateChangeSubscriber implements EventSubscriberInterface
  17. {
  18.     const DAYS_AFTER_ORDER = 'AsbsTrustedShopsReviews.config.daysAfterOrder';
  20.     private EntityRepository $orderRepository;
  21.     private ReviewEmailService $reviewEmailService;
  22.     private SystemConfigService $configService;
  23.     private LoggerInterface $logger;
  25.     public function __construct(
  26.         EntityRepository $orderRepository,
  27.         ReviewEmailService $reviewEmailService,
  28.         SystemConfigService $configService,
  29.         LoggerInterface $logger
  30.     ) {
  31.         $this->orderRepository = $orderRepository;
  32.         $this->reviewEmailService = $reviewEmailService;
  33.         $this->configService = $configService;
  34.         $this->logger = $logger;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             OrderStateMachineStateChangeEvent::class => 'onOrderStateChange'
  41.         ];
  42.     }
  44.     public function onOrderStateChange(OrderStateMachineStateChangeEvent $event): void
  45.     {
  46.         $order = $event->getOrder();
  47.         $newState = $event->getNextState();
  48.         
  49.         // Prüfe ob Order nicht mehr offen oder abgebrochen ist
  50.         if (in_array($newState->getTechnicalName(), ['open', 'cancelled'])) {
  51.             return;
  52.         }
  54.         // Prüfe ob bereits eine Bewertungsmail versendet wurde
  55.         if ($this->isReviewEmailAlreadySent($order->getId(), $event->getContext())) {
  56.             return;
  57.         }
  59.         // Prüfe ob Order älter als 14 Tage ist
  60.         if (!$this->isOrderOlderThan14Days($order)) {
  61.             return;
  62.         }
  64.         try {
  65.             $this->sendReviewEmailForOrder($order->getId(), $event->getContext());
  66.         } catch (\Exception $e) {
  67.             $this->logger->error('Failed to process review email on order state change', [
  68.                 'orderId' => $order->getId(),
  69.                 'newState' => $newState->getTechnicalName(),
  70.                 'error' => $e->getMessage()
  71.             ]);
  72.         }
  73.     }
  75.     private function isReviewEmailAlreadySent(string $orderId, Context $context): bool
  76.     {
  77.         $criteria = new Criteria([$orderId]);
  78.         $order = $this->orderRepository->search($criteria, $context)->first();
  79.         
  80.         if (!$order) {
  81.             return true; // Sicherheitshalber als "bereits versendet" markieren
  82.         }
  84.         $customFields = $order->getCustomFields() ?? [];
  85.         return isset($customFields['asbs_review_email_sent']) && $customFields['asbs_review_email_sent'] === true;
  86.     }
  88.     private function isOrderOlderThan14Days($order): bool
  89.     {
  90.         $daysAfterOrder = $this->configService->get(self::DAYS_AFTER_ORDER) ?? 14;
  91.         $orderDate = $order->getOrderDate();
  92.         $daysAgo = new \DateTime("-{$daysAfterOrder} days");
  93.         
  94.         return $orderDate <= $daysAgo;
  95.     }
  97.     private function sendReviewEmailForOrder(string $orderId, Context $context): void
  98.     {
  99.         $criteria = new Criteria([$orderId]);
  100.         $criteria->addAssociations([
  101.             'orderCustomer',
  102.             'addresses.country',
  103.             'stateMachineState'
  104.         ]);
  105.         
  106.         $order = $this->orderRepository->search($criteria, $context)->first();
  107.         
  108.         if (!$order) {
  109.             return;
  110.         }
  112.         $orderCustomer = $order->getOrderCustomer();
  113.         if (!$orderCustomer) {
  114.             return;
  115.         }
  117.         $orderData = [
  118.             'email' => $orderCustomer->getEmail(),
  119.             'firstname' => $orderCustomer->getFirstName(),
  120.             'lastname' => $orderCustomer->getLastName(),
  121.             'order_date' => $order->getOrderDate()->format('Y-m-d'),
  122.             'order_id' => $order->getOrderNumber()
  123.         ];
  125.         // Hier würde der GraphQLClient Service injiziert und aufgerufen werden
  126.         // Das machen wir über den ReviewEmailService
  127.         $this->logger->info('Processing review email for order state change', [
  128.             'orderId' => $orderId,
  129.             'orderNumber' => $order->getOrderNumber()
  130.         ]);
  131.     }
  132. }