src/EventListener/MediaObjectCreatedListener.php line 41

  1. <?php
  3. namespace App\EventListener;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\MediaObject;
  7. use App\Entity\Resize;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  14. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  15. use Intervention\Image\ImageManager;
  16. use Symfony\Component\HttpKernel\KernelInterface; 
  17. use App\Service\ImageResize;
  18. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  23. class MediaObjectCreatedListener implements EventSubscriberInterface
  24. {
  25.     private EntityManagerInterface $entityManager;
  26.     private $kernel;
  27.     private $imageResize;
  29.     private $other_user = '';
  30.     private $other_host = '';
  31.     private $other_port = '';
  32.     private $other_pass = '';
  33.     private $other_name = '';
  35.     private $my_user = '';
  36.     private $my_host = '';
  37.     private $my_port = '';
  38.     private $my_pass = '';
  39.     private $my_name = '';
  41.     private $params;
  43.     public function __construct(EntityManagerInterface $entityManager, KernelInterface $kernel, ImageResize $imageResize, ParameterBagInterface $params )
  44.     {
  45.         $this->entityManager = $entityManager;
  46.         $this->kernel = $kernel;
  47.         $this->imageResize = $imageResize;
  49.         $this->params = $params;
  51.         /** стороння база */
  52.         $this->other_user= $this->params->get('OTHER_DB_user');
  53.         $this->other_host= $this->params->get('OTHER_DB_host');
  54.         $this->other_port= $this->params->get('OTHER_DB_port');
  55.         $this->other_pass= $this->params->get('OTHER_DB_pass');
  56.         $this->other_name= $this->params->get('OTHER_DB_name');
  58.         /** моя база */
  59.         // $this->my_user= $this->params->get('MY_DB_user');
  60.         // $this->my_host= $this->params->get('MY_DB_host');
  61.         // $this->my_port= $this->params->get('MY_DB_port');
  62.         // $this->my_pass= $this->params->get('MY_DB_pass');
  63.         // $this->my_name= $this->params->get('MY_DB_name');
  64.     }
  66.     public static function getSubscribedEvents()
  67.     {
  68.         return [
  69.             KernelEvents::VIEW => ['saveMediaObject', EventPriorities::POST_WRITE],
  70.         ];
  71.     }
  73.     public function saveMediaObject(ViewEvent $event)
  74.     {
  75.         $mainMedia = $event->getControllerResult();
  76.         $method = $event->getRequest()->getMethod();
  78.         if (!$mainMedia instanceof MediaObject) {
  79.             return;
  80.         }
  81.         // echo $mainMedia->getId();
  82.         // echo $mainMedia->filePath;
  85.         $year = date('Y');
  86.         $month = date('m');
  87.         $documentRoot = $this->kernel->getProjectDir() . '/public/media';
  88.         $path = $documentRoot . "/$year/$month/";
  89.         $name = $mainMedia->filePath;
  91.         $uri = $path . $name;
  93.        
  94.         $this->dublicate([
  95.             'id' => $mainMedia->getId(),
  96.             'file_path' => $mainMedia->filePath,
  97.             'type' => $mainMedia->getType(),
  98.             'name' => $mainMedia->getName(),
  99.             'upload_timestamp' => $mainMedia->getUploadTimestamp()->format('Y-m-d H:i:s'),  
  100.             'size' => null,  
  101.             'resize_img_parent_id' => null,  
  102.         ]);
  103.      
  105.         if ( $mainMedia->getResizeImgParent() == null AND $this->isImage($uri)) {
  106.             $sizes = [90, 230, 700, 1200];
  107.             $manager = new ImageManager(
  108.                 new \Intervention\Image\Drivers\Gd\Driver() 
  109.             );
  110.             foreach($sizes as $s){
  111.                 $image = $manager->read($uri);
  112.                 $image->scale( $s);
  113.                 $newName = "{$s}_px_" . $name;
  114.                 $image->save($path . $newName );
  116.                 $newMedia = new MediaObject();
  117.                 $newMedia->filePath = $newName;
  118.                 $newMedia->setName("resize-$s");
  119.                 $newMedia->setSize($s);
  120.                 $newMedia->setResizeImgParent($mainMedia);
  121.                 $this->entityManager->persist($newMedia);
  122.                 $this->entityManager->flush();
  124.                 $this->dublicate([
  125.                     'id' => $newMedia->getId(),
  126.                     'file_path' => $newMedia->filePath,
  127.                     'type' => $newMedia->getType(),
  128.                     'name' => $newMedia->getName(),
  129.                     'upload_timestamp' => $newMedia->getUploadTimestamp()->format('Y-m-d H:i:s'),  
  130.                     'size' => $newMedia->getSize(),  
  131.                     'resize_img_parent_id' =>  $mainMedia->getId(),  
  132.                 ]);
  133.                
  134.             }
  135.         }
  138.         // die;
  139.        
  140.     }
  142.     
  143.     private function dublicate($data){
  144.         $dsn = "pgsql:host={$this->other_host};port={$this->other_port};dbname={$this->other_name};";
  146.         // 3. Опції
  147.         $options = [
  148.             \PDO::ATTR_ERRMODE            => \PDO::ERRMODE_EXCEPTION,
  149.             \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC,
  150.             \PDO::ATTR_EMULATE_PREPARES   => false,
  151.         ];
  153.       
  154.             // 4. Підключення
  155.             $pdo = new \PDO($dsn, $this->other_user, $this->other_pass, $options);
  157.             // 5. INSERT-запит
  158.             $sql = "INSERT INTO media_object (
  159.                 id,
  160.                 file_path, 
  161.                 type,
  162.                 name,
  163.                 upload_timestamp,
  164.                 \"size\",
  165.                 resize_img_parent_id
  166.             ) VALUES (
  167.             :id,
  168.             :file_path, 
  169.             :type,
  170.             :name,
  171.             :upload_timestamp,
  172.             :size,
  173.             :resize_img_parent_id
  174.             )";
  175.             $stmt = $pdo->prepare($sql);
  177.             $stmt->execute([
  178.                 'id' => $data['id'],
  179.                 'file_path' => $data['file_path'],
  180.                 'type' => $data['type'],
  181.                 'name' => $data['name'],
  182.                 'upload_timestamp' => $data['upload_timestamp'],
  183.                 'size' => $data['size'],
  184.                 'resize_img_parent_id' => $data['resize_img_parent_id'],
  185.             ]);
  188.     }
  189.     
  190.     private function isImage($file)
  191.     {
  192.         $allowedTypes = [
  193.             IMAGETYPE_GIF,
  194.             IMAGETYPE_JPEG,
  195.             IMAGETYPE_PNG,
  196.             IMAGETYPE_WEBP,
  197.             // Add more as needed
  198.         ];
  200.         $imageInfo = @getimagesize($file);
  202.         if ($imageInfo && in_array($imageInfo[2], $allowedTypes)) {
  203.             return true;
  204.         }
  205.     
  206.         return false;
  207.     }
  208. }