custom/plugins/CodevisionMiraklConnector/src/Subscriber/MiraklOfferExportEventsSubscriber.php line 21

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Webmozart\Assert\Assert;
  10. use Webmozart\Assert\InvalidArgumentException;
  12. class MiraklOfferExportEventsSubscriber implements EventSubscriberInterface
  13. {
  14.     public static function getSubscribedEvents(): array
  15.     {
  16.         return [
  17.             MiraklProductExportInspectEvent::NAME => 'onOfferExport',
  18.         ];
  19.     }
  21.     public function onOfferExport(MiraklProductExportInspectEvent $event): MiraklProductExportInspectEvent
  22.     {
  23.         $customFields = $event->getProductExportEntity()->getSalesChannel()->getCustomFields();
  25.         if ($customFields === null) {
  26.             return $event;
  27.         }
  29.         if (array_key_exists('codevisionMiraklConnectorChannel_type', $customFields) === false) {
  30.             return $event;
  31.         }
  33.         if ($customFields['codevisionMiraklConnectorChannel_type'] !== SalesChannel::OFFER_SELECT_TYPE()->getValue()) {
  34.             return $event;
  35.         }
  37.         $event->setIncludeInExport(true);
  39.         try {
  40.             $customFields = $event->getProductEntity()->getCustomFields();
  42.             if ($customFields === null) {
  43.                 return $event;
  44.             }
  46.             /**
  47.              * Feature 2023-01-06: We do not want to disable offer export if products aren't synchronized
  48.              * they could have been synchronized outside of shopware already
  49.              *
  50.              * Assert::keyExists($customFields, 'codevisionMiraklConnectorProduct_syncDate');
  51.              *
  52.              * $lastImportErrorMessage = $customFields['codevisionMiraklConnectorProduct_errorMessage'] ?? '';
  53.              *
  54.              * Assert::length($lastImportErrorMessage, 0);
  55.              */
  57.             if (array_key_exists('codevisionMiraklConnectorProduct_offerSyncDate', $customFields) === false) {
  58.                 return $event;
  59.             }
  61.             $lastSyncDate = new \DateTimeImmutable($customFields['codevisionMiraklConnectorProduct_offerSyncDate']);
  63.             // 15 Minutes grace period
  64.             $minInterval = new \DateInterval('PT15M');
  65.             $gracePeriodTime = (new \DateTime())->sub($minInterval);
  67.             // we do not want to send the offer again within a 15 minute time frame
  68.             // only active in production mode
  69.             if (CodevisionMiraklConnector::DEBUG_MODE === false) {
  70.                 Assert::greaterThan($gracePeriodTime, $lastSyncDate);
  71.             }
  73.             // this is neccessary as the update date can be slightly different than the lastSyncDate due to server
  74.             // performance reasons, thus we deduct a 30 second grace period which captures that
  75.             $minInterval = new \DateInterval('PT30S');
  76.             $graceUpdateTime = $event->getProductEntity()->getUpdatedAt()->sub($minInterval);
  78.             Assert::greaterThan($graceUpdateTime, $lastSyncDate);
  80.         } catch (InvalidArgumentException $exception) {
  81.             $event->setIncludeInExport(false);
  82.         }
  84.         return $event;
  85.     }
  86. }