src/Controller/ConnectorController.php line 53

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Doctrine\Persistence\ManagerRegistry;
  6. use Symfony\Component\Routing\Annotation\Route;
  7. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Symfony\Component\HttpFoundation\Response;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\Form\Extension\Core\Type\TextType;
  12. use Symfony\Component\Form\Extension\Core\Type\PasswordType;
  13. use Symfony\Component\Form\Extension\Core\Type\ChoiceType;
  14. use Symfony\Component\Form\Extension\Core\Type\TextareaType;
  15. use Symfony\Component\Form\Extension\Core\Type\EmailType;
  16. use Symfony\Component\Form\Extension\Core\Type\FileType;
  17. use Symfony\Component\Form\Extension\Core\Type\SubmitType;
  18. use Symfony\Component\Console\Input\ArrayInput;
  19. use Symfony\Bundle\FrameworkBundle\Console\Application;
  21. use Symfony\Component\Finder\Finder;
  22. use Monolog\Logger;
  23. use Monolog\Handler\StreamHandler;
  25. use App\Entity\Connector;
  26. use App\Entity\ConnectorBlock;
  27. use App\Entity\ConnectorBlockItem;
  28. use App\Entity\Module;
  29. use App\Entity\User;
  30. use App\Entity\UserConnector;
  31. use App\Entity\UserConnectorBlock;
  32. use App\Entity\UserConnectorBlockItem;
  33. use App\Entity\Service;
  34. use Symfony\Contracts\Translation\TranslatorInterface;
  36. class ConnectorController extends DefaultController
  37. {
  39.     protected $dynamicEntityManager;
  41.     protected ManagerRegistry $doctrine;
  42.     protected TranslatorInterface $translator;
  43.     public function __construct(ManagerRegistry $doctrine,
  44.                                 TranslatorInterface $translator)
  45.     {
  46.         $this->doctrine = $doctrine;
  47.         $this->translator = $translator;
  48.     }
  49.  
  50.     /**
  51.      * @Route("/connector", name="connector")
  52.      */
  53.     public function indexAction(Request $request)
  54.     {
  55.     
  56.         /* we load session data */
  57.         parent::init($request);
  58.         
  59.         /* we load entity managers */
  60.         $em = $this->doctrine->getManager();
  61.         $dem = $this->doctrine->getManager('dynamic_em');
  62.         
  63.         /* we load service to get list of modules */
  64.         $service = $em->getRepository(Service::class)->getService(7);
  65.     
  66.         /* we render data */
  67.         return $this->render('connector.html.twig',
  68.                 array('headerData' => $this -> getPageHeader($request),
  69.                       'moduleList' => $service->getModules(),
  70.                       'service' => $service,
  71.                 )
  72.                 );
  73.     
  74.     }    
  75.     
  76.     /**
  77.      * @Route("/connectorAdmin", name="connectorAdmin")
  78.      */
  79.     public function connectorAdminAction(Request $request)
  80.     {
  82.         /* we load session data */
  83.         parent::init($request);
  84.         $session = $request->getSession();
  85.         
  86.         /* we check if an user is logged in */
  87.         if(empty($session->get('user'))) {
  88.             return $this->redirectToRoute('login');
  89.         }
  91.         /* we load entity managers */
  92.         $em = $this->doctrine->getManager();
  93.         $dem = $this->doctrine->getManager('dynamic_em');
  95.         /* we get current user */
  96.         $currentUserId = $session->get('user')->getUserId();        
  97.         $user = $em->getRepository(User::class)->getUser($currentUserId);
  98.         
  99.         /* we get paths to user directories */
  100.         $userDirs = $this->getUserFolderPathsFromUserId($currentUserId);
  101.         
  102.         /* setting current user connector */
  103.         if(!empty($request->query->get('setCurrent'))) {
  104.             $userConnector = $em->getRepository(UserConnector::class)->getUserConnector($request->query->get('setCurrent'));
  105.             $em->getRepository(UserConnector::class)->setCurrentUserConnector($currentUserId, $request->query->get('setCurrent'));
  106.             $session->set('connector', $userConnector);
  107.              
  108.             $this->addFlash('notice', 'The connector '.$userConnector->getUserConnectorName().' was set as current one.');
  109.             return $this->redirectToRoute('connectorAdmin');
  110.              
  111.         }
  112.         
  113.         /* we get current connector */
  114.         $currentUserConnector = $em->getRepository(UserConnector::class)->getCurrentUserConnector($currentUserId);
  115.         
  116.         /* we load list of connectors for logged user */
  117.         $userConnectorList = $em->getRepository(UserConnector::class)->getUserConnectorListByUser($currentUserId);
  118.          
  119.         /* we load service to get list of modules */
  120.         $service = $em->getRepository(Service::class)->getService(7);
  121.         
  122.         $logTail = array();
  123.         if(!empty($currentUserConnector) && !empty($currentUserConnector->getLogPath()) && $currentUserConnector->getLogPath() != '') {
  124.             
  125.             $logPath = $userDirs['user'].'/'.$currentUserConnector->getLogPath();
  126.             
  127.             /* we create empty log files if it does not exist yet */            
  128.             if(!is_file($logPath)) {
  129.                 
  130.                 $pathParts = pathinfo($logPath);
  131.                 /*
  132.                 print("\n\n logPath: ");
  133.                 \Doctrine\Common\Util\Debug::dump($pathParts);
  134.                 */
  135.                 
  136.                 /* we try to create log directory */
  137.                 if (!@mkdir($pathParts['dirname'], 0777, true)) {
  138.                     echo('Failed to create folders...');
  139.                 }
  140.                 
  141.                 /* we create the log file */
  142.                 $fh = fopen($logPath, 'w');
  143.             }
  144.             
  145.             if (!$handle = fopen($logPath, 'r')) {
  146.                 echo "Cannot open file ($logPath)";
  147.                 exit;
  148.             }
  150.             $logTail = array_reverse($this->readFileTail($logPath, 200));
  151.         }
  152.         
  153.         if(!empty($currentUserConnector) && !empty($currentUserConnector->getLogErrorPath()) && $currentUserConnector->getLogErrorPath() != '') {
  154.             /* we create empty log error file if it does not exist yet */
  155.             
  156.             $logErrorPath = $userDirs['user'].'/'.$currentUserConnector->getLogErrorPath();
  157.             
  158.             /* we create empty log files if it does not exist yet */            
  159.             if(!is_file($logErrorPath)) {
  160.                 
  161.                 $pathParts = pathinfo($logErrorPath);
  162.                 /*
  163.                 print("\n\n logPath: ");
  164.                 \Doctrine\Common\Util\Debug::dump($pathParts);
  165.                 */
  166.                 
  167.                 /* we try to create log directory */
  168.                 if (!@mkdir($pathParts['dirname'], 0777, true)) {
  169.                     echo('Failed to create folders...');
  170.                 }
  171.                 
  172.                 /* we create the log file */
  173.                 $fh = fopen($logErrorPath, 'w');
  174.             }
  175.             
  176.             if (!$handle = fopen($logErrorPath, 'r')) {
  177.                 echo "Cannot open file ($logErrorPath)";
  178.                 exit;
  179.             }
  180.             
  181.             if (!$handle = fopen($logErrorPath, 'r')) {
  182.                 echo "Cannot open file ($logErrorPath)";
  183.                 exit;
  184.             }
  185.         }
  186.     
  187.         /* we prepare data for view */
  188.         $viewData = array('headerData' => $this -> getPageHeader($request),
  189.                 'connectorList' => $userConnectorList,
  190.                 'currentUserConnector' => $currentUserConnector,
  191.                 'userDirs' => $userDirs,
  192.                 'logTail' => $logTail,
  193.                 'user' => $user,
  194.                 'moduleList' => $service->getModules(),
  195.                 'userModuleList' => $user->getModules(),
  196.                 'menu' => $this -> adminMenu($request),
  197.                         'mainMenu' => $this -> adminMainMenu($request),
  198.         );
  199.         
  200.         if(!empty($request->query->get('REST'))) {
  201.             return new JsonResponse($viewData);
  202.         } else {
  203.         /* we render template */
  204.             return $this->render('connectorAdmin.html.twig', $viewData);
  205.         }
  207.     }
  209.     /**
  210.      * @Route("/connectorConfig", name="connectorConfig")
  211.      */
  212.     public function connectorConfigAction(Request $request)
  213.     {
  214.     
  215.         /* we load session data */
  216.         parent::init($request);
  217.         $session = $request->getSession();
  218.         
  219.         // we check if any user is logged in
  220.         if(!$this->isLoggedUser($request)) {
  221.             return $this->redirectToRoute('login');
  222.         }  
  223.     
  224.         /* we load master entity manager */
  225.         $em = $this->doctrine->getManager();
  226.         $dem = $this->doctrine->getManager('dynamic_em');
  227.     
  228.         $currentUserId = $session->get('user')->getUserId();
  229.         $user = $em->getRepository(User::class)->getUser($currentUserId);
  231.         /* we get current user connector */
  232.         $userConnector = $em->getRepository(UserConnector::class)->getCurrentUserConnector($currentUserId);
  234.         /*
  235.         print('<br>qqw user exists: ');
  236.         \Doctrine\Common\Util\Debug::dump($userConnector);
  237.         */        
  238.         
  239.         /* we get connector list */
  240.         $connectorCollection = $em->getRepository(Connector::class)->getConnectorList();
  241.     
  242.         /* we build form */
  243.         $formBuilder = $this->createFormBuilder($userConnector);
  244.     
  245.         $formBuilder->add('userConnectorName', TextType::class, array(
  246.                 'required' => false,
  247.                 'label' => $this->translator->trans('connector.name'),
  248.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getUserConnectorName()),
  249.                 'label_attr' => array('class' => 'form_field_label')
  250.         ));
  251.         
  252.         $formBuilder->add('userConnectorCode', TextType::class, array(
  253.                 'required' => false,
  254.                 'label' => $this->translator->trans('connector.code'),
  255.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getUserConnectorCode()),
  256.                 'label_attr' => array('class' => 'form_field_label')
  257.         ));
  258.         
  259.         /* we add connector list */
  260.         $connectors = array();
  261.         $selectedConnector = null;
  262.         foreach($connectorCollection as $conn)
  263.         {
  264.             $connId = $conn->getConnectorId();
  265.             $connectors[$conn->getConnectorName()] = $connId;
  266.             
  267.             if(!empty($userConnector->getConnector()) && $connId == $userConnector->getConnector()->getConnectorId()) {
  268.                 $selectedConnector = $connId;
  269.             }
  270.             
  271.         }
  272.         
  273.         $formBuilder->add('connectorId', ChoiceType::class, array(
  274.                 'choices' => $connectors,
  275.                 'mapped' => false,
  276.                 'label' => $this->translator->trans('connector.type'),
  277.                 'attr' => array('class' => 'selector'),
  278.                 'label_attr' => array('class' => 'form_field_label'),
  279.                 'data' => $selectedConnector
  280.         ));  
  281.         
  282.         $formBuilder->add('configPath', TextType::class, array(
  283.                 'required' => false,
  284.                 'label' => $this->translator->trans('connector.config_path'),
  285.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getConfigPath()),
  286.                 'label_attr' => array('class' => 'form_field_label')
  287.         ));
  289.         $formBuilder->add('targetDatabaseHost', TextType::class, array(
  290.                 'required' => false,
  291.                 'label' => $this->translator->trans('connector.target_db_host'),
  292.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getTargetDatabaseHost()),
  293.                 'label_attr' => array('class' => 'form_field_label')
  294.         ));
  295.         
  296.         $formBuilder->add('targetDatabaseName', TextType::class, array(
  297.                 'required' => false,
  298.                 'label' => $this->translator->trans('connector.target_db_name'),
  299.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getTargetDatabaseName()),
  300.                 'label_attr' => array('class' => 'form_field_label')
  301.         ));
  302.         
  303.         $formBuilder->add('targetDatabaseUser', TextType::class, array(
  304.                 'required' => false,
  305.                 'label' => $this->translator->trans('connector.target_db_username'),
  306.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getTargetDatabaseUser()),
  307.                 'label_attr' => array('class' => 'form_field_label')
  308.         )); 
  309.         
  310.         $formBuilder->add('targetDatabasePassword', TextType::class, array(
  311.                 'required' => false,
  312.                 'label' => $this->translator->trans('connector.target_db_password'),
  313.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getTargetDatabasePassword()),
  314.                 'label_attr' => array('class' => 'form_field_label')
  315.         ));     
  316.         
  317.         $formBuilder->add('targetURL', TextType::class, array(
  318.                 'required' => false,
  319.                 'label' => $this->translator->trans('connector.target_url'),
  320.                 'attr' => array('class' => 'text_form', 'size' => 50, 'value' => $userConnector->getTargetURL()),
  321.                 'label_attr' => array('class' => 'form_field_label')
  322.         )); 
  324.         $formBuilder->add('logPath', TextType::class, array(
  325.                 'required' => false,
  326.                 'label' => $this->translator->trans('connector.log_path'),
  327.                 'attr' => array('class' => 'text_form', 'size' => 50, 'value' => $userConnector->getLogPath()),
  328.                 'label_attr' => array('class' => 'form_field_label')
  329.         ));
  330.         
  331.         $formBuilder->add('logErrorPath', TextType::class, array(
  332.                 'required' => false,
  333.                 'label' => $this->translator->trans('connector.log_error_path'),
  334.                 'attr' => array('class' => 'text_form', 'size' => 50, 'value' => $userConnector->getLogErrorPath()),
  335.                 'label_attr' => array('class' => 'form_field_label')
  336.         ));   
  337.         
  338.         $formBuilder->add('logImportPath', TextType::class, array(
  339.                 'required' => false,
  340.                 'label' => $this->translator->trans('connector.log_import_path'),
  341.                 'attr' => array('class' => 'text_form', 'size' => 50, 'value' => $userConnector->getLogImportPath()),
  342.                 'label_attr' => array('class' => 'form_field_label')
  343.         ));
  344.         
  345.         $formBuilder->add('logExportPath', TextType::class, array(
  346.                 'required' => false,
  347.                 'label' => $this->translator->trans('connector.log_export_path'),
  348.                 'attr' => array('class' => 'text_form', 'size' => 50, 'value' => $userConnector->getLogExportPath()),
  349.                 'label_attr' => array('class' => 'form_field_label')
  350.         ));   
  352.         $formBuilder->add('fileImportPath', TextType::class, array(
  353.                 'required' => false,
  354.                 'label' => $this->translator->trans('connector.file_import_path'),
  355.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getFileImportPath()),
  356.                 'label_attr' => array('class' => 'form_field_label')
  357.         ));     
  359.         $formBuilder->add('fileExportPath', TextType::class, array(
  360.                 'required' => false,
  361.                 'label' => $this->translator->trans('connector.file_export_path'),
  362.                 'attr' => array('class' => 'text_form', 'size' => 35, 'value' => $userConnector->getFileExportPath()),
  363.                 'label_attr' => array('class' => 'form_field_label')
  364.         ));                   
  366.         $formBuilder->add('save', SubmitType::class, array('label' => $this->translator->trans('form.button.save'),
  367.                 'attr' => array('class' => 'butt_big')));
  368.     
  369.         $form = $formBuilder->getForm();
  370.     
  371.         $form->handleRequest($request);
  372.         
  373.         /* we handle the form request */
  374.         if ($request->getMethod() == 'POST') {
  375.              
  376.             //$form->bindRequest($request);
  377.              
  378.             if ($form->isValid()) {
  379.                 $formData = $form->getData();
  380.     
  381.                 /* we load data from form into object */
  382.                 $userConnector->setUserConnectorName($formData->getUserConnectorName());
  383.                 $userConnector->setUserConnectorCode($formData->getUserConnectorCode());
  384.                 $userConnector->setConfigPath($formData->getConfigPath());
  385.                 
  386.                 $userConnector->setTargetDatabaseHost($formData->getTargetDatabaseHost());
  387.                 $userConnector->setTargetDatabaseName($formData->getTargetDatabaseName());
  388.                 $userConnector->setTargetDatabaseUser($formData->getTargetDatabaseUser());
  389.                 $userConnector->setTargetDatabasePassword($formData->getTargetDatabasePassword());
  390.                 $userConnector->setTargetURL($formData->getTargetURL());
  391.                 
  392.                 $userConnector->setLogPath($formData->getLogPath());
  393.                 $userConnector->setLogImportPath($formData->getLogImportPath());
  394.                 $userConnector->setLogExportPath($formData->getLogExportPath());
  395.                 $userConnector->setLogErrorPath($formData->getLogErrorPath());
  397.                 $userConnector->setFileImportPath($formData->getFileImportPath());
  398.                 $userConnector->setFileExportPath($formData->getFileExportPath());
  400.                 /* we load connector */
  401.                 $connector = $em->getRepository(Connector::class)->getConnector($form['connectorId']->getData());
  402.     
  403.                 $userConnector->setConnector($connector);
  405.                 /*
  406.                  print('<br>qqw user exists: ');
  407.                  \Doctrine\Common\Util\Debug::dump($user);
  408.                  */
  409.     
  410.                 /* we persist and save user */
  411.                 $em->persist($userConnector);
  412.                 $em->flush();
  413.     
  414.                 $this->addFlash('notice', 'Connector was updated.');
  416.                 return $this->redirectToRoute('connectorConfig');
  417.     
  418.             }
  419.              
  420.         }
  421.     
  422.         /* we render data */
  423.         return $this->render('connectorConfig.html.twig',
  424.                 array(  'headerData' => $this -> getPageHeader($request),
  425.                         'form' => $formBuilder->getForm()->createView(),
  426.                         'userConnector' => $userConnector,
  427.                         'user' => $user,
  428.                         'menu' => $this -> adminMenu($request),
  429.                         'mainMenu' => $this -> adminMainMenu($request),
  430.                 )
  431.                 );
  432.     
  433.     }    
  434.     
  435.     /**
  436.      * @Route("/connectorLog", name="connectorLog")
  437.      */
  438.     public function connectorLogAction(Request $request)
  439.     {
  440.         
  441.         /* we load session data */
  442.         parent::init($request);
  443.         $session = $request->getSession();
  445.         /* we check if an user is logged in */
  446.         if(empty($session->get('user'))) {
  447.             return $this->redirectToRoute('login');
  448.         }        
  449.         
  450.         /* we load master entity manager */
  451.         $em = $this->doctrine->getManager();
  452.         $dem = $this->doctrine->getManager('dynamic_em');
  453.         
  454.         $currentUserId = $session->get('user')->getUserId();
  455.         
  456.         /* we get current user connector */
  457.         $userConnector = $em->getRepository(UserConnector::class)->getCurrentUserConnector($currentUserId);
  458.         
  459.         /* we get paths to user directories */
  460.         $userDirs = $this->getUserFolderPathsFromUserId($currentUserId);
  461.         
  462.         /*
  463.         print('<br>qqw user directories: ');
  464.         \Doctrine\Common\Util\Debug::dump($userDirs);
  465.         */
  466.         
  467.         /* we display standard log */
  468.         /*
  469.         if(!empty($userConnector->getLogPath()) && $userConnector->getLogPath() != '') {
  470.             print('<br>qqw logPath: '.$userConnector->getLogPath());
  471.         }
  472.         */
  474.         /* we display import log */
  475.         $importLogFinder = new Finder();
  476.         if(!empty($userConnector->getLogImportPath()) && $userConnector->getLogImportPath() != '') {
  478.             $importLogDir = $userDirs['user'].'/'.$userConnector->getLogImportPath();
  479.             $importLogFinder->files()->in($importLogDir)->sort(
  480.                     function ($a, $b) {
  481.                         return ($b->getMTime() - $a->getMTime());
  482.                     }
  483.                     );
  484.         }
  485.         
  486.         /* we display export log */
  487.         $exportLogFinder = new Finder();
  488.         if(!empty($userConnector->getLogExportPath()) && $userConnector->getLogExportPath() != '') {
  489.             
  490.             $exportLogDir = $userDirs['user'].'/'.$userConnector->getLogExportPath();
  491.             $exportLogFinder->files()->in($exportLogDir)->sort(
  492.                     function ($a, $b) {
  493.                         return ($b->getMTime() - $a->getMTime());
  494.                     }
  495.                     );
  496.         }
  497.         
  498.         /* connector logs */
  499.         $logFinder = new Finder();
  500.         $logDir = '';
  501.         if(!empty($userConnector->getLogPath()) && $userConnector->getLogPath() != '') {
  503.             $pathParts = pathinfo($userDirs['user'].'/'.$userConnector->getLogPath());
  504.             $logDir = $pathParts['dirname'];
  505.             $logFinder->files()->in($logDir)->sort(
  506.                     function ($a, $b) {
  507.                         return ($b->getMTime() - $a->getMTime());
  508.                     }
  509.                     );
  510.         }
  511.         
  512.         /* error logs */
  513.         $errorLogFinder = new Finder();
  514.         if(!empty($userConnector->getLogErrorPath()) && $userConnector->getLogErrorPath() != '') {
  515.             
  516.             $pathParts = pathinfo($userDirs['user'].'/'.$userConnector->getLogErrorPath());
  517.             
  518.             $errorLogDir = $pathParts['dirname'];
  519.             
  520.             if($logDir == $errorLogDir) {
  521.                 $errorLogFinder = null;
  522.             } else {
  523.                 $errorLogFinder->files()->in($logDir)->sort(
  524.                         function ($a, $b) {
  525.                             return ($b->getMTime() - $a->getMTime());
  526.                         }
  527.                         );
  528.             }
  529.             
  530.         }
  531.         
  533.         /* we render data */
  534.         return $this->render('connectorLog.html.php',
  535.                 array(  'headerData' => $this -> getPageHeader($request),
  536.                         'importLogFinder' => $importLogFinder,
  537.                         'exportLogFinder' => $exportLogFinder,
  538.                         'logFinder' => $logFinder,
  539.                         'errorLogFinder' => $errorLogFinder,
  540.                         'userDirs' => $userDirs,
  541.                         'userConnector' => $userConnector,
  542.                         'menu' => $this -> adminMenu($request),
  543.                         'mainMenu' => $this -> adminMainMenu($request),
  544.                 )
  545.                 );
  546.         
  547.     }
  548.     
  549.     /**
  550.      * @Route("/connectornew", name="connectorNew")
  551.      */
  552.     public function connectorNewAction(Request $request)
  553.     {
  554.                             
  555.         /* we load session data */
  556.         parent::init($request);
  557.     
  558.         $session = $request->getSession();
  560.         /* we load entity managers */
  561.         $em = $this->doctrine->getManager();
  562.         $dem = $this->doctrine->getManager('dynamic_em');
  564.         $userId = $session->get('user')->getUserId();
  565.         $user = $em->getRepository(User::class)->getUser($userId);
  567.         /* we get connector list */
  568.         $connectorCollection = $em->getRepository(Connector::class)->getConnectorList();
  569.     
  570.         /* we build form */
  571.         $userConnector = new UserConnector;
  572.         $formBuilder = $this->createFormBuilder($userConnector);
  573.     
  574.         $formBuilder->add('userConnectorName', TextType::class, array(
  575.                 'required' => true,
  576.                 'label' => $this->translator->trans('connector.name'),
  577.                 'attr' => array('class' => 'text_form', 'size' => 22),
  578.                 'label_attr' => array('class' => 'form_field_label'),
  579.         ));
  580.          
  581.         $formBuilder->add('userConnectorCode', TextType::class, array(
  582.                 'required' => true,
  583.                 'label' => $this->translator->trans('connector.code'),
  584.                 'attr' => array('class' => 'text_form', 'size' => 22),
  585.                 'label_attr' => array('class' => 'form_field_label'),
  586.         ));
  588.         /* we add connector list */
  589.         $connectors = array();
  590.         foreach($connectorCollection as $conn)
  591.         {
  592.             $connId = $conn->getConnectorId();
  593.             $connectors[$conn->getConnectorName()] = $connId;
  594.         }    
  595.         
  596.         $formBuilder->add('connectorId', ChoiceType::class, array(
  597.                 'choices' => $connectors,
  598.                 'mapped' => false,
  599.                 'label' => $this->translator->trans('connector.type'),
  600.                 'attr' => array('class' => 'selector'),
  601.                 'label_attr' => array('class' => 'form_field_label')
  602.         ));  
  604.         $formBuilder->add('save', SubmitType::class, array('label' => $this->translator->trans('form.button.save'),
  605.                 'attr' => array('class' => 'butt_big')));
  606.     
  607.         $form = $formBuilder->getForm();
  608.         $form->handleRequest($request);
  609.     
  610.         if ($request->getMethod() == 'POST') {
  611.     
  612.             if ($form->isValid()) {
  613.                 $formData = $form->getData();
  614.     
  615.                 /* we load users entity manager */
  616.                 //$dem = $this->doctrine->getManager('dynamic_em');
  618.                 $userConnector->setUserConnectorName($formData->getUserConnectorName());
  619.                 $userConnector->setUserConnectorCode($formData->getUserConnectorCode());
  620.                 $userConnector->setUserId($session->get('user')->getUserId());
  622.                 /* we set connector */
  623.                 $connector = $em->getRepository(Connector::class)->getConnector($form['connectorId']->getData());
  624.                 $userConnector->setConnector($connector);
  626.                 /* we set this connector as current one */
  627.                 $em->getRepository(UserConnector::class)->unsetCurrentUserConnector($session->get('user')->getUserId());
  628.                 $userConnector->setUserConnectorCurrent(true);
  629.                 
  630.                 /* we persist and save */
  631.                 $em->persist($userConnector);
  632.                 $em->flush();
  633.     
  634.                 $this->addFlash('notice', 'New connector was created.');
  635.     
  636.                 return $this->redirectToRoute('connectorAdmin');
  637.     
  638.             }
  639.              
  640.         }
  641.     
  642.         /* we render data */
  643.         return $this->render('connectorNew.html.twig',
  644.                 array(    'form' => $formBuilder->getForm()->createView(),
  645.                         'headerData' => $this -> getPageHeader($request),
  646.                         'user' => $user,
  647.                         'menu' => $this -> adminMenu($request),
  648.                         'mainMenu' => $this -> adminMainMenu($request),
  649.                 )
  650.                 );
  651.     
  652.     }   
  653.     
  654.     /**
  655.      * @Route("/userConnectorBlockEdit/{connectorBlockId}", name="userConnectorBlockEdit")
  656.      */
  657.     public function userConnectorBlockEditAction(Request $request, $connectorBlockId)
  658.     {
  659.         
  660.         /* we load session data */
  661.         parent::init($request);
  662.         $session = $request->getSession();
  663.         
  664.         /* we load entity managers */
  665.         $em = $this->doctrine->getManager();
  666.         $dem = $this->doctrine->getManager('dynamic_em');
  667.         
  668.         $currentUserId = $session->get('user')->getUserId();
  669.         $user = $session->get('user');
  670.         
  671.         /* we get current user connector */
  672.         $userConnector = $em->getRepository(UserConnector::class)->getCurrentUserConnector($currentUserId);
  674.         $connector = $em->getRepository(Connector::class)->getConnector($userConnector->getConnector()->getConnectorId());
  676.         /* we get connector */
  677.         $connector = $em->getRepository(Connector::class)->getConnector($userConnector->getConnector()->getConnectorId());
  679.         /*
  680.         print('<br>userConnector: ');
  681.         \Doctrine\Common\Util\Debug::dump($userConnector);
  683.         print('<hr>connector: ');
  684.         \Doctrine\Common\Util\Debug::dump($userConnector->getConnector());
  685.         */
  687.         /* we get connector block */
  688.         $connectorBlock = $em->getRepository(ConnectorBlock::class)->getConnectorBlock($connectorBlockId);
  689.         
  690.         /* we get user connector block */
  691.         $userConnectorBlock = $dem->getRepository(UserConnectorBlock::class)->getUserBlock($connectorBlockId, $userConnector->getUserConnectorId());
  693.         if(empty($userConnectorBlock)) {
  694.             //print('<br>qqw creating userConnectorBlock');
  695.             $userConnectorBlock = new UserConnectorBlock;
  696.             $userConnectorBlock->setUserConnectorBlockName($connectorBlock->getConnectorBlockName());
  697.             $userConnectorBlock->setConnectorBlockId($connectorBlockId);
  698.             $userConnectorBlock->setUserConnectorId($userConnector->getUserConnectorId());
  700.             $dem->persist($userConnectorBlock);
  701.             $dem->flush();
  702.             
  703.         }
  704.         
  705.         /* we build edit form */
  706.         $formBuilder = $this->createFormBuilder($userConnectorBlock);
  707.         
  708.         $formBuilder->add('isActive', ChoiceType::class, array(
  709.                 'choices' => array('Yes' => true, 'No' => false),
  710.                 'required' => false,
  711.                 'mapped' => false,
  712.                 'multiple' => false,
  713.                 'expanded' => true,
  714.                 'placeholder' => false,
  715.                 'label' => $this->translator->trans('connector.active'),
  716.                 'label_attr' => array('class' => 'form_field_label'),
  717.                 'attr' => array('class' => 'form_field_text'),
  718.                 'data' => $userConnectorBlock->isIsActive(),
  719.         ));
  720.         
  721.         $formBuilder->add('userConnectorBlockName', TextType::class, array(
  722.                 'required' => false,
  723.                 'label' => $this->translator->trans('connector.user_connector_block_name'),
  724.                 'attr' => array('class' => 'text_form', 'size' => 33, 'value' => $userConnectorBlock->getUserConnectorBlockName()),
  725.                 'label_attr' => array('class' => 'form_field_label')
  726.         ));
  727.         
  728.         $formBuilder->add('priority', TextType::class, array(
  729.                 'required' => false,
  730.                 'label' => $this->translator->trans('connector.priority'),
  731.                 'attr' => array('class' => 'text_form', 'size' => 11, 'value' => $userConnectorBlock->getPriority()),
  732.                 'label_attr' => array('class' => 'form_field_label')
  733.         ));
  734.         
  735.         $formBuilder->add('periodMinutes', TextType::class, array(
  736.                 'required' => false,
  737.                 'label' => $this->translator->trans('connector.period'),
  738.                 'attr' => array('class' => 'text_form', 'size' => 11, 'value' => $userConnectorBlock->getPeriodMinutes()),
  739.                 'label_attr' => array('class' => 'form_field_label')
  740.         ));
  741.         
  742.         $formBuilder->add('save', SubmitType::class, array('label' => $this->translator->trans('form.button.save'),
  743.                 'attr' => array('class' => 'butt_big')));
  744.         
  745.         $form = $formBuilder->getForm();
  746.         $form->handleRequest($request);
  747.         
  748.         if ($request->getMethod() == 'POST') {
  749.             
  750.             //$form->bindRequest($request);
  751.             
  752.             if ($form->isValid()) {
  753.                 $formData = $form->getData();
  754.                 
  755.                 if(!empty($form['isActive']->getData())) {
  756.                     $userConnectorBlock->setIsActive($form['isActive']->getData());
  757.                 }
  758.                 
  759.                 $userConnectorBlock->setUserConnectorBlockName($formData->getUserConnectorBlockName());
  760.                 $userConnectorBlock->setPriority($formData->getPriority());
  761.                 $userConnectorBlock->setPeriodMinutes($formData->getPeriodMinutes());
  763.                 /* we persist and save */
  764.                 $dem->persist($userConnectorBlock);
  765.                 $dem->flush();
  766.                 
  767.                 $this->addFlash('notice', 'User Connector Block was updated.');
  768.                 
  769.                 return $this->redirectToRoute($connector->getConnectorControllerPath());
  770.                 
  771.             }
  772.             
  773.         }
  775.         //isModule JenkinsBridge
  776.         $module = $em->getRepository(Module::class)->getModule(38);
  777.         $createJenkinsModule = false;  
  778.         $isJenkinsModule = $em->getRepository(User::class)->userHasModule($user, $module);
  779.         if($isJenkinsModule) {
  781.             /* createJenkinsProcess */
  782.             if(!empty($request->query->get('createJenkinsProcess')) && $request->query->get('createJenkinsProcess') == 1) {
  783.                 print("@TODO - createJenkinsProcess");
  784.                 $createJenkinsModule = true;
  785.             }
  787.         }
  788.         
  789.         /* we render data */
  790.         return $this->render('userConnectorBlockEdit.html.twig',
  791.                 array('headerData' => $this -> getPageHeader($request),
  792.                         'user' => $user,
  793.                         'connector' => $connector,
  794.                         'userConnector' => $userConnector,
  795.                         'connectorBlock' => $connectorBlock,
  796.                         'userConnectorBlock' => $userConnectorBlock,
  797.                         'createJenkinsModule' => $createJenkinsModule,                        
  798.                         'form' => $formBuilder->getForm()->createView(),
  799.                         'menu' => $this -> adminMenu($request),
  800.                         'mainMenu' => $this -> adminMainMenu($request),
  801.                 )
  802.                 );
  803.         
  804.     }
  805.     
  806.     
  807.     /**
  808.      * @Route("/userConnectorBlockItemEdit/{connectorBlockItemId}", name="userConnectorBlockItemEdit")
  809.      */
  810.     public function userConnectorBlockItemEditAction(Request $request, $connectorBlockItemId)
  811.     {
  812.         
  813.         /* we load session data */
  814.         parent::init($request);
  815.         $session = $request->getSession();
  816.         
  817.         /* we load entity managers */
  818.         $em = $this->doctrine->getManager();
  819.         $dem = $this->doctrine->getManager('dynamic_em');
  820.         
  821.         $currentUserId = $session->get('user')->getUserId();
  822.         $user = $em->getRepository(User::class)->getUser($currentUserId);
  823.         
  824.         /* we get current user connector */
  825.         $userConnector = $em->getRepository(UserConnector::class)->getCurrentUserConnector($currentUserId);
  827.         $connector = $em->getRepository(Connector::class)->getConnector($userConnector->getConnector()->getConnectorId());
  829.         /* we get connector block item */
  830.         $connectorBlockItem= $em->getRepository(ConnectorBlockItem::class)->getConnectorBlockItem($connectorBlockItemId);
  831.         
  832.         /* we get user connector block item */
  833.         $userConnectorBlockItem= $dem->getRepository(UserConnectorBlockItem::class)->getUserBlockItem($connectorBlockItemId, $userConnector->getUserConnectorId());
  835.         if(empty($userConnectorBlockItem)) {
  836.             //print('<br>qqw creating userConnectorBlock');
  837.             $userConnectorBlockItem= new UserConnectorBlockItem;
  838.             $userConnectorBlockItem->setUserConnectorBlockItemName($connectorBlockItem->getConnectorBlockItemName());
  839.             $userConnectorBlockItem->setConnectorBlockItemId($connectorBlockItemId);
  840.             //$userConnectorBlockItem->setConnectorBlockItem($connectorBlockItem);
  841.             $userConnectorBlockItem->setUserConnectorId($userConnector->getUserConnectorId());
  842.             
  843.             //print('<br>qqw persisting dem: '.$userConnectorBlockItem->getConnectorBlockItemId());
  844.             
  845.             $dem->persist($userConnectorBlockItem);
  846.             //$dem->persist($userConnectorBlockItem->getConnectorBlockItem());
  847.             $dem->flush();
  848.             //$dem->clear();
  849.             
  850.         }
  851.         
  852.         /* we build edit form */
  853.         $formBuilder = $this->createFormBuilder($userConnectorBlockItem);
  854.         
  855.         $formBuilder->add('isActive', ChoiceType::class, array(
  856.                 'choices' => array('Yes' => true, 'No' => false),
  857.                 'required' => false,
  858.                 'mapped' => false,
  859.                 'multiple' => false,
  860.                 'expanded' => true,
  861.                 'placeholder' => false,
  862.                 'label' => $this->translator->trans('connector.active'),
  863.                 'label_attr' => array('class' => 'form_field_label'),
  864.                 'attr' => array('class' => 'form_field_text'),
  865.                 'data' => $userConnectorBlockItem->isIsActive(),
  866.         ));
  867.         
  868.         $formBuilder->add('userConnectorBlockItemName', TextType::class, array(
  869.                 'required' => false,
  870.                 'label' => $this->translator->trans('connector.user_connector_block_name'),
  871.                 'attr' => array('class' => 'text_form', 'size' => 33, 'value' => $userConnectorBlockItem->getUserConnectorBlockItemName()),
  872.                 'label_attr' => array('class' => 'form_field_label')
  873.         ));
  874.         
  875.         $formBuilder->add('sourceUrl', TextType::class, array(
  876.                 'required' => false,
  877.                 'label' => $this->translator->trans('connector.connector_block_item_source'),
  878.                 'attr' => array('class' => 'text_form', 'size' => 55, 'value' => $userConnectorBlockItem->getSourceUrl()),
  879.                 'label_attr' => array('class' => 'form_field_label')
  880.         ));
  881.         
  882.         $formBuilder->add('transformerUrl', TextType::class, array(
  883.                 'required' => false,
  884.                 'label' => $this->translator->trans('connector.connector_block_item_transformer'),
  885.                 'attr' => array('class' => 'text_form', 'size' => 55, 'value' => $userConnectorBlockItem->getTransformerUrl()),
  886.                 'label_attr' => array('class' => 'form_field_label')
  887.         ));
  888.         
  889.         $formBuilder->add('targetUrl', TextType::class, array(
  890.                 'required' => false,
  891.                 'label' => $this->translator->trans('connector.connector_block_item_target'),
  892.                 'attr' => array('class' => 'text_form', 'size' => 55, 'value' => $userConnectorBlockItem->getTargetUrl()),
  893.                 'label_attr' => array('class' => 'form_field_label')
  894.         ));
  896.         $formBuilder->add('priority', TextType::class, array(
  897.                 'required' => false,
  898.                 'label' => $this->translator->trans('connector.priority'),
  899.                 'attr' => array('class' => 'text_form', 'size' => 11, 'value' => $userConnectorBlockItem->getPriority()),
  900.                 'label_attr' => array('class' => 'form_field_label')
  901.         ));
  902.         
  903.         $formBuilder->add('periodMinutes', TextType::class, array(
  904.                 'required' => false,
  905.                 'label' => $this->translator->trans('connector.period'),
  906.                 'attr' => array('class' => 'text_form', 'size' => 11, 'value' => $userConnectorBlockItem->getPeriodMinutes()),
  907.                 'label_attr' => array('class' => 'form_field_label')
  908.         ));
  909.         
  910.         $formBuilder->add('save', SubmitType::class, array('label' => $this->translator->trans('form.button.save'),
  911.                 'attr' => array('class' => 'butt_big')));
  912.         
  913.         $form = $formBuilder->getForm();
  914.         $form->handleRequest($request);
  915.         
  916.         if ($request->getMethod() == 'POST') {
  917.             
  918.             //$form->bindRequest($request);
  919.             
  920.             if ($form->isValid()) {
  921.                 $formData = $form->getData();
  922.                 
  923.                 if(!empty($form['isActive']->getData())) {
  924.                     $userConnectorBlockItem->setIsActive($form['isActive']->getData());
  925.                 }
  926.                 
  927.                 $userConnectorBlockItem->setUserConnectorBlockItemName($formData->getUserConnectorBlockItemName());
  928.                 $userConnectorBlockItem->setSourceUrl($formData->getSourceUrl());
  929.                 $userConnectorBlockItem->setTransformerUrl($formData->getTransformerUrl());
  930.                 $userConnectorBlockItem->setTargetUrl($formData->getTargetUrl());
  931.                 
  932.                 $userConnectorBlockItem->setPriority($formData->getPriority());
  933.                 $userConnectorBlockItem->setPeriodMinutes($formData->getPeriodMinutes());
  934.                 
  935.                 /* we persist and save */
  936.                 $dem->persist($userConnectorBlockItem);
  937.                 $dem->flush(); 
  938.                 
  939.                 $this->addFlash('notice', 'User Connector Block Item was updated.');
  940.                 
  941.                 return $this->redirectToRoute($connector->getConnectorControllerPath());
  942.                 
  943.             }
  944.             
  945.         }
  946.         
  947.         /* we render data */
  948.         return $this->render('userConnectorBlockItemEdit.html.twig',
  949.                 array('headerData' => $this -> getPageHeader($request),
  950.                         'connector' => $connector,
  951.                         'userConnector' => $userConnector,
  952.                         'connectorBlockItem' => $connectorBlockItem,
  953.                         'userConnectorBlockItem' => $userConnectorBlockItem,
  954.                         'user' => $user,
  955.                         'form' => $formBuilder->getForm()->createView(),
  956.                         'menu' => $this -> adminMenu($request),
  957.                         'mainMenu' => $this -> adminMainMenu($request),
  958.                 )
  959.                 );
  960.         
  961.     }
  962.     
  963.     public function adminMenu(Request $request)
  964.     {
  965.         $menuItems = array(0 => array('link' => 'homeuser', 'langKey' => 'user.admin', 'routeName' => 'homeuser'),
  966.                 1 => array('link' => 'connectorAdmin', 'langKey' => 'connector.admin', 'routeName' => 'connectorAdmin'),
  967.                 2 => array('link' => 'connectorLog', 'langKey' => 'connector.logs', 'routeName' => 'connectorLog'),
  968.                 3 => array('link' => 'connectornew', 'langKey' => 'connector.new_connector', 'routeName' => 'connectorNew'),
  969.                 4 => array('link' => 'connectorConfig', 'langKey' => 'connector.config', 'routeName' => 'connectorConfig'),
  970.         );
  971.     
  972.         return $menuItems;
  973.     
  974.     }    
  975.     
  976. }