package com.doumee.biz.system.impl; 
 | 
  
 | 
import com.doumee.biz.system.SystemUserBiz; 
 | 
import com.doumee.core.exception.BusinessException; 
 | 
import com.doumee.core.constants.ResponseStatus; 
 | 
import com.doumee.core.utils.PwdCheckUtil; 
 | 
import com.doumee.core.utils.Utils; 
 | 
import com.doumee.dao.system.dto.CreateSystemUserDTO; 
 | 
import com.doumee.dao.system.dto.CreateUserRoleDTO; 
 | 
import com.doumee.dao.system.dto.ResetSystemUserPwdDTO; 
 | 
import com.doumee.dao.system.dto.UpdatePwdDto; 
 | 
import com.doumee.dao.system.model.SystemUser; 
 | 
import com.doumee.dao.system.model.SystemUserRole; 
 | 
import com.doumee.service.system.SystemUserRoleService; 
 | 
import com.doumee.service.system.SystemUserService; 
 | 
import org.apache.commons.lang3.RandomStringUtils; 
 | 
import org.apache.commons.lang3.StringUtils; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.stereotype.Service; 
 | 
import org.springframework.transaction.annotation.Transactional; 
 | 
import org.springframework.util.CollectionUtils; 
 | 
  
 | 
import java.util.Date; 
 | 
import java.util.List; 
 | 
  
 | 
@Service 
 | 
public class SystemUserBizImpl implements SystemUserBiz { 
 | 
  
 | 
    @Autowired 
 | 
    private SystemUserService systemUserService; 
 | 
  
 | 
    @Autowired 
 | 
    private SystemUserRoleService systemUserRoleService; 
 | 
  
