Spaces:
No application file
No application file
File size: 2,868 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 |
<?php
namespace Mautic\ChannelBundle\Command;
use Mautic\ChannelBundle\Model\MessageQueueModel;
use Mautic\CoreBundle\Command\ModeratedCommand;
use Mautic\CoreBundle\Helper\CoreParametersHelper;
use Mautic\CoreBundle\Helper\PathsHelper;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Contracts\Translation\TranslatorInterface;
class ProcessMarketingMessagesQueueCommand extends ModeratedCommand
{
public function __construct(
private TranslatorInterface $translator,
private MessageQueueModel $messageQueueModel,
PathsHelper $pathsHelper,
CoreParametersHelper $coreParametersHelper
) {
parent::__construct($pathsHelper, $coreParametersHelper);
}
protected function configure()
{
$this
->setName('mautic:messages:send')
->setAliases(
[
'mautic:campaigns:messagequeue',
'mautic:campaigns:messages',
]
)
->addOption(
'--channel',
'-c',
InputOption::VALUE_OPTIONAL,
'Channel to use for sending messages i.e. email, sms.',
null
)
->addOption('--channel-id', '-i', InputOption::VALUE_REQUIRED, 'The ID of the message i.e. email ID, sms ID.')
->addOption('--message-id', '-m', InputOption::VALUE_REQUIRED, 'ID of a specific queued message');
parent::configure();
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
$processed = 0;
$channel = $input->getOption('channel');
$channelId = $input->getOption('channel-id');
$messageId = $input->getOption('message-id');
$key = $channel.$channelId.$messageId;
if (!$this->checkRunStatus($input, $output, $key)) {
return \Symfony\Component\Console\Command\Command::SUCCESS;
}
$output->writeln('<info>'.$this->translator->trans('mautic.campaign.command.process.messages').'</info>');
if ($messageId) {
if ($message = $this->messageQueueModel->getEntity($messageId)) {
$processed = intval($this->messageQueueModel->processMessageQueue($message));
}
} else {
$processed = intval($this->messageQueueModel->sendMessages($channel, $channelId));
}
$output->writeln('<comment>'.$this->translator->trans('mautic.campaign.command.messages.sent', ['%events%' => $processed]).'</comment>'."\n");
$this->completeRun();
return \Symfony\Component\Console\Command\Command::SUCCESS;
}
protected static $defaultDescription = 'Process sending of messages queue.';
}
|