public/dataease
1
0
Fork 0
mirror of https://github.com/dataease/dataease.git synced 2026-06-16 11:21:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(X-Pack): 数据同步任务的调度，统一使用Quartz

Browse Source
This commit is contained in:
jianneng-fit2cloud
2025-08-29 12:50:29 +08:00
parent 9df2e5e7e8
commit bfabc8bc4b
3 changed files with 46 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/core-backend/src/main/java/io/dataease/listener/XpackTaskStarter.java
View File

@@ -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());
}
}
}

15
sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Source.java
View File

@@ -21,4 +21,19 @@ public class Source {
private List<TableField> 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;
}
}

21
sdk/api/api-sync/src/main/java/io/dataease/api/sync/task/dto/Target.java
View File

@@ -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;
}
}