parent
a920112457
commit
f5c4ad557c
@ -0,0 +1,55 @@
|
|||||||
|
package ${basePackage}.config;
|
||||||
|
|
||||||
|
import ${basePackage}.frame.auth.LocalData;
|
||||||
|
import ${basePackage}.frame.schedule.RunDelayRepeatTask;
|
||||||
|
import ${basePackage}.module.system.ent.TaskSql;
|
||||||
|
import ${basePackage}.module.system.mgr.TaskSqlManager;
|
||||||
|
import ${basePackage}.module.system.req.TaskSqlFindRequest;
|
||||||
|
import ${basePackage}.module.system.rsp.TaskSqlFindResponse;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.context.annotation.Configuration;
|
||||||
|
|
||||||
|
import javax.annotation.PostConstruct;
|
||||||
|
import java.time.Duration;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sql任务注册配置
|
||||||
|
*/
|
||||||
|
@Configuration
|
||||||
|
public class TaskSqlConfig {
|
||||||
|
@Autowired
|
||||||
|
private ScheduleConfig scheduleConfig;
|
||||||
|
@Autowired
|
||||||
|
private TaskSqlManager taskSqlManager;
|
||||||
|
|
||||||
|
|
||||||
|
@PostConstruct
|
||||||
|
public void ss() {
|
||||||
|
TaskSqlFindRequest taskSqlFindRequest = new TaskSqlFindRequest();
|
||||||
|
taskSqlFindRequest.setValid(true);
|
||||||
|
taskSqlFindRequest.setPageSize(0);
|
||||||
|
TaskSqlFindResponse taskSqlFindResponse = taskSqlManager.find(taskSqlFindRequest, LocalData.getSysToken());
|
||||||
|
for (TaskSql taskSql : taskSqlFindResponse.getResult()) {
|
||||||
|
if ("DelayRepeat".equals(taskSql.getTaskType())) {
|
||||||
|
scheduleConfig.createOrRepeat(new RunDelayRepeatTask() {
|
||||||
|
@Override
|
||||||
|
public Duration interval() {
|
||||||
|
String typeValue = taskSql.getTypeValue();
|
||||||
|
return Duration.ofSeconds(Integer.parseInt(typeValue));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String taskId() {
|
||||||
|
return String.valueOf(taskSql.getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in new issue