Дмитрий
89 lines
3.9 KiB
PHP
89 lines
3.9 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
use Illuminate\Foundation\Testing\DatabaseTransactions;
|
||
use Illuminate\Support\Facades\DB;
|
||
use Tests\Concerns\SharesSupplierPdo;
|
||
|
||
uses(DatabaseTransactions::class);
|
||
uses(SharesSupplierPdo::class);
|
||
|
||
function rossvyazFixture(): string
|
||
{
|
||
return base_path('tests/Fixtures/rossvyaz/sample.csv');
|
||
}
|
||
|
||
it('dry-run parses csv, maps regions to subject_code, builds staging, does not swap', function (): void {
|
||
$this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true])
|
||
->assertSuccessful();
|
||
|
||
// Staging построен (dry-run не свапает и не дропает staging — данные видны в той же tx).
|
||
expect(DB::table('phone_ranges_staging')->count())->toBe(3);
|
||
|
||
$r495 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 495');
|
||
$r921 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 921');
|
||
$r999 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 999');
|
||
|
||
expect((int) $r495->subject_code)->toBe(82) // Москва
|
||
->and((int) $r921->subject_code)->toBe(83) // Санкт-Петербург
|
||
->and($r999->subject_code)->toBeNull(); // Атлантида — не маппится
|
||
|
||
// Живой phone_ranges не тронут (свапа не было).
|
||
expect(DB::table('phone_ranges')->count())->toBe(0);
|
||
|
||
// Журнал импорта: dry-run → rolled_back, несматчившийся регион в error.
|
||
$imp = DB::table('phone_ranges_imports')->orderByDesc('id')->first();
|
||
expect($imp->status)->toBe('rolled_back')
|
||
->and($imp->error)->toContain('Атлантида');
|
||
});
|
||
|
||
it('maps all matched rows and counts unmatched separately', function (): void {
|
||
$this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true])
|
||
->assertSuccessful();
|
||
|
||
$matched = DB::table('phone_ranges_staging')->whereNotNull('subject_code')->count();
|
||
$unmatched = DB::table('phone_ranges_staging')->whereNull('subject_code')->count();
|
||
|
||
expect($matched)->toBe(2)->and($unmatched)->toBe(1);
|
||
});
|
||
|
||
it('skips swap when checksum matches a completed import (idempotency)', function (): void {
|
||
$checksum = hash_file('sha256', rossvyazFixture());
|
||
DB::table('phone_ranges_imports')->insert([
|
||
'source_url' => 'https://rossvyaz.gov.ru/prev',
|
||
'checksum_sha256' => $checksum,
|
||
'status' => 'completed',
|
||
'imported_at' => now(),
|
||
'completed_at' => now(),
|
||
]);
|
||
|
||
// Не dry-run: но checksum совпал с completed → короткое замыкание ДО свапа.
|
||
$this->artisan('phone-ranges:import', ['--file' => rossvyazFixture()])
|
||
->assertSuccessful();
|
||
|
||
expect(DB::table('phone_ranges')->count())->toBe(0); // свапа не было
|
||
|
||
$latest = DB::table('phone_ranges_imports')->orderByDesc('id')->first();
|
||
expect($latest->status)->toBe('rolled_back');
|
||
});
|
||
|
||
it('force flag bypasses idempotency note even with matching checksum', function (): void {
|
||
// С --dry-run + --force: идемпотентность игнорируется, но dry-run всё равно не свапает.
|
||
$checksum = hash_file('sha256', rossvyazFixture());
|
||
DB::table('phone_ranges_imports')->insert([
|
||
'source_url' => 'https://rossvyaz.gov.ru/prev',
|
||
'checksum_sha256' => $checksum,
|
||
'status' => 'completed',
|
||
'imported_at' => now(),
|
||
'completed_at' => now(),
|
||
]);
|
||
|
||
$this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true, '--force' => true])
|
||
->assertSuccessful();
|
||
|
||
// --force обошёл idempotency → staging построен заново (3 строки), но dry-run не свапнул.
|
||
expect(DB::table('phone_ranges_staging')->count())->toBe(3);
|
||
expect(DB::table('phone_ranges')->count())->toBe(0);
|
||
});
|