custom/plugins/CodevisionMiraklConnector/src/Subscriber/MiraklProductExportEventsSubscriber.php line 35

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace CodevisionMiraklConnector\Subscriber;
  5. use CodevisionMiraklConnector\CodevisionMiraklConnector;
  6. use CodevisionMiraklConnector\Enum\Shopware\SalesChannel;
  7. use CodevisionMiraklConnector\Event\MiraklProductExportInspectEvent;
  8. use CodevisionMiraklConnector\Operation\GetValueFromConfigOperation;
  9. use CodevisionMiraklConnector\Response\ConfigurationValueResponse;
  10. use CodevisionMiraklConnector\Service\Logger\PluginLogAwareInterface;
  11. use CodevisionMiraklConnector\Service\Logger\PluginLogAwareTrait;
  12. use League\Tactician\CommandBus;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Webmozart\Assert\Assert;
  15. use Webmozart\Assert\InvalidArgumentException;
  17. class MiraklProductExportEventsSubscriber implements EventSubscriberInterface, PluginLogAwareInterface
  18. {
  19.     use PluginLogAwareTrait;
  21.     private CommandBus $commandBus;
  23.     public function __construct(CommandBus $commandBus)
  24.     {
  25.         $this->commandBus = $commandBus;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             MiraklProductExportInspectEvent::NAME => 'onProductExportInspect',
  32.         ];
  33.     }
  35.     public function onProductExportInspect(MiraklProductExportInspectEvent $event): MiraklProductExportInspectEvent
  36.     {
  37.         $customFields = $event->getProductExportEntity()->getSalesChannel()->getCustomFields();
  39.         if ($customFields === null) {
  40.             return $event;
  41.         }
  43.         if (array_key_exists('codevisionMiraklConnectorChannel_type', $customFields) === false) {
  44.             return $event;
  45.         }
  47.         if ($customFields['codevisionMiraklConnectorChannel_type'] !== SalesChannel::PRODUCT_SELECT_TYPE()->getValue(
  48.             )) {
  49.             return $event;
  50.         }
  52.         /**
  53.          * @var ConfigurationValueResponse $configResponse
  54.          */
  55.         $configResponse = $this->commandBus->handle(new GetValueFromConfigOperation('enableProductSync'));
  57.         if ($configResponse->getConfigurationValue() === false) {
  58.             return $event;
  59.         }
  61.         $event->setIncludeInExport(true);
  63.         try {
  64.             $customFields = $event->getProductEntity()->getCustomFields();
  66.             if ($customFields === null) {
  67.                 return $event;
  68.             }
  70.             if (array_key_exists('codevisionMiraklConnectorProduct_syncDate', $customFields) === false) {
  71.                 return $event;
  72.             }
  74.             $lastSyncDate = new \DateTimeImmutable($customFields['codevisionMiraklConnectorProduct_syncDate']);
  76.             // 15 Minutes grace period
  77.             $minInterval = new \DateInterval('PT15M');
  78.             $gracePeriodTime = (new \DateTime())->sub($minInterval);
  80.             // we do not want to send the offer again within a 15 minute time frame
  81.             // only active in production mode
  82.             if (CodevisionMiraklConnector::DEBUG_MODE === false) {
  83.                 Assert::greaterThan($gracePeriodTime, $lastSyncDate);
  84.             }
  86.             // this is neccessary as the update date can be slightly different than the lastSyncDate due to server
  87.             // performance reasons, thus we deduct a 30 second grace period which captures that
  88.             $minInterval = new \DateInterval('PT30S');
  89.             $graceUpdateTime = $event->getProductEntity()->getUpdatedAt()->sub($minInterval);
  91.             Assert::greaterThan($graceUpdateTime, $lastSyncDate);
  93.         } catch (InvalidArgumentException $exception) {
  94.             $event->setIncludeInExport(false);
  95.         }
  97.         return $event;
  98.     }
  99. }