package org.jeecg.modules.system.service.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.netty.util.internal.StringUtil;
import org.apache.commons.lang.StringUtils;
import org.jeecg.common.constant.CacheConstant;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.common.constant.FillRuleConstant;
import org.jeecg.common.constant.SymbolConstant;
import org.jeecg.common.util.FillRuleUtil;
import org.jeecg.common.util.YouBianCodeUtil;
import org.jeecg.common.util.oConvertUtils;
import org.jeecg.modules.system.entity.*;
import org.jeecg.modules.system.mapper.*;
import org.jeecg.modules.system.model.DepartIdModel;
import org.jeecg.modules.system.model.SysDepartTreeModel;
import org.jeecg.modules.system.service.ISysDepartService;
import org.jeecg.modules.system.util.FindsDepartsChildrenUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import java.util.function.Consumer;
import java.util.stream.Collectors;
/**
*
* 部门表 服务实现类
*
*
* @Author Steve
* @Since 2019-01-22
*/
@Service
public class SysDepartServiceImpl extends ServiceImpl implements ISysDepartService {
@Autowired
private SysUserDepartMapper userDepartMapper;
@Autowired
private SysDepartRoleMapper sysDepartRoleMapper;
@Autowired
private SysDepartPermissionMapper departPermissionMapper;
@Autowired
private SysDepartRolePermissionMapper departRolePermissionMapper;
@Autowired
private SysDepartRoleUserMapper departRoleUserMapper;
@Autowired
private SysUserMapper sysUserMapper;
@Override
public List queryMyDeptTreeList(String departIds) {
//根据部门id获取所负责部门
LambdaQueryWrapper query = new LambdaQueryWrapper();
String[] codeArr = this.getMyDeptParentOrgCode(departIds);
for(int i=0;i listDepts = this.list(query);
for(int i=0;i listResult = FindsDepartsChildrenUtil.wrapTreeDataToTreeList(listDepts);
return listResult;
}
/**
* queryTreeList 对应 queryTreeList 查询所有的部门数据,以树结构形式响应给前端
*/
@Override
@Cacheable(value = CacheConstant.SYS_DEPARTS_CACHE)
public List queryTreeList() {
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
query.orderByAsc(SysDepart::getDepartOrder);
List list = this.list(query);
//update-begin---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
//设置用户id,让前台显示
this.setUserIdsByDepList(list);
//update-begin---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
// 调用wrapTreeDataToTreeList方法生成树状数据
List listResult = FindsDepartsChildrenUtil.wrapTreeDataToTreeList(list);
return listResult;
}
/**
* queryTreeList 根据部门id查询,前端回显调用
*/
@Override
public List queryTreeList(String ids) {
List listResult=new ArrayList<>();
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
if(oConvertUtils.isNotEmpty(ids)){
query.in(true,SysDepart::getId,ids.split(","));
}
query.orderByAsc(SysDepart::getDepartOrder);
List list= this.list(query);
for (SysDepart depart : list) {
listResult.add(new SysDepartTreeModel(depart));
}
return listResult;
}
@Cacheable(value = CacheConstant.SYS_DEPART_IDS_CACHE)
@Override
public List queryDepartIdTreeList() {
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
query.orderByAsc(SysDepart::getDepartOrder);
List list = this.list(query);
// 调用wrapTreeDataToTreeList方法生成树状数据
List listResult = FindsDepartsChildrenUtil.wrapTreeDataToDepartIdTreeList(list);
return listResult;
}
/**
* saveDepartData 对应 add 保存用户在页面添加的新的部门对象数据
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void saveDepartData(SysDepart sysDepart, String username) {
if (sysDepart != null && username != null) {
if (sysDepart.getParentId() == null) {
sysDepart.setParentId("");
}
//String s = UUID.randomUUID().toString().replace("-", "");
sysDepart.setId(IdWorker.getIdStr(sysDepart));
// 先判断该对象有无父级ID,有则意味着不是最高级,否则意味着是最高级
// 获取父级ID
String parentId = sysDepart.getParentId();
//update-begin--Author:baihailong Date:20191209 for:部门编码规则生成器做成公用配置
JSONObject formData = new JSONObject();
formData.put("parentId",parentId);
String[] codeArray = (String[]) FillRuleUtil.executeRule(FillRuleConstant.DEPART,formData);
//update-end--Author:baihailong Date:20191209 for:部门编码规则生成器做成公用配置
sysDepart.setOrgCode(codeArray[0]);
String orgType = codeArray[1];
sysDepart.setOrgType(String.valueOf(orgType));
sysDepart.setCreateTime(new Date());
sysDepart.setDelFlag(CommonConstant.DEL_FLAG_0.toString());
this.save(sysDepart);
//update-begin---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
//新增部门的时候新增负责部门
if(oConvertUtils.isNotEmpty(sysDepart.getDirectorUserIds())){
this.addDepartByUserIds(sysDepart,sysDepart.getDirectorUserIds());
}
//update-end---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
}
}
/**
* saveDepartData 的调用方法,生成部门编码和部门类型(作废逻辑)
* @deprecated
* @param parentId
* @return
*/
private String[] generateOrgCode(String parentId) {
//update-begin--Author:Steve Date:20190201 for:组织机构添加数据代码调整
LambdaQueryWrapper query = new LambdaQueryWrapper();
LambdaQueryWrapper query1 = new LambdaQueryWrapper();
String[] strArray = new String[2];
// 创建一个List集合,存储查询返回的所有SysDepart对象
List departList = new ArrayList<>();
// 定义新编码字符串
String newOrgCode = "";
// 定义旧编码字符串
String oldOrgCode = "";
// 定义部门类型
String orgType = "";
// 如果是最高级,则查询出同级的org_code, 调用工具类生成编码并返回
if (StringUtil.isNullOrEmpty(parentId)) {
// 线判断数据库中的表是否为空,空则直接返回初始编码
query1.eq(SysDepart::getParentId, "").or().isNull(SysDepart::getParentId);
query1.orderByDesc(SysDepart::getOrgCode);
departList = this.list(query1);
if(departList == null || departList.size() == 0) {
strArray[0] = YouBianCodeUtil.getNextYouBianCode(null);
strArray[1] = "1";
return strArray;
}else {
SysDepart depart = departList.get(0);
oldOrgCode = depart.getOrgCode();
orgType = depart.getOrgType();
newOrgCode = YouBianCodeUtil.getNextYouBianCode(oldOrgCode);
}
} else { // 反之则查询出所有同级的部门,获取结果后有两种情况,有同级和没有同级
// 封装查询同级的条件
query.eq(SysDepart::getParentId, parentId);
// 降序排序
query.orderByDesc(SysDepart::getOrgCode);
// 查询出同级部门的集合
List parentList = this.list(query);
// 查询出父级部门
SysDepart depart = this.getById(parentId);
// 获取父级部门的Code
String parentCode = depart.getOrgCode();
// 根据父级部门类型算出当前部门的类型
orgType = String.valueOf(Integer.valueOf(depart.getOrgType()) + 1);
// 处理同级部门为null的情况
if (parentList == null || parentList.size() == 0) {
// 直接生成当前的部门编码并返回
newOrgCode = YouBianCodeUtil.getSubYouBianCode(parentCode, null);
} else { //处理有同级部门的情况
// 获取同级部门的编码,利用工具类
String subCode = parentList.get(0).getOrgCode();
// 返回生成的当前部门编码
newOrgCode = YouBianCodeUtil.getSubYouBianCode(parentCode, subCode);
}
}
// 返回最终封装了部门编码和部门类型的数组
strArray[0] = newOrgCode;
strArray[1] = orgType;
return strArray;
//update-end--Author:Steve Date:20190201 for:组织机构添加数据代码调整
}
/**
* removeDepartDataById 对应 delete方法 根据ID删除相关部门数据
*
*/
/*
* @Override
*
* @Transactional public boolean removeDepartDataById(String id) {
* System.out.println("要删除的ID 为=============================>>>>>"+id); boolean
* flag = this.removeById(id); return flag; }
*/
/**
* updateDepartDataById 对应 edit 根据部门主键来更新对应的部门数据
*/
@Override
@Transactional(rollbackFor = Exception.class)
public Boolean updateDepartDataById(SysDepart sysDepart, String username) {
if (sysDepart != null && username != null) {
sysDepart.setUpdateTime(new Date());
sysDepart.setUpdateBy(username);
this.updateById(sysDepart);
//update-begin---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
//修改部门管理的时候,修改负责部门
this.updateChargeDepart(sysDepart);
//update-begin---author:wangshuai ---date:20220307 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
return true;
} else {
return false;
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void deleteBatchWithChildren(List ids) {
List idList = new ArrayList();
for(String id: ids) {
idList.add(id);
this.checkChildrenExists(id, idList);
}
this.removeByIds(idList);
//根据部门id获取部门角色id
List roleIdList = new ArrayList<>();
LambdaQueryWrapper query = new LambdaQueryWrapper<>();
query.select(SysDepartRole::getId).in(SysDepartRole::getDepartId, idList);
List depRoleList = sysDepartRoleMapper.selectList(query);
for(SysDepartRole deptRole : depRoleList){
roleIdList.add(deptRole.getId());
}
//根据部门id删除用户与部门关系
userDepartMapper.delete(new LambdaQueryWrapper().in(SysUserDepart::getDepId,idList));
//根据部门id删除部门授权
departPermissionMapper.delete(new LambdaQueryWrapper().in(SysDepartPermission::getDepartId,idList));
//根据部门id删除部门角色
sysDepartRoleMapper.delete(new LambdaQueryWrapper().in(SysDepartRole::getDepartId,idList));
if(roleIdList != null && roleIdList.size()>0){
//根据角色id删除部门角色授权
departRolePermissionMapper.delete(new LambdaQueryWrapper().in(SysDepartRolePermission::getRoleId,roleIdList));
//根据角色id删除部门角色用户信息
departRoleUserMapper.delete(new LambdaQueryWrapper().in(SysDepartRoleUser::getDroleId,roleIdList));
}
}
@Override
public List getSubDepIdsByDepId(String departId) {
return this.baseMapper.getSubDepIdsByDepId(departId);
}
@Override
public List getMySubDepIdsByDepId(String departIds) {
//根据部门id获取所负责部门
String[] codeArr = this.getMyDeptParentOrgCode(departIds);
if(codeArr==null || codeArr.length==0){
return null;
}
return this.baseMapper.getSubDepIdsByOrgCodes(codeArr);
}
/**
*
* 根据关键字搜索相关的部门数据
*
*/
@Override
public List searchByKeyWord(String keyWord,String myDeptSearch,String departIds) {
LambdaQueryWrapper query = new LambdaQueryWrapper();
List newList = new ArrayList<>();
//myDeptSearch不为空时为我的部门搜索,只搜索所负责部门
if(!StringUtil.isNullOrEmpty(myDeptSearch)){
//departIds 为空普通用户或没有管理部门
if(StringUtil.isNullOrEmpty(departIds)){
return newList;
}
//根据部门id获取所负责部门
String[] codeArr = this.getMyDeptParentOrgCode(departIds);
//update-begin-author:taoyan date:20220104 for:/issues/3311 当用户属于两个部门的时候,且这两个部门没有上下级关系,我的部门-部门名称查询条件模糊搜索失效!
if (codeArr != null && codeArr.length > 0) {
query.nested(i -> {
for (String s : codeArr) {
i.or().likeRight(SysDepart::getOrgCode, s);
}
});
}
//update-end-author:taoyan date:20220104 for:/issues/3311 当用户属于两个部门的时候,且这两个部门没有上下级关系,我的部门-部门名称查询条件模糊搜索失效!
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
}
query.like(SysDepart::getDepartName, keyWord);
//update-begin--Author:huangzhilin Date:20140417 for:[bugfree号]组织机构搜索回显优化--------------------
SysDepartTreeModel model = new SysDepartTreeModel();
List departList = this.list(query);
if(departList.size() > 0) {
for(SysDepart depart : departList) {
model = new SysDepartTreeModel(depart);
model.setChildren(null);
//update-end--Author:huangzhilin Date:20140417 for:[bugfree号]组织机构搜索功回显优化----------------------
newList.add(model);
}
return newList;
}
return null;
}
/**
* 根据部门id删除并且删除其可能存在的子级任何部门
*/
@Override
@Transactional(rollbackFor = Exception.class)
public boolean delete(String id) {
List idList = new ArrayList<>();
idList.add(id);
this.checkChildrenExists(id, idList);
//清空部门树内存
//FindsDepartsChildrenUtil.clearDepartIdModel();
boolean ok = this.removeByIds(idList);
//根据部门id获取部门角色id
List roleIdList = new ArrayList<>();
LambdaQueryWrapper query = new LambdaQueryWrapper<>();
query.select(SysDepartRole::getId).in(SysDepartRole::getDepartId, idList);
List depRoleList = sysDepartRoleMapper.selectList(query);
for(SysDepartRole deptRole : depRoleList){
roleIdList.add(deptRole.getId());
}
//根据部门id删除用户与部门关系
userDepartMapper.delete(new LambdaQueryWrapper().in(SysUserDepart::getDepId,idList));
//根据部门id删除部门授权
departPermissionMapper.delete(new LambdaQueryWrapper().in(SysDepartPermission::getDepartId,idList));
//根据部门id删除部门角色
sysDepartRoleMapper.delete(new LambdaQueryWrapper().in(SysDepartRole::getDepartId,idList));
if(roleIdList != null && roleIdList.size()>0){
//根据角色id删除部门角色授权
departRolePermissionMapper.delete(new LambdaQueryWrapper().in(SysDepartRolePermission::getRoleId,roleIdList));
//根据角色id删除部门角色用户信息
departRoleUserMapper.delete(new LambdaQueryWrapper().in(SysDepartRoleUser::getDroleId,roleIdList));
}
return ok;
}
/**
* delete 方法调用
* @param id
* @param idList
*/
private void checkChildrenExists(String id, List idList) {
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getParentId,id);
List departList = this.list(query);
if(departList != null && departList.size() > 0) {
for(SysDepart depart : departList) {
idList.add(depart.getId());
this.checkChildrenExists(depart.getId(), idList);
}
}
}
@Override
public List queryUserDeparts(String userId) {
return baseMapper.queryUserDeparts(userId);
}
@Override
public List queryDepartsByUsername(String username) {
return baseMapper.queryDepartsByUsername(username);
}
/**
* 根据用户所负责部门ids获取父级部门编码
* @param departIds
* @return
*/
private String[] getMyDeptParentOrgCode(String departIds){
//根据部门id查询所负责部门
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
query.in(SysDepart::getId, Arrays.asList(departIds.split(",")));
query.orderByAsc(SysDepart::getOrgCode);
List list = this.list(query);
//查找根部门
if(list == null || list.size()==0){
return null;
}
String orgCode = this.getMyDeptParentNode(list);
String[] codeArr = orgCode.split(",");
return codeArr;
}
/**
* 获取负责部门父节点
* @param list
* @return
*/
private String getMyDeptParentNode(List list){
Map map = new HashMap(5);
//1.先将同一公司归类
for(SysDepart dept : list){
String code = dept.getOrgCode().substring(0,3);
if(map.containsKey(code)){
String mapCode = map.get(code)+","+dept.getOrgCode();
map.put(code,mapCode);
}else{
map.put(code,dept.getOrgCode());
}
}
StringBuffer parentOrgCode = new StringBuffer();
//2.获取同一公司的根节点
for(String str : map.values()){
String[] arrStr = str.split(",");
parentOrgCode.append(",").append(this.getMinLengthNode(arrStr));
}
return parentOrgCode.substring(1);
}
/**
* 获取同一公司中部门编码长度最小的部门
* @param str
* @return
*/
private String getMinLengthNode(String[] str){
int min =str[0].length();
StringBuilder orgCodeBuilder = new StringBuilder(str[0]);
for(int i =1;i queryTreeByKeyWord(String keyWord) {
LambdaQueryWrapper query = new LambdaQueryWrapper();
query.eq(SysDepart::getDelFlag, CommonConstant.DEL_FLAG_0.toString());
query.orderByAsc(SysDepart::getDepartOrder);
List list = this.list(query);
// 调用wrapTreeDataToTreeList方法生成树状数据
List listResult = FindsDepartsChildrenUtil.wrapTreeDataToTreeList(list);
List treelist =new ArrayList<>();
if(StringUtils.isNotBlank(keyWord)){
this.getTreeByKeyWord(keyWord,listResult,treelist);
}else{
return listResult;
}
return treelist;
}
/**
* 根据parentId查询部门树
* @param parentId
* @param ids 前端回显传递
* @param primaryKey 主键字段(id或者orgCode)
* @return
*/
@Override
public List queryTreeListByPid(String parentId,String ids, String primaryKey) {
Consumer> square = i -> {
if (oConvertUtils.isNotEmpty(ids)) {
if (CommonConstant.DEPART_KEY_ORG_CODE.equals(primaryKey)) {
i.in(SysDepart::getOrgCode, ids.split(SymbolConstant.COMMA));
} else {
i.in(SysDepart::getId, ids.split(SymbolConstant.COMMA));
}
} else {
if(oConvertUtils.isEmpty(parentId)){
i.and(q->q.isNull(true,SysDepart::getParentId).or().eq(true,SysDepart::getParentId,""));
}else{
i.eq(true,SysDepart::getParentId,parentId);
}
}
};
LambdaQueryWrapper lqw=new LambdaQueryWrapper<>();
lqw.eq(true,SysDepart::getDelFlag,CommonConstant.DEL_FLAG_0.toString());
lqw.func(square);
//update-begin---author:wangshuai ---date:20220527 for:[VUEN-1143]排序不对,vue3和2应该都有问题,应该按照升序排------------
lqw.orderByAsc(SysDepart::getDepartOrder);
//update-end---author:wangshuai ---date:20220527 for:[VUEN-1143]排序不对,vue3和2应该都有问题,应该按照升序排--------------
List list = list(lqw);
//update-begin---author:wangshuai ---date:20220316 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
//设置用户id,让前台显示
this.setUserIdsByDepList(list);
//update-end---author:wangshuai ---date:20220316 for:[JTC-119]在部门管理菜单下设置部门负责人 创建用户的时候不需要处理
List records = new ArrayList<>();
for (int i = 0; i < list.size(); i++) {
SysDepart depart = list.get(i);
SysDepartTreeModel treeModel = new SysDepartTreeModel(depart);
//TODO 异步树加载key拼接__+时间戳,以便于每次展开节点会刷新数据
//treeModel.setKey(treeModel.getKey()+"__"+System.currentTimeMillis());
treeModel.setKey(treeModel.getKey());
Integer count=this.baseMapper.queryCountByPid(depart.getId());
if(count>0){
treeModel.setIsLeaf(false);
}else{
treeModel.setIsLeaf(true);
}
records.add(treeModel);
}
return records;
}
@Override
public JSONObject queryAllParentIdByDepartId(String departId) {
JSONObject result = new JSONObject();
for (String id : departId.split(SymbolConstant.COMMA)) {
JSONObject all = this.queryAllParentId("id", id);
result.put(id, all);
}
return result;
}
@Override
public JSONObject queryAllParentIdByOrgCode(String orgCode) {
JSONObject result = new JSONObject();
for (String code : orgCode.split(SymbolConstant.COMMA)) {
JSONObject all = this.queryAllParentId("org_code", code);
result.put(code, all);
}
return result;
}
/**
* 查询某个部门的所有父ID信息
*
* @param fieldName 字段名
* @param value 值
*/
private JSONObject queryAllParentId(String fieldName, String value) {
JSONObject data = new JSONObject();
// 父ID集合,有序
data.put("parentIds", new JSONArray());
// 父ID的部门数据,key是id,value是数据
data.put("parentMap", new JSONObject());
this.queryAllParentIdRecursion(fieldName, value, data);
return data;
}
/**
* 递归调用查询父部门接口
*/
private void queryAllParentIdRecursion(String fieldName, String value, JSONObject data) {
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq(fieldName, value);
SysDepart depart = super.getOne(queryWrapper);
if (depart != null) {
data.getJSONArray("parentIds").add(0, depart.getId());
data.getJSONObject("parentMap").put(depart.getId(), depart);
if (oConvertUtils.isNotEmpty(depart.getParentId())) {
this.queryAllParentIdRecursion("id", depart.getParentId(), data);
}
}
}
@Override
public SysDepart queryCompByOrgCode(String orgCode) {
int length = YouBianCodeUtil.ZHANWEI_LENGTH;
String compyOrgCode = orgCode.substring(0,length);
return this.baseMapper.queryCompByOrgCode(compyOrgCode);
}
/**
* 根据id查询下级部门
* @param pid
* @return
*/
@Override
public List queryDeptByPid(String pid) {
return this.baseMapper.queryDeptByPid(pid);
}
/**
* 根据关键字筛选部门信息
* @param keyWord
* @return
*/
public void getTreeByKeyWord(String keyWord,List allResult,List newResult){
for (SysDepartTreeModel model:allResult) {
if (model.getDepartName().contains(keyWord)){
newResult.add(model);
continue;
}else if(model.getChildren()!=null){
getTreeByKeyWord(keyWord,model.getChildren(),newResult);
}
}
}
//update-begin---author:wangshuai ---date:20200308 for:[JTC-119]在部门管理菜单下设置部门负责人,新增方法添加部门负责人、删除负责部门负责人、查询部门对应的负责人
/**
* 通过用户id设置负责部门
* @param sysDepart SysDepart部门对象
* @param userIds 多个负责用户id
*/
public void addDepartByUserIds(SysDepart sysDepart, String userIds) {
//获取部门id,保存到用户
String departId = sysDepart.getId();
//循环用户id
String[] userIdArray = userIds.split(",");
for (String userId:userIdArray) {
//查询用户表增加负责部门
SysUser sysUser = sysUserMapper.selectById(userId);
//如果部门id不为空,那么就需要拼接
if(oConvertUtils.isNotEmpty(sysUser.getDepartIds())){
if(!sysUser.getDepartIds().contains(departId)) {
sysUser.setDepartIds(sysUser.getDepartIds() + "," + departId);
}
}else{
sysUser.setDepartIds(departId);
}
//设置身份为上级
sysUser.setUserIdentity(CommonConstant.USER_IDENTITY_2);
//跟新用户表
sysUserMapper.updateById(sysUser);
//判断当前用户是否包含所属部门
List userDepartList = userDepartMapper.getUserDepartByUid(userId);
boolean isExistDepId = userDepartList.stream().anyMatch(item -> departId.equals(item.getDepId()));
//如果不存在需要设置所属部门
if(!isExistDepId){
userDepartMapper.insert(new SysUserDepart(userId,departId));
}
}
}
/**
* 修改用户负责部门
* @param sysDepart SysDepart对象
*/
private void updateChargeDepart(SysDepart sysDepart) {
//新的用户id
String directorIds = sysDepart.getDirectorUserIds();
//旧的用户id(数据库中存在的)
String oldDirectorIds = sysDepart.getOldDirectorUserIds();
String departId = sysDepart.getId();
//如果用户id为空,那么用户的负责部门id应该去除
if(oConvertUtils.isEmpty(directorIds)){
this.deleteChargeDepId(departId,null);
}else if(oConvertUtils.isNotEmpty(directorIds) && oConvertUtils.isEmpty(oldDirectorIds)){
//如果用户id不为空但是用户原来负责部门的用户id为空
this.addDepartByUserIds(sysDepart,directorIds);
}else{
//都不为空,需要比较,进行添加或删除
//找到新的负责部门用户id与原来负责部门的用户id,进行删除
List userIdList = Arrays.stream(oldDirectorIds.split(",")).filter(item -> !directorIds.contains(item)).collect(Collectors.toList());
for (String userId:userIdList){
this.deleteChargeDepId(departId,userId);
}
//找到原来负责部门的用户id与新的负责部门用户id,进行新增
String addUserIds = Arrays.stream(directorIds.split(",")).filter(item -> !oldDirectorIds.contains(item)).collect(Collectors.joining(","));
if(oConvertUtils.isNotEmpty(addUserIds)){
this.addDepartByUserIds(sysDepart,addUserIds);
}
}
}
/**
* 删除用户负责部门
* @param departId 部门id
* @param userId 用户id
*/
private void deleteChargeDepId(String departId,String userId){
//先查询负责部门的用户id,因为负责部门的id使用逗号拼接起来的
LambdaQueryWrapper query = new LambdaQueryWrapper<>();
query.like(SysUser::getDepartIds,departId);
//删除全部的情况下用户id不存在
if(oConvertUtils.isNotEmpty(userId)){
query.eq(SysUser::getId,userId);
}
List userList = sysUserMapper.selectList(query);
for (SysUser sysUser:userList) {
//将不存在的部门id删除掉
String departIds = sysUser.getDepartIds();
List list = new ArrayList<>(Arrays.asList(departIds.split(",")));
list.remove(departId);
//删除之后再将新的id用逗号拼接起来进行更新
String newDepartIds = String.join(",",list);
sysUser.setDepartIds(newDepartIds);
sysUserMapper.updateById(sysUser);
}
}
/**
* 通过部门集合为部门设置用户id,用于前台展示
* @param departList 部门集合
*/
private void setUserIdsByDepList(List departList) {
//查询负责部门不为空的情况
LambdaQueryWrapper query = new LambdaQueryWrapper<>();
query.isNotNull(SysUser::getDepartIds);
List users = sysUserMapper.selectList(query);
Map map = new HashMap(5);
//先循环一遍找到不同的负责部门id
for (SysUser user:users) {
String departIds = user.getDepartIds();
String[] departIdArray = departIds.split(",");
for (String departId:departIdArray) {
//mao中包含部门key,负责用户直接拼接
if(map.containsKey(departId)){
String userIds = map.get(departId) + "," + user.getId();
map.put(departId,userIds);
}else{
map.put(departId,user.getId());
}
}
}
//循环部门集合找到部门id对应的负责用户
for (SysDepart sysDepart:departList) {
if(map.containsKey(sysDepart.getId())){
sysDepart.setDirectorUserIds(map.get(sysDepart.getId()).toString());
}
}
}
//update-end---author:wangshuai ---date:20200308 for:[JTC-119]在部门管理菜单下设置部门负责人,新增方法添加部门负责人、删除负责部门负责人、查询部门对应的负责人
}