src/EventSubscriber/MaintenanceElement/MaintenanceElementPostWriteSubscriber.php line 46

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: SUSAN MEDINA
  5.  * Date: 15/04/2019
  6.  * Time: 10:15 PM
  7.  */
  9. namespace App\EventSubscriber\MaintenanceElement;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use ApiPlatform\Core\EventListener\EventPriorities;
  17. use App\Repository\App\MaintenanceElementRepository;
  18. use App\Repository\App\MediaObjectRepository;
  19. use App\Entity\App\MaintenanceElement;
  20. use App\Services\UtilsService;
  22. class MaintenanceElementPostWriteSubscriber implements EventSubscriberInterface
  23. {
  24.     private $entityManager;
  25.     private $mediaObjectRepository;
  26.     private $elementRepository;
  27.     private $utilsService;
  29.     public function __construct(
  30.         MediaObjectRepository $mediaObjectRepository,
  31.         MaintenanceElementRepository $elementRepository,
  32.         EntityManagerInterface $entityManager,
  33.         UtilsService $utilsService)
  34.     {
  35.         $this->entityManager = $entityManager;
  36.         $this->mediaObjectRepository = $mediaObjectRepository;
  37.         $this->elementRepository = $elementRepository;
  38.         $this->utilsService = $utilsService;
  39.     }
  41.     /**
  42.      * @param ViewEvent $event
  43.      * @throws \Doctrine\Common\Persistence\Mapping\MappingException
  44.      * @throws \Doctrine\ORM\NonUniqueResultException
  45.      */
  46.     public function onKernelView(ViewEvent $event)
  47.     {
  48.         if ($this->utilsService->isAPublicRequest($event)) {
  49.             return;
  50.         }
  52.         $maintenanceElement = $event->getControllerResult();
  53.         $request = $event->getRequest();
  54.         $method = $request->getMethod();
  56.         if (!($maintenanceElement instanceof MaintenanceElement) ||
  57.             (Request::METHOD_POST !== $method && Request::METHOD_PUT !== $method)
  58.         )
  59.             return;
  61.         $content = $request->getContent();
  62.         $params = json_decode($content, true);
  64.         if (isset($params['mediaContent']) &&
  65.             is_array($params['mediaContent']) &&
  66.             count($params['mediaContent']) > 0
  67.         ) {
  68.             if (!$this->entityManager->isOpen()) {
  69.                 $this->entityManager = $this->entityManager->create(
  70.                     $this->entityManager->getConnection(),
  71.                     $this->entityManager->getConfiguration()
  72.                 );
  73.             }
  74.             $getMediaObjects = $this->mediaObjectRepository->findBy(['maintenanceElement' => $maintenanceElement->getId()]);
  75.             foreach ($getMediaObjects as $media) {
  76.                 if (!in_array($media->getId(), $params['mediaContent'])){
  77.                     $this->entityManager->remove($media);
  78.                 }
  79.             }
  80.             foreach ($params['mediaContent'] as $mediaId) {
  81.                 $mediaObject = $this->mediaObjectRepository->find($mediaId);
  82.                 $mediaObject->setMaintenanceElement($maintenanceElement);
  83.                 $this->entityManager->persist($mediaObject);
  84.             }
  85.             $this->entityManager->flush();
  86.         }
  88.         if(isset($params['children']) &&
  89.             is_array($params['children']) &&
  90.             count($params['children']) > 0
  91.         ){
  92.             if (!$this->entityManager->isOpen()) {
  93.                 $this->entityManager = $this->entityManager->create(
  94.                     $this->entityManager->getConnection(),
  95.                     $this->entityManager->getConfiguration()
  96.                 );
  97.             }
  98.             foreach ($maintenanceElement->getChildren() as $child) {
  99.                 $search = array_search($child->getId(), array_column($params['children'], 'id'));
  100.                 if ( !is_integer($search) && !$search ){
  101.                     $child->setParent(null);
  102.                     $this->entityManager->persist($child);
  103.                 }
  104.             }
  105.             foreach ($params['children'] as $child) {
  106.                 if (isset($child['id'])) {
  107.                     $children = $this->elementRepository->find($child['id']);
  108.                     $children->setParent($maintenanceElement);
  109.                     $this->entityManager->persist($children);
  110.                 }
  111.             }
  112.             $this->entityManager->flush();
  113.         }
  115.         if (Request::METHOD_POST === $method) {
  116.             $identify = $this->utilsService->generateIdentify($maintenanceElement);
  117.             $maintenanceElement->setIdentify($identify);
  118.             $this->entityManager->persist($maintenanceElement);
  119.             $this->entityManager->flush();
  120.         }
  121.     }
  123.     public static function getSubscribedEvents()
  124.     {
  125.         return [
  126.             KernelEvents::VIEW => ['onKernelView', EventPriorities::POST_WRITE]
  127.         ];
  128.     }
  129. }