V3Controller.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445
  1. <?php
  2. namespace App\Http\Controllers\Api\Client;
  3. use App\Http\Controllers\ClientController;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\AppUpdate;
  6. use App\Models\Node;
  7. use App\Models\User;
  8. use App\Models\UserSubscribe;
  9. use Arr;
  10. use Auth;
  11. use Helpers;
  12. use Illuminate\Http\Request;
  13. use Session;
  14. use Illuminate\Support\Facades\Redis;
  15. use App\Models\Sms;
  16. use Validator;
  17. use Hash;
  18. use App\Models\NodeOnlineLog;
  19. use DB;
  20. class V3Controller extends Controller
  21. {
  22. public function __construct()
  23. {
  24. $this->middleware('auth:api')->except('login','Ping','refreshByUser', 'register', 'shop', 'getConfig','version','buy','ClashConfig','getsysconfig');
  25. auth()->shouldUse('api');
  26. }
  27. public function Ping()
  28. {
  29. return response()->json(['ret' => 1], 200);
  30. }
  31. //生成配置
  32. public function ClashConfig(Request $request){
  33. $code = $request->input('code');
  34. // 检查订阅码是否有效
  35. $subscribe = UserSubscribe::whereCode($code)->first();
  36. if (! $subscribe) {
  37. return response()->json(['ret' => 0, 'msg' => trans('error.subscribe.unknown')], 200);
  38. }
  39. if ($subscribe->status !== 1) {
  40. return response()->json(['ret' => 0, 'msg' => trans('error.subscribe.sub_baned')], 200);
  41. }
  42. // 检查用户是否有效
  43. $user = $subscribe->user;
  44. if (!$user) {
  45. return response()->json(['ret' => 0, 'msg' => trans('error.subscribe.user')], 200);
  46. }
  47. if ($user->status === -1) {
  48. return response()->json(['ret' => 0, 'msg' => trans('error.subscribe.user_disable')], 200);
  49. }
  50. // 获取这个账号可用节点
  51. $query = $user->nodes()->whereIsSubscribe(1);
  52. // if ($this->subType === 1) {
  53. // $query = $query->whereIn('type', [1, 4]);
  54. // } elseif ($this->subType) {
  55. // $query = $query->whereType($this->subType);
  56. // }
  57. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  58. if (empty($nodeList)) {
  59. return $this->failed(trans('error.subscribe.none'));
  60. }
  61. $servers = [];
  62. foreach ($nodeList as $node) {
  63. $servers[] = $node->config($user);
  64. }
  65. $servers = Arr::shuffle($servers);
  66. return (new ClientController)->config("clash", $user, $servers);
  67. }
  68. //登陆
  69. public function login(Request $request)
  70. {
  71. $validator = Validator::make($request->all(), [
  72. 'email' => 'required|email',
  73. 'password' => 'required|string|min:6',
  74. ]);
  75. if ($validator->fails()) {
  76. return response()->json(['ret' => 0, 'msg' => $validator->errors()->all()], 200);
  77. }
  78. if ($token = auth()->attempt($validator->validated())) {
  79. return $this->createNewToken($request,$token);
  80. }
  81. return response()->json(['ret' => 0, 'msg' => "账号或密码错误"], 200);
  82. }
  83. protected function createNewToken($request,$token)
  84. {
  85. $user = auth()->user();
  86. //判断到期
  87. $expireTime = $user["expired_at"];
  88. // if ($expireTime < date('Y-m-d H:i:s')){
  89. // return response()->json(['ret' => 445, 'msg' => "用户到期,请即使续费"], 200);
  90. // }
  91. // $usedTraffic = $user->usedTraffic();
  92. // if ($usedTraffic >= $user["transfer_enable"]){
  93. // return response()->json(['ret' => 446, 'msg' => "流量已经用完,"], 200);
  94. // }
  95. $userinfo = $user->profile();
  96. if (empty($userinfo)){
  97. return response()->json(['ret' => 0, 'msg' => "错误"]);
  98. }
  99. $data = [
  100. 'access_token' => $token,
  101. 'user' => $userinfo,
  102. 'tutorial' => 'https://ruanjian.xiazi.buzz/',
  103. 'swoftdownload' => 'https://app.xiazai3.xyz/',
  104. 'affurl' => 'https://user.viptwo.xyz/logintoreferral?email='.$request->input('email') . '&password='.$request->input('password'),
  105. 'user_login_url' => 'https://user.viptwo.xyz/logina?email='.$request->input('email') . '&password='.$request->input('password'),
  106. 'user_buy' => 'https://user.viptwo.xyz/logina?email='.$request->input('email') . '&password='.$request->input('password'),
  107. 'user_ticket' => 'https://user.viptwo.xyz/logintoticket?email='.$request->input('email') . '&password='.$request->input('password'),
  108. 'clash_config' => route('SProxy_config', ['code'=>$userinfo['code']]),
  109. 'subUrl' => sysConfig('subscribe_domain') . "/s/" . $userinfo['code'],
  110. 'subUrl2' => "https://naizi1124.xn--3iq226gfdb94q.com" . "/s/" . $userinfo['code'],
  111. ];
  112. return response()->json(['ret' => 1, 'msg' => "请求成功",'data'=>$data], 200);
  113. }
  114. //正在获取系统配置
  115. public function getsysconfig(Request $request){
  116. //$url = "user.viptwo.xyz";
  117. $url = "zf.payviptwo.top";
  118. $tag = $request->input('email');
  119. if (!isset($tag)){
  120. $data = [
  121. 'affurl' => 'https://user.vip666999.xyz/logintoreferral', //推广
  122. 'user_login_url' => 'https://'.$url.'/logina', //购买 和登陆
  123. 'user_login_url_ke' => 'https://'.$url.'/logina', //购买和登陆
  124. 'user_buy' => 'https://'.$url.'/logina', //
  125. 'user_ticket' => 'https://'.$url.'/logintoticket',
  126. 'user_reg' => 'https://'.$url.'/register',
  127. 'user_reset' => 'https://'.$url.'/reset',
  128. 'user_tutorial' => 'https://app.xiazai8.xyz/', //在线客服
  129. 'user_rofile' => 'https://'.$url.'/Loginprofile',
  130. 'user_download' => 'https://app.xiazai8.xyz/',
  131. 'tag' => 0,
  132. ];
  133. return response()->json(['ret' => 1, 'msg' => "请求成功",'data'=>$data], 200);
  134. }
  135. else {
  136. $data = [
  137. 'affurl' => 'https://user.vip666999.xyz/logintoreferral?email='.$request->input('email') . '&password='.$request->input('password'),
  138. 'affurl_ke' => 'https://user.vip666999.xyz/logintoreferral',
  139. 'user_login_url' => 'https://'.$url.'/logina?email='.$request->input('email') . '&password='.$request->input('password'),
  140. 'user_login_url_ke' => 'https://'.$url.'/logina',
  141. 'user_buy' => 'https://'.$url.'/logina?email='.$request->input('email') . '&password='.$request->input('password'),
  142. 'user_ticket' => 'https://'.$url.'/logintoticket?email='.$request->input('email') . '&password='.$request->input('password'),
  143. 'user_ticket_ke' => 'https://'.$url.'/logintoticket',
  144. 'user_reg' => 'https://'.$url.'/register',
  145. 'user_reset' => 'https://'.$url.'/reset',
  146. 'user_tutorial' => 'https://app.xiazai8.xyz/',
  147. 'user_rofile' => 'https://'.$url.'/Loginprofile',
  148. 'user_download' => 'https://app.xiazai8.xyz/',
  149. 'tag' => 1,
  150. ];
  151. return response()->json(['ret' => 1, 'msg' => "请求成功",'data'=>$data], 200);
  152. }
  153. }
  154. //刷新token
  155. public function refresh()
  156. {
  157. $user = auth()->user();
  158. $userinfo = $user->profile();
  159. if (empty($userinfo)){
  160. return response()->json(['ret' => 0, 'msg' => "错误"]);
  161. }
  162. $data = [
  163. 'access_token' => auth()->refresh(),
  164. 'user' => $userinfo,
  165. 'affurl' => route('register', ['aff' => Auth::id()]),
  166. 'tutorial' => 'https://user.viptwo.xyz/',
  167. 'swoftdownload' => 'https://app.xiazai8.xyz/',
  168. 'clash_config' => route('SProxy_config', ['code'=>$userinfo['code']]),
  169. ];
  170. return response()->json(['ret' => 1, 'msg' => "请求成功",'data'=>$data], 200);
  171. }
  172. public function refreshByUser(Request $request)
  173. {
  174. $email = $request->input("email");
  175. $password = $request->input("password");
  176. $userinfo = User::where('email','=',$email)->first();
  177. if (empty($userinfo)){
  178. return response()->json(['ret' => 0, 'msg' => "错误"]);
  179. }
  180. $users = [
  181. 'email' => $email,
  182. 'password' =>$password
  183. ];
  184. $token = auth()->attempt($users);
  185. $data = [
  186. 'access_token' => $token,
  187. 'user' => $userinfo,
  188. 'affurl' => route('register', ['aff' => $userinfo["id"]]),
  189. 'tutorial' => 'https://user.viptwo.xyz/',
  190. 'swoftdownload' => 'https://app.xiazai3.xyz/',
  191. 'clash_config' => route('SProxy_config', ['code'=>$userinfo['code']]),
  192. ];
  193. return response()->json(['ret' => 1, 'msg' => "请求成功",'data'=>$data], 200);
  194. }
  195. public function version(Request $request){
  196. $tag = $request->input("tag");
  197. $appversion = $request->input("appverion");
  198. $version = AppUpdate::where('appname','=',$tag)->first();
  199. if (empty($version)){
  200. return response()->json(['ret' => 0, 'msg' => "获取版本失败"]);
  201. }
  202. if(version_compare($version["appversion"],$appversion,">")){
  203. $version["versionupdate"] = 1;
  204. return response()->json(['ret' => 1, 'data' => $version], 200);
  205. }
  206. return response()->json(['ret' => 0, 'msg' => "没有新版本"]);
  207. }
  208. //用户验证
  209. public function authUser(Request $request){
  210. $user = auth()->user();
  211. $userinfo = $user->profile();
  212. $is_debug = $request->input('debug');
  213. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  214. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  215. if ($is_debug == 1){
  216. //return $nodeList[0]["status"] == 1;
  217. $firstnode = [];
  218. foreach ($nodeList as $node) {
  219. // 在线人数
  220. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-1 minutes'))->latest('log_time')->first();
  221. $node->online_users = $online_log->online_user ?? 0;
  222. if (strpos($node->country_code,'hk') !== false && $node->status == 1){
  223. $firstnode[] = $node;
  224. }
  225. }
  226. if (empty($firstnode)) {
  227. // 查找其他国家的第一个
  228. foreach ($nodeList as $node) {
  229. // 在线人数
  230. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-1 minutes'))->latest('log_time')->first();
  231. $node->online_users = $online_log->online_user ?? 0;
  232. if ( $node->status == 1){
  233. $firstnode[] = $node;
  234. }
  235. }
  236. }
  237. //找到人数最小的
  238. $min["key"] = "";
  239. $min["value"] = 0;
  240. $keys = "online_users";
  241. $midormax = $this->phpMaxMin($firstnode,$keys);
  242. $servers = [];
  243. foreach ($firstnode as $key => $v ){
  244. if($key == $midormax["min"]["key"])
  245. {
  246. $servers = $v->config($user);
  247. $servers[$keys] = $firstnode[$key][$keys];
  248. }
  249. }
  250. return $servers;
  251. }
  252. if (empty($userinfo)){
  253. return response()->json(['ret' => 0, 'msg' => "错误"]);
  254. }
  255. //判断到期
  256. $expireTime = $user["expired_at"];
  257. if ($expireTime < date('Y-m-d H:i:s')){
  258. return response()->json(['ret' => 445, 'msg' => "用户到期,请续费"], 200);
  259. }
  260. $usedTraffic = $user->usedTraffic();
  261. if ($usedTraffic >= $userinfo["transfer_enable"]){
  262. return response()->json(['ret' => 446, 'msg' => "流量已经用完,请购买加油包"], 200);
  263. }
  264. if ($userinfo["enable"] == 0){
  265. return response()->json(['ret' => 446, 'msg' => "账号禁用,请等待5分钟后请刷新或者重启软件"], 200);
  266. }
  267. //获取节点
  268. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  269. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  270. $firstnode = [];
  271. foreach ($nodeList as $node) {
  272. // 在线人数
  273. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-1 minutes'))->latest('log_time')->first();
  274. $node->online_users = $online_log->online_user ?? 0;
  275. if (strpos($node->country_code,'hk') !== false && $node->status == 1){
  276. $firstnode[] = $node;
  277. }
  278. }
  279. if (empty($firstnode)) {
  280. // 查找其他国家的第一个
  281. foreach ($nodeList as $node) {
  282. // 在线人数
  283. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-1 minutes'))->latest('log_time')->first();
  284. $node->online_users = $online_log->online_user ?? 0;
  285. if ( $node->status == 1){
  286. $firstnode[] = $node;
  287. }
  288. }
  289. }
  290. //找到人数最小的
  291. $min["key"] = "";
  292. $min["value"] = 0;
  293. $keys = "online_users";
  294. $midormax = $this->phpMaxMin($firstnode,$keys);
  295. $servers = [];
  296. foreach ($firstnode as $key => $v ){
  297. if($key == $midormax["min"]["key"])
  298. {
  299. $servers = $v->config($user);
  300. $servers[$keys] = $firstnode[$key][$keys];
  301. }
  302. }
  303. return response()->json(['ret' => 1, 'data' => $servers], 200);
  304. }
  305. //获取节点
  306. public function nodeList(int $id = null)
  307. {
  308. $user = auth()->user();
  309. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  310. $nodeList = $query->where("type",'!=',2)->where("vless",'=',0)->orderByDesc('sort')->orderBy('id')->get();
  311. //var_dump($nodes); die();
  312. if (isset($id)) {
  313. $nodes = $user->nodes()->get();
  314. $node = $nodes->find($id);
  315. if (empty($node)) {
  316. return response()->json([], 204);
  317. }
  318. return response()->json($node->config($user));
  319. }
  320. $temp = array();
  321. $servers = [];
  322. $firstnode = [];
  323. foreach ($nodeList as $node) {
  324. // 在线人数
  325. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  326. $node->online_users = $online_log->online_user ?? 0;
  327. $firstnode[] = $node;
  328. }
  329. foreach ($firstnode as $key => $val){
  330. $servers[] = $val->config($user);
  331. $servers[$key]["ip"] = $firstnode[$key]["ip"];
  332. $servers[$key]["online_users"] = $firstnode[$key]["online_users"];
  333. $servers[$key]["country_code"] = $firstnode[$key]["country_code"];
  334. }
  335. return response()->json(['ret' => 1, 'data' => $servers]);
  336. }
  337. public function phpMaxMin($arr = [],$keys = ''){
  338. $max['key'] = '';
  339. $max['value'] = '';
  340. $min['key'] = '';
  341. $min['value'] = '';
  342. foreach ($arr as $key => $val){
  343. if($max['key'] === ''){
  344. $max['key'] = $key;
  345. $max['value'] = $val[$keys];
  346. }
  347. if((int)$max['value'] < $val[$keys]){
  348. $max['key'] = $key;
  349. $max['value'] = $val[$keys];
  350. }
  351. if($min['key'] === ''){
  352. $min['key'] = $key;
  353. $min['value'] = $val[$keys];
  354. }
  355. if((int)$min['value'] > $val[$keys]){
  356. $min['key'] = $key;
  357. $min['value'] = $val[$keys];
  358. }
  359. }
  360. $array['max'] = $max;
  361. $array['min'] = $min;
  362. return $array;
  363. }
  364. }