RecordImporter.php

<?php

/**
 * Piwik - free/libre analytics platform
 *
 * @link http://piwik.org
 * @license http://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later
 *
 */

namespace Piwik\Plugins\GoogleAnalyticsImporter;

use Piwik\Config as PiwikConfig;
use Piwik\DataTable;
use Piwik\Date;
use Piwik\Metrics;
use Piwik\Plugins\GoogleAnalyticsImporter\Google\GoogleAnalyticsQueryService;
use Piwik\Log\LoggerInterface;

abstract class RecordImporter
{
    public const IS_IMPORTED_FROM_GOOGLE_METADATA_NAME = 'is_imported_from_google';
    public const NOT_SET_IN_GA_LABEL = '__not_set_in_google_analytics__';
    /**
     * @var GoogleAnalyticsQueryService
     */
    private $gaQuery;
    /**
     * @var int
     */
    private $idSite;
    /**
     * @var RecordInserter
     */
    private $recordInserter;
    /**
     * @var LoggerInterface
     */
    private $logger;
    /**
     * @var int
     */
    private $standardMaximumRows;
    public function __construct(GoogleAnalyticsQueryService $gaQuery, $idSite, LoggerInterface $logger)
    {
        $this->gaQuery = $gaQuery;
        $this->idSite = $idSite;
        $this->logger = $logger;
        $this->standardMaximumRows = PiwikConfig::getInstance()->General['datatable_archiving_maximum_rows_standard'];
        $this->logger = $logger;
    }
    public function supportsSite()
    {
        return \true;
    }
    abstract public function importRecords(Date $day);
    public function setRecordInserter(\Piwik\Plugins\GoogleAnalyticsImporter\RecordInserter $recordInserter)
    {
        $this->recordInserter = $recordInserter;
    }
    /**
     * @return int
     */
    protected function getStandardMaximumRows()
    {
        return $this->standardMaximumRows;
    }
    protected function getGaQuery()
    {
        return $this->gaQuery;
    }
    protected function getLogger()
    {
        return $this->logger;
    }
    protected function getVisitMetrics()
    {
        return [Metrics::INDEX_NB_UNIQ_VISITORS, Metrics::INDEX_NB_VISITS, Metrics::INDEX_NB_ACTIONS, Metrics::INDEX_SUM_VISIT_LENGTH, Metrics::INDEX_BOUNCE_COUNT, Metrics::INDEX_NB_VISITS_CONVERTED];
    }
    protected function getConversionAwareVisitMetrics()
    {
        return array_merge($this->getVisitMetrics(), [Metrics::INDEX_NB_CONVERSIONS, Metrics::INDEX_REVENUE, Metrics::INDEX_GOALS]);
    }
    protected function getActionMetrics()
    {
        // NOTE: Metrics::INDEX_NB_VISITS, Metrics::INDEX_NB_UNIQ_VISITORS are not included here, though they are queried
        // at the same time in matomo, since Google Analytics can sometimes return less visits than it should when combined with NB_HITS.
        return [Metrics::INDEX_PAGE_NB_HITS];
    }
    protected function getPageMetrics()
    {
        return array_merge($this->getActionMetrics(), [Metrics::INDEX_PAGE_SUM_TIME_SPENT, Metrics::INDEX_PAGE_SUM_TIME_GENERATION, Metrics::INDEX_PAGE_NB_HITS_WITH_TIME_GENERATION]);
    }
    protected function getEcommerceMetrics()
    {
        return [Metrics::INDEX_ECOMMERCE_ITEM_REVENUE, Metrics::INDEX_ECOMMERCE_ITEM_QUANTITY, Metrics::INDEX_ECOMMERCE_ITEM_PRICE, Metrics::INDEX_ECOMMERCE_ORDERS, Metrics::INDEX_NB_VISITS, Metrics::INDEX_NB_ACTIONS];
    }
    protected function getIdSite()
    {
        return $this->idSite;
    }
    protected function insertRecord($recordName, DataTable $record, $maximumRowsInDataTable = null, $maximumRowsInSubDataTable = null, $columnToSortByBeforeTruncation = null)
    {
        $this->recordInserter->insertRecord($recordName, $record, $maximumRowsInDataTable, $maximumRowsInSubDataTable, $columnToSortByBeforeTruncation);
    }
    protected function insertBlobRecord($name, $values)
    {
        $this->recordInserter->insertBlobRecord($name, $values);
    }
    protected function insertNumericRecords(array $values)
    {
        $this->recordInserter->insertNumericRecords($values);
    }
    protected function addRowToTable(DataTable $record, DataTable\Row $row, $newLabel)
    {
        if ($newLabel === \false || $newLabel === null) {
            $recordImporterClass = get_class($this);
            throw new \Exception("Unexpected error: adding row to table with empty label in {$recordImporterClass}: " . var_export($newLabel, \true));
        }
        $foundRow = $record->getRowFromLabel($newLabel);
        if (empty($foundRow)) {
            $foundRow = clone $row;
            $foundRow->deleteMetadata();
            $foundRow->setColumn('label', $newLabel);
            $record->addRow($foundRow);
        } else {
            $foundRow->sumRow($row, $copyMetadata = \false);
        }
        return $foundRow;
    }
    protected function addRowToSubtable(DataTable\Row $topLevelRow, DataTable\Row $rowToAdd, $newLabel)
    {
        $subtable = $topLevelRow->getSubtable();
        if (!$subtable) {
            $subtable = new DataTable();
            $topLevelRow->setSubtable($subtable);
        }
        return $this->addRowToTable($subtable, $rowToAdd, $newLabel);
    }
    protected function createTableFromGap($gap)
    {
        $record = new DataTable();
        foreach ($gap as $bounds) {
            $row = new DataTable\Row();
            if (count($bounds) === 1) {
                $row->setColumn('label', $bounds[0] + 1 . urlencode('+'));
            } else {
                $row->setColumn('label', $bounds[0] . ' - ' . $bounds[1]);
            }
            $record->addRow($row);
        }
        return $record;
    }
    protected function getGapLabel(array $gap, $value)
    {
        $range = null;
        foreach ($gap as $bounds) {
            $upperBound = end($bounds);
            if ($value <= $upperBound) {
                $range = reset($bounds) . ' - ' . $upperBound;
                break;
            }
        }
        if (empty($range)) {
            $lowerBound = reset($bounds);
            $range = $lowerBound + 1 . urlencode('+');
        }
        return $range;
    }
}