SpringMVC上传、解析Excel

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介:     示例:导入相关数据(Excel文件),相关的文件数据编辑好。XML文件配置    再spring的xml文件中配置要上传文件的大小     Jsp界面配...


    示例:导入相关数据(Excel文件),相关的文件数据编辑好。

这里写图片描述

XML文件配置

    再spring的xml文件中配置要上传文件的大小

<!-- 上传文件拦截,设置最大上传文件大小   10M=10*1024*1024(B)=10485760 bytes -->  
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">  
    <property name="maxUploadSize" value="10485760" />  
</bean>

    

Jsp界面配置

<div>
      <form id="sourcefile" name="sourcefile" action="" method="post" enctype="multipart/form-data">
        <input type="button" value="添   加" onClick="addAirLine()" />
        <input style="margin-left: 20px;" id="source_file" name="sourceFile" type="file" value="选择文件" />
        <input style="margin-left: 20px;" data-loading-text="请勿重复提交" type="submit" value="上   传" onClick="upPolicy()">
        <input style="margin-left: 20px;"  type="submit" value="下载模板" onClick="return downloadTemplate();">
      </form>
    </div>

    js文件

function upPolicy() {
      document.sourcefile.action = "/login/policy/uploadCSV";
      var submitUrl = document.getElementById("sourcefile").attributes["action"].value;
      $.ajax({
        type: "POST",
        url: submitUrl,
        data: $('#sourcefile').serialize(),
        dataType: "json",
        success: function (result) {
          var json = JSON.parse(result);
          if (json.flag == "0" || json.flag == "1") {
            alert(tableJson.success);
            return;
          }
        }
      })
    }

    

Controller配置

@RequestMapping(value = "/uploadCSV" ,method = RequestMethod.POST)
    @ResponseBody
    public String uploadCSV(@RequestParam("sourceFile") MultipartFile sourceFile, HttpServletRequest request,HttpServletResponse response) throws IOException{

        //判断文件是否为空
        if (sourceFile==null) return null;
        //获取文件名
        String name=sourceFile.getOriginalFilename();
        //进一步判断文件是否为空(即判断其大小是否为0或其名称是否为null)
        long size =sourceFile.getSize();
        if (name==null ||("").equals(name) && size==0) return null;

        //批量导入。参数:文件名,文件。
        boolean b = batchImport(name,sourceFile);
        JSONObject jsonObject=new JSONObject();
        if(b){
            jsonObject.put("flag",0);
            jsonObject.put("success","批量导入EXCEL成功!");
        }else{
            jsonObject.put("flag",1);
            jsonObject.put("success","批量导入EXCEL失败!");
        }
        return jsonObject.toString();
    }

    分层没有那么的详细,再Controller中做的处理


    public boolean batchImport(String name,MultipartFile file){
        boolean b = false;
        //创建处理EXCEL
        ExcelUtils readExcel=new ExcelUtils();
        //解析excel,获取客户信息集合。
        List<OTAPolicyModel> cpolicyList = readExcel.getExcelInfo(name ,file);

        if(cpolicyList != null){
            b = true;
        }

        //迭代添加信息(注:实际上这里也可以直接将cpolicyList集合作为参数,在Mybatis的相应映射文件中使用foreach标签进行批量添加。)
        for(OTAPolicyModel customer:cpolicyList){
            policyDao.insertOTAPolicy(customer);
        }
        return b;
    }

    

工具类ExcelUtils.java

    即上述方法中readExcel.getExcelInfo(name ,file);语句所调用的方法以及其他相关的方法
Apache POI提供API给Java程式对Microsoft Office格式档案读和写的功能。不过这首先得判断Excel的版本而选择不同的Workbook的方式(2003版本对应的是HSSFWorkbook,2007版本及以上对应的是XSSFWorkbook)。此外,一般来说先将在客户端用户上传的文件拷贝一份至服务器的本地磁盘中,然后再从这个拷贝文件中进行读取,这样就避免了因客户端的网络异常或其他状况而在读取时造成的数据流失或损坏的情况。

package com.flight.inter.otaadapter.commons.util;

import com.flight.inter.otaadapter.model.OTAPolicyModel;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.commons.CommonsMultipartFile;

import java.io.*;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * Created by ling.zhang on 2016/12/29.
 */
public class ExcelUtils {

