remove 移除过期 用户导入
This commit is contained in:
parent
c5dc08e082
commit
cb306b0793
@ -203,13 +203,4 @@ public interface ISysUserService extends IService<SysUser>, UserService {
|
|||||||
*/
|
*/
|
||||||
int deleteUserByIds(Long[] userIds);
|
int deleteUserByIds(Long[] userIds);
|
||||||
|
|
||||||
/**
|
|
||||||
* 导入用户数据
|
|
||||||
*
|
|
||||||
* @param userList 用户数据列表
|
|
||||||
* @param isUpdateSupport 是否更新支持,如果已存在,则进行更新数据
|
|
||||||
* @param operName 操作用户
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName);
|
|
||||||
}
|
}
|
||||||
|
@ -464,56 +464,4 @@ public class SysUserServiceImpl extends ServicePlusImpl<SysUserMapper, SysUser,
|
|||||||
return baseMapper.deleteBatchIds(ids);
|
return baseMapper.deleteBatchIds(ids);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 导入用户数据
|
|
||||||
*
|
|
||||||
* @param userList 用户数据列表
|
|
||||||
* @param isUpdateSupport 是否更新支持,如果已存在,则进行更新数据
|
|
||||||
* @param operName 操作用户
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName) {
|
|
||||||
if (StringUtils.isNull(userList) || userList.size() == 0) {
|
|
||||||
throw new ServiceException("导入用户数据不能为空!");
|
|
||||||
}
|
|
||||||
int successNum = 0;
|
|
||||||
int failureNum = 0;
|
|
||||||
StringBuilder successMsg = new StringBuilder();
|
|
||||||
StringBuilder failureMsg = new StringBuilder();
|
|
||||||
String password = configService.selectConfigByKey("sys.user.initPassword");
|
|
||||||
for (SysUser user : userList) {
|
|
||||||
try {
|
|
||||||
// 验证是否存在这个用户
|
|
||||||
SysUser u = baseMapper.selectUserByUserName(user.getUserName());
|
|
||||||
if (StringUtils.isNull(u)) {
|
|
||||||
user.setPassword(SecurityUtils.encryptPassword(password));
|
|
||||||
user.setCreateBy(operName);
|
|
||||||
this.insertUser(user);
|
|
||||||
successNum++;
|
|
||||||
successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
|
|
||||||
} else if (isUpdateSupport) {
|
|
||||||
user.setUpdateBy(operName);
|
|
||||||
this.updateUser(user);
|
|
||||||
successNum++;
|
|
||||||
successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 更新成功");
|
|
||||||
} else {
|
|
||||||
failureNum++;
|
|
||||||
failureMsg.append("<br/>" + failureNum + "、账号 " + user.getUserName() + " 已存在");
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
failureNum++;
|
|
||||||
String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败:";
|
|
||||||
failureMsg.append(msg + e.getMessage());
|
|
||||||
log.error(msg, e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (failureNum > 0) {
|
|
||||||
failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
|
|
||||||
throw new ServiceException(failureMsg.toString());
|
|
||||||
} else {
|
|
||||||
successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
|
|
||||||
}
|
|
||||||
return successMsg.toString();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user