crm.php

<?php
namespace Bitrix\Landing\Connector;
 
use Bitrix\Crm\CompanyTable;
use Bitrix\Crm\Requisite\EntityLink;
use Bitrix\Crm\Settings\CompanySettings;
use Bitrix\Landing\Manager;
use Bitrix\Main\Loader;
use Bitrix\Main\Text\Encoding;
use Bitrix\SalesCenter\Integration\CrmManager;
 
class Crm
{
    protected const CACHE_TAG = 'landing_crm_contacts';
    protected const OPTION_DATA_CODE = 'shop_master_data';
 
    protected const ID_KEY = 'ID';
    protected const COMPANY_KEY = 'COMPANY';
    protected const PHONE_KEY = 'PHONE';
    protected const EMAIL_KEY = 'EMAIL';
 
    protected const DEFAULT_COMPANY = 'Company24';
    protected const DEFAULT_PHONE = '+123456789';
    protected const DEFAULT_EMAIL = 'info@company24.com';
 
    protected const DEFAULT_CONTACTS = [
        self::COMPANY_KEY => self::DEFAULT_COMPANY,
        self::PHONE_KEY => self::DEFAULT_PHONE,
        self::EMAIL_KEY => self::DEFAULT_EMAIL,
    ];
 
    protected static function addNewCompany(string $title, string $phone): void
    {
        if (!Loader::includeModule('crm'))
        {
            return;
        }
 
        $company = new \CCrmCompany(false);
        $fields = [
            'TITLE' => $title,
            'OPENED' => CompanySettings::getCurrent()->getOpenedFlag() ? 'Y' : 'N',
            'IS_MY_COMPANY' => 'Y',
            'FM' => [
                'PHONE' => [
                    'n0' => [
                        'VALUE' => $phone,
                        'VALUE_TYPE' => 'WORK'
                    ]
                ]
            ]
        ];
        $company->add($fields);
    }
 
    public static function setContacts(int $siteId, array $data): void
    {
        $shopStoredData = unserialize(Manager::getOption(self::OPTION_DATA_CODE, ''), ['allowed_classes' => false]);
        $shopStoredData = is_array($shopStoredData) ? $shopStoredData : [];
        if (isset($shopStoredData[$siteId]))
        {
            unset($shopStoredData[$siteId]);
        }
        $shopStoredData[$siteId] = [];
 
        $contacts = self::getContactsRaw();
        if (!$contacts)
        {
            self::addNewCompany(
                $data[self::COMPANY_KEY],
                $data[self::PHONE_KEY]
            );
        }
 
        foreach (self::DEFAULT_CONTACTS as $key => $value)
        {
            if (!($data[$key] ?? ''))
            {
                continue;
            }
            if ($data[$key] !== ($contacts[$key] ?? ''))
            {
                $shopStoredData[$siteId][$key] = $data[$key];
            }
        }
 
        Manager::setOption(self::OPTION_DATA_CODE, serialize($shopStoredData));
        self::clearContactsCache();
    }
 
    public static function getContactsRaw(): array
    {
        static $contacts = null;
 
        if ($contacts === null)
        {
            $contacts = [];
        }
        else
        {
            return $contacts;
        }
 
        if (
            !Loader::includeModule('crm')
            || !Loader::includeModule('salescenter')
        )
        {
            return $contacts;
        }
 
        if (!Manager::isB24())
        {
            return $contacts;
        }
 
        $defaultCompanyId = EntityLink::getDefaultMyCompanyId();
 
        if (!$contacts && $defaultCompanyId === 0)
        {
            return $contacts;
        }
 
        $contacts[self::ID_KEY] = $defaultCompanyId;
        $contacts[self::COMPANY_KEY] = CrmManager::getPublishedCompanyName() ?: self::DEFAULT_COMPANY;
 
        // get just first phone or email
 
        $phones = CrmManager::getPublishedCompanyPhone();
        $contacts[self::PHONE_KEY] = empty($phones) || $phones['ID'] == 0
            ? self::DEFAULT_PHONE
            : $phones['VALUE'];
 
        $emails = CrmManager::getPublishedCompanyEmail();
        $contacts[self::EMAIL_KEY] = empty($emails)
            ? self::DEFAULT_EMAIL
            : $emails['VALUE'];
 
        return $contacts;
    }
 
    public static function getContacts(int $siteId): array
    {
        $cache = new \CPHPCache;
        $cacheManager = $GLOBALS['CACHE_MANAGER'];
        $cacheTag = self::CACHE_TAG;
        $cacheDir = '/landing/crm_contacts';
        if ($cache->initCache(8640000, $cacheTag . $siteId, $cacheDir))
        {
            return $cache->getVars();
        }
 
        $cache->startDataCache();
        $cacheManager->startTagCache($cacheDir);
        $cacheManager->registerTag($cacheTag);
 
        $contacts = self::getContactsRaw();
        if (!$contacts)
        {
            $contacts = self::DEFAULT_CONTACTS;
        }
 
        $shopData = unserialize(Manager::getOption(self::OPTION_DATA_CODE, ''), ['allowed_classes' => false]);
        if (isset($shopData[$siteId]))
        {
            $contacts = array_merge(
                $contacts,
                $shopData[$siteId]
            );
        }
 
        foreach ($contacts as &$value)
        {
            if (is_array($value))
            {
                $value = array_shift($value);
            }
        }
        unset($value);
 
        $cacheManager->endTagCache();
        $cache->endDataCache($contacts);
 
        return $contacts;
    }
 
