<?php

namespace App\Console\Commands;

use App\Jobs\ProcessOutboundCallJob;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

/**
 * Catches outbound CDR rows that were never processed by ProcessOutboundCallJob.
 *
 * FAILED calls (and any other disposition that bypasses agihangupaction) do not
 * trigger the real-time dispatch in console.php.  This command fills that gap by
 * scanning a rolling look-back window and dispatching the job for any linkedid
 * that has no entry in outbound_reports yet.
 *
 * Designed to run every 5 minutes via the scheduler.
 */
class PollRecentOutboundCalls extends Command
{
    protected $signature = 'reports:outbound:poll-recent
                            {--minutes=30 : Look-back window in minutes}';

    protected $description = 'Dispatch ProcessOutboundCallJob for recent outbound CDR rows not yet in outbound_reports (covers FAILED and other missed dispositions)';

    public function handle(): int
    {
        $minutes = (int) $this->option('minutes');
        $since   = now()->subMinutes($minutes)->format('Y-m-d H:i:s');

        // Scope to company users (same filter as the daily batch)
        $userIds = DB::table('users')
            ->whereNotNull('company_id')
            ->pluck('id')
            ->all();

        if (empty($userIds)) {
            $this->line('No users found — nothing to poll.');
            return Command::SUCCESS;
        }

        // Find linkedids present in CDR but absent from outbound_reports
        $unprocessed = DB::table('asteriskcdrdb.cdr')
            ->select('linkedid')
            ->whereIn('disposition', ['ANSWERED', 'BUSY', 'NO ANSWER', 'FAILED'])
            ->where('dcontext', 'from-internal')
            ->where('lastapp', 'Dial')
            ->whereColumn('uniqueid', 'linkedid')
            ->where('calldate', '>=', $since)
            ->whereIn('cnum', $userIds)
            ->whereNotIn('linkedid', function ($q) {
                $q->select('linkedid')->from('outbound_reports');
            })
            ->distinct()
            ->pluck('linkedid');

        if ($unprocessed->isEmpty()) {
            $this->line('No unprocessed outbound calls found in the last ' . $minutes . ' minutes.');
            return Command::SUCCESS;
        }

        $this->info('Found ' . $unprocessed->count() . ' unprocessed outbound call(s) — dispatching jobs...');

        foreach ($unprocessed as $linkedid) {
            // Small stagger so workers aren't hammered simultaneously
            ProcessOutboundCallJob::dispatch($linkedid)->delay(now()->addSeconds(3));
        }

        return Command::SUCCESS;
    }
}