mailboxdirectory.php

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

<?php
 
namespace Bitrix\Mail;
 
use Bitrix\Mail\Helper\Mailbox;
use Bitrix\Mail\Internals\MailboxDirectoryTable;
use Bitrix\Main\Entity\ExpressionField;
use Bitrix\Main\Entity\Query;
use Bitrix\Main\Result;
 
class MailboxDirectory
{
    public static function fetchAllDirsTypes($mailboxId)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                'LOGIC'       => 'AND',
                '=MAILBOX_ID' => $mailboxId,
                [
                    'LOGIC'       => 'OR',
                    '=IS_OUTCOME' => MailboxDirectoryTable::ACTIVE,
                    '=IS_TRASH'   => MailboxDirectoryTable::ACTIVE,
                    '=IS_SPAM'    => MailboxDirectoryTable::ACTIVE,
                ]
            ],
            'select' => ['*'],
            'order'  => ['LEVEL' => 'ASC']
        ])->fetchCollection();
    }
 
    public static function fetchOneLevelByParentId($mailboxId, $id, $level)
    {
        $query = MailboxDirectoryTable::getList([
            'filter' => [
                'LOGIC'       => 'AND',
                '=MAILBOX_ID' => $mailboxId,
                '=PARENT_ID'  => $id,
                '=LEVEL'      => $level,
            ],
            'select' => ['*']
        ]);
 
        $result = [];
 
        while ($row = $query->fetchObject())
        {
            $result[$row->getPath()] = $row;
        }
 
        return $result;
    }
 
    public static function fetchAllLevelByParentId($mailboxId, $path, $level)
    {
        $query = MailboxDirectoryTable::getList([
            'filter' => [
                'LOGIC'       => 'AND',
                '=MAILBOX_ID' => $mailboxId,
                '%=PATH'      => $path,
                '>=LEVEL'     => $level,
            ],
            'select' => ['*'],
            'order'  => ['LEVEL' => 'ASC']
        ]);
 
        $result = [];
 
        while ($row = $query->fetchObject())
        {
            $result[$row->getPath()] = $row;
        }
 
        return $result;
    }
 
    public static function fetchOneByMailboxIdAndHash($mailboxId, $hash)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=MAILBOX_ID' => $mailboxId,
                '=DIR_MD5'    => $hash
            ]
        ])->fetchObject();
    }
 
    public static function fetchOneOutcome($mailboxId)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=MAILBOX_ID' => $mailboxId,
                '=IS_OUTCOME' => MailboxDirectoryTable::ACTIVE
            ]
        ])->fetchObject();
    }
 
    public static function fetchTrashAndSpamHash($mailboxId)
    {
        $query = MailboxDirectoryTable::getList([
            'filter' => [
                'LOGIC'       => 'AND',
                '=MAILBOX_ID' => $mailboxId,
                [
                    'LOGIC'     => 'OR',
                    '=IS_TRASH' => MailboxDirectoryTable::ACTIVE,
                    '=IS_SPAM'  => MailboxDirectoryTable::ACTIVE,
                ]
            ]
        ]);
 
        $result = [];
 
        while ($row = $query->fetch())
        {
            $result[] = $row['DIR_MD5'];
        }
 
        return $result;
    }
 
    public static function fetchOneById($id)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=ID' => $id
            ]
        ])->fetchObject();
    }
 
    public static function fetchOneByHash($mailboxId, $hash)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=MAILBOX_ID' => $mailboxId,
                '=DIR_MD5'    => $hash
            ]
        ])->fetchObject();
    }
 
    public static function updateSync($id, $val)
    {
        return MailboxDirectoryTable::update(
            $id,
            [
                'IS_SYNC' => $val
            ]
        );
    }
 
    public static function resetDirsTypes($mailboxId, $type)
    {
        $entity = MailboxDirectoryTable::getEntity();
        $connection = $entity->getConnection();
 
        $query = sprintf(
            'UPDATE %s SET %s WHERE %s',
            $connection->getSqlHelper()->quote($entity->getDbTableName()),
            $connection->getSqlHelper()->prepareUpdate($entity->getDbTableName(), [
                $type => MailboxDirectoryTable::INACTIVE,
            ])[0],
            Query::buildFilterSql(
                $entity,
                [
                    'MAILBOX_ID' => $mailboxId,
                    $type        => MailboxDirectoryTable::ACTIVE,
                ]
            )
        );
 
        return $connection->query($query);
    }
 
    public static function update($id, $data)
    {
        return MailboxDirectoryTable::update($id, $data);
    }
 
    public static function add(array $data)
    {
        return MailboxDirectoryTable::add($data);
    }
 
    public static function addMulti($rows, $ignoreEvents = false)
    {
        return MailboxDirectoryTable::addMulti($rows, $ignoreEvents);
    }
 
    public static function deleteList(array $filter)
    {
        $entity = MailboxDirectoryTable::getEntity();
        $connection = $entity->getConnection();
 
        return $connection->query(sprintf(
            'DELETE FROM %s WHERE %s',
            $connection->getSqlHelper()->quote($entity->getDbTableName()),
            Query::buildFilterSql($entity, $filter)
        ));
    }
 
    public static function updateSyncDirs(array $values, $val, $mailboxId)
    {
        $entity = MailboxDirectoryTable::getEntity();
        $connection = $entity->getConnection();
 
        $totalValues = count($values);
        $batchSize = 100;
        $offset = 0;
 
        while ($offset < $totalValues)
        {
            $batchValues = array_slice($values, $offset, $batchSize);
            $offset += $batchSize;
 
            $result = $connection->query(sprintf(
                "UPDATE %s SET %s WHERE %s",
                $connection->getSqlHelper()->quote($entity->getDbTableName()),
                $connection->getSqlHelper()->prepareUpdate($entity->getDbTableName(), [
                    'IS_SYNC' => $val,
                ])[0],
                Query::buildFilterSql(
                    $entity,
                    [
                        '=MAILBOX_ID' => $mailboxId,
                        '@DIR_MD5'    => $batchValues,
                        'IS_DISABLED' => MailboxDirectoryTable::INACTIVE,
                    ]
                )
            ));
        }
 
        return $result ?? new Result();
    }
 
    public static function fetchAll(int $mailboxId)
    {
        static $mailboxDirs = [];
 
        if (!isset($mailboxDirs[$mailboxId]))
        {
            $query = MailboxDirectoryTable::getList([
                'filter' => [
                    '=MAILBOX_ID' => $mailboxId
                ],
                'select' => ['*'],
                /*
                    When assembling directories, we look for their parents.
                    Sorting ensures that for a directories that parents are processed first,
                    and for children, matching parents are always found from those processed.
                 */
                'order'  => ['LEVEL' => 'ASC']
            ]);
 
            $result = [];
 
            while ($row = $query->fetchObject())
            {
                $result[$row->getPath()] = $row;
            }
 
            $mailboxDirs[$mailboxId] = $result;
        }
 
        return $mailboxDirs[$mailboxId];
    }
 
    public static function fetchAllSyncDirs($mailboxId)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=MAILBOX_ID'  => $mailboxId,
                '=IS_SYNC'     => MailboxDirectoryTable::ACTIVE,
                '=IS_DISABLED' => MailboxDirectoryTable::INACTIVE
            ],
            'select' => ['*'],
            'order'  => ['LEVEL' => 'ASC']
        ])->fetchCollection();
    }
 
    public static function fetchAllDisabledDirs($mailboxId)
    {
        return MailboxDirectoryTable::getList([
            'filter' => [
                '=MAILBOX_ID'  => $mailboxId,
                '=IS_DISABLED' => MailboxDirectoryTable::ACTIVE
            ],
            'select' => ['*'],
            'order'  => ['ID' => 'ASC']
        ])->fetchCollection();
    }
 
    public static function countMessagesSyncDirs($mailboxId)
    {
        $counter = MailboxDirectoryTable::getList([
            'filter'  => [
                '=MAILBOX_ID'  => $mailboxId,
                '=IS_SYNC'     => MailboxDirectoryTable::ACTIVE,
                '=IS_DISABLED' => MailboxDirectoryTable::INACTIVE
            ],
            'select'  => ['CNT'],
            'runtime' => [
                new ExpressionField('CNT', 'SUM(%s)', 'MESSAGE_COUNT'),
            ]
        ])->fetch();
 
        return (int)$counter['CNT'];
    }
 
    public static function getMinSyncTime($mailboxId)
    {
        $res = MailboxDirectoryTable::getList([
            'filter'  => [
                '=MAILBOX_ID' => $mailboxId,
                '=IS_SYNC'    => MailboxDirectoryTable::ACTIVE,
            ],
            'select'  => ['MIN_SYNC_TIME'],
            'runtime' => [
                new ExpressionField('MIN_SYNC_TIME', 'MIN(COALESCE(%s, 0))', 'SYNC_TIME'),
            ]
        ])->fetch();
 
        return (int)$res['MIN_SYNC_TIME'];
    }
 
    public static function countSyncDirs($mailboxId)
    {
        $counter = MailboxDirectoryTable::getList([
            'filter'  => [
                '=MAILBOX_ID'  => $mailboxId,
                '=IS_SYNC'     => MailboxDirectoryTable::ACTIVE,
                '=IS_DISABLED' => MailboxDirectoryTable::INACTIVE
            ],
            'select'  => ['CNT'],
            'runtime' => [
                new ExpressionField('CNT', 'COUNT(*)'),
            ]
        ])->fetch();
 
        return (int)$counter['CNT'];
    }
 
    public static function updateMessageCount($id, $val)
    {
        return MailboxDirectoryTable::update(
            $id,
            [
                'MESSAGE_COUNT' => $val
            ]
        );
    }
 
    public static function updateFlags($id, $flags)
    {
        return MailboxDirectoryTable::update(
            $id,
            [
                'FLAGS' => $flags
            ]
        );
    }
 
    public static function updateSyncTime($id, $val)
    {
        return MailboxDirectoryTable::update(
            $id,
            [
                'SYNC_TIME' => $val
            ]
        );
    }
 
    public static function setSyncLock(int $id, int $time)
    {
        $entity = MailboxDirectoryTable::getEntity();
        $connection = $entity->getConnection();
 
        $query = sprintf(
            "UPDATE %s SET %s WHERE %s",
            $connection->getSqlHelper()->quote($entity->getDbTableName()),
            $connection->getSqlHelper()->prepareUpdate($entity->getDbTableName(), [
                'SYNC_LOCK' => $time,
            ])[0],
            Query::buildFilterSql(
                $entity,
                [
                    '=ID' => $id,
                    [
                        'LOGIC'      => 'OR',
                        '=SYNC_LOCK' => 'IS NULL',
                        '<SYNC_LOCK' => time() - Mailbox::getTimeout(),
                    ]
                ]
            )
        );
 
        $connection->query($query);
        $count = $connection->getAffectedRowsCount();
 
        return $count;
    }
}