bot-28/tests/Integration/AgentApiRegressionTest.php

<?php

namespace Tests\Integration;

use App\Http\Controllers\admin\Agent as AdminAgent;
use App\Http\Controllers\AgentApiController;
use App\Http\Middleware\AgentAuthMiddleware;
use App\Models\Agent\Agent;
use App\Models\Agent\AgentBalanceLog;
use App\Models\Agent\AgentLoginLog;
use App\Models\Agent\AgentRebateRecord;
use App\Models\Agent\AgentToken;
use App\Models\Agent\AgentWithdrawAccount;
use App\Models\Agent\AgentWithdrawal;
use App\Services\Agent\AgentCommissionService;
use App\Services\Agent\AgentMemberService;
use App\Services\Agent\AgentProfitCommissionAssignmentService;
use App\Services\Agent\AgentReportService;
use App\Services\Agent\AgentService;
use App\Services\Agent\AgentWalletService;
use App\Services\Agent\AgentWithdrawalService;
use App\Services\PaymentOrderService;
use Carbon\Carbon;
use Illuminate\Config\Repository;
use Illuminate\Contracts\Debug\ExceptionHandler;
use Illuminate\Database\Capsule\Manager;
use Illuminate\Database\QueryException;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Events\Dispatcher;
use Illuminate\Foundation\Application;
use Illuminate\Hashing\BcryptHasher;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Facade;
use Illuminate\Support\Facades\Schema;
use Illuminate\Translation\ArrayLoader;
use Illuminate\Translation\Translator;
use Illuminate\Validation\Factory;
use PHPUnit\Framework\TestCase;
use Tests\Support\AgentTestEnvironment;

class AgentApiRegressionTest extends TestCase
{
    use AgentTestEnvironment;

    public function test_admin_password_reset_revokes_old_login(): void
    {
        $agent = $this->agent(); $token = $this->token($agent);
        $this->agents->update($agent, ['password' => 'new-password']);
        $this->assertSame(0, AgentToken::query()->where('agent_id', $agent->id)->count());
        $request = Request::create('/agent/profile');
        $request->headers->set('Authorization', 'Bearer ' . $token);
        $response = (new AgentAuthMiddleware())->handle($request, fn () => new JsonResponse(['code' => 0]));
        $this->assertSame(101011, $response->getData(true)['code']);
    }

    public function test_disable_then_enable_does_not_restore_old_login(): void
    {
        $agent = $this->agent(); $this->token($agent);
        $this->agents->update($agent, ['status' => 0]);
        $this->agents->update($agent, ['status' => 1]);
        $this->assertSame(0, AgentToken::query()->count());
    }

    public function test_non_sensitive_edit_preserves_login(): void
    {
        $agent = $this->agent(); $this->token($agent);
        $this->agents->update($agent, ['real_name' => 'new name']);
        $this->assertSame(1, AgentToken::query()->count());
    }

    public function test_finance_counts_include_only_successful_in_range_provider_orders(): void
    {
        $agent = $this->agent();
        DB::table('users')->insert(['member_id' => 'm1', 'username' => 'member', 'agent_id' => $agent->id,
            'created_at' => '2026-01-01 00:00:00']);
        $base = ['member_id' => 'm1', 'amount' => 10, 'created_at' => now()];
        DB::table('recharges')->insert($base + ['status' => 1]);
        DB::table('withdraws')->insert($base + ['status' => 1]);
        foreach ([PaymentOrderService::TYPE_PAY, PaymentOrderService::TYPE_PAYOUT, PaymentOrderService::TYPE_SELF_PAYOUT] as $type) {
            DB::table('payment_orders')->insert($base + ['type' => $type, 'status' => PaymentOrderService::STATUS_SUCCESS]);
        }
        DB::table('payment_orders')->insert($base + ['type' => PaymentOrderService::TYPE_PAY, 'status' => -99]);
        DB::table('payment_orders')->insert(array_merge($base, ['type' => PaymentOrderService::TYPE_PAY,
            'status' => PaymentOrderService::STATUS_SUCCESS, 'created_at' => '2026-08-01 00:00:00']));
        DB::table('payment_orders')->insert(array_merge($base, ['type' => PaymentOrderService::TYPE_PAY,
            'status' => PaymentOrderService::STATUS_SUCCESS, 'member_id' => 'unrelated']));
        $result = (new AgentMemberService(new AgentReportService()))->finance($agent, []);
        $member = $result['list'][0];
        $this->assertSame(2, $member->recharge_count);
        $this->assertSame(3, $member->withdraw_count);
        $this->assertSame('20.0000', $member->recharge_amount);
        $this->assertSame('30.0000', $member->withdraw_amount);
    }

