src/Controller/AdminController.php line 517

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\HttpFoundation\StreamedResponse;
  16. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use App\Entity\Empresa;
  20. use App\Entity\Usuario;
  21. use App\Entity\ConexionBD;
  22. use App\Service\LicenseContractService;
  23. use App\Service\SuperuserProvisioningService;
  24. use Symfony\Component\Security\Http\Authentication\AuthenticationUtils;
  25. use Symfony\Component\HttpFoundation\File\UploadedFile;
  26. use Symfony\Component\Routing\Annotation\Route;
  28. /**
  29.  * Description of AdminController
  30.  *
  31.  * @author joseangelparra
  32.  */
  33. class AdminController extends AbstractController
  34. {
  35.     //put your code here
  36.     private const AZURE_DI_API_VERSION = '2024-11-30';
  37.     private const EXTRACTOR_TYPE_AZURE_DI = 'azure-di';
  38.     private const EXTRACTOR_TYPE_AZURE_OPENAI = 'azure-openai';
  39.     private const GLOBAL_IS_ADMIN_SUPERADMIN = 3;
  40.     private const GLOBAL_IS_ADMIN_SUPERUSER = 4;
  41.     private const GLOBAL_IS_ADMINS = [self::GLOBAL_IS_ADMIN_SUPERADMIN, self::GLOBAL_IS_ADMIN_SUPERUSER];
  42.     private const PROFILE_SUPERUSER = 0;
  43.     private const PROFILE_SUPERADMIN = 1;
  44.     private $params;
  45.     private LicenseContractService $licenseContractService;
  46.     public function __construct(ParameterBagInterface $params, LicenseContractService $licenseContractService)
  47.     {
  49.         $this->session = new Session();
  50.         $this->params = $params;
  51.         $this->licenseContractService = $licenseContractService;
  52.     }
  54.     #[Route('/', name: 'login')]
  55.     public function Login(AuthenticationUtils $authenticationUtils)
  56.     {
  57.         $error = $authenticationUtils->getLastAuthenticationError();
  59.         $lastUsername = $authenticationUtils->getLastUSername();
  62.         return $this->render('base.html.twig', array(
  63.             'error' => $error,
  64.             'last_username' => $lastUsername
  65.         ));
  66.     }
  68.     public function changePWD(UserPasswordHasherInterface $encoder, EntityManagerInterface $em)
  69.     {
  70.         $user = $em->getRepository(Usuario::class)->find(10);
  71.         $encoded = $encoder->hashPassword($user, 'docuManager2025');
  72.         $user->setPassword($encoded);
  73.         $em->persist($user);
  74.         $flush = $em->flush();
  75.         die();
  76.     }
  78.     public function checkUserExists(Request $request, EntityManagerInterface $em)
  79.     {
  80.         $email = trim((string)$request->request->get("user", ''));
  81.         $empresaId = (int)$request->request->get("empresa_id", 0);
  82.         $connectionId = (int)$request->request->get("connection", 0);
  84.         if ($email === '') {
  85.             return new JsonResponse(['exists' => false, 'message' => 'user_required'], 400);
  86.         }
  88.         $qb = $em->createQueryBuilder()
  89.             ->select('u.id')
  90.             ->from(Usuario::class, 'u')
  91.             ->where('LOWER(u.email) = :email')
  92.             ->setParameter('email', strtolower($email));
  94.         // Validar por ambito de empresa/conexion cuando se proporciona.
  95.         if ($empresaId > 0) {
  96.             $qb->andWhere('IDENTITY(u.empresa) = :empresaId')
  97.                 ->setParameter('empresaId', $empresaId);
  98.         } elseif ($connectionId > 0) {
  99.             $qb->andWhere('u.connection = :connectionId')
  100.                 ->setParameter('connectionId', $connectionId);
  101.         }
  103.         $existsScoped = !empty($qb->setMaxResults(1)->getQuery()->getArrayResult());
  105.         // Mantiene dato global para compatibilidad/diagnostico.
  106.         $existsGlobal = !empty($em->createQueryBuilder()
  107.             ->select('u2.id')
  108.             ->from(Usuario::class, 'u2')
  109.             ->where('LOWER(u2.email) = :email')
  110.             ->setParameter('email', strtolower($email))
  111.             ->setMaxResults(1)
  112.             ->getQuery()
  113.             ->getArrayResult());
  115.         return new JsonResponse([
  116.             'exists' => $existsScoped,
  117.             'exists_scoped' => $existsScoped,
  118.             'exists_global' => $existsGlobal,
  119.             'scope' => ($empresaId > 0 ? 'empresa' : ($connectionId > 0 ? 'connection' : 'global')),
  120.         ]);
  121.     }
  123.     private function azurePortForTenant(int $tenantId, int $base = 12000, int $max = 20999): int
  124.     {
  125.         $port = $base + $tenantId;
  126.         if ($port > $max) {
  127.             $range = max(1, $max - $base);
  128.             $port  = $base + ($tenantId % $range);
  129.         }
  130.         return $port;
  131.     }
  133.     private function azureDiWorkdirFromEnv(): string
  134.     {
  135.         return rtrim((string)($_ENV['AZURE_DI_WORKDIR'] ?? ''), '/');
  136.     }
  138.     private function azureDiPhpBaseUrl(Request $request): string
  139.     {
  140.         $host = strtolower(trim((string)$request->getHost()));
  141.         if ($host !== '' && preg_match('/^(console|newdev)\.(.+)$/', $host, $matches) === 1) {
  142.             $mappedSubdomain = $matches[1] === 'console' ? 'app' : 'platform';
  143.             return 'https://' . $mappedSubdomain . '.' . $matches[2] . '/newdocu/public';
  144.         }
  146.         return rtrim(trim((string)($_ENV['AZURE_DI_DOCU_PHP_BASE_URL'] ?? '')), '/');
  147.     }
  149.     private function clampDocuMaxThreads($value, int $default = 4): int
  150.     {
  151.         if ($value === null || $value === '') {
  152.             return $default;
  153.         }
  155.         $threads = (int)$value;
  156.         if ($threads < 1) {
  157.             return 1;
  158.         }
  159.         if ($threads > 16) {
  160.             return 16;
  161.         }
  162.         return $threads;
  163.     }
  165.     private function normalizeOcrMode($value): string
  166.     {
  167.         $mode = strtolower(trim((string)$value));
  168.         if ($mode === 'plus_glm') {
  169.             return 'plus_glm';
  170.         }
  171.         if ($mode === 'v2_zxing') {
  172.             return 'v2_zxing';
  173.         }
  174.         return 'base';
  175.     }
  177.     private function isOcrV2Available(): bool
  178.     {
  179.         $forced = $_ENV['OCR_V2_AVAILABLE'] ?? null;
  180.         if ($forced !== null && $forced !== '') {
  181.             return in_array(strtolower((string)$forced), ['1', 'true', 'yes', 'on'], true);
  182.         }
  184.         $ocrV2Dir = (string)($_ENV['OCR_V2_DIR'] ?? '/home/docunecta/ocr/documanager_ocr+zxing');
  185.         if ($ocrV2Dir === '') {
  186.             return false;
  187.         }
  188.         if ($this->isPathAllowedByOpenBaseDir($ocrV2Dir)) {
  189.             return @is_dir($ocrV2Dir);
  190.         }
  192.         $sudoResult = $this->checkDirExistsWithSudo($ocrV2Dir);
  193.         return $sudoResult ?? false;
  194.     }
  196.     private function isOcrPlusAvailable(): bool
  197.     {
  198.         $forced = $_ENV['OCR_PLUS_AVAILABLE'] ?? null;
  199.         if ($forced !== null && $forced !== '') {
  200.             return in_array(strtolower((string)$forced), ['1', 'true', 'yes', 'on'], true);
  201.         }
  203.         $ocrPlusDir = (string)($_ENV['OCR_PLUS_DIR'] ?? '/home/docunecta/ocr/TEST_documanager_ocr+glm+zxing');
  204.         if ($ocrPlusDir === '') {
  205.             return false;
  206.         }
  207.         if ($this->isPathAllowedByOpenBaseDir($ocrPlusDir)) {
  208.             return @is_dir($ocrPlusDir);
  209.         }
  211.         $sudoResult = $this->checkDirExistsWithSudo($ocrPlusDir);
  212.         return $sudoResult ?? false;
  213.     }
  215.     private function isPathAllowedByOpenBaseDir(string $path): bool
  216.     {
  217.         $openBaseDir = (string)ini_get('open_basedir');
  218.         if ($openBaseDir === '') {
  219.             return true;
  220.         }
  222.         $normalizedPath = rtrim(str_replace('\\', '/', $path), '/') . '/';
  223.         $allowedParts = array_filter(array_map('trim', explode(PATH_SEPARATOR, $openBaseDir)));
  225.         foreach ($allowedParts as $allowed) {
  226.             $normalizedAllowed = rtrim(str_replace('\\', '/', (string)$allowed), '/') . '/';
  227.             if (str_starts_with($normalizedPath, $normalizedAllowed)) {
  228.                 return true;
  229.             }
  230.         }
  231.         return false;
  232.     }
  234.     private function checkDirExistsWithSudo(string $path): ?bool
  235.     {
  236.         $cmd = 'sudo -n /usr/bin/test -d ' . escapeshellarg($path) . ' && echo 1 || echo 0';
  237.         $out = @shell_exec($cmd . ' 2>/dev/null');
  238.         if ($out === null) {
  239.             return null;
  240.         }
  242.         $out = trim($out);
  243.         if ($out === '1') {
  244.             return true;
  245.         }
  246.         if ($out === '0') {
  247.             return false;
  248.         }
  249.         return null;
  250.     }
  252.     private function ensureMailMonitorService(int $companyId, string $dbHost, string $dbPort, string $dbUser, string $dbPass, string $dbName, string $filesPath): void
  253.     {
  254.         $workdir = $_ENV['MAIL_IMPORTER_WORKDIR'] ?? '';
  255.         $script  = $_ENV['MAIL_IMPORTER_SCRIPT'] ?? '';
  256.         $envFile = $_ENV['MAIL_IMPORTER_COMMON_ENV'] ?? '';
  258.         $missing = [];
  259.         if ($workdir === '') $missing[] = 'MAIL_IMPORTER_WORKDIR';
  260.         if ($script === '') $missing[] = 'MAIL_IMPORTER_SCRIPT';
  261.         if ($envFile === '') $missing[] = 'MAIL_IMPORTER_COMMON_ENV';
  262.         if (trim($filesPath) === '') $missing[] = 'FILES_PATH';
  263.         if (!empty($missing)) {
  264.             $msg = 'Mail Monitor no creado: faltan variables de entorno: ' . implode(', ', $missing);
  265.             $this->addFlash('warning', $msg);
  266.             error_log($msg);
  267.             return;
  268.         }
  270.         $serviceName = $companyId . "-mailMonitor.service";
  271.         $timerName   = $companyId . "-mailMonitor.timer";
  272.         $filesRoot   = rtrim($filesPath, '/') . '/' . $companyId;
  274.         $serviceContent = <<<EOT
  275. [Unit]
  276. Description=DocuManager Mail Monitor (empresa {$companyId})
  277. Wants=network-online.target
  278. After=network-online.target
  280. [Service]
  281. Type=oneshot
  282. WorkingDirectory={$workdir}
  283. EnvironmentFile={$envFile}
  284. Environment=MAIL_IMPORTER_DB_HOST={$dbHost}
  285. Environment=MAIL_IMPORTER_DB_PORT={$dbPort}
  286. Environment=MAIL_IMPORTER_DB_USER={$dbUser}
  287. Environment=MAIL_IMPORTER_DB_PASS={$dbPass}
  288. Environment=MAIL_IMPORTER_DB_NAME={$dbName}
  289. Environment=MAIL_IMPORTER_FILES_ROOT={$filesRoot}
  290. ExecStart=/usr/bin/python3 {$script} --once --log-level INFO
  291. User=docunecta
  292. Group=docunecta
  294. [Install]
  295. WantedBy=multi-user.target
  296. EOT;
  298.         $timerContent = <<<EOT
  299. [Unit]
  300. Description=DocuManager Mail Monitor Timer (empresa {$companyId})
  302. [Timer]
  303. OnBootSec=2min
  304. OnUnitActiveSec=15min
  305. AccuracySec=1min
  306. Persistent=true
  308. [Install]
  309. WantedBy=timers.target
  310. EOT;
  312.         $tmpServicePath = "/tmp/{$serviceName}";
  313.         $tmpTimerPath   = "/tmp/{$timerName}";
  315.         file_put_contents($tmpServicePath, $serviceContent);
  316.         file_put_contents($tmpTimerPath, $timerContent);
  317.         @chmod($tmpServicePath, 0644);
  318.         @chmod($tmpTimerPath, 0644);
  320.         $cmds = [
  321.             "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  322.             "sudo /bin/mv {$tmpTimerPath} /etc/systemd/system/{$timerName}",
  323.             "sudo /bin/systemctl daemon-reload",
  324.             "sudo /bin/systemctl enable --now {$timerName}",
  325.         ];
  326.         foreach ($cmds as $cmd) {
  327.             $out = \shell_exec($cmd . " 2>&1");
  328.             if ($out !== null) {
  329.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  330.             }
  331.         }
  332.     }
  334.     private function disableMailMonitorService(int $companyId): void
  335.     {
  336.         $serviceName = $companyId . "-mailMonitor.service";
  337.         $timerName   = $companyId . "-mailMonitor.timer";
  339.         $cmds = [
  340.             "sudo /bin/systemctl disable --now {$timerName}",
  341.             "sudo /bin/systemctl stop {$serviceName}",
  342.             "sudo /bin/rm -f /etc/systemd/system/{$serviceName}",
  343.             "sudo /bin/rm -f /etc/systemd/system/{$timerName}",
  344.             "sudo /bin/systemctl daemon-reload",
  345.         ];
  346.         foreach ($cmds as $cmd) {
  347.             $out = \shell_exec($cmd . " 2>&1");
  348.             if ($out !== null) {
  349.                 error_log("MAIL-MONITOR CMD: $cmd\n$out");
  350.             }
  351.         }
  352.     }
  354.     private function removeCompanyFilesDir(int $companyId): void
  355.     {
  356.         $base = $_ENV['FILES_PATH'] ?? '';
  357.         if (trim($base) === '') {
  358.             $msg = 'No se ha podido borrar carpeta de files: falta FILES_PATH en entorno.';
  359.             $this->addFlash('warning', $msg);
  360.             error_log($msg);
  361.             return;
  362.         }
  364.         $base = rtrim($base, '/');
  365.         $target = $base . '/' . $companyId;
  367.         if (!is_dir($target)) {
  368.             return;
  369.         }
  371.         $errors = [];
  372.         $it = new \RecursiveIteratorIterator(
  373.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  374.             \RecursiveIteratorIterator::CHILD_FIRST
  375.         );
  377.         foreach ($it as $file) {
  378.             try {
  379.                 if ($file->isDir()) {
  380.                     @rmdir($file->getPathname());
  381.                 } else {
  382.                     @unlink($file->getPathname());
  383.                 }
  384.             } catch (\Throwable $e) {
  385.                 $errors[] = $e->getMessage();
  386.             }
  387.         }
  389.         @rmdir($target);
  391.         if (!empty($errors)) {
  392.             $msg = 'No se pudo borrar completamente la carpeta de files: ' . $target;
  393.             $this->addFlash('warning', $msg);
  394.             error_log($msg . ' | ' . implode(' | ', $errors));
  395.         }
  396.     }
  398.     private function removeCompanyLogsDir(int $companyId): void
  399.     {
  400.         $base = $_ENV['LOGS_ROOT'] ?? '';
  401.         if (trim($base) === '') {
  402.             $msg = 'No se ha podido borrar carpeta de logs: falta LOGS_ROOT en entorno.';
  403.             $this->addFlash('warning', $msg);
  404.             error_log($msg);
  405.             return;
  406.         }
  408.         $base = rtrim($base, '/');
  409.         $target = $base . '/' . $companyId;
  411.         if (!is_dir($target)) {
  412.             return;
  413.         }
  415.         $errors = [];
  416.         $it = new \RecursiveIteratorIterator(
  417.             new \RecursiveDirectoryIterator($target, \FilesystemIterator::SKIP_DOTS),
  418.             \RecursiveIteratorIterator::CHILD_FIRST
  419.         );
  421.         foreach ($it as $file) {
  422.             try {
  423.                 if ($file->isDir()) {
  424.                     @rmdir($file->getPathname());
  425.                 } else {
  426.                     @unlink($file->getPathname());
  427.                 }
  428.             } catch (\Throwable $e) {
  429.                 $errors[] = $e->getMessage();
  430.             }
  431.         }
  433.         @rmdir($target);
  435.         if (!empty($errors)) {
  436.             $msg = 'No se pudo borrar completamente la carpeta de logs: ' . $target;
  437.             $this->addFlash('warning', $msg);
  438.             error_log($msg . ' | ' . implode(' | ', $errors));
  439.         }
  440.     }
  442.     private function getCompanyUserMediaPaths(\mysqli $mysqli): array
  443.     {
  444.         $paths = [];
  445.         try {
  446.             $res = $mysqli->query("SELECT avatar, firma FROM users");
  447.             if ($res) {
  448.                 while ($r = $res->fetch_assoc()) {
  449.                     foreach (['avatar', 'firma'] as $col) {
  450.                         $path = trim((string)($r[$col] ?? ''));
  451.                         if ($path === '' || str_starts_with($path, 'http')) {
  452.                             continue;
  453.                         }
  454.                         $paths[$path] = true;
  455.                     }
  456.                 }
  457.                 $res->free();
  458.             }
  459.         } catch (\Throwable $e) {
  460.             error_log('Error leyendo usuarios para borrar media: ' . $e->getMessage());
  461.         }
  462.         return array_keys($paths);
  463.     }
  465.     private function callPlatformCleanup(int $companyId, array $mediaPaths = []): void
  466.     {
  467.         $url = $_ENV['PLATFORM_CLEANUP_URL'] ?? '';
  468.         $secret = $_ENV['PLATFORM_CLEANUP_SECRET'] ?? '';
  469.         if (trim($url) === '' || trim($secret) === '') {
  470.             $msg = 'Cleanup no ejecutado: faltan PLATFORM_CLEANUP_URL o PLATFORM_CLEANUP_SECRET.';
  471.             $this->addFlash('warning', $msg);
  472.             error_log($msg);
  473.             return;
  474.         }
  476.         $payload = [
  477.             'company_id' => $companyId,
  478.             'media_paths' => array_values($mediaPaths),
  479.         ];
  480.         $body = json_encode($payload, JSON_UNESCAPED_SLASHES);
  481.         if ($body === false) {
  482.             error_log('Cleanup: no se pudo serializar payload JSON.');
  483.             return;
  484.         }
  486.         $ts = time();
  487.         $sig = hash_hmac('sha256', $ts . "\n" . $body, $secret);
  489.         $ch = curl_init();
  490.         curl_setopt($ch, CURLOPT_URL, $url);
  491.         curl_setopt($ch, CURLOPT_POST, true);
  492.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  493.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  494.             'Content-Type: application/json',
  495.             'X-Docu-Timestamp: ' . $ts,
  496.             'X-Docu-Signature: ' . $sig,
  497.         ]);
  498.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  499.         curl_setopt($ch, CURLOPT_TIMEOUT, 8);
  500.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  501.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  503.         $response = curl_exec($ch);
  504.         $error = curl_error($ch);
  505.         $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  506.         curl_close($ch);
  508.         if ($error || $code < 200 || $code >= 300) {
  509.             $msg = 'Cleanup remoto fallo (' . $code . '): ' . ($error ?: (string)$response);
  510.             $this->addFlash('warning', $msg);
  511.             error_log($msg);
  512.         }
  513.     }
  516.     #[Route('/list', name: 'list')]
  517.     public function List(EntityManagerInterface $entityManager)
  518.     {
  519.         if (!$this->getUser() || !is_object($this->getUser())) {
  520.             return $this->redirectToRoute('logout');
  521.         }
  522.         $empresas = $entityManager->getRepository(Empresa::class)->findAll();
  524.         return $this->render('listusers.html.twig', array(
  525.             'empresas' => $empresas,
  526.         ));
  527.     }
  530.     public function appChanges(Request $request, EntityManagerInterface $em)
  531.     {
  532.         if (!$this->getUser() || !is_object($this->getUser())) {
  533.             return $this->redirectToRoute('logout');
  534.         }
  536.         $defaults = [
  537.             'extract_process' => 1,
  538.             'mail_monitor_process' => 0,
  539.             'ocr_process' => 0,
  540.             's3_global' => 0,
  541.             'release_notice' => [
  542.                 'enabled' => 0,
  543.                 'starts_at' => '',
  544.                 'ends_at' => '',
  545.             ],
  546.             'custom_notices' => [],
  547.         ];
  549.         $toggles = $this->loadAppChangesToggles($em, $defaults);
  551.         if ($request->isMethod('POST')) {
  552.             $incoming = [
  553.                 'extract_process' => (int)($request->request->get('extract_process', 0) ? 1 : 0),
  554.                 'mail_monitor_process' => (int)($request->request->get('mail_monitor_process', 0) ? 1 : 0),
  555.                 'ocr_process' => (int)($request->request->get('ocr_process', 0) ? 1 : 0),
  556.                 's3_global' => (int)($request->request->get('s3_global', 0) ? 1 : 0),
  557.                 'release_notice' => $this->normalizeReleaseNoticeFromRequest($request),
  558.                 'custom_notices' => $this->normalizeCustomNoticesFromRequest($request),
  559.             ];
  561.             $toggles = array_merge($defaults, $incoming);
  562.             try {
  563.                 $result = $this->saveAppChangesToggles($em, $toggles);
  564.                 if (($result['updated'] ?? 0) > 0) {
  565.                     $this->addFlash('success', 'Ajustes App guardados correctamente.');
  566.                 } else {
  567.                     $this->addFlash('info', 'No se ha guardado nada porque no había cambios.');
  568.                 }
  569.             } catch (\Throwable $e) {
  570.                 $this->addFlash('danger', 'Error al guardar Ajustes App: ' . $e->getMessage());
  571.             }
  573.             return $this->redirectToRoute('app_changes');
  574.         }
  576.         return $this->render('app_changes/index.html.twig', [
  577.             'toggles' => $toggles,
  578.             'module_options' => $this->appChangesModuleOptions(),
  579.         ]);
  580.     }
  582.     private function appChangesModuleOptions(): array
  583.     {
  584.         return [
  585.             'extraccion' => 'Extracción',
  586.             'mailMonitor' => 'Monitor de correo',
  587.             'etiquetas' => 'Etiquetas',
  588.             'calendario' => 'Calendario',
  589.             'calExt' => 'Calendario externo',
  590.             'estados' => 'Estados',
  591.             'subida' => 'Subida',
  592.             'busquedaNatural' => 'Búsqueda natural',
  593.             'lineas' => 'Líneas',
  594.             'agora' => 'Agora',
  595.             'gstock' => 'Gstock',
  596.             'expowin' => 'Expowin',
  597.             'prinex' => 'Prinex',
  598.         ];
  599.     }
  601.     private function normalizeReleaseNoticeFromRequest(Request $request): array
  602.     {
  603.         $enabled = (int)($request->request->get('release_notice_enabled', 0) ? 1 : 0);
  604.         $startsAt = trim((string)$request->request->get('release_notice_starts_at', ''));
  605.         $endsAt = trim((string)$request->request->get('release_notice_ends_at', ''));
  607.         if ($enabled === 1 && $startsAt === '') {
  608.             $startsAt = date('Y-m-d H:i:s');
  609.         }
  611.         return [
  612.             'enabled' => $enabled,
  613.             'starts_at' => $startsAt,
  614.             'ends_at' => $endsAt,
  615.         ];
  616.     }
  618.     private function normalizeReleaseNotice($value): array
  619.     {
  620.         if (is_array($value)) {
  621.             return [
  622.                 'enabled' => (int)(!empty($value['enabled']) ? 1 : 0),
  623.                 'starts_at' => trim((string)($value['starts_at'] ?? '')),
  624.                 'ends_at' => trim((string)($value['ends_at'] ?? '')),
  625.             ];
  626.         }
  628.         return [
  629.             'enabled' => (int)($value ? 1 : 0),
  630.             'starts_at' => '',
  631.             'ends_at' => '',
  632.         ];
  633.     }
  635.     private function loadAppChangesToggles(EntityManagerInterface $em, array $defaults): array
  636.     {
  637.         $empresas = $em->getRepository(Empresa::class)
  638.             ->createQueryBuilder('e')
  639.             ->leftJoin('e.conexionBD', 'c')
  640.             ->addSelect('c')
  641.             ->where('c.id IS NOT NULL')
  642.             ->orderBy('e.id', 'ASC')
  643.             ->getQuery()
  644.             ->getResult();
  646.         foreach ($empresas as $empresa) {
  647.             $cx = $empresa->getConexionBD();
  648.             if ($cx === null) {
  649.                 continue;
  650.             }
  652.             $mysqli = @new \mysqli(
  653.                 $cx->getDbUrl(),
  654.                 $cx->getDbUser(),
  655.                 $cx->getDbPassword(),
  656.                 $cx->getDbName(),
  657.                 (int)$cx->getDbPort()
  658.             );
  660.             if ($mysqli->connect_error) {
  661.                 continue;
  662.             }
  664.             $mysqli->set_charset('utf8mb4');
  665.             $stmt = $mysqli->prepare("SELECT valor FROM parametros WHERE nombre = ? ORDER BY id ASC LIMIT 1");
  666.             if (!$stmt) {
  667.                 $mysqli->close();
  668.                 continue;
  669.             }
  671.             $name = 'app_dynamic_toggles';
  672.             $stmt->bind_param('s', $name);
  673.             $stmt->execute();
  674.             $res = $stmt->get_result();
  675.             $row = $res ? $res->fetch_assoc() : null;
  676.             $stmt->close();
  677.             $mysqli->close();
  679.             if (!is_array($row) || !isset($row['valor'])) {
  680.                 continue;
  681.             }
  683.             $decoded = json_decode((string)$row['valor'], true);
  684.             if (!is_array($decoded)) {
  685.                 continue;
  686.             }
  688.             $normalized = $defaults;
  689.             foreach (['extract_process', 'mail_monitor_process', 'ocr_process', 's3_global'] as $key) {
  690.                 if (array_key_exists($key, $decoded)) {
  691.                     $normalized[$key] = (int)($decoded[$key] ? 1 : 0);
  692.                 }
  693.             }
  694.             if (array_key_exists('release_notice', $decoded)) {
  695.                 $normalized['release_notice'] = $this->normalizeReleaseNotice($decoded['release_notice']);
  696.             }
  697.             $normalized['custom_notices'] = $this->normalizeCustomNotices($decoded['custom_notices'] ?? []);
  699.             return $normalized;
  700.         }
  702.         return $defaults;
  703.     }
  705.     private function saveAppChangesToggles(EntityManagerInterface $em, array $toggles): array
  706.     {
  707.         $normalizedToggles = [
  708.             'extract_process' => (int)(!empty($toggles['extract_process']) ? 1 : 0),
  709.             'mail_monitor_process' => (int)(!empty($toggles['mail_monitor_process']) ? 1 : 0),
  710.             'ocr_process' => (int)(!empty($toggles['ocr_process']) ? 1 : 0),
  711.             's3_global' => (int)(!empty($toggles['s3_global']) ? 1 : 0),
  712.             'release_notice' => $this->normalizeReleaseNotice($toggles['release_notice'] ?? []),
  713.             'custom_notices' => $this->normalizeCustomNotices($toggles['custom_notices'] ?? []),
  714.         ];
  716.         $payload = json_encode($normalizedToggles, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
  717.         if ($payload === false) {
  718.             throw new \RuntimeException('No se pudo serializar app_dynamic_toggles.');
  719.         }
  721.         $empresas = $em->getRepository(Empresa::class)
  722.             ->createQueryBuilder('e')
  723.             ->leftJoin('e.conexionBD', 'c')
  724.             ->addSelect('c')
  725.             ->where('c.id IS NOT NULL')
  726.             ->orderBy('e.id', 'ASC')
  727.             ->getQuery()
  728.             ->getResult();
  730.         $errors = [];
  731.         $updated = 0;
  732.         $unchanged = 0;
  733.         foreach ($empresas as $empresa) {
  734.             $cx = $empresa->getConexionBD();
  735.             if ($cx === null) {
  736.                 continue;
  737.             }
  739.             $mysqli = @new \mysqli(
  740.                 $cx->getDbUrl(),
  741.                 $cx->getDbUser(),
  742.                 $cx->getDbPassword(),
  743.                 $cx->getDbName(),
  744.                 (int)$cx->getDbPort()
  745.             );
  747.             $label = sprintf('[%d] %s', (int)$empresa->getId(), (string)$empresa->getName());
  749.             if ($mysqli->connect_error) {
  750.                 $errors[] = $label . ': ' . $mysqli->connect_error;
  751.                 continue;
  752.             }
  754.             $mysqli->set_charset('utf8mb4');
  756.             try {
  757.                 $name = 'app_dynamic_toggles';
  759.                 $select = $mysqli->prepare("SELECT valor FROM parametros WHERE nombre = ? LIMIT 1");
  760.                 if (!$select) {
  761.                     throw new \RuntimeException($mysqli->error);
  762.                 }
  763.                 $select->bind_param('s', $name);
  764.                 if (!$select->execute()) {
  765.                     throw new \RuntimeException($select->error);
  766.                 }
  767.                 $res = $select->get_result();
  768.                 $row = $res ? $res->fetch_assoc() : null;
  769.                 $select->close();
  771.                 $current = is_array($row) ? (string)($row['valor'] ?? '') : null;
  772.                 if ($current !== null && $current === $payload) {
  773.                     $unchanged++;
  774.                     continue;
  775.                 }
  777.                 $upsert = $mysqli->prepare("
  778.                     INSERT INTO parametros (nombre, valor)
  779.                     VALUES (?, ?)
  780.                     ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  781.                 ");
  782.                 if (!$upsert) {
  783.                     throw new \RuntimeException($mysqli->error);
  784.                 }
  785.                 $upsert->bind_param('ss', $name, $payload);
  786.                 if (!$upsert->execute()) {
  787.                     throw new \RuntimeException($upsert->error);
  788.                 }
  789.                 $upsert->close();
  790.                 $updated++;
  791.             } catch (\Throwable $e) {
  792.                 $errors[] = $label . ': ' . $e->getMessage();
  793.             } finally {
  794.                 $mysqli->close();
  795.             }
  796.         }
  798.         if (!empty($errors)) {
  799.             throw new \RuntimeException('No se pudieron guardar los ajustes en todas las empresas: ' . implode(' | ', $errors));
  800.         }
  802.         return [
  803.             'updated' => $updated,
  804.             'unchanged' => $unchanged,
  805.         ];
  806.     }
  808.     private function normalizeCustomNoticesFromRequest(Request $request): array
  809.     {
  810.         $ids = $request->request->all('custom_id');
  811.         $rowIndexes = $request->request->all('custom_row_index');
  812.         $enabledMap = $request->request->all('custom_enabled');
  813.         $scopes = $request->request->all('custom_scope');
  814.         $scopeModuleMap = $request->request->all('custom_scope_module');
  815.         $modules = $request->request->all('custom_module');
  816.         $messages = $request->request->all('custom_message');
  818.         $max = max(
  819.             is_array($ids) ? count($ids) : 0,
  820.             is_array($scopes) ? count($scopes) : 0,
  821.             is_array($modules) ? count($modules) : 0,
  822.             is_array($messages) ? count($messages) : 0
  823.         );
  825.         if (!is_array($ids)) {
  826.             $ids = [];
  827.         }
  828.         if (!is_array($rowIndexes)) {
  829.             $rowIndexes = [];
  830.         }
  831.         if (!is_array($enabledMap)) {
  832.             $enabledMap = [];
  833.         }
  834.         if (!is_array($scopes)) {
  835.             $scopes = [];
  836.         }
  837.         if (!is_array($scopeModuleMap)) {
  838.             $scopeModuleMap = [];
  839.         }
  840.         if (!is_array($modules)) {
  841.             $modules = [];
  842.         }
  843.         if (!is_array($messages)) {
  844.             $messages = [];
  845.         }
  847.         $getByKeyOrPosition = static function (array $values, string $key, int $position): string {
  848.             if (array_key_exists($key, $values)) {
  849.                 return trim((string)$values[$key]);
  850.             }
  851.             if (array_key_exists($position, $values)) {
  852.                 return trim((string)$values[$position]);
  853.             }
  854.             return '';
  855.         };
  857.         $rowKeys = [];
  858.         foreach ($rowIndexes as $value) {
  859.             $rowKeys[] = (string)$value;
  860.         }
  861.         foreach ([$ids, $scopes, $scopeModuleMap, $modules, $messages] as $arr) {
  862.             foreach (array_keys($arr) as $key) {
  863.                 $rowKeys[] = (string)$key;
  864.             }
  865.         }
  866.         $rowKeys = array_values(array_unique($rowKeys));
  868.         if (count($rowKeys) === 0 && $max > 0) {
  869.             for ($i = 0; $i < $max; $i++) {
  870.                 $rowKeys[] = (string)$i;
  871.             }
  872.         }
  874.         $rows = [];
  875.         foreach ($rowKeys as $position => $rowKey) {
  876.             $id = $getByKeyOrPosition($ids, $rowKey, $position);
  877.             $scope = strtolower($getByKeyOrPosition($scopes, $rowKey, $position));
  878.             if ($scope === '') {
  879.                 $scope = 'global';
  880.             }
  881.             $module = $getByKeyOrPosition($modules, $rowKey, $position);
  882.             $message = $getByKeyOrPosition($messages, $rowKey, $position);
  883.             $rowIndex = $rowKey;
  884.             $enabled = isset($enabledMap[$rowIndex]) ? 1 : 0;
  885.             if (isset($scopeModuleMap[$rowIndex])) {
  886.                 $scope = 'module';
  887.             }
  889.             if ($id === '' && $message === '') {
  890.                 continue;
  891.             }
  892.             if ($id === '') {
  893.                 $id = 'custom_' . ($position + 1);
  894.             }
  896.             if ($scope !== 'module') {
  897.                 $scope = 'global';
  898.                 $module = '';
  899.             }
  901.             $rows[] = [
  902.                 'id' => $id,
  903.                 'enabled' => $enabled,
  904.                 'scope' => $scope,
  905.                 'module' => $module,
  906.                 'message' => $message,
  907.             ];
  908.         }
  910.         return $this->normalizeCustomNotices($rows);
  911.     }
  913.     private function normalizeCustomNotices($rows): array
  914.     {
  915.         if (!is_array($rows)) {
  916.             return [];
  917.         }
  919.         $normalized = [];
  920.         foreach ($rows as $row) {
  921.             if (!is_array($row)) {
  922.                 continue;
  923.             }
  925.             $id = trim((string)($row['id'] ?? ''));
  926.             $message = trim((string)($row['message'] ?? ''));
  927.             if ($id === '' || $message === '') {
  928.                 continue;
  929.             }
  931.             $scope = strtolower(trim((string)($row['scope'] ?? 'global')));
  932.             $module = trim((string)($row['module'] ?? ''));
  933.             if ($scope !== 'module') {
  934.                 $scope = 'global';
  935.                 $module = '';
  936.             }
  938.             $normalized[] = [
  939.                 'id' => $id,
  940.                 'enabled' => (int)(!empty($row['enabled']) ? 1 : 0),
  941.                 'scope' => $scope,
  942.                 'module' => $module,
  943.                 'message' => $message,
  944.             ];
  945.         }
  947.         return array_values($normalized);
  948.     }
  950.     public function superusersList(EntityManagerInterface $em)
  951.     {
  952.         if (!$this->getUser() || !is_object($this->getUser())) {
  953.             return $this->redirectToRoute('logout');
  954.         }
  956.         $rows = $em->getConnection()->fetchAllAssociative("
  957.             SELECT
  958.                 LOWER(email) AS email_key,
  959.                 MIN(email) AS email,
  960.                 COUNT(*) AS empresas_count,
  961.                 SUM(CASE WHEN status IN ('ENABLED', '1', 1) THEN 1 ELSE 0 END) AS enabled_count
  962.             FROM users
  963.             WHERE is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")
  964.             GROUP BY LOWER(email)
  965.             ORDER BY MIN(email) ASC
  966.         ");
  968.         foreach ($rows as &$row) {
  969.             $email = $this->normalizeSuperuserEmail((string)($row['email'] ?? ''));
  970.             $links = $em->getConnection()->fetchAllAssociative(
  971.                 "SELECT empresa_id, is_admin
  972.                  FROM users
  973.                  WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")
  974.                  ORDER BY empresa_id ASC",
  975.                 ['email' => $email]
  976.             );
  978.             $empresaIds = [];
  979.             foreach ($links as $link) {
  980.                 $empresaIds[] = (int)($link['empresa_id'] ?? 0);
  981.             }
  982.             $empresaIds = array_values(array_unique(array_filter($empresaIds)));
  984.             $account = $this->resolveGlobalAccountType($em, $email, $empresaIds, $links);
  985.             $row['account_type'] = $account['key'];
  986.             $row['account_type_label'] = $account['label'];
  987.         }
  988.         unset($row);
  990.         return $this->render('superusers/list.html.twig', [
  991.             'superusers' => $rows,
  992.         ]);
  993.     }
  996.     public function superusersNew(Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  997.     {
  998.         if (!$this->getUser() || !is_object($this->getUser())) {
  999.             return $this->redirectToRoute('logout');
  1000.         }
  1002.         $empresas = $em->getRepository(Empresa::class)->findAll();
  1003.         $formData = [
  1004.             'email' => '',
  1005.             'status' => 'ENABLED',
  1006.             'empresas' => [],
  1007.             'account_type' => 'superadmin',
  1008.         ];
  1010.         if ($request->isMethod('POST')) {
  1011.             $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  1012.             $password = (string)$request->request->get('password', '');
  1013.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  1014.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  1015.             $targetProfile = $this->targetProfileFromRequest($request);
  1017.             $formData['email'] = $email;
  1018.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  1019.             $formData['empresas'] = $empresaIds;
  1020.             $formData['account_type'] = $this->accountTypeFromProfile($targetProfile);
  1022.             try {
  1023.                 $service->createSuperuser($email, $password, $empresaIds, $enabled, $targetProfile);
  1024.                 $this->addFlash('success', 'Usuario global creado correctamente.');
  1025.                 return $this->redirectToRoute('superusers_list');
  1026.             } catch (\Throwable $e) {
  1027.                 $this->addFlash('danger', $e->getMessage());
  1028.             }
  1029.         }
  1031.         return $this->render('superusers/form.html.twig', [
  1032.             'title' => 'Crear usuario global',
  1033.             'is_edit' => false,
  1034.             'form' => $formData,
  1035.             'empresas' => $empresas,
  1036.         ]);
  1037.     }
  1039.     public function superusersEdit(string $email, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  1040.     {
  1041.         if (!$this->getUser() || !is_object($this->getUser())) {
  1042.             return $this->redirectToRoute('logout');
  1043.         }
  1045.         $email = $this->normalizeSuperuserEmail($email);
  1046.         $existingRows = $em->getConnection()->fetchAllAssociative(
  1047.             "SELECT empresa_id, status, is_admin
  1048.              FROM users
  1049.              WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  1050.             ['email' => $email]
  1051.         );
  1053.         if (count($existingRows) === 0) {
  1054.             $this->addFlash('warning', 'Usuario global no encontrado.');
  1055.             return $this->redirectToRoute('superusers_list');
  1056.         }
  1058.         $selectedEmpresaIds = [];
  1059.         $hasEnabled = false;
  1060.         $isAdminCandidates = [];
  1061.         foreach ($existingRows as $row) {
  1062.             $empresaId = (int)$row['empresa_id'];
  1063.             $selectedEmpresaIds[] = $empresaId;
  1064.             $hasEnabled = $hasEnabled || strtoupper((string)$row['status']) === 'ENABLED';
  1065.             $isAdminCandidates[] = (int)($row['is_admin'] ?? 0);
  1066.         }
  1067.         $selectedEmpresaIds = array_values(array_unique($selectedEmpresaIds));
  1068.         sort($selectedEmpresaIds);
  1069.         $isAdminCandidates = array_values(array_unique($isAdminCandidates));
  1070.         $resolvedProfile = count($isAdminCandidates) === 1
  1071.             ? $this->profileFromIsAdmin((int)$isAdminCandidates[0])
  1072.             : self::PROFILE_SUPERADMIN;
  1073.         $accountType = $this->accountTypeFromProfile($resolvedProfile);
  1075.         $empresas = $em->getRepository(Empresa::class)->findAll();
  1076.         $formData = [
  1077.             'email' => $email,
  1078.             'status' => $hasEnabled ? 'ENABLED' : 'DISABLED',
  1079.             'empresas' => $selectedEmpresaIds,
  1080.             'account_type' => $accountType,
  1081.         ];
  1083.         if ($request->isMethod('POST')) {
  1084.             $newPassword = trim((string)$request->request->get('password', ''));
  1085.             $enabled = strtoupper((string)$request->request->get('status', 'ENABLED')) === 'ENABLED';
  1086.             $empresaIds = $this->readEmpresaIdsFromRequest($request);
  1087.             $targetProfile = $this->targetProfileFromRequest($request);
  1089.             $formData['status'] = $enabled ? 'ENABLED' : 'DISABLED';
  1090.             $formData['empresas'] = $empresaIds;
  1091.             $formData['account_type'] = $this->accountTypeFromProfile($targetProfile);
  1093.             try {
  1094.                 $service->updateSuperuser($email, ($newPassword === '' ? null : $newPassword), $empresaIds, $enabled, $targetProfile);
  1095.                 $this->addFlash('success', 'Usuario global actualizado correctamente.');
  1096.                 return $this->redirectToRoute('superusers_list');
  1097.             } catch (\Throwable $e) {
  1098.                 $this->addFlash('danger', $e->getMessage());
  1099.             }
  1100.         }
  1102.         return $this->render('superusers/form.html.twig', [
  1103.             'title' => 'Editar usuario global',
  1104.             'is_edit' => true,
  1105.             'form' => $formData,
  1106.             'empresas' => $empresas,
  1107.         ]);
  1108.     }
  1110.     public function superusersDeleteLink(string $email, int $empresaId, Request $request, EntityManagerInterface $em, SuperuserProvisioningService $service)
  1111.     {
  1112.         if (!$this->getUser() || !is_object($this->getUser())) {
  1113.             return $this->redirectToRoute('logout');
  1114.         }
  1115.         if (!$request->isMethod('POST')) {
  1116.             return $this->redirectToRoute('superusers_list');
  1117.         }
  1119.         $email = $this->normalizeSuperuserEmail($email);
  1120.         $rows = $em->getConnection()->fetchAllAssociative(
  1121.             "SELECT empresa_id, status, is_admin
  1122.              FROM users
  1123.              WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  1124.             ['email' => $email]
  1125.         );
  1127.         if (count($rows) === 0) {
  1128.             $this->addFlash('warning', 'Usuario global no encontrado.');
  1129.             return $this->redirectToRoute('superusers_list');
  1130.         }
  1132.         $targetEmpresaIds = [];
  1133.         $enabled = false;
  1134.         $isAdminCandidates = [];
  1135.         foreach ($rows as $row) {
  1136.             $currentEmpresaId = (int)$row['empresa_id'];
  1137.             if ($currentEmpresaId !== $empresaId) {
  1138.                 $targetEmpresaIds[] = $currentEmpresaId;
  1139.             }
  1140.             $enabled = $enabled || strtoupper((string)$row['status']) === 'ENABLED';
  1141.             $isAdminCandidates[] = (int)($row['is_admin'] ?? 0);
  1142.         }
  1143.         $isAdminCandidates = array_values(array_unique($isAdminCandidates));
  1144.         $resolvedProfile = count($isAdminCandidates) === 1
  1145.             ? $this->profileFromIsAdmin((int)$isAdminCandidates[0])
  1146.             : self::PROFILE_SUPERADMIN;
  1148.         try {
  1149.             $service->updateSuperuser($email, null, $targetEmpresaIds, $enabled, $resolvedProfile);
  1150.             $this->addFlash('success', 'Vinculación eliminada correctamente.');
  1151.         } catch (\Throwable $e) {
  1152.             $this->addFlash('danger', $e->getMessage());
  1153.         }
  1155.         return $this->redirectToRoute('superusers_edit', ['email' => $email]);
  1156.     }
  1158.     public function superusersDeleteGlobal(string $email, Request $request, SuperuserProvisioningService $service)
  1159.     {
  1160.         if (!$this->getUser() || !is_object($this->getUser())) {
  1161.             return $this->redirectToRoute('logout');
  1162.         }
  1163.         if (!$request->isMethod('POST')) {
  1164.             return $this->redirectToRoute('superusers_list');
  1165.         }
  1167.         $email = $this->normalizeSuperuserEmail($email);
  1168.         try {
  1169.             $service->deleteSuperuser($email);
  1170.             $this->addFlash('success', 'Usuario global eliminado de todas las empresas.');
  1171.         } catch (\Throwable $e) {
  1172.             $this->addFlash('danger', $e->getMessage());
  1173.         }
  1175.         return $this->redirectToRoute('superusers_list');
  1176.     }
  1178.     public function superusersCheckEmail(Request $request, EntityManagerInterface $em): JsonResponse
  1179.     {
  1180.         $email = $this->normalizeSuperuserEmail((string)$request->request->get('email', ''));
  1181.         $empresaIds = $this->readEmpresaIdsFromRequest($request);
  1183.         if ($email === '') {
  1184.             return new JsonResponse(['exists' => false, 'message' => 'email_required'], 400);
  1185.         }
  1186.         if (count($empresaIds) === 0) {
  1187.             return new JsonResponse(['exists' => false, 'message' => 'no_empresas']);
  1188.         }
  1190.         $count = (int)$em->createQueryBuilder()
  1191.             ->select('COUNT(u.id)')
  1192.             ->from(Usuario::class, 'u')
  1193.             ->where('LOWER(u.email) = :email')
  1194.             ->andWhere('u.isAdmin IN (:isAdmins)')
  1195.             ->andWhere('IDENTITY(u.empresa) IN (:empresaIds)')
  1196.             ->setParameter('email', $email)
  1197.             ->setParameter('isAdmins', self::GLOBAL_IS_ADMINS)
  1198.             ->setParameter('empresaIds', $empresaIds)
  1199.             ->getQuery()
  1200.             ->getSingleScalarResult();
  1202.         return new JsonResponse([
  1203.             'exists' => $count > 0,
  1204.             'count' => $count,
  1205.         ]);
  1206.     }
  1208.     private function normalizeSuperuserEmail(string $email): string
  1209.     {
  1210.         return strtolower(trim($email));
  1211.     }
  1213.     private function targetProfileFromRequest(Request $request): int
  1214.     {
  1215.         $accountType = strtolower(trim((string)$request->request->get('account_type', 'superadmin')));
  1216.         return $this->profileFromAccountType($accountType);
  1217.     }
  1219.     private function profileFromAccountType(string $accountType): int
  1220.     {
  1221.         return $accountType === 'superuser'
  1222.             ? self::PROFILE_SUPERUSER
  1223.             : self::PROFILE_SUPERADMIN;
  1224.     }
  1226.     private function accountTypeFromProfile(int $profile): string
  1227.     {
  1228.         return $profile === self::PROFILE_SUPERUSER ? 'superuser' : 'superadmin';
  1229.     }
  1231.     private function accountTypeLabelFromProfile(int $profile): string
  1232.     {
  1233.         return $profile === self::PROFILE_SUPERUSER ? 'Superusuario' : 'Superadministrador';
  1234.     }
  1236.     private function profileFromIsAdmin(int $isAdmin): int
  1237.     {
  1238.         return $isAdmin === self::GLOBAL_IS_ADMIN_SUPERUSER
  1239.             ? self::PROFILE_SUPERUSER
  1240.             : self::PROFILE_SUPERADMIN;
  1241.     }
  1243.     private function resolveGlobalAccountType(EntityManagerInterface $em, string $email, array $empresaIds, array $linkRows = []): array
  1244.     {
  1245.         if ($email === '' || count($empresaIds) === 0) {
  1246.             return ['key' => 'indeterminate', 'label' => 'Indeterminado'];
  1247.         }
  1249.         $isAdmins = [];
  1250.         if (!empty($linkRows)) {
  1251.             foreach ($linkRows as $row) {
  1252.                 $isAdmin = (int)($row['is_admin'] ?? 0);
  1253.                 if (in_array($isAdmin, self::GLOBAL_IS_ADMINS, true)) {
  1254.                     $isAdmins[] = $isAdmin;
  1255.                 }
  1256.             }
  1257.         }
  1259.         if (empty($isAdmins)) {
  1260.             $linkRows = $em->getConnection()->fetchAllAssociative(
  1261.                 "SELECT is_admin
  1262.                  FROM users
  1263.                  WHERE LOWER(email) = :email AND is_admin IN (" . self::GLOBAL_IS_ADMIN_SUPERADMIN . ", " . self::GLOBAL_IS_ADMIN_SUPERUSER . ")",
  1264.                 ['email' => $email]
  1265.             );
  1266.             foreach ($linkRows as $row) {
  1267.                 $isAdmin = (int)($row['is_admin'] ?? 0);
  1268.                 if (in_array($isAdmin, self::GLOBAL_IS_ADMINS, true)) {
  1269.                     $isAdmins[] = $isAdmin;
  1270.                 }
  1271.             }
  1272.         }
  1274.         $isAdmins = array_values(array_unique($isAdmins));
  1275.         if (count($isAdmins) !== 1) {
  1276.             return ['key' => 'indeterminate', 'label' => 'Indeterminado'];
  1277.         }
  1279.         $profile = $this->profileFromIsAdmin((int)$isAdmins[0]);
  1281.         return [
  1282.             'key' => $this->accountTypeFromProfile($profile),
  1283.             'label' => $this->accountTypeLabelFromProfile($profile),
  1284.         ];
  1285.     }
  1287.     /**
  1288.      * @return int[]
  1289.      */
  1290.     private function readEmpresaIdsFromRequest(Request $request): array
  1291.     {
  1292.         $raw = $request->request->all('empresas');
  1293.         if (!is_array($raw)) {
  1294.             $raw = [];
  1295.         }
  1297.         $ids = [];
  1298.         foreach ($raw as $empresaId) {
  1299.             $id = (int)$empresaId;
  1300.             if ($id > 0) {
  1301.                 $ids[] = $id;
  1302.             }
  1303.         }
  1305.         $ids = array_values(array_unique($ids));
  1306.         sort($ids);
  1307.         return $ids;
  1308.     }
  1310.     public function azureResourcesList(EntityManagerInterface $em)
  1311.     {
  1312.         if (!$this->getUser() || !is_object($this->getUser())) {
  1313.             return $this->redirectToRoute('logout');
  1314.         }
  1316.         $resources = [];
  1317.         try {
  1318.             $resources = $this->loadAzureResources($em);
  1319.         } catch (\Throwable $e) {
  1320.             $this->addFlash('danger', 'No se pudo cargar el listado de recursos IA: ' . $e->getMessage());
  1321.         }
  1323.         return $this->render('azure_resources/list.html.twig', [
  1324.             'resources' => $resources,
  1325.         ]);
  1326.     }
  1328.     public function azureResourcesNew(Request $request, EntityManagerInterface $em)
  1329.     {
  1330.         if (!$this->getUser() || !is_object($this->getUser())) {
  1331.             return $this->redirectToRoute('logout');
  1332.         }
  1334.         $resource = [
  1335.             'name' => '',
  1336.             'endpoint' => '',
  1337.             'api_key' => '',
  1338.             'extractor_type' => self::EXTRACTOR_TYPE_AZURE_DI,
  1339.             'model_id' => '',
  1340.             'base_prompt' => '',
  1341.         ];
  1343.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  1344.             $resource['name'] = trim((string)$request->request->get('name', ''));
  1345.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  1346.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  1347.             $resource['extractor_type'] = $this->normalizeExtractorType((string)$request->request->get('extractor_type', self::EXTRACTOR_TYPE_AZURE_DI));
  1348.             $resource['model_id'] = trim((string)$request->request->get('model_id', ''));
  1349.             $resource['base_prompt'] = trim((string)$request->request->get('base_prompt', ''));
  1351.             if (
  1352.                 $resource['name'] === '' ||
  1353.                 $resource['endpoint'] === '' ||
  1354.                 $resource['api_key'] === ''
  1355.             ) {
  1356.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  1357.             } elseif (
  1358.                 $resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_OPENAI &&
  1359.                 ($resource['model_id'] === '' || $resource['base_prompt'] === '')
  1360.             ) {
  1361.                 $this->addFlash('danger', 'Para recursos Azure OpenAI debes indicar model_id y prompt general.');
  1362.             } else {
  1363.                 if ($resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_DI) {
  1364.                     $resource['model_id'] = '';
  1365.                     $resource['base_prompt'] = '';
  1366.                 }
  1367.                 try {
  1368.                     $em->getConnection()->insert('azure_di_resources', [
  1369.                         'name' => $resource['name'],
  1370.                         'endpoint' => $resource['endpoint'],
  1371.                         'api_key' => $resource['api_key'],
  1372.                         'extractor_type' => $resource['extractor_type'],
  1373.                         'model_id' => $resource['model_id'],
  1374.                         'base_prompt' => $resource['base_prompt'],
  1375.                     ]);
  1376.                     $this->addFlash('success', 'Recurso IA creado correctamente.');
  1377.                     return $this->redirectToRoute('azure_resources_list');
  1378.                 } catch (\Throwable $e) {
  1379.                     $this->addFlash('danger', 'No se pudo crear el recurso: ' . $e->getMessage());
  1380.                 }
  1381.             }
  1382.         }
  1384.         return $this->render('azure_resources/new.html.twig', [
  1385.             'resource' => $resource,
  1386.         ]);
  1387.     }
  1389.     public function azureResourcesEdit(Request $request, EntityManagerInterface $em)
  1390.     {
  1391.         if (!$this->getUser() || !is_object($this->getUser())) {
  1392.             return $this->redirectToRoute('logout');
  1393.         }
  1395.         $id = (int)$request->get('id');
  1396.         $resource = $this->loadAzureResourceById($em, $id);
  1397.         if (!$resource) {
  1398.             $this->addFlash('warning', 'Recurso no encontrado.');
  1399.             return $this->redirectToRoute('azure_resources_list');
  1400.         }
  1402.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  1403.             $resource['name'] = trim((string)$request->request->get('name', ''));
  1404.             $resource['endpoint'] = $this->normalizeAzureEndpoint((string)$request->request->get('endpoint', ''));
  1405.             $resource['api_key'] = trim((string)$request->request->get('api_key', ''));
  1406.             $resource['extractor_type'] = $this->normalizeExtractorType((string)$request->request->get('extractor_type', self::EXTRACTOR_TYPE_AZURE_DI));
  1407.             $resource['model_id'] = trim((string)$request->request->get('model_id', ''));
  1408.             $resource['base_prompt'] = trim((string)$request->request->get('base_prompt', ''));
  1410.             if (
  1411.                 $resource['name'] === '' ||
  1412.                 $resource['endpoint'] === '' ||
  1413.                 $resource['api_key'] === ''
  1414.             ) {
  1415.                 $this->addFlash('danger', 'Nombre, endpoint y api key son obligatorios.');
  1416.             } elseif (
  1417.                 $resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_OPENAI &&
  1418.                 ($resource['model_id'] === '' || $resource['base_prompt'] === '')
  1419.             ) {
  1420.                 $this->addFlash('danger', 'Para recursos Azure OpenAI debes indicar model_id y prompt general.');
  1421.             } else {
  1422.                 if ($resource['extractor_type'] === self::EXTRACTOR_TYPE_AZURE_DI) {
  1423.                     $resource['model_id'] = '';
  1424.                     $resource['base_prompt'] = '';
  1425.                 }
  1426.                 try {
  1427.                     $em->getConnection()->update('azure_di_resources', [
  1428.                         'name' => $resource['name'],
  1429.                         'endpoint' => $resource['endpoint'],
  1430.                         'api_key' => $resource['api_key'],
  1431.                         'extractor_type' => $resource['extractor_type'],
  1432.                         'model_id' => $resource['model_id'],
  1433.                         'base_prompt' => $resource['base_prompt'],
  1434.                     ], [
  1435.                         'id' => $id,
  1436.                     ]);
  1437.                     $this->addFlash('success', 'Recurso IA actualizado correctamente.');
  1438.                     return $this->redirectToRoute('azure_resources_list');
  1439.                 } catch (\Throwable $e) {
  1440.                     $this->addFlash('danger', 'No se pudo actualizar el recurso: ' . $e->getMessage());
  1441.                 }
  1442.             }
  1443.         }
  1445.         return $this->render('azure_resources/edit.html.twig', [
  1446.             'resource' => $resource,
  1447.         ]);
  1448.     }
  1450.     public function azureResourcesDelete(Request $request, EntityManagerInterface $em)
  1451.     {
  1452.         if (!$this->getUser() || !is_object($this->getUser())) {
  1453.             return $this->redirectToRoute('logout');
  1454.         }
  1456.         $id = (int)$request->get('id');
  1457.         if ($id <= 0) {
  1458.             $this->addFlash('warning', 'Identificador de recurso no valido.');
  1459.             return $this->redirectToRoute('azure_resources_list');
  1460.         }
  1462.         try {
  1463.             $em->getConnection()->delete('azure_di_resources', ['id' => $id]);
  1464.             $this->addFlash('success', 'Recurso IA eliminado correctamente.');
  1465.         } catch (\Throwable $e) {
  1466.             $this->addFlash('danger', 'No se pudo eliminar el recurso: ' . $e->getMessage());
  1467.         }
  1469.         return $this->redirectToRoute('azure_resources_list');
  1470.     }
  1472.     public function azureApiResourceModels(Request $request, EntityManagerInterface $em): JsonResponse
  1473.     {
  1474.         if (!$this->getUser() || !is_object($this->getUser())) {
  1475.             return new JsonResponse(['error' => 'unauthorized'], 401);
  1476.         }
  1478.         $resource = $this->loadAzureResourceById($em, (int)$request->get('id'));
  1479.         if (!$resource) {
  1480.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  1481.         }
  1482.         if (($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  1483.             return new JsonResponse(['error' => 'resource_type_not_supported_for_di_models'], 400);
  1484.         }
  1486.         try {
  1487.             $payload = $this->azureRequest(
  1488.                 (string)$resource['endpoint'],
  1489.                 (string)$resource['api_key'],
  1490.                 '/documentintelligence/documentModels'
  1491.             );
  1492.         } catch (\Throwable $e) {
  1493.             $status = (int)$e->getCode();
  1494.             if ($status < 400 || $status > 599) {
  1495.                 $status = 502;
  1496.             }
  1497.             return new JsonResponse(['error' => $e->getMessage()], $status);
  1498.         }
  1500.         $models = $payload['value'] ?? [];
  1501.         if (!is_array($models)) {
  1502.             $models = [];
  1503.         }
  1505.         $normalizedModels = [];
  1506.         foreach ($models as $model) {
  1507.             if (!is_array($model)) {
  1508.                 continue;
  1509.             }
  1510.             $normalizedModels[] = [
  1511.                 'modelId' => (string)($model['modelId'] ?? ''),
  1512.                 'description' => (string)($model['description'] ?? ''),
  1513.                 'createdDateTime' => (string)($model['createdDateTime'] ?? ''),
  1514.                 'expirationDateTime' => (string)($model['expirationDateTime'] ?? ''),
  1515.                 'type' => $this->classifyModelType($model),
  1516.             ];
  1517.         }
  1519.         usort($normalizedModels, static function (array $a, array $b): int {
  1520.             return strcmp($a['modelId'] ?? '', $b['modelId'] ?? '');
  1521.         });
  1523.         return new JsonResponse([
  1524.             'resource' => [
  1525.                 'id' => (int)$resource['id'],
  1526.                 'name' => (string)$resource['name'],
  1527.             ],
  1528.             'models' => $normalizedModels,
  1529.         ]);
  1530.     }
  1532.     public function azureApiResourceModelDetail(Request $request, EntityManagerInterface $em): JsonResponse
  1533.     {
  1534.         if (!$this->getUser() || !is_object($this->getUser())) {
  1535.             return new JsonResponse(['error' => 'unauthorized'], 401);
  1536.         }
  1538.         $resource = $this->loadAzureResourceById($em, (int)$request->get('id'));
  1539.         if (!$resource) {
  1540.             return new JsonResponse(['error' => 'resource_not_found'], 404);
  1541.         }
  1542.         if (($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  1543.             return new JsonResponse(['error' => 'resource_type_not_supported_for_di_models'], 400);
  1544.         }
  1546.         $modelId = trim((string)$request->get('modelId'));
  1547.         if ($modelId === '') {
  1548.             return new JsonResponse(['error' => 'model_id_required'], 400);
  1549.         }
  1551.         try {
  1552.             $detail = $this->azureRequest(
  1553.                 (string)$resource['endpoint'],
  1554.                 (string)$resource['api_key'],
  1555.                 '/documentintelligence/documentModels/' . rawurlencode($modelId)
  1556.             );
  1557.             $mapped = $this->mapAzureSchemaToDefinitions($detail);
  1558.         } catch (\Throwable $e) {
  1559.             $status = (int)$e->getCode();
  1560.             if ($status < 400 || $status > 599) {
  1561.                 $status = 502;
  1562.             }
  1563.             return new JsonResponse(['error' => $e->getMessage()], $status);
  1564.         }
  1566.         return new JsonResponse([
  1567.             'model' => $detail,
  1568.             'type' => $this->classifyModelType($detail),
  1569.             'preview' => [
  1570.                 'header' => $mapped['header'],
  1571.                 'lines' => $mapped['lines'],
  1572.             ],
  1573.         ]);
  1574.     }
  1576.     public function empresaApiExtractionModelDetail(Request $request, EntityManagerInterface $em): JsonResponse
  1577.     {
  1578.         if (!$this->getUser() || !is_object($this->getUser())) {
  1579.             return new JsonResponse(['error' => 'unauthorized'], 401);
  1580.         }
  1582.         $id = (int)$request->get('id');
  1583.         $modelLocalId = (int)$request->get('modelId');
  1584.         if ($id <= 0 || $modelLocalId <= 0) {
  1585.             return new JsonResponse(['error' => 'invalid_params'], 400);
  1586.         }
  1588.         $empresa = $em->getRepository(Empresa::class)->find($id);
  1589.         if (!$empresa) {
  1590.             return new JsonResponse(['error' => 'empresa_not_found'], 404);
  1591.         }
  1593.         $cx = $empresa->getConexionBD();
  1594.         $mysqli = @new \mysqli(
  1595.             $cx->getDbUrl(),
  1596.             $cx->getDbUser(),
  1597.             $cx->getDbPassword(),
  1598.             $cx->getDbName(),
  1599.             (int)$cx->getDbPort()
  1600.         );
  1601.         if ($mysqli->connect_error) {
  1602.             return new JsonResponse(['error' => 'db_connection_error'], 500);
  1603.         }
  1605.         $provider = '';
  1606.         try {
  1607.             $stmt = $mysqli->prepare('SELECT provider FROM extraction_models WHERE id = ? LIMIT 1');
  1608.             if ($stmt) {
  1609.                 $stmt->bind_param('i', $modelLocalId);
  1610.                 if ($stmt->execute()) {
  1611.                     $res = $stmt->get_result();
  1612.                     if ($res && ($row = $res->fetch_assoc())) {
  1613.                         $provider = strtolower(trim((string)($row['provider'] ?? '')));
  1614.                     }
  1615.                 }
  1616.                 $stmt->close();
  1617.             }
  1618.         } catch (\Throwable $e) {
  1619.             $provider = '';
  1620.         }
  1622.         if ($provider === '') {
  1623.             $mysqli->close();
  1624.             return new JsonResponse(['error' => 'model_not_found'], 404);
  1625.         }
  1627.         $fields = [];
  1628.         $aoaiResourceId = 0;
  1629.         if ($provider === 'azure_openai' || $provider === 'azure-openai') {
  1630.             $fields = $this->loadAoaiFieldsForModel($mysqli, $modelLocalId);
  1631.             $aoaiResourceId = $this->resolveAoaiResourceIdForModel($mysqli, $modelLocalId, $em);
  1632.         }
  1634.         $mysqli->close();
  1636.         return new JsonResponse([
  1637.             'model_id' => $modelLocalId,
  1638.             'provider' => $provider,
  1639.             'aoai_resource_id' => $aoaiResourceId,
  1640.             'fields' => $fields,
  1641.         ]);
  1642.     }
  1644.     private function normalizeExtractorType(string $value): string
  1645.     {
  1646.         $value = strtolower(trim($value));
  1647.         return $value === self::EXTRACTOR_TYPE_AZURE_OPENAI
  1648.             ? self::EXTRACTOR_TYPE_AZURE_OPENAI
  1649.             : self::EXTRACTOR_TYPE_AZURE_DI;
  1650.     }
  1652.     private function loadAoaiFieldsForModel(\mysqli $mysqli, int $modelId): array
  1653.     {
  1654.         $fields = [];
  1656.         $stmtHeader = $mysqli->prepare(
  1657.             'SELECT field_key, prompt, value_type FROM definitions_header WHERE model_id = ? ORDER BY order_index ASC, id ASC'
  1658.         );
  1659.         if ($stmtHeader) {
  1660.             $stmtHeader->bind_param('i', $modelId);
  1661.             if ($stmtHeader->execute()) {
  1662.                 $resHeader = $stmtHeader->get_result();
  1663.                 while ($resHeader && ($row = $resHeader->fetch_assoc())) {
  1664.                     $fields[] = [
  1665.                         'scope' => 'header',
  1666.                         'field_key' => (string)($row['field_key'] ?? ''),
  1667.                         'prompt' => (string)($row['prompt'] ?? ''),
  1668.                         'value_type' => $this->normalizeAoaiValueType((string)($row['value_type'] ?? 'string')),
  1669.                     ];
  1670.                 }
  1671.             }
  1672.             $stmtHeader->close();
  1673.         }
  1675.         $stmtLines = $mysqli->prepare(
  1676.             'SELECT field_key, prompt, value_type FROM definitions_lines WHERE model_id = ? ORDER BY order_index ASC, id ASC'
  1677.         );
  1678.         if ($stmtLines) {
  1679.             $stmtLines->bind_param('i', $modelId);
  1680.             if ($stmtLines->execute()) {
  1681.                 $resLines = $stmtLines->get_result();
  1682.                 while ($resLines && ($row = $resLines->fetch_assoc())) {
  1683.                     $fields[] = [
  1684.                         'scope' => 'lines',
  1685.                         'field_key' => (string)($row['field_key'] ?? ''),
  1686.                         'prompt' => (string)($row['prompt'] ?? ''),
  1687.                         'value_type' => $this->normalizeAoaiValueType((string)($row['value_type'] ?? 'string')),
  1688.                     ];
  1689.                 }
  1690.             }
  1691.             $stmtLines->close();
  1692.         }
  1694.         return $fields;
  1695.     }
  1697.     private function resolveAoaiResourceIdForModel(\mysqli $mysqli, int $modelId, EntityManagerInterface $em): int
  1698.     {
  1699.         $currentModelId = '';
  1700.         $currentEndpoint = '';
  1701.         $stmtModelMeta = $mysqli->prepare(
  1702.             "SELECT model_id, endpoint FROM extraction_models WHERE id = ? AND provider IN ('azure_openai', 'azure-openai') LIMIT 1"
  1703.         );
  1704.         if ($stmtModelMeta) {
  1705.             $stmtModelMeta->bind_param('i', $modelId);
  1706.             if ($stmtModelMeta->execute()) {
  1707.                 $resMeta = $stmtModelMeta->get_result();
  1708.                 if ($resMeta && ($metaRow = $resMeta->fetch_assoc())) {
  1709.                     $currentModelId = trim((string)($metaRow['model_id'] ?? ''));
  1710.                     $currentEndpoint = $this->normalizeAzureEndpoint((string)($metaRow['endpoint'] ?? ''));
  1711.                 }
  1712.             }
  1713.             $stmtModelMeta->close();
  1714.         }
  1716.         if ($currentModelId === '' || $currentEndpoint === '') {
  1717.             return 0;
  1718.         }
  1720.         $azureOpenAiResources = [];
  1721.         try {
  1722.             $allResources = $this->loadAzureResources($em);
  1723.             foreach ($allResources as $resourceRow) {
  1724.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1725.                     $azureOpenAiResources[] = $resourceRow;
  1726.                 }
  1727.             }
  1728.         } catch (\Throwable $e) {
  1729.             $azureOpenAiResources = [];
  1730.         }
  1732.         foreach ($azureOpenAiResources as $resourceRow) {
  1733.             $resourceModelId = trim((string)($resourceRow['model_id'] ?? ''));
  1734.             $resourceEndpoint = $this->normalizeAzureEndpoint((string)($resourceRow['endpoint'] ?? ''));
  1735.             if ($resourceModelId === $currentModelId && $resourceEndpoint === $currentEndpoint) {
  1736.                 return (int)($resourceRow['id'] ?? 0);
  1737.             }
  1738.         }
  1740.         return 0;
  1741.     }
  1743.     private function loadAzureResources(EntityManagerInterface $em, ?string $extractorType = null): array
  1744.     {
  1745.         $rows = [];
  1746.         $sql = 'SELECT id, name, endpoint, api_key, extractor_type, model_id, base_prompt, created_at, updated_at
  1747.                 FROM azure_di_resources';
  1748.         $params = [];
  1749.         if ($extractorType !== null && $extractorType !== '') {
  1750.             $sql .= ' WHERE extractor_type = :extractor_type';
  1751.             $params['extractor_type'] = $this->normalizeExtractorType($extractorType);
  1752.         }
  1753.         $sql .= ' ORDER BY name ASC';
  1754.         try {
  1755.             $rows = $em->getConnection()->executeQuery($sql, $params)->fetchAllAssociative();
  1756.         } catch (\Throwable $e) {
  1757.             // Compatibilidad temporal con esquemas antiguos sin columnas nuevas.
  1758.             $legacyRows = $em->getConnection()->executeQuery(
  1759.                 'SELECT id, name, endpoint, api_key, created_at, updated_at FROM azure_di_resources ORDER BY name ASC'
  1760.             )->fetchAllAssociative();
  1761.             foreach ($legacyRows as &$legacy) {
  1762.                 $legacy['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  1763.                 $legacy['model_id'] = '';
  1764.                 $legacy['base_prompt'] = '';
  1765.             }
  1766.             $rows = $legacyRows;
  1767.         }
  1768.         foreach ($rows as &$row) {
  1769.             $row['id'] = (int)$row['id'];
  1770.             $row['extractor_type'] = $this->normalizeExtractorType((string)($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1771.             $row['model_id'] = (string)($row['model_id'] ?? '');
  1772.             $row['base_prompt'] = (string)($row['base_prompt'] ?? '');
  1773.         }
  1775.         return $rows;
  1776.     }
  1778.     private function loadAzureResourceById(EntityManagerInterface $em, int $id): ?array
  1779.     {
  1780.         if ($id <= 0) {
  1781.             return null;
  1782.         }
  1784.         $row = null;
  1785.         try {
  1786.             $row = $em->getConnection()->fetchAssociative(
  1787.                 'SELECT id, name, endpoint, api_key, extractor_type, model_id, base_prompt, created_at, updated_at
  1788.                  FROM azure_di_resources
  1789.                  WHERE id = :id',
  1790.                 ['id' => $id]
  1791.             );
  1792.         } catch (\Throwable $e) {
  1793.             $row = $em->getConnection()->fetchAssociative(
  1794.                 'SELECT id, name, endpoint, api_key, created_at, updated_at
  1795.                  FROM azure_di_resources
  1796.                  WHERE id = :id',
  1797.                 ['id' => $id]
  1798.             );
  1799.             if ($row) {
  1800.                 $row['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  1801.                 $row['model_id'] = '';
  1802.                 $row['base_prompt'] = '';
  1803.             }
  1804.         }
  1806.         if (!$row) {
  1807.             return null;
  1808.         }
  1810.         $row['id'] = (int)$row['id'];
  1811.         $row['extractor_type'] = $this->normalizeExtractorType((string)($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1812.         $row['model_id'] = (string)($row['model_id'] ?? '');
  1813.         $row['base_prompt'] = (string)($row['base_prompt'] ?? '');
  1814.         return $row;
  1815.     }
  1817.     private function loadAzureDiResources(EntityManagerInterface $em): array
  1818.     {
  1819.         return $this->loadAzureResources($em, self::EXTRACTOR_TYPE_AZURE_DI);
  1820.     }
  1822.     private function loadAzureDiResourceById(EntityManagerInterface $em, int $id): ?array
  1823.     {
  1824.         $row = $this->loadAzureResourceById($em, $id);
  1825.         if (!$row) {
  1826.             return null;
  1827.         }
  1828.         return ($row['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_DI
  1829.             ? $row
  1830.             : null;
  1831.     }
  1833.     private function normalizeAzureEndpoint(string $endpoint): string
  1834.     {
  1835.         $endpoint = trim($endpoint);
  1836.         if ($endpoint === '') {
  1837.             return '';
  1838.         }
  1840.         if (!preg_match('#^https?://#i', $endpoint)) {
  1841.             $endpoint = 'https://' . $endpoint;
  1842.         }
  1844.         return rtrim($endpoint, '/');
  1845.     }
  1847.     private function azureRequest(string $endpoint, string $apiKey, string $path, array $query = []): array
  1848.     {
  1849.         $endpoint = $this->normalizeAzureEndpoint($endpoint);
  1850.         if ($endpoint === '' || trim($apiKey) === '') {
  1851.             throw new \RuntimeException('Recurso IA incompleto.', 400);
  1852.         }
  1854.         $query = array_merge(['api-version' => self::AZURE_DI_API_VERSION], $query);
  1855.         $url = $endpoint . '/' . ltrim($path, '/') . '?' . http_build_query($query);
  1857.         $ch = curl_init();
  1858.         curl_setopt($ch, CURLOPT_URL, $url);
  1859.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  1860.             'Accept: application/json',
  1861.             'Ocp-Apim-Subscription-Key: ' . $apiKey,
  1862.         ]);
  1863.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1864.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 8);
  1865.         curl_setopt($ch, CURLOPT_TIMEOUT, 25);
  1867.         $response = curl_exec($ch);
  1868.         $curlError = curl_error($ch);
  1869.         $statusCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1870.         curl_close($ch);
  1872.         if ($curlError) {
  1873.             throw new \RuntimeException('Error de red con recurso IA: ' . $curlError, 0);
  1874.         }
  1876.         $decoded = [];
  1877.         if (is_string($response) && trim($response) !== '') {
  1878.             $decoded = json_decode($response, true);
  1879.             if (!is_array($decoded)) {
  1880.                 throw new \RuntimeException('Respuesta no valida del recurso IA.', 502);
  1881.             }
  1882.         }
  1884.         if ($statusCode < 200 || $statusCode >= 300) {
  1885.             $detail = $decoded['error']['message'] ?? $decoded['message'] ?? ('HTTP ' . $statusCode);
  1886.             throw new \RuntimeException((string)$detail, $statusCode);
  1887.         }
  1889.         return $decoded;
  1890.     }
  1892.     private function classifyModelType(array $model): string
  1893.     {
  1894.         $expiration = trim((string)($model['expirationDateTime'] ?? ''));
  1895.         return $expiration !== '' ? 'custom' : 'prebuilt';
  1896.     }
  1898.     public function addEmpresa(Request $req, EntityManagerInterface $em)
  1899.     {
  1900.         //dd(\shell_exec('whoami'));
  1901.         if (!$this->getUser() || !is_object($this->getUser())) {
  1902.             return $this->redirectToRoute('logout');
  1903.         }
  1904.         $azureResources = [];
  1905.         $azureDiResources = [];
  1906.         $azureOpenAiResources = [];
  1907.         try {
  1908.             $azureResources = $this->loadAzureResources($em);
  1909.             foreach ($azureResources as $resourceRow) {
  1910.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1911.                     $azureOpenAiResources[] = $resourceRow;
  1912.                 } else {
  1913.                     $azureDiResources[] = $resourceRow;
  1914.                 }
  1915.             }
  1916.         } catch (\Throwable $e) {
  1917.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  1918.         }
  1920.         $ocrPlusAvailable = $this->isOcrPlusAvailable();
  1921.         $ocrV2Available = $this->isOcrV2Available();
  1922.         
  1924.         if ($req->request->get("submit") != "") {
  1925.             $data = $req->request->all();
  1926.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, 4);
  1927.             $data['ocr_mode'] = $this->normalizeOcrMode($data['ocr_mode'] ?? 'base');
  1928.             if (!$ocrV2Available && $data['ocr_mode'] === 'v2_zxing') {
  1929.                 $data['ocr_mode'] = 'base';
  1930.             }
  1931.             if (!$ocrPlusAvailable && $data['ocr_mode'] === 'plus_glm') {
  1932.                 $data['ocr_mode'] = 'base';
  1933.             }
  1935.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  1936.             $mailMonitorEnabled = isset($data['modulo_mailMonitor']) && $toBool($data['modulo_mailMonitor']);
  1937.             $data['modulo_extraccion'] = isset($data['modulo_extraccion']) && $toBool($data['modulo_extraccion']) ? 1 : 0;
  1938.             $data['modulo_expowin'] = isset($data['modulo_expowin']) && $toBool($data['modulo_expowin']) ? 1 : 0;
  1939.             $data['modulo_prinex'] = isset($data['modulo_prinex']) && $toBool($data['modulo_prinex']) ? 1 : 0;
  1941.             $extractorType = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1942.             $data['extractor_type'] = $extractorType;
  1943.             $azureResource = null;
  1944.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  1945.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  1946.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  1947.             $aoaiFields = $this->collectAoaiFieldsFromRequest($req);
  1949.             $renderAddWithData = function () use ($azureResources, $azureDiResources, $azureOpenAiResources, $data, $aoaiFields) {
  1950.                 $contractPreview = $this->licenseContractService->defaultContract();
  1951.                 try {
  1952.                     $contractPreview = $this->licenseContractService->contractFromPayload($data);
  1953.                 } catch (\Throwable $e) {
  1954.                     // Mantener preview por defecto si los datos de licencia son inválidos.
  1955.                 }
  1956.                 return $this->render('empresa/_add.html.twig', [
  1957.                     'azure_resources' => $azureResources,
  1958.                     'azure_di_resources' => $azureDiResources,
  1959.                     'azure_openai_resources' => $azureOpenAiResources,
  1960.                     'modulos' => [
  1961.                         'extraction_model' => 0,
  1962.                     ],
  1963.                     'form_data' => $data,
  1964.                     'activeLicenseContract' => $contractPreview,
  1965.                     'aoai_fields' => $aoaiFields,
  1966.                     'ocr_plus_available' => $ocrPlusAvailable,
  1967.                     'ocr_v2_available' => $ocrV2Available,
  1968.                 ]);
  1969.             };
  1971.             try {
  1972.                 $data = $this->licenseContractService->normalizePayload($data, false);
  1973.             } catch (\InvalidArgumentException $e) {
  1974.                 $this->addFlash('danger', $e->getMessage());
  1975.                 return $renderAddWithData();
  1976.             }
  1978.             if ($data['modulo_extraccion'] === 1) {
  1979.                 if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1980.                     if ($aoaiResourceId <= 0) {
  1981.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  1982.                         return $renderAddWithData();
  1983.                     }
  1984.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  1985.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1986.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  1987.                         return $renderAddWithData();
  1988.                     }
  1989.                     $validationError = $this->validateAoaiFields($aoaiFields);
  1990.                     if ($validationError !== null) {
  1991.                         $this->addFlash('danger', $validationError);
  1992.                         return $renderAddWithData();
  1993.                     }
  1994.                 } else {
  1995.                     if ($azureResourceId <= 0 || $azureModelId === '') {
  1996.                         $this->addFlash('danger', 'Para activar extraccion debes seleccionar recurso y modelo IA.');
  1997.                         return $renderAddWithData();
  1998.                     }
  2000.                     $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  2001.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  2002.                         $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  2003.                         return $renderAddWithData();
  2004.                     }
  2006.                     try {
  2007.                         $this->azureRequest(
  2008.                             (string)$azureResource['endpoint'],
  2009.                             (string)$azureResource['api_key'],
  2010.                             '/documentintelligence/documentModels/' . rawurlencode($azureModelId)
  2011.                         );
  2012.                     } catch (\Throwable $e) {
  2013.                         $this->addFlash('danger', 'No se pudo validar el modelo IA: ' . $e->getMessage());
  2014.                         return $renderAddWithData();
  2015.                     }
  2016.                 }
  2017.             } else {
  2018.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  2019.                 $data['azure_resource_id'] = 0;
  2020.                 $data['azure_model_id'] = '';
  2021.                 $data['aoai_resource_id'] = 0;
  2022.                 $data['extraction_model'] = 0;
  2023.                 $data['modulo_expowin'] = 0;
  2024.                 $data['modulo_prinex'] = 0;
  2025.             }
  2027.             // Crear nombre de base de datos y credenciales aleatorios
  2028.             $dbName = 'doc_' . bin2hex(random_bytes(3));
  2029.             $dbUser = 'doc_' . bin2hex(random_bytes(2));
  2030.             $dbPass = bin2hex(random_bytes(8));
  2031.             $dbHost = 'localhost';
  2032.             $dbPort = '3306';
  2034.             // Credenciales de HestiaCP desde variables de entorno
  2035.             $hestiaApiUrl = $_ENV['HESTIA_API_URL'];
  2036.             $hestiaApiUser = $_ENV['HESTIA_API_USER'];
  2037.             $hestiaApiPass = $_ENV['HESTIA_API_PASS'];
  2038.             $hestiaOwner   = $_ENV['HESTIA_OWNER'];
  2039.             $accessKeyId   = $_ENV['HESTIA_ACCESS_KEY_ID'] ?? '';
  2040.             $secretKey     = $_ENV['HESTIA_SECRET_KEY'] ?? '';
  2042.             // Variables para el script de bash
  2043.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  2044.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  2045.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  2046.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  2047.             if ($ocrMode === 'plus_glm') {
  2048.                 $ocrBinary = $ocrBinaryPlus;
  2049.             } elseif ($ocrMode === 'v2_zxing') {
  2050.                 $ocrBinary = $ocrBinaryV2;
  2051.             } else {
  2052.                 $ocrBinary = $ocrBinaryBase;
  2053.             }
  2054.             $filesPath  = $_ENV['FILES_PATH'];
  2055.             if (($data['ocr_mode'] ?? 'base') === 'plus_glm' && trim($ocrBinaryPlus) === '') {
  2056.                 $this->addFlash('danger', 'OCR+ seleccionado pero falta configurar OCR_PLUS_BINARY en .env.local.');
  2057.                 return $renderAddWithData();
  2058.             }
  2059.             if (($data['ocr_mode'] ?? 'base') === 'v2_zxing' && trim($ocrBinaryV2) === '') {
  2060.                 $this->addFlash('danger', 'OCR v2 seleccionado pero falta configurar OCR_BINARY_V2 en .env.local.');
  2061.                 return $renderAddWithData();
  2062.             }
  2063.             if (($data['ocr_mode'] ?? 'base') === 'base' && trim($ocrBinaryBase) === '') {
  2064.                 $this->addFlash('danger', 'OCR Base seleccionado pero falta configurar OCR_BINARY en .env.local.');
  2065.                 return $renderAddWithData();
  2066.             }
  2067.             if (trim((string)$filesPath) === '') {
  2068.                 $this->addFlash('danger', 'Falta configurar FILES_PATH en .env.local.');
  2069.                 return $renderAddWithData();
  2070.             }
  2072.             $owner = $hestiaOwner; // o el dueńo del hosting
  2074.             $postFields = http_build_query([
  2075.                 'user' => $hestiaApiUser,
  2076.                 'password' => $hestiaApiPass,
  2077.                 'returncode' => 'yes',
  2078.                 'cmd' => 'v-add-database',
  2079.                 'arg1' => $owner,
  2080.                 'arg2' => $dbName,
  2081.                 'arg3' => $dbUser,
  2082.                 'arg4' => $dbPass,
  2083.                 'arg5' => 'mysql'
  2084.             ]);
  2085.             //dd($postFields);            
  2086.             $headers = [
  2087.                 'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  2088.             ];
  2091.             $ch = curl_init();
  2092.             curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  2093.             curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  2094.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2095.             curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2096.             curl_setopt($ch, CURLOPT_POST, true);
  2097.             curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  2098.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  2100.             $response = curl_exec($ch);
  2101.             $error = curl_error($ch);
  2102.             curl_close($ch);
  2104.             if ($error || trim($response) !== '0') {
  2105.                 $this->addFlash('danger', 'Error al crear la base de datos en HestiaCP: ' . ($error ?: $response));
  2106.                 return $this->redirectToRoute('app_empresa_new');
  2107.             }
  2109.             //Añadir sql
  2110.             $sqlFile = __DIR__ . '/../../db/db_base.sql'; // Ajusta la ruta si está en otro sitio
  2112.             if (!file_exists($sqlFile)) {
  2113.                 $this->addFlash('danger', 'Archivo db_base.sql no encontrado.');
  2114.                 return $this->redirectToRoute('app_empresa_new');
  2115.             }
  2118.             $mysqli = new \mysqli($dbHost, "{$owner}_{$dbUser}", $dbPass, "{$owner}_{$dbName}", (int)$dbPort);
  2120.             if ($mysqli->connect_error) {
  2121.                 $this->addFlash('danger', 'Error al conectar a la base de datos: ' . $mysqli->connect_error);
  2122.                 return $this->redirectToRoute('app_empresa_new');
  2123.             }
  2125.             $sql = file_get_contents($sqlFile);
  2127.             // Eliminar lĂ­neas con DELIMITER
  2128.             $sql = preg_replace('/DELIMITER\s+\$\$/', '', $sql);
  2129.             $sql = preg_replace('/DELIMITER\s+;/', '', $sql);
  2131.             // Separar por ';;' si los triggers usan ese delimitador (ajusta si es $$)
  2132.             $statements = explode('$$', $sql);
  2134.             foreach ($statements as $statementIndex => $stmt) {
  2135.                 $stmt = trim($stmt);
  2136.                 if ($stmt) {
  2137.                     try {
  2138.                         if (!$mysqli->multi_query($stmt)) {
  2139.                             $this->addFlash('danger', 'Error ejecutando SQL: ' . $mysqli->error);
  2140.                             return $this->redirectToRoute('app_empresa_new');
  2141.                         }
  2143.                         // Limpiar cualquier resultado intermedio del bloque ejecutado.
  2144.                         do {
  2145.                             if ($result = $mysqli->store_result()) {
  2146.                                 $result->free();
  2147.                             }
  2148.                         } while ($mysqli->more_results() && $mysqli->next_result());
  2149.                     } catch (\mysqli_sql_exception $e) {
  2150.                         $sqlSnippet = mb_substr(preg_replace('/\s+/', ' ', $stmt), 0, 220);
  2151.                         $this->addFlash(
  2152.                             'danger',
  2153.                             sprintf(
  2154.                                 'Error ejecutando SQL en bloque %d: %s. Sentencia: %s',
  2155.                                 $statementIndex + 1,
  2156.                                 $e->getMessage(),
  2157.                                 $sqlSnippet
  2158.                             )
  2159.                         );
  2160.                         return $this->redirectToRoute('app_empresa_new');
  2161.                     }
  2162.                 }
  2163.             }
  2165.             $updateSql = "UPDATE users SET email = '" . $mysqli->real_escape_string((string)$data["user"]) . "' WHERE id = 1";
  2167.             if (!$mysqli->query($updateSql)) {
  2168.                 $this->addFlash('danger', 'Error al actualizar usuario: ' . $mysqli->error);
  2169.                 return $this->redirectToRoute('app_empresa_new');
  2170.             }
  2172.             // Guardar parámetros (activeUsers + modulos_*) en la BD del cliente
  2173.             $localExtractionModelId = 0;
  2174.             if ($data['modulo_extraccion'] === 1) {
  2175.                 try {
  2176.                     if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  2177.                         $localExtractionModelId = $this->registerAoaiModelInClientDb(
  2178.                             $mysqli,
  2179.                             $azureResource ?? [],
  2180.                             $aoaiFields
  2181.                         );
  2182.                     } else {
  2183.                         $localExtractionModelId = $this->registerDiModelInClientDb(
  2184.                             $mysqli,
  2185.                             $azureResource ?? [],
  2186.                             $azureModelId
  2187.                         );
  2188.                     }
  2189.                 } catch (\Throwable $e) {
  2190.                     $this->addFlash('danger', 'No se pudo registrar el modelo en la BBDD cliente: ' . $e->getMessage());
  2191.                     $mysqli->close();
  2192.                     return $this->redirectToRoute('app_empresa_new');
  2193.                 }
  2194.             }
  2195.             $data['extraction_model'] = $localExtractionModelId;
  2197.             // SUBIR LOGO PERSONALIZADO (SI LO HAY) ===
  2198.             $customLogoFile = null;
  2199.             try {
  2200.                 $customLogoFile = $this->uploadEmpresaLogo($req);
  2201.             } catch (\Throwable $e) {
  2202.                 // Aquí decides si quieres que esto sea fatal o solo un aviso
  2203.                 $this->addFlash('warning', 'El logo personalizado no se pudo subir: ' . $e->getMessage());
  2204.                 // Si quieres abortar todo el proceso por fallo de logo, haz return+redirect aquí.
  2205.             }
  2207.             // Guardar logo en la BD del cliente
  2208.             $this->saveEmpresaLogo($mysqli, $data, $customLogoFile);
  2210.             // Actualizar/insertar license (capacityGb y users) en la BD del cliente
  2211.             $this->upsertLicense(
  2212.                 $mysqli,
  2213.                 $data,
  2214.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== '' ? (int)$data['maxDiskQuota'] : 200,
  2215.                 isset($data['maxActiveUsers']) && $data['maxActiveUsers'] !== '' ? (int)$data['maxActiveUsers'] : 3
  2216.             );
  2218.             // Guardar parametros (activeUsers + modulos_*) en la BD del cliente
  2219.             $this->saveEmpresaParametros($mysqli, $data);
  2220.             $this->licenseContractService->createInitialContract($mysqli, $data);
  2221.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  2222.                 try {
  2223.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  2224.                 } catch (\Throwable $e) {
  2225.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  2226.                 }
  2227.             }
  2229.             // Crear y persistir la empresa
  2230.             $emp = new Empresa();
  2231.             $emp->setName($data["name"]);
  2232.             $emp->setMaxDiskQuota((int)$data["maxDiskQuota"]);
  2233.             $emp->setMaxThreads($maxThreads);
  2237.             $em->persist($emp);
  2238.             $em->flush();
  2240.             $conexionBD = new ConexionBD();
  2241.             $conexionBD->setDbName($owner . "_" . $dbName);
  2242.             $conexionBD->setDbUser($owner . "_" . $dbUser);
  2243.             $conexionBD->setDbPassword($dbPass);
  2244.             $conexionBD->setDbUrl($dbHost);
  2245.             $conexionBD->setDbPort($dbPort);
  2246.             $em->persist($conexionBD);
  2247.             $em->flush();
  2250.             $emp->setConexionBD($conexionBD);
  2251.             $em->persist($emp);
  2252.             $em->flush();
  2254.             //crear usuario
  2255.             $user = new \App\Entity\Usuario();
  2256.             $user->setEmail($data["user"]);
  2257.             $user->setEmpresa($emp);
  2258.             $user->setPassword("dscsdcsno2234dwvw");
  2259.             $user->setStatus(1);
  2260.             $user->setIsAdmin(2);
  2261.             $user->setConnection($conexionBD->getId());
  2263.             $em->persist($user);
  2264.             $em->flush();
  2266.             //crear el script de bash
  2267.             $company_name = $emp->getId();
  2269.             // "DOCU_MAX_THREADS=" por defecto 4
  2270.             // "NO" al final es para desactivar FTP
  2272.             // Crear archivo .service
  2273.             $empresaName = (string)($data['name'] ?? '');
  2274.             $serviceContent = <<<EOT
  2275. [Unit]
  2276. Description={$empresaName} DocuManager OCR
  2277. Requires=mariadb.service
  2278. After=mariadb.service
  2280. [Service]
  2281. Type=simple
  2282. Environment="DOCU_MAX_THREADS=$maxThreads"
  2283. ExecStart=$ocrBinary localhost/{$owner}_{$dbName} {$owner}_{$dbUser} {$dbPass} {$filesPath}/{$company_name} NO
  2284. Restart=always
  2285. User=docunecta
  2287. [Install]
  2288. WantedBy=multi-user.target
  2289. EOT;
  2292.             // Guardar contenido temporal en un archivo dentro de /tmp
  2293.             $serviceName = $company_name . "-documanager.service";
  2294.             $tmpServicePath = "/tmp/$serviceName";
  2295.             file_put_contents($tmpServicePath, $serviceContent);
  2296.             \chmod($tmpServicePath, 0644);
  2298.             // Mover el archivo y habilitar el servicio desde PHP con shell_exec
  2299.             $commands = [
  2300.                 "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  2301.                 "sudo /bin/systemctl daemon-reload",
  2302.                 "sudo /bin/systemctl enable $serviceName",
  2303.                 "sudo /bin/systemctl start $serviceName",
  2304.             ];
  2305.             $errors = [];
  2306.             foreach ($commands as $cmd) {
  2307.                 $output = \shell_exec($cmd . " 2>&1");
  2308.                 if ($output !== null) {
  2309.                     // Puedes loguearlo si quieres para ver errores
  2310.                     error_log("CMD OUTPUT: $cmd\n$output");
  2311.                     $errors[] = "CMD OUTPUT: $cmd\n$output";
  2312.                 }
  2313.             }
  2315.             // === Crear servicio AZURE DI por tenant ===
  2316.             $azureBasePort = 12000;
  2317.             $tenantId      = (int)$emp->getId();
  2318.             $port          = $this->azurePortForTenant($tenantId, $azureBasePort, 20999);
  2319.             $serviceName   = $tenantId . "-azuredi.service";
  2320.             $workdir       = $this->azureDiWorkdirFromEnv();
  2321.             $docuPhpBaseUrl = $this->azureDiPhpBaseUrl($req);
  2322.             if ($workdir !== '' && $docuPhpBaseUrl !== '') {
  2323.                 $logsDir = $workdir . "/logs/" . $tenantId;
  2325.                 // Asegura carpeta de logs
  2326.                 @mkdir($logsDir, 0775, true);
  2328.                 $serviceContent = <<<EOT
  2329. [Unit]
  2330. Description=DocuManager Azure DI {$tenantId}
  2331. After=network.target
  2333. [Service]
  2334. User=root
  2335. WorkingDirectory={$workdir}
  2337. Environment=APP_HOST=127.0.0.1
  2338. Environment=APP_PORT={$port}
  2339. Environment=LOG_DIR={$logsDir}
  2340. Environment=PYTHONUNBUFFERED=1
  2341. Environment=MAX_CONCURRENT=20
  2342. Environment="PATH=/opt/azure-di/.venv/bin:/usr/local/bin:/usr/bin"
  2343. EnvironmentFile=-{$workdir}/.env
  2345. # ---- Scheduler interno de extracción ----
  2346. Environment=EXTRACT_TICK_ENABLED=1
  2347. Environment=EXTRACT_TICK_INTERVAL_SEC=10
  2348. Environment=DOCU_TENANT_ID={$tenantId}
  2349. Environment=EXTRACT_TICK_LIMIT=30
  2350. Environment=EXTRACT_TICK_TIMEOUT_SEC=25
  2351. Environment=EXTRACT_TICK_LOCK_FILE=/tmp/azure_di_extract_tick_{$tenantId}.lock
  2353. # Ajustar URL base pública/interna de PHP
  2354. Environment=DOCU_PHP_BASE_URL={$docuPhpBaseUrl}
  2356. # Debe coincidir con EXTRACT_INTERNAL_TOKEN del lado PHP
  2357. Environment=EXTRACT_INTERNAL_TOKEN=8c7e7a1b4d0f6e2a9c1d3f5b7a8e0c2d4f6a1b3c5d7e9f0a2c4e6b8d0f1a3c5
  2359. ExecStart=/opt/azure-di/.venv/bin/python -m uvicorn app.main:app --host 127.0.0.1 --port {$port} --proxy-headers --workers 2
  2361. Restart=always
  2362. RestartSec=2
  2363. StandardOutput=journal
  2364. StandardError=journal
  2366. [Install]
  2367. WantedBy=multi-user.target
  2368. EOT;
  2370.                 $tmpServicePath = "/tmp/{$serviceName}";
  2371.                 file_put_contents($tmpServicePath, $serviceContent);
  2372.                 @chmod($tmpServicePath, 0644);
  2374.                 $cmds = [
  2375.                     "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  2376.                     "sudo /bin/systemctl daemon-reload",
  2377.                     "sudo /bin/systemctl enable {$serviceName}",
  2378.                     "sudo /bin/systemctl start {$serviceName}",
  2379.                 ];
  2380.                 foreach ($cmds as $cmd) {
  2381.                     $out = \shell_exec($cmd . " 2>&1");
  2382.                     if ($out !== null) {
  2383.                         error_log("AZURE-DI CMD: $cmd\n$out");
  2384.                     }
  2385.                 }
  2386.             } else {
  2387.                 $missing = [];
  2388.                 if ($workdir === '') $missing[] = 'AZURE_DI_WORKDIR';
  2389.                 if ($docuPhpBaseUrl === '') $missing[] = 'AZURE_DI_DOCU_PHP_BASE_URL';
  2390.                 $this->addFlash('warning', 'No se pudo crear el servicio de extraccion IA: faltan variables de entorno: ' . implode(', ', $missing));
  2391.             }
  2393.             // === Crear servicio/timer Mail Monitor si el modulo esta activo ===
  2394.             if ($mailMonitorEnabled) {
  2395.                 $this->ensureMailMonitorService(
  2396.                     (int)$company_name,
  2397.                     (string)$dbHost,
  2398.                     (string)$dbPort,
  2399.                     (string)$owner . "_" . (string)$dbUser,
  2400.                     (string)$dbPass,
  2401.                     (string)$owner . "_" . (string)$dbName,
  2402.                     (string)$filesPath
  2403.                 );
  2404.             }
  2406.             if (count($errors) > 0) {
  2407.                 $this->addFlash('success', 'Empresa y base de datos creadas correctamente: ' . implode(" | ", $errors));
  2408.             }
  2412.             $this->addFlash('success', 'Empresa y base de datos creadas correctamente.');
  2413.             return $this->redirectToRoute('list');
  2414.         } else {
  2415.             // Carga recursos IA para el formulario de alta
  2416.             return $this->render('empresa/_add.html.twig', [
  2417.                 'azure_resources' => $azureResources,
  2418.                 'azure_di_resources' => $azureDiResources,
  2419.                 'azure_openai_resources' => $azureOpenAiResources,
  2420.                 'modulos' => [
  2421.                     'extraction_model' => 0,
  2422.                 ],
  2423.                 'form_data' => [
  2424.                     'extractor_type' => self::EXTRACTOR_TYPE_AZURE_DI,
  2425.                     'ocr_mode' => 'base',
  2426.                     'license_type' => 'page',
  2427.                     'license_mode' => 'monthly',
  2428.                     'license_limit_mode' => 'block',
  2429.                     'license_start_date' => date('Y-m-d'),
  2430.                     'license_units_total' => 1000,
  2431.                 ],
  2432.                 'activeLicenseContract' => $this->licenseContractService->defaultContract(),
  2433.                 'aoai_fields' => [],
  2434.                 'ocr_plus_available' => $ocrPlusAvailable,
  2435.                 'ocr_v2_available' => $ocrV2Available,
  2436.             ]);
  2437.         }
  2438.     }
  2440.     private function saveEmpresaParametros(\mysqli $mysqli, array $data): void
  2441.     {
  2442.         // Helpers
  2443.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  2444.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  2446.         // Keys y valores tal y como quieres guardarlos
  2447.         $paramMap = [
  2448.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  2450.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  2452.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  2453.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  2454.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  2455.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  2456.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  2457.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  2458.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  2459.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  2460.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  2461.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  2462.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  2463.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  2464.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  2466.             'extraction_model'  => $getInt($data, 'extraction_model', 0),
  2467.             'ocr_mode'          => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  2468.             'tokensContratados' => max(0, $getInt($data, 'tokensContratados', 0)),
  2469.         ];
  2471.         if ($paramMap['modulo_extraccion'] === 0) {
  2472.             $paramMap['modulo_expowin'] = 0;
  2473.             $paramMap['modulo_prinex'] = 0;
  2474.         }
  2476.         // RECOMENDADO en tu SQL base:
  2477.         // ALTER TABLE parametros ADD UNIQUE KEY uniq_nombre (nombre);
  2478.         $mysqli->begin_transaction();
  2479.         try {
  2480.             $stmt = $mysqli->prepare("
  2481.                 INSERT INTO parametros (nombre, valor)
  2482.                 VALUES (?, ?)
  2483.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2484.             ");
  2485.             if (!$stmt) {
  2486.                 throw new \RuntimeException('Prepare parametros: ' . $mysqli->error);
  2487.             }
  2489.             foreach ($paramMap as $nombre => $valor) {
  2490.                 // valor es TEXT en tu esquema: bindeamos como string
  2491.                 $v = (string)$valor;
  2492.                 $stmt->bind_param('ss', $nombre, $v);
  2493.                 if (!$stmt->execute()) {
  2494.                     throw new \RuntimeException("Guardar parámetro $nombre: " . $stmt->error);
  2495.                 }
  2496.             }
  2498.             $stmt->close();
  2499.             $mysqli->commit();
  2500.         } catch (\Throwable $e) {
  2501.             $mysqli->rollback();
  2503.             // Si NO puedes ańadir UNIQUE(nombre), usa fallback DELETE+INSERT:
  2504.             // $this->saveParametrosFallback($mysqli, $paramMap);
  2506.             throw $e;
  2507.         }
  2508.     }
  2510.     private function applyGstockAutoMappings(\mysqli $mysqli, int $modelId): void
  2511.     {
  2512.         if ($modelId <= 0) {
  2513.             return;
  2514.         }
  2516.         $available = [
  2517.             'header' => [],
  2518.             'line' => [],
  2519.         ];
  2521.         $stmtHeader = $mysqli->prepare('SELECT field_key FROM definitions_header WHERE model_id = ?');
  2522.         if (!$stmtHeader) {
  2523.             throw new \RuntimeException('Prepare SELECT definitions_header para automapeo Gstock: ' . $mysqli->error);
  2524.         }
  2525.         $stmtHeader->bind_param('i', $modelId);
  2526.         if (!$stmtHeader->execute()) {
  2527.             $stmtHeader->close();
  2528.             throw new \RuntimeException('Execute SELECT definitions_header para automapeo Gstock: ' . $stmtHeader->error);
  2529.         }
  2530.         $resHeader = $stmtHeader->get_result();
  2531.         while ($resHeader && ($row = $resHeader->fetch_assoc())) {
  2532.             $fieldKey = (string)($row['field_key'] ?? '');
  2533.             if ($fieldKey !== '') {
  2534.                 $available['header'][$fieldKey] = true;
  2535.             }
  2536.         }
  2537.         $stmtHeader->close();
  2539.         $stmtLines = $mysqli->prepare('SELECT field_key FROM definitions_lines WHERE model_id = ?');
  2540.         if (!$stmtLines) {
  2541.             throw new \RuntimeException('Prepare SELECT definitions_lines para automapeo Gstock: ' . $mysqli->error);
  2542.         }
  2543.         $stmtLines->bind_param('i', $modelId);
  2544.         if (!$stmtLines->execute()) {
  2545.             $stmtLines->close();
  2546.             throw new \RuntimeException('Execute SELECT definitions_lines para automapeo Gstock: ' . $stmtLines->error);
  2547.         }
  2548.         $resLines = $stmtLines->get_result();
  2549.         while ($resLines && ($row = $resLines->fetch_assoc())) {
  2550.             $fieldKey = (string)($row['field_key'] ?? '');
  2551.             if ($fieldKey !== '') {
  2552.                 $available['line'][$fieldKey] = true;
  2553.             }
  2554.         }
  2555.         $stmtLines->close();
  2557.         $existing = [];
  2558.         $stmtExisting = $mysqli->prepare('SELECT type, source, destination FROM gstock_mapping WHERE model_id = ?');
  2559.         if (!$stmtExisting) {
  2560.             throw new \RuntimeException('Prepare SELECT gstock_mapping para automapeo: ' . $mysqli->error);
  2561.         }
  2562.         $stmtExisting->bind_param('i', $modelId);
  2563.         if (!$stmtExisting->execute()) {
  2564.             $stmtExisting->close();
  2565.             throw new \RuntimeException('Execute SELECT gstock_mapping para automapeo: ' . $stmtExisting->error);
  2566.         }
  2567.         $resExisting = $stmtExisting->get_result();
  2568.         while ($resExisting && ($row = $resExisting->fetch_assoc())) {
  2569.             $type = (string)($row['type'] ?? '');
  2570.             $source = (string)($row['source'] ?? '');
  2571.             $destination = (string)($row['destination'] ?? '');
  2572.             if ($type !== '' && $source !== '' && $destination !== '') {
  2573.                 $existing[$type . '|' . $source . '|' . $destination] = true;
  2574.             }
  2575.         }
  2576.         $stmtExisting->close();
  2578.         $mysqli->begin_transaction();
  2579.         try {
  2580.             $stmtInsert = $mysqli->prepare(
  2581.                 'INSERT INTO gstock_mapping (model_id, type, source, destination) VALUES (?, ?, ?, ?)'
  2582.             );
  2583.             if (!$stmtInsert) {
  2584.                 throw new \RuntimeException('Prepare INSERT gstock_mapping para automapeo: ' . $mysqli->error);
  2585.             }
  2587.             foreach (GstockAutoMappings::MAPPINGS as $type => $pairs) {
  2588.                 foreach ($pairs as $pair) {
  2589.                     $source = (string)($pair['source'] ?? '');
  2590.                     $destination = (string)($pair['destination'] ?? '');
  2591.                     if ($source === '' || $destination === '') {
  2592.                         continue;
  2593.                     }
  2594.                     if ($type === 'header' && !isset($available['header'][$source])) {
  2595.                         continue;
  2596.                     }
  2597.                     if ($type === 'line' && !isset($available['line'][$source])) {
  2598.                         continue;
  2599.                     }
  2600.                     $key = $type . '|' . $source . '|' . $destination;
  2601.                     if (isset($existing[$key])) {
  2602.                         continue;
  2603.                     }
  2604.                     $stmtInsert->bind_param('isss', $modelId, $type, $source, $destination);
  2605.                     if (!$stmtInsert->execute()) {
  2606.                         $stmtInsert->close();
  2607.                         throw new \RuntimeException('Execute INSERT gstock_mapping para automapeo: ' . $stmtInsert->error);
  2608.                     }
  2609.                     $existing[$key] = true;
  2610.                 }
  2611.             }
  2613.             $stmtInsert->close();
  2614.             $mysqli->commit();
  2615.         } catch (\Throwable $e) {
  2616.             $mysqli->rollback();
  2617.             throw $e;
  2618.         }
  2619.     }
  2621.     private function saveEmpresaLogo(\mysqli $mysqli, array $data, ?string $customLogoFile = null): void
  2622.     {
  2623.         $this->logLogo('empresa_logo_save.log', '--- NUEVA LLAMADA saveEmpresaLogo ---');
  2624.         $this->logLogo('empresa_logo_save.log', 'customLogoFile = ' . var_export($customLogoFile, true));
  2625.         $this->logLogo('empresa_logo_save.log', 'data[empresa_vendor] = ' . var_export($data['empresa_vendor'] ?? null, true));
  2627.         // 1) Decidir qué logo vamos a guardar
  2628.         $logoFile = null;
  2630.         // --- PRIORIDAD: LOGO PERSONALIZADO ---
  2631.         if ($customLogoFile !== null && $customLogoFile !== '') {
  2632.             $logoFile = $customLogoFile;
  2633.             $this->logLogo('empresa_logo_save.log', 'Usando logo personalizado: ' . $logoFile);
  2634.         } else {
  2635.             // --- SI NO HAY PERSONALIZADO, USAMOS EL SELECT DE EMPRESA ---
  2636.             if (!isset($data['empresa_vendor']) || $data['empresa_vendor'] === '') {
  2637.                 $this->logLogo('empresa_logo_save.log', 'No hay empresa_vendor y no hay logo custom. No hago nada.');
  2638.                 return;
  2639.             }
  2641.             $empresa = $data['empresa_vendor'];
  2642.             $empresaKey = strtolower(trim((string)$empresa));
  2644.             $logoMap = [
  2645.                 'docunecta'  => 'DocuManager_transparente.png',
  2646.                 'docuindexa' => 'DocuIndexa.png',
  2647.             ];
  2648.             $vendorLabelMap = [
  2649.                 'docunecta'  => 'Docunecta',
  2650.                 'docuindexa' => 'Docuindexa',
  2651.             ];
  2653.             if (!isset($logoMap[$empresaKey])) {
  2654.                 $this->logLogo('empresa_logo_save.log', "empresa_vendor $empresa no está en logoMap. No hago nada.");
  2655.                 return;
  2656.             }
  2658.             $logoFile = $logoMap[$empresaKey];
  2659.             $vendorLabel = $vendorLabelMap[$empresaKey] ?? null;
  2660.             $this->logLogo('empresa_logo_save.log', 'Usando logo por vendor: ' . $logoFile);
  2661.         }
  2663.         if ($logoFile === null || $logoFile === '') {
  2664.             $this->logLogo('empresa_logo_save.log', 'logoFile está vacío. No hago nada.');
  2665.             return;
  2666.         }
  2668.         $this->logLogo('empresa_logo_save.log', 'Voy a guardar en parametros.logo: ' . $logoFile);
  2670.         $mysqli->begin_transaction();
  2672.         try {
  2673.             $stmt = $mysqli->prepare("
  2674.                 INSERT INTO parametros (nombre, valor)
  2675.                 VALUES (?, ?)
  2676.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2677.             ");
  2679.             if (!$stmt) {
  2680.                 $this->logLogo('empresa_logo_save.log', 'Error prepare: ' . $mysqli->error);
  2681.                 throw new \RuntimeException('Prepare logo: ' . $mysqli->error);
  2682.             }
  2684.             $paramName = 'logo';
  2685.             $stmt->bind_param('ss', $paramName, $logoFile);
  2687.             if (!$stmt->execute()) {
  2688.                 $this->logLogo('empresa_logo_save.log', 'Error execute: ' . $stmt->error);
  2689.                 throw new \RuntimeException('Guardar parámetro logo: ' . $stmt->error);
  2690.             }
  2692.             if (isset($vendorLabel) && $vendorLabel !== '') {
  2693.                 $paramName = 'vendor';
  2694.                 $stmt->bind_param('ss', $paramName, $vendorLabel);
  2695.                 if (!$stmt->execute()) {
  2696.                     $this->logLogo('empresa_logo_save.log', 'Error execute vendor: ' . $stmt->error);
  2697.                     throw new \RuntimeException('Guardar parámetro vendor: ' . $stmt->error);
  2698.                 }
  2699.             }
  2701.             $stmt->close();
  2702.             $mysqli->commit();
  2703.             $this->logLogo('empresa_logo_save.log', 'Logo guardado correctamente en BD.');
  2704.         } catch (\Throwable $e) {
  2705.             $mysqli->rollback();
  2706.             $this->logLogo('empresa_logo_save.log', 'EXCEPCIÓN: ' . $e->getMessage());
  2707.             throw $e;
  2708.         }
  2709.     }
  2711.     private function uploadEmpresaLogo(Request $req): ?string
  2712.     {
  2713.         $this->logLogo('empresa_logo_upload.log', '--- NUEVA LLAMADA uploadEmpresaLogo ---');
  2715.         // name del checkbox en el formulario (ajústalo si usas otro)
  2716.         $useCustomLogo = $req->request->get('customLogoCheck');
  2717.         $this->logLogo('empresa_logo_upload.log', 'customLogoCheck = ' . var_export($useCustomLogo, true));
  2719.         // Si no marcaron "usar logo personalizado", no hacemos nada
  2720.         if (!$useCustomLogo) {
  2721.             $this->logLogo('empresa_logo_upload.log', 'No se ha marcado customLogoCheck. Salgo sin subir.');
  2722.             return null;
  2723.         }
  2725.         /** @var UploadedFile|null $file */
  2726.         $file = $req->files->get('logo_personalizado'); // name="logo_personalizado" en el input file
  2727.         $this->logLogo('empresa_logo_upload.log', 'FILES[logo_personalizado] = ' . print_r($file, true));
  2729.         if (!$file instanceof UploadedFile || !$file->isValid()) {
  2730.             $this->logLogo('empresa_logo_upload.log', 'File no es UploadedFile válido. Salgo sin subir.');
  2731.             return null;
  2732.         }
  2734.         // VALIDACIONES BÁSICAS
  2735.         $maxSize = 2 * 1024 * 1024; // 2 MB por ejemplo
  2736.         if ($file->getSize() > $maxSize) {
  2737.             $this->logLogo('empresa_logo_upload.log', 'Tamańo demasiado grande: ' . $file->getSize());
  2738.             throw new \RuntimeException('El logo personalizado es demasiado grande (máx 2MB).');
  2739.         }
  2741.         $mime = $file->getMimeType();
  2742.         $allowedMimeTypes = ['image/png', 'image/jpeg', 'image/webp', 'image/svg+xml'];
  2743.         $this->logLogo('empresa_logo_upload.log', 'MIME = ' . $mime);
  2745.         if (!in_array($mime, $allowedMimeTypes, true)) {
  2746.             $this->logLogo('empresa_logo_upload.log', 'MIME no permitido.');
  2747.             throw new \RuntimeException('Formato de logo no permitido. Usa PNG, JPG, WEBP o SVG.');
  2748.         }
  2750.         // Directorio destino según entorno (configurado en .env/.env.local)
  2751.         $targetDir = $_ENV['APP_LOGO_DIR'] ?? null;
  2752.         $this->logLogo('empresa_logo_upload.log', 'APP_LOGO_DIR = ' . var_export($targetDir, true));
  2754.         if (!$targetDir) {
  2755.             throw new \RuntimeException('APP_LOGO_DIR no está configurado en el entorno.');
  2756.         }
  2757.         if (!is_dir($targetDir)) {
  2758.             $this->logLogo('empresa_logo_upload.log', "El directorio no existe: $targetDir");
  2759.             throw new \RuntimeException("El directorio de logos no existe: $targetDir");
  2760.         }
  2761.         if (!is_writable($targetDir)) {
  2762.             $this->logLogo('empresa_logo_upload.log', "El directorio no es escribible: $targetDir");
  2763.             throw new \RuntimeException("El directorio de logos no es escribible: $targetDir");
  2764.         }
  2766.         // Nombre de archivo "seguro" y único
  2767.         $ext = $file->guessExtension() ?: 'png';
  2768.         $fileName = 'logo_empresa_' . bin2hex(random_bytes(6)) . '.' . $ext;
  2769.         $this->logLogo('empresa_logo_upload.log', "Voy a mover archivo como: $fileName");
  2771.         // Mover físicamente el archivo
  2772.         $file->move($targetDir, $fileName);
  2773.         $this->logLogo('empresa_logo_upload.log', "Fichero movido OK a $targetDir/$fileName");
  2775.         // Devolvemos SOLO el nombre, que es lo que se guardará en parametros.logo
  2776.         return $fileName;
  2777.     }
  2779.     private function logLogo(string $fileName, string $message): void
  2780.     {
  2781.         // Directorio de logs de Symfony (donde está dev.log/prod.log)
  2782.         $logDir = $this->getParameter('kernel.logs_dir');
  2784.         $fullPath = rtrim($logDir, '/') . '/' . $fileName;
  2786.         $line = sprintf(
  2787.             "[%s] %s\n",
  2788.             date('Y-m-d H:i:s'),
  2789.             $message
  2790.         );
  2792.         file_put_contents($fullPath, $line, FILE_APPEND);
  2793.     }
  2795.     private function loadEmpresaLogo(\mysqli $mysqli): ?string
  2796.     {
  2797.         $sql = "SELECT valor FROM parametros WHERE nombre = 'logo' LIMIT 1";
  2798.         $res = $mysqli->query($sql);
  2799.         if (!$res) {
  2800.             return null;
  2801.         }
  2802.         if ($row = $res->fetch_assoc()) {
  2803.             return $row['valor'] ?? null;
  2804.         }
  2805.         return null;
  2806.     }
  2808.     private function upsertLicense(\mysqli $mysqli, array $data, int $capacityGb = 200, int $activeUsers = 3): void
  2809.     {
  2810.         $clientName = (string)($data['name'] ?? '');
  2811.         $licenseStr  = 'Documanager';
  2812.         $initialDate = date('Y-m-d');
  2813.         $price       = 0;
  2814.         $emailSender = 'Documanager.es';
  2815.         $emailFrom   = 'no-reply@docunecta.com';
  2816.         $emailName   = 'Documanager';
  2817.         $ins = $mysqli->prepare("
  2818.             INSERT INTO license
  2819.                 (client, license, initialDate, capacityGb, users, price, emailSender, emailFrom, emailName)
  2820.             VALUES
  2821.                 (?,      ?,       ?,          ?,          ?,     ?,     ?,           ?,         ?)
  2822.         ");
  2823.         if (!$ins) {
  2824.             throw new \RuntimeException('Prepare INSERT license: ' . $mysqli->error);
  2825.         }
  2826.         $ins->bind_param(
  2827.             'sssiiisss',
  2828.             $clientName,
  2829.             $licenseStr,
  2830.             $initialDate,
  2831.             $capacityGb,
  2832.             $activeUsers,
  2833.             $price,
  2834.             $emailSender,
  2835.             $emailFrom,
  2836.             $emailName
  2837.         );
  2838.         if (!$ins->execute()) {
  2839.             $ins->close();
  2840.             throw new \RuntimeException('Execute INSERT license: ' . $ins->error);
  2841.         }
  2842.         $ins->close();
  2843.     }
  2845.     private function mapAzureSchemaToDefinitions(array $modelDetail): array
  2846.     {
  2847.         $docTypes = $modelDetail['docTypes'] ?? [];
  2848.         if (!is_array($docTypes) || $docTypes === []) {
  2849.             return ['header' => [], 'lines' => []];
  2850.         }
  2852.         $modelId = (string)($modelDetail['modelId'] ?? '');
  2853.         $docTypeKey = ($modelId !== '' && array_key_exists($modelId, $docTypes))
  2854.             ? $modelId
  2855.             : array_key_first($docTypes);
  2857.         if (!is_string($docTypeKey) || !isset($docTypes[$docTypeKey]) || !is_array($docTypes[$docTypeKey])) {
  2858.             return ['header' => [], 'lines' => []];
  2859.         }
  2861.         $fieldSchema = $docTypes[$docTypeKey]['fieldSchema'] ?? [];
  2862.         if (!is_array($fieldSchema)) {
  2863.             return ['header' => [], 'lines' => []];
  2864.         }
  2866.         $rawHeader = [];
  2867.         $rawLines = [];
  2868.         foreach ($fieldSchema as $fieldKey => $fieldDef) {
  2869.             if (!is_string($fieldKey) || !is_array($fieldDef)) {
  2870.                 continue;
  2871.             }
  2872.             $this->flattenFieldSchema($fieldKey, $fieldDef, $rawHeader, $rawLines);
  2873.         }
  2875.         $header = [];
  2876.         $lines = [];
  2877.         $seenHeader = [];
  2878.         $seenLines = [];
  2880.         foreach ($rawHeader as $item) {
  2881.             $key = (string)($item['field_key'] ?? '');
  2882.             if ($key === '' || isset($seenHeader[$key])) {
  2883.                 continue;
  2884.             }
  2885.             $seenHeader[$key] = true;
  2886.             $header[] = [
  2887.                 'field_key' => $key,
  2888.                 'label' => $key,
  2889.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2890.             ];
  2891.         }
  2893.         foreach ($rawLines as $item) {
  2894.             $key = (string)($item['field_key'] ?? '');
  2895.             if ($key === '' || isset($seenLines[$key])) {
  2896.                 continue;
  2897.             }
  2898.             $seenLines[$key] = true;
  2899.             $lines[] = [
  2900.                 'field_key' => $key,
  2901.                 'label' => $key,
  2902.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2903.             ];
  2904.         }
  2906.         foreach ($header as $index => &$item) {
  2907.             $order = $index + 1;
  2908.             $item['order_index'] = $order;
  2909.             $item['order_index_table'] = $order;
  2910.             $item['visibility'] = 1;
  2911.             $item['visibility_table'] = 1;
  2912.         }
  2914.         foreach ($lines as $index => &$item) {
  2915.             $item['order_index'] = $index + 1;
  2916.             $item['visibility'] = 1;
  2917.         }
  2919.         return ['header' => $header, 'lines' => $lines];
  2920.     }
  2922.     private function flattenFieldSchema(
  2923.         string $fieldKey,
  2924.         array $fieldDef,
  2925.         array &$header,
  2926.         array &$lines,
  2927.         bool $insideItems = false,
  2928.         string $parentPath = ''
  2929.     ): void {
  2930.         $type = strtolower((string)($fieldDef['type'] ?? 'string'));
  2931.         $currentPath = $parentPath !== '' ? $parentPath . '.' . $fieldKey : $fieldKey;
  2933.         if ($insideItems) {
  2934.             if ($type === 'object') {
  2935.                 $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  2936.                 if (is_array($properties)) {
  2937.                     foreach ($properties as $childKey => $childDef) {
  2938.                         if (is_string($childKey) && is_array($childDef)) {
  2939.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $currentPath);
  2940.                         }
  2941.                     }
  2942.                 }
  2943.                 return;
  2944.             }
  2946.             if ($type === 'array') {
  2947.                 $itemsDef = $fieldDef['items'] ?? [];
  2948.                 $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  2949.                 if ($itemType === 'object') {
  2950.                     $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  2951.                     if (is_array($properties)) {
  2952.                         $arrayPath = $currentPath . '[*]';
  2953.                         foreach ($properties as $childKey => $childDef) {
  2954.                             if (is_string($childKey) && is_array($childDef)) {
  2955.                                 $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $arrayPath);
  2956.                             }
  2957.                         }
  2958.                     }
  2959.                 } else {
  2960.                     $lines[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  2961.                 }
  2962.                 return;
  2963.             }
  2965.             $lines[] = ['field_key' => $currentPath, 'azure_type' => $type];
  2966.             return;
  2967.         }
  2969.         if ($type === 'object') {
  2970.             $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  2971.             if (is_array($properties)) {
  2972.                 foreach ($properties as $childKey => $childDef) {
  2973.                     if (is_string($childKey) && is_array($childDef)) {
  2974.                         $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $currentPath);
  2975.                     }
  2976.                 }
  2977.             }
  2978.             return;
  2979.         }
  2981.         if ($type === 'array') {
  2982.             $itemsDef = $fieldDef['items'] ?? [];
  2983.             $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  2984.             $isItems = strtolower($fieldKey) === 'items';
  2986.             if ($itemType === 'object') {
  2987.                 $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  2988.                 if (!is_array($properties)) {
  2989.                     return;
  2990.                 }
  2992.                 if ($isItems) {
  2993.                     foreach ($properties as $childKey => $childDef) {
  2994.                         if (is_string($childKey) && is_array($childDef)) {
  2995.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, '');
  2996.                         }
  2997.                     }
  2998.                 } else {
  2999.                     $arrayPath = $currentPath . '[*]';
  3000.                     foreach ($properties as $childKey => $childDef) {
  3001.                         if (is_string($childKey) && is_array($childDef)) {
  3002.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $arrayPath);
  3003.                         }
  3004.                     }
  3005.                 }
  3006.                 return;
  3007.             }
  3009.             $header[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  3010.             return;
  3011.         }
  3013.         $header[] = ['field_key' => $currentPath, 'azure_type' => $type];
  3014.     }
  3016.     private function mapAzureTypeToValueType(string $azureType): string
  3017.     {
  3018.         $azureType = strtolower(trim($azureType));
  3019.         if ($azureType === 'date') {
  3020.             return 'date';
  3021.         }
  3022.         if ($azureType === 'number' || $azureType === 'integer') {
  3023.             return 'number';
  3024.         }
  3025.         return 'string';
  3026.     }
  3028.     private function registerDiModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  3029.     {
  3030.         $modelId = trim($modelId);
  3031.         if ($modelId === '') {
  3032.             throw new \RuntimeException('ModelId de recurso IA obligatorio.', 400);
  3033.         }
  3035.         $modelDetail = $this->azureRequest(
  3036.             (string)($resource['endpoint'] ?? ''),
  3037.             (string)($resource['api_key'] ?? ''),
  3038.             '/documentintelligence/documentModels/' . rawurlencode($modelId)
  3039.         );
  3040.         $type = $this->classifyModelType($modelDetail);
  3041.         $definitions = $this->mapAzureSchemaToDefinitions($modelDetail);
  3043.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  3044.         $apiKey = (string)($resource['api_key'] ?? '');
  3045.         $showConfidenceBadges = 0;
  3047.         $clientMysqli->begin_transaction();
  3048.         try {
  3049.             $existingId = 0;
  3050.             $stmtSelect = $clientMysqli->prepare(
  3051.                 "SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? LIMIT 1"
  3052.             );
  3053.             if (!$stmtSelect) {
  3054.                 throw new \RuntimeException('Prepare SELECT extraction_models: ' . $clientMysqli->error);
  3055.             }
  3056.             $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  3057.             $stmtSelect->bind_param('ss', $provider, $modelId);
  3058.             if (!$stmtSelect->execute()) {
  3059.                 $stmtSelect->close();
  3060.                 throw new \RuntimeException('Execute SELECT extraction_models: ' . $stmtSelect->error);
  3061.             }
  3062.             $result = $stmtSelect->get_result();
  3063.             if ($result && ($row = $result->fetch_assoc())) {
  3064.                 $existingId = (int)$row['id'];
  3065.             }
  3066.             $stmtSelect->close();
  3068.             if ($existingId > 0) {
  3069.                 $stmtUpdate = $clientMysqli->prepare(
  3070.                     'UPDATE extraction_models
  3071.                      SET endpoint = ?, api_key = ?, type = ?, show_confidence_badges = ?
  3072.                      WHERE id = ?'
  3073.                 );
  3074.                 if (!$stmtUpdate) {
  3075.                     throw new \RuntimeException('Prepare UPDATE extraction_models: ' . $clientMysqli->error);
  3076.                 }
  3077.                 $stmtUpdate->bind_param('sssii', $endpoint, $apiKey, $type, $showConfidenceBadges, $existingId);
  3078.                 if (!$stmtUpdate->execute()) {
  3079.                     $stmtUpdate->close();
  3080.                     throw new \RuntimeException('Execute UPDATE extraction_models: ' . $stmtUpdate->error);
  3081.                 }
  3082.                 $stmtUpdate->close();
  3083.                 $localModelId = $existingId;
  3084.             } else {
  3085.                 $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  3086.                 $stmtInsert = $clientMysqli->prepare(
  3087.                     'INSERT INTO extraction_models (provider, model_id, endpoint, api_key, type, show_confidence_badges)
  3088.                      VALUES (?, ?, ?, ?, ?, ?)'
  3089.                 );
  3090.                 if (!$stmtInsert) {
  3091.                     throw new \RuntimeException('Prepare INSERT extraction_models: ' . $clientMysqli->error);
  3092.                 }
  3093.                 $stmtInsert->bind_param('sssssi', $provider, $modelId, $endpoint, $apiKey, $type, $showConfidenceBadges);
  3094.                 if (!$stmtInsert->execute()) {
  3095.                     $stmtInsert->close();
  3096.                     throw new \RuntimeException('Execute INSERT extraction_models: ' . $stmtInsert->error);
  3097.                 }
  3098.                 $localModelId = (int)$stmtInsert->insert_id;
  3099.                 $stmtInsert->close();
  3100.             }
  3102.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  3103.             if (!$stmtDelHeader) {
  3104.                 throw new \RuntimeException('Prepare DELETE definitions_header: ' . $clientMysqli->error);
  3105.             }
  3106.             $stmtDelHeader->bind_param('i', $localModelId);
  3107.             if (!$stmtDelHeader->execute()) {
  3108.                 $stmtDelHeader->close();
  3109.                 throw new \RuntimeException('Execute DELETE definitions_header: ' . $stmtDelHeader->error);
  3110.             }
  3111.             $stmtDelHeader->close();
  3113.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  3114.             if (!$stmtDelLines) {
  3115.                 throw new \RuntimeException('Prepare DELETE definitions_lines: ' . $clientMysqli->error);
  3116.             }
  3117.             $stmtDelLines->bind_param('i', $localModelId);
  3118.             if (!$stmtDelLines->execute()) {
  3119.                 $stmtDelLines->close();
  3120.                 throw new \RuntimeException('Execute DELETE definitions_lines: ' . $stmtDelLines->error);
  3121.             }
  3122.             $stmtDelLines->close();
  3124.             if (!empty($definitions['header'])) {
  3125.                 $stmtHeader = $clientMysqli->prepare(
  3126.                     'INSERT INTO definitions_header
  3127.                     (model_id, field_key, label, value_type, order_index, visibility, order_index_table, visibility_table)
  3128.                     VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  3129.                 );
  3130.                 if (!$stmtHeader) {
  3131.                     throw new \RuntimeException('Prepare INSERT definitions_header: ' . $clientMysqli->error);
  3132.                 }
  3133.                 foreach ($definitions['header'] as $item) {
  3134.                     $fieldKey = (string)$item['field_key'];
  3135.                     $label = (string)$item['label'];
  3136.                     $valueType = (string)$item['value_type'];
  3137.                     $orderIndex = (int)$item['order_index'];
  3138.                     $visibility = (int)$item['visibility'];
  3139.                     $orderIndexTable = (int)$item['order_index_table'];
  3140.                     $visibilityTable = (int)$item['visibility_table'];
  3141.                     $stmtHeader->bind_param(
  3142.                         'isssiiii',
  3143.                         $localModelId,
  3144.                         $fieldKey,
  3145.                         $label,
  3146.                         $valueType,
  3147.                         $orderIndex,
  3148.                         $visibility,
  3149.                         $orderIndexTable,
  3150.                         $visibilityTable
  3151.                     );
  3152.                     if (!$stmtHeader->execute()) {
  3153.                         $stmtHeader->close();
  3154.                         throw new \RuntimeException('Execute INSERT definitions_header: ' . $stmtHeader->error);
  3155.                     }
  3156.                 }
  3157.                 $stmtHeader->close();
  3158.             }
  3160.             if (!empty($definitions['lines'])) {
  3161.                 $stmtLines = $clientMysqli->prepare(
  3162.                     'INSERT INTO definitions_lines
  3163.                     (model_id, field_key, label, value_type, order_index, visibility)
  3164.                     VALUES (?, ?, ?, ?, ?, ?)'
  3165.                 );
  3166.                 if (!$stmtLines) {
  3167.                     throw new \RuntimeException('Prepare INSERT definitions_lines: ' . $clientMysqli->error);
  3168.                 }
  3169.                 foreach ($definitions['lines'] as $item) {
  3170.                     $fieldKey = (string)$item['field_key'];
  3171.                     $label = (string)$item['label'];
  3172.                     $valueType = (string)$item['value_type'];
  3173.                     $orderIndex = (int)$item['order_index'];
  3174.                     $visibility = (int)$item['visibility'];
  3175.                     $stmtLines->bind_param(
  3176.                         'isssii',
  3177.                         $localModelId,
  3178.                         $fieldKey,
  3179.                         $label,
  3180.                         $valueType,
  3181.                         $orderIndex,
  3182.                         $visibility
  3183.                     );
  3184.                     if (!$stmtLines->execute()) {
  3185.                         $stmtLines->close();
  3186.                         throw new \RuntimeException('Execute INSERT definitions_lines: ' . $stmtLines->error);
  3187.                     }
  3188.                 }
  3189.                 $stmtLines->close();
  3190.             }
  3192.             $clientMysqli->commit();
  3193.             return $localModelId;
  3194.         } catch (\Throwable $e) {
  3195.             $clientMysqli->rollback();
  3196.             throw $e;
  3197.         }
  3198.     }
  3200.     private function registerModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  3201.     {
  3202.         return $this->registerDiModelInClientDb($clientMysqli, $resource, $modelId);
  3203.     }
  3205.     private function normalizeAoaiFieldScope(string $scope): string
  3206.     {
  3207.         $scope = strtolower(trim($scope));
  3208.         return $scope === 'lines' ? 'lines' : 'header';
  3209.     }
  3211.     private function normalizeAoaiValueType(string $valueType): string
  3212.     {
  3213.         $valueType = strtolower(trim($valueType));
  3214.         if ($valueType === 'number') {
  3215.             return 'number';
  3216.         }
  3217.         if ($valueType === 'date') {
  3218.             return 'date';
  3219.         }
  3220.         return 'string';
  3221.     }
  3223.     private function collectAoaiFieldsFromRequest(Request $request): array
  3224.     {
  3225.         $scopes = $request->request->all('aoai_fields_scope');
  3226.         $keys = $request->request->all('aoai_fields_key');
  3227.         $prompts = $request->request->all('aoai_fields_prompt');
  3228.         $valueTypes = $request->request->all('aoai_fields_type');
  3230.         if (!is_array($scopes)) {
  3231.             $scopes = [];
  3232.         }
  3233.         if (!is_array($keys)) {
  3234.             $keys = [];
  3235.         }
  3236.         if (!is_array($prompts)) {
  3237.             $prompts = [];
  3238.         }
  3239.         if (!is_array($valueTypes)) {
  3240.             $valueTypes = [];
  3241.         }
  3243.         $max = max(count($scopes), count($keys), count($prompts), count($valueTypes));
  3244.         $fields = [];
  3245.         for ($i = 0; $i < $max; $i++) {
  3246.             $scope = $this->normalizeAoaiFieldScope((string)($scopes[$i] ?? 'header'));
  3247.             $fieldKey = trim((string)($keys[$i] ?? ''));
  3248.             $prompt = trim((string)($prompts[$i] ?? ''));
  3249.             $valueType = $this->normalizeAoaiValueType((string)($valueTypes[$i] ?? 'string'));
  3250.             if ($fieldKey === '' && $prompt === '') {
  3251.                 continue;
  3252.             }
  3253.             $fields[] = [
  3254.                 'scope' => $scope,
  3255.                 'field_key' => $fieldKey,
  3256.                 'prompt' => $prompt,
  3257.                 'value_type' => $valueType,
  3258.             ];
  3259.         }
  3260.         return $fields;
  3261.     }
  3263.     private function validateAoaiFields(array $fields): ?string
  3264.     {
  3265.         if (count($fields) === 0) {
  3266.             return 'Debes indicar al menos un campo para Azure OpenAI.';
  3267.         }
  3269.         $seen = [];
  3270.         foreach ($fields as $item) {
  3271.             $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  3272.             $fieldKey = trim((string)($item['field_key'] ?? ''));
  3273.             $prompt = trim((string)($item['prompt'] ?? ''));
  3274.             $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  3275.             if ($fieldKey === '' || $prompt === '') {
  3276.                 return 'Todos los campos de Azure OpenAI deben tener nombre y prompt.';
  3277.             }
  3278.             if (!in_array($valueType, ['string', 'number', 'date'], true)) {
  3279.                 return 'El tipo de dato permitido es string, number o date.';
  3280.             }
  3281.             $uniq = $scope . '|' . strtolower($fieldKey);
  3282.             if (isset($seen[$uniq])) {
  3283.                 return 'No se permiten campos repetidos dentro del mismo alcance (cabecera o líneas).';
  3284.             }
  3285.             $seen[$uniq] = true;
  3286.         }
  3288.         return null;
  3289.     }
  3291.     private function registerAoaiModelInClientDb(\mysqli $clientMysqli, array $resource, array $aoaiFields): int
  3292.     {
  3293.         $extractorType = $this->normalizeExtractorType((string)($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  3294.         if ($extractorType !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3295.             throw new \RuntimeException('El recurso seleccionado no es de tipo Azure OpenAI.', 400);
  3296.         }
  3298.         $validationError = $this->validateAoaiFields($aoaiFields);
  3299.         if ($validationError !== null) {
  3300.             throw new \RuntimeException($validationError, 400);
  3301.         }
  3303.         $modelId = trim((string)($resource['model_id'] ?? ''));
  3304.         $basePrompt = trim((string)($resource['base_prompt'] ?? ''));
  3305.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  3306.         $apiKey = trim((string)($resource['api_key'] ?? ''));
  3307.         if ($modelId === '' || $basePrompt === '' || $endpoint === '' || $apiKey === '') {
  3308.             throw new \RuntimeException('El recurso Azure OpenAI está incompleto.', 400);
  3309.         }
  3311.         $provider = 'azure_openai';
  3312.         $type = 'custom';
  3313.         $showConfidenceBadges = 0;
  3315.         $clientMysqli->begin_transaction();
  3316.         try {
  3317.             $existingId = 0;
  3318.             $stmtSelect = $clientMysqli->prepare(
  3319.                 'SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? LIMIT 1'
  3320.             );
  3321.             if (!$stmtSelect) {
  3322.                 throw new \RuntimeException('Prepare SELECT extraction_models AOAI: ' . $clientMysqli->error);
  3323.             }
  3324.             $stmtSelect->bind_param('ss', $provider, $modelId);
  3325.             if (!$stmtSelect->execute()) {
  3326.                 $stmtSelect->close();
  3327.                 throw new \RuntimeException('Execute SELECT extraction_models AOAI: ' . $stmtSelect->error);
  3328.             }
  3329.             $result = $stmtSelect->get_result();
  3330.             if ($result && ($row = $result->fetch_assoc())) {
  3331.                 $existingId = (int)$row['id'];
  3332.             }
  3333.             $stmtSelect->close();
  3335.             if ($existingId > 0) {
  3336.                 $stmtUpdate = $clientMysqli->prepare(
  3337.                     'UPDATE extraction_models
  3338.                      SET endpoint = ?, api_key = ?, base_prompt = ?, type = ?, show_confidence_badges = ?
  3339.                      WHERE id = ?'
  3340.                 );
  3341.                 if (!$stmtUpdate) {
  3342.                     throw new \RuntimeException('Prepare UPDATE extraction_models AOAI: ' . $clientMysqli->error);
  3343.                 }
  3344.                 $stmtUpdate->bind_param('ssssii', $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges, $existingId);
  3345.                 if (!$stmtUpdate->execute()) {
  3346.                     $stmtUpdate->close();
  3347.                     throw new \RuntimeException('Execute UPDATE extraction_models AOAI: ' . $stmtUpdate->error);
  3348.                 }
  3349.                 $stmtUpdate->close();
  3350.                 $localModelId = $existingId;
  3351.             } else {
  3352.                 $stmtInsert = $clientMysqli->prepare(
  3353.                     'INSERT INTO extraction_models (provider, model_id, endpoint, api_key, base_prompt, type, show_confidence_badges)
  3354.                      VALUES (?, ?, ?, ?, ?, ?, ?)'
  3355.                 );
  3356.                 if (!$stmtInsert) {
  3357.                     throw new \RuntimeException('Prepare INSERT extraction_models AOAI: ' . $clientMysqli->error);
  3358.                 }
  3359.                 $stmtInsert->bind_param('ssssssi', $provider, $modelId, $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges);
  3360.                 if (!$stmtInsert->execute()) {
  3361.                     $stmtInsert->close();
  3362.                     throw new \RuntimeException('Execute INSERT extraction_models AOAI: ' . $stmtInsert->error);
  3363.                 }
  3364.                 $localModelId = (int)$stmtInsert->insert_id;
  3365.                 $stmtInsert->close();
  3366.             }
  3368.             $existingHeaderKeys = [];
  3369.             $existingLinesKeys = [];
  3371.             $stmtExistingHeader = $clientMysqli->prepare(
  3372.                 'SELECT field_key FROM definitions_header WHERE model_id = ?'
  3373.             );
  3374.             if (!$stmtExistingHeader) {
  3375.                 throw new \RuntimeException('Prepare SELECT definitions_header AOAI: ' . $clientMysqli->error);
  3376.             }
  3377.             $stmtExistingHeader->bind_param('i', $localModelId);
  3378.             if (!$stmtExistingHeader->execute()) {
  3379.                 $stmtExistingHeader->close();
  3380.                 throw new \RuntimeException('Execute SELECT definitions_header AOAI: ' . $stmtExistingHeader->error);
  3381.             }
  3382.             $resExistingHeader = $stmtExistingHeader->get_result();
  3383.             while ($resExistingHeader && ($row = $resExistingHeader->fetch_assoc())) {
  3384.                 $existingHeaderKeys[(string)($row['field_key'] ?? '')] = true;
  3385.             }
  3386.             $stmtExistingHeader->close();
  3388.             $stmtExistingLines = $clientMysqli->prepare(
  3389.                 'SELECT field_key FROM definitions_lines WHERE model_id = ?'
  3390.             );
  3391.             if (!$stmtExistingLines) {
  3392.                 throw new \RuntimeException('Prepare SELECT definitions_lines AOAI: ' . $clientMysqli->error);
  3393.             }
  3394.             $stmtExistingLines->bind_param('i', $localModelId);
  3395.             if (!$stmtExistingLines->execute()) {
  3396.                 $stmtExistingLines->close();
  3397.                 throw new \RuntimeException('Execute SELECT definitions_lines AOAI: ' . $stmtExistingLines->error);
  3398.             }
  3399.             $resExistingLines = $stmtExistingLines->get_result();
  3400.             while ($resExistingLines && ($row = $resExistingLines->fetch_assoc())) {
  3401.                 $existingLinesKeys[(string)($row['field_key'] ?? '')] = true;
  3402.             }
  3403.             $stmtExistingLines->close();
  3405.             $stmtInsertHeader = $clientMysqli->prepare(
  3406.                 'INSERT INTO definitions_header
  3407.                 (model_id, field_key, label, prompt, value_type, order_index, visibility, order_index_table, visibility_table)
  3408.                 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)'
  3409.             );
  3410.             if (!$stmtInsertHeader) {
  3411.                 throw new \RuntimeException('Prepare INSERT definitions_header AOAI: ' . $clientMysqli->error);
  3412.             }
  3414.             $stmtUpdateHeader = $clientMysqli->prepare(
  3415.                 'UPDATE definitions_header
  3416.                  SET prompt = ?, value_type = ?, order_index = ?, order_index_table = ?
  3417.                  WHERE model_id = ? AND field_key = ?'
  3418.             );
  3419.             if (!$stmtUpdateHeader) {
  3420.                 $stmtInsertHeader->close();
  3421.                 throw new \RuntimeException('Prepare UPDATE definitions_header AOAI: ' . $clientMysqli->error);
  3422.             }
  3424.             $stmtInsertLines = $clientMysqli->prepare(
  3425.                 'INSERT INTO definitions_lines
  3426.                 (model_id, field_key, label, prompt, value_type, order_index, visibility)
  3427.                 VALUES (?, ?, ?, ?, ?, ?, ?)'
  3428.             );
  3429.             if (!$stmtInsertLines) {
  3430.                 $stmtInsertHeader->close();
  3431.                 $stmtUpdateHeader->close();
  3432.                 throw new \RuntimeException('Prepare INSERT definitions_lines AOAI: ' . $clientMysqli->error);
  3433.             }
  3435.             $stmtUpdateLines = $clientMysqli->prepare(
  3436.                 'UPDATE definitions_lines
  3437.                  SET prompt = ?, value_type = ?, order_index = ?
  3438.                  WHERE model_id = ? AND field_key = ?'
  3439.             );
  3440.             if (!$stmtUpdateLines) {
  3441.                 $stmtInsertHeader->close();
  3442.                 $stmtUpdateHeader->close();
  3443.                 $stmtInsertLines->close();
  3444.                 throw new \RuntimeException('Prepare UPDATE definitions_lines AOAI: ' . $clientMysqli->error);
  3445.             }
  3447.             $headerOrder = 1;
  3448.             $lineOrder = 1;
  3449.             $incomingHeaderKeys = [];
  3450.             $incomingLinesKeys = [];
  3451.             foreach ($aoaiFields as $item) {
  3452.                 $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  3453.                 $fieldKey = trim((string)($item['field_key'] ?? ''));
  3454.                 $prompt = trim((string)($item['prompt'] ?? ''));
  3455.                 $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  3456.                 $visibility = 1;
  3457.                 if ($scope === 'lines') {
  3458.                     $orderIndex = $lineOrder++;
  3459.                     $incomingLinesKeys[$fieldKey] = true;
  3460.                     if (isset($existingLinesKeys[$fieldKey])) {
  3461.                         $stmtUpdateLines->bind_param(
  3462.                             'ssiis',
  3463.                             $prompt,
  3464.                             $valueType,
  3465.                             $orderIndex,
  3466.                             $localModelId,
  3467.                             $fieldKey
  3468.                         );
  3469.                         if (!$stmtUpdateLines->execute()) {
  3470.                             throw new \RuntimeException('Execute UPDATE definitions_lines AOAI: ' . $stmtUpdateLines->error);
  3471.                         }
  3472.                     } else {
  3473.                         $label = $fieldKey;
  3474.                         $stmtInsertLines->bind_param(
  3475.                             'issssii',
  3476.                             $localModelId,
  3477.                             $fieldKey,
  3478.                             $label,
  3479.                             $prompt,
  3480.                             $valueType,
  3481.                             $orderIndex,
  3482.                             $visibility
  3483.                         );
  3484.                         if (!$stmtInsertLines->execute()) {
  3485.                             throw new \RuntimeException('Execute INSERT definitions_lines AOAI: ' . $stmtInsertLines->error);
  3486.                         }
  3487.                     }
  3488.                 } else {
  3489.                     $orderIndex = $headerOrder++;
  3490.                     $orderIndexTable = $orderIndex;
  3491.                     $incomingHeaderKeys[$fieldKey] = true;
  3492.                     if (isset($existingHeaderKeys[$fieldKey])) {
  3493.                         $stmtUpdateHeader->bind_param(
  3494.                             'ssiiss',
  3495.                             $prompt,
  3496.                             $valueType,
  3497.                             $orderIndex,
  3498.                             $orderIndexTable,
  3499.                             $localModelId,
  3500.                             $fieldKey
  3501.                         );
  3502.                         if (!$stmtUpdateHeader->execute()) {
  3503.                             throw new \RuntimeException('Execute UPDATE definitions_header AOAI: ' . $stmtUpdateHeader->error);
  3504.                         }
  3505.                     } else {
  3506.                         $label = $fieldKey;
  3507.                         $visibilityTable = 1;
  3508.                         $stmtInsertHeader->bind_param(
  3509.                             'issssiiii',
  3510.                             $localModelId,
  3511.                             $fieldKey,
  3512.                             $label,
  3513.                             $prompt,
  3514.                             $valueType,
  3515.                             $orderIndex,
  3516.                             $visibility,
  3517.                             $orderIndexTable,
  3518.                             $visibilityTable
  3519.                         );
  3520.                         if (!$stmtInsertHeader->execute()) {
  3521.                             throw new \RuntimeException('Execute INSERT definitions_header AOAI: ' . $stmtInsertHeader->error);
  3522.                         }
  3523.                     }
  3524.                 }
  3525.             }
  3527.             $stmtInsertHeader->close();
  3528.             $stmtUpdateHeader->close();
  3529.             $stmtInsertLines->close();
  3530.             $stmtUpdateLines->close();
  3532.             $headerToDelete = array_values(array_diff(array_keys($existingHeaderKeys), array_keys($incomingHeaderKeys)));
  3533.             if (count($headerToDelete) > 0) {
  3534.                 $ph = implode(',', array_fill(0, count($headerToDelete), '?'));
  3535.                 $types = 'i' . str_repeat('s', count($headerToDelete));
  3536.                 $sql = "DELETE FROM definitions_header WHERE model_id = ? AND field_key IN ($ph)";
  3537.                 $stmtDeleteHeader = $clientMysqli->prepare($sql);
  3538.                 if (!$stmtDeleteHeader) {
  3539.                     throw new \RuntimeException('Prepare DELETE definitions_header AOAI selective: ' . $clientMysqli->error);
  3540.                 }
  3541.                 $params = array_merge([$localModelId], $headerToDelete);
  3542.                 $bind = [$types];
  3543.                 foreach ($params as $k => $v) {
  3544.                     $bind[] = &$params[$k];
  3545.                 }
  3546.                 call_user_func_array([$stmtDeleteHeader, 'bind_param'], $bind);
  3547.                 if (!$stmtDeleteHeader->execute()) {
  3548.                     $stmtDeleteHeader->close();
  3549.                     throw new \RuntimeException('Execute DELETE definitions_header AOAI selective: ' . $stmtDeleteHeader->error);
  3550.                 }
  3551.                 $stmtDeleteHeader->close();
  3552.             }
  3554.             $linesToDelete = array_values(array_diff(array_keys($existingLinesKeys), array_keys($incomingLinesKeys)));
  3555.             if (count($linesToDelete) > 0) {
  3556.                 $ph = implode(',', array_fill(0, count($linesToDelete), '?'));
  3557.                 $types = 'i' . str_repeat('s', count($linesToDelete));
  3558.                 $sql = "DELETE FROM definitions_lines WHERE model_id = ? AND field_key IN ($ph)";
  3559.                 $stmtDeleteLines = $clientMysqli->prepare($sql);
  3560.                 if (!$stmtDeleteLines) {
  3561.                     throw new \RuntimeException('Prepare DELETE definitions_lines AOAI selective: ' . $clientMysqli->error);
  3562.                 }
  3563.                 $params = array_merge([$localModelId], $linesToDelete);
  3564.                 $bind = [$types];
  3565.                 foreach ($params as $k => $v) {
  3566.                     $bind[] = &$params[$k];
  3567.                 }
  3568.                 call_user_func_array([$stmtDeleteLines, 'bind_param'], $bind);
  3569.                 if (!$stmtDeleteLines->execute()) {
  3570.                     $stmtDeleteLines->close();
  3571.                     throw new \RuntimeException('Execute DELETE definitions_lines AOAI selective: ' . $stmtDeleteLines->error);
  3572.                 }
  3573.                 $stmtDeleteLines->close();
  3574.             }
  3576.             $clientMysqli->commit();
  3577.             return $localModelId;
  3578.         } catch (\Throwable $e) {
  3579.             $clientMysqli->rollback();
  3580.             throw $e;
  3581.         }
  3582.     }
  3584.     public function Empresa(Request $req, EntityManagerInterface $em)
  3585.     {
  3586.         if (!$this->getUser() || !is_object($this->getUser())) {
  3587.             return $this->redirectToRoute('logout');
  3588.         }
  3590.         $id = (int)$req->get("id");
  3591.         if (!$id) {
  3592.             $this->addFlash('warning', 'Empresa no encontrada.');
  3593.             return $this->redirectToRoute("list");
  3594.         }
  3596.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3597.         if (!$empresa) {
  3598.             $this->addFlash('warning', 'Empresa no encontrada.');
  3599.             return $this->redirectToRoute("list");
  3600.         }
  3602.         $users = $em->getRepository(Usuario::class)->findBy([
  3603.             "empresa" => $empresa->getId()
  3604.         ]);
  3606.         // Valores por defecto por si algo falla al conectar con la BD del cliente
  3607.         $activeUsers            = null;
  3608.         $modulos                = [];
  3609.         $empresaLogo            = null;
  3610.         $extractionModelLabel   = null;
  3611.         $activeLicenseContract  = [];
  3612.         $licenseContractHistory = [];
  3613.         $visualActiveContractId = null;
  3615.         $diskUsedBytes          = null;
  3616.         $diskUsedGb             = null;
  3618.         try {
  3619.             $cx = $empresa->getConexionBD();
  3620.             if ($cx) {
  3621.                 $mysqli = @new \mysqli(
  3622.                     $cx->getDbUrl(),
  3623.                     $cx->getDbUser(),
  3624.                     $cx->getDbPassword(),
  3625.                     $cx->getDbName(),
  3626.                     (int)$cx->getDbPort()
  3627.                 );
  3629.                 if (!$mysqli->connect_error) {
  3630.                     // parámetros (modulos, límites, etc.)
  3631.                     [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  3633.                     // logo guardado en la BD del cliente
  3634.                     $empresaLogo = $this->loadEmpresaLogo($mysqli);
  3635.                     $activeLicenseContract = $this->licenseContractService->loadActiveContract($mysqli);
  3636.                     $licenseContractHistory = $this->licenseContractService->loadContractHistory($mysqli);
  3637.                     $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($licenseContractHistory);
  3639.                     $diskUsedBytes = $this->loadEmpresaDiskUsageBytes($mysqli);
  3640.                     $diskUsedGb = ($diskUsedBytes !== null)
  3641.                         ? round($diskUsedBytes / 1024 / 1024 / 1024, 2)
  3642.                         : null;
  3644.                     // Si tiene extracción y modelo seleccionado, buscamos el ID legible del modelo
  3645.                     if (
  3646.                         !empty($modulos['modulo_extraccion']) &&
  3647.                         !empty($modulos['extraction_model'])
  3648.                     ) {
  3649.                         try {
  3650.                             $stmt = $mysqli->prepare('SELECT model_id FROM extraction_models WHERE id = ? LIMIT 1');
  3651.                             if ($stmt) {
  3652.                                 $modelParam = (int)$modulos['extraction_model'];
  3653.                                 $stmt->bind_param('i', $modelParam);
  3654.                                 if ($stmt->execute()) {
  3655.                                     $res = $stmt->get_result();
  3656.                                     if ($res && ($row = $res->fetch_assoc()) && isset($row['model_id'])) {
  3657.                                         $extractionModelLabel = $row['model_id'];
  3658.                                     }
  3659.                                 }
  3660.                                 $stmt->close();
  3661.                             }
  3662.                         } catch (\Throwable $e) {
  3663.                             // Si falla, simplemente no mostramos el texto bonito del modelo
  3664.                             $extractionModelLabel = null;
  3665.                         }
  3666.                     }
  3668.                     $mysqli->close();
  3669.                 }
  3670.             }
  3671.         } catch (\Throwable $e) {
  3672.             // Aquí podrías loguear el error si quieres, pero no rompemos la pantalla
  3673.         }
  3675.         return $this->render('empresa_detail.html.twig', [
  3676.             'empresa'              => $empresa,
  3677.             'users'                => $users,
  3678.             'activeUsers'          => $activeUsers,
  3679.             'modulos'              => $modulos,
  3680.             'empresaLogo'          => $empresaLogo,
  3681.             'extractionModelLabel' => $extractionModelLabel,
  3682.             'diskUsedGb' => $diskUsedGb,
  3683.             'activeLicenseContract' => $activeLicenseContract,
  3684.             'licenseContractHistory' => $licenseContractHistory,
  3685.             'visualActiveContractId' => $visualActiveContractId,
  3686.         ]);
  3687.     }
  3689.     public function deleteEmpresa(Request $request, EntityManagerInterface $em)
  3690.     {
  3691.         $id = $request->get("id");
  3693.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3695.         $conexion = $empresa->getConexionBD();
  3696.         $usuarios = $em->getRepository(Usuario::class)->findBy(array("empresa" => $empresa->getId()));
  3698.         // Recoger avatar/firma de usuarios antes de eliminar la BD del cliente
  3699.         $mediaPaths = [];
  3700.         try {
  3701.             $mysqliMedia = @new \mysqli(
  3702.                 $conexion->getDbUrl(),
  3703.                 $conexion->getDbUser(),
  3704.                 $conexion->getDbPassword(),
  3705.                 $conexion->getDbName(),
  3706.                 (int)$conexion->getDbPort()
  3707.             );
  3708.             if (!$mysqliMedia->connect_error) {
  3709.                 $mediaPaths = $this->getCompanyUserMediaPaths($mysqliMedia);
  3710.                 $mysqliMedia->close();
  3711.             } else {
  3712.                 error_log('No se pudo conectar a BD cliente para borrar media: ' . $mysqliMedia->connect_error);
  3713.             }
  3714.         } catch (\Throwable $e) {
  3715.             error_log('Error borrando media de usuarios: ' . $e->getMessage());
  3716.         }
  3719.         $hestiaApiUrl = 'https://200.234.237.107:8083/api/';
  3720.         $owner = 'docunecta'; // o el dueño del hosting
  3723.         $postFields = http_build_query([
  3724.             'user' => 'admin',
  3725.             'password' => 'i9iQiSmxb2EpvgLq',
  3726.             'returncode' => 'yes',
  3727.             'cmd' => 'v-delete-database',
  3728.             'arg1' => 'admin',
  3729.             'arg2' => $conexion->getDbName(),
  3731.         ]);
  3733.         $accessKeyId = 'cWYbt9ShyFQ3yVRsUE8u';
  3734.         $secretKey = 'e2M_5wk2_jUAlPorF7V8zfwo3_0ihu90WoLPMKwj';
  3735.         $headers = [
  3736.             'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  3737.         ];
  3739.         $ch = curl_init();
  3740.         curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  3741.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  3742.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  3743.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  3744.         curl_setopt($ch, CURLOPT_POST, true);
  3745.         curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  3746.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  3748.         $response = curl_exec($ch);
  3749.         $error = curl_error($ch);
  3750.         curl_close($ch);
  3752.         if (($error || trim($response) !== '0') && trim($response) !== '3') {
  3753.             $this->addFlash('danger', 'Error al eliminar la base de datos en HestiaCP: ' . ($error ?: $response));
  3754.             return $this->redirectToRoute('list');
  3755.         }
  3757.         // Eliminar el servicio systemd asociado a la empresa
  3758.         $company_name = $empresa->getId();
  3760.         $serviceName = $company_name . "-documanager.service";
  3761.         $servicePath = "/etc/systemd/system/$serviceName";
  3762.         $cmds = [
  3763.             "sudo /bin/systemctl stop $serviceName",
  3764.             "sudo /bin/systemctl disable $serviceName",
  3765.             "sudo /bin/rm -f $servicePath",
  3766.             "sudo /bin/systemctl daemon-reload"
  3767.         ];
  3768.         $serviceErrors = [];
  3769.         foreach ($cmds as $cmd) {
  3770.             $output = @\shell_exec($cmd . " 2>&1");
  3771.             if ($output !== null && trim($output) !== '') {
  3772.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  3773.             }
  3774.         }
  3776.         $azureService = $company_name . "-azuredi.service";
  3777.         $servicePathAzure = "/etc/systemd/system/$azureService";
  3778.         $cmdsAzure = [
  3779.             "sudo /bin/systemctl stop $azureService",
  3780.             "sudo /bin/systemctl disable $azureService",
  3781.             "sudo /bin/rm -f $servicePathAzure",
  3782.             "sudo /bin/systemctl daemon-reload",
  3783.         ];
  3784.         foreach ($cmdsAzure as $cmd) {
  3785.             $output = @\shell_exec($cmd . " 2>&1");
  3786.             if ($output) {
  3787.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  3788.             }
  3789.         }
  3791.         // Eliminar mail monitor service + timer (si existen)
  3792.         $this->disableMailMonitorService((int)$company_name);
  3794.         // Pedir a platform que elimine files/logs/media del cliente
  3795.         $this->callPlatformCleanup((int)$company_name, $mediaPaths);
  3797.         //eliminamos usuarios
  3798.         foreach ($usuarios as $user) {
  3799.             $em->remove($user);
  3800.             $em->flush();
  3801.         }
  3803.         //eliminamos conexiĂłn
  3804.         $em->remove($conexion);
  3805.         $em->flush();
  3807.         //eliminamos empresa
  3808.         $em->remove($empresa);
  3809.         $em->flush();
  3810.         $msg = 'Empresa y base de datos eliminadas correctamente.';
  3811.         if (count($serviceErrors) > 0) {
  3812.             $msg .= ' ' . implode('<br>', $serviceErrors);
  3813.         }
  3814.         $this->addFlash('success', $msg);
  3815.         return $this->redirectToRoute('list');
  3816.     }
  3818.     public function editEmpresa(Request $request, EntityManagerInterface $em)
  3819.     {
  3820.         if (!$this->getUser() || !is_object($this->getUser())) {
  3821.             return $this->redirectToRoute('logout');
  3822.         }
  3824.         $id = (int)$request->get('id');
  3825.         $empresa = $em->getRepository(Empresa::class)->find($id);
  3826.         if (!$empresa) {
  3827.             throw $this->createNotFoundException('Empresa no encontrada');
  3828.         }
  3830.         // 1) Conectar a la BD del cliente con las credenciales de la central
  3831.         $cx = $empresa->getConexionBD();
  3832.         $mysqli = @new \mysqli(
  3833.             $cx->getDbUrl(),
  3834.             $cx->getDbUser(),
  3835.             $cx->getDbPassword(),
  3836.             $cx->getDbName(),
  3837.             (int)$cx->getDbPort()
  3838.         );
  3839.         if ($mysqli->connect_error) {
  3840.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  3841.             return $this->redirectToRoute('list');
  3842.         }
  3844.         $ocrPlusAvailable = $this->isOcrPlusAvailable();
  3845.         $ocrV2Available = $this->isOcrV2Available();
  3847.         $azureResources = [];
  3848.         $azureDiResources = [];
  3849.         $azureOpenAiResources = [];
  3850.         try {
  3851.             $azureResources = $this->loadAzureResources($em);
  3852.             foreach ($azureResources as $resourceRow) {
  3853.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3854.                     $azureOpenAiResources[] = $resourceRow;
  3855.                 } else {
  3856.                     $azureDiResources[] = $resourceRow;
  3857.                 }
  3858.             }
  3859.         } catch (\Throwable $e) {
  3860.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  3861.         }
  3863.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  3864.             // Estado previo de modulos (para detectar activacion de Mail Monitor)
  3865.             [$activeUsersPrev, $modulosPrev] = $this->loadEmpresaParametros($mysqli);
  3866.             $prevMailMonitor = (int)($modulosPrev['modulo_mailMonitor'] ?? 0);
  3868.             $data = $request->request->all();
  3869.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, $empresa->getMaxThreads() ?: 4);
  3870.             $data['ocr_mode'] = $this->normalizeOcrMode($data['ocr_mode'] ?? 'base');
  3871.             if (!$ocrV2Available && $data['ocr_mode'] === 'v2_zxing') {
  3872.                 $data['ocr_mode'] = 'base';
  3873.             }
  3874.             if (!$ocrPlusAvailable && $data['ocr_mode'] === 'plus_glm') {
  3875.                 $data['ocr_mode'] = 'base';
  3876.             }
  3879.             // 2) Actualizar SOLO central
  3880.             $empresa->setName((string)($data['name'] ?? $empresa->getName()));
  3881.             $empresa->setMaxDiskQuota(
  3882.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== ''
  3883.                     ? (int)$data['maxDiskQuota']
  3884.                     : $empresa->getMaxDiskQuota()
  3885.             );
  3886.             $empresa->setMaxThreads($maxThreads);
  3887.             $em->persist($empresa);
  3889.             // ---- Normalización de POST (checkboxes / select) ----
  3890.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  3892.             $extractionModel = 0;
  3893.             if (isset($data['extraction_model']) && $data['extraction_model'] !== '') {
  3894.                 $extractionModel = (int)$data['extraction_model'];
  3895.             }
  3896.             $data['extraction_model'] = $extractionModel;
  3897.             $data['extractor_type'] = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  3898.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  3899.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  3900.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  3901.             $aoaiFields = $this->collectAoaiFieldsFromRequest($request);
  3903.             $data['modulo_extraccion']       = isset($data['modulo_extraccion'])       && $toBool($data['modulo_extraccion'])       ? 1 : 0;
  3904.             $data['modulo_etiquetas']        = isset($data['modulo_etiquetas'])        && $toBool($data['modulo_etiquetas'])        ? 1 : 0;
  3905.             $data['modulo_calendario']       = isset($data['modulo_calendario'])       && $toBool($data['modulo_calendario'])       ? 1 : 0;
  3906.             $data['modulo_calendarioExterno'] = isset($data['modulo_calendarioExterno']) && $toBool($data['modulo_calendarioExterno']) ? 1 : 0;
  3907.             $data['modulo_estados']          = isset($data['modulo_estados'])          && $toBool($data['modulo_estados'])          ? 1 : 0;
  3908.             $data['modulo_lineas']           = isset($data['modulo_lineas'])           && $toBool($data['modulo_lineas'])           ? 1 : 0;
  3909.             $data['modulo_agora']            = isset($data['modulo_agora'])           && $toBool($data['modulo_agora'])             ? 1 : 0;
  3910.             $data['modulo_gstock']           = isset($data['modulo_gstock'])           && $toBool($data['modulo_gstock'])           ? 1 : 0;
  3911.             $data['modulo_expowin']          = isset($data['modulo_expowin'])          && $toBool($data['modulo_expowin'])          ? 1 : 0;
  3912.             $data['modulo_prinex']           = isset($data['modulo_prinex'])           && $toBool($data['modulo_prinex'])           ? 1 : 0;
  3913.             $data['modulo_mailMonitor']      = isset($data['modulo_mailMonitor'])      && $toBool($data['modulo_mailMonitor'])      ? 1 : 0;
  3914.             $data['modulo_busquedaNatural']  = isset($data['modulo_busquedaNatural'])  && $toBool($data['modulo_busquedaNatural'])  ? 1 : 0;
  3915.             $data['soloExtraccion']          = isset($data['soloExtraccion'])          && $toBool($data['soloExtraccion'])          ? 1 : 0;
  3917.             // Dependencias
  3918.             if (!$data['modulo_calendario']) {
  3919.                 $data['modulo_calendarioExterno'] = 0;
  3920.             }
  3921.             if (!$data['modulo_extraccion']) {
  3922.                 $data['modulo_lineas']   = 0;
  3923.                 $data['extraction_model'] = 0;
  3924.                 $data['modulo_agora']    = 0;
  3925.                 $data['modulo_gstock']   = 0;
  3926.                 $data['modulo_expowin']  = 0;
  3927.                 $data['modulo_prinex']   = 0;
  3928.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  3929.                 $azureResourceId = 0;
  3930.                 $azureModelId = '';
  3931.                 $aoaiResourceId = 0;
  3932.             }
  3934.             // 3) Guardar en BD del cliente: parametros + license
  3935.             if ($data['modulo_extraccion'] === 1) {
  3936.                 if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3937.                     if ($aoaiResourceId <= 0) {
  3938.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  3939.                         $mysqli->close();
  3940.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3941.                     }
  3943.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  3944.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3945.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  3946.                         $mysqli->close();
  3947.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3948.                     }
  3950.                     $validationError = $this->validateAoaiFields($aoaiFields);
  3951.                     if ($validationError !== null) {
  3952.                         $this->addFlash('danger', $validationError);
  3953.                         $mysqli->close();
  3954.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3955.                     }
  3957.                     try {
  3958.                         $data['extraction_model'] = $this->registerAoaiModelInClientDb(
  3959.                             $mysqli,
  3960.                             $azureResource,
  3961.                             $aoaiFields
  3962.                         );
  3963.                         $this->addFlash('success', 'Modelo Azure OpenAI importado/actualizado correctamente.');
  3964.                     } catch (\Throwable $e) {
  3965.                         $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  3966.                         $mysqli->close();
  3967.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3968.                     }
  3969.                 } else {
  3970.                     if (($azureResourceId > 0 && $azureModelId === '') || ($azureResourceId <= 0 && $azureModelId !== '')) {
  3971.                         $this->addFlash('danger', 'Para importar desde recurso IA debes indicar recurso y modelo.');
  3972.                         $mysqli->close();
  3973.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3974.                     }
  3976.                     if ($azureResourceId > 0 && $azureModelId !== '') {
  3977.                         $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  3978.                         if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  3979.                             $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  3980.                             $mysqli->close();
  3981.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3982.                         }
  3984.                         try {
  3985.                             $data['extraction_model'] = $this->registerDiModelInClientDb(
  3986.                                 $mysqli,
  3987.                                 $azureResource,
  3988.                                 $azureModelId
  3989.                             );
  3990.                             $this->addFlash('success', 'Modelo IA importado/actualizado correctamente.');
  3991.                         } catch (\Throwable $e) {
  3992.                             $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  3993.                             $mysqli->close();
  3994.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  3995.                         }
  3996.                     }
  3998.                     if ((int)$data['extraction_model'] <= 0) {
  3999.                         $this->addFlash('danger', 'Con extraccion activa debes seleccionar un modelo local o importar uno desde recurso IA.');
  4000.                         $mysqli->close();
  4001.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4002.                     }
  4003.                 }
  4004.             }
  4006.             $this->updateEmpresaParametros($mysqli, $data);
  4007.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  4008.                 try {
  4009.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  4010.                 } catch (\Throwable $e) {
  4011.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  4012.                 }
  4013.             }
  4014.             $this->updateLicense(
  4015.                 $mysqli,
  4016.                 $data,
  4017.                 $empresa->getName()
  4018.             );
  4020.             // Actualizar servicio OCR (hilos + binario segun modo OCR)
  4021.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  4022.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  4023.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  4024.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  4025.             if ($ocrMode === 'plus_glm') {
  4026.                 $ocrBinary = $ocrBinaryPlus;
  4027.             } elseif ($ocrMode === 'v2_zxing') {
  4028.                 $ocrBinary = $ocrBinaryV2;
  4029.             } else {
  4030.                 $ocrBinary = $ocrBinaryBase;
  4031.             }
  4032.             $filesPath = (string)($_ENV['FILES_PATH'] ?? '');
  4034.             if ($ocrBinary !== '' && $filesPath !== '') {
  4035.                 $companyId = (int)$empresa->getId();
  4036.                 $dbHost = (string)$cx->getDbUrl();
  4037.                 $dbName = (string)$cx->getDbName();
  4038.                 $dbUser = (string)$cx->getDbUser();
  4039.                 $dbPass = (string)$cx->getDbPassword();
  4041.                 $empresaName = (string)$empresa->getName();
  4042.                 $serviceContent = <<<EOT
  4043. [Unit]
  4044. Description={$empresaName} DocuManager OCR
  4045. Requires=mariadb.service
  4046. After=mariadb.service
  4048. [Service]
  4049. Type=simple
  4050. Environment="DOCU_MAX_THREADS=$maxThreads"
  4051. ExecStart=$ocrBinary {$dbHost}/{$dbName} {$dbUser} {$dbPass} {$filesPath}/{$companyId} NO
  4052. Restart=always
  4053. User=root
  4055. [Install]
  4056. WantedBy=multi-user.target
  4057. EOT;
  4059.                 $serviceName = $companyId . "-documanager.service";
  4060.                 $tmpServicePath = "/tmp/$serviceName";
  4061.                 file_put_contents($tmpServicePath, $serviceContent);
  4062.                 \chmod($tmpServicePath, 0644);
  4064.                 $cmds = [
  4065.                     "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  4066.                     "sudo /bin/systemctl daemon-reload",
  4067.                     "sudo /bin/systemctl restart $serviceName",
  4068.                 ];
  4069.                 $serviceErrors = [];
  4070.                 foreach ($cmds as $cmd) {
  4071.                     $output = \shell_exec($cmd . " 2>&1");
  4072.                     if ($output !== null && trim($output) !== '') {
  4073.                         error_log("CMD OUTPUT: $cmd\n$output");
  4074.                         $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  4075.                     }
  4076.                 }
  4077.                 if (count($serviceErrors) > 0) {
  4078.                     $this->addFlash('warning', 'Servicio OCR actualizado con avisos: ' . implode(' | ', $serviceErrors));
  4079.                 }
  4080.             } else {
  4081.                 if (($data['ocr_mode'] ?? 'base') === 'plus_glm') {
  4082.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_PLUS_BINARY o FILES_PATH.');
  4083.                 } elseif (($data['ocr_mode'] ?? 'base') === 'v2_zxing') {
  4084.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY_V2 o FILES_PATH.');
  4085.                 } else {
  4086.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY o FILES_PATH.');
  4087.                 }
  4088.             }
  4089.             // Si se activa Mail Monitor y antes estaba desactivado, crear servicio/timer
  4090.             if ($prevMailMonitor === 0 && (int)$data['modulo_mailMonitor'] === 1 && $filesPath !== '') {
  4091.                 $this->ensureMailMonitorService(
  4092.                     (int)$empresa->getId(),
  4093.                     (string)$cx->getDbUrl(),
  4094.                     (string)$cx->getDbPort(),
  4095.                     (string)$cx->getDbUser(),
  4096.                     (string)$cx->getDbPassword(),
  4097.                     (string)$cx->getDbName(),
  4098.                     (string)$filesPath
  4099.                 );
  4100.             }
  4101.             // Si se desactiva Mail Monitor, parar y eliminar service/timer
  4102.             if ($prevMailMonitor === 1 && (int)$data['modulo_mailMonitor'] === 0) {
  4103.                 $this->disableMailMonitorService((int)$empresa->getId());
  4104.             }
  4106.             $em->flush();
  4107.             $mysqli->close();
  4109.             // Mensaje de éxito
  4110.             $this->addFlash('success', 'Empresa editada correctamente.');
  4112.             return $this->redirectToRoute('app_empresa_show', ['id' => $id]);
  4113.         }
  4115.         // 4) GET: precargar desde BD del cliente
  4116.         [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  4117.         $license = $this->loadLicense($mysqli);
  4119.         $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  4120.         $selectedAoaiResourceId = 0;
  4121.         $aoaiFields = [];
  4122.         if (!empty($modulos['extraction_model'])) {
  4123.             try {
  4124.                 $stmtCurrentModel = $mysqli->prepare('SELECT provider FROM extraction_models WHERE id = ? LIMIT 1');
  4125.                 if ($stmtCurrentModel) {
  4126.                     $currentModelId = (int)$modulos['extraction_model'];
  4127.                     $stmtCurrentModel->bind_param('i', $currentModelId);
  4128.                     if ($stmtCurrentModel->execute()) {
  4129.                         $resCurrentModel = $stmtCurrentModel->get_result();
  4130.                         if ($resCurrentModel && ($modelRow = $resCurrentModel->fetch_assoc())) {
  4131.                             $provider = strtolower(trim((string)($modelRow['provider'] ?? '')));
  4132.                             if ($provider === 'azure_openai' || $provider === 'azure-openai') {
  4133.                                 $extractorType = self::EXTRACTOR_TYPE_AZURE_OPENAI;
  4134.                             }
  4135.                         }
  4136.                     }
  4137.                     $stmtCurrentModel->close();
  4138.                 }
  4139.             } catch (\Throwable $e) {
  4140.                 $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  4141.             }
  4142.         }
  4144.         if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI && !empty($modulos['extraction_model'])) {
  4145.             try {
  4146.                 $modelId = (int)$modulos['extraction_model'];
  4147.                 $selectedAoaiResourceId = $this->resolveAoaiResourceIdForModel($mysqli, $modelId, $em);
  4148.                 $aoaiFields = $this->loadAoaiFieldsForModel($mysqli, $modelId);
  4149.             } catch (\Throwable $e) {
  4150.                 $aoaiFields = [];
  4151.             }
  4152.         }
  4154.         $extractionModels = [];
  4155.         try {
  4156.             $res = $mysqli->query("SELECT id, model_id, provider FROM extraction_models WHERE provider IN ('azure-di', 'azure_openai', 'azure-openai') ORDER BY model_id");
  4157.             if ($res) {
  4158.                 while ($row = $res->fetch_assoc()) {
  4159.                     $extractionModels[] = [
  4160.                         'id' => (int)$row['id'],
  4161.                         'model_id' => (string)$row['model_id'],
  4162.                         'provider' => (string)($row['provider'] ?? ''),
  4163.                     ];
  4164.                 }
  4165.                 $res->free();
  4166.             }
  4167.         } catch (\Throwable $e) {
  4168.             $extractionModels = [];
  4169.         }
  4171.         $mysqli->close();
  4173.         return $this->render('empresa/_edit.html.twig', [
  4174.             'empresa'      => $empresa,   // central: name + maxDiskQuota
  4175.             'id'           => $id,
  4176.             'activeUsers'  => $activeUsers, // cliente
  4177.             'modulos'      => $modulos,     // cliente
  4178.             'license'      => $license,     // opcional
  4179.             'azure_resources' => $azureResources,
  4180.             'azure_di_resources' => $azureDiResources,
  4181.             'azure_openai_resources' => $azureOpenAiResources,
  4182.             'extraction_models' => $extractionModels,
  4183.             'form_data' => [
  4184.                 'extractor_type' => $extractorType,
  4185.                 'aoai_resource_id' => $selectedAoaiResourceId,
  4186.                 'ocr_mode' => $this->normalizeOcrMode($modulos['ocr_mode'] ?? 'base'),
  4187.             ],
  4188.             'aoai_fields' => $aoaiFields,
  4189.             'ocr_plus_available' => $ocrPlusAvailable,
  4190.             'ocr_v2_available' => $ocrV2Available,
  4191.         ]);
  4192.     }
  4194.     public function empresaLicenseEdit(Request $request, EntityManagerInterface $em)
  4195.     {
  4196.         if (!$this->getUser() || !is_object($this->getUser())) {
  4197.             return $this->redirectToRoute('logout');
  4198.         }
  4200.         $id = (int)$request->get('id');
  4201.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4202.         if (!$empresa) {
  4203.             throw $this->createNotFoundException('Empresa no encontrada');
  4204.         }
  4206.         $cx = $empresa->getConexionBD();
  4207.         $mysqli = @new \mysqli(
  4208.             $cx->getDbUrl(),
  4209.             $cx->getDbUser(),
  4210.             $cx->getDbPassword(),
  4211.             $cx->getDbName(),
  4212.             (int)$cx->getDbPort()
  4213.         );
  4214.         if ($mysqli->connect_error) {
  4215.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4216.             return $this->redirectToRoute('list');
  4217.         }
  4219.         $editContractId = max(0, (int)$request->query->get('edit_contract_id', 0));
  4220.         $editLicenseFormData = [];
  4221.         if ($editContractId > 0) {
  4222.             $editContract = $this->licenseContractService->loadContractById($mysqli, $editContractId);
  4223.             if (!empty($editContract)) {
  4224.                 $editLicenseFormData = [
  4225.                     'license_type' => (string)($editContract['type'] ?? 'page'),
  4226.                     'license_mode' => (string)($editContract['mode'] ?? 'monthly'),
  4227.                     'license_limit_mode' => (string)($editContract['limit_mode'] ?? 'block'),
  4228.                     'license_units_total' => (string)($editContract['units_total'] ?? '0'),
  4229.                     'license_units_used' => (string)($editContract['units_used'] ?? '0'),
  4230.                     'license_units_exceeded' => (string)($editContract['units_exceeded'] ?? '0'),
  4231.                     'license_start_date' => (string)($editContract['start_date'] ?? ''),
  4232.                     'license_end_date' => (string)($editContract['end_date'] ?? ''),
  4233.                 ];
  4234.             } else {
  4235.                 $editContractId = 0;
  4236.                 $this->addFlash('warning', 'La licencia indicada no existe.');
  4237.             }
  4238.         }
  4240.         $response = $this->renderEmpresaLicensePage($empresa, $mysqli, $editContractId > 0 ? $editContractId : null, $editLicenseFormData);
  4241.         $mysqli->close();
  4243.         return $response;
  4244.     }
  4246.     public function empresaLicenseUpdate(Request $request, EntityManagerInterface $em)
  4247.     {
  4248.         if (!$this->getUser() || !is_object($this->getUser())) {
  4249.             return $this->redirectToRoute('logout');
  4250.         }
  4252.         $id = (int)$request->get('id');
  4253.         $contractId = (int)$request->get('contractId');
  4254.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4255.         if (!$empresa) {
  4256.             throw $this->createNotFoundException('Empresa no encontrada');
  4257.         }
  4259.         $cx = $empresa->getConexionBD();
  4260.         $mysqli = @new \mysqli(
  4261.             $cx->getDbUrl(),
  4262.             $cx->getDbUser(),
  4263.             $cx->getDbPassword(),
  4264.             $cx->getDbName(),
  4265.             (int)$cx->getDbPort()
  4266.         );
  4267.         if ($mysqli->connect_error) {
  4268.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4269.             return $this->redirectToRoute('list');
  4270.         }
  4272.         $data = $request->request->all();
  4273.         try {
  4274.             $normalizedData = $this->licenseContractService->normalizePayload($data, true);
  4275.             $this->licenseContractService->updateContract($mysqli, $contractId, $normalizedData);
  4276.             $this->addFlash('success', 'Licencia actualizada correctamente.');
  4277.             $mysqli->close();
  4278.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4279.         } catch (\InvalidArgumentException $e) {
  4280.             $this->addFlash('danger', $e->getMessage());
  4281.         } catch (\Throwable $e) {
  4282.             $this->addFlash('danger', 'Error al actualizar la licencia: ' . $e->getMessage());
  4283.         }
  4285.         $response = $this->renderEmpresaLicensePage($empresa, $mysqli, $contractId, $data);
  4286.         $mysqli->close();
  4288.         return $response;
  4289.     }
  4291.     public function empresaLicenseDelete(Request $request, EntityManagerInterface $em)
  4292.     {
  4293.         if (!$this->getUser() || !is_object($this->getUser())) {
  4294.             return $this->redirectToRoute('logout');
  4295.         }
  4297.         $id = (int)$request->get('id');
  4298.         $contractId = (int)$request->get('contractId');
  4299.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4300.         if (!$empresa) {
  4301.             throw $this->createNotFoundException('Empresa no encontrada');
  4302.         }
  4304.         $cx = $empresa->getConexionBD();
  4305.         $mysqli = @new \mysqli(
  4306.             $cx->getDbUrl(),
  4307.             $cx->getDbUser(),
  4308.             $cx->getDbPassword(),
  4309.             $cx->getDbName(),
  4310.             (int)$cx->getDbPort()
  4311.         );
  4312.         if ($mysqli->connect_error) {
  4313.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4314.             return $this->redirectToRoute('list');
  4315.         }
  4317.         try {
  4318.             $this->licenseContractService->deleteContract($mysqli, $contractId);
  4319.             $this->addFlash('success', 'Licencia eliminada correctamente.');
  4320.         } catch (\Throwable $e) {
  4321.             $this->addFlash('danger', 'Error al eliminar la licencia: ' . $e->getMessage());
  4322.         }
  4324.         $mysqli->close();
  4326.         return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4327.     }
  4329.     public function empresaLicenseExport(Request $request, EntityManagerInterface $em)
  4330.     {
  4331.         if (!$this->getUser() || !is_object($this->getUser())) {
  4332.             return $this->redirectToRoute('logout');
  4333.         }
  4335.         $id = (int)$request->get('id');
  4336.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4337.         if (!$empresa) {
  4338.             throw $this->createNotFoundException('Empresa no encontrada');
  4339.         }
  4341.         try {
  4342.             $mysqli = $this->openEmpresaMysqli($empresa);
  4343.         } catch (\Throwable $e) {
  4344.             $this->addFlash('danger', $e->getMessage());
  4345.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4346.         }
  4348.         try {
  4349.             $rows = $this->buildTenantLicenseExportRows(
  4350.                 $empresa,
  4351.                 $mysqli
  4352.             );
  4353.         } catch (\Throwable $e) {
  4354.             $mysqli->close();
  4355.             $this->addFlash('danger', 'Error al exportar licencias: ' . $e->getMessage());
  4356.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4357.         }
  4359.         $mysqli->close();
  4361.         return $this->createLicenseCsvResponse(
  4362.             sprintf('license-history-tenant-%d.csv', $id),
  4363.             $this->tenantLicenseExportColumns(),
  4364.             $rows
  4365.         );
  4366.     }
  4368.     public function empresaLicenseExportAll(Request $request, EntityManagerInterface $em)
  4369.     {
  4370.         if (!$this->getUser() || !is_object($this->getUser())) {
  4371.             return $this->redirectToRoute('logout');
  4372.         }
  4374.         try {
  4375.             $range = $this->licenseContractService->validateExportRange(
  4376.                 $request->query->get('export_start_date'),
  4377.                 $request->query->get('export_end_date')
  4378.             );
  4379.         } catch (\InvalidArgumentException $e) {
  4380.             $this->addFlash('danger', $e->getMessage());
  4381.             return $this->redirectToRoute('list');
  4382.         }
  4384.         $rows = [];
  4385.         $empresas = $em->getRepository(Empresa::class)->findAll();
  4386.         foreach ($empresas as $empresa) {
  4387.             try {
  4388.                 $mysqli = $this->openEmpresaMysqli($empresa);
  4389.                 try {
  4390.                     $tenantRows = $this->buildTenantLicenseSummaryRows(
  4391.                         $empresa,
  4392.                         $mysqli,
  4393.                         $range['start_date'],
  4394.                         $range['end_date']
  4395.                     );
  4396.                     foreach ($tenantRows as $row) {
  4397.                         $rows[] = $row;
  4398.                     }
  4399.                 } finally {
  4400.                     $mysqli->close();
  4401.                 }
  4402.             } catch (\Throwable $e) {
  4403.                 $rows[] = $this->createTenantConnectionErrorRow(
  4404.                     $empresa,
  4405.                     $range['start_date'],
  4406.                     $range['end_date']
  4407.                 );
  4408.             }
  4409.         }
  4411.         return $this->createLicenseCsvResponse(
  4412.             sprintf(
  4413.                 'license-summary-all-tenants-%s-to-%s.csv',
  4414.                 $range['start_date'],
  4415.                 $range['end_date']
  4416.             ),
  4417.             $this->licenseSummaryExportColumns(),
  4418.             $rows
  4419.         );
  4420.     }
  4422.     private function renderEmpresaLicensePage(Empresa $empresa, \mysqli $mysqli, ?int $editContractId = null, array $editLicenseFormData = [])
  4423.     {
  4424.         $activeLicenseContract = $this->licenseContractService->loadActiveContract($mysqli);
  4425.         $licenseContractHistory = $this->licenseContractService->loadContractHistory($mysqli);
  4426.         $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($licenseContractHistory);
  4428.         return $this->render('empresa/licenses.html.twig', [
  4429.             'empresa' => $empresa,
  4430.             'activeLicenseContract' => $activeLicenseContract,
  4431.             'licenseContractHistory' => $licenseContractHistory,
  4432.             'visualActiveContractId' => $visualActiveContractId,
  4433.             'editContractId' => $editContractId,
  4434.             'editLicenseFormData' => $editLicenseFormData,
  4435.         ]);
  4436.     }
  4438.     public function empresaLicenseCreate(Request $request, EntityManagerInterface $em)
  4439.     {
  4440.         if (!$this->getUser() || !is_object($this->getUser())) {
  4441.             return $this->redirectToRoute('logout');
  4442.         }
  4444.         $id = (int)$request->get('id');
  4445.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4446.         if (!$empresa) {
  4447.             throw $this->createNotFoundException('Empresa no encontrada');
  4448.         }
  4450.         $cx = $empresa->getConexionBD();
  4451.         $mysqli = @new \mysqli(
  4452.             $cx->getDbUrl(),
  4453.             $cx->getDbUser(),
  4454.             $cx->getDbPassword(),
  4455.             $cx->getDbName(),
  4456.             (int)$cx->getDbPort()
  4457.         );
  4458.         if ($mysqli->connect_error) {
  4459.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4460.             return $this->redirectToRoute('list');
  4461.         }
  4463.         $data = $request->request->all();
  4465.         try {
  4466.             $normalizedData = $this->licenseContractService->normalizePayload($data, false);
  4467.             $this->licenseContractService->createNewContract($mysqli, $normalizedData);
  4468.             $this->addFlash('success', 'Nueva licencia creada correctamente.');
  4469.         } catch (\InvalidArgumentException $e) {
  4470.             $this->addFlash('danger', $e->getMessage());
  4471.         } catch (\Throwable $e) {
  4472.             $this->addFlash('danger', 'Error al crear la licencia: ' . $e->getMessage());
  4473.         }
  4474.         $mysqli->close();
  4476.         return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4477.     }
  4479.     private function openEmpresaMysqli(Empresa $empresa): \mysqli
  4480.     {
  4481.         $cx = $empresa->getConexionBD();
  4482.         if (!$cx) {
  4483.             throw new \RuntimeException('La empresa no tiene configurada una conexion de base de datos.');
  4484.         }
  4486.         $mysqli = @new \mysqli(
  4487.             $cx->getDbUrl(),
  4488.             $cx->getDbUser(),
  4489.             $cx->getDbPassword(),
  4490.             $cx->getDbName(),
  4491.             (int)$cx->getDbPort()
  4492.         );
  4494.         if ($mysqli->connect_error) {
  4495.             throw new \RuntimeException('No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4496.         }
  4498.         return $mysqli;
  4499.     }
  4501.     private function tenantLicenseExportColumns(): array
  4502.     {
  4503.         return [
  4504.             'tenant_id',
  4505.             'tenant_name',
  4506.             'license_status',
  4507.             'contract_type',
  4508.             'contract_mode',
  4509.             'limit_mode',
  4510.             'units_total',
  4511.             'units_used',
  4512.             'units_exceeded',
  4513.             'contract_start_date',
  4514.             'contract_end_date',
  4515.         ];
  4516.     }
  4518.     private function licenseSummaryExportColumns(): array
  4519.     {
  4520.         return [
  4521.             'tenant_id',
  4522.             'tenant_name',
  4523.             'range_start',
  4524.             'range_end',
  4525.             'contract_type',
  4526.             'contract_mode',
  4527.             'limit_mode',
  4528.             'units_total',
  4529.             'units_used',
  4530.             'units_exceeded',
  4531.         ];
  4532.     }
  4534.     private function buildTenantLicenseExportRows(Empresa $empresa, \mysqli $mysqli): array
  4535.     {
  4536.         $history = $this->licenseContractService->loadContractHistory($mysqli);
  4537.         $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($history);
  4538.         $rows = [];
  4540.         foreach ($history as $contract) {
  4541.             $rows[] = [
  4542.                 'tenant_id' => (string)$empresa->getId(),
  4543.                 'tenant_name' => (string)$empresa->getName(),
  4544.                 'license_status' => ((int)($contract['id'] ?? 0) === (int)$visualActiveContractId) ? 'Activa' : 'Cerrada',
  4545.                 'contract_type' => (string)($contract['type'] ?? ''),
  4546.                 'contract_mode' => (string)($contract['mode'] ?? ''),
  4547.                 'limit_mode' => (string)($contract['limit_mode'] ?? ''),
  4548.                 'units_total' => (string)max(0, (int)($contract['units_total'] ?? 0)),
  4549.                 'units_used' => (string)max(0, (int)($contract['units_used'] ?? 0)),
  4550.                 'units_exceeded' => (string)max(0, (int)($contract['units_exceeded'] ?? 0)),
  4551.                 'contract_start_date' => (string)($contract['start_date'] ?? ''),
  4552.                 'contract_end_date' => (string)($contract['end_date'] ?? ''),
  4553.             ];
  4554.         }
  4556.         return $rows;
  4557.     }
  4559.     private function buildTenantLicenseSummaryRows(Empresa $empresa, \mysqli $mysqli, string $rangeStart, string $rangeEnd): array
  4560.     {
  4561.         $contracts = $this->licenseContractService->loadContractsStartingWithinRange($mysqli, $rangeStart, $rangeEnd);
  4562.         $aggregatedRows = [];
  4564.         foreach ($contracts as $contract) {
  4565.             $contractType = trim((string)($contract['type'] ?? ''));
  4566.             $contractMode = trim((string)($contract['mode'] ?? ''));
  4567.             $limitMode = trim((string)($contract['limit_mode'] ?? ''));
  4568.             $groupKey = implode('|', [
  4569.                 $empresa->getId(),
  4570.                 $contractType,
  4571.                 $contractMode,
  4572.                 $limitMode,
  4573.             ]);
  4575.             if (!isset($aggregatedRows[$groupKey])) {
  4576.                 $aggregatedRows[$groupKey] = [
  4577.                     'tenant_id' => (string)$empresa->getId(),
  4578.                     'tenant_name' => (string)$empresa->getName(),
  4579.                     'range_start' => $rangeStart,
  4580.                     'range_end' => $rangeEnd,
  4581.                     'contract_type' => $contractType,
  4582.                     'contract_mode' => $contractMode,
  4583.                     'limit_mode' => $limitMode,
  4584.                     'units_total' => 0,
  4585.                     'units_used' => 0,
  4586.                     'units_exceeded' => 0,
  4587.                 ];
  4588.             }
  4590.             $aggregatedRows[$groupKey]['units_total'] += max(0, (int)($contract['units_total'] ?? 0));
  4591.             $aggregatedRows[$groupKey]['units_used'] += max(0, (int)($contract['units_used'] ?? 0));
  4592.             $aggregatedRows[$groupKey]['units_exceeded'] += max(0, (int)($contract['units_exceeded'] ?? 0));
  4593.         }
  4595.         $rows = [];
  4596.         foreach ($aggregatedRows as $row) {
  4597.             $rows[] = [
  4598.                 'tenant_id' => (string)$empresa->getId(),
  4599.                 'tenant_name' => (string)$empresa->getName(),
  4600.                 'range_start' => $rangeStart,
  4601.                 'range_end' => $rangeEnd,
  4602.                 'contract_type' => (string)$row['contract_type'],
  4603.                 'contract_mode' => (string)$row['contract_mode'],
  4604.                 'limit_mode' => (string)$row['limit_mode'],
  4605.                 'units_total' => (string)$row['units_total'],
  4606.                 'units_used' => (string)$row['units_used'],
  4607.                 'units_exceeded' => (string)$row['units_exceeded'],
  4608.             ];
  4609.         }
  4611.         return $rows;
  4612.     }
  4614.     private function createTenantConnectionErrorRow(Empresa $empresa, string $rangeStart, string $rangeEnd): array
  4615.     {
  4616.         return [
  4617.             'tenant_id' => (string)$empresa->getId(),
  4618.             'tenant_name' => (string)$empresa->getName(),
  4619.             'range_start' => $rangeStart,
  4620.             'range_end' => $rangeEnd,
  4621.             'contract_type' => '',
  4622.             'contract_mode' => '',
  4623.             'limit_mode' => '',
  4624.             'units_total' => '',
  4625.             'units_used' => '',
  4626.             'units_exceeded' => '',
  4627.         ];
  4628.     }
  4630.     private function createLicenseCsvResponse(string $filename, array $columns, array $rows): StreamedResponse
  4631.     {
  4632.         $response = new StreamedResponse(function () use ($columns, $rows): void {
  4633.             $out = fopen('php://output', 'wb');
  4634.             if ($out === false) {
  4635.                 throw new \RuntimeException('No se pudo abrir la salida CSV.');
  4636.             }
  4638.             fwrite($out, "\xEF\xBB\xBF");
  4639.             fputcsv($out, $columns, ';');
  4641.             foreach ($rows as $row) {
  4642.                 $csvRow = [];
  4643.                 foreach ($columns as $column) {
  4644.                     $csvRow[] = (string)($row[$column] ?? '');
  4645.                 }
  4646.                 fputcsv($out, $csvRow, ';');
  4647.             }
  4649.             fclose($out);
  4650.         });
  4652.         $response->headers->set('Content-Type', 'text/csv; charset=UTF-8');
  4653.         $response->headers->set('Content-Disposition', 'attachment; filename="' . $filename . '"');
  4655.         return $response;
  4656.     }
  4658.     private function loadEmpresaParametros(\mysqli $mysqli): array
  4659.     {
  4660.         // claves que nos interesan en la tabla parametros
  4661.         $keys = [
  4662.             'activeUsers',
  4663.             'soloExtraccion',
  4664.             'modulo_etiquetas',
  4665.             'modulo_calendario',
  4666.             'modulo_calExt',
  4667.             'modulo_estados',
  4668.             'modulo_subida',
  4669.             'modulo_mailMonitor',
  4670.             'modulo_busquedaNatural',
  4671.             'modulo_extraccion',
  4672.             'modulo_lineas',
  4673.             'modulo_agora',
  4674.             'modulo_gstock',
  4675.             'modulo_expowin',
  4676.             'modulo_prinex',
  4677.             'extraction_model',
  4678.             'ocr_mode',
  4679.             'tokensContratados',
  4680.             'tokensUsados',
  4681.         ];
  4682.         $placeholders = implode(',', array_fill(0, count($keys), '?'));
  4684.         $sql = "SELECT nombre, valor FROM parametros WHERE nombre IN ($placeholders)";
  4685.         $stmt = $mysqli->prepare($sql);
  4686.         if (!$stmt) {
  4687.             throw new \RuntimeException('Prepare SELECT parametros: ' . $mysqli->error);
  4688.         }
  4690.         // bind dinámico
  4691.         $types = str_repeat('s', count($keys));
  4692.         $stmt->bind_param($types, ...$keys);
  4693.         if (!$stmt->execute()) {
  4694.             $stmt->close();
  4695.             throw new \RuntimeException('Execute SELECT parametros: ' . $stmt->error);
  4696.         }
  4698.         $res = $stmt->get_result();
  4699.         $map = [];
  4700.         while ($row = $res->fetch_assoc()) {
  4701.             $map[$row['nombre']] = $row['valor'];
  4702.         }
  4703.         $stmt->close();
  4705.         // defaults seguros
  4706.         $activeUsers = isset($map['activeUsers']) ? (int)$map['activeUsers'] : 3;
  4708.         $flags = [
  4709.             'soloExtraccion'   => isset($map['soloExtraccion'])   ? (int)$map['soloExtraccion']   : 0,
  4710.             'modulo_etiquetas'  => isset($map['modulo_etiquetas'])  ? (int)$map['modulo_etiquetas']  : 0,
  4711.             'modulo_calendario' => isset($map['modulo_calendario']) ? (int)$map['modulo_calendario'] : 0,
  4712.             'modulo_calExt'     => isset($map['modulo_calExt'])     ? (int)$map['modulo_calExt']     : 0,
  4713.             'modulo_estados'    => isset($map['modulo_estados'])    ? (int)$map['modulo_estados']    : 0,
  4714.             'modulo_subida'     => isset($map['modulo_subida'])     ? (int)$map['modulo_subida']     : 0,
  4715.             'modulo_extraccion' => isset($map['modulo_extraccion']) ? (int)$map['modulo_extraccion'] : 0,
  4716.             'modulo_lineas'     => isset($map['modulo_lineas'])     ? (int)$map['modulo_lineas']     : 0,
  4717.             'modulo_agora'      => isset($map['modulo_agora'])      ? (int)$map['modulo_agora']      : 0,
  4718.             'modulo_gstock'     => isset($map['modulo_gstock'])     ? (int)$map['modulo_gstock']     : 0,
  4719.             'modulo_expowin'    => isset($map['modulo_expowin'])    ? (int)$map['modulo_expowin']    : 0,
  4720.             'modulo_prinex'     => isset($map['modulo_prinex'])     ? (int)$map['modulo_prinex']     : 0,
  4721.             'modulo_mailMonitor' => isset($map['modulo_mailMonitor']) ? (int)$map['modulo_mailMonitor'] : 0,
  4722.             'modulo_busquedaNatural' => isset($map['modulo_busquedaNatural']) ? (int)$map['modulo_busquedaNatural'] : 0,
  4723.         ];
  4725.         // extraction_model: default 0 (sin modelo)
  4726.         $flags['extraction_model'] = isset($map['extraction_model']) && $map['extraction_model'] !== '' ? (int)$map['extraction_model'] : 0;
  4727.         $flags['ocr_mode'] = $this->normalizeOcrMode($map['ocr_mode'] ?? 'base');
  4728.         $flags['tokensContratados'] = isset($map['tokensContratados']) && $map['tokensContratados'] !== ''
  4729.             ? max(0, (int)$map['tokensContratados'])
  4730.             : 0;
  4731.         $flags['tokensUsados'] = isset($map['tokensUsados']) && $map['tokensUsados'] !== ''
  4732.             ? max(0, (int)$map['tokensUsados'])
  4733.             : 0;
  4735.         return [$activeUsers, $flags];
  4736.     }
  4738.     private function updateEmpresaParametros(\mysqli $mysqli, array $data): void
  4739.     {
  4740.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  4741.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  4743.         $paramMap = [
  4744.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  4745.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  4746.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  4747.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  4748.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  4749.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  4750.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  4751.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  4752.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  4753.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  4754.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  4755.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  4756.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  4757.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  4758.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  4759.             'extraction_model'   => $getInt($data, 'extraction_model', 0),
  4760.             'ocr_mode'           => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  4761.             'tokensContratados'  => max(0, $getInt($data, 'tokensContratados', 0)),
  4762.         ];
  4764.         if ($paramMap['modulo_extraccion'] === 0) {
  4765.             $paramMap['modulo_lineas'] = 0;
  4766.             $paramMap['extraction_model'] = 0;
  4767.             $paramMap['modulo_agora'] = 0;
  4768.             $paramMap['modulo_gstock'] = 0;
  4769.             $paramMap['modulo_expowin'] = 0;
  4770.             $paramMap['modulo_prinex'] = 0;
  4771.         }
  4772.         if ($paramMap['modulo_calendario'] === 0) {
  4773.             $paramMap['modulo_calExt'] = 0;
  4774.         }
  4776.         $mysqli->begin_transaction();
  4777.         try {
  4778.             $stmt = $mysqli->prepare("
  4779.                 INSERT INTO parametros (nombre, valor)
  4780.                 VALUES (?, ?)
  4781.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  4782.             ");
  4783.             if (!$stmt) {
  4784.                 throw new \RuntimeException('Prepare UPSERT parametros: ' . $mysqli->error);
  4785.             }
  4787.             foreach ($paramMap as $nombre => $valor) {
  4788.                 $v = (string)$valor;
  4789.                 if (!$stmt->bind_param('ss', $nombre, $v) || !$stmt->execute()) {
  4790.                     $stmt->close();
  4791.                     throw new \RuntimeException("Guardar parámetro {$nombre}: {$stmt->error}");
  4792.                 }
  4793.             }
  4795.             $stmt->close();
  4796.             $mysqli->commit();
  4797.         } catch (\Throwable $e) {
  4798.             $mysqli->rollback();
  4799.             throw $e;
  4800.         }
  4801.     }
  4803.     private function loadLicense(\mysqli $mysqli): array
  4804.     {
  4805.         // Carga opcional para mostrar en la edición: capacityGb/users (u otros)
  4806.         $sql = "SELECT client, capacityGb, users FROM license LIMIT 1";
  4807.         $res = $mysqli->query($sql);
  4808.         if ($res && $row = $res->fetch_assoc()) {
  4809.             return $row;
  4810.         }
  4811.         return [];
  4812.     }
  4814.     private function updateLicense(\mysqli $mysqli, array $data, string $clientName): void
  4815.     {
  4816.         $capacityGb  = isset($data['maxDiskQuota']) ? (int)$data['maxDiskQuota'] : 200;
  4817.         $activeUsers = isset($data['maxActiveUsers']) ? (int)$data['maxActiveUsers'] : 3;
  4819.         $stmt = $mysqli->prepare("UPDATE license SET capacityGb = ?, users = ? WHERE client = ?");
  4820.         if (!$stmt) {
  4821.             throw new \RuntimeException('Prepare UPDATE license: ' . $mysqli->error);
  4822.         }
  4824.         $stmt->bind_param('iis', $capacityGb, $activeUsers, $clientName);
  4825.         $stmt->execute();
  4826.         $stmt->close();
  4827.     }
  4829.     public function usersListEmpresa(Request $request, EntityManagerInterface $em)
  4830.     {
  4831.         $id = $request->get("id");
  4832.         $users_empresa = $em->getRepository(Usuario::class)->findBy(array("empresa" => $id));
  4834.         return $this->render('empresa/usersList.html.twig', array(
  4835.             'users' => $users_empresa,
  4836.             'id' => $id
  4837.         ));
  4838.     }
  4840.     private function loadEmpresaDiskUsageBytes(\mysqli $mysqli): ?int
  4841.     {
  4842.         // Si la tabla no existe o hay error, devolvemos null para no romper la vista
  4843.         $sql = "SELECT COALESCE(SUM(size_bytes), 0) AS total_bytes FROM files";
  4844.         $res = $mysqli->query($sql);
  4846.         if (!$res) {
  4847.             return null;
  4848.         }
  4850.         $row = $res->fetch_assoc();
  4851.         $res->free();
  4853.         return isset($row['total_bytes']) ? (int)$row['total_bytes'] : 0;
  4854.     }
  4856.     // =======================================================================
  4857.     // VER DOCUMENTACION DE EMPRESAS
  4858.     // =======================================================================
  4860.     #[Route('/empresa/{id}/documentos', name: 'empresa_documentos', methods: ['GET'])]
  4861.     public function documentosEmpresa(Request $request, EntityManagerInterface $em)
  4862.     {
  4863.         if (!$this->getUser() || !is_object($this->getUser())) {
  4864.             return $this->redirectToRoute('logout');
  4865.         }
  4867.         $id = (int) $request->get('id');
  4868.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4870.         if (!$empresa) {
  4871.             $this->addFlash('warning', 'Empresa no encontrada.');
  4872.             return $this->redirectToRoute('list');
  4873.         }
  4875.         // Para el desplegable
  4876.         $empresas = $em->getRepository(Empresa::class)->findAll();
  4877.         $baseUrl = $this->getParameter('documanager_base_url');
  4879.         return $this->render('empresa/documentos.html.twig', [
  4880.             'empresaId' => $id,
  4881.             'empresas'  => $empresas,
  4882.             'documanagerBaseUrl' => $baseUrl,
  4883.         ]);
  4884.     }
  4886.     #[Route('/api/empresa/{id}/documentos', name: 'empresa_documentos_api', methods: ['GET'])]
  4887.     public function documentosEmpresaApi(Request $request, EntityManagerInterface $em): JsonResponse
  4888.     {
  4889.         if (!$this->getUser() || !is_object($this->getUser())) {
  4890.             return new JsonResponse(['error' => 'unauthorized'], 401);
  4891.         }
  4893.         $id = (int) $request->get('id');
  4894.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4896.         if (!$empresa) {
  4897.             return new JsonResponse(['error' => 'Empresa no encontrada'], 404);
  4898.         }
  4900.         $cx = $empresa->getConexionBD();
  4901.         if (!$cx) {
  4902.             return new JsonResponse(['error' => 'La empresa no tiene conexión configurada'], 400);
  4903.         }
  4905.         $page    = max(1, (int) $request->query->get('page', 1));
  4906.         $perPage = (int) $request->query->get('per_page', 50);
  4907.         $perPage = min(max($perPage, 10), 200);
  4908.         $q       = (string) $request->query->get('q', '');
  4909.         $offset  = ($page - 1) * $perPage;
  4911.         $mysqli = @new \mysqli(
  4912.             $cx->getDbUrl(),
  4913.             $cx->getDbUser(),
  4914.             $cx->getDbPassword(),
  4915.             $cx->getDbName(),
  4916.             (int) $cx->getDbPort()
  4917.         );
  4919.         if ($mysqli->connect_error) {
  4920.             return new JsonResponse(['error' => 'Error conectando a la BD del cliente: ' . $mysqli->connect_error], 500);
  4921.         }
  4923.         $mysqli->set_charset('utf8mb4');
  4925.         // --- TOTAL ---
  4926.         if ($q === '') {
  4927.             $sqlTotal = "SELECT COUNT(*) AS c FROM files";
  4928.             $res = $mysqli->query($sqlTotal);
  4929.             $row = $res ? $res->fetch_assoc() : null;
  4930.             $total = (int)($row['c'] ?? 0);
  4931.         } else {
  4932.             $sqlTotal = "SELECT COUNT(*) AS c
  4933.                          FROM files
  4934.                          WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?";
  4935.             $qLike = '%' . $q . '%';
  4936.             $st = $mysqli->prepare($sqlTotal);
  4937.             $st->bind_param('ssss', $qLike, $qLike, $qLike, $qLike);
  4938.             $st->execute();
  4939.             $res = $st->get_result();
  4940.             $row = $res ? $res->fetch_assoc() : null;
  4941.             $total = (int)($row['c'] ?? 0);
  4942.             $st->close();
  4943.         }
  4945.         // --- ITEMS ---
  4946.         $items = [];
  4948.         if ($q === '') {
  4949.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  4950.                     FROM files
  4951.                     ORDER BY `date` DESC
  4952.                     LIMIT ? OFFSET ?";
  4953.             $st = $mysqli->prepare($sql);
  4954.             $st->bind_param('ii', $perPage, $offset);
  4955.         } else {
  4956.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  4957.                     FROM files
  4958.                     WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?
  4959.                     ORDER BY `date` DESC
  4960.                     LIMIT ? OFFSET ?";
  4961.             $qLike = '%' . $q . '%';
  4962.             $st = $mysqli->prepare($sql);
  4963.             $st->bind_param('ssssii', $qLike, $qLike, $qLike, $qLike, $perPage, $offset);
  4964.         }
  4966.         $st->execute();
  4967.         $res = $st->get_result();
  4968.         if ($res) {
  4969.             while ($r = $res->fetch_assoc()) {
  4970.                 $items[] = $r;
  4971.             }
  4972.         }
  4973.         $st->close();
  4974.         $mysqli->close();
  4976.         return new JsonResponse([
  4977.             'company_id' => $id,
  4978.             'page'       => $page,
  4979.             'per_page'   => $perPage,
  4980.             'total'      => $total,
  4981.             'items'      => $items,
  4982.         ]);
  4983.     }
  4984. }