src/Controller/PistolettateController.php line 131

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\AdUser;
  6. use App\Utils\Breadcrumbs;
  7. use DateTime;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use FilesystemIterator;
  11. use RecursiveIteratorIterator;
  12. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  13. use Symfony\Component\Filesystem\Exception\IOExceptionInterface;
  14. use Symfony\Component\Filesystem\Filesystem;
  15. use Symfony\Component\Filesystem\Path;
  16. use Symfony\Component\Finder\Iterator\RecursiveDirectoryIterator;
  17. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  18. use Symfony\Component\HttpFoundation\File\Stream;
  19. use Symfony\Component\HttpFoundation\JsonResponse;
  20. use Symfony\Component\Routing\Annotation\Route;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use App\Entity\CooPfPistolettate;
  23. use App\Entity\CooPfColli;
  24. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Security;
  25. use Sensio\Bundle\FrameworkExtraBundle\Configuration\IsGranted;
  26. use Symfony\Component\HttpFoundation\Response;
  27. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
  28. use PHPJasper\PHPJasper;
  29. use Nelmio\ApiDocBundle\Annotation\Model;
  30. use Symfony\Component\HttpFoundation\RequestStack;
  31. use OpenApi\Annotations as OA;
  32. use Symfony\Component\Security\Core\Authentication\Token\Storage\UsageTrackingTokenStorage;
  33. use ZipArchive;
  35. class PistolettateController extends AbstractController
  36. {
  38.     private $em;
  39.     private $requestStack;
  40.     private $jsonResponse;
  42.     public function __construct(EntityManagerInterface $entityManager, RequestStack $requestStack)
  43.     {
  44.         $this->requestStack = $requestStack;
  45.         $this->em = $entityManager;
  46.     }
  48.     /**
  49.      * Elenco postazioni.
  50.      *
  51.      * Ritorna la lista delle postazioni
  52.      *
  53.      * @IsGranted("ROLE_USER")
  54.      * @Route("/api/postazioni", methods="GET", options={"expose"=true})
  55.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  56.      * @OA\Response(response=200, description="Ritorna l'elenco delle postazioni.")
  57.      *
  58.      */
  59.     public function postazioniList(Request $request, ManagerRegistry $doctrine)
  60.     {
  61.         $elenco = [];
  63.         $db = $this->getDatabase($request);
  64.         $stabilimento = $this->getStabilimento($request);
  65.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  66.         if ($db === false) {
  67.             return $this->jsonResponse;
  68.         }
  71.         $postazioni = $doctrine->getRepository('App:CooPfPostazioni', $db)->findBy(['isactive' => 'Y', 'cooStabilimentoId' => $stabilimento], ['line' => 'asc']);
  73.         //$postazioni = $doctrine->getRepository('App:CooPfPostazioni', $db)->findBy(['isactive' => 'Y'], ['line' => 'asc']);
  74.         if ($postazioni) {
  75.             foreach ($postazioni as $postazione) {
  76.                 $data = $postazione->serialize();
  77.                 $elenco[] = $data;
  78.             }
  79.         }
  80.         return new JsonResponse(['totale' => count($elenco), 'elenco' => $elenco]);
  81.     }
  83.     /**
  84.      * Elenco non conformità.
  85.      *
  86.      * Ritorna la lista delle non conformità
  87.      *
  88.      * @IsGranted("ROLE_USER")
  89.      * @Route("/api/non-conformita", methods="GET", options={"expose"=true})
  90.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  91.      * @OA\Response(response=200, description="Ritorna l'elenco delle non conformità.")
  92.      *
  93.      */
  94.     public function ncList(Request $request, ManagerRegistry $doctrine)
  95.     {
  96.         $elenco = [];
  98.         $db = $this->getDatabase($request);
  99.         $stabilimento = $this->getStabilimento($request);
  100.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  101.         if ($db === false) {
  102.             return $this->jsonResponse;
  103.         }
  106.         $ncs = $doctrine->getRepository('App:CooPfNctypetab', $db)->findBy(['isactive' => 'Y'], ['name' => 'asc']);
  108.         if ($ncs) {
  109.             foreach ($ncs as $nc) {
  110.                 $data = [
  111.                     'id' => $nc->getCooPfNctypetabId(),
  112.                     'name' => $nc->getName()
  113.                 ];
  114.                 $elenco[] = $data;
  115.             }
  116.         }
  117.         return new JsonResponse(['totale' => count($elenco), 'elenco' => $elenco]);
  118.     }
  120.     /**
  121.      * Elenco lavorazioni.
  122.      *
  123.      * Ritorna la lista delle lavorazioni
  124.      *
  125.      * @IsGranted("ROLE_USER")
  126.      * @Route("/api/lavorazioni/{postazione_id}", methods="GET", options={"expose"=true})
  127.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  128.      * @OA\Response(response=200, description="Ritorna l'elenco delle lavorazioni.")
  129.      *
  130.      */
  131.     public function lavorazioniList(int $postazione_id, Request $request, ManagerRegistry $doctrine)
  132.     {
  133.     set_time_limit(60);
  134.     ini_set( 'memory_limit', '2048M' );
  135.     $db = $this->getDatabase($request);
  136.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  137.         if ($db === false) {
  138.             return $this->jsonResponse;
  139.         }
  141.         $postazione = $doctrine->getRepository('App:CooPfPostazioni', $db)->find($postazione_id);
  143.         $pistolettate = $doctrine->getRepository('App:CooPfPistolettate', $db)->pistolettateLineaStato($postazione);
  145.         $elenco = [];
  146.         $elenco_nomi = [];
  147.         $elenco_postazioni_attuali = [];
  148.         if (isset($pistolettate)) {
  149.             $vecchiaData = null;
  150.             foreach ($pistolettate as $pistolettata) {
  151.                 //$pistolettata = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($pistolettata_id['coo_pf_pistolettate_id']);
  152.                 $name = $pistolettata->getName();
  154.                 if (!in_array($name, array_keys($elenco_postazioni_attuali))) {
  155.                     $elenco_postazioni_attuali[$name] = $pistolettata;
  156.                 }
  158.                 if (isset($elenco_postazioni_attuali[$name]) && $pistolettata->getPostazione() && $postazione && ($pistolettata->getPostazione()->getCooPfPostazioniId() == $postazione->getCooPfPostazioniId())) {
  159.                     $data = $pistolettata->serialize();
  160.                     $et = $pistolettata->getCooPfEventType();
  162.                     $p_att = $pistolettata->getPostazione()->getCooPfPostazioniId();
  163.                     if (($elenco_postazioni_attuali[$name])->getPostazione()->getCooPfPostazioniId() == $p_att) {
  164.                         if (!in_array($name, array_keys($elenco_nomi)) && !isset($elenco[$et][$name])) {
  165.                             if (!isset($elenco[$et])) {
  166.                                 $elenco[$et] = [];
  167.                             }
  168.                             $elenco[$et][$name] = [];
  169.                             $elenco_nomi[$name] = $et;
  170.                             $minutes = 0;
  171.                         } else {
  172.                             $attualeData = $pistolettata->getDataLettura();
  173.                             $interval = $attualeData->diff($vecchiaData);
  174.                             $minutes = $interval->format('%i');
  175.                         }
  176.                         $vecchiaData = $pistolettata->getDataLettura();
  177.                         $data['duration'] = $minutes;
  178.                         $elenco[$elenco_nomi[$name]][$name][] = $data;
  179.                     }
  180.                 }
  181.             }
  182.         }
  184.         return new JsonResponse(['elenco' => $elenco]);
  185.     }
  187.     /**
  188.      * Dettaglio lavorazione.
  189.      *
  190.      * Ritorna i dati della lavorazione
  191.      *
  192.      * @IsGranted("ROLE_USER")
  193.      * @Route("/api/lavorazione/{coo_pf_pistolettate_id}", methods="GET", options={"expose"=true})
  194.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  195.      * @OA\Response(response=200, description="Ritorna la lavorazione.")
  196.      *
  197.      */
  198.     public function lavorazioneDetails(int $coo_pf_pistolettate_id, Request $request, ManagerRegistry $doctrine)
  199.     {
  200.         $db = $this->getDatabase($request);
  201.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  202.         if ($db === false) {
  203.             return $this->jsonResponse;
  204.         }
  206.         $pistolettata = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($coo_pf_pistolettate_id);
  208.         return new JsonResponse($pistolettata->serialize(true));
  209.     }
  211.     /**
  212.      * Stop lavorazione.
  213.      *
  214.      * Ferma la lavorazione
  215.      *
  216.      * @IsGranted("ROLE_USER")
  217.      * @Route("/api/stop-lavorazione", methods="POST", options={"expose"=true})
  218.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  219.      * @OA\RequestBody(@OA\JsonContent(type="object", example={"coo_pf_pistolettate_id":""}))
  220.      * @OA\Response(response=200, description="Ritorna la lavorazione.")
  221.      *
  222.      */
  223.     public function lavorazioneStop(Request $request, ManagerRegistry $doctrine)
  224.     {
  225.         $data = json_decode($request->getContent(), true);
  226.         $coo_pf_pistolettate_id = isset($data['coo_pf_pistolettate_id']) ? $data['coo_pf_pistolettate_id'] : null;
  227.         $db = $this->getDatabase($request);
  228.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  229.         if ($db === false) {
  230.             return $this->jsonResponse;
  231.         }
  233.         $pistolettataOld = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($coo_pf_pistolettate_id);
  234.         $utenteloggato = $doctrine->getRepository('App:AdUser', $db)->find(100);
  236.         $pistolettata = new CooPfPistolettate();
  237.         $pistolettata->setDataLettura(new DateTime());
  238.         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  239.         $pistolettata->setAdUser($utenteloggato);
  240.         $pistolettata->setCProject($pistolettataOld->getCProject());
  241.         $pistolettata->setCProjectline($pistolettataOld->getCProjectline());
  242.         $pistolettata->setCreated(new DateTime());
  243.         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  244.         $pistolettata->setPostazione($pistolettataOld->getPostazione());
  245.         $pistolettata->setUpdated(new DateTime());
  246.         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  247.         $pistolettata->setStatus('stop');
  248.         $pistolettata->setCooPfEventType('stop');
  249.         $pistolettata->setName($pistolettataOld->getName());
  250.         try {
  251.             $doctrine->getManager($db)->persist($pistolettata);
  252.             $doctrine->getManager($db)->flush($pistolettata);
  253.             $return = new JsonResponse(['message' => "Lavorazione conclusa correttamente", 'pdf' => '', 'next_id' => $pistolettata->getCooPfPistolettateId()], 200);
  254.         } catch (Exception $e) {
  255.             $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Riprova."], 400);
  256.         }
  257.         return $return;
  258.     }
  261.     /**
  262.      * Registra azione da barcode
  263.      *
  264.      * Una volta letto il barcode inviare ID della postazione di lavoro e il valore del barcode letto
  265.      *
  266.      * @IsGranted("ROLE_USER")
  267.      * @OA\Response(response=200, description="Inserimaento andato a buon fine")
  268.      * @OA\RequestBody(@OA\JsonContent(type="object", example={"postazione_id":"", "valore":"", "evento":"", "nc_id":"", "connection": "0"}))
  269.      * @Route("/api/pistolettata", methods="POST", options={"expose"=true})
  270.      */
  271.     public function registra_azione_post(Request $request, ManagerRegistry $doctrine)
  272.     {
  273.         $db = $this->getDatabase($request);
  274.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  275.         if ($db === false) {
  276.             return $this->jsonResponse;
  277.         }
  278.         $data = json_decode($request->getContent(), true);
  279.         $postazione_id = isset($data['postazione_id']) ? $data['postazione_id'] : null;
  280.         $valoreScan = isset($data['valore']) ? $data['valore'] : '';
  281.         $evento = isset($data['evento']) ? $data['evento'] : '';
  282.         $ncId = isset($data['nc_id']) ? $data['nc_id'] : '';
  283.         $valore = trim($valoreScan);
  284.         if (!$valoreScan) {
  285.             return new JsonResponse(['message' => "Inserire il codice o usare il lettore di codice a barre"], 400);
  286.         }
  288.         if (strlen($valoreScan) != 12) {
  289.             return new JsonResponse(['message' => "Inserire il codice a barre (solo 12 cifre)"], 400);
  290.         }
  293.         $utenteloggato = $doctrine->getRepository('App:AdUser', $db)->find(100);
  295.         $postazione = $doctrine->getRepository('App:CooPfPostazioni', $db)->find($postazione_id);
  297.         $valConfronto = $postazione->fullbarcode() ? $valore : substr($valore, 0, 6);
  298.         $cooPfDistaglio = $doctrine->getRepository('App:CooPfDistaglio', $db)->distTaglio($valConfronto);
  300.         if (!$cooPfDistaglio && !count($cooPfDistaglio)) {
  301.             $cooPfDistaglio = $doctrine->getRepository('App:CooPfScansionecomm', $db)->distTaglio($valConfronto);
  302.         }
  304.         $cProjectlineId = $cooPfDistaglio ? $cooPfDistaglio->getCProjectlineId() : 0;
  305.         if ($cProjectlineId) {
  307.             $pistolettataAttuale = $doctrine->getRepository('App:CooPfPistolettate', $db)->pistolettataAttuale($valConfronto, $postazione_id);
  309.             $events = [];
  310.             if ($pistolettataAttuale && $postazione) {
  311.                 if ($pistolettataAttuale->getCooPfEventType() == 'start') {
  312.                     if ($evento == 'start') {
  313.                         $events = [/*0 => 'stop', 1 => */
  314.                             'start'];
  315.                     }
  316.                     if (in_array($evento, ['stop', 'nc', 'pause'])) {
  317.                         $events = [$evento];
  318.                     }
  319.                 } else if ($pistolettataAttuale->getCooPfEventType() == 'stop') {
  320.                     if (in_array($evento, ['start'])) {
  321.                         $events = ['start'];
  322.                     }
  323.                 } else if ($pistolettataAttuale->getCooPfEventType() == 'pause') {
  324.                     if (in_array($evento, ['start', 'stop'])) {
  325.                         $events = [$evento];
  326.                     }
  327.                 }
  328.             } else {
  329.                 if ($evento == 'start') {
  330.                     $events = [$evento];
  331.                 }
  332.             }
  334.             if (!$events) {
  335.                 return new JsonResponse(['message' => "Errore non è possibile proseguire. Riprova."], 400);
  336.             }
  339.             $projectLine = $doctrine->getRepository('App:CProjectline', $db)->find($cProjectlineId);
  340.             foreach ($events as $event) {
  341.                 //Inizio una nuova lavorazione
  342.                 if ($event == 'start') {
  344.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  345.                         $pistolettata = new CooPfPistolettate();
  346.                         $pistolettata->setDataLettura(new DateTime());
  347.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  348.                         $pistolettata->setAdUser($utenteloggato);
  349.                         $pistolettata->setCProject($projectLine->getCProject());
  350.                         $pistolettata->setCProjectline($projectLine);
  351.                         $pistolettata->setCreated(new DateTime());
  352.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  353.                         $pistolettata->setPostazione($postazione);
  354.                         $pistolettata->setUpdated(new DateTime());
  355.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  356.                         $pistolettata->setStatus('start');
  357.                         $pistolettata->setCooPfEventType('start');
  358.                         $pistolettata->setName($valoreScan);
  359.                         try {
  360.                             $doctrine->getManager($db)->persist($pistolettata);
  361.                             $doctrine->getManager($db)->flush($pistolettata);
  362.                             $return = new JsonResponse(['message' => "Lavorazione iniziata correttamente"], 200);
  363.                         } catch (Exception $e) {
  364.                             $return = new JsonResponse(['message' => "Errore durante lo start della lavorazione. Riprova."], 400);
  365.                         }
  366.                     } else {
  367.                         $return = new JsonResponse(['message' => "Stai tentando di iniziare una lavorazione che non esiste. Riprova."], 400);
  368.                     }
  369.                 }
  371.                 if ($event == 'nc') {
  373.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  374.                         $pistolettata = new CooPfPistolettate();
  375.                         $pistolettata->setDataLettura(new DateTime());
  376.                         $pisId = $this->nextId('coo_pf_pistolettate', $db, $doctrine);
  377.                         $pistolettata->setCooPfPistolettateId($pisId);
  378.                         $pistolettata->setAdUser($utenteloggato);
  379.                         $pistolettata->setCProject($projectLine->getCProject());
  380.                         $pistolettata->setCProjectline($projectLine);
  381.                         $pistolettata->setCreated(new DateTime());
  382.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  383.                         $pistolettata->setPostazione($postazione);
  384.                         $pistolettata->setUpdated(new DateTime());
  385.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  386.                         $pistolettata->setStatus('stop');
  387.                         $pistolettata->setCooPfEventType('nc');
  388.                         $pistolettata->setName($valoreScan);
  389.                         $pistolettata->setDescription($ncId);
  390.                         //$pistolettata->setAdRefListId($ncId);
  391.                         try {
  392.                             $doctrine->getManager($db)->persist($pistolettata);
  393.                             $doctrine->getManager($db)->flush($pistolettata);
  394.                             $return = new JsonResponse(['coo_pf_pistolettate_id' => $pisId, 'message' => "Lavorazione non conforme"], 200);
  395.                         } catch (Exception $e) {
  396.                             $return = new JsonResponse(['message' => "Errore durante il salvataggio della non conformità della lavorazione. Riprova."], 400);
  397.                         }
  398.                     } else {
  399.                         $return = new JsonResponse(['message' => "Stai tentando di salvare una lavorazione che non esiste. Riprova."], 400);
  400.                     }
  401.                 }
  403.                 if ($event == 'pause') {
  405.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  406.                         $pistolettata = new CooPfPistolettate();
  407.                         $pistolettata->setDataLettura(new DateTime());
  408.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  409.                         $pistolettata->setAdUser($utenteloggato);
  410.                         $pistolettata->setCProject($projectLine->getCProject());
  411.                         $pistolettata->setCProjectline($projectLine);
  412.                         $pistolettata->setCreated(new DateTime());
  413.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  414.                         $pistolettata->setPostazione($postazione);
  415.                         $pistolettata->setUpdated(new DateTime());
  416.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  417.                         $pistolettata->setStatus('stop');
  418.                         $pistolettata->setCooPfEventType('pause');
  419.                         $pistolettata->setName($valoreScan);
  420.                         try {
  421.                             $doctrine->getManager($db)->persist($pistolettata);
  422.                             $doctrine->getManager($db)->flush($pistolettata);
  423.                             $return = new JsonResponse(['message' => "Lavorazione in pausa"], 200);
  424.                         } catch (Exception $e) {
  425.                             $return = new JsonResponse(['message' => "Errore durante la messa in pausa della lavorazione. Riprova."], 400);
  426.                         }
  427.                     } else {
  428.                         $return = new JsonResponse(['message' => "Stai tentando di mettere in pausa una lavorazione che non esiste. Riprova."], 400);
  429.                     }
  430.                 }
  432.                 $labelPdf = '';
  433.                 //Effettuo lo stop di una lavorazione
  434.                 if ($event == 'stop') {
  436.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  437.                         $pistolettata = new CooPfPistolettate();
  438.                         $pistolettata->setDataLettura(new DateTime());
  439.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  440.                         $pistolettata->setAdUser($utenteloggato);
  441.                         $pistolettata->setCProject($projectLine->getCProject());
  442.                         $pistolettata->setCProjectline($projectLine);
  443.                         $pistolettata->setCreated(new DateTime());
  444.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  445.                         $pistolettata->setPostazione($pistolettataAttuale->getPostazione());
  446.                         $pistolettata->setUpdated(new DateTime());
  447.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  448.                         $pistolettata->setStatus('stop');
  449.                         $pistolettata->setCooPfEventType('stop');
  450.                         $pistolettata->setName($valoreScan);
  451.                         if ($postazione->getLine() == 3) {
  452.                             $colli = $doctrine->getRepository('App:CooPfColli', $db)->findBy(['cProjectline' => $pistolettata->getCProjectline()]);
  453.                             $numeroCollo = count($colli) + 1;
  455.                             $collo = new CooPfColli();
  456.                             $collo->setCooPfColliId($this->nextId('coo_pf_colli', $db, $doctrine));
  457.                             //$this->addFlash("cooPfColliId", $collo->getCooPfColliId());
  458.                             $collo->setCProject($pistolettata->getCProjectline()->getCProject());
  459.                             $collo->setCreated(new DateTime());
  460.                             $collo->setCreatedby($utenteloggato->getAdUserId());
  461.                             $collo->setDescription('');
  462.                             $collo->setName($numeroCollo);
  463.                             $collo->setCProjectline($pistolettata->getCProjectline());
  464.                             $collo->setUpdated(new DateTime());
  465.                             $collo->setUpdatedby($utenteloggato->getAdUserId());
  466.                             $doctrine->getManager($db)->persist($collo);
  468.                             try {
  470.                                 $doctrine->getManager($db)->flush($collo);
  471.                                 $REPORT_FOLDER = $db == 'default' ? '' : 'industrie/';
  472.                                 $input = __DIR__ . '/../../../../punto-finestre/public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.jasper';
  473.                                 $output = __DIR__ . '/../../../../punto-finestre/public/reports/' . $REPORT_FOLDER;
  474.                                 /* $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane' . ($DB == 'DATABASE_PUGLIA_URL' ? '2' : '') . '.jasper';
  475.                                   $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER; */
  476.                                 $options = [
  477.                                     'format' => ['pdf'],
  478.                                     'params' => ['RECORD_ID' => $collo->getCooPfColliId()],
  479.                                     'db_connection' => [
  480.                                         'driver' => 'postgres',
  481.                                         'username' => 'adempiere',
  482.                                         'password' => 'adempiere',
  483.                                         'host' => '192.168.1.3',
  484.                                         'database' => ($db == 'default' ? 'adempiere' : 'industrie'),
  485.                                         'port' => '5432'
  486.                                     ]
  487.                                 ];
  489.                                 $jasper = new PHPJasper;
  491.                                 $jasper->process(
  492.                                     $input,
  493.                                     $output,
  494.                                     $options
  495.                                 )->execute();
  497.                                 $labelPdf = 'https://adw.puntopersiane.it/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.pdf';
  498.                             } catch (\Exception $e) {
  499.                                 $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Non posso stampare. Riprova."], 400);
  500.                             }
  501.                         }
  502.                         try {
  503.                             $doctrine->getManager($db)->persist($pistolettata);
  504.                             $doctrine->getManager($db)->flush($pistolettata);
  505.                             $return = new JsonResponse(['message' => "Lavorazione conclusa correttamente", 'pdf' => $labelPdf, 'next_id' => $pistolettata->getCooPfPistolettateId()], 200);
  506.                         } catch (Exception $e) {
  507.                             $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Riprova."], 400);
  508.                         }
  509.                     }
  510.                 }
  513.             }
  514.             if ($return) {
  515.                 return $return;
  516.             }
  519.         } else {
  520.             return new JsonResponse(['message' => "Il codice a barre non è associato a nessuna lavorazione"], 400);
  521.         }
  523.         return new JsonResponse(['message' => "Errore generico"], 400);
  524.     }
  527.     /**
  528.      * @IsGranted("ROLE_USER")
  529.      * @Route("/postazione/taglio", name="pistolettate0")
  530.      * @Route("/postazione/assemblaggio", name="pistolettate1")
  531.      * @Route("/postazione/controllo-qualita", name="pistolettate2")
  532.      * @Route("/postazione/imballaggio", name="pistolettate3")
  533.      */
  534.     public function index(Request $request)
  535.     {
  536.         $line = str_replace('pistolettate', '', $request->attributes->get('_route'));
  539.         $postazione = $this->em->getRepository('App:CooPfPostazioni')->findOneBy(['line' => $line]);
  541.         $pistolettata = $this->em->getRepository('App:CooPfPistolettate')->findOneBy(['postazione' => $postazione], ['dataLettura' => 'DESC']);
  543.         $collo = null;
  544.         /* if ($status == 'stop' && $pistolettata && $pistolettata->getCProjectLine()) {
  545.           $collo = $this->em->getRepository('App:CooPfColli')->findOneBy(['cProjectline' => $pistolettata->getCProjectLine()], ['cooPfColliId' => 'DESC']);
  546.           } */
  548.         return $this->render('pistolettate/index.html.twig', [
  549.             'ultimoCollo' => $collo ?: null,
  550.             'pistolettata' => $pistolettata,
  551.             'project' => ($pistolettata && $pistolettata->getCProject()) ? $pistolettata->getCProject() : null,
  552.             'projectLine' => ($pistolettata && $pistolettata->getCProjectLine()) ? $pistolettata->getCProjectLine() : null,
  553.             'postazione' => $postazione,
  554.             'controller_name' => 'PistolettateController',
  555.         ]);
  556.     }
  558.     /**
  559.      * @IsGranted("ROLE_USER")
  560.      * @Route("/postazione/registra_azione", name="registra_azione")
  561.      */
  562.     public function registra_azione(Request $request)
  563.     {
  564.         $line = $request->request->get('line', -1);
  565.         $valoreScan = $request->request->get('valore', '') ?: '';
  566.         //$valore = str_pad($valore, 12, '0', STR_PAD_LEFT);
  567.         $valoreRomania = $valoreScan;
  568.         $valore = '0' . substr($valoreScan, 0, -1);
  571.         $utenteloggato = $this->getUser();
  573.         $postazione = $this->em->getRepository('App:CooPfPostazioni')->findOneBy(['line' => $line]);
  574.         $pistolettataAttuale = $this->em->getRepository('App:CooPfPistolettate')->findOneBy(['postazione' => $postazione], ['dataLettura' => 'DESC']);
  576.         if (trim($valore)) {
  577.             $cooPfDistaglio = $this->em->getRepository('App:CooPfDistaglio')->createQueryBuilder('cpd')
  578.                 ->where('cpd.cooCompressedid LIKE :value')
  579.                 ->setParameter('value', $valore . '.%')
  580.                 ->getQuery();
  581.             $cooPfDistaglio = count($cooPfDistaglio->getResult()) ? $cooPfDistaglio->getSingleResult() : null;
  583.             if (!$cooPfDistaglio) {
  584.                 $cooPfDistaglio = $this->em->getRepository('App:CooPfDistaglio')->createQueryBuilder('cpd')
  585.                     ->where('cpd.cooCompressedid LIKE :value')
  586.                     ->setParameter('value', $valoreRomania . '.%')
  587.                     ->getQuery();
  588.                 $cooPfDistaglio = count($cooPfDistaglio->getResult()) ? $cooPfDistaglio->getSingleResult() : null;
  589.             }
  591.             $terzoCaso = false;
  593.             if (!$cooPfDistaglio) {
  594.                 $terzoCaso = true;
  596.                 $terzoVal = substr($valore, 2, 5);
  598.                 $cooPfDistaglio = $this->em->getRepository('App:CooPfScansionecomm')->createQueryBuilder('csc');
  599.                 $cooPfDistaglio
  600.                     ->where($cooPfDistaglio->expr()->eq($cooPfDistaglio->expr()->substring("csc.cooCompressedid", 3, 5), "'" . $terzoVal . "'"))
  601.                     ->addOrderBy('csc.cProjectlineId', 'DESC');
  602.                 $cooPfDistaglio = $cooPfDistaglio->getQuery()->setMaxResults(1);
  604.                 $cooPfDistaglio = count($cooPfDistaglio->execute()) ? $cooPfDistaglio->getSingleResult() : null;
  606.                 if (!$cooPfDistaglio) {
  607.                     $terzoVal = substr($valoreRomania, 2, 5);
  609.                     $cooPfDistaglio = $this->em->getRepository('App:CooPfScansionecomm')->createQueryBuilder('csc');
  610.                     $cooPfDistaglio
  611.                         ->where($cooPfDistaglio->expr()->eq($cooPfDistaglio->expr()->substring("csc.cooCompressedid", 3, 5), "'" . $terzoVal . "'"))
  612.                         ->addOrderBy('csc.cProjectlineId', 'DESC');
  613.                     $cooPfDistaglio = $cooPfDistaglio->getQuery()->setMaxResults(1);
  615.                     $cooPfDistaglio = count($cooPfDistaglio->execute()) ? $cooPfDistaglio->getSingleResult() : null;
  616.                 }
  617.             }
  619.             $cProjectlineId = $cooPfDistaglio ? $cooPfDistaglio->getCProjectlineId() : 0;
  621.             if ($cProjectlineId) {
  622.                 //Inizio una nuova lavorazione
  623.                 if (!$pistolettataAttuale || ($pistolettataAttuale && $pistolettataAttuale->getStatus() == 'stop')) {
  624.                     $projectLine = $this->em->getRepository('App:CProjectline')->find($cProjectlineId);
  625.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  626.                         $pistolettata = new CooPfPistolettate();
  627.                         $pistolettata->setDataLettura(new DateTime());
  628.                         $pistolettata->setStatus('start');
  629.                         $pistolettata->setCooPfEventType('start');
  630.                         $pistolettata->setName($valoreScan);
  631.                         $pistolettata->setCooPfPistolettateId($this->nextIdOld('coo_pf_pistolettate'));
  632.                         $pistolettata->setAdUser($utenteloggato);
  633.                         $pistolettata->setCProject($projectLine->getCProject());
  634.                         $pistolettata->setCProjectline($projectLine);
  635.                         $pistolettata->setCreated(new DateTime());
  636.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  637.                         $pistolettata->setPostazione($postazione);
  638.                         $pistolettata->setUpdated(new DateTime());
  639.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  640.                         try {
  641.                             $this->em->persist($pistolettata);
  642.                             $this->em->flush();
  643.                             $this->addFlash("success", "Lavorazione iniziata correttamente");
  644.                         } catch (Exception $e) {
  645.                             $this->addFlash("error", "Errore durante lo start della lavorazione. Riprova.");
  646.                         }
  647.                     } else {
  648.                         $this->addFlash("error", "Stai tentando di iniziare una lavorazione che non esiste. Riprova.");
  649.                     }
  650.                 } //Effettuo lo stop di una lavorazione
  651.                 else if ($pistolettataAttuale && $pistolettataAttuale->getStatus() == 'start' && $pistolettataAttuale->getCProjectline()->getCProjectlineId() == $cProjectlineId) {
  652.                     $pistolettata = clone $pistolettataAttuale;
  653.                     $pistolettata->setStatus('stop');
  654.                     $pistolettata->setCooPfEventType('stop');
  655.                     $pistolettata->setName($valoreScan);
  656.                     $pistolettata->setDataLettura(new DateTime());
  657.                     $pistolettata->setCooPfPistolettateId($this->nextIdOld('coo_pf_pistolettate'));
  659.                     if ($postazione->getLine() == 3) {
  660.                         $colli = $this->em->getRepository('App:CooPfColli')->findBy(['cProjectline' => $pistolettata->getCProjectline()]);
  661.                         $numeroCollo = count($colli) + 1;
  663.                         $collo = new CooPfColli();
  664.                         $collo->setCooPfColliId($this->nextIdOld('coo_pf_colli'));
  665.                         $this->addFlash("cooPfColliId", $collo->getCooPfColliId());
  666.                         $collo->setCProject($pistolettata->getCProjectline()->getCProject());
  667.                         $collo->setCreated(new DateTime());
  668.                         $collo->setCreatedby($utenteloggato->getAdUserId());
  669.                         $collo->setDescription('');
  670.                         $collo->setName($numeroCollo);
  671.                         $collo->setCProjectline($pistolettata->getCProjectline());
  672.                         $collo->setUpdated(new DateTime());
  673.                         $collo->setUpdatedby($utenteloggato->getAdUserId());
  674.                         $this->em->persist($collo);
  675.                     }
  676.                     try {
  677.                         $this->em->persist($pistolettata);
  678.                         $this->em->flush();
  679.                         $this->addFlash("success", "Lavorazione conclusa correttamente");
  680.                     } catch (Exception $e) {
  681.                         $this->addFlash("error", "Errore durante lo stop della lavorazione. Riprova.");
  682.                     }
  683.                 } else {
  684.                     $this->addFlash("error", "Stai tentando di interrompere una lavorazione che non è attualmente in questa postazione. Riprova.");
  685.                 }
  686.             } else {
  687.                 $this->addFlash("warning", "Il codece a barre non è associato a nessuna lavorazione");
  688.             }
  689.         } else {
  690.             $this->addFlash("warning", "Inserire il codice o usare il lettore di codice a barre");
  691.         }
  693.         return $this->redirectToRoute('pistolettate' . $line);
  694.     }
  696.     private function nextIdOld($name)
  697.     {
  699.         $next = $this->em->getRepository('App:AdSequence')->findOneBy(['name' => $name]);
  700.         if ($next) {
  701.             $prossimo = $next->getCurrentnext();
  702.             $next->setCurrentnext($next->getCurrentnext() + 1);
  704.             try {
  705.                 $this->em->persist($next);
  706.                 $this->em->flush($next);
  707.             } catch (Exception $e) {
  708.                 $this->addFlash("error", "Errore nel calcolo ID. Riprova.");
  709.                 return null;
  710.             }
  712.             return $prossimo;
  713.         }
  714.         return null;
  715.     }
  717.     private function nextId($name, $db, $doctrine)
  718.     {
  720.         $next = $doctrine->getRepository('App:AdSequence', $db)->findOneBy(['name' => $name]);
  721.         if ($next) {
  722.             $prossimo = $next->getCurrentnext();
  723.             $next->setCurrentnext($next->getCurrentnext() + 1);
  725.             try {
  726.                 $doctrine->getManager($db)->persist($next);
  727.                 $doctrine->getManager($db)->flush($next);
  728.             } catch (Exception $e) {
  729.                 return null;
  730.             }
  732.             return $prossimo;
  733.         }
  734.         return null;
  735.     }
  737.     /**
  738.      * @IsGranted("ROLE_USER")
  739.      * @Route("/postazione/print_label/{id}/{stabilimento}", name="print_label", methods="GET", options={"expose"=true})
  740.      * @param int $id
  741.      */
  742.     public function print_label($id, $stabilimento = 'DATABASE_URL')
  743.     {
  744.         $REPORT_FOLDER = $stabilimento == 'DATABASE_URL' ? '' : 'industrie/';
  745.         $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.jasper';
  746.         $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER;
  747.         /* $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane' . ($DB == 'DATABASE_PUGLIA_URL' ? '2' : '') . '.jasper';
  748.           $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER; */
  749.         $options = [
  750.             'format' => ['pdf'],
  751.             'params' => ['RECORD_ID' => $id],
  752.             'db_connection' => [
  753.                 'driver' => 'postgres',
  754.                 'username' => 'adempiere',
  755.                 'password' => 'adempiere',
  756.                 'host' => 'localhost',
  757.                 'database' => ($stabilimento == 'DATABASE_URL' ? 'adempiere' : 'industrie'),
  758.                 'port' => '5432'
  759.             ]
  760.         ];
  762.         $jasper = new PHPJasper;
  764.         $jasper->process(
  765.             $input,
  766.             $output,
  767.             $options
  768.         )->execute();
  770.         $filename = 'label-' . $id . '.pdf';
  772.         $response = new Response(file_get_contents($output . 'item_label_punto_persiane.pdf'));
  773.         $response->setCharset('UTF-8');
  774.         $response->headers->set('Content-Type', 'application/pdf');
  775.         $response->headers->set('Content-Disposition', "attachement; filename=\"{$filename}\"");
  776.         return $response;
  777.     }
  779.     private function baseImagePath($stabilimento = '')
  780.     {
  781.         return "/mnt/allegatiadempiere/nc-images" . ($_SERVER["APP_IMGURL"] == 'dev' ? '-test' : '') . "/" . ($stabilimento ? $stabilimento . "/" : "");
  782.     }
  784.     /**
  785.      * @IsGranted("ROLE_USER")
  786.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  787.      * @Route("/api/nc-photo/{id}", name="zip-nc", methods="POST", options={"expose"=true})
  788.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  789.      * @param int $id
  790.      */
  791.     public function ncPhoto(Request $request, int $id = null): JsonResponse
  792.     {
  793.         $stabilimento = $this->getStabilimento($request);
  794.         $filesystem = new Filesystem();
  795.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  796.         if (!$filesystem->exists($photoDir)) {
  797.             try {
  798.                 $filesystem->mkdir($photoDir);
  799.             } catch (IOExceptionInterface $exception) {
  800.                 echo "An error occurred while creating your directory at " . $exception->getPath();
  801.             }
  802.         }
  803.         $data = json_decode($request->getContent(), true);
  804.         $status = 200;
  807.         if (isset($data['files']) && $data['files']) {
  808.             foreach ($data['files'] as $file) {
  809.                 $b64 = $file['b64'];
  810.                 $fd = explode(',', $b64);
  811.                 $filedata = $fd[1] ?? $fd[0];
  812.                 $filedata = $filedata ? base64_decode($filedata) : null;
  813.                 if ($filedata) {
  814.                     $filename = $file['fileName'];
  815.                     $filetype = $file['fileType'];
  816.                     $filesize = $file['fileSize'];
  817.                     $pos = strrpos($filename, '.');
  818.                     $estensione = substr($filename, $pos + 1, strlen($filename));
  819.                     $filesystem->dumpFile($photoDir . $filename, $filedata);
  820.                 }
  821.             }
  823.         }
  824.         return new JsonResponse(['id' => $id], $status);
  825.     }
  827.     /**
  828.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  829.      * @Route("/api/nc-photo/{id}", name="zip-nc-list", methods="GET", options={"expose"=true})
  830.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  831.      * @param int $id
  832.      */
  833.     public function ncPhotoList(Request $request, int $id = null): JsonResponse
  834.     {
  835.         $filesystem = new Filesystem();
  836.         $stabilimento = $this->getStabilimento($request);
  837.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  838.         $filesArray = [];
  839.         if ($filesystem->exists($photoDir)) {
  840.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  841.             if ($files) {
  842.                 foreach ($files as $file) {
  843.                     if (!$file->isDir()) {
  844.                         $filePath = $file->getRealPath();
  845.                         $relativePath = substr($filePath, strlen($photoDir));
  846.                         $filesArray[] = [
  847.                             'filename' => $relativePath,
  848.                             'filepath' => $filePath,
  849.                             'url' => "https://" . $_SERVER['SERVER_NAME'] . "/api/nc-photo-file/" . $id . "/" . $stabilimento . "/" . $relativePath
  850.                         ];
  851.                     }
  852.                 }
  853.             }
  854.             return new JsonResponse(['files' => $filesArray], 200);
  855.         }
  858.         return new JsonResponse(null, 400);
  859.     }
  861.     /**
  862.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  863.      * @OA\Parameter(name="filename", in="path", description="Il nome del file", @OA\Schema(type="string"))
  864.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  865.      * @Route("/api/nc-photo-file/{id}/{stabilimento}/{filename}", name="zip-nc-file", methods="GET", options={"expose"=true})
  866.      * @param Request $request
  867.      * @param int|null $id
  868.      * @param string $filename
  869.      * @return JsonResponse
  870.      */
  871.     public function ncPhotoFile(Request $request, int $id = null, string $stabilimento = '', string $filename = ''): BinaryFileResponse
  872.     {
  873.         $filesystem = new Filesystem();
  874.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  875.         $filesArray = [];
  876.         if ($filesystem->exists($photoDir)) {
  877.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  878.             if ($files) {
  879.                 foreach ($files as $file) {
  880.                     if (!$file->isDir()) {
  881.                         $filePath = $file->getRealPath();
  882.                         $relativePath = substr($filePath, strlen($photoDir));
  883.                         if ($relativePath == $filename) {
  884.                             $stream = new Stream($photoDir . $filename);
  885.                             $response = new BinaryFileResponse($stream);
  886.                             $response->headers->set('Content-Type', $file->getType());
  887.                             return $response;
  888.                         }
  889.                     }
  890.                 }
  891.             }
  892.         }
  895.         return new BinaryFileResponse(null, 400);
  896.     }
  899.     /**
  900.      * @IsGranted("ROLE_USER")
  901.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  902.      * @Route("/api/zip-nc-photo/{id}", name="zip-nc-photo", methods="GET", options={"expose"=true})
  903.      * @param int $id
  904.      */
  905.     public function zipNcPhoto(Request $request, int $id = null)
  906.     {
  907.         $filesystem = new Filesystem();
  908.         $stabilimento = $this->getStabilimento($request);
  909.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  910.         if ($filesystem->exists($photoDir)) {
  911.             $data = json_decode($request->getContent(), true);
  912.             $status = 200;
  914.             //$zip = new \ZipArchive();
  915.             $nomeFile = tempnam(sys_get_temp_dir(), 'photo');
  916.             exec('cd ' . $photoDir . ' ; zip -r ' . $nomeFile . ' .');
  917.             //$zip->open($nomeFile, \ZipArchive::CREATE);
  919.             /* $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  921.              foreach ($files as $file) {
  922.                  if (!$file->isDir()) {
  923.                      $filePath = $file->getRealPath();
  924.                      $relativePath = substr($filePath, strlen($photoDir) + 1);
  925.                      $zip->addFile($filePath, $relativePath);
  926.                  }
  928.              }*/
  929.             $stream = new Stream($nomeFile . '.zip');
  930.             $response = new BinaryFileResponse($stream);
  931.             $response->headers->set('Content-Type', 'application/zip');
  932.             return $response;
  934.         } else {
  935.             return new Response(null, 400);
  936.         }
  937.     }
  939.     /**
  940.      *
  941.      * Cambio sede
  942.      *
  943.      * Cambia la sede
  944.      *
  945.      * @IsGranted("ROLE_USER")
  946.      * @OA\Response(response=200, description="Tutto ok")
  947.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"2"}))
  948.      * @Route("/api/change-location", name="change_location", methods={"PUT", "POST"}, options={"expose"=true})
  949.      */
  950.     public
  951.     function change_location(Request $request)
  952.     {
  953.         if ($request->isMethod('POST')) {
  954.             $connection = $request->request->get('connection');
  955.         } else {
  956.             $data = json_decode($request->getContent(), true);
  957.             $connection = $data['connection'];
  958.         }
  960.         $session = $this->requestStack->getSession();
  961.         return $session->set('DB', $connection);
  963.         return new JsonResponse(['connection' => $connection], 200);
  964.     }
  966.     public
  967.     function getDatabase($request)
  968.     {
  970.         $data = json_decode($request->getContent(), true);
  971.         $connection = isset($data['connection']) ? $data['connection'] : -1;
  972.         if ($connection < 0) {
  973.             $connection = $request->request->get('connection', -1);
  974.             if ($connection < 0) {
  975.                 $connection = $request->query->get('connection', -1);
  976.             }
  977.         }
  979.         if ($connection < 0) {
  980.             return false;
  981.         }
  983.         $db = $connection == 2 ? 'puglia' : 'default';
  985.         return $db;
  986.     }
  988.     public
  989.     function getStabilimento($request)
  990.     {
  992.         $data = json_decode($request->getContent(), true);
  993.         $connection = isset($data['connection']) ? $data['connection'] : -1;
  994.         if ($connection < 0) {
  995.             if ($request->isMethod('POST')) {
  996.                 $connection = $request->request->get('connection', -1);
  997.             } else if ($request->isMethod('GET')) {
  998.                 $connection = $request->query->get('connection', -1);
  999.             }
  1000.         }
  1002.         if ($connection < 0) {
  1003.             return false;
  1004.         }
  1005.         $stabilimenti = [0 => '1000000', 1 => '1000001', 2 => '2000001'];
  1007.         return $stabilimenti[$connection];
  1008.     }
  1009. }