Préstamos de una biblioteca con PDO y transacciones

1<?php
2// Base de datos de la biblioteca (SQLite en memoria): tablas libros, socios y prestamos
3$pdo = new PDO("sqlite::memory:");
4$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
5$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
6$pdo->exec(<<<SQL
7    CREATE TABLE libros (codigo TEXT PRIMARY KEY, titulo TEXT NOT NULL, autor TEXT NOT NULL, ejemplares INTEGER NOT NULL);
8    CREATE TABLE socios (id INTEGER PRIMARY KEY, nombre TEXT NOT NULL);
9    CREATE TABLE prestamos (
10        id INTEGER PRIMARY KEY AUTOINCREMENT,
11        codigo TEXT NOT NULL REFERENCES libros(codigo),
12        socio INTEGER NOT NULL REFERENCES socios(id),
13        salida TEXT NOT NULL,
14        devolucion TEXT
15    );
16    INSERT INTO libros VALUES
17        ('L01', 'Cien años de soledad', 'Gabriel García Márquez', 2),
18        ('L02', '1984', 'George Orwell', 1),
19        ('L03', 'Rebelión en la granja', 'George Orwell', 2),
20        ('L04', 'La sombra del viento', 'Carlos Ruiz Zafón', 1),
21        ('L05', 'El nombre del viento', 'Patrick Rothfuss', 3),
22        ('L06', 'El tercer policía', 'Flann O''Brien', 1);
23    INSERT INTO socios VALUES (1, 'Ana Gil'), (2, 'Luis Mora'), (3, 'Eva Ruiz');
24    INSERT INTO prestamos (codigo, socio, salida, devolucion) VALUES
25        ('L02', 2, '2026-09-01', NULL),
26        ('L01', 1, '2026-09-20', '2026-09-28'),
27        ('L05', 1, '2026-09-25', NULL);
28    SQL);
29
30const PLAZO = 15;          // días de préstamo
31const MULTA = 20;          // céntimos por día de retraso
32const MAXIMO = 3;          // préstamos activos por socio
33
34function euros(int $c): string { return number_format($c / 100, 2, ",", ".") . " €"; }
35
36function dias(string $desde, string $hasta): int {
37    return (int) (new DateTimeImmutable($desde))->diff(new DateTimeImmutable($hasta))->format("%r%a");
38}
39
40function vence(string $salida): string {
41    return (new DateTimeImmutable($salida))->modify("+" . PLAZO . " days")->format("Y-m-d");
42}
43
44/** Ejemplares que quedan en la estantería: los totales menos los prestados sin devolver. */
45function disponibles(PDO $pdo, string $codigo): int {
46    $st = $pdo->prepare("SELECT l.ejemplares - COUNT(p.id) FROM libros l
47        LEFT JOIN prestamos p ON p.codigo = l.codigo AND p.devolucion IS NULL
48        WHERE l.codigo = ? GROUP BY l.codigo");
49    $st->execute([$codigo]);
50    return (int) $st->fetchColumn();
51}
52
53function buscar(PDO $pdo, string $texto): void {
54    // El texto va como parámetro: un apóstrofo (O'Brien) no rompe la consulta ni permite inyectar SQL
55    $st = $pdo->prepare("SELECT codigo, titulo, autor, ejemplares FROM libros
56        WHERE titulo LIKE :t OR autor LIKE :t ORDER BY titulo");
57    $st->execute([":t" => "%$texto%"]);
58    $libros = $st->fetchAll();
59    if (!$libros) {
60        echo "Sin resultados para «{$texto}»\n";
61        return;
62    }
63    foreach ($libros as $l) {
64        echo "{$l['codigo']} · {$l['titulo']} ({$l['autor']}) · disponibles " . disponibles($pdo, $l['codigo']) . " de {$l['ejemplares']}\n";
65    }
66}
67
68function prestar(PDO $pdo, string $codigo, int $socio, string $fecha): void {
69    $libro = $pdo->prepare("SELECT titulo FROM libros WHERE codigo = ?");
70    $libro->execute([$codigo]);
71    $titulo = $libro->fetchColumn();
72    $persona = $pdo->prepare("SELECT nombre FROM socios WHERE id = ?");
73    $persona->execute([$socio]);
74    $nombre = $persona->fetchColumn();
75    if ($titulo === false) { echo "No existe el libro $codigo\n"; return; }
76    if ($nombre === false) { echo "No existe el socio $socio\n"; return; }
77
78    // Las comprobaciones y el INSERT van en una transacción: nadie puede llevarse el último ejemplar entre medias
79    $pdo->beginTransaction();
80    try {
81        if (disponibles($pdo, $codigo) <= 0) throw new RuntimeException("No quedan ejemplares de «{$titulo}»");
82        $activos = $pdo->prepare("SELECT salida FROM prestamos WHERE socio = ? AND devolucion IS NULL");
83        $activos->execute([$socio]);
84        $salidas = $activos->fetchAll(PDO::FETCH_COLUMN);
85        foreach ($salidas as $s) {
86            if (vence($s) < $fecha) throw new RuntimeException("$nombre tiene préstamos vencidos");
87        }
88        if (count($salidas) >= MAXIMO) throw new RuntimeException("$nombre ya tiene " . MAXIMO . " préstamos");
89        $pdo->prepare("INSERT INTO prestamos (codigo, socio, salida) VALUES (?, ?, ?)")->execute([$codigo, $socio, $fecha]);
90        $id = $pdo->lastInsertId();
91        $pdo->commit();
92        echo "Préstamo $id: «{$titulo}» para $nombre (devolver antes del " . vence($fecha) . ")\n";
93    } catch (RuntimeException $e) {
94        $pdo->rollBack();
95        echo $e->getMessage() . "\n";
96    }
97}
98
99function devolver(PDO $pdo, int $id, string $fecha): void {
100    $st = $pdo->prepare("SELECT p.salida, p.devolucion, l.titulo FROM prestamos p JOIN libros l USING (codigo) WHERE p.id = ?");
101    $st->execute([$id]);
102    $p = $st->fetch();
103    if (!$p) { echo "No existe el préstamo $id\n"; return; }
104    if ($p['devolucion'] !== null) { echo "El préstamo $id ya se devolvió el {$p['devolucion']}\n"; return; }
105    $pdo->prepare("UPDATE prestamos SET devolucion = ? WHERE id = ?")->execute([$fecha, $id]);
106    $retraso = max(0, dias($p['salida'], $fecha) - PLAZO);
107    if ($retraso === 0) {
108        echo "Devuelto «{$p['titulo']}» a tiempo\n";
109    } else {
110        echo "Devuelto «{$p['titulo']}» con $retraso " . ($retraso === 1 ? "día" : "días") . " de retraso: multa " . euros($retraso * MULTA) . "\n";
111    }
112}
113
114function morosos(PDO $pdo, string $fecha): void {
115    $st = $pdo->query("SELECT s.nombre, l.titulo, p.salida FROM prestamos p
116        JOIN socios s ON s.id = p.socio JOIN libros l ON l.codigo = p.codigo
117        WHERE p.devolucion IS NULL ORDER BY p.salida, p.id");
118    $lista = [];
119    foreach ($st as $fila) {
120        $retraso = dias($fila['salida'], $fecha) - PLAZO;
121        if ($retraso > 0) $lista[] = "  {$fila['nombre']}: «{$fila['titulo']}» ($retraso " . ($retraso === 1 ? "día" : "días") . " de retraso)";
122    }
123    echo $lista ? "Préstamos vencidos el $fecha:\n" . implode("\n", $lista) . "\n" : "No hay préstamos vencidos el $fecha\n";
124}
125
126function resumen(PDO $pdo): void {
127    $activos = $pdo->query("SELECT COUNT(*) FROM prestamos WHERE devolucion IS NULL")->fetchColumn();
128    echo "Préstamos activos: $activos\n";
129    $top = $pdo->query("SELECT s.nombre, COUNT(*) AS n FROM prestamos p JOIN socios s ON s.id = p.socio
130        GROUP BY s.id ORDER BY n DESC, s.nombre LIMIT 1")->fetch();
131    echo $top ? "Socio más lector: {$top['nombre']} ({$top['n']} préstamos)\n" : "Socio más lector: ninguno\n";
132}
133
134foreach (explode("\n", stream_get_contents(STDIN)) as $linea) {
135    $linea = trim($linea);
136    if ($linea === "") continue;
137    $p = preg_split('/\s+/', $linea, 2);
138    $orden = strtoupper($p[0]);
139    $args = isset($p[1]) ? preg_split('/\s+/', $p[1]) : [];
140    echo "> $linea\n";
141    match (true) {
142        $orden === "BUSCAR" && isset($p[1]) => buscar($pdo, $p[1]),
143        $orden === "PRESTAR" && count($args) === 3 => prestar($pdo, $args[0], (int) $args[1], $args[2]),
144        $orden === "DEVOLVER" && count($args) === 2 => devolver($pdo, (int) $args[0], $args[1]),
145        $orden === "MOROSOS" && count($args) === 1 => morosos($pdo, $args[0]),
146        $orden === "RESUMEN" => resumen($pdo),
147        default => print("Orden no válida\n"),
148    };
149}