1.前端设计导入
<!-- 用户导入对话框 --><el-dialog :title="upload.title" :visible.sync="upload.open" width="400px" append-to-body><el-upload ref="upload" :limit="1" accept=".xlsx, .xls" :headers="upload.headers":action="upload.url + '?updateSupport=' + upload.updateSupport" :disabled="upload.isUploading":on-progress="handleFileUploadProgress" :on-success="handleFileSuccess" :auto-upload="false" drag><i class="el-icon-upload"></i><div class="el-upload__text">将文件拖到此处，或<em>点击上传</em></div><div class="el-upload__tip text-center" slot="tip"><div class="el-upload__tip" slot="tip"><el-checkbox v-model="upload.updateSupport" /> 是否更新已经存在的用户数据</div><span>仅允许导入xls、xlsx格式文件。</span><el-link type="primary" :underline="false" style="font-size:12px;vertical-align: baseline;"@click="importTemplate">下载模板</el-link></div></el-upload><div slot="footer" class="dialog-footer"><el-button type="primary" @click="submitFileForm">确 定</el-button><el-button @click="upload.open = false">取 消</el-button></div></el-dialog>data 数据
// 用户导入参数upload: {// 是否显示弹出层（用户导入）open: false,// 弹出层标题（用户导入）title: "",// 是否禁用上传isUploading: false,// 是否更新已经存在的用户数据updateSupport: 0,// 设置上传的请求头部headers: { Authorization: "Bearer " + getToken() },// 上传的地址url: process.env.VUE_APP_BASE_API + "/system/user/importCustorm"},方法
// 提交上传文件submitFileForm() {this.$refs.upload.submit();}2.后端
模板
/*模板*/@PostMapping("/importTemplate")public void importTemplate(HttpServletResponse response) throws IOException {ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class);util.importTemplateExcel(response, "用户数据");}上传文件解析
/*用户模板上传*/
@Log(title = "用户管理", businessType = BusinessType.IMPORT)
@RequiresPermissions("system:user:import")
@PostMapping("/importData")
public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception {ExcelUtil<SysUser> util = new ExcelUtil<SysUser>(SysUser.class);List<SysUser> userList = util.importExcel(file.getInputStream());String operName = SecurityUtils.getUsername();String message = userService.importUser(userList, updateSupport, operName);return success(message);
}
实现逻辑
/*** 导入用户数据* * @param userList 用户数据列表* @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据* @param operName 操作用户* @return 结果*/@Overridepublic String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName){if (StringUtils.isNull(userList) || userList.size() == 0){throw new ServiceException("导入用户数据不能为空！");}int successNum = 0;int failureNum = 0;StringBuilder successMsg = new StringBuilder();StringBuilder failureMsg = new StringBuilder();String password = configService.selectConfigByKey("sys.user.initPassword");for (SysUser user : userList){try{// 验证是否存在这个用户SysUser u = userMapper.selectUserByUserName(user.getUserName());if (StringUtils.isNull(u)){BeanValidators.validateWithException(validator, user);user.setPassword(SecurityUtils.encryptPassword(password));user.setCreateBy(operName);userMapper.insertUser(user);successNum++;successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");}else if (isUpdateSupport){BeanValidators.validateWithException(validator, user);checkUserAllowed(u);checkUserDataScope(u.getUserId());user.setUserId(u.getUserId());user.setUpdateBy(operName);userMapper.updateUser(user);successNum++;successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 更新成功");}else{failureNum++;failureMsg.append("<br/>" + failureNum + "、账号 " + user.getUserName() + " 已存在");}}catch (Exception e){failureNum++;String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败：";failureMsg.append(msg + e.getMessage());log.error(msg, e);}}if (failureNum > 0){failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");throw new ServiceException(failureMsg.toString());}else{successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");}return successMsg.toString();}}
)