 | 
    @Override 
 | 
    public void deleteById(Integer id) { 
 | 
        SystemUser user = systemUserService.findById(id); 
 | 
        if (user == null) { 
 | 
            return; 
 | 
        } 
 | 
        if (user.getFixed()) { 
 | 
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "请勿删除" + user.getUsername() + ",因为这是固定用户"); 
 | 
        } 
 | 
        systemUserService.deleteById(id); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void deleteByIdInBatch(List<Integer> ids) { 
 | 
        if (CollectionUtils.isEmpty(ids)) { 
 | 
            return; 
 | 
        } 
 | 
        for (Integer id : ids) { 
 | 
            this.deleteById(id); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updatePwd(UpdatePwdDto dto) { 
 | 
        if(StringUtils.isBlank(dto.getNewPwd()) 
 | 
                ||dto.getNewPwd().length()>20 
 | 
                ||dto.getNewPwd().length()<6 
 | 
                ||!PwdCheckUtil.checkPassword(dto.getNewPwd())){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,密码复杂度不满足要求:6-20个字符,至少包含字母、数字及特殊字符2种"); 
 | 
        } 
 | 
        SystemUser user = systemUserService.findById(dto.getUserId()); 
 | 
        if (user.getDeleted()) { 
 | 
            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "用户不存在或已被删除"); 
 | 
        } 
 | 
        // 验证原始密码 
 | 
        if (!user.getPassword().equals(Utils.Secure.encryptPassword(dto.getOldPwd(), user.getSalt()))) { 
 | 
            throw new BusinessException(ResponseStatus.PWD_INCORRECT.getCode(), "原始密码不正确"); 
 | 
        } 
 | 
        // 修改密码 
 | 
        SystemUser newUser = new SystemUser(); 
 | 
        newUser.setId(dto.getUserId()); 
 | 
        newUser.setPassword(Utils.Secure.encryptPassword(dto.getNewPwd(), user.getSalt())); 
 | 
        systemUserService.updateById(newUser); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void resetPwd(ResetSystemUserPwdDTO dto) { 
 | 
        if(StringUtils.isBlank(dto.getPassword()) 
 | 
                ||dto.getPassword().length()>20 
 | 
                ||dto.getPassword().length()<6 
 | 
                ||!PwdCheckUtil.checkPassword(dto.getPassword())){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,密码复杂度不满足要求:6-20个字符,至少包含字母、数字及特殊字符2种"); 
 | 
        } 
 | 
        // 查询用户 
 | 
        SystemUser systemUser = systemUserService.findById(dto.getId()); 
 | 
        if (systemUser == null || systemUser.getDeleted()) { 
 | 
            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "用户不存在或已被删除"); 
 | 
        } 
 | 
        // 修改密码 
 | 
        SystemUser updateUserDto = new SystemUser(); 
 | 
        updateUserDto.setId(dto.getId()); 
 | 
        updateUserDto.setPassword(Utils.Secure.encryptPassword(dto.getPassword(), systemUser.getSalt())); 
 | 
        systemUserService.updateById(updateUserDto); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void create(CreateSystemUserDTO systemUser) { 
 | 
        if(StringUtils.isBlank(systemUser.getPassword()) 
 | 
                ||systemUser.getPassword().length()>20 
 | 
                ||systemUser.getPassword().length()<6 
 | 
                ||!PwdCheckUtil.checkPassword(systemUser.getPassword())){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,密码复杂度不满足要求:6-20个字符,至少包含字母、数字及特殊字符2种"); 
 | 
        } 
 | 
        // 验证用户名 
 | 
        SystemUser queryUserDto = new SystemUser(); 
 | 
        queryUserDto.setUsername(systemUser.getUsername()); 
 | 
        queryUserDto.setDeleted(Boolean.FALSE); 
 | 
        SystemUser user = systemUserService.findOne(queryUserDto); 
 | 
        if (user != null) { 
 | 
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "用户名已存在"); 
 | 
        } 
 | 
        // 验证工号 
 | 
        if (StringUtils.isNotBlank(systemUser.getEmpNo())) { 
 | 
            queryUserDto = new SystemUser(); 
 | 
            queryUserDto.setDeleted(Boolean.FALSE); 
 | 
            queryUserDto.setEmpNo(systemUser.getEmpNo()); 
 | 
            user = systemUserService.findOne(queryUserDto); 
 | 
            if (user != null) { 
 | 
                throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "工号已存在"); 
 | 
            } 
 | 
        } 
 | 
  
 | 
        // 生成密码盐 
 | 
        String salt = RandomStringUtils.randomAlphabetic(6); 
 | 
        // 生成密码 
 | 
        systemUser.setPassword(Utils.Secure.encryptPassword(systemUser.getPassword(), salt)); 
 | 
        systemUser.setSalt(salt); 
 | 
        // 创建用户记录 
 | 
        systemUserService.create(systemUser); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateById(CreateSystemUserDTO systemUser) { 
 | 
        // 验证用户名 
 | 
        SystemUser queryUserDto = new SystemUser(); 
 | 
        queryUserDto.setUsername(systemUser.getUsername()); 
 | 
        queryUserDto.setDeleted(Boolean.FALSE); 
 | 
        SystemUser user = systemUserService.findOne(queryUserDto); 
 | 
        if (user != null && !user.getId().equals(systemUser.getId())) { 
 | 
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "用户名已存在"); 
 | 
        } 
 | 
        // 验证工号 
 | 
        if (StringUtils.isNotBlank(systemUser.getEmpNo())) { 
 | 
            queryUserDto = new SystemUser(); 
 | 
            queryUserDto.setEmpNo(systemUser.getEmpNo()); 
 | 
            queryUserDto.setDeleted(Boolean.FALSE); 
 | 
            user = systemUserService.findOne(queryUserDto); 
 | 
            if (user != null && !user.getId().equals(systemUser.getId())) { 
 | 
                throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "工号已存在"); 
 | 
            } 
 | 
        } 
 | 
        // 修改用户 
 | 
        systemUserService.updateById(systemUser); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void createUserRole(CreateUserRoleDTO dto) { 
 | 
        // 删除关联角色 
 | 
        SystemUserRole deleteDto = new SystemUserRole(); 
 | 
        deleteDto.setUserId(dto.getUserId()); 
 | 
        systemUserRoleService.delete(deleteDto); 
 | 
        // 新增新的角色 
 | 
        for (Integer roleId : dto.getRoleIds()) { 
 | 
            SystemUserRole newUserRole = new SystemUserRole(); 
 | 
            newUserRole.setUserId(dto.getUserId()); 
 | 
            newUserRole.setRoleId(roleId); 
 | 
            systemUserRoleService.create(newUserRole); 
 | 
        } 
 | 
    } 
 | 
} 
 |