custom/plugins/MasterFFLCheckout/src/Subscriber/OrderSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace MasterFFL\Checkout\Subscriber;
  5. use Shopware\Core\Checkout\Order\OrderEvents;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Psr\Log\LoggerInterface;
  11. class OrderSubscriber implements EventSubscriberInterface
  12. {
  13.     private EntityRepositoryInterface $orderRepository;
  14.     private LoggerInterface $logger;
  16.     public function __construct(
  17.         EntityRepositoryInterface $orderRepository,
  18.         LoggerInterface $logger
  19.     ) {
  20.         $this->orderRepository = $orderRepository;
  21.         $this->logger = $logger;
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten'
  28.         ];
  29.     }
  31.     public function onOrderWritten(EntityWrittenEvent $event): void
  32.     {
  33.         foreach ($event->getWriteResults() as $writeResult) {
  34.             $payload = $writeResult->getPayload();
  35.             
  36.             // Check if this is an FFL order
  37.             if (isset($payload['customFields']['is_ffl_order']) && $payload['customFields']['is_ffl_order']) {
  38.                 $this->handleFFLOrder($payload, $event->getContext());
  39.             }
  40.         }
  41.     }
  43.     private function handleFFLOrder(array $orderData, $context): void
  44.     {
  45.         try {
  46.             $this->logger->info('Processing FFL order', [
  47.                 'orderId' => $orderData['id'],
  48.                 'fflDealerId' => $orderData['customFields']['ffl_dealer_id'] ?? null
  49.             ]);
  51.             // Store FFL dealer information in order custom fields
  52.             if (isset($orderData['customFields']['ffl_dealer_id'])) {
  53.                 $this->updateOrderWithFFLData($orderData['id'], $orderData['customFields'], $context);
  54.             }
  56.         } catch (\Exception $e) {
  57.             $this->logger->error('Error processing FFL order', [
  58.                 'orderId' => $orderData['id'],
  59.                 'error' => $e->getMessage()
  60.             ]);
  61.         }
  62.     }
  64.     private function updateOrderWithFFLData(string $orderId, array $customFields, $context): void
  65.     {
  66.         $this->orderRepository->update([
  67.             [
  68.                 'id' => $orderId,
  69.                 'customFields' => array_merge($customFields, [
  70.                     'ffl_processed' => true,
  71.                     'ffl_processing_date' => date('Y-m-d H:i:s')
  72.                 ])
  73.             ]
  74.         ], $context);
  75.     }
  76. }