1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
<?php
/**
* Matomo - free/libre analytics platform
*
* @link https://matomo.org
* @license https://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later
*/
namespace Piwik\Plugins\VisitorInterest\RecordBuilders;
use Piwik\ArchiveProcessor;
use Piwik\ArchiveProcessor\Record;
use Piwik\ArchiveProcessor\RecordBuilder;
use Piwik\DataAccess\LogAggregator;
use Piwik\DataTable;
use Piwik\Metrics;
use Piwik\Plugins\VisitorInterest\Archiver;
class Engagement extends RecordBuilder
{
public function getRecordMetadata(ArchiveProcessor $archiveProcessor): array
{
return [
Record::make(Record::TYPE_BLOB, Archiver::TIME_SPENT_RECORD_NAME),
Record::make(Record::TYPE_BLOB, Archiver::PAGES_VIEWED_RECORD_NAME),
Record::make(Record::TYPE_BLOB, Archiver::VISITS_COUNT_RECORD_NAME),
Record::make(Record::TYPE_BLOB, Archiver::DAYS_SINCE_LAST_RECORD_NAME),
];
}
protected function aggregate(ArchiveProcessor $archiveProcessor): array
{
// these prefixes are prepended to the 'SELECT as' parts of each SELECT expression. detecting
// these prefixes allows us to get all the data in one query.
$prefixes = [
Archiver::TIME_SPENT_RECORD_NAME => 'tg',
Archiver::PAGES_VIEWED_RECORD_NAME => 'pg',
Archiver::VISITS_COUNT_RECORD_NAME => 'vbvn',
Archiver::DAYS_SINCE_LAST_RECORD_NAME => 'dslv',
];
// collect our extra aggregate select fields
$selects = array();
$selects = array_merge($selects, LogAggregator::getSelectsFromRangedColumn(
'visit_total_time',
Archiver::getSecondsGap(),
'log_visit',
$prefixes[Archiver::TIME_SPENT_RECORD_NAME]
));
$selects = array_merge($selects, LogAggregator::getSelectsFromRangedColumn(
'visit_total_actions',
Archiver::$pageGap,
'log_visit',
$prefixes[Archiver::PAGES_VIEWED_RECORD_NAME]
));
$selects = array_merge($selects, LogAggregator::getSelectsFromRangedColumn(
'visitor_count_visits',
Archiver::$visitNumberGap,
'log_visit',
$prefixes[Archiver::VISITS_COUNT_RECORD_NAME]
));
$selects = array_merge($selects, LogAggregator::getSelectsFromRangedColumn(
'FLOOR(log_visit.visitor_seconds_since_last / 86400)',
Archiver::$daysSinceLastVisitGap,
'log_visit',
$prefixes[Archiver::DAYS_SINCE_LAST_RECORD_NAME],
$restrictToReturningVisitors = true
));
$records = [];
$query = $archiveProcessor->getLogAggregator()->queryVisitsByDimension(array(), $where = false, $selects, array());
$row = $query->fetch();
foreach ($prefixes as $recordName => $selectAsPrefix) {
$cleanRow = LogAggregator::makeArrayOneColumn($row, Metrics::INDEX_NB_VISITS, $selectAsPrefix);
$records[$recordName] = DataTable::makeFromIndexedArray($cleanRow);
}
return $records;
}
}
|
