| | |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | failMsg.add(msg); |
| | | continue; |
| | | } else { |
| | | String[] split = techImportExcel.getAddress().split(";"); |
| | | regionIds = new ArrayList<>(); |
| | | for (String s : split) { |
| | | TRegion region = regionService.lambdaQuery().like(TRegion::getName, s).one(); |
| | | if (region == null) { |
| | | msg = "第" + techImportExcels.indexOf(techImportExcel) + "行,地区不存在"; |
| | | failMsg.add(msg); |
| | | } else { |
| | | regionIds.add(region.getId()); |
| | | if("全部".equals(techImportExcel.getAddress())){ |
| | | List<TRegion> list = regionService.lambdaQuery().list(); |
| | | regionIds = list.stream().map(TRegion::getId).collect(Collectors.toList()); |
| | | }else { |
| | | String[] split = techImportExcel.getAddress().split(";"); |
| | | regionIds = new ArrayList<>(); |
| | | for (String s : split) { |
| | | TRegion region = regionService.lambdaQuery().like(TRegion::getName, s).one(); |
| | | if (region == null) { |
| | | msg = "第" + techImportExcels.indexOf(techImportExcel) + "行,地区不存在"; |
| | | failMsg.add(msg); |
| | | } else { |
| | | regionIds.add(region.getId()); |
| | | } |
| | | } |
| | | if (regionIds.size() != split.length) { |
| | | continue; |
| | | } |
| | | } |
| | | if (regionIds.size() != split.length) { |
| | | continue; |
| | | } |
| | | |
| | | } |
| | | TTechnicalTitle tTechnicalTitle = new TTechnicalTitle(); |
| | | tTechnicalTitle.setTitileName(techImportExcel.getTitileName()); |
| | |
| | | e.printStackTrace(); |
| | | // logger.error("批量购入导入失败:{}",e.getMessage()); |
| | | // importRecordService.removeById(tImportRecord.getId()); |
| | | return R.fail("批量购入导入失败!"); |
| | | return R.fail("批量导入失败!"); |
| | | }finally { |
| | | try { |
| | | inputStream.close(); |