lbqms.git - Gitblit

			@@ -6,6 +6,8 @@
			import cn.hutool.core.bean.BeanUtil;
			import cn.hutool.core.util.ObjectUtil;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.dromara.common.core.constant.Constants;
			import org.dromara.common.core.constant.GlobalConstants;
			import org.dromara.common.core.constant.TenantConstants;
			@@ -32,9 +34,6 @@
			import org.dromara.system.mapper.SysUserMapper;
			import org.dromara.system.service.ISysPermissionService;
			import org.dromara.system.service.ISysTenantService;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.dromara.common.core.utils.*;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.stereotype.Service;

			@@ -82,9 +81,10 @@
			// 校验租户
			checkTenant(tenantId);

			// 框架登录不限制从什么表查询只要最终构建出 LoginUser 即可
			SysUserVo user = loadUserByUsername(tenantId, username);
			checkLogin(LoginType.PASSWORD, tenantId, username, () -> !BCrypt.checkpw(password, user.getPassword()));
			// 此处可根据登录用户的数据不同自行创建 loginUser
			// 此处可根据登录用户的数据不同自行创建 loginUser 属性不够用继承扩展就行了
			LoginUser loginUser = buildLoginUser(user);
			// 生成token
			LoginHelper.loginByDevice(loginUser, DeviceType.PC);
			@@ -101,7 +101,7 @@
			SysUserVo user = loadUserByPhonenumber(tenantId, phonenumber);

			checkLogin(LoginType.SMS, tenantId, user.getUserName(), () -> !validateSmsCode(tenantId, phonenumber, smsCode));
			// 此处可根据登录用户的数据不同自行创建 loginUser
			// 此处可根据登录用户的数据不同自行创建 loginUser 属性不够用继承扩展就行了
			LoginUser loginUser = buildLoginUser(user);
			// 生成token
			LoginHelper.loginByDevice(loginUser, DeviceType.APP);
			@@ -114,11 +114,11 @@
			public String emailLogin(String tenantId, String email, String emailCode) {
			// 校验租户
			checkTenant(tenantId);
			// 通过手机号查找用户
			// 通过邮箱查找用户
			SysUserVo user = loadUserByEmail(tenantId, email);

			checkLogin(LoginType.EMAIL, tenantId, user.getUserName(), () -> !validateEmailCode(tenantId, email, emailCode));
			// 此处可根据登录用户的数据不同自行创建 loginUser
			// 此处可根据登录用户的数据不同自行创建 loginUser 属性不够用继承扩展就行了
			LoginUser loginUser = buildLoginUser(user);
			// 生成token
			LoginHelper.loginByDevice(loginUser, DeviceType.APP);
			@@ -134,11 +134,12 @@
			// todo 以下自行实现
			// 校验 appid + appsrcret + xcxCode 调用登录凭证校验接口获取 session_key 与 openid
			String openid = "";
			// 框架登录不限制从什么表查询只要最终构建出 LoginUser 即可
			SysUserVo user = loadUserByOpenid(openid);
			// 校验租户
			checkTenant(user.getTenantId());

			// 此处可根据登录用户的数据不同自行创建 loginUser
			// 此处可根据登录用户的数据不同自行创建 loginUser 属性不够用继承扩展就行了
			XcxLoginUser loginUser = new XcxLoginUser();
			loginUser.setTenantId(user.getTenantId());
			loginUser.setUserId(user.getUserId());
			@@ -339,25 +340,24 @@
			String errorKey = GlobalConstants.PWD_ERR_CNT_KEY + username;
			String loginFail = Constants.LOGIN_FAIL;

			// 获取用户登录错误次数(可自定义限制策略例如: key + username + ip)
			Integer errorNumber = RedisUtils.getCacheObject(errorKey);
			// 获取用户登录错误次数，默认为0 (可自定义限制策略例如: key + username + ip)
			int errorNumber = ObjectUtil.defaultIfNull(RedisUtils.getCacheObject(errorKey), 0);
			// 锁定时间内登录则踢出
			if (ObjectUtil.isNotNull(errorNumber) && errorNumber.equals(maxRetryCount)) {
			if (errorNumber >= maxRetryCount) {
			recordLogininfor(tenantId, username, loginFail, MessageUtils.message(loginType.getRetryLimitExceed(), maxRetryCount, lockTime));
			throw new UserException(loginType.getRetryLimitExceed(), maxRetryCount, lockTime);
			}

			if (supplier.get()) {
			// 是否第一次
			errorNumber = ObjectUtil.isNull(errorNumber) ? 1 : errorNumber + 1;
			// 错误次数递增
			errorNumber++;
			RedisUtils.setCacheObject(errorKey, errorNumber, Duration.ofMinutes(lockTime));
			// 达到规定错误次数则锁定登录
			if (errorNumber.equals(maxRetryCount)) {
			RedisUtils.setCacheObject(errorKey, errorNumber, Duration.ofMinutes(lockTime));
			if (errorNumber >= maxRetryCount) {
			recordLogininfor(tenantId, username, loginFail, MessageUtils.message(loginType.getRetryLimitExceed(), maxRetryCount, lockTime));
			throw new UserException(loginType.getRetryLimitExceed(), maxRetryCount, lockTime);
			} else {
			// 未达到规定错误次数则递增
			RedisUtils.setCacheObject(errorKey, errorNumber);
			// 未达到规定错误次数
			recordLogininfor(tenantId, username, loginFail, MessageUtils.message(loginType.getRetryLimitCount(), errorNumber));
			throw new UserException(loginType.getRetryLimitCount(), errorNumber);
			}