src/Controller/AdminController.php line 43

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 App\Config\GstockAutoMappings;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\Session\Session;
  13. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  15. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Doctrine\ORM\EntityManagerInterface;
  18. use App\Entity\Empresa;
  19. use App\Entity\Usuario;
  20. use App\Entity\ConexionBD;
  21. use App\Service\SuperuserProvisioningService;
  22. use Symfony\Component\Security\Http\Authentication\AuthenticationUtils;
  23. use Symfony\Component\HttpFoundation\File\UploadedFile;
  24. use Symfony\Component\Routing\Annotation\Route;
  26. /**
  27.  * Description of AdminController
  28.  *
  29.  * @author joseangelparra
  30.  */
  31. class AdminController extends AbstractController
  32. {
  33.     //put your code here
  34.     private const AZURE_DI_API_VERSION = '2024-11-30';
  35.     private const EXTRACTOR_TYPE_AZURE_DI = 'azure-di';
  36.     private const EXTRACTOR_TYPE_AZURE_OPENAI = 'azure-openai';
  37.     private const GLOBAL_IS_ADMIN_SUPERADMIN = 3;
  38.     private const GLOBAL_IS_ADMIN_SUPERUSER = 4;
  39.     private const GLOBAL_IS_ADMINS = [self::GLOBAL_IS_ADMIN_SUPERADMIN, self::GLOBAL_IS_ADMIN_SUPERUSER];
  40.     private const PROFILE_SUPERUSER = 0;
  41.     private const PROFILE_SUPERADMIN = 1;
  42.     private $params;
  43.     public function __construct(ParameterBagInterface $params)
  44.     {
  46.         $this->session = new Session();
  47.         $this->params = $params;
  48.     }
  50.     #[Route('/', name: 'login')]
  51.     public function Login(AuthenticationUtils $authenticationUtils)
  52.     {
  53.         $error = $authenticationUtils->getLastAuthenticationError();
  55.         $lastUsername = $authenticationUtils->getLastUSername();
  58.         return $this->render('base.html.twig', array(
  59.             'error' => $error,
  60.             'last_username' => $lastUsername
  61.         ));
  62.     }
  64.     public function changePWD(UserPasswordHasherInterface $encoder, EntityManagerInterface $em)
  65.     {
  66.         $user = $em->getRepository(Usuario::class)->find(10);
  67.         $encoded = $encoder->hashPassword($user, 'docuManager2025');
  68.         $user->setPassword($encoded);
  69.         $em->persist($user);
  70.         $flush = $em->flush();
  71.         die();
  72.     }
  74.     public function checkUserExists(Request $request, EntityManagerInterface $em)
  75.     {
  76.         $email = trim((string)$request->request->get("user", ''));
  77.         $empresaId = (int)$request->request->get("empresa_id", 0);
  78.         $connectionId = (int)$request->request->get("connection", 0);
  80.         if ($email === '') {
  81.             return new JsonResponse(['exists' => false, 'message' => 'user_required'], 400);
  82.         }
  84.         $qb = $em->createQueryBuilder()
  85.             ->select('u.id')
  86.             ->from(Usuario::class, 'u')
  87.             ->where('LOWER(u.email) = :email')
  88.             ->setParameter('email', strtolower($email));
  90.         // Validar por ambito de empresa/conexion cuando se proporciona.
  91.         if ($empresaId > 0) {
  92.             $qb->andWhere('IDENTITY(u.empresa) = :empresaId')
  93.                 ->setParameter('empresaId', $empresaId);
  94.         } elseif ($connectionId > 0) {
  95.             $qb->andWhere('u.connection = :connectionId')
  96.                 ->setParameter('connectionId', $connectionId);
  97.         }
  99.         $existsScoped = !empty($qb->setMaxResults(1)->getQuery()->getArrayResult());
  101.         // Mantiene dato global para compatibilidad/diagnostico.
  102.         $existsGlobal = !empty($em->createQueryBuilder()
  103.             ->select('u2.id')
  104.             ->from(Usuario::class, 'u2')
  105.             ->where('LOWER(u2.email) = :email')
  106.             ->setParameter('email', strtolower($email))
  107.             ->setMaxResults(1)
  108.             ->getQuery()
  109.             ->getArrayResult());
  111.         return new JsonResponse([
  112.             'exists' => $existsScoped,
  113.             'exists_scoped' => $existsScoped,
  114.             'exists_global' => $existsGlobal,
  115.             'scope' => ($empresaId > 0 ? 'empresa' : ($connectionId > 0 ? 'connection' : 'global')),
  116.         ]);
  117.     }
  119.     private function azurePortForTenant(int $tenantId, int $base = 12000, int $max = 20999): int
  120.     {
  121.         $port = $base + $tenantId;
  122.         if ($port > $max) {
  123.             $range = max(1, $max - $base);
  124.             $port  = $base + ($tenantId % $range);
  125.         }
  126.         return $port;
  127.     }
  129.     private function azureDiWorkdirFromEnv(): string
  130.     {
  131.         return rtrim((string)($_ENV['AZURE_DI_WORKDIR'] ?? ''), '/');
  132.     }
  134.     private function azureDiPhpBaseUrl(Request $request): string
  135.     {
  136.         $host = strtolower(trim((string)$request->getHost()));
  137.         if ($host !== '' && preg_match('/^(console|newdev)\.(.+)$/', $host, $matches) === 1) {
  138.             $mappedSubdomain = $matches[1] === 'console' ? 'app' : 'platform';
  139.             return 'https://' . $mappedSubdomain . '.' . $matches[2] . '/newdocu/public';
  140.         }
  142.         return rtrim(trim((string)($_ENV['AZURE_DI_DOCU_PHP_BASE_URL'] ?? '')), '/');
  143.     }
  145.     private function clampDocuMaxThreads($value, int $default = 4): int
  146.     {
  147.         if ($value === null || $value === '') {
  148.             return $default;
  149.         }
  151.         $threads = (int)$value;
  152.         if ($threads < 1) {
  153.             return 1;
  154.         }
  155.         if ($threads > 16) {
  156.             return 16;
  157.         }
  158.         return $threads;
  159.     }
  161.     private function normalizeOcrMode($value): string
  162.     {
  163.         $mode = strtolower(trim((string)$value));
  164.         if ($mode === 'plus_glm') {
  165.             return 'plus_glm';
  166.         }
  167.         if ($mode === 'v2_zxing') {
  168.             return 'v2_zxing';
  169.         }
  170.         return 'base';
  171.     }
  173.     private function isOcrV2Available(): bool
  174.     {
  175.         $forced = $_ENV['OCR_V2_AVAILABLE'] ?? null;
  176.         if ($forced !== null && $forced !== '') {
  177.             return in_array(strtolower((string)$forced), ['1', 'true', 'yes', 'on'], true);
  178.         }
  180.         $ocrV2Dir = (string)($_ENV['OCR_V2_DIR'] ?? '/home/docunecta/ocr/documanager_ocr+zxing');
  181.         if ($ocrV2Dir === '') {
  182.             return false;
  183.         }
  184.         if ($this->isPathAllowedByOpenBaseDir($ocrV2Dir)) {
  185.             return @is_dir($ocrV2Dir);
  186.         }
  188.         $sudoResult = $this->checkDirExistsWithSudo($ocrV2Dir);
  189.         return $sudoResult ?? false;
  190.     }
  192.     private function isOcrPlusAvailable(): bool
  193.     {
  194.         $forced = $_ENV['OCR_PLUS_AVAILABLE'] ?? null;
  195.         if ($forced !== null && $forced !== '') {
  196.             return in_array(strtolower((string)$forced), ['1', 'true', 'yes', 'on'], true);
  197.         }
  199.         $ocrPlusDir = (string)($_ENV['OCR_PLUS_DIR'] ?? '/home/docunecta/ocr/TEST_documanager_ocr+glm+zxing');
  200.         if ($ocrPlusDir === '') {
  201.             return false;
  202.         }
  203.         if ($this->isPathAllowedByOpenBaseDir($ocrPlusDir)) {
  204.             return @is_dir($ocrPlusDir);
  205.         }
  207.         $sudoResult = $this->checkDirExistsWithSudo($ocrPlusDir);
  208.         return $sudoResult ?? false;
  209.     }
  211.     private function isPathAllowedByOpenBaseDir(string $path): bool
  212.     {
  213.         $openBaseDir = (string)ini_get('open_basedir');
  214.         if ($openBaseDir === '') {
  215.             return true;
  216.         }
  218.         $normalizedPath = rtrim(str_replace('\\', '/', $path), '/') . '/';
  219.         $allowedParts = array_filter(array_map('trim', explode(PATH_SEPARATOR, $openBaseDir)));
  221.         foreach ($allowedParts as $allowed) {
  222.             $normalizedAllowed = rtrim(str_replace('\\', '/', (string)$allowed), '/') . '/';
  223.             if (str_starts_with($normalizedPath, $normalizedAllowed)) {
  224.                 return true;
  225.             }
  226.         }
  227.         return false;
  228.     }
  230.     private function checkDirExistsWithSudo(string $path): ?bool
  231.     {
  232.         $cmd = 'sudo -n /usr/bin/test -d ' . escapeshellarg($path) . ' && echo 1 || echo 0';
  233.         $out = @shell_exec($cmd . ' 2>/dev/null');
  234.         if ($out === null) {
  235.             return null;
  236.         }
  238.         $out = trim($out);
  239.         if ($out === '1') {
  240.             return true;
  241.         }
  242.         if ($out === '0') {
  243.             return false;
  244.         }
  245.         return null;
  246.     }
  248.     private function ensureMailMonitorService(int $companyId, string $dbHost, string $dbPort, string $dbUser, string $dbPass, string $dbName, string $filesPath): void
  249.     {
  250.         $workdir = $_ENV['MAIL_IMPORTER_WORKDIR'] ?? '';
  251.         $script  = $_ENV['MAIL_IMPORTER_SCRIPT'] ?? '';
  252.         $envFile = $_ENV['MAIL_IMPORTER_COMMON_ENV'] ?? '';
  254.         $missing = [];
  255.         if ($workdir === '') $missing[] = 'MAIL_IMPORTER_WORKDIR';
  256.         if ($script === '') $missing[] = 'MAIL_IMPORTER_SCRIPT';
  257.         if ($envFile === '') $missing[] = 'MAIL_IMPORTER_COMMON_ENV';
  258.         if (trim($filesPath) === '') $missing[] = 'FILES_PATH';
  259.         if (!empty($missing)) {
  260.             $msg = 'Mail Monitor no creado: faltan variables de entorno: ' . implode(', ', $missing);
  261.             $this->addFlash('warning', $msg);
  262.             error_log($msg);
  263.             return;
  264.         }
  266.         $serviceName = $companyId . "-mailMonitor.service";
  267.         $timerName   = $companyId . "-mailMonitor.timer";
  268.         $filesRoot   = rtrim($filesPath, '/') . '/' . $companyId;
  270.         $serviceContent = <<<EOT
  271. [Unit]
  272. Description=DocuManager Mail Monitor (empresa {$companyId})
  273. Wants=network-online.target
  274. After=network-online.target
  276. [Service]
  277. Type=oneshot
  278. WorkingDirectory={$workdir}
  279. EnvironmentFile={$envFile}
  280. Environment=MAIL_IMPORTER_DB_HOST={$dbHost}
  281. Environment=MAIL_IMPORTER_DB_PORT={$dbPort}
  282. Environment=MAIL_IMPORTER_DB_USER={$dbUser}
  283. Environment=MAIL_IMPORTER_DB_PASS={$dbPass}
  284. Environment=MAIL_IMPORTER_DB_NAME={$dbName}
  285. Environment=MAIL_IMPORTER_FILES_ROOT={$filesRoot}
  286. ExecStart=/usr/bin/python3 {$script} --once --log-level INFO
  287. User=docunecta
  288. Group=docunecta
  290. [Install]
  291. WantedBy=multi-user.target
  292. EOT;
  294.         $timerContent = <<<EOT
  295. [Unit]
  296. Description=DocuManager Mail Monitor Timer (empresa {$companyId})
  298. [Timer]
  299. OnBootSec=2min
  300. OnUnitActiveSec=15min
  301. AccuracySec=1min
  302. Persistent=true
  304. [Install]
  305. WantedBy=timers.target
  306. EOT;
  308.         $tmpServicePath = "/tmp/{$serviceName}";
  309.         $tmpTimerPath   = "/tmp/{$timerName}";
  311.         file_put_contents($tmpServicePath, $serviceContent);
  312.         file_put_contents($tmpTimerPath, $timerContent);
  313.         @chmod($tmpServicePath, 0644);
  314.         @chmod($tmpTimerPath, 0644);
  316.         $cmds = [
  317.             "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  318.             "sudo /bin/mv {$tmpTimerPath} /etc/systemd/system/{$timerName}",
  319.             "sudo /bin/systemctl daemon-reload",
  320.             "sudo /bin/systemctl enable --now {$timerName}",
  321.         ];
  322.         foreach ($cmds as $cmd) {
  323.             $out = \shell_exec($cmd . " 2>&1");
  324.             if ($out !== null) {
  325.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  326.             }
  327.         }
  328.     }
  330.     private function disableMailMonitorService(int $companyId): void
  331.     {
  332.         $serviceName = $companyId . "-mailMonitor.service";
  333.         $timerName   = $companyId . "-mailMonitor.timer";
  335.         $cmds = [
  336.             "sudo /bin/systemctl disable --now {$timerName}",
  337.             "sudo /bin/systemctl stop {$serviceName}",
  338.             "sudo /bin/rm -f /etc/systemd/system/{$serviceName}",
  339.             "sudo /bin/rm -f /etc/systemd/system/{$timerName}",
  340.             "sudo /bin/systemctl daemon-reload",
  341.         ];
  342.         foreach ($cmds as $cmd) {
  343.             $out = \shell_exec($cmd . " 2>&1");
  344.             if ($out !== null) {
  345.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  346.             }
  347.         }
  348.     }
  350.     private function removeCompanyFilesDir(int $companyId): void
  351.     {
  352.         $base = $_ENV['FILES_PATH'] ?? '';
  353.         if (trim($base) === '') {
  354.             $msg = 'No se ha podido borrar carpeta de files: falta FILES_PATH en entorno.';
  355.             $this->addFlash('warning', $msg);
  356.             error_log($msg);
  357.             return;
  358.         }
  360.         $base = rtrim($base, '/');
  361.         $target = $base . '/' . $companyId;
  363.         if (!is_dir($target)) {
  364.             return;
  365.         }
  367.         $errors = [];
  368.         $it = new \RecursiveIteratorIterator(
  369.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  370.             \RecursiveIteratorIterator::CHILD_FIRST
  371.         );
  373.         foreach ($it as $file) {
  374.             try {
  375.                 if ($file->isDir()) {
  376.                     @rmdir($file->getPathname());
  377.                 } else {
  378.                     @unlink($file->getPathname());
  379.                 }
  380.             } catch (\Throwable $e) {
  381.                 $errors[] = $e->getMessage();
  382.             }
  383.         }
  385.         @rmdir($target);
  387.         if (!empty($errors)) {
  388.             $msg = 'No se pudo borrar completamente la carpeta de files: ' . $target;
  389.             $this->addFlash('warning', $msg);
  390.             error_log($msg . ' | ' . implode(' | ', $errors));
  391.         }
  392.     }
  394.     private function removeCompanyLogsDir(int $companyId): void
  395.     {
  396.         $base = $_ENV['LOGS_ROOT'] ?? '';
  397.         if (trim($base) === '') {
  398.             $msg = 'No se ha podido borrar carpeta de logs: falta LOGS_ROOT en entorno.';
  399.             $this->addFlash('warning', $msg);
  400.             error_log($msg);
  401.             return;
  402.         }
  404.         $base = rtrim($base, '/');
  405.         $target = $base . '/' . $companyId;
  407.         if (!is_dir($target)) {
  408.             return;
  409.         }
  411.         $errors = [];
  412.         $it = new \RecursiveIteratorIterator(
  413.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  414.             \RecursiveIteratorIterator::CHILD_FIRST
  415.         );
  417.         foreach ($it as $file) {
  418.             try {
  419.                 if ($file->isDir()) {
  420.                     @rmdir($file->getPathname());
  421.                 } else {
  422.                     @unlink($file->getPathname());
  423.                 }
  424.             } catch (\Throwable $e) {
  425.                 $errors[] = $e->getMessage();
  426.             }
  427.         }
  429.         @rmdir($target);
  431.         if (!empty($errors)) {
  432.             $msg = 'No se pudo borrar completamente la carpeta de logs: ' . $target;
  433.             $this->addFlash('warning', $msg);
  434.             error_log($msg . ' | ' . implode(' | ', $errors));
  435.         }
  436.     }
  438.     private function getCompanyUserMediaPaths(\mysqli $mysqli): array
  439.     {
  440.         $paths = [];
  441.         try {
  442.             $res = $mysqli->query("SELECT avatar, firma FROM users");
  443.             if ($res) {
  444.                 while ($r = $res->fetch_assoc()) {
  445.                     foreach (['avatar', 'firma'] as $col) {
  446.                         $path = trim((string)($r[$col] ?? ''));
  447.                         if ($path === '' || str_starts_with($path, 'http')) {
  448.                             continue;
  449.                         }
  450.                         $paths[$path] = true;
  451.                     }
  452.                 }
  453.                 $res->free();
  454.             }
  455.         } catch (\Throwable $e) {
  456.             error_log('Error leyendo usuarios para borrar media: ' . $e->getMessage());
  457.         }
  458.         return array_keys($paths);
  459.     }
  461.     private function callPlatformCleanup(int $companyId, array $mediaPaths = []): void
  462.     {
  463.         $url = $_ENV['PLATFORM_CLEANUP_URL'] ?? '';
  464.         $secret = $_ENV['PLATFORM_CLEANUP_SECRET'] ?? '';
  465.         if (trim($url) === '' || trim($secret) === '') {
  466.             $msg = 'Cleanup no ejecutado: faltan PLATFORM_CLEANUP_URL o PLATFORM_CLEANUP_SECRET.';
  467.             $this->addFlash('warning', $msg);
  468.             error_log($msg);
  469.             return;
  470.         }
  472.         $payload = [
  473.             'company_id' => $companyId,
  474.             'media_paths' => array_values($mediaPaths),
  475.         ];
  476.         $body = json_encode($payload, JSON_UNESCAPED_SLASHES);
  477.         if ($body === false) {
  478.             error_log('Cleanup: no se pudo serializar payload JSON.');
  479.             return;
  480.         }
  482.         $ts = time();
  483.         $sig = hash_hmac('sha256', $ts . "\n" . $body, $secret);
  485.         $ch = curl_init();
  486.         curl_setopt($ch, CURLOPT_URL, $url);
  487.         curl_setopt($ch, CURLOPT_POST, true);
  488.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  489.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  490.             'Content-Type: application/json',
  491.             'X-Docu-Timestamp: ' . $ts,
  492.             'X-Docu-Signature: ' . $sig,
  493.         ]);
  494.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  495.         curl_setopt($ch, CURLOPT_TIMEOUT, 8);
  496.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  497.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  499.         $response = curl_exec($ch);
  500.         $error = curl_error($ch);
  501.         $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  502.         curl_close($ch);
  504.         if ($error || $code < 200 || $code >= 300) {
  505.             $msg = 'Cleanup remoto fallo (' . $code . '): ' . ($error ?: (string)$response);
  506.             $this->addFlash('warning', $msg);
  507.             error_log($msg);
  508.         }
  509.     }
  512.     #[Route('/list', name: 'list')]
  513.     public function List(EntityManagerInterface $entityManager)
  514.     {
  515.         if (!$this->getUser() || !is_object($this->getUser())) {
  516.             return $this->redirectToRoute('logout');
  517.         }
  518.         $empresas = $entityManager->getRepository(Empresa::class)->findAll();
  520.         return $this->render('listusers.html.twig', array(
  521.             'empresas' => $empresas,
  522.         ));
  523.     }
  525.     public function superusersList(EntityManagerInterface $em)
  526.     {
  527.         if (!$this->getUser() || !is_object($this->getUser())) {
  528.             return $this->redirectToRoute('logout');
  529.         }
  531.         $rows = $em->getConnection()->fetchAllAssociative("
  532.             SELECT
  533.                 LOWER(email) AS email_key,
  534.                 MIN(email) AS email,
  535.                 COUNT(*) AS empresas_count,
  536.                 SUM(CASE WHEN status IN ('ENABLED', '1', 1) THEN 1 ELSE 0 END) AS enabled_count
  537.             FROM users
  538.             WHERE is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")
  539.             GROUP BY LOWER(email)
  540.             ORDER BY MIN(email) ASC
  541.         ");
  543.         foreach ($rows as &$row) {
  544.             $email = $this->normalizeSuperuserEmail((string)($row['email'] ?? ''));
  545.             $links = $em->getConnection()->fetchAllAssociative(
  546.                 "SELECT empresa_id, is_admin
  547.                  FROM users
  548.                  WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")
  549.                  ORDER BY empresa_id ASC",
  550.                 ['email' => $email]
  551.             );
  553.             $empresaIds = [];
  554.             foreach ($links as $link) {
  555.                 $empresaIds[] = (int)($link['empresa_id'] ?? 0);
  556.             }
  557.             $empresaIds = array_values(array_unique(array_filter($empresaIds)));
  559.             $account = $this->resolveGlobalAccountType($em, $email, $empresaIds, $links);
  560.             $row['account_type'] = $account['key'];
  561.             $row['account_type_label'] = $account['label'];
  562.         }
  563.         unset($row);
  565.         return $this->render('superusers/list.html.twig', [
  566.             'superusers' => $rows,
  567.         ]);
  568.     }
  571.     public function superusersNew(Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  572.     {
  573.         if (!$this->getUser() || !is_object($this->getUser())) {
  574.             return $this->redirectToRoute('logout');
  575.         }
  577.         $empresas = $em->getRepository(Empresa::class)->findAll();
  578.         $formData = [
  579.             'email' => '',
  580.             'status' => 'ENABLED',
  581.             'empresas' => [],
  582.             'account_type' => 'superadmin',
  583.         ];
  585.         if ($request->isMethod('POST')) {
  586.             $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  587.             $password = (string)$request->request->get('password', '');
  588.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  589.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  590.             $targetProfile = $this->targetProfileFromRequest($request);
  592.             $formData['email'] = $email;
  593.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  594.             $formData['empresas'] = $empresaIds;
  595.             $formData['account_type'] = $this->accountTypeFromProfile($targetProfile);
  597.             try {
  598.                 $service->createSuperuser($email, $password, $empresaIds, $enabled, $targetProfile);
  599.                 $this->addFlash('success', 'Usuario global creado correctamente.');
  600.                 return $this->redirectToRoute('superusers_list');
  601.             } catch (\Throwable $e) {
  602.                 $this->addFlash('danger', $e->getMessage());
  603.             }
  604.         }
  606.         return $this->render('superusers/form.html.twig', [
  607.             'title' => 'Crear usuario global',
  608.             'is_edit' => false,
  609.             'form' => $formData,
  610.             'empresas' => $empresas,
  611.         ]);
  612.     }
  614.     public function superusersEdit(string $email, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  615.     {
  616.         if (!$this->getUser() || !is_object($this->getUser())) {
  617.             return $this->redirectToRoute('logout');
  618.         }
  620.         $email = $this->normalizeSuperuserEmail($email);
  621.         $existingRows = $em->getConnection()->fetchAllAssociative(
  622.             "SELECT empresa_id, status, is_admin
  623.              FROM users
  624.              WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  625.             ['email' => $email]
  626.         );
  628.         if (count($existingRows) === 0) {
  629.             $this->addFlash('warning', 'Usuario global no encontrado.');
  630.             return $this->redirectToRoute('superusers_list');
  631.         }
  633.         $selectedEmpresaIds = [];
  634.         $hasEnabled = false;
  635.         $isAdminCandidates = [];
  636.         foreach ($existingRows as $row) {
  637.             $empresaId = (int)$row['empresa_id'];
  638.             $selectedEmpresaIds[] = $empresaId;
  639.             $hasEnabled = $hasEnabled || strtoupper((string)$row['status']) === 'ENABLED';
  640.             $isAdminCandidates[] = (int)($row['is_admin'] ?? 0);
  641.         }
  642.         $selectedEmpresaIds = array_values(array_unique($selectedEmpresaIds));
  643.         sort($selectedEmpresaIds);
  644.         $isAdminCandidates = array_values(array_unique($isAdminCandidates));
  645.         $resolvedProfile = count($isAdminCandidates) === 1
  646.             ? $this->profileFromIsAdmin((int)$isAdminCandidates[0])
  647.             : self::PROFILE_SUPERADMIN;
  648.         $accountType = $this->accountTypeFromProfile($resolvedProfile);
  650.         $empresas = $em->getRepository(Empresa::class)->findAll();
  651.         $formData = [
  652.             'email' => $email,
  653.             'status' => $hasEnabled ? 'ENABLED' : 'DISABLED',
  654.             'empresas' => $selectedEmpresaIds,
  655.             'account_type' => $accountType,
  656.         ];
  658.         if ($request->isMethod('POST')) {
  659.             $newPassword = trim((string)$request->request->get('password', ''));
  660.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  661.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  662.             $targetProfile = $this->targetProfileFromRequest($request);
  664.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  665.             $formData['empresas'] = $empresaIds;
  666.             $formData['account_type'] = $this->accountTypeFromProfile($targetProfile);
  668.             try {
  669.                 $service->updateSuperuser($email, ($newPassword === '' ? null : $newPassword), $empresaIds, $enabled, $targetProfile);
  670.                 $this->addFlash('success', 'Usuario global actualizado correctamente.');
  671.                 return $this->redirectToRoute('superusers_list');
  672.             } catch (\Throwable $e) {
  673.                 $this->addFlash('danger', $e->getMessage());
  674.             }
  675.         }
  677.         return $this->render('superusers/form.html.twig', [
  678.             'title' => 'Editar usuario global',
  679.             'is_edit' => true,
  680.             'form' => $formData,
  681.             'empresas' => $empresas,
  682.         ]);
  683.     }
  685.     public function superusersDeleteLink(string $email, int $empresaId, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  686.     {
  687.         if (!$this->getUser() || !is_object($this->getUser())) {
  688.             return $this->redirectToRoute('logout');
  689.         }
  690.         if (!$request->isMethod('POST')) {
  691.             return $this->redirectToRoute('superusers_list');
  692.         }
  694.         $email = $this->normalizeSuperuserEmail($email);
  695.         $rows = $em->getConnection()->fetchAllAssociative(
  696.             "SELECT empresa_id, status, is_admin
  697.              FROM users
  698.              WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  699.             ['email' => $email]
  700.         );
  702.         if (count($rows) === 0) {
  703.             $this->addFlash('warning', 'Usuario global no encontrado.');
  704.             return $this->redirectToRoute('superusers_list');
  705.         }
  707.         $targetEmpresaIds = [];
  708.         $enabled = false;
  709.         $isAdminCandidates = [];
  710.         foreach ($rows as $row) {
  711.             $currentEmpresaId = (int)$row['empresa_id'];
  712.             if ($currentEmpresaId !== $empresaId) {
  713.                 $targetEmpresaIds[] = $currentEmpresaId;
  714.             }
  715.             $enabled = $enabled || strtoupper((string)$row['status']) === 'ENABLED';
  716.             $isAdminCandidates[] = (int)($row['is_admin'] ?? 0);
  717.         }
  718.         $isAdminCandidates = array_values(array_unique($isAdminCandidates));
  719.         $resolvedProfile = count($isAdminCandidates) === 1
  720.             ? $this->profileFromIsAdmin((int)$isAdminCandidates[0])
  721.             : self::PROFILE_SUPERADMIN;
  723.         try {
  724.             $service->updateSuperuser($email, null, $targetEmpresaIds, $enabled, $resolvedProfile);
  725.             $this->addFlash('success', 'Vinculación eliminada correctamente.');
  726.         } catch (\Throwable $e) {
  727.             $this->addFlash('danger', $e->getMessage());
  728.         }
  730.         return $this->redirectToRoute('superusers_edit', ['email' => $email]);
  731.     }
  733.     public function superusersDeleteGlobal(string $email, Request $request, SuperuserProvisioningService $service)
  734.     {
  735.         if (!$this->getUser() || !is_object($this->getUser())) {
  736.             return $this->redirectToRoute('logout');
  737.         }
  738.         if (!$request->isMethod('POST')) {
  739.             return $this->redirectToRoute('superusers_list');
  740.         }
  742.         $email = $this->normalizeSuperuserEmail($email);
  743.         try {
  744.             $service->deleteSuperuser($email);
  745.             $this->addFlash('success', 'Usuario global eliminado de todas las empresas.');
  746.         } catch (\Throwable $e) {
  747.             $this->addFlash('danger', $e->getMessage());
  748.         }
  750.         return $this->redirectToRoute('superusers_list');
  751.     }
  753.     public function superusersCheckEmail(Request $request, EntityManagerInterface $em): JsonResponse
  754.     {
  755.         $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  756.         $empresaIds = $this->readEmpresaIdsFromRequest($request);
  758.         if ($email === '') {
  759.             return new JsonResponse(['exists' => false, 'message' => 'email_required'], 400);
  760.         }
  761.         if (count($empresaIds) === 0) {
  762.             return new JsonResponse(['exists' => false, 'message' => 'no_empresas']);
  763.         }
  765.         $count = (int)$em->createQueryBuilder()
  766.             ->select('COUNT(u.id)')
  767.             ->from(Usuario::class, 'u')
  768.             ->where('LOWER(u.email) = :email')
  769.             ->andWhere('u.isAdmin IN (:isAdmins)')
  770.             ->andWhere('IDENTITY(u.empresa) IN (:empresaIds)')
  771.             ->setParameter('email', $email)
  772.             ->setParameter('isAdmins', self::GLOBAL_IS_ADMINS)
  773.             ->setParameter('empresaIds', $empresaIds)
  774.             ->getQuery()
  775.             ->getSingleScalarResult();
  777.         return new JsonResponse([
  778.             'exists' => $count > 0,
  779.             'count' => $count,
  780.         ]);
  781.     }
  783.     private function normalizeSuperuserEmail(string $email): string
  784.     {
  785.         return strtolower(trim($email));
  786.     }
  788.     private function targetProfileFromRequest(Request $request): int
  789.     {
  790.         $accountType = strtolower(trim((string)$request->request->get('account_type', 'superadmin')));
  791.         return $this->profileFromAccountType($accountType);
  792.     }
  794.     private function profileFromAccountType(string $accountType): int
  795.     {
  796.         return $accountType === 'superuser'
  797.             ? self::PROFILE_SUPERUSER
  798.             : self::PROFILE_SUPERADMIN;
  799.     }
  801.     private function accountTypeFromProfile(int $profile): string
  802.     {
  803.         return $profile === self::PROFILE_SUPERUSER ? 'superuser' : 'superadmin';
  804.     }
  806.     private function accountTypeLabelFromProfile(int $profile): string
  807.     {
  808.         return $profile === self::PROFILE_SUPERUSER ? 'Superusuario' : 'Superadministrador';
  809.     }
  811.     private function profileFromIsAdmin(int $isAdmin): int
  812.     {
  813.         return $isAdmin === self::GLOBAL_IS_ADMIN_SUPERUSER
  814.             ? self::PROFILE_SUPERUSER
  815.             : self::PROFILE_SUPERADMIN;
  816.     }
  818.     private function resolveGlobalAccountType(EntityManagerInterface $em, string $email, array $empresaIds, array $linkRows = []): array
  819.     {
  820.         if ($email === '' || count($empresaIds) === 0) {
  821.             return ['key' => 'indeterminate', 'label' => 'Indeterminado'];
  822.         }
  824.         $isAdmins = [];
  825.         if (!empty($linkRows)) {
  826.             foreach ($linkRows as $row) {
  827.                 $isAdmin = (int)($row['is_admin'] ?? 0);
  828.                 if (in_array($isAdmin, self::GLOBAL_IS_ADMINS, true)) {
  829.                     $isAdmins[] = $isAdmin;
  830.                 }
  831.             }
  832.         }
  834.         if (empty($isAdmins)) {
  835.             $linkRows = $em->getConnection()->fetchAllAssociative(
  836.                 "SELECT is_admin
  837.                  FROM users
  838.                  WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  839.                 ['email' => $email]
  840.             );
  841.             foreach ($linkRows as $row) {
  842.                 $isAdmin = (int)($row['is_admin'] ?? 0);
  843.                 if (in_array($isAdmin, self::GLOBAL_IS_ADMINS, true)) {
  844.                     $isAdmins[] = $isAdmin;
  845.                 }
  846.             }
  847.         }
  849.         $isAdmins = array_values(array_unique($isAdmins));
  850.         if (count($isAdmins) !== 1) {
  851.             return ['key' => 'indeterminate', 'label' => 'Indeterminado'];
  852.         }
  854.         $profile = $this->profileFromIsAdmin((int)$isAdmins[0]);
  856.         return [
  857.             'key' => $this->accountTypeFromProfile($profile),
  858.             'label' => $this->accountTypeLabelFromProfile($profile),
  859.         ];
  860.     }
  862.     /**
  863.      * @return int[]
  864.      */
  865.     private function readEmpresaIdsFromRequest(Request $request): array
  866.     {
  867.         $raw = $request->request->all('empresas');
  868.         if (!is_array($raw)) {
  869.             $raw = [];
  870.         }
  872.         $ids = [];
  873.         foreach ($raw as $empresaId) {
  874.             $id = (int)$empresaId;
  875.             if ($id > 0) {
  876.                 $ids[] = $id;
  877.             }
  878.         }
  880.         $ids = array_values(array_unique($ids));
  881.         sort($ids);
  882.         return $ids;
  883.     }
  885.     public function azureResourcesList(EntityManagerInterface $em)
  886.     {
  887.         if (!$this->getUser() || !is_object($this->getUser())) {
  888.             return $this->redirectToRoute('logout');
  889.         }
  891.         $resources = [];
  892.         try {
  893.             $resources = $this->loadAzureResources($em);
  894.         } catch (\Throwable $e) {
  895.             $this->addFlash('danger', 'No se pudo cargar el listado de recursos IA: ' . $e->getMessage());
  896.         }
  898.         return $this->render('azure_resources/list.html.twig', [
  899.             'resources' => $resources,
  900.         ]);
  901.     }
  903.     public function azureResourcesNew(Request $request, EntityManagerInterface $em)
  904.     {
  905.         if (!$this->getUser() || !is_object($this->getUser())) {
  906.             return $this->redirectToRoute('logout');
  907.         }
  909.         $resource = [
  910.             'name' => '',
  911.             'endpoint' => '',
  912.             'api_key' => '',
  913.             'extractor_type' => self::EXTRACTOR_TYPE_AZURE_DI,
  914.             'model_id' => '',
  915.             'base_prompt' => '',
  916.         ];
  918.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  919.             $resource['name'] = trim((string)$request->request->get('name', ''));
  920.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  921.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  922.             $resource['extractor_type'] = $this->normalizeExtractorType((string)$request->request->get('extractor_type', self::EXTRACTOR_TYPE_AZURE_DI));
  923.             $resource['model_id'] = trim((string)$request->request->get('model_id', ''));
  924.             $resource['base_prompt'] = trim((string)$request->request->get('base_prompt', ''));
  926.             if (
  927.                 $resource['name'] === '' ||
  928.                 $resource['endpoint'] === '' ||
  929.                 $resource['api_key'] === ''
  930.             ) {
  931.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  932.             } elseif (
  933.                 $resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_OPENAI &&
  934.                 ($resource['model_id'] === '' || $resource['base_prompt'] === '')
  935.             ) {
  936.                 $this->addFlash('danger', 'Para recursos Azure OpenAI debes indicar model_id y prompt general.');
  937.             } else {
  938.                 if ($resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_DI) {
  939.                     $resource['model_id'] = '';
  940.                     $resource['base_prompt'] = '';
  941.                 }
  942.                 try {
  943.                     $em->getConnection()->insert('azure_di_resources', [
  944.                         'name' => $resource['name'],
  945.                         'endpoint' => $resource['endpoint'],
  946.                         'api_key' => $resource['api_key'],
  947.                         'extractor_type' => $resource['extractor_type'],
  948.                         'model_id' => $resource['model_id'],
  949.                         'base_prompt' => $resource['base_prompt'],
  950.                     ]);
  951.                     $this->addFlash('success', 'Recurso IA creado correctamente.');
  952.                     return $this->redirectToRoute('azure_resources_list');
  953.                 } catch (\Throwable $e) {
  954.                     $this->addFlash('danger', 'No se pudo crear el recurso: ' . $e->getMessage());
  955.                 }
  956.             }
  957.         }
  959.         return $this->render('azure_resources/new.html.twig', [
  960.             'resource' => $resource,
  961.         ]);
  962.     }
  964.     public function azureResourcesEdit(Request $request, EntityManagerInterface $em)
  965.     {
  966.         if (!$this->getUser() || !is_object($this->getUser())) {
  967.             return $this->redirectToRoute('logout');
  968.         }
  970.         $id = (int)$request->get('id');
  971.         $resource = $this->loadAzureResourceById($em, $id);
  972.         if (!$resource) {
  973.             $this->addFlash('warning', 'Recurso no encontrado.');
  974.             return $this->redirectToRoute('azure_resources_list');
  975.         }
  977.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  978.             $resource['name'] = trim((string)$request->request->get('name', ''));
  979.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  980.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  981.             $resource['extractor_type'] = $this->normalizeExtractorType((string)$request->request->get('extractor_type', self::EXTRACTOR_TYPE_AZURE_DI));
  982.             $resource['model_id'] = trim((string)$request->request->get('model_id', ''));
  983.             $resource['base_prompt'] = trim((string)$request->request->get('base_prompt', ''));
  985.             if (
  986.                 $resource['name'] === '' ||
  987.                 $resource['endpoint'] === '' ||
  988.                 $resource['api_key'] === ''
  989.             ) {
  990.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  991.             } elseif (
  992.                 $resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_OPENAI &&
  993.                 ($resource['model_id'] === '' || $resource['base_prompt'] === '')
  994.             ) {
  995.                 $this->addFlash('danger', 'Para recursos Azure OpenAI debes indicar model_id y prompt general.');
  996.             } else {
  997.                 if ($resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_DI) {
  998.                     $resource['model_id'] = '';
  999.                     $resource['base_prompt'] = '';
  1000.                 }
  1001.                 try {
  1002.                     $em->getConnection()->update('azure_di_resources', [
  1003.                         'name' => $resource['name'],
  1004.                         'endpoint' => $resource['endpoint'],
  1005.                         'api_key' => $resource['api_key'],
  1006.                         'extractor_type' => $resource['extractor_type'],
  1007.                         'model_id' => $resource['model_id'],
  1008.                         'base_prompt' => $resource['base_prompt'],
  1009.                     ], [
  1010.                         'id' => $id,
  1011.                     ]);
  1012.                     $this->addFlash('success', 'Recurso IA actualizado correctamente.');
  1013.                     return $this->redirectToRoute('azure_resources_list');
  1014.                 } catch (\Throwable $e) {
  1015.                     $this->addFlash('danger', 'No se pudo actualizar el recurso: ' . $e->getMessage());
  1016.                 }
  1017.             }
  1018.         }
  1020.         return $this->render('azure_resources/edit.html.twig', [
  1021.             'resource' => $resource,
  1022.         ]);
  1023.     }
  1025.     public function azureResourcesDelete(Request $request, EntityManagerInterface $em)
  1026.     {
  1027.         if (!$this->getUser() || !is_object($this->getUser())) {
  1028.             return $this->redirectToRoute('logout');
  1029.         }
  1031.         $id = (int)$request->get('id');
  1032.         if ($id <= 0) {
  1033.             $this->addFlash('warning', 'Identificador de recurso no valido.');
  1034.             return $this->redirectToRoute('azure_resources_list');
  1035.         }
  1037.         try {
  1038.             $em->getConnection()->delete('azure_di_resources', ['id' => $id]);
  1039.             $this->addFlash('success', 'Recurso IA eliminado correctamente.');
  1040.         } catch (\Throwable $e) {
  1041.             $this->addFlash('danger', 'No se pudo eliminar el recurso: ' . $e->getMessage());
  1042.         }
  1044.         return $this->redirectToRoute('azure_resources_list');
  1045.     }
  1047.     public function azureApiResourceModels(Request $request, EntityManagerInterface $em): JsonResponse
  1048.     {
  1049.         if (!$this->getUser() || !is_object($this->getUser())) {
  1050.             return new JsonResponse(['error' => 'unauthorized'], 401);
  1051.         }
  1053.         $resource = $this->loadAzureResourceById($em, (int)$request->get('id'));
  1054.         if (!$resource) {
  1055.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  1056.         }
  1057.         if (($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  1058.             return new JsonResponse(['error' => 'resource_type_not_supported_for_di_models'], 400);
  1059.         }
  1061.         try {
  1062.             $payload = $this->azureRequest(
  1063.                 (string)$resource['endpoint'],
  1064.                 (string)$resource['api_key'],
  1065.                 '/documentintelligence/documentModels'
  1066.             );
  1067.         } catch (\Throwable $e) {
  1068.             $status = (int)$e->getCode();
  1069.             if ($status < 400 || $status > 599) {
  1070.                 $status = 502;
  1071.             }
  1072.             return new JsonResponse(['error' => $e->getMessage()], $status);
  1073.         }
  1075.         $models = $payload['value'] ?? [];
  1076.         if (!is_array($models)) {
  1077.             $models = [];
  1078.         }
  1080.         $normalizedModels = [];
  1081.         foreach ($models as $model) {
  1082.             if (!is_array($model)) {
  1083.                 continue;
  1084.             }
  1085.             $normalizedModels[] = [
  1086.                 'modelId' => (string)($model['modelId'] ?? ''),
  1087.                 'description' => (string)($model['description'] ?? ''),
  1088.                 'createdDateTime' => (string)($model['createdDateTime'] ?? ''),
  1089.                 'expirationDateTime' => (string)($model['expirationDateTime'] ?? ''),
  1090.                 'type' => $this->classifyModelType($model),
  1091.             ];
  1092.         }
  1094.         usort($normalizedModels, static function (array $a, array $b): int {
  1095.             return strcmp($a['modelId'] ?? '', $b['modelId'] ?? '');
  1096.         });
  1098.         return new JsonResponse([
  1099.             'resource' => [
  1100.                 'id' => (int)$resource['id'],
  1101.                 'name' => (string)$resource['name'],
  1102.             ],
  1103.             'models' => $normalizedModels,
  1104.         ]);
  1105.     }
  1107.     public function azureApiResourceModelDetail(Request $request, EntityManagerInterface $em): JsonResponse
  1108.     {
  1109.         if (!$this->getUser() || !is_object($this->getUser())) {
  1110.             return new JsonResponse(['error' => 'unauthorized'], 401);
  1111.         }
  1113.         $resource = $this->loadAzureResourceById($em, (int)$request->get('id'));
  1114.         if (!$resource) {
  1115.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  1116.         }
  1117.         if (($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  1118.             return new JsonResponse(['error' => 'resource_type_not_supported_for_di_models'], 400);
  1119.         }
  1121.         $modelId = trim((string)$request->get('modelId'));
  1122.         if ($modelId === '') {
  1123.             return new JsonResponse(['error' => 'model_id_required'], 400);
  1124.         }
  1126.         try {
  1127.             $detail = $this->azureRequest(
  1128.                 (string)$resource['endpoint'],
  1129.                 (string)$resource['api_key'],
  1130.                 '/documentintelligence/documentModels/' . rawurlencode($modelId)
  1131.             );
  1132.             $mapped = $this->mapAzureSchemaToDefinitions($detail);
  1133.         } catch (\Throwable $e) {
  1134.             $status = (int)$e->getCode();
  1135.             if ($status < 400 || $status > 599) {
  1136.                 $status = 502;
  1137.             }
  1138.             return new JsonResponse(['error' => $e->getMessage()], $status);
  1139.         }
  1141.         return new JsonResponse([
  1142.             'model' => $detail,
  1143.             'type' => $this->classifyModelType($detail),
  1144.             'preview' => [
  1145.                 'header' => $mapped['header'],
  1146.                 'lines' => $mapped['lines'],
  1147.             ],
  1148.         ]);
  1149.     }
  1151.     private function normalizeExtractorType(string $value): string
  1152.     {
  1153.         $value = strtolower(trim($value));
  1154.         return $value === self::EXTRACTOR_TYPE_AZURE_OPENAI
  1155.             ? self::EXTRACTOR_TYPE_AZURE_OPENAI
  1156.             : self::EXTRACTOR_TYPE_AZURE_DI;
  1157.     }
  1159.     private function loadAzureResources(EntityManagerInterface $em, ?string $extractorType = null): array
  1160.     {
  1161.         $rows = [];
  1162.         $sql = 'SELECT id, name, endpoint, api_key, extractor_type, model_id, base_prompt, created_at, updated_at
  1163.                 FROM azure_di_resources';
  1164.         $params = [];
  1165.         if ($extractorType !== null && $extractorType !== '') {
  1166.             $sql .= ' WHERE extractor_type = :extractor_type';
  1167.             $params['extractor_type'] = $this->normalizeExtractorType($extractorType);
  1168.         }
  1169.         $sql .= ' ORDER BY name ASC';
  1170.         try {
  1171.             $rows = $em->getConnection()->executeQuery($sql, $params)->fetchAllAssociative();
  1172.         } catch (\Throwable $e) {
  1173.             // Compatibilidad temporal con esquemas antiguos sin columnas nuevas.
  1174.             $legacyRows = $em->getConnection()->executeQuery(
  1175.                 'SELECT id, name, endpoint, api_key, created_at, updated_at FROM azure_di_resources ORDER BY name ASC'
  1176.             )->fetchAllAssociative();
  1177.             foreach ($legacyRows as &$legacy) {
  1178.                 $legacy['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  1179.                 $legacy['model_id'] = '';
  1180.                 $legacy['base_prompt'] = '';
  1181.             }
  1182.             $rows = $legacyRows;
  1183.         }
  1184.         foreach ($rows as &$row) {
  1185.             $row['id'] = (int)$row['id'];
  1186.             $row['extractor_type'] = $this->normalizeExtractorType((string)($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1187.             $row['model_id'] = (string)($row['model_id'] ?? '');
  1188.             $row['base_prompt'] = (string)($row['base_prompt'] ?? '');
  1189.         }
  1191.         return $rows;
  1192.     }
  1194.     private function loadAzureResourceById(EntityManagerInterface $em, int $id): ?array
  1195.     {
  1196.         if ($id <= 0) {
  1197.             return null;
  1198.         }
  1200.         $row = null;
  1201.         try {
  1202.             $row = $em->getConnection()->fetchAssociative(
  1203.                 'SELECT id, name, endpoint, api_key, extractor_type, model_id, base_prompt, created_at, updated_at
  1204.                  FROM azure_di_resources
  1205.                  WHERE id = :id',
  1206.                 ['id' => $id]
  1207.             );
  1208.         } catch (\Throwable $e) {
  1209.             $row = $em->getConnection()->fetchAssociative(
  1210.                 'SELECT id, name, endpoint, api_key, created_at, updated_at
  1211.                  FROM azure_di_resources
  1212.                  WHERE id = :id',
  1213.                 ['id' => $id]
  1214.             );
  1215.             if ($row) {
  1216.                 $row['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  1217.                 $row['model_id'] = '';
  1218.                 $row['base_prompt'] = '';
  1219.             }
  1220.         }
  1222.         if (!$row) {
  1223.             return null;
  1224.         }
  1226.         $row['id'] = (int)$row['id'];
  1227.         $row['extractor_type'] = $this->normalizeExtractorType((string)($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1228.         $row['model_id'] = (string)($row['model_id'] ?? '');
  1229.         $row['base_prompt'] = (string)($row['base_prompt'] ?? '');
  1230.         return $row;
  1231.     }
  1233.     private function loadAzureDiResources(EntityManagerInterface $em): array
  1234.     {
  1235.         return $this->loadAzureResources($em, self::EXTRACTOR_TYPE_AZURE_DI);
  1236.     }
  1238.     private function loadAzureDiResourceById(EntityManagerInterface $em, int $id): ?array
  1239.     {
  1240.         $row = $this->loadAzureResourceById($em, $id);
  1241.         if (!$row) {
  1242.             return null;
  1243.         }
  1244.         return ($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_DI
  1245.             ? $row
  1246.             : null;
  1247.     }
  1249.     private function normalizeAzureEndpoint(string $endpoint): string
  1250.     {
  1251.         $endpoint = trim($endpoint);
  1252.         if ($endpoint === '') {
  1253.             return '';
  1254.         }
  1256.         if (!preg_match('#^https?://#i', $endpoint)) {
  1257.             $endpoint = 'https://' . $endpoint;
  1258.         }
  1260.         return rtrim($endpoint, '/');
  1261.     }
  1263.     private function azureRequest(string $endpoint, string $apiKey, string $path, array $query = []): array
  1264.     {
  1265.         $endpoint = $this->normalizeAzureEndpoint($endpoint);
  1266.         if ($endpoint === '' || trim($apiKey) === '') {
  1267.             throw new \RuntimeException('Recurso IA incompleto.', 400);
  1268.         }
  1270.         $query = array_merge(['api-version' => self::AZURE_DI_API_VERSION], $query);
  1271.         $url = $endpoint . '/' . ltrim($path, '/') . '?' . http_build_query($query);
  1273.         $ch = curl_init();
  1274.         curl_setopt($ch, CURLOPT_URL, $url);
  1275.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  1276.             'Accept: application/json',
  1277.             'Ocp-Apim-Subscription-Key: ' . $apiKey,
  1278.         ]);
  1279.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1280.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 8);
  1281.         curl_setopt($ch, CURLOPT_TIMEOUT, 25);
  1283.         $response = curl_exec($ch);
  1284.         $curlError = curl_error($ch);
  1285.         $statusCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1286.         curl_close($ch);
  1288.         if ($curlError) {
  1289.             throw new \RuntimeException('Error de red con recurso IA: ' . $curlError, 0);
  1290.         }
  1292.         $decoded = [];
  1293.         if (is_string($response) && trim($response) !== '') {
  1294.             $decoded = json_decode($response, true);
  1295.             if (!is_array($decoded)) {
  1296.                 throw new \RuntimeException('Respuesta no valida del recurso IA.', 502);
  1297.             }
  1298.         }
  1300.         if ($statusCode < 200 || $statusCode >= 300) {
  1301.             $detail = $decoded['error']['message'] ?? $decoded['message'] ?? ('HTTP ' . $statusCode);
  1302.             throw new \RuntimeException((string)$detail, $statusCode);
  1303.         }
  1305.         return $decoded;
  1306.     }
  1308.     private function classifyModelType(array $model): string
  1309.     {
  1310.         $expiration = trim((string)($model['expirationDateTime'] ?? ''));
  1311.         return $expiration !== '' ? 'custom' : 'prebuilt';
  1312.     }
  1314.     public function addEmpresa(Request $req, EntityManagerInterface $em)
  1315.     {
  1316.         //dd(\shell_exec('whoami'));
  1317.         if (!$this->getUser() || !is_object($this->getUser())) {
  1318.             return $this->redirectToRoute('logout');
  1319.         }
  1320.         $azureResources = [];
  1321.         $azureDiResources = [];
  1322.         $azureOpenAiResources = [];
  1323.         try {
  1324.             $azureResources = $this->loadAzureResources($em);
  1325.             foreach ($azureResources as $resourceRow) {
  1326.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1327.                     $azureOpenAiResources[] = $resourceRow;
  1328.                 } else {
  1329.                     $azureDiResources[] = $resourceRow;
  1330.                 }
  1331.             }
  1332.         } catch (\Throwable $e) {
  1333.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  1334.         }
  1336.         $ocrPlusAvailable = $this->isOcrPlusAvailable();
  1337.         $ocrV2Available = $this->isOcrV2Available();
  1338.         
  1340.         if ($req->request->get("submit") != "") {
  1341.             $data = $req->request->all();
  1342.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, 4);
  1343.             $data['ocr_mode'] = $this->normalizeOcrMode($data['ocr_mode'] ?? 'base');
  1344.             if (!$ocrV2Available && $data['ocr_mode'] === 'v2_zxing') {
  1345.                 $data['ocr_mode'] = 'base';
  1346.             }
  1347.             if (!$ocrPlusAvailable && $data['ocr_mode'] === 'plus_glm') {
  1348.                 $data['ocr_mode'] = 'base';
  1349.             }
  1351.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  1352.             $mailMonitorEnabled = isset($data['modulo_mailMonitor']) && $toBool($data['modulo_mailMonitor']);
  1353.             $data['modulo_extraccion'] = isset($data['modulo_extraccion']) && $toBool($data['modulo_extraccion']) ? 1 : 0;
  1354.             $data['modulo_expowin'] = isset($data['modulo_expowin']) && $toBool($data['modulo_expowin']) ? 1 : 0;
  1355.             $data['modulo_prinex'] = isset($data['modulo_prinex']) && $toBool($data['modulo_prinex']) ? 1 : 0;
  1356.             $data['tipo_conteo'] = (isset($data['tipo_conteo']) && (int)$data['tipo_conteo'] === 0) ? 0 : 1;
  1357.             $data['limite_archivos'] = (isset($data['limite_archivos']) && $data['limite_archivos'] !== '') ? (int)$data['limite_archivos'] : 500;
  1358.             $data['limite_paginas'] = (isset($data['limite_paginas']) && $data['limite_paginas'] !== '') ? (int)$data['limite_paginas'] : 1000;
  1359.             if ($data['tipo_conteo'] === 0) {
  1360.                 $data['limite_archivos'] = max(1, (int)$data['limite_archivos']);
  1361.                 $data['limite_paginas'] = 0;
  1362.             } else {
  1363.                 $data['limite_paginas'] = max(1, (int)$data['limite_paginas']);
  1364.                 $data['limite_archivos'] = 0;
  1365.             }
  1367.             $extractorType = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1368.             $data['extractor_type'] = $extractorType;
  1369.             $azureResource = null;
  1370.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  1371.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  1372.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  1373.             $aoaiFields = $this->collectAoaiFieldsFromRequest($req);
  1375.             $renderAddWithData = function () use ($azureResources, $azureDiResources, $azureOpenAiResources, $data, $aoaiFields) {
  1376.                 return $this->render('empresa/_add.html.twig', [
  1377.                     'azure_resources' => $azureResources,
  1378.                     'azure_di_resources' => $azureDiResources,
  1379.                     'azure_openai_resources' => $azureOpenAiResources,
  1380.                     'modulos' => [
  1381.                         'extraction_model' => 0,
  1382.                         'limite_archivos' => isset($data['limite_archivos']) ? (int)$data['limite_archivos'] : 500,
  1383.                         'limite_paginas' => isset($data['limite_paginas']) ? (int)$data['limite_paginas'] : 1000,
  1384.                         'tipo_conteo' => isset($data['tipo_conteo']) ? (int)$data['tipo_conteo'] : 1,
  1385.                     ],
  1386.                     'form_data' => $data,
  1387.                     'aoai_fields' => $aoaiFields,
  1388.                     'ocr_plus_available' => $ocrPlusAvailable,
  1389.                     'ocr_v2_available' => $ocrV2Available,
  1390.                 ]);
  1391.             };
  1393.             if ($data['modulo_extraccion'] === 1) {
  1394.                 if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1395.                     if ($aoaiResourceId <= 0) {
  1396.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  1397.                         return $renderAddWithData();
  1398.                     }
  1399.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  1400.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1401.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  1402.                         return $renderAddWithData();
  1403.                     }
  1404.                     $validationError = $this->validateAoaiFields($aoaiFields);
  1405.                     if ($validationError !== null) {
  1406.                         $this->addFlash('danger', $validationError);
  1407.                         return $renderAddWithData();
  1408.                     }
  1409.                 } else {
  1410.                     if ($azureResourceId <= 0 || $azureModelId === '') {
  1411.                         $this->addFlash('danger', 'Para activar extraccion debes seleccionar recurso y modelo IA.');
  1412.                         return $renderAddWithData();
  1413.                     }
  1415.                     $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  1416.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  1417.                         $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  1418.                         return $renderAddWithData();
  1419.                     }
  1421.                     try {
  1422.                         $this->azureRequest(
  1423.                             (string)$azureResource['endpoint'],
  1424.                             (string)$azureResource['api_key'],
  1425.                             '/documentintelligence/documentModels/' . rawurlencode($azureModelId)
  1426.                         );
  1427.                     } catch (\Throwable $e) {
  1428.                         $this->addFlash('danger', 'No se pudo validar el modelo IA: ' . $e->getMessage());
  1429.                         return $renderAddWithData();
  1430.                     }
  1431.                 }
  1432.             } else {
  1433.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  1434.                 $data['azure_resource_id'] = 0;
  1435.                 $data['azure_model_id'] = '';
  1436.                 $data['aoai_resource_id'] = 0;
  1437.                 $data['extraction_model'] = 0;
  1438.                 $data['modulo_expowin'] = 0;
  1439.                 $data['modulo_prinex'] = 0;
  1440.             }
  1442.             // Crear nombre de base de datos y credenciales aleatorios
  1443.             $dbName = 'doc_' . bin2hex(random_bytes(3));
  1444.             $dbUser = 'doc_' . bin2hex(random_bytes(2));
  1445.             $dbPass = bin2hex(random_bytes(8));
  1446.             $dbHost = 'localhost';
  1447.             $dbPort = '3306';
  1449.             // Credenciales de HestiaCP desde variables de entorno
  1450.             $hestiaApiUrl = $_ENV['HESTIA_API_URL'];
  1451.             $hestiaApiUser = $_ENV['HESTIA_API_USER'];
  1452.             $hestiaApiPass = $_ENV['HESTIA_API_PASS'];
  1453.             $hestiaOwner   = $_ENV['HESTIA_OWNER'];
  1454.             $accessKeyId   = $_ENV['HESTIA_ACCESS_KEY_ID'] ?? '';
  1455.             $secretKey     = $_ENV['HESTIA_SECRET_KEY'] ?? '';
  1457.             // Variables para el script de bash
  1458.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  1459.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  1460.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  1461.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  1462.             if ($ocrMode === 'plus_glm') {
  1463.                 $ocrBinary = $ocrBinaryPlus;
  1464.             } elseif ($ocrMode === 'v2_zxing') {
  1465.                 $ocrBinary = $ocrBinaryV2;
  1466.             } else {
  1467.                 $ocrBinary = $ocrBinaryBase;
  1468.             }
  1469.             $filesPath  = $_ENV['FILES_PATH'];
  1470.             if (($data['ocr_mode'] ?? 'base') === 'plus_glm' && trim($ocrBinaryPlus) === '') {
  1471.                 $this->addFlash('danger', 'OCR+ seleccionado pero falta configurar OCR_PLUS_BINARY en .env.local.');
  1472.                 return $renderAddWithData();
  1473.             }
  1474.             if (($data['ocr_mode'] ?? 'base') === 'v2_zxing' && trim($ocrBinaryV2) === '') {
  1475.                 $this->addFlash('danger', 'OCR v2 seleccionado pero falta configurar OCR_BINARY_V2 en .env.local.');
  1476.                 return $renderAddWithData();
  1477.             }
  1478.             if (($data['ocr_mode'] ?? 'base') === 'base' && trim($ocrBinaryBase) === '') {
  1479.                 $this->addFlash('danger', 'OCR Base seleccionado pero falta configurar OCR_BINARY en .env.local.');
  1480.                 return $renderAddWithData();
  1481.             }
  1482.             if (trim((string)$filesPath) === '') {
  1483.                 $this->addFlash('danger', 'Falta configurar FILES_PATH en .env.local.');
  1484.                 return $renderAddWithData();
  1485.             }
  1487.             $owner = $hestiaOwner; // o el dueńo del hosting
  1489.             $postFields = http_build_query([
  1490.                 'user' => $hestiaApiUser,
  1491.                 'password' => $hestiaApiPass,
  1492.                 'returncode' => 'yes',
  1493.                 'cmd' => 'v-add-database',
  1494.                 'arg1' => $owner,
  1495.                 'arg2' => $dbName,
  1496.                 'arg3' => $dbUser,
  1497.                 'arg4' => $dbPass,
  1498.                 'arg5' => 'mysql'
  1499.             ]);
  1500.             //dd($postFields);            
  1501.             $headers = [
  1502.                 'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  1503.             ];
  1506.             $ch = curl_init();
  1507.             curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  1508.             curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  1509.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1510.             curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  1511.             curl_setopt($ch, CURLOPT_POST, true);
  1512.             curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  1513.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  1515.             $response = curl_exec($ch);
  1516.             $error = curl_error($ch);
  1517.             curl_close($ch);
  1519.             if ($error || trim($response) !== '0') {
  1520.                 $this->addFlash('danger', 'Error al crear la base de datos en HestiaCP: ' . ($error ?: $response));
  1521.                 return $this->redirectToRoute('app_empresa_new');
  1522.             }
  1524.             //Añadir sql
  1525.             $sqlFile = __DIR__ . '/../../db/db_base.sql'; // Ajusta la ruta si está en otro sitio
  1527.             if (!file_exists($sqlFile)) {
  1528.                 $this->addFlash('danger', 'Archivo db_base.sql no encontrado.');
  1529.                 return $this->redirectToRoute('app_empresa_new');
  1530.             }
  1533.             $mysqli = new \mysqli($dbHost, "{$owner}_{$dbUser}", $dbPass, "{$owner}_{$dbName}", (int)$dbPort);
  1535.             if ($mysqli->connect_error) {
  1536.                 $this->addFlash('danger', 'Error al conectar a la base de datos: ' . $mysqli->connect_error);
  1537.                 return $this->redirectToRoute('app_empresa_new');
  1538.             }
  1540.             $sql = file_get_contents($sqlFile);
  1542.             // Eliminar lĂ­neas con DELIMITER
  1543.             $sql = preg_replace('/DELIMITER\s+\$\$/', '', $sql);
  1544.             $sql = preg_replace('/DELIMITER\s+;/', '', $sql);
  1546.             // Separar por ';;' si los triggers usan ese delimitador (ajusta si es $$)
  1547.             $statements = explode('$$', $sql);
  1549.             foreach ($statements as $stmt) {
  1550.                 $stmt = trim($stmt);
  1551.                 if ($stmt) {
  1552.                     if (!$mysqli->multi_query($stmt)) {
  1553.                         $this->addFlash('danger', 'Error ejecutando SQL: ' . $mysqli->error);
  1554.                         return $this->redirectToRoute('app_empresa_new');
  1555.                     }
  1556.                     // Limpiar cualquier resultado intermedio
  1557.                     while ($mysqli->more_results() && $mysqli->next_result()) {
  1558.                         $mysqli->use_result();
  1559.                     }
  1560.                 }
  1561.             }
  1563.             $updateSql = "UPDATE users SET email = '" . $mysqli->real_escape_string((string)$data["user"]) . "' WHERE id = 1";
  1565.             if (!$mysqli->query($updateSql)) {
  1566.                 $this->addFlash('danger', 'Error al actualizar usuario: ' . $mysqli->error);
  1567.                 return $this->redirectToRoute('app_empresa_new');
  1568.             }
  1570.             // Guardar parámetros (activeUsers + modulos_*) en la BD del cliente
  1571.             $localExtractionModelId = 0;
  1572.             if ($data['modulo_extraccion'] === 1) {
  1573.                 try {
  1574.                     if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1575.                         $localExtractionModelId = $this->registerAoaiModelInClientDb(
  1576.                             $mysqli,
  1577.                             $azureResource ?? [],
  1578.                             $aoaiFields
  1579.                         );
  1580.                     } else {
  1581.                         $localExtractionModelId = $this->registerDiModelInClientDb(
  1582.                             $mysqli,
  1583.                             $azureResource ?? [],
  1584.                             $azureModelId
  1585.                         );
  1586.                     }
  1587.                 } catch (\Throwable $e) {
  1588.                     $this->addFlash('danger', 'No se pudo registrar el modelo en la BBDD cliente: ' . $e->getMessage());
  1589.                     $mysqli->close();
  1590.                     return $this->redirectToRoute('app_empresa_new');
  1591.                 }
  1592.             }
  1593.             $data['extraction_model'] = $localExtractionModelId;
  1595.             // SUBIR LOGO PERSONALIZADO (SI LO HAY) ===
  1596.             $customLogoFile = null;
  1597.             try {
  1598.                 $customLogoFile = $this->uploadEmpresaLogo($req);
  1599.             } catch (\Throwable $e) {
  1600.                 // Aquí decides si quieres que esto sea fatal o solo un aviso
  1601.                 $this->addFlash('warning', 'El logo personalizado no se pudo subir: ' . $e->getMessage());
  1602.                 // Si quieres abortar todo el proceso por fallo de logo, haz return+redirect aquí.
  1603.             }
  1605.             // Guardar logo en la BD del cliente
  1606.             $this->saveEmpresaLogo($mysqli, $data, $customLogoFile);
  1608.             // Actualizar/insertar license (capacityGb y users) en la BD del cliente
  1609.             $this->upsertLicense(
  1610.                 $mysqli,
  1611.                 $data,
  1612.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== '' ? (int)$data['maxDiskQuota'] : 200,
  1613.                 isset($data['maxActiveUsers']) && $data['maxActiveUsers'] !== '' ? (int)$data['maxActiveUsers'] : 3
  1614.             );
  1616.             // Guardar parametros (activeUsers + modulos_*) en la BD del cliente
  1617.             $this->saveEmpresaParametros($mysqli, $data);
  1618.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  1619.                 try {
  1620.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  1621.                 } catch (\Throwable $e) {
  1622.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  1623.                 }
  1624.             }
  1626.             // Crear y persistir la empresa
  1627.             $emp = new Empresa();
  1628.             $emp->setName($data["name"]);
  1629.             $emp->setMaxDiskQuota((int)$data["maxDiskQuota"]);
  1630.             $emp->setMaxThreads($maxThreads);
  1634.             $em->persist($emp);
  1635.             $em->flush();
  1637.             $conexionBD = new ConexionBD();
  1638.             $conexionBD->setDbName($owner . "_" . $dbName);
  1639.             $conexionBD->setDbUser($owner . "_" . $dbUser);
  1640.             $conexionBD->setDbPassword($dbPass);
  1641.             $conexionBD->setDbUrl($dbHost);
  1642.             $conexionBD->setDbPort($dbPort);
  1643.             $em->persist($conexionBD);
  1644.             $em->flush();
  1647.             $emp->setConexionBD($conexionBD);
  1648.             $em->persist($emp);
  1649.             $em->flush();
  1651.             //crear usuario
  1652.             $user = new \App\Entity\Usuario();
  1653.             $user->setEmail($data["user"]);
  1654.             $user->setEmpresa($emp);
  1655.             $user->setPassword("dscsdcsno2234dwvw");
  1656.             $user->setStatus(1);
  1657.             $user->setIsAdmin(2);
  1658.             $user->setConnection($conexionBD->getId());
  1660.             $em->persist($user);
  1661.             $em->flush();
  1663.             //crear el script de bash
  1664.             $company_name = $emp->getId();
  1666.             // "DOCU_MAX_THREADS=" por defecto 4
  1667.             // "NO" al final es para desactivar FTP
  1669.             // Crear archivo .service
  1670.             $empresaName = (string)($data['name'] ?? '');
  1671.             $serviceContent = <<<EOT
  1672. [Unit]
  1673. Description={$empresaName} DocuManager OCR
  1674. Requires=mariadb.service
  1675. After=mariadb.service
  1677. [Service]
  1678. Type=simple
  1679. Environment="DOCU_MAX_THREADS=$maxThreads"
  1680. ExecStart=$ocrBinary localhost/{$owner}_{$dbName} {$owner}_{$dbUser} {$dbPass} {$filesPath}/{$company_name} NO
  1681. Restart=always
  1682. User=docunecta
  1684. [Install]
  1685. WantedBy=multi-user.target
  1686. EOT;
  1689.             // Guardar contenido temporal en un archivo dentro de /tmp
  1690.             $serviceName = $company_name . "-documanager.service";
  1691.             $tmpServicePath = "/tmp/$serviceName";
  1692.             file_put_contents($tmpServicePath, $serviceContent);
  1693.             \chmod($tmpServicePath, 0644);
  1695.             // Mover el archivo y habilitar el servicio desde PHP con shell_exec
  1696.             $commands = [
  1697.                 "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  1698.                 "sudo /bin/systemctl daemon-reload",
  1699.                 "sudo /bin/systemctl enable $serviceName",
  1700.                 "sudo /bin/systemctl start $serviceName",
  1701.             ];
  1702.             $errors = [];
  1703.             foreach ($commands as $cmd) {
  1704.                 $output = \shell_exec($cmd . " 2>&1");
  1705.                 if ($output !== null) {
  1706.                     // Puedes loguearlo si quieres para ver errores
  1707.                     error_log("CMD OUTPUT: $cmd\n$output");
  1708.                     $errors[] = "CMD OUTPUT: $cmd\n$output";
  1709.                 }
  1710.             }
  1712.             // === Crear servicio AZURE DI por tenant ===
  1713.             $azureBasePort = 12000;
  1714.             $tenantId      = (int)$emp->getId();
  1715.             $port          = $this->azurePortForTenant($tenantId, $azureBasePort, 20999);
  1716.             $serviceName   = $tenantId . "-azuredi.service";
  1717.             $workdir       = $this->azureDiWorkdirFromEnv();
  1718.             $docuPhpBaseUrl = $this->azureDiPhpBaseUrl($req);
  1719.             if ($workdir !== '' && $docuPhpBaseUrl !== '') {
  1720.                 $logsDir = $workdir . "/logs/" . $tenantId;
  1722.                 // Asegura carpeta de logs
  1723.                 @mkdir($logsDir, 0775, true);
  1725.                 $serviceContent = <<<EOT
  1726. [Unit]
  1727. Description=DocuManager Azure DI {$tenantId}
  1728. After=network.target
  1730. [Service]
  1731. User=root
  1732. WorkingDirectory={$workdir}
  1734. Environment=APP_HOST=127.0.0.1
  1735. Environment=APP_PORT={$port}
  1736. Environment=LOG_DIR={$logsDir}
  1737. Environment=PYTHONUNBUFFERED=1
  1738. Environment=MAX_CONCURRENT=20
  1739. Environment="PATH=/opt/azure-di/.venv/bin:/usr/local/bin:/usr/bin"
  1740. EnvironmentFile=-{$workdir}/.env
  1742. # ---- Scheduler interno de extracción ----
  1743. Environment=EXTRACT_TICK_ENABLED=1
  1744. Environment=EXTRACT_TICK_INTERVAL_SEC=10
  1745. Environment=DOCU_TENANT_ID={$tenantId}
  1746. Environment=EXTRACT_TICK_LIMIT=30
  1747. Environment=EXTRACT_TICK_TIMEOUT_SEC=25
  1748. Environment=EXTRACT_TICK_LOCK_FILE=/tmp/azure_di_extract_tick_{$tenantId}.lock
  1750. # Ajustar URL base pública/interna de PHP
  1751. Environment=DOCU_PHP_BASE_URL={$docuPhpBaseUrl}
  1753. # Debe coincidir con EXTRACT_INTERNAL_TOKEN del lado PHP
  1754. Environment=EXTRACT_INTERNAL_TOKEN=8c7e7a1b4d0f6e2a9c1d3f5b7a8e0c2d4f6a1b3c5d7e9f0a2c4e6b8d0f1a3c5
  1756. ExecStart=/opt/azure-di/.venv/bin/python -m uvicorn app.main:app --host 127.0.0.1 --port {$port} --proxy-headers --workers 2
  1758. Restart=always
  1759. RestartSec=2
  1760. StandardOutput=journal
  1761. StandardError=journal
  1763. [Install]
  1764. WantedBy=multi-user.target
  1765. EOT;
  1767.                 $tmpServicePath = "/tmp/{$serviceName}";
  1768.                 file_put_contents($tmpServicePath, $serviceContent);
  1769.                 @chmod($tmpServicePath, 0644);
  1771.                 $cmds = [
  1772.                     "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  1773.                     "sudo /bin/systemctl daemon-reload",
  1774.                     "sudo /bin/systemctl enable {$serviceName}",
  1775.                     "sudo /bin/systemctl start {$serviceName}",
  1776.                 ];
  1777.                 foreach ($cmds as $cmd) {
  1778.                     $out = \shell_exec($cmd . " 2>&1");
  1779.                     if ($out !== null) {
  1780.                         error_log("AZURE-DI CMD: $cmd\n$out");
  1781.                     }
  1782.                 }
  1783.             } else {
  1784.                 $missing = [];
  1785.                 if ($workdir === '') $missing[] = 'AZURE_DI_WORKDIR';
  1786.                 if ($docuPhpBaseUrl === '') $missing[] = 'AZURE_DI_DOCU_PHP_BASE_URL';
  1787.                 $this->addFlash('warning', 'No se pudo crear el servicio de extraccion IA: faltan variables de entorno: ' . implode(', ', $missing));
  1788.             }
  1790.             // === Crear servicio/timer Mail Monitor si el modulo esta activo ===
  1791.             if ($mailMonitorEnabled) {
  1792.                 $this->ensureMailMonitorService(
  1793.                     (int)$company_name,
  1794.                     (string)$dbHost,
  1795.                     (string)$dbPort,
  1796.                     (string)$owner . "_" . (string)$dbUser,
  1797.                     (string)$dbPass,
  1798.                     (string)$owner . "_" . (string)$dbName,
  1799.                     (string)$filesPath
  1800.                 );
  1801.             }
  1803.             if (count($errors) > 0) {
  1804.                 $this->addFlash('success', 'Empresa y base de datos creadas correctamente: ' . implode(" | ", $errors));
  1805.             }
  1809.             $this->addFlash('success', 'Empresa y base de datos creadas correctamente.');
  1810.             return $this->redirectToRoute('list');
  1811.         } else {
  1812.             // Carga recursos IA para el formulario de alta
  1813.             return $this->render('empresa/_add.html.twig', [
  1814.                 'azure_resources' => $azureResources,
  1815.                 'azure_di_resources' => $azureDiResources,
  1816.                 'azure_openai_resources' => $azureOpenAiResources,
  1817.                 'modulos' => [
  1818.                     'extraction_model' => 0,
  1819.                     'limite_archivos' => 500,
  1820.                     'limite_paginas' => 1000,
  1821.                     'tipo_conteo' => 1,
  1822.                 ],
  1823.                 'form_data' => [
  1824.                     'extractor_type' => self::EXTRACTOR_TYPE_AZURE_DI,
  1825.                     'ocr_mode' => 'base',
  1826.                 ],
  1827.                 'aoai_fields' => [],
  1828.                 'ocr_plus_available' => $ocrPlusAvailable,
  1829.                 'ocr_v2_available' => $ocrV2Available,
  1830.             ]);
  1831.         }
  1832.     }
  1834.     private function saveEmpresaParametros(\mysqli $mysqli, array $data): void
  1835.     {
  1836.         // Helpers
  1837.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  1838.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  1840.         // Keys y valores tal y como quieres guardarlos
  1841.         $paramMap = [
  1842.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  1844.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  1846.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  1847.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  1848.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  1849.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  1850.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  1851.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  1852.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  1853.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  1854.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  1855.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  1856.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  1857.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  1858.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  1860.             'tipo_conteo'      => $getInt($data, 'tipo_conteo', 1) === 1 ? 1 : 0,
  1861.             'archivos_subidos' => 0,
  1862.             'limite_archivos'  => $getInt($data, 'limite_archivos', 500),
  1863.             'paginas_subidas'  => 0,
  1864.             'limite_paginas'   => $getInt($data, 'limite_paginas', 1000),
  1866.             'extraction_model'  => $getInt($data, 'extraction_model', 0),
  1867.             'ocr_mode'          => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  1868.             'tokensContratados' => max(0, $getInt($data, 'tokensContratados', 0)),
  1869.         ];
  1871.         if ($paramMap['modulo_extraccion'] === 0) {
  1872.             $paramMap['modulo_expowin'] = 0;
  1873.             $paramMap['modulo_prinex'] = 0;
  1874.         }
  1876.         // RECOMENDADO en tu SQL base:
  1877.         // ALTER TABLE parametros ADD UNIQUE KEY uniq_nombre (nombre);
  1878.         $mysqli->begin_transaction();
  1879.         try {
  1880.             $stmt = $mysqli->prepare("
  1881.                 INSERT INTO parametros (nombre, valor)
  1882.                 VALUES (?, ?)
  1883.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  1884.             ");
  1885.             if (!$stmt) {
  1886.                 throw new \RuntimeException('Prepare parametros: ' . $mysqli->error);
  1887.             }
  1889.             foreach ($paramMap as $nombre => $valor) {
  1890.                 // valor es TEXT en tu esquema: bindeamos como string
  1891.                 $v = (string)$valor;
  1892.                 $stmt->bind_param('ss', $nombre, $v);
  1893.                 if (!$stmt->execute()) {
  1894.                     throw new \RuntimeException("Guardar parámetro $nombre: " . $stmt->error);
  1895.                 }
  1896.             }
  1898.             $stmt->close();
  1899.             $mysqli->commit();
  1900.         } catch (\Throwable $e) {
  1901.             $mysqli->rollback();
  1903.             // Si NO puedes ańadir UNIQUE(nombre), usa fallback DELETE+INSERT:
  1904.             // $this->saveParametrosFallback($mysqli, $paramMap);
  1906.             throw $e;
  1907.         }
  1908.     }
  1910.     private function applyGstockAutoMappings(\mysqli $mysqli, int $modelId): void
  1911.     {
  1912.         if ($modelId <= 0) {
  1913.             return;
  1914.         }
  1916.         $available = [
  1917.             'header' => [],
  1918.             'line' => [],
  1919.         ];
  1921.         $stmtHeader = $mysqli->prepare('SELECT field_key FROM definitions_header WHERE model_id = ?');
  1922.         if (!$stmtHeader) {
  1923.             throw new \RuntimeException('Prepare SELECT definitions_header para automapeo Gstock: ' . $mysqli->error);
  1924.         }
  1925.         $stmtHeader->bind_param('i', $modelId);
  1926.         if (!$stmtHeader->execute()) {
  1927.             $stmtHeader->close();
  1928.             throw new \RuntimeException('Execute SELECT definitions_header para automapeo Gstock: ' . $stmtHeader->error);
  1929.         }
  1930.         $resHeader = $stmtHeader->get_result();
  1931.         while ($resHeader && ($row = $resHeader->fetch_assoc())) {
  1932.             $fieldKey = (string)($row['field_key'] ?? '');
  1933.             if ($fieldKey !== '') {
  1934.                 $available['header'][$fieldKey] = true;
  1935.             }
  1936.         }
  1937.         $stmtHeader->close();
  1939.         $stmtLines = $mysqli->prepare('SELECT field_key FROM definitions_lines WHERE model_id = ?');
  1940.         if (!$stmtLines) {
  1941.             throw new \RuntimeException('Prepare SELECT definitions_lines para automapeo Gstock: ' . $mysqli->error);
  1942.         }
  1943.         $stmtLines->bind_param('i', $modelId);
  1944.         if (!$stmtLines->execute()) {
  1945.             $stmtLines->close();
  1946.             throw new \RuntimeException('Execute SELECT definitions_lines para automapeo Gstock: ' . $stmtLines->error);
  1947.         }
  1948.         $resLines = $stmtLines->get_result();
  1949.         while ($resLines && ($row = $resLines->fetch_assoc())) {
  1950.             $fieldKey = (string)($row['field_key'] ?? '');
  1951.             if ($fieldKey !== '') {
  1952.                 $available['line'][$fieldKey] = true;
  1953.             }
  1954.         }
  1955.         $stmtLines->close();
  1957.         $existing = [];
  1958.         $stmtExisting = $mysqli->prepare('SELECT type, source, destination FROM gstock_mapping WHERE model_id = ?');
  1959.         if (!$stmtExisting) {
  1960.             throw new \RuntimeException('Prepare SELECT gstock_mapping para automapeo: ' . $mysqli->error);
  1961.         }
  1962.         $stmtExisting->bind_param('i', $modelId);
  1963.         if (!$stmtExisting->execute()) {
  1964.             $stmtExisting->close();
  1965.             throw new \RuntimeException('Execute SELECT gstock_mapping para automapeo: ' . $stmtExisting->error);
  1966.         }
  1967.         $resExisting = $stmtExisting->get_result();
  1968.         while ($resExisting && ($row = $resExisting->fetch_assoc())) {
  1969.             $type = (string)($row['type'] ?? '');
  1970.             $source = (string)($row['source'] ?? '');
  1971.             $destination = (string)($row['destination'] ?? '');
  1972.             if ($type !== '' && $source !== '' && $destination !== '') {
  1973.                 $existing[$type . '|' . $source . '|' . $destination] = true;
  1974.             }
  1975.         }
  1976.         $stmtExisting->close();
  1978.         $mysqli->begin_transaction();
  1979.         try {
  1980.             $stmtInsert = $mysqli->prepare(
  1981.                 'INSERT INTO gstock_mapping (model_id, type, source, destination) VALUES (?, ?, ?, ?)'
  1982.             );
  1983.             if (!$stmtInsert) {
  1984.                 throw new \RuntimeException('Prepare INSERT gstock_mapping para automapeo: ' . $mysqli->error);
  1985.             }
  1987.             foreach (GstockAutoMappings::MAPPINGS as $type => $pairs) {
  1988.                 foreach ($pairs as $pair) {
  1989.                     $source = (string)($pair['source'] ?? '');
  1990.                     $destination = (string)($pair['destination'] ?? '');
  1991.                     if ($source === '' || $destination === '') {
  1992.                         continue;
  1993.                     }
  1994.                     if ($type === 'header' && !isset($available['header'][$source])) {
  1995.                         continue;
  1996.                     }
  1997.                     if ($type === 'line' && !isset($available['line'][$source])) {
  1998.                         continue;
  1999.                     }
  2000.                     $key = $type . '|' . $source . '|' . $destination;
  2001.                     if (isset($existing[$key])) {
  2002.                         continue;
  2003.                     }
  2004.                     $stmtInsert->bind_param('isss', $modelId, $type, $source, $destination);
  2005.                     if (!$stmtInsert->execute()) {
  2006.                         $stmtInsert->close();
  2007.                         throw new \RuntimeException('Execute INSERT gstock_mapping para automapeo: ' . $stmtInsert->error);
  2008.                     }
  2009.                     $existing[$key] = true;
  2010.                 }
  2011.             }
  2013.             $stmtInsert->close();
  2014.             $mysqli->commit();
  2015.         } catch (\Throwable $e) {
  2016.             $mysqli->rollback();
  2017.             throw $e;
  2018.         }
  2019.     }
  2021.     private function saveEmpresaLogo(\mysqli $mysqli, array $data, ?string $customLogoFile = null): void
  2022.     {
  2023.         $this->logLogo('empresa_logo_save.log', '--- NUEVA LLAMADA saveEmpresaLogo ---');
  2024.         $this->logLogo('empresa_logo_save.log', 'customLogoFile = ' . var_export($customLogoFile, true));
  2025.         $this->logLogo('empresa_logo_save.log', 'data[empresa_vendor] = ' . var_export($data['empresa_vendor'] ?? null, true));
  2027.         // 1) Decidir qué logo vamos a guardar
  2028.         $logoFile = null;
  2030.         // --- PRIORIDAD: LOGO PERSONALIZADO ---
  2031.         if ($customLogoFile !== null && $customLogoFile !== '') {
  2032.             $logoFile = $customLogoFile;
  2033.             $this->logLogo('empresa_logo_save.log', 'Usando logo personalizado: ' . $logoFile);
  2034.         } else {
  2035.             // --- SI NO HAY PERSONALIZADO, USAMOS EL SELECT DE EMPRESA ---
  2036.             if (!isset($data['empresa_vendor']) || $data['empresa_vendor'] === '') {
  2037.                 $this->logLogo('empresa_logo_save.log', 'No hay empresa_vendor y no hay logo custom. No hago nada.');
  2038.                 return;
  2039.             }
  2041.             $empresa = $data['empresa_vendor'];
  2042.             $empresaKey = strtolower(trim((string)$empresa));
  2044.             $logoMap = [
  2045.                 'docunecta'  => 'DocuManager_transparente.png',
  2046.                 'docuindexa' => 'DocuIndexa.png',
  2047.             ];
  2048.             $vendorLabelMap = [
  2049.                 'docunecta'  => 'Docunecta',
  2050.                 'docuindexa' => 'Docuindexa',
  2051.             ];
  2053.             if (!isset($logoMap[$empresaKey])) {
  2054.                 $this->logLogo('empresa_logo_save.log', "empresa_vendor $empresa no está en logoMap. No hago nada.");
  2055.                 return;
  2056.             }
  2058.             $logoFile = $logoMap[$empresaKey];
  2059.             $vendorLabel = $vendorLabelMap[$empresaKey] ?? null;
  2060.             $this->logLogo('empresa_logo_save.log', 'Usando logo por vendor: ' . $logoFile);
  2061.         }
  2063.         if ($logoFile === null || $logoFile === '') {
  2064.             $this->logLogo('empresa_logo_save.log', 'logoFile está vacío. No hago nada.');
  2065.             return;
  2066.         }
  2068.         $this->logLogo('empresa_logo_save.log', 'Voy a guardar en parametros.logo: ' . $logoFile);
  2070.         $mysqli->begin_transaction();
  2072.         try {
  2073.             $stmt = $mysqli->prepare("
  2074.                 INSERT INTO parametros (nombre, valor)
  2075.                 VALUES (?, ?)
  2076.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2077.             ");
  2079.             if (!$stmt) {
  2080.                 $this->logLogo('empresa_logo_save.log', 'Error prepare: ' . $mysqli->error);
  2081.                 throw new \RuntimeException('Prepare logo: ' . $mysqli->error);
  2082.             }
  2084.             $paramName = 'logo';
  2085.             $stmt->bind_param('ss', $paramName, $logoFile);
  2087.             if (!$stmt->execute()) {
  2088.                 $this->logLogo('empresa_logo_save.log', 'Error execute: ' . $stmt->error);
  2089.                 throw new \RuntimeException('Guardar parámetro logo: ' . $stmt->error);
  2090.             }
  2092.             if (isset($vendorLabel) && $vendorLabel !== '') {
  2093.                 $paramName = 'vendor';
  2094.                 $stmt->bind_param('ss', $paramName, $vendorLabel);
  2095.                 if (!$stmt->execute()) {
  2096.                     $this->logLogo('empresa_logo_save.log', 'Error execute vendor: ' . $stmt->error);
  2097.                     throw new \RuntimeException('Guardar parámetro vendor: ' . $stmt->error);
  2098.                 }
  2099.             }
  2101.             $stmt->close();
  2102.             $mysqli->commit();
  2103.             $this->logLogo('empresa_logo_save.log', 'Logo guardado correctamente en BD.');
  2104.         } catch (\Throwable $e) {
  2105.             $mysqli->rollback();
  2106.             $this->logLogo('empresa_logo_save.log', 'EXCEPCIÓN: ' . $e->getMessage());
  2107.             throw $e;
  2108.         }
  2109.     }
  2111.     private function uploadEmpresaLogo(Request $req): ?string
  2112.     {
  2113.         $this->logLogo('empresa_logo_upload.log', '--- NUEVA LLAMADA uploadEmpresaLogo ---');
  2115.         // name del checkbox en el formulario (ajústalo si usas otro)
  2116.         $useCustomLogo = $req->request->get('customLogoCheck');
  2117.         $this->logLogo('empresa_logo_upload.log', 'customLogoCheck = ' . var_export($useCustomLogo, true));
  2119.         // Si no marcaron "usar logo personalizado", no hacemos nada
  2120.         if (!$useCustomLogo) {
  2121.             $this->logLogo('empresa_logo_upload.log', 'No se ha marcado customLogoCheck. Salgo sin subir.');
  2122.             return null;
  2123.         }
  2125.         /** @var UploadedFile|null $file */
  2126.         $file = $req->files->get('logo_personalizado'); // name="logo_personalizado" en el input file
  2127.         $this->logLogo('empresa_logo_upload.log', 'FILES[logo_personalizado] = ' . print_r($file, true));
  2129.         if (!$file instanceof UploadedFile || !$file->isValid()) {
  2130.             $this->logLogo('empresa_logo_upload.log', 'File no es UploadedFile válido. Salgo sin subir.');
  2131.             return null;
  2132.         }
  2134.         // VALIDACIONES BÁSICAS
  2135.         $maxSize = 2 * 1024 * 1024; // 2 MB por ejemplo
  2136.         if ($file->getSize() > $maxSize) {
  2137.             $this->logLogo('empresa_logo_upload.log', 'Tamańo demasiado grande: ' . $file->getSize());
  2138.             throw new \RuntimeException('El logo personalizado es demasiado grande (máx 2MB).');
  2139.         }
  2141.         $mime = $file->getMimeType();
  2142.         $allowedMimeTypes = ['image/png', 'image/jpeg', 'image/webp', 'image/svg+xml'];
  2143.         $this->logLogo('empresa_logo_upload.log', 'MIME = ' . $mime);
  2145.         if (!in_array($mime, $allowedMimeTypes, true)) {
  2146.             $this->logLogo('empresa_logo_upload.log', 'MIME no permitido.');
  2147.             throw new \RuntimeException('Formato de logo no permitido. Usa PNG, JPG, WEBP o SVG.');
  2148.         }
  2150.         // Directorio destino según entorno (configurado en .env/.env.local)
  2151.         $targetDir = $_ENV['APP_LOGO_DIR'] ?? null;
  2152.         $this->logLogo('empresa_logo_upload.log', 'APP_LOGO_DIR = ' . var_export($targetDir, true));
  2154.         if (!$targetDir) {
  2155.             throw new \RuntimeException('APP_LOGO_DIR no está configurado en el entorno.');
  2156.         }
  2157.         if (!is_dir($targetDir)) {
  2158.             $this->logLogo('empresa_logo_upload.log', "El directorio no existe: $targetDir");
  2159.             throw new \RuntimeException("El directorio de logos no existe: $targetDir");
  2160.         }
  2161.         if (!is_writable($targetDir)) {
  2162.             $this->logLogo('empresa_logo_upload.log', "El directorio no es escribible: $targetDir");
  2163.             throw new \RuntimeException("El directorio de logos no es escribible: $targetDir");
  2164.         }
  2166.         // Nombre de archivo "seguro" y único
  2167.         $ext = $file->guessExtension() ?: 'png';
  2168.         $fileName = 'logo_empresa_' . bin2hex(random_bytes(6)) . '.' . $ext;
  2169.         $this->logLogo('empresa_logo_upload.log', "Voy a mover archivo como: $fileName");
  2171.         // Mover físicamente el archivo
  2172.         $file->move($targetDir, $fileName);
  2173.         $this->logLogo('empresa_logo_upload.log', "Fichero movido OK a $targetDir/$fileName");
  2175.         // Devolvemos SOLO el nombre, que es lo que se guardará en parametros.logo
  2176.         return $fileName;
  2177.     }
  2179.     private function logLogo(string $fileName, string $message): void
  2180.     {
  2181.         // Directorio de logs de Symfony (donde está dev.log/prod.log)
  2182.         $logDir = $this->getParameter('kernel.logs_dir');
  2184.         $fullPath = rtrim($logDir, '/') . '/' . $fileName;
  2186.         $line = sprintf(
  2187.             "[%s] %s\n",
  2188.             date('Y-m-d H:i:s'),
  2189.             $message
  2190.         );
  2192.         file_put_contents($fullPath, $line, FILE_APPEND);
  2193.     }
  2195.     private function loadEmpresaLogo(\mysqli $mysqli): ?string
  2196.     {
  2197.         $sql = "SELECT valor FROM parametros WHERE nombre = 'logo' LIMIT 1";
  2198.         $res = $mysqli->query($sql);
  2199.         if (!$res) {
  2200.             return null;
  2201.         }
  2202.         if ($row = $res->fetch_assoc()) {
  2203.             return $row['valor'] ?? null;
  2204.         }
  2205.         return null;
  2206.     }
  2208.     private function upsertLicense(\mysqli $mysqli, array $data, int $capacityGb = 200, int $activeUsers = 3): void
  2209.     {
  2210.         $clientName = (string)($data['name'] ?? '');
  2211.         $licenseStr  = 'Documanager 1.0';
  2212.         $initialDate = date('Y-m-d');
  2213.         $price       = 0;
  2214.         $emailSender = 'Documanager.es';
  2215.         $emailFrom   = 'no-reply@documanager.es';
  2216.         $emailName   = 'Documanager';
  2217.         $ins = $mysqli->prepare("
  2218.             INSERT INTO license
  2219.                 (client, license, initialDate, capacityGb, users, price, emailSender, emailFrom, emailName)
  2220.             VALUES
  2221.                 (?,      ?,       ?,          ?,          ?,     ?,     ?,           ?,         ?)
  2222.         ");
  2223.         if (!$ins) {
  2224.             throw new \RuntimeException('Prepare INSERT license: ' . $mysqli->error);
  2225.         }
  2226.         $ins->bind_param(
  2227.             'sssiiisss',
  2228.             $clientName,
  2229.             $licenseStr,
  2230.             $initialDate,
  2231.             $capacityGb,
  2232.             $activeUsers,
  2233.             $price,
  2234.             $emailSender,
  2235.             $emailFrom,
  2236.             $emailName
  2237.         );
  2238.         if (!$ins->execute()) {
  2239.             $ins->close();
  2240.             throw new \RuntimeException('Execute INSERT license: ' . $ins->error);
  2241.         }
  2242.         $ins->close();
  2243.     }
  2245.     private function mapAzureSchemaToDefinitions(array $modelDetail): array
  2246.     {
  2247.         $docTypes = $modelDetail['docTypes'] ?? [];
  2248.         if (!is_array($docTypes) || $docTypes === []) {
  2249.             return ['header' => [], 'lines' => []];
  2250.         }
  2252.         $modelId = (string)($modelDetail['modelId'] ?? '');
  2253.         $docTypeKey = ($modelId !== '' && array_key_exists($modelId, $docTypes))
  2254.             ? $modelId
  2255.             : array_key_first($docTypes);
  2257.         if (!is_string($docTypeKey) || !isset($docTypes[$docTypeKey]) || !is_array($docTypes[$docTypeKey])) {
  2258.             return ['header' => [], 'lines' => []];
  2259.         }
  2261.         $fieldSchema = $docTypes[$docTypeKey]['fieldSchema'] ?? [];
  2262.         if (!is_array($fieldSchema)) {
  2263.             return ['header' => [], 'lines' => []];
  2264.         }
  2266.         $rawHeader = [];
  2267.         $rawLines = [];
  2268.         foreach ($fieldSchema as $fieldKey => $fieldDef) {
  2269.             if (!is_string($fieldKey) || !is_array($fieldDef)) {
  2270.                 continue;
  2271.             }
  2272.             $this->flattenFieldSchema($fieldKey, $fieldDef, $rawHeader, $rawLines);
  2273.         }
  2275.         $header = [];
  2276.         $lines = [];
  2277.         $seenHeader = [];
  2278.         $seenLines = [];
  2280.         foreach ($rawHeader as $item) {
  2281.             $key = (string)($item['field_key'] ?? '');
  2282.             if ($key === '' || isset($seenHeader[$key])) {
  2283.                 continue;
  2284.             }
  2285.             $seenHeader[$key] = true;
  2286.             $header[] = [
  2287.                 'field_key' => $key,
  2288.                 'label' => $key,
  2289.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2290.             ];
  2291.         }
  2293.         foreach ($rawLines as $item) {
  2294.             $key = (string)($item['field_key'] ?? '');
  2295.             if ($key === '' || isset($seenLines[$key])) {
  2296.                 continue;
  2297.             }
  2298.             $seenLines[$key] = true;
  2299.             $lines[] = [
  2300.                 'field_key' => $key,
  2301.                 'label' => $key,
  2302.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2303.             ];
  2304.         }
  2306.         foreach ($header as $index => &$item) {
  2307.             $order = $index + 1;
  2308.             $item['order_index'] = $order;
  2309.             $item['order_index_table'] = $order;
  2310.             $item['visibility'] = 1;
  2311.             $item['visibility_table'] = 1;
  2312.         }
  2314.         foreach ($lines as $index => &$item) {
  2315.             $item['order_index'] = $index + 1;
  2316.             $item['visibility'] = 1;
  2317.         }
  2319.         return ['header' => $header, 'lines' => $lines];
  2320.     }
  2322.     private function flattenFieldSchema(
  2323.         string $fieldKey,
  2324.         array $fieldDef,
  2325.         array &$header,
  2326.         array &$lines,
  2327.         bool $insideItems = false,
  2328.         string $parentPath = ''
  2329.     ): void {
  2330.         $type = strtolower((string)($fieldDef['type'] ?? 'string'));
  2331.         $currentPath = $parentPath !== '' ? $parentPath . '.' . $fieldKey : $fieldKey;
  2333.         if ($insideItems) {
  2334.             if ($type === 'object') {
  2335.                 $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  2336.                 if (is_array($properties)) {
  2337.                     foreach ($properties as $childKey => $childDef) {
  2338.                         if (is_string($childKey) && is_array($childDef)) {
  2339.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $currentPath);
  2340.                         }
  2341.                     }
  2342.                 }
  2343.                 return;
  2344.             }
  2346.             if ($type === 'array') {
  2347.                 $itemsDef = $fieldDef['items'] ?? [];
  2348.                 $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  2349.                 if ($itemType === 'object') {
  2350.                     $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  2351.                     if (is_array($properties)) {
  2352.                         $arrayPath = $currentPath . '[*]';
  2353.                         foreach ($properties as $childKey => $childDef) {
  2354.                             if (is_string($childKey) && is_array($childDef)) {
  2355.                                 $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $arrayPath);
  2356.                             }
  2357.                         }
  2358.                     }
  2359.                 } else {
  2360.                     $lines[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  2361.                 }
  2362.                 return;
  2363.             }
  2365.             $lines[] = ['field_key' => $currentPath, 'azure_type' => $type];
  2366.             return;
  2367.         }
  2369.         if ($type === 'object') {
  2370.             $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  2371.             if (is_array($properties)) {
  2372.                 foreach ($properties as $childKey => $childDef) {
  2373.                     if (is_string($childKey) && is_array($childDef)) {
  2374.                         $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $currentPath);
  2375.                     }
  2376.                 }
  2377.             }
  2378.             return;
  2379.         }
  2381.         if ($type === 'array') {
  2382.             $itemsDef = $fieldDef['items'] ?? [];
  2383.             $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  2384.             $isItems = strtolower($fieldKey) === 'items';
  2386.             if ($itemType === 'object') {
  2387.                 $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  2388.                 if (!is_array($properties)) {
  2389.                     return;
  2390.                 }
  2392.                 if ($isItems) {
  2393.                     foreach ($properties as $childKey => $childDef) {
  2394.                         if (is_string($childKey) && is_array($childDef)) {
  2395.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, '');
  2396.                         }
  2397.                     }
  2398.                 } else {
  2399.                     $arrayPath = $currentPath . '[*]';
  2400.                     foreach ($properties as $childKey => $childDef) {
  2401.                         if (is_string($childKey) && is_array($childDef)) {
  2402.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $arrayPath);
  2403.                         }
  2404.                     }
  2405.                 }
  2406.                 return;
  2407.             }
  2409.             $header[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  2410.             return;
  2411.         }
  2413.         $header[] = ['field_key' => $currentPath, 'azure_type' => $type];
  2414.     }
  2416.     private function mapAzureTypeToValueType(string $azureType): string
  2417.     {
  2418.         $azureType = strtolower(trim($azureType));
  2419.         if ($azureType === 'date') {
  2420.             return 'date';
  2421.         }
  2422.         if ($azureType === 'number' || $azureType === 'integer') {
  2423.             return 'number';
  2424.         }
  2425.         return 'string';
  2426.     }
  2428.     private function registerDiModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  2429.     {
  2430.         $modelId = trim($modelId);
  2431.         if ($modelId === '') {
  2432.             throw new \RuntimeException('ModelId de recurso IA obligatorio.', 400);
  2433.         }
  2435.         $modelDetail = $this->azureRequest(
  2436.             (string)($resource['endpoint'] ?? ''),
  2437.             (string)($resource['api_key'] ?? ''),
  2438.             '/documentintelligence/documentModels/' . rawurlencode($modelId)
  2439.         );
  2440.         $type = $this->classifyModelType($modelDetail);
  2441.         $definitions = $this->mapAzureSchemaToDefinitions($modelDetail);
  2443.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  2444.         $apiKey = (string)($resource['api_key'] ?? '');
  2445.         $showConfidenceBadges = 0;
  2447.         $clientMysqli->begin_transaction();
  2448.         try {
  2449.             $existingId = 0;
  2450.             $stmtSelect = $clientMysqli->prepare(
  2451.                 "SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? LIMIT 1"
  2452.             );
  2453.             if (!$stmtSelect) {
  2454.                 throw new \RuntimeException('Prepare SELECT extraction_models: ' . $clientMysqli->error);
  2455.             }
  2456.             $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  2457.             $stmtSelect->bind_param('ss', $provider, $modelId);
  2458.             if (!$stmtSelect->execute()) {
  2459.                 $stmtSelect->close();
  2460.                 throw new \RuntimeException('Execute SELECT extraction_models: ' . $stmtSelect->error);
  2461.             }
  2462.             $result = $stmtSelect->get_result();
  2463.             if ($result && ($row = $result->fetch_assoc())) {
  2464.                 $existingId = (int)$row['id'];
  2465.             }
  2466.             $stmtSelect->close();
  2468.             if ($existingId > 0) {
  2469.                 $stmtUpdate = $clientMysqli->prepare(
  2470.                     'UPDATE extraction_models
  2471.                      SET endpoint = ?, api_key = ?, type = ?, show_confidence_badges = ?
  2472.                      WHERE id = ?'
  2473.                 );
  2474.                 if (!$stmtUpdate) {
  2475.                     throw new \RuntimeException('Prepare UPDATE extraction_models: ' . $clientMysqli->error);
  2476.                 }
  2477.                 $stmtUpdate->bind_param('sssii', $endpoint, $apiKey, $type, $showConfidenceBadges, $existingId);
  2478.                 if (!$stmtUpdate->execute()) {
  2479.                     $stmtUpdate->close();
  2480.                     throw new \RuntimeException('Execute UPDATE extraction_models: ' . $stmtUpdate->error);
  2481.                 }
  2482.                 $stmtUpdate->close();
  2483.                 $localModelId = $existingId;
  2484.             } else {
  2485.                 $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  2486.                 $stmtInsert = $clientMysqli->prepare(
  2487.                     'INSERT INTO extraction_models (provider, model_id, endpoint, api_key, type, show_confidence_badges)
  2488.                      VALUES (?, ?, ?, ?, ?, ?)'
  2489.                 );
  2490.                 if (!$stmtInsert) {
  2491.                     throw new \RuntimeException('Prepare INSERT extraction_models: ' . $clientMysqli->error);
  2492.                 }
  2493.                 $stmtInsert->bind_param('sssssi', $provider, $modelId, $endpoint, $apiKey, $type, $showConfidenceBadges);
  2494.                 if (!$stmtInsert->execute()) {
  2495.                     $stmtInsert->close();
  2496.                     throw new \RuntimeException('Execute INSERT extraction_models: ' . $stmtInsert->error);
  2497.                 }
  2498.                 $localModelId = (int)$stmtInsert->insert_id;
  2499.                 $stmtInsert->close();
  2500.             }
  2502.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  2503.             if (!$stmtDelHeader) {
  2504.                 throw new \RuntimeException('Prepare DELETE definitions_header: ' . $clientMysqli->error);
  2505.             }
  2506.             $stmtDelHeader->bind_param('i', $localModelId);
  2507.             if (!$stmtDelHeader->execute()) {
  2508.                 $stmtDelHeader->close();
  2509.                 throw new \RuntimeException('Execute DELETE definitions_header: ' . $stmtDelHeader->error);
  2510.             }
  2511.             $stmtDelHeader->close();
  2513.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  2514.             if (!$stmtDelLines) {
  2515.                 throw new \RuntimeException('Prepare DELETE definitions_lines: ' . $clientMysqli->error);
  2516.             }
  2517.             $stmtDelLines->bind_param('i', $localModelId);
  2518.             if (!$stmtDelLines->execute()) {
  2519.                 $stmtDelLines->close();
  2520.                 throw new \RuntimeException('Execute DELETE definitions_lines: ' . $stmtDelLines->error);
  2521.             }
  2522.             $stmtDelLines->close();
  2524.             if (!empty($definitions['header'])) {
  2525.                 $stmtHeader = $clientMysqli->prepare(
  2526.                     'INSERT INTO definitions_header
  2527.                     (model_id, field_key, label, value_type, order_index, visibility, order_index_table, visibility_table)
  2528.                     VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  2529.                 );
  2530.                 if (!$stmtHeader) {
  2531.                     throw new \RuntimeException('Prepare INSERT definitions_header: ' . $clientMysqli->error);
  2532.                 }
  2533.                 foreach ($definitions['header'] as $item) {
  2534.                     $fieldKey = (string)$item['field_key'];
  2535.                     $label = (string)$item['label'];
  2536.                     $valueType = (string)$item['value_type'];
  2537.                     $orderIndex = (int)$item['order_index'];
  2538.                     $visibility = (int)$item['visibility'];
  2539.                     $orderIndexTable = (int)$item['order_index_table'];
  2540.                     $visibilityTable = (int)$item['visibility_table'];
  2541.                     $stmtHeader->bind_param(
  2542.                         'isssiiii',
  2543.                         $localModelId,
  2544.                         $fieldKey,
  2545.                         $label,
  2546.                         $valueType,
  2547.                         $orderIndex,
  2548.                         $visibility,
  2549.                         $orderIndexTable,
  2550.                         $visibilityTable
  2551.                     );
  2552.                     if (!$stmtHeader->execute()) {
  2553.                         $stmtHeader->close();
  2554.                         throw new \RuntimeException('Execute INSERT definitions_header: ' . $stmtHeader->error);
  2555.                     }
  2556.                 }
  2557.                 $stmtHeader->close();
  2558.             }
  2560.             if (!empty($definitions['lines'])) {
  2561.                 $stmtLines = $clientMysqli->prepare(
  2562.                     'INSERT INTO definitions_lines
  2563.                     (model_id, field_key, label, value_type, order_index, visibility)
  2564.                     VALUES (?, ?, ?, ?, ?, ?)'
  2565.                 );
  2566.                 if (!$stmtLines) {
  2567.                     throw new \RuntimeException('Prepare INSERT definitions_lines: ' . $clientMysqli->error);
  2568.                 }
  2569.                 foreach ($definitions['lines'] as $item) {
  2570.                     $fieldKey = (string)$item['field_key'];
  2571.                     $label = (string)$item['label'];
  2572.                     $valueType = (string)$item['value_type'];
  2573.                     $orderIndex = (int)$item['order_index'];
  2574.                     $visibility = (int)$item['visibility'];
  2575.                     $stmtLines->bind_param(
  2576.                         'isssii',
  2577.                         $localModelId,
  2578.                         $fieldKey,
  2579.                         $label,
  2580.                         $valueType,
  2581.                         $orderIndex,
  2582.                         $visibility
  2583.                     );
  2584.                     if (!$stmtLines->execute()) {
  2585.                         $stmtLines->close();
  2586.                         throw new \RuntimeException('Execute INSERT definitions_lines: ' . $stmtLines->error);
  2587.                     }
  2588.                 }
  2589.                 $stmtLines->close();
  2590.             }
  2592.             $clientMysqli->commit();
  2593.             return $localModelId;
  2594.         } catch (\Throwable $e) {
  2595.             $clientMysqli->rollback();
  2596.             throw $e;
  2597.         }
  2598.     }
  2600.     private function registerModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  2601.     {
  2602.         return $this->registerDiModelInClientDb($clientMysqli, $resource, $modelId);
  2603.     }
  2605.     private function normalizeAoaiFieldScope(string $scope): string
  2606.     {
  2607.         $scope = strtolower(trim($scope));
  2608.         return $scope === 'lines' ? 'lines' : 'header';
  2609.     }
  2611.     private function normalizeAoaiValueType(string $valueType): string
  2612.     {
  2613.         $valueType = strtolower(trim($valueType));
  2614.         if ($valueType === 'number') {
  2615.             return 'number';
  2616.         }
  2617.         if ($valueType === 'date') {
  2618.             return 'date';
  2619.         }
  2620.         return 'string';
  2621.     }
  2623.     private function collectAoaiFieldsFromRequest(Request $request): array
  2624.     {
  2625.         $scopes = $request->request->all('aoai_fields_scope');
  2626.         $keys = $request->request->all('aoai_fields_key');
  2627.         $prompts = $request->request->all('aoai_fields_prompt');
  2628.         $valueTypes = $request->request->all('aoai_fields_type');
  2630.         if (!is_array($scopes)) {
  2631.             $scopes = [];
  2632.         }
  2633.         if (!is_array($keys)) {
  2634.             $keys = [];
  2635.         }
  2636.         if (!is_array($prompts)) {
  2637.             $prompts = [];
  2638.         }
  2639.         if (!is_array($valueTypes)) {
  2640.             $valueTypes = [];
  2641.         }
  2643.         $max = max(count($scopes), count($keys), count($prompts), count($valueTypes));
  2644.         $fields = [];
  2645.         for ($i = 0; $i < $max; $i++) {
  2646.             $scope = $this->normalizeAoaiFieldScope((string)($scopes[$i] ?? 'header'));
  2647.             $fieldKey = trim((string)($keys[$i] ?? ''));
  2648.             $prompt = trim((string)($prompts[$i] ?? ''));
  2649.             $valueType = $this->normalizeAoaiValueType((string)($valueTypes[$i] ?? 'string'));
  2650.             if ($fieldKey === '' && $prompt === '') {
  2651.                 continue;
  2652.             }
  2653.             $fields[] = [
  2654.                 'scope' => $scope,
  2655.                 'field_key' => $fieldKey,
  2656.                 'prompt' => $prompt,
  2657.                 'value_type' => $valueType,
  2658.             ];
  2659.         }
  2660.         return $fields;
  2661.     }
  2663.     private function validateAoaiFields(array $fields): ?string
  2664.     {
  2665.         if (count($fields) === 0) {
  2666.             return 'Debes indicar al menos un campo para Azure OpenAI.';
  2667.         }
  2669.         $seen = [];
  2670.         foreach ($fields as $item) {
  2671.             $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  2672.             $fieldKey = trim((string)($item['field_key'] ?? ''));
  2673.             $prompt = trim((string)($item['prompt'] ?? ''));
  2674.             $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  2675.             if ($fieldKey === '' || $prompt === '') {
  2676.                 return 'Todos los campos de Azure OpenAI deben tener nombre y prompt.';
  2677.             }
  2678.             if (!in_array($valueType, ['string', 'number', 'date'], true)) {
  2679.                 return 'El tipo de dato permitido es string, number o date.';
  2680.             }
  2681.             $uniq = $scope . '|' . strtolower($fieldKey);
  2682.             if (isset($seen[$uniq])) {
  2683.                 return 'No se permiten campos repetidos dentro del mismo alcance (cabecera o líneas).';
  2684.             }
  2685.             $seen[$uniq] = true;
  2686.         }
  2688.         return null;
  2689.     }
  2691.     private function registerAoaiModelInClientDb(\mysqli $clientMysqli, array $resource, array $aoaiFields): int
  2692.     {
  2693.         $extractorType = $this->normalizeExtractorType((string)($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  2694.         if ($extractorType !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  2695.             throw new \RuntimeException('El recurso seleccionado no es de tipo Azure OpenAI.', 400);
  2696.         }
  2698.         $validationError = $this->validateAoaiFields($aoaiFields);
  2699.         if ($validationError !== null) {
  2700.             throw new \RuntimeException($validationError, 400);
  2701.         }
  2703.         $modelId = trim((string)($resource['model_id'] ?? ''));
  2704.         $basePrompt = trim((string)($resource['base_prompt'] ?? ''));
  2705.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  2706.         $apiKey = trim((string)($resource['api_key'] ?? ''));
  2707.         if ($modelId === '' || $basePrompt === '' || $endpoint === '' || $apiKey === '') {
  2708.             throw new \RuntimeException('El recurso Azure OpenAI está incompleto.', 400);
  2709.         }
  2711.         $provider = 'azure_openai';
  2712.         $type = 'custom';
  2713.         $showConfidenceBadges = 0;
  2715.         $clientMysqli->begin_transaction();
  2716.         try {
  2717.             $existingId = 0;
  2718.             $stmtSelect = $clientMysqli->prepare(
  2719.                 'SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? LIMIT 1'
  2720.             );
  2721.             if (!$stmtSelect) {
  2722.                 throw new \RuntimeException('Prepare SELECT extraction_models AOAI: ' . $clientMysqli->error);
  2723.             }
  2724.             $stmtSelect->bind_param('ss', $provider, $modelId);
  2725.             if (!$stmtSelect->execute()) {
  2726.                 $stmtSelect->close();
  2727.                 throw new \RuntimeException('Execute SELECT extraction_models AOAI: ' . $stmtSelect->error);
  2728.             }
  2729.             $result = $stmtSelect->get_result();
  2730.             if ($result && ($row = $result->fetch_assoc())) {
  2731.                 $existingId = (int)$row['id'];
  2732.             }
  2733.             $stmtSelect->close();
  2735.             if ($existingId > 0) {
  2736.                 $stmtUpdate = $clientMysqli->prepare(
  2737.                     'UPDATE extraction_models
  2738.                      SET endpoint = ?, api_key = ?, base_prompt = ?, type = ?, show_confidence_badges = ?
  2739.                      WHERE id = ?'
  2740.                 );
  2741.                 if (!$stmtUpdate) {
  2742.                     throw new \RuntimeException('Prepare UPDATE extraction_models AOAI: ' . $clientMysqli->error);
  2743.                 }
  2744.                 $stmtUpdate->bind_param('ssssii', $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges, $existingId);
  2745.                 if (!$stmtUpdate->execute()) {
  2746.                     $stmtUpdate->close();
  2747.                     throw new \RuntimeException('Execute UPDATE extraction_models AOAI: ' . $stmtUpdate->error);
  2748.                 }
  2749.                 $stmtUpdate->close();
  2750.                 $localModelId = $existingId;
  2751.             } else {
  2752.                 $stmtInsert = $clientMysqli->prepare(
  2753.                     'INSERT INTO extraction_models (provider, model_id, endpoint, api_key, base_prompt, type, show_confidence_badges)
  2754.                      VALUES (?, ?, ?, ?, ?, ?, ?)'
  2755.                 );
  2756.                 if (!$stmtInsert) {
  2757.                     throw new \RuntimeException('Prepare INSERT extraction_models AOAI: ' . $clientMysqli->error);
  2758.                 }
  2759.                 $stmtInsert->bind_param('ssssssi', $provider, $modelId, $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges);
  2760.                 if (!$stmtInsert->execute()) {
  2761.                     $stmtInsert->close();
  2762.                     throw new \RuntimeException('Execute INSERT extraction_models AOAI: ' . $stmtInsert->error);
  2763.                 }
  2764.                 $localModelId = (int)$stmtInsert->insert_id;
  2765.                 $stmtInsert->close();
  2766.             }
  2768.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  2769.             if (!$stmtDelHeader) {
  2770.                 throw new \RuntimeException('Prepare DELETE definitions_header AOAI: ' . $clientMysqli->error);
  2771.             }
  2772.             $stmtDelHeader->bind_param('i', $localModelId);
  2773.             if (!$stmtDelHeader->execute()) {
  2774.                 $stmtDelHeader->close();
  2775.                 throw new \RuntimeException('Execute DELETE definitions_header AOAI: ' . $stmtDelHeader->error);
  2776.             }
  2777.             $stmtDelHeader->close();
  2779.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  2780.             if (!$stmtDelLines) {
  2781.                 throw new \RuntimeException('Prepare DELETE definitions_lines AOAI: ' . $clientMysqli->error);
  2782.             }
  2783.             $stmtDelLines->bind_param('i', $localModelId);
  2784.             if (!$stmtDelLines->execute()) {
  2785.                 $stmtDelLines->close();
  2786.                 throw new \RuntimeException('Execute DELETE definitions_lines AOAI: ' . $stmtDelLines->error);
  2787.             }
  2788.             $stmtDelLines->close();
  2790.             $stmtHeader = $clientMysqli->prepare(
  2791.                 'INSERT INTO definitions_header
  2792.                 (model_id, field_key, label, prompt, value_type, order_index, visibility, order_index_table, visibility_table)
  2793.                 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)'
  2794.             );
  2795.             if (!$stmtHeader) {
  2796.                 throw new \RuntimeException('Prepare INSERT definitions_header AOAI: ' . $clientMysqli->error);
  2797.             }
  2799.             $stmtLines = $clientMysqli->prepare(
  2800.                 'INSERT INTO definitions_lines
  2801.                 (model_id, field_key, label, prompt, value_type, order_index, visibility)
  2802.                 VALUES (?, ?, ?, ?, ?, ?, ?)'
  2803.             );
  2804.             if (!$stmtLines) {
  2805.                 $stmtHeader->close();
  2806.                 throw new \RuntimeException('Prepare INSERT definitions_lines AOAI: ' . $clientMysqli->error);
  2807.             }
  2809.             $headerOrder = 1;
  2810.             $lineOrder = 1;
  2811.             foreach ($aoaiFields as $item) {
  2812.                 $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  2813.                 $fieldKey = trim((string)($item['field_key'] ?? ''));
  2814.                 $prompt = trim((string)($item['prompt'] ?? ''));
  2815.                 $label = $fieldKey;
  2816.                 $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  2817.                 $visibility = 1;
  2818.                 if ($scope === 'lines') {
  2819.                     $orderIndex = $lineOrder++;
  2820.                     $stmtLines->bind_param(
  2821.                         'issssii',
  2822.                         $localModelId,
  2823.                         $fieldKey,
  2824.                         $label,
  2825.                         $prompt,
  2826.                         $valueType,
  2827.                         $orderIndex,
  2828.                         $visibility
  2829.                     );
  2830.                     if (!$stmtLines->execute()) {
  2831.                         throw new \RuntimeException('Execute INSERT definitions_lines AOAI: ' . $stmtLines->error);
  2832.                     }
  2833.                 } else {
  2834.                     $orderIndex = $headerOrder++;
  2835.                     $orderIndexTable = $orderIndex;
  2836.                     $visibilityTable = 1;
  2837.                     $stmtHeader->bind_param(
  2838.                         'issssiiii',
  2839.                         $localModelId,
  2840.                         $fieldKey,
  2841.                         $label,
  2842.                         $prompt,
  2843.                         $valueType,
  2844.                         $orderIndex,
  2845.                         $visibility,
  2846.                         $orderIndexTable,
  2847.                         $visibilityTable
  2848.                     );
  2849.                     if (!$stmtHeader->execute()) {
  2850.                         throw new \RuntimeException('Execute INSERT definitions_header AOAI: ' . $stmtHeader->error);
  2851.                     }
  2852.                 }
  2853.             }
  2855.             $stmtHeader->close();
  2856.             $stmtLines->close();
  2858.             $clientMysqli->commit();
  2859.             return $localModelId;
  2860.         } catch (\Throwable $e) {
  2861.             $clientMysqli->rollback();
  2862.             throw $e;
  2863.         }
  2864.     }
  2866.     public function Empresa(Request $req, EntityManagerInterface $em)
  2867.     {
  2868.         if (!$this->getUser() || !is_object($this->getUser())) {
  2869.             return $this->redirectToRoute('logout');
  2870.         }
  2872.         $id = (int)$req->get("id");
  2873.         if (!$id) {
  2874.             $this->addFlash('warning', 'Empresa no encontrada.');
  2875.             return $this->redirectToRoute("list");
  2876.         }
  2878.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2879.         if (!$empresa) {
  2880.             $this->addFlash('warning', 'Empresa no encontrada.');
  2881.             return $this->redirectToRoute("list");
  2882.         }
  2884.         $users = $em->getRepository(Usuario::class)->findBy([
  2885.             "empresa" => $empresa->getId()
  2886.         ]);
  2888.         // Valores por defecto por si algo falla al conectar con la BD del cliente
  2889.         $activeUsers            = null;
  2890.         $modulos                = [];
  2891.         $empresaLogo            = null;
  2892.         $extractionModelLabel   = null;
  2894.         $diskUsedBytes          = null;
  2895.         $diskUsedGb             = null;
  2897.         try {
  2898.             $cx = $empresa->getConexionBD();
  2899.             if ($cx) {
  2900.                 $mysqli = @new \mysqli(
  2901.                     $cx->getDbUrl(),
  2902.                     $cx->getDbUser(),
  2903.                     $cx->getDbPassword(),
  2904.                     $cx->getDbName(),
  2905.                     (int)$cx->getDbPort()
  2906.                 );
  2908.                 if (!$mysqli->connect_error) {
  2909.                     // parámetros (modulos, límites, etc.)
  2910.                     [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  2912.                     // logo guardado en la BD del cliente
  2913.                     $empresaLogo = $this->loadEmpresaLogo($mysqli);
  2915.                     $diskUsedBytes = $this->loadEmpresaDiskUsageBytes($mysqli);
  2916.                     $diskUsedGb = ($diskUsedBytes !== null)
  2917.                         ? round($diskUsedBytes / 1024 / 1024 / 1024, 2)
  2918.                         : null;
  2920.                     // Si tiene extracción y modelo seleccionado, buscamos el ID legible del modelo
  2921.                     if (
  2922.                         !empty($modulos['modulo_extraccion']) &&
  2923.                         !empty($modulos['extraction_model'])
  2924.                     ) {
  2925.                         try {
  2926.                             $stmt = $mysqli->prepare('SELECT model_id FROM extraction_models WHERE id = ? LIMIT 1');
  2927.                             if ($stmt) {
  2928.                                 $modelParam = (int)$modulos['extraction_model'];
  2929.                                 $stmt->bind_param('i', $modelParam);
  2930.                                 if ($stmt->execute()) {
  2931.                                     $res = $stmt->get_result();
  2932.                                     if ($res && ($row = $res->fetch_assoc()) && isset($row['model_id'])) {
  2933.                                         $extractionModelLabel = $row['model_id'];
  2934.                                     }
  2935.                                 }
  2936.                                 $stmt->close();
  2937.                             }
  2938.                         } catch (\Throwable $e) {
  2939.                             // Si falla, simplemente no mostramos el texto bonito del modelo
  2940.                             $extractionModelLabel = null;
  2941.                         }
  2942.                     }
  2944.                     $mysqli->close();
  2945.                 }
  2946.             }
  2947.         } catch (\Throwable $e) {
  2948.             // Aquí podrías loguear el error si quieres, pero no rompemos la pantalla
  2949.         }
  2951.         return $this->render('empresa_detail.html.twig', [
  2952.             'empresa'              => $empresa,
  2953.             'users'                => $users,
  2954.             'activeUsers'          => $activeUsers,
  2955.             'modulos'              => $modulos,
  2956.             'empresaLogo'          => $empresaLogo,
  2957.             'extractionModelLabel' => $extractionModelLabel,
  2958.             'diskUsedGb' => $diskUsedGb,
  2959.         ]);
  2960.     }
  2962.     public function deleteEmpresa(Request $request, EntityManagerInterface $em)
  2963.     {
  2964.         $id = $request->get("id");
  2966.         $empresa = $em->getRepository(Empresa::class)->find($id);
  2968.         $conexion = $empresa->getConexionBD();
  2969.         $usuarios = $em->getRepository(Usuario::class)->findBy(array("empresa" => $empresa->getId()));
  2971.         // Recoger avatar/firma de usuarios antes de eliminar la BD del cliente
  2972.         $mediaPaths = [];
  2973.         try {
  2974.             $mysqliMedia = @new \mysqli(
  2975.                 $conexion->getDbUrl(),
  2976.                 $conexion->getDbUser(),
  2977.                 $conexion->getDbPassword(),
  2978.                 $conexion->getDbName(),
  2979.                 (int)$conexion->getDbPort()
  2980.             );
  2981.             if (!$mysqliMedia->connect_error) {
  2982.                 $mediaPaths = $this->getCompanyUserMediaPaths($mysqliMedia);
  2983.                 $mysqliMedia->close();
  2984.             } else {
  2985.                 error_log('No se pudo conectar a BD cliente para borrar media: ' . $mysqliMedia->connect_error);
  2986.             }
  2987.         } catch (\Throwable $e) {
  2988.             error_log('Error borrando media de usuarios: ' . $e->getMessage());
  2989.         }
  2992.         $hestiaApiUrl = 'https://200.234.237.107:8083/api/';
  2993.         $owner = 'docunecta'; // o el dueño del hosting
  2996.         $postFields = http_build_query([
  2997.             'user' => 'admin',
  2998.             'password' => 'i9iQiSmxb2EpvgLq',
  2999.             'returncode' => 'yes',
  3000.             'cmd' => 'v-delete-database',
  3001.             'arg1' => 'admin',
  3002.             'arg2' => $conexion->getDbName(),
  3004.         ]);
  3006.         $accessKeyId = 'cWYbt9ShyFQ3yVRsUE8u';
  3007.         $secretKey = 'e2M_5wk2_jUAlPorF7V8zfwo3_0ihu90WoLPMKwj';
  3008.         $headers = [
  3009.             'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  3010.         ];
  3012.         $ch = curl_init();
  3013.         curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  3014.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  3015.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  3016.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  3017.         curl_setopt($ch, CURLOPT_POST, true);
  3018.         curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  3019.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  3021.         $response = curl_exec($ch);
  3022.         $error = curl_error($ch);
  3023.         curl_close($ch);
  3025.         if (($error || trim($response) !== '0') && trim($response) !== '3') {
  3026.             $this->addFlash('danger', 'Error al eliminar la base de datos en HestiaCP: ' . ($error ?: $response));
  3027.             return $this->redirectToRoute('list');
  3028.         }
  3030.         // Eliminar el servicio systemd asociado a la empresa
  3031.         $company_name = $empresa->getId();
  3033.         $serviceName = $company_name . "-documanager.service";
  3034.         $servicePath = "/etc/systemd/system/$serviceName";
  3035.         $cmds = [
  3036.             "sudo /bin/systemctl stop $serviceName",
  3037.             "sudo /bin/systemctl disable $serviceName",
  3038.             "sudo /bin/rm -f $servicePath",
  3039.             "sudo /bin/systemctl daemon-reload"
  3040.         ];
  3041.         $serviceErrors = [];
  3042.         foreach ($cmds as $cmd) {
  3043.             $output = @\shell_exec($cmd . " 2>&1");
  3044.             if ($output !== null && trim($output) !== '') {
  3045.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  3046.             }
  3047.         }
  3049.         $azureService = $company_name . "-azuredi.service";
  3050.         $servicePathAzure = "/etc/systemd/system/$azureService";
  3051.         $cmdsAzure = [
  3052.             "sudo /bin/systemctl stop $azureService",
  3053.             "sudo /bin/systemctl disable $azureService",
  3054.             "sudo /bin/rm -f $servicePathAzure",
  3055.             "sudo /bin/systemctl daemon-reload",
  3056.         ];
  3057.         foreach ($cmdsAzure as $cmd) {
  3058.             $output = @\shell_exec($cmd . " 2>&1");
  3059.             if ($output) {
  3060.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  3061.             }
  3062.         }
  3064.         // Eliminar mail monitor service + timer (si existen)
  3065.         $this->disableMailMonitorService((int)$company_name);
  3067.         // Pedir a platform que elimine files/logs/media del cliente
  3068.         $this->callPlatformCleanup((int)$company_name, $mediaPaths);
  3070.         //eliminamos usuarios
  3071.         foreach ($usuarios as $user) {
  3072.             $em->remove($user);
  3073.             $em->flush();
  3074.         }
  3076.         //eliminamos conexiĂłn
  3077.         $em->remove($conexion);
  3078.         $em->flush();
  3080.         //eliminamos empresa
  3081.         $em->remove($empresa);
  3082.         $em->flush();
  3083.         $msg = 'Empresa y base de datos eliminadas correctamente.';
  3084.         if (count($serviceErrors) > 0) {
  3085.             $msg .= ' ' . implode('<br>', $serviceErrors);
  3086.         }
  3087.         $this->addFlash('success', $msg);
  3088.         return $this->redirectToRoute('list');
  3089.     }
  3091.     public function editEmpresa(Request $request, EntityManagerInterface $em)
  3092.     {
  3093.         if (!$this->getUser() || !is_object($this->getUser())) {
  3094.             return $this->redirectToRoute('logout');
  3095.         }
  3097.         $id = (int)$request->get('id');
  3098.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3099.         if (!$empresa) {
  3100.             throw $this->createNotFoundException('Empresa no encontrada');
  3101.         }
  3103.         // 1) Conectar a la BD del cliente con las credenciales de la central
  3104.         $cx = $empresa->getConexionBD();
  3105.         $mysqli = @new \mysqli(
  3106.             $cx->getDbUrl(),
  3107.             $cx->getDbUser(),
  3108.             $cx->getDbPassword(),
  3109.             $cx->getDbName(),
  3110.             (int)$cx->getDbPort()
  3111.         );
  3112.         if ($mysqli->connect_error) {
  3113.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  3114.             return $this->redirectToRoute('list');
  3115.         }
  3117.         $ocrPlusAvailable = $this->isOcrPlusAvailable();
  3118.         $ocrV2Available = $this->isOcrV2Available();
  3120.         $azureResources = [];
  3121.         $azureDiResources = [];
  3122.         $azureOpenAiResources = [];
  3123.         try {
  3124.             $azureResources = $this->loadAzureResources($em);
  3125.             foreach ($azureResources as $resourceRow) {
  3126.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3127.                     $azureOpenAiResources[] = $resourceRow;
  3128.                 } else {
  3129.                     $azureDiResources[] = $resourceRow;
  3130.                 }
  3131.             }
  3132.         } catch (\Throwable $e) {
  3133.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  3134.         }
  3136.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  3137.             // Estado previo de modulos (para detectar activacion de Mail Monitor)
  3138.             [$activeUsersPrev, $modulosPrev] = $this->loadEmpresaParametros($mysqli);
  3139.             $prevMailMonitor = (int)($modulosPrev['modulo_mailMonitor'] ?? 0);
  3141.             $data = $request->request->all();
  3142.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, $empresa->getMaxThreads() ?: 4);
  3143.             $data['ocr_mode'] = $this->normalizeOcrMode($data['ocr_mode'] ?? 'base');
  3144.             if (!$ocrV2Available && $data['ocr_mode'] === 'v2_zxing') {
  3145.                 $data['ocr_mode'] = 'base';
  3146.             }
  3147.             if (!$ocrPlusAvailable && $data['ocr_mode'] === 'plus_glm') {
  3148.                 $data['ocr_mode'] = 'base';
  3149.             }
  3152.             // 2) Actualizar SOLO central
  3153.             $empresa->setName((string)($data['name'] ?? $empresa->getName()));
  3154.             $empresa->setMaxDiskQuota(
  3155.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== ''
  3156.                     ? (int)$data['maxDiskQuota']
  3157.                     : $empresa->getMaxDiskQuota()
  3158.             );
  3159.             $empresa->setMaxThreads($maxThreads);
  3160.             $em->persist($empresa);
  3162.             // ---- Normalización de POST (checkboxes / select) ----
  3163.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  3165.             $extractionModel = 0;
  3166.             if (isset($data['extraction_model']) && $data['extraction_model'] !== '') {
  3167.                 $extractionModel = (int)$data['extraction_model'];
  3168.             }
  3169.             $data['extraction_model'] = $extractionModel;
  3170.             $data['extractor_type'] = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  3171.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  3172.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  3173.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  3174.             $aoaiFields = $this->collectAoaiFieldsFromRequest($request);
  3176.             $data['modulo_extraccion']       = isset($data['modulo_extraccion'])       && $toBool($data['modulo_extraccion'])       ? 1 : 0;
  3177.             $data['modulo_etiquetas']        = isset($data['modulo_etiquetas'])        && $toBool($data['modulo_etiquetas'])        ? 1 : 0;
  3178.             $data['modulo_calendario']       = isset($data['modulo_calendario'])       && $toBool($data['modulo_calendario'])       ? 1 : 0;
  3179.             $data['modulo_calendarioExterno'] = isset($data['modulo_calendarioExterno']) && $toBool($data['modulo_calendarioExterno']) ? 1 : 0;
  3180.             $data['modulo_estados']          = isset($data['modulo_estados'])          && $toBool($data['modulo_estados'])          ? 1 : 0;
  3181.             $data['modulo_lineas']           = isset($data['modulo_lineas'])           && $toBool($data['modulo_lineas'])           ? 1 : 0;
  3182.             $data['modulo_agora']            = isset($data['modulo_agora'])           && $toBool($data['modulo_agora'])             ? 1 : 0;
  3183.             $data['modulo_gstock']           = isset($data['modulo_gstock'])           && $toBool($data['modulo_gstock'])           ? 1 : 0;
  3184.             $data['modulo_expowin']          = isset($data['modulo_expowin'])          && $toBool($data['modulo_expowin'])          ? 1 : 0;
  3185.             $data['modulo_prinex']           = isset($data['modulo_prinex'])           && $toBool($data['modulo_prinex'])           ? 1 : 0;
  3186.             $data['modulo_mailMonitor']      = isset($data['modulo_mailMonitor'])      && $toBool($data['modulo_mailMonitor'])      ? 1 : 0;
  3187.             $data['modulo_busquedaNatural']  = isset($data['modulo_busquedaNatural'])  && $toBool($data['modulo_busquedaNatural'])  ? 1 : 0;
  3188.             $data['soloExtraccion']          = isset($data['soloExtraccion'])          && $toBool($data['soloExtraccion'])          ? 1 : 0;
  3189.             $data['tipo_conteo']             = (isset($data['tipo_conteo']) && (int)$data['tipo_conteo'] === 0) ? 0 : 1;
  3190.             $data['limite_archivos']         = (isset($data['limite_archivos']) && $data['limite_archivos'] !== '') ? (int)$data['limite_archivos'] : 500;
  3191.             $data['limite_paginas']          = (isset($data['limite_paginas']) && $data['limite_paginas'] !== '') ? (int)$data['limite_paginas'] : 1000;
  3192.             if ($data['tipo_conteo'] === 0) {
  3193.                 $data['limite_archivos'] = max(1, (int)$data['limite_archivos']);
  3194.                 $data['limite_paginas'] = 0;
  3195.             } else {
  3196.                 $data['limite_paginas'] = max(1, (int)$data['limite_paginas']);
  3197.                 $data['limite_archivos'] = 0;
  3198.             }
  3200.             // Dependencias
  3201.             if (!$data['modulo_calendario']) {
  3202.                 $data['modulo_calendarioExterno'] = 0;
  3203.             }
  3204.             if (!$data['modulo_extraccion']) {
  3205.                 $data['modulo_lineas']   = 0;
  3206.                 $data['extraction_model'] = 0;
  3207.                 $data['modulo_agora']    = 0;
  3208.                 $data['modulo_gstock']   = 0;
  3209.                 $data['modulo_expowin']  = 0;
  3210.                 $data['modulo_prinex']   = 0;
  3211.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  3212.                 $azureResourceId = 0;
  3213.                 $azureModelId = '';
  3214.                 $aoaiResourceId = 0;
  3215.             }
  3217.             // 3) Guardar en BD del cliente: parametros + license
  3218.             if ($data['modulo_extraccion'] === 1) {
  3219.                 if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3220.                     if ($aoaiResourceId <= 0) {
  3221.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  3222.                         $mysqli->close();
  3223.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3224.                     }
  3226.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  3227.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3228.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  3229.                         $mysqli->close();
  3230.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3231.                     }
  3233.                     $validationError = $this->validateAoaiFields($aoaiFields);
  3234.                     if ($validationError !== null) {
  3235.                         $this->addFlash('danger', $validationError);
  3236.                         $mysqli->close();
  3237.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3238.                     }
  3240.                     try {
  3241.                         $data['extraction_model'] = $this->registerAoaiModelInClientDb(
  3242.                             $mysqli,
  3243.                             $azureResource,
  3244.                             $aoaiFields
  3245.                         );
  3246.                         $this->addFlash('success', 'Modelo Azure OpenAI importado/actualizado correctamente.');
  3247.                     } catch (\Throwable $e) {
  3248.                         $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  3249.                         $mysqli->close();
  3250.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3251.                     }
  3252.                 } else {
  3253.                     if (($azureResourceId > 0 && $azureModelId === '') || ($azureResourceId <= 0 && $azureModelId !== '')) {
  3254.                         $this->addFlash('danger', 'Para importar desde recurso IA debes indicar recurso y modelo.');
  3255.                         $mysqli->close();
  3256.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3257.                     }
  3259.                     if ($azureResourceId > 0 && $azureModelId !== '') {
  3260.                         $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  3261.                         if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  3262.                             $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  3263.                             $mysqli->close();
  3264.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3265.                         }
  3267.                         try {
  3268.                             $data['extraction_model'] = $this->registerDiModelInClientDb(
  3269.                                 $mysqli,
  3270.                                 $azureResource,
  3271.                                 $azureModelId
  3272.                             );
  3273.                             $this->addFlash('success', 'Modelo IA importado/actualizado correctamente.');
  3274.                         } catch (\Throwable $e) {
  3275.                             $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  3276.                             $mysqli->close();
  3277.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3278.                         }
  3279.                     }
  3281.                     if ((int)$data['extraction_model'] <= 0) {
  3282.                         $this->addFlash('danger', 'Con extraccion activa debes seleccionar un modelo local o importar uno desde recurso IA.');
  3283.                         $mysqli->close();
  3284.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3285.                     }
  3286.                 }
  3287.             }
  3289.             $this->updateEmpresaParametros($mysqli, $data);
  3290.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  3291.                 try {
  3292.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  3293.                 } catch (\Throwable $e) {
  3294.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  3295.                 }
  3296.             }
  3297.             $this->updateLicense(
  3298.                 $mysqli,
  3299.                 $data,
  3300.                 $empresa->getName()
  3301.             );
  3303.             // Actualizar servicio OCR (hilos + binario segun modo OCR)
  3304.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  3305.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  3306.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  3307.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  3308.             if ($ocrMode === 'plus_glm') {
  3309.                 $ocrBinary = $ocrBinaryPlus;
  3310.             } elseif ($ocrMode === 'v2_zxing') {
  3311.                 $ocrBinary = $ocrBinaryV2;
  3312.             } else {
  3313.                 $ocrBinary = $ocrBinaryBase;
  3314.             }
  3315.             $filesPath = (string)($_ENV['FILES_PATH'] ?? '');
  3317.             if ($ocrBinary !== '' && $filesPath !== '') {
  3318.                 $companyId = (int)$empresa->getId();
  3319.                 $dbHost = (string)$cx->getDbUrl();
  3320.                 $dbName = (string)$cx->getDbName();
  3321.                 $dbUser = (string)$cx->getDbUser();
  3322.                 $dbPass = (string)$cx->getDbPassword();
  3324.                 $empresaName = (string)$empresa->getName();
  3325.                 $serviceContent = <<<EOT
  3326. [Unit]
  3327. Description={$empresaName} DocuManager OCR
  3328. Requires=mariadb.service
  3329. After=mariadb.service
  3331. [Service]
  3332. Type=simple
  3333. Environment="DOCU_MAX_THREADS=$maxThreads"
  3334. ExecStart=$ocrBinary {$dbHost}/{$dbName} {$dbUser} {$dbPass} {$filesPath}/{$companyId} NO
  3335. Restart=always
  3336. User=root
  3338. [Install]
  3339. WantedBy=multi-user.target
  3340. EOT;
  3342.                 $serviceName = $companyId . "-documanager.service";
  3343.                 $tmpServicePath = "/tmp/$serviceName";
  3344.                 file_put_contents($tmpServicePath, $serviceContent);
  3345.                 \chmod($tmpServicePath, 0644);
  3347.                 $cmds = [
  3348.                     "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  3349.                     "sudo /bin/systemctl daemon-reload",
  3350.                     "sudo /bin/systemctl restart $serviceName",
  3351.                 ];
  3352.                 $serviceErrors = [];
  3353.                 foreach ($cmds as $cmd) {
  3354.                     $output = \shell_exec($cmd . " 2>&1");
  3355.                     if ($output !== null && trim($output) !== '') {
  3356.                         error_log("CMD OUTPUT: $cmd\n$output");
  3357.                         $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  3358.                     }
  3359.                 }
  3360.                 if (count($serviceErrors) > 0) {
  3361.                     $this->addFlash('warning', 'Servicio OCR actualizado con avisos: ' . implode(' | ', $serviceErrors));
  3362.                 }
  3363.             } else {
  3364.                 if (($data['ocr_mode'] ?? 'base') === 'plus_glm') {
  3365.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_PLUS_BINARY o FILES_PATH.');
  3366.                 } elseif (($data['ocr_mode'] ?? 'base') === 'v2_zxing') {
  3367.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY_V2 o FILES_PATH.');
  3368.                 } else {
  3369.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY o FILES_PATH.');
  3370.                 }
  3371.             }
  3372.             // Si se activa Mail Monitor y antes estaba desactivado, crear servicio/timer
  3373.             if ($prevMailMonitor === 0 && (int)$data['modulo_mailMonitor'] === 1 && $filesPath !== '') {
  3374.                 $this->ensureMailMonitorService(
  3375.                     (int)$empresa->getId(),
  3376.                     (string)$cx->getDbUrl(),
  3377.                     (string)$cx->getDbPort(),
  3378.                     (string)$cx->getDbUser(),
  3379.                     (string)$cx->getDbPassword(),
  3380.                     (string)$cx->getDbName(),
  3381.                     (string)$filesPath
  3382.                 );
  3383.             }
  3384.             // Si se desactiva Mail Monitor, parar y eliminar service/timer
  3385.             if ($prevMailMonitor === 1 && (int)$data['modulo_mailMonitor'] === 0) {
  3386.                 $this->disableMailMonitorService((int)$empresa->getId());
  3387.             }
  3389.             $em->flush();
  3390.             $mysqli->close();
  3392.             // Mensaje de éxito
  3393.             $this->addFlash('success', 'Empresa editada correctamente.');
  3395.             return $this->redirectToRoute('app_empresa_show', ['id' => $id]);
  3396.         }
  3398.         // 4) GET: precargar desde BD del cliente
  3399.         [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  3400.         $license = $this->loadLicense($mysqli); // por si quieres mostrarlo
  3402.         $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  3403.         $selectedAoaiResourceId = 0;
  3404.         $aoaiFields = [];
  3405.         if (!empty($modulos['extraction_model'])) {
  3406.             try {
  3407.                 $stmtCurrentModel = $mysqli->prepare('SELECT provider FROM extraction_models WHERE id = ? LIMIT 1');
  3408.                 if ($stmtCurrentModel) {
  3409.                     $currentModelId = (int)$modulos['extraction_model'];
  3410.                     $stmtCurrentModel->bind_param('i', $currentModelId);
  3411.                     if ($stmtCurrentModel->execute()) {
  3412.                         $resCurrentModel = $stmtCurrentModel->get_result();
  3413.                         if ($resCurrentModel && ($modelRow = $resCurrentModel->fetch_assoc())) {
  3414.                             $provider = strtolower(trim((string)($modelRow['provider'] ?? '')));
  3415.                             if ($provider === 'azure_openai') {
  3416.                                 $extractorType = self::EXTRACTOR_TYPE_AZURE_OPENAI;
  3417.                             }
  3418.                         }
  3419.                     }
  3420.                     $stmtCurrentModel->close();
  3421.                 }
  3422.             } catch (\Throwable $e) {
  3423.                 $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  3424.             }
  3425.         }
  3427.         if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI && !empty($modulos['extraction_model'])) {
  3428.             try {
  3429.                 $modelId = (int)$modulos['extraction_model'];
  3430.                 $currentModelId = '';
  3431.                 $currentEndpoint = '';
  3432.                 $stmtModelMeta = $mysqli->prepare(
  3433.                     "SELECT model_id, endpoint FROM extraction_models WHERE id = ? AND provider = 'azure_openai' LIMIT 1"
  3434.                 );
  3435.                 if ($stmtModelMeta) {
  3436.                     $stmtModelMeta->bind_param('i', $modelId);
  3437.                     if ($stmtModelMeta->execute()) {
  3438.                         $resMeta = $stmtModelMeta->get_result();
  3439.                         if ($resMeta && ($metaRow = $resMeta->fetch_assoc())) {
  3440.                             $currentModelId = trim((string)($metaRow['model_id'] ?? ''));
  3441.                             $currentEndpoint = $this->normalizeAzureEndpoint((string)($metaRow['endpoint'] ?? ''));
  3442.                         }
  3443.                     }
  3444.                     $stmtModelMeta->close();
  3445.                 }
  3446.                 if ($currentModelId !== '' && $currentEndpoint !== '') {
  3447.                     foreach ($azureOpenAiResources as $resourceRow) {
  3448.                         $resourceModelId = trim((string)($resourceRow['model_id'] ?? ''));
  3449.                         $resourceEndpoint = $this->normalizeAzureEndpoint((string)($resourceRow['endpoint'] ?? ''));
  3450.                         if ($resourceModelId === $currentModelId && $resourceEndpoint === $currentEndpoint) {
  3451.                             $selectedAoaiResourceId = (int)($resourceRow['id'] ?? 0);
  3452.                             break;
  3453.                         }
  3454.                     }
  3455.                 }
  3457.                 $stmtHeader = $mysqli->prepare(
  3458.                     'SELECT field_key, prompt, value_type FROM definitions_header WHERE model_id = ? ORDER BY order_index ASC, id ASC'
  3459.                 );
  3460.                 if ($stmtHeader) {
  3461.                     $stmtHeader->bind_param('i', $modelId);
  3462.                     if ($stmtHeader->execute()) {
  3463.                         $resHeader = $stmtHeader->get_result();
  3464.                         while ($resHeader && ($row = $resHeader->fetch_assoc())) {
  3465.                             $aoaiFields[] = [
  3466.                                 'scope' => 'header',
  3467.                                 'field_key' => (string)($row['field_key'] ?? ''),
  3468.                                 'prompt' => (string)($row['prompt'] ?? ''),
  3469.                                 'value_type' => $this->normalizeAoaiValueType((string)($row['value_type'] ?? 'string')),
  3470.                             ];
  3471.                         }
  3472.                     }
  3473.                     $stmtHeader->close();
  3474.                 }
  3476.                 $stmtLines = $mysqli->prepare(
  3477.                     'SELECT field_key, prompt, value_type FROM definitions_lines WHERE model_id = ? ORDER BY order_index ASC, id ASC'
  3478.                 );
  3479.                 if ($stmtLines) {
  3480.                     $stmtLines->bind_param('i', $modelId);
  3481.                     if ($stmtLines->execute()) {
  3482.                         $resLines = $stmtLines->get_result();
  3483.                         while ($resLines && ($row = $resLines->fetch_assoc())) {
  3484.                             $aoaiFields[] = [
  3485.                                 'scope' => 'lines',
  3486.                                 'field_key' => (string)($row['field_key'] ?? ''),
  3487.                                 'prompt' => (string)($row['prompt'] ?? ''),
  3488.                                 'value_type' => $this->normalizeAoaiValueType((string)($row['value_type'] ?? 'string')),
  3489.                             ];
  3490.                         }
  3491.                     }
  3492.                     $stmtLines->close();
  3493.                 }
  3494.             } catch (\Throwable $e) {
  3495.                 $aoaiFields = [];
  3496.             }
  3497.         }
  3499.         $extractionModels = [];
  3500.         try {
  3501.             $res = $mysqli->query("SELECT id, model_id, provider FROM extraction_models WHERE provider = 'azure-di' ORDER BY model_id");
  3502.             if ($res) {
  3503.                 while ($row = $res->fetch_assoc()) {
  3504.                     $extractionModels[] = [
  3505.                         'id' => (int)$row['id'],
  3506.                         'model_id' => (string)$row['model_id'],
  3507.                         'provider' => (string)($row['provider'] ?? ''),
  3508.                     ];
  3509.                 }
  3510.                 $res->free();
  3511.             }
  3512.         } catch (\Throwable $e) {
  3513.             $extractionModels = [];
  3514.         }
  3516.         $mysqli->close();
  3518.         return $this->render('empresa/_edit.html.twig', [
  3519.             'empresa'      => $empresa,   // central: name + maxDiskQuota
  3520.             'id'           => $id,
  3521.             'activeUsers'  => $activeUsers, // cliente
  3522.             'modulos'      => $modulos,     // cliente
  3523.             'license'      => $license,     // opcional
  3524.             'azure_resources' => $azureResources,
  3525.             'azure_di_resources' => $azureDiResources,
  3526.             'azure_openai_resources' => $azureOpenAiResources,
  3527.             'extraction_models' => $extractionModels,
  3528.             'form_data' => [
  3529.                 'extractor_type' => $extractorType,
  3530.                 'aoai_resource_id' => $selectedAoaiResourceId,
  3531.                 'ocr_mode' => $this->normalizeOcrMode($modulos['ocr_mode'] ?? 'base'),
  3532.             ],
  3533.             'aoai_fields' => $aoaiFields,
  3534.             'ocr_plus_available' => $ocrPlusAvailable,
  3535.             'ocr_v2_available' => $ocrV2Available,
  3536.         ]);
  3537.     }
  3539.     private function loadEmpresaParametros(\mysqli $mysqli): array
  3540.     {
  3541.         // claves que nos interesan en la tabla parametros
  3542.         $keys = [
  3543.             'activeUsers',
  3544.             'soloExtraccion',
  3545.             'modulo_etiquetas',
  3546.             'modulo_calendario',
  3547.             'modulo_calExt',
  3548.             'modulo_estados',
  3549.             'modulo_subida',
  3550.             'modulo_mailMonitor',
  3551.             'modulo_busquedaNatural',
  3552.             'modulo_extraccion',
  3553.             'modulo_lineas',
  3554.             'modulo_agora',
  3555.             'modulo_gstock',
  3556.             'modulo_expowin',
  3557.             'modulo_prinex',
  3558.             'tipo_conteo',
  3559.             'archivos_subidos',
  3560.             'limite_archivos',
  3561.             'paginas_subidas',
  3562.             'limite_paginas',
  3563.             'extraction_model',
  3564.             'ocr_mode',
  3565.             'tokensContratados',
  3566.             'tokensUsados',
  3567.         ];
  3568.         $placeholders = implode(',', array_fill(0, count($keys), '?'));
  3570.         $sql = "SELECT nombre, valor FROM parametros WHERE nombre IN ($placeholders)";
  3571.         $stmt = $mysqli->prepare($sql);
  3572.         if (!$stmt) {
  3573.             throw new \RuntimeException('Prepare SELECT parametros: ' . $mysqli->error);
  3574.         }
  3576.         // bind dinámico
  3577.         $types = str_repeat('s', count($keys));
  3578.         $stmt->bind_param($types, ...$keys);
  3579.         if (!$stmt->execute()) {
  3580.             $stmt->close();
  3581.             throw new \RuntimeException('Execute SELECT parametros: ' . $stmt->error);
  3582.         }
  3584.         $res = $stmt->get_result();
  3585.         $map = [];
  3586.         while ($row = $res->fetch_assoc()) {
  3587.             $map[$row['nombre']] = $row['valor'];
  3588.         }
  3589.         $stmt->close();
  3591.         // defaults seguros
  3592.         $activeUsers = isset($map['activeUsers']) ? (int)$map['activeUsers'] : 3;
  3594.         $flags = [
  3595.             'soloExtraccion'   => isset($map['soloExtraccion'])   ? (int)$map['soloExtraccion']   : 0,
  3596.             'modulo_etiquetas'  => isset($map['modulo_etiquetas'])  ? (int)$map['modulo_etiquetas']  : 0,
  3597.             'modulo_calendario' => isset($map['modulo_calendario']) ? (int)$map['modulo_calendario'] : 0,
  3598.             'modulo_calExt'     => isset($map['modulo_calExt'])     ? (int)$map['modulo_calExt']     : 0,
  3599.             'modulo_estados'    => isset($map['modulo_estados'])    ? (int)$map['modulo_estados']    : 0,
  3600.             'modulo_subida'     => isset($map['modulo_subida'])     ? (int)$map['modulo_subida']     : 0,
  3601.             'modulo_extraccion' => isset($map['modulo_extraccion']) ? (int)$map['modulo_extraccion'] : 0,
  3602.             'modulo_lineas'     => isset($map['modulo_lineas'])     ? (int)$map['modulo_lineas']     : 0,
  3603.             'modulo_agora'      => isset($map['modulo_agora'])      ? (int)$map['modulo_agora']      : 0,
  3604.             'modulo_gstock'     => isset($map['modulo_gstock'])     ? (int)$map['modulo_gstock']     : 0,
  3605.             'modulo_expowin'    => isset($map['modulo_expowin'])    ? (int)$map['modulo_expowin']    : 0,
  3606.             'modulo_prinex'     => isset($map['modulo_prinex'])     ? (int)$map['modulo_prinex']     : 0,
  3607.             'modulo_mailMonitor' => isset($map['modulo_mailMonitor']) ? (int)$map['modulo_mailMonitor'] : 0,
  3608.             'modulo_busquedaNatural' => isset($map['modulo_busquedaNatural']) ? (int)$map['modulo_busquedaNatural'] : 0,
  3609.         ];
  3611.         $limiteArchivos = isset($map['limite_archivos']) && $map['limite_archivos'] !== ''
  3612.             ? (int)$map['limite_archivos']
  3613.             : 500;
  3615.         // Lo ańadimos a $flags para no cambiar la firma del return
  3616.         $flags['limite_archivos'] = $limiteArchivos;
  3617.         $flags['tipo_conteo'] = isset($map['tipo_conteo']) ? (((int)$map['tipo_conteo'] === 0) ? 0 : 1) : 1;
  3618.         $flags['archivos_subidos'] = isset($map['archivos_subidos']) && $map['archivos_subidos'] !== ''
  3619.             ? (int)$map['archivos_subidos']
  3620.             : 0;
  3621.         $flags['paginas_subidas'] = isset($map['paginas_subidas']) && $map['paginas_subidas'] !== ''
  3622.             ? (int)$map['paginas_subidas']
  3623.             : 0;
  3624.         $flags['limite_paginas'] = isset($map['limite_paginas']) && $map['limite_paginas'] !== ''
  3625.             ? (int)$map['limite_paginas']
  3626.             : 1000;
  3628.         // extraction_model: default 0 (sin modelo)
  3629.         $flags['extraction_model'] = isset($map['extraction_model']) && $map['extraction_model'] !== '' ? (int)$map['extraction_model'] : 0;
  3630.         $flags['ocr_mode'] = $this->normalizeOcrMode($map['ocr_mode'] ?? 'base');
  3631.         $flags['tokensContratados'] = isset($map['tokensContratados']) && $map['tokensContratados'] !== ''
  3632.             ? max(0, (int)$map['tokensContratados'])
  3633.             : 0;
  3634.         $flags['tokensUsados'] = isset($map['tokensUsados']) && $map['tokensUsados'] !== ''
  3635.             ? max(0, (int)$map['tokensUsados'])
  3636.             : 0;
  3638.         return [$activeUsers, $flags];
  3639.     }
  3641.     private function updateEmpresaParametros(\mysqli $mysqli, array $data): void
  3642.     {
  3643.         $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  3644.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  3645.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  3646.         $counterDefaults = [
  3647.             'archivos_subidos' => 0,
  3648.             'paginas_subidas' => 0,
  3649.         ];
  3650.         $counterRes = $mysqli->query("SELECT nombre, valor FROM parametros WHERE nombre IN ('archivos_subidos','paginas_subidas')");
  3651.         if ($counterRes) {
  3652.             while ($row = $counterRes->fetch_assoc()) {
  3653.                 $nombre = (string)($row['nombre'] ?? '');
  3654.                 if (array_key_exists($nombre, $counterDefaults)) {
  3655.                     $counterDefaults[$nombre] = (int)($row['valor'] ?? 0);
  3656.                 }
  3657.             }
  3658.             $counterRes->free();
  3659.         }
  3661.         $paramMap = [
  3662.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  3663.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  3664.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  3665.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  3666.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  3667.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  3668.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  3669.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  3670.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  3671.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  3672.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  3673.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  3674.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  3675.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  3676.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  3677.             'tipo_conteo'        => $getInt($data, 'tipo_conteo', 1) === 1 ? 1 : 0,
  3678.             'archivos_subidos'   => $getInt($data, 'archivos_subidos', $counterDefaults['archivos_subidos']),
  3679.             'limite_archivos'    => $getInt($data, 'limite_archivos', 500),
  3680.             'paginas_subidas'    => $getInt($data, 'paginas_subidas', $counterDefaults['paginas_subidas']),
  3681.             'limite_paginas'     => $getInt($data, 'limite_paginas', 1000),
  3682.             'extraction_model'   => $getInt($data, 'extraction_model', 0),
  3683.             'ocr_mode'           => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  3684.             'tokensContratados'  => max(0, $getInt($data, 'tokensContratados', 0)),
  3685.         ];
  3687.         if ($paramMap['modulo_extraccion'] === 0) {
  3688.             $paramMap['modulo_lineas'] = 0;
  3689.             $paramMap['extraction_model'] = 0;
  3690.             $paramMap['modulo_agora'] = 0;
  3691.             $paramMap['modulo_gstock'] = 0;
  3692.             $paramMap['modulo_expowin'] = 0;
  3693.             $paramMap['modulo_prinex'] = 0;
  3694.         }
  3695.         if ($paramMap['modulo_calendario'] === 0) {
  3696.             $paramMap['modulo_calExt'] = 0;
  3697.         }
  3699.         $mysqli->begin_transaction();
  3700.         try {
  3701.             $stmt = $mysqli->prepare("
  3702.                 INSERT INTO parametros (nombre, valor)
  3703.                 VALUES (?, ?)
  3704.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  3705.             ");
  3706.             if (!$stmt) {
  3707.                 throw new \RuntimeException('Prepare UPSERT parametros: ' . $mysqli->error);
  3708.             }
  3710.             foreach ($paramMap as $nombre => $valor) {
  3711.                 $v = (string)$valor;
  3712.                 if (!$stmt->bind_param('ss', $nombre, $v) || !$stmt->execute()) {
  3713.                     $stmt->close();
  3714.                     throw new \RuntimeException("Guardar parámetro {$nombre}: {$stmt->error}");
  3715.                 }
  3716.             }
  3718.             $stmt->close();
  3719.             $mysqli->commit();
  3720.         } catch (\Throwable $e) {
  3721.             $mysqli->rollback();
  3722.             throw $e;
  3723.         }
  3724.     }
  3726.     private function loadLicense(\mysqli $mysqli): array
  3727.     {
  3728.         // Carga opcional para mostrar en la edición: capacityGb/users (u otros)
  3729.         $sql = "SELECT client, capacityGb, users FROM license LIMIT 1";
  3730.         $res = $mysqli->query($sql);
  3731.         if ($res && $row = $res->fetch_assoc()) {
  3732.             return $row;
  3733.         }
  3734.         return [];
  3735.     }
  3737.     private function updateLicense(\mysqli $mysqli, array $data, string $clientName): void
  3738.     {
  3739.         $capacityGb  = isset($data['maxDiskQuota']) ? (int)$data['maxDiskQuota'] : 200;
  3740.         $activeUsers = isset($data['maxActiveUsers']) ? (int)$data['maxActiveUsers'] : 3;
  3742.         $stmt = $mysqli->prepare("UPDATE license SET capacityGb = ?, users = ? WHERE client = ?");
  3743.         if (!$stmt) {
  3744.             throw new \RuntimeException('Prepare UPDATE license: ' . $mysqli->error);
  3745.         }
  3747.         $stmt->bind_param('iis', $capacityGb, $activeUsers, $clientName);
  3748.         $stmt->execute();
  3749.         $stmt->close();
  3750.     }
  3752.     public function usersListEmpresa(Request $request, EntityManagerInterface $em)
  3753.     {
  3754.         $id = $request->get("id");
  3755.         $users_empresa = $em->getRepository(Usuario::class)->findBy(array("empresa" => $id));
  3757.         return $this->render('empresa/usersList.html.twig', array(
  3758.             'users' => $users_empresa,
  3759.             'id' => $id
  3760.         ));
  3761.     }
  3763.     private function loadEmpresaDiskUsageBytes(\mysqli $mysqli): ?int
  3764.     {
  3765.         // Si la tabla no existe o hay error, devolvemos null para no romper la vista
  3766.         $sql = "SELECT COALESCE(SUM(size_bytes), 0) AS total_bytes FROM files";
  3767.         $res = $mysqli->query($sql);
  3769.         if (!$res) {
  3770.             return null;
  3771.         }
  3773.         $row = $res->fetch_assoc();
  3774.         $res->free();
  3776.         return isset($row['total_bytes']) ? (int)$row['total_bytes'] : 0;
  3777.     }
  3779.     // =======================================================================
  3780.     // VER DOCUMENTACION DE EMPRESAS
  3781.     // =======================================================================
  3783.     #[Route('/empresa/{id}/documentos', name: 'empresa_documentos', methods: ['GET'])]
  3784.     public function documentosEmpresa(Request $request, EntityManagerInterface $em)
  3785.     {
  3786.         if (!$this->getUser() || !is_object($this->getUser())) {
  3787.             return $this->redirectToRoute('logout');
  3788.         }
  3790.         $id = (int) $request->get('id');
  3791.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3793.         if (!$empresa) {
  3794.             $this->addFlash('warning', 'Empresa no encontrada.');
  3795.             return $this->redirectToRoute('list');
  3796.         }
  3798.         // Para el desplegable
  3799.         $empresas = $em->getRepository(Empresa::class)->findAll();
  3800.         $baseUrl = $this->getParameter('documanager_base_url');
  3802.         return $this->render('empresa/documentos.html.twig', [
  3803.             'empresaId' => $id,
  3804.             'empresas'  => $empresas,
  3805.             'documanagerBaseUrl' => $baseUrl,
  3806.         ]);
  3807.     }
  3809.     #[Route('/api/empresa/{id}/documentos', name: 'empresa_documentos_api', methods: ['GET'])]
  3810.     public function documentosEmpresaApi(Request $request, EntityManagerInterface $em): JsonResponse
  3811.     {
  3812.         if (!$this->getUser() || !is_object($this->getUser())) {
  3813.             return new JsonResponse(['error' => 'unauthorized'], 401);
  3814.         }
  3816.         $id = (int) $request->get('id');
  3817.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3819.         if (!$empresa) {
  3820.             return new JsonResponse(['error' => 'Empresa no encontrada'], 404);
  3821.         }
  3823.         $cx = $empresa->getConexionBD();
  3824.         if (!$cx) {
  3825.             return new JsonResponse(['error' => 'La empresa no tiene conexión configurada'], 400);
  3826.         }
  3828.         $page    = max(1, (int) $request->query->get('page', 1));
  3829.         $perPage = (int) $request->query->get('per_page', 50);
  3830.         $perPage = min(max($perPage, 10), 200);
  3831.         $q       = (string) $request->query->get('q', '');
  3832.         $offset  = ($page - 1) * $perPage;
  3834.         $mysqli = @new \mysqli(
  3835.             $cx->getDbUrl(),
  3836.             $cx->getDbUser(),
  3837.             $cx->getDbPassword(),
  3838.             $cx->getDbName(),
  3839.             (int) $cx->getDbPort()
  3840.         );
  3842.         if ($mysqli->connect_error) {
  3843.             return new JsonResponse(['error' => 'Error conectando a la BD del cliente: ' . $mysqli->connect_error], 500);
  3844.         }
  3846.         $mysqli->set_charset('utf8mb4');
  3848.         // --- TOTAL ---
  3849.         if ($q === '') {
  3850.             $sqlTotal = "SELECT COUNT(*) AS c FROM files";
  3851.             $res = $mysqli->query($sqlTotal);
  3852.             $row = $res ? $res->fetch_assoc() : null;
  3853.             $total = (int)($row['c'] ?? 0);
  3854.         } else {
  3855.             $sqlTotal = "SELECT COUNT(*) AS c
  3856.                          FROM files
  3857.                          WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?";
  3858.             $qLike = '%' . $q . '%';
  3859.             $st = $mysqli->prepare($sqlTotal);
  3860.             $st->bind_param('ssss', $qLike, $qLike, $qLike, $qLike);
  3861.             $st->execute();
  3862.             $res = $st->get_result();
  3863.             $row = $res ? $res->fetch_assoc() : null;
  3864.             $total = (int)($row['c'] ?? 0);
  3865.             $st->close();
  3866.         }
  3868.         // --- ITEMS ---
  3869.         $items = [];
  3871.         if ($q === '') {
  3872.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  3873.                     FROM files
  3874.                     ORDER BY `date` DESC
  3875.                     LIMIT ? OFFSET ?";
  3876.             $st = $mysqli->prepare($sql);
  3877.             $st->bind_param('ii', $perPage, $offset);
  3878.         } else {
  3879.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  3880.                     FROM files
  3881.                     WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?
  3882.                     ORDER BY `date` DESC
  3883.                     LIMIT ? OFFSET ?";
  3884.             $qLike = '%' . $q . '%';
  3885.             $st = $mysqli->prepare($sql);
  3886.             $st->bind_param('ssssii', $qLike, $qLike, $qLike, $qLike, $perPage, $offset);
  3887.         }
  3889.         $st->execute();
  3890.         $res = $st->get_result();
  3891.         if ($res) {
  3892.             while ($r = $res->fetch_assoc()) {
  3893.                 $items[] = $r;
  3894.             }
  3895.         }
  3896.         $st->close();
  3897.         $mysqli->close();
  3899.         return new JsonResponse([
  3900.             'company_id' => $id,
  3901.             'page'       => $page,
  3902.             'per_page'   => $perPage,
  3903.             'total'      => $total,
  3904.             'items'      => $items,
  3905.         ]);
  3906.     }
  3907. }