'user_group', // 用户组数据表名 'auth_group_access' => '', // 用户-用户组关系表(关系字段) 'auth_rule' => 'user_rule', // 权限规则表 ], $config)); } /** * 魔术方法-会员信息字段 * @param $name * @return null|string 字段信息 */ public function __get($name) { return $this->model ? $this->model->$name : null; } /** * 初始化 * @access public * @param array $options 参数 * @return Auth */ public static function instance(array $options = []): Auth { if (is_null(self::$instance)) { self::$instance = new static($options); } return self::$instance; } /** * 根据Token初始化会员登录态 * @param $token * @return bool * @throws DataNotFoundException * @throws DbException * @throws ModelNotFoundException */ public function init($token): bool { if ($this->logined) { return true; } if ($this->error) { return false; } $tokenData = Token::get($token); if (!$tokenData) { return false; } $userId = intval($tokenData['user_id']); if ($tokenData['type'] == 'user' && $userId > 0) { $this->model = User::where('id', $userId)->find(); if (!$this->model) { $this->setError('Account not exist'); return false; } if ($this->model['status'] != 'enable') { $this->setError('Account disabled'); return false; } $this->token = $token; $this->loginSuccessful(); return true; } else { $this->setError('Token login failed'); return false; } } /** * 会员注册 * @param string $username * @param string $password * @param string $mobile * @param string $email * @param int $group * @param array $extend * @return bool */ public function register(string $username, string $password, string $mobile = '', string $email = '', int $group = 1, array $extend = []): bool { $validate = Validate::rule([ 'mobile' => 'mobile|unique:user', 'email' => 'email|unique:user', 'username' => 'regex:^[a-zA-Z][a-zA-Z0-9_]{2,15}$|unique:user', 'password' => 'regex:^(?!.*[&<>"\'\n\r]).{6,32}$', ]); $params = [ 'username' => $username, 'password' => $password, 'mobile' => $mobile, 'email' => $email, ]; if (!$validate->check($params)) { $this->setError('Registration parameter error'); return false; } $ip = request()->ip(); $time = time(); $salt = Random::build('alnum', 16); $data = [ 'password' => encrypt_password($password, $salt), 'group_id' => $group, 'nickname' => preg_match("/^1[3-9]\d{9}$/", $username) ? substr_replace($username, '****', 3, 4) : $username, 'joinip' => $ip, 'jointime' => $time, 'lastloginip' => $ip, 'lastlogintime' => $time, 'salt' => $salt, 'status' => 'enable', ]; $data = array_merge($params, $data); $data = array_merge($data, $extend); Db::startTrans(); try { $this->model = User::create($data); $this->token = Random::uuid(); Token::set($this->token, 'user', $this->model->id, $this->keeptime); Event::trigger('userRegisterSuccessed', $this->model); Db::commit(); } catch (PDOException|Exception $e) { $this->setError($e->getMessage()); Db::rollback(); return false; } return true; } /** * 会员登录 * @param string $username * @param string $password * @param bool $keeptime * @return bool * @throws DataNotFoundException * @throws DbException * @throws ModelNotFoundException */ public function login(string $username, string $password, bool $keeptime): bool { // 判断账户类型 $accountType = false; $validate = Validate::rule([ 'mobile' => 'mobile', 'email' => 'email', 'username' => 'regex:^[a-zA-Z][a-zA-Z0-9_]{2,15}$', ]); if ($validate->check(['mobile' => $username])) $accountType = 'mobile'; if ($validate->check(['email' => $username])) $accountType = 'email'; if ($validate->check(['username' => $username])) $accountType = 'username'; if (!$accountType) { $this->setError('Account not exist'); return false; } $this->model = User::where($accountType, $username)->find(); if (!$this->model) { $this->setError('Account not exist'); return false; } if ($this->model['status'] == 'disable') { $this->setError('Account disabled'); return false; } $userLoginRetry = Config::get('buildadmin.user_login_retry'); if ($userLoginRetry && $this->model->loginfailure >= $userLoginRetry && time() - $this->model->lastlogintime < 86400) { $this->setError('Please try again after 1 day'); return false; } if ($this->model->password != encrypt_password($password, $this->model->salt)) { $this->loginFailed(); $this->setError('Password is incorrect'); return false; } if (Config::get('buildadmin.user_sso')) { Token::clear('user', $this->model->id); Token::clear('user-refresh', $this->model->id); } if ($keeptime) { $this->setRefreshToken(2592000); } $this->loginSuccessful(); return true; } /** * 直接登录会员账号 * @param int $userId 用户ID * @return bool * @throws DataNotFoundException * @throws DbException * @throws ModelNotFoundException */ public function direct(int $userId): bool { $this->model = User::find($userId); if (!$this->model) return false; if (Config::get('buildadmin.user_sso')) { Token::clear('user', $this->model->id); Token::clear('user-refresh', $this->model->id); } return $this->loginSuccessful(); } /** * 检查旧密码是否正确 * @param $password * @return bool */ public function checkPassword($password): bool { if ($this->model->password != encrypt_password($password, $this->model->salt)) { return false; } else { return true; } } /** * 登录成功 * @return bool */ public function loginSuccessful(): bool { if (!$this->model) { return false; } Db::startTrans(); try { $this->model->loginfailure = 0; $this->model->lastlogintime = time(); $this->model->lastloginip = request()->ip(); $this->model->save(); $this->logined = true; if (!$this->token) { $this->token = Random::uuid(); Token::set($this->token, 'user', $this->model->id, $this->keeptime); } Db::commit(); } catch (PDOException|Exception $e) { Db::rollback(); $this->setError($e->getMessage()); return false; } return true; } /** * 登录失败 * @return bool */ public function loginFailed(): bool { if (!$this->model) { return false; } Db::startTrans(); try { $this->model->loginfailure++; $this->model->lastlogintime = time(); $this->model->lastloginip = request()->ip(); $this->model->save(); $this->token = ''; $this->model = null; $this->logined = false; Db::commit(); } catch (PDOException|Exception $e) { Db::rollback(); $this->setError($e->getMessage()); return false; } return true; } /** * 退出登录 * @return bool */ public function logout(): bool { if (!$this->logined) { $this->setError('You are not logged in'); return false; } $this->logined = false; Token::delete($this->token); $this->token = ''; return true; } /** * 是否登录 * @return bool */ public function isLogin(): bool { return $this->logined; } /** * 获取会员模型 * @return User */ public function getUser(): User { return $this->model; } /** * 获取会员Token * @return string */ public function getToken(): string { return $this->token; } /** * 设置刷新Token * @param int $keeptime */ public function setRefreshToken(int $keeptime = 0) { $this->refreshToken = Random::uuid(); Token::set($this->refreshToken, 'user-refresh', $this->model->id, $keeptime); } /** * 获取会员刷新Token * @return string */ public function getRefreshToken(): string { return $this->refreshToken; } /** * 获取会员信息 - 只输出允许输出的字段 * @return array */ public function getUserInfo(): array { if (!$this->model) { return []; } $info = $this->model->toArray(); $info = array_intersect_key($info, array_flip($this->getAllowFields())); $info['token'] = $this->getToken(); $info['refreshToken'] = $this->getRefreshToken(); return $info; } /** * 获取允许输出字段 * @return string[] */ public function getAllowFields(): array { return $this->allowFields; } /** * 设置允许输出字段 * @param $fields */ public function setAllowFields($fields) { $this->allowFields = $fields; } /** * 设置Token有效期 * @param int $keeptime */ public function setKeeptime(int $keeptime = 0) { $this->keeptime = $keeptime; } public function check(string $name, int $uid = 0, string $relation = 'or', string $mode = 'url'): bool { return parent::check($name, $uid ?: $this->id, $relation, $mode); } public function getRuleList(int $uid = 0): array { return parent::getRuleList($uid ?: $this->id); } public function getRuleIds(int $uid = 0): array { return parent::getRuleIds($uid ?: $this->id); } public function getMenus(int $uid = 0): array { return parent::getMenus($uid ?: $this->id); } public function isSuperUser(): bool { return in_array('*', $this->getRuleIds()); } /** * 设置错误消息 * @param $error * @return $this */ public function setError($error): Auth { $this->error = $error; return $this; } /** * 获取错误消息 * @return float|int|string */ public function getError() { return $this->error ? __($this->error) : ''; } }