<?php

namespace app\common\service\user;

use app\common\exception\OperateException;
use app\common\exception\user\UserException;
use app\common\model\system\User as UserModel;
use app\common\model\system\UserLog;
use app\common\model\system\UserNotice;
use app\common\service\notice\EmailService;
use app\common\service\notice\SmsService;
use PHPMailer\PHPMailer\Exception;
use Psr\SimpleCache\InvalidArgumentException;
use system\Random;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use support\Cache;
use Webman\Event\Event;

/**
 * 用户中心服务
 * @package app\common\service\system
 */
class UserService
{
    /**
     * 保活时间
     * @var int
     */
    protected static int $keepTime = 604800;

    /**
     * 类构造函数
     * class constructor.
     */
    public function __construct()
    {
        self::$keepTime = config('cookie.expire');
    }

    /**
     * 注册服务
     * @param array $post
     * @return array
     * @throws DbException
     * @throws InvalidArgumentException
     * @throws OperateException
     */
    public static function register(array $post): array
    {
        if (!saenv('user_status')) {
            throw new OperateException('暂未开放注册！');
        }

        // 是否手机注册
        $regType = saenv('user_register_style');
        if ($regType == 'mobile') {
            $mobile = $post['mobile'] ?? '';
            $captcha = $post['captcha'] ?? '';
            if (!SmsService::checkCaptcha($mobile, $captcha, 'register')) {
                throw new OperateException('验证码错误');
            }
        }

        // 禁止批量注册
        $where[] = ['create_ip', '=', request()->getRealIp()];
        $where[] = ['create_time', '>', linux_time(1)];
        $totalMax = UserModel::where($where)->count();
        if ($totalMax >= saenv('user_register_second')) {
            throw new OperateException('禁止批量注册');
        }

        try {

            $userInfo = [
                'nickname'  => $post['nickname'],
                'email'     => $post['email'] ?? '',
                'mobile'    => $post['mobile'] ?? '',
                'pwd'       => $post['pwd'],
                'invite_id' => input('inviter', request()->cookie('inviter')),
            ];
            $userInfo = self::createUser($userInfo);
        } catch (\Throwable $e) {
            throw new OperateException($e->getMessage());
        }

        return self::createUserCookies($userInfo);
    }

    /**
     * 登录服务
     * @param string $nickname
     * @param string $pwd
     * @return array
     * @throws OperateException
     */
    public static function accountLogin(string $nickname, string $pwd): array
    {
        // 普通登录支持邮箱和用户名登录
        if (filter_var($nickname, FILTER_VALIDATE_EMAIL)) {
            $where[] = ['email', '=', htmlspecialchars(trim($nickname))];
        } else {
            $where[] = ['nickname', '=', htmlspecialchars(trim($nickname))];
        }

        $userInfo = UserModel::where($where)->findOrEmpty()->toArray();
        if (empty($userInfo)) {
            throw new OperateException('用户名或密码错误');
        }

        $uPwd = encryptPwd($pwd, $userInfo['salt']);
        if ($userInfo['pwd'] != $uPwd) {
            $errorMsg = '用户名或密码错误';
            UserLog::write($errorMsg, $userInfo['nickname'], $userInfo['id']);
            throw new OperateException($errorMsg);
        }

        if (!$userInfo['status']) {
            $errorMsg = '用户禁用或未审核，请联系管理员';
            UserLog::write($errorMsg, $userInfo['nickname'], $userInfo['id']);
            throw new OperateException($errorMsg);
        }

        return self::createUserCookies($userInfo);
    }

    /**
     * 手机登录
     * @param string $mobile
     * @param string $captcha
     * @return array
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException|OperateException
     */
    public static function mobileLogin(string $mobile, string $captcha): array
    {
        if (!SmsService::checkCaptcha($mobile, $captcha, 'login')) {
            throw new OperateException('验证码错误');
        }

        $userInfo = UserModel::where(['mobile' => $mobile])->findOrEmpty()->toArray();
        if (empty($userInfo)) {
            $maxId = UserModel::max('id');
            $userInfo = [
                'nickname' => 'u' . ($maxId + 1),
                'mobile'   => $mobile,
            ];
            return self::createUser($userInfo);
        } else if (!$userInfo['status']) {
            $errorMsg = '用户禁用或未审核，请联系管理员';
            UserLog::write($errorMsg, $userInfo['nickname'], $userInfo['id']);
            throw new OperateException($errorMsg);
        }
        self::updateUser($userInfo);
        return self::createUserCookies($userInfo);
    }

