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

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. /**
  22.  * @internal
  23.  */
  24. class ShippingSubscriber implements EventSubscriberInterface
  25. {
  26.     private ShippingService $shippingService;
  28.     private LoggerInterface $logger;
  30.     public function __construct(
  31.         ShippingService $shippingService,
  32.         LoggerInterface $logger
  33.     ) {
  34.         $this->shippingService = $shippingService;
  35.         $this->logger = $logger;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             PreWriteValidationEvent::class => 'triggerChangeSet',
  42.             OrderEvents::ORDER_DELIVERY_WRITTEN_EVENT => 'onOrderDeliveryWritten',
  43.         ];
  44.     }
  46.     public function triggerChangeSet(PreWriteValidationEvent $event): void
  47.     {
  48.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  49.             return;
  50.         }
  52.         foreach ($event->getCommands() as $command) {
  53.             if (!$command instanceof ChangeSetAware) {
  54.                 continue;
  55.             }
  57.             if ($command->getDefinition()->getEntityName() !== OrderDeliveryDefinition::ENTITY_NAME) {
  58.                 continue;
  59.             }
  61.             if (!isset($command->getPayload()['tracking_codes'])) {
  62.                 continue;
  63.             }
  65.             $command->requestChangeSet();
  66.         }
  67.     }
  69.     public function onOrderDeliveryWritten(EntityWrittenEvent $event): void
  70.     {
  71.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  72.             return;
  73.         }
  75.         foreach ($event->getWriteResults() as $writeResult) {
  76.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_DELETE) {
  77.                 continue;
  78.             }
  80.             $before = [];
  81.             $changeSet = $writeResult->getChangeSet();
  82.             if ($changeSet !== null && !$changeSet->hasChanged('tracking_codes')) {
  83.                 continue;
  84.             }
  86.             if ($changeSet !== null) {
  87.                 $codesBefore = $changeSet->getBefore('tracking_codes') ?? [];
  88.                 $before = !\is_array($codesBefore) ? \json_decode($codesBefore) : [];
  89.             }
  91.             $orderDeliveryId = $writeResult->getPrimaryKey();
  92.             $after = $writeResult->getProperty('trackingCodes') ?? [];
  93.             if (!\is_string($orderDeliveryId) || !\is_array($after) || !\is_array($before)) {
  94.                 continue;
  95.             }
  97.             try {
  98.                 $this->shippingService->updateTrackingCodes($orderDeliveryId, $after, $before, $event->getContext());
  99.             } catch (\Throwable $e) {
  100.                 $this->logger->warning('Could not update tracking codes', [
  101.                     'exception' => $e,
  102.                     'trace' => $e->getTraceAsString(),
  103.                 ]);
  104.             }
  105.         }
  106.     }
  107. }