| ÎļþÃû´Ó ruoyi/src/main/java/com/ruoyi/project/monitor/service/ISysJobService.java ÐÞ¸Ä |
| | |
|---|
| | | package com.ruoyi.project.monitor.service; |
|---|
| | | |
|---|
| | | import java.util.List; |
|---|
| | | import org.quartz.SchedulerException; |
|---|
| | | import com.ruoyi.common.exception.job.TaskException; |
|---|
| | | import com.ruoyi.project.monitor.domain.SysJob; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * å®æ¶ä»»å¡è°åº¦ä¿¡æ¯ä¿¡æ¯ æå¡å± |
|---|
| | | * |
|---|
| | | * @author ruoyi |
|---|
| | | */ |
|---|
| | | public interface ISysJobService |
|---|
| | | { |
|---|
| | | /** |
|---|
| | | * è·åquartzè°åº¦å¨ç计åä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return è°åº¦ä»»å¡éå |
|---|
| | | */ |
|---|
| | | public List<SysJob> selectJobList(SysJob job); |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * éè¿è°åº¦ä»»å¡IDæ¥è¯¢è°åº¦ä¿¡æ¯ |
|---|
| | | * |
|---|
| | | * @param jobId è°åº¦ä»»å¡ID |
|---|
| | | * @return è°åº¦ä»»å¡å¯¹è±¡ä¿¡æ¯ |
|---|
| | | */ |
|---|
| | | public SysJob selectJobById(Long jobId); |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æåä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int pauseJob(SysJob job) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æ¢å¤ä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int resumeJob(SysJob job) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * å é¤ä»»å¡åï¼æ对åºçtriggerä¹å°è¢«å é¤ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int deleteJob(SysJob job) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æ¹éå é¤è°åº¦ä¿¡æ¯ |
|---|
| | | * |
|---|
| | | * @param jobIds éè¦å é¤çä»»å¡ID |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public void deleteJobByIds(Long[] jobIds) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * ä»»å¡è°åº¦ç¶æä¿®æ¹ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int changeStatus(SysJob job) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * ç«å³è¿è¡ä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public void run(SysJob job) throws SchedulerException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æ°å¢ä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int insertJob(SysJob job) throws SchedulerException, TaskException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æ´æ°ä»»å¡ |
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public int updateJob(SysJob job) throws SchedulerException, TaskException; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * æ ¡éªcron表达å¼æ¯å¦ææ |
|---|
| | | * |
|---|
| | | * @param cronExpression è¡¨è¾¾å¼ |
|---|
| | | * @return ç»æ |
|---|
| | | */ |
|---|
| | | public boolean checkCronExpressionIsValid(String cronExpression); |
|---|
| | | } |
|---|
| | | package com.ruoyi.quartz.service;
|
|---|
| | |
|
|---|
| | | import java.util.List;
|
|---|
| | | import org.quartz.SchedulerException;
|
|---|
| | | import com.ruoyi.common.exception.job.TaskException;
|
|---|
| | | import com.ruoyi.quartz.domain.SysJob;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * å®æ¶ä»»å¡è°åº¦ä¿¡æ¯ä¿¡æ¯ æå¡å±
|
|---|
| | | * |
|---|
| | | * @author ruoyi
|
|---|
| | | */
|
|---|
| | | public interface ISysJobService
|
|---|
| | | {
|
|---|
| | | /**
|
|---|
| | | * è·åquartzè°åº¦å¨ç计åä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return è°åº¦ä»»å¡éå
|
|---|
| | | */
|
|---|
| | | public List<SysJob> selectJobList(SysJob job);
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * éè¿è°åº¦ä»»å¡IDæ¥è¯¢è°åº¦ä¿¡æ¯
|
|---|
| | | * |
|---|
| | | * @param jobId è°åº¦ä»»å¡ID
|
|---|
| | | * @return è°åº¦ä»»å¡å¯¹è±¡ä¿¡æ¯
|
|---|
| | | */
|
|---|
| | | public SysJob selectJobById(Long jobId);
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æåä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int pauseJob(SysJob job) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æ¢å¤ä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int resumeJob(SysJob job) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * å é¤ä»»å¡åï¼æ对åºçtriggerä¹å°è¢«å é¤
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int deleteJob(SysJob job) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æ¹éå é¤è°åº¦ä¿¡æ¯
|
|---|
| | | * |
|---|
| | | * @param jobIds éè¦å é¤çä»»å¡ID
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public void deleteJobByIds(Long[] jobIds) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * ä»»å¡è°åº¦ç¶æä¿®æ¹
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int changeStatus(SysJob job) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * ç«å³è¿è¡ä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public void run(SysJob job) throws SchedulerException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æ°å¢ä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int insertJob(SysJob job) throws SchedulerException, TaskException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æ´æ°ä»»å¡
|
|---|
| | | * |
|---|
| | | * @param job è°åº¦ä¿¡æ¯
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public int updateJob(SysJob job) throws SchedulerException, TaskException;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * æ ¡éªcron表达å¼æ¯å¦ææ
|
|---|
| | | * |
|---|
| | | * @param cronExpression 表达å¼
|
|---|
| | | * @return ç»æ
|
|---|
| | | */
|
|---|
| | | public boolean checkCronExpressionIsValid(String cronExpression);
|
|---|
| | | }
|
|---|
