class.ilCronEcsTaskScheduler.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2010 ILIAS open source, Extended GPL, see docs/LICENSE */
 
class ilCronEcsTaskScheduler extends \ilCronJob
{
 
    public const ID = 'ecs_task_handler';
 
    public const DEFAULT_SCHEDULE_VALUE = 1;
 
    private $logger = null;
 
    protected $lng = null;
 
    protected $result = null;
 
    public function __construct()
    {
        global $DIC;
 
        $this->logger = $DIC->logger()->wsrv();
        $this->lng = $DIC->language();
        $this->lng->loadLanguageModule('ecs');
 
        $this->result = new \ilCronJobResult();
    }
 
    public function getTitle()
    {
        return $this->lng->txt('ecs_cron_task_scheduler');
    }
 
    public function getDescription()
    {
        return $this->lng->txt('ecs_cron_task_scheduler_info');
    }
 
    public function getId()
    {
        return self::ID;
    }
 
    public function hasAutoActivation()
    {
        return false;
    }
 
    public function hasFlexibleSchedule()
    {
        return true;
    }
 
    public function getDefaultScheduleType()
    {
        return self::SCHEDULE_TYPE_IN_HOURS;
    }
 
 
 
    public function getDefaultScheduleValue()
    {
        return self::DEFAULT_SCHEDULE_VALUE;
    }
 
    public function run()
    {
        $this->logger->debug('Starting ecs task scheduler...');
 
        $servers = \ilECSServerSettings::getInstance();
 
        foreach ($servers->getServers() as $server) {
            try {
                $this->logger->info('Starting task execution for ecs server: ' . $server->getTitle());
                $scheduler = \ilECSTaskScheduler::_getInstanceByServerId($server->getServerId());
                $scheduler->startTaskExecution();
            } catch (\Exception $e) {
                $this->result->setStatus(\ilCronJobResult::STATUS_CRASHED);
                $this->result->setMessage($e->getMessage());
                $this->logger->warning('ECS task execution failed with message: ' . $e->getMessage());
                return $this->result;
            }
        }
        $this->result->setStatus(\ilCronJobResult::STATUS_OK);
        return $this->result;
    }
}