Java8 当 Lambda 遇上受检异常
public ListbulkInsert() { //返回没有添加成功的id信息 List errorList = new ArrayList (); try{ SupplierDto dto = new SupplierDto(); dto.setIsDel((byte)0); int count = supplierDao.countList(dto); int pageSize = 100; int pageCount = count % pageSize == 0? count/pageSize: count/pageSize + 1 ; for(int i = 1 ; i <= pageCount ; i++ ){ Pager pager = new Pager(pageSize , i); dto.setPager(pager); List list = supplierDao.findList(dto); List collect = list.stream().map(item -> { try{ return JsonUtils.obj2Str(item); }catch (Exception e){ e.printStackTrace(); errorList.add(item.getId().toString()); } return null; }).filter(line -> line != null).collect(Collectors.toList()); //批量插入数据 List strings = esSupplierService.bulkInsert(collect); if(strings.size() > 0){ errorList.addAll(strings); } } return errorList; }catch (Exception e){ logger.error(e.toString()); throw new ServiceException(APICode.BATCH_ADD_ERROR); }}