|
@@ -12,7 +12,9 @@ import cn.ezhizao.project.system.mapper.*;
|
|
|
import cn.ezhizao.project.system.service.ISysConfigService;
|
|
|
import cn.ezhizao.project.system.service.ISysUserService;
|
|
|
import cn.ezhizao.project.tenant.domain.BizUserTenant;
|
|
|
+import cn.ezhizao.project.tenant.mapper.BizUserTenantMapper;
|
|
|
import cn.ezhizao.project.tenant.service.IBizUserTenantService;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -51,9 +53,15 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
@Resource
|
|
|
private SysUserPostMapper userPostMapper;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private BizUserTenantMapper bizUserTenantMapper;
|
|
|
+
|
|
|
@Resource
|
|
|
private ISysConfigService configService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private SysDeptMapper deptMapper;
|
|
|
+
|
|
|
@Resource
|
|
|
protected Validator validator;
|
|
|
|
|
@@ -291,6 +299,32 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
{
|
|
|
// 新增用户信息
|
|
|
int rows = userMapper.insertUser(user);
|
|
|
+
|
|
|
+ // 新增用户岗位关联
|
|
|
+ insertUserPost(user);
|
|
|
+ // 新增用户与角色管理
|
|
|
+ insertUserRole(user);
|
|
|
+ return rows;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增保存用户信息
|
|
|
+ *
|
|
|
+ * @param user 用户信息
|
|
|
+ * @return 结果
|
|
|
+ */
|
|
|
+ @Transactional
|
|
|
+ public int insertUserImport(SysUser user)
|
|
|
+ {
|
|
|
+ // 新增用户信息
|
|
|
+ int rows = userMapper.insertUser(user);
|
|
|
+
|
|
|
+ BizUserTenant bizUserTenant = new BizUserTenant();
|
|
|
+ bizUserTenant.setUserId(user.getUserId());
|
|
|
+ bizUserTenant.setTenantId(user.getTenantId());
|
|
|
+ bizUserTenant.setDeptId(user.getDeptId());
|
|
|
+ bizUserTenantMapper.insert(bizUserTenant);
|
|
|
+
|
|
|
// 新增用户岗位关联
|
|
|
insertUserPost(user);
|
|
|
// 新增用户与角色管理
|
|
@@ -298,6 +332,8 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
return rows;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+
|
|
|
/**
|
|
|
* 注册用户信息
|
|
|
*
|
|
@@ -330,7 +366,7 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
// 新增用户与岗位管理
|
|
|
insertUserPost(user);
|
|
|
// 更新tenantId的部门
|
|
|
- BizUserTenant userTenant = userTenantService.query().eq("user_id",user.getUserId()).one();
|
|
|
+ BizUserTenant userTenant = userTenantService.query().eq("user_id",user.getUserId()).eq("tenant_id",user.getTenantId()).one();
|
|
|
if(userTenant!=null){
|
|
|
userTenant.setDeptId(user.getDeptId());
|
|
|
userTenantService.updateById(userTenant);
|
|
@@ -518,7 +554,7 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
* @return 结果
|
|
|
*/
|
|
|
@Override
|
|
|
- public String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName)
|
|
|
+ public String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName,Long tenantId)
|
|
|
{
|
|
|
if (StringUtils.isNull(userList) || userList.size() == 0)
|
|
|
{
|
|
@@ -537,14 +573,29 @@ public class SysUserServiceImpl implements ISysUserService
|
|
|
SysUser u = userMapper.selectUserByUserName(user.getUserName());
|
|
|
if (StringUtils.isNull(u))
|
|
|
{
|
|
|
- BeanValidators.validateWithException(validator, user);
|
|
|
- checkUserAllowed(user);
|
|
|
- checkUserDataScope(user.getUserId());
|
|
|
- user.setPassword(SecurityUtils.encryptPassword(password));
|
|
|
- user.setCreateBy(operName);
|
|
|
- this.insertUser(user);
|
|
|
- successNum++;
|
|
|
- successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
|
|
|
+
|
|
|
+ SysDept dept = new SysDept();
|
|
|
+ dept.setTenantId(tenantId);
|
|
|
+ dept.setDeptName(user.getDeptName());
|
|
|
+ dept=deptMapper.getDept(dept);
|
|
|
+
|
|
|
+ if(dept!=null){
|
|
|
+ BeanValidators.validateWithException(validator, user);
|
|
|
+ checkUserAllowed(user);
|
|
|
+ checkUserDataScope(user.getUserId());
|
|
|
+ user.setPassword(SecurityUtils.encryptPassword(password));
|
|
|
+ user.setCreateBy(operName);
|
|
|
+ user.setTenantId(tenantId);
|
|
|
+ user.setDeptId(dept.getDeptId());
|
|
|
+
|
|
|
+ this.insertUserImport(user);
|
|
|
+ successNum++;
|
|
|
+ successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
|
|
|
+ }else{
|
|
|
+ failureNum++;
|
|
|
+ failureMsg .append("<br/>" + failureNum + "、账号 " + user.getDeptName() + " 部门不存在");
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
else if (isUpdateSupport)
|
|
|
{
|