<?php
header('Content-Type: application/json');
require_once __DIR__ . '/../config/db.php';
$pdo = getDBConnection();

try {
    // Obtener distribuciones con detalle_traslados_v2 + ingresos
    $sql = "SELECT 
                DATE(t.fecha_traslado) as fecha,
                t.id as traslado_id,
                t.sucursal_destino,
                s.nombre as sucursal_nombre,
                p.NombreComercial as producto,
                p.id as producto_id,
                dt.cantidad_unidades_base as cantidad,
                dt.es_facturado as sefactura,
                ins.id as ingreso_id,
                ins.cantidad_ingresada as total_ingreso
            FROM traslados t
            JOIN detalle_traslados_v2 dt ON t.id = dt.traslado_id
            JOIN productos p ON dt.producto_id = p.id
            JOIN sucursales s ON t.sucursal_destino = s.id
            LEFT JOIN ingresos_sucursal ins ON ins.producto_id = p.id 
                AND DATE(ins.fecha_ingreso) = DATE(t.fecha_traslado) 
                AND ins.sucursal_id = 1
            WHERE t.sucursal_origen = 1 
            ORDER BY t.fecha_traslado DESC, t.id DESC";

    $stmt = $pdo->query($sql);
    $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

    $history = [];
    foreach ($rows as $row) {
        $fecha = $row['fecha'];
        if (!isset($history[$fecha])) $history[$fecha] = [];
        
        $prodName = $row['producto'];
        if (!isset($history[$fecha][$prodName])) {
            $history[$fecha][$prodName] = [
                'producto' => $prodName,
                'producto_id' => $row['producto_id'],
                'ingreso_id' => $row['ingreso_id'],
                'sefactura' => $row['sefactura'],
                'total_ingreso' => $row['total_ingreso'],
                'distribuciones' => []
            ];
        }
        $history[$fecha][$prodName]['distribuciones'][$row['sucursal_destino']] = [
            'cantidad' => $row['cantidad'],
            'traslado_id' => $row['traslado_id']
        ];
    }

    echo json_encode(['success' => true, 'history' => $history]);
} catch (Exception $e) {
    echo json_encode(['success' => false, 'message' => 'Error API: ' . $e->getMessage()]);
}
?>
