src/Import1CBundle/EventListener/ArticleUpdateListener.php line 11

Open in your IDE?
  1. <?php
  3. namespace Import1CBundle\EventListener;
  5. use Import1CBundle\Event\ArticleUpdateEvent;
  6. use Import1CBundle\Helper\v3\ConnectionHelper;
  7. use WebBundle\Helper\App;
  9. class ArticleUpdateListener
  10. {
  11.     public function onArticleUpdate(ArticleUpdateEvent $event)
  12.     {
  13.         $items = $event->getTovar();
  14.         $code = $items['CODE'] ?? null;
  15.         if(!$code){
  16.             return;
  17.         }
  18.         $updateService = App::getContainer()->get('bi.v4.service.update');
  19.         $updateService->saveHash($code, $event->getTovar());
  20.         $queueService = App::getContainer()->get('bi.v4.service.queue');
  22.         $queueService->toQueueArticleUpdateDescription($items, $event->getId(),  $event->getI());
  23.         $queueService->toQueueArticleUpdatePrice($items, $event->getId(), $event->getI());
  25.         $items = $this->items($code);
  26.         $queueService->toQueueArticleUpdateDiscount($items, $event->getId(), $event->getI());
  27.     }
  29.     private function items($code): ?array
  30.     {
  31.         $sql = sprintf(
  32.             'SELECT * FROM VOLUMEPRC WHERE CODE=\'%s\';',
  33.             $code,
  34.         );
  35.         return ConnectionHelper::getInstance('oneC')->executeColumnsRows($sql);
  36.     }
  37. }