mirror of
https://github.com/OpenXE-org/OpenXE.git
synced 2024-11-15 20:47:15 +01:00
78 lines
2.4 KiB
PHP
78 lines
2.4 KiB
PHP
<?php
|
|
/*
|
|
* SPDX-FileCopyrightText: 2022 Andreas Palm
|
|
* SPDX-FileCopyrightText: 2019 Xentral ERP Sorftware GmbH, Fuggerstrasse 11, D-86150 Augsburg
|
|
* SPDX-License-Identifier: LicenseRef-EGPL-3.1
|
|
*/
|
|
|
|
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);
|
|
}
|
|
}
|