workgroup.php

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

<?php

namespace Bitrix\Socialnetwork\Item;
 
use Bitrix\Main;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Engine\CurrentUser;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ModuleManager;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\SystemException;
use Bitrix\Socialnetwork\Integration\UI\EntitySelector\Config;
use Bitrix\Socialnetwork\Internals\Registry\GroupRegistry;
use Bitrix\Socialnetwork\Item\Workgroup\Type;
use Bitrix\Socialnetwork\Integration\Intranet\Structure\WorkgroupDepartmentsSynchronizer;
use Bitrix\Socialnetwork\WorkgroupTable;
use Bitrix\Socialnetwork\UserToGroupTable;
use Bitrix\Socialnetwork\Helper;
 
Loc::loadMessages(__FILE__);
 
class Workgroup implements Main\Type\Contract\Arrayable, Main\Type\Contract\Jsonable
{
    protected array $fields;
    protected static $groupsIdToCheckList = [];
 
    public static function createFromId(int $groupId = 0): static
    {
        return new static(['ID' => $groupId]);
    }
 
    public function __construct(array $fields = [])
    {
        $this->fields = $fields;
    }

    public static function getById($groupId = 0, $useCache = true): bool|static
    {
        $groupId = (int)$groupId;
 
        if ($groupId <= 0)
        {
            return false;
        }
 
        $useCache = (bool)$useCache;
 
        $registry = GroupRegistry::getInstance();
 
        if (!$useCache)
        {
            $registry->invalidate($groupId);
        }
 
        $group = $registry->get($groupId);
 
        if ($group === null)
        {
            return false; // disgusting! compatability...
        }
 
        return $group;
    }
 
    public function setFields(array $fields = []): void
    {
        $this->fields = $fields;
    }
 
    public function getFields(): array
    {
        return $this->fields;
    }
 
    public function getId(): int
    {
        return (int)($this->fields['ID'] ?? 0);
    }
 
    public function getName(): string
    {
        return (string)($this->fields['NAME'] ?? '');
    }
 
    public function getDescription(): string
    {
        return (string)($this->fields['DESCRIPTION'] ?? '');
    }
 
    public function getChatId(): int
    {
        return (int)($this->fields['CHAT_ID'] ?? 0);
    }
 
    public function getDialogId(): string
    {
        return (string)($this->fields['DIALOG_ID'] ?? '');
    }
 
    public function getImageId(): int
    {
        return (int)($this->fields['IMAGE_ID'] ?? 0);
    }
 
    public function getOwnerId(): int
    {
        return (int)($this->fields['OWNER_ID'] ?? 0);
    }
 
    public function getSiteId(): string
    {
        return (string)($this->fields['SITE_ID'] ?? '');
    }
 
    public function getSiteIds(): array
    {
        return (array)($this->fields['SITE_IDS'] ?? []);
    }
 
    public function isVisible(): bool
    {
        return ($this->fields['VISIBLE'] ?? null) === 'Y';
    }
 
    public function getType(): ?Type
    {
        $type = $this->fields['TYPE'] ?? null;
        if ($type instanceof Type)
        {
            return $type;
        }
 
        return Type::tryFrom($type);
    }
 
    public function getAvatarType(): ?string
    {
        return $this->fields['AVATAR_TYPE'] ?? null;
    }
 
    public function getAvatarUrl(): string
    {
        $avatar = Helper\Workgroup::getAvatarEntitySelectorUrl($this->getAvatarType());
        if (!empty($avatar))
        {
            return $avatar;
        }
 
        $extranetSiteId = Option::get('extranet', 'extranet_site');
        $extranetSiteId = ($extranetSiteId && ModuleManager::isModuleInstalled('extranet') ? $extranetSiteId : false);
        $isExtranet = in_array($extranetSiteId, $this->fields['SITE_IDS'] ?? [], true);
        $type = ($isExtranet && !$this->isCollab()) ? 'extranet' : $this->getType()?->value;
 
        $avatarTypes = Config::getProjectAvatarTypes();
 
        return $avatarTypes[$type ?? 'default'] ?? $avatarTypes['default'];
    }
 
