From f65e0d342fe3bec46fd00eb30b67fe301498e9f7 Mon Sep 17 00:00:00 2001
From: fengyuan_yang <1976974459@qq.com>
Date: Wed, 24 Jun 2026 16:28:52 +0800
Subject: [PATCH] =?UTF-8?q?2026-06-24=20=E9=A1=B9=E7=9B=AE=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E7=9A=84=E3=80=90Excel=E5=AF=BC=E5=85=A5=E3=80=91?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD=E4=BC=98=E5=8C=96=EF=BC=9B=20=E5=BE=85?=
 =?UTF-8?q?=E6=8A=A5=E4=BB=B7=E6=B8=85=E5=8D=95=E3=80=90=E6=8A=A5=E4=BB=B7?=
 =?UTF-8?q?=E3=80=91=E4=BC=98=E5=8C=96=EF=BC=8C=E5=81=9A=E4=BA=86=E9=98=B2?=
 =?UTF-8?q?=E5=BE=A1=E6=80=A7=E4=BF=9D=E6=8A=A4=EF=BC=8C=E9=81=87=E5=88=B0?=
 =?UTF-8?q?=E5=BE=AA=E7=8E=AF=E5=BC=95=E7=94=A8=E7=9A=84=E7=BB=93=E6=9E=84?=
 =?UTF-8?q?=E4=BC=9A=E7=BB=99=E5=87=BA=E6=98=8E=E7=A1=AE=E6=8F=90=E7=A4=BA?=
 =?UTF-8?q?=EF=BC=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/PartInformationServiceImpl.java      | 39 ++++++++++----
 .../impl/QuoteDetailBomTreeServiceImpl.java   | 52 ++++++++++++++++++-
 2 files changed, 79 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
