workflowusercounters.php

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

<?php
 
namespace Bitrix\Bizproc\Workflow;
 
class WorkflowUserCounters
{
    private const TASK_COUNTER_CODE = 'bp_tasks';
    private const COMMENT_COUNTER_CODE = 'bp_wf_comments';
    private const WORKFLOW_COUNTER_CODE = 'bp_workflow';
    private readonly int $userId;
    private readonly string $siteId;
    private static array $isNeedSyncWorkflow = [];
 
    public function __construct(int $userId)
    {
        $this->userId = max($userId, 0);
        $this->siteId = '**';
 
        if (!isset(self::$isNeedSyncWorkflow[$this->userId]))
        {
            [
                'task' => $task,
                'comment' => $comment,
                'workflow' => $workflow,
            ] = $this->getCounters();
 
            $newWorkflow = ($task ?: 0) + ($comment ?: 0);
 
            self::$isNeedSyncWorkflow[$this->userId] = $workflow !== $newWorkflow;
        }
    }
 
    public function incrementTask(int $increment = 1): void
    {
        if ($increment <= 0)
        {
            return;
        }
 
        $this->syncWorkflowIfNeed();
        $this->increment(self::TASK_COUNTER_CODE, $increment);
        $this->increment(self::WORKFLOW_COUNTER_CODE, $increment);
    }
 
    public function decrementTask(int $decrement = 1): void
    {
        if ($decrement <= 0)
        {
            return;
        }
 
        $this->syncWorkflowIfNeed();
        $this->decrement(self::TASK_COUNTER_CODE, $decrement);
        $this->decrement(self::WORKFLOW_COUNTER_CODE, $decrement);
    }
 
    public function incrementComment(int $increment = 1): void
    {
        if ($increment <= 0)
        {
            return;
        }
 
        $this->syncWorkflowIfNeed();
        $this->increment(self::COMMENT_COUNTER_CODE, $increment);
        $this->increment(self::WORKFLOW_COUNTER_CODE, $increment);
    }
 
    public function decrementComment(int $decrement = 1): void
    {
        if ($decrement <= 0)
        {
            return;
        }
 
        $this->syncWorkflowIfNeed();
        $this->decrement(self::COMMENT_COUNTER_CODE, $decrement);
        $this->decrement(self::WORKFLOW_COUNTER_CODE, $decrement);
    }
 
    public function setTask(int $value = 0): void
    {
        if ($value < 0)
        {
            return;
        }
 
        $task = $this->get(self::TASK_COUNTER_CODE);
        if ($task !== $value)
        {
            $this->set(self::TASK_COUNTER_CODE, $value);
        }
 
        $this->syncWorkflow();
    }
 
    public function setComment(int $value = 0): void
    {
        if ($value < 0)
        {
            return;
        }
 
        $comment = $this->get(self::COMMENT_COUNTER_CODE);
        if ($comment !== $value)
        {
            $this->set(self::COMMENT_COUNTER_CODE, $value);
        }
 
        $this->syncWorkflow();
    }
 
    private function syncWorkflowIfNeed(): void
    {
        if (self::$isNeedSyncWorkflow[$this->userId])
        {
            $this->syncWorkflow();
            self::$isNeedSyncWorkflow[$this->userId] = false;
        }
    }
 
    private function syncWorkflow(): void
    {
        [
            'task' => $task,
            'comment' => $comment,
            'workflow' => $workflow,
        ] = $this->getCounters();
 
        $newWorkflow = ($task ?: 0) + ($comment ?: 0);
        if ($newWorkflow !== $workflow)
        {
            $this->set(self::WORKFLOW_COUNTER_CODE, $newWorkflow);
        }
    }
 
    private function getCounters(): array
    {
        $task = $this->get(self::TASK_COUNTER_CODE);
        $comment = $this->get(self::COMMENT_COUNTER_CODE);
        $workflow = $this->get(self::WORKFLOW_COUNTER_CODE);
 
        return [
            'task' => $task,
            'comment' => $comment,
            'workflow' => $workflow
        ];
    }
 
    private function increment(string $code, int $increment): void
    {
        \CUserCounter::Increment($this->userId, $code, $this->siteId, true, $increment);
    }
 
    private function decrement(string $code, int $decrement): void
    {
        \CUserCounter::Decrement($this->userId, $code, $this->siteId, true, $decrement);
    }
 
    private function set(string $code, int $value): void
    {
        \CUserCounter::Set($this->userId, $code, $value, $this->siteId);
    }
 
    private function get(string $code): false|int
    {
        return \CUserCounter::GetValue($this->userId, $code, $this->siteId);
    }
}