src/Component/ExternalIntegration/Integration/Bullhorn/EventSubscriber/BullhornEventSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace App\Component\ExternalIntegration\Integration\Bullhorn\EventSubscriber;
  5. use App\Client\BullhornClient;
  6. use App\Entity\ExternalIntegrationLogTransaction;
  7. use App\Entity\ExternalIntegrationLogTransactionEntry;
  8. use App\Entity\Registration;
  9. use App\Event\BullhornApplicantEvent;
  10. use App\Event\BullhornEventFormSubmitEvent;
  11. use App\Manager\LogTransactionManager;
  12. use App\Util\Bullhorn;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class BullhornEventSubscriber implements EventSubscriberInterface
  18. {
  19.     private const TAG = 'BullhornEventSubscriber';
  21.     public function __construct(
  22.         private readonly EntityManagerInterface $entityManager,
  23.         private readonly BullhornClient $bullhornClient,
  24.         private readonly LoggerInterface $logger,
  25.         private readonly LogTransactionManager $logManager
  26.     ) {
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             BullhornEventFormSubmitEvent::class => 'eventRegistrationSubmitted',
  33.             BullhornApplicantEvent::CANDIDATE_SAVED => 'candidateSaved',
  34.         ];
  35.     }
  37.     /**
  38.      * @throws \Exception
  39.      */
  40.     public function eventRegistrationSubmitted(BullhornEventFormSubmitEvent $event): void
  41.     {
  42.         $transaction = $this->logManager->initTransaction(
  43.             'Handling registration',
  44.             Bullhorn::REFERENCE,
  45.             json_encode(compact('event'), \JSON_THROW_ON_ERROR),
  46.             Registration::class
  47.         );
  49.         $registration = $event->getRegistration();
  51.         try {
  52.             $ownerId = $this->bullhornClient->findVacancyOwner($registration->getEvent()?->getExternalId(), $transaction);
  53.             $candidateData = [
  54.                 'id' => $registration->getId(),
  55.                 'email' => $registration->getEmail(),
  56.                 'first_name' => $registration->getFirstName(),
  57.                 'last_name' => $registration->getLastName(),
  58.                 'phone' => $registration->getPhone(),
  59.                 'owner' => [
  60.                     'id' => $ownerId,
  61.                 ],
  62.             ];
  63.             if ($registration->getGdpr()) {
  64.                 $createdAt = $registration->getCreatedAt()?->format('U');
  65.                 $candidateData['customObject1s'] = [
  66.                     [
  67.                         'text1' => 'Recruitment Activiteiten',
  68.                         'text2' => $registration->getGdpr()->getIntegrationValue() ?? $registration->getGdpr()->getTitle(),
  69.                         'text3' => 'Website',
  70.                         'date1' => (int) $createdAt * 1000,
  71.                     ],
  72.                 ];
  73.             }
  74.             $candidateId = $this->bullhornClient->upsertCandidate($candidateData, $transaction);
  75.             $registrationId = $this->bullhornClient->addCandidateToVacancy($candidateData, $candidateId, $event->getEvent()->getExternalId(), $transaction);
  77.             $registration->setExternalId(sprintf('%s - %s', $candidateId, $registrationId));
  78.             $this->entityManager->persist($registration);
  79.             $this->entityManager->flush();
  80.             $this->logger->info(sprintf('Bullhorn integration : [%s] %s', self::TAG, 'Applicant has been added to vacancy in bullhorn'));
  82.             $this->logManager->log(
  83.                 $transaction,
  84.                 'Handled registration successfully',
  85.                 ExternalIntegrationLogTransaction::LEVEL_SUCCESS,
  86.                 json_encode(compact('event', 'registration'), \JSON_THROW_ON_ERROR),
  87.                 ExternalIntegrationLogTransaction::LEVEL_SUCCESS,
  88.                 Registration::class
  89.             );
  90.         } catch (\Exception $exception) {
  91.             $this->logger->error(sprintf('Bullhorn integration : [%s] %s', self::TAG, $exception->getMessage()));
  93.             $this->logManager->log(
  94.                 $transaction,
  95.                 'Handling registration failed',
  96.                 ExternalIntegrationLogTransactionEntry::LEVEL_ERROR,
  97.                 json_encode(compact('exception', 'event'), \JSON_THROW_ON_ERROR),
  98.                 ExternalIntegrationLogTransaction::LEVEL_ERROR,
  99.                 Registration::class
  100.             );
  101.         } finally {
  102.             $event->stopPropagation();
  103.             $this->logManager->save($transaction);
  104.         }
  105.     }
  107.     public function candidateSaved(BullhornApplicantEvent $event): void
  108.     {
  109.         $this->entityManager->persist($event->getApplicant());
  110.         $this->entityManager->flush();
  111.     }
  112. }