createentity.php

<?php
 
namespace Bitrix\Socialnetwork\CommentAux;
 
use Bitrix\Main\Config\Option;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Web\Json;
use Bitrix\Forum\MessageTable;
use Bitrix\Main\ArgumentException;
 
Loc::loadMessages(__FILE__);
 
class CreateEntity extends Base
{
    public const TYPE = 'CREATEENTITY';
    public const POST_TEXT = 'commentAuxCreateEntity';
 
    public const SOURCE_TYPE_BLOG_POST = 'BLOG_POST';
    public const SOURCE_TYPE_TASK = 'TASK';
    public const SOURCE_TYPE_FORUM_TOPIC = 'FORUM_TOPIC';
    public const SOURCE_TYPE_CALENDAR_EVENT = 'CALENDAR_EVENT';
    public const SOURCE_TYPE_TIMEMAN_ENTRY = 'TIMEMAN_ENTRY';
    public const SOURCE_TYPE_TIMEMAN_REPORT = 'TIMEMAN_REPORT';
    public const SOURCE_TYPE_LOG_ENTRY = 'LOG_ENTRY';
    public const SOURCE_TYPE_PHOTO_ALBUM = 'PHOTO_ALBUM';
    public const SOURCE_TYPE_PHOTO_PHOTO = 'PHOTO_PHOTO';
    public const SOURCE_TYPE_WIKI = 'WIKI';
    public const SOURCE_TYPE_LISTS_NEW_ELEMENT = 'LISTS_NEW_ELEMENT';
    public const SOURCE_TYPE_INTRANET_NEW_USER = 'INTRANET_NEW_USER';
    public const SOURCE_TYPE_BITRIX24_NEW_USER = 'BITRIX24_NEW_USER';
 
    public const SOURCE_TYPE_BLOG_COMMENT = 'BLOG_COMMENT';
    public const SOURCE_TYPE_FORUM_POST = 'FORUM_POST';
    public const SOURCE_TYPE_LOG_COMMENT = 'LOG_COMMENT';
 
    public const ENTITY_TYPE_TASK = 'TASK';
    public const ENTITY_TYPE_BLOG_POST = 'BLOG_POST';
    public const ENTITY_TYPE_CALENDAR_EVENT = 'CALENDAR_EVENT';
 
    protected $postTypeList = [
        self::SOURCE_TYPE_BLOG_POST,
        self::SOURCE_TYPE_TASK,
        self::SOURCE_TYPE_FORUM_TOPIC,
        self::SOURCE_TYPE_CALENDAR_EVENT,
        self::SOURCE_TYPE_TIMEMAN_ENTRY,
        self::SOURCE_TYPE_TIMEMAN_REPORT,
        self::SOURCE_TYPE_LOG_ENTRY,
        self::SOURCE_TYPE_PHOTO_ALBUM,
        self::SOURCE_TYPE_PHOTO_PHOTO,
        self::SOURCE_TYPE_WIKI,
        self::SOURCE_TYPE_LISTS_NEW_ELEMENT,
        self::SOURCE_TYPE_INTRANET_NEW_USER,
        self::SOURCE_TYPE_BITRIX24_NEW_USER,
    ];
    protected $commentTypeList = [
        self::SOURCE_TYPE_BLOG_COMMENT,
        self::SOURCE_TYPE_FORUM_POST,
        self::SOURCE_TYPE_LOG_COMMENT,
    ];
 
    protected $entityTypeList = [
        self::ENTITY_TYPE_BLOG_POST,
        self::ENTITY_TYPE_TASK,
        self::ENTITY_TYPE_CALENDAR_EVENT,
    ];
 
    protected $postTypeListInited = false;
    protected $commentTypeListInited = false;
 
    protected static $blogPostClass = \CBlogPost::class;
    protected static $blogCommentClass = \CBlogComment::class;
 
    public function getPostTypeList(): array
    {
        if ($this->postTypeListInited === false)
        {
            $moduleEvent = new \Bitrix\Main\Event(
                'socialnetwork',
                'onCommentAuxGetPostTypeList',
                []
            );
            $moduleEvent->send();
 
            foreach ($moduleEvent->getResults() as $moduleEventResult)
            {
                if ($moduleEventResult->getType() === \Bitrix\Main\EventResult::SUCCESS)
                {
                    $moduleEventParams = $moduleEventResult->getParameters();
 
                    if (
                        is_array($moduleEventParams)
                        && !empty($moduleEventParams['typeList'])
                        && is_array($moduleEventParams['typeList'])
                    )
                    {
                        foreach ($moduleEventParams['typeList'] as $type)
                        {
                            $this->addPostTypeList($type);
                        }
                    }
                }
            }
 
            $this->postTypeListInited = true;
        }
 
        return $this->postTypeList;
    }
 
