From d14f381b3a23808fbc582363a441d3b48a794448 Mon Sep 17 00:00:00 2001
From: wanxiaoli <wanxiaoli123>
Date: Mon, 12 Jan 2026 20:39:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=AF=BC=E5=87=BA=E5=AF=BC?=
 =?UTF-8?q?=E5=85=A5=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TsTaskServiceImpl.java       | 20 ++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)

diff --git a/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsTaskServiceImpl.java b/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsTaskServiceImpl.java
index 3162f0e..2fb98f8 100644
--- a/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsTaskServiceImpl.java
+++ b/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsTaskServiceImpl.java
@@ -47,9 +47,7 @@ import org.springframework.dao.DataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
 
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
+import java.io.*;
 import java.lang.reflect.Field;
 import java.nio.charset.StandardCharsets;
 import java.sql.*;
@@ -1398,6 +1396,22 @@ public class TsTaskServiceImpl extends ServiceImpl<TsTaskMapper, TsTask> impleme
 
 
 
+
+    private void executeFileBatch(List<String> inserts) {
+
+        String mergedSql = mergeFileInsert(inserts);
+
+        try {
+            jdbcTemplate.update(mergedSql);
+            LOGGER.info("ts_files 批量插入 {} 条", inserts.size());
+        } catch (Exception e) {
+            LOGGER.error("ts_files 批量插入失败", e);
+            throw e; // 触发事务回滚
+        }
+    }
+
+
+
     /**
      * 合并同一表的 INSERT VALUES
      */