Resumen Diario

use App\Services\SunatService;
use App\Models\Venta;

class ResumenDiarioController extends Controller
{
    public function __construct(
        private SunatService $sunatService
    ) {}

    public function enviarResumen(Request $request)
    {
        $fecha = $request->fecha ?? today()->toDateString();
        $empresaId = $request->user()->id_empresa;

        // Obtener boletas del día no enviadas
        $boletas = Venta::where('id_empresa', $empresaId)
            ->whereHas('tipoDocumento', fn($q) => $q->where('cod_sunat', '03'))
            ->whereDate('fecha_emision', $fecha)
            ->where(function($q) {
                $q->whereNull('estado_sunat')
                  ->orWhere('estado_sunat', '0');  // Pendiente
            })
            ->with(['cliente', 'tipoDocumento'])
            ->get();

        if ($boletas->isEmpty()) {
            return response()->json([
                'success' => false,
                'message' => 'No hay boletas para enviar en esta fecha.'
            ]);
        }

        $empresa = auth()->user()->empresa;
        
        // Generar correlativo (001, 002, ...)
        $ultimoResumen = \DB::table('resumenes_diarios')
            ->where('id_empresa', $empresaId)
            ->whereDate('fecha_resumen', $fecha)
            ->max('correlativo');
        $correlativo = str_pad(((int)$ultimoResumen + 1), 3, '0', STR_PAD_LEFT);

        // Enviar resumen
        $resultado = $this->sunatService->resumenDiario(
            $empresa,
            $boletas->all(),
            $fecha,
            $correlativo
        );

        if ($resultado['success']) {
            // Guardar registro de resumen
            \DB::table('resumenes_diarios')->insert([
                'id_empresa' => $empresaId,
                'fecha_resumen' => $fecha,
                'correlativo' => $correlativo,
                'ticket' => $resultado['ticket'],
                'nombre_archivo' => $resultado['nombre_archivo'],
                'cantidad_boletas' => $resultado['cantidad'],
                'estado' => 'enviado',
                'created_at' => now(),
            ]);
        }

        return response()->json($resultado);
    }

    public function consultarTicket(Request $request, $ticket)
    {
        $empresa = $request->user()->empresa;
        $resultado = $this->sunatService->consultarTicket($empresa, $ticket);

        if ($resultado['success'] && $resultado['codigo'] === '0') {
            // Actualizar boletas como enviadas
            $resumen = \DB::table('resumenes_diarios')
                ->where('ticket', $ticket)
                ->first();

            if ($resumen) {
                Venta::where('id_empresa', $resumen->id_empresa)
                    ->whereDate('fecha_emision', $resumen->fecha_resumen)
                    ->whereHas('tipoDocumento', fn($q) => $q->where('cod_sunat', '03'))
                    ->update(['estado_sunat' => '1']);  // Aceptado

                \DB::table('resumenes_diarios')
                    ->where('ticket', $ticket)
                    ->update([
                        'estado' => 'aceptado',
                        'codigo_sunat' => $resultado['codigo'],
                        'mensaje_sunat' => $resultado['mensaje'],
                        'updated_at' => now(),
                    ]);
            }
        }

        return response()->json($resultado);
    }
}

import { enviarResumenDiario, consultarTicketResumen } from '@/services/sunat';

const procesarResumenDiario = async (fecha) => {
  // 1. Enviar resumen
  const envioResult = await enviarResumenDiario({ fecha });
  
  if (!envioResult.success) {
    toast.error(`Error: ${envioResult.message}`);
    return;
  }

  const ticket = envioResult.ticket;
  toast.info(
    `Resumen enviado. ${envioResult.cantidad} boletas. Ticket: ${ticket}`
  );

  // 2. Polling para consultar estado
  const maxIntentos = 24; // 4 minutos (cada 10 segundos)
  let intentos = 0;

  const intervalo = setInterval(async () => {
    intentos++;
    
    try {
      const estadoResult = await consultarTicketResumen(ticket);

      if (estadoResult.codigo === '98') {
        // Aún en proceso
        console.log(`Intento ${intentos}: En proceso...`);
        return;
      }

      // Respuesta definitiva
      clearInterval(intervalo);

      if (estadoResult.success) {
        toast.success(
          `Resumen aceptado por SUNAT. Código: ${estadoResult.codigo}`
        );
        
        if (estadoResult.notas && estadoResult.notas.length > 0) {
          console.warn('Observaciones:', estadoResult.notas);
        }
      } else {
        toast.error(
          `Rechazado por SUNAT: ${estadoResult.message}`
        );
      }
    } catch (error) {
      clearInterval(intervalo);
      toast.error(`Error al consultar: ${error.message}`);
    }
  }, 10000); // Cada 10 segundos

  // Timeout de 4 minutos
  setTimeout(() => {
    if (intentos < maxIntentos) {
      clearInterval(intervalo);
      toast.warning(
        'Tiempo de espera agotado. Consulte el ticket manualmente.'
      );
    }
  }, 240000);
};

CREATE TABLE resumenes_diarios (
    id INT PRIMARY KEY AUTO_INCREMENT,
    id_empresa INT NOT NULL,
    fecha_resumen DATE NOT NULL,
    correlativo VARCHAR(3) NOT NULL,
    ticket VARCHAR(100),
    nombre_archivo VARCHAR(255),
    cantidad_boletas INT,
    estado VARCHAR(20),             -- enviado, aceptado, rechazado
    codigo_sunat VARCHAR(10),
    mensaje_sunat TEXT,
    created_at TIMESTAMP,
    updated_at TIMESTAMP,
    UNIQUE KEY (id_empresa, fecha_resumen, correlativo)
);

// app/Console/Kernel.php
protected function schedule(Schedule $schedule)
{
    // Enviar resumen diario a las 11:55 PM
    $schedule->call(function () {
        $empresas = Empresa::where('modo', 'production')->get();
        
        foreach ($empresas as $empresa) {
            $boletas = Venta::where('id_empresa', $empresa->id_empresa)
                ->whereHas('tipoDocumento', fn($q) => $q->where('cod_sunat', '03'))
                ->whereDate('fecha_emision', today())
                ->where('estado_sunat', '0')
                ->get();

            if ($boletas->isNotEmpty()) {
                $sunatService = app(SunatService::class);
                $resultado = $sunatService->resumenDiario(
                    $empresa,
                    $boletas->all(),
                    today()->toDateString()
                );

                Log::info('Resumen diario automático', [
                    'empresa' => $empresa->ruc,
                    'boletas' => $boletas->count(),
                    'ticket' => $resultado['ticket'] ?? null,
                ]);
            }
        }
    })->dailyAt('23:55');
}