custom/plugins/PickwareErpStarter/src/Reorder/Subscriber/SystemConfigSubscriber.php line 42

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\PickwareErpStarter\Reorder\Subscriber;
  14. use DateInterval;
  15. use DateTime;
  16. use DateTimeZone;
  17. use Pickware\DalBundle\EntityManager;
  18. use Pickware\PickwareErpStarter\Reorder\ScheduledTask\ReorderNotificationTask;
  19. use Shopware\Core\Framework\Context;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  21. use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskDefinition;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class SystemConfigSubscriber implements EventSubscriberInterface
  25. {
  26.     public const REORDER_NOTIFICATION_TIME_CONFIGURATION_KEY = 'PickwareErpStarter.global-plugin-config.reorderNotificationTime';
  28.     private EntityManager $entityManager;
  30.     public function __construct(EntityManager $entityManager)
  31.     {
  32.         $this->entityManager = $entityManager;
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             'system_config.written' => 'afterSystemConfigWritten',
  39.         ];
  40.     }
  42.     public function afterSystemConfigWritten(EntityWrittenEvent $event): void
  43.     {
  44.         $writeResults = $event->getWriteResults();
  45.         foreach ($writeResults as $writeResult) {
  46.             $payload = $writeResult->getPayload();
  48.             // Since we only support a global configuration (i.e. not for a specific sales channel), ignore
  49.             // configurations that have a sales channel id.
  50.             $isSalesChannelConfiguration = $payload['salesChannelId'] !== null;
  51.             $isReorderNotificationTimeConfiguration = $payload['configurationKey'] === self::REORDER_NOTIFICATION_TIME_CONFIGURATION_KEY;
  52.             if ($isSalesChannelConfiguration || !$isReorderNotificationTimeConfiguration) {
  53.                 continue;
  54.             }
  56.             $timeNowInUTC = new DateTime('now', new DateTimeZone('UTC'));
  57.             $nextExecutionTimeInUTC = DateTime::createFromFormat('H:i:s', $payload['configurationValue'], new DateTimeZone('UTC'));
  58.             if ($timeNowInUTC > $nextExecutionTimeInUTC) {
  59.                 // New reorder notification time is older than now. Set next execution to tomorrow on that time.
  60.                 $nextExecutionTimeInUTC->add(new DateInterval('P1D'));
  61.             }
  62.             $this->updateNextExecutionTimeOfScheduledTask(
  63.                 ReorderNotificationTask::class,
  64.                 $nextExecutionTimeInUTC,
  65.                 $event->getContext(),
  66.             );
  67.         }
  68.     }
  70.     private function updateNextExecutionTimeOfScheduledTask(
  71.         string $taskClass,
  72.         DateTime $nextExecutionTimeInUTC,
  73.         Context $context
  74.     ): void {
  75.         $scheduledTask = $this->entityManager->findOneBy(ScheduledTaskDefinition::class, [
  76.             'scheduledTaskClass' => $taskClass,
  77.         ], $context);
  78.         if (!$scheduledTask) {
  79.             return;
  80.         }
  82.         // Shopware expects the "nextExecutionTime" of a scheduled task to be in UTC
  83.         $this->entityManager->update(
  84.             ScheduledTaskDefinition::class,
  85.             [
  86.                 [
  87.                     'id' => $scheduledTask->getId(),
  88.                     'nextExecutionTime' => $nextExecutionTimeInUTC,
  89.                 ],
  90.             ],
  91.             $context,
  92.         );
  93.     }
  94. }