helper.php

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

<?php
 
namespace Bitrix\Mail;
 
use Bitrix\Main;
use Bitrix\Mail\Helper\Message\MessageInternalDateHandler;
 
class Helper
{
 
    public static function syncAllDirsInMailboxForTheFirstSyncDayAgent()
    {
        $userMailboxes = \Bitrix\Mail\MailboxTable::getList([
            'select' => [
                'ID'
            ],
            'filter' => [
                '=ACTIVE' => 'Y',
                '=SERVER_TYPE' => 'imap',
            ],
        ])->fetchAll();
 
        if (empty($userMailboxes))
        {
            return '';
        }
 
        $numberOfUnSynchronizedMailboxes = count($userMailboxes);
 
        foreach ($userMailboxes as $mailbox)
        {
            $mailboxID = $mailbox['ID'];
            $mailboxHelper = Helper\Mailbox::createInstance($mailboxID, false);
            if (empty($mailboxHelper))
            {
                $numberOfUnSynchronizedMailboxes--;
                continue;
            }
 
            $keyRow = [
                'MAILBOX_ID' => $mailboxID,
                'ENTITY_TYPE' => 'MAILBOX',
                'ENTITY_ID' => $mailboxID,
                'PROPERTY_NAME' => 'SYNC_FIRST_DAY',
            ];
 
            $filter = [
                '=MAILBOX_ID' => $keyRow['MAILBOX_ID'],
                '=ENTITY_TYPE' => $keyRow['ENTITY_TYPE'],
                '=ENTITY_ID' => $keyRow['ENTITY_ID'],
                '=PROPERTY_NAME' => $keyRow['PROPERTY_NAME'],
            ];
 
            $startValue = 'started_for_id_'.$mailboxID;
 
            if(\Bitrix\Mail\Internals\MailEntityOptionsTable::getCount($filter))
            {
                if(Internals\MailEntityOptionsTable::getList([
                    'select' => [
                        'VALUE',
                    ],
                    'filter' => $filter,
                ])->fetchAll()[0]['VALUE'] !== 'completed')
                {
                    \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                        $keyRow,
                        ['VALUE' => $startValue]
                    );
 
                    $synchronizationSuccess = $mailboxHelper->syncFirstDay();
 
                    if($synchronizationSuccess)
                    {
                        \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                            $keyRow,
                            ['VALUE' => 'completed']
                        );
                        $numberOfUnSynchronizedMailboxes--;
                    }
                }
                else
                {
                    $numberOfUnSynchronizedMailboxes--;
                }
            }
            else
            {
                $fields = $keyRow;
                $fields['VALUE'] = $startValue;
                \Bitrix\Mail\Internals\MailEntityOptionsTable::add(
                    $fields
                );
                $synchronizationSuccess = $mailboxHelper->syncFirstDay();
 
                if($synchronizationSuccess)
                {
                    \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                        $keyRow,
                        ['VALUE' => 'completed']
                    );
                    $numberOfUnSynchronizedMailboxes--;
                }
            }
        }
 
        if($numberOfUnSynchronizedMailboxes === 0)
        {
            return '';
        }
        else
        {
            return 'Bitrix\Mail\Helper::syncAllDirsInMailboxForTheFirstSyncDayAgent();';
        }
    }
 
    public static function syncMailboxAgent($id)
    {
        $mailboxHelper = Helper\Mailbox::createInstance($id, false);
 
        if (empty($mailboxHelper))
        {
            return '';
        }
 
        $mailbox = $mailboxHelper->getMailbox();
 
        if ($mailbox['OPTIONS']['next_sync'] <= time())
        {
            $mailboxHelper->sync();
 
            $mailbox = $mailboxHelper->getMailbox();
        }
 
        global $pPERIOD;
 
        $pPERIOD = min($pPERIOD, max($mailbox['OPTIONS']['next_sync'] - time(), 60));
 
        return sprintf('Bitrix\Mail\Helper::syncMailboxAgent(%u);', $id);
    }
 
    public static function syncOutgoingAgent($id)
    {
        $mailboxHelper = Helper\Mailbox::createInstance($id, false);
 
        if ($mailboxHelper)
        {
            $mailboxHelper->syncOutgoing();
        }
 
        return '';
    }
 
    public static function markOldMessagesAgent()
    {
        $userMailboxes = \Bitrix\Mail\MailboxTable::getList([
            'select' => [
                'ID'
            ],
            'filter' => [
                '=ACTIVE' => 'Y',
                '=SERVER_TYPE' => 'imap',
            ],
        ])->fetchAll();
 
        if (empty($userMailboxes))
        {
            return '';
        }
 
        $numberOfUnSynchronizedMailboxes = count($userMailboxes);
 
        foreach ($userMailboxes as $mailbox)
        {
            $mailboxID = $mailbox['ID'];
            $mailboxHelper = Helper\Mailbox::createInstance($mailboxID, false);
            if (empty($mailboxHelper))
            {
                $numberOfUnSynchronizedMailboxes--;
                continue;
            }
 
            $keyRow = [
                'MAILBOX_ID' => $mailboxID,
                'ENTITY_TYPE' => 'MAILBOX',
                'ENTITY_ID' => $mailboxID,
                'PROPERTY_NAME' => 'SYNC_IS_OLD_STATUS',
            ];
 
            $filter = [
                '=MAILBOX_ID' => $keyRow['MAILBOX_ID'],
                '=ENTITY_TYPE' => $keyRow['ENTITY_TYPE'],
                '=ENTITY_ID' => $keyRow['ENTITY_ID'],
                '=PROPERTY_NAME' => $keyRow['PROPERTY_NAME'],
            ];
 
            $startValue = 'started_for_id_'.$mailboxID;
 
            if(\Bitrix\Mail\Internals\MailEntityOptionsTable::getCount($filter))
            {
                if(Internals\MailEntityOptionsTable::getList([
                        'select' => [
                            'VALUE',
                        ],
                        'filter' => $filter,
                    ])->fetchAll()[0]['VALUE'] !== 'completed')
                {
                    \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                        $keyRow,
                        ['VALUE' => $startValue]
                    );
 
                    $synchronizationSuccess = $mailboxHelper->resyncIsOldStatus();
 
                    if($synchronizationSuccess)
                    {
                        \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                            $keyRow,
                            ['VALUE' => 'completed']
                        );
                        $numberOfUnSynchronizedMailboxes--;
                    }
                }
                else
                {
                    $numberOfUnSynchronizedMailboxes--;
                }
            }
            else
            {
                $fields = $keyRow;
                $fields['VALUE'] = $startValue;
                \Bitrix\Mail\Internals\MailEntityOptionsTable::add(
                    $fields
                );
                $synchronizationSuccess = $mailboxHelper->resyncIsOldStatus();
 
                if($synchronizationSuccess)
                {
                    \Bitrix\Mail\Internals\MailEntityOptionsTable::update(
                        $keyRow,
                        ['VALUE' => 'completed']
                    );
                    $numberOfUnSynchronizedMailboxes--;
                }
            }
        }
 
        if($numberOfUnSynchronizedMailboxes === 0)
        {
            return '';
        }
        else
        {
            return 'Bitrix\Mail\Helper::markOldMessagesAgent();';
        }
    }
 
    public static function cleanupMailboxAgent($id)
    {
        $mailboxHelper = Helper\Mailbox::rawInstance($id, false);
 
        if (empty($mailboxHelper))
        {
            return '';
        }
 
        $mailboxHelper->setCheckpoint();
 
        MailMessageUidTable::deleteList(
            [
                '=MAILBOX_ID' => $id,
                '!=MESSAGE_ID' => 0,
                '=IS_OLD' => \Bitrix\Mail\MailMessageUidTable::REMOTE,
            ]
        );
 
        $stage1 = $mailboxHelper->dismissOldMessages();
        $stage2 = $mailboxHelper->dismissDeletedUidMessages();
        $stage3 = $mailboxHelper->cleanup();
 
        global $pPERIOD;
 
        $pPERIOD = min($pPERIOD, max($stage1 && $stage2 && $stage3 ? $pPERIOD : 600, 60));
 
        if ($pPERIOD === null)
        {
            $pPERIOD = 60;
        }
 
        return sprintf('Bitrix\Mail\Helper::cleanupMailboxAgent(%u);', $id);
    }

    public static function resortTreeAgent($id)
    {
        $mailboxHelper = Helper\Mailbox::createInstance($id, false);
 
        if ($mailboxHelper)
        {
            $mailboxHelper->resortTree();
        }
 
        return '';
    }
 
    public static function deleteMailboxAgent($id)
    {
        return \CMailbox::delete($id) ? '' : sprintf('Bitrix\Mail\Helper::deleteMailboxAgent(%u);', $id);
    }
 
    public static function resyncDomainUsersAgent()
    {
        $res = MailServicesTable::getList(array(
            'filter' => array(
                '=ACTIVE'       => 'Y',
                '@SERVICE_TYPE' => array('domain', 'crdomain'),
            )
        ));
        while ($item = $res->fetch())
        {
            if ($item['SERVICE_TYPE'] == 'domain')
            {
                $lockName = sprintf('domain_users_sync_lock_%u', $item['ID']);
                $syncLock = \Bitrix\Main\Config\Option::get('mail', $lockName, 0);
 
                if ($syncLock < time()-3600)
                {
                    \Bitrix\Main\Config\Option::set('mail', $lockName, time());
                    \CMailDomain2::getDomainUsers($item['TOKEN'], $item['SERVER'], $error, true);
                    \Bitrix\Main\Config\Option::set('mail', $lockName, 0);
                }
            }
            else if ($item['SERVICE_TYPE'] == 'crdomain')
            {
                \CControllerClient::executeEvent('OnMailControllerResyncMemberUsers', array('DOMAIN' => $item['SERVER']));
            }
        }
 
        return 'Bitrix\Mail\Helper::resyncDomainUsersAgent();';
    }
 
    public static function syncMailbox($id, &$error)
    {
        $mailboxHelper = Helper\Mailbox::createInstance($id, false);
 
        return empty($mailboxHelper) ? false : $mailboxHelper->sync();
    }
 
    public static function listImapDirs($mailbox, &$error = [], &$errors = null)
    {
        $error  = null;
        $errors = null;
 
        $client = static::createClient($mailbox);
 
        $list   = $client->listMailboxes('*', $error, true);
        $errors = $client->getErrors();
 
        if ($list === false)
            return false;
 
        $k = count($list);
        for ($i = 0; $i < $k; $i++)
        {
            $item = $list[$i];
 
            $list[$i] = array(
                'path' => $item['name'],
                'name' => $item['title'],
                'level' => $item['level'],
                'disabled' => (bool) preg_grep('/^ \x5c Noselect $/ix', $item['flags']),
                'income' => mb_strtolower($item['name']) == 'inbox',
                'outcome' => (bool) preg_grep('/^ \x5c Sent $/ix', $item['flags']),
            );
        }
 
        return $list;
    }
 
    public static function getImapUIDsForSpecificDay($mailboxID, $dirPath = 'inbox', $internalDate)
    {
        $error  = null;
        $errors = null;
 
        $mailbox = Helper\Mailbox::prepareMailbox([
            '=ID'=>$mailboxID,
            '=ACTIVE'=>'Y'
        ]);
 
        $client = static::createClient($mailbox);
 
        $result = $client->getUIDsForSpecificDay($dirPath, $internalDate);
 
        return $result;
    }
 
    public static function getLastDeletedOldMessageInternaldate($mailboxId,$dirPath,$filter = [])
    {
        $firstSyncUID = MailMessageUidTable::getList(
            [
                'select' => [
                    'INTERNALDATE'
                ],
                'filter' => array_merge(
                    [
                        '!=IS_OLD' => 'D',
                        '=MESSAGE_ID' => 0,
                        '=MAILBOX_ID' => $mailboxId,
                        '=DIR_MD5' => md5($dirPath),
                    ],
                    $filter
                ),
                'order' => [
                    'INTERNALDATE' => 'DESC',
                ],
                'limit' => 1,
            ]
        )->fetchAll();
 
        if(isset($firstSyncUID[0]['INTERNALDATE']))
        {
            return $firstSyncUID[0]['INTERNALDATE'];
        }
        else
        {
            return false;
        }
    }
 
    public static function getStartInternalDateForDir(
        $mailboxId,
        $dirPath,
    )
    {
        $startInternalDate =  MessageInternalDateHandler::getStartInternalDateForDir($mailboxId, $dirPath);
 
        return $startInternalDate ?? false;
    }
 
    public static function getImapUnseenSyncForDir($mailbox = null, $dirPath ,$mailboxID = null)
    {
        //for testing via mailbox id
        if(is_int($mailboxID) && is_null($mailbox))
        {
            $mailbox = Helper\Mailbox::prepareMailbox([
                '=ID'=>$mailboxID,
                '=ACTIVE'=>'Y'
            ]);
        }
 
        $startInternalDate = static::getStartInternalDateForDir($mailbox['ID'], $dirPath);
 
        if($startInternalDate)
        {
            $error = [];
            $errors = [];
            return static::getImapUnseen($mailbox, $dirPath,$error,$errors, $startInternalDate);
        }
        else
        {
            return 0;
        }
 
        return false;
    }
 
    public static function setMailboxUnseenCounter($mailboxId, $count): void
    {
        $keyRow = [
            'MAILBOX_ID' => $mailboxId,
            'ENTITY_TYPE' => 'MAILBOX',
            'ENTITY_ID' => $mailboxId
        ];
 
        $filter = [
            '=MAILBOX_ID' => $keyRow['MAILBOX_ID'],
            '=ENTITY_TYPE' => $keyRow['ENTITY_TYPE'],
            '=ENTITY_ID' => $keyRow['ENTITY_ID']
        ];
 
        if ($count < 0)
        {
            $count = 0;
        }
 
        $rowValue = ['VALUE' => $count];
 
        $row = Internals\MailCounterTable::getRow(
            [
                'filter' => $filter,
                'select' => ['VALUE'],
            ]
        );
 
        $counterHasChanged = false;
 
        if (!is_null($row))
        {
            if ((int)$row['VALUE'] !== $count)
            {
                Internals\MailCounterTable::update($keyRow, $rowValue);
                $counterHasChanged = true;
            }
        }
        else
        {
            Internals\MailCounterTable::add(array_merge($rowValue,$keyRow));
            $counterHasChanged = true;
        }
 
        if ($counterHasChanged)
        {
            \CPullWatch::addToStack(
                'mail_mailbox_' .$mailboxId,
                [
                    'module_id' => 'mail',
                    'params' => [
                        'mailboxId' => $mailboxId,
                    ],
                    'command' => 'counters_updated',
                ]
            );
            \Bitrix\Pull\Event::send();
        }
    }
 
    public static function updateMailboxUnseenCounter($mailboxId)
    {
        $count = Internals\MailCounterTable::getList([
            'filter' => [
                'ENTITY_TYPE' => 'DIR',
                'MAILBOX_ID' => $mailboxId,
            ],
            'runtime' => [
                new \Bitrix\Main\Entity\ExpressionField('COUNT', 'SUM(%s)', 'VALUE'),
            ],
            'select' => [
                'COUNT'
            ]
        ])->fetchAll();
 
        if(!is_null($count[0]["COUNT"]))
        {
            static::setMailboxUnseenCounter($mailboxId,(int)$count[0]["COUNT"]);
        }
    }
 
    public static function updateMailCounters($mailbox)
    {
        $mailboxId = $mailbox['ID'];
        $directoryHelper = new Helper\MailboxDirectoryHelper($mailboxId);
        $syncDirs = $directoryHelper->getSyncDirs();
        $totalCount = 0;
        $folderCountersForAdding = [];
 
        //Since we work with internalDate inside the method
        \CTimeZone::Disable();
 
        foreach ($syncDirs as $dir)
        {
            if($dir->isInvisibleToCounters())
            {
                continue;
            }
 
            $count = static::getImapUnseenSyncForDir($mailbox, $dir->getPath());
 
            if (is_int($count))
            {
                $folderCountersForAdding[$dir->getId()] = $count;
                $totalCount += $count;
            }
        }
 
        \CTimeZone::Enable();
 
        $currentFolderCounters = Internals\MailCounterTable::getList([
            'filter' => [
                '=MAILBOX_ID' => $mailboxId,
                '=ENTITY_TYPE' => 'DIR',
                '=ENTITY_ID' =>  array_keys($folderCountersForAdding)
            ],
            'select' => [
                'ENTITY_ID',
                'VALUE'
            ]
        ]);
 
        $folderCountersForUpdating = [];
 
        while ($folderCounter = $currentFolderCounters->fetch())
        {
            $folderId = (int)$folderCounter['ENTITY_ID'];
            $folderCount = (int)$folderCounter['VALUE'];
 
            if (isset($folderCountersForAdding[$folderId]))
            {
                if ($folderCountersForAdding[$folderId] !== $folderCount)
                {
                    $folderCountersForUpdating[$folderId] = $folderCountersForAdding[$folderId];
                }
 
                unset($folderCountersForAdding[$folderId]);
            }
        }
 
        foreach ($folderCountersForAdding as $id => $count)
        {
            if ($count <= 0)
            {
                continue;
            }
 
            Internals\MailCounterTable::add(
                [
                    'MAILBOX_ID' => $mailboxId,
                    'ENTITY_TYPE' => 'DIR',
                    'ENTITY_ID' => $id,
                    'VALUE' => $count,
                ]
            );
        }
 
        foreach ($folderCountersForUpdating as $id => $count)
        {
            Internals\MailCounterTable::update(
                [
                    'MAILBOX_ID' => $mailboxId,
                    'ENTITY_TYPE' => 'DIR',
                    'ENTITY_ID' => $id,
                ],
                [
                    'VALUE' => $count,
                ]
            );
        }
 
        return $totalCount;
    }
 
    public static function getImapUnseen($mailbox, $dirPath = 'inbox', &$error = [], &$errors = null, $startInternalDate = null)
    {
        $error  = null;
        $errors = null;
 
        $client = static::createClient($mailbox);
 
        $result = $client->getUnseen($dirPath, $error, $startInternalDate);
        $errors = $client->getErrors();
 
        return $result;
    }
 
    public static function addImapMessage($id, $data, &$error)
    {
        $error = null;
 
        $id = (int) (is_array($id) ? $id['ID'] : $id);
 
        $mailbox = MailboxTable::getList(array(
            'filter' => array('ID' => $id, 'ACTIVE' => 'Y'),
            'select' => array('*', 'LANG_CHARSET' => 'SITE.CULTURE.CHARSET')
        ))->fetch();
 
        if (empty($mailbox))
            return;
 
        if (!in_array($mailbox['SERVER_TYPE'], array('imap', 'controller', 'domain', 'crdomain')))
            return;
 
        if (in_array($mailbox['SERVER_TYPE'], array('controller', 'crdomain')))
        {
            // @TODO: request controller
            $result = \CMailDomain2::getImapData();
 
            $mailbox['SERVER']  = $result['server'];
            $mailbox['PORT']    = $result['port'];
            $mailbox['USE_TLS'] = $result['secure'];
        }
        elseif ($mailbox['SERVER_TYPE'] == 'domain')
        {
            $result = \CMailDomain2::getImapData();
 
            $mailbox['SERVER']  = $result['server'];
            $mailbox['PORT']    = $result['port'];
            $mailbox['USE_TLS'] = $result['secure'];
        }
 
        $client = static::createClient($mailbox, $mailbox['LANG_CHARSET'] ?: $mailbox['CHARSET']);
 
        $dir = MailboxDirectory::fetchOneOutcome($mailbox['ID']);
        $path = $dir ? $dir->getPath() : 'INBOX';
 
        return $client->addMessage($path, $data, $error);
    }
 
    public static function updateImapMessage($userId, $hash, $data, &$error)
    {
        $error = null;
 
        $res = MailMessageUidTable::getList(array(
            'select' => array(
                'ID', 'MAILBOX_ID', 'IS_SEEN',
                'MAILBOX_USER_ID' => 'MAILBOX.USER_ID',
                'MAILBOX_OPTIONS' => 'MAILBOX.OPTIONS',
            ),
            'filter' => array(
                '=HEADER_MD5'  => $hash,
                '==DELETE_TIME' => 0,
            ),
        ));
 
        while ($item = $res->fetch())
        {
            $isOwner = $item['MAILBOX_USER_ID'] == $userId;
            $isPublic = in_array('crm_public_bind', (array) $item['MAILBOX_OPTIONS']['flags']);
            $inQueue = in_array($userId, (array) $item['MAILBOX_OPTIONS']['crm_lead_resp']);
            if (!$isOwner && !$isPublic && !$inQueue)
            {
                continue;
            }
 
            if (in_array($item['IS_SEEN'], array('Y', 'S')) != $data['seen'])
            {
                MailMessageUidTable::update(
                    array(
                        'ID' => $item['ID'],
                        'MAILBOX_ID' => $item['MAILBOX_ID'],
                    ),
                    array(
                        'IS_SEEN' => $data['seen'] ? 'S' : 'U',
                    )
                );
            }
        }
    }
 
    private static function createClient($mailbox, $langCharset = null)
    {
        return new Imap(
            $mailbox['SERVER'], $mailbox['PORT'],
            $mailbox['USE_TLS'] == 'Y' || $mailbox['USE_TLS'] == 'S',
            $mailbox['USE_TLS'] == 'Y',
            $mailbox['LOGIN'], $mailbox['PASSWORD'],
            $langCharset ? $langCharset : LANG_CHARSET
        );
    }
}
 
class DummyMail extends Main\Mail\Mail
{
 
    public function initSettings()
    {
        parent::initSettings();
 
        $this->settingServerMsSmtp = false;
        $this->settingMailFillToEmail = false;
        $this->settingMailConvertMailHeader = true;
        $this->settingConvertNewLineUnixToWindows = true;
        $this->useBlacklist = false;
    }
 
    public static function getMailEol()
    {
        return "\r\n";
    }
 
    public function __toString()
    {
        return sprintf("%s\r\n\r\n%s", $this->getHeaders(), $this->getBody());
    }

    public static function overwriteMessageHeaders(Main\Mail\Mail $message, array $headers)
    {
        foreach ($headers as $name => $value)
        {
            $message->headers[$name] = $value;
        }
    }
 
}