    public static function clearContactsCache(): void
    {
        if (defined('BX_COMP_MANAGED_CACHE'))
        {
            Manager::getCacheManager()->clearByTag(self::CACHE_TAG);
        }
    }
 
    public static function onAfterCompanyChange(array $fields): void
    {
        $companyId = $fields['ID'] ?? null;
        if ($companyId === EntityLink::getDefaultMyCompanyId())
        {
            self::clearContactsCache();
        }
    }
 
    public static function getReplacesForContent(int $siteId, bool $attributesReplace = true): array
    {
        $replace = [];
 
        $crmContacts = self::getContacts($siteId);
        $replace['#crmCompanyTitle'] = \htmlspecialcharsbx($crmContacts['COMPANY']);
 
        if (!empty($crmContacts['PHONE']))
        {
            $phone = $crmContacts['PHONE'];
            $phone = \htmlspecialcharsbx($phone);
            $replace['#crmPhoneTitle1'] = $phone;// a-tag inside
            if ($attributesReplace)
            {
                $replace['#crmPhone1'] = $phone;// a-href inside
            }
        }
 
        if (!empty($crmContacts['EMAIL']))
        {
            $email = $crmContacts['EMAIL'];
            $email = \htmlspecialcharsbx($email);
            $replace['#crmEmailTitle1'] = $email;// a-tag inside
            if ($attributesReplace)
            {
                $replace['#crmEmail1'] = $email;// a-href inside
            }
        }
 
        return $replace;
    }
 
    public static function getReplaceRequisiteCompanyNameForContent(string $xmlId): array
    {
        $companyId = (int)(explode("_", $xmlId)[1] ?? 0);
        $requisites = self::getMyRequisites();
        if (isset($requisites[$companyId]['companyTitle']) && $companyId > 0)
        {
            $companyTitle = $requisites[$companyId]['companyTitle'];
        }
        if (!isset($companyTitle))
        {
            $companyTitle = 'Company24';
        }
        $replace['#requisiteCompanyTitle'] = $companyTitle;
 
        return $replace;
    }
 
    public static function getMyRequisites(): array
    {
        if (!Loader::includeModule('crm'))
        {
            return [];
        }
 
        $fullData = [];
 
        $companies = CompanyTable::query()
            ->setSelect(['ID', 'TITLE'])
            ->where('IS_MY_COMPANY', 'Y')
            ->setOrder(['DATE_MODIFY' => 'desc'])
            ->fetchAll()
        ;
        foreach ($companies as $company)
        {
            $requisites = [];
            $bankRequisites = [];
            $requisitesRaw = \CCrmEntitySelectorHelper::PrepareRequisiteData(
                \CCrmOwnerType::Company,
                $company['ID'],
                [
                    'VIEW_FORMATTED' => true,
                    'SKIP_CHECK_MY_COMPANY_PERMISSION' => true,
                ]
            );
            foreach ($requisitesRaw as $requisite)
            {
                $requisiteData = Encoding::convertEncoding(json_decode($requisite['requisiteData'], 1), 'UTF-8', SITE_CHARSET);
                if (!empty($requisiteData['viewData']['fields']))
                {
                    $requisites[$requisite['requisiteId']] = [
                        'id' =>  $requisite['requisiteId'],
                        'title' => $requisiteData['viewData']['title'] ?? null,
                        'data' => $requisiteData['viewData']['fields'],
                    ];
                }
                if (!empty($requisiteData['bankDetailViewDataList']))
                {
                    $bankRequisites[$requisite['requisiteId']] = [
                        'id' =>  $requisite['requisiteId'],
                        'title' => $requisiteData['viewData']['title'] ?? null,
                        'bankData' => $requisiteData['bankDetailViewDataList'][0]['viewData']['fields'] ?? null,
                    ];
                }
            }
 
            if (empty($requisites))
            {
                continue;
            }
 
            $fullData[$company['ID']] = [
                'companyId' => $company['ID'],
                'companyTitle' => $company['TITLE'],
                'requisites' => $requisites,
                'bankRequisites' => $bankRequisites,
            ];
        }
 
        return $fullData;
    }
 
    public static function getMyRequisitesPlainList(array $requisites = [], string $requisitesType = 'requisites'): array
    {
        $requisitesPlainList = [];
        foreach ($requisites as $company)
        {
            foreach ($company[$requisitesType] as $requisite)
            {
                $requisitesPlainList["{$company['companyId']}_{$requisite['id']}"]
                    = "{$company['companyTitle']}: {$requisite['title']} : {$requisite['id']}";
            }
        }
 
        return $requisitesPlainList;
    }
 
    public static function getCompanyCommunications(int $companyId): array
    {
        if (!Loader::includeModule('crm'))
        {
            return [];
        }
 
        $data = [];
 
        $res = \CCrmFieldMulti::getList(
            ['ID' => 'asc'],
            [
                'ENTITY_ID' => \CCrmOwnerType::CompanyName,
                'ELEMENT_ID' => $companyId,
            ]
        );
        while ($row = $res->Fetch())
        {
            $row = array_change_key_case($row);
            $row['type_id'] = mb_strtolower($row['type_id']);
 
            if (!isset($data[$row['type_id']]))
            {
                $data[$row['type_id']] = [];
            }
            $data[$row['type_id']][] = $row['value'];
        }
 
        return $data;
    }
}