V1Controller.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352
  1. <?php
  2. namespace App\Http\Controllers\Api\Client;
  3. use App\Components\Helpers;
  4. use App\Components\IP;
  5. use App\Http\Controllers\Controller;
  6. use App\Models\AppUpdate;
  7. use App\Models\Goods;
  8. use App\Models\Node;
  9. use App\Models\Order;
  10. use App\Models\User;
  11. use Auth;
  12. use Illuminate\Http\Request;
  13. use Redirect;
  14. use Validator;
  15. use Str;
  16. use function Matrix\diagonal;
  17. class V1Controller extends Controller
  18. {
  19. public function __construct()
  20. {
  21. $this->middleware('auth.jwt', ['except' => ['login', 'register', 'shop','version','versionwin','buy','test','updateNodelPass']]);
  22. auth()->shouldUse('api');
  23. }
  24. public function test(Request $request){
  25. $query = User::activeUser()->where('expired_at', '<', date('Y-m-d H:i:s', strtotime('-2 hour')))->toSql();
  26. return response()->json(['ret' => 1, 'data' => $query,'datatime' => date('Y-m-d H:i:s', strtotime('-2 hour'))], 200);
  27. }
  28. public function version(Request $request){
  29. $version = AppUpdate::where('appname','=','android')->first();
  30. return response()->json(['ret' => 1, 'data' => $version], 200);
  31. }
  32. public function versionwin(Request $request){
  33. $version = AppUpdate::where('appname','=','win')->first();
  34. return response()->json(['ret' => 1, 'data' => $version], 200);
  35. }
  36. public function login(Request $request)
  37. {
  38. $validator = Validator::make($request->all(), [
  39. 'email' => 'required|email',
  40. 'password' => 'required|string|min:6',
  41. ]);
  42. if ($validator->fails()) {
  43. return response()->json(['ret' => 0, 'msg' => "账号密码错误(账号是邮箱)"], 200);
  44. }
  45. if ($token = auth()->attempt($validator->validated())) {
  46. return $this->createNewToken($token);
  47. }
  48. return response()->json(['ret' => 0, 'msg' => '账号密码错误'], 200);
  49. }
  50. protected function createNewToken($token)
  51. {
  52. $userinfo = auth()->user()->profile();
  53. return response()->json([
  54. 'ret' => 1,
  55. 'data' => [
  56. 'access_token' => $token,
  57. 'token_type' => 'bearer',
  58. 'expires_in' => auth()->factory()->getTTL() * 60,
  59. 'user' => $userinfo,
  60. 'affurl' => route('register', ['aff' => Auth::id()]),
  61. 'tutorial' => 'https://ruanjian.xiazi.buzz/',
  62. 'swoftdownload' => 'https://ruanjian.xiazi.buzz/',
  63. ]
  64. ]);
  65. }
  66. public function register(Request $request)
  67. {
  68. $validator = Validator::make($request->all(), [
  69. 'username' => 'required|string|between:2,100',
  70. 'email' => 'required|string|email|max:100|unique:user',
  71. 'password' => 'required|string|min:6',
  72. ]);
  73. if ($validator->fails()) {
  74. return response()->json(['ret' => 0, 'msg' => implode("", $validator->errors()->all())]);
  75. }
  76. if (!sysConfig('is_register')) {
  77. return response()->json(['ret' => 0, 'msg' => "暂停注册,升级服务器"]);
  78. }
  79. $transfer_enable = MB * ((int) sysConfig('default_traffic'));
  80. // 创建新用户
  81. $user = Helpers::addUser($request->email, $request->password, $transfer_enable, sysConfig('default_days'), null, $request->username);
  82. // 注册失败,抛出异常
  83. if (!$user) {
  84. return response()->json(['ret' => 0, 'msg' => "错误"]);
  85. }
  86. if ($token = auth()->attempt($validator->validated())) {
  87. return $this->createNewToken($token);
  88. }
  89. return response()->json(['ret' => 0, 'msg' => "错误"]);
  90. }
  91. public function logout()
  92. {
  93. auth()->logout();
  94. return response()->json(['ret' => 0,'data'=>'ok']);
  95. }
  96. public function authUser(){
  97. $user = auth()->user();
  98. $userinfo = $user->profile();
  99. if (empty($userinfo)){
  100. return response()->json(['ret' => 0, 'msg' => "错误"]);
  101. }
  102. //判断到期
  103. $expireTime = $user["expired_at"];
  104. if ($expireTime < date('Y-m-d H:i:s')){
  105. return response()->json(['ret' => 445, 'msg' => "用户到期,请即使续费"], 200);
  106. }
  107. $usedTraffic = $user->usedTraffic();
  108. if ($usedTraffic >= $userinfo["transfer_enable"]){
  109. return response()->json(['ret' => 446, 'msg' => "流量已经用完,联系客服免费重置流量"], 200);
  110. }
  111. //获取节点
  112. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  113. $nodeList = $query->where(function ($q){
  114. $q->where('type','=',0)->orwhere('type','=',4);
  115. })->orderByDesc('sort')->orderBy('id')->get();
  116. $firstnode = [];
  117. $is_hk = false;
  118. $temp = array();
  119. $result = array();
  120. foreach ($nodeList as $node) {
  121. // 在线人数
  122. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  123. $node->online_users = $online_log->online_user ?? 0;
  124. if ($node->country_code == "hk" && $node->online_users != 0){
  125. $firstnode[] = $node;
  126. $is_hk = true;
  127. } else {
  128. if (!$is_hk){
  129. $firstnode[] = $node;
  130. }
  131. }
  132. }
  133. //找到人数最小的
  134. $min["key"] = "";
  135. $min["value"] = 0;
  136. $keys = "online_users";
  137. $midormax = $this->phpMaxMin($firstnode,$keys);
  138. // foreach ($firstnode as $key => $val){
  139. // if($min['key'] === ''){
  140. // $min['key'] = $key;
  141. // $min['value'] = $val[$keys];
  142. // //$temp[$key] = $val[$keys];
  143. // }
  144. // if($min['value'] > $val[$keys]){
  145. // $result[$key] = $val;
  146. // $min['key'] = $key;
  147. // $min['value'] = $val[$keys];
  148. // }
  149. // }
  150. // if (empty($result) ){
  151. // return response()->json(['ret' => 0, 'msg' => "数据为空"], 201);
  152. // }
  153. foreach ($firstnode as $key => $v ){
  154. if($key == $midormax["min"]["key"])
  155. {
  156. $servers = $v->config($user);
  157. $servers[$keys] = $firstnode[$key][$keys];
  158. }
  159. }
  160. return response()->json(['ret' => 1, 'data' => $servers], 200);
  161. }
  162. function getMinAndMaxInArray($arr,$keys = '') {
  163. if(empty($arr)) {
  164. return array(10,10);
  165. }
  166. $disArr = array();
  167. foreach($arr as $value) {
  168. $disArr[] = floatval($value[$keys]);
  169. }
  170. sort($disArr);
  171. $resArr = !empty($disArr) ? array($disArr[0],$disArr[count($disArr)-1]) : array(10,10);
  172. unset($disArr);
  173. return $resArr;
  174. }
  175. public function phpMaxMin($arr = [],$keys = ''){
  176. $max['key'] = '';
  177. $max['value'] = '';
  178. $min['key'] = '';
  179. $min['value'] = '';
  180. foreach ($arr as $key => $val){
  181. if($max['key'] === ''){
  182. $max['key'] = $key;
  183. $max['value'] = $val[$keys];
  184. }
  185. if((int)$max['value'] < $val[$keys]){
  186. $max['key'] = $key;
  187. $max['value'] = $val[$keys];
  188. }
  189. if($min['key'] === ''){
  190. $min['key'] = $key;
  191. $min['value'] = $val[$keys];
  192. }
  193. if((int)$min['value'] > $val[$keys]){
  194. $min['key'] = $key;
  195. $min['value'] = $val[$keys];
  196. }
  197. }
  198. $array['max'] = $max;
  199. $array['min'] = $min;
  200. return $array;
  201. }
  202. public function refresh()
  203. {
  204. return $this->createNewToken(auth()->refresh());
  205. }
  206. public function userProfile()
  207. {
  208. return response()->json(['ret' => 1, 'data' => auth()->user()->profile()]);
  209. }
  210. public function iosprofile(Request $request){
  211. $zfversion = $request->input("zfversion");
  212. $version = "1.0.6"; //比客户端大才能返回正确大数据
  213. $data = auth()->user()->profile();
  214. if(version_compare($zfversion,$version,"<")){
  215. $data["zfshow"] = 1;
  216. } else {
  217. $data["zfshow"] = 0;
  218. }
  219. return response()->json(['ret' => 1, 'data' => $data]);
  220. }
  221. public function updateNodelPass(){
  222. //$nodelist = Node::where('single','=',1)->where('ip','=','192.248.167.49')->get();
  223. $nodelist = Node::where('single','=',1)->update([
  224. "passwd" => Str::random()
  225. ]);
  226. //Vc6ykqt49zUD39R2
  227. return response()->json(['ret' => 1, 'data' => $nodelist]);
  228. }
  229. public function nodeList(int $id = null)
  230. {
  231. $user = auth()->user();
  232. // $nodes = $user->nodes()->get();
  233. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  234. $nodeList = $query->where(function ($q){
  235. $q->where('type','=',0)->orwhere('type','=',4)->orwhere('vless','=',0);
  236. })->orderByDesc('sort')->orderBy('id')->get();
  237. //$nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  238. //var_dump($nodes); die();
  239. if (isset($id)) {
  240. $nodes = $user->nodes()->get();
  241. $node = $nodes->find($id);
  242. if (empty($node)) {
  243. return response()->json([], 204);
  244. }
  245. return response()->json($node->config($user));
  246. }
  247. $temp = array();
  248. $servers = [];
  249. $firstnode = [];
  250. foreach ($nodeList as $node) {
  251. // 在线人数
  252. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  253. $node->online_users = $online_log->online_user ?? 0;
  254. $firstnode[] = $node;
  255. }
  256. foreach ($firstnode as $key => $val){
  257. $servers[] = $val->config($user);
  258. $servers[$key]["online_users"] = $firstnode[$key]["online_users"];
  259. }
  260. return response()->json(['ret' => 1, 'data' => $servers]);
  261. }
  262. public function buy(Request $request){
  263. return Redirect::route('login');
  264. }
  265. public function shop()
  266. {
  267. $shop = Goods::whereStatus(1)->where('type', '<=', '2')->orderByDesc('type')->orderByDesc('sort')->get();
  268. return response()->json($shop);
  269. }
  270. }