| | |
| | | @Override |
| | | public void importOperationsUser(MultipartFile file) { |
| | | ExcelUtil<ExportOperationsUserVo> util = new ExcelUtil<ExportOperationsUserVo>(ExportOperationsUserVo.class); |
| | | List<ExportOperationsUserVo> list = null; |
| | | try { |
| | | List<ExportOperationsUserVo> list = util.importExcel(file.getInputStream()); |
| | | for (ExportOperationsUserVo exportOperationsUserVo : list) { |
| | | XpOperationsUser xpOperationsUser = new XpOperationsUser(); |
| | | xpOperationsUser.setNickName(exportOperationsUserVo.getNickName()); |
| | | xpOperationsUser.setUniqueNumber(exportOperationsUserVo.getUniqueNumber()); |
| | | xpOperationsUser.setAvatar(exportOperationsUserVo.getAvatar()); |
| | | boolean isPhone = PhoneUtil.isPhone(exportOperationsUserVo.getPhoneNumber()); |
| | | if (!isPhone) { |
| | | throw new ServiceException("以下帐号格式不正确:", I18nKeyConstant.ACCOUNT_FORMAT_ERROR, new Object[]{exportOperationsUserVo.getPhoneNumber()}); |
| | | } |
| | | xpOperationsUser.setPhoneNumber(exportOperationsUserVo.getPhoneNumber()); |
| | | xpOperationsUser.setPassword(SecurityUtils.encryptPassword("a123456")); |
| | | xpOperationsUser.setRemarks(exportOperationsUserVo.getRemarks()); |
| | | xpOperationsUser.setStatus(true); |
| | | xpOperationsUser.setIdCardFront(StringUtils.isBlank(exportOperationsUserVo.getIdCardFront()) ? null : exportOperationsUserVo.getIdCardFront()); |
| | | xpOperationsUser.setIdCardBack(StringUtils.isBlank(exportOperationsUserVo.getIdCardBack()) ? null : exportOperationsUserVo.getIdCardBack()); |
| | | xpOperationsUser.setDriverLicense(StringUtils.isBlank(exportOperationsUserVo.getDriverLicense()) ? null : exportOperationsUserVo.getDriverLicense()); |
| | | xpOperationsUser.setCertificateOfNoCriminalRecord(StringUtils.isBlank(exportOperationsUserVo.getCertificateOfNoCriminalRecord()) ? null : exportOperationsUserVo.getCertificateOfNoCriminalRecord()); |
| | | xpOperationsUser.setTrainingGraduationCertificate(StringUtils.isBlank(exportOperationsUserVo.getTrainingGraduationCertificate()) ? null : exportOperationsUserVo.getTrainingGraduationCertificate()); |
| | | xpOperationsUser.setDeleted(false); |
| | | xpOperationsUser.setCreateTime(LocalDateTime.now()); |
| | | xpOperationsUser.setUpdateTime(LocalDateTime.now()); |
| | | this.save(xpOperationsUser); |
| | | // 通过角色名称查询角色 |
| | | String roleName = exportOperationsUserVo.getRoleName(); |
| | | if(StringUtils.isNotBlank(roleName)){ |
| | | List<SysRole> sysRoles = iSysRoleService.list(Wrappers.lambdaQuery(SysRole.class) |
| | | .in(SysRole::getRoleName, Arrays.asList(roleName.split(",")))); |
| | | if(!CollectionUtils.isEmpty(sysRoles)){ |
| | | List<XpOperationsRole> xpOperationsRoles = new ArrayList<>(); |
| | | for (SysRole sysRole : sysRoles) { |
| | | XpOperationsRole xpOperationsRole = new XpOperationsRole(); |
| | | xpOperationsRole.setOperationsUserId(xpOperationsUser.getId()); |
| | | xpOperationsRole.setRoleId(sysRole.getId()); |
| | | xpOperationsRoles.add(xpOperationsRole); |
| | | } |
| | | xpOperationsRoleService.saveBatch(xpOperationsRoles); |
| | | }else { |
| | | throw new ServiceException("角色["+roleName+"]不存在",I18nKeyConstant.ROlE_NOT_EXISTS); |
| | | list = util.importExcel(file.getInputStream()); |
| | | } catch (Exception e) { |
| | | throw new ServiceException("导入运维人员数据异常", I18nKeyConstant.ACCOUNT_IMPORT_ERROR); |
| | | } |
| | | for (ExportOperationsUserVo exportOperationsUserVo : list) { |
| | | XpOperationsUser xpOperationsUser = new XpOperationsUser(); |
| | | xpOperationsUser.setNickName(exportOperationsUserVo.getNickName()); |
| | | xpOperationsUser.setUniqueNumber(exportOperationsUserVo.getUniqueNumber()); |
| | | xpOperationsUser.setAvatar(exportOperationsUserVo.getAvatar()); |
| | | boolean isPhone = PhoneUtil.isPhone(exportOperationsUserVo.getPhoneNumber()); |
| | | if (!isPhone) { |
| | | throw new ServiceException("以下帐号格式不正确:"+exportOperationsUserVo.getPhoneNumber(), I18nKeyConstant.ACCOUNT_FORMAT_ERROR); |
| | | } |
| | | xpOperationsUser.setPhoneNumber(exportOperationsUserVo.getPhoneNumber()); |
| | | xpOperationsUser.setPassword(SecurityUtils.encryptPassword("a123456")); |
| | | xpOperationsUser.setRemarks(exportOperationsUserVo.getRemarks()); |
| | | xpOperationsUser.setStatus(true); |
| | | xpOperationsUser.setIdCardFront(StringUtils.isBlank(exportOperationsUserVo.getIdCardFront()) ? null : exportOperationsUserVo.getIdCardFront()); |
| | | xpOperationsUser.setIdCardBack(StringUtils.isBlank(exportOperationsUserVo.getIdCardBack()) ? null : exportOperationsUserVo.getIdCardBack()); |
| | | xpOperationsUser.setDriverLicense(StringUtils.isBlank(exportOperationsUserVo.getDriverLicense()) ? null : exportOperationsUserVo.getDriverLicense()); |
| | | xpOperationsUser.setCertificateOfNoCriminalRecord(StringUtils.isBlank(exportOperationsUserVo.getCertificateOfNoCriminalRecord()) ? null : exportOperationsUserVo.getCertificateOfNoCriminalRecord()); |
| | | xpOperationsUser.setTrainingGraduationCertificate(StringUtils.isBlank(exportOperationsUserVo.getTrainingGraduationCertificate()) ? null : exportOperationsUserVo.getTrainingGraduationCertificate()); |
| | | xpOperationsUser.setDeleted(false); |
| | | xpOperationsUser.setCreateTime(LocalDateTime.now()); |
| | | xpOperationsUser.setUpdateTime(LocalDateTime.now()); |
| | | this.save(xpOperationsUser); |
| | | // 通过角色名称查询角色 |
| | | String roleName = exportOperationsUserVo.getRoleName(); |
| | | if(StringUtils.isNotBlank(roleName)){ |
| | | List<SysRole> sysRoles = iSysRoleService.list(Wrappers.lambdaQuery(SysRole.class) |
| | | .in(SysRole::getRoleName, Arrays.asList(roleName.split(",")))); |
| | | if(!CollectionUtils.isEmpty(sysRoles)){ |
| | | List<XpOperationsRole> xpOperationsRoles = new ArrayList<>(); |
| | | for (SysRole sysRole : sysRoles) { |
| | | XpOperationsRole xpOperationsRole = new XpOperationsRole(); |
| | | xpOperationsRole.setOperationsUserId(xpOperationsUser.getId()); |
| | | xpOperationsRole.setRoleId(sysRole.getId()); |
| | | xpOperationsRoles.add(xpOperationsRole); |
| | | } |
| | | xpOperationsRoleService.saveBatch(xpOperationsRoles); |
| | | }else { |
| | | throw new ServiceException("角色["+roleName+"]不存在",I18nKeyConstant.ROlE_NOT_EXISTS); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |