File manager

File manager - Edit - /home/web/vm-3fadc827.na4u.ru/www/bitrix/modules/bizproc/classes/general/workflowpersister.php

Back
<?php use Bitrix\Main; /** * Workflow persistence service. / class CBPAllWorkflowPersister { const LOCK_BY_TIME = false; protected $serviceInstanceId = ""; protected $ownershipDelta = 300; protected $useGZipCompression = false; private static $instance; public function __clone() { trigger_error('Clone in not allowed.', E_USER_ERROR); } private function __construct() { $this->serviceInstanceId = uniqid("", true); $this->useGZipCompression = \CBPWorkflowTemplateLoader::useGZipCompression(); } /* * @return self / public static function GetPersister() { if (!isset(self::$instance)) { $c = __CLASS__; self::$instance = new $c; } return self::$instance; } private function RetrieveWorkflow($instanceId, $silent = false) { global $DB; $queryCondition = $this->getLockerQueryCondition(); $dbResult = $DB->Query( "SELECT WORKFLOW, WORKFLOW_RO, IF (".$queryCondition.", 'Y', 'N') as UPDATEABLE ". "FROM b_bp_workflow_instance ". "WHERE ID = '".$DB->ForSql($instanceId)."' " ); if ($arResult = $dbResult->Fetch()) { if ($arResult["UPDATEABLE"] == "Y" && !$silent) { $DB->Query( "UPDATE b_bp_workflow_instance SET ". " OWNER_ID = '".$DB->ForSql($this->serviceInstanceId)."', ". " OWNED_UNTIL = ".$DB->CharToDateFunction(date($GLOBALS["DB"]->DateFormatToPHP(FORMAT_DATETIME), $this->GetOwnershipTimeout()))." ". "WHERE ID = '".$DB->ForSql($instanceId)."'" ); } elseif (!$silent) { throw new Exception(GetMessage("BPCGWP_WF_LOCKED"), \CBPRuntime::EXCEPTION_CODE_INSTANCE_LOCKED); } return [$arResult["WORKFLOW"], $arResult["WORKFLOW_RO"]]; } throw new Exception(GetMessage("BPCGWP_INVALID_WF"), \CBPRuntime::EXCEPTION_CODE_INSTANCE_NOT_FOUND); } protected function InsertWorkflow($id, $buffer, $status, $bUnlocked, array $creationData = []) { global $DB; $queryCondition = $this->getLockerQueryCondition(); if ($status == CBPWorkflowStatus::Completed \|\| $status == CBPWorkflowStatus::Terminated) { $DB->Query( "DELETE FROM b_bp_workflow_instance ". "WHERE ID = '".$DB->ForSql($id)."'" ); } else { $dbResult = $DB->Query( "SELECT ID, IF (".$queryCondition.", 'Y', 'N') as UPDATEABLE ". "FROM b_bp_workflow_instance ". "WHERE ID = '".$DB->ForSql($id)."' " ); if ($arResult = $dbResult->Fetch()) { if ($arResult["UPDATEABLE"] == "Y") { $DB->Query( "UPDATE b_bp_workflow_instance SET ". " WORKFLOW = '".$DB->ForSql($buffer)."', ". " STATUS = ".intval($status).", ". " MODIFIED = ".$DB->CurrentTimeFunction().", ". " OWNER_ID = ".($bUnlocked ? "NULL" : "'".$DB->ForSql($this->serviceInstanceId)."'").", ". " OWNED_UNTIL = ".($bUnlocked ? "NULL" : $DB->CharToDateFunction(date($GLOBALS["DB"]->DateFormatToPHP(FORMAT_DATETIME), $this->GetOwnershipTimeout())))." ". "WHERE ID = '".$DB->ForSql($id)."' " ); } else { throw new Exception(GetMessage('BPCGWP_WF_LOCKED'), \CBPRuntime::EXCEPTION_CODE_INSTANCE_LOCKED); } } else { $status = (int) $status; $ownerId = ($bUnlocked ? "NULL" : "'".$DB->ForSql($this->serviceInstanceId)."'"); $ownedUntil = ($bUnlocked ? "NULL" : $DB->CharToDateFunction(date($GLOBALS["DB"]->DateFormatToPHP(FORMAT_DATETIME), $this->GetOwnershipTimeout()))); $moduleId = isset($creationData['MODULE_ID']) ? $creationData['MODULE_ID'] : ''; $entity = isset($creationData['ENTITY']) ? $creationData['ENTITY'] : ''; $documentId = isset($creationData['DOCUMENT_ID']) ? $creationData['DOCUMENT_ID'] : ''; $tplId = isset($creationData['WORKFLOW_TEMPLATE_ID']) ? (int) $creationData['WORKFLOW_TEMPLATE_ID'] : 0; $startedBy = isset($creationData['STARTED_BY']) ? (int) $creationData['STARTED_BY'] : 0; $startedEventType = isset($creationData['STARTED_EVENT_TYPE']) ? (int) $creationData['STARTED_EVENT_TYPE'] : 0; $ro = isset($creationData['RO']) ? "'".$DB->ForSql($creationData['RO'])."'" : 'NULL'; $DB->Query( sprintf( 'INSERT INTO b_bp_workflow_instance ( ID, WORKFLOW, WORKFLOW_RO, STATUS, MODIFIED, OWNER_ID, OWNED_UNTIL, MODULE_ID, ENTITY, DOCUMENT_ID, WORKFLOW_TEMPLATE_ID, STARTED, STARTED_BY, STARTED_EVENT_TYPE ) VALUES (\'%s\', \'%s\', %s, %d, %s, %s, %s, \'%s\', \'%s\', \'%s\', %d, %s, %d, %d)', $DB->ForSql($id), $DB->ForSql($buffer), $ro, $status, $DB->CurrentTimeFunction(), $ownerId, $ownedUntil, $DB->ForSql($moduleId), $DB->ForSql($entity), $DB->ForSql($documentId), $tplId, $DB->CurrentTimeFunction(), $startedBy, $startedEventType ) ); } } } protected function GetOwnershipTimeout() { return time() + $this->ownershipDelta; } public function LoadWorkflow($instanceId, $silent = false) { [$state, $ro] = $this->RetrieveWorkflow($instanceId, $silent); if ($state) { return $this->RestoreFromSerializedForm($state, $ro); } throw new Exception("WorkflowNotFound"); } private function RestoreFromSerializedForm($buffer, $ro) { if ($this->useGZipCompression) { $buffer = gzuncompress($buffer); $ro = $ro ? gzuncompress($ro) : null; } if ($buffer == '') { throw new Exception("EmptyWorkflowInstance"); } /* @var CBPCompositeActivity $activity / $activity = CBPActivity::Load($buffer); if ($ro) { $ro = Main\Web\Json::decode($ro); if (is_array($ro)) { $activity->setReadOnlyData($ro); } } return $activity; } public static function __InsertWorkflowHack($id, $buffer) { $p = CBPWorkflowPersister::GetPersister(); if ($p->useGZipCompression) $buffer = gzcompress($buffer, 9); $p->InsertWorkflow($id, $buffer, 1, true); } public function SaveWorkflow(CBPActivity $rootActivity, $bUnlocked) { $creationData = []; if ($rootActivity->workflow->isNew()) { $dt = $rootActivity->GetDocumentId(); $creationData['MODULE_ID'] = $dt[0]; $creationData['ENTITY'] = $dt[1]; $creationData['DOCUMENT_ID'] = $dt[2]; $creationData['WORKFLOW_TEMPLATE_ID'] = $rootActivity->GetWorkflowTemplateId(); $creationData['STARTED_EVENT_TYPE'] = $rootActivity->getDocumentEventType(); $startedBy = $rootActivity->{\CBPDocument::PARAM_TAGRET_USER}; if ($startedBy) { $creationData['STARTED_BY'] = \CBPHelper::StripUserPrefix($startedBy); } /* @var CBPCompositeActivity $rootActivity / $creationData['RO'] = $this->getJsonCompressed($rootActivity->pullReadOnlyData()); } else { /* @var CBPCompositeActivity $rootActivity */ $rootActivity->pullReadOnlyData(); } $workflowStatus = $rootActivity->GetWorkflowStatus(); $buffer = ""; if (($workflowStatus != CBPWorkflowStatus::Completed) && ($workflowStatus != CBPWorkflowStatus::Terminated)) { $buffer = $this->GetSerializedForm($rootActivity); } $this->InsertWorkflow($rootActivity->GetWorkflowInstanceId(), $buffer, $workflowStatus, $bUnlocked, $creationData); } private function GetSerializedForm(CBPActivity $rootActivity) { $buffer = $rootActivity->Save(); if ($this->useGZipCompression) $buffer = gzcompress($buffer, 9); return $buffer; } private function getJsonCompressed($data): string { $buffer = Main\Web\Json::encode($data); if ($this->useGZipCompression) { $buffer = gzcompress($buffer, 9); } return $buffer; } public function UnlockWorkflow(CBPActivity $rootActivity) { global $DB; if ($rootActivity == null) throw new Exception("rootActivity"); $DB->Query( "UPDATE b_bp_workflow_instance SET ". " OWNER_ID = NULL, ". " OWNED_UNTIL = NULL ". "WHERE ID = '".$DB->ForSql($rootActivity->GetWorkflowInstanceId())."' ". " AND ( ". " (OWNER_ID = '".$DB->ForSql($this->serviceInstanceId)."' ". " AND OWNED_UNTIL >= ".$DB->CurrentTimeFunction().") ". " OR ". " (OWNER_ID IS NULL) ". " OR ". " (OWNER_ID IS NOT NULL ". " AND OWNED_UNTIL < ".$DB->CurrentTimeFunction().") ". " )" ); } protected function getLockerQueryCondition() { global $DB; if (!static::LOCK_BY_TIME) { return "(OWNER_ID IS NULL OR OWNER_ID = '".$DB->ForSql($this->serviceInstanceId)."')"; } return "( ". " (OWNER_ID = '".$DB->ForSql($this->serviceInstanceId)."' ". " AND OWNED_UNTIL >= ".$DB->CurrentTimeFunction().") ". " OR ". " (OWNER_ID IS NULL) ". " OR ". " (OWNER_ID IS NOT NULL ". " AND OWNED_UNTIL < ".$DB->CurrentTimeFunction().") ". ") "; } } //Compatibility class CBPWorkflowPersister extends CBPAllWorkflowPersister { }

| ver. 1.4 | Github | . | PHP 7.4.33 | Generation time: 0.28 | proxy | phpinfo | Settings