{exitosos}
@@ -298,27 +313,7 @@ export function DigitadorResultsPanel({ client, job, tasks, onStartDigitador }:
}>)
: [];
if (shardList.length === 0) return null;
- return (
-
-
Estado por bot
-
- {shardList.map((s, i) => (
-
-
-
- Shard {(s.shard_index ?? i) + 1}
-
- {s.worker_id || "—"}
-
-
- Estado
- {s.status || "—"}
-
-
- ))}
-
-
- );
+ return
;
})()}
diff --git a/services/desktop_app/src/renderer/modules/digitador/DigitadorWizardModule.tsx b/services/desktop_app/src/renderer/modules/digitador/DigitadorWizardModule.tsx
index 355667c..b68e8b4 100644
--- a/services/desktop_app/src/renderer/modules/digitador/DigitadorWizardModule.tsx
+++ b/services/desktop_app/src/renderer/modules/digitador/DigitadorWizardModule.tsx
@@ -14,6 +14,7 @@ import {
import { useCallback, useEffect, useMemo, useRef, useState } from "react";
import type { ApiClient } from "../../lib/apiClient";
import { formatDateTime } from "../../lib/time";
+import { ParallelBotProgress } from "../../components/ParallelBotProgress";
import type {
DigitadorJob,
DigitadorJobEvent,
@@ -598,7 +599,7 @@ export function DigitadorWizardModule({ client, job, initialSource = null }: Pro
- {Number(result.exitosos ?? processed)}/{total || "?"} filas
+ {processed}/{total || "?"} filas procesadas
{pct}%
@@ -626,27 +627,7 @@ export function DigitadorWizardModule({ client, job, initialSource = null }: Pro
- {shards.length > 0 && (
-
-
Shards por bot
-
- {shards.map((s, i) => (
-
-
-
- Shard {(s.shard_index ?? i) + 1}
-
- {s.worker_id || "—"}
-
-
- Estado
- {s.status || "—"}
-
-
- ))}
-
-
- )}
+
Log del agent
diff --git a/services/desktop_app/src/renderer/modules/downloads/DownloadsModule.tsx b/services/desktop_app/src/renderer/modules/downloads/DownloadsModule.tsx
new file mode 100644
index 0000000..27d9c69
--- /dev/null
+++ b/services/desktop_app/src/renderer/modules/downloads/DownloadsModule.tsx
@@ -0,0 +1,18 @@
+import type { ModuleDescriptor } from "../registry";
+import { registerModule } from "../registry";
+import type { Task } from "../../../shared/types";
+import { DownloadsWizardModule } from "./DownloadsWizardModule";
+import { DownloadsResultsPanel } from "./DownloadsResultsPanel";
+
+const DownloadsModule: ModuleDescriptor = {
+ type: "downloads",
+ label: "Bot de descarga",
+ iconName: "Download",
+ hasTask: (tasks: Task[]) => tasks.some((t) => t.type === "downloads"),
+ Wizard: DownloadsWizardModule as unknown as ModuleDescriptor["Wizard"],
+ Results: DownloadsResultsPanel as unknown as ModuleDescriptor["Results"],
+};
+
+registerModule(DownloadsModule);
+
+export { DownloadsModule };
diff --git a/services/desktop_app/src/renderer/modules/downloads/DownloadsResultsPanel.tsx b/services/desktop_app/src/renderer/modules/downloads/DownloadsResultsPanel.tsx
new file mode 100644
index 0000000..3d8c367
--- /dev/null
+++ b/services/desktop_app/src/renderer/modules/downloads/DownloadsResultsPanel.tsx
@@ -0,0 +1,578 @@
+import {
+ AlertCircle,
+ CheckCircle2,
+ ChevronDown,
+ ChevronRight,
+ Download,
+ FolderDown,
+ FolderOpen,
+ Loader2,
+ Plus,
+ RefreshCw,
+} from "lucide-react";
+import { useCallback, useEffect, useMemo, useState } from "react";
+import type {
+ DownloadJob,
+ DownloadJobEvent,
+ DownloadJobFile,
+ Job,
+ Task,
+} from "../../../shared/types";
+import type { ApiClient } from "../../lib/apiClient";
+import { pdfBasename, savePdfAs, savePdfsToDirectory } from "../../lib/saveMinioPdf";
+import { ParallelBotProgress } from "../../components/ParallelBotProgress";
+
+interface Props {
+ client: ApiClient;
+ job: Job;
+ tasks: Task[];
+ onStartDownload: () => void;
+ onContinueToCounting?: (ctx: {
+ downloadJobId: string;
+ downloadsPrefix: string;
+ files: DownloadJobFile[];
+ }) => void;
+}
+
+function groupFilesByNit(files: DownloadJobFile[]): Array<{ nit: string; files: DownloadJobFile[] }> {
+ const map = new Map
();
+ for (const f of files) {
+ const nit = (f.nit || "").trim() || "Sin NIT";
+ const list = map.get(nit) ?? [];
+ list.push(f);
+ map.set(nit, list);
+ }
+ return [...map.entries()]
+ .sort(([a], [b]) => a.localeCompare(b, undefined, { numeric: true }))
+ .map(([nit, group]) => ({
+ nit,
+ files: [...group].sort((x, y) =>
+ String(x.radicado ?? "").localeCompare(String(y.radicado ?? ""), undefined, { numeric: true }),
+ ),
+ }));
+}
+
+type DlProgress = { done: number; total: number; label: string } | null;
+
+export function DownloadsResultsPanel({
+ client,
+ job,
+ tasks,
+ onStartDownload,
+ onContinueToCounting,
+}: Props) {
+ const [runs, setRuns] = useState([]);
+ const [selectedId, setSelectedId] = useState("");
+ const [events, setEvents] = useState([]);
+ const [files, setFiles] = useState([]);
+ const [filesError, setFilesError] = useState(null);
+ const [loading, setLoading] = useState(false);
+ const [error, setError] = useState(null);
+ const [expandedNits, setExpandedNits] = useState>(new Set());
+ const [dlBusyKey, setDlBusyKey] = useState(null);
+ const [dlProgress, setDlProgress] = useState(null);
+ const [dlStatus, setDlStatus] = useState(null);
+
+ const downloadTasks = tasks
+ .filter((t) => t.type === "downloads")
+ .sort((a, b) => new Date(b.created_at).getTime() - new Date(a.created_at).getTime());
+
+ const loadRuns = useCallback(async () => {
+ setLoading(true);
+ setError(null);
+ try {
+ const list = await client.listDownloadJobs(100, job.id);
+ setRuns(list);
+ setSelectedId((prev) => {
+ if (prev && list.some((r) => r.id === prev)) return prev;
+ return list[0]?.id ?? "";
+ });
+ } catch (e) {
+ setError(e instanceof Error ? e.message : String(e));
+ } finally {
+ setLoading(false);
+ }
+ }, [client, job.id]);
+
+ useEffect(() => {
+ void loadRuns();
+ }, [loadRuns, downloadTasks.length]);
+
+ const selected = runs.find((r) => r.id === selectedId) ?? null;
+ const running = Boolean(
+ selected && !["completed", "failed", "cancelled"].includes(selected.status),
+ );
+
+ useEffect(() => {
+ if (!selectedId) {
+ setEvents([]);
+ setFiles([]);
+ setFilesError(null);
+ return;
+ }
+
+ let cancelled = false;
+ async function loadDetail() {
+ try {
+ const [{ events: ev }, fresh] = await Promise.all([
+ client.getDownloadEvents(selectedId, 0),
+ client.getDownloadJob(selectedId),
+ ]);
+ if (cancelled) return;
+ setEvents(ev);
+ setRuns((prev) => prev.map((r) => (r.id === fresh.id ? fresh : r)));
+
+ try {
+ const fileResp = await client.listDownloadJobFiles(selectedId);
+ if (cancelled) return;
+ setFiles(fileResp.files);
+ setFilesError(null);
+ setExpandedNits((prev) => {
+ if (prev.size > 0) return prev;
+ const nits = [
+ ...new Set(fileResp.files.map((f) => (f.nit || "").trim() || "Sin NIT")),
+ ].sort((a, b) => a.localeCompare(b, undefined, { numeric: true }));
+ // Pocas carpetas: abrir todas; muchas: solo la primera.
+ if (nits.length <= 3) return new Set(nits);
+ return nits[0] ? new Set([nits[0]]) : new Set();
+ });
+ } catch (e) {
+ if (cancelled) return;
+ setFiles([]);
+ setFilesError(e instanceof Error ? e.message : String(e));
+ }
+ } catch (e) {
+ if (!cancelled) setError(e instanceof Error ? e.message : String(e));
+ }
+ }
+
+ void loadDetail();
+ if (!running) return;
+
+ const t = setInterval(() => void loadDetail(), 3000);
+ return () => {
+ cancelled = true;
+ clearInterval(t);
+ };
+ }, [client, selectedId, running]);
+
+ const result = selected?.result ?? {};
+ const exitosos = Number(result.exitosos ?? 0);
+ const fallidos = Number(result.fallidos ?? 0);
+ const total = Number(result.total ?? 0);
+ const processed = Number(result.processed ?? exitosos + fallidos);
+ const progressPercent = total > 0 ? Math.min(100, Math.round((processed / total) * 100)) : 0;
+ const uploaded = result.uploaded_count;
+
+ const grouped = useMemo(() => groupFilesByNit(files), [files]);
+ const folderCount = grouped.length;
+ const bulkBusy = Boolean(dlBusyKey);
+
+ function toggleNit(nit: string) {
+ setExpandedNits((prev) => {
+ const next = new Set(prev);
+ if (next.has(nit)) next.delete(nit);
+ else next.add(nit);
+ return next;
+ });
+ }
+
+ function expandAll() {
+ setExpandedNits(new Set(grouped.map((g) => g.nit)));
+ }
+
+ function collapseAll() {
+ setExpandedNits(new Set());
+ }
+
+ async function downloadOne(file: DownloadJobFile) {
+ if (!selectedId || bulkBusy) return;
+ const busyId = `file:${file.key}`;
+ setDlBusyKey(busyId);
+ setDlStatus(null);
+ setError(null);
+ try {
+ const data = await client.fetchDownloadObject(selectedId, file.key);
+ const name = pdfBasename(file.key, file.radicado);
+ const ok = await savePdfAs(name, data);
+ if (ok) setDlStatus(`Guardado: ${name}`);
+ } catch (e) {
+ setError(e instanceof Error ? e.message : "No se pudo descargar el archivo.");
+ } finally {
+ setDlBusyKey(null);
+ }
+ }
+
+ async function downloadMany(items: DownloadJobFile[], scopeKey: string) {
+ if (!selectedId || bulkBusy || items.length === 0) return;
+ setDlBusyKey(scopeKey);
+ setDlStatus(null);
+ setDlProgress({ done: 0, total: items.length, label: "Preparando…" });
+ setError(null);
+ try {
+ const outcome = await savePdfsToDirectory(
+ items,
+ (key) => client.fetchDownloadObject(selectedId, key),
+ (done, tot, label) => setDlProgress({ done, total: tot, label }),
+ );
+ if (!outcome) {
+ setDlStatus(null);
+ return;
+ }
+ setDlStatus(
+ outcome.failed > 0
+ ? `Guardados ${outcome.saved}/${items.length} (${outcome.failed} con error)`
+ : `Guardados ${outcome.saved} PDF(s) en carpetas por NIT`,
+ );
+ } catch (e) {
+ setError(e instanceof Error ? e.message : "No se pudo completar la descarga.");
+ } finally {
+ setDlBusyKey(null);
+ setDlProgress(null);
+ }
+ }
+
+ const canContinue =
+ Boolean(onContinueToCounting) &&
+ selected?.status === "completed" &&
+ files.length > 0;
+
+ if (runs.length === 0 && !loading) {
+ return (
+
+
+
Aún no hay corridas de bot de descarga en este trabajo.
+
+
+
+
+
+
+ {selected && (
+
+ {selected.status}
+
+ )}
+
+
+
+ {canContinue && selected && (
+
+ )}
+
+
+
+
+ {error && (
+
+ )}
+
+ {selected?.error && (
+
+ )}
+
+ {dlStatus && (
+
+
+ {dlStatus}
+
+ )}
+
+ {dlProgress && (
+
+
+
+
+ Descargando {dlProgress.done}/{dlProgress.total}
+ {dlProgress.label ? ` · ${dlProgress.label}` : ""}
+
+
+
+
+ )}
+
+ {selected && (
+ <>
+ {(running || processed > 0) && (
+
+
+ {processed}/{total || "?"} radicados procesados
+ {progressPercent}%
+
+
+
+ )}
+
+
+
+ {exitosos}
+ OK
+
+
+ {fallidos}
+ Fallidos
+
+
+ {total || "—"}
+ Total
+
+
+ {uploaded == null ? "—" : String(uploaded)}
+ En MinIO
+
+ {files.length > 0 && (
+
+ {folderCount}
+ Carpetas
+
+ )}
+
+
+
+ {selected.shard_count && Number(selected.shard_count) > 1
+ ? `${selected.shard_count} bots (distribuido)`
+ : (
+ <>
+ Worker {selected.worker_id ?? "—"}
+
+ )}
+ {selected.original_filename ? ` · ${selected.original_filename}` : ""}
+ {selected.downloads_prefix ? (
+ <>
+ {" "}
+ · Prefijo {selected.downloads_prefix}
+
+ ) : null}
+
+
+ {(() => {
+ const shardList = Array.isArray(selected.shards)
+ ? selected.shards
+ : Array.isArray(result.shards)
+ ? (result.shards as Array<{
+ id?: string;
+ worker_id?: string | null;
+ status?: string;
+ shard_index?: number | null;
+ }>)
+ : [];
+ if (shardList.length === 0) return null;
+ return
;
+ })()}
+
+
+
+
+ Archivos en MinIO
+ {files.length > 0
+ ? ` · ${folderCount} carpeta${folderCount === 1 ? "" : "s"} · ${files.length} PDF${files.length === 1 ? "" : "s"}`
+ : ""}
+
+ {files.length > 0 && (
+
+
+
+
+
+ )}
+
+
+ {filesError && (
+
+
+
No se pudo listar MinIO: {filesError}
+
+ )}
+
+ {!filesError && files.length === 0 ? (
+
Sin PDFs listados aún.
+ ) : (
+
+ {grouped.map(({ nit, files: nitFiles }) => {
+ const open = expandedNits.has(nit);
+ const nitBusy = dlBusyKey === `nit:${nit}`;
+ return (
+
+
+
+
+
+
+ {open && (
+
+
+
+
+ | Radicado |
+ Archivo |
+ |
+
+
+
+ {nitFiles.map((f) => {
+ const fileBusy = dlBusyKey === `file:${f.key}`;
+ const name = pdfBasename(f.key, f.radicado);
+ return (
+
+ | {f.radicado ?? "—"} |
+
+ {name}
+ |
+
+
+ |
+
+ );
+ })}
+
+
+
+ )}
+
+ );
+ })}
+
+ )}
+
+
+
+
Log
+
+ {events.length === 0 ? (
+
Sin eventos.
+ ) : (
+ events.map((ev) => (
+
+ [{ev.timestamp}] {ev.message}
+
+ ))
+ )}
+
+
+
+ )}
+
+