LoginController.php 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Components\Helpers;
  4. use App\Http\Controllers\Controller;
  5. use App\Http\Models\User;
  6. use App\Http\Models\UserLabel;
  7. use App\Http\Models\UserSubscribe;
  8. use App\Http\Models\UserSubscribeLog;
  9. use Cache;
  10. use DB;
  11. use Hash;
  12. use Illuminate\Http\Request;
  13. use Response;
  14. /**
  15. * 登录接口
  16. *
  17. * Class LoginController
  18. *
  19. * @package App\Http\Controllers
  20. */
  21. class LoginController extends Controller
  22. {
  23. protected static $systemConfig;
  24. function __construct()
  25. {
  26. self::$systemConfig = Helpers::systemConfig();
  27. }
  28. // 登录返回订阅信息
  29. public function login(Request $request)
  30. {
  31. $username = trim($request->get('username'));
  32. $password = trim($request->get('password'));
  33. $cacheKey = 'request_times_' . md5(getClientIp());
  34. if (!$username || !$password) {
  35. Cache::increment($cacheKey);
  36. return Response::json(['status' => 'fail', 'data' => [], 'message' => '请输入用户名和密码']);
  37. }
  38. // 连续请求失败15次,则封IP一小时
  39. if (Cache::has($cacheKey)) {
  40. if (Cache::get($cacheKey) >= 15) {
  41. return Response::json(['status' => 'fail', 'data' => [], 'message' => '请求失败超限,禁止访问1小时']);
  42. }
  43. } else {
  44. Cache::put($cacheKey, 1, 60);
  45. }
  46. $user = User::query()->where('username', $username)->where('status', '>=', 0)->first();
  47. if (!$user) {
  48. Cache::increment($cacheKey);
  49. return Response::json(['status' => 'fail', 'data' => [], 'message' => '账号不存在或已被禁用']);
  50. } elseif (!Hash::check($password, $user->password)) {
  51. return Response::json(['status' => 'fail', 'data' => [], 'message' => '用户名或密码错误']);
  52. }
  53. DB::beginTransaction();
  54. try {
  55. // 如果未生成过订阅链接则生成一个
  56. $subscribe = UserSubscribe::query()->where('user_id', $user->id)->first();
  57. // 更新订阅链接访问次数
  58. $subscribe->increment('times', 1);
  59. // 记录每次请求
  60. $this->log($subscribe->id, getClientIp(), 'API访问');
  61. // 订阅链接
  62. $url = self::$systemConfig['subscribe_domain'] ? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url'];
  63. // 节点列表
  64. $userLabelIds = UserLabel::query()->where('user_id', $user->id)->pluck('label_id');
  65. if (empty($userLabelIds)) {
  66. return Response::json(['status' => 'fail', 'message' => '', 'data' => []]);
  67. }
  68. $nodeList = DB::table('ss_node')
  69. ->selectRaw('ss_node.*')
  70. ->leftJoin('ss_node_label', 'ss_node.id', '=', 'ss_node_label.node_id')
  71. ->whereIn('ss_node_label.label_id', $userLabelIds)
  72. ->where('ss_node.status', 1)
  73. ->groupBy('ss_node.id')
  74. ->orderBy('ss_node.sort', 'desc')
  75. ->orderBy('ss_node.id', 'asc')
  76. ->get();
  77. $c_nodes = collect();
  78. foreach ($nodeList as $node) {
  79. $temp_node = [
  80. 'name' => $node->name,
  81. 'server' => $node->server,
  82. 'server_port' => $user->port,
  83. 'method' => $user->method,
  84. 'obfs' => $user->obfs,
  85. 'flags' => $url . '/assets/images/country/' . $node->country_code . '.png',
  86. 'obfsparam' => '',
  87. 'password' => $user->passwd,
  88. 'group' => '',
  89. 'protocol' => $user->protocol,
  90. 'protoparam' => '',
  91. 'protocolparam' => ''
  92. ];
  93. $c_nodes = $c_nodes->push($temp_node);
  94. }
  95. $data = [
  96. 'status' => 1,
  97. 'class' => 0,
  98. 'level' => 2,
  99. 'expire_in' => $user->expire_time,
  100. 'text' => '',
  101. 'buy_link' => '',
  102. 'money' => '0.00',
  103. 'sspannelName' => 'ssrpanel',
  104. 'usedTraffic' => flowAutoShow($user->u + $user->d),
  105. 'Traffic' => flowAutoShow($user->transfer_enable),
  106. 'all' => 1,
  107. 'residue' => '',
  108. 'nodes' => $c_nodes,
  109. 'link' => $url . '/s/' . $subscribe->code
  110. ];
  111. DB::commit();
  112. return Response::json(['status' => 'success', 'data' => $data, 'message' => '登录成功']);
  113. } catch (\Exception $e) {
  114. DB::rollBack();
  115. return Response::json(['status' => 'success', 'data' => [], 'message' => '登录失败']);
  116. }
  117. }
  118. // 写入订阅访问日志
  119. private function log($subscribeId, $ip, $headers)
  120. {
  121. $log = new UserSubscribeLog();
  122. $log->sid = $subscribeId;
  123. $log->request_ip = $ip;
  124. $log->request_time = date('Y-m-d H:i:s');
  125. $log->request_header = $headers;
  126. $log->save();
  127. }
  128. }