index bf7b76bc..b058fc91 100644
--- a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
+++ b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
@@ -3864,23 +3864,29 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
     @Override
     @Transactional
     public void uploadProjectPartExcel(MultipartFile file, GetParamInData data) {
-        try{
-            // 转流
-            InputStream is = file.getInputStream();
-            // 读取工作簿
-            XSSFWorkbook workbook = new XSSFWorkbook(is);
+        try (InputStream is = file.getInputStream(); XSSFWorkbook workbook = new XSSFWorkbook(is)) {
             // 读取工作表
             XSSFSheet sheet = workbook.getSheetAt(0);
-            // 获取行数
-            int rows = sheet.getPhysicalNumberOfRows();
+            // 获取最后一行索引（从0开始）
+            int lastRowNum = sheet.getLastRowNum();
+            int lastDataRowNum = 0;
+            for (int j = 1; j <= lastRowNum; j++) {
+                XSSFRow row = sheet.getRow(j);
+                if (!isProjectPartImportRowEmpty(row)) {
+                    lastDataRowNum = j;
+                }
+            }
             // 声明对象
             PartInformationVo task = null;
             // 遍历每一行（从第二行开始）
-            for (int j = 1; j < rows; j++) {
-                // 实例化对象
-                task = new PartInformationVo();
+            for (int j = 1; j <= lastDataRowNum; j++) {
                 //获得该行
                 XSSFRow row = sheet.getRow(j);
+                if (isProjectPartImportRowEmpty(row)) {
+                    throw new RuntimeException("第" + (j + 1) + "行为空白，存在中间空白行，请删除空白行后重试");
+                }
+                // 实例化对象
+                task = new PartInformationVo();
                 // 为对象赋值
                 task.setSite(data.getOrderRef1()); // site
                 task.setProjectId(data.getOrderRef2()); // 项目编码
@@ -3938,6 +3944,19 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
         }
     }
 
+    private boolean isProjectPartImportRowEmpty(XSSFRow row) {
+        if (row == null) {
+            return true;
+        }
+        // Excel模板约定有效导入列为A-G，均为空则视为导入结束
+        for (int i = 0; i <= 6; i++) {
+            if (StringUtils.hasText(getCellValueAsString(row.getCell(i)))) {
+                return false;
+            }
+        }
+        return true;
+    }
+
     private static String getCellValueAsString(Cell cell) {
         if (cell == null) {
             return "";
diff --git a/src/main/java/com/spring/modules/quote/service/impl/QuoteDetailBomTreeServiceImpl.java b/src/main/java/com/spring/modules/quote/service/impl/QuoteDetailBomTreeServiceImpl.java
index e6e0410a..326f0adc 100644
--- a/src/main/java/com/spring/modules/quote/service/impl/QuoteDetailBomTreeServiceImpl.java
+++ b/src/main/java/com/spring/modules/quote/service/impl/QuoteDetailBomTreeServiceImpl.java
@@ -133,7 +133,22 @@ public class QuoteDetailBomTreeServiceImpl extends ServiceImpl<QuoteDetailBomTre
      *
      * @param ifsConFactory IFS 连接工厂，每个并发线程调用 get() 获取独立连接，避免共享连接线程安全问题
      */
-    private BomNodeData collectBomData(QuoteDetail detail, Long parentId, Integer level, Supplier<Server> ifsConFactory, Map<String, BigDecimal> costCache, Map<String, BigDecimal> workCenterCostCache) {
+    private BomNodeData collectBomData(QuoteDetail detail,
+                                       Long parentId,
+                                       Integer level,
+                                       Supplier<Server> ifsConFactory,
+                                       Map<String, BigDecimal> costCache,
+                                       Map<String, BigDecimal> workCenterCostCache) {
+        return collectBomData(detail, parentId, level, ifsConFactory, costCache, workCenterCostCache, new LinkedHashSet<>());
+    }
+
+    private BomNodeData collectBomData(QuoteDetail detail,
+                                       Long parentId,
+                                       Integer level,
+                                       Supplier<Server> ifsConFactory,
+                                       Map<String, BigDecimal> costCache,
+                                       Map<String, BigDecimal> workCenterCostCache,
+                                       Set<String> recursionPath) {
         // 统一先尝试将临时料映射到正式料，保证新建与“切换版本刷新”取数来源一致
         PartInformationEntity mappedPart = baseMapper.queryPart(detail.getSite(), detail.getPartNo());
         if (Objects.nonNull(mappedPart) && "Y".equals(mappedPart.getStatus())) {
@@ -161,6 +176,15 @@ public class QuoteDetailBomTreeServiceImpl extends ServiceImpl<QuoteDetailBomTre
         if (Objects.isNull(bom)) {
             return null;
         }
+        String currentBomPathKey = buildBomPathKey(bom);
+        if (recursionPath.contains(currentBomPathKey)) {
+            String cyclePath = formatBomPath(recursionPath, currentBomPathKey);
+            log.error("[BOM_PROCESS] 检测到BOM循环引用，终止报价创建. key={}, path={}",
+                    currentBomPathKey, cyclePath);
+            throw new RuntimeException("检测到BOM循环引用，请先在BOM维护中调整后再报价。环路：" + cyclePath);
+        }
+        Set<String> nextRecursionPath = new LinkedHashSet<>(recursionPath);
+        nextRecursionPath.add(currentBomPathKey);
         bom.setParentId(parentId);
         bom.setLevel(level);
         log.info("BOM信息：{}", bom);
@@ -205,7 +229,15 @@ public class QuoteDetailBomTreeServiceImpl extends ServiceImpl<QuoteDetailBomTre
             if (Objects.nonNull(childBomCheck) && "Y".equals(component.getBomFlag())) {
                 log.debug("[BOM_PROCESS] 递归处理半成品 - PartNo: {}", component.getComponentPart());
                 // 递归收集子节点，parentId 占位 -1，写入时由 doSaveBomDataRecursive 覆盖
-                BomNodeData childNode = collectBomData(childDetail, -1L, level + 1, ifsConFactory, costCache, workCenterCostCache);
+                BomNodeData childNode = collectBomData(
+                        childDetail,
+                        -1L,
+                        level + 1,
+                        ifsConFactory,
+                        costCache,
+                        workCenterCostCache,
+                        nextRecursionPath
+                );
                 if (childNode != null) {
                     nodeData.children.add(childNode);
                     // 半成品：bomId 在写入阶段填充，先清零价格（IFS 并行阶段会覆盖）
@@ -908,6 +940,22 @@ public class QuoteDetailBomTreeServiceImpl extends ServiceImpl<QuoteDetailBomTre
         return quoteDetail;
     }
 
+    private String buildBomPathKey(QuoteDetailBomTree bom) {
+        return String.join("|",
+                Objects.toString(bom.getSite(), ""),
+                Objects.toString(bom.getPartNo(), ""),
+                Objects.toString(bom.getBomType(), ""),
+                Objects.toString(bom.getEngChgLevel(), ""),
+                Objects.toString(bom.getAlternativeNo(), "")
+        );
+    }
+
+    private String formatBomPath(Set<String> recursionPath, String currentBomPathKey) {
+        List<String> fullPath = new ArrayList<>(recursionPath);
+        fullPath.add(currentBomPathKey);
+        return String.join(" -> ", fullPath);
+    }
+
     private void copyCommonFields(QuoteDetail source, QuoteDetail target) {
         target.setId(source.getId());
         target.setQuoteId(source.getQuoteId());