bot-28/tests/Integration/AdminListAccountTest.php

<?php

namespace Tests\Integration;

use App\Services\BackflowService;
use App\Services\RebateService;
use App\Services\RechargeService;
use Illuminate\Config\Repository;
use Illuminate\Database\Capsule\Manager;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Foundation\Application;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Facade;
use PHPUnit\Framework\TestCase;

/** 后台列表返回会员账号 account，并支持按 account 模糊筛选（关联查询与 join 查询两种写法）。 */
class AdminListAccountTest extends TestCase
{
    protected function setUp(): void
    {
        parent::setUp();
        Facade::clearResolvedInstances();
        $app = new Application(dirname(__DIR__, 2));
        $app->instance('config', new Repository(['app' => ['timezone' => 'Asia/Shanghai', 'url' => 'http://x']]));
        Facade::setFacadeApplication($app);
        $db = new Manager($app);
        $db->addConnection(['driver' => 'sqlite', 'database' => ':memory:', 'prefix' => 'bot_']);
        $db->setAsGlobal();
        $db->bootEloquent();
        $app->instance('db', $db->getDatabaseManager());
        $app->bind('db.schema', fn () => $db->schema());
        $schema = $db->schema();
        $schema->create('users', function (Blueprint $t) {
            $t->id(); $t->string('member_id'); $t->string('account')->nullable(); $t->string('username')->nullable();
            $t->string('first_name')->nullable(); $t->string('admin_note')->nullable(); $t->integer('status')->default(0);
            $t->string('phone')->nullable(); $t->string('visitor_id')->nullable(); $t->string('register_ip')->nullable(); $t->timestamps();
        });
        $schema->create('rebates', function (Blueprint $t) {
            $t->id(); $t->string('member_id'); $t->date('date'); $t->integer('status')->default(0);
            $t->decimal('betting_amount', 20, 2)->default(0); $t->timestamps();
        });
        $schema->create('backflow', function (Blueprint $t) {
            $t->id(); $t->string('member_id'); $t->string('date'); $t->integer('status')->default(0);
            $t->decimal('amount', 20, 2)->default(0); $t->decimal('granted_amount', 20, 2)->default(0); $t->timestamps();
        });
        $schema->create('backflow_rules', function (Blueprint $t) {
            $t->id(); $t->string('category'); $t->decimal('min_loss_amount', 20, 2); $t->decimal('reward_amount', 20, 2);
            $t->decimal('turnover_multiple', 20, 2)->default(0);
        });
        $schema->create('share_bet_facts', function (Blueprint $t) {
            $t->id(); $t->unsignedBigInteger('user_id'); $t->string('category'); $t->date('bet_date'); $t->dateTime('bet_at');
            $t->decimal('bet_amount', 24, 10); $t->decimal('effective_amount', 24, 10); $t->decimal('net_profit', 24, 10);
            $t->boolean('voided')->default(false); $t->string('currency')->default('CNY');
        });
        $schema->create('recharges', function (Blueprint $t) {
            $t->id(); $t->string('member_id'); $t->string('coin')->default('CNY'); $t->decimal('amount', 20, 2)->default(0);
            $t->integer('status')->default(0); $t->timestamps();
        });
        DB::table('users')->insert([
            ['member_id' => 'm1', 'account' => 'alice'],
            ['member_id' => 'm2', 'account' => 'bob'],
            ['member_id' => 'm3', 'account' => null],
        ]);
    }

    protected function tearDown(): void
    {
        DB::disconnect();
        Facade::clearResolvedInstances();
        parent::tearDown();
    }

    public function test_rebate_list_shows_and_filters_account(): void
    {
        foreach (['m1', 'm2', 'm3'] as $m) {
            DB::table('rebates')->insert(['member_id' => $m, 'date' => '2026-01-01']);
        }
        $rows = $this->accounts(RebateService::paginate(['limit' => 10])['data']);
        $this->assertSame(['m1' => 'alice', 'm2' => 'bob', 'm3' => ''], $rows);
        $this->assertSame(['m1' => 'alice'], $this->accounts(RebateService::paginate(['account' => 'lic'])['data']));
        $this->assertSame(0, RebateService::paginate(['account' => 'nobody'])['total']);
    }

    public function test_rebate_list_shows_the_current_day_but_only_past_unpaid_days_can_be_granted(): void
    {
        \Carbon\Carbon::setTestNow(\Carbon\Carbon::parse('2026-11-05 15:00:00', 'Asia/Shanghai')); // 纽约 2026-11-05 02:00
        try {
            DB::table('rebates')->insert([
                ['member_id' => 'm1', 'date' => '2026-11-05', 'status' => 0],
                ['member_id' => 'm2', 'date' => '2026-11-04', 'status' => 0],
                ['member_id' => 'm3', 'date' => '2026-11-04', 'status' => 1],
            ]);
            $rows = [];
            foreach (json_decode(json_encode(RebateService::paginate(['limit' => 10])['data']), true) as $row) {
                $rows[$row['member_id']] = [$row['date'], $row['can_grant']];
            }
            $this->assertSame(['m1' => ['2026-11-05', false], 'm2' => ['2026-11-04', true], 'm3' => ['2026-11-04', false]], $rows);
        } finally {
            \Carbon\Carbon::setTestNow();
        }
    }

