src/EventListener/CommandListener.php line 41

Open in your IDE?
  1. <?php
  2. // src/AppBundle/EventListener/CommandListener.php
  3. namespace App\EventListener;
  5. use Doctrine\Persistence\ManagerRegistry;
  6. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  7. use Symfony\Component\Console\ConsoleEvents;
  8. use Symfony\Component\HttpKernel\Event\GetResponseEvent;
  9. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use AppBundle\Service\FlexiBee\Utils;
  12. use Symfony\Component\HttpKernel\KernelInterface;
  14. use App\Entity\User;
  15. use App\Entity\UserConnector;
  17. class CommandListener
  18. {
  19.     
  20.     private $container;
  21.     private $utils;
  22.     protected $doctrine;
  23.     protected $appKernel;
  24.     
  25.     public function __construct(KernelInterface $appKernel,
  26.                                 ManagerRegistry $doctrine,
  27.                                                 $defaultLocale = 'cs')
  28.     {
  29.         $this->appKernel = $appKernel;
  30.         $this->doctrine = $doctrine;
  32.         $this->defaultLocale = $defaultLocale;
  33.     }
  34.     
  35.     //public function onConsoleCommand(ConsoleCommandEvent $event) {
  37.     /**
  38.      * @throws \ReflectionException
  39.      */
  40.     //public function __invoke(RequestEvent $event): void {
  41.     public function onConsoleCommand(ConsoleCommandEvent $event) {
  43.         // get the output instance
  44.         $output = $event->getOutput();
  46.         // get the output instance
  47.         $input = $event->getInput();
  48.         $args = $input->getArguments();
  50. //        print("\n\n qqw onConsoleCommand getInput: ".$args['connectorCode']);
  51. //        \Doctrine\Common\Util\Debug::dump($args);
  53.         // get the command to be executed
  54.         $command = $event->getCommand();
  55.         
  56.         // write something about the command
  58.         if(!empty($args['connectorCode']) && $args['connectorCode'] != '') {
  59.             $output->writeln(sprintf("\n ================= Before running command <info>%s</info> =================", $command->getName()));
  60.             $output->writeln(sprintf("\n User Connector Code: <info>%s</info>\n", $args['connectorCode']));
  62.             //$this->container->setParameter('locale', 'de');
  63.             //$request = $this->container->get('request_stack')->getCurrentRequest();
  64.             //$request = $event->getRequest();
  65.             //$request->setLocale('de');
  66.             
  67.             $em = $this->doctrine->getManager();
  68.             
  69.             /* we get user connector */
  70.             $userConnector = $em->getRepository(UserConnector::class)->getUserConnectorByCode($args['connectorCode']);
  71.             $userId = $userConnector->getUserId();
  72.             $user = $em->getRepository(User::class)->getUser($userId);
  74.             //test - setting current locale
  75.             //$this->container->get('gedmo.listener.translatable')->setTranslatableLocale('cs');
  76.             //$this->container->get('gedmo.listener.translatable')->setDefaultLocale('cs');
  77.             
  78.             
  79.             /* we setup entity manager for user erp database*/
  80. //            $connection = $this->container->get(sprintf('doctrine.dbal.%s_connection', 'dynamic_conn'));
  81.             //$connection->setLocale('en');
  83.             $connection = $this->appKernel->getContainer()->get(sprintf('doctrine.dbal.%s_connection', 'dynamic_conn'));
  84.             $connection->close();
  85.             
  86.             $refConn = new \ReflectionObject($connection);
  87.             $refParams = $refConn->getProperty('params');
  88.             $refParams->setAccessible('public'); //we have to change it for a moment
  89.             
  90.             $params = $refParams->getValue($connection);
  91.             $params['dbname'] = $user->getDatabaseName();
  92.             $params['user'] = $user->getDatabaseUser();
  93.             $params['password'] = $user->getDatabasePassword();
  94.             
  95.             $refParams->setAccessible('private');
  96.             $refParams->setValue($connection, $params);
  97.             $this->doctrine->resetManager('dynamic_em');
  98.             
  99.             /* we setup entity manager for target e-shop */
  100. //            $connectionTarget = $this->container->get(sprintf('doctrine.dbal.%s_connection', 'eshop_conn'));
  102.             $connectionTarget = $this->appKernel->getContainer()->get(sprintf('doctrine.dbal.%s_connection', 'eshop_conn'));
  103.             $connectionTarget->close();
  105.             $refConn = new \ReflectionObject($connectionTarget);
  106.             $refParams = $refConn->getProperty('params');
  107.             $refParams->setAccessible('public'); //we have to change it for a moment
  109.             $params = $refParams->getValue($connectionTarget);
  110.             $params['host'] = $userConnector->getTargetDatabaseHost();
  111.             $params['dbname'] = $userConnector->getTargetDatabaseName();
  112.             $params['user'] = $userConnector->getTargetDatabaseUser();
  113.             $params['password'] = $userConnector->getTargetDatabasePassword();
  115.             $refParams->setAccessible('private');
  116.             $refParams->setValue($connectionTarget, $params);
  117.             $this->doctrine->resetManager('eshop_em');
  118.             
  120.         }
  122.     }
  123. }