package com.vci.web.service.impl; import com.vci.common.util.ThreeDES; import com.vci.common.utility.ObjectUtility; import com.vci.constant.FrameWorkLangCodeConstant; import com.vci.constant.WebLangCodeConstant; import com.vci.corba.common.PLException; import com.vci.corba.common.data.UserEntityInfo; import com.vci.corba.framework.data.*; import com.vci.corba.omd.data.BusinessObject; import com.vci.corba.omd.etm.EnumItem; import com.vci.corba.omd.etm.EnumType; import com.vci.corba.volume.VolumeServicePrx; import com.vci.dto.SmUserDTO; import com.vci.dto.VciFileObjectDTO; import com.vci.enumpck.UI.OrgTypeEnum; import com.vci.enumpck.UI.VciFileTransProtocolEnum; import com.vci.enumpck.UserTypeEnum; import com.vci.lcstatuspck.FileLCStatus; import com.vci.model.SmUserDO; import com.vci.model.VciFileDocClassifyDO; import com.vci.model.VciFileObjectDO; import com.vci.model.VciFileVolumeDO; import com.vci.omd.utils.ObjectTool; import com.vci.pagemodel.*; import com.vci.po.SmUserPO; import com.vci.properties.OsConfig; 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.service.RevisionModelUtil; import com.vci.starter.web.enumpck.BooleanEnum; import com.vci.starter.web.enumpck.DataSecretEnum; 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.util.Lcm.Func; import com.vci.starter.web.wrapper.VciQueryWrapperForDO; import com.vci.web.dao.VciFileObjectDaoI; import com.vci.web.properties.WebProperties; import com.vci.web.service.*; import com.vci.web.util.PlatformClientUtil; import com.vci.web.util.WebUtil; import org.apache.commons.io.FilenameUtils; 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.BeanUtils; 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.multipart.MultipartFile; import javax.annotation.Resource; import java.io.*; import java.util.*; import java.util.stream.Collectors; import static com.vci.constant.FrameWorkLangCodeConstant.UPLOAD_FAIL; /** * 用户的查询相关的服务，可以兼容老平台和老的pdm * 其中包含登录相关的接口和参照，根据主键查询等接口 * 所有的数据全部转换为新平台的对象 * @author xiejun * @date 2020/3/10 */ @Service public class SmUserQueryServiceImpl implements SmUserQueryServiceI { /** * 平台调用客户端 */ @Autowired private PlatformClientUtil platformClientUtil; /** * 业务数据服务 */ @Autowired private WebBoServiceI boService; /** * 部门服务 */ @Autowired private OrgDeptQueryServiceI orgDeptQueryService; /** * 角色服务 */ @Autowired private SmRoleQueryServiceI smRoleQueryService; /** * 密码策略查询服务 */ @Autowired private WebPwdStrategyQueryServiceI smPwdStrategyQueryService; /** * 文件的卷服务 */ @Autowired private VciFileVolumeServiceI vciFileVolumeServiceI; /** * 版本和对象操作类 */ @Autowired(required = false) private RevisionModelUtil revisionModelUtil; /** * 配置对象 */ @Autowired private WebProperties webProperties; /** * 使用角色的属性查询用户时 */ private final static String QUERY_BY_ROLE_KEY_PREFIX = "pkrole."; /** * 角色的表格昵称 */ public static final String NICK_BY_ROLE = "pkrole"; /** * 使用部门查询的时候的查询字段 */ public static final String QUERY_FIELD_DEPARTMENT = "up.pldeptuid"; /** * 使用职务查询的时候的查询字段 */ public static final String QUERY_FIELD_DUTY = "pkDuty"; /** * 使用角色查询的时候的查询字段 */ public static final String QUERY_FIELD_ROLE = "roleUser.plroleuid"; /** * 密级的枚举key */ private static final String ENUM_USERSECURITYENUM = "usersecurityenum"; /** * 必填列 */ private List ColumnNameisRed = new ArrayList(); /** * 用户分页查询时获取部门放到这里避免重复查询 */ private Map> orgDepartmentVOMap; /** * 用户分页查询时获取角色放到这里避免重复查询 */ private Map> smRoleVOMap; /** * 用户分页查询时获取密码策略放到这里避免多次查询 */ private Map smPwdStrategyVOMap; /** * 日志 */ private Logger logger = LoggerFactory.getLogger(getClass()); /** * 文件上传业务层 */ @Autowired private VciFileUploadServiceI vciFileUploadServiceI; /** * 文件信息数据层 */ @Resource private VciFileObjectDaoI vciFileObjectMapper; /** * 平台配置 */ private OsConfig osConfig; /** * 检查用户是否存在，可以根据用户名，也可以根据用户oid * @param userName 传null，即用oid作为检查条件 * @param oid 传null，即用userName作为检查条件 * @return true存在，false不存在 */ @Override public boolean checkUserExist(String userName, String oid) throws PLException { if(Func.isEmpty(userName) && Func.isEmpty(oid)){ throw new PLException("500", new String[] { "检查用户是否存在时，传递的参数用户名和用户oid都为空！"}); } UserInfo userInfo = null; if(Func.isNotEmpty(userName)) { userInfo = platformClientUtil.getFrameworkService().getUserObjectByUserName(userName); }else{ userInfo = platformClientUtil.getFrameworkService().getUserObjectByoid(oid); } return Func.isNotEmpty(userInfo); } /** * 根据用户名获取用户的对象，不区分大小写 * @param userId 用户名 * @return 用户的显示对象，如果用户不存在则返回null，不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public SmUserVO getUserByUserId(String userId) throws VciBaseException { WebUtil.alertNotNull(userId,"用户名"); try { UserInfo userInfo = platformClientUtil.getFrameworkService().getUserObjectByUserName(userId); return userInfo2VO(userInfo); } catch (PLException e) { throw new VciBaseException("登录时，获取用户信息失败："+e.getMessage()); } } /** * 使用字段获取用户的信息 * @param queryField 字段 * @param queryValue 查询值 * @return 用户的信息 * @throws VciBaseException 查询出错的时候会抛出异常 */ private SmUserVO getUserByField(String queryField, String queryValue) throws VciBaseException{ VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(null, SmUserDO.class,null,true); queryWrapper.eq(queryWrapper.getTableNick() + "." +queryField,queryValue); queryWrapper.setDistinct(true); queryWrapper.wrapperSql(); addRoleQuerySql(queryWrapper); String sql = queryWrapper.getSelectFieldSql(); String fromSql = " from pluser " + queryWrapper.getTableNick() + " left join pluserdept up on " + queryWrapper.getTableNick() + ".pluid = up.pluseruid left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapper.getTableNick() + ".pluid = pkUserPassword.pluseruid " + queryWrapper.getLinkTableSql() + (StringUtils.isNotBlank(queryWrapper.getWhereSql())?(" where " + queryWrapper.getWhereSql()):""); try{ String[][] sqlQueryResult = platformClientUtil.getBOFService().getSqlQueryResult(sql + fromSql, null); if(sqlQueryResult.length>0){ BusinessObject cbo = WebUtil.arryAndSqlToBusinessObject(queryWrapper.getSelectFieldSql(),sqlQueryResult[0]); return cbo2VO(cbo); } }catch (Exception e){ throw new VciBaseException("数据解析错误:" + e ); } return null; } /** * 使用属性集合查询用户 * @param queryField 查询的字段 * @param queryValues 查询的值集合 * @return 用户的显示对象 * @throws VciBaseException 查询出错的时候会抛出异常 */ private List listUserByField(String queryField,Collection queryValues) throws VciBaseException{ List userVOList = new ArrayList<>(); WebUtil.switchCollectionForOracleIn(queryValues).forEach(values->{ VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(null,SmUserDO.class,null,true); queryWrapper.in(queryWrapper.getTableNick() + "." + queryField,WebUtil.toInSql(values.toArray(new String[0]))); queryWrapper.setDistinct(true); queryWrapper.wrapperSql(); String sql = queryWrapper.getSelectFieldSql(); String fromSql = " from pluser " + queryWrapper.getTableNick() + " left join pluserdept up on " + queryWrapper.getTableNick() + ".pluid = up.pluseruid left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapper.getTableNick() + ".pluid = pkUserPassword.pluseruid " + queryWrapper.getLinkTableSql() + (StringUtils.isNotBlank(queryWrapper.getWhereSql())?(" where " + queryWrapper.getWhereSql()):""); List dataList = boService.queryBySql(sql + fromSql, null); if(!CollectionUtils.isEmpty(dataList)){ dataList.stream().forEach(cbo->{ userVOList.add(cbo2VO(cbo)); }); } }); return userVOList; } /** * 批量获取用户的信息（根据用户名） * @param userIdCollections 用户名的集合,可以超过1000个 * @return 用户的显示对象，如果用户不存在则返回空的列表，不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public List listUserByUserIds(Collection userIdCollections) { WebUtil.alertNotNull(userIdCollections,"用户名集合"); try { UserInfo[] userInfo = platformClientUtil.getFrameworkService().fetchUserInfoByNames(VciBaseUtil.collection2StrArr(userIdCollections)); return userInfoArr2VO(userInfo); } catch (PLException e) { throw new VciBaseException("获取用户失败："+e.getMessage()); } } /** * 根据用户主键获取用户的信息 * @param userOid 用户主键 * @return 用户的显示对象，如果用户不存在则返回null，不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public SmUserVO getUserByUserOid(String userOid) { WebUtil.alertNotNull(userOid,"用户主键"); try { UserInfo userInfo = platformClientUtil.getFrameworkService().getUserObjectByoid(userOid); return userInfo2VO(userInfo); } catch (PLException e) { throw new VciBaseException("获取用户失败："+e.getMessage()); } } /** * 批量获取用户的信息 （根据用户主键） * @param userOidCollections 用户主键的集合，可以超过1000个 * @return 用户的显示对象，如果用户不存在则返回空的列表，不会抛出异常 * @throws VciBaseException 参数为空或者数据库存在问题的时候会抛出异常 */ @Override public List listUserByUserOids(Collection userOidCollections) { WebUtil.alertNotNull(userOidCollections,"用户主键集合"); try { UserInfo[] userInfoArr = platformClientUtil.getFrameworkService().getUserObjectByoids(VciBaseUtil.collection2StrArr(userOidCollections)); return userInfoArr2VO(userInfoArr); } catch (PLException e) { throw new VciBaseException("获取用户信息失败:"+e.getMessage()); } } /** * 业务数据数组转显示对象集合 * @param userInfoArr 业务数据数组 * @return 显示对象集合 */ private List userInfoArr2VO(UserInfo[] userInfoArr) throws PLException { List userVOList = new ArrayList<>(); for(UserInfo userInfo : userInfoArr){ userVOList.add(userInfo2VO(userInfo)); } return userVOList; } /** * 业务数据转换为显示对象 * @param userInfo 平台返回的业务数据 * @return 用户显示对象 */ private SmUserVO userInfo2VO(UserInfo userInfo) throws PLException { if(Func.isBlank(userInfo.id)){ return new SmUserVO(); } SmUserVO smUserVO = new SmUserVO(); smUserVO.setOid(userInfo.id); smUserVO.setId(userInfo.userName); smUserVO.setName(userInfo.trueName); smUserVO.setSecretGrade(userInfo.secretGrade); //密级处理 String secretGrade = "" + userInfo.secretGrade; EnumType item = platformClientUtil.getEnumService().getEnumTypeByName(ENUM_USERSECURITYENUM); EnumItem[] children = item.items; for(EnumItem child: children){ if(child.value.equals(secretGrade)){ smUserVO.setSecretGradeText(child.name); break; } } smUserVO.setUserType(String.valueOf(userInfo.userType)); smUserVO.setUserTypeText(UserTypeEnum.getTextByValue(String.valueOf(userInfo.userType))); smUserVO.setDescription(userInfo.desc); smUserVO.setEmail(userInfo.email); smUserVO.setStatus(userInfo.status); smUserVO.setPassword(userInfo.pwd); smUserVO.setConfirmPassword(userInfo.pwd); //用户所属部门的查询设置 Map orgDepartmentVOList; //查看全局变量中是否存在部门信息，存在的情况最主要是针对多条用户查询的时候避免重复查询的 if(Func.isNotEmpty(orgDepartmentVOMap)){ orgDepartmentVOList = Func.isNotEmpty(orgDepartmentVOMap.get(userInfo.id)) ? orgDepartmentVOMap.get(userInfo.id):new HashMap<>(); }else { Map> tempDeptMap = orgDeptQueryService.batchMapDeptNameByUserOids(Arrays.asList(userInfo.id), null); orgDepartmentVOList = Func.isNotEmpty(tempDeptMap.get(userInfo.id)) ? tempDeptMap.get(userInfo.id):new HashMap<>(); } //部门oid，正常情况下一个用户只会存在一个部门下 smUserVO.setPkDepartment(orgDepartmentVOList.keySet().stream().collect(Collectors.joining(","))); smUserVO.setPkDepartmentName(orgDepartmentVOList.values().stream().collect(Collectors.joining(","))); //密码策略查询设置 SmPasswordStrategyVO smPasswordStrategyVO; if(Func.isNotEmpty(smPwdStrategyVOMap)){ smPasswordStrategyVO = smPwdStrategyVOMap.getOrDefault(userInfo.id,new SmPasswordStrategyVO()); }else { smPasswordStrategyVO = smPwdStrategyQueryService.getPasswordStrategyVOByUserOid(userInfo.id); //如果不存在就获取默认的 smPasswordStrategyVO = Func.isNotEmpty(smPasswordStrategyVO) ? smPasswordStrategyVO:smPwdStrategyQueryService.getPasswordStrategyVOByDefault(); } smUserVO.setPkPasswordStrategy(smPasswordStrategyVO.getOid()); smUserVO.setPkPasswordStrategyName(smPasswordStrategyVO.getName()); //角色查询设置 List smRoleVOList; if (Func.isNotEmpty(smRoleVOMap)) { smRoleVOList = smRoleVOMap.get(userInfo.id); }else { smRoleVOList = smRoleQueryService.listRoleByUserOid(userInfo.id,null); } smUserVO.setPkPerson( Func.isEmpty(smRoleVOList) ? null:smRoleVOList.stream().map(SmRoleVO::getOid).collect(Collectors.joining(",")) ); smUserVO.setPkPersonName( Func.isEmpty(smRoleVOList) ? null:smRoleVOList.stream().map(SmRoleVO::getName).collect(Collectors.joining(",")) ); //是否部门领导 smUserVO.setIsDeptLeader(userInfo.isDeptLeader.equals("0") ? "不是":"是"); //专业 smUserVO.setSpecialties(userInfo.specialties); UserLogonInfo lockObj = platformClientUtil.getFrameworkService().fetchUserLogonObj(userInfo.id); smUserVO.setLockFlag(lockObj.plWrongNum != 0); smUserVO.setCreator(userInfo.createUser); smUserVO.setCreateTime(VciDateUtil.long2Date(userInfo.createTime)); smUserVO.setLastModifier(userInfo.updateUser); smUserVO.setLastLoginTime(VciDateUtil.long2Date(userInfo.updateTime)); smUserVO.setLastModifyPasswordTime(VciDateUtil.long2Date(userInfo.pwdUpdateTime)); smUserVO.setPhoto(userInfo.photo); return smUserVO; } /** * 用户的数据对象转换为显示对象 * @param userDOS 用户 * @return 显示对象 */ private List smUserDO2VOs(List userDOS){ List userVOList = new ArrayList<>(); Optional.ofNullable(userDOS).orElseGet(()->new ArrayList<>()).stream().forEach(userDO->{ userVOList.add(smUserDO2VO(userDO)); }); return userVOList; } /** * 用户的数据对象转换为显示对象 * @param smUserDO * @return */ private SmUserVO smUserDO2VO(SmUserDO smUserDO){ SmUserVO smUserVO = new SmUserVO(); BeanUtilForVCI.convert(smUserDO,smUserVO); return smUserVO; } /** * 使用属性来的查询用户的信息 * @param queryField 查询的属性 * @param queryValue 查询的值 * @param queryMap 查询的条件，如果是角色的属性，需要使用pkrole.xxx * @param notIn 是否为不包含 * @return 用户的对象 */ private List listUserByQueryField(String queryField,String queryValue,Map queryMap,boolean notIn){ if(StringUtils.isBlank(queryValue)){ return new ArrayList<>(); } VciQueryWrapperForDO queryWrapper = getQueryWrapper(queryField, queryValue, queryMap, null, notIn); List userVOList = new ArrayList<>(); queryWrapper.wrapperSql(); String sql = queryWrapper.getSelectFieldSql(); String roleSql = " left join pluserrole roleuser on " + queryWrapper.getTableNick() + ".pluid = roleuser.pluseruid "; String fromSql = " from pluser " + queryWrapper.getTableNick() + " left join pluserdept up on " + queryWrapper.getTableNick() + ".pluid = up.pluseruid left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapper.getTableNick() + ".pluid = pkUserPassword.pluseruid " + (QUERY_FIELD_ROLE.equalsIgnoreCase(queryField)?roleSql:"") + queryWrapper.getLinkTableSql() + (StringUtils.isNotBlank(queryWrapper.getWhereSql())?(" where " + queryWrapper.getWhereSql()):""); List dataList = boService.queryBySql(sql + fromSql, null); if(!CollectionUtils.isEmpty(dataList)){ dataList.stream().forEach(cbo->{ userVOList.add(cbo2VO(cbo)); }); } return userVOList; } /** * 业务数据转换为显示对象 * @param cbo 业务数据 * @return 显示对象 */ private SmUserVO cbo2VO(BusinessObject cbo){ SmUserDO userDO = new SmUserDO(); SmUserVO userVO = new SmUserVO(); WebUtil.copyValueToObjectFromCbos(cbo,userDO); if("0".equals(userDO.getLockFlag())){ userDO.setLockFlag(BooleanEnum.FASLE.getValue()); }else{ userDO.setLockFlag(BooleanEnum.TRUE.getValue()); } BeanUtilForVCI.convert(userDO,userVO); return userVO; } /** * 使用某个属性来查询用户的信息 * @param queryField 查询的属性名称 * @param queryValue 查询的值 * @param queryMap 其他查询条件，如果是角色的属性，需要使用pkrole.xxx * @param pageHelper 分页对象 * @param notIn 是否为不包含 * @return 用户的显示对象的列表 */ private DataGrid gridUserByQueryField(String queryField,String queryValue, Map queryMap, PageHelper pageHelper,boolean notIn){ /*if(StringUtils.isBlank(queryValue)){ return new DataGrid<>(); }*/ PageHelper newPageHelper = new PageHelper(-1); newPageHelper.setSort(pageHelper.getSort()); newPageHelper.setOrder(pageHelper.getOrder()); VciQueryWrapperForDO queryWrapper = getQueryWrapper(queryField, queryValue, queryMap, newPageHelper, notIn); List userVOList = new ArrayList<>(); queryWrapper.wrapperSql(); String sql = queryWrapper.getSelectFieldSql(); String fromSql = " from pluser " + queryWrapper.getTableNick() + " left join pluserdept up on " + queryWrapper.getTableNick() + ".pluid = up.pluseruid left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapper.getTableNick() + ".pluid = pkUserPassword.pluseruid " + " left join PLUSERROLE roleuser on roleuser.PLUSERUID = "+queryWrapper.getTableNick() +".PLUID"+ queryWrapper.getLinkTableSql() + (StringUtils.isNotBlank(queryWrapper.getWhereSql())?(" where " + queryWrapper.getWhereSql()):""); boolean isPage = pageHelper != null && pageHelper.getLimit() > 0; String pageSubfix = " ) A where rownum < " + (pageHelper.getLimit() * pageHelper.getPage() + 1) + ") where RN >= " + (pageHelper.getLimit() * (pageHelper.getPage() - 1) + 1); List pageSelectList = new ArrayList<>(); String temp = queryWrapper.getSelectFieldSql(); if(StringUtils.isNotBlank(temp)){ String[] split = temp.split(","); if(split!=null&&split.length>0){ for (int i = 0; i < split.length; i++) { String s = split[i]; if(s.contains(" as ")){ pageSelectList.add(s.split(" as ")[1]); } } } } List dataList = boService.queryBySql((isPage?("select " + pageSelectList.stream().collect(Collectors.joining(","))+ " from (select A.*,rownum RN from ( "):"") + sql + fromSql + (isPage?pageSubfix:""), null); if(!CollectionUtils.isEmpty(dataList)){ dataList.stream().forEach(cbo->{ userVOList.add(cbo2VO(cbo)); }); } DataGrid dataGrid = new DataGrid<>(); if(!CollectionUtils.isEmpty(dataList)){ dataGrid.setData(userVOList); queryWrapper.clearPage(); dataGrid.setTotal(boService.queryCountBySql("select count(*) as count " + fromSql,null)); } return dataGrid; } /** * 用户管理界面分页查询 * @param conditionMap 查询条件 * @param pageHelper 分页参数 * @return */ @Override public DataGrid getDataGridUsers(Map conditionMap, PageHelper pageHelper) { if(pageHelper == null){ pageHelper = new PageHelper(-1); } pageHelper.addDefaultAsc("PLTRUENAME"); String loginUserId = WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(); DataGrid dataGrid = null; try { //String loginUserId = "Ludc"; //分页查询 UserInfo[] userInfos = platformClientUtil.getFrameworkService().fetchUserInfoByCondition( conditionMap.get("name"), conditionMap.get("id"), conditionMap.get("pkDepartment"), conditionMap.get("pkPerson"), loginUserId, //当前登录的用户名 pageHelper.getPage(), pageHelper.getLimit() ); dataGrid = new DataGrid<>(); if(Func.isNotEmpty(userInfos)){ List idList = Arrays.stream(userInfos).map(item -> item.id).collect(Collectors.toList()); orgDepartmentVOMap = orgDeptQueryService.batchMapDeptNameByUserOids(idList, null); smRoleVOMap = smRoleQueryService.batchListRoleByUserOids(idList,null); smPwdStrategyVOMap = smPwdStrategyQueryService.batchSmPwdStrategyByUserOids(idList); dataGrid.setData(userInfoArr2VO(userInfos)); //用完了清空 orgDepartmentVOMap = null; smRoleVOMap = null; smPwdStrategyVOMap = null; //TODO: 这个统计总数有问题，带过去的参数不能像上面那个fetchUserInfoByCondition查询一样统计的却的总数 dataGrid.setTotal( platformClientUtil.getFrameworkService().getUserTotalByCondition( conditionMap.get("name"), conditionMap.get("id"), conditionMap.get("pkDepartment"), conditionMap.get("pkPerson"), loginUserId //当前登录的用户名 ) ); } } catch (Exception e) { throw new VciBaseException("获取用户列表失败！", new Object[]{}, e); } return dataGrid; } /** * 添加角色的查询的sql, 自动判断是否需要查询角色 * @param queryMap 查询条件 * @param queryWrapper 查询封装器 */ private void addRoleQuerySql(Map queryMap,VciQueryWrapperForDO queryWrapper){ if((queryMap !=null&& (queryMap.keySet().stream().anyMatch(s->s.toLowerCase().startsWith(QUERY_BY_ROLE_KEY_PREFIX)) || queryMap.containsKey(QUERY_FIELD_ROLE))) || (queryWrapper.getConditionMap() !=null && queryWrapper.getConditionMap().containsKey(QUERY_FIELD_ROLE))){ addRoleQuerySql(queryWrapper); } } /** * 添加角色的查询的sql * @param queryWrapper 查询封装器 */ private void addRoleQuerySql(VciQueryWrapperForDO queryWrapper){ String nick = queryWrapper.getTableNick(); queryWrapper.addLinkTableSql(" left join pluserrole roleUser on " + nick + ".pluid = roleUser.pluseruid left join plrole " + NICK_BY_ROLE + " on roleUser.plroleuid = " + NICK_BY_ROLE + ".pluid "); } /** * 根据用户名获取用户的姓名 * @param userId 用户名 * @return 用户姓名，如果不存在会返回Null */ @Override public String getUserNameByUserId(String userId) { SmUserVO userVO = getUserByUserId(userId); return userVO == null?"":userVO.getName(); } /** * 根据用户主键获取用户的姓名 * @param userOid 用户主键 * @return 用户姓名，如果不存在会返回null */ @Override public String getUserNameByUserOid(String userOid) { SmUserVO userVO = getUserByUserOid(userOid); return userVO.getName(); } /** * 统计部门下的用户：包含子部门下的用户 * @param deptOid * @param queryMap * @return * @throws VciBaseException */ @Override public List countSmUserByDeptOid(String deptOid, Map queryMap) { //是否查询子部门下关联的用户 List orgDepartmentVOList = orgDeptQueryService.listAllLevelChildrenDeptByParentOid(deptOid, null); List deptOidCollection = orgDepartmentVOList.stream().map(OrgDepartmentVO::getOid).collect(Collectors.toList()); deptOidCollection.add(deptOid);//将当前层的oid也放进去 List smUserVOList = listUserVOByDeptOid(queryMap, deptOidCollection, false); if(Func.isEmpty(smUserVOList)){ return new ArrayList<>(); } Map> smRoleVOMap = smRoleQueryService.batchListRoleByUserOids(smUserVOList.stream().map(SmUserVO::getOid).collect(Collectors.toSet()), null); smUserVOList = smUserVOList.stream().map(vo->{ List smRoleVOS = smRoleVOMap.get(vo.getOid()); vo.setPkPerson( Func.isEmpty(smRoleVOS) ? null:smRoleVOS.stream().map(SmRoleVO::getOid).collect(Collectors.joining(",")) ); vo.setPkPersonName( Func.isEmpty(smRoleVOS) ? null:smRoleVOS.stream().map(SmRoleVO::getName).collect(Collectors.joining(",")) ); return vo; }).collect(Collectors.toList()); return smUserVOList; } /** * 查询在某个部门下的用户对象 * @param deptOid 部门的主键 * @param queryMap 查询条件，如果是部门的某个属性作为查询条件，则可以使用pkDepartment.xxx这样的方式 * @return 用户的显示对象列表 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public List listUserByDeptOid(String deptOid, Map queryMap) { //查询当前选中的部门下的用户 return listUserVOByDeptOid(queryMap,Arrays.asList(deptOid),false ); } /** * 查询不在某个部门下的用户对象列表 * @param deptOid 部门的主键 * @param queryMap 查询条件，如果是部门的某个属性作为查询条件，则可以使用pkDepartment.xxx这样的方式 * @return 用户的显示对象列表，默认使用用户名升序排列 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public List listUserUnInDeptOid(String deptOid, Map queryMap) { // TODO:根据当前登录的用户决定能查那些用户 String userType = "0";//WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUsertype(); //根据当前登录的用户类型不同，查询不同的用户 if(UserTypeEnum.SUPPER_ADMIN.getValue().equals(userType)){ //超管用户只能查管理员用户 queryMap.put("plusertype", "1"); }else{ //除了超管都只能查普通用户 queryMap.put("plusertype", "2"); } return listUserVOByDeptOid(queryMap,Arrays.asList(deptOid),true); } /** * 用户根据部门查询的统一方法 * @param conditionMap 查询条件 * @param deptOidList 部门主键 * @param notIn true待选，false已选 * @return */ private List listUserVOByDeptOid(Map conditionMap/*放置查询条件*/,List deptOidList,boolean notIn){ //先查询已选人员oid List userOidList = new ArrayList<>(); WebUtil.switchCollectionForOracleIn(deptOidList).stream().forEach(deptOids->{ String sql = "select pluseruid,pldeptuid from pluserdept where pldeptuid in (" + WebUtil.toInSql(deptOids.toArray(new String[0])) + ")"; List cbos = boService.queryBySql(sql, null); //遍历出用户主键 cbos.stream().forEach(cbo->{ userOidList.add(ObjectTool.getNewBOAttributeValue(cbo,"pluseruid")); }); }); //根据用户oid查询用户 VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(conditionMap, SmUserDO.class); //添加连表查询条件 queryWrapperForDO.setLinkTableSql(" left join pluserdept up on " + queryWrapperForDO.getTableNick() + ".pluid = up.pluseruid" + " left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapperForDO.getTableNick() + ".pluid = pkUserPassword.pluseruid "); queryWrapperForDO.setOrderSql("order by " + queryWrapperForDO.getTableNick() + ".pltrueName"); List smUserDOList = new ArrayList<>(); //userOidList为空时的两种情况 if(Func.isEmpty(userOidList)){ //如果是已选查询说明已选为空直接返回空 if(!notIn){ return new ArrayList<>(); } //不是已选查询说明待选为空，直接查询用户 smUserDOList.addAll(boService.selectByQueryWrapper(queryWrapperForDO, SmUserDO.class)); }else{ //已选查询，或待选查询，但是该部门存在相关配置 WebUtil.switchCollectionForOracleIn(userOidList).stream().forEach(userOids->{ //查询不在范围内的：待选人员 if(notIn){ queryWrapperForDO.notIn(queryWrapperForDO.getTableNick()+".pluid",WebUtil.toInSql(userOids.toArray(new String[0]))); }else{ //已选人员和统计 queryWrapperForDO.in(queryWrapperForDO.getTableNick()+".pluid",WebUtil.toInSql(userOids.toArray(new String[0]))); } smUserDOList.addAll(boService.selectByQueryWrapper(queryWrapperForDO, SmUserDO.class)); }); } return smUserDO2VOs(smUserDOList); } /** * 获取查询封装器，默认只查了plstatus=0和plusertype=2（改成根据当前登录的用户来决定查什么类型的用户）， * 排序默认plusername * @param queryField 查询属性 * @param queryValue 查询的值 * @param queryMap 查询条件，如果是角色的属性，需要使用pkrole.xxx * @param pageHelper 分页对象 * @param notIn 是否为不包含 * @return 查询封装器 */ private VciQueryWrapperForDO getQueryWrapper(String queryField,String queryValue,Map queryMap,PageHelper pageHelper,boolean notIn){ if(pageHelper == null){ pageHelper = new PageHelper(-1); } pageHelper.addDefaultAsc("plusername"); VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(queryMap,SmUserDO.class,pageHelper); if(StringUtils.isNotBlank(queryField)) { if (queryValue.contains(",")) { if (notIn) { queryWrapperForDO.notIn(queryField, VciBaseUtil.toInSql(VciBaseUtil.str2List(queryValue).toArray(new String[0]))); } else { queryWrapperForDO.in(queryField, VciBaseUtil.toInSql(VciBaseUtil.str2List(queryValue).toArray(new String[0]))); } } else { if (notIn) { queryWrapperForDO.neq(queryField, queryValue); } else { queryWrapperForDO.eq(queryField, queryValue); } } } addRoleQuerySql(queryMap,queryWrapperForDO); queryWrapperForDO.eq("plstatus", "0"); // TODO:根据当前登录的用户决定能查那些用户 SessionInfo loginUser = WebThreadLocalUtil.getCurrentUserSessionInfoInThread(); //根据当前登录的用户类型不同，查询不同的用户 if(UserTypeEnum.SUPPER_ADMIN.getValue().equals(loginUser.getUsertype())){ //超管用户只能查管理员用户 queryMap.put("plusertype", "1"); }else{ //除了超管都只能查普通用户 queryMap.put("plusertype", "2"); } return queryWrapperForDO; } /** * 批量根据部门的主键获取用户 * @param deptOidCollection 部门的主键集合 * @return 部门主键和对应的用户显示对象列表的映射，key部门的主键，value是这个部门下的用户 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public Map> batchListUserByDeptOids( Collection deptOidCollection) { if(CollectionUtils.isEmpty(deptOidCollection)){ return new HashMap<>(); } List userVOList = listUserByQueryField(QUERY_FIELD_DEPARTMENT,deptOidCollection.stream().collect(Collectors.joining(",")),null,false ); if(!CollectionUtils.isEmpty(userVOList)){ return userVOList.stream().filter(s->StringUtils.isNotBlank(s.getPkDepartment())).collect(Collectors.groupingBy(SmUserVO::getPkDepartment)); } return new HashMap<>(); } /** * 查询某个角色下的用户对象 * @param roleOid 角色的主键 * @param queryMap 查询条件，如果是角色的某个属性作为查询条件，则可以使用pkRole.xxx这样的方式 * @return 用户的显示对象列表 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public List listUserByRoleOid(String roleOid, Map queryMap) { return listUserVOByRoleOid(queryMap,roleOid,false); } /** * 查询不在某个角色下的用户对象列表 * @param roleOid 角色的主键 * @param queryMap 查询条件，如果是角色的某个属性作为查询条件，则可以使用pkRole.xxx这样的方式 * @return 用户的显示对象列表，默认使用用户名升序排列 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public List listUserUnInRoleOid(String roleOid, Map queryMap) { // TODO:根据当前登录的用户决定能查那些用户 String usertype = WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUsertype(); //根据当前登录的用户类型不同，查询不同的用户 if(UserTypeEnum.SUPPER_ADMIN.getValue().equals(usertype)){ //超管用户只能查管理员用户 queryMap.put("plusertype", "1"); }else{ //除了超管都只能查普通用户 queryMap.put("plusertype", "2"); } return listUserVOByRoleOid(queryMap,roleOid,true); } /** * 用户根据角色查询的统一方法 * @param conditionMap 查询条件 * @param roleOid 角色主键 * @param notIn true不在范围内，false再范围内 * @return */ private List listUserVOByRoleOid(Map conditionMap,String roleOid,boolean notIn){ //listUserByQueryField这个方法暂时不能满足我现在的查询需求，并且引用的地方较多，所以不太好改动 //1、先查询与当前角色存在关联关系的用户 String sql = "select pluseruid,plroleuid from pluserrole where plroleuid = '" + roleOid +"'"; List cbos = boService.queryBySql(sql, null); List userOidList = new ArrayList<>(); if(CollectionUtils.isEmpty(cbos)){ return new ArrayList<>(); } //遍历出用户主键 cbos.stream().forEach(cbo->{ userOidList.add(ObjectTool.getNewBOAttributeValue(cbo,"pluseruid")); }); //2、再查询用户 VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(conditionMap, SmUserDO.class); List smUserDOS = new ArrayList<>(); queryWrapperForDO.setLinkTableSql(" left join pluserdept up on " + queryWrapperForDO.getTableNick() + ".pluid = up.pluseruid" + " left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapperForDO.getTableNick() + ".pluid = pkUserPassword.pluseruid "); WebUtil.switchCollectionForOracleIn(userOidList).stream().forEach(userOids->{ if(notIn){ queryWrapperForDO.notIn("pluid",WebUtil.toInSql(userOids.toArray(new String[0]))); }else{ queryWrapperForDO.in("pluid",WebUtil.toInSql(userOids.toArray(new String[0]))); } smUserDOS.addAll(boService.selectByQueryWrapper(queryWrapperForDO, SmUserDO.class)); }); return smUserDO2VOs(smUserDOS); } /** * 批量根据角色的主键获取用户 * @param roleOidCollection 角色的主键集合 * @return 角色主键和对应的用户显示对象列表的映射，key角色的主键，value是这个角色下的用户 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常 */ @Override public Map> batchListUserByRoleOids( Collection roleOidCollection) { if(CollectionUtils.isEmpty(roleOidCollection)){ return new HashMap<>(); } List userVOList = listUserByQueryField(QUERY_FIELD_ROLE,roleOidCollection.stream().collect(Collectors.joining(",")),null,false ); //需要查询每个角色和用户的关联信息 Map> roleHasUserOids = new HashMap<>(); VciBaseUtil.switchCollectionForOracleIn(roleOidCollection).stream().forEach(roleOids->{ String sql = " select plroleuid,pluseruid from pluserrole where plroleuid in (" + VciBaseUtil.toInSql(roleOids.toArray(new String[0])) + ")"; List dataMap = boService.queryBySqlForMap(sql, null); if(!CollectionUtils.isEmpty(dataMap)){ dataMap.stream().forEach(data->{ String roleOid = (String)data.get("plroleuid"); List userOids = roleHasUserOids.getOrDefault(roleOid,new ArrayList<>()); userOids.add((String)data.get("pluseruid")); roleHasUserOids.put(roleOid,userOids); }); } }); if(!CollectionUtils.isEmpty(userVOList)){ //需要查询每个角色和用户的关联信息 Map userVOMap = userVOList.stream().collect(Collectors.toMap(s -> s.getOid(), t -> t)); Map> roleHasUserVOMap = new HashMap<>(); roleHasUserOids.forEach((roleOid,userOids)->{ List userVOS = new ArrayList<>(); userOids.stream().forEach(userOid->{ if(userVOMap.containsKey(userOid)){ userVOS.add(userVOMap.get(userOid)); } }); roleHasUserVOMap.put(roleOid,userVOS); }); return roleHasUserVOMap; } return new HashMap<>(); } /** * 参照生效的用户 * @param queryMap 查询条件 * @param pageHelper 分页对象 * @return 用户的显示对象，默认使用用户名升序排列 * @throws VciBaseException 查询出错的时候会抛出异常 */ @Override public DataGrid refGridUsers(Map queryMap, PageHelper pageHelper) { return gridUserByQueryField(null,null,queryMap,pageHelper,false); } /** * 参照用户的树形显示 * @param treeQueryObject 树型接口查询对象 * @return 用户的树形信息，里面会包含用户对象里的所有属性 * @throws VciBaseException 查询出错的时候会抛出异常 */ @Override public List refTreeUsers(TreeQueryObject treeQueryObject) { VciQueryWrapperForDO queryWrapper = getQueryWrapper(null, null, treeQueryObject.getConditionMap(), null, false); queryWrapper.wrapperSql(); String sql = queryWrapper.getSelectFieldSql(); String fromSql = " from pluser " + queryWrapper.getTableNick() + " left join pluserdept up on " + queryWrapper.getTableNick() + ".pluid = up.pluseruid left join pldept pkDepartment on up.pldeptuid = pkDepartment.pluid " + " left join PLUSERPASSWORDSTRATEGY pkUserPassword on " +queryWrapper.getTableNick() + ".pluid = pkUserPassword.pluseruid " + queryWrapper.getLinkTableSql() + (StringUtils.isNotBlank(queryWrapper.getWhereSql())?(" where " + queryWrapper.getWhereSql()):""); List dataList = boService.queryBySql(sql + fromSql, null); List treeList = new ArrayList<>(); if(!CollectionUtils.isEmpty(dataList)){ dataList.stream().forEach(cbo->{ Tree tree = new Tree(); tree.setOid(cbo.oid); tree.setText(cbo.id + " " + cbo.name); Map attributeMap = new HashMap<>(); WebUtil.copyValueToMapFromBos(cbo,attributeMap); tree.setAttributes(attributeMap); tree.setLeaf(true); treeList.add(tree); }); } return treeList; } /** * 获取角色数据 * @param treeQueryObject * @return * @throws VciBaseException */ @Override public List refPersonOrgTree(TreeQueryObject treeQueryObject) { List rootTreeList=new ArrayList<>(); Map conditionMap=treeQueryObject.getConditionMap(); if(CollectionUtils.isEmpty(conditionMap)) { conditionMap = new HashMap<>(); } String dataType=StringUtils.isNotBlank(conditionMap.get("dataType"))?conditionMap.get("dataType"):"";//数据类型 String parentId=StringUtils.isNotBlank(conditionMap.get("parentId"))?conditionMap.get("parentId"):"";//父节点 String orgType=StringUtils.isNotBlank(conditionMap.get("orgType"))?conditionMap.get("orgType"):"";//接口查询包含的类型 try { initChildTree(dataType,orgType,parentId,rootTreeList); } catch (PLException e) { throw new VciBaseException("用户权限选择树加载失败:"+e.getMessage()); } return rootTreeList; } /** * * @param dataType * @param orgType * @param parentId */ private void initChildTree(String dataType,String orgType, String parentId, ListrootTreeList) throws PLException { if(StringUtils.isBlank(parentId)){ Tree rootTree=new Tree("root","人员组织","root"); rootTree.setParentBtmName("root"); rootTree.setExpanded(true); List childList=new ArrayList<>(); if(OrgTypeEnum.ORG_TYPE_USER.getValue().equals(orgType)){//如果是人员 Tree userTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_USER.getValue(),"用户",OrgTypeEnum.ORG_TYPE_USER.getValue(),OrgTypeEnum.ORG_TYPE_USER.getValue(),rootTree); childList.add(userTree); }else if(OrgTypeEnum.ORG_TYPE_DEPT.getValue().equals(orgType)){//如果是部门 Tree departmentTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_DEPT.getValue(),"部门",OrgTypeEnum.ORG_TYPE_DEPT.getValue(),OrgTypeEnum.ORG_TYPE_DEPT.getValue(),rootTree); childList.add(departmentTree); }else if(OrgTypeEnum.ORG_TYPE_ROLE.getValue().equals(orgType)){//如果是角色 Tree roleTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_ROLE.getValue(),"角色",OrgTypeEnum.ORG_TYPE_ROLE.getValue(),OrgTypeEnum.ORG_TYPE_ROLE.getValue(),rootTree); childList.add(roleTree); }else{ Tree userTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_USER.getValue(),"用户",OrgTypeEnum.ORG_TYPE_USER.getValue(),OrgTypeEnum.ORG_TYPE_USER.getValue(),rootTree); childList.add(userTree); Tree departmentTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_DEPT.getValue(),"部门",OrgTypeEnum.ORG_TYPE_DEPT.getValue(),OrgTypeEnum.ORG_TYPE_DEPT.getValue(),rootTree); childList.add(departmentTree); Tree roleTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_ROLE.getValue(),"角色",OrgTypeEnum.ORG_TYPE_ROLE.getValue(),OrgTypeEnum.ORG_TYPE_ROLE.getValue(),rootTree); childList.add(roleTree); } if(childList.size()>0){ rootTree.setExpanded(true); rootTree.setChildren(childList); } rootTreeList.add(rootTree); }else{ if(OrgTypeEnum.ORG_TYPE_ROOT.getValue().equals(dataType)){//如果父节点有值，则需要判断是加载什么节点 Tree rootTree=new Tree("root","人员组织","root"); rootTree.setParentBtmName("root"); rootTree.setExpanded(true); if(OrgTypeEnum.ORG_TYPE_USER.getValue().equals(orgType)){//如果是人员 Tree userTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_USER.getValue(),"用户",OrgTypeEnum.ORG_TYPE_USER.getValue(),OrgTypeEnum.ORG_TYPE_USER.getValue(),rootTree); rootTreeList.add(userTree); }else if(OrgTypeEnum.ORG_TYPE_DEPT.getValue().equals(orgType)){//如果是部门 Tree departmentTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_DEPT.getValue(),"部门",OrgTypeEnum.ORG_TYPE_DEPT.getValue(),OrgTypeEnum.ORG_TYPE_DEPT.getValue(),rootTree); rootTreeList.add(departmentTree); }else if(OrgTypeEnum.ORG_TYPE_ROLE.getValue().equals(orgType)){//如果是角色 Tree roleTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_ROLE.getValue(),"角色",OrgTypeEnum.ORG_TYPE_ROLE.getValue(),OrgTypeEnum.ORG_TYPE_ROLE.getValue(),rootTree); rootTreeList.add(roleTree); }else{ Tree userTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_USER.getValue(),"用户",OrgTypeEnum.ORG_TYPE_USER.getValue(),OrgTypeEnum.ORG_TYPE_USER.getValue(),rootTree); rootTreeList.add(userTree); Tree departmentTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_DEPT.getValue(),"部门",OrgTypeEnum.ORG_TYPE_DEPT.getValue(),OrgTypeEnum.ORG_TYPE_DEPT.getValue(),rootTree); rootTreeList.add(departmentTree); Tree roleTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_ROLE.getValue(),"角色",OrgTypeEnum.ORG_TYPE_ROLE.getValue(),OrgTypeEnum.ORG_TYPE_ROLE.getValue(),rootTree); rootTreeList.add(roleTree); } }else if(OrgTypeEnum.ORG_TYPE_USER.getValue().equals(dataType)) {//如果传进来的是user节点 if(OrgTypeEnum.ORG_TYPE_USER.getValue().equals(parentId)) { Tree userTree = initDataTreeNode(OrgTypeEnum.ORG_TYPE_USER.getValue(), "用户", OrgTypeEnum.ORG_TYPE_USER.getValue(), OrgTypeEnum.ORG_TYPE_USER.getValue(), null); UserInfo[] infos = platformClientUtil.getFrameworkService().fetchUserInfo(); Arrays.stream(infos).forEach(info -> { Tree childTree = initDataTreeNode(info.id, info.trueName + "(" + info.userName + ")", info, OrgTypeEnum.ORG_TYPE_USER.getValue(), userTree); rootTreeList.add(childTree); }); } }else if(OrgTypeEnum.ORG_TYPE_DEPT.getValue().equals(dataType)) {//如果是部门 DeptInfo[] deptInfos=new DeptInfo[]{}; Tree departmentTree=new Tree(); if(OrgTypeEnum.ORG_TYPE_DEPT.getValue().equals(parentId)) { departmentTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_DEPT.getValue(),"部门",OrgTypeEnum.ORG_TYPE_DEPT.getValue(),OrgTypeEnum.ORG_TYPE_DEPT.getValue(),null); deptInfos = platformClientUtil.getFrameworkService().fetchDepartmentInfo(); }else{ deptInfos=platformClientUtil.getFrameworkService().fetchDepartmentInfoByParentId(parentId); DeptInfo deptInfo=platformClientUtil.getFrameworkService().fetchDepartmentInfoById(parentId); departmentTree=initDataTreeNode(deptInfo.id,deptInfo.name,deptInfo,OrgTypeEnum.ORG_TYPE_DEPT.getValue(),null); } if(!CollectionUtils.isEmpty(Arrays.asList(deptInfos))){ Tree finalDepartmentTree = departmentTree; Arrays.stream(deptInfos).forEach(deptInfo -> { Tree childTree=initDataTreeNode(deptInfo.id,deptInfo.name,deptInfo,OrgTypeEnum.ORG_TYPE_DEPT.getValue(), finalDepartmentTree); rootTreeList.add(childTree); }); } if(!OrgTypeEnum.ORG_TYPE_DEPT.getValue().equals(parentId)) { UserInfo[] infos = platformClientUtil.getFrameworkService().getUserByDeptId(parentId); if (infos != null && infos.length > 0) { Tree finalDepartmentTree = departmentTree; Arrays.stream(infos).forEach(info -> { Tree childTree = initDataTreeNode(info.id, info.trueName + "(" + info.userName + ")", info, OrgTypeEnum.ORG_TYPE_USER.getValue(), finalDepartmentTree); rootTreeList.add(childTree); }); } } }else if(OrgTypeEnum.ORG_TYPE_ROLE.getValue().equals(dataType)) {//如果是角色 if(OrgTypeEnum.ORG_TYPE_ROLE.getValue().equals(parentId)){ Tree roleTree=initDataTreeNode(OrgTypeEnum.ORG_TYPE_ROLE.getValue(),"角色",OrgTypeEnum.ORG_TYPE_ROLE.getValue(),OrgTypeEnum.ORG_TYPE_ROLE.getValue(),null); RoleInfo[] roleInfos=platformClientUtil.getFrameworkService().fetchRoleInfo(); if(roleInfos!=null&&roleInfos.length>0) { Arrays.stream(roleInfos).forEach(info -> { Tree childTree = initDataTreeNode(info.id, info.name, info, OrgTypeEnum.ORG_TYPE_ROLE.getValue(), roleTree); rootTreeList.add(childTree); }); } }else{ RoleInfo roleInfo=platformClientUtil.getFrameworkService().fetchRoleInfoById(parentId); Tree roleTree=initDataTreeNode(roleInfo.id,roleInfo.name,roleInfo,OrgTypeEnum.ORG_TYPE_ROLE.getValue(),null); UserInfo[] infos=platformClientUtil.getFrameworkService().fetchUserInfoByRoleId(roleInfo.id,roleInfo.type); if(infos!=null&&infos.length>0) { Arrays.stream(infos).forEach(info -> { Tree childTree = initDataTreeNode(info.id, info.trueName + "(" + info.userName + ")", info, OrgTypeEnum.ORG_TYPE_USER.getValue(), roleTree); rootTreeList.add(childTree); }); } } } } } /** * * @param oid * @param text * @param o * @param type * @param parentTree * @return */ private Tree initDataTreeNode(String oid,String text,Object o,String type,Tree parentTree){ Tree ObjectTreeNode=new Tree(oid,text,o); ObjectTreeNode.setParentBtmName(type); if(parentTree!=null) { ObjectTreeNode.setParentId(parentTree.getParentId()); ObjectTreeNode.setParentName(parentTree.getParentName()); } return ObjectTreeNode; } /** * 校验密码是否相同，在新平台中存储的密码是两次md5 * @param userName 用户名 * @param md5Password 已经md5加密一次的密码--老的平台里不能加密 * @return true 表示相等，false表示不相等 */ @Override public boolean checkPasswordEqual(String md5Password, String userName) { if(StringUtils.isBlank(md5Password) || StringUtils.isBlank(userName)){ return false; } /*String sql = " select plpassword from pluser where plusername = :userName"; Map conditionMap = new HashMap<>(); conditionMap.put("userName",userName.trim());*/ SmUserVO userVO = this.getUserByUserId(userName); //List BusinessObjectList = boService.queryBySql(sql, conditionMap); if(Func.isEmpty(userVO) || Func.isBlank(userVO.getOid())){ return false; } //ThreeDES des = new ThreeDES();// 实例化一个对�? //des.getKey("daliantan0v0");// 生成密匙 //对查询出来的密码解密 //String plpassword = ObjectTool.getNewBOAttributeValue(BusinessObjectList.get(0), "plpassword"); String plpassword = userVO.getPassword(); //plpassword = des.getDesString(plpassword); if(md5Password.equals(plpassword)){ return true; } return false; } /** * 校验用户是否锁定 * @param smUserVO 用户对象 * @param wrongCount 密码错误次数,如果wrongCount为空时，会校验用户本身是否已经锁定了 * @return true表示已经锁定 */ @Override public boolean checkUserLock(SmUserVO smUserVO, Integer wrongCount) { if(wrongCount == null || wrongCount == 0){ return smUserVO.isLockFlag(); } //查询密码策略 SmPasswordStrategyVO passwordStrategyVO = smPwdStrategyQueryService.getPasswordStrategyVOByOid( smUserVO.getPkPasswordStrategy() ); if(passwordStrategyVO == null){ throw new VciBaseException("系统里没有密码安全策略"); } if(wrongCount >= passwordStrategyVO.getRetryTime()){ return true; } return false; } /** * 设置某个用户是锁定状态 * @param userId 用户名 */ @Override public void lockUser(String userId) { //老的这个平台，是依靠锁定次数来判断的，所以这里没办法直接设置 } /** * 设置某个用户不是锁定状态 * @param userId 用户名 */ @Override public void unLockUser(String userId) { WebUtil.alertNotNull(userId,"用户名"); String sql = "update pllogoninfo set plwrongnum = 0 where pluserid in (select pluid from pluser where plusername='" + userId + "')"; try { platformClientUtil.getBOFactoryService().executeUpdateSql(sql); } catch (PLException vciError) { throw WebUtil.getVciBaseException(vciError); } } /** * 修改密码 * @param userName 用户主键 * @param oldPassword 旧的密码 * @param password 新的密码 * @param confirmPassword 确认密码 */ @Override @Transactional(rollbackFor = Exception.class) public boolean changePassword(String userName,String oldPassword, String password, String confirmPassword) throws Exception { VciBaseUtil.alertNotNull(userName,"用户名",oldPassword,"登录密码",password,"密码",confirmPassword,"确认密码"); if(!password.equals(confirmPassword)){ throw new VciBaseException("密码和确认密码不相等"); } //对旧密码和密码进行解密，便于比对密码用 oldPassword = Func.decryptAes(oldPassword,"daliantan0v0vcip"); password = Func.decryptAes(password,"daliantan0v0vcip"); //对比旧密码 boolean b = this.checkPasswordEqual(oldPassword, userName); if(!b){ throw new PLException("500", new String[] { "您输入的密码与登录密码不一致,请重新输入!"}); } UserInfo userInfo = platformClientUtil.getFrameworkService().getUserObjectByUserName(userName); if(Func.isEmpty(userInfo) || Func.isBlank(userInfo.id)){ throw new VciBaseException("当前修改的用户不存在！"); } //TODO:校验密码是否符合策略 String error = platformClientUtil.getFrameworkService().checkPasswordStrategyByUserId(userInfo.id, password,null); if (!StringUtils.isBlank(error)) { throw new VciBaseException("当前设置的密码，密码策略校验未通过!"); } //TODO:考虑是否需要将修改方式改成直接调用平台的接口，因为现在的修改方式没能正确的更新缓存 userInfo.pwd = password; userInfo.pwdUpdateTime = System.currentTimeMillis(); boolean updateBoolean = platformClientUtil.getFrameworkService() .updateUser(userInfo, new UserEntityInfo(WebThreadLocalUtil.getCurrentUserSessionInfoInThread()== null ? userName : WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(), null)); return updateBoolean; } /** * 更新用户的密码错误次数 * @param userOid 用户的主键 * @param wrongCount 密码的错误次数 * @throws VciBaseException 参数为空或者存储到数据库中出错的时候会抛出异常 */ @Override public void updateUserPwdWrongCount(String userOid, int wrongCount){ WebUtil.alertNotNull(userOid,"用户主键"); String sql = "update pllogoninfo set plwrongnum = " + wrongCount +" where pluserid ='" + userOid + "'"; try { platformClientUtil.getBOFactoryService().executeUpdateSql(sql); } catch (PLException vciError) { throw WebUtil.getVciBaseException(vciError); } } /** * 更新用户的最后登录时间 * @param userOid 用户的主键 * @throws VciBaseException 参数为空的时候会抛出异常 */ @Override public void updateUserLoginTime(String userOid) { WebUtil.alertNotNull(userOid,"用户主键"); String sql = "update pllogoninfo set pllogontime = sysdate where pluserid ='" + userOid + "'"; try { platformClientUtil.getBOFactoryService().executeUpdateSql(sql); } catch (PLException vciError) { throw WebUtil.getVciBaseException(vciError); } } /** * 添加用户 * @param smUserDTO * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean addUser(SmUserDTO smUserDTO) throws PLException { //判空 VciBaseUtil.alertNotNull( smUserDTO,"添加的用户对象", smUserDTO.getId(),"用户名", smUserDTO.getPassword(),"密码", smUserDTO.getConfirmPassword(),"确认密码", smUserDTO.getName(),"姓名" ); //校验 check(smUserDTO,true,false); //生成存储的DO对象 Date date = new Date(); smUserDTO.setPwdUpdateTime(date); smUserDTO.setStatus((short) 0); smUserDTO.setCreateTime(date); SessionInfo loginUser = WebThreadLocalUtil.getCurrentUserSessionInfoInThread(); String loginUserId = loginUser.getUserId(); //用户类型，现在按照当前登录的用户决定他所添加的用户级别 //超管添加的就是管理员 if(UserTypeEnum.SUPPER_ADMIN.getValue().equals(loginUser.getUsertype())){ smUserDTO.setUserType(Short.parseShort(UserTypeEnum.ADMIN.getValue())); }else { //管理员添加的就是普通用户 smUserDTO.setUserType(Short.parseShort(UserTypeEnum.USER.getValue())); } smUserDTO.setCreator(loginUserId); smUserDTO.setLastModifier(loginUserId); smUserDTO.setOid(ObjectUtility.getNewObjectID36()); UserInfo userInfo = changeSmUserDTOToUserInfo(smUserDTO); //管理员添加的用户初始密码修改时间都应该为0，因为涉及到后面用户首次登录自己修改密码 userInfo.pwdUpdateTime = 0; UserEntityInfo userEntityInfo = new UserEntityInfo(loginUserId, ""); String oid = platformClientUtil.getFrameworkService().saveUser(userInfo, userEntityInfo); if (Func.isEmpty(oid)) { return false; } if(Func.isNotBlank(smUserDTO.getPkDepartment())){ //执行保存用户部门关联关系 orgDeptQueryService.saveUsersDept(new String[]{oid},smUserDTO.getPkDepartment()); } return true; } /** * 修改用户 * @param smUserDTO * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean updateUser(SmUserDTO smUserDTO) throws PLException { SmUserVO dbSmUserVO; if(StringUtils.isBlank(smUserDTO.getId()) && StringUtils.isNotBlank(smUserDTO.getOid()) && StringUtils.isNotBlank(smUserDTO.getName())){ //查询数据库中的 dbSmUserVO = getUserByUserOid(smUserDTO.getOid()); dbSmUserVO.setName(smUserDTO.getName()); dbSmUserVO.setEmail(smUserDTO.getEmail()); BeanUtils.copyProperties(dbSmUserVO,smUserDTO); //校验 check(smUserDTO,false,false); }else{ //判空 VciBaseUtil.alertNotNull( smUserDTO,"修改的用户对象", smUserDTO.getOid(),"用户主键", smUserDTO.getId(),"用户名", smUserDTO.getPassword(),"密码", smUserDTO.getConfirmPassword(),"确认密码", smUserDTO.getName(),"姓名" ); //校验 check(smUserDTO,false,false); //查询数据库中的 dbSmUserVO = getUserByUserOid(smUserDTO.getOid()); } //根据主键没查询到了用户 if(Func.isEmpty(dbSmUserVO) || Func.isBlank(dbSmUserVO.getOid())){ throw new PLException("500", new String[] { "当前修改的用户不存在"}); } SessionInfo loginUser = WebThreadLocalUtil.getCurrentUserSessionInfoInThread(); String loginUserName = loginUser.getUserId(); smUserDTO.setLastModifier(loginUserName); smUserDTO.setUserType(Short.parseShort(dbSmUserVO.getUserType())); smUserDTO.setPwdUpdateTime(dbSmUserVO.getLastModifyPasswordTime()); smUserDTO.setIsDeptLeader(smUserDTO.getIsDeptLeader().equals("不是") ? "0":"1"); UserInfo userInfo = changeSmUserDTOToUserInfo(smUserDTO); boolean updateBoolean = platformClientUtil.getFrameworkService().updateUser(userInfo, new UserEntityInfo(loginUserName, null)); //修改成功，并且用户关联部门有所更改 if(updateBoolean && !smUserDTO.getPkDepartment().equals(dbSmUserVO.getPkDepartment())){ //执行保存用户部门关联关系 orgDeptQueryService.saveUsersDept(new String[]{dbSmUserVO.getOid()},smUserDTO.getPkDepartment()); } return updateBoolean; } /** * 检查用户信息是否符合规范 * @param smUserDTO * @param isAdd 是否新增 * @param isImport 是否导入 */ private void check(SmUserDTO smUserDTO, boolean isAdd,boolean isImport){ //导入的没有确认密码 if(!isImport && !smUserDTO.getPassword().equals(smUserDTO.getConfirmPassword())){ throw new VciBaseException("密码和确认密码不相等"); } if(smUserDTO.getId().getBytes().length > 128){ throw new VciBaseException("用户名长度超过上限"); } if(smUserDTO.getPassword().getBytes().length > 128){ throw new VciBaseException("密码长度超过上限"); } if(smUserDTO.getName().getBytes().length > 64){ throw new VciBaseException("姓名长度超过上限"); } if (Func.isNotBlank(smUserDTO.getSpecialties()) && smUserDTO.getSpecialties().getBytes().length > 255){ throw new VciBaseException("专业长度超过上限"); } if (Func.isNotBlank(smUserDTO.getEmail()) && smUserDTO.getEmail().getBytes().length > 128){ throw new VciBaseException("电子邮箱长度超过上限"); } if (Func.isNotBlank(smUserDTO.getDescription()) && smUserDTO.getDescription().getBytes().length > 255 ){ throw new VciBaseException("描述长度超过上限"); } if (!smUserDTO.getId().matches("^[A-Za-z0-9_]+$")) { throw new VciBaseException("用户名必须是由A-Z a-z 0-9 _组成"); } if (Func.isNotBlank(smUserDTO.getEmail()) && !smUserDTO.getEmail().matches("^([a-z0-9A-Z]+[-|\\.]?)+[a-z0-9A-Z]@([a-z0-9A-Z]+(-[a-z0-9A-Z]+)?\\.)+[a-zA-Z]{2,}$")){ throw new VciBaseException("电子邮箱格式错误"); } /*是新增才做用户名查重处理，修改不需要查重（一经创建不允许修改用户名）， 导入的也不需要在这儿查重，因为在导入逻辑里面需要返回重复的行 */ if(isAdd && !isImport){ //根据用户名（账号）查重 SmUserVO dbSmUserVO = getUserByUserId(smUserDTO.getId()); if(Func.isNotEmpty(dbSmUserVO) && Func.isNotBlank(dbSmUserVO.getOid())){ throw new VciBaseException("该用户名在系统中已经存在,请修改!"); } } //根据当前创建这个用户的人所绑定密码策略来进行密码校验 try { String userId = WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(); String error = platformClientUtil.getFrameworkService().checkPasswordStrategyByUserId(userId, smUserDTO.getPassword(),null); if (!StringUtils.isBlank(error)) { throw new VciBaseException("当前设置的密码，密码策略校验未通过"); } } catch (PLException e) { // TODO Auto-generated catch block e.printStackTrace(); throw new VciBaseException("检查密码策略符合情况失败！"); } } /*** * 用户从DTO对象到corba对象 * @param user * @return */ public UserInfo changeSmUserDTOToUserInfo(SmUserDTO user) { UserInfo userInfo = new UserInfo(); userInfo.id = user.getOid() == null ? "" : user.getOid(); userInfo.userName = user.getId() == null ? "" : user.getId(); userInfo.pwd = user.getPassword() == null ? "" : user.getPassword(); userInfo.trueName = user.getName() == null ? "" : user.getName(); userInfo.specialties = user.getSpecialties() == null ? "" : user.getSpecialties(); userInfo.email = user.getEmail() == null ? "" : user.getEmail(); userInfo.desc = user.getDescription() == null ? "" : user.getDescription(); userInfo.userType = user.getUserType(); userInfo.status = user.getStatus(); userInfo.createTime = user.getCreateTime().getTime(); userInfo.createUser = user.getCreator() == null ? "" : user.getCreator(); userInfo.updateTime = System.currentTimeMillis(); userInfo.updateUser = user.getLastModifier() == null ? "" : user.getLastModifier(); userInfo.pwdUpdateTime = user.getPwdUpdateTime().getTime(); userInfo.grantor = user.getGrantor() == null ? "" : user.getGrantor(); userInfo.secretGrade = user.getSecretGrade() == null ? 2 : Integer.valueOf(user.getSecretGrade()); userInfo.isDeptLeader = user.getIsDeptLeader() == null ? "0" : user.getIsDeptLeader(); userInfo.photo = user.getPhoto() == null ? "" : user.getPhoto(); return userInfo; } /** * 删除用户 * @param ids * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean deleteUser(String[] ids) throws PLException { VciBaseUtil.alertNotNull(ids,"要删除的用户主键"); //调用platformClientUtil的删除用户的方法，会一起删除掉具备关联关系的一些信息，如部门 return platformClientUtil.getFrameworkService().deleteUser( ids, new UserEntityInfo(WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(),null) ); } /** * 用户停用/启用 * @param ids * @param flag * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean stopUsers(String[] ids, boolean flag) throws PLException { VciBaseUtil.alertNotNull(ids,"停用/启用的用户id列表"); return platformClientUtil.getFrameworkService().stopUsers(ids, flag,new UserEntityInfo(WebUtil.getCurrentUserId(),"用户管理")); } /** * 下载导入人员的excel模板。 * @param downloadFileName 下载时界面传过来指定文件名的 * @return 文件在本地的全路径 * @throws VciBaseException 参数为空或者文件出错的时候会抛出异常 */ @Override public String downloadImportTemplate(String downloadFileName) { //界面没传名称，使用默认名称 downloadFileName = Func.isBlank(downloadFileName) ? "用户导入模板_" + Func.format(new Date(),"yyyy-MM-dd HHmmss.sss"):downloadFileName; // 设置表单列名 List columns = new ArrayList<>(Arrays.asList("账号", "密码", "姓名", "电子邮箱", "专业", "描述", "部门(上下级部门之间以反斜杠隔开(/))")); //获取是否导出密级配置项 if (osConfig.isExportSecretGrade()) { columns = new ArrayList<>(Arrays.asList("账号", "密码", "姓名", "电子邮箱", "专业", "描述", "部门(上下级部门之间以反斜杠隔开(/))" ,"密级")); } //设置必填列 ColumnNameisRed.clear(); ColumnNameisRed.add(0); ColumnNameisRed.add(1); ColumnNameisRed.add(2); //写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 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 importUser(File file) throws Exception { 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(); UserEntityInfo userEntityInfo = new UserEntityInfo(loginUserId,null); //是否导入密级配置 boolean exportSecretGrade = osConfig.isExportSecretGrade(); List poList = ExcelUtil.readDataObjectFromExcel(file, SmUserPO.class,excelOption,(value, po, fieldName)->{ Integer secretValue = UserSecretEnum.getSecretValueByText(po.getSecretGradeText()); //是否必须导入密级 if(exportSecretGrade){ if(secretValue == null){ throw new VciBaseException("传入的密级不符合规则!"); } po.setSecretGrade(secretValue); } }); //去除都是空的情况 if(CollectionUtils.isEmpty(poList)){ return BaseResult.fail(ExcelLangCodeConstant.IMPORT_CONTENT_NULL,new String[]{}); } //数据库查询是否有已存在的用户，方便后续做判重处理 List smUserVOList = this.listUserByUserIds(poList.stream().map(SmUserPO::getId).collect(Collectors.toSet())); List repeatUserId = new ArrayList<>(); if(Func.isNotEmpty(smUserVOList)){ repeatUserId = smUserVOList.stream().map(SmUserVO::getId).collect(Collectors.toList()); } //当前excel中是否重复用的判重Map:（key：账号，value：行号） Map excelReapeat = new HashMap<>(); //先获取全部部门名称的父子对应关系：key为部门子父级名称路径，value为部门信息 List orgDepartmentVOList = orgDeptQueryService.getDeptAllFullName(); Map deptVOMap = orgDepartmentVOList.stream().collect(Collectors.toMap(OrgDepartmentVO::getFullDeptNamePath, s->s)); //Map deptVOMap = orgDeptQueryService.getDeptAllTreeMap(); //判断必填属性是否为空，用户是否已存在，以及部门是否填错等校验逻辑 List finalRepeatUserId = repeatUserId; poList.stream().forEach(smUserPO -> { //先对必填属性判空处理 if(Func.isBlank(smUserPO.getId())){ throw new VciBaseException("第【"+smUserPO.getRowIndex()+"】行，usernameerror"); }else if(Func.isBlank(smUserPO.getName())){ throw new VciBaseException("第【"+smUserPO.getRowIndex()+"】行，nameerror"); }else if(Func.isBlank(smUserPO.getPassword())){ throw new VciBaseException("第【"+smUserPO.getRowIndex()+"】行，passworderror"); }else if (Func.isNotEmpty(smUserVOList) && finalRepeatUserId.contains(smUserPO.getId())){//2、判断用户名是否重复 throw new VciBaseException("第【"+smUserPO.getRowIndex()+"】行，用户名在系统中已经存在,请修改!"); }else if(Func.isNotBlank(smUserPO.getPkDepartmentName())){//处理填写了部门的数据行 OrgDepartmentVO orgDepartmentVO = deptVOMap.get(smUserPO.getPkDepartmentName()); //部门为空就说明用户填写错误 if(Func.isEmpty(orgDepartmentVO) && Func.isBlank(orgDepartmentVO.getOid())){ throw new VciBaseException("第【"+smUserPO.getRowIndex()+"】行数据，部门设置错误，原因：未查询到该路径下的部门"); } }else if(excelReapeat.containsKey(smUserPO.getId())){//表格中判重 throw new VciBaseException("第【"+excelReapeat.get(smUserPO.getId())+"】行和第【"+smUserPO.getRowIndex()+"】行数据，账号重复"); } excelReapeat.put(smUserPO.getId(),smUserPO.getRowIndex()); }); //保存逻辑 poList.stream().forEach(smUserPO->{ SmUserDTO smUserDTO = new SmUserDTO(); BeanUtilForVCI.convert(smUserPO,smUserDTO); //用户信息是否规范检查 this.check(smUserDTO,true,true); //生成存储的DO对象 Date date = new Date(); smUserDTO.setPwdUpdateTime(date); smUserDTO.setStatus((short) 0); smUserDTO.setCreateTime(date); smUserDTO.setCreator(loginUserId); smUserDTO.setLastModifier(loginUserId); //保存用户 String oid = null; try { //保存用户获取到用户oid oid = platformClientUtil.getFrameworkService().saveUser(changeSmUserDTOToUserInfo(smUserDTO), userEntityInfo); //保存用户部门关联关系 if(Func.isNotBlank(oid) && Func.isNotBlank(smUserDTO.getPkDepartmentName())){ orgDeptQueryService.saveUsersDept( new String[]{oid}, deptVOMap.get(smUserDTO.getPkDepartmentName()).getOid() ); } } catch (PLException e) { e.printStackTrace(); throw new VciBaseException("执行到第【"+smUserPO.getRowIndex()+"】行保存逻辑时出现错误，原因：" + VciBaseUtil.getExceptionMessage(e)); } }); }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("用户导入成功！"); } /** * 根据角色类型查询用户名 * @param roleType * @return */ @Override public List queryUserNameByRoleType(String roleType) { List userNameList = new ArrayList<>(); if(Func.isBlank(roleType)){ return userNameList; } String sql = "SELECT PLUSERNAME FROM PLUSER p WHERE PLUID IN " + "(SELECT PLUSERUID FROM PLUSERROLE p WHERE PLROLEUID IN " + "( SELECT PLUID FROM PLROLE p WHERE PLTYPE = "+ roleType + "))"; List cbos = boService.queryBySql(sql, null); cbos.stream().forEach(cbo->{ userNameList.add(ObjectTool.getNewBOAttributeValue(cbo,"plusername")); }); return userNameList; } /** * 使用当前用户的类型查询用户 * @return * @throws VciBaseException */ @Override public List listUserByUserType(Integer type) throws PLException { try { UserInfo[] userInfo = platformClientUtil.getFrameworkService().fetchUserInfoByType(type != null ? type.shortValue() :Short.parseShort(WebUtil.getCurrentUserSessionInfo().getUsertype())); return userInfoArr2VO(userInfo); } catch (PLException e) { throw new VciBaseException("登录时，获取用户信息失败："+e.getMessage()); } } /** * 导出用户列表三员账号除外 * @return */ @Override public String expUser() throws PLException { // 设置表单列名 List columns = new ArrayList<>(Arrays.asList("姓名, 账号, 状态, 密码策略, 锁定状态, 所属部门, 专业, 角色, 电子邮件, 描述, 部门领导, 密级".split(","))); //设置必填列 ColumnNameisRed.clear(); ColumnNameisRed.add(0); ColumnNameisRed.add(1); ColumnNameisRed.add(2); //写excel String excelPath = LocalFileUtil.getDefaultTempFolder() + File.separator + "userList.xls"; try { new File(excelPath).createNewFile(); } catch (Throwable e) { throw new VciBaseException(LangBaseUtil.getErrorMsg(e), new String[]{excelPath}, e); } //设置列 List 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))); } } UserInfo[] userInfos = platformClientUtil.getFrameworkService().fetchUserInfoWithOutSanYuan(); //部门信息集合 Hashtable deptHashTable = new Hashtable(); for(int index = 1; index <= userInfos.length; index++){ UserInfo userInfo = userInfos[index-1]; excelDataList.add(new WriteExcelData(index,0, userInfo.trueName)); excelDataList.add(new WriteExcelData(index,1, userInfo.userName)); excelDataList.add(new WriteExcelData(index,2, userInfo.status==1 ? "停用":"启用")); /**密码策略**/ PasswordStrategyInfo pwsObj = platformClientUtil.getFrameworkService().fetchPasswordStrategyByUserId(userInfo.id); excelDataList.add(new WriteExcelData(index,3, pwsObj.name)); /**锁定状态**/ UserLogonInfo lockObj = platformClientUtil.getFrameworkService().fetchUserLogonObj(userInfo.id); if (pwsObj != null) excelDataList.add(new WriteExcelData(index,4, (pwsObj.retryTime > 0 && lockObj.plWrongNum >= pwsObj.retryTime) ? "锁定" : "未锁定")); else excelDataList.add(new WriteExcelData(index,4, "未锁定")); DeptInfo obj = null; RoleInfo[] roles = null; String deptName = ""; obj = platformClientUtil.getFrameworkService().fetchDeptByUserId(userInfo.id); if (obj != null){ if(!deptHashTable.containsKey((obj.id))){ deptName = getDeptObjectAllByDeptId(obj); deptHashTable.put(obj.id, deptName); }else{ deptName = deptHashTable.get(obj.id); } } roles = platformClientUtil.getFrameworkService().fetchRoleInfoByUserId(userInfo.id); excelDataList.add(new WriteExcelData(index,5, deptName)); excelDataList.add(new WriteExcelData(index,6, userInfo.specialties)); String roleNames = ""; if (roles.length != 0){ for(int j = 0 ; j < roles.length ; j ++){ if (j < roles.length -1){ roleNames += roles[j].name + ","; }else { roleNames += roles[j].name; } } } excelDataList.add(new WriteExcelData(index,7, roleNames)); excelDataList.add(new WriteExcelData(index,8, userInfo.email)); excelDataList.add(new WriteExcelData(index,9, userInfo.desc)); excelDataList.add(new WriteExcelData(index,10, userInfo.isDeptLeader.equals("1") ? "是" : "否")); String secretGrade = String.valueOf(userInfo.secretGrade); try { EnumType item = platformClientUtil.getEnumService().getEnumTypeByName(ENUM_USERSECURITYENUM); EnumItem[] children = item.items; String securityShowName = ""; for(EnumItem child: children){ if(child.value.equals(secretGrade)){ securityShowName = child.name; break; } } excelDataList.add(new WriteExcelData(index,11, securityShowName)); } catch (PLException e) { e.printStackTrace(); } } WriteExcelOption excelOption = new WriteExcelOption(excelDataList); ExcelUtil.writeDataToFile(excelPath, excelOption); return excelPath; } /** * 修改用户头像 * @param file 文件 * @return */ @Override public boolean updateUserPhoto(MultipartFile file) throws PLException { //获取文件仓位置 VciFileVolumeDO vciFileVolumeDO = vciFileVolumeServiceI.getUploadVolume(); String volumeName = vciFileVolumeDO.getName(); VolumeServicePrx volumnCorbaService = platformClientUtil.getVolumeService(volumeName); if(volumnCorbaService == null){ throw new VciBaseException("没有获取到卷服务"); } InputStream in = null; String path = vciFileVolumeDO.getId() + ":/userphoto/" + WebUtil.getSessionInfo().getUserOid() + "." + FilenameUtils.getExtension(file.getOriginalFilename()); UserInfo userInfo = platformClientUtil.getFrameworkService().getUserObjectByoid(WebUtil.getSessionInfo().getUserOid()); if(StringUtils.isNotBlank(userInfo.photo)){ volumnCorbaService.deleteFile(userInfo.photo); } try{ long currentTime = volumnCorbaService.getCurrrentTimeMillions(); in = file.getInputStream(); long fileSize = file.getSize(); int blockSize = webProperties.getBlockLength()*1024; byte[] buffer = new byte[blockSize]; long temp =0L; for(temp = 0L; temp < fileSize - (long)blockSize; temp += (long)blockSize) { in.read(buffer, 0, blockSize); volumnCorbaService.receiveFile(path, buffer, temp, currentTime, fileSize); } int remainSize = (int)(fileSize - temp); buffer = new byte[remainSize]; in.read(buffer, 0, remainSize); volumnCorbaService.receiveFile(path, buffer, temp, currentTime, fileSize); }catch(IOException e){ throw new VciBaseException("读取文件[" + file.getName() + "]出现了错误，" + e.getMessage() ,new String[0],e); }catch(Exception e){ throw new VciBaseException("处理上传文件[" + file.getName() + "]出现了错误，" + e.getMessage() ,new String[0],e); }finally { if(in!=null){ try { in.close(); } catch (IOException e) { } } } userInfo.photo = path; boolean b = platformClientUtil.getFrameworkService().updateUser(userInfo, new UserEntityInfo(WebThreadLocalUtil.getCurrentUserSessionInfoInThread().getUserId(), null)); if(!b){ return false; } return true; } @Override public String getUserPhoto() throws PLException { //获取文件仓位置 VciFileVolumeDO vciFileVolumeDO = vciFileVolumeServiceI.getUploadVolume(); String volumeName = vciFileVolumeDO.getName(); VolumeServicePrx volumnCorbaService = platformClientUtil.getVolumeService(volumeName); if(volumnCorbaService == null){ throw new VciBaseException("没有获取到卷服务"); } UserInfo userInfo = platformClientUtil.getFrameworkService().getUserObjectByoid(WebUtil.getSessionInfo().getUserOid()); String serverPath = userInfo.photo; String tempFilePath = LocalFileUtil.getDefaultTempFolder() + File.separator+serverPath.substring(serverPath.lastIndexOf("/") + 1); try { FileOutputStream destFileOs = new FileOutputStream(tempFilePath); long blockSize = webProperties.getBlockLength()*1024; if(blockSize> Integer.MAX_VALUE){ blockSize = Integer.MAX_VALUE; } long fileSize = volumnCorbaService.getFileSize(serverPath); long temp = 0; while (fileSize - temp > blockSize) { destFileOs.write(volumnCorbaService.sendFile(serverPath, temp)); temp += blockSize; } destFileOs.write(volumnCorbaService.sendFile(serverPath, temp)); destFileOs.flush(); destFileOs.close(); } catch (FileNotFoundException e) { throw new VciBaseException("要写入的文件没有找到",new String[]{tempFilePath},e); } catch (IOException e) { throw new VciBaseException("写入文件出错" + e.getMessage(),new String[]{tempFilePath},e); } catch (Exception e){ throw new VciBaseException("卷服务传输文件时出现了错误" + e.getMessage(),new String[0],e); } return tempFilePath; } //根据子部门查询所属的父类部门，并拼接成字符串形式，返回 public String getDeptObjectAllByDeptId(DeptInfo obj) throws PLException { String fetchDepName = ""; DeptInfo[] depObjectAll = platformClientUtil.getFrameworkService().fetchDepartmentInfosBySonId(obj.id); for(int i=depObjectAll.length-1;i>=0; i--){ fetchDepName += depObjectAll[i].name+"/"; } if(fetchDepName.length() != 0){ fetchDepName = fetchDepName.substring(0, fetchDepName.length() - 1); } return fetchDepName; } }