src/EventSubscriber/TablePositionSubscriber.php line 31

  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Document\Area\Area;
  7. use App\Document\Area\TablePosition;
  8. use Doctrine\ODM\MongoDB\DocumentManager;
  9. use Doctrine\ODM\MongoDB\MongoDBException;
  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;
  15. final class TablePositionSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(private readonly DocumentManager $manager)
  18.     {
  19.     }
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             KernelEvents::VIEW => ['updateTablePosition', EventPriorities::PRE_WRITE],
  25.         ];
  26.     }
  28.     /**
  29.      * @throws MongoDBException
  30.      */
  31.     public function updateTablePosition(ViewEvent $event): void
  32.     {
  33.         $tablePosition = $event->getControllerResult();
  34.         $method = $event->getRequest()->getMethod();
  36.         if (!$tablePosition instanceof TablePosition || !in_array($method, [Request::METHOD_POST, Request::METHOD_PUT])) {
  37.             return;
  38.         }
  40.         if (Request::METHOD_POST === $method) {
  41.             $area = $tablePosition->getArea();
  42.             $this->updateOtherTablePositions($area);
  43.         }
  45.         if (Request::METHOD_PUT === $method) {
  46.             $newPosition = $tablePosition->getPosition();
  48.             /** @var int $oldPosition */
  49.             $oldPosition = $this->manager->getUnitOfWork()->getOriginalDocumentData($tablePosition)['position'];
  51.             $area = $tablePosition->getArea();
  52.             if ($newPosition != $oldPosition) {
  53.                 if ($newPosition > $oldPosition) {
  54.                     $this->updateOtherTablePositions($area, $oldPosition);
  55.                 } else {
  56.                     $this->updateOtherTablePositions($area, null, $oldPosition);
  57.                 }
  58.             }
  59.         }
  60.     }
  62.     /**
  63.      * @throws MongoDBException
  64.      */
  65.     private function updateOtherTablePositions(Area $area, ?int $gt = null, ?int $lte = null): void
  66.     {
  67.         $query = $this->manager->createQueryBuilder(TablePosition::class);
  68.         $query->updateMany()
  69.             ->field('area')->references($area);
  71.         if ($gt) {
  72.             $query->field('position')->gt($gt);
  73.         }
  75.         if ($lte) {
  76.             $query->field('position')->lte($lte);
  77.         }
  79.         if ($gt && $lte) {
  80.             $query->addAnd($query->expr()->field('position')->gt($gt));
  81.             $query->addAnd($query->expr()->field('position')->lte($lte));
  82.         }
  84.         $query->field('position')->inc($gt ? -1 : 1);
  85.         $query->getQuery()->execute();
  86.     }
  87. }