OpenXE/classes/Modules/SubscriptionCycle/Scheduler/SubscriptionCycleManualJobTask.php

<?php

declare(strict_types=1);

namespace Xentral\Modules\SubscriptionCycle\Scheduler;


use ApplicationCore;
use DateTimeImmutable;
use DateTimeInterface;
use Exception;
use Xentral\Components\Database\Database;
use Xentral\Modules\SubscriptionCycle\Service\SubscriptionCycleJobService;
use Xentral\Modules\SubscriptionCycle\SubscriptionCycleModuleInterface;
use Xentral\Modules\SubscriptionCycle\SubscriptionModuleInterface;

final class SubscriptionCycleManualJobTask
{
  private ApplicationCore $app;
  private Database $db;
  private SubscriptionCycleJobService $cycleJobService;
  private TaskMutexServiceInterface $taskMutexService;
  private SubscriptionModuleInterface $subscriptionModule;

  /**
   * SubscriptionCycleManualJobTask constructor.
   *
   * @param ApplicationCore $app
   * @param Database $db
   * @param TaskMutexServiceInterface $taskMutexService
   * @param SubscriptionCycleJobService $cycleJobService
   * @param SubscriptionModuleInterface $subscriptionModule
   */
    public function __construct(
        ApplicationCore $app,
        Database $db,
        TaskMutexServiceInterface $taskMutexService,
        SubscriptionCycleJobService $cycleJobService,
        SubscriptionModuleInterface $subscriptionModule
    ) {
        $this->app = $app;
        $this->db = $db;
        $this->taskMutexService = $taskMutexService;
        $this->cycleJobService = $cycleJobService;
        $this->subscriptionModule = $subscriptionModule;
    }

    public function execute(): void
    {
        if ($this->taskMutexService->isTaskInstanceRunning('rechnungslauf_manual')) {
            return;
        }
        $this->taskMutexService->setMutex('rechnungslauf_manual');
        $jobs = $this->cycleJobService->listAll(100);
        foreach ($jobs as $job) {
          switch ($job['document_type']) {
            case 'rechnung':
              $this->subscriptionModule->CreateInvoice((int)$job['address_id']);
              break;
            case 'auftrag':
              $this->subscriptionModule->CreateOrder((int)$job['address_id']);
              break;
          }
          $this->cycleJobService->delete((int)$job['id']);
        }
    }

    public function cleanup(): void
    {
        $this->taskMutexService->setMutex('rechnungslauf_manual', false);
    }
}