POI上传excel的java后台逻辑

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: POI上传excel的java后台逻辑

一、方式一

先导入依赖

<dependency>
            <groupId>org.apache.poi</groupId>
            <artifactId>poi</artifactId>
</dependency>
<dependency>
            <groupId>org.apache.poi</groupId>
            <artifactId>poi-scratchpad</artifactId>
</dependency>
<dependency>
            <groupId>org.apache.poi</groupId>
            <artifactId>poi-ooxml</artifactId>
</dependency>

1、抽象类,把公共的方法抽出来

public abstract class AbstractExcelImportController {
   
    public AbstractExcelImportController() {
   
    }

    public abstract SheetConfig getSheetConfig();

    @RequestMapping({
   "showImportExcelDlg.do"})
    public String showImportExcelDlg(Model model) {
   
        Map<String, Object> result = new HashMap();
        result.put("urlprofix", this.getUrlProfix());
        model.addAttribute(UIConst.UIPAGEMODEL, result);
        return "platform/excelimport/excelimport.ui";
    }

    public abstract String getUrlProfix();

    @RequestMapping({
   "importExcel.do"})
    public String importExcel(MultipartFile excelimport_importfile, String overrideFlat, Model model, HttpServletRequest request) throws Exception {
   
        String errorMessage = null;
        if (excelimport_importfile != null && !excelimport_importfile.isEmpty() && excelimport_importfile.getSize() != 0L) {
   
            if (!excelimport_importfile.getOriginalFilename().endsWith("xls")) {
   
                errorMessage = "上传文件必须是以xls为后缀";
            } else {
   
                ExcelImporter importer = ExcelImporter.newInstance(this.getSheetConfig());

                try {
   
                    List<Map<String, Object>> datas = importer.readExcel(excelimport_importfile.getInputStream());
                    this.handleExcelData(datas, overrideFlat);
                } catch (BusinessException var8) {
   
                    var8.printStackTrace();
                    errorMessage = var8.getMessage();
                } catch (Exception var9) {
   
                    errorMessage = var9.getMessage();
                }
            }
        } else {
   
            errorMessage = "上传文件不能为空";
        }

        Map<String, Object> result = new HashMap();
        if (errorMessage != null) {
   
            result.put("success", false);
            result.put("errorMessage", errorMessage);
        } else {
   
            result.put("success", true);
        }

        model.addAttribute("result", CustomObjectMapper.getInstance().writeValueAsString(result));
        return "platform/excelimport/importresult";
    }

    protected abstract void handleExcelData(List<Map<String, Object>> var1, String var2) throws BusinessException;

    @RequestMapping({
   "downloadExcelTemplate.do"})
    public void downloadExcelTemplate(HttpServletRequest request, HttpServletResponse response) throws Exception {
   
        ExcelExporter exporter = ExcelExporter.newInstance(this.getSheetConfig());
        OutputStream out = response.getOutputStream();
        response.setContentType("application/octet-stream");
        response.setHeader("Content-Disposition", "attachment;filename=" + new String(this.getExcelTemplateFileName().getBytes("gb2312"), "ISO8859-1"));
        List<Map<String, Object>> datas = new ArrayList();
        exporter.writeExcel(datas, out);
    }

    public abstract String getExcelTemplateFileName();
}

2、每一个需要上传excel的web层(Controller)继承上边的接口,实现自己的上传业务逻辑

public class DeptController extends AbstractExcelImportController {
   