    /**
     * 创建用户
     * @param array $userInfo
     * @return array
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException|OperateException
     */
    public static function createUser(array $userInfo): array
    {
        if (UserModel::getByNickname($userInfo['nickname'])) {
            throw new OperateException('当前用户名已被占用！');
        }

        if (!empty($userInfo['email']) && UserModel::getByEmail($userInfo['email'])) {
            throw new OperateException('当前邮箱已被占用！');
        }

        if (!empty($userInfo['mobile']) && UserModel::getByMobile($userInfo['mobile'])) {
            throw new OperateException('当前手机号已被占用！');
        }

        if (isset($userInfo['pwd']) && $userInfo['pwd']) {
            $userInfo['salt'] = Random::alpha();
            $userInfo['pwd'] = encryptPwd($userInfo['pwd'], $userInfo['salt']);
        }

        $userInfo['login_time'] = time();
        $userInfo['login_ip'] = request()->getRealIp();
        $userInfo['create_ip'] = request()->getRealIp();

        try {
            $userInfo = UserModel::create($userInfo)->toArray();
        } catch (\Throwable $th) {
            throw new OperateException($th->getMessage());
        }

        return $userInfo;
    }

    /**
     *
     * 返回前端令牌
     * @param array $userInfo
     * @return array
     */
    public static function createUserCookies(array $userInfo = []): array
    {
        $userToken = UserTokenService::buildToken($userInfo['id']);
        $response = response()
            ->cookie('uid', $userInfo['id'], self::$keepTime, '/')
            ->cookie('token', $userToken, self::$keepTime, '/')
            ->cookie('nickname', $userInfo['nickname'], self::$keepTime, '/');
        Cache::set($userToken, $userInfo['id'], self::$keepTime);
        Cache::set('user_info_' . $userInfo['id'], $userInfo, self::$keepTime);
        Event::emit("userLoginSuccess", $userInfo);
        return ['token' => $userToken, 'id' => $userInfo['id'], 'response' => $response];
    }

    /**
     * 更新用户信息
     * @param array $userInfo
     */
    public static function updateUser(array $userInfo = []): void
    {
        $data['login_time'] = time();
        $data['login_ip'] = request()->getRealIp();
        $data['login_count'] = $userInfo['login_count'] + 1;
        $data['update_time'] = time();
        UserModel::update($data, ['id' => $userInfo['id']]);
        UserLog::write('登录成功', $userInfo['nickname'], $userInfo['id'], 1);
    }

    /**
     * 退出登录
     * @return void
     */
    public static function logout(): void
    {
        response()->cookie('uid', null);
        response()->cookie('token', null);
        response()->cookie('nickname', null);
        Cache::delete(UserTokenService::getToken());
    }

    /**
     * @param array $params
     * @param int $userId
     * @return bool
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     * @throws OperateException
     */
    public static function editProfile(array $params = [], int $userId = 0): bool
    {
        $userInfo = UserModel::where('id', $userId)->findOrEmpty()->toArray();
        if (empty($userInfo)) {
            throw new OperateException('用户不存在');
        }

        $data = [];
        if (isset($params['nickname']) && $params['nickname']) {
            // 验证昵称是否存在
            $data['nickname'] = $params['nickname'];
            if ($data['nickname'] != $userInfo['nickname']
                && UserModel::where('nickname', $data['nickname'])->find()) {
                throw new OperateException('昵称已存在');
            }
        }

        $fields = ['avatar', 'name', 'wechat', 'qq', 'idCard', 'address', 'gender'];
        foreach ($fields as $field) {
            if (isset($params[$field])) {
                $data[$field] = $params[$field];
            }
        }

        try {
            UserModel::update($data, ['id' => $userId]);
        } catch (\Exception $e) {
            throw new OperateException($e->getMessage());
        }

        return true;
    }

    /**
     * 忘记密码
     * @param array $params
     * @return bool
     * @throws DataNotFoundException|DbException|ModelNotFoundException|OperateException
     */
    public static function forgotPwd(array $params = []): bool
    {
        $value = $params['name'] ?? '';
        $pwd = $params['pwd'] ?? '';
        $captcha = $params['captcha'] ?? '';
        $filterVar = filter_var($value, FILTER_VALIDATE_EMAIL);

        // 获取验证服务类
        $checkClass = $filterVar ? EmailService::class : SmsService::class;
        if (!$checkClass::checkCaptcha($value, $captcha, 'forgot')) {
            throw new OperateException('无效的验证码');
        }

        $where = [$filterVar ? 'email' : 'mobile' => $value];
        $userInfo = UserModel::where($where)->findOrEmpty()->toArray();
        if (empty($userInfo)) {
            throw new OperateException('用户不存在');
        }

        try {
            $salt = Random::alpha();
            $pwd = encryptPwd($pwd, $salt);
            UserModel::update(['id' => $userInfo['id'], 'pwd' => $pwd, 'salt' => $salt]);
        } catch (\Exception $e) {
            throw new OperateException($e->getMessage());
        }

        return true;
    }

