|
|
@@ -23,10 +23,7 @@ import com.ydtech.handler.CreateAndUpdateMetaObjectHandler;
|
|
|
import com.ydtech.modules.admin.components.UnionPayRequestApiComponent;
|
|
|
import com.ydtech.modules.admin.components.request.UnionPayRequest;
|
|
|
import com.ydtech.modules.admin.components.response.UnionPayResponse;
|
|
|
-import com.ydtech.modules.admin.constants.QuMarks;
|
|
|
-import com.ydtech.modules.admin.constants.RoleConstants;
|
|
|
-import com.ydtech.modules.admin.constants.UserAgentStatus;
|
|
|
-import com.ydtech.modules.admin.constants.UserWorkStatus;
|
|
|
+import com.ydtech.modules.admin.constants.*;
|
|
|
import com.ydtech.modules.admin.dao.SysDeptMapper;
|
|
|
import com.ydtech.modules.admin.dao.SysPartnerMapper;
|
|
|
import com.ydtech.modules.admin.dao.SysUserLinkAreaMapper;
|
|
|
@@ -51,6 +48,7 @@ import com.ydtech.modules.esm.service.EsmUserImageService;
|
|
|
import com.ydtech.modules.esm.service.EsmUserReferrerService;
|
|
|
import com.ydtech.modules.message.constants.MessageTypeConstants;
|
|
|
import com.ydtech.modules.message.service.MessageSecretaryService;
|
|
|
+import com.ydtech.modules.protocol.utils.AssertionUtils;
|
|
|
import com.ydtech.security.utils.PasswordUtils;
|
|
|
import com.ydtech.utils.IDCardUtils;
|
|
|
import com.ydtech.utils.StringUtils;
|
|
|
@@ -153,6 +151,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
@Value("${httpUrl}")
|
|
|
private String httpUrl;
|
|
|
+
|
|
|
@Override
|
|
|
public IPage<SysUserBaseVO> findUserList(PageDto<SysUserDto> pageDto) {
|
|
|
PageVo<SysUserBaseVO> pageVo = new PageVo();
|
|
|
@@ -325,15 +324,15 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
return HttpResult.error("手机号不能为空");
|
|
|
}
|
|
|
// if ("0".equals(type)) { // 0 登录 1 注册
|
|
|
- SysUser sysUser = this.findByPhone(phone);
|
|
|
- if (sysUser == null) {
|
|
|
- return HttpResult.error("手机号不存在!");
|
|
|
- }
|
|
|
+ SysUser sysUser = this.findByPhone(phone);
|
|
|
+ if (sysUser == null) {
|
|
|
+ return HttpResult.error("手机号不存在!");
|
|
|
+ }
|
|
|
// }
|
|
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
String timeCreate = simpleDateFormat.format(sysUser.getCreateTime());
|
|
|
String userId = sysUser.getId();
|
|
|
- List<SysUserTrack> sysUserTracks = sysUserTrackService.list(new LambdaQueryWrapper<SysUserTrack>().eq(SysUserTrack::getUserId,userId).orderByDesc(SysUserTrack::getApproveTime));
|
|
|
+ List<SysUserTrack> sysUserTracks = sysUserTrackService.list(new LambdaQueryWrapper<SysUserTrack>().eq(SysUserTrack::getUserId, userId).orderByDesc(SysUserTrack::getApproveTime));
|
|
|
SysUserTrack sysUserTrack = sysUserTracks.get(0);
|
|
|
|
|
|
Integer type = sysUser.getType();
|
|
|
@@ -365,7 +364,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
Map params = new HashMap();//请求参数
|
|
|
params.put("mobile", phone);//接收短信的手机号码
|
|
|
params.put("tpl_id", "265910");//短信模板ID,请参考个人中心短信模板设置
|
|
|
- params.put("vars",varsJson);
|
|
|
+ params.put("vars", varsJson);
|
|
|
params.put("key", "fbe7b165e9e13e52f3b1f2654eab9c0e");//应用APPKEY(应用详细页查询)
|
|
|
params.put("dtype", "json");//返回数据的格式,xml或json,默认json
|
|
|
|
|
|
@@ -967,14 +966,14 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
esmUserImageService.saveBatch(esmUserImages);
|
|
|
}
|
|
|
SpringUtil.getBean(RecordUserUtils.class).addRecord(userId, userId);
|
|
|
- return HttpResult.ok("新增成功",sysUserMapper.selectById(userId));
|
|
|
+ return HttpResult.ok("新增成功", sysUserMapper.selectById(userId));
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public HttpResult saveUserInfo1(SysUser2Vo sysUserVo) {
|
|
|
|
|
|
- log.info("添加团队入参:{}",sysUserVo);
|
|
|
+ log.info("添加团队入参:{}", sysUserVo);
|
|
|
SysUser sysUser = sysUserVo.getSysUser();
|
|
|
sysUser.setType(3);
|
|
|
sysUser.setCreateTime(new Date());
|
|
|
@@ -1130,7 +1129,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
esmUserImageService.saveBatch(esmUserImages);
|
|
|
}
|
|
|
SpringUtil.getBean(RecordUserUtils.class).addRecord(userId, userId);
|
|
|
- return HttpResult.ok("新增成功",sysUserMapper.selectById(userId));
|
|
|
+ return HttpResult.ok("新增成功", sysUserMapper.selectById(userId));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -1234,6 +1233,14 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
userId = sysUser.getId();
|
|
|
updateById(sysUser);
|
|
|
}
|
|
|
+
|
|
|
+ if(StringUtils.isEmpty(sysUser.getLeaderId())){
|
|
|
+ SysUser leaderUser = baseMapper.getByRoleIdAndDeptId("21", sysUser.getDeptId());
|
|
|
+ sysUser.setLeaderId(leaderUser.getLeaderId());
|
|
|
+ sysUser.setLeaderName(leaderUser.getLeaderName());
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
SysUserInfo sysUserInfo = sysUserVo.getSysUserInfo();
|
|
|
sysUserInfo.setId(userId);
|
|
|
sysUserInfoService.saveOrUpdate(sysUserInfo);
|
|
|
@@ -1241,6 +1248,17 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
sysUser.setStatus(sysUserVo.getSysUser().getStatus());
|
|
|
updateById(sysUser);
|
|
|
|
|
|
+ SysDept sysDept = sysDeptService.getById(sysUser.getDeptId());
|
|
|
+ // 渠道负责人更新数据
|
|
|
+ if (ManagementSource.MS_01.getCode().equals(sysDept.getManagementSource()) && "21".equals(sysUser.getRoleId())) {
|
|
|
+ boolean update = lambdaUpdate()
|
|
|
+ .set(SysUser::getLeaderId, sysUser.getLeaderId())
|
|
|
+ .set(SysUser::getLeaderName, sysUser.getLeaderName())
|
|
|
+ .eq(SysUser::getDeptId, sysDept.getId())
|
|
|
+ .update();
|
|
|
+ AssertionUtils.isSucceed(update, "出单员数据更新失败");
|
|
|
+ }
|
|
|
+
|
|
|
//角色配置
|
|
|
SysUserRole sysUserRole = sysUserRoleService.selectByUserId(userId);
|
|
|
sysUserRole.setRoleId(StringUtils.toLong(sysUser.getRoleId()));
|
|
|
@@ -1361,10 +1379,29 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
userId = sysUser.getId();
|
|
|
updateById(sysUser);
|
|
|
}
|
|
|
+
|
|
|
+ if(StringUtils.isEmpty(sysUser.getLeaderId())){
|
|
|
+ SysUser leaderUser = baseMapper.getByRoleIdAndDeptId("21", sysUser.getDeptId());
|
|
|
+ sysUser.setLeaderId(leaderUser.getLeaderId());
|
|
|
+ sysUser.setLeaderName(leaderUser.getLeaderName());
|
|
|
+ }
|
|
|
+
|
|
|
SysUserInfo sysUserInfo = sysUserVo.getSysUserInfo();
|
|
|
sysUserInfo.setId(userId);
|
|
|
sysUserInfoService.saveOrUpdate(sysUserInfo);
|
|
|
} else {
|
|
|
+
|
|
|
+ SysDept sysDept = sysDeptService.getById(sysUser.getDeptId());
|
|
|
+ // 渠道负责人更新数据
|
|
|
+ if (ManagementSource.MS_01.getCode().equals(sysDept.getManagementSource()) && "21".equals(sysUser.getRoleId())) {
|
|
|
+ boolean update = lambdaUpdate()
|
|
|
+ .set(SysUser::getLeaderId, sysUser.getLeaderId())
|
|
|
+ .set(SysUser::getLeaderName, sysUser.getLeaderName())
|
|
|
+ .eq(SysUser::getDeptId, sysDept.getId())
|
|
|
+ .update();
|
|
|
+ AssertionUtils.isSucceed(update, "出单员数据更新失败");
|
|
|
+ }
|
|
|
+
|
|
|
sysUser.setStatus(sysUserVo.getSysUser().getStatus());
|
|
|
// 设置跳过填充
|
|
|
CreateAndUpdateMetaObjectHandler.setSkipFill(true);
|
|
|
@@ -2291,7 +2328,6 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
@Override
|
|
|
public HttpResult updateManagementPersonnel(UpdateManagementDto managementDto) {
|
|
|
try {
|
|
|
@@ -2324,11 +2360,12 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
public List<SysUser> findDxUserList() {
|
|
|
return sysUserMapper.findDxUserList();
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
- * @version
|
|
|
- * @author: hxl
|
|
|
- * @Date: 2024/9/25 19:23
|
|
|
- * @Description: 查询用户管理的电销组员
|
|
|
+ * @version
|
|
|
+ * @author: hxl
|
|
|
+ * @Date: 2024/9/25 19:23
|
|
|
+ * @Description: 查询用户管理的电销组员
|
|
|
*/
|
|
|
@Override
|
|
|
public List<String> getGroupByUserId(String userId) {
|
|
|
@@ -2353,11 +2390,11 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
List<SysDeptTreeVo> sysDeptTreeVos = BeanUtil.copyToList(sysDeptList, SysDeptTreeVo.class);
|
|
|
Map<String, List<SysDeptTreeVo>> map = sysDeptTreeVos.stream().sorted(Comparator.comparing(SysDeptTreeVo::getId)).collect(Collectors.groupingBy(SysDeptTreeVo::getParentId));
|
|
|
sysDeptTreeVos.forEach(i -> {
|
|
|
- if(map.get(i.getId()) ==null ){
|
|
|
+ if (map.get(i.getId()) == null) {
|
|
|
List<SysUser> orDefault = groupedByDeptId.getOrDefault(i.getId(), new ArrayList<>());
|
|
|
List<SysDeptTreeVo> sysDeptTreeVos1 = BeanUtil.copyToList(orDefault, SysDeptTreeVo.class);
|
|
|
i.setChildren(sysDeptTreeVos1);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
i.setChildren(map.getOrDefault(i.getId(), new ArrayList<>()));
|
|
|
i.setDeptCount(i.getChildren().size());
|
|
|
}
|
|
|
@@ -2366,8 +2403,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
|
|
|
return sysDeptTreeVos;
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 获取人员数
|
|
|
+ *
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
@@ -2403,7 +2442,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
sysPartnerDto.setLevel(sysUser.getLevel());
|
|
|
sysPartnerService.insert(sysPartnerDto);
|
|
|
}
|
|
|
- } else if (type == 2){
|
|
|
+ } else if (type == 2) {
|
|
|
SysDept sysDept = sysDeptService.getById(sysUser.getDeptId());
|
|
|
SysDept sysDeptParent = sysDeptService.getById(sysDept.getParentId());
|
|
|
SysUser sysUserReferrerId = this.getById(sysUser.getReferrerId());
|
|
|
@@ -2446,7 +2485,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
int noCount = 3;
|
|
|
//根据机构号获取userid最大值,不需要加人员类型判断 从sys_user获取
|
|
|
String maxId = this.findMaxId(recommender.getDeptId());
|
|
|
- String nextPK = StringUtils.isNullOrEmpty(maxId)? recommender.getDeptId() + "001"
|
|
|
+ String nextPK = StringUtils.isNullOrEmpty(maxId) ? recommender.getDeptId() + "001"
|
|
|
: IdGenerate.nextCode(maxId, noCount);
|
|
|
SysUser sysUser = new SysUser();
|
|
|
sysUser.setId(nextPK);
|
|
|
@@ -2496,13 +2535,13 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
request.setPhoneNo(dto.getMobile());
|
|
|
request.setCertNo(dto.getIdentity());
|
|
|
UnionPayResponse response = unionPayRequestApiComponent.threeFactorVerifyRequest(request);
|
|
|
- if (response != null&&!"00".equals(response.getRespCode())) {
|
|
|
- msg = "认证信息不一致:"+response.getDetailRespMsg();
|
|
|
+ if (response != null && !"00".equals(response.getRespCode())) {
|
|
|
+ msg = "认证信息不一致:" + response.getDetailRespMsg();
|
|
|
status = UserAgentStatus.UAS_2.getCode();
|
|
|
user.setFactorVerify(2); // 认证失败 即未认证状态
|
|
|
userAgentVo.setStatus(status);
|
|
|
userAgentVo.setDesc(msg);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
msg = "认证成功";
|
|
|
status = UserAgentStatus.UAS_1.getCode();
|
|
|
user.setFactorVerify(1);
|
|
|
@@ -2548,7 +2587,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
SysUserInfo info = sysUserInfoService.getById(sysUser.getId());
|
|
|
SysUserAgentVo userAgentVo = new SysUserAgentVo();
|
|
|
userAgentVo.setSysUser(user);
|
|
|
- if (Objects.nonNull(info)){
|
|
|
+ if (Objects.nonNull(info)) {
|
|
|
userAgentVo.setSysUserInfo(info);
|
|
|
}
|
|
|
|
|
|
@@ -2558,11 +2597,11 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
if (Objects.nonNull(track)) {
|
|
|
userAgentVo.setDesc(track.getApproveMess());
|
|
|
}
|
|
|
- } else if(UserWorkStatus.UWS_3.getCode().equals(user.getStatus())){
|
|
|
- userAgentVo.setDesc(sysUserTrackService.getApproveMessByUserId(sysUser.getId(),"1"));
|
|
|
+ } else if (UserWorkStatus.UWS_3.getCode().equals(user.getStatus())) {
|
|
|
+ userAgentVo.setDesc(sysUserTrackService.getApproveMessByUserId(sysUser.getId(), "1"));
|
|
|
}
|
|
|
List<EsmUserImageQueryVo> esmUserImageQueryVo = esmUserImageService.getEsmUserImageQueryVo(sysUser.getId());
|
|
|
- if(CollUtil.isNotEmpty(esmUserImageQueryVo)){
|
|
|
+ if (CollUtil.isNotEmpty(esmUserImageQueryVo)) {
|
|
|
userAgentVo.setEsmUserImageVo(esmUserImageQueryVo);
|
|
|
}
|
|
|
return userAgentVo;
|
|
|
@@ -2581,10 +2620,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
UnionPayResponse response = unionPayRequestApiComponent.bankCardVerifyRequest(request);
|
|
|
String msg;
|
|
|
Integer status;
|
|
|
- if (response != null&&!"00".equals(response.getRespCode())) {
|
|
|
- msg = "认证信息不一致:"+response.getDetailRespMsg();
|
|
|
+ if (response != null && !"00".equals(response.getRespCode())) {
|
|
|
+ msg = "认证信息不一致:" + response.getDetailRespMsg();
|
|
|
status = UserAgentStatus.UAS_4.getCode();
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
msg = "银行卡认证成功";
|
|
|
status = UserAgentStatus.UAS_3.getCode();
|
|
|
SysUserBankCardVO sysUserBankCardVO = new SysUserBankCardVO();
|
|
|
@@ -2620,4 +2659,8 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
|
|
|
esmUserImageService.saveBatch(esmUserImages);
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public SysUser getByRoleIdAndDeptId(String roleId, String deptId) {
|
|
|
+ return baseMapper.getByRoleIdAndDeptId(roleId, deptId);
|
|
|
+ }
|
|
|
}
|