ResultTable.php

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

<?php
 
namespace Bitrix\Bizproc\Result\Entity;
 
use Bitrix\Main;
use Bitrix\Main\Entity;
use Bitrix\Main\ORM\Fields\ArrayField;
use Bitrix\Main\ORM\Fields\Validators\LengthValidator;
use Bitrix\Main\SystemException;

class ResultTable extends Main\ORM\Data\DataManager
{
    public static function getTableName(): string
    {
        return 'b_bp_workflow_result';
    }

    public static function getMap(): array
    {
        return [
            (new Entity\IntegerField('ID'))
                ->configurePrimary()
                ->configureAutocomplete(),
            (new Entity\StringField('WORKFLOW_ID'))
                ->addValidator(new LengthValidator(1, 32)),
            (new Entity\StringField('ACTIVITY'))
                ->addValidator(new LengthValidator(1, 128)),
            (new ArrayField('RESULT'))
                ->configureSerializationJson(),
            new Entity\DatetimeField('CREATED_DATE'),
            new Entity\IntegerField('PRIORITY'),
        ];
    }

    public static function upsert(array $data): void
    {
        $priority = (int)($data['PRIORITY'] ?? 0);
 
        $currentResult =
            self::query()
                ->setSelect(['ID', 'PRIORITY'])
                ->where('WORKFLOW_ID', $data['WORKFLOW_ID'])
                ->exec()
                ->fetchAll();
 
        if (empty($currentResult))
        {
            $data['CREATED_DATE'] = new Main\Type\DateTime();
            self::add($data);
        }
        else if (isset($currentResult[0]['PRIORITY']) && ($currentResult[0]['PRIORITY'] <= $priority))
        {
            self::update($currentResult[0]['ID'], $data);
        }
    }
 
    public static function deleteByWorkflowId(string $workflowId): void
    {
        $iterator = static::query()->setFilter(['=WORKFLOW_ID' => $workflowId])->exec();
 
        while ($result = $iterator->fetchObject())
        {
            $result->delete();
        }
    }
}