diff --git a/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java b/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java index d49469e0e7..ccdfda18bd 100644 --- a/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java +++ b/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java @@ -297,6 +297,7 @@ public class ExtractDataService { saveErrorLog(datasetTableId, taskId, e); msg = false; lastExecStatus = JobStatus.Error; + execTime = null; } finally { try { deleteFile("all_scope", datasetTableId); }catch (Exception ignore){ System.out.println(ignore.getMessage());} try { sendWebMsg(datasetTable, datasetTableTask, datasetTableTaskLog, msg); }catch (Exception ignore){ System.out.println(ignore.getMessage());} @@ -316,14 +317,17 @@ public class ExtractDataService { return; } - if (datasetTable.getLastUpdateTime() == 0 || datasetTable.getLastUpdateTime() == null) { - updateTableStatus(datasetTableId, datasetTable, JobStatus.Completed, null); - return; - } - if (datasetTableTask == null ) { datasetTableTaskLog = writeDatasetTableTaskLog(datasetTableId, taskId); } + + if (datasetTable.getLastUpdateTime() == null || datasetTable.getLastUpdateTime() == 0) { + updateTableStatus(datasetTableId, datasetTable, JobStatus.Completed, null); + saveErrorLog(datasetTableId, taskId, new Exception("未进行全量同步")); + lastExecStatus = JobStatus.Error; + return; + } + execTime = System.currentTimeMillis(); if (StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd()) && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd().replace(" ", ""))) {// 增量添加 String sql = datasetTableIncrementalConfig.getIncrementalAdd().replace(lastUpdateTime, datasetTable.getLastUpdateTime().toString()) @@ -348,6 +352,7 @@ public class ExtractDataService { saveErrorLog(datasetTableId, taskId, e); msg = false; lastExecStatus = JobStatus.Error; + execTime = null; } finally { try { deleteFile("incremental_add", datasetTableId); deleteFile("incremental_delete", datasetTableId); }catch (Exception ignore){} try { sendWebMsg(datasetTable, datasetTableTask, datasetTableTaskLog, msg); }catch (Exception ignore){} diff --git a/frontend/src/views/system/task/DatasetTaskList.vue b/frontend/src/views/system/task/DatasetTaskList.vue index 53cd99bdf9..ef53ae2cca 100644 --- a/frontend/src/views/system/task/DatasetTaskList.vue +++ b/frontend/src/views/system/task/DatasetTaskList.vue @@ -417,7 +417,8 @@ export default { }, changeTaskStatus(task) { let param = JSON.parse(JSON.stringify(task)); - post('/dataset/task/updateStatus', task).then(response => { + param.status = task.status === 'Underway' ? 'Pending' : 'Underway' + post('/dataset/task/updateStatus', param).then(response => { if(response.success){ task.status = param.status this.$message({