    public function getSynchronizedDepartmentIds(): array
    {
        $departments = $this->fields['UF_SG_DEPT'] ?? [];
        if ($departments === [])
        {
            return [];
        }
 
        $departmentIds = $departments['VALUE'] ?? [];
        if (empty($departmentIds))
        {
            return [];
        }
 
        Main\Type\Collection::normalizeArrayValuesByInt($departmentIds, false);
 
        return $departmentIds;
    }
 
    public function getUserMemberIds(): array
    {
        $memberIds = $this->fields['MEMBERS'] ?? [];
        if ($memberIds === [])
        {
            return [];
        }
 
        Main\Type\Collection::normalizeArrayValuesByInt($memberIds, false);
 
        return $memberIds;
    }
 
    public function getInvitedMemberIds(): array
    {
        $requestedIds = $this->fields['INVITED_MEMBERS'] ?? [];
        if ($requestedIds === [])
        {
            return [];
        }
 
        Main\Type\Collection::normalizeArrayValuesByInt($requestedIds, false);
 
        return $requestedIds;
    }
 
    public function getModeratorMemberIds(): array
    {
        $moderatorIds = $this->fields['MODERATOR_MEMBERS'] ?? [];
        if ($moderatorIds === [])
        {
            return [];
        }
 
        Main\Type\Collection::normalizeArrayValuesByInt($moderatorIds, false);
 
        return $moderatorIds;
    }
 
    public function getOrdinaryMembers(): array
    {
        $ordinaryMemberIds = $this->fields['ORDINARY_MEMBERS'] ?? [];
        if ($ordinaryMemberIds === [])
        {
            return [];
        }
 
        Main\Type\Collection::normalizeArrayValuesByInt($ordinaryMemberIds, false);
 
        return $ordinaryMemberIds;
    }
 
    public function getMemberIdsWithRole(): array
    {
        $invited = array_fill_keys($this->getInvitedMemberIds(), UserToGroupTable::ROLE_REQUEST);
        $ordinary = array_fill_keys($this->getOrdinaryMembers(), UserToGroupTable::ROLE_USER);
        $moderators = array_fill_keys($this->getModeratorMemberIds(), UserToGroupTable::ROLE_MODERATOR);
        $owner = [$this->getOwnerId() => UserToGroupTable::ROLE_OWNER];
 
        return $invited + $ordinary + $moderators + $owner;
    }
 
    public function isProject(): bool
    {
        return (
            isset($this->fields['PROJECT'])
            && $this->fields['PROJECT'] === 'Y'
        );
    }
 
    public function isScrumProject(): bool
    {
        return (!empty($this->fields['SCRUM_MASTER_ID']));
    }
 
    public function isCollab(): bool
    {
        return $this->getType() === Type::Collab;
    }
 
    public function getDefaultSprintDuration(): int
    {
        return ($this->fields['SCRUM_SPRINT_DURATION'] ? : 0);
    }
 
    public function getScrumMaster(): int
    {
        return ($this->fields['SCRUM_MASTER_ID'] ? : 0);
    }
 
    public function getScrumTaskResponsible(): string
    {
        if ($this->fields['SCRUM_TASK_RESPONSIBLE'])
        {
            $scrumTaskResponsible = $this->fields['SCRUM_TASK_RESPONSIBLE'];
            $availableResponsibleTypes = ['A', 'M'];
            return (
                in_array($scrumTaskResponsible, $availableResponsibleTypes, true) ? $scrumTaskResponsible : 'A'
            );
        }
 
        return 'A';
    }

    public function syncDeptConnection($exclude = false): void
    {
        $currentUserId = (int)CurrentUser::get()->getId();
 
        WorkgroupDepartmentsSynchronizer::getInstance()->synchronize($this, $currentUserId, $exclude);
    }
 
