![]() 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/PointBundle/EventListener/ |
<?php namespace Mautic\PointBundle\EventListener; use Mautic\LeadBundle\Entity\PointsChangeLogRepository; use Mautic\LeadBundle\Event\LeadEvent; use Mautic\LeadBundle\Event\LeadMergeEvent; use Mautic\LeadBundle\Event\LeadTimelineEvent; use Mautic\LeadBundle\Event\PointsChangeEvent; use Mautic\LeadBundle\LeadEvents; use Mautic\PointBundle\Entity\LeadPointLogRepository; use Mautic\PointBundle\Entity\LeadTriggerLogRepository; use Mautic\PointBundle\Model\TriggerModel; use Symfony\Component\EventDispatcher\EventSubscriberInterface; use Symfony\Contracts\Translation\TranslatorInterface; class LeadSubscriber implements EventSubscriberInterface { public function __construct( private TriggerModel $triggerModel, private TranslatorInterface $translator, private PointsChangeLogRepository $pointsChangeLogRepository, private LeadPointLogRepository $leadPointLogRepository, private LeadTriggerLogRepository $leadTriggerLogRepository ) { } public static function getSubscribedEvents(): array { return [ LeadEvents::LEAD_POINTS_CHANGE => ['onLeadPointsChange', 0], LeadEvents::TIMELINE_ON_GENERATE => ['onTimelineGenerate', 0], LeadEvents::LEAD_POST_MERGE => ['onLeadMerge', 0], LeadEvents::LEAD_POST_SAVE => ['onLeadSave', -1], ]; } /** * Trigger applicable events for the lead. */ public function onLeadPointsChange(PointsChangeEvent $event): void { $this->triggerModel->triggerEvents($event->getLead()); } /** * Handle point triggers for new leads (including 0 point triggers). */ public function onLeadSave(LeadEvent $event): void { if ($event->isNew()) { $this->triggerModel->triggerEvents($event->getLead()); } } /** * Compile events for the lead timeline. */ public function onTimelineGenerate(LeadTimelineEvent $event): void { // Set available event types $eventTypeKey = 'point.gained'; $eventTypeName = $this->translator->trans('mautic.point.event.gained'); $event->addEventType($eventTypeKey, $eventTypeName); $event->addSerializerGroup('pointList'); if (!$event->isApplicable($eventTypeKey)) { return; } $logs = $this->pointsChangeLogRepository->getLeadTimelineEvents($event->getLeadId(), $event->getQueryOptions()); // Add to counter $event->addToCounter($eventTypeKey, $logs); if (!$event->isEngagementCount()) { // Add the logs to the event array foreach ($logs['results'] as $log) { $eventLabel = $log['eventName'].' / '.$log['delta']; if (!empty($log['groupName'])) { $eventLabel .= ' ('.$log['groupName'].')'; } $event->addEvent( [ 'event' => $eventTypeKey, 'eventId' => $eventTypeKey.$log['id'], 'eventLabel' => $eventLabel, 'eventType' => $eventTypeName, 'timestamp' => $log['dateAdded'], 'extra' => [ 'log' => $log, ], 'icon' => 'fa-calculator', 'contactId' => $log['lead_id'], ] ); } } } public function onLeadMerge(LeadMergeEvent $event): void { $this->leadPointLogRepository->updateLead( $event->getLoser()->getId(), $event->getVictor()->getId() ); $this->leadTriggerLogRepository->updateLead( $event->getLoser()->getId(), $event->getVictor()->getId() ); } }