Skip to content
Extraits de code Groupes Projets
Valider d8ac3977 rédigé par mattab's avatar mattab
Parcourir les fichiers

Code reformat phpstorm

parent 1668b467
Aucune branche associée trouvée
Aucune étiquette associée trouvée
Aucune requête de fusion associée trouvée
......@@ -8,12 +8,14 @@ class Piwik_Archive_Parameters
* @var array
*/
private $idSites = array();
/**
* The list of Piwik_Period's to query archive data for.
*
* @var array
*/
private $periods = array();
/**
* Segment applied to the visits set.
*
......@@ -41,6 +43,16 @@ class Piwik_Archive_Parameters
$this->periods = $this->getAsNonEmptyArray($periods, 'periods');
}
public function getIdSites()
{
return $this->idSites;
}
public function setIdSites($idSites)
{
$this->idSites = $this->getAsNonEmptyArray($idSites, 'idSites');
}
private function getAsNonEmptyArray($array, $paramName)
{
if (!is_array($array)) {
......@@ -53,15 +65,5 @@ class Piwik_Archive_Parameters
return $array;
}
public function getIdSites()
{
return $this->idSites;
}
public function setIdSites($idSites)
{
$this->idSites = $this->getAsNonEmptyArray($idSites, 'idSites');
}
}
......@@ -85,7 +85,6 @@ class Piwik_ArchiveProcessor_Day extends Piwik_ArchiveProcessor
return $metrics;
}
protected function convertMetricsIdToName($data)
{
$metrics = array();
......
......@@ -26,6 +26,7 @@
class Piwik_DataAccess_ArchiveSelector
{
const NB_VISITS_RECORD_LOOKED_UP = "nb_visits";
const NB_VISITS_CONVERTED_RECORD_LOOKED_UP = "nb_visits_converted";
static public function getArchiveIdAndVisits(Piwik_Site $site, Piwik_Period $period, Piwik_Segment $segment, $minDatetimeArchiveProcessedUTC, $requestedPlugin)
......@@ -47,7 +48,6 @@ class Piwik_DataAccess_ArchiveSelector
$pluginOrVisitsSummary = array_unique($pluginOrVisitsSummary);
$sqlWhereArchiveName = self::getNameCondition($pluginOrVisitsSummary, $segment);
$sqlQuery = " SELECT idarchive, value, name, date1 as startDate
FROM " . Piwik_DataAccess_ArchiveTableCreator::getNumericTable($dateStart) . "``
WHERE idsite = ?
......@@ -69,8 +69,9 @@ class Piwik_DataAccess_ArchiveSelector
list($visits, $visitsConverted) = self::getVisitsMetricsFromResults($idArchive, $idArchiveVisitsSummary, $results);
if($visits === false
&& $idArchive === false) {
if ($visits === false
&& $idArchive === false
) {
return false;
}
......@@ -81,18 +82,20 @@ class Piwik_DataAccess_ArchiveSelector
{
$visits = $visitsConverted = false;
$archiveWithVisitsMetricsWasFound = ($idArchiveVisitsSummary !== false);
if($archiveWithVisitsMetricsWasFound) {
if ($archiveWithVisitsMetricsWasFound) {
$visits = $visitsConverted = 0;
}
foreach ($results as $result) {
if (in_array($result['idarchive'], array($idArchive, $idArchiveVisitsSummary))) {
$value = (int)$result['value'];
if (empty($visits)
&& $result['name'] == self::NB_VISITS_RECORD_LOOKED_UP) {
&& $result['name'] == self::NB_VISITS_RECORD_LOOKED_UP
) {
$visits = $value;
}
if (empty($visitsConverted)
&& $result['name'] == self::NB_VISITS_CONVERTED_RECORD_LOOKED_UP) {
&& $result['name'] == self::NB_VISITS_CONVERTED_RECORD_LOOKED_UP
) {
$visitsConverted = $value;
}
}
......@@ -117,7 +120,7 @@ class Piwik_DataAccess_ArchiveSelector
/**
* Queries and returns archive IDs for a set of sites, periods, and a segment.
*
*
* @param array $siteIds
* @param array $periods
* @param Piwik_Segment $segment
......@@ -135,8 +138,8 @@ class Piwik_DataAccess_ArchiveSelector
FROM %s
WHERE period = ?
AND %s
AND ". self::getNameCondition($plugins, $segment) ."
AND idsite IN (".implode(',', $siteIds).")
AND " . self::getNameCondition($plugins, $segment) . "
AND idsite IN (" . implode(',', $siteIds) . ")
GROUP BY idsite, date1, date2";
$monthToPeriods = array();
......@@ -162,23 +165,23 @@ class Piwik_DataAccess_ArchiveSelector
foreach ($periods as $period) {
$dateStrs[] = $period->getDateStart()->toString('Y-m-d');
}
$dateCondition = "date1 IN ('".implode("','", $dateStrs)."')";
$dateCondition = "date1 IN ('" . implode("','", $dateStrs) . "')";
}
$sql = sprintf($getArchiveIdsSql, $table, $dateCondition);
// get the archive IDs
foreach (Piwik_FetchAll($sql, $bind) as $row) {
$archiveName = $row['name'];
//FIXMEA duplicate with Archive.php
$dateStr = $row['date1'].",".$row['date2'];
$dateStr = $row['date1'] . "," . $row['date2'];
$result[$archiveName][$dateStr][] = $row['idarchive'];
}
}
return $result;
}
......@@ -198,14 +201,14 @@ class Piwik_DataAccess_ArchiveSelector
$inNames = Piwik_Common::getSqlStringFieldsArray($recordNames);
if ($loadAllSubtables) {
$name = reset($recordNames);
// select blobs w/ name like "$name_[0-9]+" w/o using RLIKE
$nameEnd = strlen($name) + 2;
$whereNameIs = "(name = ?
OR (name LIKE ?
AND SUBSTRING(name, $nameEnd, 1) >= '0'
AND SUBSTRING(name, $nameEnd, 1) <= '9') )";
$bind = array($name, $name.'%');
$bind = array($name, $name . '%');
} else {
$whereNameIs = "name IN ($inNames)";
$bind = array_values($recordNames);
......@@ -219,12 +222,12 @@ class Piwik_DataAccess_ArchiveSelector
// get data from every table we're querying
$rows = array();
foreach ($archiveIds as $period => $ids) {
if(empty($ids)) {
if (empty($ids)) {
throw new Exception("Unexpected: id archive not found for period '$period' '");
}
// $period = "2009-01-04,2009-01-04",
$date = Piwik_Date::factory( substr($period, 0, 10) );
if($archiveDataType == 'numeric') {
$date = Piwik_Date::factory(substr($period, 0, 10));
if ($archiveDataType == 'numeric') {
$table = Piwik_DataAccess_ArchiveTableCreator::getNumericTable($date);
} else {
$table = Piwik_DataAccess_ArchiveTableCreator::getBlobTable($date);
......@@ -234,14 +237,14 @@ class Piwik_DataAccess_ArchiveSelector
$rows[] = $row;
}
}
return $rows;
}
/**
* Returns the SQL condition used to find successfully completed archives that
* this instance is querying for.
*
*
* @param array $plugins
* @param Piwik_Segment $segment
* @return string
......@@ -252,21 +255,20 @@ class Piwik_DataAccess_ArchiveSelector
// if it was completed
$doneFlags = Piwik_ArchiveProcessor_Rules::getDoneFlags($plugins, $segment);
$allDoneFlags = "'".implode("','", $doneFlags)."'";
$allDoneFlags = "'" . implode("','", $doneFlags) . "'";
// create the SQL to find archives that are DONE
return "(name IN ($allDoneFlags)) AND ".
" (value = '".Piwik_ArchiveProcessor::DONE_OK."' OR ".
" value = '".Piwik_ArchiveProcessor::DONE_OK_TEMPORARY."')";
return "(name IN ($allDoneFlags)) AND " .
" (value = '" . Piwik_ArchiveProcessor::DONE_OK . "' OR " .
" value = '" . Piwik_ArchiveProcessor::DONE_OK_TEMPORARY . "')";
}
static public function purgeOutdatedArchives(Piwik_Date $dateStart, $purgeArchivesOlderThan)
{
$numericTable = Piwik_DataAccess_ArchiveTableCreator::getNumericTable($dateStart);
$blobTable = Piwik_DataAccess_ArchiveTableCreator::getBlobTable($dateStart);
$idArchivesToDelete = self::getTemporaryArchiveIdsOlderThan($numericTable, $purgeArchivesOlderThan);
if(!empty($idArchivesToDelete)) {
if (!empty($idArchivesToDelete)) {
self::deleteArchiveIds($numericTable, $blobTable, $idArchivesToDelete);
}
Piwik::log("Purging temporary archives: done [ purged archives older than $purgeArchivesOlderThan from $blobTable and $numericTable ] [Deleted IDs: " . implode(',', $idArchivesToDelete) . "]");
......@@ -312,7 +314,7 @@ class Piwik_DataAccess_ArchiveSelector
AND ts_archived < ?)
OR value = " . Piwik_ArchiveProcessor::DONE_ERROR . ")";
$result = Piwik_FetchAll($query,array($purgeArchivesOlderThan));
$result = Piwik_FetchAll($query, array($purgeArchivesOlderThan));
$idArchivesToDelete = array();
if (!empty($result)) {
foreach ($result as $row) {
......
......@@ -15,6 +15,7 @@ class Piwik_DataAccess_ArchiveTableCreator
{
return self::getTable($date, "numeric");
}
static public function getBlobTable(Piwik_Date $date)
{
return self::getTable($date, "blob");
......
......@@ -43,7 +43,7 @@ class Piwik_DataAccess_ArchiveWriter
public function getIdArchive()
{
if($this->idArchive === false) {
if ($this->idArchive === false) {
throw new Exception("Must call allocateNewArchiveId() first");
}
return $this->idArchive;
......@@ -133,9 +133,9 @@ class Piwik_DataAccess_ArchiveWriter
$this->logArchiveStatusAsFinal();
$this->releaseArchiveProcessorLock();
if($this->period->getLabel() != 'day') {
if ($this->period->getLabel() != 'day') {
$purgeArchivesOlderThan = Piwik_ArchiveProcessor_Rules::shouldPurgeOutdatedArchives($this->dateStart);
if($purgeArchivesOlderThan) {
if ($purgeArchivesOlderThan) {
Piwik_DataAccess_ArchiveSelector::purgeOutdatedArchives($this->dateStart, $purgeArchivesOlderThan);
}
}
......@@ -251,6 +251,4 @@ class Piwik_DataAccess_ArchiveWriter
{
return ($value === '0' || $value === false || $value === 0 || $value === 0.0);
}
}
\ No newline at end of file
......@@ -16,18 +16,31 @@
class Piwik_DataAccess_LogAggregator
{
const LOG_VISIT_TABLE = 'log_visit';
const LOG_ACTIONS_TABLE = 'log_link_visit_action';
const LOG_CONVERSION_TABLE = "log_conversion";
const REVENUE_SUBTOTAL_FIELD = 'revenue_subtotal';
const REVENUE_TAX_FIELD = 'revenue_tax';
const REVENUE_SHIPPING_FIELD = 'revenue_shipping';
const REVENUE_DISCOUNT_FIELD = 'revenue_discount';
const TOTAL_REVENUE_FIELD = 'revenue';
const ITEMS_COUNT_FIELD = "items";
const CONVERSION_DATETIME_FIELD = "server_time";
const ACTION_DATETIME_FIELD = "server_time";
const VISIT_DATETIME_FIELD = 'visit_last_action_time';
const IDGOAL_FIELD = 'idgoal';
const FIELDS_SEPARATOR = ", \n\t\t\t";
/** @var \Piwik_Date */
......
0% Chargement en cours ou .
You are about to add 0 people to the discussion. Proceed with caution.
Veuillez vous inscrire ou vous pour commenter