Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/mautic.corals.io/app/bundles/EmailBundle/Controller/ |
<?php
namespace Mautic\EmailBundle\Controller;
use Mautic\CacheBundle\Cache\CacheProvider;
use Mautic\CoreBundle\Controller\AjaxController as CommonAjaxController;
use Mautic\CoreBundle\Controller\AjaxLookupControllerTrait;
use Mautic\CoreBundle\Controller\VariantAjaxControllerTrait;
use Mautic\CoreBundle\Helper\CoreParametersHelper;
use Mautic\CoreBundle\Helper\InputHelper;
use Mautic\CoreBundle\Helper\UserHelper;
use Mautic\EmailBundle\Helper\PlainTextHelper;
use Mautic\EmailBundle\Mailer\Message\MauticMessage;
use Mautic\EmailBundle\Model\EmailModel;
use Mautic\EmailBundle\Stats\EmailDependencies;
use Mautic\PageBundle\Form\Type\AbTestPropertiesType;
use Symfony\Component\Form\FormFactoryInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
use Symfony\Component\Mailer\Transport\TransportInterface;
use Symfony\Component\Mime\Address;
class AjaxController extends CommonAjaxController
{
use VariantAjaxControllerTrait;
use AjaxLookupControllerTrait;
/**
* @return JsonResponse
*/
public function getAbTestFormAction(Request $request, FormFactoryInterface $formFactory)
{
return $this->getAbTestForm(
$request,
$formFactory,
'email',
AbTestPropertiesType::class,
'email_abtest_settings',
'emailform',
'@MauticEmail/AbTest/form.html.twig',
['@MauticEmail/AbTest/form.html.twig', '@MauticEmail/FormTheme/Email/layout.html.twig']
);
}
public function sendBatchAction(Request $request): JsonResponse
{
$dataArray = ['success' => 0];
/** @var EmailModel $model */
$model = $this->getModel('email');
$objectId = $request->request->get('id', 0);
$pending = $request->request->get('pending', 0);
$limit = $request->request->get('batchlimit', 100);
if ($objectId && $entity = $model->getEntity($objectId)) {
$dataArray['success'] = 1;
$session = $request->getSession();
$progress = $session->get('mautic.email.send.progress', [0, (int) $pending]);
$stats = $session->get('mautic.email.send.stats', ['sent' => 0, 'failed' => 0, 'failedRecipients' => []]);
$inProgress = $session->get('mautic.email.send.active', false);
if ($pending && !$inProgress && $entity->isPublished()) {
$session->set('mautic.email.send.active', true);
[$batchSentCount, $batchFailedCount, $batchFailedRecipients] = $model->sendEmailToLists($entity, null, $limit);
$progress[0] += ($batchSentCount + $batchFailedCount);
$stats['sent'] += $batchSentCount;
$stats['failed'] += $batchFailedCount;
foreach ($batchFailedRecipients as $emails) {
$stats['failedRecipients'] = $stats['failedRecipients'] + $emails;
}
$session->set('mautic.email.send.progress', $progress);
$session->set('mautic.email.send.stats', $stats);
$session->set('mautic.email.send.active', false);
}
$dataArray['percent'] = ($progress[1]) ? ceil(($progress[0] / $progress[1]) * 100) : 100;
$dataArray['progress'] = $progress;
$dataArray['stats'] = $stats;
}
return $this->sendJsonResponse($dataArray);
}
/**
* Called by parent::getBuilderTokensAction().
*
* @return array
*/
protected function getBuilderTokens($query)
{
/** @var EmailModel $model */
$model = $this->getModel('email');
return $model->getBuilderComponents(null, ['tokens'], (string) $query);
}
public function generatePlaintTextAction(Request $request): JsonResponse
{
$custom = $request->request->get('custom');
$parser = new PlainTextHelper(
[
'base_url' => $request->getSchemeAndHttpHost().$request->getBasePath(),
]
);
$dataArray = [
'text' => $parser->setHtml($custom)->getText(),
];
return $this->sendJsonResponse($dataArray);
}
public function getAttachmentsSizeAction(Request $request): JsonResponse
{
$assets = $request->query->get('assets') ?? [];
$size = 0;
if ($assets) {
/** @var \Mautic\AssetBundle\Model\AssetModel $assetModel */
$assetModel = $this->getModel('asset');
$size = $assetModel->getTotalFilesize($assets);
}
return $this->sendJsonResponse(['size' => $size]);
}
/**
* Tests monitored email connection settings.
*/
public function testMonitoredEmailServerConnectionAction(Request $request): JsonResponse
{
$dataArray = ['success' => 0, 'message' => ''];
if ($this->user->isAdmin()) {
$settings = $request->request->all();
if (empty($settings['password'])) {
$existingMonitoredSettings = $this->coreParametersHelper->get('monitored_email');
if (is_array($existingMonitoredSettings) && (!empty($existingMonitoredSettings[$settings['mailbox']]['password']))) {
$settings['password'] = $existingMonitoredSettings[$settings['mailbox']]['password'];
}
}
/** @var \Mautic\EmailBundle\MonitoredEmail\Mailbox $helper */
$helper = $this->factory->getHelper('mailbox');
try {
$helper->setMailboxSettings($settings);
$folders = $helper->getListingFolders();
if (!empty($folders)) {
$dataArray['folders'] = '';
foreach ($folders as $folder) {
$dataArray['folders'] .= "<option value=\"$folder\">$folder</option>\n";
}
}
$dataArray['success'] = 1;
$dataArray['message'] = $this->translator->trans('mautic.core.success');
} catch (\Exception $e) {
$dataArray['message'] = $this->translator->trans($e->getMessage());
}
}
return $this->sendJsonResponse($dataArray);
}
public function sendTestEmailAction(TransportInterface $transport, UserHelper $userHelper, CoreParametersHelper $parametersHelper): Response
{
$user = $userHelper->getUser();
$email = (new MauticMessage())
->subject($this->translator->trans('mautic.email.config.mailer.transport.test_send.subject'))
->text($this->translator->trans('mautic.email.config.mailer.transport.test_send.body'))
->from(new Address($parametersHelper->get('mailer_from_email'), $parametersHelper->get('mailer_from_name') ?: ''))
->to(new Address($user->getEmail(), trim($user->getFirstName().' '.$user->getLastName()) ?: ''));
$success = 1;
$message = $this->translator->trans('mautic.core.success');
try {
$transport->send($email);
} catch (TransportExceptionInterface $e) {
$success = 0;
$message = $e->getMessage();
}
return $this->sendJsonResponse(['success' => $success, 'message' => $message]);
}
public function getEmailCountStatsAction(Request $request): JsonResponse
{
/** @var EmailModel $model */
$model = $this->getModel('email');
$id = $request->query->get('id');
$ids = $request->query->get('ids');
// Support for legacy calls
if (!$ids && $id) {
$ids = [$id];
}
$data = [];
foreach ($ids as $id) {
if ($email = $model->getEntity($id)) {
$pending = $model->getPendingLeads($email, null, true);
$queued = $model->getQueuedCounts($email);
$data[] = [
'id' => $email->getId(),
'pending' => 'list' === $email->getEmailType() && $pending ? $this->translator->trans(
'mautic.email.stat.leadcount',
['%count%' => $pending]
) : 0,
'queued' => ($queued) ? $this->translator->trans('mautic.email.stat.queued', ['%count%' => $queued]) : 0,
'sentCount' => $this->translator->trans('mautic.email.stat.sentcount', ['%count%' => $email->getSentCount(true)]),
'readCount' => $this->translator->trans('mautic.email.stat.readcount', ['%count%' => $email->getReadCount(true)]),
'readPercent' => $this->translator->trans('mautic.email.stat.readpercent', ['%count%' => $email->getReadPercentage(true)]),
];
}
}
// Support for legacy calls
if ($request->get('id') && !empty($data[0])) {
$data = $data[0];
} else {
$data = [
'success' => 1,
'stats' => $data,
];
}
return new JsonResponse($data);
}
public function getEmailDeliveredCountAction(Request $request, CacheProvider $cacheProvider): JsonResponse
{
$emailId = (int) InputHelper::clean($request->query->get('id'));
if (0 === $emailId) {
return $this->sendJsonResponse([
'success' => 0,
'message' => $this->translator->trans('mautic.core.error.badrequest'),
], 400);
}
$cacheTimeout = (int) $this->coreParametersHelper->get('cached_data_timeout');
$cacheItem = $cacheProvider->getItem('email.stats.delivered.'.$emailId);
if ($cacheItem->isHit()) {
$deliveredCount = $cacheItem->get();
} else {
/** @var EmailModel $model */
$model = $this->getModel('email');
$email = $model->getEntity($emailId);
if (null === $email) {
return $this->sendJsonResponse([
'success' => 0,
'message' => $this->translator->trans('mautic.api.call.notfound'),
], 404);
}
$deliveredCount = $model->getDeliveredCount($email);
$cacheItem->set($deliveredCount);
$cacheItem->expiresAfter($cacheTimeout * 60);
$cacheProvider->save($cacheItem);
}
return $this->sendJsonResponse([
'success' => 1,
'delivered' => $deliveredCount,
]);
}
public function heatmapAction(Request $request, EmailModel $model): JsonResponse
{
$emailId = (int) $request->query->get('id');
$email = $model->getEntity($emailId);
if (null === $email) {
return $this->sendJsonResponse([
'message' => $this->translator->trans('mautic.api.call.notfound'),
], 404);
}
if (!$this->security->hasEntityAccess(
'email:emails:viewown',
'email:emails:viewother',
$email->getCreatedBy()
)
) {
return $this->accessDenied();
}
$content = $email->getCustomHtml();
$clickStats = $model->getEmailClickStats($emailId);
$totalUniqueClicks = array_sum(array_column($clickStats, 'unique_hits'));
$totalClicks = array_sum(array_column($clickStats, 'hits'));
foreach ($clickStats as &$stat) {
$stat['unique_hits_rate'] = round($totalUniqueClicks > 0 ? ($stat['unique_hits'] / $totalUniqueClicks) : 0, 4);
$stat['unique_hits_text'] = $this->translator->trans('mautic.email.heatmap.clicks', ['%count%' => $stat['unique_hits']]);
$stat['hits_rate'] = round($totalClicks > 0 ? ($stat['hits'] / $totalClicks) : 0, 4);
$stat['hits_text'] = $this->translator->trans('mautic.email.heatmap.clicks', ['%count%' => $stat['hits']]);
}
$legendTemplate = $this->renderView('@MauticEmail/Heatmap/heatmap_legend.html.twig', [
'totalClicks' => $totalClicks,
'totalUniqueClicks' => $totalUniqueClicks,
]);
return $this->sendJsonResponse([
'content' => $content,
'clickStats' => $clickStats,
'totalUniqueClicks' => $totalUniqueClicks,
'totalClicks' => $totalClicks,
'legendTemplate' => $legendTemplate,
]);
}
public function getEmailUsagesAction(Request $request, EmailDependencies $emailDependencies): JsonResponse
{
$emailId = (int) $request->query->get('id');
if (0 === $emailId) {
return $this->sendJsonResponse([
'message' => $this->translator->trans('mautic.core.error.badrequest'),
], 400);
}
$usagesHtml = $this->renderView('@MauticCore/Helper/usage.html.twig', [
'title' => $this->translator->trans('mautic.email.usages'),
'stats' => $emailDependencies->getChannelsIds($emailId),
'noUsages' => $this->translator->trans('mautic.email.no_usages'),
]);
return $this->sendJsonResponse([
'usagesHtml' => $usagesHtml,
]);
}
}