src/Controller/AdminController.php line 44

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  4. /*
  5.  * To change this license header, choose License Headers in Project Properties.
  6.  * To change this template file, choose Tools | Templates
  7.  * and open the template in the editor.
  8.  */
  10. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  11. use Symfony\Component\HttpFoundation\Session\Session;
  12. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use App\Entity\Empresa;
  18. use App\Entity\Usuario;
  19. use App\Entity\ConexionBD;
  20. use App\Service\SuperuserProvisioningService;
  21. use Symfony\Component\Security\Http\Authentication\AuthenticationUtils;
  22. use Symfony\Component\HttpFoundation\File\UploadedFile;
  23. use Symfony\Component\Routing\Annotation\Route;
  25. /**
  26.  * Description of AdminController
  27.  *
  28.  * @author joseangelparra
  29.  */
  30. class AdminController extends AbstractController
  31. {
  32.     //put your code here
  33.     private const AZURE_DI_API_VERSION = '2024-11-30';
  34.     private const SUPERUSER_IS_ADMIN = 3;
  35.     private $params;
  36.     public function __construct(ParameterBagInterface $params)
  37.     {
  39.         $this->session = new Session();
  40.         $this->params = $params;
  41.     }
  43.     #[Route('/', name: 'login')]
  44.     public function Login(AuthenticationUtils $authenticationUtils)
  45.     {
  46.         $error = $authenticationUtils->getLastAuthenticationError();
  48.         $lastUsername = $authenticationUtils->getLastUSername();
  51.         return $this->render('base.html.twig', array(
  52.             'error' => $error,
  53.             'last_username' => $lastUsername
  54.         ));
  55.     }
  57.     public function changePWD(UserPasswordHasherInterface $encoder, EntityManagerInterface $em)
  58.     {
  59.         $user = $em->getRepository(Usuario::class)->find(10);
  60.         $encoded = $encoder->hashPassword($user, 'docuManager2025');
  61.         $user->setPassword($encoded);
  62.         $em->persist($user);
  63.         $flush = $em->flush();
  64.         die();
  65.     }
  67.     public function checkUserExists(Request $request, EntityManagerInterface $em)
  68.     {
  69.         $email = trim((string)$request->request->get("user", ''));
  70.         $empresaId = (int)$request->request->get("empresa_id", 0);
  71.         $connectionId = (int)$request->request->get("connection", 0);
  73.         if ($email === '') {
  74.             return new JsonResponse(['exists' => false, 'message' => 'user_required'], 400);
  75.         }
  77.         $qb = $em->createQueryBuilder()
  78.             ->select('u.id')
  79.             ->from(Usuario::class, 'u')
  80.             ->where('LOWER(u.email) = :email')
  81.             ->setParameter('email', strtolower($email));
  83.         // Validar por ambito de empresa/conexion cuando se proporciona.
  84.         if ($empresaId > 0) {
  85.             $qb->andWhere('IDENTITY(u.empresa) = :empresaId')
  86.                 ->setParameter('empresaId', $empresaId);
  87.         } elseif ($connectionId > 0) {
  88.             $qb->andWhere('u.connection = :connectionId')
  89.                 ->setParameter('connectionId', $connectionId);
  90.         }
  92.         $existsScoped = !empty($qb->setMaxResults(1)->getQuery()->getArrayResult());
  94.         // Mantiene dato global para compatibilidad/diagnostico.
  95.         $existsGlobal = !empty($em->createQueryBuilder()
  96.             ->select('u2.id')
  97.             ->from(Usuario::class, 'u2')
  98.             ->where('LOWER(u2.email) = :email')
  99.             ->setParameter('email', strtolower($email))
  100.             ->setMaxResults(1)
  101.             ->getQuery()
  102.             ->getArrayResult());
  104.         return new JsonResponse([
  105.             'exists' => $existsScoped,
  106.             'exists_scoped' => $existsScoped,
  107.             'exists_global' => $existsGlobal,
  108.             'scope' => ($empresaId > 0 ? 'empresa' : ($connectionId > 0 ? 'connection' : 'global')),
  109.         ]);
  110.     }
  112.     private function azurePortForTenant(int $tenantId, int $base = 12000, int $max = 20999): int
  113.     {
  114.         $port = $base + $tenantId;
  115.         if ($port > $max) {
  116.             $range = max(1, $max - $base);
  117.             $port  = $base + ($tenantId % $range);
  118.         }
  119.         return $port;
  120.     }
  122.     private function azureDiWorkdirFromEnv(): string
  123.     {
  124.         return rtrim((string)($_ENV['AZURE_DI_WORKDIR'] ?? ''), '/');
  125.     }
  127.     private function clampDocuMaxThreads($value, int $default = 4): int
  128.     {
  129.         if ($value === null || $value === '') {
  130.             return $default;
  131.         }
  133.         $threads = (int)$value;
  134.         if ($threads < 1) {
  135.             return 1;
  136.         }
  137.         if ($threads > 16) {
  138.             return 16;
  139.         }
  140.         return $threads;
  141.     }
  143.     private function ensureMailMonitorService(int $companyId, string $dbHost, string $dbPort, string $dbUser, string $dbPass, string $dbName, string $filesPath): void
  144.     {
  145.         $workdir = $_ENV['MAIL_IMPORTER_WORKDIR'] ?? '';
  146.         $script  = $_ENV['MAIL_IMPORTER_SCRIPT'] ?? '';
  147.         $envFile = $_ENV['MAIL_IMPORTER_COMMON_ENV'] ?? '';
  149.         $missing = [];
  150.         if ($workdir === '') $missing[] = 'MAIL_IMPORTER_WORKDIR';
  151.         if ($script === '') $missing[] = 'MAIL_IMPORTER_SCRIPT';
  152.         if ($envFile === '') $missing[] = 'MAIL_IMPORTER_COMMON_ENV';
  153.         if (trim($filesPath) === '') $missing[] = 'FILES_PATH';
  154.         if (!empty($missing)) {
  155.             $msg = 'Mail Monitor no creado: faltan variables de entorno: ' . implode(', ', $missing);
  156.             $this->addFlash('warning', $msg);
  157.             error_log($msg);
  158.             return;
  159.         }
  161.         $serviceName = $companyId . "-mailMonitor.service";
  162.         $timerName   = $companyId . "-mailMonitor.timer";
  163.         $filesRoot   = rtrim($filesPath, '/') . '/' . $companyId;
  165.         $serviceContent = <<<EOT
  166. [Unit]
  167. Description=DocuManager Mail Monitor (empresa {$companyId})
  168. Wants=network-online.target
  169. After=network-online.target
  171. [Service]
  172. Type=oneshot
  173. WorkingDirectory={$workdir}
  174. EnvironmentFile={$envFile}
  175. Environment=MAIL_IMPORTER_DB_HOST={$dbHost}
  176. Environment=MAIL_IMPORTER_DB_PORT={$dbPort}
  177. Environment=MAIL_IMPORTER_DB_USER={$dbUser}
  178. Environment=MAIL_IMPORTER_DB_PASS={$dbPass}
  179. Environment=MAIL_IMPORTER_DB_NAME={$dbName}
  180. Environment=MAIL_IMPORTER_FILES_ROOT={$filesRoot}
  181. ExecStart=/usr/bin/python3 {$script} --once --log-level INFO
  182. User=docunecta
  183. Group=docunecta
  185. [Install]
  186. WantedBy=multi-user.target
  187. EOT;
  189.         $timerContent = <<<EOT
  190. [Unit]
  191. Description=DocuManager Mail Monitor Timer (empresa {$companyId})
  193. [Timer]
  194. OnBootSec=2min
  195. OnUnitActiveSec=15min
  196. AccuracySec=1min
  197. Persistent=true
  199. [Install]
  200. WantedBy=timers.target
  201. EOT;
  203.         $tmpServicePath = "/tmp/{$serviceName}";
  204.         $tmpTimerPath   = "/tmp/{$timerName}";
  206.         file_put_contents($tmpServicePath, $serviceContent);
  207.         file_put_contents($tmpTimerPath, $timerContent);
  208.         @chmod($tmpServicePath, 0644);
  209.         @chmod($tmpTimerPath, 0644);
  211.         $cmds = [
  212.             "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  213.             "sudo /bin/mv {$tmpTimerPath} /etc/systemd/system/{$timerName}",
  214.             "sudo /bin/systemctl daemon-reload",
  215.             "sudo /bin/systemctl enable --now {$timerName}",
  216.         ];
  217.         foreach ($cmds as $cmd) {
  218.             $out = \shell_exec($cmd . " 2>&1");
  219.             if ($out !== null) {
  220.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  221.             }
  222.         }
  223.     }
  225.     private function disableMailMonitorService(int $companyId): void
  226.     {
  227.         $serviceName = $companyId . "-mailMonitor.service";
  228.         $timerName   = $companyId . "-mailMonitor.timer";
  230.         $cmds = [
  231.             "sudo /bin/systemctl disable --now {$timerName}",
  232.             "sudo /bin/systemctl stop {$serviceName}",
  233.             "sudo /bin/rm -f /etc/systemd/system/{$serviceName}",
  234.             "sudo /bin/rm -f /etc/systemd/system/{$timerName}",
  235.             "sudo /bin/systemctl daemon-reload",
  236.         ];
  237.         foreach ($cmds as $cmd) {
  238.             $out = \shell_exec($cmd . " 2>&1");
  239.             if ($out !== null) {
  240.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  241.             }
  242.         }
  243.     }
  245.     private function removeCompanyFilesDir(int $companyId): void
  246.     {
  247.         $base = $_ENV['FILES_PATH'] ?? '';
  248.         if (trim($base) === '') {
  249.             $msg = 'No se ha podido borrar carpeta de files: falta FILES_PATH en entorno.';
  250.             $this->addFlash('warning', $msg);
  251.             error_log($msg);
  252.             return;
  253.         }
  255.         $base = rtrim($base, '/');
  256.         $target = $base . '/' . $companyId;
  258.         if (!is_dir($target)) {
  259.             return;
  260.         }
  262.         $errors = [];
  263.         $it = new \RecursiveIteratorIterator(
  264.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  265.             \RecursiveIteratorIterator::CHILD_FIRST
  266.         );
  268.         foreach ($it as $file) {
  269.             try {
  270.                 if ($file->isDir()) {
  271.                     @rmdir($file->getPathname());
  272.                 } else {
  273.                     @unlink($file->getPathname());
  274.                 }
  275.             } catch (\Throwable $e) {
  276.                 $errors[] = $e->getMessage();
  277.             }
  278.         }
  280.         @rmdir($target);
  282.         if (!empty($errors)) {
  283.             $msg = 'No se pudo borrar completamente la carpeta de files: ' . $target;
  284.             $this->addFlash('warning', $msg);
  285.             error_log($msg . ' | ' . implode(' | ', $errors));
  286.         }
  287.     }
  289.     private function removeCompanyLogsDir(int $companyId): void
  290.     {
  291.         $base = $_ENV['LOGS_ROOT'] ?? '';
  292.         if (trim($base) === '') {
  293.             $msg = 'No se ha podido borrar carpeta de logs: falta LOGS_ROOT en entorno.';
  294.             $this->addFlash('warning', $msg);
  295.             error_log($msg);
  296.             return;
  297.         }
  299.         $base = rtrim($base, '/');
  300.         $target = $base . '/' . $companyId;
  302.         if (!is_dir($target)) {
  303.             return;
  304.         }
  306.         $errors = [];
  307.         $it = new \RecursiveIteratorIterator(
  308.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  309.             \RecursiveIteratorIterator::CHILD_FIRST
  310.         );
  312.         foreach ($it as $file) {
  313.             try {
  314.                 if ($file->isDir()) {
  315.                     @rmdir($file->getPathname());
  316.                 } else {
  317.                     @unlink($file->getPathname());
  318.                 }
  319.             } catch (\Throwable $e) {
  320.                 $errors[] = $e->getMessage();
  321.             }
  322.         }
  324.         @rmdir($target);
  326.         if (!empty($errors)) {
  327.             $msg = 'No se pudo borrar completamente la carpeta de logs: ' . $target;
  328.             $this->addFlash('warning', $msg);
  329.             error_log($msg . ' | ' . implode(' | ', $errors));
  330.         }
  331.     }
  333.     private function getCompanyUserMediaPaths(\mysqli $mysqli): array
  334.     {
  335.         $paths = [];
  336.         try {
  337.             $res = $mysqli->query("SELECT avatar, firma FROM users");
  338.             if ($res) {
  339.                 while ($r = $res->fetch_assoc()) {
  340.                     foreach (['avatar', 'firma'] as $col) {
  341.                         $path = trim((string)($r[$col] ?? ''));
  342.                         if ($path === '' || str_starts_with($path, 'http')) {
  343.                             continue;
  344.                         }
  345.                         $paths[$path] = true;
  346.                     }
  347.                 }
  348.                 $res->free();
  349.             }
  350.         } catch (\Throwable $e) {
  351.             error_log('Error leyendo usuarios para borrar media: ' . $e->getMessage());
  352.         }
  353.         return array_keys($paths);
  354.     }
  356.     private function callPlatformCleanup(int $companyId, array $mediaPaths = []): void
  357.     {
  358.         $url = $_ENV['PLATFORM_CLEANUP_URL'] ?? '';
  359.         $secret = $_ENV['PLATFORM_CLEANUP_SECRET'] ?? '';
  360.         if (trim($url) === '' || trim($secret) === '') {
  361.             $msg = 'Cleanup no ejecutado: faltan PLATFORM_CLEANUP_URL o PLATFORM_CLEANUP_SECRET.';
  362.             $this->addFlash('warning', $msg);
  363.             error_log($msg);
  364.             return;
  365.         }
  367.         $payload = [
  368.             'company_id' => $companyId,
  369.             'media_paths' => array_values($mediaPaths),
  370.         ];
  371.         $body = json_encode($payload, JSON_UNESCAPED_SLASHES);
  372.         if ($body === false) {
  373.             error_log('Cleanup: no se pudo serializar payload JSON.');
  374.             return;
  375.         }
  377.         $ts = time();
  378.         $sig = hash_hmac('sha256', $ts . "\n" . $body, $secret);
  380.         $ch = curl_init();
  381.         curl_setopt($ch, CURLOPT_URL, $url);
  382.         curl_setopt($ch, CURLOPT_POST, true);
  383.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  384.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  385.             'Content-Type: application/json',
  386.             'X-Docu-Timestamp: ' . $ts,
  387.             'X-Docu-Signature: ' . $sig,
  388.         ]);
  389.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  390.         curl_setopt($ch, CURLOPT_TIMEOUT, 8);
  391.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  392.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  394.         $response = curl_exec($ch);
  395.         $error = curl_error($ch);
  396.         $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  397.         curl_close($ch);
  399.         if ($error || $code < 200 || $code >= 300) {
  400.             $msg = 'Cleanup remoto fallo (' . $code . '): ' . ($error ?: (string)$response);
  401.             $this->addFlash('warning', $msg);
  402.             error_log($msg);
  403.         }
  404.     }
  407.     #[Route('/list', name: 'list')]
  408.     public function List(EntityManagerInterface $entityManager)
  409.     {
  410.         if (!$this->getUser() || !is_object($this->getUser())) {
  411.             return $this->redirectToRoute('logout');
  412.         }
  413.         $empresas = $entityManager->getRepository(Empresa::class)->findAll();
  415.         return $this->render('listusers.html.twig', array(
  416.             'empresas' => $empresas,
  417.         ));
  418.     }
  420.     public function superusersList(EntityManagerInterface $em)
  421.     {
  422.         if (!$this->getUser() || !is_object($this->getUser())) {
  423.             return $this->redirectToRoute('logout');
  424.         }
  426.         $rows = $em->getConnection()->fetchAllAssociative("
  427.             SELECT
  428.                 LOWER(email) AS email_key,
  429.                 MIN(email) AS email,
  430.                 COUNT(*) AS empresas_count,
  431.                 SUM(CASE WHEN status IN ('ENABLED', '1', 1) THEN 1 ELSE 0 END) AS enabled_count
  432.             FROM users
  433.             WHERE is_admin = :isAdmin
  434.             GROUP BY LOWER(email)
  435.             ORDER BY MIN(email) ASC
  436.         ", ['isAdmin' => self::SUPERUSER_IS_ADMIN]);
  438.         return $this->render('superusers/list.html.twig', [
  439.             'superusers' => $rows,
  440.         ]);
  441.     }
  443.     public function superusersNew(Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  444.     {
  445.         if (!$this->getUser() || !is_object($this->getUser())) {
  446.             return $this->redirectToRoute('logout');
  447.         }
  449.         $empresas = $em->getRepository(Empresa::class)->findAll();
  450.         $formData = [
  451.             'email' => '',
  452.             'status' => 'ENABLED',
  453.             'empresas' => [],
  454.         ];
  456.         if ($request->isMethod('POST')) {
  457.             $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  458.             $password = (string)$request->request->get('password', '');
  459.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  460.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  462.             $formData['email'] = $email;
  463.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  464.             $formData['empresas'] = $empresaIds;
  466.             try {
  467.                 $service->createSuperuser($email, $password, $empresaIds, $enabled);
  468.                 $this->addFlash('success', 'Superusuario creado correctamente.');
  469.                 return $this->redirectToRoute('superusers_list');
  470.             } catch (\Throwable $e) {
  471.                 $this->addFlash('danger', $e->getMessage());
  472.             }
  473.         }
  475.         return $this->render('superusers/form.html.twig', [
  476.             'title' => 'Crear superusuario',
  477.             'is_edit' => false,
  478.             'form' => $formData,
  479.             'empresas' => $empresas,
  480.         ]);
  481.     }
  483.     public function superusersEdit(string $email, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  484.     {
  485.         if (!$this->getUser() || !is_object($this->getUser())) {
  486.             return $this->redirectToRoute('logout');
  487.         }
  489.         $email = $this->normalizeSuperuserEmail($email);
  490.         $existingRows = $em->getConnection()->fetchAllAssociative(
  491.             "SELECT empresa_id, status
  492.              FROM users
  493.              WHERE LOWER(email) = :email AND is_admin = :isAdmin",
  494.             ['email' => $email, 'isAdmin' => self::SUPERUSER_IS_ADMIN]
  495.         );
  497.         if (count($existingRows) === 0) {
  498.             $this->addFlash('warning', 'Superusuario no encontrado.');
  499.             return $this->redirectToRoute('superusers_list');
  500.         }
  502.         $selectedEmpresaIds = [];
  503.         $hasEnabled = false;
  504.         foreach ($existingRows as $row) {
  505.             $selectedEmpresaIds[] = (int)$row['empresa_id'];
  506.             $hasEnabled = $hasEnabled || strtoupper((string)$row['status']) === 'ENABLED';
  507.         }
  508.         $selectedEmpresaIds = array_values(array_unique($selectedEmpresaIds));
  509.         sort($selectedEmpresaIds);
  511.         $empresas = $em->getRepository(Empresa::class)->findAll();
  512.         $formData = [
  513.             'email' => $email,
  514.             'status' => $hasEnabled ? 'ENABLED' : 'DISABLED',
  515.             'empresas' => $selectedEmpresaIds,
  516.         ];
  518.         if ($request->isMethod('POST')) {
  519.             $newPassword = trim((string)$request->request->get('password', ''));
  520.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  521.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  523.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  524.             $formData['empresas'] = $empresaIds;
  526.             try {
  527.                 $service->updateSuperuser($email, ($newPassword === '' ? null : $newPassword), $empresaIds, $enabled);
  528.                 $this->addFlash('success', 'Superusuario actualizado correctamente.');
  529.                 return $this->redirectToRoute('superusers_list');
  530.             } catch (\Throwable $e) {
  531.                 $this->addFlash('danger', $e->getMessage());
  532.             }
  533.         }
  535.         return $this->render('superusers/form.html.twig', [
  536.             'title' => 'Editar superusuario',
  537.             'is_edit' => true,
  538.             'form' => $formData,
  539.             'empresas' => $empresas,
  540.         ]);
  541.     }
  543.     public function superusersDeleteLink(string $email, int $empresaId, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  544.     {
  545.         if (!$this->getUser() || !is_object($this->getUser())) {
  546.             return $this->redirectToRoute('logout');
  547.         }
  548.         if (!$request->isMethod('POST')) {
  549.             return $this->redirectToRoute('superusers_list');
  550.         }
  552.         $email = $this->normalizeSuperuserEmail($email);
  553.         $rows = $em->getConnection()->fetchAllAssociative(
  554.             "SELECT empresa_id, status
  555.              FROM users
  556.              WHERE LOWER(email) = :email AND is_admin = :isAdmin",
  557.             ['email' => $email, 'isAdmin' => self::SUPERUSER_IS_ADMIN]
  558.         );
  560.         if (count($rows) === 0) {
  561.             $this->addFlash('warning', 'Superusuario no encontrado.');
  562.             return $this->redirectToRoute('superusers_list');
  563.         }
  565.         $targetEmpresaIds = [];
  566.         $enabled = false;
  567.         foreach ($rows as $row) {
  568.             $currentEmpresaId = (int)$row['empresa_id'];
  569.             if ($currentEmpresaId !== $empresaId) {
  570.                 $targetEmpresaIds[] = $currentEmpresaId;
  571.             }
  572.             $enabled = $enabled || strtoupper((string)$row['status']) === 'ENABLED';
  573.         }
  575.         try {
  576.             $service->updateSuperuser($email, null, $targetEmpresaIds, $enabled);
  577.             $this->addFlash('success', 'Vinculación eliminada correctamente.');
  578.         } catch (\Throwable $e) {
  579.             $this->addFlash('danger', $e->getMessage());
  580.         }
  582.         return $this->redirectToRoute('superusers_edit', ['email' => $email]);
  583.     }
  585.     public function superusersCheckEmail(Request $request, EntityManagerInterface $em): JsonResponse
  586.     {
  587.         $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  588.         $empresaIds = $this->readEmpresaIdsFromRequest($request);
  590.         if ($email === '') {
  591.             return new JsonResponse(['exists' => false, 'message' => 'email_required'], 400);
  592.         }
  593.         if (count($empresaIds) === 0) {
  594.             return new JsonResponse(['exists' => false, 'message' => 'no_empresas']);
  595.         }
  597.         $count = (int)$em->createQueryBuilder()
  598.             ->select('COUNT(u.id)')
  599.             ->from(Usuario::class, 'u')
  600.             ->where('LOWER(u.email) = :email')
  601.             ->andWhere('u.isAdmin = :isAdmin')
  602.             ->andWhere('IDENTITY(u.empresa) IN (:empresaIds)')
  603.             ->setParameter('email', $email)
  604.             ->setParameter('isAdmin', self::SUPERUSER_IS_ADMIN)
  605.             ->setParameter('empresaIds', $empresaIds)
  606.             ->getQuery()
  607.             ->getSingleScalarResult();
  609.         return new JsonResponse([
  610.             'exists' => $count > 0,
  611.             'count' => $count,
  612.         ]);
  613.     }
  615.     private function normalizeSuperuserEmail(string $email): string
  616.     {
  617.         return strtolower(trim($email));
  618.     }
  620.     /**
  621.      * @return int[]
  622.      */
  623.     private function readEmpresaIdsFromRequest(Request $request): array
  624.     {
  625.         $raw = $request->request->all('empresas');
  626.         if (!is_array($raw)) {
  627.             $raw = [];
  628.         }
  630.         $ids = [];
  631.         foreach ($raw as $empresaId) {
  632.             $id = (int)$empresaId;
  633.             if ($id > 0) {
  634.                 $ids[] = $id;
  635.             }
  636.         }
  638.         $ids = array_values(array_unique($ids));
  639.         sort($ids);
  640.         return $ids;
  641.     }
  643.     public function azureResourcesList(EntityManagerInterface $em)
  644.     {
  645.         if (!$this->getUser() || !is_object($this->getUser())) {
  646.             return $this->redirectToRoute('logout');
  647.         }
  649.         $resources = [];
  650.         try {
  651.             $resources = $this->loadAzureDiResources($em);
  652.         } catch (\Throwable $e) {
  653.             $this->addFlash('danger', 'No se pudo cargar el listado de recursos IA: ' . $e->getMessage());
  654.         }
  656.         return $this->render('azure_resources/list.html.twig', [
  657.             'resources' => $resources,
  658.         ]);
  659.     }
  661.     public function azureResourcesNew(Request $request, EntityManagerInterface $em)
  662.     {
  663.         if (!$this->getUser() || !is_object($this->getUser())) {
  664.             return $this->redirectToRoute('logout');
  665.         }
  667.         $resource = [
  668.             'name' => '',
  669.             'endpoint' => '',
  670.             'api_key' => '',
  671.         ];
  673.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  674.             $resource['name'] = trim((string)$request->request->get('name', ''));
  675.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  676.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  678.             if ($resource['name'] === '' || $resource['endpoint'] === '' || $resource['api_key'] === '') {
  679.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  680.             } else {
  681.                 try {
  682.                     $em->getConnection()->insert('azure_di_resources', [
  683.                         'name' => $resource['name'],
  684.                         'endpoint' => $resource['endpoint'],
  685.                         'api_key' => $resource['api_key'],
  686.                     ]);
  687.                     $this->addFlash('success', 'Recurso IA creado correctamente.');
  688.                     return $this->redirectToRoute('azure_resources_list');
  689.                 } catch (\Throwable $e) {
  690.                     $this->addFlash('danger', 'No se pudo crear el recurso: ' . $e->getMessage());
  691.                 }
  692.             }
  693.         }
  695.         return $this->render('azure_resources/new.html.twig', [
  696.             'resource' => $resource,
  697.         ]);
  698.     }
  700.     public function azureResourcesEdit(Request $request, EntityManagerInterface $em)
  701.     {
  702.         if (!$this->getUser() || !is_object($this->getUser())) {
  703.             return $this->redirectToRoute('logout');
  704.         }
  706.         $id = (int)$request->get('id');
  707.         $resource = $this->loadAzureDiResourceById($em, $id);
  708.         if (!$resource) {
  709.             $this->addFlash('warning', 'Recurso no encontrado.');
  710.             return $this->redirectToRoute('azure_resources_list');
  711.         }
  713.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  714.             $resource['name'] = trim((string)$request->request->get('name', ''));
  715.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  716.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  718.             if ($resource['name'] === '' || $resource['endpoint'] === '' || $resource['api_key'] === '') {
  719.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  720.             } else {
  721.                 try {
  722.                     $em->getConnection()->update('azure_di_resources', [
  723.                         'name' => $resource['name'],
  724.                         'endpoint' => $resource['endpoint'],
  725.                         'api_key' => $resource['api_key'],
  726.                     ], [
  727.                         'id' => $id,
  728.                     ]);
  729.                     $this->addFlash('success', 'Recurso IA actualizado correctamente.');
  730.                     return $this->redirectToRoute('azure_resources_list');
  731.                 } catch (\Throwable $e) {
  732.                     $this->addFlash('danger', 'No se pudo actualizar el recurso: ' . $e->getMessage());
  733.                 }
  734.             }
  735.         }
  737.         return $this->render('azure_resources/edit.html.twig', [
  738.             'resource' => $resource,
  739.         ]);
  740.     }
  742.     public function azureResourcesDelete(Request $request, EntityManagerInterface $em)
  743.     {
  744.         if (!$this->getUser() || !is_object($this->getUser())) {
  745.             return $this->redirectToRoute('logout');
  746.         }
  748.         $id = (int)$request->get('id');
  749.         if ($id <= 0) {
  750.             $this->addFlash('warning', 'Identificador de recurso no valido.');
  751.             return $this->redirectToRoute('azure_resources_list');
  752.         }
  754.         try {
  755.             $em->getConnection()->delete('azure_di_resources', ['id' => $id]);
  756.             $this->addFlash('success', 'Recurso IA eliminado correctamente.');
  757.         } catch (\Throwable $e) {
  758.             $this->addFlash('danger', 'No se pudo eliminar el recurso: ' . $e->getMessage());
  759.         }
  761.         return $this->redirectToRoute('azure_resources_list');
  762.     }
  764.     public function azureApiResourceModels(Request $request, EntityManagerInterface $em): JsonResponse
  765.     {
  766.         if (!$this->getUser() || !is_object($this->getUser())) {
  767.             return new JsonResponse(['error' => 'unauthorized'], 401);
  768.         }
  770.         $resource = $this->loadAzureDiResourceById($em, (int)$request->get('id'));
  771.         if (!$resource) {
  772.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  773.         }
  775.         try {
  776.             $payload = $this->azureRequest(
  777.                 (string)$resource['endpoint'],
  778.                 (string)$resource['api_key'],
  779.                 '/documentintelligence/documentModels'
  780.             );
  781.         } catch (\Throwable $e) {
  782.             $status = (int)$e->getCode();
  783.             if ($status < 400 || $status > 599) {
  784.                 $status = 502;
  785.             }
  786.             return new JsonResponse(['error' => $e->getMessage()], $status);
  787.         }
  789.         $models = $payload['value'] ?? [];
  790.         if (!is_array($models)) {
  791.             $models = [];
  792.         }
  794.         $normalizedModels = [];
  795.         foreach ($models as $model) {
  796.             if (!is_array($model)) {
  797.                 continue;
  798.             }
  799.             $normalizedModels[] = [
  800.                 'modelId' => (string)($model['modelId'] ?? ''),
  801.                 'description' => (string)($model['description'] ?? ''),
  802.                 'createdDateTime' => (string)($model['createdDateTime'] ?? ''),
  803.                 'expirationDateTime' => (string)($model['expirationDateTime'] ?? ''),
  804.                 'type' => $this->classifyModelType($model),
  805.             ];
  806.         }
  808.         usort($normalizedModels, static function (array $a, array $b): int {
  809.             return strcmp($a['modelId'] ?? '', $b['modelId'] ?? '');
  810.         });
  812.         return new JsonResponse([
  813.             'resource' => [
  814.                 'id' => (int)$resource['id'],
  815.                 'name' => (string)$resource['name'],
  816.             ],
  817.             'models' => $normalizedModels,
  818.         ]);
  819.     }
  821.     public function azureApiResourceModelDetail(Request $request, EntityManagerInterface $em): JsonResponse
  822.     {
  823.         if (!$this->getUser() || !is_object($this->getUser())) {
  824.             return new JsonResponse(['error' => 'unauthorized'], 401);
  825.         }
  827.         $resource = $this->loadAzureDiResourceById($em, (int)$request->get('id'));
  828.         if (!$resource) {
  829.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  830.         }
  832.         $modelId = trim((string)$request->get('modelId'));
  833.         if ($modelId === '') {
  834.             return new JsonResponse(['error' => 'model_id_required'], 400);
  835.         }
  837.         try {
  838.             $detail = $this->azureRequest(
  839.                 (string)$resource['endpoint'],
  840.                 (string)$resource['api_key'],
  841.                 '/documentintelligence/documentModels/' . rawurlencode($modelId)
  842.             );
  843.             $mapped = $this->mapAzureSchemaToDefinitions($detail);
  844.         } catch (\Throwable $e) {
  845.             $status = (int)$e->getCode();
  846.             if ($status < 400 || $status > 599) {
  847.                 $status = 502;
  848.             }
  849.             return new JsonResponse(['error' => $e->getMessage()], $status);
  850.         }
  852.         return new JsonResponse([
  853.             'model' => $detail,
  854.             'type' => $this->classifyModelType($detail),
  855.             'preview' => [
  856.                 'header' => $mapped['header'],
  857.                 'lines' => $mapped['lines'],
  858.             ],
  859.         ]);
  860.     }
  862.     private function loadAzureDiResources(EntityManagerInterface $em): array
  863.     {
  864.         $rows = $em->getConnection()->executeQuery(
  865.             'SELECT id, name, endpoint, api_key, created_at, updated_at FROM azure_di_resources ORDER BY name ASC'
  866.         )->fetchAllAssociative();
  868.         foreach ($rows as &$row) {
  869.             $row['id'] = (int)$row['id'];
  870.         }
  872.         return $rows;
  873.     }
  875.     private function loadAzureDiResourceById(EntityManagerInterface $em, int $id): ?array
  876.     {
  877.         if ($id <= 0) {
  878.             return null;
  879.         }
  881.         $row = $em->getConnection()->fetchAssociative(
  882.             'SELECT id, name, endpoint, api_key, created_at, updated_at
  883.              FROM azure_di_resources
  884.              WHERE id = :id',
  885.             ['id' => $id]
  886.         );
  888.         if (!$row) {
  889.             return null;
  890.         }
  892.         $row['id'] = (int)$row['id'];
  893.         return $row;
  894.     }
  896.     private function normalizeAzureEndpoint(string $endpoint): string
  897.     {
  898.         $endpoint = trim($endpoint);
  899.         if ($endpoint === '') {
  900.             return '';
  901.         }
  903.         if (!preg_match('#^https?://#i', $endpoint)) {
  904.             $endpoint = 'https://' . $endpoint;
  905.         }
  907.         return rtrim($endpoint, '/');
  908.     }
  910.     private function azureRequest(string $endpoint, string $apiKey, string $path, array $query = []): array
  911.     {
  912.         $endpoint = $this->normalizeAzureEndpoint($endpoint);
  913.         if ($endpoint === '' || trim($apiKey) === '') {
  914.             throw new \RuntimeException('Recurso IA incompleto.', 400);
  915.         }
  917.         $query = array_merge(['api-version' => self::AZURE_DI_API_VERSION], $query);
  918.         $url = $endpoint . '/' . ltrim($path, '/') . '?' . http_build_query($query);
  920.         $ch = curl_init();
  921.         curl_setopt($ch, CURLOPT_URL, $url);
  922.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  923.             'Accept: application/json',
  924.             'Ocp-Apim-Subscription-Key: ' . $apiKey,
  925.         ]);
  926.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  927.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 8);
  928.         curl_setopt($ch, CURLOPT_TIMEOUT, 25);
  930.         $response = curl_exec($ch);
  931.         $curlError = curl_error($ch);
  932.         $statusCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
  933.         curl_close($ch);
  935.         if ($curlError) {
  936.             throw new \RuntimeException('Error de red con recurso IA: ' . $curlError, 0);
  937.         }
  939.         $decoded = [];
  940.         if (is_string($response) && trim($response) !== '') {
  941.             $decoded = json_decode($response, true);
  942.             if (!is_array($decoded)) {
  943.                 throw new \RuntimeException('Respuesta no valida del recurso IA.', 502);
  944.             }
  945.         }
  947.         if ($statusCode < 200 || $statusCode >= 300) {
  948.             $detail = $decoded['error']['message'] ?? $decoded['message'] ?? ('HTTP ' . $statusCode);
  949.             throw new \RuntimeException((string)$detail, $statusCode);
  950.         }
  952.         return $decoded;
  953.     }
  955.     private function classifyModelType(array $model): string
  956.     {
  957.         $expiration = trim((string)($model['expirationDateTime'] ?? ''));
  958.         return $expiration !== '' ? 'custom' : 'prebuilt';
  959.     }
  961.     public function addEmpresa(Request $req, EntityManagerInterface $em)
  962.     {
  963.         //dd(\shell_exec('whoami'));
  964.         if (!$this->getUser() || !is_object($this->getUser())) {
  965.             return $this->redirectToRoute('logout');
  966.         }
  967.         $azureResources = [];
  968.         try {
  969.             $azureResources = $this->loadAzureDiResources($em);
  970.         } catch (\Throwable $e) {
  971.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  972.         }
  974.         if ($req->request->get("submit") != "") {
  975.             $data = $req->request->all();
  976.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, 4);
  978.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  979.             $mailMonitorEnabled = isset($data['modulo_mailMonitor']) && $toBool($data['modulo_mailMonitor']);
  980.             $data['modulo_extraccion'] = isset($data['modulo_extraccion']) && $toBool($data['modulo_extraccion']) ? 1 : 0;
  981.             $data['modulo_expowin'] = isset($data['modulo_expowin']) && $toBool($data['modulo_expowin']) ? 1 : 0;
  983.             $azureResource = null;
  984.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  985.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  987.             if ($data['modulo_extraccion'] === 1) {
  988.                 if ($azureResourceId <= 0 || $azureModelId === '') {
  989.                     $this->addFlash('danger', 'Para activar extraccion debes seleccionar recurso y modelo IA.');
  990.                     return $this->render('empresa/_add.html.twig', [
  991.                         'azure_resources' => $azureResources,
  992.                         'modulos' => [
  993.                             'extraction_model' => 0,
  994.                             'limite_archivos' => isset($data['limite_archivos']) ? (int)$data['limite_archivos'] : 500,
  995.                         ],
  996.                     ]);
  997.                 }
  999.                 $azureResource = $this->loadAzureDiResourceById($em, $azureResourceId);
  1000.                 if (!$azureResource) {
  1001.                     $this->addFlash('danger', 'El recurso IA seleccionado no existe.');
  1002.                     return $this->render('empresa/_add.html.twig', [
  1003.                         'azure_resources' => $azureResources,
  1004.                         'modulos' => [
  1005.                             'extraction_model' => 0,
  1006.                             'limite_archivos' => isset($data['limite_archivos']) ? (int)$data['limite_archivos'] : 500,
  1007.                         ],
  1008.                     ]);
  1009.                 }
  1011.                 try {
  1012.                     $this->azureRequest(
  1013.                         (string)$azureResource['endpoint'],
  1014.                         (string)$azureResource['api_key'],
  1015.                         '/documentintelligence/documentModels/' . rawurlencode($azureModelId)
  1016.                     );
  1017.                 } catch (\Throwable $e) {
  1018.                     $this->addFlash('danger', 'No se pudo validar el modelo IA: ' . $e->getMessage());
  1019.                     return $this->render('empresa/_add.html.twig', [
  1020.                         'azure_resources' => $azureResources,
  1021.                         'modulos' => [
  1022.                             'extraction_model' => 0,
  1023.                             'limite_archivos' => isset($data['limite_archivos']) ? (int)$data['limite_archivos'] : 500,
  1024.                         ],
  1025.                     ]);
  1026.                 }
  1027.             } else {
  1028.                 $data['azure_resource_id'] = 0;
  1029.                 $data['azure_model_id'] = '';
  1030.                 $data['extraction_model'] = 0;
  1031.                 $data['modulo_expowin'] = 0;
  1032.             }
  1034.             // Crear nombre de base de datos y credenciales aleatorios
  1035.             $dbName = 'doc_' . bin2hex(random_bytes(3));
  1036.             $dbUser = 'doc_' . bin2hex(random_bytes(2));
  1037.             $dbPass = bin2hex(random_bytes(8));
  1038.             $dbHost = 'localhost';
  1039.             $dbPort = '3306';
  1041.             // Credenciales de HestiaCP desde variables de entorno
  1042.             $hestiaApiUrl = $_ENV['HESTIA_API_URL'];
  1043.             $hestiaApiUser = $_ENV['HESTIA_API_USER'];
  1044.             $hestiaApiPass = $_ENV['HESTIA_API_PASS'];
  1045.             $hestiaOwner   = $_ENV['HESTIA_OWNER'];
  1046.             $accessKeyId   = $_ENV['HESTIA_ACCESS_KEY_ID'] ?? '';
  1047.             $secretKey     = $_ENV['HESTIA_SECRET_KEY'] ?? '';
  1049.             // Variables para el script de bash
  1050.             $ocrBinary  = $_ENV['OCR_BINARY'];
  1051.             $filesPath  = $_ENV['FILES_PATH'];
  1053.             $owner = $hestiaOwner; // o el dueńo del hosting
  1055.             $postFields = http_build_query([
  1056.                 'user' => $hestiaApiUser,
  1057.                 'password' => $hestiaApiPass,
  1058.                 'returncode' => 'yes',
  1059.                 'cmd' => 'v-add-database',
  1060.                 'arg1' => $owner,
  1061.                 'arg2' => $dbName,
  1062.                 'arg3' => $dbUser,
  1063.                 'arg4' => $dbPass,
  1064.                 'arg5' => 'mysql'
  1065.             ]);
  1066.             //dd($postFields);            
  1067.             $headers = [
  1068.                 'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  1069.             ];
  1072.             $ch = curl_init();
  1073.             curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  1074.             curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  1075.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1076.             curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  1077.             curl_setopt($ch, CURLOPT_POST, true);
  1078.             curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  1079.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  1081.             $response = curl_exec($ch);
  1082.             $error = curl_error($ch);
  1083.             curl_close($ch);
  1085.             if ($error || trim($response) !== '0') {
  1086.                 $this->addFlash('danger', 'Error al crear la base de datos en HestiaCP: ' . ($error ?: $response));
  1087.                 return $this->redirectToRoute('app_empresa_new');
  1088.             }
  1090.             //Añadir sql
  1091.             $sqlFile = __DIR__ . '/../../db/db_base.sql'; // Ajusta la ruta si está en otro sitio
  1093.             if (!file_exists($sqlFile)) {
  1094.                 $this->addFlash('danger', 'Archivo db_base.sql no encontrado.');
  1095.                 return $this->redirectToRoute('app_empresa_new');
  1096.             }
  1099.             $mysqli = new \mysqli($dbHost, "{$owner}_{$dbUser}", $dbPass, "{$owner}_{$dbName}", (int)$dbPort);
  1101.             if ($mysqli->connect_error) {
  1102.                 $this->addFlash('danger', 'Error al conectar a la base de datos: ' . $mysqli->connect_error);
  1103.                 return $this->redirectToRoute('app_empresa_new');
  1104.             }
  1106.             $sql = file_get_contents($sqlFile);
  1108.             // Eliminar lĂ­neas con DELIMITER
  1109.             $sql = preg_replace('/DELIMITER\s+\$\$/', '', $sql);
  1110.             $sql = preg_replace('/DELIMITER\s+;/', '', $sql);
  1112.             // Separar por ';;' si los triggers usan ese delimitador (ajusta si es $$)
  1113.             $statements = explode('$$', $sql);
  1115.             foreach ($statements as $stmt) {
  1116.                 $stmt = trim($stmt);
  1117.                 if ($stmt) {
  1118.                     if (!$mysqli->multi_query($stmt)) {
  1119.                         $this->addFlash('danger', 'Error ejecutando SQL: ' . $mysqli->error);
  1120.                         return $this->redirectToRoute('app_empresa_new');
  1121.                     }
  1122.                     // Limpiar cualquier resultado intermedio
  1123.                     while ($mysqli->more_results() && $mysqli->next_result()) {
  1124.                         $mysqli->use_result();
  1125.                     }
  1126.                 }
  1127.             }
  1129.             $updateSql = "UPDATE users SET email = '" . $mysqli->real_escape_string((string)$data["user"]) . "' WHERE id = 1";
  1131.             if (!$mysqli->query($updateSql)) {
  1132.                 $this->addFlash('danger', 'Error al actualizar usuario: ' . $mysqli->error);
  1133.                 return $this->redirectToRoute('app_empresa_new');
  1134.             }
  1136.             // Guardar parámetros (activeUsers + modulos_*) en la BD del cliente
  1137.             $localExtractionModelId = 0;
  1138.             if ($data['modulo_extraccion'] === 1) {
  1139.                 try {
  1140.                     $localExtractionModelId = $this->registerModelInClientDb(
  1141.                         $mysqli,
  1142.                         $azureResource ?? [],
  1143.                         $azureModelId
  1144.                     );
  1145.                 } catch (\Throwable $e) {
  1146.                     $this->addFlash('danger', 'No se pudo registrar el modelo en la BBDD cliente: ' . $e->getMessage());
  1147.                     $mysqli->close();
  1148.                     return $this->redirectToRoute('app_empresa_new');
  1149.                 }
  1150.             }
  1151.             $data['extraction_model'] = $localExtractionModelId;
  1153.             // SUBIR LOGO PERSONALIZADO (SI LO HAY) ===
  1154.             $customLogoFile = null;
  1155.             try {
  1156.                 $customLogoFile = $this->uploadEmpresaLogo($req);
  1157.             } catch (\Throwable $e) {
  1158.                 // Aquí decides si quieres que esto sea fatal o solo un aviso
  1159.                 $this->addFlash('warning', 'El logo personalizado no se pudo subir: ' . $e->getMessage());
  1160.                 // Si quieres abortar todo el proceso por fallo de logo, haz return+redirect aquí.
  1161.             }
  1163.             // Guardar logo en la BD del cliente
  1164.             $this->saveEmpresaLogo($mysqli, $data, $customLogoFile);
  1166.             // Actualizar/insertar license (capacityGb y users) en la BD del cliente
  1167.             $this->upsertLicense(
  1168.                 $mysqli,
  1169.                 $data,
  1170.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== '' ? (int)$data['maxDiskQuota'] : 200,
  1171.                 isset($data['maxActiveUsers']) && $data['maxActiveUsers'] !== '' ? (int)$data['maxActiveUsers'] : 3
  1172.             );
  1174.             // Guardar parametros (activeUsers + modulos_*) en la BD del cliente
  1175.             $this->saveEmpresaParametros($mysqli, $data);
  1177.             // Crear y persistir la empresa
  1178.             $emp = new Empresa();
  1179.             $emp->setName($data["name"]);
  1180.             $emp->setMaxDiskQuota((int)$data["maxDiskQuota"]);
  1181.             $emp->setMaxThreads($maxThreads);
  1185.             $em->persist($emp);
  1186.             $em->flush();
  1188.             $conexionBD = new ConexionBD();
  1189.             $conexionBD->setDbName($owner . "_" . $dbName);
  1190.             $conexionBD->setDbUser($owner . "_" . $dbUser);
  1191.             $conexionBD->setDbPassword($dbPass);
  1192.             $conexionBD->setDbUrl($dbHost);
  1193.             $conexionBD->setDbPort($dbPort);
  1194.             $em->persist($conexionBD);
  1195.             $em->flush();
  1198.             $emp->setConexionBD($conexionBD);
  1199.             $em->persist($emp);
  1200.             $em->flush();
  1202.             //crear usuario
  1203.             $user = new \App\Entity\Usuario();
  1204.             $user->setEmail($data["user"]);
  1205.             $user->setEmpresa($emp);
  1206.             $user->setPassword("dscsdcsno2234dwvw");
  1207.             $user->setStatus(1);
  1208.             $user->setIsAdmin(2);
  1209.             $user->setConnection($conexionBD->getId());
  1211.             $em->persist($user);
  1212.             $em->flush();
  1214.             //crear el script de bash
  1215.             $company_name = $emp->getId();
  1217.             // "DOCU_MAX_THREADS=" por defecto 4
  1218.             // "NO" al final es para desactivar FTP
  1220.             // Crear archivo .service
  1221.             $empresaName = (string)($data['name'] ?? '');
  1222.             $serviceContent = <<<EOT
  1223. [Unit]
  1224. Description={$empresaName} DocuManager OCR
  1225. Requires=mariadb.service
  1226. After=mariadb.service
  1228. [Service]
  1229. Type=simple
  1230. Environment="DOCU_MAX_THREADS=$maxThreads"
  1231. ExecStart=$ocrBinary localhost/{$owner}_{$dbName} {$owner}_{$dbUser} {$dbPass} {$filesPath}/{$company_name} NO
  1232. Restart=always
  1233. User=root
  1235. [Install]
  1236. WantedBy=multi-user.target
  1237. EOT;
  1240.             // Guardar contenido temporal en un archivo dentro de /tmp
  1241.             $serviceName = $company_name . "-documanager.service";
  1242.             $tmpServicePath = "/tmp/$serviceName";
  1243.             file_put_contents($tmpServicePath, $serviceContent);
  1244.             \chmod($tmpServicePath, 0644);
  1246.             // Mover el archivo y habilitar el servicio desde PHP con shell_exec
  1247.             $commands = [
  1248.                 "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  1249.                 "sudo /bin/systemctl daemon-reload",
  1250.                 "sudo /bin/systemctl enable $serviceName",
  1251.                 "sudo /bin/systemctl start $serviceName",
  1252.             ];
  1253.             $errors = [];
  1254.             foreach ($commands as $cmd) {
  1255.                 $output = \shell_exec($cmd . " 2>&1");
  1256.                 if ($output !== null) {
  1257.                     // Puedes loguearlo si quieres para ver errores
  1258.                     error_log("CMD OUTPUT: $cmd\n$output");
  1259.                     $errors[] = "CMD OUTPUT: $cmd\n$output";
  1260.                 }
  1261.             }
  1263.             // === Crear servicio AZURE DI por tenant ===
  1264.             $azureBasePort = 12000;
  1265.             $tenantId      = (int)$emp->getId();
  1266.             $port          = $this->azurePortForTenant($tenantId, $azureBasePort, 20999);
  1267.             $serviceName   = $tenantId . "-azuredi.service";
  1268.             $workdir       = $this->azureDiWorkdirFromEnv();
  1269.             if ($workdir !== '') {
  1270.                 $logsDir = $workdir . "/logs/" . $tenantId;
  1272.                 // Asegura carpeta de logs
  1273.                 @mkdir($logsDir, 0775, true);
  1275.                 $serviceContent = <<<EOT
  1276.                 [Unit]
  1277.                 Description=DocuManager Azure DI (tenant {$tenantId})
  1278.                 After=network.target
  1280.                 [Service]
  1281.                 User=root
  1282.                 WorkingDirectory={$workdir}
  1283.                 Environment=APP_HOST=127.0.0.1
  1284.                 Environment=APP_PORT={$port}
  1285.                 Environment=LOG_DIR={$logsDir}
  1286.                 Environment=PYTHONUNBUFFERED=1
  1287.                 Environment=MAX_CONCURRENT=20
  1288.                 Environment="PATH=/opt/azure-di/.venv/bin:/usr/local/bin:/usr/bin"
  1289.                 EnvironmentFile=-{$workdir}/.env
  1290.                 ExecStart=/opt/azure-di/.venv/bin/python -m uvicorn app.main:app --host 127.0.0.1 --port {$port} --proxy-headers --workers 2
  1291.                 Restart=always
  1292.                 RestartSec=2
  1293.                 StandardOutput=journal
  1294.                 StandardError=journal
  1296.                 [Install]
  1297.                 WantedBy=multi-user.target
  1298.                 EOT;
  1300.                 $tmpServicePath = "/tmp/{$serviceName}";
  1301.                 file_put_contents($tmpServicePath, $serviceContent);
  1302.                 @chmod($tmpServicePath, 0644);
  1304.                 $cmds = [
  1305.                     "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  1306.                     "sudo /bin/systemctl daemon-reload",
  1307.                     "sudo /bin/systemctl enable {$serviceName}",
  1308.                     "sudo /bin/systemctl start {$serviceName}",
  1309.                 ];
  1310.                 foreach ($cmds as $cmd) {
  1311.                     $out = \shell_exec($cmd . " 2>&1");
  1312.                     if ($out !== null) {
  1313.                         error_log("AZURE-DI CMD: $cmd\n$out");
  1314.                     }
  1315.                 }
  1316.             } else {
  1317.                 $this->addFlash('warning', 'No se pudo crear el servicio de extraccion IA: falta configuracion de entorno.');
  1318.             }
  1320.             // === Crear servicio/timer Mail Monitor si el modulo esta activo ===
  1321.             if ($mailMonitorEnabled) {
  1322.                 $this->ensureMailMonitorService(
  1323.                     (int)$company_name,
  1324.                     (string)$dbHost,
  1325.                     (string)$dbPort,
  1326.                     (string)$owner . "_" . (string)$dbUser,
  1327.                     (string)$dbPass,
  1328.                     (string)$owner . "_" . (string)$dbName,
  1329.                     (string)$filesPath
  1330.                 );
  1331.             }
  1333.             if (count($errors) > 0) {
  1334.                 $this->addFlash('success', 'Empresa y base de datos creadas correctamente: ' . implode(" | ", $errors));
  1335.             }
  1339.             $this->addFlash('success', 'Empresa y base de datos creadas correctamente.');
  1340.             return $this->redirectToRoute('list');
  1341.         } else {
  1342.             // Carga recursos Azure DI para el formulario de alta
  1343.             return $this->render('empresa/_add.html.twig', [
  1344.                 'azure_resources' => $azureResources,
  1345.                 'modulos' => [
  1346.                     'extraction_model' => 0,
  1347.                     'limite_archivos' => 500,
  1348.                 ],
  1349.             ]);
  1350.         }
  1351.     }
  1353.     private function saveEmpresaParametros(\mysqli $mysqli, array $data): void
  1354.     {
  1355.         // Helpers
  1356.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  1357.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  1359.         // Keys y valores tal y como quieres guardarlos
  1360.         $paramMap = [
  1361.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  1363.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  1365.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  1366.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  1367.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  1368.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  1369.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  1370.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  1371.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  1372.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  1373.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  1374.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  1375.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  1376.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  1378.             'limite_archivos'  => $getInt($data, 'limite_archivos', 500),
  1380.             'extraction_model'  => $getInt($data, 'extraction_model', 0),
  1381.         ];
  1383.         if ($paramMap['modulo_extraccion'] === 0) {
  1384.             $paramMap['modulo_expowin'] = 0;
  1385.         }
  1387.         // RECOMENDADO en tu SQL base:
  1388.         // ALTER TABLE parametros ADD UNIQUE KEY uniq_nombre (nombre);
  1389.         $mysqli->begin_transaction();
  1390.         try {
  1391.             $stmt = $mysqli->prepare("
  1392.                 INSERT INTO parametros (nombre, valor)
  1393.                 VALUES (?, ?)
  1394.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  1395.             ");
  1396.             if (!$stmt) {
  1397.                 throw new \RuntimeException('Prepare parametros: ' . $mysqli->error);
  1398.             }
  1400.             foreach ($paramMap as $nombre => $valor) {
  1401.                 // valor es TEXT en tu esquema: bindeamos como string
  1402.                 $v = (string)$valor;
  1403.                 $stmt->bind_param('ss', $nombre, $v);
  1404.                 if (!$stmt->execute()) {
  1405.                     throw new \RuntimeException("Guardar parámetro $nombre: " . $stmt->error);
  1406.                 }
  1407.             }
  1409.             $stmt->close();
  1410.             $mysqli->commit();
  1411.         } catch (\Throwable $e) {
  1412.             $mysqli->rollback();
  1414.             // Si NO puedes ańadir UNIQUE(nombre), usa fallback DELETE+INSERT:
  1415.             // $this->saveParametrosFallback($mysqli, $paramMap);
  1417.             throw $e;
  1418.         }
  1419.     }
  1421.     private function saveEmpresaLogo(\mysqli $mysqli, array $data, ?string $customLogoFile = null): void
  1422.     {
  1423.         $this->logLogo('empresa_logo_save.log', '--- NUEVA LLAMADA saveEmpresaLogo ---');
  1424.         $this->logLogo('empresa_logo_save.log', 'customLogoFile = ' . var_export($customLogoFile, true));
  1425.         $this->logLogo('empresa_logo_save.log', 'data[empresa_vendor] = ' . var_export($data['empresa_vendor'] ?? null, true));
  1427.         // 1) Decidir qué logo vamos a guardar
  1428.         $logoFile = null;
  1430.         // --- PRIORIDAD: LOGO PERSONALIZADO ---
  1431.         if ($customLogoFile !== null && $customLogoFile !== '') {
  1432.             $logoFile = $customLogoFile;
  1433.             $this->logLogo('empresa_logo_save.log', 'Usando logo personalizado: ' . $logoFile);
  1434.         } else {
  1435.             // --- SI NO HAY PERSONALIZADO, USAMOS EL SELECT DE EMPRESA ---
  1436.             if (!isset($data['empresa_vendor']) || $data['empresa_vendor'] === '') {
  1437.                 $this->logLogo('empresa_logo_save.log', 'No hay empresa_vendor y no hay logo custom. No hago nada.');
  1438.                 return;
  1439.             }
  1441.             $empresa = $data['empresa_vendor'];
  1442.             $empresaKey = strtolower(trim((string)$empresa));
  1444.             $logoMap = [
  1445.                 'docunecta'  => 'DocuManager_transparente.png',
  1446.                 'docuindexa' => 'DocuIndexa.png',
  1447.             ];
  1448.             $vendorLabelMap = [
  1449.                 'docunecta'  => 'Docunecta',
  1450.                 'docuindexa' => 'Docuindexa',
  1451.             ];
  1453.             if (!isset($logoMap[$empresaKey])) {
  1454.                 $this->logLogo('empresa_logo_save.log', "empresa_vendor $empresa no está en logoMap. No hago nada.");
  1455.                 return;
  1456.             }
  1458.             $logoFile = $logoMap[$empresaKey];
  1459.             $vendorLabel = $vendorLabelMap[$empresaKey] ?? null;
  1460.             $this->logLogo('empresa_logo_save.log', 'Usando logo por vendor: ' . $logoFile);
  1461.         }
  1463.         if ($logoFile === null || $logoFile === '') {
  1464.             $this->logLogo('empresa_logo_save.log', 'logoFile está vacío. No hago nada.');
  1465.             return;
  1466.         }
  1468.         $this->logLogo('empresa_logo_save.log', 'Voy a guardar en parametros.logo: ' . $logoFile);
  1470.         $mysqli->begin_transaction();
  1472.         try {
  1473.             $stmt = $mysqli->prepare("
  1474.                 INSERT INTO parametros (nombre, valor)
  1475.                 VALUES (?, ?)
  1476.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  1477.             ");
  1479.             if (!$stmt) {
  1480.                 $this->logLogo('empresa_logo_save.log', 'Error prepare: ' . $mysqli->error);
  1481.                 throw new \RuntimeException('Prepare logo: ' . $mysqli->error);
  1482.             }
  1484.             $paramName = 'logo';
  1485.             $stmt->bind_param('ss', $paramName, $logoFile);
  1487.             if (!$stmt->execute()) {
  1488.                 $this->logLogo('empresa_logo_save.log', 'Error execute: ' . $stmt->error);
  1489.                 throw new \RuntimeException('Guardar parámetro logo: ' . $stmt->error);
  1490.             }
  1492.             if (isset($vendorLabel) && $vendorLabel !== '') {
  1493.                 $paramName = 'vendor';
  1494.                 $stmt->bind_param('ss', $paramName, $vendorLabel);
  1495.                 if (!$stmt->execute()) {
  1496.                     $this->logLogo('empresa_logo_save.log', 'Error execute vendor: ' . $stmt->error);
  1497.                     throw new \RuntimeException('Guardar parámetro vendor: ' . $stmt->error);
  1498.                 }
  1499.             }
  1501.             $stmt->close();
  1502.             $mysqli->commit();
  1503.             $this->logLogo('empresa_logo_save.log', 'Logo guardado correctamente en BD.');
  1504.         } catch (\Throwable $e) {
  1505.             $mysqli->rollback();
  1506.             $this->logLogo('empresa_logo_save.log', 'EXCEPCIÓN: ' . $e->getMessage());
  1507.             throw $e;
  1508.         }
  1509.     }
  1511.     private function uploadEmpresaLogo(Request $req): ?string
  1512.     {
  1513.         $this->logLogo('empresa_logo_upload.log', '--- NUEVA LLAMADA uploadEmpresaLogo ---');
  1515.         // name del checkbox en el formulario (ajústalo si usas otro)
  1516.         $useCustomLogo = $req->request->get('customLogoCheck');
  1517.         $this->logLogo('empresa_logo_upload.log', 'customLogoCheck = ' . var_export($useCustomLogo, true));
  1519.         // Si no marcaron "usar logo personalizado", no hacemos nada
  1520.         if (!$useCustomLogo) {
  1521.             $this->logLogo('empresa_logo_upload.log', 'No se ha marcado customLogoCheck. Salgo sin subir.');
  1522.             return null;
  1523.         }
  1525.         /** @var UploadedFile|null $file */
  1526.         $file = $req->files->get('logo_personalizado'); // name="logo_personalizado" en el input file
  1527.         $this->logLogo('empresa_logo_upload.log', 'FILES[logo_personalizado] = ' . print_r($file, true));
  1529.         if (!$file instanceof UploadedFile || !$file->isValid()) {
  1530.             $this->logLogo('empresa_logo_upload.log', 'File no es UploadedFile válido. Salgo sin subir.');
  1531.             return null;
  1532.         }
  1534.         // VALIDACIONES BÁSICAS
  1535.         $maxSize = 2 * 1024 * 1024; // 2 MB por ejemplo
  1536.         if ($file->getSize() > $maxSize) {
  1537.             $this->logLogo('empresa_logo_upload.log', 'Tamańo demasiado grande: ' . $file->getSize());
  1538.             throw new \RuntimeException('El logo personalizado es demasiado grande (máx 2MB).');
  1539.         }
  1541.         $mime = $file->getMimeType();
  1542.         $allowedMimeTypes = ['image/png', 'image/jpeg', 'image/webp', 'image/svg+xml'];
  1543.         $this->logLogo('empresa_logo_upload.log', 'MIME = ' . $mime);
  1545.         if (!in_array($mime, $allowedMimeTypes, true)) {
  1546.             $this->logLogo('empresa_logo_upload.log', 'MIME no permitido.');
  1547.             throw new \RuntimeException('Formato de logo no permitido. Usa PNG, JPG, WEBP o SVG.');
  1548.         }
  1550.         // Directorio destino según entorno (configurado en .env/.env.local)
  1551.         $targetDir = $_ENV['APP_LOGO_DIR'] ?? null;
  1552.         $this->logLogo('empresa_logo_upload.log', 'APP_LOGO_DIR = ' . var_export($targetDir, true));
  1554.         if (!$targetDir) {
  1555.             throw new \RuntimeException('APP_LOGO_DIR no está configurado en el entorno.');
  1556.         }
  1557.         if (!is_dir($targetDir)) {
  1558.             $this->logLogo('empresa_logo_upload.log', "El directorio no existe: $targetDir");
  1559.             throw new \RuntimeException("El directorio de logos no existe: $targetDir");
  1560.         }
  1561.         if (!is_writable($targetDir)) {
  1562.             $this->logLogo('empresa_logo_upload.log', "El directorio no es escribible: $targetDir");
  1563.             throw new \RuntimeException("El directorio de logos no es escribible: $targetDir");
  1564.         }
  1566.         // Nombre de archivo "seguro" y único
  1567.         $ext = $file->guessExtension() ?: 'png';
  1568.         $fileName = 'logo_empresa_' . bin2hex(random_bytes(6)) . '.' . $ext;
  1569.         $this->logLogo('empresa_logo_upload.log', "Voy a mover archivo como: $fileName");
  1571.         // Mover físicamente el archivo
  1572.         $file->move($targetDir, $fileName);
  1573.         $this->logLogo('empresa_logo_upload.log', "Fichero movido OK a $targetDir/$fileName");
  1575.         // Devolvemos SOLO el nombre, que es lo que se guardará en parametros.logo
  1576.         return $fileName;
  1577.     }
  1579.     private function logLogo(string $fileName, string $message): void
  1580.     {
  1581.         // Directorio de logs de Symfony (donde está dev.log/prod.log)
  1582.         $logDir = $this->getParameter('kernel.logs_dir');
  1584.         $fullPath = rtrim($logDir, '/') . '/' . $fileName;
  1586.         $line = sprintf(
  1587.             "[%s] %s\n",
  1588.             date('Y-m-d H:i:s'),
  1589.             $message
  1590.         );
  1592.         file_put_contents($fullPath, $line, FILE_APPEND);
  1593.     }
  1595.     private function loadEmpresaLogo(\mysqli $mysqli): ?string
  1596.     {
  1597.         $sql = "SELECT valor FROM parametros WHERE nombre = 'logo' LIMIT 1";
  1598.         $res = $mysqli->query($sql);
  1599.         if (!$res) {
  1600.             return null;
  1601.         }
  1602.         if ($row = $res->fetch_assoc()) {
  1603.             return $row['valor'] ?? null;
  1604.         }
  1605.         return null;
  1606.     }
  1608.     private function upsertLicense(\mysqli $mysqli, array $data, int $capacityGb = 200, int $activeUsers = 3): void
  1609.     {
  1610.         $clientName = (string)($data['name'] ?? '');
  1611.         $licenseStr  = 'Documanager 1.0';
  1612.         $initialDate = date('Y-m-d');
  1613.         $price       = 0;
  1614.         $emailSender = 'Documanager.es';
  1615.         $emailFrom   = 'no-reply@documanager.es';
  1616.         $emailName   = 'Documanager';
  1617.         $smtpHost    = 'documanager.es';
  1618.         $smtpUser    = 'no-reply@documanager.es';
  1619.         $smtpPort    = 587;
  1620.         $smtpPass    = 'Documanager1!';
  1622.         $ins = $mysqli->prepare("
  1623.             INSERT INTO license
  1624.                 (client, license, initialDate, capacityGb, users, price, emailSender, emailFrom, emailName, smtpHost, smtpUser, smtpPort, smtpPass)
  1625.             VALUES
  1626.                 (?,      ?,       ?,          ?,          ?,     ?,     ?,           ?,         ?,         ?,        ?,        ?,        ?)
  1627.         ");
  1628.         if (!$ins) {
  1629.             throw new \RuntimeException('Prepare INSERT license: ' . $mysqli->error);
  1630.         }
  1631.         $ins->bind_param(
  1632.             'sssiiisssssis',
  1633.             $clientName,
  1634.             $licenseStr,
  1635.             $initialDate,
  1636.             $capacityGb,
  1637.             $activeUsers,
  1638.             $price,
  1639.             $emailSender,
  1640.             $emailFrom,
  1641.             $emailName,
  1642.             $smtpHost,
  1643.             $smtpUser,
  1644.             $smtpPort,
  1645.             $smtpPass
  1646.         );
  1647.         if (!$ins->execute()) {
  1648.             $ins->close();
  1649.             throw new \RuntimeException('Execute INSERT license: ' . $ins->error);
  1650.         }
  1651.         $ins->close();
  1652.     }
  1654.     private function mapAzureSchemaToDefinitions(array $modelDetail): array
  1655.     {
  1656.         $docTypes = $modelDetail['docTypes'] ?? [];
  1657.         if (!is_array($docTypes) || $docTypes === []) {
  1658.             return ['header' => [], 'lines' => []];
  1659.         }
  1661.         $modelId = (string)($modelDetail['modelId'] ?? '');
  1662.         $docTypeKey = ($modelId !== '' && array_key_exists($modelId, $docTypes))
  1663.             ? $modelId
  1664.             : array_key_first($docTypes);
  1666.         if (!is_string($docTypeKey) || !isset($docTypes[$docTypeKey]) || !is_array($docTypes[$docTypeKey])) {
  1667.             return ['header' => [], 'lines' => []];
  1668.         }
  1670.         $fieldSchema = $docTypes[$docTypeKey]['fieldSchema'] ?? [];
  1671.         if (!is_array($fieldSchema)) {
  1672.             return ['header' => [], 'lines' => []];
  1673.         }
  1675.         $rawHeader = [];
  1676.         $rawLines = [];
  1677.         foreach ($fieldSchema as $fieldKey => $fieldDef) {
  1678.             if (!is_string($fieldKey) || !is_array($fieldDef)) {
  1679.                 continue;
  1680.             }
  1681.             $this->flattenFieldSchema($fieldKey, $fieldDef, $rawHeader, $rawLines);
  1682.         }
  1684.         $header = [];
  1685.         $lines = [];
  1686.         $seenHeader = [];
  1687.         $seenLines = [];
  1689.         foreach ($rawHeader as $item) {
  1690.             $key = (string)($item['field_key'] ?? '');
  1691.             if ($key === '' || isset($seenHeader[$key])) {
  1692.                 continue;
  1693.             }
  1694.             $seenHeader[$key] = true;
  1695.             $header[] = [
  1696.                 'field_key' => $key,
  1697.                 'label' => $key,
  1698.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  1699.             ];
  1700.         }
  1702.         foreach ($rawLines as $item) {
  1703.             $key = (string)($item['field_key'] ?? '');
  1704.             if ($key === '' || isset($seenLines[$key])) {
  1705.                 continue;
  1706.             }
  1707.             $seenLines[$key] = true;
  1708.             $lines[] = [
  1709.                 'field_key' => $key,
  1710.                 'label' => $key,
  1711.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  1712.             ];
  1713.         }
  1715.         foreach ($header as $index => &$item) {
  1716.             $order = $index + 1;
  1717.             $item['order_index'] = $order;
  1718.             $item['order_index_table'] = $order;
  1719.             $item['visibility'] = 1;
  1720.             $item['visibility_table'] = 1;
  1721.         }
  1723.         foreach ($lines as $index => &$item) {
  1724.             $item['order_index'] = $index + 1;
  1725.             $item['visibility'] = 1;
  1726.         }
  1728.         return ['header' => $header, 'lines' => $lines];
  1729.     }
  1731.     private function flattenFieldSchema(
  1732.         string $fieldKey,
  1733.         array $fieldDef,
  1734.         array &$header,
  1735.         array &$lines,
  1736.         bool $insideItems = false,
  1737.         string $parentPath = ''
  1738.     ): void {
  1739.         $type = strtolower((string)($fieldDef['type'] ?? 'string'));
  1740.         $currentPath = $parentPath !== '' ? $parentPath . '.' . $fieldKey : $fieldKey;
  1742.         if ($insideItems) {
  1743.             if ($type === 'object') {
  1744.                 $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  1745.                 if (is_array($properties)) {
  1746.                     foreach ($properties as $childKey => $childDef) {
  1747.                         if (is_string($childKey) && is_array($childDef)) {
  1748.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $currentPath);
  1749.                         }
  1750.                     }
  1751.                 }
  1752.                 return;
  1753.             }
  1755.             if ($type === 'array') {
  1756.                 $itemsDef = $fieldDef['items'] ?? [];
  1757.                 $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  1758.                 if ($itemType === 'object') {
  1759.                     $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  1760.                     if (is_array($properties)) {
  1761.                         $arrayPath = $currentPath . '[*]';
  1762.                         foreach ($properties as $childKey => $childDef) {
  1763.                             if (is_string($childKey) && is_array($childDef)) {
  1764.                                 $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $arrayPath);
  1765.                             }
  1766.                         }
  1767.                     }
  1768.                 } else {
  1769.                     $lines[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  1770.                 }
  1771.                 return;
  1772.             }
  1774.             $lines[] = ['field_key' => $currentPath, 'azure_type' => $type];
  1775.             return;
  1776.         }
  1778.         if ($type === 'object') {
  1779.             $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  1780.             if (is_array($properties)) {
  1781.                 foreach ($properties as $childKey => $childDef) {
  1782.                     if (is_string($childKey) && is_array($childDef)) {
  1783.                         $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $currentPath);
  1784.                     }
  1785.                 }
  1786.             }
  1787.             return;
  1788.         }
  1790.         if ($type === 'array') {
  1791.             $itemsDef = $fieldDef['items'] ?? [];
  1792.             $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  1793.             $isItems = strtolower($fieldKey) === 'items';
  1795.             if ($itemType === 'object') {
  1796.                 $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  1797.                 if (!is_array($properties)) {
  1798.                     return;
  1799.                 }
  1801.                 if ($isItems) {
  1802.                     foreach ($properties as $childKey => $childDef) {
  1803.                         if (is_string($childKey) && is_array($childDef)) {
  1804.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, '');
  1805.                         }
  1806.                     }
  1807.                 } else {
  1808.                     $arrayPath = $currentPath . '[*]';
  1809.                     foreach ($properties as $childKey => $childDef) {
  1810.                         if (is_string($childKey) && is_array($childDef)) {
  1811.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $arrayPath);
  1812.                         }
  1813.                     }
  1814.                 }
  1815.                 return;
  1816.             }
  1818.             $header[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  1819.             return;
  1820.         }
  1822.         $header[] = ['field_key' => $currentPath, 'azure_type' => $type];
  1823.     }
  1825.     private function mapAzureTypeToValueType(string $azureType): string
  1826.     {
  1827.         $azureType = strtolower(trim($azureType));
  1828.         if ($azureType === 'date') {
  1829.             return 'date';
  1830.         }
  1831.         if ($azureType === 'number' || $azureType === 'integer') {
  1832.             return 'number';
  1833.         }
  1834.         return 'string';
  1835.     }
  1837.     private function registerModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  1838.     {
  1839.         $modelId = trim($modelId);
  1840.         if ($modelId === '') {
  1841.             throw new \RuntimeException('ModelId de recurso IA obligatorio.', 400);
  1842.         }
  1844.         $modelDetail = $this->azureRequest(
  1845.             (string)($resource['endpoint'] ?? ''),
  1846.             (string)($resource['api_key'] ?? ''),
  1847.             '/documentintelligence/documentModels/' . rawurlencode($modelId)
  1848.         );
  1849.         $type = $this->classifyModelType($modelDetail);
  1850.         $definitions = $this->mapAzureSchemaToDefinitions($modelDetail);
  1852.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  1853.         $apiKey = (string)($resource['api_key'] ?? '');
  1854.         $showConfidenceBadges = 1;
  1856.         $clientMysqli->begin_transaction();
  1857.         try {
  1858.             $existingId = 0;
  1859.             $stmtSelect = $clientMysqli->prepare(
  1860.                 "SELECT id FROM extraction_models WHERE provider = 'azure-di' AND model_id = ? LIMIT 1"
  1861.             );
  1862.             if (!$stmtSelect) {
  1863.                 throw new \RuntimeException('Prepare SELECT extraction_models: ' . $clientMysqli->error);
  1864.             }
  1865.             $stmtSelect->bind_param('s', $modelId);
  1866.             if (!$stmtSelect->execute()) {
  1867.                 $stmtSelect->close();
  1868.                 throw new \RuntimeException('Execute SELECT extraction_models: ' . $stmtSelect->error);
  1869.             }
  1870.             $result = $stmtSelect->get_result();
  1871.             if ($result && ($row = $result->fetch_assoc())) {
  1872.                 $existingId = (int)$row['id'];
  1873.             }
  1874.             $stmtSelect->close();
  1876.             if ($existingId > 0) {
  1877.                 $stmtUpdate = $clientMysqli->prepare(
  1878.                     'UPDATE extraction_models
  1879.                      SET endpoint = ?, api_key = ?, type = ?, show_confidence_badges = ?
  1880.                      WHERE id = ?'
  1881.                 );
  1882.                 if (!$stmtUpdate) {
  1883.                     throw new \RuntimeException('Prepare UPDATE extraction_models: ' . $clientMysqli->error);
  1884.                 }
  1885.                 $stmtUpdate->bind_param('sssii', $endpoint, $apiKey, $type, $showConfidenceBadges, $existingId);
  1886.                 if (!$stmtUpdate->execute()) {
  1887.                     $stmtUpdate->close();
  1888.                     throw new \RuntimeException('Execute UPDATE extraction_models: ' . $stmtUpdate->error);
  1889.                 }
  1890.                 $stmtUpdate->close();
  1891.                 $localModelId = $existingId;
  1892.             } else {
  1893.                 $provider = 'azure-di';
  1894.                 $stmtInsert = $clientMysqli->prepare(
  1895.                     'INSERT INTO extraction_models (provider, model_id, endpoint, api_key, type, show_confidence_badges)
  1896.                      VALUES (?, ?, ?, ?, ?, ?)'
  1897.                 );
  1898.                 if (!$stmtInsert) {
  1899.                     throw new \RuntimeException('Prepare INSERT extraction_models: ' . $clientMysqli->error);
  1900.                 }
  1901.                 $stmtInsert->bind_param('sssssi', $provider, $modelId, $endpoint, $apiKey, $type, $showConfidenceBadges);
  1902.                 if (!$stmtInsert->execute()) {
  1903.                     $stmtInsert->close();
  1904.                     throw new \RuntimeException('Execute INSERT extraction_models: ' . $stmtInsert->error);
  1905.                 }
  1906.                 $localModelId = (int)$stmtInsert->insert_id;
  1907.                 $stmtInsert->close();
  1908.             }
  1910.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  1911.             if (!$stmtDelHeader) {
  1912.                 throw new \RuntimeException('Prepare DELETE definitions_header: ' . $clientMysqli->error);
  1913.             }
  1914.             $stmtDelHeader->bind_param('i', $localModelId);
  1915.             if (!$stmtDelHeader->execute()) {
  1916.                 $stmtDelHeader->close();
  1917.                 throw new \RuntimeException('Execute DELETE definitions_header: ' . $stmtDelHeader->error);
  1918.             }
  1919.             $stmtDelHeader->close();
  1921.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  1922.             if (!$stmtDelLines) {
  1923.                 throw new \RuntimeException('Prepare DELETE definitions_lines: ' . $clientMysqli->error);
  1924.             }
  1925.             $stmtDelLines->bind_param('i', $localModelId);
  1926.             if (!$stmtDelLines->execute()) {
  1927.                 $stmtDelLines->close();
  1928.                 throw new \RuntimeException('Execute DELETE definitions_lines: ' . $stmtDelLines->error);
  1929.             }
  1930.             $stmtDelLines->close();
  1932.             if (!empty($definitions['header'])) {
  1933.                 $stmtHeader = $clientMysqli->prepare(
  1934.                     'INSERT INTO definitions_header
  1935.                     (model_id, field_key, label, value_type, order_index, visibility, order_index_table, visibility_table)
  1936.                     VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  1937.                 );
  1938.                 if (!$stmtHeader) {
  1939.                     throw new \RuntimeException('Prepare INSERT definitions_header: ' . $clientMysqli->error);
  1940.                 }
  1941.                 foreach ($definitions['header'] as $item) {
  1942.                     $fieldKey = (string)$item['field_key'];
  1943.                     $label = (string)$item['label'];
  1944.                     $valueType = (string)$item['value_type'];
  1945.                     $orderIndex = (int)$item['order_index'];
  1946.                     $visibility = (int)$item['visibility'];
  1947.                     $orderIndexTable = (int)$item['order_index_table'];
  1948.                     $visibilityTable = (int)$item['visibility_table'];
  1949.                     $stmtHeader->bind_param(
  1950.                         'isssiiii',
  1951.                         $localModelId,
  1952.                         $fieldKey,
  1953.                         $label,
  1954.                         $valueType,
  1955.                         $orderIndex,
  1956.                         $visibility,
  1957.                         $orderIndexTable,
  1958.                         $visibilityTable
  1959.                     );
  1960.                     if (!$stmtHeader->execute()) {
  1961.                         $stmtHeader->close();
  1962.                         throw new \RuntimeException('Execute INSERT definitions_header: ' . $stmtHeader->error);
  1963.                     }
  1964.                 }
  1965.                 $stmtHeader->close();
  1966.             }
  1968.             if (!empty($definitions['lines'])) {
  1969.                 $stmtLines = $clientMysqli->prepare(
  1970.                     'INSERT INTO definitions_lines
  1971.                     (model_id, field_key, label, value_type, order_index, visibility)
  1972.                     VALUES (?, ?, ?, ?, ?, ?)'
  1973.                 );
  1974.                 if (!$stmtLines) {
  1975.                     throw new \RuntimeException('Prepare INSERT definitions_lines: ' . $clientMysqli->error);
  1976.                 }
  1977.                 foreach ($definitions['lines'] as $item) {
  1978.                     $fieldKey = (string)$item['field_key'];
  1979.                     $label = (string)$item['label'];
  1980.                     $valueType = (string)$item['value_type'];
  1981.                     $orderIndex = (int)$item['order_index'];
  1982.                     $visibility = (int)$item['visibility'];
  1983.                     $stmtLines->bind_param(
  1984.                         'isssii',
  1985.                         $localModelId,
  1986.                         $fieldKey,
  1987.                         $label,
  1988.                         $valueType,
  1989.                         $orderIndex,
  1990.                         $visibility
  1991.                     );
  1992.                     if (!$stmtLines->execute()) {
  1993.                         $stmtLines->close();
  1994.                         throw new \RuntimeException('Execute INSERT definitions_lines: ' . $stmtLines->error);
  1995.                     }
  1996.                 }
  1997.                 $stmtLines->close();
  1998.             }
  2000.             $clientMysqli->commit();
  2001.             return $localModelId;
  2002.         } catch (\Throwable $e) {
  2003.             $clientMysqli->rollback();
  2004.             throw $e;
  2005.         }
  2006.     }
  2008.     public function Empresa(Request $req, EntityManagerInterface $em)
  2009.     {
  2010.         if (!$this->getUser() || !is_object($this->getUser())) {
  2011.             return $this->redirectToRoute('logout');
  2012.         }
  2014.         $id = (int)$req->get("id");
  2015.         if (!$id) {
  2016.             $this->addFlash('warning', 'Empresa no encontrada.');
  2017.             return $this->redirectToRoute("list");
  2018.         }
  2020.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2021.         if (!$empresa) {
  2022.             $this->addFlash('warning', 'Empresa no encontrada.');
  2023.             return $this->redirectToRoute("list");
  2024.         }
  2026.         $users = $em->getRepository(Usuario::class)->findBy([
  2027.             "empresa" => $empresa->getId()
  2028.         ]);
  2030.         // Valores por defecto por si algo falla al conectar con la BD del cliente
  2031.         $activeUsers            = null;
  2032.         $modulos                = [];
  2033.         $empresaLogo            = null;
  2034.         $extractionModelLabel   = null;
  2036.         $diskUsedBytes          = null;
  2037.         $diskUsedGb             = null;
  2039.         try {
  2040.             $cx = $empresa->getConexionBD();
  2041.             if ($cx) {
  2042.                 $mysqli = @new \mysqli(
  2043.                     $cx->getDbUrl(),
  2044.                     $cx->getDbUser(),
  2045.                     $cx->getDbPassword(),
  2046.                     $cx->getDbName(),
  2047.                     (int)$cx->getDbPort()
  2048.                 );
  2050.                 if (!$mysqli->connect_error) {
  2051.                     // parámetros (modulos, límites, etc.)
  2052.                     [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  2054.                     // logo guardado en la BD del cliente
  2055.                     $empresaLogo = $this->loadEmpresaLogo($mysqli);
  2057.                     $diskUsedBytes = $this->loadEmpresaDiskUsageBytes($mysqli);
  2058.                     $diskUsedGb = ($diskUsedBytes !== null)
  2059.                         ? round($diskUsedBytes / 1024 / 1024 / 1024, 2)
  2060.                         : null;
  2062.                     // Si tiene extracción y modelo seleccionado, buscamos el ID legible del modelo
  2063.                     if (
  2064.                         !empty($modulos['modulo_extraccion']) &&
  2065.                         !empty($modulos['extraction_model'])
  2066.                     ) {
  2067.                         try {
  2068.                             $stmt = $mysqli->prepare('SELECT model_id FROM extraction_models WHERE id = ? LIMIT 1');
  2069.                             if ($stmt) {
  2070.                                 $modelParam = (int)$modulos['extraction_model'];
  2071.                                 $stmt->bind_param('i', $modelParam);
  2072.                                 if ($stmt->execute()) {
  2073.                                     $res = $stmt->get_result();
  2074.                                     if ($res && ($row = $res->fetch_assoc()) && isset($row['model_id'])) {
  2075.                                         $extractionModelLabel = $row['model_id'];
  2076.                                     }
  2077.                                 }
  2078.                                 $stmt->close();
  2079.                             }
  2080.                         } catch (\Throwable $e) {
  2081.                             // Si falla, simplemente no mostramos el texto bonito del modelo
  2082.                             $extractionModelLabel = null;
  2083.                         }
  2084.                     }
  2086.                     $mysqli->close();
  2087.                 }
  2088.             }
  2089.         } catch (\Throwable $e) {
  2090.             // Aquí podrías loguear el error si quieres, pero no rompemos la pantalla
  2091.         }
  2093.         return $this->render('empresa_detail.html.twig', [
  2094.             'empresa'              => $empresa,
  2095.             'users'                => $users,
  2096.             'activeUsers'          => $activeUsers,
  2097.             'modulos'              => $modulos,
  2098.             'empresaLogo'          => $empresaLogo,
  2099.             'extractionModelLabel' => $extractionModelLabel,
  2100.             'diskUsedGb' => $diskUsedGb,
  2101.         ]);
  2102.     }
  2104.     public function deleteEmpresa(Request $request, EntityManagerInterface $em)
  2105.     {
  2106.         $id = $request->get("id");
  2108.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2110.         $conexion = $empresa->getConexionBD();
  2111.         $usuarios = $em->getRepository(Usuario::class)->findBy(array("empresa" => $empresa->getId()));
  2113.         // Recoger avatar/firma de usuarios antes de eliminar la BD del cliente
  2114.         $mediaPaths = [];
  2115.         try {
  2116.             $mysqliMedia = @new \mysqli(
  2117.                 $conexion->getDbUrl(),
  2118.                 $conexion->getDbUser(),
  2119.                 $conexion->getDbPassword(),
  2120.                 $conexion->getDbName(),
  2121.                 (int)$conexion->getDbPort()
  2122.             );
  2123.             if (!$mysqliMedia->connect_error) {
  2124.                 $mediaPaths = $this->getCompanyUserMediaPaths($mysqliMedia);
  2125.                 $mysqliMedia->close();
  2126.             } else {
  2127.                 error_log('No se pudo conectar a BD cliente para borrar media: ' . $mysqliMedia->connect_error);
  2128.             }
  2129.         } catch (\Throwable $e) {
  2130.             error_log('Error borrando media de usuarios: ' . $e->getMessage());
  2131.         }
  2134.         $hestiaApiUrl = 'https://200.234.237.107:8083/api/';
  2135.         $owner = 'docunecta'; // o el dueño del hosting
  2138.         $postFields = http_build_query([
  2139.             'user' => 'admin',
  2140.             'password' => 'i9iQiSmxb2EpvgLq',
  2141.             'returncode' => 'yes',
  2142.             'cmd' => 'v-delete-database',
  2143.             'arg1' => 'admin',
  2144.             'arg2' => $conexion->getDbName(),
  2146.         ]);
  2148.         $accessKeyId = 'cWYbt9ShyFQ3yVRsUE8u';
  2149.         $secretKey = 'e2M_5wk2_jUAlPorF7V8zfwo3_0ihu90WoLPMKwj';
  2150.         $headers = [
  2151.             'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  2152.         ];
  2154.         $ch = curl_init();
  2155.         curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  2156.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  2157.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2158.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2159.         curl_setopt($ch, CURLOPT_POST, true);
  2160.         curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  2161.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  2163.         $response = curl_exec($ch);
  2164.         $error = curl_error($ch);
  2165.         curl_close($ch);
  2167.         if (($error || trim($response) !== '0') && trim($response) !== '3') {
  2168.             $this->addFlash('danger', 'Error al eliminar la base de datos en HestiaCP: ' . ($error ?: $response));
  2169.             return $this->redirectToRoute('list');
  2170.         }
  2172.         // Eliminar el servicio systemd asociado a la empresa
  2173.         $company_name = $empresa->getId();
  2175.         $serviceName = $company_name . "-documanager.service";
  2176.         $servicePath = "/etc/systemd/system/$serviceName";
  2177.         $cmds = [
  2178.             "sudo /bin/systemctl stop $serviceName",
  2179.             "sudo /bin/systemctl disable $serviceName",
  2180.             "sudo /bin/rm -f $servicePath",
  2181.             "sudo /bin/systemctl daemon-reload"
  2182.         ];
  2183.         $serviceErrors = [];
  2184.         foreach ($cmds as $cmd) {
  2185.             $output = @\shell_exec($cmd . " 2>&1");
  2186.             if ($output !== null && trim($output) !== '') {
  2187.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  2188.             }
  2189.         }
  2191.         $azureService = $company_name . "-azuredi.service";
  2192.         $servicePathAzure = "/etc/systemd/system/$azureService";
  2193.         $cmdsAzure = [
  2194.             "sudo /bin/systemctl stop $azureService",
  2195.             "sudo /bin/systemctl disable $azureService",
  2196.             "sudo /bin/rm -f $servicePathAzure",
  2197.             "sudo /bin/systemctl daemon-reload",
  2198.         ];
  2199.         foreach ($cmdsAzure as $cmd) {
  2200.             $output = @\shell_exec($cmd . " 2>&1");
  2201.             if ($output) {
  2202.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  2203.             }
  2204.         }
  2206.         // Eliminar mail monitor service + timer (si existen)
  2207.         $this->disableMailMonitorService((int)$company_name);
  2209.         // Pedir a platform que elimine files/logs/media del cliente
  2210.         $this->callPlatformCleanup((int)$company_name, $mediaPaths);
  2212.         //eliminamos usuarios
  2213.         foreach ($usuarios as $user) {
  2214.             $em->remove($user);
  2215.             $em->flush();
  2216.         }
  2218.         //eliminamos conexiĂłn
  2219.         $em->remove($conexion);
  2220.         $em->flush();
  2222.         //eliminamos empresa
  2223.         $em->remove($empresa);
  2224.         $em->flush();
  2225.         $msg = 'Empresa y base de datos eliminadas correctamente.';
  2226.         if (count($serviceErrors) > 0) {
  2227.             $msg .= ' ' . implode('<br>', $serviceErrors);
  2228.         }
  2229.         $this->addFlash('success', $msg);
  2230.         return $this->redirectToRoute('list');
  2231.     }
  2233.     public function editEmpresa(Request $request, EntityManagerInterface $em)
  2234.     {
  2235.         if (!$this->getUser() || !is_object($this->getUser())) {
  2236.             return $this->redirectToRoute('logout');
  2237.         }
  2239.         $id = (int)$request->get('id');
  2240.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2241.         if (!$empresa) {
  2242.             throw $this->createNotFoundException('Empresa no encontrada');
  2243.         }
  2245.         // 1) Conectar a la BD del cliente con las credenciales de la central
  2246.         $cx = $empresa->getConexionBD();
  2247.         $mysqli = @new \mysqli(
  2248.             $cx->getDbUrl(),
  2249.             $cx->getDbUser(),
  2250.             $cx->getDbPassword(),
  2251.             $cx->getDbName(),
  2252.             (int)$cx->getDbPort()
  2253.         );
  2254.         if ($mysqli->connect_error) {
  2255.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  2256.             return $this->redirectToRoute('list');
  2257.         }
  2259.         $azureResources = [];
  2260.         try {
  2261.             $azureResources = $this->loadAzureDiResources($em);
  2262.         } catch (\Throwable $e) {
  2263.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  2264.         }
  2266.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  2267.             // Estado previo de modulos (para detectar activacion de Mail Monitor)
  2268.             [$activeUsersPrev, $modulosPrev] = $this->loadEmpresaParametros($mysqli);
  2269.             $prevMailMonitor = (int)($modulosPrev['modulo_mailMonitor'] ?? 0);
  2271.             $data = $request->request->all();
  2272.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, $empresa->getMaxThreads() ?: 4);
  2275.             // 2) Actualizar SOLO central
  2276.             $empresa->setName((string)($data['name'] ?? $empresa->getName()));
  2277.             $empresa->setMaxDiskQuota(
  2278.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== ''
  2279.                     ? (int)$data['maxDiskQuota']
  2280.                     : $empresa->getMaxDiskQuota()
  2281.             );
  2282.             $empresa->setMaxThreads($maxThreads);
  2283.             $em->persist($empresa);
  2285.             // ---- Normalización de POST (checkboxes / select) ----
  2286.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  2288.             $extractionModel = 0;
  2289.             if (isset($data['extraction_model']) && $data['extraction_model'] !== '') {
  2290.                 $extractionModel = (int)$data['extraction_model'];
  2291.             }
  2292.             $data['extraction_model'] = $extractionModel;
  2293.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  2294.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  2296.             $data['modulo_extraccion']       = isset($data['modulo_extraccion'])       && $toBool($data['modulo_extraccion'])       ? 1 : 0;
  2297.             $data['modulo_etiquetas']        = isset($data['modulo_etiquetas'])        && $toBool($data['modulo_etiquetas'])        ? 1 : 0;
  2298.             $data['modulo_calendario']       = isset($data['modulo_calendario'])       && $toBool($data['modulo_calendario'])       ? 1 : 0;
  2299.             $data['modulo_calendarioExterno'] = isset($data['modulo_calendarioExterno']) && $toBool($data['modulo_calendarioExterno']) ? 1 : 0;
  2300.             $data['modulo_estados']          = isset($data['modulo_estados'])          && $toBool($data['modulo_estados'])          ? 1 : 0;
  2301.             $data['modulo_lineas']           = isset($data['modulo_lineas'])           && $toBool($data['modulo_lineas'])           ? 1 : 0;
  2302.             $data['modulo_agora']            = isset($data['modulo_agora'])           && $toBool($data['modulo_agora'])             ? 1 : 0;
  2303.             $data['modulo_gstock']           = isset($data['modulo_gstock'])           && $toBool($data['modulo_gstock'])           ? 1 : 0;
  2304.             $data['modulo_expowin']          = isset($data['modulo_expowin'])          && $toBool($data['modulo_expowin'])          ? 1 : 0;
  2305.             $data['modulo_mailMonitor']      = isset($data['modulo_mailMonitor'])      && $toBool($data['modulo_mailMonitor'])      ? 1 : 0;
  2306.             $data['modulo_busquedaNatural']  = isset($data['modulo_busquedaNatural'])  && $toBool($data['modulo_busquedaNatural'])  ? 1 : 0;
  2307.             $data['soloExtraccion']          = isset($data['soloExtraccion'])          && $toBool($data['soloExtraccion'])          ? 1 : 0;
  2309.             // Dependencias
  2310.             if (!$data['modulo_calendario']) {
  2311.                 $data['modulo_calendarioExterno'] = 0;
  2312.             }
  2313.             if (!$data['modulo_extraccion']) {
  2314.                 $data['modulo_lineas']   = 0;
  2315.                 $data['extraction_model'] = 0;
  2316.                 $data['modulo_agora']    = 0;
  2317.                 $data['modulo_gstock']   = 0;
  2318.                 $data['modulo_expowin']  = 0;
  2319.                 $azureResourceId = 0;
  2320.                 $azureModelId = '';
  2321.             }
  2323.             // 3) Guardar en BD del cliente: parametros + license
  2324.             if ($data['modulo_extraccion'] === 1) {
  2325.                 if (($azureResourceId > 0 && $azureModelId === '') || ($azureResourceId <= 0 && $azureModelId !== '')) {
  2326.                     $this->addFlash('danger', 'Para importar desde recurso IA debes indicar recurso y modelo.');
  2327.                     $mysqli->close();
  2328.                     return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  2329.                 }
  2331.                 if ($azureResourceId > 0 && $azureModelId !== '') {
  2332.                     $azureResource = $this->loadAzureDiResourceById($em, $azureResourceId);
  2333.                     if (!$azureResource) {
  2334.                         $this->addFlash('danger', 'El recurso IA seleccionado no existe.');
  2335.                         $mysqli->close();
  2336.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  2337.                     }
  2339.                     try {
  2340.                         $data['extraction_model'] = $this->registerModelInClientDb(
  2341.                             $mysqli,
  2342.                             $azureResource,
  2343.                             $azureModelId
  2344.                         );
  2345.                         $this->addFlash('success', 'Modelo IA importado/actualizado correctamente.');
  2346.                     } catch (\Throwable $e) {
  2347.                         $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  2348.                         $mysqli->close();
  2349.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  2350.                     }
  2351.                 }
  2353.                 if ((int)$data['extraction_model'] <= 0) {
  2354.                     $this->addFlash('danger', 'Con extraccion activa debes seleccionar un modelo local o importar uno desde recurso IA.');
  2355.                     $mysqli->close();
  2356.                     return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  2357.                 }
  2358.             }
  2360.             $this->updateEmpresaParametros($mysqli, $data);
  2361.             $this->updateLicense(
  2362.                 $mysqli,
  2363.                 $data,
  2364.                 $empresa->getName()
  2365.             );
  2367.             // Actualizar servicio OCR (hilos)
  2368.             $ocrBinary = $_ENV['OCR_BINARY'] ?? '';
  2369.             $filesPath = $_ENV['FILES_PATH'] ?? '';
  2371.             if ($ocrBinary !== '' && $filesPath !== '') {
  2372.                 $companyId = (int)$empresa->getId();
  2373.                 $dbHost = (string)$cx->getDbUrl();
  2374.                 $dbName = (string)$cx->getDbName();
  2375.                 $dbUser = (string)$cx->getDbUser();
  2376.                 $dbPass = (string)$cx->getDbPassword();
  2378.                 $empresaName = (string)$empresa->getName();
  2379.                 $serviceContent = <<<EOT
  2380. [Unit]
  2381. Description={$empresaName} DocuManager OCR
  2382. Requires=mariadb.service
  2383. After=mariadb.service
  2385. [Service]
  2386. Type=simple
  2387. Environment="DOCU_MAX_THREADS=$maxThreads"
  2388. ExecStart=$ocrBinary {$dbHost}/{$dbName} {$dbUser} {$dbPass} {$filesPath}/{$companyId} NO
  2389. Restart=always
  2390. User=root
  2392. [Install]
  2393. WantedBy=multi-user.target
  2394. EOT;
  2396.                 $serviceName = $companyId . "-documanager.service";
  2397.                 $tmpServicePath = "/tmp/$serviceName";
  2398.                 file_put_contents($tmpServicePath, $serviceContent);
  2399.                 \chmod($tmpServicePath, 0644);
  2401.                 $cmds = [
  2402.                     "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  2403.                     "sudo /bin/systemctl daemon-reload",
  2404.                     "sudo /bin/systemctl restart $serviceName",
  2405.                 ];
  2406.                 $serviceErrors = [];
  2407.                 foreach ($cmds as $cmd) {
  2408.                     $output = \shell_exec($cmd . " 2>&1");
  2409.                     if ($output !== null && trim($output) !== '') {
  2410.                         error_log("CMD OUTPUT: $cmd\n$output");
  2411.                         $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  2412.                     }
  2413.                 }
  2414.                 if (count($serviceErrors) > 0) {
  2415.                     $this->addFlash('warning', 'Servicio OCR actualizado con avisos: ' . implode(' | ', $serviceErrors));
  2416.                 }
  2417.             } else {
  2418.                 $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY o FILES_PATH.');
  2419.             }
  2420.             // Si se activa Mail Monitor y antes estaba desactivado, crear servicio/timer
  2421.             if ($prevMailMonitor === 0 && (int)$data['modulo_mailMonitor'] === 1 && $filesPath !== '') {
  2422.                 $this->ensureMailMonitorService(
  2423.                     (int)$empresa->getId(),
  2424.                     (string)$cx->getDbUrl(),
  2425.                     (string)$cx->getDbPort(),
  2426.                     (string)$cx->getDbUser(),
  2427.                     (string)$cx->getDbPassword(),
  2428.                     (string)$cx->getDbName(),
  2429.                     (string)$filesPath
  2430.                 );
  2431.             }
  2432.             // Si se desactiva Mail Monitor, parar y eliminar service/timer
  2433.             if ($prevMailMonitor === 1 && (int)$data['modulo_mailMonitor'] === 0) {
  2434.                 $this->disableMailMonitorService((int)$empresa->getId());
  2435.             }
  2437.             $em->flush();
  2438.             $mysqli->close();
  2440.             // Mensaje de éxito
  2441.             $this->addFlash('success', 'Empresa editada correctamente.');
  2443.             return $this->redirectToRoute('app_empresa_show', ['id' => $id]);
  2444.         }
  2446.         // 4) GET: precargar desde BD del cliente
  2447.         [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  2448.         $license = $this->loadLicense($mysqli); // por si quieres mostrarlo
  2450.         $extractionModels = [];
  2451.         try {
  2452.             $res = $mysqli->query('SELECT id, model_id FROM extraction_models ORDER BY model_id');
  2453.             if ($res) {
  2454.                 while ($row = $res->fetch_assoc()) {
  2455.                     $extractionModels[] = [
  2456.                         'id' => (int)$row['id'],
  2457.                         'model_id' => (string)$row['model_id'],
  2458.                     ];
  2459.                 }
  2460.                 $res->free();
  2461.             }
  2462.         } catch (\Throwable $e) {
  2463.             $extractionModels = [];
  2464.         }
  2466.         $mysqli->close();
  2468.         return $this->render('empresa/_edit.html.twig', [
  2469.             'empresa'      => $empresa,   // central: name + maxDiskQuota
  2470.             'id'           => $id,
  2471.             'activeUsers'  => $activeUsers, // cliente
  2472.             'modulos'      => $modulos,     // cliente
  2473.             'license'      => $license,     // opcional
  2474.             'azure_resources' => $azureResources,
  2475.             'extraction_models' => $extractionModels,
  2476.         ]);
  2477.     }
  2479.     private function loadEmpresaParametros(\mysqli $mysqli): array
  2480.     {
  2481.         // claves que nos interesan en la tabla parametros
  2482.         $keys = [
  2483.             'activeUsers',
  2484.             'soloExtraccion',
  2485.             'modulo_etiquetas',
  2486.             'modulo_calendario',
  2487.             'modulo_calExt',
  2488.             'modulo_estados',
  2489.             'modulo_subida',
  2490.             'modulo_mailMonitor',
  2491.             'modulo_busquedaNatural',
  2492.             'modulo_extraccion',
  2493.             'modulo_lineas',
  2494.             'modulo_agora',
  2495.             'modulo_gstock',
  2496.             'modulo_expowin',
  2497.             'limite_archivos',
  2498.             'extraction_model',
  2499.         ];
  2500.         $placeholders = implode(',', array_fill(0, count($keys), '?'));
  2502.         $sql = "SELECT nombre, valor FROM parametros WHERE nombre IN ($placeholders)";
  2503.         $stmt = $mysqli->prepare($sql);
  2504.         if (!$stmt) {
  2505.             throw new \RuntimeException('Prepare SELECT parametros: ' . $mysqli->error);
  2506.         }
  2508.         // bind dinámico
  2509.         $types = str_repeat('s', count($keys));
  2510.         $stmt->bind_param($types, ...$keys);
  2511.         if (!$stmt->execute()) {
  2512.             $stmt->close();
  2513.             throw new \RuntimeException('Execute SELECT parametros: ' . $stmt->error);
  2514.         }
  2516.         $res = $stmt->get_result();
  2517.         $map = [];
  2518.         while ($row = $res->fetch_assoc()) {
  2519.             $map[$row['nombre']] = $row['valor'];
  2520.         }
  2521.         $stmt->close();
  2523.         // defaults seguros
  2524.         $activeUsers = isset($map['activeUsers']) ? (int)$map['activeUsers'] : 3;
  2526.         $flags = [
  2527.             'soloExtraccion'   => isset($map['soloExtraccion'])   ? (int)$map['soloExtraccion']   : 0,
  2528.             'modulo_etiquetas'  => isset($map['modulo_etiquetas'])  ? (int)$map['modulo_etiquetas']  : 0,
  2529.             'modulo_calendario' => isset($map['modulo_calendario']) ? (int)$map['modulo_calendario'] : 0,
  2530.             'modulo_calExt'     => isset($map['modulo_calExt'])     ? (int)$map['modulo_calExt']     : 0,
  2531.             'modulo_estados'    => isset($map['modulo_estados'])    ? (int)$map['modulo_estados']    : 0,
  2532.             'modulo_subida'     => isset($map['modulo_subida'])     ? (int)$map['modulo_subida']     : 0,
  2533.             'modulo_extraccion' => isset($map['modulo_extraccion']) ? (int)$map['modulo_extraccion'] : 0,
  2534.             'modulo_lineas'     => isset($map['modulo_lineas'])     ? (int)$map['modulo_lineas']     : 0,
  2535.             'modulo_agora'      => isset($map['modulo_agora'])      ? (int)$map['modulo_agora']      : 0,
  2536.             'modulo_gstock'     => isset($map['modulo_gstock'])     ? (int)$map['modulo_gstock']     : 0,
  2537.             'modulo_expowin'    => isset($map['modulo_expowin'])    ? (int)$map['modulo_expowin']    : 0,
  2538.             'modulo_mailMonitor' => isset($map['modulo_mailMonitor']) ? (int)$map['modulo_mailMonitor'] : 0,
  2539.             'modulo_busquedaNatural' => isset($map['modulo_busquedaNatural']) ? (int)$map['modulo_busquedaNatural'] : 0,
  2540.         ];
  2542.         $limiteArchivos = isset($map['limite_archivos']) && $map['limite_archivos'] !== ''
  2543.             ? (int)$map['limite_archivos']
  2544.             : 500;
  2546.         // Lo ańadimos a $flags para no cambiar la firma del return
  2547.         $flags['limite_archivos'] = $limiteArchivos;
  2549.         // extraction_model: default 0 (sin modelo)
  2550.         $flags['extraction_model'] = isset($map['extraction_model']) && $map['extraction_model'] !== '' ? (int)$map['extraction_model'] : 0;
  2552.         return [$activeUsers, $flags];
  2553.     }
  2555.     private function updateEmpresaParametros(\mysqli $mysqli, array $data): void
  2556.     {
  2557.         $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  2558.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  2559.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  2561.         $paramMap = [
  2562.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  2563.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  2564.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  2565.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  2566.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  2567.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  2568.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  2569.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  2570.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  2571.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  2572.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  2573.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  2574.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  2575.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  2576.             'limite_archivos'    => $getInt($data, 'limite_archivos', 500),
  2577.             'extraction_model'   => $getInt($data, 'extraction_model', 0),
  2578.         ];
  2580.         if ($paramMap['modulo_extraccion'] === 0) {
  2581.             $paramMap['modulo_lineas'] = 0;
  2582.             $paramMap['extraction_model'] = 0;
  2583.             $paramMap['modulo_agora'] = 0;
  2584.             $paramMap['modulo_gstock'] = 0;
  2585.             $paramMap['modulo_expowin'] = 0;
  2586.         }
  2587.         if ($paramMap['modulo_calendario'] === 0) {
  2588.             $paramMap['modulo_calExt'] = 0;
  2589.         }
  2591.         $mysqli->begin_transaction();
  2592.         try {
  2593.             $stmt = $mysqli->prepare("
  2594.                 INSERT INTO parametros (nombre, valor)
  2595.                 VALUES (?, ?)
  2596.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2597.             ");
  2598.             if (!$stmt) {
  2599.                 throw new \RuntimeException('Prepare UPSERT parametros: ' . $mysqli->error);
  2600.             }
  2602.             foreach ($paramMap as $nombre => $valor) {
  2603.                 $v = (string)$valor;
  2604.                 if (!$stmt->bind_param('ss', $nombre, $v) || !$stmt->execute()) {
  2605.                     $stmt->close();
  2606.                     throw new \RuntimeException("Guardar parámetro {$nombre}: {$stmt->error}");
  2607.                 }
  2608.             }
  2610.             $stmt->close();
  2611.             $mysqli->commit();
  2612.         } catch (\Throwable $e) {
  2613.             $mysqli->rollback();
  2614.             throw $e;
  2615.         }
  2616.     }
  2618.     private function loadLicense(\mysqli $mysqli): array
  2619.     {
  2620.         // Carga opcional para mostrar en la edición: capacityGb/users (u otros)
  2621.         $sql = "SELECT client, capacityGb, users FROM license LIMIT 1";
  2622.         $res = $mysqli->query($sql);
  2623.         if ($res && $row = $res->fetch_assoc()) {
  2624.             return $row;
  2625.         }
  2626.         return [];
  2627.     }
  2629.     private function updateLicense(\mysqli $mysqli, array $data, string $clientName): void
  2630.     {
  2631.         $capacityGb  = isset($data['maxDiskQuota']) ? (int)$data['maxDiskQuota'] : 200;
  2632.         $activeUsers = isset($data['maxActiveUsers']) ? (int)$data['maxActiveUsers'] : 3;
  2634.         $stmt = $mysqli->prepare("UPDATE license SET capacityGb = ?, users = ? WHERE client = ?");
  2635.         if (!$stmt) {
  2636.             throw new \RuntimeException('Prepare UPDATE license: ' . $mysqli->error);
  2637.         }
  2639.         $stmt->bind_param('iis', $capacityGb, $activeUsers, $clientName);
  2640.         $stmt->execute();
  2641.         $stmt->close();
  2642.     }
  2644.     public function usersListEmpresa(Request $request, EntityManagerInterface $em)
  2645.     {
  2646.         $id = $request->get("id");
  2647.         $users_empresa = $em->getRepository(Usuario::class)->findBy(array("empresa" => $id));
  2649.         return $this->render('empresa/usersList.html.twig', array(
  2650.             'users' => $users_empresa,
  2651.             'id' => $id
  2652.         ));
  2653.     }
  2655.     private function loadEmpresaDiskUsageBytes(\mysqli $mysqli): ?int
  2656.     {
  2657.         // Si la tabla no existe o hay error, devolvemos null para no romper la vista
  2658.         $sql = "SELECT COALESCE(SUM(size_bytes), 0) AS total_bytes FROM files";
  2659.         $res = $mysqli->query($sql);
  2661.         if (!$res) {
  2662.             return null;
  2663.         }
  2665.         $row = $res->fetch_assoc();
  2666.         $res->free();
  2668.         return isset($row['total_bytes']) ? (int)$row['total_bytes'] : 0;
  2669.     }
  2671.     // =======================================================================
  2672.     // VER DOCUMENTACION DE EMPRESAS
  2673.     // =======================================================================
  2675.     #[Route('/empresa/{id}/documentos', name: 'empresa_documentos', methods: ['GET'])]
  2676.     public function documentosEmpresa(Request $request, EntityManagerInterface $em)
  2677.     {
  2678.         if (!$this->getUser() || !is_object($this->getUser())) {
  2679.             return $this->redirectToRoute('logout');
  2680.         }
  2682.         $id = (int) $request->get('id');
  2683.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2685.         if (!$empresa) {
  2686.             $this->addFlash('warning', 'Empresa no encontrada.');
  2687.             return $this->redirectToRoute('list');
  2688.         }
  2690.         // Para el desplegable
  2691.         $empresas = $em->getRepository(Empresa::class)->findAll();
  2692.         $baseUrl = $this->getParameter('documanager_base_url');
  2694.         return $this->render('empresa/documentos.html.twig', [
  2695.             'empresaId' => $id,
  2696.             'empresas'  => $empresas,
  2697.             'documanagerBaseUrl' => $baseUrl,
  2698.         ]);
  2699.     }
  2701.     #[Route('/api/empresa/{id}/documentos', name: 'empresa_documentos_api', methods: ['GET'])]
  2702.     public function documentosEmpresaApi(Request $request, EntityManagerInterface $em): JsonResponse
  2703.     {
  2704.         if (!$this->getUser() || !is_object($this->getUser())) {
  2705.             return new JsonResponse(['error' => 'unauthorized'], 401);
  2706.         }
  2708.         $id = (int) $request->get('id');
  2709.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2711.         if (!$empresa) {
  2712.             return new JsonResponse(['error' => 'Empresa no encontrada'], 404);
  2713.         }
  2715.         $cx = $empresa->getConexionBD();
  2716.         if (!$cx) {
  2717.             return new JsonResponse(['error' => 'La empresa no tiene conexión configurada'], 400);
  2718.         }
  2720.         $page    = max(1, (int) $request->query->get('page', 1));
  2721.         $perPage = (int) $request->query->get('per_page', 50);
  2722.         $perPage = min(max($perPage, 10), 200);
  2723.         $q       = (string) $request->query->get('q', '');
  2724.         $offset  = ($page - 1) * $perPage;
  2726.         $mysqli = @new \mysqli(
  2727.             $cx->getDbUrl(),
  2728.             $cx->getDbUser(),
  2729.             $cx->getDbPassword(),
  2730.             $cx->getDbName(),
  2731.             (int) $cx->getDbPort()
  2732.         );
  2734.         if ($mysqli->connect_error) {
  2735.             return new JsonResponse(['error' => 'Error conectando a la BD del cliente: ' . $mysqli->connect_error], 500);
  2736.         }
  2738.         $mysqli->set_charset('utf8mb4');
  2740.         // --- TOTAL ---
  2741.         if ($q === '') {
  2742.             $sqlTotal = "SELECT COUNT(*) AS c FROM files";
  2743.             $res = $mysqli->query($sqlTotal);
  2744.             $row = $res ? $res->fetch_assoc() : null;
  2745.             $total = (int)($row['c'] ?? 0);
  2746.         } else {
  2747.             $sqlTotal = "SELECT COUNT(*) AS c
  2748.                          FROM files
  2749.                          WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?";
  2750.             $qLike = '%' . $q . '%';
  2751.             $st = $mysqli->prepare($sqlTotal);
  2752.             $st->bind_param('ssss', $qLike, $qLike, $qLike, $qLike);
  2753.             $st->execute();
  2754.             $res = $st->get_result();
  2755.             $row = $res ? $res->fetch_assoc() : null;
  2756.             $total = (int)($row['c'] ?? 0);
  2757.             $st->close();
  2758.         }
  2760.         // --- ITEMS ---
  2761.         $items = [];
  2763.         if ($q === '') {
  2764.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  2765.                     FROM files
  2766.                     ORDER BY `date` DESC
  2767.                     LIMIT ? OFFSET ?";
  2768.             $st = $mysqli->prepare($sql);
  2769.             $st->bind_param('ii', $perPage, $offset);
  2770.         } else {
  2771.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  2772.                     FROM files
  2773.                     WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?
  2774.                     ORDER BY `date` DESC
  2775.                     LIMIT ? OFFSET ?";
  2776.             $qLike = '%' . $q . '%';
  2777.             $st = $mysqli->prepare($sql);
  2778.             $st->bind_param('ssssii', $qLike, $qLike, $qLike, $qLike, $perPage, $offset);
  2779.         }
  2781.         $st->execute();
  2782.         $res = $st->get_result();
  2783.         if ($res) {
  2784.             while ($r = $res->fetch_assoc()) {
  2785.                 $items[] = $r;
  2786.             }
  2787.         }
  2788.         $st->close();
  2789.         $mysqli->close();
  2791.         return new JsonResponse([
  2792.             'company_id' => $id,
  2793.             'page'       => $page,
  2794.             'per_page'   => $perPage,
  2795.             'total'      => $total,
  2796.             'items'      => $items,
  2797.         ]);
  2798.     }
  2799. }