    public function getGroupUrlData($params = array())
    {
        static $cache = array();
 
        $groupFields = $this->getFields();
        $userId = (int)($params['USER_ID'] ?? 0);
 
        if (
            !empty($cache)
            && !empty($cache[$groupFields["ID"]])
        )
        {
            $groupUrlTemplate = $cache[$groupFields['ID']]['URL_TEMPLATE'];
            $groupSiteId = $cache[$groupFields['ID']]['SITE_ID'];
        }
        else
        {
            $groupSiteId = \CSocNetGroup::getDefaultSiteId($groupFields["ID"], $groupFields["SITE_ID"]);
            $workgroupsPage = Option::get("socialnetwork", "workgroups_page", "/workgroups/", SITE_ID);
            $groupUrlTemplate = Helper\Path::get('group_path_template');
            $groupUrlTemplate = "#GROUPS_PATH#".mb_substr($groupUrlTemplate, mb_strlen($workgroupsPage), mb_strlen($groupUrlTemplate) - mb_strlen($workgroupsPage));
 
            $cache[$groupFields["ID"]] = array(
                'URL_TEMPLATE' => $groupUrlTemplate ,
                'SITE_ID' => $groupSiteId,
            );
        }
 
        $groupUrl = str_replace(array("#group_id#", "#GROUP_ID#"), $groupFields["ID"], $groupUrlTemplate);
        $serverName = $domainName = '';
 
        if ($userId > 0)
        {
            $tmp = \CSocNetLogTools::processPath(
                [
                    'GROUP_URL' => $groupUrl,
                ],
                $userId,
                $groupSiteId
            );
 
            $groupUrl = $tmp["URLS"]["GROUP_URL"];
            $serverName = (mb_strpos($groupUrl, "http://") === 0 || mb_strpos($groupUrl, "https://") === 0 ? "" : $tmp["SERVER_NAME"]);
            $domainName = (mb_strpos($groupUrl, "http://") === 0 || mb_strpos($groupUrl, "https://") === 0 ? "" : (isset($tmp["DOMAIN"]) && !empty($tmp["DOMAIN"]) ? "//".$tmp["DOMAIN"] : ""));
        }
 
        return [
            'URL' => $groupUrl,
            'SERVER_NAME' => $serverName,
            'DOMAIN' => $domainName,
        ];
    }
 
    public function isLandingGroup(): bool
    {
        return ($this->getFields()['LANDING'] ?? null) === 'Y';
    }
 
    public function getInitiatePermission(): ?string
    {
        return $this->fields['INITIATE_PERMS'] ?? null;
    }
 
    public function toArray(): array
    {
        return $this->getFields();
    }
 
    public function toJson($options = 0): array
    {
        return $this->toArray();
    }
 
    public static function onBeforeIBlockSectionUpdate($section)
    {
        if (
            !isset($section['ID'], $section['IBLOCK_ID'])
            || (int)$section['ID'] <= 0
            || (int)$section['IBLOCK_ID'] <= 0
            || (
                isset($section['ACTIVE'])
                && $section['ACTIVE'] === 'N'
            )
            || (int)$section['IBLOCK_ID'] !== (int)Option::get('intranet', 'iblock_structure', 0)
        )
        {
            return true;
        }
 
        $rootSectionIdList = [];
        $res = \CIBlockSection::getNavChain($section['IBLOCK_ID'], $section['ID'], array('ID'));
        while ($rootSection = $res->fetch())
        {
            if ((int)$rootSection['ID'] !== (int)$section['ID'])
            {
                $rootSectionIdList[] = $rootSection['ID'];
            }
        }
 
        if (!empty($rootSectionIdList))
        {
            $groupList = UserToGroup::getConnectedGroups($rootSectionIdList);
            self::$groupsIdToCheckList = array_merge(self::$groupsIdToCheckList, $groupList);
        }
 
        return true;
    }
 
