package com.vci.frameworkcore.compatibility.impl; import com.vci.corba.common.PLException; import com.vci.corba.common.data.UserEntityInfo; import com.vci.corba.framework.data.DeptInfo; import com.vci.corba.omd.data.BusinessObject; import com.vci.frameworkcore.compatibility.OrgDeptQueryServiceI; import com.vci.frameworkcore.model.dto.OrgDepartmentDTO; import com.vci.frameworkcore.lcstatuspck.FrameworkDataLCStatus; import com.vci.frameworkcore.model.OrgDeptForPlatform1; import com.vci.frameworkcore.pagemodel.OrgDepartmentVO; import com.vci.omd.utils.ObjectTool; import com.vci.starter.revision.bo.TreeWrapperOptions; import com.vci.starter.revision.service.RevisionModelUtil; import com.vci.starter.web.constant.QueryOptionConstant; import com.vci.starter.web.exception.VciBaseException; import com.vci.starter.web.pagemodel.*; import com.vci.starter.web.util.BeanUtil; import com.vci.starter.web.util.VciBaseUtil; import com.vci.starter.web.wrapper.VciQueryWrapperForDO; import com.vci.web.service.WebBoServiceI; import com.vci.web.util.Func; import com.vci.web.util.PlatformClientUtil; import com.vci.web.util.WebUtil; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; /** * 部门的查询服务,兼容老平台 * @author 谢军 * @date 2020/3/10 */ @Service public class OrgDeptQueryServiceImpl implements OrgDeptQueryServiceI{ /** * 业务数据服务 */ @Autowired private WebBoServiceI boService; /** * 平台调用客户端 */ @Autowired private PlatformClientUtil platformClientUtil; /** * 对象操作工具类 */ @Autowired private RevisionModelUtil revisionModelUtil; /** * 根据部门主键获取部门的信息 * @param deptOid 部门主键 * @return 部门的显示对象,如果部门不存在则返回null,不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public OrgDepartmentVO getDeptByDeptOid(String deptOid) throws VciBaseException { if(StringUtils.isBlank(deptOid)){ return null; } OrgDeptForPlatform1 deptForPlatform1 = boService.selectByOid(deptOid, OrgDeptForPlatform1.class); return deptDO2VO(deptForPlatform1); } /** * 根据父部门主键获取和部门名称部门的信息 * @param parentDeptOid 父部门主键 * @param conditionMap 部门名称 * @return 部门的显示对象,如果部门不存在则返回null,不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public OrgDepartmentVO getDeptByDeptPOidAndCondition(String parentDeptOid,Map conditionMap) throws VciBaseException { if(Func.isEmpty(conditionMap)){ conditionMap = new HashMap(); } VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(new HashMap<>(),OrgDeptForPlatform1.class); //父主键为空查顶层 if(Func.isBlank(parentDeptOid)){ queryWrapper.isNull("plparentuid"); }else{ queryWrapper.eq("plparentuid",parentDeptOid); } List roleForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class); if(Func.isEmpty(roleForPlatform1s)){ return null; } return deptDO2VO(roleForPlatform1s.get(0)); } /** * 部门的数据对象转换为显示对象 * @param depts 数据对象 * @return 显示对象 */ public List deptDO2VOs(Collection depts){ List departmentVOS = new ArrayList<>(); Optional.ofNullable(depts).orElseGet(()->new ArrayList<>()).stream().forEach(dept->{ departmentVOS.add(deptDO2VO(dept)); }); return departmentVOS; } /** * 部门的数据对象转换为显示对象 * @param deptForPlatform1 数据对象 * @return 显示对象 */ public OrgDepartmentVO deptDO2VO(OrgDeptForPlatform1 deptForPlatform1){ OrgDepartmentVO departmentVO = new OrgDepartmentVO(); if(deptForPlatform1!=null){ departmentVO.setOid(deptForPlatform1.getPluid()); departmentVO.setId(deptForPlatform1.getPlnum()); departmentVO.setName(deptForPlatform1.getPlname()); if(0 == deptForPlatform1.getPlstatus()){ departmentVO.setLcStatus(FrameworkDataLCStatus.ENABLED.getValue()); }else{ departmentVO.setLcStatus(FrameworkDataLCStatus.DISABLED.getValue()); } departmentVO.setPkFatherDepartment(deptForPlatform1.getPlparentuid()); departmentVO.setDescription(deptForPlatform1.getPldesc()); departmentVO.setCheckInTime(deptForPlatform1.getPlcreatetime()); departmentVO.setCreator(deptForPlatform1.getPlcreateuser()); departmentVO.setLastModifyTime(deptForPlatform1.getPlupdatetime()); departmentVO.setLastModifier(deptForPlatform1.getPlupdateuser()); } return departmentVO; } /** * 批量获取部门的信息 (根据部门主键) * @param deptOidCollections 部门主键的集合,可以超过1000个 * @return 部门的显示对象,如果部门不存在则返回空的列表,不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public List listDeptByDeptOids( Collection deptOidCollections) throws VciBaseException { if(CollectionUtils.isEmpty(deptOidCollections)){ return new ArrayList<>(); } List depts = new ArrayList<>(); WebUtil.switchCollectionForOracleIn(deptOidCollections).stream().forEach(roleOids->{ Map conditionMap=new HashMap(); conditionMap.put("pluid", QueryOptionConstant.IN + VciBaseUtil.toInSql(roleOids.toArray(new String[0]))); VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class); List roleForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class); if(!CollectionUtils.isEmpty(roleForPlatform1s)){ depts.addAll(roleForPlatform1s); } }); return deptDO2VOs(depts); } /** * 获取部门的列表,默认会以部门名称升序排列,部门的编辑页面列表不要使用这个接口 * @param queryMap 查询条件 * @param pageHelper 分页和排序的信息,在兼容老平台的时候会自动兼容,如果属性不存在会自动忽略 * @return 部门的显示对象列表 * @throws VciBaseException 参数为空的时候会抛出异常 */ @Override public DataGrid gridDepts(Map queryMap, PageHelper pageHelper) throws VciBaseException { if(pageHelper == null){ pageHelper = new PageHelper(-1); } //根据部门编号排序 pageHelper.addDefaultAsc("plnum"); VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class,pageHelper); List deptForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class); DataGrid dataGrid = new DataGrid<>(); if(!CollectionUtils.isEmpty(deptForPlatform1s)){ dataGrid.setData(deptDO2VOs(deptForPlatform1s)); dataGrid.setTotal(boService.countByQueryWrapper(queryWrapper,OrgDeptForPlatform1.class)); } return dataGrid; } /** * 根据部门主键获取部门的姓名 * @param deptOid 部门主键 * @return 部门姓名,如果不存在会返回null */ @Override public String getDeptNameByDeptOid(String deptOid) { WebUtil.alertNotNull(deptOid,"部门的主键"); return getDeptByDeptOid(deptOid).getName(); } /** * 使用用户主键查询部门 * @param userOid 用户主键 * @param queryMap 查询条件 * @param notIn 是否为不包含 * @return 角色的显示对象 */ private List listDeptByUserOid(String userOid,Map queryMap,boolean notIn){ if(StringUtils.isBlank(userOid)){ return new ArrayList<>(); } if(queryMap == null){ queryMap = new HashMap<>(); } List deptForPlatform1s = new ArrayList<>(); if(userOid.contains(",")){ Map finalQueryMap = queryMap; WebUtil.switchCollectionForOracleIn(WebUtil.str2List(userOid)).stream().forEach(userOids->{ Map conditionMap = new HashMap<>(); finalQueryMap.forEach((key,value)->{ conditionMap.put(key,value); }); conditionMap.put("pluid", notIn ? QueryOptionConstant.NOTIN : QueryOptionConstant.IN + "select pldeptuid from PLUSERDEPT where pluseruid in (" + WebUtil.toInSql(userOids.toArray(new String[0])) + ")"); VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class); List roleForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class); if(!CollectionUtils.isEmpty(roleForPlatform1s)){ deptForPlatform1s.addAll(roleForPlatform1s); } }); }else { queryMap.put("pluid", notIn ? QueryOptionConstant.NOTIN : QueryOptionConstant.IN + "select pldeptuid from PLUSERDEPT where pluseruid ='" + userOid.trim() + "'"); } VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class); List roleForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class); if(!CollectionUtils.isEmpty(roleForPlatform1s)){ deptForPlatform1s.addAll(roleForPlatform1s); } return deptDO2VOs(deptForPlatform1s); } /** * 根据用户主键获取关联的部门 * @param userOid 用户主键 * @param queryMap 查询条件,如果需要使用用户的属性来查询可以使用pkUser.xxxx * @return 部门的显示对象 */ @Override public List listDeptByUserOid(String userOid, Map queryMap) { List departmentVOS = listDeptByUserOid(userOid, queryMap, false); if(CollectionUtils.isEmpty(departmentVOS)){ return new ArrayList<>(); } return departmentVOS; } /** * 获取未关联某个用户的部门 * @param userOid 用户主键 * @param queryMap 查询条件,如果需要使用用户的属性来查询可以使用pkUser.xxxx * @return 部门的显示对象 */ @Override public List listDeptUnInUserOid(String userOid, Map queryMap) { return listDeptByUserOid(userOid, queryMap, true); } /** * 获取未关联某个用户的部门 * @param userOid 用户主键 * @param queryMap 查询条件,如果需要使用用户的属性来查询可以使用pkUser.xxxx * @param pageHelper 分页和排序对象,老平台不支持使用部门编号来排序 * @return 部门的显示对象 */ @Override public DataGrid gridDeptUninUserOid(String userOid, Map queryMap, PageHelper pageHelper) { return gridDeptByUserOid(userOid,queryMap,pageHelper,true); } /** * 使用用户查询部门列表 * @param userOid 用户主键 * @param queryMap 查询条件 * @param pageHelper 分页对象 * @param notIn 不包含 * @return 列表数据 */ private DataGrid gridDeptByUserOid(String userOid,Map queryMap,PageHelper pageHelper,boolean notIn){ if(queryMap == null){ queryMap = new HashMap<>(); } if(StringUtils.isBlank(userOid)){ return new DataGrid<>(); } if(userOid.contains(",")){ String[] userOids = userOid.trim().split(","); if(userOids.length>1000){ //这个方法不支持超过1000个的用户查询 throw new VciBaseException("这个方法不支持超过1000个用户的主键来查询"); } queryMap.put("pluid", notIn ? QueryOptionConstant.NOTIN : QueryOptionConstant.IN + "select pldeptuid from PLUSERDEPT where pluseruid in (" + WebUtil.toInSql(userOids) + ")"); }else { queryMap.put("pluid", notIn ? QueryOptionConstant.NOTIN : QueryOptionConstant.IN + "select pldeptuid from PLUSERDEPT where pluseruid ='" + userOid.trim() + "'"); } return gridDepts(queryMap,pageHelper); } /** * 批量根据用户的主键来获取部门 * @param userOidCollection 用户主键集合 * @param queryMap 查询条件,如果需要使用用户的属性来查询可以使用pkUser.xxxx * @return 部门的显示对象,key是用户主键,value是这个用户关联的部门 */ @Override public Map> batchListDeptByUserOids( Collection userOidCollection, Map queryMap) { if(CollectionUtils.isEmpty(userOidCollection)){ return new HashMap<>(); } List deptVOList = new ArrayList<>(); Map> userDeptOidMap = new HashMap<>(); WebUtil.switchCollectionForOracleIn(userOidCollection).stream().forEach(userOids->{ List deptVOs = listDeptByUserOid(userOids.stream().collect(Collectors.joining(",")), queryMap, false); if(!CollectionUtils.isEmpty(deptVOs)){ deptVOList.addAll(deptVOs); String sql = "select pluseruid,pldeptuid from pluserdept where pluseruid in (" + WebUtil.toInSql(userOids.toArray(new String[0])) + ")"; List cbos = boService.queryBySql(sql, null); if(!CollectionUtils.isEmpty(cbos)){ cbos.stream().forEach(cbo->{ String userOid = ObjectTool.getNewBOAttributeValue(cbo,"pluseruid"); List deptOids = userDeptOidMap.getOrDefault(userOid,new ArrayList<>()); deptOids.add(ObjectTool.getNewBOAttributeValue(cbo,"pldeptuid")); userDeptOidMap.put(userOid,deptOids); }); } } }); if(!CollectionUtils.isEmpty(deptVOList)){ //这儿应该对deptVOList做一次去重处理,因为肯定会有重复的部门被查出来 Map deptVOMap = deptVOList.stream() .collect(Collectors.toMap(OrgDepartmentVO::getOid, Function.identity(), (existing, replacement) -> existing)); //Map deptVOMap = deptVOList.stream().distinct().collect(Collectors.toMap(s -> s.getOid(), t -> t)); Map> userDeptVOMap = new HashMap<>(); userDeptOidMap.forEach((userOid,deptOids)->{ List deptVOS = new ArrayList<>(); deptOids.forEach(deptOid->{ if(deptVOMap.containsKey(deptOid)){ deptVOS.add(deptVOMap.get(deptOid)); } }); userDeptVOMap.put(userOid,deptVOS); }); return userDeptVOMap; } return new HashMap<>(); } /** * 获取某个部门的直属下级部门 * @param pkFatherDepartmment 部门的主键 * @param queryMap 查询条件 * @return 部门显示对象 */ @Override public List listChildrenDeptByParentOid( String pkFatherDepartmment, Map queryMap) { VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class); if(StringUtils.isBlank(pkFatherDepartmment)){ queryWrapperForDO.isNull("plparentuid"); }else{ queryWrapperForDO.eq("plparentuid",pkFatherDepartmment.trim()); } List depts = boService.selectByQueryWrapper(queryWrapperForDO, OrgDeptForPlatform1.class); return deptDO2VOs(depts); } /** * 获取某个部门的所有层级的下级部门 * @param pkFatherDepartmment 部门的主键 * @param queryMap 查询条件 * @return 部门显示对象 */ @Override public List listAllLevelChildrenDeptByParentOid( String pkFatherDepartmment, Map queryMap) { VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class); queryWrapperForDO.in("pluid","select pluid from pldept start with " + (StringUtils.isBlank(pkFatherDepartmment)?" (plparentuid is null or plparentuid = '') ":"plparentuid = '" + pkFatherDepartmment.trim() + "'") + "connect by PRIOR pluid=plparentuid"); return deptDO2VOs(boService.selectByQueryWrapper(queryWrapperForDO, OrgDeptForPlatform1.class)); } /** * 参照树形数据的部门信息 * @param treeQueryObject 树形查询的条件 * @return 树节点 */ @Override public List refTreeDept(TreeQueryObject treeQueryObject) { String pkFatherDepartmment=treeQueryObject.getParentOid(); Map conditionMap = treeQueryObject.getConditionMap(); if(conditionMap==null){ conditionMap=new HashMap(); } List orgDepartmentVOList=new ArrayList(); if(treeQueryObject.isQueryAllLevel()){ orgDepartmentVOList = listAllLevelChildrenDeptByParentOid(pkFatherDepartmment, conditionMap); }else{ conditionMap.put("plparentuid", pkFatherDepartmment); VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class); orgDepartmentVOList = deptDO2VOs(boService.selectByQueryWrapper(queryWrapperForDO,OrgDeptForPlatform1.class)); } TreeWrapperOptions treeWrapperOptions = new TreeWrapperOptions(); BeanUtil.convert(treeQueryObject,treeWrapperOptions); treeWrapperOptions.setParentFieldName("pkFatherDepartment"); return revisionModelUtil.doList2Trees(orgDepartmentVOList,treeWrapperOptions,dept->{ return dept.getId() + " " + dept.getName() + (FrameworkDataLCStatus.DISABLED.getValue().equals(dept.getLcStatus())?"【停用】":""); }); } /** * 参照树形表格的部门信息,上级部门的是表格中的树形列 * @param treeQueryObject 树形查询的条件 * @return 部门的树表信息 */ @Override public DataGrid refTreeGridDept(TreeQueryObject treeQueryObject) { String pkFatherDepartmment=treeQueryObject.getParentOid(); Map conditionMap = treeQueryObject.getConditionMap(); if(conditionMap==null){ conditionMap=new HashMap(); } List orgDepartmentVOList=new ArrayList(); if(treeQueryObject.isQueryAllLevel()){ orgDepartmentVOList = listAllLevelChildrenDeptByParentOid(pkFatherDepartmment, conditionMap); }else{ conditionMap.put("plparentuid", pkFatherDepartmment); VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class); orgDepartmentVOList = deptDO2VOs(boService.selectByQueryWrapper(queryWrapperForDO,OrgDeptForPlatform1.class)); } DataGrid dataGrid = new DataGrid(); dataGrid.setData(orgDepartmentVOList); if(!CollectionUtils.isEmpty(orgDepartmentVOList)){ dataGrid.setTotal(orgDepartmentVOList.size()); } return dataGrid; } /** * 保存部门角色关联信息,带查重功能 * @param userOIds 用户id * @param deptId 部门id * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean saveUsersDept(String[] userOIds, String deptId) throws PLException { //先进性查重处理 List repeatUserOidList = new ArrayList<>(); //循环进行查重,避免in大于1000 WebUtil.switchCollectionForOracleIn(Arrays.asList(userOIds)).stream().forEach(userOId->{ String sql = "select pluseruid,pldeptuid from pluserdept where pldeptuid = '" + deptId + "' and " + "pluseruid in ("+WebUtil.toInSql(userOId.toArray(new String[0]))+")"; List cbos = boService.queryBySql(sql, null); if(!CollectionUtils.isEmpty(cbos)){ cbos.stream().forEach(cbo->{ repeatUserOidList.add(ObjectTool.getNewBOAttributeValue(cbo,"pluseruid")); }); } }); //从即将要执行保存的用户oid中移除当前用户已经存在关联关系的oid //移除重复的 List tempList = new ArrayList<>(Arrays.asList(userOIds)); tempList.removeAll(repeatUserOidList); userOIds = tempList.toArray(new String[tempList.size()]); if(Func.isNotEmpty(userOIds)){ platformClientUtil.getFrameworkService().saveUserDept(userOIds, deptId,null); } return true; } /** * 增加部门信息 * @param orgDepartmentDTO * @return */ @Override public boolean addDept(OrgDepartmentDTO orgDepartmentDTO) throws PLException { //判空 VciBaseUtil.alertNotNull( orgDepartmentDTO,"添加的部门对象", orgDepartmentDTO.getName(),"部门名"); //部门名判重 Map conditionMap = new HashMap<>(); conditionMap.put("plname",orgDepartmentDTO.getName()); conditionMap.put("plnum",QueryOptionConstant.OR + orgDepartmentDTO.getId()); OrgDepartmentVO departmentVO = getDeptByDeptPOidAndCondition(orgDepartmentDTO.getPkFatherDepartment(), conditionMap); if(Func.isNotEmpty(departmentVO)){ throw new VciBaseException("同一父节点下该部门名称或编号已经存在,请修改!"); } //SessionInfo loginUser = WebThreadLocalUtil.getCurrentUserSessionInfoInThread(); String userId = "developer";//loginUser.getUserId(); //生成存储的corba对象 orgDepartmentDTO.setCreateTime(new Date()); orgDepartmentDTO.setCreator(userId); orgDepartmentDTO.setLastModifier(userId); orgDepartmentDTO.setStatus((short) 0); DeptInfo deptInfo = changeOrgDeptDTOToDeptInfo(orgDepartmentDTO); UserEntityInfo userEntityInfo = new UserEntityInfo(userId, ""); String oid = platformClientUtil.getFrameworkService().saveDepartment(deptInfo, userEntityInfo); if (Func.isEmpty(oid)) { return false; } return true; } /** * 修改部门信息 * @param orgDepartmentDTO * @return */ @Override public boolean updateDept(OrgDepartmentDTO orgDepartmentDTO) throws PLException { //判空 VciBaseUtil.alertNotNull( orgDepartmentDTO,"修改的部门对象", orgDepartmentDTO.getOid(),"用户主键", orgDepartmentDTO.getId(),"用户名" ); //按oid查询数据库中已存在的 OrgDepartmentVO departmentVO = getDeptByDeptOid(orgDepartmentDTO.getOid()); //根据主键没查询到 OrgDepartmentDTO orgDepartmentDTO1 = new OrgDepartmentDTO(); //默认属性给赋值上 //BeanUtil.convert(departmentVO,orgDepartmentDTO1); Func.copy(departmentVO,orgDepartmentDTO); //orgDepartmentDTO1.setName(orgDepartmentDTO.getName()); //orgDepartmentDTO1.setCode(orgDepartmentDTO.getCode()); //orgDepartmentDTO1.setDescription(orgDepartmentDTO.getDescription()); String loginUserId = "developer";//WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(); orgDepartmentDTO1.setLastModifier(loginUserId); DeptInfo deptInfo = changeOrgDeptDTOToDeptInfo(orgDepartmentDTO1); boolean updateBoolean = platformClientUtil.getFrameworkService().updateDepartment(deptInfo, new UserEntityInfo(loginUserId, null)); return updateBoolean; } /** * Dto对象转corb对象 * @param orgDepartmentDTO * @return */ public DeptInfo changeOrgDeptDTOToDeptInfo(OrgDepartmentDTO orgDepartmentDTO) { DeptInfo departmentInfo = new DeptInfo(); departmentInfo.id = orgDepartmentDTO.getOid() == null ? "" : orgDepartmentDTO.getOid(); departmentInfo.name = orgDepartmentDTO.getName() == null ? "" : orgDepartmentDTO.getName(); departmentInfo.num = orgDepartmentDTO.getId() == null ? "" : orgDepartmentDTO.getId(); departmentInfo.code = orgDepartmentDTO.getCode() == null ? "" : orgDepartmentDTO.getCode(); departmentInfo.specialties = orgDepartmentDTO.getSpecialties() == null ? "" : orgDepartmentDTO.getSpecialties(); departmentInfo.status = orgDepartmentDTO.getStatus() == 0 ? 0 : orgDepartmentDTO.getStatus(); departmentInfo.description = orgDepartmentDTO.getDescription() == null ? "" : orgDepartmentDTO.getDescription(); departmentInfo.parentId = orgDepartmentDTO.getPkFatherDepartment() == null ? "" : orgDepartmentDTO.getPkFatherDepartment(); departmentInfo.createUser = orgDepartmentDTO.getCreator() == null ? "" : orgDepartmentDTO.getCreator(); departmentInfo.createTime = orgDepartmentDTO.getCreateTime().getTime(); departmentInfo.updateTime = System.currentTimeMillis(); departmentInfo.updateUser = orgDepartmentDTO.getLastModifier() == null ? "" : orgDepartmentDTO.getLastModifier(); //departmentInfo.grantor = orgDepartmentDTO.getGrantor() == null ? "" : orgDepartmentDTO.getGrantor(); return departmentInfo; } /** * 删除部门 * @param ids * @return */ @Override public boolean deleteDept(String[] ids) throws PLException { VciBaseUtil.alertNotNull(ids,"要删除的部门主键"); //具备连带删除的功能,如角色菜单授权表里面的授权信息 return platformClientUtil.getFrameworkService().deleteDepartment( ids, new UserEntityInfo("developer"/*WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId()*/, null) ); } /** * 获取所有部门的信息 * @return key:部门由名称组成的路径(/间隔),value对应最小层级的部门信息 */ @Override public Map getDeptAllTreeMap() { List orgDepartmentVOList = listAllLevelChildrenDeptByParentOid(null, null); Map stringOrgDepartmentVOMap = convertToMap(orgDepartmentVOList); return stringOrgDepartmentVOMap; } public Map convertToMap(List orgDepartmentVOList) { Map map = new HashMap<>(); for (OrgDepartmentVO orgDepartmentVO : orgDepartmentVOList) { String key = buildKey(orgDepartmentVO, orgDepartmentVOList); map.put(key, orgDepartmentVO); } return map; } private String buildKey(OrgDepartmentVO orgDepartmentVO, List orgDepartmentVOList) { StringBuilder keyBuilder = new StringBuilder(); OrgDepartmentVO current = orgDepartmentVO; while (current != null) { keyBuilder.insert(0, current.getName()); keyBuilder.insert(0, "/"); current = getParentDepartment(current.getPkFatherDepartment(), orgDepartmentVOList); } keyBuilder.deleteCharAt(0); return keyBuilder.toString(); } private OrgDepartmentVO getParentDepartment(String pkFatherDepartment, List orgDepartmentVOList) { for (OrgDepartmentVO orgDepartmentVO : orgDepartmentVOList) { if (pkFatherDepartment != null && pkFatherDepartment.equals(orgDepartmentVO.getOid())) { return orgDepartmentVO; } } return null; } }