Agent.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515
  1. <?php
  2. namespace App\Http\Controllers\admin;
  3. use App\Http\Controllers\AgentApiController;
  4. use App\Models\Agent\Agent as AgentModel;
  5. use App\Models\Agent\AgentLoginLog;
  6. use App\Models\Agent\AgentWithdrawal;
  7. use App\Models\Agent\AgentRebateRecord;
  8. use App\Models\EgameItem;
  9. use App\Services\Agent\AgentDomainService;
  10. use App\Services\Agent\AgentReportService;
  11. use App\Services\Agent\AgentService;
  12. use App\Services\Agent\AgentWalletService;
  13. use App\Services\Agent\AgentWithdrawalService;
  14. use App\Services\Agent\AgentPlanApplicationService;
  15. use App\Services\Agent\AgentRechargeService;
  16. use App\Services\Agent\AgentPaymentService;
  17. use App\Models\Agent\AgentSetting;
  18. use App\Models\Agent\AgentRecharge;
  19. use App\Models\Agent\AgentProfitEntry;
  20. use App\Services\Agent\AgentProfitCommissionProfileService;
  21. use Illuminate\Http\Request;
  22. use Illuminate\Validation\Rule;
  23. use Illuminate\Support\Facades\DB;
  24. use App\Rules\DecimalNumber;
  25. use App\Constants\Util;
  26. use App\Services\ThirdGameBalanceService;
  27. class Agent extends AgentApiController
  28. {
  29. public function index(Request $request, AgentDomainService $domains)
  30. {
  31. return $this->execute(function () use ($request, $domains) {
  32. $data = $request->validate([
  33. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  34. 'username' => ['nullable', 'string', 'max:64'], 'real_name' => ['nullable', 'string', 'max:128'],
  35. 'type' => ['nullable', 'integer', 'in:1,2'], 'status' => ['nullable', 'integer', 'in:0,1'],
  36. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  37. ]);
  38. $page = max(1, (int) ($data['page'] ?? 1));
  39. $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
  40. $query = AgentModel::query()->with(['token:id,agent_id,expires_at,last_used_at', 'profitCommissionProfile'])->withCount(['members']);
  41. if (!empty($data['username'])) $query->where('username', 'like', '%' . $data['username'] . '%');
  42. if (!empty($data['real_name'])) $query->where('real_name', 'like', '%' . $data['real_name'] . '%');
  43. if (!empty($data['type'])) $query->where('type', $data['type']);
  44. if (isset($data['status'])) $query->where('status', $data['status']);
  45. if (!empty($data['start_date'])) $query->where('created_at', '>=', $data['start_date'] . ' 00:00:00');
  46. if (!empty($data['end_date'])) $query->where('created_at', '<=', $data['end_date'] . ' 23:59:59');
  47. $total = (clone $query)->count();
  48. $list = $query->orderByDesc('id')->forPage($page, $limit)->get()->map(fn(AgentModel $agent) => $this->formatAgent($agent, $domains));
  49. return compact('total', 'page', 'limit', 'list');
  50. });
  51. }
  52. public function show(Request $request, AgentDomainService $domains)
  53. {
  54. return $this->execute(function () use ($request, $domains) {
  55. $data = $request->validate(['id' => ['required', 'integer', 'exists:agents,id']]);
  56. $agent = AgentModel::query()->with(['token:id,agent_id,expires_at,last_used_at', 'profitCommissionProfile'])->withCount(['members'])->findOrFail($data['id']);
  57. return $this->formatAgent($agent, $domains);
  58. });
  59. }
  60. public function store(Request $request, AgentService $service)
  61. {
  62. return $this->execute(function () use ($request, $service) {
  63. $data = $request->validate($this->rules());
  64. return DB::transaction(function () use ($data, $service) {
  65. $agent = $service->create($data, (int) request()->user->id);
  66. if (bccomp((string) ($data['initial_balance'] ?? 0), '0', 4) > 0) {
  67. app(AgentWalletService::class)->adjust(
  68. (int) $agent->id,
  69. (string) $data['initial_balance'],
  70. 'credit',
  71. '新增代理初始额度',
  72. 'agent-initial:' . $agent->id,
  73. 'admin',
  74. (int) request()->user->id
  75. );
  76. $agent = $agent->fresh(['profitCommissionProfile']);
  77. }
  78. return $agent;
  79. });
  80. });
  81. }
  82. public function update(Request $request, AgentService $service)
  83. {
  84. return $this->execute(function () use ($request, $service) {
  85. $data = $request->validate(array_merge(['id' => ['required', 'integer', 'exists:agents,id']], $this->rules(true)));
  86. return DB::transaction(function () use ($service, $data) {
  87. return $service->update(AgentModel::query()->findOrFail($data['id']), $data);
  88. });
  89. });
  90. }
  91. public function domains(Request $request, AgentDomainService $service)
  92. {
  93. return $this->execute(function () use ($request, $service) {
  94. $data = $request->validate([
  95. 'id' => ['required', 'integer', 'exists:agents,id'],
  96. // domains:域名数组(整体替换,空数组为清空),也可以是字符串(一个域名)
  97. 'domains' => ['present', function ($attribute, $value, $fail) {
  98. if (!is_string($value) && !is_array($value)) $fail('域名格式错误');
  99. elseif (is_string($value) && mb_strlen($value) > 255) $fail('域名不能超过255个字符');
  100. }],
  101. 'domains.*' => ['nullable', 'string', 'max:255'],
  102. ]);
  103. $domains = $request->input('domains');
  104. $values = is_array($domains) ? $domains : ($domains === null ? [] : [(string) $domains]);
  105. return $service->save(AgentModel::query()->findOrFail($data['id']), $values);
  106. });
  107. }
  108. public function adjust(Request $request, AgentWalletService $wallets)
  109. {
  110. return $this->execute(function () use ($request, $wallets) {
  111. $data = $request->validate([
  112. 'agent_id' => ['required', 'integer', 'exists:agents,id'], 'type' => ['required', 'in:credit,debit,margin_credit,margin_refund'],
  113. 'amount' => ['required', 'numeric', 'min:0.0001', new DecimalNumber()], 'remark' => ['required', 'string', 'max:500'],
  114. 'request_id' => ['required', 'string', 'max:64'],
  115. ]);
  116. return $wallets->adjust(
  117. (int) $data['agent_id'], (string) $data['amount'], $data['type'], $data['remark'],
  118. 'admin:' . request()->user->id . ':' . $data['request_id'], 'admin', (int) request()->user->id
  119. );
  120. });
  121. }
  122. public function quota(Request $request, ThirdGameBalanceService $thirdGame)
  123. {
  124. return $this->execute(function () use ($request, $thirdGame) {
  125. $data = $request->validate([
  126. 'agent_id' => ['required', 'integer', 'exists:agents,id'],
  127. 'refresh' => ['nullable', 'boolean'],
  128. ]);
  129. $agent = AgentModel::query()->findOrFail($data['agent_id']);
  130. $provider = $thirdGame->agentBalances((int) $agent->id, $request->boolean('refresh'));
  131. if (empty($provider['ok'])) {
  132. throw new \RuntimeException((string) ($provider['msg'] ?? '三方平台余额查询失败'));
  133. }
  134. $balances = is_array($provider['balances'] ?? null) ? $provider['balances'] : [];
  135. $platforms = EgameItem::query()->where('item_type', EgameItem::TYPE_PLATFORM)->where('game_type', 0)
  136. ->where('status', EgameItem::STATUS_ENABLED)->orderByDesc('sort')->get(['plat_type', 'name', 'logo'])
  137. ->map(function (EgameItem $platform) use ($balances) {
  138. $key = strtolower((string) $platform->plat_type);
  139. $platform->logo = Util::ensureUrl($platform->logo);
  140. $platform->setAttribute('balance', $balances[$key] ?? '0.0000000000');
  141. $platform->setAttribute('account_opened', array_key_exists($key, $balances) ? 1 : 0);
  142. return $platform;
  143. });
  144. return [
  145. 'agent_id' => (int) $agent->id,
  146. 'player_id' => (string) $provider['player_id'],
  147. 'currency' => (string) $provider['currency'],
  148. 'balance' => (string) $agent->balance,
  149. 'frozen_balance' => (string) $agent->frozen_balance,
  150. 'quota_mode' => 'provider',
  151. 'provider_wallet_supported' => true,
  152. 'platforms' => $platforms,
  153. ];
  154. });
  155. }
  156. public function loginLogs(Request $request)
  157. {
  158. return $this->execute(function () use ($request) {
  159. $data = $request->validate([
  160. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  161. 'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
  162. 'ip' => ['nullable', 'string', 'max:64'], 'device' => ['nullable', 'in:mobile,pc'],
  163. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  164. ]);
  165. $query = AgentLoginLog::query();
  166. foreach (['agent_id', 'username', 'ip', 'device'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
  167. return $this->paginate($query, $data, 'login_at', true, 'login_at');
  168. });
  169. }
  170. public function withdrawals(Request $request)
  171. {
  172. return $this->execute(function () use ($request) {
  173. $data = $request->validate([
  174. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  175. 'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:40'],
  176. 'status' => ['nullable', 'in:pending,approved,processing,rejected,paid,failed'], 'channel' => ['nullable', 'string', 'max:32'],
  177. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  178. ]);
  179. $query = AgentWithdrawal::query()->with('agent:id,username,real_name');
  180. foreach (['agent_id', 'order_no', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
  181. if (!empty($data['channel'])) $query->where('account_type', $data['channel']);
  182. $result = $this->paginate($query, $data);
  183. $result['list']->each->makeVisible(AgentWithdrawal::ADMIN_ONLY);
  184. return $result;
  185. });
  186. }
  187. public function auditWithdrawal(Request $request, AgentWithdrawalService $service)
  188. {
  189. return $this->execute(function () use ($request, $service) {
  190. $data = $request->validate([
  191. 'id' => ['required', 'integer', 'exists:agent_withdrawals,id'],
  192. 'action' => ['required', 'in:approve,reject,paid'], 'remark' => ['nullable', 'string', 'max:500'],
  193. ]);
  194. return $service->audit((int) $data['id'], $data['action'], (int) request()->user->id, (string) ($data['remark'] ?? ''));
  195. });
  196. }
  197. public function reports(Request $request, AgentReportService $reports)
  198. {
  199. return $this->execute(function () use ($request, $reports) {
  200. $data = $request->validate([
  201. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:20'],
  202. 'username' => ['nullable', 'string', 'max:64'], 'start_date' => ['required', 'date_format:Y-m-d'],
  203. 'end_date' => ['required', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  204. ]);
  205. return $reports->reportRows(null, $data);
  206. });
  207. }
  208. public function commissions(Request $request)
  209. {
  210. return $this->execute(function () use ($request) {
  211. $data = $request->validate([
  212. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  213. 'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:48'],
  214. 'username' => ['nullable', 'string', 'max:64'],
  215. 'platform' => ['nullable', 'string', 'max:32'],
  216. 'category' => ['nullable', 'string', 'max:32'],
  217. 'profit_status' => ['nullable', 'in:pending,credited'],
  218. 'settlement_date' => ['nullable', 'date_format:Y-m-d'],
  219. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  220. ]);
  221. $query = AgentRebateRecord::query()->with('agent:id,username');
  222. if (!empty($data['category'])) $query->where('platform', $data['category']);
  223. foreach (['agent_id', 'order_no', 'platform', 'profit_status'] as $field) {
  224. if (!empty($data[$field])) $query->where($field, $data[$field]);
  225. }
  226. if (!empty($data['username'])) {
  227. $query->whereHas('agent', fn($query) => $query->where('username', 'like', '%' . $data['username'] . '%'));
  228. }
  229. if (!empty($data['settlement_date'])) $query->where('settlement_date', $data['settlement_date']);
  230. if (!empty($data['start_date'])) $query->where('created_at', '>=', $data['start_date'] . ' 00:00:00');
  231. if (!empty($data['end_date'])) $query->where('created_at', '<=', $data['end_date'] . ' 23:59:59');
  232. return $this->paginate($query, $data, 'settlement_date', false);
  233. });
  234. }
  235. public function profitCommissionProfiles(Request $request, AgentProfitCommissionProfileService $service)
  236. {
  237. return $this->execute(function () use ($request, $service) {
  238. $data = $request->validate([
  239. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  240. 'name' => ['nullable', 'string', 'max:128'],
  241. ]);
  242. return $service->paginate($data);
  243. });
  244. }
  245. public function saveProfitCommissionProfile(Request $request, AgentProfitCommissionProfileService $service)
  246. {
  247. return $this->execute(function () use ($request, $service) {
  248. $data = $request->validate([
  249. 'id' => ['nullable', 'integer', 'exists:agent_profit_commission_profiles,id'],
  250. 'name' => ['required', 'string', 'max:128'],
  251. 'margin_amount' => ['required', 'numeric', 'min:0', new DecimalNumber()],
  252. 'f1_lottery_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  253. 'f1_sport_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  254. 'live_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  255. 'slot_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  256. 'sport_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  257. 'esports_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  258. 'fishing_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  259. 'chess_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  260. ]);
  261. return $service->save($data, (int) request()->user->id);
  262. });
  263. }
  264. public function deleteProfitCommissionProfile(Request $request, AgentProfitCommissionProfileService $service)
  265. {
  266. return $this->execute(function () use ($request, $service) {
  267. $data = $request->validate(['id' => ['required', 'integer', 'exists:agent_profit_commission_profiles,id']]);
  268. $service->delete((int) $data['id']);
  269. return [];
  270. });
  271. }
  272. /** 代理全局配置:停止分成阈值(方案保证金的百分比)、入股价格与可购买区间。 */
  273. public function settings()
  274. {
  275. return $this->execute(fn () => AgentSetting::current());
  276. }
  277. public function saveSettings(Request $request)
  278. {
  279. return $this->execute(function () use ($request) {
  280. $data = $request->validate([
  281. 'margin_stop_percent' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  282. 'equity_enabled' => ['required', 'boolean'],
  283. 'equity_price_per_percent' => ['required', 'numeric', 'min:0', new DecimalNumber()],
  284. 'equity_min_percent' => ['required', 'numeric', 'gt:0', 'max:100', new DecimalNumber(3, 4)],
  285. 'equity_max_percent' => ['required', 'numeric', 'gte:equity_min_percent', 'max:100', new DecimalNumber(3, 4)],
  286. 'equity_recharge_lock_days' => ['nullable', 'integer', 'between:0,365'],
  287. 'recharge_channel_group_id' => ['nullable', 'integer', \Illuminate\Validation\Rule::exists('recharge_channel_group', 'id')->whereNull('deleted_at')],
  288. ]);
  289. if (array_key_exists('recharge_channel_group_id', $data)) $data['recharge_channel_group_id'] = (int) ($data['recharge_channel_group_id'] ?: 1);
  290. if (array_key_exists('equity_recharge_lock_days', $data) && $data['equity_recharge_lock_days'] === null) unset($data['equity_recharge_lock_days']);
  291. $setting = AgentSetting::current();
  292. $setting->fill($data + ['updated_by' => (int) request()->user->id]);
  293. $setting->equity_enabled = $request->boolean('equity_enabled') ? 1 : 0;
  294. $setting->save();
  295. return $setting->fresh();
  296. });
  297. }
  298. public function planApplications(Request $request, AgentPlanApplicationService $service)
  299. {
  300. return $this->execute(function () use ($request, $service) {
  301. $data = $request->validate([
  302. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  303. 'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
  304. 'status' => ['nullable', 'in:pending,approved,rejected'],
  305. ]);
  306. return $service->paginate($data);
  307. });
  308. }
  309. public function auditPlanApplication(Request $request, AgentPlanApplicationService $service)
  310. {
  311. return $this->execute(function () use ($request, $service) {
  312. $data = $request->validate([
  313. 'id' => ['required', 'integer'], 'status' => ['required', 'in:approved,rejected'],
  314. 'reject_reason' => ['required_if:status,rejected', 'nullable', 'string', 'max:500'],
  315. ]);
  316. return $service->audit((int) $data['id'], $data['status'], (int) request()->user->id, (string) ($data['reject_reason'] ?? ''));
  317. });
  318. }
  319. /** 入股购买记录(全部代理)。 */
  320. public function equityOrders(Request $request, \App\Services\Agent\AgentEquityService $service)
  321. {
  322. return $this->execute(function () use ($request, $service) {
  323. $data = $request->validate([
  324. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  325. 'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
  326. 'order_no' => ['nullable', 'string', 'max:40'], 'status' => ['nullable', 'in:pending_payment,completed,cancelled'],
  327. 'date_type' => ['nullable', 'in:created_at,completed_at'],
  328. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  329. ]);
  330. return $service->paginate($data);
  331. });
  332. }
  333. /** 取消代理的待付款入股订单。 */
  334. public function cancelEquityOrder(Request $request, \App\Services\Agent\AgentEquityService $service)
  335. {
  336. return $this->execute(function () use ($request, $service) {
  337. $data = $request->validate(['id' => ['required', 'integer'], 'remark' => ['required', 'string', 'max:255']]);
  338. return $service->adminCancel((int) $data['id'], (int) request()->user->id, (string) $data['remark']);
  339. });
  340. }
  341. public function recharges(Request $request)
  342. {
  343. return $this->execute(function () use ($request) {
  344. $data = $request->validate([
  345. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  346. 'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:40'],
  347. 'txid' => ['nullable', 'string', 'max:100'], 'type' => ['nullable', 'integer', 'in:1,2'],
  348. 'status' => ['nullable', 'integer', 'in:0,1,2,3'],
  349. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  350. ]);
  351. $query = AgentRecharge::query()->with('agent:id,username,real_name,type');
  352. foreach (['agent_id', 'order_no', 'txid', 'type'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
  353. if (isset($data['status'])) $query->where('status', (int) $data['status']);
  354. return $this->paginate($query, $data);
  355. });
  356. }
  357. public function auditRecharge(Request $request, AgentRechargeService $service)
  358. {
  359. return $this->execute(function () use ($request, $service) {
  360. $data = $request->validate([
  361. 'id' => ['required', 'integer'], 'status' => ['required', 'integer', 'in:1,2'],
  362. 'remark' => ['required_if:status,2', 'nullable', 'string', 'max:500'],
  363. ]);
  364. return $service->audit((int) $data['id'], (int) $data['status'], (int) request()->user->id, (string) ($data['remark'] ?? ''));
  365. });
  366. }
  367. /** 代理人民币充值(在线代收 + 人工充值)。 */
  368. public function paymentOrders(Request $request, AgentPaymentService $service)
  369. {
  370. return $this->execute(function () use ($request, $service) {
  371. $data = $request->validate([
  372. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  373. 'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:64'],
  374. 'type' => ['nullable', 'integer', 'in:1,3'], 'channel' => ['nullable', 'string', 'max:50'],
  375. 'payment_type' => ['nullable', 'integer'], 'status' => ['nullable', 'integer', 'between:0,7'],
  376. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  377. ]);
  378. return $service->paginate($data);
  379. });
  380. }
  381. public function paymentOrderPayData(Request $request, AgentPaymentService $service)
  382. {
  383. return $this->execute(function () use ($request, $service) {
  384. $data = $request->validate([
  385. 'ids' => ['required', 'array', 'min:1'], 'ids.*' => ['required', 'integer', 'min:1'],
  386. 'payment_type' => ['required', 'integer'], 'pay_data' => ['required', 'string'],
  387. ]);
  388. return ['updated' => $service->setPayData($data['ids'], (int) $data['payment_type'], $data['pay_data'])];
  389. });
  390. }
  391. public function auditPaymentOrder(Request $request, AgentPaymentService $service)
  392. {
  393. return $this->execute(function () use ($request, $service) {
  394. $data = $request->validate([
  395. 'id' => ['required', 'integer'], 'status' => ['required', 'integer', 'in:2,3'],
  396. 'remark' => ['required_if:status,3', 'nullable', 'string', 'max:255'],
  397. ]);
  398. return $service->manualAudit((int) $data['id'], (int) $data['status'], (string) ($data['remark'] ?? ''), (int) request()->user->id);
  399. });
  400. }
  401. public function rejectPaymentOrder(Request $request, AgentPaymentService $service)
  402. {
  403. return $this->execute(function () use ($request, $service) {
  404. $data = $request->validate(['id' => ['required', 'integer'], 'remark' => ['nullable', 'string', 'max:120']]);
  405. return $service->reject((int) $data['id'], (string) ($data['remark'] ?? ''), (int) request()->user->id);
  406. });
  407. }
  408. public function queryPaymentOrder(Request $request, AgentPaymentService $service)
  409. {
  410. return $this->execute(function () use ($request, $service) {
  411. $data = $request->validate(['id' => ['required', 'integer']]);
  412. $result = $service->query((int) $data['id']);
  413. return ['paid' => (int) ($result['code'] ?? 0) === 1, 'msg' => (string) ($result['msg'] ?? '')];
  414. });
  415. }
  416. public function profitEntries(Request $request)
  417. {
  418. return $this->execute(function () use ($request) {
  419. $data = $request->validate([
  420. 'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
  421. 'agent_id' => ['nullable', 'integer'], 'user_id' => ['nullable', 'integer'], 'category' => ['nullable', 'string', 'max:32'],
  422. 'status' => ['nullable', 'in:counted,skipped_inactive,skipped_no_plan,skipped_category'],
  423. 'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
  424. ]);
  425. $query = AgentProfitEntry::query();
  426. foreach (['agent_id', 'user_id', 'category', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
  427. if (!empty($data['start_date'])) $query->where('settle_date', '>=', $data['start_date']);
  428. if (!empty($data['end_date'])) $query->where('settle_date', '<=', $data['end_date']);
  429. $page = max(1, (int) ($data['page'] ?? 1));
  430. $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
  431. $total = (clone $query)->count();
  432. $list = $query->orderByDesc('id')->forPage($page, $limit)->get()->each->makeVisible('realtime_balance_after');
  433. return compact('total', 'page', 'limit', 'list');
  434. });
  435. }
  436. private function rules(bool $update = false): array
  437. {
  438. return [
  439. 'language' => ['sometimes', 'required', 'in:zh,en,vi'],
  440. 'type' => [$update ? 'nullable' : 'required', 'integer', 'in:1,2'],
  441. 'username' => $update
  442. ? ['sometimes', 'string', 'min:4', 'max:64', 'alpha_dash', Rule::unique('agents', 'username')->ignore((int) request()->input('id'))]
  443. : ['required', 'string', 'min:4', 'max:64', 'alpha_dash', 'unique:agents,username'],
  444. 'password' => [$update ? 'nullable' : 'required', 'string', 'min:6', 'max:100'],
  445. 'withdraw_password' => ['nullable', 'string', 'min:6', 'max:100'], 'real_name' => ['nullable', 'string', 'max:128'],
  446. 'deposit_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  447. 'withdraw_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
  448. 'status' => ['nullable', 'integer', 'in:0,1'],
  449. 'initial_balance' => $update ? ['prohibited'] : ['nullable', 'numeric', 'min:0', new DecimalNumber()],
  450. ];
  451. }
  452. private function paginate($query, array $data, string $orderBy = 'id', bool $filterCreatedAt = true, string $dateColumn = 'created_at'): array
  453. {
  454. $page = max(1, (int) ($data['page'] ?? 1));
  455. $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
  456. if ($filterCreatedAt && !empty($data['start_date'])) $query->where($dateColumn, '>=', $data['start_date'] . ' 00:00:00');
  457. if ($filterCreatedAt && !empty($data['end_date'])) $query->where($dateColumn, '<=', $data['end_date'] . ' 23:59:59');
  458. $total = (clone $query)->count();
  459. $list = $query->orderByDesc($orderBy)->orderByDesc('id')->forPage($page, $limit)->get();
  460. return compact('total', 'page', 'limit', 'list');
  461. }
  462. private function formatAgent(AgentModel $agent, AgentDomainService $domains): array
  463. {
  464. $token = $agent->token;
  465. $online = $token
  466. && $token->expires_at->isFuture()
  467. && $token->last_used_at
  468. && $token->last_used_at->gte(now()->subMinutes(config('agent.online_minutes', 5)));
  469. $data = $agent->toArray();
  470. unset($data['token']);
  471. $wallets = app(AgentWalletService::class);
  472. return array_merge($data, $domains->format($agent), $wallets->funds($agent), [
  473. // 总后台可以看到实时保证金;代理端不返回。
  474. 'realtime_balance' => (string) $agent->realtime_balance,
  475. 'realtime_margin' => $agent->isJoint() ? $wallets->effectiveMargin($agent) : null,
  476. 'login_status' => $online ? 1 : 0,
  477. 'login_status_text' => $online ? '在线' : '离线',
  478. 'last_active_at' => $token?->last_used_at?->toDateTimeString(),
  479. ]);
  480. }
  481. }