.-.-.-.-.-

<?php

namespace Bitrix\Mail;

use Bitrix\Mail\Internals\MessageAccessTable;
use Bitrix\Main;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;

Loc::loadMessages(__FILE__);

class MessageUserType
{

const USER_TYPE_ID = 'mail_message';

public static function getUserTypeDescription()
	{
		return array(
			'USER_TYPE_ID'  => static::USER_TYPE_ID,
			'CLASS_NAME'    => __CLASS__,
			'DESCRIPTION'   => Loc::getMessage('MAIL_MESSAGE_USER_TYPE_NAME'),
			'BASE_TYPE'     => 'int',
			'VIEW_CALLBACK' => array(__CLASS__, 'getPublicView'),
			'EDIT_CALLBACK' => array(__CLASS__, 'getPublicEdit'),
			'onBeforeSave'  => array(__CLASS__, 'onBeforeSave'),
			'onDelete'      => array(__CLASS__, 'onDelete'),
		);
	}

public static function getDbColumnType($userField)
	{
		return 'INT';
	}

public static function getPublicView($userField, $params)
	{
		return static::getPublicHtml($userField, $params, 'view');
	}

public static function getPublicEdit($userField, $params)
	{
		return static::getPublicHtml($userField, $params, 'edit');
	}

protected static function getPublicHtml($userField, $params, $mode = 'view')
	{
		global $APPLICATION;

if (!in_array($mode, array('view', 'edit')))
		{
			$mode = 'view';
		}

ob_start();

foreach ((array) $userField['VALUE'] as $item)
		{
			$APPLICATION->includeComponent(
				'bitrix:mail.uf.message', '',
				array(
					'USER_FIELD' => $userField,
					'MESSAGE_ID' => (int) $item,
					'MODE' => $mode,
				),
				null,
				array('HIDE_ICONS' => 'Y')
			);
		}

return ob_get_clean();
	}

public static function onBeforeSaveAll($userField, $mailIds, $userId)
	{
		$previousMailsIds = (array) $userField['VALUE'];
		if ($previousMailsIds !== false)
		{
			$result = static::deleteList([
				'!@MESSAGE_ID' => $mailIds,
				'=ENTITY_UF_ID' => $userField['ID'],
				'=ENTITY_TYPE' => $userField['ENTITY_ID'],
				'=ENTITY_ID' => $userField['VALUE_ID'],
			]);
		}
		$newMailIdsToSave = array_diff($mailIds, $previousMailsIds);
		foreach ($newMailIdsToSave as $mailMessageId)
		{
			static::onBeforeSave($userField, $mailMessageId, $userId);
		}
	}

public static function onBeforeSave($userField, $mailMessageId, $userId)
	{
		$previousMailsIds = (array) $userField['VALUE'];
		if (!in_array($mailMessageId, $previousMailsIds))
		{
			$message = MailMessageTable::getList([
				'select' => [
					'ID', 'MAILBOX_ID',
				],
				'filter' => [
					'=ID' => $mailMessageId,
				],
			])->fetch();

if (MailboxTable::getUserMailbox($message['MAILBOX_ID'], $userId))
			{
				if ($userField['VALUE'] !== false && $userField['MULTIPLE'] === 'N')
				{
					$result = static::deleteList([
						'!=MESSAGE_ID' => $mailMessageId,
						'=ENTITY_UF_ID' => $userField['ID'],
						'=ENTITY_TYPE' => $userField['ENTITY_ID'],
						'=ENTITY_ID' => $userField['VALUE_ID'],
					]);
				}
				Internals\MessageAccessTable::add([
					'TOKEN' => md5(sprintf(
						'%u:%u:%u:%s:%s:%u',
						time(),
						$message['MAILBOX_ID'],
						$mailMessageId,
						$userField['ENTITY_ID'],
						$userField['ID'],
						$userField['VALUE_ID']
					)),
					'MAILBOX_ID' => $message['MAILBOX_ID'],
					'MESSAGE_ID' => $mailMessageId,
					'ENTITY_UF_ID' => $userField['ID'],
					'ENTITY_TYPE' => $userField['ENTITY_ID'],
					'ENTITY_ID' => $userField['VALUE_ID'],
					'SECRET' => bin2hex(Main\Security\Random::getBytes(16)),
					'OPTIONS' => [],
				]);
				static::sendEntityCreatedEvents($message, $userField);
			}
		}

return $mailMessageId;
	}

public static function onDelete($userField, $messageId)
	{
		$result = static::deleteList([
			'=MESSAGE_ID' => $messageId,
			'=ENTITY_UF_ID' => $userField['ID'],
			'=ENTITY_TYPE' => $userField['ENTITY_ID'],
			'=ENTITY_ID' => $userField['ENTITY_VALUE_ID'],
		]);
	}

private static function deleteList($filter)
	{
		$entity = Internals\MessageAccessTable::getEntity();
		$connection = $entity->getConnection();
		return $connection->query(sprintf(
			'DELETE FROM %s WHERE %s',
			$connection->getSqlHelper()->quote($entity->getDbTableName()),
			Main\Entity\Query::buildFilterSql(
				$entity,
				$filter
			)
		));
	}

private static function sendEntityCreatedEvents($message, $userField)
	{
		if (Main\Loader::includeModule('pull'))
		{
			$bindingEntityLink = '';

if ($userField['ENTITY_ID'] === MessageAccessTable::ENTITY_TYPE_CRM_ACTIVITY
				&& Loader::includeModule('crm'))
			{
				$bindingEntity = \Bitrix\Crm\ActivityTable::query()
					->addSelect('OWNER_TYPE_ID')
					->addSelect('OWNER_ID')
					->where('ID', $userField['VALUE_ID'])
					->exec()
					->fetch();

if ($bindingEntity)
				{
					$bindingEntityLink = \CCrmOwnerType::GetEntityShowPath($bindingEntity['OWNER_TYPE_ID'], $bindingEntity['OWNER_ID']);
				}
			}

if ($userField['ENTITY_ID'] === MessageAccessTable::ENTITY_TYPE_TASKS_TASK
				&& Loader::includeModule('tasks'))
			{
				$bindingEntity = \Bitrix\Tasks\Internals\TaskTable::getList([
					'select' => ['ID'],
					'filter' => [
						'=ID' => $userField['VALUE_ID'],
					],
					'limit' => 1,
				])->fetch();

if ($bindingEntity)
				{
					global $USER;
					$userPage = \Bitrix\Main\Config\Option::get('socialnetwork', 'user_page', '/company/personal/', SITE_ID);
					$bindingEntityLink = \CComponentEngine::makePathFromTemplate(
						\Bitrix\Main\Config\Option::get(
							'tasks',
							'paths_task_user_action',
							$userPage . 'user/#user_id#/tasks/task/#action#/#task_id#/',
							SITE_ID
						),
						[
							'user_id' => $USER->getId(),
							'action' => 'view',
							'task_id' => $bindingEntity['ID'],
						]
					);
				}
			}

if ($userField['ENTITY_ID'] === MessageAccessTable::ENTITY_TYPE_BLOG_POST
				&& Loader::includeModule('blog'))
			{
				$bindingEntity = \Bitrix\Blog\PostTable::getList([
					'select' => ['ID'],
					'filter' => [
						'=ID' => $userField['VALUE_ID'],
					],
					'limit' => 1,
				])->fetch();

if ($bindingEntity)
				{
					global $USER;
					$userPage = \Bitrix\Main\Config\Option::get('socialnetwork', 'user_page', '/company/personal/', SITE_ID);
					$bindingEntityLink = \CComponentEngine::makePathFromTemplate(
						$userPage . 'user/#user_id#/blog/#post_id#/',
						[
							'user_id' => $USER->getId(),
							'post_id' => $bindingEntity['ID'],
						]
					);
				}
			}

\CPullWatch::addToStack(
				'mail_mailbox_' . $message['MAILBOX_ID'],
				[
					'module_id' => 'mail',
					'command' => 'messageBindingCreated',
					'params' => [
						'messageId' => $message['ID'],
						'mailboxId' => $message['MAILBOX_ID'],
						'entityType' => $userField['ENTITY_ID'],
						'entityId' => $userField['VALUE_ID'],
						'bindingEntityLink' => $bindingEntityLink,
					],
				]
			);
		}
		$event = new Main\Event(
			'mail',
			'onBeforeUserFieldSave',
			[
				'mailbox_id' => $message['MAILBOX_ID'],
				'message_id' => $message['ID'],
				'entity_uf_id' => $userField['ID'],
				'entity_type' => $userField['ENTITY_ID'],
				'entity_id' => $userField['VALUE_ID'],
			]
		);
		$event->send();
	}
}

/var/www/axolotl/data/www/b24.axolotl.ru/./public_html/bitrix/modules/mail/lib/messageusertype.php