ThirdGamePlayerIdentityTest.php 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. <?php
  2. namespace Tests\Integration;
  3. use App\Services\ThirdGameBalanceService;
  4. use App\Services\ThirdGameOrderService;
  5. use Illuminate\Config\Repository;
  6. use Illuminate\Database\Capsule\Manager;
  7. use Illuminate\Foundation\Application;
  8. use Illuminate\Support\Facades\DB;
  9. use Illuminate\Support\Facades\Facade;
  10. use PHPUnit\Framework\TestCase;
  11. /** Provider order identities are resolved against an isolated SQLite database only. */
  12. class ThirdGamePlayerIdentityTest extends TestCase
  13. {
  14. protected function setUp(): void
  15. {
  16. Facade::clearResolvedInstances();
  17. $app = new Application(dirname(__DIR__, 2));
  18. $app->instance('config', new Repository(['app' => ['timezone' => 'Asia/Shanghai'], 'third_game' => ['player_prefix' => 'u']]));
  19. Facade::setFacadeApplication($app);
  20. $db = new Manager($app);
  21. $db->addConnection(['driver' => 'sqlite', 'database' => ':memory:', 'prefix' => 'bot_']);
  22. $db->setAsGlobal(); $db->bootEloquent(); $app->instance('db', $db->getDatabaseManager());
  23. DB::statement('CREATE TABLE bot_users (id INTEGER PRIMARY KEY,member_id TEXT,username TEXT,first_name TEXT)');
  24. DB::statement('CREATE TABLE bot_third_game_orders (id INTEGER PRIMARY KEY AUTOINCREMENT,order_key TEXT UNIQUE,
  25. user_id INTEGER,member_id TEXT,username TEXT,first_name TEXT,player_id TEXT,platform TEXT,currency TEXT,
  26. game_type INTEGER,game_name TEXT,round_no TEXT,table_no TEXT,seat TEXT,bet_amount TEXT,valid_amount TEXT,
  27. settled_amount TEXT,bet_content TEXT,status INTEGER,game_order_id TEXT,bet_time TEXT,last_update_time TEXT,
  28. created_at TEXT,updated_at TEXT)');
  29. DB::table('users')->insert([
  30. ['id' => 1, 'member_id' => 'm1', 'username' => 'one', 'first_name' => ''],
  31. ['id' => 106, 'member_id' => 'm106', 'username' => 'member106', 'first_name' => ''],
  32. ['id' => 1000, 'member_id' => 'm1000', 'username' => 'member1000', 'first_name' => ''],
  33. ]);
  34. }
  35. protected function tearDown(): void
  36. {
  37. DB::disconnect(); Facade::clearResolvedInstances(); parent::tearDown();
  38. }
  39. private function lookup(array $playerIds): array
  40. {
  41. $service = new ThirdGameOrderService(new ThirdGameBalanceService());
  42. return (new \ReflectionMethod($service, 'usersByPlayerId'))->invoke($service, $playerIds);
  43. }
  44. public function test_new_padded_and_legacy_identifiers_in_one_batch_resolve_to_the_correct_member(): void
  45. {
  46. $rows = $this->lookup(['u106', 'u0106', 'u0001', 'u1', 'u1000']);
  47. $this->assertCount(5, $rows);
  48. $this->assertSame(106, $rows['u0106']->id);
  49. $this->assertSame(106, $rows['u106']->id);
  50. $this->assertSame('m106', $rows['u0106']->member_id);
  51. $this->assertSame(1, $rows['u0001']->id);
  52. $this->assertSame(1, $rows['u1']->id);
  53. $this->assertSame(1000, $rows['u1000']->id);
  54. }
  55. public function test_noncanonical_zero_padding_and_unknown_accounts_do_not_get_bound_to_another_member(): void
  56. {
  57. $this->assertSame([], $this->lookup(['u000106', 'u01', 'u00001', 'u01000', 'u0000',
  58. 'u0', 'u10000000000', 'u0999', 'a0106', 'U0106', 'p1234567890']));
  59. $this->assertSame([], $this->lookup([]));
  60. }
  61. public function test_test_namespace_does_not_associate_production_players_with_test_members(): void
  62. {
  63. config(['third_game.player_prefix' => 'tu']);
  64. $rows = $this->lookup(['u106', 'u0106', 'u1000', 'tu106', 'tu0106', 'tu1000']);
  65. $this->assertSame(['tu106', 'tu0106', 'tu1000'], array_keys($rows));
  66. $this->assertSame(106, $rows['tu0106']->id);
  67. $this->assertSame([], $this->lookup(['u0106', 'tu00106', 'tu0000', 'tu1000000000']));
  68. }
  69. public function test_sync_and_listing_keep_namespaces_separate_even_when_an_old_foreign_snapshot_exists(): void
  70. {
  71. config(['third_game.player_prefix' => 'tu']);
  72. $foreign = ['player_id' => 'u0106', 'platform' => 'pg', 'game_order_id' => 'production-order',
  73. 'currency' => 'CNY', 'game_type' => 2, 'status' => 1, 'bet_amount' => '999',
  74. 'bet_time' => '2026-10-27 10:00:00', 'last_update_time' => '2026-10-27 10:01:00'];
  75. $foreignKey = hash('sha256', "pg\0u0106\0production-order");
  76. DB::table('third_game_orders')->insert($foreign + ['order_key' => $foreignKey, 'user_id' => 106,
  77. 'member_id' => 'm106', 'username' => 'member106', 'first_name' => '', 'created_at' => '2026-10-27 10:00:00']);
  78. $before = (array) DB::table('third_game_orders')->where('order_key', $foreignKey)->first();
  79. $local = array_replace($foreign, ['player_id' => 'tu0106', 'game_order_id' => 'test-order', 'bet_amount' => '10']);
  80. $service = new ThirdGameOrderService(new ThirdGameBalanceService());
  81. $persist = new \ReflectionMethod($service, 'persistProviderResult');
  82. $result = $persist->invoke($service, ['ok' => true, 'list' => [$foreign, $local],
  83. 'page_no' => 1, 'page_size' => 2, 'total' => 4]);
  84. $this->assertSame(2, $result['received']);
  85. $this->assertSame(1, $result['synced']);
  86. $this->assertSame(1, $result['matched_users']);
  87. $this->assertSame(4, $result['total']);
  88. $this->assertTrue($result['has_more']);
  89. $this->assertSame($before, (array) DB::table('third_game_orders')->where('order_key', $foreignKey)->first());
  90. $this->assertSame(106, DB::table('third_game_orders')->where('player_id', 'tu0106')->value('user_id'));
  91. $list = $service->paginate([]);
  92. $this->assertSame(1, $list['total']);
  93. $this->assertSame('tu0106', $list['list'][0]['player_id']);
  94. config(['third_game.player_prefix' => 'u']);
  95. $production = $service->paginate([]);
  96. $this->assertSame(1, $production['total']);
  97. $this->assertSame('u0106', $production['list'][0]['player_id']);
  98. $rejected = $persist->invoke($service, ['ok' => true, 'list' => [$local], 'page_no' => 1, 'page_size' => 1, 'total' => 1]);
  99. $this->assertSame(0, $rejected['synced']);
  100. $this->assertSame(2, DB::table('third_game_orders')->count());
  101. }
  102. }