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.model.dto.SmUserDTO;
|
import com.vci.frameworkcore.model.po.OrgDeptPO;
|
import com.vci.frameworkcore.model.po.SmUserPO;
|
import com.vci.frameworkcore.pagemodel.OrgDepartmentVO;
|
import com.vci.frameworkcore.pagemodel.SmUserVO;
|
import com.vci.frameworkcore.properties.ConfigReader;
|
import com.vci.omd.utils.ObjectTool;
|
import com.vci.starter.poi.bo.ReadExcelOption;
|
import com.vci.starter.poi.bo.WriteExcelData;
|
import com.vci.starter.poi.bo.WriteExcelOption;
|
import com.vci.starter.poi.constant.ExcelLangCodeConstant;
|
import com.vci.starter.poi.util.ExcelUtil;
|
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.enumpck.UserSecretEnum;
|
import com.vci.starter.web.exception.VciBaseException;
|
import com.vci.starter.web.pagemodel.*;
|
import com.vci.starter.web.util.*;
|
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.apache.poi.hssf.util.HSSFColor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.util.WebUtils;
|
|
import java.io.File;
|
import java.nio.charset.StandardCharsets;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
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;
|
|
/**
|
* 必填列
|
*/
|
private ArrayList<Integer> ColumnNameisRed = new ArrayList<Integer>();
|
|
/**
|
* 日志
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 根据部门主键获取部门的信息
|
* @param deptOid 部门主键
|
* @return 部门的显示对象，如果部门不存在则返回null，不会抛出异常
|
* @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常
|
*/
|
@Override
|
public OrgDepartmentVO getDeptByDeptOid(String deptOid) throws VciBaseException {
|
if(StringUtils.isBlank(deptOid)){
|
return null;
|
}
|
Map<String, String> conditionMap = new HashMap<>();
|
conditionMap.put("pluid",deptOid);
|
VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class);
|
List<OrgDeptForPlatform1> deptForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class);
|
if(Func.isEmpty(deptForPlatform1s)){
|
return null;
|
}
|
return deptDO2VO(deptForPlatform1s.get(0));
|
}
|
|
/**
|
* 根据父部门主键获取和部门名称部门的信息
|
* @param parentDeptOid 父部门主键
|
* @param conditionMap 部门名称
|
* @return 部门的显示对象，如果部门不存在则返回null，不会抛出异常
|
* @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常
|
*/
|
@Override
|
public List<OrgDepartmentVO> getDeptByDeptPOidAndCondition(String parentDeptOid,Map<String,String> conditionMap) throws VciBaseException {
|
if(Func.isEmpty(conditionMap)){
|
conditionMap = new HashMap();
|
}
|
VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class);
|
//父主键为空查顶层
|
if(Func.isBlank(parentDeptOid)){
|
queryWrapper.isNull("plparentuid");
|
}else{
|
queryWrapper.eq("plparentuid",parentDeptOid);
|
}
|
List<OrgDeptForPlatform1> roleForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class);
|
if(Func.isEmpty(roleForPlatform1s)){
|
return null;
|
}
|
return deptDO2VOs(roleForPlatform1s);
|
}
|
|
/**
|
* 部门的数据对象转换为显示对象
|
* @param depts 数据对象
|
* @return 显示对象
|
*/
|
public List<OrgDepartmentVO> deptDO2VOs(Collection<OrgDeptForPlatform1> depts){
|
List<OrgDepartmentVO> 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());
|
// 除部门主键外的唯一标识，长度为Dept:+8位可通过该参数反推回部门主键的hash编码
|
departmentVO.setUniqueId("Dept:"+Func.oidEnHash(deptForPlatform1.getPluid()));
|
departmentVO.setId(deptForPlatform1.getPlnum());
|
departmentVO.setName(deptForPlatform1.getPlname());
|
departmentVO.setStatus(deptForPlatform1.getPlstatus());
|
if(0 == deptForPlatform1.getPlstatus()){
|
departmentVO.setStatusText(FrameworkDataLCStatus.ENABLED.getValue());
|
}else{
|
departmentVO.setStatusText(FrameworkDataLCStatus.DISABLED.getValue());
|
}
|
departmentVO.setSpecialties(deptForPlatform1.getPlspecialties());
|
departmentVO.setCode(deptForPlatform1.getPlcode());
|
departmentVO.setPkFatherDepartment(deptForPlatform1.getPlparentuid());
|
departmentVO.setDescription(deptForPlatform1.getPldesc());
|
departmentVO.setCreateTime(new Date(deptForPlatform1.getPlcreatetime()));
|
departmentVO.setCreator(deptForPlatform1.getPlcreateuser());
|
departmentVO.setLastModifyTime(new Date(deptForPlatform1.getPlupdatetime()));
|
departmentVO.setLastModifier(deptForPlatform1.getPlupdateuser());
|
}
|
return departmentVO;
|
}
|
|
/**
|
* 批量获取部门的信息 （根据部门主键）
|
* @param deptOidCollections 部门主键的集合，可以超过1000个
|
* @return 部门的显示对象，如果部门不存在则返回空的列表，不会抛出异常
|
* @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常
|
*/
|
@Override
|
public List<OrgDepartmentVO> listDeptByDeptOids(
|
Collection<String> deptOidCollections) throws VciBaseException {
|
if(CollectionUtils.isEmpty(deptOidCollections)){
|
return new ArrayList<>();
|
}
|
List<OrgDeptForPlatform1> depts = new ArrayList<>();
|
WebUtil.switchCollectionForOracleIn(deptOidCollections).stream().forEach(roleOids->{
|
Map<String,String> conditionMap=new HashMap<String, String>();
|
conditionMap.put("pluid", QueryOptionConstant.IN + VciBaseUtil.toInSql(roleOids.toArray(new String[0])));
|
VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,OrgDeptForPlatform1.class);
|
List<OrgDeptForPlatform1> 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<OrgDepartmentVO> gridDepts(Map<String, String> queryMap,
|
PageHelper pageHelper) throws VciBaseException {
|
if(pageHelper == null){
|
pageHelper = new PageHelper(-1);
|
}
|
//根据部门编号排序
|
pageHelper.addDefaultAsc("plnum");
|
VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class,pageHelper);
|
List<OrgDeptForPlatform1> deptForPlatform1s = boService.selectByQueryWrapper(queryWrapper, OrgDeptForPlatform1.class);
|
DataGrid<OrgDepartmentVO> 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<OrgDepartmentVO> listDeptByUserOid(String userOid,Map<String,String> queryMap,boolean notIn){
|
if(StringUtils.isBlank(userOid)){
|
return new ArrayList<>();
|
}
|
if(queryMap == null){
|
queryMap = new HashMap<>();
|
}
|
List<OrgDeptForPlatform1> deptForPlatform1s = new ArrayList<>();
|
if(userOid.contains(",")){
|
Map<String, String> finalQueryMap = queryMap;
|
WebUtil.switchCollectionForOracleIn(WebUtil.str2List(userOid)).stream().forEach(userOids->{
|
Map<String,String> 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<OrgDeptForPlatform1> 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<OrgDeptForPlatform1> 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<OrgDepartmentVO> listDeptByUserOid(String userOid,
|
Map<String, String> queryMap) {
|
List<OrgDepartmentVO> departmentVOS = listDeptByUserOid(userOid, queryMap, false);
|
if(CollectionUtils.isEmpty(departmentVOS)){
|
return new ArrayList<>();
|
}
|
return departmentVOS;
|
}
|
|
/**
|
* 获取未关联某个用户的部门
|
* @param userOid 用户主键
|
* @param queryMap 查询条件，如果需要使用用户的属性来查询可以使用pkUser.xxxx
|
* @return 部门的显示对象
|
*/
|
@Override
|
public List<OrgDepartmentVO> listDeptUnInUserOid(String userOid,
|
Map<String, String> queryMap) {
|
return listDeptByUserOid(userOid, queryMap, true);
|
}
|
|
/**
|
* 获取未关联某个用户的部门
|
* @param userOid 用户主键
|
* @param queryMap 查询条件，如果需要使用用户的属性来查询可以使用pkUser.xxxx
|
* @param pageHelper 分页和排序对象，老平台不支持使用部门编号来排序
|
* @return 部门的显示对象
|
*/
|
@Override
|
public DataGrid<OrgDepartmentVO> gridDeptUninUserOid(String userOid,
|
Map<String, String> queryMap, PageHelper pageHelper) {
|
return gridDeptByUserOid(userOid,queryMap,pageHelper,true);
|
}
|
|
/**
|
* 使用用户查询部门列表
|
* @param userOid 用户主键
|
* @param queryMap 查询条件
|
* @param pageHelper 分页对象
|
* @param notIn 不包含
|
* @return 列表数据
|
*/
|
private DataGrid<OrgDepartmentVO> gridDeptByUserOid(String userOid,Map<String,String> 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<String, List<OrgDepartmentVO>> batchListDeptByUserOids(
|
Collection<String> userOidCollection, Map<String, String> queryMap) {
|
if(CollectionUtils.isEmpty(userOidCollection)){
|
return new HashMap<>();
|
}
|
List<OrgDepartmentVO> deptVOList = new ArrayList<>();
|
Map<String,List<String>> userDeptOidMap = new HashMap<>();
|
WebUtil.switchCollectionForOracleIn(userOidCollection).stream().forEach(userOids->{
|
List<OrgDepartmentVO> 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<BusinessObject> cbos = boService.queryBySql(sql, null);
|
if(!CollectionUtils.isEmpty(cbos)){
|
cbos.stream().forEach(cbo->{
|
String userOid = ObjectTool.getNewBOAttributeValue(cbo,"pluseruid");
|
List<String> deptOids = userDeptOidMap.getOrDefault(userOid,new ArrayList<>());
|
deptOids.add(ObjectTool.getNewBOAttributeValue(cbo,"pldeptuid"));
|
userDeptOidMap.put(userOid,deptOids);
|
});
|
}
|
}
|
});
|
if(!CollectionUtils.isEmpty(deptVOList)){
|
//这儿应该对deptVOList做一次去重处理，因为肯定会有重复的部门被查出来
|
Map<String, OrgDepartmentVO> deptVOMap = deptVOList.stream()
|
.collect(Collectors.toMap(OrgDepartmentVO::getOid, Function.identity(), (existing, replacement) -> existing));
|
Map<String, List<OrgDepartmentVO>> userDeptVOMap = new HashMap<>();
|
userDeptOidMap.forEach((userOid,deptOids)->{
|
List<OrgDepartmentVO> 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 userOidCollection 用户主键集合
|
* @param queryMap 查询条件，如果需要使用用户的属性来查询可以使用pkUser.xxxx
|
* @return 部门的显示对象，key是用户主键,value是关联的部门（包含父节点如当前部门为人力资源部则值为：550/人力资源部）
|
*/
|
@Override
|
public Map<String,Map<String,String>> batchMapDeptNameByUserOids(Collection<String> userOidCollection, Map<String, String> queryMap) {
|
if(CollectionUtils.isEmpty(userOidCollection)){
|
return new HashMap<>();
|
}
|
Map<String,Map<String,String>> deptOidNameMap = new HashMap<>();
|
Map<String,Map<String,String>> userDeptOidMap = new HashMap<>();
|
WebUtil.switchCollectionForOracleIn(userOidCollection).stream().forEach(userOids->{
|
//1、要先根据用户主键获取到关联的部门主键
|
String sql = "select pluseruid,pldeptuid from pluserdept where pluseruid in (" + WebUtil.toInSql(userOids.toArray(new String[0])) + ")";
|
List<BusinessObject> cbos = boService.queryBySql(sql, null);
|
if(!CollectionUtils.isEmpty(cbos)){
|
cbos.stream().forEach(cbo->{
|
//角色主键
|
String userOid = ObjectTool.getNewBOAttributeValue(cbo,"pluseruid");
|
//部门主键
|
String deptUid = ObjectTool.getNewBOAttributeValue(cbo, "pldeptuid");
|
//2、然后根据部门主键获取到由部门名称/组成的值
|
//避免多次查询，或者循环查询
|
if(deptOidNameMap.containsKey(deptUid)){
|
userDeptOidMap.put(userOid,deptOidNameMap.get(deptUid));
|
}else {
|
if(Func.isNotEmpty(deptUid)){
|
//2.1、查询部门oid，当前部门包含父部门
|
String queryDeptSql = "select pluid,plname from pldept START with pluid = '" +
|
deptUid + "' connect by prior plparentuid = pluid";
|
List<BusinessObject> cboDepts = boService.queryBySql(queryDeptSql, null);
|
if(!CollectionUtils.isEmpty(cboDepts)){
|
StringBuilder sb = new StringBuilder();
|
for (int i = cboDepts.size()-1; i >=0; i--) {
|
String deptName = ObjectTool.getNewBOAttributeValue(cboDepts.get(i),"plname");
|
sb.append(deptName);
|
sb.append("/");
|
}
|
//2.2、避免同一部门多次查询，这里存储在一个公共集合中，便于重复使用
|
//删除最后一个斜杠
|
sb.deleteCharAt(sb.length() - 1);
|
Map<String,String> tempMap = new HashMap<>();
|
tempMap.put(deptUid,sb.toString());
|
deptOidNameMap.put(deptUid,tempMap);
|
userDeptOidMap.put(userOid,tempMap);
|
}
|
}
|
}
|
});
|
}
|
});
|
return userDeptOidMap;
|
}
|
|
/**
|
* 获取某个部门的直属下级部门
|
* @param pkFatherDepartmment 部门的主键
|
* @param queryMap 查询条件
|
* @return 部门显示对象
|
*/
|
@Override
|
public List<OrgDepartmentVO> listChildrenDeptByParentOid(
|
String pkFatherDepartmment, Map<String, String> queryMap) {
|
VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(queryMap,OrgDeptForPlatform1.class);
|
if(StringUtils.isBlank(pkFatherDepartmment)){
|
queryWrapperForDO.isNull("plparentuid");
|
}else{
|
queryWrapperForDO.eq("plparentuid",pkFatherDepartmment.trim());
|
}
|
List<OrgDeptForPlatform1> depts = boService.selectByQueryWrapper(queryWrapperForDO, OrgDeptForPlatform1.class);
|
return deptDO2VOs(depts);
|
}
|
|
/**
|
* 获取某个部门的所有层级的下级部门
|
* @param pkFatherDepartmment 部门的主键
|
* @param queryMap 查询条件
|
* @return 部门显示对象
|
*/
|
@Override
|
public List<OrgDepartmentVO> listAllLevelChildrenDeptByParentOid(
|
String pkFatherDepartmment, Map<String, String> 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<Tree> refTreeDept(TreeQueryObject treeQueryObject) {
|
String pkFatherDepartmment=treeQueryObject.getParentOid();
|
Map<String, String> conditionMap = treeQueryObject.getConditionMap();
|
Map<String, String> extandParamsMap = treeQueryObject.getExtandParamsMap();
|
if(conditionMap==null){
|
conditionMap=new HashMap<String, String>();
|
}
|
List<OrgDepartmentVO> orgDepartmentVOList=new ArrayList<OrgDepartmentVO>();
|
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");
|
List<Tree> trees = revisionModelUtil.doList2Trees(orgDepartmentVOList, treeWrapperOptions, dept -> {
|
return dept.getId() + " " + dept.getName() + (FrameworkDataLCStatus.DISABLED.getValue().equals(dept.getLcStatus()) ? "【停用】" : "");
|
});
|
//extandParamsMap中添加"showAllDepartmentNode"为"true"时,并且parentOid为空，返回结果中会包含“所有部门”这个节点
|
if(Func.isBlank(pkFatherDepartmment) && (Func.isNotEmpty(extandParamsMap) && Boolean.parseBoolean(extandParamsMap.getOrDefault("showAllDepartmentNode","false")))){
|
List<Tree> treeList = new ArrayList<>();
|
Tree tree = new Tree();
|
tree.setLeaf(false);
|
tree.setParentId(null);
|
//没有实际作用只是界面上渲染使用
|
tree.setOid(UUID.randomUUID().toString());
|
tree.setParentName(null);
|
Map<String, String> map = new HashMap<>();
|
map.put("name","所有部门");
|
map.put("ALLDept","ALLDept");
|
tree.setAttributes(map);
|
tree.setChildren(trees);
|
treeList.add(tree);
|
return treeList;
|
}
|
return trees;
|
}
|
|
/**
|
* 参照树形表格的部门信息，上级部门的是表格中的树形列
|
* @param treeQueryObject 树形查询的条件
|
* @return 部门的树表信息
|
*/
|
@Override
|
public DataGrid refTreeGridDept(TreeQueryObject treeQueryObject) {
|
String pkFatherDepartmment=treeQueryObject.getParentOid();
|
Map<String, String> conditionMap = treeQueryObject.getConditionMap();
|
if(conditionMap==null){
|
conditionMap=new HashMap<String, String>();
|
}
|
List<OrgDepartmentVO> orgDepartmentVOList=new ArrayList<OrgDepartmentVO>();
|
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<String> 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<BusinessObject> cbos = boService.queryBySql(sql, null);
|
if(!CollectionUtils.isEmpty(cbos)){
|
cbos.stream().forEach(cbo->{
|
repeatUserOidList.add(ObjectTool.getNewBOAttributeValue(cbo,"pluseruid"));
|
});
|
}
|
});
|
|
//从即将要执行保存的用户oid中移除当前用户已经存在关联关系的oid
|
//移除重复的
|
List<String> 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,new UserEntityInfo(WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(),null));
|
}
|
return true;
|
}
|
|
/**
|
* 增加部门信息
|
* @param orgDepartmentDTO
|
* @return
|
*/
|
@Override
|
public boolean addDept(OrgDepartmentDTO orgDepartmentDTO) throws PLException {
|
//判空
|
VciBaseUtil.alertNotNull(
|
orgDepartmentDTO,"添加的部门对象",
|
orgDepartmentDTO.getName(),"部门名");
|
//部门名和编号判重
|
Map<String, String> conditionMap = new HashMap<>();
|
conditionMap.put("plname",QueryOptionConstant.OR + orgDepartmentDTO.getName());
|
if(Func.isNotBlank(orgDepartmentDTO.getId())){
|
conditionMap.put("plnum",QueryOptionConstant.OR + orgDepartmentDTO.getId());
|
}
|
List<OrgDepartmentVO> departmentVOS = getDeptByDeptPOidAndCondition(orgDepartmentDTO.getPkFatherDepartment(), conditionMap);
|
if(Func.isNotEmpty(departmentVOS)){
|
throw new VciBaseException("同一父节点下该部门名称或编号已经存在,请修改!");
|
}
|
SessionInfo loginUser = WebThreadLocalUtil.getCurrentUserSessionInfoInThread();
|
String userId = 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 dbDepartmentVO = getDeptByDeptOid(orgDepartmentDTO.getOid());
|
if(Func.isEmpty(dbDepartmentVO)){
|
throw new VciBaseException("修改的部门不存在！");
|
}
|
//部门名和编号判重
|
Map<String, String> conditionMap = new HashMap<>();
|
conditionMap.put("plname",QueryOptionConstant.OR + orgDepartmentDTO.getName());
|
if(Func.isNotBlank(orgDepartmentDTO.getId())){
|
conditionMap.put("plnum",QueryOptionConstant.OR + orgDepartmentDTO.getId());
|
}
|
List<OrgDepartmentVO> repeatDepartmentVOS = getDeptByDeptPOidAndCondition(orgDepartmentDTO.getPkFatherDepartment(), conditionMap);
|
repeatDepartmentVOS = repeatDepartmentVOS.stream().filter(item -> {
|
if((item.getName().equals(orgDepartmentDTO.getName()) || item.getId().equals(orgDepartmentDTO.getId())) &&
|
!item.getOid().equals(orgDepartmentDTO.getOid())){
|
return true;
|
}
|
return false;
|
}).collect(Collectors.toList());
|
if(Func.isNotEmpty(repeatDepartmentVOS) ){
|
throw new VciBaseException("同一父节点下该部门名称或编号已经存在,请修改!");
|
}
|
OrgDepartmentDTO departmentDTO = new OrgDepartmentDTO();
|
BeanUtil.convert(dbDepartmentVO,departmentDTO);
|
departmentDTO.setCode(orgDepartmentDTO.getCode());
|
departmentDTO.setId(orgDepartmentDTO.getId());
|
departmentDTO.setSpecialties(orgDepartmentDTO.getSpecialties());
|
departmentDTO.setDescription(orgDepartmentDTO.getDescription());
|
departmentDTO.setName(orgDepartmentDTO.getName());
|
String loginUserId = WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId();
|
orgDepartmentDTO.setLastModifier(loginUserId);
|
DeptInfo deptInfo = changeOrgDeptDTOToDeptInfo(departmentDTO);
|
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<String, OrgDepartmentVO> getDeptAllTreeMap() {
|
List<OrgDepartmentVO> orgDepartmentVOList = listAllLevelChildrenDeptByParentOid(null, null);
|
Map<String, OrgDepartmentVO> stringOrgDepartmentVOMap = convertToMap(orgDepartmentVOList);
|
return stringOrgDepartmentVOMap;
|
}
|
|
/**
|
* 下载导入部门的excel模板。
|
* @param downloadFileName
|
* @return
|
*/
|
@Override
|
public String downloadImportTemplate(String downloadFileName) {
|
//界面没传名称，使用默认名称
|
downloadFileName = Func.isBlank(downloadFileName) ? "部门导入模板_" + Func.format(new Date(),"yyyy-MM-dd HHmmss.sss"):downloadFileName;
|
// 设置表单列名
|
List<String> columns = new ArrayList<>(Arrays.asList("ID", "名称", "编号", "代号", "专业", "父ID（部门唯一标识ID）", "描述"));
|
//设置必填列
|
ColumnNameisRed.clear();
|
ColumnNameisRed.add(0);
|
ColumnNameisRed.add(1);
|
//写excel
|
String excelPath = LocalFileUtil.getDefaultTempFolder() + File.separator + downloadFileName + ".xls";
|
try {
|
new File(excelPath).createNewFile();
|
} catch (Throwable e) {
|
throw new VciBaseException(LangBaseUtil.getErrorMsg(e), new String[]{excelPath}, e);
|
}
|
//设置列
|
List<WriteExcelData> excelDataList = new ArrayList<>();
|
for (int index = 0; index < columns.size(); index++) {
|
//判断是否为必填列，给必填列设置颜色
|
if(ColumnNameisRed.contains(index)){
|
WriteExcelData excelData = new WriteExcelData(0, index, columns.get(index));
|
excelData.setFontColor(String.valueOf(HSSFColor.HSSFColorPredefined.RED.getIndex()));
|
excelDataList.add(excelData);
|
}else{
|
excelDataList.add(new WriteExcelData(0,index, columns.get(index)));
|
}
|
}
|
WriteExcelOption excelOption = new WriteExcelOption(excelDataList);
|
ExcelUtil.writeDataToFile(excelPath, excelOption);
|
return excelPath;
|
}
|
|
/**
|
* 导入部门
|
* @param file
|
* @return
|
* @throws VciBaseException
|
*/
|
@Override
|
public BaseResult importDept(File file) throws VciBaseException {
|
VciBaseUtil.alertNotNull(file,"excel文件");
|
if(!file.exists()){
|
throw new VciBaseException("导入的excel文件不存在,{0}",new String[]{file.getPath()});
|
}
|
try{
|
//1、读取excel中的数据，组成对象
|
ReadExcelOption excelOption = new ReadExcelOption();
|
//当前登录的用户账号
|
//String loginUserId = WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId();
|
String loginUserId = "developer";
|
UserEntityInfo userEntityInfo = new UserEntityInfo(loginUserId,null);
|
List<OrgDeptPO> poList = ExcelUtil.readDataObjectFromExcel(file, OrgDeptPO.class,excelOption,(value, po, fieldName)->{});
|
//去除都是空的情况
|
if(CollectionUtils.isEmpty(poList)){
|
return BaseResult.fail(ExcelLangCodeConstant.IMPORT_CONTENT_NULL,new String[]{});
|
}
|
/*部门导入几个比较重要的情景：
|
1、当前导入的数据是一个部门树结构(要判断用户手输的ID是否存在重复，输了就要判断是否在当前表格中重复，
|
并且保存时不能使用用户手输的ID，要根据手输ID和实际存储OID做对应映射，
|
并且不破坏表格中部门树结构，如果没手输ID就只需要关注parentId这个属性，
|
并且需要注意如果有的ID有，有的没有那就需要注意，既存在和系统中，
|
关联的部门树，又存在和当前表格中关联的部门树)。
|
2、当前导入的数据父id关联了已存在的部门oid(要查询父id这个部门是否存在，)
|
解决思路：最好是将表格中可能是部门树的给遍历成树，然后再做查重啥的处理
|
*/
|
//2、必填判空、判重（数据库判重和excel中判重），组装成保存用的数据对象
|
List<DeptInfo> deptInfoList = new ArrayList<>();
|
//2.1、用以存储excel中重复的数据，三个不可重复的字段）（Name不能为空，Name、Code同一父部门下唯一）
|
List<String> repeatIdList = new ArrayList<>();
|
Map<String,String> repeatNameMap = new HashMap<>();
|
Map<String,String> repeatNumMap = new HashMap<>();
|
Map<String,String> indexMap = new HashMap<>();
|
//2.2、存储用户手输的oid和实际存储oid的映射关系
|
Map<String, String> oidMap = new HashMap<>();
|
poList.stream().forEach(po->{
|
String parentId = Func.isBlank(po.getParentId()) ? "":po.getParentId();
|
//表格内判重
|
//部门名称判空
|
if(Func.isEmpty(po.getName())){
|
throw new VciBaseException("第【"+po.getRowIndex()+"】行，depterror,Reason:Name cannot be empty");
|
}else if(repeatNameMap.getOrDefault(po.getName(), "").equals(parentId)/*excel中同一部门下Name相等*/){
|
//同一部门下名称判重
|
throw new VciBaseException("第【"+po.getRowIndex()+"】行，deptnameerror,Reason: Names under the same department cannot be duplicated");
|
}else if(Func.isNotEmpty(po.getId()) && repeatIdList.equals(po.getId())){
|
throw new VciBaseException("第【"+po.getRowIndex()+"】行，deptiderror,Reason: The primary key cannot be duplicated");
|
}else if(Func.isNotEmpty(po.getNum()) && repeatNumMap.getOrDefault(po.getNum(),"").equals(parentId)/*excel中同一部门下编号存在 */){
|
throw new VciBaseException("第【"+po.getRowIndex()+"】行，deptnumerror,Reason: The number cannot be duplicated");
|
}else{
|
//2.2、查询数据库中的数据（查重ID和NUM），比较麻烦需要根据ParentID查询（所有只能单条查询进行判重）
|
//组装查重条件:同一部门下(parentId相等)，name或者num相等
|
HashMap<String, String> conditionMap = new HashMap<>();
|
conditionMap.put("plname",po.getName());
|
conditionMap.put("plnum",QueryOptionConstant.OR + po.getNum());
|
String pId = Func.isBlank(po.getParentId()) ? null:po.getParentId();
|
List<OrgDepartmentVO> repeatOrgDept = this.getDeptByDeptPOidAndCondition(pId, conditionMap);
|
//只要不为空就说明当前行数据在系统中重复
|
if(Func.isNotEmpty(repeatOrgDept)){
|
throw new VciBaseException("第【"+po.getRowIndex()+"】行，deptname or deptnum error,Reason: The name or number already exists in the system");
|
}
|
}
|
//存储校验通过的数据，以便后续excel查重
|
repeatNameMap.put(po.getName(),Func.isBlank(po.getParentId()) ? "":po.getParentId());
|
repeatIdList.add(po.getId());
|
repeatNumMap.put(po.getNum(),po.getParentId());
|
indexMap.put(po.getName(),po.getRowIndex());
|
//校验数据就该组装成DTO数据对象了
|
OrgDepartmentDTO dto = new OrgDepartmentDTO();
|
BeanUtil.convert(po,dto);
|
dto.setOid(po.getId());
|
dto.setId(po.getNum());
|
dto.setPkFatherDepartment(po.getParentId());
|
dto.setCreateTime(new Date());
|
dto.setCreator(loginUserId);
|
dto.setLastModifier(loginUserId);
|
dto.setStatus((short) 0);
|
//2.2、过程中处理主键转换问题最好是一条一条的处理ID是否存在还有ParentID是否存在的问题
|
//先判断是已存在的部门ID，还是不存在的部门ID，已存在系统中的ID就是为Dept:开头的
|
String pId = dto.getPkFatherDepartment();
|
//是已存在系统中的部门id
|
if(pId.contains("Dept:")){
|
//解析出真实的oid
|
String deParentId = Func.oidDeHash(pId.replace("Dept:", "").trim());
|
//解析出来的deParentId必须得在库中存在
|
if(Func.isBlank(deParentId) || Func.isEmpty(this.getDeptByDeptOid(deParentId))){
|
throw new VciBaseException("第【"+ po.getRowIndex() +"】行，deptparentiderror,Reason:Parent ID resolution error or does not exist in the system");
|
}
|
//替换掉临时使用的部门唯一标识
|
dto.setPkOrganizationName(deParentId);
|
}
|
//用户手输了部门oid，但是避免oid不规范需要，用规范oid进行替换，如果没输入保存时会自动生成oid
|
if(Func.isNotBlank(dto.getOid())){
|
String pkOid = VciBaseUtil.getPk();
|
dto.setOid(pkOid);
|
//oid映射关系，后续用来更新parentId
|
oidMap.put(dto.getOid(),pkOid);
|
}
|
DeptInfo deptInfo = this.changeOrgDeptDTOToDeptInfo(dto);
|
deptInfoList.add(deptInfo);
|
});
|
//3、处理id和parentId的映射关系:将用户手输的父ID转换成实际存储的ID
|
List<DeptInfo> lastDeptInfoList = deptInfoList.stream().map(info -> {
|
//parentId不为空并且没有Dept:相关的字符串,说明是用户手输的ParentId(导入的数据就是一个树结构)
|
if (Func.isNotBlank(info.parentId) || info.parentId.contains("Dept:")) {
|
//转换ParentId为实际要存储的部门ID
|
info.parentId = oidMap.get(info.parentId);
|
}
|
return info;
|
}).collect(Collectors.toList());
|
//4、对最终处理好的部门数据保存，实现最终统一保存，避免了一部分数据进了一部分数据因为校验没过没进库的问题
|
platformClientUtil.getFrameworkService().batchSaveDepart(
|
lastDeptInfoList.toArray(new DeptInfo[lastDeptInfoList.size()]),
|
userEntityInfo
|
);
|
}catch (Exception e){
|
if(logger.isErrorEnabled()){
|
logger.error("读取excel内容时或保存用户信息时出现了错误，具体原因：",e.getMessage());
|
}
|
e.printStackTrace();
|
return BaseResult.fail(LangBaseUtil.getErrorMsg(e),new String[]{},e);
|
}
|
return BaseResult.success("部门导入成功！");
|
}
|
|
public Map<String, OrgDepartmentVO> convertToMap(List<OrgDepartmentVO> orgDepartmentVOList) {
|
Map<String, OrgDepartmentVO> map = new HashMap<>();
|
for (OrgDepartmentVO orgDepartmentVO : orgDepartmentVOList) {
|
String key = buildKey(orgDepartmentVO, orgDepartmentVOList);
|
map.put(key, orgDepartmentVO);
|
}
|
return map;
|
}
|
|
private String buildKey(OrgDepartmentVO orgDepartmentVO, List<OrgDepartmentVO> 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<OrgDepartmentVO> orgDepartmentVOList) {
|
for (OrgDepartmentVO orgDepartmentVO : orgDepartmentVOList) {
|
if (pkFatherDepartment != null && pkFatherDepartment.equals(orgDepartmentVO.getOid())) {
|
return orgDepartmentVO;
|
}
|
}
|
return null;
|
}
|
|
}
|