    public static function onAfterIBlockSectionUpdate($section)
    {
        if(
            !isset($section['ID'], $section['IBLOCK_ID'])
            || (int)$section['ID'] <= 0
            || (int)$section['IBLOCK_ID'] <= 0
            || (int)$section['IBLOCK_ID'] !== (int)Option::get('intranet', 'iblock_structure', 0)
        )
        {
            return true;
        }
 
        $oldGroupsIdToCheckList = self::$groupsIdToCheckList;
        $newGroupsIdToCheckList = [];
 
        if (
            isset($section['ACTIVE'])
            && $section['ACTIVE'] === 'N'
        )
        {
            self::disconnectSection($section['ID']);
        }
        else
        {
            $res = \CIBlockSection::getNavChain($section['IBLOCK_ID'], $section['ID'], array('ID'));
            while ($rootSection = $res->fetch())
            {
                if ((int)$rootSection['ID'] !== (int)$section['ID'])
                {
                    $rootSectionIdList[] = $rootSection['ID'];
                }
            }
 
            if (!empty($rootSectionIdList))
            {
                $newGroupsIdToCheckList = UserToGroup::getConnectedGroups($rootSectionIdList);
            }
        }
 
        if (!empty($oldGroupsIdToCheckList))
        {
            $oldGroupsIdToCheckList = array_unique($oldGroupsIdToCheckList);
            foreach($oldGroupsIdToCheckList as $groupId)
            {
                $groupItem = self::getById($groupId, false);
                $groupItem->syncDeptConnection(true);
            }
        }
 
        if (!empty($newGroupsIdToCheckList))
        {
            $newGroupsIdToCheckList = array_unique($newGroupsIdToCheckList);
            foreach($newGroupsIdToCheckList as $groupId)
            {
                $groupItem = self::getById($groupId, false);
                $groupItem->syncDeptConnection();
            }
        }
 
        return true;
    }
 
    public static function onBeforeIBlockSectionDelete($sectionId)
    {
        if ((int)$sectionId <= 0)
        {
            return true;
        }
 
        $res = \CIBlockSection::getList(
            [],
            [ 'ID' => $sectionId ],
            false,
            [ 'ID', 'IBLOCK_ID' ]
        );
        if (
            !($section = $res->fetch())
            || !isset($section['IBLOCK_ID'])
            || (int)$section['IBLOCK_ID'] <= 0
            || (
                isset($section['ACTIVE'])
                && $section['ACTIVE'] === 'N'
            )
            || (int)$section['IBLOCK_ID'] !== (int)Option::get('intranet', 'iblock_structure', 0)
        )
        {
            return true;
        }
 
        $rootSectionIdList = [];
        $res = \CIBlockSection::getNavChain($section['IBLOCK_ID'], $section['ID'], array('ID'));
        while ($rootSection = $res->fetch())
        {
            if ((int)$rootSection['ID'] !== (int)$section['ID'])
            {
                $rootSectionIdList[] = $rootSection['ID'];
            }
        }
 
        if (!empty($rootSectionIdList))
        {
            $groupList = UserToGroup::getConnectedGroups($rootSectionIdList);
            self::$groupsIdToCheckList = array_merge(self::$groupsIdToCheckList, $groupList);
        }
 
        return true;
    }
 
    public static function onAfterIBlockSectionDelete($section): bool
    {
        if(
            !isset($section['ID'], $section['IBLOCK_ID'])
            || (int)$section['ID'] <= 0
            || (int)$section['IBLOCK_ID'] <= 0
            || (int)$section['IBLOCK_ID'] !== (int)Option::get('intranet', 'iblock_structure', 0)
        )
        {
            return true;
        }
 
        self::disconnectSection($section['ID']);
 
        if (!empty(self::$groupsIdToCheckList))
        {
            $groupsToCheck = array_unique(self::$groupsIdToCheckList);
            foreach($groupsToCheck as $groupId)
            {
                $groupItem = self::getById($groupId, false);
                $groupItem->syncDeptConnection();
            }
        }
 
        return true;
    }
 
