|
@@ -1067,7 +1067,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
String oldPswdEncrypt = passwordEncoder.encode(oldPwd);
|
|
String oldPswdEncrypt = passwordEncoder.encode(oldPwd);
|
|
|
if(user.getPassword().equals(oldPswdEncrypt)){
|
|
if(user.getPassword().equals(oldPswdEncrypt)){
|
|
|
user.setPassword(passwordEncoder.encode(newPwd));
|
|
user.setPassword(passwordEncoder.encode(newPwd));
|
|
@@ -2577,7 +2577,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
this.copyQuerysInParams(queryFilter);
|
|
this.copyQuerysInParams(queryFilter);
|
|
|
handleQueryFilter(queryFilter);
|
|
handleQueryFilter(queryFilter);
|
|
|
PageBean pageBean = queryFilter.getPageBean();
|
|
PageBean pageBean = queryFilter.getPageBean();
|
|
|
- if(BeanUtils.isEmpty(pageBean)){
|
|
|
|
|
|
|
+ if(BeanUtils.isEmpty(pageBean)){
|
|
|
pageBean = new PageBean(1, PageBean.WITHOUT_PAGE, false);
|
|
pageBean = new PageBean(1, PageBean.WITHOUT_PAGE, false);
|
|
|
}
|
|
}
|
|
|
IPage<User> query = baseMapper.queryByType(convert2IPage(pageBean),convert2Wrapper(queryFilter, currentModelClass()));
|
|
IPage<User> query = baseMapper.queryByType(convert2IPage(pageBean),convert2Wrapper(queryFilter, currentModelClass()));
|
|
@@ -2794,14 +2794,14 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
return groupList;
|
|
return groupList;
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 删除用户组缓存
|
|
* 删除用户组缓存
|
|
|
* @param userId
|
|
* @param userId
|
|
|
*/
|
|
*/
|
|
|
@CacheEvict(value = CacheKeyConst.EIP_UC_USER_GROUPS, key = "#userId", ignoreException = false)
|
|
@CacheEvict(value = CacheKeyConst.EIP_UC_USER_GROUPS, key = "#userId", ignoreException = false)
|
|
|
public void removeUserGroupsCache(String userId) {
|
|
public void removeUserGroupsCache(String userId) {
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -3179,7 +3179,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
return new CommonResult<UserVo>(true, "获取用户失败,"+e.getMessage()+"", null);
|
|
return new CommonResult<UserVo>(true, "获取用户失败,"+e.getMessage()+"", null);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public User getUserByMpOpenId(String wxWorkId) {
|
|
public User getUserByMpOpenId(String wxWorkId) {
|
|
|
return baseMapper.getUserByMpOpenId(wxWorkId);
|
|
return baseMapper.getUserByMpOpenId(wxWorkId);
|
|
@@ -3517,7 +3517,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
IPage<Map<String, Object>> page = null;
|
|
IPage<Map<String, Object>> page = null;
|
|
|
//如果没有传入组织条件,则获取用户默认维度下的主组织。
|
|
//如果没有传入组织条件,则获取用户默认维度下的主组织。
|
|
|
if (!hasOrgCondition) {
|
|
if (!hasOrgCondition) {
|
|
@@ -3530,7 +3530,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
//传入了pathName,则查询当前组织及其子组织下的用户
|
|
//传入了pathName,则查询当前组织及其子组织下的用户
|
|
|
page = baseMapper.queryUserWithMainOrgPostByOrgPath(convert2IPage(queryFilter.getPageBean()),convert2Wrapper(queryFilter,currentModelClass()));
|
|
page = baseMapper.queryUserWithMainOrgPostByOrgPath(convert2IPage(queryFilter.getPageBean()),convert2Wrapper(queryFilter,currentModelClass()));
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
if (BeanUtils.isNotEmpty(page) && BeanUtils.isNotEmpty(page.getRecords())) {
|
|
if (BeanUtils.isNotEmpty(page) && BeanUtils.isNotEmpty(page.getRecords())) {
|
|
|
for (Map<String, Object> records : page.getRecords()) {
|
|
for (Map<String, Object> records : page.getRecords()) {
|
|
|
if (BeanUtils.isNotEmpty(records.get("pathname"))) {
|
|
if (BeanUtils.isNotEmpty(records.get("pathname"))) {
|
|
@@ -3543,7 +3543,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
return new PageList<>(page);
|
|
return new PageList<>(page);
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
@@ -4007,7 +4007,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
if (user.getDataScope().equals(2)) {
|
|
if (user.getDataScope().equals(2)) {
|
|
|
wrapper.eq("COUNTY_CODE",user.getCountyCode());
|
|
wrapper.eq("COUNTY_CODE",user.getCountyCode());
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+ wrapper.ne("ACCOUNT_","admin");
|
|
|
return this.list(wrapper);
|
|
return this.list(wrapper);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -4019,16 +4019,16 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}
|
|
}
|
|
|
return true;
|
|
return true;
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public void batchUpdateUsersFromExterUni(String type, List<WxUser> userList) {
|
|
public void batchUpdateUsersFromExterUni(String type, List<WxUser> userList) {
|
|
|
if(BeanUtils.isNotEmpty(userList)){
|
|
if(BeanUtils.isNotEmpty(userList)){
|
|
|
//1、只处理有手机号的用户
|
|
//1、只处理有手机号的用户
|
|
|
List<WxUser> userListHasMobile = userList.stream().filter(e->BeanUtils.isNotEmpty(e.getMobile())).collect(Collectors.toList());
|
|
List<WxUser> userListHasMobile = userList.stream().filter(e->BeanUtils.isNotEmpty(e.getMobile())).collect(Collectors.toList());
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
//2、获取系统存在相同手机号的用户
|
|
//2、获取系统存在相同手机号的用户
|
|
|
List<User> existUserList = this.getAll();
|
|
List<User> existUserList = this.getAll();
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
//3、整理出系统未存在的用户,和已存在的用户
|
|
//3、整理出系统未存在的用户,和已存在的用户
|
|
|
List<WxUser> willCreate = new ArrayList<>();
|
|
List<WxUser> willCreate = new ArrayList<>();
|
|
|
List<UserUnite> userUniteList = new ArrayList<>();
|
|
List<UserUnite> userUniteList = new ArrayList<>();
|
|
@@ -4038,14 +4038,14 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
if(exist.isPresent()){
|
|
if(exist.isPresent()){
|
|
|
UserUnite userUnite = new UserUnite();
|
|
UserUnite userUnite = new UserUnite();
|
|
|
userUnite.setUserId(exist.get().getUserId());
|
|
userUnite.setUserId(exist.get().getUserId());
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
if("weChatWork".equals(type)){
|
|
if("weChatWork".equals(type)){
|
|
|
userUnite.setWxWorkId(wxUser.getUserid());
|
|
userUnite.setWxWorkId(wxUser.getUserid());
|
|
|
}else if("dingtalk".equals(type)){
|
|
}else if("dingtalk".equals(type)){
|
|
|
userUnite.setDingtalkId(wxUser.getUserid());
|
|
userUnite.setDingtalkId(wxUser.getUserid());
|
|
|
}
|
|
}
|
|
|
userUniteList.add(userUnite);
|
|
userUniteList.add(userUnite);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
//组织
|
|
//组织
|
|
|
if(BeanUtils.isNotEmpty(wxUser.getDepartment())){
|
|
if(BeanUtils.isNotEmpty(wxUser.getDepartment())){
|
|
|
for(String deptid : wxUser.getDepartment()){
|
|
for(String deptid : wxUser.getDepartment()){
|
|
@@ -4059,7 +4059,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
willCreate.add(wxUser);
|
|
willCreate.add(wxUser);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
//4、创建用户
|
|
//4、创建用户
|
|
|
String initPwd = pwdStrategyManager.getDefault().getInitPwd();
|
|
String initPwd = pwdStrategyManager.getDefault().getInitPwd();
|
|
|
//将用户加入一般用户角色中
|
|
//将用户加入一般用户角色中
|
|
@@ -4072,18 +4072,18 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
wxUser.setPassword(initPwd);
|
|
wxUser.setPassword(initPwd);
|
|
|
wxUser.setRoleId(roleId);
|
|
wxUser.setRoleId(roleId);
|
|
|
User newUser = this.createUserFromWxUser(wxUser);
|
|
User newUser = this.createUserFromWxUser(wxUser);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
UserUnite userUnite = new UserUnite();
|
|
UserUnite userUnite = new UserUnite();
|
|
|
userUnite.setUserId(newUser.getUserId());
|
|
userUnite.setUserId(newUser.getUserId());
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
if("weChatWork".equals(type)){
|
|
if("weChatWork".equals(type)){
|
|
|
userUnite.setWxWorkId(wxUser.getUserid());
|
|
userUnite.setWxWorkId(wxUser.getUserid());
|
|
|
}else if("dingtalk".equals(type)){
|
|
}else if("dingtalk".equals(type)){
|
|
|
userUnite.setDingtalkId(wxUser.getUserid());
|
|
userUnite.setDingtalkId(wxUser.getUserid());
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
userUniteList.add(userUnite);
|
|
userUniteList.add(userUnite);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
if(BeanUtils.isNotEmpty(wxUser.getDepartment())){
|
|
if(BeanUtils.isNotEmpty(wxUser.getDepartment())){
|
|
|
for(String deptid : wxUser.getDepartment()){
|
|
for(String deptid : wxUser.getDepartment()){
|
|
|
OrgUser ou = new OrgUser();
|
|
OrgUser ou = new OrgUser();
|
|
@@ -4095,7 +4095,7 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
}
|
|
}
|
|
|
//6批量处理用户与组织的关系
|
|
//6批量处理用户与组织的关系
|
|
|
this.orgUserManager.batchUpdateOrgUser(orgUserList);
|
|
this.orgUserManager.batchUpdateOrgUser(orgUserList);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
//6、批量处理绑定关系
|
|
//6、批量处理绑定关系
|
|
|
this.userUniteManager.updateUserUniteList(userUniteList);
|
|
this.userUniteManager.updateUserUniteList(userUniteList);
|
|
|
}
|
|
}
|
|
@@ -4106,24 +4106,24 @@ public class UserManagerImpl extends BaseManagerImpl <UserDao, User> implements
|
|
|
newUser.setFullname(wxUser.getName());
|
|
newUser.setFullname(wxUser.getName());
|
|
|
newUser.setAccount(wxUser.getMobile());
|
|
newUser.setAccount(wxUser.getMobile());
|
|
|
newUser.setMobile(wxUser.getMobile());
|
|
newUser.setMobile(wxUser.getMobile());
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
newUser.setId(UniqueIdUtil.getSuid());
|
|
newUser.setId(UniqueIdUtil.getSuid());
|
|
|
newUser.setStatus(User.STATUS_NORMAL);
|
|
newUser.setStatus(User.STATUS_NORMAL);
|
|
|
newUser.setCreateTime(LocalDateTime.now());
|
|
newUser.setCreateTime(LocalDateTime.now());
|
|
|
newUser.setFrom(User.FROM_RESTFUL);
|
|
newUser.setFrom(User.FROM_RESTFUL);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
newUser.setPassword(passwordEncoder.encode(wxUser.getPassword()));
|
|
newUser.setPassword(passwordEncoder.encode(wxUser.getPassword()));
|
|
|
newUser.setPwdCreateTime(LocalDateTime.now());
|
|
newUser.setPwdCreateTime(LocalDateTime.now());
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
try {
|
|
try {
|
|
|
this.create(newUser);
|
|
this.create(newUser);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
UserRole userRole = new UserRole();
|
|
UserRole userRole = new UserRole();
|
|
|
userRole.setId(UniqueIdUtil.getSuid());
|
|
userRole.setId(UniqueIdUtil.getSuid());
|
|
|
userRole.setRoleId(wxUser.getRoleId());
|
|
userRole.setRoleId(wxUser.getRoleId());
|
|
|
userRole.setUserId(newUser.getId());
|
|
userRole.setUserId(newUser.getId());
|
|
|
userRoleManager.save(userRole);
|
|
userRoleManager.save(userRole);
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
throw new RuntimeException(e.getMessage());
|
|
throw new RuntimeException(e.getMessage());
|
|
|
}
|
|
}
|