v2board/app/Http/Controllers/Admin/UserController.php

210 lines
8.1 KiB
PHP
Raw Normal View History

2019-10-29 15:33:36 +08:00
<?php
namespace App\Http\Controllers\Admin;
2020-10-08 12:13:47 +08:00
use App\Http\Requests\Admin\UserFetch;
use App\Http\Requests\Admin\UserGenerate;
2019-10-29 15:33:36 +08:00
use App\Http\Requests\Admin\UserUpdate;
2020-10-08 12:13:47 +08:00
use App\Utils\Helper;
2019-10-29 15:33:36 +08:00
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use App\Models\Order;
use App\Models\User;
2019-11-04 02:02:55 +08:00
use App\Models\Plan;
2020-10-08 12:13:47 +08:00
use Illuminate\Support\Facades\DB;
2019-10-29 15:33:36 +08:00
class UserController extends Controller
{
2020-10-08 12:13:47 +08:00
private function filter(Request $request, $builder)
{
if ($request->input('filter')) {
$request->validate([
'filter' => 'array',
'filter.*.key' => 'required|in:email,transfer_enable,d,expired_at,uuid,token',
'filter.*.condition' => 'required|in:>,<,=,>=,<=',
'filter.*.value' => 'required'
]);
foreach ($request->input('filter') as $filter) {
if ($filter['key'] === 'email' && $filter['condition'] === '=') {
$builder->where($filter['key'], 'like', '%' . $filter['value'] . '%');
continue;
}
if ($filter['key'] === 'd' || $filter['key'] === 'transfer_enable') {
$filter['value'] = $filter['value'] * 1073741824;
}
$builder->where($filter['key'], $filter['condition'], $filter['value']);
}
}
}
public function fetch(UserFetch $request)
2020-01-11 13:36:52 +08:00
{
2019-10-29 15:33:36 +08:00
$current = $request->input('current') ? $request->input('current') : 1;
$pageSize = $request->input('pageSize') >= 10 ? $request->input('pageSize') : 10;
2020-02-09 18:53:45 +08:00
$sortType = in_array($request->input('sort_type'), ['ASC', 'DESC']) ? $request->input('sort_type') : 'DESC';
$sort = $request->input('sort') ? $request->input('sort') : 'created_at';
$userModel = User::orderBy($sort, $sortType);
2020-10-08 12:13:47 +08:00
$this->filter($request, $userModel);
2019-10-29 15:33:36 +08:00
$total = $userModel->count();
2019-11-04 02:02:55 +08:00
$res = $userModel->forPage($current, $pageSize)
->get();
$plan = Plan::get();
for ($i = 0; $i < count($res); $i++) {
for ($k = 0; $k < count($plan); $k++) {
if ($plan[$k]['id'] == $res[$i]['plan_id']) {
$res[$i]['plan_name'] = $plan[$k]['name'];
}
}
}
2019-10-29 15:33:36 +08:00
return response([
2019-11-04 02:02:55 +08:00
'data' => $res,
2019-10-29 15:33:36 +08:00
'total' => $total
]);
}
2020-01-29 16:49:32 +08:00
public function getUserInfoById(Request $request)
2020-01-11 13:36:52 +08:00
{
2020-01-29 16:49:32 +08:00
if (empty($request->input('id'))) {
2019-12-16 13:59:15 +08:00
abort(500, '参数错误');
}
return response([
2020-05-25 17:20:48 +08:00
'data' => User::find($request->input('id'))
2019-12-16 13:59:15 +08:00
]);
}
2020-01-11 13:36:52 +08:00
public function update(UserUpdate $request)
{
2020-07-15 15:57:12 +08:00
$params = $request->validated();
2019-10-29 15:33:36 +08:00
$user = User::find($request->input('id'));
if (!$user) {
abort(500, '用户不存在');
}
2020-02-28 16:38:44 +08:00
if (User::where('email', $params['email'])->first() && $user->email !== $params['email']) {
2019-10-29 15:33:36 +08:00
abort(500, '邮箱已被使用');
}
2020-02-28 16:38:44 +08:00
if (isset($params['password'])) {
$params['password'] = password_hash($params['password'], PASSWORD_DEFAULT);
2020-05-23 23:21:49 +08:00
$params['password_algo'] = NULL;
2019-10-29 15:33:36 +08:00
} else {
2020-02-28 16:38:44 +08:00
unset($params['password']);
2019-10-29 15:33:36 +08:00
}
2020-02-28 16:38:44 +08:00
if (isset($params['plan_id'])) {
$plan = Plan::find($params['plan_id']);
2019-11-27 19:55:53 +08:00
if (!$plan) {
abort(500, '订阅计划不存在');
}
2020-02-28 16:38:44 +08:00
$params['group_id'] = $plan->group_id;
2019-11-27 19:55:53 +08:00
}
2020-03-17 14:28:47 +08:00
try {
$user->update($params);
} catch (\Exception $e) {
2019-10-29 15:33:36 +08:00
abort(500, '保存失败');
}
return response([
'data' => true
]);
}
2020-10-08 12:13:47 +08:00
2020-10-08 22:35:07 +08:00
public function dumpCSV(Request $request)
2020-10-08 12:13:47 +08:00
{
2020-10-08 22:42:26 +08:00
$userModel = User::orderBy('id', 'asc');
2020-10-08 12:13:47 +08:00
$this->filter($request, $userModel);
$res = $userModel->get();
$plan = Plan::get();
for ($i = 0; $i < count($res); $i++) {
for ($k = 0; $k < count($plan); $k++) {
if ($plan[$k]['id'] == $res[$i]['plan_id']) {
$res[$i]['plan_name'] = $plan[$k]['name'];
}
}
}
2020-10-08 22:35:07 +08:00
$data = "邮箱,余额,推广佣金,总流量,剩余流量,套餐到期时间,订阅计划,订阅地址\r\n";
$baseUrl = config('v2board.subscribe_url', config('v2board.app_url', env('APP_URL')));
foreach($res as $user) {
$expireDate = $user['expired_at'] === NULL ? '长期有效' : $user['expired_at'];
$balance = $user['balance'] / 100;
$commissionBalance = $user['commission_balance'] / 100;
$transferEnable = $user['transfer_enable'] ? $user['transfer_enable'] / 1073741824 : 0;
$notUseFlow = (($user['transfer_enable'] - ($user['u'] + $user['d'])) / 1073741824) ?? 0;
$planName = $user['plan_name'] ?? '无订阅';
$subscribeUrl = $baseUrl . '/api/v1/client/subscribe?token=' . $user['token'];
$data .= "{$user['email']},{$balance},{$commissionBalance},{$transferEnable},{$notUseFlow},{$expireDate},{$planName},{$subscribeUrl}\r\n";
}
echo $data;
2020-10-08 12:13:47 +08:00
}
public function generate(UserGenerate $request)
{
if ($request->input('email_prefix')) {
if ($request->input('plan_id')) {
$plan = Plan::find($request->input('plan_id'));
if (!$plan) {
abort(500, '订阅计划不存在');
}
}
$user = [
'email' => $request->input('email_prefix') . '@' . $request->input('email_suffix'),
'plan_id' => isset($plan->id) ? $plan->id : NULL,
'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
'expired_at' => $request->input('expired_at') ?? NULL,
'uuid' => Helper::guid(true),
'token' => Helper::guid()
];
$user['password'] = password_hash($request->input('password') ?? $user['email'], PASSWORD_DEFAULT);
if (!User::create($user)) {
abort(500, '生成失败');
}
return response([
'data' => true
]);
}
if ($request->input('count')) {
$this->multiGenerate($request);
}
}
private function multiGenerate(Request $request)
{
if ($request->input('plan_id')) {
$plan = Plan::find($request->input('plan_id'));
if (!$plan) {
abort(500, '订阅计划不存在');
}
}
$users = [];
for ($i = 0;$i < $request->input('count');$i++) {
$user = [
'email' => Helper::randomChar(6) . '@' . $request->input('email_suffix'),
'plan_id' => isset($plan->id) ? $plan->id : NULL,
'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
'expired_at' => $request->input('expired_at') ?? NULL,
'uuid' => Helper::guid(true),
'token' => Helper::guid(),
'created_at' => time(),
'updated_at' => time()
];
$user['password'] = password_hash($request->input('password') ?? $user['email'], PASSWORD_DEFAULT);
array_push($users, $user);
}
DB::beginTransaction();
if (!User::insert($users)) {
DB::rollBack();
abort(500, '生成失败');
}
DB::commit();
$data = "账号,密码,过期时间,UUID,创建时间\r\n";
foreach($users as $user) {
$expireDate = $user['expired_at'] === NULL ? '长期有效' : $user['expired_at'];
$createDate = date('Y-m-d H:i:s', $user['created_at']);
$password = $request->input('password') ?? $user['email'];
$data .= "{$user['email']},{$password},{$expireDate},{$user['uuid']},{$createDate}\r\n";
}
echo $data;
}
2019-10-29 15:33:36 +08:00
}