From f4485365fd5c6eda51924569bfadf07ec643c629 Mon Sep 17 00:00:00 2001 From: 10001392 <1055202292@qq.com> Date: Thu, 12 Sep 2024 14:07:23 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E7=89=A9=E6=96=99=E5=8F=98=E6=9B=B4?= =?UTF-8?q?=E3=80=91=E5=A4=A7=E6=89=B9=E9=87=8F=E5=AF=BC=E5=85=A5=EF=BC=8C?= =?UTF-8?q?=E4=B8=8A=E9=99=9010000=E6=9D=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../product/material/service/MaterialUpdateBillService.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialUpdateBillService.java b/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialUpdateBillService.java index 552aabcf..32798d53 100644 --- a/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialUpdateBillService.java +++ b/nflg_project_dev/material/src/main/java/com/nflg/product/material/service/MaterialUpdateBillService.java @@ -406,6 +406,9 @@ public class MaterialUpdateBillService extends ServiceImpl excelContext = EecExcelUtil.getExcelContext(file.getInputStream(), MaterialStateUpExcelDTO.class); if (CollectionUtil.isNotEmpty(excelContext) && excelContext.size() > 1000) { + if (excelContext.size() > 10000) { + return ResultVO.error("导入失败，最多支持10000条批量导入"); + } redisTemplate.opsForValue().set(buildKey(userCode + ":updateBatchImport"), file.getOriginalFilename()); // 大数据量，子线程分批次提交OA（每批1000条），主线程提前返回结果给前端 CompletableFuture task1 = CompletableFuture.supplyAsync(() -> { @@ -433,6 +436,9 @@ public class MaterialUpdateBillService extends ServiceImpl excelContext = EecExcelUtil.getExcelContext(file.getInputStream(), TwentyMaterialTemplateExcelDTO.class); if (CollectionUtil.isNotEmpty(excelContext) && excelContext.size() > 1000) { + if (excelContext.size() > 10000) { + return ResultVO.error("导入失败，最多支持10000条批量导入"); + } redisTemplate.opsForValue().set(buildKey(userCode + ":updateBatchImport"), file.getOriginalFilename()); // 大数据量，子线程分批次提交OA（每批1000条），主线程提前返回结果给前端 CompletableFuture task1 = CompletableFuture.supplyAsync(() -> {