QueueTable.php

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

<?php
 
declare(strict_types=1);
 
namespace Bitrix\Socialnetwork\Collab\Onboarding\Internals\Model;
 
use Bitrix\Main\Entity\DataManager;
use Bitrix\Main\Entity\ReferenceField;
use Bitrix\Main\ORM\Data\Internal\DeleteByFilterTrait;
use Bitrix\Main\ORM\Fields\BooleanField;
use Bitrix\Main\ORM\Fields\DatetimeField;
use Bitrix\Main\ORM\Fields\IntegerField;
use Bitrix\Main\ORM\Fields\StringField;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\UserTable;

class QueueTable extends DataManager
{
    use DeleteByFilterTrait;
 
    public static function getTableName(): string
    {
        return 'b_sonet_onboarding_queue';
    }
 
    public static function getObjectClass(): string
    {
        return JobModel::class;
    }
 
    public static function getCollectionClass(): string
    {
        return JobCollectionModel::class;
    }
 
    public static function getMap(): array
    {
        return [
            (new IntegerField('ID'))
                ->configurePrimary()
                ->configureAutocomplete(),
 
            (new IntegerField('COLLAB_ID'))
                ->configureRequired(),
 
            (new IntegerField('USER_ID'))
                ->configureRequired(),
 
            (new StringField('TYPE'))
                ->configureRequired(),
 
            (new DatetimeField('CREATED_DATE'))
                ->configureDefaultValueNow(),
 
            (new DatetimeField('NEXT_EXECUTION'))
                ->configureRequired(),
 
            (new DatetimeField('PROCESSED_DATE'))
                ->configureNullable(),
 
            (new BooleanField('IS_PROCESSED'))
                ->configureValues(0, 1)
                ->configureDefaultValue(0),
 
            (new ReferenceField(
                'USER',
                UserTable::getEntity(),
                ['this.USER_ID', 'ref.ID']
            ))->configureJoinType(Join::TYPE_INNER),
        ];
    }
}