hecho lo de proximos envios

ci4/app/Services/LogisticaService.php

@@ -79,6 +79,79 @@ class LogisticaService
         return $builder;
     }
 
+    public static function findNextEnvios(int $envio_id)
+    {
+        $db = \Config\Database::connect();
+
+        // 1. Dirección del envío actual
+        $envio = $db->table('envios')->select('direccion')->where('id', $envio_id)->get()->getRow();
+        if (!$envio) {
+            return $db->table('(SELECT NULL AS id, NULL AS name) AS empty')->where('1 = 0');
+        }
+
+        $direccionNormalizada = str_replace(' ', '', strtolower(trim($envio->direccion)));
+        $direccionSQL = $db->escape($direccionNormalizada);
+
+        // 2. Obtener presupuestos con esa dirección
+        $presupuestosConEsaDireccion = $db->table('presupuesto_direcciones')
+            ->select('presupuesto_id')
+            ->where("REPLACE(LOWER(TRIM(direccion)), ' ', '') = $direccionSQL", null, false)
+            ->get()
+            ->getResultArray();
+
+        $presupuestoIds = array_column($presupuestosConEsaDireccion, 'presupuesto_id');
+        if (empty($presupuestoIds)) {
+            return $db->table('(SELECT NULL AS id, NULL AS name) AS empty')->where('1 = 0');
+        }
+
+        $hoy = date('Y-m-d');
+        $sieteDiasDespues = date('Y-m-d', strtotime('+7 days'));
+
+        // 3. Subconsulta principal
+        $subBuilder = $db->table('pedidos_linea pl')
+            ->select("
+            ot.id AS ot,
+            DATE(p.fecha_encuadernado) as fechaEncuadernado,
+            (
+                SELECT IFNULL(SUM(el.unidades_envio), 0)
+                FROM envios_lineas el
+                JOIN envios e ON e.id = el.envio_id
+                WHERE el.pedido_id = p.id
+                AND el.presupuesto_id = pr.id
+                AND REPLACE(LOWER(TRIM(e.direccion)), ' ', '') = $direccionSQL
+                AND (e.finalizado = 1 OR e.id = $envio_id)
+            ) AS unidades_enviadas,
+            pd.cantidad AS cantidad
+        ")
+            ->join('pedidos p', 'p.id = pl.pedido_id')
+            ->join('presupuestos pr', 'pr.id = pl.presupuesto_id')
+            ->join('presupuesto_direcciones pd', 'pd.presupuesto_id = pr.id')
+            ->join('ordenes_trabajo ot', 'ot.pedido_id = p.id')
+            ->join('orden_trabajo_dates ot_dates', 'ot_dates.orden_trabajo_id = ot.id')
+            ->whereIn('pr.id', $presupuestoIds)
+            ->whereIn('p.estado', ['finalizado', 'produccion'])
+            ->where('p.fecha_encuadernado IS NOT NULL')
+            ->where('DATE(p.fecha_encuadernado) >=', $hoy)
+            ->where('DATE(p.fecha_encuadernado) <=', $sieteDiasDespues)
+            ->where("NOT EXISTS (
+            SELECT 1
+            FROM envios_lineas el
+            WHERE el.envio_id = $envio_id
+            AND el.pedido_id = p.id
+            AND el.presupuesto_id = pr.id
+            GROUP BY el.pedido_id, el.presupuesto_id
+            HAVING SUM(el.unidades_envio) >= pd.cantidad
+        )", null, false)
+            ->groupBy('pl.id');
+
+        // 4. Envolver y filtrar por unidades pendientes
+        $builder = $db->table("({$subBuilder->getCompiledSelect(false)}) AS sub");
+        $builder->select('ot, fechaEncuadernado');
+        $builder->where('cantidad > unidades_enviadas');
+        
+        return $builder;
+    }
+
 
     public static function findForNewEnvio()
     {