From c55871d134abef05787bc442650c2d1b8bd802c8 Mon Sep 17 00:00:00 2001 From: gaoxq <376340421@qq.com> Date: Wed, 27 Aug 2025 23:53:49 +0800 Subject: [PATCH] =?UTF-8?q?API=E6=95=B0=E6=8D=AE=E8=A1=A8=E6=9B=B4?= =?UTF-8?q?=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/mini/capi/job/taskDbSync.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/mini/capi/job/taskDbSync.java b/src/main/java/com/mini/capi/job/taskDbSync.java index 149fb93..870113d 100644 --- a/src/main/java/com/mini/capi/job/taskDbSync.java +++ b/src/main/java/com/mini/capi/job/taskDbSync.java @@ -336,16 +336,16 @@ public class taskDbSync { errorMsg = e.getMessage() != null ? e.getMessage() : e.getClass().getSimpleName(); System.err.println("同步数据失败: " + errorMsg); } - syncTaskService.updateById(task); DbConfig sourceDbConfig = dbConfigService.getById(task.getSourceDbId()); DbConfig targetDbConfig = dbConfigService.getById(task.getTargetDbId()); LocalDateTime endTime = LocalDateTime.now(); - task.setLastSyncTime(endTime); SyncTaskLog taskLog = new SyncTaskLog(task.getTaskId(), task.getTaskName(), task.getSourceDbId(), sourceDbConfig.getDbName(), sourceTable, task.getTargetDbId(), targetDbConfig.getDbName(), targetTable, startTime, endTime, (long) totalRows, (long) successRows, (long) failRows, ustatus, errorMsg, (int) Duration.between(startTime, endTime).getSeconds(), "0"); + task.setLastSyncTime(endTime); taskLogService.save(taskLog); + syncTaskService.updateById(task); } /**