 /**
     * add by sgw 20190325
     *excel模板
     * @return  返回excel模板
     */
    @Override
    public SheetConfig getSheetConfig() {
   
        SheetConfig sheetConfig = new SheetConfig();
        List<SheetConfig.ColumnDef> columnDefList = new ArrayList<SheetConfig.ColumnDef>();
        SheetConfig.ColumnDef columnDef = null;

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("部门编码");
        columnDef.setName("fdeptCode");
        columnDef.setComment("必填项!");
        columnDef.setWidth(30);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.CODE);
        columnDefList.add(columnDef);

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("部门名称");
        columnDef.setName("fdeptName");
        columnDef.setComment("必填项!");
        columnDef.setWidth(30);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.STRING);
        columnDefList.add(columnDef);

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("联系人");
        columnDef.setName("flinkMan");
        columnDef.setWidth(30);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.STRING);
        columnDefList.add(columnDef);

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("联系电话");
        columnDef.setName("flinkTel");
        columnDef.setWidth(50);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.STRING);
        columnDefList.add(columnDef);

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("联系地址");
        columnDef.setName("faddr");

        columnDef.setWidth(50);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.STRING);
        columnDefList.add(columnDef);

        columnDef = new SheetConfig.ColumnDef();
        columnDef.setTitle("是否启用");
        columnDef.setName("fisEnable");
        columnDef.setComment("必填项!");
        columnDef.setWidth(20);
        columnDef.setColumnType(SheetConfig.ColumnDef.ColumnType.STRING);
        columnDefList.add(columnDef);

        sheetConfig.setColumnDefList(columnDefList);
        return sheetConfig;
    }

    /**
     * add by sgw 20190325
     * 告诉前端公用的excelImport.js,处理上传excel的controller路径
     * @return  处理excel的java类
     */

    @Override
    public String getUrlProfix() {
   
        return "basicinfo/standard/dept";
    }

    /**
     * add by sgw 20190325
     * 批量上传部门excel
     * @param datas        excel数据
     * @param overrideFlat 是否更新(覆盖)导入  "true":是
     * @throws BusinessException
     */
    @Override
    protected void handleExcelData(List<Map<String, Object>> datas, String overrideFlat) throws BusinessException {
   
        User user = (User) AppContext.getContext().getAttribute(
                AppContext.SESSION, "user");
        //1、更新(覆盖)导入:已存在部门编码时,将该部门编码下的部门信息进行更新(即无法更新部门编码,只能更新已有部门编码下的其他信息)
        if (overrideFlat != null && "true".equals(overrideFlat)) {
   
            //1.1、校验excel数据是否有误;如果传过来的部门编码在数据库里已经存在的了,则删除数据库里对应的数据
            boolean isCorrectDates = this.deptService.checkExcelDates(datas, overrideFlat, user,"update");
            //1.2、将新的部门数据插入到数据库里
            if (isCorrectDates) {
   
                //2.2、数据无误,将excel的数据循环导入到数据库
                for (Map<String, Object> map : datas) {
   
                    Dept dept = new Dept();
                    dept.setFdeptCode(map.get("fdeptCode").toString());
                    dept.setFdeptName(map.get("fdeptName").toString());
                    if (map.get("flinkMan") != null) {
   
                        dept.setFlinkMan(map.get("flinkMan").toString());
                    }
                    if (map.get("flinkTel") != null) {
   
                        dept.setFlinkTel(map.get("flinkTel").toString());
                    }
                    if (map.get("faddr") != null) {
   
                        dept.setFaddr(map.get("faddr").toString());
                    }
                    if (map.get("fisEnable") != null) {
   
                        if ("是".equals(map.get("fisEnable").toString())) {
   
                            dept.setFisEnable(1);
                        } else {
   
                            dept.setFisEnable(0);
                        }
                    }
                    this.deptService.doInsert(dept, user.getId());
                }
            }
        }
        //2、新增导入:已存在部门编码时,强制要求修改部门编码后再进行上传
        else {
   
            //2.1、校验excel数据是否有误
            boolean isCorrectDates = this.deptService.checkExcelDates(datas, overrideFlat, user,"add");
            if (isCorrectDates) {
   
                //2.2、数据无误,将excel的数据循环导入到数据库
                for (Map<String, Object> map : datas) {
   
                    Dept dept = new Dept();
                    dept.setFdeptCode(map.get("fdeptCode").toString());
                    dept.setFdeptName(map.get("fdeptName").toString());
                    if (map.get("flinkMan") != null) {
   
                        dept.setFlinkMan(map.get("flinkMan").toString());
                    }
                    if (map.get("flinkTel") != null) {
   
                        dept.setFlinkTel(map.get("flinkTel").toString());
                    }
                    if (map.get("faddr") != null) {
   
                        dept.setFaddr(map.get("faddr").toString());
                    }
                    if (map.get("fisEnable") != null) {
   
                        if ("是".equals(map.get("fisEnable").toString())) {
   
                            dept.setFisEnable(1);
                        } else {
   
                            dept.setFisEnable(0);
                        }
                    }
                    this.deptService.doInsert(dept, user.getId());
                }
            }
        }
    }

    /**
     * add by sgw 20190325
     * @return excel模板的文件名
     */
    @Override
    public String getExcelTemplateFileName() {
   
        return "主管部门信息.xls";
    }
}

二、方式二

依赖

<dependency>
    <groupId>org.apache.poi</groupId>
    <artifactId>poi</artifactId>
    <version>3.10-FINAL</version>
