|
|
|
@ -1,17 +1,21 @@ |
|
|
|
package com.epmet.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.epmet.common.token.constant.LoginConstant; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
|
import com.epmet.commons.tools.redis.RedisKeys; |
|
|
|
import com.epmet.commons.tools.security.dto.TokenDto; |
|
|
|
import com.epmet.commons.tools.utils.*; |
|
|
|
import com.epmet.commons.tools.utils.CpUserDetailRedis; |
|
|
|
import com.epmet.commons.tools.utils.DateUtils; |
|
|
|
import com.epmet.commons.tools.utils.HttpClientManager; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.commons.tools.validator.PhoneValidatorUtils; |
|
|
|
import com.epmet.constant.AuthHttpUrlConstant; |
|
|
|
import com.epmet.constant.PublicUserLoginConstant; |
|
|
|
import com.epmet.constant.SmsTemplateConstant; |
|
|
|
import com.epmet.constant.ThirdApiConstant; |
|
|
|
import com.epmet.dto.PaCustomerDTO; |
|
|
|
import com.epmet.dto.PaUserDTO; |
|
|
|
import com.epmet.dto.PaUserWechatDTO; |
|
|
|
@ -32,10 +36,8 @@ import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
|
|
|
|
/** |
|
|
|
@ -68,13 +70,17 @@ public class PublicUserLoginServiceImpl implements PublicUserLoginService { |
|
|
|
public UserTokenResultDTO wxCodeToToken(PaWxCodeFormDTO formDTO) { |
|
|
|
//1.通过微信code获取用户基本信息
|
|
|
|
WxMpUser wxMpUser = this.getWxMpUser(formDTO.getWxCode()); |
|
|
|
WxCodeToTokenFormDTO dto = new WxCodeToTokenFormDTO(); |
|
|
|
dto.setWxMpUser(wxMpUser); |
|
|
|
dto.setSource(formDTO.getSource()); |
|
|
|
|
|
|
|
//2.将获取的用户基本信息初始化到数据库
|
|
|
|
Result<SaveUserResultDTO> result = epmetThirdFeignClient.saveUser(wxMpUser); |
|
|
|
String url = ThirdApiConstant.THIRD_PAUSER_SAVEUSER; |
|
|
|
Result<String> result = HttpClientManager.getInstance().sendPostByJSON(url, JSON.toJSONString(dto)); |
|
|
|
if (!result.success()) { |
|
|
|
throw new RenException(PublicUserLoginConstant.SAVE_USER_EXCEPTION); |
|
|
|
} |
|
|
|
SaveUserResultDTO resultDTO = result.getData(); |
|
|
|
SaveUserResultDTO resultDTO = JSONObject.parseObject(result.getData(), SaveUserResultDTO.class); |
|
|
|
|
|
|
|
//3.获取用户token
|
|
|
|
String token = this.generateGovWxmpToken(resultDTO.getUserId()); |
|
|
|
@ -156,19 +162,23 @@ public class PublicUserLoginServiceImpl implements PublicUserLoginService { |
|
|
|
logger.error(String.format(SEND_SMS_CODE_ERROR, formDTO.getPhone(), EpmetErrorCode.ERROR_PHONE.getCode(), EpmetErrorCode.ERROR_PHONE.getMsg())); |
|
|
|
throw new RenException(EpmetErrorCode.ERROR_PHONE.getCode()); |
|
|
|
} |
|
|
|
//2、根据手机号校验用户是否存在
|
|
|
|
Result<CustomerUserResultDTO> Result = epmetThirdFeignClient.checkPaUser(formDTO.getPhone()); |
|
|
|
if (!Result.success()) { |
|
|
|
logger.error(String.format(SEND_SMS_CODE_ERROR, formDTO.getPhone(), Result.getCode(), Result.getMsg())); |
|
|
|
throw new RenException(Result.getCode()); |
|
|
|
//2、根据数据来源和手机号校验用户是否存在
|
|
|
|
CheckPaUserFormDTO dto = new CheckPaUserFormDTO(); |
|
|
|
dto.setPhone(formDTO.getPhone()); |
|
|
|
dto.setSource(formDTO.getSource()); |
|
|
|
String url = ThirdApiConstant.THIRD_PAUSER_CHECKPAUSER; |
|
|
|
Result<String> result = HttpClientManager.getInstance().sendPostByJSON(url, JSON.toJSONString(dto)); |
|
|
|
if (!result.success()) { |
|
|
|
logger.error(String.format(SEND_SMS_CODE_ERROR, formDTO.getPhone(), result.getCode(), result.getMsg())); |
|
|
|
throw new RenException(result.getCode()); |
|
|
|
} |
|
|
|
CustomerUserResultDTO ResultDTO = Result.getData(); |
|
|
|
CustomerUserResultDTO resultDTO = JSONObject.parseObject(result.getData(), CustomerUserResultDTO.class); |
|
|
|
//登陆
|
|
|
|
if (formDTO.getIsLogon() && null == ResultDTO.getPaUserResult()) { |
|
|
|
if (formDTO.getIsLogon() && null == resultDTO.getPaUserResult()) { |
|
|
|
throw new RenException(EpmetErrorCode.PUBLIC_NOT_EXISTS.getCode()); |
|
|
|
} |
|
|
|
//注册
|
|
|
|
if (!formDTO.getIsLogon() && null != ResultDTO.getPaUserResult()) { |
|
|
|
if (!formDTO.getIsLogon() && null != resultDTO.getPaUserResult()) { |
|
|
|
throw new RenException(EpmetErrorCode.MOBILE_USED.getCode()); |
|
|
|
} |
|
|
|
//3、发送短信验证码
|
|
|
|
@ -194,13 +204,17 @@ public class PublicUserLoginServiceImpl implements PublicUserLoginService { |
|
|
|
**/ |
|
|
|
@Override |
|
|
|
public UserTokenResultDTO loginByPhone(TokenDto tokenDTO, LoginByPhoneFormDTO formDTO) { |
|
|
|
//1.根据手机号查询到用户、客户信息
|
|
|
|
Result<CustomerUserResultDTO> result = epmetThirdFeignClient.checkPaUser(formDTO.getPhone()); |
|
|
|
//1.根据数据来源和手机号查询用户、客户信息
|
|
|
|
CheckPaUserFormDTO dto = new CheckPaUserFormDTO(); |
|
|
|
dto.setPhone(formDTO.getPhone()); |
|
|
|
dto.setSource(formDTO.getSource()); |
|
|
|
String url = ThirdApiConstant.THIRD_PAUSER_CHECKPAUSER; |
|
|
|
Result<String> result = HttpClientManager.getInstance().sendPostByJSON(url, JSON.toJSONString(dto)); |
|
|
|
if (!result.success()) { |
|
|
|
logger.error(String.format("手机验证码登录异常,手机号[%s],code[%s],msg[%s]", formDTO.getPhone(), result.getCode(), result.getMsg())); |
|
|
|
throw new RenException(result.getCode()); |
|
|
|
} |
|
|
|
CustomerUserResultDTO resultDTO = result.getData(); |
|
|
|
CustomerUserResultDTO resultDTO = JSONObject.parseObject(result.getData(), CustomerUserResultDTO.class); |
|
|
|
|
|
|
|
//2.用户不存在时不允许登陆
|
|
|
|
PaUserDTO userDTO = resultDTO.getPaUserResult(); |
|
|
|
@ -236,7 +250,9 @@ public class PublicUserLoginServiceImpl implements PublicUserLoginService { |
|
|
|
visited.setUserId(userDTO.getId()); |
|
|
|
visited.setLogonUserId(tokenDTO.getUserId()); |
|
|
|
visited.setPhone(formDTO.getPhone()); |
|
|
|
Result visitedResult = epmetThirdFeignClient.saveUserVisited(visited); |
|
|
|
visited.setSource(formDTO.getSource()); |
|
|
|
String saveUserVisitedUrl = ThirdApiConstant.THIRD_PAUSERVISITED_SAVEUSERVISITED; |
|
|
|
Result<String> visitedResult = HttpClientManager.getInstance().sendPostByJSON(saveUserVisitedUrl, JSON.toJSONString(visited)); |
|
|
|
if(!visitedResult.success()){ |
|
|
|
logger.error(PublicUserLoginConstant.SAVE_VISITED_EXCEPTION); |
|
|
|
} |
|
|
|
@ -256,12 +272,16 @@ public class PublicUserLoginServiceImpl implements PublicUserLoginService { |
|
|
|
@Override |
|
|
|
public UserTokenResultDTO register(RegisterFormDTO formDTO) { |
|
|
|
//1.调用epmet-third服务，完成信息注册
|
|
|
|
Result<RegisterResultDTO> result = epmetThirdFeignClient.register(formDTO); |
|
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(AuthHttpUrlConstant.REGISTER_URL, JSON.toJSONString(formDTO)).getData(); |
|
|
|
JSONObject toResult = JSON.parseObject(data); |
|
|
|
Result result = ConvertUtils.mapToEntity(toResult, Result.class); |
|
|
|
if (!result.success()) { |
|
|
|
logger.error("调用epmet_third服务初始化用户信息失败"); |
|
|
|
logger.error(String.format("调用epmet_third服务初始化用户信息失败,数据来源[%s],手机号[%s],userId:[%S]", formDTO.getSource(), formDTO.getPhone(), formDTO.getUserId())); |
|
|
|
throw new RenException(result.getCode()); |
|
|
|
} |
|
|
|
RegisterResultDTO resultDTO = result.getData(); |
|
|
|
Object RegisterResult = result.getData(); |
|
|
|
JSONObject jsonObject = JSON.parseObject(RegisterResult.toString()); |
|
|
|
RegisterResultDTO resultDTO = ConvertUtils.mapToEntity(jsonObject, RegisterResultDTO.class); |
|
|
|
|
|
|
|
//2.直接生成一个新的token放入缓存中(不管缓存中是否存在旧的token，都重新生成)
|
|
|
|
//2-1.生成token
|
|
|
|
|
jianjun
5 years ago