src/EventSubscriber/ChatMessageSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Service\Es8N8;
  6. use App\Entity\ChatThread;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use App\Event\ChatMessagePrePersistEvent;
  9. use App\Event\ChatMessagePostPersistEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ChatMessageSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private EntityManagerInterface $_em,
  16.         private Es8N8 $es8N8,
  17.     ) {
  18.     }
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             ChatMessagePrePersistEvent::NAME => 'preCreate',
  24.             ChatMessagePostPersistEvent::NAME => 'postCreate',
  25.         ];
  26.     }
  28.     public function preCreate(ChatMessagePrePersistEvent $event)
  29.     {
  30.         $object = $event->getObject();
  31.         $chatThread = $object->getChatThread();
  32.         $chatThread->setLastMessageAt(new \DateTime());
  33.         $this->_em->persist($chatThread);
  34.     }
  36.     public function postCreate(ChatMessagePostPersistEvent $event)
  37.     {
  38.         $object = $event->getObject();
  39.         $thread = $object->getChatThread();
  41.         $isCreateChatSupportTicket = $thread->getContainer()->getConfiguration('isCreateChatSupportTicket', false);
  43.         if ($isCreateChatSupportTicket && $thread->getThreadType() === ChatThread::THREAD_TYPE_O2O) {
  44.             $targetUser = $object->getTargetUser();
  45.             if ($targetUser->getUserType() === 'relation_manager') {
  46.                 $this->es8N8->makeSupportTicket($object);
  47.             }
  48.         }
  49.     }
  50. }