V1Controller.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350
  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. $transfer_enable = MB * ((int) sysConfig('default_traffic'));
  77. // 创建新用户
  78. $user = Helpers::addUser($request->email, $request->password, $transfer_enable, sysConfig('default_days'), null, $request->username);
  79. // 注册失败,抛出异常
  80. if (!$user) {
  81. return response()->json(['ret' => 0, 'msg' => "错误"]);
  82. }
  83. if ($token = auth()->attempt($validator->validated())) {
  84. return $this->createNewToken($token);
  85. }
  86. return response()->json(['ret' => 0, 'msg' => "错误"]);
  87. }
  88. public function logout()
  89. {
  90. auth()->logout();
  91. return response()->json(['ret' => 0,'data'=>'ok']);
  92. }
  93. public function authUser(){
  94. $user = auth()->user();
  95. $userinfo = $user->profile();
  96. if (empty($userinfo)){
  97. return response()->json(['ret' => 0, 'msg' => "错误"]);
  98. }
  99. //判断到期
  100. $expireTime = $user["expired_at"];
  101. if ($expireTime < date('Y-m-d H:i:s')){
  102. return response()->json(['ret' => 445, 'msg' => "用户到期,请即使续费"], 200);
  103. }
  104. $usedTraffic = $user->usedTraffic();
  105. if ($usedTraffic >= $userinfo["transfer_enable"]){
  106. return response()->json(['ret' => 446, 'msg' => "流量已经用完,联系客服免费重置流量"], 200);
  107. }
  108. //获取节点
  109. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  110. $nodeList = $query->where(function ($q){
  111. $q->where('type','=',0)->orwhere('type','=',4);
  112. })->orderByDesc('sort')->orderBy('id')->get();
  113. $firstnode = [];
  114. $is_hk = false;
  115. $temp = array();
  116. $result = array();
  117. foreach ($nodeList as $node) {
  118. // 在线人数
  119. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  120. $node->online_users = $online_log->online_user ?? 0;
  121. if ($node->country_code == "hk" && $node->online_users != 0){
  122. $firstnode[] = $node;
  123. $is_hk = true;
  124. } else {
  125. if (!$is_hk){
  126. $firstnode[] = $node;
  127. }
  128. }
  129. }
  130. //找到人数最小的
  131. $min["key"] = "";
  132. $min["value"] = 0;
  133. $keys = "online_users";
  134. $midormax = $this->phpMaxMin($firstnode,$keys);
  135. // foreach ($firstnode as $key => $val){
  136. // if($min['key'] === ''){
  137. // $min['key'] = $key;
  138. // $min['value'] = $val[$keys];
  139. // //$temp[$key] = $val[$keys];
  140. // }
  141. // if($min['value'] > $val[$keys]){
  142. // $result[$key] = $val;
  143. // $min['key'] = $key;
  144. // $min['value'] = $val[$keys];
  145. // }
  146. // }
  147. // if (empty($result) ){
  148. // return response()->json(['ret' => 0, 'msg' => "数据为空"], 201);
  149. // }
  150. foreach ($firstnode as $key => $v ){
  151. if($key == $midormax["min"]["key"])
  152. {
  153. $servers = $v->config($user);
  154. $servers[$keys] = $firstnode[$key][$keys];
  155. }
  156. }
  157. return response()->json(['ret' => 1, 'data' => $servers], 200);
  158. }
  159. function getMinAndMaxInArray($arr,$keys = '') {
  160. if(empty($arr)) {
  161. return array(10,10);
  162. }
  163. $disArr = array();
  164. foreach($arr as $value) {
  165. $disArr[] = floatval($value[$keys]);
  166. }
  167. sort($disArr);
  168. $resArr = !empty($disArr) ? array($disArr[0],$disArr[count($disArr)-1]) : array(10,10);
  169. unset($disArr);
  170. return $resArr;
  171. }
  172. public function phpMaxMin($arr = [],$keys = ''){
  173. $max['key'] = '';
  174. $max['value'] = '';
  175. $min['key'] = '';
  176. $min['value'] = '';
  177. foreach ($arr as $key => $val){
  178. if($max['key'] === ''){
  179. $max['key'] = $key;
  180. $max['value'] = $val[$keys];
  181. }
  182. if((int)$max['value'] < $val[$keys]){
  183. $max['key'] = $key;
  184. $max['value'] = $val[$keys];
  185. }
  186. if($min['key'] === ''){
  187. $min['key'] = $key;
  188. $min['value'] = $val[$keys];
  189. }
  190. if((int)$min['value'] > $val[$keys]){
  191. $min['key'] = $key;
  192. $min['value'] = $val[$keys];
  193. }
  194. }
  195. $array['max'] = $max;
  196. $array['min'] = $min;
  197. return $array;
  198. }
  199. public function refresh()
  200. {
  201. return $this->createNewToken(auth()->refresh());
  202. }
  203. public function userProfile()
  204. {
  205. return response()->json(['ret' => 1, 'data' => auth()->user()->profile()]);
  206. }
  207. public function iosprofile(Request $request){
  208. $zfversion = $request->input("zfversion");
  209. $version = "1.0.6"; //比客户端大才能返回正确大数据
  210. $data = auth()->user()->profile();
  211. if(version_compare($zfversion,$version,"<")){
  212. $data["zfshow"] = 1;
  213. } else {
  214. $data["zfshow"] = 0;
  215. }
  216. return response()->json(['ret' => 1, 'data' => $data]);
  217. }
  218. public function updateNodelPass(){
  219. //$nodelist = Node::where('single','=',1)->where('ip','=','192.248.167.49')->get();
  220. $nodelist = Node::where('single','=',1)->update([
  221. "passwd" => Str::random()
  222. ]);
  223. //Vc6ykqt49zUD39R2
  224. return response()->json(['ret' => 1, 'data' => $nodelist]);
  225. }
  226. public function nodeList(int $id = null)
  227. {
  228. $user = auth()->user();
  229. // $nodes = $user->nodes()->get();
  230. $query = $user->nodes()->with(['labels', 'level_table','onlineLogs']);
  231. $nodeList = $query->where(function ($q){
  232. $q->where('type','=',0)->orwhere('type','=',4);
  233. })->orderByDesc('sort')->orderBy('id')->get();
  234. //$nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  235. //var_dump($nodes); die();
  236. if (isset($id)) {
  237. $nodes = $user->nodes()->get();
  238. $node = $nodes->find($id);
  239. if (empty($node)) {
  240. return response()->json([], 204);
  241. }
  242. return response()->json($node->config($user));
  243. }
  244. $temp = array();
  245. $servers = [];
  246. $firstnode = [];
  247. foreach ($nodeList as $node) {
  248. // 在线人数
  249. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  250. $node->online_users = $online_log->online_user ?? 0;
  251. $firstnode[] = $node;
  252. }
  253. foreach ($firstnode as $key => $val){
  254. $servers[] = $val->config($user);
  255. $servers[$key]["online_users"] = $firstnode[$key]["online_users"];
  256. }
  257. return response()->json(['ret' => 1, 'data' => $servers]);
  258. }
  259. public function buy(Request $request){
  260. return Redirect::route('login');
  261. }
  262. public function shop()
  263. {
  264. $shop = Goods::whereStatus(1)->where('type', '<=', '2')->orderByDesc('type')->orderByDesc('sort')->get();
  265. return response()->json($shop);
  266. }
  267. }