filesave.php

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

<?php
namespace Bitrix\Clouds;
 
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Data\DataManager;
use Bitrix\Main\ORM\Fields;

 
class FileSaveTable extends DataManager
{
    private static $files = [];

    public static function getTableName()
    {
        return 'b_clouds_file_save';
    }

    public static function getMap()
    {
        return [
            new Fields\IntegerField(
                'ID',
                [
                    'primary' => true,
                    'autocomplete' => true,
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_ID_FIELD'),
                ]
            ),
            new Fields\DatetimeField(
                'TIMESTAMP_X',
                [
                    'required' => true,
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_TIMESTAMP_X_FIELD'),
                ]
            ),
            new Fields\IntegerField(
                'BUCKET_ID',
                [
                    'required' => true,
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_BUCKET_ID_FIELD'),
                ]
            ),
            new Fields\StringField(
                'SUBDIR',
                [
                    'validation' => [__CLASS__, 'validateSubdir'],
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_SUBDIR_FIELD'),
                ]
            ),
            new Fields\StringField(
                'FILE_NAME',
                [
                    'required' => true,
                    'validation' => [__CLASS__, 'validateFileName'],
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_FILE_NAME_FIELD'),
                ]
            ),
            new Fields\StringField(
                'EXTERNAL_ID',
                [
                    'validation' => [__CLASS__, 'validateExternalId'],
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_EXTERNAL_ID_FIELD'),
                ]
            ),
            new Fields\IntegerField(
                'FILE_SIZE',
                [
                    'title' => Loc::getMessage('FILE_SAVE_ENTITY_FILE_SIZE_FIELD'),
                    'size' => 8,
                ]
            ),
            new Fields\Relations\Reference(
                'BUCKET',
                '\Bitrix\Clouds\CloudsFileBucket',
                ['=this.BUCKET_ID' => 'ref.ID'],
                ['join_type' => 'LEFT']
            ),
        ];
    }

    public static function validateSubdir(): array
    {
        return [
            new Fields\Validators\LengthValidator(null, 255),
        ];
    }

    public static function validateFileName(): array
    {
        return [
            new Fields\Validators\LengthValidator(null, 255),
        ];
    }

    public static function validateExternalId(): array
    {
        return [
            new Fields\Validators\LengthValidator(null, 50),
        ];
    }

    public static function startFileOperation($bucketId, $subDir, $fileName, $externalId)
    {
        $key = $bucketId . '|' . $subDir . '|' . $fileName;
        $entity = static::getEntity();
        $connection = $entity->getConnection();
        if ($connection->isTableExists($entity->getDBTableName()))
        {
            $fileSave = \Bitrix\Clouds\FileSaveTable::createObject();
            $fileSave->setTimestampX(new \Bitrix\Main\Type\DateTime());
            $fileSave->setBucketId($bucketId);
            $fileSave->setSubdir($subDir);
            $fileSave->setFileName($fileName);
            $fileSave->setExternalId($externalId);
            $fileSave->setFileSize(-1);
            $saveResult = $fileSave->save();
            if ($saveResult->isSuccess())
            {
                self::$files[$key] = $fileSave;
            }
        }
    }

    public static function setFileSize($bucketId, $subDir, $fileName, $fileSize)
    {
        $key = $bucketId . '|' . $subDir . '|' . $fileName;
        if (isset(self::$files[$key]))
        {
            $fileSave = self::$files[$key];
            $fileSave->setFileSize($fileSize);
            $fileSave->save();
        }
    }

    public static function endFileOperation($bucketId, $subDir, $fileName)
    {
        $key = $bucketId . '|' . $subDir . '|' . $fileName;
        if (isset(self::$files[$key]))
        {
            $fileSave = self::$files[$key];
            $fileSave->delete();
            unset(self::$files[$key]);
        }
    }
}