台账导入-数据重复校验

airport-admin/src/main/java/com/sundot/airport/web/controller/ledger/LedgerImportController.java

@@ -1,6 +1,8 @@
 package com.sundot.airport.web.controller.ledger;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import com.sundot.airport.common.dto.ImportResultVO;
 import com.sundot.airport.common.utils.poi.ExcelUtil;
 import com.sundot.airport.common.annotation.Log;
 import com.sundot.airport.common.core.controller.BaseController;
@@ -26,6 +28,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
+import java.util.stream.Collectors;
 
 /**
  * 台账一键导入Controller
@@ -35,6 +38,7 @@ import java.util.UUID;
 @RequestMapping("/ledger/import")
 public class LedgerImportController extends BaseController {
 
+    private static final Integer START_LINE_NUMBER = 3;
     @Autowired private ILedgerSupervisionProblemService supervisionProblemService;
     @Autowired private ILedgerPatrolInspectionService patrolInspectionService;
     @Autowired private ILedgerRealtimeInterceptionService realtimeInterceptionService;
@@ -82,6 +86,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSupervisionProblem> existList = supervisionProblemService.selectSupervisionProblemList(new LedgerSupervisionProblem());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSupervisionProblem item = list.get(i);
+                String tag = item.getInspectedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         supervisionProblemService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -128,6 +155,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerRealtimeInterception> existList = realtimeInterceptionService.selectList(new LedgerRealtimeInterception());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectorName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerRealtimeInterception item = list.get(i);
+                String tag = item.getInspectorName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         realtimeInterceptionService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -151,6 +201,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerServicePatrol> existList = servicePatrolService.selectList(new LedgerServicePatrol());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerServicePatrol item = list.get(i);
+                String tag = item.getInspectedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         servicePatrolService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -197,6 +270,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSecurityTest> existList = securityTestService.selectList(new LedgerSecurityTest());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getTestedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSecurityTest item = list.get(i);
+                String tag = item.getTestedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         securityTestService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -243,6 +339,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerUnsafeEvent> existList = unsafeEventService.selectList(new LedgerUnsafeEvent());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getResponsibleName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerUnsafeEvent item = list.get(i);
+                String tag = item.getResponsibleName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         unsafeEventService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -275,6 +394,29 @@ public class LedgerImportController extends BaseController {
             cal.set(java.util.Calendar.SECOND, timeCal.get(java.util.Calendar.SECOND));
             item.setRecordDate(cal.getTime());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSeizureStats> existList = seizureStatsService.selectList(new LedgerSeizureStats());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectorName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSeizureStats item = list.get(i);
+                String tag = item.getInspectorName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         seizureStatsService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -301,6 +443,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerTerminalBonus> existList = terminalBonusService.selectList(new LedgerTerminalBonus());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getScoreDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerTerminalBonus item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getScoreDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         terminalBonusService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -347,6 +512,29 @@ public class LedgerImportController extends BaseController {
             item.setSourceType("1");
             item.setCreateBy(getUsername());
         });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerRewardApproval> existList = rewardApprovalService.selectList(new LedgerRewardApproval());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getApproveDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerRewardApproval item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getApproveDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         rewardApprovalService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -488,6 +676,29 @@ public class LedgerImportController extends BaseController {
             return AjaxResult.error("导入数据为空或解析失败，请检查Excel表头是否与模板一致");
         }
         list.forEach(item -> { item.setImportBatch(batchNo); item.setSourceType("1"); item.setCreateBy(getUsername()); });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerLeaveSpecial> existList = leaveSpecialService.selectList(new LedgerLeaveSpecial());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getStartDate() + "_" + item.getEndDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerLeaveSpecial item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getStartDate() + "_" + item.getEndDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         leaveSpecialService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -534,6 +745,29 @@ public class LedgerImportController extends BaseController {
             return AjaxResult.error("导入数据为空或解析失败，请检查Excel表头是否与模板一致");
         }
         list.forEach(item -> { item.setImportBatch(batchNo); item.setSourceType("1"); item.setCreateBy(getUsername()); });
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerQualificationLevel> existList = qualificationLevelService.selectQueryList(new LedgerQualificationLevel());
+            List<String> repeatList = new ArrayList<>();
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerQualificationLevel item = list.get(i);
+                String tag = item.getPersonName();
+                if (existConditionList.contains(item.getPersonName())) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return AjaxResult.error("导入失败，第【" + repeatNum + "】行数据重复，请检查台账");
+            }
+        }
         qualificationLevelService.batchInsert(list);
         return AjaxResult.success("导入成功，共" + list.size() + "条");
     }
@@ -547,7 +781,7 @@ public class LedgerImportController extends BaseController {
     @PostMapping("/combined")
     public AjaxResult importCombined(@RequestParam("file") MultipartFile file) throws Exception {
         String batchNo = generateBatchNo();
-        Map<String, String> result = combinedImportService.importAll(file, batchNo, getUsername());
+        List<ImportResultVO> result = combinedImportService.importAll(file, batchNo, getUsername());
         return AjaxResult.success(result);
     }
 

airport-common/src/main/java/com/sundot/airport/common/dto/ImportResultDto.java

@@ -0,0 +1,39 @@
+package com.sundot.airport.common.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * 导入结果通用报文
+ *
+ * @author ruoyi
+ * @date 2025-09-07
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ImportResultDto implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 导入数量
+     */
+    private Integer importNum;
+
+    /**
+     * 跳过数量
+     */
+    private Integer skipNum;
+
+    /**
+     * 重复行数描述
+     */
+    private String repeatNumDesc;
+
+}

