diff --git a/src/main/java/com/mini/capi/job/taskDbSync.java b/src/main/java/com/mini/capi/job/taskDbSync.java index ec61e80..149fb93 100644 --- a/src/main/java/com/mini/capi/job/taskDbSync.java +++ b/src/main/java/com/mini/capi/job/taskDbSync.java @@ -336,14 +336,14 @@ public class taskDbSync { errorMsg = e.getMessage() != null ? e.getMessage() : e.getClass().getSimpleName(); System.err.println("同步数据失败: " + errorMsg); } - task.setLastSyncTime(LocalDateTime.now()); 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, - LocalDateTime.now(), LocalDateTime.now(), (long) totalRows, (long) successRows, (long) failRows, ustatus, + startTime, endTime, (long) totalRows, (long) successRows, (long) failRows, ustatus, errorMsg, (int) Duration.between(startTime, endTime).getSeconds(), "0"); taskLogService.save(taskLog); }