package com.iplatform.scheduler.service;
|
|
import com.iplatform.model.po.S_scheduler;
|
import com.iplatform.scheduler.Constants;
|
import com.walker.db.page.GenericPager;
|
import com.walker.db.page.ListPageContext;
|
import com.walker.db.page.PageSearch;
|
import com.walker.infrastructure.utils.DateUtils;
|
import com.walker.jdbc.service.BaseServiceImpl;
|
import org.springframework.stereotype.Service;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 调度任务数据库操作。
|
* @author 时克英
|
* @date 2022-09-07
|
*/
|
@Service
|
public class SchedulerServiceImpl extends BaseServiceImpl {
|
|
private static final String SQL_PAGE_LIST_SEARCH = "select * from s_scheduler where dept=0 or dept=:dept order by create_time desc";
|
private static final String SQL_PAGE_LIST = "select * from s_scheduler order by create_time desc";
|
|
public GenericPager<S_scheduler> queryPageSchedulerList(long dept){
|
PageSearch pageSearch = ListPageContext.getPageSearch();
|
if(dept < 0){
|
return this.selectSplit(SQL_PAGE_LIST, new Object[]{}, pageSearch.getPageIndex(), pageSearch.getPageSize(), new S_scheduler());
|
}
|
Map<String, Object> parameters = new HashMap<>();
|
parameters.put("dept", dept);
|
return this.selectSplit(SQL_PAGE_LIST_SEARCH, parameters, pageSearch.getPageIndex(), pageSearch.getPageSize(), new S_scheduler());
|
}
|
|
/**
|
* 查询正在运行（包含：暂停的）状态的调度器记录
|
* @return
|
*/
|
public List<S_scheduler> queryRunningSchedulers(){
|
return this.select(new S_scheduler(), "where status >= ? and status <= ?", new Object[]{1,2});
|
}
|
|
/**
|
* 调度器启动，状态更新
|
* @param id
|
*/
|
public void execUpdateSchedulerStarted(int id){
|
S_scheduler e = new S_scheduler();
|
e.setStatus(Constants.STATUS_START);
|
e.setStart_time(Long.parseLong(DateUtils.getDateTimeSecondForShow()));
|
this.update(e, "where id=?", new Object[]{id});
|
}
|
|
/**
|
* 调度器（手动）停止，状态更新
|
* @param id
|
*/
|
public void execUpdateSchedulerStopped(int id){
|
S_scheduler e = new S_scheduler();
|
e.setStatus(Constants.STATUS_TERMINATE);
|
e.setEnd_time(Long.parseLong(DateUtils.getDateTimeSecondForShow()));
|
this.update(e, "where id=?", new Object[]{id});
|
}
|
|
/**
|
* 调度器暂停，状态更新
|
* @param id
|
*/
|
public void execUpdateSchedulerPause(int id){
|
S_scheduler e = new S_scheduler();
|
e.setStatus(Constants.STATUS_PAUSE);
|
e.setPause_time(Long.parseLong(DateUtils.getDateTimeSecondForShow()));
|
this.update(e, "where id=?", new Object[]{id});
|
}
|
|
/**
|
* 调度器运行完成，状态更新
|
* @param id
|
*/
|
public void execUpdateSchedulerDone(int id){
|
S_scheduler e = new S_scheduler();
|
e.setStatus(Constants.STATUS_END);
|
e.setEnd_time(Long.parseLong(DateUtils.getDateTimeSecondForShow()));
|
this.update(e, "where id=?", new Object[]{id});
|
}
|
|
public void execTestTransaction(boolean throwError){
|
this.execUpdateSchedulerPause(1);
|
if(throwError){
|
throw new IllegalArgumentException("抛出测试异常，第一条数据应当无法更新");
|
}
|
this.execUpdateSchedulerPause(2);
|
}
|
|
// private static final String SQL_UPD_STATUS_STARTED = "update s_scheduler set status=1, start_time=? where id=?";
|
// private static final String SQL_UPD_STATUS_STOPED = "update s_scheduler set status=-1, end_time=? where id=?";
|
// private static final String SQL_UPD_STATUS_PAUSE = "update s_scheduler set status=2, pause_time=? where id=?";
|
// private static final String SQL_UPD_STATUS_DONE = "update s_scheduler set status=9, end_time=? where id=?";
|
}
|
