package com.ks.app.service.impl.user;
|
|
import com.ks.app.dto.user.LoginInfoDTO;
|
import com.ks.app.entity.config.SystemConfigKey;
|
import com.ks.app.entity.user.UserInfo;
|
import com.ks.app.entity.user.UserLoginRecord;
|
import com.ks.app.entity.user.WXUserInfo;
|
import com.ks.app.exception.user.LoginException;
|
import com.ks.app.service.inter.config.SystemConfigService;
|
import com.ks.app.service.inter.user.*;
|
import com.ks.app.service.manager.VerifyCodeManager;
|
import com.ks.app.utils.AliyunOneKeyLoginUtil;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.StringUtil;
|
import org.yeshi.utils.entity.wx.WeiXinUser;
|
import org.yeshi.utils.wx.WXAppLoginUtil;
|
|
import javax.annotation.Resource;
|
import java.util.UUID;
|
|
@Service
|
public class UserAccountServiceImpl implements UserAccountService {
|
|
@Resource
|
private UserInfoService userInfoService;
|
@Resource
|
private UserLoginRecordService userLoginRecordService;
|
@Resource
|
private VerifyCodeManager verifyCodeManager;
|
|
@Resource
|
private WXUserInfoService wxUserInfoService;
|
|
@Resource
|
private QQUserInfoService qqUserInfoService;
|
|
@Resource
|
private SystemConfigService systemConfigService;
|
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public UserInfo login(LoginInfoDTO loginInfo) throws LoginException {
|
|
if (loginInfo == null) {
|
throw new LoginException("登录信息为空");
|
}
|
|
UserInfo user = null;
|
switch (loginInfo.getLoginType()) {
|
case UserLoginRecord
|
.TYPE_LOGIN_PHONE: {
|
if (!StringUtil.isNullOrEmpty(loginInfo.getPhoneAuthInfo())) {
|
//一键登录
|
//获取电话号码
|
String mobile = AliyunOneKeyLoginUtil.getMobile(loginInfo.getPhoneAuthInfo(), UUID.randomUUID().toString(), systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.aliyunOneKeyAuthAcessKey), systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.aliyunOneKeyAuthAcessSecret));
|
if (StringUtil.isNullOrEmpty(mobile)) {
|
throw new LoginException("电话号码获取失败");
|
}
|
loginInfo.setPhone(mobile);
|
} else {
|
//验证码登录
|
if (!verifyCodeManager.isPhoneCodeRight(loginInfo.getSystem(), loginInfo.getPhone(), loginInfo.getVcode())) {
|
throw new LoginException("验证码出错");
|
}
|
}
|
//执行登录操作
|
user = userInfoService.selectByPhoneAndSystemAndStatus(loginInfo.getPhone(), loginInfo.getSystem(), UserInfo.STATUS_NORMAL);
|
if (user == null) {
|
//创建用户
|
UserInfo newUser = new UserInfo();
|
newUser.setPhone(loginInfo.getPhone());
|
newUser.setSystem(loginInfo.getSystem());
|
newUser.setNickName("");
|
newUser.setPortrait(systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.defaultPortrait));
|
try {
|
userInfoService.add(newUser);
|
} catch (Exception e) {
|
throw new LoginException("注册用户失败");
|
}
|
//更改昵称
|
UserInfo updateUser = new UserInfo();
|
updateUser.setId(newUser.getId());
|
updateUser.setNickName(systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.defaultNickNamePrefix) + newUser.getId());
|
userInfoService.update(updateUser);
|
user = newUser;
|
}
|
}
|
break;
|
case UserLoginRecord
|
.TYPE_LOGIN_WX: {
|
String appId = systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.wxAppId);
|
String appSecret = systemConfigService.getValueCache(loginInfo.getSystem(), SystemConfigKey.wxAppSecret);
|
WeiXinUser weiXinUser = WXAppLoginUtil.getWeiXinUser(loginInfo.getWxCode(), appId, appSecret);
|
if (weiXinUser == null) {
|
throw new LoginException("微信授权信息获取失败");
|
}
|
//保存微信用户信息
|
WXUserInfo wxUserInfo = null;
|
try {
|
wxUserInfo = wxUserInfoService.save(WXUserInfo.create(weiXinUser));
|
} catch (Exception e) {
|
throw new LoginException("保存微信授权信息失败");
|
}
|
wxUserInfo.setSystem(loginInfo.getSystem());
|
user = userInfoService.selectByWXIdAndSystemAndStatus(wxUserInfo.getId(), wxUserInfo.getSystem(), UserInfo.STATUS_NORMAL);
|
if (user == null) {
|
//新建用户
|
UserInfo newUser = new UserInfo();
|
newUser.setWxUser(wxUserInfo);
|
newUser.setSystem(loginInfo.getSystem());
|
newUser.setNickName(wxUserInfo.getNickName());
|
newUser.setPortrait(wxUserInfo.getHeadImgUrl());
|
try {
|
userInfoService.add(newUser);
|
} catch (Exception e) {
|
throw new LoginException("注册用户失败");
|
}
|
user = newUser;
|
}
|
|
}
|
break;
|
case UserLoginRecord
|
.TYPE_LOGIN_QQ:
|
//保存QQ信息
|
|
|
break;
|
case UserLoginRecord
|
.TYPE_LOGIN_EMAIL:
|
//验证密码是否正确
|
UserInfo oldUser = userInfoService.selectByEmailAndSystemAndStatus(loginInfo.getEmail(), loginInfo.getSystem(), UserInfo.STATUS_NORMAL);
|
if (oldUser == null) {
|
throw new LoginException("邮箱未注册");
|
}
|
|
if (!StringUtil.Md5(loginInfo.getPwd()).equalsIgnoreCase(oldUser.getPwd())) {
|
throw new LoginException("密码错误");
|
}
|
user = oldUser;
|
break;
|
default:
|
throw new LoginException("登录方式不存在");
|
}
|
|
loginSuccess(user.getId(), loginInfo);
|
return null;
|
}
|
|
@Override
|
public void unRegister(Long uid) {
|
UserInfo update = new UserInfo();
|
update.setId(uid);
|
update.setStatus(UserInfo.STATUS_OWN_DELETE);
|
userInfoService.update(update);
|
}
|
|
|
/**
|
* @return void
|
* @author hxh
|
* @description 登录成功
|
* @date 18:21 2021/11/15
|
**/
|
private void loginSuccess(Long uid, LoginInfoDTO dto) {
|
UserLoginRecord record = new UserLoginRecord();
|
record.setLoginIPInfo(dto.getIpInfo());
|
record.setLoginType(dto.getLoginType());
|
record.setUid(uid);
|
userLoginRecordService.addUserLoginRecord(record);
|
}
|
|
|
}
|
