123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359 |
- <?php
- namespace App\Http\Controllers\Admin;
- use App\Components\Helpers;
- use App\Components\IP;
- use App\Http\Controllers\Controller;
- use App\Http\Requests\Admin\UserStoreRequest;
- use App\Http\Requests\Admin\UserUpdateRequest;
- use App\Models\Level;
- use App\Models\Node;
- use App\Models\Order;
- use App\Models\User;
- use App\Models\UserGroup;
- use App\Models\UserHourlyDataFlow;
- use Arr;
- use Auth;
- use Exception;
- use Illuminate\Http\JsonResponse;
- use Illuminate\Http\Request;
- use Log;
- use Response;
- use Session;
- use Spatie\Permission\Models\Role;
- use Str;
- class UserController extends Controller
- {
- // 用户列表
- public function index(Request $request)
- {
- $id = $request->input('id');
- $email = $request->input('email');
- $wechat = $request->input('wechat');
- $qq = $request->input('qq');
- $port = $request->input('port');
- $group = $request->input('group');
- $level = $request->input('level');
- $status = $request->input('status');
- $enable = $request->input('enable');
- $online = $request->input('online');
- $flowAbnormal = $request->input('flowAbnormal');
- $expireWarning = $request->input('expireWarning');
- $largeTraffic = $request->input('largeTraffic');
- $query = User::with('subscribe');
- if (isset($id)) {
- $query->whereId($id);
- }
- if (isset($email)) {
- $query->where('email', 'like', '%'.$email.'%');
- }
- if (isset($wechat)) {
- $query->where('wechat', 'like', '%'.$wechat.'%');
- }
- if (isset($qq)) {
- $query->where('qq', 'like', '%'.$qq.'%');
- }
- if (isset($port)) {
- $query->wherePort($port);
- }
- if (isset($status)) {
- $query->whereStatus($status);
- }
- if (isset($enable)) {
- $query->whereEnable($enable);
- }
- if (isset($group)) {
- $query->whereUserGroupId($group);
- }
- if (isset($level)) {
- $query->whereLevel($level);
- }
- // 流量超过100G的
- if ($largeTraffic) {
- $query->whereIn('status', [0, 1])->whereRaw('(u + d)/transfer_enable >= 0.9');
- }
- // 临近过期提醒
- if ($expireWarning) {
- $query->whereBetween('expired_at', [date('Y-m-d H:i:s'), date('Y-m-d H:i:s', strtotime('+'.sysConfig('expire_days').' days'))]);
- }
- // 当前在线
- if ($online) {
- $query->where('t', '>=', strtotime('-10 minutes'));
- }
- // 不活跃用户
- if ($request->has('unActive')) {
- $query->whereBetween('t', [1, strtotime('-'.sysConfig('expire_days').' days')])->whereEnable(1);
- }
- // 不活跃用户
- if ($request->has('paying')) {
- $payingUser = Order::whereStatus(2)->where('goods_id', '<>', 0)->whereIsExpire(0)->where('amount', '>', 0)->pluck('user_id')->unique();
- $query->whereIn('id', $payingUser);
- }
- // 1小时内流量异常用户
- if ($flowAbnormal) {
- $query->whereIn('id', (new UserHourlyDataFlow)->trafficAbnormal());
- }
- return view('admin.user.index', [
- 'userList' => $query->orderByDesc('id')->paginate(15)->appends($request->except('page')),
- 'userGroups' => UserGroup::all()->pluck('name', 'id')->toArray(),
- 'levels' => Level::all()->pluck('name', 'level')->toArray(),
- ]);
- }
- // 添加账号页面
- public function create()
- {
- if (Auth::getUser()->hasRole('Super Admin')) { // 超级管理员直接获取全部角色
- $roles = Role::all()->pluck('description', 'name');
- } elseif (Auth::getUser()->can('give roles')) { // 有权者只能获得已有角色,防止权限泛滥
- $roles = Auth::getUser()->roles()->pluck('description', 'name');
- }
- return view('admin.user.info', [
- 'levels' => Level::orderBy('level')->get(),
- 'userGroups' => UserGroup::orderBy('id')->get(),
- 'roles' => $roles ?? null,
- ]);
- }
- // 添加账号
- public function store(UserStoreRequest $request): JsonResponse
- {
- $data = $request->validated();
- Arr::forget($data, 'roles');
- $data['password'] = $data['password'] ?? Str::random();
- $data['port'] = $data['port'] ?? Helpers::getPort();
- $data['passwd'] = $data['passwd'] ?? Str::random();
- $data['vmess_id'] = $data['uuid'] ?? Str::uuid();
- Arr::forget($data, 'uuid');
- $data['transfer_enable'] *= GB;
- $data['expired_at'] = $data['expired_at'] ?? date('Y-m-d H:i:s', strtotime('+365 days'));
- $data['remark'] = str_replace(['atob', 'eval'], '', $data['remark']);
- $data['reg_ip'] = IP::getClientIp();
- $data['reset_time'] = $data['reset_time'] > date('Y-m-d H:i:s') ? $data['reset_time'] : null;
- $user = User::create($data);
- $roles = $request->input('roles');
- try {
- if ($roles && (Auth::getUser()->can('give roles') || (in_array('Super Admin', $roles, true) && Auth::getUser()->hasRole('Super Admin')))) {
- // 编辑用户权限
- // 只有超级管理员才有赋予超级管理的权限
- $user->assignRole($roles);
- }
- if ($user) {
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($user->id, null, 0, $data['transfer_enable'], '后台手动添加用户');
- return Response::json(['status' => 'success', 'message' => '添加成功']);
- }
- } catch (Exception $e) {
- Log::error('添加用户错误:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'message' => $e->getMessage()]);
- }
- return Response::json(['status' => 'fail', 'message' => '添加失败']);
- }
- // 编辑账号页面
- public function edit(User $user)
- {
- if (Auth::getUser()->hasRole('Super Admin')) { // 超级管理员直接获取全部角色
- $roles = Role::all()->pluck('description', 'name');
- } elseif (Auth::getUser()->can('give roles')) { // 有权者只能获得已有角色,防止权限泛滥
- $roles = Auth::getUser()->roles()->pluck('description', 'name');
- }
- return view('admin.user.info', [
- 'user' => $user->load('inviter:id,email'),
- 'levels' => Level::orderBy('level')->get(),
- 'userGroups' => UserGroup::orderBy('id')->get(),
- 'roles' => $roles ?? null,
- ]);
- }
- // 编辑账号
- public function update(UserUpdateRequest $request, User $user)
- {
- $data = $request->validated();
- $data['passwd'] = $request->input('passwd') ?? Str::random();
- $data['vmess_id'] = $data['uuid'] ?? Str::uuid();
- Arr::forget($data, ['roles', 'uuid', 'password']);
- $data['transfer_enable'] *= GB;
- $data['enable'] = $data['status'] < 0 ? 0 : $data['enable'];
- $data['expired_at'] = $data['expired_at'] ?? date('Y-m-d H:i:s', strtotime('+365 days'));
- $data['remark'] = str_replace(['atob', 'eval'], '', $data['remark']);
- $data['reset_time'] = $data['reset_time'] > date('Y-m-d H:i:s') ? $data['reset_time'] : null;
- // 只有超级管理员才能赋予超级管理员
- $roles = $request->input('roles');
- try {
- if ($roles && (Auth::getUser()->can('give roles') || (in_array('Super Admin', $roles, true)
- && Auth::getUser()->hasRole('Super Admin')) || Auth::getUser()->hasRole('Super Admin'))) {
- $user->syncRoles($roles);
- }
- // Input checking for dummy
- if ($data['enable'] === '1') {
- if ($data['status'] === '-1' || $data['transfer_enable'] === 0 ) {
- $data['enable'] = 0;
- }
- }
- // 非演示环境才可以修改管理员密码
- $password = $request->input('password');
- if (! empty($password) && ! (env('APP_DEMO') && $user->id === 1)) {
- $data['password'] = $password;
- }
- // 写入用户流量变动记录
- if ($user->transfer_enable !== $data['transfer_enable']) {
- Helpers::addUserTrafficModifyLog($user->id, null, $user->transfer_enable, $data['transfer_enable'], '后台手动编辑用户');
- }
- if ($user->update($data)) {
- return Response::json(['status' => 'success', 'message' => '编辑成功']);
- }
- } catch (Exception $e) {
- Log::error('编辑用户信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'message' => '编辑用户信息错误:'.$e->getMessage()]);
- }
- return Response::json(['status' => 'fail', 'message' => '编辑失败']);
- }
- // 删除用户
- public function destroy(User $user)
- {
- if ($user->id === 1) {
- return Response::json(['status' => 'fail', 'message' => '系统管理员不可删除']);
- }
- try {
- if ($user->delete()) {
- return Response::json(['status' => 'success', 'message' => '删除成功']);
- }
- } catch (Exception $e) {
- Log::error('删除用户信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'message' => '删除失败'.$e->getMessage()]);
- }
- return Response::json(['status' => 'fail', 'message' => '删除失败']);
- }
- // 批量生成账号
- public function batchAddUsers()
- {
- try {
- for ($i = 0; $i < (int) request('amount', 1); $i++) {
- $user = Helpers::addUser(Str::random(8).'b'.$i.'@auto.generate', 123456, 204800 * MB , 30);
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($user->id, null, 0, 1024 * GB, '后台批量生成用户');
- }
- return Response::json(['status' => 'success', 'message' => '批量生成账号成功']);
- } catch (Exception $e) {
- return Response::json(['status' => 'fail', 'message' => '批量生成账号失败:'.$e->getMessage()]);
- }
- }
- // 转换成某个用户的身份
- public function switchToUser(User $user): JsonResponse
- {
- // 存储当前管理员ID,并将当前登录信息改成要切换的用户的身份信息
- Session::put('admin', Auth::id());
- Session::put('user', $user->id);
- return Response::json(['status' => 'success', 'message' => '身份切换成功']);
- }
- // 重置用户流量
- public function resetTraffic(User $user): JsonResponse
- {
- try {
- $user->update(['u' => 0, 'd' => 0]);
- } catch (Exception $e) {
- Log::error('流量重置失败:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'message' => '流量重置失败']);
- }
- return Response::json(['status' => 'success', 'message' => '流量重置成功']);
- }
- // 操作用户余额
- public function handleUserCredit(Request $request, User $user): JsonResponse
- {
- $amount = (int) $request->input('amount');
- if (empty($amount)) {
- return Response::json(['status' => 'fail', 'message' => '充值异常']);
- }
- // 加减余额
- if ($user->updateCredit($amount)) {
- Helpers::addUserCreditLog($user->id, null, $user->credit, $user->credit + $amount, $amount, '后台手动充值'); // 写入余额变动日志
- return Response::json(['status' => 'success', 'message' => '充值成功']);
- }
- return Response::json(['status' => 'fail', 'message' => '充值失败']);
- }
- // 导出配置信息
- public function export(User $user)
- {
- return view('admin.user.export', [
- 'user' => $user,
- 'nodeList' => Node::whereStatus(1)->orderByDesc('sort')->orderBy('id')->paginate(15)->appends(\request('page')),
- ]);
- }
- public function exportProxyConfig(Request $request, User $user): JsonResponse
- {
- $server = Node::findOrFail($request->input('id'))->config($user); // 提取节点信息
- return Response::json(['status' => 'success', 'data' => $this->getUserNodeInfo($server, $request->input('type') !== 'text'), 'title' => $server['type']]);
- }
-
-
- public function UserDis(Request $request){
- $id = $request->input('id');
- // 从请求中获取需要更新的数据
- $data = [
- 'enable' => 0,
- 'expired_at' => '2020-05-01 15:35:19',
- 'remark' => '已经退款'
- ];
- // 使用Eloquent ORM查找对应的用户记录
- $user = User::find($id);
- // 使用update()方法更新用户记录
- return $user->update($data);
- }
- }
|