    //总行数
    private int totalRows = 0;
    //总条数
    private int totalCells = 0;
    //错误信息接收器
    private String errorMsg;
    //构造方法
    public ExcelUtils(){}
    //获取总行数
    public int getTotalRows()  { return totalRows;}
    //获取总列数
    public int getTotalCells() {  return totalCells;}
    //获取错误信息
    public String getErrorInfo() { return errorMsg; }

    /**
     * 验证EXCEL文件
     * @param filePath
     * @return
     */
    public boolean validateExcel(String filePath){
        if (filePath == null || !(WDWUtil.isExcel2003(filePath) || WDWUtil.isExcel2007(filePath))){
            errorMsg = "文件名不是excel格式";
            return false;
        }
        return true;
    }

    /**
     * 读EXCEL文件,获取客户信息集合
     * @param
     * @return
     */
    public List<OTAPolicyModel> getExcelInfo(String fileName, MultipartFile Mfile){

        //把spring文件上传的MultipartFile转换成CommonsMultipartFile类型
        CommonsMultipartFile cf= (CommonsMultipartFile)Mfile; //获取本地存储路径
        File file = new  File("D:\\fileupload");
        //创建一个目录 (它的路径名由当前 File 对象指定,包括任一必须的父路径。)
        if (!file.exists()) file.mkdirs();
        //新建一个文件
        File file1 = new File("D:\\fileupload" + new Date().getTime() + ".xlsx");
        //将上传的文件写入新建的文件中
        try {
            cf.getFileItem().write(file1);
        } catch (Exception e) {
            e.printStackTrace();
        }

        //初始化客户信息的集合
        List<OTAPolicyModel> customerList=new ArrayList<OTAPolicyModel>();
        //初始化输入流
        InputStream is = null;
        try{
            //验证文件名是否合格
            if(!validateExcel(fileName)){
                return null;
            }
            //根据文件名判断文件是2003版本还是2007版本
            boolean isExcel2003 = true;
            if(WDWUtil.isExcel2007(fileName)){
                isExcel2003 = false;
            }
            //根据新建的文件实例化输入流
            is = new FileInputStream(file1);
            //根据excel里面的内容读取客户信息
            customerList = getExcelInfo(is, isExcel2003);
            is.close();
        }catch(Exception e){
            e.printStackTrace();
        } finally{
            if(is !=null)
            {
                try{
                    is.close();
                }catch(IOException e){
                    is = null;
                    e.printStackTrace();
                }
            }
        }
        return customerList;
    }
    /**
     * 根据excel里面的内容读取客户信息
     * @param is 输入流
     * @param isExcel2003 excel是2003还是2007版本
     * @return
     * @throws IOException
     */
    public  List<OTAPolicyModel> getExcelInfo(InputStream is,boolean isExcel2003){
        List<OTAPolicyModel> customerList=null;
        try{
            /** 根据版本选择创建Workbook的方式 */
            Workbook wb = null;
            //当excel是2003时
            if(isExcel2003){
                wb = new HSSFWorkbook(is);
            }
            else{//当excel是2007时
                wb = new XSSFWorkbook(is);
            }
            //读取Excel里面客户的信息
            customerList=readExcelValue(wb);
        }
        catch (IOException e)  {
            e.printStackTrace();
        }
        return customerList;
    }
    /**
     * 读取Excel里面客户的信息
     * @param wb
     * @return
     */
    private List<OTAPolicyModel> readExcelValue(Workbook wb){
        //得到第一个shell
        Sheet sheet=wb.getSheetAt(0);

        //得到Excel的行数
        this.totalRows=sheet.getPhysicalNumberOfRows();

        //得到Excel的列数(前提是有行数)
        if(totalRows>=1 && sheet.getRow(0) != null){
            this.totalCells=sheet.getRow(0).getPhysicalNumberOfCells();
        }

        List<OTAPolicyModel> oTAPolicyModelList=new ArrayList<OTAPolicyModel>();
        OTAPolicyModel oTAPolicyModel;
        //循环Excel行数,从第二行开始。标题不入库
        for(int r=1;r<totalRows;r++){
            Row row = sheet.getRow(r);
            if (row == null) continue;
            oTAPolicyModel = new OTAPolicyModel();
            try {
                Thread.currentThread().sleep(1);
            }catch (InterruptedException e){
                e.printStackTrace();
            }
            oTAPolicyModel.setPolicyid(System.currentTimeMillis());
            //循环Excel的列
            for(int c = 0; c <this.totalCells; c++){
                Cell cell = row.getCell(c);
                if (null != cell){
                    if(c==0){
                        oTAPolicyModel.setSource(cell.getStringCellValue());//供应商
                    }else if(c==1){
                        oTAPolicyModel.setVendee(cell.getStringCellValue());//输出渠道
                    }else if(c==2){
                        int triptype=0;
                        if (cell.getStringCellValue()=="全部"){
                            triptype=0;
                        }else if (cell.getStringCellValue().equals("单程")){
                            triptype=10;
                        }else if (cell.getStringCellValue().equals("往返")){
                            triptype=20;
                        }else if (cell.getStringCellValue().equals("单程直飞")){
                            triptype=11;
                        }else if (cell.getStringCellValue().equals("单程中转")){
                            triptype=12;
                        }else if (cell.getStringCellValue().equals("往返直飞")){
                            triptype=21;
                        }else if (cell.getStringCellValue().equals("往返中转")){
                            triptype=22;
                        }
                        oTAPolicyModel.setTriptype(triptype);//行程类型
                    }else if(c==3){
                        oTAPolicyModel.setCarrier(cell.getStringCellValue());//航司代码
                    }else if(c==4){
                        oTAPolicyModel.setDepcity(cell.getStringCellValue());//起飞城市
                    }else if(c==5){
                        oTAPolicyModel.setArrcity(cell.getStringCellValue());//降落城市
                    }else if(c==6){
                        oTAPolicyModel.setSalebegindatel(new BigDecimal(cell.getNumericCellValue()).setScale(0,BigDecimal.ROUND_HALF_DOWN).longValue());//销售开始日期
                    }else if(c==7){
                        oTAPolicyModel.setSaleenddatel(new BigDecimal(cell.getNumericCellValue()).setScale(0,BigDecimal.ROUND_HALF_DOWN).longValue());//销售结束日期
                    }else if(c==8){
                        oTAPolicyModel.setTravelbegindatel(new BigDecimal(cell.getNumericCellValue()).setScale(0,BigDecimal.ROUND_HALF_DOWN).longValue());//旅行开始日期
                    }else if(c==9){
                        oTAPolicyModel.setTravelenddatel(new BigDecimal(cell.getNumericCellValue()).setScale(0,BigDecimal.ROUND_HALF_DOWN).longValue());//旅行结束日期
                    }else if(c==10){
                        int cabintype=9;
                        if (cell.getStringCellValue().equals("全部")){
                            cabintype=9;
                        }else if (cell.getStringCellValue().equals("经济舱")){
                            cabintype=1;
                        }else if (cell.getStringCellValue().equals("商务")){
                            cabintype=2;
                        }else if (cell.getStringCellValue().equals("头等")){
                            cabintype=3;
                        }
                        oTAPolicyModel.setCabintype(cabintype);//舱位等级
                    }else if(c==11){

                        oTAPolicyModel.setFdtype(cell.getStringCellValue().equals("按价格区间")?1:2);//返点类型
                    }else if(c==12){
                        oTAPolicyModel.setCabin(cell.getStringCellValue());//舱位
                    }else if(c==13){
                        oTAPolicyModel.setPricebegin(cell.getNumericCellValue());//最低价格
                    }else if(c==14){
                        oTAPolicyModel.setPriceend(cell.getNumericCellValue());//最高价格
                    }else if(c==15){
                        oTAPolicyModel.setLmoney(cell.getNumericCellValue());//留钱
                    }else if(c==16){
                        oTAPolicyModel.setFpercent(cell.getNumericCellValue());//全价返点
                    }else if(c==17){
                        oTAPolicyModel.setFtpercent(cell.getNumericCellValue());//票面返点
                    }else if(c==18){
                        int carrierlimit=2;
                        if (cell.getStringCellValue().equals("是")){
                            carrierlimit=1;
                        }else  if (cell.getStringCellValue().equals("否")){
                            carrierlimit=0;
                        }else  if (cell.getStringCellValue().equals("无")){
                            carrierlimit=2;
                        }
                        oTAPolicyModel.setCarrierlimit(carrierlimit);//开票航司限制
                    }else if(c==19){
                        int transport=2;
                        if (cell.getStringCellValue().equals("是")){
                            transport=1;
                        }else  if (cell.getStringCellValue().equals("否")){
                            transport=0;
                        }else  if (cell.getStringCellValue().equals("无限制")){
                            transport=2;
                        }
                        oTAPolicyModel.setTransport(transport);//支持联运
                    }else if(c==20){
                        int sharedflight=2;
                        if (cell.getStringCellValue().equals("是")){
                            sharedflight=1;
                        }else  if (cell.getStringCellValue().equals("否")){
                            sharedflight=0;
                        }else  if (cell.getStringCellValue().equals("无")){
                            sharedflight=2;
                        }
                        oTAPolicyModel.setSharedflight(sharedflight);//支持共享航班
                    }else if(c==21){
                        oTAPolicyModel.setPstatus(cell.getStringCellValue().equals("有效")?1:2);//状态
                    }else if(c==22){
                        int faretype=0;
                        if (cell.getStringCellValue().equals("私有")){
                            faretype=1;
                        }else  if (cell.getStringCellValue().equals("公布")){
                            faretype=2;
                        }else  if (cell.getStringCellValue().equals("全部")){
                            faretype=0;
                        }
                        oTAPolicyModel.setFaretype(faretype);//运价类型
                    }else if(c==23){
                        oTAPolicyModel.setLimitprice(new BigDecimal(cell.getNumericCellValue()).setScale(0,BigDecimal.ROUND_HALF_DOWN).longValue());//加价限制
                    }else if(c==24){
                        int limittransit=2;
                        if (cell.getStringCellValue().equals("全部")){
                            limittransit=2;
                        }else  if (cell.getStringCellValue().equals("适用")){
                            limittransit=0;
                        }else  if (cell.getStringCellValue().equals("不适用")){
                            limittransit=1;
                        }
                        oTAPolicyModel.setLimittransit(limittransit);//中转限制
                    }else if(c==25){
                        oTAPolicyModel.setArrcity(cell.getStringCellValue());//中转城市
                    }else if(c==26){
                        int limitnation=2;
                        if (cell.getStringCellValue().equals("全部")){
                            limitnation=2;
                        }else  if (cell.getStringCellValue().equals("适用")){
                            limitnation=0;
                        }else  if (cell.getStringCellValue().equals("不适用")){
                            limitnation=1;
                        }
                        oTAPolicyModel.setLimitnation(limitnation);//国籍限制
                    }else if(c==27){
                        oTAPolicyModel.setArrcity(cell.getStringCellValue());//国籍
                    }else if (c==28){
                        oTAPolicyModel.setUsername(cell.getStringCellValue());//用户名
                    }

                }
            }
            //添加客户
            oTAPolicyModelList.add(oTAPolicyModel);
        }
        return oTAPolicyModelList;
    }

}

    
    
    

    