    public function getCommentTypeList(): array
    {
        if ($this->commentTypeListInited === false)
        {
            $moduleEvent = new \Bitrix\Main\Event(
                'socialnetwork',
                'onCommentAuxGetCommentTypeList',
                []
            );
            $moduleEvent->send();
 
            foreach ($moduleEvent->getResults() as $moduleEventResult)
            {
                if ($moduleEventResult->getType() === \Bitrix\Main\EventResult::SUCCESS)
                {
                    $moduleEventParams = $moduleEventResult->getParameters();
 
                    if (
                        is_array($moduleEventParams)
                        && !empty($moduleEventParams['typeList'])
                        && is_array($moduleEventParams['typeList'])
                    )
                    {
                        foreach($moduleEventParams['typeList'] as $type)
                        {
                            $this->addCommentTypeList($type);
                        }
                    }
                }
            }
 
            $this->commentTypeListInited = true;
        }
 
        return $this->commentTypeList;
    }
 
    public function addPostTypeList($type): void
    {
        $this->postTypeList[] = $type;
    }
 
    public function addCommentTypeList($type): void
    {
        $this->commentTypeList[] = $type;
    }
 
    public function getSourceTypeList(): array
    {
        return array_merge($this->getPostTypeList(), $this->getCommentTypeList());
    }
 
    public function getEntityTypeList(): array
    {
        return $this->entityTypeList;
    }
 
    public function getParamsFromFields($fields = []): array
    {
        $params = [];
 
        if (!empty($fields['SHARE_DEST']))
        {
            $params = $this->getSocNetData($fields['SHARE_DEST']);
        }
        elseif (
            isset($fields['RATING_TYPE_ID'], $fields['SOURCE_ID'])
            && (int)$fields['SOURCE_ID'] > 0
            && in_array($fields['RATING_TYPE_ID'], ['FORUM_POST', 'CRM_ENTITY_COMMENT' ])
            && Loader::includeModule('forum')
        )
        {
            $messageId = (int)$fields['SOURCE_ID'];
 
            $forumPostLivefeedProvider = new \Bitrix\Socialnetwork\Livefeed\ForumPost();
            $commentData = $forumPostLivefeedProvider->getAuxCommentCachedData($messageId);
 
            $serviceData = $this->getForumServiceData($commentData);
 
            if (
                !empty($commentData)
                && !empty($serviceData)
                && isset($commentData['SERVICE_TYPE'])
                && $commentData['SERVICE_TYPE'] === $this->getForumType()
            )
            {
                try
                {
                    $messageParams = Json::decode($serviceData);
                }
                catch (ArgumentException $e)
                {
                    $messageParams = [];
                }
 
                $params = $messageParams;
            }
            else
            {
                $res = MessageTable::getList([
                    'filter' => [
                        '=ID' => (int)$fields['SOURCE_ID']
                    ],
                    'select' => $this->getForumMessageFields(),
                ]);
 
                if ($forumMessageFields = $res->fetch())
                {
                    $serviceData = $this->getForumServiceData($forumMessageFields);
                    if (!empty($serviceData))
                    {
                        try
                        {
                            $messageParams = Json::decode($serviceData);
                        }
                        catch (ArgumentException $e)
                        {
                            $messageParams = [];
                        }
 
                        $params = $messageParams;
                    }
                }
            }
        }
 
        return $params;
    }
 
