UserController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Requests\Admin\UserFetch;
  4. use App\Http\Requests\Admin\UserGenerate;
  5. use App\Http\Requests\Admin\UserSendMail;
  6. use App\Http\Requests\Admin\UserUpdate;
  7. use App\Jobs\SendEmailJob;
  8. use App\Services\UserService;
  9. use App\Utils\Helper;
  10. use Illuminate\Http\Request;
  11. use App\Http\Controllers\Controller;
  12. use App\Models\User;
  13. use App\Models\Plan;
  14. use Illuminate\Support\Facades\DB;
  15. class UserController extends Controller
  16. {
  17. public function resetSecret(Request $request)
  18. {
  19. $user = User::find($request->input('id'));
  20. if (!$user) abort(500, '用户不存在');
  21. $user->token = Helper::guid();
  22. $user->uuid = Helper::guid(true);
  23. return response([
  24. 'data' => $user->save()
  25. ]);
  26. }
  27. private function filter(Request $request, $builder)
  28. {
  29. $filters = $request->input('filter');
  30. if ($filters) {
  31. foreach ($filters as $k => $filter) {
  32. if ($filter['condition'] === '模糊') {
  33. $filter['condition'] = 'like';
  34. $filter['value'] = "%{$filter['value']}%";
  35. }
  36. if ($filter['key'] === 'd' || $filter['key'] === 'transfer_enable') {
  37. $filter['value'] = $filter['value'] * 1073741824;
  38. }
  39. if ($filter['key'] === 'invite_by_email') {
  40. $user = User::where('email', $filter['condition'], $filter['value'])->first();
  41. $inviteUserId = isset($user->id) ? $user->id : 0;
  42. $builder->where('invite_user_id', $inviteUserId);
  43. unset($filters[$k]);
  44. continue;
  45. }
  46. $builder->where($filter['key'], $filter['condition'], $filter['value']);
  47. }
  48. }
  49. }
  50. public function fetch(UserFetch $request)
  51. {
  52. $current = $request->input('current') ? $request->input('current') : 1;
  53. $pageSize = $request->input('pageSize') >= 10 ? $request->input('pageSize') : 10;
  54. $sortType = in_array($request->input('sort_type'), ['ASC', 'DESC']) ? $request->input('sort_type') : 'DESC';
  55. $sort = $request->input('sort') ? $request->input('sort') : 'created_at';
  56. $userModel = User::select(
  57. DB::raw('*'),
  58. DB::raw('(u+d) as total_used')
  59. )
  60. ->orderBy($sort, $sortType);
  61. $this->filter($request, $userModel);
  62. $total = $userModel->count();
  63. $res = $userModel->forPage($current, $pageSize)
  64. ->get();
  65. $plan = Plan::get();
  66. for ($i = 0; $i < count($res); $i++) {
  67. for ($k = 0; $k < count($plan); $k++) {
  68. if ($plan[$k]['id'] == $res[$i]['plan_id']) {
  69. $res[$i]['plan_name'] = $plan[$k]['name'];
  70. }
  71. }
  72. $res[$i]['subscribe_url'] = Helper::getSubscribeHost() . '/api/v1/client/subscribe?token=' . $res[$i]['token'];
  73. }
  74. return response([
  75. 'data' => $res,
  76. 'total' => $total
  77. ]);
  78. }
  79. public function getUserInfoById(Request $request)
  80. {
  81. if (empty($request->input('id'))) {
  82. abort(500, '参数错误');
  83. }
  84. $user = User::find($request->input('id'));
  85. if ($user->invite_user_id) {
  86. $user['invite_user'] = User::find($user->invite_user_id);
  87. }
  88. return response([
  89. 'data' => $user
  90. ]);
  91. }
  92. public function update(UserUpdate $request)
  93. {
  94. $params = $request->validated();
  95. $user = User::find($request->input('id'));
  96. if (!$user) {
  97. abort(500, '用户不存在');
  98. }
  99. if (User::where('email', $params['email'])->first() && $user->email !== $params['email']) {
  100. abort(500, '邮箱已被使用');
  101. }
  102. if (isset($params['password'])) {
  103. $params['password'] = password_hash($params['password'], PASSWORD_DEFAULT);
  104. $params['password_algo'] = NULL;
  105. } else {
  106. unset($params['password']);
  107. }
  108. if (isset($params['plan_id'])) {
  109. $plan = Plan::find($params['plan_id']);
  110. if (!$plan) {
  111. abort(500, '订阅计划不存在');
  112. }
  113. $params['group_id'] = $plan->group_id;
  114. }
  115. if ($request->input('invite_user_email')) {
  116. $inviteUser = User::where('email', $request->input('invite_user_email'))->first();
  117. if ($inviteUser) {
  118. $params['invite_user_id'] = $inviteUser->id;
  119. }
  120. } else {
  121. $params['invite_user_id'] = null;
  122. }
  123. try {
  124. $user->update($params);
  125. } catch (\Exception $e) {
  126. abort(500, '保存失败');
  127. }
  128. return response([
  129. 'data' => true
  130. ]);
  131. }
  132. public function dumpCSV(Request $request)
  133. {
  134. $userModel = User::orderBy('id', 'asc');
  135. $this->filter($request, $userModel);
  136. $res = $userModel->get();
  137. $plan = Plan::get();
  138. for ($i = 0; $i < count($res); $i++) {
  139. for ($k = 0; $k < count($plan); $k++) {
  140. if ($plan[$k]['id'] == $res[$i]['plan_id']) {
  141. $res[$i]['plan_name'] = $plan[$k]['name'];
  142. }
  143. }
  144. }
  145. $data = "邮箱,余额,推广佣金,总流量,剩余流量,套餐到期时间,订阅计划,订阅地址\r\n";
  146. $baseUrl = config('v2board.subscribe_url', config('v2board.app_url', env('APP_URL')));
  147. foreach($res as $user) {
  148. $expireDate = $user['expired_at'] === NULL ? '长期有效' : date('Y-m-d H:i:s', $user['expired_at']);
  149. $balance = $user['balance'] / 100;
  150. $commissionBalance = $user['commission_balance'] / 100;
  151. $transferEnable = $user['transfer_enable'] ? $user['transfer_enable'] / 1073741824 : 0;
  152. $notUseFlow = (($user['transfer_enable'] - ($user['u'] + $user['d'])) / 1073741824) ?? 0;
  153. $planName = $user['plan_name'] ?? '无订阅';
  154. $subscribeUrl = $baseUrl . '/api/v1/client/subscribe?token=' . $user['token'];
  155. $data .= "{$user['email']},{$balance},{$commissionBalance},{$transferEnable},{$notUseFlow},{$expireDate},{$planName},{$subscribeUrl}\r\n";
  156. }
  157. echo "\xEF\xBB\xBF" . $data;
  158. }
  159. public function generate(UserGenerate $request)
  160. {
  161. if ($request->input('email_prefix')) {
  162. if ($request->input('plan_id')) {
  163. $plan = Plan::find($request->input('plan_id'));
  164. if (!$plan) {
  165. abort(500, '订阅计划不存在');
  166. }
  167. }
  168. $user = [
  169. 'email' => $request->input('email_prefix') . '@' . $request->input('email_suffix'),
  170. 'plan_id' => isset($plan->id) ? $plan->id : NULL,
  171. 'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
  172. 'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
  173. 'expired_at' => $request->input('expired_at') ?? NULL,
  174. 'uuid' => Helper::guid(true),
  175. 'token' => Helper::guid()
  176. ];
  177. if (User::where('email', $user['email'])->first()) {
  178. abort(500, '邮箱已存在于系统中');
  179. }
  180. $user['password'] = password_hash($request->input('password') ?? $user['email'], PASSWORD_DEFAULT);
  181. if (!User::create($user)) {
  182. abort(500, '生成失败');
  183. }
  184. return response([
  185. 'data' => true
  186. ]);
  187. }
  188. if ($request->input('generate_count')) {
  189. $this->multiGenerate($request);
  190. }
  191. }
  192. private function multiGenerate(Request $request)
  193. {
  194. if ($request->input('plan_id')) {
  195. $plan = Plan::find($request->input('plan_id'));
  196. if (!$plan) {
  197. abort(500, '订阅计划不存在');
  198. }
  199. }
  200. $users = [];
  201. for ($i = 0;$i < $request->input('generate_count');$i++) {
  202. $user = [
  203. 'email' => Helper::randomChar(6) . '@' . $request->input('email_suffix'),
  204. 'plan_id' => isset($plan->id) ? $plan->id : NULL,
  205. 'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
  206. 'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
  207. 'expired_at' => $request->input('expired_at') ?? NULL,
  208. 'uuid' => Helper::guid(true),
  209. 'token' => Helper::guid(),
  210. 'created_at' => time(),
  211. 'updated_at' => time()
  212. ];
  213. $user['password'] = password_hash($request->input('password') ?? $user['email'], PASSWORD_DEFAULT);
  214. array_push($users, $user);
  215. }
  216. DB::beginTransaction();
  217. if (!User::insert($users)) {
  218. DB::rollBack();
  219. abort(500, '生成失败');
  220. }
  221. DB::commit();
  222. $data = "账号,密码,过期时间,UUID,创建时间,订阅地址\r\n";
  223. $baseUrl = config('v2board.subscribe_url', config('v2board.app_url', env('APP_URL')));
  224. foreach($users as $user) {
  225. $expireDate = $user['expired_at'] === NULL ? '长期有效' : date('Y-m-d H:i:s', $user['expired_at']);
  226. $createDate = date('Y-m-d H:i:s', $user['created_at']);
  227. $password = $request->input('password') ?? $user['email'];
  228. $subscribeUrl = $baseUrl . '/api/v1/client/subscribe?token=' . $user['token'];
  229. $data .= "{$user['email']},{$password},{$expireDate},{$user['uuid']},{$createDate},{$subscribeUrl}\r\n";
  230. }
  231. echo $data;
  232. }
  233. public function sendMail(UserSendMail $request)
  234. {
  235. $sortType = in_array($request->input('sort_type'), ['ASC', 'DESC']) ? $request->input('sort_type') : 'DESC';
  236. $sort = $request->input('sort') ? $request->input('sort') : 'created_at';
  237. $builder = User::orderBy($sort, $sortType);
  238. $this->filter($request, $builder);
  239. $users = $builder->get();
  240. foreach ($users as $user) {
  241. SendEmailJob::dispatch([
  242. 'email' => $user->email,
  243. 'subject' => $request->input('subject'),
  244. 'template_name' => 'notify',
  245. 'template_value' => [
  246. 'name' => config('v2board.app_name', 'V2Board'),
  247. 'url' => config('v2board.app_url'),
  248. 'content' => $request->input('content')
  249. ]
  250. ],
  251. 'send_email_mass');
  252. }
  253. return response([
  254. 'data' => true
  255. ]);
  256. }
  257. public function ban(Request $request)
  258. {
  259. $sortType = in_array($request->input('sort_type'), ['ASC', 'DESC']) ? $request->input('sort_type') : 'DESC';
  260. $sort = $request->input('sort') ? $request->input('sort') : 'created_at';
  261. $builder = User::orderBy($sort, $sortType);
  262. $this->filter($request, $builder);
  263. try {
  264. $builder->update([
  265. 'banned' => 1
  266. ]);
  267. } catch (\Exception $e) {
  268. abort(500, '处理失败');
  269. }
  270. return response([
  271. 'data' => true
  272. ]);
  273. }
  274. }