工具类WDWUtil.java

package com.flight.inter.otaadapter.commons.util;

/**
 * Created by ling.zhang on 2016/12/29.
 */
public class WDWUtil {
    // @描述:是否是2003的excel,返回true是2003
    public static boolean isExcel2003(String filePath)  {
        return filePath.matches("^.+\\.(?i)(xls)$");
    }

    //@描述:是否是2007的excel,返回true是2007
    public static boolean isExcel2007(String filePath)  {
        return filePath.matches("^.+\\.(?i)(xlsx)$");
    }
}

    说明:上面的代码为了阅读便利而先贴的是父方法,后贴的是子方法,而在实际的代码编辑中一般是先编辑子方法,后编辑父方法,如上面应该是先编辑工具类的代码,再编辑服务层的代码,最后编辑控制器的代码。

    这样,整个流程就可以了,赶紧拿去测试吧~~

相关文章
|
1月前
|
负载均衡 算法 Java
Spring Cloud全解析:负载均衡算法
本文介绍了负载均衡的两种方式:集中式负载均衡和进程内负载均衡,以及常见的负载均衡算法,包括轮询、随机、源地址哈希、加权轮询、加权随机和最小连接数等方法,帮助读者更好地理解和应用负载均衡技术。
|
22天前
|
Java 对象存储 开发者
解析Spring Cloud与Netflix OSS:微服务架构中的左右手如何协同作战
Spring Cloud与Netflix OSS不仅是现代微服务架构中不可或缺的一部分,它们还通过不断的技术创新和社区贡献推动了整个行业的发展。无论是对于初创企业还是大型组织来说,掌握并合理运用这两套工具,都能极大地提升软件系统的灵活性、可扩展性以及整体性能。随着云计算和容器化技术的进一步普及,Spring Cloud与Netflix OSS将继续引领微服务技术的发展潮流。
33 0
|
12天前
|
数据处理 Python
Python 高级技巧:深入解析读取 Excel 文件的多种方法
在数据分析中,从 Excel 文件读取数据是常见需求。本文介绍了使用 Python 的三个库:`pandas`、`openpyxl` 和 `xlrd` 来高效处理 Excel 文件的方法。`pandas` 提供了简洁的接口,而 `openpyxl` 和 `xlrd` 则针对不同版本的 Excel 文件格式提供了详细的数据读取和处理功能。此外,还介绍了如何处理复杂格式(如合并单元格)和进行性能优化(如分块读取)。通过这些技巧,可以轻松应对各种 Excel 数据处理任务。
40 16
|
4天前
|
前端开发 JavaScript
💥【exceljs】纯前端如何实现Excel导出下载和上传解析?
本文介绍了用于处理Excel文件的库——ExcelJS,相较于SheetJS,ExcelJS支持更高级的样式自定义且易于使用。表格对比显示,ExcelJS在样式设置、内存效率及流式操作方面更具优势。主要适用于Node.js环境,也支持浏览器端使用。文中详细展示了如何利用ExcelJS实现前端的Excel导出下载和上传解析功能,并提供了示例代码。此外,还提供了在线调试的仓库链接和运行命令,方便读者实践。
|
5天前
|
人工智能 缓存 Java
深入解析Spring AI框架:在Java应用中实现智能化交互的关键
【10月更文挑战第12天】Spring AI 是 Spring 框架家族的新成员,旨在满足 Java 应用程序对人工智能集成的需求。它支持自然语言处理、图像识别等多种 AI 技术,并提供与云服务(如 OpenAI、Azure Cognitive Services)及本地模型的无缝集成。通过简单的配置和编码,开发者可轻松实现 AI 功能,同时应对模型切换、数据安全及性能优化等挑战。
|
1月前
|
XML 监控 Java
Spring Cloud全解析:熔断之Hystrix简介
Hystrix 是由 Netflix 开源的延迟和容错库,用于提高分布式系统的弹性。它通过断路器模式、资源隔离、服务降级及限流等机制防止服务雪崩。Hystrix 基于命令模式,通过 `HystrixCommand` 封装对外部依赖的调用逻辑。断路器能在依赖服务故障时快速返回备选响应,避免长时间等待。此外,Hystrix 还提供了监控功能,能够实时监控运行指标和配置变化。依赖管理方面,可通过 `@EnableHystrix` 启用 Hystrix 支持,并配置全局或局部的降级策略。结合 Feign 可实现客户端的服务降级。
119 23
|
20天前
|
存储 缓存 Java
在Spring Boot中使用缓存的技术解析
通过利用Spring Boot中的缓存支持,开发者可以轻松地实现高效和可扩展的缓存策略,进而提升应用的性能和用户体验。Spring Boot的声明式缓存抽象和对多种缓存技术的支持,使得集成和使用缓存变得前所未有的简单。无论是在开发新应用还是优化现有应用,合理地使用缓存都是提高性能的有效手段。
21 1
|
2月前
|
缓存 Java 开发者
Spring高手之路22——AOP切面类的封装与解析
本篇文章深入解析了Spring AOP的工作机制,包括Advisor和TargetSource的构建与作用。通过详尽的源码分析和实际案例,帮助开发者全面理解AOP的核心技术,提升在实际项目中的应用能力。
33 0
Spring高手之路22——AOP切面类的封装与解析
|
2月前
|
Java 微服务 Spring
Spring Cloud全解析:配置中心之解决configserver单点问题
但是如果该configserver挂掉了,那就无法获取最新的配置了,微服务就出现了configserver的单点问题,那么如何避免configserver单点呢?
|
2月前
|
XML Java 数据格式
Spring Cloud全解析:注册中心之zookeeper注册中心
使用ZooKeeper作为Spring Cloud的注册中心无需单独部署服务器,直接利用ZooKeeper服务端功能。项目通过`spring-cloud-starter-zookeeper-discovery`依赖实现服务注册与发现。配置文件指定连接地址,如`localhost:2181`。启动应用后,服务自动注册到ZooKeeper的`/services`路径下,形成临时节点,包含服务实例信息。
197 3

推荐镜像

更多