From 6f1203d1cf895efc473fade3ab049fc30d92c618 Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期三, 26 三月 2025 16:48:23 +0800
Subject: [PATCH] 优化
---
server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java | 381 +++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 316 insertions(+), 65 deletions(-)
diff --git a/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java b/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
index 7f344ed..0fdc117 100644
--- a/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
+++ b/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
@@ -2,25 +2,31 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.config.jwt.JwtTokenUtil;
import com.doumee.core.exception.BusinessException;
-import com.doumee.core.model.LoginUserInfo;
+import com.doumee.dao.system.dto.LoginH5DTO;
+import com.doumee.service.business.third.TmsService;
+import com.doumee.service.business.third.model.LoginUserInfo;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.dao.CompanyMapper;
+import com.doumee.dao.business.dao.MemberMapper;
import com.doumee.dao.business.dao.SmsEmailMapper;
import com.doumee.dao.business.model.Company;
+import com.doumee.dao.business.model.Member;
import com.doumee.dao.business.model.SmsEmail;
import com.doumee.dao.system.SystemUserMapper;
-import com.doumee.dao.system.dto.LoginByOpenidDTO;
import com.doumee.dao.system.dto.LoginDTO;
import com.doumee.dao.system.dto.LoginPhoneDTO;
import com.doumee.dao.system.model.*;
+import com.doumee.service.business.third.model.request.TmsEmployeeListRequest;
+import com.doumee.service.business.third.model.response.TmsEmployeeListResponse;
import com.doumee.service.common.CaptchaService;
import com.doumee.service.system.*;
-import com.github.yulichang.wrapper.MPJLambdaWrapper;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.apache.shiro.authc.AuthenticationException;
@@ -31,6 +37,7 @@
import org.springframework.context.annotation.Lazy;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
@@ -49,8 +56,15 @@
@Lazy
@Autowired
private SystemUserService systemUserService;
+ @Lazy
+ @Autowired
+ private MemberMapper memberMapper;
+ @Autowired
+ private SystemDictDataBiz systemDictDataBiz;
+ @Lazy
@Autowired
private SystemUserMapper systemUserMapper;
+ @Lazy
@Autowired
private SmsEmailMapper smsEmailMapper;
@@ -65,15 +79,18 @@
@Lazy
@Autowired
private SystemPermissionService systemPermissionService;
-
+ @Lazy
@Autowired
private CaptchaService captchaService;
+ @Lazy
@Autowired
private SystemLoginLogService systemLoginLogService;
@Autowired
private CompanyMapper companyMapper;
+ @Autowired
+ private TmsService tmsService;
@Resource
private JwtTokenUtil jwtTokenUtil;
@@ -124,19 +141,9 @@
@Override
public LoginUserInfo loginByPasswordNew(LoginDTO dto, ServerHttpRequest request) {
- SystemLoginLog loginLog = new SystemLoginLog();
- loginLog.setLoginUsername(dto.getUsername());
- loginLog.setLoginTime(new Date());
- loginLog.setSystemVersion(systemVersion);
-// loginLog.setLocation(Utils.Location.getLocationString(loginLog.getIp()));
- if(request!=null&&request.getHeaders()!=null && request.getHeaders().size()>0){
- loginLog.setIp(Utils.User_Client.getIP(request));
- loginLog.setPlatform(Utils.User_Client.getPlatform(request));
- loginLog.setClientInfo(Utils.User_Client.getBrowser(request));
- loginLog.setOsInfo(Utils.User_Client.getOS(request));
- }
- loginLog.setServerIp(Utils.Server.getIP());
-// if(isDebug == null || !isDebug && dto.getCheckCode()){
+ SystemLoginLog loginLog = getInitLoginlog(dto.getUsername(),request);
+
+ if((isDebug == null || !isDebug) && (Objects.isNull(dto.getCheckCode()) || dto.getCheckCode()) ){
// 鏍￠獙楠岃瘉鐮�
try {
captchaService.check(dto.getUuid(), dto.getCode());
@@ -145,9 +152,121 @@
loginLog.setReason(e.getMessage().length() > 200 ? (e.getMessage().substring(0, 190) + "...") : e.getMessage());
loginLog.setSuccess(Boolean.FALSE);
systemLoginLogService.create(loginLog);
- throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT.getCode(),"瀵逛笉璧凤紝楠岃瘉鐮佷笉姝ｇ‘锛�");
+ throw e;
}
-// }
+ }
+ try {
+ LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),request);
+ systemLoginLogService.create(loginLog);
+ return user;
+ }catch (BusinessException e){
+ loginLog.setSuccess(Boolean.FALSE);
+ systemLoginLogService.create(loginLog);
+ throw e;
+
+ }catch (Exception e){
+ loginLog.setSuccess(Boolean.FALSE);
+ systemLoginLogService.create(loginLog);
+ throw e;
+ }
+ }
+ @Override
+ public LoginUserInfo loginH5 (LoginH5DTO dto, ServerHttpRequest request) {
+ SystemLoginLog loginLog = getInitLoginlog(dto.getUsername(),request);
+
+ if((isDebug == null || !isDebug) && (Objects.isNull(dto.getCheckCode()) || dto.getCheckCode()) ){
+ // 鏍￠獙楠岃瘉鐮�
+ try {
+ captchaService.check(dto.getUuid(), dto.getCode());
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ loginLog.setReason(e.getMessage().length() > 200 ? (e.getMessage().substring(0, 190) + "...") : e.getMessage());
+ loginLog.setSuccess(Boolean.FALSE);
+ systemLoginLogService.create(loginLog);
+ throw e;
+ }
+ }
+ LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),request);
+ systemLoginLogService.create(loginLog);
+ return user;
+ }
+
+ private SystemLoginLog getInitLoginlog(String username, ServerHttpRequest request) {
+ SystemLoginLog loginLog = new SystemLoginLog();
+ loginLog.setLoginUsername( username);
+ loginLog.setLoginTime(new Date());
+ loginLog.setSystemVersion(systemVersion);
+// loginLog.setLocation(Utils.Location.getLocationString(loginLog.getIp()));
+ if(request!=null&&request.getHeaders()!=null && request.getHeaders().size()>0){
+ loginLog.setIp(Utils.User_Client.getIP(request));
+ loginLog.setPlatform(Utils.User_Client.getPlatform(request));
+ loginLog.setClientInfo(Utils.User_Client.getBrowser(request));
+ loginLog.setOsInfo(Utils.User_Client.getOS(request));
+ loginLog.setSuccess(Boolean.TRUE);
+ }
+ loginLog.setServerIp(Utils.Server.getIP());
+ return loginLog;
+ }
+
+ @Override
+ public LoginUserInfo loginH5ByPhone(LoginPhoneDTO dto, ServerHttpRequest request) {
+ isCaptcheValide(dto.getPhone(),dto.getCode());//妫�鏌ラ獙璇佺爜
+ SystemLoginLog loginLog = getInitLoginlog(dto.getPhone(),request);
+ try{
+ LoginUserInfo userInfo = dealLoginByPwdNewBiz(null,null,dto.getPhone(),dto.getOpenid(), request );
+ systemLoginLogService.create(loginLog);
+ return userInfo;
+ }catch (BusinessException e){
+ loginLog.setSuccess(Boolean.FALSE);
+ systemLoginLogService.create(loginLog);
+ throw e;
+
+ }catch (Exception e){
+ loginLog.setSuccess(Boolean.FALSE);
+ systemLoginLogService.create(loginLog);
+ throw e;
+ }
+ }
+ private LoginUserInfo dealLoginByPwdNewBiz(String username,String pwd, String phone, String openid, ServerHttpRequest request) {
+ // 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
+ SystemUser queryDto = new SystemUser();
+ queryDto.setMobile(phone);
+ queryDto.setUsername(username);
+ queryDto.setType(Constants.memberType.internal);
+ queryDto.setDeleted(Boolean.FALSE);
+ SystemUser user = systemUserService.findOne(queryDto);
+ if (user == null) {
+ throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
+ }
+ if(!Constants.equalsInteger(user.getSource(),Constants.ZERO)){
+ throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN);
+ }
+ if(StringUtils.isNotBlank( pwd)){
+ String pppp = Utils.Secure.encryptPassword(new String(pwd), user.getSalt());
+ // 姣旇緝瀵嗙爜
+ if( !StringUtils.equals(pppp, user.getPassword())){
+ throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
+ }
+ }
+ dealOpenIdBiz(user,openid);
+ Company company = new Company();
+ if(Objects.nonNull(user.getCompanyId())){
+ company = companyMapper.selectById(user.getCompanyId());
+ }
+ // 鑾峰彇鐧诲綍鐢ㄦ埛淇℃伅
+ List<SystemRole> roles = systemRoleService.findByUserId(user.getId());
+ List<SystemPermission> permissions = systemPermissionService.findByUserId(user.getId());
+ SystemRole rt = new SystemRole();
+ rt.setDeleted(Boolean.FALSE);
+ //鏁版嵁閮ㄩ棬鏉冮檺闆嗗悎
+ user.setCompanyIdList(systemDataPermissionService.selectHighRole(new SystemDataPermission(),rt,user));
+ LoginUserInfo userInfo = LoginUserInfo.from(user, roles, permissions,company,null);
+ return userInfo;
+ }
+
+ @Override
+ public LoginUserInfo loginByPasswordForPda(LoginDTO dto, ServerHttpRequest request) {
+ SystemLoginLog loginLog =getInitLoginlog(dto.getUsername(),request);
// 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
SystemUser queryDto = new SystemUser();
queryDto.setUsername(dto.getUsername());
@@ -187,9 +306,36 @@
//濡傛灉openId涓嶄负绌�,缁戝畾璇ョ敤鎴穙penid
systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
.set(SystemUser::getOpenid,null)
- .eq(SystemUser::getType,user.getType()));
+ .set(SystemUser::getOpenidHkDate,null)
+ .set(SystemUser::getOpenidHkInfo,null)
+ .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+ .ne(SystemUser::getType,Constants.memberType.gkuser)
+ .eq(SystemUser::getOpenid,openid)
+ );
systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
.set(SystemUser::getOpenid,openid)
+ .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+ .set(SystemUser::getOpenidHkDate,null)
+ .set(SystemUser::getOpenidHkInfo,null)
+ .eq(SystemUser::getId,user.getId()));
+ }
+ }
+ private void dealOpenIdBizForGk(SystemUser user, String openid) {
+ if(StringUtils.isNotBlank(openid)){
+ //濡傛灉openId涓嶄负绌�,缁戝畾璇ョ敤鎴穙penid
+ systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
+ .set(SystemUser::getOpenid,null)
+ .set(SystemUser::getOpenidHkDate,null)
+ .set(SystemUser::getOpenidHkInfo,null)
+ .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+ .eq(SystemUser::getOpenid,openid)
+ .eq(SystemUser::getType,user.getType())
+ );
+ systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
+ .set(SystemUser::getOpenid,openid)
+ .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+ .set(SystemUser::getOpenidHkDate,null)
+ .set(SystemUser::getOpenidHkInfo,null)
.eq(SystemUser::getId,user.getId()));
}
}
@@ -197,20 +343,7 @@
@Override
public LoginUserInfo loginByPhone(LoginPhoneDTO dto, ServerHttpRequest request) {
- SystemLoginLog loginLog = new SystemLoginLog();
- loginLog.setLoginUsername(dto.getPhone());
- loginLog.setLoginTime(new Date());
- loginLog.setSystemVersion(systemVersion);
-// loginLog.setLocation(Utils.Location.getLocationString(loginLog.getIp()));
- if(request!=null&&request.getHeaders()!=null && request.getHeaders().size()>0){
- loginLog.setIp(Utils.User_Client.getIP(request));
- loginLog.setPlatform(Utils.User_Client.getPlatform(request));
- loginLog.setClientInfo(Utils.User_Client.getBrowser(request));
- loginLog.setOsInfo(Utils.User_Client.getOS(request));
- }
- loginLog.setServerIp(Utils.Server.getIP());
-
-
+ SystemLoginLog loginLog =getInitLoginlog(dto.getPhone(),request);
// 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
SystemUser queryDto = new SystemUser();
queryDto.setMobile(dto.getPhone());
@@ -256,67 +389,186 @@
// 鑾峰彇鐧诲綍鐢ㄦ埛淇℃伅
List<SystemRole> roles = systemRoleService.findByUserId(user.getId());
List<SystemPermission> permissions = systemPermissionService.findByUserId(user.getId());
-
SystemRole rt = new SystemRole();
rt.setDeleted(Boolean.FALSE);
//鏁版嵁閮ㄩ棬鏉冮檺闆嗗悎
user.setCompanyIdList(systemDataPermissionService.selectHighRole(new SystemDataPermission(),rt,user));
-
LoginUserInfo userInfo = LoginUserInfo.from(user, roles, permissions,company,null);
+ systemLoginLogService.create(loginLog);
return userInfo;
}
@Override
- public LoginUserInfo driverLogin(LoginDTO dto, ServerHttpRequest request) {
- SystemLoginLog loginLog = new SystemLoginLog();
- loginLog.setLoginUsername(dto.getUsername());
- loginLog.setLoginTime(new Date());
- loginLog.setReason("銆愬叕浼楀彿銆戝徃鏈虹鐧婚檰锛歰penid="+dto.getOpenid());
- loginLog.setSystemVersion(systemVersion);
-// loginLog.setLocation(Utils.Location.getLocationString(loginLog.getIp()));
- if(request!=null&&request.getHeaders()!=null && request.getHeaders().size()>0){
- loginLog.setIp(Utils.User_Client.getIP(request));
- loginLog.setPlatform(Utils.User_Client.getPlatform(request));
- loginLog.setClientInfo(Utils.User_Client.getBrowser(request));
- loginLog.setOsInfo(Utils.User_Client.getOS(request));
- }
- loginLog.setServerIp(Utils.Server.getIP());
+ public LoginUserInfo driverLogin(LoginH5DTO dto, ServerHttpRequest request) {
+ SystemLoginLog loginLog =getInitLoginlog(dto.getUsername(),request);
+ LoginUserInfo userInfo = dealLoginDriverBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid());
+ systemLoginLogService.create(loginLog);
+ return userInfo;
+ }
+ @Override
+ public LoginUserInfo loginDriverByPhone(LoginPhoneDTO dto, ServerHttpRequest request){
+ isCaptcheValide(dto.getPhone(),dto.getCode());//楠岃瘉鐮佹牎楠�
+ SystemLoginLog loginLog =getInitLoginlog(dto.getPhone(),request);
+ LoginUserInfo userInfo = dealLoginDriverBiz(null,null,dto.getPhone(),dto.getOpenid());
+ systemLoginLogService.create(loginLog);
+ return userInfo;
+ }
+
+ private LoginUserInfo dealLoginDriverBiz(String username,String password, String phone, String openid) {
// 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
SystemUser queryDto = new SystemUser();
- queryDto.setUsername(dto.getUsername());
+ queryDto.setUsername(username);
+ queryDto.setMobile(phone);
queryDto.setDeleted(Boolean.FALSE);
SystemUser user = systemUserService.findOne(queryDto);
if (user == null) {
throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
}
- //娉ㄥ唽鍙告満/鍔冲姟浜哄憳
- if((Constants.equalsInteger(user.getType(),Constants.ZERO)||Constants.equalsInteger(user.getType(),Constants.TWO)) && Objects.nonNull(user.getMemberId())){
+ //娉ㄥ唽鍙告満
+ if((Constants.equalsInteger(user.getType(),Constants.ZERO)
+ ||Constants.equalsInteger(user.getType(),Constants.TWO))
+ && Objects.nonNull(user.getMemberId())){
if(Constants.equalsInteger(user.getType(),Constants.TWO)){
if(Objects.isNull(user.getCompanyId())){
- throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN);
+ throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN.getCode(),"瀵逛笉璧凤紝璇ヨ处鍙蜂笉鑳界櫥褰曞徃鏈虹鍝");
}
- Company company = companyMapper.selectById(user.getCompanyId());
+ /* Company company = companyMapper.selectById(user.getCompanyId());
if(Objects.isNull(company) || Constants.equalsInteger(company.getType(),Constants.ONE)){
throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN);
- }
+ }*/
}
}else{
- throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN);
+ throw new BusinessException(ResponseStatus.NO_ALLOW_LOGIN.getCode(),"瀵逛笉璧凤紝璇ヨ处鍙蜂笉鑳界櫥褰曞徃鏈虹鍝︼紒");
}
-
-
- String pwd = Utils.Secure.encryptPassword(new String(dto.getPassword()), user.getSalt());
- // 姣旇緝瀵嗙爜
- if( !StringUtils.equals(pwd, user.getPassword())){
- throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
+ if(StringUtils.isNotBlank(password)){
+ String pwd = Utils.Secure.encryptPassword(new String(password), user.getSalt());
+ // 姣旇緝瀵嗙爜
+ if( !StringUtils.equals(pwd, user.getPassword())){
+ throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
+ }
}
- dealOpenIdBiz(user,dto.getOpenid());
+ dealOpenIdBiz(user,openid);
Company company = new Company();
if(Objects.nonNull(user.getCompanyId())){
company = companyMapper.selectById(user.getCompanyId());
}
LoginUserInfo userInfo = LoginUserInfo.from(user, null, null,company,null);
+ return userInfo;
+ }
+
+ public void isCaptcheValide( String phone, String captche) {
+ SmsEmail model = smsEmailMapper.selectOne(new QueryWrapper<SmsEmail>().lambda()
+ .eq(SmsEmail::getType, Constants.ZERO)
+ .eq(SmsEmail::getPhone, phone)
+ .eq(SmsEmail::getRemark, captche)
+ .eq(SmsEmail::getIsdeleted, Constants.ZERO)
+ );
+ if(model == null){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝楠岃瘉鐮佷笉姝ｇ‘锛岃閲嶆柊鍙戦�佸啀璇曪紒");
+ }
+ if(!Constants.equalsInteger(model.getStatus(),Constants.ZERO)){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝楠岃瘉鐮佸凡澶辨晥锛岃閲嶆柊鍙戦�佸啀璇曪紒");
+ }
+ if(model.getCreateDate() !=null &&
+ System.currentTimeMillis() - model.getCreateDate().getTime() > 3*60*1000){
+ model.setStatus(Constants.ONE);
+ model.setEditDate(new Date());
+ smsEmailMapper.updateById(model);
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝楠岃瘉鐮佸凡澶辨晥锛岃閲嶆柊鍙戦�佸啀璇晘");
+ }
+ model.setStatus(Constants.ONE);
+ model.setEditDate(new Date());
+ smsEmailMapper.updateById(model);
+ }
+
+ @Override
+ @Transactional
+ public LoginUserInfo loginDriverWithCode(LoginPhoneDTO param, ServerHttpRequest request) {
+ isCaptcheValide(param.getPhone(),param.getCode());//妫�鏌ラ獙璇佺爜
+ SystemLoginLog loginLog =getInitLoginlog(param.getPhone(),request);
+ loginLog.setServerIp(Utils.Server.getIP());
+ // 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
+ SystemUser queryDto = new SystemUser();
+ queryDto.setUsername(param.getPhone());
+ queryDto.setDeleted(Boolean.FALSE);
+ SystemUser systemUser = systemUserService.findOne(queryDto);
+ if (systemUser == null) {
+ systemUser = autoRegisterUser(Constants.memberType.driver,param.getPhone(),param.getOpenid(),true);
+ }else{
+ if(!Constants.equalsInteger(systemUser.getType(),Constants.memberType.driver)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝璇蜂娇鐢ㄦ纭殑鍙告満璐﹀彿鐧婚檰锛�");
+ }
+ }
+ dealOpenIdBiz(systemUser,param.getOpenid());
+ Company company = new Company();
+ if(Objects.nonNull(systemUser.getCompanyId())){
+ company = companyMapper.selectById(systemUser.getCompanyId());
+ }
+ LoginUserInfo userInfo = LoginUserInfo.from(systemUser, null, null,company,null);
+ systemLoginLogService.create(loginLog);
+ return userInfo;
+ }
+
+ private SystemUser autoRegisterUser(int type, String phone,String openid,boolean needMember) {
+ String salt = RandomStringUtils.randomAlphabetic(6);
+ String pwd =Utils.Secure.encryptPassword(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.INITIAL_PASSWORD).getCode(), salt);
+ Integer memberId = null;
+ if(needMember){
+ Member member = new Member();
+ member.setCreateDate(new Date());
+ member.setIsdeleted(Constants.ZERO);
+ member.setType(Constants.memberType.driver);
+ member.setPhone(phone);
+ member.setStatus(Constants.ZERO);
+ member.setOpenid(openid);
+ member.setPassward(pwd);
+ memberMapper.insert(member);
+ memberId = member.getId();
+ }
+
+ SystemUser systemUser = new SystemUser();
+ systemUser.setCreateTime(new Date());
+ systemUser.setCreateUser(1);
+ systemUser.setDeleted(Boolean.FALSE);
+ systemUser.setUsername(phone);
+ systemUser.setRealname(null);
+ systemUser.setMemberId(memberId);
+ systemUser.setMobile(phone);
+ systemUser.setSalt(salt);
+ systemUser.setPassword(pwd);
+ systemUser.setStatus(Constants.ZERO);
+ systemUser.setType(type);
+ systemUser.setSource(Constants.TWO);
+ systemUser.setOpenid(openid);
+ systemUserMapper.insert(systemUser);
+ return systemUser;
+ }
+
+ @Override
+ @Transactional
+ public LoginUserInfo loginGkUserWithCode(LoginPhoneDTO param, ServerHttpRequest request) {
+ isCaptcheValide(param.getPhone(),param.getCode());//妫�鏌ラ獙璇佺爜
+ TmsEmployeeListRequest tp = new TmsEmployeeListRequest();
+ tp.setTel(param.getPhone());
+ TmsEmployeeListResponse response = tmsService.getEmployeeList(tp);
+ if(response == null || response.getTel()==null){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝鎮ㄨ緭鍏ョ殑鎵嬫満鍙蜂笉姝ｇ‘锛�");
+ }
+ SystemLoginLog loginLog = getInitLoginlog(param.getPhone(),request);
+ // 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
+ SystemUser queryDto = new SystemUser();
+ queryDto.setUsername(param.getPhone());
+ queryDto.setType(Constants.memberType.gkuser);
+ queryDto.setDeleted(Boolean.FALSE);
+ SystemUser systemUser = systemUserService.findOne(queryDto);
+ if (systemUser == null) {
+ //鏂板绠℃帶浜哄憳鏁版嵁
+ systemUser = systemUser = autoRegisterUser(Constants.memberType.gkuser,param.getPhone(),param.getOpenid(),false);
+ }
+ dealOpenIdBizForGk(systemUser,param.getOpenid());
+ LoginUserInfo userInfo = LoginUserInfo.from(systemUser, null, null,null,null);
+ systemLoginLogService.create(loginLog);
return userInfo;
}
@@ -353,7 +605,6 @@
LoginUserInfo userInfo = LoginUserInfo.from(user, roles, permissions,company,null);
String token = jwtTokenUtil.generateToken(userInfo);
-
return token;
}
--
Gitblit v1.9.3