setName('mautic:segments:update')
->setAliases(['mautic:segments:rebuild'])
->addOption(
'--batch-limit',
'-b',
InputOption::VALUE_OPTIONAL,
'Set batch size of contacts to process per round. Defaults to 300.',
300
)
->addOption(
'--max-contacts',
'-m',
InputOption::VALUE_OPTIONAL,
'Set max number of contacts to process per segment for this script execution. Defaults to all.',
false
)
->addOption(
'--list-id',
'-i',
InputOption::VALUE_OPTIONAL,
'Specific ID to rebuild. Defaults to all.',
false
)
->addOption(
'--timing',
'-tm',
InputOption::VALUE_OPTIONAL,
'Measure timing of build with output to CLI .',
false
)
->addOption(
'exclude',
'd',
InputOption::VALUE_IS_ARRAY | InputOption::VALUE_OPTIONAL,
'Exclude a specific segment from being rebuilt. Otherwise, all segments will be rebuilt.',
[]
);
parent::configure();
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
$id = $input->getOption('list-id');
$batch = $input->getOption('batch-limit');
$max = $input->getOption('max-contacts');
$enableTimeMeasurement = (bool) $input->getOption('timing');
$output = ($input->getOption('quiet')) ? new NullOutput() : $output;
$excludeSegments = $input->getOption('exclude');
if (!$this->checkRunStatus($input, $output, $id)) {
return \Symfony\Component\Console\Command\Command::SUCCESS;
}
if ($enableTimeMeasurement) {
$startTime = microtime(true);
}
if ($id) {
$list = $this->listModel->getEntity($id);
if (!$list) {
$output->writeln(''.$this->translator->trans('mautic.lead.list.rebuild.not_found', ['%id%' => $id]).'');
return \Symfony\Component\Console\Command\Command::FAILURE;
}
$this->rebuildSegment($list, $batch, $max, $output);
} else {
$filter = [
'iterable_mode' => true,
];
if (is_array($excludeSegments) && count($excludeSegments) > 0) {
$filter['filter'] = [
'force' => [
[
'expr' => 'notIn',
'column' => $this->listModel->getRepository()->getTableAlias().'.id',
'value' => $excludeSegments,
],
],
];
}
$leadLists = $this->listModel->getEntities($filter);
foreach ($leadLists as $leadList) {
$startTimeForSingleSegment = time();
$this->rebuildSegment($leadList, $batch, $max, $output);
if ($enableTimeMeasurement) {
$totalTime = round(microtime(true) - $startTimeForSingleSegment, 2);
$output->writeln(''.$this->translator->trans('mautic.lead.list.rebuild.contacts.time', ['%time%' => $totalTime]).''."\n");
}
unset($leadList);
}
unset($leadLists);
}
$this->completeRun();
if ($enableTimeMeasurement) {
$totalTime = round(microtime(true) - $startTime, 2);
$output->writeln(''.$this->translator->trans('mautic.lead.list.rebuild.total.time', ['%time%' => $totalTime]).''."\n");
}
return \Symfony\Component\Console\Command\Command::SUCCESS;
}
private function rebuildSegment(LeadList $segment, int $batch, int $max, OutputInterface $output): void
{
if ($segment->isPublished()) {
$output->writeln(''.$this->translator->trans('mautic.lead.list.rebuild.rebuilding', ['%id%' => $segment->getId()]).'');
$startTime = microtime(true);
$processed = $this->listModel->rebuildListLeads($segment, $batch, $max, $output);
$rebuildTime = round(microtime(true) - $startTime, 2);
if (0 >= (int) $max) {
// Only full segment rebuilds count
$segment->setLastBuiltDateToCurrentDatetime();
$segment->setLastBuiltTime($rebuildTime);
$this->listModel->saveEntity($segment);
}
$output->writeln(
''.$this->translator->trans('mautic.lead.list.rebuild.leads_affected', ['%leads%' => $processed]).''
);
}
}
protected static $defaultDescription = 'Update contacts in smart segments based on new contact data.';
}