src/Controller/ProcessosController.php line 676

Open in your IDE?
  1. <?php
  2. namespace App\Controller;
  4. use App\Controller\CorreuController;
  5. use App\Entity\Abonaments;
  6. use App\Entity\PersonType;
  7. use App\Entity\Consumers;
  8. use App\Entity\ValorsWsAxess;
  9. use App\Entity\Paisos;
  10. use App\Entity\Perfils;
  11. use App\Entity\Rgpd;
  12. use App\Entity\ComandesLinies;
  13. use App\Util\changeSize;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  20. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  21. use Symfony\Component\Mailer\MailerInterface;
  22. use Symfony\Component\Security\Core\Security;
  23. use Symfony\Component\Security\Core\SecurityContext;
  24. use App\Entity\ConsumersHasConsumers;
  25. use App\Controller\WebServicesCustomerAccountController;
  26. use Symfony\Component\Translation\LocaleSwitcher;
  28. class ProcessosController extends AbstractController
  29. {
  30.     var $sBDname;
  31.     //var $sBDname = 'TT_AXESS_MAS_Integracions'; //Real
  32.     //var $sBDname = 'TT_AXESS_MAT_Integracions'; //BETA Copia de Real
  33.     var $sServer = '192.168.20.179';
  34.     var $sUserName = 'Entorno';
  35.     var $sPassword = 'Etn@2537';
  36.     var $sBase;
  38.     private $em;
  39.     private $objUtil;
  40.     private $phpmailer;
  41.     private $sPathUploads;
  43.     public function __construct(EntityManagerInterface $em)
  44.     {
  45.         $this->em = $em;
  46.         $this->objUtil = new \App\Util\Util($this->em);
  47.         $this->phpmailer = new CorreuController();
  48.         $this->sPathUploads = dirname(__FILE__) . "/../../public/uploads/";
  49.         switch ($_SERVER['SERVER_NAME'])
  50.         {
  51.             case 'masella.com':
  52.             case 'www.masella.com':
  53.             case 'beta.masella.com':
  54.                 $this->sBase = '/var/www/vhosts/masella.com/httpdocs/';
  55.                 $this->sBDname = 'TT_AXESS_MAS_Integracions'; //Real
  56.                 break;
  57.             case 'dev22.masella.com':
  58.                 $this->sBase = '/var/www/vhosts/' . $_SERVER['SERVER_NAME'] . '/httpdocs/';
  59.                 $this->sBDname = 'TT_AXESS_MAS_Integracions'; //Real
  60.                 break;
  61.             case 'dev23.masella.com':
  62.             case 'sf6.masella.com':
  63.             case 'new.masella.com':
  64.                 $this->sBase = '/var/www/vhosts/' . $_SERVER['SERVER_NAME'] . '/httpdocs/';
  65.                 $this->sBDname = 'TT_AXESS_MAT_Integracions'; //BETA Copia de Real
  66.                 break;
  67.             case 'masella015.developer.entorno.es':
  68.                 $this->sBase = '/home/jramon/projects/masella2015/';
  69.                 $this->sBDname = 'TT_AXESS_MAT_Integracions'; //BETA Copia de Real
  70.                 break;
  71.         }
  72.     }
  74.     public function check_email_sqlserver($sEmail, $Consumer_id_Proj = null, $Consumer_id_Pos = null, $Consumer_id_Num = null, $aAux = array())
  75.     {
  76.         /* Connect using Windows Authentication. */
  77.         try {
  78.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  79.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  80.         } catch (Exception $e) {
  81.             //die(print_r($e->getMessage(), false));
  82.             $bRes = $this->phpmailer->EnviarAction(array(
  83.                 'sSubjecte' => 'Error en la connexió amb sqlsrv ',
  84.                 'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  85.                 'sTo'       => $this->getParameter('EMAIL_ERRORES'),
  86.                 'sMissatge' => print_r($e->getMessage(), false),
  87.             ));
  89.         }
  90.         $tsql = "SELECT * FROM v_AXESS_CONSUMERS "
  91.                 . " WHERE Email = '" . $sEmail . "'"
  92.                 . " AND Actiu = -1";
  93.         if (!is_null($Consumer_id_Proj)
  94.             && !is_null($Consumer_id_Pos)
  95.             && !is_null($Consumer_id_Num))
  96.         {
  97.             $tsql .= " AND NOT (Consumer_id_Proj = " . $Consumer_id_Proj;
  98.             $tsql .= " AND Consumer_id_Pos =" . $Consumer_id_Pos;
  99.             $tsql .= " AND Consumer_id_Num =" . $Consumer_id_Num . ")";
  100.         }
  102.         $aResult = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  103.         if ($aResult)
  104.         {
  105.             /*
  106.             if ($aResult[0]['Email'] != '') {
  107.                 /////////////////////////////////////////////////
  108.                 /// Creem el CustomerAccount si el email existeix
  109.                 /////////////////////////////////////////////////
  110.                 $objWebServicesCustomerAccount = new WebServicesCustomerAccountController();
  111.                 /////////////////////////////////////////////////////////////////////////////////////
  112.                 /// Quan la cridem com una clase no te acces al getParameter, així li passem el valor
  113.                 /////////////////////////////////////////////////////////////////////////////////////
  114.                 $objContainer = $aAux['container'];
  115.                 $objMailer = $aAux['mailer'];
  116.                 $objWebServicesCustomerAccount->setEnviroments($objContainer->getParameter('kernel.environment'));
  117.                 $objWebServicesCustomerAccount->setObjContainer($objContainer);
  118.                 $objWebServicesCustomerAccount->setObjGetMailer($objMailer);
  120.                 $aElements = array('i_nPersProjNo' => $aResult[0]['Consumer_id_Proj'],
  121.                     'i_nPersPosNo' => $aResult[0]['Consumer_id_Pos'],
  122.                     'i_nPersPersNo' => $aResult[0]['Consumer_id_Num'],
  123.                     'i_szUserName' => $aResult[0]['Email'],
  124.                     'i_szPassword' => $aAux['texto_aleatorio'],
  125.                 );
  126.                 $jsonReturn = $objWebServicesCustomerAccount->createCustomerAccount($aElements);
  127.                 $aReturnCreateCustomerAccount = json_decode($jsonReturn->getContent(), true);
  128.                 if ($aReturnCreateCustomerAccount['error']['CreateCustomerFromPerson']) {
  129.                 } else {
  130.                     ///////////////////////////////////////////////////////////////////////////
  131.                     // l'Error -3 segurament és per que ja existeix Account per aquest customer
  132.                     ///////////////////////////////////////////////////////////////////////////
  133.                     if ($aReturnCreateCustomerAccount['error']['NERRORNO'] != -3) {
  134.                         $sMensaje = "Error al crear l'account a ProcessosController" . "\n";
  135.                         $sMensaje .= print_r($aReturnCreateCustomerAccount, true);
  136.                         $this->phpmailer->EnviarAction(array(
  137.                             'sSubjecte' => "Error al crear l'account a ProcessosController",
  138.                             'sFrom'     => $objContainer->getParameter('EMAIL_RESERVAS'),
  139.                             'sTo'       => $objContainer->getParameter('EMAIL_ERRORES'),
  140.                             'sMissatge' => $sMensaje,
  141.                         ));
  143.                     }
  144.                 }
  145.             }
  146.             */
  147.         }
  148.         $iTotal = count($aResult);
  149.         return ($iTotal == 0?0:1);
  150.     }
  152.     public function insetPersonTypeindexAction(Request $peticion)
  153.     {
  154.         $aRequest = $peticion->request;
  156.         echo 'Inici -> ' . date('Y-m-d H:i:s') . '<br>';
  158.         /* Connect using Windows Authentication. */
  159.         try {
  160.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  161.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  162.         } catch (Exception $e) {
  163.             die(print_r($e->getMessage(), false));
  164.         }
  166.         $tsql = "SELECT * FROM V_AXESS_PERSONTYPE";
  168.         echo $tsql;
  170.         $aResult = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  172.         $iPersonTypeCount = count($aResult);
  173.         echo '<br>Total PersonType a carregar:' . $iPersonTypeCount . '<br>';
  174.         if ($aResult > 0) 
  175.         {
  176.             foreach ($aResult as $row) 
  177.             {
  178.                 echo '<pre>';
  179.                 print_r($row);
  180.                 echo '</pre>';
  182.                 $aArray = array('id_axess' => $row['PersonType_id']);
  183.                 $enPersonTypeAux = $this->em->getRepository(PersonType::class)->findBy($aArray);
  184.                 $enPersonType = array();
  185.                 if ($enPersonTypeAux) 
  186.                 {
  187.                     $enPersonType = $this->em->getRepository(PersonType::class)->find($enPersonTypeAux[0]->getId());
  188.                 }
  189.                 
  190.                 if (!$enPersonType) 
  191.                 {
  192.                     $enPersonType = new PersonType();
  193.                 }
  194.                 $enPersonType->setIdAxess($row['PersonType_id']);
  195.                 $enPersonType->setNomCa($row['PersonType_desc']);
  196.                 $enPersonType->setNomEn($row['PersonType_desc']);
  197.                 $enPersonType->setNomEs($row['PersonType_desc']);
  198.                 $enPersonType->setNomFr($row['PersonType_desc']);
  199.                 $enPersonType->setNomPt($row['PersonType_desc']);
  200.                 $enPersonType->setIdGeneral(intval($row['PersonType_General_id']));
  201.                 $enPersonType->setNomGeneralCa($row['PersonType_General_desc']);
  202.                 $enPersonType->setNomGeneralEn($row['PersonType_General_desc']);
  203.                 $enPersonType->setNomGeneralEs($row['PersonType_General_desc']);
  204.                 $enPersonType->setNomGeneralFr($row['PersonType_General_desc']);
  205.                 $enPersonType->setNomGeneralPt($row['PersonType_General_desc']);
  206.                 //$enPersonType->setNomGeneralPt('hlhlhl');
  207.                 $this->em->persist($enPersonType);
  208.                 $this->em->flush();
  209.             }
  210.         }
  211.         echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  212.         return new Response('Finalitzat');
  213.     }
  215.     /**
  216.      * Updates "Abonaments" entities with data imported from an external source,
  217.      * while deactivating old records and inserting or updating new ones based on input data.
  218.      *
  219.      * This method connects to an external SQL Server database using Windows Authentication,
  220.      * fetches external data, and processes each record to either create a new entity or update an existing one.
  221.      *
  222.      * @param Request $peticion The HTTP request triggering the update process.
  223.      *
  224.      * @throws \PDOException If an error occurs while connecting to the external database.
  225.      * @throws \Exception Any unexpected exception during the process.
  226.      */
  227.     public function insetUpdateTarifasAction(Request $peticion)
  228.     {
  229.         echo 'Inici -> ' . date('Y-m-d H:i:s') . '<br>';
  231.         /* Connect using Windows Authentication. */
  232.         try {
  233.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  234.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  235.         } catch (Exception $e) {
  236.             die(print_r($e->getMessage(), false));
  237.         }
  239.         ////////////////////////////////////////////////////////////////////////////////////
  240.         /// Desactivem els abonaments per posteriorment activar els que venen de la migració
  241.         ////////////////////////////////////////////////////////////////////////////////////
  242.          $sQuery =   "UPDATE App:Abonaments abo SET "
  243.                     . " abo.actiu = :actiu";
  245.         $query = $this->em->createQuery($sQuery)
  246.             ->setParameter('actiu', 0);
  247.         $enAbonaments = $query->getResult();
  249.         $tsql = "SELECT * FROM V_ENTORNO_PREUS ORDER BY Pool_id ASC, TicketType_id ASC, PersonType_General_id ASC ";
  251.         //echo $tsql;
  253.         $aResult = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  255.         $iPersonTypeCount = count($aResult);
  256.         echo '<br>Total tarifes a carregar:' . $iPersonTypeCount . '<br>';
  257.         if ($aResult > 0) 
  258.         {
  259.             $iOrdre = 0;
  260.             foreach ($aResult as $row) {
  261.                 echo '<pre>';
  262.                 print_r($row);
  263.                 echo '</pre>';
  264.                 //die('stop');
  265.                 $aArray = array(
  266.                     'tariff_sheet_id' => $row['TariffSheet_id'],
  267.                     'tarifa_id' => $row['Tarifa_id'],
  268.                     'section_id' => $row['Section_id'],
  269.                     'ticket_type_id' => $row['TicketType_id'],
  270.                     'pool_id' => $row['Pool_id'],
  271.                     'person_type_id' => $row['PersonType_id'],
  272.                     'person_type_general_id' => $row['PersonType_General_id'],
  273.                 );
  275.                 $enAbonamentsAux = $this->em->getRepository(Abonaments::class)->findOneBy($aArray);
  277.                 if ($enAbonamentsAux) {
  278.                     $enAbonaments = $this->em->getRepository(Abonaments::class)->find($enAbonamentsAux->getId());
  279.                 } else {
  280.                     $enAbonaments = new Abonaments();
  281.                 }
  282.                 $enAbonaments->setPerId(null);
  283.                 $enAbonaments->setNomCa($row['TicketType_desc2']);
  284.                 $enAbonaments->setNomEs($row['TicketType_desc2']);
  285.                 $enAbonaments->setNomEn($row['TicketType_desc2']);
  286.                 $enAbonaments->setNomFr($row['TicketType_desc2']);
  287.                 $enAbonaments->setNomBreuCa($row['TicketType_desc2']);
  288.                 $enAbonaments->setNomBreuEn($row['TicketType_desc2']);
  289.                 $enAbonaments->setNomBreuEs($row['TicketType_desc2']);
  290.                 $enAbonaments->setNomBreuFr($row['TicketType_desc2']);
  291.                 if ($row['Entorno_Tipus'] == 'EXT') {
  292.                     $enAbonaments->setEstacio('Extra');
  293.                 } else {
  294.                     $enAbonaments->setEstacio($row['Entorno_Tipus']);
  295.                 }
  296.                 $enAbonaments->setTariffSheetId($row['TariffSheet_id']);
  297.                 $enAbonaments->setTarifaId($row['Tarifa_id']);
  298.                 $enAbonaments->setTarifaDesc($row['Tarifa_desc']);
  299.                 $enAbonaments->setSectionId($row['Section_id']);
  300.                 $enAbonaments->setSectionDesc($row['Section_desc']);
  301.                 //$dateTime = new \DateTime();
  302.                 //echo $dateTime->setTimestamp(substr($row['Section_data_ini'],0,10));
  303.                 $enAbonaments->setDataInici(new \DateTime(substr($row['Section_data_ini'], 0, 10)));
  304.                 $enAbonaments->setDataIniciCalendari(new \DateTime(substr($row['Section_data_ini'], 0, 10)));
  305.                 $enAbonaments->setDataFi(new \DateTime(substr($row['Section_data_fi'], 0, 10)));
  306.                 $enAbonaments->setDataFiCalendari(new \DateTime(substr($row['Section_data_fi'], 0, 10)));
  307.                 $enAbonaments->setTicketTypeId(intval($row['TicketType_id']));
  308.                 $enAbonaments->setTicketTypeDesc($row['TicketType_desc']);
  309.                 $enAbonaments->setPoolId($row['Pool_id']);
  310.                 $enAbonaments->setPoolDesc($row['Pool_desc']);
  311.                 $enAbonaments->setPersonTypeId($row['PersonType_id']);
  312.                 $enAbonaments->setPersonTypeDesc($row['PersonType_desc']);
  313.                 $enAbonaments->setPersonTypeGeneralId($row['PersonType_General_id']);
  314.                 $enAbonaments->setPersonTypeGeneralDesc($row['PersonType_General_desc']);
  315.                 $enAbonaments->setPreu($row['Preu']);
  316.                 $enAbonaments->setActiu(1);
  317.                 $enAbonaments->setFamiliar(0);
  318.                 $enAbonaments->setEmpresa(0);
  319.                 $enAbonaments->setSuplement(0);
  320.                 $enAbonaments->setSenseSuplement(0);
  321.                 $enAbonaments->setOrdre($row['Entorno_Ordre']);
  322.                 $enAbonaments->setAtribut($row['Atribut']);
  323.                 if ($row['OP_Public'] == 'S') {
  324.                     $enAbonaments->setNomesTablet(0);
  325.                 } else {
  326.                     $enAbonaments->setNomesTablet(1);
  327.                 }
  329.                 if ($row['OP_Clubs'] == 'S')
  330.                 {
  331.                     $enAbonaments->setClubEsqui(1);
  332.                 }
  334.                 if ($row['OP_Clubs'] == 'S'
  335.                     || $row['OP_Clubs1'] == 'S'
  336.                     || $row['OP_Clubs2'] == 'S'
  337.                     || $row['OP_Clubs3'] == 'S'
  338.                     || $row['OP_Clubs4'] == 'S'
  339.                 ) {
  340. //                    if ($row['OP_Oficina'] != 'S')
  341. //                    {
  342. //                        //////////////////////////////////////////////////
  343. //                        // assignem el perfil de club d'esquí que és el 14
  344. //                        //////////////////////////////////////////////////
  345.                         $enPerfils = $this->em->getRepository(Perfils::class)->find(14);
  346.                         $enAbonaments->setPerId($enPerfils);
  347. //                    }
  348.                 } else {
  349.                     $enAbonaments->setClubEsqui(0);
  350.                 }
  352.                 if ($row['OP_Clubs1'] == 'S') {
  353.                     $enAbonaments->setClubs1(1);
  354.                 } else {
  355.                     $enAbonaments->setClubs1(0);
  356.                 }
  357.                 if ($row['OP_Clubs2'] == 'S') {
  358.                     $enAbonaments->setClubs2(1);
  359.                 } else {
  360.                     $enAbonaments->setClubs2(0);
  361.                 }
  362.                 if ($row['OP_Clubs3'] == 'S') {
  363.                     $enAbonaments->setClubs3(1);
  364.                 } else {
  365.                     $enAbonaments->setClubs3(0);
  366.                 }
  367.                 if ($row['OP_Clubs4'] == 'S') {
  368.                     $enAbonaments->setClubs4(1);
  369.                 } else {
  370.                     $enAbonaments->setClubs4(0);
  371.                 }
  373. //                if ($row['OP_Oficina'] != 'S'
  374. //                    && $row['OP_Admin'] == 'S') {
  375. //                    ///////////////////////////////////////////
  376. //                    // assignem el perfil de l'Ari que és el 15
  377. //                    ///////////////////////////////////////////
  378. //                    $enPerfils = $this->em->getRepository(Perfils::class)->find(15);
  379. //                    $enAbonaments->setPerId($enPerfils);
  380. //                } else {
  381. //                    //$enAbonaments->setPerId(null);
  382. //                }
  383.                 if ($row['OP_FiresOficines'] == 'S')
  384.                 {
  385.                     $enAbonaments->setFiresOficina(1);
  386.                 } else {
  387.                     $enAbonaments->setFiresOficina(0);
  388.                 }
  390.                 if ($row['OP_Admin'] == 'S')
  391.                 {
  392.                     $enAbonaments->setAdmin(1);
  393.                 } else {
  394.                     $enAbonaments->setAdmin(0);
  395.                 }
  397.                 if ($row['EsSuplement'] == 'S')
  398.                 {
  399.                     $enAbonaments->setSuplement(1);
  400.                 } else {
  401.                     $enAbonaments->setSuplement(0);
  402.                 }
  403.                 if ($row['EsNocturn'] == 'S')
  404.                 {
  405.                     $enAbonaments->setNocturn(1);
  406.                 } else {
  407.                     $enAbonaments->setNocturn(0);
  408.                 }
  409.                 if ($row['EsPackFamiliar'] == 'S')
  410.                 {
  411.                     $enAbonaments->setFamiliar(1);
  412.                 } else {
  413.                     $enAbonaments->setFamiliar(0);
  414.                 }
  415.                 if ($row['Es_Alp2500'] == 'S') // Si és temporada Alp2500
  416.                 {
  417.                     $enAbonaments->setAlp2500(1);
  418.                 } else {
  419.                     $enAbonaments->setAlp2500(0);
  420.                 }
  421.                 if ($row['Te_Dte_Lessio'] == 'S')
  422.                 {
  423.                     $enAbonaments->setTeDescompteLesio(1);
  424.                 } else {
  425.                     $enAbonaments->setTeDescompteLesio(0);
  426.                 }
  428.                 $this->em->persist($enAbonaments);
  429.                 $this->em->flush();
  430.             }
  431.         }
  432.         echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  433.         return new Response('Finalitzat');
  434.     }
  436.     function updateConsumersByAxessAction()
  437.     {
  438.         set_time_limit(300000);
  440.         if ($this->getParameter('kernel.environment') == 'dev')
  441.         {
  442.             $bTest = true;
  443.             echo "Inici actualització a entorno de consumers des de sqlServer: " . date("Y-m-d H:i:s") . '<br>';
  444.         } else {
  445.             $bTest = false;
  446.         }
  448.         /* Connect using Windows Authentication. */
  449.         try {
  450.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  451.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  452.         } catch (Exception $e) {
  453.             die(print_r($e->getMessage(), false));
  454.         }
  456.         $sDataHora = date("Y_m_d_H_i_s");
  457.         $this->sDir = $this->sBase . 'query_ws/';
  459.         $sReturn = "EN-1|No hi ha consumers per modificar";
  460.         $aResultats = array();
  461.         $entityValorsWsAxess = $this->em->getRepository(ValorsWsAxess::class)->find(1);
  463.         if ($entityValorsWsAxess)
  464.         {
  465.             $dUltimaModificacio = $entityValorsWsAxess->getUltimDataModificacioConsumers();
  466.             $dUltimaModificacio = $dUltimaModificacio->format("Y-m-d") . 'T' . $dUltimaModificacio->format("H:i:s") . ".000";
  467.             $iCuantosRegistros = 500;
  468.             $iIniciRegistres = 0;
  469.             $aResultats = array();
  470.             $iCon = 0;
  471.             do{
  472.                 $iTotalRegistresLlegits = 0;
  473.                 ///////////////////////////////////////////
  474.                 // consulta a l'sqlServer amb la data
  475.                 ///////////////////////////////////////////
  476.                 $tsql = "SELECT * FROM v_AXESS_CONSUMERS";
  477.                 $tsql .= " WHERE 1=1";
  478.                 //$tsql .= " AND Consumer_id_Pos= 35";
  479.                 //$tsql .= " AND Consumer_id_Num= 12997";
  480.                 $tsql .= " AND TIPUS_LOG = 'U'";
  481.                 $tsql .= " AND TT_Data_actualitzacio >= '" . str_replace(' ', 'T', $dUltimaModificacio) . "'";
  482.                 $tsql .= " ORDER BY TT_Data_actualitzacio ASC, Consumer_id DESC";
  483.                 $tsql .= " OFFSET " . $iIniciRegistres . " ROWS FETCH FIRST " . $iCuantosRegistros . " ROWS ONLY ";
  484.                 //echo $tsql;
  485.                 //$getConsumers = $conn->prepare($tsql, [PDO::ATTR_CURSOR => PDO::CURSOR_SCROLL,]);
  486.                 $getConsumers = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  487.                 echo '<br>' . count($getConsumers) . '<br>';
  488.                 //die('stop');
  489.                 //$getConsumers->execute();
  490.                 //$aResult = $getConsumers->fetchAll(PDO::FETCH_ASSOC);
  491.                 //$iConsumersCount = count($aResult);
  492.                 $bDataModificada = false;
  493.                 if ($getConsumers > 0) 
  494.                 {
  495.                     foreach ($getConsumers as $row) 
  496.                     {
  497.                         /*
  498.                         echo '<pre>';
  499.                         print_r($row);
  500.                         echo '</pre>';
  501.                         */
  502.                         ////////////////////////////////////////////////////
  503.                         /// Guardem la data per començar des de aquesta data
  504.                         ////////////////////////////////////////////////////
  506.                         $dUltimaModificacio = $row['TT_Data_actualitzacio'];
  507.                         $bDataModificada = true;
  508.                         ////////////////////////////////////////////////////////////////////////////////
  509.                         // Consultar si existeix el consumer a entorno i si existeix fer l'actualització
  510.                         ////////////////////////////////////////////////////////////////////////////////
  511.                         $aParam = array(    
  512.                             'customer_id_proj'  => $row['Consumer_id_Proj'],
  513.                             'customer_id_pos'   => $row['Consumer_id_Pos'],
  514.                             'customer_id_num'   => $row['Consumer_id_Num']
  515.                         );
  516.                         $enConsumers = $this->em->getRepository(Consumers::class)->findOneBy($aParam);
  517.                         if ($enConsumers)
  518.                         {
  519.                             $iConsumerFill = $enConsumers->getId();
  520.                             //dump($enConsumers);
  521.                             $enConsumersUpdate = $this->em->getRepository(Consumers::class)->find($iConsumerFill);
  522.                             if ($enConsumersUpdate) 
  523.                             {
  524.                                 ////////////////////////////////
  525.                                 // Actualitzar dades de consumer
  526.                                 ////////////////////////////////
  527.                                 $jsonCognoms = $this->objUtil->separarCognoms($row['Cognoms']);
  528.                                 $aCognoms = json_decode($jsonCognoms->getContent(), true);
  529.                                 $enConsumersUpdate->setNom($row['Nom']);
  530.                                 $enConsumersUpdate->setCognoms($row['Cognoms']);
  531.                                 $enConsumersUpdate->setCognom1($aCognoms['cognom1']);
  532.                                 $enConsumersUpdate->setCognom2($aCognoms['cognom2']);
  533.                                 $enConsumersUpdate->setDni($row['Dni']);
  534.                                 $dateTime = new \DateTime();
  535.                                 $enConsumersUpdate->setDataNaixement($dateTime->setTimestamp(strtotime($row['Naixement'])));
  536.                                 $enConsumersUpdate->setDireccio($row['Adreca'] . $row['Adreca2'] . $row['Adreca3']);
  537.                                 $enConsumersUpdate->setCp($row['CodiPostal']);
  538.                                 $enConsumersUpdate->setPoblacio($row['Poblacio']);
  539.                                 $enConsumersUpdate->setEmail($row['Email']);
  540.                                 $enConsumersUpdate->setTelefon($row['Telefon']);
  541.                                 //$enConsumersUpdate->setWtp($row['Wtp_ult']);
  542.                                 $enConsumersUpdate->setOrigenEntrada('Mod sqlServer');
  543.                                 $enConsumersUpdate->setResposta4i(($enConsumersUpdate->getResposta4i() !=''?$enConsumersUpdate->getResposta4i() . '<br>':'') . '|Mod sqlServer|Modificat des del sqlServer el ' .  date('Y-m-d H:i:s') );
  544.                                 $enConsumersUpdate->setDni($row['Dni']);
  545.                                 if ($row['Actiu'] == 0)
  546.                                 {
  547.                                     $enConsumersUpdate->setHistoric(1);
  548.                                 } else {
  549.                                     $enConsumersUpdate->setHistoric(0);
  550.                                 }
  551.                                 //dump ($enConsumersUpdate);
  552.                                 //die('stop');
  553.                                 $this->em->persist($enConsumersUpdate);
  554.                                 $this->em->flush();
  555.                                 $aResultats[$iCon]['consumer'] = $row;
  556.                                 //////////////////////////////////////////////////////
  557.                                 /// Comprova si esta a una familia que no es ell
  558.                                 //////////////////////////////////////////////////////
  559.                                 if ($row['Consumer_id_Proj'] != $row['Familia_id_Proj']
  560.                                     || $row['Consumer_id_Pos'] != $row['Familia_id_Pos']
  561.                                     || $row['Consumer_id_Num'] != $row['Familia_id_Num']
  562.                                 ) {
  563.                                     $aParam = array(
  564.                                         'customer_id_proj'  => $row['Familia_id_Proj'],
  565.                                         'customer_id_pos'   => $row['Familia_id_Pos'],
  566.                                         'customer_id_num'   => $row['Familia_id_Num']
  567.                                     );
  568.                                     $enConsumers = $this->em->getRepository(Consumers::class)->findOneBy($aParam);
  569.                                     if ($enConsumers) 
  570.                                     {
  571.                                         $iConsumerPare = $enConsumers->getId();
  572.                                         ////////////////////
  573.                                         /// Creem la familia
  574.                                         ////////////////////
  575.                                         $blRes = $this->forward('App\Controller\ConsumersHasConsumersController::addFamiliaAction', array(
  576.                                             'aValues' => array( 
  577.                                                 'consumers'         => $iConsumerPare,
  578.                                                 'consumers_fill'    => $iConsumerFill,
  579.                                             ))
  580.                                         );
  581.                                         if ($blRes)
  582.                                         {
  583.                                             $aResultats[$iCon]['familia'] = array(  
  584.                                                 'pare'  => $iConsumerPare,
  585.                                                 'fill'  => $iConsumerFill
  586.                                             );
  587.                                         }
  588.                                     }
  589.                                 }
  590.                             }
  591.                             ////////////////////////////////////////////////
  592.                             // TODO: S'ha de treure aquest break a real!!!!!
  593.                             ////////////////////////////////////////////////
  594.                             //break;
  595.                         }
  596.                         $iTotalRegistresLlegits++;
  597.                     }
  598.                 }
  599.                 //////////////////////////////////////////////////
  600.                 // Actualitzem els valors a la taula ValorsWsAxess
  601.                 //////////////////////////////////////////////////
  602.                 if ($bDataModificada) 
  603.                 {
  604.                     $dateTime = new \DateTime();
  605.                     $entityValorsWsAxess->setUltimDataModificacioConsumers($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  606.                 }
  607.                 $dateTime = new \DateTime();
  608.                 $entityValorsWsAxess->setUltimaLecturaConsumers($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  609.                 $this->em->persist($entityValorsWsAxess);
  610.                 $this->em->flush();
  612.                 $iIniciRegistres = $iIniciRegistres + $iTotalRegistresLlegits;
  613.                 ////////////////////////////////////////////////
  614.                 // TODO: S'ha de treure aquest break a real!!!!!
  615.                 ////////////////////////////////////////////////
  616.                 //break;
  617.                 //echo '-' . $iTotalRegistresLlegits . '==' . $iCuantosRegistros . '-<br>';
  618.             } while ($iTotalRegistresLlegits == $iCuantosRegistros);
  619.             //echo '-' . $iTotalRegistresLlegits . '==' . $iCuantosRegistros . '-';
  620.         }
  621.         if ($bTest) {
  622.             echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  623.             echo '<pre>';
  624.             dump ($aResultats);
  625.             echo '</pre>';
  626.         }
  628.         if (!empty($aResultats))
  629.         {
  630.             $sDirAux = $this->sDir . 'update_Consumers_Axess';
  631.             if (!file_exists($sDirAux))
  632.             {
  633.                 mkdir($sDirAux, 0777, true);
  634.                 chmod($sDirAux, 0777);
  635.             }
  636.             $sDirAux2 = $sDirAux . '/' . date("Ymd");
  637.             if (!file_exists($sDirAux2))
  638.             {
  639.                 mkdir($sDirAux2, 0777);
  640.                 chmod($sDirAux2, 0777);
  641.             }
  643.             $aFileXmlRequest = fopen($sDirAux2 . '/' . date("Y_m_d_H_i_s") . '_consumers_' . date("YmdHis") . '.txt', 'w');
  644.             foreach ($aResultats as $rId => $rVal)
  645.             {
  646.                 fputs($aFileXmlRequest, $rId . ' : ' . print_r($rVal, true) . PHP_EOL);
  647.             }
  648.             fclose($aFileXmlRequest);
  649.             /*
  650.             $sMissatge = '<pre>' . print_r($aResultats, true) . '</pre>';
  651.             $this->phpmailer->EnviarAction(array(
  652.                 'sSubjecte' => "Masella WSAxess Error Consulta_AMB_Consumers",
  653.                 'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  654.                 'sTo'       => 'jramon@entorno.es',
  655.                 'sMissatge' => $sMissatge,
  656.             ));
  658.             */
  659.         }
  660.         //////////////////////////////////////////////////
  661.         // Actualitzem els valors a la taula ValorsWsAxess
  662.         //////////////////////////////////////////////////
  663.         if ($bDataModificada) 
  664.         {
  665.             $dateTime = new \DateTime();
  666.             $entityValorsWsAxess->setUltimDataModificacioConsumers($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  667.         }
  668.         $dateTime = new \DateTime();
  669.         $entityValorsWsAxess->setUltimaLecturaConsumers($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  670.         $this->em->persist($entityValorsWsAxess);
  671.         $this->em->flush();
  673.         return new Response('Finalitzat');
  674.     }
  676.     function updateCompanyByAxessAction()
  677.     {
  678.         set_time_limit(300000);
  680.         if ($this->getParameter('kernel.environment') == 'dev')
  681.         {
  682.             $bTest = true;
  683.             echo "Inici actualització a entorno de companies des de sqlServer: " . date("Y-m-d H:i:s") . '<br>';
  684.         } else {
  685.             $bTest = false;
  686.         }
  688.         /* Connect using Windows Authentication. */
  689.         try {
  690.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  691.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  692.         } catch (Exception $e) {
  693.             die(print_r($e->getMessage(), false));
  694.         }
  696.         $sDataHora = date("Y_m_d_H_i_s");
  697.         $this->sDir = $this->sBase . 'query_ws/';
  699.         $sReturn = "EN-1|No hi ha companies per modificar";
  700.         $aResultats = array();
  701.         $entityValorsWsAxess = $this->em->getRepository(ValorsWsAxess::class)->find(1);
  702.         if ($entityValorsWsAxess)
  703.         {
  704.             $dUltimaModificacio = $entityValorsWsAxess->getUltimDataModificacioCompany();
  705.             $dUltimaModificacio = $dUltimaModificacio->format("Y-m-d") . 'T' . $dUltimaModificacio->format("H:i:s") . ".000";
  706.             $iCuantosRegistros = 100;
  707.             $iIniciRegistres = 0;
  708.             $aResultats = array();
  709.             $iCon = 0;
  710.             do{
  711.                 $iTotalRegistresLlegits = 0;
  712.                 ///////////////////////////////////////////
  713.                 // consulta a l'sqlServer amb la data
  714.                 ///////////////////////////////////////////
  715.                 $tsql = "SELECT * FROM V_AXESS_CLIENTS";
  716.                 $tsql .= " WHERE 1=1";
  717.                 $tsql .= " AND TT_Data_actualitzacio > '" . str_replace(' ', 'T', $dUltimaModificacio) . "'";
  718.                 $tsql .= " ORDER BY TT_Data_actualitzacio ASC, Client_id DESC";
  719.                 $tsql .= " OFFSET " . $iIniciRegistres . " ROWS FETCH FIRST " . $iCuantosRegistros . " ROWS ONLY ";
  720.                 //echo $tsql;
  721.                 //$getConsumers = $conn->prepare($tsql, [PDO::ATTR_CURSOR => PDO::CURSOR_SCROLL,]);
  722.                 $getConsumers = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  723.                 echo '<br>' . count($getConsumers) . '<br>';
  725.                 //$getConsumers->execute();
  726.                 //$aResult = $getConsumers->fetchAll(PDO::FETCH_ASSOC);
  727.                 //$iConsumersCount = count($aResult);
  728.                 $bDataModificada = false;
  729.                 if ($getConsumers > 0) 
  730.                 {
  731.                     foreach ($getConsumers as $row) 
  732.                     {
  733.                         /*
  734.                         echo '<pre>';
  735.                         print_r($row);
  736.                         echo '</pre>';
  737.                         */
  738.                         ////////////////////////////////////////////////////
  739.                         /// Guardem la data per començar des de aquesta data
  740.                         ////////////////////////////////////////////////////
  741.                         $dUltimaModificacio = $row['TT_Data_actualitzacio'];
  742.                         $bDataModificada = true;
  743.                         ////////////////////////////////////////////////////////////////////////////////
  744.                         // Consultar si existeix el consumer a entorno i si existeix fer l'actualització
  745.                         ////////////////////////////////////////////////////////////////////////////////
  746.                         $aParam = array(    
  747.                             'company_proj_no'   => $row['Client_id_Proj'],
  748.                             'company_pos_no'    => $row['Client_id_Pos'],
  749.                             'company_num'       => $row['Client_id_num']
  750.                         );
  751.                         $enConsumers = $this->em->getRepository(Consumers::class)->findBy($aParam);
  753.                         if ($enConsumers)
  754.                         {
  755.                             foreach ($enConsumers as $key => $aConsumer)
  756.                             {
  757.                                 //dump($aConsumer);
  758.                                 $enConsumersUpdate = $this->em->getRepository(Consumers::class)->find($aConsumer->getId());
  759.                                 if ($enConsumersUpdate) 
  760.                                 {
  761.                                     ////////////////////////////////
  762.                                     // Actualitzar dades de consumer
  763.                                     ////////////////////////////////
  764.                                     $enConsumersUpdate->setNomEmpresa($row['Nom_Fiscal']); // TODO: no se si és Nom_Comercial
  765.                                     $enConsumersUpdate->setNifEmpresa($row['Nif']);
  766.                                     $enConsumersUpdate->setDireccioEmpresa($row['Adreca'] . $row['Adreca2'] . $row['Adreca3']);
  767.                                     $enConsumersUpdate->setCpEmpresa($row['CodiPostal']);
  768.                                     $enConsumersUpdate->setPoblacioEmpresa($row['Poblacio']);
  769.                                     //////////////////////////////////////////////
  770.                                     /// s'ha de recuperar l'objecte del pais
  771.                                     //////////////////////////////////////////////
  772.                                     $objPais = $this->em->getRepository(Paisos::class)->findOneBy(array('iso2' =>$row['Pais']));
  773.                                     if ($objPais) 
  774.                                     {
  775.                                         $enConsumersUpdate->setPaiId($objPais);
  776.                                     }
  777.                                     $enConsumersUpdate->setProvinciaEmpresa($row['Provincia']);
  778.                                     $enConsumersUpdate->setOrigenEntrada('Mod sqlServer');
  779.                                     $enConsumersUpdate->setResposta4i(($enConsumersUpdate->getResposta4i() != '' ? $enConsumersUpdate->getResposta4i() . '<br>' : '') . '|Mod sqlServer Company|Modificat des del sqlServer el ' . date('Y-m-d H:i:s'));
  780.                                     //$enConsumersUpdate->setDni(???);
  782.                                     //dump ($enConsumersUpdate);
  783.                                     //die('stop');
  784.                                     $this->em->persist($enConsumersUpdate);
  785.                                     $this->em->flush();
  786.                                     $aResultats[$iCon]['Company'] = $row;
  787.                                 }
  788.                                 ////////////////////////////////////////////////
  789.                                 // TODO: S'ha de treure aquest break a real!!!!!
  790.                                 ////////////////////////////////////////////////
  791.                                 //break;
  792.                             }
  793.                         }
  794.                         $iTotalRegistresLlegits++;
  795.                     }
  796.                 }
  797.                 //////////////////////////////////////////////////
  798.                 // Actualitzem els valors a la taula ValorsWsAxess
  799.                 //////////////////////////////////////////////////
  800.                 if ($bDataModificada) 
  801.                 {
  802.                     $dateTime = new \DateTime();
  803.                     $entityValorsWsAxess->setUltimDataModificacioCompany($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  804.                 }
  805.                 $dateTime = new \DateTime();
  806.                 $entityValorsWsAxess->setUltimaLecturaCompany($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  807.                 $this->em->persist($entityValorsWsAxess);
  808.                 $this->em->flush();
  810.                 $iIniciRegistres = $iIniciRegistres + $iTotalRegistresLlegits;
  811.                 ////////////////////////////////////////////////
  812.                 // TODO: S'ha de treure aquest break a real!!!!!
  813.                 ////////////////////////////////////////////////
  814.                 //break;
  815.             } while ($iTotalRegistresLlegits == $iCuantosRegistros);
  817.         }
  818.         if ($bTest) 
  819.         {
  820.             echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  821.             echo '<pre>';
  822.             dump ($aResultats);
  823.             echo '</pre>';
  824.         }
  826.         if (!empty($aResultats))
  827.         {
  828.             $sDirAux = $this->sDir . 'update_Company_Axess';
  829.             if (!file_exists($sDirAux))
  830.             {
  831.                 mkdir($sDirAux, 0777, true);
  832.                 chmod($sDirAux, 0777);
  833.             }
  834.             $sDirAux2 = $sDirAux . '/' . date("Ymd");
  835.             if (!file_exists($sDirAux2))
  836.             {
  837.                 mkdir($sDirAux2, 0777);
  838.                 chmod($sDirAux2, 0777);
  839.             }
  841.             $aFileXmlRequest = fopen($sDirAux2 . '/' . date("Y_m_d_H_i_s") . '_company_' . date("YmdHis") . '.txt', 'w');
  842.             foreach ($aResultats as $rId => $rVal)
  843.             {
  844.                 fputs($aFileXmlRequest, $rId . ' : ' . print_r($rVal, true) . PHP_EOL);
  845.             }
  846.             fclose($aFileXmlRequest);
  847.             /*
  848.             $sMissatge = '<pre>' . print_r($aResultats, true) . '</pre>';
  849.             $this->phpmailer->EnviarAction(array(
  850.                 'sSubjecte' => "Masella WSAxess Error Consulta_AMB_Consumers",
  851.                 'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  852.                 'sTo'       => 'jramon@entorno.es',
  853.                 'sMissatge' => $sMissatge,
  854.             ));
  856.             */
  857.         }
  858.         //////////////////////////////////////////////////
  859.         // Actualitzem els valors a la taula ValorsWsAxess
  860.         //////////////////////////////////////////////////
  861.         if ($bDataModificada) 
  862.         {
  863.             $dateTime = new \DateTime();
  864.             $entityValorsWsAxess->setUltimDataModificacioCompany($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  865.         }
  866.         $dateTime = new \DateTime();
  867.         $entityValorsWsAxess->setUltimaLecturaCompany($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  868.         $this->em->persist($entityValorsWsAxess);
  869.         $this->em->flush();
  871.         return new Response('Finalitzat');
  872.     }
  874.     /*
  875.     function moureImatgeAbonatAConsumerAction()
  876.     {
  877.         die('stop');
  878.         set_time_limit(300000);
  879.         echo 'Inici -> ' . date('Y-m-d H:i:s') . '<br>';
  881.         $sQuery = "SELECT c "
  882.             . " FROM App:Consumers c "
  883.         ;
  884.         $query = $this->em->createQuery($sQuery);
  885.         //$query->setMaxResults(10);
  886.         $objConsumers = $query->getResult();
  888.         //dump($objAbonats);
  889.         echo '<br>Total abonats : ' . count($objConsumers) . '<br>';
  890.         $icon = 1;
  891.         foreach ($objConsumers as $key => $val)
  892.         {
  893.             echo '<br>(' . $icon++ . ')-------------' . $val->getId();
  894.             if ($val->getImatge() != '')
  895.             {
  896.                 $sOrigen = $this->sPathUploads . "abonats/" . $val->getImatge();
  897.                 $sDesti = $this->sPathUploads . "consumers/" . $val->getImatge();
  898.                 echo '<br>' . $sDesti . '<br>';
  899.                 if (!file_exists($sDesti)) {
  900.                     if (file_exists($sOrigen)) {
  901.                         if (copy($sOrigen, $sDesti)) {
  902.                             echo '<br>mogut<br>';
  903.                             if (filesize($sDesti) > 0) {
  904.                                 $miObjSize = new changeSize;
  905.                                 $miObjSize->canviTamanyImatge($sDesti, 250, 0);
  906.                             }
  907.                         }
  908.                     }
  909.                 }
  910.             }
  912.             if ($val->getDocumento() != '')
  913.             {
  914.                 $sOrigen =  $this->sPathUploads . "abonats/" . $val->getDocumento();
  915.                 $sDesti = $this->sPathUploads . "consumers/" . $val->getDocumento();
  916.                 echo '<br>' . $sDesti . '<br>';
  917.                 if (!file_exists($sDesti)) {
  918.                     if (file_exists($sOrigen)) {
  919.                         $bRes = copy($sOrigen, $sDesti);
  920.                         echo '<br>mogut<br>';
  921.                     } else {
  922.                         echo '<br>No existeix el fitxer a l origen <br>';
  923.                         echo $sOrigen .'<br>';
  924.                     }
  925.                 }
  926.             }
  927.         }
  928.         echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  929.         return new Response('Finalitzat');
  930.     }
  931.     */
  933.     public function createCustomerAccountAction()
  934.     {
  935.         set_time_limit(300000);
  936.         echo 'Inici -> ' . date('Y-m-d H:i:s') . '<br>';
  938.         $objWebServicesCustomerAccount = new WebServicesCustomerAccountController();
  939.         /////////////////////////////////////////////////////////////////////////////////////
  940.         /// Quan la cridem com una clase no te acces al getParameter, així li passem el valor
  941.         /////////////////////////////////////////////////////////////////////////////////////
  942.         $objWebServicesCustomerAccount->setEnviroments($this->getParameter('kernel.environment'));
  943.         $objWebServicesCustomerAccount->setObjContainer($this);
  944.         $objWebServicesCustomerAccount->setObjGetMailer($this->phpmailer);
  946.         $aParams = array(   'customer_account_no'       => null,
  947.                             'resposta_dci4_connect'     => null,
  948.                             'tipus'                     => "Pagador",
  949.                             'historic'                  => 0
  950.         );
  951.         $enConsumers = $this->em->getRepository(Consumers::class)->findBy($aParams);
  952.         if ($enConsumers) 
  953.         {
  954.             $iContador = 0;
  955.             foreach ($enConsumers as $key => $aConsumer)
  956.             {
  957.                 $enConsumersUpdate = $this->em->getRepository(Consumers::class)->find($aConsumer->getId());
  958.                 $aElements = array( 
  959.                     'i_nPersProjNo' => $aConsumer->getCustomerIdProj(),
  960.                     'i_nPersPosNo'  => $aConsumer->getCustomerIdPos(),
  961.                     'i_nPersPersNo' => $aConsumer->getCustomerIdNum(),
  962.                     'i_szUserName'  => $aConsumer->getEmail(),
  963.                     'i_szPassword'  => $aConsumer->getClau(),
  964.                     'i_encryptmail'  => 0,
  965.                 );
  966.                 echo '<pre>';
  967.                 print_r($aElements);
  968.                 echo '</pre>';
  969.                 //die('stop');
  970.                 $jsonReturn = $objWebServicesCustomerAccount->createCustomerAccount($aElements);
  971.                 $aReturnCreateCustomerAccount = json_decode($jsonReturn->getContent(), true);
  972.                 if ($aReturnCreateCustomerAccount['error']['CreateCustomerFromPerson']) 
  973.                 {
  974.                     echo 'ok!!!' . '<br>';
  975.                     $enConsumersUpdate->setCustomerAccountNo($aReturnCreateCustomerAccount['aCustomerAccount']['NCUSTOMERACCOUNTNO']);
  976.                     $enConsumersUpdate->setValidateHash($aReturnCreateCustomerAccount['aCustomerAccount']['SZVALIDATEHASH']);
  977.                 } else {
  978.                     echo '<pre>';
  979.                     print_r($aReturnCreateCustomerAccount);
  980.                     echo '</pre>';
  981.                 }
  982.                 $enConsumersUpdate->setRespostaDci4Connect(print_r($aReturnCreateCustomerAccount,true));
  983.                 $this->em->persist($enConsumersUpdate);
  984.                 $this->em->flush();
  985.                 //dump($aReturnCreateCustomerAccount);
  986.                 echo '-------------------------------' . '<br>';
  987.                 ////////////////////////
  988.                 /// TODO: Treure a real
  989.                 ////////////////////////
  990.                 $iContador++;
  991.                 if ($iContador == 1000) die('stop');
  992.             }
  993.         }
  994.         echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  995.         return new Response('Finalitzat');
  996.     }
  998.     function updateReemplazamentWTPByAxessAction()
  999.     {
  1000.         set_time_limit(300000);
  1002.         if ($this->getParameter('kernel.environment') == 'dev')
  1003.         {
  1004.             $bTest = true;
  1005.             echo "Inici actualització a entorno de Reemplazament WTP des de sqlServer: " . date("Y-m-d H:i:s") . '<br>';
  1006.         } else {
  1007.             $bTest = false;
  1008.         }
  1010.         /* Connect using Windows Authentication. */
  1011.         try {
  1012.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  1013.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  1014.         } catch (Exception $e) {
  1015.             die(print_r($e->getMessage(), false));
  1016.         }
  1018.         $sDataHora = date("Y_m_d_H_i_s");
  1019.         $this->sDir = $this->sBase . 'query_ws/';
  1021.         $sReturn = "EN-1|No hi ha consumers per modificar";
  1022.         $aResultats = array();
  1023.         $entityValorsWsAxess = $this->em->getRepository(ValorsWsAxess::class)->find(1);
  1024.         if ($entityValorsWsAxess)
  1025.         {
  1026.             $dUltimaModificacio = $entityValorsWsAxess->getUltimDataModificacioReemplazamentWtp();
  1027.             $iCuantosRegistros = 10;
  1028.             $iIniciRegistres = 0;
  1029.             $aResultats = array();
  1030.             $iCon = 0;
  1031.             do {
  1032.                 $iTotalRegistresLlegits = 0;
  1033.                 ///////////////////////////////////////////
  1034.                 // consulta a l'sqlServer amb la data
  1035.                 ///////////////////////////////////////////
  1036.                 $tsql = "SELECT *, concat(convert(varchar(10),Data_Venda,111),' ',Hora_Venda) as dddd FROM V_ENTORNO_REEXPEDICIONS";
  1037.                 $tsql .= " WHERE 1=1";
  1038.                 if ($dUltimaModificacio != '')
  1039.                 {
  1040.                     $tsql .= " AND concat(convert(varchar(10),Data_Venda,111),' ',Hora_Venda) > '" . $dUltimaModificacio->format("Y/m/d") . " " . $dUltimaModificacio->format("H:i:s") . "'";
  1041.                 }
  1042.                 //$tsql .= " AND Data_Venda >= '" . $dUltimaModificacio->format("Y-m-d") . 'T' . "00:00:00.000'";
  1043.                 $tsql .= " ORDER BY Data_Venda ASC, Hora_Venda ASC";
  1044.                 $tsql .= " OFFSET " . $iIniciRegistres . " ROWS FETCH FIRST " . $iCuantosRegistros . " ROWS ONLY ";
  1045.                 echo $tsql;
  1046.                 //die('stop');
  1047.                 //$getConsumers = $conn->prepare($tsql, [PDO::ATTR_CURSOR => PDO::CURSOR_SCROLL,]);
  1048.                 $getConsumers = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  1049.                 echo '<br>' . count($getConsumers) . '<br>';
  1051.                 //$getConsumers->execute();
  1052.                 //$aResult = $getConsumers->fetchAll(PDO::FETCH_ASSOC);
  1053.                 //$iConsumersCount = count($aResult);
  1054.                 $bDataModificada = false;
  1055.                 if ($getConsumers > 0) 
  1056.                 {
  1057.                     foreach ($getConsumers as $row) 
  1058.                     {
  1059.                         echo '<pre>';
  1060.                         print_r($row);
  1061.                         echo '</pre>';
  1062.                         //die('stop');
  1063.                         ////////////////////////////////////////////////////
  1064.                         /// Guardem la data per començar des de aquesta data
  1065.                         ////////////////////////////////////////////////////
  1067.                         $dUltimaModificacio = str_replace(' 00:00:00.000','',$row['Data_Venda']) . 'T' . $row['Hora_Venda'] . '.000';
  1068.                         $bDataModificada = true;
  1069.                         ////////////////////////////////////////////////////////////////////////////////
  1070.                         // Consultar si existeix el consumer a entorno i si existeix fer l'actualització
  1071.                         ////////////////////////////////////////////////////////////////////////////////
  1072.                         $aParam = array(    
  1073.                             'customer_id_proj'  => $row['Person_Proj'],
  1074.                             'customer_id_pos'   => $row['Person_Pos'],
  1075.                             'customer_id_num'   => $row['Person_Num']
  1076.                         );
  1077.                         $enConsumers = $this->em->getRepository(Consumers::class)->findOneBy($aParam);
  1078.                         if ($enConsumers)
  1079.                         {
  1080.                             $iConsumerFill = $enConsumers->getId();
  1081.                             dump($enConsumers);
  1082.                             $enConsumersUpdate = $this->em->getRepository(Consumers::class)->find($iConsumerFill);
  1083.                             if ($enConsumersUpdate) 
  1084.                             {
  1085.                                 ////////////////////////////////
  1086.                                 // Actualitzar dades de consumer
  1087.                                 ////////////////////////////////
  1088.                                 $enConsumersUpdate->setWtp($row['Wtp']);
  1089.                                 $enConsumersUpdate->setOrigenEntrada('Mod sqlServer');
  1090.                                 $enConsumersUpdate->setResposta4i(($enConsumersUpdate->getResposta4i() !=''?$enConsumersUpdate->getResposta4i() . '<br>':'') . '|Mod sqlServer|Modificat des del sqlServer REEXPEDICIONS el ' .  date('Y-m-d H:i:s') . ' ' . print_r($row, true) );
  1091.                                 //dump ($enConsumersUpdate);
  1092.                                 //die('stop');
  1093.                                 $this->em->persist($enConsumersUpdate);
  1094.                                 $this->em->flush();
  1095.                                 $aResultats[$iCon]['consumer'] = $row;
  1096.                             }
  1097.                             ////////////////////////////////////////////////
  1098.                             // TODO: S'ha de treure aquest break a real!!!!!
  1099.                             ////////////////////////////////////////////////
  1100.                             //break;
  1101.                         }
  1102.                         $iTotalRegistresLlegits++;
  1103.                     }
  1104.                 }
  1105.                 //////////////////////////////////////////////////
  1106.                 // Actualitzem els valors a la taula ValorsWsAxess
  1107.                 //////////////////////////////////////////////////
  1108.                 if ($bDataModificada) 
  1109.                 {
  1110.                     $dateTime = new \DateTime();
  1111.                     $entityValorsWsAxess->setUltimDataModificacioReemplazamentWtp($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  1112.                 }
  1113.                 $dateTime = new \DateTime();
  1114.                 $entityValorsWsAxess->setUltimaLecturaReemplazamentWtp($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  1115.                 $this->em->persist($entityValorsWsAxess);
  1116.                 $this->em->flush();
  1118.                 $iIniciRegistres = $iIniciRegistres + $iTotalRegistresLlegits;
  1119.                 ////////////////////////////////////////////////
  1120.                 // TODO: S'ha de treure aquest break a real!!!!!
  1121.                 ////////////////////////////////////////////////
  1122.                 //break;
  1123.             } while ($iTotalRegistresLlegits == $iCuantosRegistros);
  1125.         }
  1126.         if ($bTest) 
  1127.         {
  1128.             echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  1129.             echo '<pre>';
  1130.             dump ($aResultats);
  1131.             echo '</pre>';
  1132.         }
  1134.         if (!empty($aResultats))
  1135.         {
  1136.             $sDirAux = $this->sDir . 'update_ReemplazamentWTP_Axess';
  1137.             if (!file_exists($sDirAux))
  1138.             {
  1139.                 mkdir($sDirAux, 0777, true);
  1140.                 chmod($sDirAux, 0777);
  1141.             }
  1142.             $sDirAux2 = $sDirAux . '/' . date("Ymd");
  1143.             if (!file_exists($sDirAux2))
  1144.             {
  1145.                 mkdir($sDirAux2, 0777);
  1146.                 chmod($sDirAux2, 0777);
  1147.             }
  1149.             $aFileXmlRequest = fopen($sDirAux2 . '/' . date("Y_m_d_H_i_s") . '_reemplazament_wtp_' . date("YmdHis") . '.txt', 'w');
  1150.             foreach ($aResultats as $rId => $rVal)
  1151.             {
  1152.                 fputs($aFileXmlRequest, $rId . ' : ' . print_r($rVal, true) . PHP_EOL);
  1153.             }
  1154.             fclose($aFileXmlRequest);
  1155.             /*
  1156.             $sMissatge = '<pre>' . print_r($aResultats, true) . '</pre>';
  1157.             $this->phpmailer->EnviarAction(array(
  1158.                 'sSubjecte' => "Masella WSAxess Error Consulta_AMB_Consumers",
  1159.                 'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  1160.                 'sTo'       => 'jramon@entorno.es',
  1161.                 'sMissatge' => $sMissatge,
  1162.             ));
  1165.             */
  1166.         }
  1167.         //////////////////////////////////////////////////
  1168.         // Actualitzem els valors a la taula ValorsWsAxess
  1169.         //////////////////////////////////////////////////
  1170.         if ($bDataModificada) 
  1171.         {
  1172.             $dateTime = new \DateTime();
  1173.             $entityValorsWsAxess->setUltimDataModificacioReemplazamentWtp($dateTime->setTimestamp(strtotime($dUltimaModificacio)));
  1174.         }
  1175.         $dateTime = new \DateTime();
  1176.         $entityValorsWsAxess->setUltimaLecturaReemplazamentWtp($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  1177.         $this->em->persist($entityValorsWsAxess);
  1178.         $this->em->flush();
  1180.         return new Response('Finalitzat');
  1181.     }
  1183.     function updateWTPBySqlServerAction()
  1184.     {
  1185.         set_time_limit(300000);
  1187.         if ($this->getParameter('kernel.environment') == 'dev')
  1188.         {
  1189.             $bTest = true;
  1190.             echo "Inici actualització a entorno de WTP des de sqlServer: " . date("Y-m-d H:i:s") . '<br>';
  1191.         } else {
  1192.             $bTest = false;
  1193.         }
  1195.         /* Connect using Windows Authentication. */
  1196.         try {
  1197.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  1198.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  1199.         } catch (Exception $e) {
  1200.             die(print_r($e->getMessage(), false));
  1201.         }
  1203.         $sDataHora = date("Y_m_d_H_i_s");
  1204.         $this->sDir = $this->sBase . 'query_ws/';
  1206.         $sReturn = "EN-1|No hi ha WTP per modificar";
  1207.         $iCon = 0;
  1208.         $aResultats = array();
  1210.         $sQuery = "SELECT cl "
  1211.             . " FROM App:ComandesLinies cl INNER JOIN App:Comandes c "
  1212.             . " WHERE cl.comandes = c.id"
  1213.             . " AND c.estat = :estat"
  1214.             . " AND c.enviat = :enviat"
  1215.             . " AND cl.anulada = :anulada"
  1216.             . " AND cl.id > :comandesLiniesID"
  1217.             . " AND (cl.xip_introduit_client is null"
  1218.             . " OR cl.xip_introduit_client = :xipintroduitclient)"
  1219.             . " AND (cl.estat = :estatlinia"
  1220.             . " OR cl.estat = :estatlinia2"
  1221.             . " OR cl.estat is null"
  1222.             . " OR cl.estat = :estatlinia3"
  1223.             . " OR cl.estat = :estatlinia4)"
  1224.             . " AND cl.journal_no is not null";
  1226.         //$sQuery .= ' ORDER BY p.id ASC';
  1227.         $sQuery .= ' ORDER BY c.data ASC';
  1228.         //echo $sQuery;
  1229.         $query = $this->em->createQuery($sQuery);
  1231.         $query->setParameter('estat', 1);
  1232.         $query->setParameter('enviat', 1);
  1233.         $query->setParameter('estatlinia', 'open');
  1234.         $query->setParameter('estatlinia2', 'inwork');
  1235.         $query->setParameter('estatlinia3', '');
  1236.         $query->setParameter('estatlinia4', 'aborted');
  1237.         $query->setParameter('xipintroduitclient', '');
  1238.         $query->setParameter('anulada', '0');
  1239.         $query->setParameter('comandesLiniesID', 61794);// això ho fem fer no buscar línies de temporades passades
  1241.         $objComandes = $query->getResult();
  1244.         foreach ($objComandes as $key => $val)
  1245.         {
  1246.             $aResultats[$iCon]['NJOURNALNR'] = $val->getJournalNo();
  1247.             $aResultats[$iCon]['SERIALNR'] = $val->getSerialNr();
  1248.             $aResultats[$iCon]['NPOSNR'] = $val->getPosNo();
  1249.             $aResultats[$iCon]['NPROJNR'] = $val->getProjNo();
  1250.             echo '<br>';
  1251.             echo 'NJOURNALNR : ' . $val->getJournalNo() . '<br>';
  1252.             echo 'SERIALNR : ' . $val->getSerialNr() . '<br>';
  1253.             echo 'NPOSNR : ' . $val->getPosNo() . '<br>';
  1254.             echo 'NPROJNR : ' . $val->getProjNo() . '<br>';
  1255.             echo '<br>';
  1257.             ///////////////////////////////////////////
  1258.             // consulta a l'sqlServer amb la data
  1259.             ///////////////////////////////////////////
  1260.             $tsql = "SELECT * FROM V_AXESS_PREPAIDTICKETS2";
  1261.             $tsql .= " WHERE 1=1";
  1262.             $tsql .= " AND nKassaNr = '" . $val->getPosNo() . "'";
  1263.             $tsql .= " AND nProjNr = '" . $val->getProjNo() . "'";
  1264.             $tsql .= " AND nJournalNr = '" . $val->getJournalNo() . "'";
  1265.             //echo $tsql;
  1266.             //die('stop');
  1267.             //$getConsumers = $conn->prepare($tsql, [PDO::ATTR_CURSOR => PDO::CURSOR_SCROLL,]);
  1268.             $aLiniesResult = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  1269.             echo '<br>' . count($aLiniesResult) . '<br>';
  1271.             $bDataModificada = false;
  1272.             if (count($aLiniesResult) > 0)
  1273.             {
  1274.                     $aLinies = $aLiniesResult[0];
  1275.                 echo '<pre>';
  1276.                 print_r($aLinies);
  1277.                 echo '</pre>';
  1278.                 $dateTime = new \DateTime();
  1279.                 $entityComandesLinies = $this->em->getRepository(ComandesLinies::class)->find($val->getId());
  1280.                 $aResultats[$iCon]['sqlserver'] = 'sense resultat';
  1281.                 if ($entityComandesLinies)
  1282.                 {
  1283.                     $aResultats[$iCon]['sqlserver'] = $aLinies;
  1284.                     /////////////////////////////////////
  1285.                     // s'ha d'actualitzar al consumer WTP
  1286.                     /////////////////////////////////////
  1287.                     if ($aLinies['szWtpNr64'] != '')
  1288.                     {
  1289.                         $entityComandesLinies->setXip($aLinies['szWtpNr64']);
  1290.                         if (!is_null($entityComandesLinies->getConsumers()))
  1291.                         {
  1292.                             $entityConsumers = $this->em->getRepository(Consumers::class)->find($entityComandesLinies->getConsumers()->getId());
  1293.                             $entityConsumers->setWtp($aLinies['szWtpNr64']);
  1294.                             $this->em->persist($entityComandesLinies);
  1295.                             $this->em->flush();
  1296.                         }
  1297.                         $entityComandesLinies->setEstat('completed');
  1298.                         $entityComandesLinies->setRespostaEnviat('Actualitza WTP des de SqlServer');
  1299.                         $entityComandesLinies->setDataComunicacio($dateTime->createFromFormat('Y-m-d H:i:s', date('Y-m-d H:i:s')));
  1300.                         $this->em->persist($entityComandesLinies);
  1301.                         $this->em->flush();
  1302.                     }
  1303.                 }
  1304.             }
  1306.             ////////////////////////////////////////////////
  1307.             // TODO: S'ha de treure aquest break a real!!!!!
  1308.             ////////////////////////////////////////////////
  1309.             //break;
  1311.         }
  1312.         if ($bTest)
  1313.         {
  1314.             echo '<br>Fi -> ' . date('Y-m-d H:i:s');
  1315.             echo '<pre>';
  1316.             dump ($aResultats);
  1317.             echo '</pre>';
  1318.         }
  1320.         if (!empty($aResultats))
  1321.         {
  1322.             $sDirAux = $this->sDir . 'update_WTP_by_SqlServer';
  1323.             if (!file_exists($sDirAux))
  1324.             {
  1325.                 mkdir($sDirAux, 0777, true);
  1326.                 chmod($sDirAux, 0777);
  1327.             }
  1328.             $sDirAux2 = $sDirAux . '/' . date("Ymd");
  1329.             if (!file_exists($sDirAux2))
  1330.             {
  1331.                 mkdir($sDirAux2, 0777);
  1332.                 chmod($sDirAux2, 0777);
  1333.             }
  1335.             $aFileXmlRequest = fopen($sDirAux2 . '/' . date("Y_m_d_H_i_s") . '_reemplazament_wtp_' . date("YmdHis") . '.txt', 'w');
  1336.             foreach ($aResultats as $rId => $rVal)
  1337.             {
  1338.                 fputs($aFileXmlRequest, $rId . ' : ' . print_r($rVal, true) . PHP_EOL);
  1339.             }
  1340.             fclose($aFileXmlRequest);
  1341.             /*
  1342.             $sMissatge = '<pre>' . print_r($aResultats, true) . '</pre>';
  1343.             $this->phpmailer->EnviarAction(array(
  1344.                 'sSubjecte' => "Masella WSAxess Error Consulta_AMB_Consumers",
  1345.                 'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  1346.                 'sTo'       => 'jramon@entorno.es',
  1347.                 'sMissatge' => $sMissatge,
  1348.             ));
  1351.             */
  1352.         }
  1353.         return new Response('Finalitzat');
  1354.     }
  1357.     function sendEstadisticsProcesAction ()
  1358.     {
  1359.         $this->sDir = $this->sBase . 'query_ws/';
  1360.         $sDirAux = $this->sDir . 'create_attribute_Axess';
  1361.         if (!file_exists($sDirAux))
  1362.         {
  1363.             mkdir($sDirAux, 0777, true);
  1364.             chmod($sDirAux, 0777);
  1365.         }
  1366.         $sDirAux2 = $sDirAux . '/' . date("Ymd");
  1367.         if (!file_exists($sDirAux2))
  1368.         {
  1369.             mkdir($sDirAux2, 0777);
  1370.             chmod($sDirAux2, 0777);
  1371.         }
  1373.         $aFileXmlRequest = fopen($sDirAux2 . '/' . date("Y_m_d_H_i_s") . '_create_attribute_' . date("YmdHis") . '.txt', 'w');
  1376.         set_time_limit(300000);
  1377.         $objWebServicesGenerateTokenAccount = new WebServicesGenerateTokenAccountController();
  1378.         /////////////////////////////////////////////////////////////////////////////////////
  1379.         /// Quan la cridem com una clase no te acces al getParameter, així li passem el valor
  1380.         /////////////////////////////////////////////////////////////////////////////////////
  1381.         $objWebServicesGenerateTokenAccount->setEnviroments($this->getParameter('kernel.environment'));
  1382.         $objWebServicesGenerateTokenAccount->setObjContainer($this);
  1383.         $objWebServicesGenerateTokenAccount->setObjGetMailer($this->phpmailer);
  1384.         echo "Inici actualització  de dades estadístiques: " . date("Y-m-d H:i:s") . '<br>';
  1385.         if ($this->getParameter('kernel.environment') == 'dev')
  1386.         {
  1387.             $bTest = true;
  1388.         } else {
  1389.             $bTest = false;
  1390.         }
  1392.         $sQuery = "SELECT p "
  1393.             . " FROM App:Comandes p "
  1394.             . " WHERE p.estat = 1"
  1395.             . " AND p.enviat = 1"
  1396.             //. " AND p.enviat = 1)"
  1397.             //. " OR p.estat = 3)"
  1398.             . " AND p.proces_estadistic != 1"
  1399.             //. " AND (p.id = 39954"
  1400.             //. " OR p.id = 39962"
  1401.             //. " OR p.id = 39959"
  1402.             //. " OR p.id = 39958"
  1403.             //. " OR p.id = 39957"
  1404.             //. " OR p.id = 39956"
  1405.             //. " )"
  1406.             ;
  1407.         $sQuery .= ' ORDER BY p.id ASC';
  1409.         //echo $sQuery;
  1410.         $query = $this->em->createQuery($sQuery);
  1411.         $query->setFirstResult(0);
  1412.         $query->setMaxResults(350);
  1413.         $objComandes = $query->getResult();
  1415.         if ($objComandes)
  1416.         {
  1417.             if ($this->getParameter('kernel.environment') == 'dev')
  1418.             {
  1419.                 //dump($objComandes);
  1420.             }
  1422.             foreach ($objComandes as $key => $aComanda)
  1423.             {
  1424.                 $aAtribut = array();
  1425.                 $bTenimValidateToken = true;
  1426.                 echo '-----------------------------------------------------------------------------------<br>';
  1427.                 echo 'Comanda ->' . $aComanda->getLocalitzador() . '-' . $aComanda->getId() . '-<br>';
  1428.                 fputs($aFileXmlRequest, '-----------------------------------------------------------------------------------' . PHP_EOL);
  1429.                 fputs($aFileXmlRequest, 'Comanda ->' . $aComanda->getLocalitzador() . '-' . $aComanda->getId() . PHP_EOL);
  1431.                 $objComandesLinies = $this->em->getRepository(ComandesLinies::class)->findBy(array(
  1432.                     'comandes' => $aComanda->getId()
  1433.                 ));
  1434.                 if ($objComandesLinies)
  1435.                 {
  1436.                     $bErrorAttribut = false;
  1437.                     foreach ($objComandesLinies as $key => $aLinia) 
  1438.                     {
  1439.                         //dump($aLinia);
  1440.                         if ($aLinia->getAnulada() == 0) {
  1441.                             echo 'Atribut ->' . $aLinia->getAbonaments()->getAtribut() . '-<br>';
  1442.                             fputs($aFileXmlRequest, ' Línia -> ' . $aLinia->getId() . ' Atribut -> ' . $aLinia->getAbonaments()->getAtribut() . PHP_EOL);
  1443.                             if ($aLinia->getAbonaments()->getAtribut() != '') 
  1444.                             {
  1445.                                 if (!array_key_exists($aLinia->getAbonaments()->getAtribut(), $aAtribut)) 
  1446.                                 {
  1447.                                     $aAtribut[$aLinia->getAbonaments()->getAtribut()] = 0;
  1448.                                 }
  1449.                                // if ($aComanda->getEstat() == 3) // Si és una devolució s'ha de restar
  1450.                                // {
  1451.                                //     $aAtribut[$aLinia->getAbonaments()->getAtribut()]--;
  1452.                                // } else {
  1453.                                     $aAtribut[$aLinia->getAbonaments()->getAtribut()]++;
  1454.                                // }
  1455.                             } else {
  1456.                                 fputs($aFileXmlRequest, 'ERROR : No valor attribut.' . PHP_EOL);
  1457.                                 fputs($aFileXmlRequest, $aLinia->getAbonaments()->getNomCa() . PHP_EOL);
  1458.                                 echo 'ERROR : No valor attribut.' . $aLinia->getAbonaments()->getNomCa() . '<br>';
  1459.                                 $bErrorAttribut = true;
  1460.                             }
  1461.                         }
  1462.                     }
  1463.                     
  1464.                     if (!empty($aAtribut))
  1465.                     {
  1466.                         //dump ($aAtribut);
  1467.                         echo 'Costumer -> ' . $aComanda->getConsumers()->getCustomerIdProj() . '-' . $aComanda->getConsumers()->getCustomerIdPos() . '-' . $aComanda->getConsumers()->getCustomerIdNum() . '<br>';
  1468.                         fputs($aFileXmlRequest, 'Costumer -> ' . $aComanda->getConsumers()->getCustomerIdProj() . '-' . $aComanda->getConsumers()->getCustomerIdPos() . '-' . $aComanda->getConsumers()->getCustomerIdNum() . PHP_EOL);
  1470.                         $aDades['NPERSPROJNO'] = $aComanda->getConsumers()->getCustomerIdProj();
  1471.                         $aDades['NPERSPOSNO'] = $aComanda->getConsumers()->getCustomerIdPos();
  1472.                         $aDades['NPERSNO'] = $aComanda->getConsumers()->getCustomerIdNum();
  1473.                         $aDades['aAtribut'] = $aAtribut;
  1474.                         ////////////////////////////////////////////////////
  1475.                         /// Generem el token permanent del consumer si podem
  1476.                         ////////////////////////////////////////////////////
  1477.                         if (is_null($aComanda->getConsumers()->getValidateToken())
  1478.                             || $aComanda->getConsumers()->getValidateToken() == '')
  1479.                         {
  1480.                             $bTenimValidateToken = false;
  1481.                             $aElements = array(
  1482.                                 'i_szUserName'      => $aComanda->getConsumers()->getEmail(),
  1483.                                 'i_szPassword'      => $aComanda->getConsumers()->getClau(),
  1484.                                 'i_szLoginToken'    => '',
  1485.                                 'i_nLoginTypeNr'    => 1
  1486.                             );
  1488.                             $jsonReturn = $objWebServicesGenerateTokenAccount->generateTokenAccount($aElements, $this->em);
  1489.                             $aReturnWebServicesGenerateTokenAccount = json_decode($jsonReturn->getContent(), true);
  1490.                             //dump ($aReturnWebServicesGenerateTokenAccount);
  1492.                             if ($aReturnWebServicesGenerateTokenAccount['error']['ConnexioConnectAxess']
  1493.                                 && $aReturnWebServicesGenerateTokenAccount['error']['GenerateToken']) 
  1494.                             {
  1495.                                 $bTenimValidateToken = true;
  1496.                             }
  1498.                         }
  1499.                         if ($bTenimValidateToken) 
  1500.                         {
  1501.                             echo '-' . $aComanda->getConsumers()->getValidateToken() . '-<br>';
  1502.                             echo '<pre>';
  1503.                             print_r($aDades);
  1504.                             echo '<pre>';
  1505.                             $aElements = array(
  1506.                                 'i_szUserName'      => '',
  1507.                                 'i_szPassword'      => '',
  1508.                                 'i_szLoginToken'    => $aComanda->getConsumers()->getValidateToken(),
  1509.                                 'i_nLoginTypeNr'    => 5
  1510.                             );
  1512.                             $jsonReturn = $objWebServicesGenerateTokenAccount->createAttributeToCustomer($aElements, $aAtribut);
  1513.                             $aReturnCreateAttributeToCustomer = json_decode($jsonReturn->getContent(), true);
  1515.                             dump($aReturnCreateAttributeToCustomer);
  1516.                             fputs($aFileXmlRequest, 'Resposta Axess ' . print_r($aReturnCreateAttributeToCustomer, true) . PHP_EOL);
  1517.                             if ($aReturnCreateAttributeToCustomer['error']['ConnexioConnectAxess']
  1518.                                 && $aReturnCreateAttributeToCustomer['error']['CreateAttribute']) 
  1519.                             {
  1520.                                 $objComandes = $this->em->getRepository(Comandes::class)->find($aComanda->getId());
  1521.                                 $objComandes->setProcesEstadistic(1);
  1522.                                 $this->em->persist($objComandes);
  1523.                                 $this->em->flush();
  1524.                                 fputs($aFileXmlRequest, 'Assiganció correcte' . PHP_EOL);
  1525.                                 echo '<br>Assiganció correcte<br>';
  1526.                             } else {
  1527.                                 fputs($aFileXmlRequest, 'ERROR : Resposta Axess ' . print_r($aReturnCreateAttributeToCustomer, true) . PHP_EOL);
  1528.                             }
  1529.                         } else {
  1530.                             fputs($aFileXmlRequest, 'ERROR : No Token ' . print_r($aDades, true) . PHP_EOL);
  1531.                             echo '<br>No tenim token de :';
  1532.                             echo '<pre>';
  1533.                             print_r($aDades);
  1534.                             echo '<pre>';
  1535.                         }
  1536.                     } else {
  1537.                         //////////////////////////////////////////////////////////////
  1538.                         // Si no té atributs segurament té totes les línies anul·lades
  1539.                         //////////////////////////////////////////////////////////////
  1540.                         //if ($bErrorAttribut === false)
  1541.                         //{
  1542.                             fputs($aFileXmlRequest, 'Segurament té totes les línies anul·lades o és una assegurança' . PHP_EOL);
  1543.                             echo 'Segurament té totes les línies anul·lades' . '<br>';
  1544.                             $objComandes = $this->em->getRepository(Comandes::class)->find($aComanda->getId());
  1545.                             $objComandes->setProcesEstadistic(1);
  1546.                             $this->em->persist($objComandes);
  1547.                             $this->em->flush();
  1548.                         //}
  1549.                     }
  1550.                 }
  1551.             }
  1552.             fclose($aFileXmlRequest);
  1553.         }
  1555.         if ($this->getParameter('kernel.environment') == 'dev')
  1556.         {
  1558.         }
  1559.         echo '-----------------------------------------------------------------------------------<br>';
  1560.         echo "Final actualització de dades estadístiques: " . date("Y-m-d H:i:s") . '<br>';
  1561.         return new Response('Finalitzat');
  1562.     }
  1563. /*
  1564.     function sendEstadisticsProcesAction (){
  1565.         die();
  1566.         set_time_limit(300000);
  1567.         $objWebServicesGenerateTokenAccount = new WebServicesGenerateTokenAccountController();
  1568.         /////////////////////////////////////////////////////////////////////////////////////
  1569.         /// Quan la cridem com una clase no te acces al getParameter, així li passem el valor
  1570.         /////////////////////////////////////////////////////////////////////////////////////
  1571.         $objWebServicesGenerateTokenAccount->setEnviroments($this->getParameter('kernel.environment'));
  1572.         $objWebServicesGenerateTokenAccount->setObjContainer($this->container);
  1573.         $objWebServicesGenerateTokenAccount->setObjGetMailer($this->get('mailer'));
  1575.         if ($this->getParameter('kernel.environment') == 'dev')
  1576.         {
  1577.             $bTest = true;
  1578.             echo "Inici actualització Token account: " . date("Y-m-d H:i:s") . '<br>';
  1579.         } else {
  1580.             $bTest = false;
  1581.         }
  1583.         $sQuery = "SELECT p "
  1584.             . " FROM App:Consumers p "
  1585.             . " WHERE p.historic = 0"
  1586.             . " AND p.customer_account_no IS NOT NULL"
  1587.             . " AND p.validate_token IS NULL"
  1588.         ;
  1589.         $sQuery .= ' ORDER BY p.id ASC';
  1591.         $query = $this->em->createQuery($sQuery);
  1593.         $objConsumers = $query->getResult();
  1595.         if ($objConsumers)
  1596.         {
  1597.             if ($this->getParameter('kernel.environment') == 'dev')
  1598.             {
  1599.                 //dump($objComandes);
  1600.             }
  1601.             $iCon = 0;
  1602.             foreach ($objConsumers as $key => $aConsumer)
  1603.             {
  1604.                 $bTenimValidateToken = true;
  1605.                 $iCon++;
  1606.                 echo '(' . $iCon . ') Consumer ->account:' . $aConsumer->getCustomerAccountNo() . ' id:' . $aConsumer->getId() . '<br>';
  1607.                 ////////////////////////////////////////////////////
  1608.                 /// Generem el token permanent del consumer si podem
  1609.                 ////////////////////////////////////////////////////
  1610.                 if (is_null($aConsumer->getValidateToken())
  1611.                     || $aConsumer->getValidateToken() == '')
  1612.                 {
  1613.                     $bTenimValidateToken = false;
  1614.                     $SZLOGINTOKEN = '';
  1615.                     $aElements = array( 'i_szUserName'      => $aConsumer->getEmail(),
  1616.                                         'i_szPassword'      => $aConsumer->getClau(),
  1617.                                         'i_szLoginToken'    => '',
  1618.                                         'i_nLoginTypeNr'    => 1
  1619.                     );
  1621.                     $jsonReturn = $objWebServicesGenerateTokenAccount->generateTokenAccount($aElements, $em);
  1622.                     $aReturnWebServicesGenerateTokenAccount = json_decode($jsonReturn->getContent(), true);
  1623.                     //dump ($aReturnWebServicesGenerateTokenAccount);
  1627.                     if ($aReturnWebServicesGenerateTokenAccount['error']['ConnexioConnectAxess']
  1628.                         && $aReturnWebServicesGenerateTokenAccount['error']['GenerateToken']) {
  1629.                         $bTenimValidateToken = true;
  1630.                         $SZLOGINTOKEN = $aReturnWebServicesGenerateTokenAccount['aCustomerAccount']['SZLOGINTOKEN'];
  1631.                     }
  1633.                 }
  1634.                 echo $aConsumer->getCustomerIdProj() . '-' . $aConsumer->getCustomerIdPos() . '-' . $aConsumer->getCustomerIdNum() . '<br>';
  1635.                 if ($bTenimValidateToken) {
  1636.                     echo '-' . $SZLOGINTOKEN . '-<br>';
  1637.                 } else {
  1638.                     echo '<br>No tenim token!!!!';
  1639.                 }
  1640.                 echo '<br>--------------------------<br>';
  1641.                 //die('stop');
  1642.             }
  1643.         }
  1645.         if ($this->getParameter('kernel.environment') == 'dev')
  1646.         {
  1647.             echo "Final actualització de Token account: " . date("Y-m-d H:i:s") . '<br>';
  1648.         }
  1649.         return new Response('Finalitzat');
  1650.     }
  1651. */
  1654.     function sendEmailComandesNoAcabadesAction ()
  1655.     {
  1656.         $entityValorsWsAxess = $this->em->getRepository(ValorsWsAxess::class)->find(1);
  1658.         if (is_null($entityValorsWsAxess ->getUltimEnviamentNoComanda())
  1659.             || $entityValorsWsAxess ->getUltimEnviamentNoComanda()->format('Y-m-d') != date("Y-m-d"))
  1660.         {
  1661.             $sQuery = "SELECT p "
  1662.                 . " FROM App:Comandes p "
  1663.                 . " WHERE p.estat = 0"
  1664.                 . " AND p.lloc_venda = 'Web'"
  1665.                 . " AND p.data >= '" . date("Y-m-d", strtotime('-1 days')) . " 00:00:00'"
  1666.                 . " AND p.data <= '" . date("Y-m-d", strtotime('-1 days')) . " 23:59:59'"
  1667.                 . " AND p.consumers IS NOT NULL";
  1668.             //echo $sQuery;
  1669.             $query = $this->em->createQuery($sQuery);
  1671.             $objComandes = $query->getResult();
  1673.             //dump($objComandes);
  1674.             if ($objComandes)
  1675.             {
  1676.                 $aEmails = array();
  1677.                 foreach ($objComandes as $key => $aComanda)
  1678.                 {
  1679.                     echo '<br>Comanda ->' . $aComanda->getLocalitzador() . '-<br>';
  1680.                     if (!in_array($aComanda->getConsumers()->getEmail(), $aEmails))
  1681.                     {
  1682.                         $aEmails[] = $aComanda->getConsumers()->getEmail();
  1684.                         $bRes = $this->phpmailer->EnviarAction(array(
  1685.                             'sSubjecte' => 'Ajut per acabar la comanda',
  1686.                             'sFrom'     => $this->getParameter('EMAIL_RESERVAS'),
  1687.                             'sTo'       => $aComanda->getConsumers()->getEmail(),
  1688.                             'sMissatge' => $this->renderView('plantillaEmailComandesNoAcabades.html.twig', array()),
  1689.                         ));
  1690.                         if ($bRes) echo 'Email enviat<br>';
  1691.                     }
  1692.                 }
  1693.             }
  1694.             $dateTime = new \DateTime();
  1695.             $entityValorsWsAxess->setUltimEnviamentNoComanda($dateTime->createFromFormat('Y-m-d', date("Y-m-d")));
  1696.             $this->em->persist($entityValorsWsAxess);
  1697.             $this->em->flush();
  1698.         } else {
  1699.             echo 'ja executat avui.';
  1700.         }
  1701.         return new Response('Finalitzat');
  1702.     }
  1704.     function sendAcceptarRebrePromoDescompteAction ()
  1705.     {
  1706.         if ($this->getParameter('kernel.environment') == 'dev')
  1707.         {
  1708.             $bTest = true;
  1709.             echo "Inici actualització rebre promoció i descompte des de sqlServer: " . date("Y-m-d H:i:s") . '<br>';
  1710.         } else {
  1711.             $bTest = false;
  1712.         }
  1714.         /* Connect using Windows Authentication. */
  1715.         try {
  1716.             $options = array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION);
  1717.             $conn = new \PDO('sqlsrv:Server=' . $this->sServer . ';Database=' . $this->sBDname . ';Encrypt = false;', $this->sUserName, $this->sPassword, $options);
  1718.         } catch (Exception $e) {
  1719.             die(print_r($e->getMessage(), false));
  1720.         }
  1722.         $sQuery = "SELECT p "
  1723.             . " FROM App:Rgpd p "
  1724.             . " WHERE p.enviat = 0"
  1725.             . " AND p.consumers IS NOT NULL"
  1726.             . " ORDER BY p.id ASC";
  1727.         //echo $sQuery;
  1728.         $query = $this->em->createQuery($sQuery);
  1730.         $objRgpd = $query->getResult();
  1732.         //dump($objRgpd);
  1733.         if ($objRgpd)
  1734.         {
  1735.             foreach ($objRgpd as $key => $aRgpd) {
  1736.                 if ($aRgpd->getConsumers()) {
  1737.                     if ($aRgpd->getConsumers()->getCustomeraccountno()) {
  1738.                         echo '<br>Rgpd ->' . $aRgpd->getNewsletter() . '<br>';
  1739.                         echo '<br>Rgpd ->' . $aRgpd->getIdioma() . '<br>';
  1740.                         echo '<br>Rgpd ->' . $aRgpd->getConsumers()->getCustomeraccountno() . '<br>';
  1742.                         ///////////////////////////////////////////
  1743.                         // consulta a l'sqlServer amb la data
  1744.                         ///////////////////////////////////////////
  1745.                         $tsql = "SELECT * FROM ENTORNO_CUSTOMER_CHECK";
  1746.                         $tsql .= " WHERE 1=1";
  1747.                         $tsql .= " AND CustomerNr =" . $aRgpd->getConsumers()->getCustomeraccountno();
  1748.                         //echo $tsql;
  1749.                         $getCustomerCheck = $conn->query($tsql)->fetchAll(\PDO::FETCH_ASSOC);
  1750.                         echo '<br>Total : ' . count($getCustomerCheck) . '<br>';
  1752.                         if (count($getCustomerCheck) > 0) {
  1753.                             echo '<br>Update<br>';
  1754.                             $tsql = "UPDATE ENTORNO_CUSTOMER_CHECK SET ";
  1755.                             $tsql .= " ComunicationLanguage=:ComunicationLanguage,";
  1756.                             $tsql .= " CheckRebrePromocions=:CheckRebrePromocions";
  1757.                             $tsql .= " WHERE ";
  1758.                             $tsql .= " CustomerNr = :CustomerNr";
  1759.                         } else {
  1760.                             echo '<br>Insert<br>';
  1761.                             $tsql = "INSERT INTO ENTORNO_CUSTOMER_CHECK (";
  1762.                             $tsql .= " CustomerNr,";
  1763.                             $tsql .= " ComunicationLanguage,";
  1764.                             $tsql .= " CheckRebrePromocions";
  1765.                             $tsql .= " ) VALUES (";
  1766.                             $tsql .= " :CustomerNr,";
  1767.                             $tsql .= " :ComunicationLanguage,";
  1768.                             $tsql .= " :CheckRebrePromocions";
  1769.                             $tsql .= " )";
  1770.                         }
  1771.                         //echo $tsql;
  1772.                         // Preparem la sentència SQL
  1773.                         $stmt = $conn->prepare($tsql);
  1775.                         // Assignem valors als paràmetres
  1776.                         $stmt->bindParam(':CustomerNr', $aRgpd->getConsumers()->getCustomeraccountno());
  1777.                         $stmt->bindParam(':ComunicationLanguage', $aRgpd->getIdioma());
  1778.                         $sCheckRebrePromocions = 'n';
  1779.                         if ($aRgpd->getNewsletter() == 1) {
  1780.                             $sCheckRebrePromocions = 's';
  1781.                         }
  1782.                         $stmt->bindParam(':CheckRebrePromocions', $sCheckRebrePromocions);
  1784.                         // Executem la sentència SQL
  1785.                         if ($stmt->execute()) {
  1786.                             if (count($getCustomerCheck) > 0) {
  1787.                                 echo "Actualització exitosa!";
  1788.                             } else {
  1789.                                 echo "Inserció exitosa!";
  1790.                             }
  1791.                             // Marquem el registre com a enviat
  1792.                             $enRgpd = $this->em->getRepository(Rgpd::class)->find($aRgpd->getId());
  1793.                             $enRgpd->setEnviat(1);
  1794.                             $this->em->persist($enRgpd);
  1795.                             $this->em->flush();
  1796.                         } else {
  1797.                             echo "Error en la inserció: " . $stmt->errorInfo()[2];
  1798.                         }
  1800.                         echo '<br>---------------------<br>';
  1801.                     }
  1802.                 }
  1803.             }
  1804.         }
  1805.         echo '<br>-----------------------------------------------------------------------------------<br>';
  1806.         echo "Final actualització rebre promoció i descompte: " . date("Y-m-d H:i:s") . '<br>';
  1807.         return new Response('Finalitzat');
  1808.     }
  1809. }