src/Service/TicketService.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\Slave\Client;
  6. use App\Entity\Slave\ClientPhone;
  7. use App\Entity\Slave\Termid;
  8. use App\Entity\Slave\Ticket;
  9. use App\Entity\Slave\Warehouse;
  10. use App\Entity\Slave\TicketLog;
  11. use App\Service\UtilitiesService;
  12. use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
  13. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
  14. use Symfony\Component\HttpFoundation\Response;
  16. class TicketService
  17. {
  18.     // IMPORT DA EMAIL
  19.     // Chiamata da ScriptController
  20.     static public function importTickets($em, $emMaster, $user, $inbox, $email, $header, $supplierTicketEmails)
  21.     {
  22.         if(property_exists($header, "subject"))
  23.             $subject = $header->subject; // Prendo l'oggetto
  24.         else
  25.             $subject = "";
  26.         if($subject != "")
  27.             $subject = imap_mime_header_decode($subject)[0]->text;
  29.         $isHtml = false;
  30.         $dt = explode(', ', $header->date); // Prendo la data di creazione
  31.         $dts = explode(' (', $dt[sizeof($dt) - 1]); // Pulisco mettendo il formato per il create_date_from_format
  32.         $datetimeStart = date_create_from_format('j M Y H:i:s O', $dts[0]); //4 Jul 2023 16:00:11 +0200"
  33.         
  34.         $supplier = null;
  35.         foreach($supplierTicketEmails as $ste){
  36.             if($supplier == null){
  37.                 foreach($ste->getSupplier()->getOperations() as $op){
  38.                     if($supplier == null){
  39.                         foreach($op->getSubjectMappings() as $subj){
  40.                             if(strpos($subject, $subj->getValue()) !== false){
  41.                                 $supplier = $ste->getSupplier();
  42.                                 $isHtml = $ste->isHtml();
  43.                                 break;
  44.                             }
  45.                         }
  46.                     }
  47.                 }
  48.             }
  49.         }
  51.         $tickets = array();
  52.         $arrayNumberTermids = array();
  54.         if($supplier != null){
  55.             switch($supplier->getSlug()){
  56.                 case 'nexi-book-monetica':
  57.                 case 'nexi-book-meps':
  58.                     $json = TicketService::createJsonFromEmail($inbox, $email, false, false, false);
  59.                     $supplierMonetica = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-monetica'));
  60.                     $supplierMeps = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-meps'));
  61.                     $supplier = TicketService::nexiSupplierSearch($supplierMonetica, $json);
  62.                     if($supplier == null) $supplier = TicketService::nexiSupplierSearch($supplierMeps, $json);
  64.                     switch($supplier){
  65.                         case 'Monetica':
  66.                             $supplier = $supplierMonetica; 
  67.                             break;
  68.                         case 'Meps':
  69.                             $supplier = $supplierMeps; 
  70.                             break;
  71.                         default: break;
  72.                     }
  74.                     $subjectMapping = null;
  75.                     if($supplier != null){
  76.                         foreach($supplier->getOperations() as $op){
  77.                             if($subjectMapping == null){
  78.                                 foreach($op->getSubjectMappings() as $sm){
  79.                                     if(strpos($subject, $sm->getValue()) !== false){
  80.                                         $subjectMapping = $sm;
  81.                                         break;
  82.                                     }
  83.                                 }
  84.                             }
  85.                             else
  86.                                 break;
  87.                         }
  88.                     }
  90.                     if($subjectMapping != null){
  91.                         $operation = $subjectMapping->getOperation();
  92.                         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  93.                         if($supplier == null){
  94.                             $ticket->setSystemError(true);
  95.                             $ticket->setSystemErrorSlug('supplier');
  96.                             $ticket->setSystemErrorDetails("Non è stato possibile comprendere qual'è il fornitore NEXI (Meps o Monetica)");
  97.                             $em->flush();
  98.                         }
  99.                         if($ticket != null)
  100.                             array_push($tickets, $ticket);
  101.                     }
  102.                     break;
  103.                 case 'csc---nexi-book-monetica':
  104.                 case 'csc---nexi-book-meps':
  105.                     if($isHtml)
  106.                         $json = TicketService::createJsonFromEmail($inbox, $email, true, false, false);
  107.                     else
  108.                         $json = TicketService::createJsonFromEmail($inbox, $email, false, false, false);
  109.                     $supplierMonetica = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---nexi-book-monetica'));
  110.                     $supplierMeps = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---nexi-book-meps'));
  112.                     $supplier = TicketService::nexiSupplierSearch($supplierMonetica, $json);
  113.                     if($supplier == null) $supplier = TicketService::nexiSupplierSearch($supplierMeps, $json);
  115.                     switch($supplier){
  116.                         case 'Monetica':
  117.                             $supplier = $supplierMonetica; 
  118.                             break;
  119.                         case 'Meps':
  120.                             $supplier = $supplierMeps; 
  121.                             break;
  122.                         default: break;
  123.                     }
  125.                     $subjectMapping = null;
  126.                     if($supplier != null){
  127.                         foreach($supplier->getOperations() as $op){
  128.                             if($subjectMapping == null){
  129.                                 foreach($op->getSubjectMappings() as $sm){
  130.                                     if(strpos($subject, $sm->getValue()) !== false){
  131.                                         $subjectMapping = $sm;
  132.                                         break;
  133.                                     }
  134.                                 }
  135.                             }
  136.                             else
  137.                                 break;
  138.                         }
  139.                     }
  141.                     if($subjectMapping != null){
  142.                         $operation = $subjectMapping->getOperation();
  143.                         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  144.                         if($supplier == null){
  145.                             $ticket->setSystemError(true);
  146.                             $ticket->setSystemErrorSlug('supplier');
  147.                             $ticket->setSystemErrorDetails("Non è stato possibile comprendere qual'è il fornitore CSC NEXI (Meps o Monetica)");
  148.                             $em->flush();
  149.                         }
  150.                         if($ticket != null)
  151.                             array_push($tickets, $ticket);
  152.                     }
  153.                     break;
  154.                 case 'bcc-pos':
  155.                     $found = false;
  156.                     foreach($supplier->getOperations() as $op){
  157.                         $subjectMapping = $em->getRepository('App\Entity\Slave\OperationSubjectMapping')->findOneByOperationLikeSubject($op->getId(), $subject);
  158.                         if($subjectMapping){
  159.                             $found = true;
  160.                             break;
  161.                         }
  162.                     }
  164.                     if($found){
  165.                         // Assegno operazione guardando la chiave tipo intervento e confrontandola con la regex
  166.                         $attachmentsCheck = TicketService::getAttachmentsFromEmail($inbox, $email); // Prendo allegati email -> struttura array(["is_attachment"] => true/false, ["attachment"] => file)
  167.                         $attachments = array();
  168.                         foreach($attachmentsCheck as $att){
  169.                             if($att['is_attachment'] == 1){
  170.                                 array_push($attachments, $att);
  171.                             }
  172.                         }
  174.                         foreach($attachments as $attachment){
  175.                             $jsons = array();
  176.                             $index = null;
  177.                             $rows = explode("\r\n", $attachment['attachment']);
  178.                             $keys = explode(';', $rows[0]);
  179.                             for($i = 0; $i < sizeof($keys); $i++){
  180.                                 if(rtrim(ltrim($keys[$i], '"'), '"') == $supplier->getOperationMapping()){
  181.                                     $index = $i;
  182.                                     break;
  183.                                 }
  184.                             }
  185.                             $operation = null;
  186.                             for($i = 1; $i < sizeof($rows); $i++){
  187.                                 if($rows[$i] != ''){
  188.                                     $columns = explode(';', preg_replace('/\"/', '', $rows[$i]));
  189.                                     // Cerco l'operazione che corrisponde al regex
  190.                                     if($index != null){
  191.                                         foreach($supplier->getOperations() as $op){
  192.                                             if(!$op->isUav()){
  193.                                                 if(preg_match('/'.$op->getIdentifierRegex().'/', $columns[$index])){
  194.                                                     $operation = $op;
  195.                                                     break;
  196.                                                 }
  197.                                             }
  198.                                         }
  199.                                     }
  200.                                     // In ogni caso creo il json del ticket
  201.                                     $first = true;
  202.                                     $json = '[';
  203.                                     $rowValues = explode(';', $rows[$i]);
  204.                                     for($k = 0; $k < sizeof($rowValues); $k++)
  205.                                         [$json, $first] = TicketService::addToJson($json, $first, json_decode($keys[$k]), json_decode($rowValues[$k]));
  206.                                     $json.= ']';
  207.                                     if(sizeof($rowValues) > 1){
  208.                                         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  209.                                         if($operation == null){
  210.                                             $ticket->setSystemError(true);
  211.                                             $ticket->setSystemErrorSlug('key_mapping');
  212.                                             $ticket->setSystemErrorDetails("Non esiste la chiave \"".$supplier->getOperationMapping()."\" nei dettagli del ticket");
  213.                                             $em->flush();
  214.                                         }
  215.                                         if($ticket != null)
  216.                                             array_push($tickets, $ticket);
  217.                                     }
  218.                                 }
  219.                             }
  220.                         }
  221.                     }
  222.                     break;
  223.                 case 'fabrick':
  224.                 case 'fabrick---flex':
  225.                     $datetimeStart = date_modify($datetimeStart, "+2 hours");
  226.                     $operation = null;
  227.                     $json = TicketService::createJsonFromEmail($inbox, $email, false, false, true);
  228.                     $subjectMappings = $em->getRepository('App\Entity\Slave\OperationSubjectMapping')->findAllLikeSubject($supplier->getId(), $subject);
  229.                     foreach($subjectMappings as $sm){
  230.                         if($operation != null)
  231.                             break;
  232.                         $opField = $supplier->getOperationMapping();
  233.                         $op = $sm->getOperation();
  234.                         $jsonControl = json_decode($json, true);
  235.                         for($i=0; $i<sizeof($jsonControl); $i++){
  236.                             if(array_key_exists($opField, $jsonControl[$i]) && preg_match('/'.$op->getIdentifierRegex().'/', $jsonControl[$i][$opField])){
  237.                                 $operation = $op;
  238.                                 break;
  239.                             }
  240.                         }
  241.                     }
  242.                     
  243.                     [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  244.                     if($operation == null){
  245.                         $ticket->setSystemError(true);
  246.                         $ticket->setSystemErrorSlug('operation');
  247.                         $ticket->setSystemErrorDetails("Non è stato possibile comprendere qual'è l'operazione dal soggetto \"".$subject."\" dell'email");
  248.                         $em->flush();
  249.                     }
  250.                     if($ticket != null)
  251.                         array_push($tickets, $ticket);
  252.                     break;
  253.                 case 'demis-adp':
  254.                     $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'adp'));
  255.                     break;
  256.                 case 'worldline-italia':
  257.                 case 'worldline-ccb':
  258.                     $json = TicketService::createJsonFromEmail($inbox, $email, false, true, false);
  259.                     $identifier = TicketService::worldlineSupplierSearch('email', $json);
  261.                     $supplierNormal = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'worldline-italia'));
  262.                     $supplierCCB = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'worldline-ccb'));
  263.                     switch($identifier){
  264.                         case 'Normal': $supplier = $supplierNormal; break;
  265.                         case 'CCB': $supplier = $supplierCCB; break;
  266.                         default: break;
  267.                     }
  268.                     
  269.                     $subjectMapping = null;
  270.                     if($supplier != null){
  271.                         foreach($supplier->getOperations() as $op){
  272.                             if($subjectMapping == null){
  273.                                 foreach($op->getSubjectMappings() as $sm){
  274.                                     if(strpos($subject, $sm->getValue()) !== false){
  275.                                         $subjectMapping = $sm;
  276.                                         break;
  277.                                     }
  278.                                 }
  279.                             }
  280.                             else
  281.                                 break;
  282.                         }
  283.                     }
  285.                     if($subjectMapping != null){
  286.                         $operation = $subjectMapping->getOperation();
  287.                         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  288.                         if($supplier == null){
  289.                             $ticket->setSystemError(true);
  290.                             $ticket->setSystemErrorSlug('supplier');
  291.                             $ticket->setSystemErrorDetails("Non è stato possibile comprendere qual'è il fornitore WORLDLINE (Normale o CCB)");
  292.                             $em->flush();
  293.                         }
  294.                         if($ticket != null)
  295.                             array_push($tickets, $ticket);
  296.                     }
  297.                     break;
  298.                 case 'csc---axerve':
  299.                 case 'csc---cglobal':
  300.                 case 'csc---cronos':
  301.                 case 'csc---cse':
  302.                 case 'csc---decathlon':
  303.                 case 'csc---euronet':
  304.                 case 'csc---lis-pay':
  305.                 case 'csc---mooney':
  306.                 case 'csc---nexi-book-sia':
  307.                 case 'csc---numera':
  308.                 case 'csc---p4cards':
  309.                 case 'csc---q8':
  310.                 case 'csc---repas':
  311.                 case 'csc---stripe':
  312.                 case 'csc---worldline-italia':
  313.                 case 'csc---yamamay':
  314.                 case 'lis-holding':
  315.                     // Assegno operazione guardando l'oggetto delle email
  316.                     $operation = null;
  317.                     if($supplier->getSlug() == 'lis-holding')
  318.                         $json = TicketService::createJsonFromEmail($inbox, $email, false, false, false);
  319.                     else
  320.                         $json = TicketService::createJsonFromEmail($inbox, $email, true, false, false);
  321.                     
  322.                     $subjectMapping = $em->getRepository('App\Entity\Slave\OperationSubjectMapping')->findOneLikeSubject($supplier->getId(), $subject);
  323.                     if($subjectMapping != null){
  324.                         $operation = $subjectMapping->getOperation();
  325.                         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  326.                         if($operation == null){
  327.                             $ticket->setSystemError(true);
  328.                             $ticket->setSystemErrorSlug('operation');
  329.                             $ticket->setSystemErrorDetails("Non è stato possibile comprendere qual'è l'operazione dal soggetto \"".$subject."\" dell'email");
  330.                             $em->flush();
  331.                         }
  332.                         if($ticket != null)
  333.                             array_push($tickets, $ticket);
  334.                     }
  335.                     break;
  336.                 default: break;
  337.             }
  338.         }
  339.         return [$supplier, $tickets];
  340.     }
  342.     // Case BCC-POS
  343.     static public function getAttachmentsFromEmail($inbox, $email)
  344.     {
  345.         $structure = imap_fetchstructure($inbox, $email);
  346.         $attachments = array();
  348.         if(isset($structure->parts) && count($structure->parts) && $structure->ifid != "1"){
  349.             for($i = 0; $i < count($structure->parts); $i++) {
  350.                 $attachments[$i] = array('is_attachment' => false, 'attachment' => '');
  351.                 if($structure->parts[$i]->ifdparameters)
  352.                     foreach($structure->parts[$i]->dparameters as $object)
  353.                         if(strtolower($object->attribute) == 'filename')
  354.                             $attachments[$i]['is_attachment'] = true;
  356.                 if($structure->parts[$i]->ifparameters)
  357.                     foreach($structure->parts[$i]->parameters as $object)
  358.                         if(strtolower($object->attribute) == 'name')
  359.                             $attachments[$i]['is_attachment'] = true;
  361.                 if($attachments[$i]['is_attachment']){
  362.                     $attachments[$i]['attachment'] = imap_fetchbody($inbox, $email, $i+1);
  363.                     /* 3 = BASE64 encoding */
  364.                     if($structure->parts[$i]->encoding == 3) $attachments[$i]['attachment'] = base64_decode($attachments[$i]['attachment']);
  365.                     /* 4 = QUOTED-PRINTABLE encoding */
  366.                     elseif($structure->parts[$i]->encoding == 4) $attachments[$i]['attachment'] = quoted_printable_decode($attachments[$i]['attachment']);
  367.                 }
  368.             }
  369.         }
  371.         return $attachments;
  372.     }
  374.     // Case NEXI MONETICA o NEXI MEPS
  375.     static public function nexiSupplierSearch($sup, $json)
  376.     {
  377.         $supplier = null;
  378.         foreach($sup->getOperations() as $operation){
  379.             if(!$operation->isUav()){
  380.                 $supplier = TicketService::nexiSupplierSearchMepsOrMonetica($json, $operation->getKeyTicketNumber());
  381.                 if($supplier != null) break;
  382.             }
  383.         }
  384.         return $supplier;
  385.     }
  387.     static public function nexiMaintenanceSupplierSearch($sup, $json)
  388.     {
  389.         return TicketService::nexiSupplierSearchMepsOrMonetica($json, $sup->getOperationMaintenance()->getKeyTicketNumber());
  390.     }
  392.     static public function nexiSupplierSearchMepsOrMonetica($json, $key)
  393.     {
  394.         $array = json_decode($json, true);
  395.         foreach($array as $val){
  396.             $extraArray = json_decode($key->getMappingExtra(), true);
  397.             if(array_key_exists($key->getMappingValue(), $val)){
  398.                 if(substr($val[$key->getMappingValue()], 0, 1) == 'K' || substr($val[$key->getMappingValue()], 0, 1) == 'S')
  399.                     return 'Meps';
  400.                 else
  401.                     return 'Monetica';
  402.             }
  403.             else{
  404.                 $altKey = $key->displayMappingExtraValue("alt_key");
  405.                 if($altKey !== false){
  406.                     if(array_key_exists($altKey, $val)){
  407.                         if(substr($val[$altKey], 0, 1) == 'K' || substr($val[$altKey], 0, 1) == 'S')
  408.                             return 'Meps';
  409.                         else
  410.                             return 'Monetica';
  411.                     }
  412.                 }
  413.             }
  414.         }
  415.         return null;
  416.     }
  418.     // Case WORLDLINE CCB o Normale
  419.     static public function worldlineSupplierSearch($from, $json)
  420.     {
  421.         $identifier = null;
  422.         $json = json_decode($json, true);
  423.         $value = "";
  424.         $key = "";
  425.         switch($from){
  426.             case 'import': $key = "Canale brand"; break;
  427.             case 'email': $key = "Canale Brand"; break;
  428.             default: break;
  429.         }
  430.         for($i=0; $i < sizeof($json); $i++){
  431.             if(array_key_exists($key, $json[$i])){
  432.                 $value = $json[$i][$key];
  433.                 break;
  434.             }
  435.         }
  437.         switch($value){
  438.             case 'WL-BNL':
  439.             case 'WL-Desio':
  440.             case 'WL-Fucino':
  441.             case 'Worldline': $identifier = 'Normal'; break;
  442.             case 'WL-CCB': $identifier = 'CCB'; break;
  443.             default: $identifier = 'Normal'; break;
  444.         }
  446.         return $identifier;
  447.     }
  449.     // Case SATE
  450.     static public function sateSupplierSearch($from, $json)
  451.     {
  452.         $identifier = null;
  453.         $json = json_decode($json, true);
  454.         switch($from){
  455.             case 'import': $key = "Cliente"; break;
  456.             case 'email': $key = ""; break;
  457.             default: break;
  458.         }
  459.         for($i=0; $i < sizeof($json); $i++){
  460.             if(array_key_exists($key, $json[$i])){
  461.                 $value = $json[$i][$key];
  462.                 break;
  463.             }
  464.         }
  465.         switch($value){
  466.             case 'Argentea': $identifier = 'Sate-Argentea'; break;
  467.             case 'FlagPay': $identifier = 'Sate-Flagpay'; break;
  468.             case 'Mooney': $identifier = 'Sate-Mooney'; break;
  469.             case 'Numera': $identifier = 'Sate-Numera'; break;
  470.             case 'Pluxee': $identifier = 'Sate-Pluxee'; break;
  471.             case 'Worldline': $identifier = 'Sate-Worldline'; break;
  472.             default: break;
  473.         }
  474.         return $identifier;
  475.     }
  477.     // Altri case tranne BCC-POS
  478.     static public function createJsonFromEmail($inbox, $email, $isCsc, $isWorldline, $isFabrick)
  479.     {
  480.         $body = imap_fetchbody($inbox, $email, 1, FT_PEEK);
  481.         $body = UtilitiesService::convertAsciiToHtml($body, $isFabrick);
  482.         $body = preg_replace("<<br>>", "", $body);
  483.         if($isCsc){
  484.             $body = strip_tags($body);
  485.             $startIndex = strpos($body, "Cliente");
  486.             if ($startIndex !== false) {
  487.                 $body = substr($body, $startIndex);
  488.                 $endIndex =  strpos($body, "QUESTA MAIL");
  489.                 if ($endIndex !== false) {
  490.                     $body = substr($body, 0, $endIndex);
  491.                 }
  492.             }
  493.             $bodyArray = preg_split("/(#+)/", $body, -1, PREG_SPLIT_DELIM_CAPTURE);
  494.         }
  495.         elseif($isFabrick){
  496.             $body = strip_tags($body);
  497.             $startIndex = strpos($body, "Stato");
  498.             if ($startIndex !== false) {
  499.                 $body = substr($body, $startIndex);
  500.             }
  501.             $body = preg_replace("/\\r\\n/", "-#-", $body);
  502.             $bodyArray = preg_split("/(-#-)+/", $body, -1, PREG_SPLIT_DELIM_CAPTURE);
  503.         }
  504.         else{
  505.             $body = preg_replace("/\\r\\n/", "-#-", $body);
  506.             $bodyArray = preg_split("/(-#-)+/", $body, -1, PREG_SPLIT_DELIM_CAPTURE);
  507.         }
  509.         $fields = array();
  510.         foreach($bodyArray as $string){
  511.             $string = preg_replace('/\r\n/', '', $string);
  512.             $string = preg_replace('/\n/', '', $string);
  513.             $string = preg_replace('/Questa e-mailC3=A8 stata generata automaticamente\. Si prega di non rispondere a questo messaggio\./i', '', $string);
  515.             if($isCsc)
  516.                 $string = preg_replace('/#/', '', $string);
  517.             if(str_contains($string, ':'))
  518.                 array_push($fields, $string);
  519.             // Serve per concatenare le note o i campi che vanno a capo a caso, se non ci sono i : nella stringa, aggiungo il valore al campo precedente, ignorando dove c'è solo a capo, senza altri valori
  520.             elseif(sizeof($fields) > 1 && $string != "-#-")
  521.                 $fields[sizeof($fields) - 1].= $string;
  522.         }
  523.         $json = TicketService::createJsonData($fields);
  524.         return $json;
  525.     }
  526.     
  527.     static public function checkTicketExistanceCsv($em, $json, $number, $termid, $arrayNumberTermids){
  528.         $array = json_decode($json, true);
  529.         $ticketAlreadyExist = false;
  530.         // Cerco il ticket-termid nel database
  531.         $tickets = $em->getRepository('App\Entity\Slave\Ticket')->findAllByNumber($number);
  532.         foreach($tickets as $t){
  533.             if($t != null && $t->getTermid()->getCode() == $termid){
  534.                 $ticketAlreadyExist = true;
  535.                 break;
  536.             }
  537.         }
  538.         // Cerco il ticket-termid nell'array numero-termid del CSV che sto importando -> serve a evitare che non sia ancora nel database perchè non è ancora stato pushato ma è era già presente nel file
  539.         if(!$ticketAlreadyExist){
  540.             foreach($arrayNumberTermids as $nt){
  541.                 if($nt[0] == $number && $nt[1] == $termid){
  542.                     $ticketAlreadyExist = true;
  543.                     $ticket = $t;
  544.                     break;
  545.                 }
  546.             }
  547.         }
  549.         if(!$ticketAlreadyExist){
  550.             $tmp = [];
  551.             array_push($tmp, $number, $termid);
  552.             array_push($arrayNumberTermids, $tmp);
  553.         }
  554.         return [$ticketAlreadyExist, $arrayNumberTermids];
  555.     }
  557.     static public function checkTicketExistanceDownload($em, $supplier, $operation, $json, $arrayNumberTermids){
  558.         $ticketAlreadyExist = null;
  559.         $ticket = null;
  560.         $keyNumber = $operation->getKeyTicketNumber();
  561.         $altKeyNumber = $operation->getKeyTicketNumber()->displayMappingExtraValue("alt_key");
  562.         $keyTermid = $operation->getKeyTermid();
  563.         $altKeyTermid = $operation->getKeyTermid()->displayMappingExtraValue("alt_key");
  564.         $array = json_decode($json, true);
  565.         $number = null;
  566.         $termid = null;
  568.         foreach($array as $val){
  569.             if($number == null && array_key_exists($keyNumber->getMappingValue(), $val))
  570.                 $number = preg_replace('/<br>/', '', $val[$keyNumber->getMappingValue()]);
  571.             else{
  572.                 if($number == null && $altKeyNumber !== false && array_key_exists($altKeyNumber, $val))
  573.                     $number = preg_replace('/<br>/', '', $val[$altKeyNumber]);
  574.             }
  575.             if($termid == null && array_key_exists($keyTermid->getMappingValue(), $val))
  576.                 $termid = preg_replace('/<br>/', '', $val[$keyTermid->getMappingValue()]);
  577.             else{
  578.                 if($termid == null && $altKeyTermid !== false && array_key_exists($altKeyTermid, $val))
  579.                     $termid = preg_replace('/<br>/', '', $val[$altKeyTermid]);
  580.             }
  581.         }
  582.             
  583.         if($number != null && $termid != null){
  584.             $ticketAlreadyExist = false;
  585.             // Cerco il ticket-termid nel database
  586.             $tickets = $em->getRepository('App\Entity\Slave\Ticket')->findAllByNumber($number);
  587.             foreach($tickets as $t){
  588.                 if($t != null && $t->getTermid()->getCode() == $termid){
  589.                     $ticketAlreadyExist = true;
  590.                     $ticket = $t;
  591.                     break;
  592.                 }
  593.             }
  595.             // Cerco il ticket-termid nell'array numero-termid del CSV che sto importando -> serve a evitare che non sia ancora nel database perchè non è ancora stato pushato ma è era già presente nel file
  596.             if(!$ticketAlreadyExist){
  597.                 foreach($arrayNumberTermids as $nt){
  598.                     if($nt[0] == $number && $nt[1] == $termid){
  599.                         $ticketAlreadyExist = true;
  600.                         break;
  601.                     }
  602.                 }
  603.             }
  605.             if(!$ticketAlreadyExist){
  606.                 $tmp = [];
  607.                 array_push($tmp, $number, $termid);
  608.                 array_push($arrayNumberTermids, $tmp);
  609.             }
  610.         }
  611.         return [$ticketAlreadyExist, $ticket, $arrayNumberTermids];
  612.     }
  614.     // Funzioni importTickets
  615.     static public function createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids){
  617.         // Controllo se esiste già un ticket con lo stesso numero e termid
  618.         [$ticketAlreadyExist, $returnTicket, $arrayNumberTermids] = TicketService::checkTicketExistanceDownload($em, $supplier, $operation, $json, $arrayNumberTermids);
  619.         
  620.         if(!$ticketAlreadyExist){
  621.             $statusToAssign = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'to_assign'));
  622.             $today = new \Datetime();
  623.             $ticket = new Ticket();
  624.             $ticket->setSupplier($supplier);
  625.             $ticket->setOperation($operation);
  626.             $ticket->setDatetimeStart($datetimeStart);
  627.             $ticket->setStatus($statusToAssign);
  628.             $ticket->setDirectoryPath($today->format("Y").'/'.$today->format("m").'/'.md5(uniqid()));
  629.             $ticket->setJson($json);
  630.             $ticket->setJsonReport('[]');
  631.             $ticket->setDatetimeImport(new \DateTime());
  632.             
  633.             $array = json_decode($json, true);
  634.             for($i=0; $i<sizeof($array); $i++){
  635.                 if($supplier->getOperationNotBillableCodes() != null && $supplier->getOperationNotBillableCodes() != '' && array_key_exists($supplier->getOperationMapping(), $array[$i]) && preg_match('/'.$supplier->getOperationNotBillableCodes().'/', $array[$i][$supplier->getOperationMapping()]))
  636.                     $ticket->setBillable(false);
  637.             }
  639.             try {
  640.                 $em->persist($ticket);
  641.                 $em->flush();
  642.             } catch (UniqueConstraintViolationException $exception) {
  643.                 return null;
  644.             } catch (\Throwable $exception) {
  645.                 // TO DO
  646.                 switch($exception->getCode()){
  647.                     case 1062:
  648.                     case 1557:
  649.                     case 1569:
  650.                     case 1586: return null; break;
  651.                 }
  652.             }
  653.             return [$ticket, $arrayNumberTermids];
  654.         }
  655.         else{
  656.             if($supplier->getSlug() == 'worldline-ccb' || $supplier->getSlug() == 'worldline-italia'){
  657.                 if($returnTicket != null){
  658.                     $actualJson = $returnTicket->getJson();
  659.                     $dateExpirationKeyMapping = $em->getRepository('App\Entity\Slave\OperationKeyMapping')->findOneBy(["operation" => $returnTicket->getOperation()->getId(), "ticketColumn"=>"Data scadenza"]);
  660.                     $actualK = $dateExpirationKeyMapping->getMappingValue();
  661.                     $newK = $dateExpirationKeyMapping->displayMappingExtraValue("alt_key");
  662.                     $newFormat = $dateExpirationKeyMapping->displayMappingExtraValue("alt_date_format");
  663.                     $newV = "";
  665.                     $newArray = json_decode($json, true);
  666.                     foreach ($newArray as $newItem) {
  667.                         if(array_key_exists($newK, $newItem)){
  668.                             $newV = $newItem[$newK];
  669.                             break;
  670.                         }
  671.                     }
  672.                     if($newV != ""){
  673.                         // CERCO SE ESISTE GIA' LA CHIAVE NEL JSON
  674.                         $actualArray = json_decode($actualJson, true);
  675.                         if($actualArray != null){
  676.                             for($i = 0; $i< sizeof($actualArray); $i++){
  677.                                 if (array_key_exists($actualK, $actualArray[$i])) {
  678.                                     $actualArray[$i] = [$newK => $newV];
  679.                                     $datetimeExpiration = date_create_from_format($newFormat, $newV);
  680.                                     $returnTicket->setDatetimeExpiration($datetimeExpiration);
  681.                                     break;
  682.                                 }
  683.                             }
  684.                             $json = json_encode($actualArray, JSON_PRETTY_PRINT);
  685.                             $returnTicket->setJson($json);
  686.                             $em->flush();
  687.                         }
  688.                     }
  689.                 }
  690.                 return [$returnTicket, $arrayNumberTermids];
  691.             }
  692.         }
  693.         return [null, $arrayNumberTermids];
  694.     }
  696.     static public function createJsonData($array)
  697.     {
  698.         $first = true;
  699.         $json = '[';
  700.         foreach($array as $string){
  701.             $parts = explode(':', $string, 2);
  702.             [$json, $first] = TicketService::addToJson($json, $first, $parts[0], $parts[1]);
  703.         }
  704.         $json.= ']';
  705.         return $json;
  706.     }
  708.     static public function addToJson($json, $first, $key, $value)
  709.     {
  710.         if($first) $first = false; else $json.= ',';
  711.         $k = preg_replace('/<br>/', '', ltrim(rtrim($key, " "), " "));
  712.         $k = preg_replace("/\s\/\s/", "/", $k);
  713.         $v = preg_replace('/<br>/', '', ltrim(rtrim($value, " "), " "));
  714.         $json.= '{'.json_encode($k).':'.json_encode($v).'}';
  715.         return [$json, $first];
  716.     }
  718.     static public function ticketMapClient($em, $ticket)
  719.     {
  720.         $found = false;
  721.         $error = false;
  722.         $code = '';
  723.         $json = json_decode($ticket->getJson(), true);
  724.         $keys = preg_split('/\|/', $ticket->getOperation()->getCodeClient());
  725.         
  726.         foreach($keys as $key){
  727.             if(!$found){
  728.                 $parts = explode('+', $key);
  729.                 for($i = 0; $i < sizeof($json); $i++){
  730.                     foreach($parts as $p){
  731.                         if(array_key_exists(preg_replace("/\s\/\s/", "/", $p), $json[$i])){
  732.                             $code .= $json[$i][preg_replace("/\s\/\s/", "/", $p)];
  733.                             $found = true;
  734.                             break;
  735.                         }
  736.                     }
  737.                 }
  738.             }
  739.         }
  741.         if(!$found){
  742.             $error = true;
  743.             $ticket->setSystemError(true);
  744.             $ticket->setSystemErrorSlug('client');
  745.             $ticket->setSystemErrorDetails("Non è configurata la chiave per identificare il cliente nell'operazione");
  746.         }
  747.         else{
  748.             $found = false;
  749.             $termid = null;
  750.             $keysRequired = $em->getRepository('App\Entity\Slave\OperationKeyMapping')->findByOperationAndRequired($ticket->getOperation()->getId(), true);
  751.             foreach($keysRequired as $k){
  752.                 if(!$found){
  753.                     $altKey = $k->displayMappingExtraValue("alt_key");
  754.                     for($i = 0; $i < sizeof($json); $i++){
  755.                         if(array_key_exists($k->getMappingValue(), $json[$i]) || ($altKey !== false && array_key_exists($altKey, $json[$i]))){
  756.                             if(array_key_exists($k->getMappingValue(), $json[$i]))
  757.                                 $value = $json[$i][$k->getMappingValue()];
  758.                             else
  759.                                 $value = $json[$i][$altKey]; 
  760.                             //if($code == '' && $k->getTicketColumn() == 'Term ID'){
  761.                             if($k->getTicketColumn() == 'Term ID'){
  762.                                 $code = UtilitiesService::updateTermidCodeToEightChars($value);
  763.                                 $termid = $em->getRepository('App\Entity\Slave\Termid')->findOneBy(array('code' => $code));
  764.                                 $found = true;
  765.                                 break;
  766.                             }
  767.                         }
  768.                     }
  769.                 }
  770.             }
  771.             $client = null;
  772.             if($termid != null && $termid->getClient() != null)
  773.                 $client = $termid->getClient();
  774.             if($client == null)
  775.                 $client = $em->getRepository('App\Entity\Slave\Client')->findOneBy(array('code' => $code));
  777.             if($client == null){
  778.                 $client = new Client();
  779.                 $client->setCode($code);
  780.                 $client->setDirectoryPath(md5(uniqid()));
  781.                 $em->persist($client);
  782.     
  783.                 $warehouse = new Warehouse();
  784.                 $warehouse->setClient($client);
  785.                 $warehouse->setMovable(false);
  786.                 $client->setWarehouse($warehouse);
  787.                 $em->persist($warehouse);
  788.                 $em->flush();
  789.             }
  790.     
  791.             $ticket->setClient($client);
  792.         }
  794.         $em->flush();
  795.         return $error;
  796.     }
  798.     static public function isInCoverCompany($company, $regionId)
  799.     {        
  800.         foreach($company->getRegions() as $region){
  801.             if($regionId == $region->getId()){
  802.                 return true;
  803.                 break;
  804.             }
  805.         }
  806.         return false;
  807.     }
  809.     static public function ticketMapColumns($em, $emMaster, $company, $ticket)
  810.     {
  811.         $array = json_decode($ticket->getJson(), true);
  812.         $client = $ticket->getClient();
  813.         $first = true;
  814.         $json = '[';
  816.         $keysOptional = $em->getRepository('App\Entity\Slave\OperationKeyMapping')->findByOperationAndRequired($ticket->getOperation()->getId(), false);
  817.         foreach($keysOptional as $k){
  818.             $altKey = $k->displayMappingExtraValue("alt_key");
  819.             foreach($array as $val){
  820.                 $isAlt = false;
  821.                 if(array_key_exists($k->getMappingValue(), $val) || ($altKey !== false && array_key_exists($altKey, $val))){
  822.                     if(array_key_exists($k->getMappingValue(), $val))
  823.                         $value = $val[$k->getMappingValue()];
  824.                     else{
  825.                         $value = $val[$altKey];
  826.                         $isAlt = true;
  827.                     }
  828.                     switch($k->getTicketColumn()){
  829.                         case 'Telefono 1': TicketService::managePhone($em, $client, $value, "Telefono 1"); break;
  830.                         case 'Telefono 2': TicketService::managePhone($em, $client, $value, "Telefono 2"); break;
  831.                         case 'Telefono 3': TicketService::managePhone($em, $client, $value, "Telefono cellulare"); break;
  832.                         case 'Referente': $client->setReferent($value); break;
  833.                         case 'Orari apertura': $client->setOpenings($value); break;
  834.                         case 'Giorno chiusura': $client->setClosures($value); break;
  835.                         case 'Data scadenza':
  836.                             if(!$isAlt){
  837.                                 if($k->displayMappingExtraValue('date_format') != null && $k->displayMappingExtraValue('date_format') != ''){
  838.                                     $datetime = date_create_from_format($k->displayMappingExtraValue('date_format'), $value);
  839.                                     if($datetime != "")
  840.                                         $ticket->setDatetimeExpiration($datetime);
  841.                                 }
  842.                             }
  843.                             else{
  844.                                 if($k->displayMappingExtraValue('alt_date_format') != null && $k->displayMappingExtraValue('alt_date_format') != ''){
  845.                                     $datetime = date_create_from_format($k->displayMappingExtraValue('alt_date_format'), $value);
  846.                                     if($datetime != "")
  847.                                         $ticket->setDatetimeExpiration($datetime);
  848.                                 }
  849.                             }
  850.                             $found = true;
  851.                             break;
  852.                         case 'Cassa': 
  853.                         case 'ABI': 
  854.                         case 'Risorsa': 
  855.                         case 'Risorsa upgrade': 
  856.                         case 'Accessori': 
  857.                         case 'Matricole': 
  858.                         case 'Anomalia': 
  859.                         case 'Connessioni': 
  860.                         case 'Dettagli operazione': 
  861.                         case 'Dettagli intervento': 
  862.                         case 'Note': 
  863.                             [$json, $first] = TicketService::addToJson($json, $first, $k->getTicketColumn(), $value);
  864.                             break;
  865.                         case 'Data richiesta':
  866.                             if($k->displayMappingExtraValue('date_format') != null && $k->displayMappingExtraValue('date_format') != ''){
  867.                                 $datetime = date_create_from_format($k->displayMappingExtraValue('date_format'), $value);
  868.                                 if($datetime != "")
  869.                                     $ticket->setDatetimeStart($datetime);
  870.                             }
  871.                         case 'Ora richiesta':
  872.                             if($k->displayMappingExtraValue('time_format') != null && $k->displayMappingExtraValue('time_format') != ''){
  873.                                 $datetime = date_create_from_format('Ymd'.$k->displayMappingExtraValue('time_format'), $ticket->getDatetimeStart()->format('Ymd').$value);
  874.                                 if($datetime != "")
  875.                                     $ticket->setDatetimeStart($datetime);
  876.                             }
  877.                             break;
  878.                         default: break;
  879.                     }
  880.                 }
  881.             }
  882.         }
  883.         $json .= ']';
  884.         $ticket->setJsonReport($json);
  885.         $keysRequired = $em->getRepository('App\Entity\Slave\OperationKeyMapping')->findByOperationAndRequired($ticket->getOperation()->getId(), true);
  886.         foreach($keysRequired as $k){
  887.             $errorSlug = 'key_mapping';
  888.             $errorMsg = "Non esiste la chiave \"".$k->getMappingValue()."\" per la colonna \"".$k->getTicketColumn()."\" nel dettaglio del ticket";
  889.             $found = false;
  890.             $zip = null;
  891.             $altKey = $k->displayMappingExtraValue("alt_key");
  892.             foreach($array as $val){
  893.                 $isAlt = false;
  894.                 if(array_key_exists($k->getMappingValue(), $val) || ($altKey !== false && array_key_exists($altKey, $val))){
  895.                     if(array_key_exists($k->getMappingValue(), $val))
  896.                         $value = $val[$k->getMappingValue()];
  897.                     else{
  898.                         $value = $val[$altKey];
  899.                         $isAlt = true;
  900.                     }
  901.                     switch($k->getTicketColumn()){
  902.                         case 'Numero intervento': 
  903.                             $ticket->setNumber($value);
  904.                             $found = true;
  905.                             break;
  906.                         case 'Term ID': 
  907.                             $code = UtilitiesService::updateTermidCodeToEightChars($value);
  908.                             $termid = $em->getRepository('App\Entity\Slave\Termid')->findOneBy(array('code' => $code));
  909.                             if($termid == null){
  910.                                 $termid = new Termid();
  911.                                 $termid->setClient($client);
  912.                                 $termid->setCode($value);
  913.                                 $em->persist($termid);
  914.                             }
  915.                             $found = true;
  916.                             $ticket->setTermid($termid);
  917.                             if(sizeof($termid->getProducts()) > 0){
  918.                                 foreach($termid->getProducts() as $prod)
  919.                                     $prod->getActualWarehouse($client->getWarehouse());
  920.                             }
  921.                             break;
  922.                         case 'Insegna': 
  923.                             $client->setNickname($value);
  924.                             if($client->getWarehouse()->getNickname() == null)
  925.                                 $client->getWarehouse()->setNickname('Cliente - '.$value);
  926.                             $found = true;
  927.                             break;
  928.                         case 'CAP': 
  929.                             if($ticket->getZip() == null)
  930.                                 $ticket->setZip($value);
  931.                             if($client->getZip() == null)
  932.                                 $client->setZip($value);
  933.                             $found = true;
  934.                             $zip = $emMaster->getRepository('App\Entity\Master\Zip')->findOneByCode($value);
  935.                             if($zip != null){
  936.                                 $ticket->setIdProvince($zip->getCities()[0]->getProvince()->getId());
  937.                                 $client->setIdProvince($zip->getCities()[0]->getProvince()->getId());
  938.                             }
  939.                             break;
  940.                         case 'Provincia': 
  941.                             $province = $emMaster->getRepository('App\Entity\Master\Province')->findOneBySignOrName($value);
  942.                             if($province == null){
  943.                                 if($zip != null)
  944.                                     $province = $zip->getCity()->getProvince();
  945.                             }
  946.                             if($province != null){
  947.                                 $ticket->setIdProvince($province->getId());
  948.                                 $client->setIdProvince($province->getId());
  949.                                 if(TicketService::isInCoverCompany($company, $province->getRegion()->getId()))
  950.                                     $found = true;
  951.                                 else{
  952.                                     $errorSlug = 'city';
  953.                                     $errorMsg = "L'indirizzo del ticket non è in copertura all'azienda; assegna manualmente l'indirizzo!";
  954.                                 }
  955.                             }
  956.                             else{
  957.                                 $errorSlug = 'province_alias';
  958.                                 $errorMsg = 'Il server non ha trovato la provincia; seleziona la provincia corrispondente a: "'.$value.'"';
  959.                             }
  960.                             break;
  961.                         case 'Città':
  962.                             $city = $emMaster->getRepository('App\Entity\Master\City')->findByNameOrAliasAndProvince($value, $ticket->getIdProvince());
  963.                             if($city != null){
  964.                                 $ticket->setIdCity($city->getId());
  965.                                 $client->setIdCity($city->getId());
  966.                                 
  967.                                 $ticket->setIdProvince($city->getProvince()->getId());
  968.                                 $client->setIdProvince($city->getProvince()->getId());
  970.                                 if($zip == null && sizeof($city->getZips()) == 1){
  971.                                     $client->setZip($city->getZips()[0]->getCode());
  972.                                     $ticket->setZip($city->getZips()[0]->getCode());
  973.                                 }
  974.                                 if(TicketService::isInCoverCompany($company, $city->getProvince()->getRegion()->getId())){
  975.                                     $found = true;
  976.                                 }
  977.                                 else{
  978.                                     $errorSlug = 'city';
  979.                                     $errorMsg = "L'indirizzo del ticket non è in copertura all'azienda; assegna manualmente l'indirizzo!";
  980.                                 }
  981.                             }
  982.                             else{
  983.                                 $province = $emMaster->getRepository('App\Entity\Master\Province')->findOneById($ticket->getIdProvince());
  984.                                 $errorSlug = 'city_alias';
  985.                                 $errorMsg = 'Il server non ha trovato la città; verifica se devi inserire un alias per: "'.$value.'"';
  986.                             }
  987.                             break;
  988.                         case 'Indirizzo':
  989.                             $client->setAddress($value);
  990.                             $ticket->setAddress($value);
  991.                             $found = true;
  992.                             break;
  993.                         default: break;
  994.                     }
  995.                 }
  996.             }
  997.             if(!$found){
  998.                 $ticket->setSystemError(true);
  999.                 $ticket->setSystemErrorSlug($errorSlug);
  1000.                 $ticket->setSystemErrorDetails($errorMsg);
  1001.                 $em->flush();
  1002.                 return true;
  1003.             }
  1004.         }
  1006.         if($client->getZip() == null && $client->getIdCity() != null){
  1007.             $city = $emMaster->getRepository('App\Entity\Master\City')->findOneById($client->getIdCity());
  1008.             if(sizeof($city->getZips()) == 1)
  1009.                 $zip = $city->getZips()[0]->getCode();
  1010.             else{
  1011.                 $zip = $city->getZips()[0]->getCode();
  1012.                 /* TODO
  1013.                 $address = $client->getAddress().' '.$city->getName().' '.$city->getProvince()->getSign();
  1014.                 $zip = UtilitiesService::calculateZipFromAddress($address);
  1015.                 */
  1016.             }
  1017.             $client->setZip($zip);
  1018.             $ticket->setZip($zip);
  1019.         }
  1021.         $em->flush();
  1022.         return false;
  1023.     }
  1024.     
  1025.     static public function ticketMapOptionalColumns($em, $ticket)
  1026.     {
  1027.         $array = json_decode($ticket->getJson(), true);
  1028.         $client = $ticket->getClient();
  1029.         $first = true;
  1030.         $json = '[';
  1032.         $keysOptional = $em->getRepository('App\Entity\Slave\OperationKeyMapping')->findByOperationAndRequired($ticket->getOperation()->getId(), false);
  1033.         foreach($keysOptional as $k){
  1034.             $altKey = $k->displayMappingExtraValue("alt_key");
  1035.             foreach($array as $val){
  1036.                 $isAlt = false;
  1037.                 if(array_key_exists($k->getMappingValue(), $val) || ($altKey !== false && array_key_exists($altKey, $val))){
  1038.                     if(array_key_exists($k->getMappingValue(), $val))
  1039.                         $value = $val[$k->getMappingValue()];
  1040.                     else{
  1041.                         $value = $val[$altKey];
  1042.                         $isAlt = true;
  1043.                     }
  1044.                     switch($k->getTicketColumn()){
  1045.                         case 'Telefono 1': TicketService::managePhone($em, $client, $value, "Telefono 1"); break;
  1046.                         case 'Telefono 2': TicketService::managePhone($em, $client, $value, "Telefono 2"); break;
  1047.                         case 'Telefono 3': TicketService::managePhone($em, $client, $value, "Telefono cellulare"); break;
  1048.                         case 'Referente': $client->setReferent($value); break;
  1049.                         case 'Orari apertura': $client->setOpenings($value); break;
  1050.                         case 'Giorno chiusura': $client->setClosures($value); break;
  1051.                         case 'Data scadenza':
  1052.                             if(!$isAlt){
  1053.                                 if($k->displayMappingExtraValue('date_format') != null && $k->displayMappingExtraValue('date_format') != ''){
  1054.                                     $datetime = date_create_from_format($k->displayMappingExtraValue('date_format'), $value);
  1055.                                     if($datetime != "")
  1056.                                         $ticket->setDatetimeExpiration($datetime);
  1057.                                 }
  1058.                             }
  1059.                             else{
  1060.                                 if($k->displayMappingExtraValue('alt_date_format') != null && $k->displayMappingExtraValue('alt_date_format') != ''){
  1061.                                     $datetime = date_create_from_format($k->displayMappingExtraValue('alt_date_format'), $value);
  1062.                                     if($datetime != "")
  1063.                                         $ticket->setDatetimeExpiration($datetime);
  1064.                                 }
  1065.                             }
  1066.                             $found = true;
  1067.                             break;
  1068.                         case 'Cassa': 
  1069.                         case 'ABI': 
  1070.                         case 'Risorsa': 
  1071.                         case 'Risorsa upgrade': 
  1072.                         case 'Accessori': 
  1073.                         case 'Matricole': 
  1074.                         case 'Anomalia': 
  1075.                         case 'Connessioni': 
  1076.                         case 'Dettagli operazione': 
  1077.                         case 'Dettagli intervento': 
  1078.                         case 'Note': 
  1079.                             [$json, $first] = TicketService::addToJson($json, $first, $k->getTicketColumn(), $value);
  1080.                             break;
  1081.                         case 'Data richiesta':
  1082.                             if($k->displayMappingExtraValue('date_format') != null && $k->displayMappingExtraValue('date_format') != ''){
  1083.                                 $datetime = date_create_from_format($k->displayMappingExtraValue('date_format'), $value);
  1084.                                 if($datetime != "")
  1085.                                     $ticket->setDatetimeStart($datetime);
  1086.                             }
  1087.                         case 'Ora richiesta':
  1088.                             if($k->displayMappingExtraValue('time_format') != null && $k->displayMappingExtraValue('time_format') != ''){
  1089.                                 $datetime = date_create_from_format('Ymd'.$k->displayMappingExtraValue('time_format'), $ticket->getDatetimeStart()->format('Ymd').$value);
  1090.                                 if($datetime != "")
  1091.                                     $ticket->setDatetimeStart($datetime);
  1092.                             }
  1093.                             break;
  1094.                         default: break;
  1095.                     }
  1096.                 }
  1097.             }
  1098.         }
  1099.         $json .= ']';
  1100.         $ticket->setJsonReport($json);
  1102.         $em->flush();
  1103.     }
  1105.     static public function managePhone($em, $client, $number, $name)
  1106.     {
  1107.         $found = false;
  1108.         if($number != ""){
  1109.             foreach($client->getPhones() as $phone){
  1110.                 if($phone->getNumber() == $number){
  1111.                     $found = true;
  1112.                     break;
  1113.                 }
  1114.             }
  1115.             if(!$found){
  1116.                 $clientPhone = new ClientPhone();
  1117.                 $clientPhone->setClient($client);
  1118.                 $clientPhone->setNumber($number);
  1119.                 $clientPhone->setName($name);
  1120.                 $em->persist($clientPhone);
  1122.                 $client->addPhone($clientPhone);
  1123.             }
  1124.         }
  1125.     }
  1127.     static public function ticketAssignOperationTariffAmount($em, $emMaster, $ticket)
  1128.     {
  1129.         $tariff = null;
  1130.         $uavTariff = null;
  1132.         $city = $emMaster->getRepository('App\Entity\Master\City')->findOneById($ticket->getIdCity());
  1133.         // CERCO LA TARIFFA OPERAZIONE
  1134.         if($city != null){
  1135.             foreach($ticket->getOperation()->getTariffs() as $tar){
  1136.                 $zips = array();
  1137.                 foreach($tar->getZips() as $arrayZip)
  1138.                     array_push($zips, $arrayZip[1]);
  1140.                 if($tar->getIdProvince() == $city->getProvince()->getId() && ($tar->isAllZip() || in_array($ticket->getZip(), $zips))){
  1141.                     $tariff = $tar;
  1142.                     break;
  1143.                 }
  1144.             }
  1145.         }
  1147.         // SE LA TARIFFA ESISTE, CONTROLLO GLI ALGORITMI DEI SUOI AMOUNT
  1148.         if($tariff != null){
  1149.             $found = false;
  1150.             foreach($tariff->getAmounts() as $ota){
  1151.                 if($ota->getAlgorithm() != null && !$found){
  1152.                     switch($ota->getAlgorithm()->getSlug()){
  1153.                         case "monetica-massive-dll":
  1154.                             $matrix = json_decode($ticket->getJsonReport(), true);
  1155.                             foreach($matrix as $array){
  1156.                                 if(array_key_exists('Anomalia', $array) && str_contains(strtolower($array["Anomalia"]), strtolower("Aggiornamento mandate")) && str_contains(strtolower($array["Anomalia"]), strtolower("effettuare DLL"))){
  1157.                                     $operationTariffAmount = $ota;
  1158.                                     $found = true;
  1159.                                     break;
  1160.                                 }
  1161.                             }
  1162.                             break;
  1163.                         default: break;
  1164.                     }
  1165.                 }
  1166.             }
  1167.             if(!$found)
  1168.                 $operationTariffAmount = $tariff->getStandardAmount();
  1170.             $ticket->setOperationTariffAmount($operationTariffAmount);
  1171.             $ticket->setSystemError(false);
  1172.         }
  1173.         else{
  1174.             $ticket->setSystemError(true);
  1175.             $ticket->setSystemErrorSlug('tariff');
  1176.             $ticket->setSystemErrorDetails("Tariffa operazione corrispondente a questa provincia/città/CAP da assegnare al ticket non trovata!");
  1177.             $em->flush();
  1178.             return true;
  1179.         }
  1180.         
  1181.         // CERCO L'OPERAZIONE UAV DEL FORNITORE
  1182.         $uavOt = null;
  1183.         foreach($ticket->getSupplier()->getOperations() as $op){
  1184.             if($op->isUav()){
  1185.                 $uavOt = $op;
  1186.                 break;
  1187.             }
  1188.         }
  1189.         // CERCO LE TARIFFE DELL'UAV
  1190.         foreach($uavOt->getTariffs() as $uavTar){
  1191.             $zips = array();
  1192.             foreach($uavTar->getZips() as $arrayZip)
  1193.                 array_push($zips, $arrayZip[1]);
  1195.             if($uavTar->getIdProvince() == $city->getProvince()->getId() && ($uavTar->isAllZip() || in_array($ticket->getZip(), $zips))){
  1196.                 $uavTariff = $uavTar;
  1197.                 break;
  1198.             }
  1199.         }
  1200.         
  1201.         if($uavTariff != null){
  1202.             $ticket->setUavOperationTariffAmount($uavTariff->getStandardAmount());
  1203.         }
  1204.         else{
  1205.             $ticket->setSystemError(true);
  1206.             $ticket->setSystemErrorSlug('tariff-uav');
  1207.             $ticket->setSystemErrorDetails("Tariffa UAV per il fornitore non trovata!");
  1208.             $em->flush();
  1209.             return true;
  1210.         }
  1211.         $em->flush();
  1212.     }
  1214.     static public function ticketAutoAssign($em, $emMaster, $user, $ticket, $mailer)
  1215.     {     
  1216.         $autoAssign = $em->getRepository('App\Entity\Slave\Setting')->findOneBySlug('ticket_auto_assign');
  1217.         
  1218.         if($autoAssign->getValue() && $ticket->getTechnician() == null){
  1219.             $technicians = array();
  1220.             $statusAssigned = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'assigned'));
  1221.             $city = $emMaster->getRepository('App\Entity\Master\City')->findOneById($ticket->getIdCity());
  1222.             $techincianAreas = $em->getRepository('App\Entity\Slave\TechnicianArea')->findByIdProvinceAndUserAutoAssignIncluded($city->getProvince()->getId());
  1223.             // Creo un array con i tecnici assegnabili
  1224.             foreach($techincianAreas as $ta){
  1225.                 $zips = array();
  1226.                 foreach($ta->getZips() as $arrayZip)
  1227.                     array_push($zips, $arrayZip[1]);
  1228.                 
  1229.                 $autoAssignSuppliersIds = array();
  1230.                 foreach($ta->getUser()->getAutoAssignSuppliers() as $supplier)
  1231.                     array_push($autoAssignSuppliersIds, $supplier->getId());
  1233.                 // SE tecnico gestisce quei fornitori E copre tutta l'area O il CAP del cliente ---> pusho nell'array
  1234.                 if(in_array($ticket->getOperation()->getSupplier()->getId(), $autoAssignSuppliersIds) && ($ta->isAllZip() || in_array($ticket->getZip(), $zips)))
  1235.                     array_push($technicians, $ta->getUser());
  1236.             }
  1238.             if(sizeof($technicians) > 0){
  1239.                 TicketService::createTicketLog($em, $user, $ticket, "cs", $ticket->getStatus(), $statusAssigned->getValue());
  1240.                 $ticket->setStatus($statusAssigned);
  1241.                 if(sizeof($technicians) == 1){
  1242.                     // Se c'è solo un tecnico --- Se non è in ferie lo assegno altrimenti assegno il sostituto
  1243.                     if($technicians[0]->getActualHoliday() == false){
  1244.                         $ticket->setTechnician($technicians[0]);
  1245.                         TicketService::createTicketLog($em, $user, $ticket, "ct", $ticket->getTechnician(), $technicians[0]);
  1246.                     }
  1247.                     else{
  1248.                         TicketService::createTicketLog($em, $user, $ticket, "ct", $ticket->getTechnician(), $technicians[0]->getActualHoliday()->getSubstitute());
  1249.                         $ticket->setTechnician($technicians[0]->getActualHoliday()->getSubstitute());
  1250.                     }
  1251.                 }
  1252.                 else{
  1253.                     // Scremo i tecnici che sono in ferie
  1254.                     $techs = array();
  1255.                     foreach($technicians as $technician){
  1256.                         if($technician->getActualHoliday() == false)
  1257.                             array_push($techs, $technician);
  1258.                     }
  1259.                     if(sizeof($techs) > 0){
  1260.                         if(sizeof($techs) == 1){
  1261.                             $technician = $techs[0];
  1262.                         }
  1263.                         else{
  1264.                             $first = true;
  1265.                             foreach($techs as $t){
  1266.                                 if($first){
  1267.                                     $first = false;
  1268.                                     $technician = $t;
  1269.                                 }
  1270.                                 if($technician->countTicketsUnderManagement('actual') > $t->countTicketsUnderManagement('actual'))
  1271.                                     $technician = $t;
  1272.                             }
  1273.                         }
  1274.                         TicketService::createTicketLog($em, $user, $ticket, "ct", $ticket->getTechnician(), $technician);
  1275.                         $ticket->setTechnician($technician);
  1276.                     }
  1277.                 }
  1278.             }
  1279.             
  1280.             $em->flush();
  1281.             
  1282.             // Invio messaggio di notifica al tecnico
  1283.             $settingTechnicianSendAssignEmail = $em->getRepository('App\Entity\Slave\Setting')->findOneBy(array('slug' => 'ticket_technician_send_assign_email'));
  1284.             if($settingTechnicianSendAssignEmail->getValue() == 1 && $ticket->getTechnician()->isAssignEmailActive()){
  1285.                 $tickets = [];
  1286.                 array_push($tickets, $ticket);
  1287.                 $message = (new TemplatedEmail())
  1288.                     ->subject($this->params->get('subject_ticket_take_charge'))
  1289.                     ->from($this->params->get('email_noreply'))
  1290.                     ->to($ticket->getTechnician()->getEmail())
  1291.                     ->htmlTemplate('email/technician_tickets.html.twig')
  1292.                     ->context(['user' => $ticket->getTechnician(), 'tickets' => $tickets]);
  1293.                 $mailer->send($message);
  1294.             }
  1296.         }
  1297.         return true;
  1298.     }
  1300.     // SCARICA DA EMAIL
  1301.     static public function downloadTicket($em, $emMaster, $user, $inbox, $email, $mailer, $testing, $company, $countTicket, $countTicketError)
  1302.     {
  1303.         $header = imap_headerinfo($inbox, $email); // Gestisco l'header
  1304.         $sender = null;
  1305.         
  1306.         // Serve per skippare le email che non hanno mittente o di spam
  1307.         if(property_exists($header, 'from') && property_exists($header->from[0], 'host'))
  1308.             $sender = $header->from[0]->mailbox."@".$header->from[0]->host;
  1310.         $supplierTicketEmails = $em->getRepository('App\Entity\Slave\SupplierTicketEmail')->findBySenderAndMailer($sender, $mailer);
  1312.         [$supplier, $tickets] = TicketService::importTickets($em, $emMaster, $user, $inbox, $email, $header, $supplierTicketEmails);
  1314.         $now = new \DateTime();
  1315.         if(!$testing){
  1316.             if($tickets != null){
  1317.                 // Se ha creato ticket -> Segno email vista e sposto nella cartella fornitore
  1318.                 imap_setflag_full($inbox, $email, "\\SEEN");
  1319.                 if($supplier != null)
  1320.                     imap_mail_move($inbox, $email, 'INBOX.'.$supplier->getSlug());
  1321.                 else
  1322.                     imap_mail_move($inbox, $email, 'INBOX.nexi');
  1323.                 $countTicket++;
  1324.             }
  1325.             else{
  1326.                 $dt = explode(', ', $header->date); // Prendo la data di creazione
  1327.                 $dts = explode(' (', $dt[sizeof($dt) - 1]); // Pulisco mettendo il formato per il create_date_from_format
  1328.                 $dtsTrim = rtrim(ltrim($dts[0]));
  1329.                 $datetimeStart = date_create_from_format('j M Y H:i:s O', $dtsTrim); //4 Jul 2023 16:00:11 +0200"
  1330.                 $threeHours = date_modify(clone($datetimeStart), "+3 hours");
  1331.                 // Se non ha creato ticket -> Controllo se è lì da più di 3 ore la sposto in "other"
  1332.                 if($threeHours->format("YmdHis") < $now->format("YmdHis"))
  1333.                     imap_mail_move($inbox, $email, 'INBOX.other');
  1334.             }
  1335.         }
  1336.         else{
  1337.             if($tickets != null)
  1338.                 $countTicket++;
  1339.         }
  1341.         foreach($tickets as $ticket){
  1342.             if($ticket->getOperation() != null){
  1343.                 $error = TicketService::ticketMapClient($em, $ticket);
  1344.                 if(!$error) $error = TicketService::ticketMapColumns($em, $emMaster, $company, $ticket);
  1345.                 if(!$error) $error = TicketService::ticketAssignOperationTariffAmount($em, $emMaster, $ticket);
  1346.                 if(!$error) TicketService::ticketAutoAssign($em, $emMaster, $user, $ticket, $mailer);
  1347.             }
  1348.             else{
  1349.                 $error = true;
  1350.                 if($supplier != null){
  1351.                     $ticket->setSystemError(true);
  1352.                     $ticket->setSystemErrorSlug('operation');
  1353.                     $ticket->setSystemErrorDetails("Impossibile determinare l'<b>operazione</b> del ticket");
  1354.                     $em->flush();
  1355.                 }
  1356.             }
  1357.             if($error)
  1358.                 $countTicketError++;
  1359.         }
  1360.         return [$countTicket, $countTicketError];
  1361.     }
  1363.     // IMPORT CSV
  1364.     // Chiamata da UserTicketController
  1365.     static public function importFile($em, $emMaster, $user, $form, $company, $operationId, $row, $mailer)
  1366.     {
  1367.         $supplierSlug = $form->get('supplier')->getData();
  1368.         $file = $form->get('file')->getData();
  1369.         $separator = $form->get('separator')->getData();
  1371.         $tickets = array();
  1372.         $arrayNumberTermids = array();
  1373.         $countInserted = 0;
  1374.         $content = file_get_contents($file);
  1375.         $content = preg_replace('/\\\\/', '/', $content);
  1376.         switch($supplierSlug){
  1377.             case 'demis-adp':
  1378.             case 'bcc-pos':
  1379.             case 'lis-holding':
  1380.             case 'nexi':
  1381.             case 'nexi-book-sia':
  1382.             case 'worldline-italia':
  1383.             case 'worldline-ccb':
  1384.                 $content = preg_replace('/,,/', ',"",', $content);
  1385.                 $content = preg_replace('/\",\"/', '";"', $content);
  1386.                 $separator = ";";
  1387.                 break;
  1388.             case 'fabrick':
  1389.             case 'sate':
  1390.                 break;
  1391.             default: break;
  1392.         }
  1393.         file_put_contents($file, $content);
  1395.         if(($handle = fopen($file, "r")) !== FALSE) {
  1397.             while(($data = fgetcsv($handle, 5000, $separator)) !== FALSE) {
  1398.                 // Data
  1399.                 switch($supplierSlug){
  1400.                     case 'bcc-pos':
  1401.                     case 'fabrick':
  1402.                     case 'lis-holding':
  1403.                     case 'nexi':
  1404.                     case 'sate':
  1405.                     case 'worldline-italia':
  1406.                     case 'worldline-ccb':
  1407.                         $dataEncoded = array_map("utf8_encode", $data);
  1408.                         break;
  1409.                     case 'demis-adp':
  1410.                     case 'nexi-book-sia':
  1411.                         $dataEncoded = $data;
  1412.                         break;
  1413.                     default: break;
  1414.                 }
  1416.                 if($row == 0){
  1417.                     $keys = TicketService::importFileGetKeys($dataEncoded);
  1418.                 }
  1419.                 else{                    
  1420.                     switch($supplierSlug){
  1421.                         case 'fabrick': $json = TicketService::importFileCreateJson($dataEncoded, $keys, true); break;
  1422.                         default: $json = TicketService::importFileCreateJson($dataEncoded, $keys, false); break;
  1423.                     }
  1425.                     // Supplier
  1426.                     switch($supplierSlug){
  1427.                         case 'demis-adp':
  1428.                         case 'bcc-pos':
  1429.                         case 'fabrick':
  1430.                         case 'lis-holding':
  1431.                         case 'nexi-book-sia':
  1432.                             $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => $supplierSlug));
  1433.                             break;
  1434.                         case 'nexi':
  1435.                         case 'sate':
  1436.                         case 'worldline':
  1437.                         case 'worldline-italia':
  1438.                         case 'worldline-ccb':
  1439.                             $supplierIdentifier = TicketService::importFileFindSupplier($em, $supplierSlug, $json);
  1440.                             switch($supplierIdentifier){
  1441.                                 case "Meps": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-meps')); break;
  1442.                                 case "Monetica": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-monetica')); break;
  1443.                                 case "CCB": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'worldline-ccb')); break;
  1444.                                 case "Normal": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'worldline-italia')); break;
  1445.                                 case "Sate-Argentea": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---argentea')); break;
  1446.                                 case "Sate-Flagpay": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---flagpay')); break;
  1447.                                 case "Sate-Mooney": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---mooney')); break;
  1448.                                 case "Sate-Numera": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---numera')); break;
  1449.                                 case "Sate-Pluxee": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---pluxee')); break;
  1450.                                 case "Sate-Worldline": $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'sate---worldline')); break;
  1451.                                 default: break;
  1452.                             }
  1453.                             break;
  1454.                         default: break;
  1455.                     }
  1457.                     // Operation
  1458.                     $operation = null;
  1459.                     switch($supplierSlug){
  1460.                         case 'demis-adp':
  1461.                         case 'bcc-pos':
  1462.                         case 'fabrick':
  1463.                         case 'lis-holding':
  1464.                         case 'nexi': 
  1465.                         case 'sate':
  1466.                         case 'worldline-italia':
  1467.                         case 'worldline-ccb':
  1468.                             $operation = TicketService::importFileDefineOperation($supplier, $keys, $data);
  1469.                             break;
  1470.                         case 'nexi-book-sia':
  1471.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneById($operationId);
  1472.                             break;
  1473.                         default: break;
  1474.                     }
  1475.                     
  1476.                     // Datetime start
  1477.                     $array = json_decode($json, true);
  1478.                     $datetime = null;
  1479.                     $datetimeField = null;
  1480.                     $datetimeFormat = null;
  1482.                     switch($supplierSlug){
  1483.                         case 'bcc-pos':
  1484.                             foreach($array as $val){
  1485.                                 if(array_key_exists('DataScheda', $val)) $date = $val['DataScheda'];
  1486.                                 if(array_key_exists('Dataordine', $val)) $date = $val['Dataordine'];
  1487.                                 if(array_key_exists('Ora Ordine', $val)) $time = $val['Ora Ordine'];
  1488.                             }
  1489.                             $datetime = $date." ".$time;
  1490.                             $datetimeFormat = 'dmY Hi';
  1491.                             break;
  1492.                         case 'fabrick':
  1493.                             $datetimeField = 'Data creazione';
  1494.                             $datetimeFormat = 'd-m-Y H:i:s';
  1495.                             break;
  1496.                         case 'lis-holding':
  1497.                             // MANCA DATA DI RICEZIONE
  1498.                             break;
  1499.                         case 'nexi': 
  1500.                             $datetimeField = 'Data ora assegnazione';
  1501.                             $datetimeFormat = 'd/m/Y H.i';
  1502.                             break;
  1503.                         case 'demis-adp':
  1504.                         case 'worldline-italia':
  1505.                         case 'worldline-ccb':
  1506.                             $datetimeField = 'Data apertura';
  1507.                             $datetimeFormat = 'd/m/Y H:i';
  1508.                             break;
  1509.                         case 'nexi-book-sia':
  1510.                             $datetimeField = 'sys_created_on';
  1511.                             $datetimeFormat = 'd-m-Y H:i:s';
  1512.                             break;
  1513.                         case 'sate':
  1514.                             $datetimeField = 'Data apertura';
  1515.                             $datetimeFormat = 'd/m/Y H:i:s';
  1516.                             break;
  1517.                         default: break;
  1518.                     }
  1520.                     if($datetime == null){
  1521.                         foreach($array as $val){
  1522.                             if(array_key_exists($datetimeField, $val))
  1523.                                 $datetime = $val[$datetimeField];
  1524.                         }
  1525.                     }
  1526.                     $datetimeStart = date_create_from_format($datetimeFormat, $datetime);
  1527.                     [$tickets, $arrayNumberTermids] = TicketService::importFileCreateTicket($em, $user, $tickets, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  1528.                 }
  1529.                 $row++;
  1530.             }
  1532.             fclose($handle);
  1533.         }
  1535.         $error = false;
  1536.         foreach($tickets as $ticket){
  1537.             //QUESTO IF SERVE PERCHE' IL CONTROLLO DEI DOPPIONI SE ESISTE RITORNA COMUNQUE UN TICKET NULL
  1538.             if($ticket != null){
  1539.                 if($ticket->getOperation() != null){
  1540.                     $error = TicketService::ticketMapClient($em, $ticket);
  1541.                     if(!$error) $error = TicketService::ticketMapColumns($em, $emMaster, $company, $ticket);
  1542.                     if(!$error) TicketService::ticketAssignOperationTariffAmount($em, $emMaster, $ticket);
  1543.                     if(!$error) TicketService::ticketAutoAssign($em, $emMaster, $user, $ticket, $mailer);
  1544.                 }
  1545.                 else{
  1546.                     $error = true;
  1547.                     if($supplier != null){
  1548.                         $ticket->setSystemError(true);
  1549.                         $ticket->setSystemErrorSlug('operation');
  1550.                         $ticket->setSystemErrorDetails("Impossibile determinare l'<b>operazione</b> del ticket");
  1551.                         $em->flush();
  1552.                     }
  1553.                 }
  1554.                 $countInserted++;
  1555.             }
  1556.         }
  1557.         return [$error, $row, $countInserted];
  1558.     }
  1560.     static public function importFileCSC($em, $emMaster, $user, $form, $error, $row, $countInserted, $mailer)
  1561.     {        
  1562.         $arrayNumberTermids = [];
  1563.         
  1564.         if(($handle = fopen($form->get('file')->getData(), "r")) !== FALSE) {
  1565.             while(($data = fgetcsv($handle, 2000, $form->get('separator')->getData())) !== FALSE) {
  1566.                 if($row == 0){
  1567.                     $data = preg_replace("/à/", "a", $data);
  1568.                     $keys = TicketService::importFileGetKeys(array_map("utf8_encode", $data));
  1569.                 }
  1570.                 else{
  1571.                     $json = TicketService::importFileCreateJson(array_map("utf8_encode", $data), $keys, false);
  1572.                     $array = json_decode($json, true);
  1573.                     $supplier = null;
  1574.                     $supOpPrefix = null;
  1576.                     switch(strtolower($array[10]['Cliente'])){
  1577.                         case 'c global': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cglobal')); $supOpPrefix = 'csc_cglobal'; break;
  1578.                         case 'c-global spa': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cglobal')); $supOpPrefix = 'csc_cglobal'; break;
  1579.                         case 'stripe': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---stripe')); $supOpPrefix = 'csc_stripe'; break;
  1580.                         case 'cronos': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cronos')); $supOpPrefix = 'csc_cronos'; break;
  1581.                         case 'cronos s.r.l.': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cronos')); $supOpPrefix = 'csc_cronos'; break;
  1582.                         case 'c.s.e. centro servizi elettronici': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cse')); $supOpPrefix = 'csc_cse'; break;
  1583.                         case 'decathlon italia s.r.l': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---decathlon')); $supOpPrefix = 'csc_decathlon'; break;
  1584.                         case 'euronet': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---euronet')); $supOpPrefix = 'csc_euronet'; break;
  1585.                         case 'get your bill': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---get-your-bill')); $supOpPrefix = 'csc_euronet'; break;
  1586.                         case 'lis pay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---lis-pay')); $supOpPrefix = 'csc_lis_pay'; break;
  1587.                         case 'lis poste pay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---lispostepay')); $supOpPrefix = 'csc_lis_poste_pay'; break;
  1588.                         case 'numera sist. e inform. spa':  $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---numera')); $supOpPrefix = 'csc_numera'; break;
  1589.                         case 'q8': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---q8')); $supOpPrefix = 'csc_q8'; break;
  1590.                         case 'pay distribution-yamamay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---yamamay')); $supOpPrefix = 'csc_yamamay'; break;
  1591.                         case 'nexi payments s.p.a.': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---nexi-book-monetica')); $supOpPrefix = 'csc_nexi_book_monetica'; break;
  1592.                         case 'p4cards': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---p4cards')); $supOpPrefix = 'csc_p4cards'; break;
  1593.                         case 'repas': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---repas')); $supOpPrefix = 'csc_repas'; break;
  1594.                         default: break;
  1595.                     }
  1597.                     $operation = null;
  1598.                     switch(strtolower($array[24]['Tipo int.'])){
  1599.                         case 'assistenza':
  1600.                         case 'intervento tecnico':
  1601.                         case 'intervento tecnico premium':
  1602.                         case 'intervento tecnico - upgrade pos':
  1603.                         case 'ritorno x intervento errato':
  1604.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_maintenance'));
  1605.                             break;
  1606.                         case 'migrazione':
  1607.                         case 'sostituzione massiva':
  1608.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_massive'));
  1609.                             break;
  1610.                         case 'disinstallazione':
  1611.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_uninstallation'));
  1612.                             break;
  1613.                         case 'installazione pos':
  1614.                         case 'installazione ordinaria':
  1615.                         case 'Installazione pos Urgente':
  1616.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_installation'));
  1617.                             break;
  1618.                         case 'sostituzione':
  1619.                         case 'sostituzione terminale':
  1620.                         case 'reinst/riconfig terminale':
  1621.                         case 'sost pos (no rientro pos old)':
  1622.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_replacement'));
  1623.                             break;
  1624.                         default: break;
  1625.                     }
  1626.                     
  1627.                     $technician = null;
  1628.                     switch(strtolower($array[18]['Tecnico Assegnatario'])){
  1629.                         case 'biondist': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'stefanobiondi71@gmail.com')); break;
  1630.                         case 'butialb': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'alberto.buti@stsolution.biz')); break;
  1631.                         case 'centroufficioelba': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'cuelba@elba2000.it')); break;
  1632.                         case 'chellis': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'chelli.simone@gmail.com')); break;
  1633.                         case 'delbiancogiulio': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'giulio.delbianco@stsolution.biz')); break;
  1634.                         case 'gemolimirko': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'mirko.gemoli@stsolution.biz')); break;
  1635.                         case 'iavernarogianluca': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'gianluca.iavernaro@stsolution.biz')); break;
  1636.                         case 'lippiluca': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'luca.lippi@stsolution.biz')); break;
  1637.                         case 'loriniandrea': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'andrea.lorini@stsolution.biz')); break;
  1638.                         case 'marinof': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'francesco.marino@stsolution.biz')); break;
  1639.                         case 'speedyline': $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'speedylineservice@gmail.com')); break;
  1640.                         case 'toscana01':
  1641.                         case 'zelonimanuel':
  1642.                             $technician = $em->getRepository('App\Entity\Slave\User')->findOneBy(array('email' => 'diessesrl@eposmanager.software'));
  1643.                             break;
  1644.                         default: break;
  1645.                     }
  1647.                     [$ticketAlreadyExist, $arrayNumberTermids] = TicketService::checkTicketExistanceCsv($em, $json, $array[1]['ID intervento cliente'], $array[8]['Termid'], $arrayNumberTermids);
  1648.                     if(!$ticketAlreadyExist){
  1649.                         
  1650.                         $countInserted++;
  1651.                         $today = new \Datetime();
  1652.                         $datetimeStart = date_create_from_format('d/m/Y H:i', $array[2]['D/O Ricezione']);
  1653.                         $datetimeExpiration = date_create_from_format('d/m/Y H:i', $array[4]['D/O Scadenza']);
  1654.                         $datetimeEnd = date_create_from_format('d/m/Y H:i', $array[6]['Data/ora chiusura']);
  1655.                         $province = $emMaster->getRepository('App\Entity\Master\Province')->findOneBy(array('sign' => $array[17]['Prov']));
  1656.                         $city = $emMaster->getRepository('App\Entity\Master\City')->findByNameOrAliasAndProvince($array[16]['Localita'], $province->getId());
  1657.                         $jsonReport = '[{"ABI":'.json_encode($array[11]['ABI Rif.']).'}, {"Matricole":'.json_encode($array[22]['Matricola']).'}, {"Anomalia":'.json_encode($array[26]['Anomalia']).'}]';
  1659.                         $termid = $em->getRepository('App\Entity\Slave\Termid')->findOneByCode($array[8]['Termid']);
  1660.                         if($termid == null){
  1661.                             $termid = new Termid();
  1662.                             $termid->setCode($array[8]['Termid']);
  1663.                             $em->persist($termid);
  1664.                         }
  1666.                         $client = $termid->getClient();
  1667.                         if($client == null){
  1668.                             $client = $em->getRepository('App\Entity\Slave\Termid')->findOneByCode($array[9]['SIA']);
  1670.                             if($client == null){
  1671.                                 $client = new Client();
  1672.                                 $client->setCode($array[9]['SIA']);
  1673.                                 $client->setName($array[12]['Rag.Soc.']);
  1674.                                 $client->setNickname($array[13]['Insegna']);
  1675.                                 $client->setAddress($array[14]['Indirizzo']);
  1676.                                 $client->setZip($array[15]['CAP']);
  1677.                                 if($city != null) $client->setIdCity($city->getId());
  1678.                                 $client->setIdProvince($province->getId());
  1679.                                 $em->persist($client);
  1681.                                 $clientPhone = new ClientPhone();
  1682.                                 $clientPhone->setClient($client);
  1683.                                 $clientPhone->setName('Telefono 1');
  1684.                                 $clientPhone->setNumber($array[19]['Tel.']);
  1685.                                 $em->persist($clientPhone);
  1686.                     
  1687.                                 $warehouse = new Warehouse();
  1688.                                 $warehouse->setClient($client);
  1689.                                 $warehouse->setNickname('Magazzino cliente - '.$client->getNickname());
  1690.                                 $warehouse->setMovable(false);
  1691.                                 $client->setWarehouse($warehouse);
  1692.                                 $em->persist($warehouse);
  1693.                             }
  1694.                             
  1695.                             $termid->setClient($client);
  1696.                         }
  1698.                         $ticket = new Ticket();
  1699.                         $ticket->setNumber($array[0]['id scheda']);
  1700.                         $ticket->setSupplier($supplier);
  1701.                         $ticket->setClient($client);
  1702.                         $ticket->setOperation($operation);
  1703.                         $ticket->setTermid($termid);
  1704.                         $ticket->setDatetimeStart($datetimeStart);
  1705.                         $ticket->setDatetimeExpiration($datetimeExpiration);
  1706.                         $ticket->setDatetimeEnd($datetimeEnd);
  1707.                         $ticket->setJson($json);
  1708.                         $ticket->setDirectoryPath($today->format("Y").'/'.$today->format("m").'/'.md5(uniqid()));
  1709.                         $ticket->setJsonReport($jsonReport);
  1710.                         $ticket->setAddress($array[14]['Indirizzo']);
  1711.                         $ticket->setZip($array[15]['CAP']);
  1712.                         if($city != null)
  1713.                             $ticket->setIdCity($city->getId());
  1714.                         else
  1715.                             $ticket->setOtherCity($array[16]['Localita']);
  1716.                         $ticket->setIdProvince($province->getId());
  1717.                         $ticket->setClosedOnPortal(false);
  1718.                         $ticket->setDatetimeImport(new \DateTime());
  1719.                         $array = json_decode($json, true);
  1720.                         for($i=0; $i<sizeof($array); $i++){
  1721.                             if($supplier->getOperationNotBillableCodes() != null && $supplier->getOperationNotBillableCodes() != '' && array_key_exists($supplier->getOperationMapping(), $array[$i]) && preg_match('/'.$supplier->getOperationNotBillableCodes().'/', $array[$i][$supplier->getOperationMapping()]))
  1722.                                 $ticket->setBillable(false);
  1723.                         }
  1724.             
  1725.                         $em->persist($ticket);
  1727.                         TicketService::createTicketLog($em, $user, $ticket, "ct", $ticket->getTechnician(), $technician);
  1728.                         $ticket->setTechnician($technician);
  1729.                         if($technician == null){
  1730.                             $statusToAssign = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'to_assign'));
  1731.                             TicketService::createTicketLog($em, $user, $ticket, "cs", null, $statusToAssign->getValue());
  1732.                             $ticket->setStatus($statusToAssign);
  1733.                         }
  1734.                         else{
  1735.                             $statusAssigned = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'assigned'));
  1736.                             TicketService::createTicketLog($em, $user, $ticket, "cs", null, $statusAssigned->getValue());
  1737.                             $ticket->setStatus($statusAssigned);
  1738.                         }
  1739.                         
  1740.                         $em->flush();
  1741.                         TicketService::ticketAssignOperationTariffAmount($em, $emMaster, $ticket);
  1743.                         // Invio messaggio di notifica al tecnico
  1744.                         $settingTechnicianSendAssignEmail = $em->getRepository('App\Entity\Slave\Setting')->findOneBy(array('slug' => 'ticket_technician_send_assign_email'));
  1745.                         if($settingTechnicianSendAssignEmail->getValue() == 1 && $ticket->getTechnician()->isAssignEmailActive()){
  1746.                             $tickets = [];
  1747.                             array_push($tickets, $ticket);
  1748.                             $message = (new TemplatedEmail())
  1749.                                 ->subject($this->params->get('subject_ticket_take_charge'))
  1750.                                 ->from($this->params->get('email_noreply'))
  1751.                                 ->to($ticket->getTechnician()->getEmail())
  1752.                                 ->htmlTemplate('email/technician_tickets.html.twig')
  1753.                                 ->context(['user' => $ticket->getTechnician(), 'tickets' => $tickets]);
  1754.                             $mailer->send($message);
  1755.                         }
  1756.                     }
  1757.                 }
  1758.                 $row++;
  1759.             }
  1760.         }
  1762.         return [$error, $row, $countInserted];
  1763.     }
  1765.     static public function importFileCSCNew($em, $emMaster, $user, $form, $error, $row, $countInserted, $mailer)
  1766.     {        
  1767.         $arrayNumberTermids = [];
  1768.         
  1769.         if(($handle = fopen($form->get('file')->getData(), "r")) !== FALSE) {
  1770.             while(($data = fgetcsv($handle, 2000, $form->get('separator')->getData())) !== FALSE) {
  1771.                 if($row == 0){
  1772.                     $data = preg_replace("/à/", "a", $data);
  1773.                     $keys = TicketService::importFileGetKeys(array_map("utf8_encode", $data));
  1774.                 }
  1775.                 else{
  1776.                     $json = TicketService::importFileCreateJson(array_map("utf8_encode", $data), $keys, false);
  1777.                     $array = json_decode($json, true);
  1778.                     $supplier = null;
  1779.                     $supOpPrefix = null;
  1781.                     switch(strtolower($array[0]['Cliente'])){
  1782.                         case 'c global': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cglobal')); $supOpPrefix = 'csc_cglobal'; break;
  1783.                         case 'c-global spa': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cglobal')); $supOpPrefix = 'csc_cglobal'; break;
  1784.                         case 'stripe': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---stripe')); $supOpPrefix = 'csc_stripe'; break;
  1785.                         case 'cronos': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cronos')); $supOpPrefix = 'csc_cronos'; break;
  1786.                         case 'cronos s.r.l.': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cronos')); $supOpPrefix = 'csc_cronos'; break;
  1787.                         case 'c.s.e. centro servizi elettronici': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---cse')); $supOpPrefix = 'csc_cse'; break;
  1788.                         case 'decathlon italia s.r.l': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---decathlon')); $supOpPrefix = 'csc_decathlon'; break;
  1789.                         case 'euronet': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---euronet')); $supOpPrefix = 'csc_euronet'; break;
  1790.                         case 'get your bill': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---get-your-bill')); $supOpPrefix = 'csc_euronet'; break;
  1791.                         case 'lis pay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---lis-pay')); $supOpPrefix = 'csc_lis_pay'; break;
  1792.                         case 'lis poste pay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---lispostepay')); $supOpPrefix = 'csc_lis_poste_pay'; break;
  1793.                         case 'numera sist. e inform. spa':  $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---numera')); $supOpPrefix = 'csc_numera'; break;
  1794.                         case 'q8': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---q8')); $supOpPrefix = 'csc_q8'; break;
  1795.                         case 'pay distribution-yamamay': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---yamamay')); $supOpPrefix = 'csc_yamamay'; break;
  1796.                         case 'nexi payments s.p.a.': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---nexi-book-monetica')); $supOpPrefix = 'csc_nexi_book_monetica'; break;
  1797.                         case 'p4cards': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---p4cards')); $supOpPrefix = 'csc_p4cards'; break;
  1798.                         case 'repas': $supplier = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'csc---repas')); $supOpPrefix = 'csc_repas'; break;
  1799.                         default: break;
  1800.                     }
  1802.                     $operation = null;
  1803.                     switch(strtolower($array[1]['Tipo'])){
  1804.                         case 'assistenza':
  1805.                         case 'intervento tecnico':
  1806.                         case 'intervento tecnico premium':
  1807.                         case 'intervento tecnico - upgrade pos':
  1808.                         case 'ritorno x intervento errato':
  1809.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_maintenance'));
  1810.                             break;
  1811.                         case 'migrazione':
  1812.                         case 'sostituzione massiva':
  1813.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_massive'));
  1814.                             break;
  1815.                         case 'disinstallazione':
  1816.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_uninstallation'));
  1817.                             break;
  1818.                         case 'installazione pos':
  1819.                         case 'installazione ordinaria':
  1820.                         case 'Installazione pos Urgente':
  1821.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_installation'));
  1822.                             break;
  1823.                         case 'sostituzione':
  1824.                         case 'sostituzione terminale':
  1825.                         case 'reinst/riconfig terminale':
  1826.                         case 'sost pos (no rientro pos old)':
  1827.                             $operation = $em->getRepository('App\Entity\Slave\Operation')->findOneBy(array('slugMaster' => $supOpPrefix.'_replacement'));
  1828.                             break;
  1829.                         default: break;
  1830.                     }
  1831.                     
  1832.                     $technician = null;
  1834.                     [$ticketAlreadyExist, $arrayNumberTermids] = TicketService::checkTicketExistanceCsv($em, $json, $array[2]['Intervento cliente'], $array[3]['TID'], $arrayNumberTermids);
  1835.                     if(!$ticketAlreadyExist){
  1836.                         
  1837.                         $countInserted++;
  1838.                         $today = new \Datetime();
  1839.                         $datetimeStart = date_create_from_format('d/m/Y H:i:s', $array[8]['Data apertura']);
  1840.                         $datetimeExpiration = date_create_from_format('d/m/Y H:i:s', $array[11]['Data scadenza']);
  1841.                         $province = $emMaster->getRepository('App\Entity\Master\Province')->findOneBy(array('name' => $array[29]['Provincia']));
  1842.                         $city = $emMaster->getRepository('App\Entity\Master\City')->findByNameOrAliasAndProvince($array[31]['Citta'], $province->getId());
  1844.                         $termid = $em->getRepository('App\Entity\Slave\Termid')->findOneByCode($array[3]['TID']);
  1845.                         if($termid == null){
  1846.                             $termid = new Termid();
  1847.                             $termid->setCode($array[3]['TID']);
  1848.                             $em->persist($termid);
  1849.                         }
  1851.                         $client = $termid->getClient();
  1852.                         if($client == null){
  1853.                             $client = new Client();
  1854.                             $client->setCode($array[3]['TID']);
  1855.                             $client->setName($array[5]['Insegna']);
  1856.                             $client->setNickname($array[5]['Insegna']);
  1857.                             $client->setAddress($array[32]['Indirizzo']);
  1858.                             $client->setZip($array[30]['Cap']);
  1859.                             if($city != null) $client->setIdCity($city->getId());
  1860.                             $client->setIdProvince($province->getId());
  1861.                             $em->persist($client);
  1863.                             $clientPhone = new ClientPhone();
  1864.                             $clientPhone->setClient($client);
  1865.                             $clientPhone->setName('Telefono 1');
  1866.                             $clientPhone->setNumber($array[34]['Telefono 1']);
  1867.                             $em->persist($clientPhone);
  1869.                             if($array[35]['Telefono 2'] != "" && $array[35]['Telefono 2'] != '-'){
  1870.                                 $clientPhone = new ClientPhone();
  1871.                                 $clientPhone->setClient($client);
  1872.                                 $clientPhone->setName('Telefono 2');
  1873.                                 $clientPhone->setNumber($array[35]['Telefono 2']);
  1874.                                 $em->persist($clientPhone);
  1875.                             }
  1876.                 
  1877.                             $warehouse = new Warehouse();
  1878.                             $warehouse->setClient($client);
  1879.                             $warehouse->setNickname('Magazzino cliente - '.$client->getNickname());
  1880.                             $warehouse->setMovable(false);
  1881.                             $client->setWarehouse($warehouse);
  1882.                             $em->persist($warehouse);
  1883.                             
  1884.                             $termid->setClient($client);
  1885.                         }
  1887.                         $ticket = new Ticket();
  1888.                         $ticket->setNumber($array[2]['Intervento cliente']);
  1889.                         $ticket->setSupplier($supplier);
  1890.                         $ticket->setClient($client);
  1891.                         $ticket->setOperation($operation);
  1892.                         $ticket->setTermid($termid);
  1893.                         $ticket->setDatetimeStart($datetimeStart);
  1894.                         $ticket->setDatetimeExpiration($datetimeExpiration);
  1895.                         $ticket->setJson($json);
  1896.                         $ticket->setDirectoryPath($today->format("Y").'/'.$today->format("m").'/'.md5(uniqid()));
  1897.                         $ticket->setAddress($array[32]['Indirizzo']);
  1898.                         $ticket->setZip($array[30]['Cap']);
  1899.                         if($city != null)
  1900.                             $ticket->setIdCity($city->getId());
  1901.                         else
  1902.                             $ticket->setOtherCity($array[31]['Citta']);
  1903.                         $ticket->setIdProvince($province->getId());
  1904.                         $ticket->setClosedOnPortal(false);
  1905.                         $ticket->setDatetimeImport(new \DateTime());
  1906.                         $array = json_decode($json, true);
  1907.                         for($i=0; $i<sizeof($array); $i++){
  1908.                             if($supplier->getOperationNotBillableCodes() != null && $supplier->getOperationNotBillableCodes() != '' && array_key_exists($supplier->getOperationMapping(), $array[$i]) && preg_match('/'.$supplier->getOperationNotBillableCodes().'/', $array[$i][$supplier->getOperationMapping()]))
  1909.                                 $ticket->setBillable(false);
  1910.                         }
  1911.             
  1912.                         $em->persist($ticket);
  1914.                         TicketService::createTicketLog($em, $user, $ticket, "ct", $ticket->getTechnician(), $technician);
  1915.                         $ticket->setTechnician($technician);
  1916.                         if($technician == null){
  1917.                             $statusToAssign = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'to_assign'));
  1918.                             TicketService::createTicketLog($em, $user, $ticket, "cs", null, $statusToAssign->getValue());
  1919.                             $ticket->setStatus($statusToAssign);
  1920.                         }
  1921.                         else{
  1922.                             $statusAssigned = $em->getRepository('App\Entity\Slave\TicketStatus')->findOneBy(array('slug' => 'assigned'));
  1923.                             TicketService::createTicketLog($em, $user, $ticket, "cs", null, $statusAssigned->getValue());
  1924.                             $ticket->setStatus($statusAssigned);
  1925.                         }
  1926.                         
  1927.                         $em->flush();
  1928.                         TicketService::ticketAssignOperationTariffAmount($em, $emMaster, $ticket);
  1930.                         // Invio messaggio di notifica al tecnico
  1931.                         $settingTechnicianSendAssignEmail = $em->getRepository('App\Entity\Slave\Setting')->findOneBy(array('slug' => 'ticket_technician_send_assign_email'));
  1932.                         if($settingTechnicianSendAssignEmail->getValue() == 1 && $ticket->getTechnician()->isAssignEmailActive()){
  1933.                             $tickets = [];
  1934.                             array_push($tickets, $ticket);
  1935.                             $message = (new TemplatedEmail())
  1936.                                 ->subject($this->params->get('subject_ticket_take_charge'))
  1937.                                 ->from($this->params->get('email_noreply'))
  1938.                                 ->to($ticket->getTechnician()->getEmail())
  1939.                                 ->htmlTemplate('email/technician_tickets.html.twig')
  1940.                                 ->context(['user' => $ticket->getTechnician(), 'tickets' => $tickets]);
  1941.                             $mailer->send($message);
  1942.                         }
  1943.                     }
  1944.                 }
  1945.                 $row++;
  1946.             }
  1947.         }
  1949.         return [$error, $row, $countInserted];
  1950.     }
  1952.     // Funzioni di gestione
  1953.     static public function importFileGetKeys($data)
  1954.     {
  1955.         $keys = array();
  1956.         foreach($data as $d)
  1957.             array_push($keys, $d);
  1958.         return $keys;
  1959.     }
  1961.     static public function importFileCreateJson($data, $keys, $utf8Decode)
  1962.     {
  1963.         $first = true;
  1964.         $json = '[';
  1965.         for($i = 0; $i < sizeof($data); $i++){
  1966.             if($utf8Decode)
  1967.                 $keys[$i] = utf8_decode($keys[$i]);
  1968.             [$json, $first] = TicketService::addToJson($json, $first, $keys[$i], $data[$i]);
  1969.         }
  1970.         $json.= ']';
  1971.         return $json;
  1972.     }
  1974.     static public function importFileFindSupplier($em, $supplierType, $json)
  1975.     {
  1976.         $identifier = null;
  1977.         switch($supplierType){
  1978.             case 'nexi':
  1979.                 $supplierMonetica = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-monetica'));
  1980.                 $supplierMeps = $em->getRepository('App\Entity\Slave\Supplier')->findOneBy(array('slug' => 'nexi-book-meps'));
  1981.                 $identifier = TicketService::nexiSupplierSearch($supplierMonetica, $json);
  1982.                 if($identifier == null)
  1983.                     $identifier = TicketService::nexiSupplierSearch($supplierMeps, $json);
  1984.                 break;
  1985.             case 'demis-adp':
  1986.             case 'worldline':
  1987.             case 'worldline-italia':
  1988.             case 'worldline-ccb':
  1989.                 $identifier = TicketService::worldlineSupplierSearch('import', $json);
  1990.                 break;
  1991.             case 'sate':
  1992.                 $identifier = TicketService::sateSupplierSearch('import', $json);
  1993.                 break;
  1994.             default: break;
  1995.         }
  1996.         return $identifier;
  1997.     }
  1999.     static public function importFileDefineOperation($supplier, $keys, $data)
  2000.     {
  2001.         $index = null;
  2002.         $operation = null;
  2003.         for($k = 0; $k < sizeof($keys); $k++){
  2004.             $keys[$k] = preg_replace("/\"/","", $keys[$k]);
  2005.             $keys[$k] = preg_replace("//","", $keys[$k]);
  2006.             if(rtrim(ltrim(strtolower($keys[$k]), '"'), '"') == strtolower($supplier->getOperationMapping())){
  2007.                 $index = $k;
  2008.                 break;
  2009.             }
  2010.         }
  2011.         if($index !== null){
  2012.             foreach($supplier->getOperations() as $op){
  2013.                 if(!$op->isUav() && $op->getIdentifierRegex() != null){
  2014.                     if(preg_match('/'.$op->getIdentifierRegex().'/', $data[$index])){
  2015.                         $operation = $op;
  2016.                         break;
  2017.                     }
  2018.                 }
  2019.             }
  2020.         }
  2021.         return $operation;
  2022.     }
  2024.     static public function importFileCreateTicket($em, $user, $tickets, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids)
  2025.     {
  2026.         [$ticket, $arrayNumberTermids] = TicketService::createTicket($em, $user, $supplier, $operation, $datetimeStart, $json, $arrayNumberTermids);
  2027.         if($ticket != null && $operation == null){
  2028.             $ticket->setSystemError(true);
  2029.             $ticket->setSystemErrorSlug('key_mapping');
  2030.             $ticket->setSystemErrorDetails("Non esiste la chiave \"".$supplier->getOperationMapping()."\" nei dettagli del ticket");
  2031.             $em->flush();
  2032.         }
  2033.         if($ticket != null)
  2034.             array_push($tickets, $ticket);
  2035.         return [$tickets, $arrayNumberTermids];
  2036.     }
  2038.     static public function createTicketLog($em, $user, $ticket, $action, $oldValue, $newValue)
  2039.     {
  2040.         $persist = false;
  2041.         switch($action){
  2042.             case 'cs':
  2043.                 if(($oldValue != null && $oldValue->getValue() != $newValue) || ($oldValue == null && $newValue != null))
  2044.                     $persist = true;
  2045.                 break;
  2046.             case 'ct':
  2047.                 if(($oldValue != null && $newValue != null && $oldValue->__toString() != $newValue->__toString()) || ($oldValue == null && $newValue != null) || ($oldValue != null && $newValue == null))
  2048.                     $persist = true;
  2049.                 break;
  2050.             default: break;
  2051.         }
  2052.         if($persist){
  2053.             $ticketLog = new TicketLog();
  2054.             $ticketLog->setTicket($ticket);
  2055.             $ticketLog->setDatetime(new \Datetime());
  2056.             $ticketLog->setAction($action);
  2057.             if($user != null)
  2058.                 $ticketLog->setOperator($user->__toString());
  2059.             else
  2060.                 $ticketLog->setOperator('Script');
  2061.             switch($action){
  2062.                 case 'cs':
  2063.                     if($oldValue == null) $oldValue = "Nessuno"; else $oldValue = $oldValue->getValue();
  2064.                     if($newValue == null) $newValue = "Nessuno";
  2065.                     $ticketLog->setOldValue($oldValue);
  2066.                     $ticketLog->setNewValue($newValue);
  2067.                     break;
  2068.                 case 'ct':
  2069.                     if($oldValue == null) $oldValue = "Nessuno"; else $oldValue = $oldValue->__toString();
  2070.                     if($newValue == null) $newValue = "Nessuno"; else $newValue = $newValue->__toString();
  2071.                     $ticketLog->setOldValue($oldValue);
  2072.                     $ticketLog->setNewValue($newValue);
  2073.                     break;
  2074.                 default: break;
  2075.             }
  2076.             $em->persist($ticketLog);
  2077.             
  2078.             $em->flush($ticketLog);
  2079.         }
  2080.     }
  2081. }