custom/plugins/CompraEsiSW6/src/Tasks/EsiLoggingTaskHandler.php line 15

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Compra\EsiSW6\Tasks;
  5. use Compra\EsiSW6\Administration\Service\ConfigurationService;
  6. use Compra\EsiSW6\Logging\Services\LoggingService;
  7. use Compra\FoundationSW6\Core\Framework\AbstractScheduledTaskHandler;
  8. use Exception;
  9. use Monolog\Logger;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. /**
  13.  * @deprecated tag:v6.5.0 - change type of $scheduledTaskRepository to EntityRepository
  14.  */
  15. class EsiLoggingTaskHandler extends AbstractScheduledTaskHandler
  16. {
  17.     /**
  18.      * @var EntityRepositoryInterface
  19.      */
  20.     protected $scheduledTaskRepository;
  22.     protected ConfigurationService $configurationService;
  24.     protected LoggingService $loggingService;
  26.     public function __construct(
  27.         Logger $logger,
  28.         EntityRepositoryInterface $scheduledTaskRepository,
  29.         LoggingService $loggingService,
  30.         ConfigurationService $configurationService
  31.     )
  32.     {
  33.         $this->scheduledTaskRepository = $scheduledTaskRepository;
  34.         $this->loggingService = $loggingService;
  35.         $this->configurationService = $configurationService;
  37.         parent::__construct($logger, $scheduledTaskRepository);
  38.     }
  40.     public static function getHandledMessages(): iterable
  41.     {
  42.         return [EsiLoggingTask::class];
  43.     }
  45.     /**
  46.      * @throws Exception
  47.      * @throws \Doctrine\DBAL\Driver\Exception
  48.      */
  49.     public function run(): void
  50.     {
  51.         echo "==Esi Logging Start==\n";
  52.         if ($this->configurationService->getConfigurationByName('logging_send_error')) {
  53.             //checks for weekend configuration
  54.             //returns weekend information if applicable
  55.             if ($this->loggingService->isTodayLoggingEnabled()) {
  56.                 echo "ESI Logging skipped. Not configured to run on weekends.\n";
  57.             }
  59.             //checks for ESI runtime configuration
  60.             //returns runtime information if applicable
  61.             else if ($this->loggingService->isNowInRuntimePeriod()) {
  62.                 echo "ESI Logging skipped. Outside of service time.\n";
  63.             }
  65.             else {
  66.                 //checks for configured errors in previous import tasks and sends mail if applicable
  68.                 $loggingErrors = null;
  70.                 try {
  71.                     $loggingErrors = $this->loggingService->processEsiLoggingTask();
  72.                     if(count($loggingErrors) > 0) {
  73.                         $this->loggingService->sendLoggingErrorMail($loggingErrors, 'ESI Logging Fehlerbericht');
  74.                     }
  75.                 } catch(\Exception $e) {
  76.                     echo $e->getMessage();
  77.                 }
  79.                 echo sprintf("ESI Logging processed successfully with %s errors.\n", $loggingErrors ? (string) count($loggingErrors) : "");
  80.             }
  81.         }
  82.         echo "==Esi Logging Complete==\n";
  84.     }
  85. }