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 () { $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' => '0', 'type' => 'decimal']); SystemSetting::updateOrCreate(['key' => 'autopodbor_max_competitors'], ['value' => '15', 'type' => 'int']); // Фейк-агент отдаёт конкурента с телефонами в разных форматах (как из карточек). app()->bind(CompetitorAgent::class, fn () => new class implements CompetitorAgent { public function findCompetitors(FindCompetitorsRequest $r): FindCompetitorsResult { return new FindCompetitorsResult([ ['name' => 'Ф', 'site_url' => 'f.ru', 'directory_urls' => [], 'phones' => ['8 (800) 111-22-33', '+78001112233']], ]); } public function studyCompetitor(StudyCompetitorRequest $r): StudyCompetitorResult { return new StudyCompetitorResult([]); } public function resolveByName(ResolveByNameRequest $r): ResolveByNameResult { return new ResolveByNameResult([]); } }); $run = AutopodborRun::create([ 'tenant_id' => $tenant->id, 'kind' => 'search', 'status' => 'queued', 'region_code' => 16, 'params' => ['examples' => [], 'about_self' => [], 'include_federal' => false], ]); runSearchJob($run->id); $c = AutopodborCompetitor::where('search_run_id', $run->id)->where('name', 'Ф')->first(); expect($c)->not->toBeNull() ->and($c->phones)->toBe(['78001112233']); // два формата одного номера → один нормализованный }); 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'); });