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
123
124
|
<?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\Goals;
use Piwik\Common;
use Piwik\Config;
use Piwik\Date;
use Piwik\Db;
use Piwik\Metrics\Formatter;
use Piwik\Piwik;
use Piwik\Plugins\CustomVariables\CustomVariables;
use Piwik\Plugins\Live\VisitorDetailsAbstract;
use Piwik\Site;
use Piwik\Tracker\Action;
use Piwik\Tracker\PageUrl;
class VisitorDetails extends VisitorDetailsAbstract
{
const EVENT_VALUE_PRECISION = 3;
protected $lastGoalResults = array();
protected $lastVisitIds = array();
public function extendVisitorDetails(&$visitor)
{
$idVisit = $visitor['idVisit'];
if (in_array($idVisit, $this->lastVisitIds)) {
$goalConversionDetails = isset($this->lastGoalResults[$idVisit]) ? $this->lastGoalResults[$idVisit] : array();
} else {
$goalConversionDetails = $this->queryGoalConversionsForVisits(array($idVisit));
}
$visitor['goalConversions'] = count($goalConversionDetails);
}
public function provideActionsForVisitIds(&$actions, $idVisits)
{
$this->lastVisitIds = $idVisits;
$this->lastGoalResults = array();
$goalConversionDetails = $this->queryGoalConversionsForVisits($idVisits);
// use while / array_shift combination instead of foreach to save memory
while (is_array($goalConversionDetails) && count($goalConversionDetails)) {
$goalConversionDetail = array_shift($goalConversionDetails);
$idVisit = $goalConversionDetail['idvisit'];
unset($goalConversionDetail['idvisit']);
$this->lastGoalResults[$idVisit][] = $actions[$idVisit][] = $goalConversionDetail;
}
}
/**
* @param $idVisit
* @return array
* @throws \Exception
*/
protected function queryGoalConversionsForVisits($idVisits)
{
$sql = "
SELECT
log_conversion.idvisit,
'goal' as type,
goal.name as goalName,
goal.idgoal as goalId,
log_conversion.revenue as revenue,
log_conversion.idlink_va,
log_conversion.idlink_va as goalPageId,
log_conversion.server_time as serverTimePretty,
log_conversion.url as url
FROM " . Common::prefixTable('log_conversion') . " AS log_conversion
LEFT JOIN " . Common::prefixTable('goal') . " AS goal
ON (goal.idsite = log_conversion.idsite
AND
goal.idgoal = log_conversion.idgoal)
AND goal.deleted = 0
WHERE log_conversion.idvisit IN ('" . implode("','", $idVisits) . "')
AND log_conversion.idgoal > 0
ORDER BY log_conversion.idvisit, server_time ASC
";
return Db::fetchAll($sql);
}
public function initProfile($visits, &$profile)
{
$profile['totalGoalConversions'] = 0;
$profile['totalConversionsByGoal'] = array();
}
public function handleProfileVisit($visit, &$profile)
{
$profile['totalGoalConversions'] += $visit->getColumn('goalConversions');
}
public function handleProfileAction($action, &$profile)
{
if ($action['type'] != 'goal') {
return;
}
$idGoal = $action['goalId'];
$idGoalKey = 'idgoal=' . $idGoal;
if (!isset($profile['totalConversionsByGoal'][$idGoalKey])) {
$profile['totalConversionsByGoal'][$idGoalKey] = 0;
}
++$profile['totalConversionsByGoal'][$idGoalKey];
if (!empty($action['revenue'])) {
if (!isset($profile['totalRevenueByGoal'][$idGoalKey])) {
$profile['totalRevenueByGoal'][$idGoalKey] = 0;
}
$profile['totalRevenueByGoal'][$idGoalKey] += $action['revenue'];
}
}
}
|
