PLTWEB.git - Gitblit

package com.vci.frameworkcore.compatibility.impl;
 
import com.vci.corba.common.PLException;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.frameworkcore.compatibility.OrgDeptQueryServiceI;
import com.vci.frameworkcore.lcstatuspck.FrameworkDataLCStatus;
import com.vci.frameworkcore.model.OrgDeptForPlatform1;
import com.vci.frameworkcore.model.SmRoleForPlatform1;
import com.vci.frameworkcore.pagemodel.OrgDepartmentVO;
import com.vci.frameworkcore.pagemodel.SmRoleVO;
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.DataGrid;
import com.vci.starter.web.pagemodel.PageHelper;
import com.vci.starter.web.pagemodel.Tree;
import com.vci.starter.web.pagemodel.TreeQueryObject;
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 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());
            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<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, OrgDepartmentVO> deptVOMap = deptVOList.stream().distinct().collect(Collectors.toMap(s -> s.getOid(), t -> t));
            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 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();
        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");
        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<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 {
        if(Func.isEmpty(userOIds) || Func.isBlank(deptId)){
            return false;
        }
        //先进性查重处理
        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,null);
        }
        return true;
    }
 
    /**
     * 获取所有部门的信息
     * @return key：部门由名称组成的路径（/间隔），value对应最小层级的部门信息
     */
    @Override
    public Map<String, OrgDepartmentVO> getDeptAllTreeMap() {
        List<OrgDepartmentVO> orgDepartmentVOList = listAllLevelChildrenDeptByParentOid(null, null);
        Map<String, OrgDepartmentVO> stringOrgDepartmentVOMap = convertToMap(orgDepartmentVOList);
        return stringOrgDepartmentVOMap;
    }
 
    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;
    }
 
}