From d9f01f760bac2b37e8bc1c37b522ecc2f2a4f193 Mon Sep 17 00:00:00 2001
From: wang <wzh@>
Date: Thu, 24 Sep 2026 11:39:22 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E4=B8=8D=E8=BF=81=E7=A7=BB?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dataserviceyy/service/FtpSyncService.java | 31 +++++++++----------
 1 file changed, 15 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/threecloud/dataserviceyy/service/FtpSyncService.java b/src/main/java/com/threecloud/dataserviceyy/service/FtpSyncService.java
index cf282e3..12c7953 100644
--- a/src/main/java/com/threecloud/dataserviceyy/service/FtpSyncService.java
+++ b/src/main/java/com/threecloud/dataserviceyy/service/FtpSyncService.java
@@ -471,23 +471,22 @@ public class FtpSyncService {
     private void recordProcessedFile(FtpCityConfig city, String fileName, long fileSize,
                                      int recordCount, int successCount, int failCount,
                                      long processTime, String errorMsg) {
-        try {
-            FtpProcessedFile record = new FtpProcessedFile();
-            record.setCityCode(city.getCityCode());
-            record.setCityName(city.getCityName());
-            record.setFileName(fileName);
-            record.setFileSize(fileSize);
-            record.setProcessStatus(failCount == 0 ? "1" : "0");
-            record.setRecordCount(recordCount);
-            record.setSuccessCount(successCount);
-            record.setFailCount(failCount);
-            record.setProcessTime(processTime);
-            record.setErrorMsg(errorMsg);
-            processedFileMapper.insert(record);
-            logger.debug("【FTP文件】已记录处理结果: {}", fileName);
-        } catch (Exception e) {
-            logger.error("【FTP文件】记录处理结果失败: {}, 原因={}", fileName, e.getMessage());
+        FtpProcessedFile record = new FtpProcessedFile();
+        record.setCityCode(city.getCityCode());
+        record.setCityName(city.getCityName());
+        record.setFileName(fileName);
+        record.setFileSize(fileSize);
+        record.setProcessStatus(failCount == 0 ? "1" : "0");
+        record.setRecordCount(recordCount);
+        record.setSuccessCount(successCount);
+        record.setFailCount(failCount);
+        record.setProcessTime(processTime);
+        record.setErrorMsg(errorMsg);
+        int inserted = processedFileMapper.insert(record);
+        if (inserted != 1) {
+            throw new IllegalStateException("处理结果写入异常，影响行数=" + inserted + ", fileName=" + fileName);
         }
+        logger.debug("【FTP文件】已记录处理结果: {}", fileName);
     }
 
     /**