UserController.php 13 KB

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