airport-common/src/main/java/com/sundot/airport/common/dto/ImportResultVO.java

@@ -0,0 +1,34 @@
+package com.sundot.airport.common.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * 导入结果报文
+ *
+ * @author ruoyi
+ * @date 2025-09-07
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ImportResultVO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 表名
+     */
+    private String sheetName;
+
+    /**
+     * 导入结果
+     */
+    private String sheetResult;
+
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/ILedgerCombinedImportService.java

@@ -1,7 +1,9 @@
 package com.sundot.airport.ledger.service;
 
+import com.sundot.airport.common.dto.ImportResultVO;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -18,7 +20,7 @@ public interface ILedgerCombinedImportService {
      * @param username 操作人
      * @return Map<Sheet名, 导入结果描述>
      */
-    Map<String, String> importAll(MultipartFile file, String batchNo, String username) throws Exception;
+    List<ImportResultVO> importAll(MultipartFile file, String batchNo, String username) throws Exception;
 
     /**
      * 按导入时间范围清理全部台账表数据（20张表 + 台账同步配分事项）

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerCombinedImportServiceImpl.java

@@ -1,9 +1,15 @@
 package com.sundot.airport.ledger.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.text.StrBuilder;
+import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sundot.airport.common.core.domain.entity.SysDept;
 import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.dto.ImportResultDto;
+import com.sundot.airport.common.dto.ImportResultVO;
 import com.sundot.airport.common.enums.DeptType;
 import com.sundot.airport.system.domain.SysPost;
 import com.sundot.airport.system.domain.BasePosition;
@@ -45,6 +51,7 @@ import java.util.stream.Collectors;
 @Service
 public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportService {
 
+    private static final Integer START_LINE_NUMBER = 3;
     @Autowired private ILedgerSupervisionProblemService supervisionProblemService;
     @Autowired private ILedgerPatrolInspectionService patrolInspectionService;
     @Autowired private ILedgerRealtimeInterceptionService realtimeInterceptionService;
@@ -109,8 +116,8 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
     // ════════════════════════════════════════════════════════════════
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public Map<String, String> importAll(MultipartFile file, String batchNo, String username) throws Exception {
-        Map<String, String> result = new LinkedHashMap<>();
+    public List<ImportResultVO> importAll(MultipartFile file, String batchNo, String username) throws Exception {
+        List<ImportResultVO> result = new ArrayList<>();
         boolean hasError = false;
         try (Workbook wb = WorkbookFactory.create(file.getInputStream())) {
             buildImportCache();
@@ -120,14 +127,22 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
                 String handler   = entry.getValue();
                 Sheet sheet = wb.getSheet(sheetName);
                 if (sheet == null) {
-                    result.put(sheetName, "未找到该Sheet，跳过");
+                    result.add(ImportResultVO.builder().sheetName(sheetName).sheetResult("未找到该Sheet，跳过").build());
                     continue;
                 }
                 try {
-                    int count = self.dispatchInNestedTransaction(sheet, handler, batchNo, username);
-                    result.put(sheetName, "导入成功 " + count + " 条");
+                    ImportResultDto resultDto = self.dispatchInNestedTransaction(sheet, handler, batchNo, username);
+                    StrBuilder sb = new StrBuilder();
+                    sb.append("导入【").append(String.valueOf(resultDto.getImportNum())).append("】条");
+                    if (ObjUtil.isNotNull(resultDto.getSkipNum())) {
+                        sb.append(",跳过【").append(String.valueOf(resultDto.getSkipNum())).append("】条");
+                    }
+                    if (StrUtil.isNotEmpty(resultDto.getRepeatNumDesc())) {
+                        sb.append(",第【").append(resultDto.getRepeatNumDesc()).append("】行数据重复，请检查台账");
+                    }
+                    result.add(ImportResultVO.builder().sheetName(sheetName).sheetResult(sb.toString()).build());
                 } catch (Exception e) {
-                    result.put(sheetName, "导入失败: " + e.getMessage());
+                    result.add(ImportResultVO.builder().sheetName(sheetName).sheetResult("导入失败: " + e.getMessage()).build());
                     hasError = true;
                 }
             }
@@ -142,11 +157,11 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
 
 
     @Transactional(propagation = Propagation.NESTED, rollbackFor = Exception.class)
-    public int dispatchInNestedTransaction(Sheet sheet, String handler, String batchNo, String username) {
+    public ImportResultDto dispatchInNestedTransaction(Sheet sheet, String handler, String batchNo, String username) {
         return dispatch(sheet, handler, batchNo, username);
     }
 
-    private int dispatch(Sheet sheet, String handler, String batchNo, String username) {
+    private ImportResultDto dispatch(Sheet sheet, String handler, String batchNo, String username) {
         switch (handler) {
             case "supervisionProblem":    return doSupervisionProblem(sheet, batchNo, username);
 //            case "patrolInspection":      return doPatrolInspection(sheet, batchNo, username);
@@ -169,7 +184,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
 //            case "healthSoldier":         return doHealthSoldier(sheet, batchNo, username);
 //            case "dormFireSafety":        return doDormFireSafety(sheet, batchNo, username);
 //            case "trainingIssue":         return doTrainingIssue(sheet, batchNo, username);
-            default: return 0;
+            default: return ImportResultDto.builder().importNum(0).build();
         }
     }
 
@@ -182,7 +197,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      *          问题类型(6) 整改措施(7) 依据(8) 问题层级(9) 附件(10)
      *          整改情况(11) 整改佐证材料(12) 巡查人员(13)
      */
-    private int doSupervisionProblem(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doSupervisionProblem(Sheet sheet, String batchNo, String username) {
         List<LedgerSupervisionProblem> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerSupervisionProblem o = new LedgerSupervisionProblem();
@@ -248,8 +263,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSupervisionProblem> existList = supervisionProblemService.selectSupervisionProblemList(new LedgerSupervisionProblem());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSupervisionProblem item = list.get(i);
+                String tag = item.getInspectedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         supervisionProblemService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 2. 队室三级质控巡查记录表 → ledger_patrol_inspection
@@ -336,7 +376,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * 导入顺序：时间(0) 区域(1) 工作点(2) 岗位(3) 责任人(4) 实时质控拦截物品(5)
      *          个数(6) 问题层级(7) 附件(8) 检查人员(9)
      */
-    private int doRealtimeInterception(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doRealtimeInterception(Sheet sheet, String batchNo, String username) {
         List<LedgerRealtimeInterception> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerRealtimeInterception o = new LedgerRealtimeInterception();
@@ -400,8 +440,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerRealtimeInterception> existList = realtimeInterceptionService.selectList(new LedgerRealtimeInterception());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectorName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerRealtimeInterception item = list.get(i);
+                String tag = item.getInspectorName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         realtimeInterceptionService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 4. 服务巡查 → ledger_service_patrol
@@ -409,7 +474,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      *          问题类型(6) 整改措施(7) 问题层级(8) 附件(9) 整改情况(10)
      *          佐证材料(11) 检查人员(12)
      */
-    private int doServicePatrol(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doServicePatrol(Sheet sheet, String batchNo, String username) {
         List<LedgerServicePatrol> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerServicePatrol o = new LedgerServicePatrol();
@@ -477,15 +542,40 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerServicePatrol> existList = servicePatrolService.selectList(new LedgerServicePatrol());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerServicePatrol item = list.get(i);
+                String tag = item.getInspectedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         servicePatrolService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 5. 投诉情况 → ledger_complaint
      * R2: 时间(0) 航班号(1) 旅客姓名(2) 责任人(3) 投诉情况(4)
      *     旅客诉求(5) 类别(6) 渠道来源(7) 是否有责(8) 处理进度(9)
      */
-    private int doComplaint(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doComplaint(Sheet sheet, String batchNo, String username) {
         List<LedgerComplaint> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerComplaint o = new LedgerComplaint();
@@ -522,7 +612,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             list.add(o);
         }
         complaintService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 6. 安保测试记录表（部门）→ ledger_security_test
@@ -530,7 +620,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      *          被测试人员(5) 被测试岗位(6) 测试物品(7) 图片或视频(8) 是否通过(9)
      *          层级(10) 整改措施(11) 整改材料(12)
      */
-    private int doSecurityTest(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doSecurityTest(Sheet sheet, String batchNo, String username) {
         List<LedgerSecurityTest> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerSecurityTest o = new LedgerSecurityTest();
@@ -623,9 +713,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
                 }
             }
         }
-        
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSecurityTest> existList = securityTestService.selectList(new LedgerSecurityTest());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getTestedName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSecurityTest item = list.get(i);
+                String tag = item.getTestedName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         securityTestService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 7. 通道过检率（pivot表）→ ledger_channel_pass_rate
@@ -633,9 +747,9 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * R2: 小组(0) 2026年1月平均过检率(1) 2026年2月...(2) ...
      * 每行展开为多条（每月一条）
      */
-    private int doChannelPassRate(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doChannelPassRate(Sheet sheet, String batchNo, String username) {
         Row headerRow = sheet.getRow(1);
-        if (headerRow == null) return 0;
+        if (headerRow == null) return ImportResultDto.builder().importNum(0).build();
 
         // 找月份列（从列1开始）
         List<int[]> monthCols = new ArrayList<>();
@@ -688,7 +802,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             }
         }
         channelPassRateService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /**
@@ -727,7 +841,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * R2: 时间(0) 事件描述(1) 类别(2) 航班号(3) 责任人(4)
      *     涉及物品(5) 岗位(6) 区域(7) 通道号(8) 附件(9)
      */
-    private int doUnsafeEvent(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doUnsafeEvent(Sheet sheet, String batchNo, String username) {
         List<LedgerUnsafeEvent> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerUnsafeEvent o = new LedgerUnsafeEvent();
@@ -789,8 +903,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerUnsafeEvent> existList = unsafeEventService.selectList(new LedgerUnsafeEvent());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getResponsibleName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerUnsafeEvent item = list.get(i);
+                String tag = item.getResponsibleName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         unsafeEventService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 9. 2026查获违规品统计 → ledger_seizure_stats
@@ -800,7 +939,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      *     违规物品(16) 二级分类(17) 数量(18) 事件简况(19) 查获位置(20)
      *     处理结果(21) 备注(22)
      */
-    private int doSeizureStats(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doSeizureStats(Sheet sheet, String batchNo, String username) {
         List<LedgerSeizureStats> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerSeizureStats o = new LedgerSeizureStats();
@@ -881,14 +1020,39 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerSeizureStats> existList = seizureStatsService.selectList(new LedgerSeizureStats());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getInspectorName() + "_" + item.getRecordDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerSeizureStats item = list.get(i);
+                String tag = item.getInspectorName() + "_" + item.getRecordDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         seizureStatsService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 10. 航站楼加分 → ledger_terminal_bonus
      * R2: 姓名(0) 所属航站楼(1) 记分值(2) 记分日期(3) 捡到物品金额(4) 记分条款(5)
      */
-    private int doTerminalBonus(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doTerminalBonus(Sheet sheet, String batchNo, String username) {
         List<LedgerTerminalBonus> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerTerminalBonus o = new LedgerTerminalBonus();
@@ -919,14 +1083,39 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerTerminalBonus> existList = terminalBonusService.selectList(new LedgerTerminalBonus());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getScoreDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerTerminalBonus item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getScoreDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         terminalBonusService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 11. 成绩收集 → ledger_exam_score
      * R2: 类别(0) 期数(1) 考试人员(2) 理论成绩(3) 图像成绩(4)
      */
-    private int doExamScore(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doExamScore(Sheet sheet, String batchNo, String username) {
         List<LedgerExamScore> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerExamScore o = new LedgerExamScore();
@@ -957,7 +1146,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             list.add(o);
         }
         examScoreService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 12. 小额奖励审批单-安检-质控 → ledger_reward_approval
@@ -965,7 +1154,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * R1: 姓名(0) 查获（事件）时间(1) 奖励类别(2) 查获物品(3) 人员类别(4)
      *     主要事由简述(5) 处置结果(6) 证明材料(7)
      */
-    private int doRewardApproval(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doRewardApproval(Sheet sheet, String batchNo, String username) {
         List<LedgerRewardApproval> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {  // 跳2行表头
             LedgerRewardApproval o = new LedgerRewardApproval();
@@ -996,8 +1185,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerRewardApproval> existList = rewardApprovalService.selectList(new LedgerRewardApproval());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getApproveDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerRewardApproval item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getApproveDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         rewardApprovalService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 13. 部门奖惩记录表 → ledger_reward_penalty
@@ -1027,7 +1241,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * R2: 姓名(0) 时间（起）(1) 时间（止）(2) 休假类别(3) 天数/时长(4)
      * 天数/时长列可能是纯数字（天）或"X小时"格式；小时值按8小时/天换算成天数
      */
-    private int doLeaveSpecial(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doLeaveSpecial(Sheet sheet, String batchNo, String username) {
         List<LedgerLeaveSpecial> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerLeaveSpecial o = new LedgerLeaveSpecial();
@@ -1057,8 +1271,33 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerLeaveSpecial> existList = leaveSpecialService.selectList(new LedgerLeaveSpecial());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName() + "_" + item.getStartDate() + "_" + item.getEndDate()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerLeaveSpecial item = list.get(i);
+                String tag = item.getPersonName() + "_" + item.getStartDate() + "_" + item.getEndDate();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         leaveSpecialService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 
     /** 15. 锦旗及感谢信 → ledger_banner_letter
@@ -1741,7 +1980,7 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
      * 导入顺序：姓名(0) 一级发证时间(1) 二级发证时间(2) 三级发证时间(3)
      *          四级发证时间(4) 五级发证时间(5)
      */
-    private int doQualificationLevel(Sheet sheet, String batchNo, String username) {
+    private ImportResultDto doQualificationLevel(Sheet sheet, String batchNo, String username) {
         List<LedgerQualificationLevel> list = new ArrayList<>();
         for (Object[] c : dataRows(sheet, 2)) {
             LedgerQualificationLevel o = new LedgerQualificationLevel();
@@ -1773,7 +2012,32 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
             o.setCreateBy(username);
             list.add(o);
         }
+        if (CollUtil.isNotEmpty(list)) {
+            List<LedgerQualificationLevel> existList = qualificationLevelService.selectQueryList(new LedgerQualificationLevel());
+            List<String> repeatList = new ArrayList<>();
+            Integer skipNum = 0;
+            List<Integer> existIndexList = new ArrayList<>();
+            List<String> existConditionList = existList.stream().map(item -> item.getPersonName()).collect(Collectors.toList());
+            for (int i = 0; i < list.size(); i++) {
+                LedgerQualificationLevel item = list.get(i);
+                String tag = item.getPersonName();
+                if (existConditionList.contains(tag)) {
+                    existIndexList.add(i + START_LINE_NUMBER);
+                } else {
+                    if (repeatList.contains(tag)) {
+                        existIndexList.add(i + START_LINE_NUMBER);
+                    } else {
+                        repeatList.add(tag);
+                        skipNum++;
+                    }
+                }
+            }
+            if (CollUtil.isNotEmpty(existIndexList)) {
+                String repeatNum = existIndexList.stream().map(Object::toString).collect(Collectors.joining("、"));
+                return ImportResultDto.builder().importNum(0).skipNum(skipNum).repeatNumDesc(repeatNum).build();
+            }
+        }
         qualificationLevelService.batchInsert(list);
-        return list.size();
+        return ImportResultDto.builder().importNum(list.size()).build();
     }
 }