taskusertable.php

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

<?php
 
namespace Bitrix\Bizproc\Workflow\Task;
 
use Bitrix\Main\ArgumentException;
use Bitrix\Main\DB\SqlQueryException;
use Bitrix\Main\Entity\DataManager;
use Bitrix\Main\Entity\DatetimeField;
use Bitrix\Main\Entity\IntegerField;
use Bitrix\Main\NotImplementedException;
use Bitrix\Main\ORM\Data\UpdateResult;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\SystemException;
use Bitrix\Main\Type\DateTime;

class TaskUserTable extends DataManager
{
    public static function getTableName()
    {
        return 'b_bp_task_user';
    }
 
    public static function getMap()
    {
        return [
            (new IntegerField('ID'))
                ->configurePrimary()
                ->configureAutocomplete()
            ,
            (new IntegerField('USER_ID'))
                ->configureNullable(false)
            ,
            (new IntegerField('TASK_ID'))
                ->configureNullable(false)
            ,
            (new IntegerField('STATUS'))
                ->configureNullable(false)
                ->configureDefaultValue(0)
            ,
            (new DatetimeField('DATE_UPDATE'))
                ->configureNullable()
            ,
            (new IntegerField('ORIGINAL_USER_ID'))
                ->configureNullable(false)
                ->configureDefaultValue(0)
            ,
            new \Bitrix\Main\ORM\Fields\Relations\Reference(
                'USER_TASKS',
                TaskTable::class,
                Join::on('this.TASK_ID', 'ref.ID')
            ),
            (new \Bitrix\Main\ORM\Fields\Relations\Reference(
                'USER_TASKS_SEARCH_CONTENT',
                TaskSearchContentTable::class,
                Join::on('this.TASK_ID', 'ref.TASK_ID')
            ))
                ->configureJoinType(Join::TYPE_INNER)
            ,
        ];
    }

    public static function add(array $data)
    {
        throw new NotImplementedException('Use CBPTaskService class.');
    }

    public static function delete($primary)
    {
        throw new NotImplementedException('Use CBPTaskService class.');
    }

    public static function updateStatus(int $taskId, array $userIds, int $status = \CBPTaskUserStatus::Ok): ?UpdateResult
    {
        $ids = static::getPrimariesByUniqueKey($taskId, $userIds);
        if (!$ids)
        {
            return null;
        }
 
        $update = ['STATUS' => $status, 'DATE_UPDATE' => new DateTime()];
 
        if (count($ids) > 1)
        {
            return static::updateMulti($ids, $update);
        }
 
        return static::update($ids[0], $update);
    }

    public static function delegateTask(int $taskId, int $fromUserId, int $toUserId): ?UpdateResult
    {
        $ids = static::getPrimariesByUniqueKey($taskId, [$fromUserId]);
        if (!$ids)
        {
            return null;
        }
 
        $originalUserId = static::getOriginalTaskUserId($taskId, $fromUserId) ?? 0;
        $update = ['USER_ID' => $toUserId];
        if ($originalUserId <= 0)
        {
            $update['ORIGINAL_USER_ID'] = $fromUserId;
        }
 
        return static::update($ids[0], $update);
    }
 
    public static function getOriginalTaskUserId(int $taskId, int $userId): ?int
    {
        $row =
            static::query()
                ->setSelect(['ORIGINAL_USER_ID'])
                ->where('TASK_ID', $taskId)
                ->where('USER_ID', $userId)
                ->exec()
                ->fetch()
        ;
        if ($row)
        {
            return (int)$row['ORIGINAL_USER_ID'];
        }
 
        return null;
    }
 
    protected static function getPrimariesByUniqueKey(int $taskId, array $userIds): array
    {
        $query =
            static::query()
                ->setSelect(['ID'])
                ->where('TASK_ID', $taskId)
        ;
        if (count($userIds) > 1)
        {
            $query->whereIn('USER_ID', $userIds);
        }
        else
        {
            $query->where('USER_ID', $userIds[0] ?? 0);
        }
 
        return array_column($query->exec()->fetchAll(), 'ID');
    }
}