SubscribeController.php 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Components\IP;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\UserSubscribe;
  6. use App\Models\UserSubscribeLog;
  7. use Illuminate\Http\Request;
  8. use Response;
  9. /**
  10. * 订阅控制器.
  11. *
  12. * Class SubscribeController
  13. */
  14. class SubscribeController extends Controller
  15. {
  16. // 订阅码列表
  17. public function index(Request $request)
  18. {
  19. $user_id = $request->input('user_id');
  20. $email = $request->input('email');
  21. $status = $request->input('status');
  22. $times = $request->input('times');
  23. $starttime = $request->input('starttime');
  24. $endtime = $request->input('endtime');
  25. $query = UserSubscribe::with(['user:id,email']);
  26. if (isset($user_id)) {
  27. $query->whereUserId($user_id);
  28. }
  29. if (isset($email)) {
  30. $query->whereHas('user', static function ($q) use ($email) {
  31. $q->where('email', 'like', '%'.$email.'%');
  32. });
  33. }
  34. if (isset($times)){
  35. $query->where('times','>',$times);
  36. }
  37. if (isset($starttime) && isset($endtime))
  38. {
  39. $query->whereBetween('updated_at', [$starttime,$endtime]);
  40. }
  41. if (isset($status)) {
  42. $query->whereStatus($status);
  43. }
  44. return view('admin.subscribe.index', ['subscribeList' => $query->latest()->paginate(20)->appends($request->except('page'))]);
  45. }
  46. //订阅记录
  47. public function subscribeLog($id)
  48. {
  49. $query = UserSubscribeLog::with('user:email');
  50. if (isset($id)) {
  51. $query->whereUserSubscribeId($id);
  52. }
  53. $subscribeLogs = $query->latest()->paginate(20)->appends(\request('page'));
  54. foreach ($subscribeLogs as $log) {
  55. // 跳过上报多IP的
  56. if ($log->request_ip) {
  57. $log->ipInfo = implode(' ', IP::getIPInfo($log->request_ip));
  58. }
  59. }
  60. return view('admin.subscribe.log', ['subscribeLog' => $subscribeLogs]);
  61. }
  62. // 设置用户的订阅的状态
  63. public function setSubscribeStatus(UserSubscribe $subscribe)
  64. {
  65. if ($subscribe->status) {
  66. $subscribe->update(['status' => 0, 'ban_time' => time(), 'ban_desc' => '后台手动封禁']);
  67. } else {
  68. $subscribe->update(['status' => 1, 'ban_time' => null, 'ban_desc' => '']);
  69. }
  70. return Response::json(['status' => 'success', 'message' => '操作成功']);
  71. }
  72. }