terminado (provisional) modulo de facturas

src/main/java/com/imprimelibros/erp/pedidos/PedidoEstadoService.java

@@ -0,0 +1,55 @@
+package com.imprimelibros.erp.pedidos;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+
+@Service
+public class PedidoEstadoService {
+
+    private static final Logger log = LoggerFactory.getLogger(PedidoEstadoService.class);
+
+    private final PedidoLineaRepository pedidoLineaRepository;
+    private final PedidoService pedidoService;
+
+    public PedidoEstadoService(PedidoLineaRepository pedidoLineaRepository, PedidoService pedidoService) {
+        this.pedidoLineaRepository = pedidoLineaRepository;
+        this.pedidoService = pedidoService;
+    }
+
+    /**
+     * Ejecuta cada noche a las 4:00 AM
+     */
+    @Scheduled(cron = "0 0 4 * * *")
+    public void actualizarEstadosPedidos() {
+
+        List<PedidoLinea> pedidosLineas = pedidoLineaRepository.findPedidosLineasParaActualizarEstado();
+
+        for (PedidoLinea linea : pedidosLineas) {
+            try {
+                Map<String, Object> resultado = pedidoService.actualizarEstado(linea.getId(), Locale.getDefault());
+
+                if (!Boolean.TRUE.equals(resultado.get("success"))) {
+                    log.error("Error al actualizar estado. pedidoLineaId={} message={}",
+                            linea.getId(), resultado.get("message"));
+                }
+            } catch (Exception ex) {
+                log.error("Excepción actualizando estado. pedidoLineaId={}", linea.getId(), ex);
+            }
+
+            // rate limit / delay
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+                log.error("Job interrumpido mientras dormía (rate limit).");
+                return;
+            }
+        }
+    }
+}

src/main/java/com/imprimelibros/erp/pedidos/PedidoLineaRepository.java

@@ -1,6 +1,7 @@
 package com.imprimelibros.erp.pedidos;
 
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
@@ -9,7 +10,25 @@ import java.util.List;
 public interface PedidoLineaRepository extends JpaRepository<PedidoLinea, Long> {
 
     List<PedidoLinea> findByPedidoId(Long pedidoId);
+
     List<PedidoLinea> findByPedidoIdOrderByIdAsc(Long pedidoId);
 
     List<PedidoLinea> findByPresupuestoId(Long presupuestoId);
+
+    @Query("""
+                SELECT pl
+                FROM PedidoLinea pl
+                JOIN pl.presupuesto p
+                WHERE pl.estadoManual = false
+                  AND pl.estado IN (
+                        'haciendo_ferro',
+                        'esperando_aceptacion_ferro',
+                        'produccion',
+                        'terminado'
+                  )
+                  AND p.proveedor = 'Safekat'
+                  AND p.proveedorRef1 IS NOT NULL
+                  AND p.proveedorRef2 IS NOT NULL
+            """)
+    List<PedidoLinea> findPedidosLineasParaActualizarEstado();
 }

src/main/java/com/imprimelibros/erp/pedidos/PedidoService.java

@@ -24,6 +24,7 @@ import com.imprimelibros.erp.presupuesto.service.PresupuestoService;
 import com.imprimelibros.erp.users.UserService;
 import com.imprimelibros.erp.direcciones.DireccionService;
 import com.imprimelibros.erp.externalApi.skApiClient;
+import com.imprimelibros.erp.facturacion.FacturaDireccion;
 import com.imprimelibros.erp.facturacion.dto.DireccionFacturacionDto;
 import com.imprimelibros.erp.pedidos.PedidoLinea.Estado;
 