    public function test_login_logs_filter_login_time_not_record_creation_time(): void
    {
        $agent = $this->agent();
        AgentLoginLog::query()->create(['agent_id' => $agent->id, 'username' => $agent->username,
            'login_at' => '2026-09-06 23:59:59', 'created_at' => '2026-09-07 00:00:01']);
        $controller = new AdminAgent();
        $request = Request::create('/admin/agent/login-logs', 'GET', ['start_date' => '2026-09-06', 'end_date' => '2026-09-06']);
        $this->assertSame(1, $controller->loginLogs($request)->getData(true)['data']['total']);
    }

    public function test_admin_balance_logs_include_signed_debits_for_the_selected_agent(): void
    {
        $agent = $this->agent(Agent::TYPE_EQUITY);
        $other = $this->agent();
        $wallets = new AgentWalletService();
        foreach ([$agent, $other] as $owner) {
            $wallets->adjust($owner->id, '100', 'credit', '初始额度', 'credit-' . $owner->id, 'admin', 1);
            $wallets->adjust($owner->id, '25.1250', 'debit', '人工扣款', 'debit-' . $owner->id, 'admin', 1);
        }

        $controller = new AdminAgent();
        $query = ['agent_id' => $agent->id];
        $all = $controller->balanceLogs(Request::create('/admin/agent/balance-logs', 'GET', $query))->getData(true);
        $this->assertSame(0, $all['code']);
        $this->assertSame(['debit', 'credit'], array_column($all['data']['list'], 'type'));
        $this->assertContains(['value' => 'debit', 'label' => '人工扣款'], $all['data']['types']);
        $filtered = $controller->balanceLogs(Request::create('/admin/agent/balance-logs', 'GET', $query + ['type' => 'debit']))->getData(true)['data'];
        $this->assertSame(1, $filtered['total']);
        $row = $filtered['list'][0];
        $this->assertSame(['人工扣款', '-25.1250', '100.0000', '74.8750'], [$row['type_text'], $row['amount'], $row['before_balance'], $row['after_balance']]);
        $this->assertArrayNotHasKey('idempotency_key', $row);
    }

    public function test_admin_withdrawal_list_includes_the_current_agent_type_and_label(): void
    {
        $joint = $this->agent();
        $equity = $this->agent(Agent::TYPE_EQUITY);
        foreach ([$joint, $equity] as $agent) {
            $account = $this->fundedAccount($agent);
            (new AgentWithdrawalService())->request($agent, $account->id, '10', 'withdraw-old', 'type-list');
        }

        $response = (new AdminAgent())->withdrawals(Request::create('/admin/agent/withdrawals'))->getData(true);
        $this->assertSame(0, $response['code']);
        $agents = array_column($response['data']['list'], 'agent', 'agent_id');
        $this->assertSame([1, '合营'], [$agents[$joint->id]['type'], $agents[$joint->id]['type_text']]);
        $this->assertSame([2, '入股'], [$agents[$equity->id]['type'], $agents[$equity->id]['type_text']]);
    }

    private function fundedAccount(Agent $agent): AgentWithdrawAccount
    {
        $this->paymentChannels(); // 提现按总后台通道组合校验（组合 1 含 usdt）
        Agent::query()->whereKey($agent->id)->update(['balance' => 100, 'realtime_balance' => 100]);
        return AgentWithdrawAccount::query()->create(['agent_id' => $agent->id, 'type' => 'usdt', 'network' => 'TRC20',
            'account' => 'TQn9Y2khEsLJW1ChVWFMSMeRDow5KcbLSE', 'status' => 1]);
    }

    public function test_withdrawal_uses_current_password_not_stale_request_model(): void
    {
        $agent = $this->agent(); $account = $this->fundedAccount($agent);
        $this->agents->update($agent, ['withdraw_password' => 'withdraw-new']);
        $this->expectException(\InvalidArgumentException::class);
        $this->expectExceptionMessage('提现密码错误');
        (new AgentWithdrawalService())->request($agent, $account->id, '10', 'withdraw-old', 'stale');
    }

