SubscribeController.php 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Controllers\Controller;
  4. use App\Models\UserSubscribe;
  5. use App\Utils\IP;
  6. use Illuminate\Contracts\View\View;
  7. use Illuminate\Http\JsonResponse;
  8. use Illuminate\Http\Request;
  9. class SubscribeController extends Controller
  10. {
  11. public function index(Request $request): View
  12. { // 订阅码列表
  13. $query = UserSubscribe::with(['user:id,username']);
  14. $request->whenFilled('username', function ($username) use ($query) {
  15. $query->whereHas('user', function ($query) use ($username) {
  16. $query->where('username', 'like', "%$username%");
  17. });
  18. });
  19. foreach (['user_id', 'status', 'code'] as $field) {
  20. $request->whenFilled($field, function ($value) use ($query, $field) {
  21. $query->where($field, $value);
  22. });
  23. }
  24. return view('admin.subscribe.index', ['subscribeList' => $query->sortable(['id' => 'desc'])->paginate(20)->appends($request->except('page'))]);
  25. }
  26. public function subscribeLog(Request $request, UserSubscribe $userSubscribe): View
  27. { // 订阅记录
  28. $query = $userSubscribe->userSubscribeLogs();
  29. $request->whenFilled('id', function ($value) use ($query) {
  30. $query->where('id', $value);
  31. });
  32. $request->whenFilled('ip', function ($value) use ($query) {
  33. $query->where('request_ip', 'like', "%$value%");
  34. });
  35. if ($request->filled('start')) {
  36. $query->whereBetween('request_time', [$request->input('start').' 00:00:00', $request->input('end').' 23:59:59']);
  37. }
  38. $subscribeLogs = $query->latest()->paginate(20)->appends($request->except('page'));
  39. // 批量获取 IP 信息以减少查询次数
  40. $ipList = $subscribeLogs->pluck('request_ip')->filter()->unique()->toArray();
  41. $ipInfoMap = [];
  42. foreach ($ipList as $ip) {
  43. if ($ip) {
  44. $ipInfo = IP::getIPInfo($ip);
  45. $ipInfoMap[$ip] = $ipInfo ? ($ipInfo['address'] ?? null) : null;
  46. }
  47. }
  48. // 将 IP 信息附加到日志记录中
  49. $subscribeLogs->getCollection()->transform(function ($log) use ($ipInfoMap) {
  50. $log->ipInfo = $log->request_ip ? ($ipInfoMap[$log->request_ip] ?? null) : null;
  51. return $log;
  52. });
  53. return view('admin.subscribe.log', ['subscribeLog' => $subscribeLogs, 'subscribe' => $userSubscribe]);
  54. }
  55. public function setSubscribeStatus(UserSubscribe $userSubscribe): JsonResponse
  56. {
  57. $data = $userSubscribe->status
  58. ? ['status' => 0, 'ban_time' => strtotime(sysConfig('ban_duration').' minutes'), 'ban_desc' => 'Your subscription has been disabled by the administrator, please contact the administrator to restore it']
  59. : ['status' => 1, 'ban_time' => null, 'ban_desc' => null];
  60. $ret = $userSubscribe->update($data)
  61. ? ['status' => 'success', 'message' => trans('common.success_item', ['attribute' => trans('common.update')])]
  62. : ['status' => 'fail', 'message' => trans('common.failed_item', ['attribute' => trans('common.update')])];
  63. return response()->json($ret);
  64. }
  65. }