UserController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Components\Helpers;
  4. use App\Components\IP;
  5. use App\Http\Controllers\Controller;
  6. use App\Http\Requests\Admin\UserStoreRequest;
  7. use App\Http\Requests\Admin\UserUpdateRequest;
  8. use App\Models\Level;
  9. use App\Models\Node;
  10. use App\Models\User;
  11. use App\Models\UserGroup;
  12. use App\Models\UserHourlyDataFlow;
  13. use Auth;
  14. use DB;
  15. use Exception;
  16. use Illuminate\Http\JsonResponse;
  17. use Illuminate\Http\Request;
  18. use Log;
  19. use Redirect;
  20. use Response;
  21. use Session;
  22. use Str;
  23. class UserController extends Controller
  24. {
  25. // 用户列表
  26. public function index(Request $request)
  27. {
  28. $id = $request->input('id');
  29. $email = $request->input('email');
  30. $wechat = $request->input('wechat');
  31. $qq = $request->input('qq');
  32. $port = $request->input('port');
  33. $group = $request->input('group');
  34. $level = $request->input('level');
  35. $status = $request->input('status');
  36. $enable = $request->input('enable');
  37. $online = $request->input('online');
  38. $flowAbnormal = $request->input('flowAbnormal');
  39. $expireWarning = $request->input('expireWarning');
  40. $largeTraffic = $request->input('largeTraffic');
  41. $query = User::with('subscribe');
  42. if (isset($id)) {
  43. $query->whereId($id);
  44. }
  45. if (isset($email)) {
  46. $query->where('email', 'like', '%'.$email.'%');
  47. }
  48. if (isset($wechat)) {
  49. $query->where('wechat', 'like', '%'.$wechat.'%');
  50. }
  51. if (isset($qq)) {
  52. $query->where('qq', 'like', '%'.$qq.'%');
  53. }
  54. if (isset($port)) {
  55. $query->wherePort($port);
  56. }
  57. if (isset($status)) {
  58. $query->whereStatus($status);
  59. }
  60. if (isset($enable)) {
  61. $query->whereEnable($enable);
  62. }
  63. if (isset($group)) {
  64. $query->whereGroupId($group);
  65. }
  66. if (isset($level)) {
  67. $query->whereLevel($level);
  68. }
  69. // 流量超过100G的
  70. if ($largeTraffic) {
  71. $query->whereIn('status', [0, 1])->whereRaw('(u + d)/transfer_enable >= 0.9');
  72. }
  73. // 临近过期提醒
  74. if ($expireWarning) {
  75. $query->whereBetween('expired_at', [date('Y-m-d'), date('Y-m-d', strtotime('+'.sysConfig('expire_days').' days'))]);
  76. }
  77. // 当前在线
  78. if ($online) {
  79. $query->where('t', '>=', strtotime('-10 minutes'));
  80. }
  81. // 不活跃用户
  82. if ($request->input('unActive')) {
  83. $query->whereBetween('t', [1, strtotime('-'.sysConfig('expire_days').' days')])->whereEnable(1);
  84. }
  85. // 1小时内流量异常用户
  86. if ($flowAbnormal) {
  87. $query->whereIn('id', (new UserHourlyDataFlow)->trafficAbnormal());
  88. }
  89. return view('admin.user.index', [
  90. 'userList' => $query->orderByDesc('id')->paginate(15)->appends($request->except('page')),
  91. 'userGroups' => UserGroup::all()->pluck('name', 'id')->toArray(),
  92. 'levels' => Level::all()->pluck('name', 'level')->toArray(),
  93. ]);
  94. }
  95. // 添加账号页面
  96. public function create()
  97. {
  98. return view('admin.user.info', [
  99. 'levelList' => Level::orderBy('level')->get(),
  100. 'groupList' => UserGroup::orderBy('id')->get(),
  101. ]);
  102. }
  103. // 添加账号
  104. public function store(UserStoreRequest $request): JsonResponse
  105. {
  106. try {
  107. $data = $request->except('_token', 'uuid');
  108. $data['password'] = $data['password'] ?? Str::random();
  109. $data['port'] = $data['port'] ?? Helpers::getPort();
  110. $data['passwd'] = $data['passwd'] ?? Str::random();
  111. $data['vmess_id'] = $request->input('uuid') ?? Str::uuid();
  112. $data['expired_at'] = $data['expired_at'] ?? date('Y-m-d', strtotime('+365 days'));
  113. $data['remark'] = str_replace(['atob', 'eval'], '', $data['remark']);
  114. $data['reg_ip'] = IP::getClientIp();
  115. $data['reset_time'] = $data['reset_time'] > date('Y-m-d') ? $data['reset_time'] : null;
  116. $user = User::create($data);
  117. if ($user) {
  118. // 写入用户流量变动记录
  119. Helpers::addUserTrafficModifyLog($user->id, 0, 0, $data['transfer_enable'], '后台手动添加用户');
  120. return Response::json(['status' => 'success', 'message' => '添加成功']);
  121. }
  122. } catch (Exception $e) {
  123. Log::error('添加用户错误:'.$e->getMessage());
  124. return Response::json(['status' => 'fail', 'message' => $e->getMessage()]);
  125. }
  126. return Response::json(['status' => 'fail', 'message' => '添加失败']);
  127. }
  128. // 编辑账号页面
  129. public function edit($id)
  130. {
  131. $user = User::find($id);
  132. return view('admin.user.info', [
  133. 'user' => $user->load('inviter:id,email'),
  134. 'levelList' => Level::orderBy('level')->get(),
  135. 'groupList' => UserGroup::orderBy('id')->get(),
  136. ]);
  137. }
  138. // 编辑账号
  139. public function update(UserUpdateRequest $request, $id)
  140. {
  141. $user = User::find($id);
  142. try {
  143. $data = $request->except('_token', 'password', 'uuid', 'password', 'is_admin');
  144. $data['passwd'] = $request->input('passwd') ?? Str::random();
  145. $data['vmess_id'] = $request->input('uuid') ?? Str::uuid();
  146. $data['transfer_enable'] *= GB;
  147. $data['enable'] = $data['status'] < 0 ? 0 : $data['enable'];
  148. $data['expired_at'] = $data['expired_at'] ?? date('Y-m-d', strtotime('+365 days'));
  149. $data['remark'] = str_replace(['atob', 'eval'], '', $data['remark']);
  150. // Input checking for dummy
  151. if ($data['enable'] === '1') {
  152. if ($data['status'] === '-1' || $data['transfer_enable'] === 0 || $data['expired_at'] < date('Y-m-d')) {
  153. $data['enable'] = 0;
  154. }
  155. }
  156. // 只有admin才有权限操作管理员属性
  157. if (Auth::getUser()->is_admin === 1) {
  158. $data['is_admin'] = (int) $request->input('is_admin');
  159. }
  160. // 非演示环境才可以修改管理员密码
  161. $password = $request->input('password');
  162. if (! empty($password) && ! (env('APP_DEMO') && $id === 1)) {
  163. $data['password'] = $password;
  164. }
  165. // 写入用户流量变动记录
  166. if ($user->transfer_enable !== $data['transfer_enable']) {
  167. Helpers::addUserTrafficModifyLog($id, 0, $user->transfer_enable, $data['transfer_enable'], '后台手动编辑用户');
  168. }
  169. if ($user->update($data)) {
  170. return Response::json(['status' => 'success', 'message' => '编辑成功']);
  171. }
  172. } catch (Exception $e) {
  173. Log::error('编辑用户信息异常:'.$e->getMessage());
  174. return Response::json(['status' => 'fail', 'message' => '编辑用户信息错误:'.$e->getMessage()]);
  175. }
  176. return Response::json(['status' => 'fail', 'message' => '编辑失败']);
  177. }
  178. // 删除用户
  179. public function destroy($id)
  180. {
  181. if ($id <= 1) {
  182. return Response::json(['status' => 'fail', 'message' => '系统管理员不可删除']);
  183. }
  184. try {
  185. DB::beginTransaction();
  186. User::find($id)->delete();
  187. DB::commit();
  188. return Response::json(['status' => 'success', 'message' => '删除成功']);
  189. } catch (Exception $e) {
  190. Log::error('删除用户信息异常:'.$e->getMessage());
  191. DB::rollBack();
  192. return Response::json(['status' => 'fail', 'message' => '删除失败']);
  193. }
  194. }
  195. // 批量生成账号
  196. public function batchAddUsers(Request $request)
  197. {
  198. try {
  199. DB::beginTransaction();
  200. for ($i = 0; $i < $request->input('amount', 1); $i++) {
  201. $uid = Helpers::addUser(Str::random(8).'@auto.generate', Str::random(), 1024 * GB, 365);
  202. if ($uid) {
  203. // 写入用户流量变动记录
  204. Helpers::addUserTrafficModifyLog($uid, 0, 0, 1024 * GB, '后台批量生成用户');
  205. }
  206. }
  207. DB::commit();
  208. return Response::json(['status' => 'success', 'message' => '批量生成账号成功']);
  209. } catch (Exception $e) {
  210. DB::rollBack();
  211. return Response::json(['status' => 'fail', 'message' => '批量生成账号失败:'.$e->getMessage()]);
  212. }
  213. }
  214. // 转换成某个用户的身份
  215. public function switchToUser(Request $request): JsonResponse
  216. {
  217. $id = $request->input('user_id');
  218. $user = User::find($id);
  219. if (! $user) {
  220. return Response::json(['status' => 'fail', 'message' => '用户不存在']);
  221. }
  222. // 存储当前管理员ID,并将当前登录信息改成要切换的用户的身份信息
  223. Session::put('admin', Auth::id());
  224. Auth::login($user);
  225. return Response::json(['status' => 'success', 'message' => '身份切换成功']);
  226. }
  227. // 重置用户流量
  228. public function resetTraffic(Request $request): JsonResponse
  229. {
  230. try {
  231. User::find($request->input('id'))->update(['u' => 0, 'd' => 0]);
  232. } catch (Exception $e) {
  233. Log::error('流量重置失败:'.$e->getMessage());
  234. return Response::json(['status' => 'fail', 'message' => '流量重置失败']);
  235. }
  236. return Response::json(['status' => 'success', 'message' => '流量重置成功']);
  237. }
  238. // 操作用户余额
  239. public function handleUserCredit(Request $request): JsonResponse
  240. {
  241. $userId = $request->input('user_id');
  242. $amount = $request->input('amount');
  243. if (empty($userId) || empty($amount)) {
  244. return Response::json(['status' => 'fail', 'message' => '充值异常']);
  245. }
  246. $user = User::find($userId);
  247. // 加减余额
  248. if ($user->updateCredit($amount)) {
  249. Helpers::addUserCreditLog($userId, 0, $user->credit, $user->credit + $amount, $amount, '后台手动充值'); // 写入余额变动日志
  250. return Response::json(['status' => 'success', 'message' => '充值成功']);
  251. }
  252. return Response::json(['status' => 'fail', 'message' => '充值失败']);
  253. }
  254. // 导出配置信息
  255. public function export(Request $request, $id)
  256. {
  257. if (empty($id)) {
  258. return Redirect::back();
  259. }
  260. $user = User::find($id);
  261. if (empty($user)) {
  262. return Redirect::back();
  263. }
  264. $view['nodeList'] = Node::whereStatus(1)->orderByDesc('sort')->orderBy('id')->paginate(15)->appends($request->except('page'));
  265. $view['user'] = $user;
  266. return view('admin.user.export', $view);
  267. }
  268. public function exportProxyConfig(Request $request, $uid): JsonResponse
  269. {
  270. $node = Node::find($request->input('id'));
  271. if ($node->type === 1) {
  272. if ($node->compatible) {
  273. $proxyType = 'SS';
  274. } else {
  275. $proxyType = 'SSR';
  276. }
  277. } else {
  278. $proxyType = 'V2Ray';
  279. }
  280. $data = $this->getUserNodeInfo($uid, $node->id, $request->input('type') !== 'text' ? 0 : 1);
  281. return Response::json(['status' => 'success', 'data' => $data, 'title' => $proxyType]);
  282. }
  283. }