@@ -191,24 +192,24 @@ public class PedidoService {
 
         try {
             Pedido pedido = pedidoRepository.findById(pedidoId).orElse(null);
-            if (pedido == null) {
-                return false;
+            if (pedido != null) {
+
+                PedidoDireccion direccionPedido = pedidoDireccionRepository.findByPedidoIdAndFacturacionTrue(pedidoId);
+
+                if (direccionPedido == null) {
+                    // crear
+                    direccionPedido = direccionData.toPedidoDireccion();
+                    direccionPedido.setPedido(pedido);
+
+                } else {
+                    // actualizar en la existente (NO crees una nueva, para conservar ID)
+                    direccionData.applyTo(direccionPedido); // si implementas applyTo()
+                    direccionPedido.setFacturacion(true); // por si acaso
+                }
+
+                pedidoDireccionRepository.save(direccionPedido);
             }
 
-            PedidoDireccion direccionPedido = pedidoDireccionRepository.findByPedidoIdAndFacturacionTrue(pedidoId);
-
-            if (direccionPedido == null) {
-                // crear
-                direccionPedido = direccionData.toPedidoDireccion();
-                direccionPedido.setPedido(pedido);
-
-            } else {
-                // actualizar en la existente (NO crees una nueva, para conservar ID)
-                direccionData.applyTo(direccionPedido); // si implementas applyTo()
-                direccionPedido.setFacturacion(true); // por si acaso
-            }
-
-            pedidoDireccionRepository.save(direccionPedido);
             return true;
         } catch (Exception e) {
             e.printStackTrace();
@@ -299,43 +300,81 @@ public class PedidoService {
     }
 
     public Map<String, Object> actualizarEstado(Long pedidoLineaId, Locale locale) {
+
         PedidoLinea pedidoLinea = pedidoLineaRepository.findById(pedidoLineaId).orElse(null);
         if (pedidoLinea == null) {
-            return Map.of("success", false,
+            return Map.of(
+                    "success", false,
                     "message", messageSource.getMessage("pedido.errors.linea-not-found", null, locale));
         }
 
-        if (pedidoLinea.getEstado().getPriority() >= PedidoLinea.Estado.haciendo_ferro.getPriority() &&
-                pedidoLinea.getEstado().getPriority() < PedidoLinea.Estado.enviado.getPriority()) {
-            PedidoLinea.Estado estadoOld = pedidoLinea.getEstado();
-            Map<String, Object> result = skApiClient.checkPedidoEstado(
-                    Long.valueOf(pedidoLinea.getPresupuesto().getProveedorRef2().toString()), locale);
-            if (result == null || !result.containsKey("estado")) {
-                return Map.of(
-                        "success", false,
-                        "message", messageSource.getMessage("pedido.errors.update-server-error", null, locale));
-            }
-            PedidoLinea.Estado estadoSk = PedidoLinea.Estado.valueOf((String) result.get("estado"));
-            if (estadoOld == estadoSk) {
-                return Map.of(
-                        "success", true,
-                        "state", messageSource.getMessage("pedido.estado." + estadoSk.name(), null, locale),
-                        "stateKey", estadoSk.name(),
-                        "message", messageSource.getMessage("pedido.success.same-estado", null, locale));
-            }
+        PedidoLinea.Estado estadoOld = pedidoLinea.getEstado();
+        if (estadoOld == null) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.cannot-update", null, locale));
+        }
 
-            pedidoLinea.setEstado(estadoSk);
-            pedidoLineaRepository.save(pedidoLinea);
+        // Rango: >= haciendo_ferro y < enviado
+        if (estadoOld.getPriority() < PedidoLinea.Estado.haciendo_ferro.getPriority()
+                || estadoOld.getPriority() >= PedidoLinea.Estado.enviado.getPriority()) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.cannot-update", null, locale));
+        }
+
+        var presupuesto = pedidoLinea.getPresupuesto();
+        if (presupuesto == null || presupuesto.getProveedorRef2() == null) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.update-server-error", null, locale));
+        }
+
+        Long refExterna;
+        try {
+            refExterna = Long.valueOf(presupuesto.getProveedorRef2().toString());
+        } catch (Exception ex) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.update-server-error", null, locale));
+        }
+
+        Map<String, Object> result = skApiClient.checkPedidoEstado(refExterna, locale);
+
+        if (result == null || result.get("estado") == null) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.update-server-error", null, locale));
+        }
+
+        String estadoStr = String.valueOf(result.get("estado"));
+
+        PedidoLinea.Estado estadoSk;
+        try {
+            // si la API devuelve minúsculas tipo "produccion", esto funciona
+            estadoSk = PedidoLinea.Estado.valueOf(estadoStr.trim().toLowerCase());
+        } catch (Exception ex) {
+            return Map.of(
+                    "success", false,
+                    "message", messageSource.getMessage("pedido.errors.update-server-error", null, locale));
+        }
+
+        if (estadoOld == estadoSk) {
             return Map.of(
                     "success", true,
                     "state", messageSource.getMessage("pedido.estado." + estadoSk.name(), null, locale),
                     "stateKey", estadoSk.name(),
-                    "message", messageSource.getMessage("pedido.success.estado-actualizado", null, locale));
+                    "message", messageSource.getMessage("pedido.success.same-estado", null, locale));
         }
 
