2e5db6737b
Закрыты денежно-независимые куски Этапа 2 (находки #1, часть). Списание по факту (2.2/2.4) ждёт подтверждения билинг-модели МТС. - 2.1 Статус кампании «cancelled»: константа STATUS_CANCELLED, переходы draft→cancelled и queued→cancelled (отмена только ДО запуска); cancelled — терминальный. Из running/терминальных отмена запрещена. Миграция не нужна — status это string(16) без CHECK-констрейнта. - 2.3 Возврат брони (release), иначе резерв кошелька залипал (находка #1): • при отказе робота (finalize) — release после записи FAILED, отдельным tenantTx, чтобы сбой возврата не откатил статус; • при перманентном сбое джоба (failed) — тоже release; • новый endpoint POST /api/telegram/campaigns/{id}/cancel: draft/queued → cancelled с возвратом брони; из running/терминальных — 422. Возврат гейтится !sandbox (в песочнице заморозки не было). Ключи release совпадают с freeze в launch ('telegram','campaign',id). RLS: денежная операция в джобе идёт под SET LOCAL app.current_tenant_id (образец ChargeTgNameFeeJob). Возврат при rejected здесь НЕ трогаем — его выставляет опросчик модерации (Этап 3, задача 3.4). TDD, робот в тестах замокан, тесты на liderra_testing (7999… номера). Приёмка: Pest ClientTg RefundOnFail 5/5 + регрессия соседей (32/32 суммарно), deptrac 0, pint чисто, phpstan по боевым файлам (джоб/контроллер) 0. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
140 lines
6.3 KiB
PHP
140 lines
6.3 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
use App\Jobs\ClientTg\RunTelegramCampaignJob;
|
|
use App\Models\AdWallet;
|
|
use App\Models\ClientTg\Campaign;
|
|
use App\Models\ClientTg\CampaignPhone;
|
|
use App\Models\Tenant;
|
|
use App\Models\User;
|
|
use App\Services\Advertising\AdWalletService;
|
|
use App\Services\ClientTg\RobotResult;
|
|
use App\Services\ClientTg\TelegramRobotRunner;
|
|
use Illuminate\Foundation\Testing\RefreshDatabase;
|
|
|
|
uses(RefreshDatabase::class);
|
|
|
|
/**
|
|
* Задача 2.3 — ВОЗВРАТ брони кошелька: при отказе робота (finalize), перманентном
|
|
* сбое джоба (failed) и отмене кампании (cancel). Ключ брони совпадает с freeze в
|
|
* launch: ('telegram', 'campaign', $campaign->id). Гейт !sandbox везде — в песочнице
|
|
* заморозки не было, release бросил бы firstOrFail. Списание по факту — задача 2.4.
|
|
*
|
|
* Все тесты по умолчанию в БОЕВОМ режиме (sandbox=false) — проверяем денежный путь.
|
|
* Синтетические номера 7999… — реальные НИКОГДА.
|
|
*/
|
|
beforeEach(function () {
|
|
config()->set('client_tg.sandbox', false);
|
|
});
|
|
|
|
/** Кампания-список заданного статуса с двумя фейковыми номерами. */
|
|
function refundCampaign(int $tenantId, string $status, string $budgetCap = '500.00'): Campaign
|
|
{
|
|
$campaign = Campaign::query()->create([
|
|
'tenant_id' => $tenantId,
|
|
'status' => $status,
|
|
'ad_text' => 'Приходите к нам за услугой',
|
|
'ad_link' => 'https://example.test/promo',
|
|
'ord_category' => 'Размещение рекламы',
|
|
'budget_cap_rub' => $budgetCap,
|
|
'audience_kind' => Campaign::AUDIENCE_LIST,
|
|
'planned_count' => 2,
|
|
'estimated_cost_rub' => '0.00',
|
|
'created_by' => 1,
|
|
]);
|
|
|
|
foreach (['79990000001', '79990000002'] as $phone) {
|
|
CampaignPhone::query()->create([
|
|
'tenant_id' => $tenantId,
|
|
'campaign_id' => $campaign->id,
|
|
'phone' => $phone,
|
|
]);
|
|
}
|
|
|
|
return $campaign;
|
|
}
|
|
|
|
/** Подменяет раннер моком, возвращающим $result. */
|
|
function refundMockRobot(RobotResult $result): void
|
|
{
|
|
$mock = Mockery::mock(TelegramRobotRunner::class);
|
|
$mock->shouldReceive('run')->andReturn($result);
|
|
app()->instance(TelegramRobotRunner::class, $mock);
|
|
}
|
|
|
|
it('отказ робота возвращает бронь (frozen→0, balance цел)', function () {
|
|
$tenant = Tenant::factory()->create();
|
|
app(AdWalletService::class)->topup($tenant->id, '1000.00', 'telegram', 'Пополнение');
|
|
$campaign = refundCampaign($tenant->id, Campaign::STATUS_QUEUED, '500.00');
|
|
app(AdWalletService::class)->freeze($tenant->id, 'telegram', 'campaign', $campaign->id, '500.00');
|
|
refundMockRobot(RobotResult::failed('Канал недоступен', 'upload'));
|
|
|
|
RunTelegramCampaignJob::dispatchSync($campaign->id, $tenant->id);
|
|
|
|
$fresh = Campaign::find($campaign->id);
|
|
$wallet = AdWallet::where('tenant_id', $tenant->id)->first();
|
|
expect($fresh->status)->toBe(Campaign::STATUS_FAILED)
|
|
->and((string) $wallet->frozen_rub)->toBe('0.00')
|
|
->and((string) $wallet->balance_rub)->toBe('1000.00');
|
|
});
|
|
|
|
it('в песочнице отказ робота НЕ трогает кошелёк (бронь не возвращается — её и нет)', function () {
|
|
config()->set('client_tg.sandbox', true);
|
|
$tenant = Tenant::factory()->create();
|
|
app(AdWalletService::class)->topup($tenant->id, '1000.00', 'telegram', 'Пополнение');
|
|
$campaign = refundCampaign($tenant->id, Campaign::STATUS_QUEUED, '500.00');
|
|
app(AdWalletService::class)->freeze($tenant->id, 'telegram', 'campaign', $campaign->id, '500.00');
|
|
refundMockRobot(RobotResult::failed('Канал недоступен', 'upload'));
|
|
|
|
RunTelegramCampaignJob::dispatchSync($campaign->id, $tenant->id);
|
|
|
|
$wallet = AdWallet::where('tenant_id', $tenant->id)->first();
|
|
expect((string) $wallet->frozen_rub)->toBe('500.00');
|
|
});
|
|
|
|
it('cancel из draft возвращает бронь и ставит cancelled', function () {
|
|
$tenant = Tenant::factory()->create();
|
|
$user = User::factory()->create(['tenant_id' => $tenant->id]);
|
|
$this->actingAs($user);
|
|
app(AdWalletService::class)->topup($tenant->id, '1000.00', 'telegram', 'Пополнение');
|
|
$campaign = refundCampaign($tenant->id, Campaign::STATUS_DRAFT, '300.00');
|
|
app(AdWalletService::class)->freeze($tenant->id, 'telegram', 'campaign', $campaign->id, '300.00');
|
|
|
|
$this->postJson("/api/telegram/campaigns/{$campaign->id}/cancel")
|
|
->assertOk()
|
|
->assertJsonPath('status', Campaign::STATUS_CANCELLED);
|
|
|
|
$wallet = AdWallet::where('tenant_id', $tenant->id)->first();
|
|
expect((string) $wallet->frozen_rub)->toBe('0.00')
|
|
->and((string) $wallet->balance_rub)->toBe('1000.00');
|
|
});
|
|
|
|
it('cancel из running запрещён 422, статус остаётся running', function () {
|
|
$tenant = Tenant::factory()->create();
|
|
$user = User::factory()->create(['tenant_id' => $tenant->id]);
|
|
$this->actingAs($user);
|
|
$campaign = refundCampaign($tenant->id, Campaign::STATUS_RUNNING, '300.00');
|
|
|
|
$this->postJson("/api/telegram/campaigns/{$campaign->id}/cancel")->assertStatus(422);
|
|
|
|
expect(Campaign::find($campaign->id)->status)->toBe(Campaign::STATUS_RUNNING);
|
|
});
|
|
|
|
it('cancel в песочнице не трогает кошелёк (frozen сохраняется)', function () {
|
|
config()->set('client_tg.sandbox', true);
|
|
$tenant = Tenant::factory()->create();
|
|
$user = User::factory()->create(['tenant_id' => $tenant->id]);
|
|
$this->actingAs($user);
|
|
app(AdWalletService::class)->topup($tenant->id, '1000.00', 'telegram', 'Пополнение');
|
|
$campaign = refundCampaign($tenant->id, Campaign::STATUS_DRAFT, '300.00');
|
|
app(AdWalletService::class)->freeze($tenant->id, 'telegram', 'campaign', $campaign->id, '300.00');
|
|
|
|
$this->postJson("/api/telegram/campaigns/{$campaign->id}/cancel")
|
|
->assertOk()
|
|
->assertJsonPath('status', Campaign::STATUS_CANCELLED);
|
|
|
|
$wallet = AdWallet::where('tenant_id', $tenant->id)->first();
|
|
expect((string) $wallet->frozen_rub)->toBe('300.00');
|
|
});
|