src/Controller/ScriptController.php line 180

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Slave\Intervention;
  6. use App\Entity\Slave\OperationKeyMapping;
  7. use App\Entity\Slave\TicketSuspension;
  8. use App\Service\CompanyService;
  9. use App\Service\EncryptionService;
  10. use App\Service\TicketService;
  11. use App\Service\UtilitiesService;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
  14. use Symfony\Bundle\FrameworkBundle\Console\Application;
  15. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  16. use Symfony\Component\Console\Input\ArrayInput;
  17. use Symfony\Component\Console\Output\BufferedOutput;
  18. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpKernel\KernelInterface;
  22. use Symfony\Component\Mailer\MailerInterface;
  23. use Symfony\Component\Routing\Annotation\Route;
  24. use Symfony\Component\Form\FormError;
  26. /**
  27.  * @Route("/script")
  28. */
  29. class ScriptController extends AbstractController
  30. {
  31.     protected $mr;
  32.     private $params;
  34.     public function __construct(ManagerRegistry $managerRegistry, ParameterBagInterface $params)
  35.     {
  36.         $this->mr = $managerRegistry;
  37.         $this->params = $params;
  38.     }
  39.     
  40.     /**
  41.      * @Route("/aggiorna_master_db", name="admin_update_master_db")
  42.      */
  43.     public function adminUpdateMasterDb(Request $request, KernelInterface $kernel)
  44.     {        
  45.         $application = new Application($kernel);
  46.         $application->setAutoExit(false);
  48.         $input = new ArrayInput(array(
  49.             'command' => 'doctrine:schema:update',
  50.             '--force' => true,
  51.             '--dump-sql' => true,
  52.             '--complete' => true,
  53.             '--em' => 'master'
  54.         ));
  55.         
  56.         $output = new BufferedOutput();
  57.         $application->run($input, $output);
  59.         $content = $output->fetch();
  61.         return new Response($content);
  62.     }
  63.     
  64.     /**
  65.      * @Route("/aggiorna_tutti_db", name="admin_update_all_db")
  66.      */
  67.     public function adminUpdateAllDb(Request $request, KernelInterface $kernel)
  68.     {    
  69.         $application = new Application($kernel);
  70.         $application->setAutoExit(false);
  71.         
  72.         $emMaster = $this->mr->getManager('master');
  73.         $companies = $emMaster->getRepository("App\Entity\Master\Company")->findAll();
  74.         $content = "{ \"database aggiornati\" : [";
  75.         $first = true;
  77.         foreach($companies as $company){
  78.             if($first) $first = false; else $content.=", ";
  79.             $this->mr->getConnection('slave')->changeDatabase($this->getParameter('slave_database_host'), $this->getParameter('slave_database_port'), $this->getParameter('slave_database_user'), $this->getParameter('slave_database_password'), $company->getDbName());
  80.             
  81.             $input = new ArrayInput(array(
  82.                 'command' => 'doctrine:schema:update',
  83.                 '--force' => true,
  84.                 '--dump-sql' => true,
  85.                 '--complete' => true,
  86.                 '--em' => 'slave'
  87.             ));
  89.             $output = new BufferedOutput();
  90.             $application->run($input, $output);
  91.             
  92.             $content.= "{\"Nome database\" : ".json_encode($company->getDbName()).", \"output\" : ".json_encode($output->fetch())."}";
  93.         }
  94.         $content.="]}";
  96.         return new Response(json_encode($content));
  97.     }
  99.     // LICENZE
  100.         /**
  101.          * @Route("/licenze-funzionalita/controlla", name="script_licenses_features_check")
  102.          */
  103.         public function scriptLicensesFeaturesCheck(Request $request)
  104.         {
  105.             $em = $this->mr->getManager();
  106.             $today = new \Datetime();
  107.             $licenses = $em->getRepository('App\Entity\Master\License')->findAllActive();
  108.             $jtlfs = $em->getRepository('App\Entity\Master\JoinTableLicenseFeature')->findAllActive();
  110.             foreach($licenses as $license){
  111.                 if($license->getExpirationDate()->format('Ymd') < $today->format('Ymd')){
  112.                     $license->setActive(false);
  113.                 }
  114.             }
  116.             foreach($jtlfs as $jtlf){
  117.                 if($jtlf->getExpirationDate()->format('Ymd') < $today->format('Ymd')){
  118.                     $jtlf->setActive(false);
  119.                 }
  120.             }
  122.             $em->flush();
  124.             return $this->redirectToRoute("homepage");
  125.         }
  126.     //
  128.     // TICKET
  129.         /**
  130.          * @Route("/ticket/scarica-da-email", name="script_ticket_download_email")
  131.          */
  132.         /*public function scriptTicketDownloadEmail(Request $request)
  133.         {
  134.             $emMaster = $this->mr->getManager('master');
  135.             $session = $request->getSession();
  136.             $companies = $emMaster->getRepository('App\Entity\Master\Company')->findAll();
  137.             $mailbox = "{in.postassl.it:993/imap/ssl}INBOX";
  138.             $first = true;
  139.             $json = "[";
  140.             foreach($companies as $company){
  141.                 $session->set('companyId', $company->getId());
  142.                 $em = CompanyService::getSlaveManagerByCompany($this->mr, $this->params, $company);
  143.                 foreach($company->getMailers() as $mailer){
  144.                     $count = 0;
  145.                     $countTicket = 0;
  146.                     $countTicketError = 0;
  147.                     $inbox = imap_open($mailbox, $mailer->getUser(), EncryptionService::decrypt($mailer->getPassword())) or die('Impossibile connettersi alla casella email: '.imap_last_error()); // Connessione alla casella email
  148.                     $emails = imap_search($inbox, 'UNSEEN'); // Cerca tutte le email da leggere
  149.                     $testing = $this->params->get('ticket_download_script_testing');
  150.                     $error = false;
  152.                     if($emails){
  153.                         rsort($emails); // Ordino con la più nuova in cima
  154.                         foreach($emails as $email){
  155.                             if($count < 600)
  156.                                 [$countTicket, $countTicketError] = TicketService::downloadTicket($em, $emMaster, $inbox, $email, $mailer, $testing, $company,$countTicket, $countTicketError);
  157.                             else
  158.                                 break;
  159.                             $count++;
  160.                         }
  161.                     }
  162.                     if(!$testing){
  163.                         imap_expunge($inbox); // Elimina le mail "marcate"
  164.                         imap_close($inbox); // Chiude la connessione
  165.                     }
  167.                     if($first) $first = false; else $json.=", ";
  168.                     
  169.                     $json.= '{"Account": "'.$mailer->getUser().'", "E-mail processate":"'.$count.'", "Ticket scaricati":"'.$countTicket.'", "Ticket con errori":"'.$countTicketError.'"}';
  170.                 }
  171.             }
  172.             $json.= "]";
  174.             return  new Response(json_encode(array("scriptTicketDownloadEmail" => $json)));
  175.         }*/
  176.         
  177.         /**
  178.          * @Route("/ticket/scarica-da-email-per-mailer/{mailerNickname}", name="script_ticket_download_email_by_mailer")
  179.          */
  180.         public function scriptTicketDownloadEmailByMailer(Request $request, MailerInterface $theburMailer, $mailerNickname)
  181.         {
  182.             $emMaster = $this->mr->getManager('master');
  183.             $mailer =  $emMaster->getRepository('App\Entity\Master\CompanyMailer')->findOneByNickname($mailerNickname);
  184.             $mailbox = "{in.postassl.it:993/imap/ssl}INBOX";
  186.             $em = CompanyService::getSlaveManagerByCompany($this->mr, $this->params, $mailer->getCompany());
  187.             $count = 0;
  188.             $countTicket = 0;
  189.             $countTicketError = 0;
  190.             $inbox = imap_open($mailbox, $mailer->getUser(), EncryptionService::decrypt($mailer->getPassword())) or die('Impossibile connettersi alla casella email: '.imap_last_error()); // Connessione alla casella email
  191.             $emails = imap_search($inbox, 'UNSEEN'); // Cerca tutte le email da leggere
  192.             $testing = $this->params->get('ticket_download_script_testing');
  193.             $error = false;
  195.             if($emails){
  196.                 rsort($emails); // Ordino con la più nuova in cima
  197.                 foreach($emails as $email){
  198.                     if($count < 600){
  199.                         // INOLTRO A THEBURMANUTENZIONE@GMAIL.COM
  200.                         if($mailerNickname == "thebursrl"){
  201.                             $overview = imap_fetch_overview($inbox, $email, 0);
  202.                             $isRead = isset($overview[0]->seen) && $overview[0]->seen == 1;
  203.                             if(!$isRead){
  204.                                 $header = imap_headerinfo($inbox, $email); // Gestisco l'header                            
  205.                                 // Serve per skippare le email che non hanno mittente o di spam
  206.                                 if(property_exists($header, 'from') && property_exists($header->from[0], 'host'))
  207.                                     $sender = $header->from[0]->mailbox."@".$header->from[0]->host;
  208.                                 if($sender == "thebur.manutenzioni@gmail.com"){
  209.                                     $body = imap_fetchbody($inbox, $email, 1.2);
  210.                                     $subject = $header->subject;
  211.                                     $to = 'thebur.integrations@gmail.com';
  213.                                     $headers = "From: $sender\r\n";
  214.                                     $headers .= "Reply-To: $sender\r\n";
  215.                                     $headers .= "X-Mailer: PHP/" . phpversion();
  217.                                     mail($to, $subject, $body, $headers);
  218.                                     imap_setflag_full($inbox, $email, "\\SEEN");
  219.                                 }
  220.                             }
  221.                         }
  223.                         [$countTicket, $countTicketError] = TicketService::downloadTicket($em, $emMaster, $inbox, $email, $mailer, $testing, $mailer->getCompany(), $countTicket, $countTicketError);
  224.                     }
  225.                     else
  226.                         break;
  227.                     $count++;
  228.                 }
  229.             }
  230.             if(!$testing){
  231.                 imap_expunge($inbox); // Elimina le mail "marcate"
  232.                 imap_close($inbox); // Chiude la connessione
  233.             }
  234.             
  235.             $json= '{"Account": "'.$mailer->getUser().'", "E-mail processate":"'.$count.'", "Ticket scaricati":"'.$countTicket.'", "Ticket con errori":"'.$countTicketError.'"}';
  237.             return  new Response(json_encode(array("scriptTicketDownloadEmailByMailer" => $json)));
  238.         }
  240.         /**
  241.          * @Route("/ticket/sblocca-sospensioni-approvate-e-concluse", name="script_ticket_unlock_approved_and_expired_suspensions")
  242.          */
  243.         public function scriptTicketUnlockApprovedAndExpiredSuspensions(Request $request)
  244.         {
  245.             $emMaster = $this->mr->getManager('master');
  246.             $session = $request->getSession();
  247.             $companies = $emMaster->getRepository('App\Entity\Master\Company')->findAll();
  248.             $first = true;
  249.             $json='[';
  250.             foreach($companies as $company){
  251.                 $session->set('companyId', $company->getId());
  252.                 $em = CompanyService::getSlaveManagerByCompany($this->mr, $this->params, $company);
  253.                 $approvedAndLockedSuspensionsExpired = $em->getRepository('App\Entity\Slave\TicketSuspension')->findAllApprovedLockedExpired();
  255.                 foreach($approvedAndLockedSuspensionsExpired as $sus){
  256.                     if($first) $first = false; else $json.= ', ';
  257.                     $json.='{"ticket":"'.$sus->getTicket()->getNumber().'", "Motivo":"Sospensione terminata"}';
  258.                     $unlockCausal = "Sbloccato automaticamente per fine sospensione";
  259.                     $sus->unlock($unlockCausal, $sus->getDatetimeTo(), $em);
  260.                 }
  261.                 $em->flush();
  262.             }
  264.             $json.=']';
  266.             return  new Response(json_encode(array("script_ticket_unlock_approved_and_expired_suspensions" => $json)));
  267.         }
  269.         /**
  270.          * @Route("/ticket/notifica-prendi-in-carico/{companyCode}", name="script_ticket_notify_take_charge")
  271.          */
  272.         public function scriptTicketNotifyTakeCharge(Request $request, MailerInterface $mailer, $companyCode)
  273.         {
  274.             $emMaster = $this->mr->getManager('master');
  275.             $company = $emMaster->getRepository('App\Entity\Master\Company')->findOneByCode($companyCode);
  276.             $now = new \Datetime();
  277.             $first = true;
  278.             $json='{';
  279.             $em = CompanyService::getSlaveManagerByCompany($this->mr, $this->params, $company);
  281.             $technicians = $em->getRepository("App\Entity\Slave\User")->findTechniciansActive();
  282.             $settingMinutesTakeCharge = $em->getRepository('App\Entity\Slave\Setting')->findOneBy(array('slug' => 'ticket_technician_minutes_take_charge'));
  283.             $settingSunday = $em->getRepository('App\Entity\Slave\Setting')->findOneBy(array('slug' => 'script_sunday_active'));
  284.             $json.= '"Frequenza":"'.$settingMinutesTakeCharge->getValue().'","Invia la domenica":"'.$settingSunday->getValue().'","Da prendere in carico":[';
  285.             if($settingMinutesTakeCharge->getValue() != 'never' && ($now->format('i') % $settingMinutesTakeCharge->getValue() == 0) && ($settingSunday->getValue() == 1 || ($settingSunday->getValue() == 0 && $now->format('N') != 7))){
  286.                 $users = array();
  287.                 foreach($technicians as $t){
  288.                     $onHoliday = false;
  289.                     foreach($t->getHolidays() as $h){
  290.                         if($now->format('Ymd') >= $h->getDateFrom()->format('Ymd') && $now->format('Ymd') <= $h->getDateTo()->format('Ymd')){
  291.                             $onHoliday = true;
  292.                             break;
  293.                         }
  294.                     }
  295.                     if(!$onHoliday){
  296.                         $tickets = $em->getRepository('App\Entity\Slave\Ticket')->findByUserAndStatus($t->getId(), 'assigned');
  297.                         if(sizeof($tickets) > 0)
  298.                             array_push($users, array($t, $tickets));
  299.                     }
  300.                 }
  301.                 
  302.                 foreach($users as $u){
  303.                     if($first) $first = false; else $json.= ', ';
  304.                     $json.='{"Tecnico":"'.$u[0].'", "E-mail":"'.$u[0]->getEmail().'", "Ticket da prendere in carico":"'.sizeof($u[1]).'"}';
  305.                     $message = (new TemplatedEmail())
  306.                         ->subject($this->params->get('subject_ticket_take_charge'))
  307.                         ->from($this->params->get('email_noreply'))
  308.                         ->to($u[0]->getEmail())
  309.                         ->htmlTemplate('email/technician_tickets.html.twig')
  310.                         ->context(['user' => $u[0], 'tickets' => $u[1]]);
  311.                     $mailer->send($message);
  312.                 }
  313.             }
  315.             $json.=']}';
  317.             return  new Response(json_encode(array("script_ticket_notify_take_charge" => $json)));
  318.         }
  320.         /**
  321.          * @Route("/chiavi-mappatura/aggiungi", name="script_mapping_key_add")
  322.          */        
  323.         public function scriptMappingKeyAdd(Request $request)
  324.         {    
  325.             //return false;
  326.             $emMaster = $this->mr->getManager('master');
  327.             $session = $request->getSession();
  328.             $companies = $emMaster->getRepository('App\Entity\Master\Company')->findAll();
  329.             $now = new \Datetime();
  330.             $first = true;
  331.             $json='[';
  332.             foreach($companies as $company){
  333.                 $em = CompanyService::getSlaveManagerByCompany($this->mr, $this->params, $company);
  334.                 $addCount = 0;
  335.                 $skipCount = 0;
  336.                 $session->set('companyId', $company->getId());
  337.                 $operations = $em->getRepository("App\Entity\Slave\Operation")->findAll();
  339.                 foreach($operations as $operation){
  340.                     // SE NON E UAV -> INSERISCO I KEY MAPPING
  341.                     if(!$operation->isUav()){
  342.                         $arrayKeyMappings = array(
  343.                             //0 => array('Cluster', '122', '0', '0', '0')
  344.                         );
  346.                         foreach($arrayKeyMappings as $km){
  347.                             $operationKeyMapping = $em->getRepository("App\Entity\Slave\OperationKeyMapping")->findOneByOperationAndColumn($operation->getId(), $km[0]);
  348.                             if($operationKeyMapping == null){
  349.                                 $addCount++;
  350.                                 $operationKeyMapping = new OperationKeyMapping();
  351.                                 $operationKeyMapping->setOperation($operation);
  352.                                 $operationKeyMapping->setTicketColumn($km[0]);
  353.                                 $operationKeyMapping->setPriority($km[1]);
  354.                                 $operationKeyMapping->setKeyRequired($km[2]);
  355.                                 $operationKeyMapping->setTicketNumber($km[3]);
  356.                                 $operationKeyMapping->setTermid($km[4]);
  357.                                 $em->persist($operationKeyMapping);
  358.                             }
  359.                             else
  360.                                 $skipCount++;
  361.                         }
  362.                     }
  363.                     else
  364.                         $skipCount++;
  365.                 }
  367.                 $em->flush();
  368.                 
  369.                 if($first) $first = false; else $json.=', ';
  370.                 $json.='{"Azienda":"'.$company->getName().'", "Chiavi inserite":"'.$addCount.'", "Chiavi già presenti":"'.$skipCount.'"}';
  371.             }
  372.             $json.=']';
  374.             return  new Response(json_encode(array("script_mapping_key_add" => $json)));
  375.         }
  377.     //
  379. }