    private static function disconnectSection($sectionId): void
    {
        $groupList = array();
        $res = WorkgroupTable::getList(array(
            'filter' => array(
                '=UF_SG_DEPT' => $sectionId,
            ),
            'select' => array('ID', 'UF_SG_DEPT'),
        ));
        while($group = $res->fetch())
        {
            $groupList[] = $group;
        }
 
        foreach($groupList as $group)
        {
            $departmentListOld = array_map('intval',  $group['UF_SG_DEPT']);
            $departmentListNew = array_diff($departmentListOld, array($sectionId));
 
            \CSocNetGroup::update($group['ID'], array(
                'UF_SG_DEPT' => $departmentListNew,
            ));
 
            $groupItem = self::getById($group['ID'], false);
            $groupItem->syncDeptConnection(true);
        }
    }
 
    public static function getTypes($params = []): array
    {
        return Helper\Workgroup::getTypes($params);
    }
 
    public static function getPresets($params = array()): array
    {
        return Helper\Workgroup::getPresets($params);
    }
 
    private static function getGroupContent($params = array()): string
    {
        static $fieldsList = null;;
 
        $content = '';
 
        $groupId = (int)($params['id'] ?? 0);
 
        if ($groupId <= 0)
        {
            return $content;
        }
 
        if ($fieldsList === null)
        {
            $fieldsList = self::getContentFieldsList();
        }
 
        if (
            isset($params['fields'])
            && is_array($params['fields'])
            && ($diff = array_diff($fieldsList, array_keys($params['fields'])))
            && empty($diff)
        )
        {
            $groupFieldsList = $params['fields'];
        }
        else
        {
            $res = WorkgroupTable::getList(array(
                'filter' => array(
                    'ID' => $groupId,
                ),
                'select' => $fieldsList,
            ));
            $groupFieldsList = $res->fetch();
        }
 
        if (!empty($groupFieldsList))
        {
            $content .= $groupFieldsList['NAME'];
            if (!empty($groupFieldsList['DESCRIPTION']))
            {
                $content .= ' '.$groupFieldsList['DESCRIPTION'];
            }
 
            if (!empty($groupFieldsList['KEYWORDS']))
            {
                $keywordList = explode(",", $groupFieldsList["KEYWORDS"]);
                $tagList = array();
                foreach($keywordList as $keyword)
                {
                    $tagList[] = trim($keyword);
                    $tagList[] = '#'.trim($keyword);
                }
                if (!empty($tagList))
                {
                    $content .= ' '.implode(' ', $tagList);
                }
            }
 
            if (
                !empty($groupFieldsList['OWNER_ID'])
                && (int)$groupFieldsList['OWNER_ID'] > 0
            )
            {
                $res = Main\UserTable::getList(array(
                    'filter' => array(
                        'ID' => (int)$groupFieldsList['OWNER_ID'],
                    ),
                    'select' => array('ID', 'NAME', 'LAST_NAME', 'SECOND_NAME', 'LOGIN', 'EMAIL'),
                ));
                if ($userFields = $res->fetch())
                {
                    $content .= ' '.\CUser::formatName(\CSite::getNameFormat(null, $groupFieldsList['SITE_ID']), $userFields, true);
                }
            }
        }
 
        return $content;
    }
 
    public static function setIndex($params = array()): void
    {
        global $DB;
 
        static $connection = null;
 
        if (!is_array($params))
        {
            return;
        }
 
        $fields = (isset($params['fields']) ? $params['fields'] : array());
 
        if (
            !is_array($fields)
            || empty($fields)
        )
        {
            return;
        }
 
        $groupId = (isset($fields['ID']) ? intval($fields['ID']) : 0);
 
        if ($groupId <= 0)
        {
            return;
        }
 
        $content = self::getGroupContent(array(
            'id' => $groupId,
            'fields' => $fields,
        ));
 
        $content = self::prepareToken($content);
 
        $event = new Main\Event(
            'socialnetwork',
            'onWorkgroupIndexGetContent',
            array(
                'groupId' => $groupId,
            )
        );
        $event->send();
 
        foreach($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == \Bitrix\Main\EventResult::SUCCESS)
            {
                $eventParams = $eventResult->getParameters();
 
                if (
                    is_array($eventParams)
                    && isset($eventParams['content'])
                )
                {
                    $eventContent = $eventParams['content'];
                    if (Main\Loader::includeModule('search'))
                    {
                        $eventContent = \CSearch::killTags($eventContent);
                    }
                    $eventContent = trim(str_replace(
                        array("\r", "\n", "\t"),
                        " ",
                        $eventContent
                    ));
 
                    $eventContent = self::prepareToken($eventContent);
                    if (!empty($eventContent))
                    {
                        $content .= ' '.$eventContent;
                    }
                }
            }
        }
 
