From 419a33c32bf72a7cc2403b79658d4228ff254eec Mon Sep 17 00:00:00 2001 From: taojinlong Date: Wed, 6 Dec 2023 13:52:23 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E6=B2=A1=E6=9C=89=E5=B7=B2=E5=AE=8C?= =?UTF-8?q?=E6=88=90=E7=9A=84=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1=EF=BC=8C?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E8=BF=9B=E8=A1=8C=E5=A2=9E=E9=87=8F=E5=90=8C?= =?UTF-8?q?=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/dataease/service/dataset/ExtractDataService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java b/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java index d8a0f693b1..a60555ba88 100644 --- a/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java +++ b/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java @@ -362,13 +362,14 @@ public class ExtractDataService { case add_scope: // 增量更新 try { + if (datasetTable.getLastUpdateTime() == null || datasetTable.getLastUpdateTime() == 0) { + throw new Exception("未进行全量同步"); + } if (datasource.getType().equalsIgnoreCase(DatasourceTypes.api.name())) { extractData(datasetTable, datasource, datasetTableFields, "incremental_add", null); } else { DatasetTableIncrementalConfig datasetTableIncrementalConfig = dataSetTableService.incrementalConfig(datasetTableId); - if (datasetTable.getLastUpdateTime() == null || datasetTable.getLastUpdateTime() == 0) { - throw new Exception("未进行全量同步"); - } + execTime = System.currentTimeMillis(); if (datasetTableIncrementalConfig != null && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd()) && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd().replace(" ", ""))) {// 增量添加