|
|
@@ -101,14 +101,14 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
@Autowired
|
|
|
private SysMessageTemplateService messageTemplateService;
|
|
|
|
|
|
- private String getCurrentAreaCode(String province,String city,String area){
|
|
|
+ private String getCurrentAreaCode(String province, String city, String area) {
|
|
|
String userWorkNumber = "";
|
|
|
if (!area.isEmpty()) {
|
|
|
userWorkNumber += area; // 使用县
|
|
|
} else if (!city.isEmpty()) {
|
|
|
- userWorkNumber += city.substring(0,4); // 使用市
|
|
|
+ userWorkNumber += city.substring(0, 4); // 使用市
|
|
|
} else if (!province.isEmpty()) {
|
|
|
- userWorkNumber += province.substring(0,2); // 使用省
|
|
|
+ userWorkNumber += province.substring(0, 2); // 使用省
|
|
|
}
|
|
|
return userWorkNumber;
|
|
|
}
|
|
|
@@ -147,26 +147,26 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public HttpResult getUserSelect(SysUserInfoListVo sysUserInfoListVo){
|
|
|
+ public HttpResult getUserSelect(SysUserInfoListVo sysUserInfoListVo) {
|
|
|
return HttpResult.ok(baseMapper.getUserSelect(sysUserInfoListVo));
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public Page<SysUserJzgInfoDto> getUserInfoList(Page page, SysUserInfoListVo sysUserInfoListVo) {
|
|
|
- return sysUserJzgInfoMapper.getUserInfoList(page,sysUserInfoListVo);
|
|
|
+ return sysUserJzgInfoMapper.getUserInfoList(page, sysUserInfoListVo);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public UserTransferInfoVo getTransferInfo(String userId) {
|
|
|
SysUserJzgInfo userJzgInfo = sysUserJzgInfoService.getOne(new LambdaQueryWrapper<SysUserJzgInfo>()
|
|
|
- .eq(SysUserJzgInfo::getUserId,userId));
|
|
|
+ .eq(SysUserJzgInfo::getUserId, userId));
|
|
|
SysDept dept = sysDeptService.getById(userJzgInfo.getDeptId());
|
|
|
- if(Objects.isNull(dept)){
|
|
|
+ if (Objects.isNull(dept)) {
|
|
|
throw new SystemException("人员所属机构不存在");
|
|
|
}
|
|
|
long count = sysUserJzgInfoService.count(new LambdaQueryWrapper<SysUserJzgInfo>()
|
|
|
.eq(SysUserJzgInfo::getLeaderId, userId));
|
|
|
- return new UserTransferInfoVo(userId,String.valueOf(count),dept.getName());
|
|
|
+ return new UserTransferInfoVo(userId, String.valueOf(count), dept.getName());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -175,7 +175,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
//检查用户的业务员数量
|
|
|
List<SysUserJzgInfo> list = sysUserJzgInfoService.list(new LambdaQueryWrapper<SysUserJzgInfo>()
|
|
|
.eq(SysUserJzgInfo::getLeaderId, originalUserId));
|
|
|
- list.forEach(item->{
|
|
|
+ list.forEach(item -> {
|
|
|
item.setLeaderId(userTransferVo.getTransferUserId());
|
|
|
});
|
|
|
return sysUserJzgInfoService.updateBatchById(list);
|
|
|
@@ -191,7 +191,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
SysUserJzgInfo userByUserId = sysUserJzgInfoService.getUserByUserId(userId);
|
|
|
//离职申请状态机返回
|
|
|
StateResult resign = userStateListener.ResignRequest(userByUserId);
|
|
|
- if(resign.isResult()){
|
|
|
+ if (resign.isResult()) {
|
|
|
//更新状态
|
|
|
userByUserId.setStatus(UserState.UserStateEnum.RESIGN_ING.getValue());
|
|
|
sysUserJzgInfoService.updateById(userByUserId);
|
|
|
@@ -200,10 +200,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public boolean realNameAuth(String userId){
|
|
|
+ public boolean realNameAuth(String userId) {
|
|
|
SysUserJzgInfo userByUserId = sysUserJzgInfoService.getUserByUserId(userId);
|
|
|
StateResult stateResult = userStateListener.AuthCert(userByUserId);
|
|
|
- if(stateResult.isResult()){
|
|
|
+ if (stateResult.isResult()) {
|
|
|
//更新状态
|
|
|
userByUserId.setStatus(stateResult.getCurrentState());
|
|
|
sysUserJzgInfoService.updateById(userByUserId);
|
|
|
@@ -241,9 +241,9 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
AuditCountVo auditCountVo = new AuditCountVo();
|
|
|
LambdaQueryWrapper<SysUserJzgInfo> queryWrapper1 = new LambdaQueryWrapper<>();
|
|
|
queryWrapper1.eq(StringUtils.isNotEmpty(sysUserInfoParam.getTypeAttr()), SysUserJzgInfo::getTypeAttr, sysUserInfoParam.getTypeAttr())
|
|
|
- .eq(StringUtils.isNotEmpty(sysUserInfoParam.getDeptId()),SysUserJzgInfo::getDeptId, sysUserInfoParam.getDeptId())
|
|
|
- .eq(SysUserJzgInfo::getIsDelete,0)
|
|
|
- .eq(SysUserJzgInfo::getIsEnable,0)
|
|
|
+ .eq(StringUtils.isNotEmpty(sysUserInfoParam.getDeptId()), SysUserJzgInfo::getDeptId, sysUserInfoParam.getDeptId())
|
|
|
+ .eq(SysUserJzgInfo::getIsDelete, 0)
|
|
|
+ .eq(SysUserJzgInfo::getIsEnable, 0)
|
|
|
;
|
|
|
|
|
|
queryWrapper1.eq(SysUserJzgInfo::getStatus, UserState.UserStateEnum.COMPANY_REVIEW_ING.getValue()); // 未审核
|
|
|
@@ -251,12 +251,12 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
LambdaQueryWrapper<SysUserJzgInfo> queryWrapper2 = new LambdaQueryWrapper<>();
|
|
|
queryWrapper2.eq(StringUtils.isNotEmpty(sysUserInfoParam.getTypeAttr()), SysUserJzgInfo::getTypeAttr, sysUserInfoParam.getTypeAttr())
|
|
|
- .eq(StringUtils.isNotEmpty(sysUserInfoParam.getDeptId()),SysUserJzgInfo::getDeptId, sysUserInfoParam.getDeptId())
|
|
|
- .eq(SysUserJzgInfo::getIsDelete,0)
|
|
|
- .eq(SysUserJzgInfo::getIsEnable,0)
|
|
|
+ .eq(StringUtils.isNotEmpty(sysUserInfoParam.getDeptId()), SysUserJzgInfo::getDeptId, sysUserInfoParam.getDeptId())
|
|
|
+ .eq(SysUserJzgInfo::getIsDelete, 0)
|
|
|
+ .eq(SysUserJzgInfo::getIsEnable, 0)
|
|
|
;
|
|
|
|
|
|
- queryWrapper2.eq(SysUserJzgInfo::getStatus,UserState.UserStateEnum.COMPANY_REVIEW_FAILED.getValue()); // 审核失败
|
|
|
+ queryWrapper2.eq(SysUserJzgInfo::getStatus, UserState.UserStateEnum.COMPANY_REVIEW_FAILED.getValue()); // 审核失败
|
|
|
Long failCount = sysUserJzgInfoService.count(queryWrapper2);
|
|
|
auditCountVo.setNoAuditCount(noCount);
|
|
|
auditCountVo.setFailAuditCount(failCount);
|
|
|
@@ -265,10 +265,15 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
@Override
|
|
|
public List<SysTennatVo> getTenantList(String userId) {
|
|
|
+ // 租户id
|
|
|
+ String systemCode = (String) redissonClient.getBucket(RedisKeyConstants.APP_SYSTEM_CODE + userId).get();
|
|
|
List<SysTennatVo> tenantList = sysUserJzgInfoMapper.getTenantList(userId);
|
|
|
- tenantList.forEach(item->{
|
|
|
+ tenantList.forEach(item -> {
|
|
|
String presignedObjectUrl = MinioUtils.getPresignedObjectUrl(bucketName, item.getSysIcon());
|
|
|
item.setIconAddress(presignedObjectUrl);
|
|
|
+ if (StringUtils.hasText(systemCode) && item.getSystemCode().equals(systemCode)) {
|
|
|
+ item.setDefaultValue(true);
|
|
|
+ }
|
|
|
});
|
|
|
return tenantList;
|
|
|
}
|
|
|
@@ -276,11 +281,11 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
@Override
|
|
|
public boolean validateSmsCode(String mobile, String smsCode) {
|
|
|
//校验短信验证码
|
|
|
- if(Objects.isNull(redissonClient.getBucket(RedisKeyConstants.SMS_CODE + mobile).get())){
|
|
|
+ if (Objects.isNull(redissonClient.getBucket(RedisKeyConstants.SMS_CODE + mobile).get())) {
|
|
|
throw new SystemException("短信验证码已过期");
|
|
|
}
|
|
|
String systemSmsCode = redissonClient.getBucket(RedisKeyConstants.SMS_CODE + mobile).get().toString();
|
|
|
- if(!smsCode.equals(systemSmsCode)){
|
|
|
+ if (!smsCode.equals(systemSmsCode)) {
|
|
|
throw new SystemException("短信验证码错误,请重新输入");
|
|
|
}
|
|
|
return true;
|
|
|
@@ -293,10 +298,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
.eq(SysUser::getIsDelete, 0);
|
|
|
SysUser user = sysUserService.getOne(queryWrapper);
|
|
|
// 加密密码和盐值
|
|
|
- String encryptedPassword = PasswordUtils.encode(password,user.getSalt());
|
|
|
+ String encryptedPassword = PasswordUtils.encode(password, user.getSalt());
|
|
|
|
|
|
//调试时候用 万能密码
|
|
|
- if(!password.equals("Aa159357")) {
|
|
|
+ if (!password.equals("Aa159357")) {
|
|
|
// 对比密码
|
|
|
if (!encryptedPassword.equals(user.getPassword())) {
|
|
|
return false;
|
|
|
@@ -307,10 +312,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
|
|
|
@Override
|
|
|
- public boolean realNameAuthFailed(String userId){
|
|
|
+ public boolean realNameAuthFailed(String userId) {
|
|
|
SysUserJzgInfo userByUserId = sysUserJzgInfoService.getUserByUserId(userId);
|
|
|
StateResult stateResult = userStateListener.AuthCertFailed(userByUserId);
|
|
|
- if(stateResult.isResult()){
|
|
|
+ if (stateResult.isResult()) {
|
|
|
//更新状态
|
|
|
userByUserId.setStatus(stateResult.getCurrentState());
|
|
|
sysUserJzgInfoService.updateById(userByUserId);
|
|
|
@@ -322,28 +327,28 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public HttpResult addUserInfo(SysUserVo sysUserVo) {
|
|
|
SysUser sysUser = baseMapper.getUserByMobile(sysUserVo.getMobile());
|
|
|
- String sysUserJzgInfoId = "",sysUserId = "";
|
|
|
+ String sysUserJzgInfoId = "", sysUserId = "";
|
|
|
SysUserJzgInfo sysUserJzgInfo = new SysUserJzgInfo();
|
|
|
if (!Objects.isNull(sysUser)) {
|
|
|
- verifyUser(sysUserVo.getTypeAttr(),sysUserVo.getDeptId(),sysUserVo.getIdentity(),sysUser.getId(),sysUserVo.getLeaderId(),sysUserVo.getReferrerId(),sysUserVo.getMobile());
|
|
|
+ verifyUser(sysUserVo.getTypeAttr(), sysUserVo.getDeptId(), sysUserVo.getIdentity(), sysUser.getId(), sysUserVo.getLeaderId(), sysUserVo.getReferrerId(), sysUserVo.getMobile());
|
|
|
BeanUtils.copyProperties(sysUserVo, sysUserJzgInfo);
|
|
|
sysUserJzgInfo.setUserId(sysUser.getId());
|
|
|
sysUserJzgInfoService.save(sysUserJzgInfo);
|
|
|
// 同时添加为业务员
|
|
|
if (sysUserVo.getIsAddSalesman() == 1) {
|
|
|
- addSalesmanList(sysUserJzgInfo,sysUserVo);
|
|
|
+ addSalesmanList(sysUserJzgInfo, sysUserVo);
|
|
|
}
|
|
|
sysUserJzgInfoId = sysUserJzgInfo.getId();
|
|
|
sysUserId = sysUser.getId();
|
|
|
if (sysUserVo.getOrganizationId() != null && !sysUserVo.getOrganizationId().equals("")) {
|
|
|
saveOrganization(sysUserVo.getOrganizationId(), sysUserJzgInfo.getUserId());
|
|
|
}
|
|
|
- saveFile(sysUserVo.getSfz1(), sysUserVo.getSfz2(), sysUserVo.getQualification(), sysUserVo.getContract(), sysUserVo.getApplicant(), sysUserVo.getSalaryTable(), sysUserVo.getLeaveTable(),sysUserJzgInfo.getUserId());
|
|
|
+ saveFile(sysUserVo.getSfz1(), sysUserVo.getSfz2(), sysUserVo.getQualification(), sysUserVo.getContract(), sysUserVo.getApplicant(), sysUserVo.getSalaryTable(), sysUserVo.getLeaveTable(), sysUserJzgInfo.getUserId());
|
|
|
//系统中已存在业务员
|
|
|
// throw new SystemException("用户信息已存在,无法添加");
|
|
|
} else {
|
|
|
// 如果手机号为新号 重新生成SysUser 设置默认密码
|
|
|
- SysUser sysUser1 = new SysUser(sysUserVo.getMobile(),sysUserVo.getMobile(),sysUserVo.getIdentity(),sysUserVo.getIdentityTimeStart(),sysUserVo.getIdentityTimeEnd(),null);
|
|
|
+ SysUser sysUser1 = new SysUser(sysUserVo.getMobile(), sysUserVo.getMobile(), sysUserVo.getIdentity(), sysUserVo.getIdentityTimeStart(), sysUserVo.getIdentityTimeEnd(), null);
|
|
|
this.save(sysUser1);
|
|
|
BeanUtils.copyProperties(sysUserVo, sysUserJzgInfo);
|
|
|
sysUserJzgInfo.setId(IdGenerate.nextId());
|
|
|
@@ -353,9 +358,9 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
sysUserJzgInfoService.save(sysUserJzgInfo);
|
|
|
// 同时添加为业务员
|
|
|
if (sysUserVo.getIsAddSalesman() == 1) {
|
|
|
- addSalesmanList(sysUserJzgInfo,sysUserVo);
|
|
|
- }else if(sysUserVo.getIsAddSalesman() == 0){
|
|
|
- SysUserJzgInfoSalesman sysUserJzgInfoSalesman = new SysUserJzgInfoSalesman(sysUserJzgInfo.getId(),"2");
|
|
|
+ addSalesmanList(sysUserJzgInfo, sysUserVo);
|
|
|
+ } else if (sysUserVo.getIsAddSalesman() == 0) {
|
|
|
+ SysUserJzgInfoSalesman sysUserJzgInfoSalesman = new SysUserJzgInfoSalesman(sysUserJzgInfo.getId(), "2");
|
|
|
sysUserJzgInfoSalesmanService.save(sysUserJzgInfoSalesman);
|
|
|
}
|
|
|
// 直接添加业务员
|
|
|
@@ -368,29 +373,29 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
if (sysUserVo.getOrganizationId() != null && !sysUserVo.getOrganizationId().equals("")) {
|
|
|
saveOrganization(sysUserVo.getOrganizationId(), sysUserJzgInfo.getUserId());
|
|
|
}
|
|
|
- saveFile(sysUserVo.getSfz1(), sysUserVo.getSfz2(), sysUserVo.getQualification(), sysUserVo.getContract(), sysUserVo.getApplicant(), sysUserVo.getSalaryTable(), sysUserVo.getLeaveTable(),sysUserJzgInfo.getId());
|
|
|
+ saveFile(sysUserVo.getSfz1(), sysUserVo.getSfz2(), sysUserVo.getQualification(), sysUserVo.getContract(), sysUserVo.getApplicant(), sysUserVo.getSalaryTable(), sysUserVo.getLeaveTable(), sysUserJzgInfo.getId());
|
|
|
}
|
|
|
|
|
|
//如果表单输入的银行卡号和银行名不为空,则保存银行卡信息
|
|
|
if (sysUserVo.getBankCardId() != null && sysUserVo.getBankName() != null) {
|
|
|
SysUserJzgInfoBankCard sysUserJzgInfoBankCard =
|
|
|
- new SysUserJzgInfoBankCard(sysUserId, sysUserVo.getBankCardId(), sysUserVo.getBankName(),sysUserJzgInfo.getSystemCode());
|
|
|
+ new SysUserJzgInfoBankCard(sysUserId, sysUserVo.getBankCardId(), sysUserVo.getBankName(), sysUserJzgInfo.getSystemCode());
|
|
|
sysUserJzgInfoBankCardService.save(sysUserJzgInfoBankCard);
|
|
|
}
|
|
|
//如果角色存在的话则存储角色
|
|
|
- if(!Objects.isNull(sysUserVo.getRoleIds()) && !sysUserVo.getRoleIds().isEmpty()){
|
|
|
+ if (!Objects.isNull(sysUserVo.getRoleIds()) && !sysUserVo.getRoleIds().isEmpty()) {
|
|
|
String finalSysUserId = sysUserId;
|
|
|
List<SysUserRole> sysUserRoleList = new ArrayList<>();
|
|
|
sysUserVo.getRoleIds().forEach(roleId -> {
|
|
|
- SysUserRole sysUserRole = new SysUserRole(finalSysUserId,roleId);
|
|
|
+ SysUserRole sysUserRole = new SysUserRole(finalSysUserId, roleId);
|
|
|
sysUserRoleList.add(sysUserRole);
|
|
|
});
|
|
|
sysUserRoleService.saveBatch(sysUserRoleList);
|
|
|
}
|
|
|
String resultMsg = "";
|
|
|
- if(sysUserVo.getTypeAttr().equals("2")){
|
|
|
+ if (sysUserVo.getTypeAttr().equals("2")) {
|
|
|
resultMsg = "添加成员成功";
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
resultMsg = "添加业务员成功";
|
|
|
}
|
|
|
|
|
|
@@ -398,7 +403,8 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
this.addUserMessage(baseController.getUserName(), sysUserJzgInfo, MessageCodeEnum.TEMPLATE_11);
|
|
|
return HttpResult.ok(resultMsg);
|
|
|
}
|
|
|
- private void addSalesmanList(SysUserJzgInfo sysUserJzgInfo,SysUserVo sysUserVo) {
|
|
|
+
|
|
|
+ private void addSalesmanList(SysUserJzgInfo sysUserJzgInfo, SysUserVo sysUserVo) {
|
|
|
List<SysUserJzgInfoSalesman> sysUserJzgInfoSalesmanList = new ArrayList<>();
|
|
|
// 添加后线人员
|
|
|
SysUserJzgInfoSalesman sysUserJzgInfoSalesman = new SysUserJzgInfoSalesman();
|
|
|
@@ -417,6 +423,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
/**
|
|
|
* 新增业务员消息
|
|
|
+ *
|
|
|
* @param userName
|
|
|
* @param sysUserJzgInfo
|
|
|
* @param tplCode
|
|
|
@@ -425,17 +432,17 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
// 获取消息模板 并替换内容
|
|
|
SysMessageTemplate template = messageTemplateService.getModel(tplCode);
|
|
|
Map<String, Object> valuesMap = new HashMap<>();
|
|
|
- valuesMap.put("addUser",sysUserJzgInfo.getName());
|
|
|
+ valuesMap.put("addUser", sysUserJzgInfo.getName());
|
|
|
valuesMap.put("createBy", userName);
|
|
|
- valuesMap.put("issueName","");
|
|
|
- valuesMap.put("issueNumber","");
|
|
|
- String content = StringUtils.replaceContent(template.getContent(),valuesMap);
|
|
|
+ valuesMap.put("issueName", "");
|
|
|
+ valuesMap.put("issueNumber", "");
|
|
|
+ String content = StringUtils.replaceContent(template.getContent(), valuesMap);
|
|
|
// 获取出单员
|
|
|
String operatorCode = sysUserJzgInfo.getOperatorCode();
|
|
|
// 获取接收用户
|
|
|
List<String> recerveList = new ArrayList<>();
|
|
|
userMessageTemplate.sendAddUser(sysUserJzgInfo.getId(), template.getTplName(),
|
|
|
- content, tplCode,recerveList);
|
|
|
+ content, tplCode, recerveList);
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -507,7 +514,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
if (sysUserJzgInfoBankCardVo.getAttachment() != null) {
|
|
|
SysUploadFiles sysUploadFiles = sysUploadFilesMapper.selectOne
|
|
|
(new LambdaQueryWrapper<SysUploadFiles>().eq(SysUploadFiles::getId, sysUserJzgInfoBankCardVo.getAttachment()));
|
|
|
- SysUserJzgInfoFile sysUserJzgInfoFile = new SysUserJzgInfoFile(sysUserJzgInfoBankCardVo.getAttachment(),sysUserJzgInfoBankCardVo.getUserJzgInfoId(),sysUploadFiles.getFileName());
|
|
|
+ SysUserJzgInfoFile sysUserJzgInfoFile = new SysUserJzgInfoFile(sysUserJzgInfoBankCardVo.getAttachment(), sysUserJzgInfoBankCardVo.getUserJzgInfoId(), sysUploadFiles.getFileName());
|
|
|
sysUserJzgInfoFile.setId(fileId);
|
|
|
sysUserJzgInfoFile.setFileUrl(MinioUtils.getPresignedObjectUrl("jzg", sysUploadFiles.getFileName()));
|
|
|
sysUserJzgInfoFile.setFileType("bankcard");
|
|
|
@@ -549,7 +556,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
// throw new SystemException("该业务员已被禁用");
|
|
|
// }
|
|
|
BeanUtils.copyProperties(sysUserVo, sysUserJzgInfo);
|
|
|
- verifyFile(sysUserVo,sysUserJzgInfo.getId());
|
|
|
+ verifyFile(sysUserVo, sysUserJzgInfo.getId());
|
|
|
if (sysUserJzgInfo.getStatus() == 5) { // 如果状态为5 说明该业务员重新提交审核 进行业务员审核
|
|
|
StateResult stateResult = userStateListener.salesmanAuthIng(sysUserJzgInfo);
|
|
|
if (stateResult.isResult()) {
|
|
|
@@ -564,18 +571,18 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
//用户角色处理
|
|
|
List<SysRole> userRole = sysUserRoleService.getUserRole(sysUserVo.getUserId());
|
|
|
List<String> roleIds = userRole.stream().map(u -> u.getId()).collect(Collectors.toList());
|
|
|
- if(!roleIds.isEmpty()) {
|
|
|
- sysUserRoleService.deleteByUserId(sysUserVo.getUserId(),roleIds);
|
|
|
+ if (!roleIds.isEmpty()) {
|
|
|
+ sysUserRoleService.deleteByUserId(sysUserVo.getUserId(), roleIds);
|
|
|
}
|
|
|
List<SysUserRole> sysUserRoleList = new ArrayList<>();
|
|
|
- sysUserVo.getRoleIds().forEach(roleId->{
|
|
|
- SysUserRole sysUserRole = new SysUserRole(sysUserVo.getUserId(),roleId);
|
|
|
+ sysUserVo.getRoleIds().forEach(roleId -> {
|
|
|
+ SysUserRole sysUserRole = new SysUserRole(sysUserVo.getUserId(), roleId);
|
|
|
sysUserRoleList.add(sysUserRole);
|
|
|
});
|
|
|
sysUserRoleService.saveBatch(sysUserRoleList);
|
|
|
|
|
|
//修改团队信息
|
|
|
- if(sysUserVo.getOrganizationId() != null && !sysUserVo.getOrganizationId().isEmpty()) {
|
|
|
+ if (sysUserVo.getOrganizationId() != null && !sysUserVo.getOrganizationId().isEmpty()) {
|
|
|
sysOrganizationUserLinkService.remove(new LambdaQueryWrapper<SysOrganizationUserLink>()
|
|
|
.eq(SysOrganizationUserLink::getUserId, sysUserVo.getUserId())
|
|
|
.eq(SysOrganizationUserLink::getOrganizationId, sysUserVo.getOrganizationId()));
|
|
|
@@ -596,25 +603,25 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
throw new SystemException("该用户不存在");
|
|
|
}
|
|
|
SysUser sysUser = sysUserService.getById(sysUserJzgInfo.getUserId());
|
|
|
- if(sysUser == null){
|
|
|
+ if (sysUser == null) {
|
|
|
throw new SystemException("该用户不存在");
|
|
|
}
|
|
|
sysUserJzgInfo.setMobile(sysUser.getMobile());
|
|
|
SysDept dept = sysDeptService.getById(sysUserJzgInfo.getDeptId());
|
|
|
- if(!Objects.isNull(dept)){
|
|
|
+ if (!Objects.isNull(dept)) {
|
|
|
sysUserJzgInfo.setDeptName(dept.getName());
|
|
|
}
|
|
|
List<String> areaList = new ArrayList<>();
|
|
|
- if(!Objects.isNull(sysUserJzgInfo.getProvince()) && !sysUserJzgInfo.getProvince().isEmpty()){
|
|
|
+ if (!Objects.isNull(sysUserJzgInfo.getProvince()) && !sysUserJzgInfo.getProvince().isEmpty()) {
|
|
|
areaList.add(sysUserJzgInfo.getProvince());
|
|
|
- }else if(!Objects.isNull(sysUserJzgInfo.getCity()) && !sysUserJzgInfo.getCity().isEmpty()) {
|
|
|
+ } else if (!Objects.isNull(sysUserJzgInfo.getCity()) && !sysUserJzgInfo.getCity().isEmpty()) {
|
|
|
areaList.add(sysUserJzgInfo.getCity());
|
|
|
- }else if(!Objects.isNull(sysUserJzgInfo.getDistrict()) && !sysUserJzgInfo.getDistrict().isEmpty()){
|
|
|
+ } else if (!Objects.isNull(sysUserJzgInfo.getDistrict()) && !sysUserJzgInfo.getDistrict().isEmpty()) {
|
|
|
areaList.add(sysUserJzgInfo.getDistrict());
|
|
|
}
|
|
|
- if(areaList.size() == 0){
|
|
|
+ if (areaList.size() == 0) {
|
|
|
sysUserJzgInfo.setRegion("");
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
List<SysArea> sysAreas = sysAreaService.queryAllByAreaCode(areaList);
|
|
|
String region = "";
|
|
|
for (int i = 0; i < sysAreas.size(); i++) {
|
|
|
@@ -624,7 +631,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
if (!Objects.isNull(sysUserJzgInfo.getLeaderId()) && !sysUserJzgInfo.getLeaderId().equals("")) {
|
|
|
SysUserJzgInfo userJzgInfo = sysUserJzgInfoService.getById(sysUserJzgInfo.getLeaderId());
|
|
|
- if(Objects.nonNull(userJzgInfo)){
|
|
|
+ if (Objects.nonNull(userJzgInfo)) {
|
|
|
sysUserJzgInfo.setLeaderName(userJzgInfo.getName());
|
|
|
}
|
|
|
}
|
|
|
@@ -636,10 +643,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
(new LambdaQueryWrapper<SysOrganizationUserLink>().eq(SysOrganizationUserLink::getUserId, sysUserJzgInfo.getUserId()));
|
|
|
|
|
|
|
|
|
- if(!Objects.isNull(sysOrganizationUserLink)){
|
|
|
+ if (!Objects.isNull(sysOrganizationUserLink)) {
|
|
|
String organizationId = sysOrganizationUserLink.getOrganizationId();
|
|
|
SysOrganization sysOrganization = sysOrganizationService.getById(organizationId);
|
|
|
- if(!Objects.isNull(sysOrganization)){
|
|
|
+ if (!Objects.isNull(sysOrganization)) {
|
|
|
String organizationName = sysOrganizationService.getById(organizationId).getName();
|
|
|
sysUserJzgInfo.setOrganizationId(organizationId);
|
|
|
sysUserJzgInfo.setOrganizationName(organizationName);
|
|
|
@@ -655,9 +662,9 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
|
|
|
List<SysUserJzgInfoFile> sysUserJzgInfoFile = sysUserJzgInfoFileService.list
|
|
|
- (new LambdaQueryWrapper<SysUserJzgInfoFile>().eq(SysUserJzgInfoFile::getUserId,sysUserJzgInfo.getId()));
|
|
|
+ (new LambdaQueryWrapper<SysUserJzgInfoFile>().eq(SysUserJzgInfoFile::getUserId, sysUserJzgInfo.getId()));
|
|
|
sysUserJzgInfo.setFileList(sysUserJzgInfoFile);
|
|
|
- List<SysUserJzgInfoBankCardDto> sysUserJzgInfoBankCardDto = sysUserJzgInfoBankCardService.getBankCardByUserId(sysUserJzgInfo.getId(),baseController.getUserSystemCode());
|
|
|
+ List<SysUserJzgInfoBankCardDto> sysUserJzgInfoBankCardDto = sysUserJzgInfoBankCardService.getBankCardByUserId(sysUserJzgInfo.getId(), baseController.getUserSystemCode());
|
|
|
sysUserJzgInfo.setBankCardList(sysUserJzgInfoBankCardDto);
|
|
|
if (!sysUserJzgInfoBankCardDto.isEmpty()) {
|
|
|
sysUserJzgInfo.setBankCardNumber(sysUserJzgInfoBankCardDto.get(0).getBankCardNumber());
|
|
|
@@ -667,14 +674,16 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
|
|
|
|
|
|
- public void verifyUser(String typeAttr,String deptId,String identity,String userId,String leaderId,String referrerId,String mobile){
|
|
|
+ public void verifyUser(String typeAttr, String deptId, String identity, String userId, String leaderId, String referrerId, String mobile) {
|
|
|
SysDept sysDept = sysDeptService.getById(deptId);
|
|
|
|
|
|
- List<SysUserJzgInfo> sysUserJzgInfos = sysUserJzgInfoService.getUserInfoByIdentity(identity, userId);
|
|
|
+ List<SysUserJzgInfo> sysUserJzgInfos = sysUserJzgInfoService.getUserInfoByIdentity(identity, userId);
|
|
|
SysUserJzgInfo sysUserJzgInfoByLeaderId = sysUserJzgInfoService.getOne
|
|
|
- (new LambdaQueryWrapper<SysUserJzgInfo>().eq(SysUserJzgInfo::getId,leaderId).eq(SysUserJzgInfo::getIsDelete,0));
|
|
|
+ (new LambdaQueryWrapper<SysUserJzgInfo>().eq(SysUserJzgInfo::getId, leaderId)
|
|
|
+ .eq(SysUserJzgInfo::getIsDelete, 0));
|
|
|
SysUserJzgInfo sysUserJzgInfoByReferrerId = sysUserJzgInfoService.getOne
|
|
|
- (new LambdaQueryWrapper<SysUserJzgInfo>().eq(SysUserJzgInfo::getId,referrerId).eq(SysUserJzgInfo::getIsDelete,0));
|
|
|
+ (new LambdaQueryWrapper<SysUserJzgInfo>().eq(SysUserJzgInfo::getId, referrerId)
|
|
|
+ .eq(SysUserJzgInfo::getIsDelete, 0));
|
|
|
SysUserJzgInfo userByMobile = sysUserJzgInfoService.getUserByMobile(mobile);
|
|
|
|
|
|
if (sysUserJzgInfos.size() > 0) {
|
|
|
@@ -683,7 +692,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
if (sysDept == null) {
|
|
|
throw new SystemException("所选机构不存在");
|
|
|
}
|
|
|
- if(!typeAttr.equals("2")) {
|
|
|
+ if (!typeAttr.equals("2")) {
|
|
|
if (sysUserJzgInfoByLeaderId == null) {
|
|
|
throw new SystemException("所选管理员不存在");
|
|
|
}
|
|
|
@@ -691,7 +700,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
throw new SystemException("所选推荐人不存在");
|
|
|
}
|
|
|
}
|
|
|
- if(Objects.nonNull(userByMobile)){
|
|
|
+ if (Objects.nonNull(userByMobile)) {
|
|
|
throw new ValidateException("手机号已存在无法添加");
|
|
|
}
|
|
|
}
|
|
|
@@ -704,7 +713,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
sysOrganizationUserLinkService.save(sysOrganizationUserLink);
|
|
|
}
|
|
|
|
|
|
- public void saveFile(String sfz1, String sfz2, String qualification, String contract, String applicant, String salaryTable, String leaveTable,String userId) {
|
|
|
+ public void saveFile(String sfz1, String sfz2, String qualification, String contract, String applicant, String salaryTable, String leaveTable, String userId) {
|
|
|
saveSingleFile(sfz1, "sfz1", userId);
|
|
|
saveSingleFile(sfz2, "sfz2", userId);
|
|
|
saveSingleFile(qualification, "qualification", userId);
|
|
|
@@ -713,6 +722,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
saveSingleFile(salaryTable, "salary", userId);
|
|
|
saveSingleFile(leaveTable, "leave", userId);
|
|
|
}
|
|
|
+
|
|
|
private void saveSingleFile(String fileId, String fileType, String userId) {
|
|
|
if (!Objects.isNull(fileId) && !fileId.isEmpty()) {
|
|
|
SysUploadFiles sysUploadFiles = sysUploadFilesMapper.selectOne(
|
|
|
@@ -724,16 +734,16 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public boolean uploadFile(String fileId,String fileType,String userId){
|
|
|
+ public boolean uploadFile(String fileId, String fileType, String userId) {
|
|
|
List<SysUserJzgInfoFile> sysUserJzgInfoFiles = sysUserJzgInfoFileService.list(
|
|
|
(new LambdaQueryWrapper<SysUserJzgInfoFile>().eq(SysUserJzgInfoFile::getUserId, userId)
|
|
|
.eq(SysUserJzgInfoFile::getFileType, fileType)));
|
|
|
- if(sysUserJzgInfoFiles.size()>0) {
|
|
|
+ if (sysUserJzgInfoFiles.size() > 0) {
|
|
|
sysUserJzgInfoFileService.removeBatchByIds(sysUserJzgInfoFiles);
|
|
|
}
|
|
|
SysUploadFiles sysUploadFiles = sysUploadFilesMapper.selectOne
|
|
|
(new LambdaQueryWrapper<SysUploadFiles>().eq(SysUploadFiles::getId, fileId));
|
|
|
- if(sysUploadFiles != null) {
|
|
|
+ if (sysUploadFiles != null) {
|
|
|
SysUserJzgInfoFile sysUserJzgInfoFile = new SysUserJzgInfoFile(fileId, userId, sysUploadFiles.getFileName());
|
|
|
sysUserJzgInfoFile.setFileType(fileType);
|
|
|
sysUserJzgInfoFile.setFileUrl(MinioUtils.getPresignedObjectUrl("jzg", sysUploadFiles.getFileName()));
|
|
|
@@ -744,17 +754,22 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
/**
|
|
|
* 检测文件是否修改
|
|
|
+ *
|
|
|
* @return
|
|
|
*/
|
|
|
- public boolean checkFileModify(List<SysUserJzgInfoFile> fileList,String fileType,String fileId){
|
|
|
- if(fileId!=null && !fileId.isEmpty()) {
|
|
|
- List<SysUserJzgInfoFile> collect = fileList.stream().filter(x -> x.getId().equals(fileId) && x.getFileType().equals(fileType)).collect(Collectors.toList());
|
|
|
+ public boolean checkFileModify(List<SysUserJzgInfoFile> fileList, String fileType, String fileId) {
|
|
|
+ if (fileId != null && !fileId.isEmpty()) {
|
|
|
+ List<SysUserJzgInfoFile> collect = fileList.stream()
|
|
|
+ .filter(x -> x.getId().equals(fileId) && x.getFileType().equals(fileType))
|
|
|
+ .collect(Collectors.toList());
|
|
|
if (collect.size() > 0) {
|
|
|
return false;
|
|
|
}
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
//如果传入的文件id为空 , 判断是否存在文件 如果存在则删除
|
|
|
- List<SysUserJzgInfoFile> collect = fileList.stream().filter(x -> x.getFileType().equals(fileType)).collect(Collectors.toList());
|
|
|
+ List<SysUserJzgInfoFile> collect = fileList.stream()
|
|
|
+ .filter(x -> x.getFileType().equals(fileType))
|
|
|
+ .collect(Collectors.toList());
|
|
|
if (collect.size() > 0) {
|
|
|
sysUserJzgInfoFileService.removeBatchByIds(collect);
|
|
|
}
|
|
|
@@ -764,44 +779,44 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
- public void verifyFile(SysUserVo sysUserVo,String userId){
|
|
|
+ public void verifyFile(SysUserVo sysUserVo, String userId) {
|
|
|
List<SysUserJzgInfoFile> fileList = sysUserJzgInfoFileService.list(new LambdaQueryWrapper<SysUserJzgInfoFile>()
|
|
|
.eq(SysUserJzgInfoFile::getUserId, userId));
|
|
|
- if(checkFileModify(fileList,"sfz1",sysUserVo.getSfz1())){
|
|
|
- uploadFile(sysUserVo.getSfz1(),"sfz1",userId);
|
|
|
+ if (checkFileModify(fileList, "sfz1", sysUserVo.getSfz1())) {
|
|
|
+ uploadFile(sysUserVo.getSfz1(), "sfz1", userId);
|
|
|
}
|
|
|
- if(checkFileModify(fileList,"sfz2",sysUserVo.getSfz2())){
|
|
|
- uploadFile(sysUserVo.getSfz2(),"sfz2",userId);
|
|
|
+ if (checkFileModify(fileList, "sfz2", sysUserVo.getSfz2())) {
|
|
|
+ uploadFile(sysUserVo.getSfz2(), "sfz2", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"qualification",sysUserVo.getQualification())){
|
|
|
- uploadFile(sysUserVo.getQualification(),"qualification",userId);
|
|
|
+ if (checkFileModify(fileList, "qualification", sysUserVo.getQualification())) {
|
|
|
+ uploadFile(sysUserVo.getQualification(), "qualification", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"contract",sysUserVo.getContract())){
|
|
|
- uploadFile(sysUserVo.getContract(),"contract",userId);
|
|
|
+ if (checkFileModify(fileList, "contract", sysUserVo.getContract())) {
|
|
|
+ uploadFile(sysUserVo.getContract(), "contract", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"applicant",sysUserVo.getApplicant())){
|
|
|
- uploadFile(sysUserVo.getApplicant(),"applicant",userId);
|
|
|
+ if (checkFileModify(fileList, "applicant", sysUserVo.getApplicant())) {
|
|
|
+ uploadFile(sysUserVo.getApplicant(), "applicant", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"salaryTable",sysUserVo.getSalaryTable())){
|
|
|
- uploadFile(sysUserVo.getSalaryTable(),"salaryTable",userId);
|
|
|
+ if (checkFileModify(fileList, "salaryTable", sysUserVo.getSalaryTable())) {
|
|
|
+ uploadFile(sysUserVo.getSalaryTable(), "salaryTable", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"leaveTable",sysUserVo.getLeaveTable())){
|
|
|
- uploadFile(sysUserVo.getLeaveTable(),"leaveTable",userId);
|
|
|
+ if (checkFileModify(fileList, "leaveTable", sysUserVo.getLeaveTable())) {
|
|
|
+ uploadFile(sysUserVo.getLeaveTable(), "leaveTable", userId);
|
|
|
}
|
|
|
|
|
|
- if(checkFileModify(fileList,"bankCard",sysUserVo.getBankCard())){
|
|
|
- uploadFile(sysUserVo.getBankCard(),"bankCard",userId);
|
|
|
+ if (checkFileModify(fileList, "bankCard", sysUserVo.getBankCard())) {
|
|
|
+ uploadFile(sysUserVo.getBankCard(), "bankCard", userId);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public Object getHistoryData(String id) {
|
|
|
- return sysUserJzgInfoService.getById(id);
|
|
|
+ return sysUserJzgInfoService.getById(id);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -813,6 +828,12 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
public SalesmanVo getUserInfoBySystemCodeAndUserId(String userId) {
|
|
|
return sysUserJzgInfoMapper.getUserInfoBySystemCodeAndUserId(userId);
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void setTenantList(String systemCode, String userId) {
|
|
|
+ redissonClient.getBucket(RedisKeyConstants.APP_SYSTEM_CODE + userId).set(systemCode);
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|
|
|
|