        if (!empty($content))
        {
            if ($connection === null)
            {
                $connection = \Bitrix\Main\Application::getConnection();
            }
 
            $value = $DB->forSql($content);
            $encryptedValue = sha1($content);
 
            $connection->query("UPDATE ".WorkgroupTable::getTableName()." SET SEARCH_INDEX = CASE WHEN " . $connection->getSqlHelper()->getSha1Function('SEARCH_INDEX') . " = '{$encryptedValue}' THEN SEARCH_INDEX ELSE '{$value}' END WHERE ID = {$groupId}");
        }
    }
 
    public static function getContentFieldsList(): array
    {
        return [ 'NAME', 'DESCRIPTION', 'OWNER_ID', 'KEYWORDS', 'SITE_ID' ];
    }
 
    public static function prepareToken($str)
    {
        return str_rot13($str);
    }
 
    public static function getInitiatePermOptionsList(array $params = []): array
    {
        $ownerValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_OWNER');
        $moderatorsValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_MOD');
        $userValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_USER');
 
        if (
            isset($params['scrum'])
            && $params['scrum']
        )
        {
            $ownerValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_OWNER_SCRUM2');
            $moderatorsValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_MOD_SCRUM2');
            $userValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_USER_SCRUM');
        }
        elseif (
            isset($params['project'])
            && $params['project']
        )
        {
            $ownerValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_OWNER_PROJECT');
            $moderatorsValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_MOD_PROJECT');
            $userValue = Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_USER_PROJECT');
        }
 
        return [
            UserToGroupTable::ROLE_OWNER => $ownerValue,
            UserToGroupTable::ROLE_MODERATOR => $moderatorsValue,
            UserToGroupTable::ROLE_USER => $userValue,
        ];
    }
 
    public static function getSpamPermOptionsList(): array
    {
        return [
            UserToGroupTable::ROLE_OWNER => Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_OWNER'),
            UserToGroupTable::ROLE_MODERATOR => Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_MOD'),
            UserToGroupTable::ROLE_USER => Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_USER'),
            SONET_ROLES_ALL => Loc::getMessage('SOCIALNETWORK_ITEM_WORKGROUP_IP_ALL'),
        ];
    }

    public static function getByFeatureOperation(array $params = []): array
    {
        return Helper\Workgroup::getByFeatureOperation($params);
    }
 
    public static function getListSprintDuration(): array
    {
        return Helper\Workgroup::getListSprintDuration();
    }
 
    public static function getScrumTaskResponsibleList(): array
    {
        return Helper\Workgroup::getScrumTaskResponsibleList();
    }
 
    public static function getTypeCodeByParams($params)
    {
        return Helper\Workgroup::getTypeCodeByParams($params);
    }
 
    public static function getTypeByCode($params = [])
    {
        return Helper\Workgroup::getTypeByCode($params);
    }
 
    public static function getEditFeaturesAvailability()
    {
        return Helper\Workgroup::getEditFeaturesAvailability();
    }
 
    public static function canWorkWithClosedWorkgroups(): bool
    {
        static $optionValue = null;
        if ($optionValue === null)
        {
            $optionValue = Option::get('socialnetwork', 'work_with_closed_groups', 'N');
        }
 
        return ($optionValue === 'Y');
    }
}