custom/plugins/MasterFFLCheckout/src/Subscriber/CheckoutSubscriber.php line 81

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\EntityRepositoryInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\RequestStack;
  10. use Psr\Log\LoggerInterface;
  12. class CheckoutSubscriber implements EventSubscriberInterface
  13. {
  14.     private EntityRepositoryInterface $orderRepository;
  15.     private RequestStack $requestStack;
  16.     private LoggerInterface $logger;
  18.     public function __construct(
  19.         EntityRepositoryInterface $orderRepository,
  20.         RequestStack $requestStack,
  21.         LoggerInterface $logger
  22.     ) {
  23.         $this->orderRepository = $orderRepository;
  24.         $this->requestStack = $requestStack;
  25.         $this->logger = $logger;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             'checkout.order.placed' => 'onOrderPlaced',
  32.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten'
  33.         ];
  34.     }
  36.     public function onOrderPlaced($event): void
  37.     {
  38.         try {
  39.             $request = $this->requestStack->getCurrentRequest();
  40.             if (!$request) {
  41.                 $this->logger->warning('FFL: No request found in onOrderPlaced');
  42.                 return;
  43.             }
  45.             $session = $request->getSession();
  46.             
  47.             // Check for FFL dealer info in multiple session keys
  48.             $fflDealerInfo = $session->get('ffl_dealer_info');
  49.             $fflDealerAddress = $session->get('ffl_dealer_address');
  50.             
  51.             $this->logger->info('FFL: Order placed, checking for FFL data', [
  52.                 'ffl_dealer_info' => $fflDealerInfo ? 'Present' : 'Not found',
  53.                 'ffl_dealer_address' => $fflDealerAddress ? 'Present' : 'Not found'
  54.             ]);
  55.             
  56.             if ($fflDealerInfo || $fflDealerAddress) {
  57.                 $orderId = method_exists($event, 'getOrderId') ? $event->getOrderId() : $event->getOrder()->getId();
  58.                 $dealerData = $fflDealerInfo ? ($fflDealerInfo['dealerData'] ?? $fflDealerInfo) : $fflDealerAddress;
  59.                 
  60.                 $this->updateOrderWithFFLData($orderId, $dealerData, $event->getContext());
  61.                 
  62.                 // Keep FFL data in session for order confirmation page
  63.                 $session->set('order_ffl_dealer', $dealerData);
  64.                 
  65.                 $this->logger->info('FFL: Order updated with FFL data', [
  66.                     'orderId' => $orderId,
  67.                     'dealerId' => $dealerData['dealerId'] ?? 'unknown'
  68.                 ]);
  69.             } else {
  70.                 $this->logger->info('FFL: No FFL data found for order');
  71.             }
  73.         } catch (\Exception $e) {
  74.             $this->logger->error('FFL: Error processing FFL order on placement', [
  75.                 'error' => $e->getMessage(),
  76.                 'trace' => $e->getTraceAsString()
  77.             ]);
  78.         }
  79.     }
  81.     public function onOrderWritten(EntityWrittenEvent $event): void
  82.     {
  83.         try {
  84.             $request = $this->requestStack->getCurrentRequest();
  85.             if (!$request) return;
  87.             $session = $request->getSession();
  88.             $fflData = $session->get('ffl_dealer_info') ?: $session->get('ffl_dealer_address');
  90.             if (!$fflData) return;
  92.             foreach ($event->getWriteResults() as $writeResult) {
  93.                 $payload = $writeResult->getPayload();
  94.                 
  95.                 if ($writeResult->getOperation() === 'insert') {
  96.                     $orderId = $payload['id'];
  97.                     $dealerData = is_array($fflData) && isset($fflData['dealerData']) ? $fflData['dealerData'] : $fflData;
  98.                     
  99.                     $this->updateOrderWithFFLData($orderId, $dealerData, $event->getContext());
  100.                     
  101.                     $this->logger->info('FFL: Order written event processed', [
  102.                         'orderId' => $orderId
  103.                     ]);
  104.                 }
  105.             }
  107.         } catch (\Exception $e) {
  108.             $this->logger->error('FFL: Error in onOrderWritten', [
  109.                 'error' => $e->getMessage()
  110.             ]);
  111.         }
  112.     }
  114.     private function updateOrderWithFFLData(string $orderId, array $fflData, $context): void
  115.     {
  116.         try {
  117.             $customFields = [
  118.                 'is_ffl_order' => true,
  119.                 'ffl_dealer_id' => $fflData['dealerId'] ?? '',
  120.                 'ffl_dealer_name' => $fflData['firstName'] ?? $fflData['company'] ?? '',
  121.                 'ffl_dealer_company' => $fflData['company'] ?? '',
  122.                 'ffl_dealer_street' => $fflData['street'] ?? '',
  123.                 'ffl_dealer_city' => $fflData['city'] ?? '',
  124.                 'ffl_dealer_state' => $fflData['regionCode'] ?? '',
  125.                 'ffl_dealer_zipcode' => $fflData['zipcode'] ?? '',
  126.                 'ffl_dealer_phone' => $fflData['phoneNumber'] ?? $fflData['telephone'] ?? '',
  127.                 'ffl_processing_date' => date('Y-m-d H:i:s')
  128.             ];
  130.             $this->orderRepository->update([
  131.                 [
  132.                     'id' => $orderId,
  133.                     'customFields' => $customFields
  134.                 ]
  135.             ], $context);
  137.             $this->logger->info('FFL: Order custom fields updated', [
  138.                 'orderId' => $orderId,
  139.                 'dealerId' => $fflData['dealerId'] ?? 'unknown'
  140.             ]);
  142.         } catch (\Exception $e) {
  143.             $this->logger->error('FFL: Error updating order with FFL data', [
  144.                 'orderId' => $orderId,
  145.                 'error' => $e->getMessage()
  146.             ]);
  147.         }
  148.     }
  149. }