stateservice.php

См. документацию.

<?php
 
use Bitrix\Bizproc\Workflow\Entity\WorkflowDurationStatTable;
use Bitrix\Bizproc\Workflow\Entity\WorkflowStateTable;
use Bitrix\Bizproc\Workflow\Entity\WorkflowInstanceTable;
use Bitrix\Main;
 
class CBPStateService extends CBPRuntimeService
{
    const COUNTERS_CACHE_TAG_PREFIX = 'b_bp_wfi_cnt_';
 
    protected static array $statesCache = [];
 
    public function setStateTitle($workflowId, $stateTitle)
    {
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception("workflowId");
        }
 
        WorkflowStateTable::update($workflowId, ['STATE_TITLE' => $stateTitle]);
    }
 
    public function setStatePermissions($workflowId, $arStatePermissions = array(), $bRewrite = true)
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId == '')
            throw new Exception("workflowId");
 
        if ($bRewrite === true || ($bRewrite['setMode'] ?? null) === CBPSetPermissionsMode::Clear)
        {
            $DB->Query(
                "DELETE FROM b_bp_workflow_permissions ".
                "WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
            );
        }
        $arState = self::GetWorkflowState($workflowId);
        $documentService = $this->runtime->GetService("DocumentService");
        $documentService->SetPermissions($arState["DOCUMENT_ID"], $workflowId, $arStatePermissions, $bRewrite);
        $documentType = $documentService->GetDocumentType($arState["DOCUMENT_ID"]);
        if ($documentType)
            $arStatePermissions = $documentService->toInternalOperations($documentType, $arStatePermissions);
 
        foreach ($arStatePermissions as $permission => $arObjects)
        {
            foreach ($arObjects as $object)
            {
                $DB->Query(
                    "INSERT INTO b_bp_workflow_permissions (WORKFLOW_ID, OBJECT_ID, PERMISSION) ".
                    "VALUES ('".$DB->ForSql($workflowId)."', '".$DB->ForSql($object)."', '".$DB->ForSql($permission)."')"
                );
            }
        }
    }
 
    public function getStateTitle($workflowId)
    {
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception("workflowId");
        }
 
        $result = WorkflowStateTable::query()
            ->setSelect(['STATE_TITLE'])
            ->where('ID', $workflowId)
            ->fetch();
 
        return $result['STATE_TITLE'] ?? '';
    }
 
    public static function getStateDocumentId($workflowId)
    {
        static $cache = [];
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception("workflowId");
        }
 
        if (isset($cache[$workflowId]))
        {
            return $cache[$workflowId];
        }
 
        $result = WorkflowStateTable::query()
            ->setSelect(['MODULE_ID', 'ENTITY', 'DOCUMENT_ID'])
            ->where('ID', $workflowId)
            ->fetch();
 
        if ($result)
        {
            $cache[$workflowId] = [$result['MODULE_ID'], $result['ENTITY'], $result['DOCUMENT_ID']];
 
            return $cache[$workflowId];
        }
 
        return false;
    }
 
    public function AddWorkflow($workflowId, $workflowTemplateId, $documentId, $starterUserId = 0)
    {
        $docId = CBPHelper::ParseDocumentId($documentId);
 
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception("workflowId");
        }
 
        $workflowTemplateId = (int)$workflowTemplateId;
        if ($workflowTemplateId <= 0)
        {
            throw new Exception("workflowTemplateId");
        }
 
        $starterUserId = (int)$starterUserId;
 
        if (WorkflowStateTable::exists($workflowId))
        {
            throw new Exception("WorkflowAlreadyExists");
        }
 
        $addResult = WorkflowStateTable::add([
            'ID' => $workflowId,
            'MODULE_ID' => $docId[0] ?: null,
            'ENTITY' => $docId[1],
            'DOCUMENT_ID' => $docId[2],
            'DOCUMENT_ID_INT' => (int)$docId[2],
            'WORKFLOW_TEMPLATE_ID' => $workflowTemplateId,
            'STARTED_BY' => $starterUserId ?: null,
        ]);
 
        if ($starterUserId > 0 && $addResult->isSuccess())
        {
            self::cleanRunningCountersCache($starterUserId);
        }
        self::clearStatesCache();
    }
 
    public static function deleteWorkflow($workflowId)
    {
        $connection = Main\Application::getConnection();
 
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception("workflowId");
        }
 
        $info = self::getWorkflowStateInfo($workflowId);
 
        if (!empty($info['STARTED_BY']))
        {
            self::cleanRunningCountersCache($info['STARTED_BY']);
        }
 
        $workflowIdSql = $connection->getSqlHelper()->forSql($workflowId);
        $connection->query(
            "DELETE FROM b_bp_workflow_permissions WHERE WORKFLOW_ID = '{$workflowIdSql}'",
        );
 
        WorkflowStateTable::delete($workflowId);
        self::clearStatesCache();
    }
 
    public function deleteAllDocumentWorkflows($documentId)
    {
        self::DeleteByDocument($documentId);
    }
 
    public function onStatusChange(string $workflowId, int $status): void
    {
        self::clearStatesCache();
        if ($status == CBPWorkflowStatus::Completed || $status == CBPWorkflowStatus::Terminated)
        {
            $info = $this->getWorkflowStateInfo($workflowId);
            $userId = isset($info['STARTED_BY']) ? (int)$info['STARTED_BY'] : 0;
            if ($userId > 0)
            {
                self::cleanRunningCountersCache($userId);
            }
 
            foreach (GetModuleEvents('bizproc', 'OnWorkflowComplete', true) as $event)
            {
                ExecuteModuleEventEx($event, array($workflowId, $status));
            }
 
            // Clean workflow subscriptions
            \Bitrix\Bizproc\SchedulerEventTable::deleteByWorkflow($workflowId);
 
            if ($info)
            {
                $this->fillWorkflowDurationStat($info, $status);
            }
        }
    }
 
    private static function extractState(&$arStates, $arResult): void
    {
        if (!array_key_exists($arResult["ID"], $arStates))
        {
            $arStates[$arResult["ID"]] = array(
                "ID" => $arResult["ID"],
                "TEMPLATE_ID" => $arResult["WORKFLOW_TEMPLATE_ID"],
                "TEMPLATE_NAME" => $arResult["NAME"],
                "TEMPLATE_DESCRIPTION" => $arResult["DESCRIPTION"],
                "STATE_MODIFIED" => $arResult["MODIFIED"],
                "STATE_NAME" => $arResult["STATE"],
                "STATE_TITLE" => $arResult["STATE_TITLE"],
                "STATE_PARAMETERS" => ($arResult["STATE_PARAMETERS"] <> '' ? unserialize($arResult["STATE_PARAMETERS"], ['allowed_classes' => false]) : array()),
                "WORKFLOW_STATUS" => $arResult["STATUS"],
                "STATE_PERMISSIONS" => array(),
                "DOCUMENT_ID" => array($arResult["MODULE_ID"], $arResult["ENTITY"], $arResult["DOCUMENT_ID"]),
                "STARTED" => $arResult["STARTED"],
                "STARTED_BY" => $arResult["STARTED_BY"],
                "STARTED_FORMATTED" => $arResult["STARTED_FORMATTED"],
            );
        }
 
        if ($arResult["PERMISSION"] <> '' && $arResult["OBJECT_ID"] <> '')
        {
            $arResult["PERMISSION"] = mb_strtolower($arResult["PERMISSION"]);
 
            if (!array_key_exists($arResult["PERMISSION"], $arStates[$arResult["ID"]]["STATE_PERMISSIONS"]))
                $arStates[$arResult["ID"]]["STATE_PERMISSIONS"][$arResult["PERMISSION"]] = array();
 
            $arStates[$arResult["ID"]]["STATE_PERMISSIONS"][$arResult["PERMISSION"]][] = $arResult["OBJECT_ID"];
        }
    }
 
    public static function countDocumentWorkflows($documentId)
    {
        $documentId = \CBPHelper::ParseDocumentId($documentId);
 
        return WorkflowInstanceTable::getCount([
            '=MODULE_ID' => $documentId[0],
            '=ENTITY' => $documentId[1],
            '=DOCUMENT_ID' => $documentId[2],
            '!=STARTED_EVENT_TYPE' => CBPDocumentEventType::Automation,
        ]);
    }
 
    public static function getDocumentStates(array $documentId, array|string $workflowId = ''): array
    {
        global $DB;
 
        [$moduleId, $entity, $ids] = $documentId;
 
        $cacheKey = self::getStatesCacheKey($documentId, $workflowId);
 
        if (!isset(static::$statesCache[$cacheKey]))
        {
            $idsCondition = [];
            foreach ((array)$ids as $id)
            {
                $idsCondition[] = "WS.DOCUMENT_ID = '{$DB->ForSql($id)}'";
            }
 
            if (empty($idsCondition))
            {
                static::$statesCache[$cacheKey] = [];
 
                return [];
            }
 
            $sqlAdditionalFilter = "";
            if (is_array($workflowId) && count($workflowId) > 0)
            {
                $workflowId = array_map(function($id) use ($DB) {
                    return "'{$DB->ForSql((string)$id)}'";
                }, $workflowId);
                $sqlAdditionalFilter = " AND WS.ID IN (" . implode(',', $workflowId) . ")";
            }
            elseif (is_string($workflowId) && $workflowId)
            {
                $sqlAdditionalFilter = " AND WS.ID = '{$DB->ForSql(trim($workflowId))}' ";
            }
 
            $dbResult = $DB->Query(
                "SELECT WS.ID, WS.WORKFLOW_TEMPLATE_ID, WS.STATE, WS.STATE_TITLE, WS.STATE_PARAMETERS, "
                . " "
                . $DB->DateToCharFunction("WS.MODIFIED", "FULL")
                . " as MODIFIED, "
                . " WS.MODULE_ID, WS.ENTITY, WS.DOCUMENT_ID, "
                . " WT.NAME, WT.DESCRIPTION, WP.OBJECT_ID, WP.PERMISSION, WI.STATUS, "
                . " WS.STARTED, "
                . $DB->DateToCharFunction("WS.STARTED", "FULL")
                . " as STARTED_FORMATTED, WS.STARTED_BY "
                . "FROM b_bp_workflow_state WS "
                . " LEFT JOIN b_bp_workflow_permissions WP ON (WS.ID = WP.WORKFLOW_ID) "
                . " LEFT JOIN b_bp_workflow_template WT ON (WS.WORKFLOW_TEMPLATE_ID = WT.ID) "
                . " LEFT JOIN b_bp_workflow_instance WI ON (WS.ID = WI.ID) "
                . "WHERE ("
                . implode(' OR ', $idsCondition)
                . ") "
                . " AND WS.ENTITY = '"
                . $DB->ForSql($entity)
                . "' "
                . " AND WS.MODULE_ID "
                . ($moduleId ? "= '" . $DB->ForSql($moduleId) . "'" : "IS NULL")
                . " "
                . $sqlAdditionalFilter
            );
 
            $states = [];
            while ($row = $dbResult->Fetch())
            {
                self::extractState($states, $row);
            }
 
            static::$statesCache[$cacheKey] = $states;
        }
 
        return static::$statesCache[$cacheKey];
    }
 
    public static function getIdsByDocument(array $documentId, int $limit = null)
    {
        return WorkflowStateTable::getIdsByDocument($documentId, $limit);
    }
 
    public static function getWorkflowState($workflowId)
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId == '')
            throw new Exception("workflowId");
 
        $dbResult = $DB->Query(
            "SELECT WS.ID, WS.WORKFLOW_TEMPLATE_ID, WS.STATE, WS.STATE_TITLE, WS.STATE_PARAMETERS, ".
            "   ".$DB->DateToCharFunction("WS.MODIFIED", "FULL")." as MODIFIED, ".
            "   WS.MODULE_ID, WS.ENTITY, WS.DOCUMENT_ID, ".
            "   WT.NAME, WT.DESCRIPTION, WP.OBJECT_ID, WP.PERMISSION, WI.STATUS, ".
            "   WS.STARTED, WS.STARTED_BY, ".$DB->DateToCharFunction("WS.STARTED", "FULL")." as STARTED_FORMATTED ".
            "FROM b_bp_workflow_state WS ".
            "   LEFT JOIN b_bp_workflow_permissions WP ON (WS.ID = WP.WORKFLOW_ID) ".
            "   LEFT JOIN b_bp_workflow_template WT ON (WS.WORKFLOW_TEMPLATE_ID = WT.ID) ".
            "   LEFT JOIN b_bp_workflow_instance WI ON (WS.ID = WI.ID) ".
            "WHERE WS.ID = '".$DB->ForSql($workflowId)."' "
        );
 
        $arStates = array();
        while ($arResult = $dbResult->Fetch())
        {
            self::extractState($arStates, $arResult);
        }
 
        $keys = array_keys($arStates);
        if (count($keys) > 0)
            $arStates = $arStates[$keys[0]];
 
        return $arStates;
    }
 
    public static function getWorkflowStateInfo($workflowId)
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId === '')
        {
            throw new Exception('workflowId');
        }
 
        $dbResult = $DB->Query(
            "SELECT 
                WS.ID, WS.STATE_TITLE, WS.MODULE_ID, WS.ENTITY, WS.DOCUMENT_ID, WI.STATUS, WS.STARTED_BY,
                WS.WORKFLOW_TEMPLATE_ID, WT.NAME WORKFLOW_TEMPLATE_NAME, WS.STARTED ".
            "FROM b_bp_workflow_state WS ".
            "LEFT JOIN b_bp_workflow_instance WI ON (WS.ID = WI.ID) ".
            "LEFT JOIN b_bp_workflow_template WT ON (WS.WORKFLOW_TEMPLATE_ID = WT.ID) ".
            "WHERE WS.ID = '".$DB->ForSql($workflowId)."' "
        );
 
        $state = false;
        $result = $dbResult->Fetch();
        if ($result)
        {
            $state = [
                'ID' => $result["ID"],
                'WORKFLOW_TEMPLATE_ID' => $result['WORKFLOW_TEMPLATE_ID'],
                'WORKFLOW_TEMPLATE_NAME' => $result['WORKFLOW_TEMPLATE_NAME'],
                'STATE_TITLE' => $result['STATE_TITLE'],
                'WORKFLOW_STATUS' => $result['STATUS'],
                'DOCUMENT_ID' => [$result['MODULE_ID'], $result['ENTITY'], $result['DOCUMENT_ID']],
                'STARTED_BY' => $result['STARTED_BY'],
                'STARTED' => $result['STARTED'],
            ];
        }
 
        return $state;
    }
 
    public static function exists(string $workflowId)
    {
        return WorkflowStateTable::exists($workflowId);
    }
 
    public static function getWorkflowIntegerId($workflowId)
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId == '')
            throw new Exception("workflowId");
 
        $dbResult = $DB->Query(
            "SELECT ID FROM b_bp_workflow_state_identify WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
        );
 
        $result = $dbResult->fetch();
        if (!$result)
        {
            $strSql =
                "INSERT INTO b_bp_workflow_state_identify (WORKFLOW_ID) ".
                "VALUES ('".$DB->ForSql($workflowId)."')";
            $res = $DB->Query($strSql, true);
            //crutch for #0071996
            if ($res)
            {
                $result = array('ID' => $DB->LastID());
            }
            else
            {
                $dbResult = $DB->Query(
                    "SELECT ID FROM b_bp_workflow_state_identify WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
                );
 
                $result = $dbResult->fetch();
            }
        }
        return (int)$result['ID'];
    }
 
    public static function getWorkflowByIntegerId($integerId)
    {
        global $DB;
 
        $integerId = intval($integerId);
        if ($integerId <= 0)
            throw new Exception("integerId");
 
        $dbResult = $DB->Query(
            "SELECT WORKFLOW_ID FROM b_bp_workflow_state_identify WHERE ID = ".$integerId." "
        );
 
        $result = $dbResult->fetch();
        if ($result)
        {
            return $result['WORKFLOW_ID'];
        }
        return false;
    }
 
    public static function deleteByDocument(array $documentId): void
    {
        global $DB;
 
        [$moduleId, $entity, $docId] = CBPHelper::ParseDocumentId($documentId);
        $users = [];
 
        $workflows = $DB->Query(
            "SELECT ID, STARTED_BY "
            . "FROM b_bp_workflow_state "
            . "WHERE DOCUMENT_ID = '"
            . $DB->ForSql($docId)
            . "' "
            . " AND ENTITY = '"
            . $DB->ForSql($entity)
            . "' "
            . " AND MODULE_ID "
            . (($moduleId <> '') ? "= '" . $DB->ForSql($moduleId) . "'" : "IS NULL")
            . " "
        );
        while ($row = $workflows->Fetch())
        {
            $DB->Query(
                "DELETE FROM b_bp_workflow_permissions WHERE WORKFLOW_ID = '{$DB->ForSql($row["ID"])}' "
            );
 
            WorkflowStateTable::delete($row["ID"]);
 
            if (!empty($row['STARTED_BY']))
            {
                $users[] = $row['STARTED_BY'];
            }
            self::clearStatesCache();
        }
 
        self::cleanRunningCountersCache($users);
    }
 
    public static function mergeStates($firstDocumentId, $secondDocumentId)
    {
        global $DB;
 
        $arFirstDocumentId = CBPHelper::ParseDocumentId($firstDocumentId);
        $arSecondDocumentId = CBPHelper::ParseDocumentId($secondDocumentId);
 
        $DB->Query(
            "UPDATE b_bp_workflow_state SET ".
            "   DOCUMENT_ID = '".$DB->ForSql($arFirstDocumentId[2])."', ".
            "   DOCUMENT_ID_INT = ".intval($arFirstDocumentId[2]).", ".
            "   ENTITY = '".$DB->ForSql($arFirstDocumentId[1])."', ".
            "   MODULE_ID = '".$DB->ForSql($arFirstDocumentId[0])."' ".
            "WHERE DOCUMENT_ID = '".$DB->ForSql($arSecondDocumentId[2])."' ".
            "   AND ENTITY = '".$DB->ForSql($arSecondDocumentId[1])."' ".
            "   AND MODULE_ID = '".$DB->ForSql($arSecondDocumentId[0])."' "
        );
        self::clearStatesCache();
    }
 
    public static function migrateDocumentType($oldType, $newType, $workflowTemplateIds)
    {
        global $DB;
 
        $arOldType = CBPHelper::ParseDocumentId($oldType);
        $arNewType = CBPHelper::ParseDocumentId($newType);
 
        $DB->Query(
            "UPDATE b_bp_workflow_state SET ".
            "   ENTITY = '".$DB->ForSql($arNewType[1])."', ".
            "   MODULE_ID = '".$DB->ForSql($arNewType[0])."' ".
            "WHERE ENTITY = '".$DB->ForSql($arOldType[1])."' ".
            "   AND MODULE_ID = '".$DB->ForSql($arOldType[0])."' ".
            "   AND WORKFLOW_TEMPLATE_ID IN (".implode(",", $workflowTemplateIds).") "
        );
    }
 
    public function setState($workflowId, $arState, $arStatePermissions = array())
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId == '')
            throw new Exception("workflowId");
 
        $state = trim($arState["STATE"]);
        $stateTitle = trim($arState["TITLE"]);
        $stateParameters = "";
        if (count($arState["PARAMETERS"]) > 0)
            $stateParameters = serialize($arState["PARAMETERS"]);
 
        $DB->Query(
            "UPDATE b_bp_workflow_state SET ".
            "   STATE = ".($state <> '' ? "'".$DB->ForSql($state)."'" : "NULL").", ".
            "   STATE_TITLE = ".($stateTitle <> '' ? "'".$DB->ForSql($stateTitle)."'" : "NULL").", ".
            "   STATE_PARAMETERS = ".($stateParameters <> '' ? "'".$DB->ForSql($stateParameters)."'" : "NULL").", ".
            "   MODIFIED = ".$DB->CurrentTimeFunction()." ".
            "WHERE ID = '".$DB->ForSql($workflowId)."' "
        );
 
        if ($arStatePermissions !== false)
        {
            $arState = self::GetWorkflowState($workflowId);
            $runtime = $this->runtime;
            if (!isset($runtime) || !is_object($runtime))
                $runtime = CBPRuntime::GetRuntime();
            $documentService = $runtime->GetService("DocumentService");
 
            $permissionRewrite = true;
            if (isset($arStatePermissions['__mode']) || isset($arStatePermissions['__scope']))
            {
                $permissionRewrite = [
                    'setMode' => $arStatePermissions['__mode'] ?? CBPSetPermissionsMode::Clear,
                    'setScope' => $arStatePermissions['__scope'] ?? CBPSetPermissionsMode::ScopeWorkflow,
                ];
                unset($arStatePermissions['__mode'], $arStatePermissions['__scope']);
            }
 
            $documentService->SetPermissions($arState["DOCUMENT_ID"], $workflowId, $arStatePermissions, $permissionRewrite);
            $documentType = $documentService->GetDocumentType($arState["DOCUMENT_ID"]);
            if ($documentType)
            {
                $arStatePermissions = $documentService->toInternalOperations($documentType, $arStatePermissions);
            }
 
            $DB->Query(
                "DELETE FROM b_bp_workflow_permissions ".
                "WHERE WORKFLOW_ID = '".$DB->ForSql($workflowId)."' "
            );
 
            foreach ($arStatePermissions as $permission => $arObjects)
            {
                foreach ($arObjects as $object)
                {
                    $DB->Query(
                        "INSERT INTO b_bp_workflow_permissions (WORKFLOW_ID, OBJECT_ID, PERMISSION) ".
                        "VALUES ('".$DB->ForSql($workflowId)."', '".$DB->ForSql($object)."', '".$DB->ForSql($permission)."')"
                    );
                }
            }
        }
        self::clearStatesCache();
    }
 
    public function setStateParameters($workflowId, $arStateParameters = array())
    {
        global $DB;
 
        $workflowId = trim($workflowId);
        if ($workflowId == '')
            throw new Exception("workflowId");
 
        $stateParameters = "";
        if (count($arStateParameters) > 0)
            $stateParameters = serialize($arStateParameters);
 
        $DB->Query(
            "UPDATE b_bp_workflow_state SET ".
            "   STATE_PARAMETERS = ".($stateParameters <> '' ? "'".$DB->ForSql($stateParameters)."'" : "NULL").", ".
            "   MODIFIED = ".$DB->CurrentTimeFunction()." ".
            "WHERE ID = '".$DB->ForSql($workflowId)."' "
        );
    }
 
    public function addStateParameter($workflowId, $arStateParameter)
    {
        $workflowId = trim($workflowId);
        if (empty($workflowId))
        {
            throw new Exception('workflowId');
        }
 
        $state = WorkflowStateTable::getByPrimary($workflowId, ['select' => ['STATE_PARAMETERS']])->fetch();
        if ($state)
        {
            $stateParameters = [];
            if (!empty($state['STATE_PARAMETERS']))
            {
                $stateParameters = unserialize($state['STATE_PARAMETERS'], ['allowed_classes' => false]);
            }
 
            $stateParameters[] = $arStateParameter;
 
            WorkflowStateTable::update($workflowId, ['STATE_PARAMETERS' => serialize($stateParameters)]);
        }
    }
 
    public function deleteStateParameter($workflowId, $name)
    {
        $workflowId = trim($workflowId);
        if (empty($workflowId))
        {
            throw new Exception('workflowId');
        }
 
        $state = WorkflowStateTable::getByPrimary($workflowId, ['select' => ['STATE_PARAMETERS']])->fetch();
        if ($state)
        {
            $stateParameters = [];
            if (!empty($state['STATE_PARAMETERS']))
            {
                $stateParameters = unserialize($state['STATE_PARAMETERS'], ['allowed_classes' => false]);
            }
 
            $newStateParameters = [];
            foreach ($stateParameters as $parameter)
            {
                if ($parameter['NAME'] !== $name)
                {
                    $newStateParameters[] = $parameter;
                }
            }
 
            WorkflowStateTable::update(
                $workflowId,
                ['STATE_PARAMETERS' => $newStateParameters ? serialize($newStateParameters) : null]
            );
        }
    }
 
    public static function getRunningCounters($userId)
    {
        global $DB;
 
        $counters = array('*' => 0);
        $cache = \Bitrix\Main\Application::getInstance()->getManagedCache();
        $cacheTag = self::COUNTERS_CACHE_TAG_PREFIX.$userId;
        if ($cache->read(3600*24*7, $cacheTag))
        {
            $counters = (array) $cache->get($cacheTag);
        }
        else
        {
            $query =
                "SELECT WI.MODULE_ID AS MODULE_ID, WI.ENTITY AS ENTITY, COUNT('x') AS CNT ".
                'FROM b_bp_workflow_instance WI '.
                'WHERE WI.STARTED_BY = '.(int)$userId.' '.
                'GROUP BY MODULE_ID, ENTITY';
 
            $iterator = $DB->Query($query);
            if ($iterator)
            {
                while ($row = $iterator->fetch())
                {
                    $cnt = (int)$row['CNT'];
                    $counters[$row['MODULE_ID']][$row['ENTITY']] = $cnt;
                    if (!isset($counters[$row['MODULE_ID']]['*']))
                        $counters[$row['MODULE_ID']]['*'] = 0;
                    $counters[$row['MODULE_ID']]['*'] += $cnt;
                    $counters['*'] += $cnt;
                }
                $cache->set($cacheTag, $counters);
            }
        }
        return $counters;
    }
 
    protected static function cleanRunningCountersCache($users)
    {
        $users = (array) $users;
        $users = array_unique($users);
        $cache = \Bitrix\Main\Application::getInstance()->getManagedCache();
        foreach ($users as $userId)
        {
            $cache->clean(self::COUNTERS_CACHE_TAG_PREFIX.$userId);
        }
    }
 
    private static function getStatesCacheKey(array $documentId, array|string $workflowId = ''): string
    {
        [$moduleId, $entity, $ids] = $documentId;
        $cacheKey = "$moduleId@$entity@";
 
        foreach ((array)$ids as $id)
        {
            $cacheKey .= "$id@";
        }
 
        if (is_array($workflowId))
        {
            $cacheKey .= implode('@', $workflowId);
        }
        else
        {
            $cacheKey .= $workflowId;
        }
 
        return $cacheKey;
    }
 
    private static function clearStatesCache(): void
    {
        static::$statesCache = [];
    }
 
    private function fillWorkflowDurationStat(array $workflowStateInfo, int $status)
    {
        $dateFormat = 'Y-m-d H:i:s';
 
        if ($status === CBPWorkflowStatus::Completed && Main\Type\DateTime::isCorrect($workflowStateInfo['STARTED'], $dateFormat))
        {
            $templateId = (int)$workflowStateInfo['WORKFLOW_TEMPLATE_ID'];
            $startedDate = new Main\Type\DateTime($workflowStateInfo['STARTED'], $dateFormat);
 
            WorkflowDurationStatTable::add([
                'WORKFLOW_ID' => (string)$workflowStateInfo['ID'],
                'TEMPLATE_ID' => $templateId,
                'DURATION' => (new Main\Type\DateTime())->getTimestamp() - $startedDate->getTimestamp(),
            ]);
        }
    }
}