forked from github/dataease
30 lines
1.0 KiB
Java
30 lines
1.0 KiB
Java
package io.dataease.job.sechedule;
|
|
|
|
import com.google.gson.Gson;
|
|
import io.dataease.commons.utils.LogUtil;
|
|
import org.quartz.*;
|
|
|
|
public abstract class DeScheduleJob implements Job {
|
|
|
|
protected String datasetTableId;
|
|
protected String expression;
|
|
protected String taskId;
|
|
protected String updateType;
|
|
|
|
@Override
|
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
|
JobKey jobKey = context.getTrigger().getJobKey();
|
|
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
|
|
this.datasetTableId = jobDataMap.getString("datasetTableId");
|
|
this.expression = jobDataMap.getString("expression");
|
|
this.taskId = jobDataMap.getString("taskId");
|
|
this.updateType = jobDataMap.getString("updateType");
|
|
|
|
LogUtil.info(jobKey.getGroup() + " Running: " + datasetTableId);
|
|
LogUtil.info("CronExpression: " + expression);
|
|
businessExecute(context);
|
|
}
|
|
|
|
abstract void businessExecute(JobExecutionContext context);
|
|
}
|