From a90de684d9fd5129bae68e9e5b4d94d6298ca64e Mon Sep 17 00:00:00 2001
From: taojinlong <jinlong@fit2cloud.com>
Date: Mon, 9 Sep 2024 14:57:49 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E6=BA=90=E6=A0=A1=E9=AA=8C=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/dataease/datasource/server/DatasourceServer.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
index cb83fe5337..52a62462f4 100644
--- a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
+++ b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
@@ -130,6 +130,8 @@ public class DatasourceServer implements DatasourceApi {
 
     private boolean isUpdatingStatus = false;
 
+    private static List<Long> syncDsIds = new ArrayList<>();
+
     private void getParents(Long pid, List<Long> ids) {
         CoreDatasource parent = datasourceMapper.selectById(pid);// 查找父级folder
         ids.add(parent.getId());
@@ -1069,11 +1071,16 @@ public class DatasourceServer implements DatasourceApi {
         wrapper.notIn("type", Arrays.asList("Excel", "folder"));
         List<CoreDatasource> datasources = datasourceMapper.selectList(wrapper);
         datasources.forEach(datasource -> {
+            if (!syncDsIds.contains(datasource.getId())) {
+                syncDsIds.add(datasource.getId());
+            }
             commonThreadPool.addTask(() -> {
                 try {
                     LicenseUtil.validate();
                     validate(datasource);
                 } catch (Exception e) {
+                } finally {
+                    syncDsIds.removeIf(id -> id.equals(datasource.getId()));
                 }
             });
         });