diff --git a/core/core-backend/src/main/java/io/dataease/listener/XpackTaskStarter.java b/core/core-backend/src/main/java/io/dataease/listener/XpackTaskStarter.java index eb83895a7c..7c002c30de 100644 --- a/core/core-backend/src/main/java/io/dataease/listener/XpackTaskStarter.java +++ b/core/core-backend/src/main/java/io/dataease/listener/XpackTaskStarter.java @@ -2,6 +2,7 @@ package io.dataease.listener; import io.dataease.job.schedule.DeDataFillingTaskExecutor; import io.dataease.job.schedule.DeTaskExecutor; +import io.dataease.job.schedule.DeXpackDataSyncTaskExecutor; import io.dataease.license.utils.LicenseUtil; import io.dataease.utils.LogUtil; import jakarta.annotation.Resource; @@ -20,6 +21,9 @@ public class XpackTaskStarter implements ApplicationRunner { @Resource private DeDataFillingTaskExecutor deDataFillingTaskExecutor; + @Resource + private DeXpackDataSyncTaskExecutor deXpackDataSyncTaskExecutor; + @Override public void run(ApplicationArguments args) { try { @@ -34,5 +38,11 @@ public class XpackTaskStarter implements ApplicationRunner { } catch (Exception e) { LogUtil.error(e.getMessage(), e.getCause()); } + try { + LicenseUtil.validate(); + deXpackDataSyncTaskExecutor.init(); + } catch (Exception e) { + LogUtil.error(e.getMessage(), e.getCause()); + } } } diff --git a/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Source.java b/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Source.java index 5fba8e1746..2a4110dadc 100644 --- a/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Source.java +++ b/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Source.java @@ -21,4 +21,19 @@ public class Source { private List fieldList; private String incrementField; private String esQuery; + + public Source() { + } + + public Source(Source source) { + this.type = source.type; + this.query = source.query; + this.tables = source.tables; + this.datasource = source.datasource; + this.datasourceId = source.datasourceId; + this.tableExtract = source.tableExtract; + this.fieldList = source.fieldList; + this.incrementField = source.incrementField; + this.esQuery = source.esQuery; + } } diff --git a/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Target.java b/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Target.java index 8aae4df06e..1fed2f32e2 100644 --- a/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Target.java +++ b/sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Target.java @@ -26,4 +26,25 @@ public class Target { private String remarks; private Long incrementOffset; private String incrementOffsetUnit; + + public Target() { + } + + public Target(Target target) { + this.type = target.type; + this.createTable = target.createTable; + this.fieldList = target.fieldList; + this.tableName = target.tableName; + this.datasource = target.datasource; + this.datasourceId = target.datasourceId; + this.targetProperty = target.targetProperty; + this.incrementSync = target.incrementSync; + this.incrementField = target.incrementField; + this.datasourceVersion = target.datasourceVersion; + this.faultToleranceRate = target.faultToleranceRate; + this.incrementFieldType = target.incrementFieldType; + this.remarks = target.remarks; + this.incrementOffset = target.incrementOffset; + this.incrementOffsetUnit = target.incrementOffsetUnit; + } }