From 4e00a3a6e9e2dfd5801c918d68a61b55e5872352 Mon Sep 17 00:00:00 2001
From: gaoxq <376340421@qq.com>
Date: Sun, 7 Sep 2025 15:47:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E5=89=8D=E7=AB=AF?=
 =?UTF-8?q?=E7=9B=AE=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/mini/capi/sys/service/DbService.java  | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/mini/capi/sys/service/DbService.java b/src/main/java/com/mini/capi/sys/service/DbService.java
index 6e53023..e33f4f5 100644
--- a/src/main/java/com/mini/capi/sys/service/DbService.java
+++ b/src/main/java/com/mini/capi/sys/service/DbService.java
@@ -39,7 +39,6 @@ public class DbService {
 
 
     private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMdd");
-    private static final String dsValue = LocalDate.now().format(DATE_FORMATTER);
 
 
     public ApiResult<List<TabResult>> listSourceTables(String dbId) {
@@ -83,7 +82,6 @@ public class DbService {
     }
 
 
-
     /**
      * 运行全部任务
      */
@@ -103,7 +101,7 @@ public class DbService {
     /**
      * 运行单个任务
      */
-    public ApiResult<?> jobSyncOneTask( String taskId) {
+    public ApiResult<?> jobSyncOneTask(String taskId) {
         try {
             SyncTask task = syncTaskService.getById(taskId);
             // 记录是否有任务失败（仅用于后台日志，不影响接口返回）
@@ -143,6 +141,7 @@ public class DbService {
      * 同步表数据
      */
     public void syncTableData(SyncTask task, JdbcTemplate sourceJdbc, JdbcTemplate targetJdbc) {
+        String dsValue = LocalDate.now().format(DATE_FORMATTER);
         try {
             // 确保源表和目标表名转为小写
             String sourceTable = task.getSourceTable();
@@ -152,9 +151,9 @@ public class DbService {
                 createTargetTable(sourceJdbc, targetJdbc, sourceTable, targetTable);
             }
             // 2. 清空目标表当前ds值的数据
-            clearTargetTableData(targetJdbc, targetTable);
+            clearTargetTableData(targetJdbc, targetTable, dsValue);
             // 3. 全量同步数据
-            syncAllData(task, sourceJdbc, targetJdbc, sourceTable, targetTable);
+            syncAllData(task, sourceJdbc, targetJdbc, sourceTable, targetTable, dsValue);
         } catch (Exception e) {
             System.err.println("表同步失败: " + e.getMessage());
         }
@@ -311,7 +310,7 @@ public class DbService {
     /**
      * 清空目标表中当前ds值的数据
      */
-    private void clearTargetTableData(JdbcTemplate targetJdbc, String targetTable) {
+    private void clearTargetTableData(JdbcTemplate targetJdbc, String targetTable, String dsValue) {
         String sql = "DELETE FROM " + targetTable + " WHERE ds = ?";
         targetJdbc.update(sql, dsValue);
     }
@@ -320,7 +319,8 @@ public class DbService {
      * 全量同步数据
      */
     private void syncAllData(SyncTask task, JdbcTemplate sourceJdbc, JdbcTemplate targetJdbc,
-                             String sourceTable, String targetTable) {
+                             String sourceTable, String targetTable, String dsValue) {
+
         LocalDateTime startTime = LocalDateTime.now();
         int totalRows = 0;
         int successRows = 0;