Spaces:
No application file
No application file
File size: 3,879 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 |
<?php
namespace Mautic\CampaignBundle\Executioner\Event;
use Doctrine\Common\Collections\ArrayCollection;
use Mautic\CampaignBundle\Entity\Event;
use Mautic\CampaignBundle\Entity\LeadEventLog;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\AbstractEventAccessor;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\DecisionAccessor;
use Mautic\CampaignBundle\Executioner\Dispatcher\DecisionDispatcher;
use Mautic\CampaignBundle\Executioner\Exception\CannotProcessEventException;
use Mautic\CampaignBundle\Executioner\Exception\DecisionNotApplicableException;
use Mautic\CampaignBundle\Executioner\Logger\EventLogger;
use Mautic\CampaignBundle\Executioner\Result\EvaluatedContacts;
use Mautic\LeadBundle\Entity\Lead;
class DecisionExecutioner implements EventInterface
{
public const TYPE = 'decision';
public function __construct(
private EventLogger $eventLogger,
private DecisionDispatcher $dispatcher
) {
}
/**
* @param mixed $passthrough
* @param string|null $channel
* @param int|null $channelId
*
* @throws CannotProcessEventException
* @throws DecisionNotApplicableException
*/
public function evaluateForContact(DecisionAccessor $config, Event $event, Lead $contact, $passthrough = null, $channel = null, $channelId = null): void
{
if (Event::TYPE_DECISION !== $event->getEventType()) {
throw new CannotProcessEventException('Cannot process event ID '.$event->getId().' as a decision.');
}
$log = $this->eventLogger->buildLogEntry($event, $contact);
$log->setChannel($channel);
$log->setChannelId($channelId);
$decisionEvent = $this->dispatcher->dispatchRealTimeEvent($config, $log, $passthrough);
if (!$decisionEvent->wasDecisionApplicable()) {
throw new DecisionNotApplicableException('evaluation failed');
}
$this->eventLogger->persistLog($log);
}
/**
* @throws CannotProcessEventException
*/
public function execute(AbstractEventAccessor $config, ArrayCollection $logs): EvaluatedContacts
{
\assert($config instanceof DecisionAccessor);
$evaluatedContacts = new EvaluatedContacts();
$failedLogs = [];
/** @var LeadEventLog $log */
foreach ($logs as $log) {
if (Event::TYPE_DECISION !== $log->getEvent()->getEventType()) {
throw new CannotProcessEventException('Event ID '.$log->getEvent()->getId().' is not a decision');
}
try {
/* @var DecisionAccessor $config */
$this->dispatchEvent($config, $log);
$evaluatedContacts->pass($log->getLead());
// Update the date triggered timestamp
$log->setDateTriggered(new \DateTime());
} catch (DecisionNotApplicableException) {
// Fail the contact but remove the log from being processed upstream
// active/positive/green path while letting the InactiveExecutioner handle the inactive/negative/red paths
$failedLogs[] = $log;
$evaluatedContacts->fail($log->getLead());
}
}
$this->dispatcher->dispatchDecisionResultsEvent($config, $logs, $evaluatedContacts);
// Remove the logs
foreach ($failedLogs as $log) {
$logs->removeElement($log);
}
return $evaluatedContacts;
}
/**
* @throws DecisionNotApplicableException
*/
private function dispatchEvent(DecisionAccessor $config, LeadEventLog $log): void
{
$decisionEvent = $this->dispatcher->dispatchEvaluationEvent($config, $log);
if (!$decisionEvent->wasDecisionApplicable()) {
throw new DecisionNotApplicableException('evaluation failed');
}
}
}
|