custom/plugins/MasterFFLCheckout/src/Subscriber/DeleteFflAddressSubscriber.php line 25

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace MasterFFL\Checkout\Subscriber;
  5. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Psr\Log\LoggerInterface;
  12. class DeleteFflAddressSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private readonly EntityRepository $customerAddressRepository,
  16.         private readonly EntityRepository $customerRepository,
  17.         private readonly LoggerInterface  $logger
  18.     ) {}
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlaced'];
  23.     }
  25.     public function onCheckoutOrderPlaced(CheckoutOrderPlacedEvent $event): void
  26.     {
  27.         $order      = $event->getOrder();
  28.         $context    = $event->getContext();
  29.         $customerId = $order->getOrderCustomer()?->getCustomerId();
  31.         // Get shipping address
  32.         $shippingAddress = $order->getDeliveries()->first()?->getShippingOrderAddress();
  33.         if (!$shippingAddress) {
  34.             $this->logger->info('[FFL] No shipping address found in order');
  35.             return;
  36.         }
  38.         // Check if this is an FFL address - FIXED LOGIC
  39.         $customFields = $shippingAddress->getCustomFields() ?? [];
  40.         $isFflAddress = $customFields['is_ffl_address'] ?? false;
  42.         // Log for debugging
  43.         $this->logger->info('[FFL] Order placed - checking address type', [
  44.             'order_id' => $order->getId(),
  45.             'custom_fields' => $customFields,
  46.             'is_ffl_address' => $isFflAddress
  47.         ]);
  49.         // If NOT an FFL address, skip processing
  50.         if (!$isFflAddress || $isFflAddress !== true) {
  51.             $this->logger->info('[FFL] Not an FFL address, skipping cleanup', [
  52.                 'order_id' => $order->getId(),
  53.                 'is_ffl_address' => $isFflAddress
  54.             ]);
  55.             return;
  56.         }
  58.         if ($customerId === null) {
  59.             $this->logger->warning('[FFL] No customer ID found in order');
  60.             return;
  61.         }
  63.         $this->processFflAddressCleanup($customerId, $order->getId(), $context);
  64.     }
  66.     private function processFflAddressCleanup(string $customerId, string $orderId, $context): void
  67.     {
  68.         try {
  69.             // Get all customer addresses
  70.             $addresses = $this->customerAddressRepository->search(
  71.                 (new Criteria())->addFilter(new EqualsFilter('customerId', $customerId)),
  72.                 $context
  73.             )->getEntities();
  75.             $fflAddressIds = [];
  76.             $regularAddressIds = [];
  78.             // Separate FFL and regular addresses
  79.             foreach ($addresses as $address) {
  80.                 $customFields = $address->getCustomFields() ?? [];
  81.                 $isFflAddress = $customFields['is_ffl_address'] ?? false;
  82.                 
  83.                 if ($isFflAddress === true || $isFflAddress === 1 || $isFflAddress === '1') {
  84.                     $fflAddressIds[] = $address->getId();
  85.                 } else {
  86.                     $regularAddressIds[] = $address->getId();
  87.                 }
  88.             }
  90.             $this->logger->info('[FFL] Address analysis', [
  91.                 'customer_id' => $customerId,
  92.                 'order_id' => $orderId,
  93.                 'ffl_addresses' => count($fflAddressIds),
  94.                 'regular_addresses' => count($regularAddressIds)
  95.             ]);
  97.             // If no FFL addresses to clean up, return
  98.             if (empty($fflAddressIds)) {
  99.                 $this->logger->info('[FFL] No FFL addresses found to cleanup');
  100.                 return;
  101.             }
  103.             // If customer has regular addresses, delete FFL addresses and set new default
  104.             if (!empty($regularAddressIds)) {
  105.                 $this->safeDeleteFflAddresses($fflAddressIds, $regularAddressIds[0], $customerId, $context);
  106.                 
  107.                 $this->logger->info('[FFL] FFL addresses cleaned up successfully', [
  108.                     'customer_id' => $customerId,
  109.                     'order_id' => $orderId,
  110.                     'deleted_ffl_addresses' => $fflAddressIds,
  111.                     'new_default_address' => $regularAddressIds[0]
  112.                 ]);
  113.             } else {
  114.                 // Customer only has FFL addresses - keep one and mark it as regular
  115.                 $this->convertFflAddressToRegular($fflAddressIds[0], $context);
  116.                 
  117.                 $this->logger->warning('[FFL] Customer only had FFL addresses, converted one to regular', [
  118.                     'customer_id' => $customerId,
  119.                     'order_id' => $orderId,
  120.                     'converted_address' => $fflAddressIds[0]
  121.                 ]);
  122.             }
  124.         } catch (\Exception $e) {
  125.             $this->logger->error('[FFL] Error during FFL address cleanup', [
  126.                 'customer_id' => $customerId,
  127.                 'order_id' => $orderId,
  128.                 'error' => $e->getMessage()
  129.             ]);
  130.         }
  131.     }
  133.     private function safeDeleteFflAddresses(array $fflAddressIds, string $newDefaultId, string $customerId, $context): void
  134.     {
  135.         // Update customer default addresses first
  136.         $this->customerRepository->update([[
  137.             'id' => $customerId,
  138.             'defaultShippingAddressId' => $newDefaultId,
  139.             'defaultBillingAddressId' => $newDefaultId,
  140.         ]], $context);
  142.         // Delete FFL addresses
  143.         $payload = array_map(fn ($id) => ['id' => $id], $fflAddressIds);
  144.         $this->customerAddressRepository->delete($payload, $context);
  145.     }
  147.     private function convertFflAddressToRegular(string $addressId, $context): void
  148.     {
  149.         // Remove FFL flag from address
  150.         $this->customerAddressRepository->update([[
  151.             'id' => $addressId,
  152.             'customFields' => [
  153.                 'is_ffl_address' => false,
  154.                 'converted_from_ffl' => true,
  155.                 'converted_at' => date('Y-m-d H:i:s')
  156.             ]
  157.         ]], $context);
  158.     }
  159. }