up
This commit is contained in:
@@ -49,54 +49,49 @@ if ($sesionCerrada) {
|
||||
|
||||
// ── Cola según área ───────────────────────────────────────────
|
||||
if ($area === 'recepcion') {
|
||||
$estadosCola = ["'espera'", "'en_recepcion'"];
|
||||
// Recepción: todos los turnos en espera/en_recepcion
|
||||
$inEstados = "'espera', 'en_recepcion'";
|
||||
$filtroLugar = '';
|
||||
$bindsCola = [$sesionId];
|
||||
|
||||
$stmt = $pdo->prepare(
|
||||
"SELECT t.id, t.codigo, t.numero, t.estado, t.paciente_nombre,
|
||||
t.recepcion_desk_id, t.creado_at, t.llamado_recepcion_at, t.llamado_lugar_at,
|
||||
p.codigo AS prioridad_codigo, p.nombre AS prioridad_nombre,
|
||||
p.color AS prioridad_color, p.orden_peso
|
||||
FROM turnero_turnos t
|
||||
JOIN turnero_prioridades p ON p.id = t.prioridad_id
|
||||
WHERE t.sesion_id = ? AND t.estado IN ($inEstados)
|
||||
ORDER BY p.orden_peso ASC, t.creado_at ASC"
|
||||
);
|
||||
$stmt->execute($bindsCola);
|
||||
} else {
|
||||
$estadosCola = ["'en_espera_lugar'", "'en_servicio'"];
|
||||
// Expandir grupo de lugares
|
||||
$grupoIds = lugarIdsDeGrupo($lugarId);
|
||||
$inLugares = implode(',', array_map('intval', $grupoIds));
|
||||
$filtroLugar = "AND t.lugar_destino_id IN ($inLugares)";
|
||||
$bindsCola = [$sesionId];
|
||||
// Lugar: cola compartida (grupo) solo en_espera_lugar
|
||||
$grupoIds = lugarIdsDeGrupo($lugarId);
|
||||
$inLugares = implode(',', array_map('intval', $grupoIds));
|
||||
|
||||
$stmt = $pdo->prepare(
|
||||
"SELECT t.id, t.codigo, t.numero, t.estado, t.paciente_nombre,
|
||||
t.recepcion_desk_id, t.creado_at, t.llamado_recepcion_at, t.llamado_lugar_at,
|
||||
p.codigo AS prioridad_codigo, p.nombre AS prioridad_nombre,
|
||||
p.color AS prioridad_color, p.orden_peso
|
||||
FROM turnero_turnos t
|
||||
JOIN turnero_prioridades p ON p.id = t.prioridad_id
|
||||
WHERE t.sesion_id = ?
|
||||
AND t.estado = 'en_espera_lugar'
|
||||
AND t.lugar_destino_id IN ($inLugares)
|
||||
ORDER BY p.orden_peso ASC, t.creado_at ASC"
|
||||
);
|
||||
$stmt->execute([$sesionId]);
|
||||
}
|
||||
|
||||
$inEstados = implode(', ', $estadosCola);
|
||||
|
||||
$stmt = $pdo->prepare(
|
||||
"SELECT t.id,
|
||||
t.codigo,
|
||||
t.numero,
|
||||
t.estado,
|
||||
t.paciente_nombre,
|
||||
t.recepcion_desk_id,
|
||||
t.creado_at,
|
||||
t.llamado_recepcion_at,
|
||||
t.llamado_lugar_at,
|
||||
p.codigo AS prioridad_codigo,
|
||||
p.nombre AS prioridad_nombre,
|
||||
p.color AS prioridad_color,
|
||||
p.orden_peso
|
||||
FROM turnero_turnos t
|
||||
JOIN turnero_prioridades p ON p.id = t.prioridad_id
|
||||
WHERE t.sesion_id = ?
|
||||
AND t.estado IN ({$inEstados})
|
||||
{$filtroLugar}
|
||||
ORDER BY p.orden_peso ASC, t.creado_at ASC"
|
||||
);
|
||||
$stmt->execute($bindsCola);
|
||||
$cola = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
|
||||
// ── Turno actualmente en pantalla (último llamado) ────────────
|
||||
$campoLlamado = $area === 'recepcion' ? 'llamado_recepcion_at' : 'llamado_lugar_at';
|
||||
$estadoActivo = $area === 'recepcion' ? "'en_recepcion'" : "'en_servicio'";
|
||||
if ($area === 'lugar') {
|
||||
$filtroActivo = "AND t.lugar_destino_id IN ($inLugares)";
|
||||
$bindActivo = [$sesionId];
|
||||
} else {
|
||||
$filtroActivo = '';
|
||||
$bindActivo = [$sesionId];
|
||||
}
|
||||
// Activo: para lugar filtrar SOLO por esta estación (ya fue asignada al llamar)
|
||||
$filtroActivo = $area === 'lugar' ? 'AND t.lugar_destino_id = ?' : '';
|
||||
$bindActivo = $area === 'lugar' ? [$sesionId, $lugarId] : [$sesionId];
|
||||
|
||||
$stmt = $pdo->prepare(
|
||||
"SELECT t.id,
|
||||
|
||||
@@ -61,12 +61,12 @@ try {
|
||||
} else {
|
||||
// Cola de un Lugar específico: turnos 'en_espera_lugar' asignados a ese lugar
|
||||
if ($turnoId) {
|
||||
// Llamar uno específico por id
|
||||
// Llamar uno específico por id (puede ser en_espera_lugar o ya en_servicio para re-llamar)
|
||||
$stmt = $pdo->prepare(
|
||||
'SELECT t.*, p.codigo AS prioridad_codigo, p.nombre AS prioridad_nombre, p.color AS prioridad_color
|
||||
FROM turnero_turnos t
|
||||
JOIN turnero_prioridades p ON p.id = t.prioridad_id
|
||||
WHERE t.id = ? AND t.estado = "en_espera_lugar"'
|
||||
WHERE t.id = ? AND t.estado IN ("en_espera_lugar", "en_servicio")'
|
||||
);
|
||||
$stmt->execute([$turnoId]);
|
||||
$turno = $stmt->fetch(PDO::FETCH_ASSOC);
|
||||
@@ -82,15 +82,33 @@ try {
|
||||
}
|
||||
}
|
||||
|
||||
// Re-llamar: si ya está en_servicio en ESTA estación, solo actualiza llamado_at
|
||||
if ($turno['estado'] === 'en_servicio' && $turno['lugar_destino_id'] == $lugarId) {
|
||||
$pdo->prepare(
|
||||
'UPDATE turnero_turnos SET llamado_lugar_at = NOW() WHERE id = ?'
|
||||
)->execute([$turno['id']]);
|
||||
$pdo->commit();
|
||||
// Refrescar y retornar
|
||||
$stmt = $pdo->prepare(
|
||||
'SELECT t.*, p.codigo AS prioridad_codigo, p.nombre AS prioridad_nombre, p.color AS prioridad_color
|
||||
FROM turnero_turnos t JOIN turnero_prioridades p ON p.id = t.prioridad_id WHERE t.id = ?'
|
||||
);
|
||||
$stmt->execute([$turno['id']]);
|
||||
$turnoActualizado = $stmt->fetch(PDO::FETCH_ASSOC);
|
||||
notificarSSE((int)$turnoActualizado['sesion_id']);
|
||||
jsonOk(['turno' => $turnoActualizado], "Turno {$turnoActualizado['codigo']} re-llamado");
|
||||
}
|
||||
|
||||
$stmt = $pdo->prepare(
|
||||
'UPDATE turnero_turnos
|
||||
SET estado = "en_servicio",
|
||||
llamado_lugar_at = NOW(),
|
||||
inicio_lugar_at = NOW(),
|
||||
atendido_lugar_por = ?
|
||||
SET estado = "en_servicio",
|
||||
llamado_lugar_at = NOW(),
|
||||
inicio_lugar_at = NOW(),
|
||||
atendido_lugar_por= ?,
|
||||
lugar_destino_id = ?
|
||||
WHERE id = ? AND estado = "en_espera_lugar"'
|
||||
);
|
||||
$stmt->execute([adminId(), $turno['id']]);
|
||||
$stmt->execute([adminId(), $lugarId, $turno['id']]);
|
||||
|
||||
if ($stmt->rowCount() === 0) {
|
||||
$pdo->rollBack();
|
||||
|
||||
Reference in New Issue
Block a user