UserController.php 12 KB

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