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/Payment/Update/

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.
 *
 */




/**
 * This process transactions which are scheduled for a update.
 * The scheduling is organised by the
 * transaction itself.
 *
 * @author Thomas Hunziker / Simon Schurter
 *
 */
class Customweb_Payment_Update_ScheduledProcessor extends Customweb_Payment_Update_AbstractLockProcessor {
	private $transactionObject = null;
	private $transactionId = null;

	/**
	 * @Cron()
	 * @see Customweb_Payment_Update_AbstractProcessor::process() 
	 */
	public function process(){
		if ($this->getUpdateAdapter() === null) {
			return;
		}
		
		if (!$this->tryLockUpdate()) {
			return;
		}
		
		$approximatelyExecutedTime = 4;
		$maxExecutionTime = Customweb_Util_System::getMaxExecutionTime() - $approximatelyExecutedTime;
		$start = $this->getStartTime();
		$maxEndtime = $maxExecutionTime + $start;
		
		try {
			$candidates = $this->getHandler()->getScheduledTransactionIds();
			foreach ($candidates as $transactionId) {
				if ($maxEndtime > time()) {
					$this->executeUpdate($transactionId);
				}
				else {
					break;
				}
			}
		}
		catch (Exception $e) {
			$this->getHandler()->log("Failed to load scheduled transactions: " . $e->getMessage().$e->getTraceAsString(), Customweb_Payment_Update_IHandler::LOG_TYPE_ERROR);
		}
		
		$this->unlockUpdate();
	}

	protected function getBackendStorageSpace(){
		return 'scheduled_update_processor';
	}

	private function executeUpdate($transactionId){
		$this->getTransactionHandler()->beginTransaction();
		try {
			$transactionObject = $this->getTransactionHandler()->findTransactionByTransactionId($transactionId);
			if ($transactionObject == null) {
				$this->getHandler()->log(
						Customweb_Util_String::formatString("No transaction found for transaction id '!id'.", array(
							'!id' => $transactionId 
						)), Customweb_Payment_Update_IHandler::LOG_TYPE_ERROR);
			}
			else {
				if ($transactionObject->getUpdateExecutionDate() !== null && $transactionObject->getUpdateExecutionDate()->getTimestamp() <= time()) {
					// 				$lastUpdateDate = $transactionObject->getUpdateExecutionDate();
					try {
						if (method_exists($transactionObject, 'setUpdateExecutionDate')) {
							$transactionObject->setUpdateExecutionDate(null);
						}
						
						$this->getUpdateAdapter()->updateTransaction($transactionObject);
						
						$this->getHandler()->log(
								Customweb_Util_String::formatString("Update Adapter for transaction with id '!id' successfully called.", array(
									'!id' => $transactionId 
								)), Customweb_Payment_Update_IHandler::LOG_TYPE_INFO);
					}
					catch (Exception $e) {
						$this->getHandler()->log($e->getMessage(), Customweb_Payment_Update_IHandler::LOG_TYPE_ERROR);
					}
				}
				$this->getTransactionHandler()->persistTransactionObject($transactionObject);
			}
			$this->getTransactionHandler()->commitTransaction();
		}
		catch (Exception $e) {
			$this->getTransactionHandler()->rollbackTransaction();
			$this->getHandler()->log(
					Customweb_Util_String::formatString("Unexpected error while updating the transaction with id '!id'. Error: !e", array(
						'!id' => $transactionId, '!e' => $e->getMessage()
					)), Customweb_Payment_Update_IHandler::LOG_TYPE_INFO);
		}
	}
}