SysJobController.java 7.8 KB
Newer Older
1  
zhangzhen committed
1
package share.quartz.controller;
wuwenlong committed
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185
//
//import java.util.List;
//import javax.servlet.http.HttpServletResponse;
//import org.quartz.SchedulerException;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.security.access.prepost.PreAuthorize;
//import org.springframework.web.bind.annotation.DeleteMapping;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.PathVariable;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.PutMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//import share.common.annotation.Log;
//import share.common.constant.Constants;
//import share.common.core.controller.BaseController;
//import share.common.core.domain.AjaxResult;
//import share.common.core.page.TableDataInfo;
//import share.common.enums.BusinessType;
//import share.common.exception.job.TaskException;
//import share.common.utils.StringUtils;
//import share.common.utils.poi.ExcelUtil;
//import share.quartz.domain.SysJob;
//import share.quartz.service.ISysJobService;
//import share.quartz.util.CronUtils;
//import share.quartz.util.ScheduleUtils;
//
///**
// * 调度任务信息操作处理
// *
// * @author ruoyi
// */
////@RestController
////@RequestMapping("/monitor/job")
//public class SysJobController extends BaseController
//{
////    @Autowired
////    private ISysJobService jobService;
////
////    /**
////     * 查询定时任务列表
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:list')")
////    @GetMapping("/list")
////    public TableDataInfo list(SysJob sysJob)
////    {
////        startPage();
////        List<SysJob> list = jobService.selectJobList(sysJob);
////        return getDataTable(list);
////    }
////
////    /**
////     * 导出定时任务列表
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:export')")
////    @Log(title = "定时任务", businessType = BusinessType.EXPORT)
////    @PostMapping("/export")
////    public void export(HttpServletResponse response, SysJob sysJob)
////    {
////        List<SysJob> list = jobService.selectJobList(sysJob);
////        ExcelUtil<SysJob> util = new ExcelUtil<SysJob>(SysJob.class);
////        util.exportExcel(response, list, "定时任务");
////    }
////
////    /**
////     * 获取定时任务详细信息
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:query')")
////    @GetMapping(value = "/{jobId}")
////    public AjaxResult getInfo(@PathVariable("jobId") Long jobId)
////    {
////        return success(jobService.selectJobById(jobId));
////    }
////
////    /**
////     * 新增定时任务
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:add')")
////    @Log(title = "定时任务", businessType = BusinessType.INSERT)
////    @PostMapping
////    public AjaxResult add(@RequestBody SysJob job) throws SchedulerException, TaskException
////    {
////        if (!CronUtils.isValid(job.getCronExpression()))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,Cron表达式不正确");
////        }
////        else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'rmi'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS }))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'ldap(s)'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'http(s)'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,目标字符串存在违规");
////        }
////        else if (!ScheduleUtils.whiteList(job.getInvokeTarget()))
////        {
////            return error("新增任务'" + job.getJobName() + "'失败,目标字符串不在白名单内");
////        }
////        job.setCreateBy(getUsername());
////        return toAjax(jobService.insertJob(job));
////    }
////
////    /**
////     * 修改定时任务
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:edit')")
////    @Log(title = "定时任务", businessType = BusinessType.UPDATE)
////    @PutMapping
////    public AjaxResult edit(@RequestBody SysJob job) throws SchedulerException, TaskException
////    {
////        if (!CronUtils.isValid(job.getCronExpression()))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,Cron表达式不正确");
////        }
////        else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'rmi'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS }))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'ldap(s)'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'http(s)'调用");
////        }
////        else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,目标字符串存在违规");
////        }
////        else if (!ScheduleUtils.whiteList(job.getInvokeTarget()))
////        {
////            return error("修改任务'" + job.getJobName() + "'失败,目标字符串不在白名单内");
////        }
////        job.setUpdateBy(getUsername());
////        return toAjax(jobService.updateJob(job));
////    }
////
////    /**
////     * 定时任务状态修改
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:changeStatus')")
////    @Log(title = "定时任务", businessType = BusinessType.UPDATE)
////    @PutMapping("/changeStatus")
////    public AjaxResult changeStatus(@RequestBody SysJob job) throws SchedulerException
////    {
////        SysJob newJob = jobService.selectJobById(job.getJobId());
////        newJob.setStatus(job.getStatus());
////        return toAjax(jobService.changeStatus(newJob));
////    }
////
////    /**
////     * 定时任务立即执行一次
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:changeStatus')")
////    @Log(title = "定时任务", businessType = BusinessType.UPDATE)
////    @PutMapping("/run")
////    public AjaxResult run(@RequestBody SysJob job) throws SchedulerException
////    {
////        boolean result = jobService.run(job);
////        return result ? success() : error("任务不存在或已过期!");
////    }
////
////    /**
////     * 删除定时任务
////     */
////    @PreAuthorize("@ss.hasPermi('monitor:job:remove')")
////    @Log(title = "定时任务", businessType = BusinessType.DELETE)
////    @DeleteMapping("/{jobIds}")
////    public AjaxResult remove(@PathVariable Long[] jobIds) throws SchedulerException, TaskException
////    {
////        jobService.deleteJobByIds(jobIds);
////        return success();
////    }
//}