accountgoogle.php

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

<?php
 
namespace Bitrix\Seo\Analytics\Services;
 
use Bitrix\Main\Error;
use Bitrix\Main\NotImplementedException;
use Bitrix\Main\PhoneNumber\Parser;
use Bitrix\Main\Result;
use Bitrix\Main\Type\Date;
use Bitrix\Main\Web\Json;
 
use Bitrix\Seo\Analytics;
use Bitrix\Seo\Retargeting;
 
class AccountGoogle extends Analytics\Account
{
    const TYPE_CODE = 'google';
 
    public function getList()
    {
        $response = $this->request->send(array(
            'methodName' => 'analytics.account.list',
            'parameters' => array()
        ));
 
        return $response;
    }
 
    public function getProfile()
    {
        $response = $this->getRequest()->getClient()->get(
            'https://www.googleapis.com/oauth2/v1/userinfo?access_token=' .
            urlencode($this->getRequest()->getAuthAdapter()->getToken())
        );
 
        if ($response)
        {
            $response = Json::decode($response);
            if (is_array($response))
            {
                return array(
                    'ID' => $response['id'],
                    'NAME' => $response['name'],
                    'LINK' => '',
                    'PICTURE' => $response['picture'],
                );
            }
        }
 
 
        return null;
    }

    public function getExpenses($accountId, Date $dateFrom = null, Date $dateTo = null)
    {
        $parameters = [
            'ACCOUNT_ID' => $accountId,
        ];
        if($dateFrom && $dateTo)
        {
            $parameters['DATE_FROM'] = $dateFrom->format('Ymd');
            $parameters['DATE_TO'] = $dateTo->format('Ymd');
        }
        $response = $this->getRequest()->send([
            'methodName' => 'analytics.expenses.get',
            'parameters' => $parameters,
        ]);
 
        if($response->isSuccess())
        {
            $data = $response->getData();
            $response->setData([
                'expenses' => new Analytics\Internals\Expenses([
                    'impressions' => $data['Impressions'],
                    'clicks' => $data['Clicks'],
                    'actions' => $data['Interactions'],
                    'cpc' => $data['Avg. CPC'],
                    'cpm' => $data['Avg. CPM'],
                    'spend' => $data['Cost'],
                    'currency' => $data['Currency'],
                ]),
            ]);
        }
 
        return $response;
    }

    public function getExpensesReport($accountId, Date $dateFrom = null, Date $dateTo = null)
    {
        $parameters = [
            'ACCOUNT_ID' => $accountId,
        ];
        if($dateFrom && $dateTo)
        {
            $parameters['DATE_FROM'] = $dateFrom->format('Ymd');
            $parameters['DATE_TO'] = $dateTo->format('Ymd');
        }
        $response = $this->getRequest()->send([
            'methodName' => 'analytics.expenses.report',
            'parameters' => $parameters,
        ]);
 
        return $response;
    }

    public function getDailyExpensesReport(?string $accountId, ?Date $dateFrom, ?Date $dateTo): Result
    {
        $result = new Result();
 
        $parameters = [
            'ACCOUNT_ID' => $accountId,
        ];
 
        if ($dateFrom && $dateTo)
        {
            $parameters['DATE_FROM'] = $dateFrom->format('Ymd');
            $parameters['DATE_TO'] = $dateTo->format('Ymd');
        }
 
        $response = $this->getRequest()->send([
            'methodName' => 'analytics.ads.expenses.get',
            'parameters' => $parameters,
            'streamTimeout' => static::LOAD_DAILY_EXPENSES_TIMEOUT,
            'listenHttpErrors' => true,
        ]);
 
        if (!$response->isSuccess())
        {
            $innerErrors = implode(',', $response->getErrorMessages());
            $errorMessage = $this->buildErrorMessage("Error occurred while load daily expenses: {$innerErrors}");
 
            return $result->addError(new Error($errorMessage));
        }
 
        $data = $response->getData();
 
        if (isset($data['ROWS']) && count($data['ROWS']) > 0)
        {
            foreach ($data['ROWS'] as &$row)
            {
                $row['COST'] /= 1000000;
            }
        }
 
        $result->setData(['expenses' => Helpers\ExpensesAdapter::translateExpensesReportToDailyExpenses($data)]);
 
        return $result;
    }
 
    public function hasDailyExpensesReport(): bool
    {
        return true;
    }

    public function hasExpensesReport()
    {
        return true;
    }

    public function updateAnalyticParams($accountId, array $params, array $publicPageIds = [])
    {
        $result = new Result();
        if(!isset($params['phone']) && !isset($params['url_tags']))
        {
            return $result;
        }
        $parameters = [
            'ACCOUNT_ID' => $accountId,
        ];
        if(isset($params['phone']))
        {
            $phoneNumber = Parser::getInstance()->parse($params['phone']);
            $parameters['PHONE'] = ['COUNTRY_CODE' => mb_strtoupper($phoneNumber->getCountry()), 'NUMBER' => $phoneNumber->format()];
        }
        if(isset($params['url_tags']))
        {
            $parameters['URL_TAGS'] = $params['url_tags'];
        }
 
        return $this->getRequest()->send([
            'methodName' => 'analytics.update',
            'parameters' => $parameters,
        ]);
    }
}