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/PluginBundle/Command/ |
<?php
namespace Mautic\PluginBundle\Command;
use Mautic\PluginBundle\Helper\IntegrationHelper;
use Mautic\PluginBundle\Integration\UnifiedIntegrationInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Contracts\Translation\TranslatorInterface;
class FetchLeadsCommand extends Command
{
public function __construct(
private TranslatorInterface $translator,
private IntegrationHelper $integrationHelper
) {
parent::__construct();
}
protected function configure()
{
$this
->setName('mautic:integration:fetchleads')
->setAliases(
[
'mautic:integration:synccontacts',
]
)
->addOption(
'--integration',
'-i',
InputOption::VALUE_REQUIRED,
'Fetch leads from integration. Integration must be enabled and authorised.',
null
)
->addOption('--start-date', '-d', InputOption::VALUE_REQUIRED, 'Set start date for updated values.')
->addOption(
'--end-date',
'-t',
InputOption::VALUE_REQUIRED,
'Set end date for updated values.'
)
->addOption(
'--fetch-all',
null,
InputOption::VALUE_NONE,
'Get all CRM contacts whatever the date is. Should be used at instance initialization only'
)
->addOption(
'--time-interval',
'-a',
InputOption::VALUE_OPTIONAL,
'Send time interval to check updates on Salesforce, it should be a correct php formatted time interval in the past eg:(10 minutes)'
)
->addOption(
'--limit',
'-l',
InputOption::VALUE_OPTIONAL,
'Number of records to process when syncing objects',
100
)
->addOption('--force', '-f', InputOption::VALUE_NONE, 'Force execution even if another process is assumed running.');
parent::configure();
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
$integration = $input->getOption('integration');
$startDate = $input->getOption('start-date');
$endDate = $input->getOption('end-date');
$interval = $input->getOption('time-interval');
$limit = $input->getOption('limit');
$fetchAll = $input->getOption('fetch-all');
$leadsExecuted = $contactsExecuted = null;
// @TODO Since integration is mandatory it should really be turned into an agument, but that would not be B.C.
if (!$integration) {
throw new \RuntimeException('An integration must be specified');
}
$integrationObject = $this->integrationHelper->getIntegrationObject($integration);
if (!$integrationObject instanceof UnifiedIntegrationInterface) {
$availableIntegrations = array_filter($this->integrationHelper->getIntegrationObjects(),
fn (UnifiedIntegrationInterface $availableIntegration) => $availableIntegration->isConfigured());
throw new \RuntimeException(sprintf('The Integration "%s" is not one of the available integrations (%s)', $integration, implode(', ', array_keys($availableIntegrations))));
}
if (!$interval) {
$interval = '15 minutes';
}
$startDate = !$startDate ? date('c', strtotime('-'.$interval)) : date('c', strtotime($startDate));
$endDate = !$endDate ? date('c') : date('c', strtotime($endDate));
if (!$startDate || !$endDate) {
$output->writeln(sprintf('<info>Invalid date rage given %s -> %s</info>', $startDate, $endDate));
return 255;
}
$integrationObject = $this->integrationHelper->getIntegrationObject($integration);
if (!$integrationObject->isAuthorized()) {
$output->writeln(sprintf('<error>ERROR:</error> <info>'.$this->translator->trans('mautic.plugin.command.notauthorized').'</info>', $integration));
return 255;
}
// Tell audit log to use integration name
define('MAUTIC_AUDITLOG_USER', $integration);
$config = $integrationObject->mergeConfigToFeatureSettings();
$supportedFeatures = $integrationObject->getIntegrationSettings()->getSupportedFeatures();
defined('MAUTIC_CONSOLE_VERBOSITY') or define('MAUTIC_CONSOLE_VERBOSITY', $output->getVerbosity());
if (!isset($config['objects'])) {
$config['objects'] = [];
}
$params['start'] = $startDate;
$params['end'] = $endDate;
$params['limit'] = $limit;
$params['fetchAll'] = $fetchAll;
$params['output'] = $output;
$integrationObject->setCommandParameters($params);
// set this constant to ensure that all contacts have the same date modified time and date synced time to prevent a pull/push loop
define('MAUTIC_DATE_MODIFIED_OVERRIDE', time());
if (isset($supportedFeatures) && in_array('get_leads', $supportedFeatures)) {
if (null !== $integrationObject && method_exists($integrationObject, 'getLeads') && isset($config['objects'])) {
$output->writeln('<info>'.$this->translator->trans('mautic.plugin.command.fetch.leads', ['%integration%' => $integration]).'</info>');
$output->writeln('<comment>'.$this->translator->trans('mautic.plugin.command.fetch.leads.starting').'</comment>');
// Handle case when integration object are named "Contacts" and "Leads"
$leadObjectName = 'Lead';
if (in_array('Leads', $config['objects'])) {
$leadObjectName = 'Leads';
}
$contactObjectName = 'Contact';
if (in_array(strtolower('Contacts'), array_map(fn ($i): string => strtolower($i), $config['objects']), true)) {
$contactObjectName = 'Contacts';
}
$updated = $created = $processed = 0;
if (in_array($leadObjectName, $config['objects'])) {
$leadList = [];
$results = $integrationObject->getLeads($params, null, $leadsExecuted, $leadList, $leadObjectName);
if (is_array($results)) {
[$justUpdated, $justCreated] = $results;
$updated += (int) $justUpdated;
$created += (int) $justCreated;
} else {
$processed += (int) $results;
}
}
if (in_array(strtolower($contactObjectName), array_map(fn ($i): string => strtolower($i), $config['objects']), true)) {
$output->writeln('');
$output->writeln('<comment>'.$this->translator->trans('mautic.plugin.command.fetch.contacts.starting').'</comment>');
$contactList = [];
$results = $integrationObject->getLeads($params, null, $contactsExecuted, $contactList, $contactObjectName);
if (is_array($results)) {
[$justUpdated, $justCreated] = $results;
$updated += (int) $justUpdated;
$created += (int) $justCreated;
} else {
$processed += (int) $results;
}
}
$output->writeln('');
if ($processed) {
$output->writeln(
'<comment>'.$this->translator->trans('mautic.plugin.command.fetch.leads.events_executed', ['%events%' => $processed])
.'</comment>'."\n"
);
} else {
$output->writeln(
'<comment>'.$this->translator->trans(
'mautic.plugin.command.fetch.leads.events_executed_breakout',
['%updated%' => $updated, '%created%' => $created]
)
.'</comment>'."\n"
);
}
}
if (null !== $integrationObject && method_exists($integrationObject, 'getCompanies') && isset($config['objects'])
&& in_array(
'company',
$config['objects']
)
) {
$updated = $created = $processed = 0;
$output->writeln('<info>'.$this->translator->trans('mautic.plugin.command.fetch.companies', ['%integration%' => $integration]).'</info>');
$output->writeln('<comment>'.$this->translator->trans('mautic.plugin.command.fetch.companies.starting').'</comment>');
$results = $integrationObject->getCompanies($params);
if (is_array($results)) {
[$justUpdated, $justCreated] = $results;
$updated += (int) $justUpdated;
$created += (int) $justCreated;
} else {
$processed += (int) $results;
}
$output->writeln('');
if ($processed) {
$output->writeln(
'<comment>'.$this->translator->trans('mautic.plugin.command.fetch.companies.events_executed', ['%events%' => $processed])
.'</comment>'."\n"
);
} else {
$output->writeln(
'<comment>'.$this->translator->trans(
'mautic.plugin.command.fetch.companies.events_executed_breakout',
['%updated%' => $updated, '%created%' => $created]
)
.'</comment>'."\n"
);
}
}
}
if (isset($supportedFeatures) && in_array('push_leads', $supportedFeatures) && method_exists($integrationObject, 'pushLeads')) {
$output->writeln('<info>'.$this->translator->trans('mautic.plugin.command.pushing.leads', ['%integration%' => $integration]).'</info>');
$result = $integrationObject->pushLeads($params);
$ignored = 0;
if (4 === count($result)) {
[$updated, $created, $errored, $ignored] = $result;
} elseif (3 === count($result)) {
[$updated, $created, $errored] = $result;
} else {
$errored = '?';
[$updated, $created] = $result;
}
$output->writeln(
'<comment>'.$this->translator->trans(
'mautic.plugin.command.fetch.pushing.leads.events_executed',
[
'%updated%' => $updated,
'%created%' => $created,
'%errored%' => $errored,
'%ignored%' => $ignored,
]
)
.'</comment>'."\n"
);
if (in_array('push_companies', $supportedFeatures) && method_exists($integrationObject, 'pushCompanies')) {
$output->writeln('<info>'.$this->translator->trans('mautic.plugin.command.pushing.companies', ['%integration%' => $integration]).'</info>');
$result = $integrationObject->pushCompanies($params);
$ignored = 0;
if (4 === count($result)) {
[$updated, $created, $errored, $ignored] = $result;
} elseif (3 === count($result)) {
[$updated, $created, $errored] = $result;
} else {
$errored = '?';
[$updated, $created] = $result;
}
$output->writeln(
'<comment>'.$this->translator->trans(
'mautic.plugin.command.fetch.pushing.companies.events_executed',
[
'%updated%' => $updated,
'%created%' => $created,
'%errored%' => $errored,
'%ignored%' => $ignored,
]
)
.'</comment>'."\n"
);
}
}
return Command::SUCCESS;
}
protected static $defaultDescription = 'Fetch leads from integration.';
}