    public function test_disabled_agent_cannot_submit_with_stale_request_model(): void
    {
        $agent = $this->agent(); $account = $this->fundedAccount($agent);
        $this->agents->update($agent, ['status' => 0]);
        $this->expectException(\RuntimeException::class);
        $this->expectExceptionMessage('代理账号已禁用');
        (new AgentWithdrawalService())->request($agent, $account->id, '10', 'withdraw-old', 'disabled');
    }

    public function test_withdrawal_retry_and_rejection_move_funds_once(): void
    {
        $agent = $this->agent(); $account = $this->fundedAccount($agent);
        $service = new AgentWithdrawalService();
        $one = $service->request($agent, $account->id, '10', 'withdraw-old', 'retry');
        $two = $service->request($agent, $account->id, '10', 'withdraw-old', 'retry');
        $this->assertSame($one->id, $two->id);
        $this->assertSame('90.0000', $agent->fresh()->balance);
        $this->assertSame('10.0000', $agent->fresh()->frozen_balance);
        $service->audit($one->id, 'reject', 1);
        $this->assertSame('100.0000', $agent->fresh()->balance);
        $this->assertSame('0.0000', $agent->fresh()->frozen_balance);
        $this->assertSame(1, AgentWithdrawal::query()->count());
        $this->assertSame(2, AgentBalanceLog::query()->count());
    }

    public function test_member_finance_does_not_include_other_agent_members(): void
    {
        $agent = $this->agent(); $other = $this->agent();
        foreach ([$agent, $agent, $other] as $i => $owner) {
            DB::table('users')->insert(['member_id' => 'm' . $i, 'username' => 'member' . $i,
                'agent_id' => $owner->id, 'created_at' => now()]);
        }
        $service = new AgentMemberService(new AgentReportService());
        $this->assertSame(2, $service->finance($agent, [])['total']);
        $this->assertSame(0, $service->finance($agent, ['agent_id' => $other->id])['total']);
        $this->assertSame(1, $service->finance($other, [])['total']);
    }

    public function test_business_errors_keep_existing_response_contract(): void
    {
        $controller = new class extends AgentApiController {
            public function trigger() {
                return $this->execute(fn () => throw new \RuntimeException('代理余额不足'));
            }
        };
        $data = $controller->trigger()->getData(true);
        $this->assertSame(['code', 'timestamp', 'msg', 'data'], array_keys($data));
        $this->assertSame(-3, $data['code']);
        $this->assertSame('代理余额不足', $data['msg']);
    }

    public function test_settlement_command_rejects_invalid_and_unfinished_dates(): void
    {
        $handler = $this->createMock(ExceptionHandler::class);
        $handler->expects($this->exactly(3))->method('report');
        $this->app->instance(ExceptionHandler::class, $handler);
        $reports = $this->createMock(AgentReportService::class);
        $reports->expects($this->never())->method('refreshDaily');
        $this->app->instance(AgentReportService::class, $reports);
        $commissions = $this->createMock(AgentCommissionService::class);
        $commissions->expects($this->never())->method('settle');
        $this->app->instance(AgentCommissionService::class, $commissions);
        foreach (['2026-02-30', '2026-09-07', '2026-09-08'] as $date) {
            $command = new \App\Console\Commands\AgentDailySettle();
            $command->setLaravel($this->app);
            $tester = new \Symfony\Component\Console\Tester\CommandTester($command);
            $this->assertSame(1, $tester->execute(['date' => $date]));
        }
    }

    public function test_sql_errors_are_logged_but_not_returned_to_frontend(): void
    {
        $handler = $this->createMock(ExceptionHandler::class);
        $handler->expects($this->once())->method('report');
        $this->app->instance(ExceptionHandler::class, $handler);
        $controller = new class extends AgentApiController {
            public function trigger() {
                return $this->execute(fn () => throw new QueryException('select sensitive_table', ['secret'], new \PDOException('internal database error')));
            }
        };
        $data = $controller->trigger()->getData(true);
        $this->assertSame(-3, $data['code']);
        $this->assertSame('系统处理失败，请稍后重试', $data['msg']);
        $this->assertSame([], $data['data']);
    }
}