package com.artfess.uc.manager.impl; import com.alibaba.druid.util.StringUtils; import com.alibaba.fastjson.JSONObject; import com.artfess.base.cache.annotation.Cacheable; import com.artfess.base.constants.CacheKeyConst; import com.artfess.base.enums.DelStatusEnum; import com.artfess.base.exception.BaseException; import com.artfess.base.manager.impl.BaseManagerImpl; import com.artfess.base.model.CommonResult; import com.artfess.base.query.FieldRelation; import com.artfess.base.query.PageBean; import com.artfess.base.query.QueryFilter; import com.artfess.base.query.QueryOP; import com.artfess.base.util.BeanUtils; import com.artfess.base.util.FileUtil; import com.artfess.base.util.JsonUtil; import com.artfess.base.util.StringUtil; import com.artfess.base.util.UniqueIdUtil; import com.artfess.base.util.time.DateFormatUtil; import com.artfess.base.util.time.DateUtil; import com.artfess.base.vo.OrgPositionTreeVo; import com.artfess.poi.util.ExcelUtil; import com.artfess.security.util.AuthorCheck; import com.artfess.uc.dao.OrgDao; import com.artfess.uc.dao.OrgJobDao; import com.artfess.uc.dao.OrgParamsDao; import com.artfess.uc.dao.OrgPostDao; import com.artfess.uc.dao.OrgUserDao; import com.artfess.uc.dao.UcOrgPositionDao; import com.artfess.uc.exception.HotentHttpStatus; import com.artfess.uc.exception.RequiredException; import com.artfess.uc.manager.DemensionManager; import com.artfess.uc.manager.OrgAuthManager; import com.artfess.uc.manager.OrgJobManager; import com.artfess.uc.manager.OrgManager; import com.artfess.uc.manager.OrgParamsManager; import com.artfess.uc.manager.OrgPostManager; import com.artfess.uc.manager.OrgRoleManager; import com.artfess.uc.manager.OrgUserManager; import com.artfess.uc.manager.ParamsManager; import com.artfess.uc.manager.PropertiesService; import com.artfess.uc.manager.RoleManager; import com.artfess.uc.manager.UserManager; import com.artfess.uc.manager.UserUnderManager; import com.artfess.uc.model.Demension; import com.artfess.uc.model.Org; import com.artfess.uc.model.OrgAuth; import com.artfess.uc.model.OrgJob; import com.artfess.uc.model.OrgParams; import com.artfess.uc.model.OrgPost; import com.artfess.uc.model.OrgRole; import com.artfess.uc.model.OrgTree; import com.artfess.uc.model.OrgUser; import com.artfess.uc.model.Params; import com.artfess.uc.model.Role; import com.artfess.uc.model.UcOrgPosition; import com.artfess.uc.model.User; import com.artfess.uc.model.UserUnder; import com.artfess.uc.params.common.OrgExportObject; import com.artfess.uc.params.org.OrgAuthVo; import com.artfess.uc.params.org.OrgPositionVo; import com.artfess.uc.params.org.OrgPostVo; import com.artfess.uc.params.org.OrgUserVo; import com.artfess.uc.params.org.OrgVo; import com.artfess.uc.params.orgRole.OrgRoleVo; import com.artfess.uc.params.post.PostDueVo; import com.artfess.uc.params.user.UserUnderVo; import com.artfess.uc.params.user.UserVo; import com.artfess.uc.util.ContextUtil; import com.artfess.uc.util.OrgUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.fasterxml.jackson.databind.node.ObjectNode; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import org.apache.poi.hssf.usermodel.HSSFWorkbook; 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.Assert; import org.springframework.util.ObjectUtils; import javax.annotation.Resource; import java.io.File; import java.io.IOException; import java.io.Serializable; import java.sql.SQLException; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.HashSet; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; /** * 
 *
 * 描述：组织架构 处理实现类
 * 构建组：x5-bpmx-platform
 * 作者:ray
 * 邮箱:zhangyg@jee-soft.cn
 * 日期:2016-06-28 15:13:03
 * 版权：广州宏天软件有限公司
 *
*/ @Service public class OrgManagerImpl extends BaseManagerImpl implements OrgManager { protected static Logger logger = LoggerFactory.getLogger(OrgManagerImpl.class); @Autowired OrgParamsManager orgParamsService; @Autowired OrgUserManager orgUserService; @Autowired UserUnderManager userUnderService; @Autowired UserUnderManager userUnderManager; @Autowired UserManager userService; @Autowired OrgPostManager orgPostService; @Autowired OrgPostDao orgPostDao; @Autowired OrgRoleManager orgRoleService; @Autowired DemensionManager demensionService; @Autowired ParamsManager paramsSerivce; @Autowired OrgAuthManager orgAuthService; @Autowired OrgJobManager orgJobService; @Autowired OrgJobDao orgJobDao; @Autowired OrgUserDao orgUserDao; @Autowired RoleManager roleService; @Autowired OrgRoleManager orgRoleManager; @Autowired DemensionManager DemensionManager; @Autowired PropertiesService propertiesService; @Autowired OrgParamsDao orgParamsDao; @Autowired private AuthorCheck authorCheck; @Resource UcOrgPositionDao orgPositionDao; // 子节点 static List childOrg = new ArrayList(); public Org getByCode(String code) { return baseMapper.getByCode(code); } public List getOrgListByUserId(String userId) { return baseMapper.getOrgListByUserId(userId); } public List getOrgListByAccount(String account) throws Exception { User user = userService.getByAccount(account); return baseMapper.getOrgListByUserId(user.getId()); } @Override @Cacheable(value = CacheKeyConst.EIP_UC_USER_MAIN_ORG, key = "#demId + '-' + #userId") public Org getMainGroup(String userId, String demId) { if (BeanUtils.isNotEmpty(demId)) { if (BeanUtils.isEmpty(demensionService.get(demId))) { Demension sysDemension = demensionService.getByCode(demId); if (BeanUtils.isNotEmpty(sysDemension)) { demId = sysDemension.getId(); } } } else { Demension sysDemension = demensionService.getDefaultDemension(); if (BeanUtils.isNotEmpty(sysDemension)) { demId = sysDemension.getId(); } } List list = baseMapper.getMainOrgListByUser(userId, StringUtil.isEmpty(demId) ? null : demId); if (BeanUtils.isEmpty(list)) { list = baseMapper.getOrgListByUserId(userId); } return BeanUtils.isEmpty(list) ? null : list.get(0); } @Override @Transactional public void removeByIds(String... ids) { super.removeByIds(ids); for (String id : ids) { // 删除组织参数 orgParamsService.removeByOrgId(id); // 删除组织岗位 orgPostService.delByOrgId(id); // 删除组织用户 orgUserService.delByOrgId(id); // 删除下属 userUnderService.delByOrgId(id); // 删除分级组织管理 orgAuthService.delByOrgId(id); } // 查找子节点 List allList = this.getAll(); childOrg.removeAll(childOrg); for (String id : ids) { treeOrgList(allList, id); } // 删除子节点 String[] childIds = new String[childOrg.size()]; for (int i = 0; i < childOrg.size(); i++) { String id = childOrg.get(i).getId(); childIds[i] = id; this.remove(id); } // 子组织中相关数据的删除 for (String childId : childIds) { orgParamsService.removeByOrgId(childId); orgPostService.delByOrgId(childId); orgUserService.delByOrgId(childId); userUnderService.delByOrgId(childId); orgAuthService.delByOrgId(childId); } } @Override @Transactional public void updateByOrg(Org org) throws SQLException { String extName = org.getPathName().substring(0, org.getPathName().indexOf("/" + org.getName())); String extId = org.getPath().substring(0, org.getPath().indexOf("." + org.getId())); this.update(org); String[] ids = {org.getId()}; // 查找子节点 List allList = this.getAll(); List cList = new ArrayList(); for (String id : ids) { getChild(allList, id, cList); } // 更新子节点 String[] childIds = new String[cList.size()]; // 子节点是递归往上找的数据，最孙的节点排在list前面，遍历时，先从一级子节点进行修改 for (int i = cList.size() - 1; i >= 0; i--) { String id = cList.get(i).getId(); childIds[i] = id; Org c = this.get(id); if (c.getParentId().equals(org.getId())) {// 一级子组织 c.setPathName(org.getPathName() + "/" + c.getName()); c.setPath(org.getPath() + c.getId() + "."); c.setDemId(org.getDemId()); } else {// 二级及以下组织 String pName = org.getName(); String pId = org.getId(); Org p = this.get(c.getParentId()); String pathName = p.getPathName().substring(p.getPathName().indexOf("/" + pName), p.getPathName().length()) + "/" + c.getName(); String path = p.getPath().substring(p.getPath().indexOf("." + pId), p.getPath().length()) + c.getId() + "."; c.setPathName(extName + pathName); c.setPath(extId + path); c.setDemId(org.getDemId()); } this.update(c); } } /** * 获取某个父节点下面的所有子节点 * * @param orgList * @param parentId * @return */ public static List treeOrgList(List orgList, String parentId) { for (Org org : orgList) { // 遍历出父id等于参数的id，add进子节点集合 if (parentId.equals(org.getParentId())) { // 递归遍历下一级 treeOrgList(orgList, org.getId()); childOrg.add(org); } } return childOrg; } @Override public List getByParentId(String parentId) { List rtnList = new ArrayList(); List allList = this.getAll(); return getChild(allList, parentId, rtnList); } /** * 获取某个父节点下面的所有子节点 * * @param orgList * @param parentId * @return */ public static List getChild(List orgList, String parentId, List rtnList) { for (Org org : orgList) { // 遍历出父id等于参数的id，add进子节点集合 if (parentId.equals(org.getParentId())) { // 递归遍历下一级 getChild(orgList, org.getId(), rtnList); rtnList.add(org); } } return rtnList; } public List getByOrgName(String orgName) { return baseMapper.getByOrgName(orgName); } @Override public List getByPathName(String pathName) { return baseMapper.getByPathName(pathName); } @Override public List getByParentAndDem(QueryFilter queryFilter) { return baseMapper.getByParentAndDem(convert2Wrapper(queryFilter, currentModelClass())); } @Override public Org getByDemIdAndSonId(String demId, String sonId) { return baseMapper.getByDemIdAndSonId(demId, sonId); } @Override public List getMainOrgListByUser(String userId, String demId) { return baseMapper.getMainOrgListByUser(userId, demId); } @Override public List getOrgListByDemId(String demId) { return baseMapper.getOrgListByDemId(demId); } @Override public List getUserOrg(String userId, String demId, Boolean isMain) { Map params = new HashMap(); if (BeanUtils.isNotEmpty(isMain)) { if (isMain) { params.put("isMain", "1"); } else { params.put("isMain", "0"); } } if (StringUtil.isNotEmpty(demId)) { params.put("demId", demId); } params.put("userId", userId); return baseMapper.getUserOrg(params); } @Override @Transactional public CommonResult addOrg(OrgVo orgVo) throws Exception { if (StringUtil.isEmpty(orgVo.getName())) { throw new RuntimeException("添加组织失败，组织名称【name】不能为空！"); } if (StringUtil.isEmpty(orgVo.getCode())) { throw new RuntimeException("添加组织失败，组织编码【code】不能为空！"); } if (orgVo.getCode().contains(",")) { throw new RuntimeException("组织编码中不能包含英文逗号‘,’"); } if (StringUtil.isEmpty(orgVo.getDemId())) { throw new RuntimeException("添加组织失败，维度id【demId】不能为空！"); } if (baseMapper.getCountByCode(orgVo.getCode()) > 0) { throw new RuntimeException("添加组织失败，组织编码[" + orgVo.getCode() + "]已存在！"); } Demension dem = demensionService.get(orgVo.getDemId()); if (BeanUtils.isEmpty(dem)) { throw new RuntimeException("添加组织失败，根据输入的demId[" + orgVo.getDemId() + "]没有找到对应的维度信息！"); } Org pOrg = null; if (!"0".equals(orgVo.getParentId()) && StringUtil.isNotEmpty(orgVo.getParentId())) { pOrg = this.get(orgVo.getParentId()); if (BeanUtils.isEmpty(pOrg)) { throw new RuntimeException("添加组织失败，根据输入的parentId[" + orgVo.getParentId() + "]没有找到对应的组织信息！"); } if (BeanUtils.isEmpty(pOrg) && !pOrg.getDemId().equals(orgVo.getDemId())) { throw new RuntimeException("添加组织失败，根据输入demId与所输入的父组织所对应的维度id不一致！"); } String orgKind = orgVo.getOrgKind(); if (orgKind.equals("ogn") && pOrg.getOrgKind().equals("dept")) { throw new RuntimeException("添加组织失败，该组织的父级类型是【部门】，该组织类型不能为【机构】！"); } } //ToDo 以后验证版本信息时候 开放 /*SysAuthorization resultCode = authorCheck.redFileToObject(); if(resultCode==null){ throw new RuntimeException("添加组织失败，没找到系统的授权信息！"); } int orgNum = Integer.valueOf(resultCode.getOgnNum()); JdbcTemplate jdbcTemplate = AppUtil.getBean(JdbcTemplate.class); String sql = "select count(*) from UC_ORG where ORG_KIND_='ogn' and IS_DELE_!= '1' "; int onum = jdbcTemplate.queryForObject(sql, Integer.class); if(onum >= orgNum){ throw new RuntimeException("添加组织失败，添加的组织数量已等于授权的数量【"+orgNum+"】了！"); }*/ Org o = new Org(); o.setId(UniqueIdUtil.getSuid()); o.setOrgKind(orgVo.getOrgKind()); o.setCode(orgVo.getCode()); o.setName(orgVo.getName()); o.setDemId(orgVo.getDemId()); if (StringUtils.isEmpty(orgVo.getParentId())) { o.setParentId("0"); } else { o.setParentId(orgVo.getParentId()); } if (StringUtil.isNotEmpty(orgVo.getGrade())) { o.setGrade(orgVo.getGrade()); } if (BeanUtils.isNotEmpty(orgVo.getOrderNo())) { o.setOrderNo(orgVo.getOrderNo()); } if (BeanUtils.isEmpty(pOrg)) { o.setPathName("/" + orgVo.getName()); o.setPath(orgVo.getDemId() + "." + o.getId() + "."); } else { o.setPath(pOrg.getPath() + o.getId() + "."); o.setPathName(pOrg.getPathName() + "/" + orgVo.getName()); } o.setLimitNum(orgVo.getLimitNum().intValue()); o.setExceedLimitNum(orgVo.getExceedLimitNum().intValue()); this.create(o); return new CommonResult(true, "添加组织成功！", ""); } @Override @Transactional public CommonResult deleteOrg(String codes) throws Exception { if (StringUtils.isEmpty(codes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：组织代码必填！"); } String message = ""; String[] codeArr = codes.split(","); for (String code : codeArr) { Org o = this.getByCode(code); if (BeanUtils.isEmpty(o)) { message += "编码为【" + code + "】的组织不存在；"; continue; } QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("PARENT_ID_", o.getId()); int num = baseMapper.selectCount(queryWrapper); if(num>0){ throw new RuntimeException("删除组织失败，编码为【" + code + "】的组织下还有子组织！"); } QueryWrapper queryUserWrapper = new QueryWrapper<>(); queryUserWrapper.eq("ORG_ID_", o.getId()); int usernum = orgUserDao.selectCount(queryUserWrapper); if(usernum>0){ throw new RuntimeException("删除组织失败，编码为【" + code + "】的组织下还有人员！"); } String[] ids = {o.getId()}; removeByIds(ids); } if (StringUtils.isEmpty(message)) { message = "删除组织成功！"; } else { message = "部分删除成功，其中" + message; } return new CommonResult(true, message, ""); } @Override @Transactional public CommonResult updateOrg(OrgVo orgVo) throws Exception { if (orgVo.getExceedLimitNum() == 1) { if (orgVo.getLimitNum() < orgVo.getNowNum()) { throw new RuntimeException("更新组织失败，当前组织人数超出限编人数！"); } } if (StringUtil.isEmpty(orgVo.getCode())) { throw new RuntimeException("更新组织失败，组织编码【code】必填！"); } Org o = this.getByCode(orgVo.getCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("更新组织失败，根据组织编码【" + orgVo.getCode() + "】没有找到对应的组织！"); } Demension dem = demensionService.get(orgVo.getDemId()); if (StringUtil.isNotEmpty(orgVo.getDemId()) && BeanUtils.isEmpty(dem)) { throw new RuntimeException("更新组织失败，根据输入的demId【" + orgVo.getDemId() + "】没有找到对应的维度信息！"); } Org pOrg = null; if (StringUtil.isNotEmpty(orgVo.getParentId()) && !"0".equals(orgVo.getParentId())) { pOrg = this.get(orgVo.getParentId()); if (BeanUtils.isEmpty(pOrg)) { throw new RuntimeException("更新组织失败，根据输入的parentId【" + orgVo.getDemId() + "】没有找到对应的组织信息！"); } if (StringUtil.isNotEmpty(orgVo.getDemId()) && BeanUtils.isNotEmpty(pOrg) && !pOrg.getDemId().equals(orgVo.getDemId())) { throw new RuntimeException("更新组织失败，根据输入demId与所输入的父组织所对应的维度id不一致！"); } } String orgKind = orgVo.getOrgKind(); if (orgKind.equals("ogn")) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("ORG_KIND_", "dept").eq("ID_", orgVo.getParentId()); int num = baseMapper.selectCount(queryWrapper); if (num > 0) { throw new RuntimeException("更新组织失败，该组织的父级是部门，该组织不能修改为机构！"); } } if (orgKind.equals("dept")) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("ORG_KIND_", "ogn").eq("PARENT_ID_", o.getId()); int num = baseMapper.selectCount(queryWrapper); if (num > 0) { throw new RuntimeException("更新组织失败，该组织下已有子组织了，不能修改为部门！"); } } if (StringUtil.isNotEmpty(orgVo.getName())) { o.setName(orgVo.getName()); } if (StringUtil.isNotEmpty(orgVo.getGrade())) { o.setGrade(orgVo.getGrade()); } if (BeanUtils.isNotEmpty(orgVo.getOrderNo())) { o.setOrderNo(orgVo.getOrderNo()); } if (BeanUtils.isNotEmpty(orgVo.getOrgKind())) { o.setOrgKind(orgVo.getOrgKind()); } if (BeanUtils.isEmpty(pOrg)) { if (StringUtil.isNotEmpty(orgVo.getName())) { o.setPathName("/" + orgVo.getName()); } if (StringUtil.isNotEmpty(orgVo.getDemId())) { o.setPath(orgVo.getDemId() + "." + o.getId() + "."); o.setDemId(orgVo.getDemId()); } } else { o.setPath(pOrg.getPath() + o.getId() + "."); o.setPathName(pOrg.getPathName() + "/" + orgVo.getName()); o.setDemId(orgVo.getDemId()); o.setParentId(pOrg.getId()); } o.setLimitNum(orgVo.getLimitNum().intValue()); o.setExceedLimitNum(orgVo.getExceedLimitNum().intValue()); this.updateByOrg(o); return new CommonResult(true, "组织更新成功！", ""); } @Override public Org getOrg(String code) throws Exception { if (StringUtils.isEmpty(code)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：组织编码code必填！"); } Org o = this.getByCode(code); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织编码没有找到对应的组织信息！"); } o = this.get(o.getId()); String pId = o.getParentId(); String demId = o.getDemId(); Demension d = demensionService.get(demId); if (d != null && !StringUtil.isEmpty(d.getDemCode())) { o.setDemCode(d.getDemCode()); } if ("0".equals(pId) || StringUtil.isEmpty(pId)) { o.setParentOrgName(d.getDemName()); } else { o.setParentOrgName(this.get(pId).getName()); } List params = this.getOrgParams(o.getCode()); if (BeanUtils.isNotEmpty(params)) { Map map = new HashMap(); for (OrgParams param : params) { map.put(param.getAlias(), param.getValue()); } o.setParams(map); } return o; } @Override @Transactional public CommonResult saveOrgParams(String orgCode, List params) throws Exception { if (StringUtils.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：组织编码orgCode必填！"); } Org org = this.getByCode(orgCode); if (BeanUtils.isEmpty(org)) { throw new RuntimeException("根据输入的组织编码没有找到对应的组织信息！"); } orgParamsService.removeByOrgId(org.getId()); // 判断输入的key是否存在 for (ObjectNode o : params) { String key = o.get("alias").asText(); Params p = paramsSerivce.getByAlias(key); if (BeanUtils.isEmpty(p)) { throw new RuntimeException("【" + key + "】参数key不存在！"); } if (!p.getType().equals("2")) { throw new RuntimeException("【" + key + "】对应的【用户组织扩展参数】类型不是【组织参数】类型！"); } } try { orgParamsService.saveParams(org.getId(), params); } catch (Exception e) { System.out.println(e); if (e.getMessage().indexOf("ORA-12899") > -1) { throw new RuntimeException("保存失败，参数值过长"); } else { throw e; } // TODO: handle exception } return new CommonResult(true, "保存组织参数成功！", ""); } @Override public List getOrgParams(String orgCode) throws Exception { Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织编码没有找到对应的组织信息！"); } List list = orgParamsService.getByOrgId(o.getId()); return list; } @Override public CommonResult getParamByAlias(String orgCode, String alias) throws Exception { Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织编码没有找到对应的组织信息！"); } OrgParams p = orgParamsService.getByOrgIdAndAlias(o.getId(), alias); if (BeanUtils.isEmpty(p)) { throw new RuntimeException("根据输入的参数别名【" + alias + "】没有找到对应的参数信息"); } return new CommonResult(true, "获取完毕！", p); } @Override @Transactional public CommonResult addOrgUser(OrgUserVo orgUserVo) throws Exception { if (StringUtil.isEmpty(orgUserVo.getAccount())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：用户帐号account必填！"); } if (StringUtil.isEmpty(orgUserVo.getOrgCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：组织编码orgCode必填！"); } User u = userService.getByAccount(orgUserVo.getAccount()); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("没有找到对应的用户！"); } if (BeanUtils.isNotEmpty(orgUserVo.getIsCharge()) && !(orgUserVo.getIsCharge() != 1 || orgUserVo.getIsCharge() != 0)) { throw new RuntimeException("isCharge只能为0或1"); } if (BeanUtils.isNotEmpty(orgUserVo.getIsMaster()) && !(orgUserVo.getIsMaster() != 1 || orgUserVo.getIsMaster() != 0)) { throw new RuntimeException("isMaster只能为0或1"); } Org o = this.getByCode(orgUserVo.getOrgCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("没有找到对应的组织！"); } Map map = new HashMap(); map.put("userId", u.getId()); map.put("orgId", o.getId()); List list = orgUserService.getByParms(map); if (BeanUtils.isEmpty(list)) { OrgUser orgUser = new OrgUser(); orgUser.setId(UniqueIdUtil.getSuid()); orgUser.setUserId(u.getId()); orgUser.setOrgId(o.getId()); orgUser.setIsRelActive(1); if (BeanUtils.isEmpty(orgUserVo.getIsCharge())) { orgUser.setIsCharge(0); } else { orgUser.setIsCharge(orgUserVo.getIsCharge()); } if (BeanUtils.isEmpty(orgUserVo.getIsMaster())) { orgUser.setIsMaster(0); } else { orgUser.setIsMaster(orgUserVo.getIsMaster()); if (orgUserVo.getIsMaster() == 1) { List l = orgUserService.getOrgUserMaster(u.getId(), o.getDemId()); if (BeanUtils.isNotEmpty(l)) { OrgUser ou = l.get(0); ou.setIsMaster(0); orgUserService.update(ou); } } } orgUserService.create(orgUser); } else { User user = userService.getByAccount(orgUserVo.getAccount()); Org org = getByCode(orgUserVo.getOrgCode()); throw new RuntimeException("用户【" + user.getFullname() + "(" + orgUserVo.getAccount() + ")】已存在组织【" + org.getName() + "(" + orgUserVo.getOrgCode() + ")】中"); } return new CommonResult(true, "加入用户成功", ""); } @Override @Transactional public CommonResult delOrgUser(String ids) throws Exception { if (StringUtil.isEmpty(ids)) { throw new RuntimeException("id值不能为空！"); } String[] orgUserIds = ids.split(","); Boolean isDele = false; StringBuilder str = new StringBuilder(); for (String id : orgUserIds) {// 将用户在该组织下的所有相关下属删除 OrgUser obj = orgUserService.get(id); if (BeanUtils.isNotEmpty(obj)) { //清除用户主组织缓存 orgUserService.removeUserMainOrgCache(obj.getUserId()); orgUserService.removeUserMainOrgCache("", obj.getUserId()); userUnderService.delByUserIdAndOrgId(obj.getUserId(), obj.getOrgId()); isDele = true; } else { str.append(id); str.append("，"); } } String msg = StringUtil.isEmpty(str.toString()) ? "用户取消加入成功！" : "部分用户取消加入成功，id为：" + str.toString() + "的数据不存在！"; orgUserService.removeByIds(orgUserIds); return new CommonResult(isDele, msg, ""); } @Override public CommonResult getUserIsMaster(String account, String demCode) throws Exception { if (StringUtils.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：用户帐号account必填！"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的account没有找到对应的用户信息"); } if (StringUtils.isEmpty(demCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "：维度编码demCode必填！"); } Demension d = demensionService.getByCode(demCode); if (BeanUtils.isEmpty(d)) { throw new RuntimeException("根据输入的demCode没有找到对应的维度信息"); } List orgUsers = orgUserService.getOrgUserMaster(u.getId(), d.getId()); if (BeanUtils.isEmpty(orgUsers)) { return new CommonResult(true, "用户在【" + d.getDemCode() + "】下没有主组织", false); } else { return new CommonResult(true, "用户在【" + d.getDemCode() + "】下存在主组织", true); } } @Override @Transactional public CommonResult setMaster(String account, String postCode) throws Exception { OrgPost post = orgPostService.getByCode(postCode); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入的岗位编码没有找到对应的岗位信息"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号没有找到对应的用户"); } OrgUser orgUser = orgUserService.getOrgUser(post.getOrgId(), u.getId(), post.getId()); if (BeanUtils.isEmpty(orgUser)) { throw new RuntimeException("对不起，该用户目前还不是该岗位下的人员！"); } orgUserService.setMaster(orgUser.getId()); return new CommonResult(true, "操作成功！", ""); } @Override public List getTreeDataByDem(String demCode, String pOrgCode) throws Exception { if (StringUtil.isEmpty(demCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":维度编码demCode必填"); } Demension d = demensionService.getByCode(demCode); if (BeanUtils.isEmpty(d)) { throw new RuntimeException("根据输入的demCode没有找到对应的维度"); } Org p = this.getByCode(pOrgCode); if (StringUtil.isNotEmpty(pOrgCode) && BeanUtils.isEmpty(p)) { throw new RuntimeException("根据输入的pOrgCode没有找到组织"); } List orgTree = new ArrayList(); String pId = "0"; if (BeanUtils.isNotEmpty(p)) { pId = p.getId(); } // DefaultQueryFilter filter = new DefaultQueryFilter(); QueryFilter filter = QueryFilter.build(); PageBean page = new PageBean(); page.setPageSize(PageBean.WITHOUT_PAGE); filter.setPageBean(page); filter.addParams("demId", d.getId()); // filter.addParamsFilter("parentId", pId); List groupList = this.getByParentAndDem(filter); List rtnList = new ArrayList(); getChild(groupList, pId, rtnList); for (Org group : rtnList) { OrgTree groupTree = new OrgTree(group); orgTree.add(groupTree); } return orgTree; } @Override @Transactional public CommonResult setOrgCharge(String account, String orgCode, Boolean isCharge) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":组织编码orgCode必填"); } User u = userService.getByAccount(account); Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号没有获取到用户！"); } if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织编码没有获取到对应组织！"); } List orgUserList = orgUserService.getListByOrgIdUserId(o.getId(), u.getId()); if (BeanUtils.isEmpty(orgUserList)) { throw new RuntimeException("用户【" + account + "】与组织【" + orgCode + "】不存在关系"); } orgUserService.setCharge(u.getId(), isCharge, o.getId()); return new CommonResult(true, "设置成功", ""); } @Override @Transactional public CommonResult addUserUnders(UserUnderVo userUnderObj) throws Exception { if (StringUtil.isEmpty(userUnderObj.getUnderAccounts())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":下属用户帐号underAccounts必填"); } if (StringUtil.isEmpty(userUnderObj.getAccount())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } if (StringUtil.isEmpty(userUnderObj.getOrgCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":组织编码orgCode必填"); } User u = userService.getByAccount(userUnderObj.getAccount()); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的account没有找到对应的用户！"); } Org o = this.getByCode(userUnderObj.getOrgCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的orgCode没有找到组织！"); } if (BeanUtils.isEmpty(orgUserService.getListByOrgIdUserId(o.getId(), u.getId()))) { return new CommonResult(false, "用户【" + u.getFullname() + "】与组织【" + o.getName() + "】不存在关系", ""); } // 添加下属 String[] underAccounts = userUnderObj.getUnderAccounts().split(","); for (String a : underAccounts) { User under = userService.getByAccount(a); if (BeanUtils.isEmpty(under)) { throw new RuntimeException("根据帐号【" + a + "】没有找到对应的用户！"); } if (BeanUtils.isEmpty(orgUserService.getListByOrgIdUserId(o.getId(), under.getId()))) { return new CommonResult(false, "用户【" + under.getFullname() + "】与组织【" + o.getName() + "】不存在关系", ""); } if (userUnderObj.getAccount().equals(a)) { throw new RuntimeException("用户【" + a + "】不能将自己添加为自己的下属！"); } Map m = new HashMap(); m.put("userId", under.getId()); m.put("orgId", o.getId()); m.put("underUserId", u.getId()); List list = userUnderService.getUserUnder(m);// 判断是否设置互为上下级 if (BeanUtils.isNotEmpty(list)) { throw new RuntimeException( "用户【" + under.getAccount() + "】在组织【" + o.getCode() + "】下是用户【" + u.getAccount() + "】的上级"); } Map m1 = new HashMap(); m1.put("noUserId", u.getId()); m1.put("orgId", o.getId()); m1.put("underUserId", under.getId()); List list1 = userUnderService.getUserUnder(m1);// 获取该组织下，不是当前上级用户的数据 if (BeanUtils.isNotEmpty(list1)) {// 同一组织下，用户只能有一个上级 User supperUser = userService.get(list1.get(0).getUserId()); throw new RuntimeException( "用户【" + a + "】在当前组织中已有上级" + "【" + supperUser.getFullname() + "】，在当前组织中不能再设置其他上级。"); } else { Map m2 = new HashMap(); m2.put("userId", u.getId()); m2.put("orgId", o.getId()); m2.put("underUserId", under.getId()); List list2 = userUnderService.getUserUnder(m2);// 获取该组织下，是当前上级用户的数据 if (BeanUtils.isNotEmpty(list2)) {// continue; } else { UserUnder userUnder = new UserUnder(); userUnder.setId(UniqueIdUtil.getSuid()); userUnder.setUserId(u.getId()); userUnder.setUnderUserId(under.getId()); userUnder.setUnderUserName(under.getFullname()); userUnder.setOrgId(o.getId()); userUnderService.create(userUnder); } } } return new CommonResult(true, "添加下属成功！", ""); } @Override @Transactional public CommonResult delUserUnders(String account, String orgCode) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":组织编码orgCode必填"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的account没有找到对应的用户！"); } Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的orgCode没有找到组织！"); } Map params = new HashMap(); params.put("userId", u.getId()); params.put("orgId", o.getId()); List l = userUnderService.getUserUnder(params); if (BeanUtils.isEmpty(l)) { return new CommonResult(false, "用户【" + u.getFullname() + "】在组织【" + o.getName() + "】下没有下级", ""); } userUnderService.delByUserIdAndOrgId(u.getId(), o.getId()); return new CommonResult(true, "删除成功！", ""); } @Override public List getUserUnders(String account, String orgCode) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":组织编码orgCode必填"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的account没有找到对应的用户！"); } Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的orgCode没有找到组织！"); } Map m = new HashMap(); m.put("userId", u.getId()); m.put("orgId", o.getId()); List list = userUnderService.getUserUnder(m); List userList = new ArrayList(); for (UserUnder under : list) { User user = userService.get(under.getUnderUserId()); userList.add(user); } return OrgUtil.convertToUserVoList(userList); } @Override @Transactional public CommonResult saveOrgAuth(OrgAuthVo orgAuthVo) throws Exception { if (StringUtil.isEmpty(orgAuthVo.getAccount())) { throw new RequiredException(HotentHttpStatus.REUIRED.description() + "：用户帐号必填！"); } User u = userService.getByAccount(orgAuthVo.getAccount()); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("没有找到对应的用户！"); } if (StringUtil.isEmpty(orgAuthVo.getOrgCode())) { throw new RequiredException(HotentHttpStatus.REUIRED.description() + "：组织代码必填！"); } Org o = this.getByCode(orgAuthVo.getOrgCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("没有找到对应的组织！"); } if (StringUtil.isEmpty(orgAuthVo.getDemCode())) { throw new RequiredException(HotentHttpStatus.REUIRED.description() + "：维度编码必填！"); } Demension d = demensionService.getByCode(orgAuthVo.getDemCode()); if (BeanUtils.isEmpty(d)) { throw new RuntimeException("没有找到对应的组织维度！"); } if (!o.getDemId().equals(d.getId())) { throw new RuntimeException("输入的组织所对应的维度与输入的维度不一致！"); } if (StringUtil.isEmpty(orgAuthVo.getId())) { OrgAuth a = orgAuthService.getByOrgIdAndUserId(o.getId(), u.getId()); if (BeanUtils.isNotEmpty(a)) { throw new RuntimeException("用户在该组织已经是分级管理员！"); } } else { List list = orgAuthService.getListByOrgIdAndUserId(o.getId(), u.getId()); if (list != null && list.size() > 1) { throw new RuntimeException("用户在该组织已经是分级管理员！"); } } OrgAuth auth = new OrgAuth(); if (StringUtil.isEmpty(orgAuthVo.getId())) { auth.setId(UniqueIdUtil.getSuid()); auth.setOrgId(o.getId()); auth.setUserId(u.getId()); auth.setOrgPerms(orgAuthVo.getOrgPerms()); auth.setUserPerms(orgAuthVo.getUserPerms()); auth.setPosPerms(orgAuthVo.getPosPerms()); auth.setOrgauthPerms(orgAuthVo.getOrgauthPerms()); auth.setLayoutPerms(orgAuthVo.getLayoutPerms()); auth.setDemId(d.getId()); orgAuthService.create(auth); return new CommonResult(true, "添加分级管理成功！", ""); } else { auth.setId(orgAuthVo.getId()); auth.setOrgId(o.getId()); auth.setUserId(u.getId()); auth.setOrgPerms(orgAuthVo.getOrgPerms()); auth.setUserPerms(orgAuthVo.getUserPerms()); auth.setPosPerms(orgAuthVo.getPosPerms()); auth.setOrgauthPerms(orgAuthVo.getOrgauthPerms()); auth.setLayoutPerms(orgAuthVo.getLayoutPerms()); auth.setDemId(d.getId()); orgAuthService.update(auth); return new CommonResult(true, "更新分级管理成功！", ""); } } @Override @Transactional public CommonResult deleteOrgAuth(String ids) throws Exception { if (StringUtil.isEmpty(ids)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":分级组织管理id必填"); } String[] idArr = ids.split(","); for (String id : idArr) { if (BeanUtils.isEmpty(orgAuthService.get(id))) { throw new RuntimeException("根据输入的分级组织管理id没有找到对应数据！"); } orgAuthService.remove(id); } return new CommonResult(true, "删除成功！", ""); } @Override public Page getOrgAuthList(String account, String orgCode, String demCode) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号没有找到对应的用户！"); } Org o = null; if (StringUtil.isNotEmpty(orgCode)) { o = this.getByCode(orgCode); } if (StringUtil.isNotEmpty(orgCode) && BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织代码没有找到对应的组织！"); } Demension de = null; if (StringUtil.isNotEmpty(demCode)) { de = demensionService.getByCode(demCode); } if (StringUtil.isNotEmpty(demCode) && BeanUtils.isEmpty(de)) { throw new RuntimeException("根据输入的维度编码没有找到对应的维度！"); } QueryFilter filter = QueryFilter.build(); filter.addParams("userId", u.getId()); if (BeanUtils.isNotEmpty(o)) { filter.addParams("orgId", o.getId()); } if (BeanUtils.isNotEmpty(de)) { filter.addParams("demId", de.getId()); } Page list = (Page) orgAuthService.getAllOrgAuth(filter); return list; } @Override public OrgAuth getOrgAuth(String id) throws Exception { if (StringUtil.isEmpty(id)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":分级组织管理id必填"); } if (BeanUtils.isEmpty(orgAuthService.get(id))) { throw new RuntimeException("根据输入的id数据没有找到对应的信息"); } OrgAuth orgAuth = orgAuthService.get(id); User user = userService.get(orgAuth.getUserId()); orgAuth.setUserName(user.getFullname()); orgAuth.setUserAccount(user.getAccount()); return orgAuth; } @Override public List getUserOrgs(String account, String demCode, Boolean isMain) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号没有找到对应的用户！"); } Demension de = null; if (StringUtil.isNotEmpty(demCode)) { de = demensionService.getByCode(demCode); } if (StringUtil.isNotEmpty(demCode) && BeanUtils.isEmpty(de)) { throw new RuntimeException("根据输入的维度编码没有找到对应的维度！"); } List list = null; String demId = null; if (BeanUtils.isNotEmpty(de)) { demId = de.getId(); } if (BeanUtils.isEmpty(isMain)) { list = this.getUserOrg(u.getId(), demId, null); } else { list = this.getUserOrg(u.getId(), demId, isMain); } return list; } @Override public List getUsersByOrgCodes(String orgCodes, Boolean isMain) throws Exception { if (StringUtil.isEmpty(orgCodes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织代码orgCodes必填！"); } List list = new ArrayList(); String[] orgCodeArr = orgCodes.split(","); for (String orgCode : orgCodeArr) { Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据组织代码【" + orgCode + "】没有找到对应的组织信息！"); } List l = userService.getOrgUsers(o.getId(), isMain); if (BeanUtils.isNotEmpty(l)) { list.addAll(l); } } return OrgUtil.convertToUserVoList(list); } @Override public List getPostsByOrgCodes(String orgCodes, Boolean isMain) throws Exception { if (StringUtil.isEmpty(orgCodes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织代码orgCodes必填！"); } List list = new ArrayList(); String[] orgCodeArr = orgCodes.split(","); for (String orgCode : orgCodeArr) { Org o = this.getByCode(orgCode); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据组织代码【" + orgCode + "】没有找到对应的组织信息！"); } List l = orgPostService.getRelCharge(o.getId(), isMain); if (BeanUtils.isNotEmpty(l)) { list.addAll(l); } } return list; } @Override public List getByLevel(String level, String demCode) throws Exception { if (StringUtil.isEmpty(level)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织级别level必填！"); } Demension d = null; if (StringUtil.isNotEmpty(demCode)) { d = demensionService.getByCode(demCode); } if (StringUtil.isNotEmpty(demCode) && BeanUtils.isEmpty(d)) { throw new RuntimeException("根据输入的输入的维度编码demCode没有找到对应的维度！"); } QueryFilter filter = QueryFilter.build(); //filter.setClazz(Org.class); filter.addParams("grade_", level); if (BeanUtils.isNotEmpty(d)) { filter.addParams("dem_id_", d.getId()); } return this.query(filter).getRows(); } @Override @Transactional public CommonResult saveUserPost(String accounts, String postCode) throws Exception { if (StringUtil.isEmpty(accounts)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "用户帐号accounts必填！"); } if (StringUtil.isEmpty(postCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位代码postCode必填！"); } String[] postCodeArr = postCode.split(","); String[] accountArr = accounts.split(","); for (String str : postCodeArr) { OrgPost post = orgPostService.getByCode(str); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入岗位代码没有找到对应的岗位信息！"); } Org org = this.get(post.getOrgId()); if(null != org) { if (postCode.indexOf(",") < 0) { if (org.getExceedLimitNum() == 1 && org.getLimitNum() != 0) { Map map = new HashMap<>(); map.put("orgCode", org.getCode()); map.put("group", "true"); List> list = orgUserService.getUserNumByOrgCode(map); if (org.getLimitNum() < list.size() + accountArr.length) { return new CommonResult(false, "人数超出组织上限，不予添加", null); } } } } for (String account : accountArr) { User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号【" + account + "】没有找到对应的用户"); } OrgUser ou = orgUserService.getOrgUser(post.getOrgId(), u.getId(), post.getId()); if (BeanUtils.isNotEmpty(ou)) { continue; } ou = orgUserService.getOrgUser(post.getOrgId(), u.getId(), ""); if (BeanUtils.isNotEmpty(ou)) { ou.setRelId(post.getId()); orgUserService.update(ou); } else { ou = new OrgUser(); ou.setId(UniqueIdUtil.getSuid()); ou.setUserId(u.getId()); ou.setIsCharge(0); ou.setIsMaster(0); ou.setIsRelActive(1); ou.setOrgId(post.getOrgId()); ou.setRelId(post.getId()); orgUserService.create(ou); } // ou = new OrgUser(); // ou.setId(UniqueIdUtil.getSuid()); // ou.setUserId(u.getId()); // ou.setIsCharge(0); // ou.setIsMaster(0); // ou.setIsRelActive(1); // ou.setOrgId(post.getOrgId()); // ou.setRelId(post.getId()); // orgUserService.create(ou); } } return new CommonResult(true, "添加成功", ""); } @Override @Transactional public CommonResult saveUserPosts(String account, String postCodes) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "用户帐号accounts必填！"); } if (StringUtil.isEmpty(postCodes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位代码postCode必填！"); } String[] postCodesArr = postCodes.split(","); for (String postCode : postCodesArr) { OrgPost post = orgPostService.getByCode(postCode); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入岗位代码没有找到对应的岗位信息！"); } Org org = this.get(post.getOrgId()); if (org.getExceedLimitNum() == 1 && org.getLimitNum() != 0) { Map map = new HashMap<>(); map.put("orgCode", org.getCode()); map.put("group", "true"); List> list = orgUserService.getUserNumByOrgCode(map); if (org.getLimitNum() <= list.size()) { return new CommonResult(false, "人数超出组织上限，不予添加", null); } } User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号【" + account + "】没有找到对应的用户"); } OrgUser ou = orgUserService.getOrgUser(post.getOrgId(), u.getId(), post.getId()); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("ORG_ID_", post.getOrgId()); queryWrapper.eq("USER_ID_", u.getId()); List> list = orgUserService.listMaps(queryWrapper); if (BeanUtils.isNotEmpty(ou)) { throw new BaseException("当前用户已在【" + post.getName() + "】的岗位上！"); } for (int i = 0; i < list.size(); i++) { if (ObjectUtils.isEmpty(list.get(i).get("relId"))) { if (BeanUtils.isNotEmpty(list.get(i).get("ID_"))) { delOrgUser(list.get(i).get("ID_").toString()); } else { delOrgUser(list.get(i).get("id_").toString()); } break; } } ou = new OrgUser(); ou.setId(UniqueIdUtil.getSuid()); ou.setUserId(u.getId()); ou.setIsCharge(0); ou.setIsMaster(0); ou.setIsRelActive(1); ou.setOrgId(post.getOrgId()); ou.setRelId(post.getId()); orgUserService.create(ou); } return new CommonResult(true, "添加成功", ""); } @Override @Transactional public CommonResult delUserPost(String accounts, String postCode) throws Exception { if (StringUtil.isEmpty(accounts)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "用户帐号accounts必填！"); } if (StringUtil.isEmpty(postCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位代码postCode必填！"); } OrgPost post = orgPostService.getByCode(postCode); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入岗位代码没有找到对应的岗位信息！"); } String[] accountArr = accounts.split(","); for (String account : accountArr) { User u = userService.getByAccount(account); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号【" + account + "】没有找到对应的用户"); } OrgUser ou = orgUserService.getOrgUser(post.getOrgId(), u.getId(), post.getId()); if (BeanUtils.isEmpty(ou)) { // continue; throw new RuntimeException("用户【" + account + "】不在岗位【" + post.getCode() + "】下"); } orgUserService.remove(ou.getId()); } return new CommonResult(true, "删除成功", ""); } /** * todo * @param orgPostVo * @return * @throws Exception */ @Override @Transactional public CommonResult saveOrgPost(OrgPostVo orgPostVo) throws Exception { if (StringUtil.isEmpty(orgPostVo.getCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位代码code必填！"); } if (orgPostVo.getCode().contains(",")) { throw new RuntimeException("添加岗位失败，岗位编码不允许含英文逗号‘,’"); } if (StringUtil.isEmpty(orgPostVo.getName())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位名称name必填！"); } // if (StringUtil.isEmpty(orgPostVo.getJobCode())) { // throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "职务代码jobCode必填！"); // } if (StringUtil.isEmpty(orgPostVo.getOrgCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织代码orgCode必填！"); } Org o = this.getByCode(orgPostVo.getOrgCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织代码没有找到对应的组织信息！"); } // OrgJob job = orgJobService.getByCode(orgPostVo.getJobCode()); // if (BeanUtils.isEmpty(job)) { // throw new RuntimeException("没有找到对应的人员类别信息！"); // } if (orgPostService.getCountByCode(orgPostVo.getCode()) > 0) { throw new RuntimeException("岗位编码【" + orgPostVo.getCode() + "】已经存在系统中！"); } OrgPost rel = new OrgPost(); rel.setId(UniqueIdUtil.getSuid()); rel.setName(orgPostVo.getName()); rel.setCode(orgPostVo.getCode()); rel.setLevel(orgPostVo.getLevel()); rel.setOrgId(o.getId()); rel.setOrgCode(o.getCode()); rel.setOrgName(o.getName()); rel.setIsCharge(orgPostVo.getIsCharge()); if (orgPostVo.getIsCharge() == 1) { List l = orgPostService.getRelCharge(o.getId(), true); if (BeanUtils.isNotEmpty(l)) { OrgPost p = l.get(0); p.setIsCharge(0); orgPostService.update(p); } } orgPostService.create(rel); return new CommonResult(true, "添加岗位成功！", ""); } @Override @Transactional public CommonResult deleteOrgPost(String postCodes) throws Exception { if (StringUtil.isEmpty(postCodes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位编码postCodes必填！"); } String[] codeArr = postCodes.split(","); for (String code : codeArr) { OrgPost rel = orgPostService.getByCode(code); if (BeanUtils.isEmpty(rel)) { throw new RuntimeException("根据输入的岗位编码【" + code + "】没有找到对应的岗位信息！"); } //判断岗位组是否存在人员 Map map = new HashMap(); map.put("orgId", rel.getOrgId()); map.put("relId", rel.getId()); List orgUsers = orgUserService.getByParms(map); if (BeanUtils.isNotEmpty(orgUsers)) { throw new RuntimeException("岗位【" + rel.getName() + "】下还存在分配用户，请删除用户在进行操作！"); } // if (OrgUtil.checkUserGruopIsUserRel("pos", rel.getId())) { // throw new RuntimeException("编码为【"+code+"】的岗位为汇报节点不能删除！"); // } String[] ids = {rel.getId()}; orgPostService.removeByIds(ids); } return new CommonResult(true, "删除岗位成功", ""); } @Override @Transactional public CommonResult setPostMaster(String postCode, Boolean isMain) throws Exception { if (StringUtil.isEmpty(postCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位编码postCode必填！"); } if (BeanUtils.isEmpty(isMain)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "是否责任岗位isMain必填！"); } OrgPost post = orgPostService.getByCode(postCode); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入的岗位编码没有找到对应的岗位！"); } if (isMain) {// 若为设置责任岗位，那么先将该组织中的责任岗位取消再设置 orgPostService.cancelRelCharge(post.getOrgId()); } orgPostService.setRelCharge(post.getId(), isMain); return new CommonResult(true, "设置成功！", ""); } @Override @Transactional public CommonResult setUserPostDueTime(PostDueVo postDueVo) throws Exception { if (StringUtil.isEmpty(postDueVo.getCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位编码code必填！"); } if (StringUtil.isEmpty(postDueVo.getAccount())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "用户帐号account必填！"); } if (BeanUtils.isEmpty(postDueVo.getEndDate()) && BeanUtils.isEmpty(postDueVo.getStartDate())) { throw new RuntimeException("开始时间和结束时间至少填写一个！"); } OrgPost post = orgPostService.getByCode(postDueVo.getCode()); if (BeanUtils.isEmpty(post)) { throw new RuntimeException("根据输入的岗位编码没有找到对应的岗位信息！"); } User u = userService.getByAccount(postDueVo.getAccount()); if (BeanUtils.isEmpty(u)) { throw new RuntimeException("根据输入的用户帐号没有找到对应的用户信息！"); } OrgUser orgUser = orgUserService.getOrgUser(post.getOrgId(), u.getId(), post.getId()); if (BeanUtils.isEmpty(orgUser)) { throw new RuntimeException("用户与该岗位没关系，不能设置！"); } if (StringUtil.isNotEmpty(postDueVo.getStartDate()) && StringUtil.isNotEmpty(postDueVo.getEndDate())) { LocalDateTime startDate = DateFormatUtil.parse(postDueVo.getStartDate()); LocalDateTime endDate = DateFormatUtil.parse(postDueVo.getEndDate()); if (DateUtil.getTime(startDate, endDate) < 0) { throw new RuntimeException("开始时间不能大于结束时间！"); } } if (StringUtil.isNotEmpty(postDueVo.getStartDate())) { orgUser.setStartDate(DateFormatUtil.parse(postDueVo.getStartDate())); } else { orgUser.setStartDate(null); } if (StringUtil.isNotEmpty(postDueVo.getEndDate())) { orgUser.setEndDate(DateFormatUtil.parse(postDueVo.getEndDate())); } else { orgUser.setEndDate(null); } orgUserService.update(orgUser); return new CommonResult(true, "设置成功！", ""); } @Override @Transactional public CommonResult validOrgUser() throws Exception { orgUserService.syncValidOrgUser(); return new CommonResult(true, "校验成功！", ""); } @Override @Transactional public CommonResult addOrgRole(OrgRoleVo orgRoleVo) throws Exception { if (StringUtil.isEmpty(orgRoleVo.getOrgCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织编码orgCode必填！"); } Org org = this.getByCode(orgRoleVo.getOrgCode()); if (BeanUtils.isEmpty(org)) { throw new RuntimeException("根据输入的组织编码，没有找到对应的组织信息！"); } if (StringUtil.isEmpty(orgRoleVo.getRoleCodes())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "角色编码roleCodes必填！"); } String[] roleCodes = orgRoleVo.getRoleCodes().split(","); for (String rCode : roleCodes) { Role r = roleService.getByAlias(rCode); if (BeanUtils.isEmpty(r)) { r = roleService.get(rCode); if (BeanUtils.isEmpty(r)) throw new RuntimeException("根据输入的角色编码，没有找到对应的角色信息！"); } if (orgRoleVo.getIsInherit() > 0) { orgRoleService.addOrgRole(org.getId(), r, 1); } else { orgRoleService.addOrgRole(org.getId(), r, 0); } } return new CommonResult(true, "保存成功", ""); } @Override @Transactional public void delOrgRoleByCode(String orgCode, String roleCodes) throws Exception { if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织编码orgCode必填！"); } Org org = this.getByCode(orgCode); if (BeanUtils.isEmpty(org)) { throw new RuntimeException("根据输入的组织编码，没有找到对应的组织信息！"); } if (StringUtil.isEmpty(roleCodes)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "角色编码roleCodes必填！"); } String[] roleCodeArr = roleCodes.split(","); for (String rCode : roleCodeArr) { Role r = roleService.getByAlias(rCode); if (BeanUtils.isEmpty(r)) { throw new RuntimeException("根据输入的角色编码，没有找到对应的角色信息！"); } orgRoleService.delByOrgIdAndRoleId(org.getId(), r.getId()); } } @Override @Transactional public CommonResult delOrgRoleById(String ids) throws Exception { if (StringUtil.isEmpty(ids)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织角色ID必填！"); } String[] roleId = ids.split(","); for (String id : roleId) { orgRoleService.remove(id); } return new CommonResult(true, "删除成功", ""); } @Override @Transactional public void delAllOrgRole(String orgCode) throws Exception { if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织编码orgCode必填！"); } Org org = this.getByCode(orgCode); if (BeanUtils.isEmpty(org)) { throw new RuntimeException("根据输入的组织编码，没有找到对应的组织信息！"); } orgRoleService.delByOrgIdAndRoleId(org.getId(), null); } @Override public List getOrgRoleByCode(String orgCode) throws Exception { if (StringUtil.isEmpty(orgCode)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织编码orgCode必填！"); } Org org = this.getByCode(orgCode); if (BeanUtils.isEmpty(org)) { throw new RuntimeException("根据输入的组织编码，没有找到对应的组织信息！"); } return getRolesByOrgId(org.getId()); } public List getRolesByOrgId(String orgId) { Map map = new HashMap(); map.put("orgId", orgId); List roleList = roleService.getOrgRoleList(map);// 获取自身所拥有角色 // 根据组织id获取。 if (BeanUtils.isNotEmpty(roleList)) return roleList; // 沿着路径往上查找。 roleList = new ArrayList(); String path = getPathByOrgId(orgId); if (StringUtil.isEmpty(path)) return roleList; String[] aryPath = path.split("[.]"); // 从后往前找。 for (int i = aryPath.length - 1; i >= 0; i--) { String tmpOrgId = aryPath[i]; Map m = new HashMap(); m.put("orgId", tmpOrgId); m.put("isInherit", 1); roleList = roleService.getOrgRoleList(m);// 获取父组织可继承的角色 // 如果找到了则停止循环。 if (BeanUtils.isNotEmpty(roleList)) { break; } } return roleList; } /** * 根据组织ID获取组织路径。 * * @param orgId 组织ID。 * @return */ private String getPathByOrgId(String orgId) { Org sysOrg = this.get(orgId); if (sysOrg == null) return ""; String path = sysOrg.getPath(); if (StringUtil.isEmpty(path)) return ""; // 去掉当前Id。 path = path.replace("." + orgId + ".", ""); // 去掉维度Id。 int pos = path.indexOf("."); path = path.substring(pos + 1); return path; } @Override @Transactional public CommonResult updateOrgPost(OrgPostVo postVo) throws Exception { if (StringUtils.isEmpty(postVo.getCode())) { return new CommonResult(false, "岗位编码必填", ""); } if (StringUtils.isEmpty(postVo.getName())) { return new CommonResult(false, "岗位名称必填", ""); } OrgPost p = orgPostService.getByCode(postVo.getCode()); if (BeanUtils.isEmpty(p)) { return new CommonResult(false, "根据输入的编码没有找到对应的岗位", ""); } if (StringUtil.isNotEmpty(postVo.getOrgCode()) && StringUtil.isNotEmpty(p.getOrgCode())) { Org o = this.getByCode(postVo.getOrgCode()); //岗位所属组织发生了变化， if (!p.getOrgId().equals(o.getId())) { p.setOrgId(o.getId()); //判断新组织是否有限编 if (o.getExceedLimitNum() == 1 && o.getLimitNum() != 0) { Map map = new HashMap<>(); map.put("orgCode", o.getCode()); map.put("group", "true"); //获取新组织已有人数 List> list = orgUserService.getUserNumByOrgCode(map); if (o.getLimitNum() <= list.size()) { return new CommonResult(false, "岗位组织所属人数超出上限，修改失败", null); } else { Set userIds = new HashSet<>(); for (Map l : list) { userIds.add((String) l.get("userId")); } //查询当前岗位下的人数 QueryFilter queryFilter = QueryFilter.build().withPage(new PageBean(1, PageBean.WITHOUT_PAGE)); queryFilter.addFilter("pos_id_", p.getId(), QueryOP.EQUAL); IPage> userByGroup = orgUserService.getUserByGroup(queryFilter); //List> userByGroup = orgUserService.getUserByGroup(queryFilter); Set addUserIds = new HashSet<>(); if (BeanUtils.isNotEmpty(userByGroup)) { for (Map orgUser : userByGroup.getRecords()) { if (!userIds.contains(orgUser.get("userId"))) { addUserIds.add((String) orgUser.get("userId")); } } } if (o.getLimitNum() <= (list.size() + addUserIds.size())) { return new CommonResult(false, "岗位所属组织人数超出上限，修改失败", null); } } } orgUserService.updateUserOrgByPostId(p.getId(), p.getOrgId()); } } if (postVo.getIsCharge() == 1) { p.setIsCharge(1); this.setPostMaster(p.getCode(), true); } p.setLevel(postVo.getLevel()); p.setName(postVo.getName()); orgPostService.update(p); return new CommonResult(true, "更新成功", ""); } @Override @Transactional public CommonResult setUnderUsers(String orgId, String account, String underAccounts) throws Exception { User u = userService.getByAccount(account); Org o = this.get(orgId); // 添加下属 String[] underAccountArr = underAccounts.split(","); for (String a : underAccountArr) { User under = userService.getByAccount(a); if (BeanUtils.isEmpty(under)) { throw new BaseException("根据帐号【" + a + "】没有找到对应的用户！"); } if (account.equals(a)) { throw new BaseException("用户【" + under.getFullname() + "】不能将自己添加为自己的下属！"); } Map m = new HashMap(); m.put("userId", under.getId()); m.put("orgId", o.getId()); m.put("underUserId", u.getId()); List list = userUnderService.getUserUnder(m);// 判断是否设置互为上下级 if (BeanUtils.isNotEmpty(list)) { throw new BaseException( "用户【" + under.getFullname() + "】在组织【" + o.getCode() + "】下是用户【" + u.getFullname() + "】的上级"); } Map m1 = new HashMap(); m1.put("noUserId", u.getId()); m1.put("orgId", o.getId()); m1.put("underUserId", under.getId()); List list1 = userUnderService.getUserUnder(m1);// 获取该组织下，不是当前上级用户的数据 if (BeanUtils.isNotEmpty(list1)) {// 同一组织下，用户只能有一个上级 User supperUser = userService.get(list1.get(0).getUserId()); throw new BaseException("用户【" + under.getFullname() + "】在当前组织中已有上级" + "【" + supperUser.getFullname() + "】，在当前组织中不能再设置其他上级。"); } else { Map m2 = new HashMap(); m2.put("userId", u.getId()); m2.put("orgId", o.getId()); m2.put("underUserId", under.getId()); List list2 = userUnderService.getUserUnder(m2);// 获取该组织下，是当前上级用户的数据 if (BeanUtils.isNotEmpty(list2)) {// continue; } else { UserUnder userUnder = new UserUnder(); userUnder.setId(UniqueIdUtil.getSuid()); userUnder.setUserId(u.getId()); userUnder.setUnderUserId(under.getId()); userUnder.setUnderUserName(under.getFullname()); userUnder.setOrgId(o.getId()); userUnderService.create(userUnder); } } if (BeanUtils.isEmpty(orgUserService.getListByOrgIdUserId(o.getId(), under.getId()))) {// 若添加的下属还不属于该组织人员，那么将用户添为该组织人员 OrgUser ou = new OrgUser(); ou.setId(UniqueIdUtil.getSuid()); ou.setUserId(under.getId()); ou.setOrgId(orgId); } } return new CommonResult(true, "添加下属成功", ""); } @Override @Transactional public CommonResult addUsersForOrg(String orgCode, String accounts) throws Exception { String[] accountArr = accounts.split(","); Org o = this.getByCode(orgCode); for (String a : accountArr) { User u = userService.getByAccount(a); if (BeanUtils.isEmpty(u)) { return new CommonResult(false, "帐号【" + a + "】不存在", ""); } List l = orgUserService.getListByOrgIdUserId(o.getId(), u.getId()); if (BeanUtils.isNotEmpty(l)) { continue; } OrgUser ou = new OrgUser(); ou.setId(UniqueIdUtil.getSuid()); ou.setIsCharge(0); ou.setIsMaster(0); ou.setOrgId(o.getId()); ou.setUserId(u.getId()); ou.setVersion(1); ou.setIsRelActive(1); orgUserService.create(ou); } return new CommonResult(true, "加入成功", ""); } @Override public List getOrgByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); List list = new ArrayList(); if (StringUtil.isNotEmpty(exportObject.getDemCodes())) { QueryFilter filter = QueryFilter.build().withPage(new PageBean(1, PageBean.WITHOUT_PAGE)); filter.addFilter("CODE_", exportObject.getDemCodes(), QueryOP.IN, FieldRelation.AND); list = DemensionManager.queryNoPage(filter); } if (BeanUtils.isNotEmpty(list)) { Set demIds = new HashSet(); for (Demension demension : list) { demIds.add(demension.getId()); } queryFilter.addFilter("DEM_ID_", new ArrayList(demIds), QueryOP.IN, FieldRelation.AND); } if (StringUtil.isNotEmpty(exportObject.getOrgCodes())) { List ids = getOrgAndChildrens(exportObject.getOrgCodes()); if (BeanUtils.isNotEmpty(ids)) { queryFilter.addFilter("ID_", ids, QueryOP.IN, FieldRelation.AND); } } return this.queryNoPage(queryFilter); } /** * 获取组织的子组织 * * @param orgCodes * @return */ private List getOrgAndChildrens(String orgCodes) { QueryFilter filter = QueryFilter.build().withPage(new PageBean(1, PageBean.WITHOUT_PAGE)); filter.setPageBean(new PageBean(1, PageBean.WITHOUT_PAGE)); filter.addFilter("CODE_", orgCodes, QueryOP.IN, FieldRelation.AND); List porgs = this.queryNoPage(filter); if (BeanUtils.isNotEmpty(porgs)) { QueryFilter filter2 = QueryFilter.build().withPage(new PageBean(1, PageBean.WITHOUT_PAGE)); filter2.setPageBean(new PageBean(1, PageBean.WITHOUT_PAGE)); for (Org org : porgs) { filter2.addFilter("PATH_", org.getPath(), QueryOP.RIGHT_LIKE, FieldRelation.OR); } List childrens = this.queryNoPage(filter2); if (BeanUtils.isNotEmpty(childrens)) { Set ids = new HashSet(); for (Org org : childrens) { ids.add(org.getId()); } List list = new ArrayList(); list.addAll(ids); return list; } } return new ArrayList(); } /** * 获取同步数据时，如果传了组织相关的参数，则添加过滤条件 * * @param queryFilter * @param exportObject * @throws Exception */ private void addOrgFilter(QueryFilter queryFilter, OrgExportObject exportObject) throws Exception { if (StringUtil.isNotEmpty(exportObject.getDemCodes()) || StringUtil.isNotEmpty(exportObject.getOrgCodes())) { List orgs = getOrgByTime(exportObject); if (BeanUtils.isNotEmpty(orgs)) { List orgIds = new ArrayList(); for (Org org : orgs) { orgIds.add(org.getId()); } queryFilter.addFilter("ORG_ID_", orgIds, QueryOP.IN, FieldRelation.AND); } } } @Override public List getOrgParamByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); return orgParamsService.queryNoPage(queryFilter); } @Override public List getOrgPostByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); return orgPostService.queryNoPage(queryFilter); } @Override public List getOrgRoleByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); addOrgFilter(queryFilter, exportObject); return orgRoleManager.queryNoPage(queryFilter); } @Override public List getOrgUserByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); addOrgFilter(queryFilter, exportObject); return orgUserService.queryNoPage(queryFilter); } @Override public List getUserUnderByTime(OrgExportObject exportObject) throws Exception { QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(exportObject.getBtime(), exportObject.getEtime()); addOrgFilter(queryFilter, exportObject); return userUnderManager.queryNoPage(queryFilter); } @Override public List getOrgsByAccount(String account) throws Exception { if (StringUtil.isEmpty(account)) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + ":用户帐号account必填"); } List list = baseMapper.getOrgsByAccount(account); for (Org org : list) { Demension dem = demensionService.get(org.getDemId()); if (BeanUtils.isNotEmpty(dem)) { org.setDemName(dem.getDemName()); } } OrgUtil.removeDuplicate(list, "id"); return list; } @Override @Transactional public Integer removePostPhysical() { return orgPostDao.removePhysical(); } @Override @Transactional public Integer removeOrgUserPhysical() { return orgUserService.removePhysical(); } @Override public CommonResult isCodeExist(String code) throws Exception { Org org = baseMapper.getByCode(code); boolean isExist = BeanUtils.isNotEmpty(org); return new CommonResult(isExist, isExist ? "该组织编码已存在！" : "", isExist); } @Override public CommonResult isPostCodeExist(String code) throws Exception { OrgPost post = orgPostDao.getByCode(code); boolean isExist = BeanUtils.isNotEmpty(post); return new CommonResult(isExist, isExist ? "该岗位编码已存在！" : "", isExist); } @Override @Transactional public CommonResult updateOrgPos(String orgId, String parentId) throws Exception { if (StringUtil.isEmpty(orgId) || StringUtil.isEmpty(parentId)) { throw new RequiredException("移动节点或目标节点id不能为空！"); } Org org = this.get(orgId); if (BeanUtils.isEmpty(org)) { throw new RequiredException("根据移动节点id【" + orgId + "】未找到对应组织！"); } org.setParentId(parentId); if ("0".equals(parentId)) { parentId = org.getDemId(); } Org parentOrg = this.get(parentId); if (BeanUtils.isEmpty(parentOrg)) { org.setPath(parentId + "." + orgId + "."); org.setPathName("/" + org.getName()); } else { org.setPath(parentOrg.getPath() + orgId + "."); org.setPathName(parentOrg.getPathName() + "/" + org.getName()); } this.update(org); updateChildrenOrg(org); return new CommonResult(true, "更新组织成功！", ""); } /** * 递归更新子组织的path和pathName * * @param parentOrg * @throws SQLException */ private void updateChildrenOrg(Org parentOrg) throws SQLException { List childrens = this.getByParentId(parentOrg.getId()); for (Org org : childrens) { org.setPath(parentOrg.getPath() + org.getId() + "."); org.setPathName(parentOrg.getPathName() + "/" + org.getName()); this.update(org); updateChildrenOrg(org); } } @SuppressWarnings({"unchecked", "rawtypes"}) @Override public String exportData(String orgCode, boolean isChildre) throws Exception { if (StringUtil.isEmpty(orgCode)) { throw new RequiredException("组织编码【orgCode】不能为空！"); } Org org = baseMapper.getByCode(orgCode); if (BeanUtils.isEmpty(org)) { throw new RequiredException("根据组织编码【" + orgCode + "】找不到对应组织！"); } QueryFilter queryFilter = QueryFilter.build(); queryFilter.getPageBean().setPageSize(PageBean.WITHOUT_PAGE); if (isChildre) { queryFilter.getParams().put("whereSql", " org.path_ like '" + org.getPath() + "%'"); } else { queryFilter.getParams().put("orgId", org.getId()); } String orgName = org.getName(); String times = DateUtil.getCurrentTime("yyyymmddhhmmss"); List list = orgUserService.getOrgUserData(queryFilter); String path = (FileUtil.getIoTmpdir() + "/attachFiles/tempZip/" + orgName + "/" + times).replace("/", File.separator); String excelPath = path + File.separator; String excelName = "组织【" + orgName + "】相关数据"; exportExcel(list, orgName, excelName, excelPath); String filePath = excelPath + excelName; return filePath; } private void exportExcel(List list, String sheetName, String excelName, String excelPath) throws Exception { Map exportMaps = new LinkedHashMap(); exportMaps.put("fullName", "用户姓名"); exportMaps.put("account", "用户账号"); exportMaps.put("userNumber", "工号"); exportMaps.put("userId", "用户ID"); exportMaps.put("status", "用户状态"); exportMaps.put("mobile", "手机号码"); exportMaps.put("email", "邮箱"); exportMaps.put("orgName", "组织名称"); exportMaps.put("orgCode", "组织编码"); exportMaps.put("orgId", "组织ID"); exportMaps.put("orgPath", "组织路径"); exportMaps.put("orgPathName", "路径名称"); exportMaps.put("isMaster", "主岗位"); exportMaps.put("isCharge", "负责人"); exportMaps.put("relName", "岗位名称"); exportMaps.put("postCode", "岗位编码"); exportMaps.put("relId", "岗位ID"); exportMaps.put("isRelActive", "岗位是否有效"); HSSFWorkbook book = ExcelUtil.exportExcel(sheetName, 16, exportMaps, list); ExcelUtil.saveExcel(book, excelName, excelPath); } @Override public List> getPathNames(List userIds) { return baseMapper.getPathNames(userIds); } @Override public Map> getChildrenIds(Map ids) { Map> resultMap = new HashMap>(); if (BeanUtils.isNotEmpty(ids)) { for (String key : ids.keySet()) { String idStr = ids.get(key); if (StringUtil.isEmpty(idStr)) { continue; } String[] idArray = idStr.split(","); QueryFilter filter1 = QueryFilter.build().withPage(new PageBean(1, PageBean.WITHOUT_PAGE)); filter1.addFilter("ID_", idArray, QueryOP.IN); List orgs = this.queryNoPage(filter1); if (BeanUtils.isNotEmpty(orgs)) { Map pathMap = new HashMap(); for (int i = 0; i < orgs.size(); i++) { pathMap.put(String.valueOf(i + 1), orgs.get(i).getPath()); } List childrenIds = baseMapper.getChildrenIds(pathMap); resultMap.put(key, new HashSet<>(childrenIds)); } } } return resultMap; } @Override public Org getOrgMaster(String account) { List orglist = baseMapper.getOrgMaster(account); if (BeanUtils.isNotEmpty(orglist)) { return orglist.get(0); } else { return null; } } @Override @Transactional public CommonResult addOrgFromExterUni(Org orgVo) { if (BeanUtils.isEmpty(orgVo.getName())) { throw new RuntimeException("添加组织失败，组织名称【name】不能为空！"); } if (BeanUtils.isEmpty(orgVo.getCode())) { throw new RuntimeException("添加组织失败，组织编码【code】不能为空！"); } if (orgVo.getCode().contains(",")) { throw new RuntimeException("组织编码中不能包含英文逗号‘,’"); } if (BeanUtils.isEmpty(orgVo.getDemId())) { Demension defaultDem = demensionService.getDefaultDemension(); if (BeanUtils.isEmpty(defaultDem)) { throw new RuntimeException("添加组织[" + orgVo.getName() + "]失败，本系统无默认维度"); } else { orgVo.setDemId(defaultDem.getId()); } } else { Demension dem = demensionService.get(orgVo.getDemId()); if (BeanUtils.isEmpty(dem)) { throw new RuntimeException("添加组织[" + orgVo.getName() + "]失败，根据输入的demId[" + orgVo.getDemId() + "]没有找到对应的维度信息！"); } } Org o = this.getByCode(orgVo.getCode()); if (BeanUtils.isNotEmpty(o)) { throw new RuntimeException("添加组织[" + orgVo.getName() + "]失败，组织编码[" + orgVo.getCode() + "]已存在！"); } Org pOrg = null; if (!"0".equals(orgVo.getParentId()) && BeanUtils.isNotEmpty(orgVo.getParentId())) { pOrg = this.get(orgVo.getParentId()); if (BeanUtils.isEmpty(pOrg)) { throw new RuntimeException("添加组织[" + orgVo.getName() + "]失败，根据输入的parentId[" + orgVo.getParentId() + "]没有找到对应的组织信息！"); } if (BeanUtils.isEmpty(pOrg) && !pOrg.getDemId().equals(orgVo.getDemId())) { throw new RuntimeException("添加组织[" + orgVo.getName() + "]失败，根据输入demId与所输入的父组织所对应的维度id不一致！"); } } o = new Org(); o.setId(orgVo.getId()); o.setCode(orgVo.getCode()); o.setName(orgVo.getName()); o.setDemId(orgVo.getDemId()); o.setOrderNo(orgVo.getOrderNo()); if (StringUtils.isEmpty(orgVo.getParentId())) { o.setParentId("0"); } else { o.setParentId(orgVo.getParentId()); } if (BeanUtils.isEmpty(pOrg)) { o.setPathName("/" + orgVo.getName()); o.setPath(orgVo.getDemId() + "." + o.getId() + "."); } else { o.setPath(pOrg.getPath() + o.getId() + "."); o.setPathName(pOrg.getPathName() + "/" + orgVo.getName()); } this.create(o); return new CommonResult(true, "添加组织成功！", ""); } @Override public List getOrgsByparentId(String parentId) { return baseMapper.getByParentId(parentId); } @Override @Transactional public Integer removePhysical() { return baseMapper.removePhysical(); } @Override public Org get(Serializable id) { return baseMapper.get(id); } @Override public List getSubOrgByIds(Set parentIds) { if (parentIds.isEmpty()) { return new ArrayList<>(); } return baseMapper.getSubOrgByIds(parentIds); } @Override public List> getOrgIdMapByUserId(String userId) { return baseMapper.getOrgIdMapByUserId(userId); } @Override public CommonResult getFillOrg(String demId, String grade) { String userId = ContextUtil.getCurrentUserId(); Org curOrg = this.getMainGroup(userId, demId); Org gradeOrg = null; if (BeanUtils.isNotEmpty(curOrg)) { if (grade.equals(curOrg.getGrade())) { gradeOrg = curOrg; } else { gradeOrg = getPOrgByGread(curOrg.getParentId(), grade); } } else { return new CommonResult<>(false, "获取当前用户所属主组织失败！"); } if (BeanUtils.isEmpty(gradeOrg)) { return new CommonResult<>(false, "未获取到当前用户填制单位！"); } return new CommonResult<>(true, "获取成功！", gradeOrg); } private Org getPOrgByGread(String orgId, String grade) { Org org = this.get(orgId); if (BeanUtils.isNotEmpty(org) && !grade.equals(org.getGrade())) { return getPOrgByGread(org.getParentId(), grade); } return org; } @Override public Map getParentMainOrg(String userId) { Map map = new HashMap<>(); Org org = getMainGroup(userId, ""); if (BeanUtils.isNotEmpty(org)) { String path = org.getPath(); List ids = Arrays.asList(path.split("\\.")).stream().map(s -> (s.trim())).collect(Collectors.toList()); List list = baseMapper.selectList(new QueryWrapper().in("ID_", ids)); if (BeanUtils.isNotEmpty(list)) { list.forEach(item -> { map.put(item.getGrade(), item); }); } } return map; } @Override public OrgParams getParamById(String orgId, String alias) { return orgParamsService.getByOrgIdAndAlias(orgId, alias); } @Override public boolean isOrgHasParamKey(String orgId, String alias) { OrgParams byOrgIdAndAlias = orgParamsDao.getByOrgIdAndAlias(orgId, alias); if (BeanUtils.isEmpty(byOrgIdAndAlias)) { return false; } else { return true; } } @Override public boolean hasOrgParamKey(String grade, String userId, String alias) throws Exception { Map map = this.getParentMainOrg(userId); if (map.containsKey(grade)) { OrgParams p = orgParamsService.getByOrgIdAndAlias(map.get(grade).getId(), alias); if (BeanUtils.isNotEmpty(p)) { return true; } } return false; } @Override public List getOrgListByCodes(List list) { return baseMapper.getOrgListByCodes(list); } @Override public List getByPathNames(List pathNames) { return baseMapper.getPathNameList(pathNames); } @Override public boolean insertBatch(List list) { return this.saveBatch(list); } /** * 通过用户ID获取所有父组织 */ @Override public List getParantMainOrgAll(String userId) throws IOException { String orgStr = orgUserService.getCacheByKeyOrgPost(userId); Org org = null; if (StringUtil.isNotEmpty(orgStr)) { Map stringObjectMap = JsonUtil.toMap(orgStr); Map postMap = (Map) stringObjectMap.get("postCharge"); if (BeanUtils.isNotEmpty(postMap)) { org = this.getByCode(postMap.get("orgcode").toString()); } } else { org = getMainGroup(userId, ""); } if (BeanUtils.isNotEmpty(org)) { String path = org.getPath(); List ids = Arrays.asList(path.split("\\.")).stream().map(s -> (s.trim())).collect(Collectors.toList()); List list = baseMapper.selectList(new QueryWrapper().in("ID_", ids)); return list; } else { return new ArrayList<>(); } } @Override public List getOrgByAccount(String code) { QueryWrapper orgQueryWrapper = new QueryWrapper<>(); String[] split = code.split(","); List strings = Arrays.asList(split); orgQueryWrapper.in(strings.size() > 0, "code_", strings); return this.baseMapper.selectList(orgQueryWrapper); } @Override public CommonResult saveOrgPosition(OrgPositionVo orgPositionVo) { Assert.hasText(orgPositionVo.getOrgId(), "请选择组织"); Assert.hasText(orgPositionVo.getPostionIds(), "请选择要关联的岗位"); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("org_id_", orgPositionVo.getOrgId()); orgPositionDao.delete(queryWrapper); String[] split = orgPositionVo.getPostionIds().split(","); for(String positionId : split) { UcOrgPosition rel = new UcOrgPosition(); rel.setOrgId(orgPositionVo.getOrgId()); rel.setPosId(positionId); orgPositionDao.insert(rel); } return new CommonResult(true, "添加岗位成功！", ""); } @Override public List getPositionTree() { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("IS_DELE_", DelStatusEnum.N.getType()); List orgs = this.baseMapper.selectList(queryWrapper); List treeList = Lists.newArrayList(); orgs.forEach(org -> { OrgPositionTreeVo orgTree = new OrgPositionTreeVo(); orgTree.setName(org.getName()); orgTree.setParentId(org.getParentId()); orgTree.setId(org.getId()); orgTree.setType("1"); treeList.add(orgTree); }); List list = this.baseMapper.getExamSysInfo(); list.forEach(json -> { if(!StringUtil.isNotEmpty(json.getString("parentid"))){ return; } OrgPositionTreeVo orgTree = new OrgPositionTreeVo(); orgTree.setName(json.getString("name_")); orgTree.setParentId(json.getString("parentid")); orgTree.setId(json.getString("id")); treeList.add(orgTree); }); QueryWrapper query = new QueryWrapper<>(); query.eq("IS_DELE_", DelStatusEnum.N.getType()); List posts = orgPostDao.getPositions(); posts.forEach(post -> { OrgPositionTreeVo orgTree = new OrgPositionTreeVo(); orgTree.setName(post.getString("name")); if(StringUtil.isNotEmpty(post.getString("sysid"))){ orgTree.setParentId(post.getString("sysid")); }else{ orgTree.setParentId(post.getString("orgid")); } orgTree.setId(post.getString("id")); orgTree.setType("2"); treeList.add(orgTree); }); return BeanUtils.listToTree(treeList); } @Override @Transactional public CommonResult addOrgPostFromExterUni(OrgPost orgPostVo) throws Exception { if (StringUtil.isEmpty(orgPostVo.getCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位代码code必填！"); } if (orgPostVo.getCode().contains(",")) { throw new RuntimeException("添加岗位失败，岗位编码不允许含英文逗号‘,’"); } if (StringUtil.isEmpty(orgPostVo.getName())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "岗位名称name必填！"); } if (StringUtil.isEmpty(orgPostVo.getJobCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "职务代码jobCode必填！"); } if (StringUtil.isEmpty(orgPostVo.getOrgCode())) { throw new RuntimeException(HotentHttpStatus.REUIRED.description() + "组织代码orgCode必填！"); } Org o = this.getByCode(orgPostVo.getOrgCode()); if (BeanUtils.isEmpty(o)) { throw new RuntimeException("根据输入的组织代码没有找到对应的组织信息！"); } OrgJob job = orgJobService.getByCode(orgPostVo.getJobCode()); if (BeanUtils.isEmpty(job)) { throw new RuntimeException("根据输入的职务编码没有找到对应的职务信息！"); } if (orgPostService.getCountByCode(orgPostVo.getCode()) > 0) { throw new RuntimeException("岗位编码【" + orgPostVo.getCode() + "】已经存在系统中！"); } OrgPost rel = new OrgPost(); if (BeanUtils.isEmpty(orgPostVo.getId())) { rel.setId(UniqueIdUtil.getSuid()); } else { if (BeanUtils.isNotEmpty(orgPostService.get(orgPostVo.getId()))) { throw new RuntimeException("添加岗位【" + orgPostVo.getName() + "】失败，岗位ID【" + orgPostVo.getId() + "】已经存在系统中！"); } rel.setId(orgPostVo.getId()); } rel.setName(orgPostVo.getName()); rel.setCode(orgPostVo.getCode()); rel.setRelDefId(job.getId()); rel.setOrgId(o.getId()); rel.setIsCharge(orgPostVo.getIsCharge()); if (orgPostVo.getIsCharge() == 1) { List l = orgPostService.getRelCharge(o.getId(), true); if (BeanUtils.isNotEmpty(l)) { OrgPost p = l.get(0); p.setIsCharge(0); orgPostService.update(p); } } orgPostService.create(rel); return new CommonResult(true, "添加岗位成功！", ""); } @Override public List getOrgTreeVoList(String demCode, String pOrgCode, String orgKind) { Demension d = demensionService.getByCode(demCode); if (BeanUtils.isEmpty(d)) { throw new RuntimeException("根据输入的demCode没有找到对应的维度"); } return this.baseMapper.getOrgTreeVoList(d.getId(), pOrgCode, orgKind); } }