src/Controller/PistolettateController.php line 1010

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 Symfony\Component\HttpFoundation\File\UploadedFile;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use FilesystemIterator;
  12. use RecursiveIteratorIterator;
  13. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  14. use Symfony\Component\Filesystem\Exception\IOExceptionInterface;
  15. use Symfony\Component\Filesystem\Filesystem;
  16. use Symfony\Component\Filesystem\Path;
  17. use Symfony\Component\Finder\Iterator\RecursiveDirectoryIterator;
  18. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  19. use Symfony\Component\HttpFoundation\File\Stream;
  20. use Symfony\Component\HttpFoundation\JsonResponse;
  21. use Symfony\Component\Routing\Annotation\Route;
  22. use Symfony\Component\HttpFoundation\Request;
  23. use App\Entity\CooPfPistolettate;
  24. use App\Entity\CooPfColli;
  25. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Security;
  26. use Sensio\Bundle\FrameworkExtraBundle\Configuration\IsGranted;
  27. use Symfony\Component\HttpFoundation\Response;
  28. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
  29. use PHPJasper\PHPJasper;
  30. use Nelmio\ApiDocBundle\Annotation\Model;
  31. use Symfony\Component\HttpFoundation\RequestStack;
  32. use OpenApi\Annotations as OA;
  33. use Symfony\Component\Security\Core\Authentication\Token\Storage\UsageTrackingTokenStorage;
  34. use ZipArchive;
  36. class PistolettateController extends AbstractController
  37. {
  39.     private $em;
  40.     private $requestStack;
  41.     private $jsonResponse;
  43.     public function __construct(EntityManagerInterface $entityManager, RequestStack $requestStack)
  44.     {
  45.         $this->requestStack = $requestStack;
  46.         $this->em = $entityManager;
  47.     }
  49.     /**
  50.      * Elenco postazioni.
  51.      *
  52.      * Ritorna la lista delle postazioni
  53.      *
  54.      * @IsGranted("ROLE_USER")
  55.      * @Route("/api/postazioni", methods="GET", options={"expose"=true})
  56.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  57.      * @OA\Response(response=200, description="Ritorna l'elenco delle postazioni.")
  58.      *
  59.      */
  60.     public function postazioniList(Request $request, ManagerRegistry $doctrine)
  61.     {
  62.         $elenco = [];
  64.         $db = $this->getDatabase($request);
  65.         $stabilimento = $this->getStabilimento($request);
  66.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  67.         if ($db === false) {
  68.             return $this->jsonResponse;
  69.         }
  72.         $postazioni = $doctrine->getRepository('App:CooPfPostazioni', $db)->findBy(['isactive' => 'Y', 'cooStabilimentoId' => $stabilimento], ['line' => 'asc']);
  74.         //$postazioni = $doctrine->getRepository('App:CooPfPostazioni', $db)->findBy(['isactive' => 'Y'], ['line' => 'asc']);
  75.         if ($postazioni) {
  76.             foreach ($postazioni as $postazione) {
  77.                 $data = $postazione->serialize();
  78.                 $elenco[] = $data;
  79.             }
  80.         }
  81.         return new JsonResponse(['totale' => count($elenco), 'elenco' => $elenco]);
  82.     }
  84.     /**
  85.      * Elenco non conformità.
  86.      *
  87.      * Ritorna la lista delle non conformità
  88.      *
  89.      * @IsGranted("ROLE_USER")
  90.      * @Route("/api/non-conformita", methods="GET", options={"expose"=true})
  91.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  92.      * @OA\Response(response=200, description="Ritorna l'elenco delle non conformità.")
  93.      *
  94.      */
  95.     public function ncList(Request $request, ManagerRegistry $doctrine)
  96.     {
  97.         $elenco = [];
  99.         $db = $this->getDatabase($request);
  100.         $stabilimento = $this->getStabilimento($request);
  101.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  102.         if ($db === false) {
  103.             return $this->jsonResponse;
  104.         }
  107.         $ncs = $doctrine->getRepository('App:CooPfNctypetab', $db)->findBy(['isactive' => 'Y'], ['name' => 'asc']);
  109.         if ($ncs) {
  110.             foreach ($ncs as $nc) {
  111.                 $data = [
  112.                     'id' => $nc->getCooPfNctypetabId(),
  113.                     'name' => $nc->getName()
  114.                 ];
  115.                 $elenco[] = $data;
  116.             }
  117.         }
  118.         return new JsonResponse(['totale' => count($elenco), 'elenco' => $elenco]);
  119.     }
  121.     /**
  122.      * Elenco lavorazioni.
  123.      *
  124.      * Ritorna la lista delle lavorazioni
  125.      *
  126.      * @IsGranted("ROLE_USER")
  127.      * @Route("/api/lavorazioni/{postazione_id}", methods="GET", options={"expose"=true})
  128.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  129.      * @OA\Response(response=200, description="Ritorna l'elenco delle lavorazioni.")
  130.      *
  131.      */
  132.     public function lavorazioniList(int $postazione_id, Request $request, ManagerRegistry $doctrine)
  133.     {
  134.     set_time_limit(60);
  135.     ini_set( 'memory_limit', '2048M' );
  136.     $db = $this->getDatabase($request);
  137.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  138.         if ($db === false) {
  139.             return $this->jsonResponse;
  140.         }
  142.         $postazione = $doctrine->getRepository('App:CooPfPostazioni', $db)->find($postazione_id);
  144.         $pistolettate = $doctrine->getRepository('App:CooPfPistolettate', $db)->pistolettateLineaStato($postazione);
  146.         $elenco = [];
  147.         $elenco_nomi = [];
  148.         $elenco_postazioni_attuali = [];
  149.         if (isset($pistolettate)) {
  150.             $vecchiaData = null;
  151.             foreach ($pistolettate as $pistolettata) {
  152.                 //$pistolettata = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($pistolettata_id['coo_pf_pistolettate_id']);
  153.                 $name = $pistolettata->getName();
  155.                 if (!in_array($name, array_keys($elenco_postazioni_attuali))) {
  156.                     $elenco_postazioni_attuali[$name] = $pistolettata;
  157.                 }
  159.                 if (isset($elenco_postazioni_attuali[$name]) && $pistolettata->getPostazione() && $postazione && ($pistolettata->getPostazione()->getCooPfPostazioniId() == $postazione->getCooPfPostazioniId())) {
  160.                     $data = $pistolettata->serialize();
  161.                     $et = $pistolettata->getCooPfEventType();
  163.                     $p_att = $pistolettata->getPostazione()->getCooPfPostazioniId();
  164.                     if (($elenco_postazioni_attuali[$name])->getPostazione()->getCooPfPostazioniId() == $p_att) {
  165.                         if (!in_array($name, array_keys($elenco_nomi)) && !isset($elenco[$et][$name])) {
  166.                             if (!isset($elenco[$et])) {
  167.                                 $elenco[$et] = [];
  168.                             }
  169.                             $elenco[$et][$name] = [];
  170.                             $elenco_nomi[$name] = $et;
  171.                             $minutes = 0;
  172.                         } else {
  173.                             $attualeData = $pistolettata->getDataLettura();
  174.                             $interval = $attualeData->diff($vecchiaData);
  175.                             $minutes = $interval->format('%i');
  176.                         }
  177.                         $vecchiaData = $pistolettata->getDataLettura();
  178.                         $data['duration'] = $minutes;
  179.                         $elenco[$elenco_nomi[$name]][$name][] = $data;
  180.                     }
  181.                 }
  182.             }
  183.         }
  185.         return new JsonResponse(['elenco' => $elenco]);
  186.     }
  188.     /**
  189.      * Dettaglio lavorazione.
  190.      *
  191.      * Ritorna i dati della lavorazione
  192.      *
  193.      * @IsGranted("ROLE_USER")
  194.      * @Route("/api/lavorazione/{coo_pf_pistolettate_id}", methods="GET", options={"expose"=true})
  195.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  196.      * @OA\Response(response=200, description="Ritorna la lavorazione.")
  197.      *
  198.      */
  199.     public function lavorazioneDetails(int $coo_pf_pistolettate_id, Request $request, ManagerRegistry $doctrine)
  200.     {
  201.         $db = $this->getDatabase($request);
  202.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  203.         if ($db === false) {
  204.             return $this->jsonResponse;
  205.         }
  207.         $pistolettata = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($coo_pf_pistolettate_id);
  209.         return new JsonResponse($pistolettata->serialize(true));
  210.     }
  212.     /**
  213.      * Stop lavorazione.
  214.      *
  215.      * Ferma la lavorazione
  216.      *
  217.      * @IsGranted("ROLE_USER")
  218.      * @Route("/api/stop-lavorazione", methods="POST", options={"expose"=true})
  219.      * @OA\Parameter(name="connection", in="query", description="Connessione", @OA\Schema(type="integer"))
  220.      * @OA\RequestBody(@OA\JsonContent(type="object", example={"coo_pf_pistolettate_id":""}))
  221.      * @OA\Response(response=200, description="Ritorna la lavorazione.")
  222.      *
  223.      */
  224.     public function lavorazioneStop(Request $request, ManagerRegistry $doctrine)
  225.     {
  226.         $data = json_decode($request->getContent(), true);
  227.         $coo_pf_pistolettate_id = isset($data['coo_pf_pistolettate_id']) ? $data['coo_pf_pistolettate_id'] : null;
  228.         $db = $this->getDatabase($request);
  229.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  230.         if ($db === false) {
  231.             return $this->jsonResponse;
  232.         }
  234.         $pistolettataOld = $doctrine->getRepository('App:CooPfPistolettate', $db)->find($coo_pf_pistolettate_id);
  235.         $utenteloggato = $doctrine->getRepository('App:AdUser', $db)->find(100);
  237.         $pistolettata = new CooPfPistolettate();
  238.         $pistolettata->setDataLettura(new DateTime());
  239.         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  240.         $pistolettata->setAdUser($utenteloggato);
  241.         $pistolettata->setCProject($pistolettataOld->getCProject());
  242.         $pistolettata->setCProjectline($pistolettataOld->getCProjectline());
  243.         $pistolettata->setCreated(new DateTime());
  244.         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  245.         $pistolettata->setPostazione($pistolettataOld->getPostazione());
  246.         $pistolettata->setUpdated(new DateTime());
  247.         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  248.         $pistolettata->setStatus('stop');
  249.         $pistolettata->setCooPfEventType('stop');
  250.         $pistolettata->setName($pistolettataOld->getName());
  251.         try {
  252.             $doctrine->getManager($db)->persist($pistolettata);
  253.             $doctrine->getManager($db)->flush($pistolettata);
  254.             $return = new JsonResponse(['message' => "Lavorazione conclusa correttamente", 'pdf' => '', 'next_id' => $pistolettata->getCooPfPistolettateId()], 200);
  255.         } catch (Exception $e) {
  256.             $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Riprova."], 400);
  257.         }
  258.         return $return;
  259.     }
  262.     /**
  263.      * Registra azione da barcode
  264.      *
  265.      * Una volta letto il barcode inviare ID della postazione di lavoro e il valore del barcode letto
  266.      *
  267.      * @IsGranted("ROLE_USER")
  268.      * @OA\Response(response=200, description="Inserimaento andato a buon fine")
  269.      * @OA\RequestBody(@OA\JsonContent(type="object", example={"postazione_id":"", "valore":"", "evento":"", "nc_id":"", "connection": "0"}))
  270.      * @Route("/api/pistolettata", methods="POST", options={"expose"=true})
  271.      */
  272.     public function registra_azione_post(Request $request, ManagerRegistry $doctrine)
  273.     {
  274.         $db = $this->getDatabase($request);
  275.         $this->jsonResponse = new JsonResponse(['error' => 'NO_CONNECTION'], 400);
  276.         if ($db === false) {
  277.             return $this->jsonResponse;
  278.         }
  279.         $data = json_decode($request->getContent(), true);
  280.         $postazione_id = isset($data['postazione_id']) ? $data['postazione_id'] : null;
  281.         $valoreScan = isset($data['valore']) ? $data['valore'] : '';
  282.         $evento = isset($data['evento']) ? $data['evento'] : '';
  283.         $ncId = isset($data['nc_id']) ? $data['nc_id'] : '';
  284.         $valore = trim($valoreScan);
  285.         if (!$valoreScan) {
  286.             return new JsonResponse(['message' => "Inserire il codice o usare il lettore di codice a barre"], 400);
  287.         }
  289.         if (strlen($valoreScan) != 12) {
  290.             return new JsonResponse(['message' => "Inserire il codice a barre (solo 12 cifre)"], 400);
  291.         }
  294.         $utenteloggato = $doctrine->getRepository('App:AdUser', $db)->find(100);
  296.         $postazione = $doctrine->getRepository('App:CooPfPostazioni', $db)->find($postazione_id);
  298.         $valConfronto = $postazione->fullbarcode() ? $valore : substr($valore, 0, 6);
  299.         $cooPfDistaglio = $doctrine->getRepository('App:CooPfDistaglio', $db)->distTaglio($valConfronto);
  301.         if (!$cooPfDistaglio && !count($cooPfDistaglio)) {
  302.             $cooPfDistaglio = $doctrine->getRepository('App:CooPfScansionecomm', $db)->distTaglio($valConfronto);
  303.         }
  305.         $cProjectlineId = $cooPfDistaglio ? $cooPfDistaglio->getCProjectlineId() : 0;
  306.         if ($cProjectlineId) {
  308.             $pistolettataAttuale = $doctrine->getRepository('App:CooPfPistolettate', $db)->pistolettataAttuale($valConfronto, $postazione_id);
  310.             $events = [];
  311.             if ($pistolettataAttuale && $postazione) {
  312.                 if ($pistolettataAttuale->getCooPfEventType() == 'start') {
  313.                     if ($evento == 'start') {
  314.                         $events = [/*0 => 'stop', 1 => */
  315.                             'start'];
  316.                     }
  317.                     if (in_array($evento, ['stop', 'nc', 'pause'])) {
  318.                         $events = [$evento];
  319.                     }
  320.                 } else if ($pistolettataAttuale->getCooPfEventType() == 'stop') {
  321.                     if (in_array($evento, ['start'])) {
  322.                         $events = ['start'];
  323.                     }
  324.                 } else if ($pistolettataAttuale->getCooPfEventType() == 'pause') {
  325.                     if (in_array($evento, ['start', 'stop'])) {
  326.                         $events = [$evento];
  327.                     }
  328.                 }
  329.             } else {
  330.                 if ($evento == 'start') {
  331.                     $events = [$evento];
  332.                 }
  333.             }
  335.             if (!$events) {
  336.                 return new JsonResponse(['message' => "Errore non è possibile proseguire. Riprova."], 400);
  337.             }
  340.             $projectLine = $doctrine->getRepository('App:CProjectline', $db)->find($cProjectlineId);
  341.             foreach ($events as $event) {
  342.                 //Inizio una nuova lavorazione
  343.                 if ($event == 'start') {
  345.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  346.                         $pistolettata = new CooPfPistolettate();
  347.                         $pistolettata->setDataLettura(new DateTime());
  348.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  349.                         $pistolettata->setAdUser($utenteloggato);
  350.                         $pistolettata->setCProject($projectLine->getCProject());
  351.                         $pistolettata->setCProjectline($projectLine);
  352.                         $pistolettata->setCreated(new DateTime());
  353.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  354.                         $pistolettata->setPostazione($postazione);
  355.                         $pistolettata->setUpdated(new DateTime());
  356.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  357.                         $pistolettata->setStatus('start');
  358.                         $pistolettata->setCooPfEventType('start');
  359.                         $pistolettata->setName($valoreScan);
  360.                         try {
  361.                             $doctrine->getManager($db)->persist($pistolettata);
  362.                             $doctrine->getManager($db)->flush($pistolettata);
  363.                             $return = new JsonResponse(['message' => "Lavorazione iniziata correttamente"], 200);
  364.                         } catch (Exception $e) {
  365.                             $return = new JsonResponse(['message' => "Errore durante lo start della lavorazione. Riprova."], 400);
  366.                         }
  367.                     } else {
  368.                         $return = new JsonResponse(['message' => "Stai tentando di iniziare una lavorazione che non esiste. Riprova."], 400);
  369.                     }
  370.                 }
  372.                 if ($event == 'nc') {
  374.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  375.                         $pistolettata = new CooPfPistolettate();
  376.                         $pistolettata->setDataLettura(new DateTime());
  377.                         $pisId = $this->nextId('coo_pf_pistolettate', $db, $doctrine);
  378.                         $pistolettata->setCooPfPistolettateId($pisId);
  379.                         $pistolettata->setAdUser($utenteloggato);
  380.                         $pistolettata->setCProject($projectLine->getCProject());
  381.                         $pistolettata->setCProjectline($projectLine);
  382.                         $pistolettata->setCreated(new DateTime());
  383.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  384.                         $pistolettata->setPostazione($postazione);
  385.                         $pistolettata->setUpdated(new DateTime());
  386.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  387.                         $pistolettata->setStatus('stop');
  388.                         $pistolettata->setCooPfEventType('nc');
  389.                         $pistolettata->setName($valoreScan);
  390.                         $pistolettata->setDescription($ncId);
  391.                         //$pistolettata->setAdRefListId($ncId);
  392.                         try {
  393.                             $doctrine->getManager($db)->persist($pistolettata);
  394.                             $doctrine->getManager($db)->flush($pistolettata);
  395.                             $return = new JsonResponse(['coo_pf_pistolettate_id' => $pisId, 'message' => "Lavorazione non conforme"], 200);
  396.                         } catch (Exception $e) {
  397.                             $return = new JsonResponse(['message' => "Errore durante il salvataggio della non conformità della lavorazione. Riprova."], 400);
  398.                         }
  399.                     } else {
  400.                         $return = new JsonResponse(['message' => "Stai tentando di salvare una lavorazione che non esiste. Riprova."], 400);
  401.                     }
  402.                 }
  404.                 if ($event == 'pause') {
  406.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  407.                         $pistolettata = new CooPfPistolettate();
  408.                         $pistolettata->setDataLettura(new DateTime());
  409.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  410.                         $pistolettata->setAdUser($utenteloggato);
  411.                         $pistolettata->setCProject($projectLine->getCProject());
  412.                         $pistolettata->setCProjectline($projectLine);
  413.                         $pistolettata->setCreated(new DateTime());
  414.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  415.                         $pistolettata->setPostazione($postazione);
  416.                         $pistolettata->setUpdated(new DateTime());
  417.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  418.                         $pistolettata->setStatus('stop');
  419.                         $pistolettata->setCooPfEventType('pause');
  420.                         $pistolettata->setName($valoreScan);
  421.                         try {
  422.                             $doctrine->getManager($db)->persist($pistolettata);
  423.                             $doctrine->getManager($db)->flush($pistolettata);
  424.                             $return = new JsonResponse(['message' => "Lavorazione in pausa"], 200);
  425.                         } catch (Exception $e) {
  426.                             $return = new JsonResponse(['message' => "Errore durante la messa in pausa della lavorazione. Riprova."], 400);
  427.                         }
  428.                     } else {
  429.                         $return = new JsonResponse(['message' => "Stai tentando di mettere in pausa una lavorazione che non esiste. Riprova."], 400);
  430.                     }
  431.                 }
  433.                 $labelPdf = '';
  434.                 //Effettuo lo stop di una lavorazione
  435.                 if ($event == 'stop') {
  437.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  438.                         $pistolettata = new CooPfPistolettate();
  439.                         $pistolettata->setDataLettura(new DateTime());
  440.                         $pistolettata->setCooPfPistolettateId($this->nextId('coo_pf_pistolettate', $db, $doctrine));
  441.                         $pistolettata->setAdUser($utenteloggato);
  442.                         $pistolettata->setCProject($projectLine->getCProject());
  443.                         $pistolettata->setCProjectline($projectLine);
  444.                         $pistolettata->setCreated(new DateTime());
  445.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  446.                         $pistolettata->setPostazione($pistolettataAttuale->getPostazione());
  447.                         $pistolettata->setUpdated(new DateTime());
  448.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  449.                         $pistolettata->setStatus('stop');
  450.                         $pistolettata->setCooPfEventType('stop');
  451.                         $pistolettata->setName($valoreScan);
  452.                         if ($postazione->getLine() == 5) {
  453.                             $colli = $doctrine->getRepository('App:CooPfColli', $db)->findBy(['cProjectline' => $pistolettata->getCProjectline()]);
  454.                             $numeroCollo = count($colli) + 1;
  456.                             $collo = new CooPfColli();
  457.                             $collo->setCooPfColliId($this->nextId('coo_pf_colli', $db, $doctrine));
  458.                             //$this->addFlash("cooPfColliId", $collo->getCooPfColliId());
  459.                             $collo->setCProject($pistolettata->getCProjectline()->getCProject());
  460.                             $collo->setCreated(new DateTime());
  461.                             $collo->setCreatedby($utenteloggato->getAdUserId());
  462.                             $collo->setDescription('');
  463.                             $collo->setName($numeroCollo);
  464.                             $collo->setCProjectline($pistolettata->getCProjectline());
  465.                             $collo->setUpdated(new DateTime());
  466.                             $collo->setUpdatedby($utenteloggato->getAdUserId());
  467.                             $doctrine->getManager($db)->persist($collo);
  469.                             try {
  471.                                 $doctrine->getManager($db)->flush($collo);
  472.                                 $REPORT_FOLDER = $db == 'default' ? '' : 'industrie/';
  473.                                 $input = __DIR__ . '/../../../../punto-finestre/public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.jasper';
  474.                                 $output = __DIR__ . '/../../../../punto-finestre/public/reports/' . $REPORT_FOLDER;
  475.                                 /* $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane' . ($DB == 'DATABASE_PUGLIA_URL' ? '2' : '') . '.jasper';
  476.                                   $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER; */
  477.                                 $options = [
  478.                                     'format' => ['pdf'],
  479.                                     'params' => ['RECORD_ID' => $collo->getCooPfColliId()],
  480.                                     'db_connection' => [
  481.                                         'driver' => 'postgres',
  482.                                         'username' => 'adempiere',
  483.                                         'password' => 'adempiere',
  484.                                         'host' => '192.168.1.3',
  485.                                         'database' => ($db == 'default' ? 'adempiere' : 'industrie'),
  486.                                         'port' => '5432'
  487.                                     ]
  488.                                 ];
  490.                                 $jasper = new PHPJasper;
  492.                                 $jasper->process(
  493.                                     $input,
  494.                                     $output,
  495.                                     $options
  496.                                 )->execute();
  498.                                 $labelPdf = 'https://adw.puntopersiane.it/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.pdf';
  499.                             } catch (\Exception $e) {
  500.                                 $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Non posso stampare. Riprova."], 400);
  501.                             }
  502.                         }
  503.                         try {
  504.                             $doctrine->getManager($db)->persist($pistolettata);
  505.                             $doctrine->getManager($db)->flush($pistolettata);
  506.                             $return = new JsonResponse(['message' => "Lavorazione conclusa correttamente", 'pdf' => $labelPdf, 'next_id' => $pistolettata->getCooPfPistolettateId()], 200);
  507.                         } catch (Exception $e) {
  508.                             $return = new JsonResponse(['message' => "Errore durante lo stop della lavorazione. Riprova."], 400);
  509.                         }
  510.                     }
  511.                 }
  514.             }
  515.             if ($return) {
  516.                 return $return;
  517.             }
  520.         } else {
  521.             return new JsonResponse(['message' => "Il codice a barre non è associato a nessuna lavorazione"], 400);
  522.         }
  524.         return new JsonResponse(['message' => "Errore generico"], 400);
  525.     }
  528.     /**
  529.      * @IsGranted("ROLE_USER")
  530.      * @Route("/postazione/taglio", name="pistolettate0")
  531.      * @Route("/postazione/assemblaggio", name="pistolettate1")
  532.      * @Route("/postazione/controllo-qualita", name="pistolettate2")
  533.      * @Route("/postazione/imballaggio", name="pistolettate3")
  534.      */
  535.     public function index(Request $request)
  536.     {
  537.         $line = str_replace('pistolettate', '', $request->attributes->get('_route'));
  540.         $postazione = $this->em->getRepository('App:CooPfPostazioni')->findOneBy(['line' => $line]);
  542.         $pistolettata = $this->em->getRepository('App:CooPfPistolettate')->findOneBy(['postazione' => $postazione], ['dataLettura' => 'DESC']);
  544.         $collo = null;
  545.         /* if ($status == 'stop' && $pistolettata && $pistolettata->getCProjectLine()) {
  546.           $collo = $this->em->getRepository('App:CooPfColli')->findOneBy(['cProjectline' => $pistolettata->getCProjectLine()], ['cooPfColliId' => 'DESC']);
  547.           } */
  549.         return $this->render('pistolettate/index.html.twig', [
  550.             'ultimoCollo' => $collo ?: null,
  551.             'pistolettata' => $pistolettata,
  552.             'project' => ($pistolettata && $pistolettata->getCProject()) ? $pistolettata->getCProject() : null,
  553.             'projectLine' => ($pistolettata && $pistolettata->getCProjectLine()) ? $pistolettata->getCProjectLine() : null,
  554.             'postazione' => $postazione,
  555.             'controller_name' => 'PistolettateController',
  556.         ]);
  557.     }
  559.     /**
  560.      * @IsGranted("ROLE_USER")
  561.      * @Route("/postazione/registra_azione", name="registra_azione")
  562.      */
  563.     public function registra_azione(Request $request)
  564.     {
  565.         $line = $request->request->get('line', -1);
  566.         $valoreScan = $request->request->get('valore', '') ?: '';
  567.         //$valore = str_pad($valore, 12, '0', STR_PAD_LEFT);
  568.         $valoreRomania = $valoreScan;
  569.         $valore = '0' . substr($valoreScan, 0, -1);
  572.         $utenteloggato = $this->getUser();
  574.         $postazione = $this->em->getRepository('App:CooPfPostazioni')->findOneBy(['line' => $line]);
  575.         $pistolettataAttuale = $this->em->getRepository('App:CooPfPistolettate')->findOneBy(['postazione' => $postazione], ['dataLettura' => 'DESC']);
  577.         if (trim($valore)) {
  578.             $cooPfDistaglio = $this->em->getRepository('App:CooPfDistaglio')->createQueryBuilder('cpd')
  579.                 ->where('cpd.cooCompressedid LIKE :value')
  580.                 ->setParameter('value', $valore . '.%')
  581.                 ->getQuery();
  582.             $cooPfDistaglio = count($cooPfDistaglio->getResult()) ? $cooPfDistaglio->getSingleResult() : null;
  584.             if (!$cooPfDistaglio) {
  585.                 $cooPfDistaglio = $this->em->getRepository('App:CooPfDistaglio')->createQueryBuilder('cpd')
  586.                     ->where('cpd.cooCompressedid LIKE :value')
  587.                     ->setParameter('value', $valoreRomania . '.%')
  588.                     ->getQuery();
  589.                 $cooPfDistaglio = count($cooPfDistaglio->getResult()) ? $cooPfDistaglio->getSingleResult() : null;
  590.             }
  592.             $terzoCaso = false;
  594.             if (!$cooPfDistaglio) {
  595.                 $terzoCaso = true;
  597.                 $terzoVal = substr($valore, 2, 5);
  599.                 $cooPfDistaglio = $this->em->getRepository('App:CooPfScansionecomm')->createQueryBuilder('csc');
  600.                 $cooPfDistaglio
  601.                     ->where($cooPfDistaglio->expr()->eq($cooPfDistaglio->expr()->substring("csc.cooCompressedid", 3, 5), "'" . $terzoVal . "'"))
  602.                     ->addOrderBy('csc.cProjectlineId', 'DESC');
  603.                 $cooPfDistaglio = $cooPfDistaglio->getQuery()->setMaxResults(1);
  605.                 $cooPfDistaglio = count($cooPfDistaglio->execute()) ? $cooPfDistaglio->getSingleResult() : null;
  607.                 if (!$cooPfDistaglio) {
  608.                     $terzoVal = substr($valoreRomania, 2, 5);
  610.                     $cooPfDistaglio = $this->em->getRepository('App:CooPfScansionecomm')->createQueryBuilder('csc');
  611.                     $cooPfDistaglio
  612.                         ->where($cooPfDistaglio->expr()->eq($cooPfDistaglio->expr()->substring("csc.cooCompressedid", 3, 5), "'" . $terzoVal . "'"))
  613.                         ->addOrderBy('csc.cProjectlineId', 'DESC');
  614.                     $cooPfDistaglio = $cooPfDistaglio->getQuery()->setMaxResults(1);
  616.                     $cooPfDistaglio = count($cooPfDistaglio->execute()) ? $cooPfDistaglio->getSingleResult() : null;
  617.                 }
  618.             }
  620.             $cProjectlineId = $cooPfDistaglio ? $cooPfDistaglio->getCProjectlineId() : 0;
  622.             if ($cProjectlineId) {
  623.                 //Inizio una nuova lavorazione
  624.                 if (!$pistolettataAttuale || ($pistolettataAttuale && $pistolettataAttuale->getStatus() == 'stop')) {
  625.                     $projectLine = $this->em->getRepository('App:CProjectline')->find($cProjectlineId);
  626.                     if ($projectLine && $projectLine->getCProjectlineId() > 0) {
  627.                         $pistolettata = new CooPfPistolettate();
  628.                         $pistolettata->setDataLettura(new DateTime());
  629.                         $pistolettata->setStatus('start');
  630.                         $pistolettata->setCooPfEventType('start');
  631.                         $pistolettata->setName($valoreScan);
  632.                         $pistolettata->setCooPfPistolettateId($this->nextIdOld('coo_pf_pistolettate'));
  633.                         $pistolettata->setAdUser($utenteloggato);
  634.                         $pistolettata->setCProject($projectLine->getCProject());
  635.                         $pistolettata->setCProjectline($projectLine);
  636.                         $pistolettata->setCreated(new DateTime());
  637.                         $pistolettata->setCreatedby($utenteloggato->getAdUserId());
  638.                         $pistolettata->setPostazione($postazione);
  639.                         $pistolettata->setUpdated(new DateTime());
  640.                         $pistolettata->setUpdatedby($utenteloggato->getAdUserId());
  641.                         try {
  642.                             $this->em->persist($pistolettata);
  643.                             $this->em->flush();
  644.                             $this->addFlash("success", "Lavorazione iniziata correttamente");
  645.                         } catch (Exception $e) {
  646.                             $this->addFlash("error", "Errore durante lo start della lavorazione. Riprova.");
  647.                         }
  648.                     } else {
  649.                         $this->addFlash("error", "Stai tentando di iniziare una lavorazione che non esiste. Riprova.");
  650.                     }
  651.                 } //Effettuo lo stop di una lavorazione
  652.                 else if ($pistolettataAttuale && $pistolettataAttuale->getStatus() == 'start' && $pistolettataAttuale->getCProjectline()->getCProjectlineId() == $cProjectlineId) {
  653.                     $pistolettata = clone $pistolettataAttuale;
  654.                     $pistolettata->setStatus('stop');
  655.                     $pistolettata->setCooPfEventType('stop');
  656.                     $pistolettata->setName($valoreScan);
  657.                     $pistolettata->setDataLettura(new DateTime());
  658.                     $pistolettata->setCooPfPistolettateId($this->nextIdOld('coo_pf_pistolettate'));
  660.                     if ($postazione->getLine() == 5) {
  661.                         $colli = $this->em->getRepository('App:CooPfColli')->findBy(['cProjectline' => $pistolettata->getCProjectline()]);
  662.                         $numeroCollo = count($colli) + 1;
  664.                         $collo = new CooPfColli();
  665.                         $collo->setCooPfColliId($this->nextIdOld('coo_pf_colli'));
  666.                         $this->addFlash("cooPfColliId", $collo->getCooPfColliId());
  667.                         $collo->setCProject($pistolettata->getCProjectline()->getCProject());
  668.                         $collo->setCreated(new DateTime());
  669.                         $collo->setCreatedby($utenteloggato->getAdUserId());
  670.                         $collo->setDescription('');
  671.                         $collo->setName($numeroCollo);
  672.                         $collo->setCProjectline($pistolettata->getCProjectline());
  673.                         $collo->setUpdated(new DateTime());
  674.                         $collo->setUpdatedby($utenteloggato->getAdUserId());
  675.                         $this->em->persist($collo);
  676.                     }
  677.                     try {
  678.                         $this->em->persist($pistolettata);
  679.                         $this->em->flush();
  680.                         $this->addFlash("success", "Lavorazione conclusa correttamente");
  681.                     } catch (Exception $e) {
  682.                         $this->addFlash("error", "Errore durante lo stop della lavorazione. Riprova.");
  683.                     }
  684.                 } else {
  685.                     $this->addFlash("error", "Stai tentando di interrompere una lavorazione che non è attualmente in questa postazione. Riprova.");
  686.                 }
  687.             } else {
  688.                 $this->addFlash("warning", "Il codece a barre non è associato a nessuna lavorazione");
  689.             }
  690.         } else {
  691.             $this->addFlash("warning", "Inserire il codice o usare il lettore di codice a barre");
  692.         }
  694.         return $this->redirectToRoute('pistolettate' . $line);
  695.     }
  697.     private function nextIdOld($name)
  698.     {
  700.         $next = $this->em->getRepository('App:AdSequence')->findOneBy(['name' => $name]);
  701.         if ($next) {
  702.             $prossimo = $next->getCurrentnext();
  703.             $next->setCurrentnext($next->getCurrentnext() + 1);
  705.             try {
  706.                 $this->em->persist($next);
  707.                 $this->em->flush($next);
  708.             } catch (Exception $e) {
  709.                 $this->addFlash("error", "Errore nel calcolo ID. Riprova.");
  710.                 return null;
  711.             }
  713.             return $prossimo;
  714.         }
  715.         return null;
  716.     }
  718.     private function nextId($name, $db, $doctrine)
  719.     {
  721.         $next = $doctrine->getRepository('App:AdSequence', $db)->findOneBy(['name' => $name]);
  722.         if ($next) {
  723.             $prossimo = $next->getCurrentnext();
  724.             $next->setCurrentnext($next->getCurrentnext() + 1);
  726.             try {
  727.                 $doctrine->getManager($db)->persist($next);
  728.                 $doctrine->getManager($db)->flush($next);
  729.             } catch (Exception $e) {
  730.                 return null;
  731.             }
  733.             return $prossimo;
  734.         }
  735.         return null;
  736.     }
  738.     /**
  739.      * @IsGranted("ROLE_USER")
  740.      * @Route("/postazione/print_label/{id}/{stabilimento}", name="print_label", methods="GET", options={"expose"=true})
  741.      * @param int $id
  742.      */
  743.     public function print_label($id, $stabilimento = 'DATABASE_URL')
  744.     {
  745.         $REPORT_FOLDER = $stabilimento == 'DATABASE_URL' ? '' : 'industrie/';
  746.         $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane.jasper';
  747.         $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER;
  748.         /* $input = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER . 'item_label_punto_persiane' . ($DB == 'DATABASE_PUGLIA_URL' ? '2' : '') . '.jasper';
  749.           $output = __DIR__ . '/../../public/reports/' . $REPORT_FOLDER; */
  750.         $options = [
  751.             'format' => ['pdf'],
  752.             'params' => ['RECORD_ID' => $id],
  753.             'db_connection' => [
  754.                 'driver' => 'postgres',
  755.                 'username' => 'adempiere',
  756.                 'password' => 'adempiere',
  757.                 'host' => 'localhost',
  758.                 'database' => ($stabilimento == 'DATABASE_URL' ? 'adempiere' : 'industrie'),
  759.                 'port' => '5432'
  760.             ]
  761.         ];
  763.         $jasper = new PHPJasper;
  765.         $jasper->process(
  766.             $input,
  767.             $output,
  768.             $options
  769.         )->execute();
  771.         $filename = 'label-' . $id . '.pdf';
  773.         $response = new Response(file_get_contents($output . 'item_label_punto_persiane.pdf'));
  774.         $response->setCharset('UTF-8');
  775.         $response->headers->set('Content-Type', 'application/pdf');
  776.         $response->headers->set('Content-Disposition', "attachement; filename=\"{$filename}\"");
  777.         return $response;
  778.     }
  780.     private function baseImagePath($stabilimento = '')
  781.     {
  782.         return "/mnt/allegatiadempiere/nc-images" . ($_SERVER["APP_IMGURL"] == 'dev' ? '-test' : '') . "/" . ($stabilimento ? $stabilimento . "/" : "");
  783.     }
  785.     private function basePFImagePath($stabilimento = '')
  786.     {
  787.         return "/mnt/allegatiadempiere/fotoprodfin" . ($_SERVER["APP_IMGURL"] == 'dev' ? '-test' : '') . "/" . ($stabilimento ? $stabilimento . "/" : "");
  788.     }
  790.     /**
  791.      * @IsGranted("ROLE_USER")
  792.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  793.      * @Route("/api/nc-photo/{id}", name="zip-nc", methods="POST", options={"expose"=true})
  794.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  795.      * @param int $id
  796.      */
  797.     public function ncPhoto(Request $request, int $id = null): JsonResponse
  798.     {
  799.         // Il metodo getStabilimento leggerà 'connection' da $_POST o dall'URL
  800.         $stabilimento = $this->getStabilimento($request);
  802.         $filesystem = new Filesystem();
  803.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  805.         if (!$filesystem->exists($photoDir)) {
  806.             try {
  807.                 $filesystem->mkdir($photoDir);
  808.             } catch (IOExceptionInterface $exception) {
  809.                 // Nei controller è meglio ritornare un errore JSON invece di un echo
  810.                 return new JsonResponse(['error' => 'Impossibile creare la directory'], 500);
  811.             }
  812.         }
  814.         // In multipart/form-data, i file non sono nel body/content,
  815.         // ma dentro al sacco $request->files
  816.         $files = $request->files->get('files'); // Si aspetta un array di file
  818.         if (is_array($files)) {
  819.             /** @var UploadedFile $file */
  820.             foreach ($files as $file) {
  821.                 // Verifica che il file sia stato caricato correttamente dal browser/client
  822.                 if ($file instanceof UploadedFile && $file->isValid()) {
  823.                     // Recupera il nome originale del file (es. "foto.jpg")
  824.                     $filename = $file->getClientOriginalName();
  826.                     try {
  827.                         // Sposta il file dalla cartella temporanea di PHP a quella finale
  828.                         $file->move($photoDir, $filename);
  829.                     } catch (FileException $e) {
  830.                         // Gestisci l'errore se il file non può essere spostato (es. permessi)
  831.                         return new JsonResponse(['error' => 'Errore durante il salvataggio del file: ' . $filename], 500);
  832.                     }
  833.                 }
  834.             }
  835.         }
  837.         return new JsonResponse(['id' => $id], 200);
  838.     }
  840.     /**
  841.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  842.      * @Route("/api/nc-photo/{id}", name="zip-nc-list", methods="GET", options={"expose"=true})
  843.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  844.      * @param int $id
  845.      */
  846.     public function ncPhotoList(Request $request, int $id = null): JsonResponse
  847.     {
  848.         $filesystem = new Filesystem();
  849.         $stabilimento = $this->getStabilimento($request);
  850.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  851.         $filesArray = [];
  852.         if ($filesystem->exists($photoDir)) {
  853.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  854.             if ($files) {
  855.                 foreach ($files as $file) {
  856.                     if (!$file->isDir()) {
  857.                         $filePath = $file->getRealPath();
  858.                         $relativePath = substr($filePath, strlen($photoDir));
  859.                         $filesArray[] = [
  860.                             'filename' => $relativePath,
  861.                             'filepath' => $filePath,
  862.                             'url' => "https://" . $_SERVER['SERVER_NAME'] . "/api/nc-photo-file/" . $id . "/" . $stabilimento . "/" . $relativePath
  863.                         ];
  864.                     }
  865.                 }
  866.             }
  867.             return new JsonResponse(['files' => $filesArray], 200);
  868.         }
  871.         return new JsonResponse(null, 400);
  872.     }
  874.     /**
  875.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  876.      * @OA\Parameter(name="filename", in="path", description="Il nome del file", @OA\Schema(type="string"))
  877.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  878.      * @Route("/api/nc-photo-file/{id}/{stabilimento}/{filename}", name="zip-nc-file", methods="GET", options={"expose"=true})
  879.      * @param Request $request
  880.      * @param int|null $id
  881.      * @param string $filename
  882.      * @return JsonResponse
  883.      */
  884.     public function ncPhotoFile(Request $request, int $id = null, string $stabilimento = '', string $filename = ''): BinaryFileResponse
  885.     {
  886.         $filesystem = new Filesystem();
  887.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  888.         $filesArray = [];
  889.         if ($filesystem->exists($photoDir)) {
  890.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  891.             if ($files) {
  892.                 foreach ($files as $file) {
  893.                     if (!$file->isDir()) {
  894.                         $filePath = $file->getRealPath();
  895.                         $relativePath = substr($filePath, strlen($photoDir));
  896.                         if ($relativePath == $filename) {
  897.                             $stream = new Stream($photoDir . $filename);
  898.                             $response = new BinaryFileResponse($stream);
  899.                             $response->headers->set('Content-Type', $file->getType());
  900.                             return $response;
  901.                         }
  902.                     }
  903.                 }
  904.             }
  905.         }
  908.         return new BinaryFileResponse(null, 400);
  909.     }
  912.     /**
  913.      * @IsGranted("ROLE_USER")
  914.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata non conformità", @OA\Schema(type="integer"))
  915.      * @Route("/api/zip-nc-photo/{id}", name="zip-nc-photo", methods="GET", options={"expose"=true})
  916.      * @param int $id
  917.      */
  918.     public function zipNcPhoto(Request $request, int $id = null)
  919.     {
  920.         $filesystem = new Filesystem();
  921.         $stabilimento = $this->getStabilimento($request);
  922.         $photoDir = Path::normalize($this->baseImagePath($stabilimento) . $id . "/");
  923.         if ($filesystem->exists($photoDir)) {
  924.             $data = json_decode($request->getContent(), true);
  925.             $status = 200;
  927.             //$zip = new \ZipArchive();
  928.             $nomeFile = tempnam(sys_get_temp_dir(), 'photo');
  929.             exec('cd ' . $photoDir . ' ; zip -r ' . $nomeFile . ' .');
  930.             //$zip->open($nomeFile, \ZipArchive::CREATE);
  932.             /* $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  934.              foreach ($files as $file) {
  935.                  if (!$file->isDir()) {
  936.                      $filePath = $file->getRealPath();
  937.                      $relativePath = substr($filePath, strlen($photoDir) + 1);
  938.                      $zip->addFile($filePath, $relativePath);
  939.                  }
  941.              }*/
  942.             $stream = new Stream($nomeFile . '.zip');
  943.             $response = new BinaryFileResponse($stream);
  944.             $response->headers->set('Content-Type', 'application/zip');
  945.             return $response;
  947.         } else {
  948.             return new Response(null, 400);
  949.         }
  950.     }
  952.     /**
  953.      * @IsGranted("ROLE_USER")
  954.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata prodotto finito", @OA\Schema(type="integer"))
  955.      * @Route("/api/pf-photo/{id}", name="zip-pf", methods="POST", options={"expose"=true})
  956.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  957.      * @param int $id
  958.      */
  959.     public function pfPhoto(Request $request, int $id = null): JsonResponse
  960.     {
  961.         // Il metodo getStabilimento leggerà 'connection' da $_POST o dall'URL
  962.         $stabilimento = $this->getStabilimento($request);
  964.         $filesystem = new Filesystem();
  965.         $photoDir = Path::normalize($this->basePFImagePath($stabilimento) . $id . "/");
  967.         if (!$filesystem->exists($photoDir)) {
  968.             try {
  969.                 $filesystem->mkdir($photoDir);
  970.             } catch (IOExceptionInterface $exception) {
  971.                 // Nei controller è meglio ritornare un errore JSON invece di un echo
  972.                 return new JsonResponse(['error' => 'Impossibile creare la directory'], 500);
  973.             }
  974.         }
  976.         // In multipart/form-data, i file non sono nel body/content,
  977.         // ma dentro al sacco $request->files
  978.         $files = $request->files->get('files'); // Si aspetta un array di file
  980.         if (is_array($files)) {
  981.             /** @var UploadedFile $file */
  982.             foreach ($files as $file) {
  983.                 // Verifica che il file sia stato caricato correttamente dal browser/client
  984.                 if ($file instanceof UploadedFile && $file->isValid()) {
  985.                     // Recupera il nome originale del file (es. "foto.jpg")
  986.                     $filename = $file->getClientOriginalName();
  988.                     try {
  989.                         // Sposta il file dalla cartella temporanea di PHP a quella finale
  990.                         $file->move($photoDir, $filename);
  991.                     } catch (FileException $e) {
  992.                         // Gestisci l'errore se il file non può essere spostato (es. permessi)
  993.                         return new JsonResponse(['error' => 'Errore durante il salvataggio del file: ' . $filename], 500);
  994.                     }
  995.                 } else {
  996.                     return new JsonResponse(['error' => 'Errore durante il salvataggio del file: ' . $file->getErrorMessage()], 500);
  997.                 }
  998.             }
  999.         }
  1001.         return new JsonResponse(['id' => $id], 200);
  1002.     }
  1004.     /**
  1005.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata prodotto finito", @OA\Schema(type="integer"))
  1006.      * @Route("/api/pf-photo/{id}", name="zip-pf-list", methods="GET", options={"expose"=true})
  1007.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  1008.      * @param int $id
  1009.      */
  1010.     public function pfPhotoList(Request $request, int $id = null): JsonResponse
  1011.     {
  1012.         $filesystem = new Filesystem();
  1013.         $stabilimento = $this->getStabilimento($request);
  1014.         $photoDir = Path::normalize($this->basePFImagePath($stabilimento) . $id . "/");
  1015.         $filesArray = [];
  1016.         if ($filesystem->exists($photoDir)) {
  1017.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  1018.             if ($files) {
  1019.                 foreach ($files as $file) {
  1020.                     if (!$file->isDir()) {
  1021.                         $filePath = $file->getRealPath();
  1022.                         $relativePath = substr($filePath, strlen($photoDir));
  1023.                         $filesArray[] = [
  1024.                             'filename' => $relativePath,
  1025.                             'filepath' => $filePath,
  1026.                             'url' => "https://" . $_SERVER['SERVER_NAME'] . "/api/pf-photo-file/" . $id . "/" . $stabilimento . "/" . $relativePath
  1027.                         ];
  1028.                     }
  1029.                 }
  1030.             }
  1031.             return new JsonResponse(['files' => $filesArray], 200);
  1032.         }
  1035.         return new JsonResponse(null, 400);
  1036.     }
  1038.     /**
  1039.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata prodotto finito", @OA\Schema(type="integer"))
  1040.      * @OA\Parameter(name="filename", in="path", description="Il nome del file", @OA\Schema(type="string"))
  1041.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"0"}))
  1042.      * @Route("/api/pf-photo-file/{id}/{stabilimento}/{filename}", name="zip-pf-file", methods="GET", options={"expose"=true})
  1043.      * @param Request $request
  1044.      * @param int|null $id
  1045.      * @param string $filename
  1046.      * @return JsonResponse
  1047.      */
  1048.     public function pfPhotoFile(Request $request, int $id = null, string $stabilimento = '', string $filename = ''): BinaryFileResponse
  1049.     {
  1050.         $filesystem = new Filesystem();
  1051.         $photoDir = Path::normalize($this->basePFImagePath($stabilimento) . $id . "/");
  1052.         $filesArray = [];
  1053.         if ($filesystem->exists($photoDir)) {
  1054.             $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  1055.             if ($files) {
  1056.                 foreach ($files as $file) {
  1057.                     if (!$file->isDir()) {
  1058.                         $filePath = $file->getRealPath();
  1059.                         $relativePath = substr($filePath, strlen($photoDir));
  1060.                         if ($relativePath == $filename) {
  1061.                             $stream = new Stream($photoDir . $filename);
  1062.                             $response = new BinaryFileResponse($stream);
  1063.                             $response->headers->set('Content-Type', $file->getType());
  1064.                             return $response;
  1065.                         }
  1066.                     }
  1067.                 }
  1068.             }
  1069.         }
  1072.         return new BinaryFileResponse(null, 400);
  1073.     }
  1076.     /**
  1077.      * @IsGranted("ROLE_USER")
  1078.      * @OA\Parameter(name="id", in="path", description="L'ID della pistolettata prodotto finito", @OA\Schema(type="integer"))
  1079.      * @Route("/api/zip-pf-photo/{id}", name="zip-pf-photo", methods="GET", options={"expose"=true})
  1080.      * @param int $id
  1081.      */
  1082.     public function zipPfPhoto(Request $request, int $id = null)
  1083.     {
  1084.         $filesystem = new Filesystem();
  1085.         $stabilimento = $this->getStabilimento($request);
  1086.         $photoDir = Path::normalize($this->basePFImagePath($stabilimento) . $id . "/");
  1087.         if ($filesystem->exists($photoDir)) {
  1088.             $data = json_decode($request->getContent(), true);
  1089.             $status = 200;
  1091.             //$zip = new \ZipArchive();
  1092.             $nomeFile = tempnam(sys_get_temp_dir(), 'photoProdottoFinito');
  1093.             exec('cd ' . $photoDir . ' ; zip -r ' . $nomeFile . ' .');
  1094.             //$zip->open($nomeFile, \ZipArchive::CREATE);
  1096.             /* $files = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($photoDir, FilesystemIterator::CURRENT_AS_FILEINFO), RecursiveIteratorIterator::LEAVES_ONLY);
  1098.              foreach ($files as $file) {
  1099.                  if (!$file->isDir()) {
  1100.                      $filePath = $file->getRealPath();
  1101.                      $relativePath = substr($filePath, strlen($photoDir) + 1);
  1102.                      $zip->addFile($filePath, $relativePath);
  1103.                  }
  1105.              }*/
  1106.             $stream = new Stream($nomeFile . '.zip');
  1107.             $response = new BinaryFileResponse($stream);
  1108.             $response->headers->set('Content-Type', 'application/zip');
  1109.             return $response;
  1111.         } else {
  1112.             return new Response(null, 400);
  1113.         }
  1114.     }
  1116.     /**
  1117.      *
  1118.      * Cambio sede
  1119.      *
  1120.      * Cambia la sede
  1121.      *
  1122.      * @IsGranted("ROLE_USER")
  1123.      * @OA\Response(response=200, description="Tutto ok")
  1124.      * @OA\RequestBody(description="0 Sede, 1 Romania, 2 Puglia", @OA\JsonContent(type="object", example={"connection":"2"}))
  1125.      * @Route("/api/change-location", name="change_location", methods={"PUT", "POST"}, options={"expose"=true})
  1126.      */
  1127.     public
  1128.     function change_location(Request $request)
  1129.     {
  1130.         if ($request->isMethod('POST')) {
  1131.             $connection = $request->request->get('connection');
  1132.         } else {
  1133.             $data = json_decode($request->getContent(), true);
  1134.             $connection = $data['connection'];
  1135.         }
  1137.         $session = $this->requestStack->getSession();
  1138.         return $session->set('DB', $connection);
  1140.         return new JsonResponse(['connection' => $connection], 200);
  1141.     }
  1143.     public
  1144.     function getDatabase($request)
  1145.     {
  1147.         $data = json_decode($request->getContent(), true);
  1148.         $connection = isset($data['connection']) ? $data['connection'] : -1;
  1149.         if ($connection < 0) {
  1150.             $connection = $request->request->get('connection', -1);
  1151.             if ($connection < 0) {
  1152.                 $connection = $request->query->get('connection', -1);
  1153.             }
  1154.         }
  1156.         if ($connection < 0) {
  1157.             return false;
  1158.         }
  1160.         $db = $connection == 2 ? 'puglia' : 'default';
  1162.         return $db;
  1163.     }
  1165.     public
  1166.     function getStabilimento($request)
  1167.     {
  1169.         $data = json_decode($request->getContent(), true);
  1170.         $content = ($request->getContent());      // body raw
  1171.         $connection = isset($data['connection']) ? $data['connection'] : -1;
  1172.         if ($connection < 0) {
  1173.             if ($request->isMethod('POST')) {
  1174.                 $connection = $request->request->get('connection', -1);
  1175.             } else if ($request->isMethod('GET')) {
  1176.                 $connection = $request->query->get('connection', -1);
  1177.             }
  1178.         }
  1180.         if ($connection < 0) {
  1181.             return false;
  1182.         }
  1183.         $stabilimenti = [0 => '1000000', 1 => '1000001', 2 => '2000001'];
  1185.         return $stabilimenti[$connection];
  1186.     }
  1187. }