-
\ No newline at end of file
+
diff --git a/registro_salida.php b/registro_salida.php
index 9c99abd..1e11959 100644
--- a/registro_salida.php
+++ b/registro_salida.php
@@ -11,58 +11,71 @@ if ($_SERVER["REQUEST_METHOD"] == "POST") {
$product_id = filter_input(INPUT_POST, 'product_id', FILTER_VALIDATE_INT);
$sede_id = filter_input(INPUT_POST, 'sede_id', FILTER_VALIDATE_INT);
$quantity = filter_input(INPUT_POST, 'quantity', FILTER_VALIDATE_INT);
+ $movement_date = filter_input(INPUT_POST, 'movement_date');
- if ($product_id && $sede_id && $quantity) {
+ if ($product_id && $sede_id && $quantity && $movement_date) {
try {
- $pdo = new PDO("mysql:host=" . DB_HOST . ";dbname=" . DB_NAME . ";charset=utf8", DB_USER, DB_PASS);
- $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+ $pdo = db();
+ $pdo->beginTransaction();
- // Verificar si ya existe un registro para este producto en esta sede
+ // 1. Verificar y actualizar stock en stock_sedes
$stmt = $pdo->prepare("SELECT * FROM stock_sedes WHERE product_id = :product_id AND sede_id = :sede_id");
$stmt->execute(['product_id' => $product_id, 'sede_id' => $sede_id]);
$existing_stock = $stmt->fetch();
if ($existing_stock) {
- // Si existe, actualizar la cantidad
$new_quantity = $existing_stock['quantity'] - $quantity;
if ($new_quantity < 0) {
$error = "No hay suficiente stock para registrar la salida.";
+ $pdo->rollBack();
} else {
$update_stmt = $pdo->prepare("UPDATE stock_sedes SET quantity = :quantity WHERE id = :id");
$update_stmt->execute(['quantity' => $new_quantity, 'id' => $existing_stock['id']]);
- $message = "¡Inventario actualizado correctamente!";
+
+ // 2. Insertar en el historial de movimientos
+ $history_stmt = $pdo->prepare(
+ "INSERT INTO stock_movements (product_id, sede_id, quantity, type, movement_date)
+ VALUES (:product_id, :sede_id, :quantity, 'salida', :movement_date)"
+ );
+ $history_stmt->execute([
+ 'product_id' => $product_id,
+ 'sede_id' => $sede_id,
+ 'quantity' => $quantity,
+ 'movement_date' => $movement_date
+ ]);
+
+ $pdo->commit();
+ $message = "¡Inventario actualizado y movimiento registrado correctamente!";
}
} else {
- // Si no existe, no se puede dar salida
$error = "No hay stock registrado para este producto en la sede seleccionada.";
+ $pdo->rollBack();
}
} catch (PDOException $e) {
+ if ($pdo->inTransaction()) {
+ $pdo->rollBack();
+ }
$error = "Error al actualizar el inventario: " . $e->getMessage();
}
} else {
- $error = "Por favor, complete todos los campos del formulario.";
+ $error = "Por favor, complete todos los campos del formulario, incluyendo la fecha.";
}
}
-// Obtener productos y sedes de la base de datos para los dropdowns
+// Obtener productos y sedes para los dropdowns
$products = [];
$sedes = [];
-
try {
- $pdo = new PDO("mysql:host=" . DB_HOST . ";dbname=" . DB_NAME . ";charset=utf8", DB_USER, DB_PASS);
- $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-
+ $pdo = db();
$products_stmt = $pdo->query("SELECT id, nombre FROM products ORDER BY nombre ASC");
$products = $products_stmt->fetchAll(PDO::FETCH_ASSOC);
$sedes_stmt = $pdo->query("SELECT id, nombre FROM sedes ORDER BY nombre ASC");
$sedes = $sedes_stmt->fetchAll(PDO::FETCH_ASSOC);
-
} catch (PDOException $e) {
$error = "Error al cargar datos: " . $e->getMessage();
}
-
?>
-
\ No newline at end of file
+
diff --git a/save_flujo_caja.php b/save_flujo_caja.php
index 7eb8768..120aedc 100644
--- a/save_flujo_caja.php
+++ b/save_flujo_caja.php
@@ -12,7 +12,7 @@ if ($data) {
$allowed_columns = [
'bcp_yape', 'b_nacion', 'interbank', 'bbva', 'otros_ingresos',
'tu1', 'tu2', 'tu3', 'fl1', 'fl2', 'fl3',
- 'rc_envio', 'rc_contraent', 'total_inversion_publicitaria'
+ 'rc_envio', 'rc_contraent', 'sc', 'total_inversion_publicitaria'
];
if (in_array($columna, $allowed_columns)) {