custom/plugins/PickwareErpStarter/vendor/pickware/config-bundle/src/AbstractScheduledTaskExecutionTimeConfigSubscriber.php line 49

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\ConfigBundle;
  14. use DateTime;
  15. use DateTimeZone;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. /**
  20.  * Use this subscriber to allow setting the execution time (not datetime!) of a scheduled task via plugin configuration.
  21.  */
  22. abstract class AbstractScheduledTaskExecutionTimeConfigSubscriber implements EventSubscriberInterface
  23. {
  24.     private ScheduledTaskExecutionTimeUpdater $scheduledTaskExecutionTimeUpdater;
  25.     private string $configurationKey;
  26.     private string $scheduledTaskClassName;
  28.     public function __construct(
  29.         ScheduledTaskExecutionTimeUpdater $scheduledTaskExecutionTimeUpdater,
  30.         string $configurationKey,
  31.         string $scheduledTaskClassName
  32.     ) {
  33.         $this->scheduledTaskExecutionTimeUpdater = $scheduledTaskExecutionTimeUpdater;
  34.         $this->configurationKey = $configurationKey;
  35.         $this->scheduledTaskClassName = $scheduledTaskClassName;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             'system_config.written' => 'afterSystemConfigWritten',
  42.         ];
  43.     }
  45.     /**
  46.      * Listens to configuration changes and uses the time (not datetime!) input of a config field to update the next
  47.      * execution time of the scheduled task.
  48.      */
  49.     public function afterSystemConfigWritten(EntityWrittenEvent $event): void
  50.     {
  51.         $writeResults = $event->getWriteResults();
  52.         foreach ($writeResults as $writeResult) {
  53.             $payload = $writeResult->getPayload();
  55.             // Since scheduled tasks are unique, we only support a single global configuration (i.e. not for a specific
  56.             // sales channel) for scheduled task configuration. Ignore configurations that have a sales channel id.
  57.             $isSalesChannelConfiguration = $payload['salesChannelId'] !== null;
  58.             if ($isSalesChannelConfiguration || $payload['configurationKey'] !== $this->configurationKey) {
  59.                 continue;
  60.             }
  62.             $nextExecutionTimeInUTC = DateTime::createFromFormat('H:i:s', $payload['configurationValue'], new DateTimeZone('UTC'));
  63.             $this->scheduledTaskExecutionTimeUpdater->updateExecutionTimeOfScheduledTask(
  64.                 $this->scheduledTaskClassName,
  65.                 $nextExecutionTimeInUTC,
  66.                 $event->getContext(),
  67.             );
  68.         }
  69.     }
  70. }