|
|
@ -45,6 +45,8 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
@Autowired
|
|
|
|
private TaskSqlMapper taskSqlMapper;
|
|
|
|
private TaskSqlMapper taskSqlMapper;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
|
|
|
private Scheduler scheduler;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 插入
|
|
|
|
* 插入
|
|
|
@ -114,7 +116,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
return response;
|
|
|
|
return response;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
response.setResult(result);
|
|
|
|
response.setResult(result);
|
|
|
|
Scheduler scheduler = LocalData.getBean(Scheduler.class);
|
|
|
|
|
|
|
|
scheduler.remove(String.valueOf(request.getId()));
|
|
|
|
scheduler.remove(String.valueOf(request.getId()));
|
|
|
|
|
|
|
|
|
|
|
|
return response;
|
|
|
|
return response;
|
|
|
@ -168,7 +169,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
if (request.getValid()) {
|
|
|
|
if (request.getValid()) {
|
|
|
|
createOrRepeat(MapperUtil.map(request, TaskSql.class));
|
|
|
|
createOrRepeat(MapperUtil.map(request, TaskSql.class));
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
Scheduler scheduler = LocalData.getBean(Scheduler.class);
|
|
|
|
|
|
|
|
scheduler.remove(String.valueOf(request.getId()));
|
|
|
|
scheduler.remove(String.valueOf(request.getId()));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -214,7 +214,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
public boolean createOrRepeat(TaskSql taskSql) {
|
|
|
|
public boolean createOrRepeat(TaskSql taskSql) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
if ("Cron".equals(taskSql.getTaskType())) {
|
|
|
|
if ("Cron".equals(taskSql.getTaskType())) {
|
|
|
|
Scheduler scheduler = LocalData.getBean(Scheduler.class);
|
|
|
|
|
|
|
|
scheduler.createOrRepeat(new RunCronTask() {
|
|
|
|
scheduler.createOrRepeat(new RunCronTask() {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
@ -232,6 +231,11 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public String taskNote() {
|
|
|
|
|
|
|
|
return taskSql.getTaskNote();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
protected void task() {
|
|
|
|
protected void task() {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
@ -243,7 +247,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if ("DelayRepeat".equals(taskSql.getTaskType())) {
|
|
|
|
if ("DelayRepeat".equals(taskSql.getTaskType())) {
|
|
|
|
Scheduler scheduler = LocalData.getBean(Scheduler.class);
|
|
|
|
|
|
|
|
scheduler.createOrRepeat(new RunDelayRepeatTask() {
|
|
|
|
scheduler.createOrRepeat(new RunDelayRepeatTask() {
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public Duration interval() {
|
|
|
|
public Duration interval() {
|
|
|
@ -261,6 +264,11 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public String taskNote() {
|
|
|
|
|
|
|
|
return taskSql.getTaskNote();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
protected void task() {
|
|
|
|
protected void task() {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
@ -272,7 +280,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if ("FixRepeat".equals(taskSql.getTaskType())) {
|
|
|
|
if ("FixRepeat".equals(taskSql.getTaskType())) {
|
|
|
|
Scheduler scheduler = LocalData.getBean(Scheduler.class);
|
|
|
|
|
|
|
|
scheduler.createOrRepeat(new RunFixRepeatTask() {
|
|
|
|
scheduler.createOrRepeat(new RunFixRepeatTask() {
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public Duration interval() {
|
|
|
|
public Duration interval() {
|
|
|
@ -290,6 +297,11 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
return String.valueOf(taskSql.getId());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public String taskNote() {
|
|
|
|
|
|
|
|
return taskSql.getTaskNote();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
protected void task() {
|
|
|
|
protected void task() {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|