    public function getText(): string
    {
        static $userPage = null;
        static $parser = null;
 
        $result = '';
        $params = $this->params;
        $options = $this->options;
 
        $siteId = (!empty($options['siteId']) ? $options['siteId'] : SITE_ID);
 
        if (
            !isset($params['sourceType'], $params['sourceId'], $params['entityId'], $params['entityType'])
            || (int)$params['sourceId'] <= 0
            || (int)$params['entityId'] <= 0
            || !in_array($params['sourceType'], $this->getSourceTypeList(), true)
            || !in_array($params['entityType'], $this->getEntityTypeList(), true)
        )
        {
            return $result;
        }
 
        if ($provider = $this->getLivefeedProvider())
        {
            $options['suffix'] = $provider->getSuffix($options['suffix'] ?? null);
            $this->setOptions($options);
        }
 
        if ($userPage === null)
        {
            $userPage = Option::get(
                    'socialnetwork',
                    'user_page',
                    SITE_DIR.'company/personal/',
                    $siteId
                ).'user/#user_id#/';
        }
 
        if (in_array($params['sourceType'], $this->getCommentTypeList(), true))
        {
            $sourceData = $this->getSourceCommentData([
                'userPage' => $userPage,
            ]);
 
            $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_COMMENT_' . $params['sourceType'] . (!empty($sourceData['suffix']) ? '_' . $sourceData['suffix'] : ''), [
                '#ENTITY_CREATED#' => $this->getEntityCreatedMessage(),
                '#ENTITY_NAME#' => $this->getEntityName(),
                '#A_BEGIN#' => (!empty($sourceData['path']) ? '[URL=' . $sourceData['path'] . ']' : ''),
                '#A_END#' => (!empty($sourceData['path']) ? '[/URL]' : '')
            ]);
        }
        elseif (in_array($params['sourceType'], $this->getPostTypeList(), true))
        {
            $suffix = ($options['suffix'] ?? ($params['sourceType'] === static::SOURCE_TYPE_BLOG_POST ? '2' : ''));
 
            $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_POST_' . $params['sourceType'] . (!empty($suffix) ? '_' . $suffix : ''), [
                '#ENTITY_CREATED#' => $this->getEntityCreatedMessage(),
                '#ENTITY_NAME#' => $this->getEntityName(),
            ]);
        }
 
        if (!empty($result))
        {
            if ($parser === null)
            {
                $parser = new \CTextParser();
                $parser->allow = [ 'HTML' => 'N', 'ANCHOR' => 'Y' ];
            }
            $result = $parser->convertText($result);
        }
 
        return (string)$result;
    }
 
    protected function getNotFoundMessage(): string
    {
        $result = '';
 
        $params = $this->params;
        if (
            !isset($params['entityType'])
            || !in_array($params['entityType'], $this->getEntityTypeList(), true)
        )
        {
            return $result;
        }
 
        $entityType = $params['entityType'];
 
        switch ($entityType)
        {
            case static::ENTITY_TYPE_TASK:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_TASK_NOT_FOUND');
                break;
            case static::ENTITY_TYPE_BLOG_POST:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_BLOG_POST_NOT_FOUND');
                break;
            case static::ENTITY_TYPE_CALENDAR_EVENT:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_CALENDAR_EVENT_NOT_FOUND');
                break;
            default:
        }
 
        return (string)$result;
    }
 
    protected function getEntityCreatedMessage(): string
    {
        $result = '';
 
        $params = $this->params;
 
        if (
            !isset($params['entityType'])
            || !in_array($params['entityType'], $this->getEntityTypeList(), true)
        )
        {
            return $result;
        }
 
        switch ($params['entityType'])
        {
            case static::ENTITY_TYPE_TASK:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_ENTITY_CREATED_TASK');
                break;
            case static::ENTITY_TYPE_BLOG_POST:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_ENTITY_CREATED_BLOG_POST');
                break;
            case static::ENTITY_TYPE_CALENDAR_EVENT:
                $result = Loc::getMessage('SONET_COMMENTAUX_CREATEENTITY_ENTITY_CREATED_CALENDAR_EVENT');
                break;
            default:
                $result = '';
        }
 
        return (string)$result;
    }
 
    protected function getEntityName(): string
    {
        if ($entity = $this->getEntity(false))
        {
            $entityPath = $entity['url'];
            $entityTitle = $entity['title'];
        }
        else
        {
            $entityPath = '';
            $entityTitle = $this->getNotFoundMessage();
        }
 
        if (mb_strlen($entityTitle) <= 0)
        {
            return '';
        }
 
        return (!empty($entityPath) ? '[URL=' . $entityPath . ']' . $entityTitle . '[/URL]' : $entityTitle);
    }
 
    public function checkRecalcNeeded($fields, $params): bool
    {
        $result = false;
 
        if (
            !empty($params['bPublicPage'])
            && $params['bPublicPage']
        )
        {
            $result = true;
        }
        else
        {
            $handlerParams = $this->getParamsFromFields($fields);
 
            if (
                !empty($handlerParams)
                && !empty($handlerParams['entityType'])
                && !empty($handlerParams['entityId'])
                && (int)$handlerParams['entityId'] > 0
                && ($this->getEntity())
            )
            {
                $result = true;
            }
        }
 
        return $result;
    }
 
    protected function getEntity($checkPermissions = true)
    {
        static $cache = [
            'Y' => [],
            'N' => [],
        ];
 
        $params = $this->params;
        $entityType = $params['entityType'] ?? null;
        $entityId = (int) ($params['entityId'] ?? null);
 
        $result = false;
        $permissionCacheKey = ($checkPermissions ? 'Y' : 'N');
        $entityKey = $entityType . '_' . $entityId;
 
        if (isset($cache[$permissionCacheKey][$entityKey]))
        {
            $result = $cache[$permissionCacheKey][$entityKey];
        }
        else
        {
            $entity = false;
 
            switch ($entityType)
            {
                case static::ENTITY_TYPE_TASK:
                    $provider = new \Bitrix\Socialnetwork\Livefeed\TasksTask();
                    break;
                case static::ENTITY_TYPE_BLOG_POST:
                    $provider = new \Bitrix\Socialnetwork\Livefeed\BlogPost();
                    break;
                case static::ENTITY_TYPE_CALENDAR_EVENT:
                    $provider = new \Bitrix\Socialnetwork\Livefeed\CalendarEvent();
                    break;
                default:
                    $provider = false;
            }
 
            if ($provider)
            {
                $provider->setEntityId($entityId);
                $provider->setOption('checkAccess', $checkPermissions);
 
                $entity = [
                    'title' => $provider->getSourceTitle(),
                    'url' => $provider->getLiveFeedUrl(),
                ];
            }
 
            if ($entity)
            {
                $result = $cache[$permissionCacheKey][$entityKey] = $entity;
            }
            elseif(!$checkPermissions)
            {
                $result = $cache[$permissionCacheKey][$entityKey] = false;
            }
        }
 
        return $result;
    }
 
    protected function getRatingNotificationNotigyTag(array $ratingVoteParams = [], array $fields = []): string
    {
        return 'RATING|' . ($ratingVoteParams['VALUE'] >= 0 ? '' : 'DL|') . 'BLOG_COMMENT|' . $fields['ID'];
    }
 
    protected function getForumType(): string
    {
        return \Bitrix\Forum\Comments\Service\Manager::TYPE_ENTITY_CREATED;
    }
 
    protected function getForumServiceData(array $commentData = [])
    {
        return $commentData['SERVICE_DATA'];
    }
 
    protected function getForumMessageFields(): array
    {
        return [ 'SERVICE_DATA' ];
    }
 
    protected function getSocNetData($data = ''): array
    {
        try
        {
            $result = Json::decode($data);
        }
        catch (ArgumentException $e)
        {
            $result = [];
        }
 
        return $result;
    }
 
    public function getLivefeedProvider()
    {
        $params = $this->params;
        $options = $this->options;
 
        return \Bitrix\Socialnetwork\Livefeed\Provider::init([
            'ENTITY_TYPE' => ($params['sourceType'] ?? $params['sourcetype']),
            'ENTITY_ID' => (int)($params['sourceId'] ?? $params['sourceid']),
            'LOG_ID' => (int)($options['logId'] ?? 0)
        ]);
    }
 
    protected function getSourceCommentData(array $additionalParams = []): array
    {
        $result = [
            'path' => '',
            'suffix' => '',
        ];
 
        $params = $this->params;
        $options = $this->options;
 
        $userPage = ($additionalParams['userPage'] ?? '');
        $params['sourceType'] = ($params['sourceType'] ?? $params['sourcetype']);
        $params['sourceId'] = (int)($params['sourceId'] ?? $params['sourceid']);
 
        if (
            $params['sourceType'] === static::SOURCE_TYPE_BLOG_COMMENT
            && Loader::includeModule('blog')
            && ($comment = static::$blogCommentClass::getById($params['sourceId']))
            && ($post = static::$blogPostClass::getById($comment['POST_ID']))
        )
        {
            $result['path'] = (
                (!isset($options['im']) || !$options['im'])
                && (!isset($options['bPublicPage']) || !$options['bPublicPage'])
                && (!isset($options['mail']) || !$options['mail'])
                    ? str_replace([ '#user_id#', '#USER_ID#' ], $post['AUTHOR_ID'], $userPage) . 'blog/' . $post['ID'] . '/?commentId=' . $params['sourceId'] . '#com' . $params['sourceId']
                    : ''
            );
        }
        else
        {
            $commentProvider = \Bitrix\Socialnetwork\Livefeed\Provider::getProvider($params['sourceType']);
 
            if (
                $commentProvider
                && (!isset($options['im']) || !$options['im'])
                && (!isset($options['bPublicPage']) || !$options['bPublicPage'])
                && (!isset($options['mail']) || !$options['mail'])
                && isset($options['logId'])
                && (int)$options['logId'] > 0
            )
            {
                $commentProvider->setEntityId((int)$params['sourceId']);
                $commentProvider->setLogId($options['logId']);
                $commentProvider->initSourceFields();
 
                $result['path'] = $commentProvider->getLiveFeedUrl();
            }
        }
 
        $result['suffix'] = ($options['suffix'] ?? ($params['sourceType'] === static::SOURCE_TYPE_BLOG_COMMENT ? '2' : ''));
 
        return $result;
    }
}