Spaces:
No application file
No application file
File size: 3,677 Bytes
d2897cd |
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 |
<?php
namespace Mautic\EmailBundle\Stats\Helper;
use Doctrine\DBAL\ArrayParameterType;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Query\QueryBuilder;
use Mautic\CoreBundle\Doctrine\Provider\GeneratedColumnsProviderInterface;
use Mautic\CoreBundle\Helper\Chart\ChartQuery;
use Mautic\CoreBundle\Helper\Chart\DateRangeUnitTrait;
use Mautic\CoreBundle\Helper\UserHelper;
use Mautic\EmailBundle\Stats\FetchOptions\EmailStatOptions;
use Mautic\StatsBundle\Aggregate\Collection\StatCollection;
use Mautic\StatsBundle\Aggregate\Collector;
abstract class AbstractHelper implements StatHelperInterface
{
use FilterTrait;
use DateRangeUnitTrait;
public function __construct(
private Collector $collector,
Connection $connection,
protected GeneratedColumnsProviderInterface $generatedColumnsProvider,
private UserHelper $userHelper
) {
$this->connection = $connection;
}
/**
* @return array
*
* @throws \Exception
*/
public function fetchStats(\DateTime $fromDateTime, \DateTime $toDateTime, EmailStatOptions $options)
{
$statCollection = $this->collector->fetchStats($this->getName(), $fromDateTime, $toDateTime, $options);
$calculator = $statCollection->getCalculator($fromDateTime, $toDateTime);
$stats = match ($this->getTimeUnitFromDateRange($fromDateTime, $toDateTime)) {
'Y' => $calculator->getSumsByYear(),
'm' => $calculator->getSumsByMonth(),
'W' => $calculator->getSumsByWeek(),
'd' => $calculator->getSumsByDay(),
default => $calculator->getCountsByHour(),
};
// Chart.js only care about the values
return array_values($stats->getStats());
}
/**
* @return ChartQuery
*/
protected function getQuery(\DateTime $fromDateTime, \DateTime $toDateTime)
{
$unit = $this->getTimeUnitFromDateRange($fromDateTime, $toDateTime);
if ('W' == $unit) { // We won't support week storage, we will store it by date
$unit = 'd';
}
$query = new ChartQuery($this->connection, $fromDateTime, $toDateTime, $unit);
$query->setGeneratedColumnProvider($this->generatedColumnsProvider);
return $query;
}
/**
* Joins the email table and limits created_by to currently logged in user.
*
* @param string $emailIdColumn
*/
protected function limitQueryToCreator(QueryBuilder $q, $emailIdColumn = 't.email_id')
{
$q->join('t', MAUTIC_TABLE_PREFIX.'emails', 'e', 'e.id = '.$emailIdColumn)
->andWhere('e.created_by = :userId')
->setParameter('userId', $this->userHelper->getUser()->getId());
}
/**
* @param string $column
* @param string $prefix
*/
protected function limitQueryToEmailIds(QueryBuilder $q, array $ids, $column, $prefix)
{
if (0 === count($ids)) {
return;
}
if (1 === count($ids)) {
$q->andWhere("$prefix.$column = :email_id");
$q->setParameter('email_id', $ids[0]);
return;
}
$q->andWhere("$prefix.$column IN (:email_ids)");
$q->setParameter('email_ids', $ids, ArrayParameterType::INTEGER);
}
/**
* @throws \Exception
*/
protected function fetchAndBindToCollection(QueryBuilder $q, StatCollection $statCollection)
{
$results = $q->executeQuery()->fetchAllAssociative();
foreach ($results as $result) {
$statCollection->addStatByDateTimeStringInUTC($result['date'], $result['count']);
}
}
}
|