src/Controller/AdminController.php line 55

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_lineas'] = isset($data['modulo_lineas']) && $toBool($data['modulo_lineas']) ? 1 : 0;
  1939.             $data['modulo_conciliacion'] = isset($data['modulo_conciliacion']) && $toBool($data['modulo_conciliacion']) ? 1 : 0;
  1940.             $data['modulo_precios'] = isset($data['modulo_precios']) && $toBool($data['modulo_precios']) ? 1 : 0;
  1941.             $data['modulo_ubikos'] = isset($data['modulo_ubikos']) && $toBool($data['modulo_ubikos']) ? 1 : 0;
  1942.             $data['modulo_expowin'] = isset($data['modulo_expowin']) && $toBool($data['modulo_expowin']) ? 1 : 0;
  1943.             $data['modulo_prinex'] = isset($data['modulo_prinex']) && $toBool($data['modulo_prinex']) ? 1 : 0;
  1945.             $extractorType = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  1946.             $data['extractor_type'] = $extractorType;
  1947.             $azureResource = null;
  1948.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  1949.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  1950.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  1951.             $aoaiFields = $this->collectAoaiFieldsFromRequest($req);
  1952.             $enricherEnabled = isset($data['enricher_enabled']) && $toBool($data['enricher_enabled']);
  1953.             $enricherResourceId = (int)($data['enricher_resource_id'] ?? 0);
  1954.             $enricherFields = $this->collectEnricherFieldsFromRequest($req);
  1956.             $renderAddWithData = function () use ($azureResources, $azureDiResources, $azureOpenAiResources, $data, $aoaiFields, $enricherFields, $enricherEnabled) {
  1957.                 $contractPreview = $this->licenseContractService->defaultContract();
  1958.                 try {
  1959.                     $contractPreview = $this->licenseContractService->contractFromPayload($data);
  1960.                 } catch (\Throwable $e) {
  1961.                     // Mantener preview por defecto si los datos de licencia son inválidos.
  1962.                 }
  1963.                 return $this->render('empresa/_add.html.twig', [
  1964.                     'azure_resources' => $azureResources,
  1965.                     'azure_di_resources' => $azureDiResources,
  1966.                     'azure_openai_resources' => $azureOpenAiResources,
  1967.                     'modulos' => [
  1968.                         'extraction_model' => 0,
  1969.                     ],
  1970.                     'form_data' => $data,
  1971.                     'activeLicenseContract' => $contractPreview,
  1972.                     'aoai_fields' => $aoaiFields,
  1973.                     'enricher' => [
  1974.                         'enabled' => $enricherEnabled ? 1 : 0,
  1975.                         'aoai_resource_id' => (int)($data['enricher_resource_id'] ?? 0),
  1976.                         'fields' => $enricherFields,
  1977.                     ],
  1978.                     'ocr_plus_available' => $ocrPlusAvailable,
  1979.                     'ocr_v2_available' => $ocrV2Available,
  1980.                 ]);
  1981.             };
  1983.             try {
  1984.                 $data = $this->licenseContractService->normalizePayload($data, false);
  1985.             } catch (\InvalidArgumentException $e) {
  1986.                 $this->addFlash('danger', $e->getMessage());
  1987.                 return $renderAddWithData();
  1988.             }
  1990.             if ($data['modulo_extraccion'] === 1) {
  1991.                 if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1992.                     if ($aoaiResourceId <= 0) {
  1993.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  1994.                         return $renderAddWithData();
  1995.                     }
  1996.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  1997.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  1998.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  1999.                         return $renderAddWithData();
  2000.                     }
  2001.                     $validationError = $this->validateAoaiFields($aoaiFields);
  2002.                     if ($validationError !== null) {
  2003.                         $this->addFlash('danger', $validationError);
  2004.                         return $renderAddWithData();
  2005.                     }
  2006.                 } else {
  2007.                     if ($azureResourceId <= 0 || $azureModelId === '') {
  2008.                         $this->addFlash('danger', 'Para activar extraccion debes seleccionar recurso y modelo IA.');
  2009.                         return $renderAddWithData();
  2010.                     }
  2012.                     $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  2013.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  2014.                         $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  2015.                         return $renderAddWithData();
  2016.                     }
  2018.                     try {
  2019.                         $this->azureRequest(
  2020.                             (string)$azureResource['endpoint'],
  2021.                             (string)$azureResource['api_key'],
  2022.                             '/documentintelligence/documentModels/' . rawurlencode($azureModelId)
  2023.                         );
  2024.                     } catch (\Throwable $e) {
  2025.                         $this->addFlash('danger', 'No se pudo validar el modelo IA: ' . $e->getMessage());
  2026.                         return $renderAddWithData();
  2027.                     }
  2028.                 }
  2030.                 if ($enricherEnabled) {
  2031.                     if ($enricherResourceId <= 0) {
  2032.                         $this->addFlash('danger', 'Para activar el enricher debes seleccionar un recurso Azure OpenAI.');
  2033.                         return $renderAddWithData();
  2034.                     }
  2035.                     $enricherResource = $this->loadAzureResourceById($em, $enricherResourceId);
  2036.                     if (!$enricherResource || ($enricherResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  2037.                         $this->addFlash('danger', 'El recurso Azure OpenAI del enricher no existe.');
  2038.                         return $renderAddWithData();
  2039.                     }
  2040.                     $validationError = $this->validateAoaiFields($enricherFields);
  2041.                     if ($validationError !== null) {
  2042.                         $this->addFlash('danger', $validationError);
  2043.                         return $renderAddWithData();
  2044.                     }
  2045.                 }
  2046.             } else {
  2047.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  2048.                 $data['azure_resource_id'] = 0;
  2049.                 $data['azure_model_id'] = '';
  2050.                 $data['aoai_resource_id'] = 0;
  2051.                 $data['enricher_enabled'] = 0;
  2052.                 $data['enricher_resource_id'] = 0;
  2053.                 $data['extraction_model'] = 0;
  2054.                 $data['modulo_lineas'] = 0;
  2055.                 $data['modulo_conciliacion'] = 0;
  2056.                 $data['modulo_precios'] = 0;
  2057.                 $data['modulo_ubikos'] = 0;
  2058.                 $data['modulo_expowin'] = 0;
  2059.                 $data['modulo_prinex'] = 0;
  2060.             }
  2062.             if ($data['modulo_extraccion'] === 0) {
  2063.                 $data['modulo_lineas'] = 0;
  2064.                 $data['modulo_conciliacion'] = 0;
  2065.                 $data['modulo_precios'] = 0;
  2066.                 $data['modulo_ubikos'] = 0;
  2067.             }
  2068.             if ($data['modulo_lineas'] === 0) {
  2069.                 $data['modulo_precios'] = 0;
  2070.             }
  2072.             // Crear nombre de base de datos y credenciales aleatorios
  2073.             $dbName = 'doc_' . bin2hex(random_bytes(3));
  2074.             $dbUser = 'doc_' . bin2hex(random_bytes(2));
  2075.             $dbPass = bin2hex(random_bytes(8));
  2076.             $dbHost = 'localhost';
  2077.             $dbPort = '3306';
  2079.             // Credenciales de HestiaCP desde variables de entorno
  2080.             $hestiaApiUrl = $_ENV['HESTIA_API_URL'];
  2081.             $hestiaApiUser = $_ENV['HESTIA_API_USER'];
  2082.             $hestiaApiPass = $_ENV['HESTIA_API_PASS'];
  2083.             $hestiaOwner   = $_ENV['HESTIA_OWNER'];
  2084.             $accessKeyId   = $_ENV['HESTIA_ACCESS_KEY_ID'] ?? '';
  2085.             $secretKey     = $_ENV['HESTIA_SECRET_KEY'] ?? '';
  2087.             // Variables para el script de bash
  2088.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  2089.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  2090.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  2091.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  2092.             if ($ocrMode === 'plus_glm') {
  2093.                 $ocrBinary = $ocrBinaryPlus;
  2094.             } elseif ($ocrMode === 'v2_zxing') {
  2095.                 $ocrBinary = $ocrBinaryV2;
  2096.             } else {
  2097.                 $ocrBinary = $ocrBinaryBase;
  2098.             }
  2099.             $filesPath  = $_ENV['FILES_PATH'];
  2100.             if (($data['ocr_mode'] ?? 'base') === 'plus_glm' && trim($ocrBinaryPlus) === '') {
  2101.                 $this->addFlash('danger', 'OCR+ seleccionado pero falta configurar OCR_PLUS_BINARY en .env.local.');
  2102.                 return $renderAddWithData();
  2103.             }
  2104.             if (($data['ocr_mode'] ?? 'base') === 'v2_zxing' && trim($ocrBinaryV2) === '') {
  2105.                 $this->addFlash('danger', 'OCR v2 seleccionado pero falta configurar OCR_BINARY_V2 en .env.local.');
  2106.                 return $renderAddWithData();
  2107.             }
  2108.             if (($data['ocr_mode'] ?? 'base') === 'base' && trim($ocrBinaryBase) === '') {
  2109.                 $this->addFlash('danger', 'OCR Base seleccionado pero falta configurar OCR_BINARY en .env.local.');
  2110.                 return $renderAddWithData();
  2111.             }
  2112.             if (trim((string)$filesPath) === '') {
  2113.                 $this->addFlash('danger', 'Falta configurar FILES_PATH en .env.local.');
  2114.                 return $renderAddWithData();
  2115.             }
  2117.             $owner = $hestiaOwner; // o el dueńo del hosting
  2119.             $postFields = http_build_query([
  2120.                 'user' => $hestiaApiUser,
  2121.                 'password' => $hestiaApiPass,
  2122.                 'returncode' => 'yes',
  2123.                 'cmd' => 'v-add-database',
  2124.                 'arg1' => $owner,
  2125.                 'arg2' => $dbName,
  2126.                 'arg3' => $dbUser,
  2127.                 'arg4' => $dbPass,
  2128.                 'arg5' => 'mysql'
  2129.             ]);
  2130.             //dd($postFields);            
  2131.             $headers = [
  2132.                 'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  2133.             ];
  2136.             $ch = curl_init();
  2137.             curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  2138.             curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  2139.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2140.             curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2141.             curl_setopt($ch, CURLOPT_POST, true);
  2142.             curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  2143.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  2145.             $response = curl_exec($ch);
  2146.             $error = curl_error($ch);
  2147.             curl_close($ch);
  2149.             if ($error || trim($response) !== '0') {
  2150.                 $this->addFlash('danger', 'Error al crear la base de datos en HestiaCP: ' . ($error ?: $response));
  2151.                 return $this->redirectToRoute('app_empresa_new');
  2152.             }
  2154.             //Añadir sql
  2155.             $sqlFile = __DIR__ . '/../../db/db_base.sql'; // Ajusta la ruta si está en otro sitio
  2157.             if (!file_exists($sqlFile)) {
  2158.                 $this->addFlash('danger', 'Archivo db_base.sql no encontrado.');
  2159.                 return $this->redirectToRoute('app_empresa_new');
  2160.             }
  2163.             $mysqli = new \mysqli($dbHost, "{$owner}_{$dbUser}", $dbPass, "{$owner}_{$dbName}", (int)$dbPort);
  2165.             if ($mysqli->connect_error) {
  2166.                 $this->addFlash('danger', 'Error al conectar a la base de datos: ' . $mysqli->connect_error);
  2167.                 return $this->redirectToRoute('app_empresa_new');
  2168.             }
  2170.             $sql = file_get_contents($sqlFile);
  2172.             // Eliminar lĂ­neas con DELIMITER
  2173.             $sql = preg_replace('/DELIMITER\s+\$\$/', '', $sql);
  2174.             $sql = preg_replace('/DELIMITER\s+;/', '', $sql);
  2176.             // Separar por ';;' si los triggers usan ese delimitador (ajusta si es $$)
  2177.             $statements = explode('$$', $sql);
  2179.             foreach ($statements as $statementIndex => $stmt) {
  2180.                 $stmt = trim($stmt);
  2181.                 if ($stmt) {
  2182.                     try {
  2183.                         if (!$mysqli->multi_query($stmt)) {
  2184.                             $this->addFlash('danger', 'Error ejecutando SQL: ' . $mysqli->error);
  2185.                             return $this->redirectToRoute('app_empresa_new');
  2186.                         }
  2188.                         // Limpiar cualquier resultado intermedio del bloque ejecutado.
  2189.                         do {
  2190.                             if ($result = $mysqli->store_result()) {
  2191.                                 $result->free();
  2192.                             }
  2193.                         } while ($mysqli->more_results() && $mysqli->next_result());
  2194.                     } catch (\mysqli_sql_exception $e) {
  2195.                         $sqlSnippet = mb_substr(preg_replace('/\s+/', ' ', $stmt), 0, 220);
  2196.                         $this->addFlash(
  2197.                             'danger',
  2198.                             sprintf(
  2199.                                 'Error ejecutando SQL en bloque %d: %s. Sentencia: %s',
  2200.                                 $statementIndex + 1,
  2201.                                 $e->getMessage(),
  2202.                                 $sqlSnippet
  2203.                             )
  2204.                         );
  2205.                         return $this->redirectToRoute('app_empresa_new');
  2206.                     }
  2207.                 }
  2208.             }
  2210.             $updateSql = "UPDATE users SET email = '" . $mysqli->real_escape_string((string)$data["user"]) . "' WHERE id = 1";
  2212.             if (!$mysqli->query($updateSql)) {
  2213.                 $this->addFlash('danger', 'Error al actualizar usuario: ' . $mysqli->error);
  2214.                 return $this->redirectToRoute('app_empresa_new');
  2215.             }
  2217.             // Guardar parámetros (activeUsers + modulos_*) en la BD del cliente
  2218.             $localExtractionModelId = 0;
  2219.             if ($data['modulo_extraccion'] === 1) {
  2220.                 try {
  2221.                     if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  2222.                         $localExtractionModelId = $this->registerAoaiModelInClientDb(
  2223.                             $mysqli,
  2224.                             $azureResource ?? [],
  2225.                             $aoaiFields
  2226.                         );
  2227.                     } else {
  2228.                         $localExtractionModelId = $this->registerDiModelInClientDb(
  2229.                             $mysqli,
  2230.                             $azureResource ?? [],
  2231.                             $azureModelId
  2232.                         );
  2233.                     }
  2234.                 } catch (\Throwable $e) {
  2235.                     $this->addFlash('danger', 'No se pudo registrar el modelo en la BBDD cliente: ' . $e->getMessage());
  2236.                     $mysqli->close();
  2237.                     return $this->redirectToRoute('app_empresa_new');
  2238.                 }
  2239.             }
  2240.             $data['extraction_model'] = $localExtractionModelId;
  2242.             if ($data['modulo_extraccion'] === 1 && $localExtractionModelId > 0 && $enricherEnabled) {
  2243.                 try {
  2244.                     $enricherResource = $this->loadAzureResourceById($em, $enricherResourceId);
  2245.                     $this->registerAoaiEnricherInClientDb(
  2246.                         $mysqli,
  2247.                         $localExtractionModelId,
  2248.                         $enricherResource ?? [],
  2249.                         $enricherFields,
  2250.                         true
  2251.                     );
  2252.                 } catch (\Throwable $e) {
  2253.                     $this->addFlash('danger', 'No se pudo registrar el enricher en la BBDD cliente: ' . $e->getMessage());
  2254.                     $mysqli->close();
  2255.                     return $this->redirectToRoute('app_empresa_new');
  2256.                 }
  2257.             }
  2259.             // SUBIR LOGO PERSONALIZADO (SI LO HAY) ===
  2260.             $customLogoFile = null;
  2261.             try {
  2262.                 $customLogoFile = $this->uploadEmpresaLogo($req);
  2263.             } catch (\Throwable $e) {
  2264.                 // Aquí decides si quieres que esto sea fatal o solo un aviso
  2265.                 $this->addFlash('warning', 'El logo personalizado no se pudo subir: ' . $e->getMessage());
  2266.                 // Si quieres abortar todo el proceso por fallo de logo, haz return+redirect aquí.
  2267.             }
  2269.             // Guardar logo en la BD del cliente
  2270.             $this->saveEmpresaLogo($mysqli, $data, $customLogoFile);
  2272.             // Actualizar/insertar license (capacityGb y users) en la BD del cliente
  2273.             $this->upsertLicense(
  2274.                 $mysqli,
  2275.                 $data,
  2276.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== '' ? (int)$data['maxDiskQuota'] : 200,
  2277.                 isset($data['maxActiveUsers']) && $data['maxActiveUsers'] !== '' ? (int)$data['maxActiveUsers'] : 3
  2278.             );
  2280.             // Guardar parametros (activeUsers + modulos_*) en la BD del cliente
  2281.             $this->saveEmpresaParametros($mysqli, $data);
  2282.             $this->licenseContractService->createInitialContract($mysqli, $data);
  2283.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  2284.                 try {
  2285.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  2286.                 } catch (\Throwable $e) {
  2287.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  2288.                 }
  2289.             }
  2291.             // Crear y persistir la empresa
  2292.             $emp = new Empresa();
  2293.             $emp->setName($data["name"]);
  2294.             $emp->setMaxDiskQuota((int)$data["maxDiskQuota"]);
  2295.             $emp->setMaxThreads($maxThreads);
  2299.             $em->persist($emp);
  2300.             $em->flush();
  2302.             $conexionBD = new ConexionBD();
  2303.             $conexionBD->setDbName($owner . "_" . $dbName);
  2304.             $conexionBD->setDbUser($owner . "_" . $dbUser);
  2305.             $conexionBD->setDbPassword($dbPass);
  2306.             $conexionBD->setDbUrl($dbHost);
  2307.             $conexionBD->setDbPort($dbPort);
  2308.             $em->persist($conexionBD);
  2309.             $em->flush();
  2312.             $emp->setConexionBD($conexionBD);
  2313.             $em->persist($emp);
  2314.             $em->flush();
  2316.             //crear usuario
  2317.             $user = new \App\Entity\Usuario();
  2318.             $user->setEmail($data["user"]);
  2319.             $user->setEmpresa($emp);
  2320.             $user->setPassword("dscsdcsno2234dwvw");
  2321.             $user->setStatus(1);
  2322.             $user->setIsAdmin(2);
  2323.             $user->setConnection($conexionBD->getId());
  2325.             $em->persist($user);
  2326.             $em->flush();
  2328.             //crear el script de bash
  2329.             $company_name = $emp->getId();
  2331.             // "DOCU_MAX_THREADS=" por defecto 4
  2332.             // "NO" al final es para desactivar FTP
  2334.             // Crear archivo .service
  2335.             $empresaName = (string)($data['name'] ?? '');
  2336.             $serviceContent = <<<EOT
  2337. [Unit]
  2338. Description={$empresaName} DocuManager OCR
  2339. Requires=mariadb.service
  2340. After=mariadb.service
  2342. [Service]
  2343. Type=simple
  2344. Environment="DOCU_MAX_THREADS=$maxThreads"
  2345. ExecStart=$ocrBinary localhost/{$owner}_{$dbName} {$owner}_{$dbUser} {$dbPass} {$filesPath}/{$company_name} NO
  2346. Restart=always
  2347. User=docunecta
  2349. [Install]
  2350. WantedBy=multi-user.target
  2351. EOT;
  2354.             // Guardar contenido temporal en un archivo dentro de /tmp
  2355.             $serviceName = $company_name . "-documanager.service";
  2356.             $tmpServicePath = "/tmp/$serviceName";
  2357.             file_put_contents($tmpServicePath, $serviceContent);
  2358.             \chmod($tmpServicePath, 0644);
  2360.             // Mover el archivo y habilitar el servicio desde PHP con shell_exec
  2361.             $commands = [
  2362.                 "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  2363.                 "sudo /bin/systemctl daemon-reload",
  2364.                 "sudo /bin/systemctl enable $serviceName",
  2365.                 "sudo /bin/systemctl start $serviceName",
  2366.             ];
  2367.             $errors = [];
  2368.             foreach ($commands as $cmd) {
  2369.                 $output = \shell_exec($cmd . " 2>&1");
  2370.                 if ($output !== null) {
  2371.                     // Puedes loguearlo si quieres para ver errores
  2372.                     error_log("CMD OUTPUT: $cmd\n$output");
  2373.                     $errors[] = "CMD OUTPUT: $cmd\n$output";
  2374.                 }
  2375.             }
  2377.             // === Crear servicio AZURE DI por tenant ===
  2378.             $azureBasePort = 12000;
  2379.             $tenantId      = (int)$emp->getId();
  2380.             $port          = $this->azurePortForTenant($tenantId, $azureBasePort, 20999);
  2381.             $serviceName   = $tenantId . "-azuredi.service";
  2382.             $workdir       = $this->azureDiWorkdirFromEnv();
  2383.             $docuPhpBaseUrl = $this->azureDiPhpBaseUrl($req);
  2384.             if ($workdir !== '' && $docuPhpBaseUrl !== '') {
  2385.                 $logsDir = $workdir . "/logs/" . $tenantId;
  2387.                 // Asegura carpeta de logs
  2388.                 @mkdir($logsDir, 0775, true);
  2390.                 $serviceContent = <<<EOT
  2391. [Unit]
  2392. Description=DocuManager Azure DI {$tenantId}
  2393. After=network.target
  2395. [Service]
  2396. User=root
  2397. WorkingDirectory={$workdir}
  2399. Environment=APP_HOST=127.0.0.1
  2400. Environment=APP_PORT={$port}
  2401. Environment=LOG_DIR={$logsDir}
  2402. Environment=PYTHONUNBUFFERED=1
  2403. Environment=MAX_CONCURRENT=20
  2404. Environment="PATH=/opt/azure-di/.venv/bin:/usr/local/bin:/usr/bin"
  2405. EnvironmentFile=-{$workdir}/.env
  2407. # ---- Scheduler interno de extracción ----
  2408. Environment=EXTRACT_TICK_ENABLED=1
  2409. Environment=EXTRACT_TICK_INTERVAL_SEC=10
  2410. Environment=DOCU_TENANT_ID={$tenantId}
  2411. Environment=EXTRACT_TICK_LIMIT=30
  2412. Environment=EXTRACT_TICK_TIMEOUT_SEC=25
  2413. Environment=EXTRACT_TICK_LOCK_FILE=/tmp/azure_di_extract_tick_{$tenantId}.lock
  2415. # Ajustar URL base pública/interna de PHP
  2416. Environment=DOCU_PHP_BASE_URL={$docuPhpBaseUrl}
  2418. # Debe coincidir con EXTRACT_INTERNAL_TOKEN del lado PHP
  2419. Environment=EXTRACT_INTERNAL_TOKEN=8c7e7a1b4d0f6e2a9c1d3f5b7a8e0c2d4f6a1b3c5d7e9f0a2c4e6b8d0f1a3c5
  2421. ExecStart=/opt/azure-di/.venv/bin/python -m uvicorn app.main:app --host 127.0.0.1 --port {$port} --proxy-headers --workers 2
  2423. Restart=always
  2424. RestartSec=2
  2425. StandardOutput=journal
  2426. StandardError=journal
  2428. [Install]
  2429. WantedBy=multi-user.target
  2430. EOT;
  2432.                 $tmpServicePath = "/tmp/{$serviceName}";
  2433.                 file_put_contents($tmpServicePath, $serviceContent);
  2434.                 @chmod($tmpServicePath, 0644);
  2436.                 $cmds = [
  2437.                     "sudo /bin/mv {$tmpServicePath} /etc/systemd/system/{$serviceName}",
  2438.                     "sudo /bin/systemctl daemon-reload",
  2439.                     "sudo /bin/systemctl enable {$serviceName}",
  2440.                     "sudo /bin/systemctl start {$serviceName}",
  2441.                 ];
  2442.                 foreach ($cmds as $cmd) {
  2443.                     $out = \shell_exec($cmd . " 2>&1");
  2444.                     if ($out !== null) {
  2445.                         error_log("AZURE-DI CMD: $cmd\n$out");
  2446.                     }
  2447.                 }
  2448.             } else {
  2449.                 $missing = [];
  2450.                 if ($workdir === '') $missing[] = 'AZURE_DI_WORKDIR';
  2451.                 if ($docuPhpBaseUrl === '') $missing[] = 'AZURE_DI_DOCU_PHP_BASE_URL';
  2452.                 $this->addFlash('warning', 'No se pudo crear el servicio de extraccion IA: faltan variables de entorno: ' . implode(', ', $missing));
  2453.             }
  2455.             // === Crear servicio/timer Mail Monitor si el modulo esta activo ===
  2456.             if ($mailMonitorEnabled) {
  2457.                 $this->ensureMailMonitorService(
  2458.                     (int)$company_name,
  2459.                     (string)$dbHost,
  2460.                     (string)$dbPort,
  2461.                     (string)$owner . "_" . (string)$dbUser,
  2462.                     (string)$dbPass,
  2463.                     (string)$owner . "_" . (string)$dbName,
  2464.                     (string)$filesPath
  2465.                 );
  2466.             }
  2468.             if (count($errors) > 0) {
  2469.                 $this->addFlash('success', 'Empresa y base de datos creadas correctamente: ' . implode(" | ", $errors));
  2470.             }
  2474.             $this->addFlash('success', 'Empresa y base de datos creadas correctamente.');
  2475.             return $this->redirectToRoute('list');
  2476.         } else {
  2477.             // Carga recursos IA para el formulario de alta
  2478.             return $this->render('empresa/_add.html.twig', [
  2479.                 'azure_resources' => $azureResources,
  2480.                 'azure_di_resources' => $azureDiResources,
  2481.                 'azure_openai_resources' => $azureOpenAiResources,
  2482.                 'modulos' => [
  2483.                     'extraction_model' => 0,
  2484.                 ],
  2485.                 'form_data' => [
  2486.                     'extractor_type' => self::EXTRACTOR_TYPE_AZURE_DI,
  2487.                     'ocr_mode' => 'base',
  2488.                     'license_type' => 'page',
  2489.                     'license_mode' => 'monthly',
  2490.                     'license_limit_mode' => 'block',
  2491.                     'license_start_date' => date('Y-m-d'),
  2492.                     'license_units_total' => 1000,
  2493.                 ],
  2494.                 'activeLicenseContract' => $this->licenseContractService->defaultContract(),
  2495.                 'aoai_fields' => [],
  2496.                 'enricher' => [
  2497.                     'enabled' => 0,
  2498.                     'aoai_resource_id' => 0,
  2499.                     'fields' => [],
  2500.                 ],
  2501.                 'ocr_plus_available' => $ocrPlusAvailable,
  2502.                 'ocr_v2_available' => $ocrV2Available,
  2503.             ]);
  2504.         }
  2505.     }
  2507.     private function saveEmpresaParametros(\mysqli $mysqli, array $data): void
  2508.     {
  2509.         // Helpers
  2510.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  2511.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  2513.         // Keys y valores tal y como quieres guardarlos
  2514.         $paramMap = [
  2515.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  2517.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  2519.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  2520.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  2521.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  2522.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  2523.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  2524.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  2525.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  2526.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  2527.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  2528.             'modulo_conciliacion' => $getFlag($data, 'modulo_conciliacion'),
  2529.             'modulo_precios'     => $getFlag($data, 'modulo_precios'),
  2530.             'modulo_ubikos'      => $getFlag($data, 'modulo_ubikos'),
  2531.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  2532.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  2533.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  2534.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  2536.             'extraction_model'  => $getInt($data, 'extraction_model', 0),
  2537.             'ocr_mode'          => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  2538.             'tokensContratados' => max(0, $getInt($data, 'tokensContratados', 0)),
  2539.         ];
  2541.         if ($paramMap['modulo_extraccion'] === 0) {
  2542.             $paramMap['modulo_lineas'] = 0;
  2543.             $paramMap['modulo_conciliacion'] = 0;
  2544.             $paramMap['modulo_precios'] = 0;
  2545.             $paramMap['modulo_ubikos'] = 0;
  2546.             $paramMap['modulo_expowin'] = 0;
  2547.             $paramMap['modulo_prinex'] = 0;
  2548.         }
  2549.         if ($paramMap['modulo_lineas'] === 0) {
  2550.             $paramMap['modulo_precios'] = 0;
  2551.         }
  2553.         // RECOMENDADO en tu SQL base:
  2554.         // ALTER TABLE parametros ADD UNIQUE KEY uniq_nombre (nombre);
  2555.         $mysqli->begin_transaction();
  2556.         try {
  2557.             $stmt = $mysqli->prepare("
  2558.                 INSERT INTO parametros (nombre, valor)
  2559.                 VALUES (?, ?)
  2560.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2561.             ");
  2562.             if (!$stmt) {
  2563.                 throw new \RuntimeException('Prepare parametros: ' . $mysqli->error);
  2564.             }
  2566.             foreach ($paramMap as $nombre => $valor) {
  2567.                 // valor es TEXT en tu esquema: bindeamos como string
  2568.                 $v = (string)$valor;
  2569.                 $stmt->bind_param('ss', $nombre, $v);
  2570.                 if (!$stmt->execute()) {
  2571.                     throw new \RuntimeException("Guardar parámetro $nombre: " . $stmt->error);
  2572.                 }
  2573.             }
  2575.             $stmt->close();
  2576.             $mysqli->commit();
  2577.         } catch (\Throwable $e) {
  2578.             $mysqli->rollback();
  2580.             // Si NO puedes ańadir UNIQUE(nombre), usa fallback DELETE+INSERT:
  2581.             // $this->saveParametrosFallback($mysqli, $paramMap);
  2583.             throw $e;
  2584.         }
  2585.     }
  2587.     private function applyGstockAutoMappings(\mysqli $mysqli, int $modelId): void
  2588.     {
  2589.         if ($modelId <= 0) {
  2590.             return;
  2591.         }
  2593.         $available = [
  2594.             'header' => [],
  2595.             'line' => [],
  2596.         ];
  2598.         $stmtHeader = $mysqli->prepare('SELECT field_key FROM definitions_header WHERE model_id = ?');
  2599.         if (!$stmtHeader) {
  2600.             throw new \RuntimeException('Prepare SELECT definitions_header para automapeo Gstock: ' . $mysqli->error);
  2601.         }
  2602.         $stmtHeader->bind_param('i', $modelId);
  2603.         if (!$stmtHeader->execute()) {
  2604.             $stmtHeader->close();
  2605.             throw new \RuntimeException('Execute SELECT definitions_header para automapeo Gstock: ' . $stmtHeader->error);
  2606.         }
  2607.         $resHeader = $stmtHeader->get_result();
  2608.         while ($resHeader && ($row = $resHeader->fetch_assoc())) {
  2609.             $fieldKey = (string)($row['field_key'] ?? '');
  2610.             if ($fieldKey !== '') {
  2611.                 $available['header'][$fieldKey] = true;
  2612.             }
  2613.         }
  2614.         $stmtHeader->close();
  2616.         $stmtLines = $mysqli->prepare('SELECT field_key FROM definitions_lines WHERE model_id = ?');
  2617.         if (!$stmtLines) {
  2618.             throw new \RuntimeException('Prepare SELECT definitions_lines para automapeo Gstock: ' . $mysqli->error);
  2619.         }
  2620.         $stmtLines->bind_param('i', $modelId);
  2621.         if (!$stmtLines->execute()) {
  2622.             $stmtLines->close();
  2623.             throw new \RuntimeException('Execute SELECT definitions_lines para automapeo Gstock: ' . $stmtLines->error);
  2624.         }
  2625.         $resLines = $stmtLines->get_result();
  2626.         while ($resLines && ($row = $resLines->fetch_assoc())) {
  2627.             $fieldKey = (string)($row['field_key'] ?? '');
  2628.             if ($fieldKey !== '') {
  2629.                 $available['line'][$fieldKey] = true;
  2630.             }
  2631.         }
  2632.         $stmtLines->close();
  2634.         $existing = [];
  2635.         $stmtExisting = $mysqli->prepare('SELECT type, source, destination FROM gstock_mapping WHERE model_id = ?');
  2636.         if (!$stmtExisting) {
  2637.             throw new \RuntimeException('Prepare SELECT gstock_mapping para automapeo: ' . $mysqli->error);
  2638.         }
  2639.         $stmtExisting->bind_param('i', $modelId);
  2640.         if (!$stmtExisting->execute()) {
  2641.             $stmtExisting->close();
  2642.             throw new \RuntimeException('Execute SELECT gstock_mapping para automapeo: ' . $stmtExisting->error);
  2643.         }
  2644.         $resExisting = $stmtExisting->get_result();
  2645.         while ($resExisting && ($row = $resExisting->fetch_assoc())) {
  2646.             $type = (string)($row['type'] ?? '');
  2647.             $source = (string)($row['source'] ?? '');
  2648.             $destination = (string)($row['destination'] ?? '');
  2649.             if ($type !== '' && $source !== '' && $destination !== '') {
  2650.                 $existing[$type . '|' . $source . '|' . $destination] = true;
  2651.             }
  2652.         }
  2653.         $stmtExisting->close();
  2655.         $mysqli->begin_transaction();
  2656.         try {
  2657.             $stmtInsert = $mysqli->prepare(
  2658.                 'INSERT INTO gstock_mapping (model_id, type, source, destination) VALUES (?, ?, ?, ?)'
  2659.             );
  2660.             if (!$stmtInsert) {
  2661.                 throw new \RuntimeException('Prepare INSERT gstock_mapping para automapeo: ' . $mysqli->error);
  2662.             }
  2664.             foreach (GstockAutoMappings::MAPPINGS as $type => $pairs) {
  2665.                 foreach ($pairs as $pair) {
  2666.                     $source = (string)($pair['source'] ?? '');
  2667.                     $destination = (string)($pair['destination'] ?? '');
  2668.                     if ($source === '' || $destination === '') {
  2669.                         continue;
  2670.                     }
  2671.                     if ($type === 'header' && !isset($available['header'][$source])) {
  2672.                         continue;
  2673.                     }
  2674.                     if ($type === 'line' && !isset($available['line'][$source])) {
  2675.                         continue;
  2676.                     }
  2677.                     $key = $type . '|' . $source . '|' . $destination;
  2678.                     if (isset($existing[$key])) {
  2679.                         continue;
  2680.                     }
  2681.                     $stmtInsert->bind_param('isss', $modelId, $type, $source, $destination);
  2682.                     if (!$stmtInsert->execute()) {
  2683.                         $stmtInsert->close();
  2684.                         throw new \RuntimeException('Execute INSERT gstock_mapping para automapeo: ' . $stmtInsert->error);
  2685.                     }
  2686.                     $existing[$key] = true;
  2687.                 }
  2688.             }
  2690.             $stmtInsert->close();
  2691.             $mysqli->commit();
  2692.         } catch (\Throwable $e) {
  2693.             $mysqli->rollback();
  2694.             throw $e;
  2695.         }
  2696.     }
  2698.     private function saveEmpresaLogo(\mysqli $mysqli, array $data, ?string $customLogoFile = null): void
  2699.     {
  2700.         $this->logLogo('empresa_logo_save.log', '--- NUEVA LLAMADA saveEmpresaLogo ---');
  2701.         $this->logLogo('empresa_logo_save.log', 'customLogoFile = ' . var_export($customLogoFile, true));
  2702.         $this->logLogo('empresa_logo_save.log', 'data[empresa_vendor] = ' . var_export($data['empresa_vendor'] ?? null, true));
  2704.         // 1) Decidir qué logo vamos a guardar
  2705.         $logoFile = null;
  2707.         // --- PRIORIDAD: LOGO PERSONALIZADO ---
  2708.         if ($customLogoFile !== null && $customLogoFile !== '') {
  2709.             $logoFile = $customLogoFile;
  2710.             $this->logLogo('empresa_logo_save.log', 'Usando logo personalizado: ' . $logoFile);
  2711.         } else {
  2712.             // --- SI NO HAY PERSONALIZADO, USAMOS EL SELECT DE EMPRESA ---
  2713.             if (!isset($data['empresa_vendor']) || $data['empresa_vendor'] === '') {
  2714.                 $this->logLogo('empresa_logo_save.log', 'No hay empresa_vendor y no hay logo custom. No hago nada.');
  2715.                 return;
  2716.             }
  2718.             $empresa = $data['empresa_vendor'];
  2719.             $empresaKey = strtolower(trim((string)$empresa));
  2721.             $logoMap = [
  2722.                 'docunecta'  => 'DocuManager_transparente.png',
  2723.                 'docuindexa' => 'DocuIndexa.png',
  2724.             ];
  2725.             $vendorLabelMap = [
  2726.                 'docunecta'  => 'Docunecta',
  2727.                 'docuindexa' => 'Docuindexa',
  2728.             ];
  2730.             if (!isset($logoMap[$empresaKey])) {
  2731.                 $this->logLogo('empresa_logo_save.log', "empresa_vendor $empresa no está en logoMap. No hago nada.");
  2732.                 return;
  2733.             }
  2735.             $logoFile = $logoMap[$empresaKey];
  2736.             $vendorLabel = $vendorLabelMap[$empresaKey] ?? null;
  2737.             $this->logLogo('empresa_logo_save.log', 'Usando logo por vendor: ' . $logoFile);
  2738.         }
  2740.         if ($logoFile === null || $logoFile === '') {
  2741.             $this->logLogo('empresa_logo_save.log', 'logoFile está vacío. No hago nada.');
  2742.             return;
  2743.         }
  2745.         $this->logLogo('empresa_logo_save.log', 'Voy a guardar en parametros.logo: ' . $logoFile);
  2747.         $mysqli->begin_transaction();
  2749.         try {
  2750.             $stmt = $mysqli->prepare("
  2751.                 INSERT INTO parametros (nombre, valor)
  2752.                 VALUES (?, ?)
  2753.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  2754.             ");
  2756.             if (!$stmt) {
  2757.                 $this->logLogo('empresa_logo_save.log', 'Error prepare: ' . $mysqli->error);
  2758.                 throw new \RuntimeException('Prepare logo: ' . $mysqli->error);
  2759.             }
  2761.             $paramName = 'logo';
  2762.             $stmt->bind_param('ss', $paramName, $logoFile);
  2764.             if (!$stmt->execute()) {
  2765.                 $this->logLogo('empresa_logo_save.log', 'Error execute: ' . $stmt->error);
  2766.                 throw new \RuntimeException('Guardar parámetro logo: ' . $stmt->error);
  2767.             }
  2769.             if (isset($vendorLabel) && $vendorLabel !== '') {
  2770.                 $paramName = 'vendor';
  2771.                 $stmt->bind_param('ss', $paramName, $vendorLabel);
  2772.                 if (!$stmt->execute()) {
  2773.                     $this->logLogo('empresa_logo_save.log', 'Error execute vendor: ' . $stmt->error);
  2774.                     throw new \RuntimeException('Guardar parámetro vendor: ' . $stmt->error);
  2775.                 }
  2776.             }
  2778.             $stmt->close();
  2779.             $mysqli->commit();
  2780.             $this->logLogo('empresa_logo_save.log', 'Logo guardado correctamente en BD.');
  2781.         } catch (\Throwable $e) {
  2782.             $mysqli->rollback();
  2783.             $this->logLogo('empresa_logo_save.log', 'EXCEPCIÓN: ' . $e->getMessage());
  2784.             throw $e;
  2785.         }
  2786.     }
  2788.     private function uploadEmpresaLogo(Request $req): ?string
  2789.     {
  2790.         $this->logLogo('empresa_logo_upload.log', '--- NUEVA LLAMADA uploadEmpresaLogo ---');
  2792.         // name del checkbox en el formulario (ajústalo si usas otro)
  2793.         $useCustomLogo = $req->request->get('customLogoCheck');
  2794.         $this->logLogo('empresa_logo_upload.log', 'customLogoCheck = ' . var_export($useCustomLogo, true));
  2796.         // Si no marcaron "usar logo personalizado", no hacemos nada
  2797.         if (!$useCustomLogo) {
  2798.             $this->logLogo('empresa_logo_upload.log', 'No se ha marcado customLogoCheck. Salgo sin subir.');
  2799.             return null;
  2800.         }
  2802.         /** @var UploadedFile|null $file */
  2803.         $file = $req->files->get('logo_personalizado'); // name="logo_personalizado" en el input file
  2804.         $this->logLogo('empresa_logo_upload.log', 'FILES[logo_personalizado] = ' . print_r($file, true));
  2806.         if (!$file instanceof UploadedFile || !$file->isValid()) {
  2807.             $this->logLogo('empresa_logo_upload.log', 'File no es UploadedFile válido. Salgo sin subir.');
  2808.             return null;
  2809.         }
  2811.         // VALIDACIONES BÁSICAS
  2812.         $maxSize = 2 * 1024 * 1024; // 2 MB por ejemplo
  2813.         if ($file->getSize() > $maxSize) {
  2814.             $this->logLogo('empresa_logo_upload.log', 'Tamańo demasiado grande: ' . $file->getSize());
  2815.             throw new \RuntimeException('El logo personalizado es demasiado grande (máx 2MB).');
  2816.         }
  2818.         $mime = $file->getMimeType();
  2819.         $allowedMimeTypes = ['image/png', 'image/jpeg', 'image/webp', 'image/svg+xml'];
  2820.         $this->logLogo('empresa_logo_upload.log', 'MIME = ' . $mime);
  2822.         if (!in_array($mime, $allowedMimeTypes, true)) {
  2823.             $this->logLogo('empresa_logo_upload.log', 'MIME no permitido.');
  2824.             throw new \RuntimeException('Formato de logo no permitido. Usa PNG, JPG, WEBP o SVG.');
  2825.         }
  2827.         // Directorio destino según entorno (configurado en .env/.env.local)
  2828.         $targetDir = $_ENV['APP_LOGO_DIR'] ?? null;
  2829.         $this->logLogo('empresa_logo_upload.log', 'APP_LOGO_DIR = ' . var_export($targetDir, true));
  2831.         if (!$targetDir) {
  2832.             throw new \RuntimeException('APP_LOGO_DIR no está configurado en el entorno.');
  2833.         }
  2834.         if (!is_dir($targetDir)) {
  2835.             $this->logLogo('empresa_logo_upload.log', "El directorio no existe: $targetDir");
  2836.             throw new \RuntimeException("El directorio de logos no existe: $targetDir");
  2837.         }
  2838.         if (!is_writable($targetDir)) {
  2839.             $this->logLogo('empresa_logo_upload.log', "El directorio no es escribible: $targetDir");
  2840.             throw new \RuntimeException("El directorio de logos no es escribible: $targetDir");
  2841.         }
  2843.         // Nombre de archivo "seguro" y único
  2844.         $ext = $file->guessExtension() ?: 'png';
  2845.         $fileName = 'logo_empresa_' . bin2hex(random_bytes(6)) . '.' . $ext;
  2846.         $this->logLogo('empresa_logo_upload.log', "Voy a mover archivo como: $fileName");
  2848.         // Mover físicamente el archivo
  2849.         $file->move($targetDir, $fileName);
  2850.         $this->logLogo('empresa_logo_upload.log', "Fichero movido OK a $targetDir/$fileName");
  2852.         // Devolvemos SOLO el nombre, que es lo que se guardará en parametros.logo
  2853.         return $fileName;
  2854.     }
  2856.     private function logLogo(string $fileName, string $message): void
  2857.     {
  2858.         // Directorio de logs de Symfony (donde está dev.log/prod.log)
  2859.         $logDir = $this->getParameter('kernel.logs_dir');
  2861.         $fullPath = rtrim($logDir, '/') . '/' . $fileName;
  2863.         $line = sprintf(
  2864.             "[%s] %s\n",
  2865.             date('Y-m-d H:i:s'),
  2866.             $message
  2867.         );
  2869.         file_put_contents($fullPath, $line, FILE_APPEND);
  2870.     }
  2872.     private function loadEmpresaLogo(\mysqli $mysqli): ?string
  2873.     {
  2874.         $sql = "SELECT valor FROM parametros WHERE nombre = 'logo' LIMIT 1";
  2875.         $res = $mysqli->query($sql);
  2876.         if (!$res) {
  2877.             return null;
  2878.         }
  2879.         if ($row = $res->fetch_assoc()) {
  2880.             return $row['valor'] ?? null;
  2881.         }
  2882.         return null;
  2883.     }
  2885.     private function upsertLicense(\mysqli $mysqli, array $data, int $capacityGb = 200, int $activeUsers = 3): void
  2886.     {
  2887.         $clientName = (string)($data['name'] ?? '');
  2888.         $licenseStr  = 'Documanager';
  2889.         $initialDate = date('Y-m-d');
  2890.         $price       = 0;
  2891.         $emailSender = 'Documanager.es';
  2892.         $emailFrom   = 'no-reply@docunecta.com';
  2893.         $emailName   = 'Documanager';
  2894.         $ins = $mysqli->prepare("
  2895.             INSERT INTO license
  2896.                 (client, license, initialDate, capacityGb, users, price, emailSender, emailFrom, emailName)
  2897.             VALUES
  2898.                 (?,      ?,       ?,          ?,          ?,     ?,     ?,           ?,         ?)
  2899.         ");
  2900.         if (!$ins) {
  2901.             throw new \RuntimeException('Prepare INSERT license: ' . $mysqli->error);
  2902.         }
  2903.         $ins->bind_param(
  2904.             'sssiiisss',
  2905.             $clientName,
  2906.             $licenseStr,
  2907.             $initialDate,
  2908.             $capacityGb,
  2909.             $activeUsers,
  2910.             $price,
  2911.             $emailSender,
  2912.             $emailFrom,
  2913.             $emailName
  2914.         );
  2915.         if (!$ins->execute()) {
  2916.             $ins->close();
  2917.             throw new \RuntimeException('Execute INSERT license: ' . $ins->error);
  2918.         }
  2919.         $ins->close();
  2920.     }
  2922.     private function mapAzureSchemaToDefinitions(array $modelDetail): array
  2923.     {
  2924.         $docTypes = $modelDetail['docTypes'] ?? [];
  2925.         if (!is_array($docTypes) || $docTypes === []) {
  2926.             return ['header' => [], 'lines' => []];
  2927.         }
  2929.         $modelId = (string)($modelDetail['modelId'] ?? '');
  2930.         $docTypeKey = ($modelId !== '' && array_key_exists($modelId, $docTypes))
  2931.             ? $modelId
  2932.             : array_key_first($docTypes);
  2934.         if (!is_string($docTypeKey) || !isset($docTypes[$docTypeKey]) || !is_array($docTypes[$docTypeKey])) {
  2935.             return ['header' => [], 'lines' => []];
  2936.         }
  2938.         $fieldSchema = $docTypes[$docTypeKey]['fieldSchema'] ?? [];
  2939.         if (!is_array($fieldSchema)) {
  2940.             return ['header' => [], 'lines' => []];
  2941.         }
  2943.         $rawHeader = [];
  2944.         $rawLines = [];
  2945.         foreach ($fieldSchema as $fieldKey => $fieldDef) {
  2946.             if (!is_string($fieldKey) || !is_array($fieldDef)) {
  2947.                 continue;
  2948.             }
  2949.             $this->flattenFieldSchema($fieldKey, $fieldDef, $rawHeader, $rawLines);
  2950.         }
  2952.         $header = [];
  2953.         $lines = [];
  2954.         $seenHeader = [];
  2955.         $seenLines = [];
  2957.         foreach ($rawHeader as $item) {
  2958.             $key = (string)($item['field_key'] ?? '');
  2959.             if ($key === '' || isset($seenHeader[$key])) {
  2960.                 continue;
  2961.             }
  2962.             $seenHeader[$key] = true;
  2963.             $header[] = [
  2964.                 'field_key' => $key,
  2965.                 'label' => $key,
  2966.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2967.             ];
  2968.         }
  2970.         foreach ($rawLines as $item) {
  2971.             $key = (string)($item['field_key'] ?? '');
  2972.             if ($key === '' || isset($seenLines[$key])) {
  2973.                 continue;
  2974.             }
  2975.             $seenLines[$key] = true;
  2976.             $lines[] = [
  2977.                 'field_key' => $key,
  2978.                 'label' => $key,
  2979.                 'value_type' => $this->mapAzureTypeToValueType((string)($item['azure_type'] ?? '')),
  2980.             ];
  2981.         }
  2983.         foreach ($header as $index => &$item) {
  2984.             $order = $index + 1;
  2985.             $item['order_index'] = $order;
  2986.             $item['order_index_table'] = $order;
  2987.             $item['visibility'] = 1;
  2988.             $item['visibility_table'] = 1;
  2989.         }
  2991.         foreach ($lines as $index => &$item) {
  2992.             $item['order_index'] = $index + 1;
  2993.             $item['visibility'] = 1;
  2994.         }
  2996.         return ['header' => $header, 'lines' => $lines];
  2997.     }
  2999.     private function flattenFieldSchema(
  3000.         string $fieldKey,
  3001.         array $fieldDef,
  3002.         array &$header,
  3003.         array &$lines,
  3004.         bool $insideItems = false,
  3005.         string $parentPath = ''
  3006.     ): void {
  3007.         $type = strtolower((string)($fieldDef['type'] ?? 'string'));
  3008.         $currentPath = $parentPath !== '' ? $parentPath . '.' . $fieldKey : $fieldKey;
  3010.         if ($insideItems) {
  3011.             if ($type === 'object') {
  3012.                 $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  3013.                 if (is_array($properties)) {
  3014.                     foreach ($properties as $childKey => $childDef) {
  3015.                         if (is_string($childKey) && is_array($childDef)) {
  3016.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $currentPath);
  3017.                         }
  3018.                     }
  3019.                 }
  3020.                 return;
  3021.             }
  3023.             if ($type === 'array') {
  3024.                 $itemsDef = $fieldDef['items'] ?? [];
  3025.                 $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  3026.                 if ($itemType === 'object') {
  3027.                     $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  3028.                     if (is_array($properties)) {
  3029.                         $arrayPath = $currentPath . '[*]';
  3030.                         foreach ($properties as $childKey => $childDef) {
  3031.                             if (is_string($childKey) && is_array($childDef)) {
  3032.                                 $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, $arrayPath);
  3033.                             }
  3034.                         }
  3035.                     }
  3036.                 } else {
  3037.                     $lines[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  3038.                 }
  3039.                 return;
  3040.             }
  3042.             $lines[] = ['field_key' => $currentPath, 'azure_type' => $type];
  3043.             return;
  3044.         }
  3046.         if ($type === 'object') {
  3047.             $properties = $fieldDef['properties'] ?? $fieldDef['fields'] ?? [];
  3048.             if (is_array($properties)) {
  3049.                 foreach ($properties as $childKey => $childDef) {
  3050.                     if (is_string($childKey) && is_array($childDef)) {
  3051.                         $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $currentPath);
  3052.                     }
  3053.                 }
  3054.             }
  3055.             return;
  3056.         }
  3058.         if ($type === 'array') {
  3059.             $itemsDef = $fieldDef['items'] ?? [];
  3060.             $itemType = strtolower((string)($itemsDef['type'] ?? 'string'));
  3061.             $isItems = strtolower($fieldKey) === 'items';
  3063.             if ($itemType === 'object') {
  3064.                 $properties = $itemsDef['properties'] ?? $itemsDef['fields'] ?? [];
  3065.                 if (!is_array($properties)) {
  3066.                     return;
  3067.                 }
  3069.                 if ($isItems) {
  3070.                     foreach ($properties as $childKey => $childDef) {
  3071.                         if (is_string($childKey) && is_array($childDef)) {
  3072.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, true, '');
  3073.                         }
  3074.                     }
  3075.                 } else {
  3076.                     $arrayPath = $currentPath . '[*]';
  3077.                     foreach ($properties as $childKey => $childDef) {
  3078.                         if (is_string($childKey) && is_array($childDef)) {
  3079.                             $this->flattenFieldSchema($childKey, $childDef, $header, $lines, false, $arrayPath);
  3080.                         }
  3081.                     }
  3082.                 }
  3083.                 return;
  3084.             }
  3086.             $header[] = ['field_key' => $currentPath, 'azure_type' => $itemType];
  3087.             return;
  3088.         }
  3090.         $header[] = ['field_key' => $currentPath, 'azure_type' => $type];
  3091.     }
  3093.     private function mapAzureTypeToValueType(string $azureType): string
  3094.     {
  3095.         $azureType = strtolower(trim($azureType));
  3096.         if ($azureType === 'date') {
  3097.             return 'date';
  3098.         }
  3099.         if ($azureType === 'number' || $azureType === 'integer') {
  3100.             return 'number';
  3101.         }
  3102.         return 'string';
  3103.     }
  3105.     private function registerDiModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  3106.     {
  3107.         $modelId = trim($modelId);
  3108.         if ($modelId === '') {
  3109.             throw new \RuntimeException('ModelId de recurso IA obligatorio.', 400);
  3110.         }
  3112.         $modelDetail = $this->azureRequest(
  3113.             (string)($resource['endpoint'] ?? ''),
  3114.             (string)($resource['api_key'] ?? ''),
  3115.             '/documentintelligence/documentModels/' . rawurlencode($modelId)
  3116.         );
  3117.         $type = $this->classifyModelType($modelDetail);
  3118.         $definitions = $this->mapAzureSchemaToDefinitions($modelDetail);
  3120.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  3121.         $apiKey = (string)($resource['api_key'] ?? '');
  3122.         $showConfidenceBadges = 0;
  3124.         $clientMysqli->begin_transaction();
  3125.         try {
  3126.             $existingId = 0;
  3127.             $stmtSelect = $clientMysqli->prepare(
  3128.                 "SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? AND mode = 'full_extract' LIMIT 1"
  3129.             );
  3130.             if (!$stmtSelect) {
  3131.                 throw new \RuntimeException('Prepare SELECT extraction_models: ' . $clientMysqli->error);
  3132.             }
  3133.             $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  3134.             $stmtSelect->bind_param('ss', $provider, $modelId);
  3135.             if (!$stmtSelect->execute()) {
  3136.                 $stmtSelect->close();
  3137.                 throw new \RuntimeException('Execute SELECT extraction_models: ' . $stmtSelect->error);
  3138.             }
  3139.             $result = $stmtSelect->get_result();
  3140.             if ($result && ($row = $result->fetch_assoc())) {
  3141.                 $existingId = (int)$row['id'];
  3142.             }
  3143.             $stmtSelect->close();
  3145.             if ($existingId > 0) {
  3146.                 $stmtUpdate = $clientMysqli->prepare(
  3147.                     'UPDATE extraction_models
  3148.                      SET endpoint = ?, api_key = ?, type = ?, show_confidence_badges = ?
  3149.                      WHERE id = ?'
  3150.                 );
  3151.                 if (!$stmtUpdate) {
  3152.                     throw new \RuntimeException('Prepare UPDATE extraction_models: ' . $clientMysqli->error);
  3153.                 }
  3154.                 $stmtUpdate->bind_param('sssii', $endpoint, $apiKey, $type, $showConfidenceBadges, $existingId);
  3155.                 if (!$stmtUpdate->execute()) {
  3156.                     $stmtUpdate->close();
  3157.                     throw new \RuntimeException('Execute UPDATE extraction_models: ' . $stmtUpdate->error);
  3158.                 }
  3159.                 $stmtUpdate->close();
  3160.                 $localModelId = $existingId;
  3161.             } else {
  3162.                 $provider = self::EXTRACTOR_TYPE_AZURE_DI;
  3163.                 $stmtInsert = $clientMysqli->prepare(
  3164.                     'INSERT INTO extraction_models (provider, mode, model_id, endpoint, api_key, type, show_confidence_badges)
  3165.                      VALUES (?, ?, ?, ?, ?, ?, ?)'
  3166.                 );
  3167.                 if (!$stmtInsert) {
  3168.                     throw new \RuntimeException('Prepare INSERT extraction_models: ' . $clientMysqli->error);
  3169.                 }
  3170.                 $mode = 'full_extract';
  3171.                 $stmtInsert->bind_param('ssssssi', $provider, $mode, $modelId, $endpoint, $apiKey, $type, $showConfidenceBadges);
  3172.                 if (!$stmtInsert->execute()) {
  3173.                     $stmtInsert->close();
  3174.                     throw new \RuntimeException('Execute INSERT extraction_models: ' . $stmtInsert->error);
  3175.                 }
  3176.                 $localModelId = (int)$stmtInsert->insert_id;
  3177.                 $stmtInsert->close();
  3178.             }
  3180.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  3181.             if (!$stmtDelHeader) {
  3182.                 throw new \RuntimeException('Prepare DELETE definitions_header: ' . $clientMysqli->error);
  3183.             }
  3184.             $stmtDelHeader->bind_param('i', $localModelId);
  3185.             if (!$stmtDelHeader->execute()) {
  3186.                 $stmtDelHeader->close();
  3187.                 throw new \RuntimeException('Execute DELETE definitions_header: ' . $stmtDelHeader->error);
  3188.             }
  3189.             $stmtDelHeader->close();
  3191.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  3192.             if (!$stmtDelLines) {
  3193.                 throw new \RuntimeException('Prepare DELETE definitions_lines: ' . $clientMysqli->error);
  3194.             }
  3195.             $stmtDelLines->bind_param('i', $localModelId);
  3196.             if (!$stmtDelLines->execute()) {
  3197.                 $stmtDelLines->close();
  3198.                 throw new \RuntimeException('Execute DELETE definitions_lines: ' . $stmtDelLines->error);
  3199.             }
  3200.             $stmtDelLines->close();
  3202.             if (!empty($definitions['header'])) {
  3203.                 $stmtHeader = $clientMysqli->prepare(
  3204.                     'INSERT INTO definitions_header
  3205.                     (model_id, field_key, label, value_type, order_index, visibility, order_index_table, visibility_table)
  3206.                     VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  3207.                 );
  3208.                 if (!$stmtHeader) {
  3209.                     throw new \RuntimeException('Prepare INSERT definitions_header: ' . $clientMysqli->error);
  3210.                 }
  3211.                 foreach ($definitions['header'] as $item) {
  3212.                     $fieldKey = (string)$item['field_key'];
  3213.                     $label = (string)$item['label'];
  3214.                     $valueType = (string)$item['value_type'];
  3215.                     $orderIndex = (int)$item['order_index'];
  3216.                     $visibility = (int)$item['visibility'];
  3217.                     $orderIndexTable = (int)$item['order_index_table'];
  3218.                     $visibilityTable = (int)$item['visibility_table'];
  3219.                     $stmtHeader->bind_param(
  3220.                         'isssiiii',
  3221.                         $localModelId,
  3222.                         $fieldKey,
  3223.                         $label,
  3224.                         $valueType,
  3225.                         $orderIndex,
  3226.                         $visibility,
  3227.                         $orderIndexTable,
  3228.                         $visibilityTable
  3229.                     );
  3230.                     if (!$stmtHeader->execute()) {
  3231.                         $stmtHeader->close();
  3232.                         throw new \RuntimeException('Execute INSERT definitions_header: ' . $stmtHeader->error);
  3233.                     }
  3234.                 }
  3235.                 $stmtHeader->close();
  3236.             }
  3238.             if (!empty($definitions['lines'])) {
  3239.                 $stmtLines = $clientMysqli->prepare(
  3240.                     'INSERT INTO definitions_lines
  3241.                     (model_id, field_key, label, value_type, order_index, visibility)
  3242.                     VALUES (?, ?, ?, ?, ?, ?)'
  3243.                 );
  3244.                 if (!$stmtLines) {
  3245.                     throw new \RuntimeException('Prepare INSERT definitions_lines: ' . $clientMysqli->error);
  3246.                 }
  3247.                 foreach ($definitions['lines'] as $item) {
  3248.                     $fieldKey = (string)$item['field_key'];
  3249.                     $label = (string)$item['label'];
  3250.                     $valueType = (string)$item['value_type'];
  3251.                     $orderIndex = (int)$item['order_index'];
  3252.                     $visibility = (int)$item['visibility'];
  3253.                     $stmtLines->bind_param(
  3254.                         'isssii',
  3255.                         $localModelId,
  3256.                         $fieldKey,
  3257.                         $label,
  3258.                         $valueType,
  3259.                         $orderIndex,
  3260.                         $visibility
  3261.                     );
  3262.                     if (!$stmtLines->execute()) {
  3263.                         $stmtLines->close();
  3264.                         throw new \RuntimeException('Execute INSERT definitions_lines: ' . $stmtLines->error);
  3265.                     }
  3266.                 }
  3267.                 $stmtLines->close();
  3268.             }
  3270.             $clientMysqli->commit();
  3271.             return $localModelId;
  3272.         } catch (\Throwable $e) {
  3273.             $clientMysqli->rollback();
  3274.             throw $e;
  3275.         }
  3276.     }
  3278.     private function registerModelInClientDb(\mysqli $clientMysqli, array $resource, string $modelId): int
  3279.     {
  3280.         return $this->registerDiModelInClientDb($clientMysqli, $resource, $modelId);
  3281.     }
  3283.     private function normalizeAoaiFieldScope(string $scope): string
  3284.     {
  3285.         $scope = strtolower(trim($scope));
  3286.         return $scope === 'lines' ? 'lines' : 'header';
  3287.     }
  3289.     private function normalizeAoaiValueType(string $valueType): string
  3290.     {
  3291.         $valueType = strtolower(trim($valueType));
  3292.         if ($valueType === 'number') {
  3293.             return 'number';
  3294.         }
  3295.         if ($valueType === 'date') {
  3296.             return 'date';
  3297.         }
  3298.         return 'string';
  3299.     }
  3301.     private function collectAoaiFieldsFromRequest(Request $request): array
  3302.     {
  3303.         $scopes = $request->request->all('aoai_fields_scope');
  3304.         $keys = $request->request->all('aoai_fields_key');
  3305.         $prompts = $request->request->all('aoai_fields_prompt');
  3306.         $valueTypes = $request->request->all('aoai_fields_type');
  3308.         if (!is_array($scopes)) {
  3309.             $scopes = [];
  3310.         }
  3311.         if (!is_array($keys)) {
  3312.             $keys = [];
  3313.         }
  3314.         if (!is_array($prompts)) {
  3315.             $prompts = [];
  3316.         }
  3317.         if (!is_array($valueTypes)) {
  3318.             $valueTypes = [];
  3319.         }
  3321.         $max = max(count($scopes), count($keys), count($prompts), count($valueTypes));
  3322.         $fields = [];
  3323.         for ($i = 0; $i < $max; $i++) {
  3324.             $scope = $this->normalizeAoaiFieldScope((string)($scopes[$i] ?? 'header'));
  3325.             $fieldKey = trim((string)($keys[$i] ?? ''));
  3326.             $prompt = trim((string)($prompts[$i] ?? ''));
  3327.             $valueType = $this->normalizeAoaiValueType((string)($valueTypes[$i] ?? 'string'));
  3328.             if ($fieldKey === '' && $prompt === '') {
  3329.                 continue;
  3330.             }
  3331.             $fields[] = [
  3332.                 'scope' => $scope,
  3333.                 'field_key' => $fieldKey,
  3334.                 'prompt' => $prompt,
  3335.                 'value_type' => $valueType,
  3336.             ];
  3337.         }
  3338.         return $fields;
  3339.     }
  3341.     private function collectEnricherFieldsFromRequest(Request $request): array
  3342.     {
  3343.         $scopes = $request->request->all('enricher_fields_scope');
  3344.         $keys = $request->request->all('enricher_fields_key');
  3345.         $prompts = $request->request->all('enricher_fields_prompt');
  3346.         $valueTypes = $request->request->all('enricher_fields_type');
  3348.         if (!is_array($scopes)) {
  3349.             $scopes = [];
  3350.         }
  3351.         if (!is_array($keys)) {
  3352.             $keys = [];
  3353.         }
  3354.         if (!is_array($prompts)) {
  3355.             $prompts = [];
  3356.         }
  3357.         if (!is_array($valueTypes)) {
  3358.             $valueTypes = [];
  3359.         }
  3361.         $max = max(count($scopes), count($keys), count($prompts), count($valueTypes));
  3362.         $fields = [];
  3363.         for ($i = 0; $i < $max; $i++) {
  3364.             $scope = $this->normalizeAoaiFieldScope((string)($scopes[$i] ?? 'header'));
  3365.             $fieldKey = trim((string)($keys[$i] ?? ''));
  3366.             $prompt = trim((string)($prompts[$i] ?? ''));
  3367.             $valueType = $this->normalizeAoaiValueType((string)($valueTypes[$i] ?? 'string'));
  3368.             if ($fieldKey === '' && $prompt === '') {
  3369.                 continue;
  3370.             }
  3371.             $fields[] = [
  3372.                 'scope' => $scope,
  3373.                 'field_key' => $fieldKey,
  3374.                 'prompt' => $prompt,
  3375.                 'value_type' => $valueType,
  3376.             ];
  3377.         }
  3378.         return $fields;
  3379.     }
  3381.     private function validateAoaiFields(array $fields): ?string
  3382.     {
  3383.         if (count($fields) === 0) {
  3384.             return 'Debes indicar al menos un campo para Azure OpenAI.';
  3385.         }
  3387.         $seen = [];
  3388.         foreach ($fields as $item) {
  3389.             $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  3390.             $fieldKey = trim((string)($item['field_key'] ?? ''));
  3391.             $prompt = trim((string)($item['prompt'] ?? ''));
  3392.             $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  3393.             if ($fieldKey === '' || $prompt === '') {
  3394.                 return 'Todos los campos de Azure OpenAI deben tener nombre y prompt.';
  3395.             }
  3396.             if (!in_array($valueType, ['string', 'number', 'date'], true)) {
  3397.                 return 'El tipo de dato permitido es string, number o date.';
  3398.             }
  3399.             $uniq = $scope . '|' . strtolower($fieldKey);
  3400.             if (isset($seen[$uniq])) {
  3401.                 return 'No se permiten campos repetidos dentro del mismo alcance (cabecera o líneas).';
  3402.             }
  3403.             $seen[$uniq] = true;
  3404.         }
  3406.         return null;
  3407.     }
  3409.     private function registerAoaiModelInClientDb(\mysqli $clientMysqli, array $resource, array $aoaiFields): int
  3410.     {
  3411.         $extractorType = $this->normalizeExtractorType((string)($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  3412.         if ($extractorType !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3413.             throw new \RuntimeException('El recurso seleccionado no es de tipo Azure OpenAI.', 400);
  3414.         }
  3416.         $validationError = $this->validateAoaiFields($aoaiFields);
  3417.         if ($validationError !== null) {
  3418.             throw new \RuntimeException($validationError, 400);
  3419.         }
  3421.         $modelId = trim((string)($resource['model_id'] ?? ''));
  3422.         $basePrompt = trim((string)($resource['base_prompt'] ?? ''));
  3423.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  3424.         $apiKey = trim((string)($resource['api_key'] ?? ''));
  3425.         if ($modelId === '' || $basePrompt === '' || $endpoint === '' || $apiKey === '') {
  3426.             throw new \RuntimeException('El recurso Azure OpenAI está incompleto.', 400);
  3427.         }
  3429.         $provider = 'azure_openai';
  3430.         $type = 'custom';
  3431.         $showConfidenceBadges = 0;
  3433.         $clientMysqli->begin_transaction();
  3434.         try {
  3435.             $existingId = 0;
  3436.             $stmtSelect = $clientMysqli->prepare(
  3437.                 "SELECT id FROM extraction_models WHERE provider = ? AND model_id = ? AND mode = 'full_extract' LIMIT 1"
  3438.             );
  3439.             if (!$stmtSelect) {
  3440.                 throw new \RuntimeException('Prepare SELECT extraction_models AOAI: ' . $clientMysqli->error);
  3441.             }
  3442.             $stmtSelect->bind_param('ss', $provider, $modelId);
  3443.             if (!$stmtSelect->execute()) {
  3444.                 $stmtSelect->close();
  3445.                 throw new \RuntimeException('Execute SELECT extraction_models AOAI: ' . $stmtSelect->error);
  3446.             }
  3447.             $result = $stmtSelect->get_result();
  3448.             if ($result && ($row = $result->fetch_assoc())) {
  3449.                 $existingId = (int)$row['id'];
  3450.             }
  3451.             $stmtSelect->close();
  3453.             if ($existingId > 0) {
  3454.                 $stmtUpdate = $clientMysqli->prepare(
  3455.                     'UPDATE extraction_models
  3456.                      SET endpoint = ?, api_key = ?, base_prompt = ?, type = ?, show_confidence_badges = ?
  3457.                      WHERE id = ?'
  3458.                 );
  3459.                 if (!$stmtUpdate) {
  3460.                     throw new \RuntimeException('Prepare UPDATE extraction_models AOAI: ' . $clientMysqli->error);
  3461.                 }
  3462.                 $stmtUpdate->bind_param('ssssii', $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges, $existingId);
  3463.                 if (!$stmtUpdate->execute()) {
  3464.                     $stmtUpdate->close();
  3465.                     throw new \RuntimeException('Execute UPDATE extraction_models AOAI: ' . $stmtUpdate->error);
  3466.                 }
  3467.                 $stmtUpdate->close();
  3468.                 $localModelId = $existingId;
  3469.             } else {
  3470.                 $stmtInsert = $clientMysqli->prepare(
  3471.                     'INSERT INTO extraction_models (provider, mode, model_id, endpoint, api_key, base_prompt, type, show_confidence_badges)
  3472.                      VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  3473.                 );
  3474.                 if (!$stmtInsert) {
  3475.                     throw new \RuntimeException('Prepare INSERT extraction_models AOAI: ' . $clientMysqli->error);
  3476.                 }
  3477.                 $mode = 'full_extract';
  3478.                 $stmtInsert->bind_param('sssssssi', $provider, $mode, $modelId, $endpoint, $apiKey, $basePrompt, $type, $showConfidenceBadges);
  3479.                 if (!$stmtInsert->execute()) {
  3480.                     $stmtInsert->close();
  3481.                     throw new \RuntimeException('Execute INSERT extraction_models AOAI: ' . $stmtInsert->error);
  3482.                 }
  3483.                 $localModelId = (int)$stmtInsert->insert_id;
  3484.                 $stmtInsert->close();
  3485.             }
  3487.             $existingHeaderKeys = [];
  3488.             $existingLinesKeys = [];
  3490.             $stmtExistingHeader = $clientMysqli->prepare(
  3491.                 'SELECT field_key FROM definitions_header WHERE model_id = ?'
  3492.             );
  3493.             if (!$stmtExistingHeader) {
  3494.                 throw new \RuntimeException('Prepare SELECT definitions_header AOAI: ' . $clientMysqli->error);
  3495.             }
  3496.             $stmtExistingHeader->bind_param('i', $localModelId);
  3497.             if (!$stmtExistingHeader->execute()) {
  3498.                 $stmtExistingHeader->close();
  3499.                 throw new \RuntimeException('Execute SELECT definitions_header AOAI: ' . $stmtExistingHeader->error);
  3500.             }
  3501.             $resExistingHeader = $stmtExistingHeader->get_result();
  3502.             while ($resExistingHeader && ($row = $resExistingHeader->fetch_assoc())) {
  3503.                 $existingHeaderKeys[(string)($row['field_key'] ?? '')] = true;
  3504.             }
  3505.             $stmtExistingHeader->close();
  3507.             $stmtExistingLines = $clientMysqli->prepare(
  3508.                 'SELECT field_key FROM definitions_lines WHERE model_id = ?'
  3509.             );
  3510.             if (!$stmtExistingLines) {
  3511.                 throw new \RuntimeException('Prepare SELECT definitions_lines AOAI: ' . $clientMysqli->error);
  3512.             }
  3513.             $stmtExistingLines->bind_param('i', $localModelId);
  3514.             if (!$stmtExistingLines->execute()) {
  3515.                 $stmtExistingLines->close();
  3516.                 throw new \RuntimeException('Execute SELECT definitions_lines AOAI: ' . $stmtExistingLines->error);
  3517.             }
  3518.             $resExistingLines = $stmtExistingLines->get_result();
  3519.             while ($resExistingLines && ($row = $resExistingLines->fetch_assoc())) {
  3520.                 $existingLinesKeys[(string)($row['field_key'] ?? '')] = true;
  3521.             }
  3522.             $stmtExistingLines->close();
  3524.             $stmtInsertHeader = $clientMysqli->prepare(
  3525.                 'INSERT INTO definitions_header
  3526.                 (model_id, field_key, label, prompt, value_type, order_index, visibility, order_index_table, visibility_table)
  3527.                 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)'
  3528.             );
  3529.             if (!$stmtInsertHeader) {
  3530.                 throw new \RuntimeException('Prepare INSERT definitions_header AOAI: ' . $clientMysqli->error);
  3531.             }
  3533.             $stmtUpdateHeader = $clientMysqli->prepare(
  3534.                 'UPDATE definitions_header
  3535.                  SET prompt = ?, value_type = ?, order_index = ?, order_index_table = ?
  3536.                  WHERE model_id = ? AND field_key = ?'
  3537.             );
  3538.             if (!$stmtUpdateHeader) {
  3539.                 $stmtInsertHeader->close();
  3540.                 throw new \RuntimeException('Prepare UPDATE definitions_header AOAI: ' . $clientMysqli->error);
  3541.             }
  3543.             $stmtInsertLines = $clientMysqli->prepare(
  3544.                 'INSERT INTO definitions_lines
  3545.                 (model_id, field_key, label, prompt, value_type, order_index, visibility)
  3546.                 VALUES (?, ?, ?, ?, ?, ?, ?)'
  3547.             );
  3548.             if (!$stmtInsertLines) {
  3549.                 $stmtInsertHeader->close();
  3550.                 $stmtUpdateHeader->close();
  3551.                 throw new \RuntimeException('Prepare INSERT definitions_lines AOAI: ' . $clientMysqli->error);
  3552.             }
  3554.             $stmtUpdateLines = $clientMysqli->prepare(
  3555.                 'UPDATE definitions_lines
  3556.                  SET prompt = ?, value_type = ?, order_index = ?
  3557.                  WHERE model_id = ? AND field_key = ?'
  3558.             );
  3559.             if (!$stmtUpdateLines) {
  3560.                 $stmtInsertHeader->close();
  3561.                 $stmtUpdateHeader->close();
  3562.                 $stmtInsertLines->close();
  3563.                 throw new \RuntimeException('Prepare UPDATE definitions_lines AOAI: ' . $clientMysqli->error);
  3564.             }
  3566.             $headerOrder = 1;
  3567.             $lineOrder = 1;
  3568.             $incomingHeaderKeys = [];
  3569.             $incomingLinesKeys = [];
  3570.             foreach ($aoaiFields as $item) {
  3571.                 $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  3572.                 $fieldKey = trim((string)($item['field_key'] ?? ''));
  3573.                 $prompt = trim((string)($item['prompt'] ?? ''));
  3574.                 $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  3575.                 $visibility = 1;
  3576.                 if ($scope === 'lines') {
  3577.                     $orderIndex = $lineOrder++;
  3578.                     $incomingLinesKeys[$fieldKey] = true;
  3579.                     if (isset($existingLinesKeys[$fieldKey])) {
  3580.                         $stmtUpdateLines->bind_param(
  3581.                             'ssiis',
  3582.                             $prompt,
  3583.                             $valueType,
  3584.                             $orderIndex,
  3585.                             $localModelId,
  3586.                             $fieldKey
  3587.                         );
  3588.                         if (!$stmtUpdateLines->execute()) {
  3589.                             throw new \RuntimeException('Execute UPDATE definitions_lines AOAI: ' . $stmtUpdateLines->error);
  3590.                         }
  3591.                     } else {
  3592.                         $label = $fieldKey;
  3593.                         $stmtInsertLines->bind_param(
  3594.                             'issssii',
  3595.                             $localModelId,
  3596.                             $fieldKey,
  3597.                             $label,
  3598.                             $prompt,
  3599.                             $valueType,
  3600.                             $orderIndex,
  3601.                             $visibility
  3602.                         );
  3603.                         if (!$stmtInsertLines->execute()) {
  3604.                             throw new \RuntimeException('Execute INSERT definitions_lines AOAI: ' . $stmtInsertLines->error);
  3605.                         }
  3606.                     }
  3607.                 } else {
  3608.                     $orderIndex = $headerOrder++;
  3609.                     $orderIndexTable = $orderIndex;
  3610.                     $incomingHeaderKeys[$fieldKey] = true;
  3611.                     if (isset($existingHeaderKeys[$fieldKey])) {
  3612.                         $stmtUpdateHeader->bind_param(
  3613.                             'ssiiss',
  3614.                             $prompt,
  3615.                             $valueType,
  3616.                             $orderIndex,
  3617.                             $orderIndexTable,
  3618.                             $localModelId,
  3619.                             $fieldKey
  3620.                         );
  3621.                         if (!$stmtUpdateHeader->execute()) {
  3622.                             throw new \RuntimeException('Execute UPDATE definitions_header AOAI: ' . $stmtUpdateHeader->error);
  3623.                         }
  3624.                     } else {
  3625.                         $label = $fieldKey;
  3626.                         $visibilityTable = 1;
  3627.                         $stmtInsertHeader->bind_param(
  3628.                             'issssiiii',
  3629.                             $localModelId,
  3630.                             $fieldKey,
  3631.                             $label,
  3632.                             $prompt,
  3633.                             $valueType,
  3634.                             $orderIndex,
  3635.                             $visibility,
  3636.                             $orderIndexTable,
  3637.                             $visibilityTable
  3638.                         );
  3639.                         if (!$stmtInsertHeader->execute()) {
  3640.                             throw new \RuntimeException('Execute INSERT definitions_header AOAI: ' . $stmtInsertHeader->error);
  3641.                         }
  3642.                     }
  3643.                 }
  3644.             }
  3646.             $stmtInsertHeader->close();
  3647.             $stmtUpdateHeader->close();
  3648.             $stmtInsertLines->close();
  3649.             $stmtUpdateLines->close();
  3651.             $headerToDelete = array_values(array_diff(array_keys($existingHeaderKeys), array_keys($incomingHeaderKeys)));
  3652.             if (count($headerToDelete) > 0) {
  3653.                 $ph = implode(',', array_fill(0, count($headerToDelete), '?'));
  3654.                 $types = 'i' . str_repeat('s', count($headerToDelete));
  3655.                 $sql = "DELETE FROM definitions_header WHERE model_id = ? AND field_key IN ($ph)";
  3656.                 $stmtDeleteHeader = $clientMysqli->prepare($sql);
  3657.                 if (!$stmtDeleteHeader) {
  3658.                     throw new \RuntimeException('Prepare DELETE definitions_header AOAI selective: ' . $clientMysqli->error);
  3659.                 }
  3660.                 $params = array_merge([$localModelId], $headerToDelete);
  3661.                 $bind = [$types];
  3662.                 foreach ($params as $k => $v) {
  3663.                     $bind[] = &$params[$k];
  3664.                 }
  3665.                 call_user_func_array([$stmtDeleteHeader, 'bind_param'], $bind);
  3666.                 if (!$stmtDeleteHeader->execute()) {
  3667.                     $stmtDeleteHeader->close();
  3668.                     throw new \RuntimeException('Execute DELETE definitions_header AOAI selective: ' . $stmtDeleteHeader->error);
  3669.                 }
  3670.                 $stmtDeleteHeader->close();
  3671.             }
  3673.             $linesToDelete = array_values(array_diff(array_keys($existingLinesKeys), array_keys($incomingLinesKeys)));
  3674.             if (count($linesToDelete) > 0) {
  3675.                 $ph = implode(',', array_fill(0, count($linesToDelete), '?'));
  3676.                 $types = 'i' . str_repeat('s', count($linesToDelete));
  3677.                 $sql = "DELETE FROM definitions_lines WHERE model_id = ? AND field_key IN ($ph)";
  3678.                 $stmtDeleteLines = $clientMysqli->prepare($sql);
  3679.                 if (!$stmtDeleteLines) {
  3680.                     throw new \RuntimeException('Prepare DELETE definitions_lines AOAI selective: ' . $clientMysqli->error);
  3681.                 }
  3682.                 $params = array_merge([$localModelId], $linesToDelete);
  3683.                 $bind = [$types];
  3684.                 foreach ($params as $k => $v) {
  3685.                     $bind[] = &$params[$k];
  3686.                 }
  3687.                 call_user_func_array([$stmtDeleteLines, 'bind_param'], $bind);
  3688.                 if (!$stmtDeleteLines->execute()) {
  3689.                     $stmtDeleteLines->close();
  3690.                     throw new \RuntimeException('Execute DELETE definitions_lines AOAI selective: ' . $stmtDeleteLines->error);
  3691.                 }
  3692.                 $stmtDeleteLines->close();
  3693.             }
  3695.             $clientMysqli->commit();
  3696.             return $localModelId;
  3697.         } catch (\Throwable $e) {
  3698.             $clientMysqli->rollback();
  3699.             throw $e;
  3700.         }
  3701.     }
  3703.     private function loadEnricherForFullModel(\mysqli $mysqli, int $fullModelId, EntityManagerInterface $em): array
  3704.     {
  3705.         if ($fullModelId <= 0) {
  3706.             return [
  3707.                 'enabled' => 0,
  3708.                 'enricher_model_id' => 0,
  3709.                 'aoai_resource_id' => 0,
  3710.                 'fields' => [],
  3711.             ];
  3712.         }
  3714.         $row = null;
  3715.         $stmt = $mysqli->prepare(
  3716.             "SELECT eme.enricher_model_id, eme.enabled
  3717.              FROM extraction_model_enrichers eme
  3718.              INNER JOIN extraction_models em ON em.id = eme.enricher_model_id
  3719.              WHERE eme.full_model_id = ?
  3720.                AND em.mode = 'field_enricher'
  3721.                AND em.provider IN ('azure_openai', 'azure-openai')
  3722.              ORDER BY eme.priority ASC, eme.id ASC
  3723.              LIMIT 1"
  3724.         );
  3725.         if ($stmt) {
  3726.             $stmt->bind_param('i', $fullModelId);
  3727.             if ($stmt->execute()) {
  3728.                 $res = $stmt->get_result();
  3729.                 if ($res && ($found = $res->fetch_assoc())) {
  3730.                     $row = $found;
  3731.                 }
  3732.             }
  3733.             $stmt->close();
  3734.         }
  3736.         if (!$row) {
  3737.             return [
  3738.                 'enabled' => 0,
  3739.                 'enricher_model_id' => 0,
  3740.                 'aoai_resource_id' => 0,
  3741.                 'fields' => [],
  3742.             ];
  3743.         }
  3745.         $enricherModelId = (int)($row['enricher_model_id'] ?? 0);
  3746.         return [
  3747.             'enabled' => (int)($row['enabled'] ?? 0),
  3748.             'enricher_model_id' => $enricherModelId,
  3749.             'aoai_resource_id' => $this->resolveAoaiResourceIdForModel($mysqli, $enricherModelId, $em),
  3750.             'fields' => $this->loadAoaiFieldsForModel($mysqli, $enricherModelId),
  3751.         ];
  3752.     }
  3754.     private function disableEnrichersForFullModel(\mysqli $mysqli, int $fullModelId): void
  3755.     {
  3756.         if ($fullModelId <= 0) {
  3757.             return;
  3758.         }
  3760.         $stmt = $mysqli->prepare('UPDATE extraction_model_enrichers SET enabled = 0 WHERE full_model_id = ?');
  3761.         if (!$stmt) {
  3762.             throw new \RuntimeException('Prepare UPDATE extraction_model_enrichers disable: ' . $mysqli->error);
  3763.         }
  3764.         $stmt->bind_param('i', $fullModelId);
  3765.         if (!$stmt->execute()) {
  3766.             $stmt->close();
  3767.             throw new \RuntimeException('Execute UPDATE extraction_model_enrichers disable: ' . $stmt->error);
  3768.         }
  3769.         $stmt->close();
  3770.     }
  3772.     private function registerAoaiEnricherInClientDb(\mysqli $clientMysqli, int $fullModelId, array $resource, array $fields, bool $enabled): int
  3773.     {
  3774.         if ($fullModelId <= 0) {
  3775.             throw new \RuntimeException('Debes seleccionar un modelo principal antes de configurar el enricher.', 400);
  3776.         }
  3778.         $extractorType = $this->normalizeExtractorType((string)($resource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  3779.         if ($extractorType !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  3780.             throw new \RuntimeException('El recurso del enricher debe ser Azure OpenAI.', 400);
  3781.         }
  3783.         $validationError = $this->validateAoaiFields($fields);
  3784.         if ($validationError !== null) {
  3785.             throw new \RuntimeException($validationError, 400);
  3786.         }
  3788.         $modelId = trim((string)($resource['model_id'] ?? ''));
  3789.         $basePrompt = trim((string)($resource['base_prompt'] ?? ''));
  3790.         $endpoint = $this->normalizeAzureEndpoint((string)($resource['endpoint'] ?? ''));
  3791.         $apiKey = trim((string)($resource['api_key'] ?? ''));
  3792.         if ($modelId === '' || $basePrompt === '' || $endpoint === '' || $apiKey === '') {
  3793.             throw new \RuntimeException('El recurso Azure OpenAI del enricher esta incompleto.', 400);
  3794.         }
  3796.         $provider = 'azure_openai';
  3797.         $mode = 'field_enricher';
  3798.         $type = 'custom';
  3799.         $showConfidenceBadges = 0;
  3800.         $enabledInt = $enabled ? 1 : 0;
  3801.         $priority = 1;
  3803.         $clientMysqli->begin_transaction();
  3804.         try {
  3805.             $enricherModelId = 0;
  3806.             $stmtCurrent = $clientMysqli->prepare(
  3807.                 "SELECT eme.enricher_model_id
  3808.                  FROM extraction_model_enrichers eme
  3809.                  INNER JOIN extraction_models em ON em.id = eme.enricher_model_id
  3810.                  WHERE eme.full_model_id = ?
  3811.                    AND em.mode = 'field_enricher'
  3812.                    AND em.provider IN ('azure_openai', 'azure-openai')
  3813.                  ORDER BY eme.priority ASC, eme.id ASC
  3814.                  LIMIT 1"
  3815.             );
  3816.             if (!$stmtCurrent) {
  3817.                 throw new \RuntimeException('Prepare SELECT current enricher: ' . $clientMysqli->error);
  3818.             }
  3819.             $stmtCurrent->bind_param('i', $fullModelId);
  3820.             if (!$stmtCurrent->execute()) {
  3821.                 $stmtCurrent->close();
  3822.                 throw new \RuntimeException('Execute SELECT current enricher: ' . $stmtCurrent->error);
  3823.             }
  3824.             $resCurrent = $stmtCurrent->get_result();
  3825.             if ($resCurrent && ($current = $resCurrent->fetch_assoc())) {
  3826.                 $enricherModelId = (int)($current['enricher_model_id'] ?? 0);
  3827.             }
  3828.             $stmtCurrent->close();
  3830.             if ($enricherModelId > 0) {
  3831.                 $stmtUpdateModel = $clientMysqli->prepare(
  3832.                     'UPDATE extraction_models
  3833.                      SET provider = ?, mode = ?, model_id = ?, endpoint = ?, api_key = ?, base_prompt = ?, type = ?, show_confidence_badges = ?
  3834.                      WHERE id = ?'
  3835.                 );
  3836.                 if (!$stmtUpdateModel) {
  3837.                     throw new \RuntimeException('Prepare UPDATE extraction_models enricher: ' . $clientMysqli->error);
  3838.                 }
  3839.                 $stmtUpdateModel->bind_param(
  3840.                     'sssssssii',
  3841.                     $provider,
  3842.                     $mode,
  3843.                     $modelId,
  3844.                     $endpoint,
  3845.                     $apiKey,
  3846.                     $basePrompt,
  3847.                     $type,
  3848.                     $showConfidenceBadges,
  3849.                     $enricherModelId
  3850.                 );
  3851.                 if (!$stmtUpdateModel->execute()) {
  3852.                     $stmtUpdateModel->close();
  3853.                     throw new \RuntimeException('Execute UPDATE extraction_models enricher: ' . $stmtUpdateModel->error);
  3854.                 }
  3855.                 $stmtUpdateModel->close();
  3856.             } else {
  3857.                 $stmtInsertModel = $clientMysqli->prepare(
  3858.                     'INSERT INTO extraction_models (provider, mode, model_id, endpoint, api_key, base_prompt, type, show_confidence_badges)
  3859.                      VALUES (?, ?, ?, ?, ?, ?, ?, ?)'
  3860.                 );
  3861.                 if (!$stmtInsertModel) {
  3862.                     throw new \RuntimeException('Prepare INSERT extraction_models enricher: ' . $clientMysqli->error);
  3863.                 }
  3864.                 $stmtInsertModel->bind_param(
  3865.                     'sssssssi',
  3866.                     $provider,
  3867.                     $mode,
  3868.                     $modelId,
  3869.                     $endpoint,
  3870.                     $apiKey,
  3871.                     $basePrompt,
  3872.                     $type,
  3873.                     $showConfidenceBadges
  3874.                 );
  3875.                 if (!$stmtInsertModel->execute()) {
  3876.                     $stmtInsertModel->close();
  3877.                     throw new \RuntimeException('Execute INSERT extraction_models enricher: ' . $stmtInsertModel->error);
  3878.                 }
  3879.                 $enricherModelId = (int)$stmtInsertModel->insert_id;
  3880.                 $stmtInsertModel->close();
  3881.             }
  3883.             $stmtDeleteOtherRelations = $clientMysqli->prepare(
  3884.                 'DELETE FROM extraction_model_enrichers WHERE full_model_id = ? AND enricher_model_id <> ?'
  3885.             );
  3886.             if (!$stmtDeleteOtherRelations) {
  3887.                 throw new \RuntimeException('Prepare DELETE other extraction_model_enrichers: ' . $clientMysqli->error);
  3888.             }
  3889.             $stmtDeleteOtherRelations->bind_param('ii', $fullModelId, $enricherModelId);
  3890.             if (!$stmtDeleteOtherRelations->execute()) {
  3891.                 $stmtDeleteOtherRelations->close();
  3892.                 throw new \RuntimeException('Execute DELETE other extraction_model_enrichers: ' . $stmtDeleteOtherRelations->error);
  3893.             }
  3894.             $stmtDeleteOtherRelations->close();
  3896.             $stmtRelation = $clientMysqli->prepare(
  3897.                 'INSERT INTO extraction_model_enrichers (full_model_id, enricher_model_id, priority, enabled)
  3898.                  VALUES (?, ?, ?, ?)
  3899.                  ON DUPLICATE KEY UPDATE priority = VALUES(priority), enabled = VALUES(enabled)'
  3900.             );
  3901.             if (!$stmtRelation) {
  3902.                 throw new \RuntimeException('Prepare UPSERT extraction_model_enrichers: ' . $clientMysqli->error);
  3903.             }
  3904.             $stmtRelation->bind_param('iiii', $fullModelId, $enricherModelId, $priority, $enabledInt);
  3905.             if (!$stmtRelation->execute()) {
  3906.                 $stmtRelation->close();
  3907.                 throw new \RuntimeException('Execute UPSERT extraction_model_enrichers: ' . $stmtRelation->error);
  3908.             }
  3909.             $stmtRelation->close();
  3911.             $stmtDelHeader = $clientMysqli->prepare('DELETE FROM definitions_header WHERE model_id = ?');
  3912.             if (!$stmtDelHeader) {
  3913.                 throw new \RuntimeException('Prepare DELETE definitions_header enricher: ' . $clientMysqli->error);
  3914.             }
  3915.             $stmtDelHeader->bind_param('i', $enricherModelId);
  3916.             if (!$stmtDelHeader->execute()) {
  3917.                 $stmtDelHeader->close();
  3918.                 throw new \RuntimeException('Execute DELETE definitions_header enricher: ' . $stmtDelHeader->error);
  3919.             }
  3920.             $stmtDelHeader->close();
  3922.             $stmtDelLines = $clientMysqli->prepare('DELETE FROM definitions_lines WHERE model_id = ?');
  3923.             if (!$stmtDelLines) {
  3924.                 throw new \RuntimeException('Prepare DELETE definitions_lines enricher: ' . $clientMysqli->error);
  3925.             }
  3926.             $stmtDelLines->bind_param('i', $enricherModelId);
  3927.             if (!$stmtDelLines->execute()) {
  3928.                 $stmtDelLines->close();
  3929.                 throw new \RuntimeException('Execute DELETE definitions_lines enricher: ' . $stmtDelLines->error);
  3930.             }
  3931.             $stmtDelLines->close();
  3933.             $this->insertAoaiDefinitionRows($clientMysqli, $enricherModelId, $fields);
  3934.             $this->syncEnricherFieldsToFullModel($clientMysqli, $fullModelId, $fields);
  3936.             $clientMysqli->commit();
  3937.             return $enricherModelId;
  3938.         } catch (\Throwable $e) {
  3939.             $clientMysqli->rollback();
  3940.             throw $e;
  3941.         }
  3942.     }
  3944.     private function insertAoaiDefinitionRows(\mysqli $mysqli, int $modelId, array $fields): void
  3945.     {
  3946.         $stmtInsertHeader = $mysqli->prepare(
  3947.             'INSERT INTO definitions_header
  3948.             (model_id, field_key, label, prompt, value_type, order_index, visibility, order_index_table, visibility_table)
  3949.             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)'
  3950.         );
  3951.         if (!$stmtInsertHeader) {
  3952.             throw new \RuntimeException('Prepare INSERT definitions_header enricher: ' . $mysqli->error);
  3953.         }
  3955.         $stmtInsertLines = $mysqli->prepare(
  3956.             'INSERT INTO definitions_lines
  3957.             (model_id, field_key, label, prompt, value_type, order_index, visibility)
  3958.             VALUES (?, ?, ?, ?, ?, ?, ?)'
  3959.         );
  3960.         if (!$stmtInsertLines) {
  3961.             $stmtInsertHeader->close();
  3962.             throw new \RuntimeException('Prepare INSERT definitions_lines enricher: ' . $mysqli->error);
  3963.         }
  3965.         $headerOrder = 1;
  3966.         $lineOrder = 1;
  3967.         foreach ($fields as $item) {
  3968.             $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  3969.             $fieldKey = trim((string)($item['field_key'] ?? ''));
  3970.             $prompt = trim((string)($item['prompt'] ?? ''));
  3971.             $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  3972.             $label = $fieldKey;
  3973.             $visibility = 1;
  3975.             if ($scope === 'lines') {
  3976.                 $orderIndex = $lineOrder++;
  3977.                 $stmtInsertLines->bind_param(
  3978.                     'issssii',
  3979.                     $modelId,
  3980.                     $fieldKey,
  3981.                     $label,
  3982.                     $prompt,
  3983.                     $valueType,
  3984.                     $orderIndex,
  3985.                     $visibility
  3986.                 );
  3987.                 if (!$stmtInsertLines->execute()) {
  3988.                     $stmtInsertLines->close();
  3989.                     $stmtInsertHeader->close();
  3990.                     throw new \RuntimeException('Execute INSERT definitions_lines enricher: ' . $stmtInsertLines->error);
  3991.                 }
  3992.             } else {
  3993.                 $orderIndex = $headerOrder++;
  3994.                 $orderIndexTable = $orderIndex;
  3995.                 $visibilityTable = 1;
  3996.                 $stmtInsertHeader->bind_param(
  3997.                     'issssiiii',
  3998.                     $modelId,
  3999.                     $fieldKey,
  4000.                     $label,
  4001.                     $prompt,
  4002.                     $valueType,
  4003.                     $orderIndex,
  4004.                     $visibility,
  4005.                     $orderIndexTable,
  4006.                     $visibilityTable
  4007.                 );
  4008.                 if (!$stmtInsertHeader->execute()) {
  4009.                     $stmtInsertLines->close();
  4010.                     $stmtInsertHeader->close();
  4011.                     throw new \RuntimeException('Execute INSERT definitions_header enricher: ' . $stmtInsertHeader->error);
  4012.                 }
  4013.             }
  4014.         }
  4016.         $stmtInsertLines->close();
  4017.         $stmtInsertHeader->close();
  4018.     }
  4020.     private function syncEnricherFieldsToFullModel(\mysqli $mysqli, int $fullModelId, array $fields): void
  4021.     {
  4022.         $stmtMaxHeader = $mysqli->prepare('SELECT COALESCE(MAX(order_index), 0), COALESCE(MAX(order_index_table), 0) FROM definitions_header WHERE model_id = ?');
  4023.         if (!$stmtMaxHeader) {
  4024.             throw new \RuntimeException('Prepare SELECT max definitions_header full: ' . $mysqli->error);
  4025.         }
  4026.         $stmtMaxHeader->bind_param('i', $fullModelId);
  4027.         if (!$stmtMaxHeader->execute()) {
  4028.             $stmtMaxHeader->close();
  4029.             throw new \RuntimeException('Execute SELECT max definitions_header full: ' . $stmtMaxHeader->error);
  4030.         }
  4031.         $stmtMaxHeader->bind_result($headerOrder, $headerTableOrder);
  4032.         $stmtMaxHeader->fetch();
  4033.         $stmtMaxHeader->close();
  4035.         $stmtMaxLines = $mysqli->prepare('SELECT COALESCE(MAX(order_index), 0) FROM definitions_lines WHERE model_id = ?');
  4036.         if (!$stmtMaxLines) {
  4037.             throw new \RuntimeException('Prepare SELECT max definitions_lines full: ' . $mysqli->error);
  4038.         }
  4039.         $stmtMaxLines->bind_param('i', $fullModelId);
  4040.         if (!$stmtMaxLines->execute()) {
  4041.             $stmtMaxLines->close();
  4042.             throw new \RuntimeException('Execute SELECT max definitions_lines full: ' . $stmtMaxLines->error);
  4043.         }
  4044.         $stmtMaxLines->bind_result($lineOrder);
  4045.         $stmtMaxLines->fetch();
  4046.         $stmtMaxLines->close();
  4048.         $stmtExistsHeader = $mysqli->prepare('SELECT id FROM definitions_header WHERE model_id = ? AND field_key = ? LIMIT 1');
  4049.         $stmtExistsLines = $mysqli->prepare('SELECT id FROM definitions_lines WHERE model_id = ? AND field_key = ? LIMIT 1');
  4050.         $stmtInsertHeader = $mysqli->prepare(
  4051.             'INSERT INTO definitions_header
  4052.             (model_id, field_key, label, prompt, value_type, order_index, visibility, order_index_table, visibility_table)
  4053.             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)'
  4054.         );
  4055.         $stmtInsertLines = $mysqli->prepare(
  4056.             'INSERT INTO definitions_lines
  4057.             (model_id, field_key, label, prompt, value_type, order_index, visibility)
  4058.             VALUES (?, ?, ?, ?, ?, ?, ?)'
  4059.         );
  4060.         if (!$stmtExistsHeader || !$stmtExistsLines || !$stmtInsertHeader || !$stmtInsertLines) {
  4061.             foreach ([$stmtExistsHeader, $stmtExistsLines, $stmtInsertHeader, $stmtInsertLines] as $stmt) {
  4062.                 if ($stmt) {
  4063.                     $stmt->close();
  4064.                 }
  4065.             }
  4066.             throw new \RuntimeException('Prepare sync definitions full model: ' . $mysqli->error);
  4067.         }
  4069.         foreach ($fields as $item) {
  4070.             $scope = $this->normalizeAoaiFieldScope((string)($item['scope'] ?? 'header'));
  4071.             $fieldKey = trim((string)($item['field_key'] ?? ''));
  4072.             $prompt = trim((string)($item['prompt'] ?? ''));
  4073.             $valueType = $this->normalizeAoaiValueType((string)($item['value_type'] ?? 'string'));
  4074.             $label = $fieldKey;
  4075.             $visibility = 1;
  4077.             if ($scope === 'lines') {
  4078.                 $stmtExistsLines->bind_param('is', $fullModelId, $fieldKey);
  4079.                 if (!$stmtExistsLines->execute()) {
  4080.                     throw new \RuntimeException('Execute SELECT definitions_lines full: ' . $stmtExistsLines->error);
  4081.                 }
  4082.                 $res = $stmtExistsLines->get_result();
  4083.                 if ($res && $res->fetch_assoc()) {
  4084.                     $res->free();
  4085.                     continue;
  4086.                 }
  4087.                 if ($res) {
  4088.                     $res->free();
  4089.                 }
  4091.                 $lineOrder++;
  4092.                 $stmtInsertLines->bind_param(
  4093.                     'issssii',
  4094.                     $fullModelId,
  4095.                     $fieldKey,
  4096.                     $label,
  4097.                     $prompt,
  4098.                     $valueType,
  4099.                     $lineOrder,
  4100.                     $visibility
  4101.                 );
  4102.                 if (!$stmtInsertLines->execute()) {
  4103.                     throw new \RuntimeException('Execute INSERT definitions_lines full: ' . $stmtInsertLines->error);
  4104.                 }
  4105.             } else {
  4106.                 $stmtExistsHeader->bind_param('is', $fullModelId, $fieldKey);
  4107.                 if (!$stmtExistsHeader->execute()) {
  4108.                     throw new \RuntimeException('Execute SELECT definitions_header full: ' . $stmtExistsHeader->error);
  4109.                 }
  4110.                 $res = $stmtExistsHeader->get_result();
  4111.                 if ($res && $res->fetch_assoc()) {
  4112.                     $res->free();
  4113.                     continue;
  4114.                 }
  4115.                 if ($res) {
  4116.                     $res->free();
  4117.                 }
  4119.                 $headerOrder++;
  4120.                 $headerTableOrder++;
  4121.                 $visibilityTable = 1;
  4122.                 $stmtInsertHeader->bind_param(
  4123.                     'issssiiii',
  4124.                     $fullModelId,
  4125.                     $fieldKey,
  4126.                     $label,
  4127.                     $prompt,
  4128.                     $valueType,
  4129.                     $headerOrder,
  4130.                     $visibility,
  4131.                     $headerTableOrder,
  4132.                     $visibilityTable
  4133.                 );
  4134.                 if (!$stmtInsertHeader->execute()) {
  4135.                     throw new \RuntimeException('Execute INSERT definitions_header full: ' . $stmtInsertHeader->error);
  4136.                 }
  4137.             }
  4138.         }
  4140.         $stmtExistsHeader->close();
  4141.         $stmtExistsLines->close();
  4142.         $stmtInsertHeader->close();
  4143.         $stmtInsertLines->close();
  4144.     }
  4146.     public function Empresa(Request $req, EntityManagerInterface $em)
  4147.     {
  4148.         if (!$this->getUser() || !is_object($this->getUser())) {
  4149.             return $this->redirectToRoute('logout');
  4150.         }
  4152.         $id = (int)$req->get("id");
  4153.         if (!$id) {
  4154.             $this->addFlash('warning', 'Empresa no encontrada.');
  4155.             return $this->redirectToRoute("list");
  4156.         }
  4158.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4159.         if (!$empresa) {
  4160.             $this->addFlash('warning', 'Empresa no encontrada.');
  4161.             return $this->redirectToRoute("list");
  4162.         }
  4164.         $users = $em->getRepository(Usuario::class)->findBy([
  4165.             "empresa" => $empresa->getId()
  4166.         ]);
  4168.         // Valores por defecto por si algo falla al conectar con la BD del cliente
  4169.         $activeUsers            = null;
  4170.         $modulos                = [];
  4171.         $empresaLogo            = null;
  4172.         $extractionModelLabel   = null;
  4173.         $activeLicenseContract  = [];
  4174.         $licenseContractHistory = [];
  4175.         $visualActiveContractId = null;
  4177.         $diskUsedBytes          = null;
  4178.         $diskUsedGb             = null;
  4180.         try {
  4181.             $cx = $empresa->getConexionBD();
  4182.             if ($cx) {
  4183.                 $mysqli = @new \mysqli(
  4184.                     $cx->getDbUrl(),
  4185.                     $cx->getDbUser(),
  4186.                     $cx->getDbPassword(),
  4187.                     $cx->getDbName(),
  4188.                     (int)$cx->getDbPort()
  4189.                 );
  4191.                 if (!$mysqli->connect_error) {
  4192.                     // parámetros (modulos, límites, etc.)
  4193.                     [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  4195.                     // logo guardado en la BD del cliente
  4196.                     $empresaLogo = $this->loadEmpresaLogo($mysqli);
  4197.                     $activeLicenseContract = $this->licenseContractService->loadActiveContract($mysqli);
  4198.                     $licenseContractHistory = $this->licenseContractService->loadContractHistory($mysqli);
  4199.                     $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($licenseContractHistory);
  4201.                     $diskUsedBytes = $this->loadEmpresaDiskUsageBytes($mysqli);
  4202.                     $diskUsedGb = ($diskUsedBytes !== null)
  4203.                         ? round($diskUsedBytes / 1024 / 1024 / 1024, 2)
  4204.                         : null;
  4206.                     // Si tiene extracción y modelo seleccionado, buscamos el ID legible del modelo
  4207.                     if (
  4208.                         !empty($modulos['modulo_extraccion']) &&
  4209.                         !empty($modulos['extraction_model'])
  4210.                     ) {
  4211.                         try {
  4212.                             $stmt = $mysqli->prepare('SELECT model_id FROM extraction_models WHERE id = ? LIMIT 1');
  4213.                             if ($stmt) {
  4214.                                 $modelParam = (int)$modulos['extraction_model'];
  4215.                                 $stmt->bind_param('i', $modelParam);
  4216.                                 if ($stmt->execute()) {
  4217.                                     $res = $stmt->get_result();
  4218.                                     if ($res && ($row = $res->fetch_assoc()) && isset($row['model_id'])) {
  4219.                                         $extractionModelLabel = $row['model_id'];
  4220.                                     }
  4221.                                 }
  4222.                                 $stmt->close();
  4223.                             }
  4224.                         } catch (\Throwable $e) {
  4225.                             // Si falla, simplemente no mostramos el texto bonito del modelo
  4226.                             $extractionModelLabel = null;
  4227.                         }
  4228.                     }
  4230.                     $mysqli->close();
  4231.                 }
  4232.             }
  4233.         } catch (\Throwable $e) {
  4234.             // Aquí podrías loguear el error si quieres, pero no rompemos la pantalla
  4235.         }
  4237.         return $this->render('empresa_detail.html.twig', [
  4238.             'empresa'              => $empresa,
  4239.             'users'                => $users,
  4240.             'activeUsers'          => $activeUsers,
  4241.             'modulos'              => $modulos,
  4242.             'empresaLogo'          => $empresaLogo,
  4243.             'extractionModelLabel' => $extractionModelLabel,
  4244.             'diskUsedGb' => $diskUsedGb,
  4245.             'activeLicenseContract' => $activeLicenseContract,
  4246.             'licenseContractHistory' => $licenseContractHistory,
  4247.             'visualActiveContractId' => $visualActiveContractId,
  4248.         ]);
  4249.     }
  4251.     public function deleteEmpresa(Request $request, EntityManagerInterface $em)
  4252.     {
  4253.         $id = $request->get("id");
  4255.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4257.         $conexion = $empresa->getConexionBD();
  4258.         $usuarios = $em->getRepository(Usuario::class)->findBy(array("empresa" => $empresa->getId()));
  4260.         // Recoger avatar/firma de usuarios antes de eliminar la BD del cliente
  4261.         $mediaPaths = [];
  4262.         try {
  4263.             $mysqliMedia = @new \mysqli(
  4264.                 $conexion->getDbUrl(),
  4265.                 $conexion->getDbUser(),
  4266.                 $conexion->getDbPassword(),
  4267.                 $conexion->getDbName(),
  4268.                 (int)$conexion->getDbPort()
  4269.             );
  4270.             if (!$mysqliMedia->connect_error) {
  4271.                 $mediaPaths = $this->getCompanyUserMediaPaths($mysqliMedia);
  4272.                 $mysqliMedia->close();
  4273.             } else {
  4274.                 error_log('No se pudo conectar a BD cliente para borrar media: ' . $mysqliMedia->connect_error);
  4275.             }
  4276.         } catch (\Throwable $e) {
  4277.             error_log('Error borrando media de usuarios: ' . $e->getMessage());
  4278.         }
  4281.         $hestiaApiUrl = 'https://200.234.237.107:8083/api/';
  4282.         $owner = 'docunecta'; // o el dueño del hosting
  4285.         $postFields = http_build_query([
  4286.             'user' => 'admin',
  4287.             'password' => 'i9iQiSmxb2EpvgLq',
  4288.             'returncode' => 'yes',
  4289.             'cmd' => 'v-delete-database',
  4290.             'arg1' => 'admin',
  4291.             'arg2' => $conexion->getDbName(),
  4293.         ]);
  4295.         $accessKeyId = 'cWYbt9ShyFQ3yVRsUE8u';
  4296.         $secretKey = 'e2M_5wk2_jUAlPorF7V8zfwo3_0ihu90WoLPMKwj';
  4297.         $headers = [
  4298.             'Authorization: Bearer ' . $accessKeyId . ':' . $secretKey
  4299.         ];
  4301.         $ch = curl_init();
  4302.         curl_setopt($ch, CURLOPT_URL, $hestiaApiUrl);
  4303.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  4304.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  4305.         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  4306.         curl_setopt($ch, CURLOPT_POST, true);
  4307.         curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
  4308.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // Solo si usas certificados autofirmados
  4310.         $response = curl_exec($ch);
  4311.         $error = curl_error($ch);
  4312.         curl_close($ch);
  4314.         if (($error || trim($response) !== '0') && trim($response) !== '3') {
  4315.             $this->addFlash('danger', 'Error al eliminar la base de datos en HestiaCP: ' . ($error ?: $response));
  4316.             return $this->redirectToRoute('list');
  4317.         }
  4319.         // Eliminar el servicio systemd asociado a la empresa
  4320.         $company_name = $empresa->getId();
  4322.         $serviceName = $company_name . "-documanager.service";
  4323.         $servicePath = "/etc/systemd/system/$serviceName";
  4324.         $cmds = [
  4325.             "sudo /bin/systemctl stop $serviceName",
  4326.             "sudo /bin/systemctl disable $serviceName",
  4327.             "sudo /bin/rm -f $servicePath",
  4328.             "sudo /bin/systemctl daemon-reload"
  4329.         ];
  4330.         $serviceErrors = [];
  4331.         foreach ($cmds as $cmd) {
  4332.             $output = @\shell_exec($cmd . " 2>&1");
  4333.             if ($output !== null && trim($output) !== '') {
  4334.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  4335.             }
  4336.         }
  4338.         $azureService = $company_name . "-azuredi.service";
  4339.         $servicePathAzure = "/etc/systemd/system/$azureService";
  4340.         $cmdsAzure = [
  4341.             "sudo /bin/systemctl stop $azureService",
  4342.             "sudo /bin/systemctl disable $azureService",
  4343.             "sudo /bin/rm -f $servicePathAzure",
  4344.             "sudo /bin/systemctl daemon-reload",
  4345.         ];
  4346.         foreach ($cmdsAzure as $cmd) {
  4347.             $output = @\shell_exec($cmd . " 2>&1");
  4348.             if ($output) {
  4349.                 $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  4350.             }
  4351.         }
  4353.         // Eliminar mail monitor service + timer (si existen)
  4354.         $this->disableMailMonitorService((int)$company_name);
  4356.         // Pedir a platform que elimine files/logs/media del cliente
  4357.         $this->callPlatformCleanup((int)$company_name, $mediaPaths);
  4359.         //eliminamos usuarios
  4360.         foreach ($usuarios as $user) {
  4361.             $em->remove($user);
  4362.             $em->flush();
  4363.         }
  4365.         //eliminamos conexiĂłn
  4366.         $em->remove($conexion);
  4367.         $em->flush();
  4369.         //eliminamos empresa
  4370.         $em->remove($empresa);
  4371.         $em->flush();
  4372.         $msg = 'Empresa y base de datos eliminadas correctamente.';
  4373.         if (count($serviceErrors) > 0) {
  4374.             $msg .= ' ' . implode('<br>', $serviceErrors);
  4375.         }
  4376.         $this->addFlash('success', $msg);
  4377.         return $this->redirectToRoute('list');
  4378.     }
  4380.     public function editEmpresa(Request $request, EntityManagerInterface $em)
  4381.     {
  4382.         if (!$this->getUser() || !is_object($this->getUser())) {
  4383.             return $this->redirectToRoute('logout');
  4384.         }
  4386.         $id = (int)$request->get('id');
  4387.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4388.         if (!$empresa) {
  4389.             throw $this->createNotFoundException('Empresa no encontrada');
  4390.         }
  4392.         // 1) Conectar a la BD del cliente con las credenciales de la central
  4393.         $cx = $empresa->getConexionBD();
  4394.         $mysqli = @new \mysqli(
  4395.             $cx->getDbUrl(),
  4396.             $cx->getDbUser(),
  4397.             $cx->getDbPassword(),
  4398.             $cx->getDbName(),
  4399.             (int)$cx->getDbPort()
  4400.         );
  4401.         if ($mysqli->connect_error) {
  4402.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4403.             return $this->redirectToRoute('list');
  4404.         }
  4406.         $ocrPlusAvailable = $this->isOcrPlusAvailable();
  4407.         $ocrV2Available = $this->isOcrV2Available();
  4409.         $azureResources = [];
  4410.         $azureDiResources = [];
  4411.         $azureOpenAiResources = [];
  4412.         try {
  4413.             $azureResources = $this->loadAzureResources($em);
  4414.             foreach ($azureResources as $resourceRow) {
  4415.                 if (($resourceRow['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  4416.                     $azureOpenAiResources[] = $resourceRow;
  4417.                 } else {
  4418.                     $azureDiResources[] = $resourceRow;
  4419.                 }
  4420.             }
  4421.         } catch (\Throwable $e) {
  4422.             $this->addFlash('warning', 'No se pudo cargar el catalogo de recursos IA: ' . $e->getMessage());
  4423.         }
  4425.         if ($request->isMethod('POST') && $request->request->get('submit') !== null) {
  4426.             // Estado previo de modulos (para detectar activacion de Mail Monitor)
  4427.             [$activeUsersPrev, $modulosPrev] = $this->loadEmpresaParametros($mysqli);
  4428.             $prevMailMonitor = (int)($modulosPrev['modulo_mailMonitor'] ?? 0);
  4430.             $data = $request->request->all();
  4431.             $maxThreads = $this->clampDocuMaxThreads($data['maxThreads'] ?? null, $empresa->getMaxThreads() ?: 4);
  4432.             $data['ocr_mode'] = $this->normalizeOcrMode($data['ocr_mode'] ?? 'base');
  4433.             if (!$ocrV2Available && $data['ocr_mode'] === 'v2_zxing') {
  4434.                 $data['ocr_mode'] = 'base';
  4435.             }
  4436.             if (!$ocrPlusAvailable && $data['ocr_mode'] === 'plus_glm') {
  4437.                 $data['ocr_mode'] = 'base';
  4438.             }
  4441.             // 2) Actualizar SOLO central
  4442.             $empresa->setName((string)($data['name'] ?? $empresa->getName()));
  4443.             $empresa->setMaxDiskQuota(
  4444.                 isset($data['maxDiskQuota']) && $data['maxDiskQuota'] !== ''
  4445.                     ? (int)$data['maxDiskQuota']
  4446.                     : $empresa->getMaxDiskQuota()
  4447.             );
  4448.             $empresa->setMaxThreads($maxThreads);
  4449.             $em->persist($empresa);
  4451.             // ---- Normalización de POST (checkboxes / select) ----
  4452.             $toBool = fn($v) => in_array(strtolower((string)$v), ['1', 'on', 'true', 'yes'], true);
  4454.             $extractionModel = 0;
  4455.             if (isset($data['extraction_model']) && $data['extraction_model'] !== '') {
  4456.                 $extractionModel = (int)$data['extraction_model'];
  4457.             }
  4458.             $data['extraction_model'] = $extractionModel;
  4459.             $data['extractor_type'] = $this->normalizeExtractorType((string)($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI));
  4460.             $azureResourceId = (int)($data['azure_resource_id'] ?? 0);
  4461.             $azureModelId = trim((string)($data['azure_model_id'] ?? ''));
  4462.             $aoaiResourceId = (int)($data['aoai_resource_id'] ?? 0);
  4463.             $aoaiFields = $this->collectAoaiFieldsFromRequest($request);
  4464.             $enricherEnabled = isset($data['enricher_enabled']) && $toBool($data['enricher_enabled']);
  4465.             $enricherResourceId = (int)($data['enricher_resource_id'] ?? 0);
  4466.             $enricherFields = $this->collectEnricherFieldsFromRequest($request);
  4468.             $data['modulo_extraccion']       = isset($data['modulo_extraccion'])       && $toBool($data['modulo_extraccion'])       ? 1 : 0;
  4469.             $data['modulo_etiquetas']        = isset($data['modulo_etiquetas'])        && $toBool($data['modulo_etiquetas'])        ? 1 : 0;
  4470.             $data['modulo_calendario']       = isset($data['modulo_calendario'])       && $toBool($data['modulo_calendario'])       ? 1 : 0;
  4471.             $data['modulo_calendarioExterno'] = isset($data['modulo_calendarioExterno']) && $toBool($data['modulo_calendarioExterno']) ? 1 : 0;
  4472.             $data['modulo_estados']          = isset($data['modulo_estados'])          && $toBool($data['modulo_estados'])          ? 1 : 0;
  4473.             $data['modulo_lineas']           = isset($data['modulo_lineas'])           && $toBool($data['modulo_lineas'])           ? 1 : 0;
  4474.             $data['modulo_conciliacion']     = isset($data['modulo_conciliacion'])     && $toBool($data['modulo_conciliacion'])     ? 1 : 0;
  4475.             $data['modulo_precios']          = isset($data['modulo_precios'])          && $toBool($data['modulo_precios'])          ? 1 : 0;
  4476.             $data['modulo_ubikos']           = isset($data['modulo_ubikos'])           && $toBool($data['modulo_ubikos'])           ? 1 : 0;
  4477.             $data['modulo_agora']            = isset($data['modulo_agora'])           && $toBool($data['modulo_agora'])             ? 1 : 0;
  4478.             $data['modulo_gstock']           = isset($data['modulo_gstock'])           && $toBool($data['modulo_gstock'])           ? 1 : 0;
  4479.             $data['modulo_expowin']          = isset($data['modulo_expowin'])          && $toBool($data['modulo_expowin'])          ? 1 : 0;
  4480.             $data['modulo_prinex']           = isset($data['modulo_prinex'])           && $toBool($data['modulo_prinex'])           ? 1 : 0;
  4481.             $data['modulo_mailMonitor']      = isset($data['modulo_mailMonitor'])      && $toBool($data['modulo_mailMonitor'])      ? 1 : 0;
  4482.             $data['modulo_busquedaNatural']  = isset($data['modulo_busquedaNatural'])  && $toBool($data['modulo_busquedaNatural'])  ? 1 : 0;
  4483.             $data['soloExtraccion']          = isset($data['soloExtraccion'])          && $toBool($data['soloExtraccion'])          ? 1 : 0;
  4485.             // Dependencias
  4486.             if (!$data['modulo_calendario']) {
  4487.                 $data['modulo_calendarioExterno'] = 0;
  4488.             }
  4489.             if (!$data['modulo_extraccion']) {
  4490.                 $data['modulo_lineas']   = 0;
  4491.                 $data['modulo_conciliacion'] = 0;
  4492.                 $data['modulo_precios']  = 0;
  4493.                 $data['modulo_ubikos']   = 0;
  4494.                 $data['extraction_model'] = 0;
  4495.                 $data['modulo_agora']    = 0;
  4496.                 $data['modulo_gstock']   = 0;
  4497.                 $data['modulo_expowin']  = 0;
  4498.                 $data['modulo_prinex']   = 0;
  4499.                 $data['extractor_type'] = self::EXTRACTOR_TYPE_AZURE_DI;
  4500.                 $azureResourceId = 0;
  4501.                 $azureModelId = '';
  4502.                 $aoaiResourceId = 0;
  4503.                 $enricherEnabled = false;
  4504.                 $enricherResourceId = 0;
  4505.             }
  4506.             if (!$data['modulo_lineas']) {
  4507.                 $data['modulo_precios'] = 0;
  4508.             }
  4510.             // 3) Guardar en BD del cliente: parametros + license
  4511.             if ($data['modulo_extraccion'] === 1) {
  4512.                 if (($data['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) === self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  4513.                     if ($aoaiResourceId <= 0) {
  4514.                         $this->addFlash('danger', 'Para Azure OpenAI debes seleccionar un recurso IA.');
  4515.                         $mysqli->close();
  4516.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4517.                     }
  4519.                     $azureResource = $this->loadAzureResourceById($em, $aoaiResourceId);
  4520.                     if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  4521.                         $this->addFlash('danger', 'El recurso Azure OpenAI seleccionado no existe.');
  4522.                         $mysqli->close();
  4523.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4524.                     }
  4526.                     $validationError = $this->validateAoaiFields($aoaiFields);
  4527.                     if ($validationError !== null) {
  4528.                         $this->addFlash('danger', $validationError);
  4529.                         $mysqli->close();
  4530.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4531.                     }
  4533.                     try {
  4534.                         $data['extraction_model'] = $this->registerAoaiModelInClientDb(
  4535.                             $mysqli,
  4536.                             $azureResource,
  4537.                             $aoaiFields
  4538.                         );
  4539.                         $this->addFlash('success', 'Modelo Azure OpenAI importado/actualizado correctamente.');
  4540.                     } catch (\Throwable $e) {
  4541.                         $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  4542.                         $mysqli->close();
  4543.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4544.                     }
  4545.                 } else {
  4546.                     if (($azureResourceId > 0 && $azureModelId === '') || ($azureResourceId <= 0 && $azureModelId !== '')) {
  4547.                         $this->addFlash('danger', 'Para importar desde recurso IA debes indicar recurso y modelo.');
  4548.                         $mysqli->close();
  4549.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4550.                     }
  4552.                     if ($azureResourceId > 0 && $azureModelId !== '') {
  4553.                         $azureResource = $this->loadAzureResourceById($em, $azureResourceId);
  4554.                         if (!$azureResource || ($azureResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_DI) {
  4555.                             $this->addFlash('danger', 'El recurso IA seleccionado no existe o no es de tipo Azure DI.');
  4556.                             $mysqli->close();
  4557.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4558.                         }
  4560.                         try {
  4561.                             $data['extraction_model'] = $this->registerDiModelInClientDb(
  4562.                                 $mysqli,
  4563.                                 $azureResource,
  4564.                                 $azureModelId
  4565.                             );
  4566.                             $this->addFlash('success', 'Modelo IA importado/actualizado correctamente.');
  4567.                         } catch (\Throwable $e) {
  4568.                             $this->addFlash('danger', 'No se pudo registrar el modelo IA: ' . $e->getMessage());
  4569.                             $mysqli->close();
  4570.                             return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4571.                         }
  4572.                     }
  4574.                     if ((int)$data['extraction_model'] <= 0) {
  4575.                         $this->addFlash('danger', 'Con extraccion activa debes seleccionar un modelo local o importar uno desde recurso IA.');
  4576.                         $mysqli->close();
  4577.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4578.                     }
  4579.                 }
  4581.                 if ($enricherEnabled) {
  4582.                     if ((int)$data['extraction_model'] <= 0) {
  4583.                         $this->addFlash('danger', 'Debes seleccionar un modelo principal antes de configurar el enricher.');
  4584.                         $mysqli->close();
  4585.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4586.                     }
  4587.                     if ($enricherResourceId <= 0) {
  4588.                         $this->addFlash('danger', 'Para activar el enricher debes seleccionar un recurso Azure OpenAI.');
  4589.                         $mysqli->close();
  4590.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4591.                     }
  4592.                     $enricherResource = $this->loadAzureResourceById($em, $enricherResourceId);
  4593.                     if (!$enricherResource || ($enricherResource['extractor_type'] ?? self::EXTRACTOR_TYPE_AZURE_DI) !== self::EXTRACTOR_TYPE_AZURE_OPENAI) {
  4594.                         $this->addFlash('danger', 'El recurso Azure OpenAI del enricher no existe.');
  4595.                         $mysqli->close();
  4596.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4597.                     }
  4598.                     $validationError = $this->validateAoaiFields($enricherFields);
  4599.                     if ($validationError !== null) {
  4600.                         $this->addFlash('danger', $validationError);
  4601.                         $mysqli->close();
  4602.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4603.                     }
  4605.                     try {
  4606.                         $previousExtractionModel = (int)($modulosPrev['extraction_model'] ?? 0);
  4607.                         if ($previousExtractionModel > 0 && $previousExtractionModel !== (int)$data['extraction_model']) {
  4608.                             $this->disableEnrichersForFullModel($mysqli, $previousExtractionModel);
  4609.                         }
  4610.                         $this->registerAoaiEnricherInClientDb(
  4611.                             $mysqli,
  4612.                             (int)$data['extraction_model'],
  4613.                             $enricherResource,
  4614.                             $enricherFields,
  4615.                             true
  4616.                         );
  4617.                         $this->addFlash('success', 'Enricher Azure OpenAI importado/actualizado correctamente.');
  4618.                     } catch (\Throwable $e) {
  4619.                         $this->addFlash('danger', 'No se pudo registrar el enricher IA: ' . $e->getMessage());
  4620.                         $mysqli->close();
  4621.                         return $this->redirectToRoute('app_edit_empresa', ['id' => $id]);
  4622.                     }
  4623.                 } else {
  4624.                     $modelToDisable = (int)($data['extraction_model'] ?: ($modulosPrev['extraction_model'] ?? 0));
  4625.                     if ($modelToDisable > 0) {
  4626.                         try {
  4627.                             $this->disableEnrichersForFullModel($mysqli, $modelToDisable);
  4628.                         } catch (\Throwable $e) {
  4629.                             $this->addFlash('warning', 'No se pudo desactivar el enricher: ' . $e->getMessage());
  4630.                         }
  4631.                     }
  4632.                 }
  4633.             } elseif ((int)($modulosPrev['extraction_model'] ?? 0) > 0) {
  4634.                 try {
  4635.                     $this->disableEnrichersForFullModel($mysqli, (int)$modulosPrev['extraction_model']);
  4636.                 } catch (\Throwable $e) {
  4637.                     $this->addFlash('warning', 'No se pudo desactivar el enricher: ' . $e->getMessage());
  4638.                 }
  4639.             }
  4641.             $this->updateEmpresaParametros($mysqli, $data);
  4642.             if ((int)($data['modulo_gstock'] ?? 0) === 1 && (int)($data['extraction_model'] ?? 0) > 0) {
  4643.                 try {
  4644.                     $this->applyGstockAutoMappings($mysqli, (int)$data['extraction_model']);
  4645.                 } catch (\Throwable $e) {
  4646.                     $this->addFlash('warning', 'No se pudo completar el automapeo de Gstock: ' . $e->getMessage());
  4647.                 }
  4648.             }
  4649.             $this->updateLicense(
  4650.                 $mysqli,
  4651.                 $data,
  4652.                 $empresa->getName()
  4653.             );
  4655.             // Actualizar servicio OCR (hilos + binario segun modo OCR)
  4656.             $ocrBinaryBase = (string)($_ENV['OCR_BINARY'] ?? '');
  4657.             $ocrBinaryV2 = (string)($_ENV['OCR_BINARY_V2'] ?? '');
  4658.             $ocrBinaryPlus = (string)($_ENV['OCR_PLUS_BINARY'] ?? '');
  4659.             $ocrMode = ($data['ocr_mode'] ?? 'base');
  4660.             if ($ocrMode === 'plus_glm') {
  4661.                 $ocrBinary = $ocrBinaryPlus;
  4662.             } elseif ($ocrMode === 'v2_zxing') {
  4663.                 $ocrBinary = $ocrBinaryV2;
  4664.             } else {
  4665.                 $ocrBinary = $ocrBinaryBase;
  4666.             }
  4667.             $filesPath = (string)($_ENV['FILES_PATH'] ?? '');
  4669.             if ($ocrBinary !== '' && $filesPath !== '') {
  4670.                 $companyId = (int)$empresa->getId();
  4671.                 $dbHost = (string)$cx->getDbUrl();
  4672.                 $dbName = (string)$cx->getDbName();
  4673.                 $dbUser = (string)$cx->getDbUser();
  4674.                 $dbPass = (string)$cx->getDbPassword();
  4676.                 $empresaName = (string)$empresa->getName();
  4677.                 $serviceContent = <<<EOT
  4678. [Unit]
  4679. Description={$empresaName} DocuManager OCR
  4680. Requires=mariadb.service
  4681. After=mariadb.service
  4683. [Service]
  4684. Type=simple
  4685. Environment="DOCU_MAX_THREADS=$maxThreads"
  4686. ExecStart=$ocrBinary {$dbHost}/{$dbName} {$dbUser} {$dbPass} {$filesPath}/{$companyId} NO
  4687. Restart=always
  4688. User=root
  4690. [Install]
  4691. WantedBy=multi-user.target
  4692. EOT;
  4694.                 $serviceName = $companyId . "-documanager.service";
  4695.                 $tmpServicePath = "/tmp/$serviceName";
  4696.                 file_put_contents($tmpServicePath, $serviceContent);
  4697.                 \chmod($tmpServicePath, 0644);
  4699.                 $cmds = [
  4700.                     "sudo /bin/mv /tmp/$serviceName /etc/systemd/system/$serviceName",
  4701.                     "sudo /bin/systemctl daemon-reload",
  4702.                     "sudo /bin/systemctl restart $serviceName",
  4703.                 ];
  4704.                 $serviceErrors = [];
  4705.                 foreach ($cmds as $cmd) {
  4706.                     $output = \shell_exec($cmd . " 2>&1");
  4707.                     if ($output !== null && trim($output) !== '') {
  4708.                         error_log("CMD OUTPUT: $cmd\n$output");
  4709.                         $serviceErrors[] = "CMD OUTPUT: $cmd\n$output";
  4710.                     }
  4711.                 }
  4712.                 if (count($serviceErrors) > 0) {
  4713.                     $this->addFlash('warning', 'Servicio OCR actualizado con avisos: ' . implode(' | ', $serviceErrors));
  4714.                 }
  4715.             } else {
  4716.                 if (($data['ocr_mode'] ?? 'base') === 'plus_glm') {
  4717.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_PLUS_BINARY o FILES_PATH.');
  4718.                 } elseif (($data['ocr_mode'] ?? 'base') === 'v2_zxing') {
  4719.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY_V2 o FILES_PATH.');
  4720.                 } else {
  4721.                     $this->addFlash('warning', 'No se pudo actualizar el servicio OCR: faltan OCR_BINARY o FILES_PATH.');
  4722.                 }
  4723.             }
  4724.             // Si se activa Mail Monitor y antes estaba desactivado, crear servicio/timer
  4725.             if ($prevMailMonitor === 0 && (int)$data['modulo_mailMonitor'] === 1 && $filesPath !== '') {
  4726.                 $this->ensureMailMonitorService(
  4727.                     (int)$empresa->getId(),
  4728.                     (string)$cx->getDbUrl(),
  4729.                     (string)$cx->getDbPort(),
  4730.                     (string)$cx->getDbUser(),
  4731.                     (string)$cx->getDbPassword(),
  4732.                     (string)$cx->getDbName(),
  4733.                     (string)$filesPath
  4734.                 );
  4735.             }
  4736.             // Si se desactiva Mail Monitor, parar y eliminar service/timer
  4737.             if ($prevMailMonitor === 1 && (int)$data['modulo_mailMonitor'] === 0) {
  4738.                 $this->disableMailMonitorService((int)$empresa->getId());
  4739.             }
  4741.             $em->flush();
  4742.             $mysqli->close();
  4744.             // Mensaje de éxito
  4745.             $this->addFlash('success', 'Empresa editada correctamente.');
  4747.             return $this->redirectToRoute('app_empresa_show', ['id' => $id]);
  4748.         }
  4750.         // 4) GET: precargar desde BD del cliente
  4751.         [$activeUsers, $modulos] = $this->loadEmpresaParametros($mysqli);
  4752.         $license = $this->loadLicense($mysqli);
  4754.         $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  4755.         $selectedAoaiResourceId = 0;
  4756.         $aoaiFields = [];
  4757.         $enricher = [
  4758.             'enabled' => 0,
  4759.             'enricher_model_id' => 0,
  4760.             'aoai_resource_id' => 0,
  4761.             'fields' => [],
  4762.         ];
  4763.         if (!empty($modulos['extraction_model'])) {
  4764.             try {
  4765.                 $stmtCurrentModel = $mysqli->prepare("SELECT provider FROM extraction_models WHERE id = ? AND mode = 'full_extract' LIMIT 1");
  4766.                 if ($stmtCurrentModel) {
  4767.                     $currentModelId = (int)$modulos['extraction_model'];
  4768.                     $stmtCurrentModel->bind_param('i', $currentModelId);
  4769.                     if ($stmtCurrentModel->execute()) {
  4770.                         $resCurrentModel = $stmtCurrentModel->get_result();
  4771.                         if ($resCurrentModel && ($modelRow = $resCurrentModel->fetch_assoc())) {
  4772.                             $provider = strtolower(trim((string)($modelRow['provider'] ?? '')));
  4773.                             if ($provider === 'azure_openai' || $provider === 'azure-openai') {
  4774.                                 $extractorType = self::EXTRACTOR_TYPE_AZURE_OPENAI;
  4775.                             }
  4776.                         }
  4777.                     }
  4778.                     $stmtCurrentModel->close();
  4779.                 }
  4780.             } catch (\Throwable $e) {
  4781.                 $extractorType = self::EXTRACTOR_TYPE_AZURE_DI;
  4782.             }
  4783.         }
  4785.         if ($extractorType === self::EXTRACTOR_TYPE_AZURE_OPENAI && !empty($modulos['extraction_model'])) {
  4786.             try {
  4787.                 $modelId = (int)$modulos['extraction_model'];
  4788.                 $selectedAoaiResourceId = $this->resolveAoaiResourceIdForModel($mysqli, $modelId, $em);
  4789.                 $aoaiFields = $this->loadAoaiFieldsForModel($mysqli, $modelId);
  4790.             } catch (\Throwable $e) {
  4791.                 $aoaiFields = [];
  4792.             }
  4793.         }
  4794.         if (!empty($modulos['extraction_model'])) {
  4795.             try {
  4796.                 $enricher = $this->loadEnricherForFullModel($mysqli, (int)$modulos['extraction_model'], $em);
  4797.             } catch (\Throwable $e) {
  4798.                 $enricher = [
  4799.                     'enabled' => 0,
  4800.                     'enricher_model_id' => 0,
  4801.                     'aoai_resource_id' => 0,
  4802.                     'fields' => [],
  4803.                 ];
  4804.             }
  4805.         }
  4807.         $extractionModels = [];
  4808.         try {
  4809.             $res = $mysqli->query("SELECT id, model_id, provider FROM extraction_models WHERE mode = 'full_extract' AND provider IN ('azure-di', 'azure_openai', 'azure-openai') ORDER BY model_id");
  4810.             if ($res) {
  4811.                 while ($row = $res->fetch_assoc()) {
  4812.                     $extractionModels[] = [
  4813.                         'id' => (int)$row['id'],
  4814.                         'model_id' => (string)$row['model_id'],
  4815.                         'provider' => (string)($row['provider'] ?? ''),
  4816.                     ];
  4817.                 }
  4818.                 $res->free();
  4819.             }
  4820.         } catch (\Throwable $e) {
  4821.             $extractionModels = [];
  4822.         }
  4824.         $mysqli->close();
  4826.         return $this->render('empresa/_edit.html.twig', [
  4827.             'empresa'      => $empresa,   // central: name + maxDiskQuota
  4828.             'id'           => $id,
  4829.             'activeUsers'  => $activeUsers, // cliente
  4830.             'modulos'      => $modulos,     // cliente
  4831.             'license'      => $license,     // opcional
  4832.             'azure_resources' => $azureResources,
  4833.             'azure_di_resources' => $azureDiResources,
  4834.             'azure_openai_resources' => $azureOpenAiResources,
  4835.             'extraction_models' => $extractionModels,
  4836.             'form_data' => [
  4837.                 'extractor_type' => $extractorType,
  4838.                 'aoai_resource_id' => $selectedAoaiResourceId,
  4839.                 'ocr_mode' => $this->normalizeOcrMode($modulos['ocr_mode'] ?? 'base'),
  4840.             ],
  4841.             'aoai_fields' => $aoaiFields,
  4842.             'enricher' => $enricher,
  4843.             'ocr_plus_available' => $ocrPlusAvailable,
  4844.             'ocr_v2_available' => $ocrV2Available,
  4845.         ]);
  4846.     }
  4848.     public function empresaLicenseEdit(Request $request, EntityManagerInterface $em)
  4849.     {
  4850.         if (!$this->getUser() || !is_object($this->getUser())) {
  4851.             return $this->redirectToRoute('logout');
  4852.         }
  4854.         $id = (int)$request->get('id');
  4855.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4856.         if (!$empresa) {
  4857.             throw $this->createNotFoundException('Empresa no encontrada');
  4858.         }
  4860.         $cx = $empresa->getConexionBD();
  4861.         $mysqli = @new \mysqli(
  4862.             $cx->getDbUrl(),
  4863.             $cx->getDbUser(),
  4864.             $cx->getDbPassword(),
  4865.             $cx->getDbName(),
  4866.             (int)$cx->getDbPort()
  4867.         );
  4868.         if ($mysqli->connect_error) {
  4869.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4870.             return $this->redirectToRoute('list');
  4871.         }
  4873.         $editContractId = max(0, (int)$request->query->get('edit_contract_id', 0));
  4874.         $editLicenseFormData = [];
  4875.         if ($editContractId > 0) {
  4876.             $editContract = $this->licenseContractService->loadContractById($mysqli, $editContractId);
  4877.             if (!empty($editContract)) {
  4878.                 $editLicenseFormData = [
  4879.                     'license_type' => (string)($editContract['type'] ?? 'page'),
  4880.                     'license_mode' => (string)($editContract['mode'] ?? 'monthly'),
  4881.                     'license_limit_mode' => (string)($editContract['limit_mode'] ?? 'block'),
  4882.                     'license_units_total' => (string)($editContract['units_total'] ?? '0'),
  4883.                     'license_units_used' => (string)($editContract['units_used'] ?? '0'),
  4884.                     'license_units_exceeded' => (string)($editContract['units_exceeded'] ?? '0'),
  4885.                     'license_start_date' => (string)($editContract['start_date'] ?? ''),
  4886.                     'license_end_date' => (string)($editContract['end_date'] ?? ''),
  4887.                 ];
  4888.             } else {
  4889.                 $editContractId = 0;
  4890.                 $this->addFlash('warning', 'La licencia indicada no existe.');
  4891.             }
  4892.         }
  4894.         $response = $this->renderEmpresaLicensePage($empresa, $mysqli, $editContractId > 0 ? $editContractId : null, $editLicenseFormData);
  4895.         $mysqli->close();
  4897.         return $response;
  4898.     }
  4900.     public function empresaLicenseUpdate(Request $request, EntityManagerInterface $em)
  4901.     {
  4902.         if (!$this->getUser() || !is_object($this->getUser())) {
  4903.             return $this->redirectToRoute('logout');
  4904.         }
  4906.         $id = (int)$request->get('id');
  4907.         $contractId = (int)$request->get('contractId');
  4908.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4909.         if (!$empresa) {
  4910.             throw $this->createNotFoundException('Empresa no encontrada');
  4911.         }
  4913.         $cx = $empresa->getConexionBD();
  4914.         $mysqli = @new \mysqli(
  4915.             $cx->getDbUrl(),
  4916.             $cx->getDbUser(),
  4917.             $cx->getDbPassword(),
  4918.             $cx->getDbName(),
  4919.             (int)$cx->getDbPort()
  4920.         );
  4921.         if ($mysqli->connect_error) {
  4922.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4923.             return $this->redirectToRoute('list');
  4924.         }
  4926.         $data = $request->request->all();
  4927.         try {
  4928.             $normalizedData = $this->licenseContractService->normalizePayload($data, true);
  4929.             $this->licenseContractService->updateContract($mysqli, $contractId, $normalizedData);
  4930.             $this->addFlash('success', 'Licencia actualizada correctamente.');
  4931.             $mysqli->close();
  4932.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4933.         } catch (\InvalidArgumentException $e) {
  4934.             $this->addFlash('danger', $e->getMessage());
  4935.         } catch (\Throwable $e) {
  4936.             $this->addFlash('danger', 'Error al actualizar la licencia: ' . $e->getMessage());
  4937.         }
  4939.         $response = $this->renderEmpresaLicensePage($empresa, $mysqli, $contractId, $data);
  4940.         $mysqli->close();
  4942.         return $response;
  4943.     }
  4945.     public function empresaLicenseDelete(Request $request, EntityManagerInterface $em)
  4946.     {
  4947.         if (!$this->getUser() || !is_object($this->getUser())) {
  4948.             return $this->redirectToRoute('logout');
  4949.         }
  4951.         $id = (int)$request->get('id');
  4952.         $contractId = (int)$request->get('contractId');
  4953.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4954.         if (!$empresa) {
  4955.             throw $this->createNotFoundException('Empresa no encontrada');
  4956.         }
  4958.         $cx = $empresa->getConexionBD();
  4959.         $mysqli = @new \mysqli(
  4960.             $cx->getDbUrl(),
  4961.             $cx->getDbUser(),
  4962.             $cx->getDbPassword(),
  4963.             $cx->getDbName(),
  4964.             (int)$cx->getDbPort()
  4965.         );
  4966.         if ($mysqli->connect_error) {
  4967.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  4968.             return $this->redirectToRoute('list');
  4969.         }
  4971.         try {
  4972.             $this->licenseContractService->deleteContract($mysqli, $contractId);
  4973.             $this->addFlash('success', 'Licencia eliminada correctamente.');
  4974.         } catch (\Throwable $e) {
  4975.             $this->addFlash('danger', 'Error al eliminar la licencia: ' . $e->getMessage());
  4976.         }
  4978.         $mysqli->close();
  4980.         return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  4981.     }
  4983.     public function empresaLicenseExport(Request $request, EntityManagerInterface $em)
  4984.     {
  4985.         if (!$this->getUser() || !is_object($this->getUser())) {
  4986.             return $this->redirectToRoute('logout');
  4987.         }
  4989.         $id = (int)$request->get('id');
  4990.         $empresa = $em->getRepository(Empresa::class)->find($id);
  4991.         if (!$empresa) {
  4992.             throw $this->createNotFoundException('Empresa no encontrada');
  4993.         }
  4995.         try {
  4996.             $mysqli = $this->openEmpresaMysqli($empresa);
  4997.         } catch (\Throwable $e) {
  4998.             $this->addFlash('danger', $e->getMessage());
  4999.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  5000.         }
  5002.         try {
  5003.             $rows = $this->buildTenantLicenseExportRows(
  5004.                 $empresa,
  5005.                 $mysqli
  5006.             );
  5007.         } catch (\Throwable $e) {
  5008.             $mysqli->close();
  5009.             $this->addFlash('danger', 'Error al exportar licencias: ' . $e->getMessage());
  5010.             return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  5011.         }
  5013.         $mysqli->close();
  5015.         return $this->createLicenseCsvResponse(
  5016.             sprintf('license-history-tenant-%d.csv', $id),
  5017.             $this->tenantLicenseExportColumns(),
  5018.             $rows
  5019.         );
  5020.     }
  5022.     public function empresaLicenseExportAll(Request $request, EntityManagerInterface $em)
  5023.     {
  5024.         if (!$this->getUser() || !is_object($this->getUser())) {
  5025.             return $this->redirectToRoute('logout');
  5026.         }
  5028.         try {
  5029.             $range = $this->licenseContractService->validateExportRange(
  5030.                 $request->query->get('export_start_date'),
  5031.                 $request->query->get('export_end_date')
  5032.             );
  5033.         } catch (\InvalidArgumentException $e) {
  5034.             $this->addFlash('danger', $e->getMessage());
  5035.             return $this->redirectToRoute('list');
  5036.         }
  5038.         $rows = [];
  5039.         $empresas = $em->getRepository(Empresa::class)->findAll();
  5040.         foreach ($empresas as $empresa) {
  5041.             try {
  5042.                 $mysqli = $this->openEmpresaMysqli($empresa);
  5043.                 try {
  5044.                     $tenantRows = $this->buildTenantLicenseSummaryRows(
  5045.                         $empresa,
  5046.                         $mysqli,
  5047.                         $range['start_date'],
  5048.                         $range['end_date']
  5049.                     );
  5050.                     foreach ($tenantRows as $row) {
  5051.                         $rows[] = $row;
  5052.                     }
  5053.                 } finally {
  5054.                     $mysqli->close();
  5055.                 }
  5056.             } catch (\Throwable $e) {
  5057.                 $rows[] = $this->createTenantConnectionErrorRow(
  5058.                     $empresa,
  5059.                     $range['start_date'],
  5060.                     $range['end_date']
  5061.                 );
  5062.             }
  5063.         }
  5065.         return $this->createLicenseCsvResponse(
  5066.             sprintf(
  5067.                 'license-summary-all-tenants-%s-to-%s.csv',
  5068.                 $range['start_date'],
  5069.                 $range['end_date']
  5070.             ),
  5071.             $this->licenseSummaryExportColumns(),
  5072.             $rows
  5073.         );
  5074.     }
  5076.     private function renderEmpresaLicensePage(Empresa $empresa, \mysqli $mysqli, ?int $editContractId = null, array $editLicenseFormData = [])
  5077.     {
  5078.         $activeLicenseContract = $this->licenseContractService->loadActiveContract($mysqli);
  5079.         $licenseContractHistory = $this->licenseContractService->loadContractHistory($mysqli);
  5080.         $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($licenseContractHistory);
  5082.         return $this->render('empresa/licenses.html.twig', [
  5083.             'empresa' => $empresa,
  5084.             'activeLicenseContract' => $activeLicenseContract,
  5085.             'licenseContractHistory' => $licenseContractHistory,
  5086.             'visualActiveContractId' => $visualActiveContractId,
  5087.             'editContractId' => $editContractId,
  5088.             'editLicenseFormData' => $editLicenseFormData,
  5089.         ]);
  5090.     }
  5092.     public function empresaLicenseCreate(Request $request, EntityManagerInterface $em)
  5093.     {
  5094.         if (!$this->getUser() || !is_object($this->getUser())) {
  5095.             return $this->redirectToRoute('logout');
  5096.         }
  5098.         $id = (int)$request->get('id');
  5099.         $empresa = $em->getRepository(Empresa::class)->find($id);
  5100.         if (!$empresa) {
  5101.             throw $this->createNotFoundException('Empresa no encontrada');
  5102.         }
  5104.         $cx = $empresa->getConexionBD();
  5105.         $mysqli = @new \mysqli(
  5106.             $cx->getDbUrl(),
  5107.             $cx->getDbUser(),
  5108.             $cx->getDbPassword(),
  5109.             $cx->getDbName(),
  5110.             (int)$cx->getDbPort()
  5111.         );
  5112.         if ($mysqli->connect_error) {
  5113.             $this->addFlash('danger', 'No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  5114.             return $this->redirectToRoute('list');
  5115.         }
  5117.         $data = $request->request->all();
  5119.         try {
  5120.             $normalizedData = $this->licenseContractService->normalizePayload($data, false);
  5121.             $this->licenseContractService->createNewContract($mysqli, $normalizedData);
  5122.             $this->addFlash('success', 'Nueva licencia creada correctamente.');
  5123.         } catch (\InvalidArgumentException $e) {
  5124.             $this->addFlash('danger', $e->getMessage());
  5125.         } catch (\Throwable $e) {
  5126.             $this->addFlash('danger', 'Error al crear la licencia: ' . $e->getMessage());
  5127.         }
  5128.         $mysqli->close();
  5130.         return $this->redirectToRoute('app_empresa_licenses', ['id' => $id]);
  5131.     }
  5133.     private function openEmpresaMysqli(Empresa $empresa): \mysqli
  5134.     {
  5135.         $cx = $empresa->getConexionBD();
  5136.         if (!$cx) {
  5137.             throw new \RuntimeException('La empresa no tiene configurada una conexion de base de datos.');
  5138.         }
  5140.         $mysqli = @new \mysqli(
  5141.             $cx->getDbUrl(),
  5142.             $cx->getDbUser(),
  5143.             $cx->getDbPassword(),
  5144.             $cx->getDbName(),
  5145.             (int)$cx->getDbPort()
  5146.         );
  5148.         if ($mysqli->connect_error) {
  5149.             throw new \RuntimeException('No se puede conectar a la BD del cliente: ' . $mysqli->connect_error);
  5150.         }
  5152.         return $mysqli;
  5153.     }
  5155.     private function tenantLicenseExportColumns(): array
  5156.     {
  5157.         return [
  5158.             'tenant_id',
  5159.             'tenant_name',
  5160.             'license_status',
  5161.             'contract_type',
  5162.             'contract_mode',
  5163.             'limit_mode',
  5164.             'units_total',
  5165.             'units_used',
  5166.             'units_exceeded',
  5167.             'contract_start_date',
  5168.             'contract_end_date',
  5169.         ];
  5170.     }
  5172.     private function licenseSummaryExportColumns(): array
  5173.     {
  5174.         return [
  5175.             'tenant_id',
  5176.             'tenant_name',
  5177.             'range_start',
  5178.             'range_end',
  5179.             'contract_type',
  5180.             'contract_mode',
  5181.             'limit_mode',
  5182.             'units_total',
  5183.             'units_used',
  5184.             'units_exceeded',
  5185.         ];
  5186.     }
  5188.     private function buildTenantLicenseExportRows(Empresa $empresa, \mysqli $mysqli): array
  5189.     {
  5190.         $history = $this->licenseContractService->loadContractHistory($mysqli);
  5191.         $visualActiveContractId = $this->licenseContractService->resolveVisualActiveContractId($history);
  5192.         $rows = [];
  5194.         foreach ($history as $contract) {
  5195.             $rows[] = [
  5196.                 'tenant_id' => (string)$empresa->getId(),
  5197.                 'tenant_name' => (string)$empresa->getName(),
  5198.                 'license_status' => ((int)($contract['id'] ?? 0) === (int)$visualActiveContractId) ? 'Activa' : 'Cerrada',
  5199.                 'contract_type' => (string)($contract['type'] ?? ''),
  5200.                 'contract_mode' => (string)($contract['mode'] ?? ''),
  5201.                 'limit_mode' => (string)($contract['limit_mode'] ?? ''),
  5202.                 'units_total' => (string)max(0, (int)($contract['units_total'] ?? 0)),
  5203.                 'units_used' => (string)max(0, (int)($contract['units_used'] ?? 0)),
  5204.                 'units_exceeded' => (string)max(0, (int)($contract['units_exceeded'] ?? 0)),
  5205.                 'contract_start_date' => (string)($contract['start_date'] ?? ''),
  5206.                 'contract_end_date' => (string)($contract['end_date'] ?? ''),
  5207.             ];
  5208.         }
  5210.         return $rows;
  5211.     }
  5213.     private function buildTenantLicenseSummaryRows(Empresa $empresa, \mysqli $mysqli, string $rangeStart, string $rangeEnd): array
  5214.     {
  5215.         $contracts = $this->licenseContractService->loadContractsStartingWithinRange($mysqli, $rangeStart, $rangeEnd);
  5216.         $aggregatedRows = [];
  5218.         foreach ($contracts as $contract) {
  5219.             $contractType = trim((string)($contract['type'] ?? ''));
  5220.             $contractMode = trim((string)($contract['mode'] ?? ''));
  5221.             $limitMode = trim((string)($contract['limit_mode'] ?? ''));
  5222.             $groupKey = implode('|', [
  5223.                 $empresa->getId(),
  5224.                 $contractType,
  5225.                 $contractMode,
  5226.                 $limitMode,
  5227.             ]);
  5229.             if (!isset($aggregatedRows[$groupKey])) {
  5230.                 $aggregatedRows[$groupKey] = [
  5231.                     'tenant_id' => (string)$empresa->getId(),
  5232.                     'tenant_name' => (string)$empresa->getName(),
  5233.                     'range_start' => $rangeStart,
  5234.                     'range_end' => $rangeEnd,
  5235.                     'contract_type' => $contractType,
  5236.                     'contract_mode' => $contractMode,
  5237.                     'limit_mode' => $limitMode,
  5238.                     'units_total' => 0,
  5239.                     'units_used' => 0,
  5240.                     'units_exceeded' => 0,
  5241.                 ];
  5242.             }
  5244.             $aggregatedRows[$groupKey]['units_total'] += max(0, (int)($contract['units_total'] ?? 0));
  5245.             $aggregatedRows[$groupKey]['units_used'] += max(0, (int)($contract['units_used'] ?? 0));
  5246.             $aggregatedRows[$groupKey]['units_exceeded'] += max(0, (int)($contract['units_exceeded'] ?? 0));
  5247.         }
  5249.         $rows = [];
  5250.         foreach ($aggregatedRows as $row) {
  5251.             $rows[] = [
  5252.                 'tenant_id' => (string)$empresa->getId(),
  5253.                 'tenant_name' => (string)$empresa->getName(),
  5254.                 'range_start' => $rangeStart,
  5255.                 'range_end' => $rangeEnd,
  5256.                 'contract_type' => (string)$row['contract_type'],
  5257.                 'contract_mode' => (string)$row['contract_mode'],
  5258.                 'limit_mode' => (string)$row['limit_mode'],
  5259.                 'units_total' => (string)$row['units_total'],
  5260.                 'units_used' => (string)$row['units_used'],
  5261.                 'units_exceeded' => (string)$row['units_exceeded'],
  5262.             ];
  5263.         }
  5265.         return $rows;
  5266.     }
  5268.     private function createTenantConnectionErrorRow(Empresa $empresa, string $rangeStart, string $rangeEnd): array
  5269.     {
  5270.         return [
  5271.             'tenant_id' => (string)$empresa->getId(),
  5272.             'tenant_name' => (string)$empresa->getName(),
  5273.             'range_start' => $rangeStart,
  5274.             'range_end' => $rangeEnd,
  5275.             'contract_type' => '',
  5276.             'contract_mode' => '',
  5277.             'limit_mode' => '',
  5278.             'units_total' => '',
  5279.             'units_used' => '',
  5280.             'units_exceeded' => '',
  5281.         ];
  5282.     }
  5284.     private function createLicenseCsvResponse(string $filename, array $columns, array $rows): StreamedResponse
  5285.     {
  5286.         $response = new StreamedResponse(function () use ($columns, $rows): void {
  5287.             $out = fopen('php://output', 'wb');
  5288.             if ($out === false) {
  5289.                 throw new \RuntimeException('No se pudo abrir la salida CSV.');
  5290.             }
  5292.             fwrite($out, "\xEF\xBB\xBF");
  5293.             fputcsv($out, $columns, ';');
  5295.             foreach ($rows as $row) {
  5296.                 $csvRow = [];
  5297.                 foreach ($columns as $column) {
  5298.                     $csvRow[] = (string)($row[$column] ?? '');
  5299.                 }
  5300.                 fputcsv($out, $csvRow, ';');
  5301.             }
  5303.             fclose($out);
  5304.         });
  5306.         $response->headers->set('Content-Type', 'text/csv; charset=UTF-8');
  5307.         $response->headers->set('Content-Disposition', 'attachment; filename="' . $filename . '"');
  5309.         return $response;
  5310.     }
  5312.     private function loadEmpresaParametros(\mysqli $mysqli): array
  5313.     {
  5314.         // claves que nos interesan en la tabla parametros
  5315.         $keys = [
  5316.             'activeUsers',
  5317.             'soloExtraccion',
  5318.             'modulo_etiquetas',
  5319.             'modulo_calendario',
  5320.             'modulo_calExt',
  5321.             'modulo_estados',
  5322.             'modulo_subida',
  5323.             'modulo_mailMonitor',
  5324.             'modulo_busquedaNatural',
  5325.             'modulo_extraccion',
  5326.             'modulo_lineas',
  5327.             'modulo_conciliacion',
  5328.             'modulo_precios',
  5329.             'modulo_ubikos',
  5330.             'modulo_agora',
  5331.             'modulo_gstock',
  5332.             'modulo_expowin',
  5333.             'modulo_prinex',
  5334.             'extraction_model',
  5335.             'ocr_mode',
  5336.             'tokensContratados',
  5337.             'tokensUsados',
  5338.         ];
  5339.         $placeholders = implode(',', array_fill(0, count($keys), '?'));
  5341.         $sql = "SELECT nombre, valor FROM parametros WHERE nombre IN ($placeholders)";
  5342.         $stmt = $mysqli->prepare($sql);
  5343.         if (!$stmt) {
  5344.             throw new \RuntimeException('Prepare SELECT parametros: ' . $mysqli->error);
  5345.         }
  5347.         // bind dinámico
  5348.         $types = str_repeat('s', count($keys));
  5349.         $stmt->bind_param($types, ...$keys);
  5350.         if (!$stmt->execute()) {
  5351.             $stmt->close();
  5352.             throw new \RuntimeException('Execute SELECT parametros: ' . $stmt->error);
  5353.         }
  5355.         $res = $stmt->get_result();
  5356.         $map = [];
  5357.         while ($row = $res->fetch_assoc()) {
  5358.             $map[$row['nombre']] = $row['valor'];
  5359.         }
  5360.         $stmt->close();
  5362.         // defaults seguros
  5363.         $activeUsers = isset($map['activeUsers']) ? (int)$map['activeUsers'] : 3;
  5365.         $flags = [
  5366.             'soloExtraccion'   => isset($map['soloExtraccion'])   ? (int)$map['soloExtraccion']   : 0,
  5367.             'modulo_etiquetas'  => isset($map['modulo_etiquetas'])  ? (int)$map['modulo_etiquetas']  : 0,
  5368.             'modulo_calendario' => isset($map['modulo_calendario']) ? (int)$map['modulo_calendario'] : 0,
  5369.             'modulo_calExt'     => isset($map['modulo_calExt'])     ? (int)$map['modulo_calExt']     : 0,
  5370.             'modulo_estados'    => isset($map['modulo_estados'])    ? (int)$map['modulo_estados']    : 0,
  5371.             'modulo_subida'     => isset($map['modulo_subida'])     ? (int)$map['modulo_subida']     : 0,
  5372.             'modulo_extraccion' => isset($map['modulo_extraccion']) ? (int)$map['modulo_extraccion'] : 0,
  5373.             'modulo_lineas'     => isset($map['modulo_lineas'])     ? (int)$map['modulo_lineas']     : 0,
  5374.             'modulo_conciliacion' => isset($map['modulo_conciliacion']) ? (int)$map['modulo_conciliacion'] : 0,
  5375.             'modulo_precios'    => isset($map['modulo_precios'])    ? (int)$map['modulo_precios']    : 0,
  5376.             'modulo_ubikos'     => isset($map['modulo_ubikos'])     ? (int)$map['modulo_ubikos']     : 0,
  5377.             'modulo_agora'      => isset($map['modulo_agora'])      ? (int)$map['modulo_agora']      : 0,
  5378.             'modulo_gstock'     => isset($map['modulo_gstock'])     ? (int)$map['modulo_gstock']     : 0,
  5379.             'modulo_expowin'    => isset($map['modulo_expowin'])    ? (int)$map['modulo_expowin']    : 0,
  5380.             'modulo_prinex'     => isset($map['modulo_prinex'])     ? (int)$map['modulo_prinex']     : 0,
  5381.             'modulo_mailMonitor' => isset($map['modulo_mailMonitor']) ? (int)$map['modulo_mailMonitor'] : 0,
  5382.             'modulo_busquedaNatural' => isset($map['modulo_busquedaNatural']) ? (int)$map['modulo_busquedaNatural'] : 0,
  5383.         ];
  5385.         // extraction_model: default 0 (sin modelo)
  5386.         $flags['extraction_model'] = isset($map['extraction_model']) && $map['extraction_model'] !== '' ? (int)$map['extraction_model'] : 0;
  5387.         $flags['ocr_mode'] = $this->normalizeOcrMode($map['ocr_mode'] ?? 'base');
  5388.         $flags['tokensContratados'] = isset($map['tokensContratados']) && $map['tokensContratados'] !== ''
  5389.             ? max(0, (int)$map['tokensContratados'])
  5390.             : 0;
  5391.         $flags['tokensUsados'] = isset($map['tokensUsados']) && $map['tokensUsados'] !== ''
  5392.             ? max(0, (int)$map['tokensUsados'])
  5393.             : 0;
  5395.         return [$activeUsers, $flags];
  5396.     }
  5398.     private function updateEmpresaParametros(\mysqli $mysqli, array $data): void
  5399.     {
  5400.         $getInt  = fn(array $a, string $k, int $d) => (isset($a[$k]) && $a[$k] !== '') ? (int)$a[$k] : $d;
  5401.         $getFlag = fn(array $a, string $k) => (isset($a[$k]) && (int)$a[$k] === 1) ? 1 : 0;
  5403.         $paramMap = [
  5404.             'activeUsers'        => $getInt($data, 'maxActiveUsers', 3),
  5405.             'soloExtraccion'     => $getFlag($data, 'soloExtraccion'),
  5406.             'modulo_etiquetas'   => $getFlag($data, 'modulo_etiquetas'),
  5407.             'modulo_calendario'  => $getFlag($data, 'modulo_calendario'),
  5408.             'modulo_calExt'      => $getFlag($data, 'modulo_calendarioExterno'),
  5409.             'modulo_estados'     => $getFlag($data, 'modulo_estados'),
  5410.             'modulo_subida'      => $getFlag($data, 'modulo_subida'),
  5411.             'modulo_mailMonitor' => $getFlag($data, 'modulo_mailMonitor'),
  5412.             'modulo_busquedaNatural' => $getFlag($data, 'modulo_busquedaNatural'),
  5413.             'modulo_extraccion'  => $getFlag($data, 'modulo_extraccion'),
  5414.             'modulo_lineas'      => $getFlag($data, 'modulo_lineas'),
  5415.             'modulo_conciliacion' => $getFlag($data, 'modulo_conciliacion'),
  5416.             'modulo_precios'     => $getFlag($data, 'modulo_precios'),
  5417.             'modulo_ubikos'      => $getFlag($data, 'modulo_ubikos'),
  5418.             'modulo_agora'       => $getFlag($data, 'modulo_agora'),
  5419.             'modulo_gstock'      => $getFlag($data, 'modulo_gstock'),
  5420.             'modulo_expowin'     => $getFlag($data, 'modulo_expowin'),
  5421.             'modulo_prinex'      => $getFlag($data, 'modulo_prinex'),
  5422.             'extraction_model'   => $getInt($data, 'extraction_model', 0),
  5423.             'ocr_mode'           => $this->normalizeOcrMode($data['ocr_mode'] ?? 'base'),
  5424.             'tokensContratados'  => max(0, $getInt($data, 'tokensContratados', 0)),
  5425.         ];
  5427.         if ($paramMap['modulo_extraccion'] === 0) {
  5428.             $paramMap['modulo_lineas'] = 0;
  5429.             $paramMap['modulo_conciliacion'] = 0;
  5430.             $paramMap['modulo_precios'] = 0;
  5431.             $paramMap['modulo_ubikos'] = 0;
  5432.             $paramMap['extraction_model'] = 0;
  5433.             $paramMap['modulo_agora'] = 0;
  5434.             $paramMap['modulo_gstock'] = 0;
  5435.             $paramMap['modulo_expowin'] = 0;
  5436.             $paramMap['modulo_prinex'] = 0;
  5437.         }
  5438.         if ($paramMap['modulo_lineas'] === 0) {
  5439.             $paramMap['modulo_precios'] = 0;
  5440.         }
  5441.         if ($paramMap['modulo_calendario'] === 0) {
  5442.             $paramMap['modulo_calExt'] = 0;
  5443.         }
  5445.         $mysqli->begin_transaction();
  5446.         try {
  5447.             $stmt = $mysqli->prepare("
  5448.                 INSERT INTO parametros (nombre, valor)
  5449.                 VALUES (?, ?)
  5450.                 ON DUPLICATE KEY UPDATE valor = VALUES(valor)
  5451.             ");
  5452.             if (!$stmt) {
  5453.                 throw new \RuntimeException('Prepare UPSERT parametros: ' . $mysqli->error);
  5454.             }
  5456.             foreach ($paramMap as $nombre => $valor) {
  5457.                 $v = (string)$valor;
  5458.                 if (!$stmt->bind_param('ss', $nombre, $v) || !$stmt->execute()) {
  5459.                     $stmt->close();
  5460.                     throw new \RuntimeException("Guardar parámetro {$nombre}: {$stmt->error}");
  5461.                 }
  5462.             }
  5464.             $stmt->close();
  5465.             $mysqli->commit();
  5466.         } catch (\Throwable $e) {
  5467.             $mysqli->rollback();
  5468.             throw $e;
  5469.         }
  5470.     }
  5472.     private function loadLicense(\mysqli $mysqli): array
  5473.     {
  5474.         // Carga opcional para mostrar en la edición: capacityGb/users (u otros)
  5475.         $sql = "SELECT client, capacityGb, users FROM license LIMIT 1";
  5476.         $res = $mysqli->query($sql);
  5477.         if ($res && $row = $res->fetch_assoc()) {
  5478.             return $row;
  5479.         }
  5480.         return [];
  5481.     }
  5483.     private function updateLicense(\mysqli $mysqli, array $data, string $clientName): void
  5484.     {
  5485.         $capacityGb  = isset($data['maxDiskQuota']) ? (int)$data['maxDiskQuota'] : 200;
  5486.         $activeUsers = isset($data['maxActiveUsers']) ? (int)$data['maxActiveUsers'] : 3;
  5488.         $stmt = $mysqli->prepare("UPDATE license SET capacityGb = ?, users = ? WHERE client = ?");
  5489.         if (!$stmt) {
  5490.             throw new \RuntimeException('Prepare UPDATE license: ' . $mysqli->error);
  5491.         }
  5493.         $stmt->bind_param('iis', $capacityGb, $activeUsers, $clientName);
  5494.         $stmt->execute();
  5495.         $stmt->close();
  5496.     }
  5498.     public function usersListEmpresa(Request $request, EntityManagerInterface $em)
  5499.     {
  5500.         $id = $request->get("id");
  5501.         $users_empresa = $em->getRepository(Usuario::class)->findBy(array("empresa" => $id));
  5503.         return $this->render('empresa/usersList.html.twig', array(
  5504.             'users' => $users_empresa,
  5505.             'id' => $id
  5506.         ));
  5507.     }
  5509.     private function loadEmpresaDiskUsageBytes(\mysqli $mysqli): ?int
  5510.     {
  5511.         // Si la tabla no existe o hay error, devolvemos null para no romper la vista
  5512.         $sql = "SELECT COALESCE(SUM(size_bytes), 0) AS total_bytes FROM files";
  5513.         $res = $mysqli->query($sql);
  5515.         if (!$res) {
  5516.             return null;
  5517.         }
  5519.         $row = $res->fetch_assoc();
  5520.         $res->free();
  5522.         return isset($row['total_bytes']) ? (int)$row['total_bytes'] : 0;
  5523.     }
  5525.     // =======================================================================
  5526.     // VER DOCUMENTACION DE EMPRESAS
  5527.     // =======================================================================
  5529.     #[Route('/empresa/{id}/documentos', name: 'empresa_documentos', methods: ['GET'])]
  5530.     public function documentosEmpresa(Request $request, EntityManagerInterface $em)
  5531.     {
  5532.         if (!$this->getUser() || !is_object($this->getUser())) {
  5533.             return $this->redirectToRoute('logout');
  5534.         }
  5536.         $id = (int) $request->get('id');
  5537.         $empresa = $em->getRepository(Empresa::class)->find($id);
  5539.         if (!$empresa) {
  5540.             $this->addFlash('warning', 'Empresa no encontrada.');
  5541.             return $this->redirectToRoute('list');
  5542.         }
  5544.         // Para el desplegable
  5545.         $empresas = $em->getRepository(Empresa::class)->findAll();
  5546.         $baseUrl = $this->getParameter('documanager_base_url');
  5548.         return $this->render('empresa/documentos.html.twig', [
  5549.             'empresaId' => $id,
  5550.             'empresas'  => $empresas,
  5551.             'documanagerBaseUrl' => $baseUrl,
  5552.         ]);
  5553.     }
  5555.     #[Route('/api/empresa/{id}/documentos', name: 'empresa_documentos_api', methods: ['GET'])]
  5556.     public function documentosEmpresaApi(Request $request, EntityManagerInterface $em): JsonResponse
  5557.     {
  5558.         if (!$this->getUser() || !is_object($this->getUser())) {
  5559.             return new JsonResponse(['error' => 'unauthorized'], 401);
  5560.         }
  5562.         $id = (int) $request->get('id');
  5563.         $empresa = $em->getRepository(Empresa::class)->find($id);
  5565.         if (!$empresa) {
  5566.             return new JsonResponse(['error' => 'Empresa no encontrada'], 404);
  5567.         }
  5569.         $cx = $empresa->getConexionBD();
  5570.         if (!$cx) {
  5571.             return new JsonResponse(['error' => 'La empresa no tiene conexión configurada'], 400);
  5572.         }
  5574.         $page    = max(1, (int) $request->query->get('page', 1));
  5575.         $perPage = (int) $request->query->get('per_page', 50);
  5576.         $perPage = min(max($perPage, 10), 200);
  5577.         $q       = (string) $request->query->get('q', '');
  5578.         $offset  = ($page - 1) * $perPage;
  5580.         $mysqli = @new \mysqli(
  5581.             $cx->getDbUrl(),
  5582.             $cx->getDbUser(),
  5583.             $cx->getDbPassword(),
  5584.             $cx->getDbName(),
  5585.             (int) $cx->getDbPort()
  5586.         );
  5588.         if ($mysqli->connect_error) {
  5589.             return new JsonResponse(['error' => 'Error conectando a la BD del cliente: ' . $mysqli->connect_error], 500);
  5590.         }
  5592.         $mysqli->set_charset('utf8mb4');
  5594.         // --- TOTAL ---
  5595.         if ($q === '') {
  5596.             $sqlTotal = "SELECT COUNT(*) AS c FROM files";
  5597.             $res = $mysqli->query($sqlTotal);
  5598.             $row = $res ? $res->fetch_assoc() : null;
  5599.             $total = (int)($row['c'] ?? 0);
  5600.         } else {
  5601.             $sqlTotal = "SELECT COUNT(*) AS c
  5602.                          FROM files
  5603.                          WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?";
  5604.             $qLike = '%' . $q . '%';
  5605.             $st = $mysqli->prepare($sqlTotal);
  5606.             $st->bind_param('ssss', $qLike, $qLike, $qLike, $qLike);
  5607.             $st->execute();
  5608.             $res = $st->get_result();
  5609.             $row = $res ? $res->fetch_assoc() : null;
  5610.             $total = (int)($row['c'] ?? 0);
  5611.             $st->close();
  5612.         }
  5614.         // --- ITEMS ---
  5615.         $items = [];
  5617.         if ($q === '') {
  5618.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  5619.                     FROM files
  5620.                     ORDER BY `date` DESC
  5621.                     LIMIT ? OFFSET ?";
  5622.             $st = $mysqli->prepare($sql);
  5623.             $st->bind_param('ii', $perPage, $offset);
  5624.         } else {
  5625.             $sql = "SELECT name, size_bytes, path, `date`, status, control, tag, notes
  5626.                     FROM files
  5627.                     WHERE name LIKE ? OR path LIKE ? OR tag LIKE ? OR notes LIKE ?
  5628.                     ORDER BY `date` DESC
  5629.                     LIMIT ? OFFSET ?";
  5630.             $qLike = '%' . $q . '%';
  5631.             $st = $mysqli->prepare($sql);
  5632.             $st->bind_param('ssssii', $qLike, $qLike, $qLike, $qLike, $perPage, $offset);
  5633.         }
  5635.         $st->execute();
  5636.         $res = $st->get_result();
  5637.         if ($res) {
  5638.             while ($r = $res->fetch_assoc()) {
  5639.                 $items[] = $r;
  5640.             }
  5641.         }
  5642.         $st->close();
  5643.         $mysqli->close();
  5645.         return new JsonResponse([
  5646.             'company_id' => $id,
  5647.             'page'       => $page,
  5648.             'per_page'   => $perPage,
  5649.             'total'      => $total,
  5650.             'items'      => $items,
  5651.         ]);
  5652.     }
  5653. }