Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/old/lib/internal/Customweb/Cron/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php
/**
  * You are allowed to use this API in your web application.
 *
 * Copyright (C) 2018 by customweb GmbH
 *
 * This program is licenced under the customweb software licence. With the
 * purchase or the installation of the software in your application you
 * accept the licence agreement. The allowed usage is outlined in the
 * customweb software licence which can be found under
 * http://www.sellxed.com/en/software-license-agreement
 *
 * Any modification or distribution is strictly forbidden. The license
 * grants you the installation in one application. For multiuse you will need
 * to purchase further licences at http://www.sellxed.com/shop.
 *
 * See the customweb software licence agreement for more details.
 *
 */



/**
 * Implementation of a processor for cron annotations. 
 * 
 * The methods annotated with the cron annotation. The object is either
 * called statically or as an bean from the container.
 * 
 * @author Thomas Hunziker
 *
 */
class Customweb_Cron_Processor {
	
	private $container;
	
	/**
	 * @var array
	 */
	private $packages = array();
	
	private $startTime = null;
	
	public function __construct(Customweb_DependencyInjection_IContainer $container, $packages = array()) {
		$this->container = new Customweb_DependencyInjection_Container_Extendable($container);
		$this->packages = $packages;
	}
	
	/**
	 * Execute all cron jobs.
	 * 
	 * @throws Exception In case something went wrong.
	 */
	public function run() {
		$scanner = new Customweb_Annotation_Scanner();
		$annotations = $scanner->find('Customweb_Cron_Annotation_Cron', $this->packages);
		
		$approxFinalizeTime = 4;
		$maxExecutionTime = Customweb_Util_System::getMaxExecutionTime() - $approxFinalizeTime;
		$start = $this->getStartTime();
		$endTime = $start + $maxExecutionTime;
		
		foreach ($annotations as $identifier => $annotation) {
			if ($endTime < time()) {
				break;
			}
			if ($annotation instanceof Customweb_Cron_Annotation_Cron) {
				$parts = explode('::', $identifier, 2);
				$className = $parts[0];
				$methodName = $parts[1];
				$this->invoke($className, $methodName, $annotation);
			}
		}
	}
	
	protected function invoke($className, $methodName, Customweb_Cron_Annotation_Cron $annotation) {
		$reflector = new ReflectionClass($className);
		$method = $reflector->getMethod($methodName);
		
		$object = null;
		if (!$method->isStatic()) {
			$bean = Customweb_DependencyInjection_Bean_Provider_Annotation_Util::createBeanInstance($className, $className);
			$object = $bean->getInstance($this->getContainer());
		}
		$args = $this->resolveInvocationArguements($method);
		$method->invoke($object, $args);
	}
	
	protected function resolveInvocationArguements(ReflectionMethod $method) {
		$args = array();
	
		foreach ($method->getParameters() as $parameter) {
			$type = Customweb_Core_Util_Reflection::getParameterType($parameter);
			if ($type === null) {
				throw new Exception(Customweb_Core_String::_("Unable to invoke method @method because it contain a primitive type.")->format(array('@method' => $method->getName())));
			}
			$args[] = $this->getContainer()->getBean($type);
		}
	
		return $args;
	}
	
	protected function getContainer() {
		return $this->container;
	}
	
	/**
	 * Returns the start time of the PHP process.
	 *
	 * @return int
	 */
	protected function getStartTime() {
		if ($this->startTime === null) {
			if (isset($_SERVER['REQUEST_TIME'])) {
				$this->startTime = $_SERVER['REQUEST_TIME'];
			}
			else {
				$this->startTime = time();
			}
		}
	
		return $this->startTime;
	}
	
}