</dependency>
<dependency>
    <groupId>org.apache.poi</groupId>
    <artifactId>poi-ooxml</artifactId>
    <version>3.10.1</version>
</dependency>

mapper.xml:

<select id="exportUser" resultType="java.util.Map">
    select user_id as userId, username, email, mobile, create_time as createTime from sys_user
</select>

接口:

List<Map<String, Object>> exportUser();

service:

 @Override
    public Workbook exportUser() {
   
        //1,创建了一个空的excel文件
        Workbook workbook = new HSSFWorkbook();
        //2,填充数据:创建sheet页
        Sheet sheet = workbook.createSheet("XXX公司的员工信息");
        //标题数组
        String titles[] ={
   "用户id","用户名","邮箱","电话","创建时间"};
        String colums[] ={
   "userId", "username", "email", "mobile", "createTime"};
        List<Map<String, Object>> maps = sysUserMapper.exportUser();
        //创建行
        Row rowTile = sheet.createRow(0);
        //标题行
        for (int i = 0; i <titles.length ; i++) {
   
            Cell cell = rowTile.createCell(i);
            cell.setCellValue(titles[i]);
        }
        //遍历数据,填充到单元格
        for (int i = 0; i <maps.size() ; i++) {
   
            //一条记录应该创建一个Row对象 这里从第二行开始所以+1
            //这个是空的,需要填充数据
            Row row = sheet.createRow(i+1);
            //填充单元格
            for (int j = 0; j < titles.length; j++) {
   
                Cell cell = row.createCell(j);
                //获取用户id的值
                //这里获取的值可以是"userId"..
                Map<String, Object> rowValue = maps.get(i);
                //循环动态设置多个字段的值
                Object o = rowValue.get(colums[j]);
                //这里也就是为什么查询数据库使用map封装的原因。
                cell.setCellValue(o+"");
            }
        }
        return workbook;
    }

controller:

   /**
    * 导出用户的excel数据
    * @param response
    */
   @RequestMapping("/sys/user/export")
   public void exportUser(HttpServletResponse response){
   
       Workbook workbook = sysUserService.exportUser();
       try {
   
           //设置响应头   所有文件都支持
           response.setContentType("application/octet-stream");
           String fileName = "员工信息.xls";
           fileName = URLEncoder.encode(fileName,"utf-8");
           response.setHeader("content-disposition","attachment;filename="+fileName);
           //文件下载
           workbook.write(response.getOutputStream());
       } catch (IOException e) {
   
           e.printStackTrace();
       }
   }
相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
相关文章
|
1月前
|
关系型数据库 MySQL Java
【IDEA】java后台操作mysql数据库驱动常见错误解决方案
【IDEA】java后台操作mysql数据库驱动常见错误解决方案
65 0
|
15天前
|
Java API Apache
Java编程如何读取Word文档里的Excel表格,并在保存文本内容时保留表格的样式?
【10月更文挑战第29天】Java编程如何读取Word文档里的Excel表格,并在保存文本内容时保留表格的样式?
71 5
|
15天前
|
Java API Apache
|
18天前
|
存储 Java API
Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
25 4
|
1月前
|
小程序 Java
小程序访问java后台失败解决方案
小程序访问java后台失败解决方案
44 2
|
1月前
|
小程序 JavaScript Java
小程序访问java后台
小程序访问java后台
27 1
|
1月前
|
Java 测试技术 Maven
编写一个java后台
编写一个java后台
15 1
|
22天前
|
存储 缓存 NoSQL
一篇搞懂!Java对象序列化与反序列化的底层逻辑
本文介绍了Java中的序列化与反序列化,包括基本概念、应用场景、实现方式及注意事项。序列化是将对象转换为字节流,便于存储和传输;反序列化则是将字节流还原为对象。文中详细讲解了实现序列化的步骤,以及常见的反序列化失败原因和最佳实践。通过实例和代码示例,帮助读者更好地理解和应用这一重要技术。
20 0
|
1月前
|
前端开发 JavaScript Java
导出excel的两个方式:前端vue+XLSX 导出excel,vue+后端POI 导出excel,并进行分析、比较
这篇文章介绍了使用前端Vue框架结合XLSX库和后端结合Apache POI库导出Excel文件的两种方法,并对比分析了它们的优缺点。
235 0
|
2月前
|
存储 Java
java的Excel导出,数组与业务字典匹配并去掉最后一个逗号
java的Excel导出,数组与业务字典匹配并去掉最后一个逗号
44 2