diff --git a/blade-common/src/main/java/org/springblade/common/excel/ImportFailureExcelUtil.java b/blade-common/src/main/java/org/springblade/common/excel/ImportFailureExcelUtil.java
index 955cc989..0fc7d2f1 100644
--- a/blade-common/src/main/java/org/springblade/common/excel/ImportFailureExcelUtil.java
+++ b/blade-common/src/main/java/org/springblade/common/excel/ImportFailureExcelUtil.java
@@ -45,7 +45,9 @@ import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Arrays;
+import java.util.Collections;
import java.util.HashMap;
+import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
@@ -174,7 +176,10 @@ public class ImportFailureExcelUtil {
}
/**
- * 以「原始单元格文本」方式重读导入文件，得到的行用于构造读取阶段的失败明细。
+ * 以「原始单元格文本」方式重读导入文件，得到的行用于构造失败明细。
+ *
+ * 优先使用 Excel 文件真实表头（含动态费用列等模型类未声明的列），保证失败明细
+ * 与原导入模板列一致，用户修正后可直接用该文件重新导入。
*
* 用途：当 {@code ExcelUtil.read(file, XxxExcel.class)} 因单元格无法转换而失败时，
* 已解析的实体列表是不完整的（异常中断了整批读取）。此时用本方法重读一次：
@@ -182,18 +187,36 @@ public class ImportFailureExcelUtil {
* 供导出「原表全量 + 仅出错行带原因」的失败明细。
*
* @param file 上传的 Excel 文件
- * @param excelClass 导入模型类（按列序号反查表头名，用于把列序号映射成列名）
+ * @param excelClass 导入模型类（表头缺失时按列序号反查表头名）
* @return 按行组织的明细数据：每行是「表头名 → 单元格文本」的有序 Map；
* 读不出内容时返回空列表（调用方按空明细处理）
*/
public static List> readRawRows(java.io.InputStream file, Class excelClass) {
List> rawRows = new ArrayList<>();
+ Map headerByIndex = new LinkedHashMap<>();
try {
cn.idev.excel.read.builder.ExcelReaderBuilder builder = cn.idev.excel.FastExcel
.read(file, new cn.idev.excel.event.AnalysisEventListener>() {
+ @Override
+ public void invokeHeadMap(Map headMap, cn.idev.excel.context.AnalysisContext context) {
+ if (headMap == null) {
+ return;
+ }
+ headMap.forEach((index, header) -> {
+ if (index == null) {
+ return;
+ }
+ String name = header == null ? "" : header.trim();
+ // 历史失败明细再导入时忽略旧的失败原因列，导出时重新追加
+ if (!name.isEmpty() && !FAILURE_REASON.equals(name)) {
+ headerByIndex.put(index, name);
+ }
+ });
+ }
+
@Override
public void invoke(Map data, cn.idev.excel.context.AnalysisContext context) {
- rawRows.add(new java.util.LinkedHashMap<>(data));
+ rawRows.add(data == null ? new LinkedHashMap<>() : new LinkedHashMap<>(data));
}
@Override
@@ -206,25 +229,80 @@ public class ImportFailureExcelUtil {
// 重读本身失败时退回空明细，由调用方按「无法读取」提示
return new ArrayList<>();
}
- List fields = excelClass == null ? List.of() : excelFields(excelClass);
List> rows = new ArrayList<>();
for (Map rawRow : rawRows) {
- Map row = new java.util.LinkedHashMap<>();
- for (Map.Entry entry : rawRow.entrySet()) {
- Integer columnIndex = entry.getKey();
- String columnName = columnIndex != null && columnIndex < fields.size()
- ? columnName(excelClass, columnIndex)
- : null;
- if (columnName == null) {
- columnName = "第" + (columnIndex == null ? "?" : columnIndex + 1) + "列";
+ Map row = new LinkedHashMap<>();
+ Set columnIndexes = new LinkedHashSet<>(headerByIndex.keySet());
+ if (rawRow != null) {
+ columnIndexes.addAll(rawRow.keySet());
+ }
+ List sortedIndexes = new ArrayList<>(columnIndexes);
+ Collections.sort(sortedIndexes);
+ for (Integer columnIndex : sortedIndexes) {
+ if (columnIndex == null) {
+ continue;
}
- row.put(columnName, entry.getValue());
+ String columnName = headerByIndex.get(columnIndex);
+ if (columnName == null || columnName.isBlank()) {
+ columnName = columnName(excelClass, columnIndex);
+ }
+ if (columnName == null || columnName.isBlank()) {
+ columnName = "第" + (columnIndex + 1) + "列";
+ }
+ if (FAILURE_REASON.equals(columnName)) {
+ continue;
+ }
+ row.put(columnName, rawRow == null ? null : rawRow.get(columnIndex));
}
rows.add(row);
}
return rows;
}
+ /**
+ * 按原上传文件真实表头导出失败明细（含动态列），并追加「导入失败原因」。
+ *
+ * 适用于运输对账等「模板列 = 固定列 + 动态费用列」场景：按实体字段反射导出
+ * 会丢掉动态列，用户无法用失败文件修正后重新导入。本方法重读原文件全量列，
+ * 再按 failureList 行序挂上失败原因。
+ *
+ * @param response 响应
+ * @param fileName 文件名
+ * @param sheetName 工作表名
+ * @param file 原导入文件
+ * @param failureList 校验失败列表（与原表行序一致，成功行 errorMessage 可为空）
+ * @param excelClass 导入模型类（原文件重读失败时回退到按实体导出）
+ */
+ public static void exportOriginalWithFailures(HttpServletResponse response, String fileName, String sheetName,
+ org.springframework.web.multipart.MultipartFile file,
+ List failureList, Class excelClass) {
+ List> rawRows = new ArrayList<>();
+ if (file != null && !file.isEmpty()) {
+ try (java.io.InputStream inputStream = file.getInputStream()) {
+ rawRows = readRawRows(inputStream, excelClass);
+ } catch (IOException ignored) {
+ rawRows = new ArrayList<>();
+ }
+ }
+ if (rawRows.isEmpty()) {
+ // 原文件读不出时回退实体导出，至少保证失败原因可下载
+ if (failureList != null && !failureList.isEmpty()) {
+ export(response, fileName, sheetName, failureList, excelClass);
+ }
+ return;
+ }
+ Map failureMessageByRow = new HashMap<>();
+ if (failureList != null) {
+ for (int index = 0; index < failureList.size(); index++) {
+ Object message = errorMessage(failureList.get(index));
+ if (message != null && !String.valueOf(message).isBlank()) {
+ failureMessageByRow.put(index, String.valueOf(message));
+ }
+ }
+ }
+ exportRawFailure(response, fileName, sheetName, rawRows, failureMessageByRow);
+ }
+
/**
* 导出「读取阶段失败」明细：原表全量行 + 末尾「导入失败原因」列。
*
@@ -259,24 +337,20 @@ public class ImportFailureExcelUtil {
}
List> rows = new ArrayList<>();
Map> redColumnsByRow = new HashMap<>();
+ List> headerKeywords = new ArrayList<>();
+ for (int columnIndex = 0; columnIndex < headers.size() - 1; columnIndex++) {
+ headerKeywords.add(headerKeywords(headers.get(columnIndex)));
+ }
for (int rowIndex = 0; rowIndex < rawRows.size(); rowIndex++) {
Map rawRow = rawRows.get(rowIndex);
List