src/Controller/DefaultController.php line 50

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\HomeSlider;
  6. use App\Entity\Order;
  7. use App\Entity\OrderProduct;
  8. use App\Entity\Product;
  9. use App\Repository\HomePageRepository;
  10. use App\Repository\HomeSliderRepository;
  11. use App\Repository\OrderRepository;
  12. use App\Repository\ProductRepository;
  13. use App\Repository\SonataUserUserRepository;
  14. use App\Services\ApiConsumer;
  15. use App\Twig\Extension\MediaExtension;
  16. use App\Utils\EAS256CBC;
  17. use App\Utils\SeoUtils;
  18. use DateTime;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use PhpOffice\PhpSpreadsheet\Cell\DataType;
  21. use PhpOffice\PhpSpreadsheet\IOFactory;
  22. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  23. use PhpOffice\PhpSpreadsheet\Shared\Date as ExcelDate;
  24. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  25. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  26. use Symfony\Component\HttpFoundation\JsonResponse;
  27. use Symfony\Component\HttpFoundation\Request;
  28. use Symfony\Component\HttpFoundation\Response;
  29. use Symfony\Component\HttpFoundation\StreamedResponse;
  30. use Symfony\Component\Routing\Annotation\Route;
  32. class DefaultController extends AbstractController
  33. {
  34.     protected readonly SeoUtils $seoUtils;
  36.     protected ApiConsumer            $apiConsumer;
  37.     protected EntityManagerInterface $em;
  38.     private static string            $default_task = '5178';
  40.     public function __construct(SeoUtils $seoUtils, ApiConsumer $apiConsumer, EntityManagerInterface $em)
  41.     {
  42.         $this->seoUtils    = $seoUtils;
  43.         $this->apiConsumer = $apiConsumer;
  44.         $this->em          = $em;
  45.     }
  47.     /**
  48.      * @Route("/{reactRouting}", name="homepage", requirements={"reactRouting"=".+"}, defaults={"reactRouting": null}, priority=-10)
  49.      */
  50.     public function indexAction(Request $request): Response
  51.     {
  52.         return $this->render('default/index.html.twig');
  53.     }
  56.     /**
  57.      * @Route("/data/Initial.json", name="data_home2")
  58.      */
  59.     public function dataHomeAction(Request $request, HomePageRepository $homePageRepository, MediaExtension $media): \Symfony\Component\HttpFoundation\JsonResponse
  60.     {
  61.         $page = $homePageRepository->findOneBy([]);
  63.         $data[] = [
  64.             'bannerPrimary' => [
  65.                 'id'         => 1,
  66.                 'imgDesktop' => $media->media($page->getBannerPrimaryDesktop()),
  67.                 'imgMobile'  => $media->media($page->getBannerPrimaryMobile()),
  68.                 'link'       => $page->getBannerPrimaryLink(),
  69.             ],
  70.             'bannerSecondary' => [
  71.                 'id'         => 2,
  72.                 'imgDesktop' => $media->media($page->getBannerSecondaryDesktop()),
  73.                 'imgMobile'  => $media->media($page->getBannerSecondaryMobile()),
  74.                 'link'       => $page->getBannerSecondaryLink(),
  75.             ],
  76.             'bannerTertiary' => [
  77.                 'id'         => 3,
  78.                 'imgDesktop' => $media->media($page->getBannerTertiaryDesktop()),
  79.                 'imgMobile'  => $media->media($page->getBannerTertiaryMobile()),
  80.                 'link'       => $page->getBannerTertiaryLink(),
  81.             ],
  82.             'slides' => array_values(array_map(
  83.                                          fn(HomeSlider $item) => [
  84.                                              'id'        => $item->getId(),
  85.                                              'imgDesktop' => $media->media($item->getSlideDesktop()),
  86.                                              'imgMobile'  => $media->media($item->getBannerMobile()),
  87.                                              'link'       => $item->getLink(),
  89.                                          ],
  90.                                          array_filter(iterator_to_array($page->getSliders()), fn($item) => $item->isPublic())
  91.                                      )),
  93.         ];
  96.         return $this->json($data);
  97.     }
  98.     /**
  99.      * @Route("/data/batch.json", name="data_batch")
  100.      * @Route("/data/batch_json", name="data_batch2")
  101.      */
  102.     public function dataBatchAction(Request $request, OrderRepository $orderRepository): \Symfony\Component\HttpFoundation\JsonResponse
  103.     {
  104.         $id = $request->query->get('id');
  106.         $session = $request->getSession();
  108.         $order = $orderRepository->findOneBy(['ws_id' => (int)$id]);
  110.         $tracking = $this->apiConsumer->getImportsTasksTracking($order->getId(), $order->getWsId(), $session->get('user_password_hash'));
  112.         $data[] =
  113.             [
  114.                 "id"              => $order->getId(),
  115.                 "idWeb"           => $order->getId(),
  116.                 "batchId"         => $order->getWsId(),
  117.                 "Cliente"         => '',
  118.                 "Estado"          => $tracking->estado,
  119.                 "detalleDeCarga"  => '0000',
  120.                 "FechaDeCarga"    => $tracking->start_process,
  121.                 "FechaDeProceso"  => $tracking->end_process,
  122.                 "FechaFinProceso" => $tracking->end_process,
  123.                 "detalle"         => $id,
  125.             ];
  128.         return $this->json($data);
  129.     }
  132.     /**
  133.      * @Route("/data/homeWork.json", name="data_homeWork")
  134.      * @Route("/data/homeWork_json", name="data_homeWork2")
  135.      */
  136.     public function dataHomeWorkAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  137.     {
  138.         $id = $request->query->get('id');
  140.         $session = $request->getSession();
  142.         $tasks_ws = $this->getTasksFormat($request, $id);
  144.         $fields = [];
  146.         foreach ($tasks_ws as $tasks_w) {
  147.             $fields[] = $this->correctWorks($tasks_w, true);
  148.         }
  151.         $field_last = array_pop($fields);
  153.         $data = [];
  155.         $data[] =
  156.             [
  157.                 "id"             => $id,
  158.                 "IdWork"         => $id,
  159.                 "name"           => '',
  160.                 "modalContent"   => "Para armar el archivo de texto, crea filas con los datos separados por tabuladores y cada registro en una nueva línea, en el siguiente orden: " . implode(", ", $fields) . ' y ' . $field_last,
  161.                 "exampleFile"    => $id ? $this->generateUrl('download_example', ['task_id' => $id]) : '',
  162.                 "exampleFileXls" => $id ? $this->generateUrl('download_example_xls', ['task_id' => $id]) : '',
  163.                 "example"        => [],
  164.             ];
  167.         return $this->json($data);
  168.     }
  170.     private function correctWorks($word, $ucfirst = false): string
  171.     {
  172.         $result = match ($word) {
  173.             'lot' => 'lote',
  174.             'hold' => 'Tratamiento',
  175.             default => $word,
  176.         };
  178.         return $ucfirst ? ucfirst($result) : $result;
  179.     }
  182.     /**
  183.      * @Route("/data/fileTranfer.json", name="data_file_tranfer")
  184.      * @Route("/data/fileTranfer_json", name="data_file_tranfer2")
  185.      */
  186.     public function dataFileTransferAction(Request $request, OrderRepository $orderRepository): \Symfony\Component\HttpFoundation\JsonResponse
  187.     {
  188.         $id = $request->query->get('id');
  190.         $session = $request->getSession();
  192.         $works_ws  = $this->apiConsumer->getImportsTasksList($id, $session->get('user_password_hash'));
  193.         $orders_ws = $this->apiConsumer->getPedidoSeguimiento($id, $session->get('user_password_hash'));
  196.         $orders  = [];
  197.         $statuss = [];
  198.         foreach ($orders_ws as $order_ws) {
  200.             $order = $orderRepository->findOneBy(['ws_id' => $order_ws->ob_oid]);
  202.             if ($order != null) {
  203.                 $data_merge = [
  204.                     'web_id'    => $order->getId(),
  205.                     'create_at' => $order->getCreateAt()->format('Y-m-d H:i:s'),
  206.                     'file'      => $order->getFileName() ?? '',
  207.                     'user'      => $order->getUser()->getUsername(),
  208.                     'client'    => $order->getUser()->getUsername(),
  209.                 ];
  210.                 $orders[]   = array_merge((array)$order_ws, $data_merge);
  211.                 $statuss[]  = [
  212.                     'id'   => $order->getId(),
  213.                     'name' => $order_ws->Estado
  214.                 ];
  215.             }
  216.         }
  219.         $works = [];
  220.         foreach ($works_ws as $work) {
  221.             $works[] = [
  222.                 'id'     => $work->Id_Tarea,
  223.                 'IdWork' => $work->Id_Tarea,
  224.                 'name'   => $work->Descripcion,
  225.             ];
  226.         }
  228.         $order_list = [];
  229.         foreach ($orders as $order) {
  230.             $order        = (object)$order;
  231.             $order_list[] =
  232.                 [
  233.                     "id"             => $order->web_id,
  234.                     "idWeb"          => $order->web_id,
  235.                     "BatchId"        => $order->ob_oid,
  236.                     "Carga"          => $order->create_at,
  237.                     "Archivo"        => $order->file,
  238.                     "Usuario"        => $order->user,
  239.                     "Cliente"        => $order->client,
  240.                     "Estado"         => $order->Estado,
  241.                     "detalleDeCarga" => $order->Cita,
  242.                     "FechaDeCarga"   => $order->Fecha_Cita,
  243.                     "FechaDeProceso" => $order->Fecha_Cita,
  244.                     "detalle"        => 'None',
  245.                 ];
  246.         }
  248.         $data = [
  249.             [
  250.                 'stateList' => $statuss,
  251.                 'orderList' => $order_list,
  252.                 'homework'  => $works,
  253.             ]
  254.         ];
  257.         return $this->json($data);
  258.     }
  261.     /**
  262.      * @param Request                  $request
  263.      * @param ProductRepository        $productRepository
  264.      * @param SonataUserUserRepository $userRepository
  265.      * @param OrderRepository          $orderRepository
  266.      * @return JsonResponse
  267.      * @Route("/intranet/process_order", name="process_order")
  268.      */
  269.     public function processOrdenAction(Request $request, ProductRepository $productRepository, SonataUserUserRepository $userRepository, OrderRepository $orderRepository)
  270.     {
  271.         $session        = $request->getSession();
  272.         $p              = $request->request;
  273.         $data           = json_decode($p->get('orderData'));
  274.         $data           = $data->data ?? null;
  275.         $user_pass_hash = $session->get('user_password_hash');
  278.         $response = [
  279.             "status"  => 'error',
  280.             "message" => 'No se pudo procesar el pedido',
  282.         ];
  284.         $user = $userRepository->findOneBy(['user_pass_hash' => $user_pass_hash]);
  286.         if ($data) {
  288.             $order = new Order();
  289.             $order->setUser($user);
  290.             $order->setAccountId($data->accountId);
  291.             $order->setTasks(self::$default_task);
  293.             $errors = [];
  295.             if (!$data->info->name) {
  296.                 $errors['name'] = 'El nombre es obligatorio';
  297.             }
  298.             if (!$data->info->phone) {
  299.                 $errors['phone'] = 'El teléfono es obligatorio';
  300.             }
  301.             if (!$data->info->address) {
  302.                 $errors['phone'] = 'La dirección es obligatoria';
  303.             }
  304.             if (!$data->info->city) {
  305.                 $errors['city'] = 'La ciudad es obligatoria';
  306.             }
  308.             if (count($errors) < 0) {
  309.                 $response = [
  310.                     "status"  => 'error',
  311.                     "message" => 'Debes completar todos los campos obligatorios',
  312.                     "errors"  => $errors,
  313.                 ];
  314.                 return $this->json($response);
  315.             }
  317.             $order->setContactName($data->info->name);
  318.             $order->setContactPhone($data->info->phone);
  319.             $order->setContactAddress($data->info->address);
  320.             $order->setContactCity($data->info->city);
  322.             $this->em->persist($order);
  323.             $this->em->flush();
  326.             foreach ($data->list as $item) {
  328.                 $product = $productRepository->findOneBy(['product_id' => $item->id]);
  329.                 if (!$product) {
  330.                     $product = new Product();
  331.                     $product->setProductId($item->id);
  332.                     $product->setName($item->name);
  333.                     $product->setPackaging($item->packagingType);
  334.                     $this->em->persist($product);
  335.                     $this->em->flush();
  336.                 }
  338.                 $order_prod = new OrderProduct();
  339.                 $order_prod->setOrder($order);
  340.                 $order_prod->setProduct($product);
  341.                 $order_prod->setBatch($item->selectBatch);
  342.                 $order_prod->setQuantity($item->total);
  343.                 $this->em->persist($order_prod);
  344.                 $this->em->flush();
  345.             }
  347.             $send = $this->sendFileBase64($request, $order, false);
  349.             if ($send) {
  350.                 $response = [
  351.                     "status"  => 'success',
  352.                     "message" => 'Pedido recibido correctamente',
  354.                 ];
  355.             }
  358.         }
  360.         return $this->json($response);
  361.     }
  363.     /**
  364.      * @param Request $request
  365.      * @return JsonResponse
  366.      * @Route("/intranet/process_order_file", name="process_order_file")
  367.      */
  368.     public function processOrdenFileAction(Request $request, ProductRepository $productRepository, SonataUserUserRepository $userRepository, OrderRepository $orderRepository)
  369.     {
  370.         $session        = $request->getSession();
  371.         $user_pass_hash = $session->get('user_password_hash');
  372.         $account_id     = $request->request->get('accountId');
  373.         $id_home_work   = $request->request->get('idHomeWork');
  374.         
  376.         $file = $request->files->get('file');
  378. //        $products = $this->apiConsumer->getclientInv($account_id, $session->get('user_password_hash'));
  380.         $allowedMimeTypes = [
  381.             'text/plain',                 // .txt
  382.             'application/vnd.ms-excel',   // .xls (antiguo formato de Excel)
  383.             'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet', // .xlsx
  384.         ];
  386.         $mimeType = $file->getMimeType();
  388.         if (!in_array($mimeType, $allowedMimeTypes)) {
  389.             $response = [
  390.                 "status"  => 'error',
  391.                 "message" => 'El archivo debe ser en formato TXT o Excel',
  392.             ];
  393.             return $this->json($response);
  394.         }
  396.         if ($mimeType == 'text/plain') {
  397.             $lines = file($file, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
  398.         } else {
  399.             $spreadsheet = IOFactory::load($file->getPathname());
  400.             $sheet       = $spreadsheet->getActiveSheet();
  401.             $lines       = [];
  403.             // --- Rango de fechas dinámico: 5 años antes y 5 después de hoy ---
  404.             $today = new \DateTime();
  405.             $startDate = (clone $today)->modify('-5 years');
  406.             $endDate = (clone $today)->modify('+5 years');
  408.             $startSerial = \PhpOffice\PhpSpreadsheet\Shared\Date::PHPToExcel($startDate);
  409.             $endSerial = \PhpOffice\PhpSpreadsheet\Shared\Date::PHPToExcel($endDate);
  410.             // --- Fin del rango dinámico ---
  412.             foreach ($sheet->getRowIterator() as $row) {
  413.                 $rowData = [];
  414.                 foreach ($row->getCellIterator() as $cell) {
  415.                     $value = $cell->getValue();
  417.                     // Heurística para detectar y convertir fechas probables en el rango dinámico
  418.                     if (is_numeric($value) && $value >= $startSerial && $value <= $endSerial) {
  419.                         try {
  420.                             // Intentar convertir el serial de Excel a fecha
  421.                             $dateTime = ExcelDate::excelToDateTimeObject($value);
  422.                             $value = $dateTime->format('d/m/Y');
  423.                         } catch (\Exception $e) {
  424.                             // Si falla, mantener el valor como string
  425.                             $value = (string)$value;
  426.                         }
  427.                     } else {
  428.                         // Para todos los demás valores, solo convertir a string
  429.                         $value = (string)$value;
  430.                     }
  432.                     $rowData[] = $value;
  433.                 }
  434.                 // Solo agregar la fila si tiene al menos un valor no vacío
  435.                 if (!empty(array_filter($rowData, function($cell) {
  436.                     return trim($cell) !== '';
  437.                 }))) {
  438.                     $lines[] = $rowData;
  439.                 }
  440.             }
  441.         }
  444.         $user = $userRepository->findOneBy(['user_pass_hash' => $user_pass_hash]);
  446.         $order = new Order();
  447.         $order->setUser($user);
  448.         $order->setAccountId($account_id);
  449.         $order->setTasks($id_home_work);
  450.         $order->setFileName($file->getClientOriginalName());
  451.         $this->em->persist($order);
  452.         $this->em->flush();
  454.         /*foreach ($lines as $line) {
  455.             if ($mimeType == 'text/plain') {
  456.                 $columns = explode("\t", $line); // Dividir la línea en columnas
  457.             } else {
  458.                 $columns = $line;
  459.             }
  461.             $fields       = [];
  462.             $tasks_format = $this->getTasksFormat($request, $id_home_work);
  463.             foreach ($columns as $key => $field) {
  464.                 if (isset($tasks_format[$key])) {
  465.                     $fields[$tasks_format[$key]] = trim($field);
  466.                 }
  467.             }
  468.             
  469. //            dump($fields);
  472.             $product = $productRepository->findOneBy(['product_id' => $fields['producto']]);
  473.             
  474.             if (!$product) {
  475.                 $prod_ws = array_filter($products, function ($item) use ($fields) {
  476.                     return trim($item->producto_cod) === trim($fields['producto']);
  477.                 });
  479.                 if (!isset($prod_ws[0])) {
  480. //                    dump("No se encontró el producto con código: " . $fields['producto']);
  481.                     continue;
  482.                 }
  483.                 $prod_ws = $prod_ws[0];
  485.                 $product = new Product();
  486.                 $product->setProductId($prod_ws->producto_cod);
  487.                 $product->setName($prod_ws->desc_prod);
  488.                 $product->setPackaging($prod_ws->Unim);
  489.                 $this->em->persist($product);
  490.                 $this->em->flush();
  491.             }
  493.             // Validar que los campos requeridos existan
  494.             if (!isset($fields['cantidad']) || !isset($fields['hold']) || !isset($fields['Dirección']) || !isset($fields['Ciudad'])) {
  495.                 continue;
  496.             }
  498.             $order_prod = new OrderProduct();
  499.             $order_prod->setOrder($order);
  500.             $order_prod->setProduct($product);
  501.             $order_prod->setQuantity((int)$fields['cantidad']);
  502.             $order_prod->setHold($fields['hold']);
  503.             $order_prod->setAddress($fields['Dirección']);
  504.             $order_prod->setCity($fields['Ciudad']);
  505.             $this->em->persist($order_prod);
  506.             $this->em->flush();
  507.             
  508. //            dump($order_prod);
  510.         }*/
  512.         if ($mimeType == 'text/plain') {
  513.             $base64 = base64_encode(file_get_contents($file->getPathname()));
  514.         }else{
  516.             $content = '';
  517.             foreach ($lines as $line) {
  518.                 $content .= implode("\t", $line) . "\n";
  519.             }
  521.             $base64 = base64_encode($content);
  522.         }
  525.         $send = $this->sendFileBase64($request, $order, $id_home_work, $base64/*$mimeType == 'text/plain' ? $base64 : false*/);
  527.         if ($send) {
  528.             $response = [
  529.                 "status"  => 'success',
  530.                 "message" => 'Pedido recibido correctamente',
  532.             ];
  533.         } else {
  534.             $response = [
  535.                 "status"  => 'error',
  536.                 "message" => 'No se pudo procesar el pedido',
  538.             ];
  539.         }
  541.         return $this->json($response);
  542.     }
  545.     public function sendFileBase64($request, Order $order, $task = false, $base64 = false)
  546.     {
  547.         $session        = $request->getSession();
  548.         $user_pass_hash = $session->get('user_password_hash');
  550.         $products = $this->em->getRepository(OrderProduct::class)->findBy(['order' => $order->getId()]);
  552.         $web_task_id     = self::$default_task;
  553.         $web_task_detail = [
  554.             'cod_cliente',
  555.             'producto_cod',
  556.             'Lote',
  557.             'Cant_Solicitada',
  558.             'Dirección',
  559.             'NroReferencia',
  560.         ];
  562.         if ($base64) {
  563.             $file_64 = $base64;
  565.         } else {
  566.             $data = [];
  567.             foreach ($products as $prod) {
  568.                 $tmp = [];
  570.                 foreach ($task === false ? $web_task_detail : $this->getTasksFormat($request, $task) as $field) {
  571.                     $tmp[] = $this->resolverFieldName($prod, $field);
  572.                 }
  573.                 $data[] = $tmp;
  574.             }
  576.             $content = "";
  577.             foreach ($data as $row) {
  578.                 $content .= implode("\t", $row) . "\n";
  579.             }
  581.             $file_64 = base64_encode($content);
  582.         }
  583.         
  584. //        dump(base64_decode($file_64));
  585. //        exit;
  588.         $send = $this->apiConsumer->getImportsTasksFile($user_pass_hash, $task === false ? '76796070-0' : $order->getAccountId(), $order->getId(), $task === false ? $web_task_id : $task, $file_64);
  590.         if ($send) {
  591.             $order->setStatus('Enviado');
  592.             $order->setWsId($send);
  593.             $this->em->persist($order);
  594.             $this->em->flush();
  596.             return true;
  597.         } else {
  598.             return false;
  599.         }
  600.     }
  603.     /**
  604.      * @Route("/data/product.json", name="data_products")
  605.      */
  606.     public function dataProductsAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  607.     {
  608.         $id = $request->query->get('id');
  610.         $session = $request->getSession();
  612.         $products = $this->apiConsumer->getclientInv($id, $session->get('user_password_hash'));
  614.         $data     = [];
  615.         $data_tmp = [];
  617.         foreach ($products as $product) {
  619.             if (rtrim($product->Tratamiento) == '') {
  620.                 $data_tmp[$product->producto_cod][] =
  621.                     [
  622.                         "producto_cod" => $product->producto_cod,
  623.                         "desc_prod"    => $product->desc_prod,
  624.                         "Unim"         => $product->Unim,
  625.                         'Lote'         => $product->Lote,
  626.                         'Disponible'   => $product->Disponible,
  627.                         'Tratamiento'  => $product->Tratamiento,
  629.                     ];
  630.             }
  633.         }
  636.         foreach ($data_tmp as $product) {
  637.             $data_lote  = [];
  638.             $total_lote = [];
  639.             foreach ($product as $lote) {
  640.                 $data_lote[]  = [
  641.                     'batch'    => $lote['Lote'],
  642.                     'quantity' => $lote['Disponible'],
  643.                 ];
  644.                 $total_lote[] = (int)$lote['Disponible'];
  645.             }
  648.             $data[] =
  649.                 [
  650.                     "id"                => $product[0]['producto_cod'],
  651.                     "name"              => $product[0]['desc_prod'],
  652.                     "stored"            => array_sum($total_lote),
  653.                     "packagingType"     => $product[0]['Unim'],
  654.                     "packagingQuantity" => null,
  655.                     'batch'             => $data_lote
  657.                 ];
  660.         }
  663.         return $this->json($data);
  664.     }
  666.     /**
  667.      * @Route("/data/inventory.json", name="data_inventory")
  668.      * @Route("/data/inventory_json", name="data_inventory2")
  669.      */
  670.     public function dataInventoryAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  671.     {
  672.         $id = $request->query->get('id');
  674.         $session = $request->getSession();
  676.         $products = $this->apiConsumer->getclientInv($id, $session->get('user_password_hash'));
  678.         $prod = [];
  680.         foreach ($products as $product) {
  682.             $prod[] =
  683.                 [
  684.                     "id"            => $product->producto_cod,
  685.                     "name"          => $product->desc_prod,
  686.                     "stored"        => $product->Total,
  687.                     "packagingType" => $product->Unim,
  688.                     "batch"         => $product->Lote,
  689.                     "Treatment"     => $product->Tratamiento,
  690.                 ];
  691.         }
  693.         $data = [
  694.             [
  695.                 'file' => $this->generateUrl('download_inventory', ['id' => $id]),
  696.                 'data' => $prod,
  697.             ]
  698.         ];
  701.         return $this->json($data);
  702.     }
  704.     /**
  705.      * @Route("/download/inventory", name="download_inventory")
  706.      */
  707.     public function downloadInventoryAction(Request $request): StreamedResponse
  708.     {
  710.         $id = $request->query->get('id');
  712.         $session = $request->getSession();
  714.         $products = $this->apiConsumer->getclientInv($id, $session->get('user_password_hash'));
  716.         $spreadsheet = new Spreadsheet();
  717.         $sheet       = $spreadsheet->getActiveSheet();
  719.         $sheet->setCellValue('A1', 'Código');
  720.         $sheet->setCellValue('B1', 'Nombre');
  721.         $sheet->setCellValue('C1', 'Lote');
  722.         $sheet->setCellValue('D1', 'Tratamiento');
  723.         $sheet->setCellValue('E1', 'Disponible');
  724.         $sheet->setCellValue('F1', 'Reservado');
  725.         $sheet->setCellValue('G1', 'En despacho');
  726.         $sheet->setCellValue('H1', 'En Preparación');
  727.         $sheet->setCellValue('I1', 'Merma');
  728.         $sheet->setCellValue('J1', 'Total');
  729.         $sheet->setCellValue('K1', 'Embalaje');
  732.         $row = 2;
  733.         foreach ($products as $item) {
  734.             $sheet->setCellValueExplicit('A' . $row, $item->producto_cod, DataType::TYPE_STRING);
  735. //            $sheet->setCellValue('A' . $row, $item->producto_cod);
  736.             $sheet->setCellValueExplicit('B' . $row, $item->desc_prod, DataType::TYPE_STRING);
  737.             $sheet->setCellValueExplicit('C' . $row, $item->Lote, DataType::TYPE_STRING);
  738.             $sheet->setCellValueExplicit('D' . $row, $item->Tratamiento, DataType::TYPE_STRING);
  739.             $sheet->setCellValueExplicit('E' . $row, $item->Disponible, DataType::TYPE_STRING);
  740.             $sheet->setCellValueExplicit('F' . $row, $item->Reservado, DataType::TYPE_STRING);
  741.             $sheet->setCellValueExplicit('G' . $row, $item->En_Despacho, DataType::TYPE_STRING);
  742.             $sheet->setCellValueExplicit('H' . $row, $item->En_Preparación, DataType::TYPE_STRING);
  743.             $sheet->setCellValueExplicit('I' . $row, $item->Merma, DataType::TYPE_STRING);
  744.             $sheet->setCellValueExplicit('J' . $row, $item->Total, DataType::TYPE_STRING);
  745.             $sheet->setCellValueExplicit('K' . $row, $item->Unim, DataType::TYPE_STRING);
  746.             $row++;
  747.         }
  749.         $response = new StreamedResponse(function () use ($spreadsheet) {
  750.             $writer = new Xlsx($spreadsheet);
  751.             $writer->save('php://output');
  752.         });
  754.         // Configurar las cabeceras de la respuesta
  755.         $response->headers->set('Content-Type', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
  756.         $response->headers->set('Content-Disposition', 'attachment;filename="inventario_' . date('d/m/Y H:i:s') . '.xlsx"');
  757.         $response->headers->set('Cache-Control', 'max-age=0');
  759.         return $response;
  760.     }
  762.     /**
  763.      * @Route("/data/account.json", name="data_account")
  764.      */
  765.     public function dataAccountAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  766.     {
  767.         $session = $request->getSession();
  769.         $accounts = $this->apiConsumer->getclientList($session->get('user_password_hash'));
  771.         $data = [];
  773.         foreach ($accounts as $account) {
  775.             $data[] =
  776.                 [
  777.                     "id"      => $account->cod_cliente,
  778.                     "account" => $account->cliente_nombre,
  779.                 ];
  782.         }
  784.         return $this->json($data);
  785.     }
  787.     /**
  788.      * @Route("/data/user.json", name="data_users")
  789.      * @Route("/data/users_json", name="data_user2")
  790.      */
  791.     public function dataUserAction(Request $request, SonataUserUserRepository $userRepository)
  792.     {
  793.         $session = $request->getSession();
  795.         $user = $userRepository->findOneBy(['user_pass_hash' => $session->get('user_password_hash')]);
  797.         $account = $this->apiConsumer->getclientList($session->get('user_password_hash'))[0] ?? null;
  799. //        $validate = $this->apiConsumer->getClienteValidar($session->get('user_password_hash'))[0] ?? null;
  801.         $data =
  802.             [
  803.                 "id"           => $user->getId(),
  804.                 "name"         => /*$validate->Modulo_Name*/'',
  805.                 "token"        => $session->get('user_password_hash'),
  806.                 "year"         => 1900,
  807.                 "bill"         => true,
  808.                 "accountId"    => $account->cod_cliente,
  809.                 "userMsj"      => "",
  810.                 "adminMsj"     => "",
  811.                 "modalContent" => ('Para armar el archivo de texto, crea filas con los datos separados por tabuladores y cada registro en una nueva línea, en el siguiente orden: Código de Cliente, Código de Producto, Fecha, Código, Cantidad y Tipo de embalaje.'),
  812.                 'exampleFile'  => '',
  813.                 'example'      => [
  814.                     $this->getTasksFormat($request, null, true)
  815.                 ]
  816.             ];
  819.         return $this->json($data);
  820.     }
  822.     private function getTasks($cod_client, $user_pass_hash)
  823.     {
  824. //        return $this->apiConsumer->getImportsTasksFormats('5178', $user_pass_hash) ?? null;
  825.         return $this->apiConsumer->getImportsTasksList($cod_client, $user_pass_hash)[0] ?? null;
  826.     }
  828.     private function getTasksFormat(Request $request, $task_id = null, $ucfirst = false): array
  829.     {
  830.         $session        = $request->getSession();
  831.         $user_pass_hash = $session->get('user_password_hash');
  833.         if ($task_id == null) {
  834.             $task_id = self::$default_task;
  835.         }
  837.         $tasks_format = $this->apiConsumer->getImportsTasksFormats($task_id, $user_pass_hash) ?? null;
  839.         $tasks_ar = [];
  841.         foreach ($tasks_format as $item) {
  842.             $tasks_ar[(int)$item->Posicion - 1] = $ucfirst ? ucfirst($item->Descripcion) : $item->Descripcion;
  843.         }
  845.         ksort($tasks_ar);
  847.         return $tasks_ar;
  848.     }
  850.     private function resolverFieldName(OrderProduct $product, $field): bool|int|string|null
  851.     {
  852.         return match (ltrim($field)) {
  853.             'fecha' => date('d/m/Y'),
  854.             'cod_cliente' => $product->getOrder()->getAccountId(),
  855.             'hold' => $product->getHold(),
  856.             'Ciudad' => $product->getCity(),
  857.             'producto', 'producto_cod' => $product->getProduct()->getProductId(),
  858.             'cantidad', 'Cant_Solicitada' => $product->getQuantity(),
  859.             'lot', 'Lote' => $product->getBatch() != 0 ? $product->getBatch() : '*',
  860.             'Dirección' => $product->getOrder()->getContactAddress() ?: $product->getAddress(),
  861.             'NroReferencia' => $product->getOrder()->getId(),
  862.             default => false,
  863.         };
  864.     }
  866.     private function setFieldName(OrderProduct $product, $field)
  867.     {
  868.         switch ($field) {
  869.             case'fecha':
  870.                 return date('d/m/Y');
  871.             case'producto':
  872.                 return $product->getProduct()->getProductId();
  873.             case'cantidad':
  874.                 return $product->getQuantity();
  875.             case'lot':
  876.                 return '*';
  877.             default;
  878.         }
  879.     }
  881.     #[Route('/download-example/{task_id}', name: 'download_example')]
  882.     public function downloadExampleTxt(Request $request, $task_id): Response
  883.     {
  884.         $session = $request->getSession();
  886. //        $tasks_ws = $this->apiConsumer->getImportsTasksFormats($task_id, $session->get('user_password_hash'));
  887.         $tasks_ws = $this->getTasksFormat($request, $task_id);
  889.         $fields = [];
  891.         foreach ($tasks_ws as $tasks_w) {
  892.             $fields[] = $this->correctWorks($tasks_w, true);
  893.         }
  895.         $content = "";
  897.         foreach ([$fields] as $row) {
  898.             $content .= implode("\t", $row) . "\n";
  899.         }
  902.         // Crear la respuesta con encabezados adecuados
  903.         $response = new Response($content);
  905.         $response->headers->set('Content-Type', 'text/plain');
  906.         $response->headers->set('Content-Disposition', 'attachment; filename="ejemplo_pedido.txt"');
  907.         $response->headers->set('Content-Length', strlen($content));
  909.         return $response;
  910.     }
  912.     #[Route('/download-example-xls/{task_id}', name: 'download_example_xls')]
  913.     public function downloadExampleXls(Request $request, $task_id): Response
  914.     {
  915.         $session = $request->getSession();
  917. //        $tasks_ws = $this->apiConsumer->getImportsTasksFormats($task_id, $session->get('user_password_hash'));
  918.         $tasks_ws = $this->getTasksFormat($request, $task_id);
  920.         $fields = [];
  923.         foreach ($tasks_ws as $tasks_w) {
  924.             $fields[] = $this->correctWorks($tasks_w, true);
  925.         }
  928.         $spreadsheet = new Spreadsheet();
  929.         $sheet       = $spreadsheet->getActiveSheet();
  931.         $letras = range('A', 'Z');
  932.         foreach ($fields as $index => $field) {
  933.             $sheet->setCellValue($letras[$index] . '1', $field);
  934.         }
  937.         $response = new StreamedResponse(function () use ($spreadsheet) {
  938.             $writer = new Xlsx($spreadsheet);
  939.             $writer->save('php://output');
  940.         });
  942.         $response->headers->set('Content-Type', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
  943.         $response->headers->set('Content-Disposition', 'attachment;filename="ejemplo_archivo' . '.xlsx"');
  944.         $response->headers->set('Cache-Control', 'max-age=0');
  946.         return $response;
  947.     }
  949.     /**
  950.      * @Route("/data/tracing.json", name="data_tracing")
  951.      * @Route("/data/tracing_json", name="data_tracing2")
  952.      */
  953.     public function dataTracingAction(Request $request, OrderRepository $orderRepository): \Symfony\Component\HttpFoundation\JsonResponse
  954.     {
  955.         $session = $request->getSession();
  957.         $hash = $session->get('user_password_hash');
  959.         $id_client = $request->query->get('id');
  961.         $tracing = $this->apiConsumer->getPedidoSeguimiento($id_client, $hash);
  963.         $data = [];
  965.         foreach ($tracing as $item) {
  967.             $data[] =
  968.                 [
  969.                     "id"           => $item->ob_oid,
  970.                     "date"         => $item->Crea_date,
  971.                     "orderId"      => $item->ob_oid,
  972.                     "create_date"  => $item->Crea_date,
  973.                     "status"       => $item->Estado,
  974.                     "guide_number" => $item->num_guia_despacho,
  975.                     "cita"         => $item->Cita,
  976.                     "fecha_cita"   => $item->Fecha_Cita,
  977.                 ];
  979.         }
  981.         return $this->json($data);
  982.     }
  984.     /**
  985.      * @Route("/data/order.json", name="data_order")
  986.      * @Route("/data/order_json", name="data_order2")
  987.      */
  988.     public function dataOrderAction(Request $request, OrderRepository $orderRepository): \Symfony\Component\HttpFoundation\JsonResponse
  989.     {
  990.         $session = $request->getSession();
  992.         $hash = $session->get('user_password_hash');
  994.         $order_id  = $request->query->get('id');
  995.         $branch_id = $request->query->get('branchId');
  997.         $orders = $orderRepository->findOneBy(['ws_id' => $order_id]);
  999.         $tracings = $this->apiConsumer->getPedidoSeguimiento($branch_id, $hash);
  1001.         $tracings_prods = $this->apiConsumer->getPedidoSeguimientoDetalle($branch_id, $order_id, $hash);
  1003.         $products = [];
  1005.         if ($tracings_prods) {
  1006.             foreach ($tracings_prods as $product) {
  1007.                 $products[] = [
  1008.                     'id'                  => $product->producto_cod,
  1009.                     'name'                => $product->desc_prod,
  1010.                     'quantity'            => (int)$product->Cant_Solicitada,
  1011.                     'quantity_processed'  => (int)$product->Cant_en_Proceso,
  1012.                     'quantity_dispatched' => (int)$product->Cant_Despachada,
  1013.                     'batch'               => $product->Lote ?: 'Sin lote',
  1014.                     'status'              => $product->Estado,
  1015.                 ];
  1016.             }
  1017.         }
  1020.         $data_ws = [];
  1021.         foreach ($tracings as $tracing) {
  1022. //            if ($tracing->ob_oid == $order_id) {
  1023.                 $data_ws = [
  1024.                     'Crea_date'         => $tracing->Crea_date,
  1025.                     'ob_oid'            => $tracing->ob_oid,
  1026.                     'Tipo'              => $tracing->Tipo,
  1027.                     'num_guia_despacho' => $tracing->num_guia_despacho,
  1028.                     'Productos'         => $tracing->Productos,
  1029.                     'Lineas'            => $tracing->Lineas,
  1030.                     'Cant_Solicitada'   => $tracing->Cant_Solicitada,
  1031.                     'Cant_Despachada'   => $tracing->Cant_Despachada,
  1032.                     'Estado'            => $tracing->Estado,
  1033.                     'Cita'              => $tracing->Cita,
  1034.                     'Fecha_Cita'        => $tracing->Fecha_Cita,
  1035.                     'Hora_Cita'         => $tracing->Hora_Cita,
  1036.                     'Boleto'            => $tracing->Boleto,
  1037.                     'Hora_Presentacion' => $tracing->Hora_Presentacion,
  1038.                     'Hora_Ingreso'      => $tracing->Hora_Ingreso,
  1039.                     'Hora_Salida'       => $tracing->Hora_Salida,
  1040.                 ];
  1041. //            }
  1042.         }
  1045.         $data = [];
  1048.         $data[] =
  1049.             [
  1050.                 "id"                => $data_ws['ob_oid'],
  1051.                 "date"              => $data_ws['Crea_date'],
  1052.                 "Tipo"              => $data_ws['Tipo'],
  1053.                 "num_guia_despacho" => $data_ws['num_guia_despacho'],
  1054.                 "Productos"         => $data_ws['Productos'],
  1055.                 "Lineas"            => $data_ws['Lineas'],
  1056.                 "Cant_Solicitada"   => $data_ws['Cant_Solicitada'],
  1057.                 "Cant_Despachada"   => $data_ws['Cant_Despachada'],
  1058.                 "Cita"              => $data_ws['Cita'],
  1059.                 "Fecha_Cita"        => $data_ws['Fecha_Cita'],
  1060.                 "Hora_Cita"         => $data_ws['Hora_Cita'],
  1061.                 "status"            => $data_ws['Estado'],
  1062.                 "statusMsg"         => $data_ws['Estado'],
  1063.                 "products"          => $products,
  1064.             ];
  1066.         return $this->json($data);
  1067.     }
  1069.     /**
  1070.      * @Route("/data/bill.json", name="data_bill")
  1071.      * @Route("/data/bill_json", name="data_bill2")
  1072.      */
  1073.     public function dataBillAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  1074.     {
  1075.         $session = $request->getSession();
  1077.         $id_client = $request->query->get('id');
  1079.         $bills = $this->apiConsumer->getFacturaResumen($session->get('user_password_hash'));
  1082.         $data = [];
  1084.         foreach ($bills as $item) {
  1085.             $fecha = new \DateTime($item->F_Emis);
  1087.             $data[] =
  1088.                 [
  1089.                     "id"            => $item->Factura,
  1090.                     "date"          => $fecha->format('d/m/Y'),
  1091.                     //                    "n_credito"     => $item->N_Credito ,
  1092.                     "nota_venta"    => $item->NotaVenta,
  1093.                     "cotizacion"    => $item->cotizacion,
  1094.                     "f_impt"        => $item->F_Impt,
  1095.                     "f_emis"        => $item->F_Emis,
  1096.                     "f_venc"        => $item->F_Venc,
  1097.                     "rut_recep"     => $item->RutRecep,
  1098.                     "id_erp"        => $item->id_erp,
  1099.                     "rzn_soc_recep" => $item->RznSocRecep,
  1100.                     "lineas"        => $item->Lineas,
  1101.                     "cve_des"       => $item->CveDes,
  1102.                     "venta_item"    => $this->moneyFormat($item->Venta_Item),
  1103.                     "desc"          => $this->moneyFormat($item->Desc),
  1104.                     "mnt_exe"       => $this->moneyFormat($item->MntExe),
  1105.                     "neto"          => $this->moneyFormat($item->Neto),
  1106.                     "iva"           => $this->moneyFormat($item->IVA),
  1107.                     "total"         => $this->moneyFormat($item->Total),
  1108.                     "pendiente"     => $this->moneyFormat($item->Pendiente),
  1109.                     "estado"        => $item->Estado,
  1110.                     "dias_vencido"  => $item->Dias_Vencido,
  1111.                     "file"          => $this->generateUrl('data_bill_pdf', ['folio' => $item->Factura]),
  1112.                 ];
  1115.         }
  1117.         usort($data, function ($a, $b) {
  1118.             $dateA = DateTime::createFromFormat('d/m/Y', $a['date']);
  1119.             $dateB = DateTime::createFromFormat('d/m/Y', $b['date']);
  1120.             return $dateB <=> $dateA; // Orden ascendente
  1121.         });
  1124.         return $this->json($data);
  1125.     }
  1127.     private function moneyFormat($value)
  1128.     {
  1129.         return '$' . number_format((int)$value, 0, null, '.');
  1130.     }
  1132.     /**
  1133.      * @Route("/data/bill_pdf/{folio}", name="data_bill_pdf")
  1134.      */
  1135.     public function getFacturaFile(Request $request, $folio)
  1136.     {
  1137.         $session = $request->getSession();
  1139.         $id_client = $request->query->get('id');
  1140.         $id_client = $request->query->get('id');
  1142.         $pdf_64 = $this->apiConsumer->getFacturaPDF($session->get('user_password_hash'), $folio);
  1145.         $pdfContent = base64_decode($pdf_64);
  1148.         if ($pdfContent === false) {
  1149.             return new Response("Error al decodificar el PDF.", Response::HTTP_INTERNAL_SERVER_ERROR);
  1150.         }
  1152.         // Retornar el PDF directamente en la respuesta HTTP
  1153.         return new Response($pdfContent, 200, [
  1154.             'Content-Type'        => 'application/pdf',
  1155.             'Content-Disposition' => 'inline; filename="factura-' . $folio . '.pdf"',
  1156.         ]);
  1157.     }
  1159.     /**
  1160.      * @Route("/data/report.json", name="data_report")
  1161.      * @Route("/data/report_json", name="data_report2")
  1162.      */
  1163.     public function dataReportAction(Request $request): \Symfony\Component\HttpFoundation\JsonResponse
  1164.     {
  1165.         $session = $request->getSession();
  1167.         $id_client = $request->query->get('id');
  1170.         $report = $this->apiConsumer->getPowerBIList($session->get('user_password_hash'));
  1172.         $data = [];
  1174.         foreach ($report as $item) {
  1176.             $data[] =
  1177.                 [
  1178.                     "id_registro"   => $item->id_registro,
  1179.                     "create_date"   => $item->crea_date,
  1180.                     "create_oper"   => $item->crea_oper,
  1181.                     "id_usuario"    => $item->id_usuario,
  1182.                     "Descripc"      => $item->Descripc,
  1183.                     "Estado"        => $item->Estado,
  1184.                     "URLs"          => $item->URLs,
  1185.                     "OrderBy"       => $item->OrdenBy,
  1186.                     "Intervalo"     => $item->Intervalo,
  1187.                     "URLsParametro" => $item->URLsParametro,
  1188.                 ];
  1191.         }
  1193.         return $this->json($data);
  1194.     }
  1195. }