package com.xxl.job.admin.controller; import com.xxl.job.admin.core.model.XxlJobGroup; import com.xxl.job.admin.core.model.XxlJobInfo; import com.xxl.job.admin.core.route.ExecutorRouteStrategyEnum; import com.xxl.job.admin.dao.IXxlJobGroupDao; import com.xxl.job.admin.service.IXxlJobService; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.glue.GlueTypeEnum; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import javax.annotation.Resource; import java.util.List; import java.util.Map; /** * index controller * @author xuxueli 2015-12-19 16:13:16 */ @Controller @RequestMapping("/jobinfo") public class JobInfoController { @Resource private IXxlJobGroupDao xxlJobGroupDao; @Resource private IXxlJobService xxlJobService; @RequestMapping public String index(Model model) { // 路由策略-列表 model.addAttribute("ExecutorRouteStrategyEnum", ExecutorRouteStrategyEnum.values()); // Glue类型-字典 model.addAttribute("GlueTypeEnum", GlueTypeEnum.values()); // 任务组 List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("JobGroupList", jobGroupList); return "jobinfo/jobinfo.index"; } @RequestMapping("/pageList") @ResponseBody public Map pageList(@RequestParam(required = false, defaultValue = "0") int start, @RequestParam(required = false, defaultValue = "10") int length, int jobGroup, String executorHandler, String filterTime) { return xxlJobService.pageList(start, length, jobGroup, executorHandler, filterTime); } @RequestMapping("/add") @ResponseBody public ReturnT add(XxlJobInfo jobInfo) { return xxlJobService.add(jobInfo); } @RequestMapping("/reschedule") @ResponseBody public ReturnT reschedule(XxlJobInfo jobInfo) { return xxlJobService.reschedule(jobInfo); } @RequestMapping("/remove") @ResponseBody public ReturnT remove(int id) { return xxlJobService.remove(id); } @RequestMapping("/pause") @ResponseBody public ReturnT pause(int id) { return xxlJobService.pause(id); } @RequestMapping("/resume") @ResponseBody public ReturnT resume(int id) { return xxlJobService.resume(id); } @RequestMapping("/trigger") @ResponseBody public ReturnT triggerJob(int id) { return xxlJobService.triggerJob(id); } }