    public function test_backflow_list_shows_and_filters_account(): void
    {
        foreach (['m1', 'm2'] as $m) {
            DB::table('backflow')->insert(['member_id' => $m, 'date' => '2026-01']);
        }
        $this->assertSame(['m1' => 'alice', 'm2' => 'bob'], $this->accounts(BackflowService::paginate(['limit' => 10])['data']));
        $this->assertSame(['m2' => 'bob'], $this->accounts(BackflowService::paginate(['limit' => 10, 'account' => 'bo'])['data']));
    }

    public function test_backflow_list_recalculates_unpaid_rows_with_current_rules_and_shows_granted_and_pending(): void
    {
        \Carbon\Carbon::setTestNow(\Carbon\Carbon::parse('2026-11-05 15:00:00', 'Asia/Shanghai'));
        try {
            DB::table('backflow_rules')->insert([
                ['category' => 'self:lottery', 'min_loss_amount' => 10, 'reward_amount' => 8],
                ['category' => 'self:lottery', 'min_loss_amount' => 300, 'reward_amount' => 50],
            ]);
            foreach ([1 => '-50', 2 => '-350', 3 => '-50'] as $userId => $profit) {
                DB::table('share_bet_facts')->insert(['user_id' => $userId, 'category' => 'self:lottery', 'bet_date' => '2026-11-03',
                    'bet_at' => '2026-11-03 12:00:00', 'bet_amount' => 100, 'effective_amount' => 100, 'net_profit' => $profit]);
            }
            // 存储的 amount=20 是旧规则算出的过期值；列表应按当前规则显示
            DB::table('backflow')->insert([
                ['member_id' => 'm1', 'date' => '2026-11', 'status' => 0, 'amount' => 20, 'granted_amount' => 0],   // 当月未发：应发 8
                ['member_id' => 'm2', 'date' => '2026-11', 'status' => 2, 'amount' => 20, 'granted_amount' => 8],   // 部分发放：应发 50，待发 42
                ['member_id' => 'm3', 'date' => '2026-11', 'status' => 2, 'amount' => 20, 'granted_amount' => 8],   // 已发完：旧值会误显示待发 12
                ['member_id' => 'm1', 'date' => '2026-10', 'status' => 0, 'amount' => 5, 'granted_amount' => 0],    // 往月无注单：应发 0，可点发放结清
                ['member_id' => 'm2', 'date' => '2026-10', 'status' => 1, 'amount' => 35, 'granted_amount' => 35],  // 已发放：保留存储值
                ['member_id' => 'm1', 'date' => '2026-12', 'status' => 0, 'amount' => 0, 'granted_amount' => 0],   // 未来月份不展示
            ]);
            $rows = [];
            foreach (json_decode(json_encode(BackflowService::paginate(['limit' => 10])['data']), true) as $row) {
                $rows[$row['member_id'] . '|' . $row['date']] = [$row['amount'], $row['granted_amount'], $row['pending_amount'], $row['can_grant'], $row['status_text']];
            }
            ksort($rows);
            $this->assertSame([
                'm1|2026-10' => ['0.00', '0.00', '0.00', true, '未发放'],
                'm1|2026-11' => ['8.00', '0.00', '8.00', true, '未发放'],
                'm2|2026-10' => ['35.00', '35.00', '0.00', false, '已发放'],
                'm2|2026-11' => ['50.00', '8.00', '42.00', true, '部分发放'],
                'm3|2026-11' => ['8.00', '8.00', '0.00', false, '部分发放'],
            ], $rows);
            $this->assertSame(2, BackflowService::paginate(['limit' => 10, 'status' => 2])['total']);
        } finally {
            \Carbon\Carbon::setTestNow();
        }
    }

    public function test_recharge_list_shows_and_filters_account(): void
    {
        foreach (['m1', 'm2'] as $m) {
            DB::table('recharges')->insert(['member_id' => $m, 'amount' => 1, 'created_at' => '2026-01-01 00:00:00']);
        }
        $this->assertSame(['m1' => 'alice', 'm2' => 'bob'], $this->accounts(RechargeService::paginate([])['data']));
        $this->assertSame(['m1' => 'alice'], $this->accounts(RechargeService::paginate(['account' => 'ALI'])['data']));
    }

    private function accounts(array $rows): array
    {
        $out = [];
        foreach (json_decode(json_encode($rows), true) as $row) {
            $out[$row['member_id']] = $row['account'];
        }
        ksort($out);
        return $out;
    }
}