custom/plugins/SwagPayPal/src/Checkout/Order/Shipping/ShippingSubscriber.php line 66

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Swag\PayPal\Checkout\Order\Shipping;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryDefinition;
  12. use Shopware\Core\Checkout\Order\OrderEvents;
  13. use Shopware\Core\Defaults;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\ChangeSetAware;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  18. use Swag\PayPal\Checkout\Order\Shipping\Service\ShippingService;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ShippingSubscriber implements EventSubscriberInterface
  22. {
  23.     private ShippingService $shippingService;
  25.     private LoggerInterface $logger;
  27.     public function __construct(
  28.         ShippingService $shippingService,
  29.         LoggerInterface $logger
  30.     ) {
  31.         $this->shippingService = $shippingService;
  32.         $this->logger = $logger;
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             PreWriteValidationEvent::class => 'triggerChangeSet',
  39.             OrderEvents::ORDER_DELIVERY_WRITTEN_EVENT => 'onOrderDeliveryWritten',
  40.         ];
  41.     }
  43.     public function triggerChangeSet(PreWriteValidationEvent $event): void
  44.     {
  45.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  46.             return;
  47.         }
  49.         foreach ($event->getCommands() as $command) {
  50.             if (!$command instanceof ChangeSetAware) {
  51.                 continue;
  52.             }
  54.             if ($command->getDefinition()->getEntityName() !== OrderDeliveryDefinition::ENTITY_NAME) {
  55.                 continue;
  56.             }
  58.             if (!isset($command->getPayload()['tracking_codes'])) {
  59.                 continue;
  60.             }
  62.             $command->requestChangeSet();
  63.         }
  64.     }
  66.     public function onOrderDeliveryWritten(EntityWrittenEvent $event): void
  67.     {
  68.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  69.             return;
  70.         }
  72.         foreach ($event->getWriteResults() as $writeResult) {
  73.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_DELETE) {
  74.                 continue;
  75.             }
  77.             $before = [];
  78.             $changeSet = $writeResult->getChangeSet();
  79.             if ($changeSet !== null && !$changeSet->hasChanged('tracking_codes')) {
  80.                 continue;
  81.             }
  83.             if ($changeSet !== null) {
  84.                 $codesBefore = $changeSet->getBefore('tracking_codes') ?? [];
  85.                 $before = !\is_array($codesBefore) ? \json_decode($codesBefore) : [];
  86.             }
  88.             $orderDeliveryId = $writeResult->getPrimaryKey();
  89.             $after = $writeResult->getProperty('trackingCodes') ?? [];
  90.             if (!\is_string($orderDeliveryId) || !\is_array($after) || !\is_array($before)) {
  91.                 continue;
  92.             }
  94.             try {
  95.                 $this->shippingService->updateTrackingCodes($orderDeliveryId, $after, $before, $event->getContext());
  96.             } catch (\Throwable $e) {
  97.                 $this->logger->warning('Could not update tracking codes', [
  98.                     'exception' => $e,
  99.                     'trace' => $e->getTraceAsString(),
  100.                 ]);
  102.                 throw $e;
  103.             }
  104.         }
  105.     }
  106. }