Postman请求方式：
Controller接口代码：
/** * /partImport/part/importUpload * @param importFile * @return */ @PostMapping("/part/importUpload") public Map<String, Object> importUpload(@RequestParam(value = "file") MultipartFile importFile) { return partMainDataImportService.importUpload(importFile); }
对象类型：
import org.springframework.web.multipart.MultipartFile;
逻辑思路：
1、Excel转变可获取数据
2、数据结果集插入DB
@Override public Map<String, Object> importUpload(MultipartFile importFile) { StopWatch stopWatch = new StopWatch(); stopWatch.start(); Map<String, Object> resultMap = new HashMap<>(); List<Map<Integer, String>> partMainDatas = null; // Sheet1 配件主数据信息 List<Map<Integer, String>> partExclusivePrice = null; // Sheet2 配件专属价格 List<Map<Integer, String>> partReplacements = null; // Sheet3 配件替换件 try { // 获取数据集合对象 getDataListFromImportExcel导出方法 partMainDatas = getDataListFromImportExcel(importFile, resultMap, 0); partExclusivePrice = getDataListFromImportExcel(importFile, resultMap, 1); partReplacements = getDataListFromImportExcel(importFile, resultMap, 2); Integer integer = insertPartMainData(partMainDatas); resultMap.put("partMainDatas", integer); if (!CollectionUtils.isEmpty(partExclusivePrice)) { Integer integer2 = insertExclusivePrice(partExclusivePrice); resultMap.put("partOwnPrices", integer2); } else { resultMap.put("partOwnPrices", 0); } if (!CollectionUtils.isEmpty(partReplacements)) { Integer integer3 = insertReplacements(partReplacements); resultMap.put("partShifts", integer3); } else { resultMap.put("partShifts", 0); } } catch (Exception exception) { exception.printStackTrace(); return resultMap; } finally { stopWatch.stop(); resultMap.put("execTime", stopWatch.getTotalTimeSeconds() + '秒'); } resultMap.put("200", "导入成功"); return resultMap; }
Excel转换到数据逻辑部分：
/** * 提供给配件主数据导入处理 * @param importFile * @param map 响应结果，如果报错异常，则在这里设置 * @return */ private List<Map<Integer, String>> getDataListFromImportExcel(MultipartFile importFile, Map<String, Object> map, Integer sheetIndex) throws Exception { Workbook workbook = null; // Excel工作薄 Sheet sheet = null; // Excel表单 Sheet页 Row row = null; // 行 Map<Integer, String> dataMap = null; // 表单中的一行数据 List<Map<Integer, String>> dataList = null; // 表单中的所有数据 boolean isValidRow = false; // Excel行中是否是有效数据行 InputStream inputStream = importFile.getInputStream(); // 文件流 String filename = importFile.getOriginalFilename(); // 文件名 // 获取Excel工作簿对象 if ("xls".equalsIgnoreCase(filename.substring(filename.lastIndexOf(".") + 1, filename.length()))) { workbook = new HSSFWorkbook(inputStream); } else { workbook = new XSSFWorkbook(inputStream); } sheet = workbook.getSheetAt(sheetIndex); // 获取指定Sheet页来处理 Boolean flag = false; // 标记，如果检测到空行为true Integer num = 0; dataList = new ArrayList<>(); int physicalNumberOfRows = sheet.getPhysicalNumberOfRows(); for (int i = 1 /* 从表单第二行开始读取数据，读取整个表单中的数据 */; i < physicalNumberOfRows; i++) { num = 0; if(flag){ break; } row = sheet.getRow(i); if (null != row) { dataMap = new HashMap<>(); int physicalNumberOfCells = sheet.getRow(0).getPhysicalNumberOfCells(); for (int j = 0; j < physicalNumberOfCells; j++) { if(null != row.getCell(j) && !StringUtils.isNullOrEmpty(row.getCell(j).getStringCellValue())){ num ++; break; }else if(sheet.getRow(0).getPhysicalNumberOfCells() - 1 == j && num == 0){ flag = true; // true结束 break; } } // 根据模板表头长度,读取一行数据 for (int j = 0; j < sheet.getRow(0).getPhysicalNumberOfCells(); j++) { if(flag){ break; } // 属于零件主数据导入的判断逻辑, sheet主数据 且下标是这个集合内的，判断空则抛出空异常 if ( sheetIndex.equals(0) && this.validateColumnIndexListForMainData.contains(j) && null == row.getCell(j) ) { map.put("5002", "导入的Excel数据(Sheet1配件主数据)必填字段存在空值！！！"); throw new ServiceBizException(ERR_MESSAGE); } else if (sheetIndex.equals(1) && null == row.getCell(j)) { map.put("5003", "导入的Excel数据(Sheet2专属价格)存在空值！！！"); throw new ServiceBizException(ERR_MESSAGE); } else if (sheetIndex.equals(2) && null == row.getCell(j)) { map.put("5004", "导入的Excel数据(Sheet3替换件)存在空值！！！"); throw new ServiceBizException(ERR_MESSAGE); } if (row.getCell(j) == null) { dataMap.put(j, ""); } else { String parseExcel = parseExcel(row.getCell(j)).trim(); if (!StringUtils.isBlank(parseExcel)) { dataMap.put(j, parseExcel); isValidRow = true; } else { dataMap.put(j, ""); } } } /** * 读取完一条记录，如果是有效数据行，则加入返回结果中 */ if (isValidRow) { dataList.add(dataMap); } } } if (CollectionUtils.isEmpty(dataList) && sheetIndex.equals(0)) { map.put("5001", "导入的Excel数据不能为空"); throw new ServiceBizException(ERR_MESSAGE); } return dataList; }
这里有一段解析处理，有点麻烦
private static String parseExcel(Cell cell) { String result = ""; switch (cell.getCellType()) { case HSSFCell.CELL_TYPE_NUMERIC:// 数字类型 if (HSSFDateUtil.isCellDateFormatted(cell)) {// 处理日期格式、时间格式 SimpleDateFormat sdf = null; if (cell.getCellStyle().getDataFormat() == HSSFDataFormat.getBuiltinFormat("h:mm")) { sdf = new SimpleDateFormat("HH:mm"); } else {// 日期 sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); } Date date = cell.getDateCellValue(); result = sdf.format(date); } else if (cell.getCellStyle().getDataFormat() == 58) { // 处理自定义日期格式：m月d日(通过判断单元格的格式id解决，id的值是58) SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); double value = cell.getNumericCellValue(); Date date = org.apache.poi.ss.usermodel.DateUtil.getJavaDate(value); result = sdf.format(date); } else { cell.setCellType(XSSFCell.CELL_TYPE_STRING); result = cell.getStringCellValue().toString(); } break; case HSSFCell.CELL_TYPE_STRING:// String类型 result = cell.getRichStringCellValue().toString(); break; case HSSFCell.CELL_TYPE_BLANK: result = ""; break; default: result = ""; break; } return result;
然后第二部分数据封装对象来插入DB：
/** * * @param datas * @return */ private Integer insertPartMainData(List<Map<Integer, String>> datas) throws Exception { Integer affectRows = 0; Class<PartInfoPO> partInfoPOClass = PartInfoPO.class; PartInfoPO partInfoPO ; // 先遍历集合 for (Map<Integer, String> row : datas) { partInfoPO = new PartInfoPO(); partInfoPO.setOwnerCode("-1"); // pmd是每一行的结果 Set<Integer> columns = row.keySet(); // 遍历每一行获取单元格的值 for (Integer column : columns) { String fieldKey = fields.get(column); String fieldValue = row.get(column); if(StringUtils.isNullOrEmpty(fieldValue)){continue;} Field field = partInfoPOClass.getDeclaredField(fieldKey); field.setAccessible(true); Class<?> type = field.getType(); fieldValue = "是".equals(fieldValue) ? YES : "否".equals(fieldValue) ? NO : fieldValue; if (Integer.class.equals(type)) { // fieldValue = "是".equals(fieldValue) ? "10041001" : "否".equals(fieldValue) ? "10041002" : fieldValue; field.set(partInfoPO, Integer.valueOf(fieldValue)); } else if(BigDecimal.class.equals(type)) { // fieldValue = "是".equals(fieldValue) ? "10041001" : "否".equals(fieldValue) ? "10041002" : fieldValue; field.set(partInfoPO, new BigDecimal(fieldValue)); } else if(Date.class.equals(type) ) { SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd"); field.set(partInfoPO, simpleDateFormat.parse(fieldValue)); } else { field.set(partInfoPO, fieldValue); } } affectRows += partInfoMapper.insert(partInfoPO); } return affectRows; }