| | |
| | | package cn.huge.module.ctuser.service; |
| | | |
| | | import cn.huge.base.common.dto.SelectTermDTO; |
| | | import cn.huge.base.common.exception.MethodException; |
| | | import cn.huge.base.common.exception.ServiceException; |
| | | import cn.huge.base.common.utils.DateUtils; |
| | | import cn.huge.base.common.utils.IdUtils; |
| | | import cn.huge.base.common.utils.ObjectUtils; |
| | | import cn.huge.base.common.utils.SelectTermUtils; |
| | | import cn.huge.module.client.api.impl.UtilsClientImpl; |
| | | import cn.huge.module.constant.BaseConsts; |
| | | import cn.huge.module.ctrole.domain.po.CtRole; |
| | | import cn.huge.module.ctuser.dao.mapper.CtUserMapper; |
| | | import cn.huge.module.ctuser.domain.po.CtUser; |
| | | import cn.huge.module.ctuser.domain.po.*; |
| | | import cn.huge.module.ctuser.dto.CtUserSaveDTO; |
| | | import cn.huge.module.cust.constant.RoleBaseEnum; |
| | | import cn.huge.module.cust.constant.UserBaseConsts; |
| | | import cn.huge.module.cust.dto.CtUserDTO; |
| | | import cn.huge.module.redis.constant.RedisKeyConsts; |
| | | import cn.huge.module.rsoper.domain.po.RsRole; |
| | | import cn.huge.module.rsoper.service.RsRoleService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.google.common.collect.Maps; |
| | | import org.apache.commons.collections.CollectionUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.domain.Sort; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.stereotype.Service; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.domain.Page; |
| | | import org.springframework.data.domain.PageImpl; |
| | | import org.springframework.data.domain.PageRequest; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.DigestUtils; |
| | | |
| | | import javax.annotation.PostConstruct; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | import java.util.stream.Stream; |
| | | |
| | | /** |
| | | * @title: 客户用户表业务逻辑处理 |
| | |
| | | public class CtUserService extends ServiceImpl<CtUserMapper, CtUser>{ |
| | | |
| | | @Autowired |
| | | private RedisTemplate<String, Object> redisTemplate; |
| | | |
| | | @Autowired |
| | | private CtUserMapper mapper; |
| | | @Autowired |
| | | private CtAccountService ctAccountService; |
| | | @Autowired |
| | | private CtUnitService ctUnitService; |
| | | @Autowired |
| | | private CtUseroleService ctUseroleService; |
| | | @Autowired |
| | | private CtUsepostService ctUsepostService; |
| | | @Autowired |
| | | private CtDeptService ctDeptService; |
| | | @Autowired |
| | | private RsRoleService rsRoleService; |
| | | |
| | | @Autowired |
| | | private UtilsClientImpl utilsClient; |
| | |
| | | } |
| | | |
| | | /** |
| | | * 新增或更新对象 |
| | | * @param ctUser 实体对象 |
| | | */ |
| | | public void saveCtUser(CtUser ctUser){ |
| | | * 新增对象 |
| | | * @param ctUser 实体对象 |
| | | */ |
| | | public void saveToRedis(CtUser ctUser){ |
| | | try{ |
| | | Date nowDate = DateUtils.getMowDate(); |
| | | // 判断是否新增 |
| | | if (IdUtils.checkNewId(ctUser.getId())){ |
| | | ctUser.setId(utilsClient.getNewTimeId()); |
| | | ctUser.setCreateTime(nowDate); |
| | | } |
| | | ctUser.setUpdateTime(nowDate); |
| | | this.saveOrUpdate(ctUser); |
| | | mapper.insert(ctUser); |
| | | // 清楚redis缓存 |
| | | String key = RedisKeyConsts.CTUSER + ctUser.getId(); |
| | | redisTemplate.delete(key); |
| | | // 重新set |
| | | redisTemplate.opsForValue().set(key, ctUser); |
| | | }catch (Exception e){ |
| | | log.error("[CtUserService.saveCtUser]调用失败,异常信息:"+e, e); |
| | | throw new ServiceException("CtUserService.saveCtUser", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 更新对象 |
| | | * @param ctUser 实体对象 |
| | | */ |
| | | public void updateToRedis(CtUser ctUser){ |
| | | try{ |
| | | mapper.updateById(ctUser); |
| | | // 清楚redis缓存 |
| | | String key = RedisKeyConsts.CTUSER + ctUser.getId(); |
| | | redisTemplate.delete(key); |
| | | // 重新set |
| | | redisTemplate.opsForValue().set(key, ctUser); |
| | | }catch (Exception e){ |
| | | log.error("[CtUserService.saveCtUser]调用失败,异常信息:"+e, e); |
| | | throw new ServiceException("CtUserService.saveCtUser", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 根据id查询 |
| | | * @param id 编号 |
| | | * @return |
| | | */ |
| | | public CtUser getByIdFromRedis(String id){ |
| | | String key = RedisKeyConsts.CTUSER + id; |
| | | // 从redis获取 |
| | | CtUser ctUser = (CtUser) redisTemplate.opsForValue().get(key); |
| | | if (ObjectUtils.isEmpty(ctUser)){ |
| | | ctUser = mapper.selectById(id); |
| | | if (ObjectUtils.isNotEmpty(ctUser)){ |
| | | redisTemplate.opsForValue().set(key, ctUser); |
| | | } |
| | | } |
| | | return ctUser; |
| | | } |
| | | |
| | | /** |
| | | * 重写根据id获取用户(id带有角色信息,如:1001&01) |
| | | * @param userId 登录用户编号 |
| | | * @return Object |
| | | */ |
| | | public CtUser getById(String userId) { |
| | | String loginUserId = ""; |
| | | if (userId.indexOf(BaseConsts.AND) != -1){ |
| | | String[] userIds = userId.split(BaseConsts.AND); |
| | | loginUserId = userIds[0]; |
| | | }else { |
| | | loginUserId = userId; |
| | | } |
| | | return mapper.selectById(loginUserId); |
| | | } |
| | | |
| | | public CtUser getByIdCard(String idCard) { |
| | | return mapper.selectByIdCard(idCard); |
| | | } |
| | | |
| | | /** |
| | | * web端-获取人员信息列表查询条件 |
| | | * @param userId 当前登录用户编号 |
| | | * @return |
| | | */ |
| | | public Map<String, Object> webListSelectTerm(String userId){ |
| | | try { |
| | | Map<String, Object> result = Maps.newHashMap(); |
| | | // 获取当前登录用户 |
| | | CtUserDTO loginUser = this.clientGetUserAll(userId); |
| | | // 组织条件 |
| | | List<CtUnit> ctUnits = ctUnitService.list(); |
| | | List<SelectTermDTO> unitSelectTerms = new ArrayList<>(); |
| | | for (CtUnit ctUnit : ctUnits) { |
| | | SelectTermDTO unitSelectTerm = new SelectTermDTO(); |
| | | unitSelectTerm.setValue(ctUnit.getId()); |
| | | unitSelectTerm.setLabel(ctUnit.getUnitName()); |
| | | unitSelectTerm.setParentId(ctUnit.getParentId()); |
| | | unitSelectTerms.add(unitSelectTerm); |
| | | |
| | | // 部门条件 |
| | | QueryWrapper<CtDept> ctDeptQueryWrapper = new QueryWrapper<>(); |
| | | ctDeptQueryWrapper.eq("unit_id", ctUnit.getId()); |
| | | List<CtDept> ctDepts = ctDeptService.list(ctDeptQueryWrapper); |
| | | if (CollectionUtils.isNotEmpty(ctDepts)) { |
| | | List<SelectTermDTO> deptSelectTerms = new ArrayList<>(); |
| | | for (CtDept ctDept : ctDepts) { |
| | | SelectTermDTO deptSelectTerm = new SelectTermDTO(); |
| | | deptSelectTerm.setValue(ctDept.getId()); |
| | | deptSelectTerm.setLabel(ctDept.getName()); |
| | | deptSelectTerm.setParentId(ctDept.getParentId()); |
| | | deptSelectTerms.add(deptSelectTerm); |
| | | } |
| | | List<SelectTermDTO> depts = SelectTermUtils.createTreeByRoot(deptSelectTerms); |
| | | unitSelectTerm.setChainList(depts); |
| | | } |
| | | } |
| | | result.put("units", SelectTermUtils.createTreeByFirst(unitSelectTerms, loginUser.getUnitId())); |
| | | |
| | | // 查询可选角色 |
| | | List<SelectTermDTO> roleSelectTerms = new ArrayList<>(); |
| | | List<RsRole> rsRoleList = rsRoleService.list(); |
| | | for (RsRole rsRole : rsRoleList) { |
| | | SelectTermDTO selectTerm = new SelectTermDTO(); |
| | | selectTerm.setValue(rsRole.getId()); |
| | | selectTerm.setLabel(rsRole.getName()); |
| | | roleSelectTerms.add(selectTerm); |
| | | } |
| | | result.put("roles", roleSelectTerms); |
| | | return result; |
| | | }catch (Exception e){ |
| | | log.error("[CtUserService.webListSelectTerm]调用失败,异常信息:"+e, e); |
| | | throw new ServiceException("CtUserService.webListSelectTerm", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * web端-人员信息管理-人员列表 |
| | | * @param page 分页对象 |
| | | * @param terms 条件 |
| | | * @return Page |
| | | */ |
| | | public Map<String, Object> webPageQuery(int page, int size, Map<String, Object> terms, String userId){ |
| | | try { |
| | | // 获取当前登录用户 |
| | | CtUserDTO loginUser = this.clientGetUserAll(userId); |
| | | Map<String, Object> result = Maps.newHashMap(); |
| | | // todo 角色数据权限 |
| | | |
| | | Sort sort = Sort.by(Sort.Direction.DESC, "t1.create_time"); |
| | | PageRequest pageRequest = PageRequest.of(page - 1, size, sort); |
| | | Page<CtUser> ctUserPage = this.pageUserAndRole(pageRequest, terms); |
| | | QueryWrapper<CtAccount> accountQueryWrapper = new QueryWrapper<>(); |
| | | QueryWrapper<CtUserole> ctUseroleQueryWrapper = new QueryWrapper<>(); |
| | | QueryWrapper<CtUsepost> ctUsepostQueryWrapper = new QueryWrapper<>(); |
| | | for (CtUser ctUser : ctUserPage) { |
| | | accountQueryWrapper.clear(); |
| | | // 密码 |
| | | accountQueryWrapper.eq("acc_type", UserBaseConsts.ACC_TYPE_1); |
| | | accountQueryWrapper.eq("user_id", ctUser.getId()); |
| | | CtAccount ctAccount = ctAccountService.getOne(accountQueryWrapper); |
| | | if (ObjectUtils.isNotEmpty(ctAccount)) { |
| | | ctUser.setAcc(ctAccount.getAcc()); |
| | | ctUser.setCipher(ctAccount.getCipherOpen()); |
| | | } |
| | | // 角色 |
| | | ctUseroleQueryWrapper.clear(); |
| | | ctUseroleQueryWrapper.eq("user_id", ctUser.getId()); |
| | | List<CtUserole> ctUseroleList = ctUseroleService.list(ctUseroleQueryWrapper); |
| | | if (ObjectUtils.isNotEmpty(ctUseroleList)) { |
| | | for (CtUserole ctUserole : ctUseroleList) { |
| | | ctUserole.setRoleId(ctUserole.getRoleCode()); |
| | | } |
| | | ctUser.setCtUseroleList(ctUseroleList); |
| | | } |
| | | // 岗位 |
| | | ctUsepostQueryWrapper.clear(); |
| | | ctUsepostQueryWrapper.eq("user_id", ctUser.getId()); |
| | | List<CtUsepost> ctUsepostList = ctUsepostService.list(ctUsepostQueryWrapper); |
| | | if (ObjectUtils.isNotEmpty(ctUsepostList)) { |
| | | ctUser.setCtUsepostList(ctUsepostList); |
| | | } |
| | | } |
| | | result.put("ctUserPage", ctUserPage); |
| | | terms = Maps.newHashMap(); |
| | | // 生效名额 |
| | | terms.put("status", UserBaseConsts.USER_STATUS_1); |
| | | // todo 角色数据权限 |
| | | |
| | | long countZzStatus = this.countTerms(terms); |
| | | result.put("countZzStatus", countZzStatus); |
| | | return result; |
| | | }catch (Exception e){ |
| | | log.error("[CtUserService.webPageQuery]调用失败,异常信息:"+e, e); |
| | | throw new ServiceException("CtUserService.webPageQuery", e); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * web端-人员信息管理-新增/新用户信息 |
| | | * @param ctUserSaveDTO 提交用户信息 |
| | | * @param userId 当前登录用户编号 |
| | | */ |
| | | public void webSaveCtUser(CtUserSaveDTO ctUserSaveDTO, String userId) { |
| | | try { |
| | | // 获取当前登录用户 |
| | | CtUser loginUser = this.getById(userId); |
| | | Date nowDate = DateUtils.getNowDate(); |
| | | // 判断是否新增 |
| | | CtUser ctUser = new CtUser(); |
| | | BeanUtils.copyProperties(ctUserSaveDTO, ctUser); |
| | | ctUser.setUpdateTime(nowDate); |
| | | if (IdUtils.checkNewId(ctUser.getId())) { |
| | | ctUser.setId(utilsClient.getNewTimeId()); |
| | | ctUser.setCreateTime(nowDate); |
| | | ctUser.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
| | | ctUser.setJoinWay(UserBaseConsts.JOIN_WAY_1); |
| | | ctUser.setRealStatus(UserBaseConsts.REAL_STATUS_0); |
| | | ctUser.setStatus(UserBaseConsts.USER_STATUS_1); |
| | | ctUser.setCustId(loginUser.getCustId()); |
| | | mapper.insert(ctUser); |
| | | |
| | | // 创建账号 |
| | | CtAccount ctAccount = ctAccountService.getByAccAndType(ctUser.getAcc(), UserBaseConsts.ACC_TYPE_1); |
| | | if (ObjectUtils.isNotEmpty(ctAccount)) { |
| | | throw new ServiceException("账号已存在,请重新输入!"); |
| | | } else { |
| | | ctAccount = new CtAccount(); |
| | | ctAccount.setCustId(ctUser.getCustId()); |
| | | ctAccount.setId(utilsClient.getNewTimeId()); |
| | | ctAccount.setUserId(ctUser.getId()); |
| | | ctAccount.setAccType(UserBaseConsts.ACC_TYPE_1); |
| | | ctAccount.setAcc(ctUser.getAcc()); |
| | | ctAccount.setCipher(DigestUtils.md5DigestAsHex(ctUserSaveDTO.getCipher().getBytes())); |
| | | ctAccount.setCipherOpen(ctUserSaveDTO.getCipher()); |
| | | ctAccount.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
| | | ctAccount.setCreateTime(nowDate); |
| | | ctAccount.setCipherTime(nowDate); |
| | | ctAccount.setUpdateTime(nowDate); |
| | | ctAccountService.save(ctAccount); |
| | | } |
| | | |
| | | // 保存角色 |
| | | List<CtUserole> ctUseroleList = ctUserSaveDTO.getCtUseroleList(); |
| | | for (CtUserole ctUserole : ctUseroleList) { |
| | | ctUserole.setId(utilsClient.getNewTimeId()); |
| | | ctUserole.setUserId(ctUser.getId()); |
| | | RsRole rsRole = rsRoleService.getById(ctUserole.getRoleId()); |
| | | ctUserole.setRoleId(rsRole.getId()); |
| | | ctUserole.setRoleCode(rsRole.getId()); |
| | | ctUserole.setCustId(ctUser.getCustId()); |
| | | ctUserole.setCreateTime(nowDate); |
| | | ctUserole.setUpdateTime(nowDate); |
| | | ctUseroleService.save(ctUserole); |
| | | } |
| | | |
| | | // 岗位 |
| | | List<CtUsepost> ctUsepostList = ctUserSaveDTO.getCtUsepostList(); |
| | | if (ObjectUtils.isNotEmpty(ctUsepostList)) { |
| | | for (CtUsepost ctUsepost : ctUsepostList) { |
| | | ctUsepost.setId(utilsClient.getNewTimeId()); |
| | | ctUsepost.setUserId(ctUser.getId()); |
| | | ctUsepost.setUnitId(ctUser.getUnitId()); |
| | | ctUsepost.setDeptId(ctUser.getDeptId()); |
| | | ctUsepost.setMatchType(UserBaseConsts.MATCH_TYPE_1); |
| | | ctUsepost.setCustId(ctUser.getCustId()); |
| | | ctUsepost.setCreateTime(nowDate); |
| | | ctUsepost.setUpdateTime(nowDate); |
| | | ctUsepostService.save(ctUsepost); |
| | | } |
| | | } |
| | | } else { |
| | | // 修改用户信息 |
| | | mapper.updateById(ctUser); |
| | | |
| | | // 修改账号信息 |
| | | CtAccount ctAccount = ctAccountService.getByUserIdAndType(ctUser.getId(), UserBaseConsts.ACC_TYPE_1); |
| | | if (!ctAccount.getAcc().equals(ctUser.getAcc())) { |
| | | CtAccount oldAccount = ctAccountService.getByAccAndType(ctUser.getAcc(), UserBaseConsts.ACC_TYPE_1); |
| | | if (ObjectUtils.isNotEmpty(oldAccount)) { |
| | | throw new MethodException("修改后的账号已存在,请重新输入!"); |
| | | } else { |
| | | ctAccount.setAcc(ctUser.getAcc()); |
| | | } |
| | | } |
| | | ctAccount.setCipher(DigestUtils.md5DigestAsHex(ctUserSaveDTO.getCipher().getBytes())); |
| | | ctAccount.setCipherOpen(ctUserSaveDTO.getCipher()); |
| | | ctAccount.setCipherTime(nowDate); |
| | | ctAccount.setUpdateTime(nowDate); |
| | | ctAccountService.updateById(ctAccount); |
| | | |
| | | // 修改角色信息 |
| | | ctUseroleService.deleteByUserId(ctUser.getId()); |
| | | List<CtUserole> ctUseroleList = ctUserSaveDTO.getCtUseroleList(); |
| | | for (CtUserole ctUserole : ctUseroleList) { |
| | | ctUserole.setId(utilsClient.getNewTimeId()); |
| | | ctUserole.setUserId(ctUser.getId()); |
| | | ctUserole.setCustId(ctUser.getCustId()); |
| | | RsRole rsRole = rsRoleService.getById(ctUserole.getRoleId()); |
| | | ctUserole.setRoleId(rsRole.getId()); |
| | | ctUserole.setRoleCode(rsRole.getId()); |
| | | ctUserole.setCreateTime(nowDate); |
| | | ctUserole.setUpdateTime(nowDate); |
| | | ctUseroleService.save(ctUserole); |
| | | } |
| | | |
| | | // 修改岗位信息 |
| | | ctUsepostService.deleteByUserId(ctUser.getId()); |
| | | List<CtUsepost> ctUsepostList = ctUserSaveDTO.getCtUsepostList(); |
| | | if (ObjectUtils.isNotEmpty(ctUsepostList)) { |
| | | for (CtUsepost ctUsepost : ctUsepostList) { |
| | | ctUsepost.setId(utilsClient.getNewTimeId()); |
| | | ctUsepost.setUserId(ctUser.getId()); |
| | | ctUsepost.setUnitId(ctUser.getUnitId()); |
| | | ctUsepost.setDeptId(ctUser.getDeptId()); |
| | | ctUsepost.setMatchType(UserBaseConsts.MATCH_TYPE_1); |
| | | ctUsepost.setCustId(ctUser.getCustId()); |
| | | ctUsepost.setCreateTime(nowDate); |
| | | ctUsepost.setUpdateTime(nowDate); |
| | | ctUsepostService.save(ctUsepost); |
| | | } |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("service方法[CtUserService.webSaveCtUser]调用异常:" + e, e); |
| | | throw new MethodException(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 按条件分页查询 |
| | | * |
| | | * @param page 分页对象 |
| | | * @param terms 条件 |
| | | * @return Page |
| | | */ |
| | | public Page<CtUser> pageUserAndRole(PageRequest page, Map<String, Object> terms) { |
| | | long total = mapper.countQueryCtUser(terms); |
| | | List<CtUser> content = mapper.pageQueryCtUser(page, terms); |
| | | return new PageImpl<CtUser>(content, page, total); |
| | | } |
| | | |
| | | /** |
| | | * 获取当前登录用户,获取用户所有信息(用户信息、角色等) |
| | | * @param userId 登录用户编号 |
| | | * @return Object |
| | | */ |
| | | public CtUserDTO clientGetUserAll(String userId) { |
| | | String loginUserId = ""; |
| | | String loginRoleCode = ""; |
| | | if (userId.indexOf(BaseConsts.AND) != -1){ |
| | | String[] userIds = userId.split(BaseConsts.AND); |
| | | loginUserId = userIds[0]; |
| | | loginRoleCode = userIds[1]; |
| | | }else { |
| | | loginUserId = userId; |
| | | } |
| | | // 用户信息 |
| | | CtUser ctUser = mapper.selectById(loginUserId); |
| | | if (ObjectUtils.isNotEmpty(ctUser)){ |
| | | CtUserDTO ctUserDTO = new CtUserDTO(); |
| | | BeanUtils.copyProperties(ctUser, ctUserDTO); |
| | | // 角色代码 |
| | | if (StringUtils.isEmpty(loginRoleCode)) { |
| | | List<String> roleCodeList = ctUseroleService.listRoleCode(loginUserId); |
| | | String userRole = roleCodeList.stream().map(String::valueOf).collect(Collectors.joining(",")); |
| | | ctUserDTO.setRoleCodes(userRole); |
| | | }else { |
| | | ctUserDTO.setRoleCodes(loginRoleCode); |
| | | } |
| | | return ctUserDTO; |
| | | }else { |
| | | return null; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 批量删除 |
| | | * @param data 批量id对象 |
| | | */ |
| | | public void removeListId(List<String> data) { |
| | | for (String id : data) { |
| | | // 查询人员信息 |
| | | CtUser ctUser = this.getById(id); |
| | | // 删除人员 |
| | | this.removeById(id); |
| | | // 删除账号 |
| | | UpdateWrapper<CtAccount> ctAccountUpdateWrapper = new UpdateWrapper(); |
| | | ctAccountUpdateWrapper.eq("user_id", ctUser.getId()); |
| | | ctAccountService.remove(ctAccountUpdateWrapper); |
| | | // 删除人员岗位 |
| | | UpdateWrapper<CtUsepost> ctUsepostUpdateWrapper = new UpdateWrapper(); |
| | | ctUsepostUpdateWrapper.eq("user_id", ctUser.getId()); |
| | | ctUsepostService.remove(ctUsepostUpdateWrapper); |
| | | // 删除人员角色 |
| | | UpdateWrapper<CtUserole> ctUseroleUpdateWrapper = new UpdateWrapper(); |
| | | ctUseroleUpdateWrapper.eq("user_id", ctUser.getId()); |
| | | ctUseroleService.remove(ctUseroleUpdateWrapper); |
| | | //更新部门和组织的调解专长和范围 |
| | | this.updateField("unit", ctUser.getUnitId()); |
| | | this.updateField("dept", ctUser.getDeptId()); |
| | | } |
| | | } |
| | | |
| | | private void updateField(String tag, String targetId){ |
| | | QueryWrapper query = new QueryWrapper(); |
| | | if("unit".equals(tag)){ |
| | | query.eq("unit_id", targetId); |
| | | }else if("dept".equals(tag)){ |
| | | query.eq("dept_id", targetId); |
| | | } |
| | | List<CtUser> ctUser1 = mapper.selectList(query); |
| | | Set<String> setGoodField = new HashSet<>(); |
| | | Set<String> setGoodFieldName = new HashSet<>(); |
| | | Set<String> setCanField = new HashSet<>(); |
| | | Set<String> setCanFieldName = new HashSet<>(); |
| | | String goodField = new String(); |
| | | String goodFieldName = new String(); |
| | | String canField = new String(); |
| | | String canFieldName = new String(); |
| | | if(CollectionUtils.isNotEmpty(ctUser1)){ |
| | | for(CtUser ctUsers1: ctUser1){ |
| | | if (StringUtils.isNotEmpty(ctUsers1.getGoodField())) { |
| | | setGoodField.addAll(Stream.of(ctUsers1.getGoodField().split(",")).collect(Collectors.toSet())); |
| | | setGoodFieldName.addAll(Stream.of(ctUsers1.getGoodFieldName().split(",")).collect(Collectors.toSet())); |
| | | } |
| | | if (StringUtils.isNotEmpty(ctUsers1.getCanField())) { |
| | | setCanField.addAll(Stream.of(ctUsers1.getCanField().split(",")).collect(Collectors.toSet())); |
| | | setCanFieldName.addAll(Stream.of(ctUsers1.getCanFieldName().split(",")).collect(Collectors.toSet())); |
| | | } |
| | | } |
| | | goodField = String.join(",", setGoodField); |
| | | goodFieldName = String.join(",", setGoodFieldName); |
| | | canField = String.join(",", setCanField); |
| | | canFieldName = String.join(",", setCanFieldName); |
| | | } |
| | | if("unit".equals(tag)){ |
| | | CtUnit ctUnit = new CtUnit(); |
| | | ctUnit.setId(targetId); |
| | | ctUnit.setGoodField(goodField); |
| | | ctUnit.setGoodFieldName(goodFieldName); |
| | | ctUnit.setCanField(canField); |
| | | ctUnit.setCanFieldName(canFieldName); |
| | | ctUnit.setUpdateTime(DateUtils.getNowDate()); |
| | | ctUnitService.updateTerms(ctUnit); |
| | | }else if("dept".equals(tag)){ |
| | | CtDept ctDept = new CtDept(); |
| | | ctDept.setId(targetId); |
| | | ctDept.setGoodField(goodField); |
| | | ctDept.setGoodFieldName(goodFieldName); |
| | | ctDept.setCanField(canField); |
| | | ctDept.setCanFieldName(canFieldName); |
| | | ctDept.setUpdateTime(DateUtils.getNowDate()); |
| | | ctDeptService.updateCtDept(ctDept); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 根据部门和角色查询 |
| | | * @param unitId 组织编号 |
| | | * @param roleCode 角色代码 |
| | | * @return List<SelectTermDTO> |
| | | */ |
| | | public List<CtUser> listUserByDeptRoleList(String unitId, String roleCode){ |
| | | return mapper.listUserByUnitRoleList(unitId, roleCode); |
| | | } |
| | | |
| | | /** |
| | | * 选择人员 |
| | | * @param userId |
| | | * @param roleCode |
| | | * @return |
| | | */ |
| | | public List<SelectTermDTO> userChoose(String userId, String roleCode) { |
| | | try { |
| | | // 获取当前登录用户 |
| | | CtUserDTO loginUser = clientGetUserAll(userId); |
| | | List<SelectTermDTO> result = new ArrayList<>(); |
| | | // 人员条件 |
| | | List<CtUser> ctUsers = null; |
| | | if (StringUtils.isNotEmpty(roleCode)){ |
| | | ctUsers = listUserByDeptRoleList(loginUser.getUnitId(), roleCode); |
| | | }else { |
| | | QueryWrapper<CtUser> ctUserQueryWrapper = new QueryWrapper<>(); |
| | | ctUserQueryWrapper.in("unit_id", loginUser.getUnitId()).select("id", "true_name"); |
| | | ctUsers = this.list(ctUserQueryWrapper); |
| | | } |
| | | SelectTermDTO unitSelectTerm = new SelectTermDTO(); |
| | | unitSelectTerm.setValue(loginUser.getUnitId()); |
| | | unitSelectTerm.setLabel(loginUser.getUnitName()); |
| | | unitSelectTerm.setCheckable(false); |
| | | List<SelectTermDTO> userSelectTerms = new ArrayList<>(); |
| | | for(CtUser ctUser : ctUsers){ |
| | | SelectTermDTO userSelectTerm = new SelectTermDTO(); |
| | | userSelectTerm.setValue(ctUser.getId()); |
| | | userSelectTerm.setCheckable(true); |
| | | userSelectTerm.setLabel(ctUser.getTrueName()); |
| | | userSelectTerms.add(userSelectTerm); |
| | | } |
| | | unitSelectTerm.setChildren(userSelectTerms); |
| | | result.add(unitSelectTerm); |
| | | return result; |
| | | }catch (Exception e) { |
| | | log.error("[CtUserService.userChoose]调用失败,异常信息:" + e, e); |
| | | throw new ServiceException("CtUserService.userChoose", e); |
| | | } |
| | | } |
| | | } |