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