bot-28/app/Http/Controllers/admin/User.php

<?php

namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Services\SecretService;
use App\Services\TopUpService;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\DB;
use App\Services\UserService;
use Exception;
use Illuminate\Validation\ValidationException;
use App\Services\AddressService;

use Illuminate\Http\JsonResponse;
use App\Models\User as UserModel;
use App\Models\UserSession;
use App\Models\UserLogin;
use Illuminate\Support\Facades\Cache;

class User extends Controller
{

    //修改用户密码/资金密码
    function setPassword()
    {
        try {
            $params = request()->validate([
                'member_id' => ['required', 'string', 'min:1'],
                'password' => ['nullable'],
                'payment_password' => ['nullable'],
            ]);
            $user = UserModel::where('member_id', $params['member_id'])->first();
            if (!$user) throw new Exception("用户不存在", HttpStatus::CUSTOM_ERROR);

            if (!empty($params['password'])) {
                $user->password = create_password($params['password']);
                $user->save();
                //删除缓存
                $token = UserSession::where('user_id', $params['member_id'])->orderByDesc('expire_time')->value('token');
                Cache::delete('token_user_' . $token);
                UserSession::where('user_id', $params['member_id'])->delete();
            }
            if (!empty($params['payment_password'])) {
                $user->payment_password = password_hash($params['payment_password'], PASSWORD_DEFAULT);
                $user->save();
            }
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    function banned()
    {
        try {
            $params = request()->validate([
                'member_id' => ['required', 'string', 'min:1'],
                'is_banned' => ['required', 'integer', 'in:0,1'],
            ]);
            UserModel::where('member_id', $params['member_id'])->update(['is_banned' => $params['is_banned']]);
            if ($params['is_banned'] == 1) {
                //如果用户被禁用，删除所有会话
                UserSession::where('user_id', $params['member_id'])->delete();
                return $this->success();
            }
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    function setNote()
    {
        try {
            $params = request()->validate([
                'member_id' => ['required', 'string', 'min:1'],
                'admin_note' => ['required', 'string', 'min:1', 'max:120'],
            ]);
            $user = UserModel::where('member_id', $params['member_id'])->first();
            if (!$user) throw new Exception("用户不存在", HttpStatus::CUSTOM_ERROR);
            $user->admin_note = $params['admin_note'];
            $user->save();
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    public function index(): JsonResponse
    {
        try {
            $search = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1'],
                'member_id' => ['nullable', 'string', 'min:1'],
                'like_first_name' => ['nullable', 'string', 'min:1'],
                'username' => ['nullable', 'string', 'min:1'],
                'register_ip' => ['nullable', 'string', 'min:1'],
                'order' => ["nullable", 'string', "in:asc,desc"],
                'by' => ['nullable', 'string', "in:available_balance,created_at,last_active_time"],
                'user_code' => ['nullable'],
                'agent_user_code' => ['nullable'],
                'level' => ['nullable'],
                'start_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:end_time'],
                'end_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:start_time'],
                'recharge_channel_group_id' => ['nullable'],
            ]);
            $order = request()->input('order', 'desc');
            $by = request()->input('by', 'available_balance');

            $result = UserService::paginate($search,$order,$by);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first().'ssss');
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success($result);
    }

    public function merge(): JsonResponse
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'member_id' => ['required', 'string', 'min:1'],
                'secret_key' => ['required', 'string', 'min:1'],
            ]);

            $res = SecretService::migration($params['member_id'], $params['secret_key']);
            if (!$res) {
                throw new Exception(lang("迁移失败"), HttpStatus::CUSTOM_ERROR);
            }
            $oldUser = UserModel::where('secret_key', $params['secret_key'])->first();
            $newUser = UserModel::where('member_id', $params['member_id'])->first();
            App::setLocale($oldUser->language);
            $text = lang('账户转移通知') . "：\n";
            $text .= lang('管理员已将您的账户转移至新用户') . "\n\n";
            $text .= lang('新用户信息') . "\n";
            $text .= lang('用户ID') . "：{$newUser->getMemberId()}\n";
            if ($newUser->getUsername()) {
                $text .= lang("用户名") . "：@{$newUser->getUsername()}\n";
            }
            $text .= lang('昵称') . "：{$newUser->getFirstName()}\n";
            TopUpService::notifyTransferSuccess($oldUser->getMemberId(), $text);
            App::setLocale($newUser->language);
            $text = lang("账户转移通知") . "：\n";
            $text .= lang("管理员已将指定账户转移至您的账户") . "\n\n";
            $text .= lang('原账户信息') . "\n\n";
            $text .= lang('用户ID') . "：{$oldUser->getMemberId()}\n";
            if ($oldUser->getUsername()) {
                $text .= lang('用户名') . "：@{$oldUser->getUsername()}\n";
            }
            $text .= lang('昵称') . "：{$oldUser->getFirstName()}\n";
            TopUpService::notifyTransferSuccess($newUser->getMemberId(), $text);
            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            if ($e->getCode() == HttpStatus::CUSTOM_ERROR) {
                return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
            }
            return $this->error(intval($e->getCode()));
        }
        return $this->success(msg: '已完成迁移');
    }


    public function address()
    {
        try {
            request()->validate([
                'member_id' => ['required', 'integer', 'min:1'],
            ]);
            $search = request()->all();
            $result = AddressService::findAll($search);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(intval($e->getCode()));
        }
        return $this->success($result);
    }

    /**
     * 用户登录日志
     */
    public function loginLog()
    {
        try {
            $params = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1'],
                'user_id' => ['nullable'],
                'member_id' => ['nullable'],
                'first_name' => ['nullable'],
                'start_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:end_time'],
                'end_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:start_time'],
            ]);
            $page = request()->input('page', 1);
            $limit = request()->input('limit', 15);

            $query = UserLogin::join('users', 'user_login.user_id', '=', 'users.user_id');
            if (!empty($params['user_id'])) {
                $query = $query->where('user_login.user_id', $params['user_id']);
            }
            if (!empty($params['member_id'])) {
                $query = $query->where('user_login.user_id', $params['member_id']);
            }
            if (!empty($params['first_name'])) {
                $query = $query->where('users.first_name', 'like', "%{$params['first_name']}%");
            }
            if (!empty($params['start_time'])) {
                $startTime = $params['start_time'] . " 00:00:00";
                $query = $query->where('user_login.created_at', '>=', $startTime);
            }
            if (!empty($params['end_time'])) {
                $endTime = $params['end_time'] . " 23:59:59";
                $query = $query->where('user_login.updated_at', '<=', $endTime);
            }
            $count = $query->count();
            $list = $query
                ->forPage($page, $limit)
                ->orderByDesc('user_login.created_at')
                ->get();
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR,$e->getMessage());
        }
        return $this->success(['total' => $count, 'data' => $list]);

    }

    function setRechargeChannelGroup()
    {
        try {
            $params = request()->validate([
                'member_id' => ['required', 'array'],
                'recharge_channel_group_id' => ['required', 'integer', 'min:1'],
            ]);
            UserModel::whereIn('member_id', $params['member_id'])->update(['recharge_channel_group_id' => $params['recharge_channel_group_id']]);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

}