portal/app/tests/Feature/Autopodbor/RunAutopodborSearchJobTest.php

<?php

declare(strict_types=1);

use App\Jobs\Autopodbor\RunAutopodborSearchJob;
use App\Mail\AutopodborReadyMail;
use App\Models\AutopodborCompetitor;
use App\Models\AutopodborRun;
use App\Models\SystemSetting;
use App\Models\Tenant;
use App\Services\Autopodbor\Agent\CompetitorAgent;
use Illuminate\Foundation\Testing\DatabaseTransactions;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Mail;
use Tests\Concerns\SharesSupplierPdo;
use Tests\Doubles\EmptyCompetitorAgent;

uses(DatabaseTransactions::class, SharesSupplierPdo::class);

function runSearchJob(int $runId): void
{
    // handle через контейнер (DI зависимостей)
    app()->call([new RunAutopodborSearchJob($runId), 'handle']);
}

it('успешный подбор: сохраняет конкурентов, списывает, status=done', function () {
    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '500', 'type' => 'decimal']);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_max_competitors'], ['value' => '15', 'type' => 'int']);
    $run = AutopodborRun::create([
        'tenant_id' => $tenant->id,
        'kind' => 'search',
        'status' => 'queued',
        'region_code' => 16,
        'params' => ['examples' => ['okna.ru'], 'about_self' => [], 'include_federal' => true],
    ]);

    runSearchJob($run->id);

    expect($run->fresh()->status)->toBe('done')
        ->and($run->fresh()->price_rub_charged)->toBe('500.00')
        ->and(AutopodborCompetitor::where('search_run_id', $run->id)->count())->toBeGreaterThan(0)
        ->and((string) $tenant->fresh()->balance_rub)->toBe('99500.00');
});

it('после готового подбора шлёт письмо «готово» на почту тенанта', function () {
    Mail::fake();
    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00', 'contact_email' => 'client@demo.local']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '500', 'type' => 'decimal']);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_max_competitors'], ['value' => '15', 'type' => 'int']);
    $run = AutopodborRun::create([
        'tenant_id' => $tenant->id, 'kind' => 'search', 'status' => 'queued',
        'region_code' => 16, 'params' => ['examples' => ['okna.ru'], 'about_self' => [], 'include_federal' => true],
    ]);

    runSearchJob($run->id);

    expect($run->fresh()->status)->toBe('done');
    Mail::assertSent(AutopodborReadyMail::class, fn ($m) => $m->hasTo('client@demo.local'));
});

it('пустой результат: status=empty, без списания', function () {
    app()->bind(CompetitorAgent::class, EmptyCompetitorAgent::class);
    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '500', 'type' => 'decimal']);
    $run = AutopodborRun::create([
        'tenant_id' => $tenant->id,
        'kind' => 'search',
        'status' => 'queued',
        'region_code' => 16,
        'params' => ['examples' => [], 'about_self' => [], 'include_federal' => false],
    ]);

    runSearchJob($run->id);

    expect($run->fresh()->status)->toBe('empty')
        ->and($run->fresh()->price_rub_charged)->toBeNull()
        ->and((string) $tenant->fresh()->balance_rub)->toBe('100000.00');
});

it('если почта падает с исключением — прогон всё равно завершается статусом done и конкуренты сохранены', function () {
    // Имитируем недоступность SMTP: Mail::to() бросает исключение
    Mail::shouldReceive('to')->andThrow(new RuntimeException('smtp down'));

    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00', 'contact_email' => 'client@demo.local']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '500', 'type' => 'decimal']);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_max_competitors'], ['value' => '15', 'type' => 'int']);
    $run = AutopodborRun::create([
        'tenant_id' => $tenant->id, 'kind' => 'search', 'status' => 'queued',
        'region_code' => 16, 'params' => ['examples' => ['okna.ru'], 'about_self' => [], 'include_federal' => true],
    ]);

    // handle() НЕ должен бросать — ошибка почты поглощается внутри notifyReady()
    expect(fn () => runSearchJob($run->id))->not->toThrow(Throwable::class);

    expect($run->fresh()->status)->toBe('done')
        ->and(AutopodborCompetitor::where('search_run_id', $run->id)->count())->toBeGreaterThan(0);
});

it('если почта падает при пустом результате — прогон всё равно завершается статусом empty', function () {
    Mail::shouldReceive('to')->andThrow(new RuntimeException('smtp down'));

    app()->bind(CompetitorAgent::class, EmptyCompetitorAgent::class);
    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00', 'contact_email' => 'client@demo.local']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '500', 'type' => 'decimal']);
    $run = AutopodborRun::create([
        'tenant_id' => $tenant->id, 'kind' => 'search', 'status' => 'queued',
        'region_code' => 16, 'params' => ['examples' => [], 'about_self' => [], 'include_federal' => false],
    ]);

    expect(fn () => runSearchJob($run->id))->not->toThrow(Throwable::class);

    expect($run->fresh()->status)->toBe('empty');
});

it('повторный подбор не дублирует известных конкурентов и не списывает (сквозной дедуп)', function () {
    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
    DB::statement('SET app.current_tenant_id = '.$tenant->id);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_price_search_rub'], ['value' => '300', 'type' => 'decimal']);
    SystemSetting::updateOrCreate(['key' => 'autopodbor_max_competitors'], ['value' => '15', 'type' => 'int']);

    $mk = fn () => AutopodborRun::create([
        'tenant_id' => $tenant->id, 'kind' => 'search', 'status' => 'queued',
        'region_code' => 16, 'params' => ['examples' => ['okna.ru'], 'about_self' => [], 'include_federal' => true],
    ]);

    $run1 = $mk();
    runSearchJob($run1->id);
    $afterFirst = AutopodborCompetitor::where('tenant_id', $tenant->id)->count();
    expect($afterFirst)->toBeGreaterThan(0);

    $run2 = $mk();
    runSearchJob($run2->id);

    // Заглушка отдаёт тот же набор → второй прогон не добавляет дублей и не списывает
    expect(AutopodborCompetitor::where('tenant_id', $tenant->id)->count())->toBe($afterFirst)
        ->and($run2->fresh()->status)->toBe('empty')
        ->and($run2->fresh()->price_rub_charged)->toBeNull()
        ->and((string) $tenant->fresh()->balance_rub)->toBe('99700.00');
});