SubscribeController.php 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Http\Models\Device;
  5. use App\Http\Models\SsGroup;
  6. use App\Http\Models\SsNode;
  7. use App\Http\Models\User;
  8. use App\Http\Models\UserLabel;
  9. use App\Http\Models\UserSubscribe;
  10. use App\Http\Models\UserSubscribeLog;
  11. use Illuminate\Http\Request;
  12. use Redirect;
  13. use Response;
  14. /**
  15. * 订阅控制器
  16. *
  17. * Class SubscribeController
  18. *
  19. * @package App\Http\Controllers
  20. */
  21. class SubscribeController extends Controller
  22. {
  23. protected static $systemConfig;
  24. function __construct()
  25. {
  26. self::$systemConfig = Helpers::systemConfig();
  27. }
  28. // 订阅码列表
  29. public function subscribeList(Request $request)
  30. {
  31. $user_id = $request->input('user_id');
  32. $username = $request->input('username');
  33. $status = $request->input('status');
  34. $query = UserSubscribe::with(['user:id,username']);
  35. if(isset($user_id)){
  36. $query->where('user_id', $user_id);
  37. }
  38. if(isset($username)){
  39. $query->whereHas('user', function($q) use ($username){
  40. $q->where('username', 'like', '%'.$username.'%');
  41. });
  42. }
  43. if(isset($status)){
  44. $query->where('status', $status);
  45. }
  46. $view['subscribeList'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
  47. return Response::view('subscribe.subscribeList', $view);
  48. }
  49. //订阅记录
  50. public function subscribeLog(Request $request)
  51. {
  52. $id = $request->input('id');
  53. $query = UserSubscribeLog::with('user:username');
  54. if(isset($id)){
  55. $query->where('sid', $id);
  56. }
  57. $view['subscribeLog'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
  58. return Response::view('subscribe.subscribeLog', $view);
  59. }
  60. // 订阅设备列表
  61. public function deviceList(Request $request)
  62. {
  63. $type = $request->input('type');
  64. $platform = $request->input('platform');
  65. $name = $request->input('name');
  66. $status = $request->input('status');
  67. $query = Device::query();
  68. if(isset($type)){
  69. $query->where('type', $type);
  70. }
  71. if(isset($platform)){
  72. $query->where('platform', $platform);
  73. }
  74. if(isset($name)){
  75. $query->where('name', 'like', '%'.$name.'%');
  76. }
  77. if(isset($status)){
  78. $query->where('status', $status);
  79. }
  80. $view['deviceList'] = $query->paginate(20)->appends($request->except('page'));
  81. return Response::view('subscribe.deviceList', $view);
  82. }
  83. // 设置用户的订阅的状态
  84. public function setSubscribeStatus(Request $request)
  85. {
  86. $id = $request->input('id');
  87. $status = $request->input('status', 0);
  88. if(empty($id)){
  89. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']);
  90. }
  91. if($status){
  92. UserSubscribe::query()->where('id', $id)->update(['status' => 1, 'ban_time' => 0, 'ban_desc' => '']);
  93. }else{
  94. UserSubscribe::query()->where('id', $id)->update(['status' => 0, 'ban_time' => time(), 'ban_desc' => '后台手动封禁']);
  95. }
  96. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  97. }
  98. // 设置设备是否允许订阅的状态
  99. public function setDeviceStatus(Request $request)
  100. {
  101. $id = $request->input('id');
  102. $status = $request->input('status', 0);
  103. if(empty($id)){
  104. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']);
  105. }
  106. Device::query()->where('id', $id)->update(['status' => $status]);
  107. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  108. }
  109. // 通过订阅码获取订阅信息
  110. public function getSubscribeByCode(Request $request, $code)
  111. {
  112. if(empty($code)){
  113. return Redirect::to('login');
  114. }
  115. // 校验合法性
  116. $subscribe = UserSubscribe::query()->with('user')->where('status', 1)->where('code', $code)->first();
  117. if(!$subscribe){
  118. exit($this->noneNode());
  119. }
  120. $user = User::query()->whereIn('status', [0, 1])->where('enable', 1)->where('id', $subscribe->user_id)->first();
  121. if(!$user){
  122. exit($this->noneNode());
  123. }
  124. // 更新访问次数
  125. $subscribe->increment('times', 1);
  126. // 记录每次请求
  127. $this->log($subscribe->id, getClientIp(), $request->headers);
  128. // 获取这个账号可用节点
  129. $userLabelIds = UserLabel::query()->where('user_id', $user->id)->pluck('label_id');
  130. if(empty($userLabelIds)){
  131. exit($this->noneNode());
  132. }
  133. $query = SsNode::query()->selectRaw('ss_node.*')->leftjoin("ss_node_label", "ss_node.id", "=", "ss_node_label.node_id");
  134. // 启用混合订阅时,加入V2Ray节点,未启用时仅下发SSR节点信息
  135. if(!self::$systemConfig['mix_subscribe']){
  136. $query->where('ss_node.type', 1);
  137. }
  138. $nodeList = $query->where('ss_node.status', 1)->where('ss_node.is_subscribe', 1)->whereIn('ss_node_label.label_id', $userLabelIds)->groupBy('ss_node.id')->orderBy('ss_node.sort', 'desc')->orderBy('ss_node.id', 'asc')->get()->toArray();
  139. if(empty($nodeList)){
  140. exit($this->noneNode());
  141. }
  142. // 打乱数组
  143. if(self::$systemConfig['rand_subscribe']){
  144. shuffle($nodeList);
  145. }
  146. $scheme = '';
  147. // 展示到期时间和剩余流量
  148. if(self::$systemConfig['is_custom_subscribe']){
  149. $scheme .= $this->expireDate($user).$this->lastTraffic($user);
  150. }
  151. // 控制客户端最多获取节点数
  152. foreach($nodeList as $key => $node){
  153. // 控制显示的节点数
  154. if(self::$systemConfig['subscribe_max'] && $key >= self::$systemConfig['subscribe_max']){
  155. break;
  156. }
  157. // 获取分组名称
  158. $host = $node['server']? : $node['ip'];
  159. if($node['type'] == 1){
  160. $group = SsGroup::query()->where('id', $node['group_id'])->first();
  161. $group = empty($group)? Helpers::systemConfig()['website_name'] : $group->name;
  162. $obfs_param = $user->obfs_param? : $node['obfs_param'];
  163. if($node['single']){
  164. $port = $node['port'];
  165. $protocol = $node['protocol'];
  166. $method = $node['method'];
  167. $obfs = $node['obfs'];
  168. $passwd = $node['passwd'];
  169. $protocol_param = $user->port.':'.$user->passwd;
  170. }else{
  171. $port = $user->port;
  172. $protocol = $user->protocol;
  173. $method = $user->method;
  174. $obfs = $user->obfs;
  175. $passwd = $user->passwd;
  176. $protocol_param = $user->protocol_param;
  177. }
  178. // 生成ssr scheme
  179. $scheme .= 'ssr://'.base64url_encode($host.':'.$port.':'.$protocol.':'.$method.':'.$obfs.':'.base64url_encode($passwd).'/?obfsparam='.base64url_encode($obfs_param).'&protoparam='.base64url_encode($protocol_param).'&remarks='.base64url_encode($node['name']).'&group='.base64url_encode($group).'&udpport=0&uot=0')."\n";
  180. }else{
  181. // 生成v2ray scheme
  182. $v2_json = [
  183. "v" => "2",
  184. "ps" => $node['name'],
  185. "add" => $host,
  186. "port" => $node['v2_port'],
  187. "id" => $user->vmess_id,
  188. "aid" => $node['v2_alter_id'],
  189. "net" => $node['v2_net'],
  190. "type" => $node['v2_type'],
  191. "host" => $node['v2_host'],
  192. "path" => $node['v2_path'],
  193. "tls" => $node['v2_tls']? "tls" : ""
  194. ];
  195. $scheme .= 'vmess://'.base64url_encode(json_encode($v2_json, JSON_PRETTY_PRINT))."\n";
  196. }
  197. }
  198. // 适配Quantumult的自定义订阅头
  199. if(self::$systemConfig['is_custom_subscribe']){
  200. $headers = [
  201. 'Content-type' => 'application/octet-stream; charset=utf-8',
  202. 'Cache-Control' => 'no-store, no-cache, must-revalidate',
  203. 'Subscription-Userinfo' => 'upload='.$user->u.'; download='.$user->d.'; total='.$user->transfer_enable.'; expire='.strtotime($user->expire_time)
  204. ];
  205. return Response::make(base64url_encode($scheme), 200, $headers);
  206. }else{
  207. return Response::make(base64url_encode($scheme));
  208. }
  209. }
  210. // 写入订阅访问日志
  211. private function log($subscribeId, $ip, $headers)
  212. {
  213. $log = new UserSubscribeLog();
  214. $log->sid = $subscribeId;
  215. $log->request_ip = $ip;
  216. $log->request_time = date('Y-m-d H:i:s');
  217. $log->request_header = $headers;
  218. $log->save();
  219. }
  220. // 抛出无可用的节点信息,用于兼容防止客户端订阅失败
  221. private function noneNode()
  222. {
  223. return base64url_encode('ssr://'.base64url_encode('0.0.0.0:1:origin:none:plain:'.base64url_encode('0000').'/?obfsparam=&protoparam=&remarks='.base64url_encode('无可用节点或账号被封禁或订阅被封禁').'&group='.base64url_encode('错误').'&udpport=0&uot=0')."\n");
  224. }
  225. /**
  226. * 过期时间
  227. *
  228. * @param object $user
  229. *
  230. * @return string
  231. */
  232. private function expireDate($user)
  233. {
  234. $text = '到期时间: '.$user->expire_time;
  235. return 'ssr://'.base64url_encode('0.0.0.1:1:origin:none:plain:'.base64url_encode('0000').'/?obfsparam=&protoparam=&remarks='.base64url_encode($text).'&group='.base64url_encode(Helpers::systemConfig()['website_name']).'&udpport=0&uot=0')."\n";
  236. }
  237. /**
  238. * 剩余流量
  239. *
  240. * @param object $user
  241. *
  242. * @return string
  243. */
  244. private function lastTraffic($user)
  245. {
  246. $text = '剩余流量: '.flowAutoShow($user->transfer_enable-$user->u-$user->d);
  247. return 'ssr://'.base64url_encode('0.0.0.2:1:origin:none:plain:'.base64url_encode('0000').'/?obfsparam=&protoparam=&remarks='.base64url_encode($text).'&group='.base64url_encode(Helpers::systemConfig()['website_name']).'&udpport=0&uot=0')."\n";
  248. }
  249. }