失败不迁移文件

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);
     }
 
     /**