+        pedidoLinea.setEstado(estadoSk);
+        pedidoLineaRepository.save(pedidoLinea);
+
         return Map.of(
-                "success", false,
-                "message", messageSource.getMessage("pedido.errors.cannot-update", null, locale));
+                "success", true,
+                "state", messageSource.getMessage("pedido.estado." + estadoSk.name(), null, locale),
+                "stateKey", estadoSk.name(),
+                "message", messageSource.getMessage("pedido.success.estado-actualizado", null, locale));
     }
 
     public Boolean markPedidoAsMaquetacionDone(Long pedidoId) {

src/main/java/com/imprimelibros/erp/pedidos/PedidosController.java

@@ -26,6 +26,7 @@ import com.imprimelibros.erp.datatables.DataTable;
 import com.imprimelibros.erp.datatables.DataTablesParser;
 import com.imprimelibros.erp.datatables.DataTablesRequest;
 import com.imprimelibros.erp.datatables.DataTablesResponse;
+import com.imprimelibros.erp.facturacion.service.FacturacionService;
 import com.imprimelibros.erp.i18n.TranslationService;
 import com.imprimelibros.erp.paises.PaisesService;
 import com.imprimelibros.erp.presupuesto.service.PresupuestoService;
@@ -52,10 +53,12 @@ public class PedidosController {
     private final PedidoLineaRepository repoPedidoLinea;
     private final PaisesService paisesService;
     private final TranslationService translationService;
+    private final FacturacionService facturacionService;
 
     public PedidosController(PedidoRepository repoPedido, PedidoService pedidoService, UserDao repoUser,
             MessageSource messageSource, TranslationService translationService,
-            PedidoLineaRepository repoPedidoLinea, PaisesService paisesService, PresupuestoService presupuestoService) {
+            PedidoLineaRepository repoPedidoLinea, PaisesService paisesService,
+            FacturacionService facturacionService, PresupuestoService presupuestoService) {
         this.repoPedido = repoPedido;
         this.pedidoService = pedidoService;
         this.repoUser = repoUser;
@@ -63,6 +66,7 @@ public class PedidosController {
         this.translationService = translationService;
         this.repoPedidoLinea = repoPedidoLinea;
         this.paisesService = paisesService;
+        this.facturacionService = facturacionService;
         this.presupuestoService = presupuestoService;
     }
 
@@ -236,6 +240,7 @@ public class PedidosController {
         model.addAttribute("direccionFacturacion", direccionFacturacion);
 
         Boolean showCancel = false;
+        Boolean showDownloadFactura = true;
         List<Map<String, Object>> lineas = pedidoService.getLineas(id, locale);
         for (Map<String, Object> linea : lineas) {
 
@@ -243,6 +248,9 @@ public class PedidosController {
                     ((Number) linea.get("lineaId")).longValue()).orElse(null);
             if (pedidoLinea != null) {
                 Map<String, Boolean> buttons = new HashMap<>();
+                if (pedidoLinea.getEstado() != PedidoLinea.Estado.enviado) {
+                    showDownloadFactura = false;
+                }
                 if (pedidoLinea.getEstado().getPriority() >= PedidoLinea.Estado.esperando_aceptacion_ferro.getPriority()
                         && pedidoLinea.getEstado().getPriority() <= PedidoLinea.Estado.produccion.getPriority()) {
 
@@ -263,8 +271,10 @@ public class PedidosController {
                     linea.put("buttons", buttons);
                 }
 
-                if(pedidoLinea.getEstado() != PedidoLinea.Estado.cancelado && pedidoLinea.getEstado() != PedidoLinea.Estado.terminado && pedidoLinea.getEstado() != PedidoLinea.Estado.enviado) {
-                    showCancel = true;   
+                if (pedidoLinea.getEstado() != PedidoLinea.Estado.cancelado
+                        && pedidoLinea.getEstado() != PedidoLinea.Estado.terminado
+                        && pedidoLinea.getEstado() != PedidoLinea.Estado.enviado) {
+                    showCancel = true;
                 }
             }
 
@@ -280,8 +290,16 @@ public class PedidosController {
             linea.put("direccionesEntrega", dirEntrega);
 
         }
+        Long facturaId = null;
+        if (showDownloadFactura) {
+            facturaId = facturacionService.getFacturaIdFromPedidoId(id);
+        }
         model.addAttribute("lineas", lineas);
-        model.addAttribute("showCancel", showCancel);   
+        model.addAttribute("showCancel", showCancel);
+        if (showDownloadFactura && facturaId != null) {
+            model.addAttribute("facturaId", facturaId);
+            model.addAttribute("showDownloadFactura", showDownloadFactura);
+        }
         model.addAttribute("id", id);
         return "imprimelibros/pedidos/pedidos-view";
     }