    /**
     * 修改密码
     * @param array $params
     * @param int $userId
     * @return bool
     * @throws OperateException
     */
    public static function changePwd(array $params = [], int $userId = 0): bool
    {
        $pwd = $params['pwd'] ?? '';
        $oldPwd = $params['oldpwd'] ?? '';
        $userInfo = UserModel::where('id', $userId)->findOrEmpty()->toArray();
        if (empty($userInfo)) {
            throw new OperateException('用户不存在');
        }

        $yPwd = encryptPwd($oldPwd, $userInfo['salt']);
        if (!empty($userInfo['pwd']) && $yPwd != $userInfo['pwd']) {
            throw new OperateException('原密码错误');
        }

        $salt = Random::alpha();
        $pwd = encryptPwd($pwd, $salt);
        try {
            UserModel::update([
                'id'   => $userId,
                'pwd'  => $pwd,
                'salt' => $salt,
            ]);
        } catch (\Exception $e) {
            throw new OperateException($e->getMessage());
        }

        return true;
    }

    /**
     * 修改手机号
     * @param $email
     * @param $captcha
     * @param $event
     * @param $userId
     * @return bool
     * @throws Exception
     * @throws UserException|OperateException
     */
    public static function changeEmail($email, $captcha, $event, $userId): bool
    {
        if (!EmailService::filterEmail($email)) {
            throw new OperateException("邮箱格式不正确");
        }

        if ($email && UserModel::getByEmail($email)) {
            throw new OperateException("您输入的邮箱已被占用");
        }

        try {
            EmailService::checkCaptcha($email, $captcha, $event);
            UserModel::update(['id' => $userId, 'email' => $email]);
        } catch (\Throwable $e) {
            throw new OperateException($e->getMessage());
        }

        return true;
    }

    /**
     * 修改手机号
     * @param $mobile
     * @param $captcha
     * @param $event
     * @param $userId
     * @return bool
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     * @throws UserException|OperateException
     */
    public static function changeMobile($mobile, $captcha, $event, $userId): bool
    {
        if (!SmsService::filterMobile($mobile)) {
            throw new OperateException("手机号码格式不正确");
        }

        if ($mobile && UserModel::getByMobile($mobile)) {
            throw new OperateException("您输入的手机号已被占用");
        }
        try {
            if (!SmsService::checkCaptcha($mobile, $captcha, $event)) {
                throw new UserException('无效的验证码');
            }
            UserModel::update(['id' => $userId, 'mobile' => (int)$mobile]);
        } catch (\Throwable $e) {
            throw new OperateException($e->getMessage());
        }

        return true;
    }

    /**
     * 获取消息列表
     * @param int $limit
     * @param int $page
     * @param array $where
     * @return array
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public static function listMessage(mixed $limit = 10, mixed $page = 1, array $where = []): array
    {
        $count = (new UserNotice)->where($where)->count();
        $page = ($count <= $limit) ? 1 : $page;
        $list = (new UserNotice)->where($where)->order('id', 'desc')->limit($limit)->page($page)->select()->toArray();
        return [$list, $count];
    }

    /**
     * 读取消息
     * @param $id
     * @param int $userId
     * @return array
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException|OperateException
     */
    public static function viewMessage($id, int $userId = 0): array
    {
        $where[] = ['id', '=', $id];
        $where[] = ['user_id', '=', $userId];
        $msgInfo = UserNotice::where($where)->findOrEmpty()->toArray();
        if (empty($msgInfo)) {
            throw new OperateException('消息不存在');
        }

        if ($msgInfo['status'] == 0) {
            UserNotice::update(['id' => $id, 'status' => 1]);
        }

        if ($msgInfo['send_id']) {
            $fromInfo = UserModel::where('id', $msgInfo['send_id'])->findOrEmpty()->toArray();
            $msgInfo['nickname'] = $fromInfo['nickname'] ?? 'Unknown';
        }

        $unread = UserNotice::where(['user_id' => $userId, 'status' => 0])->count();
        return ['msgInfo' => $msgInfo, 'unread' => $unread];
    }

    /**
     * @param $ids
     * @param string $type
     * @param int $userId
     * @return bool
     * @throws UserException
     */
    public static function batchMessage($ids, string $type = 'del', int $userId = 0): bool
    {
        $where[] = ['user_id', '=', $userId];
        $where[] = ['id', 'in', implode(',', $ids)];
        try {
            $type == 'del' ? UserNotice::where($where)->delete() : UserNotice::where($where)->update(['status' => 1]);
        } catch (\Exception $e) {
            throw new UserException($e->getMessage());
        }
        return true;
    }
}