BaseTask.php

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

<?php
 
namespace Bitrix\Bizproc\Task;
 
use Bitrix\Bizproc\Error;
use Bitrix\Bizproc\Result;
use Bitrix\Bizproc\Task\Data\TaskData;
use Bitrix\Bizproc\Task\Dto\CompleteTaskDto;
use Bitrix\Bizproc\Task\Dto\DeleteTaskDto;
use Bitrix\Bizproc\Task\Dto\UpdateTaskDto;
use Bitrix\Main\Type\Collection;
 
abstract class BaseTask implements Task
{
    protected TaskData $task;
    protected int $userId;
    protected int $originalUserId;
 
    public function __construct(TaskData $task, int $userId)
    {
        $this->task = $task;
        $this->userId = max($userId, 0);
 
        $this->originalUserId = max(\CBPTaskService::getOriginalTaskUserId($task->id, $this->userId), 0);
    }
 
    public function getId(): int
    {
        return $this->task->id;
    }
 
    public static function add(Dto\AddTaskDto $task): ?Task
    {
        if (!$task->settings || empty(static::getAssociatedActivity()))
        {
            return null;
        }
 
        $taskData = [
            'WORKFLOW_ID' => $task->workflowId,
            'USERS' => $task->userIds,
            'ACTIVITY' => static::getAssociatedActivity(),
            'ACTIVITY_NAME' => $task->activityName,
            'NAME' => $task->settings->name,
            'DESCRIPTION' => $task->settings->description,
            'IS_INLINE' => $task->settings->isInline ? 'Y' : 'N',
            'DELEGATION_TYPE' => $task->settings->delegationType,
            'PARAMETERS' => array_merge(
                $task->settings->parameters,
                ['DOCUMENT_ID' => $task->complexDocumentId, 'WORKFLOW_ID' => $task->workflowId]
            ),
        ];
 
        $taskService = static::getTaskService();
        $taskId = $taskService::add($taskData);
        if (!$taskId)
        {
            return null;
        }
 
        $taskData['ID'] = $taskId;
 
        return new static(TaskData::createFromArray($taskData), 0);
    }
 
    public function update(UpdateTaskDto $updateData): Result
    {
        $fields = [];
 
        if ($updateData->users) // can not be empty. if empty then use delete
        {
            $users = $updateData->users;
            Collection::normalizeArrayValuesByInt($users, false);
            if ($users)
            {
                $fields['USERS'] = $users;
            }
        }
 
        if ($updateData->parameters !== null)
        {
            $fields['PARAMETERS'] = $updateData->parameters;
        }
 
        if ($updateData->status !== null && $updateData->status > \CBPTaskStatus::Running)
        {
            $fields['STATUS'] = $updateData->status;
        }
 
        if ($fields)
        {
            $taskService = static::getTaskService();
            $taskService::update($this->getId(), $fields);
 
            return Result::createOk();
        }
 
        return Result::createError(new Error('empty fields'));
    }
 
    public function delete(DeleteTaskDto $deleteData): Result
    {
        $taskService = static::getTaskService();
        $taskService::delete($this->getId());
 
        return Result::createOk();
    }
 
    public function complete(CompleteTaskDto $completeData): Result
    {
        if ($completeData->status <= \CBPTaskStatus::Running)
        {
            return Result::createError(new Error('not finish status'));
        }
 
        return $this->update(new UpdateTaskDto(status: \CBPTaskStatus::CompleteOk));
    }
 
    protected static function getTaskService(): \CBPTaskService
    {
        static $taskService;
        $taskService ??= \CBPRuntime::getRuntime()->getTaskService();
 
        return $taskService;
    }
}