package com.artfess.uc.manager.impl;
import com.artfess.base.cache.annotation.CacheEvict;
import com.artfess.base.constants.CacheKeyConst;
import com.artfess.base.constants.SystemConstants;
import com.artfess.base.exception.SystemException;
import com.artfess.base.feign.SystemConfigFeignService;
import com.artfess.base.jwt.JwtTokenHandler;
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.PageList;
import com.artfess.base.query.QueryFilter;
import com.artfess.base.query.QueryOP;
import com.artfess.base.util.AppUtil;
import com.artfess.base.util.AuthenticationUtil;
import com.artfess.base.util.BeanUtils;
import com.artfess.base.util.FileUtil;
import com.artfess.base.util.IPUtils;
import com.artfess.base.util.JsonUtil;
import com.artfess.base.util.MapUtil;
import com.artfess.base.util.PinyinUtil;
import com.artfess.base.util.StringUtil;
import com.artfess.base.util.ThreadMsgUtil;
import com.artfess.base.util.UniqueIdUtil;
import com.artfess.base.util.ZipUtil;
import com.artfess.base.util.string.StringPool;
import com.artfess.base.util.time.DateFormatUtil;
import com.artfess.poi.util.ExcelUtil;
import com.artfess.security.model.SysAuthorization;
import com.artfess.security.util.AuthorCheck;
import com.artfess.uc.api.constant.GroupTypeConstant;
import com.artfess.uc.api.model.Group;
import com.artfess.uc.api.model.IGroup;
import com.artfess.uc.api.model.IUser;
import com.artfess.uc.dao.PropertiesDao;
import com.artfess.uc.dao.UserDao;
import com.artfess.uc.dao.UserParamsDao;
import com.artfess.uc.exception.BaseException;
import com.artfess.uc.exception.HotentHttpStatus;
import com.artfess.uc.exception.NotFoundException;
import com.artfess.uc.exception.RequiredException;
import com.artfess.uc.manager.DemensionManager;
import com.artfess.uc.manager.OperateLogManager;
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.OrgUserManager;
import com.artfess.uc.manager.ParamsManager;
import com.artfess.uc.manager.PropertiesService;
import com.artfess.uc.manager.PwdStrategyManager;
import com.artfess.uc.manager.RoleManager;
import com.artfess.uc.manager.TenantAuthManager;
import com.artfess.uc.manager.UserGroupManager;
import com.artfess.uc.manager.UserManager;
import com.artfess.uc.manager.UserParamsManager;
import com.artfess.uc.manager.UserRelManager;
import com.artfess.uc.manager.UserRoleManager;
import com.artfess.uc.model.Demension;
import com.artfess.uc.model.Org;
import com.artfess.uc.model.OrgJob;
import com.artfess.uc.model.OrgParams;
import com.artfess.uc.model.OrgPost;
import com.artfess.uc.model.OrgUser;
import com.artfess.uc.model.Params;
import com.artfess.uc.model.Properties;
import com.artfess.uc.model.PwdStrategy;
import com.artfess.uc.model.Role;
import com.artfess.uc.model.User;
import com.artfess.uc.model.UserGroup;
import com.artfess.uc.model.UserParams;
import com.artfess.uc.model.UserRel;
import com.artfess.uc.model.UserRole;
import com.artfess.uc.params.common.DataSyncObject;
import com.artfess.uc.params.common.DataSyncVo;
import com.artfess.uc.params.common.OrgExportObject;
import com.artfess.uc.params.common.UserExportObject;
import com.artfess.uc.params.echarts.ChartLink;
import com.artfess.uc.params.echarts.ChartNode;
import com.artfess.uc.params.echarts.ChartOption;
import com.artfess.uc.params.group.GroupIdentity;
import com.artfess.uc.params.params.ParamObject;
import com.artfess.uc.params.user.TriggerVo;
import com.artfess.uc.params.user.UserMarkObject;
import com.artfess.uc.params.user.UserPolymer;
import com.artfess.uc.params.user.UserPolymerOrgPos;
import com.artfess.uc.params.user.UserPolymerRole;
import com.artfess.uc.params.user.UserPwdObject;
import com.artfess.uc.params.user.UserRelObject;
import com.artfess.uc.params.user.UserStatusVo;
import com.artfess.uc.params.user.UserVo;
import com.artfess.uc.util.OrgUtil;
import com.artfess.uc.util.UserPhotoFileFindVisitor;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.formula.functions.T;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.Field;
import java.lang.reflect.ParameterizedType;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.sql.SQLException;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
/**
*
* 描述：用户表 处理实现类
* 构建组：x5-bpmx-platform
* 作者:ray
* 邮箱:zhangyg@jee-soft.cn
* 日期:2016-06-30 10:26:50
* 版权：广州宏天软件有限公司
*
*/
@Service
public class UserManagerImpl extends BaseManagerImpl implements UserManager {
protected static Logger logger = LoggerFactory.getLogger(UserManagerImpl.class);
//导入数据code重复时给code加的后缀
protected static String IMPORT_NEW_SUFFIX = "_imp";
@Autowired
ResourceLoader resourceLoader;
@Value("${system.attachment.path:''}")
private String attachPath;
@Autowired
UserRoleManager userRoleManager;
@Autowired
OrgUserManager orgUserManager;
@Autowired
UserParamsDao userParamsDao;
@Autowired
OrgManager orgService;
@Autowired
OrgPostManager orgPostService;
@Autowired
OrgJobManager orgJobService;
@Autowired
OrgPostManager orgPostManager;
@Autowired
DemensionManager demensionService;
@Autowired
OrgUserManager orgUserService;
@Autowired
PropertiesService propertiesService;
@Autowired
UserRoleManager userRoleService;
@Autowired
UserParamsManager userParamsService;
@Autowired
UserGroupManager userGroupService;
@Autowired
RoleManager roleService;
@Autowired
OrgAuthManager orgAuthService;
@Autowired
ParamsManager paramsService;
@Autowired
UserRelManager userRelService;
@Autowired
OrgManager orgManager;
@Autowired
DemensionManager demensionManager;
@Autowired
OrgJobManager orgJobManager;
@Autowired
RoleManager roleManager;
@Autowired
OperateLogManager operateLogService;
@Autowired
PropertiesDao propertiesDao;
@Autowired
PasswordEncoder passwordEncoder;
@Autowired
SystemConfigFeignService portalFeignService;
@Autowired
JwtTokenHandler jwtTokenHandler;
@Autowired
UserDetailsService userDetailsService;
@Autowired
PwdStrategyManager pwdStrategyManager;
@Autowired
OrgParamsManager orgParamsService;
@Autowired
private AuthorCheck authorCheck;
@Override
@Transactional
public User addUser(UserVo user) throws Exception {
if (StringUtil.isEmpty(user.getAccount())) {
throw new RequiredException("添加用户失败，用户帐号【account】必填！");
}
if (StringUtil.isEmpty(user.getFullname())) {
throw new RequiredException("添加用户失败，用户名称【fullname】必填！");
}
if (StringUtil.isEmpty(user.getPassword())) {
throw new RequiredException("添加用户失败，登录密码【password】必填！");
}
if (baseMapper.getCountByAccount(user.getAccount()) > 0) {
throw new RuntimeException("添加用户失败，帐号【" + user.getAccount() + "】已存在，请重新输入！");
}
User u = this.getByNumber(user.getUserNumber());
if (BeanUtils.isNotEmpty(u)) {
throw new RuntimeException("添加用户失败，工号【" + user.getUserNumber() + "】已存在，请重新输入！");
}
if (StringUtil.isNotEmpty(user.getMobile())) {
u = this.getByMobile(user.getMobile());
if (BeanUtils.isNotEmpty(u)) {
throw new RuntimeException("添加用户失败，手机号【" + user.getMobile() + "】已存在，请重新输入！");
}
}
if (!checkEmail(user.getEmail()) && !StringUtil.isEmpty(user.getEmail())) {
throw new RuntimeException("添加用户失败，邮箱格式不正确！");
}
//Todo 等要验证版本权限时候开放
/* SysAuthorization resultCode = authorCheck.redFileToObject();
if(resultCode==null){
throw new RuntimeException("添加用户失败，没找到系统的授权信息！");
}
int userNum = Integer.valueOf(resultCode.getUserNum());
JdbcTemplate jdbcTemplate = AppUtil.getBean(JdbcTemplate.class);
String sql = "select count(*) from uc_user where IS_DELE_!= '1' ";
int num = jdbcTemplate.queryForObject(sql, Integer.class);
if(num >= userNum){
throw new RuntimeException("添加用户失败，添加的用户数量已等于授权的数量【"+userNum+"】了！");
}*/
User newUser = UserVo.parser(user);
newUser.setStatus(User.STATUS_NORMAL);
if (BeanUtils.isEmpty(user.getId())) {
newUser.setId(UniqueIdUtil.getSuid());
} else {
if (this.getUserById(user.getId()).getState()) {
throw new RuntimeException("添加用户失败，用户ID【" + user.getId() + "】已存在，请重新输入！");
}
newUser.setId(user.getId());
}
newUser.setCreateTime(LocalDateTime.now());
newUser.setFrom(User.FROM_RESTFUL);
String password = user.getPassword();
if (StringUtil.isEmpty(user.getPassword())) {
password = pwdStrategyManager.getDefault().getInitPwd();
}
newUser.setPassword(passwordEncoder.encode(password));
newUser.setPwdCreateTime(LocalDateTime.now());
Integer status = BeanUtils.isNotEmpty(user.getStatus()) ? user.getStatus() : 1;
if (status != 1 && status != -1 && status != -2 && status != 0) {
status = 1;
}
newUser.setStatus(status);
newUser.setLockedStatus(1);
try {
this.create(newUser);
//将用户加入一般用户角色中
Role role = roleManager.getByAlias("ybyh");
String roleId = "1";
if (BeanUtils.isNotEmpty(role)) {
roleId = role.getId();
}
UserRole userRole = new UserRole();
userRole.setId(UniqueIdUtil.getSuid());
userRole.setRoleId(roleId);
userRole.setUserId(newUser.getId());
userRoleManager.save(userRole);
} catch (Exception e) {
throw new RuntimeException(e.getMessage());
}
return newUser;
}
@Override
@Transactional
public User updateUser(UserVo user) throws Exception {
// if(demoMode) {
// throw new ServerRejectException("演示模式下无法执行该操作");
// }
if (StringUtil.isEmpty(user.getAccount())) {
throw new RequiredException("更新用户失败，用户帐号【account】必填！");
}
User u = this.getByAccount(user.getAccount());
if (BeanUtils.isEmpty(u)) {
throw new RuntimeException("更新用户失败，根据【" + user.getAccount() + "】没有找到对应的用户信息！");
}
if (StringUtil.isNotEmpty(user.getUserNumber())) {
if (!user.getUserNumber().equals(u.getUserNumber())
&& BeanUtils.isEmpty(this.getByNumber(user.getUserNumber()))) {
u.setUserNumber(user.getUserNumber());
} else if (!user.getUserNumber().equals(u.getUserNumber())
&& BeanUtils.isNotEmpty(this.getByNumber(user.getUserNumber()))) {
throw new RuntimeException("更新用户失败，工号【" + user.getUserNumber() + "】在系统中已存在，不能重复！");
}
}
/* if(StringUtil.isNotEmpty(user.getMobile())){
u = this.getByMobile(user.getMobile());
if(BeanUtils.isNotEmpty(u) && !u.getAccount().equals(user.getAccount())){
throw new RuntimeException("更新用户失败，账号为【"+u.getAccount()+"】的手机号【"+user.getMobile()+"】已存在，请重新输入！");
}else{
u = this.getByAccount(user.getAccount());
}
}*/
if (StringUtil.isNotEmpty(user.getBirthday())) {
u.setBirthday(DateFormatUtil.dateParse(user.getBirthday(), StringPool.DATE_FORMAT_DATE));
} else {
u.setBirthday(null);
}
if (StringUtil.isNotEmpty(user.getEntryDate())) {
u.setEntryDate(DateFormatUtil.dateParse(user.getEntryDate(), StringPool.DATE_FORMAT_DATE));
} else {
u.setEntryDate(null);
}
//下列字段信息，为空也要设置到最新数据中
u.setAddress(user.getAddress());
//邮箱转为小写
if (StringUtil.isNotEmpty(user.getEmail())) {
u.setEmail(user.getEmail().toLowerCase());
} else {
u.setEmail(user.getEmail());
}
u.setPhoto(user.getPhoto());
u.setFullname(user.getFullname());
u.setSex(user.getSex());
u.setMobile(user.getMobile());
u.setStatus(user.getStatus());
u.setIdCard(user.getIdCard());
u.setPhone(user.getPhone());
u.setPhoto(user.getPhoto());
u.setEducation(user.getEducation());
u.setLeaveDate(user.getLeaveDate());
u.setUserType(user.getUserType());
this.update(u);
// if(User.HASSYNCTOWX_YEX == u.getHasSyncToWx() && (0 == u.getStatus() || -2 == u.getStatus())) {
// wxUserService.upStatus(u,"0");
// }else if(User.HASSYNCTOWX_YEX == u.getHasSyncToWx() && 1 == u.getStatus()) {
// wxUserService.upStatus(u,"1");
// }
return u;
}
@Override
public void updateUserIP() throws Exception {
String account = AuthenticationUtil.getCurrentUsername();
User u = this.getByAccount(account);
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
.getRequest();
String ip = IPUtils.getIpAddr(request);
u.setIP(ip);
this.update(u);
}
@Override
public void updateUserSkin(String skin) throws Exception {
String account = AuthenticationUtil.getCurrentUsername();
User u = this.getByAccount(account);
u.setSkin(skin);
this.update(u);
}
@Override
@Transactional
public CommonResult deleteUser(UserMarkObject userMark) {
// if(demoMode) {
// throw new ServerRejectException("演示模式下无法执行该操作");
// }
StringBuilder msg = new StringBuilder();
boolean isTrue = false;
if (StringUtil.isNotEmpty(userMark.getAccount())) {
String[] accounts = userMark.getAccount().split(",");
for (String account : accounts) {
User user = baseMapper.getByAccount(account);
if (BeanUtils.isNotEmpty(user)) {
if (OrgUtil.checkUserGruopIsUserRel("user", user.getId())) {
msg.append("帐号【" + account + "】的用户为汇报节点不能删除，");
} else {
this.remove(user.getId());
isTrue = true;
}
} else {
msg.append("帐号【" + account + "】不存在，");
}
}
} else {
if (StringUtil.isNotEmpty(userMark.getUserNumber())) {
String[] numbers = userMark.getUserNumber().split(",");
for (String number : numbers) {
User user = baseMapper.getByNumber(number);
if (BeanUtils.isNotEmpty(user)) {
if (OrgUtil.checkUserGruopIsUserRel("user", user.getId())) {
msg.append("工号【" + number + "】的用户为汇报节点不能删除，");
} else {
this.remove(user.getId());
isTrue = true;
}
} else {
msg.append("工号【" + number + "】不存在，");
}
}
}
}
if (StringUtil.isEmpty(userMark.getAccount()) && StringUtil.isEmpty(userMark.getUserNumber())) {
isTrue = false;
msg.append("用户帐号和工号至少输入一个，不能同时为空！");
}
return new CommonResult(isTrue, BeanUtils.isEmpty(msg) ? "删除用户成功！" : msg.toString(), "");
}
@Override
@Transactional
public CommonResult deleteUserByIds(String ids) {
// if(demoMode) {
// throw new ServerRejectException("演示模式下无法执行该操作");
// }
String[] idArray = ids.split(",");
StringBuilder msg = new StringBuilder();
boolean isTrue = true;
for (String id : idArray) {
User user = this.get(id);
if (BeanUtils.isNotEmpty(user)) {
if (user.isAdmin()) {
throw new RuntimeException("管理员用户不能删除!");
}
this.remove(user.getId());
// if(User.HASSYNCTOWX_YEX == user.getHasSyncToWx()) {
// wxUserService.upStatus(user,"0");
// }
//删除租户管理员
TenantAuthManager tenantAuthManager = AppUtil.getBean(TenantAuthManager.class);
tenantAuthManager.delByUserId(user.getUserId());
} else {
isTrue = false;
msg.append("帐号【" + id + "】不存在，");
}
}
return new CommonResult(isTrue, BeanUtils.isEmpty(msg) ? "删除用户成功！" : msg.toString(), "");
}
@Override
public UserVo getUser(String json) throws Exception {
User user = getUserByJson(json);
if (BeanUtils.isEmpty(user)) {
return null;
}
UserVo userVo = OrgUtil.convertToUserVo(user);
List params = this.getUserParams(user.getAccount());
if (BeanUtils.isNotEmpty(params)) {
Map map = new HashMap();
for (UserParams param : params) {
map.put(param.getAlias(), param.getValue());
}
userVo.setParams(map);
}
return userVo;
}
public User getByAccount(String account) {
return baseMapper.getByAccount(account);
}
public User getByMobile(String mobile) {
return baseMapper.getByMobile(mobile);
}
/**
* 不含组织用户关系数据
*/
public List queryOrgUser(QueryFilter queryFilter) {
queryFilter.addFilter("org.IS_DELE_", User.DELETE_YES, QueryOP.NOT_EQUAL);
queryFilter.addFilter("u.IS_DELE_", User.DELETE_YES, QueryOP.NOT_EQUAL);
Map params = queryFilter.getParams();
if (BeanUtils.isNotEmpty(params.get("orgId"))) {
queryFilter.addFilter("org.ID_", params.get("orgId"), QueryOP.EQUAL);
}
return baseMapper.queryOrgUser(convert2Wrapper(queryFilter, currentModelClass()));
}
/**
* 不含组织用户关系数据
*/
public List getUserListByOrgId(String orgId) {
return baseMapper.getUserListByOrgId(orgId);
}
/**
* 含组织用户关系数据
*/
@SuppressWarnings("rawtypes")
public List queryOrgUserRel(QueryFilter queryFilter) {
queryFilter.addFilter("orguser.IS_DELE_", User.DELETE_YES, QueryOP.NOT_EQUAL);
queryFilter.addFilter("org.IS_DELE_", User.DELETE_YES, QueryOP.NOT_EQUAL);
return baseMapper.queryOrgUserRel(convert2Wrapper(queryFilter, currentModelClass()));
}
public List getListByPostCode(String postCode) {
return baseMapper.getListByPostCode(postCode);
}
public List getListByPostId(String postId) {
return baseMapper.getListByPostId(postId);
}
public List getUserListByRoleId(String roleId) {
return baseMapper.getUserListByRoleId(roleId);
}
public List getUserListByRoleCode(String roleCode) {
return baseMapper.getUserListByRoleCode(roleCode);
}
@Override
@Transactional
public void removeByIds(String... ids) {
User user = baseMapper.getByAccount(SystemConstants.SYSTEM_ACCOUNT);
for (String id : ids) {
if (id.equals(user.getUserId())) {
ThreadMsgUtil.addMsg(ids.length >= 2 ? "admin帐号不能删除,其它用户删除成功。" : "admin帐号不能删除");
break;
}
}
if (StringUtil.isEmpty(ThreadMsgUtil.getMessage(false))) {
ThreadMsgUtil.addMsg("用户删除成功。");
}
super.removeByIds(ids);
UserManagerImpl bean = AppUtil.getBean(getClass());
for (String id : ids) {
orgUserManager.removeByUserId(id, LocalDateTime.now());
userRoleManager.removeByUserId(id, LocalDateTime.now());
userParamsDao.removeByUserId(id, LocalDateTime.now());
bean.delUserMenuCache(id);
}
}
@CacheEvict(value = CacheKeyConst.EIP_SYS_USERMENU, key = "#userId")
protected void delUserMenuCache(String userId) {
}
@Override
public List getByUserEmail(String email) {
return baseMapper.getByUserEmail(email);
}
/**
* 添加需要新增的组织
*
* @param org
* @param orgList
* @return
*/
public Org dealOrg(Org org, List orgList, String preCode, Map orgMap) {
Org rtn = null;
if (BeanUtils.isEmpty(orgList)) {
if (BeanUtils.isNotEmpty(orgMap.get(org.getCode()))) {
org.setCode(org.getCode() + "_" + org.getId().substring(org.getId().length() - 3));
}
orgList.add(org);
orgMap.put(org.getCode(), org.getId());
rtn = org;
} else {
Boolean flag = true;
for (int i = 0; i < orgList.size(); i++) {
if (orgList.get(i).getPathName().equals(org.getPathName())) {
flag = false;
rtn = orgList.get(i);
}
if (orgList.get(i).getName().equals(org.getName()) && orgList.get(i) != org) {//新增数据中，组织同名的情况
org.setCode(preCode + "_" + PinyinUtil.getPinYinHeadChar(org.getName()) + (i + 1));
}
Org systemOrg = orgService.getByCode(org.getCode());//判断是否与数据库中组织代码重复
if (BeanUtils.isNotEmpty(systemOrg)) {
org.setCode(preCode + "_" + PinyinUtil.getPinYinHeadChar(org.getName()) + (i + 1) + (i + 1));
}
if (i == (orgList.size() - 1) && flag) {
if (BeanUtils.isNotEmpty(orgMap.get(org.getCode()))) {
org.setCode(org.getCode() + "_" + org.getId().substring(org.getId().length() - 3));
}
orgList.add(org);
orgMap.put(org.getCode(), org.getId());
rtn = org;
}
}
}
return rtn;
}
/**
* 处理组织的上下级关系
*
* @param supperPathName 父级路径名
* @param underPathName 子级路径名
* @param demId 对应维度id
* @param orgList
* @return
*/
public Org dealOrgUnder(String supperPathName, String underPathName, List orgList, String demId, String preCode, Map orgMap) {
String underName = underPathName.substring(underPathName.lastIndexOf("/") + 1, underPathName.length());
List chirList = orgService.getByPathName(underPathName);
if (BeanUtils.isNotEmpty(chirList)) {//子组织不为空
for (Org org : chirList) {
if (demId.equals(org.getDemId())) {
return org;
}
}
}
//子组织为空的情况
List pList = orgService.getByPathName(supperPathName);
List parentList = new ArrayList();
for (Org org : pList) {
if (demId.equals(org.getDemId())) {
parentList.add(org);
}
}
Org chird = new Org();
if (BeanUtils.isEmpty(parentList)) {//父组织为空，直接从orgList中寻找父级组织
for (int i = 0; i < orgList.size(); i++) {
if (orgList.get(i).getPathName().equals(supperPathName)) {
chird.setId(UniqueIdUtil.getSuid());
chird.setParentId(orgList.get(i).getId());
chird.setDemId(demId);
chird.setName(underName);
chird.setPathName(underPathName);
chird.setPath(orgList.get(i).getPath() + chird.getId() + ".");
chird.setCode(preCode + "_" + PinyinUtil.getPinYinHeadChar(underName));
//chird.setOrgType("实体");
}
}
} else {//父组织不为空，从数据库中拿父组织
chird.setId(UniqueIdUtil.getSuid());
chird.setParentId(parentList.get(0).getId());
chird.setDemId(demId);
chird.setName(underName);
chird.setCode(preCode + "_" + PinyinUtil.getPinYinHeadChar(underName));
chird.setPathName(underPathName);
chird.setPath(parentList.get(0).getPath() + chird.getId() + ".");
//chird.setOrgType("实体");
}
return dealOrg(chird, orgList, preCode, orgMap);
}
/**
* 处理excel中的职务
*
* @param reldefNameStr 职务名称
* @param orgJobList 新增职务列表
* @return
*/
public List dealOrgJob(String reldefNameStr, List orgJobList, String preCode) {
if (StringUtil.isEmpty(reldefNameStr)) return null;
String[] reldefNames = reldefNameStr.split(";");
List rtn = new ArrayList();
for (String reldefName : reldefNames) {
OrgJob reldef = null;
List selectList = orgJobService.getByName(reldefName);
if (BeanUtils.isNotEmpty(selectList)) {
reldef = selectList.get(0);
} else {
Boolean flag = true;
reldef = new OrgJob();
reldef.setId(UniqueIdUtil.getSuid());
reldef.setCode(PinyinUtil.getPinYinHeadChar(reldefName));
reldef.setName(reldefName);
OrgJob sysOrgJob = orgJobService.getByCode(reldef.getCode());
if (BeanUtils.isNotEmpty(sysOrgJob)) {
reldef.setCode(reldef.getCode() + reldef.getId());
}
if (BeanUtils.isEmpty(orgJobList)) {
orgJobList.add(reldef);
} else {
for (int i = 0; i < orgJobList.size(); i++) {
if (orgJobList.get(i).getName().equals(reldefName)) {
flag = false;
reldef = orgJobList.get(i);
}
if (i == (orgJobList.size() - 1) && flag) {
//新增
orgJobList.add(reldef);
}
}
}
}
if (BeanUtils.isNotEmpty(reldef)) {
rtn.add(reldef);
}
}
return rtn;
}
/**
* 处理新增用户列表
*
* @param user
* @param userList
* @return
*/
public User dealUser(User user, List userList) throws Exception {
User rtn = new User();
if (StringUtil.isNotEmpty(user.getId())) {
rtn = user;
} else {
Boolean flag = true;
if (BeanUtils.isEmpty(userList)) {
user.setId(UniqueIdUtil.getSuid());
rtn = user;
userList.add(user);
} else {
for (int i = 0; i < userList.size(); i++) {
if (userList.get(i).getAccount().equals(user.getAccount()) && userList.get(i) != user) {
logger.error("Excel表格中用户帐号重复：" + userList.get(i).getAccount());
}
if (userList.get(i).getAccount().equals(user.getAccount()) && userList.get(i) == user) {
flag = false;
rtn = userList.get(i);
}
if (i == (userList.size() - 1) && flag) {
user.setId(UniqueIdUtil.getSuid());
rtn = user;
userList.add(user);
}
}
}
}
return rtn;
}
/**
* 处理用、组织、岗位关系
*
* @param user
* @param org
* @param orgPosts
* @param isMaster
* @param isCharge
* @param orgUserList
* @param orgPostList
*/
public void dealUserOrgPost(User user, Org org, List orgPosts, List orgUserList, List orgPostList, Map orgPostAddMap,
String isMaster, String isCharge, Map isMasterMap, String demId) {
if (BeanUtils.isEmpty(org)) return;
if (BeanUtils.isNotEmpty(orgPosts)) {
for (OrgPost orgPost : orgPosts) {
OrgUser orgUser = new OrgUser();
if (StringUtil.isNotEmpty(orgPostAddMap.get(orgPost.getId()))) {//在数据库中没有存在，考虑是否加入新增岗位列表中
Boolean flag = true;
if (BeanUtils.isEmpty(orgPostList)) {//新增岗位列表
orgPost.setCode(org.getCode() + "_" + orgPost.getCode());
orgPostList.add(orgPost);
} else {
for (int i = 0; i < orgPostList.size(); i++) {
if (orgPostList.get(i).getOrgId().equals(orgPost.getOrgId()) && orgPostList.get(i).getName().equals(orgPost.getName())) {
orgPost = orgPostList.get(i);
flag = false;
}
if (flag && i == (orgPostList.size() - 1)) {
orgPost.setCode(org.getCode() + "_" + orgPost.getCode());
orgPostList.add(orgPost);
}
}
}
}
QueryFilter filter = QueryFilter.build();
filter.addFilter("orgId", orgPost.getOrgId(), QueryOP.EQUAL, FieldRelation.AND);
filter.addFilter("userId", user.getId(), QueryOP.EQUAL, FieldRelation.AND);
filter.addFilter("relId", orgPost.getId(), QueryOP.EQUAL, FieldRelation.AND);
PageList pageList = orgUserService.query(filter);
if (BeanUtils.isEmpty(pageList.getRows())) {//不存在则添加组织用户关系
orgUser.setId(UniqueIdUtil.getSuid());
orgUser.setOrgId(orgPost.getOrgId());//组织id
orgUser.setRelId(orgPost.getId());//岗位编号
orgUser.setUserId(user.getId());
dealMasterAndCharge(isMaster, isCharge, orgUser, isMasterMap, demId);
orgUserList.add(orgUser);
}
}
} else {
OrgUser orgUser = new OrgUser();
QueryFilter filter = QueryFilter.build();
filter.addFilter("userId", user.getId(), QueryOP.EQUAL, FieldRelation.AND);
PageList pageList = orgUserService.query(filter);
if (BeanUtils.isEmpty(pageList.getRows())) {//不存在则添加组织用户关系
orgUser.setId(UniqueIdUtil.getSuid());
orgUser.setOrgId(org.getId());//组织id
orgUser.setUserId(user.getId());
dealMasterAndCharge(isMaster, isCharge, orgUser, isMasterMap, demId);
orgUserList.add(orgUser);
}
}
}
/**
* 处理负责人和主组织
*/
private void dealMasterAndCharge(String isMaster, String isCharge, OrgUser orgUser, Map isMasterMap, String demId) {
if (StringUtil.isNotEmpty(isMaster) && (isMaster.equals("1") || isMaster.equals("是"))
&& hasMaster(orgUser.getUserId(), orgUser.getOrgId(), demId) && StringUtil.isEmpty(isMasterMap.get(orgUser.getUserId() + "_" + demId))) {
orgUser.setIsMaster(1);
isMasterMap.put(orgUser.getUserId() + "_" + demId, "1");
} else {
orgUser.setIsMaster(0);
}
if (StringUtil.isNotEmpty(isCharge)) {
//1：负责人；2：主负责
if (isCharge.equals("1")) {
orgUser.setIsCharge(1);
} else if (isCharge.equals("2")) {
if (BeanUtils.isEmpty(orgUserManager.getChargesByOrgId(orgUser.getOrgId(), 2))) {
orgUser.setIsCharge(2);
}
}
} else {
orgUser.setIsCharge(0);
}
}
private boolean hasMaster(String userId, String orgId, String demId) {
Map map = new HashMap();
map.put("userId", userId);
List orgUsers = orgUserManager.getByParms(map);
if (BeanUtils.isNotEmpty(orgUsers)) {
for (OrgUser orgUser : orgUsers) {
if (!orgUser.getOrgId().equals(orgId) && orgUser.getIsMaster() == 1) {
Org org = orgService.get(orgUser.getOrgId());
if (BeanUtils.isNotEmpty(org) && org.getDemId().equals(demId)) {
return false;
}
}
}
}
return true;
}
@Override
public List getUpUsersByUserId(String underUserId) {
return baseMapper.getUpUsersByUserId(underUserId);
}
@Override
public User getUpUserByUserIdAndOrgId(String account, String orgCode) {
User u = this.getByAccount(account);
if (BeanUtils.isEmpty(u)) {
throw new RuntimeException("帐号为【" + account + "】的用户不存在！");
}
Org o = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(o)) {
throw new RuntimeException("编码为【" + orgCode + "】的组织不存在！");
}
return baseMapper.getUpUserByUserIdAndOrgId(u.getId(), o.getId());
}
@Override
public List getUnderUsersByUserId(String upUserId) {
return baseMapper.getUnderUsersByUserId(upUserId);
}
@Override
public List getUnderUserByUserIdAndOrgId(String account, String orgCode) {
User u = this.getByAccount(account);
if (BeanUtils.isEmpty(u)) {
throw new RuntimeException("帐号为【" + account + "】的用户不存在！");
}
Org o = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(o)) {
throw new RuntimeException("编码为【" + orgCode + "】的组织不存在！");
}
Map map = new HashMap();
map.put("upUserId", u.getId());
map.put("orgId", o.getId());
return baseMapper.getUnderUserByUserIdAndOrgId(u.getId(), o.getId());
}
@Override
public List getListByJobId(String jobId) {
List list = new ArrayList();
List orgPost = orgPostManager.getByReldefId(jobId);
if (BeanUtils.isEmpty(orgPost)) return list;
for (OrgPost rel : orgPost) {
List positionUser = getListByPostId(rel.getId());
if (BeanUtils.isNotEmpty(positionUser)) {
list.addAll(positionUser);
}
}
BeanUtils.removeDuplicate(list);
return list;
}
@Override
public User getByNumber(String userNumber) {
return baseMapper.getByNumber(userNumber);
}
@Override
@Transactional
@CacheEvict(value = CacheKeyConst.EIP_UC_USER_ACCOUNT, allEntries = true)
public CommonResult changUserPsd(UserPwdObject userPwdObject)
throws Exception {
if (StringUtil.isEmpty(userPwdObject.getAccount()) && StringUtil.isEmpty(userPwdObject.getUserNumber())) {
throw new RuntimeException("帐号和工号不能同时为空！");
}
User user = getUserByObject(userPwdObject);
String oldPwd = userPwdObject.getOldPwd();
String newPwd = userPwdObject.getNewPwd();
if (user.getStatus() != 1) {
String stateStr = user.getStatus() == 0 || user.getStatus() == -1 ? user.getStatus() == 0 ? "已被禁用" : "未激活" : "已被离职";
return new CommonResult(false, "用户" + stateStr + "，不能修改密码！", "");
}
if (StringUtil.isEmpty(oldPwd)) {
return new CommonResult(false, "旧密码不能为空！", "");
}
if (StringUtil.isEmpty(newPwd)) {
return new CommonResult(false, "新密码不能为空！", "");
}
if (newPwd.equals(oldPwd)) {
return new CommonResult(false, "新密码不能和旧密码一样！", "");
}
PwdStrategy pwdStrategy = pwdStrategyManager.getDefault();
if (BeanUtils.isNotEmpty(pwdStrategy)) {
// 密码策略
int pwdRule = pwdStrategy.getPwdRule();
// 密码长度
int pwdLength = pwdStrategy.getPwdLength();
// 启用策略 0:停用，1:启用
int enable = pwdStrategy.getEnable();
if (enable == 1) {
if (newPwd.length() < pwdLength) {
return new CommonResult(false, "新密码长度不能小于" + pwdLength, "");
}
if (pwdRule == 2) {//必须包含数字、字母
String regex = "^(?![a-zA-z]+$)(?!\\d+$)(?![!@#$%^&*]+$)[a-zA-Z\\d!@#$%^&*]+$";
boolean result = newPwd.matches(regex);
if (!result) {
return new CommonResult(false, "新密码必须包含数字、字母！", "");
}
} else if (pwdRule == 3) {//必须包含数字、字母、特殊字符
String regex = "^(?=.*?[A-Za-z])(?=.*?\\d)(?=.*?[~!@#$%^&*()_+`\\-={}:\";'<>?,.\\/])[a-zA-Z\\d~!@#$%^&*()_+`\\-={}:\";'<>?,.\\/]*$";
boolean result = newPwd.matches(regex);
if (!result) {
return new CommonResult(false, "新密码必须包含数字、字母、特殊字符！", "");
}
} else if (pwdRule == 4) {//必须包含数字、大小字母、特殊字符
String regex = "^(?=.*?[a-z])(?=.*?[A-Z])(?=.*?\\d)(?=.*?[~!@#$%^&*()_+`\\-={}:\";'<>?,.\\/])[a-zA-Z\\d~!@#$%^&*()_+`\\-={}:\";'<>?,.\\/]*$";
boolean result = newPwd.matches(regex);
if (!result) {
return new CommonResult(false, "新密码必须包含数字、大小字母、特殊字符！", "");
}
}
}
}
String oldPswdEncrypt = passwordEncoder.encode(oldPwd);
if (user.getPassword().equals(oldPswdEncrypt)) {
user.setPassword(passwordEncoder.encode(newPwd));
user.setPwdCreateTime(LocalDateTime.now());
this.update(user);
return new CommonResult(true, "更新密码成功！", "");
} else {
return new CommonResult(false, "旧密码输入错误，更新密码失败！", "");
}
}
@Override
@Transactional
public CommonResult updateUserPsw(UserPwdObject userPwdObject)
throws Exception {
if (StringUtil.isEmpty(userPwdObject.getAccount()) && StringUtil.isEmpty(userPwdObject.getUserNumber())) {
return new CommonResult(false, "帐号和工号不能同时为空！", "");
}
if (BeanUtils.isEmpty(userPwdObject) || StringUtil.isEmpty(userPwdObject.getNewPwd())) {
return new CommonResult(false, "新密码不能为空！", "");
}
if (userPwdObject.getNewPwd().trim().length() < 6) {
return new CommonResult(false, "密码长度不能小于6位！", "");
}
String userMarks = userPwdObject.getAccount();
int type = 1;//1： 帐号 2：工号 3：id
if (StringUtil.isEmpty(userMarks) && StringUtil.isNotEmpty(userPwdObject.getUserNumber())) {
userMarks = userPwdObject.getUserNumber();
type = 2;
}
List users = getUserByType(userMarks, type);
if (BeanUtils.isNotEmpty(users)) {
for (User user : users) {
user.setPassword(passwordEncoder.encode(userPwdObject.getNewPwd()));
user.setPwdCreateTime(LocalDateTime.now());
this.update(user);
}
return new CommonResult(true, "更新密码成功！", "");
}
return new CommonResult(false, "未更新任何用户的密码（未找到对应用户）！", "");
}
@Override
@Transactional
public CommonResult updateOneselfPsw(UserPwdObject userPwdObject)
throws Exception {
/*PasswordEncoder p = null;
if(StringUtil.isEmpty(userPwdObject.getAccount()) && StringUtil.isEmpty(userPwdObject.getUserNumber())){
throw new RuntimeException("用户帐号与工号不能同时为空！");
}
User u = null;
if(StringUtil.isNotEmpty(userPwdObject.getAccount())){
u = this.getByAccount(userPwdObject.getAccount());
}
if(StringUtil.isEmpty(userPwdObject.getAccount()) && StringUtil.isNotEmpty(userPwdObject.getUserNumber())){
u = this.getByNumber(userPwdObject.getUserNumber());
}
if(BeanUtils.isEmpty(u)){
throw new RuntimeException("没有找到符合添加的用户！");
}
if(BeanUtils.isEmpty(userPwdObject)||StringUtil.isEmpty(userPwdObject.getNewPwd())){
throw new RuntimeException("新密码不能为空！");
}
if(userPwdObject.getNewPwd().trim().length()<6){
return new CommonResult(false, "密码长度不能小于6位！", "");
}
if(!p.matches(userPwdObject.getOldPwd(), u.getPassword())){
return new CommonResult(false, "旧密码输入错误", "");
}
u.setPassword(p.encode(userPwdObject.getNewPwd()));
this.update(u);*/
return new CommonResult(true, "更新密码成功！", "");
}
/**
* 根据用户标识的json数据获取用户
*
* @param json
* @return
* @throws IOException
*/
private User getUserByJson(String json) throws IOException {
ObjectNode markJson = (ObjectNode) JsonUtil.toJsonNode(json);
if (BeanUtils.isEmpty(markJson)) {
throw new RequiredException("用户ID、用户帐号、用户工号必填其中一个！");
}
UserMarkObject userMark = (UserMarkObject) JsonUtil.toBean(markJson, UserMarkObject.class);
return getUserByObject(userMark);
}
@SuppressWarnings("unused")
private PageList convertRestPageList(PageList pageList) {
PageList voPageList = new PageList();
voPageList.setPage(pageList.getPage());
voPageList.setPageSize(pageList.getPageSize());
voPageList.setTotal(pageList.getTotal());
voPageList.setRows(OrgUtil.convertToUserVoList(pageList.getRows()));
return voPageList;
}
private User getUserByObject(Object obj) throws IOException {
User user = null;
if (BeanUtils.isNotEmpty(obj)) {
String key = "";
ObjectNode json = (ObjectNode) JsonUtil.toJsonNode(obj);
if (json.findValue("account") != null && StringUtil.isNotEmpty(json.get("account").asText())) {
user = this.getByAccount(json.get("account").asText());
key = json.get("account").asText();
} else if (json.findValue("userNumber") != null && StringUtil.isNotEmpty(json.get("userNumber").asText())) {
user = this.getByNumber(json.get("userNumber").asText());
key = json.get("userNumber").asText();
} else if (json.findValue("userId") != null && StringUtil.isNotEmpty(json.get("userId").asText())) {
user = this.get(json.get("userId").asText());
key = json.get("userId").asText();
}
if (BeanUtils.isEmpty(user)) {
return null;
}
}
return user;
}
private List getUserByType(String userMarks, int type) {
List list = new ArrayList();
if (StringUtil.isNotEmpty(userMarks)) {
String[] strArray = userMarks.split(",");
if (type == 1) {
for (String str : strArray) {
User user = this.getByAccount(str);
if (BeanUtils.isNotEmpty(user)) {
list.add(user);
}
}
} else if (type == 2) {
for (String str : strArray) {
User user = this.getByNumber(str);
if (BeanUtils.isNotEmpty(user)) {
list.add(user);
}
}
} else if (type == 3) {
for (String str : strArray) {
User user = this.get(str);
if (BeanUtils.isNotEmpty(user)) {
list.add(user);
}
}
}
}
return list;
}
/**
* 通过帐号或工号获取用户id
*
* @param value
* @param type 1:帐号 2：工号
* @return
*/
private String getUserId(String value, int type) {
String userId = "";
User user = null;
if (type == 1) {
user = this.getByAccount(value);
} else if (type == 2) {
user = this.getByNumber(value);
}
if (BeanUtils.isNotEmpty(user)) {
userId = user.getId();
}
return userId;
}
/**
* 获取维度id
*
* @param userRelObject
* @return
*/
private String getDemId(UserRelObject userRelObject) {
String demId = "";
if (StringUtil.isNotEmpty(userRelObject.getDemCode())) {
Demension demension = demensionService.getByCode(userRelObject.getDemCode());
if (BeanUtils.isNotEmpty(demension)) {
demId = demension.getId();
} else {
throw new RuntimeException("编码为【" + userRelObject.getDemCode() + "】的维度不存在！");
}
}
return demId;
}
private List getChargesByOrgId(String orgId, Boolean isMain) {
List list = new ArrayList();
List orgPost = orgPostService.getRelCharge(orgId, true);
if (BeanUtils.isNotEmpty(orgPost)) {
List users = baseMapper.getListByPostId(orgPost.get(0).getId());
list.addAll(users);
} else {
List orgUsers = orgUserService.getChargesByOrgId(orgId, isMain);
if (BeanUtils.isNotEmpty(orgUsers)) {
for (OrgUser orgUser : orgUsers) {
User user = this.get(orgUser.getUserId());
list.add(user);
}
}
}
return list;
}
/**
* 获取用户的组织信息
*
* @param userRelObject
* @return
* @throws IOException
*/
private List getUserOrgs(UserRelObject userRelObject) throws IOException {
if (StringUtil.isEmpty(userRelObject.getAccount()) && StringUtil.isEmpty(userRelObject.getUserNumber())) {
throw new RuntimeException("用户帐号和工号至少输入一个，不能同时为空！");
}
List orgs = new ArrayList();
User user = getUserByObject(userRelObject);
String demId = getDemId(userRelObject);
if (StringUtil.isNotEmpty(demId)) {
Org org = orgService.getMainGroup(user.getId(), demId);
if (BeanUtils.isNotEmpty(org)) {
orgs.add(org);
}
} else {
orgs = orgService.getMainOrgListByUser(user.getId(), null);
}
return orgs;
}
@Override
@Transactional
public CommonResult saveUserParams(String account,
List params) throws Exception {
if (StringUtil.isEmpty(account)) {
throw new RuntimeException("用户帐号不能为空！");
}
try {
StringBuilder pcodes = new StringBuilder();
User user = this.getByAccount(account);
boolean isTrue = false;
if (BeanUtils.isEmpty(user)) {
throw new RuntimeException("保存失败，没找到帐号为【" + account + "】的用户！");
} else {
List list = new ArrayList();
if (BeanUtils.isNotEmpty(params)) {
for (ParamObject paramObject : params) {
Params param = paramsService.getByAlias(paramObject.getAlias());
if (BeanUtils.isNotEmpty(param) && "1".equals(param.getType())) {
list.add((ObjectNode) JsonUtil.toJsonNode(paramObject.toString()));
isTrue = true;
} else {
pcodes.append(paramObject.getAlias() + "，");
}
}
}
if (BeanUtils.isNotEmpty(list)) {
userParamsService.saveParams(user.getId(), list);
return new CommonResult(true, isTrue && StringUtil.isEmpty(pcodes.toString()) ? "保存成功" : "部分保存成功，用户参数编码：" + pcodes + "不存在！", "");
}
throw new RuntimeException("未保存任何参数，用户参数编码：" + pcodes + "不存在！");
}
} catch (Exception e) {
String msg = e.getMessage();
if (msg.indexOf("ORA-12899") > -1) msg = "参数值过长";
throw new RuntimeException("保存失败，" + msg);
}
}
@Override
public List getUserParams(String account) throws Exception {
if (StringUtil.isEmpty(account)) {
throw new RuntimeException("帐号不能为空！");
}
String userId = getUserId(account, 1);
if (StringUtil.isEmpty(userId)) {
throw new RuntimeException("没找到帐号为【" + account + "】的用户！");
} else {
return userParamsService.getByUserId(userId);
}
}
@Override
public UserParams getParamByCode(String account, String code)
throws Exception {
if (StringUtil.isEmpty(account) || StringUtil.isEmpty(code)) {
throw new RuntimeException("帐号和参数编码不能为空！");
}
String userId = getUserId(account, 1);
if (StringUtil.isEmpty(userId)) {
throw new RuntimeException("没找到帐号为【" + account + "】的用户！");
} else {
return userParamsService.getByUserIdAndAlias(userId, code);
}
}
@Override
public CommonResult getMainOrgByDemCode(UserRelObject userRelObject)
throws Exception {
User user = getUserByObject(userRelObject);
String demCode = userRelObject.getDemCode();
if (StringUtil.isEmpty(demCode)) {
return new CommonResult(false, "请传入维度编码！", null);
}
Demension demension = demensionService.getByCode(demCode);
if (BeanUtils.isEmpty(demension)) {
return new CommonResult(false, "根据维度编码【" + demCode + "】未找到对应维度！", null);
}
Org org = orgService.getMainGroup(user.getUserId(), demension.getId());
boolean isTrue = BeanUtils.isNotEmpty(org) ? true : false;
String msg = isTrue ? "成功获取用户主组织！" : "用户在【" + demension.getDemName() + "】维度下未设置主组织！";
return new CommonResult(isTrue, msg, org);
}
@Override
public List getUserPosts(UserRelObject userRelObject)
throws Exception {
User user = getUserByObject(userRelObject);
String demId = "";
if (StringUtil.isNotEmpty(userRelObject.getDemCode())) {
Demension demension = demensionService.getByCode(userRelObject.getDemCode());
if (BeanUtils.isNotEmpty(demension)) {
demId = demension.getId();
} else {
throw new RuntimeException("根据输入的维度编码没有找到对应的维度信息！");
}
}
List list = orgPostService.getListByUserId(user.getId(), demId);
if (BeanUtils.isNotEmpty(list) && BeanUtils.isNotEmpty(userRelObject.getIsMain()) && userRelObject.getIsMain()) {
List list2 = new ArrayList();
list2.addAll(list);
for (OrgPost orgPost : list2) {
if (BeanUtils.isNotEmpty(orgPost.getIsCharge()) && 1 != orgPost.getIsCharge()) {
list.remove(orgPost);
}
}
}
return list;
}
@Override
public Set getImmeSuperior(UserRelObject userRelObject)
throws Exception {
Set identitys = new HashSet();
List orgs = getUserOrgs(userRelObject);
for (Org org : orgs) {
String orgId = org.getParentId();
if (StringUtil.isNotEmpty(orgId)) {
identitys.addAll(OrgUtil.convertToGroupIdentity(getChargesByOrgId(orgId, BeanUtils.isEmpty(userRelObject.getIsMain()) ? false : userRelObject.getIsMain())));
}
}
return identitys;
}
@Override
public Set getImmeUnders(UserRelObject userRelObject)
throws Exception {
Set identitys = new HashSet();
List orgs = getUserOrgs(userRelObject);
QueryFilter queryFilter = QueryFilter.build();
StringBuilder orgIds = new StringBuilder();
boolean isFirst = true;
for (Org org : orgs) {
if (isFirst) {
isFirst = false;
} else {
orgIds.append(",");
}
orgIds.append(org.getId());
}
//queryFilter.setClazz(Org.class);
if (StringUtil.isEmpty(orgIds.toString())) {
return identitys;
}
queryFilter.addFilter("parentId", orgIds.toString(), QueryOP.IN, FieldRelation.AND);
List chirldOrgs = orgService.query(queryFilter).getRows();
for (Org org : chirldOrgs) {
identitys.addAll(OrgUtil.convertToGroupIdentity(getUserListByOrgId(org.getId())));
}
return identitys;
}
@Override
public List getUserJobs(String json) throws Exception {
User user = getUserByJson(json);
return orgJobService.getListByUserId(user.getId());
}
@Override
public List getUserGroups(String json) throws Exception {
User user = getUserByJson(json);
return userGroupService.getByUserId(user.getUserId());
}
@Override
public List getNewUsersFromAD(String dateStr) throws Exception {
if (StringUtil.isEmpty(dateStr)) {
throw new RequiredException(HotentHttpStatus.REUIRED.description() + "：date时间必填！");
}
QueryFilter queryFilter = QueryFilter.build();
//queryFilter.setClazz(User.class);
queryFilter.addFilter("from", User.FROM_AD, QueryOP.EQUAL, FieldRelation.AND);
if (StringUtil.isNotEmpty(dateStr)) {
dateStr = dateStr.trim().length() == 10 ? dateStr + " 00:00:00" : dateStr;
LocalDateTime date = DateFormatUtil.parse(dateStr, StringPool.DATE_FORMAT_DATETIME);
queryFilter.addFilter("createTime", date, QueryOP.GREAT_EQUAL, FieldRelation.AND);
}
List list = query(queryFilter).getRows();
return OrgUtil.convertToUserVoList(list);
}
@Override
public Set getByRoleCodeAndOrgCode(String roleCode, String orgCode)
throws Exception {
Role role = roleService.getByAlias(roleCode);
if (BeanUtils.isEmpty(role)) {
throw new RequiredException("编码为【" + roleCode + "】的角色不存在！");
}
Org org = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(org)) {
throw new RequiredException("编码为【" + orgCode + "】的组织不存在！");
}
Set identitys = new HashSet();
List users = baseMapper.getByOrgCodeAndroleCode(orgCode, roleCode);
if (BeanUtils.isNotEmpty(users)) {
identitys = OrgUtil.convertToGroupIdentity(users);
}
return identitys;
}
@Override
public Set getByJobCodeAndOrgCode(String jobCode, String orgCode)
throws Exception {
OrgJob job = orgJobService.getByCode(jobCode);
if (BeanUtils.isEmpty(job)) {
throw new RequiredException("编码为【" + jobCode + "】的职务不存在！");
}
Org org = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(org)) {
throw new RequiredException("编码为【" + orgCode + "】的组织不存在！");
}
Set identitys = new HashSet();
List users = baseMapper.getByJobCodeAndOrgCode(orgCode, jobCode);
identitys = OrgUtil.convertToGroupIdentity(users);
return identitys;
}
@Override
public Set getByPostCodeAndOrgCode(String postCode, String orgCode)
throws Exception {
OrgPost post = orgPostService.getByCode(postCode);
if (BeanUtils.isEmpty(post)) {
throw new RequiredException("编码为【" + postCode + "】的岗位不存在！");
}
Org org = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(org)) {
throw new RequiredException("编码为【" + orgCode + "】的组织不存在！");
}
Set identitys = new HashSet();
List orgUsers = orgUserManager.getByPostCodeAndOrgCode(orgCode, postCode);
if (BeanUtils.isNotEmpty(orgUsers)) {
List list = new ArrayList();
for (OrgUser orgUser : orgUsers) {
User user = get(orgUser.getUserId());
if (BeanUtils.isNotEmpty(user)) {
list.add(user);
}
}
identitys = OrgUtil.convertToGroupIdentity(list);
}
return identitys;
}
@Override
public List getUpUsersByUser(String account) throws Exception {
String userId = getUserId(account, 1);
if (BeanUtils.isEmpty(userId)) {
throw new RuntimeException("没找到帐号为【" + account + "】的用户！");
}
return OrgUtil.convertToUserVoList(getUpUsersByUserId(userId));
}
@Override
public UserVo getUpUserByUserAndOrg(String account, String orgCode)
throws Exception {
return OrgUtil.convertToUserVo(getUpUserByUserIdAndOrgId(account, orgCode));
}
@Override
public List getUnderUsersByUser(String account) throws Exception {
String userId = getUserId(account, 1);
if (BeanUtils.isEmpty(userId)) {
throw new RuntimeException("没找到帐号为【" + account + "】的用户！");
}
return OrgUtil.convertToUserVoList(getUnderUsersByUserId(userId));
}
@Override
public List getUnderUserByUserAndOrg(String account,
String orgCode) throws Exception {
return OrgUtil.convertToUserVoList(getUnderUserByUserIdAndOrgId(account, orgCode));
}
@Override
public List getOrgUsers(String orgId, Boolean isMain) {
Map params = new HashMap();
if (BeanUtils.isNotEmpty(isMain)) {
if (isMain) {
params.put("isMain", "1");
} else {
params.put("isMain", "0");
}
}
params.put("orgId", orgId);
return baseMapper.getOrgUsers(params);
}
@Override
@Transactional
public void updatePhoto(String account, String photo) throws Exception {
User user = baseMapper.getByAccount(account);
if (BeanUtils.isEmpty(user)) {
throw new RuntimeException("没找到帐号为【" + account + "】的用户！");
}
user.setPhoto(photo);
this.update(user);
}
@Override
public CommonResult forbiddenUser(UserMarkObject userMark) throws Exception {
return toDealUserState(userMark, 0);
}
@Override
public CommonResult activateUser(UserMarkObject userMark) throws Exception {
return toDealUserState(userMark, 1);
}
@Override
public CommonResult leaveUser(UserMarkObject userMark) throws Exception {
return toDealUserState(userMark, -2);
}
@Override
@Transactional
public CommonResult lockUser(UserMarkObject userMark) throws Exception {
return toDealUserLockStatus(userMark, 2);
}
@Override
@Transactional
public CommonResult unLockUser(UserMarkObject userMark) throws Exception {
return toDealUserLockStatus(userMark, 1);
}
@Transactional
private CommonResult toDealUserState(UserMarkObject userMark, int state) throws SQLException {
StringBuilder msg = new StringBuilder();
boolean isTrue = false;
if (StringUtil.isNotEmpty(userMark.getAccount())) {
String[] accounts = userMark.getAccount().split(",");
for (String account : accounts) {
User user = baseMapper.getByAccount(account);
if (BeanUtils.isNotEmpty(user) && user.getStatus() != state) {
dealUserState(user, state);
isTrue = true;
} else {
String dmsg = BeanUtils.isEmpty(user) ? "不存在" : state == 1 || state == 0 ? state == 1 ? "已激活" : "已被禁用" : "已被离职";
msg.append("用户帐号【" + account + "】" + dmsg + "，");
}
}
}
if (StringUtil.isNotEmpty(userMark.getUserNumber())) {
String[] numbers = userMark.getUserNumber().split(",");
for (String number : numbers) {
User user = baseMapper.getByNumber(number);
if (BeanUtils.isNotEmpty(user) && user.getStatus() != state) {
dealUserState(user, state);
isTrue = true;
} else {
String dmsg = BeanUtils.isEmpty(user) ? "不存在" : state == 1 || state == 0 ? state == 1 ? "已激活" : "已被禁用" : "已被离职";
msg.append("用户工号【" + number + "】" + dmsg + "，");
}
}
}
String successMsg = state == 1 || state == 0 ? state == 1 ? "激活用户成功！" : "用户禁用成功" : "离职用户成功";
if (StringUtil.isEmpty(userMark.getAccount()) && StringUtil.isEmpty(userMark.getUserNumber())) {
isTrue = false;
msg.append("用户帐号和工号至少输入一个，不能同时为空！");
}
return new CommonResult(isTrue, BeanUtils.isNotEmpty(msg) ? msg.toString() : successMsg, "");
}
@Transactional
private CommonResult toDealUserLockStatus(UserMarkObject userMark, Integer lockStatus) throws SQLException {
StringBuilder msg = new StringBuilder();
boolean isTrue = false;
if (StringUtil.isNotEmpty(userMark.getAccount())) {
String[] accounts = userMark.getAccount().split(",");
for (String account : accounts) {
User user = baseMapper.getByAccount(account);
if (BeanUtils.isNotEmpty(user) && user.getLockedStatus() != lockStatus) {
user.setLockedStatus(lockStatus);
if (lockStatus == 1) {
user.setLockedTime(null);
} else {
user.setLockedTime(LocalDateTime.now());
}
this.update(user);
isTrue = true;
} else {
String dmsg = BeanUtils.isEmpty(user) ? "不存在" : lockStatus == 1 ? "已正常" : lockStatus == 2 ? "已被锁定" : "";
msg.append("用户帐号【" + account + "】" + dmsg + "，");
}
}
}
if (StringUtil.isNotEmpty(userMark.getUserNumber())) {
String[] numbers = userMark.getUserNumber().split(",");
for (String number : numbers) {
User user = baseMapper.getByNumber(number);
if (BeanUtils.isNotEmpty(user) && user.getLockedStatus() != lockStatus) {
user.setLockedStatus(lockStatus);
if (lockStatus == 1) {
user.setLockedTime(null);
} else {
user.setLockedTime(LocalDateTime.now());
}
this.update(user);
isTrue = true;
} else {
String dmsg = BeanUtils.isEmpty(user) ? "不存在" : lockStatus == 1 ? "已正常" : lockStatus == 2 ? "已被锁定" : "";
msg.append("用户工号【" + number + "】" + dmsg + "，");
}
}
}
String successMsg = lockStatus == 1 ? "解锁成功！" : lockStatus == 2 ? "锁定用户成功!" : "";
if (StringUtil.isEmpty(userMark.getAccount()) && StringUtil.isEmpty(userMark.getUserNumber())) {
isTrue = false;
msg.append("用户帐号和工号至少输入一个，不能同时为空！");
}
return new CommonResult(isTrue, BeanUtils.isNotEmpty(msg) ? msg.toString() : successMsg, "");
}
@Override
public List getUserByPost(String postCode) {
if (StringUtil.isEmpty(postCode)) {
throw new RequiredException(HotentHttpStatus.REUIRED.description() + "：postCode岗位编码必填！");
}
//因为流程节点插件抽取人员统一传的是id。而获取岗位人员的feign接口只有根据code查的，查不到。暂时先做兼容传id
QueryFilter queryFilter = QueryFilter.build();
queryFilter.addFilter("ID_", postCode, QueryOP.IN, FieldRelation.OR);
queryFilter.addFilter("CODE_", postCode, QueryOP.IN, FieldRelation.OR);
PageList query = orgPostManager.query(queryFilter);
if (BeanUtils.isEmpty(query) || BeanUtils.isEmpty(query.getRows())) {
return new ArrayList<>();
}
List postCodes = new ArrayList<>();
for (OrgPost orgPost : query.getRows()) {
postCodes.add(orgPost.getCode());
}
return OrgUtil.convertToUserVoList(baseMapper.getUserByPosts(postCodes));
}
@Override
@Transactional
public String exportUsers(boolean isOrg, boolean isRole, boolean isAll, QueryFilter queryFilter)
throws Exception {
//queryFilter.setClazz(User.class);
boolean isOtherAll = isAll && BeanUtils.isEmpty(queryFilter.getQuerys());
List userList = new ArrayList();
if (isAll) {
queryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
userList = this.queryNoPage(queryFilter);
} else {
PageList query = this.query(queryFilter);
userList = query.getRows();
}
String zipFilePath = "";
if (BeanUtils.isNotEmpty(userList)) {
// 拼装exprotMaps
Field[] baseFields = UserDao.class.getDeclaredFields();
String fileName = "htuc_user_" + DateFormatUtil.format(LocalDateTime.now(), "yyyy_MMdd_HHmm");
String zipPath = (FileUtil.getIoTmpdir() + "/attachFiles/tempZip/" + fileName).replace("/", File.separator);
String excelPath = zipPath + File.separator;
//导出用户
this.exportExcel(baseFields, userList, "用户列表", "user", excelPath);
if (isOrg || isRole) {
List userIds = new ArrayList();
if (!isOtherAll) {
for (User user : userList) {
userIds.add(user.getId());
}
}
if (isOrg) {
//导出用户组织关系（包含组织、用户组织关系、职务、岗位）
this.exportOrg(userIds, baseFields, excelPath, fileName, isOtherAll);
}
if (isRole) {
//导出用户角色关系（包含角色、用户角色关系）
this.exportRoles(userIds, baseFields, excelPath, isOtherAll);
}
}
// 打包
ZipUtil.zip(zipPath, true);
zipFilePath = (FileUtil.getIoTmpdir() + "/attachFiles/tempZip/").replace("/", File.separator) + fileName;
} else {
throw new RuntimeException("没有需要导出的用户组织信息！");
}
return zipFilePath;
}
/**
* 处理用户状态
*
* @param user
* @param status
* @throws SQLException
*/
@Transactional
private void dealUserState(User user, Integer status) throws SQLException {
if (BeanUtils.isNotEmpty(user)) {
user.setStatus(status);
this.update(user);
}
}
/**
* 导出组织
*
* @param userIds
* @param baseFields
* @param excelPath
* @param fileName
* @throws Exception
*/
@Transactional
private void exportOrg(List userIds, Field[] baseFields, String excelPath, String fileName, boolean isOtherAll) throws Exception {
QueryFilter orgUserQueryFilter = QueryFilter.build();
if (!isOtherAll) {
orgUserQueryFilter.addFilter("userId", userIds, QueryOP.IN, FieldRelation.AND);
}
orgUserQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//orgUserQueryFilter.setClazz(OrgUser.class);
List orgUsers = orgUserManager.queryNoPage(orgUserQueryFilter);
if (BeanUtils.isNotEmpty(orgUsers)) {
//导出用户组织关系
this.exportExcel(baseFields, orgUsers, "用户组织关系列表", "orgUser", excelPath);
List orgIds = new ArrayList();
List postIds = new ArrayList();
for (int i = 0; i < orgUsers.size(); i++) {
orgIds.add(orgUsers.get(i).getOrgId());
if (StringUtil.isNotEmpty(orgUsers.get(i).getRelId())) {
postIds.add(orgUsers.get(i).getRelId());
}
}
//导出组织
QueryFilter orgQueryFilter = QueryFilter.build();
BeanUtils.removeDuplicate(orgIds);
orgQueryFilter.addFilter("id", orgIds, QueryOP.IN, FieldRelation.AND);
orgQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//orgQueryFilter.setClazz(Org.class);
List orgs = orgManager.queryNoPage(orgQueryFilter);
if (BeanUtils.isNotEmpty(orgs)) {
this.exportExcel(baseFields, orgs, "组织列表", "org", excelPath);
//导出维度
List demIds = new ArrayList();
for (Org org : orgs) {
demIds.add(org.getDemId());
}
exportDemension(baseFields, excelPath, demIds);
}
//导出岗位
if (BeanUtils.isNotEmpty(postIds)) {
exportJobAndPost(baseFields, excelPath, postIds);
}
}
}
/**
* 导出维度
*
* @param baseFields
* @param excelPath
* @param demIds
* @throws Exception
*/
@Transactional
private void exportDemension(Field[] baseFields, String excelPath, List demIds) throws Exception {
BeanUtils.removeDuplicate(demIds);
QueryFilter demQueryFilter = QueryFilter.build();
demQueryFilter.addFilter("id", demIds, QueryOP.IN, FieldRelation.AND);
demQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//demQueryFilter.setClazz(OrgPost.class);
List dems = demensionManager.queryNoPage(demQueryFilter);
if (BeanUtils.isNotEmpty(dems)) {
this.exportExcel(baseFields, dems, "维度列表", "demension", excelPath);
}
}
/**
* 导出职务岗位
*
* @param baseFields
* @param excelPath
* @param postIds
* @throws Exception
*/
@Transactional
private void exportJobAndPost(Field[] baseFields, String excelPath, List postIds) throws Exception {
BeanUtils.removeDuplicate(postIds);
QueryFilter postQueryFilter = QueryFilter.build();
postQueryFilter.addFilter("id", postIds, QueryOP.IN, FieldRelation.AND);
postQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//postQueryFilter.setClazz(OrgPost.class);
List orgPosts = orgPostManager.queryNoPage(postQueryFilter);
if (BeanUtils.isNotEmpty(orgPosts)) {
this.exportExcel(baseFields, orgPosts, "岗位列表", "post", excelPath);
List jobIds = new ArrayList();
//导出职务
for (OrgPost orgPost : orgPosts) {
if (StringUtil.isNotEmpty(orgPost.getRelDefId())) {
jobIds.add(orgPost.getRelDefId());
}
}
QueryFilter jobQueryFilter = QueryFilter.build();
jobQueryFilter.addFilter("id", jobIds, QueryOP.IN, FieldRelation.AND);
jobQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//jobQueryFilter.setClazz(OrgJob.class);
List orgJobs = orgJobManager.queryNoPage(jobQueryFilter);
if (BeanUtils.isNotEmpty(orgJobs)) {
this.exportExcel(baseFields, orgJobs, "职务列表", "job", excelPath);
}
}
}
/**
* 导出角色
*
* @param userIds
* @param baseFields
* @param excelPath
* @param isOtherAll
* @throws Exception
*/
@Transactional
private void exportRoles(List userIds, Field[] baseFields, String excelPath, boolean isOtherAll) throws Exception {
BeanUtils.removeDuplicate(userIds);
QueryFilter userRoleQueryFilter = QueryFilter.build();
if (!isOtherAll) {
userRoleQueryFilter.addFilter("userId", userIds, QueryOP.IN, FieldRelation.AND);
}
userRoleQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//userRoleQueryFilter.setClazz(UserRole.class);
List userRoles = userRoleManager.queryNoPage(userRoleQueryFilter);
if (BeanUtils.isNotEmpty(userRoles)) {
this.exportExcel(baseFields, userRoles, "用户角色关系列表", "userRole", excelPath);
List roleIds = new ArrayList();
//导出职务
for (UserRole userRole : userRoles) {
roleIds.add(userRole.getRoleId());
}
QueryFilter roleQueryFilter = QueryFilter.build();
roleQueryFilter.addFilter("id", roleIds, QueryOP.IN, FieldRelation.AND);
roleQueryFilter.addFilter("isDelete", "1", QueryOP.NOT_EQUAL, FieldRelation.AND, "group_1");
//roleQueryFilter.setClazz(Role.class);
List roles = roleManager.queryNoPage(roleQueryFilter);
if (BeanUtils.isNotEmpty(roles)) {
this.exportExcel(baseFields, roles, "角色列表", "role", excelPath);
}
}
}
private void exportExcel(Field[] baseFields, List list, String sheetName, String excelName, String excelPath) throws Exception {
Map exportMaps = new LinkedHashMap();
Field[] fields = list.get(0).getClass().getDeclaredFields();
for (Field field : fields) {
if (field.getModifiers() == 4) {//修饰符类型为protected
exportMaps.put(field.getName(), field.getName());
}
}
for (Field field : baseFields) {
if (field.getModifiers() == 4) {//修饰符类型为protected
exportMaps.put(field.getName(), field.getName());
}
}
HSSFWorkbook book = ExcelUtil.exportExcel(sheetName, 24, exportMaps, list);
ExcelUtil.saveExcel(book, excelName, excelPath);
}
@Override
public List getUserByTime(UserExportObject userExport)
throws Exception {
QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(userExport.getBtime(), userExport.getEtime());
StringBuilder sql = new StringBuilder();
//职务
if (StringUtil.isNotEmpty(userExport.getJobCodes())) {
sql.append(" and ID_ in( select aa.USER_ID_ from uc_org_user aa where aa.is_dele_ = '0' and aa.pos_id_ in (select bb.ID_ from uc_org_post bb where bb.is_dele_='0' and bb.job_id_ in (select cc.id_ from uc_org_job cc where cc.is_dele_='0' and cc.CODE_ in ");
sql.append(OrgUtil.getSubInSql(userExport.getJobCodes(), ","));
sql.append(" ))) ");
}
//岗位
if (StringUtil.isNotEmpty(userExport.getPostCodes())) {
sql.append(" and ID_ in( select dd.USER_ID_ FROM uc_org_user dd where dd.is_dele_='0' and dd.pos_id_ in( select ee.ID_ from uc_org_post ee where ee.is_dele_='0' and ee.CODE_ in ");
sql.append(OrgUtil.getSubInSql(userExport.getPostCodes(), ","));
sql.append(" )) ");
}
//组织
else if (StringUtil.isNotEmpty(userExport.getOrgCodes())) {
sql.append(" and ID_ in( select ff.USER_ID_ FROM uc_org_user ff where ff.is_dele_='0' and ff.org_id_ in( select gg.ID_ from uc_org gg where gg.is_dele_='0' and gg.CODE_ in ");
sql.append(OrgUtil.getSubInSql(userExport.getOrgCodes(), ","));
sql.append(" )) ");
}
//维度
else if (StringUtil.isNotEmpty(userExport.getDemCodes())) {
sql.append(" and ID_ in( select hh.user_id_ FROM uc_org_user hh where hh.is_dele_='0' and hh.org_id_ in( select ii.ID_ from uc_org ii where ii.is_dele_='0' and ii.dem_id_ in(select jj.ID_ from uc_demension jj where jj.is_dele_='0' and jj.code_ in ");
sql.append(OrgUtil.getSubInSql(userExport.getDemCodes(), ","));
sql.append(" ))) ");
}
if (BeanUtils.isNotEmpty(sql)) {
Map params = new HashMap();
params.put("dimSql", sql.toString());
queryFilter.setParams(params);
}
return baseMapper.queryByDim(convert2Wrapper(queryFilter, currentModelClass()));
}
@Override
public List getUserParamByTime(String btime, String etime)
throws Exception {
QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(btime, etime);
return userParamsService.queryNoPage(queryFilter);
}
@Override
public List getUserRoleByTime(String btime, String etime)
throws Exception {
QueryFilter queryFilter = OrgUtil.getDataByTimeFilter(btime, etime);
return userRoleManager.queryNoPage(queryFilter);
}
@Override
public List getChargesByOrg(String orgCode, Boolean isMain)
throws Exception {
Org org = orgService.getByCode(orgCode);
if (BeanUtils.isEmpty(org)) {
org = orgService.get(orgCode);
if (BeanUtils.isEmpty(org)) {
throw new RuntimeException("组织编码或id【" + orgCode + "不存在】！");
}
}
List orgUser = orgUserService.getChargesByOrgId(org.getId(), isMain);
if (BeanUtils.isNotEmpty(orgUser)) {
List userIds = new ArrayList();
for (OrgUser oUser : orgUser) {
userIds.add(oUser.getUserId());
}
QueryFilter filter = QueryFilter.build();
//filter.setClazz(User.class);
filter.addFilter("id", userIds, QueryOP.IN, FieldRelation.AND);
return this.query(filter).getRows();
}
return null;
}
@Override
public DataSyncVo getSyncDataByTime(DataSyncObject dataSync)
throws Exception {
DataSyncVo dataSyncVo = new DataSyncVo();
String btime = dataSync.getBtime();
String etime = dataSync.getEtime();
//用户
if (dataSync.getIsUser()) {
UserExportObject userExport = new UserExportObject();
userExport.setBtime(btime);
userExport.setEtime(etime);
userExport.setDemCodes(dataSync.getDemCodes());
userExport.setOrgCodes(dataSync.getOrgCodes());
userExport.setJobCodes(dataSync.getJobCodes());
userExport.setPostCodes(dataSync.getPostCodes());
dataSyncVo.setUserList(this.getUserByTime(userExport));
}
OrgExportObject exportObject = new OrgExportObject();
exportObject.setBtime(btime);
exportObject.setEtime(etime);
exportObject.setDemCodes(dataSync.getDemCodes());
exportObject.setOrgCodes(dataSync.getOrgCodes());
//维度
if (dataSync.getIsDem()) {
dataSyncVo.setDemList(demensionService.getDemByTime(exportObject));
}
//组织
if (dataSync.getIsOrg()) {
dataSyncVo.setOrgList(orgService.getOrgByTime(exportObject));
}
//分级组织
if (dataSync.getIsOrgAuth()) {
dataSyncVo.setOrgAuthList(orgAuthService.getOrgAuthByTime(exportObject));
}
//职务
if (dataSync.getIsJob()) {
dataSyncVo.setJobList(orgJobService.getJobByTime(btime, etime));
}
//岗位
if (dataSync.getIsPost()) {
dataSyncVo.setPostList(orgService.getOrgPostByTime(exportObject));
}
//用户组织关系
if (dataSync.getIsOrgUser()) {
dataSyncVo.setOrgUserList(orgService.getOrgUserByTime(exportObject));
}
//组织中的用户下属
if (dataSync.getIsUnder()) {
dataSyncVo.setUnderList(orgService.getUserUnderByTime(exportObject));
}
//组织角色
if (dataSync.getIsOrgRole()) {
dataSyncVo.setOrgRoleList(orgService.getOrgRoleByTime(exportObject));
}
//用户组织参数
if (dataSync.getIsParams()) {
dataSyncVo.setParamsList(paramsService.getParamsByTime(btime, etime));
}
//用户参数
if (dataSync.getIsUserParams()) {
dataSyncVo.setUserParamList(this.getUserParamByTime(btime, etime));
}
//组织参数
if (dataSync.getIsOrgParams()) {
dataSyncVo.setOrgParamList(orgService.getOrgParamByTime(exportObject));
}
//角色
if (dataSync.getIsRole()) {
dataSyncVo.setRoleList(roleService.getRoleByTime(btime, etime));
}
//用户角色关系
if (dataSync.getIsUserRole()) {
dataSyncVo.setUserRoleList(this.getUserRoleByTime(btime, etime));
}
//群组
if (dataSync.getIsGroup()) {
dataSyncVo.setGroupList(userGroupService.getUserGroupByTime(btime, etime));
}
//汇报线节点
if (dataSync.getIsUserRel()) {
dataSyncVo.setUserRelList(userRelService.getUserRelByTime(btime, etime));
}
return dataSyncVo;
}
// 清理头像目录
private void cleanPhotoFolder(String account, String exceptFile) throws IOException {
Path path = Paths.get(attachPath, account);
if (Files.notExists(path) || StringUtil.isEmpty(exceptFile)) return;
UserPhotoFileFindVisitor userPhotoFileFindVisitor = new UserPhotoFileFindVisitor(exceptFile);
Files.walkFileTree(path, userPhotoFileFindVisitor);
for (String fileName : userPhotoFileFindVisitor.getFilenameList()) {
Files.delete(Paths.get(fileName));
}
}
@Override
@Transactional
public void saveUser(UserPolymer userPolymer) throws Exception {
UserVo user = userPolymer.getUser();
String account = user.getAccount();
// 处理用户数据
if (userPolymer.getAdding()) {
this.addUser(user);
} else {
this.updateUser(user);
}
cleanPhotoFolder(account, user.getPhoto());
// 处理角色数据
List roles = userPolymer.getRoles();
int roleSize = BeanUtils.isEmpty(roles) ? 0 : roles.size();
String[] roleCodes = new String[roleSize];
for (int i = 0; i < roleSize; i++) {
UserPolymerRole userPolymerRole = roles.get(i);
roleCodes[i] = userPolymerRole.getCode();
}
userRoleService.saveUserRole(account, roleCodes);
// 处理组织岗位数据
List orgsPoses = userPolymer.getOrgsPoses();
orgUserService.saveOrgUser(account, orgsPoses);
}
@Override
@Transactional
public CommonResult saveUser(UserVo user) {
try {
String account = user.getAccount();
if (StringUtil.isEmpty(user.getAccount())) {
throw new RequiredException("更新用户失败，用户帐号【account】必填！");
}
User u = this.getByAccount(user.getAccount());
if (BeanUtils.isEmpty(u)) {
throw new RuntimeException("更新用户失败，根据【" + user.getAccount() + "】没有找到对应的用户信息！");
}
if (StringUtil.isNotEmpty(user.getBirthday())) {
u.setBirthday(DateFormatUtil.parse(user.getBirthday(), StringPool.DATE_FORMAT_DATE).toLocalDate());
} else {
u.setBirthday(null);
}
u.setAddress(user.getAddress());
u.setEducation(user.getEducation());
u.setSex(user.getSex());
u.setPhoto(user.getPhoto());
u.setIdCard(user.getIdCard());
this.update(u);
cleanPhotoFolder(account, user.getPhoto());
} catch (Exception e) {
return new CommonResult(false, "修改用户信息失败", e.getMessage());
}
return new CommonResult(true, "修改用户信息成功", "");
}
@Override
public ChartOption getUserRelCharts(String json) throws Exception {
User user = getUserByJson(json);
if (BeanUtils.isEmpty(user)) {
throw new RuntimeException("根据用户标识信息获取不到用户！");
}
String currentUserName = user.getFullname();
String text = "【" + currentUserName + "】的汇报关系图";
String subtext = "数据来自华润三九用户中心";
List legend = new ArrayList();
legend.add("组织领导");
legend.add("汇报线");
String seriesName = "汇报关系";
ArrayNode categories = (ArrayNode) JsonUtil.toJsonNode("[{name: '当前用户'},{name: '组织领导'},{name:'汇报线'}]");
List nodes = new ArrayList();
List links = new ArrayList();
ChartNode root = new ChartNode("root", 0, currentUserName + "\n" + "（当前用户）", "当前人", currentUserName + "\n" + "（当前用户）", 35);
nodes.add(root);
Map nodeIdMap = new HashMap();
//汇报线节点
ChartOption option = new ChartOption(text, subtext, legend, seriesName, categories);
//获取汇报线汇报关系
getUserRelOptions(root, option, nodes, links, user.getAccount(), nodeIdMap);
//获取组织汇报关系
getOrgOptions(root, option, nodes, links, user.getId(), nodeIdMap);
option.setNodes(nodes);
option.setLinks(links);
return option;
}
/**
* 获取汇报线汇报关系
*
* @param option
* @param nodes
* @param links
* @param account
* @return
* @throws Exception
*/
private void getUserRelOptions(ChartNode root, ChartOption option, List nodes, List links, String account,
Map nodeIdMap) throws Exception {
List rels = userRelService.getUserRels(account, null);
for (UserRel userRel : rels) {
//如果父节点id为分类id，则跳过
if (userRel.getParentId().equals(userRel.getTypeId())) {
continue;
}
List relNodes = new ArrayList();
List relLinks = new ArrayList();
UserRel pRel = userRelService.get(userRel.getParentId());
if (BeanUtils.isNotEmpty(pRel) && pRel.getStatus() == 1) {
ObjectNode proType = portalFeignService.getSysTypeById(pRel.getTypeId());
String typeName = BeanUtils.isEmpty(proType) ? "未找到！" : proType.get("name").asText();
getSupRel(root, userRel, pRel, relNodes, relLinks, true, nodeIdMap, typeName);
if (BeanUtils.isNotEmpty(relNodes)) {
nodes.addAll(relNodes);
}
if (BeanUtils.isNotEmpty(relLinks)) {
links.addAll(relLinks);
}
}
}
}
/**
* 获取上级汇报节点
*
* @throws Exception
*/
private void getSupRel(ChartNode root, UserRel nowRel, UserRel pRel, List relNodes, List relLinks, boolean isFirst,
Map nodeIdMap, String typeName) throws Exception {
if (BeanUtils.isNotEmpty(pRel)) {
ChartNode node = nodeIdMap.get(pRel.getId());
if (BeanUtils.isEmpty(node)) {
String label = getRelLabel(pRel);
node = new ChartNode(pRel.getId(), 2, label, "所属汇报线【" + typeName + "】", label, 30);
nodeIdMap.put(pRel.getId(), node);
relNodes.add(node);
}
ChartLink link = new ChartLink("汇报线", isFirst ? root.getId() : nowRel.getId(), pRel.getId(), isFirst ? 5 : 3);
relLinks.add(link);
UserRel ppRel = userRelService.get(pRel.getParentId());
//如果不是顶层节点，则往上找上级节点
if (BeanUtils.isNotEmpty(ppRel) && ppRel.getStatus() == 1) {
getSupRel(root, pRel, ppRel, relNodes, relLinks, false, nodeIdMap, typeName);
}
}
}
/**
* 获取汇报线节点标签
*
* @param rel
* @return
* @throws Exception
*/
private String getRelLabel(UserRel rel) throws Exception {
StringBuilder sbd = new StringBuilder();
List users = userRelService.getUsersByRel(rel.getAlias());
sbd.append(rel.getName());
sbd.append("\n");
sbd.append("（");
switch (rel.getGroupType()) {
case UserRel.GROUP_USER:
sbd.append("用户");
break;
case UserRel.GROUP_ORG:
sbd.append("组织");
break;
case UserRel.GROUP_POS:
sbd.append("岗位");
break;
case UserRel.GROUP_ROLE:
sbd.append("角色");
break;
case UserRel.GROUP_GROUP:
sbd.append("群组");
break;
}
if (!UserRel.GROUP_USER.equals(rel.getGroupType())) {
sbd.append("【");
sbd.append(BeanUtils.isNotEmpty(users) ? this.getUserNames(users) : "未找到用户");
sbd.append("】");
}
sbd.append("）");
return sbd.toString();
}
/**
* 获取组织汇报关系
*
* @param option
* @param nodes
* @param links
* @param userId
* @param nodeIdMap
* @return
* @throws Exception
*/
private void getOrgOptions(ChartNode root, ChartOption option, List nodes, List links, String userId,
Map nodeIdMap) throws Exception {
List orgs = orgService.getMainOrgListByUser(userId, null);
for (Org org : orgs) {
List orgNodes = new ArrayList();
List orgLinks = new ArrayList();
Org pOrg = orgService.get(org.getParentId());
if (BeanUtils.isNotEmpty(pOrg)) {
Demension dem = demensionService.get(pOrg.getDemId());
String demName = BeanUtils.isEmpty(dem) ? "未找到！" : dem.getDemName();
getSupOrg(root, org, pOrg, orgNodes, orgLinks, true, nodeIdMap, demName);
if (BeanUtils.isNotEmpty(orgNodes)) {
nodes.addAll(orgNodes);
}
if (BeanUtils.isNotEmpty(orgLinks)) {
links.addAll(orgLinks);
}
}
}
}
/**
* 获取上级组织
*
* @throws Exception
*/
private void getSupOrg(ChartNode root, Org nowOrg, Org pOrg, List orgNodes, List orgLinks, boolean isFirst,
Map nodeIdMap, String demName) throws Exception {
if (BeanUtils.isNotEmpty(pOrg)) {
List posts = orgPostService.getRelCharge(pOrg.getId(), true);
ChartNode node = nodeIdMap.get(pOrg.getId());
if (BeanUtils.isEmpty(node)) {
String label = getOrgLabel(pOrg, posts);
node = new ChartNode(pOrg.getId(), 1, label, "所属维度【" + demName + "】", label, 30);
nodeIdMap.put(pOrg.getId(), node);
orgNodes.add(node);
}
ChartLink link = new ChartLink("组织领导", isFirst ? root.getId() : nowOrg.getId(), pOrg.getId(), isFirst ? 5 : 3);
orgLinks.add(link);
Org ppOrg = orgService.get(pOrg.getParentId());
//如果不是顶层节点，则往上找上级节点
if (BeanUtils.isNotEmpty(ppOrg)) {
getSupOrg(root, pOrg, ppOrg, orgNodes, orgLinks, false, nodeIdMap, demName);
}
}
}
/**
* 获取组织节点标签
*
* @param org
* @return
* @throws Exception
*/
private String getOrgLabel(Org org, List posts) throws Exception {
StringBuilder sbd = new StringBuilder();
sbd.append(org.getName());
sbd.append("\n");
sbd.append("（");
List users = null;
if (BeanUtils.isNotEmpty(posts)) {
OrgPost post = posts.get(0);
users = getListByPostId(post.getId());
// 如果没有设置主岗位，则找组织负责人（包含负责人和主负责人）
// if(BeanUtils.isEmpty(users)){
// sbd.append("负责人");
// users = getChargesByOrg(org.getCode(), false);
// }else{
// sbd.append(post.getName());
// }
sbd.append(post.getName());
String names = getUserNames(users);
sbd.append("【");
sbd.append(StringUtil.isNotEmpty(names) ? names : "未设置人员");
sbd.append("】");
} else {
users = getChargesByOrg(org.getCode(), false);
if (BeanUtils.isEmpty(users)) {
sbd.append("未设置责任岗位、负责人");
} else {
sbd.append("负责人");
sbd.append("【");
sbd.append(getUserNames(users));
sbd.append("】");
}
}
sbd.append("）");
return sbd.toString();
}
private String getUserNames(List users) {
StringBuilder sbd = new StringBuilder();
if (BeanUtils.isNotEmpty(users)) {
boolean isFirst = true;
for (User user : users) {
if (isFirst) {
isFirst = false;
} else {
sbd.append("，");
}
sbd.append(user.getFullname());
}
}
return sbd.toString();
}
@Override
public IPage getRoleUserQuery(QueryFilter filter) {
PageBean pageBean = filter.getPageBean();
copyQuerysInParams(filter);
return baseMapper.getUserListByRoleCodeMap(convert2IPage(pageBean), convert2Wrapper(filter, currentModelClass()));
}
@Override
public IPage getOrgUserQuery(QueryFilter queryFilter) {
return baseMapper.getUserListByOrgQuery(convert2IPage(queryFilter.getPageBean()), convert2Wrapper(queryFilter, currentModelClass()));
}
@Override
public boolean showADButton() {
Properties sysProperties = propertiesService.getPropertiesByCode("ldaptime");
boolean flag = false;
if (BeanUtils.isNotEmpty(sysProperties)) {
if (StringUtil.isNotEmpty(sysProperties.getValue())) {
flag = true;
}
}
return flag;
}
/**
* 获取组织中用户为负责人的组织
*
* @param orgs
* @param userId
* @return
* @throws Exception
*/
@SuppressWarnings("unused")
private List getUserManagerOrgs(List orgs, String userId) throws Exception {
List list = new ArrayList();
for (Org org : orgs) {
if (isUserManagerInOrg(userId, org.getCode())) {
list.add(org);
}
}
return list;
}
/**
* 判断用户在该组织中是否负责人（1、组织中有责任岗位，则判断该用户是否在责任岗位中；2、组织中没有责任岗位，则判断该用户是否为（主）负责人）
*
* @param userId
* @param orgCode
* @return
* @throws Exception
*/
@SuppressWarnings("rawtypes")
private boolean isUserManagerInOrg(String userId, String orgCode) throws Exception {
boolean isIn = false;
List orgPosts = orgService.getPostsByOrgCodes(orgCode, true);
if (BeanUtils.isNotEmpty(orgPosts)) {
QueryFilter queryFilter = QueryFilter.build();
queryFilter.addFilter("orguser.user_id_", userId, QueryOP.EQUAL, FieldRelation.AND);
queryFilter.addFilter("orguser.pos_id_", orgPosts.get(0).getId(), QueryOP.EQUAL, FieldRelation.AND);
List orgUserList = this.queryOrgUserRel(queryFilter);
if (BeanUtils.isNotEmpty(orgUserList)) {
return true;
} else {
Org org = orgService.getByCode(orgCode);
if (BeanUtils.isNotEmpty(org)) {
List orgUsers = orgUserService.getListByOrgIdUserId(org.getId(), userId);
for (OrgUser orgUser : orgUsers) {
if (orgUser.getIsCharge() != 0) {
return true;
}
}
}
}
}
return isIn;
}
@Override
@Transactional
public void setStatus(UserStatusVo userStatusVo) throws Exception {
baseMapper.updateStatusByAccounts(userStatusVo.getStatus(), userStatusVo.getAccounts(), LocalDateTime.now());
}
@Override
public CommonResult isAccountExist(String account) throws Exception {
Integer amount = baseMapper.queryByAccount(account);
return new CommonResult(true, "", amount > 0);
}
@Override
public CommonResult isUserNumberExist(String account, String userNumber) throws Exception {
Integer amount = baseMapper.queryByUserNumber(account, userNumber);
return new CommonResult(true, "", amount > 0);
}
@Override
public CommonResult uploadPortrait(String account, MultipartFile file) throws Exception {
String finalName;
if (!file.isEmpty()) {
String originalFilename = file.getOriginalFilename();
String extName = getExtName(originalFilename);
finalName = UniqueIdUtil.getSuid() + extName;
Path path = Paths.get(attachPath, account, finalName);
Path parent = path.getParent();
if (Files.notExists(parent)) {
File dir = new File(parent.toString());
dir.mkdirs();
}
Files.copy(file.getInputStream(), path);
return new CommonResult(true, "上传成功", account + "/" + finalName);
} else {
throw new SystemException("Upload file is empty.");
}
}
private String getExtName(String fileName) {
Pattern regex = Pattern.compile("^.*(\\.\\w+)$");
Matcher regexMatcher = regex.matcher(fileName);
if (regexMatcher.matches()) {
return regexMatcher.group(1);
}
return null;
}
@Override
public Resource downloadPortrait(String account, String filename) throws Exception {
return resourceLoader.getResource("file:" + Paths.get(attachPath, account, filename).toString());
}
@Override
public IPage getDemUserQuery(QueryFilter filter) throws Exception {
PageBean pageBean = filter.getPageBean();
copyQuerysInParams(filter);
return baseMapper.getDemUserQuery(convert2IPage(pageBean), convert2Wrapper(filter, currentModelClass()));
}
@Override
public IPage getUserByOrgQuery(QueryFilter filter) throws Exception {
PageBean pageBean = filter.getPageBean();
copyQuerysInParams(filter);
return baseMapper.getUserByOrgQuery(convert2IPage(pageBean), convert2Wrapper(filter, currentModelClass()));
}
@Override
public CommonResult setTrigger(TriggerVo triggerVo, String ip)
throws Exception {
/*String values = triggerVo.getValues();
String cron = OrgUtil.getScheduledCron(values);
String logMsg = OrgUtil.getScheduledCronLog(values);
String type = triggerVo.getType();
if(ScheduledOaTask.SCHEDULED_OA.equals(type)){
scheduledOaTask.setCron(cron);
logMsg = "将OA同步定时计划修改为："+logMsg;
}else if(ScheduledAdTask.SCHEDULED_AD.equals(type)){
scheduledAdTask.setCron(cron);
logMsg = "将AD同步定时计划修改为："+logMsg;
}
Properties properties = propertiesDao.getByCode(type);
properties.setValue(triggerVo.getValues());
propertiesDao.update(properties, properties.getVersion());
String reqUrl = "/api/user/v1/user/setTrigger";
OperateLog log = new OperateLog(1, "POST", reqUrl, logMsg,values, "", "");
log.setReqIp(ip);
log.setEndTime(LocalDateTime.now());
OperateLogUtil.doLogAsync(log);*/
return new CommonResult(true, "任务执行计划设置成功！", "");
}
@Override
public CommonResult getUserById(String userId) throws Exception {
if (StringUtil.isEmpty(userId)) {
return new CommonResult(false, "获取用户失败，用户ID：“userId”不能为空！", null);
}
User user = this.get(userId);
if (BeanUtils.isEmpty(user)) {
return new CommonResult(false, "获取用户失败，用户ID为【" + userId + "】的用户不存在！", null);
}
UserVo userVo = new UserVo(user);
return new CommonResult(true, "设置成功！", userVo);
}
@Override
public PageList queryByType(QueryFilter queryFilter)
throws SystemException {
this.copyQuerysInParams(queryFilter);
handleQueryFilter(queryFilter);
PageBean pageBean = queryFilter.getPageBean();
if (BeanUtils.isEmpty(pageBean)) {
pageBean = new PageBean(1, 50, true);
}
IPage query = baseMapper.queryByType(convert2IPage(pageBean), convert2Wrapper(queryFilter, currentModelClass()));
return new PageList