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 impleme + + private void executeFileBatch(List 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 */