Easyexcel用法及Rest接口实现文件上传

依赖jar包
<dependency>
   <groupId>com.alibaba</groupId>
    <artifactId>easyexcel</artifactId>
    <version>1.1.2-beat1</version>
  </dependency>
 
  <dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.3</version>
</dependency>
<dependency>
<groupId>org.jboss.resteasy</groupId>
<artifactId>resteasy-multipart-provider</artifactId>
<version>3.0.18.final</version>
<exclusions>
<exclusion>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</exclusion>
</exclusions>
</dependency>
 

代码
package com.chinacreator.c2.mop.resource.web.rest;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;

import org.apache.commons.fileupload.FileItemIterator;
import org.apache.commons.fileupload.FileItemStream;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import com.alibaba.excel.EasyExcelFactory;
import com.alibaba.excel.metadata.Sheet;
import com.alibaba.fastjson.JSONObject;

import com.chinacreator.c2.util.UUIDUtil;
import com.chinacreator.c2.web.exception.InvalidRestParamException;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import io.swagger.annotations.ApiResponse;
import io.swagger.annotations.ApiResponses;
import io.swagger.annotations.SwaggerDefinition;
import io.swagger.annotations.Tag;

import com.chinacreator.c2.mop.resource.Deviceinfo;
import com.chinacreator.c2.mop.resource.Optnodeinfo;
import com.chinacreator.c2.mop.resource.Subdeviceinfo;
import com.chinacreator.c2.mop.resource.readmodel.DeviceInfoReadModel;
import com.chinacreator.c2.mop.resource.readmodel.DeviceSubInfoReadModel;
import com.chinacreator.c2.mop.resource.readmodel.OptNodeInfoReadModel;
import com.chinacreator.c2.mop.resource.service.DeviceinfoService;
import com.chinacreator.c2.mop.resource.service.OptnodeinfoService;

import com.chinacreator.c2.mop.resource.service.SubdeviceinfoService ;
@Controller
@Api("资源导入")
@Path("mop/v1/resources")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
@SwaggerDefinition(tags = {@Tag(name = "ResourceImport", description = "资源导入")})
@ApiResponses(value = {@ApiResponse(code = 400, message = "错误的请求参数", response = Error.class),
@ApiResponse(code = 404, message = "操作失败，资源未找到", response = Error.class),
@ApiResponse(code = 500, message = "系统内部错误", response = Error.class)})
public class ResourceImport {
@Autowired
private DeviceinfoService deviceinfoService;

@Autowired
private SubdeviceinfoService subdeviceinfoService;

@Autowired
private OptnodeinfoService optnodeinfoService;


   public static final String DEVICE_INFO = "deviceinfo";
  
   public static final String DEVICE_SUB_INFO = "devicesubinfo";
  
   public static final String OPT_NODE_INFO = "optnodeinfo";



@POST
@Path("/{resourcetype}")
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.MULTIPART_FORM_DATA })
@ApiOperation(value = "预览导入运维资源excel文件(文件要放在请求头里面，文件的参数名为files)", tags = "运维资源导入", notes = "运维资源导入(文件要放在请求头里面，文件的参数名为files)")
public   boolean importOptNodeInfo(@PathParam("resourcetype") String resourcetype,
                           @ApiParam(value = "上传的文件", name = "files") @Context HttpServletRequest request
)  {
  boolean bool=false;
  if(DEVICE_INFO.equals(resourcetype)) {
   List<Object> data=getParseExcelObject(DeviceInfoReadModel.class, request);
   List<Deviceinfo> deviceInfos=new ArrayList<Deviceinfo>();
   List<String> lst=new ArrayList<String>();
   for (Object ob : data) {
   Deviceinfo deviceInfo= JSONObject.parseObject(ob.toString(),Deviceinfo.class);
   String id=deviceInfo.getDevid();
   if("null".equals(id)) {
   throw new InvalidRestParamException("导入的资产编号不能为空");
   }
   deviceInfos.add(deviceInfo);
   lst.add(id);
    }
  List<String> ls= deviceinfoService.getAllId();
  for (String string : ls) {
  for (String string1 : lst) {
  if(string.equals(string1)) {
  bool=false;
  throw new InvalidRestParamException("excel中存在重复的数据，设备ID为"+string);
  }
}

}
   deviceinfoService.insertBatch(deviceInfos);
   bool=true;
  }
 
  if(DEVICE_SUB_INFO.equals(resourcetype)) {
   List<Object> data=getParseExcelObject(DeviceSubInfoReadModel.class, request);
   List<Subdeviceinfo> subdeviceinfos=new ArrayList<Subdeviceinfo>();
   List<String> lst=new ArrayList<String>();
   for (Object ob : data) {
   Subdeviceinfo subdeviceinfo= JSONObject.parseObject(ob.toString(),Subdeviceinfo.class);
   subdeviceinfos.add(subdeviceinfo);
   String id=subdeviceinfo.getSubdevid();
   if("null".equals(id)) {
   throw new InvalidRestParamException("导入的子资产编号不能为空");
   }
   lst.add(id);
    }
  List<String> ls= subdeviceinfoService.getAllId();
  for (String string : ls) {
  for (String string1 : lst) {
  if(string.equals(string1)) {
  bool=false;
  throw new InvalidRestParamException("excel中存在重复的数据，子资源编号为"+string);
  }
}
}
  subdeviceinfoService.insertBatch(subdeviceinfos);
   bool=true;
  }
  if(OPT_NODE_INFO.equals(resourcetype)) {
   List<Object> data=getParseExcelObject(OptNodeInfoReadModel.class, request);
   List<Optnodeinfo> optnodeinfos=new ArrayList<Optnodeinfo>();
   for (Object ob : data) {
   Optnodeinfo optnodeinfo= JSONObject.parseObject(ob.toString(),Optnodeinfo.class);
   String id = UUIDUtil.createUUID();
   optnodeinfo.setId(id);
   optnodeinfos.add(optnodeinfo);
    }
   optnodeinfoService.insertBatch(optnodeinfos);
   bool=true;
 
  }
    return bool;
}
 
  public List<Object> getParseExcelObject(Class c,HttpServletRequest request){
  List<Object> data =null;
  InputStream inputstream =null;
  ServletFileUpload upload = new ServletFileUpload();
try {
FileItemIterator iter = upload.getItemIterator(request);
while (iter.hasNext()) {
FileItemStream fileItemStream = iter.next();
inputstream = fileItemStream.openStream();
data = EasyExcelFactory.read(inputstream, new Sheet(1, 1, c));
}
} catch (FileUploadException e1) {
e1.printStackTrace();
} catch (IOException e1) {
e1.printStackTrace();
}
  finally {
try {
inputstream.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
 
return data;
  }
 
}