|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | @Lazy | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemUserService systemUserService; | 
|---|
|  |  |  | @Lazy | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private MemberMapper memberMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemDictDataBiz systemDictDataBiz; | 
|---|
|  |  |  | @Lazy | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemUserMapper systemUserMapper; | 
|---|
|  |  |  | @Lazy | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SmsEmailMapper smsEmailMapper; | 
|---|
|  |  |  | 
|---|
|  |  |  | @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; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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(),dto.getDdUnionId(),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(),dto.getDdUnionId(),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(),dto.getDdUnionId(), 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, String ddUnionId, 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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(StringUtils.isNotBlank(openid)){ | 
|---|
|  |  |  | dealOpenIdBiz(user,openid); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(StringUtils.isNotBlank(ddUnionId)){ | 
|---|
|  |  |  | dealDDUnionIdBiz(user,ddUnionId); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | //如果openId不为空,绑定该用户openid | 
|---|
|  |  |  | 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 dealDDUnionIdBiz(SystemUser user, String ddUnionId) { | 
|---|
|  |  |  | if(StringUtils.isNotBlank(ddUnionId)){ | 
|---|
|  |  |  | //如果openId不为空,绑定该用户openid | 
|---|
|  |  |  | systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda() | 
|---|
|  |  |  | .set(SystemUser::getDdUnionId,null) | 
|---|
|  |  |  | .set(SystemUser::getOpenidHkStatus,Constants.ZERO) | 
|---|
|  |  |  | .ne(SystemUser::getType,Constants.memberType.gkuser) | 
|---|
|  |  |  | .eq(SystemUser::getDdUnionId,ddUnionId) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda() | 
|---|
|  |  |  | .set(SystemUser::getDdUnionId,ddUnionId) | 
|---|
|  |  |  | .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不为空,绑定该用户openid | 
|---|
|  |  |  | 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())); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | // 获取登录用户信息 | 
|---|
|  |  |  | 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("【公众号】司机端登陆:openid="+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; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | LoginUserInfo userInfo = LoginUserInfo.from(user, roles, permissions,company,null); | 
|---|
|  |  |  | String token = jwtTokenUtil.generateToken(userInfo); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return  token; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|