ApiCryptoTest.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673
  1. <?php
  2. namespace Tests\Integration;
  3. use App\Constants\StepStatus;
  4. use App\Http\Controllers\api\TelegramWebHook;
  5. use App\Services\ApiCryptoService;
  6. use App\Services\QianBaoWithdrawService;
  7. use App\Services\UserService;
  8. use App\Services\WithdrawService;
  9. use Illuminate\Contracts\Http\Kernel;
  10. use Illuminate\Database\Schema\Blueprint;
  11. use Illuminate\Foundation\Application;
  12. use Illuminate\Http\JsonResponse;
  13. use Illuminate\Http\Request;
  14. use Illuminate\Support\Facades\DB;
  15. use Illuminate\Support\Facades\Cache;
  16. use Illuminate\Support\Facades\Facade;
  17. use Illuminate\Support\Facades\Route;
  18. use Illuminate\Support\Facades\Schema;
  19. use PHPUnit\Framework\TestCase;
  20. use Symfony\Component\HttpFoundation\Response;
  21. class ApiCryptoTest extends TestCase
  22. {
  23. private Application $app;
  24. private Kernel $kernel;
  25. private ApiCryptoService $crypto;
  26. private int $errorReporting;
  27. private string $displayErrors;
  28. private const TOKEN = 'fixture-member-token';
  29. protected function setUp(): void
  30. {
  31. Facade::clearResolvedInstances();
  32. $this->errorReporting = error_reporting();
  33. $this->displayErrors = ini_get('display_errors');
  34. $this->app = require dirname(__DIR__, 2) . '/bootstrap/app.php';
  35. $this->kernel = $this->app->make(Kernel::class);
  36. $this->kernel->bootstrap();
  37. $key = base64_encode(str_repeat('k', 32));
  38. $this->crypto = new ApiCryptoService($key);
  39. config([
  40. 'app.env' => 'testing',
  41. 'app.debug' => false,
  42. 'app.key' => 'base64:' . $key,
  43. 'api_crypto.enabled' => true,
  44. 'api_crypto.key' => $key,
  45. 'api_crypto.allow_plaintext' => false,
  46. 'api_crypto.timestamp_tolerance' => 300,
  47. 'api_crypto.max_payload_bytes' => 2097152,
  48. 'cache.default' => 'array',
  49. 'database.default' => 'sqlite',
  50. 'database.connections.sqlite.url' => null,
  51. 'database.connections.sqlite.database' => ':memory:',
  52. 'database.connections.sqlite.prefix' => 'bot_',
  53. 'logging.default' => 'null',
  54. 'logging.channels.dblog' => config('logging.channels.null'),
  55. 'app.tree_payment_merchant_id' => '',
  56. 'app.tree_pay_mch_id' => '',
  57. 'app.jd_pay_mch_id' => '',
  58. ]);
  59. }
  60. protected function tearDown(): void
  61. {
  62. DB::disconnect();
  63. Facade::clearResolvedInstances();
  64. $this->app->flush();
  65. restore_error_handler();
  66. restore_exception_handler();
  67. error_reporting($this->errorReporting);
  68. ini_set('display_errors', $this->displayErrors);
  69. parent::tearDown();
  70. }
  71. public function test_real_wallet_and_lottery_routes_keep_the_original_business_response(): void
  72. {
  73. $this->createWalletFixture();
  74. Schema::create('pc_issues', function (Blueprint $table) {
  75. $table->id();
  76. $table->integer('status');
  77. $table->string('issue_no');
  78. });
  79. $response = $this->sendEncrypted('/api/wallet/withdrawChannel?lang=zh', 'GET', ['lang' => 'en'], true);
  80. $body = $this->unwrap($response);
  81. self::assertSame(0, $body['code']);
  82. self::assertSame(['code', 'timestamp', 'msg', 'data'], array_keys($body));
  83. self::assertSame('Bank card', array_column($body['data'], 'label', 'value')['DF001']);
  84. $channels = array_column($body['data'], null, 'value');
  85. self::assertTrue($channels['DF001']['requires_bank_name']);
  86. self::assertTrue($channels['DF001']['requires_bank_branch']);
  87. self::assertSame('Bank name', $channels['DF001']['bank_name_label']);
  88. self::assertTrue($channels['NOwithdraw']['requires_real_name']);
  89. self::assertTrue($channels['ZIMUwithdraw']['requires_real_name']);
  90. self::assertTrue($channels['JDpay']['requires_real_name']);
  91. self::assertTrue($channels['usdt']['requires_real_name']);
  92. self::assertSame(['bank', 'wechat', 'alipay'], array_column($channels['rgtx']['payout_methods'], 'value'));
  93. self::assertSame([true, false, true], array_column($channels['rgtx']['payout_methods'], 'requires_card_no'));
  94. self::assertSame('Bank name', $channels['rgtx']['payout_methods'][0]['bank_name_label']);
  95. self::assertArrayNotHasKey('bank_name_label', $channels['rgtx']['payout_methods'][1]);
  96. $lottery = $this->unwrap($this->sendEncrypted('/api/newPc/yuanTou', 'GET', (object) []));
  97. self::assertSame(0, $lottery['code'] ?? null, json_encode($lottery));
  98. self::assertSame([], $lottery['data']);
  99. DB::table('users')->where('member_id', '42')->update(['real_name' => 'Fixture Name']);
  100. $response = $this->sendEncrypted('/api/wallet/payout?amount=900', 'POST', [
  101. 'channel' => 'NOwithdraw', 'amount' => 100, 'card_no' => ' no_fixture ', 'safe_word' => 'fixture-password',
  102. ], true, ['card_no' => 'outer-account']);
  103. $body = $this->unwrap($response);
  104. self::assertSame(0, $body['code'] ?? null, json_encode($body));
  105. $order = DB::table('payment_orders')->sole();
  106. self::assertSame('NOwithdraw', $order->channel);
  107. self::assertSame('no_fixture', $order->card_no);
  108. self::assertSame(100, (int) $order->amount);
  109. self::assertSame('Fixture Name', $order->account);
  110. DB::table('user_session')->where('token', self::TOKEN)->update(['expire_time' => time() - 1]);
  111. $expiredSession = $this->sendEncrypted('/api/wallet/withdrawChannel', 'GET', (object) [], true);
  112. self::assertSame(401, $expiredSession->getStatusCode());
  113. self::assertSame(401, $this->unwrap($expiredSession)['code']);
  114. }
  115. public function test_authentication_and_maintenance_errors_remain_encrypted(): void
  116. {
  117. $this->createMaintenanceFixture();
  118. $response = $this->sendEncrypted('/api/wallet/withdrawChannel', 'GET', (object) []);
  119. self::assertSame(401, $response->getStatusCode());
  120. self::assertSame(401, $this->unwrap($response)['code']);
  121. DB::table('maintenance_settings')->where('scope_code', 'site')->update(['enabled' => 1, 'platforms' => '["H5"]']);
  122. $response = $this->sendEncrypted('/api/wallet/withdrawChannel?platform=PC', 'GET', ['platform' => 'H5']);
  123. self::assertSame(200, $response->getStatusCode());
  124. self::assertSame(11001, $this->unwrap($response)['code']);
  125. }
  126. public function test_registered_real_name_is_used_for_binding_and_payout(): void
  127. {
  128. $this->createWalletFixture();
  129. DB::table('users')->where('member_id', '42')->update(['real_name' => 'Registered Name']);
  130. $binding = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', [
  131. 'channel' => 'DF001', 'bank_name' => 'Fixture Bank', 'bank_branch' => 'Fixture Branch',
  132. 'card_no' => '12345', 'account' => 'Different Name',
  133. ], true));
  134. self::assertSame('Registered Name', $binding['data']['real_name']);
  135. self::assertSame('Registered Name', DB::table('banks')->sole()->account);
  136. $payout = $this->unwrap($this->sendEncrypted('/api/wallet/payout', 'POST', [
  137. 'channel' => 'DF001', 'bank_name' => 'Fixture Bank', 'bank_branch' => 'Fixture Branch', 'card_no' => '12345',
  138. 'amount' => 100, 'safe_word' => 'fixture-password', 'account' => 'Another Name',
  139. ], true));
  140. self::assertSame(0, $payout['code'], $payout['msg']);
  141. self::assertSame('Registered Name', DB::table('payment_orders')->sole()->account);
  142. self::assertSame('Fixture Branch', DB::table('payment_orders')->sole()->bank_branch);
  143. $zimu = $this->unwrap($this->sendEncrypted('/api/wallet/payout', 'POST', [
  144. 'channel' => 'ZIMUwithdraw', 'card_no' => 'zimu-wallet-fixture',
  145. 'amount' => 100, 'safe_word' => 'fixture-password', 'account' => 'Another Name',
  146. ], true));
  147. self::assertSame(0, $zimu['code'], $zimu['msg']);
  148. self::assertSame('Registered Name', DB::table('payment_orders')->where('channel', 'ZIMUwithdraw')->value('account'));
  149. self::assertSame('Registered Name', UserService::paginate()['data']->first()->toArray()['real_name']);
  150. self::assertArrayNotHasKey('real_name', \App\Models\User::first()->toArray());
  151. }
  152. public function test_only_the_first_successful_named_binding_can_set_a_missing_real_name(): void
  153. {
  154. $this->createWalletFixture();
  155. $params = ['channel' => 'DF001', 'bank_name' => 'Fixture Bank', 'bank_branch' => 'Fixture Branch', 'card_no' => '12345'];
  156. $payout = $this->unwrap($this->sendEncrypted('/api/wallet/payout', 'POST', $params + [
  157. 'amount' => 100, 'safe_word' => 'fixture-password', 'account' => 'Unbound Name',
  158. ], true));
  159. self::assertSame('请先绑定收款账户并填写真实姓名', $payout['msg']);
  160. self::assertSame(0, DB::table('payment_orders')->count());
  161. $invalid = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', $params + [
  162. 'id' => 999, 'account' => 'Invalid Binding',
  163. ], true));
  164. self::assertNotSame(0, $invalid['code']);
  165. self::assertNull(DB::table('users')->value('real_name'));
  166. DB::unprepared("CREATE TRIGGER reject_bank BEFORE INSERT ON bot_banks
  167. WHEN NEW.card_no = 'reject-fixture' BEGIN SELECT RAISE(ABORT, 'fixture failure'); END");
  168. $failedSave = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', [
  169. 'card_no' => 'reject-fixture', 'account' => 'Failed Name',
  170. ] + $params, true));
  171. self::assertNotSame(0, $failedSave['code']);
  172. self::assertNull(DB::table('users')->value('real_name'));
  173. foreach (['NOwithdraw', 'ZIMUwithdraw'] as $channel) {
  174. $noName = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', [
  175. 'channel' => $channel, 'card_no' => 'wallet-fixture',
  176. ], true));
  177. self::assertSame('请输入真实姓名', $noName['msg']);
  178. $payout = $this->unwrap($this->sendEncrypted('/api/wallet/payout', 'POST', [
  179. 'channel' => $channel, 'card_no' => 'wallet-fixture', 'amount' => 100,
  180. 'safe_word' => 'fixture-password', 'account' => 'Unbound Name',
  181. ], true));
  182. self::assertSame('请先绑定收款账户并填写真实姓名', $payout['msg']);
  183. }
  184. $binding = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', $params + [
  185. 'account' => " First Bound Name ",
  186. ], true));
  187. self::assertSame('First Bound Name', $binding['data']['real_name']);
  188. $id = DB::table('banks')->where('channel', 'DF001')->value('id');
  189. $update = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', $params + [
  190. 'id' => $id, 'account' => 'Replacement Name',
  191. ], true));
  192. self::assertSame('First Bound Name', $update['data']['real_name']);
  193. self::assertSame('First Bound Name', DB::table('banks')->where('id', $id)->value('account'));
  194. $noBinding = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', [
  195. 'channel' => 'NOwithdraw', 'card_no' => 'no_fixture',
  196. ], true));
  197. self::assertSame(0, $noBinding['code']);
  198. $deleted = $this->unwrap($this->sendEncrypted('/api/wallet/delBank', 'GET', ['id' => $id], true));
  199. self::assertSame(0, $deleted['code']);
  200. $list = $this->unwrap($this->sendEncrypted('/api/wallet/bankList', 'GET', (object) [], true));
  201. self::assertSame('First Bound Name', $list['data']['real_name']);
  202. self::assertSame('First Bound Name', $list['data']['list'][0]['account']);
  203. }
  204. public function test_manual_payout_uses_bank_details_or_wallet_payment_qr_and_shares_the_pending_limit(): void
  205. {
  206. $this->createWalletFixture();
  207. $common = ['channel' => 'rgtx', 'amount' => 100, 'safe_word' => 'fixture-password'];
  208. $payout = fn (array $params) => $this->unwrap($this->sendEncrypted('/api/wallet/payout', 'POST', $params, true));
  209. $qr = 'https://uploads.example.test/fixture.png';
  210. $alipayAccount = 'cash@example.test';
  211. $wechat = ['payout_method' => 'wechat', 'qr_image' => $qr];
  212. $alipay = ['payout_method' => 'alipay', 'card_no' => $alipayAccount, 'qr_image' => $qr];
  213. foreach ([$wechat, $alipay] as $wallet) {
  214. self::assertSame('请先绑定收款账户并填写真实姓名', $payout($common + $wallet + ['account' => 'Injected Name'])['msg']);
  215. }
  216. DB::table('users')->update(['real_name' => 'Fixture Name']);
  217. self::assertSame('请输入银行名称', $payout($common + ['card_no' => '12345'])['msg']);
  218. self::assertSame('请输入银行名称', $payout(['channel' => 'DF001', 'card_no' => '12345'] + $common)['msg']);
  219. foreach (['rgtx', 'DF001'] as $channel) {
  220. self::assertSame('请输入开户行支行名称', $payout([
  221. 'channel' => $channel, 'bank_name' => 'Fixture Bank', 'card_no' => '12345',
  222. ] + $common)['msg']);
  223. }
  224. self::assertSame('请上传有效的收款码图片', $payout($common + ['payout_method' => 'wechat', 'qr_image' => 'javascript:alert(1)'])['msg']);
  225. self::assertSame('请上传有效的收款码图片', $payout($common + ['payout_method' => 'alipay', 'card_no' => $alipayAccount])['msg']);
  226. self::assertSame('请输入支付宝账号', $payout($common + ['payout_method' => 'alipay', 'qr_image' => $qr])['msg']);
  227. self::assertSame('请输入支付宝账号', $payout($common + ['card_no' => $qr] + $alipay)['msg']);
  228. $bank = $payout($common + ['bank_name' => 'Fixture Bank', 'bank_branch' => 'Fixture Branch', 'card_no' => '12345']);
  229. self::assertSame(0, $bank['code'], $bank['msg']);
  230. self::assertSame('bank', $bank['data']['payout_method']);
  231. self::assertSame('Fixture Bank', $bank['data']['bank_name']);
  232. self::assertSame('Fixture Branch', $bank['data']['bank_branch']);
  233. self::assertSame('您已有1笔提现订单正常处理中!', $payout($common + $wechat)['msg']);
  234. self::assertSame(1, DB::table('payment_orders')->count());
  235. self::assertSame(900, (int) DB::table('wallets')->value('available_balance'));
  236. foreach ([[$wechat, '微信', ''], [$alipay, '支付宝', $alipayAccount]] as [$wallet, $bankName, $cardNo]) {
  237. DB::table('payment_orders')->update(['status' => 2]);
  238. $result = $payout($common + $wallet + ['account' => 'Injected Name']);
  239. self::assertSame(0, $result['code'], $result['msg']);
  240. self::assertSame($wallet['payout_method'], $result['data']['payout_method']);
  241. self::assertSame($qr, $result['data']['qr_image']);
  242. $stored = DB::table('payment_orders')->where('id', $result['data']['id'])->first();
  243. self::assertSame(4, (int) $stored->type);
  244. self::assertSame($bankName, $stored->bank_name);
  245. self::assertSame('Fixture Name', $stored->account);
  246. self::assertSame($cardNo, $stored->card_no);
  247. self::assertSame($qr, $stored->qr_image);
  248. }
  249. // Legacy WeChat rows stored the QR URL in the account column.
  250. DB::table('payment_orders')->where('bank_name', '微信')->update(['card_no' => $qr, 'qr_image' => null]);
  251. $this->app->instance('request', Request::create('/admin/withdraw/rmb?type=4'));
  252. $admin = (new \App\Http\Controllers\admin\Withdraw())->rmb()->getData(true);
  253. self::assertSame(0, $admin['code'], $admin['msg']);
  254. $rows = array_column($admin['data']['data'], null, 'payout_method');
  255. self::assertSame('Fixture Bank', $rows['bank']['bank_name']);
  256. self::assertSame('Fixture Branch', $rows['bank']['bank_branch']);
  257. self::assertSame('Fixture Name', $rows['wechat']['recipient_name']);
  258. self::assertSame('fixture-login', $rows['wechat']['account']);
  259. self::assertSame($qr, $rows['wechat']['qr_image']);
  260. self::assertSame('', $rows['wechat']['card_no']);
  261. self::assertSame($alipayAccount, $rows['alipay']['card_no']);
  262. self::assertSame($qr, $rows['alipay']['qr_image']);
  263. $bind = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', ['channel' => 'rgtx'] + $alipay, true));
  264. self::assertSame(0, $bind['code'], $bind['msg']);
  265. $bankList = $this->unwrap($this->sendEncrypted('/api/wallet/bankList', 'GET', ['channel' => 'rgtx'], true));
  266. self::assertSame($alipayAccount, $bankList['data']['list'][0]['card_no']);
  267. self::assertSame($qr, $bankList['data']['list'][0]['qr_image']);
  268. self::assertSame('Fixture Name', $bankList['data']['list'][0]['account']);
  269. }
  270. public function test_protocol_errors_and_rollout_flags(): void
  271. {
  272. Route::get('api/wallet/probe', fn () => response()->json(['code' => 0]));
  273. foreach (['/api/wallet/probe', '/api/newPc', '/api/issue', '/api/pcissue'] as $path) {
  274. $response = $this->send($path);
  275. self::assertSame(400, $response->getStatusCode());
  276. self::assertSame(4001, $this->unwrap($response)['code']);
  277. }
  278. $payload = $this->crypto->encrypt(['amount' => 100], 'request');
  279. $envelope = json_decode(base64_decode(strtr($payload, '-_', '+/')), true);
  280. $envelope['tag'][0] = $envelope['tag'][0] === 'A' ? 'B' : 'A';
  281. $tampered = rtrim(strtr(base64_encode(json_encode($envelope)), '+/', '-_'), '=');
  282. $expired = $this->crypto->encrypt((object) [], 'request', (time() - 301) * 1000);
  283. $wrongDirection = $this->crypto->encrypt((object) [], 'response');
  284. foreach (['', $tampered, $expired, $wrongDirection, $this->crypto->encrypt([], 'request')] as $invalid) {
  285. $response = $this->send('/api/wallet/probe?payload=' . $invalid, 'GET', ['HTTP_X_API_ENCRYPTED' => '1']);
  286. self::assertSame(400, $response->getStatusCode());
  287. self::assertSame(4002, $this->unwrap($response)['code']);
  288. }
  289. Route::get('api/wallet/large-response', fn () => response()->json(['data' => str_repeat('x', 1024)]));
  290. config(['api_crypto.max_payload_bytes' => 1024]);
  291. $response = $this->sendEncrypted('/api/wallet/large-response', 'GET', (object) []);
  292. self::assertSame(500, $response->getStatusCode());
  293. self::assertSame(5002, json_decode($response->getContent(), true)['code']);
  294. config(['api_crypto.allow_plaintext' => true]);
  295. self::assertSame('{"code":0}', $this->send('/api/wallet/probe')->getContent());
  296. self::assertSame(0, $this->unwrap($this->sendEncrypted('/api/wallet/probe', 'GET', (object) []))['code']);
  297. config(['api_crypto.key' => 'invalid']);
  298. $response = $this->send('/api/wallet/probe');
  299. self::assertSame(500, $response->getStatusCode());
  300. self::assertSame(5001, json_decode($response->getContent(), true)['code']);
  301. config(['api_crypto.enabled' => false]);
  302. self::assertSame('{"code":0}', $this->send('/api/wallet/probe')->getContent());
  303. }
  304. public function test_withdrawal_account_and_address_apis_ignore_and_hide_aliases(): void
  305. {
  306. $this->createWalletFixture();
  307. $bank = $this->unwrap($this->sendEncrypted('/api/wallet/addBank', 'POST', [
  308. 'channel' => 'DF001', 'bank_name' => 'Fixture Bank', 'bank_branch' => 'Fixture Branch',
  309. 'card_no' => '12345', 'account' => 'Fixture Name',
  310. 'alias' => 'ignored bank alias',
  311. ], true));
  312. self::assertSame(0, $bank['code']);
  313. self::assertSame('', DB::table('banks')->value('alias'));
  314. DB::table('banks')->update(['alias' => 'old bank alias']);
  315. $bankList = $this->unwrap($this->sendEncrypted('/api/wallet/bankList', 'GET', (object) [], true));
  316. self::assertSame('12345', $bankList['data']['list'][0]['card_no']);
  317. self::assertSame('Fixture Bank', $bankList['data']['list'][0]['bank_name']);
  318. self::assertSame('Fixture Branch', $bankList['data']['list'][0]['bank_branch']);
  319. self::assertArrayNotHasKey('alias', $bankList['data']['list'][0]);
  320. DB::table('banks')->update(['bank_branch' => null, 'alias' => 'Legacy Branch']);
  321. $bankList = $this->unwrap($this->sendEncrypted('/api/wallet/bankList', 'GET', (object) [], true));
  322. self::assertSame('Legacy Branch', $bankList['data']['list'][0]['bank_branch']);
  323. self::assertArrayNotHasKey('alias', $bankList['data']['list'][0]);
  324. $address = 'T' . str_repeat('A', 33);
  325. $saved = $this->unwrap($this->sendEncrypted('/api/wallet/addAddress', 'POST', [
  326. 'address' => $address, 'alias' => 'ignored address alias',
  327. ], true));
  328. self::assertSame(0, $saved['code']);
  329. self::assertNull(DB::table('address')->value('alias'));
  330. DB::table('address')->update(['alias' => 'old address alias']);
  331. $addresses = $this->unwrap($this->sendEncrypted('/api/wallet/address', 'GET', (object) [], true));
  332. self::assertSame($address, $addresses['data']['list'][0]['address']);
  333. self::assertArrayNotHasKey('alias', $addresses['data']['list'][0]);
  334. }
  335. public function test_telegram_saves_withdrawal_destinations_without_prompting_for_aliases(): void
  336. {
  337. $this->createWalletFixture();
  338. Cache::put('42_QB_WITHDRAW_CHANNEL', 'DF001');
  339. QianBaoWithdrawService::onMessage(42, 'Fixture Bank', 1, StepStatus::QB_INPUT_BANK_NAME);
  340. self::assertSame(StepStatus::QB_INPUT_BANK_BRANCH, Cache::get(get_step_key(42)));
  341. QianBaoWithdrawService::onMessage(42, 'Fixture Branch', 1, StepStatus::QB_INPUT_BANK_BRANCH);
  342. self::assertSame(StepStatus::QB_INPUT_CARD_NO, Cache::get(get_step_key(42)));
  343. QianBaoWithdrawService::onMessage(42, '12345', 1, StepStatus::QB_INPUT_CARD_NO);
  344. self::assertSame(StepStatus::QB_INPUT_ACCOUNT, Cache::get(get_step_key(42)));
  345. $saved = QianBaoWithdrawService::onMessage(42, 'Fixture Name', 2, StepStatus::QB_INPUT_ACCOUNT);
  346. $keyboard = json_decode($saved['reply_markup'], true)['inline_keyboard'];
  347. self::assertSame('12345', $keyboard[0][0]['text']);
  348. self::assertSame('', DB::table('banks')->where('card_no', '12345')->value('alias'));
  349. self::assertSame('Fixture Branch', DB::table('banks')->where('card_no', '12345')->value('bank_branch'));
  350. self::assertNull(Cache::get(get_step_key(42)));
  351. Cache::put('42_QB_WITHDRAW_CARD_NO', '67890');
  352. Cache::put('42_QB_ACCOUNT', 'Fixture Name');
  353. QianBaoWithdrawService::onMessage(42, 'Legacy Branch', 3, StepStatus::LEGACY_QB_INPUT_ALIAS);
  354. self::assertSame('', DB::table('banks')->where('card_no', '67890')->value('alias'));
  355. self::assertSame('Legacy Branch', DB::table('banks')->where('card_no', '67890')->value('bank_branch'));
  356. $address = 'T' . str_repeat('A', 33);
  357. $saved = WithdrawService::onMessage(42, $address, 4, StepStatus::INPUT_ADDRESS_TRC20);
  358. $keyboard = json_decode($saved['reply_markup'], true)['inline_keyboard'];
  359. self::assertSame($address, $keyboard[0][0]['text']);
  360. self::assertNull(Cache::get(get_step_key(42)));
  361. $oldAddress = 'T' . str_repeat('B', 33);
  362. Cache::put('42_address', $oldAddress);
  363. WithdrawService::onMessage(42, 'ignored', 5, StepStatus::LEGACY_INPUT_ADDRESS_ALIAS);
  364. self::assertTrue(DB::table('address')->where('address', $oldAddress)->exists());
  365. self::assertSame(0, DB::table('address')->whereNotNull('alias')->count());
  366. }
  367. public function test_jd_and_usdt_require_a_saved_name_without_storing_it_on_orders(): void
  368. {
  369. $this->createWalletFixture();
  370. $address = 'T' . str_repeat('A', 33);
  371. $jd = ['channel' => 'JDpay', 'card_no' => 'jd-wallet', 'amount' => 100, 'safe_word' => 'fixture-password'];
  372. $usdt = ['address' => $address, 'amount' => 20, 'safe_word' => 'fixture-password'];
  373. $post = fn (string $route, array $params) => $this->unwrap(
  374. $this->sendEncrypted('/api/wallet/' . $route, 'POST', $params, true)
  375. );
  376. self::assertSame('请先绑定收款账户并填写真实姓名', $post('payout', $jd + ['account' => 'Injected Name'])['msg']);
  377. self::assertSame('请先绑定收款账户并填写真实姓名', $post('withdraw', $usdt + ['account' => 'Injected Name'])['msg']);
  378. self::assertSame('请输入真实姓名', $post('addBank', ['channel' => 'JDpay', 'card_no' => 'jd-wallet'])['msg']);
  379. self::assertSame('请输入真实姓名', $post('addAddress', ['address' => $address])['msg']);
  380. self::assertNull(DB::table('users')->value('real_name'));
  381. $binding = $post('addAddress', ['address' => $address, 'account' => 'Fixture Name']);
  382. self::assertSame(0, $binding['code']);
  383. self::assertSame('Fixture Name', $binding['data']['real_name']);
  384. $jdBinding = $post('addBank', ['channel' => 'JDpay', 'card_no' => 'jd-wallet', 'account' => 'Ignored Name']);
  385. self::assertSame(0, $jdBinding['code']);
  386. self::assertSame('', DB::table('banks')->sole()->account);
  387. $jdResult = $post('payout', $jd);
  388. self::assertSame(0, $jdResult['code'], $jdResult['msg']);
  389. self::assertSame('', DB::table('payment_orders')->sole()->account);
  390. $usdtResult = $post('withdraw', $usdt);
  391. self::assertSame(0, $usdtResult['code'], $usdtResult['msg']);
  392. self::assertArrayNotHasKey('account', $usdtResult['data']);
  393. self::assertSame('Fixture Name', DB::table('users')->value('real_name'));
  394. }
  395. public function test_cors_preflight_and_head(): void
  396. {
  397. Route::get('api/wallet/probe', fn () => response()->json(['code' => 0]));
  398. $response = $this->send('/api/wallet/probe', 'OPTIONS', [
  399. 'HTTP_ORIGIN' => 'https://frontend.example',
  400. 'HTTP_ACCESS_CONTROL_REQUEST_METHOD' => 'POST',
  401. 'HTTP_ACCESS_CONTROL_REQUEST_HEADERS' => 'content-type,x-api-encrypted',
  402. ]);
  403. self::assertSame(204, $response->getStatusCode());
  404. self::assertStringContainsString('x-api-encrypted', strtolower($response->headers->get('Access-Control-Allow-Headers')));
  405. self::assertFalse($response->headers->has('X-Api-Encrypted'));
  406. $response = $this->sendEncrypted('/api/wallet/probe', 'HEAD', (object) []);
  407. self::assertSame(200, $response->getStatusCode());
  408. self::assertSame('1', $response->headers->get('X-Api-Encrypted'));
  409. self::assertStringContainsString('X-Api-Encrypted', $response->headers->get('Access-Control-Expose-Headers'));
  410. self::assertSame('', $response->getContent());
  411. }
  412. public function test_excluded_routes_keep_plaintext_input_and_response(): void
  413. {
  414. $this->createMaintenanceFixture();
  415. (require dirname(__DIR__, 2) . '/database/migrations/2026_09_08_160000_add_payment_provider_status_and_channel_soft_deletes.php')->up();
  416. $this->app->instance(TelegramWebHook::class, new class extends TelegramWebHook {
  417. public function __construct() {}
  418. public function handle(Request $request): JsonResponse
  419. {
  420. return response()->json(['update_id' => $request->input('update_id')]);
  421. }
  422. });
  423. $telegram = $this->send('/api/onMessage', 'POST', ['CONTENT_TYPE' => 'application/json'], '{"update_id":123}');
  424. self::assertSame('{"update_id":123}', $telegram->getContent());
  425. self::assertFalse($telegram->headers->has('X-Api-Encrypted'));
  426. foreach (['notify', 'harvest'] as $callback) {
  427. $response = $this->send('/api/pay/' . $callback, 'POST', ['CONTENT_TYPE' => 'application/json'],
  428. '{"appId":"unmatched-fixture","merchantNum":"unmatched-fixture","userCode":"unmatched-fixture","mchId":"unmatched-fixture"}');
  429. self::assertSame(200, $response->getStatusCode(), $callback . ': ' . $response->getContent());
  430. self::assertSame('success', $response->getContent());
  431. self::assertFalse($response->headers->has('X-Api-Encrypted'));
  432. }
  433. Schema::create('config', function (Blueprint $table) {
  434. $table->id();
  435. $table->string('field');
  436. $table->string('val');
  437. });
  438. DB::table('config')->insert([
  439. ['field' => 'activity_rule', 'val' => 'Telegram rule fixture'],
  440. ['field' => 'benefits_service_customer', 'val' => 'customer fixture'],
  441. ]);
  442. $activity = $this->send('/api/ActivityReward/rule');
  443. self::assertSame(200, $activity->getStatusCode());
  444. self::assertSame('Telegram rule fixture', json_decode($activity->getContent(), true)['data']['rule']);
  445. self::assertFalse($activity->headers->has('X-Api-Encrypted'));
  446. $admin = $this->send('/admin/maintenance/options');
  447. self::assertFalse($admin->headers->has('X-Api-Encrypted'));
  448. }
  449. private function send(string $url, string $method = 'GET', array $headers = [], ?string $body = null): Response
  450. {
  451. return $this->kernel->handle(Request::create($url, $method, [], [], [], $headers + [
  452. 'HTTP_ORIGIN' => 'https://frontend.example',
  453. 'HTTP_ACCEPT' => 'application/json',
  454. ], $body));
  455. }
  456. private function sendEncrypted(string $url, string $method, array|object $parameters, bool $authenticated = false, array $outerBody = []): Response
  457. {
  458. $payload = $this->crypto->encrypt($parameters, 'request');
  459. $headers = ['HTTP_X_API_ENCRYPTED' => '1'];
  460. if ($authenticated) {
  461. $headers['HTTP_AUTHORIZATION'] = self::TOKEN;
  462. }
  463. if ($method === 'POST') {
  464. return $this->send($url, $method, $headers + ['CONTENT_TYPE' => 'application/json'], json_encode(['payload' => $payload] + $outerBody));
  465. }
  466. return $this->send($url . (str_contains($url, '?') ? '&' : '?') . 'payload=' . $payload, $method, $headers);
  467. }
  468. private function unwrap(Response $response): array
  469. {
  470. self::assertSame('1', $response->headers->get('X-Api-Encrypted'), (string) $response->getContent());
  471. self::assertStringContainsString('no-store', $response->headers->get('Cache-Control'));
  472. $envelope = json_decode($response->getContent(), true, 512, JSON_THROW_ON_ERROR);
  473. self::assertTrue($envelope['encrypted']);
  474. return $this->crypto->decrypt($envelope['payload'], 'response');
  475. }
  476. private function createMaintenanceFixture(): void
  477. {
  478. (require dirname(__DIR__, 2) . '/database/migrations/2026_10_26_120000_create_maintenance_settings.php')->up();
  479. }
  480. private function createWalletFixture(): void
  481. {
  482. DB::connection()->getPdo()->sqliteCreateCollation('utf8mb4_general_ci', 'strcasecmp');
  483. $this->createMaintenanceFixture();
  484. Schema::create('users', function (Blueprint $table) {
  485. $table->id();
  486. $table->string('user_id');
  487. $table->string('member_id');
  488. $table->string('account')->default('fixture-login');
  489. $table->string('first_name')->nullable();
  490. $table->string('admin_note')->nullable();
  491. $table->integer('from');
  492. $table->bigInteger('last_active_time')->default(0);
  493. $table->integer('recharge_channel_group_id');
  494. $table->string('payment_password');
  495. $table->integer('level')->default(1);
  496. $table->string('agent_user_code')->nullable();
  497. $table->timestamps();
  498. });
  499. (require dirname(__DIR__, 2) . '/database/migrations/2026_11_06_120000_add_real_name_to_users.php')->up();
  500. Schema::create('level', function (Blueprint $table) {
  501. $table->id();
  502. $table->integer('level');
  503. $table->string('level_name');
  504. $table->string('img');
  505. $table->decimal('recharge');
  506. });
  507. Schema::create('user_session', function (Blueprint $table) {
  508. $table->id();
  509. $table->string('user_id');
  510. $table->string('token');
  511. $table->bigInteger('expire_time');
  512. $table->bigInteger('create_time');
  513. $table->bigInteger('update_time');
  514. });
  515. Schema::create('recharge_channel_group', function (Blueprint $table) {
  516. $table->id();
  517. $table->string('withdraw_type');
  518. $table->softDeletes();
  519. });
  520. Schema::create('recharge_channel', function (Blueprint $table) {
  521. $table->id();
  522. $table->integer('data_type');
  523. $table->integer('status');
  524. $table->integer('sort');
  525. $table->string('name');
  526. $table->string('type');
  527. $table->decimal('rate');
  528. $table->decimal('min');
  529. $table->decimal('max');
  530. $table->string('fixed')->nullable();
  531. $table->string('logo')->nullable();
  532. });
  533. (require dirname(__DIR__, 2) . '/database/migrations/2026_09_08_160000_add_payment_provider_status_and_channel_soft_deletes.php')->up();
  534. Schema::create('wallets', function (Blueprint $table) {
  535. $table->id();
  536. $table->string('member_id');
  537. $table->decimal('available_balance');
  538. $table->decimal('frozen_balance')->default(0);
  539. $table->timestamps();
  540. });
  541. Schema::create('payment_orders', function (Blueprint $table) {
  542. $table->id();
  543. $table->integer('type');
  544. $table->integer('status');
  545. foreach (['member_id', 'order_no', 'channel', 'bank_name', 'account', 'card_no'] as $field) {
  546. $table->string($field);
  547. }
  548. $table->string('callback_url')->nullable();
  549. $table->string('remark')->nullable();
  550. $table->decimal('amount');
  551. $table->decimal('fee');
  552. $table->timestamps();
  553. });
  554. Schema::create('backflow', function (Blueprint $table) {
  555. $table->id();
  556. $table->string('member_id');
  557. $table->string('date');
  558. $table->integer('status')->default(0);
  559. $table->decimal('withdrawal_amount')->default(0);
  560. $table->timestamps();
  561. });
  562. Schema::create('balance_logs', function (Blueprint $table) {
  563. $table->id();
  564. $table->integer('type')->default(1);
  565. $table->string('member_id');
  566. $table->string('change_type');
  567. $table->integer('related_id');
  568. $table->string('remark');
  569. $table->decimal('amount');
  570. $table->decimal('before_balance');
  571. $table->decimal('after_balance');
  572. $table->timestamps();
  573. });
  574. Schema::create('banks', function (Blueprint $table) {
  575. $table->id();
  576. foreach (['member_id', 'channel', 'bank_name', 'account', 'card_no'] as $field) {
  577. $table->string($field);
  578. }
  579. $table->string('alias')->default('');
  580. $table->timestamps();
  581. });
  582. Schema::create('address', function (Blueprint $table) {
  583. $table->id();
  584. $table->string('member_id');
  585. $table->string('address');
  586. $table->string('alias')->nullable();
  587. $table->timestamps();
  588. });
  589. (require dirname(__DIR__, 2) . '/database/migrations/2026_11_06_140000_add_qr_image_to_withdrawal_destinations.php')->up();
  590. (require dirname(__DIR__, 2) . '/database/migrations/2026_11_06_150000_add_bank_branch_to_withdrawal_destinations.php')->up();
  591. Schema::create('config', function (Blueprint $table) {
  592. $table->id();
  593. $table->string('field');
  594. $table->string('val');
  595. });
  596. DB::table('config')->insert([['field' => 'service_charge', 'val' => '1'], ['field' => 'exchange_rate_rmb', 'val' => '1']]);
  597. Schema::create('withdraws', function (Blueprint $table) {
  598. $table->id();
  599. $table->string('member_id');
  600. $table->string('address');
  601. $table->integer('status');
  602. foreach (['amount', 'service_charge', 'to_account', 'exchange_rate', 'after_balance'] as $field) {
  603. $table->decimal($field);
  604. }
  605. $table->timestamps();
  606. });
  607. DB::table('users')->insert(['user_id' => '42', 'member_id' => '42', 'from' => 1, 'recharge_channel_group_id' => 1,
  608. 'payment_password' => password_hash('fixture-password', PASSWORD_DEFAULT)]);
  609. DB::table('user_session')->insert(['user_id' => '42', 'token' => self::TOKEN,
  610. 'expire_time' => time() + 3600, 'create_time' => time(), 'update_time' => time()]);
  611. DB::table('wallets')->insert(['member_id' => '42', 'available_balance' => 1000]);
  612. DB::table('recharge_channel_group')->insert(['id' => 1, 'withdraw_type' => 'DF001,NOwithdraw,ZIMUwithdraw,JDpay,rgtx,usdt']);
  613. foreach (['DF001' => '银行卡', 'NOwithdraw' => 'NO快捷提现', 'ZIMUwithdraw' => '808账户提现', 'JDpay' => 'JD钱包', 'rgtx' => '人工提现', 'usdt' => 'USDT提现'] as $type => $name) {
  614. DB::table('recharge_channel')->insert(['data_type' => 2, 'status' => 1, 'sort' => 0,
  615. 'name' => $name, 'type' => $type, 'rate' => 0, 'min' => 10, 'max' => 5000]);
  616. }
  617. }
  618. }