package com.gkhy.labRiskManage.domain.account.service.impl;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.gkhy.labRiskManage.api.controller.account.query.UserQuery;
|
import com.gkhy.labRiskManage.commons.domain.Result;
|
import com.gkhy.labRiskManage.commons.domain.SearchResult;
|
import com.gkhy.labRiskManage.commons.enums.ResultCode;
|
import com.gkhy.labRiskManage.commons.enums.SystemCacheKeyEnum;
|
import com.gkhy.labRiskManage.commons.exception.BusinessException;
|
import com.gkhy.labRiskManage.commons.model.PageQuery;
|
import com.gkhy.labRiskManage.commons.utils.BeanCopyUtils;
|
import com.gkhy.labRiskManage.domain.account.converter.UserInfoDomainConverter;
|
import com.gkhy.labRiskManage.domain.account.entity.SysUserIdentityBind;
|
import com.gkhy.labRiskManage.domain.account.entity.SysUserRoleBind;
|
import com.gkhy.labRiskManage.domain.account.entity.User;
|
import com.gkhy.labRiskManage.domain.account.enums.IdentityStatusEnum;
|
import com.gkhy.labRiskManage.domain.account.enums.UserIdTypeEnum;
|
import com.gkhy.labRiskManage.domain.account.enums.UserStatusEnum;
|
import com.gkhy.labRiskManage.domain.account.model.bo.CreateUserBO;
|
import com.gkhy.labRiskManage.domain.account.model.bo.UpdateUserBO;
|
import com.gkhy.labRiskManage.domain.account.model.dto.SysDepartmentDomainDTO;
|
import com.gkhy.labRiskManage.domain.account.repository.jpa.UserRepository;
|
import com.gkhy.labRiskManage.domain.account.service.RoleDomainService;
|
import com.gkhy.labRiskManage.domain.account.service.SysDepartmentDomainService;
|
import com.gkhy.labRiskManage.domain.account.service.UserDomainService;
|
import com.gkhy.labRiskManage.domain.account.model.dto.UserInfoDomainDTO;
|
import com.google.common.collect.Range;
|
import com.google.common.hash.Hashing;
|
import org.redisson.api.RMapCache;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.data.domain.Pageable;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.jpa.domain.Specification;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
|
import javax.persistence.criteria.*;
|
import java.nio.charset.StandardCharsets;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Optional;
|
import java.util.concurrent.TimeUnit;
|
|
@Service
|
public class UserDomainServiceImpl implements UserDomainService {
|
|
@Autowired
|
private UserRepository userRepository;
|
|
@Autowired
|
private RedissonClient redissonClient;
|
|
@Autowired
|
private ObjectMapper objectMapper;
|
|
@Autowired
|
private UserInfoDomainConverter userInfoDomainConverter;
|
|
@Autowired
|
private RoleDomainService roleDomainService;
|
|
@Autowired
|
private SysDepartmentDomainService departmentDomainService;
|
|
@Override
|
@Transactional
|
public UserInfoDomainDTO newUser(CreateUserBO createUserBO) {
|
if(createUserBO == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
User user = new User();
|
user.setName(createUserBO.getName());
|
user.setRealName(createUserBO.getRealName());
|
user.setStatus(UserStatusEnum.STATUS_ACTIVE.getStatus());
|
user.setSalt(genPasswordSalt());
|
user.setHash(genPasswordHash(createUserBO.getPwd(), user.getSalt()));
|
|
//校验用户名称
|
User userInfo = userRepository.findUserByName(createUserBO.getName());
|
if(userInfo != null){
|
throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR,"该用户名称已存在");
|
}
|
//部门校验
|
SysDepartmentDomainDTO dep = departmentDomainService.findById(createUserBO.getDepId());
|
if(dep == null){
|
throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR_OBJECT_NOT_EXIST.getCode(),"部门不存在");
|
}
|
user.setDepId(dep.getId());
|
//校验证件
|
if(UserIdTypeEnum.prase(createUserBO.getIdType()) == null){
|
throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(),"证件类型不支持");
|
}
|
/*User checkUser = userRepository.findByIdTypeAndIdSerial(createUserBO.getIdType(), createUserBO.getIdSerial());
|
if(checkUser != null){
|
throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(),"证件已经被使用");
|
}*/
|
//手机号校验
|
User checkUser = userRepository.findUserByPhone(createUserBO.getPhone());
|
if(checkUser != null){
|
throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(),"手机号已经被使用");
|
}
|
if(IdentityStatusEnum.prase(createUserBO.getIdentityStatus()) == null){
|
throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_ILLEGAL.getCode(),"用户用户身份不合法");
|
}
|
user.setPhone(createUserBO.getPhone());
|
user.setIdType(createUserBO.getIdType());
|
user.setIdSerial(createUserBO.getIdSerial());
|
user.setGmtCreate(LocalDateTime.now());
|
user.setGmtModified(LocalDateTime.now());
|
user.setIdentityStatus(createUserBO.getIdentityStatus());
|
user.setQualificationAttId(createUserBO.getQualificationAttId());
|
|
if(userRepository.save(user) != null){
|
UserInfoDomainDTO userInfoDomainDTO = new UserInfoDomainConverter().toUserInfoDTO(user);
|
return userInfoDomainDTO;
|
}else {
|
throw new BusinessException(this.getClass(), ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(), "数据库错误");
|
}
|
}
|
|
@Transactional
|
@Override
|
public UserInfoDomainDTO updateUserInfo(UpdateUserBO updateUserBO) {
|
if(updateUserBO == null || updateUserBO.getId() == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
if(updateUserBO.getName() == null || updateUserBO.getName().isEmpty())
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "用户名不能为空");
|
if(updateUserBO.getRealName() == null || updateUserBO.getRealName().isEmpty())
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "真实姓名不能为空");
|
if(updateUserBO.getIdType() == null || UserIdTypeEnum.prase(updateUserBO.getIdType()) == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "证件类型不支持");
|
SysDepartmentDomainDTO dep = departmentDomainService.findById(updateUserBO.getDepId());
|
if(dep == null){
|
throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR_OBJECT_NOT_EXIST.getCode(),"部门不存在");
|
}
|
Optional<User> userOptional = userRepository.findById(updateUserBO.getId());
|
if(!userOptional.isPresent()){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
}
|
//校验手机号
|
UserInfoDomainDTO u = findUserByPhone(updateUserBO.getPhone());
|
if(u != null && !u.getId().equals(updateUserBO.getId())){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED, "手机号已经被使用");
|
}
|
|
User user = userOptional.get();
|
user.setName(updateUserBO.getName());
|
user.setRealName(updateUserBO.getRealName());
|
user.setIdType(updateUserBO.getIdType());
|
user.setIdSerial(updateUserBO.getIdSerial());
|
user.setDepId(updateUserBO.getDepId());
|
user.setPhone(updateUserBO.getPhone());
|
user.setIdentityStatus(updateUserBO.getIdentityStatus());
|
user.setQualificationAttId(updateUserBO.getQualificationAttId());
|
//写库
|
User saveUserRs = userRepository.save(user);
|
return userInfoDomainConverter.toUserInfoDTO(saveUserRs);
|
}
|
|
@Override
|
public UserInfoDomainDTO getUserInfoById(Long uid) {
|
if(uid == null || uid < 0)
|
return null;
|
//1、先从redis缓存加载
|
// Object cacheUserObj = redissonClient.getMapCache(SystemCacheKeyEnum.KEY_CACHE_USER.getKey()).get(""+uid);
|
// if(cacheUserObj != null){
|
// String cacheUserJson = (String)cacheUserObj;
|
// User cacheUser = null;
|
// try {
|
// cacheUser = objectMapper.readValue(cacheUserJson,User.class);
|
// } catch (JsonProcessingException e) {
|
// e.printStackTrace();
|
// }
|
// //2、缓存命中，直接返回
|
// if(cacheUser != null){
|
// UserInfoDTO userInfoDTO = new UserInfoConverter().toUserInfoDTO(cacheUser);
|
// return userInfoDTO;
|
// }
|
// }
|
//3、缓存未命中，入库查
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent()){
|
return null;
|
}
|
User user = userOptional.get();
|
//获取角色信息
|
// RoleInfoDoaminDTO roleInfoDoaminDTO = roleDomainService.findRoleById(user.getRoleId());
|
UserInfoDomainDTO userInfoDomainDTO = new UserInfoDomainConverter().toUserInfoDTO(user);
|
// if(roleInfoDoaminDTO != null)
|
// userInfoDomainDTO.setRole(roleInfoDoaminDTO);
|
//重置缓存数据
|
// resetUserCache(user);
|
return userInfoDomainDTO;
|
}
|
|
@Override
|
public UserInfoDomainDTO getUserInfoByName(String name) {
|
if(name == null || name.isEmpty())
|
return null;
|
User user = userRepository.findUserByName(name);
|
if(user == null)
|
return null;
|
UserInfoDomainDTO userInfoDomainDTO = new UserInfoDomainConverter().toUserInfoDTO(user);
|
return userInfoDomainDTO;
|
}
|
|
@Override
|
public List<UserInfoDomainDTO> findUserListByRealName(String name) {
|
if(name == null || name.isEmpty())
|
return null;
|
List<User> userList = userRepository.getUsersByRealName(name);
|
if(userList == null || userList.isEmpty())
|
return null;
|
List<UserInfoDomainDTO> dtoList = new ArrayList<>();
|
userList.forEach(u -> {
|
dtoList.add(userInfoDomainConverter.toUserInfoDTO(u));
|
});
|
return dtoList;
|
}
|
|
@Override
|
public SearchResult<List<UserInfoDomainDTO>> findUserListByRole(Long roleId, boolean usePage, Integer page,
|
Integer pageSize) {
|
SearchResult<List<UserInfoDomainDTO>> result = new SearchResult<>();
|
result.setSuccess();
|
result.setUsePage(usePage);
|
if(roleId == null || roleId < 0)
|
return null;
|
Specification<User> userSpecification = new Specification<User>() {
|
@Override
|
public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
|
List<Predicate> predicateList = new ArrayList<>();
|
predicateList.add(root.get("status").in(UserStatusEnum.getActiveUserStatus()));
|
Join<User, SysUserRoleBind> userRoleJion = root.join("sysUserRoleBinds", JoinType.LEFT);
|
predicateList.add(criteriaBuilder.equal(userRoleJion.get("roleId"), roleId));
|
|
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
|
}
|
};
|
PageRequest pageRequest = null;
|
if(usePage == true){
|
if(page <= 0){
|
page = 1;
|
result.setPageIndex(1);
|
}
|
if(pageSize <= 0 || pageSize > 50){
|
pageSize = 20;
|
result.setPageSize(20);
|
}
|
pageRequest = PageRequest.of(page-1,pageSize);
|
}
|
List<User> userList = null;
|
if(pageRequest != null){
|
Page<User> userListPage = userRepository.findAll(userSpecification,pageRequest);
|
result.setTotal(userListPage.getTotalElements());
|
result.setPages(userListPage.getTotalPages());
|
result.setPageIndex(page);
|
result.setPageSize(userListPage.getSize());
|
userList = userListPage.getContent();
|
}else {
|
userList = userRepository.findAll(userSpecification);
|
}
|
if(userList != null && !userList.isEmpty()){
|
result.setCount(userList.size());
|
result.setData(userInfoDomainConverter.toDomainUserInfoList(userList));
|
}
|
return result;
|
}
|
|
@Override
|
public List<UserInfoDomainDTO> getUserInfoListByIds(List<Long> uidList) {
|
if(uidList == null || uidList.size() == 0)
|
return null;
|
List<User> userList = userRepository.findAllByIdIn(uidList);
|
if(userList == null || userList.size() == 0)
|
return null;
|
List<UserInfoDomainDTO> doList = new ArrayList<>();
|
UserInfoDomainConverter converter = new UserInfoDomainConverter();
|
for(User u : userList){
|
UserInfoDomainDTO userInfoDomainDTO = converter.toUserInfoDTO(u);
|
doList.add(userInfoDomainDTO);
|
}
|
return doList;
|
}
|
|
@Override
|
@Transactional
|
public boolean updateUserPwd(Long uid, String oldPwd, String newPwd) {
|
if(uid == null || oldPwd == null || newPwd == null || oldPwd.isEmpty() || newPwd.isEmpty())
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent()){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
}
|
User user = userOptional.get();
|
//验证旧密码
|
String hash = String.valueOf(Hashing.hmacMd5(user.getSalt().getBytes(StandardCharsets.UTF_8)).hashString(oldPwd,
|
StandardCharsets.UTF_8));
|
if(!hash.equals(user.getHash()))
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "旧密码错误");
|
String newSalt = String.valueOf(Hashing.hmacMd5("".getBytes()).hashString(""+uid+Range.atLeast(1)+System.nanoTime(),
|
StandardCharsets.UTF_8));
|
String newHash = String.valueOf(Hashing.hmacMd5(newSalt.getBytes(StandardCharsets.UTF_8)).hashString(newPwd,
|
StandardCharsets.UTF_8));
|
if(userRepository.updatePassword(uid,newHash,newSalt, LocalDateTime.now()) == 1){
|
// deleteUserCache(uid);
|
return true;
|
}else {
|
throw new BusinessException(this.getClass(), ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(), "数据库错误");
|
}
|
}
|
|
@Override
|
@Transactional
|
public boolean updateUserStatus(Long uid, Byte status) {
|
if(uid == null || status == null || UserStatusEnum.prase(status) == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent()){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
}
|
User user = userOptional.get();
|
if(user.getStatus().equals(status))
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "用户状态未发生改变");
|
if(userRepository.updateUserStatus(uid,status,LocalDateTime.now()) == 1){
|
// deleteUserCache(uid);
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
@Transactional
|
public boolean updateUserRole(Long uid, Long roleId) {
|
if(uid == null || roleId == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent()){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
}
|
User user = userOptional.get();
|
/*if(user.getRoleId() != null && user.getRoleId().equals(roleId))
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "用户角色未发生改变");*/
|
//todo:校验角色信息
|
/*if(userRepository.updateUserRole(uid,roleId,LocalDateTime.now()) != null){
|
// deleteUserCache(uid);
|
return true;
|
}*/
|
return false;
|
}
|
|
@Override
|
public boolean checkPassword(String pwd, String hash, String salt) {
|
if(pwd == null || pwd.isEmpty() || salt == null || salt.isEmpty() || hash == null || hash.isEmpty())
|
return false;
|
if(Hashing.hmacMd5(salt.getBytes(StandardCharsets.UTF_8)).hashString(pwd, StandardCharsets.UTF_8).toString().equals(hash)){
|
return true;
|
}else {
|
return false;
|
}
|
}
|
|
@Override
|
public UserInfoDomainDTO findUserByPhone(String phoneNumber) {
|
if(phoneNumber == null || phoneNumber.isEmpty() || phoneNumber.length() < 11)
|
return null;
|
User user = userRepository.findUserByPhone(phoneNumber);
|
if(user == null)
|
return null;
|
UserInfoDomainDTO userInfoDomainDTO = userInfoDomainConverter.toUserInfoDTO(user);
|
return userInfoDomainDTO;
|
}
|
|
@Override
|
public UserInfoDomainDTO findUserByIdSerial(Byte idType, String idSerial) {
|
if(idType == null || idSerial == null || idSerial.isEmpty() || idSerial.length() < 10)
|
return null;
|
User user = userRepository.findByIdTypeAndIdSerial(idType,idSerial);
|
if(user == null)
|
return null;
|
UserInfoDomainDTO userInfoDomainDTO = userInfoDomainConverter.toUserInfoDTO(user);
|
return userInfoDomainDTO;
|
}
|
|
@Override
|
@Transactional
|
public boolean updateUserPhoneNumber(Long uid, String phoneNumber) {
|
if(uid == null || phoneNumber == null || phoneNumber.isEmpty())
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
User user = userRepository.findUserByPhone(phoneNumber);
|
if(user != null && !user.getId().equals(uid))
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "手机号码已经被使用");
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent())
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
user = userOptional.get();
|
if(user.getPhone().equals(phoneNumber))
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "手机号码未发生变化");
|
if(userRepository.updateUserPhone(uid,phoneNumber) == 1){
|
// deleteUserCache(uid);
|
return true;
|
}else {
|
throw new BusinessException(this.getClass(),ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(),"数据库更新出错");
|
}
|
}
|
|
@Override
|
@Transactional
|
public boolean deleteUser(Long uid) {
|
if(uid == null)
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
Optional<User> userOptional = userRepository.findById(uid);
|
if(!userOptional.isPresent())
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_ACCOUNT_NOT_EXIST.getCode(), "用户不存在");
|
User user = userOptional.get();
|
if(user.getStatus().equals(UserStatusEnum.STATUS_DELETE.getStatus())){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(), "用户不存在");
|
}
|
if(userRepository.updateUserStatus(uid,UserStatusEnum.STATUS_DELETE.getStatus(), LocalDateTime.now()) ==1){
|
// deleteUserCache(uid);
|
return true;
|
}
|
return false;
|
}
|
|
/**
|
* 用户列表
|
*/
|
@Override
|
public List<UserInfoDomainDTO> getUserList() {
|
|
return BeanCopyUtils.copyBeanList(userRepository.getUserList(), UserInfoDomainDTO.class);
|
}
|
/**
|
* 根据用户id获取信息
|
*/
|
public UserInfoDomainDTO getUserById(Long id){
|
if(id == null)
|
return null;
|
User user = userRepository.getById(id);
|
UserInfoDomainDTO userInfoDomainDTO = userInfoDomainConverter.toUserInfoDTO(user);
|
return userInfoDomainDTO;
|
}
|
|
|
/**
|
* 根据用户获取数据
|
*/
|
public List<UserInfoDomainDTO> getUserByRoleId(Long roleId){
|
if(null == roleId){
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "参数缺失");
|
}
|
Specification<User> userSpecification = new Specification<User>() {
|
@Override
|
public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
|
List<Predicate> predicateList = new ArrayList<>();
|
predicateList.add(root.get("status").in(UserStatusEnum.getActiveUserStatus()));
|
Join<User, SysUserRoleBind> userRoleJion = root.join("sysUserRoleBinds", JoinType.LEFT);
|
predicateList.add(criteriaBuilder.equal(userRoleJion.get("roleId"), roleId));
|
|
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
|
}
|
};
|
List<User> userList = userRepository.findAll(userSpecification);
|
return userInfoDomainConverter.toDomainUserInfoList(userList);
|
|
}
|
|
/**
|
*
|
* @param pageQuery
|
* @return
|
*/
|
@Override
|
public SearchResult<List<UserInfoDomainDTO>> findUserList(PageQuery<UserQuery> pageQuery) {
|
SearchResult searchResult = new SearchResult<>();
|
searchResult.setPageIndex(pageQuery.getPageIndex());
|
searchResult.setPageSize(pageQuery.getPageSize());
|
searchResult.setSuccess();
|
|
UserQuery userQuery = pageQuery.getSearchParams();
|
Specification<User> userSpecification = new Specification<User>() {
|
@Override
|
public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
|
List<Predicate> predicateList = new ArrayList<>();
|
if(query != null){
|
if(!ObjectUtils.isEmpty(userQuery.getRoleId())){
|
Join<User, SysUserRoleBind> userRoleJion = root.join("sysUserRoleBinds", JoinType.LEFT);
|
predicateList.add(criteriaBuilder.equal(userRoleJion.get("roleId"), userQuery.getRoleId()));
|
}
|
if(!ObjectUtils.isEmpty(userQuery.getName())){
|
predicateList.add(criteriaBuilder.like(root.get("name"),userQuery.getName()));
|
}
|
if(!ObjectUtils.isEmpty(userQuery.getRealName())){
|
predicateList.add(criteriaBuilder.like(root.get("realName"),userQuery.getRealName()));
|
}
|
}
|
predicateList.add(root.get("status").in(UserStatusEnum.getActiveUserStatus()));
|
|
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
|
}
|
};
|
Pageable pageable = PageRequest.of(pageQuery.getPageIndex()-1, pageQuery.getPageSize(), Sort.Direction.DESC, "gmtCreate");
|
Page<User> pageResult = userRepository.findAll(userSpecification, pageable);
|
|
searchResult.setTotal(pageResult.getTotalElements());
|
searchResult.setPages(pageResult.getTotalPages());
|
searchResult.setData(userInfoDomainConverter.toDomainUserInfoList(pageResult.getContent()));
|
|
return searchResult;
|
}
|
|
@Override
|
public SearchResult<List<UserInfoDomainDTO>> findExpertList(PageQuery<UserQuery> pageQuery) {
|
SearchResult searchResult = new SearchResult<>();
|
searchResult.setPageIndex(pageQuery.getPageIndex());
|
searchResult.setPageSize(pageQuery.getPageSize());
|
searchResult.setSuccess();
|
|
UserQuery userQuery = pageQuery.getSearchParams();
|
Specification<User> userSpecification = new Specification<User>() {
|
@Override
|
public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
|
List<Predicate> predicateList = new ArrayList<>();
|
predicateList.add(root.get("status").in(UserStatusEnum.getActiveUserStatus()));
|
predicateList.add(criteriaBuilder.equal(root.get("identityStatus"),IdentityStatusEnum.EXPERT.getStatus()));
|
if(query != null){
|
if(!ObjectUtils.isEmpty(userQuery.getRoleId())){
|
Join<User, SysUserRoleBind> userRoleJion = root.join("sysUserRoleBinds", JoinType.LEFT);
|
predicateList.add(criteriaBuilder.equal(userRoleJion.get("roleId"), userQuery.getRoleId()));
|
}
|
if(!ObjectUtils.isEmpty(userQuery.getName())){
|
predicateList.add(criteriaBuilder.like(root.get("name"),userQuery.getName()));
|
}
|
if(!ObjectUtils.isEmpty(userQuery.getRealName())){
|
predicateList.add(criteriaBuilder.like(root.get("realName"),userQuery.getRealName()));
|
}
|
if(!ObjectUtils.isEmpty(userQuery.getUserIndentityId())){
|
Join<User, SysUserIdentityBind> userIdentityBindJion = root.join("sysUserIdentityBinds", JoinType.LEFT);
|
predicateList.add(criteriaBuilder.equal(userIdentityBindJion.get("userIdentityId"), userQuery.getUserIndentityId()));
|
}
|
}
|
|
|
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
|
}
|
};
|
Pageable pageable = PageRequest.of(pageQuery.getPageIndex()-1, pageQuery.getPageSize(), Sort.Direction.DESC, "gmtCreate");
|
Page<User> pageResult = userRepository.findAll(userSpecification, pageable);
|
|
searchResult.setTotal(pageResult.getTotalElements());
|
searchResult.setPages(pageResult.getTotalPages());
|
searchResult.setData(userInfoDomainConverter.toDomainUserInfoList(pageResult.getContent()));
|
|
return searchResult;
|
}
|
|
|
/**
|
* 用户查询
|
*/
|
@Override
|
public UserInfoDomainDTO getUserInfoByIdAndSellInfo(Long evaluateUserId, String info) {
|
|
if (ObjectUtils.isEmpty(evaluateUserId)){
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "请求参数不能为空");
|
}
|
|
User userInfo = userRepository.getUserInfoByIdAndSellInfo(evaluateUserId);
|
|
if (ObjectUtils.isEmpty(userInfo)){
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), info + "不存在，请检查是否输入有误或人员已被删除");
|
}
|
return BeanCopyUtils.copyBean(userInfo, UserInfoDomainDTO.class);
|
}
|
|
|
/**
|
* 清除REDIS缓存的用户数据
|
* @param userId
|
* @return
|
*/
|
public Result deleteUserCache(Long userId){
|
Result result = new Result<>();
|
if(userId == null){
|
return result;
|
}
|
RMapCache<String,Object> userCacheMap = redissonClient.getMapCache(SystemCacheKeyEnum.KEY_CACHE_USER.getKey());
|
String userKey = ""+userId;
|
userCacheMap.remove(userKey);
|
result.setSuccess();
|
return result;
|
}
|
|
/**
|
* 重置缓存的用户数据
|
* @param user
|
* @return
|
*/
|
public boolean resetUserCache(User user){
|
if(user == null)
|
return false;
|
String cacheJson = null;
|
try {
|
cacheJson = objectMapper.writeValueAsString(user);
|
} catch (JsonProcessingException e) {
|
throw new BusinessException(this.getClass(), ResultCode.SYSTEM_ERROR.getCode(),"序列化对象出错");
|
}
|
RMapCache<String,Object> userCacheMap = redissonClient.getMapCache(SystemCacheKeyEnum.KEY_CACHE_USER.getKey());
|
String userKey = ""+user.getId();
|
//写入redis缓存，有效期1小时
|
userCacheMap.put(userKey,cacheJson,60, TimeUnit.MINUTES);
|
return true;
|
}
|
|
/**
|
* 生成salt
|
* @return
|
*/
|
private String genPasswordSalt(){
|
String seed = ""+System.nanoTime();
|
String m = ""+ Range.atLeast(1).toString();
|
String salt = Hashing.hmacMd5(seed.getBytes(StandardCharsets.UTF_8)).hashBytes(m.getBytes(StandardCharsets.UTF_8)).toString();
|
return salt;
|
}
|
|
/**
|
* 生成hash
|
* @param password
|
* @param salt
|
* @return
|
*/
|
private String genPasswordHash(String password,String salt){
|
if(password == null || salt == null || password.isEmpty() || salt.isEmpty())
|
return null;
|
String hash = Hashing.hmacMd5(salt.getBytes(StandardCharsets.UTF_8)).hashBytes(password.getBytes(StandardCharsets.UTF_8)).toString();
|
return hash;
|
}
|
|
|
|
}
|
