| | |
|---|
| | | import com.yeshi.fanli.entity.bus.user.ForbiddenUserIdentifyCode;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.ForbiddenUserIdentifyCode.ForbiddenUserIdentifyCodeTypeEnum;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.LoginResult;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.SMSHistory;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.ThreeSale;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.UserAccountBindingHistory;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.UserConnectHistory;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.UserInfo;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.WeiXinUser;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.service.inter.user.BindingAccountService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserAccountBindingHistoryService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserAccountService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.FileUtil;
|
|---|
| | | import com.yeshi.fanli.util.RedisManager;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.factory.msg.MsgAccountDetailFactory;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class UserAccountServiceImpl implements UserAccountService {
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private RedisManager redisManager;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserInfoMapper userInfoMapper;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private ForbiddenUserIdentifyCodeService forbiddenUserIdentifyCodeService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserInfoExtraService userInfoExtraService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserAccountBindingHistoryService userAccountBindingHistoryService;
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | @Override
|
|---|
| | |
|---|
| | | * @param unionId
|
|---|
| | | * @return
|
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | public UserInfo getUserInfoByWXUnionId(String appId, String unionId) throws UserAccountException {
|
|---|
| | | if (StringUtil.isNullOrEmpty(appId))
|
|---|
| | | throw new UserAccountException(1, "appId为空");
|
|---|
| | |
|---|
| | | updateUserInfo.setNickName(Constant.systemCommonConfig.getDefaultNickName() + user.getId());
|
|---|
| | | userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | // 第一次登录时创建用户额外信息
|
|---|
| | | userInfoExtraService.createUserInfoExtra(user.getId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | |
|---|
| | | return user.getPortrait();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | @Override
|
|---|
| | | public UserInfo loginPhone(HttpServletRequest request, int loginType, String vcode, String phone, String appId)
|
|---|
| | | throws UserAccountException {
|
|---|
| | |
|
|---|
| | | // 空额清理
|
|---|
| | | if (phone == null || phone.trim().length() == 0) {
|
|---|
| | | throw new UserAccountException(1, "请输入手机号码");
|
|---|
| | | }
|
|---|
| | | phone = phone.replaceAll(" ", "");
|
|---|
| | |
|
|---|
| | | // 苹果应用商店上线测试号码
|
|---|
| | | if ("17316780233".equalsIgnoreCase(phone) && "2581".equalsIgnoreCase(vcode)) {
|
|---|
| | | ;
|
|---|
| | | } else {
|
|---|
| | |
|
|---|
| | | if (StringUtil.isNullOrEmpty(vcode)) {
|
|---|
| | | throw new UserAccountException(1, "请输入验证码");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String oldVcode = redisManager.getSMSVCode(phone, SMSHistory.TYPE_LOGIN);
|
|---|
| | | LogHelper.test("----------------------登录验证码： " + oldVcode);
|
|---|
| | | if (!Constant.IS_TEST)
|
|---|
| | | if (StringUtil.isNullOrEmpty(oldVcode) || !oldVcode.equalsIgnoreCase(vcode)) {
|
|---|
| | | throw new UserAccountException(1, "验证码错误，重新输入");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | JSONObject logInfo = new JSONObject();
|
|---|
| | | logInfo.put("appId", appId);
|
|---|
| | | logInfo.put("phone", phone);
|
|---|
| | | logInfo.put("loginType", loginType);
|
|---|
| | | LogHelper.lgoinInfo(logInfo.toString());
|
|---|
| | |
|
|---|
| | | // 判断手机号码是否被封禁
|
|---|
| | | ForbiddenUserIdentifyCode identifyCode1 = forbiddenUserIdentifyCodeService
|
|---|
| | | .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.phone, phone);
|
|---|
| | | if (identifyCode1 != null && identifyCode1.getEffective() != null && identifyCode1.getEffective()) {
|
|---|
| | | throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 清空限制
|
|---|
| | | redisManager.clearSMSFrequencyLimit(phone, SMSHistory.TYPE_LOGIN);
|
|---|
| | | // 清理次数
|
|---|
| | | redisManager.removeCommonString("sendMSNLoginCount" + phone);
|
|---|
| | |
|
|---|
| | | // 查询是否存在该电话历史用户
|
|---|
| | | UserInfo userInfo = userInfoMapper.getEffectiveUserInfoByPhone(phone);
|
|---|
| | | if (userInfo != null) {
|
|---|
| | | // 更新账户登录信息
|
|---|
| | | updateLonginInfo(userInfo, loginType, request);
|
|---|
| | | } else {
|
|---|
| | | userInfo = new UserInfo();
|
|---|
| | | userInfo.setAppId(appId);
|
|---|
| | | userInfo.setNickName(Constant.systemCommonConfig.getDefaultNickName());
|
|---|
| | | userInfo.setPortrait(Constant.systemCommonConfig.getDefaultPortrait());
|
|---|
| | | userInfo.setPhone(phone);
|
|---|
| | | userInfo.setLoginType(loginType);
|
|---|
| | | userInfo.setState(UserInfo.STATE_NORMAL);
|
|---|
| | | // 创建用户
|
|---|
| | | addUser(userInfo);
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | // 第一次登录时创建用户额外信息
|
|---|
| | | userInfoExtraService.createUserInfoExtra(userInfo.getId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return userInfo;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | @Override
|
|---|
| | | public UserInfo loginWinXin(HttpServletRequest request, int loginType, String code, String appId)
|
|---|
| | | throws UserAccountException {
|
|---|
| | | // 日志信息
|
|---|
| | | JSONObject logInfo = new JSONObject();
|
|---|
| | | logInfo.put("appId", appId);
|
|---|
| | | logInfo.put("code", code);
|
|---|
| | | logInfo.put("loginType", loginType);
|
|---|
| | | LogHelper.lgoinInfo(logInfo.toString());
|
|---|
| | |
|
|---|
| | | // 通过Code换取信息
|
|---|
| | | WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
|
|---|
| | | if (weiXinUser == null) {
|
|---|
| | | throw new UserAccountException(1, "微信帐号授权失败");
|
|---|
| | | }
|
|---|
| | | LogHelper.test("微信授权用户信息：" + new Gson().toJson(weiXinUser));
|
|---|
| | |
|
|---|
| | | // 判断微信unionid是否被封禁
|
|---|
| | | ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService
|
|---|
| | | .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.wxUnionId, weiXinUser.getUnionid());
|
|---|
| | | if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective()) {
|
|---|
| | | throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | UserInfo userInfo = userInfoMapper.getEffectiveUserInfoByWXUnionId(weiXinUser.getUnionid());
|
|---|
| | | // 直接用的微信登录
|
|---|
| | | if (userInfo != null) {
|
|---|
| | | LogHelper.test("微信unionID存在:" + weiXinUser.getUnionid());
|
|---|
| | | // 更新账户登录信息
|
|---|
| | | updateLonginInfo(userInfo, loginType, request);
|
|---|
| | | // 删除邀请分享图
|
|---|
| | | spreadUserImgService.deleteImgUrl(userInfo.getId());
|
|---|
| | | } else {
|
|---|
| | | LogHelper.test("微信unionID不存在:" + weiXinUser.getUnionid());
|
|---|
| | | // 创建新账户
|
|---|
| | | userInfo = new UserInfo();
|
|---|
| | | userInfo.setPortrait(weiXinUser.getHeadimgurl());
|
|---|
| | | userInfo.setAppId(appId);
|
|---|
| | | userInfo.setNickName(weiXinUser.getNickname());
|
|---|
| | | userInfo.setWxName(weiXinUser.getNickname());
|
|---|
| | | userInfo.setWxOpenId(weiXinUser.getOpenid());
|
|---|
| | | userInfo.setWxUnionId(weiXinUser.getUnionid());
|
|---|
| | | userInfo.setWxPic(weiXinUser.getHeadimgurl());
|
|---|
| | | userInfo.setLastLoginTime(System.currentTimeMillis());
|
|---|
| | | userInfo.setLoginType(loginType);
|
|---|
| | | userInfo.setLastLoginIp(request.getRemoteHost());
|
|---|
| | | userInfo.setState(UserInfo.STATE_NORMAL);
|
|---|
| | | addUser(userInfo);
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | // 第一次登录时创建用户额外信息
|
|---|
| | | userInfoExtraService.createUserInfoExtra(userInfo.getId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return userInfo;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 更新账户登录信息
|
|---|
| | | * |
|---|
| | | * @param userInfo
|
|---|
| | | * @param loginType
|
|---|
| | | * @param request
|
|---|
| | | */
|
|---|
| | | public void updateLonginInfo(UserInfo userInfo, int loginType, HttpServletRequest request) {
|
|---|
| | | // 设置登录时间与登录类型
|
|---|
| | | UserInfo updateUserInfo = new UserInfo(userInfo.getId());
|
|---|
| | | updateUserInfo.setLastLoginTime(System.currentTimeMillis());
|
|---|
| | | updateUserInfo.setLoginType(loginType);
|
|---|
| | | updateUserInfo.setLastLoginIp(request.getRemoteHost());
|
|---|
| | | userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void bindPhoneNew(Long uid, String phone) throws UserAccountException {
|
|---|
| | | UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
|
|---|
| | | if (user == null) {
|
|---|
| | | throw new UserAccountException(1, "用户不存在");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String hasPhone = user.getPhone();
|
|---|
| | | if (!StringUtil.isNullOrEmpty(hasPhone) && hasPhone.equals(phone)) {
|
|---|
| | | throw new UserAccountException(2, "您已经绑定了该电话号码");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | UserInfo phoneUser = userInfoMapper.getEffectiveUserInfoByPhone(phone);
|
|---|
| | | if (phoneUser != null) {
|
|---|
| | | throw new UserAccountException(2, "号码已经被占用");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 更新电话号码
|
|---|
| | | UserInfo update = new UserInfo(user.getId());
|
|---|
| | | update.setPhone(phone);
|
|---|
| | | userInfoMapper.updateByPrimaryKeySelective(update);
|
|---|
| | | // 加入绑定记录
|
|---|
| | | UserAccountBindingHistory history = new UserAccountBindingHistory();
|
|---|
| | | history.setContent(phone);
|
|---|
| | | history.setType(UserAccountBindingHistory.TYPE_PHONE);
|
|---|
| | | history.setUid(uid);
|
|---|
| | |
|
|---|
| | | // 之前已经绑定电话号码
|
|---|
| | | if (!StringUtil.isNullOrEmpty(user.getPhone()))
|
|---|
| | | history.setFirst(false);
|
|---|
| | | else
|
|---|
| | | history.setFirst(true);
|
|---|
| | | userAccountBindingHistoryService.addUserAccountBindingHistory(history);
|
|---|
| | |
|
|---|
| | | // 发送消息
|
|---|
| | | userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_PHONE);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void bindWeiXin(Long uid, String code) throws UserAccountException {
|
|---|
| | | UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
|
|---|
| | | if (user == null) {
|
|---|
| | | throw new UserAccountException(1, "用户不存在");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
|
|---|
| | | if (weiXinUser == null) {
|
|---|
| | | throw new UserAccountException(2, "微信帐号授权失败");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String wxUnionId = weiXinUser.getUnionid();
|
|---|
| | | if (StringUtil.isNullOrEmpty(wxUnionId)) {
|
|---|
| | | throw new UserAccountException(2, "微信帐号授权失败");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String wxUnionIdExist = user.getWxUnionId();
|
|---|
| | | if (StringUtil.isNullOrEmpty(wxUnionIdExist)) {
|
|---|
| | | UserInfo newUser = userInfoMapper.getEffectiveUserInfoByWXUnionId(wxUnionId);
|
|---|
| | | if (newUser != null) {
|
|---|
| | | throw new UserAccountException(4, "该微信号已被其他帐号绑定");
|
|---|
| | | }
|
|---|
| | | } else if (wxUnionId.equals(wxUnionIdExist)) {
|
|---|
| | | throw new UserAccountException(3, "微信帐号一致无需更换");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (StringUtil.isNullOrEmpty(user.getPhone())) {
|
|---|
| | | throw new UserAccountException(5, "该帐号没有绑定手机号码，需绑定手机号码才能完成微信更换");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | UserInfo updateUserInfo = new UserInfo(uid);
|
|---|
| | | updateUserInfo.setWxName(weiXinUser.getNickname());
|
|---|
| | | updateUserInfo.setWxOpenId(weiXinUser.getOpenid());
|
|---|
| | | updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());
|
|---|
| | | updateUserInfo.setWxUnionId(weiXinUser.getUnionid());
|
|---|
| | |
|
|---|
| | | // 将默认昵称替换成微信昵称
|
|---|
| | | String defaultNickName = Constant.systemCommonConfig.getDefaultNickName();
|
|---|
| | | if (!StringUtil.isNullOrEmpty(weiXinUser.getNickname()) && !StringUtil.isNullOrEmpty(defaultNickName)
|
|---|
| | | && defaultNickName.equals(user.getNickName())) {
|
|---|
| | | updateUserInfo.setNickName(weiXinUser.getNickname());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 将默认头像替换成微信头像
|
|---|
| | | String defaultPortrait = Constant.systemCommonConfig.getDefaultPortrait();
|
|---|
| | | if (!StringUtil.isNullOrEmpty(weiXinUser.getHeadimgurl()) && !StringUtil.isNullOrEmpty(defaultPortrait)
|
|---|
| | | && defaultPortrait.equals(user.getPortrait())) {
|
|---|
| | | updateUserInfo.setPortrait(weiXinUser.getHeadimgurl());
|
|---|
| | | }
|
|---|
| | | userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);
|
|---|
| | |
|
|---|
| | | // 加入绑定记录
|
|---|
| | | UserAccountBindingHistory history = new UserAccountBindingHistory();
|
|---|
| | | history.setContent(weiXinUser.getUnionid());
|
|---|
| | | history.setType(UserAccountBindingHistory.TYPE_WX);
|
|---|
| | | history.setUid(uid);
|
|---|
| | |
|
|---|
| | | // 之前已经绑定电话号码
|
|---|
| | | if (!StringUtil.isNullOrEmpty(user.getWxUnionId()))
|
|---|
| | | history.setFirst(false);
|
|---|
| | | else
|
|---|
| | | history.setFirst(true);
|
|---|
| | | userAccountBindingHistoryService.addUserAccountBindingHistory(history);
|
|---|
| | |
|
|---|
| | | userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_WX);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
