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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
<?php
/**
* Piwik - Open source web analytics
*
* @link http://piwik.org
* @license http://www.gnu.org/licenses/gpl-3.0.html Gpl v3 or later
* @version $Id$
*
* @category Piwik
* @package Piwik
*/
/**
* @package Piwik
* @subpackage Piwik_Archive
*/
class Piwik_Archive_Array_IndexedBySite extends Piwik_Archive_Array
{
/**
* @param Piwik_Site $oSite
* @param string $strPeriod eg. 'day' 'week' etc.
* @param string $strDate A date range, eg. 'last10', 'previous5' or 'YYYY-MM-DD,YYYY-MM-DD'
*/
function __construct($sites, $strPeriod, $strDate)
{
foreach($sites as $idSite)
{
$archive = Piwik_Archive::build($idSite, $strPeriod, $strDate );
$archive->setSite(new Piwik_Site($idSite));
$archive->prepareArchive();
$this->archives[$idSite] = $archive;
}
ksort( $this->archives );
}
protected function getIndexName()
{
return 'idSite';
}
protected function getDataTableLabelValue( $archive )
{
return $archive->getIdSite();
}
/**
* Given a list of fields defining numeric values, it will return a Piwik_DataTable_Array
* ordered by idsite
*
* @param array|string $fields array( fieldName1, fieldName2, ...) Names of the mysql table fields to load
* @return Piwik_DataTable_Array
*/
public function getDataTableFromNumeric( $fields )
{
$tableArray = $this->getNewDataTableArray();
if ($this->getFirstArchive() instanceof Piwik_Archive_Single)
{
$values = $this->getValues($fields);
foreach($this->archives as $idSite => $archive)
{
$table = new Piwik_DataTable_Simple();
if (array_key_exists($idSite, $values))
{
$table->addRowsFromArray($values[$idSite]);
}
$tableArray->addTable($table, $idSite);
}
}
elseif ($this->getFirstArchive() instanceof Piwik_Archive_Array)
{
foreach($this->archives as $idSite => $archive)
{
$tableArray->addTable($archive->getDataTableFromNumeric($fields), $idSite);
}
}
return $tableArray;
}
private function getValues($fields)
{
$arrayValues = array();
foreach($this->loadValuesFromDB($fields) as $value)
{
$arrayValues[$value['idsite']][$value['name']] = $value['value'];
}
return $arrayValues;
}
private function loadValuesFromDB($fields)
{
$sql = "SELECT value, name, idarchive, idsite
FROM {$this->getNumericTableName()}
WHERE idarchive IN ( {$this->getArchiveIds()} )
AND name IN ( {$this->getSqlStringFieldsArray($fields)} )";
return Piwik_FetchAll($sql);
}
private function getFirstArchive()
{
reset($this->archives);
return current($this->archives);
}
private function getArchiveIds()
{
foreach($this->archives as $archive)
{
if( $this->getNumericTableName() != $archive->archiveProcessing->getTableArchiveNumericName())
{
throw new Exception("Piwik_Archive_Array_IndexedBySite::getDataTableFromNumeric() algorithm won't work if data is stored in different tables");
}
$archiveIds[] = $archive->getIdArchive();
}
return implode(', ', array_filter($archiveIds));
}
private function getNumericTableName()
{
return $this->getFirstArchive()->archiveProcessing->getTableArchiveNumericName();
}
}
|
